res_xmpp.c File Reference

XMPP client and component module. More...

#include "asterisk.h"
#include <ctype.h>
#include <iksemel.h>
#include "asterisk/xmpp.h"
#include "asterisk/module.h"
#include "asterisk/manager.h"
#include "asterisk/app.h"
#include "asterisk/mwi.h"
#include "asterisk/message.h"
#include "asterisk/cli.h"
#include "asterisk/config_options.h"
#include "asterisk/json.h"

Include dependency graph for res_xmpp.c:

Go to the source code of this file.

Data Structures
struct	ast_xmpp_client_config
	XMPP Client Configuration. More...
struct	ast_xmpp_global_config
	XMPP Global Configuration. More...
struct	xmpp_config
struct	xmpp_pak_handler
	Defined handlers for different PAK types. More...
struct	xmpp_state_handler
	Defined handlers for XMPP client states. More...

Macros
#define	BUDDY_BUCKETS   53
	Number of buckets for buddies (per client) More...
#define	BUDDY_NOT_IN_ROSTER   7
#define	BUDDY_OFFLINE   6
#define	CLIENT_BUCKETS   53
	Number of buckets for client connections. More...
#define	RESOURCE_BUCKETS   53
	Number of buckets for resources (per buddy) More...
#define	STATUS_DISAPPEAR   6
	Status for a disappearing buddy. More...
#define	XMPP_TLS_NS   "urn:ietf:params:xml:ns:xmpp-tls"
	Namespace for TLS support. More...

Enumerations
enum	{   XMPP_AUTOPRUNE = (1 << 0) , XMPP_AUTOREGISTER = (1 << 1) , XMPP_AUTOACCEPT = (1 << 2) , XMPP_DEBUG = (1 << 3) ,   XMPP_USETLS = (1 << 4) , XMPP_USESASL = (1 << 5) , XMPP_FORCESSL = (1 << 6) , XMPP_KEEPALIVE = (1 << 7) ,   XMPP_COMPONENT = (1 << 8) , XMPP_SEND_TO_DIALPLAN = (1 << 9) , XMPP_DISTRIBUTE_EVENTS = (1 << 10) }
	Supported general configuration flags. More...
enum	{ XMPP_XEP0248 = (1 << 0) , XMPP_PUBSUB = (1 << 1) , XMPP_PUBSUB_AUTOCREATE = (1 << 2) }
	Supported pubsub configuration flags. More...

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	acf_jabberreceive_read (struct ast_channel *chan, const char *name, char *data, char *buf, size_t buflen)
static int	acf_jabberstatus_read (struct ast_channel *chan, const char *name, char *data, char *buf, size_t buflen)
static	AO2_GLOBAL_OBJ_STATIC (globals)
struct ast_module *	AST_MODULE_SELF_SYM (void)
int	ast_xmpp_chatroom_invite (struct ast_xmpp_client *client, const char *user, const char *room, const char *message)
	Invite a user to an XMPP multi-user chatroom. More...
int	ast_xmpp_chatroom_join (struct ast_xmpp_client *client, const char *room, const char *nickname)
	Join an XMPP multi-user chatroom. More...
int	ast_xmpp_chatroom_leave (struct ast_xmpp_client *client, const char *room, const char *nickname)
	Leave an XMPP multi-user chatroom. More...
int	ast_xmpp_chatroom_send (struct ast_xmpp_client *client, const char *nickname, const char *address, const char *message)
	Send a message to an XMPP multi-user chatroom. More...
static void *	ast_xmpp_client_config_alloc (const char *cat)
	Allocator function for configuration. More...
static void	ast_xmpp_client_config_destructor (void *obj)
	Destructor function for configuration. More...
int	ast_xmpp_client_disconnect (struct ast_xmpp_client *client)
	Disconnect an XMPP client connection. More...
struct ast_xmpp_client *	ast_xmpp_client_find (const char *name)
	Find an XMPP client connection using a given name. More...
void	ast_xmpp_client_lock (struct ast_xmpp_client *client)
	Lock an XMPP client connection. More...
int	ast_xmpp_client_send (struct ast_xmpp_client *client, iks *stanza)
	Send an XML stanza out using an established XMPP client connection. More...
int	ast_xmpp_client_send_message (struct ast_xmpp_client *client, const char *user, const char *message)
	Send a message to a given user using an established XMPP client connection. More...
void	ast_xmpp_client_unlock (struct ast_xmpp_client *client)
	Unlock an XMPP client connection. More...
void	ast_xmpp_client_unref (struct ast_xmpp_client *client)
	Release XMPP client connection reference. More...
void	ast_xmpp_increment_mid (char *mid)
	Helper function which increments the message identifier. More...
static int	cached_devstate_cb (void *obj, void *arg, int flags)
static int	client_bitfield_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
static int	client_buddy_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
static int	client_status_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
	CONFIG_INFO_STANDARD (cfg_info, globals, xmpp_config_alloc,.files=ACO_FILES(&res_xmpp_conf),.post_apply_config=xmpp_config_post_apply,)
static int	delete_old_messages (struct ast_xmpp_client *client, char *from)
static int	fetch_access_token (struct ast_xmpp_client_config *cfg)
static int	get_buddy_status (struct ast_xmpp_client_config *clientcfg, char *screenname, char *resource)
static int	global_bitfield_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
static int	load_module (void)
	Load the module. More...
static int	manager_jabber_send (struct mansession *s, const struct message *m)
static int	reload (void)
static void	sleep_with_backoff (unsigned int *sleep_time)
static int	unload_module (void)
static int	xmpp_action_hook (void *data, int type, iks *node)
	Action hook for when things occur. More...
static int	xmpp_buddy_cmp (void *obj, void *arg, int flags)
	Comparator function for XMPP buddy. More...
static void	xmpp_buddy_destructor (void *obj)
	Destructor callback function for XMPP buddy. More...
static int	xmpp_buddy_hash (const void *obj, const int flags)
	Hashing function for XMPP buddy. More...
static char *	xmpp_cli_create_collection (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Method to expose PubSub collection node creation via CLI. More...
static char *	xmpp_cli_create_leafnode (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Method to expose PubSub leaf node creation via CLI. More...
static char *	xmpp_cli_delete_pubsub_node (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Method to expose PubSub node deletion via CLI. More...
static char *	xmpp_cli_list_pubsub_nodes (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Method to expose PubSub node list via CLI. More...
static char *	xmpp_cli_purge_pubsub_nodes (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
	Method to purge PubSub nodes via CLI. More...
static struct ast_xmpp_client *	xmpp_client_alloc (const char *name)
	Allocator function for ast_xmpp_client. More...
static int	xmpp_client_authenticate (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we need to authenticate. More...
static int	xmpp_client_authenticate_digest (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we need to authenticate using non-SASL. More...
static int	xmpp_client_authenticate_sasl (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we need to authenticate using SASL. More...
static int	xmpp_client_authenticating (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we are authenticating. More...
static void	xmpp_client_change_state (struct ast_xmpp_client *client, int state)
	Internal function which changes the XMPP client state. More...
static int	xmpp_client_config_merge_buddies (void *obj, void *arg, int flags)
static int	xmpp_client_config_post_apply (void *obj, void *arg, int flags)
static struct ast_xmpp_buddy *	xmpp_client_create_buddy (struct ao2_container *container, const char *id)
	Internal function which creates a buddy on a client. More...
static void	xmpp_client_destructor (void *obj)
	Destructor callback function for XMPP client. More...
static void *	xmpp_client_find_or_create (const char *category)
	Look up existing client or create a new one. More...
static int	xmpp_client_receive (struct ast_xmpp_client *client, unsigned int timeout)
	Internal function which receives data from the XMPP client connection. More...
static int	xmpp_client_reconnect (struct ast_xmpp_client *client)
	Internal function used to reconnect an XMPP client to its server. More...
static int	xmpp_client_request_tls (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we need to request TLS support. More...
static int	xmpp_client_requested_tls (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we receive a response to our TLS initiation request. More...
static int	xmpp_client_send_disco_info_request (struct ast_xmpp_client *client, const char *to, const char *from)
	Helper function which sends a discovery information request to a user. More...
static int	xmpp_client_send_message (struct ast_xmpp_client *client, int group, const char *nick, const char *address, const char *message)
	Internal function used to send a message to a user or chatroom. More...
static int	xmpp_client_send_raw_message (struct ast_xmpp_client *client, const char *message)
	Internal function which sends a raw message. More...
static int	xmpp_client_service_discovery_get_hook (void *data, ikspak *pak)
	Hook function called when client receives a service discovery get message. More...
static int	xmpp_client_service_discovery_result_hook (void *data, ikspak *pak)
	Hook function called when client receives a service discovery result message. More...
static int	xmpp_client_set_group_presence (struct ast_xmpp_client *client, const char *room, int level, const char *nick)
static void	xmpp_client_set_presence (struct ast_xmpp_client *client, const char *to, const char *from, int level, const char *desc)
	Internal function which changes the presence status of an XMPP client. More...
static int	xmpp_client_subscribe_user (void *obj, void *arg, int flags)
	Callback function which subscribes to a user if needed. More...
static void *	xmpp_client_thread (void *data)
	XMPP client connection thread. More...
static int	xmpp_client_unsubscribe_user (struct ast_xmpp_client *client, const char *user)
	Helper function which unsubscribes a user and removes them from the roster. More...
static int	xmpp_component_authenticate (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we should authenticate as a component. More...
static int	xmpp_component_authenticating (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, int type, iks *node)
	Internal function called when we authenticated as a component. More...
static int	xmpp_component_register_get_hook (void *data, ikspak *pak)
	Hook function called when the component is queried about registration. More...
static int	xmpp_component_register_set_hook (void *data, ikspak *pak)
	Hook function called when someone registers to the component. More...
static int	xmpp_component_service_discovery_get_hook (void *data, ikspak *pak)
	Hook function called when component receives a service discovery get message. More...
static int	xmpp_component_service_discovery_items_hook (void *data, ikspak *pak)
	Hook function called when we receive a service discovery items request. More...
static void *	xmpp_config_alloc (void)
	Allocator for XMPP configuration. More...
static int	xmpp_config_cmp (void *obj, void *arg, int flags)
	Comparator function for configuration. More...
static void	xmpp_config_destructor (void *obj)
	Destructor for XMPP configuration. More...
static void *	xmpp_config_find (struct ao2_container *tmp_container, const char *category)
	Find function for configuration. More...
static void	xmpp_config_post_apply (void)
static int	xmpp_config_prelink (void *newitem)
static int	xmpp_connect_hook (void *data, ikspak *pak)
	Hook function called when client finishes authenticating with the server. More...
static char *	xmpp_do_set_debug (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void	xmpp_init_event_distribution (struct ast_xmpp_client *client)
	Initialize collections for event distribution. More...
static int	xmpp_io_recv (struct ast_xmpp_client *client, char *buffer, size_t buf_len, int timeout)
	Internal function which polls on an XMPP client and receives data. More...
static int	xmpp_is_secure (struct ast_xmpp_client *client)
	Helper function which returns whether an XMPP client connection is secure or not. More...
static int	xmpp_join_exec (struct ast_channel *chan, const char *data)
	Application to join a chat room. More...
static int	xmpp_leave_exec (struct ast_channel *chan, const char *data)
	Application to leave a chat room. More...
static void	xmpp_log_hook (void *data, const char *xmpp, size_t size, int incoming)
	Logging hook function. More...
static void	xmpp_message_destroy (struct ast_xmpp_message *message)
	Destroy function for XMPP messages. More...
static int	xmpp_pak_message (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, iks *node, ikspak *pak)
	Internal function called when a message is received. More...
static int	xmpp_pak_presence (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, iks *node, ikspak *pak)
	Internal function called when a presence message is received. More...
static int	xmpp_pak_s10n (struct ast_xmpp_client *client, struct ast_xmpp_client_config *cfg, iks *node, ikspak *pak)
	Internal function called when a subscription message is received. More...
static int	xmpp_ping_request (struct ast_xmpp_client *client, const char *to, const char *from)
	Helper function which sends a ping request to a server. More...
static iks *	xmpp_pubsub_build_node_config (iks *pubsub, const char *node_type, const char *collection_name)
static iks *	xmpp_pubsub_build_node_request (struct ast_xmpp_client *client, const char *collection)
	Build the a node request. More...
static iks *	xmpp_pubsub_build_publish_skeleton (struct ast_xmpp_client *client, const char *node, const char *event_type, unsigned int cachable)
	Build the skeleton of a publish. More...
static void	xmpp_pubsub_create_affiliations (struct ast_xmpp_client *client, const char *node)
	Add Owner affiliations for pubsub node. More...
static void	xmpp_pubsub_create_collection (struct ast_xmpp_client *client, const char *collection_name)
	Create a PubSub collection node. More...
static void	xmpp_pubsub_create_leaf (struct ast_xmpp_client *client, const char *collection_name, const char *leaf_name)
	Create a PubSub leaf node. More...
static void	xmpp_pubsub_create_node (struct ast_xmpp_client *client, const char *node_type, const char *name, const char *collection_name)
	Create a pubsub node. More...
static void	xmpp_pubsub_delete_node (struct ast_xmpp_client *client, const char *node_name)
	Delete a PubSub node. More...
static int	xmpp_pubsub_delete_node_list (void *data, ikspak *pak)
	Delete pubsub item lists. More...
static void	xmpp_pubsub_devstate_cb (void *data, struct stasis_subscription *sub, struct stasis_message *msg)
	Callback function for device state events. More...
static int	xmpp_pubsub_handle_error (void *data, ikspak *pak)
static int	xmpp_pubsub_handle_event (void *data, ikspak *pak)
	Callback for handling PubSub events. More...
static iks *	xmpp_pubsub_iq_create (struct ast_xmpp_client *client, const char *type)
	Create an IQ packet. More...
static void	xmpp_pubsub_mwi_cb (void *data, struct stasis_subscription *sub, struct stasis_message *msg)
	Callback function for MWI events. More...
static void	xmpp_pubsub_publish_device_state (struct ast_xmpp_client *client, const char *device, const char *device_state, unsigned int cachable)
	Publish device state to a PubSub node. More...
static void	xmpp_pubsub_publish_mwi (struct ast_xmpp_client *client, const char *mailbox, const char *oldmsgs, const char *newmsgs)
	Publish MWI to a PubSub node. More...
static void	xmpp_pubsub_purge_nodes (struct ast_xmpp_client *client, const char *collection_name)
static int	xmpp_pubsub_receive_node_list (void *data, ikspak *pak)
	Receive pubsub item lists. More...
static void	xmpp_pubsub_request_nodes (struct ast_xmpp_client *client, const char *collection)
	Request item list from pubsub. More...
static void	xmpp_pubsub_subscribe (struct ast_xmpp_client *client, const char *node)
	Subscribe to a PubSub node. More...
static void	xmpp_pubsub_unsubscribe (struct ast_xmpp_client *client, const char *node)
	Unsubscribe from a PubSub node. More...
static int	xmpp_resource_cmp (void *obj, void *arg, int flags)
	Comparator function for XMPP resource. More...
static void	xmpp_resource_destructor (void *obj)
	Destructor callback function for XMPP resource. More...
static int	xmpp_resource_hash (const void *obj, const int flags)
	Hashing function for XMPP resource. More...
static int	xmpp_resource_immediate (void *obj, void *arg, int flags)
	Internal astobj2 callback function which returns the first resource, which is the highest priority one. More...
static int	xmpp_resource_is_available (void *obj, void *arg, int flags)
	Callback function which returns when the resource is available. More...
static int	xmpp_roster_hook (void *data, ikspak *pak)
	Hook function called when roster is received from server. More...
static int	xmpp_send_cb (const struct ast_msg *msg, const char *to, const char *from)
static int	xmpp_send_exec (struct ast_channel *chan, const char *data)
static int	xmpp_send_stream_header (struct ast_xmpp_client *client, const struct ast_xmpp_client_config *cfg, const char *to)
	Helper function which sends an XMPP stream header to the server. More...
static int	xmpp_sendgroup_exec (struct ast_channel *chan, const char *data)
	Application to send a message to a groupchat. More...
static char *	xmpp_show_buddies (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	xmpp_show_clients (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Asterisk XMPP Interface" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CHANNEL_DEPEND, }
static const char *	app_ajijoin = "JabberJoin"
static const char *	app_ajileave = "JabberLeave"
static const char *	app_ajisend = "JabberSend"
static const char *	app_ajisendgroup = "JabberSendGroup"
static const char *	app_ajistatus = "JabberStatus"
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct aco_type	client_option
struct aco_type *	client_options [] = ACO_TYPES(&client_option)
static int	debug
	Global debug status. More...
static struct aco_type	global_option
struct aco_type *	global_options [] = ACO_TYPES(&global_option)
static struct ast_custom_function	jabberreceive_function
static struct ast_custom_function	jabberstatus_function
static ast_cond_t	message_received_condition
static ast_mutex_t	messagelock
static const struct ast_msg_tech	msg_tech
struct aco_file	res_xmpp_conf
static struct ast_cli_entry	xmpp_cli []
static const struct xmpp_pak_handler	xmpp_pak_handlers []
static const struct xmpp_state_handler	xmpp_state_handlers []

Detailed Description

XMPP client and component module.

Author

Joshua Colp jcolp.nosp@m.@dig.nosp@m.ium.c.nosp@m.om

Iksemel http://code.google.com/p/iksemel/

A reference module for interfacting Asterisk directly as a client or component with an XMPP/Jabber compliant server.

This module is based upon the original res_jabber as done by Matt O'Gorman.

Definition in file res_xmpp.c.

Macro Definition Documentation

BUDDY_BUCKETS

#define BUDDY_BUCKETS   53

Number of buckets for buddies (per client)

Definition at line 429 of file res_xmpp.c.

BUDDY_NOT_IN_ROSTER

#define BUDDY_NOT_IN_ROSTER   7

Definition at line 1628 of file res_xmpp.c.

BUDDY_OFFLINE

#define BUDDY_OFFLINE   6

Definition at line 1627 of file res_xmpp.c.

CLIENT_BUCKETS

#define CLIENT_BUCKETS   53

Number of buckets for client connections.

Definition at line 426 of file res_xmpp.c.

RESOURCE_BUCKETS

#define RESOURCE_BUCKETS   53

Number of buckets for resources (per buddy)

Definition at line 432 of file res_xmpp.c.

STATUS_DISAPPEAR

#define STATUS_DISAPPEAR   6

Status for a disappearing buddy.

Definition at line 438 of file res_xmpp.c.

XMPP_TLS_NS

#define XMPP_TLS_NS   "urn:ietf:params:xml:ns:xmpp-tls"

Namespace for TLS support.

Definition at line 435 of file res_xmpp.c.

Enumeration Type Documentation

anonymous enum

anonymous enum

Supported general configuration flags.

Enumerator
XMPP_AUTOPRUNE
XMPP_AUTOREGISTER
XMPP_AUTOACCEPT
XMPP_DEBUG
XMPP_USETLS
XMPP_USESASL
XMPP_FORCESSL
XMPP_KEEPALIVE
XMPP_COMPONENT
XMPP_SEND_TO_DIALPLAN
XMPP_DISTRIBUTE_EVENTS

Definition at line 404 of file res_xmpp.c.

     {
    XMPP_AUTOPRUNE = (1 << 0),
    XMPP_AUTOREGISTER = (1 << 1),
    XMPP_AUTOACCEPT = (1 << 2),
    XMPP_DEBUG = (1 << 3),
    XMPP_USETLS = (1 << 4),
    XMPP_USESASL = (1 << 5),
    XMPP_FORCESSL = (1 << 6),
    XMPP_KEEPALIVE = (1 << 7),
    XMPP_COMPONENT = (1 << 8),
    XMPP_SEND_TO_DIALPLAN = (1 << 9),
    XMPP_DISTRIBUTE_EVENTS = (1 << 10),
};

anonymous enum

anonymous enum

Supported pubsub configuration flags.

Enumerator
XMPP_XEP0248
XMPP_PUBSUB
XMPP_PUBSUB_AUTOCREATE

Definition at line 419 of file res_xmpp.c.

     {
    XMPP_XEP0248 = (1 << 0),
    XMPP_PUBSUB = (1 << 1),
    XMPP_PUBSUB_AUTOCREATE = (1 << 2),
};

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 4703 of file res_xmpp.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 4703 of file res_xmpp.c.

acf_jabberreceive_read()

static int acf_jabberreceive_read ( struct ast_channel *  chan, const char *  name, char *  data, char *  buf, size_t  buflen  )

static

Definition at line 1933 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *parse = NULL;
    int timeout, jidlen, resourcelen, found = 0;
    struct timeval start;
    long diff = 0;
    struct ast_xmpp_message *message;
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(account);
                 AST_APP_ARG(jid);
                 AST_APP_ARG(timeout);
        );
    AST_DECLARE_APP_ARGS(jid,
                 AST_APP_ARG(screenname);
                 AST_APP_ARG(resource);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_WARNING, "%s requires arguments (account,jid[,timeout])\n", name);
        return -1;
    }
 
    parse = ast_strdupa(data);
    AST_STANDARD_APP_ARGS(args, parse);
 
    if (args.argc < 2 || args.argc > 3) {
        ast_log(LOG_WARNING, "%s requires arguments (account,jid[,timeout])\n", name);
        return -1;
    }
 
    parse = ast_strdupa(args.jid);
    AST_NONSTANDARD_APP_ARGS(jid, parse, '/');
    if (jid.argc < 1 || jid.argc > 2 || strlen(args.jid) > XMPP_MAX_JIDLEN) {
        ast_log(LOG_WARNING, "Invalid JID : %s\n", parse);
        return -1;
    }
 
    if (ast_strlen_zero(args.timeout)) {
        timeout = 20;
    } else {
        sscanf(args.timeout, "%d", &timeout);
        if (timeout <= 0) {
            ast_log(LOG_WARNING, "Invalid timeout specified: '%s'\n", args.timeout);
            return -1;
        }
    }
 
    jidlen = strlen(jid.screenname);
    resourcelen = ast_strlen_zero(jid.resource) ? 0 : strlen(jid.resource);
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.account))) {
        ast_log(LOG_WARNING, "Could not find client %s, exiting\n", args.account);
        return -1;
    }
 
    ast_debug(3, "Waiting for an XMPP message from %s\n", args.jid);
 
    start = ast_tvnow();
 
    if (chan && ast_autoservice_start(chan) < 0) {
        ast_log(LOG_WARNING, "Cannot start autoservice for channel %s\n", ast_channel_name(chan));
        return -1;
    }
 
    /* search the messages list, grab the first message that matches with
     * the from JID we're expecting, and remove it from the messages list */
    while (diff < timeout) {
        struct timespec ts = { 0, };
        struct timeval wait;
        int res = 0;
 
        wait = ast_tvadd(start, ast_tv(timeout, 0));
        ts.tv_sec = wait.tv_sec;
        ts.tv_nsec = wait.tv_usec * 1000;
 
        /* wait up to timeout seconds for an incoming message */
        ast_mutex_lock(&messagelock);
        if (AST_LIST_EMPTY(&clientcfg->client->messages)) {
            res = ast_cond_timedwait(&message_received_condition, &messagelock, &ts);
        }
        ast_mutex_unlock(&messagelock);
        if (res == ETIMEDOUT) {
            ast_debug(3, "No message received from %s in %d seconds\n", args.jid, timeout);
            break;
        }
 
        AST_LIST_LOCK(&clientcfg->client->messages);
        AST_LIST_TRAVERSE_SAFE_BEGIN(&clientcfg->client->messages, message, list) {
            if (jid.argc == 1) {
                /* no resource provided, compare bare JIDs */
                if (strncasecmp(jid.screenname, message->from, jidlen)) {
                    continue;
                }
            } else {
                /* resource appended, compare bare JIDs and resources */
                char *resource = strchr(message->from, '/');
                if (!resource || strlen(resource) == 0) {
                    ast_log(LOG_WARNING, "Remote JID has no resource : %s\n", message->from);
                    if (strncasecmp(jid.screenname, message->from, jidlen)) {
                        continue;
                    }
                } else {
                    resource ++;
                    if (strncasecmp(jid.screenname, message->from, jidlen) || strncmp(jid.resource, resource, resourcelen)) {
                        continue;
                    }
                }
            }
            /* check if the message is not too old */
            if (ast_tvdiff_sec(ast_tvnow(), message->arrived) >= clientcfg->message_timeout) {
                ast_debug(3, "Found old message from %s, deleting it\n", message->from);
                AST_LIST_REMOVE_CURRENT(list);
                xmpp_message_destroy(message);
                continue;
            }
            found = 1;
            ast_copy_string(buf, message->message, buflen);
            AST_LIST_REMOVE_CURRENT(list);
            xmpp_message_destroy(message);
            break;
        }
        AST_LIST_TRAVERSE_SAFE_END;
        AST_LIST_UNLOCK(&clientcfg->client->messages);
        if (found) {
            break;
        }
 
        /* check timeout */
        diff = ast_tvdiff_ms(ast_tvnow(), start);
    }
 
    if (chan && ast_autoservice_stop(chan) < 0) {
        ast_log(LOG_WARNING, "Cannot stop autoservice for channel %s\n", ast_channel_name(chan));
    }
 
    /* return if we timed out */
    if (!found) {
        ast_log(LOG_NOTICE, "Timed out : no message received from %s\n", args.jid);
        return -1;
    }
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, args, AST_APP_ARG, ast_autoservice_start(), ast_autoservice_stop(), ast_channel_name(), ast_cond_timedwait, ast_copy_string(), ast_debug, AST_DECLARE_APP_ARGS, AST_LIST_EMPTY, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, ast_mutex_lock, ast_mutex_unlock, AST_NONSTANDARD_APP_ARGS, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_tv(), ast_tvadd(), ast_tvdiff_ms(), ast_tvdiff_sec(), ast_tvnow(), buf, globals, LOG_NOTICE, LOG_WARNING, ast_xmpp_message::message, message_received_condition, messagelock, name, NULL, RAII_VAR, xmpp_config_find(), XMPP_MAX_JIDLEN, and xmpp_message_destroy().

acf_jabberstatus_read()

static int acf_jabberstatus_read ( struct ast_channel *  chan, const char *  name, char *  data, char *  buf, size_t  buflen  )

static

Definition at line 1666 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(sender);
                 AST_APP_ARG(jid);
        );
    AST_DECLARE_APP_ARGS(jid,
                 AST_APP_ARG(screenname);
                 AST_APP_ARG(resource);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_ERROR, "Usage: JABBER_STATUS(<sender>,<jid>[/<resource>])\n");
        return 0;
    }
    AST_STANDARD_APP_ARGS(args, data);
 
    if (args.argc != 2) {
        ast_log(LOG_ERROR, "JABBER_STATUS requires 2 arguments: sender and jid.\n");
        return -1;
    }
 
    AST_NONSTANDARD_APP_ARGS(jid, args.jid, '/');
    if (jid.argc < 1 || jid.argc > 2) {
        ast_log(LOG_WARNING, "Wrong JID %s, exiting\n", args.jid);
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.sender))) {
        ast_log(LOG_WARNING, "Could not find sender connection: '%s'\n", args.sender);
        return -1;
    }
 
    snprintf(buf, buflen, "%d", get_buddy_status(clientcfg, jid.screenname, jid.resource));
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_NONSTANDARD_APP_ARGS, AST_STANDARD_APP_ARGS, ast_strlen_zero(), buf, get_buddy_status(), globals, LOG_ERROR, LOG_WARNING, NULL, RAII_VAR, and xmpp_config_find().

AO2_GLOBAL_OBJ_STATIC()

static AO2_GLOBAL_OBJ_STATIC ( globals  )

static

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 4703 of file res_xmpp.c.

ast_xmpp_chatroom_invite()

int ast_xmpp_chatroom_invite	(	struct ast_xmpp_client *	client,
		const char *	user,
		const char *	room,
		const char *	message
	)

Invite a user to an XMPP multi-user chatroom.

Parameters

client	Pointer to the client
user	JID of the user
room	Name of the chatroom
message	Message to send with the invitation

Return values

0	on success
-1	on failure

Definition at line 943 of file res_xmpp.c.

{
    int res = 0;
    iks *invite, *body = NULL, *namespace = NULL;
 
    if (!(invite = iks_new("message")) || !(body = iks_new("body")) || !(namespace = iks_new("x"))) {
        res = -1;
        goto done;
    }
 
    iks_insert_attrib(invite, "to", user);
    ast_xmpp_client_lock(client);
    iks_insert_attrib(invite, "id", client->mid);
    ast_xmpp_increment_mid(client->mid);
    ast_xmpp_client_unlock(client);
    iks_insert_cdata(body, message, 0);
    iks_insert_node(invite, body);
    iks_insert_attrib(namespace, "xmlns", "jabber:x:conference");
    iks_insert_attrib(namespace, "jid", room);
    iks_insert_node(invite, namespace);
 
    res = ast_xmpp_client_send(client, invite);
 
done:
    iks_delete(namespace);
    iks_delete(body);
    iks_delete(invite);
 
    return res;
}

References ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), done, ast_xmpp_client::mid, and NULL.

ast_xmpp_chatroom_join()

int ast_xmpp_chatroom_join	(	struct ast_xmpp_client *	client,
		const char *	room,
		const char *	nickname
	)

Join an XMPP multi-user chatroom.

Parameters

client	Pointer to the client
room	Name of the chatroom
nickname	Nickname to use

Return values

0	on success
-1	on failure

Definition at line 1010 of file res_xmpp.c.

{
    return xmpp_client_set_group_presence(client, room, IKS_SHOW_AVAILABLE, nickname);
}

References xmpp_client_set_group_presence().

Referenced by xmpp_join_exec().

ast_xmpp_chatroom_leave()

int ast_xmpp_chatroom_leave	(	struct ast_xmpp_client *	client,
		const char *	room,
		const char *	nickname
	)

Leave an XMPP multi-user chatroom.

Parameters

client	Pointer to the client
room	Name of the chatroom
nickname	Nickname being used

Return values

0	on success
-1	on failure

Definition at line 1020 of file res_xmpp.c.

{
    return xmpp_client_set_group_presence(client, room, IKS_SHOW_UNAVAILABLE, nickname);
}

References xmpp_client_set_group_presence().

Referenced by xmpp_leave_exec().

ast_xmpp_chatroom_send()

int ast_xmpp_chatroom_send	(	struct ast_xmpp_client *	client,
		const char *	nickname,
		const char *	address,
		const char *	message
	)

Send a message to an XMPP multi-user chatroom.

Parameters

client	Pointer to the client
nickname	Nickname to use
address	Address of the room
message	Message itself

Return values

0	on success
-1	on failure

Definition at line 1015 of file res_xmpp.c.

{
    return xmpp_client_send_message(client, 1, nickname, address, message);
}

References xmpp_client_send_message().

Referenced by xmpp_sendgroup_exec().

ast_xmpp_client_config_alloc()

static void * ast_xmpp_client_config_alloc ( const char *  cat )

static

Allocator function for configuration.

Definition at line 677 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg;
 
    if (!(cfg = ao2_alloc(sizeof(*cfg), ast_xmpp_client_config_destructor))) {
        return NULL;
    }
 
    if (ast_string_field_init(cfg, 512)) {
        ao2_ref(cfg, -1);
        return NULL;
    }
 
    if (!(cfg->client = xmpp_client_find_or_create(cat))) {
        ao2_ref(cfg, -1);
        return NULL;
    }
 
    cfg->buddies = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0, BUDDY_BUCKETS,
        xmpp_buddy_hash, NULL, xmpp_buddy_cmp);
    if (!cfg->buddies) {
        ao2_ref(cfg, -1);
        return NULL;
    }
 
    ast_string_field_set(cfg, name, cat);
 
    return cfg;
}

References ao2_alloc, AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_hash, ao2_ref, ast_string_field_init, ast_string_field_set, ast_xmpp_client_config_destructor(), ast_xmpp_client_config::buddies, BUDDY_BUCKETS, ast_xmpp_client_config::client, name, NULL, xmpp_buddy_cmp(), xmpp_buddy_hash(), and xmpp_client_find_or_create().

ast_xmpp_client_config_destructor()

static void ast_xmpp_client_config_destructor ( void *  obj )

static

Destructor function for configuration.

Definition at line 529 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg = obj;
    ast_string_field_free_memory(cfg);
    ao2_cleanup(cfg->client);
    ao2_cleanup(cfg->buddies);
}

References ao2_cleanup, ast_string_field_free_memory, ast_xmpp_client_config::buddies, and ast_xmpp_client_config::client.

Referenced by ast_xmpp_client_config_alloc().

ast_xmpp_client_disconnect()

int ast_xmpp_client_disconnect

(

struct ast_xmpp_client *

client

)

Disconnect an XMPP client connection.

Parameters

client

Pointer to the client

Return values

0	on success
-1	on failure

Definition at line 3525 of file res_xmpp.c.

{
    if ((client->thread != AST_PTHREADT_NULL) && !pthread_equal(pthread_self(), client->thread)) {
        xmpp_client_change_state(client, XMPP_STATE_DISCONNECTING);
        pthread_cancel(client->thread);
        pthread_join(client->thread, NULL);
        client->thread = AST_PTHREADT_NULL;
    }
 
    if (client->mwi_sub) {
        client->mwi_sub = stasis_unsubscribe_and_join(client->mwi_sub);
        xmpp_pubsub_unsubscribe(client, "message_waiting");
    }
 
    if (client->device_state_sub) {
        client->device_state_sub = stasis_unsubscribe_and_join(client->device_state_sub);
        xmpp_pubsub_unsubscribe(client, "device_state");
    }
 
#ifdef HAVE_OPENSSL
    if (client->stream_flags & SECURE) {
        SSL_shutdown(client->ssl_session);
        SSL_CTX_free(client->ssl_context);
        SSL_free(client->ssl_session);
    }
 
    client->stream_flags = 0;
#endif
 
    if (client->parser) {
        iks_disconnect(client->parser);
    }
 
    xmpp_client_change_state(client, XMPP_STATE_DISCONNECTED);
 
    return 0;
}

References AST_PTHREADT_NULL, ast_xmpp_client::device_state_sub, ast_xmpp_client::mwi_sub, NULL, ast_xmpp_client::parser, stasis_unsubscribe_and_join(), ast_xmpp_client::thread, xmpp_client_change_state(), xmpp_pubsub_unsubscribe(), XMPP_STATE_DISCONNECTED, and XMPP_STATE_DISCONNECTING.

Referenced by xmpp_client_config_post_apply(), xmpp_client_destructor(), xmpp_client_reconnect(), and xmpp_client_thread().

ast_xmpp_client_find()

struct ast_xmpp_client * ast_xmpp_client_find

(

const char *

name

)

Find an XMPP client connection using a given name.

Parameters

name	Name of the client connection

Return values

non-NULL	on success
NULL	on failure

Note

This will return the client connection with the reference count incremented by one.

Definition at line 881 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        return NULL;
    }
 
    ao2_ref(clientcfg->client, +1);
    return clientcfg->client;
}

