(key string, m *v1.Message)
| 339 | } |
| 340 | |
| 341 | func (h *handlerDownside) agentControl(key string, m *v1.Message) error { |
| 342 | if h.agentClient == nil { |
| 343 | h.publishFailedMsg(key, ErrAgentNotSet, m) |
| 344 | return errors.Trace(errors.New(ErrAgentNotSet)) |
| 345 | } |
| 346 | res, err := h.agentClient.GetOrSetAgentFlag(m.Metadata["action"]) |
| 347 | if err != nil { |
| 348 | h.publishFailedMsg(key, err.Error(), m) |
| 349 | return errors.Trace(err) |
| 350 | } |
| 351 | h.log.Debug("agent info", log.Any("status", res)) |
| 352 | response := &v1.Message{ |
| 353 | Kind: v1.MessageCMD, |
| 354 | Metadata: map[string]string{ |
| 355 | "success": "true", |
| 356 | "token": m.Metadata["token"], |
| 357 | "stat": strconv.FormatBool(res), |
| 358 | }, |
| 359 | Content: v1.LazyValue{}, |
| 360 | } |
| 361 | err = h.pb.Publish(sync.TopicUpside, response) |
| 362 | if err != nil { |
| 363 | h.log.Error("failed to publish message", log.Any("topic", sync.TopicUpside), log.Any("chain name", key), log.Error(err)) |
| 364 | } |
| 365 | return nil |
| 366 | } |
| 367 | |
| 368 | func assembleUrl(req *v1.RPCRequest) string { |
| 369 | url := req.App |
no test coverage detected