#include <stdlib.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include <amxd/amxd_dm.h>
#include <amxd/amxd_object.h>
#include <amxd/amxd_object_function.h>
#include <amxb/amxb_be.h>
#include <amxo/amxo.h>
#include "dummy_be.h"
#include <amxc/amxc_macros.h>

Functions
static void	amxb_dummy_send_notification (const char const sig_name, const amxc_var_t const data, void *const priv)

static void	amxb_dummy_free_subscription (UNUSED const char key, amxc_htable_it_t it)

static void *	amxb_dummy_connect (UNUSED const char host, UNUSED const char port, UNUSED const char path, UNUSED amxp_signal_mngr_t sigmngr)

static int	amxb_dummy_disconnect (UNUSED void *ctx)

static int	amxb_dummy_invoke (UNUSED void const ctx, amxb_invoke_t invoke_ctx, amxc_var_t args, amxb_request_t request, UNUSED int timeout)

static void	amxb_dummy_free (UNUSED void *ctx)

static int	amxb_dummy_register (UNUSED void const ctx, UNUSED amxd_dm_t const dm)

static bool	amxb_dummy_has (UNUSED void const ctx, const char object)

static uint32_t	amxb_dummy_capabilities (UNUSED void *const ctx)

static int	amxb_dummy_subscribe (UNUSED void const ctx, const char object)

static int	amxb_dummy_unsubscribe (UNUSED void const ctx, const char object)

int	test_register_dummy_be (void)

int	test_unregister_dummy_be (void)

int	test_load_dummy_remote (const char *odl)

void	test_set_dummy_caps (uint32_t dummy_caps)

amxd_dm_t *	test_get_dm (void)

amxo_parser_t *	test_get_parser (void)

Variables
static amxd_dm_t	remote_dm

static amxo_parser_t	parser

static uint32_t	caps = AMXB_BE_DISCOVER_DESCRIBE \| AMXB_BE_DISCOVER_LIST \| AMXB_BE_DISCOVER

static amxp_signal_mngr_t *	dummy_sigmngr = NULL

static amxc_htable_t	subscriptions

static amxb_be_funcs_t	amxb_dummy_impl

static amxb_version_t	sup_min_lib_version

static amxb_version_t	sup_max_lib_version

static amxb_version_t	dummy_be_version

amxb_be_info_t	amxb_dummy_be_info

Function Documentation

◆ amxb_dummy_capabilities()

static uint32_t amxb_dummy_capabilities ( UNUSED void *const ctx )

static

Definition at line 158 of file dummy_be.c.

                                                                 {
     return caps;
 }

◆ amxb_dummy_connect()

static void* amxb_dummy_connect	(	UNUSED const char *	host,
		UNUSED const char *	port,
		UNUSED const char *	path,
		UNUSED amxp_signal_mngr_t *	sigmngr
	)

static

Definition at line 94 of file dummy_be.c.

                                                                     {
  
     amxd_dm_init(&remote_dm);
     amxo_parser_init(&parser);
     dummy_sigmngr = sigmngr;
     return &remote_dm;
 }

◆ amxb_dummy_disconnect()

static int amxb_dummy_disconnect ( UNUSED void * ctx )

static

Definition at line 105 of file dummy_be.c.

                                                    {
     amxd_dm_clean(&remote_dm);
     dummy_sigmngr = NULL;
     return 0;
 }

◆ amxb_dummy_free()

static void amxb_dummy_free ( UNUSED void * ctx )

static

Definition at line 141 of file dummy_be.c.

                                               {
     amxo_parser_clean(&parser);
     amxd_dm_clean(&remote_dm);
 }

◆ amxb_dummy_free_subscription()

static void amxb_dummy_free_subscription	(	UNUSED const char *	key,
		amxc_htable_it_t *	it
	)

static

Definition at line 90 of file dummy_be.c.

                                                                                        {
     free(it);
 }

◆ amxb_dummy_has()

static bool amxb_dummy_has	(	UNUSED void *const	ctx,
		const char *	object
	)

static

Definition at line 151 of file dummy_be.c.

                                                {
     amxd_object_t* obj = amxd_dm_findf(&remote_dm, "%s", object);
  
     return obj != NULL;
 }

◆ amxb_dummy_invoke()