References ao2_cleanup, ao2_global_obj_ref, ao2_ref, globals, name, NULL, RAII_VAR, and xmpp_config_find().

Referenced by custom_connection_handler().

ast_xmpp_client_lock()

void ast_xmpp_client_lock

(

struct ast_xmpp_client *

client

)

Lock an XMPP client connection.

Parameters

client

Pointer to the client

Definition at line 899 of file res_xmpp.c.

{
    ao2_lock(client);
}

References ao2_lock.

Referenced by ast_xmpp_chatroom_invite(), xmpp_client_authenticate_digest(), xmpp_client_authenticating(), xmpp_client_send_disco_info_request(), xmpp_component_register_set_hook(), xmpp_pak_message(), xmpp_ping_request(), and xmpp_pubsub_iq_create().

ast_xmpp_client_send()

int ast_xmpp_client_send	(	struct ast_xmpp_client *	client,
		iks *	stanza
	)

Send an XML stanza out using an established XMPP client connection.

Parameters

client	Pointer to the client
stanza	Pointer to the Iksemel stanza

Return values

0	on success
-1	on failure

Definition at line 2534 of file res_xmpp.c.

{
    return xmpp_client_send_raw_message(client, iks_string(iks_stack(stanza), stanza));
}

References xmpp_client_send_raw_message().

Referenced by ast_xmpp_chatroom_invite(), jingle_send_error_response(), jingle_send_response(), jingle_send_session_action(), jingle_send_session_info(), jingle_send_session_terminate(), jingle_send_transport_info(), xmpp_client_authenticate_digest(), xmpp_client_authenticate_sasl(), xmpp_client_authenticating(), xmpp_client_send_disco_info_request(), xmpp_client_send_message(), xmpp_client_service_discovery_get_hook(), xmpp_client_set_group_presence(), xmpp_client_set_presence(), xmpp_client_subscribe_user(), xmpp_client_unsubscribe_user(), xmpp_component_register_get_hook(), xmpp_component_register_set_hook(), xmpp_component_service_discovery_get_hook(), xmpp_component_service_discovery_items_hook(), xmpp_connect_hook(), xmpp_pak_s10n(), xmpp_ping_request(), xmpp_pubsub_create_affiliations(), xmpp_pubsub_create_node(), xmpp_pubsub_delete_node(), xmpp_pubsub_handle_error(), xmpp_pubsub_publish_device_state(), xmpp_pubsub_publish_mwi(), xmpp_pubsub_purge_nodes(), xmpp_pubsub_request_nodes(), xmpp_pubsub_subscribe(), and xmpp_pubsub_unsubscribe().

ast_xmpp_client_send_message()

int ast_xmpp_client_send_message	(	struct ast_xmpp_client *	client,
		const char *	user,
		const char *	message
	)

Send a message to a given user using an established XMPP client connection.

Parameters

client	Pointer to the client
user	User the message should be sent to
message	The message to send

Return values

0	on success
-1	on failure

Definition at line 938 of file res_xmpp.c.

{
    return xmpp_client_send_message(client, 0, NULL, user, message);
}

References NULL, and xmpp_client_send_message().

Referenced by jingle_sendtext(), manager_jabber_send(), xmpp_send_cb(), and xmpp_send_exec().

ast_xmpp_client_unlock()

void ast_xmpp_client_unlock

(

struct ast_xmpp_client *

client

)

Unlock an XMPP client connection.

Parameters

client

Pointer to the client

Definition at line 904 of file res_xmpp.c.

{
    ao2_unlock(client);
}

References ao2_unlock.

Referenced by ast_xmpp_chatroom_invite(), xmpp_client_authenticate_digest(), xmpp_client_authenticating(), xmpp_client_send_disco_info_request(), xmpp_component_register_set_hook(), xmpp_pak_message(), xmpp_ping_request(), and xmpp_pubsub_iq_create().

ast_xmpp_client_unref()

void ast_xmpp_client_unref

(

struct ast_xmpp_client *

client

)

Release XMPP client connection reference.

Parameters

client

Pointer to the client

Definition at line 894 of file res_xmpp.c.

{
    ao2_ref(client, -1);
}

References ao2_ref.

Referenced by jingle_endpoint_destructor(), and jingle_session_destructor().

ast_xmpp_increment_mid()

void ast_xmpp_increment_mid

(

char *

mid

)

Helper function which increments the message identifier.

Parameters

mid	Pointer to a string containing the message identifier

Definition at line 1025 of file res_xmpp.c.

{
    int i = 0;
 
    for (i = strlen(mid) - 1; i >= 0; i--) {
        if (mid[i] != 'z') {
            mid[i] = mid[i] + 1;
            i = 0;
        } else {
            mid[i] = 'a';
        }
    }
}

Referenced by ast_xmpp_chatroom_invite(), jingle_send_session_action(), jingle_send_session_info(), jingle_send_session_terminate(), jingle_send_transport_info(), xmpp_client_authenticate_digest(), xmpp_client_authenticating(), xmpp_client_send_disco_info_request(), xmpp_component_register_set_hook(), xmpp_ping_request(), and xmpp_pubsub_iq_create().

cached_devstate_cb()

static int cached_devstate_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 1571 of file res_xmpp.c.

{
    struct stasis_message *msg = obj;
    struct ast_xmpp_client *client = arg;
    xmpp_pubsub_devstate_cb(client, client->device_state_sub, msg);
    return 0;
}

References ast_xmpp_client::device_state_sub, and xmpp_pubsub_devstate_cb().

Referenced by xmpp_init_event_distribution().

client_bitfield_handler()

static int client_bitfield_handler ( const struct aco_option *  opt, struct ast_variable *  var, void *  obj  )

static

Definition at line 4525 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg = obj;
 
    if (!strcasecmp(var->name, "debug")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_DEBUG);
    } else if (!strcasecmp(var->name, "type")) {
        ast_set2_flag(&cfg->flags, !strcasecmp(var->value, "component") ? 1 : 0, XMPP_COMPONENT);
    } else if (!strcasecmp(var->name, "distribute_events")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_DISTRIBUTE_EVENTS);
    } else if (!strcasecmp(var->name, "usetls")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_USETLS);
    } else if (!strcasecmp(var->name, "usesasl")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_USESASL);
    } else if (!strcasecmp(var->name, "forceoldssl")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_FORCESSL);
    } else if (!strcasecmp(var->name, "keepalive")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_KEEPALIVE);
    } else if (!strcasecmp(var->name, "autoprune")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_AUTOPRUNE);
        ast_set2_flag(&cfg->mod_flags, 1, XMPP_AUTOPRUNE);
    } else if (!strcasecmp(var->name, "autoregister")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_AUTOREGISTER);
        ast_set2_flag(&cfg->mod_flags, 1, XMPP_AUTOREGISTER);
    } else if (!strcasecmp(var->name, "auth_policy")) {
        ast_set2_flag(&cfg->flags, !strcasecmp(var->value, "accept") ? 1 : 0, XMPP_AUTOACCEPT);
        ast_set2_flag(&cfg->mod_flags, 1, XMPP_AUTOACCEPT);
    } else if (!strcasecmp(var->name, "sendtodialplan")) {
        ast_set2_flag(&cfg->flags, ast_true(var->value), XMPP_SEND_TO_DIALPLAN);
    } else {
        return -1;
    }
 
    return 0;
}

References ast_set2_flag, ast_true(), ast_xmpp_client_config::flags, ast_xmpp_client_config::mod_flags, var, XMPP_AUTOACCEPT, XMPP_AUTOPRUNE, XMPP_AUTOREGISTER, XMPP_COMPONENT, XMPP_DEBUG, XMPP_DISTRIBUTE_EVENTS, XMPP_FORCESSL, XMPP_KEEPALIVE, XMPP_SEND_TO_DIALPLAN, XMPP_USESASL, and XMPP_USETLS.

Referenced by load_module().

client_buddy_handler()

static int client_buddy_handler ( const struct aco_option *  opt, struct ast_variable *  var, void *  obj  )

static

Definition at line 4590 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg = obj;
    struct ast_xmpp_buddy *buddy;
 
    if ((buddy = ao2_find(cfg->buddies, var->value, OBJ_KEY))) {
        ao2_ref(buddy, -1);
        return -1;
    }
 
    if (!(buddy = xmpp_client_create_buddy(cfg->buddies, var->value))) {
        return -1;
    }
 
    ao2_ref(buddy, -1);
 
    return 0;
}

References ao2_find, ao2_ref, ast_xmpp_client_config::buddies, OBJ_KEY, var, and xmpp_client_create_buddy().

Referenced by load_module().

client_status_handler()

static int client_status_handler ( const struct aco_option *  opt, struct ast_variable *  var, void *  obj  )

static

Definition at line 4561 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg = obj;
 
    if (!strcasecmp(var->value, "unavailable")) {
        cfg->status = IKS_SHOW_UNAVAILABLE;
    } else if (!strcasecmp(var->value, "available") || !strcasecmp(var->value, "online")) {
        cfg->status = IKS_SHOW_AVAILABLE;
    } else if (!strcasecmp(var->value, "chat") || !strcasecmp(var->value, "chatty")) {
        cfg->status = IKS_SHOW_CHAT;
    } else if (!strcasecmp(var->value, "away")) {
        cfg->status = IKS_SHOW_AWAY;
    } else if (!strcasecmp(var->value, "xa") || !strcasecmp(var->value, "xaway")) {
        cfg->status = IKS_SHOW_XA;
    } else if (!strcasecmp(var->value, "dnd")) {
        cfg->status = IKS_SHOW_DND;
    } else if (!strcasecmp(var->value, "invisible")) {
#ifdef IKS_SHOW_INVISIBLE
        cfg->status = IKS_SHOW_INVISIBLE;
#else
        cfg->status = IKS_SHOW_DND;
#endif
    } else {
        return -1;
    }
 
    return 0;
}

References ast_xmpp_client_config::status, and var.

Referenced by load_module().

CONFIG_INFO_STANDARD()

CONFIG_INFO_STANDARD	(	cfg_info	,
		globals	,
		xmpp_config_alloc	,
		.	files = ACO_FILES(&res_xmpp_conf),
		.	post_apply_config = xmpp_config_post_apply
	)

delete_old_messages()

static int delete_old_messages ( struct ast_xmpp_client *  client, char *  from  )

static

Definition at line 2092 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    int deleted = 0, isold = 0;
    struct ast_xmpp_message *message = NULL;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return 0;
    }
 
    AST_LIST_LOCK(&client->messages);
    AST_LIST_TRAVERSE_SAFE_BEGIN(&client->messages, message, list) {
        if (isold) {
            if (!from || !strncasecmp(from, message->from, strlen(from))) {
                AST_LIST_REMOVE_CURRENT(list);
                xmpp_message_destroy(message);
                deleted++;
            }
        } else if (ast_tvdiff_sec(ast_tvnow(), message->arrived) >= clientcfg->message_timeout) {
            isold = 1;
            if (!from || !strncasecmp(from, message->from, strlen(from))) {
                AST_LIST_REMOVE_CURRENT(list);
                xmpp_message_destroy(message);
                deleted++;
            }
        }
    }
    AST_LIST_TRAVERSE_SAFE_END;
    AST_LIST_UNLOCK(&client->messages);
 
    return deleted;
}

References ao2_cleanup, ao2_global_obj_ref, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_tvdiff_sec(), ast_tvnow(), ast_xmpp_message::from, globals, ast_xmpp_message::list, ast_xmpp_client::messages, ast_xmpp_client::name, NULL, RAII_VAR, xmpp_config_find(), and xmpp_message_destroy().

Referenced by xmpp_pak_message().

fetch_access_token()

static int fetch_access_token ( struct ast_xmpp_client_config *  cfg )

static

Definition at line 3824 of file res_xmpp.c.

{
    RAII_VAR(char *, cmd, NULL, ast_free);
    char cBuf[1024] = "";
    const char *url = "https://www.googleapis.com/oauth2/v3/token";
    struct ast_json_error error;
    RAII_VAR(struct ast_json *, jobj, NULL, ast_json_unref);
 
    if (ast_asprintf(&cmd,
        "CURL(%s,client_id=%s&client_secret=%s&refresh_token=%s&grant_type=refresh_token)",
        url, cfg->oauth_clientid, cfg->oauth_secret, cfg->refresh_token) < 0) {
        return -1;
    }
 
    ast_debug(2, "Performing OAuth 2.0 authentication for client '%s' using command: %s\n",
        cfg->name, cmd);
 
    if (ast_func_read(NULL, cmd, cBuf, sizeof(cBuf) - 1)) {
        ast_log(LOG_ERROR, "CURL is unavailable. This is required for OAuth 2.0 authentication of XMPP client '%s'. Please ensure it is loaded.\n",
            cfg->name);
        return -1;
    }
 
    ast_debug(2, "OAuth 2.0 authentication for client '%s' returned: %s\n", cfg->name, cBuf);
 
    jobj = ast_json_load_string(cBuf, &error);
    if (jobj) {
        const char *token = ast_json_string_get(ast_json_object_get(jobj, "access_token"));
        if (token) {
            ast_string_field_set(cfg, password, token);
            return 0;
        }
    }
 
    ast_log(LOG_ERROR, "An error occurred while performing OAuth 2.0 authentication for client '%s': %s\n", cfg->name, cBuf);
 
    return -1;
}

References ast_asprintf, ast_debug, ast_free, ast_func_read(), ast_json_load_string(), ast_json_object_get(), ast_json_string_get(), ast_json_unref(), ast_log, ast_string_field_set, error(), LOG_ERROR, ast_xmpp_client_config::name, NULL, ast_xmpp_client_config::oauth_clientid, ast_xmpp_client_config::oauth_secret, RAII_VAR, ast_xmpp_client_config::refresh_token, and url.

Referenced by xmpp_client_reconnect().

get_buddy_status()

static int get_buddy_status ( struct ast_xmpp_client_config *  clientcfg, char *  screenname, char *  resource  )

static

Definition at line 1630 of file res_xmpp.c.

{
    int status = BUDDY_OFFLINE;
    struct ast_xmpp_resource *res;
    struct ast_xmpp_buddy *buddy = ao2_find(clientcfg->client->buddies, screenname, OBJ_KEY);
 
    if (!buddy) {
        return BUDDY_NOT_IN_ROSTER;
    }
 
    res = ao2_callback(
        buddy->resources,
        0,
        ast_strlen_zero(resource) ? xmpp_resource_immediate : xmpp_resource_cmp,
        resource);
 
    if (res) {
        status = res->status;
    }
 
    ao2_cleanup(res);
    ao2_cleanup(buddy);
 
    return status;
}

References ao2_callback, ao2_cleanup, ao2_find, ast_strlen_zero(), ast_xmpp_client::buddies, BUDDY_NOT_IN_ROSTER, BUDDY_OFFLINE, ast_xmpp_client_config::client, OBJ_KEY, ast_xmpp_buddy::resources, status, ast_xmpp_resource::status, xmpp_resource_cmp(), and xmpp_resource_immediate().

Referenced by acf_jabberstatus_read().

global_bitfield_handler()

static int global_bitfield_handler ( const struct aco_option *  opt, struct ast_variable *  var, void *  obj  )

static

Definition at line 4502 of file res_xmpp.c.

{
    struct ast_xmpp_global_config *global = obj;
 
    if (!strcasecmp(var->name, "debug")) {
        debug = ast_true(var->value);
    } else if (!strcasecmp(var->name, "autoprune")) {
        ast_set2_flag(&global->general, ast_true(var->value), XMPP_AUTOPRUNE);
    } else if (!strcasecmp(var->name, "autoregister")) {
        ast_set2_flag(&global->general, ast_true(var->value), XMPP_AUTOREGISTER);
    } else if (!strcasecmp(var->name, "auth_policy")) {
        ast_set2_flag(&global->general, !strcasecmp(var->value, "accept") ? 1 : 0, XMPP_AUTOACCEPT);
    } else if (!strcasecmp(var->name, "collection_nodes")) {
        ast_set2_flag(&global->pubsub, ast_true(var->value), XMPP_XEP0248);
    } else if (!strcasecmp(var->name, "pubsub_autocreate")) {
        ast_set2_flag(&global->pubsub, ast_true(var->value), XMPP_PUBSUB_AUTOCREATE);
    } else {
        return -1;
    }
 
    return 0;
}

References ast_set2_flag, ast_true(), debug, global, var, XMPP_AUTOACCEPT, XMPP_AUTOPRUNE, XMPP_AUTOREGISTER, XMPP_PUBSUB_AUTOCREATE, and XMPP_XEP0248.

Referenced by load_module().

load_module()

static int load_module ( void  )

static

Load the module.

Module loading including tests for configuration or dependencies. This function can return AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_DECLINE, or AST_MODULE_LOAD_SUCCESS. If a dependency or environment variable fails tests return AST_MODULE_LOAD_FAILURE. If the module can not load the configuration file or other non-critical problem return AST_MODULE_LOAD_DECLINE. On success return AST_MODULE_LOAD_SUCCESS.

Definition at line 4619 of file res_xmpp.c.

