Forwarder: fix in AppSync publishing

warp-contracts · May 17, 2024 · 789be71 · 789be71
1 parent b0568ab
commit 789be71
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/src/forward/controller.go b/src/forward/controller.go
@@ -85,11 +85,9 @@ func NewController(config *config.Config) (self *Controller, err error) {
 			WithInputChannel(appSyncMapper.Output)
 
 		return task.NewTask(config, "watched").
-			WithSubtask(duplicator.Task).
 			WithSubtask(redisDuplicator.Task).
 			WithSubtaskSlice(redisPublishers).
-			WithSubtask(appSyncPublisher.Task).
-			WithSubtask(appSyncMapper.Task)
+			WithSubtask(appSyncPublisher.Task)
 	}
 
 	watchdog := task.NewWatchdog(config).
@@ -112,6 +110,9 @@ func NewController(config *config.Config) (self *Controller, err error) {
 		WithSubtask(fetcher.Task).
 		WithSubtask(watchdog.Task).
 		WithSubtask(interactionStreamer.Task).
-		WithSubtask(server.Task)
+		WithSubtask(server.Task).
+		WithSubtask(duplicator.Task).
+		WithSubtask(appSyncMapper.Task)
+
 	return
 }
diff --git a/src/utils/config/forwarder.go b/src/utils/config/forwarder.go
@@ -43,7 +43,7 @@ func setForwarderDefaults() {
 	viper.SetDefault("Forwarder.FetcherLastSortKeySettingBlockHeight", "0")
 	viper.SetDefault("Forwarder.FetcherLastSortKeySettingEnabled", "true")
 	viper.SetDefault("Forwarder.FetcherBatchSize", "10")
-	viper.SetDefault("Forwarder.PublisherRedisChannelName", "interactions")
+	viper.SetDefault("Forwarder.PublisherRedisChannelName", "contracts")
 	viper.SetDefault("Forwarder.PublisherAppSyncChannelName", "interactions")
 	viper.SetDefault("Forwarder.HeightDelay", "1s")
 	viper.SetDefault("Forwarder.ArweaveFetcherQueueSize", "3000")

diff --git a/src/utils/publisher/app-sync.go b/src/utils/publisher/app-sync.go
@@ -23,7 +23,7 @@ const mutation = `mutation Publish($data: AWSJSON!, $name: String!) {
 	}
   }`
 
-// Forwards messages to Redis
+// Forwards messages to AppSync
 type AppSyncPublisher[In encoding.BinaryMarshaler] struct {
 	*task.Task