/* Copyright (C) 1995 EGLE Magic, New Zealand, All rights reserved. */
#include <stdlib.h>
#include <stdio.h>
#include <ctype.h>
#include <string.h>
#include <assert.h>
#ifndef NO_FCNTL
#include <fcntl.h>
#else
#include <file.h>
#endif
#include "emsg.h"
#include "dnews.h"
#include "sary.h"
#include "str.h"
#include "lib.h"
#include "group.h"
#include "hist.h"
#include "suck.h"
#include "feed.h"
#include "item.h"
#include "control.h"

/* If suck sees a message is a control item, then it calls this routine */
/*
  Possibilities are:
	cancel
	rmgroup	
	newgroup
	version
  All other control messages are logged but not actioned.
*/
#define TEMP_ITEM file_work("control.email")
#define CONTROL file_config("control.conf") 
#define VERSION_FILE file_config("version.file") 
#define BFSZ 200
static char action[BFSZ],gname[BFSZ],from[BFSZ],thecmd[BFSZ];
void fix_address(char *in);
int ctl_process(char *chead, String *xitem)
{
	int i;
	int lvl;
	char *ismod;
	char bf[BFSZ],approved[BFSZ];
	char subj[BFSZ+100],title[BFSZ];
	Sary *cfile; 
	FILE *f;
	char *s;
#ifdef VMS
	char *vx="$ ";
	char *vxc="$ !";
#else
	char *vx="";
	char *vxc="";
#endif
	ncpy(thecmd,get_word(chead,0),50);
	strlwr(thecmd);
	imsg("control: Control message {%s} \n",chead);
	if (strcmp(thecmd,"cancel")==0) return ctl_cancel(chead,xitem);

	ncpy(from,get_ahead(xitem,"Sender:"),BFSZ-1);
	if (strlen(from)==0) ncpy(from,get_ahead(xitem,"From:"),BFSZ-1);
	fix_address(from);
	ncpy(gname,get_word(chead,1),BFSZ-1);

	/* Proces control.conf */
	cfile = s_alloc();
	strcpy(action,"mail"); /* Default action, mail it*/
	s_read(cfile,CONTROL);
	for (i=0; i<s_len(cfile); i++) {
		ctl_line(s_line(cfile,i));
	}
	s_free(cfile);

	if (strcmp(action,"doit")==0) lvl = 5;
	else if (strcmp(action,"mail,doit")==0) lvl = 4;
	else if (strcmp(action,"doit,mail")==0) lvl = 4;
	else if (strcmp(action,"mail")==0) lvl = 3;
	else if (strcmp(action,"log")==0) lvl = 2;
	else if (strcmp(action,"drop")==0) lvl = 1;
	if (lvl==4) strcpy(action,"doit");

	if ((strcmp(thecmd,"rmgroup")==0) ||
		(strcmp(thecmd,"newgroup")==0)) {
		ncpy(approved,get_ahead(xitem,"Approved:"),BFSZ-1);
		fix_address(approved);
		/* Can't think of anything useful to compare this too 
		   so am just checking that it exists.  */
		if (strlen(approved)==0) {
			emsg("control: Rejecting un-approved posting\n");
			return FALSE;
		}		
	} 


	/* DOIT */
	if (lvl==1) return TRUE;

	if (strcmp(thecmd,"newgroup")==0) {
		strcpy(title,"");
		s = strstr(str_s(xitem),"For your newsgroups file:") ;
		if (s!=NULL) {
			s = strstr(s,gname);
			if (s!=NULL) {
				ncpy(title,s,100);
				s = strchr(title,'\015'); 
				if (s!=NULL) *s = 0;
			}
		}

	}
	ismod = "y";
	if (strstr(get_word(chead,2),"moderated")!=NULL) ismod = "m";

	sprintf(bf,"control_%s.%s",thecmd,action);
	f = xfopen(file_log(bf),"a");
	if (f==NULL) {filemsg("Unable to write log file %s \n",file_log(bf)); return;}
	if (strcmp(thecmd,"newgroup")==0) {
		fprintf(f,"%stellnews newgroup %s %s %s %s \n",vx,gname,ismod,from,title);	/* Add time stamp. */
	} else if (strcmp(thecmd,"rmgroup")==0) {
		fprintf(f,"%stellnews %s # %s \n",vx,chead,from);	/* Add time stamp. */
	} else {
		fprintf(f,"%s# Other  %s %s %s \n",vxc,action,from,chead);	/* Add time stamp. */
	}
	xfclose(f);

	if (lvl==2) return TRUE;

	if (lvl!=5) {
		remove(TEMP_ITEM);
		str_write(xitem,TEMP_ITEM);
		sprintf(subj,"Done: %s",chead);
		if (lvl==3) sprintf(subj,"Logged only: %s",chead);
		if (!lib_mail_msg(config_get(C_MANAGER),subj,TEMP_ITEM)) {
			emsg("Failed to send %s to %s \n",TEMP_ITEM,config_get(C_MANAGER));
		}
	}
	if (lvl==3) return TRUE;

	/*
		For your newsgroups file:
		soc.genealogy.misc	General genealogical discussions.
	*/

	if (strcmp(thecmd,"rmgroup")==0) group_delete(group_find(gname));
	else if (strcmp(thecmd,"newgroup")==0) group_new(gname,from,ismod,title);
	else if (strcmp(thecmd,"version")==0) {
		sprintf(bf,"Version %s (%s)",DNEWS_VERSION,lib_getlicense());
		lib_mail_msg(from,bf,VERSION_FILE);
	}
	group_write(); 
	return TRUE;
}
/* in=  cmd:mail:groups:action */
/* KNOWN BUG, BLANKS ARE NOT VALID BETWEEN COLONS*/
void ctl_line(char *in)
{
	char tmpaction[BFSZ];
	char fwild[BFSZ],gwild[BFSZ];
	char cmd[BFSZ];
	char *s;
	
	strlwr(in);
	s = strtok(in,":\n");	if (s==NULL) return;
	if (*s=='#') return;
	ncpy(cmd,s,90);
	s = strtok(NULL,":\n");	if (s==NULL) return;
	ncpy(fwild,s,BFSZ-1);	
	s = strtok(NULL,":\n");	if (s==NULL) return;
	ncpy(gwild,s,BFSZ-1);	
	s = strtok(NULL,":\n");	if (s==NULL) return;
	ncpy(tmpaction,s,BFSZ-1);	

	/* if group command check if gwild matches gname */
	if (strcmp(cmd,"newgroup")==0 || strcmp(cmd,"rmgroup")==0) {
		if (!group_match(gwild,gname)) {
			dmsg("controlx: Group didn't match {%s} {%s} \n",gname,gwild);
			return;
		}
	}
	if (!match_wild(fwild,from)) {
		dmsg("controlx: from didn't match {%s} {%s} \n",fwild,from);
		return;
	}
	if (strcmp(cmd,"all")!=0) {
	if (strcmp(thecmd,cmd)!=0) {
		dmsg("controlx: Command didn't match {%s} {%s} \n",thecmd,cmd);
		return;
	}
	}
	/* Ok, we matched, so copy the action command */
	strcpy(action,tmpaction);
	
}
/* 	if article exists 
		Verify from or senders match, then delete both.
	Otherwise, 
		Add a dummy line to history database, so if seen again
		it will not be accepted 

If returns 'true' pass this message on to our feeds, if false, then
don't.
*/
static char cfrom[BFSZ];
int ctl_cancel(char *chead, String *xitem) 
{
	char mid[BFSZ];
	int grp,num;
	String *head;
	ncpy(mid,get_word(chead,1),BFSZ-1);	
	if (!hist_find(mid,&grp,&num)) {
		/* Add to history so we won't accept it when it arrives.
		   Minor bug, this doesn't check that it matches!!!
		   Tough shit, it won't get anywhere if it doesn't anyway.
		*/
		hist_add(mid,"1-Jan-95 1:01:01 GMT","","");
		return FALSE; 
	}

	/* Get the real item, if we can, and verify it matches. */	
	head = item_head(grp,num);
	if (head==NULL) return FALSE; /* It's already deleted, */	

	/* Get the VERIFIED sender of both articles */
	ncpy(from,get_ahead(head,"Sender:"),BFSZ-1);
	if (strlen(from)==0) ncpy(from,get_ahead(head,"From:"),BFSZ-1);
	fix_address(from);

	ncpy(cfrom,get_ahead(xitem,"Sender:"),BFSZ-1);
	if (strlen(cfrom)==0) ncpy(cfrom,get_ahead(xitem,"From:"),BFSZ-1);
	fix_address(cfrom);

	/* Now compare, not case sensitive  */
	strlwr(cfrom); strlwr(from);
	if (strcmp(cfrom,from)!=0) {
		wmsg("cancel: Cancel failed, not from the same user {%s} {%s} \n",cfrom,from);
		return FALSE;
	}

	/* Now delete the item, damn that's tricky.  */	
	imsg("cancel: Deleting cancelled item %d %d \n",grp,num);
	item_delete(grp,num);
	return TRUE;	
}
/*
	Input:  joe <a@x.y.z>	or  a@x.y.z (joe)
	output: a@x.y.z
*/
void fix_address(char *in)
{
	char bf[200];
	char *s;

	ncpy(bf,in,199);
	
	s = strtok(bf," \t\n<>");		
	for (;s!=NULL;) {
		if (*s!='(') {  /* Because users can edit this bit!!!*/
			if (strstr(s,"@")!=NULL) {strcpy(in,s); return;}
		}
		s = strtok(NULL," \t\n<>()");		
	}
	emsg("control: Invalid address {%s} \n",in);
	return;
}