{
    if (aco_info_init(&cfg_info)) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    aco_option_register_custom(&cfg_info, "debug", ACO_EXACT, global_options, "no", global_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "autoprune", ACO_EXACT, global_options, "no", global_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "autoregister", ACO_EXACT, global_options, "yes", global_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "collection_nodes", ACO_EXACT, global_options, "no", global_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "pubsub_autocreate", ACO_EXACT, global_options, "no", global_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "auth_policy", ACO_EXACT, global_options, "accept", global_bitfield_handler, 0);
 
    aco_option_register(&cfg_info, "username", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, user));
    aco_option_register(&cfg_info, "secret", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, password));
    aco_option_register(&cfg_info, "refresh_token", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, refresh_token));
    aco_option_register(&cfg_info, "oauth_clientid", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, oauth_clientid));
    aco_option_register(&cfg_info, "oauth_secret", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, oauth_secret));
    aco_option_register(&cfg_info, "serverhost", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, server));
    aco_option_register(&cfg_info, "statusmessage", ACO_EXACT, client_options, "Online and Available", OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, statusmsg));
    aco_option_register(&cfg_info, "pubsub_node", ACO_EXACT, client_options, NULL, OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, pubsubnode));
    aco_option_register(&cfg_info, "context", ACO_EXACT, client_options, "default", OPT_STRINGFIELD_T, 0, STRFLDSET(struct ast_xmpp_client_config, context));
    aco_option_register(&cfg_info, "priority", ACO_EXACT, client_options, "1", OPT_UINT_T, 0, FLDSET(struct ast_xmpp_client_config, priority));
    aco_option_register(&cfg_info, "port", ACO_EXACT, client_options, "5222", OPT_UINT_T, 0, FLDSET(struct ast_xmpp_client_config, port));
    aco_option_register(&cfg_info, "timeout", ACO_EXACT, client_options, "5", OPT_UINT_T, 0, FLDSET(struct ast_xmpp_client_config, message_timeout));
 
    /* Global options that can be overridden per client must not specify a default */
    aco_option_register_custom(&cfg_info, "autoprune", ACO_EXACT, client_options, NULL, client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "autoregister", ACO_EXACT, client_options, NULL, client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "auth_policy", ACO_EXACT, client_options, NULL, client_bitfield_handler, 0);
 
    aco_option_register_custom(&cfg_info, "debug", ACO_EXACT, client_options, "no", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "type", ACO_EXACT, client_options, "client", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "distribute_events", ACO_EXACT, client_options, "no", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "usetls", ACO_EXACT, client_options, "yes", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "usesasl", ACO_EXACT, client_options, "yes", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "forceoldssl", ACO_EXACT, client_options, "no", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "keepalive", ACO_EXACT, client_options, "yes", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "sendtodialplan", ACO_EXACT, client_options, "no", client_bitfield_handler, 0);
    aco_option_register_custom(&cfg_info, "status", ACO_EXACT, client_options, "available", client_status_handler, 0);
    aco_option_register_custom(&cfg_info, "buddy", ACO_EXACT, client_options, NULL, client_buddy_handler, 0);
 
    if (aco_process_config(&cfg_info, 0) == ACO_PROCESS_ERROR) {
        aco_info_destroy(&cfg_info);
        return AST_MODULE_LOAD_DECLINE;
    }
 
    ast_manager_register_xml("JabberSend", EVENT_FLAG_SYSTEM, manager_jabber_send);
 
    ast_register_application_xml(app_ajisend, xmpp_send_exec);
    ast_register_application_xml(app_ajisendgroup, xmpp_sendgroup_exec);
    ast_register_application_xml(app_ajijoin, xmpp_join_exec);
    ast_register_application_xml(app_ajileave, xmpp_leave_exec);
 
    ast_cli_register_multiple(xmpp_cli, ARRAY_LEN(xmpp_cli));
    ast_custom_function_register(&jabberstatus_function);
    ast_custom_function_register(&jabberreceive_function);
    ast_msg_tech_register(&msg_tech);
 
    ast_mutex_init(&messagelock);
    ast_cond_init(&message_received_condition, NULL);
 
    if (ast_eid_is_empty(&ast_eid_default)) {
        ast_log(LOG_WARNING, "Entity ID is not set. The distributing device state or MWI will not work.\n");
    }
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ACO_EXACT, aco_info_destroy(), aco_info_init(), aco_option_register, aco_option_register_custom, aco_process_config(), ACO_PROCESS_ERROR, app_ajijoin, app_ajileave, app_ajisend, app_ajisendgroup, ARRAY_LEN, ast_cli_register_multiple, ast_cond_init, ast_custom_function_register, ast_eid_default, ast_eid_is_empty(), ast_log, ast_manager_register_xml, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_msg_tech_register(), ast_mutex_init, ast_register_application_xml, client_bitfield_handler(), client_buddy_handler(), client_options, client_status_handler(), voicemailpwcheck::context, EVENT_FLAG_SYSTEM, FLDSET, global_bitfield_handler(), global_options, jabberreceive_function, jabberstatus_function, LOG_WARNING, manager_jabber_send(), message_received_condition, messagelock, msg_tech, NULL, OPT_STRINGFIELD_T, OPT_UINT_T, priority, STRFLDSET, xmpp_cli, xmpp_join_exec(), xmpp_leave_exec(), xmpp_send_exec(), and xmpp_sendgroup_exec().

manager_jabber_send()

static int manager_jabber_send ( struct mansession *  s, const struct message *  m  )

static

Definition at line 3924 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *id = astman_get_header(m, "ActionID");
    const char *jabber = astman_get_header(m, "Jabber");
    const char *screenname = astman_get_header(m, "ScreenName");
    const char *message = astman_get_header(m, "Message");
 
    if (ast_strlen_zero(jabber)) {
        astman_send_error(s, m, "No transport specified");
        return 0;
    }
    if (ast_strlen_zero(screenname)) {
        astman_send_error(s, m, "No ScreenName specified");
        return 0;
    }
    if (ast_strlen_zero(message)) {
        astman_send_error(s, m, "No Message specified");
        return 0;
    }
 
    astman_send_ack(s, m, "Attempting to send Jabber Message");
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, jabber))) {
        astman_send_error(s, m, "Could not find Sender");
        return 0;
    }
 
    if (strchr(screenname, '@') && !ast_xmpp_client_send_message(clientcfg->client, screenname, message)) {
        astman_append(s, "Response: Success\r\n");
    } else {
        astman_append(s, "Response: Error\r\n");
    }
 
    if (!ast_strlen_zero(id)) {
        astman_append(s, "ActionID: %s\r\n", id);
    }
 
    astman_append(s, "\r\n");
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, ast_strlen_zero(), ast_xmpp_client_send_message(), astman_append(), astman_get_header(), astman_send_ack(), astman_send_error(), globals, NULL, RAII_VAR, and xmpp_config_find().

Referenced by load_module().

reload()

static int reload ( void  )

static

Definition at line 4688 of file res_xmpp.c.

{
    if (aco_process_config(&cfg_info, 1) == ACO_PROCESS_ERROR) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    return 0;
}

References aco_process_config(), ACO_PROCESS_ERROR, and AST_MODULE_LOAD_DECLINE.

sleep_with_backoff()

static void sleep_with_backoff ( unsigned int *  sleep_time )

static

Definition at line 3716 of file res_xmpp.c.

{
    /* We're OK with our thread dying here */
    pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
 
    sleep(*sleep_time);
    *sleep_time = MIN(60, *sleep_time * 2);
 
    pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
}

References MIN, and NULL.

Referenced by xmpp_client_thread().

unload_module()

static int unload_module ( void  )

static

Definition at line 4481 of file res_xmpp.c.

{
    ast_msg_tech_unregister(&msg_tech);
    ast_cli_unregister_multiple(xmpp_cli, ARRAY_LEN(xmpp_cli));
    ast_unregister_application(app_ajisend);
    ast_unregister_application(app_ajisendgroup);
    ast_unregister_application(app_ajistatus);
    ast_unregister_application(app_ajijoin);
    ast_unregister_application(app_ajileave);
    ast_manager_unregister("JabberSend");
    ast_custom_function_unregister(&jabberstatus_function);
    ast_custom_function_unregister(&jabberreceive_function);
    aco_info_destroy(&cfg_info);
    ao2_global_obj_release(globals);
 
    ast_cond_destroy(&message_received_condition);
    ast_mutex_destroy(&messagelock);
 
    return 0;
}

References aco_info_destroy(), ao2_global_obj_release, app_ajijoin, app_ajileave, app_ajisend, app_ajisendgroup, app_ajistatus, ARRAY_LEN, ast_cli_unregister_multiple(), ast_cond_destroy, ast_custom_function_unregister(), ast_manager_unregister(), ast_msg_tech_unregister(), ast_mutex_destroy, ast_unregister_application(), globals, jabberreceive_function, jabberstatus_function, message_received_condition, messagelock, msg_tech, and xmpp_cli.

xmpp_action_hook()

static int xmpp_action_hook ( void *  data, int  type, iks *  node  )

static

Action hook for when things occur.

Definition at line 3455 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    ikspak *pak;
    int i;
 
    if (!node) {
        ast_log(LOG_ERROR, "xmpp_action_hook was called without a packet\n");
        return IKS_HOOK;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return IKS_HOOK;
    }
 
    /* If the client is disconnecting ignore everything */
    if (client->state == XMPP_STATE_DISCONNECTING) {
        return IKS_HOOK;
    }
 
    pak = iks_packet(node);
 
    /* work around iksemel's impossibility to recognize node names
     * containing a colon. Set the namespace of the corresponding
     * node accordingly. */
    if (iks_has_children(node) && strchr(iks_name(iks_child(node)), ':')) {
        char *node_ns = NULL;
        char attr[XMPP_MAX_ATTRLEN];
        char *node_name = iks_name(iks_child(node));
        char *aux = strchr(node_name, ':') + 1;
        snprintf(attr, strlen("xmlns:") + (strlen(node_name) - strlen(aux)), "xmlns:%s", node_name);
        node_ns = iks_find_attrib(iks_child(node), attr);
        if (node_ns) {
            pak->ns = node_ns;
            pak->query = iks_child(node);
        }
    }
 
    /* Process through any state handlers */
    for (i = 0; i < ARRAY_LEN(xmpp_state_handlers); i++) {
        if ((xmpp_state_handlers[i].state == client->state) && (xmpp_state_handlers[i].component == (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT) ? 1 : 0))) {
            if (xmpp_state_handlers[i].handler(client, clientcfg, type, node)) {
                /* If the handler wants us to stop now, do so */
                return IKS_HOOK;
            }
            break;
        }
    }
 
    /* Process through any PAK handlers */
    for (i = 0; i < ARRAY_LEN(xmpp_pak_handlers); i++) {
        if (xmpp_pak_handlers[i].type == pak->type) {
            if (xmpp_pak_handlers[i].handler(client, clientcfg, node, pak)) {
                /* If the handler wants us to stop now, do so */
                return IKS_HOOK;
            }
            break;
        }
    }
 
    /* Send the packet through the filter in case any filters want to process it */
    iks_filter_packet(client->filter, pak);
 
    iks_delete(node);
 
    return IKS_OK;
}

References ao2_cleanup, ao2_global_obj_ref, ARRAY_LEN, ast_log, ast_test_flag, xmpp_state_handler::component, ast_xmpp_client::filter, globals, handler(), LOG_ERROR, ast_xmpp_client::name, NULL, RAII_VAR, ast_xmpp_client::state, type, XMPP_COMPONENT, xmpp_config_find(), XMPP_MAX_ATTRLEN, xmpp_pak_handlers, XMPP_STATE_DISCONNECTING, and xmpp_state_handlers.

Referenced by xmpp_client_config_post_apply().

xmpp_buddy_cmp()

static int xmpp_buddy_cmp ( void *  obj, void *  arg, int  flags  )

static

Comparator function for XMPP buddy.

Definition at line 587 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy1 = obj, *buddy2 = arg;
    const char *id = arg;
 
    return !strcmp(buddy1->id, flags & OBJ_KEY ? id : buddy2->id) ? CMP_MATCH | CMP_STOP : 0;
}

References CMP_MATCH, CMP_STOP, ast_xmpp_buddy::id, and OBJ_KEY.

Referenced by ast_xmpp_client_config_alloc(), and xmpp_client_alloc().

xmpp_buddy_destructor()

static void xmpp_buddy_destructor ( void *  obj )

static

Destructor callback function for XMPP buddy.

Definition at line 862 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy = obj;
 
    if (buddy->resources) {
        ao2_ref(buddy->resources, -1);
    }
}

References ao2_ref, and ast_xmpp_buddy::resources.

Referenced by xmpp_client_create_buddy().

xmpp_buddy_hash()

static int xmpp_buddy_hash ( const void *  obj, const int  flags  )

static

Hashing function for XMPP buddy.

Definition at line 578 of file res_xmpp.c.

{
    const struct ast_xmpp_buddy *buddy = obj;
    const char *id = obj;
 
    return ast_str_hash(flags & OBJ_KEY ? id : buddy->id);
}

References ast_str_hash(), ast_xmpp_buddy::id, and OBJ_KEY.

Referenced by ast_xmpp_client_config_alloc(), and xmpp_client_alloc().

xmpp_cli_create_collection()

static char * xmpp_cli_create_collection ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Method to expose PubSub collection node creation via CLI.

Returns

char *

Definition at line 4218 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *name, *collection_name;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp create collection";
        e->usage =
            "Usage: xmpp create collection <connection> <collection>\n"
            "       Creates a PubSub collection node using the account\n"
            "       as configured in xmpp.conf.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 5) {
        return CLI_SHOWUSAGE;
    }
    name = a->argv[3];
    collection_name = a->argv[4];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        ast_cli(a->fd, "Unable to find client '%s'!\n", name);
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "Creating test PubSub node collection.\n");
 
    xmpp_pubsub_create_collection(clientcfg->client, collection_name);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, globals, name, NULL, RAII_VAR, ast_cli_entry::usage, xmpp_config_find(), and xmpp_pubsub_create_collection().

xmpp_cli_create_leafnode()

static char * xmpp_cli_create_leafnode ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Method to expose PubSub leaf node creation via CLI.

Returns

char *

Definition at line 4258 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *name, *collection_name, *leaf_name;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp create leaf";
        e->usage =
            "Usage: xmpp create leaf <connection> <collection> <leaf>\n"
            "       Creates a PubSub leaf node using the account\n"
            "       as configured in xmpp.conf.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 6) {
        return CLI_SHOWUSAGE;
    }
    name = a->argv[3];
    collection_name = a->argv[4];
    leaf_name = a->argv[5];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        ast_cli(a->fd, "Unable to find client '%s'!\n", name);
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "Creating test PubSub node collection.\n");
 
    xmpp_pubsub_create_leaf(clientcfg->client, collection_name, leaf_name);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, globals, name, NULL, RAII_VAR, ast_cli_entry::usage, xmpp_config_find(), and xmpp_pubsub_create_leaf().

xmpp_cli_delete_pubsub_node()

static char * xmpp_cli_delete_pubsub_node ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Method to expose PubSub node deletion via CLI.

Parameters

e	pointer to ast_cli_entry structure
cmd
a	pointer to ast_cli_args structure

Returns

char *

Definition at line 4180 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *name;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp delete node";
        e->usage =
            "Usage: xmpp delete node <connection> <node>\n"
            "       Deletes a node on PubSub server\n"
            "       as configured in xmpp.conf.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 5) {
        return CLI_SHOWUSAGE;
    }
    name = a->argv[3];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        ast_cli(a->fd, "Unable to find client '%s'!\n", name);
        return CLI_FAILURE;
    }
 
    xmpp_pubsub_delete_node(clientcfg->client, a->argv[4]);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, globals, name, NULL, RAII_VAR, ast_cli_entry::usage, xmpp_config_find(), and xmpp_pubsub_delete_node().

xmpp_cli_list_pubsub_nodes()

static char * xmpp_cli_list_pubsub_nodes ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Method to expose PubSub node list via CLI.

Parameters

e	pointer to ast_cli_entry structure
cmd
a	pointer to ast_cli_args structure

Returns

char *

Definition at line 4049 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *name = NULL, *collection = NULL;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp list nodes";
        e->usage =
            "Usage: xmpp list nodes <connection> [collection]\n"
            "       Lists the user's nodes on the respective connection\n"
            "       ([connection] as configured in xmpp.conf.)\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc > 5 || a->argc < 4) {
        return CLI_SHOWUSAGE;
    } else if (a->argc == 4 || a->argc == 5) {
        name = a->argv[3];
    }
 
    if (a->argc == 5) {
        collection = a->argv[4];
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        ast_cli(a->fd, "Unable to find client '%s'!\n", name);
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "Listing pubsub nodes.\n");
 
    xmpp_pubsub_request_nodes(clientcfg->client, collection);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, globals, name, NULL, RAII_VAR, ast_cli_entry::usage, xmpp_config_find(), and xmpp_pubsub_request_nodes().

xmpp_cli_purge_pubsub_nodes()

static char * xmpp_cli_purge_pubsub_nodes ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Method to purge PubSub nodes via CLI.

Parameters

e	pointer to ast_cli_entry structure
cmd
a	pointer to ast_cli_args structure

Returns

char *

Definition at line 4135 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    const char *name;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp purge nodes";
        e->usage =
            "Usage: xmpp purge nodes <connection> <node>\n"
            "       Purges nodes on PubSub server\n"
            "       as configured in xmpp.conf.\n";
            return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != 5) {
        return CLI_SHOWUSAGE;
    }
    name = a->argv[3];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, name))) {
        ast_cli(a->fd, "Unable to find client '%s'!\n", name);
        return CLI_FAILURE;
    }
 
    if (ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248)) {
        xmpp_pubsub_purge_nodes(clientcfg->client, a->argv[4]);
    } else {
        xmpp_pubsub_delete_node(clientcfg->client, a->argv[4]);
    }
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ast_cli(), ast_test_flag, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, globals, name, NULL, RAII_VAR, ast_cli_entry::usage, xmpp_config_find(), xmpp_pubsub_delete_node(), xmpp_pubsub_purge_nodes(), and XMPP_XEP0248.

xmpp_client_alloc()

static struct ast_xmpp_client * xmpp_client_alloc ( const char *  name )

static

Allocator function for ast_xmpp_client.

Definition at line 610 of file res_xmpp.c.

{
    struct ast_xmpp_client *client;
 
    if (!(client = ao2_alloc(sizeof(*client), xmpp_client_destructor))) {
        return NULL;
    }
 
    AST_LIST_HEAD_INIT(&client->messages);
    client->thread = AST_PTHREADT_NULL;
 
    client->endpoint = ast_endpoint_create("XMPP", name);
    if (!client->endpoint) {
        ao2_ref(client, -1);
        return NULL;
    }
 
    client->buddies = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0, BUDDY_BUCKETS,
        xmpp_buddy_hash, NULL, xmpp_buddy_cmp);
    if (!client->buddies) {
        ast_log(LOG_ERROR, "Could not initialize buddy container for '%s'\n", name);
        ao2_ref(client, -1);
        return NULL;
    }
 
    if (ast_string_field_init(client, 512)) {
        ast_log(LOG_ERROR, "Could not initialize stringfields for '%s'\n", name);
        ao2_ref(client, -1);
        return NULL;
    }
 
    if (!(client->stack = iks_stack_new(8192, 8192))) {
        ast_log(LOG_ERROR, "Could not create an Iksemel stack for '%s'\n", name);
        ao2_ref(client, -1);
        return NULL;
    }
 
    ast_string_field_set(client, name, name);
 
    client->timeout = 50;
    xmpp_client_change_state(client, XMPP_STATE_DISCONNECTED);
    ast_copy_string(client->mid, "aaaaa", sizeof(client->mid));
 
    return client;
}

References ao2_alloc, AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_hash, ao2_ref, ast_copy_string(), ast_endpoint_create(), AST_LIST_HEAD_INIT, ast_log, AST_PTHREADT_NULL, ast_string_field_init, ast_string_field_set, ast_xmpp_client::buddies, BUDDY_BUCKETS, ast_xmpp_client::endpoint, LOG_ERROR, ast_xmpp_client::messages, ast_xmpp_client::mid, name, NULL, ast_xmpp_client::stack, ast_xmpp_client::thread, ast_xmpp_client::timeout, xmpp_buddy_cmp(), xmpp_buddy_hash(), xmpp_client_change_state(), xmpp_client_destructor(), and XMPP_STATE_DISCONNECTED.

Referenced by xmpp_client_find_or_create().

xmpp_client_authenticate()

static int xmpp_client_authenticate ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we need to authenticate.

Definition at line 2757 of file res_xmpp.c.

{
    return ast_test_flag(&cfg->flags, XMPP_USESASL) ? xmpp_client_authenticate_sasl(client, cfg, type, node) : xmpp_client_authenticate_digest(client, cfg, type, node);
}

References ast_test_flag, ast_xmpp_client_config::flags, type, xmpp_client_authenticate_digest(), xmpp_client_authenticate_sasl(), and XMPP_USESASL.

xmpp_client_authenticate_digest()

static int xmpp_client_authenticate_digest ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we need to authenticate using non-SASL.

Definition at line 2654 of file res_xmpp.c.

{
    iks *iq = NULL, *query = NULL;
    char buf[41], sidpass[100];
 
    if (!(iq = iks_new("iq")) || !(query = iks_insert(iq, "query"))) {
        ast_log(LOG_ERROR, "Stanzas could not be allocated for authentication on client '%s'\n", client->name);
        iks_delete(iq);
        return -1;
    }
 
    iks_insert_attrib(iq, "type", "set");
    iks_insert_cdata(iks_insert(query, "username"), client->jid->user, 0);
    iks_insert_cdata(iks_insert(query, "resource"), client->jid->resource, 0);
 
    iks_insert_attrib(query, "xmlns", "jabber:iq:auth");
    snprintf(sidpass, sizeof(sidpass), "%s%s", iks_find_attrib(node, "id"), cfg->password);
    ast_sha1_hash(buf, sidpass);
    iks_insert_cdata(iks_insert(query, "digest"), buf, 0);
 
    ast_xmpp_client_lock(client);
    iks_filter_add_rule(client->filter, xmpp_connect_hook, client, IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, client->mid, IKS_RULE_DONE);
    iks_insert_attrib(iq, "id", client->mid);
    ast_xmpp_increment_mid(client->mid);
    ast_xmpp_client_unlock(client);
 
    iks_insert_attrib(iq, "to", client->jid->server);
 
    ast_xmpp_client_send(client, iq);
 
    iks_delete(iq);
 
    xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATING);
 
    return 0;
}

References ast_log, ast_sha1_hash(), ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), buf, ast_xmpp_client::filter, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::mid, ast_xmpp_client::name, NULL, ast_xmpp_client_config::password, xmpp_client_change_state(), xmpp_connect_hook(), and XMPP_STATE_AUTHENTICATING.

Referenced by xmpp_client_authenticate().

xmpp_client_authenticate_sasl()

static int xmpp_client_authenticate_sasl ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we need to authenticate using SASL.

Definition at line 2692 of file res_xmpp.c.

{
    int features, len = strlen(client->jid->user) + strlen(cfg->password) + 3;
    iks *auth;
    char combined[len];
    char base64[(len + 2) * 4 / 3];
 
    if (strcmp(iks_name(node), "stream:features")) {
        /* Ignore anything beside stream features */
        return 0;
    }
 
    features = iks_stream_features(node);
 
    if ((features & IKS_STREAM_SASL_MD5) && !xmpp_is_secure(client)) {
        if (iks_start_sasl(client->parser, IKS_SASL_DIGEST_MD5, (char*)client->jid->user, (char*)cfg->password) != IKS_OK) {
            ast_log(LOG_ERROR, "Tried to authenticate client '%s' using SASL DIGEST-MD5 but could not\n", client->name);
            return -1;
        }
 
        xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATING);
        return 0;
    }
 
    /* Our only other available option is plain so if they don't support it, bail out now */
    if (!(features & IKS_STREAM_SASL_PLAIN)) {
        ast_log(LOG_ERROR, "Tried to authenticate client '%s' using SASL PLAIN but server does not support it\n", client->name);
        return -1;
    }
 
    if (!(auth = iks_new("auth"))) {
        ast_log(LOG_ERROR, "Could not allocate memory for SASL PLAIN authentication for client '%s'\n", client->name);
        return -1;
    }
 
    iks_insert_attrib(auth, "xmlns", IKS_NS_XMPP_SASL);
    if (!ast_strlen_zero(cfg->refresh_token)) {
        iks_insert_attrib(auth, "mechanism", "X-OAUTH2");
        iks_insert_attrib(auth, "auth:service", "oauth2");
        iks_insert_attrib(auth, "xmlns:auth", "http://www.google.com/talk/protocol/auth");
    } else {
        iks_insert_attrib(auth, "mechanism", "PLAIN");
    }
 
    if (strchr(client->jid->user, '/')) {
        char *user = ast_strdupa(client->jid->user);
 
        snprintf(combined, sizeof(combined), "%c%s%c%s", 0, strsep(&user, "/"), 0, cfg->password);
    } else {
        snprintf(combined, sizeof(combined), "%c%s%c%s", 0, client->jid->user, 0, cfg->password);
    }
 
    ast_base64encode(base64, (const unsigned char *) combined, len - 1, (len + 2) * 4 / 3);
    iks_insert_cdata(auth, base64, 0);
 
    ast_xmpp_client_send(client, auth);
 
    iks_delete(auth);
 
    xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATING);
 
    return 0;
}

References ast_base64encode(), ast_log, ast_strdupa, ast_strlen_zero(), ast_xmpp_client_send(), base64, ast_xmpp_client::jid, len(), LOG_ERROR, ast_xmpp_client::name, ast_xmpp_client::parser, ast_xmpp_client_config::password, ast_xmpp_client_config::refresh_token, strsep(), xmpp_client_change_state(), xmpp_is_secure(), and XMPP_STATE_AUTHENTICATING.

Referenced by xmpp_client_authenticate().

xmpp_client_authenticating()

static int xmpp_client_authenticating ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we are authenticating.

Definition at line 2763 of file res_xmpp.c.

{
    int features;
 
    if (!strcmp(iks_name(node), "success")) {
        /* Authentication was a success, yay! */
        xmpp_send_stream_header(client, cfg, client->jid->server);
 
        return 0;
    } else if (!strcmp(iks_name(node), "failure")) {
        /* Authentication was a bust, disconnect and reconnect later */
        return -1;
    } else if (strcmp(iks_name(node), "stream:features")) {
        /* Ignore any other responses */
        return 0;
    }
 
    features = iks_stream_features(node);
 
    if (features & IKS_STREAM_BIND) {
        iks *auth;
 
        if (!(auth = iks_make_resource_bind(client->jid))) {
            ast_log(LOG_ERROR, "Failed to allocate memory for stream bind on client '%s'\n", client->name);
            return -1;
        }
 
        ast_xmpp_client_lock(client);
        iks_insert_attrib(auth, "id", client->mid);
        ast_xmpp_increment_mid(client->mid);
        ast_xmpp_client_unlock(client);
        ast_xmpp_client_send(client, auth);
 
        iks_delete(auth);
 
        iks_filter_add_rule(client->filter, xmpp_connect_hook, client, IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_DONE);
    }
 
    if (features & IKS_STREAM_SESSION) {
        iks *auth;
 
        if (!(auth = iks_make_session())) {
            ast_log(LOG_ERROR, "Failed to allocate memory for stream session on client '%s'\n", client->name);
            return -1;
        }
 
        iks_insert_attrib(auth, "id", "auth");
        ast_xmpp_client_lock(client);
        ast_xmpp_increment_mid(client->mid);
        ast_xmpp_client_unlock(client);
        ast_xmpp_client_send(client, auth);
 
        iks_delete(auth);
 
        iks_filter_add_rule(client->filter, xmpp_connect_hook, client, IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, "auth", IKS_RULE_DONE);
    }
 
    return 0;
}

References ast_log, ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), ast_xmpp_client::filter, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::mid, ast_xmpp_client::name, xmpp_connect_hook(), and xmpp_send_stream_header().

xmpp_client_change_state()

static void xmpp_client_change_state ( struct ast_xmpp_client *  client, int  state  )

static

Internal function which changes the XMPP client state.

Definition at line 596 of file res_xmpp.c.

{
    if (state == client->state) {
        return;
    }
    client->state = state;
    if (client->state == XMPP_STATE_DISCONNECTED) {
        ast_endpoint_set_state(client->endpoint, AST_ENDPOINT_OFFLINE);
    } else if (client->state == XMPP_STATE_CONNECTED) {
        ast_endpoint_set_state(client->endpoint, AST_ENDPOINT_ONLINE);
    }
}

References AST_ENDPOINT_OFFLINE, AST_ENDPOINT_ONLINE, ast_endpoint_set_state(), ast_xmpp_client::endpoint, ast_xmpp_client::state, state, XMPP_STATE_CONNECTED, and XMPP_STATE_DISCONNECTED.

Referenced by ast_xmpp_client_disconnect(), xmpp_client_alloc(), xmpp_client_authenticate_digest(), xmpp_client_authenticate_sasl(), xmpp_client_reconnect(), xmpp_client_request_tls(), xmpp_client_requested_tls(), xmpp_component_authenticate(), xmpp_component_authenticating(), xmpp_connect_hook(), and xmpp_roster_hook().

