client/uiclient.c

/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2025 Olaf Wintermann. All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *   1. Redistributions of source code must retain the above copyright
 *      notice, this list of conditions and the following disclaimer.
 *
 *   2. Redistributions in binary form must reproduce the above copyright
 *      notice, this list of conditions and the following disclaimer in the
 *      documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#include "uiclient.h"
#include "args.h"

#include <cx/hash_map.h>

#include "../ui/common/args.h"

static UiMessageHandler *io;

static CxMap *msg_types;
static CxMap *objects;

void client_init(UiMessageHandler *handler) {
    io = handler;
    
    msg_types = cxHashMapCreateSimple(CX_STORE_POINTERS);
    cxMapPut(msg_types, "simple_window", msg_simple_window);
    cxMapPut(msg_types, "show", msg_show);
    
    cxMapPut(msg_types, "vbox", msg_vbox);
    cxMapPut(msg_types, "hbox", msg_vbox);
    cxMapPut(msg_types, "grid", msg_vbox);
    cxMapPut(msg_types, "end", msg_end);
    cxMapPut(msg_types, "button", msg_button);
    
    objects = cxHashMapCreateSimple(CX_STORE_POINTERS);
}

static cxmutstr jsonobj_getstring(const CxJsonValue *obj, const char *name) {
    CxJsonValue *value = cxJsonObjGet(obj, name);
    if(value->type == CX_JSON_STRING) {
        return value->value.string;
    } else {
        return (cxmutstr){ NULL, 0 };
    }
}

/*
 * UI thread callback
 */
static int msg_received(void *data) {
    CxJsonValue *value = data;
    if(client_handle_json(NULL, value)) {
        fprintf(stderr, "Error: invalid json message\n");
    }
    cxJsonValueFree(value);
    return 0;
}

/*
 * This message callback is executed in the message handler input thread
 */
void client_msg_received(cxmutstr msg) {
    // parse message
    CxJson json;
    cxJsonInit(&json, NULL);
    
    cxJsonFilln(&json, msg.ptr, msg.length);
    CxJsonValue *value;
    if(cxJsonNext(&json, &value) == CX_JSON_NO_ERROR && value) {
        // handle json message in the UI thread
        ui_call_mainthread(msg_received, value);
    } else {
        fprintf(stderr, "Error: invalid json message\n");
    }
    cxJsonDestroy(&json);
}

int client_handle_json(UiObject *obj, const CxJsonValue *value) {
    if(value->type != CX_JSON_OBJECT) {
        return 1;
    }
    
    CxJsonValue *type = cxJsonObjGet(value, "type");
    if(!type || type->type != CX_JSON_STRING) {
        return 1;
    }
    
    json_msg_handler handler = cxMapGet(msg_types, type->value.string);
    if(!handler) {
        return 1;
    }
    
    return handler(obj, value);
}

int client_handle_children(UiObject *parent, const CxJsonValue *value) {
    CxJsonValue *children = cxJsonObjGet(value, "children");
    if(children && children->type == CX_JSON_ARRAY) {
        for(int i=0;i<children->value.array.array_size;i++) {
            CxJsonValue *child = children->value.array.array[i];
            if(client_handle_json(parent, child)) {
                fprintf(stderr, "Error: invalid child\n");
                return 1;
            }
        }
    }
    return 0;
}

void client_add_obj_mapping(UiObject *obj, cxmutstr id) {
    cxMapPut(objects, id, obj);
    
    CxAllocator *a = ui_allocator(obj->ctx);
    
    WindowData *wdata = cxMalloc(a, sizeof(WindowData));
    wdata->widgets = cxHashMapCreate(a, CX_STORE_POINTERS, 128);
    obj->window = wdata;
}

UiObject* client_get_mapped_obj(cxmutstr id) {
    return cxMapGet(objects, id);
}

void client_reg_widget(UiObject *obj, cxmutstr id, UIWIDGET w) {
    WindowData *wdata = obj->window;
    if(!wdata) {
        fprintf(stderr, "Error: missing obj window data\n");
        return;
    }
    cxMapPut(wdata->widgets, id, w);
}

UIWIDGET client_get_widget(UiObject *obj, cxmutstr id) {
    WindowData *wdata = obj->window;
    if(!wdata) {
        fprintf(stderr, "Error: missing obj window data\n");
        return NULL;
    }
    return cxMapGet(wdata->widgets, id);
}

static UiObject* get_msg_obj(UiObject *obj, const CxJsonValue *value) {
    if(obj) {
        return obj;
    }
    CxJsonValue *obj_id = cxJsonObjGet(value, "obj");
    if(!obj_id || obj_id->type != CX_JSON_STRING) {
        return NULL;
    }
    return client_get_mapped_obj(obj_id->value.string);
}

int msg_simple_window(UiObject *parent, const CxJsonValue *value) {
    cxmutstr id = jsonobj_getstring(value, "id");
    cxmutstr title = jsonobj_getstring(value, "title");
    
    if(!id.ptr) {
        return 1;
    }
    
    UiObject *obj = ui_simple_window(title.ptr, NULL);
    client_add_obj_mapping(obj, id);
    
    return client_handle_children(obj, value);
}

int msg_show(UiObject *parent, const CxJsonValue *value) {
    UiObject *obj = client_get_mapped_obj(jsonobj_getstring(value, "obj"));
    if(!obj) {
        return 1;
    }
    ui_show(obj);
    return 0;
}

typedef UIWIDGET(*ctcreate_func)(UiObject *obj, UiContainerArgs *args);

static int msg_container(UiObject *parent, const CxJsonValue *value, ctcreate_func create) {
    CxJsonValue *args_value = cxJsonObjGet(value, "args");
    cxmutstr id = jsonobj_getstring(value, "id");
    if(!id.ptr) {
        return 1;
    }
    UiObject *obj = get_msg_obj(parent, value);
    if(!obj) {
        return 1;
    }
    
    UiContainerArgs *args = json2container_args(args_value);
    UIWIDGET w = create(obj, args);
    ui_container_args_free(args);
    client_reg_widget(obj, id, w);
    
    return 0;
}

int msg_vbox(UiObject *parent, const CxJsonValue *value) {
    return msg_container(parent, value, ui_vbox_create);
}

int msg_hbox(UiObject *parent, const CxJsonValue *value) {
    return msg_container(parent, value, ui_hbox_create);
}

int msg_grid(UiObject *parent, const CxJsonValue *value) {
    return msg_container(parent, value, ui_grid_create);
}

int msg_end(UiObject *parent, const CxJsonValue *value) {
    UiObject *obj = get_msg_obj(parent, value);
    if(!obj) {
        return 1;
    }
    ui_end_new(obj);
    return 0;
}

int msg_button(UiObject *parent, const CxJsonValue *value) {
    CxJsonValue *args_value = cxJsonObjGet(value, "args");
    cxmutstr id = jsonobj_getstring(value, "id");
    if(!id.ptr) {
        return 1;
    }
    UiObject *obj = get_msg_obj(parent, value);
    if(!obj) {
        return 1;
    }
    
    UiButtonArgs *args = json2button_args(args_value);
    UIWIDGET w = ui_button_create(obj, args);
    ui_button_args_free(args);
    client_reg_widget(obj, id, w);
    
    return 0;
}