Function mi_fs_subscribe

modules/freeswitch_scripting/fss_mod.c:248–329

fs_subscribe 10.0.0.10 DTMF HEARTBEAT CHANNEL_STATE FOO ... */

/* fs_subscribe 10.0.0.10 DTMF HEARTBEAT CHANNEL_STATE FOO ... */
mi_response_t *mi_fs_subscribe(const mi_params_t *params,
								struct mi_handler *async_hdl)
{
	mi_response_t *resp = NULL;
	mi_item_t *events;
	str event_str;
	int i, no_events;
	str_list *evlist = NULL, *li, **last = &evlist;
	fs_evs *sock;
	str url;

	if (get_mi_string_param(params, "freeswitch_url", &url.s, &url.len) < 0)
		return init_mi_param_error();

	sock = fs_api.get_evs_by_url(&url);
	if (!sock) {
		LM_ERR("failed to get a socket for FS URL %.*s\n", url.len, url.s);
		return init_mi_error(500, MI_SSTR("Internal Error"));
	}

	lock_start_write(db_reload_lk);

	if (find_evs(sock) != 0) {
		if (add_evs(sock) != 0) {
			lock_stop_write(db_reload_lk);
			fs_api.put_evs(sock);
			LM_ERR("failed to ref socket\n");
			return init_mi_error(501, MI_SSTR("Internal Error"));
		}
	} else {
		/* we're already referencing this socket */
		fs_api.put_evs(sock);
	}

	LM_DBG("found socket %s:%d for URL '%.*s'\n", sock->host.s, sock->port,
	       url.len, url.s);

	if (get_mi_array_param(params, "events", &events, &no_events) < 0) {
		lock_stop_write(db_reload_lk);
		return init_mi_param_error();
	}

	for (i = 0; i < no_events; i++) {
		if (get_mi_arr_param_string(events, i, &event_str.s, &event_str.len) < 0) {
			resp = init_mi_param_error();
			goto out_free;
		}

		if (ZSTR(event_str) || add_to_fss_sockets(sock, &event_str) <= 0)
			continue;

		li = pkg_malloc(sizeof *li);
		if (!li) {
			LM_ERR("oom\n");
			resp = init_mi_error(502, MI_SSTR("Internal Error"));
			goto out_free;
		}
		memset(li, 0, sizeof *li);