InitBadgeStore subscribes to incoming badge events.
()
| 29 | |
| 30 | // InitBadgeStore subscribes to incoming badge events. |
| 31 | func InitBadgeStore() error { |
| 32 | log.Printf("initializing badge store\n") |
| 33 | |
| 34 | rpcClient := wshclient.GetBareRpcClient() |
| 35 | rpcClient.EventListener.On(wps.Event_Badge, handleBadgeEvent) |
| 36 | wshclient.EventSubCommand(rpcClient, wps.SubscriptionRequest{ |
| 37 | Event: wps.Event_Badge, |
| 38 | AllScopes: true, |
| 39 | }, nil) |
| 40 | |
| 41 | return nil |
| 42 | } |
| 43 | |
| 44 | func handleBadgeEvent(event *wps.WaveEvent) { |
| 45 | if event.Event != wps.Event_Badge { |
no test coverage detected