-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathuser.h
358 lines (296 loc) · 10.2 KB
/
user.h
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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
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
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
/**
* @file user.h
* @brief File per la gestione/creazione di utenti
* @author Emilio Panti 531844
* Si dichiara che il contenuto di questo file e' in ogni sua parte opera
* originale dell'autore
*/
#ifndef USER_H_
#define USER_H_
#include <pthread.h>
#include <message.h>
#include <abs_list.h>
//per usare la struttura group definita in group.h
typedef struct group group_us_t;
//stati assumibili da una struttura utente
typedef enum {
ONLINE = 0, //l'utente è online
OFFLINE = 1, //l'utente è offline
INACTIVE = 2, //l'utente è in fase di deregistrazione
} status_t;
/**
* @struct user_t
* @brief Struttura dati utente
*
* @var nickname nome dell'utente
* @var status status dell'utente
* @var fd descrittore aperto verso il client
* @var mtx puntatore al mutex per controllare l'accesso alla struttura utente
* @var msg_list lista dei messaggi arrivati all'utente
* @var groups lista di gruppi a cui è iscritto l'utente
*/
typedef struct user {
char nickname[MAX_NAME_LENGTH+1];
status_t status;
long fd;
pthread_mutex_t *mtx;
list_t *msg_list;
list_t *groups;
} user_t;
/**
* @struct param_get_listname_t
* @brief Struttura dati per i parametri della funzione get_listname
*
* @var len lunghezza effettiva della stringa all_names
* @var maxlen lunghezza massima della stringa all_names
* @var all_names stringa contenente la lista nomi
*/
typedef struct {
int len;
int maxlen;
char *all_names;
} param_get_listname_t;
/**
* @struct param_postmsg_all_t
* @brief Struttura dati per i parametri della funzione postmsg_all
*
* @var msg_to_send messaggio da inviare
* @var delivered contatore degli utenti a cui è stato consegnato il messaggio
* @var notdelivered contatore degli utenti a cui non è stato consegnato il messaggio
*/
typedef struct {
message_t *msg_to_send;
int delivered;
int notdelivered;
} param_postmsg_all_t;
/* ------------------------------ interfaccia user ------------------------------- */
/* ------------- funzioni strettamente legate alla strutture 'user_t' ---------------- */
/**
* @function lock_user
* @brief prende la lock dell'utente
*
* @param user puntatore all'utente
*
* @return 0 se successo, oppure un altro intero che rappresenta l'errore
*/
int lock_user(user_t *user);
/**
* @function unlock_user
* @brief rilascia la lock dell'utente
*
* @param user puntatore all'utente
*
* @return 0 se successo, oppure un altro intero che rappresenta l'errore
*/
int unlock_user(user_t *user);
/**
* @function create_user
* @brief Crea ed alloca la memoria necessaria per un utente
*
* @param name nome utente
* @param fd descrittore dell'utente al momento della sua creazione
*
* @return p puntatore al nuovo utente, NULL in caso di fallimento (errno settato)
*/
user_t *create_user(char *name, long fd);
/**
* @function clean_user
* @brief Libera la memoria allocata per l'utente
*
* @param us puntatore all'utente da cancellare
*/
void clean_user(void *us);
/**
* @function set_online
* @brief Cerca di mettere online l'utente passato
*
* @param user utente da mettere online
* @param fd descrittore da assegnare all'utente
*
* @return 1 se successo, 0 se era già online oppure se inattivo,
* -1 in caso di errore
*/
int set_online(user_t *user, long fd);
/**
* @function disable_user
* @brief Pone ad inattivo lo stato dell' utente ed elimina quest'ultimo da tutti i gruppi
* a cui è iscritto
*
* @param user utente da disattivare
* @param groupnames_list struttura dati per salvare i nomi dei gruppi di cui l'utente
* era creatore
*
* @return 1 se successo, 0 se era già inattivo l'utente, -1 se in caso di errore
*/
int disable_user(user_t *user);
/**
* @function sendMsg_toUser
* @brief Spedisce il messaggio passato da parametro all'utente specificato.
*
* @param user utente a cui inviare il messaggio
* @param msg messaggio da inviare
* @param sent per sapere all'esterno se è stato consegnato o meno il messaggio
*
* @return 1 se successo, 0 se l'utente si è disconnesso durante l'invio del messaggio o se era inattivo,
* -1 in caso di errore
*/
int sendMsg_toUser(user_t *user, message_t *msg, int *sent);
/**
* @function sendHdr_toUser
* @brief Spedisce l'header del messaggio passato da parametro all'utente specificato.
*
* @param user utente a cui inviare il messaggio
* @param hdr header del messaggio da inviare
*
* @return 1 se successo, 0 se l'utente si è disconnesso durante l'invio del messaggio o se era inattivo,
* -1 in caso di errore
*/
int sendHdr_toUser(user_t *user, message_hdr_t *hdr);
/**
* @function send_history
* @brief Spedisce la history dei messaggi all'utente passato da parametro
*
* @param user utente a cui inviare la history
* @param msgsdelivered contatore dei messaggi testuali inviati all'utente in questa funzione
* @param filesdelivered contatore dei messaggi files inviati all'utente in questa funzione
*
* @return 1 se successo, 0 se l'utente si è disconnesso durante l'invio dei messaggi o se era inattivo,
* -1 in caso di errore
*/
int send_history(user_t *user, int *msgsdelivered, int *filesdelivered);
/**
* @function subscribe
* @brief Inserisce il gruppo passato nella lista gruppi dell' utente
*
* @param user utente
* @param group gruppo da inserire nella lista dei gruppi dell'utente
*
* @return 1 se successo, 0 se l'utente è già iscritto a tale gruppo o se era inattivo,
* -1 in caso di errore
*/
int subscribe(user_t *user, group_us_t *group);
/**
* @function unsubscribe
* @brief Rimuove il gruppo passato dalla lista gruppi dell' utente
*
* @param user utente
* @param groupname nome del gruppo da rimuovere dalla lista dei gruppi dell'utente
*
* @return puntatore al gruppo rimosso, NULL ed errno non modificato nel caso non sia presente
* nella lista dei gruppi dell' utente o se l'utente è inattivo, NULL ed errno settato
* in caso di errore
*/
group_us_t* unsubscribe(user_t *user, char *groupname);
/**
* @function check_subscription
* @brief Controlla che l'utente sia iscritto al gruppo passato
*
* @param user utente
* @param groupname nome del gruppo da cercare nella lista dei gruppi dell'utente
*
* @return puntatore al gruppo trovato, NULL ed errno non modificato nel caso non sia presente
* nella lista dei gruppi dell' utente o se l'utente è inattivo, NULL ed errno settato
* in caso di errore
*/
group_us_t* check_subscription(user_t *user, char *groupname);
/* ------------- funzioni di inizializzazione delle varie struct ---------------- */
/**
* @function init_param_get_listname
* @brief Inizializza un struttura 'param_get_listname_t'
*
* @param max_user_in_list numero massimo di nomi utente da inserire nella lista dei nomi
*
* @return p puntatore alla nuova struttura, NULL in caso di fallimento
*/
param_get_listname_t *init_param_get_listname(int max_user_in_list);
/**
* @function init_param_postmsg_all
* @brief Inizializza un struttura 'param_postmsg_all_t'
*
* @param msg messaggio da inviare
*
* @return p puntatore alla nuova struttura, NULL in caso di fallimento
*/
param_postmsg_all_t *init_param_postmsg_all(message_t *msg);
/*------------ funzioni per la creazione/gestione/uso di liste ed hashtable -----------------
----------------- generiche che hanno come elementi degli utenti 'user_t' ------------------------*/
/**
* @function setmutex_user
* @brief Assegna la mutex passata alla struttura utente passata
*
* @param us utente a cui assegnare la mutex
* @param mutex mutex da assegnare
*
* @note: setta errno in caso di errore
*/
void setmutex_user(void *us, pthread_mutex_t *mutex);
/**
* @function hashfun_user
* @brief funzione hash che restituisce un valore tra 0 e (dim-1)
*
* @param dim modulo da applicare alla funzione hash calcolata su name
* @param name stringa a cui applicare la funzione hash
*
* @return ind valore compreso tra 0 e (dim-1),
* -1 in caso di errore e setta errno
*
* @note: è stato ripreso l'algoritmo "djb2" by Dan Bernstein.
*/
int hashfun_user(int dim, void *name);
/**
* @function cmp_user_by_name
* @brief Compara il nickname di un utente con un altro nome
*
* @param us utente di cui comparare il nickname
* @param name nome da comparare con il nickname di user
*
* @return un valore < 0 se (us->nickname < name),
* un valore = 0 se (us->nickname = name),
* un valore > 0 se (us->nickname > name),
* -1 ed errno settato in caso di errore
*/
int cmp_user_by_name(void *us, void *name);
/**
* @function cmp_user_by_fd
* @brief Compara l'fd di un utente con un altro passato come parametro
*
* @param us utente di cui comparare l'fd
* @param fd fd da comparare con quello di us
*
* @return (user->fd - *fd) se successo, -1 ed errno settato in caso di errore
*/
int cmp_user_by_fd(void *us, void *fd);
/**
* @function get_listname
* @brief Inserisce in param->all_names anche us->nickname e aggiunge
* a param->len un valore pari a (MAX_NAME_LENGTH+1)
*
* @param us puntatore all'utente
* @param param struttura in cui ci sono i dati da aggiornare/usare per la funzione
*
* @return 0 in caso di successo, -1 in caso di errore
*/
int get_listname(void *us, void *param);
/**
* @function postmsg_all
* @brief Invia il messaggio param->msg_to_send all'utente us e poi aggiorna
* i valori param->delivered o param->notdelivered a seconda dell'esito
* dell' invio del messaggio
*
* @param us puntatore all'utente
* @param param struttura in cui ci sono i dati da aggiornare/usare per la funzione
*
* @return 0 in caso di successo, -1 in caso di errore
*/
int postmsg_all(void *us, void *param);
/**
* @function gen_unsubscribe
* @brief Rimuove il gruppo passato dalla lista gruppi dell' utente
*
* @param us puntatore all' utente
* @param str nome del gruppo da rimuovere dai membri del gruppo
*
* @return 0 se successo, -1 in caso di errore
*/
int gen_unsubscribe(void *us, void *str);
#endif /* USER_H_ */