cleanup: dont log shutdown errors

Signed-off-by: Sander Pick <[email protected]>

api/server.go

@@ -107,9 +107,10 @@ func NewServer(ctx context.Context, ts tserv.Threadservice, conf Config) (*Serve
  go func() {
  for err := range errc {
  if err != nil {
- log.Errorf("proxy error: %s", err)
  if err == http.ErrServerClosed {
  break
+ } else {
+ log.Errorf("proxy error: %s", err)
  }
  }
  }

eventstore/manager.go

@@ -59,6 +59,9 @@ func NewManager(ts threadservice.Threadservice, opts ...StoreOption) (*Manager,
 
  for res := range q.Next() {
  idStr := ds.RawKey(res.Key).Parent().Parent().Parent().Parent().Name() // reaching for the stars here
+ if idStr == "" {
+ continue
+ }
  id, err := uuid.Parse(idStr)
  if err != nil {
  return nil, err

eventstore/manager_test.go

@@ -55,6 +55,8 @@ func TestManager_GetStore(t *testing.T) {
  err = model.Create(newPerson)
  checkErr(t, err)
  assertPersonInModel(t, model, newPerson)
+ err = store.Start()
+ checkErr(t, err)
 
  // Close it down, restart next
  err = man.Close()

service.go

@@ -279,7 +279,6 @@ func (s *service) subscribe(id thread.ID) {
  for {
  msg, err := sub.Next(s.threads.ctx)
  if err != nil {
- log.Error(err)
  break
  }
 

threads.go

@@ -142,9 +142,10 @@ func NewThreads(
  go func() {
  for err := range errc {
  if err != nil {
- log.Errorf("proxy error: %s", err)
  if err == http.ErrServerClosed {
  break
+ } else {
+ log.Errorf("proxy error: %s", err)
  }
  }
  }