/********************************************************
 * File: stats.c
 * Created at Sun Jan 28 22:10:33 MSK 2001 by raorn // raorn@binec.ru
 * Statistics
 * $Id: stats.c,v 1.4 2001/02/11 01:56:52 raorn Exp $
 *******************************************************/
#include "crashecho.h"

#define STATS_IDENTIFIER      "CST3"

struct DiskAreaStats {
  uchar Tagname[80];
  struct Node4D Aka;

  uchar Group;
  uchar fill_to_make_even;      /* Just ignore this one */

  ulong TotalTexts;
  ushort Last8Days[8];
  ulong Dupes;

  time_t FirstTime;
  time_t LastTime;
};

struct DiskNodeStats {
  struct Node4D Node;
  ulong GotNetmails;
  ulong GotNetmailBytes;
  ulong SentNetmails;
  ulong SentNetmailBytes;
  ulong GotEchomails;
  ulong GotEchomailBytes;
  ulong SentEchomails;
  ulong SentEchomailBytes;
  ulong Dupes;
  time_t FirstTime;
};

bool WriteStats(uchar * file)
{
  struct Area *area;
  struct ConfigNode *cnode;
  struct DiskAreaStats dastat;
  struct DiskNodeStats dnstat;
  FILE *fh;
  ulong areas, nodes;

  if (!(fh = fopen(file, "wb"))) {
    LogWrite(1, SYSTEMERR, "Unable to open %s for writing", file);
    LogWrite(1, SYSTEMERR, "Error: %s", strerror(errno));
    return (FALSE);
  }

  areas = 0;
  nodes = 0;

  for (area = (struct Area *) config.AreaList.First; area; area = area->Next)
    if (area->AreaType == AREATYPE_BAD || area->AreaType == AREATYPE_ECHOMAIL || area->AreaType == AREATYPE_NETMAIL) {
      if (!(area->Flags & AREA_UNCONFIRMED))
        areas++;
    }

  for (cnode = (struct ConfigNode *) config.CNodeList.First; cnode; cnode = cnode->Next)
    nodes++;

  if (DayStatsWritten == 0)
    DayStatsWritten = time(NULL) / (24 * 60 * 60);

  fwrite(STATS_IDENTIFIER, 4, 1, fh);
  fwrite(&DayStatsWritten, sizeof(ulong), 1, fh);
  fwrite(&areas, sizeof(ulong), 1, fh);

  for (area = (struct Area *) config.AreaList.First; area; area = area->Next) {
    if (area->AreaType == AREATYPE_BAD || area->AreaType == AREATYPE_ECHOMAIL || area->AreaType == AREATYPE_NETMAIL) {
      if (!(area->Flags & AREA_UNCONFIRMED)) {
        strcpy(dastat.Tagname, area->Tagname);
        dastat.TotalTexts = area->Texts;
        dastat.Dupes = area->Dupes;
        dastat.LastTime = area->LastTime;
        dastat.FirstTime = area->FirstTime;
        memcpy(&dastat.Last8Days[0], &area->Last8Days[0], sizeof(ushort) * 8);
        Copy4D(&dastat.Aka, &area->Aka->Node);
        dastat.Group = area->Group;

        fwrite(&dastat, sizeof(struct DiskAreaStats), 1, fh);
      }
    }
  }

  fwrite(&nodes, sizeof(ulong), 1, fh);

  for (cnode = (struct ConfigNode *) config.CNodeList.First; cnode; cnode = cnode->Next) {
    Copy4D(&dnstat.Node, &cnode->Node);
    dnstat.GotEchomails = cnode->GotEchomails;
    dnstat.GotEchomailBytes = cnode->GotEchomailBytes;
    dnstat.SentEchomails = cnode->SentEchomails;
    dnstat.SentEchomailBytes = cnode->SentEchomailBytes;
    dnstat.GotNetmails = cnode->GotNetmails;
    dnstat.GotNetmailBytes = cnode->GotNetmailBytes;
    dnstat.SentNetmails = cnode->SentNetmails;
    dnstat.SentNetmailBytes = cnode->SentNetmailBytes;
    dnstat.Dupes = cnode->Dupes;
    dnstat.FirstTime = cnode->FirstTime;

    fwrite(&dnstat, sizeof(struct DiskNodeStats), 1, fh);
  }

  fclose(fh);

  return (TRUE);
}

bool ReadStats(uchar * file)
{
  struct Area *area;
  struct ConfigNode *cnode;
  struct DiskAreaStats dastat;
  struct DiskNodeStats dnstat;
  ulong c, num;
  FILE *fh;
  uchar buf[5];

  if (!(fh = fopen(file, "rb")))
    return (TRUE);              /* No reason for exiting */

  fread(buf, 4, 1, fh);
  buf[4] = 0;

  if (strcmp(buf, STATS_IDENTIFIER) != 0) {
    LogWrite(1, SYSTEMERR, "Unknown format of stats file %s, exiting...", file);
    fclose(fh);
    return (FALSE);
  }

  fread(&DayStatsWritten, sizeof(ulong), 1, fh);

  fread(&num, sizeof(ulong), 1, fh);
  c = 0;

  while (c < num && fread(&dastat, 1, sizeof(struct DiskAreaStats), fh) == sizeof(struct DiskAreaStats)) {
    for (area = (struct Area *) config.AreaList.First; area; area = area->Next)
      if (stricmp(area->Tagname, dastat.Tagname) == 0)
        break;

    if (area) {
      area->Texts = dastat.TotalTexts;
      area->Dupes = dastat.Dupes;
      area->FirstTime = dastat.FirstTime;
      area->LastTime = dastat.LastTime;
      memcpy(&area->Last8Days[0], &dastat.Last8Days[0], sizeof(ushort) * 8);
    }

    c++;
  }

  fread(&num, sizeof(ulong), 1, fh);
  c = 0;

  while (c < num && fread(&dnstat, 1, sizeof(struct DiskNodeStats), fh) == sizeof(struct DiskNodeStats)) {
    for (cnode = (struct ConfigNode *) config.CNodeList.First; cnode; cnode = cnode->Next)
      if (Compare4D(&dnstat.Node, &cnode->Node) == 0)
        break;

    if (cnode) {
      cnode->GotEchomails = dnstat.GotEchomails;
      cnode->GotEchomailBytes = dnstat.GotEchomailBytes;
      cnode->SentEchomails = dnstat.SentEchomails;
      cnode->SentEchomailBytes = dnstat.SentEchomailBytes;
      cnode->GotNetmails = dnstat.GotNetmails;
      cnode->GotNetmailBytes = dnstat.GotNetmailBytes;
      cnode->SentNetmails = dnstat.SentNetmails;
      cnode->SentNetmailBytes = dnstat.SentNetmailBytes;
      cnode->Dupes = dnstat.Dupes;

      cnode->FirstTime = dnstat.FirstTime;
    }

    c++;
  }

  fclose(fh);

  return (TRUE);
}