static int amxb_dummy_invoke	(	UNUSED void *const	ctx,
		amxb_invoke_t *	invoke_ctx,
		amxc_var_t *	args,
		amxb_request_t *	request,
		UNUSED int	timeout
	)

static

Definition at line 111 of file dummy_be.c.

                                                  {
  
     amxc_var_t empty_args;
     amxc_var_t* return_value = NULL;
     amxc_var_init(&empty_args);
     amxc_var_set_type(&empty_args, AMXC_VAR_ID_HTABLE);
     amxc_var_set_type(request->result, AMXC_VAR_ID_LIST);
  
     int rv = 0;
  
     if(args == NULL) {
         args = &empty_args;
     }
  
     return_value = amxc_var_add_new(request->result);
     amxd_object_t* obj = amxd_dm_findf(&remote_dm, invoke_ctx->object);
     if(obj == NULL) {
         rv = amxd_status_invalid_path;
     } else {
         rv = amxd_object_invoke_function(obj, invoke_ctx->method, args, return_value);
     }
  
     amxc_var_clean(&empty_args);
     return rv;
 }

◆ amxb_dummy_register()

static int amxb_dummy_register	(	UNUSED void *const	ctx,
		UNUSED amxd_dm_t *const	dm
	)

static

Definition at line 146 of file dummy_be.c.

                                                            {
     return 0;
 }

◆ amxb_dummy_send_notification()

static void amxb_dummy_send_notification	(	const char *const	sig_name,
		const amxc_var_t *const	data,
		void *const	priv
	)

static

Definition at line 74 of file dummy_be.c.

                                                            {
     amxc_var_t notification;
     amxc_htable_it_t* it = (amxc_htable_it_t*) priv;
     amxc_var_init(&notification);
     amxc_var_set_type(&notification, AMXC_VAR_ID_HTABLE);
  
     amxc_var_copy(&notification, data);
     amxc_var_add_key(cstring_t, &notification, "notification", sig_name);
  
     amxp_sigmngr_emit_signal(dummy_sigmngr, amxc_htable_it_get_key(it), &notification);
  
     amxc_var_clean(&notification);
 }

◆ amxb_dummy_subscribe()

static int amxb_dummy_subscribe	(	UNUSED void *const	ctx,
		const char *	object
	)

static

Definition at line 162 of file dummy_be.c.

                                                     {
  
     int retval = 0;
     amxc_string_t expression;
     amxc_htable_it_t* it = NULL;
  
     amxc_string_init(&expression, 0);
  
     when_failed(retval, exit);
  
     it = (amxc_htable_it_t*) calloc(1, sizeof(amxc_htable_it_t));
     amxc_htable_insert(&subscriptions, object, it);
     amxc_string_appendf(&expression, "path starts with \"%s.\"", object);
     amxp_slot_connect_filtered(&remote_dm.sigmngr,
                                ".*",
                                amxc_string_get(&expression, 0),
                                amxb_dummy_send_notification,
                                it);
  
 exit:
     amxc_string_clean(&expression);
     return retval;
 }

◆ amxb_dummy_unsubscribe()

static int amxb_dummy_unsubscribe	(	UNUSED void *const	ctx,
		const char *	object
	)

static

Definition at line 187 of file dummy_be.c.

                                                       {
     amxc_htable_it_t* it = amxc_htable_get(&subscriptions, object);
     if(it != NULL) {
         amxp_slot_disconnect_with_priv(&remote_dm.sigmngr, amxb_dummy_send_notification, it);
     }
     amxc_htable_it_clean(it, amxb_dummy_free_subscription);
  
     return 0;
 }

◆ test_get_dm()

amxd_dm_t* test_get_dm ( void )

Definition at line 264 of file dummy_be.c.

                              {
     return &remote_dm;
 }

◆ test_get_parser()

amxo_parser_t* test_get_parser ( void )

Definition at line 268 of file dummy_be.c.

                                      {
     return &parser;
 }

◆ test_load_dummy_remote()

int test_load_dummy_remote ( const char * odl )

Definition at line 254 of file dummy_be.c.

                                             {
     amxd_object_t* root_obj = amxd_dm_get_root(&remote_dm);
  
     return amxo_parser_parse_file(&parser, odl, root_obj);
 }

◆ test_register_dummy_be()

int test_register_dummy_be ( void )

