/* -----------------------------------------------------------------------------
*
*  npdbtypes.h
*
*  ANTz - realtime 3D data visualization tools for the real-world, based on NPE.
*
*  ANTz is hosted at http://openantz.com and NPE at http://neuralphysics.org
*
*  Written in 2010-2019 by Shane Saxon - saxon@openantz.com
*
*  Please see main.c for a complete list of additional code contributors.
*
*  To the extent possible under law, the author(s) have dedicated all copyright 
*  and related and neighboring rights to this software to the public domain
*  worldwide. This software is distributed without any warranty.
*
*  Released under the CC0 license, which is GPL compatible.
*
*  You should have received a copy of the CC0 Public Domain Dedication along
*  with this software (license file named LICENSE.txt). If not, see
*  http://creativecommons.org/publicdomain/zero/1.0/
*
* --------------------------------------------------------------------------- */

#ifndef NPDBTYPES_H_
#define NPDBTYPES_H_

#include "stdbool.h"


#ifdef WIN32
	#define NPDB_CALLCONV __stdcall
#else
	#define NPDB_CALLCONV
#endif

/*
#ifdef NP_OSX_
#define NPDB_CALLCONV
#endif
*/

#define	kNPurlMax			4096			///< maximum length of URL accepted
enum NP_DATABASE {
	kNPdbHostMax	= 512,		///< max number of DB host servers
	kNPdbMax		= 4096,		///< max number of databases
	kNPtblMax		= 128,		///< max number of tables, new lde
	kNPpwdMax		= 256,		///< max password length
	kNPuserNameMax	= 256,		///< max user name length
	kNPdbNameMax	= 64,		///< @todo make sure 64 is good for non-MySQL DBs
	kNPdbFuncSetMax	= 64		///< max number DB function sets
};

struct NPdbFunction{
	int			type;					///< function protype index
	void*		funcPtr;				///< pointer to the function
	
	char		name[kNPdbNameMax];		///< function UI name
	char*		desc;					///< function description
};
typedef struct NPdbFunction NPdbFunction;
typedef struct NPdbFunction *pNPdbFunction;

struct NPdbFuncSet{
	int			id;						///< the function set ID
	char		hostType[kNPdbNameMax];	///< content type, antz or 3rd party
	void*		dbLib;					///< library handle
	
	//pNPdbFunction*	funcList;
	//int				funcCount;
	///  abstract our database server type specific methods
	
	void* (NPDB_CALLCONV *init)			();
	void* (NPDB_CALLCONV *connect)		();
	int   (NPDB_CALLCONV *options)		();
	void* (NPDB_CALLCONV *ping)			();
	void* (NPDB_CALLCONV *close)		    ();
	
	void* (*show)			();
	void* (NPDB_CALLCONV *query)		    ();
	void* (NPDB_CALLCONV *store_result)	();
	void* (NPDB_CALLCONV *free_result)	();
	
	int   (*use)						();
	void* (NPDB_CALLCONV *select)		    ();
	void* (NPDB_CALLCONV *alter)		    ();
	void* (NPDB_CALLCONV *insert)		    ();
	void* (NPDB_CALLCONV *fetch_row)	    ();
	void* (NPDB_CALLCONV *fetch_lengths)  ();
	void* (NPDB_CALLCONV *num_fields)	    ();
	void* (NPDB_CALLCONV *num_rows)		();
	void* (NPDB_CALLCONV *db_error)		();
	void* (NPDB_CALLCONV *db_errno)		();
	void* (NPDB_CALLCONV *conn_thread_id) ();
    unsigned int (NPDB_CALLCONV *escape_string) ();
	
	///< error and errno use 'db_' prefix to prevent name conflict
	
	int   (*InitConnOptions)		();
	void* (*GetTableFields)			();	///creates the table fields descrisptor
	void* (*getNodeTableFields)  ();
	
