prot-a.c 7.83 KB
Newer Older
Per Cederqvist's avatar
Per Cederqvist committed
1
2
3
4
5
6
7
8
9
/*
 * Protocol A.
 */

#include <stdio.h>
#include <setjmp.h>

#include <kom-errno.h>
#include <kom-types.h>
10
#include <server/smalloc.h>
Per Cederqvist's avatar
Per Cederqvist committed
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
#include "lyskomd.h"
#include "com.h"
#include "connections.h"
#include "isc-parse.h"
#include "prot-a.h"
#include "prot-a-output.h"
#include "prot-a-parse.h"
#include <debug.h>
#include "isc.h"
#include "mux.h"

BUGDECL;

void
prot_a_reply(Connection *client,
	     Bool status,
	     Result_holder *res)
{
    /*
     * The function is called. Now return the answer.
     */

    if ( status == OK )
    {
	mux_printf(client, "=%d", client->ref_no);

	switch ( fnc_defs[ client->function ].result )
	{
39
	case rt_number:
Per Cederqvist's avatar
Per Cederqvist committed
40
41
42
43
	    mux_printf(client, " %ld", (u_long)res->number);
	    BUG(("=%d\n", res->number));
	    break;

44
	case rt_success:
Per Cederqvist's avatar
Per Cederqvist committed
45
46
47
	    BUG(("=Success\n"));
	    break;
	    
48
	case rt_person:
Per Cederqvist's avatar
Per Cederqvist committed
49
50
51
52
	    prot_a_output_person(client, &res->person);
	    BUG(("={Person struct not listed}\n"));
	    break;

53
	case rt_membership:
Per Cederqvist's avatar
Per Cederqvist committed
54
55
56
57
	    prot_a_output_membership(client, &res->membership);
	    BUG(("={Membership struct not listed}\n"));
	    break;

58
	case rt_conf_list:
Per Cederqvist's avatar
Per Cederqvist committed
59
60
61
62
	    prot_a_output_conf_list(client, res->conf_list);
	    BUG(("={Conf_list not listed}\n"));
	    break;

63
	case rt_conf_no_list:
Per Cederqvist's avatar
Per Cederqvist committed
64
65
66
67
	    prot_a_output_conf_no_list(client, res->conf_no_list);
	    BUG(("={Conf_no_list not listed}\n"));
	    break;
	    	    
68
	case rt_conference:
Per Cederqvist's avatar
Per Cederqvist committed
69
70
71
72
	    prot_a_output_conference(client, &res->conference);
	    BUG(("={Conference struct not listed}\n"));
	    break;

73
	case rt_string:
Per Cederqvist's avatar
Per Cederqvist committed
74
75
76
77
78
79
	    prot_a_output_string(client, res->string);
	    BUG(("={%dH", res->string.len));
	    BUGSTR(res->string);
	    BUG(("}\n"));
	    break;
	    
80
	case rt_mark_list:
Per Cederqvist's avatar
Per Cederqvist committed
81
82
83
84
	    prot_a_output_mark_list(client, res->mark_list);
	    BUG(("={Mark_list not listed}\n"));
	    break;
	    
85
	case rt_text_stat:
Per Cederqvist's avatar
Per Cederqvist committed
86
87
88
89
	    prot_a_output_text_stat(client, &res->text_stat);
	    BUG(("={Text_stat struct not listed}\n"));
	    break;
	    
90
	case rt_text_list:
Per Cederqvist's avatar
Per Cederqvist committed
91
92
93
94
	    prot_a_output_text_list(client, res->text_list);
	    BUG(("={Text_list not listed}\n"));
	    break;

95
	case rt_who_info_list:
Per Cederqvist's avatar
Per Cederqvist committed
96
97
98
99
	    prot_a_output_who_info_list(client, res->who_info_list);
	    BUG(("={Who_info_list not listed}\n"));
	    break;

100
	case rt_who_info_list_old:
Per Cederqvist's avatar
Per Cederqvist committed
101
102
103
104
105
	    prot_a_output_who_info_list_old(client,
					    res->who_info_list_old);
	    BUG(("={Old who_info_list not listed}\n"));
	    break;

106
	case rt_session_info:
Per Cederqvist's avatar
Per Cederqvist committed
107
108
109
110
111
	    prot_a_output_session_info(client,
				       &res->session_info);
	    BUG(("={Session_info not listed}\n"));
	    break;
    
112
	case rt_info:
Per Cederqvist's avatar
Per Cederqvist committed
113
114
115
116
	    prot_a_output_info(client, &res->info);
	    BUG(("={Who_info struct not listed}\n"));
	    break;

117
	case rt_membership_list:
Per Cederqvist's avatar
Per Cederqvist committed
118
119
120
121
	    prot_a_output_membership_list (client, res->membership_list);
	    BUG (("={Membership_list not listed}\n"));
	    break;
	    
122
	case rt_member_list:
Per Cederqvist's avatar
Per Cederqvist committed
123
124
125
126
	    prot_a_output_member_list (client, res->member_list);
	    BUG(("={Member_list not listed}\n"));
	    break;

127
	case rt_time_date:
Per Cederqvist's avatar
Per Cederqvist committed
128
129
130
131
	    prot_a_output_time (client, res->time_date);
	    BUG(("=(time_t)%d\n", res->time_date));
	    break;

132
	case rt_session_no:
Per Cederqvist's avatar
Per Cederqvist committed
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
	    prot_a_output_session_no (client, res->session_no);
	    BUG(("=(Session_no)%d\n", res->session_no));
	    break;
	}
	mux_putc('\n', client);
    }
    else
    {
	/* Failure. Give a reply with the error message. */
	mux_printf(client, "%%%d %d %d\n",
		client->ref_no, kom_errno, err_stat);
	BUG(("%%Err %d\n", kom_errno));
    }

    mux_flush(client);
}

