X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fcontrol.c;h=b81526cf1dc855078349afb8ed70a4803bb0388d;hb=a9d212c452ddc4c041c6b1ca30670dde9a321a07;hp=68bbd51c77f8178bb4f26a36cdc89fc88aab03dc;hpb=fa36b0df38c64a226ec3076215567d6b3f572d42;p=citadel.git

diff --git a/citadel/control.c b/citadel/control.c
index 68bbd51c7..b81526cf1 100644
--- a/citadel/control.c
+++ b/citadel/control.c
@@ -1,8 +1,15 @@
 /*
- * $Id$
- *
  * This module handles states which are global to the entire server.
  *
+ * Copyright (c) 1987-2012 by the citadel.org team
+ *
+ *  This program is open source software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License version 3.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
  */
 
 #include "sysdep.h"
@@ -28,31 +35,130 @@
 #include <errno.h>
 #include <limits.h>
 #include <sys/types.h>
+#include <sys/file.h>
+#include <sys/stat.h>
+#include <libcitadel.h>
 #include "citadel.h"
 #include "server.h"
 #include "control.h"
-#include "serv_extensions.h"
 #include "sysdep_decls.h"
 #include "support.h"
 #include "config.h"
 #include "msgbase.h"
 #include "citserver.h"
-#include "tools.h"
 #include "room_ops.h"
+#include "user_ops.h"
+#include "database.h"
+#include "threads.h"
 
 #ifndef HAVE_SNPRINTF
 #include "snprintf.h"
 #endif
 
+#include "ctdl_module.h"
+
 struct CitControl CitControl;
 extern struct config config;
 FILE *control_fp = NULL;