xmpp_client_config_merge_buddies()

static int xmpp_client_config_merge_buddies ( void *  obj, void *  arg, int  flags  )

static

Definition at line 3808 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy1 = obj, *buddy2;
    struct ao2_container *buddies = arg;
 
    /* If the buddy does not already exist link it into the client buddies container */
    if (!(buddy2 = ao2_find(buddies, buddy1->id, OBJ_KEY))) {
        ao2_link(buddies, buddy1);
    } else {
        ao2_ref(buddy2, -1);
    }
 
    /* All buddies are unlinked from the configuration buddies container, always */
    return 1;
}

References ao2_find, ao2_link, ao2_ref, ast_xmpp_buddy::id, and OBJ_KEY.

Referenced by xmpp_client_config_post_apply().

xmpp_client_config_post_apply()

static int xmpp_client_config_post_apply ( void *  obj, void *  arg, int  flags  )

static

Definition at line 3863 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *cfg = obj;
    RAII_VAR(struct xmpp_config *, gcfg, ao2_global_obj_ref(globals), ao2_cleanup);
 
    /* Merge global options that have not been modified */
    ast_copy_flags(&cfg->flags, &gcfg->global->general, ~(cfg->mod_flags.flags) & (XMPP_AUTOPRUNE | XMPP_AUTOREGISTER | XMPP_AUTOACCEPT));
 
    /* Merge buddies as need be */
    ao2_callback(cfg->buddies, OBJ_MULTIPLE | OBJ_UNLINK, xmpp_client_config_merge_buddies, cfg->client->buddies);
 
    if (cfg->client->reconnect) {
        /* Disconnect the existing session since our role is changing, or we are starting up */
        ast_xmpp_client_disconnect(cfg->client);
 
        if (!(cfg->client->parser = iks_stream_new(ast_test_flag(&cfg->flags, XMPP_COMPONENT) ? "jabber:component:accept" : "jabber:client", cfg->client,
                               xmpp_action_hook))) {
            ast_log(LOG_ERROR, "Iksemel stream could not be created for client '%s' - client not active\n", cfg->name);
            return -1;
        }
 
        iks_set_log_hook(cfg->client->parser, xmpp_log_hook);
 
        /* Create a JID based on the given user, if no resource is given use the default */
        if (!strchr(cfg->user, '/') && !ast_test_flag(&cfg->flags, XMPP_COMPONENT)) {
            char resource[strlen(cfg->user) + strlen("/asterisk-xmpp") + 1];
 
            snprintf(resource, sizeof(resource), "%s/asterisk-xmpp", cfg->user);
            cfg->client->jid = iks_id_new(cfg->client->stack, resource);
        } else {
            cfg->client->jid = iks_id_new(cfg->client->stack, cfg->user);
        }
 
        if (!cfg->client->jid || (ast_strlen_zero(cfg->client->jid->user) && !ast_test_flag(&cfg->flags, XMPP_COMPONENT))) {
            ast_log(LOG_ERROR, "Jabber identity '%s' could not be created for client '%s' - client not active\n", cfg->user, cfg->name);
            return -1;
        }
 
        ast_pthread_create_background(&cfg->client->thread, NULL, xmpp_client_thread, cfg->client);
 
        cfg->client->reconnect = 0;
    } else if (cfg->client->state == XMPP_STATE_CONNECTED) {
        /* If this client is connected update their presence status since it may have changed */
        xmpp_client_set_presence(cfg->client, NULL, cfg->client->jid->full, cfg->status, cfg->statusmsg);
 
        /* Subscribe to the status of any newly added buddies */
        if (ast_test_flag(&cfg->flags, XMPP_AUTOREGISTER)) {
            ao2_callback(cfg->client->buddies, OBJ_NODATA | OBJ_MULTIPLE, xmpp_client_subscribe_user, cfg->client);
        }
    }
 
    return 0;
}

References ao2_callback, ao2_cleanup, ao2_global_obj_ref, ast_copy_flags, ast_log, ast_pthread_create_background, ast_strlen_zero(), ast_test_flag, ast_xmpp_client_disconnect(), ast_xmpp_client::buddies, ast_xmpp_client_config::buddies, ast_xmpp_client_config::client, ast_flags::flags, ast_xmpp_client_config::flags, globals, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client_config::mod_flags, ast_xmpp_client_config::name, NULL, OBJ_MULTIPLE, OBJ_NODATA, OBJ_UNLINK, ast_xmpp_client::parser, RAII_VAR, ast_xmpp_client::reconnect, ast_xmpp_client::stack, ast_xmpp_client::state, ast_xmpp_client_config::status, ast_xmpp_client_config::statusmsg, ast_xmpp_client::thread, ast_xmpp_client_config::user, xmpp_action_hook(), XMPP_AUTOACCEPT, XMPP_AUTOPRUNE, XMPP_AUTOREGISTER, xmpp_client_config_merge_buddies(), xmpp_client_set_presence(), xmpp_client_subscribe_user(), xmpp_client_thread(), XMPP_COMPONENT, xmpp_log_hook(), and XMPP_STATE_CONNECTED.

Referenced by xmpp_config_post_apply().

xmpp_client_create_buddy()

static struct ast_xmpp_buddy * xmpp_client_create_buddy ( struct ao2_container *  container, const char *  id  )

static

Internal function which creates a buddy on a client.

Definition at line 2163 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy;
 
    if (!(buddy = ao2_alloc(sizeof(*buddy), xmpp_buddy_destructor))) {
        return NULL;
    }
 
    buddy->resources = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
        RESOURCE_BUCKETS, xmpp_resource_hash, NULL, xmpp_resource_cmp);
    if (!buddy->resources) {
        ao2_ref(buddy, -1);
        return NULL;
    }
 
    ast_copy_string(buddy->id, id, sizeof(buddy->id));
 
    /* Assume we need to subscribe to get their presence until proven otherwise */
    buddy->subscribe = 1;
 
    ao2_link(container, buddy);
 
    return buddy;
}

References ao2_alloc, AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_hash, ao2_link, ao2_ref, ast_copy_string(), container, ast_xmpp_buddy::id, NULL, RESOURCE_BUCKETS, ast_xmpp_buddy::resources, ast_xmpp_buddy::subscribe, xmpp_buddy_destructor(), xmpp_resource_cmp(), and xmpp_resource_hash().

Referenced by client_buddy_handler(), xmpp_pak_s10n(), and xmpp_roster_hook().

xmpp_client_destructor()

static void xmpp_client_destructor ( void *  obj )

static

Destructor callback function for XMPP client.

Definition at line 551 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = obj;
    struct ast_xmpp_message *message;
 
    ast_xmpp_client_disconnect(client);
 
    ast_endpoint_shutdown(client->endpoint);
    client->endpoint = NULL;
 
    if (client->filter) {
        iks_filter_delete(client->filter);
    }
 
    if (client->stack) {
        iks_stack_delete(client->stack);
    }
 
    ao2_cleanup(client->buddies);
 
    while ((message = AST_LIST_REMOVE_HEAD(&client->messages, list))) {
        xmpp_message_destroy(message);
    }
    AST_LIST_HEAD_DESTROY(&client->messages);
}

References ao2_cleanup, ast_endpoint_shutdown(), AST_LIST_HEAD_DESTROY, AST_LIST_REMOVE_HEAD, ast_xmpp_client_disconnect(), ast_xmpp_client::buddies, ast_xmpp_client::endpoint, ast_xmpp_client::filter, ast_xmpp_message::list, ast_xmpp_message::message, ast_xmpp_client::messages, NULL, ast_xmpp_client::stack, and xmpp_message_destroy().

Referenced by xmpp_client_alloc().

xmpp_client_find_or_create()

static void * xmpp_client_find_or_create ( const char *  category )

static

Look up existing client or create a new one.

Definition at line 663 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, category))) {
        return xmpp_client_alloc(category);
    }
 
    ao2_ref(clientcfg->client, +1);
    return clientcfg->client;
}

References ao2_cleanup, ao2_global_obj_ref, ao2_ref, globals, NULL, RAII_VAR, xmpp_client_alloc(), and xmpp_config_find().

Referenced by ast_xmpp_client_config_alloc().

xmpp_client_receive()

static int xmpp_client_receive ( struct ast_xmpp_client *  client, unsigned int  timeout  )

static

Internal function which receives data from the XMPP client connection.

Definition at line 3648 of file res_xmpp.c.

{
    int len, ret, pos = 0, newbufpos = 0;
    char buf[NET_IO_BUF_SIZE - 1] = "";
    char newbuf[NET_IO_BUF_SIZE - 1] = "";
    unsigned char c;
 
    while (1) {
        len = xmpp_io_recv(client, buf, NET_IO_BUF_SIZE - 2, timeout);
        if (len < 0) return IKS_NET_RWERR;
        if (len == 0) return IKS_NET_EXPIRED;
        buf[len] = '\0';
 
        /* our iksemel parser won't work as expected if we feed
           it with XML packets that contain multiple whitespace
           characters between tags */
        while (pos < len) {
            c = buf[pos];
            /* if we stumble on the ending tag character,
               we skip any whitespace that follows it*/
            if (c == '>') {
                while (isspace(buf[pos+1])) {
                    pos++;
                }
            }
            newbuf[newbufpos] = c;
            newbufpos++;
            pos++;
        }
        pos = 0;
        newbufpos = 0;
 
        /* Log the message here, because iksemel's logHook is
           unaccessible */
        xmpp_log_hook(client, buf, len, 1);
 
        if(buf[0] == ' ') {
            ast_debug(1, "JABBER: Detected Google Keep Alive. "
                "Sending out Ping request for client '%s'\n", client->name);
            /* If we just send out the ping here then we will have socket
             * read errors because the socket will timeout */
            xmpp_ping_request(client, client->jid->server, client->jid->full);
        }
 
        /* let iksemel deal with the string length,
           and reset our buffer */
        ret = iks_parse(client->parser, newbuf, 0, 0);
        memset(newbuf, 0, sizeof(newbuf));
 
        switch (ret) {
        case IKS_NOMEM:
            ast_log(LOG_WARNING, "Parsing failure: Out of memory.\n");
            break;
        case IKS_BADXML:
            ast_log(LOG_WARNING, "Parsing failure: Invalid XML.\n");
            break;
        case IKS_HOOK:
            ast_log(LOG_WARNING, "Parsing failure: Hook returned an error.\n");
            break;
        }
        if (ret != IKS_OK) {
            return ret;
        }
        ast_debug(3, "XML parsing successful\n");
    }
    return IKS_OK;
}

References ast_debug, ast_log, buf, c, IKS_NET_EXPIRED, ast_xmpp_client::jid, len(), LOG_WARNING, ast_xmpp_client::name, NET_IO_BUF_SIZE, newbuf(), ast_xmpp_client::parser, xmpp_io_recv(), xmpp_log_hook(), and xmpp_ping_request().

Referenced by xmpp_client_thread().

xmpp_client_reconnect()

static int xmpp_client_reconnect ( struct ast_xmpp_client *  client )

static

Internal function used to reconnect an XMPP client to its server.

Definition at line 3564 of file res_xmpp.c.

{
    struct timeval tv = { .tv_sec = 5, .tv_usec = 0 };
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    int res = IKS_NET_NOCONN;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return -1;
    }
 
    ast_xmpp_client_disconnect(client);
 
    client->timeout = 50;
    iks_parser_reset(client->parser);
 
    if (!client->filter && !(client->filter = iks_filter_new())) {
        ast_log(LOG_ERROR, "Could not create IKS filter for client connection '%s'\n", client->name);
        return -1;
    }
 
    if (!ast_strlen_zero(clientcfg->refresh_token)) {
        ast_debug(2, "Obtaining OAuth access token for client '%s'\n", client->name);
        if (fetch_access_token(clientcfg)) {
            return -1;
        }
    }
 
    /* If it's a component connect to user otherwise connect to server */
    res = iks_connect_via(client->parser, S_OR(clientcfg->server, client->jid->server), clientcfg->port,
                  ast_test_flag(&clientcfg->flags, XMPP_COMPONENT) ? clientcfg->user : client->jid->server);
 
    /* Set socket timeout options */
    setsockopt(iks_fd(client->parser), SOL_SOCKET, SO_RCVTIMEO, (char *)&tv,sizeof(struct timeval));
 
    if (res == IKS_NET_NOCONN) {
        ast_log(LOG_ERROR, "No XMPP connection available when trying to connect client '%s'\n", client->name);
        return -1;
    } else if (res == IKS_NET_NODNS) {
        ast_log(LOG_ERROR, "No DNS available for XMPP connection when trying to connect client '%s'\n", client->name);
        return -1;
    }
 
    /* Depending on the configuration of the client we eiher jump to requesting TLS, or authenticating */
    xmpp_client_change_state(client, (ast_test_flag(&clientcfg->flags, XMPP_USETLS) ? XMPP_STATE_REQUEST_TLS : XMPP_STATE_AUTHENTICATE));
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, ast_debug, ast_log, ast_strlen_zero(), ast_test_flag, ast_xmpp_client_disconnect(), fetch_access_token(), ast_xmpp_client::filter, globals, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, NULL, ast_xmpp_client::parser, RAII_VAR, S_OR, ast_xmpp_client::timeout, xmpp_client_change_state(), XMPP_COMPONENT, xmpp_config_find(), XMPP_STATE_AUTHENTICATE, XMPP_STATE_REQUEST_TLS, and XMPP_USETLS.

Referenced by xmpp_client_thread().

xmpp_client_request_tls()

static int xmpp_client_request_tls ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we need to request TLS support.

Definition at line 2540 of file res_xmpp.c.

{
    /* If the client connection is already secure we can jump straight to authenticating */
    if (xmpp_is_secure(client)) {
        xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATE);
        return 0;
    }
 
#ifndef HAVE_OPENSSL
    ast_log(LOG_ERROR, "TLS connection for client '%s' cannot be established. OpenSSL is not available.\n", client->name);
    return -1;
#else
    if (iks_send_raw(client->parser, "<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>") == IKS_NET_TLSFAIL) {
        ast_log(LOG_ERROR, "TLS connection for client '%s' cannot be started.\n", client->name);
        return -1;
    }
 
    client->stream_flags |= TRY_SECURE;
 
    xmpp_client_change_state(client, XMPP_STATE_REQUESTED_TLS);
 
    return 0;
#endif
}

References ast_log, LOG_ERROR, ast_xmpp_client::name, ast_xmpp_client::parser, xmpp_client_change_state(), xmpp_is_secure(), XMPP_STATE_AUTHENTICATE, and XMPP_STATE_REQUESTED_TLS.

xmpp_client_requested_tls()

static int xmpp_client_requested_tls ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we receive a response to our TLS initiation request.

Definition at line 2584 of file res_xmpp.c.

{
#ifdef HAVE_OPENSSL
    int sock;
    long ssl_opts;
    char *err;
#endif
 
    if (!strcmp(iks_name(node), "success")) {
        /* TLS is up and working, we can move on to authenticating now */
        xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATE);
        return 0;
    } else if (!strcmp(iks_name(node), "failure")) {
        /* TLS negotiation was a failure, close it on down! */
        return -1;
    } else if (strcmp(iks_name(node), "proceed")) {
        /* Ignore any other responses */
        return 0;
    }
 
#ifndef HAVE_OPENSSL
    ast_log(LOG_ERROR, "Somehow we managed to try to start TLS negotiation on client '%s' without OpenSSL support, disconnecting\n", client->name);
    return -1;
#else
    client->ssl_method = SSLv23_method();
    if (!(client->ssl_context = SSL_CTX_new((SSL_METHOD *) client->ssl_method))) {
        goto failure;
    }
 
    ssl_opts = SSL_OP_NO_SSLv2 | SSL_OP_NO_SSLv3;
    SSL_CTX_set_options(client->ssl_context, ssl_opts);
 
    if (!(client->ssl_session = SSL_new(client->ssl_context))) {
        goto failure;
    }
 
    sock = iks_fd(client->parser);
    if (!SSL_set_fd(client->ssl_session, sock)) {
        goto failure;
    }
 
    if (SSL_connect(client->ssl_session) <= 0) {
        goto failure;
    }
 
    client->stream_flags &= (~TRY_SECURE);
    client->stream_flags |= SECURE;
 
    if (xmpp_send_stream_header(client, cfg, client->jid->server) != IKS_OK) {
        ast_log(LOG_ERROR, "TLS connection for client '%s' could not be established, failed to send stream header after negotiation\n",
            client->name);
        return -1;
    }
 
    ast_debug(1, "TLS connection for client '%s' started with server\n", client->name);
 
    xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATE);
 
    return 0;
 
failure:
    err = openssl_error_string();
    ast_log(LOG_ERROR, "TLS connection for client '%s' cannot be established. "
        "OpenSSL initialization failed: %s\n", client->name, err);
    ast_free(err);
    return -1;
#endif
}

References ast_debug, ast_free, ast_log, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, ast_xmpp_client::parser, xmpp_client_change_state(), xmpp_send_stream_header(), and XMPP_STATE_AUTHENTICATE.

xmpp_client_send_disco_info_request()

static int xmpp_client_send_disco_info_request ( struct ast_xmpp_client *  client, const char *  to, const char *  from  )

static

Helper function which sends a discovery information request to a user.

Definition at line 3192 of file res_xmpp.c.

{
    iks *iq, *query;
    int res;
 
    if (!(iq = iks_new("iq")) || !(query = iks_new("query"))) {
        iks_delete(iq);
        return -1;
    }
 
    iks_insert_attrib(iq, "type", "get");
    iks_insert_attrib(iq, "to", to);
    iks_insert_attrib(iq, "from", from);
    ast_xmpp_client_lock(client);
    iks_insert_attrib(iq, "id", client->mid);
    ast_xmpp_increment_mid(client->mid);
    ast_xmpp_client_unlock(client);
    iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#info");
    iks_insert_node(iq, query);
 
    res = ast_xmpp_client_send(client, iq);
 
    iks_delete(query);
    iks_delete(iq);
 
    return res;
}

References ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), and ast_xmpp_client::mid.

Referenced by xmpp_pak_presence().

xmpp_client_send_message()

static int xmpp_client_send_message ( struct ast_xmpp_client *  client, int  group, const char *  nick, const char *  address, const char *  message  )

static

Internal function used to send a message to a user or chatroom.

Definition at line 910 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    int res = 0;
    char from[XMPP_MAX_JIDLEN];
    iks *message_packet;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(message_packet = iks_make_msg(group ? IKS_TYPE_GROUPCHAT : IKS_TYPE_CHAT, address, message))) {
        return -1;
    }
 
    if (!ast_strlen_zero(nick) && ast_test_flag(&clientcfg->flags, XMPP_COMPONENT)) {
        snprintf(from, sizeof(from), "%s@%s/%s", nick, client->jid->full, nick);
    } else {
        snprintf(from, sizeof(from), "%s", client->jid->full);
    }
 
    iks_insert_attrib(message_packet, "from", from);
 
    res = ast_xmpp_client_send(client, message_packet);
 
    iks_delete(message_packet);
 
    return res;
}

References ao2_cleanup, ao2_global_obj_ref, ast_strlen_zero(), ast_test_flag, ast_xmpp_client_send(), globals, ast_xmpp_client::jid, ast_xmpp_client::name, NULL, RAII_VAR, XMPP_COMPONENT, xmpp_config_find(), and XMPP_MAX_JIDLEN.

Referenced by ast_xmpp_chatroom_send(), and ast_xmpp_client_send_message().

xmpp_client_send_raw_message()

static int xmpp_client_send_raw_message ( struct ast_xmpp_client *  client, const char *  message  )

static

Internal function which sends a raw message.

Definition at line 2489 of file res_xmpp.c.

{
    int ret;
 
    if (client->state == XMPP_STATE_DISCONNECTED) {
        /* iks_send_raw will crash without a connection */
        return IKS_NET_NOCONN;
    }
 
#ifdef HAVE_OPENSSL
    if (xmpp_is_secure(client)) {
        int len = strlen(message);
 
        ret = SSL_write(client->ssl_session, message, len);
        if (ret) {
            /* Log the message here, because iksemel's logHook is
               unaccessible */
            xmpp_log_hook(client, message, len, 0);
            return IKS_OK;
        }
    }
#endif
    /* If needed, data will be sent unencrypted, and logHook will
       be called inside iks_send_raw */
    ret = iks_send_raw(client->parser, message);
    if (ret != IKS_OK) {
        return ret;
    }
 
    return IKS_OK;
}

References len(), ast_xmpp_client::parser, ast_xmpp_client::state, xmpp_is_secure(), xmpp_log_hook(), and XMPP_STATE_DISCONNECTED.

Referenced by ast_xmpp_client_send(), xmpp_component_authenticate(), and xmpp_send_stream_header().

xmpp_client_service_discovery_get_hook()

static int xmpp_client_service_discovery_get_hook ( void *  data, ikspak *  pak  )

static

Hook function called when client receives a service discovery get message.

Definition at line 2343 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    iks *iq, *disco = NULL, *ident = NULL, *google = NULL, *jingle = NULL, *ice = NULL, *rtp = NULL, *audio = NULL, *video = NULL, *query = NULL;
 
    if (!(iq = iks_new("iq")) || !(query = iks_new("query")) || !(ident = iks_new("identity")) || !(disco = iks_new("feature")) ||
        !(google = iks_new("feature")) || !(jingle = iks_new("feature")) || !(ice = iks_new("feature")) || !(rtp = iks_new("feature")) ||
        !(audio = iks_new("feature")) || !(video = iks_new("feature"))) {
        ast_log(LOG_ERROR, "Could not allocate memory for responding to service discovery request from '%s' on client '%s'\n",
            pak->from->full, client->name);
        goto end;
    }
 
    iks_insert_attrib(iq, "from", client->jid->full);
 
    if (pak->from) {
        iks_insert_attrib(iq, "to", pak->from->full);
    }
 
    iks_insert_attrib(iq, "type", "result");
    iks_insert_attrib(iq, "id", pak->id);
    iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#info");
    iks_insert_attrib(ident, "category", "client");
    iks_insert_attrib(ident, "type", "pc");
    iks_insert_attrib(ident, "name", "asterisk");
    iks_insert_attrib(disco, "var", "http://jabber.org/protocol/disco#info");
 
    iks_insert_attrib(google, "var", "http://www.google.com/xmpp/protocol/voice/v1");
    iks_insert_attrib(jingle, "var", "urn:xmpp:jingle:1");
    iks_insert_attrib(ice, "var", "urn:xmpp:jingle:transports:ice-udp:1");
    iks_insert_attrib(rtp, "var", "urn:xmpp:jingle:apps:rtp:1");
    iks_insert_attrib(audio, "var", "urn:xmpp:jingle:apps:rtp:audio");
    iks_insert_attrib(video, "var", "urn:xmpp:jingle:apps:rtp:video");
    iks_insert_node(iq, query);
    iks_insert_node(query, ident);
    iks_insert_node(query, google);
    iks_insert_node(query, disco);
    iks_insert_node(query, jingle);
    iks_insert_node(query, ice);
    iks_insert_node(query, rtp);
    iks_insert_node(query, audio);
    iks_insert_node(query, video);
    ast_xmpp_client_send(client, iq);
 
end:
    iks_delete(query);
    iks_delete(video);
    iks_delete(audio);
    iks_delete(rtp);
    iks_delete(ice);
    iks_delete(jingle);
    iks_delete(google);
    iks_delete(ident);
    iks_delete(disco);
    iks_delete(iq);
 
    return IKS_FILTER_EAT;
}

References ast_log, ast_xmpp_client_send(), end, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, and NULL.

Referenced by xmpp_connect_hook().

xmpp_client_service_discovery_result_hook()

static int xmpp_client_service_discovery_result_hook ( void *  data, ikspak *  pak  )

static

Hook function called when client receives a service discovery result message.

Definition at line 2403 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    struct ast_xmpp_buddy *buddy;
    struct ast_xmpp_resource *resource;
 
    if (!(buddy = ao2_find(client->buddies, pak->from->partial, OBJ_KEY))) {
        return IKS_FILTER_EAT;
    }
 
    if (!(resource = ao2_callback(buddy->resources, 0, xmpp_resource_cmp, pak->from->resource))) {
        ao2_ref(buddy, -1);
        return IKS_FILTER_EAT;
    }
 
    ao2_lock(resource);
 
    if (iks_find_with_attrib(pak->query, "feature", "var", "urn:xmpp:jingle:1")) {
        resource->caps.jingle = 1;
    }
 
    ao2_unlock(resource);
 
    ao2_ref(resource, -1);
    ao2_ref(buddy, -1);
 
    return IKS_FILTER_EAT;
}

References ao2_callback, ao2_find, ao2_lock, ao2_ref, ao2_unlock, ast_xmpp_client::buddies, OBJ_KEY, ast_xmpp_resource::resource, ast_xmpp_buddy::resources, and xmpp_resource_cmp().

Referenced by xmpp_component_authenticating(), and xmpp_connect_hook().

xmpp_client_set_group_presence()

static int xmpp_client_set_group_presence ( struct ast_xmpp_client *  client, const char *  room, int  level, const char *  nick  )

static

Definition at line 974 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    int res = 0;
    iks *presence = NULL, *x = NULL;
    char from[XMPP_MAX_JIDLEN], roomid[XMPP_MAX_JIDLEN];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(presence = iks_make_pres(level, NULL)) || !(x = iks_new("x"))) {
        res = -1;
        goto done;
    }
 
    if (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT)) {
        snprintf(from, sizeof(from), "%s@%s/%s", nick, client->jid->full, nick);
        snprintf(roomid, sizeof(roomid), "%s/%s", room, nick);
    } else {
        snprintf(from, sizeof(from), "%s", client->jid->full);
        snprintf(roomid, sizeof(roomid), "%s/%s", room, S_OR(nick, client->jid->user));
    }
 
    iks_insert_attrib(presence, "to", roomid);
    iks_insert_attrib(presence, "from", from);
    iks_insert_attrib(x, "xmlns", "http://jabber.org/protocol/muc");
    iks_insert_node(presence, x);
 
    res = ast_xmpp_client_send(client, presence);
 
done:
    iks_delete(x);
    iks_delete(presence);
 
    return res;
}

References ao2_cleanup, ao2_global_obj_ref, ast_test_flag, ast_xmpp_client_send(), done, globals, ast_xmpp_client::jid, ast_xmpp_client::name, NULL, RAII_VAR, S_OR, XMPP_COMPONENT, xmpp_config_find(), and XMPP_MAX_JIDLEN.

Referenced by ast_xmpp_chatroom_join(), and ast_xmpp_chatroom_leave().

xmpp_client_set_presence()

static void xmpp_client_set_presence ( struct ast_xmpp_client *  client, const char *  to, const char *  from, int  level, const char *  desc  )

static

Internal function which changes the presence status of an XMPP client.

