nua_event_server.c 8.86 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56
/*
 * This file is part of the Sofia-SIP package
 *
 * Copyright (C) 2006 Nokia Corporation.
 *
 * Contact: Pekka Pessi <pekka.pessi@nokia.com>
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public License
 * as published by the Free Software Foundation; either version 2.1 of
 * the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA
 *
 */

/**@CFILE nua_event_server.c
 * @brief Easy event server
 *
 * @author Pekka Pessi <Pekka.Pessi@nokia.com>
 *
 * @date Created: Wed Mar  8 11:48:49 EET 2006 ppessi
 */

#include "config.h"

#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <limits.h>

#include <assert.h>

#include <sofia-sip/string0.h>

#include <sofia-sip/sip_protos.h>
#include <sofia-sip/sip_status.h>
#include <sofia-sip/su_tagarg.h>

#define NEA_SMAGIC_T         struct nua_handle_s
#define NEA_EMAGIC_T         struct nua_handle_s

#include "nua_stack.h"

/* ======================================================================== */
/* Event server */

static
57 58
nea_event_t *nh_notifier_event(nua_handle_t *nh,
			       su_home_t *home,
59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78
			       sip_event_t const *event,
			       tagi_t const *tags);

static
void authorize_watcher(nea_server_t *nes,
		       nua_handle_t *nh,
		       nea_event_t *ev,
		       nea_subnode_t *sn,
		       sip_t const *sip);

void
nua_stack_notifier(nua_t *nua, nua_handle_t *nh, nua_event_t e, tagi_t const *tags)
{
  su_home_t home[1] = { SU_HOME_INIT(home) };
  sip_event_t const *event = NULL;
  sip_content_type_t const *ct = NULL;
  sip_payload_t const *pl = NULL;
  url_string_t const *url = NULL;
  char const *event_s = NULL, *ct_s = NULL, *pl_s = NULL;
  nea_event_t *ev;
79 80
  int status = 900;
  char const *phrase = nua_internal_error;
81

82
  nua_stack_init_handle(nua, nh, tags);
83

84 85
  tl_gets(tags,
	  NUTAG_URL_REF(url),
86 87 88 89 90 91 92 93 94 95
	  SIPTAG_EVENT_REF(event),
	  SIPTAG_EVENT_STR_REF(event_s),
	  SIPTAG_CONTENT_TYPE_STR_REF(ct_s),
	  SIPTAG_PAYLOAD_REF(pl),
	  SIPTAG_PAYLOAD_STR_REF(pl_s),
	  TAG_END());

  if (!event && !event_s)
    status = 400, phrase = "Missing Event";

96
  else if (!ct && !ct_s)
97 98 99
    status = 400, phrase = "Missing Content-Type";

  else if (!nh->nh_notifier &&
100
	   !(nh->nh_notifier =
101 102
	     nea_server_create(nua->nua_nta, nua->nua_root,
			       url->us_url,
103
			       NH_PGET(nh, max_subscriptions),
104
			       NULL, nh,
105
			       TAG_NEXT(tags))))
106
    status = 900, phrase = nua_internal_error;
107 108

  else if (!event && !(event = sip_event_make(home, event_s)))
109
    status = 900, phrase = "Could not create an event header";
110 111

  else if (!(ev = nh_notifier_event(nh, home, event, tags)))
112
    status = 900, phrase = "Could not create an event view";
113 114

  else if (nea_server_update(nh->nh_notifier, ev,  TAG_NEXT(tags)) < 0)
115
    status = 900, phrase = "No content for event";
116 117

  else if (nea_server_notify(nh->nh_notifier, ev) < 0)
118 119
    status = 900, phrase = "Error when notifying watchers";

120 121
  else
    nua_stack_tevent(nua, nh, NULL, e, status = SIP_200_OK,
122 123 124
		     SIPTAG_EVENT(event),
		     SIPTAG_CONTENT_TYPE(ct),
		     TAG_END());
125

126
  if (status != 200)
127
    nua_stack_event(nua, nh, NULL, e, status, phrase, NULL);
128 129 130 131 132 133 134

  su_home_deinit(home);
}


