Function ospProcessSubscribe

modules/osp/cnam.c:311–363

* Process SUBSCRIBE * param msg SIP message * param cnamrecord Cached CNAM record * param ignore2 * return MODULE_RETURNCODE_TRUE success, MODULE_RETURNCODE_FALSE failure */

 * return MODULE_RETURNCODE_TRUE success, MODULE_RETURNCODE_FALSE failure
 */
int ospProcessSubscribe(
    struct sip_msg* msg,
    str* cnamrecord)
{
    int expire;
    str contact = { NULL, 0 };
    str tag = { NULL, 0 };
    str notify = { "NOTIFY", 6 };
    dlg_t *dialog;
    char buffer[OSP_HEADERBUF_SIZE];
    str headers = { buffer, sizeof(buffer) };
    int result = MODULE_RETURNCODE_FALSE;

    LM_DBG("cnam record '%.*s'\n", cnamrecord->len, cnamrecord->s);
    /* Parse SUBSCRIBE */
    if (ospParseSubscribe(msg) == 0) {
        expire = 0;
        if (msg->expires != NULL) {
            expire = ((exp_body_t*)msg->expires->parsed)->val;
        }

        if (get_local_contact(msg->rcv.bind_address, NULL, &contact) < 0) {
            LM_WARN("failed to get contact\n");
        }

        /* Send 200 OK reply */
        if (ospReply200(msg, expire, &contact, &tag) == 0) {
            /* Create dialog */
            if ((dialog = ospCreateDialog(msg, &tag)) != NULL) {
                /* Generate extra headers */
                if (ospExtraHeaders(msg, expire, &contact, &headers) == 0) {
                    /* Send NOTIFY */
                    if (run_tm_api(&osp_tmb, t_request_within, &notify, &headers, cnamrecord, dialog, ospNotifyCallback, NULL, NULL) < 0) {
                        LM_ERR("failed to send notify\n");
                    } else {
                       result = MODULE_RETURNCODE_TRUE;
                    }
                } else {
                    LM_ERR("failed to generate extre headers\n");
                }
            } else {
                LM_ERR("failed to create dialog\n");
            }
            ospFreeDialog(dialog);
        } else {
            LM_ERR("failed to send ok\n");
        }
    } else {
        LM_ERR("failed to parse subscribe\n");
    }

    return result;
}