filter_mysql.h

#ifndef FILTER_MYSQL_H
#define FILTER_MYSQL_H


#include <cstdlib>
#include <iostream>
#include <string>
#include <cmath>
#include <map>
#include <vector>
#include <deque>
#include <deque>

#include "calltable.h"

#define FLAG_RTP_ALL	(1 << 0)
#define FLAG_RTP_HEAD	(1 << 1)
#define FLAG_NORTP      (1 << 2)
#define FLAG_RTCP	(1 << 3)
#define FLAG_NORTCP     (1 << 4)
#define FLAG_SIP	(1 << 5)
#define FLAG_NOSIP      (1 << 6)
#define FLAG_REGISTER	(1 << 7)
#define FLAG_NOREGISTER	(1 << 8)
#define FLAG_GRAPH	(1 << 9)
#define FLAG_NOGRAPH    (1 << 10)
#define FLAG_AUDIO	(1 << 11)
#define FLAG_AUDIO_WAV	(1 << 12)
#define FLAG_AUDIO_OGG	(1 << 13)
#define FLAG_NOWAV      (1 << 14)
#define FLAG_SKIP       (1 << 15)
#define FLAG_NOSKIP     (1 << 16)
#define FLAG_SCRIPT     (1 << 17)
#define FLAG_NOSCRIPT   (1 << 18)
#define FLAG_AMOSLQO    (1 << 19)
#define FLAG_BMOSLQO    (1 << 20)
#define FLAG_ABMOSLQO   (1 << 21)
#define FLAG_NOMOSLQO   (1 << 22)
#define FLAG_HIDEMSG	(1 << 23)
#define FLAG_SHOWMSG	(1 << 24)
#define FLAG_SPOOL_2	(1 << 25)

#define MAX_PREFIX 64

struct filter_db_row_base {
	filter_db_row_base() {
		direction = 0;
		rtp = 0;
		rtcp = 0;
		sip = 0;
		reg = 0;
		graph = 0;
		wav = 0;
		skip = 0;
		mos_lqo = 0;
		script = 0;
		hide_message = 0;
		spool_2 = 0;
	}
	int direction;
	int rtp;
	int rtcp;
	int sip;
	int reg;
	int graph;
	int wav;
	int skip;
	int mos_lqo;
	int script;
	int hide_message;
	int spool_2;
};

class filter_base {
protected:
	void loadBaseDataRow(class SqlDb_row *sqlRow, filter_db_row_base *baseRow);
	void loadBaseDataRow(map<string, string> *row, filter_db_row_base *baseRow);
	unsigned int getFlagsFromBaseData(filter_db_row_base *baseRow);
	void setCallFlagsFromFilterFlags(volatile unsigned int *callFlags, unsigned int filterFlags);
};

class IPfilter : public filter_base {
private:
	struct db_row : filter_db_row_base {
		db_row() {
			ip = 0;
			mask = 0;
		}
		unsigned int ip;
		int mask;
	};
        struct t_node {
		unsigned int ip;
		int mask;
		int direction;
		unsigned int flags;
                t_node *next;
        };
        t_node *first_node;
public: 
        IPfilter();
        ~IPfilter();
        void load();
	int _add_call_flags(volatile unsigned int *flags, unsigned int saddr, unsigned int daddr);
        void dump();
        static void dump2man(ostringstream &oss);
	static int add_call_flags(volatile unsigned int *flags, unsigned int saddr, unsigned int daddr, bool enableReload = false);
	static void loadActive();
	static void freeActive();
	static void prepareReload();
	static void applyReload();
	static void lock() {
		while(__sync_lock_test_and_set(&_sync, 1));
	}
	static void unlock() {
		__sync_lock_release(&_sync);
	}
	static void lock_reload() {
		while(__sync_lock_test_and_set(&_sync_reload, 1));
	}
	static void unlock_reload() {
		__sync_lock_release(&_sync_reload);
	}
private:
	int count;
	static IPfilter *filter_active;
	static IPfilter *filter_reload;
	static volatile bool reload_do;
	static volatile int _sync;
	static volatile int _sync_reload;
};

class TELNUMfilter : public filter_base {
private:
	struct db_row : filter_db_row_base {
		db_row() {
			memset(prefix, 0, sizeof(prefix));
		}
		char prefix[MAX_PREFIX];
	};
	struct t_payload {
		char prefix[MAX_PREFIX];
		int direction;
		unsigned int ip;
		int mask;
		unsigned int flags;
	};
        struct t_node_tel {
                t_node_tel *nodes[256];
                t_payload *payload;
        };
        t_node_tel *first_node;
public: 
        TELNUMfilter();
        ~TELNUMfilter();
        void load();
	void loadFile();
	void add_payload(t_payload *payload);
	int _add_call_flags(volatile unsigned int *flags, char *telnum_src, char *telnum_dst);
        void dump(t_node_tel *node = NULL);
        static void dump2man(ostringstream &oss, t_node_tel *node = NULL);
	static int add_call_flags(volatile unsigned int *flags, char *telnum_src, char *telnum_dst, bool enableReload = false);
	static void loadActive();
	static void freeActive();
	static void prepareReload();
	static void applyReload();
	static void lock() {
		while(__sync_lock_test_and_set(&_sync, 1));
	}
	static void unlock() {
		__sync_lock_release(&_sync);
	}
	static void lock_reload() {
		while(__sync_lock_test_and_set(&_sync_reload, 1));
	}
	static void unlock_reload() {
		__sync_lock_release(&_sync_reload);
	}
private:
	int count;
	static TELNUMfilter *filter_active;
	static TELNUMfilter *filter_reload;
	static volatile bool reload_do;
	static volatile int _sync;
	static volatile int _sync_reload;
};