/* Create a event view for notifier */
static
135 136
nea_event_t *nh_notifier_event(nua_handle_t *nh,
			       su_home_t *home,
137 138 139 140 141 142 143 144 145 146 147
			       sip_event_t const *event,
			       tagi_t const *tags)
{
  nea_event_t *ev = nea_event_get(nh->nh_notifier, event->o_type);
  sip_accept_t const *accept = NULL;
  char const  *accept_s = NULL;
  sip_content_type_t const *ct = NULL;
  char const *ct_s = NULL;

  if (ev == NULL) {
    char *o_type = su_strdup(home, event->o_type);
148
    char *o_subtype = o_type ? strchr(o_type, '.') : NULL;
149 150 151 152

    if (o_subtype)
      *o_subtype++ = '\0';

153
    tl_gets(tags,
154 155 156 157 158
	    SIPTAG_ACCEPT_REF(accept),
	    SIPTAG_ACCEPT_STR_REF(accept_s),
	    SIPTAG_CONTENT_TYPE_REF(ct),
	    SIPTAG_CONTENT_TYPE_STR_REF(ct_s),
	    TAG_END());
159

160 161 162 163 164 165 166 167 168 169 170
    /*
     * XXX - We really should build accept header when we add new content
     * types
     */
    if (accept_s == NULL && accept)
      accept_s = sip_header_as_string(home, (sip_header_t *)accept);
    if (accept_s == NULL && ct)
      accept_s = ct->c_type;
    if (accept_s == NULL && ct_s)
      accept_s = ct_s;

171
    ev = nea_event_create(nh->nh_notifier,
172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198
			  authorize_watcher, nh,
			  o_type, o_subtype,
			  ct ? ct->c_type : ct_s,
			  accept_s);
  }

  return ev;
}

/* Callback from nea_server asking nua to authorize subscription */
static
void authorize_watcher(nea_server_t *nes,
		       nua_handle_t *nh,
		       nea_event_t *ev,
		       nea_subnode_t *sn,
		       sip_t const *sip)
{
  nua_t *nua = nh->nh_nua;
  msg_t *msg = NULL;
  nta_incoming_t *irq = NULL;
  int substate = sn->sn_state;
  int status; char const *phrase;

  SET_STATUS1(SIP_200_OK);

  /* OK. In nhp (nua_handle_preferences_t) structure we have the
     current default action (or state) for incoming
199 200
     subscriptions.
     Action can now be modified by the application with NUTAG_SUBSTATE().
201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222
  */
  irq = nea_sub_get_request(sn->sn_subscriber);
  msg = nta_incoming_getrequest(irq);

  if (sn->sn_state == nea_embryonic) {
    char const *what;

    substate = NH_PGET(nh, substate);

    if (substate == nua_substate_embryonic)
      substate = nua_substate_pending;

    if (substate == nua_substate_terminated) {
      what = "rejected"; SET_STATUS1(SIP_403_FORBIDDEN);
    }
    else if (substate == nua_substate_pending) {
      what = "pending"; SET_STATUS1(SIP_202_ACCEPTED);
    }
    else {
      what = "active";
    }

223
    SU_DEBUG_7(("nua(%p): authorize_watcher: %s\n", (void *)nh, what));
224 225 226 227 228 229 230 231 232 233
    nea_sub_auth(sn->sn_subscriber, substate,
		 TAG_IF(substate == nua_substate_pending,
			NEATAG_FAKE(1)),
		 TAG_IF(substate == nua_substate_terminated,
			NEATAG_REASON("rejected")),
		 TAG_END());
  }
  else if (sn->sn_state == nea_terminated || sn->sn_expires == 0) {
    substate = nua_substate_terminated;
    nea_server_flush(nes, NULL);
234 235
    SU_DEBUG_7(("nua(%p): authorize_watcher: %s\n",
		(void *)nh, "watcher is removed"));
236 237
  }

238 239 240 241
  nua_stack_tevent(nua, nh, msg, nua_i_subscription, status, phrase,
		   NUTAG_SUBSTATE(substate),
		   NEATAG_SUB(sn->sn_subscriber),
		   TAG_END());
242 243 244
}