+long control_highest_user = 0;
+
+
+/*
+ * lock_control  -  acquire a lock on the control record file.
+ *                  This keeps multiple citservers from running concurrently.
+ */
+void lock_control(void)
+{
+#if defined(LOCK_EX) && defined(LOCK_NB)
+	if (flock(fileno(control_fp), (LOCK_EX | LOCK_NB))) {
+		syslog(LOG_EMERG, "citserver: unable to lock %s.\n", file_citadel_control);
+		syslog(LOG_EMERG, "Is another citserver already running?\n");
+		exit(CTDLEXIT_CONTROL);
+	}
+#endif
+}
+
+/*
+ * callback to get highest room number when rebuilding control file
+ */
+void control_find_highest(struct ctdlroom *qrbuf, void *data)
+{
+	struct ctdlroom room;
+	struct cdbdata *cdbfr;
+	long *msglist;
+	int num_msgs=0;
+	int c;
+	int room_fixed = 0;
+	int message_fixed = 0;
+	
+	if (qrbuf->QRnumber > CitControl.MMnextroom)
+	{
+		CitControl.MMnextroom = qrbuf->QRnumber;
+		room_fixed = 1;
+	}
+		
+	CtdlGetRoom (&room, qrbuf->QRname);
+	
+	/* Load the message list */
+	cdbfr = cdb_fetch(CDB_MSGLISTS, &room.QRnumber, sizeof(long));
+	if (cdbfr != NULL) {
+		msglist = (long *) cdbfr->ptr;
+		num_msgs = cdbfr->len / sizeof(long);
+	} else {
+		return;	/* No messages at all?  No further action. */
+	}
+
+	if (num_msgs>0)
+	{
+		for (c=0; c<num_msgs; c++)
+		{
+			if (msglist[c] > CitControl.MMhighest)
+			{
+				CitControl.MMhighest = msglist[c];
+				message_fixed = 1;
+			}
+		}
+	}
+	cdb_free(cdbfr);
+	if (room_fixed)
+		syslog(LOG_INFO, "Control record checking....Fixed room counter\n");
+	if (message_fixed)
+		syslog(LOG_INFO, "Control record checking....Fixed message count\n");
+	return;
+}
+
+
+/*
+ * Callback to get highest user number.
+ */
+ 
+void control_find_user (struct ctdluser *EachUser, void *out_data)
+{
+	int user_fixed = 0;
+	
+	if (EachUser->usernum > CitControl.MMnextuser)
+	{
+		CitControl.MMnextuser = EachUser->usernum;
+		user_fixed = 1;
+	}
+	if(user_fixed)
+		syslog(LOG_INFO, "Control record checking....Fixed user count\n");
+}
+
 
 /*
  * get_control  -  read the control record into memory.
  */
 void get_control(void)
 {
+	static int already_have_control = 0;
+	int rv = 0;
+
+	/*
+	 * If we already have the control record in memory, there's no point
+	 * in reading it from disk again.
+	 */
+	if (already_have_control) return;
 
 	/* Zero it out.  If the control record on disk is missing or short,
 	 * the system functions with all control record fields initialized
@@ -62,28 +168,54 @@ void get_control(void)
 	if (control_fp == NULL) {
 		control_fp = fopen(file_citadel_control, "rb+");
 		if (control_fp != NULL) {
-			fchown(fileno(control_fp), config.c_ctdluid, -1);
+			lock_control();
+			rv = fchown(fileno(control_fp), config.c_ctdluid, -1);
+			if (rv == -1)
+				syslog(LOG_EMERG, "Failed to adjust ownership of: %s [%s]\n", 
+				       file_citadel_control, strerror(errno));
+			rv = fchmod(fileno(control_fp), S_IRUSR|S_IWUSR);
+			if (rv == -1)
+				syslog(LOG_EMERG, "Failed to adjust accessrights of: %s [%s]\n", 
+				       file_citadel_control, strerror(errno));
 		}
 	}
 	if (control_fp == NULL) {
 		control_fp = fopen(file_citadel_control, "wb+");
 		if (control_fp != NULL) {
-			fchown(fileno(control_fp), config.c_ctdluid, -1);
+			lock_control();
 			memset(&CitControl, 0, sizeof(struct CitControl));
-			fwrite(&CitControl, sizeof(struct CitControl),
-			       1, control_fp);
+
+			rv = fchown(fileno(control_fp), config.c_ctdluid, -1);
+			if (rv == -1)
+				syslog(LOG_EMERG, "Failed to adjust ownership of: %s [%s]\n", 
+				       file_citadel_control, strerror(errno));
+
+			rv = fchmod(fileno(control_fp), S_IRUSR|S_IWUSR);
+			if (rv == -1)
+				syslog(LOG_EMERG, "Failed to adjust accessrights of: %s [%s]\n", 
+				       file_citadel_control, strerror(errno));
+			rv = fwrite(&CitControl, sizeof(struct CitControl), 1, control_fp);
+			if (rv == -1)
+				syslog(LOG_EMERG, "Failed to write: %s [%s]\n", 
+				       file_citadel_control, strerror(errno));
 			rewind(control_fp);
 		}
 	}
 	if (control_fp == NULL) {
-		lprintf(CTDL_ALERT, "ERROR opening %s: %s\n",
-				file_citadel_control,
-				strerror(errno));
+		syslog(LOG_ALERT, "ERROR opening %s: %s\n", file_citadel_control, strerror(errno));
 		return;
 	}
 
 	rewind(control_fp);
-	fread(&CitControl, sizeof(struct CitControl), 1, control_fp);
+	rv = fread(&CitControl, sizeof(struct CitControl), 1, control_fp);
+	if (rv == -1)
+		syslog(LOG_EMERG, "Failed to read Controlfile: %s [%s]\n", 
+		       file_citadel_control, strerror(errno));
+	already_have_control = 1;
+	rv = chown(file_citadel_control, config.c_ctdluid, (-1));
+	if (rv == -1)
+		syslog(LOG_EMERG, "Failed to adjust ownership of: %s [%s]\n", 
+		       file_citadel_control, strerror(errno));	
 }
 
 /*
@@ -91,16 +223,44 @@ void get_control(void)
  */
 void put_control(void)
 {
+	int rv = 0;
 
 	if (control_fp != NULL) {
 		rewind(control_fp);
-		fwrite(&CitControl, sizeof(struct CitControl), 1,
-		       control_fp);
+		rv = fwrite(&CitControl, sizeof(struct CitControl), 1, control_fp);
+		if (rv == -1)
+			syslog(LOG_EMERG, "Failed to write: %s [%s]\n", 
+			       file_citadel_control, strerror(errno));
 		fflush(control_fp);
 	}
 }
 
 
+/*
+ * check_control   -  check the control record has sensible values for message, user and room numbers
+ */
+void check_control(void)
+{
+	syslog(LOG_INFO, "Checking/re-building control record\n");
+	get_control();
+	// Find highest room number and message number.
+	CtdlForEachRoom(control_find_highest, NULL);
+	ForEachUser(control_find_user, NULL);
+	put_control();
+}
+
+
+/*
+ * release_control - close our fd on exit
+ */
+void release_control(void)
+{
+	if (control_fp != NULL) {
+		fclose(control_fp);
+	}
+	control_fp = NULL;
+}
+
 /*
  * get_new_message_number()  -  Obtain a new, unique ID to be used for a message.
  */
@@ -116,6 +276,23 @@ long get_new_message_number(void)
 }
 
 
