2 * Asterisk -- An open source telephony toolkit.
4 * Copyright (C) 1999 - 2006, Digium, Inc.
6 * Mark Spencer <markster@digium.com>
8 * See http://www.asterisk.org for more information about
9 * the Asterisk project. Please do not directly contact
10 * any of the maintainers of this project for assistance;
11 * the project provides a web site, mailing lists and IRC
12 * channels for your use.
14 * This program is free software, distributed under the terms of
15 * the GNU General Public License Version 2. See the LICENSE file
16 * at the top of the source tree.
21 * \brief Open Settlement Protocol (OSP) Applications
23 * \author Mark Spencer <markster@digium.com>
25 * \extref The OSP Toolkit: http://www.transnexus.com
26 * \extref OpenSSL http://www.openssl.org
28 * \ingroup applications
32 <depend>osptk</depend>
33 <depend>openssl</depend>
38 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
41 #include <osp/osputils.h>
42 #include <osp/ospb64.h>
44 #include "asterisk/paths.h"
45 #include "asterisk/lock.h"
46 #include "asterisk/config.h"
47 #include "asterisk/utils.h"
48 #include "asterisk/causes.h"
49 #include "asterisk/channel.h"
50 #include "asterisk/app.h"
51 #include "asterisk/module.h"
52 #include "asterisk/pbx.h"
53 #include "asterisk/cli.h"
54 #include "asterisk/astosp.h"
57 <application name="OSPAuth" language="en_US">
62 <parameter name="provider" />
63 <parameter name="options" />
66 <para>Authenticate a call by OSP and sets the variables:</para>
68 <variable name="OSPINHANDLE">
69 <para>The inbound call transaction handle.</para>
71 <variable name="OSPINTIMELIMIT">
72 <para>The inbound call duration limit in seconds.</para>
75 <para>This application sets the following channel variable upon completion:</para>
77 <variable name="OSPAUTHSTATUS">
78 <para>The status of the OSP Auth attempt as a text string, one of</para>
79 <value name="SUCCESS" />
80 <value name="FAILED" />
81 <value name="ERROR" />
86 <application name="OSPLookup" language="en_US">
88 Lookup destination by OSP.
91 <parameter name="exten" required="true" />
92 <parameter name="provider" />
93 <parameter name="options">
96 <para>generate H323 call id for the outbound call</para>
99 <para>generate SIP call id for the outbound call.
100 Have not been implemented</para>
103 <para>generate IAX call id for the outbound call.
104 Have not been implemented</para>
110 <para>Looks up an extension via OSP and sets the variables, where <literal>n</literal> is the
111 number of the result beginning with <literal>1</literal>:</para>
113 <variable name="OSPOUTHANDLE">
114 <para>The OSP Handle for anything remaining.</para>
116 <variable name="OSPTECH">
117 <para>The technology to use for the call.</para>
119 <variable name="OSPDESTINATION">
120 <para>The destination to use for the call.</para>
122 <variable name="OSPOUTCALLING">
123 <para>The calling number to use for the call.</para>
125 <variable name="OSPOUTCALLED">
126 <para>The called number to use for the call.</para>
128 <variable name="OSPDIALSTR">
129 <para>The dial command string.</para>
131 <variable name="OSPOUTTOKEN">
132 <para>The actual OSP token as a string.</para>
134 <variable name="OSPOUTTIMELIMIT">
135 <para>The outbound call duraction limit in seconds.</para>
137 <variable name="OSPOUTCALLIDTYPES">
138 <para>The outbound call id types.</para>
140 <variable name="OSPOUTCALLID">
141 <para>The outbound call id.</para>
143 <variable name="OSPDESTREMAILS">
144 <para>The number of OSP results total remaining.</para>
148 <variable name="OSPLOOKUPSTATUS">
149 <para>This application sets the following channel variable upon completion:</para>
150 <value name="SUCCESS" />
151 <value name="FAILED" />
152 <value name="ERROR" />
157 <application name="OSPNext" language="en_US">
159 Lookup next destination by OSP.
162 <parameter name="cause" required="true" />
163 <parameter name="provider" />
164 <parameter name="options" />
167 <para>Looks up the next OSP Destination for <variable>OSPOUTHANDLE</variable>.</para>
168 <para>This application sets the following channel variable upon completion:</para>
170 <variable name="OSPNEXTSTATUS">
171 <para>The status of the OSP Next attempt as a text string, one of</para>
172 <value name="SUCCESS" />
173 <value name="FAILED" />
174 <value name="ERROR" />
179 <ref type="application">OSPLookup</ref>
182 <application name="OSPFinish" language="en_US">
187 <parameter name="status" />
188 <parameter name="options" />
191 <para>Records call state for <variable>OSPINHANDLE</variable>, according to status, which should
192 be one of <literal>BUSY</literal>, <literal>CONGESTION</literal>, <literal>ANSWER</literal>,
193 <literal>NOANSWER</literal>, or <literal>CHANUNAVAIL</literal> or coincidentally, just what the
194 Dial application stores in its <variable>DIALSTATUS</variable>.</para>
195 <para>This application sets the following channel variable upon completion:</para>
197 <variable name="OSPFINISHSTATUS">
198 <para>The status of the OSP Finish attempt as a text string, one of</para>
199 <value name="SUCCESS" />
200 <value name="FAILED" />
201 <value name="ERROR" />
208 /* OSP Buffer Sizes */
209 #define OSP_SIZE_INTSTR ((unsigned int)16) /* OSP signed/unsigned int string buffer size */
210 #define OSP_SIZE_NORSTR ((unsigned int)256) /* OSP normal string buffer size */
211 #define OSP_SIZE_KEYSTR ((unsigned int)1024) /* OSP certificate string buffer size */
212 #define OSP_SIZE_TOKSTR ((unsigned int)4096) /* OSP token string buffer size */
213 #define OSP_SIZE_TECHSTR ((unsigned int)32) /* OSP signed/unsigned int string buffer size */
214 #define OSP_SIZE_UUID ((unsigned int)16) /* UUID size */
215 #define OSP_SIZE_UUIDSTR ((unsigned int)36) /* UUID string size */
216 #define OSP_SIZE_QOSSTR ((unsigned int)1024) /* QoS string buffer size */
219 #define OSP_CALLID_UNDEF ((unsigned int)0) /* Undefined */
220 #define OSP_CALLID_SIP ((unsigned int)(1 << 0)) /* SIP */
221 #define OSP_CALLID_H323 ((unsigned int)(1 << 1)) /* H.323 */
222 #define OSP_CALLID_IAX ((unsigned int)(1 << 2)) /* IAX2 */
223 #define OSP_CALLID_MAXNUM ((unsigned int)3) /* Max number of call ID types */
225 /* OSP Supported Destination Protocols */
226 #define OSP_PROT_SIP ((const char*)"SIP") /* SIP protocol name */
227 #define OSP_PROT_H323 ((const char*)"H323") /* H.323 Q.931 protocol name*/
228 #define OSP_PROT_IAX ((const char*)"IAX") /* IAX2 protocol name */
229 #define OSP_PROT_SKYPE ((const char*)"SKYPE") /* Skype protocol name */
231 /* OSP supported Destination Tech */
232 #define OSP_TECH_SIP ((const char*)"SIP") /* SIP tech name */
233 #define OSP_TECH_H323 ((const char*)"H323") /* OH323 tech name */
234 #define OSP_TECH_IAX ((const char*)"IAX2") /* IAX2 tech name */
235 #define OSP_TECH_SKYPE ((const char*)"SKYPE") /* Skype tech name */
237 /* SIP OSP header field name */
238 #define OSP_SIP_HEADER ((const char*)"P-OSP-Auth-Token")
240 /* OSP Authentication Policy */
241 enum osp_authpolicy {
242 OSP_AUTH_NO = 0, /* Accept any call */
243 OSP_AUTH_YES, /* Accept call with valid OSP token or without OSP token */
244 OSP_AUTH_EXC /* Only accept call with valid OSP token */
247 /* OSP Service Type */
249 OSP_SRV_VOICE = 0, /* Normal voice service */
250 OSP_SRV_NPQUERY /* Ported number query service */
254 #define OSP_OK ((int)1) /* OSP function call successful */
255 #define OSP_FAILED ((int)0) /* OSP function call failed */
256 #define OSP_ERROR ((int)-1) /* OSP function call error */
257 #define OSP_AST_OK ((int)0) /* Asterisk function call successful */
258 #define OSP_AST_ERROR ((int)-1) /* Asterisk function call error */
259 #define OSP_INVALID_HANDLE ((int)-1) /* Invalid OSP handle, provider, transaction etc. */
260 #define OSP_CONFIG_FILE ((const char*)"osp.conf") /* OSP configuration file name */
261 #define OSP_GENERAL_CAT ((const char*)"general") /* OSP global configuration context name */
262 #define OSP_DEF_PROVIDER ((const char*)"default") /* OSP default provider context name */
263 #define OSP_MAX_CERTS ((unsigned int)10) /* OSP max number of cacerts */
264 #define OSP_MAX_SPOINTS ((unsigned int)10) /* OSP max number of service points */
265 #define OSP_DEF_MAXCONNECT ((unsigned int)20) /* OSP default max_connections */
266 #define OSP_MIN_MAXCONNECT ((unsigned int)1) /* OSP min max_connections */
267 #define OSP_MAX_MAXCONNECT ((unsigned int)1000) /* OSP max max_connections */
268 #define OSP_DEF_RETRYDELAY ((unsigned int)0) /* OSP default retry delay */
269 #define OSP_MIN_RETRYDELAY ((unsigned int)0) /* OSP min retry delay */
270 #define OSP_MAX_RETRYDELAY ((unsigned int)10) /* OSP max retry delay */
271 #define OSP_DEF_RETRYLIMIT ((unsigned int)2) /* OSP default retry times */
272 #define OSP_MIN_RETRYLIMIT ((unsigned int)0) /* OSP min retry times */
273 #define OSP_MAX_RETRYLIMIT ((unsigned int)100) /* OSP max retry times */
274 #define OSP_DEF_TIMEOUT ((unsigned int)500) /* OSP default timeout in ms */
275 #define OSP_MIN_TIMEOUT ((unsigned int)200) /* OSP min timeout in ms */
276 #define OSP_MAX_TIMEOUT ((unsigned int)10000) /* OSP max timeout in ms */
277 #define OSP_DEF_AUTHPOLICY OSP_AUTH_YES /* OSP default auth policy, yes */
278 #define OSP_AUDIT_URL ((const char*)"localhost") /* OSP default Audit URL */
279 #define OSP_LOCAL_VALIDATION ((int)1) /* Validate OSP token locally */
280 #define OSP_SSL_LIFETIME ((unsigned int)300) /* SSL life time, in seconds */
281 #define OSP_HTTP_PERSISTENCE ((int)1) /* In seconds */
282 #define OSP_CUSTOMER_ID ((const char*)"") /* OSP customer ID */
283 #define OSP_DEVICE_ID ((const char*)"") /* OSP device ID */
284 #define OSP_DEF_MAXDESTS ((unsigned int)5) /* OSP default max number of destinations */
285 #define OSP_DEF_TIMELIMIT ((unsigned int)0) /* OSP default duration limit, no limit */
286 #define OSP_DEF_PROTOCOL OSP_PROT_SIP /* OSP default destination protocol, SIP */
287 #define OSP_DEF_SRVTYPE OSP_SRV_VOICE /* OSP default service type, voice */
288 #define OSP_MAX_CUSTOMINFO ((unsigned int)8) /* OSP max number of custom info */
289 #define OSP_DEF_INTSTATS ((int)-1) /* OSP default int statistic */
290 #define OSP_DEF_FLOATSTATS ((float)-1) /* OSP default float statistic */
293 struct osp_provider {
294 OSPTPROVHANDLE handle; /* OSP provider handle */
295 char name[OSP_SIZE_NORSTR]; /* OSP provider context name */
296 char privatekey[OSP_SIZE_NORSTR]; /* OSP private key file name */
297 char localcert[OSP_SIZE_NORSTR]; /* OSP local cert file name */
298 unsigned int canum; /* Number of cacerts */
299 char cacerts[OSP_MAX_CERTS][OSP_SIZE_NORSTR]; /* Cacert file names */
300 unsigned int spnum; /* Number of service points */
301 char spoints[OSP_MAX_SPOINTS][OSP_SIZE_NORSTR]; /* Service point URLs */
302 unsigned int maxconnect; /* Max number of connections */
303 unsigned int retrydelay; /* Retry delay */
304 unsigned int retrylimit; /* Retry limit */
305 unsigned int timeout; /* Timeout in ms */
306 char source[OSP_SIZE_NORSTR]; /* IP of self */
307 enum osp_authpolicy authpolicy; /* OSP authentication policy */
308 const char* defprotocol; /* OSP default destination protocol */
309 enum osp_srvtype srvtype; /* OSP default service type */
310 struct osp_provider* next; /* Pointer to next OSP provider */
315 unsigned char buf[OSP_SIZE_NORSTR]; /* Call ID string */
316 unsigned int len; /* Call ID length */
319 /* Number Portability Parameters */
321 const char* rn; /* Rounding number */
322 const char* cic; /* Carrier Identification Code */
323 int npdi; /* NP Database Dip Indicator */
326 /* SIP Diversion Header Parameters */
327 struct osp_diversion {
328 const char* user; /* Diversion header user info */
329 const char* host; /* Diversion header host info */
332 /* OSP Application In/Output Results */
334 int inhandle; /* Inbound transaction handle */
335 int outhandle; /* Outbound transaction handle */
336 unsigned int intimelimit; /* Inbound duration limit */
337 unsigned int outtimelimit; /* Outbound duration limit */
338 char tech[OSP_SIZE_TECHSTR]; /* Outbound Asterisk TECH string */
339 char dest[OSP_SIZE_NORSTR]; /* Outbound destination IP address */
340 char calling[OSP_SIZE_NORSTR]; /* Outbound calling number, may be translated */
341 char called[OSP_SIZE_NORSTR]; /* Outbound called number, may be translated */
342 char token[OSP_SIZE_TOKSTR]; /* Outbound OSP token */
343 char networkid[OSP_SIZE_NORSTR]; /* Outbound network ID */
344 char nprn[OSP_SIZE_NORSTR]; /* Outbound NP routing number */
345 char npcic[OSP_SIZE_NORSTR]; /* Outbound NP carrier identification code */
346 int npdi; /* Outbound NP database dip indicator */
347 unsigned int numdests; /* Number of remain outbound destinations */
348 struct osp_callid outcallid; /* Outbound call ID */
353 OSP_CALL_INBOUND, /* Inbound call leg */
354 OSP_CALL_OUTBOUND /* Outbound call leg */
357 /* OSP Media Stream Direction */
359 OSP_DIR_RX = 0, /* Receive */
360 OSP_DIR_TX, /* Send */
361 OSP_DIR_NUMBER /* Number of directions */
366 int value; /* Value */
367 float min; /* Minimum */
368 float max; /* Maximum */
369 float avg; /* Average */
370 float ndev; /* Normal deviation */
371 float sdev; /* Standard deviation */
374 /* OSP Module Global Variables */
375 AST_MUTEX_DEFINE_STATIC(osp_lock); /* Lock of OSP provider list */
376 static int osp_initialized = 0; /* Init flag */
377 static int osp_hardware = 0; /* Hardware accelleration flag */
378 static int osp_security = 0; /* Using security features flag */
379 static struct osp_provider* osp_providers = NULL; /* OSP provider list */
380 static unsigned int osp_tokenformat = TOKEN_ALGO_SIGNED; /* Token format supported */
382 /* OSP default certificates */
383 const char* B64PKey = "MIIBOgIBAAJBAK8t5l+PUbTC4lvwlNxV5lpl+2dwSZGW46dowTe6y133XyVEwNiiRma2YNk3xKs/TJ3Wl9Wpns2SYEAJsFfSTukCAwEAAQJAPz13vCm2GmZ8Zyp74usTxLCqSJZNyMRLHQWBM0g44Iuy4wE3vpi7Wq+xYuSOH2mu4OddnxswCP4QhaXVQavTAQIhAOBVCKXtppEw9UaOBL4vW0Ed/6EA/1D8hDW6St0h7EXJAiEAx+iRmZKhJD6VT84dtX5ZYNVk3j3dAcIOovpzUj9a0CECIEduTCapmZQ5xqAEsLXuVlxRtQgLTUD4ZxDElPn8x0MhAiBE2HlcND0+qDbvtwJQQOUzDgqg5xk3w8capboVdzAlQQIhAMC+lDL7+gDYkNAft5Mu+NObJmQs4Cr+DkDFsKqoxqrm";
384 const char* B64LCert = "MIIBeTCCASMCEHqkOHVRRWr+1COq3CR/xsowDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTA1MDYyMzAwMjkxOFoXDTA2MDYyNDAwMjkxOFowRTELMAkGA1UEBhMCQVUxEzARBgNVBAgTClNvbWUtU3RhdGUxITAfBgNVBAoTGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDBcMA0GCSqGSIb3DQEBAQUAA0sAMEgCQQCvLeZfj1G0wuJb8JTcVeZaZftncEmRluOnaME3ustd918lRMDYokZmtmDZN8SrP0yd1pfVqZ7NkmBACbBX0k7pAgMBAAEwDQYJKoZIhvcNAQEEBQADQQDnV8QNFVVJx/+7IselU0wsepqMurivXZzuxOmTEmTVDzCJx1xhA8jd3vGAj7XDIYiPub1PV23eY5a2ARJuw5w9";
385 const char* B64CACert = "MIIBYDCCAQoCAQEwDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTAyMDIwNDE4MjU1MloXDTEyMDIwMzE4MjU1MlowOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAPGeGwV41EIhX0jEDFLRXQhDEr50OUQPq+f55VwQd0TQNts06BP29+UiNdRW3c3IRHdZcJdC1Cg68ME9cgeq0h8CAwEAATANBgkqhkiG9w0BAQQFAANBAGkzBSj1EnnmUxbaiG1N4xjIuLAWydun7o3bFk2tV8dBIhnuh445obYyk1EnQ27kI7eACCILBZqi2MHDOIMnoN0=";
387 /* OSP Client Wrapper APIs */
390 * \brief Create OSP provider handle according to configuration
391 * \param cfg OSP configuration
392 * \param name OSP provider context name
393 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
395 static int osp_create_provider(
396 struct ast_config* cfg,
399 int res = OSP_FAILED;
400 struct ast_variable* var;
401 struct osp_provider* provider;
402 OSPTPRIVATEKEY privatekey;
404 OSPT_CERT cacerts[OSP_MAX_CERTS];
405 const OSPT_CERT* pcacerts[OSP_MAX_CERTS];
406 const char* pspoints[OSP_MAX_SPOINTS];
407 unsigned char privatekeydata[OSP_SIZE_KEYSTR];
408 unsigned char localcertdata[OSP_SIZE_KEYSTR];
409 unsigned char cacertdata[OSP_SIZE_KEYSTR];
410 int i, num, error = OSPC_ERR_NO_ERROR;
412 if (!(provider = ast_calloc(1, sizeof(*provider)))) {
413 ast_log(LOG_ERROR, "Out of memory\n");
417 /* ast_calloc has set 0 in provider */
418 provider->handle = OSP_INVALID_HANDLE;
419 ast_copy_string(provider->name, name, sizeof(provider->name));
420 snprintf(provider->privatekey, sizeof(provider->privatekey), "%s/%s-privatekey.pem", ast_config_AST_KEY_DIR, name);
421 snprintf(provider->localcert, sizeof(provider->localcert), "%s/%s-localcert.pem", ast_config_AST_KEY_DIR, name);
422 snprintf(provider->cacerts[0], sizeof(provider->cacerts[0]), "%s/%s-cacert_0.pem", ast_config_AST_KEY_DIR, name);
423 provider->maxconnect = OSP_DEF_MAXCONNECT;
424 provider->retrydelay = OSP_DEF_RETRYDELAY;
425 provider->retrylimit = OSP_DEF_RETRYLIMIT;
426 provider->timeout = OSP_DEF_TIMEOUT;
427 provider->authpolicy = OSP_DEF_AUTHPOLICY;
428 provider->defprotocol = OSP_DEF_PROTOCOL;
429 provider->srvtype = OSP_DEF_SRVTYPE;
431 for (var = ast_variable_browse(cfg, name); var != NULL; var = var->next) {
432 if (!strcasecmp(var->name, "privatekey")) {
434 if (var->value[0] == '/') {
435 ast_copy_string(provider->privatekey, var->value, sizeof(provider->privatekey));
437 snprintf(provider->privatekey, sizeof(provider->privatekey), "%s/%s", ast_config_AST_KEY_DIR, var->value);
439 ast_debug(1, "OSP: privatekey '%s'\n", provider->privatekey);
441 } else if (!strcasecmp(var->name, "localcert")) {
443 if (var->value[0] == '/') {
444 ast_copy_string(provider->localcert, var->value, sizeof(provider->localcert));
446 snprintf(provider->localcert, sizeof(provider->localcert), "%s/%s", ast_config_AST_KEY_DIR, var->value);
448 ast_debug(1, "OSP: localcert '%s'\n", provider->localcert);
450 } else if (!strcasecmp(var->name, "cacert")) {
452 if (provider->canum < OSP_MAX_CERTS) {
453 if (var->value[0] == '/') {
454 ast_copy_string(provider->cacerts[provider->canum], var->value, sizeof(provider->cacerts[provider->canum]));
456 snprintf(provider->cacerts[provider->canum], sizeof(provider->cacerts[provider->canum]), "%s/%s", ast_config_AST_KEY_DIR, var->value);
458 ast_debug(1, "OSP: cacerts[%d]: '%s'\n", provider->canum, provider->cacerts[provider->canum]);
461 ast_log(LOG_WARNING, "OSP: Too many CA Certificates at line %d\n", var->lineno);
464 } else if (!strcasecmp(var->name, "servicepoint")) {
465 if (provider->spnum < OSP_MAX_SPOINTS) {
466 ast_copy_string(provider->spoints[provider->spnum], var->value, sizeof(provider->spoints[provider->spnum]));
467 ast_debug(1, "OSP: servicepoint[%d]: '%s'\n", provider->spnum, provider->spoints[provider->spnum]);
470 ast_log(LOG_WARNING, "OSP: Too many Service Points at line %d\n", var->lineno);
472 } else if (!strcasecmp(var->name, "maxconnect")) {
473 if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_MAXCONNECT) && (num <= OSP_MAX_MAXCONNECT)) {
474 provider->maxconnect = num;
475 ast_debug(1, "OSP: maxconnect '%d'\n", num);
477 ast_log(LOG_WARNING, "OSP: maxconnect should be an integer from %d to %d, not '%s' at line %d\n",
478 OSP_MIN_MAXCONNECT, OSP_MAX_MAXCONNECT, var->value, var->lineno);
480 } else if (!strcasecmp(var->name, "retrydelay")) {
481 if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_RETRYDELAY) && (num <= OSP_MAX_RETRYDELAY)) {
482 provider->retrydelay = num;
483 ast_debug(1, "OSP: retrydelay '%d'\n", num);
485 ast_log(LOG_WARNING, "OSP: retrydelay should be an integer from %d to %d, not '%s' at line %d\n",
486 OSP_MIN_RETRYDELAY, OSP_MAX_RETRYDELAY, var->value, var->lineno);
488 } else if (!strcasecmp(var->name, "retrylimit")) {
489 if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_RETRYLIMIT) && (num <= OSP_MAX_RETRYLIMIT)) {
490 provider->retrylimit = num;
491 ast_debug(1, "OSP: retrylimit '%d'\n", num);
493 ast_log(LOG_WARNING, "OSP: retrylimit should be an integer from %d to %d, not '%s' at line %d\n",
494 OSP_MIN_RETRYLIMIT, OSP_MAX_RETRYLIMIT, var->value, var->lineno);
496 } else if (!strcasecmp(var->name, "timeout")) {
497 if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_TIMEOUT) && (num <= OSP_MAX_TIMEOUT)) {
498 provider->timeout = num;
499 ast_debug(1, "OSP: timeout '%d'\n", num);
501 ast_log(LOG_WARNING, "OSP: timeout should be an integer from %d to %d, not '%s' at line %d\n",
502 OSP_MIN_TIMEOUT, OSP_MAX_TIMEOUT, var->value, var->lineno);
504 } else if (!strcasecmp(var->name, "source")) {
505 ast_copy_string(provider->source, var->value, sizeof(provider->source));
506 ast_debug(1, "OSP: source '%s'\n", provider->source);
507 } else if (!strcasecmp(var->name, "authpolicy")) {
508 if ((sscanf(var->value, "%30d", &num) == 1) && ((num == OSP_AUTH_NO) || (num == OSP_AUTH_YES) || (num == OSP_AUTH_EXC))) {
509 provider->authpolicy = num;
510 ast_debug(1, "OSP: authpolicy '%d'\n", num);
512 ast_log(LOG_WARNING, "OSP: authpolicy should be %d, %d or %d, not '%s' at line %d\n",
513 OSP_AUTH_NO, OSP_AUTH_YES, OSP_AUTH_EXC, var->value, var->lineno);
515 } else if (!strcasecmp(var->name, "defprotocol")) {
516 if (!strcasecmp(var->value, OSP_PROT_SIP)) {
517 provider->defprotocol = OSP_PROT_SIP;
518 ast_debug(1, "OSP: default protocol SIP\n");
519 } else if (!strcasecmp(var->value, OSP_PROT_H323)) {
520 provider->defprotocol = OSP_PROT_H323;
521 ast_debug(1, "OSP: default protocol H.323\n");
522 } else if (!strcasecmp(var->value, OSP_PROT_IAX)) {
523 provider->defprotocol = OSP_PROT_IAX;
524 ast_debug(1, "OSP: default protocol IAX\n");
525 } else if (!strcasecmp(var->value, OSP_PROT_SKYPE)) {
526 provider->defprotocol = OSP_PROT_SKYPE;
527 ast_debug(1, "OSP: default protocol Skype\n");
529 ast_log(LOG_WARNING, "OSP: default protocol should be %s, %s, %s or %s not '%s' at line %d\n",
530 OSP_PROT_SIP, OSP_PROT_H323, OSP_PROT_IAX, OSP_PROT_SKYPE, var->value, var->lineno);
532 } else if (!strcasecmp(var->name, "servicetype")) {
533 if ((sscanf(var->value, "%30d", &num) == 1) && ((num == OSP_SRV_VOICE) || (num == OSP_SRV_NPQUERY))) {
534 provider->srvtype = num;
535 ast_debug(1, "OSP: servicetype '%d'\n", num);
537 ast_log(LOG_WARNING, "OSP: servicetype should be %d or %d, not '%s' at line %d\n",
538 OSP_SRV_VOICE, OSP_SRV_NPQUERY, var->value, var->lineno);
543 if (provider->canum == 0) {
547 for (i = 0; i < provider->spnum; i++) {
548 pspoints[i] = provider->spoints[i];
552 privatekey.PrivateKeyData = NULL;
553 privatekey.PrivateKeyLength = 0;
555 localcert.CertData = NULL;
556 localcert.CertDataLength = 0;
558 for (i = 0; i < provider->canum; i++) {
559 cacerts[i].CertData = NULL;
560 cacerts[i].CertDataLength = 0;
563 if ((error = OSPPUtilLoadPEMPrivateKey((unsigned char*)provider->privatekey, &privatekey)) != OSPC_ERR_NO_ERROR) {
564 ast_log(LOG_WARNING, "OSP: Unable to load privatekey '%s', error '%d'\n", provider->privatekey, error);
565 } else if ((error = OSPPUtilLoadPEMCert((unsigned char*)provider->localcert, &localcert)) != OSPC_ERR_NO_ERROR) {
566 ast_log(LOG_WARNING, "OSP: Unable to load localcert '%s', error '%d'\n", provider->localcert, error);
568 for (i = 0; i < provider->canum; i++) {
569 if ((error = OSPPUtilLoadPEMCert((unsigned char*)provider->cacerts[i], &cacerts[i])) != OSPC_ERR_NO_ERROR) {
570 ast_log(LOG_WARNING, "OSP: Unable to load cacert '%s', error '%d'\n", provider->cacerts[i], error);
573 pcacerts[i] = &cacerts[i];
578 privatekey.PrivateKeyData = privatekeydata;
579 privatekey.PrivateKeyLength = sizeof(privatekeydata);
581 localcert.CertData = localcertdata;
582 localcert.CertDataLength = sizeof(localcertdata);
584 cacerts[0].CertData = cacertdata;
585 cacerts[0].CertDataLength = sizeof(cacertdata);
586 pcacerts[0] = &cacerts[0];
588 if ((error = OSPPBase64Decode(B64PKey, strlen(B64PKey), privatekey.PrivateKeyData, &privatekey.PrivateKeyLength)) != OSPC_ERR_NO_ERROR) {
589 ast_log(LOG_WARNING, "OSP: Unable to decode private key, error '%d'\n", error);
590 } else if ((error = OSPPBase64Decode(B64LCert, strlen(B64LCert), localcert.CertData, &localcert.CertDataLength)) != OSPC_ERR_NO_ERROR) {
591 ast_log(LOG_WARNING, "OSP: Unable to decode local cert, error '%d'\n", error);
592 } else if ((error = OSPPBase64Decode(B64CACert, strlen(B64CACert), cacerts[0].CertData, &cacerts[0].CertDataLength)) != OSPC_ERR_NO_ERROR) {
593 ast_log(LOG_WARNING, "OSP: Unable to decode cacert, error '%d'\n", error);
597 if (error == OSPC_ERR_NO_ERROR) {
598 error = OSPPProviderNew(provider->spnum,
606 OSP_LOCAL_VALIDATION,
608 provider->maxconnect,
609 OSP_HTTP_PERSISTENCE,
610 provider->retrydelay,
611 provider->retrylimit,
616 if (error != OSPC_ERR_NO_ERROR) {
617 ast_log(LOG_WARNING, "OSP: Unable to create provider '%s', error '%d'\n", name, error);
620 ast_debug(1, "OSP: provider '%s'\n", name);
621 ast_mutex_lock(&osp_lock);
622 provider->next = osp_providers;
623 osp_providers = provider;
624 ast_mutex_unlock(&osp_lock);
630 for (i = 0; i < provider->canum; i++) {
631 if (cacerts[i].CertData) {
632 ast_free(cacerts[i].CertData);
635 if (localcert.CertData) {
636 ast_free(localcert.CertData);
638 if (privatekey.PrivateKeyData) {
639 ast_free(privatekey.PrivateKeyData);
651 * \brief Get OSP provider by name
652 * \param name OSP provider context name
653 * \param provider OSP provider structure
654 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
656 static int osp_get_provider(
658 struct osp_provider** provider)
660 int res = OSP_FAILED;
661 struct osp_provider* p;
665 ast_mutex_lock(&osp_lock);
666 for (p = osp_providers; p != NULL; p = p->next) {
667 if (!strcasecmp(p->name, name)) {
669 ast_debug(1, "OSP: find provider '%s'\n", name);
674 ast_mutex_unlock(&osp_lock);
680 * \brief Create OSP transaction handle
681 * \param name OSP provider context name
682 * \param trans OSP transaction handle, output
683 * \param source Source of provider, output
684 * \param sourcesize Size of source buffer, in
685 * \return OSK_OK Success, OSK_FAILED Failed, OSP_ERROR Error
687 static int osp_create_transaction(
691 unsigned int srcsize)
693 int res = OSP_FAILED;
694 struct osp_provider* provider;
697 if ((trans == NULL) || (source == NULL) || (srcsize <= 0)) {
698 ast_log(LOG_ERROR, "Invalid parameters\n");
702 *trans = OSP_INVALID_HANDLE;
705 ast_mutex_lock(&osp_lock);
706 for (provider = osp_providers; provider; provider = provider->next) {
707 if (!strcasecmp(provider->name, name)) {
708 error = OSPPTransactionNew(provider->handle, trans);
709 if (error == OSPC_ERR_NO_ERROR) {
710 ast_debug(1, "OSP: transaction '%d'\n", *trans);
711 ast_copy_string(source, provider->source, srcsize);
712 ast_debug(1, "OSP: source '%s'\n", source);
715 *trans = OSP_INVALID_HANDLE;
716 ast_debug(1, "OSP: Unable to create transaction handle, error '%d'\n", error);
723 ast_mutex_unlock(&osp_lock);
729 * \brief Convert "address:port" to "[x.x.x.x]:port" or "hostname:port" format
730 * \param src Source address string
731 * \param dest Destination address string
732 * \param destsize Size of dest buffer
734 static void osp_convert_inout(
737 unsigned int destsize)
740 char buffer[OSP_SIZE_NORSTR];
743 if ((dest != NULL) && (destsize > 0)) {
744 if (!ast_strlen_zero(src)) {
745 ast_copy_string(buffer, src, sizeof(buffer));
747 if((port = strchr(buffer, ':')) != NULL) {
752 if (inet_pton(AF_INET, buffer, &inp) == 1) {
754 snprintf(dest, destsize, "[%s]:%s", buffer, port);
756 snprintf(dest, destsize, "[%s]", buffer);
758 dest[destsize - 1] = '\0';
760 ast_copy_string(dest, src, destsize);
769 * \brief Convert "[x.x.x.x]:port" or "hostname:prot" to "address:port" format
770 * \param src Source address string
771 * \param dest Destination address string
772 * \param destsize Size of dest buffer
774 static void osp_convert_outin(
777 unsigned int destsize)
779 char buffer[OSP_SIZE_NORSTR];
783 if ((dest != NULL) && (destsize > 0)) {
784 if (!ast_strlen_zero(src)) {
785 ast_copy_string(buffer, src, sizeof(buffer));
787 if (buffer[0] == '[') {
788 if((port = strchr(buffer + 1, ':')) != NULL) {
793 if ((end = strchr(buffer + 1, ']')) != NULL) {
798 snprintf(dest, destsize, "%s:%s", buffer + 1, port);
799 dest[destsize - 1] = '\0';
801 ast_copy_string(dest, buffer + 1, destsize);
804 ast_copy_string(dest, src, destsize);
813 * \brief Validate OSP token of inbound call
814 * \param trans OSP transaction handle
815 * \param source Source of inbound call
816 * \param destination Destination of inbound call
817 * \param calling Calling number
818 * \param called Called number
819 * \param token OSP token, may be empty
820 * \param timelimit Call duration limit, output
821 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
823 static int osp_validate_token(
826 const char* destination,
830 unsigned int* timelimit)
834 unsigned char tokenstr[OSP_SIZE_TOKSTR];
835 char src[OSP_SIZE_NORSTR];
836 char dest[OSP_SIZE_NORSTR];
837 unsigned int authorised;
838 unsigned int dummy = 0;
841 if (timelimit == NULL) {
842 ast_log(LOG_ERROR, "Invalid parameters\n");
846 tokenlen = ast_base64decode(tokenstr, token, strlen(token));
847 osp_convert_inout(source, src, sizeof(src));
848 osp_convert_inout(destination, dest, sizeof(dest));
849 error = OSPPTransactionValidateAuthorisation(trans,
854 calling ? calling : "",
867 if (error != OSPC_ERR_NO_ERROR) {
868 ast_log(LOG_WARNING, "OSP: Unable to validate inbound token, error '%d'\n", error);
871 } else if (authorised) {
872 ast_debug(1, "OSP: Authorised\n");
875 ast_debug(1, "OSP: Unauthorised\n");
883 * \brief Choose min duration limit
884 * \param in Inbound duration limit
885 * \param out Outbound duration limit
886 * \return min duration limit
888 static unsigned int osp_choose_timelimit(
892 if (in == OSP_DEF_TIMELIMIT) {
894 } else if (out == OSP_DEF_TIMELIMIT) {
897 return in < out ? in : out;
902 * \brief Choose min duration limit
903 * \param provider OSP provider
904 * \param calling Calling number
905 * \param called Called number
906 * \param destination Destination IP in '[x.x.x.x]' format
907 * \param tokenlen OSP token length
908 * \param token OSP token
909 * \param reason Failure reason, output
910 * \param results OSP lookup results, in/output
911 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
913 static int osp_check_destination(
914 struct osp_provider* provider,
917 const char* destination,
918 unsigned int tokenlen,
920 OSPEFAILREASON* reason,
921 struct osp_results* results)
924 OSPE_DEST_OSPENABLED enabled;
925 OSPE_DEST_PROTOCOL protocol;
926 char dest[OSP_SIZE_NORSTR];
929 if ((provider == NULL) || (reason == NULL) || (results == NULL)) {
930 ast_log(LOG_ERROR, "Invalid parameters\n");
934 if ((error = OSPPTransactionIsDestOSPEnabled(results->outhandle, &enabled)) != OSPC_ERR_NO_ERROR) {
935 ast_debug(1, "OSP: Unable to get destination OSP version, error '%d'\n", error);
936 *reason = OSPC_FAIL_NORMAL_UNSPECIFIED;
940 if (enabled == OSPC_DOSP_FALSE) {
941 results->token[0] = '\0';
943 ast_base64encode(results->token, (const unsigned char*)token, tokenlen, sizeof(results->token) - 1);
946 if ((error = OSPPTransactionGetDestinationNetworkId(results->outhandle, sizeof(results->networkid), results->networkid)) != OSPC_ERR_NO_ERROR) {
947 ast_debug(1, "OSP: Unable to get destination network ID, error '%d'\n", error);
948 results->networkid[0] = '\0';
951 error = OSPPTransactionGetNumberPortabilityParameters(results->outhandle,
952 sizeof(results->nprn),
954 sizeof(results->npcic),
957 if (error != OSPC_ERR_NO_ERROR) {
958 ast_debug(1, "OSP: Unable to get number portability parameters, error '%d'\n", error);
959 results->nprn[0] = '\0';
960 results->npcic[0] = '\0';
964 if ((error = OSPPTransactionGetDestProtocol(results->outhandle, &protocol)) != OSPC_ERR_NO_ERROR) {
965 ast_debug(1, "OSP: Unable to get destination protocol, error '%d'\n", error);
966 *reason = OSPC_FAIL_NORMAL_UNSPECIFIED;
967 results->token[0] = '\0';
968 results->networkid[0] = '\0';
969 results->nprn[0] = '\0';
970 results->npcic[0] = '\0';
976 osp_convert_outin(destination, dest, sizeof(dest));
979 ast_debug(1, "OSP: protocol SIP\n");
980 ast_copy_string(results->tech, OSP_TECH_SIP, sizeof(results->tech));
981 ast_copy_string(results->dest, dest, sizeof(results->dest));
982 ast_copy_string(results->calling, calling, sizeof(results->calling));
983 ast_copy_string(results->called, called, sizeof(results->called));
985 case OSPC_DPROT_Q931:
986 ast_debug(1, "OSP: protocol Q.931\n");
987 ast_copy_string(results->tech, OSP_TECH_H323, sizeof(results->tech));
988 ast_copy_string(results->dest, dest, sizeof(results->dest));
989 ast_copy_string(results->calling, calling, sizeof(results->calling));
990 ast_copy_string(results->called, called, sizeof(results->called));
993 ast_debug(1, "OSP: protocol IAX\n");
994 ast_copy_string(results->tech, OSP_TECH_IAX, sizeof(results->tech));
995 ast_copy_string(results->dest, dest, sizeof(results->dest));
996 ast_copy_string(results->calling, calling, sizeof(results->calling));
997 ast_copy_string(results->called, called, sizeof(results->called));
999 case OSPC_DPROT_SKYPE:
1000 ast_debug(1, "OSP: protocol Skype\n");
1001 ast_copy_string(results->tech, OSP_TECH_SKYPE, sizeof(results->tech));
1002 ast_copy_string(results->dest, dest, sizeof(results->dest));
1003 ast_copy_string(results->calling, calling, sizeof(results->calling));
1004 ast_copy_string(results->called, called, sizeof(results->called));
1006 case OSPC_DPROT_UNDEFINED:
1007 case OSPC_DPROT_UNKNOWN:
1008 ast_debug(1, "OSP: unknown/undefined protocol '%d'\n", protocol);
1009 ast_debug(1, "OSP: use default protocol '%s'\n", provider->defprotocol);
1010 ast_copy_string(results->tech, provider->defprotocol, sizeof(results->tech));
1011 ast_copy_string(results->dest, dest, sizeof(results->dest));
1012 ast_copy_string(results->calling, calling, sizeof(results->calling));
1013 ast_copy_string(results->called, called, sizeof(results->called));
1015 case OSPC_DPROT_LRQ:
1016 case OSPC_DPROT_T37:
1017 case OSPC_DPROT_T38:
1018 case OSPC_DPROT_SMPP:
1019 case OSPC_DPROT_XMPP:
1021 ast_log(LOG_WARNING, "OSP: unsupported protocol '%d'\n", protocol);
1022 *reason = OSPC_FAIL_PROTOCOL_ERROR;
1023 results->token[0] = '\0';
1024 results->networkid[0] = '\0';
1025 results->nprn[0] = '\0';
1026 results->npcic[0] = '\0';
1036 * \brief Convert Asterisk status to TC code
1037 * \param cause Asterisk hangup cause
1038 * \return OSP TC code
1040 static OSPEFAILREASON asterisk2osp(
1043 return (OSPEFAILREASON)cause;
1047 * \brief OSP Authentication function
1048 * \param name OSP provider context name
1049 * \param trans OSP transaction handle, output
1050 * \param source Source of inbound call
1051 * \param calling Calling number
1052 * \param called Called number
1053 * \param token OSP token, may be empty
1054 * \param timelimit Call duration limit, output
1055 * \return OSP_OK Authenricated, OSP_FAILED Unauthenticated, OSP_ERROR Error
1057 static int osp_auth(
1061 const char* calling,
1064 unsigned int* timelimit)
1067 struct osp_provider* provider = NULL;
1068 char dest[OSP_SIZE_NORSTR];
1070 if ((trans == NULL) || (timelimit == NULL)) {
1071 ast_log(LOG_ERROR, "Invalid parameters\n");
1075 *trans = OSP_INVALID_HANDLE;
1076 *timelimit = OSP_DEF_TIMELIMIT;
1078 if ((res = osp_get_provider(name, &provider)) <= 0) {
1079 ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
1083 switch (provider->authpolicy) {
1088 if (ast_strlen_zero(token)) {
1090 } else if ((res = osp_create_transaction(name, trans, dest, sizeof(dest))) <= 0) {
1091 ast_debug(1, "OSP: Unable to generate transaction handle\n");
1092 *trans = OSP_INVALID_HANDLE;
1094 } else if((res = osp_validate_token(*trans, source, dest, calling, called, token, timelimit)) <= 0) {
1095 OSPPTransactionRecordFailure(*trans, OSPC_FAIL_CALL_REJECTED);
1100 if (ast_strlen_zero(token)) {
1102 } else if ((res = osp_create_transaction(name, trans, dest, sizeof(dest))) <= 0) {
1103 ast_debug(1, "OSP: Unable to generate transaction handle\n");
1104 *trans = OSP_INVALID_HANDLE;
1106 } else if((res = osp_validate_token(*trans, source, dest, calling, called, token, timelimit)) <= 0) {
1107 OSPPTransactionRecordFailure(*trans, OSPC_FAIL_CALL_REJECTED);
1116 * \brief Create a UUID
1117 * \param uuid UUID buffer
1118 * \param bufsize UUID buffer size
1119 * \return OSK_OK Created, OSP_ERROR Error
1121 static int osp_create_uuid(
1122 unsigned char* uuid,
1123 unsigned int* bufsize)
1126 long int tmp[OSP_SIZE_UUID / sizeof(long int)];
1128 if ((uuid != NULL) && (*bufsize >= OSP_SIZE_UUID)) {
1129 for (i = 0; i < OSP_SIZE_UUID / sizeof(long int); i++) {
1130 tmp[i] = ast_random();
1132 memcpy(uuid, tmp, OSP_SIZE_UUID);
1133 *bufsize = OSP_SIZE_UUID;
1136 ast_log(LOG_ERROR, "Invalid parameters\n");
1144 * \brief UUID to string
1146 * \param buffer String buffer
1147 * \param bufsize String buffer size
1148 * \return OSP_OK Successed, OSP_ERROR Error
1150 static int osp_uuid2str(
1151 unsigned char* uuid,
1153 unsigned int bufsize)
1157 if ((uuid != NULL) && (bufsize > OSP_SIZE_UUIDSTR)) {
1158 snprintf(buffer, bufsize, "%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x",
1159 uuid[0], uuid[1], uuid[2], uuid[3], uuid[4], uuid[5], uuid[6], uuid[7],
1160 uuid[8], uuid[9], uuid[10], uuid[11], uuid[12], uuid[13], uuid[14], uuid[15]);
1163 ast_log(LOG_ERROR, "Invalid parameters\n");
1171 * \brief Create a call ID according to the type
1172 * \param type Call ID type
1173 * \param callid Call ID buffer
1174 * \return OSK_OK Created, OSP_FAILED Not create, OSP_ERROR Error
1176 static int osp_create_callid(
1178 struct osp_callid* callid)
1182 if (callid == NULL) {
1183 ast_log(LOG_ERROR, "Invalid parameters\n");
1187 callid->len = sizeof(callid->buf);
1189 case OSP_CALLID_H323:
1190 res = osp_create_uuid(callid->buf, &callid->len);
1192 case OSP_CALLID_SIP:
1193 case OSP_CALLID_IAX:
1200 if ((res != OSP_OK) && (callid->len != 0)) {
1201 callid->buf[0] = '\0';
1209 * \brief OSP Lookup function
1210 * \param name OSP provider context name
1211 * \param callidtypes Call ID types
1212 * \param srcdev Source device of outbound call
1213 * \param calling Calling number
1214 * \param called Called number
1215 * \param snetid Source network ID
1216 * \param np NP parameters
1217 * \param div SIP Diversion header parameters
1218 * \param cinfo Custom info
1219 * \param results Lookup results
1220 * \return OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error
1222 static int osp_lookup(
1224 unsigned int callidtypes,
1226 const char* calling,
1229 struct osp_npparam* np,
1230 struct osp_diversion* div,
1231 const char* cinfo[],
1232 struct osp_results* results)
1235 struct osp_provider* provider = NULL;
1236 char source[OSP_SIZE_NORSTR];
1237 char callingnum[OSP_SIZE_NORSTR];
1238 char callednum[OSP_SIZE_NORSTR];
1239 char destination[OSP_SIZE_NORSTR];
1240 unsigned int tokenlen;
1241 char token[OSP_SIZE_TOKSTR];
1242 char src[OSP_SIZE_NORSTR];
1243 char dev[OSP_SIZE_NORSTR];
1244 char host[OSP_SIZE_NORSTR];
1245 unsigned int i, type;
1246 struct osp_callid callid;
1247 unsigned int callidnum;
1248 OSPT_CALL_ID* callids[OSP_CALLID_MAXNUM];
1249 char dest[OSP_SIZE_NORSTR];
1250 const char* preferred[2] = { NULL };
1251 unsigned int dummy = 0;
1252 OSPEFAILREASON reason;
1255 if (results == NULL) {
1256 ast_log(LOG_ERROR, "Invalid parameters\n");
1260 osp_convert_inout(results->dest, dest, sizeof(dest));
1262 results->outhandle = OSP_INVALID_HANDLE;
1263 results->tech[0] = '\0';
1264 results->calling[0] = '\0';
1265 results->called[0] = '\0';
1266 results->token[0] = '\0';
1267 results->networkid[0] = '\0';
1268 results->nprn[0] = '\0';
1269 results->npcic[0] = '\0';
1271 results->numdests = 0;
1272 results->outtimelimit = OSP_DEF_TIMELIMIT;
1274 if ((res = osp_get_provider(name, &provider)) <= 0) {
1275 ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
1279 if ((res = osp_create_transaction(name, &results->outhandle, source, sizeof(source))) <= 0) {
1280 ast_debug(1, "OSP: Unable to generate transaction handle\n");
1281 results->outhandle = OSP_INVALID_HANDLE;
1282 if (results->inhandle != OSP_INVALID_HANDLE) {
1283 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
1288 if (!ast_strlen_zero(snetid)) {
1289 OSPPTransactionSetNetworkIds(results->outhandle, snetid, "");
1292 OSPPTransactionSetNumberPortability(results->outhandle, np->rn, np->cic, np->npdi);
1294 osp_convert_inout(div->host, host, sizeof(host));
1295 OSPPTransactionSetDiversion(results->outhandle, div->user, host);
1297 if (cinfo != NULL) {
1298 for (i = 0; i < OSP_MAX_CUSTOMINFO; i++) {
1299 if (!ast_strlen_zero(cinfo[i])) {
1300 OSPPTransactionSetCustomInfo(results->outhandle, i, cinfo[i]);
1307 for (i = 0; i < OSP_CALLID_MAXNUM; i++) {
1309 if (callidtypes & type) {
1310 error = osp_create_callid(type, &callid);
1312 callids[callidnum] = OSPPCallIdNew(callid.len, callid.buf);
1318 osp_convert_inout(source, src, sizeof(src));
1319 osp_convert_inout(srcdev, dev, sizeof(dev));
1320 if (provider->srvtype == OSP_SRV_NPQUERY) {
1321 OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_NPQUERY);
1322 if (!ast_strlen_zero(dest)) {
1323 preferred[0] = dest;
1325 results->numdests = 1;
1327 OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_VOICE);
1328 results->numdests = OSP_DEF_MAXDESTS;
1330 error = OSPPTransactionRequestAuthorisation(results->outhandle,
1333 calling ? calling : "",
1345 for (i = 0; i < callidnum; i++) {
1346 OSPPCallIdDelete(&callids[i]);
1349 if (error != OSPC_ERR_NO_ERROR) {
1350 ast_log(LOG_WARNING, "OSP: Unable to request authorization, error '%d'\n", error);
1351 results->numdests = 0;
1352 if (results->inhandle != OSP_INVALID_HANDLE) {
1353 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
1358 if (!results->numdests) {
1359 ast_debug(1, "OSP: No more destination\n");
1360 if (results->inhandle != OSP_INVALID_HANDLE) {
1361 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1366 results->outcallid.len = sizeof(results->outcallid.buf);
1367 tokenlen = sizeof(token);
1368 error = OSPPTransactionGetFirstDestination(results->outhandle,
1372 &results->outtimelimit,
1373 &results->outcallid.len,
1374 results->outcallid.buf,
1379 sizeof(destination),
1385 if (error != OSPC_ERR_NO_ERROR) {
1386 ast_debug(1, "OSP: Unable to get first route, error '%d'\n", error);
1387 results->numdests = 0;
1388 results->outtimelimit = OSP_DEF_TIMELIMIT;
1389 if (results->inhandle != OSP_INVALID_HANDLE) {
1390 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1395 results->numdests--;
1396 results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
1397 ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
1398 ast_debug(1, "OSP: calling '%s'\n", callingnum);
1399 ast_debug(1, "OSP: called '%s'\n", callednum);
1400 ast_debug(1, "OSP: destination '%s'\n", destination);
1401 ast_debug(1, "OSP: token size '%d'\n", tokenlen);
1403 if ((res = osp_check_destination(provider, callingnum, callednum, destination, tokenlen, token, &reason, results)) > 0) {
1407 if (!results->numdests) {
1408 ast_debug(1, "OSP: No more destination\n");
1409 results->outtimelimit = OSP_DEF_TIMELIMIT;
1410 OSPPTransactionRecordFailure(results->outhandle, reason);
1411 if (results->inhandle != OSP_INVALID_HANDLE) {
1412 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1417 while(results->numdests) {
1418 results->outcallid.len = sizeof(results->outcallid.buf);
1419 tokenlen = sizeof(token);
1420 error = OSPPTransactionGetNextDestination(results->outhandle,
1425 &results->outtimelimit,
1426 &results->outcallid.len,
1427 results->outcallid.buf,
1432 sizeof(destination),
1438 if (error == OSPC_ERR_NO_ERROR) {
1439 results->numdests--;
1440 results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
1441 ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
1442 ast_debug(1, "OSP: calling '%s'\n", callingnum);
1443 ast_debug(1, "OSP: called '%s'\n", callednum);
1444 ast_debug(1, "OSP: destination '%s'\n", destination);
1445 ast_debug(1, "OSP: token size '%d'\n", tokenlen);
1447 if ((res = osp_check_destination(provider, callingnum, callednum, destination, tokenlen, token, &reason, results)) > 0) {
1449 } else if (!results->numdests) {
1450 ast_debug(1, "OSP: No more destination\n");
1451 OSPPTransactionRecordFailure(results->outhandle, reason);
1452 if (results->inhandle != OSP_INVALID_HANDLE) {
1453 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1459 ast_debug(1, "OSP: Unable to get route, error '%d'\n", error);
1460 results->numdests = 0;
1461 results->outtimelimit = OSP_DEF_TIMELIMIT;
1462 if (results->inhandle != OSP_INVALID_HANDLE) {
1463 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
1474 * \brief OSP Lookup Next function
1475 * \param name OSP provider name
1476 * \param cause Asterisk hangup cuase
1477 * \param results Lookup results, in/output
1478 * \return OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error
1480 static int osp_next(
1483 struct osp_results* results)
1486 struct osp_provider* provider = NULL;
1487 char calling[OSP_SIZE_NORSTR];
1488 char called[OSP_SIZE_NORSTR];
1489 char dest[OSP_SIZE_NORSTR];
1490 unsigned int tokenlen;
1491 char token[OSP_SIZE_TOKSTR];
1492 OSPEFAILREASON reason;
1495 if (results == NULL) {
1496 ast_log(LOG_ERROR, "Invalid parameters\n");
1500 results->tech[0] = '\0';
1501 results->dest[0] = '\0';
1502 results->calling[0] = '\0';
1503 results->called[0] = '\0';
1504 results->token[0] = '\0';
1505 results->networkid[0] = '\0';
1506 results->nprn[0] = '\0';
1507 results->npcic[0] = '\0';
1509 results->outtimelimit = OSP_DEF_TIMELIMIT;
1511 if ((res = osp_get_provider(name, &provider)) <= 0) {
1512 ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
1516 if (results->outhandle == OSP_INVALID_HANDLE) {
1517 ast_debug(1, "OSP: Transaction handle undefined\n");
1518 results->numdests = 0;
1519 if (results->inhandle != OSP_INVALID_HANDLE) {
1520 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
1525 reason = asterisk2osp(cause);
1527 if (!results->numdests) {
1528 ast_debug(1, "OSP: No more destination\n");
1529 OSPPTransactionRecordFailure(results->outhandle, reason);
1530 if (results->inhandle != OSP_INVALID_HANDLE) {
1531 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1536 while(results->numdests) {
1537 results->outcallid.len = sizeof(results->outcallid.buf);
1538 tokenlen = sizeof(token);
1539 error = OSPPTransactionGetNextDestination(
1545 &results->outtimelimit,
1546 &results->outcallid.len,
1547 results->outcallid.buf,
1558 if (error == OSPC_ERR_NO_ERROR) {
1559 results->numdests--;
1560 results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
1561 ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
1562 ast_debug(1, "OSP: calling '%s'\n", calling);
1563 ast_debug(1, "OSP: called '%s'\n", called);
1564 ast_debug(1, "OSP: destination '%s'\n", dest);
1565 ast_debug(1, "OSP: token size '%d'\n", tokenlen);
1567 if ((res = osp_check_destination(provider, calling, called, dest, tokenlen, token, &reason, results)) > 0) {
1570 } else if (!results->numdests) {
1571 ast_debug(1, "OSP: No more destination\n");
1572 OSPPTransactionRecordFailure(results->outhandle, reason);
1573 if (results->inhandle != OSP_INVALID_HANDLE) {
1574 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
1580 ast_debug(1, "OSP: Unable to get route, error '%d'\n", error);
1581 results->token[0] = '\0';
1582 results->numdests = 0;
1583 results->outtimelimit = OSP_DEF_TIMELIMIT;
1584 if (results->inhandle != OSP_INVALID_HANDLE) {
1585 OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
1596 * \brief Get integer from variable string
1597 * \param vstr Variable string
1598 * \return OSP_DEF_INTSTATS Error
1600 static int osp_get_varint(
1604 int value = OSP_DEF_INTSTATS;
1606 if (!ast_strlen_zero(vstr)) {
1607 if ((tmp = strchr(vstr, '=')) != NULL) {
1609 if (sscanf(tmp, "%30d", &value) != 1) {
1610 value = OSP_DEF_INTSTATS;
1619 * \brief Get float from variable string
1620 * \param vstr Variable string
1621 * \return OSP_DEF_FLOATSTATS Error
1623 static float osp_get_varfloat(
1627 float value = OSP_DEF_FLOATSTATS;
1629 if (!ast_strlen_zero(vstr)) {
1630 if ((tmp = strchr(vstr, '=')) != NULL) {
1632 if (sscanf(tmp, "%30f", &value) != 1) {
1633 value = OSP_DEF_FLOATSTATS;
1643 * \param trans OSP in/outbound transaction handle
1644 * \param leg Inbound/outbound
1645 * \param qos QoS string
1646 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
1648 static int osp_report_qos(
1650 enum osp_callleg leg,
1653 int res = OSP_FAILED;
1654 enum osp_direction dir;
1655 char buffer[OSP_SIZE_NORSTR];
1658 int totalpackets[OSP_DIR_NUMBER];
1659 struct osp_metrics lost[OSP_DIR_NUMBER];
1660 struct osp_metrics jitter[OSP_DIR_NUMBER];
1661 struct osp_metrics rtt;
1664 if (!ast_strlen_zero(qos)) {
1665 for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
1666 totalpackets[dir] = OSP_DEF_INTSTATS;
1669 for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
1670 lost[dir].value = OSP_DEF_INTSTATS;
1671 lost[dir].min = OSP_DEF_FLOATSTATS;
1672 lost[dir].max = OSP_DEF_FLOATSTATS;
1673 lost[dir].avg = OSP_DEF_FLOATSTATS;
1674 lost[dir].sdev = OSP_DEF_FLOATSTATS;
1677 for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
1678 jitter[dir].value = OSP_DEF_INTSTATS;
1679 jitter[dir].min = OSP_DEF_FLOATSTATS;
1680 jitter[dir].max = OSP_DEF_FLOATSTATS;
1681 jitter[dir].avg = OSP_DEF_FLOATSTATS;
1682 jitter[dir].sdev = OSP_DEF_FLOATSTATS;
1685 rtt.value = OSP_DEF_INTSTATS;
1686 rtt.min = OSP_DEF_FLOATSTATS;
1687 rtt.max = OSP_DEF_FLOATSTATS;
1688 rtt.avg = OSP_DEF_FLOATSTATS;
1689 rtt.sdev = OSP_DEF_FLOATSTATS;
1691 ast_copy_string(buffer, qos, sizeof(buffer));
1692 for (item = strtok_r(buffer, ";", &tmp); item; item = strtok_r(NULL, ";", &tmp)) {
1693 if (!strncasecmp(item, "rxcount", strlen("rxcount"))) {
1694 totalpackets[OSP_DIR_RX] = osp_get_varint(item);
1695 } else if (!strncasecmp(item, "txcount", strlen("txcount"))) {
1696 totalpackets[OSP_DIR_TX] = osp_get_varint(item);
1697 } else if (!strncasecmp(item, "lp", strlen("lp"))) {
1698 lost[OSP_DIR_RX].value = osp_get_varint(item);
1699 } else if (!strncasecmp(item, "minrxlost", strlen("minrxlost"))) {
1700 lost[OSP_DIR_RX].min = osp_get_varfloat(item);
1701 } else if (!strncasecmp(item, "maxrxlost", strlen("maxrxlost"))) {
1702 lost[OSP_DIR_RX].max = osp_get_varfloat(item);
1703 } else if (!strncasecmp(item, "avgrxlost", strlen("avgrxlost"))) {
1704 lost[OSP_DIR_RX].avg = osp_get_varfloat(item);
1705 } else if (!strncasecmp(item, "stdevrxlost", strlen("stdevrxlost"))) {
1706 lost[OSP_DIR_RX].sdev = osp_get_varfloat(item);
1707 } else if (!strncasecmp(item, "rlp", strlen("rlp"))) {
1708 lost[OSP_DIR_TX].value = osp_get_varint(item);
1709 } else if (!strncasecmp(item, "reported_minlost", strlen("reported_minlost"))) {
1710 lost[OSP_DIR_TX].min = osp_get_varfloat(item);
1711 } else if (!strncasecmp(item, "reported_maxlost", strlen("reported_maxlost"))) {
1712 lost[OSP_DIR_TX].max = osp_get_varfloat(item);
1713 } else if (!strncasecmp(item, "reported_avglost", strlen("reported_avglost"))) {
1714 lost[OSP_DIR_TX].avg = osp_get_varfloat(item);
1715 } else if (!strncasecmp(item, "reported_stdevlost", strlen("reported_stdevlost"))) {
1716 lost[OSP_DIR_TX].sdev = osp_get_varfloat(item);
1717 } else if (!strncasecmp(item, "rxjitter", strlen("rxjitter"))) {
1718 jitter[OSP_DIR_RX].value = osp_get_varint(item);
1719 } else if (!strncasecmp(item, "minrxjitter", strlen("minrxjitter"))) {
1720 jitter[OSP_DIR_RX].min = osp_get_varfloat(item);
1721 } else if (!strncasecmp(item, "maxrxjitter", strlen("maxrxjitter"))) {
1722 jitter[OSP_DIR_RX].max = osp_get_varfloat(item);
1723 } else if (!strncasecmp(item, "avgrxjitter", strlen("avgjitter"))) {
1724 jitter[OSP_DIR_RX].avg = osp_get_varfloat(item);
1725 } else if (!strncasecmp(item, "stdevrxjitter", strlen("stdevjitter"))) {
1726 jitter[OSP_DIR_RX].sdev = osp_get_varfloat(item);
1727 } else if (!strncasecmp(item, "txjitter", strlen("txjitter"))) {
1728 jitter[OSP_DIR_TX].value = osp_get_varint(item);
1729 } else if (!strncasecmp(item, "reported_minjitter", strlen("reported_minjitter"))) {
1730 jitter[OSP_DIR_TX].min = osp_get_varfloat(item);
1731 } else if (!strncasecmp(item, "reported_maxjitter", strlen("reported_maxjitter"))) {
1732 jitter[OSP_DIR_TX].max = osp_get_varfloat(item);
1733 } else if (!strncasecmp(item, "reported_avgjitter", strlen("reported_avgjitter"))) {
1734 jitter[OSP_DIR_TX].avg = osp_get_varfloat(item);
1735 } else if (!strncasecmp(item, "reported_stdevjitter", strlen("reported_stdevjitter"))) {
1736 jitter[OSP_DIR_TX].sdev = osp_get_varfloat(item);
1737 } else if (!strncasecmp(item, "rtt", strlen("rtt"))) {
1738 rtt.value = osp_get_varint(item);
1739 } else if (!strncasecmp(item, "minrtt", strlen("minrtt"))) {
1740 rtt.min = osp_get_varfloat(item);
1741 } else if (!strncasecmp(item, "maxrtt", strlen("maxrtt"))) {
1742 rtt.max = osp_get_varfloat(item);
1743 } else if (!strncasecmp(item, "avgrtt", strlen("avgrtt"))) {
1744 rtt.avg = osp_get_varfloat(item);
1745 } else if (!strncasecmp(item, "stdevrtt", strlen("stdevrtt"))) {
1746 rtt.sdev = osp_get_varfloat(item);
1750 ast_debug(1, "OSP: call leg '%d'\n", leg);
1751 ast_debug(1, "OSP: rxcount '%d'\n", totalpackets[OSP_DIR_RX]);
1752 ast_debug(1, "OSP: txcount '%d'\n", totalpackets[OSP_DIR_TX]);
1753 ast_debug(1, "OSP: lp '%d'\n",lost[OSP_DIR_RX].value);
1754 ast_debug(1, "OSP: minrxlost '%f'\n", lost[OSP_DIR_RX].min);
1755 ast_debug(1, "OSP: maxrxlost '%f'\n", lost[OSP_DIR_RX].max);
1756 ast_debug(1, "OSP: avgrxlost '%f'\n", lost[OSP_DIR_RX].avg);
1757 ast_debug(1, "OSP: stdevrxlost '%f'\n", lost[OSP_DIR_RX].sdev);
1758 ast_debug(1, "OSP: rlp '%d'\n", lost[OSP_DIR_TX].value);
1759 ast_debug(1, "OSP: reported_minlost '%f'\n", lost[OSP_DIR_TX].min);
1760 ast_debug(1, "OSP: reported_maxlost '%f'\n", lost[OSP_DIR_TX].max);
1761 ast_debug(1, "OSP: reported_avglost '%f'\n", lost[OSP_DIR_TX].avg);
1762 ast_debug(1, "OSP: reported_stdevlost '%f'\n", lost[OSP_DIR_TX].sdev);
1763 ast_debug(1, "OSP: rxjitter '%d'\n", jitter[OSP_DIR_RX].value);
1764 ast_debug(1, "OSP: minrxjitter '%f'\n", jitter[OSP_DIR_RX].min);
1765 ast_debug(1, "OSP: maxrxjitter '%f'\n", jitter[OSP_DIR_RX].max);
1766 ast_debug(1, "OSP: avgrxjitter '%f'\n", jitter[OSP_DIR_RX].avg);
1767 ast_debug(1, "OSP: stdevrxjitter '%f'\n", jitter[OSP_DIR_RX].sdev);
1768 ast_debug(1, "OSP: txjitter '%d'\n", jitter[OSP_DIR_TX].value);
1769 ast_debug(1, "OSP: reported_minjitter '%f'\n", jitter[OSP_DIR_TX].min);
1770 ast_debug(1, "OSP: reported_maxjitter '%f'\n", jitter[OSP_DIR_TX].max);
1771 ast_debug(1, "OSP: reported_avgjitter '%f'\n", jitter[OSP_DIR_TX].avg);
1772 ast_debug(1, "OSP: reported_stdevjitter '%f'\n", jitter[OSP_DIR_TX].sdev);
1773 ast_debug(1, "OSP: rtt '%d'\n", rtt.value);
1774 ast_debug(1, "OSP: minrtt '%f'\n", rtt.min);
1775 ast_debug(1, "OSP: maxrtt '%f'\n", rtt.max);
1776 ast_debug(1, "OSP: avgrtt '%f'\n", rtt.avg);
1777 ast_debug(1, "OSP: stdevrtt '%f'\n", rtt.sdev);
1779 if (leg == OSP_CALL_INBOUND) {
1780 OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_DOWNSTREAM, totalpackets[OSP_DIR_RX]);
1781 OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_UPSTREAM, totalpackets[OSP_DIR_TX]);
1782 if (lost[OSP_DIR_RX].value >= 0) {
1783 value = lost[OSP_DIR_RX].value;
1785 value = (int)lost[OSP_DIR_RX].avg;
1787 OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_DOWNSTREAM, value, OSP_DEF_INTSTATS);
1788 if (lost[OSP_DIR_TX].value >= 0) {
1789 value = lost[OSP_DIR_TX].value;
1791 value = (int)lost[OSP_DIR_TX].avg;
1793 OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_UPSTREAM, value, OSP_DEF_INTSTATS);
1794 if (jitter[OSP_DIR_RX].value >= 0) {
1795 value = jitter[OSP_DIR_RX].value;
1797 value = (int)jitter[OSP_DIR_RX].avg;
1799 OSPPTransactionSetJitter(trans,
1801 OSPC_SFLOW_DOWNSTREAM,
1803 (int)jitter[OSP_DIR_RX].min,
1804 (int)jitter[OSP_DIR_RX].max,
1805 value, jitter[OSP_DIR_RX].sdev);
1806 if (jitter[OSP_DIR_TX].value >= 0) {
1807 value = jitter[OSP_DIR_TX].value;
1809 value = (int)jitter[OSP_DIR_TX].avg;
1811 OSPPTransactionSetJitter(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_UPSTREAM,
1812 OSP_DEF_INTSTATS, (int)jitter[OSP_DIR_TX].min, (int)jitter[OSP_DIR_TX].max, value, jitter[OSP_DIR_TX].sdev);
1814 OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_UPSTREAM, totalpackets[OSP_DIR_RX]);
1815 OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_DOWNSTREAM, totalpackets[OSP_DIR_TX]);
1816 OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_UPSTREAM, lost[OSP_DIR_RX].value, OSP_DEF_INTSTATS);
1817 OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_DOWNSTREAM, lost[OSP_DIR_TX].value, OSP_DEF_INTSTATS);
1818 if (jitter[OSP_DIR_RX].value >= 0) {
1819 value = jitter[OSP_DIR_RX].value;
1821 value = (int)jitter[OSP_DIR_RX].avg;
1823 OSPPTransactionSetJitter(trans,
1825 OSPC_SFLOW_UPSTREAM,
1827 (int)jitter[OSP_DIR_RX].min,
1828 (int)jitter[OSP_DIR_RX].max,
1830 jitter[OSP_DIR_RX].sdev);
1831 if (jitter[OSP_DIR_TX].value >= 0) {
1832 value = jitter[OSP_DIR_TX].value;
1834 value = (int)jitter[OSP_DIR_TX].avg;
1836 OSPPTransactionSetJitter(trans,
1838 OSPC_SFLOW_DOWNSTREAM,
1840 (int)jitter[OSP_DIR_TX].min,
1841 (int)jitter[OSP_DIR_TX].max,
1843 jitter[OSP_DIR_TX].sdev);
1845 if (rtt.value >= 0) {
1848 value = (int)rtt.avg;
1850 OSPPTransactionSetRoundTripDelay(trans, OSP_DEF_INTSTATS, (int)rtt.min, (int)rtt.max, value, rtt.sdev);
1859 * \brief OSP Finish function
1860 * \param trans OSP in/outbound transaction handle
1861 * \param recorded If failure reason has been recorded
1862 * \param cause Asterisk hangup cause
1863 * \param start Call start time
1864 * \param connect Call connect time
1865 * \param end Call end time
1866 * \param release Who release first, 0 source, 1 destination
1867 * \param inqos Inbound QoS string
1868 * \param outqos Outbound QoS string
1869 * \return OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error
1871 static int osp_finish(
1878 unsigned int release,
1883 OSPEFAILREASON reason;
1885 unsigned isPddInfoPresent = 0;
1887 unsigned int dummy = 0;
1890 if (trans == OSP_INVALID_HANDLE) {
1895 reason = asterisk2osp(cause);
1896 OSPPTransactionRecordFailure(trans, reason);
1899 osp_report_qos(trans, OSP_CALL_INBOUND, inqos);
1900 osp_report_qos(trans, OSP_CALL_OUTBOUND, outqos);
1902 error = OSPPTransactionReportUsage(trans,
1903 difftime(end, connect),
1918 if (error == OSPC_ERR_NO_ERROR) {
1919 ast_debug(1, "OSP: Usage reported\n");
1922 ast_debug(1, "OSP: Unable to report usage, error '%d'\n", error);
1925 OSPPTransactionDelete(trans);
1930 /* OSP Application APIs */
1933 * \brief OSP Application OSPAuth
1934 * \param chan Channel
1935 * \param data Parameter
1936 * \return OSP_AST_OK Success, OSP_AST_ERROR Error
1938 static int ospauth_exec(
1939 struct ast_channel *chan,
1943 const char* provider = OSP_DEF_PROVIDER;
1944 struct varshead* headp;
1945 struct ast_var_t* current;
1946 const char* source = "";
1947 const char* token = "";
1949 unsigned int timelimit;
1950 char buffer[OSP_SIZE_INTSTR];
1954 AST_DECLARE_APP_ARGS(args,
1955 AST_APP_ARG(provider);
1956 AST_APP_ARG(options);
1959 if (!(tmp = ast_strdupa(data))) {
1960 ast_log(LOG_ERROR, "Out of memory\n");
1961 return OSP_AST_ERROR;
1964 AST_STANDARD_APP_ARGS(args, tmp);
1966 if (!ast_strlen_zero(args.provider)) {
1967 provider = args.provider;
1969 ast_debug(1, "OSPAuth: provider '%s'\n", provider);
1971 headp = &chan->varshead;
1972 AST_LIST_TRAVERSE(headp, current, entries) {
1973 if (!strcasecmp(ast_var_name(current), "OSPINPEERIP")) {
1974 source = ast_var_value(current);
1975 } else if (!strcasecmp(ast_var_name(current), "OSPINTOKEN")) {
1976 token = ast_var_value(current);
1980 ast_debug(1, "OSPAuth: source '%s'\n", source);
1981 ast_debug(1, "OSPAuth: token size '%zd'\n", strlen(token));
1983 if ((res = osp_auth(provider, &handle, source, chan->cid.cid_num, chan->exten, token, &timelimit)) > 0) {
1984 status = AST_OSP_SUCCESS;
1986 timelimit = OSP_DEF_TIMELIMIT;
1988 status = AST_OSP_FAILED;
1990 status = AST_OSP_ERROR;
1994 snprintf(buffer, sizeof(buffer), "%d", handle);
1995 pbx_builtin_setvar_helper(chan, "OSPINHANDLE", buffer);
1996 ast_debug(1, "OSPAuth: OSPINHANDLE '%s'\n", buffer);
1997 snprintf(buffer, sizeof(buffer), "%d", timelimit);
1998 pbx_builtin_setvar_helper(chan, "OSPINTIMELIMIT", buffer);
1999 ast_debug(1, "OSPAuth: OSPINTIMELIMIT '%s'\n", buffer);
2000 pbx_builtin_setvar_helper(chan, "OSPAUTHSTATUS", status);
2001 ast_debug(1, "OSPAuth: %s\n", status);
2004 res = OSP_AST_ERROR;
2013 * \brief OSP Application OSPLookup
2014 * \param chan Channel
2015 * \param data Parameter
2016 * \return OSP_AST_OK Success, OSP_AST_ERROR Error
2018 static int osplookup_exec(
2019 struct ast_channel* chan,
2023 const char* provider = OSP_DEF_PROVIDER;
2024 unsigned int callidtypes = OSP_CALLID_UNDEF;
2025 struct varshead* headp;
2026 struct ast_var_t* current;
2027 const char* srcdev = "";
2028 const char* snetid = "";
2029 struct osp_npparam np;
2030 struct osp_diversion div;
2032 const char* cinfo[OSP_MAX_CUSTOMINFO] = { NULL };
2033 char buffer[OSP_SIZE_TOKSTR];
2034 struct osp_results results;
2038 AST_DECLARE_APP_ARGS(args,
2040 AST_APP_ARG(provider);
2041 AST_APP_ARG(options);
2044 if (ast_strlen_zero(data)) {
2045 ast_log(LOG_WARNING, "OSPLookup: Arg required, OSPLookup(exten[|provider[|options]])\n");
2046 return OSP_AST_ERROR;
2049 if (!(tmp = ast_strdupa(data))) {
2050 ast_log(LOG_ERROR, "Out of memory\n");
2051 return OSP_AST_ERROR;
2054 AST_STANDARD_APP_ARGS(args, tmp);
2056 ast_debug(1, "OSPLookup: exten '%s'\n", args.exten);
2058 if (!ast_strlen_zero(args.provider)) {
2059 provider = args.provider;
2061 ast_debug(1, "OSPlookup: provider '%s'\n", provider);
2064 if (strchr(args.options, 'h')) {
2065 callidtypes |= OSP_CALLID_H323;
2067 if (strchr(args.options, 's')) {
2068 callidtypes |= OSP_CALLID_SIP;
2070 if (strchr(args.options, 'i')) {
2071 callidtypes |= OSP_CALLID_IAX;
2074 ast_debug(1, "OSPLookup: call id types '%d'\n", callidtypes);
2076 results.inhandle = OSP_INVALID_HANDLE;
2077 results.intimelimit = OSP_DEF_TIMELIMIT;
2078 results.dest[0] = '\0';
2087 headp = &chan->varshead;
2088 AST_LIST_TRAVERSE(headp, current, entries) {
2089 if (!strcasecmp(ast_var_name(current), "OSPINPEERIP")) {
2090 srcdev = ast_var_value(current);
2091 } else if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
2092 if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
2093 results.inhandle = OSP_INVALID_HANDLE;
2095 } else if (!strcasecmp(ast_var_name(current), "OSPINTIMELIMIT")) {
2096 if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
2097 results.intimelimit = OSP_DEF_TIMELIMIT;
2099 } else if (!strcasecmp(ast_var_name(current), "OSPINNETWORKID")) {
2100 snetid = ast_var_value(current);
2101 } else if (!strcasecmp(ast_var_name(current), "OSPINNPRN")) {
2102 np.rn = ast_var_value(current);
2103 } else if (!strcasecmp(ast_var_name(current), "OSPINNPCIC")) {
2104 np.cic = ast_var_value(current);
2105 } else if (!strcasecmp(ast_var_name(current), "OSPINNPDI")) {
2106 if (ast_true(ast_var_value(current))) {
2109 } else if (!strcasecmp(ast_var_name(current), "OSPINTOHOST")) {
2110 ast_copy_string(results.dest, ast_var_value(current), sizeof(results.dest));
2111 } else if (!strcasecmp(ast_var_name(current), "OSPINDIVUSER")) {
2112 div.user = ast_var_value(current);
2113 } else if (!strcasecmp(ast_var_name(current), "OSPINDIVHOST")) {
2114 div.host = ast_var_value(current);
2115 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO1")) {
2116 cinfo[0] = ast_var_value(current);
2117 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO2")) {
2118 cinfo[1] = ast_var_value(current);
2119 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO3")) {
2120 cinfo[2] = ast_var_value(current);
2121 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO4")) {
2122 cinfo[3] = ast_var_value(current);
2123 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO5")) {
2124 cinfo[4] = ast_var_value(current);
2125 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO6")) {
2126 cinfo[5] = ast_var_value(current);
2127 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO7")) {
2128 cinfo[6] = ast_var_value(current);
2129 } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO8")) {
2130 cinfo[7] = ast_var_value(current);
2133 ast_debug(1, "OSPLookup: source device '%s'\n", srcdev);
2134 ast_debug(1, "OSPLookup: OSPINHANDLE '%d'\n", results.inhandle);
2135 ast_debug(1, "OSPLookup: OSPINTIMELIMIT '%d'\n", results.intimelimit);
2136 ast_debug(1, "OSPLookup: OSPINNETWORKID '%s'\n", snetid);
2137 ast_debug(1, "OSPLookup: OSPINNPRN '%s'\n", np.rn);
2138 ast_debug(1, "OSPLookup: OSPINNPCIC '%s'\n", np.cic);
2139 ast_debug(1, "OSPLookup: OSPINNPDI '%d'\n", np.npdi);
2140 ast_debug(1, "OSPLookup: OSPINTOHOST '%s'\n", results.dest);
2141 ast_debug(1, "OSPLookup: OSPINDIVUSER '%s'\n", div.user);
2142 ast_debug(1, "OSPLookup: OSPINDIVHOST'%s'\n", div.host);
2143 for (i = 0; i < OSP_MAX_CUSTOMINFO; i++) {
2144 if (!ast_strlen_zero(cinfo[i])) {
2145 ast_debug(1, "OSPLookup: OSPINCUSTOMINFO%d '%s'\n", i, cinfo[i]);
2149 if ((cres = ast_autoservice_start(chan)) < 0) {
2150 return OSP_AST_ERROR;
2153 if ((res = osp_lookup(provider, callidtypes, srcdev, chan->cid.cid_num, args.exten, snetid, &np, &div, cinfo, &results)) > 0) {
2154 status = AST_OSP_SUCCESS;
2156 results.tech[0] = '\0';
2157 results.dest[0] = '\0';
2158 results.calling[0] = '\0';
2159 results.called[0] = '\0';
2160 results.token[0] = '\0';
2161 results.networkid[0] = '\0';
2162 results.nprn[0] = '\0';
2163 results.npcic[0] = '\0';
2165 results.numdests = 0;
2166 results.outtimelimit = OSP_DEF_TIMELIMIT;
2167 results.outcallid.buf[0] = '\0';
2168 results.outcallid.len = 0;
2170 status = AST_OSP_FAILED;
2172 status = AST_OSP_ERROR;
2176 snprintf(buffer, sizeof(buffer), "%d", results.outhandle);
2177 pbx_builtin_setvar_helper(chan, "OSPOUTHANDLE", buffer);
2178 ast_debug(1, "OSPLookup: OSPOUTHANDLE '%s'\n", buffer);
2179 pbx_builtin_setvar_helper(chan, "OSPOUTTECH", results.tech);
2180 ast_debug(1, "OSPLookup: OSPOUTTECH '%s'\n", results.tech);
2181 pbx_builtin_setvar_helper(chan, "OSPDESTINATION", results.dest);
2182 ast_debug(1, "OSPLookup: OSPDESTINATION '%s'\n", results.dest);
2183 pbx_builtin_setvar_helper(chan, "OSPOUTCALLING", results.calling);
2184 ast_debug(1, "OSPLookup: OSPOUTCALLING '%s'\n", results.calling);
2185 pbx_builtin_setvar_helper(chan, "OSPOUTCALLED", results.called);
2186 ast_debug(1, "OSPLookup: OSPOUTCALLED '%s'\n", results.called);
2187 pbx_builtin_setvar_helper(chan, "OSPOUTNETWORKID", results.networkid);
2188 ast_debug(1, "OSPLookup: OSPOUTNETWORKID '%s'\n", results.networkid);
2189 pbx_builtin_setvar_helper(chan, "OSPOUTNPRN", results.nprn);
2190 ast_debug(1, "OSPLookup: OSPOUTNPRN '%s'\n", results.nprn);
2191 pbx_builtin_setvar_helper(chan, "OSPOUTNPCIC", results.npcic);
2192 ast_debug(1, "OSPLookup: OSPOUTNPCIC '%s'\n", results.npcic);
2193 snprintf(buffer, sizeof(buffer), "%d", results.npdi);
2194 pbx_builtin_setvar_helper(chan, "OSPOUTNPDI", buffer);
2195 ast_debug(1, "OSPLookup: OSPOUTNPDI'%s'\n", buffer);
2196 pbx_builtin_setvar_helper(chan, "OSPOUTTOKEN", results.token);
2197 ast_debug(1, "OSPLookup: OSPOUTTOKEN size '%zd'\n", strlen(results.token));
2198 snprintf(buffer, sizeof(buffer), "%d", results.numdests);
2199 pbx_builtin_setvar_helper(chan, "OSPDESTREMAILS", buffer);
2200 ast_debug(1, "OSPLookup: OSPDESTREMAILS '%s'\n", buffer);
2201 snprintf(buffer, sizeof(buffer), "%d", results.outtimelimit);
2202 pbx_builtin_setvar_helper(chan, "OSPOUTTIMELIMIT", buffer);
2203 ast_debug(1, "OSPLookup: OSPOUTTIMELIMIT '%s'\n", buffer);
2204 snprintf(buffer, sizeof(buffer), "%d", callidtypes);
2205 pbx_builtin_setvar_helper(chan, "OSPOUTCALLIDTYPES", buffer);
2206 ast_debug(1, "OSPLookup: OSPOUTCALLIDTYPES '%s'\n", buffer);
2207 pbx_builtin_setvar_helper(chan, "OSPLOOKUPSTATUS", status);
2208 ast_debug(1, "OSPLookup: %s\n", status);
2210 if (!strcasecmp(results.tech, OSP_TECH_SIP)) {
2211 snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, results.called, results.dest);
2212 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2213 if (!ast_strlen_zero(results.token)) {
2214 snprintf(buffer, sizeof(buffer), "%s: %s", OSP_SIP_HEADER, results.token);
2215 pbx_builtin_setvar_helper(chan, "_SIPADDHEADER", buffer);
2216 ast_debug(1, "OSPLookup: SIPADDHEADER size '%zd'\n", strlen(buffer));
2218 } else if (!strcasecmp(results.tech, OSP_TECH_H323)) {
2219 if ((callidtypes & OSP_CALLID_H323) && (results.outcallid.len != 0)) {
2220 osp_uuid2str(results.outcallid.buf, buffer, sizeof(buffer));
2224 pbx_builtin_setvar_helper(chan, "OSPOUTCALLID", buffer);
2225 snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, results.called, results.dest);
2226 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2227 } else if (!strcasecmp(results.tech, OSP_TECH_IAX)) {
2228 snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.tech, results.dest, results.called);
2229 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2230 } else if (!strcasecmp(results.tech, OSP_TECH_SKYPE)) {
2231 snprintf(buffer, sizeof(buffer), "%s/%s", results.tech, results.called);
2232 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2235 if ((cres = ast_autoservice_stop(chan)) < 0) {
2236 return OSP_AST_ERROR;
2240 res = OSP_AST_ERROR;
2249 * \brief OSP Application OSPNext
2250 * \param chan Channel
2251 * \param data Parameter
2252 * \return OSP_AST_OK Success, OSP_AST_ERROR Error
2254 static int ospnext_exec(
2255 struct ast_channel* chan,
2259 const char* provider = OSP_DEF_PROVIDER;
2261 struct varshead* headp;
2262 struct ast_var_t* current;
2263 struct osp_results results;
2264 char buffer[OSP_SIZE_TOKSTR];
2265 unsigned int callidtypes = OSP_CALLID_UNDEF;
2269 AST_DECLARE_APP_ARGS(args,
2271 AST_APP_ARG(provider);
2272 AST_APP_ARG(options);
2275 if (ast_strlen_zero(data)) {
2276 ast_log(LOG_WARNING, "OSPNext: Arg required, OSPNext(cause[|provider[|options]])\n");
2277 return OSP_AST_ERROR;
2280 if (!(tmp = ast_strdupa(data))) {
2281 ast_log(LOG_ERROR, "Out of memory\n");
2282 return OSP_AST_ERROR;
2285 AST_STANDARD_APP_ARGS(args, tmp);
2287 if (!ast_strlen_zero(args.cause) && sscanf(args.cause, "%30d", &cause) != 1) {
2290 ast_debug(1, "OSPNext: cause '%d'\n", cause);
2292 if (!ast_strlen_zero(args.provider)) {
2293 provider = args.provider;
2295 ast_debug(1, "OSPlookup: provider '%s'\n", provider);
2297 results.inhandle = OSP_INVALID_HANDLE;
2298 results.outhandle = OSP_INVALID_HANDLE;
2299 results.intimelimit = OSP_DEF_TIMELIMIT;
2300 results.numdests = 0;
2302 headp = &chan->varshead;
2303 AST_LIST_TRAVERSE(headp, current, entries) {
2304 if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
2305 if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
2306 results.inhandle = OSP_INVALID_HANDLE;
2308 } else if (!strcasecmp(ast_var_name(current), "OSPOUTHANDLE")) {
2309 if (sscanf(ast_var_value(current), "%30d", &results.outhandle) != 1) {
2310 results.outhandle = OSP_INVALID_HANDLE;
2312 } else if (!strcasecmp(ast_var_name(current), "OSPINTIMELIMIT")) {
2313 if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
2314 results.intimelimit = OSP_DEF_TIMELIMIT;
2316 } else if (!strcasecmp(ast_var_name(current), "OSPOUTCALLIDTYPES")) {
2317 if (sscanf(ast_var_value(current), "%30d", &callidtypes) != 1) {
2318 callidtypes = OSP_CALLID_UNDEF;
2320 } else if (!strcasecmp(ast_var_name(current), "OSPDESTREMAILS")) {
2321 if (sscanf(ast_var_value(current), "%30d", &results.numdests) != 1) {
2322 results.numdests = 0;
2326 ast_debug(1, "OSPNext: OSPINHANDLE '%d'\n", results.inhandle);
2327 ast_debug(1, "OSPNext: OSPOUTHANDLE '%d'\n", results.outhandle);
2328 ast_debug(1, "OSPNext: OSPINTIMELIMIT '%d'\n", results.intimelimit);
2329 ast_debug(1, "OSPNext: OSPOUTCALLIDTYPES '%d'\n", callidtypes);
2330 ast_debug(1, "OSPNext: OSPDESTREMAILS '%d'\n", results.numdests);
2332 if ((res = osp_next(provider, cause, &results)) > 0) {
2333 status = AST_OSP_SUCCESS;
2335 results.tech[0] = '\0';
2336 results.dest[0] = '\0';
2337 results.calling[0] = '\0';
2338 results.called[0] = '\0';
2339 results.token[0] = '\0';
2340 results.networkid[0] = '\0';
2341 results.nprn[0] = '\0';
2342 results.npcic[0] = '\0';
2344 results.numdests = 0;
2345 results.outtimelimit = OSP_DEF_TIMELIMIT;
2346 results.outcallid.buf[0] = '\0';
2347 results.outcallid.len = 0;
2349 status = AST_OSP_FAILED;
2351 status = AST_OSP_ERROR;
2355 pbx_builtin_setvar_helper(chan, "OSPOUTTECH", results.tech);
2356 ast_debug(1, "OSPNext: OSPOUTTECH '%s'\n", results.tech);
2357 pbx_builtin_setvar_helper(chan, "OSPDESTINATION", results.dest);
2358 ast_debug(1, "OSPNext: OSPDESTINATION '%s'\n", results.dest);
2359 pbx_builtin_setvar_helper(chan, "OSPOUTCALLING", results.calling);
2360 ast_debug(1, "OSPNext: OSPOUTCALLING '%s'\n", results.calling);
2361 pbx_builtin_setvar_helper(chan, "OSPOUTCALLED", results.called);
2362 ast_debug(1, "OSPNext: OSPOUTCALLED'%s'\n", results.called);
2363 pbx_builtin_setvar_helper(chan, "OSPOUTNETWORKID", results.networkid);
2364 ast_debug(1, "OSPLookup: OSPOUTNETWORKID '%s'\n", results.networkid);
2365 pbx_builtin_setvar_helper(chan, "OSPOUTNPRN", results.nprn);
2366 ast_debug(1, "OSPLookup: OSPOUTNPRN '%s'\n", results.nprn);
2367 pbx_builtin_setvar_helper(chan, "OSPOUTNPCIC", results.npcic);
2368 ast_debug(1, "OSPLookup: OSPOUTNPCIC '%s'\n", results.npcic);
2369 snprintf(buffer, sizeof(buffer), "%d", results.npdi);
2370 pbx_builtin_setvar_helper(chan, "OSPOUTNPDI", buffer);
2371 ast_debug(1, "OSPLookup: OSPOUTNPDI'%s'\n", buffer);
2372 pbx_builtin_setvar_helper(chan, "OSPOUTTOKEN", results.token);
2373 ast_debug(1, "OSPNext: OSPOUTTOKEN size '%zd'\n", strlen(results.token));
2374 snprintf(buffer, sizeof(buffer), "%d", results.numdests);
2375 pbx_builtin_setvar_helper(chan, "OSPDESTREMAILS", buffer);
2376 ast_debug(1, "OSPNext: OSPDESTREMAILS '%s'\n", buffer);
2377 snprintf(buffer, sizeof(buffer), "%d", results.outtimelimit);
2378 pbx_builtin_setvar_helper(chan, "OSPOUTTIMELIMIT", buffer);
2379 ast_debug(1, "OSPNext: OSPOUTTIMELIMIT '%s'\n", buffer);
2380 pbx_builtin_setvar_helper(chan, "OSPNEXTSTATUS", status);
2381 ast_debug(1, "OSPNext: %s\n", status);
2383 if (!strcasecmp(results.tech, OSP_TECH_SIP)) {
2384 snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, results.called, results.dest);
2385 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2386 if (!ast_strlen_zero(results.token)) {
2387 snprintf(buffer, sizeof(buffer), "%s: %s", OSP_SIP_HEADER, results.token);
2388 pbx_builtin_setvar_helper(chan, "_SIPADDHEADER", buffer);
2389 ast_debug(1, "OSPLookup: SIPADDHEADER size '%zd'\n", strlen(buffer));
2391 } else if (!strcasecmp(results.tech, OSP_TECH_H323)) {
2392 if ((callidtypes & OSP_CALLID_H323) && (results.outcallid.len != 0)) {
2393 osp_uuid2str(results.outcallid.buf, buffer, sizeof(buffer));
2397 pbx_builtin_setvar_helper(chan, "OSPOUTCALLID", buffer);
2398 snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, results.called, results.dest);
2399 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2400 } else if (!strcasecmp(results.tech, OSP_TECH_IAX)) {
2401 snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.tech, results.dest, results.called);
2402 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2403 } else if (!strcasecmp(results.tech, OSP_TECH_SKYPE)) {
2404 snprintf(buffer, sizeof(buffer), "%s/%s", results.tech, results.called);
2405 pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
2409 res = OSP_AST_ERROR;
2418 * \brief OSP Application OSPFinish
2419 * \param chan Channel
2420 * \param data Parameter
2421 * \return OSP_AST_OK Success, OSP_AST_ERROR Error
2423 static int ospfinished_exec(
2424 struct ast_channel* chan,
2429 struct varshead* headp;
2430 struct ast_var_t* current;
2431 int inhandle = OSP_INVALID_HANDLE;
2432 int outhandle = OSP_INVALID_HANDLE;
2434 time_t start, connect, end;
2435 unsigned int release;
2436 char buffer[OSP_SIZE_INTSTR];
2437 char inqos[OSP_SIZE_QOSSTR] = { 0 };
2438 char outqos[OSP_SIZE_QOSSTR] = { 0 };
2442 AST_DECLARE_APP_ARGS(args,
2444 AST_APP_ARG(options);
2447 if (!(tmp = ast_strdupa(data))) {
2448 ast_log(LOG_ERROR, "Out of memory\n");
2449 return OSP_AST_ERROR;
2452 AST_STANDARD_APP_ARGS(args, tmp);
2454 headp = &chan->varshead;
2455 AST_LIST_TRAVERSE(headp, current, entries) {
2456 if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
2457 if (sscanf(ast_var_value(current), "%30d", &inhandle) != 1) {
2458 inhandle = OSP_INVALID_HANDLE;
2460 } else if (!strcasecmp(ast_var_name(current), "OSPOUTHANDLE")) {
2461 if (sscanf(ast_var_value(current), "%30d", &outhandle) != 1) {
2462 outhandle = OSP_INVALID_HANDLE;
2464 } else if (!recorded &&
2465 (!strcasecmp(ast_var_name(current), "OSPAUTHSTATUS") ||
2466 !strcasecmp(ast_var_name(current), "OSPLOOKUPSTATUS") ||
2467 !strcasecmp(ast_var_name(current), "OSPNEXTSTATUS")))
2469 if (strcasecmp(ast_var_value(current), AST_OSP_SUCCESS)) {
2472 } else if (!strcasecmp(ast_var_name(current), "OSPINAUDIOQOS")) {
2473 ast_copy_string(inqos, ast_var_value(current), sizeof(inqos));
2474 } else if (!strcasecmp(ast_var_name(current), "OSPOUTAUDIOQOS")) {
2475 ast_copy_string(outqos, ast_var_value(current), sizeof(outqos));
2478 ast_debug(1, "OSPFinish: OSPINHANDLE '%d'\n", inhandle);
2479 ast_debug(1, "OSPFinish: OSPOUTHANDLE '%d'\n", outhandle);
2480 ast_debug(1, "OSPFinish: recorded '%d'\n", recorded);
2481 ast_debug(1, "OSPFinish: OSPINAUDIOQOS '%s'\n", inqos);
2482 ast_debug(1, "OSPFinish: OSPOUTAUDIOQOS '%s'\n", outqos);
2484 if (!ast_strlen_zero(args.cause) && sscanf(args.cause, "%30d", &cause) != 1) {
2487 ast_debug(1, "OSPFinish: cause '%d'\n", cause);
2490 start = chan->cdr->start.tv_sec;
2491 connect = chan->cdr->answer.tv_sec;
2502 ast_debug(1, "OSPFinish: start '%ld'\n", start);
2503 ast_debug(1, "OSPFinish: connect '%ld'\n", connect);
2504 ast_debug(1, "OSPFinish: end '%ld'\n", end);
2506 release = ast_check_hangup(chan) ? 0 : 1;
2508 if (osp_finish(outhandle, recorded, cause, start, connect, end, release, inqos, outqos) <= 0) {
2509 ast_debug(1, "OSPFinish: Unable to report usage for outbound call\n");
2512 case AST_CAUSE_NORMAL_CLEARING:
2515 cause = AST_CAUSE_NO_ROUTE_DESTINATION;
2518 if (osp_finish(inhandle, recorded, cause, start, connect, end, release, inqos, outqos) <= 0) {
2519 ast_debug(1, "OSPFinish: Unable to report usage for inbound call\n");
2521 snprintf(buffer, sizeof(buffer), "%d", OSP_INVALID_HANDLE);
2522 pbx_builtin_setvar_helper(chan, "OSPOUTHANDLE", buffer);
2523 pbx_builtin_setvar_helper(chan, "OSPINHANDLE", buffer);
2526 status = AST_OSP_SUCCESS;
2528 status = AST_OSP_FAILED;
2530 status = AST_OSP_ERROR;
2532 pbx_builtin_setvar_helper(chan, "OSPFINISHSTATUS", status);
2535 res = OSP_AST_ERROR;
2543 /* OSP Module APIs */
2545 static int osp_unload(void)
2547 struct osp_provider* provider;
2548 struct osp_provider* next;
2550 if (osp_initialized) {
2551 ast_mutex_lock(&osp_lock);
2552 for (provider = osp_providers; provider; provider = next) {
2553 next = provider->next;
2554 OSPPProviderDelete(provider->handle, 0);
2557 osp_providers = NULL;
2558 ast_mutex_unlock(&osp_lock);
2562 osp_tokenformat = TOKEN_ALGO_SIGNED;
2565 osp_initialized = 0;
2571 static int osp_load(int reload)
2575 struct ast_config* cfg;
2576 struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
2577 int error = OSPC_ERR_NO_ERROR;
2579 if ((cfg = ast_config_load(OSP_CONFIG_FILE, config_flags)) == CONFIG_STATUS_FILEUNCHANGED) {
2581 } else if (cfg == CONFIG_STATUS_FILEINVALID) {
2582 ast_log(LOG_ERROR, "Config file %s is in an invalid format. Aborting.\n", OSP_CONFIG_FILE);
2591 if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "accelerate")) && ast_true(cvar)) {
2592 if ((error = OSPPInit(1)) != OSPC_ERR_NO_ERROR) {
2593 ast_log(LOG_WARNING, "OSP: Unable to enable hardware accelleration\n");
2601 ast_debug(1, "OSP: osp_hardware '%d'\n", osp_hardware);
2603 if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "securityfeatures")) && ast_true(cvar)) {
2606 ast_debug(1, "OSP: osp_security '%d'\n", osp_security);
2609 if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "tokenformat"))) {
2610 if ((sscanf(cvar, "%30d", &ivar) == 1) &&
2611 ((ivar == TOKEN_ALGO_SIGNED) || (ivar == TOKEN_ALGO_UNSIGNED) || (ivar == TOKEN_ALGO_BOTH)))
2613 osp_tokenformat = ivar;
2615 ast_log(LOG_WARNING, "tokenformat should be an integer from %d, %d or %d, not '%s'\n",
2616 TOKEN_ALGO_SIGNED, TOKEN_ALGO_UNSIGNED, TOKEN_ALGO_BOTH, cvar);
2619 ast_debug(1, "OSP: osp_tokenformat '%d'\n", osp_tokenformat);
2621 for (cvar = ast_category_browse(cfg, NULL); cvar != NULL; cvar = ast_category_browse(cfg, cvar)) {
2622 if (strcasecmp(cvar, OSP_GENERAL_CAT)) {
2623 osp_create_provider(cfg, cvar);
2627 osp_initialized = 1;
2629 ast_config_destroy(cfg);
2631 ast_log(LOG_WARNING, "OSP: Unable to find configuration. OSP support disabled\n");
2634 ast_debug(1, "OSP: osp_initialized '%d'\n", osp_initialized);
2639 static char *handle_cli_osp_show(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
2643 struct osp_provider* provider;
2644 const char* name = NULL;
2645 const char* tokenalgo;
2649 e->command = "osp show";
2652 " Displays information on Open Settlement Protocol support\n";
2658 if ((a->argc < 2) || (a->argc > 3)) {
2659 return CLI_SHOWUSAGE;
2667 switch (osp_tokenformat) {
2668 case TOKEN_ALGO_BOTH:
2671 case TOKEN_ALGO_UNSIGNED:
2672 tokenalgo = "Unsigned";
2674 case TOKEN_ALGO_SIGNED:
2676 tokenalgo = "Signed";
2679 ast_cli(a->fd, "OSP: %s/%s/%s/%s\n",
2680 osp_initialized ? "Initialized" : "Uninitialized",
2681 osp_hardware ? "Accelerated" : "Normal",
2682 osp_security ? "Enabled" : "Disabled",
2686 ast_mutex_lock(&osp_lock);
2687 for (provider = osp_providers; provider; provider = provider->next) {
2688 if (!name || !strcasecmp(provider->name, name)) {
2690 ast_cli(a->fd, "\n");
2692 ast_cli(a->fd, " == OSP Provider '%s' == \n", provider->name);
2694 ast_cli(a->fd, "Local Private Key: %s\n", provider->privatekey);
2695 ast_cli(a->fd, "Local Certificate: %s\n", provider->localcert);
2696 for (i = 0; i < provider->canum; i++) {
2697 ast_cli(a->fd, "CA Certificate %d: %s\n", i + 1, provider->cacerts[i]);
2700 for (i = 0; i < provider->spnum; i++) {
2701 ast_cli(a->fd, "Service Point %d: %s\n", i + 1, provider->spoints[i]);
2703 ast_cli(a->fd, "Max Connections: %d\n", provider->maxconnect);
2704 ast_cli(a->fd, "Retry Delay: %d seconds\n", provider->retrydelay);
2705 ast_cli(a->fd, "Retry Limit: %d\n", provider->retrylimit);
2706 ast_cli(a->fd, "Timeout: %d milliseconds\n", provider->timeout);
2707 ast_cli(a->fd, "Source: %s\n", strlen(provider->source) ? provider->source : "<unspecified>");
2708 ast_cli(a->fd, "Auth Policy %d\n", provider->authpolicy);
2709 ast_cli(a->fd, "Default protocol %s\n", provider->defprotocol);
2710 ast_cli(a->fd, "Service type %d\n", provider->srvtype);
2711 ast_cli(a->fd, "OSP Handle: %d\n", provider->handle);
2715 ast_mutex_unlock(&osp_lock);
2719 ast_cli(a->fd, "Unable to find OSP provider '%s'\n", name);
2721 ast_cli(a->fd, "No OSP providers configured\n");
2728 /* OSPAuth() dialplan application */
2729 static const char app1[] = "OSPAuth";
2731 /* OSPLookup() dialplan application */
2732 static const char app2[] = "OSPLookup";
2734 /* OSPNext() dialplan application */
2735 static const char app3[] = "OSPNext";
2737 /* OSPFinish() dialplan application */
2738 static const char app4[] = "OSPFinish";
2740 static struct ast_cli_entry cli_osp[] = {
2741 AST_CLI_DEFINE(handle_cli_osp_show, "Displays OSF information")
2744 static int load_module(void)
2749 return AST_MODULE_LOAD_DECLINE;
2751 ast_cli_register_multiple(cli_osp, sizeof(cli_osp) / sizeof(struct ast_cli_entry));
2752 res = ast_register_application_xml(app1, ospauth_exec);
2753 res |= ast_register_application_xml(app2, osplookup_exec);
2754 res |= ast_register_application_xml(app3, ospnext_exec);
2755 res |= ast_register_application_xml(app4, ospfinished_exec);
2760 static int unload_module(void)
2764 res = ast_unregister_application(app4);
2765 res |= ast_unregister_application(app3);
2766 res |= ast_unregister_application(app2);
2767 res |= ast_unregister_application(app1);
2768 ast_cli_unregister_multiple(cli_osp, sizeof(cli_osp) / sizeof(struct ast_cli_entry));
2774 static int reload(void)
2781 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "Open Settlement Protocol Applications",
2782 .load = load_module,
2783 .unload = unload_module,