/* ---------------------------------------------------------------------- */
Pekka Pessi's avatar
Pekka Pessi committed
245
/* Authorization of watchers by application */
246

Pekka Pessi's avatar
Pekka Pessi committed
247 248 249 250
void nua_stack_authorize(nua_t *nua,
			 nua_handle_t *nh,
			 nua_event_t e,
			 tagi_t const *tags)
251 252
{
  nea_sub_t *sub = NULL;
253
  int state = nea_extended;
254 255 256

  tl_gets(tags,
	  NEATAG_SUB_REF(sub),
257
	  NUTAG_SUBSTATE_REF(state),
258 259 260 261
	  TAG_END());

  if (sub && state > 0) {
    nea_sub_auth(sub, state, TAG_NEXT(tags));
262
    nua_stack_event(nua, nh, NULL, e, SIP_200_OK, NULL);
263 264
  }
  else {
Pekka Pessi's avatar
Pekka Pessi committed
265
    nua_stack_event(nua, nh, NULL, e, NUA_ERROR_AT(__FILE__, __LINE__), NULL);
266 267 268
  }
}

Pekka Pessi's avatar
Pekka Pessi committed
269 270 271
/** @internal Shutdown notifier object */
int nh_notifier_shutdown(nua_handle_t *nh,
			 nea_event_t *ev,
272
			 tag_type_t t,
Pekka Pessi's avatar
Pekka Pessi committed
273
			 tag_value_t v, ...)
274 275 276 277 278 279 280 281 282 283 284 285 286 287 288
{
  nea_server_t *nes = nh->nh_notifier;
  nea_subnode_t const **subs;
  int busy = 0;

  if (nes == NULL)
    return 0;

  subs = nea_server_get_subscribers(nes, ev);

  if (subs) {
    int i;
    ta_list ta;

    ta_start(ta, t, v);
289

290 291
    for (i = 0; subs[i]; i++)
      nea_sub_auth(subs[i]->sn_subscriber, nea_terminated, ta_tags(ta));
292

293 294 295 296 297 298
    ta_end(ta);

    busy++;
  }

  nea_server_free_subscribers(nes, subs);
299

300 301 302 303 304 305 306 307 308
  nea_server_flush(nh->nh_notifier, NULL);

  if (ev == NULL)
    nea_server_destroy(nh->nh_notifier), nh->nh_notifier = NULL;

  return busy;
}


Pekka Pessi's avatar
Pekka Pessi committed
309 310 311 312 313
/** @internal Terminate notifier. */
void nua_stack_terminate(nua_t *nua,
			 nua_handle_t *nh,
			 nua_event_t e,
			 tagi_t const *tags)
314 315 316 317 318 319 320 321
{
  sip_event_t const *event = NULL;
  sip_content_type_t const *ct = NULL;
  sip_payload_t const *pl = NULL;
  char const *event_s = NULL, *ct_s = NULL, *pl_s = NULL;
  nea_event_t *nev = NULL;

  if (nh->nh_notifier == NULL) {
322
    UA_EVENT2(e, 900, "No event server to terminate");
323 324 325
    return;
  }

326
  tl_gets(tags,
327 328 329 330 331 332 333 334
	  SIPTAG_EVENT_REF(event),
	  SIPTAG_EVENT_STR_REF(event_s),
	  SIPTAG_CONTENT_TYPE_REF(ct),
	  SIPTAG_CONTENT_TYPE_STR_REF(ct_s),
	  SIPTAG_PAYLOAD_REF(pl),
	  SIPTAG_PAYLOAD_STR_REF(pl_s),
	  TAG_END());

335
  nev = nea_event_get(nh->nh_notifier,
336 337 338 339 340 341
		      event ? event->o_type : event_s);

  if (nev && (pl || pl_s) && (ct || ct_s)) {
    nea_server_update(nh->nh_notifier, nev, TAG_NEXT(tags));
  }

342 343
  nh_notifier_shutdown(nh, NULL,
		       NEATAG_REASON("noresource"),
344 345
		       TAG_NEXT(tags));

346
  nua_stack_event(nua, nh, NULL, e, SIP_200_OK, NULL);
347
}