Synchronize notification to peer node middleware
(router IRoutes, pubSub *p2p.PubSub)
| 32 | |
| 33 | // Synchronize notification to peer node middleware |
| 34 | func PubSubMiddleware(router IRoutes, pubSub *p2p.PubSub) HandlerFunc { |
| 35 | subscribe(router, pubSub) |
| 36 | return func(context *Context) error { |
| 37 | // sync write operate cmd |
| 38 | if context.Op.IsMasterOnly() { |
| 39 | args := make([]string, len(context.Args)) |
| 40 | for k, v := range context.Args { |
| 41 | args[k] = string(v.([]byte)) |
| 42 | } |
| 43 | s, _ := json.Marshal(args) |
| 44 | pubSub.Outbound <- string(s) |
| 45 | // logrus.Info("outbound: ", string(s)) |
| 46 | } |
| 47 | return context.Next() |
| 48 | } |
| 49 | } |
| 50 | |
| 51 | func subscribe(router IRoutes, pubSub *p2p.PubSub) { |
| 52 | utils.GoWithRecover(func() { |
no test coverage detected