| 5139 | } |
| 5140 | |
| 5141 | func (c *unixSocketClient) AgentChannelReply( |
| 5142 | ctx context.Context, |
| 5143 | request AgentChannelReplyRequest, |
| 5144 | credentials agentidentity.Credentials, |
| 5145 | ) (AgentChannelMessageRecord, error) { |
| 5146 | var response contract.AgentChannelMessageResponse |
| 5147 | if err := c.doAgentJSON( |
| 5148 | ctx, |
| 5149 | http.MethodPost, |
| 5150 | "/api/agent/channels/reply", |
| 5151 | nil, |
| 5152 | request, |
| 5153 | credentials, |
| 5154 | &response, |
| 5155 | ); err != nil { |
| 5156 | return AgentChannelMessageRecord{}, err |
| 5157 | } |
| 5158 | return response.Message, nil |
| 5159 | } |
| 5160 | |
| 5161 | func (c *unixSocketClient) AgentTaskClaimNext( |
| 5162 | ctx context.Context, |