Definition at line 2305 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    iks *presence = NULL, *cnode = NULL, *priority = NULL;
    char priorityS[10];
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(presence = iks_make_pres(level, desc)) || !(cnode = iks_new("c")) || !(priority = iks_new("priority"))) {
        ast_log(LOG_ERROR, "Unable to allocate stanzas for setting presence status for client '%s'\n", client->name);
        goto done;
    }
 
    if (!ast_strlen_zero(to)) {
        iks_insert_attrib(presence, "to", to);
    }
 
    if (!ast_strlen_zero(from)) {
        iks_insert_attrib(presence, "from", from);
    }
 
    snprintf(priorityS, sizeof(priorityS), "%d", clientcfg->priority);
    iks_insert_cdata(priority, priorityS, strlen(priorityS));
    iks_insert_node(presence, priority);
    iks_insert_attrib(cnode, "node", "http://www.asterisk.org/xmpp/client/caps");
    iks_insert_attrib(cnode, "ver", "asterisk-xmpp");
    iks_insert_attrib(cnode, "ext", "voice-v1 video-v1 camera-v1");
    iks_insert_attrib(cnode, "xmlns", "http://jabber.org/protocol/caps");
    iks_insert_node(presence, cnode);
    ast_xmpp_client_send(client, presence);
 
done:
    iks_delete(cnode);
    iks_delete(presence);
    iks_delete(priority);
}

References ao2_cleanup, ao2_global_obj_ref, ast_log, ast_strlen_zero(), ast_xmpp_client_send(), desc, done, globals, LOG_ERROR, ast_xmpp_client::name, NULL, priority, RAII_VAR, and xmpp_config_find().

Referenced by xmpp_client_config_post_apply(), xmpp_connect_hook(), xmpp_pak_presence(), and xmpp_pak_s10n().

xmpp_client_subscribe_user()

static int xmpp_client_subscribe_user ( void *  obj, void *  arg, int  flags  )

static

Callback function which subscribes to a user if needed.

Definition at line 2226 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy = obj;
    struct ast_xmpp_client *client = arg;
 
    if (!buddy->subscribe) {
        return 0;
    }
 
    if (ast_xmpp_client_send(client, iks_make_s10n(IKS_TYPE_SUBSCRIBE, buddy->id,
                               "Greetings! I am the Asterisk Open Source PBX and I want to subscribe to your presence\n"))) {
        ast_log(LOG_WARNING, "Could not send subscription for '%s' on client '%s'\n",
            buddy->id, client->name);
    }
 
    buddy->subscribe = 0;
 
    return 0;
}

References ast_log, ast_xmpp_client_send(), ast_xmpp_buddy::id, LOG_WARNING, ast_xmpp_client::name, and ast_xmpp_buddy::subscribe.

Referenced by xmpp_client_config_post_apply(), and xmpp_roster_hook().

xmpp_client_thread()

static void * xmpp_client_thread ( void *  data )

static

XMPP client connection thread.

Definition at line 3728 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    int res = IKS_NET_RWERR;
    unsigned int sleep_time = 1;
 
    /* We only allow cancellation while sleeping */
    pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
 
    do {
        if (client->state == XMPP_STATE_DISCONNECTING) {
            ast_debug(1, "[%s] Disconnecting\n", client->name);
            break;
        }
 
        if (res == IKS_NET_RWERR || client->timeout == 0) {
            ast_debug(3, "[%s] Connecting\n", client->name);
            if ((res = xmpp_client_reconnect(client)) != IKS_OK) {
                sleep_with_backoff(&sleep_time);
                res = IKS_NET_RWERR;
            }
            continue;
        }
 
        res = xmpp_client_receive(client, 1);
 
        /* Decrease timeout if no data received, and delete
         * old messages globally */
        if (res == IKS_NET_EXPIRED) {
            client->timeout--;
        }
 
        if (res == IKS_HOOK) {
            ast_debug(2, "[%s] Got hook event\n", client->name);
        } else if (res == IKS_NET_TLSFAIL) {
            ast_log(LOG_ERROR, "[%s] TLS failure\n", client->name);
        } else if (!client->timeout && client->state == XMPP_STATE_CONNECTED) {
            RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
            RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
 
            if (cfg && cfg->clients) {
                clientcfg = xmpp_config_find(cfg->clients, client->name);
            }
 
            if (clientcfg && ast_test_flag(&clientcfg->flags, XMPP_KEEPALIVE)) {
                res = xmpp_ping_request(client, client->jid->server, client->jid->full);
            } else {
                res = IKS_OK;
            }
 
            if (res == IKS_OK) {
                client->timeout = 50;
            } else {
                ast_log(LOG_WARNING, "[%s] Network timeout\n", client->name);
            }
        } else if (res == IKS_NET_RWERR) {
            ast_log(LOG_WARNING, "[%s] Socket read error\n", client->name);
            ast_xmpp_client_disconnect(client);
            sleep_with_backoff(&sleep_time);
        } else if (res == IKS_NET_NOSOCK) {
            ast_log(LOG_WARNING, "[%s] No socket\n", client->name);
        } else if (res == IKS_NET_NOCONN) {
            ast_log(LOG_WARNING, "[%s] No connection\n", client->name);
        } else if (res == IKS_NET_NODNS) {
            ast_log(LOG_WARNING, "[%s] No DNS\n", client->name);
        } else if (res == IKS_NET_NOTSUPP) {
            ast_log(LOG_WARNING, "[%s] Not supported\n", client->name);
        } else if (res == IKS_NET_DROPPED) {
            ast_log(LOG_WARNING, "[%s] Dropped?\n", client->name);
        } else if (res == IKS_NET_UNKNOWN) {
            ast_debug(5, "[%s] Unknown\n", client->name);
        } else if (res == IKS_OK) {
            sleep_time = 1;
        }
 
    } while (1);
 
    return NULL;
}

References ao2_cleanup, ao2_global_obj_ref, ast_debug, ast_log, ast_test_flag, ast_xmpp_client_disconnect(), globals, IKS_NET_EXPIRED, ast_xmpp_client::jid, LOG_ERROR, LOG_WARNING, ast_xmpp_client::name, NULL, RAII_VAR, sleep_with_backoff(), ast_xmpp_client::state, ast_xmpp_client::timeout, xmpp_client_receive(), xmpp_client_reconnect(), xmpp_config_find(), XMPP_KEEPALIVE, xmpp_ping_request(), XMPP_STATE_CONNECTED, and XMPP_STATE_DISCONNECTING.

Referenced by xmpp_client_config_post_apply().

xmpp_client_unsubscribe_user()

static int xmpp_client_unsubscribe_user ( struct ast_xmpp_client *  client, const char *  user  )

static

Helper function which unsubscribes a user and removes them from the roster.

Definition at line 2189 of file res_xmpp.c.

{
    iks *iq, *query = NULL, *item = NULL;
 
    if (ast_xmpp_client_send(client, iks_make_s10n(IKS_TYPE_UNSUBSCRIBE, user,
                               "Goodbye. Your status is no longer required.\n"))) {
        return -1;
    }
 
    if (!(iq = iks_new("iq")) || !(query = iks_new("query")) || !(item = iks_new("item"))) {
        ast_log(LOG_WARNING, "Could not allocate memory for roster removal of '%s' from client '%s'\n",
            user, client->name);
        goto done;
    }
 
    iks_insert_attrib(iq, "from", client->jid->full);
    iks_insert_attrib(iq, "type", "set");
    iks_insert_attrib(query, "xmlns", "jabber:iq:roster");
    iks_insert_node(iq, query);
    iks_insert_attrib(item, "jid", user);
    iks_insert_attrib(item, "subscription", "remove");
    iks_insert_node(query, item);
 
    if (ast_xmpp_client_send(client, iq)) {
        ast_log(LOG_WARNING, "Could not send roster removal request of '%s' from client '%s'\n",
            user, client->name);
    }
 
done:
    iks_delete(item);
    iks_delete(query);
    iks_delete(iq);
 
    return 0;
}

References ast_log, ast_xmpp_client_send(), done, item, ast_xmpp_client::jid, LOG_WARNING, ast_xmpp_client::name, and NULL.

Referenced by xmpp_roster_hook().

xmpp_component_authenticate()

static int xmpp_component_authenticate ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we should authenticate as a component.

Definition at line 2824 of file res_xmpp.c.

{
    char secret[160], shasum[320], message[344];
    ikspak *pak = iks_packet(node);
 
    snprintf(secret, sizeof(secret), "%s%s", pak->id, cfg->password);
    ast_sha1_hash(shasum, secret);
    snprintf(message, sizeof(message), "<handshake>%s</handshake>", shasum);
 
    if (xmpp_client_send_raw_message(client, message) != IKS_OK) {
        ast_log(LOG_ERROR, "Unable to send handshake for component '%s'\n", client->name);
        return -1;
    }
 
    xmpp_client_change_state(client, XMPP_STATE_AUTHENTICATING);
 
    return 0;
}

References ast_log, ast_sha1_hash(), LOG_ERROR, ast_xmpp_client::name, ast_xmpp_client_config::password, xmpp_client_change_state(), xmpp_client_send_raw_message(), and XMPP_STATE_AUTHENTICATING.

xmpp_component_authenticating()

static int xmpp_component_authenticating ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, int  type, iks *  node  )

static

Internal function called when we authenticated as a component.

Definition at line 3090 of file res_xmpp.c.

{
    if (!strcmp(iks_name(node), "stream:features")) {
        return 0;
    }
 
    if (strcmp(iks_name(node), "handshake")) {
        ast_log(LOG_ERROR, "Failed to authenticate component '%s'\n", client->name);
        return -1;
    }
 
    iks_filter_add_rule(client->filter, xmpp_component_service_discovery_items_hook, client, IKS_RULE_NS, "http://jabber.org/protocol/disco#items", IKS_RULE_DONE);
 
    iks_filter_add_rule(client->filter, xmpp_component_service_discovery_get_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_GET, IKS_RULE_NS, "http://jabber.org/protocol/disco#info", IKS_RULE_DONE);
 
    /* This uses the client service discovery result hook on purpose, as the code is common between both */
    iks_filter_add_rule(client->filter, xmpp_client_service_discovery_result_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_NS, "http://jabber.org/protocol/disco#info", IKS_RULE_DONE);
 
    iks_filter_add_rule(client->filter, xmpp_component_register_get_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_GET, IKS_RULE_NS, "jabber:iq:register", IKS_RULE_DONE);
    iks_filter_add_rule(client->filter, xmpp_component_register_set_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_SET, IKS_RULE_NS, "jabber:iq:register", IKS_RULE_DONE);
 
    xmpp_client_change_state(client, XMPP_STATE_CONNECTED);
 
    return 0;
}

References ast_log, ast_xmpp_client::filter, LOG_ERROR, ast_xmpp_client::name, xmpp_client_change_state(), xmpp_client_service_discovery_result_hook(), xmpp_component_register_get_hook(), xmpp_component_register_set_hook(), xmpp_component_service_discovery_get_hook(), xmpp_component_service_discovery_items_hook(), and XMPP_STATE_CONNECTED.

xmpp_component_register_get_hook()

static int xmpp_component_register_get_hook ( void *  data, ikspak *  pak  )

static

Hook function called when the component is queried about registration.

Definition at line 2931 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    iks *iq = NULL, *query = NULL, *error = NULL, *notacceptable = NULL, *instructions = NULL;
    struct ast_xmpp_buddy *buddy;
    char *node;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(iq = iks_new("iq")) || !(query = iks_new("query")) || !(error = iks_new("error")) || !(notacceptable = iks_new("not-acceptable")) ||
        !(instructions = iks_new("instructions"))) {
        ast_log(LOG_ERROR, "Failed to allocate stanzas for register get response to '%s' on component '%s'\n",
            pak->from->partial, client->name);
        goto done;
    }
 
    iks_insert_attrib(iq, "from", clientcfg->user);
    iks_insert_attrib(iq, "to", pak->from->full);
    iks_insert_attrib(iq, "id", pak->id);
    iks_insert_attrib(iq, "type", "result");
    iks_insert_attrib(query, "xmlns", "jabber:iq:register");
    iks_insert_node(iq, query);
 
    if (!(buddy = ao2_find(client->buddies, pak->from->partial, OBJ_KEY))) {
        iks_insert_attrib(error, "code", "406");
        iks_insert_attrib(error, "type", "modify");
        iks_insert_attrib(notacceptable, "xmlns", "urn:ietf:params:xml:ns:xmpp-stanzas");
 
        iks_insert_node(iq, error);
        iks_insert_node(error, notacceptable);
 
        ast_log(LOG_ERROR, "Received register attempt from '%s' but buddy is not configured on component '%s'\n",
            pak->from->partial, client->name);
    } else if (!(node = iks_find_attrib(pak->query, "node"))) {
        iks_insert_cdata(instructions, "Welcome to Asterisk - the Open Source PBX.\n", 0);
        iks_insert_node(query, instructions);
        ao2_ref(buddy, -1);
    } else {
        ast_log(LOG_WARNING, "Received register get to component '%s' using unsupported node '%s' from '%s'\n",
            client->name, node, pak->from->partial);
        ao2_ref(buddy, -1);
        goto done;
    }
 
    if (ast_xmpp_client_send(client, iq)) {
        ast_log(LOG_WARNING, "Could not send response to '%s' for received register get on component '%s'\n",
            pak->from->partial, client->name);
    }
 
done:
    iks_delete(instructions);
    iks_delete(notacceptable);
    iks_delete(error);
    iks_delete(query);
    iks_delete(iq);
 
    return IKS_FILTER_EAT;
}

References ao2_cleanup, ao2_find, ao2_global_obj_ref, ao2_ref, ast_log, ast_xmpp_client_send(), ast_xmpp_client::buddies, done, error(), globals, LOG_ERROR, LOG_WARNING, ast_xmpp_client::name, NULL, OBJ_KEY, RAII_VAR, and xmpp_config_find().

Referenced by xmpp_component_authenticating().

xmpp_component_register_set_hook()

static int xmpp_component_register_set_hook ( void *  data, ikspak *  pak  )

static

Hook function called when someone registers to the component.

Definition at line 2992 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    iks *iq, *presence = NULL, *x = NULL;
 
    if (!(iq = iks_new("iq")) || !(presence = iks_new("presence")) || !(x = iks_new("x"))) {
        ast_log(LOG_ERROR, "Failed to allocate stanzas for register set response to '%s' on component '%s'\n",
            pak->from->partial, client->name);
        goto done;
    }
 
    iks_insert_attrib(iq, "from", client->jid->full);
    iks_insert_attrib(iq, "to", pak->from->full);
    iks_insert_attrib(iq, "id", pak->id);
    iks_insert_attrib(iq, "type", "result");
 
    if (ast_xmpp_client_send(client, iq)) {
        ast_log(LOG_WARNING, "Could not send response to '%s' for received register set on component '%s'\n",
            pak->from->partial, client->name);
        goto done;
    }
 
    iks_insert_attrib(presence, "from", client->jid->full);
    iks_insert_attrib(presence, "to", pak->from->partial);
    ast_xmpp_client_lock(client);
    iks_insert_attrib(presence, "id", client->mid);
    ast_xmpp_increment_mid(client->mid);
    ast_xmpp_client_unlock(client);
    iks_insert_attrib(presence, "type", "subscribe");
    iks_insert_attrib(x, "xmlns", "vcard-temp:x:update");
 
    iks_insert_node(presence, x);
 
    if (ast_xmpp_client_send(client, presence)) {
        ast_log(LOG_WARNING, "Could not send subscription to '%s' on component '%s'\n",
            pak->from->partial, client->name);
    }
 
done:
    iks_delete(x);
    iks_delete(presence);
    iks_delete(iq);
 
    return IKS_FILTER_EAT;
}

References ast_log, ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), done, ast_xmpp_client::jid, LOG_ERROR, LOG_WARNING, ast_xmpp_client::mid, ast_xmpp_client::name, and NULL.

Referenced by xmpp_component_authenticating().

xmpp_component_service_discovery_get_hook()

static int xmpp_component_service_discovery_get_hook ( void *  data, ikspak *  pak  )

static

Hook function called when component receives a service discovery get message.

Definition at line 2844 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    iks *iq = NULL, *query = NULL, *identity = NULL, *disco = NULL, *reg = NULL, *commands = NULL, *gateway = NULL;
    iks *version = NULL, *vcard = NULL, *search = NULL, *item = NULL;
    char *node;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(iq = iks_new("iq")) || !(query = iks_new("query")) || !(identity = iks_new("identity")) || !(disco = iks_new("feature")) ||
        !(reg = iks_new("feature")) || !(commands = iks_new("feature")) || !(gateway = iks_new("feature")) || !(version = iks_new("feature")) ||
        !(vcard = iks_new("feature")) || !(search = iks_new("search")) || !(item = iks_new("item"))) {
        ast_log(LOG_ERROR, "Failed to allocate stanzas for service discovery get response to '%s' on component '%s'\n",
            pak->from->partial, client->name);
        goto done;
    }
 
    iks_insert_attrib(iq, "from", clientcfg->user);
    iks_insert_attrib(iq, "to", pak->from->full);
    iks_insert_attrib(iq, "id", pak->id);
    iks_insert_attrib(iq, "type", "result");
 
    if (!(node = iks_find_attrib(pak->query, "node"))) {
        iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#info");
        iks_insert_attrib(identity, "category", "gateway");
        iks_insert_attrib(identity, "type", "pstn");
        iks_insert_attrib(identity, "name", "Asterisk The Open Source PBX");
        iks_insert_attrib(disco, "var", "http://jabber.org/protocol/disco");
        iks_insert_attrib(reg, "var", "jabber:iq:register");
        iks_insert_attrib(commands, "var", "http://jabber.org/protocol/commands");
        iks_insert_attrib(gateway, "var", "jabber:iq:gateway");
        iks_insert_attrib(version, "var", "jabber:iq:version");
        iks_insert_attrib(vcard, "var", "vcard-temp");
        iks_insert_attrib(search, "var", "jabber:iq:search");
 
        iks_insert_node(iq, query);
        iks_insert_node(query, identity);
        iks_insert_node(query, disco);
        iks_insert_node(query, reg);
        iks_insert_node(query, commands);
        iks_insert_node(query, gateway);
        iks_insert_node(query, version);
        iks_insert_node(query, vcard);
        iks_insert_node(query, search);
    } else if (!strcasecmp(node, "http://jabber.org/protocol/commands")) {
        iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#items");
        iks_insert_attrib(query, "node", "http://jabber.org/protocol/commands");
        iks_insert_attrib(item, "node", "confirmaccount");
        iks_insert_attrib(item, "name", "Confirm account");
        iks_insert_attrib(item, "jid", clientcfg->user);
 
        iks_insert_node(iq, query);
        iks_insert_node(query, item);
    } else if (!strcasecmp(node, "confirmaccount")) {
        iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#info");
        iks_insert_attrib(commands, "var", "http://jabber.org/protocol/commands");
 
        iks_insert_node(iq, query);
        iks_insert_node(query, commands);
    } else {
        ast_debug(3, "Unsupported service discovery info request received with node '%s' on component '%s'\n",
              node, client->name);
        goto done;
    }
 
    if (ast_xmpp_client_send(client, iq)) {
        ast_log(LOG_WARNING, "Could not send response to service discovery request on component '%s'\n",
            client->name);
    }
 
done:
    iks_delete(search);
    iks_delete(vcard);
    iks_delete(version);
    iks_delete(gateway);
    iks_delete(commands);
    iks_delete(reg);
    iks_delete(disco);
    iks_delete(identity);
    iks_delete(query);
    iks_delete(iq);
 
    return IKS_FILTER_EAT;
}

References ao2_cleanup, ao2_global_obj_ref, ast_debug, ast_log, ast_xmpp_client_send(), commands, done, globals, item, LOG_ERROR, LOG_WARNING, ast_xmpp_client::name, NULL, RAII_VAR, version, and xmpp_config_find().

Referenced by xmpp_component_authenticating().

xmpp_component_service_discovery_items_hook()

static int xmpp_component_service_discovery_items_hook ( void *  data, ikspak *  pak  )

static

Hook function called when we receive a service discovery items request.

Definition at line 3039 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    iks *iq = NULL, *query = NULL, *item = NULL, *feature = NULL;
    char *node;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(iq = iks_new("iq")) || !(query = iks_new("query")) || !(item = iks_new("item")) || !(feature = iks_new("feature"))) {
        ast_log(LOG_ERROR, "Failed to allocate stanzas for service discovery items response to '%s' on component '%s'\n",
            pak->from->partial, client->name);
        goto done;
    }
 
    iks_insert_attrib(iq, "from", clientcfg->user);
    iks_insert_attrib(iq, "to", pak->from->full);
    iks_insert_attrib(iq, "id", pak->id);
    iks_insert_attrib(iq, "type", "result");
    iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#items");
    iks_insert_node(iq, query);
 
    if (!(node = iks_find_attrib(pak->query, "node"))) {
        iks_insert_attrib(item, "node", "http://jabber.org/protocol/commands");
        iks_insert_attrib(item, "name", "Asterisk Commands");
        iks_insert_attrib(item, "jid", clientcfg->user);
 
        iks_insert_node(query, item);
    } else if (!strcasecmp(node, "http://jabber.org/protocol/commands")) {
        iks_insert_attrib(query, "node", "http://jabber.org/protocol/commands");
    } else {
        ast_log(LOG_WARNING, "Received service discovery items request to component '%s' using unsupported node '%s' from '%s'\n",
            client->name, node, pak->from->partial);
        goto done;
    }
 
    if (ast_xmpp_client_send(client, iq)) {
        ast_log(LOG_WARNING, "Could not send response to service discovery items request from '%s' on component '%s'\n",
            pak->from->partial, client->name);
    }
 
done:
    iks_delete(feature);
    iks_delete(item);
    iks_delete(query);
    iks_delete(iq);
 
    return IKS_FILTER_EAT;
}

References ao2_cleanup, ao2_global_obj_ref, ast_log, ast_xmpp_client_send(), done, globals, item, LOG_ERROR, LOG_WARNING, ast_xmpp_client::name, NULL, RAII_VAR, and xmpp_config_find().

Referenced by xmpp_component_authenticating().

xmpp_config_alloc()

static void * xmpp_config_alloc ( void  )

static

Allocator for XMPP configuration.

Definition at line 724 of file res_xmpp.c.

{
    struct xmpp_config *cfg;
 
    if (!(cfg = ao2_alloc(sizeof(*cfg), xmpp_config_destructor))) {
        return NULL;
    }
 
    if (!(cfg->global = ao2_alloc(sizeof(*cfg->global), NULL))) {
        goto error;
    }
 
    cfg->clients = ao2_container_alloc_list(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
        NULL, xmpp_config_cmp);
    if (!cfg->clients) {
        goto error;
    }
 
    return cfg;
error:
    ao2_ref(cfg, -1);
    return NULL;
}

References ao2_alloc, AO2_ALLOC_OPT_LOCK_MUTEX, ao2_container_alloc_list, ao2_ref, xmpp_config::clients, error(), xmpp_config::global, NULL, xmpp_config_cmp(), and xmpp_config_destructor().

xmpp_config_cmp()

static int xmpp_config_cmp ( void *  obj, void *  arg, int  flags  )

static

Comparator function for configuration.

Definition at line 716 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *one = obj, *two = arg;
    const char *match = (flags & OBJ_KEY) ? arg : two->name;
    return strcasecmp(one->name, match) ? 0 : (CMP_MATCH | CMP_STOP);
}

References CMP_MATCH, CMP_STOP, ast_xmpp_client_config::flags, match(), ast_xmpp_client_config::name, and OBJ_KEY.

Referenced by xmpp_config_alloc().

xmpp_config_destructor()

static void xmpp_config_destructor ( void *  obj )

static

Destructor for XMPP configuration.

Definition at line 708 of file res_xmpp.c.

{
    struct xmpp_config *cfg = obj;
    ao2_cleanup(cfg->global);
    ao2_cleanup(cfg->clients);
}

References ao2_cleanup, xmpp_config::clients, and xmpp_config::global.

Referenced by xmpp_config_alloc().

xmpp_config_find()

static void * xmpp_config_find ( struct ao2_container *  tmp_container, const char *  category  )

static

Find function for configuration.

Definition at line 657 of file res_xmpp.c.

{
    return ao2_find(tmp_container, category, OBJ_KEY);
}

References ao2_find, and OBJ_KEY.

Referenced by acf_jabberreceive_read(), acf_jabberstatus_read(), ast_xmpp_client_find(), delete_old_messages(), manager_jabber_send(), xmpp_action_hook(), xmpp_cli_create_collection(), xmpp_cli_create_leafnode(), xmpp_cli_delete_pubsub_node(), xmpp_cli_list_pubsub_nodes(), xmpp_cli_purge_pubsub_nodes(), xmpp_client_find_or_create(), xmpp_client_reconnect(), xmpp_client_send_message(), xmpp_client_set_group_presence(), xmpp_client_set_presence(), xmpp_client_thread(), xmpp_component_register_get_hook(), xmpp_component_service_discovery_get_hook(), xmpp_component_service_discovery_items_hook(), xmpp_config_prelink(), xmpp_connect_hook(), xmpp_init_event_distribution(), xmpp_join_exec(), xmpp_leave_exec(), xmpp_log_hook(), xmpp_pubsub_iq_create(), xmpp_roster_hook(), xmpp_send_cb(), xmpp_send_exec(), and xmpp_sendgroup_exec().

xmpp_config_post_apply()

static void xmpp_config_post_apply ( void  )

static

Definition at line 793 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
 
    ao2_callback(cfg->clients, OBJ_NODATA | OBJ_MULTIPLE, xmpp_client_config_post_apply, NULL);
}

References ao2_callback, ao2_cleanup, ao2_global_obj_ref, globals, NULL, OBJ_MULTIPLE, OBJ_NODATA, RAII_VAR, and xmpp_client_config_post_apply().

xmpp_config_prelink()

static int xmpp_config_prelink ( void *  newitem )

static

Definition at line 748 of file res_xmpp.c.

{
    struct ast_xmpp_client_config *clientcfg = newitem;
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, oldclientcfg, NULL, ao2_cleanup);
 
    if (ast_strlen_zero(clientcfg->user)) {
        ast_log(LOG_ERROR, "No user specified on client '%s'\n", clientcfg->name);
        return -1;
    } else if (ast_strlen_zero(clientcfg->password) && ast_strlen_zero(clientcfg->refresh_token)) {
        ast_log(LOG_ERROR, "No password or refresh_token specified on client '%s'\n", clientcfg->name);
        return -1;
    } else if (ast_strlen_zero(clientcfg->server)) {
        ast_log(LOG_ERROR, "No server specified on client '%s'\n", clientcfg->name);
        return -1;
    } else if (!ast_strlen_zero(clientcfg->refresh_token) &&
           (ast_strlen_zero(clientcfg->oauth_clientid) || ast_strlen_zero(clientcfg->oauth_secret))) {
        ast_log(LOG_ERROR, "No oauth_clientid or oauth_secret specified, so client '%s' can't be used\n", clientcfg->name);
        return -1;
    }
 
    /* If this is a new connection force a reconnect */
    if (!cfg || !cfg->clients || !(oldclientcfg = xmpp_config_find(cfg->clients, clientcfg->name))) {
        clientcfg->client->reconnect = 1;
        return 0;
    }
 
    /* If any configuration options are changing that would require reconnecting set the bit so we will do so if possible */
    if (strcmp(clientcfg->user, oldclientcfg->user) ||
        strcmp(clientcfg->password, oldclientcfg->password) ||
        strcmp(clientcfg->refresh_token, oldclientcfg->refresh_token) ||
        strcmp(clientcfg->oauth_clientid, oldclientcfg->oauth_clientid) ||
        strcmp(clientcfg->oauth_secret, oldclientcfg->oauth_secret) ||
        strcmp(clientcfg->server, oldclientcfg->server) ||
        (clientcfg->port != oldclientcfg->port) ||
        (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT) != ast_test_flag(&oldclientcfg->flags, XMPP_COMPONENT)) ||
        (clientcfg->priority != oldclientcfg->priority)) {
        clientcfg->client->reconnect = 1;
    } else {
        clientcfg->client->reconnect = 0;
    }
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, ast_log, ast_strlen_zero(), ast_test_flag, ast_xmpp_client_config::client, ast_xmpp_client_config::flags, globals, LOG_ERROR, ast_xmpp_client_config::name, NULL, ast_xmpp_client_config::oauth_clientid, ast_xmpp_client_config::oauth_secret, ast_xmpp_client_config::password, ast_xmpp_client_config::port, ast_xmpp_client_config::priority, RAII_VAR, ast_xmpp_client::reconnect, ast_xmpp_client_config::refresh_token, ast_xmpp_client_config::server, ast_xmpp_client_config::user, XMPP_COMPONENT, and xmpp_config_find().

