#include <fcntl.h>
#include <sys/file.h>
#include <signal.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include "str.h"
#include "fmt.h"
#include "buffer.h"
#define NOVARS
#include "minit.h"
#include <errmsg.h>
#include <errno.h>

static int infd,outfd;

static char buf[1500];

void addservice(char* service) {
  char* x;
  if (str_start(service,MINITROOT "/"))
    service+=sizeof(MINITROOT "/") -1;
  x=service+str_len(service)-1;
  while (x>service && *x=='/') { *x=0; --x; }
  strncpy(buf+1,service,1400);
  buf[1400]=0;
}

int addreadwrite(char* service) {
  addservice(service);
  write(infd,buf,str_len(buf));
  return read(outfd,buf,1500);
}

/* return PID, 0 if error */
pid_t __readpid(char *service) {
  int len;
  buf[0]='p';
  len=addreadwrite(service);
  if (len<0) return 0;
  buf[len]=0;
  return atoi(buf);
}

/* return nonzero if error */
int respawn(char *service,int yesno) {
  int len;
  buf[0]=yesno?'R':'r';
  len=addreadwrite(service);
  return (len!=1 || buf[0]=='0');
}

/* return nonzero if error */
int setpid(char *service, pid_t pid) {
  char *tmp;
  int len;
  buf[0]='P';
  addservice(service);
  tmp=buf+str_len(buf)+1;
  tmp[fmt_ulong(tmp,pid)]=0;
  write(infd,buf,str_len(buf)+str_len(tmp)+2);
  len=read(outfd,buf,1500);
  return (len!=1 || buf[0]=='0');
}

/* return nonzero if error */
int check_remove(char *service) {
  int len;
  buf[0]='C';
  len=addreadwrite(service);
  return (len!=1 || buf[0]=='0');
}

/* return nonzero if error */
int startservice(char *service) {
  int len;
  buf[0]='s';
  len=addreadwrite(service);
  return (len!=1 || buf[0]=='0');
}

/* return uptime, 0 if error */
unsigned long uptime(char *service) {
  int len;
  buf[0]='u';
  len=addreadwrite(service);
  if (len<0) return 0;
  buf[len]=0;
  return atoi(buf);
}

void dumphistory() {
  char tmp[16384];
  int i,j;
  char first,last;
  first=1; last='x';
  write(infd,"h",1);
  for (;;) {
    int prev,done;
    j=read(outfd,tmp,sizeof(tmp));
    if (j<1) break;
    done=i=0;
    if (first) {
      if (tmp[0]=='0') {
	carp("minit compiled without history support.");
	return;
      }
      i+=2;
    } else {
      if (!tmp[0] && last=='\n') break;
    }
    prev=i;
    for (; i<j; ++i)
      if (!tmp[i]) {
	tmp[i]=done?0:'\n';
	if (i<j && !tmp[i+1]) { done=1; --j; }
      }
    if (first)
      write(1,tmp+2,j-2);
    else
      write(1,tmp,j);
    if (done) break;
    last=tmp[j-1];
    first=0;
  }
}

void dumpdependencies(char* service) {
  char tmp[16384];
  int i,j;
  char first,last;
  buf[0]='d';
  addservice(service);
  write(infd,buf,str_len(buf));
  first=1; last='x';
  for (;;) {
    int prev,done;
    j=read(outfd,tmp,sizeof(tmp));
    if (j<1) break;
    done=i=0;
    if (first) {
      if (tmp[0]=='0') {
	carp(service,": no such service.");
	return;
      }
      i+=2;
    } else {
      if (!tmp[0] && last=='\n') break;
    }
    prev=i;
    for (; i<j; ++i)
      if (!tmp[i]) {
	tmp[i]=done?0:'\n';
	if (i<j && !tmp[i+1]) { done=1; --j; }
      }
    if (first)
      write(1,tmp+2,j-2);
    else
      write(1,tmp,j);
    if (done) break;
    last=tmp[j-1];
    first=0;
  }
}