class DOMAINfilter : public filter_base {
private:
	struct db_row : filter_db_row_base{
		db_row() {
		}
		std::string domain;
	};
        struct t_node {
		std::string domain;
		int direction;
		unsigned int flags;
		t_node *next;
	};
	t_node *first_node;
public: 
	DOMAINfilter();
	~DOMAINfilter();
	void load();
	int _add_call_flags(volatile unsigned int *flags, char *domain_src, char *domain_dst);
	void dump();
        static void dump2man(ostringstream &oss);
	static int add_call_flags(volatile unsigned int *flags, char *domain_src, char *domain_dst, bool enableReload = false);
	static void loadActive();
	static void freeActive();
	static void prepareReload();
	static void applyReload();
	static void lock() {
		while(__sync_lock_test_and_set(&_sync, 1));
	}
	static void unlock() {
		__sync_lock_release(&_sync);
	}
	static void lock_reload() {
		while(__sync_lock_test_and_set(&_sync_reload, 1));
	}
	static void unlock_reload() {
		__sync_lock_release(&_sync_reload);
	}
private:
	int count;
	static DOMAINfilter *filter_active;
	static DOMAINfilter *filter_reload;
	static volatile bool reload_do;
	static volatile int _sync;
	static volatile int _sync_reload;
};

class SIP_HEADERfilter : public filter_base {
private:
	struct db_row : filter_db_row_base{
		db_row() {
		}
		std::string header;
		std::string content;
		bool prefix;
		bool regexp;
	};
        struct item_data {
		int direction;
		bool prefix;
		bool regexp;
		unsigned int flags;
	};
	struct header_data {
		std::map<std::string, item_data> strict_prefix;
		std::map<std::string, item_data> regexp;
	};
	std::map<std::string, header_data> data;
public: 
	SIP_HEADERfilter();
	~SIP_HEADERfilter();
	void load();
	int _add_call_flags(struct ParsePacket::ppContentsX *parseContents, volatile unsigned int *flags);
	void dump();
        static void dump2man(ostringstream &oss);
	void _addNodes(ParsePacket *parsePacket);
	static int add_call_flags(struct ParsePacket::ppContentsX *parseContents, volatile unsigned int *flags, bool enableReload = false);
	static void addNodes(ParsePacket *parsePacket);
	static void loadActive();
	static void freeActive();
	static void prepareReload();
	static void applyReload();
	static unsigned long getLoadTime() {
		return(loadTime);
	}
	static void lock() {
		while(__sync_lock_test_and_set(&_sync, 1));
	}
	static void unlock() {
		__sync_lock_release(&_sync);
	}
	static void lock_reload() {
		while(__sync_lock_test_and_set(&_sync_reload, 1));
	}
	static void unlock_reload() {
		__sync_lock_release(&_sync_reload);
	}
private:
	int count;
	static SIP_HEADERfilter *filter_active;
	static SIP_HEADERfilter *filter_reload;
	static volatile bool reload_do;
	static volatile unsigned long loadTime;
	static volatile int _sync;
	static volatile int _sync_reload;
};

inline void set_global_flags(volatile unsigned int &flags) {
	extern int opt_saveSIP;
	extern int opt_saveRTP;
	extern int opt_onlyRTPheader;
	extern int opt_saveRTCP;
	extern int opt_saveWAV;
	extern int opt_audio_format;
	extern int opt_saveGRAPH;
	extern int opt_skipdefault;
	extern int opt_hide_message_content;
	extern bool opt_sip_register_save_all;
	
	if(opt_saveSIP) {
		flags |= FLAG_SAVESIP;
	}
	if(opt_saveRTP) {
		flags |= FLAG_SAVERTP;
	}
	if(opt_onlyRTPheader) {
		flags |= FLAG_SAVERTPHEADER;
	}
	if(opt_saveRTCP) {
		flags |= FLAG_SAVERTCP;
	}
	if(opt_saveWAV) {
		flags |= (opt_audio_format == FORMAT_OGG ? FLAG_SAVEAUDIO_OGG : FLAG_SAVEAUDIO_WAV);
	}
	if(opt_saveGRAPH) {
		flags |= FLAG_SAVEGRAPH;
	}
	if(opt_skipdefault) {
		flags |= FLAG_SKIPCDR;
	}
	if(opt_hide_message_content) {
		flags |= FLAG_HIDEMESSAGE;
	}
	if(opt_sip_register_save_all) {
		flags |= FLAG_SAVEREGISTER;
	}
}


#endif //FILTER_MYSQL_H