/*
 *  Copyright 2019 Gregory Meyer
 *
 *  Permission is hereby granted, free of charge, to any person
 *  obtaining a copy of this software and associated documentation
 *  files (the "Software"), to deal in the Software without
 *  restriction, including without limitation the rights to use, copy,
 *  modify, merge, publish, distribute, sublicense, and/or sell copies
 *  of the Software, and to permit persons to whom the Software is
 *  furnished to do so, subject to the following conditions:
 *
 *  The above copyright notice and this permission notice shall be
 *  included in all copies or substantial portions of the Software.
 *
 *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 *  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 *  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
 *  BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 *  ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 *  CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 *  SOFTWARE.
 */

#ifndef SRM_CORE_H
#define SRM_CORE_H

#include <srm/msg.h>
#include <srm/util.h>
#include <srm/types.h>

#include <assert.h>

#ifdef __cplusplus
extern "C" {
#endif

struct SrmCore {
    const void *impl_ptr;
    const SrmCoreVtbl *vptr;
};

struct SrmPublisher {
    void *impl_ptr;
    const SrmPublisherVtbl *vptr;
};

struct SrmSubscriber {
    void *impl_ptr;
    const SrmSubscriberVtbl *vptr;
};

struct SrmSubscribeParams {
    SrmMsgType msg_type;
    SrmStrView topic;
    SrmSubscribeCallback callback;
    void *arg;
};

struct SrmAdvertiseParams {
    SrmMsgType msg_type;
    SrmStrView topic;
};

typedef enum SrmParamType {
    SRM_INTEGER,
    SRM_BOOLEAN,
    SRM_REAL,
    SRM_STRING
} SrmParamType;

struct SrmCoreVtbl {
    SrmStrView (*get_type)(const void*);

    int (*subscribe)(const void*, SrmSubscribeParams, SrmSubscriber*);
    int (*advertise)(const void*, SrmAdvertiseParams, SrmPublisher*);

    SrmStrView (*get_err_msg)(const void*, int);

    int (*log_error)(const void*, SrmStrView);
    int (*log_warn)(const void*, SrmStrView);
    int (*log_info)(const void*, SrmStrView);
    int (*log_debug)(const void*, SrmStrView);
    int (*log_trace)(const void*, SrmStrView);

    int (*param_type)(const void*, SrmStrView, int*);

    int (*param_seti)(const void*, SrmStrView, ptrdiff_t);
    int (*param_geti)(const void*, SrmStrView, ptrdiff_t*);
    int (*param_swapi)(const void*, SrmStrView, ptrdiff_t, ptrdiff_t*);

    int (*param_setb)(const void*, SrmStrView, int);
    int (*param_getb)(const void*, SrmStrView, int*);
    int (*param_swapb)(const void*, SrmStrView, int, int*);

    int (*param_setr)(const void*, SrmStrView, double);
    int (*param_getr)(const void*, SrmStrView, double*);
    int (*param_swapr)(const void*, SrmStrView, double, double*);

    int (*param_sets)(const void*, SrmStrView, SrmStrView);
    int (*param_gets)(const void*, SrmStrView, SrmString*);
    int (*param_swaps)(const void*, SrmStrView, SrmStrView, SrmString*);
};

struct SrmSubscriberVtbl {
    SrmStrView (*get_channel_name)(const void*);
    SrmMsgType (*get_channel_type)(const void*);
    int (*disconnect)(void*);
    SrmStrView (*get_err_msg)(const void*, int);
};

struct SrmPublisherVtbl {
    SrmStrView (*get_channel_name)(const void*);
    SrmMsgType (*get_channel_type)(const void*);
    int (*publish)(void*, SrmPublishFn, void*);
    int (*disconnect)(void*);
    SrmStrView (*get_err_msg)(const void*, int);
};

#ifdef __cplusplus
} // extern "C"
#endif

#endif