(routeId string, event wps.WaveEvent)
| 197 | } |
| 198 | |
| 199 | func (router *WshRouter) SendEvent(routeId string, event wps.WaveEvent) { |
| 200 | defer func() { |
| 201 | panichandler.PanicHandler("WshRouter.SendEvent", recover()) |
| 202 | }() |
| 203 | lm := router.getLinkForRoute(routeId) |
| 204 | if lm == nil { |
| 205 | return |
| 206 | } |
| 207 | msg := RpcMessage{ |
| 208 | Command: wshrpc.Command_EventRecv, |
| 209 | Route: routeId, |
| 210 | Data: event, |
| 211 | } |
| 212 | msgBytes, err := json.Marshal(msg) |
| 213 | if err != nil { |
| 214 | // nothing to do |
| 215 | return |
| 216 | } |
| 217 | router.sendRpcMessageToLink(lm.linkId, lm.client, msgBytes, baseds.NoLinkId, "eventrecv") |
| 218 | } |
| 219 | |
| 220 | func (router *WshRouter) handleNoRoute(msg RpcMessage, ingressLinkId baseds.LinkId) { |
| 221 | lm := router.getLinkMeta(ingressLinkId) |
nothing calls this directly
no test coverage detected