/*
 * Check if it is a legal function.
 *
 * BUG: This should be generated from fncdef.txt.
 */


/*
 * Set up all data structures that are private to protocol A. This
 * function is called from connections.c whenever a connection says
 * that it is of type A.
 */
void
prot_a_init(Connection *conn)
{
    conn->parse_pos = 0;
    conn->fnc_parse_pos = 0;
    conn->array_parse_pos = 0;
    conn->struct_parse_pos = 0;
    conn->string_parse_pos = 0;
    conn->ref_no = 0;
    conn->function = 0;
    conn->num0 = 0;
    conn->num1 = 0;
    conn->num2 = 0;
    conn->num3 = 0;
    conn->c_string0 = EMPTY_STRING;
    conn->c_string1 = EMPTY_STRING;
    conn->string0 = EMPTY_STRING;
    conn->c_misc_info_p = NULL;
    conn->c_local_text_no_p = NULL;
    conn->priv_bits = DEFAULT_PRIV_BITS;
    conn->conf_type = NULL_CONF_TYPE;
}

void
prot_a_destruct(Connection *conn)
{

    /*
     * All strings et c should already by free:d - that is done at the
     * end of each atomic call. But free them anyhow, just in case
     * this client is forced of.
     */

    s_clear(&conn->string0);
    s_clear(&conn->c_string0);
    s_clear(&conn->c_string1);
    sfree(conn->c_misc_info_p);
    sfree(conn->c_local_text_no_p);
}


static Bool
prot_a_is_legal_fnc(Call_header fnc)
{
    switch(fnc)
    {
    case call_fnc_login: 
    case call_fnc_logout: 
    case call_fnc_pepsi: 
    case call_fnc_change_name: 
    case call_fnc_change_what_i_am_doing: 
    case call_fnc_create_person: 
    case call_fnc_get_person_stat_old:
    case call_fnc_set_priv_bits:
    case call_fnc_set_passwd: 
    case call_fnc_query_read_texts: 
    case call_fnc_create_conf: 
    case call_fnc_delete_conf: 
    case call_fnc_lookup_name: 
    case call_fnc_get_conf_stat_old: 
    case call_fnc_add_member: 
    case call_fnc_sub_member: 
    case call_fnc_set_presentation: 
    case call_fnc_set_etc_motd: 
    case call_fnc_set_supervisor: 
    case call_fnc_set_permitted_submitters: 
    case call_fnc_set_super_conf: 
    case call_fnc_set_conf_type: 
    case call_fnc_set_garb_nice: 
    case call_fnc_get_marks: 
    case call_fnc_mark_text: 
    case call_fnc_get_text: 
    case call_fnc_get_text_stat: 
    case call_fnc_mark_as_read: 
    case call_fnc_create_text: 
    case call_fnc_delete_text: 
    case call_fnc_add_recipient: 
    case call_fnc_sub_recipient: 
    case call_fnc_add_comment: 
    case call_fnc_sub_comment: 
    case call_fnc_get_map: 
    case call_fnc_get_time: 
    case call_fnc_get_info:
    case call_fnc_add_footnote:
    case call_fnc_sub_footnote:
    case call_fnc_who_is_on_old:
    case call_fnc_set_unread:
    case call_fnc_set_motd_of_lyskom:
    case call_fnc_enable:
    case call_fnc_sync:
    case call_fnc_shutdown:
    case call_fnc_broadcast:
    case call_fnc_get_membership:
    case call_fnc_get_created_texts:
    case call_fnc_get_members:
    case call_fnc_get_person_stat:
    case call_fnc_get_conf_stat:
    case call_fnc_who_is_on:
    case call_fnc_get_unread_confs:
    case call_fnc_send_message:
    case call_fnc_get_session_info:
    case call_fnc_disconnect:
    case call_fnc_who_am_i:
Per Cederqvist's avatar
Per Cederqvist committed
265
    case call_fnc_set_user_area:
Per Cederqvist's avatar
Per Cederqvist committed
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
	return TRUE;

    default:
	return FALSE;
    }
}    


void
prot_a_parse_packet(Connection *client)
{
    if ( s_empty(client->username) )
    {
	/* Connection not established yet */

	prot_a_parse_string(client, &client->c_string0, USERNAME_LEN);

	client->username = client->c_string0; /* Kludge to deal with */
	client->c_string0 = EMPTY_STRING;     /* "A5B" as first input. */
				/* Protokoll B will not suffer from this... */
	
Per Cederqvist's avatar
Per Cederqvist committed
287
288
	if ( s_strcat(&client->username,
		      s_fcrea_str((const unsigned char *)"@")) != OK )
Per Cederqvist's avatar
Per Cederqvist committed
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
	    restart_kom("prot_a_parse_packet: s_strcat\n");

	if ( s_strcat(&client->username, client->hostname) != OK )
	    restart_kom("prot_a_parse_packet: s_strcat II\n");

	mux_printf(client, "LysKOM\n");
	mux_flush(client);
	BUG(("[Client %d is logged on]\n", client->session_no));
    }	

    switch(client->parse_pos)
    {
    case 0:			/* Get ref_no */
	client->ref_no = prot_a_parse_long(client);
	client->parse_pos = 1;
	/* Fall through */
    case 1:			/* Get fnc_no */
	client->function = prot_a_parse_long(client);
	if ( !prot_a_is_legal_fnc(client->function) )
	    longjmp(parse_env, ISC_PROTOCOL_ERR);
	client->parse_pos = 2;
	/* Fall through */
    case 2:
	/* Call the function that parses the arguments for this call. */
	fnc_defs[client->function].parser(client);
	/* Fall through */
    default:
	client->parse_pos = 0;
    }

}