Support basic Busy Lamp Field (BLF) function as server (#4474)

Tested with Yealink phones (models T77U, T34W, T31P, T30P)

Author: alfedotov

pjsip/include/pjsip-simple/presence.h

@@ -403,6 +403,25 @@ PJ_DECL(pj_status_t) pjsip_pres_parse_xpidf2(char *body, unsigned body_len,
                                              pjsip_pres_status *status);
 
 
+/**
+ * This is a utility function to create DIALOG-INFO message body from PJSIP
+ * presence status.
+ *
+ * @param pool          The pool to allocate memory for the message body.
+ * @param status        Presence status to be converted into DIALOG-INFO
+ *                      message body.
+ * @param entity        The entity ID, which normally is equal to the
+ *                      presentity ID publishing this presence info.
+ * @param p_body        Pointer to receive the SIP message body.
+ *
+ * @return              PJ_SUCCESS on success.
+ */
+PJ_DECL(pj_status_t) pjsip_pres_create_dialog_info(pj_pool_t* pool,
+                                                   const pjsip_pres_status* status,
+                                                   const pj_str_t* entity,
+                                                   pjsip_msg_body** p_body);
+
+
 
 /**
  * @}

pjsip/src/pjsip-simple/presence.c

@@ -69,6 +69,7 @@ typedef enum content_type_e
     CONTENT_TYPE_NONE,
     CONTENT_TYPE_PIDF,
     CONTENT_TYPE_XPIDF,
+    CONTENT_TYPE_DIALOG_INFO,
 } content_type_e;
 
 /*
@@ -133,11 +134,13 @@ static pjsip_evsub_user pres_user =
  */
 static const pj_str_t STR_EVENT     = { "Event", 5 };
 static const pj_str_t STR_PRESENCE          = { "presence", 8 };
+static const pj_str_t STR_DIALOG            = { "dialog", 6 };
 static const pj_str_t STR_APPLICATION       = { "application", 11 };
 static const pj_str_t STR_PIDF_XML          = { "pidf+xml", 8};
 static const pj_str_t STR_XPIDF_XML         = { "xpidf+xml", 9};
 static const pj_str_t STR_APP_PIDF_XML      = { "application/pidf+xml", 20 };
 static const pj_str_t STR_APP_XPIDF_XML    = { "application/xpidf+xml", 21 };
+static const pj_str_t STR_APP_DIALOG_INFO_XML = { "application/dialog-info+xml", 27 };
 
 
 /*
@@ -273,6 +276,10 @@ PJ_DEF(pj_status_t) pjsip_pres_create_uas( pjsip_dialog *dlg,
         return PJSIP_ERRNO_FROM_SIP_STATUS(PJSIP_SC_BAD_REQUEST);
     }
     if (pj_stricmp(&event->event_type, &STR_PRESENCE) != 0) {
+    }
+    else if (pj_stricmp(&event->event_type, &STR_DIALOG) != 0) {
+    }
+    else {
         return PJSIP_ERRNO_FROM_SIP_STATUS(PJSIP_SC_BAD_EVENT);
     }
 
@@ -289,6 +296,10 @@ PJ_DEF(pj_status_t) pjsip_pres_create_uas( pjsip_dialog *dlg,
             if (pj_stricmp(&accept->values[i], &STR_APP_XPIDF_XML)==0) {
                 content_type = CONTENT_TYPE_XPIDF;
                 break;
+            } else
+            if (pj_stricmp(&accept->values[i], &STR_APP_DIALOG_INFO_XML) == 0) {
+                content_type = CONTENT_TYPE_DIALOG_INFO;
+                break;
             }
         }
 
@@ -499,6 +510,11 @@ static pj_status_t pres_create_msg_body( pjsip_pres *pres,
         return pjsip_pres_create_xpidf(tdata->pool, &pres->status,
                                        &entity, &tdata->msg->body);
 
+    } else if (pres->content_type == CONTENT_TYPE_DIALOG_INFO) {
+
+        return pjsip_pres_create_dialog_info(tdata->pool, &pres->status,
+                                             &entity, &tdata->msg->body);
+
     } else {
         return PJSIP_SIMPLE_EBADCONTENT;
     }

pjsip/src/pjsip-simple/presence_body.c

@@ -25,6 +25,7 @@
 #include <pj/os.h>
 #include <pj/pool.h>
 #include <pj/string.h>
+#include <pjsip-simple/dialog_info.h>
 
 
 #define THIS_FILE   "presence_body.c"
@@ -33,7 +34,14 @@
 static const pj_str_t STR_APPLICATION = { "application", 11 };
 static const pj_str_t STR_PIDF_XML =    { "pidf+xml", 8 };
 static const pj_str_t STR_XPIDF_XML =   { "xpidf+xml", 9 };
-
+static const pj_str_t STR_DIALOG_INFO_XML = { "dialog-info+xml", 15 };
+//static pj_str_t STR_TRYING = { "trying", 6 };
+//static pj_str_t STR_PROCEEDING = { "proceeding", 10 };
+//static pj_str_t STR_EARLY = { "early", 5 };
+static pj_str_t STR_CONFIRMED = { "confirmed", 9 };
+static pj_str_t STR_TERMINATED = { "terminated", 10 };
+static pj_str_t STR_VERSION = { "1.0", 3 };
+static pj_str_t STR_EMPTY_STRING = { NULL, 0 };
 
 
 
@@ -294,3 +302,48 @@ PJ_DEF(pj_status_t) pjsip_pres_parse_xpidf2(char *body, unsigned body_len,
 }
 
 
+/*
+ * This is a utility function to create DIALOG-INFO message body from PJSIP
+ * presence status (pjsip_pres_status).
+ */
+PJ_DEF(pj_status_t) pjsip_pres_create_dialog_info(pj_pool_t* pool,
+                                                  const pjsip_pres_status* status,
+                                                  const pj_str_t* entity,
+                                                  pjsip_msg_body** p_body)
+{
+    pjsip_dlg_info_dialog* dlginfo;
+    pjsip_msg_body* body;
+
+    pjrpid_element rpid = status->info[0].rpid;
+    pj_bool_t basic_open = status->info[0].basic_open;
+
+    const pj_str_t* state;
+
+    if (basic_open) {
+        if (rpid.activity == PJRPID_ACTIVITY_BUSY) {
+            state = &STR_CONFIRMED;
+        }
+        else {
+            state = &STR_TERMINATED;
+        }
+    }
+    else {
+        //pjsip_dlg_info_dialog_set_state(pool, dlginfo, &STR_TERMINATED);
+        state = &STR_TERMINATED;
+    }
+
+    /* Create DIALOG-INFO document. */
+    dlginfo = pjsip_dlg_info_create(pool, &STR_VERSION, state, entity);
+
+    body = PJ_POOL_ZALLOC_T(pool, pjsip_msg_body);
+    body->data = dlginfo;
+    body->content_type.type = STR_APPLICATION;
+    body->content_type.subtype = STR_DIALOG_INFO_XML;
+    body->print_body = &pres_print_body;
+    body->clone_data = &xml_clone_data;
+
+    *p_body = body;
+
+    return PJ_SUCCESS;
+}
+