switch_curl.c

#include <switch.h>
#include "switch_curl.h"
#include <curl/curl.h>

SWITCH_DECLARE(switch_CURL *) switch_curl_easy_init(void)
{
	return curl_easy_init();
}

SWITCH_DECLARE(switch_CURLcode) switch_curl_easy_perform(switch_CURL *handle)
{
	return curl_easy_perform((CURL *)handle);
}


SWITCH_DECLARE(switch_CURLcode) switch_curl_easy_getinfo(switch_CURL *curl, switch_CURLINFO info, ... )
{
	va_list ap;
	switch_CURLcode code;

	va_start(ap, info);
	code = curl_easy_getinfo(curl, info, va_arg(ap, void *));
	va_end(ap);

	return code;
}

SWITCH_DECLARE(void) switch_curl_easy_cleanup(switch_CURL *handle)
{
	curl_easy_cleanup((CURL *)handle);
}



SWITCH_DECLARE(switch_curl_slist_t *) switch_curl_slist_append(switch_curl_slist_t * list, const char * string )
{
	return (switch_curl_slist_t *) curl_slist_append((struct curl_slist *)list, string);
}


SWITCH_DECLARE(void) switch_curl_slist_free_all(switch_curl_slist_t * list)
{
	curl_slist_free_all((struct curl_slist *) list);
}

SWITCH_DECLARE(const char *) switch_curl_easy_strerror(switch_CURLcode errornum )
{
	return curl_easy_strerror(errornum);
}

SWITCH_DECLARE(void) switch_curl_init(void)
{
	curl_global_init(CURL_GLOBAL_ALL);
}

SWITCH_DECLARE(void) switch_curl_destroy(void)
{
	curl_global_cleanup();
}

SWITCH_DECLARE(switch_status_t) switch_curl_process_mime(switch_event_t *event, switch_CURL *curl_handle, switch_curl_mime **mimep)
{
#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
	curl_mime *mime = NULL;
	curl_mimepart *part = NULL;
	uint8_t added = 0;
	switch_CURLcode curl_code = CURLE_OK;
#else
	struct curl_httppost *formpost=NULL;
	struct curl_httppost *lastptr=NULL;
#endif
	switch_event_header_t *hp;
	int go = 0;

	for (hp = event->headers; hp; hp = hp->next) {
		if (!strncasecmp(hp->name, "attach_file:", 12)) {
			go = 1;
			break;
		}
	}

	if (!go) {
		return SWITCH_STATUS_FALSE;
	}

#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
	mime = curl_mime_init(curl_handle);
#endif

	for (hp = event->headers; hp; hp = hp->next) {
		if (!strncasecmp(hp->name, "attach_file:", 12)) {
			char *pname = strdup(hp->name + 12);

			if (pname) {
				char *fname = strchr(pname, ':');

				if (fname) {
					*fname++ = '\0';

#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
					part = curl_mime_addpart(mime);
					if ((curl_code = curl_mime_name(part, pname))) {
						free(pname);
						goto error;
					}

					if ((curl_code = curl_mime_filename(part, fname))) {
						free(pname);
						goto error;
					}

					if ((curl_code = curl_mime_filedata(part, hp->value))) {
						free(pname);
						goto error;
					}

					added++;
#else
					curl_formadd(&formpost,
								 &lastptr,
								 CURLFORM_COPYNAME, pname,
								 CURLFORM_FILENAME, fname,
								 CURLFORM_FILE, hp->value,
								 CURLFORM_END);
#endif
				}

				free(pname);
			}
		} else {
#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
			part = curl_mime_addpart(mime);
			if ((curl_code = curl_mime_name(part, hp->name))) {
				goto error;
			}

			if ((curl_code = curl_mime_data(part, hp->value, CURL_ZERO_TERMINATED))) {
				goto error;
			}

			added++;
#else
			curl_formadd(&formpost,
						 &lastptr,
						 CURLFORM_COPYNAME, hp->name,
						 CURLFORM_COPYCONTENTS, hp->value,
						 CURLFORM_END);
#endif
		}
	}

#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
 error:
	if (curl_code) {
		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "CURL error occured. Error code: %d Error msg: [%s]\n", curl_code, switch_curl_easy_strerror(curl_code));
	}

	if (!added) {
		curl_mime_free(mime);
		mime = NULL;
	}

	*mimep = mime;
#else
	*mimep = formpost;
#endif

	return SWITCH_STATUS_SUCCESS;
}

SWITCH_DECLARE(void) switch_curl_mime_free(switch_curl_mime **mimep)
{
	if (mimep && *mimep) {
#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
		curl_mime_free(*mimep);
#else
		curl_formfree(*mimep);
#endif
		mimep = NULL;
	}
}

SWITCH_DECLARE(switch_CURLcode) switch_curl_easy_setopt_mime(switch_CURL *curl_handle, switch_curl_mime *mime)
{
#if defined(LIBCURL_VERSION_NUM) && (LIBCURL_VERSION_NUM >= 0x073800)
	return curl_easy_setopt(curl_handle, CURLOPT_MIMEPOST, mime);
#else
	return curl_easy_setopt(curl_handle, CURLOPT_HTTPPOST, mime);
#endif
}

/* For Emacs:
 * Local Variables:
 * mode:c
 * indent-tabs-mode:t
 * tab-width:4
 * c-basic-offset:4
 * End:
 * For VIM:
 * vim:set softtabstop=4 shiftwidth=4 tabstop=4 noet:
 */