	void* (*StatementInsert)		();
	void* (*StatementCreate)		();
	void* (*StatementCreateTable)	();
	void* (*StatementCreateNodeTable) ();
	void* (*StatementUse)			();
	void* (*StatementShow)			();
	void* (*StatementDrop)			();
	void* (*StatementSelect)		();
	void* (*StatementTruncate)		();
	void* (*StatementUpdate)		();
	void* (*StatementDBshow)		();
	void* (*StatementDatabases)     ();
	void* (*getFuncsFromHost)    ();
	
	int   (*showDatabases)          (); // I might pass this a fcn ptr and change it to (*show), lde @todo
	char* (*getTableFields)			();
	
	int size;
};
typedef struct NPdbFuncSet NPdbFuncSet;
typedef struct NPdbFuncSet *pNPdbFuncSet;

struct NPdbLiteral {
	int type;
	void* literal;
};
typedef struct NPdbLiteral NPdbLiteral;
typedef struct NPdbLiteral *pNPdbLiteral;

struct NPdbStringLiteral {
	char* npString; // 'abcd' or "abcd"
};
typedef struct NPdbStringLiteral NPdbStringLiteral;
typedef struct NPdbStringLiteral *pNPdbStringLiteral;

// Experimental, lde @todo
struct NPdbReservedWord {
	char word[20];
	int  type; // Function, Data Type, Logical Operator, Etc...., lde
//	void** (*thing)();
//	int  numThings;
};
typedef struct NPdbReservedWord NPdbReservedWord;
typedef struct NPdbReservedWord *pNPdbReservedWord;

struct NPdbQuery {
	int placeholder;
};
typedef struct NPdbQuery NPdbQuery;
typedef struct NPdbQuery *pNPdbQuery;

/// Host id unique to the session, ip is generally more permanent.
/// Note that the list of databases is not stored with the host.
/// The name of the current database in USE is stored with the host.
struct NPdbHost{
	int			id;				///< local host ID unique to this session only
	void*		conn;			///< host connection handle
	bool		connected;
	unsigned long conn_id;		///< Host's database thread id, lde
	
	char		type[64];		///< server type 'mysql', 'postgresql', etc.
	
	int			port;					///< port address
	char		ip[kNPurlMax];			///< IP address or URL
	
	char		user[kNPuserNameMax];	///< this hosts user name
	char		password[kNPpwdMax];	///< this hosts password
	
	char		inUseDB[kNPdbNameMax];	///< name of DB currently in USE
	int			dbCount;				///< number of databases for this host
	
	//char		currentTable[];
	int			(*connect)();
	pNPdbFuncSet hostFuncSet;			///< function calls for this host type
}; //@todo: hosts need an active server, lde
typedef struct NPdbHost NPdbHost;
typedef struct NPdbHost * pNPdbHost;


struct NPdbFields{
	char*		name;		///< field name
	char*		typeStr;	///< field type as DB string format
	char*		params;		///< any additional field params, limits, etc.
	int *		type;		///< field type constant
	int			count;		///< number of field columns
};
typedef struct NPdbFields NPdbFields;
typedef struct NPdbFields * pNPdbFields;

/// holds a pair of lists that correspond an external id to local node pointer
/// nextID index is used for fast search processing when using an ordered list
struct NPmapID{
	int		nextID;		///< index used for accelerated search of ordered list
	int*	recID;		///< list of external table record id's to map
	int*	nodeID;		///< matching list of local scene node id's
	int		count;		///< number of item pairs in the lists
};
typedef struct NPmapID NPmapID;
typedef struct NPmapID * pNPmapID;	

#define kNPmaxFields 4096
struct NPdbTable{
	int			id;							///< local table ID for this database
	int			type;						///< table type: node, tag, chmap, etc.
	char*		name;
	
	int			rows;						///< number of rows in this table
	
	pNPdbFields	fields[100];					///< field descriptor
	char*		fieldsStr;
	int			fieldCount;					///< number of fields in this table, init to 0 , @todo, lde
	
