/**
 * Created by strawmanbobi
 * 2016-11-27
 */

// global inclusion
let orm = require('orm');
let dbOrm = require('../mini_poem/db/mysql/mysql_connection').mysqlDB;
let logger = require('../mini_poem/logging/logger4js').helper;
let dateUtils = require('../mini_poem/utils/date_utils.js');

// local inclusion
let ErrorCode = require('../constants/error_code');
let errorCode = new ErrorCode();

let Enums = require('../constants/enums');
let enums = new Enums();

let IRProtocol = dbOrm.define('ir_protocol',
    {
        id: Number,
        name: String,
        type: Number,
        status: Number,
        update_time: String,
        contributor: String,
        boot_code: String
    },
    {
        cache: false
    }
);

IRProtocol.createIRProtocol = function(protocol, callback) {
    let date = dateUtils.formatDate(new Date(), "yyyy-MM-dd hh:mm:ss");
    let newProtocol = new IRProtocol({
        name: protocol.name,
        status: protocol.status,
        type: protocol.type,
        update_time: date,
        contributor: protocol.contributor,
        boot_code: protocol.boot_code
    });
    newProtocol.save(function(error, createdProtocol) {
        if(error) {
            logger.error('failed to create protocol : ' + error);
            callback(errorCode.FAILED, null);
        } else {
            callback(errorCode.SUCCESS, createdProtocol);
        }
    });
};

IRProtocol.updateProtocolByID = function(protocolID, newProtocol, callback) {
    IRProtocol.get(protocolID, function(error, protocol) {
        if (error) {
            logger.error("get protocol by ID error in update protocol : " + error);
            callback(errorCode.FAILED, null);
        } else {
            protocol.name = newProtocol.name;
            protocol.type = newProtocol.type;
            protocol.status = newProtocol.status;
            protocol.update_time = newProtocol.update_time;
            protocol.boot_code = null;
            protocol.contributor = newProtocol.contributor;
            protocol.save(function(error, createdProtocol) {
                if(error) {
                    logger.error('failed to create protocol in update protocol : ' + error);
                    callback(errorCode.FAILED, null);
                } else {
                    callback(errorCode.SUCCESS, createdProtocol);
                }
            });
        }
    });
};

IRProtocol.findIRProtocolByConditions = function(conditions, callback) {
    IRProtocol.find(conditions)
        .run(function (error, protocols) {
            if (error) {
                logger.error("find protocol error : " + error);
                callback(errorCode.FAILED, null);
            } else {
                callback(errorCode.SUCCESS, protocols);
            }
        });
};

IRProtocol.listIRProtocols = function(conditions, from, count, sortField, callback) {
    if("id" == sortField && 0 != from) {
        conditions.id = orm.gt(from);
        IRProtocol.find(conditions).limit(parseInt(count)).orderRaw("?? ASC", [sortField])
            .run(function (listProtocolsErr, protocols) {
                if (listProtocolsErr) {
                    logger.error("list protocols error : " + listProtocolsErr);
                    callback(errorCode.FAILED, null);
                } else {
                    callback(errorCode.SUCCESS, protocols);
                }
            });
    } else {
        IRProtocol.find(conditions).limit(parseInt(count)).offset(parseInt(from)).orderRaw("?? ASC", [sortField])
            .run(function (listProtocolsErr, protocols) {
                if (listProtocolsErr) {
                    logger.error("list protocols error : " + listProtocolsErr);
                    callback(errorCode.FAILED, null);
                } else {
                    callback(errorCode.SUCCESS, protocols);
                }
            });
    }
};

IRProtocol.getIRProtocolByID = function(protocolID, callback) {
    IRProtocol.get(protocolID, function(error, protocol) {
        if (error) {
            logger.error("get protocol by ID error : " + error);
            callback(errorCode.FAILED, null);
        } else {
            callback(errorCode.SUCCESS, protocol);
        }
    });
};

module.exports = IRProtocol;