1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807 |
- /*
- * Asterisk -- An open source telephony toolkit.
- *
- * Copyright (C) 2013, Digium, Inc.
- *
- * Matt Jordan <mjordan@digium.com>
- *
- * See http://www.asterisk.org for more information about
- * the Asterisk project. Please do not directly contact
- * any of the maintainers of this project for assistance;
- * the project provides a web site, mailing lists and IRC
- * channels for your use.
- *
- * This program is free software, distributed under the terms of
- * the GNU General Public License Version 2. See the LICENSE file
- * at the top of the source tree.
- */
- /*! \file
- *
- * \brief Stasis Messages and Data Types for Channel Objects
- *
- * \author \verbatim Matt Jordan <mjordan@digium.com> \endverbatim
- *
- */
- /*** MODULEINFO
- <support_level>core</support_level>
- ***/
- #include "asterisk.h"
- ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
- #include "asterisk/astobj2.h"
- #include "asterisk/json.h"
- #include "asterisk/pbx.h"
- #include "asterisk/bridge.h"
- #include "asterisk/translate.h"
- #include "asterisk/stasis.h"
- #include "asterisk/stasis_cache_pattern.h"
- #include "asterisk/stasis_channels.h"
- #include "asterisk/dial.h"
- #include "asterisk/linkedlists.h"
- /*** DOCUMENTATION
- <managerEvent language="en_US" name="VarSet">
- <managerEventInstance class="EVENT_FLAG_DIALPLAN">
- <synopsis>Raised when a variable is set to a particular value.</synopsis>
- <syntax>
- <channel_snapshot/>
- <parameter name="Variable">
- <para>The variable being set.</para>
- </parameter>
- <parameter name="Value">
- <para>The new value of the variable.</para>
- </parameter>
- </syntax>
- </managerEventInstance>
- </managerEvent>
- <managerEvent language="en_US" name="AgentLogin">
- <managerEventInstance class="EVENT_FLAG_AGENT">
- <synopsis>Raised when an Agent has logged in.</synopsis>
- <syntax>
- <channel_snapshot/>
- <parameter name="Agent">
- <para>Agent ID of the agent.</para>
- </parameter>
- </syntax>
- <see-also>
- <ref type="application">AgentLogin</ref>
- <ref type="managerEvent">AgentLogoff</ref>
- </see-also>
- </managerEventInstance>
- </managerEvent>
- <managerEvent language="en_US" name="AgentLogoff">
- <managerEventInstance class="EVENT_FLAG_AGENT">
- <synopsis>Raised when an Agent has logged off.</synopsis>
- <syntax>
- <xi:include xpointer="xpointer(/docs/managerEvent[@name='AgentLogin']/managerEventInstance/syntax/parameter)" />
- <parameter name="Logintime">
- <para>The number of seconds the agent was logged in.</para>
- </parameter>
- </syntax>
- <see-also>
- <ref type="managerEvent">AgentLogin</ref>
- </see-also>
- </managerEventInstance>
- </managerEvent>
- <managerEvent language="en_US" name="ChannelTalkingStart">
- <managerEventInstance class="EVENT_FLAG_CLASS">
- <synopsis>Raised when talking is detected on a channel.</synopsis>
- <syntax>
- <channel_snapshot/>
- </syntax>
- <see-also>
- <ref type="function">TALK_DETECT</ref>
- <ref type="managerEvent">ChannelTalkingStop</ref>
- </see-also>
- </managerEventInstance>
- </managerEvent>
- <managerEvent language="en_US" name="ChannelTalkingStop">
- <managerEventInstance class="EVENT_FLAG_CLASS">
- <synopsis>Raised when talking is no longer detected on a channel.</synopsis>
- <syntax>
- <channel_snapshot/>
- <parameter name="Duration">
- <para>The length in time, in milliseconds, that talking was
- detected on the channel.</para>
- </parameter>
- </syntax>
- <see-also>
- <ref type="function">TALK_DETECT</ref>
- <ref type="managerEvent">ChannelTalkingStart</ref>
- </see-also>
- </managerEventInstance>
- </managerEvent>
- ***/
- #define NUM_MULTI_CHANNEL_BLOB_BUCKETS 7
- static struct stasis_cp_all *channel_cache_all;
- static struct stasis_cache *channel_cache_by_name;
- static struct stasis_caching_topic *channel_by_name_topic;
- struct stasis_cp_all *ast_channel_cache_all(void)
- {
- return channel_cache_all;
- }
- struct stasis_cache *ast_channel_cache(void)
- {
- return stasis_cp_all_cache(channel_cache_all);
- }
- struct stasis_topic *ast_channel_topic_all(void)
- {
- return stasis_cp_all_topic(channel_cache_all);
- }
- struct stasis_topic *ast_channel_topic_all_cached(void)
- {
- return stasis_cp_all_topic_cached(channel_cache_all);
- }
- struct stasis_cache *ast_channel_cache_by_name(void)
- {
- return channel_cache_by_name;
- }
- static const char *channel_snapshot_get_id(struct stasis_message *message)
- {
- struct ast_channel_snapshot *snapshot;
- if (ast_channel_snapshot_type() != stasis_message_type(message)) {
- return NULL;
- }
- snapshot = stasis_message_data(message);
- return snapshot->uniqueid;
- }
- static const char *channel_snapshot_get_name(struct stasis_message *message)
- {
- struct ast_channel_snapshot *snapshot;
- if (ast_channel_snapshot_type() != stasis_message_type(message)) {
- return NULL;
- }
- snapshot = stasis_message_data(message);
- return snapshot->name;
- }
- /*!
- * \internal
- * \brief Hash function for \ref ast_channel_snapshot objects
- */
- static int channel_snapshot_hash_cb(const void *obj, const int flags)
- {
- const struct ast_channel_snapshot *object = obj;
- const char *key;
- switch (flags & OBJ_SEARCH_MASK) {
- case OBJ_SEARCH_KEY:
- key = obj;
- break;
- case OBJ_SEARCH_OBJECT:
- key = object->name;
- break;
- default:
- ast_assert(0);
- return 0;
- }
- return ast_str_case_hash(key);
- }
- /*!
- * \internal
- * \brief Comparison function for \ref ast_channel_snapshot objects
- */
- static int channel_snapshot_cmp_cb(void *obj, void *arg, int flags)
- {
- const struct ast_channel_snapshot *object_left = obj;
- const struct ast_channel_snapshot *object_right = arg;
- const char *right_key = arg;
- int cmp;
- switch (flags & OBJ_SEARCH_MASK) {
- case OBJ_SEARCH_OBJECT:
- right_key = object_right->name;
- case OBJ_SEARCH_KEY:
- cmp = strcasecmp(object_left->name, right_key);
- break;
- case OBJ_SEARCH_PARTIAL_KEY:
- cmp = strncasecmp(object_left->name, right_key, strlen(right_key));
- break;
- default:
- cmp = 0;
- break;
- }
- if (cmp) {
- return 0;
- }
- return CMP_MATCH;
- }
- static void channel_snapshot_dtor(void *obj)
- {
- struct ast_channel_snapshot *snapshot = obj;
- ast_string_field_free_memory(snapshot);
- ao2_cleanup(snapshot->manager_vars);
- }
- struct ast_channel_snapshot *ast_channel_snapshot_create(struct ast_channel *chan)
- {
- struct ast_channel_snapshot *snapshot;
- struct ast_bridge *bridge;
- /* no snapshots for dummy channels */
- if (!ast_channel_tech(chan)) {
- return NULL;
- }
- snapshot = ao2_alloc_options(sizeof(*snapshot), channel_snapshot_dtor,
- AO2_ALLOC_OPT_LOCK_NOLOCK);
- if (!snapshot || ast_string_field_init(snapshot, 1024)) {
- ao2_cleanup(snapshot);
- return NULL;
- }
- ast_string_field_set(snapshot, name, ast_channel_name(chan));
- ast_string_field_set(snapshot, type, ast_channel_tech(chan)->type);
- ast_string_field_set(snapshot, accountcode, ast_channel_accountcode(chan));
- ast_string_field_set(snapshot, peeraccount, ast_channel_peeraccount(chan));
- ast_string_field_set(snapshot, userfield, ast_channel_userfield(chan));
- ast_string_field_set(snapshot, uniqueid, ast_channel_uniqueid(chan));
- ast_string_field_set(snapshot, linkedid, ast_channel_linkedid(chan));
- ast_string_field_set(snapshot, hangupsource, ast_channel_hangupsource(chan));
- if (ast_channel_appl(chan)) {
- ast_string_field_set(snapshot, appl, ast_channel_appl(chan));
- }
- if (ast_channel_data(chan)) {
- ast_string_field_set(snapshot, data, ast_channel_data(chan));
- }
- ast_string_field_set(snapshot, context, ast_channel_context(chan));
- ast_string_field_set(snapshot, exten, ast_channel_exten(chan));
- ast_string_field_set(snapshot, caller_name,
- S_COR(ast_channel_caller(chan)->id.name.valid, ast_channel_caller(chan)->id.name.str, ""));
- ast_string_field_set(snapshot, caller_number,
- S_COR(ast_channel_caller(chan)->id.number.valid, ast_channel_caller(chan)->id.number.str, ""));
- ast_string_field_set(snapshot, caller_subaddr,
- S_COR(ast_channel_caller(chan)->id.subaddress.valid, ast_channel_caller(chan)->id.subaddress.str, ""));
- ast_string_field_set(snapshot, caller_ani,
- S_COR(ast_channel_caller(chan)->ani.number.valid, ast_channel_caller(chan)->ani.number.str, ""));
- ast_string_field_set(snapshot, caller_rdnis,
- S_COR(ast_channel_redirecting(chan)->from.number.valid, ast_channel_redirecting(chan)->from.number.str, ""));
- ast_string_field_set(snapshot, caller_dnid,
- S_OR(ast_channel_dialed(chan)->number.str, ""));
- ast_string_field_set(snapshot, dialed_subaddr,
- S_COR(ast_channel_dialed(chan)->subaddress.valid, ast_channel_dialed(chan)->subaddress.str, ""));
- ast_string_field_set(snapshot, connected_name,
- S_COR(ast_channel_connected(chan)->id.name.valid, ast_channel_connected(chan)->id.name.str, ""));
- ast_string_field_set(snapshot, connected_number,
- S_COR(ast_channel_connected(chan)->id.number.valid, ast_channel_connected(chan)->id.number.str, ""));
- ast_string_field_set(snapshot, language, ast_channel_language(chan));
- if ((bridge = ast_channel_get_bridge(chan))) {
- ast_string_field_set(snapshot, bridgeid, bridge->uniqueid);
- ao2_cleanup(bridge);
- }
- snapshot->creationtime = ast_channel_creationtime(chan);
- snapshot->state = ast_channel_state(chan);
- snapshot->priority = ast_channel_priority(chan);
- snapshot->amaflags = ast_channel_amaflags(chan);
- snapshot->hangupcause = ast_channel_hangupcause(chan);
- ast_copy_flags(&snapshot->flags, ast_channel_flags(chan), 0xFFFFFFFF);
- snapshot->caller_pres = ast_party_id_presentation(&ast_channel_caller(chan)->id);
- ast_set_flag(&snapshot->softhangup_flags, ast_channel_softhangup_internal_flag(chan));
- snapshot->manager_vars = ast_channel_get_manager_vars(chan);
- snapshot->tech_properties = ast_channel_tech(chan)->properties;
- return snapshot;
- }
- static void publish_message_for_channel_topics(struct stasis_message *message, struct ast_channel *chan)
- {
- if (chan) {
- stasis_publish(ast_channel_topic(chan), message);
- } else {
- stasis_publish(ast_channel_topic_all(), message);
- }
- }
- static void channel_blob_dtor(void *obj)
- {
- struct ast_channel_blob *event = obj;
- ao2_cleanup(event->snapshot);
- ast_json_unref(event->blob);
- }
- static void ast_channel_publish_dial_internal(struct ast_channel *caller,
- struct ast_channel *peer, struct ast_channel *forwarded, const char *dialstring,
- const char *dialstatus, const char *forward)
- {
- struct ast_multi_channel_blob *payload;
- struct stasis_message *msg;
- struct ast_json *blob;
- struct ast_channel_snapshot *peer_snapshot;
- if (!ast_channel_dial_type()) {
- return;
- }
- ast_assert(peer != NULL);
- blob = ast_json_pack("{s: s, s: s, s: s}",
- "dialstatus", S_OR(dialstatus, ""),
- "forward", S_OR(forward, ""),
- "dialstring", S_OR(dialstring, ""));
- if (!blob) {
- return;
- }
- payload = ast_multi_channel_blob_create(blob);
- ast_json_unref(blob);
- if (!payload) {
- return;
- }
- if (caller) {
- struct ast_channel_snapshot *caller_snapshot;
- ast_channel_lock(caller);
- if (ast_strlen_zero(dialstatus)) {
- caller_snapshot = ast_channel_snapshot_get_latest(ast_channel_uniqueid(caller));
- } else {
- caller_snapshot = ast_channel_snapshot_create(caller);
- }
- ast_channel_unlock(caller);
- if (!caller_snapshot) {
- ao2_ref(payload, -1);
- return;
- }
- ast_multi_channel_blob_add_channel(payload, "caller", caller_snapshot);
- ao2_ref(caller_snapshot, -1);
- }
- ast_channel_lock(peer);
- if (ast_strlen_zero(dialstatus)) {
- peer_snapshot = ast_channel_snapshot_get_latest(ast_channel_uniqueid(peer));
- } else {
- peer_snapshot = ast_channel_snapshot_create(peer);
- }
- ast_channel_unlock(peer);
- if (!peer_snapshot) {
- ao2_ref(payload, -1);
- return;
- }
- ast_multi_channel_blob_add_channel(payload, "peer", peer_snapshot);
- ao2_ref(peer_snapshot, -1);
- if (forwarded) {
- struct ast_channel_snapshot *forwarded_snapshot;
- ast_channel_lock(forwarded);
- forwarded_snapshot = ast_channel_snapshot_create(forwarded);
- ast_channel_unlock(forwarded);
- if (!forwarded_snapshot) {
- ao2_ref(payload, -1);
- return;
- }
- ast_multi_channel_blob_add_channel(payload, "forwarded", forwarded_snapshot);
- ao2_ref(forwarded_snapshot, -1);
- }
- msg = stasis_message_create(ast_channel_dial_type(), payload);
- ao2_ref(payload, -1);
- if (msg) {
- publish_message_for_channel_topics(msg, caller);
- ao2_ref(msg, -1);
- }
- }
- static void remove_dial_masquerade(struct ast_channel *peer);
- static void remove_dial_masquerade_caller(struct ast_channel *caller);
- static int set_dial_masquerade(struct ast_channel *caller,
- struct ast_channel *peer, const char *dialstring);
- void ast_channel_publish_dial_forward(struct ast_channel *caller, struct ast_channel *peer,
- struct ast_channel *forwarded, const char *dialstring, const char *dialstatus,
- const char *forward)
- {
- ast_assert(peer != NULL);
- /* XXX With an early bridge the below dial masquerade datastore code could, theoretically,
- * go away as the act of changing the channel during dialing would be done using the bridge
- * API itself and not a masquerade.
- */
- if (caller) {
- /*
- * Lock two or three channels.
- *
- * We need to hold the locks to hold off a potential masquerade
- * messing up the stasis dial event ordering.
- */
- for (;; ast_channel_unlock(caller), sched_yield()) {
- ast_channel_lock(caller);
- if (ast_channel_trylock(peer)) {
- continue;
- }
- if (forwarded && ast_channel_trylock(forwarded)) {
- ast_channel_unlock(peer);
- continue;
- }
- break;
- }
- if (ast_strlen_zero(dialstatus)) {
- set_dial_masquerade(caller, peer, dialstring);
- } else {
- remove_dial_masquerade(peer);
- }
- }
- ast_channel_publish_dial_internal(caller, peer, forwarded, dialstring, dialstatus,
- forward);
- if (caller) {
- if (forwarded) {
- ast_channel_unlock(forwarded);
- }
- ast_channel_unlock(peer);
- remove_dial_masquerade_caller(caller);
- ast_channel_unlock(caller);
- }
- }
- void ast_channel_publish_dial(struct ast_channel *caller, struct ast_channel *peer,
- const char *dialstring, const char *dialstatus)
- {
- ast_channel_publish_dial_forward(caller, peer, NULL, dialstring, dialstatus, NULL);
- }
- static struct stasis_message *create_channel_blob_message(struct ast_channel_snapshot *snapshot,
- struct stasis_message_type *type,
- struct ast_json *blob)
- {
- struct stasis_message *msg;
- struct ast_channel_blob *obj;
- obj = ao2_alloc(sizeof(*obj), channel_blob_dtor);
- if (!obj) {
- return NULL;
- }
- if (snapshot) {
- obj->snapshot = snapshot;
- ao2_ref(obj->snapshot, +1);
- }
- if (!blob) {
- blob = ast_json_null();
- }
- obj->blob = ast_json_ref(blob);
- msg = stasis_message_create(type, obj);
- ao2_cleanup(obj);
- return msg;
- }
- struct stasis_message *ast_channel_blob_create_from_cache(const char *channel_id,
- struct stasis_message_type *type,
- struct ast_json *blob)
- {
- struct ast_channel_snapshot *snapshot;
- struct stasis_message *msg;
- if (!type) {
- return NULL;
- }
- snapshot = ast_channel_snapshot_get_latest(channel_id);
- msg = create_channel_blob_message(snapshot, type, blob);
- ao2_cleanup(snapshot);
- return msg;
- }
- struct stasis_message *ast_channel_blob_create(struct ast_channel *chan,
- struct stasis_message_type *type, struct ast_json *blob)
- {
- struct ast_channel_snapshot *snapshot;
- struct stasis_message *msg;
- if (!type) {
- return NULL;
- }
- snapshot = chan ? ast_channel_snapshot_create(chan) : NULL;
- msg = create_channel_blob_message(snapshot, type, blob);
- ao2_cleanup(snapshot);
- return msg;
- }
- /*! \brief A channel snapshot wrapper object used in \ref ast_multi_channel_blob objects */
- struct channel_role_snapshot {
- struct ast_channel_snapshot *snapshot; /*!< A channel snapshot */
- char role[0]; /*!< The role assigned to the channel */
- };
- /*! \brief A multi channel blob data structure for multi_channel_blob stasis messages */
- struct ast_multi_channel_blob {
- struct ao2_container *channel_snapshots; /*!< A container holding the snapshots */
- struct ast_json *blob; /*!< A blob of JSON data */
- };
- /*!
- * \internal
- * \brief Comparison function for \ref channel_role_snapshot objects
- */
- static int channel_role_cmp_cb(void *obj, void *arg, int flags)
- {
- const struct channel_role_snapshot *object_left = obj;
- const struct channel_role_snapshot *object_right = arg;
- const char *right_key = arg;
- int cmp;
- switch (flags & OBJ_SEARCH_MASK) {
- case OBJ_SEARCH_OBJECT:
- right_key = object_right->role;
- case OBJ_SEARCH_KEY:
- cmp = strcasecmp(object_left->role, right_key);
- break;
- case OBJ_SEARCH_PARTIAL_KEY:
- cmp = strncasecmp(object_left->role, right_key, strlen(right_key));
- break;
- default:
- cmp = 0;
- break;
- }
- if (cmp) {
- return 0;
- }
- return CMP_MATCH;
- }
- /*!
- * \internal
- * \brief Hash function for \ref channel_role_snapshot objects
- */
- static int channel_role_hash_cb(const void *obj, const int flags)
- {
- const struct channel_role_snapshot *object = obj;
- const char *key;
- switch (flags & OBJ_SEARCH_MASK) {
- case OBJ_SEARCH_KEY:
- key = obj;
- break;
- case OBJ_SEARCH_OBJECT:
- key = object->role;
- break;
- default:
- ast_assert(0);
- return 0;
- }
- return ast_str_case_hash(key);
- }
- /*!
- * \internal
- * \brief Destructor for \ref ast_multi_channel_blob objects
- */
- static void multi_channel_blob_dtor(void *obj)
- {
- struct ast_multi_channel_blob *multi_blob = obj;
- ao2_cleanup(multi_blob->channel_snapshots);
- ast_json_unref(multi_blob->blob);
- }
- struct ast_multi_channel_blob *ast_multi_channel_blob_create(struct ast_json *blob)
- {
- struct ast_multi_channel_blob *obj;
- ast_assert(blob != NULL);
- obj = ao2_alloc(sizeof(*obj), multi_channel_blob_dtor);
- if (!obj) {
- return NULL;
- }
- obj->channel_snapshots = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
- NUM_MULTI_CHANNEL_BLOB_BUCKETS, channel_role_hash_cb, NULL, channel_role_cmp_cb);
- if (!obj->channel_snapshots) {
- ao2_ref(obj, -1);
- return NULL;
- }
- obj->blob = ast_json_ref(blob);
- return obj;
- }
- struct ast_channel_snapshot *ast_channel_snapshot_get_latest(const char *uniqueid)
- {
- struct stasis_message *message;
- struct ast_channel_snapshot *snapshot;
- ast_assert(!ast_strlen_zero(uniqueid));
- message = stasis_cache_get(ast_channel_cache(), ast_channel_snapshot_type(),
- uniqueid);
- if (!message) {
- return NULL;
- }
- snapshot = ao2_bump(stasis_message_data(message));
- ao2_ref(message, -1);
- return snapshot;
- }
- struct ast_channel_snapshot *ast_channel_snapshot_get_latest_by_name(const char *name)
- {
- struct stasis_message *message;
- struct ast_channel_snapshot *snapshot;
- ast_assert(!ast_strlen_zero(name));
- message = stasis_cache_get(ast_channel_cache_by_name(), ast_channel_snapshot_type(),
- name);
- if (!message) {
- return NULL;
- }
- snapshot = ao2_bump(stasis_message_data(message));
- ao2_ref(message, -1);
- return snapshot;
- }
- static void channel_role_snapshot_dtor(void *obj)
- {
- struct channel_role_snapshot *role_snapshot = obj;
- ao2_cleanup(role_snapshot->snapshot);
- }
- void ast_multi_channel_blob_add_channel(struct ast_multi_channel_blob *obj, const char *role, struct ast_channel_snapshot *snapshot)
- {
- struct channel_role_snapshot *role_snapshot;
- int role_len = strlen(role) + 1;
- if (!obj || ast_strlen_zero(role) || !snapshot) {
- return;
- }
- role_snapshot = ao2_alloc_options(sizeof(*role_snapshot) + role_len,
- channel_role_snapshot_dtor, AO2_ALLOC_OPT_LOCK_NOLOCK);
- if (!role_snapshot) {
- return;
- }
- ast_copy_string(role_snapshot->role, role, role_len);
- role_snapshot->snapshot = snapshot;
- ao2_ref(role_snapshot->snapshot, +1);
- ao2_link(obj->channel_snapshots, role_snapshot);
- ao2_ref(role_snapshot, -1);
- }
- struct ast_channel_snapshot *ast_multi_channel_blob_get_channel(struct ast_multi_channel_blob *obj, const char *role)
- {
- struct channel_role_snapshot *role_snapshot;
- struct ast_channel_snapshot *snapshot;
- if (!obj || ast_strlen_zero(role)) {
- return NULL;
- }
- role_snapshot = ao2_find(obj->channel_snapshots, role, OBJ_SEARCH_KEY);
- /* Note that this function does not increase the ref count on snapshot */
- if (!role_snapshot) {
- return NULL;
- }
- snapshot = role_snapshot->snapshot;
- ao2_ref(role_snapshot, -1);
- return snapshot;
- }
- struct ao2_container *ast_multi_channel_blob_get_channels(struct ast_multi_channel_blob *obj, const char *role)
- {
- struct ao2_container *ret_container;
- struct ao2_iterator *it_role_snapshots;
- struct channel_role_snapshot *role_snapshot;
- char *arg;
- if (!obj || ast_strlen_zero(role)) {
- return NULL;
- }
- ret_container = ao2_container_alloc_hash(AO2_ALLOC_OPT_LOCK_MUTEX, 0,
- NUM_MULTI_CHANNEL_BLOB_BUCKETS,
- channel_snapshot_hash_cb, NULL, channel_snapshot_cmp_cb);
- if (!ret_container) {
- return NULL;
- }
- arg = ast_strdupa(role);
- it_role_snapshots = ao2_callback(obj->channel_snapshots,
- OBJ_MULTIPLE | OBJ_SEARCH_KEY, channel_role_cmp_cb, arg);
- if (!it_role_snapshots) {
- ao2_ref(ret_container, -1);
- return NULL;
- }
- while ((role_snapshot = ao2_iterator_next(it_role_snapshots))) {
- ao2_link(ret_container, role_snapshot->snapshot);
- ao2_ref(role_snapshot, -1);
- }
- ao2_iterator_destroy(it_role_snapshots);
- return ret_container;
- }
- struct ast_json *ast_multi_channel_blob_get_json(struct ast_multi_channel_blob *obj)
- {
- if (!obj) {
- return NULL;
- }
- return obj->blob;
- }
- void ast_channel_stage_snapshot(struct ast_channel *chan)
- {
- ast_set_flag(ast_channel_flags(chan), AST_FLAG_SNAPSHOT_STAGE);
- }
- void ast_channel_stage_snapshot_done(struct ast_channel *chan)
- {
- ast_clear_flag(ast_channel_flags(chan), AST_FLAG_SNAPSHOT_STAGE);
- ast_channel_publish_snapshot(chan);
- }
- void ast_channel_publish_snapshot(struct ast_channel *chan)
- {
- struct ast_channel_snapshot *snapshot;
- struct stasis_message *message;
- if (!ast_channel_snapshot_type()) {
- return;
- }
- if (ast_test_flag(ast_channel_flags(chan), AST_FLAG_SNAPSHOT_STAGE)) {
- return;
- }
- snapshot = ast_channel_snapshot_create(chan);
- if (!snapshot) {
- return;
- }
- message = stasis_message_create(ast_channel_snapshot_type(), snapshot);
- ao2_ref(snapshot, -1);
- if (!message) {
- return;
- }
- ast_assert(ast_channel_topic(chan) != NULL);
- stasis_publish(ast_channel_topic(chan), message);
- ao2_ref(message, -1);
- }
- void ast_channel_publish_cached_blob(struct ast_channel *chan, struct stasis_message_type *type, struct ast_json *blob)
- {
- struct stasis_message *message;
- if (!blob) {
- blob = ast_json_null();
- }
- message = ast_channel_blob_create_from_cache(ast_channel_uniqueid(chan), type, blob);
- if (message) {
- stasis_publish(ast_channel_topic(chan), message);
- ao2_ref(message, -1);
- }
- }
- void ast_channel_publish_blob(struct ast_channel *chan, struct stasis_message_type *type, struct ast_json *blob)
- {
- struct stasis_message *message;
- if (!blob) {
- blob = ast_json_null();
- }
- message = ast_channel_blob_create(chan, type, blob);
- if (message) {
- stasis_publish(ast_channel_topic(chan), message);
- ao2_ref(message, -1);
- }
- }
- void ast_channel_publish_varset(struct ast_channel *chan, const char *name, const char *value)
- {
- struct ast_json *blob;
- ast_assert(name != NULL);
- ast_assert(value != NULL);
- blob = ast_json_pack("{s: s, s: s}",
- "variable", name,
- "value", value);
- if (!blob) {
- ast_log(LOG_ERROR, "Error creating message\n");
- return;
- }
- /*! If there are manager variables, force a cache update */
- if (chan && ast_channel_has_manager_vars()) {
- ast_channel_publish_snapshot(chan);
- }
- if (chan) {
- ast_channel_publish_cached_blob(chan, ast_channel_varset_type(), blob);
- } else {
- /* This function is NULL safe for global variables */
- ast_channel_publish_blob(NULL, ast_channel_varset_type(), blob);
- }
- ast_json_unref(blob);
- }
- static struct ast_manager_event_blob *varset_to_ami(struct stasis_message *msg)
- {
- struct ast_str *channel_event_string;
- struct ast_channel_blob *obj = stasis_message_data(msg);
- const char *variable =
- ast_json_string_get(ast_json_object_get(obj->blob, "variable"));
- char *value;
- struct ast_manager_event_blob *ev;
- value = ast_escape_c_alloc(ast_json_string_get(ast_json_object_get(obj->blob,
- "value")));
- if (!value) {
- return NULL;
- }
- if (obj->snapshot) {
- channel_event_string = ast_manager_build_channel_state_string(obj->snapshot);
- } else {
- channel_event_string = ast_str_create(35);
- ast_str_set(&channel_event_string, 0,
- "Channel: none\r\n"
- "Uniqueid: none\r\n");
- }
- if (!channel_event_string) {
- ast_free(value);
- return NULL;
- }
- ev = ast_manager_event_blob_create(EVENT_FLAG_DIALPLAN, "VarSet",
- "%s"
- "Variable: %s\r\n"
- "Value: %s\r\n",
- ast_str_buffer(channel_event_string), variable, value);
- ast_free(channel_event_string);
- ast_free(value);
- return ev;
- }
- static struct ast_manager_event_blob *agent_login_to_ami(struct stasis_message *msg)
- {
- struct ast_str *channel_string;
- struct ast_channel_blob *obj = stasis_message_data(msg);
- const char *agent = ast_json_string_get(ast_json_object_get(obj->blob, "agent"));
- struct ast_manager_event_blob *ev;
- channel_string = ast_manager_build_channel_state_string(obj->snapshot);
- if (!channel_string) {
- return NULL;
- }
- ev = ast_manager_event_blob_create(EVENT_FLAG_AGENT, "AgentLogin",
- "%s"
- "Agent: %s\r\n",
- ast_str_buffer(channel_string), agent);
- ast_free(channel_string);
- return ev;
- }
- static struct ast_manager_event_blob *agent_logoff_to_ami(struct stasis_message *msg)
- {
- struct ast_str *channel_string;
- struct ast_channel_blob *obj = stasis_message_data(msg);
- const char *agent = ast_json_string_get(ast_json_object_get(obj->blob, "agent"));
- long logintime = ast_json_integer_get(ast_json_object_get(obj->blob, "logintime"));
- struct ast_manager_event_blob *ev;
- channel_string = ast_manager_build_channel_state_string(obj->snapshot);
- if (!channel_string) {
- return NULL;
- }
- ev = ast_manager_event_blob_create(EVENT_FLAG_AGENT, "AgentLogoff",
- "%s"
- "Agent: %s\r\n"
- "Logintime: %ld\r\n",
- ast_str_buffer(channel_string), agent, logintime);
- ast_free(channel_string);
- return ev;
- }
- void ast_publish_channel_state(struct ast_channel *chan)
- {
- struct ast_channel_snapshot *snapshot;
- struct stasis_message *message;
- if (!ast_channel_snapshot_type()) {
- return;
- }
- ast_assert(chan != NULL);
- if (!chan) {
- return;
- }
- snapshot = ast_channel_snapshot_create(chan);
- if (!snapshot) {
- return;
- }
- message = stasis_message_create(ast_channel_snapshot_type(), snapshot);
- ao2_ref(snapshot, -1);
- if (!message) {
- return;
- }
- ast_assert(ast_channel_topic(chan) != NULL);
- stasis_publish(ast_channel_topic(chan), message);
- ao2_ref(message, -1);
- }
- struct ast_json *ast_channel_snapshot_to_json(
- const struct ast_channel_snapshot *snapshot,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_json *json_chan;
- if (snapshot == NULL
- || (sanitize
- && sanitize->channel_snapshot
- && sanitize->channel_snapshot(snapshot))) {
- return NULL;
- }
- json_chan = ast_json_pack(
- /* Broken up into groups of three for readability */
- "{ s: s, s: s, s: s,"
- " s: o, s: o, s: s,"
- " s: o, s: o, s: s }",
- /* First line */
- "id", snapshot->uniqueid,
- "name", snapshot->name,
- "state", ast_state2str(snapshot->state),
- /* Second line */
- "caller", ast_json_name_number(
- snapshot->caller_name, snapshot->caller_number),
- "connected", ast_json_name_number(
- snapshot->connected_name, snapshot->connected_number),
- "accountcode", snapshot->accountcode,
- /* Third line */
- "dialplan", ast_json_dialplan_cep(
- snapshot->context, snapshot->exten, snapshot->priority),
- "creationtime", ast_json_timeval(snapshot->creationtime, NULL),
- "language", snapshot->language);
- return json_chan;
- }
- int ast_channel_snapshot_cep_equal(
- const struct ast_channel_snapshot *old_snapshot,
- const struct ast_channel_snapshot *new_snapshot)
- {
- ast_assert(old_snapshot != NULL);
- ast_assert(new_snapshot != NULL);
- /* We actually get some snapshots with CEP set, but before the
- * application is set. Since empty application is invalid, we treat
- * setting the application from nothing as a CEP change.
- */
- if (ast_strlen_zero(old_snapshot->appl) &&
- !ast_strlen_zero(new_snapshot->appl)) {
- return 0;
- }
- return old_snapshot->priority == new_snapshot->priority &&
- strcmp(old_snapshot->context, new_snapshot->context) == 0 &&
- strcmp(old_snapshot->exten, new_snapshot->exten) == 0;
- }
- int ast_channel_snapshot_caller_id_equal(
- const struct ast_channel_snapshot *old_snapshot,
- const struct ast_channel_snapshot *new_snapshot)
- {
- ast_assert(old_snapshot != NULL);
- ast_assert(new_snapshot != NULL);
- return strcmp(old_snapshot->caller_number, new_snapshot->caller_number) == 0 &&
- strcmp(old_snapshot->caller_name, new_snapshot->caller_name) == 0;
- }
- int ast_channel_snapshot_connected_line_equal(
- const struct ast_channel_snapshot *old_snapshot,
- const struct ast_channel_snapshot *new_snapshot)
- {
- ast_assert(old_snapshot != NULL);
- ast_assert(new_snapshot != NULL);
- return strcmp(old_snapshot->connected_number, new_snapshot->connected_number) == 0 &&
- strcmp(old_snapshot->connected_name, new_snapshot->connected_name) == 0;
- }
- static struct ast_json *channel_blob_to_json(
- struct stasis_message *message,
- const char *type,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_json *to_json;
- struct ast_channel_blob *channel_blob = stasis_message_data(message);
- struct ast_json *blob = channel_blob->blob;
- struct ast_channel_snapshot *snapshot = channel_blob->snapshot;
- const struct timeval *tv = stasis_message_timestamp(message);
- int res = 0;
- if (blob == NULL || ast_json_is_null(blob)) {
- to_json = ast_json_object_create();
- } else {
- /* blobs are immutable, so shallow copies are fine */
- to_json = ast_json_copy(blob);
- }
- if (!to_json) {
- return NULL;
- }
- res |= ast_json_object_set(to_json, "type", ast_json_string_create(type));
- res |= ast_json_object_set(to_json, "timestamp",
- ast_json_timeval(*tv, NULL));
- /* For global channel messages, the snapshot is optional */
- if (snapshot) {
- struct ast_json *json_channel;
- json_channel = ast_channel_snapshot_to_json(snapshot, sanitize);
- if (!json_channel) {
- ast_json_unref(to_json);
- return NULL;
- }
- res |= ast_json_object_set(to_json, "channel", json_channel);
- }
- if (res != 0) {
- ast_json_unref(to_json);
- return NULL;
- }
- return to_json;
- }
- static struct ast_json *dtmf_end_to_json(
- struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_channel_blob *channel_blob = stasis_message_data(message);
- struct ast_json *blob = channel_blob->blob;
- struct ast_channel_snapshot *snapshot = channel_blob->snapshot;
- const char *direction =
- ast_json_string_get(ast_json_object_get(blob, "direction"));
- const char *digit =
- ast_json_string_get(ast_json_object_get(blob, "digit"));
- long duration_ms =
- ast_json_integer_get(ast_json_object_get(blob, "duration_ms"));
- const struct timeval *tv = stasis_message_timestamp(message);
- struct ast_json *json_channel;
- /* Only present received DTMF end events as JSON */
- if (strcasecmp("Received", direction) != 0) {
- return NULL;
- }
- json_channel = ast_channel_snapshot_to_json(snapshot, sanitize);
- if (!json_channel) {
- return NULL;
- }
- return ast_json_pack("{s: s, s: o, s: s, s: i, s: o}",
- "type", "ChannelDtmfReceived",
- "timestamp", ast_json_timeval(*tv, NULL),
- "digit", digit,
- "duration_ms", duration_ms,
- "channel", json_channel);
- }
- static struct ast_json *varset_to_json(
- struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- return channel_blob_to_json(message, "ChannelVarset", sanitize);
- }
- static struct ast_json *hangup_request_to_json(
- struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- return channel_blob_to_json(message, "ChannelHangupRequest", sanitize);
- }
- static struct ast_json *dial_to_json(
- struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_multi_channel_blob *payload = stasis_message_data(message);
- struct ast_json *blob = ast_multi_channel_blob_get_json(payload);
- const char *dialstatus =
- ast_json_string_get(ast_json_object_get(blob, "dialstatus"));
- const char *forward =
- ast_json_string_get(ast_json_object_get(blob, "forward"));
- const char *dialstring =
- ast_json_string_get(ast_json_object_get(blob, "dialstring"));
- struct ast_json *caller_json = ast_channel_snapshot_to_json(ast_multi_channel_blob_get_channel(payload, "caller"), sanitize);
- struct ast_json *peer_json = ast_channel_snapshot_to_json(ast_multi_channel_blob_get_channel(payload, "peer"), sanitize);
- struct ast_json *forwarded_json = ast_channel_snapshot_to_json(ast_multi_channel_blob_get_channel(payload, "forwarded"), sanitize);
- struct ast_json *json;
- const struct timeval *tv = stasis_message_timestamp(message);
- int res = 0;
- json = ast_json_pack("{s: s, s: o, s: s, s: s, s: s}",
- "type", "Dial",
- "timestamp", ast_json_timeval(*tv, NULL),
- "dialstatus", dialstatus,
- "forward", forward,
- "dialstring", dialstring);
- if (!json) {
- ast_json_unref(caller_json);
- ast_json_unref(peer_json);
- ast_json_unref(forwarded_json);
- return NULL;
- }
- if (caller_json) {
- res |= ast_json_object_set(json, "caller", caller_json);
- }
- if (peer_json) {
- res |= ast_json_object_set(json, "peer", peer_json);
- }
- if (forwarded_json) {
- res |= ast_json_object_set(json, "forwarded", forwarded_json);
- }
- if (res) {
- ast_json_unref(json);
- return NULL;
- }
- return json;
- }
- static struct ast_manager_event_blob *talking_start_to_ami(struct stasis_message *msg)
- {
- struct ast_str *channel_string;
- struct ast_channel_blob *obj = stasis_message_data(msg);
- struct ast_manager_event_blob *blob;
- channel_string = ast_manager_build_channel_state_string(obj->snapshot);
- if (!channel_string) {
- return NULL;
- }
- blob = ast_manager_event_blob_create(EVENT_FLAG_CALL, "ChannelTalkingStart",
- "%s", ast_str_buffer(channel_string));
- ast_free(channel_string);
- return blob;
- }
- static struct ast_json *talking_start_to_json(struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- return channel_blob_to_json(message, "ChannelTalkingStarted", sanitize);
- }
- static struct ast_manager_event_blob *talking_stop_to_ami(struct stasis_message *msg)
- {
- struct ast_str *channel_string;
- struct ast_channel_blob *obj = stasis_message_data(msg);
- int duration = ast_json_integer_get(ast_json_object_get(obj->blob, "duration"));
- struct ast_manager_event_blob *blob;
- channel_string = ast_manager_build_channel_state_string(obj->snapshot);
- if (!channel_string) {
- return NULL;
- }
- blob = ast_manager_event_blob_create(EVENT_FLAG_CALL, "ChannelTalkingStop",
- "%s"
- "Duration: %d\r\n",
- ast_str_buffer(channel_string),
- duration);
- ast_free(channel_string);
- return blob;
- }
- static struct ast_json *talking_stop_to_json(struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- return channel_blob_to_json(message, "ChannelTalkingFinished", sanitize);
- }
- static struct ast_json *hold_to_json(struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_channel_blob *channel_blob = stasis_message_data(message);
- struct ast_json *blob = channel_blob->blob;
- struct ast_channel_snapshot *snapshot = channel_blob->snapshot;
- const char *musicclass = ast_json_string_get(ast_json_object_get(blob, "musicclass"));
- const struct timeval *tv = stasis_message_timestamp(message);
- struct ast_json *json_channel;
- json_channel = ast_channel_snapshot_to_json(snapshot, sanitize);
- if (!json_channel) {
- return NULL;
- }
- return ast_json_pack("{s: s, s: o, s: s, s: o}",
- "type", "ChannelHold",
- "timestamp", ast_json_timeval(*tv, NULL),
- "musicclass", S_OR(musicclass, "N/A"),
- "channel", json_channel);
- }
- static struct ast_json *unhold_to_json(struct stasis_message *message,
- const struct stasis_message_sanitizer *sanitize)
- {
- struct ast_channel_blob *channel_blob = stasis_message_data(message);
- struct ast_channel_snapshot *snapshot = channel_blob->snapshot;
- const struct timeval *tv = stasis_message_timestamp(message);
- struct ast_json *json_channel;
- json_channel = ast_channel_snapshot_to_json(snapshot, sanitize);
- if (!json_channel) {
- return NULL;
- }
- return ast_json_pack("{s: s, s: o, s: o}",
- "type", "ChannelUnhold",
- "timestamp", ast_json_timeval(*tv, NULL),
- "channel", json_channel);
- }
- /*!
- * @{ \brief Define channel message types.
- */
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_snapshot_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_dial_type,
- .to_json = dial_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_varset_type,
- .to_ami = varset_to_ami,
- .to_json = varset_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_hangup_request_type,
- .to_json = hangup_request_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_dtmf_begin_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_dtmf_end_type,
- .to_json = dtmf_end_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_hold_type,
- .to_json = hold_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_unhold_type,
- .to_json = unhold_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_chanspy_start_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_chanspy_stop_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_fax_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_hangup_handler_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_moh_start_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_moh_stop_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_monitor_start_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_monitor_stop_type);
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_agent_login_type,
- .to_ami = agent_login_to_ami,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_agent_logoff_type,
- .to_ami = agent_logoff_to_ami,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_talking_start,
- .to_ami = talking_start_to_ami,
- .to_json = talking_start_to_json,
- );
- STASIS_MESSAGE_TYPE_DEFN(ast_channel_talking_stop,
- .to_ami = talking_stop_to_ami,
- .to_json = talking_stop_to_json,
- );
- /*! @} */
- static void stasis_channels_cleanup(void)
- {
- stasis_caching_unsubscribe_and_join(channel_by_name_topic);
- channel_by_name_topic = NULL;
- ao2_cleanup(channel_cache_by_name);
- channel_cache_by_name = NULL;
- ao2_cleanup(channel_cache_all);
- channel_cache_all = NULL;
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_snapshot_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_dial_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_varset_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_hangup_request_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_dtmf_begin_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_dtmf_end_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_hold_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_unhold_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_chanspy_start_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_chanspy_stop_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_fax_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_hangup_handler_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_moh_start_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_moh_stop_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_monitor_start_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_monitor_stop_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_agent_login_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_agent_logoff_type);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_talking_start);
- STASIS_MESSAGE_TYPE_CLEANUP(ast_channel_talking_stop);
- }
- int ast_stasis_channels_init(void)
- {
- int res = 0;
- ast_register_cleanup(stasis_channels_cleanup);
- channel_cache_all = stasis_cp_all_create("ast_channel_topic_all",
- channel_snapshot_get_id);
- if (!channel_cache_all) {
- return -1;
- }
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_login_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_agent_logoff_type);
- channel_cache_by_name = stasis_cache_create(channel_snapshot_get_name);
- if (!channel_cache_by_name) {
- return -1;
- }
- /* This should be initialized before the caching topic */
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_snapshot_type);
- channel_by_name_topic = stasis_caching_topic_create(
- stasis_cp_all_topic(channel_cache_all),
- channel_cache_by_name);
- if (!channel_by_name_topic) {
- return -1;
- }
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_dial_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_varset_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_hangup_request_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_dtmf_begin_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_dtmf_end_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_hold_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_unhold_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_chanspy_start_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_chanspy_stop_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_fax_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_hangup_handler_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_moh_start_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_moh_stop_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_monitor_start_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_monitor_stop_type);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_talking_start);
- res |= STASIS_MESSAGE_TYPE_INIT(ast_channel_talking_stop);
- return res;
- }
- /*!
- * \internal
- * \brief A list element for the dial_masquerade_datastore -- stores data about a dialed peer
- */
- struct dial_target {
- /*! Called party channel. */
- struct ast_channel *peer;
- /*! Dialstring used to call the peer. */
- char *dialstring;
- /*! Next entry in the list. */
- AST_LIST_ENTRY(dial_target) list;
- };
- static void dial_target_free(struct dial_target *doomed)
- {
- if (!doomed) {
- return;
- }
- ast_free(doomed->dialstring);
- ast_channel_cleanup(doomed->peer);
- ast_free(doomed);
- }
- /*!
- * \internal
- * \brief Datastore used for advancing dial state in the case of a masquerade
- * against a channel in the process of dialing.
- */
- struct dial_masquerade_datastore {
- /*! Calling party channel. */
- struct ast_channel *caller;
- /*! List of called peers. */
- AST_LIST_HEAD_NOLOCK(, dial_target) dialed_peers;
- };
- static void dial_masquerade_datastore_cleanup(struct dial_masquerade_datastore *masq_data)
- {
- struct dial_target *cur;
- while ((cur = AST_LIST_REMOVE_HEAD(&masq_data->dialed_peers, list))) {
- dial_target_free(cur);
- }
- }
- static void dial_masquerade_datastore_remove_chan(struct dial_masquerade_datastore *masq_data, struct ast_channel *chan)
- {
- struct dial_target *cur;
- ao2_lock(masq_data);
- if (masq_data->caller == chan) {
- dial_masquerade_datastore_cleanup(masq_data);
- } else {
- AST_LIST_TRAVERSE_SAFE_BEGIN(&masq_data->dialed_peers, cur, list) {
- if (cur->peer == chan) {
- AST_LIST_REMOVE_CURRENT(list);
- dial_target_free(cur);
- break;
- }
- }
- AST_LIST_TRAVERSE_SAFE_END;
- }
- ao2_unlock(masq_data);
- }
- static void dial_masquerade_datastore_dtor(void *vdoomed)
- {
- dial_masquerade_datastore_cleanup(vdoomed);
- }
- static struct dial_masquerade_datastore *dial_masquerade_datastore_alloc(void)
- {
- struct dial_masquerade_datastore *masq_data;
- masq_data = ao2_alloc(sizeof(struct dial_masquerade_datastore),
- dial_masquerade_datastore_dtor);
- if (!masq_data) {
- return NULL;
- }
- AST_LIST_HEAD_INIT_NOLOCK(&masq_data->dialed_peers);
- return masq_data;
- }
- /*!
- * \internal
- * \brief Datastore destructor for dial_masquerade_datastore
- */
- static void dial_masquerade_datastore_destroy(void *data)
- {
- ao2_ref(data, -1);
- }
- /*!
- * \internal
- * \brief Datastore destructor for dial_masquerade_datastore
- */
- static void dial_masquerade_caller_datastore_destroy(void *data)
- {
- dial_masquerade_datastore_cleanup(data);
- ao2_ref(data, -1);
- }
- static struct ast_datastore *dial_masquerade_datastore_find(struct ast_channel *chan);
- static void dial_masquerade_fixup(void *data, struct ast_channel *old_chan, struct ast_channel *new_chan)
- {
- struct dial_masquerade_datastore *masq_data = data;
- struct dial_target *cur;
- struct ast_datastore *datastore;
- ao2_lock(masq_data);
- if (!masq_data->caller) {
- /* Nothing to do but remove the datastore */
- } else if (masq_data->caller == old_chan) {
- /* The caller channel is being masqueraded out. */
- ast_debug(1, "Caller channel %s being masqueraded out to %s (is_empty:%d)\n",
- ast_channel_name(new_chan), ast_channel_name(old_chan),
- AST_LIST_EMPTY(&masq_data->dialed_peers));
- AST_LIST_TRAVERSE(&masq_data->dialed_peers, cur, list) {
- ast_channel_publish_dial_internal(new_chan, cur->peer, NULL,
- cur->dialstring, "NOANSWER", NULL);
- ast_channel_publish_dial_internal(old_chan, cur->peer, NULL,
- cur->dialstring, NULL, NULL);
- }
- dial_masquerade_datastore_cleanup(masq_data);
- } else {
- /* One of the peer channels is being masqueraded out. */
- AST_LIST_TRAVERSE_SAFE_BEGIN(&masq_data->dialed_peers, cur, list) {
- if (cur->peer == old_chan) {
- ast_debug(1, "Peer channel %s being masqueraded out to %s\n",
- ast_channel_name(new_chan), ast_channel_name(old_chan));
- ast_channel_publish_dial_internal(masq_data->caller, new_chan, NULL,
- cur->dialstring, "CANCEL", NULL);
- ast_channel_publish_dial_internal(masq_data->caller, old_chan, NULL,
- cur->dialstring, NULL, NULL);
- AST_LIST_REMOVE_CURRENT(list);
- dial_target_free(cur);
- break;
- }
- }
- AST_LIST_TRAVERSE_SAFE_END;
- }
- ao2_unlock(masq_data);
- /* Remove the datastore from the channel. */
- datastore = dial_masquerade_datastore_find(old_chan);
- if (!datastore) {
- return;
- }
- ast_channel_datastore_remove(old_chan, datastore);
- ast_datastore_free(datastore);
- }
- /*!
- * \internal
- * \brief Primary purpose for dial_masquerade_datastore, publishes
- * the channel dial event needed to set the incoming channel into the
- * dial state during a masquerade.
- * \param data pointer to the dial_masquerade_datastore
- * \param old_chan Channel being replaced
- * \param new_chan Channel being pushed to dial mode
- */
- static void dial_masquerade_breakdown(void *data, struct ast_channel *old_chan, struct ast_channel *new_chan)
- {
- struct dial_masquerade_datastore *masq_data = data;
- struct dial_target *cur;
- ao2_lock(masq_data);
- if (!masq_data->caller) {
- ao2_unlock(masq_data);
- return;
- }
- if (masq_data->caller == new_chan) {
- /*
- * The caller channel is being masqueraded into.
- * The masquerade is likely because of a blonde transfer.
- */
- ast_debug(1, "Caller channel %s being masqueraded into by %s (is_empty:%d)\n",
- ast_channel_name(old_chan), ast_channel_name(new_chan),
- AST_LIST_EMPTY(&masq_data->dialed_peers));
- AST_LIST_TRAVERSE(&masq_data->dialed_peers, cur, list) {
- ast_channel_publish_dial_internal(old_chan, cur->peer, NULL,
- cur->dialstring, "NOANSWER", NULL);
- ast_channel_publish_dial_internal(new_chan, cur->peer, NULL,
- cur->dialstring, NULL, NULL);
- }
- ao2_unlock(masq_data);
- return;
- }
- /*
- * One of the peer channels is being masqueraded into.
- * The masquerade is likely because of a call pickup.
- */
- AST_LIST_TRAVERSE(&masq_data->dialed_peers, cur, list) {
- if (cur->peer == new_chan) {
- ast_debug(1, "Peer channel %s being masqueraded into by %s\n",
- ast_channel_name(old_chan), ast_channel_name(new_chan));
- ast_channel_publish_dial_internal(masq_data->caller, old_chan, NULL,
- cur->dialstring, "CANCEL", NULL);
- ast_channel_publish_dial_internal(masq_data->caller, new_chan, NULL,
- cur->dialstring, NULL, NULL);
- break;
- }
- }
- ao2_unlock(masq_data);
- }
- static const struct ast_datastore_info dial_masquerade_info = {
- .type = "stasis-chan-dial-masq",
- .destroy = dial_masquerade_datastore_destroy,
- .chan_fixup = dial_masquerade_fixup,
- .chan_breakdown = dial_masquerade_breakdown,
- };
- static const struct ast_datastore_info dial_masquerade_caller_info = {
- .type = "stasis-chan-dial-masq",
- .destroy = dial_masquerade_caller_datastore_destroy,
- .chan_fixup = dial_masquerade_fixup,
- .chan_breakdown = dial_masquerade_breakdown,
- };
- /*!
- * \internal
- * \brief Find the dial masquerade datastore on the given channel.
- *
- * \param chan Channel a datastore data is wanted from
- *
- * \return A pointer to the datastore if it exists.
- */
- static struct ast_datastore *dial_masquerade_datastore_find(struct ast_channel *chan)
- {
- struct ast_datastore *datastore;
- datastore = ast_channel_datastore_find(chan, &dial_masquerade_info, NULL);
- if (!datastore) {
- datastore = ast_channel_datastore_find(chan, &dial_masquerade_caller_info, NULL);
- }
- return datastore;
- }
- /*!
- * \internal
- * \brief Add the dial masquerade datastore to a channel.
- *
- * \param chan Channel to setup dial masquerade datastore on.
- * \param masq_data NULL to setup caller datastore otherwise steals the ref on success.
- *
- * \retval masq_data given or created on success.
- * (A ref is not returned but can be obtained before chan is unlocked.)
- * \retval NULL on error. masq_data ref is not stolen.
- */
- static struct dial_masquerade_datastore *dial_masquerade_datastore_add(
- struct ast_channel *chan, struct dial_masquerade_datastore *masq_data)
- {
- struct ast_datastore *datastore;
- datastore = ast_datastore_alloc(!masq_data ? &dial_masquerade_caller_info : &dial_masquerade_info, NULL);
- if (!datastore) {
- return NULL;
- }
- if (!masq_data) {
- masq_data = dial_masquerade_datastore_alloc();
- if (!masq_data) {
- ast_datastore_free(datastore);
- return NULL;
- }
- masq_data->caller = chan;
- }
- datastore->data = masq_data;
- ast_channel_datastore_add(chan, datastore);
- return masq_data;
- }
- static int set_dial_masquerade(struct ast_channel *caller, struct ast_channel *peer, const char *dialstring)
- {
- struct ast_datastore *datastore;
- struct dial_masquerade_datastore *masq_data;
- struct dial_target *target;
- /* Find or create caller datastore */
- datastore = dial_masquerade_datastore_find(caller);
- if (!datastore) {
- masq_data = dial_masquerade_datastore_add(caller, NULL);
- } else {
- masq_data = datastore->data;
- }
- if (!masq_data) {
- return -1;
- }
- ao2_ref(masq_data, +1);
- /*
- * Someone likely forgot to do an ast_channel_publish_dial()
- * or ast_channel_publish_dial_forward() with a final dial
- * status on the channel.
- */
- ast_assert(masq_data->caller == caller);
- /* Create peer target to put into datastore */
- target = ast_calloc(1, sizeof(*target));
- if (!target) {
- ao2_ref(masq_data, -1);
- return -1;
- }
- if (dialstring) {
- target->dialstring = ast_strdup(dialstring);
- if (!target->dialstring) {
- ast_free(target);
- ao2_ref(masq_data, -1);
- return -1;
- }
- }
- target->peer = ast_channel_ref(peer);
- /* Put peer target into datastore */
- ao2_lock(masq_data);
- dial_masquerade_datastore_remove_chan(masq_data, peer);
- AST_LIST_INSERT_HEAD(&masq_data->dialed_peers, target, list);
- ao2_unlock(masq_data);
- datastore = dial_masquerade_datastore_find(peer);
- if (datastore) {
- if (datastore->data == masq_data) {
- /*
- * Peer already had the datastore for this dial masquerade.
- * This was a redundant peer dial masquerade setup.
- */
- ao2_ref(masq_data, -1);
- return 0;
- }
- /* Something is wrong. Try to fix if the assert doesn't abort. */
- ast_assert(0);
- /* Remove the stale dial masquerade datastore */
- dial_masquerade_datastore_remove_chan(datastore->data, peer);
- ast_channel_datastore_remove(peer, datastore);
- ast_datastore_free(datastore);
- }
- /* Create the peer dial masquerade datastore */
- if (dial_masquerade_datastore_add(peer, masq_data)) {
- /* Success */
- return 0;
- }
- /* Failed to create the peer datastore */
- dial_masquerade_datastore_remove_chan(masq_data, peer);
- ao2_ref(masq_data, -1);
- return -1;
- }
- static void remove_dial_masquerade(struct ast_channel *peer)
- {
- struct ast_datastore *datastore;
- struct dial_masquerade_datastore *masq_data;
- datastore = dial_masquerade_datastore_find(peer);
- if (!datastore) {
- return;
- }
- masq_data = datastore->data;
- if (masq_data) {
- dial_masquerade_datastore_remove_chan(masq_data, peer);
- }
- ast_channel_datastore_remove(peer, datastore);
- ast_datastore_free(datastore);
- }
- static void remove_dial_masquerade_caller(struct ast_channel *caller)
- {
- struct ast_datastore *datastore;
- struct dial_masquerade_datastore *masq_data;
- datastore = dial_masquerade_datastore_find(caller);
- if (!datastore) {
- return;
- }
- masq_data = datastore->data;
- if (!masq_data || !AST_LIST_EMPTY(&masq_data->dialed_peers)) {
- return;
- }
- dial_masquerade_datastore_remove_chan(masq_data, caller);
- ast_channel_datastore_remove(caller, datastore);
- ast_datastore_free(datastore);
- }
|