mod_kazoo/kz_node.c at master · freeswitch/mod_kazoo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
#include "mod_kazoo.h"

static int kz_nodes_module_names_array_callback(void *pArg, const char *module_name)
{
	cJSON *json = (cJSON *) pArg;
	if(!strstr(module_name, "CORE")) {
		cJSON_AddItemToArray(json, cJSON_CreateString(module_name));
	}
	return 0;
}

void kz_nodes_collect_media_role(cJSON *container)
{
	cJSON *retval = NULL;
	if(kz_json_api("sofia.status.info", NULL, &retval) == SWITCH_STATUS_SUCCESS) {
		if(retval != NULL && (!(retval->type & cJSON_NULL))) {
			cJSON_AddItemToObject(container, "Media", cJSON_Duplicate(retval, 1));
		}
	}
	if(retval) {
		cJSON_Delete(retval);
	}
}

void kz_nodes_collect_modules(cJSON *container)
{
	cJSON *modules = cJSON_CreateObject();
	cJSON *loaded = cJSON_CreateArray();
	cJSON *available = cJSON_CreateArray();
	switch_loadable_module_enumerate_available(SWITCH_GLOBAL_dirs.mod_dir, kz_nodes_module_names_array_callback, available);
	switch_loadable_module_enumerate_loaded(kz_nodes_module_names_array_callback, loaded);
	cJSON_AddItemToObject(modules, "available", available);
	cJSON_AddItemToObject(modules, "loaded", loaded);
	cJSON_AddItemToObject(container, "Modules", modules);
}

void kz_nodes_collect_runtime(cJSON *container)
{
	cJSON *retval = NULL;
	if(kz_json_api("status", NULL, &retval) == SWITCH_STATUS_SUCCESS) {
		if(retval != NULL && (!(retval->type & cJSON_NULL))) {
			cJSON *val = cJSON_Duplicate(retval, 1);
			cJSON_AddItemToObject(val, "Core-UUID", cJSON_CreateString(switch_core_get_uuid()));
			cJSON_AddItemToObject(container, "Runtime-Info", val);
		}
	}
	if(retval) {
		cJSON_Delete(retval);
	}
}

void kz_nodes_collect_apps(cJSON *container)
{
	cJSON *apps = cJSON_CreateObject();
	cJSON *app = cJSON_CreateObject();
	cJSON_AddItemToObject(app, "Uptime", cJSON_CreateNumber(switch_core_uptime()));
	cJSON_AddItemToObject(apps, "freeswitch", app);
	cJSON_AddItemToObject(container, "WhApps", apps);
}

void kz_nodes_collect_roles(cJSON *container)
{
	cJSON *roles = cJSON_CreateObject();
	cJSON_AddItemToObject(container, "Roles", roles);
	kz_nodes_collect_media_role(roles);
}

cJSON * kz_node_create()
{
	cJSON *node = cJSON_CreateObject();

	kz_nodes_collect_apps(node);
	kz_nodes_collect_runtime(node);
	kz_nodes_collect_modules(node);
	kz_nodes_collect_roles(node);

	return node;
}

SWITCH_STANDARD_JSON_API(kz_node_info_json_function)
{
	cJSON * ret = kz_node_create();
	*json_reply = ret;
	return SWITCH_STATUS_SUCCESS;
}

void add_kz_node(switch_loadable_module_interface_t **module_interface)
{
	switch_json_api_interface_t *json_api_interface = NULL;
	SWITCH_ADD_JSON_API(json_api_interface, "node.info", "JSON node API", kz_node_info_json_function, "");
}