+/*
+ * CtdlGetCurrentMessageNumber()  -  Obtain the current highest message number in the system
+ * This provides a quick way to initialise a variable that might be used to indicate
+ * messages that should not be processed. EG. a new Sieve script will use this
+ * to record determine that messages older than this should not be processed.
+ */
+long CtdlGetCurrentMessageNumber(void)
+{
+	long retval = 0L;
+	begin_critical_section(S_CONTROL);
+	get_control();
+	retval = CitControl.MMhighest;
+	end_critical_section(S_CONTROL);
+	return(retval);
+}
+
+
 /*
  * get_new_user_number()  -  Obtain a new, unique ID to be used for a user.
  */
@@ -150,6 +327,10 @@ long get_new_room_number(void)
 
 /* 
  * Get or set global configuration options
+ *
+ * IF YOU ADD OR CHANGE FIELDS HERE, YOU *MUST* DOCUMENT YOUR CHANGES AT:
+ * http://www.citadel.org/doku.php?id=documentation:applicationprotocol
+ *
  */
 void cmd_conf(char *argbuf)
 {
@@ -222,6 +403,26 @@ void cmd_conf(char *argbuf)
 		cprintf("%d\n", config.c_journal_pubmsgs);
 		cprintf("%s\n", config.c_journal_dest);
 		cprintf("%s\n", config.c_default_cal_zone);
+		cprintf("%d\n", config.c_pftcpdict_port);
+		cprintf("%d\n", config.c_managesieve_port);
+	        cprintf("%d\n", config.c_auth_mode);
+	        cprintf("%s\n", config.c_funambol_host);
+	        cprintf("%d\n", config.c_funambol_port);
+	        cprintf("%s\n", config.c_funambol_source);
+	        cprintf("%s\n", config.c_funambol_auth);
+		cprintf("%d\n", config.c_rbl_at_greeting);
+		cprintf("%s\n", config.c_master_user);
+		cprintf("%s\n", config.c_master_pass);
+		cprintf("%s\n", config.c_pager_program);
+		cprintf("%d\n", config.c_imap_keep_from);
+		cprintf("%d\n", config.c_xmpp_c2s_port);
+		cprintf("%d\n", config.c_xmpp_s2s_port);
+		cprintf("%ld\n", config.c_pop3_fetch);
+		cprintf("%ld\n", config.c_pop3_fastest);
+		cprintf("%d\n", config.c_spam_flag_only);
+		cprintf("%d\n", config.c_guest_logins);
+		cprintf("%d\n", config.c_port_number);
+		cprintf("%d\n", config.c_ctdluid);
 		cprintf("000\n");
 	}
 
@@ -229,7 +430,7 @@ void cmd_conf(char *argbuf)
 		unbuffer_output();
 		cprintf("%d Send configuration...\n", SEND_LISTING);
 		a = 0;
