Mostly made changes to allow client_gets to handle reading a buffer
[citadel.git] / citadel / control.c
1 /*
2  * $Id$
3  *
4  * This module handles states which are global to the entire server.
5  *
6  */
7
8 #include "sysdep.h"
9 #include <stdlib.h>
10 #include <unistd.h>
11 #include <stdio.h>
12 #include <fcntl.h>
13 #include <signal.h>
14 #include <time.h>
15 #include <ctype.h>
16 #include <string.h>
17 #include <errno.h>
18 #include <limits.h>
19 #include <syslog.h>
20 #include <sys/types.h>
21 #include "citadel.h"
22 #include "server.h"
23 #include "control.h"
24 #include "sysdep_decls.h"
25 #include "support.h"
26 #include "config.h"
27 #include "msgbase.h"
28 #include "tools.h"
29 #include "room_ops.h"
30
31 struct CitControl CitControl;
32 struct config config;
33 FILE *control_fp = NULL;
34
35 /*
36  * get_control  -  read the control record into memory.
37  */
38 void get_control(void) {
39
40         /* Zero it out.  If the control record on disk is missing or short,
41          * the system functions with all control record fields initialized
42          * to zero.
43          */
44         memset(&CitControl, 0, sizeof(struct CitControl));
45         if (control_fp == NULL) {
46                 control_fp = fopen("citadel.control", "rb+");
47                 if (control_fp != NULL) {
48                         fchown(fileno(control_fp), config.c_bbsuid, -1);
49                 }
50         }
51         if (control_fp == NULL) {
52                 control_fp = fopen("citadel.control", "wb+");
53                 if (control_fp != NULL) {
54                         fchown(fileno(control_fp), config.c_bbsuid, -1);
55                         memset(&CitControl, 0, sizeof(struct CitControl));
56                         fwrite(&CitControl, sizeof(struct CitControl),
57                                 1, control_fp);
58                         rewind(control_fp);
59                 }
60         }
61         if (control_fp == NULL) {
62                 lprintf(1, "ERROR opening citadel.control: %s\n",
63                         strerror(errno));
64                 return;
65         }
66
67         rewind(control_fp);
68         fread(&CitControl, sizeof(struct CitControl), 1, control_fp);
69         }
70
71 /*
72  * put_control  -  write the control record to disk.
73  */
74 void put_control(void) {
75
76         if (control_fp != NULL) {
77                 rewind(control_fp);
78                 fwrite(&CitControl, sizeof(struct CitControl), 1, control_fp);
79                 fflush(control_fp);
80                 }
81         }
82
83
84 /*
85  * get_new_message_number()  -  Obtain a new, unique ID to be used for a message.
86  */
87 long get_new_message_number(void) {
88         begin_critical_section(S_CONTROL);
89         get_control();
90         ++CitControl.MMhighest;
91         put_control();
92         end_critical_section(S_CONTROL);
93         return(CitControl.MMhighest);
94         }
95
96
97 /*
98  * get_new_user_number()  -  Obtain a new, unique ID to be used for a user.
99  */
100 long get_new_user_number(void) {
101         begin_critical_section(S_CONTROL);
102         get_control();
103         ++CitControl.MMnextuser;
104         put_control();
105         end_critical_section(S_CONTROL);
106         return(CitControl.MMnextuser);
107         }
108
109
110
111 /*
112  * get_new_room_number()  -  Obtain a new, unique ID to be used for a room.
113  */
114 long get_new_room_number(void) {
115         begin_critical_section(S_CONTROL);
116         get_control();
117         ++CitControl.MMnextroom;
118         put_control();
119         end_critical_section(S_CONTROL);
120         return(CitControl.MMnextroom);
121         }
122
123
124
125 /* 
126  * Get or set global configuration options
127  */
128 void cmd_conf(char *argbuf) {
129         char cmd[SIZ];
130         char *ibuf;
131         int a;
132         char *confptr;
133         char confname[SIZ];
134
135         if (!(CC->logged_in)) {
136                 cprintf("%d Not logged in.\n",ERROR+NOT_LOGGED_IN);
137                 return;
138                 }
139
140         if (CC->usersupp.axlevel < 6) {
141                 cprintf("%d Higher access required.\n",
142                         ERROR+HIGHER_ACCESS_REQUIRED);
143                 return;
144                 }
145
146         extract(cmd, argbuf, 0);
147         if (!strcasecmp(cmd, "GET")) {
148                 cprintf("%d Configuration...\n", LISTING_FOLLOWS);
149                 cprintf("%s\n", config.c_nodename);
150                 cprintf("%s\n", config.c_fqdn);
151                 cprintf("%s\n", config.c_humannode);
152                 cprintf("%s\n", config.c_phonenum);
153                 cprintf("%d\n", config.c_creataide);
154                 cprintf("%d\n", config.c_sleeping);
155                 cprintf("%d\n", config.c_initax);
156                 cprintf("%d\n", config.c_regiscall);
157                 cprintf("%d\n", config.c_twitdetect);
158                 cprintf("%s\n", config.c_twitroom);
159                 cprintf("%s\n", config.c_moreprompt);
160                 cprintf("%d\n", config.c_restrict);
161                 cprintf("%s\n", config.c_bbs_city);
162                 cprintf("%s\n", config.c_sysadm);
163                 cprintf("%d\n", config.c_maxsessions);
164                 cprintf("%s\n", config.c_net_password);
165                 cprintf("%d\n", config.c_userpurge);
166                 cprintf("%d\n", config.c_roompurge);
167                 cprintf("%s\n", config.c_logpages);
168                 cprintf("%d\n", config.c_createax);
169                 cprintf("%d\n", config.c_maxmsglen);
170                 cprintf("%d\n", config.c_min_workers);
171                 cprintf("%d\n", config.c_max_workers);
172                 cprintf("%d\n", config.c_pop3_port);
173                 cprintf("%d\n", config.c_smtp_port);
174                 cprintf("%d\n", config.c_default_filter);
175                 cprintf("%d\n", config.c_aide_zap);
176                 cprintf("%d\n", config.c_imap_port);
177                 cprintf("000\n");
178                 }
179
180         else if (!strcasecmp(cmd, "SET")) {
181             char buf[SIZ];
182                 cprintf("%d Send configuration...\n", SEND_LISTING);
183                 a = 0;
184                 while (client_gets(&ibuf), strcmp(ibuf, "000")) {
185                     switch(a) {
186                         case 0: safestrncpy(config.c_nodename, ibuf,
187                                         sizeof config.c_nodename);
188                                 break;
189                         case 1: safestrncpy(config.c_fqdn, ibuf,
190                                         sizeof config.c_fqdn);
191                                 break;
192                         case 2: safestrncpy(config.c_humannode, ibuf,
193                                         sizeof config.c_humannode);
194                                 break;
195                         case 3: safestrncpy(config.c_phonenum, ibuf,
196                                         sizeof config.c_phonenum);
197                                 break;
198                         case 4: config.c_creataide = atoi(ibuf);
199                                 break;
200                         case 5: config.c_sleeping = atoi(ibuf);
201                                 break;
202                         case 6: config.c_initax = atoi(ibuf);
203                                 if (config.c_initax < 1) config.c_initax = 1;
204                                 if (config.c_initax > 6) config.c_initax = 6;
205                                 break;
206                         case 7: config.c_regiscall = atoi(ibuf);
207                                 if (config.c_regiscall != 0)
208                                         config.c_regiscall = 1;
209                                 break;
210                         case 8: config.c_twitdetect = atoi(ibuf);
211                                 if (config.c_twitdetect != 0)
212                                         config.c_twitdetect = 1;
213                                 break;
214                         case 9: safestrncpy(config.c_twitroom, ibuf,
215                                         sizeof config.c_twitroom);
216                                 break;
217                         case 10: safestrncpy(config.c_moreprompt, ibuf,
218                                         sizeof config.c_moreprompt);
219                                 break;
220                         case 11: config.c_restrict = atoi(ibuf);
221                                 if (config.c_restrict != 0)
222                                         config.c_restrict = 1;
223                                 break;
224                         case 12: safestrncpy(config.c_bbs_city, ibuf,
225                                         sizeof config.c_bbs_city);
226                                 break;
227                         case 13: safestrncpy(config.c_sysadm, ibuf,
228                                         sizeof config.c_sysadm);
229                                 break;
230                         case 14: config.c_maxsessions = atoi(ibuf);
231                                 if (config.c_maxsessions < 1)
232                                         config.c_maxsessions = 1;
233                                 break;
234                         case 15: safestrncpy(config.c_net_password, ibuf,
235                                         sizeof config.c_net_password);
236                                 break;
237                         case 16: config.c_userpurge = atoi(ibuf);
238                                 break;
239                         case 17: config.c_roompurge = atoi(ibuf);
240                                 break;
241                         case 18: safestrncpy(config.c_logpages, ibuf,
242                                         sizeof config.c_logpages);
243                                 break;
244                         case 19: config.c_createax = atoi(ibuf);
245                                 if (config.c_createax < 1)
246                                         config.c_createax = 1;
247                                 if (config.c_createax > 6)
248                                         config.c_createax = 6;
249                                 break;
250                         case 20: if (atoi(ibuf) >= 8192)
251                                         config.c_maxmsglen = atoi(ibuf);
252                                 break;
253                         case 21: if (atoi(ibuf) >= 2)
254                                         config.c_min_workers = atoi(ibuf);
255                         case 22: if (atoi(ibuf) >= config.c_min_workers)
256                                         config.c_max_workers = atoi(ibuf);
257                         case 23: config.c_pop3_port = atoi(ibuf);
258                                 break;
259                         case 24: config.c_smtp_port = atoi(ibuf);
260                                 break;
261                         case 25: config.c_default_filter = atoi(ibuf);
262                                 break;
263                         case 26: config.c_aide_zap = atoi(ibuf);
264                                 if (config.c_aide_zap != 0)
265                                         config.c_aide_zap = 1;
266                                 break;
267                         case 27: config.c_imap_port = atoi(ibuf);
268                                 break;
269                         }
270                     ++a;
271                     }
272                 put_config();
273                 snprintf(buf,sizeof buf,
274                          "Global system configuration edited by %s\n",
275                          CC->curr_user);
276                 aide_message(buf);
277
278                 if (strlen(config.c_logpages) > 0)
279                         create_room(config.c_logpages, 3, "", 0, 1);
280                 }
281
282         else if (!strcasecmp(cmd, "GETSYS")) {
283                 extract(confname, argbuf, 1);
284                 confptr = CtdlGetSysConfig(confname);
285                 if (confptr != NULL) {
286                         cprintf("%d %s\n", LISTING_FOLLOWS, confname);
287                         client_write(confptr, strlen(confptr));
288                         if (confptr[strlen(confptr)-1] != 10)
289                                 client_write("\n", 1);
290                         cprintf("000\n");
291                         phree(confptr);
292                 }
293                 else {
294                         cprintf("%d No such configuration.\n",
295                                 ERROR+ILLEGAL_VALUE);
296                 }
297         }
298
299         else if (!strcasecmp(cmd, "PUTSYS")) {
300                 extract(confname, argbuf, 1);
301                 cprintf("%d %s\n", SEND_LISTING, confname);
302                 confptr = CtdlReadMessageBody("000", config.c_maxmsglen, NULL);
303                 CtdlPutSysConfig(confname, confptr);
304                 phree(confptr);
305         }
306
307         else {
308                 cprintf("%d Illegal option(s) specified.\n",
309                         ERROR+ILLEGAL_VALUE);
310                 }
311         }