fix: fix merge conflict

RSS3-Network · Sep 14, 2024 · 74ac0db · 74ac0db
1 parent 581ce97
commit 74ac0db
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 7 deletions.
diff --git a/internal/engine/source/factory.go b/internal/engine/source/factory.go
@@ -28,8 +28,6 @@ func New(config *config.Module, sourceFilter engine.DataSourceFilter, checkpoint
 		return activitypub.NewSource(config, checkpoint, databaseClient)
 	case network.NearSource:
 		return near.NewSource(config, sourceFilter, checkpoint, redisClient)
-	case network.ActivityPubSource:
-		return activitypub.NewSource(config, checkpoint, databaseClient)
 	default:
 		return nil, fmt.Errorf("unsupported network source %s", config.Network)
 	}

diff --git a/internal/engine/worker/decentralized/core/worker.go b/internal/engine/worker/decentralized/core/worker.go
@@ -21,12 +21,8 @@ func NewWorker(config *config.Module, redisClient rueidis.Client) (engine.Worker
 		return mastodon.NewWorker()
 	case network.EthereumSource:
 		return ethereum.NewWorker(config, redisClient)
-	case network.ActivityPubSource:
-		return mastodon.NewWorker()
 	case network.ArweaveSource:
 		return arweave.NewWorker(config)
-	case network.EthereumSource:
-		return ethereum.NewWorker(config, redisClient)
 	case network.FarcasterSource:
 		return farcaster.NewWorker()
 	case network.NearSource:

diff --git a/internal/node/indexer/server.go b/internal/node/indexer/server.go
@@ -15,7 +15,7 @@ import (
 	"github.com/rss3-network/node/internal/engine"
 	"github.com/rss3-network/node/internal/engine/source"
 	decentralizedWorker "github.com/rss3-network/node/internal/engine/worker/decentralized"
-	worker "github.com/rss3-network/node/internal/engine/worker/decentralized"
+	// worker "github.com/rss3-network/node/internal/engine/worker/decentralized"
 	federatedWorker "github.com/rss3-network/node/internal/engine/worker/federated"
 	"github.com/rss3-network/node/internal/node/monitor"
 	"github.com/rss3-network/node/internal/stream"