freeswitch/src/mod/endpoints/mod_sofia/test/sipp-based-tests.c

/*
 * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
 * Copyright (C) 2005-2021, Anthony Minessale II <anthm@freeswitch.org>
 *
 * Version: MPL 1.1
 *
 * The contents of this file are subject to the Mozilla Public License Version
 * 1.1 (the "License"); you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 * http://www.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS IS" basis,
 * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
 * for the specific language governing rights and limitations under the
 * License.
 *
 * The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
 *
 * The Initial Developer of the Original Code is
 * Anthony Minessale II <anthm@freeswitch.org>
 * Portions created by the Initial Developer are Copyright (C)
 * the Initial Developer. All Rights Reserved.
 *
 * Contributor(s):
 * Dragos Oancea <dragos@signalwire.com>
 *
 *
 * sipp-based-tests.c - Test FreeSwitch using sipp (https://github.com/SIPp/sipp)
 *
 */

#include <switch.h>
#include <test/switch_test.h>
#include <stdlib.h>

int test_success = 0;
int test_sofia_debug = 1;
static int timeout_sec = 10;

static void test_wait_for_uuid(char *uuid)
{
	switch_stream_handle_t stream = { 0 };
	int loop_count = 50;
	char *channel_data=NULL;

	do {
		SWITCH_STANDARD_STREAM(stream);
		switch_api_execute("show", "channels", NULL, &stream);

		if (!strncmp((char *)stream.data, "uuid,", 5)) {
			channel_data = switch_mprintf("%s", (char *)stream.data);
			switch_safe_free(stream.data);
			break;
		}
		switch_safe_free(stream.data);
		switch_sleep(100 * 1000);
	} while (loop_count--);

	if (channel_data) {
		char *temp = NULL;
		int i;

		if ((temp = strchr(channel_data, '\n'))) {
			temp++;
			for (i = 0; temp[i] != ',' && i < 99; i++) {
				uuid[i] = temp[i];
			}
		}
		free(channel_data);
	}
}

static const char *test_wait_for_chan_var(switch_channel_t *channel, const char *seq) 
{
	int loop_count = 50;
	const char *var=NULL;
	do {
		if (!strcmp(switch_channel_get_variable(channel, "sip_cseq"),seq)){
			switch_sleep(100 * 1000);
			var = switch_channel_get_variable(channel, "rtp_local_sdp_str");
			break;
		}

		switch_sleep(100 * 1000);
	} while(loop_count--);

	return var;
}

static switch_bool_t has_ipv6() 
{
	switch_stream_handle_t stream = { 0 };
	SWITCH_STANDARD_STREAM(stream);
	switch_api_execute("sofia", "status profile external-ipv6", NULL, &stream);

	if (strstr((char *)stream.data, "Invalid Profile")) {

		switch_safe_free(stream.data);

		return SWITCH_FALSE;
	}

	switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "STATUS PROFILE: %s\n", (char *) stream.data);
	
	switch_safe_free(stream.data);

	return SWITCH_TRUE;
}

static void register_gw()
{
	switch_stream_handle_t stream = { 0 };
	SWITCH_STANDARD_STREAM(stream);
	switch_api_execute("sofia", "profile external register testgw", NULL, &stream);
	switch_safe_free(stream.data);
}

static void unregister_gw()
{
	switch_stream_handle_t stream = { 0 };
	SWITCH_STANDARD_STREAM(stream);
	switch_api_execute("sofia", "profile external unregister testgw", NULL, &stream);
	switch_safe_free(stream.data);
}

static int start_sipp_uac(const char *ip, int remote_port, const char *dialed_number, const char *scenario_uac, const char *extra)
{
	char *cmd = switch_mprintf("sipp %s:%d -nr -p 5062 -m 1 -s %s -recv_timeout 10000 -timeout 10s -sf %s -bg %s", ip, remote_port, dialed_number, scenario_uac, extra);
	int sys_ret = switch_system(cmd, SWITCH_TRUE);

	printf("%s\n", cmd);
	switch_safe_free(cmd);
	switch_sleep(1000 * 1000);

	return sys_ret;
} 

