#include "Watchaccess.h"
#include "string.h"

/* Scripturi shell pentru trimis mail-uri la userii in culpa */

#define SH_MAILV " mail -s \"Proces vechi\" "
#define PROCES_VECHI "<<XXXXXXXX\n Opriti procesul Nr: "
#define COADA_PROCES " deoarece este prea vechi. Multumim.\n\
XXXXXXXX\n"

#define SH_MAILF "mail -s \"Fara angajament\" "
#define COADA_FARA "<<XXXXXXXX\n Rugam completati un angajament\
 UBBNET, altfel vi se blocheaza contul. Multumim.\n\
XXXXXXXX\n"

main (argc, argv)
     int argc;
     char *argv[];
{
  Mesaj *Cerere, *Raspuns, *Initializare;
  struct sockaddr_in Interventie, Supraveghere;

  char s[MAX], *p, User[MAX], Pid[MAX], d[MAX];
  short l;
  int nv, nf, sd, fd, len_addr;
  FILE *f;

/* Initializari */

  if (argc != 3)	/* Verificarea numarului de argumente */
    ERR ("Interventie", 201);
  gethostname (s, MAX);

/* Creaza mesajul de initializare */

  Initializare = Alloc (4*sizeof(short) + strlen(argv[2]) + 1);
  AtribuireI (Initializare, 1, 1);
  AtribuireI (Initializare, 2, 1);
  AtribuireI (Initializare, 3, atoi (argv[1]));
  AtribuireS (Initializare, 0, argv[2]);

/* Creaza mesajul de raspuns */

  Raspuns = Alloc (4 * sizeof (short) + strlen (s) + 1);
  AtribuireI (Raspuns, 1, 1);
  AtribuireI (Raspuns, 2, 1);
  AtribuireI (Raspuns, 3, getuid ());
  AtribuireS (Raspuns, 0, s);

/* Creare adrese socket */

  memset ((char *) &Supraveghere, 0, sizeof (Supraveghere));
  memset ((char *) &Interventie, 0, sizeof (Interventie));
  Interventie.sin_family = AF_INET;
  Interventie.sin_addr.s_addr = htonl (INADDR_ANY);
  Interventie.sin_port = htons (PORT_INTERVENTIE);

/* Initiarea comunicarii prin socket */

  if ((sd = socket (AF_INET, SOCK_STREAM, 0)) < 0)
    ERR ("Interventie", 202);
  if (bind (sd, (struct sockaddr *) &Interventie,
	    sizeof (Interventie)) != 0)
    ERR ("Interventie", 203);
  if (listen (sd, 5) != 0)
    ERR ("Interventie", 204);

  signal(SIGCHLD, SIG_IGN); /* Evitare zombie */

  for (;;) {		/* Bucla principala de asteptare */

    if (fd = accept (sd, (struct sockaddr *) &Supraveghere, 
                                             &len_addr), 0)
      ERR ("Interventie", 205);

    f = popen("date", "r");
    fgets(User, MAX, f);
    fclose(f);
    User[strlen(User)-1] = 0; /* Pregateste data si ora */
    sprintf(d, "I: %s", User);

/* Primeste mesajul cerere de interventie */

    if (Recv (fd, (char *) &l, sizeof (short)) < 0) {
      MES (d, 206);
      continue;
    }
    l = ntohs (l);
    Cerere = Alloc (l);
    if (Recv (fd, (char *)Cerere + sizeof(short), 
                          l - sizeof(short)) < 0) {
      MES (d, 207);
      continue;
    }
    
/* Valideaza continutul cererii primite */

    if (!Valid (Cerere) ||
	(ValoareI (Cerere, 1) != 3) ||
	(ValoareI (Cerere, 2) != 3) ||
        (ValoareI (Cerere, 3) != ValoareI (Initializare, 3)) ||
	(strstr (ValoareS (Initializare, 0),
		 ValoareS (Cerere, 0)) == 0)) {
      MES (d, 208);
      continue;
    }  

/* Scrie informatiile in fisiere locale */

    nv = ValoareI (Cerere, 4);
    nf = ValoareI (Cerere, 5);
    f = fopen ("PROCESE_VECHI", "w");
    fprintf (f, "%s", ValoareS (Cerere, 1));
    fclose (f);
    f = fopen ("FARA_ANGAJAMENT", "w");
    fprintf (f, "%s", ValoareS (Cerere, 2));
    fclose (f);

/* Pregateste si lanseaza mesaje spre cei in culpa */

    p = (char *) Cerere + 6 * sizeof (short) + 
             strlen (ValoareS (Cerere, 0)) + 1;
    for (l = 0; l < nv; l++) {
      strncpy (User, p, (char *) index (p, '\t') - p);
      User[(char *) index (p, '\t') - p] = '\0';
      p += strlen (User) + 1;
      strncpy (Pid, p, (char *) index (p, '\n') - p);
      Pid[(char *) index (p, '\n') - p] = '\0';
      p += strlen (Pid) + 1;

      sprintf (s, "%s %s %s %s %s", SH_MAILV, User, 
                  PROCES_VECHI,  Pid, COADA_PROCES);
      f = popen (s, "r");/* Mesaj spre un user cu proces vechi */
      fclose(f);
    }
    p++;

    for (l = 0; l < nf; l++) {
      strncpy (User, p, (char *) index (p, '\n') - p);
      User[(char *) index (p, '\n') - p] = '\0';
      p += strlen (User) + 1;
      sprintf (s, "%s %s %s", SH_MAILF, User, COADA_FARA);
      f = popen (s, "r");/* Mesaj spre un user fara angajament */
      fclose(f);
    }
    Delete (Cerere);

/* Confirma ca interventiile s-au terminat si inchide */

    if (Send (fd, (char *) Raspuns,
	      ValoareI (Raspuns, 0)) < 0)
      ERR (d, 209);

    close (fd);
  }
}
/* Programul 3.20 Textul sursa al serverului Interventie.c */