int main(int argc,char *argv[]) {
  if (argc<2) {
    msg(
	"usage: msvc -[uodpchaitkogC] service\n"
	"       msvc -Ppid service\n"
	" -u\tup; start service with respawn\n"
	" -o\tonce; start service without respawn\n"
	" -d\tdown; disable respawn, stop service\n"
	" -p\tpause; send SIGSTOP\n"
	" -c\tcontinue; send SIGCONT\n"
	" -h\thangup; send SIGHUP\n"
	" -a\talarm; send SIGALRM\n"
	" -i\tintr; send SIGINT\n"
	" -t\tterminate; send SIGTERM\n"
	" -k\tkill; send SIGKILL\n"
	" -g\tget; output just the PID\n"
	" -Ppid\tset PID of service (for pidfilehack)\n"
	" -D service\tprint services started as dependency\n"
	" -H\tprint last n respawned services\n"
	" -C\tClear; remove service form active list\n");
    return 0;
  }
  errmsg_iam("msvc");
  infd=open(MINITFIFOS "/in",O_WRONLY);
  outfd=open(MINITFIFOS "/out",O_RDONLY);
  if (infd>=0) {
    while (lockf(infd,F_LOCK,1)) {
      carp("could not acquire lock!");
      sleep(1);
    }
    if (argc==2 && argv[1][1]!='H') {
      pid_t pid=__readpid(argv[1]);
      if (buf[0]!='0') {
	unsigned long len;
	unsigned long ut=uptime(argv[1]);

	if (isatty(1)) {
	  char tmp[FMT_ULONG+20];
	  char tmp2[FMT_ULONG];
	  char* what;

	  if (pid==0) what="down "; else
	  if (pid==1) what="finished "; else {
	    len=fmt_str(tmp,"up (pid ");
	    len+=fmt_ulong(tmp+len,pid);
	    tmp[len+fmt_str(tmp+len,") ")]=0;
	    what=tmp;
	  }
	  tmp2[fmt_ulong(tmp2,ut)]=0;
	  msg(argv[1],": ",what,tmp2," seconds");
	} else {
	  char tmp[FMT_ULONG*2+5];
	  len=fmt_ulong(tmp,pid);
	  tmp[len]=' '; ++len;
	  len+=fmt_ulong(tmp+len,ut);
	  tmp[len]='\n';
	  write(1,tmp,len+1);
	}

	if (pid==0) return 2; else if (pid==1) return 3; else return 0;
      } else
	carp(argv[1],": no such service.");
      return 1;
    } else {
      int i;
      int ret=0;
      int sig=0;
      pid_t pid;
      if (argv[1][0]=='-') {
	switch (argv[1][1]) {
	case 'g':
	  for (i=2; i<argc; ++i) {
	    pid=__readpid(argv[i]);
	    if (pid<2) {
	      carp(argv[i],pid==1?": service terminated":": no such service");
	      ret=1;
	    } else {
	      char tmp[FMT_ULONG];
	      int i;
	      tmp[i=fmt_ulong(tmp,pid)]='\n';
	      write(1,tmp,i+1);
	    }
	  }
	  break;
	case 'p': sig=SIGSTOP; goto dokill; break;
	case 'c': sig=SIGCONT; goto dokill; break;
	case 'h': sig=SIGHUP; goto dokill; break;
	case 'a': sig=SIGALRM; goto dokill; break;
	case 'i': sig=SIGINT; goto dokill; break;
	case 't': sig=SIGTERM; goto dokill; break;
	case 'k': sig=SIGKILL; goto dokill; break;
	case 'o':
	  for (i=2; i<argc; ++i)
	    if (startservice(argv[i]) || respawn(argv[i],0)) {
	      carp("Could not start ",argv[i]);
	      ret=1;
	    }
	  break;
	case 'd':
	  for (i=2; i<argc; ++i) {
	    pid=__readpid(argv[i]);
	    if (pid==0) {
	      carp(argv[i],": no such service");
	      ret=1;
	    } else if (pid<=1) {
	      ret=1;
	    } else
	      respawn(argv[i],0) || kill(pid,SIGTERM) || kill(pid,SIGCONT);
	  }
	  break;
	case 'u':
	  for (i=2; i<argc; ++i)
	    if (startservice(argv[i]) || respawn(argv[i],1)) {
	      carp("Could not start ",argv[i]);
	      ret=1;
	    }
	  break;
	case 'C':
	  for (i=2; i<argc; ++i)
	    if (check_remove(argv[i])) {
	      carp(argv[i]," could not be cleared");
	      ret=1;
	    }
	  break;
	case 'P':
	  pid=atoi(argv[1]+2);
	  if (pid>1)
	    if (setpid(argv[2],pid)) {
	      carp("Could not set PID of service ",argv[2]);
	      ret=1;
	    }
	  break;
	case 'H':
	  dumphistory();
	  break;
	case 'D':
	  dumpdependencies(argv[2]);
	  break;
	}
      }
      return ret;
dokill:
      for (i=2; i<argc; i++) {
	pid=__readpid(argv[i]);
	if (!pid) {
	  carp(argv[i],": no such service");
	  ret=1;
	} else if (pid==1) {
	  carp(argv[i],": service not running");
	  ret=1;
	} else if (kill(pid,sig)) {
	  char tmp[FMT_ULONG];
	  char tmp2[FMT_ULONG];
	  char* s;
	  switch (errno) {
	    case EINVAL: s="invalid signal"; break;
	    case EPERM: s="permission denied"; break;
	    case ESRCH: s="no such pid"; break;
	    default: s="unknown error";
	  }
	  tmp[fmt_ulong(tmp,sig)]=0;
	  tmp2[fmt_ulong(tmp2,pid)]=0;
	  carp(argv[i],": could not send signal ",tmp," to PID ",tmp2,": ",s);
	  ret=1;
	}
      }
      return ret;
    }
  } else {
    carp("minit: could not open " MINITFIFOS "/in or " MINITFIFOS "/out");
    return 1;
  }
}