[doldaconnect.git] / daemon / conf.c

/*
 *  Dolda Connect - Modular multiuser Direct Connect-style client
 *  Copyright (C) 2004 Fredrik Tolf (fredrik@dolda2000.com)
 *  
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *  
 *  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.
 *  
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/
#include <langinfo.h>
#include <stdio.h>
#include <unistd.h>
#include <malloc.h>
#include <string.h>
#include <sys/types.h>
#include <errno.h>
#include <wctype.h>
#include <stddef.h>
#include <wchar.h>
#include <iconv.h>
#include <arpa/inet.h>

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include "conf.h"
#include "log.h"
#include "utils.h"

static struct configmod *modules = NULL;

#if 0
static void dumpconfig(void)
{
    struct configmod *mod;
    struct configvar *var;
    
    for(mod = modules; mod != NULL; mod = mod->next)
    {
	printf("%s:\n", mod->name);
	for(var = mod->vars; var->type != CONF_VAR_END; var++)
	{
	    switch(var->type)
	    {
	    case CONF_VAR_BOOL:
		printf("\t%s: %s\n", var->name, var->val.num?"t":"f");
		break;
	    case CONF_VAR_INT:
		printf("\t%s: %i\n", var->name, var->val.num);
		break;
	    case CONF_VAR_STRING:
		printf("\t%s: \"%ls\" (%i)\n", var->name, var->val.str, wcslen(var->val.str));
		break;
	    case CONF_VAR_IPV4:
		printf("\t%s: %s\n", var->name, inet_ntoa(var->val.ipv4));
		break;
	    }
	}
    }
}
#endif

struct configvar *confgetvar(char *modname, char *varname)
{
    struct configmod *m;
    struct configvar *v;
    
    for(m = modules; m != NULL; m = m->next)
    {
	if(!strcmp(m->name, modname))
	{
	    for(v = m->vars; v->type != CONF_VAR_END; v++)
	    {
		if(!strcmp(v->name, varname))
		    return(v);
	    }
	    break;
	}
    }
    return(NULL);
}

void confregmod(struct configmod *mod)
{
    struct configvar *var;
    
    for(var = mod->vars; var->type != CONF_VAR_END; var++)
    {
	switch(var->type)
	{
	case CONF_VAR_BOOL:
	case CONF_VAR_INT:
	    var->val.num = var->defaults.num;
	    break;
	case CONF_VAR_STRING:
	    if(var->defaults.str != NULL)
	    {
		var->val.str = swcsdup(var->defaults.str);
	    } else {
		var->val.str = NULL;
	    }
	    break;
	case CONF_VAR_IPV4:
	    var->val.ipv4.s_addr = var->defaults.ipv4.s_addr;
	    break;
	}
	CBCHAININIT(var, conf_update);
    }
    mod->next = modules;
    modules = mod;
}

int runconfcmd(int argc, wchar_t **argv)
{
    struct configmod *module;
    struct configvar *var;
    struct configcmd *cmd;
    int ret, handled;
    wchar_t *p;
    char *cmdn, *buf, *buf2, *valbuf;
    long num;
    struct in_addr newipv4;
    int cb;
    
    if(argc < 1)
	return(0);
    if((cmdn = icwcstombs(argv[0], "us-ascii")) == NULL)
    {
	flog(LOG_WARNING, "could not convert %ls to us-ascii", argv[0]);
	return(1);
    }
    ret = 1;
    handled = 0;
    if(!strcmp(cmdn, "set"))
    {
	handled = 1;
	ret = 0;
	if((p = wcschr(argv[1], L'.')) == NULL)
	{
	    flog(LOG_WARNING, "illegal configuration variable format: %ls", argv[1]);
	    errno = EINVAL;
	    free(cmdn);
	    return(1);
	}
	*(p++) = L'\0';
	if((buf = icwcstombs(argv[1], "us-ascii")) == NULL)
	{
	    flog(LOG_WARNING, "could not convert %ls to us-ascii", argv[1]);
	    free(cmdn);
	    return(1);
	}
	if((buf2 = icwcstombs(p, "us-ascii")) == NULL)
	{
	    free(buf);
	    flog(LOG_WARNING, "could not convert %ls to us-ascii", p);
	    free(cmdn);
	    return(1);
	}
	for(module = modules; module != NULL; module = module->next)
	{
	    if(!strcmp(module->name, buf) && (module->vars != NULL))
	    {
		for(var = module->vars; var->type != CONF_VAR_END; var++)
		{
		    if(!strcmp(var->name, buf2))
		    {
			cb = 0;
			switch(var->type)
			{
			case CONF_VAR_BOOL:
			    wcstolower(argv[2]);
			    if(!wcscmp(argv[2], L"off") ||
			       !wcscmp(argv[2], L"false") ||
			       !wcscmp(argv[2], L"no") ||
			       !wcscmp(argv[2], L"0"))
			    {
				if(var->val.num)
				    cb = 1;
				var->val.num = 0;
			    } else if(!wcscmp(argv[2], L"on") ||
				      !wcscmp(argv[2], L"true") ||
				      !wcscmp(argv[2], L"yes") ||
				      !wcscmp(argv[2], L"1")) {
				if(!var->val.num)
				    cb = 1;
				var->val.num = 1;
			    } else {
				flog(LOG_WARNING, "unrecognized boolean: %ls", argv[2]);
			    }
			    break;
			case CONF_VAR_INT:
			    num = wcstol(argv[2], &p, 0);
			    if(p == argv[2])
			    {
				flog(LOG_WARNING, "%ls: not a number, ignoring", argv[2]);
				ret = 1;
			    } else {
				if(*p != L'\0')
				    flog(LOG_WARNING, "%ls: could not entirely parse as a number, ignoring trailing garbage", argv[2]);
				if(num != var->val.num)
				    cb = 1;
				var->val.num = num;
			    }
			    break;
			case CONF_VAR_STRING:
			    if(wcscmp(var->val.str, argv[2]))
				cb = 1;
			    free(var->val.str);
			    var->val.str = swcsdup(argv[2]);
			    break;
			case CONF_VAR_IPV4:
			    if((valbuf = icwcstombs(argv[2], "us-ascii")) == NULL)
			    {
				flog(LOG_WARNING, "could not convert IPv4 address to as-ascii in var %s, ignoring", buf2);
			    } else {
				if(!inet_aton(valbuf, &newipv4))
				{
				    flog(LOG_WARNING, "could not parse IPv4 address (%s), ignoring", valbuf);
				    memcpy(&var->val.ipv4, &var->defaults.ipv4, sizeof(var->val.ipv4));
				} else {
				    if(memcmp(&newipv4, &var->val.ipv4, sizeof(newipv4)))
					cb = 1;
				    memcpy(&var->val.ipv4, &newipv4, sizeof(newipv4));
				}
				free(valbuf);
			    }
			    break;
			}
			if(cb)
			    CBCHAINDOCB(var, conf_update, var);
			break;
		    }
		}
		if(var == NULL)
		    flog(LOG_WARNING, "variable %s not found, ignoring set command", buf2);
		break;
	    }
	}
	if(module == NULL)
	    flog(LOG_WARNING, "module %s not found, ignoring set command", buf);
	free(buf2);
	free(buf);
    }
    for(module = modules; !handled && (module != NULL); module = module->next)
    {
	if(module->cmds != NULL)
	{
	    for(cmd = module->cmds; cmd->name != NULL; cmd++)
	    {
		if(!strcmp(cmd->name, cmdn))
		{
		    handled = 1;
		    ret = cmd->handler(argc, argv);
		    break;
		}
	    }
	}
    }
    if(!handled)
	flog(LOG_WARNING, "command not found: %s", cmdn);
    free(cmdn);
    return(ret);
}

void readconfig(FILE *stream)
{
    int state;
    wint_t c;
    wchar_t *words[16];
    wchar_t *buf, *p, *p2;
    int w;
    int line;
    
    buf = smalloc(sizeof(wchar_t) * 1024);
    state = 0;
    c = getwc(stream);
    w = 0;
    line = 1;
    p = buf;
    while(c != WEOF)
    {
	if(c == '#')
	{
	    do
		c = getwc(stream);
	    while((c != WEOF) && (c != L'\n'));
	    continue;
	}
	switch(state)
	{
	case 0:
	    if(iswspace(c))
	    {
		if(c == L'\n')
		{
		    line++;
		    if(runconfcmd(w, words))
			flog(LOG_WARNING, "ignoring this command on line %i", line);
		    w = 0;
		}
		c = getwc(stream);
	    } else {
		state = 1;
		p2 = p;
	    }
	    break;
	case 1:
	    if(c == L'\"')
	    {
		state = 2;
		c = getwc(stream);
	    } else if(iswspace(c)) {
		if(w >= 16)
		{
		    flog(LOG_WARNING, "too many words on config line %i, ignoring rest", line);
		} else {
		    *(p++) = L'\0';
		    words[w++] = p2;
		}
		state = 0;
	    } else {
		if(c == L'\\')
		    c = getwc(stream);
		if(p - buf < 1023)
		    *(p++) = c;
		else
		    flog(LOG_WARNING, "too many characters on config line %i, ignoring rest", line);
		c = getwc(stream);
	    }
	    break;
	case 2:
	    if(c == L'\"')
	    {
		c = getwc(stream);
		state = 1;
	    } else {
		if(c == L'\\')
		    c = getwc(stream);
		if(p - buf < 1023)
		    *(p++) = c;
		else
		    flog(LOG_WARNING, "too many characters on config line %i, ignoring rest", line);
		c = getwc(stream);
	    }
	    break;
	}
    }
    free(buf);
    if(ferror(stream))
	flog(LOG_WARNING, "error on configuration stream: %s", strerror(errno));
    if(state != 0)
	flog(LOG_WARNING, "unexpected end of file");
}
Commit	Line	Data
d3372da9	1	/*
	2	* Dolda Connect - Modular multiuser Direct Connect-style client
	3	* Copyright (C) 2004 Fredrik Tolf (fredrik@dolda2000.com)
	4	*
	5	* This program is free software; you can redistribute it and/or modify
	6	* it under the terms of the GNU General Public License as published by
	7	* the Free Software Foundation; either version 2 of the License, or
	8	* (at your option) any later version.
	9	*
	10	* This program is distributed in the hope that it will be useful,
	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	* GNU General Public License for more details.
	14	*
	15	* You should have received a copy of the GNU General Public License
	16	* along with this program; if not, write to the Free Software
	17	* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	18	*/
	19	#include <langinfo.h>
	20	#include <stdio.h>
	21	#include <unistd.h>
	22	#include <malloc.h>
	23	#include <string.h>
	24	#include <sys/types.h>
	25	#include <errno.h>
	26	#include <wctype.h>
	27	#include <stddef.h>
	28	#include <wchar.h>
	29	#include <iconv.h>
	30	#include <arpa/inet.h>
	31
	32	#ifdef HAVE_CONFIG_H
	33	#include <config.h>
	34	#endif
	35	#include "conf.h"
	36	#include "log.h"
	37	#include "utils.h"
	38
	39	static struct configmod *modules = NULL;
	40
	41	#if 0
	42	static void dumpconfig(void)
	43	{
	44	struct configmod *mod;
	45	struct configvar *var;
	46
	47	for(mod = modules; mod != NULL; mod = mod->next)
	48	{
	49	printf("%s:\n", mod->name);
	50	for(var = mod->vars; var->type != CONF_VAR_END; var++)
	51	{
	52	switch(var->type)
	53	{
	54	case CONF_VAR_BOOL:
	55	printf("\t%s: %s\n", var->name, var->val.num?"t":"f");
	56	break;
	57	case CONF_VAR_INT:
	58	printf("\t%s: %i\n", var->name, var->val.num);
	59	break;
	60	case CONF_VAR_STRING:
	61	printf("\t%s: \"%ls\" (%i)\n", var->name, var->val.str, wcslen(var->val.str));
	62	break;
	63	case CONF_VAR_IPV4:
	64	printf("\t%s: %s\n", var->name, inet_ntoa(var->val.ipv4));
65	break;
66	}
67	}
68	}
69	}
70	#endif
71
72	struct configvar confgetvar(char modname, char *varname)
73	{
74	struct configmod *m;
75	struct configvar *v;
76
77	for(m = modules; m != NULL; m = m->next)
78	{
79	if(!strcmp(m->name, modname))
80	{
81	for(v = m->vars; v->type != CONF_VAR_END; v++)
82	{
83	if(!strcmp(v->name, varname))
84	return(v);
85	}
86	break;
87	}
88	}
89	return(NULL);
90	}
91
92	void confregmod(struct configmod *mod)
93	{
94	struct configvar *var;
95
96	for(var = mod->vars; var->type != CONF_VAR_END; var++)
97	{
98	switch(var->type)
99	{
100	case CONF_VAR_BOOL:
101	case CONF_VAR_INT:
102	var->val.num = var->defaults.num;
103	break;
104	case CONF_VAR_STRING:
105	if(var->defaults.str != NULL)
106	{
107	var->val.str = swcsdup(var->defaults.str);
108	} else {
109	var->val.str = NULL;
110	}
111	break;
112	case CONF_VAR_IPV4:
113	var->val.ipv4.s_addr = var->defaults.ipv4.s_addr;
114	break;
115	}
116	CBCHAININIT(var, conf_update);
117	}
118	mod->next = modules;
119	modules = mod;
120	}
121
122	int runconfcmd(int argc, wchar_t **argv)
123	{
124	struct configmod *module;
125	struct configvar *var;
126	struct configcmd *cmd;
127	int ret, handled;
128	wchar_t *p;
129	char cmdn, buf, buf2, valbuf;
130	long num;
131	struct in_addr newipv4;
132	int cb;
133
134	if(argc < 1)
135	return(0);
136	if((cmdn = icwcstombs(argv[0], "us-ascii")) == NULL)
137	{
138	flog(LOG_WARNING, "could not convert %ls to us-ascii", argv[0]);
139	return(1);
140	}
141	ret = 1;
142	handled = 0;
143	if(!strcmp(cmdn, "set"))
144	{
145	handled = 1;
146	ret = 0;
147	if((p = wcschr(argv[1], L'.')) == NULL)
148	{
149	flog(LOG_WARNING, "illegal configuration variable format: %ls", argv[1]);
150	errno = EINVAL;
151	free(cmdn);
152	return(1);
153	}
154	*(p++) = L'\0';
155	if((buf = icwcstombs(argv[1], "us-ascii")) == NULL)
156	{
157	flog(LOG_WARNING, "could not convert %ls to us-ascii", argv[1]);
158	free(cmdn);
159	return(1);
160	}
161	if((buf2 = icwcstombs(p, "us-ascii")) == NULL)
162	{
163	free(buf);
164	flog(LOG_WARNING, "could not convert %ls to us-ascii", p);
165	free(cmdn);
166	return(1);
167	}
168	for(module = modules; module != NULL; module = module->next)
169	{
170	if(!strcmp(module->name, buf) && (module->vars != NULL))
171	{
172	for(var = module->vars; var->type != CONF_VAR_END; var++)
173	{
174	if(!strcmp(var->name, buf2))
175	{
176	cb = 0;
177	switch(var->type)
178	{
179	case CONF_VAR_BOOL:
180	wcstolower(argv[2]);
181	if(!wcscmp(argv[2], L"off") \|\|
182	!wcscmp(argv[2], L"false") \|\|
183	!wcscmp(argv[2], L"no") \|\|
184	!wcscmp(argv[2], L"0"))
185	{
186	if(var->val.num)
187	cb = 1;
188	var->val.num = 0;
189	} else if(!wcscmp(argv[2], L"on") \|\|
190	!wcscmp(argv[2], L"true") \|\|
191	!wcscmp(argv[2], L"yes") \|\|
192	!wcscmp(argv[2], L"1")) {
193	if(!var->val.num)
194	cb = 1;
195	var->val.num = 1;
196	} else {
197	flog(LOG_WARNING, "unrecognized boolean: %ls", argv[2]);
198	}
199	break;
200	case CONF_VAR_INT:
201	num = wcstol(argv[2], &p, 0);
202	if(p == argv[2])
203	{
204	flog(LOG_WARNING, "%ls: not a number, ignoring", argv[2]);
205	ret = 1;
206	} else {
207	if(*p != L'\0')
208	flog(LOG_WARNING, "%ls: could not entirely parse as a number, ignoring trailing garbage", argv[2]);
209	if(num != var->val.num)
210	cb = 1;
211	var->val.num = num;
212	}
213	break;
214	case CONF_VAR_STRING:
215	if(wcscmp(var->val.str, argv[2]))
216	cb = 1;
217	free(var->val.str);
218	var->val.str = swcsdup(argv[2]);
219	break;
220	case CONF_VAR_IPV4:
221	if((valbuf = icwcstombs(argv[2], "us-ascii")) == NULL)
222	{
223	flog(LOG_WARNING, "could not convert IPv4 address to as-ascii in var %s, ignoring", buf2);
224	} else {
225	if(!inet_aton(valbuf, &newipv4))
226	{
227	flog(LOG_WARNING, "could not parse IPv4 address (%s), ignoring", valbuf);
228	memcpy(&var->val.ipv4, &var->defaults.ipv4, sizeof(var->val.ipv4));
229	} else {
230	if(memcmp(&newipv4, &var->val.ipv4, sizeof(newipv4)))
231	cb = 1;
232	memcpy(&var->val.ipv4, &newipv4, sizeof(newipv4));
233	}
234	free(valbuf);
235	}
236	break;
237	}
238	if(cb)
239	CBCHAINDOCB(var, conf_update, var);
240	break;
241	}
242	}
243	if(var == NULL)
244	flog(LOG_WARNING, "variable %s not found, ignoring set command", buf2);
245	break;
246	}
247	}
248	if(module == NULL)
249	flog(LOG_WARNING, "module %s not found, ignoring set command", buf);
250	free(buf2);
251	free(buf);
252	}
253	for(module = modules; !handled && (module != NULL); module = module->next)
254	{
255	if(module->cmds != NULL)
256	{
257	for(cmd = module->cmds; cmd->name != NULL; cmd++)
258	{
259	if(!strcmp(cmd->name, cmdn))
260	{
261	handled = 1;
262	ret = cmd->handler(argc, argv);
263	break;
264	}
265	}
266	}
267	}
268	if(!handled)
269	flog(LOG_WARNING, "command not found: %s", cmdn);
270	free(cmdn);
271	return(ret);
272	}
273
d3372da9	274	void readconfig(FILE *stream)
	275	{
	276	int state;
	277	wint_t c;
	278	wchar_t *words[16];
	279	wchar_t buf, p, *p2;
	280	int w;
	281	int line;
	282
	283	buf = smalloc(sizeof(wchar_t) * 1024);
	284	state = 0;
	285	c = getwc(stream);
	286	w = 0;
	287	line = 1;
	288	p = buf;
	289	while(c != WEOF)
	290	{
	291	if(c == '#')
	292	{
	293	do
	294	c = getwc(stream);
	295	while((c != WEOF) && (c != L'\n'));
	296	continue;
	297	}
	298	switch(state)
	299	{
	300	case 0:
	301	if(iswspace(c))
	302	{
	303	if(c == L'\n')
	304	{
	305	line++;
	306	if(runconfcmd(w, words))
	307	flog(LOG_WARNING, "ignoring this command on line %i", line);
	308	w = 0;
	309	}
	310	c = getwc(stream);
	311	} else {
	312	state = 1;
	313	p2 = p;
	314	}
	315	break;
	316	case 1:
	317	if(c == L'\"')
	318	{
	319	state = 2;
	320	c = getwc(stream);
	321	} else if(iswspace(c)) {
	322	if(w >= 16)
	323	{
	324	flog(LOG_WARNING, "too many words on config line %i, ignoring rest", line);
	325	} else {
	326	*(p++) = L'\0';
	327	words[w++] = p2;
	328	}
	329	state = 0;
	330	} else {
	331	if(c == L'\\')
	332	c = getwc(stream);
	333	if(p - buf < 1023)
	334	*(p++) = c;
	335	else
	336	flog(LOG_WARNING, "too many characters on config line %i, ignoring rest", line);
	337	c = getwc(stream);
338	}
339	break;
340	case 2:
341	if(c == L'\"')
342	{
343	c = getwc(stream);
344	state = 1;
345	} else {
346	if(c == L'\\')
347	c = getwc(stream);
348	if(p - buf < 1023)
349	*(p++) = c;
350	else
351	flog(LOG_WARNING, "too many characters on config line %i, ignoring rest", line);
352	c = getwc(stream);
353	}
354	break;
355	}
356	}
357	free(buf);
358	if(ferror(stream))
359	flog(LOG_WARNING, "error on configuration stream: %s", strerror(errno));
360	if(state != 0)
361	flog(LOG_WARNING, "unexpected end of file");
362	}