18 files changed, 3437 insertions, 0 deletions
diff --git a/miranda-wine/plugins/db3x/Makefile b/miranda-wine/plugins/db3x/Makefile
new file mode 100644
index 0000000..5a75630
--- /dev/null
+++ b/miranda-wine/plugins/db3x/Makefile
@@ -0,0 +1,53 @@
+SRC = commonheaders.c \
+      database.c \
+	  dbcache.c \
+	  dbcontacts.c \
+	  dbevents.c \
+	  dbheaders.c \
+	  dbini.c \
+	  dblists.c \
+	  dbmodulechain.c \
+	  dbsettings.c \
+	  dbtime.c \
+	  encrypt.c \
+	  init.c
+OBJ = $(SRC:.c=.o)
+RES = resource.res
+LIB = -lgdi32 -lversion -lcomctl32 -lcomdlg32 -lole32
+
+CC = gcc
+RC = windres
+RM = rm
+
+# Install location
+ifdef DEBUG
+BIN = ..\..\bin\debug\plugins\dbx_3x.dll
+else
+BIN = ..\..\bin\release\plugins\dbx_3x.dll
+endif
+
+# Defines
+DEFINES = -DWIN32 -D__SEH_NOOP
+ifdef DEBUG
+DEFINES := $(DEFINES) -D_DEBUG
+endif
+
+# Flags
+LFLAGS  = -shared 
+RCFLAGS = --input-format rc --output-format coff
+ifdef DEBUG
+CFLAGS  = -g $(DEFINES) -I../../include
+else
+CFLAGS  = -O1 $(DEFINES) -I../../include
+endif
+
+# Targets
+all : $(OBJ) $(RES)
+	$(CC) $(LFLAGS) $(CFLAGS) -o $(BIN) $(OBJ) $(RES) $(LIB) -Wl
+
+$(RES) : $(RES:.res=.rc) $(RES:.res=.h) Makefile
+	$(RC) $(RCFLAGS) -o $(RES) -i $(RES:.res=.rc)
+
+clean :
+	$(RM) -f $(OBJ) $(RES)
+
diff --git a/miranda-wine/plugins/db3x/commonheaders.c b/miranda-wine/plugins/db3x/commonheaders.c
new file mode 100644
index 0000000..14f99f7
--- /dev/null
+++ b/miranda-wine/plugins/db3x/commonheaders.c
@@ -0,0 +1 @@
+#include "commonheaders.h"
diff --git a/miranda-wine/plugins/db3x/commonheaders.h b/miranda-wine/plugins/db3x/commonheaders.h
new file mode 100644
index 0000000..c0a8146
--- /dev/null
+++ b/miranda-wine/plugins/db3x/commonheaders.h
@@ -0,0 +1,66 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#define _WIN32_WINNT 0x0501
+#include <windows.h>
+
+#include <malloc.h>
+
+#ifdef _DEBUG
+#	define _ALPHA_BASE_ 1	// defined for CVS builds
+#	define _ALPHA_FUSE_ 1	// defined for fuse powered core
+#	define _CRTDBG_MAP_ALLOC
+#	include <stdlib.h>
+#	include <crtdbg.h>
+#endif
+
+#include <commctrl.h>
+#include <stdio.h>
+#include <string.h>
+#include <time.h>
+#include <stddef.h>
+#include <process.h>
+#include <io.h>
+#include <string.h>
+#include <direct.h>
+#include "resource.h"
+#include <newpluginapi.h>
+#include <win2k.h>
+#include <m_system.h>
+#include <m_database.h>
+#include <m_langpack.h>
+
+extern PLUGINLINK *pluginLink;
+
+extern struct MM_INTERFACE memoryManagerInterface;
+extern struct LIST_INTERFACE li;
+
+#define mir_alloc(n) memoryManagerInterface.mmi_malloc(n)
+#define mir_free(ptr) memoryManagerInterface.mmi_free(ptr)
+#define mir_realloc(ptr,size) memoryManagerInterface.mmi_realloc(ptr,size)
+
+#ifdef __GNUC__
+#define mir_i64(x) (x##LL)
+#else
+#define mir_i64(x) (x##i64)
+#endif
diff --git a/miranda-wine/plugins/db3x/database.c b/miranda-wine/plugins/db3x/database.c
new file mode 100644
index 0000000..38843a7
--- /dev/null
+++ b/miranda-wine/plugins/db3x/database.c
@@ -0,0 +1,186 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+#include "commonheaders.h"
+#include "database.h"
+
+int ProfileManager(char *szDbDest,int cbDbDest);
+int ShouldAutoCreate(void);
+int CreateDbHeaders(HANDLE hFile);
+int InitialiseDbHeaders(void);
+int InitSettings(void);
+void UninitSettings(void);
+int InitContacts(void);
+void UninitContacts(void);
+int InitEvents(void);
+void UninitEvents(void);
+int InitCrypt(void);
+int InitTime(void);
+int InitModuleNames(void);
+void UninitModuleNames(void);
+int InitCache(void);
+void UninitCache(void);
+int InitIni(void);
+void UninitIni(void);
+
+HANDLE hDbFile=INVALID_HANDLE_VALUE;
+CRITICAL_SECTION csDbAccess;
+struct DBHeader dbHeader;
+char szDbPath[MAX_PATH];
+
+static void UnloadDatabase(void)
+{
+	CloseHandle(hDbFile);
+}
+
+DWORD CreateNewSpace(int bytes)
+{
+	DWORD ofsNew;
+
+	ofsNew=dbHeader.ofsFileEnd;
+	dbHeader.ofsFileEnd+=bytes;
+	DBWrite(0,&dbHeader,sizeof(dbHeader));
+	log2("newspace %d@%08x",bytes,ofsNew);
+	return ofsNew;
+}
+
+void DeleteSpace(DWORD ofs,int bytes)
+{
+	PBYTE buf;
+	log2("deletespace %d@%08x",bytes,ofs);
+	dbHeader.slackSpace+=bytes;
+	DBWrite(0,&dbHeader,sizeof(dbHeader));
+	buf=(PBYTE)mir_alloc(bytes);
+	memset(buf,0,bytes);
+	DBWrite(ofs,buf,bytes);
+	mir_free(buf);
+}
+
+void UnloadDatabaseModule(void)
+{
+	//UninitIni();
+	UninitEvents();
+	UninitSettings();
+	UninitContacts();
+	UninitModuleNames();
+	UninitCache();
+	UnloadDatabase();
+	DeleteCriticalSection(&csDbAccess);
+}
+
+static int GetProfileName(WPARAM wParam, LPARAM lParam)
+{
+	char * p = 0;
+	p = strrchr(szDbPath, '\\');
+	if ( p == 0 ) return 1;
+	p++;
+	strncpy((char*)lParam, p, (size_t) wParam);
+	return 0;
+}
+
+static int GetProfilePath(WPARAM wParam, LPARAM lParam)
+{
+	char * dst = (char*)lParam;
+	char * p = 0;
+	strncpy(dst,szDbPath,wParam);
+	p = strrchr(dst, '\\');
+	if ( p == NULL ) return 1;
+	*p=0;
+	return 0;
+}
+
+int LoadDatabaseModule(void)
+{
+	InitializeCriticalSection(&csDbAccess);
+	log0("DB logging running");
+	{
+		DWORD dummy=0;
+		hDbFile=CreateFile(szDbPath,GENERIC_READ|GENERIC_WRITE, 0, NULL, OPEN_ALWAYS, 0, NULL);
+		if ( hDbFile == INVALID_HANDLE_VALUE ) {
+			return 1;
+		}
+		if ( !ReadFile(hDbFile,&dbHeader,sizeof(dbHeader),&dummy,NULL) ) {
+			CloseHandle(hDbFile);
+			return 1;
+		}
+	}
+	//if(ParseCommandLine()) return 1;
+	if(InitCache()) return 1;
+	if(InitModuleNames()) return 1;
+	if(InitContacts()) return 1;
+	if(InitSettings()) return 1;
+	if(InitEvents()) return 1;
+	if(InitCrypt()) return 1;
+	//if(InitTime()) return 1;
+	//if(InitIni()) return 1;
+	CreateServiceFunction(MS_DB_GETPROFILENAME,GetProfileName);
+	CreateServiceFunction(MS_DB_GETPROFILEPATH,GetProfilePath);
+	return 0;
+}
+
+static DWORD DatabaseCorrupted=0;
+
+void __cdecl dbpanic(void *arg)
+{
+	
+	MessageBox(0,Translate("Miranda has detected corruption in your database. This corruption maybe fixed by DBTool.  Please download it from http://www.miranda-im.org. Miranda will now shutdown."),Translate("Database Panic"),MB_SETFOREGROUND|MB_TOPMOST|MB_APPLMODAL|MB_ICONWARNING|MB_OK);
+	TerminateProcess(GetCurrentProcess(),255);
+	return;
+}
+
+void DatabaseCorruption(void)
+{
+	int kill=0;
+
+	EnterCriticalSection(&csDbAccess);
+	if (DatabaseCorrupted==0) {
+		DatabaseCorrupted++;
+		kill++;
+	} else {
+		/* db is already corrupted, someone else is dealing with it, wait here
+		so that we don't do any more damage */
+		LeaveCriticalSection(&csDbAccess);
+		Sleep(INFINITE);
+		return;
+	}
+	LeaveCriticalSection(&csDbAccess);
+	if (kill) {
+		_beginthread(dbpanic,0,NULL);
+		Sleep(INFINITE);
+	}
+}
+
+#ifdef DBLOGGING
+void DBLog(const char *file,int line,const char *fmt,...)
+{
+	FILE *fp;
+	va_list vararg;
+	char str[1024];
+
+	va_start(vararg,fmt);
+	mir_vsnprintf(str,sizeof(str),fmt,vararg);
+	va_end(vararg);
+	fp=fopen("c:\\mirandadatabase.log.txt","at");
+	fprintf(fp,"%u: %s %d: %s\n",GetTickCount(),file,line,str);
+	fclose(fp);
+}
+#endif
diff --git a/miranda-wine/plugins/db3x/database.h b/miranda-wine/plugins/db3x/database.h
new file mode 100644
index 0000000..d2a6a8f
--- /dev/null
+++ b/miranda-wine/plugins/db3x/database.h
@@ -0,0 +1,218 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+
+//all offsets are relative to the start of the file
+//offsets are 0 if there is nothing in the chain or this is the last in the
+//chain
+
+/* tree diagram
+
+DBHeader
+ |-->end of file (plain offset)
+ |-->first contact (DBContact)
+ |   |-->next contact (DBContact)
+ |   |   \--> ...
+ |   |-->first settings (DBContactSettings)
+ |   |	 |-->next settings (DBContactSettings)
+ |   |   |   \--> ...
+ |   |   \-->module name (DBModuleName)
+ |   \-->first/last/firstunread event
+ |-->user contact (DBContact)
+ |   |-->next contact=NULL
+ |   |-->first settings	as above
+ |   \-->first/last/firstunread event as above
+ \-->first module name (DBModuleName)
+     \-->next module name (DBModuleName)
+	     \--> ...
+*/
+
+#define DB_RESIZE_GRANULARITY    16384
+#define DB_THIS_VERSION          0x00000700u
+#define DB_SETTINGS_RESIZE_GRANULARITY  128
+
+#include <pshpack1.h>
+struct DBHeader {
+  BYTE signature[16];      // 'Miranda ICQ DB',0,26
+  DWORD version;		   //as 4 bytes, ie 1.2.3.10=0x0102030a
+                           //this version is 0x00000700
+  DWORD ofsFileEnd;		   //offset of the end of the database - place to write
+                           //new structures
+  DWORD slackSpace;		   //a counter of the number of bytes that have been
+                           //wasted so far due to deleting structures and/or
+						   //re-making them at the end. We should compact when
+						   //this gets above a threshold
+  DWORD contactCount;	   //number of contacts in the chain,excluding the user
+  DWORD ofsFirstContact;   //offset to first struct DBContact in the chain
+  DWORD ofsUser;		   //offset to struct DBContact representing the user
+  DWORD ofsFirstModuleName;	//offset to first struct DBModuleName in the chain
+};
+
+#define DBCONTACT_SIGNATURE   0x43DECADEu
+struct DBContact {
+  DWORD signature;
+  DWORD ofsNext;			 //offset to the next contact in the chain. zero if
+                             //this is the 'user' contact or the last contact
+							 //in the chain
+  DWORD ofsFirstSettings;	 //offset to the first DBContactSettings in the
+                             //chain for this contact.
+  DWORD eventCount;			 //number of events in the chain for this contact
+  DWORD ofsFirstEvent,ofsLastEvent;	 //offsets to the first and last DBEvent in
+                                     //the chain for this contact
+  DWORD ofsFirstUnreadEvent; //offset to the first (chronological) unread event
+							 //in the chain, 0 if all are read
+  DWORD timestampFirstUnread; //timestamp of the event at ofsFirstUnreadEvent
+};
+
+#define DBMODULENAME_SIGNATURE  0x4DDECADEu
+struct DBModuleName {
+  DWORD signature;
+  DWORD ofsNext;		//offset to the next module name in the chain
+  BYTE cbName;			//number of characters in this module name
+  char name[1];			//name, no nul terminator
+};
+
+#define DBCONTACTSETTINGS_SIGNATURE  0x53DECADEu
+struct DBContactSettings {
+  DWORD signature;
+  DWORD ofsNext;		 //offset to the next contactsettings in the chain
+  DWORD ofsModuleName;	 //offset to the DBModuleName of the owner of these
+                         //settings
+  DWORD cbBlob;			 //size of the blob in bytes. May be larger than the
+                         //actual size for reducing the number of moves
+						 //required using granularity in resizing
+  BYTE blob[1];			 //the blob. a back-to-back sequence of DBSetting
+                         //structs, the last has cbName=0
+};
+
+/*	not a valid structure, content is figured out on the fly
+struct DBSetting {
+  BYTE cbName;			//number of bytes in the name of this setting
+                        //this =0 marks the end
+  char szName[...];		//setting name, excluding nul
+  BYTE dataType;		//type of data. see m_database.h, db/contact/getsetting
+  union {			   //a load of types of data, length is defined by dataType
+    BYTE bVal; WORD wVal; DWORD dVal;
+	struct {
+	  WORD cbString;
+	  char szVal[...];	  //excludes nul terminator
+	};
+	struct {
+	  WORD cbBlob;
+	  BYTE blobVal[...];
+	};
+  };
+};
+*/
+
+#define DBEVENT_SIGNATURE  0x45DECADEu
+struct DBEvent {
+  DWORD signature;
+  DWORD ofsPrev,ofsNext;	 //offset to the previous and next events in the
+                             //chain. Chain is sorted chronologically
+  DWORD ofsModuleName;		 //offset to a DBModuleName struct of the name of
+                             //the owner of this event
+  DWORD timestamp;			 //seconds since 00:00:00 01/01/1970
+  DWORD flags;				 //see m_database.h, db/event/add
+  WORD eventType;			 //module-defined event type
+  DWORD cbBlob;				 //number of bytes in the blob
+  BYTE blob[1];				 //the blob. module-defined formatting
+};
+#include <poppack.h>
+
+typedef struct
+{
+	BYTE bIsResident;
+	char name[1];
+}
+	DBCachedSettingName;
+
+typedef struct
+{
+	char* name;
+	DBVARIANT value;
+}
+	DBCachedGlobalValue;
+
+typedef struct DBCachedContactValue_tag
+{
+	char* name;
+	DBVARIANT value;
+	struct DBCachedContactValue_tag* next;
+}
+	DBCachedContactValue;
+
+typedef struct
+{
+	HANDLE hContact;
+	HANDLE hNext;
+	DBCachedContactValue* first;
+}
+	DBCachedContactValueList;
+
+
+//databasecorruption: called if any signatures are broken. very very fatal
+void DatabaseCorruption(void);
+PBYTE DBRead(DWORD ofs,int bytesRequired,int *bytesAvail);	//any preview result could be invalidated by the next call
+void DBWrite(DWORD ofs,PVOID pData,int count);
+void DBFlush(int setting);
+void DBMoveChunk(DWORD ofsDest,DWORD ofsSource,int bytes);
+DWORD CreateNewSpace(int bytes);
+void DeleteSpace(DWORD ofs,int bytes);
+void GetProfileDirectory(char *szPath,int cbPath);
+int GetDefaultProfilePath(char *szPath,int cbPath,int *specified);
+int ShouldShowProfileManager(void);
+int CheckDbHeaders(struct DBHeader * hdr);
+int CreateDbHeaders(HANDLE hFile);
+int LoadDatabaseModule(void);
+void UnloadDatabaseModule(void);
+
+void Utf8Decode( char* str, wchar_t** ucs2 );
+char* Utf8Encode( const char* src );
+char* Utf8EncodeUcs2( const wchar_t* src );
+
+#ifdef _DEBUG
+#define MAXCACHEDREADSIZE     512
+#else
+#define MAXCACHEDREADSIZE     2048	 //push it to 1K  //technically 4096 would work, but I'm not going to push it
+#endif
+
+#ifdef _DEBUG
+//#define DBLOGGING
+#endif
+#ifdef DBLOGGING
+void DBLog(const char *file,int line,const char *fmt,...);
+#define logg()  DBLog(__FILE__,__LINE__,"")
+#define log0(s)  DBLog(__FILE__,__LINE__,s)
+#define log1(s,a)  DBLog(__FILE__,__LINE__,s,a)
+#define log2(s,a,b)  DBLog(__FILE__,__LINE__,s,a,b)
+#define log3(s,a,b,c)  DBLog(__FILE__,__LINE__,s,a,b,c)
+#define log4(s,a,b,c,d)  DBLog(__FILE__,__LINE__,s,a,b,c,d)
+#else
+#define logg()
+#define log0(s)
+#define log1(s,a)
+#define log2(s,a,b)
+#define log3(s,a,b,c)
+#define log4(s,a,b,c,d)
+#endif
diff --git a/miranda-wine/plugins/db3x/dbcache.c b/miranda-wine/plugins/db3x/dbcache.c
new file mode 100644
index 0000000..dd3bc5a
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbcache.c
@@ -0,0 +1,229 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+
+#define CACHESECTIONSIZE   4096
+#define CACHESECTIONCOUNT  32
+
+extern HANDLE hDbFile;
+extern CRITICAL_SECTION csDbAccess;
+
+static BOOL safetyMode=TRUE;
+static PBYTE pDbCache;
+static DWORD lastUseCounter;
+struct DBCacheSectionInfo {
+	DWORD ofsBase;
+	DWORD lastUsed;
+} static cacheSectionInfo[CACHESECTIONCOUNT];
+
+static __inline int FindSectionForOffset(const DWORD ofs)
+{
+	int i;
+	for(i=0;i<CACHESECTIONCOUNT;i++)
+		if(ofs>=cacheSectionInfo[i].ofsBase && ofs<cacheSectionInfo[i].ofsBase+CACHESECTIONSIZE)
+			return i;
+	return -1;
+}
+
+static __inline int FindLRUSection(void)
+{
+	int i,lru=0;
+	DWORD lowestLastUse=cacheSectionInfo[0].lastUsed;
+	for(i=1;i<CACHESECTIONCOUNT;i++) if(cacheSectionInfo[i].lastUsed<lowestLastUse) {lru=i; lowestLastUse=cacheSectionInfo[i].lastUsed;}
+	return lru;
+}
+
+static __inline void LoadSection(const int i,DWORD ofs)
+{
+	cacheSectionInfo[i].ofsBase=ofs-ofs%CACHESECTIONSIZE;
+	log1("readsect %08x",ofs);
+	SetFilePointer(hDbFile,cacheSectionInfo[i].ofsBase,NULL,FILE_BEGIN);
+	ReadFile(hDbFile,pDbCache+i*CACHESECTIONSIZE,CACHESECTIONSIZE,&ofs,NULL);
+}
+
+static __inline void MoveSection(int *sectId,int dest)
+{
+	CopyMemory(pDbCache+dest*CACHESECTIONSIZE,pDbCache+(*sectId)*CACHESECTIONSIZE,CACHESECTIONSIZE);
+	cacheSectionInfo[dest].ofsBase=cacheSectionInfo[*sectId].ofsBase;
+	*sectId=dest;
+}
+
+
+
+//we are assumed to be in a mutex here
+PBYTE DBRead(DWORD ofs,int bytesRequired,int *bytesAvail)
+{
+
+	int part1sect;
+	int part2sect;
+
+
+	part1sect = FindSectionForOffset(ofs);
+	if (ofs%CACHESECTIONSIZE+bytesRequired<CACHESECTIONSIZE) {
+		//only one section required
+		if(part1sect==-1) {
+			part1sect=FindLRUSection();
+			LoadSection(part1sect,ofs);
+		}
+		cacheSectionInfo[part1sect].lastUsed=++lastUseCounter;
+		if(bytesAvail!=NULL) *bytesAvail=cacheSectionInfo[part1sect].ofsBase+CACHESECTIONSIZE-ofs;
+		return pDbCache+part1sect*CACHESECTIONSIZE+(ofs-cacheSectionInfo[part1sect].ofsBase);
+	}
+	//two sections are required
+	part2sect=FindSectionForOffset(ofs+CACHESECTIONSIZE);
+	if(part1sect!=-1) {
+		if(part2sect==-1) {  //first part in cache, but not second part
+			if(part1sect==CACHESECTIONCOUNT-1) MoveSection(&part1sect,0);
+			LoadSection(part1sect+1,ofs+CACHESECTIONSIZE);
+		}
+		else if(part2sect!=part1sect+1) {   //both parts are in cache, but not already consecutive
+			if(part1sect==CACHESECTIONCOUNT-1) {
+				//first part is at end, move to before second part
+				if(part2sect==0) //second part is at start: need to move both
+					MoveSection(&part2sect,1);
+				MoveSection(&part1sect,part2sect-1);
+			}
+			else  //move second part to after first part
+				MoveSection(&part2sect,part1sect+1);
+		}
+	}
+	else {
+		if(part2sect==-1) {  //neither section is in cache
+			part1sect=0; part2sect=1;
+			LoadSection(part1sect,ofs); LoadSection(part2sect,ofs+CACHESECTIONSIZE);
+		}
+		else {    //part 2 is in cache, but not part 1
+			if(part2sect==0) MoveSection(&part2sect,1);
+			part1sect=part2sect-1;
+			LoadSection(part1sect,ofs);
+		}
+	}
+	//both sections are now consecutive, starting at part1sect
+	cacheSectionInfo[part1sect].lastUsed=++lastUseCounter;
+	cacheSectionInfo[part1sect+1].lastUsed=++lastUseCounter;
+	if(bytesAvail!=NULL) *bytesAvail=cacheSectionInfo[part1sect+1].ofsBase+CACHESECTIONSIZE-ofs;
+	return pDbCache+part1sect*CACHESECTIONSIZE+(ofs-cacheSectionInfo[part1sect].ofsBase);
+}
+
+
+
+//we are assumed to be in a mutex here
+void DBWrite(DWORD ofs,PVOID pData,int bytes)
+{
+	//write direct, and rely on Windows' write caching
+	DWORD bytesWritten;
+	int i;
+
+	log2("write %d@%08x",bytes,ofs);
+	SetFilePointer(hDbFile,ofs,NULL,FILE_BEGIN);
+	if (WriteFile(hDbFile,pData,bytes,&bytesWritten,NULL)==0)
+	{
+		DatabaseCorruption();
+	}
+	logg();
+	//check if any of the cache sections contain this bit
+	for(i=0;i<CACHESECTIONCOUNT;i++) {
+		if(ofs+bytes>=cacheSectionInfo[i].ofsBase && ofs<cacheSectionInfo[i].ofsBase+CACHESECTIONSIZE) {
+			if(ofs<cacheSectionInfo[i].ofsBase) {  //don't start at beginning
+				if(ofs+bytes>=cacheSectionInfo[i].ofsBase+CACHESECTIONSIZE)   //don't finish at end
+					CopyMemory(pDbCache+i*CACHESECTIONSIZE,(PBYTE)pData+cacheSectionInfo[i].ofsBase-ofs,CACHESECTIONSIZE);
+				else CopyMemory(pDbCache+i*CACHESECTIONSIZE,(PBYTE)pData+cacheSectionInfo[i].ofsBase-ofs,bytes-(cacheSectionInfo[i].ofsBase-ofs));
+			}
+			else {	  //start at beginning
+				if(ofs+bytes>=cacheSectionInfo[i].ofsBase+CACHESECTIONSIZE)   //don't finish at end
+					CopyMemory(pDbCache+i*CACHESECTIONSIZE+ofs-cacheSectionInfo[i].ofsBase,pData,cacheSectionInfo[i].ofsBase+CACHESECTIONSIZE-ofs);
+				else CopyMemory(pDbCache+i*CACHESECTIONSIZE+ofs-cacheSectionInfo[i].ofsBase,pData,bytes);
+			}
+		}
+	}
+}
+
+void DBMoveChunk(DWORD ofsDest,DWORD ofsSource,int bytes)
+{
+	DWORD bytesRead;
+	PBYTE buf;
+
+	log3("move %d %08x->%08x",bytes,ofsSource,ofsDest);
+	buf=(PBYTE)mir_alloc(bytes);
+	SetFilePointer(hDbFile,ofsSource,NULL,FILE_BEGIN);
+	ReadFile(hDbFile,buf,bytes,&bytesRead,NULL);
+	DBWrite(ofsDest,buf,bytes);
+	mir_free(buf);
+	logg();
+}
+
+static int flushBuffersTimerId;
+static VOID CALLBACK DoBufferFlushTimerProc(HWND hwnd,UINT message,UINT idEvent,DWORD dwTime)
+{
+	KillTimer(NULL,flushBuffersTimerId);
+	log0("tflush1");
+	FlushFileBuffers(hDbFile);
+	log0("tflush2");
+}
+
+void DBFlush(int setting)
+{
+	if(!setting) {
+		log0("nflush1");
+		if(safetyMode) FlushFileBuffers(hDbFile);
+		log0("nflush2");
+		return;
+	}
+	KillTimer(NULL,flushBuffersTimerId);
+	flushBuffersTimerId=SetTimer(NULL,flushBuffersTimerId,50,DoBufferFlushTimerProc);
+}
+
+static int CacheSetSafetyMode(WPARAM wParam,LPARAM lParam)
+{
+	EnterCriticalSection(&csDbAccess);
+	safetyMode=wParam;
+	LeaveCriticalSection(&csDbAccess);
+	if(safetyMode) FlushFileBuffers(hDbFile);
+	return 0;
+}
+
+int InitCache(void)
+{
+	int i;
+	DWORD bytesRead;
+	
+	CreateServiceFunction(MS_DB_SETSAFETYMODE,CacheSetSafetyMode);
+	pDbCache=(PBYTE)mir_alloc(CACHESECTIONSIZE*CACHESECTIONCOUNT);
+	lastUseCounter=CACHESECTIONCOUNT;
+	for(i=0;i<CACHESECTIONCOUNT;i++) {
+		cacheSectionInfo[i].ofsBase=0;
+		cacheSectionInfo[i].lastUsed=i;
+		SetFilePointer(hDbFile,cacheSectionInfo[i].ofsBase,NULL,FILE_BEGIN);
+		ReadFile(hDbFile,pDbCache+i*CACHESECTIONSIZE,CACHESECTIONSIZE,&bytesRead,NULL);
+	}
+	return 0;
+}
+
+void UninitCache(void)
+{
+	mir_free(pDbCache);
+	KillTimer(NULL,flushBuffersTimerId);
+}
diff --git a/miranda-wine/plugins/db3x/dbcontacts.c b/miranda-wine/plugins/db3x/dbcontacts.c
new file mode 100644
index 0000000..2a8d038
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbcontacts.c
@@ -0,0 +1,270 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+static int GetContactCount(WPARAM wParam,LPARAM lParam);
+static int FindFirstContact(WPARAM wParam,LPARAM lParam);
+static int FindNextContact(WPARAM wParam,LPARAM lParam);
+static int DeleteContact(WPARAM wParam,LPARAM lParam);
+static int AddContact(WPARAM wParam,LPARAM lParam);
+static int IsDbContact(WPARAM wParam,LPARAM lParam);
+
+extern CRITICAL_SECTION csDbAccess;
+extern struct DBHeader dbHeader;
+static HANDLE hContactDeletedEvent,hContactAddedEvent;
+
+extern HANDLE hCacheHeap;
+extern SortedList lContacts;
+
+int InitContacts(void)
+{
+	CreateServiceFunction(MS_DB_CONTACT_GETCOUNT,GetContactCount);
+	CreateServiceFunction(MS_DB_CONTACT_FINDFIRST,FindFirstContact);
+	CreateServiceFunction(MS_DB_CONTACT_FINDNEXT,FindNextContact);
+	CreateServiceFunction(MS_DB_CONTACT_DELETE,DeleteContact);
+	CreateServiceFunction(MS_DB_CONTACT_ADD,AddContact);
+	CreateServiceFunction(MS_DB_CONTACT_IS,IsDbContact);
+	hContactDeletedEvent=CreateHookableEvent(ME_DB_CONTACT_DELETED);
+	hContactAddedEvent=CreateHookableEvent(ME_DB_CONTACT_ADDED);
+	return 0;
+}
+
+void UninitContacts(void)
+{
+}
+
+static int GetContactCount(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	
+	EnterCriticalSection(&csDbAccess);
+	ret=dbHeader.contactCount;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindFirstContact(WPARAM wParam,LPARAM lParam)
+{
+	int ret = 0;
+	EnterCriticalSection(&csDbAccess);
+	ret = (int)(HANDLE)dbHeader.ofsFirstContact;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindNextContact(WPARAM wParam,LPARAM lParam)
+{
+	int ret, index;
+	struct DBContact *dbc;
+	DBCachedContactValueList *VL = NULL;
+	
+	EnterCriticalSection(&csDbAccess);
+	{
+		DBCachedContactValueList VLtemp;
+		VLtemp.hContact = (HANDLE)wParam;
+		if ( li.List_GetIndex(&lContacts,&VLtemp,&index)) {
+			VL = ( DBCachedContactValueList* )lContacts.items[index];
+			if ( VL->hNext != NULL ) {
+				LeaveCriticalSection(&csDbAccess);
+				return (int)VL->hNext;
+	}	}	}
+
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE)
+		ret=(int)(HANDLE)NULL;
+	else {
+		if ( VL == NULL ) {
+			VL = (DBCachedContactValueList*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedContactValueList));
+			VL->hContact = (HANDLE)wParam;
+			li.List_Insert(&lContacts,VL,index);
+		}
+		VL->hNext = (HANDLE)dbc->ofsNext;
+		ret=(int)(HANDLE)dbc->ofsNext;
+	}
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int DeleteContact(WPARAM wParam,LPARAM lParam)
+{
+	struct DBContact *dbc,*dbcPrev;
+	DWORD ofsThis,ofsNext,ofsFirstEvent;
+	struct DBContactSettings *dbcs;
+	struct DBEvent *dbe;
+	int index;
+	
+	if((HANDLE)wParam==NULL) return 1;
+	EnterCriticalSection(&csDbAccess);
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	if ( (HANDLE)wParam == (HANDLE)dbHeader.ofsUser ) {
+		LeaveCriticalSection(&csDbAccess);
+		log0("FATAL: del of user chain attempted.");
+		return 1;
+	}
+	log0("del contact");
+	LeaveCriticalSection(&csDbAccess);
+	//call notifier while outside mutex
+	NotifyEventHooks(hContactDeletedEvent,wParam,0);
+	//get back in
+	EnterCriticalSection(&csDbAccess);
+
+	{	DBCachedContactValueList VLtemp;
+		VLtemp.hContact = (HANDLE)wParam;
+		if ( li.List_GetIndex(&lContacts,&VLtemp,&index))
+		{
+			DBCachedContactValueList *VL = ( DBCachedContactValueList* )lContacts.items[index];
+			DBCachedContactValue* V = VL->first;
+			while ( V != NULL ) {
+				DBCachedContactValue* V1 = V->next;
+				if ( V->value.type == DBVT_ASCIIZ )
+					HeapFree( hCacheHeap, HEAP_NO_SERIALIZE, V->value.pszVal );
+				HeapFree( hCacheHeap, HEAP_NO_SERIALIZE, V );
+				V = V1;
+			}
+			HeapFree( hCacheHeap, HEAP_NO_SERIALIZE, VL );
+
+			li.List_Remove(&lContacts,index);
+	}	}
+
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	//delete settings chain
+	ofsThis=dbc->ofsFirstSettings;
+	ofsFirstEvent=dbc->ofsFirstEvent;
+	while(ofsThis) {
+		dbcs=(struct DBContactSettings*)DBRead(ofsThis,sizeof(struct DBContactSettings),NULL);
+		ofsNext=dbcs->ofsNext;
+		DeleteSpace(ofsThis,offsetof(struct DBContactSettings,blob)+dbcs->cbBlob);
+		ofsThis=ofsNext;
+	}
+	//delete event chain
+	ofsThis=ofsFirstEvent;
+	while(ofsThis) {
+		dbe=(struct DBEvent*)DBRead(ofsThis,sizeof(struct DBEvent),NULL);
+		ofsNext=dbe->ofsNext;
+		DeleteSpace(ofsThis,offsetof(struct DBEvent,blob)+dbe->cbBlob);
+		ofsThis=ofsNext;
+	}
+	//find previous contact in chain and change ofsNext
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbHeader.ofsFirstContact==wParam) {
+		dbHeader.ofsFirstContact=dbc->ofsNext;
+		DBWrite(0,&dbHeader,sizeof(dbHeader));
+	}
+	else {
+		ofsNext=dbc->ofsNext;
+		ofsThis=dbHeader.ofsFirstContact;
+		dbcPrev=(struct DBContact*)DBRead(ofsThis,sizeof(struct DBContact),NULL);
+		while(dbcPrev->ofsNext!=wParam) {
+			if(dbcPrev->ofsNext==0) DatabaseCorruption();
+			ofsThis=dbcPrev->ofsNext;
+			dbcPrev=(struct DBContact*)DBRead(ofsThis,sizeof(struct DBContact),NULL);
+		}
+		dbcPrev->ofsNext=ofsNext;
+		DBWrite(ofsThis,dbcPrev,sizeof(struct DBContact));
+		{
+			DBCachedContactValueList VLtemp;
+			VLtemp.hContact = (HANDLE)ofsThis;
+			if ( li.List_GetIndex(&lContacts,&VLtemp,&index))
+			{
+				DBCachedContactValueList *VL = ( DBCachedContactValueList* )lContacts.items[index];
+				VL->hNext = ( HANDLE )ofsNext;
+		}	}
+	}
+	//delete contact
+	DeleteSpace(wParam,sizeof(struct DBContact));
+	//decrement contact count
+	dbHeader.contactCount--;
+	DBWrite(0,&dbHeader,sizeof(dbHeader));
+	DBFlush(0);
+	//quit
+	LeaveCriticalSection(&csDbAccess);
+	return 0;
+}
+
+static int AddContact(WPARAM wParam,LPARAM lParam)
+{
+	struct DBContact dbc;
+	DWORD ofsNew;
+
+	log0("add contact");
+	EnterCriticalSection(&csDbAccess);
+	ofsNew=CreateNewSpace(sizeof(struct DBContact));
+	dbc.signature=DBCONTACT_SIGNATURE;
+	dbc.eventCount=0;
+	dbc.ofsFirstEvent=dbc.ofsLastEvent=0;
+	dbc.ofsFirstSettings=0;
+	dbc.ofsNext=dbHeader.ofsFirstContact;
+	dbc.ofsFirstUnreadEvent=0;
+	dbc.timestampFirstUnread=0;
+	dbHeader.ofsFirstContact=ofsNew;
+	dbHeader.contactCount++;
+	DBWrite(ofsNew,&dbc,sizeof(struct DBContact));
+	DBWrite(0,&dbHeader,sizeof(dbHeader));
+	DBFlush(0);
+
+	{	int index;
+
+		DBCachedContactValueList *VL = (DBCachedContactValueList*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedContactValueList));
+		VL->hContact = (HANDLE)ofsNew;
+
+		li.List_GetIndex(&lContacts,VL,&index);
+		li.List_Insert(&lContacts,VL,index);
+	}
+
+	LeaveCriticalSection(&csDbAccess);
+	NotifyEventHooks(hContactAddedEvent,(WPARAM)ofsNew,0);
+	return (int)ofsNew;
+} 
+
+static int IsDbContact(WPARAM wParam,LPARAM lParam)
+{
+	struct DBContact dbc;
+	DWORD ofsContact=(DWORD)wParam;
+	int ret;
+
+	EnterCriticalSection(&csDbAccess);
+	{
+		int index;
+		DBCachedContactValueList VLtemp,*VL;
+		VLtemp.hContact = (HANDLE)wParam;
+		if ( li.List_GetIndex(&lContacts,&VLtemp,&index))
+			ret = TRUE;
+		else {
+			dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+			ret=dbc.signature==DBCONTACT_SIGNATURE;
+
+			if (ret) {
+				VL = (DBCachedContactValueList*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedContactValueList));
+				VL->hContact = (HANDLE)wParam;
+				li.List_Insert(&lContacts,VL,index);
+	}	}	}
+
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
diff --git a/miranda-wine/plugins/db3x/dbevents.c b/miranda-wine/plugins/db3x/dbevents.c
new file mode 100644
index 0000000..ffc5eed
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbevents.c
@@ -0,0 +1,436 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+
+DWORD GetModuleNameOfs(const char *szName);
+char *GetModuleNameByOfs(DWORD ofs);
+
+static int GetEventCount(WPARAM wParam,LPARAM lParam);
+static int AddEvent(WPARAM wParam,LPARAM lParam);
+static int DeleteEvent(WPARAM wParam,LPARAM lParam);
+static int GetBlobSize(WPARAM wParam,LPARAM lParam);
+static int GetEvent(WPARAM wParam,LPARAM lParam);
+static int MarkEventRead(WPARAM wParam,LPARAM lParam);
+static int GetEventContact(WPARAM wParam,LPARAM lParam);
+static int FindFirstEvent(WPARAM wParam,LPARAM lParam);
+static int FindFirstUnreadEvent(WPARAM wParam,LPARAM lParam);
+static int FindLastEvent(WPARAM wParam,LPARAM lParam);
+static int FindNextEvent(WPARAM wParam,LPARAM lParam);
+static int FindPrevEvent(WPARAM wParam,LPARAM lParam);
+
+extern CRITICAL_SECTION csDbAccess;
+extern struct DBHeader dbHeader;
+
+static HANDLE hEventDeletedEvent,hEventAddedEvent,hEventFilterAddedEvent;
+
+int InitEvents(void)
+{
+	CreateServiceFunction(MS_DB_EVENT_GETCOUNT,GetEventCount);
+	CreateServiceFunction(MS_DB_EVENT_ADD,AddEvent);
+	CreateServiceFunction(MS_DB_EVENT_DELETE,DeleteEvent);
+	CreateServiceFunction(MS_DB_EVENT_GETBLOBSIZE,GetBlobSize);
+	CreateServiceFunction(MS_DB_EVENT_GET,GetEvent);
+	CreateServiceFunction(MS_DB_EVENT_MARKREAD,MarkEventRead);
+	CreateServiceFunction(MS_DB_EVENT_GETCONTACT,GetEventContact);
+	CreateServiceFunction(MS_DB_EVENT_FINDFIRST,FindFirstEvent);
+	CreateServiceFunction(MS_DB_EVENT_FINDFIRSTUNREAD,FindFirstUnreadEvent);
+	CreateServiceFunction(MS_DB_EVENT_FINDLAST,FindLastEvent);
+	CreateServiceFunction(MS_DB_EVENT_FINDNEXT,FindNextEvent);
+	CreateServiceFunction(MS_DB_EVENT_FINDPREV,FindPrevEvent);
+	hEventDeletedEvent=CreateHookableEvent(ME_DB_EVENT_DELETED);
+	hEventAddedEvent=CreateHookableEvent(ME_DB_EVENT_ADDED);
+	hEventFilterAddedEvent=CreateHookableEvent(ME_DB_EVENT_FILTER_ADD);
+	return 0;
+}
+
+void UninitEvents(void)
+{
+}
+
+static int GetEventCount(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBContact *dbc;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) wParam=dbHeader.ofsUser;
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) ret=-1;
+	else ret=dbc->eventCount;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int AddEvent(WPARAM wParam,LPARAM lParam)
+{
+	DBEVENTINFO *dbei=(DBEVENTINFO*)lParam;
+	struct DBContact dbc;
+	struct DBEvent dbe,*dbeTest;
+	DWORD ofsNew,ofsModuleName,ofsContact,ofsThis;
+
+	if(dbei==NULL||dbei->cbSize!=sizeof(DBEVENTINFO)) return (int)NULL;
+	if(dbei->timestamp==0) return (int)NULL;
+	if (NotifyEventHooks(hEventFilterAddedEvent,wParam,lParam)) {
+		return (int)NULL;
+	}
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) ofsContact=dbHeader.ofsUser;
+	else ofsContact=wParam;
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	if(dbc.signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+	  	return (int)NULL;
+	}
+	ofsNew=CreateNewSpace(offsetof(struct DBEvent,blob)+dbei->cbBlob);
+	ofsModuleName=GetModuleNameOfs(dbei->szModule);
+
+	dbe.signature=DBEVENT_SIGNATURE;
+	dbe.ofsModuleName=ofsModuleName;
+	dbe.timestamp=dbei->timestamp;
+	dbe.flags=dbei->flags;
+	dbe.eventType=dbei->eventType;
+	dbe.cbBlob=dbei->cbBlob;
+	//find where to put it - sort by timestamp
+	if(dbc.eventCount==0) {
+		dbe.ofsPrev=wParam;
+		dbe.ofsNext=0;
+		dbe.flags|=DBEF_FIRST;
+		dbc.ofsFirstEvent=dbc.ofsLastEvent=ofsNew;
+	}
+	else {
+		dbeTest=(struct DBEvent*)DBRead(dbc.ofsFirstEvent,sizeof(struct DBEvent),NULL);
+		// Should new event be placed before first event in chain?
+		if (dbei->timestamp < dbeTest->timestamp) {
+			dbe.ofsPrev=wParam;
+			dbe.ofsNext=dbc.ofsFirstEvent;
+			dbe.flags|=DBEF_FIRST;
+			dbc.ofsFirstEvent=ofsNew;
+			dbeTest=(struct DBEvent*)DBRead(dbe.ofsNext,sizeof(struct DBEvent),NULL);
+			dbeTest->flags&=~DBEF_FIRST;
+			dbeTest->ofsPrev=ofsNew;
+			DBWrite(dbe.ofsNext,dbeTest,sizeof(struct DBEvent));
+		}
+		else {
+			// Loop through the chain, starting at the end
+			ofsThis = dbc.ofsLastEvent;
+			dbeTest = (struct DBEvent*)DBRead(ofsThis, sizeof(struct DBEvent), NULL);
+			for(;;) {
+				// If the new event's timesstamp is equal to or greater than the
+				// current dbevent, it will be inserted after. If not, continue
+				// with the previous dbevent in chain.
+				if (dbe.timestamp >= dbeTest->timestamp) {
+					dbe.ofsPrev = ofsThis;
+					dbe.ofsNext = dbeTest->ofsNext;
+					dbeTest->ofsNext = ofsNew;
+					DBWrite(ofsThis, dbeTest, sizeof(struct DBEvent));
+					if (dbe.ofsNext == 0)
+						dbc.ofsLastEvent = ofsNew;
+					else {
+						dbeTest = (struct DBEvent*)DBRead(dbe.ofsNext, sizeof(struct DBEvent), NULL);
+						dbeTest->ofsPrev = ofsNew;
+						DBWrite(dbe.ofsNext, dbeTest, sizeof(struct DBEvent));
+					}
+					break;
+				}
+				ofsThis = dbeTest->ofsPrev;
+				dbeTest = (struct DBEvent*)DBRead(ofsThis, sizeof(struct DBEvent), NULL);
+			}
+		}
+	}
+	dbc.eventCount++;
+	if(!(dbe.flags&(DBEF_READ|DBEF_SENT))) {
+		if(dbe.timestamp<dbc.timestampFirstUnread || dbc.timestampFirstUnread==0) {
+			dbc.timestampFirstUnread=dbe.timestamp;
+			dbc.ofsFirstUnreadEvent=ofsNew;
+		}
+	}
+	DBWrite(ofsContact,&dbc,sizeof(struct DBContact));
+	DBWrite(ofsNew,&dbe,offsetof(struct DBEvent,blob));
+	DBWrite(ofsNew+offsetof(struct DBEvent,blob),dbei->pBlob,dbei->cbBlob);
+	DBFlush(0);
+	LeaveCriticalSection(&csDbAccess);
+	log1("add event @ %08x",ofsNew);
+	NotifyEventHooks(hEventAddedEvent,wParam,(LPARAM)ofsNew);
+	return (int)ofsNew;
+}
+
+static int DeleteEvent(WPARAM wParam,LPARAM lParam)
+{
+	struct DBContact dbc;
+	DWORD ofsContact,ofsThis;
+	struct DBEvent dbe,*dbeNext,*dbePrev;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) ofsContact=dbHeader.ofsUser;
+	else ofsContact=wParam;
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	dbe=*(struct DBEvent*)DBRead(lParam,sizeof(struct DBEvent),NULL);
+	if(dbc.signature!=DBCONTACT_SIGNATURE || dbe.signature!=DBEVENT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	log1("delete event @ %08x",wParam);
+	LeaveCriticalSection(&csDbAccess);
+	//call notifier while outside mutex
+	NotifyEventHooks(hEventDeletedEvent,wParam,lParam);
+	//get back in
+	EnterCriticalSection(&csDbAccess);
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	dbe=*(struct DBEvent*)DBRead(lParam,sizeof(struct DBEvent),NULL);
+	//check if this was the first unread, if so, recalc the first unread
+	if(dbc.ofsFirstUnreadEvent==(DWORD)lParam) {
+		dbeNext=&dbe;
+		for(;;) {
+			if(dbeNext->ofsNext==0) {
+				dbc.ofsFirstUnreadEvent=0;
+				dbc.timestampFirstUnread=0;
+				break;
+			}
+			ofsThis=dbeNext->ofsNext;
+			dbeNext=(struct DBEvent*)DBRead(ofsThis,sizeof(struct DBEvent),NULL);
+			if(!(dbeNext->flags&(DBEF_READ|DBEF_SENT))) {
+				dbc.ofsFirstUnreadEvent=ofsThis;
+				dbc.timestampFirstUnread=dbeNext->timestamp;
+				break;
+			}
+		}
+	}
+	//get previous and next events in chain and change offsets
+	if(dbe.flags&DBEF_FIRST) {
+		if(dbe.ofsNext==0) {
+			dbc.ofsFirstEvent=dbc.ofsLastEvent=0;
+		}
+		else {
+			dbeNext=(struct DBEvent*)DBRead(dbe.ofsNext,sizeof(struct DBEvent),NULL);
+			dbeNext->flags|=DBEF_FIRST;
+			dbeNext->ofsPrev=dbe.ofsPrev;
+			DBWrite(dbe.ofsNext,dbeNext,sizeof(struct DBEvent));
+			dbc.ofsFirstEvent=dbe.ofsNext;
+		}
+	}
+	else {
+		if(dbe.ofsNext==0) {
+			dbePrev=(struct DBEvent*)DBRead(dbe.ofsPrev,sizeof(struct DBEvent),NULL);
+			dbePrev->ofsNext=0;
+			DBWrite(dbe.ofsPrev,dbePrev,sizeof(struct DBEvent));
+			dbc.ofsLastEvent=dbe.ofsPrev;
+		}
+		else {
+			dbePrev=(struct DBEvent*)DBRead(dbe.ofsPrev,sizeof(struct DBEvent),NULL);
+			dbePrev->ofsNext=dbe.ofsNext;
+			DBWrite(dbe.ofsPrev,dbePrev,sizeof(struct DBEvent));
+			dbeNext=(struct DBEvent*)DBRead(dbe.ofsNext,sizeof(struct DBEvent),NULL);
+			dbeNext->ofsPrev=dbe.ofsPrev;
+			DBWrite(dbe.ofsNext,dbeNext,sizeof(struct DBEvent));
+		}
+	}
+	//delete event
+	DeleteSpace(lParam,offsetof(struct DBEvent,blob)+dbe.cbBlob);
+	//decrement event count
+	dbc.eventCount--;
+	DBWrite(ofsContact,&dbc,sizeof(struct DBContact));
+	DBFlush(0);
+	//quit
+	LeaveCriticalSection(&csDbAccess);
+	return 0;
+}
+
+static int GetBlobSize(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBEvent *dbe;
+	
+	EnterCriticalSection(&csDbAccess);
+	dbe=(struct DBEvent*)DBRead(wParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE) ret=-1;
+	else ret=dbe->cbBlob;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int GetEvent(WPARAM wParam,LPARAM lParam)
+{
+	struct DBEvent *dbe;
+	DBEVENTINFO *dbei=(DBEVENTINFO*)lParam;
+	int bytesToCopy,i;
+	
+	if(dbei==NULL||dbei->cbSize!=sizeof(DBEVENTINFO)) return 1;
+	EnterCriticalSection(&csDbAccess);
+	dbe=(struct DBEvent*)DBRead(wParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+	  	return 1;
+	}
+	dbei->szModule=GetModuleNameByOfs(dbe->ofsModuleName);
+	dbei->timestamp=dbe->timestamp;
+	dbei->flags=dbe->flags;
+	dbei->eventType=dbe->eventType;
+	if(dbei->cbBlob<dbe->cbBlob) bytesToCopy=dbei->cbBlob;
+	else bytesToCopy=dbe->cbBlob;
+	dbei->cbBlob=dbe->cbBlob;
+	for(i=0;;i+=MAXCACHEDREADSIZE) {
+		if(bytesToCopy-i<=MAXCACHEDREADSIZE) {
+			CopyMemory(dbei->pBlob+i,DBRead(wParam+offsetof(struct DBEvent,blob)+i,bytesToCopy-i,NULL),bytesToCopy-i);
+			break;
+		}
+		CopyMemory(dbei->pBlob+i,DBRead(wParam+offsetof(struct DBEvent,blob)+i,MAXCACHEDREADSIZE,NULL),MAXCACHEDREADSIZE);
+	}
+	LeaveCriticalSection(&csDbAccess);
+	return 0;
+}
+
+static int MarkEventRead(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBEvent *dbe;
+	struct DBContact dbc;
+	DWORD ofsThis;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) wParam=dbHeader.ofsUser;
+	dbc=*(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	dbe=(struct DBEvent*)DBRead(lParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE || dbc.signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+	  	return -1;
+	}
+	if(dbe->flags&DBEF_READ || dbe->flags&DBEF_SENT) {
+		ret=(int)dbe->flags;
+		LeaveCriticalSection(&csDbAccess);
+		return ret;
+	}
+	log1("mark read @ %08x",wParam);
+	dbe->flags|=DBEF_READ;
+	DBWrite(lParam,dbe,sizeof(struct DBEvent));
+	ret=(int)dbe->flags;
+	if(dbc.ofsFirstUnreadEvent==(DWORD)lParam) {
+		for(;;) {
+			if(dbe->ofsNext==0) {
+				dbc.ofsFirstUnreadEvent=0;
+				dbc.timestampFirstUnread=0;
+				break;
+			}
+			ofsThis=dbe->ofsNext;
+			dbe=(struct DBEvent*)DBRead(ofsThis,sizeof(struct DBEvent),NULL);
+			if(!(dbe->flags&(DBEF_READ|DBEF_SENT))) {
+				dbc.ofsFirstUnreadEvent=ofsThis;
+				dbc.timestampFirstUnread=dbe->timestamp;
+				break;
+			}
+		}
+	}
+	DBWrite(wParam,&dbc,sizeof(struct DBContact));
+	DBFlush(0);
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int GetEventContact(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBEvent *dbe;
+	
+	EnterCriticalSection(&csDbAccess);
+	dbe=(struct DBEvent*)DBRead(wParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+	  	return -1;
+	}
+	while(!(dbe->flags&DBEF_FIRST))
+		dbe=(struct DBEvent*)DBRead(dbe->ofsPrev,sizeof(struct DBEvent),NULL);
+	ret=(int)(HANDLE)dbe->ofsPrev;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindFirstEvent(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBContact *dbc;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) wParam=dbHeader.ofsUser;
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) ret=(int)(HANDLE)NULL;
+	else ret=(int)dbc->ofsFirstEvent;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindFirstUnreadEvent(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBContact *dbc;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) wParam=dbHeader.ofsUser;
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) ret=(int)(HANDLE)NULL;
+	else ret=(int)dbc->ofsFirstUnreadEvent;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindLastEvent(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBContact *dbc;
+	
+	EnterCriticalSection(&csDbAccess);
+	if(wParam==0) wParam=dbHeader.ofsUser;
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) ret=(int)(HANDLE)NULL;
+	else ret=(int)dbc->ofsLastEvent;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindNextEvent(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBEvent *dbe;
+	
+	EnterCriticalSection(&csDbAccess);
+	dbe=(struct DBEvent*)DBRead(wParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE) ret=(int)(HANDLE)NULL;
+	else ret=(int)(HANDLE)dbe->ofsNext;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
+
+static int FindPrevEvent(WPARAM wParam,LPARAM lParam)
+{
+	int ret;
+	struct DBEvent *dbe;
+	
+	EnterCriticalSection(&csDbAccess);
+	dbe=(struct DBEvent*)DBRead(wParam,sizeof(struct DBEvent),NULL);
+	if(dbe->signature!=DBEVENT_SIGNATURE) ret=(int)(HANDLE)NULL;
+	else if(dbe->flags&DBEF_FIRST) ret=(int)(HANDLE)NULL;
+	else ret=(int)(HANDLE)dbe->ofsPrev;
+	LeaveCriticalSection(&csDbAccess);
+	return ret;
+}
diff --git a/miranda-wine/plugins/db3x/dbheaders.c b/miranda-wine/plugins/db3x/dbheaders.c
new file mode 100644
index 0000000..da7cb6e
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbheaders.c
@@ -0,0 +1,78 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+extern struct DBHeader dbHeader;
+extern HANDLE hDbFile;
+
+struct DBSignature {
+  char name[15];
+  BYTE eof;
+};
+static struct DBSignature dbSignature={"Miranda ICQ DB",0x1A};
+
+//the cache has not been loaded when these functions are used
+
+int CreateDbHeaders(HANDLE hFile)
+{
+	struct DBContact user;
+	DWORD bytesWritten;
+
+	CopyMemory(dbHeader.signature,&dbSignature,sizeof(dbHeader.signature));
+	dbHeader.version=DB_THIS_VERSION;
+	dbHeader.ofsFileEnd=sizeof(struct DBHeader);
+	dbHeader.slackSpace=0;
+	dbHeader.contactCount=0;
+	dbHeader.ofsFirstContact=0;
+	dbHeader.ofsFirstModuleName=0;
+	dbHeader.ofsUser=0;
+	//create user
+	dbHeader.ofsUser=dbHeader.ofsFileEnd;
+	dbHeader.ofsFileEnd+=sizeof(struct DBContact);
+	SetFilePointer(hFile,0,NULL,FILE_BEGIN);
+	WriteFile(hFile,&dbHeader,sizeof(dbHeader),&bytesWritten,NULL);
+	user.signature=DBCONTACT_SIGNATURE;
+	user.ofsNext=0;
+	user.ofsFirstSettings=0;
+	user.eventCount=0;
+	user.ofsFirstEvent=user.ofsLastEvent=0;
+	SetFilePointer(hFile,dbHeader.ofsUser,NULL,FILE_BEGIN);
+	WriteFile(hFile,&user,sizeof(struct DBContact),&bytesWritten,NULL);
+	FlushFileBuffers(hFile);
+	return 0;
+}
+
+int CheckDbHeaders(struct DBHeader * hdr)
+{
+	if(memcmp(hdr->signature,&dbSignature,sizeof(hdr->signature))) return 1;
+	if(hdr->version!=DB_THIS_VERSION) return 2;
+	if(hdr->ofsUser==0) return 3;
+	return 0;
+}
+
+int InitialiseDbHeaders(void)
+{
+	return 0;
+}
diff --git a/miranda-wine/plugins/db3x/dbmodulechain.c b/miranda-wine/plugins/db3x/dbmodulechain.c
new file mode 100644
index 0000000..352a06c
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbmodulechain.c
@@ -0,0 +1,132 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+extern struct DBHeader dbHeader;
+
+static int EnumModuleNames(WPARAM wParam,LPARAM lParam);
+
+struct ModuleName {
+	char *name;
+	DWORD hash;
+	DWORD ofs;
+};
+static struct ModuleName *moduleName;
+static int moduleNameCount;
+
+int InitModuleNames(void)
+{
+	struct DBModuleName *dbmn;
+	DWORD ofsThis,ofsNext;
+	int nameLen;
+
+	moduleNameCount=0;
+	moduleName=NULL;
+	ofsThis=dbHeader.ofsFirstModuleName;
+	dbmn=(struct DBModuleName*)DBRead(ofsThis,sizeof(struct DBModuleName),NULL);
+	while(ofsThis) {
+		if(dbmn->signature!=DBMODULENAME_SIGNATURE) DatabaseCorruption();
+		moduleName=(struct ModuleName*)mir_realloc(moduleName,sizeof(struct ModuleName)*(moduleNameCount+1));
+		moduleName[moduleNameCount].ofs=ofsThis;
+		moduleName[moduleNameCount].hash=dbmn->cbName;    //very very simple hash so far
+		moduleName[moduleNameCount].name=(char*)mir_alloc(dbmn->cbName+1);
+		ofsNext=dbmn->ofsNext;
+		nameLen=dbmn->cbName;
+		CopyMemory(moduleName[moduleNameCount].name,DBRead(ofsThis+offsetof(struct DBModuleName,name),nameLen,NULL),nameLen);
+		moduleName[moduleNameCount].name[nameLen]=0;
+		moduleNameCount++;
+		ofsThis=ofsNext;
+		dbmn=(struct DBModuleName*)DBRead(ofsThis,sizeof(struct DBModuleName),NULL);
+	}
+	CreateServiceFunction(MS_DB_MODULES_ENUM,EnumModuleNames);
+	return 0;
+}
+
+void UninitModuleNames(void)
+{
+	int i;
+	for(i=0;i<moduleNameCount;i++) mir_free(moduleName[i].name);
+	if(moduleNameCount) mir_free(moduleName);
+}
+
+static DWORD FindExistingModuleNameOfs(const char *szName,int nameLen)
+{
+	int i;
+	for(i=0;i<moduleNameCount;i++)
+		if(moduleName[i].hash==(DWORD)nameLen && !strcmp(moduleName[i].name,szName)) return moduleName[i].ofs;
+	return 0;
+}
+
+//will create the offset if it needs to
+DWORD GetModuleNameOfs(const char *szName)
+{
+	struct DBModuleName dbmn;
+	int nameLen=strlen(szName);
+	DWORD ofsNew,ofsExisting;
+
+	ofsExisting=FindExistingModuleNameOfs(szName,nameLen);
+	if(ofsExisting) return ofsExisting;
+	//need to create the module name
+	ofsNew=CreateNewSpace(nameLen+offsetof(struct DBModuleName,name));
+	dbmn.signature=DBMODULENAME_SIGNATURE;
+	dbmn.cbName=nameLen;
+	dbmn.ofsNext=dbHeader.ofsFirstModuleName;
+	dbHeader.ofsFirstModuleName=ofsNew;
+	DBWrite(0,&dbHeader,sizeof(dbHeader));
+	DBWrite(ofsNew,&dbmn,offsetof(struct DBModuleName,name));
+	DBWrite(ofsNew+offsetof(struct DBModuleName,name),(PVOID)szName,nameLen);
+	DBFlush(0);
+	//add to cache
+	moduleName=(struct ModuleName*)mir_realloc(moduleName,sizeof(struct ModuleName)*(moduleNameCount+1));
+	moduleName[moduleNameCount].ofs=ofsNew;
+	moduleName[moduleNameCount].hash=nameLen;    //very very simple hash so far
+	moduleName[moduleNameCount].name=(char*)mir_alloc(nameLen+1);
+	strcpy(moduleName[moduleNameCount].name,szName);
+	moduleNameCount++;
+	//quit
+	return ofsNew;
+}
+
+//it's OK that this is a bit slow - it's rarely used
+char *GetModuleNameByOfs(DWORD ofs)
+{
+	int i;
+
+	for(i=0;i<moduleNameCount;i++)
+		if(moduleName[i].ofs==ofs) return moduleName[i].name;
+	DatabaseCorruption();
+	return NULL;
+} 
+
+static int EnumModuleNames(WPARAM wParam,LPARAM lParam)
+{
+	int i;
+	int ret;
+	for(i=0;i<moduleNameCount;i++) {
+		ret=((DBMODULEENUMPROC)lParam)(moduleName[i].name,moduleName[i].ofs,wParam);
+		if(ret) return ret;
+	}
+	return 0;
+}
diff --git a/miranda-wine/plugins/db3x/dbsettings.c b/miranda-wine/plugins/db3x/dbsettings.c
new file mode 100644
index 0000000..d01988e
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbsettings.c
@@ -0,0 +1,957 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project,
+all portions of this codebase are copyrighted to the people
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+
+#include "database.h"
+
+DWORD GetModuleNameOfs(const char *szName);
+
+extern CRITICAL_SECTION csDbAccess;
+extern struct DBHeader dbHeader;
+
+HANDLE hCacheHeap = NULL;
+SortedList lContacts;
+
+static SortedList lSettings, lGlobalSettings;
+static HANDLE hSettingChangeEvent = NULL;
+
+#define SETTINGSGROUPOFSCOUNT    32
+struct SettingsGroupOfsCacheEntry {
+	DWORD ofsContact;
+	DWORD ofsModuleName;
+	DWORD ofsSettingsGroup;
+};
+static struct SettingsGroupOfsCacheEntry settingsGroupOfsCache[SETTINGSGROUPOFSCOUNT];
+static int nextSGOCacheEntry;
+
+//this function caches results
+static DWORD GetSettingsGroupOfsByModuleNameOfs(struct DBContact *dbc,DWORD ofsContact,DWORD ofsModuleName)
+{
+	struct DBContactSettings *dbcs;
+	DWORD ofsThis;
+	int i;
+
+	for(i=0;i<SETTINGSGROUPOFSCOUNT;i++) {
+		if(settingsGroupOfsCache[i].ofsContact==ofsContact && settingsGroupOfsCache[i].ofsModuleName==ofsModuleName)
+			return settingsGroupOfsCache[i].ofsSettingsGroup;
+	}
+	ofsThis=dbc->ofsFirstSettings;
+	while(ofsThis) {
+		dbcs=(struct DBContactSettings*)DBRead(ofsThis,sizeof(struct DBContactSettings),NULL);
+		if(dbcs->signature!=DBCONTACTSETTINGS_SIGNATURE) DatabaseCorruption();
+		if(dbcs->ofsModuleName==ofsModuleName) {
+			settingsGroupOfsCache[nextSGOCacheEntry].ofsContact=ofsContact;
+			settingsGroupOfsCache[nextSGOCacheEntry].ofsModuleName=ofsModuleName;
+			settingsGroupOfsCache[nextSGOCacheEntry].ofsSettingsGroup=ofsThis;
+			if(++nextSGOCacheEntry==SETTINGSGROUPOFSCOUNT) nextSGOCacheEntry=0;
+			return ofsThis;
+		}
+		ofsThis=dbcs->ofsNext;
+	}
+	return 0;
+}
+
+static void InvalidateSettingsGroupOfsCacheEntry(DWORD ofsSettingsGroup)
+{
+	int i;
+
+	for(i=0;i<SETTINGSGROUPOFSCOUNT;i++) {
+		if(settingsGroupOfsCache[i].ofsSettingsGroup==ofsSettingsGroup) {
+			settingsGroupOfsCache[i].ofsContact=0;
+			settingsGroupOfsCache[i].ofsModuleName=0;
+			settingsGroupOfsCache[i].ofsSettingsGroup=0;
+			break;
+}	}	}
+
+static DWORD __inline GetSettingValueLength(PBYTE pSetting)
+{
+	if(pSetting[0]&DBVTF_VARIABLELENGTH) return 2+*(PWORD)(pSetting+1);
+	return pSetting[0];
+}
+
+static char* InsertCachedSetting( const char* szName, size_t cbNameLen, int index )
+{
+	char* newValue = (char*)HeapAlloc( hCacheHeap, HEAP_NO_SERIALIZE, cbNameLen );
+	*newValue = 0;
+	strcpy(newValue+1,szName+1);
+	li.List_Insert(&lSettings,newValue,index);
+	return newValue;
+}
+
+static char* GetCachedSetting(const char *szModuleName,const char *szSettingName,int settingNameLen)
+{
+	int moduleNameLen = strlen(szModuleName),index;
+	char *szFullName = (char*)alloca(moduleNameLen+settingNameLen+3);
+
+	strcpy(szFullName+1,szModuleName);
+	szFullName[moduleNameLen+1]='/';
+	strcpy(szFullName+moduleNameLen+2,szSettingName);
+
+	if ( li.List_GetIndex(&lSettings, szFullName, &index))
+		return((char*)lSettings.items[index] + 1);
+
+	return InsertCachedSetting( szFullName, moduleNameLen+settingNameLen+3, index )+1;
+}
+
+static void SetCachedVariant( DBVARIANT* s /* new */, DBVARIANT* d /* cached */ )
+{
+	char* szSave = ( d->type == DBVT_UTF8 || d->type == DBVT_ASCIIZ ) ? d->pszVal : NULL;
+
+	memcpy( d, s, sizeof( DBVARIANT ));
+	if (( s->type == DBVT_UTF8 || s->type == DBVT_ASCIIZ ) && s->pszVal != NULL ) {
+		if ( szSave != NULL )
+			d->pszVal = (char*)HeapReAlloc(hCacheHeap,HEAP_NO_SERIALIZE,szSave,strlen(s->pszVal)+1);
+		else
+			d->pszVal = (char*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE,strlen(s->pszVal)+1);
+		strcpy(d->pszVal,s->pszVal);
+	}
+
+	switch( d->type ) {
+		case DBVT_BYTE:	log1( "set cached byte: %d", d->bVal ); break;
+		case DBVT_WORD:	log1( "set cached word: %d", d->wVal ); break;
+		case DBVT_DWORD:	log1( "set cached dword: %d", d->dVal ); break;
+		case DBVT_UTF8:
+		case DBVT_ASCIIZ: log1( "set cached string: '%s'", d->pszVal ); break;
+		default:				log1( "set cached crap: %d", d->type ); break;
+}	}
+
+static void FreeCachedVariant( DBVARIANT* V )
+{
+	if (( V->type == DBVT_ASCIIZ || V->type == DBVT_UTF8 ) && V->pszVal != NULL )
+		HeapFree(hCacheHeap,HEAP_NO_SERIALIZE,V->pszVal);
+}
+
+static DBVARIANT* GetCachedValuePtr( HANDLE hContact, char* szSetting, int bAllocate )
+{
+	int index;
+
+	if ( hContact == 0 ) {
+		DBCachedGlobalValue Vtemp, *V;
+		Vtemp.name = szSetting;
+		if ( li.List_GetIndex(&lGlobalSettings,&Vtemp,&index)) {
+			V = (DBCachedGlobalValue*)lGlobalSettings.items[index];
+			if ( bAllocate == -1 ) {
+				FreeCachedVariant( &V->value );
+				li.List_Remove(&lGlobalSettings,index);
+				HeapFree(hCacheHeap,HEAP_NO_SERIALIZE,V);
+				return NULL;
+		}	}
+		else {
+			if ( bAllocate != 1 )
+				return NULL;
+
+			V = (DBCachedGlobalValue*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedGlobalValue));
+			V->name = szSetting;
+			li.List_Insert(&lGlobalSettings,V,index);
+		}
+
+		return &V->value;
+	}
+	else {
+		DBCachedContactValue *V, *V1;
+		DBCachedContactValueList VLtemp,*VL;
+
+		VLtemp.hContact=hContact;
+		if ( li.List_GetIndex(&lContacts,&VLtemp,&index)) {
+			VL = (DBCachedContactValueList*)lContacts.items[index];
+		}
+		else {
+			if ( bAllocate == -1 )
+				return NULL;
+
+			VL = (DBCachedContactValueList*)HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedContactValueList));
+			VL->hContact = hContact;
+			li.List_Insert(&lContacts,VL,index);
+		}
+
+		for ( V = VL->first; V != NULL; V = V->next)
+			if (strcmp(V->name,szSetting)==0)
+				break;
+
+		if ( V == NULL )
+		{	if ( bAllocate != 1 )
+				return NULL;
+
+			V = HeapAlloc(hCacheHeap,HEAP_NO_SERIALIZE+HEAP_ZERO_MEMORY,sizeof(DBCachedContactValue));
+			V->next = VL->first;
+			VL->first = V;
+			V->name = szSetting;
+		}
+		else if ( bAllocate == -1 ) {
+			FreeCachedVariant(&V->value);
+			if ( VL->first == V )
+				VL->first = V->next;
+			for ( V1=VL->first; V1 != NULL; V1 = V1->next )
+				if ( V1->next == V ) {
+					V1->next = V->next;
+					break;
+				}
+			HeapFree(hCacheHeap,HEAP_NO_SERIALIZE,V);
+			return NULL;
+		}
+
+		return &V->value;
+}	}
+
+#define NeedBytes(n)   if(bytesRemaining<(n)) pBlob=(PBYTE)DBRead(ofsBlobPtr,(n),&bytesRemaining)
+#define MoveAlong(n)   {int x=n; pBlob+=(x); ofsBlobPtr+=(x); bytesRemaining-=(x);}
+#define VLT(n) ((n==DBVT_UTF8)?DBVT_ASCIIZ:n)
+static __inline int GetContactSettingWorker(HANDLE hContact,DBCONTACTGETSETTING *dbcgs,int isStatic)
+{
+	struct DBContact dbc;
+	struct DBContactSettings dbcs;
+	DWORD ofsModuleName,ofsContact,ofsSettingsGroup,ofsBlobPtr;
+	int settingNameLen;
+	int bytesRemaining;
+	PBYTE pBlob;
+	char* szCachedSettingName;
+
+	if ((!dbcgs->szSetting) || (!dbcgs->szModule))
+		return 1;
+	settingNameLen=strlen(dbcgs->szSetting);
+
+	EnterCriticalSection(&csDbAccess);
+
+	log3("get [%08p] %s/%s",hContact,dbcgs->szModule,dbcgs->szSetting);
+
+	szCachedSettingName = GetCachedSetting(dbcgs->szModule,dbcgs->szSetting,settingNameLen);
+	{
+		DBVARIANT* pCachedValue = GetCachedValuePtr( hContact, szCachedSettingName, 0 );
+		if ( pCachedValue != NULL ) {
+			if ( pCachedValue->type == DBVT_ASCIIZ || pCachedValue->type == DBVT_UTF8 ) {
+				int   cbOrigLen = dbcgs->pValue->cchVal;
+				char* cbOrigPtr = dbcgs->pValue->pszVal;
+				memcpy( dbcgs->pValue, pCachedValue, sizeof( DBVARIANT ));
+				if ( isStatic ) {
+					int cbLen = 0;
+					if ( pCachedValue->pszVal != NULL )
+						cbLen = strlen( pCachedValue->pszVal );
+
+					cbOrigLen--;
+					dbcgs->pValue->pszVal = cbOrigPtr;
+					if(cbLen<cbOrigLen) cbOrigLen=cbLen;
+					CopyMemory(dbcgs->pValue->pszVal,pCachedValue->pszVal,cbOrigLen);
+					dbcgs->pValue->pszVal[cbOrigLen]=0;
+					dbcgs->pValue->cchVal=cbLen;
+				}
+				else {
+					dbcgs->pValue->pszVal = (char*)mir_alloc(strlen(pCachedValue->pszVal)+1);
+					strcpy(dbcgs->pValue->pszVal,pCachedValue->pszVal);
+				}
+			}
+			else
+				memcpy( dbcgs->pValue, pCachedValue, sizeof( DBVARIANT ));
+
+			switch( dbcgs->pValue->type ) {
+				case DBVT_BYTE:	log1( "get cached byte: %d", dbcgs->pValue->bVal ); break;
+				case DBVT_WORD:	log1( "get cached word: %d", dbcgs->pValue->wVal ); break;
+				case DBVT_DWORD:	log1( "get cached dword: %d", dbcgs->pValue->dVal ); break;
+				case DBVT_UTF8:
+				case DBVT_ASCIIZ: log1( "get cached string: '%s'", dbcgs->pValue->pszVal); break;
+				default:				log1( "get cached crap: %d", dbcgs->pValue->type ); break;
+			}
+
+			LeaveCriticalSection(&csDbAccess);
+			return ( pCachedValue->type == DBVT_DELETED ) ? 1 : 0;
+	}	}
+
+	ofsModuleName=GetModuleNameOfs(dbcgs->szModule);
+	if(hContact==NULL) ofsContact=dbHeader.ofsUser;
+	else ofsContact=(DWORD)hContact;
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	if(dbc.signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	ofsSettingsGroup=GetSettingsGroupOfsByModuleNameOfs(&dbc,ofsContact,ofsModuleName);
+	if(ofsSettingsGroup) {
+		dbcs=*(struct DBContactSettings*)DBRead(ofsSettingsGroup,sizeof(struct DBContactSettings),&bytesRemaining);
+		ofsBlobPtr=ofsSettingsGroup+offsetof(struct DBContactSettings,blob);
+		pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+		while(pBlob[0]) {
+			NeedBytes(1+settingNameLen);
+			if(pBlob[0]==settingNameLen && !memcmp(pBlob+1,dbcgs->szSetting,settingNameLen)) {
+				MoveAlong(1+settingNameLen);
+				NeedBytes(5);
+				if(isStatic && pBlob[0]&DBVTF_VARIABLELENGTH && VLT(dbcgs->pValue->type) != VLT(pBlob[0])) {
+					LeaveCriticalSection(&csDbAccess);
+					return 1;
+				}
+				dbcgs->pValue->type=pBlob[0];
+				switch(pBlob[0]) {
+					case DBVT_DELETED: { /* this setting is deleted */
+						dbcgs->pValue->type=DBVT_DELETED;
+						LeaveCriticalSection(&csDbAccess);
+						return 2;
+					}
+					case DBVT_BYTE: dbcgs->pValue->bVal=pBlob[1]; break;
+					case DBVT_WORD: dbcgs->pValue->wVal=*(PWORD)(pBlob+1); break;
+					case DBVT_DWORD: dbcgs->pValue->dVal=*(PDWORD)(pBlob+1); break;
+					case DBVT_UTF8:
+					case DBVT_ASCIIZ:
+						NeedBytes(3+*(PWORD)(pBlob+1));
+						if(isStatic) {
+							dbcgs->pValue->cchVal--;
+							if(*(PWORD)(pBlob+1)<dbcgs->pValue->cchVal) dbcgs->pValue->cchVal=*(PWORD)(pBlob+1);
+							CopyMemory(dbcgs->pValue->pszVal,pBlob+3,dbcgs->pValue->cchVal);
+							dbcgs->pValue->pszVal[dbcgs->pValue->cchVal]=0;
+							dbcgs->pValue->cchVal=*(PWORD)(pBlob+1);
+						}
+						else {
+							dbcgs->pValue->pszVal=(char*)mir_alloc(1+*(PWORD)(pBlob+1));
+							CopyMemory(dbcgs->pValue->pszVal,pBlob+3,*(PWORD)(pBlob+1));
+							dbcgs->pValue->pszVal[*(PWORD)(pBlob+1)]=0;
+						}
+						break;
+					case DBVT_BLOB:
+						NeedBytes(3+*(PWORD)(pBlob+1));
+						if(isStatic) {
+							if(*(PWORD)(pBlob+1)<dbcgs->pValue->cpbVal) dbcgs->pValue->cpbVal=*(PWORD)(pBlob+1);
+							CopyMemory(dbcgs->pValue->pbVal,pBlob+3,dbcgs->pValue->cchVal);
+						}
+						else {
+							dbcgs->pValue->pbVal=(char*)mir_alloc(*(PWORD)(pBlob+1));
+							CopyMemory(dbcgs->pValue->pbVal,pBlob+3,*(PWORD)(pBlob+1));
+						}
+						dbcgs->pValue->cpbVal=*(PWORD)(pBlob+1);
+						break;
+				}
+
+				/**** add to cache **********************/
+				if ( dbcgs->pValue->type != DBVT_BLOB )
+				{
+					DBVARIANT* pCachedValue = GetCachedValuePtr( hContact, szCachedSettingName, 1 );
+					if ( pCachedValue != NULL )
+						SetCachedVariant(dbcgs->pValue,pCachedValue);
+				}
+
+				LeaveCriticalSection(&csDbAccess);
+				logg();
+				return 0;
+			}
+			NeedBytes(1);
+			MoveAlong(pBlob[0]+1);
+			NeedBytes(3);
+			MoveAlong(1+GetSettingValueLength(pBlob));
+			NeedBytes(1);
+	}	}
+
+	/**** add missing setting to cache **********************/
+	if ( dbcgs->pValue->type != DBVT_BLOB )
+	{
+		DBVARIANT* pCachedValue = GetCachedValuePtr( hContact, szCachedSettingName, 1 );
+		if ( pCachedValue != NULL )
+			pCachedValue->type = DBVT_DELETED;
+	}
+
+	LeaveCriticalSection(&csDbAccess);
+	logg();
+	return 1;
+}
+
+static int GetContactSetting(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTGETSETTING* dgs = ( DBCONTACTGETSETTING* )lParam;
+	dgs->pValue->type = 0;
+	if ( GetContactSettingWorker(( HANDLE )wParam, dgs, 0 ))
+		return 1;
+
+	if ( dgs->pValue->type == DBVT_UTF8 ) {
+		Utf8Decode( dgs->pValue->pszVal, NULL );
+		dgs->pValue->type = DBVT_ASCIIZ;
+	}
+
+	return 0;
+}
+
+static int GetContactSettingStr(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTGETSETTING* dgs = (DBCONTACTGETSETTING*)lParam;
+	int iSaveType = dgs->pValue->type;
+
+	if ( GetContactSettingWorker(( HANDLE )wParam, dgs, 0 ))
+		return 1;
+
+   if ( iSaveType == 0 || iSaveType == dgs->pValue->type )
+		return 0;
+
+	if ( dgs->pValue->type != DBVT_ASCIIZ && dgs->pValue->type != DBVT_UTF8 )
+		return 0;
+
+	if ( iSaveType == DBVT_WCHAR ) {
+		if ( dgs->pValue->type != DBVT_UTF8 ) {
+			int len = MultiByteToWideChar( CP_ACP, 0, dgs->pValue->pszVal, -1, NULL, 0 );
+			wchar_t* wszResult = ( wchar_t* )mir_alloc(( len+1 )*sizeof( wchar_t ));
+			if ( wszResult == NULL )
+				return 1;
+
+			MultiByteToWideChar( CP_ACP, 0, dgs->pValue->pszVal, -1, wszResult, len );
+			wszResult[ len ] = 0;
+			mir_free( dgs->pValue->pszVal );
+			dgs->pValue->pwszVal = wszResult;
+		}
+		else {
+			char* savePtr = dgs->pValue->pszVal;
+			Utf8Decode( dgs->pValue->pszVal, &dgs->pValue->pwszVal );
+			mir_free( savePtr );
+		}
+	}
+	else if ( iSaveType == DBVT_UTF8 ) {
+		char* tmpBuf = Utf8Encode( dgs->pValue->pszVal );
+		if ( tmpBuf == NULL )
+			return 1;
+
+		mir_free( dgs->pValue->pszVal );
+		dgs->pValue->pszVal = tmpBuf;
+	}
+	else if ( iSaveType == DBVT_ASCIIZ )
+		Utf8Decode( dgs->pValue->pszVal, NULL );
+
+	dgs->pValue->type = iSaveType;
+	return 0;
+}
+
+static int GetContactSettingStatic(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTGETSETTING* dgs = (DBCONTACTGETSETTING*)lParam;
+	if ( GetContactSettingWorker(( HANDLE )wParam, dgs, 1 ))
+		return 1;
+
+	if ( dgs->pValue->type == DBVT_UTF8 ) {
+		Utf8Decode( dgs->pValue->pszVal, NULL );
+		dgs->pValue->type = DBVT_ASCIIZ;
+	}
+
+	return 0;
+}
+
+static int FreeVariant(WPARAM wParam,LPARAM lParam)
+{
+	DBVARIANT *dbv=(DBVARIANT*)lParam;
+	if ( dbv == 0 ) return 1;
+	switch ( dbv->type ) {
+		case DBVT_ASCIIZ:
+		case DBVT_UTF8:
+		case DBVT_WCHAR:
+		{
+			if ( dbv->pszVal ) mir_free(dbv->pszVal);
+			dbv->pszVal=0;
+			break;
+		}
+		case DBVT_BLOB:
+		{
+			if ( dbv->pbVal ) mir_free(dbv->pbVal);
+			dbv->pbVal=0;
+			break;
+		}
+	}
+	dbv->type=0;
+	return 0;
+}
+
+static int SetSettingResident(WPARAM wParam,LPARAM lParam)
+{
+	char*  szSetting;
+	size_t cbSettingNameLen = strlen(( char* )lParam );
+	int    idx;
+	char*  szTemp = ( char* )alloca( cbSettingNameLen+2 );
+	strcpy( szTemp+1, ( char* )lParam );
+
+	EnterCriticalSection(&csDbAccess);
+	if ( !li.List_GetIndex( &lSettings, szTemp, &idx ))
+		szSetting = InsertCachedSetting( szTemp, cbSettingNameLen+2, idx );
+	else
+		szSetting = lSettings.items[ idx ];
+
+   *szSetting = (char)wParam;
+
+	LeaveCriticalSection(&csDbAccess);
+	return 0;
+}
+
+static int WriteContactSetting(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTWRITESETTING *dbcws=(DBCONTACTWRITESETTING*)lParam;
+	struct DBContact dbc;
+	DWORD ofsModuleName;
+	struct DBContactSettings dbcs;
+	PBYTE pBlob;
+	int settingNameLen=0;
+	int moduleNameLen=0;
+	int settingDataLen=0;
+
+	int bytesRequired,bytesRemaining;
+	DWORD ofsContact,ofsSettingsGroup,ofsBlobPtr;
+
+	if (dbcws == NULL)
+		return 1;
+
+	if (dbcws->value.type == DBVT_WCHAR) {
+		if (dbcws->value.pszVal != NULL) {
+			char* val = Utf8EncodeUcs2(dbcws->value.pwszVal);
+			if ( val == NULL )
+				return 1;
+
+			dbcws->value.pszVal = ( char* )alloca( strlen( val )+1 );
+			strcpy( dbcws->value.pszVal, val );
+			mir_free(val);
+			dbcws->value.type = DBVT_UTF8;
+		}
+		else return 1;
+	}
+
+	if(dbcws->value.type!=DBVT_BYTE && dbcws->value.type!=DBVT_WORD && dbcws->value.type!=DBVT_DWORD && dbcws->value.type!=DBVT_ASCIIZ && dbcws->value.type!=DBVT_UTF8 && dbcws->value.type!=DBVT_BLOB)
+		return 1;
+	if ((!dbcws->szModule) || (!dbcws->szSetting) || ((dbcws->value.type == DBVT_ASCIIZ || dbcws->value.type == DBVT_UTF8 )&& dbcws->value.pszVal == NULL) || (dbcws->value.type == DBVT_BLOB && dbcws->value.pbVal == NULL) )
+		return 1;
+	// the db format can't tolerate more than 255 bytes of space (incl. null) for settings+module name
+	settingNameLen=strlen(dbcws->szSetting);
+	moduleNameLen=strlen(dbcws->szModule);
+	if ( settingNameLen > 0xFE )
+	{
+		#ifdef _DEBUG
+			OutputDebugString("WriteContactSetting() got a > 255 setting name length. \n");
+		#endif
+		return 1;
+	}
+	if ( moduleNameLen > 0xFE )
+	{
+		#ifdef _DEBUG
+			OutputDebugString("WriteContactSetting() got a > 255 module name length. \n");
+		#endif
+		return 1;
+	}
+
+	// the db can not tolerate strings/blobs longer than 0xFFFF since the format writes 2 lengths
+	switch( dbcws->value.type ) {
+	case DBVT_ASCIIZ:		case DBVT_BLOB:	case DBVT_UTF8:
+		{	int len = ( dbcws->value.type != DBVT_BLOB ) ? strlen(dbcws->value.pszVal) : dbcws->value.cpbVal;
+			if ( len >= 0xFFFF ) {
+				#ifdef _DEBUG
+					OutputDebugString("WriteContactSetting() writing huge string/blob, rejecting ( >= 0xFFFF ) \n");
+				#endif
+				return 1;
+			}
+		}
+	}
+
+	EnterCriticalSection(&csDbAccess);
+	{
+		char* szCachedSettingName = GetCachedSetting(dbcws->szModule, dbcws->szSetting, settingNameLen);
+		if ( dbcws->value.type != DBVT_BLOB ) {
+			DBVARIANT* pCachedValue = GetCachedValuePtr((HANDLE)wParam, szCachedSettingName, 1);
+			if ( pCachedValue != NULL ) {
+				BOOL bIsIdentical = FALSE;
+				if ( pCachedValue->type == dbcws->value.type ) {
+					switch(dbcws->value.type) {
+						case DBVT_BYTE:   bIsIdentical = pCachedValue->bVal == dbcws->value.bVal;  break;
+						case DBVT_WORD:   bIsIdentical = pCachedValue->wVal == dbcws->value.wVal;  break;
+						case DBVT_DWORD:  bIsIdentical = pCachedValue->dVal == dbcws->value.dVal;  break;
+						case DBVT_UTF8:
+						case DBVT_ASCIIZ: bIsIdentical = strcmp( pCachedValue->pszVal, dbcws->value.pszVal ) == 0; break;
+					}
+					if ( bIsIdentical ) {
+						LeaveCriticalSection(&csDbAccess);
+						return 0;
+					}
+				}
+				SetCachedVariant(&dbcws->value, pCachedValue);
+			}
+			if ( szCachedSettingName[-1] != 0 ) {
+				LeaveCriticalSection(&csDbAccess);
+				NotifyEventHooks(hSettingChangeEvent,wParam,lParam);
+				return 0;
+			}
+		}
+		else GetCachedValuePtr((HANDLE)wParam, szCachedSettingName, -1);
+	}
+
+	ofsModuleName=GetModuleNameOfs(dbcws->szModule);
+ 	if(wParam==0) ofsContact=dbHeader.ofsUser;
+	else ofsContact=wParam;
+
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	if(dbc.signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	log0("write setting");
+	//make sure the module group exists
+	ofsSettingsGroup=GetSettingsGroupOfsByModuleNameOfs(&dbc,ofsContact,ofsModuleName);
+	if(ofsSettingsGroup==0) {  //module group didn't exist - make it
+		if(dbcws->value.type&DBVTF_VARIABLELENGTH) {
+		  if(dbcws->value.type==DBVT_ASCIIZ || dbcws->value.type==DBVT_UTF8) bytesRequired=strlen(dbcws->value.pszVal)+2;
+		  else if(dbcws->value.type==DBVT_BLOB) bytesRequired=dbcws->value.cpbVal+2;
+		}
+		else bytesRequired=dbcws->value.type;
+		bytesRequired+=2+settingNameLen;
+		bytesRequired+=(DB_SETTINGS_RESIZE_GRANULARITY-(bytesRequired%DB_SETTINGS_RESIZE_GRANULARITY))%DB_SETTINGS_RESIZE_GRANULARITY;
+		ofsSettingsGroup=CreateNewSpace(bytesRequired+offsetof(struct DBContactSettings,blob));
+		dbcs.signature=DBCONTACTSETTINGS_SIGNATURE;
+		dbcs.ofsNext=dbc.ofsFirstSettings;
+		dbcs.ofsModuleName=ofsModuleName;
+		dbcs.cbBlob=bytesRequired;
+		dbcs.blob[0]=0;
+		dbc.ofsFirstSettings=ofsSettingsGroup;
+		DBWrite(ofsContact,&dbc,sizeof(struct DBContact));
+		DBWrite(ofsSettingsGroup,&dbcs,sizeof(struct DBContactSettings));
+		ofsBlobPtr=ofsSettingsGroup+offsetof(struct DBContactSettings,blob);
+		pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+	}
+	else {
+		dbcs=*(struct DBContactSettings*)DBRead(ofsSettingsGroup,sizeof(struct DBContactSettings),&bytesRemaining);
+		//find if the setting exists
+		ofsBlobPtr=ofsSettingsGroup+offsetof(struct DBContactSettings,blob);
+		pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+		while(pBlob[0]) {
+			NeedBytes(settingNameLen+1);
+			if(pBlob[0]==settingNameLen && !memcmp(pBlob+1,dbcws->szSetting,settingNameLen))
+				break;
+			NeedBytes(1);
+			MoveAlong(pBlob[0]+1);
+			NeedBytes(3);
+			MoveAlong(1+GetSettingValueLength(pBlob));
+			NeedBytes(1);
+		}
+		if(pBlob[0]) {	 //setting already existed, and up to end of name is in cache
+			MoveAlong(1+settingNameLen);
+			//if different type or variable length and length is different
+			NeedBytes(3);
+			if(pBlob[0]!=dbcws->value.type || ((pBlob[0]==DBVT_ASCIIZ || pBlob[0]==DBVT_UTF8) && *(PWORD)(pBlob+1)!=strlen(dbcws->value.pszVal)) || (pBlob[0]==DBVT_BLOB && *(PWORD)(pBlob+1)!=dbcws->value.cpbVal)) {
+				//bin it
+				int nameLen,valLen;
+				DWORD ofsSettingToCut;
+				NeedBytes(3);
+				nameLen=1+settingNameLen;
+				valLen=1+GetSettingValueLength(pBlob);
+				ofsSettingToCut=ofsBlobPtr-nameLen;
+				MoveAlong(valLen);
+				NeedBytes(1);
+				while(pBlob[0]) {
+					MoveAlong(pBlob[0]+1);
+					NeedBytes(3);
+					MoveAlong(1+GetSettingValueLength(pBlob));
+					NeedBytes(1);
+				}
+				DBMoveChunk(ofsSettingToCut,ofsSettingToCut+nameLen+valLen,ofsBlobPtr+1-ofsSettingToCut);
+				ofsBlobPtr-=nameLen+valLen;
+				pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+			}
+			else {
+				//replace existing setting at pBlob
+				MoveAlong(1);	//skip data type
+				switch(dbcws->value.type) {
+					case DBVT_BYTE: DBWrite(ofsBlobPtr,&dbcws->value.bVal,1); break;
+					case DBVT_WORD: DBWrite(ofsBlobPtr,&dbcws->value.wVal,2); break;
+					case DBVT_DWORD: DBWrite(ofsBlobPtr,&dbcws->value.dVal,4); break;
+					case DBVT_UTF8:
+					case DBVT_ASCIIZ: DBWrite(ofsBlobPtr+2,dbcws->value.pszVal,strlen(dbcws->value.pszVal)); break;
+					case DBVT_BLOB: DBWrite(ofsBlobPtr+2,dbcws->value.pbVal,dbcws->value.cpbVal); break;
+				}
+				//quit
+				DBFlush(1);
+				LeaveCriticalSection(&csDbAccess);
+				//notify
+				NotifyEventHooks(hSettingChangeEvent,wParam,lParam);
+				return 0;
+			}
+		}
+	}
+	//cannot do a simple replace, add setting to end of list
+	//pBlob already points to end of list
+	//see if it fits
+	if(dbcws->value.type&DBVTF_VARIABLELENGTH) {
+	  if(dbcws->value.type==DBVT_ASCIIZ || dbcws->value.type==DBVT_UTF8) bytesRequired=strlen(dbcws->value.pszVal)+2;
+	  else if(dbcws->value.type==DBVT_BLOB) bytesRequired=dbcws->value.cpbVal+2;
+	}
+	else bytesRequired=dbcws->value.type;
+	bytesRequired+=2+settingNameLen;
+	bytesRequired+=ofsBlobPtr+1-(ofsSettingsGroup+offsetof(struct DBContactSettings,blob));
+	if((DWORD)bytesRequired>dbcs.cbBlob) {
+		//doesn't fit: move entire group
+		struct DBContactSettings *dbcsPrev;
+		DWORD ofsDbcsPrev,oldSize,ofsNew;
+
+		InvalidateSettingsGroupOfsCacheEntry(ofsSettingsGroup);
+		bytesRequired+=(DB_SETTINGS_RESIZE_GRANULARITY-(bytesRequired%DB_SETTINGS_RESIZE_GRANULARITY))%DB_SETTINGS_RESIZE_GRANULARITY;
+		//find previous group to change its offset
+		ofsDbcsPrev=dbc.ofsFirstSettings;
+		if(ofsDbcsPrev==ofsSettingsGroup) ofsDbcsPrev=0;
+		else {
+			dbcsPrev=(struct DBContactSettings*)DBRead(ofsDbcsPrev,sizeof(struct DBContactSettings),NULL);
+			while(dbcsPrev->ofsNext!=ofsSettingsGroup) {
+				if(dbcsPrev->ofsNext==0) DatabaseCorruption();
+				ofsDbcsPrev=dbcsPrev->ofsNext;
+				dbcsPrev=(struct DBContactSettings*)DBRead(ofsDbcsPrev,sizeof(struct DBContactSettings),NULL);
+			}
+		}
+		//create the new one
+		ofsNew=CreateNewSpace(bytesRequired+offsetof(struct DBContactSettings,blob));
+		//copy across
+		DBMoveChunk(ofsNew,ofsSettingsGroup,bytesRequired+offsetof(struct DBContactSettings,blob));
+		oldSize=dbcs.cbBlob;
+		dbcs.cbBlob=bytesRequired;
+		DBWrite(ofsNew,&dbcs,offsetof(struct DBContactSettings,blob));
+		if(ofsDbcsPrev==0) {
+			dbc.ofsFirstSettings=ofsNew;
+			DBWrite(ofsContact,&dbc,sizeof(struct DBContact));
+		}
+		else {
+			dbcsPrev=(struct DBContactSettings*)DBRead(ofsDbcsPrev,sizeof(struct DBContactSettings),NULL);
+			dbcsPrev->ofsNext=ofsNew;
+			DBWrite(ofsDbcsPrev,dbcsPrev,offsetof(struct DBContactSettings,blob));
+		}
+		DeleteSpace(ofsSettingsGroup,oldSize+offsetof(struct DBContactSettings,blob));
+		ofsBlobPtr+=ofsNew-ofsSettingsGroup;
+		ofsSettingsGroup=ofsNew;
+		pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+	}
+	//we now have a place to put it and enough space: make it
+	DBWrite(ofsBlobPtr,&settingNameLen,1);
+	DBWrite(ofsBlobPtr+1,(PVOID)dbcws->szSetting,settingNameLen);
+	MoveAlong(1+settingNameLen);
+	DBWrite(ofsBlobPtr,&dbcws->value.type,1);
+	MoveAlong(1);
+	switch(dbcws->value.type) {
+		case DBVT_BYTE: DBWrite(ofsBlobPtr,&dbcws->value.bVal,1); MoveAlong(1); break;
+		case DBVT_WORD: DBWrite(ofsBlobPtr,&dbcws->value.wVal,2); MoveAlong(2); break;
+		case DBVT_DWORD: DBWrite(ofsBlobPtr,&dbcws->value.dVal,4); MoveAlong(4); break;
+		case DBVT_UTF8:
+		case DBVT_ASCIIZ:
+			{	int len=strlen(dbcws->value.pszVal);
+				DBWrite(ofsBlobPtr,&len,2);
+				DBWrite(ofsBlobPtr+2,dbcws->value.pszVal,len);
+				MoveAlong(2+len);
+			}
+			break;
+		case DBVT_BLOB:
+			DBWrite(ofsBlobPtr,&dbcws->value.cpbVal,2);
+			DBWrite(ofsBlobPtr+2,dbcws->value.pbVal,dbcws->value.cpbVal);
+			MoveAlong(2+dbcws->value.cpbVal);
+			break;
+	}
+	{	BYTE zero=0;
+		DBWrite(ofsBlobPtr,&zero,1);
+	}
+	//quit
+	DBFlush(1);
+	LeaveCriticalSection(&csDbAccess);
+	//notify
+	NotifyEventHooks(hSettingChangeEvent,wParam,lParam);
+	return 0;
+}
+
+static int DeleteContactSetting(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTGETSETTING *dbcgs=(DBCONTACTGETSETTING*)lParam;
+	struct DBContact *dbc;
+	DWORD ofsModuleName,ofsSettingsGroup,ofsBlobPtr;
+	struct DBContactSettings dbcs;
+	PBYTE pBlob;
+	int settingNameLen=strlen(dbcgs->szSetting),bytesRemaining;
+	char* szCachedSettingName;
+	WPARAM saveWparam = wParam;
+
+	if ((!dbcgs->szModule) || (!dbcgs->szSetting))
+		return 1;
+
+	EnterCriticalSection(&csDbAccess);
+	ofsModuleName=GetModuleNameOfs(dbcgs->szModule);
+ 	if(wParam==0) wParam=dbHeader.ofsUser;
+
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	//make sure the module group exists
+	ofsSettingsGroup=GetSettingsGroupOfsByModuleNameOfs(dbc,wParam,ofsModuleName);
+	if(ofsSettingsGroup==0) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	dbc=(struct DBContact*)DBRead(wParam,sizeof(struct DBContact),NULL);
+	if(dbc->signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	ofsSettingsGroup=GetSettingsGroupOfsByModuleNameOfs(dbc,wParam,ofsModuleName);
+	if(ofsSettingsGroup==0) {
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	dbcs=*(struct DBContactSettings*)DBRead(ofsSettingsGroup,sizeof(struct DBContactSettings),NULL);
+	//find if the setting exists
+	ofsBlobPtr=ofsSettingsGroup+offsetof(struct DBContactSettings,blob);
+	pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+	while(pBlob[0]) {
+		NeedBytes(settingNameLen+1);
+		if(pBlob[0]==settingNameLen && !memcmp(pBlob+1,dbcgs->szSetting,settingNameLen))
+			break;
+		NeedBytes(1);
+		MoveAlong(pBlob[0]+1);
+		NeedBytes(3);
+		MoveAlong(1+GetSettingValueLength(pBlob));
+		NeedBytes(1);
+	}
+	if(!pBlob[0]) {     //setting didn't exist
+		LeaveCriticalSection(&csDbAccess);
+		return 1;
+	}
+	{	//bin it
+		int nameLen,valLen;
+		DWORD ofsSettingToCut;
+		MoveAlong(1+settingNameLen);
+		NeedBytes(3);
+		nameLen=1+settingNameLen;
+		valLen=1+GetSettingValueLength(pBlob);
+		ofsSettingToCut=ofsBlobPtr-nameLen;
+		MoveAlong(valLen);
+		NeedBytes(1);
+		while(pBlob[0]) {
+			MoveAlong(pBlob[0]+1);
+			NeedBytes(3);
+			MoveAlong(1+GetSettingValueLength(pBlob));
+			NeedBytes(1);
+		}
+		DBMoveChunk(ofsSettingToCut,ofsSettingToCut+nameLen+valLen,ofsBlobPtr+1-ofsSettingToCut);
+	}
+
+	szCachedSettingName = GetCachedSetting(dbcgs->szModule,dbcgs->szSetting,settingNameLen);
+	GetCachedValuePtr((HANDLE)saveWparam, szCachedSettingName, -1 );
+
+	//quit
+	DBFlush(1);
+	LeaveCriticalSection(&csDbAccess);
+	{	//notify
+		DBCONTACTWRITESETTING dbcws;
+		dbcws.szModule=dbcgs->szModule;
+		dbcws.szSetting=dbcgs->szSetting;
+		dbcws.value.type=DBVT_DELETED;
+		NotifyEventHooks(hSettingChangeEvent,saveWparam,(LPARAM)&dbcws);
+	}
+	return 0;
+}
+
+static int EnumContactSettings(WPARAM wParam,LPARAM lParam)
+{
+	DBCONTACTENUMSETTINGS *dbces=(DBCONTACTENUMSETTINGS*)lParam;
+	struct DBContact dbc;
+	struct DBContactSettings dbcs;
+	DWORD ofsModuleName,ofsContact,ofsBlobPtr;
+	int bytesRemaining, result;
+	PBYTE pBlob;
+	char szSetting[256];
+
+	if (!dbces->szModule)
+		return -1;
+
+	EnterCriticalSection(&csDbAccess);
+
+	ofsModuleName=GetModuleNameOfs(dbces->szModule);
+	if(wParam==0) ofsContact=dbHeader.ofsUser;
+	else ofsContact=wParam;
+	dbc=*(struct DBContact*)DBRead(ofsContact,sizeof(struct DBContact),NULL);
+	if(dbc.signature!=DBCONTACT_SIGNATURE) {
+		LeaveCriticalSection(&csDbAccess);
+		return -1;
+	}
+	dbces->ofsSettings=GetSettingsGroupOfsByModuleNameOfs(&dbc,ofsContact,ofsModuleName);
+	if(!dbces->ofsSettings) {
+		LeaveCriticalSection(&csDbAccess);
+		return -1;
+	}
+	dbcs=*(struct DBContactSettings*)DBRead(dbces->ofsSettings,sizeof(struct DBContactSettings),&bytesRemaining);
+	ofsBlobPtr=dbces->ofsSettings+offsetof(struct DBContactSettings,blob);
+	pBlob=(PBYTE)DBRead(ofsBlobPtr,1,&bytesRemaining);
+	if(pBlob[0]==0) {
+		LeaveCriticalSection(&csDbAccess);
+		return -1;
+	}
+	result = 0;
+	while(pBlob[0]) {
+		NeedBytes(1);
+		NeedBytes(1+pBlob[0]);
+		CopyMemory(szSetting,pBlob+1,pBlob[0]); szSetting[pBlob[0]]=0;
+		result = (dbces->pfnEnumProc)(szSetting,dbces->lParam);
+		MoveAlong(1+pBlob[0]);
+		NeedBytes(3);
+		MoveAlong(1+GetSettingValueLength(pBlob));
+		NeedBytes(1);
+	}
+	LeaveCriticalSection(&csDbAccess);
+	return result;
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+//
+//   Module initialization procedure
+
+static int stringCompare( DBCachedSettingName* p1, DBCachedSettingName* p2 )
+{
+	return strcmp( p1->name, p2->name );
+}
+
+static int stringCompare2( DBCachedGlobalValue* p1, DBCachedGlobalValue* p2 )
+{
+	return strcmp( p1->name, p2->name );
+}
+
+static int handleCompare( void* p1, void* p2 )
+{
+	if ( *( long* )p1 == *( long* )p2 )
+		return 0;
+
+	return *( long* )p1 - *( long* )p2;
+}
+
+int InitSettings(void)
+{
+	CreateServiceFunction(MS_DB_CONTACT_GETSETTING,GetContactSetting);
+	CreateServiceFunction(MS_DB_CONTACT_GETSETTING_STR,GetContactSettingStr);
+	CreateServiceFunction(MS_DB_CONTACT_GETSETTINGSTATIC,GetContactSettingStatic);
+	CreateServiceFunction(MS_DB_CONTACT_FREEVARIANT,FreeVariant);
+	CreateServiceFunction(MS_DB_CONTACT_WRITESETTING,WriteContactSetting);
+	CreateServiceFunction(MS_DB_CONTACT_DELETESETTING,DeleteContactSetting);
+	CreateServiceFunction(MS_DB_CONTACT_ENUMSETTINGS,EnumContactSettings);
+	CreateServiceFunction(MS_DB_SETSETTINGRESIDENT,SetSettingResident);
+	hSettingChangeEvent=CreateHookableEvent(ME_DB_CONTACT_SETTINGCHANGED);
+
+	hCacheHeap=HeapCreate(HEAP_NO_SERIALIZE,0,0);
+	lSettings.sortFunc=stringCompare;
+	lSettings.increment=50;
+	lContacts.sortFunc=handleCompare;
+	lContacts.increment=100;
+	lGlobalSettings.sortFunc=stringCompare2;
+	lGlobalSettings.increment=100;
+	return 0;
+}
+
+void UninitSettings(void)
+{
+	HeapDestroy(hCacheHeap);
+	li.List_Destroy(&lContacts);
+	li.List_Destroy(&lSettings);
+	li.List_Destroy(&lGlobalSettings);
+}
diff --git a/miranda-wine/plugins/db3x/dbtime.c b/miranda-wine/plugins/db3x/dbtime.c
new file mode 100644
index 0000000..e9189b9
--- /dev/null
+++ b/miranda-wine/plugins/db3x/dbtime.c
@@ -0,0 +1,163 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+static int daysInMonth[12]={31,28,31,30,31,30,31,31,30,31,30,31};
+static int IsLeapYear(int year)
+{
+	if(year&3) return 0;
+	if(year%100) return 1;
+	if(year%400) return 0;
+	return 1;
+}
+
+static int CompareSystemTimes(SYSTEMTIME *st,SYSTEMTIME *switchDate)
+{
+	FILETIME ft1,ft2;
+	
+	if(switchDate->wYear==0) {	   //strange day-in-month thing
+		SYSTEMTIME tempst;
+
+		//short-circuit if the months aren't the same
+		if(st->wMonth<switchDate->wMonth) return -1;
+		if(st->wMonth>switchDate->wMonth) return 1;
+		
+		tempst=*switchDate;
+		tempst.wYear=st->wYear;
+		tempst.wDay=1;
+		SystemTimeToFileTime(&tempst,&ft1);
+		FileTimeToSystemTime(&ft1,&tempst);	  //gets the day of week of the first of the month
+		tempst.wDay=1+(7+switchDate->wDayOfWeek-tempst.wDayOfWeek)%7;
+		if(switchDate->wDay==5) {	  //last wDayOfWeek in month
+			if(tempst.wMonth==2) {
+				if(IsLeapYear(tempst.wYear)) daysInMonth[1]=29;
+				else daysInMonth[1]=28;
+			}
+			tempst.wDay+=7*3;		//can't be less than 4 of that day in the month
+			if(tempst.wDay+7<=daysInMonth[switchDate->wMonth-1]) tempst.wDay+=7;
+		}
+		else tempst.wDay+=7*(switchDate->wDay-1);	//nth of month
+		SystemTimeToFileTime(&tempst,&ft2);
+	}
+	else {
+		switchDate->wYear=st->wYear;
+		SystemTimeToFileTime(switchDate,&ft2);
+	}
+	SystemTimeToFileTime(st,&ft1);
+	return CompareFileTime(&ft1,&ft2);
+}
+
+static int TimestampToLocal(WPARAM wParam,LPARAM lParam)
+{
+	TIME_ZONE_INFORMATION tzInfo;
+	LARGE_INTEGER liFiletime;
+	FILETIME filetime;
+	SYSTEMTIME st;
+
+	GetTimeZoneInformation(&tzInfo);
+	if(tzInfo.StandardDate.wMonth==0) {	 //no daylight savings time
+		return (int)(wParam-tzInfo.Bias*60);
+	}
+	//this huge number is the difference between 1970 and 1601 in seconds
+	liFiletime.QuadPart=(mir_i64(11644473600)+(__int64)wParam)*10000000;
+	filetime.dwHighDateTime=liFiletime.HighPart;
+	filetime.dwLowDateTime=liFiletime.LowPart;
+	FileTimeToSystemTime(&filetime,&st);
+	if(tzInfo.DaylightDate.wMonth<tzInfo.StandardDate.wMonth) {
+		//northern hemisphere
+		if(CompareSystemTimes(&st,&tzInfo.DaylightDate)<0 ||
+		   CompareSystemTimes(&st,&tzInfo.StandardDate)>0) {
+		    return (int)(wParam-(tzInfo.Bias+tzInfo.StandardBias)*60);
+		}
+	    return (int)(wParam-(tzInfo.Bias+tzInfo.DaylightBias)*60);
+	}
+	else {
+		//southern hemisphere
+		if(CompareSystemTimes(&st,&tzInfo.StandardDate)<0 ||
+		   CompareSystemTimes(&st,&tzInfo.DaylightDate)>0) {
+		    return (int)(wParam-(tzInfo.Bias+tzInfo.DaylightBias)*60);
+		}
+	    return (int)(wParam-(tzInfo.Bias+tzInfo.StandardBias)*60);
+	}
+	return 0;
+}
+
+static int TimestampToString(WPARAM wParam,LPARAM lParam)
+{
+	DBTIMETOSTRING *tts=(DBTIMETOSTRING*)lParam;
+	LARGE_INTEGER liFiletime;
+	FILETIME filetime;
+	SYSTEMTIME st;
+	char dateTimeStr[64];
+	char *pDest,*pFormat;
+	int destCharsLeft,dateTimeStrLen;
+
+	//this huge number is the difference between 1970 and 1601 in seconds
+	liFiletime.QuadPart=(mir_i64(11644473600)+(__int64)(DWORD)TimestampToLocal(wParam,0))*10000000;
+	filetime.dwHighDateTime=liFiletime.HighPart;
+	filetime.dwLowDateTime=liFiletime.LowPart;
+	FileTimeToSystemTime(&filetime,&st);
+	destCharsLeft=tts->cbDest;
+	for(pFormat=tts->szFormat,pDest=tts->szDest;*pFormat;pFormat++) {
+		switch(*pFormat) {
+			case 't':
+				GetTimeFormat(LOCALE_USER_DEFAULT,TIME_NOSECONDS,&st,NULL,dateTimeStr,sizeof(dateTimeStr));
+				break;
+			case 's':
+				GetTimeFormat(LOCALE_USER_DEFAULT,0,&st,NULL,dateTimeStr,sizeof(dateTimeStr));
+				break;
+			case 'm':
+				GetTimeFormat(LOCALE_USER_DEFAULT,TIME_NOMINUTESORSECONDS,&st,NULL,dateTimeStr,sizeof(dateTimeStr));
+				break;
+			case 'd':
+				GetDateFormat(LOCALE_USER_DEFAULT,DATE_SHORTDATE,&st,NULL,dateTimeStr,sizeof(dateTimeStr));
+				break;
+			case 'D':
+				GetDateFormat(LOCALE_USER_DEFAULT,DATE_LONGDATE,&st,NULL,dateTimeStr,sizeof(dateTimeStr));
+				break;
+			default:
+				if(destCharsLeft) {
+					*pDest++=*pFormat;
+					destCharsLeft--;
+				}
+				continue;
+		}
+		dateTimeStrLen=strlen(dateTimeStr);
+		if(destCharsLeft<dateTimeStrLen) dateTimeStrLen=destCharsLeft;
+		CopyMemory(pDest,dateTimeStr,dateTimeStrLen);
+		destCharsLeft-=dateTimeStrLen;
+		pDest+=dateTimeStrLen;
+	}
+	if(destCharsLeft) *pDest=0;
+	else tts->szDest[tts->cbDest-1]=0;
+	return 0;
+}
+
+int InitTime(void)
+{
+	CreateServiceFunction(MS_DB_TIME_TIMESTAMPTOLOCAL,TimestampToLocal);
+	CreateServiceFunction(MS_DB_TIME_TIMESTAMPTOSTRING,TimestampToString);
+	return 0;
+}
diff --git a/miranda-wine/plugins/db3x/encrypt.c b/miranda-wine/plugins/db3x/encrypt.c
new file mode 100644
index 0000000..1382a27
--- /dev/null
+++ b/miranda-wine/plugins/db3x/encrypt.c
@@ -0,0 +1,67 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+//VERY VERY VERY BASIC ENCRYPTION FUNCTION
+
+
+void Encrypt(char*msg,BOOL up)
+{
+	int i;
+	int jump;
+	if (up)
+	{
+		jump=5;
+	}
+	else
+	{
+		jump=-5;
+	}
+
+	for (i=0;msg[i];i++)
+	{
+			msg[i]=msg[i]+jump;
+	}
+
+}
+
+static int EncodeString(WPARAM wParam,LPARAM lParam)
+{
+	Encrypt((char*)lParam,TRUE);
+	return 0;
+}
+
+static int DecodeString(WPARAM wParam,LPARAM lParam)
+{
+	Encrypt((char*)lParam,FALSE);
+	return 0;
+}
+
+int InitCrypt(void)
+{
+	CreateServiceFunction(MS_DB_CRYPT_ENCODESTRING,EncodeString);
+	CreateServiceFunction(MS_DB_CRYPT_DECODESTRING,DecodeString);
+	return 0;
+}
diff --git a/miranda-wine/plugins/db3x/encryption.h b/miranda-wine/plugins/db3x/encryption.h
new file mode 100644
index 0000000..73c2d7e
--- /dev/null
+++ b/miranda-wine/plugins/db3x/encryption.h
@@ -0,0 +1,23 @@
+/*
+Miranda ICQ: the free icq client for MS Windows 
+Copyright (C) 2000-2  Richard Hughes, Roland Rabien & Tristan Van de Vreede
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+#ifndef MODULAR
+#include <windows.h>
+
+void Encrypt(char*msg,BOOL up);
+#endif 
+\ No newline at end of file
diff --git a/miranda-wine/plugins/db3x/init.c b/miranda-wine/plugins/db3x/init.c
new file mode 100644
index 0000000..91834ed
--- /dev/null
+++ b/miranda-wine/plugins/db3x/init.c
@@ -0,0 +1,193 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project,
+all portions of this codebase are copyrighted to the people
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+#include <m_plugins.h>
+
+struct MM_INTERFACE memoryManagerInterface;
+struct LIST_INTERFACE li;
+extern char szDbPath[MAX_PATH];
+
+HINSTANCE g_hInst=NULL;
+PLUGINLINK *pluginLink;
+
+static int getCapability( int flag )
+{
+	return 0;
+}
+
+// returns 0 if the profile is created, EMKPRF*
+static int makeDatabase(char * profile, int * error)
+{
+	HANDLE hFile=CreateFile(profile, GENERIC_READ|GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL);
+	if ( hFile != INVALID_HANDLE_VALUE ) {
+		CreateDbHeaders(hFile);
+		CloseHandle(hFile);
+		return 0;
+	}
+	if ( error != NULL ) *error=EMKPRF_CREATEFAILED;
+	return 1;
+}
+
+// returns 0 if the given profile has a valid header
+static int grokHeader( char * profile, int * error )
+{
+	int rc=1;
+	int chk=0;
+	struct DBHeader hdr;
+	HANDLE hFile = INVALID_HANDLE_VALUE;
+	DWORD dummy=0;
+
+	hFile = CreateFile(profile, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL);
+	if ( hFile == INVALID_HANDLE_VALUE ) {
+		if ( error != NULL ) *error=EGROKPRF_CANTREAD;
+		return 1;
+	}
+	// read the header, which can fail (for various reasons)
+	if ( !ReadFile(hFile, &hdr, sizeof(struct DBHeader), &dummy, NULL) ) {
+		if ( error != NULL) *error=EGROKPRF_CANTREAD;
+		CloseHandle(hFile);
+		return 1;
+	}
+	chk=CheckDbHeaders(&hdr);
+	if ( chk == 0 ) {
+		// all the internal tests passed, hurrah
+		rc=0;
+		if ( error != NULL ) *error=0;
+	} else {
+		// didn't pass at all, or some did.
+		switch ( chk ) {
+			case 1:
+			{
+				// "Miranda ICQ DB" wasn't present
+				if ( error != NULL ) *error = EGROKPRF_UNKHEADER;
+				break;
+			}
+			case 2:
+			{
+				// header was present, but version information newer
+				if ( error != NULL ) *error= EGROKPRF_VERNEWER;
+				break;
+			}
+			case 3:
+			{
+				// header/version OK, internal data missing
+				if ( error != NULL ) *error=EGROKPRF_DAMAGED;
+				break;
+			}
+		} // switch
+	} //if
+	CloseHandle(hFile);
+	return rc;
+}
+
+// returns 0 if all the APIs are injected otherwise, 1
+static int LoadDatabase( char * profile, void * plink )
+{
+	PLUGINLINK *link = plink;
+#ifdef _DEBUG
+	_CrtSetDbgFlag( _CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF);
+#endif
+	// don't need thread notifications
+	strncpy(szDbPath, profile, sizeof(szDbPath));
+	// this is like Load()'s pluginLink
+	pluginLink=link;
+	// set the memory manager
+	memoryManagerInterface.cbSize=sizeof(struct MM_INTERFACE);
+	CallService(MS_SYSTEM_GET_MMI,0,(LPARAM)&memoryManagerInterface);
+	// set the lists manager;
+	li.cbSize = sizeof( li );
+	if ( CallService(MS_SYSTEM_GET_LI,0,(LPARAM)&li) == CALLSERVICE_NOTFOUND ) {
+		MessageBoxA( NULL, "This version of plugin requires Miranda IM 0.5 or later", "Fatal error", MB_OK );
+		return 1;
+	}
+
+	// inject all APIs and hooks into the core
+	return LoadDatabaseModule();
+}
+
+static int UnloadDatabase(int wasLoaded)
+{
+	if ( !wasLoaded) return 0;
+	UnloadDatabaseModule();
+	return 0;
+}
+
+static int getFriendlyName( char * buf, size_t cch, int shortName )
+{
+	strncpy(buf,shortName ? "db3x driver" : "db3x database support",cch);
+	return 0;
+}
+
+
+static DATABASELINK dblink = {
+	sizeof(DATABASELINK),
+	getCapability,
+	getFriendlyName,
+	makeDatabase,
+	grokHeader,
+	LoadDatabase,
+	UnloadDatabase,
+};
+
+static PLUGININFO pluginInfo = {
+	sizeof(PLUGININFO),
+	"Miranda database driver",
+	PLUGIN_MAKE_VERSION(0,6,0,0),
+	"Provides Miranda database support: global settings, contacts, history, settings per contact.",
+	"Miranda-IM project",
+	"ghazan@miranda-im.org",
+	"Copyright 2000-2006 Miranda IM project",
+	"",
+	0,
+	DEFMOD_DB
+};
+
+
+BOOL WINAPI DllMain(HINSTANCE hInstDLL, DWORD dwReason, LPVOID reserved)
+{
+	g_hInst=hInstDLL;
+	return TRUE;
+}
+
+__declspec(dllexport) DATABASELINK* DatabasePluginInfo(void * reserved)
+{
+	return &dblink;
+}
+
+__declspec(dllexport) PLUGININFO * MirandaPluginInfo(DWORD mirandaVersion)
+{
+	if ( mirandaVersion < PLUGIN_MAKE_VERSION(0,4,0,0) ) return NULL;
+	return &pluginInfo;
+}
+
+int __declspec(dllexport) Load(PLUGINLINK * link)
+{
+	return 1;
+}
+
+int __declspec(dllexport) Unload(void)
+{
+	return 0;
+}
diff --git a/miranda-wine/plugins/db3x/resource.h b/miranda-wine/plugins/db3x/resource.h
new file mode 100644
index 0000000..96abbff
--- /dev/null
+++ b/miranda-wine/plugins/db3x/resource.h
@@ -0,0 +1,30 @@
+//{{NO_DEPENDENCIES}}
+// Microsoft Developer Studio generated include file.
+// Used by resource.rc
+//
+#define IDC_NOTOALL                     3
+#define IDD_INSTALLINI                  235
+#define IDD_WARNINICHANGE               236
+#define IDD_INIIMPORTDONE               237
+#define IDC_ININAME                     1333
+#define IDC_VIEWINI                     1334
+#define IDC_SECURITYINFO                1335
+#define IDC_SETTINGNAME                 1336
+#define IDC_NEWVALUE                    1337
+#define IDC_WARNNOMORE                  1338
+#define IDC_DELETE                      1339
+#define IDC_RECYCLE                     1340
+#define IDC_NEWNAME                     1341
+#define IDC_MOVE                        1342
+#define IDC_LEAVE                       1343
+
+// Next default values for new objects
+// 
+#ifdef APSTUDIO_INVOKED
+#ifndef APSTUDIO_READONLY_SYMBOLS
+#define _APS_NEXT_RESOURCE_VALUE        269
+#define _APS_NEXT_COMMAND_VALUE         40018
+#define _APS_NEXT_CONTROL_VALUE         1657
+#define _APS_NEXT_SYMED_VALUE           101
+#endif
+#endif
diff --git a/miranda-wine/plugins/db3x/resource.rc b/miranda-wine/plugins/db3x/resource.rc
new file mode 100644
index 0000000..daa99f3
--- /dev/null
+++ b/miranda-wine/plugins/db3x/resource.rc
@@ -0,0 +1,169 @@
+//Microsoft Developer Studio generated resource script.
+//
+#include "resource.h"
+
+#define APSTUDIO_READONLY_SYMBOLS
+/////////////////////////////////////////////////////////////////////////////
+//
+// Generated from the TEXTINCLUDE 2 resource.
+//
+#include <winres.h>
+/////////////////////////////////////////////////////////////////////////////
+#undef APSTUDIO_READONLY_SYMBOLS
+
+/////////////////////////////////////////////////////////////////////////////
+// English (U.S.) resources
+
+#if !defined(AFX_RESOURCE_DLL) || defined(AFX_TARG_ENU)
+#ifdef _WIN32
+LANGUAGE LANG_ENGLISH, SUBLANG_ENGLISH_US
+#pragma code_page(1252)
+#endif //_WIN32
+
+/////////////////////////////////////////////////////////////////////////////
+//
+// Dialog
+//
+
+IDD_INSTALLINI DIALOGEX 0, 0, 212, 102
+STYLE DS_MODALFRAME | DS_SETFOREGROUND | DS_3DLOOK | DS_FIXEDSYS | DS_CENTER | 
+    WS_POPUP | WS_VISIBLE | WS_CAPTION | WS_SYSMENU
+EXSTYLE WS_EX_CONTROLPARENT
+CAPTION "Install Database Settings"
+FONT 8, "MS Shell Dlg", 0, 0, 0x1
+BEGIN
+    DEFPUSHBUTTON   "Yes",IDOK,26,83,50,14
+    PUSHBUTTON      "No",IDCANCEL,81,83,50,14
+    LTEXT           "A file containing new database settings has been placed in the Miranda IM directory.",
+                    IDC_STATIC,5,5,202,16
+    LTEXT           "Do you want to import the settings now?",IDC_STATIC,5,
+                    69,202,8
+    PUSHBUTTON      "No to all",IDC_NOTOALL,136,83,50,14
+    LTEXT           "",IDC_ININAME,5,24,143,16,SS_NOPREFIX | SS_CENTERIMAGE
+    PUSHBUTTON      "&View contents",IDC_VIEWINI,149,25,58,14
+    LTEXT           "Security systems to prevent malicious changes are in place and you will be warned before changes that are not known to be safe.",
+                    IDC_SECURITYINFO,5,43,202,24
+END
+
+IDD_WARNINICHANGE DIALOGEX 0, 0, 187, 113
+STYLE DS_MODALFRAME | DS_SETFOREGROUND | DS_3DLOOK | DS_FIXEDSYS | DS_CENTER | 
+    WS_POPUP | WS_VISIBLE | WS_CAPTION | WS_SYSMENU
+EXSTYLE WS_EX_CONTROLPARENT
+CAPTION "Database Setting Change"
+FONT 8, "MS Shell Dlg", 0, 0, 0x1
+BEGIN
+    LTEXT           "Database settings are being imported from",IDC_STATIC,5,
+                    5,177,8
+    CONTROL         "",IDC_ININAME,"Static",SS_SIMPLE | SS_NOPREFIX |
+                    WS_GROUP,5,13,177,8
+    LTEXT           "This file wishes to change the setting",IDC_STATIC,5,24,
+                    177,8
+    CONTROL         "",IDC_SETTINGNAME,"Static",SS_SIMPLE | SS_NOPREFIX |
+                    WS_GROUP,12,33,170,8
+    LTEXT           "to the value",IDC_STATIC,5,42,177,8
+    CONTROL         "",IDC_NEWVALUE,"Static",SS_SIMPLE | SS_NOPREFIX |
+                    WS_GROUP,12,51,170,8
+    LTEXT           "",IDC_SECURITYINFO,5,60,177,8
+    LTEXT           "Do you want to allow this change?",IDC_STATIC,5,71,177,
+                    8
+    CONTROL         "&Allow all further changes to this section",
+                    IDC_WARNNOMORE,"Button",BS_AUTOCHECKBOX | WS_TABSTOP,13,
+                    80,169,10
+    DEFPUSHBUTTON   "&Yes",IDYES,5,94,50,14
+    PUSHBUTTON      "&No",IDNO,59,94,50,14
+    PUSHBUTTON      "Cancel Import",IDCANCEL,123,94,59,14
+END
+
+IDD_INIIMPORTDONE DIALOGEX 0, 0, 186, 73
+STYLE DS_MODALFRAME | DS_SETFOREGROUND | DS_3DLOOK | DS_FIXEDSYS | DS_CENTER | 
+    WS_POPUP | WS_VISIBLE | WS_CAPTION | WS_SYSMENU
+EXSTYLE WS_EX_CONTROLPARENT
+CAPTION "Database Import Complete"
+FONT 8, "MS Shell Dlg", 0, 0, 0x1
+BEGIN
+    LTEXT           "The import has completed from",IDC_STATIC,5,5,176,8
+    CONTROL         "",IDC_ININAME,"Static",SS_SIMPLE | SS_NOPREFIX |
+                    WS_GROUP,5,13,176,8
+    LTEXT           "What do you want to do with the file now?",IDC_STATIC,5,
+                    24,176,8
+    PUSHBUTTON      "&Recycle",IDC_RECYCLE,5,36,50,14
+    PUSHBUTTON      "&Delete",IDC_DELETE,68,36,50,14
+    EDITTEXT        IDC_NEWNAME,5,55,117,12,ES_AUTOHSCROLL
+    PUSHBUTTON      "&Move/Rename",IDC_MOVE,124,54,57,14
+    PUSHBUTTON      "&Leave",IDC_LEAVE,131,36,50,14
+END
+
+
+/////////////////////////////////////////////////////////////////////////////
+//
+// DESIGNINFO
+//
+
+#ifdef APSTUDIO_INVOKED
+GUIDELINES DESIGNINFO DISCARDABLE 
+BEGIN
+    IDD_INSTALLINI, DIALOG
+    BEGIN
+        LEFTMARGIN, 5
+        RIGHTMARGIN, 207
+        TOPMARGIN, 5
+        BOTTOMMARGIN, 97
+    END
+
+    IDD_WARNINICHANGE, DIALOG
+    BEGIN
+        LEFTMARGIN, 5
+        RIGHTMARGIN, 182
+        TOPMARGIN, 5
+        BOTTOMMARGIN, 108
+    END
+
+    IDD_INIIMPORTDONE, DIALOG
+    BEGIN
+        LEFTMARGIN, 5
+        RIGHTMARGIN, 181
+        TOPMARGIN, 5
+        BOTTOMMARGIN, 68
+    END
+END
+#endif    // APSTUDIO_INVOKED
+
+
+#ifdef APSTUDIO_INVOKED
+/////////////////////////////////////////////////////////////////////////////
+//
+// TEXTINCLUDE
+//
+
+1 TEXTINCLUDE DISCARDABLE 
+BEGIN
+    "resource.h\0"
+END
+
+2 TEXTINCLUDE DISCARDABLE 
+BEGIN
+    "#include <winres.h>\0"
+END
+
+3 TEXTINCLUDE DISCARDABLE 
+BEGIN
+    "\r\n"
+    "\0"
+END
+
+#endif    // APSTUDIO_INVOKED
+
+#endif    // English (U.S.) resources
+/////////////////////////////////////////////////////////////////////////////
+
+
+
+#ifndef APSTUDIO_INVOKED
+/////////////////////////////////////////////////////////////////////////////
+//
+// Generated from the TEXTINCLUDE 3 resource.
+//
+
+
+/////////////////////////////////////////////////////////////////////////////
+#endif    // not APSTUDIO_INVOKED
diff --git a/miranda-wine/plugins/db3x/utf.c b/miranda-wine/plugins/db3x/utf.c
new file mode 100644
index 0000000..52064a6
--- /dev/null
+++ b/miranda-wine/plugins/db3x/utf.c
@@ -0,0 +1,166 @@
+/*
+
+Miranda IM: the free IM client for Microsoft* Windows*
+
+Copyright 2000-2003 Miranda ICQ/IM project, 
+all portions of this codebase are copyrighted to the people 
+listed in contributors.txt.
+
+This program 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
+of the License, or (at your option) any later version.
+
+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.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+*/
+
+#include "commonheaders.h"
+#include "database.h"
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// Utf8Decode - converts UTF8-encoded string to the UCS2/MBCS format
+
+void Utf8Decode( char* str, wchar_t** ucs2 )
+{
+	int len;
+	wchar_t* tempBuf;
+
+	if ( str == NULL )
+		return;
+
+	len = strlen( str );
+	if ( len < 2 ) {
+		if ( ucs2 != NULL ) {
+			*ucs2 = ( wchar_t* )mir_alloc(( len+1 )*sizeof( wchar_t ));
+			MultiByteToWideChar( CP_ACP, 0, str, len, *ucs2, len );
+			( *ucs2 )[ len ] = 0;
+		}
+		return;
+	}
+
+	tempBuf = ( wchar_t* )alloca(( len+1 )*sizeof( wchar_t ));
+	{
+		wchar_t* d = tempBuf;
+		BYTE* s = ( BYTE* )str;
+
+		while( *s )
+		{
+			if (( *s & 0x80 ) == 0 ) {
+				*d++ = *s++;
+				continue;
+			}
+
+			if (( s[0] & 0xE0 ) == 0xE0 && ( s[1] & 0xC0 ) == 0x80 && ( s[2] & 0xC0 ) == 0x80 ) {
+				*d++ = (( WORD )( s[0] & 0x0F) << 12 ) + ( WORD )(( s[1] & 0x3F ) << 6 ) + ( WORD )( s[2] & 0x3F );
+				s += 3;
+				continue;
+			}
+
+			if (( s[0] & 0xE0 ) == 0xC0 && ( s[1] & 0xC0 ) == 0x80 ) {
+				*d++ = ( WORD )(( s[0] & 0x1F ) << 6 ) + ( WORD )( s[1] & 0x3F );
+				s += 2;
+				continue;
+			}
+
+			*d++ = *s++;
+		}
+
+		*d = 0;
+	}
+
+	if ( ucs2 != NULL ) {
+		int fullLen = ( len+1 )*sizeof( wchar_t );
+		*ucs2 = ( wchar_t* )mir_alloc( fullLen );
+		memcpy( *ucs2, tempBuf, fullLen );
+	}
+
+   WideCharToMultiByte( CP_ACP, 0, tempBuf, -1, str, len, NULL, NULL );
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// Utf8Encode - converts MBCS string to the UTF8-encoded format
+
+char* Utf8Encode( const char* src )
+{
+	int len;
+	char* result;
+	wchar_t* tempBuf;
+
+	if ( src == NULL )
+		return NULL;
+
+	len = strlen( src );
+	result = ( char* )mir_alloc( len*3 + 1 );
+	if ( result == NULL )
+		return NULL;
+
+	tempBuf = ( wchar_t* )alloca(( len+1 )*sizeof( wchar_t ));
+	MultiByteToWideChar( CP_ACP, 0, src, -1, tempBuf, len );
+	tempBuf[ len ] = 0;
+	{
+		wchar_t* s = tempBuf;
+		BYTE*		d = ( BYTE* )result;
+
+		while( *s ) {
+			int U = *s++;
+
+			if ( U < 0x80 ) {
+				*d++ = ( BYTE )U;
+			}
+			else if ( U < 0x800 ) {
+				*d++ = 0xC0 + (( U >> 6 ) & 0x3F );
+				*d++ = 0x80 + ( U & 0x003F );
+			}
+			else {
+				*d++ = 0xE0 + ( U >> 12 );
+				*d++ = 0x80 + (( U >> 6 ) & 0x3F );
+				*d++ = 0x80 + ( U & 0x3F );
+		}	}
+
+		*d = 0;
+	}
+
+	return result;
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// Utf8Encode - converts UCS2 string to the UTF8-encoded format
+
+char* Utf8EncodeUcs2( const wchar_t* src )
+{
+	int len = wcslen( src );
+	char* result = ( char* )mir_alloc( len*3 + 1 );
+	if ( result == NULL )
+		return NULL;
+
+	{	const wchar_t* s = src;
+		BYTE*	d = ( BYTE* )result;
+
+		while( *s ) {
+			int U = *s++;
+
+			if ( U < 0x80 ) {
+				*d++ = ( BYTE )U;
+			}
+			else if ( U < 0x800 ) {
+				*d++ = 0xC0 + (( U >> 6 ) & 0x3F );
+				*d++ = 0x80 + ( U & 0x003F );
+			}
+			else {
+				*d++ = 0xE0 + ( U >> 12 );
+				*d++ = 0x80 + (( U >> 6 ) & 0x3F );
+				*d++ = 0x80 + ( U & 0x3F );
+		}	}
+
+		*d = 0;
+	}
+
+	return result;
+}