/* PipeWire AGL Cluster IPC
 *
 * Copyright © 2021 Collabora Ltd.
 *    @author Julian Bouzas <julian.bouzas@collabora.com>
 *
 * SPDX-License-Identifier: MIT
 */

#include <alloca.h>
#include "private.h"
#include "protocol.h"
#include "sender.h"
#include "client.h"

#define BUFFER_SIZE 1024

static void on_lost_connection(
                struct icipc_sender *self,
                int receiver_fd,
                void *data) {
        icipc_log_warn("client: lost connection with server %d", receiver_fd);
}

/* API */

struct icipc_client *icipc_client_new(const char *path, bool connect) {
        struct icipc_sender *base;
        base = icipc_sender_new(path, BUFFER_SIZE, on_lost_connection, NULL, 0);

        if (connect)
                icipc_sender_connect(base);

        return (struct icipc_client *)base;
}

void icipc_client_free(struct icipc_client *self) {
        struct icipc_sender *base = icipc_client_to_sender(self);
        icipc_sender_free(base);
}

bool icipc_client_send_request(
                struct icipc_client *self,
                const char *name,
                const struct icipc_data *args,
                icipc_sender_reply_func_t reply,
                void *data) {
        struct icipc_sender *base = icipc_client_to_sender(self);

        /* check params */
        if (name == NULL)
                return false;

        const size_t size = icipc_protocol_calculate_request_size(name, args);
        uint8_t *buffer = alloca(size);
        icipc_protocol_build_request(buffer, size, name, args);
        return icipc_sender_send(base, buffer, size, reply, data);
}

const struct icipc_data *icipc_client_send_request_finish(
                struct icipc_sender *self,
                const uint8_t * buffer,
                size_t size,
                const char **error) {
        /* error */
        if (icipc_protocol_is_reply_error(buffer, size)) {
                icipc_protocol_parse_reply_error(buffer, size, error);
                return NULL;
        }

        /* ok */
        if (icipc_protocol_is_reply_ok(buffer, size)) {
                const struct icipc_data *value = NULL;
                if (icipc_protocol_parse_reply_ok(buffer, size, &value))
                        return value;
        }

        return NULL;
}