1097 lines
25 KiB
C
1097 lines
25 KiB
C
/*****************************************************************************
|
|
*
|
|
* $Id$
|
|
* Purpose: File Database Maintenance
|
|
*
|
|
*****************************************************************************
|
|
* Copyright (C) 1997-2001
|
|
*
|
|
* Michiel Broek FIDO: 2:280/2802
|
|
* Beekmansbos 10
|
|
* 1971 BV IJmuiden
|
|
* the Netherlands
|
|
*
|
|
* This file is part of MBSE BBS.
|
|
*
|
|
* This BBS 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, or (at your option) any
|
|
* later version.
|
|
*
|
|
* MBSE BBS 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 MBSE BBS; see the file COPYING. If not, write to the Free
|
|
* Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
*****************************************************************************/
|
|
|
|
#include "../lib/libs.h"
|
|
#include "../lib/structs.h"
|
|
#include "../lib/records.h"
|
|
#include "../lib/common.h"
|
|
#include "../lib/clcomm.h"
|
|
#include "../lib/dbcfg.h"
|
|
#include "mbfile.h"
|
|
|
|
|
|
|
|
extern int do_quiet; /* Supress screen output */
|
|
int do_pack = FALSE; /* Pack filebase */
|
|
int do_check = FALSE; /* Check filebase */
|
|
int do_kill = FALSE; /* Kill/move old files */
|
|
int do_index = FALSE; /* Create request index */
|
|
int do_list = FALSE; /* List fileareas */
|
|
extern int e_pid; /* Pid of external process */
|
|
extern int show_log; /* Show logging */
|
|
time_t t_start; /* Start time */
|
|
time_t t_end; /* End time */
|
|
int marker = 0; /* Marker counter */
|
|
|
|
|
|
typedef struct _Index {
|
|
struct _Index *next;
|
|
struct FILEIndex idx;
|
|
} Findex;
|
|
|
|
|
|
void ProgName(void)
|
|
{
|
|
if (do_quiet)
|
|
return;
|
|
|
|
colour(15, 0);
|
|
printf("\nMBFILE: MBSE BBS %s File maintenance utility\n", VERSION);
|
|
colour(14, 0);
|
|
printf(" %s\n", COPYRIGHT);
|
|
}
|
|
|
|
|
|
|
|
void die(int onsig)
|
|
{
|
|
/*
|
|
* First check if a child is running, if so, kill it.
|
|
*/
|
|
if (e_pid) {
|
|
if ((kill(e_pid, SIGTERM)) == 0)
|
|
Syslog('+', "SIGTERM to pid %d succeeded", e_pid);
|
|
else {
|
|
if ((kill(e_pid, SIGKILL)) == 0)
|
|
Syslog('+', "SIGKILL to pid %d succeded", e_pid);
|
|
else
|
|
WriteError("$Failed to kill pid %d", e_pid);
|
|
}
|
|
|
|
/*
|
|
* In case the child had the tty in raw mode...
|
|
*/
|
|
if (!do_quiet)
|
|
system("stty sane");
|
|
}
|
|
|
|
signal(onsig, SIG_IGN);
|
|
|
|
if (onsig) {
|
|
if (onsig <= NSIG)
|
|
WriteError("$Terminated on signal %d (%s)", onsig, SigName[onsig]);
|
|
else
|
|
WriteError("Terminated with error %d", onsig);
|
|
}
|
|
|
|
time(&t_end);
|
|
Syslog(' ', "MBFILE finished in %s", t_elapsed(t_start, t_end));
|
|
|
|
if (!do_quiet) {
|
|
colour(7, 0);
|
|
printf("\n");
|
|
}
|
|
ExitClient(onsig);
|
|
}
|
|
|
|
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
int i;
|
|
char *cmd;
|
|
struct passwd *pw;
|
|
|
|
#ifdef MEMWATCH
|
|
mwInit();
|
|
#endif
|
|
InitConfig();
|
|
TermInit(1);
|
|
time(&t_start);
|
|
umask(002);
|
|
|
|
/*
|
|
* Catch all signals we can, and ignore the rest.
|
|
*/
|
|
for (i = 0; i < NSIG; i++) {
|
|
if ((i == SIGHUP) || (i == SIGBUS) || (i == SIGKILL) ||
|
|
(i == SIGILL) || (i == SIGSEGV) || (i == SIGTERM))
|
|
signal(i, (void (*))die);
|
|
else
|
|
signal(i, SIG_IGN);
|
|
}
|
|
|
|
if(argc < 2)
|
|
Help();
|
|
|
|
cmd = xstrcpy((char *)"Command line: mbfile");
|
|
|
|
for (i = 1; i < argc; i++) {
|
|
|
|
cmd = xstrcat(cmd, (char *)" ");
|
|
cmd = xstrcat(cmd, tl(argv[i]));
|
|
|
|
if (!strncmp(argv[i], "in", 2))
|
|
do_index = TRUE;
|
|
if (!strncmp(argv[i], "l", 1))
|
|
do_list = TRUE;
|
|
if (!strncmp(argv[i], "p", 1))
|
|
do_pack = TRUE;
|
|
if (!strncmp(argv[i], "c", 1))
|
|
do_check = TRUE;
|
|
if (!strncmp(argv[i], "k", 1))
|
|
do_kill = TRUE;
|
|
if (!strncmp(argv[i], "-q", 2))
|
|
do_quiet = TRUE;
|
|
}
|
|
|
|
if (!(do_pack || do_check || do_kill || do_index || do_list))
|
|
Help();
|
|
|
|
ProgName();
|
|
pw = getpwuid(getuid());
|
|
InitClient(pw->pw_name, (char *)"mbfile", CFG.location, CFG.logfile, CFG.util_loglevel, CFG.error_log);
|
|
|
|
Syslog(' ', " ");
|
|
Syslog(' ', "MBFILE v%s", VERSION);
|
|
Syslog(' ', cmd);
|
|
free(cmd);
|
|
|
|
if (!do_quiet)
|
|
printf("\n");
|
|
|
|
if (!diskfree(CFG.freespace))
|
|
die(101);
|
|
|
|
if (do_kill)
|
|
Kill();
|
|
|
|
if (do_check)
|
|
Check();
|
|
|
|
if (do_pack)
|
|
PackFileBase();
|
|
|
|
if (do_index)
|
|
Index();
|
|
|
|
if (do_list)
|
|
ListFileAreas();
|
|
|
|
die(0);
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
void Help(void)
|
|
{
|
|
do_quiet = FALSE;
|
|
ProgName();
|
|
|
|
colour(11, 0);
|
|
printf("\nUsage: mbfile [command] <options>\n\n");
|
|
colour(9, 0);
|
|
printf(" Commands are:\n\n");
|
|
colour(3, 0);
|
|
// printf(" a adopt <area> <file> [desc] Adopt file to area\n");
|
|
printf(" c check Check filebase\n");
|
|
// printf(" d delete <area> <file> Mark file in area for deletion\n");
|
|
// printf(" im import <area> Import files in current dir to area\n");
|
|
printf(" in index Create filerequest index\n");
|
|
printf(" k kill Kill/move old files\n");
|
|
printf(" l list List file areas\n");
|
|
// printf(" m move <from> <to> <file> Move file from to area\n");
|
|
printf(" p pack Pack filebase\n");
|
|
// printf(" r rearc <area> [file] [arc] Rearc file(s) in area\n");
|
|
colour(9, 0);
|
|
printf("\n Options are:\n\n");
|
|
colour(3, 0);
|
|
printf(" -q -quiet Quiet mode\n");
|
|
colour(7, 0);
|
|
printf("\n");
|
|
die(0);
|
|
}
|
|
|
|
|
|
|
|
void Marker(void)
|
|
{
|
|
/*
|
|
* Keep the connection with the server alive
|
|
*/
|
|
Nopper();
|
|
|
|
/*
|
|
* Release system resources when running in the background
|
|
*/
|
|
if (CFG.slow_util && do_quiet)
|
|
usleep(1);
|
|
|
|
if (do_quiet)
|
|
return;
|
|
|
|
switch (marker) {
|
|
case 0: printf(">---");
|
|
break;
|
|
|
|
case 1: printf(">>--");
|
|
break;
|
|
|
|
case 2: printf(">>>-");
|
|
break;
|
|
|
|
case 3: printf(">>>>");
|
|
break;
|
|
|
|
case 4: printf("<>>>");
|
|
break;
|
|
|
|
case 5: printf("<<>>");
|
|
break;
|
|
|
|
case 6: printf("<<<>");
|
|
break;
|
|
|
|
case 7: printf("<<<<");
|
|
break;
|
|
|
|
case 8: printf("-<<<");
|
|
break;
|
|
|
|
case 9: printf("--<<");
|
|
break;
|
|
|
|
case 10:printf("---<");
|
|
break;
|
|
|
|
case 11:printf("----");
|
|
break;
|
|
}
|
|
printf("\b\b\b\b");
|
|
fflush(stdout);
|
|
|
|
if (marker < 11)
|
|
marker++;
|
|
else
|
|
marker = 0;
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* Check files for age, and not downloaded for x days. If they match
|
|
* one of these criteria (setable in areas setup), the file will be
|
|
* move to some retire area or deleted, depending on the setup.
|
|
* If they are moved, the upload date is reset to the current date,
|
|
* so you can set new removal criteria again.
|
|
*/
|
|
void Kill(void)
|
|
{
|
|
FILE *pAreas, *pFile, *pDest, *pTemp;
|
|
int i, iAreas, iAreasNew = 0;
|
|
int iTotal = 0, iKilled = 0, iMoved = 0;
|
|
char *sAreas, *fAreas, *newdir = NULL, *sTemp;
|
|
time_t Now;
|
|
int rc, Killit, FilesLeft;
|
|
struct fileareas darea;
|
|
char from[PATH_MAX], to[PATH_MAX];
|
|
|
|
sAreas = calloc(PATH_MAX, sizeof(char));
|
|
fAreas = calloc(PATH_MAX, sizeof(char));
|
|
sTemp = calloc(PATH_MAX, sizeof(char));
|
|
|
|
IsDoing("Kill files");
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf("Kill/move files...\n");
|
|
}
|
|
|
|
sprintf(sAreas, "%s/etc/fareas.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pAreas = fopen (sAreas, "r")) == NULL) {
|
|
WriteError("Can't open %s", sAreas);
|
|
die(0);
|
|
}
|
|
|
|
fread(&areahdr, sizeof(areahdr), 1, pAreas);
|
|
fseek(pAreas, 0, SEEK_END);
|
|
iAreas = (ftell(pAreas) - areahdr.hdrsize) / areahdr.recsize;
|
|
Now = time(NULL);
|
|
|
|
for (i = 1; i <= iAreas; i++) {
|
|
|
|
fseek(pAreas, ((i-1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&area, areahdr.recsize, 1, pAreas);
|
|
|
|
if ((area.Available) && (area.DLdays || area.FDdays) && (!area.CDrom)) {
|
|
|
|
if (!diskfree(CFG.freespace))
|
|
die(101);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r%4d => %-44s \b\b\b\b", i, area.Name);
|
|
fflush(stdout);
|
|
}
|
|
|
|
/*
|
|
* Check if download directory exists,
|
|
* if not, create the directory.
|
|
*/
|
|
if (access(area.Path, R_OK) == -1) {
|
|
Syslog('!', "Create dir: %s", area.Path);
|
|
newdir = xstrcpy(area.Path);
|
|
newdir = xstrcat(newdir, (char *)"/");
|
|
mkdirs(newdir);
|
|
free(newdir);
|
|
newdir = NULL;
|
|
}
|
|
|
|
sprintf(fAreas, "%s/fdb/fdb%d.data", getenv("MBSE_ROOT"), i);
|
|
|
|
/*
|
|
* Open the file database, if it doesn't exist,
|
|
* create an empty one.
|
|
*/
|
|
if ((pFile = fopen(fAreas, "r+")) == NULL) {
|
|
Syslog('!', "Creating new %s", fAreas);
|
|
if ((pFile = fopen(fAreas, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fAreas);
|
|
die(0);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Now start checking the files in the filedatabase
|
|
* against the contents of the directory.
|
|
*/
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
iTotal++;
|
|
Marker();
|
|
|
|
Killit = FALSE;
|
|
if (area.DLdays) {
|
|
/*
|
|
* Test last download date or never downloaded and the
|
|
* file is more then n days available for download.
|
|
*/
|
|
if ((file.LastDL) &&
|
|
(((Now - file.LastDL) / 84400) > area.DLdays)) {
|
|
Killit = TRUE;
|
|
}
|
|
if ((!file.LastDL) &&
|
|
(((Now - file.UploadDate) / 84400) > area.DLdays)) {
|
|
Killit = TRUE;
|
|
}
|
|
}
|
|
|
|
if (area.FDdays) {
|
|
/*
|
|
* Check filedate
|
|
*/
|
|
if (((Now - file.UploadDate) / 84400) > area.FDdays) {
|
|
Killit = TRUE;
|
|
}
|
|
}
|
|
|
|
if (Killit) {
|
|
do_pack = TRUE;
|
|
if (area.MoveArea) {
|
|
fseek(pAreas, ((area.MoveArea -1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&darea, areahdr.recsize, 1, pAreas);
|
|
sprintf(from, "%s/%s", area.Path, file.Name);
|
|
sprintf(to, "%s/%s", darea.Path, file.Name);
|
|
if ((rc = file_mv(from, to)) == 0) {
|
|
Syslog('+', "Move %s, area %d => %d", file.Name, i, area.MoveArea);
|
|
sprintf(to, "%s/fdb/fdb%d.data", getenv("MBSE_ROOT"), area.MoveArea);
|
|
if ((pDest = fopen(to, "a+")) != NULL) {
|
|
file.UploadDate = time(NULL);
|
|
file.LastDL = time(NULL);
|
|
fwrite(&file, sizeof(file), 1, pDest);
|
|
fclose(pDest);
|
|
}
|
|
/*
|
|
* Now again if there is a dotted version (thumbnail) of this file.
|
|
*/
|
|
sprintf(from, "%s/.%s", area.Path, file.Name);
|
|
sprintf(to, "%s/.%s", darea.Path, file.Name);
|
|
if (file_exist(from, R_OK) == 0)
|
|
file_mv(from, to);
|
|
file.Deleted = TRUE;
|
|
fseek(pFile, - sizeof(file), SEEK_CUR);
|
|
fwrite(&file, sizeof(file), 1, pFile);
|
|
iMoved++;
|
|
} else {
|
|
WriteError("Move %s failed rc = %d", file.Name, rc);
|
|
}
|
|
} else {
|
|
Syslog('+', "Delete %s, area %d", file.Name, i);
|
|
file.Deleted = TRUE;
|
|
fseek(pFile, - sizeof(file), SEEK_CUR);
|
|
fwrite(&file, sizeof(file), 1, pFile);
|
|
iKilled++;
|
|
sprintf(from, "%s/%s", area.Path, file.Name);
|
|
unlink(from);
|
|
}
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Now we must pack this area database otherwise
|
|
* we run into trouble later on.
|
|
*/
|
|
fseek(pFile, 0, SEEK_SET);
|
|
sprintf(sTemp, "%s/fdb/fdbtmp.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pTemp = fopen(sTemp, "a+")) != NULL) {
|
|
FilesLeft = FALSE;
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
if ((!file.Deleted) && strcmp(file.Name, "") != 0) {
|
|
fwrite(&file, sizeof(file), 1, pTemp);
|
|
FilesLeft = TRUE;
|
|
}
|
|
}
|
|
|
|
fclose(pFile);
|
|
fclose(pTemp);
|
|
if ((rename(sTemp, fAreas)) == 0) {
|
|
unlink(sTemp);
|
|
chmod(fAreas, 006600);
|
|
}
|
|
if (!FilesLeft) {
|
|
Syslog('+', "Warning: area %d (%s) is empty", i, area.Name);
|
|
}
|
|
} else
|
|
fclose(pFile);
|
|
|
|
iAreasNew++;
|
|
|
|
} /* if area.Available */
|
|
}
|
|
|
|
fclose(pAreas);
|
|
|
|
Syslog('+', "Kill Areas [%5d] Files [%5d] Deleted [%5d] Moved [%5d]", iAreasNew, iTotal, iKilled, iMoved);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r \r");
|
|
fflush(stdout);
|
|
}
|
|
|
|
free(sTemp);
|
|
free(sAreas);
|
|
free(fAreas);
|
|
}
|
|
|
|
|
|
|
|
void tidy_index(Findex **);
|
|
void tidy_index(Findex **fap)
|
|
{
|
|
Findex *tmp, *old;
|
|
|
|
for (tmp = *fap; tmp; tmp = old) {
|
|
old = tmp->next;
|
|
free(tmp);
|
|
}
|
|
*fap = NULL;
|
|
}
|
|
|
|
|
|
|
|
void fill_index(struct FILEIndex, Findex **);
|
|
void fill_index(struct FILEIndex idx, Findex **fap)
|
|
{
|
|
Findex *tmp;
|
|
|
|
tmp = (Findex *)malloc(sizeof(Findex));
|
|
tmp->next = *fap;
|
|
tmp->idx = idx;
|
|
*fap = tmp;
|
|
}
|
|
|
|
|
|
int comp_index(Findex **, Findex **);
|
|
|
|
void sort_index(Findex **);
|
|
void sort_index(Findex **fap)
|
|
{
|
|
Findex *ta, **vector;
|
|
size_t n = 0, i;
|
|
|
|
if (*fap == NULL)
|
|
return;
|
|
|
|
for (ta = *fap; ta; ta = ta->next)
|
|
n++;
|
|
|
|
vector = (Findex **)malloc(n * sizeof(Findex *));
|
|
|
|
i = 0;
|
|
for (ta = *fap; ta; ta = ta->next)
|
|
vector[i++] = ta;
|
|
|
|
qsort(vector, n, sizeof(Findex *),
|
|
(int(*)(const void*, const void *))comp_index);
|
|
|
|
(*fap) = vector[0];
|
|
i = 1;
|
|
|
|
for (ta = *fap; ta; ta = ta->next) {
|
|
if (i < n)
|
|
ta->next = vector[i++];
|
|
else
|
|
ta->next = NULL;
|
|
}
|
|
|
|
free(vector);
|
|
return;
|
|
}
|
|
|
|
|
|
|
|
int comp_index(Findex **fap1, Findex **fap2)
|
|
{
|
|
return strcasecmp((*fap1)->idx.LName, (*fap2)->idx.LName);
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* Build a sorted index for the file request processor.
|
|
*/
|
|
void Index(void)
|
|
{
|
|
FILE *pAreas, *pFile, *pIndex;
|
|
long i, iAreas, iAreasNew = 0, record;
|
|
int iTotal = 0;
|
|
char *sAreas, *fAreas, *newdir = NULL, *sIndex;
|
|
Findex *fdx = NULL;
|
|
Findex *tmp;
|
|
struct FILEIndex idx;
|
|
|
|
sAreas = calloc(PATH_MAX, sizeof(char));
|
|
fAreas = calloc(PATH_MAX, sizeof(char));
|
|
sIndex = calloc(PATH_MAX, sizeof(char));
|
|
|
|
IsDoing("Kill files");
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf("Create filerequest index...\n");
|
|
}
|
|
|
|
sprintf(sAreas, "%s/etc/fareas.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pAreas = fopen (sAreas, "r")) == NULL) {
|
|
WriteError("$Can't open %s", sAreas);
|
|
die(0);
|
|
}
|
|
|
|
sprintf(sIndex, "%s/etc/request.index", getenv("MBSE_ROOT"));
|
|
if ((pIndex = fopen(sIndex, "w")) == NULL) {
|
|
WriteError("$Can't create %s", sIndex);
|
|
die(0);
|
|
}
|
|
|
|
fread(&areahdr, sizeof(areahdr), 1, pAreas);
|
|
fseek(pAreas, 0, SEEK_END);
|
|
iAreas = (ftell(pAreas) - areahdr.hdrsize) / areahdr.recsize;
|
|
|
|
for (i = 1; i <= iAreas; i++) {
|
|
|
|
fseek(pAreas, ((i-1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&area, areahdr.recsize, 1, pAreas);
|
|
|
|
if ((area.Available) && (area.FileReq)) {
|
|
|
|
if (!diskfree(CFG.freespace))
|
|
die(101);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r%4ld => %-44s \b\b\b\b", i, area.Name);
|
|
fflush(stdout);
|
|
}
|
|
|
|
/*
|
|
* Check if download directory exists,
|
|
* if not, create the directory.
|
|
*/
|
|
if (access(area.Path, R_OK) == -1) {
|
|
Syslog('!', "Create dir: %s", area.Path);
|
|
newdir = xstrcpy(area.Path);
|
|
newdir = xstrcat(newdir, (char *)"/");
|
|
mkdirs(newdir);
|
|
free(newdir);
|
|
newdir = NULL;
|
|
}
|
|
|
|
sprintf(fAreas, "%s/fdb/fdb%ld.data", getenv("MBSE_ROOT"), i);
|
|
|
|
/*
|
|
* Open the file database, if it doesn't exist,
|
|
* create an empty one.
|
|
*/
|
|
if ((pFile = fopen(fAreas, "r+")) == NULL) {
|
|
Syslog('!', "Creating new %s", fAreas);
|
|
if ((pFile = fopen(fAreas, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fAreas);
|
|
die(0);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Now start creating the unsorted index.
|
|
*/
|
|
record = 0;
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
iTotal++;
|
|
if ((iTotal % 10) == 0)
|
|
Marker();
|
|
memset(&idx, 0, sizeof(idx));
|
|
sprintf(idx.Name, "%s", tu(file.Name));
|
|
sprintf(idx.LName, "%s", tu(file.LName));
|
|
idx.AreaNum = i;
|
|
idx.Record = record;
|
|
fill_index(idx, &fdx);
|
|
record++;
|
|
}
|
|
|
|
fclose(pFile);
|
|
iAreasNew++;
|
|
|
|
} /* if area.Available */
|
|
}
|
|
|
|
fclose(pAreas);
|
|
|
|
sort_index(&fdx);
|
|
for (tmp = fdx; tmp; tmp = tmp->next)
|
|
fwrite(&tmp->idx, sizeof(struct FILEIndex), 1, pIndex);
|
|
fclose(pIndex);
|
|
tidy_index(&fdx);
|
|
|
|
Syslog('+', "Index Areas [%5d] Files [%5d]", iAreasNew, iTotal);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r \r");
|
|
fflush(stdout);
|
|
}
|
|
|
|
free(sIndex);
|
|
free(sAreas);
|
|
free(fAreas);
|
|
RemoveSema((char *)"reqindex");
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* Check file database integrity, all files in the file database must
|
|
* exist in real, the size and date/time must match, the files crc is
|
|
* checked, and if anything is wrong, the file database is updated.
|
|
* If the file is missing the entry is marked as deleted. With the
|
|
* pack option that record will be removed.
|
|
* After these checks, de database is checked for missing records, if
|
|
* there are files on disk but not in the directory these files are
|
|
* deleted. System files (beginning with a dot) are left alone and
|
|
* the files 'files.bbs', 'files.bak', '00index', 'header' 'readme'
|
|
* and 'index.html' too.
|
|
*
|
|
* Remarks: Maybe if the crc check fails, and the date and time are
|
|
* ok, the file is damaged and must be made unavailable.
|
|
*/
|
|
void Check(void)
|
|
{
|
|
FILE *pAreas, *pFile;
|
|
int i, iAreas, iAreasNew = 0;
|
|
int iTotal = 0, iErrors = 0;
|
|
char *sAreas, *fAreas, *newdir;
|
|
DIR *dp;
|
|
struct dirent *de;
|
|
int Found, Update;
|
|
char fn[PATH_MAX];
|
|
struct stat stb;
|
|
|
|
sAreas = calloc(PATH_MAX, sizeof(char));
|
|
fAreas = calloc(PATH_MAX, sizeof(char));
|
|
newdir = calloc(PATH_MAX, sizeof(char));
|
|
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf("Checking file database...\n");
|
|
}
|
|
|
|
sprintf(sAreas, "%s/etc/fareas.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pAreas = fopen (sAreas, "r")) == NULL) {
|
|
WriteError("Can't open %s", sAreas);
|
|
die(0);
|
|
}
|
|
|
|
fread(&areahdr, sizeof(areahdr), 1, pAreas);
|
|
fseek(pAreas, 0, SEEK_END);
|
|
iAreas = (ftell(pAreas) - areahdr.hdrsize) / areahdr.recsize;
|
|
|
|
for (i = 1; i <= iAreas; i++) {
|
|
|
|
fseek(pAreas, ((i-1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&area, areahdr.recsize, 1, pAreas);
|
|
|
|
if (area.Available) {
|
|
|
|
IsDoing("Check area %d", i);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r%4d => %-44s \b\b\b\b", i, area.Name);
|
|
fflush(stdout);
|
|
}
|
|
|
|
/*
|
|
* Check if download directory exists,
|
|
* if not, create the directory.
|
|
*/
|
|
if (access(area.Path, R_OK) == -1) {
|
|
Syslog('!', "No dir: %s", area.Path);
|
|
sprintf(newdir, "%s/foobar", area.Path);
|
|
mkdirs(newdir);
|
|
}
|
|
|
|
sprintf(fAreas, "%s/fdb/fdb%d.data", getenv("MBSE_ROOT"), i);
|
|
|
|
/*
|
|
* Open the file database, if it doesn't exist,
|
|
* create an empty one.
|
|
*/
|
|
if ((pFile = fopen(fAreas, "r+")) == NULL) {
|
|
Syslog('!', "Creating new %s", fAreas);
|
|
if ((pFile = fopen(fAreas, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fAreas);
|
|
die(0);
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Now start checking the files in the filedatabase
|
|
* against the contents of the directory.
|
|
*/
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
|
|
iTotal++;
|
|
sprintf(newdir, "%s/%s", area.Path, file.Name);
|
|
|
|
if (file_exist(newdir, R_OK)) {
|
|
Syslog('+', "File %s area %d not on disk.", newdir, i);
|
|
if (!file.NoKill) {
|
|
file.Deleted = TRUE;
|
|
do_pack = TRUE;
|
|
}
|
|
iErrors++;
|
|
file.Missing = TRUE;
|
|
fseek(pFile, - sizeof(file), SEEK_CUR);
|
|
fwrite(&file, sizeof(file), 1, pFile);
|
|
} else {
|
|
/*
|
|
* File exists, now check the file.
|
|
*/
|
|
Marker();
|
|
Update = FALSE;
|
|
if (file_time(newdir) != file.FileDate) {
|
|
Syslog('!', "Date mismatch area %d file %s", i, file.Name);
|
|
file.FileDate = file_time(newdir);
|
|
iErrors++;
|
|
Update = TRUE;
|
|
}
|
|
if (file_size(newdir) != file.Size) {
|
|
Syslog('!', "Size mismatch area %d file %s", i, file.Name);
|
|
file.Size = file_size(newdir);
|
|
iErrors++;
|
|
Update = TRUE;
|
|
}
|
|
if (file_crc(newdir, CFG.slow_util && do_quiet) != file.Crc32) {
|
|
Syslog('!', "CRC error area %d, file %s", i, file.Name);
|
|
file.Crc32 = file_crc(newdir, CFG.slow_util && do_quiet);
|
|
iErrors++;
|
|
Update = TRUE;
|
|
}
|
|
Marker();
|
|
if (Update) {
|
|
fseek(pFile, - sizeof(file), SEEK_CUR);
|
|
fwrite(&file, sizeof(file), 1, pFile);
|
|
}
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Check files in the directory against the database.
|
|
* This test is skipped for CD-rom.
|
|
*/
|
|
if (!area.CDrom) {
|
|
if ((dp = opendir(area.Path)) != NULL) {
|
|
while ((de = readdir(dp)) != NULL) {
|
|
if (de->d_name[0] != '.') {
|
|
Marker();
|
|
Found = FALSE;
|
|
rewind(pFile);
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
if (strcmp(file.Name, de->d_name) == 0) {
|
|
Found = TRUE;
|
|
break;
|
|
}
|
|
}
|
|
if ((!Found) &&
|
|
(strncmp(de->d_name, "files.bbs", 9)) &&
|
|
(strncmp(de->d_name, "files.bak", 9)) &&
|
|
(strncmp(de->d_name, "00index", 7)) &&
|
|
(strncmp(de->d_name, "header", 6)) &&
|
|
(strncmp(de->d_name, "index", 5)) &&
|
|
(strncmp(de->d_name, "readme", 6))) {
|
|
sprintf(fn, "%s/%s", area.Path, de->d_name);
|
|
if (stat(fn, &stb) == 0)
|
|
if (S_ISREG(stb.st_mode)) {
|
|
if (unlink(fn) == 0) {
|
|
Syslog('!', "%s not in fdb, deleted from disk", fn);
|
|
iErrors++;
|
|
} else {
|
|
WriteError("$%s not in fdb, cannot delete", fn);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
closedir(dp);
|
|
} else {
|
|
WriteError("Can't open %s", area.Path);
|
|
}
|
|
}
|
|
|
|
fclose(pFile);
|
|
iAreasNew++;
|
|
|
|
} /* if area.Available */
|
|
}
|
|
|
|
fclose(pAreas);
|
|
if (!do_quiet) {
|
|
printf("\r \r");
|
|
fflush(stdout);
|
|
}
|
|
|
|
free(newdir);
|
|
free(sAreas);
|
|
free(fAreas);
|
|
|
|
Syslog('+', "Check Areas [%5d] Files [%5d] Errors [%5d]", iAreasNew, iTotal, iErrors);
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
* Removes records who are marked for deletion. If there is still a file
|
|
* on disk, it will be removed too.
|
|
*/
|
|
void PackFileBase(void)
|
|
{
|
|
FILE *fp, *pAreas, *pFile;
|
|
int i, iAreas, iAreasNew = 0;
|
|
int iTotal = 0, iRemoved = 0;
|
|
char *sAreas, *fAreas, *fTmp, fn[PATH_MAX];
|
|
|
|
sAreas = calloc(PATH_MAX, sizeof(char));
|
|
fAreas = calloc(PATH_MAX, sizeof(char));
|
|
fTmp = calloc(PATH_MAX, sizeof(char));
|
|
|
|
IsDoing("Pack filebase");
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf("Packing file database...\n");
|
|
}
|
|
|
|
sprintf(sAreas, "%s/etc/fareas.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pAreas = fopen (sAreas, "r")) == NULL) {
|
|
WriteError("Can't open %s", sAreas);
|
|
die(0);
|
|
}
|
|
|
|
fread(&areahdr, sizeof(areahdr), 1, pAreas);
|
|
fseek(pAreas, 0, SEEK_END);
|
|
iAreas = (ftell(pAreas) - areahdr.hdrsize) / areahdr.recsize;
|
|
|
|
for (i = 1; i <= iAreas; i++) {
|
|
|
|
fseek(pAreas, ((i-1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&area, areahdr.recsize, 1, pAreas);
|
|
|
|
if (area.Available && !area.CDrom) {
|
|
|
|
if (!diskfree(CFG.freespace))
|
|
die(101);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r%4d => %-44s", i, area.Name);
|
|
fflush(stdout);
|
|
}
|
|
Marker();
|
|
|
|
sprintf(fAreas, "%s/fdb/fdb%d.data", getenv("MBSE_ROOT"), i);
|
|
sprintf(fTmp, "%s/fdb/fdbtmp.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pFile = fopen(fAreas, "r")) == NULL) {
|
|
Syslog('!', "Creating new %s", fAreas);
|
|
if ((pFile = fopen(fAreas, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fAreas);
|
|
die(0);
|
|
}
|
|
}
|
|
|
|
if ((fp = fopen(fTmp, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fTmp);
|
|
die(0);
|
|
}
|
|
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
|
|
iTotal++;
|
|
|
|
if ((!file.Deleted) && (strcmp(file.Name, "") != 0)) {
|
|
fwrite(&file, sizeof(file), 1, fp);
|
|
} else {
|
|
iRemoved++;
|
|
Syslog('+', "Removed file \"%s\" from area %d", file.Name, i);
|
|
sprintf(fn, "%s/%s", area.Path, file.Name);
|
|
Syslog('+', "Unlink %s result %d", fn, unlink(fn));
|
|
/*
|
|
* If a dotted version (thumbnail) exists, remove it silently
|
|
*/
|
|
sprintf(fn, "%s/.%s", area.Path, file.Name);
|
|
unlink(fn);
|
|
}
|
|
}
|
|
|
|
fclose(fp);
|
|
fclose(pFile);
|
|
|
|
if ((rename(fTmp, fAreas)) == 0) {
|
|
unlink(fTmp);
|
|
chmod(fAreas, 00660);
|
|
}
|
|
iAreasNew++;
|
|
|
|
} /* if area.Available */
|
|
}
|
|
|
|
fclose(pAreas);
|
|
Syslog('+', "Pack Areas [%5d] Files [%5d] Removed [%5d]", iAreasNew, iTotal, iRemoved);
|
|
|
|
if (!do_quiet) {
|
|
printf("\r \r");
|
|
fflush(stdout);
|
|
}
|
|
|
|
free(fTmp);
|
|
free(sAreas);
|
|
free(fAreas);
|
|
}
|
|
|
|
|
|
void ListFileAreas(void)
|
|
{
|
|
FILE *pAreas, *pFile;
|
|
int i, iAreas, fcount, tcount = 0;
|
|
int iTotal = 0;
|
|
long fsize, tsize = 0;
|
|
char *sAreas, *fAreas;
|
|
|
|
sAreas = calloc(PATH_MAX, sizeof(char));
|
|
fAreas = calloc(PATH_MAX, sizeof(char));
|
|
|
|
IsDoing("List fileareas");
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf(" Area Files MByte File Group Area name\n");
|
|
printf("----- ----- ----- ------------ --------------------------------------------\n");
|
|
colour(7, 0);
|
|
}
|
|
|
|
sprintf(sAreas, "%s/etc/fareas.data", getenv("MBSE_ROOT"));
|
|
|
|
if ((pAreas = fopen (sAreas, "r")) == NULL) {
|
|
WriteError("Can't open %s", sAreas);
|
|
if (!do_quiet)
|
|
printf("Can't open %s\n", sAreas);
|
|
die(0);
|
|
}
|
|
|
|
fread(&areahdr, sizeof(areahdr), 1, pAreas);
|
|
fseek(pAreas, 0, SEEK_END);
|
|
iAreas = (ftell(pAreas) - areahdr.hdrsize) / areahdr.recsize;
|
|
|
|
for (i = 1; i <= iAreas; i++) {
|
|
fseek(pAreas, ((i-1) * areahdr.recsize) + areahdr.hdrsize, SEEK_SET);
|
|
fread(&area, areahdr.recsize, 1, pAreas);
|
|
|
|
if (area.Available) {
|
|
|
|
sprintf(fAreas, "%s/fdb/fdb%d.data", getenv("MBSE_ROOT"), i);
|
|
|
|
/*
|
|
* Open the file database, create new one if it doesn't excist.
|
|
*/
|
|
if ((pFile = fopen(fAreas, "r+")) == NULL) {
|
|
Syslog('!', "Creating new %s", fAreas);
|
|
if ((pFile = fopen(fAreas, "a+")) == NULL) {
|
|
WriteError("$Can't create %s", fAreas);
|
|
die(0);
|
|
}
|
|
}
|
|
|
|
fcount = 0;
|
|
fsize = 0L;
|
|
while (fread(&file, sizeof(file), 1, pFile) == 1) {
|
|
fcount++;
|
|
fsize = fsize + file.Size;
|
|
}
|
|
fsize = fsize / 1048576;
|
|
tcount += fcount;
|
|
tsize += fsize;
|
|
|
|
if (!do_quiet)
|
|
printf("%5d %5d %5ld %-12s %s\n", i, fcount, fsize, area.BbsGroup, area.Name);
|
|
iTotal++;
|
|
}
|
|
}
|
|
|
|
if (!do_quiet) {
|
|
colour(3, 0);
|
|
printf("----- ----- ----- ---------------------------------------------------------\n");
|
|
printf("%5d %5d %5ld \n", iTotal, tcount, tsize);
|
|
}
|
|
|
|
fclose(pAreas);
|
|
if (!do_quiet) {
|
|
printf("\r \r");
|
|
fflush(stdout);
|
|
}
|
|
|
|
free(sAreas);
|
|
free(fAreas);
|
|
}
|
|
|