xmpp_connect_hook()

static int xmpp_connect_hook ( void *  data, ikspak *  pak  )

static

Hook function called when client finishes authenticating with the server.

Definition at line 2433 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    iks *roster;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return -1;
    }
 
    client->jid = (iks_find_cdata(pak->query, "jid")) ? iks_id_new(client->stack, iks_find_cdata(pak->query, "jid")) : client->jid;
 
    if (ast_test_flag(&clientcfg->flags, XMPP_DISTRIBUTE_EVENTS)) {
        xmpp_init_event_distribution(client);
    }
 
    if (!(roster = iks_make_iq(IKS_TYPE_GET, IKS_NS_ROSTER))) {
        ast_log(LOG_ERROR, "Unable to allocate memory for roster request for client '%s'\n", client->name);
        return -1;
    }
 
    iks_filter_add_rule(client->filter, xmpp_client_service_discovery_get_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_GET, IKS_RULE_NS, "http://jabber.org/protocol/disco#info", IKS_RULE_DONE);
    iks_filter_add_rule(client->filter, xmpp_client_service_discovery_result_hook, client, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_NS, "http://jabber.org/protocol/disco#info", IKS_RULE_DONE);
 
    iks_insert_attrib(roster, "id", "roster");
    ast_xmpp_client_send(client, roster);
 
    iks_filter_remove_hook(client->filter, xmpp_connect_hook);
    iks_filter_add_rule(client->filter, xmpp_roster_hook, client, IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, "roster", IKS_RULE_DONE);
 
    xmpp_client_set_presence(client, NULL, client->jid->full, clientcfg->status, clientcfg->statusmsg);
    xmpp_client_change_state(client, XMPP_STATE_ROSTER);
 
    return IKS_FILTER_EAT;
}

References ao2_cleanup, ao2_global_obj_ref, ast_log, ast_test_flag, ast_xmpp_client_send(), ast_xmpp_client::filter, globals, if(), ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, NULL, RAII_VAR, ast_xmpp_client::stack, xmpp_client_change_state(), xmpp_client_service_discovery_get_hook(), xmpp_client_service_discovery_result_hook(), xmpp_client_set_presence(), xmpp_config_find(), xmpp_connect_hook(), XMPP_DISTRIBUTE_EVENTS, xmpp_init_event_distribution(), xmpp_roster_hook(), and XMPP_STATE_ROSTER.

Referenced by xmpp_client_authenticate_digest(), xmpp_client_authenticating(), and xmpp_connect_hook().

xmpp_do_set_debug()

static char * xmpp_do_set_debug ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 4300 of file res_xmpp.c.

{
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp set debug {on|off}";
        e->usage =
            "Usage: xmpp set debug {on|off}\n"
            "       Enables/disables dumping of XMPP/Jabber packets for debugging purposes.\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (a->argc != e->args) {
        return CLI_SHOWUSAGE;
    }
 
    if (!strncasecmp(a->argv[e->args - 1], "on", 2)) {
        debug = 1;
        ast_cli(a->fd, "XMPP Debugging Enabled.\n");
        return CLI_SUCCESS;
    } else if (!strncasecmp(a->argv[e->args - 1], "off", 3)) {
        debug = 0;
        ast_cli(a->fd, "XMPP Debugging Disabled.\n");
        return CLI_SUCCESS;
    }
    return CLI_SHOWUSAGE; /* defaults to invalid */
}

References a, ast_cli_entry::args, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, debug, NULL, and ast_cli_entry::usage.

xmpp_init_event_distribution()

static void xmpp_init_event_distribution ( struct ast_xmpp_client *  client )

static

Initialize collections for event distribution.

Parameters

client

the configured XMPP client we use to connect to a XMPP server

Definition at line 1583 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    RAII_VAR(struct ao2_container *, cached, NULL, ao2_cleanup);
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return;
    }
 
    xmpp_pubsub_unsubscribe(client, "device_state");
    xmpp_pubsub_unsubscribe(client, "message_waiting");
 
    if (!(client->mwi_sub = stasis_subscribe_pool(ast_mwi_topic_all(), xmpp_pubsub_mwi_cb, client))) {
        return;
    }
    stasis_subscription_accept_message_type(client->mwi_sub, ast_mwi_state_type());
    stasis_subscription_set_filter(client->mwi_sub, STASIS_SUBSCRIPTION_FILTER_SELECTIVE);
 
    if (!(client->device_state_sub = stasis_subscribe(ast_device_state_topic_all(), xmpp_pubsub_devstate_cb, client))) {
        client->mwi_sub = stasis_unsubscribe(client->mwi_sub);
        return;
    }
    stasis_subscription_accept_message_type(client->device_state_sub, ast_device_state_message_type());
    stasis_subscription_set_filter(client->device_state_sub, STASIS_SUBSCRIPTION_FILTER_SELECTIVE);
 
    cached = stasis_cache_dump(ast_device_state_cache(), NULL);
    ao2_callback(cached, OBJ_NODATA, cached_devstate_cb, client);
 
    xmpp_pubsub_subscribe(client, "device_state");
    xmpp_pubsub_subscribe(client, "message_waiting");
    iks_filter_add_rule(client->filter, xmpp_pubsub_handle_event, client, IKS_RULE_TYPE,
                IKS_PAK_MESSAGE, IKS_RULE_FROM, clientcfg->pubsubnode, IKS_RULE_DONE);
    iks_filter_add_rule(client->filter, xmpp_pubsub_handle_error, client, IKS_RULE_TYPE,
                IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_ERROR, IKS_RULE_DONE);
 
}

References ao2_callback, ao2_cleanup, ao2_global_obj_ref, ast_device_state_cache(), ast_device_state_message_type(), ast_device_state_topic_all(), ast_mwi_state_type(), ast_mwi_topic_all(), cached_devstate_cb(), ast_xmpp_client::device_state_sub, ast_xmpp_client::filter, globals, ast_xmpp_client::mwi_sub, ast_xmpp_client::name, NULL, OBJ_NODATA, RAII_VAR, stasis_cache_dump(), stasis_subscribe, stasis_subscribe_pool, stasis_subscription_accept_message_type(), STASIS_SUBSCRIPTION_FILTER_SELECTIVE, stasis_subscription_set_filter(), stasis_unsubscribe(), xmpp_config_find(), xmpp_pubsub_devstate_cb(), xmpp_pubsub_handle_error(), xmpp_pubsub_handle_event(), xmpp_pubsub_mwi_cb(), xmpp_pubsub_subscribe(), and xmpp_pubsub_unsubscribe().

Referenced by xmpp_connect_hook().

xmpp_io_recv()

static int xmpp_io_recv ( struct ast_xmpp_client *  client, char *  buffer, size_t  buf_len, int  timeout  )

static

Internal function which polls on an XMPP client and receives data.

Definition at line 3614 of file res_xmpp.c.

{
    struct pollfd pfd = { .events = POLLIN };
    int len, res;
 
#ifdef HAVE_OPENSSL
    if (xmpp_is_secure(client)) {
        pfd.fd = SSL_get_fd(client->ssl_session);
        if (pfd.fd < 0) {
            return -1;
        }
    } else
#endif /* HAVE_OPENSSL */
        pfd.fd = iks_fd(client->parser);
 
    res = ast_poll(&pfd, 1, timeout > 0 ? timeout * 1000 : -1);
    if (res > 0) {
#ifdef HAVE_OPENSSL
        if (xmpp_is_secure(client)) {
            len = SSL_read(client->ssl_session, buffer, buf_len);
        } else
#endif /* HAVE_OPENSSL */
            len = recv(pfd.fd, buffer, buf_len, 0);
 
        if (len > 0) {
            return len;
        } else if (len <= 0) {
            return -1;
        }
    }
    return res;
}

References ast_poll, len(), ast_xmpp_client::parser, and xmpp_is_secure().

Referenced by xmpp_client_receive().

xmpp_is_secure()

static int xmpp_is_secure ( struct ast_xmpp_client *  client )

static

Helper function which returns whether an XMPP client connection is secure or not.

Definition at line 872 of file res_xmpp.c.

{
#ifdef HAVE_OPENSSL
    return client->stream_flags & SECURE;
#else
    return 0;
#endif
}

Referenced by xmpp_client_authenticate_sasl(), xmpp_client_request_tls(), xmpp_client_send_raw_message(), and xmpp_io_recv().

xmpp_join_exec()

static int xmpp_join_exec ( struct ast_channel *  chan, const char *  data  )

static

Application to join a chat room.

Parameters

chan	ast_channel
data	Data is sender|jid|nickname.

Return values

0	success
-1	error

Definition at line 1718 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *s, nick[XMPP_MAX_RESJIDLEN];
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(sender);
                 AST_APP_ARG(jid);
                 AST_APP_ARG(nick);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,jid[,nickname])\n", app_ajijoin);
        return -1;
    }
    s = ast_strdupa(data);
 
    AST_STANDARD_APP_ARGS(args, s);
    if (args.argc < 2 || args.argc > 3) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,jid[,nickname])\n", app_ajijoin);
        return -1;
    }
 
    if (strchr(args.jid, '/')) {
        ast_log(LOG_ERROR, "Invalid room name : resource must not be appended\n");
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.sender))) {
        ast_log(LOG_ERROR, "Could not find sender connection: '%s'\n", args.sender);
        return -1;
    }
 
    if (ast_strlen_zero(args.nick)) {
        if (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT)) {
            snprintf(nick, sizeof(nick), "asterisk");
        } else {
            snprintf(nick, sizeof(nick), "%s", clientcfg->client->jid->user);
        }
    } else {
        snprintf(nick, sizeof(nick), "%s", args.nick);
    }
 
    if (!ast_strlen_zero(args.jid) && strchr(args.jid, '@')) {
        ast_xmpp_chatroom_join(clientcfg->client, args.jid, nick);
    } else {
        ast_log(LOG_ERROR, "Problem with specified jid of '%s'\n", args.jid);
    }
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, app_ajijoin, args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_test_flag, ast_xmpp_chatroom_join(), globals, LOG_ERROR, NULL, RAII_VAR, XMPP_COMPONENT, xmpp_config_find(), and XMPP_MAX_RESJIDLEN.

Referenced by load_module().

xmpp_leave_exec()

static int xmpp_leave_exec ( struct ast_channel *  chan, const char *  data  )

static

Application to leave a chat room.

Parameters

chan	ast_channel
data	Data is sender|jid|nickname.

Return values

0	success
-1	error

Definition at line 1777 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *s, nick[XMPP_MAX_RESJIDLEN];
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(sender);
                 AST_APP_ARG(jid);
                 AST_APP_ARG(nick);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,jid[,nickname])\n", app_ajileave);
        return -1;
    }
    s = ast_strdupa(data);
 
    AST_STANDARD_APP_ARGS(args, s);
    if (args.argc < 2 || args.argc > 3) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,jid[,nickname])\n", app_ajileave);
        return -1;
    }
 
    if (strchr(args.jid, '/')) {
        ast_log(LOG_ERROR, "Invalid room name, resource must not be appended\n");
        return -1;
    }
 
    if (ast_strlen_zero(args.jid) || !strchr(args.jid, '@')) {
        ast_log(LOG_ERROR, "No jabber ID specified\n");
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.sender))) {
        ast_log(LOG_ERROR, "Could not find sender connection: '%s'\n", args.sender);
        return -1;
    }
 
    if (ast_strlen_zero(args.nick)) {
        if (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT)) {
            snprintf(nick, sizeof(nick), "asterisk");
        } else {
            snprintf(nick, sizeof(nick), "%s", clientcfg->client->jid->user);
        }
    } else {
        snprintf(nick, sizeof(nick), "%s", args.nick);
    }
 
    ast_xmpp_chatroom_leave(clientcfg->client, args.jid, nick);
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, app_ajileave, args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_test_flag, ast_xmpp_chatroom_leave(), globals, LOG_ERROR, NULL, RAII_VAR, XMPP_COMPONENT, xmpp_config_find(), and XMPP_MAX_RESJIDLEN.

Referenced by load_module().

xmpp_log_hook()

static void xmpp_log_hook ( void *  data, const char *  xmpp, size_t  size, int  incoming  )

static

Logging hook function.

Definition at line 2471 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
 
    if (!debug && (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) || !ast_test_flag(&clientcfg->flags, XMPP_DEBUG))) {
        return;
    }
 
    if (!incoming) {
        ast_verbose("\n<--- XMPP sent to '%s' --->\n%s\n<------------->\n", client->name, xmpp);
    } else {
        ast_verbose("\n<--- XMPP received from '%s' --->\n%s\n<------------->\n", client->name, xmpp);
    }
}

References ao2_cleanup, ao2_global_obj_ref, ast_test_flag, ast_verbose(), debug, globals, ast_xmpp_client::name, NULL, RAII_VAR, xmpp_config_find(), and XMPP_DEBUG.

Referenced by xmpp_client_config_post_apply(), xmpp_client_receive(), and xmpp_client_send_raw_message().

xmpp_message_destroy()

static void xmpp_message_destroy ( struct ast_xmpp_message *  message )

static

Destroy function for XMPP messages.

Definition at line 538 of file res_xmpp.c.

{
    if (message->from) {
        ast_free(message->from);
    }
    if (message->message) {
        ast_free(message->message);
    }
 
    ast_free(message);
}

References ast_free.

Referenced by acf_jabberreceive_read(), delete_old_messages(), and xmpp_client_destructor().

xmpp_pak_message()

static int xmpp_pak_message ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, iks *  node, ikspak *  pak  )

static

Internal function called when a message is received.

Definition at line 3117 of file res_xmpp.c.

{
    struct ast_xmpp_message *message;
    char *body;
    int deleted = 0;
 
    ast_debug(3, "XMPP client '%s' received a message\n", client->name);
 
    if (!(body = iks_find_cdata(pak->x, "body"))) {
        /* Message contains no body, ignore it. */
        return 0;
    }
 
    if (!(message = ast_calloc(1, sizeof(*message)))) {
        return -1;
    }
 
    message->arrived = ast_tvnow();
 
    message->message = ast_strdup(body);
 
    ast_copy_string(message->id, S_OR(pak->id, ""), sizeof(message->id));
    message->from = !ast_strlen_zero(pak->from->full) ? ast_strdup(pak->from->full) : NULL;
 
    if (ast_test_flag(&cfg->flags, XMPP_SEND_TO_DIALPLAN)) {
        struct ast_msg *msg;
        struct ast_xmpp_buddy *buddy;
 
        if ((msg = ast_msg_alloc())) {
            int res;
 
            ast_xmpp_client_lock(client);
 
            buddy = ao2_find(client->buddies, pak->from->partial, OBJ_KEY | OBJ_NOLOCK);
 
            res = ast_msg_set_to(msg, "xmpp:%s", cfg->user);
            res |= ast_msg_set_from(msg, "xmpp:%s", message->from);
            res |= ast_msg_set_body(msg, "%s", message->message);
            res |= ast_msg_set_context(msg, "%s", cfg->context);
            res |= ast_msg_set_tech(msg, "%s", "XMPP");
            res |= ast_msg_set_endpoint(msg, "%s", client->name);
 
            if (buddy) {
                res |= ast_msg_set_var(msg, "XMPP_BUDDY", buddy->id);
            }
 
            ao2_cleanup(buddy);
 
            ast_xmpp_client_unlock(client);
 
            if (res) {
                ast_msg_destroy(msg);
            } else {
                ast_msg_queue(msg);
            }
        }
    }
 
    /* remove old messages received from this JID
     * and insert received message */
    deleted = delete_old_messages(client, pak->from->partial);
    ast_debug(3, "Deleted %d messages for client %s from JID %s\n", deleted, client->name, pak->from->partial);
    AST_LIST_LOCK(&client->messages);
    AST_LIST_INSERT_HEAD(&client->messages, message, list);
    AST_LIST_UNLOCK(&client->messages);
 
    /* wake up threads waiting for messages */
    ast_mutex_lock(&messagelock);
    ast_cond_broadcast(&message_received_condition);
    ast_mutex_unlock(&messagelock);
 
    return 0;
}

References ao2_cleanup, ao2_find, ast_calloc, ast_cond_broadcast, ast_copy_string(), ast_debug, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, ast_msg_alloc(), ast_msg_destroy(), ast_msg_queue(), ast_msg_set_body(), ast_msg_set_context(), ast_msg_set_endpoint(), ast_msg_set_from(), ast_msg_set_tech(), ast_msg_set_to(), ast_msg_set_var(), ast_mutex_lock, ast_mutex_unlock, ast_strdup, ast_strlen_zero(), ast_test_flag, ast_tvnow(), ast_xmpp_client_lock(), ast_xmpp_client_unlock(), ast_xmpp_client::buddies, ast_xmpp_client_config::context, delete_old_messages(), ast_xmpp_client_config::flags, ast_xmpp_buddy::id, ast_xmpp_message::message, message_received_condition, messagelock, ast_xmpp_client::messages, ast_xmpp_client::name, NULL, OBJ_KEY, OBJ_NOLOCK, S_OR, ast_xmpp_client_config::user, and XMPP_SEND_TO_DIALPLAN.

xmpp_pak_presence()

static int xmpp_pak_presence ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, iks *  node, ikspak *  pak  )

static

Internal function called when a presence message is received.

Definition at line 3263 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy;
    struct ast_xmpp_resource *resource;
    char *type = iks_find_attrib(pak->x, "type");
    int status = pak->show ? pak->show : STATUS_DISAPPEAR;
    enum ast_device_state state = AST_DEVICE_UNAVAILABLE;
 
    /* If this is a component presence probe request answer immediately with our presence status */
    if (ast_test_flag(&cfg->flags, XMPP_COMPONENT) && !ast_strlen_zero(type) && !strcasecmp(type, "probe")) {
        xmpp_client_set_presence(client, pak->from->full, iks_find_attrib(pak->x, "to"), cfg->status, cfg->statusmsg);
    }
 
    /* If no resource is available this is a general buddy presence update, which we will ignore */
    if (!pak->from->resource) {
        return 0;
    }
 
    if (!(buddy = ao2_find(client->buddies, pak->from->partial, OBJ_KEY))) {
        /* Only output the message if it is not about us */
        if (strcmp(client->jid->partial, pak->from->partial)) {
            ast_log(LOG_WARNING, "Received presence information about '%s' despite not having them in roster on client '%s'\n",
                pak->from->partial, client->name);
        }
        return 0;
    }
 
    ao2_lock(buddy->resources);
 
    if (!(resource = ao2_callback(buddy->resources, OBJ_NOLOCK, xmpp_resource_cmp, pak->from->resource))) {
        /* Only create the new resource if it is not going away - in reality this should not happen */
        if (status != STATUS_DISAPPEAR) {
            if (!(resource = ao2_alloc(sizeof(*resource), xmpp_resource_destructor))) {
                ast_log(LOG_ERROR, "Could not allocate resource object for resource '%s' of buddy '%s' on client '%s'\n",
                    pak->from->resource, buddy->id, client->name);
                ao2_unlock(buddy->resources);
                ao2_ref(buddy, -1);
                return 0;
            }
 
            ast_copy_string(resource->resource, pak->from->resource, sizeof(resource->resource));
        }
    } else {
        /* We unlink the resource in case the priority changes or in case they are going away */
        ao2_unlink_flags(buddy->resources, resource, OBJ_NOLOCK);
    }
 
    /* Only update the resource and add it back in if it is not going away */
    if (resource && (status != STATUS_DISAPPEAR)) {
        char *node, *ver;
 
        /* Try to get the XMPP spec node, and fall back to Google if not found */
        if (!(node = iks_find_attrib(iks_find(pak->x, "c"), "node"))) {
            node = iks_find_attrib(iks_find(pak->x, "caps:c"), "node");
        }
 
        if (!(ver = iks_find_attrib(iks_find(pak->x, "c"), "ver"))) {
            ver = iks_find_attrib(iks_find(pak->x, "caps:c"), "ver");
        }
 
        if (resource->description) {
            ast_free(resource->description);
        }
 
        if ((node && strcmp(resource->caps.node, node)) || (ver && strcmp(resource->caps.version, ver))) {
            /* For interoperability reasons, proceed even if the resource fails to provide node or version */
            if (node) {
                ast_copy_string(resource->caps.node, node, sizeof(resource->caps.node));
            }
            if (ver) {
                ast_copy_string(resource->caps.version, ver, sizeof(resource->caps.version));
            }
 
            /* Google Talk places the capabilities information directly in presence, so see if it is there */
            if (iks_find_with_attrib(pak->x, "c", "node", "http://www.google.com/xmpp/client/caps") ||
                iks_find_with_attrib(pak->x, "caps:c", "node", "http://www.google.com/xmpp/client/caps") ||
                iks_find_with_attrib(pak->x, "c", "node", "http://www.android.com/gtalk/client/caps") ||
                iks_find_with_attrib(pak->x, "caps:c", "node", "http://www.android.com/gtalk/client/caps") ||
                iks_find_with_attrib(pak->x, "c", "node", "http://mail.google.com/xmpp/client/caps") ||
                iks_find_with_attrib(pak->x, "caps:c", "node", "http://mail.google.com/xmpp/client/caps")) {
                resource->caps.google = 1;
            }
 
            /* To discover if the buddy supports Jingle we need to query, so do so */
            if (xmpp_client_send_disco_info_request(client, pak->from->full, client->jid->full)) {
                ast_log(LOG_WARNING, "Could not send discovery information request to resource '%s' of buddy '%s' on client '%s', capabilities may be incomplete\n", resource->resource, buddy->id, client->name);
            }
        }
 
        resource->status = status;
        resource->description = ast_strdup(iks_find_cdata(pak->x, "status"));
        resource->priority = atoi((iks_find_cdata(pak->x, "priority")) ? iks_find_cdata(pak->x, "priority") : "0");
 
        ao2_link_flags(buddy->resources, resource, OBJ_NOLOCK);
 
        manager_event(EVENT_FLAG_USER, "JabberStatus",
                  "Account: %s\r\nJID: %s\r\nResource: %s\r\nStatus: %d\r\nPriority: %d"
                  "\r\nDescription: %s\r\n",
                  client->name, pak->from->partial, resource->resource, resource->status,
                  resource->priority, S_OR(resource->description, ""));
 
        ao2_ref(resource, -1);
    } else {
        /* This will get hit by presence coming in for an unknown resource, and also when a resource goes away */
        if (resource) {
            ao2_ref(resource, -1);
        }
 
        manager_event(EVENT_FLAG_USER, "JabberStatus",
                  "Account: %s\r\nJID: %s\r\nStatus: %u\r\n",
                  client->name, pak->from->partial, pak->show ? pak->show : IKS_SHOW_UNAVAILABLE);
    }
 
    /* Determine if at least one resource is available for device state purposes */
    if ((resource = ao2_callback(buddy->resources, OBJ_NOLOCK, xmpp_resource_is_available, NULL))) {
        state = AST_DEVICE_NOT_INUSE;
        ao2_ref(resource, -1);
    }
 
    ao2_unlock(buddy->resources);
 
    ao2_ref(buddy, -1);
 
    ast_devstate_changed(state, AST_DEVSTATE_CACHABLE, "XMPP/%s/%s", client->name, pak->from->partial);
 
    return 0;
}

References ao2_alloc, ao2_callback, ao2_find, ao2_link_flags, ao2_lock, ao2_ref, ao2_unlink_flags, ao2_unlock, ast_copy_string(), AST_DEVICE_NOT_INUSE, AST_DEVICE_UNAVAILABLE, AST_DEVSTATE_CACHABLE, ast_devstate_changed(), ast_free, ast_log, ast_strdup, ast_strlen_zero(), ast_test_flag, ast_xmpp_client::buddies, EVENT_FLAG_USER, ast_xmpp_client_config::flags, ast_xmpp_buddy::id, ast_xmpp_client::jid, LOG_ERROR, LOG_WARNING, manager_event, ast_xmpp_client::name, NULL, OBJ_KEY, OBJ_NOLOCK, ast_xmpp_resource::resource, ast_xmpp_buddy::resources, S_OR, status, ast_xmpp_client_config::status, STATUS_DISAPPEAR, ast_xmpp_client_config::statusmsg, type, xmpp_client_send_disco_info_request(), xmpp_client_set_presence(), XMPP_COMPONENT, xmpp_resource_cmp(), xmpp_resource_destructor(), and xmpp_resource_is_available().

xmpp_pak_s10n()

static int xmpp_pak_s10n ( struct ast_xmpp_client *  client, struct ast_xmpp_client_config *  cfg, iks *  node, ikspak *  pak  )

static

Internal function called when a subscription message is received.

Definition at line 3392 of file res_xmpp.c.

{
    struct ast_xmpp_buddy *buddy;
 
    switch (pak->subtype) {
    case IKS_TYPE_SUBSCRIBE:
        if (ast_test_flag(&cfg->flags, XMPP_AUTOREGISTER)) {
            iks *presence, *status = NULL;
 
            if ((presence = iks_new("presence")) && (status = iks_new("status"))) {
                iks_insert_attrib(presence, "type", "subscribed");
                iks_insert_attrib(presence, "to", pak->from->full);
                iks_insert_attrib(presence, "from", client->jid->full);
 
                if (pak->id) {
                    iks_insert_attrib(presence, "id", pak->id);
                }
 
                iks_insert_cdata(status, "Asterisk has approved your subscription", 0);
                iks_insert_node(presence, status);
 
                if (ast_xmpp_client_send(client, presence)) {
                    ast_log(LOG_ERROR, "Could not send subscription acceptance to '%s' from client '%s'\n",
                        pak->from->partial, client->name);
                }
            } else {
                ast_log(LOG_ERROR, "Could not allocate presence stanzas for accepting subscription from '%s' to client '%s'\n",
                    pak->from->partial, client->name);
            }
 
            iks_delete(status);
            iks_delete(presence);
        }
 
        if (ast_test_flag(&cfg->flags, XMPP_COMPONENT)) {
            xmpp_client_set_presence(client, pak->from->full, iks_find_attrib(pak->x, "to"), cfg->status, cfg->statusmsg);
        }
        /* This purposely flows through so we have the subscriber amongst our buddies */
    case IKS_TYPE_SUBSCRIBED:
        ao2_lock(client->buddies);
 
        if (!(buddy = ao2_find(client->buddies, pak->from->partial, OBJ_KEY | OBJ_NOLOCK))) {
            buddy = xmpp_client_create_buddy(client->buddies, pak->from->partial);
        }
 
        if (!buddy) {
            ast_log(LOG_WARNING, "Could not find or create buddy '%s' on client '%s'\n",
                pak->from->partial, client->name);
        } else {
            ao2_ref(buddy, -1);
        }
 
        ao2_unlock(client->buddies);
 
        break;
    default:
        break;
    }
 
    return 0;
}

