| 1052 | } |
| 1053 | |
| 1054 | bool AgentClient::handle_tasker_wait(const json::value& j) |
| 1055 | { |
| 1056 | if (!j.is<TaskerWaitReverseRequest>()) { |
| 1057 | return false; |
| 1058 | } |
| 1059 | const TaskerWaitReverseRequest& req = j.as<TaskerWaitReverseRequest>(); |
| 1060 | LogFunc << VAR(req) << VAR(ipc_addr_); |
| 1061 | MaaTasker* tasker = query_tasker(req.tasker_id); |
| 1062 | if (!tasker) { |
| 1063 | LogError << "tasker not found" << VAR(req.tasker_id); |
| 1064 | return false; |
| 1065 | } |
| 1066 | MaaStatus status = tasker->wait(req.task_id); |
| 1067 | TaskerWaitReverseResponse resp { |
| 1068 | .status = status, |
| 1069 | }; |
| 1070 | send(resp); |
| 1071 | return true; |
| 1072 | } |
| 1073 | |
| 1074 | bool AgentClient::handle_tasker_running(const json::value& j) |
| 1075 | { |