2 * Asterisk -- An open source telephony toolkit.
4 * Copyright (C) 2004 - 2006, Tilghman Lesher
6 * Tilghman Lesher <curl-20050919@the-tilghman.com>
7 * and Brian Wilkins <bwilkins@cfl.rr.com> (Added POST option)
9 * app_curl.c is distributed with no restrictions on usage or
12 * See http://www.asterisk.org for more information about
13 * the Asterisk project. Please do not directly contact
14 * any of the maintainers of this project for assistance;
15 * the project provides a web site, mailing lists and IRC
16 * channels for your use.
22 * \brief Curl - Load a URL
24 * \author Tilghman Lesher <curl-20050919@the-tilghman.com>
26 * \note Brian Wilkins <bwilkins@cfl.rr.com> (Added POST option)
37 ASTERISK_FILE_VERSION(__FILE__
, "$Revision$")
42 #include <curl/curl.h>
44 #include "asterisk/lock.h"
45 #include "asterisk/file.h"
46 #include "asterisk/logger.h"
47 #include "asterisk/channel.h"
48 #include "asterisk/pbx.h"
49 #include "asterisk/cli.h"
50 #include "asterisk/options.h"
51 #include "asterisk/module.h"
52 #include "asterisk/app.h"
53 #include "asterisk/utils.h"
61 static void *myrealloc(void *ptr
, size_t size
)
63 /* There might be a realloc() out there that doesn't like reallocing
64 NULL pointers, so we take care of it here */
66 return ast_realloc(ptr
, size
);
68 return ast_malloc(size
);
71 static size_t WriteMemoryCallback(void *ptr
, size_t size
, size_t nmemb
, void *data
)
73 register int realsize
= size
* nmemb
;
74 struct MemoryStruct
*mem
= (struct MemoryStruct
*)data
;
76 mem
->memory
= (char *)myrealloc(mem
->memory
, mem
->size
+ realsize
+ 1);
78 memcpy(&(mem
->memory
[mem
->size
]), ptr
, realsize
);
79 mem
->size
+= realsize
;
80 mem
->memory
[mem
->size
] = 0;
85 static int curl_internal(struct MemoryStruct
*chunk
, char *url
, char *post
)
89 curl
= curl_easy_init();
95 curl_easy_setopt(curl
, CURLOPT_NOSIGNAL
, 1);
96 curl_easy_setopt(curl
, CURLOPT_TIMEOUT
, 180);
97 curl_easy_setopt(curl
, CURLOPT_FRESH_CONNECT
, 1);
98 curl_easy_setopt(curl
, CURLOPT_FORBID_REUSE
, 1);
99 curl_easy_setopt(curl
, CURLOPT_URL
, url
);
100 curl_easy_setopt(curl
, CURLOPT_WRITEFUNCTION
, WriteMemoryCallback
);
101 curl_easy_setopt(curl
, CURLOPT_WRITEDATA
, (void *)chunk
);
102 curl_easy_setopt(curl
, CURLOPT_USERAGENT
, "asterisk-libcurl-agent/1.0");
105 curl_easy_setopt(curl
, CURLOPT_POST
, 1);
106 curl_easy_setopt(curl
, CURLOPT_POSTFIELDS
, post
);
109 curl_easy_perform(curl
);
110 curl_easy_cleanup(curl
);
114 static int acf_curl_exec(struct ast_channel
*chan
, char *cmd
, char *info
, char *buf
, size_t len
)
116 struct ast_module_user
*u
;
117 struct MemoryStruct chunk
= { NULL
, 0 };
118 AST_DECLARE_APP_ARGS(args
,
120 AST_APP_ARG(postdata
);
125 if (ast_strlen_zero(info
)) {
126 ast_log(LOG_WARNING
, "CURL requires an argument (URL)\n");
130 u
= ast_module_user_add(chan
);
132 AST_STANDARD_APP_ARGS(args
, info
);
134 if (!curl_internal(&chunk
, args
.url
, args
.postdata
)) {
136 chunk
.memory
[chunk
.size
] = '\0';
137 if (chunk
.memory
[chunk
.size
- 1] == 10)
138 chunk
.memory
[chunk
.size
- 1] = '\0';
140 ast_copy_string(buf
, chunk
.memory
, len
);
144 ast_log(LOG_ERROR
, "Cannot allocate curl structure\n");
147 ast_module_user_remove(u
);
152 struct ast_custom_function acf_curl
= {
154 .synopsis
= "Retrieves the contents of a URL",
155 .syntax
= "CURL(url[|post-data])",
157 " url - URL to retrieve\n"
158 " post-data - Optional data to send as a POST (GET is default action)\n",
159 .read
= acf_curl_exec
,
162 static int unload_module(void)
166 res
= ast_custom_function_unregister(&acf_curl
);
168 ast_module_user_hangup_all();
170 curl_global_cleanup();
175 static int load_module(void)
179 if (curl_global_init(CURL_GLOBAL_ALL
)) {
180 ast_log(LOG_ERROR
, "Unable to initialize the CURL library. Cannot load func_curl\n");
181 return AST_MODULE_LOAD_DECLINE
;
184 res
= ast_custom_function_register(&acf_curl
);
189 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY
, "Load external URL");