Skip to content

Commit

Permalink
Merge pull request ssbc#264 from KyleMaas/try-to-fix-migrate-test
Browse files Browse the repository at this point in the history
Fix TestMigrate
  • Loading branch information
decentral1se authored Dec 18, 2022
2 parents 1986947 + 7f77540 commit 7bd9543
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 7 deletions.
6 changes: 0 additions & 6 deletions cmd/gossb-migrate-mf/migrate/migrate_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ import (

"github.com/ssbc/go-metafeed/metakeys"
refs "github.com/ssbc/go-ssb-refs"
"github.com/ssbc/go-ssb/internal/testutils"
"github.com/ssbc/go-ssb/sbot"
"github.com/stretchr/testify/require"
)
Expand Down Expand Up @@ -41,11 +40,6 @@ func TestMigrationSentinel(t *testing.T) {
}

func TestMigrate(t *testing.T) {
if testutils.SkipOnCI(t) {
// https://github.com/ssbc/go-ssb/pull/167
return
}

/* setup start */
var err error
r := require.New(t)
Expand Down
3 changes: 2 additions & 1 deletion plugins/gossip/feed_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"io"
"math"
"sync"
"strings"

"github.com/go-kit/kit/metrics"
"github.com/ssbc/go-luigi"
Expand Down Expand Up @@ -104,7 +105,7 @@ func (m *FeedManager) serveLiveFeeds() {
}

err = luigi.Pump(m.rootCtx, luigi.FuncSink(m.pour), src)
if err != nil && err != ssb.ErrShuttingDown && err != context.Canceled {
if err != nil && err != ssb.ErrShuttingDown && err != context.Canceled && !strings.HasSuffix(err.Error(), "file already closed") {
err = fmt.Errorf("error while serving live feed: %w", err)
panic(err)
}
Expand Down

0 comments on commit 7bd9543

Please sign in to comment.