static int start_sipp_uas(const char *ip, int listen_port, const char *scenario_uas, const char *extra)
{
	char *cmd = switch_mprintf("sipp %s -p %d -nr -m 1 -s 1001 -recv_timeout 10000 -timeout 10s -sf %s -bg %s", ip, listen_port, scenario_uas, extra);
	int sys_ret = switch_system(cmd, SWITCH_TRUE);

	printf("%s\n", cmd);
	switch_safe_free(cmd);
	switch_sleep(1000 * 1000);

	return sys_ret;
}
static int run_sipp(const char *ip, int remote_port, int listen_port, const char *dialed_number, const char *scenario_uac, const char *auth_password, const char *extra)
{
	char *cmd = switch_mprintf("sipp %s:%d -nr -p %d -m 1 -s %s -recv_timeout 10000 -timeout 10s -sf %s -au %s -ap %s -bg %s", ip, remote_port, listen_port, dialed_number, scenario_uac, dialed_number, auth_password, extra);
	int sys_ret = switch_system(cmd, SWITCH_TRUE);

	printf("%s\n", cmd);
	switch_safe_free(cmd);
	switch_sleep(1000 * 1000);

	return sys_ret;
}

static void kill_sipp(void)
{
	switch_system("pkill -x sipp", SWITCH_TRUE);
	switch_sleep(1000 * 1000);
}

static void show_event(switch_event_t *event) {
	char *str;
	/*print the event*/
	switch_event_serialize_json(event, &str);
	if (str) {
		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "%s\n", str);
		switch_safe_free(str);
	}
}

static void event_handler(switch_event_t *event) 
{
	const char *new_ev = switch_event_get_header(event, "Event-Subclass");

	if (new_ev && !strcmp(new_ev, "sofia::gateway_invalid_digest_req")) { 
		test_success = 1;
	}

	show_event(event);
}

static void event_handler_reg_ok(switch_event_t *event) 
{
	const char *new_ev = switch_event_get_header(event, "Event-Subclass");
	
	if (new_ev && !strcmp(new_ev, "sofia::gateway_state")) {
		const char *state = switch_event_get_header(event, "State");
		if (state && !strcmp(state, "REGED")) {
			test_success++;
		}
	}

	show_event(event);
}

static void event_handler_reg_fail(switch_event_t *event) 
{
	const char *new_ev = switch_event_get_header(event, "Event-Subclass");

	if (new_ev && !strcmp(new_ev, "sofia::gateway_state")) {
		const char *state = switch_event_get_header(event, "State");
		if (state && !strcmp(state, "FAIL_WAIT")) {
			test_success++;
		}
	}

	show_event(event);
}

FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
{
	FST_MODULE_BEGIN(mod_sofia, uac-uas)
	{
		FST_SETUP_BEGIN()
		{
			switch_stream_handle_t stream = { 0 };
			SWITCH_STANDARD_STREAM(stream);
			switch_api_execute("sofia", "global siptrace on", NULL, &stream);
			if (test_sofia_debug) {
				switch_api_execute("sofia", "loglevel all 9", NULL, &stream);
				switch_api_execute("sofia", "tracelevel debug", NULL, &stream);
			}
			switch_safe_free(stream.data);

			switch_core_set_variable("spawn_instead_of_system", "true");

			fst_requires_module("mod_sndfile");
			fst_requires_module("mod_voicemail");
			fst_requires_module("mod_sofia");
			fst_requires_module("mod_loopback");
			fst_requires_module("mod_console");
			fst_requires_module("mod_dptools");
			fst_requires_module("mod_dialplan_xml");
			fst_requires_module("mod_commands");
			fst_requires_module("mod_say_en");
			fst_requires_module("mod_tone_stream");

		}
		FST_SETUP_END()

		FST_TEARDOWN_BEGIN()
		{
				switch_sleep(200 * 1000);
		}
		FST_TEARDOWN_END()

		FST_TEST_BEGIN(uac_telephone_event_check)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			char uuid[100] = "";
			int sipp_ret;
			int sdp_count = 0;

			sipp_ret = start_sipp_uac(local_ip_v4, 5080, "1212121212", "sipp-scenarios/uac_telephone_event.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				test_wait_for_uuid(uuid);
				if (!zstr(uuid)) {
					const char *sdp_str1 = NULL, *sdp_str2 = NULL;
					switch_core_session_t *session = switch_core_session_locate(uuid);
					switch_channel_t *channel = switch_core_session_get_channel(session);
					fst_check(channel);

					sdp_str1 = test_wait_for_chan_var(channel,"1");
					sdp_str2 = test_wait_for_chan_var(channel,"2");

					if (sdp_str1 && sdp_str2 && (strstr(sdp_str1,"telephone-event")) && (strstr(sdp_str2,"telephone-event"))){
						char *temp = NULL;
						sdp_count = 1;

						if ((temp = strstr(sdp_str2,"RTP/AVP"))) {
							int count = 0, i;

							for (i = 7; temp[i] != '\n' && i < 99; i++) {
								/* checking for payload-type 101.*/
								if(temp[i++] == '1' && temp[i++] == '0' && temp[i++] == '1')
									count++;
							}
							if (count > 1) {
								switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Duplicate entry of payload in SDP.\n");
								sdp_count = 0;
							}
						}

					} else {
						switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Telephone-event missing in SDP.\n");
					}
					switch_core_session_rwunlock(session);

				} else {
					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Uuid not found in Channel Data.\n");
				}

				fst_check(sdp_count == 1);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
			}
		}
		FST_TEST_END()

		FST_TEST_BEGIN(uac_savp_check)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			char uuid[100] = "";
			int sipp_ret;
			int sdp_count = 0;

			sipp_ret = start_sipp_uac(local_ip_v4, 5080, "1212121212", "sipp-scenarios/uac_savp_check.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				test_wait_for_uuid(uuid);
				if (!zstr(uuid)) {
					const char *sdp_str1 = NULL, *sdp_str2 = NULL;
					const char *temp = NULL, *temp1 = NULL;
					switch_core_session_t *session = switch_core_session_locate(uuid);
					switch_channel_t *channel = switch_core_session_get_channel(session);
					fst_check(channel);

					sdp_str1 = test_wait_for_chan_var(channel,"1");
					sdp_str2 = test_wait_for_chan_var(channel,"2");

					if (sdp_str1 && sdp_str2 && (temp = strstr(sdp_str2,"RTP/SAVP")) && (temp1 = strstr(temp,"crypto"))) {
						int i = 0;

						sdp_count = 1;
						for (i = 0; temp1[i]; i++) {

							if ((temp = strstr(temp1,"RTP/SAVP"))) {
								if ((temp1 = strstr(temp,"crypto"))) {
									i = 0;
								} else {
									switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Fail due to no crypto found with SAVP.\n");
									sdp_count = 0;
									break;
								}
							}

						}

					} else {
						switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "SAVP not found in SDP.\n");
					}
					switch_core_session_rwunlock(session);

				} else {
					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Uuid not found in Channel Data.\n");
				}

				fst_check(sdp_count == 1); 
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
			}
		}
		FST_TEST_END()

		FST_TEST_BEGIN(uac_digest_leak_udp)
		{
			switch_core_session_t *session;
			switch_call_cause_t cause;
			switch_status_t status;
			switch_channel_t *channel;
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;

			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler, NULL);

			status = switch_ivr_originate(NULL, &session, &cause, "loopback/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
			sipp_ret = start_sipp_uac(local_ip_v4, 5080, "1001", "sipp-scenarios/uac_digest_leak.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {

				fst_check(status == SWITCH_STATUS_SUCCESS);
				if (!session) {
					fst_check(!"no session");
				} else {
					channel = switch_core_session_get_channel(session);
					fst_xcheck(switch_channel_get_state(channel) < CS_HANGUP, "Expect call not to be hung up");

					while (1) {
						int ret;
						switch_sleep(1000 * 1000);
						ret = switch_system("pidof sipp", SWITCH_TRUE);
						if (!ret) {
							break;
						}
					}

					switch_sleep(5000 * 1000);

					switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);

					switch_core_session_rwunlock(session);
					switch_sleep(1000 * 1000);

					switch_event_unbind_callback(event_handler);
					/* sipp should timeout, attempt kill, just in case.*/
					kill_sipp();
					fst_check(test_success);
				}
			}

			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(uac_digest_leak_tcp)
		{
			switch_core_session_t *session;
			switch_call_cause_t cause;
			switch_status_t status;
			switch_channel_t *channel;
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;

			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler, NULL);

			status = switch_ivr_originate(NULL, &session, &cause, "loopback/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
			sipp_ret = start_sipp_uac(local_ip_v4, 5080, "1001", "sipp-scenarios/uac_digest_leak-tcp.xml", "-t t1");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				fst_check(status == SWITCH_STATUS_SUCCESS);
				if (!session) {
					fst_check(!"no session");
				}

				channel = switch_core_session_get_channel(session);
				fst_xcheck(switch_channel_get_state(channel) < CS_HANGUP, "Expect call not to be hung up");

				while (1) {
					int ret;
					switch_sleep(1000 * 1000);
					ret = switch_system("pidof sipp", SWITCH_TRUE);
					if (!ret) {
						break;
					}
				}

				switch_sleep(5000 * 1000);

				switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);

				switch_core_session_rwunlock(session);
				switch_sleep(1000 * 1000);

				switch_event_unbind_callback(event_handler);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
				fst_check(test_success);
			}

			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(uac_digest_leak_udp_ipv6)
		{
			switch_core_session_t *session;
			switch_call_cause_t cause;
			switch_status_t status;
			switch_channel_t *channel;
			const char *local_ip_v6 = switch_core_get_variable("local_ip_v6");
			int sipp_ret;
			char *ipv6 = NULL;

			if (!has_ipv6()) {
				goto skiptest;
			}
			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler, NULL);

			if (!strchr(local_ip_v6,'[')) {
				ipv6 = switch_mprintf("[%s]", local_ip_v6);
			}
			status = switch_ivr_originate(NULL, &session, &cause, "loopback/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);

			if (!ipv6) {
				sipp_ret = start_sipp_uac(local_ip_v6, 6060, "1001", "sipp-scenarios/uac_digest_leak-ipv6.xml", "-i [::1]");
			} else {
				sipp_ret = start_sipp_uac(ipv6, 6060, "1001", "sipp-scenarios/uac_digest_leak-ipv6.xml", "-i [::1] -mi [::1]");
			}

			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				fst_check(status == SWITCH_STATUS_SUCCESS);
				if (!session) {
					fst_check(!"no session");
				}

				channel = switch_core_session_get_channel(session);
				fst_xcheck(switch_channel_get_state(channel) < CS_HANGUP, "Expect call not to be hung up");

				while (1) {
					int ret;
					switch_sleep(1000 * 1000);
					ret = switch_system("pidof sipp", SWITCH_TRUE);
					if (!ret) {
						break;
					}
				}

				switch_sleep(5000 * 1000);

				switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);

				switch_core_session_rwunlock(session);
				switch_sleep(1000 * 1000);

				switch_event_unbind_callback(event_handler);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
				switch_safe_free(ipv6);
				fst_check(test_success);
			}
skiptest:
			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(register_ok)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;

			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler_reg_ok, NULL);

			sipp_ret = start_sipp_uas(local_ip_v4, 6080, "sipp-scenarios/uas_register.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				switch_sleep(1000 * 1000);

				register_gw();

				switch_sleep(5000 * 1000);

				switch_event_unbind_callback(event_handler_reg_ok);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
				fst_check(test_success);
			}

			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(register_403)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;

			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler_reg_fail, NULL);

			sipp_ret = start_sipp_uas(local_ip_v4, 6080, "sipp-scenarios/uas_register_403.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				switch_sleep(1000 * 1000);

				register_gw();

				switch_sleep(5000 * 1000);

				switch_event_unbind_callback(event_handler_reg_fail);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
				fst_check(test_success);
			}

			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(subscribe_auth_check)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			const char *auth_password = switch_core_get_variable("default_password");
			switch_cache_db_handle_t *dbh = NULL;
			char *dsn = "sofia_reg_internal";
			char count[20]="";
			char count1[20]="";
			int sipp_ret;

			/* check without 407 Proxy Authentication. If count not 0 fail case. */
			sipp_ret = run_sipp(local_ip_v4, 5060, 6091, "1001", "sipp-scenarios/uac_subscriber.xml", auth_password, "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				switch_sleep(100 * 1000);

				if (switch_cache_db_get_db_handle_dsn(&dbh, dsn) == SWITCH_STATUS_SUCCESS) {
					switch_cache_db_execute_sql2str(dbh, "select count(*) from  sip_subscriptions where contact like \"%1001%6091%\";", (char *)&count1, 20, NULL);
					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Count : %s\n", count1);
				}
				fst_check_string_equals(count1, "0");

				/* check with 407  Proxy Authentication Required. If count not 1 fail case. */
				sipp_ret = run_sipp(local_ip_v4, 5060, 6090, "1001", "sipp-scenarios/uac_407_subscriber.xml", auth_password, "");
				if (sipp_ret < 0 || sipp_ret == 127) {
					fst_check(!"sipp not found");
				} else {
					switch_sleep(100 * 1000);

					switch_cache_db_execute_sql2str(dbh, "select count(*) from  sip_subscriptions where contact like \"%1001%6090%\";", (char *)&count, 20, NULL);
					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Count : %s\n", count);
					fst_check_string_equals(count, "1");

				}
			}

			/* sipp should timeout, attempt kill, just in case.*/
			kill_sipp();
		}
		FST_TEST_END()

		FST_TEST_BEGIN(register_no_challange)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;

			switch_event_bind("sofia", SWITCH_EVENT_CUSTOM, NULL, event_handler_reg_ok, NULL);

			sipp_ret = start_sipp_uas(local_ip_v4, 6080, "sipp-scenarios/uas_register_no_challange.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				switch_sleep(1000 * 1000);

				register_gw();

				switch_sleep(5000 * 1000);

				/*the REGISTER with Expires 0 */
				unregister_gw();

				switch_sleep(1000 * 1000);

				register_gw();

				switch_sleep(1000 * 1000);

				switch_event_unbind_callback(event_handler_reg_ok);

				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
				fst_check(test_success);
			}

			test_success = 0;
		}
		FST_TEST_END()

		FST_TEST_BEGIN(invite_407)
		{
			const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
			int sipp_ret;
			switch_core_session_t *session; 
			switch_call_cause_t cause;
			switch_status_t status;
			switch_channel_t *channel;
			char *to;
			const int inv_sipp_port = 6082;

			sipp_ret = start_sipp_uas(local_ip_v4, inv_sipp_port, "sipp-scenarios/uas_407.xml", "");
			if (sipp_ret < 0 || sipp_ret == 127) {
				fst_check(!"sipp not found");
			} else {
				switch_sleep(1000 * 1000);
				to = switch_mprintf("sofia/gateway/testgw-noreg/sipp@%s:%d", local_ip_v4, inv_sipp_port);
				/*originate will fail if the 407 we get from sipp is dropped due to wrong IP.*/
				status = switch_ivr_originate(NULL, &session, &cause, to, timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
				fst_check(status == SWITCH_STATUS_SUCCESS);

				/*test is considered PASSED if we get a session*/
				fst_check(session);
				if (session) {
					switch_sleep(1000 * 1000);
					channel = switch_core_session_get_channel(session);
					switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
					switch_core_session_rwunlock(session);
				}

				switch_safe_free(to);
				/* sipp should timeout, attempt kill, just in case.*/
				kill_sipp();
			}
		}
		FST_TEST_END()

	}
	FST_MODULE_END()
}
FST_CORE_END()