mirror of
https://github.com/anope/anope.git
synced 2026-06-28 12:26:36 +02:00
BUILD : 1.7.8 (608) BUGS : NOTES : Added db-merger and epona db converter. docs will follow.
git-svn-id: svn://svn.anope.org/anope/trunk@608 31f1291d-b8d6-0310-a050-a5561fc1590b git-svn-id: http://anope.svn.sourceforge.net/svnroot/anope/trunk@456 5417fbe8-f217-4b02-8779-1006273d7864
This commit is contained in:
parent
2278e8c77b
commit
3e27304655
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,774 @@
|
||||
/*
|
||||
* IRC - Internet Relay Chat, epona2anope.c
|
||||
* (C) Copyright 2005, Florian Schulze (Certus)
|
||||
*
|
||||
* Based on the original code of Anope, (C) 2005 Anope Team
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License (see it online
|
||||
* at http://www.gnu.org/copyleft/gpl.html) as published by the Free
|
||||
* Software Foundation;
|
||||
*
|
||||
* This program 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.
|
||||
*
|
||||
* This program tries to convert epona-1.4.15+ dbs to anope standard dbs.
|
||||
* At the moment this only affects chanserv dbs.
|
||||
*
|
||||
* - Certus
|
||||
* February 26, 2005
|
||||
*/
|
||||
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <stdio.h>
|
||||
#include <unistd.h>
|
||||
#include <fcntl.h>
|
||||
#include <ctype.h>
|
||||
#include <time.h>
|
||||
|
||||
/* CONFIGURATION BLOCK */
|
||||
|
||||
#define CHAN_DB_EPONA "chan1.db"
|
||||
#define CHAN_DB_ANOPE "chan.db"
|
||||
|
||||
/* END OF CONFIGURATION BLOCK */
|
||||
|
||||
#define C_LBLUE "\033[1;34m"
|
||||
#define C_NONE "\033[m"
|
||||
|
||||
#define getc_db(f) (fgetc((f)->fp))
|
||||
#define HASH(nick) ((tolower((nick)[0])&31)<<5 | (tolower((nick)[1])&31))
|
||||
#define HASH2(chan) ((chan)[1] ? ((chan)[1]&31)<<5 | ((chan)[2]&31) : 0)
|
||||
#define read_buffer(buf,f) (read_db((f),(buf),sizeof(buf)) == sizeof(buf))
|
||||
#define write_buffer(buf,f) (write_db((f),(buf),sizeof(buf)) == sizeof(buf))
|
||||
#define read_db(f,buf,len) (fread((buf),1,(len),(f)->fp))
|
||||
#define write_db(f,buf,len) (fwrite((buf),1,(len),(f)->fp))
|
||||
#define read_int8(ret,f) ((*(ret)=fgetc((f)->fp))==EOF ? -1 : 0)
|
||||
#define write_int8(val,f) (fputc((val),(f)->fp)==EOF ? -1 : 0)
|
||||
#define SAFE(x) do { \
|
||||
if ((x) < 0) { \
|
||||
printf("Error, the database is broken, trying to continue... no guarantee.\n"); \
|
||||
} \
|
||||
} while (0)
|
||||
#define READ(x) do { \
|
||||
if ((x) < 0) { \
|
||||
printf("Error, the database is broken, trying to continue... no guarantee.\n"); \
|
||||
exit(0); \
|
||||
} \
|
||||
} while (0)
|
||||
|
||||
typedef int16_t int16;
|
||||
typedef u_int16_t uint16;
|
||||
typedef int32_t int32;
|
||||
typedef u_int32_t uint32;
|
||||
typedef struct memo_ Memo;
|
||||
typedef struct dbFILE_ dbFILE;
|
||||
typedef struct nickalias_ NickAlias;
|
||||
typedef struct nickcore_ NickCore;
|
||||
typedef struct chaninfo_ ChannelInfo;
|
||||
typedef struct botinfo_ BotInfo;
|
||||
typedef struct badword_ BadWord;
|
||||
typedef struct hostcore_ HostCore;
|
||||
|
||||
struct memo_ {
|
||||
uint32 number; /* Index number -- not necessarily array position! */
|
||||
int16 flags; /* Flags */
|
||||
time_t time; /* When was it sent? */
|
||||
char sender[32]; /* Name of the sender */
|
||||
char *text;
|
||||
};
|
||||
|
||||
struct dbFILE_ {
|
||||
int mode; /* 'r' for reading, 'w' for writing */
|
||||
FILE *fp; /* The normal file descriptor */
|
||||
char filename[1024]; /* Name of the database file */
|
||||
};
|
||||
|
||||
typedef struct {
|
||||
int16 memocount; /* Current # of memos */
|
||||
int16 memomax; /* Max # of memos one can hold*/
|
||||
Memo *memos; /* Pointer to original memos */
|
||||
} MemoInfo;
|
||||
|
||||
typedef struct {
|
||||
int16 in_use; /* 1 if this entry is in use, else 0 */
|
||||
int16 level;
|
||||
NickCore *nc; /* Guaranteed to be non-NULL if in use, NULL if not */
|
||||
time_t last_seen;
|
||||
} ChanAccess;
|
||||
|
||||
typedef struct {
|
||||
int16 in_use; /* Always 0 if not in use */
|
||||
int16 is_nick; /* 1 if a regged nickname, 0 if a nick!user@host mask */
|
||||
int16 flags;
|
||||
union {
|
||||
char *mask; /* Guaranteed to be non-NULL if in use, NULL if not */
|
||||
NickCore *nc; /* Same */
|
||||
} u;
|
||||
char *reason;
|
||||
char *creator;
|
||||
time_t addtime;
|
||||
} AutoKick;
|
||||
|
||||
struct nickcore_ {
|
||||
NickCore *next, *prev;
|
||||
|
||||
char *display; /* How the nick is displayed */
|
||||
int unused; /* Used for nick collisions */
|
||||
};
|
||||
|
||||
struct chaninfo_ {
|
||||
ChannelInfo *next, *prev;
|
||||
|
||||
char name[64]; /* Channel name */
|
||||
char *founder; /* Who registered the channel */
|
||||
char *successor; /* Who gets the channel if the founder nick is dropped or expires */
|
||||
char founderpass[32]; /* Channel password */
|
||||
char *desc; /* Description */
|
||||
char *url; /* URL */
|
||||
char *email; /* Email address */
|
||||
time_t time_registered; /* When was it registered */
|
||||
time_t last_used; /* When was it used hte last time */
|
||||
char *last_topic; /* Last topic on the channel */
|
||||
char last_topic_setter[32]; /* Who set the last topic */
|
||||
time_t last_topic_time; /* When the last topic was set */
|
||||
uint32 flags; /* Flags */
|
||||
char *forbidby; /* if forbidden: who did it */
|
||||
char *forbidreason; /* if forbidden: why */
|
||||
int16 bantype; /* Bantype */
|
||||
int16 *levels; /* Access levels for commands */
|
||||
int16 accesscount; /* # of pple with access */
|
||||
ChanAccess *access; /* List of authorized users */
|
||||
int16 akickcount; /* # of akicked pple */
|
||||
AutoKick *akick; /* List of users to kickban */
|
||||
uint32 mlock_on, mlock_off; /* See channel modes below */
|
||||
uint32 mlock_limit; /* 0 if no limit */
|
||||
char *mlock_key; /* NULL if no key */
|
||||
char *mlock_flood; /* NULL if no +f */
|
||||
char *mlock_joinrate; /* NULL if no +j */
|
||||
char *mlock_redirect; /* NULL if no +L */
|
||||
char *entry_message; /* Notice sent on entering channel */
|
||||
MemoInfo memos; /* Memos */
|
||||
char *bi; /* Bot used on this channel */
|
||||
uint32 botflags; /* BS_* below */
|
||||
int16 *ttb; /* Times to ban for each kicker */
|
||||
int16 bwcount; /* Badword count */
|
||||
BadWord *badwords; /* For BADWORDS kicker */
|
||||
int16 capsmin, capspercent; /* For CAPS kicker */
|
||||
int16 floodlines, floodsecs; /* For FLOOD kicker */
|
||||
int16 repeattimes; /* For REPEAT kicker */
|
||||
};
|
||||
|
||||
struct botinfo_ {
|
||||
BotInfo *next, *prev;
|
||||
char *nick; /* Nickname of the bot */
|
||||
char *user; /* Its user name */
|
||||
char *host; /* Its hostname */
|
||||
char *real; /* Its real name */
|
||||
int16 flags; /* Bot flags */
|
||||
time_t created; /* Birth date */
|
||||
int16 chancount; /* Number of channels that use the bot. */
|
||||
};
|
||||
|
||||
struct badword_ {
|
||||
int16 in_use;
|
||||
char *word;
|
||||
int16 type;
|
||||
};
|
||||
|
||||
dbFILE *open_db_write(const char *service, const char *filename, int version);
|
||||
dbFILE *open_db_read(const char *service, const char *filename, int version);
|
||||
NickCore *findcore(const char *nick, int version);
|
||||
ChannelInfo *cs_findchan(const char *chan);
|
||||
char *strscpy(char *d, const char *s, size_t len);
|
||||
int write_file_version(dbFILE * f, uint32 version);
|
||||
int mystricmp(const char *s1, const char *s2);
|
||||
int write_string(const char *s, dbFILE * f);
|
||||
int write_ptr(const void *ptr, dbFILE * f);
|
||||
int read_int16(uint16 * ret, dbFILE * f);
|
||||
int read_int32(uint32 * ret, dbFILE * f);
|
||||
int read_string(char **ret, dbFILE * f);
|
||||
int write_int16(uint16 val, dbFILE * f);
|
||||
int write_int32(uint32 val, dbFILE * f);
|
||||
int read_ptr(void **ret, dbFILE * f);
|
||||
void alpha_insert_chan(ChannelInfo * ci);
|
||||
void close_db(dbFILE * f);
|
||||
|
||||
ChannelInfo *chanlists[256];
|
||||
NickCore *nclists[1024];
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
dbFILE *f;
|
||||
int i;
|
||||
NickCore *nc, *ncnext;
|
||||
long countr = 0, countw = 0;
|
||||
|
||||
printf("\n"C_LBLUE"Epona to Anope DB converter by Certus"C_NONE"\n\n");
|
||||
|
||||
/* Section I: Reading */
|
||||
if ((f = open_db_read("ChanServ", CHAN_DB_EPONA, 17))) {
|
||||
ChannelInfo *ci, **last, *prev;
|
||||
int c;
|
||||
|
||||
printf("Trying to convert channel database...\n");
|
||||
|
||||
for (i = 0; i < 256; i++) {
|
||||
int16 tmp16;
|
||||
int32 tmp32;
|
||||
int n_levels;
|
||||
char *s;
|
||||
int n_ttb;
|
||||
int J;
|
||||
|
||||
last = &chanlists[i];
|
||||
prev = NULL;
|
||||
|
||||
while ((c = getc_db(f)) == 1) {
|
||||
int j;
|
||||
|
||||
if (c != 1) {
|
||||
printf("Invalid format in %s.\n", CHAN_DB_EPONA);
|
||||
exit(0);
|
||||
}
|
||||
|
||||
ci = calloc(sizeof(ChannelInfo), 1);
|
||||
*last = ci;
|
||||
last = &ci->next;
|
||||
ci->prev = prev;
|
||||
prev = ci;
|
||||
READ(read_buffer(ci->name, f));
|
||||
READ(read_string(&ci->founder, f));
|
||||
READ(read_string(&ci->successor, f));
|
||||
READ(read_buffer(ci->founderpass, f));
|
||||
READ(read_string(&ci->desc, f));
|
||||
if (!ci->desc)
|
||||
ci->desc = strdup("");
|
||||
READ(read_string(&ci->url, f));
|
||||
READ(read_string(&ci->email, f));
|
||||
READ(read_int32(&tmp32, f));
|
||||
ci->time_registered = tmp32;
|
||||
READ(read_int32(&tmp32, f));
|
||||
ci->last_used = tmp32;
|
||||
READ(read_string(&ci->last_topic, f));
|
||||
READ(read_buffer(ci->last_topic_setter, f));
|
||||
READ(read_int32(&tmp32, f));
|
||||
ci->last_topic_time = tmp32;
|
||||
READ(read_int32(&ci->flags, f));
|
||||
/* Temporary flags cleanup */
|
||||
ci->flags &= ~0x80000000;
|
||||
READ(read_string(&ci->forbidby, f));
|
||||
READ(read_string(&ci->forbidreason, f));
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->bantype = tmp16;
|
||||
READ(read_int16(&tmp16, f));
|
||||
n_levels = tmp16;
|
||||
ci->levels = calloc(36 * sizeof(*ci->levels), 1);
|
||||
for (j = 0; j < n_levels; j++) {
|
||||
if (j < 36)
|
||||
READ(read_int16(&ci->levels[j], f));
|
||||
else
|
||||
READ(read_int16(&tmp16, f));
|
||||
}
|
||||
READ(read_int16(&ci->accesscount, f));
|
||||
if (ci->accesscount) {
|
||||
ci->access = calloc(ci->accesscount, sizeof(ChanAccess));
|
||||
for (j = 0; j < ci->accesscount; j++) {
|
||||
READ(read_int16(&ci->access[j].in_use, f));
|
||||
if (ci->access[j].in_use) {
|
||||
READ(read_int16(&ci->access[j].level, f));
|
||||
READ(read_string(&s, f));
|
||||
if (s) {
|
||||
ci->access[j].nc = findcore(s, 0);
|
||||
free(s);
|
||||
}
|
||||
if (ci->access[j].nc == NULL)
|
||||
ci->access[j].in_use = 0;
|
||||
READ(read_int32(&tmp32, f));
|
||||
ci->access[j].last_seen = tmp32;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
ci->access = NULL;
|
||||
}
|
||||
READ(read_int16(&ci->akickcount, f));
|
||||
if (ci->akickcount) {
|
||||
ci->akick = calloc(ci->akickcount, sizeof(AutoKick));
|
||||
for (j = 0; j < ci->akickcount; j++) {
|
||||
SAFE(read_int16(&ci->akick[j].flags, f));
|
||||
if (ci->akick[j].flags & 0x0001) {
|
||||
SAFE(read_string(&s, f));
|
||||
if (ci->akick[j].flags & 0x0002) {
|
||||
ci->akick[j].u.nc = findcore(s, 0);
|
||||
if (!ci->akick[j].u.nc)
|
||||
ci->akick[j].flags &= ~0x0001;
|
||||
free(s);
|
||||
} else {
|
||||
ci->akick[j].u.mask = s;
|
||||
}
|
||||
SAFE(read_string(&s, f));
|
||||
if (ci->akick[j].flags & 0x0001)
|
||||
ci->akick[j].reason = s;
|
||||
else if (s)
|
||||
free(s);
|
||||
SAFE(read_string(&s, f));
|
||||
if (ci->akick[j].flags & 0x0001) {
|
||||
ci->akick[j].creator = s;
|
||||
} else if (s) {
|
||||
free(s);
|
||||
}
|
||||
SAFE(read_int32(&tmp32, f));
|
||||
if (ci->akick[j].flags & 0x0001)
|
||||
ci->akick[j].addtime = tmp32;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
ci->akick = NULL;
|
||||
}
|
||||
READ(read_int32(&ci->mlock_on, f));
|
||||
READ(read_int32(&ci->mlock_off, f));
|
||||
READ(read_int32(&ci->mlock_limit, f));
|
||||
READ(read_string(&ci->mlock_key, f));
|
||||
READ(read_string(&ci->mlock_flood, f));
|
||||
READ(read_string(&ci->mlock_joinrate, f));
|
||||
READ(read_string(&ci->mlock_redirect, f));
|
||||
READ(read_int16(&ci->memos.memocount, f));
|
||||
READ(read_int16(&ci->memos.memomax, f));
|
||||
if (ci->memos.memocount) {
|
||||
Memo *memos;
|
||||
memos = calloc(sizeof(Memo) * ci->memos.memocount, 1);
|
||||
ci->memos.memos = memos;
|
||||
for (j = 0; j < ci->memos.memocount; j++, memos++) {
|
||||
READ(read_int32(&memos->number, f));
|
||||
READ(read_int16(&memos->flags, f));
|
||||
READ(read_int32(&tmp32, f));
|
||||
memos->time = tmp32;
|
||||
READ(read_buffer(memos->sender, f));
|
||||
READ(read_string(&memos->text, f));
|
||||
}
|
||||
}
|
||||
READ(read_string(&ci->entry_message, f));
|
||||
|
||||
/* BotServ options */
|
||||
READ(read_string(&ci->bi, f));
|
||||
READ(read_int32(&tmp32, f));
|
||||
ci->botflags = tmp32;
|
||||
READ(read_int16(&tmp16, f));
|
||||
n_ttb = tmp16;
|
||||
ci->ttb = calloc(2 * 8, 1);
|
||||
for (j = 0; j < n_ttb; j++) {
|
||||
if (j < 8)
|
||||
READ(read_int16(&ci->ttb[j], f));
|
||||
else
|
||||
READ(read_int16(&tmp16, f));
|
||||
}
|
||||
for (j = n_ttb; j < 8; j++)
|
||||
ci->ttb[j] = 0;
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->capsmin = tmp16;
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->capspercent = tmp16;
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->floodlines = tmp16;
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->floodsecs = tmp16;
|
||||
READ(read_int16(&tmp16, f));
|
||||
ci->repeattimes = tmp16;
|
||||
|
||||
READ(read_int16(&ci->bwcount, f));
|
||||
if (ci->bwcount) {
|
||||
ci->badwords = calloc(ci->bwcount, sizeof(BadWord));
|
||||
for (j = 0; j < ci->bwcount; j++) {
|
||||
SAFE(read_int16(&ci->badwords[j].in_use, f));
|
||||
if (ci->badwords[j].in_use) {
|
||||
SAFE(read_string(&ci->badwords[j].word, f));
|
||||
SAFE(read_int16(&ci->badwords[j].type, f));
|
||||
}
|
||||
}
|
||||
} else {
|
||||
ci->badwords = NULL;
|
||||
}
|
||||
countr++;
|
||||
} /* getc_db() */
|
||||
*last = NULL;
|
||||
} /* for() loop */
|
||||
close_db(f);
|
||||
}
|
||||
|
||||
/* II: Saving */
|
||||
{
|
||||
if ((f = open_db_write("ChanServ", CHAN_DB_ANOPE, 16))) {
|
||||
ChannelInfo *ci;
|
||||
Memo *memos;
|
||||
static time_t lastwarn = 0;
|
||||
|
||||
for (i = 0; i < 256; i++) {
|
||||
int16 tmp16;
|
||||
for (ci = chanlists[i]; ci; ci = ci->next) {
|
||||
int j;
|
||||
SAFE(write_int8(1, f));
|
||||
SAFE(write_buffer(ci->name, f));
|
||||
if (ci->founder)
|
||||
SAFE(write_string(ci->founder, f));
|
||||
else
|
||||
SAFE(write_string(NULL, f));
|
||||
if (ci->successor)
|
||||
SAFE(write_string(ci->successor, f));
|
||||
else
|
||||
SAFE(write_string(NULL, f));
|
||||
SAFE(write_buffer(ci->founderpass, f));
|
||||
SAFE(write_string(ci->desc, f));
|
||||
SAFE(write_string(ci->url, f));
|
||||
SAFE(write_string(ci->email, f));
|
||||
SAFE(write_int32(ci->time_registered, f));
|
||||
SAFE(write_int32(ci->last_used, f));
|
||||
SAFE(write_string(ci->last_topic, f));
|
||||
SAFE(write_buffer(ci->last_topic_setter, f));
|
||||
SAFE(write_int32(ci->last_topic_time, f));
|
||||
SAFE(write_int32(ci->flags, f));
|
||||
SAFE(write_string(ci->forbidby, f));
|
||||
SAFE(write_string(ci->forbidreason, f));
|
||||
SAFE(write_int16(ci->bantype, f));
|
||||
tmp16 = 36;
|
||||
SAFE(write_int16(tmp16, f));
|
||||
for (j = 0; j < 36; j++)
|
||||
SAFE(write_int16(ci->levels[j], f));
|
||||
|
||||
SAFE(write_int16(ci->accesscount, f));
|
||||
for (j = 0; j < ci->accesscount; j++) {
|
||||
SAFE(write_int16(ci->access[j].in_use, f));
|
||||
if (ci->access[j].in_use) {
|
||||
SAFE(write_int16(ci->access[j].level, f));
|
||||
SAFE(write_string(ci->access[j].nc->display, f));
|
||||
SAFE(write_int32(ci->access[j].last_seen, f));
|
||||
}
|
||||
}
|
||||
SAFE(write_int16(ci->akickcount, f));
|
||||
for (j = 0; j < ci->akickcount; j++) {
|
||||
SAFE(write_int16(ci->akick[j].flags, f));
|
||||
if (ci->akick[j].flags & 0x0001) {
|
||||
if (ci->akick[j].flags & 0x0002)
|
||||
SAFE(write_string(ci->akick[j].u.nc->display, f));
|
||||
else
|
||||
SAFE(write_string(ci->akick[j].u.mask, f));
|
||||
SAFE(write_string(ci->akick[j].reason, f));
|
||||
SAFE(write_string(ci->akick[j].creator, f));
|
||||
SAFE(write_int32(ci->akick[j].addtime, f));
|
||||
}
|
||||
}
|
||||
|
||||
SAFE(write_int32(ci->mlock_on, f));
|
||||
SAFE(write_int32(ci->mlock_off, f));
|
||||
SAFE(write_int32(ci->mlock_limit, f));
|
||||
SAFE(write_string(ci->mlock_key, f));
|
||||
SAFE(write_string(ci->mlock_flood, f));
|
||||
SAFE(write_string(ci->mlock_redirect, f));
|
||||
SAFE(write_int16(ci->memos.memocount, f));
|
||||
SAFE(write_int16(ci->memos.memomax, f));
|
||||
memos = ci->memos.memos;
|
||||
for (j = 0; j < ci->memos.memocount; j++, memos++) {
|
||||
SAFE(write_int32(memos->number, f));
|
||||
SAFE(write_int16(memos->flags, f));
|
||||
SAFE(write_int32(memos->time, f));
|
||||
SAFE(write_buffer(memos->sender, f));
|
||||
SAFE(write_string(memos->text, f));
|
||||
}
|
||||
SAFE(write_string(ci->entry_message, f));
|
||||
if (ci->bi)
|
||||
SAFE(write_string(ci->bi, f));
|
||||
else
|
||||
SAFE(write_string(NULL, f));
|
||||
SAFE(write_int32(ci->botflags, f));
|
||||
tmp16 = 8;
|
||||
SAFE(write_int16(tmp16, f));
|
||||
for (j = 0; j < 8; j++)
|
||||
SAFE(write_int16(ci->ttb[j], f));
|
||||
SAFE(write_int16(ci->capsmin, f));
|
||||
SAFE(write_int16(ci->capspercent, f));
|
||||
SAFE(write_int16(ci->floodlines, f));
|
||||
SAFE(write_int16(ci->floodsecs, f));
|
||||
SAFE(write_int16(ci->repeattimes, f));
|
||||
|
||||
SAFE(write_int16(ci->bwcount, f));
|
||||
for (j = 0; j < ci->bwcount; j++) {
|
||||
SAFE(write_int16(ci->badwords[j].in_use, f));
|
||||
if (ci->badwords[j].in_use) {
|
||||
SAFE(write_string(ci->badwords[j].word, f));
|
||||
SAFE(write_int16(ci->badwords[j].type, f));
|
||||
}
|
||||
}
|
||||
countw++;
|
||||
} /* for (chanlists[i]) */
|
||||
SAFE(write_int8(0, f));
|
||||
} /* for (i) */
|
||||
close_db(f);
|
||||
printf("%ld channels read, %ld channels written. New database saved as %s.\n", countr, countw, CHAN_DB_ANOPE);
|
||||
}
|
||||
}
|
||||
|
||||
printf("\n\nConverting is now done.\n");
|
||||
return 0;
|
||||
} /* End of main() */
|
||||
|
||||
/* Open a database file for reading and check for the version */
|
||||
dbFILE *open_db_read(const char *service, const char *filename, int version)
|
||||
{
|
||||
dbFILE *f;
|
||||
FILE *fp;
|
||||
int myversion;
|
||||
|
||||
f = calloc(sizeof(*f), 1);
|
||||
if (!f) {
|
||||
printf("Can't allocate memory for %s database %s.\n", service, filename);
|
||||
exit(0);
|
||||
}
|
||||
strscpy(f->filename, filename, sizeof(f->filename));
|
||||
f->mode = 'r';
|
||||
fp = fopen(f->filename, "rb");
|
||||
if (!fp) {
|
||||
printf("Can't read %s database %s.\n", service, f->filename);
|
||||
free(f);
|
||||
return NULL;
|
||||
}
|
||||
f->fp = fp;
|
||||
myversion = fgetc(fp) << 24 | fgetc(fp) << 16 | fgetc(fp) << 8 | fgetc(fp);
|
||||
if (feof(fp)) {
|
||||
printf("Error reading version number on %s: End of file detected.\n", f->filename);
|
||||
exit(0);
|
||||
} else if (myversion < version) {
|
||||
printf("Unsuported database version (%d) on %s.\n", myversion, f->filename);
|
||||
exit(0);
|
||||
}
|
||||
return f;
|
||||
}
|
||||
|
||||
/* Open a database file for reading and check for the version */
|
||||
dbFILE *open_db_write(const char *service, const char *filename, int version)
|
||||
{
|
||||
dbFILE *f;
|
||||
int fd;
|
||||
|
||||
f = calloc(sizeof(*f), 1);
|
||||
if (!f) {
|
||||
printf("Can't allocate memory for %s database %s.\n", service, filename);
|
||||
exit(0);
|
||||
}
|
||||
strscpy(f->filename, filename, sizeof(f->filename));
|
||||
filename = f->filename;
|
||||
f->mode = 'w';
|
||||
/* Use open() to avoid people sneaking a new file in under us */
|
||||
fd = open(filename, O_WRONLY | O_CREAT | O_EXCL, 0666);
|
||||
f->fp = fdopen(fd, "wb"); /* will fail and return NULL if fd < 0 */
|
||||
if (!f->fp || !write_file_version(f, version)) {
|
||||
printf("Can't write to %s database %s.\n", service, filename);
|
||||
if (f->fp) {
|
||||
fclose(f->fp);
|
||||
unlink(filename);
|
||||
}
|
||||
free(f);
|
||||
return NULL;
|
||||
}
|
||||
return f;
|
||||
}
|
||||
|
||||
/* Close it */
|
||||
void close_db(dbFILE * f)
|
||||
{
|
||||
fclose(f->fp);
|
||||
free(f);
|
||||
}
|
||||
|
||||
int read_int16(uint16 * ret, dbFILE * f)
|
||||
{
|
||||
int c1, c2;
|
||||
|
||||
c1 = fgetc(f->fp);
|
||||
c2 = fgetc(f->fp);
|
||||
if (c1 == EOF || c2 == EOF)
|
||||
return -1;
|
||||
*ret = c1 << 8 | c2;
|
||||
return 0;
|
||||
}
|
||||
|
||||
int write_int16(uint16 val, dbFILE * f)
|
||||
{
|
||||
if (fputc((val >> 8) & 0xFF, f->fp) == EOF
|
||||
|| fputc(val & 0xFF, f->fp) == EOF)
|
||||
return -1;
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
int read_int32(uint32 * ret, dbFILE * f)
|
||||
{
|
||||
int c1, c2, c3, c4;
|
||||
|
||||
c1 = fgetc(f->fp);
|
||||
c2 = fgetc(f->fp);
|
||||
c3 = fgetc(f->fp);
|
||||
c4 = fgetc(f->fp);
|
||||
if (c1 == EOF || c2 == EOF || c3 == EOF || c4 == EOF)
|
||||
return -1;
|
||||
*ret = c1 << 24 | c2 << 16 | c3 << 8 | c4;
|
||||
return 0;
|
||||
}
|
||||
|
||||
int write_int32(uint32 val, dbFILE * f)
|
||||
{
|
||||
if (fputc((val >> 24) & 0xFF, f->fp) == EOF)
|
||||
return -1;
|
||||
if (fputc((val >> 16) & 0xFF, f->fp) == EOF)
|
||||
return -1;
|
||||
if (fputc((val >> 8) & 0xFF, f->fp) == EOF)
|
||||
return -1;
|
||||
if (fputc((val) & 0xFF, f->fp) == EOF)
|
||||
return -1;
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
int read_ptr(void **ret, dbFILE * f)
|
||||
{
|
||||
int c;
|
||||
|
||||
c = fgetc(f->fp);
|
||||
if (c == EOF)
|
||||
return -1;
|
||||
*ret = (c ? (void *) 1 : (void *) 0);
|
||||
return 0;
|
||||
}
|
||||
|
||||
int write_ptr(const void *ptr, dbFILE * f)
|
||||
{
|
||||
if (fputc(ptr ? 1 : 0, f->fp) == EOF)
|
||||
return -1;
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
int read_string(char **ret, dbFILE * f)
|
||||
{
|
||||
char *s;
|
||||
uint16 len;
|
||||
|
||||
if (read_int16(&len, f) < 0)
|
||||
return -1;
|
||||
if (len == 0) {
|
||||
*ret = NULL;
|
||||
return 0;
|
||||
}
|
||||
s = calloc(len, 1);
|
||||
if (len != fread(s, 1, len, f->fp)) {
|
||||
free(s);
|
||||
return -1;
|
||||
}
|
||||
*ret = s;
|
||||
return 0;
|
||||
}
|
||||
|
||||
int write_string(const char *s, dbFILE * f)
|
||||
{
|
||||
uint32 len;
|
||||
|
||||
if (!s)
|
||||
return write_int16(0, f);
|
||||
len = strlen(s);
|
||||
if (len > 65534)
|
||||
len = 65534;
|
||||
if (write_int16((uint16) (len + 1), f) < 0)
|
||||
return -1;
|
||||
if (len > 0 && fwrite(s, 1, len, f->fp) != len)
|
||||
return -1;
|
||||
if (fputc(0, f->fp) == EOF)
|
||||
return -1;
|
||||
return 0;
|
||||
}
|
||||
|
||||
NickCore *findcore(const char *nick, int unused)
|
||||
{
|
||||
NickCore *nc;
|
||||
|
||||
for (nc = nclists[HASH(nick)]; nc; nc = nc->next) {
|
||||
if (!mystricmp(nc->display, nick))
|
||||
if ((nc->unused && unused) || (!nc->unused && !unused))
|
||||
return nc;
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
int write_file_version(dbFILE * f, uint32 version)
|
||||
{
|
||||
FILE *fp = f->fp;
|
||||
if (fputc(version >> 24 & 0xFF, fp) < 0 ||
|
||||
fputc(version >> 16 & 0xFF, fp) < 0 ||
|
||||
fputc(version >> 8 & 0xFF, fp) < 0 ||
|
||||
fputc(version & 0xFF, fp) < 0) {
|
||||
printf("Error writing version number on %s.\n", f->filename);
|
||||
exit(0);
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
|
||||
/* strscpy: Copy at most len-1 characters from a string to a buffer, and
|
||||
* add a null terminator after the last character copied.
|
||||
*/
|
||||
|
||||
char *strscpy(char *d, const char *s, size_t len)
|
||||
{
|
||||
char *d_orig = d;
|
||||
|
||||
if (!len)
|
||||
return d;
|
||||
while (--len && (*d++ = *s++));
|
||||
*d = '\0';
|
||||
return d_orig;
|
||||
}
|
||||
|
||||
int mystricmp(const char *s1, const char *s2)
|
||||
{
|
||||
register int c;
|
||||
|
||||
while ((c = tolower(*s1)) == tolower(*s2)) {
|
||||
if (c == 0)
|
||||
return 0;
|
||||
s1++;
|
||||
s2++;
|
||||
}
|
||||
if (c < tolower(*s2))
|
||||
return -1;
|
||||
return 1;
|
||||
}
|
||||
|
||||
ChannelInfo *cs_findchan(const char *chan)
|
||||
{
|
||||
ChannelInfo *ci;
|
||||
for (ci = chanlists[tolower(chan[1])]; ci; ci = ci->next) {
|
||||
if (!mystricmp(ci->name, chan))
|
||||
return ci;
|
||||
}
|
||||
return NULL;
|
||||
}
|
||||
|
||||
void alpha_insert_chan(ChannelInfo * ci)
|
||||
{
|
||||
ChannelInfo *ptr, *prev;
|
||||
char *chan = ci->name;
|
||||
|
||||
for (prev = NULL, ptr = chanlists[tolower(chan[1])];
|
||||
ptr != NULL && mystricmp(ptr->name, chan) < 0;
|
||||
prev = ptr, ptr = ptr->next);
|
||||
ci->prev = prev;
|
||||
ci->next = ptr;
|
||||
if (!prev)
|
||||
chanlists[tolower(chan[1])] = ci;
|
||||
else
|
||||
prev->next = ci;
|
||||
if (ptr)
|
||||
ptr->prev = ci;
|
||||
}
|
||||
|
||||
+5
-1
@@ -8,10 +8,14 @@
|
||||
VERSION_MAJOR="1"
|
||||
VERSION_MINOR="7"
|
||||
VERSION_PATCH="8"
|
||||
VERSION_BUILD="607"
|
||||
VERSION_BUILD="608"
|
||||
|
||||
# $Log$
|
||||
#
|
||||
# BUILD : 1.7.8 (608)
|
||||
# BUGS :
|
||||
# NOTES : Added db-merger and epona db converter. docs will follow.
|
||||
#
|
||||
# BUILD : 1.7.8 (607)
|
||||
# BUGS : N/A
|
||||
# NOTES : Clean up after proxy was removed, some Win32 touch ups
|
||||
|
||||
Reference in New Issue
Block a user