References ao2_find, ao2_lock, ao2_ref, ao2_unlock, ast_log, ast_test_flag, ast_xmpp_client_send(), ast_xmpp_client::buddies, ast_xmpp_client_config::flags, ast_xmpp_client::jid, LOG_ERROR, LOG_WARNING, ast_xmpp_client::name, NULL, OBJ_KEY, OBJ_NOLOCK, status, ast_xmpp_client_config::status, ast_xmpp_client_config::statusmsg, XMPP_AUTOREGISTER, xmpp_client_create_buddy(), xmpp_client_set_presence(), and XMPP_COMPONENT.

xmpp_ping_request()

static int xmpp_ping_request ( struct ast_xmpp_client *  client, const char *  to, const char *  from  )

static

Helper function which sends a ping request to a server.

Definition at line 3229 of file res_xmpp.c.

{
    iks *iq, *ping;
    int res;
 
    ast_debug(2, "JABBER: Sending Keep-Alive Ping for client '%s'\n", client->name);
 
    if (!(iq = iks_new("iq")) || !(ping = iks_new("ping"))) {
        iks_delete(iq);
        return -1;
    }
 
    iks_insert_attrib(iq, "type", "get");
    iks_insert_attrib(iq, "to", to);
    iks_insert_attrib(iq, "from", from);
 
    ast_xmpp_client_lock(client);
    iks_insert_attrib(iq, "id", client->mid);
    ast_xmpp_increment_mid(client->mid);
    ast_xmpp_client_unlock(client);
 
    iks_insert_attrib(ping, "xmlns", "urn:xmpp:ping");
    iks_insert_node(iq, ping);
 
    res = ast_xmpp_client_send(client, iq);
 
    iks_delete(ping);
    iks_delete(iq);
 
 
    return res;
}

References ast_debug, ast_xmpp_client_lock(), ast_xmpp_client_send(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), ast_xmpp_client::mid, and ast_xmpp_client::name.

Referenced by xmpp_client_receive(), and xmpp_client_thread().

xmpp_pubsub_build_node_config()

static iks * xmpp_pubsub_build_node_config ( iks *  pubsub, const char *  node_type, const char *  collection_name  )

static

Definition at line 1114 of file res_xmpp.c.

{
    iks *configure, *x, *field_owner, *field_node_type, *field_node_config,
        *field_deliver_payload, *field_persist_items, *field_access_model,
        *field_pubsub_collection;
    configure = iks_insert(pubsub, "configure");
    x = iks_insert(configure, "x");
    iks_insert_attrib(x, "xmlns", "jabber:x:data");
    iks_insert_attrib(x, "type", "submit");
    field_owner = iks_insert(x, "field");
    iks_insert_attrib(field_owner, "var", "FORM_TYPE");
    iks_insert_attrib(field_owner, "type", "hidden");
    iks_insert_cdata(iks_insert(field_owner, "value"),
             "http://jabber.org/protocol/pubsub#owner", 39);
    if (node_type) {
        field_node_type = iks_insert(x, "field");
        iks_insert_attrib(field_node_type, "var", "pubsub#node_type");
        iks_insert_cdata(iks_insert(field_node_type, "value"), node_type, strlen(node_type));
    }
    field_node_config = iks_insert(x, "field");
    iks_insert_attrib(field_node_config, "var", "FORM_TYPE");
    iks_insert_attrib(field_node_config, "type", "hidden");
    iks_insert_cdata(iks_insert(field_node_config, "value"),
             "http://jabber.org/protocol/pubsub#node_config", 45);
    field_deliver_payload = iks_insert(x, "field");
    iks_insert_attrib(field_deliver_payload, "var", "pubsub#deliver_payloads");
    iks_insert_cdata(iks_insert(field_deliver_payload, "value"), "1", 1);
    field_persist_items = iks_insert(x, "field");
    iks_insert_attrib(field_persist_items, "var", "pubsub#persist_items");
    iks_insert_cdata(iks_insert(field_persist_items, "value"), "1", 1);
    field_access_model = iks_insert(x, "field");
    iks_insert_attrib(field_access_model, "var", "pubsub#access_model");
    iks_insert_cdata(iks_insert(field_access_model, "value"), "whitelist", 9);
    if (node_type && !strcasecmp(node_type, "leaf")) {
        field_pubsub_collection = iks_insert(x, "field");
        iks_insert_attrib(field_pubsub_collection, "var", "pubsub#collection");
        iks_insert_cdata(iks_insert(field_pubsub_collection, "value"), collection_name,
                 strlen(collection_name));
    }
    return configure;
}

Referenced by xmpp_pubsub_create_node().

xmpp_pubsub_build_node_request()

static iks * xmpp_pubsub_build_node_request ( struct ast_xmpp_client *  client, const char *  collection  )

static

Build the a node request.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
collection	name of the collection for request

Returns

iks *

Definition at line 3974 of file res_xmpp.c.

{
    iks *request = xmpp_pubsub_iq_create(client, "get"), *query;
 
    if (!request) {
        return NULL;
    }
 
    query = iks_insert(request, "query");
    iks_insert_attrib(query, "xmlns", "http://jabber.org/protocol/disco#items");
 
    if (collection) {
        iks_insert_attrib(query, "node", collection);
    }
 
    return request;
}

References ast_xmpp_client_config::client, NULL, request(), and xmpp_pubsub_iq_create().

Referenced by xmpp_pubsub_purge_nodes(), and xmpp_pubsub_request_nodes().

xmpp_pubsub_build_publish_skeleton()

static iks * xmpp_pubsub_build_publish_skeleton ( struct ast_xmpp_client *  client, const char *  node, const char *  event_type, unsigned int  cachable  )

static

Build the skeleton of a publish.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node	Name of the node that will be published to
event_type,cachable

Returns

iks *

Definition at line 1077 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    iks *request, *pubsub, *publish, *item;
 
    if (!cfg || !cfg->global || !(request = xmpp_pubsub_iq_create(client, "set"))) {
        return NULL;
    }
 
    pubsub = iks_insert(request, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub");
    publish = iks_insert(pubsub, "publish");
    iks_insert_attrib(publish, "node", ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248) ? node : event_type);
    item = iks_insert(publish, "item");
    iks_insert_attrib(item, "id", node);
 
    if (cachable == AST_DEVSTATE_NOT_CACHABLE) {
        iks *options, *x, *field_form_type, *field_persist;
 
        options = iks_insert(pubsub, "publish-options");
        x = iks_insert(options, "x");
        iks_insert_attrib(x, "xmlns", "jabber:x:data");
        iks_insert_attrib(x, "type", "submit");
        field_form_type = iks_insert(x, "field");
        iks_insert_attrib(field_form_type, "var", "FORM_TYPE");
        iks_insert_attrib(field_form_type, "type", "hidden");
        iks_insert_cdata(iks_insert(field_form_type, "value"), "http://jabber.org/protocol/pubsub#publish-options", 0);
        field_persist = iks_insert(x, "field");
        iks_insert_attrib(field_persist, "var", "pubsub#persist_items");
        iks_insert_cdata(iks_insert(field_persist, "value"), "0", 1);
    }
 
    return item;
 
}

References ao2_cleanup, ao2_global_obj_ref, AST_DEVSTATE_NOT_CACHABLE, ast_test_flag, globals, item, NULL, options, publish, RAII_VAR, request(), xmpp_pubsub_iq_create(), and XMPP_XEP0248.

Referenced by xmpp_pubsub_publish_device_state(), and xmpp_pubsub_publish_mwi().

xmpp_pubsub_create_affiliations()

static void xmpp_pubsub_create_affiliations ( struct ast_xmpp_client *  client, const char *  node  )

static

Add Owner affiliations for pubsub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node	the name of the node to which to add affiliations

Definition at line 1161 of file res_xmpp.c.

{
    iks *modify_affiliates = xmpp_pubsub_iq_create(client, "set");
    iks *pubsub, *affiliations, *affiliate;
    struct ao2_iterator i;
    struct ast_xmpp_buddy *buddy;
 
    if (!modify_affiliates) {
        ast_log(LOG_ERROR, "Could not create IQ for creating affiliations on client '%s'\n", client->name);
        return;
    }
 
    pubsub = iks_insert(modify_affiliates, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub#owner");
    affiliations = iks_insert(pubsub, "affiliations");
    iks_insert_attrib(affiliations, "node", node);
 
    i = ao2_iterator_init(client->buddies, 0);
    while ((buddy = ao2_iterator_next(&i))) {
        affiliate = iks_insert(affiliations, "affiliation");
        iks_insert_attrib(affiliate, "jid", buddy->id);
        iks_insert_attrib(affiliate, "affiliation", "owner");
        ao2_ref(buddy, -1);
    }
    ao2_iterator_destroy(&i);
 
    ast_xmpp_client_send(client, modify_affiliates);
    iks_delete(modify_affiliates);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_log, ast_xmpp_client_send(), ast_xmpp_client::buddies, ast_xmpp_buddy::id, LOG_ERROR, ast_xmpp_client::name, and xmpp_pubsub_iq_create().

Referenced by xmpp_pubsub_create_node().

xmpp_pubsub_create_collection()

static void xmpp_pubsub_create_collection ( struct ast_xmpp_client *  client, const char *  collection_name  )

static

Create a PubSub collection node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
collection_name	The name to use for this collection

Definition at line 1244 of file res_xmpp.c.

{
    xmpp_pubsub_create_node(client, "collection", collection_name, NULL);
}

References NULL, and xmpp_pubsub_create_node().

Referenced by xmpp_cli_create_collection(), and xmpp_pubsub_handle_error().

xmpp_pubsub_create_leaf()

static void xmpp_pubsub_create_leaf ( struct ast_xmpp_client *  client, const char *  collection_name, const char *  leaf_name  )

static

Create a PubSub leaf node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
collection_name
leaf_name	The name to use for this collection

Definition at line 1256 of file res_xmpp.c.

{
    xmpp_pubsub_create_node(client, "leaf", leaf_name, collection_name);
}

References xmpp_pubsub_create_node().

Referenced by xmpp_cli_create_leafnode(), and xmpp_pubsub_handle_error().

xmpp_pubsub_create_node()

static void xmpp_pubsub_create_node ( struct ast_xmpp_client *  client, const char *  node_type, const char *  name, const char *  collection_name  )

static

Create a pubsub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node_type	the type of node to create
name	the name of the node to create
collection_name

Definition at line 1198 of file res_xmpp.c.

{
    iks *node, *pubsub, *create;
 
    if (!(node = xmpp_pubsub_iq_create(client, "set"))) {
        return;
    }
 
    pubsub = iks_insert(node, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub");
    create = iks_insert(pubsub, "create");
    iks_insert_attrib(create, "node", name);
    xmpp_pubsub_build_node_config(pubsub, node_type, collection_name);
    ast_xmpp_client_send(client, node);
    xmpp_pubsub_create_affiliations(client, name);
    iks_delete(node);
}

References ast_xmpp_client_send(), name, xmpp_pubsub_build_node_config(), xmpp_pubsub_create_affiliations(), and xmpp_pubsub_iq_create().

Referenced by xmpp_pubsub_create_collection(), xmpp_pubsub_create_leaf(), xmpp_pubsub_handle_error(), and xmpp_pubsub_publish_device_state().

xmpp_pubsub_delete_node()

static void xmpp_pubsub_delete_node ( struct ast_xmpp_client *  client, const char *  node_name  )

static

Delete a PubSub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node_name	the name of the node to delete

Definition at line 1222 of file res_xmpp.c.

{
    iks *request, *pubsub, *delete;
 
    if (!(request = xmpp_pubsub_iq_create(client, "set"))) {
        return;
    }
 
    pubsub = iks_insert(request, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub#owner");
    delete = iks_insert(pubsub, "delete");
    iks_insert_attrib(delete, "node", node_name);
    ast_xmpp_client_send(client, request);
 
    iks_delete(request);
}

References ast_xmpp_client_send(), request(), and xmpp_pubsub_iq_create().

Referenced by xmpp_cli_delete_pubsub_node(), xmpp_cli_purge_pubsub_nodes(), and xmpp_pubsub_delete_node_list().

xmpp_pubsub_delete_node_list()

static int xmpp_pubsub_delete_node_list ( void *  data, ikspak *  pak  )

static

Delete pubsub item lists.

Parameters

data	pointer to ast_xmpp_client structure
pak	response from pubsub diso::items query

Return values

IKS_FILTER_EAT

Definition at line 4096 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    iks *item = NULL;
 
    if (iks_has_children(pak->query)) {
        item = iks_first_tag(pak->query);
        ast_log(LOG_WARNING, "Connection: %s  Node name: %s\n", client->jid->partial,
            iks_find_attrib(item, "node"));
        while ((item = iks_next_tag(item))) {
            xmpp_pubsub_delete_node(client, iks_find_attrib(item, "node"));
        }
    }
 
    if (item) {
        iks_delete(item);
    }
 
    return IKS_FILTER_EAT;
}

References ast_log, item, ast_xmpp_client::jid, LOG_WARNING, NULL, and xmpp_pubsub_delete_node().

Referenced by xmpp_pubsub_purge_nodes().

xmpp_pubsub_devstate_cb()

static void xmpp_pubsub_devstate_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  msg  )

static

Callback function for device state events.

Parameters

data	void pointer to ast_client structure
sub,msg

Definition at line 1362 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    struct ast_device_state_message *dev_state;
 
    if (!stasis_subscription_is_subscribed(sub) || ast_device_state_message_type() != stasis_message_type(msg)) {
        return;
    }
 
    dev_state = stasis_message_data(msg);
    if (!dev_state->eid || ast_eid_cmp(&ast_eid_default, dev_state->eid)) {
        /* If the event is aggregate or didn't originate from this server, don't send it out. */
        return;
    }
 
    xmpp_pubsub_publish_device_state(client, dev_state->device, ast_devstate_str(dev_state->state), dev_state->cachable);
}

References ast_device_state_message_type(), ast_devstate_str(), ast_eid_cmp(), ast_eid_default, ast_device_state_message::cachable, ast_device_state_message::device, ast_device_state_message::eid, stasis_message_data(), stasis_message_type(), stasis_subscription_is_subscribed(), ast_device_state_message::state, sub, and xmpp_pubsub_publish_device_state().

Referenced by cached_devstate_cb(), and xmpp_init_event_distribution().

xmpp_pubsub_handle_error()

static int xmpp_pubsub_handle_error ( void *  data, ikspak *  pak  )

static

Definition at line 1503 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    char *node_name, *error;
    int error_num;
    iks *orig_request, *orig_pubsub = iks_find(pak->x, "pubsub");
    struct ast_xmpp_client *client = data;
 
    if (!cfg || !cfg->global) {
        ast_log(LOG_ERROR, "No global configuration available\n");
        return IKS_FILTER_EAT;
    }
 
    if (!orig_pubsub) {
        ast_debug(1, "Error isn't a PubSub error, why are we here?\n");
        return IKS_FILTER_EAT;
    }
 
    orig_request = iks_child(orig_pubsub);
    error = iks_find_attrib(iks_find(pak->x, "error"), "code");
    node_name = iks_find_attrib(orig_request, "node");
 
    if (!sscanf(error, "%30d", &error_num)) {
        return IKS_FILTER_EAT;
    }
 
    if (error_num > 399 && error_num < 500 && error_num != 404) {
        ast_log(LOG_ERROR,
            "Error performing operation on PubSub node %s, %s.\n", node_name, error);
        return IKS_FILTER_EAT;
    } else if (error_num > 499 && error_num < 600) {
        ast_log(LOG_ERROR, "PubSub Server error, %s\n", error);
        return IKS_FILTER_EAT;
    }
 
    if (!strcasecmp(iks_name(orig_request), "publish")) {
        iks *request;
 
        if (ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248)) {
            if (iks_find(iks_find(orig_request, "item"), "state")) {
                xmpp_pubsub_create_leaf(client, "device_state", node_name);
            } else if (iks_find(iks_find(orig_request, "item"), "mailbox")) {
                xmpp_pubsub_create_leaf(client, "message_waiting", node_name);
            }
        } else {
            xmpp_pubsub_create_node(client, NULL, node_name, NULL);
        }
 
        if ((request = xmpp_pubsub_iq_create(client, "set"))) {
            iks_insert_node(request, orig_pubsub);
            ast_xmpp_client_send(client, request);
            iks_delete(request);
        } else {
            ast_log(LOG_ERROR, "PubSub publish could not create IQ\n");
        }
 
        return IKS_FILTER_EAT;
    } else if (!strcasecmp(iks_name(orig_request), "subscribe")) {
        if (ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248)) {
            xmpp_pubsub_create_collection(client, node_name);
        } else {
            xmpp_pubsub_create_node(client, NULL, node_name, NULL);
        }
    }
 
    return IKS_FILTER_EAT;
}

References ao2_cleanup, ao2_global_obj_ref, ast_debug, ast_log, ast_test_flag, ast_xmpp_client_send(), error(), globals, LOG_ERROR, NULL, RAII_VAR, request(), xmpp_pubsub_create_collection(), xmpp_pubsub_create_leaf(), xmpp_pubsub_create_node(), xmpp_pubsub_iq_create(), and XMPP_XEP0248.

Referenced by xmpp_init_event_distribution().

xmpp_pubsub_handle_event()

static int xmpp_pubsub_handle_event ( void *  data, ikspak *  pak  )

static

Callback for handling PubSub events.

Parameters

data	void pointer to ast_xmpp_client structure
pak	A pak

Return values

IKS_FILTER_EAT

Definition at line 1457 of file res_xmpp.c.

{
    char *item_id, *device_state, *mailbox, *cachable_str;
    int oldmsgs, newmsgs;
    iks *item, *item_content;
    struct ast_eid pubsub_eid;
    unsigned int cachable = AST_DEVSTATE_CACHABLE;
    item = iks_find(iks_find(iks_find(pak->x, "event"), "items"), "item");
    if (!item) {
        ast_log(LOG_ERROR, "Could not parse incoming PubSub event\n");
        return IKS_FILTER_EAT;
    }
    item_id = iks_find_attrib(item, "id");
    item_content = iks_child(item);
    ast_str_to_eid(&pubsub_eid, iks_find_attrib(item_content, "eid"));
    if (!ast_eid_cmp(&ast_eid_default, &pubsub_eid)) {
        ast_debug(1, "Returning here, eid of incoming event matches ours!\n");
        return IKS_FILTER_EAT;
    }
    if (!strcasecmp(iks_name(item_content), "state")) {
        if ((cachable_str = iks_find_attrib(item_content, "cachable"))) {
            sscanf(cachable_str, "%30u", &cachable);
        }
        device_state = iks_find_cdata(item, "state");
        ast_publish_device_state_full(item_id,
                        ast_devstate_val(device_state),
                        cachable == AST_DEVSTATE_CACHABLE ? AST_DEVSTATE_CACHABLE : AST_DEVSTATE_NOT_CACHABLE,
                        &pubsub_eid);
        return IKS_FILTER_EAT;
    } else if (!strcasecmp(iks_name(item_content), "mailbox")) {
        mailbox = strsep(&item_id, "@");
        sscanf(iks_find_cdata(item_content, "OLDMSGS"), "%10d", &oldmsgs);
        sscanf(iks_find_cdata(item_content, "NEWMSGS"), "%10d", &newmsgs);
 
        ast_publish_mwi_state_full(mailbox, item_id, newmsgs, oldmsgs, NULL, &pubsub_eid);
 
        return IKS_FILTER_EAT;
    } else {
        ast_debug(1, "Don't know how to handle PubSub event of type %s\n",
              iks_name(item_content));
        return IKS_FILTER_EAT;
    }
 
    return IKS_FILTER_EAT;
}

References ast_debug, AST_DEVSTATE_CACHABLE, AST_DEVSTATE_NOT_CACHABLE, ast_devstate_val(), ast_eid_cmp(), ast_eid_default, ast_log, ast_publish_device_state_full(), ast_publish_mwi_state_full(), ast_str_to_eid(), item, LOG_ERROR, voicemailpwcheck::mailbox, NULL, and strsep().

Referenced by xmpp_init_event_distribution().

xmpp_pubsub_iq_create()

static iks * xmpp_pubsub_iq_create ( struct ast_xmpp_client *  client, const char *  type  )

static

Create an IQ packet.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
type	the type of IQ packet to create

Returns

iks *

Definition at line 1045 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    iks *request;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name)) ||
        !(request = iks_new("iq"))) {
        return NULL;
    }
 
    if (!ast_strlen_zero(clientcfg->pubsubnode)) {
        iks_insert_attrib(request, "to", clientcfg->pubsubnode);
    }
 
    iks_insert_attrib(request, "from", client->jid->full);
    iks_insert_attrib(request, "type", type);
    ast_xmpp_client_lock(client);
    ast_xmpp_increment_mid(client->mid);
    iks_insert_attrib(request, "id", client->mid);
    ast_xmpp_client_unlock(client);
 
    return request;
}

References ao2_cleanup, ao2_global_obj_ref, ast_strlen_zero(), ast_xmpp_client_lock(), ast_xmpp_client_unlock(), ast_xmpp_increment_mid(), globals, ast_xmpp_client::jid, ast_xmpp_client::mid, ast_xmpp_client::name, NULL, RAII_VAR, request(), type, and xmpp_config_find().

Referenced by xmpp_pubsub_build_node_request(), xmpp_pubsub_build_publish_skeleton(), xmpp_pubsub_create_affiliations(), xmpp_pubsub_create_node(), xmpp_pubsub_delete_node(), xmpp_pubsub_handle_error(), xmpp_pubsub_subscribe(), and xmpp_pubsub_unsubscribe().

xmpp_pubsub_mwi_cb()

static void xmpp_pubsub_mwi_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  msg  )

static

Callback function for MWI events.

Parameters

data	void pointer to ast_client structure
sub,msg

Definition at line 1335 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    char oldmsgs[10], newmsgs[10];
    struct ast_mwi_state *mwi_state;
 
    if (!stasis_subscription_is_subscribed(sub) || ast_mwi_state_type() != stasis_message_type(msg)) {
        return;
    }
 
    mwi_state = stasis_message_data(msg);
 
    if (ast_eid_cmp(&ast_eid_default, &mwi_state->eid)) {
        /* If the event didn't originate from this server, don't send it back out. */
        return;
    }
 
    snprintf(oldmsgs, sizeof(oldmsgs), "%d", mwi_state->old_msgs);
    snprintf(newmsgs, sizeof(newmsgs), "%d", mwi_state->new_msgs);
    xmpp_pubsub_publish_mwi(client, mwi_state->uniqueid, oldmsgs, newmsgs);
}

References ast_eid_cmp(), ast_eid_default, ast_mwi_state_type(), ast_mwi_state::eid, ast_mwi_state::new_msgs, ast_mwi_state::old_msgs, stasis_message_data(), stasis_message_type(), stasis_subscription_is_subscribed(), sub, ast_mwi_state::uniqueid, and xmpp_pubsub_publish_mwi().

Referenced by xmpp_init_event_distribution().

xmpp_pubsub_publish_device_state()

static void xmpp_pubsub_publish_device_state ( struct ast_xmpp_client *  client, const char *  device, const char *  device_state, unsigned int  cachable  )

static

Publish device state to a PubSub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
device	the name of the device whose state to publish
device_state	the state to publish
cachable

Definition at line 1300 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    iks *request, *state;
    char eid_str[20], cachable_str[2];
 
    if (!cfg || !cfg->global || !(request = xmpp_pubsub_build_publish_skeleton(client, device, "device_state", cachable))) {
        return;
    }
 
    if (ast_test_flag(&cfg->global->pubsub, XMPP_PUBSUB_AUTOCREATE)) {
        if (ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248)) {
            xmpp_pubsub_create_node(client, "leaf", device, "device_state");
        } else {
            xmpp_pubsub_create_node(client, NULL, device, NULL);
        }
    }
 
    ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
    state = iks_insert(request, "state");
    iks_insert_attrib(state, "xmlns", "http://asterisk.org");
    iks_insert_attrib(state, "eid", eid_str);
    snprintf(cachable_str, sizeof(cachable_str), "%u", cachable);
    iks_insert_attrib(state, "cachable", cachable_str);
    iks_insert_cdata(state, device_state, strlen(device_state));
    ast_xmpp_client_send(client, iks_root(request));
    iks_delete(request);
}

References ao2_cleanup, ao2_global_obj_ref, ast_eid_default, ast_eid_to_str(), ast_test_flag, ast_xmpp_client_send(), globals, NULL, RAII_VAR, request(), state, XMPP_PUBSUB_AUTOCREATE, xmpp_pubsub_build_publish_skeleton(), xmpp_pubsub_create_node(), and XMPP_XEP0248.

Referenced by xmpp_pubsub_devstate_cb().

xmpp_pubsub_publish_mwi()

static void xmpp_pubsub_publish_mwi ( struct ast_xmpp_client *  client, const char *  mailbox, const char *  oldmsgs, const char *  newmsgs  )

static

Publish MWI to a PubSub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
mailbox	The mailbox identifier
oldmsgs	Old messages
newmsgs	New Messages

Definition at line 1269 of file res_xmpp.c.

{
    char eid_str[20];
    iks *mailbox_node, *request;
 
    request = xmpp_pubsub_build_publish_skeleton(client, mailbox, "message_waiting",
        AST_DEVSTATE_CACHABLE);
    if (!request) {
        return;
    }
 
    ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
    mailbox_node = iks_insert(request, "mailbox");
    iks_insert_attrib(mailbox_node, "xmlns", "http://asterisk.org");
    iks_insert_attrib(mailbox_node, "eid", eid_str);
    iks_insert_cdata(iks_insert(mailbox_node, "NEWMSGS"), newmsgs, strlen(newmsgs));
    iks_insert_cdata(iks_insert(mailbox_node, "OLDMSGS"), oldmsgs, strlen(oldmsgs));
 
    ast_xmpp_client_send(client, iks_root(request));
 
    iks_delete(request);
}

References AST_DEVSTATE_CACHABLE, ast_eid_default, ast_eid_to_str(), ast_xmpp_client_send(), voicemailpwcheck::mailbox, request(), and xmpp_pubsub_build_publish_skeleton().

Referenced by xmpp_pubsub_mwi_cb().

