func SyncAgent(req *entities.SyncRequest, clientPayload *entities.ClientPayload) (entities.SyncResponse, error) {.

incomingSubnetC, ok := (*mainCtx).Value(constants.IncomingSubnetEventChId).(*chan *entities.Event) if !ok { logger.Errorf("incomingSubnetC closed") return } for { event, ok := <-*incomingSubnetC if !ok { logger.Fatal("incomingSubnetC closed for read") return } go service.HandleNewPubSubSubnetEvent(event, ctx) } }.

incomingTopicC, ok := (*mainCtx).Value(constants.IncomingTopicEventChId).(*chan *entities.Event) if !ok { logger.Errorf("incomingTopicC closed") return } for { event, ok := <-*incomingTopicC if !ok { logger.Fatal("incomingTopicC closed for read") return } go service.HandleNewPubSubTopicEvent(event, ctx) } }.

incomingWalletC, ok := (*mainCtx).Value(constants.IncomingWalletEventChId).(*chan *entities.Event) if !ok { logger.Errorf("incomingWalletC closed") return } for { event, ok := <-*incomingWalletC if !ok { logger.Fatal("incomingWalletC closed for read") return } go service.HandleNewPubSubWalletEvent(event, ctx) } }.