Forwarder: set static channel name in AppSync mapper

warp-contracts · May 21, 2024 · 9fbb193 · 9fbb193
1 parent b13f65d
commit 9fbb193
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/forward/mappers.go b/src/forward/mappers.go
@@ -46,6 +46,8 @@ func appSyncMapper(config *config.Config, channelName string, forContract bool)
 	return task.NewMapper[*Payload, *publisher.AppSyncPayload[*model.InteractionNotification]](config, "map-appsync-notification").
 		WithWorkerPool(1, config.Contract.StoreBatchSize).
 		WithProcessFunc(func(data *Payload, out chan *publisher.AppSyncPayload[*model.InteractionNotification]) (err error) {
+			channelName := channelName
+
 			// Neglect empty messages
 			if data.Interaction == nil {
 				return nil