	pNPmapID	mapID;						///< maps the row id to local data ptr
	
	void*		owner;						///< Database this table is attached to, lde pNPdatabase
	
	int			size;						///< size of this table in bytes
};
typedef struct NPdbTable NPdbTable;
typedef struct NPdbTable * pNPdbTable;

struct NPdbCSVwrite
{
	char*	   csvName;
	int		   running;
	pNPdbTable table;
	void*	   dataRef;
};
typedef struct NPdbCSVwrite NPdbCSVwrite;
typedef struct NPdbCSVwrite *pNPdbCSVwrite;


enum NP_DB_CONTENT_TYPES 
{
	kNPdbTypeNull = 0,
	kNPdbTypeNative,		///< native dataset with nodes, tags, etc.
	kNPdbTypePlugin,		///< DB plugin type for 3rd party support
	kNPdbTypeUnknown,		///< unknown DB content structure
	kNPdbTypeCount
};

struct NPdatabase{
	int			id;						///< this databases ID // Connection structure
	int*		idMap;
	int			format;					///< content format, antz or 3rd party
	int*		refCount;				///< memory reference counter, lde
	
	char		name[kNPdbNameMax +1];	///< database name +1 for '\0'
	
	//	pNPdbTable* tables;					///< contains row count		// old, lde
	pNPdbTable	tableList[kNPtblMax];	///< list of tables			// new, lde
	pNPdbTable	tableInUse;				///< current table in use
	int			tableCount;				///< total number of tables
	
	//char*       queries[1024];			///< Query history, lde @todo
	
	int			nodeCount;				///< if exists, node table row count // @todo, include nodeCount on dbMenu, lde
	
	float		saveUpdateRate;			///< auto save update rate, 0 is off
	float		loadUpdateRate;			///< auto load update rate, 0 is off
	
	int			(*loadNodeTbl)();
	pNPdbHost	host;		///< references this databases host
	
};
typedef struct NPdatabase NPdatabase;
typedef struct NPdatabase * pNPdatabase;




/// holds list of databases and there hosts
struct NPdbs { // Should this be renamed to NPdbServer, lde @todo
	void* coreNode; ///< core nodes tie global structures to the scene graph
	
	void*		ptrList[100];			// new, lde @todo // 100, arbritary
	int			ptrCount;
	bool			running;				///< true if hosts are connected
	void			(*connectHosts)();		// new, lde
	pNPdbHost		hosts[kNPdbHostMax];	///< list of database hosts
	int				hostCount;				///< number of DB host servers
	
	pNPdbFuncSet	funcSetList[kNPdbFuncSetMax]; ///< host type specific
	int				funcSetCount;				  ///< function set count
	
	pNPdatabase		dbList[kNPdbMax];		///< list of databases
	int				dbCount;				///< number of databases
	
	pNPdatabase		activeDB;				///< points to active DB in list
	char			inUseDB2[kNPdbNameMax];	///< Name of in use database, lde
	
	float			saveUpdateRate;		///< auto save update rate, 0 is off
	float			loadUpdateRate;		///< auto load update rate, 0 is off
	
	bool			loadUpdate;			///< flag a single update this cycle
	bool			saveUpdate;			///< flag a single update this cycle
	
	int				size;				///< size in RAM of all db elements
};
typedef struct NPdbs NPdbs;
typedef struct NPdbs *pNPdbs;

// struct pNPdatabases { //zzsql
struct NPdatabases {
	void* coreNode; ///< core nodes tie global structures to the scene graph
	///< each global struct has a corresponding base node.
	
	char** list;		///< list of databases by name
	int size;			///< number of items in the list
};
typedef struct NPdatabases NPdatabases;
typedef struct NPdatabases *pNPdatabases;

// new struct, lde
struct NPtables {
	char** list;		///< list of tables by name
	int size;			///< number of items in the list
};
typedef struct NPtables NPtables;
typedef struct NPtables *pNPtables;

#endif

