| 1032 | } |
| 1033 | |
| 1034 | bool AgentClient::handle_tasker_status(const json::value& j) |
| 1035 | { |
| 1036 | if (!j.is<TaskerStatusReverseRequest>()) { |
| 1037 | return false; |
| 1038 | } |
| 1039 | const TaskerStatusReverseRequest& req = j.as<TaskerStatusReverseRequest>(); |
| 1040 | LogFunc << VAR(req) << VAR(ipc_addr_); |
| 1041 | MaaTasker* tasker = query_tasker(req.tasker_id); |
| 1042 | if (!tasker) { |
| 1043 | LogError << "tasker not found" << VAR(req.tasker_id); |
| 1044 | return false; |
| 1045 | } |
| 1046 | MaaStatus status = tasker->status(req.task_id); |
| 1047 | TaskerStatusReverseResponse resp { |
| 1048 | .status = status, |
| 1049 | }; |
| 1050 | send(resp); |
| 1051 | return true; |
| 1052 | } |
| 1053 | |
| 1054 | bool AgentClient::handle_tasker_wait(const json::value& j) |
| 1055 | { |