handleResponse()

void handleResponse

(

const fl::json &

response

)

Definition at line 192 of file RpcClient.ino.

                                            {
    // Check if this is our expected response
    if (response.contains("id")) {
        const fl::json& idJson = response["id"];
        if (idJson.is_number()) {
            auto idOpt = idJson.as_int();
            if (idOpt) {
                int id = *idOpt;
                if (id != expectedRequestId) {
                    fl::printf("Warning: Received response for ID %d, expected %d\n", id, expectedRequestId);
                }
            }
        }
    }
 
    // Check for error
    if (response.contains("error")) {
        Serial.println("ERROR Response:");
        Serial.println(response.to_string().c_str());
        waitingForResponse = false;
        return;
    }
 
    // Check for ACK (ASYNC/ASYNC_STREAM modes)
    if (response.contains("result")) {
        const fl::json& result = response["result"];
 
        if (result.contains("ack")) {
            auto ackOpt = result["ack"].as_bool();
            if (ackOpt && *ackOpt == true) {
                Serial.println("Received ACK - request accepted");
                return; // Wait for actual result
            }
        }
 
        // Check for streaming update (ASYNC_STREAM mode)
        if (result.contains("update")) {
            auto updateOpt = result["update"].as_int();
            if (updateOpt) {
                int update = *updateOpt;
                fl::printf("Received update: %d\n", update);
 
                // Visual feedback: show progress on LEDs
                int ledIndex = (update % NUM_LEDS);
                leds[ledIndex] = CRGB::Blue;
                FastLED.show();
            }
            return; // Wait for more updates or final
        }
 
        // Check for final result (ASYNC_STREAM mode)
        if (result.contains("stop")) {
            auto stopOpt = result["stop"].as_bool();
            if (stopOpt && *stopOpt == true) {
                if (result.contains("value")) {
                    Serial.print("Received FINAL result: ");
                    Serial.println(result["value"].to_string().c_str());
                } else {
                    Serial.println("Received FINAL marker (no value)");
                }
                waitingForResponse = false;
                return;
            }
        }
 
        // Regular result (SYNC or ASYNC final)
        Serial.print("Received result: ");
        Serial.println(result.to_string().c_str());
        waitingForResponse = false;
    } else {
        Serial.println("Received response without result:");
        Serial.println(response.to_string().c_str());
    }
}

References fl::json::as_int(), fl::CRGB::Blue, expectedRequestId, FastLED, fl::json::is_number(), leds, NUM_LEDS, fl::printf(), Serial, and waitingForResponse.

Referenced by loop().

Here is the call graph for this function:

Here is the caller graph for this function: