subscription_manager.h

#ifndef __SUBSCRIPTION_MANAGER_H
#define __SUBSCRIPTION_MANAGER_H

#include <cds/sstr.h>
#include "time_event_manager.h"
#include "../../modules/tm/dlg.h"
#include "trace.h"

struct _subscription_data_t;

typedef enum {
        auth_rejected,
        auth_polite_block,
        auth_unresolved,
        auth_granted
} authorization_result_t;

typedef int(*send_notify_func)(struct _subscription_data_t *s);
typedef int(*terminate_func)(struct _subscription_data_t *s);
typedef authorization_result_t (*subscription_authorize_func)(struct _subscription_data_t *s);

typedef enum {
        subscription_uninitialized,
        subscription_active,
        subscription_pending,
        subscription_terminated,
        subscription_terminated_to,     /* terminated timeout */
        subscription_terminated_pending,        /* terminated pending subscription */
        subscription_terminated_pending_to      /* terminated pending subscription (timeout) */
} subscription_status_t;

typedef struct _subscription_data_t {
        time_event_data_t expiration;
        dlg_t *dialog;
        void *usr_data;
        subscription_status_t status;
        struct _subscription_data_t *next;
        struct _subscription_data_t *prev;
        str_t contact;
        str_t record_id;
        str_t package;
        str_t subscriber;       

} subscription_data_t;

typedef struct {
        subscription_data_t *first;
        subscription_data_t *last;

        send_notify_func notify;
        terminate_func terminate;
        subscription_authorize_func authorize;

        gen_lock_t *mutex;
        
        time_event_manager_t timer;

        int default_expiration;
        int min_expiration;
        int max_expiration;
        
} subscription_manager_t;

int subscription_management_init(void);
        
subscription_manager_t *sm_create(send_notify_func notify, 
                terminate_func terminate, 
                subscription_authorize_func authorize,
                gen_lock_t *mutex,
                int min_exp, 
                int max_exp, 
                int default_exp,
                int expiration_timer_period);

int sm_init(subscription_manager_t *sm,
                send_notify_func notify, 
                terminate_func terminate, 
                subscription_authorize_func authorize,
                gen_lock_t *mutex,
                int min_exp, 
                int max_exp, 
                int default_exp,
                int expiration_timer_period);

int sm_init_subscription_nolock(subscription_manager_t *mng,
                subscription_data_t *dst, 
                struct sip_msg *m);

int sm_refresh_subscription_nolock(subscription_manager_t *mng,
                subscription_data_t *s, 
                struct sip_msg *m);
                
void sm_release_subscription_nolock(subscription_manager_t *mng,
                subscription_data_t *dst);

int sm_prepare_subscription_response(subscription_manager_t *mng,
                subscription_data_t *s, 
                struct sip_msg *m);

int sm_find_subscription(subscription_manager_t *mng,
                str_t *from_tag, str_t *to_tag, str_t *call_id, 
                subscription_data_t **dst);

int sm_subscription_terminated(subscription_data_t *s);

int sm_subscription_pending(subscription_data_t *s);

int sm_subscription_expires_in(subscription_manager_t *mng,
                subscription_data_t *s);

int sm_init_subscription_nolock_ex(subscription_manager_t *mng,
                subscription_data_t *dst, 
                dlg_t *dialog,
                subscription_status_t status,
                const str_t *contact,
                const str_t *record_id,
                const str_t *package,
                const str_t *subscriber,
                int expires_after,
                void *subscription_data);

#endif