-		while (client_getln(buf, sizeof buf), strcmp(buf, "000")) {
+		while (client_getln(buf, sizeof buf) >= 0 && strcmp(buf, "000")) {
 			switch (a) {
 			case 0:
 				safestrncpy(config.c_nodename, buf,
@@ -420,17 +621,85 @@ void cmd_conf(char *argbuf)
 			case 49:
 				safestrncpy(config.c_default_cal_zone, buf,
 						sizeof config.c_default_cal_zone);
+				break;
+			case 50:
+				config.c_pftcpdict_port = atoi(buf);
+				break;
+			case 51:
+				config.c_managesieve_port = atoi(buf);
+				break;
+			case 52:
+				config.c_auth_mode = atoi(buf);
+			case 53:
+				safestrncpy(config.c_funambol_host, buf,
+					sizeof config.c_funambol_host);
+				break;
+			case 54:
+				config.c_funambol_port = atoi(buf);
+				break;
+			case 55:
+				safestrncpy(config.c_funambol_source,
+					buf, 
+					sizeof config.c_funambol_source);
+				break;
+			case 56:
+				safestrncpy(config.c_funambol_auth,
+					buf,
+					sizeof config.c_funambol_auth);
+				break;
+			case 57:
+				config.c_rbl_at_greeting = atoi(buf);
+				break;
+			case 58:
+				safestrncpy(config.c_master_user, buf, sizeof config.c_master_user);
+				break;
+			case 59:
+				safestrncpy(config.c_master_pass, buf, sizeof config.c_master_pass);
+				break;
+			case 60:
+				safestrncpy(config.c_pager_program,
+					buf,
+					sizeof config.c_pager_program);
+				break;
+			case 61:
+				config.c_imap_keep_from = atoi(buf);
+				break;
+			case 62:
+				config.c_xmpp_c2s_port = atoi(buf);
+				break;
+			case 63:
+				config.c_xmpp_s2s_port = atoi(buf);
+				break;
+			case 64:
+				config.c_pop3_fetch = atol(buf);
+				break;
+			case 65:
+				config.c_pop3_fastest = atol(buf);
+				break;
+			case 66:
+				config.c_spam_flag_only = atoi(buf);
+				break;
+			case 67:
+				config.c_guest_logins = atoi(buf);
+				break;
+			case 68:
+				config.c_port_number = atoi(buf);
+				break;
+			case 69:
+				config.c_ctdluid = atoi(buf);
+				break;
 			}
 			++a;
 		}
 		put_config();
 		snprintf(buf, sizeof buf,
-			 "The global system configuration has been edited by %s.\n",
-			 CC->curr_user);
-		aide_message(buf);
+			"The global system configuration has been edited by %s.\n",
+			 (CC->logged_in ? CC->curr_user : "an administrator")
+		);
+		CtdlAideMessage(buf,"Citadel Configuration Manager Message");
 
-		if (strlen(config.c_logpages) > 0)
-			create_room(config.c_logpages, 3, "", 0, 1, 1, VIEW_BBS);
+		if (!IsEmptyStr(config.c_logpages))
+			CtdlCreateRoom(config.c_logpages, 3, "", 0, 1, 1, VIEW_BBS);
 
 		/* If full text indexing has been disabled, invalidate the
 		 * index so it doesn't try to use it later.
@@ -445,9 +714,12 @@ void cmd_conf(char *argbuf)
 		extract_token(confname, argbuf, 1, '|', sizeof confname);
 		confptr = CtdlGetSysConfig(confname);
 		if (confptr != NULL) {
+			long len; 
+
+			len = strlen(confptr);
 			cprintf("%d %s\n", LISTING_FOLLOWS, confname);
-			client_write(confptr, strlen(confptr));
-			if (confptr[strlen(confptr) - 1] != 10)
+			client_write(confptr, len);
+			if ((len > 0) && (confptr[len - 1] != 10))
 				client_write("\n", 1);
 			cprintf("000\n");
 			free(confptr);
@@ -461,8 +733,7 @@ void cmd_conf(char *argbuf)
 		extract_token(confname, argbuf, 1, '|', sizeof confname);
 		unbuffer_output();
 		cprintf("%d %s\n", SEND_LISTING, confname);
-		confptr = CtdlReadMessageBody("000",
-				config.c_maxmsglen, NULL, 0);
+		confptr = CtdlReadMessageBody(HKEY("000"), config.c_maxmsglen, NULL, 0, 0);
 		CtdlPutSysConfig(confname, confptr);
 		free(confptr);
 	}
@@ -472,3 +743,18 @@ void cmd_conf(char *argbuf)
 			ERROR + ILLEGAL_VALUE);
 	}
 }
+
+
+/*****************************************************************************/
+/*                      MODULE INITIALIZATION STUFF                          */
+/*****************************************************************************/
+
+
+CTDL_MODULE_INIT(control)
+{
+	if (!threading) {
+		CtdlRegisterProtoHook(cmd_conf, "CONF", "get/set system configuration");
+	}
+	/* return our id for the Log */
+	return "control";
+}