source s_mail_orig {
    network(
		ip("0.0.0.0")
		port(9526)
		transport(tcp)
		ip-protocol(4)
		so_rcvbuf(520192)
		log_iw_size(100000)
	);
};

source s_mail_info {
    network(
		ip("0.0.0.0")
		port(9527)
		transport(tcp)
		ip-protocol(4)
		so_rcvbuf(520192)
		log_iw_size(100000)
		flags(no-parse)
	);
};

source s_mail_security {
    network(
		ip("0.0.0.0")
		port(9528)
		transport(tcp)
		ip-protocol(4)
		so_rcvbuf(520192)
		log_iw_size(100000)
		flags(no-parse)
	);
};

source s_mail_admin_log {
	network(
		ip("0.0.0.0")
		port(9529)
		transport(tcp)
		ip-protocol(4)
		so_rcvbuf(520192)
		log_iw_size(100000)
		flags(no-parse)
	);
};


destination d_mail_aggr_mail_log {
	sql(
		type(sqlite3)
		database("/var/spool/@MailPlus-Server/aggr_log/aggr_mail_log.db")
		table("mail_log_table")
		columns(
			"message_id text default NULL",
			"queue_id text default NULL",
			"date integer default NULL",
			"mail_from text default NULL",
			"mail_to text default NULL",
			"size integer default NULL",
			"status integer default NULL",
			"host text default NULL",
			"subject text default NULL",
			"ori_mail_to text default NULL"
		)
		values(
			"${MESSID}",
			"${QUEID}",
			"${TIMESTAMP}",
			"${SENDER}",
			"${RECEIVER}",
			"${SIZE}",
			"${STATUS}",
			"${HOST}",
			"${SUBJECT}",
			"${ORIMAILTO}"
		)
		indexes(
			"message_id",
			"date",
			"mail_from",
			"mail_to",
			"size",
			"status",
			"subject",
			"ori_mail_to"
		)
		retries(10)
		flags(explicit-commits)
		flush-lines(200)
		flush_timeout(10000)
		log_fifo_size(50000)
	);
};

destination d_mail_aggr_security_log {
	sql(
		type(sqlite3)
		database("/var/spool/@MailPlus-Server/aggr_log/aggr_security_log.db")
		table("security_log_table")
		columns(
			"date integer default NULL",
			"src text default NULL",
			"type text default NULL",
			"event text default NULL",
			"host text default NULL",
			"sender text default NULL",
			"recipient text default NULL",
			"subject text default NULL"
		)
		values(
			"${TIMESTAMP}",
			"${src}",
			"${type}",
			"${event}",
			"${HOST}",
			"${sender}",
			"${recipient}",
			"${subject}"
		)
		indexes(
			"date",
			"src",
			"type",
			"sender",
			"recipient",
			"subject"
		)
		retries(10)
		flags(explicit-commits)
		flush-lines(200)
		flush_timeout(10000)
		log_fifo_size(50000)
	);
};

destination d_mail_admin_log {
    sql(
        type(sqlite3)
        database("/var/spool/@MailPlus-Server/aggr_log/admin_log.db")
        table("admin_log")
        columns(
            "tab_type integer default NULL",
            "statement integer default NULL",
            "user text default NULL",
            "uid integer default NULL",
            "date integer default NULL",
            "ip text default NULL",
            "server text default NULL",
            "webapi_param text default NULL",
        )
        values(
            "${TAB_TYPE}",
            "${STATEMENT}",
            "${USER}",
            "${UID}",
			"${EXEC_TIME}",
            "${IP}",
            "${HOST}${SERVER}",
            "${WEBAPI_PARAM}",
        )
        indexes(
            "tab_type",
            "statement",
            "user",
            "date",
            "ip",
            "server",
        )
        retries(10)
        flags(explicit-commits)
        flush-lines(200)
        flush_timeout(10000)
        log_fifo_size(50000)
    );
};



destination d_mail_aggr_maillog {
	file("/var/spool/@MailPlus-Server/aggr_log/aggr_maillog"
		perm(0644)
		suppress(0)
);};

log {
	source(s_mail_orig);
	destination(d_mail_aggr_maillog);
};

log {
	source(s_mail_info);
	parser(p_json_message);
	destination(d_mail_aggr_mail_log);
};

log {
	source(s_mail_security);
	parser(p_json_message);
	destination(d_mail_aggr_security_log);
};

log {
    source(s_mail_admin_log);
    parser(p_json_message);
    destination(d_mail_admin_log);
};