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
100
101
102
103
104
105
106
107
108
109
110
|
#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,i64 replyid){
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->replyid=replyid;
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);
}
void event_emit_leave(i64 timestamp,const char *user,const char *room){
struct event_item *event=event_item_alloc();
event->type=EVENT_LEAVE;
event->timestamp=timestamp;
event->user=strdup(user);
event->room=strdup(room);
event_emit(event);
event_item_free(event);
}
|
