aboutsummaryrefslogtreecommitdiff
path: root/event.c
blob: 40eaff8562c09ba72acc7d342fb58cb5fb416a60 (plain)
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
#include <string.h>
#include "event.h"


struct cbs_chain{
	event_callback_t *cb;
	struct cbs_chain *prev,*next;
};

struct cbs_chain *callbacks=NULL,*callbacks_last=NULL;


static struct cbs_chain* find_chain_item(event_callback_t *cb){
	struct cbs_chain *item=callbacks;
	while(item&&item->cb!=cb)item=item->next;
	return item;
}


void event_register(event_callback_t *cb){
	struct cbs_chain *item=find_chain_item(cb);
	if(item!=NULL){
		debug("event_register: callback %p already registered!",cb);
		return;
	}
	item=malloc(1,struct cbs_chain);
	item->cb=cb;
	item->prev=item->next=NULL;
	if(callbacks){
		item->prev=callbacks_last;
		callbacks_last->next=item;
		callbacks_last=item;
	} else {
		callbacks=callbacks_last=item;
	}
}

void event_unregister(event_callback_t *cb){
	struct cbs_chain *item=find_chain_item(cb);
	if(item==NULL){
		debug("event_unregister: callback %p was not registered!",cb);
		return;
	}
	if(item->prev)item->prev->next=item->next;
	if(item->next)item->next->prev=item->prev;
	if(callbacks==item)callbacks=item->next;
	if(callbacks_last==item)callbacks_last=item->prev;
	free(item);
}

struct event_item* event_item_alloc(void){
	struct event_item *event=malloc(1,struct event_item);
	memset(event,0,sizeof(struct event_item));
	return event;
}

void event_item_free(struct event_item *event){
	if(event->message)free(event->message);
	if(event->user)free(event->user);
	if(event->room)free(event->room);
	free(event);
}

void event_emit(const struct event_item *event){
	for(struct cbs_chain *item=callbacks;item!=NULL;item=item->next){
		item->cb(event);
	}
}

void event_emit_message(i64 timestamp,const char *message,const char *user,const char *room){
	struct event_item *event=event_item_alloc();
	event->type=EVENT_MESSAGE;
	event->timestamp=timestamp;
	event->message=strdup(message);
	event->user=strdup(user);
	event->room=strdup(room);
	event_emit(event);
	event_item_free(event);
}

void event_emit_online(i64 timestamp,const char *user,i64 numonline){
	struct event_item *event=event_item_alloc();
	event->type=EVENT_ONLINE;
	event->timestamp=timestamp;
	event->user=strdup(user);
	event->num=numonline;
	event_emit(event);
	event_item_free(event);
}

void event_emit_join(i64 timestamp,const char *user,const char *room){
	struct event_item *event=event_item_alloc();
	event->type=EVENT_JOIN;
	event->timestamp=timestamp;
	event->user=strdup(user);
	event->room=strdup(room);
	event_emit(event);
	event_item_free(event);
}