Definition at line 244 of file dummy_be.c.

                                  {
     amxc_htable_init(&subscriptions, 5);
     return amxb_be_register(&amxb_dummy_impl);
 }

◆ test_set_dummy_caps()

void test_set_dummy_caps ( uint32_t dummy_caps )

Definition at line 260 of file dummy_be.c.

                                               {
     caps = dummy_caps;
 }

◆ test_unregister_dummy_be()

int test_unregister_dummy_be ( void )

Definition at line 249 of file dummy_be.c.

                                    {
     amxc_htable_clean(&subscriptions, amxb_dummy_free_subscription);
     return amxb_be_unregister(&amxb_dummy_impl);
 }

Variable Documentation

◆ amxb_dummy_be_info

amxb_be_info_t amxb_dummy_be_info

Initial value:

= {
    .min_supported = &sup_min_lib_version,
    .max_supported = &sup_max_lib_version,
    .be_version = &dummy_be_version,
    .name = "dummy",
    .description = "AMXB Dummy Backend for testing",
    .funcs = &amxb_dummy_impl,
}

Definition at line 235 of file dummy_be.c.

◆ amxb_dummy_impl

amxb_be_funcs_t amxb_dummy_impl

static

Initial value:

= {
    .connect = amxb_dummy_connect,
    .disconnect = amxb_dummy_disconnect,
    .get_fd = NULL,
    .read = NULL,
    .invoke = amxb_dummy_invoke,
    .async_invoke = NULL,
    .wait_request = NULL,
    .close_request = NULL,
    .subscribe = amxb_dummy_subscribe,
    .unsubscribe = amxb_dummy_unsubscribe,
    .free = amxb_dummy_free,
    .register_dm = amxb_dummy_register,
    .has = amxb_dummy_has,
    .capabilities = amxb_dummy_capabilities,
    .name = "dummy",
    .size = sizeof(amxb_be_funcs_t),
}

Definition at line 198 of file dummy_be.c.

◆ caps

uint32_t caps = AMXB_BE_DISCOVER_DESCRIBE | AMXB_BE_DISCOVER_LIST | AMXB_BE_DISCOVER

static

Definition at line 70 of file dummy_be.c.

◆ dummy_be_version

amxb_version_t dummy_be_version

static

Initial value:

= {
    .major = 0,
    .minor = 0,
    .build = 0,
}

Definition at line 229 of file dummy_be.c.

◆ dummy_sigmngr

amxp_signal_mngr_t* dummy_sigmngr = NULL

static

Definition at line 71 of file dummy_be.c.

◆ parser

amxo_parser_t parser

static

Definition at line 69 of file dummy_be.c.

◆ remote_dm

amxd_dm_t remote_dm

static

Definition at line 68 of file dummy_be.c.

◆ subscriptions

amxc_htable_t subscriptions

static

Definition at line 72 of file dummy_be.c.

◆ sup_max_lib_version

amxb_version_t sup_max_lib_version

static

Initial value:

= {
    .major = 2,
    .minor = -1,
    .build = -1
}

Definition at line 223 of file dummy_be.c.

◆ sup_min_lib_version

amxb_version_t sup_min_lib_version

static

Initial value:

= {
    .major = 2,
    .minor = 0,
    .build = -1
}

Definition at line 217 of file dummy_be.c.

Functions

Variables

Function Documentation

◆ amxb_dummy_capabilities()

◆ amxb_dummy_connect()

◆ amxb_dummy_disconnect()

◆ amxb_dummy_free()

◆ amxb_dummy_free_subscription()

◆ amxb_dummy_has()

◆ amxb_dummy_invoke()

◆ amxb_dummy_register()

◆ amxb_dummy_send_notification()

◆ amxb_dummy_subscribe()

◆ amxb_dummy_unsubscribe()

◆ test_get_dm()

◆ test_get_parser()

◆ test_load_dummy_remote()

◆ test_register_dummy_be()

◆ test_set_dummy_caps()

◆ test_unregister_dummy_be()

Variable Documentation

◆ amxb_dummy_be_info

◆ amxb_dummy_impl

◆ caps

◆ dummy_be_version

◆ dummy_sigmngr

◆ parser

◆ remote_dm

◆ subscriptions

◆ sup_max_lib_version

◆ sup_min_lib_version