| 311 | } |
| 312 | |
| 313 | void C2Agent::extractPayload(const C2Payload &resp) { |
| 314 | if (resp.getStatus().getState() == state::UpdateState::NESTED) { |
| 315 | for (const C2Payload& payload : resp.getNestedPayloads()) { |
| 316 | extractPayload(payload); |
| 317 | } |
| 318 | return; |
| 319 | } |
| 320 | switch (resp.getStatus().getState()) { |
| 321 | case state::UpdateState::INITIATE: |
| 322 | logger_->log_debug("Received initiation event from protocol"); |
| 323 | break; |
| 324 | case state::UpdateState::READ_COMPLETE: |
| 325 | logger_->log_trace("Received Ack from Server"); |
| 326 | // we have a heartbeat response. |
| 327 | for (const C2ContentResponse &server_response : resp.getContent()) { |
| 328 | handle_c2_server_response(server_response); |
| 329 | } |
| 330 | break; |
| 331 | case state::UpdateState::FULLY_APPLIED: |
| 332 | logger_->log_debug("Received fully applied event from protocol"); |
| 333 | break; |
| 334 | case state::UpdateState::PARTIALLY_APPLIED: |
| 335 | logger_->log_debug("Received partially applied event from protocol"); |
| 336 | break; |
| 337 | case state::UpdateState::NOT_APPLIED: |
| 338 | logger_->log_debug("Received not applied event from protocol"); |
| 339 | break; |
| 340 | case state::UpdateState::SET_ERROR: |
| 341 | logger_->log_debug("Received error event from protocol"); |
| 342 | break; |
| 343 | case state::UpdateState::READ_ERROR: |
| 344 | logger_->log_debug("Received error event from protocol"); |
| 345 | break; |
| 346 | case state::UpdateState::NESTED: // multiple updates embedded into one |
| 347 | |
| 348 | default: |
| 349 | logger_->log_debug("Received nested event from protocol"); |
| 350 | break; |
| 351 | } |
| 352 | } |
| 353 | |
| 354 | void C2Agent::handle_c2_server_response(const C2ContentResponse &resp) { |
| 355 | switch (resp.op) { |
nothing calls this directly
no test coverage detected