xmpp_pubsub_purge_nodes()

static void xmpp_pubsub_purge_nodes ( struct ast_xmpp_client *  client, const char *  collection_name  )

static

Definition at line 4117 of file res_xmpp.c.

{
    iks *request = xmpp_pubsub_build_node_request(client, collection_name);
    ast_xmpp_client_send(client, request);
    iks_filter_add_rule(client->filter, xmpp_pubsub_delete_node_list, client, IKS_RULE_TYPE,
                IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, client->mid,
                IKS_RULE_DONE);
    ast_xmpp_client_send(client, request);
    iks_delete(request);
}

References ast_xmpp_client_send(), ast_xmpp_client::filter, ast_xmpp_client::mid, request(), xmpp_pubsub_build_node_request(), and xmpp_pubsub_delete_node_list().

Referenced by xmpp_cli_purge_pubsub_nodes().

xmpp_pubsub_receive_node_list()

static int xmpp_pubsub_receive_node_list ( void *  data, ikspak *  pak  )

static

Receive pubsub item lists.

Parameters

data	pointer to ast_xmpp_client structure
pak	response from pubsub diso::items query

Return values

IKS_FILTER_EAT

Definition at line 3998 of file res_xmpp.c.

{
    struct ast_xmpp_client *client = data;
    iks *item = NULL;
 
    if (iks_has_children(pak->query)) {
        item = iks_first_tag(pak->query);
        ast_verbose("Connection %s: %s\nNode name: %s\n", client->name, client->jid->partial,
                iks_find_attrib(item, "node"));
        while ((item = iks_next_tag(item))) {
            ast_verbose("Node name: %s\n", iks_find_attrib(item, "node"));
        }
    }
 
    if (item) {
        iks_delete(item);
    }
 
 
    return IKS_FILTER_EAT;
}

References ast_verbose(), item, ast_xmpp_client::jid, ast_xmpp_client::name, and NULL.

Referenced by xmpp_pubsub_request_nodes().

xmpp_pubsub_request_nodes()

static void xmpp_pubsub_request_nodes ( struct ast_xmpp_client *  client, const char *  collection  )

static

Request item list from pubsub.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
collection	name of the collection for request

Definition at line 4025 of file res_xmpp.c.

{
    iks *request = xmpp_pubsub_build_node_request(client, collection);
 
    if (!request) {
        ast_log(LOG_ERROR, "Could not request pubsub nodes on client '%s' - IQ could not be created\n", client->name);
        return;
    }
 
    iks_filter_add_rule(client->filter, xmpp_pubsub_receive_node_list, client, IKS_RULE_TYPE,
                IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, client->mid,
                IKS_RULE_DONE);
    ast_xmpp_client_send(client, request);
    iks_delete(request);
 
}

References ast_log, ast_xmpp_client_send(), ast_xmpp_client::filter, LOG_ERROR, ast_xmpp_client::mid, ast_xmpp_client::name, request(), xmpp_pubsub_build_node_request(), and xmpp_pubsub_receive_node_list().

Referenced by xmpp_cli_list_pubsub_nodes().

xmpp_pubsub_subscribe()

static void xmpp_pubsub_subscribe ( struct ast_xmpp_client *  client, const char *  node  )

static

Subscribe to a PubSub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node	the name of the node to which to subscribe

Definition at line 1410 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    iks *request = xmpp_pubsub_iq_create(client, "set");
    iks *pubsub, *subscribe;
 
    if (!cfg || !cfg->global || !request) {
        ast_log(LOG_ERROR, "Could not create IQ when creating pubsub subscription on client '%s'\n", client->name);
        return;
    }
 
    pubsub = iks_insert(request, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub");
    subscribe = iks_insert(pubsub, "subscribe");
    iks_insert_attrib(subscribe, "jid", client->jid->partial);
    iks_insert_attrib(subscribe, "node", node);
    if (ast_test_flag(&cfg->global->pubsub, XMPP_XEP0248)) {
        iks *options, *x, *sub_options, *sub_type, *sub_depth, *sub_expire;
        options = iks_insert(pubsub, "options");
        x = iks_insert(options, "x");
        iks_insert_attrib(x, "xmlns", "jabber:x:data");
        iks_insert_attrib(x, "type", "submit");
        sub_options = iks_insert(x, "field");
        iks_insert_attrib(sub_options, "var", "FORM_TYPE");
        iks_insert_attrib(sub_options, "type", "hidden");
        iks_insert_cdata(iks_insert(sub_options, "value"),
                 "http://jabber.org/protocol/pubsub#subscribe_options", 51);
        sub_type = iks_insert(x, "field");
        iks_insert_attrib(sub_type, "var", "pubsub#subscription_type");
        iks_insert_cdata(iks_insert(sub_type, "value"), "items", 5);
        sub_depth = iks_insert(x, "field");
        iks_insert_attrib(sub_depth, "var", "pubsub#subscription_depth");
        iks_insert_cdata(iks_insert(sub_depth, "value"), "all", 3);
        sub_expire = iks_insert(x, "field");
        iks_insert_attrib(sub_expire, "var", "pubsub#expire");
        iks_insert_cdata(iks_insert(sub_expire, "value"), "presence", 8);
    }
    ast_xmpp_client_send(client, request);
    iks_delete(request);
}

References ao2_cleanup, ao2_global_obj_ref, ast_log, ast_test_flag, ast_xmpp_client_send(), globals, ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, options, RAII_VAR, request(), subscribe, xmpp_pubsub_iq_create(), and XMPP_XEP0248.

Referenced by xmpp_init_event_distribution().

xmpp_pubsub_unsubscribe()

static void xmpp_pubsub_unsubscribe ( struct ast_xmpp_client *  client, const char *  node  )

static

Unsubscribe from a PubSub node.

Parameters

client	the configured XMPP client we use to connect to a XMPP server
node	the name of the node to which to unsubscribe from

Definition at line 1385 of file res_xmpp.c.

{
    iks *request = xmpp_pubsub_iq_create(client, "set");
    iks *pubsub, *unsubscribe;
 
    if (!request) {
        ast_log(LOG_ERROR, "Could not create IQ when creating pubsub unsubscription on client '%s'\n", client->name);
        return;
    }
 
    pubsub = iks_insert(request, "pubsub");
    iks_insert_attrib(pubsub, "xmlns", "http://jabber.org/protocol/pubsub");
    unsubscribe = iks_insert(pubsub, "unsubscribe");
    iks_insert_attrib(unsubscribe, "jid", client->jid->partial);
    iks_insert_attrib(unsubscribe, "node", node);
 
    ast_xmpp_client_send(client, request);
    iks_delete(request);
}

References ast_log, ast_xmpp_client_send(), ast_xmpp_client::jid, LOG_ERROR, ast_xmpp_client::name, request(), unsubscribe(), and xmpp_pubsub_iq_create().

Referenced by ast_xmpp_client_disconnect(), and xmpp_init_event_distribution().

xmpp_resource_cmp()

static int xmpp_resource_cmp ( void *  obj, void *  arg, int  flags  )

static

Comparator function for XMPP resource.

Definition at line 853 of file res_xmpp.c.

{
    struct ast_xmpp_resource *resource1 = obj;
    const char *resource = arg;
 
    return !strcmp(resource1->resource, resource) ? CMP_MATCH | CMP_STOP : 0;
}

References CMP_MATCH, CMP_STOP, and ast_xmpp_resource::resource.

Referenced by get_buddy_status(), xmpp_client_create_buddy(), xmpp_client_service_discovery_result_hook(), and xmpp_pak_presence().

xmpp_resource_destructor()

static void xmpp_resource_destructor ( void *  obj )

static

Destructor callback function for XMPP resource.

Definition at line 835 of file res_xmpp.c.

{
    struct ast_xmpp_resource *resource = obj;
 
    if (resource->description) {
        ast_free(resource->description);
    }
}

References ast_free, and ast_xmpp_resource::resource.

Referenced by xmpp_pak_presence().

xmpp_resource_hash()

static int xmpp_resource_hash ( const void *  obj, const int  flags  )

static

Hashing function for XMPP resource.

Definition at line 845 of file res_xmpp.c.

{
    const struct ast_xmpp_resource *resource = obj;
 
    return flags & OBJ_KEY ? -1 : resource->priority;
}

References OBJ_KEY, and ast_xmpp_resource::resource.

Referenced by xmpp_client_create_buddy().

xmpp_resource_immediate()

static int xmpp_resource_immediate ( void *  obj, void *  arg, int  flags  )

static

Internal astobj2 callback function which returns the first resource, which is the highest priority one.

Definition at line 1622 of file res_xmpp.c.

{
    return CMP_MATCH | CMP_STOP;
}

References CMP_MATCH, and CMP_STOP.

Referenced by get_buddy_status().

xmpp_resource_is_available()

static int xmpp_resource_is_available ( void *  obj, void *  arg, int  flags  )

static

Callback function which returns when the resource is available.

Definition at line 3221 of file res_xmpp.c.

{
    struct ast_xmpp_resource *resource = obj;
 
    return (resource->status == IKS_SHOW_AVAILABLE) ? CMP_MATCH | CMP_STOP : 0;
}

References CMP_MATCH, CMP_STOP, and ast_xmpp_resource::resource.

Referenced by xmpp_pak_presence().

xmpp_roster_hook()

static int xmpp_roster_hook ( void *  data, ikspak *  pak  )

static

Hook function called when roster is received from server.

Definition at line 2247 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    struct ast_xmpp_client *client = data;
    iks *item;
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, client->name))) {
        return IKS_FILTER_EAT;
    }
 
    for (item = iks_child(pak->query); item; item = iks_next(item)) {
        struct ast_xmpp_buddy *buddy;
 
        if (iks_strcmp(iks_name(item), "item")) {
            continue;
        }
 
        if (!(buddy = ao2_find(client->buddies, iks_find_attrib(item, "jid"), OBJ_KEY))) {
            if (ast_test_flag(&clientcfg->flags, XMPP_AUTOPRUNE)) {
                /* The buddy has not been specified in the configuration file, we no longer
                 * want them on our buddy list or to receive their presence. */
                if (xmpp_client_unsubscribe_user(client, iks_find_attrib(item, "jid"))) {
                    ast_log(LOG_ERROR, "Could not unsubscribe user '%s' on client '%s'\n",
                        iks_find_attrib(item, "jid"), client->name);
                }
                continue;
            }
 
            if (!(buddy = xmpp_client_create_buddy(client->buddies, iks_find_attrib(item, "jid")))) {
                ast_log(LOG_ERROR, "Could not allocate buddy '%s' on client '%s'\n", iks_find_attrib(item, "jid"),
                    client->name);
                continue;
            }
        }
 
        /* Determine if we need to subscribe to their presence or not */
        if (!iks_strcmp(iks_find_attrib(item, "subscription"), "none") ||
            !iks_strcmp(iks_find_attrib(item, "subscription"), "from")) {
            buddy->subscribe = 1;
        } else {
            buddy->subscribe = 0;
        }
 
        ao2_ref(buddy, -1);
    }
 
    /* If autoregister is enabled we need to go through every buddy that we need to subscribe to and do so */
    if (ast_test_flag(&clientcfg->flags, XMPP_AUTOREGISTER)) {
        ao2_callback(client->buddies, OBJ_NODATA | OBJ_MULTIPLE, xmpp_client_subscribe_user, client);
    }
 
    xmpp_client_change_state(client, XMPP_STATE_CONNECTED);
 
    return IKS_FILTER_EAT;
}

References ao2_callback, ao2_cleanup, ao2_find, ao2_global_obj_ref, ao2_ref, ast_log, ast_test_flag, ast_xmpp_client::buddies, globals, item, LOG_ERROR, ast_xmpp_client::name, NULL, OBJ_KEY, OBJ_MULTIPLE, OBJ_NODATA, RAII_VAR, ast_xmpp_buddy::subscribe, XMPP_AUTOPRUNE, XMPP_AUTOREGISTER, xmpp_client_change_state(), xmpp_client_create_buddy(), xmpp_client_subscribe_user(), xmpp_client_unsubscribe_user(), xmpp_config_find(), and XMPP_STATE_CONNECTED.

Referenced by xmpp_connect_hook().

xmpp_send_cb()

static int xmpp_send_cb ( const struct ast_msg *  msg, const char *  to, const char *  from  )

static

Definition at line 2126 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *sender, *dest;
    int res;
 
    sender = ast_strdupa(from);
    strsep(&sender, ":");
    dest = ast_strdupa(to);
    strsep(&dest, ":");
 
    if (ast_strlen_zero(sender)) {
        ast_log(LOG_ERROR, "MESSAGE(from) of '%s' invalid for XMPP\n", from);
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, sender))) {
        ast_log(LOG_WARNING, "Could not finder account to send from as '%s'\n", sender);
        return -1;
    }
 
    ast_debug(1, "Sending message to '%s' from '%s'\n", dest, clientcfg->name);
 
    if ((res = ast_xmpp_client_send_message(clientcfg->client, dest, ast_msg_get_body(msg))) != IKS_OK) {
        ast_log(LOG_WARNING, "Failed to send XMPP message (%d).\n", res);
    }
 
    return res == IKS_OK ? 0 : -1;
}

References ao2_cleanup, ao2_global_obj_ref, ast_debug, ast_log, ast_msg_get_body(), ast_strdupa, ast_strlen_zero(), ast_xmpp_client_send_message(), ast_xmpp_message::from, globals, LOG_ERROR, LOG_WARNING, NULL, RAII_VAR, strsep(), and xmpp_config_find().

xmpp_send_exec()

static int xmpp_send_exec ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 1838 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *s;
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(sender);
                 AST_APP_ARG(recipient);
                 AST_APP_ARG(message);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_WARNING, "%s requires arguments (account,jid,message)\n", app_ajisend);
        return -1;
    }
    s = ast_strdupa(data);
 
    AST_STANDARD_APP_ARGS(args, s);
 
    if ((args.argc < 3) || ast_strlen_zero(args.message) || !strchr(args.recipient, '@')) {
        ast_log(LOG_WARNING, "%s requires arguments (account,jid,message)\n", app_ajisend);
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.sender))) {
        ast_log(LOG_WARNING, "Could not find sender connection: '%s'\n", args.sender);
        return -1;
    }
 
    ast_xmpp_client_send_message(clientcfg->client, args.recipient, args.message);
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, app_ajisend, args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_xmpp_client_send_message(), globals, LOG_WARNING, NULL, RAII_VAR, and xmpp_config_find().

Referenced by load_module().

xmpp_send_stream_header()

static int xmpp_send_stream_header ( struct ast_xmpp_client *  client, const struct ast_xmpp_client_config *  cfg, const char *  to  )

static

Helper function which sends an XMPP stream header to the server.

Definition at line 2522 of file res_xmpp.c.

{
    char *namespace = ast_test_flag(&cfg->flags, XMPP_COMPONENT) ? "jabber:component:accept" : "jabber:client";
    char msg[91 + strlen(namespace) + 6 + strlen(to) + 16 + 1];
 
    snprintf(msg, sizeof(msg), "<?xml version='1.0'?>"
         "<stream:stream xmlns:stream='http://etherx.jabber.org/streams' xmlns='"
         "%s' to='%s' version='1.0'>", namespace, to);
 
    return xmpp_client_send_raw_message(client, msg);
}

References ast_test_flag, ast_xmpp_client_config::flags, xmpp_client_send_raw_message(), and XMPP_COMPONENT.

Referenced by xmpp_client_authenticating(), and xmpp_client_requested_tls().

xmpp_sendgroup_exec()

static int xmpp_sendgroup_exec ( struct ast_channel *  chan, const char *  data  )

static

Application to send a message to a groupchat.

Parameters

chan	ast_channel
data	Data is sender|groupchat|message.

Return values

0	success
-1	error

Definition at line 1879 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    RAII_VAR(struct ast_xmpp_client_config *, clientcfg, NULL, ao2_cleanup);
    char *s, nick[XMPP_MAX_RESJIDLEN];
    AST_DECLARE_APP_ARGS(args,
                 AST_APP_ARG(sender);
                 AST_APP_ARG(groupchat);
                 AST_APP_ARG(message);
                 AST_APP_ARG(nick);
        );
 
    if (ast_strlen_zero(data)) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,groupchatid,message[,nickname])\n", app_ajisendgroup);
        return -1;
    }
    s = ast_strdupa(data);
 
    AST_STANDARD_APP_ARGS(args, s);
    if ((args.argc < 3) || (args.argc > 4) || ast_strlen_zero(args.message) || !strchr(args.groupchat, '@')) {
        ast_log(LOG_ERROR, "%s requires arguments (sender,groupchatid,message[,nickname])\n", app_ajisendgroup);
        return -1;
    }
 
    if (!cfg || !cfg->clients || !(clientcfg = xmpp_config_find(cfg->clients, args.sender))) {
        ast_log(LOG_ERROR, "Could not find sender connection: '%s'\n", args.sender);
        return -1;
    }
 
    if (ast_strlen_zero(args.nick) || args.argc == 3) {
        if (ast_test_flag(&clientcfg->flags, XMPP_COMPONENT)) {
            snprintf(nick, sizeof(nick), "asterisk");
        } else {
            snprintf(nick, sizeof(nick), "%s", clientcfg->client->jid->user);
        }
    } else {
        snprintf(nick, sizeof(nick), "%s", args.nick);
    }
 
    ast_xmpp_chatroom_send(clientcfg->client, nick, args.groupchat, args.message);
 
    return 0;
}

References ao2_cleanup, ao2_global_obj_ref, app_ajisendgroup, args, AST_APP_ARG, AST_DECLARE_APP_ARGS, ast_log, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_test_flag, ast_xmpp_chatroom_send(), globals, LOG_ERROR, NULL, RAII_VAR, XMPP_COMPONENT, xmpp_config_find(), and XMPP_MAX_RESJIDLEN.

Referenced by load_module().

xmpp_show_buddies()

static char * xmpp_show_buddies ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 4410 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    struct ao2_iterator i;
    struct ast_xmpp_client_config *clientcfg;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp show buddies";
        e->usage =
            "Usage: xmpp show buddies\n"
            "       Shows buddy lists of our clients\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (!cfg || !cfg->clients) {
        return NULL;
    }
 
    ast_cli(a->fd, "XMPP buddy lists\n");
 
    i = ao2_iterator_init(cfg->clients, 0);
    while ((clientcfg = ao2_iterator_next(&i))) {
        struct ao2_iterator bud;
        struct ast_xmpp_buddy *buddy;
 
        ast_cli(a->fd, "Client: %s\n", clientcfg->name);
 
        bud = ao2_iterator_init(clientcfg->client->buddies, 0);
        while ((buddy = ao2_iterator_next(&bud))) {
            struct ao2_iterator res;
            struct ast_xmpp_resource *resource;
 
            ast_cli(a->fd, "\tBuddy:\t%s\n", buddy->id);
 
            res = ao2_iterator_init(buddy->resources, 0);
            while ((resource = ao2_iterator_next(&res))) {
                ast_cli(a->fd, "\t\tResource: %s\n", resource->resource);
                ast_cli(a->fd, "\t\t\tnode: %s\n", resource->caps.node);
                ast_cli(a->fd, "\t\t\tversion: %s\n", resource->caps.version);
                ast_cli(a->fd, "\t\t\tGoogle Talk capable: %s\n", resource->caps.google ? "yes" : "no");
                ast_cli(a->fd, "\t\t\tJingle capable: %s\n", resource->caps.jingle ? "yes" : "no");
 
                ao2_ref(resource, -1);
            }
            ao2_iterator_destroy(&res);
 
            ao2_ref(buddy, -1);
        }
        ao2_iterator_destroy(&bud);
 
        ao2_ref(clientcfg, -1);
    }
    ao2_iterator_destroy(&i);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_global_obj_ref, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli(), ast_xmpp_client::buddies, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_xmpp_client_config::client, ast_cli_entry::command, globals, ast_xmpp_buddy::id, ast_xmpp_client_config::name, NULL, RAII_VAR, ast_xmpp_resource::resource, ast_xmpp_buddy::resources, and ast_cli_entry::usage.

xmpp_show_clients()

static char * xmpp_show_clients ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 4334 of file res_xmpp.c.

{
    RAII_VAR(struct xmpp_config *, cfg, ao2_global_obj_ref(globals), ao2_cleanup);
    struct ao2_iterator i;
    struct ast_xmpp_client_config *clientcfg;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "xmpp show connections";
        e->usage =
            "Usage: xmpp show connections\n"
            "       Shows state of client and component connections\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    }
 
    if (!cfg || !cfg->clients) {
        return NULL;
    }
 
    ast_cli(a->fd, "Jabber Users and their status:\n");
 
    i = ao2_iterator_init(cfg->clients, 0);
    while ((clientcfg = ao2_iterator_next(&i))) {
        char *state;
 
        switch (clientcfg->client->state) {
        case XMPP_STATE_DISCONNECTING:
            state = "Disconnecting";
            break;
        case XMPP_STATE_DISCONNECTED:
            state = "Disconnected";
            break;
        case XMPP_STATE_CONNECTING:
            state = "Connecting";
            break;
        case XMPP_STATE_REQUEST_TLS:
            state = "Waiting to request TLS";
            break;
        case XMPP_STATE_REQUESTED_TLS:
            state = "Requested TLS";
            break;
        case XMPP_STATE_AUTHENTICATE:
            state = "Waiting to authenticate";
            break;
        case XMPP_STATE_AUTHENTICATING:
            state = "Authenticating";
            break;
        case XMPP_STATE_ROSTER:
            state = "Retrieving roster";
            break;
        case XMPP_STATE_CONNECTED:
            state = "Connected";
            break;
        default:
            state = "Unknown";
        }
 
        ast_cli(a->fd, "       [%s] %s     - %s\n", clientcfg->name, clientcfg->user, state);
 
        ao2_ref(clientcfg, -1);
    }
    ao2_iterator_destroy(&i);
 
    ast_cli(a->fd, "----\n");
    ast_cli(a->fd, "   Number of clients: %d\n", ao2_container_count(cfg->clients));
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_container_count(), ao2_global_obj_ref, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_xmpp_client_config::client, ast_cli_entry::command, globals, ast_xmpp_client_config::name, NULL, RAII_VAR, ast_xmpp_client::state, state, ast_cli_entry::usage, ast_xmpp_client_config::user, XMPP_STATE_AUTHENTICATE, XMPP_STATE_AUTHENTICATING, XMPP_STATE_CONNECTED, XMPP_STATE_CONNECTING, XMPP_STATE_DISCONNECTED, XMPP_STATE_DISCONNECTING, XMPP_STATE_REQUEST_TLS, XMPP_STATE_REQUESTED_TLS, and XMPP_STATE_ROSTER.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Asterisk XMPP Interface" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CHANNEL_DEPEND, }

static

Definition at line 4703 of file res_xmpp.c.

app_ajijoin

const char* app_ajijoin = "JabberJoin"

static

Definition at line 519 of file res_xmpp.c.

Referenced by load_module(), unload_module(), and xmpp_join_exec().

app_ajileave

const char* app_ajileave = "JabberLeave"

static

Definition at line 520 of file res_xmpp.c.

Referenced by load_module(), unload_module(), and xmpp_leave_exec().

app_ajisend

const char* app_ajisend = "JabberSend"

static

Definition at line 516 of file res_xmpp.c.

Referenced by load_module(), unload_module(), and xmpp_send_exec().

app_ajisendgroup

const char* app_ajisendgroup = "JabberSendGroup"

static

Definition at line 517 of file res_xmpp.c.

Referenced by load_module(), unload_module(), and xmpp_sendgroup_exec().

app_ajistatus

const char* app_ajistatus = "JabberStatus"

static

Definition at line 518 of file res_xmpp.c.

Referenced by unload_module().

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 4703 of file res_xmpp.c.

client_option

struct aco_type client_option

static

Definition at line 810 of file res_xmpp.c.

client_options

struct aco_type* client_options[] = ACO_TYPES(&client_option)

Definition at line 821 of file res_xmpp.c.

Referenced by load_module().

debug

int debug

static

Global debug status.

Definition at line 441 of file res_xmpp.c.

Referenced by ari_set_debug(), ast_cc_agent_accept_request(), ast_cc_agent_caller_available(), ast_cc_agent_caller_busy(), ast_cc_agent_recalling(), ast_cc_completed(), ast_cc_failed(), ast_cc_monitor_callee_available(), ast_cc_monitor_failed(), ast_cc_monitor_request_acked(), ast_sip_initialize_sorcery_global(), cc_offer(), cc_ref(), cc_request_state_change(), cc_unref(), check_debug(), check_events(), global_bitfield_handler(), load_module(), stasis_app_set_debug(), stasis_app_set_debug_by_name(), stasis_app_set_global_debug(), xmpp_do_set_debug(), and xmpp_log_hook().

global_option

struct aco_type global_option

static

Definition at line 800 of file res_xmpp.c.

global_options

struct aco_type* global_options[] = ACO_TYPES(&global_option)

Definition at line 808 of file res_xmpp.c.

Referenced by load_module().

jabberreceive_function

struct ast_custom_function jabberreceive_function

static

Initial value:

= {
    .name = "JABBER_RECEIVE",
    .read = acf_jabberreceive_read,
}

Definition at line 2079 of file res_xmpp.c.

Referenced by load_module(), and unload_module().

jabberstatus_function

struct ast_custom_function jabberstatus_function

static

Initial value:

= {
    .name = "JABBER_STATUS",
    .read = acf_jabberstatus_read,
}

Definition at line 1706 of file res_xmpp.c.

Referenced by load_module(), and unload_module().

message_received_condition

ast_cond_t message_received_condition

static

Definition at line 522 of file res_xmpp.c.

Referenced by acf_jabberreceive_read(), load_module(), unload_module(), and xmpp_pak_message().

messagelock

ast_mutex_t messagelock

static

Definition at line 523 of file res_xmpp.c.

Referenced by acf_jabberreceive_read(), load_module(), unload_module(), and xmpp_pak_message().

msg_tech

const struct ast_msg_tech msg_tech

static

Initial value:

= {
    .name = "xmpp",
    .msg_send = xmpp_send_cb,
}

Definition at line 2157 of file res_xmpp.c.

Referenced by load_module(), and unload_module().

res_xmpp_conf

struct aco_file res_xmpp_conf

Initial value:

= {
    .filename = "xmpp.conf",
    .alias = "jabber.conf",
    .types = ACO_TYPES(&global_option, &client_option),
}

Definition at line 823 of file res_xmpp.c.

xmpp_cli

struct ast_cli_entry xmpp_cli[]

static

Definition at line 4470 of file res_xmpp.c.

Referenced by load_module(), and unload_module().

xmpp_pak_handlers

const struct xmpp_pak_handler xmpp_pak_handlers[]

static

Initial value:

= {
    { IKS_PAK_MESSAGE, xmpp_pak_message, },
    { IKS_PAK_PRESENCE, xmpp_pak_presence, },
    { IKS_PAK_S10N, xmpp_pak_s10n, },
}

Referenced by xmpp_action_hook().

xmpp_state_handlers

const struct xmpp_state_handler xmpp_state_handlers[]

static

Referenced by xmpp_action_hook().