const { R } = require("redbean-node");

function patchRedBeanPostgres() {
    const RedBeanNode = R.constructor;
    if (RedBeanNode.prototype._pgPatched) {
        return;
    }
    RedBeanNode.prototype._pgPatched = true;

    function cleanPgSql(sql) {
        if (typeof sql === "string") {
            return sql.replace(/`([^`]+)`/g, '"$1"');
        }
        return sql;
    }

    const origNormalizeRawCore = RedBeanNode.prototype.normalizeRawCore;
    RedBeanNode.prototype.normalizeRawCore = function (sql, data) {
        if (this.dbType === "pg") {
            sql = cleanPgSql(sql);
        }
        return origNormalizeRawCore.call(this, sql, data);
    };

    const origNormalizeRaw = RedBeanNode.prototype.normalizeRaw;
    RedBeanNode.prototype.normalizeRaw = async function (sql, data) {
        let result = await this.normalizeRawCore(sql, data);
        this.queryLog(sql);
        if (this.dbType === "mysql") {
            result = result[0];
        } else if (this.dbType === "pg" && result && result.rows) {
            result = result.rows;
        }
        return result;
    };

    RedBeanNode.prototype.getRow = async function (sql, data = [], autoLimit = false) {
        if (autoLimit) {
            if (this.dbType === "mssql") {
                if (sql.trim().toLowerCase().startsWith("select ")) {
                    sql = sql.replace(/select/i, "$& TOP 1");
                }
            } else if (this.dbType === "pg") {
                let limitTemplate = this.knex.limit(1).toSQL();
                sql = cleanPgSql(sql) + limitTemplate.sql.replace("select *", "");
                data = data.concat(limitTemplate.bindings);
            } else {
                let limitTemplate = this.knex.limit(1).toSQL().toNative();
                sql = sql + limitTemplate.sql.replace("select *", "");
                data = data.concat(limitTemplate.bindings);
            }
        }
        this.queryLog(sql);
        let result = await this.normalizeRaw(sql, data);
        if (result && result.length > 0) {
            return result[0];
        } else {
            return null;
        }
    };

    const origFindCore = RedBeanNode.prototype.findCore;
    RedBeanNode.prototype.findCore = function (type, clause, data = []) {
        if (this.dbType === "pg") {
            clause = cleanPgSql(clause);
        }
        return origFindCore.call(this, type, clause, data);
    };

    RedBeanNode.prototype.findOne = async function (type, clause = "", data = []) {
        if (this.dbType === "pg") {
            clause = cleanPgSql(clause);
        }
        let queryPromise = this.knex.table(type).whereRaw(clause, data).first();
        this.queryLog(queryPromise);
        let obj;
        try {
            obj = await queryPromise;
        } catch (error) {
            this.checkAllowedError(error);
        }
        if (!obj) {
            return null;
        }
        return this.convertToBean(type, obj);
    };

    const origCount = RedBeanNode.prototype.count;
    RedBeanNode.prototype.count = async function (type, clause = "", data = [], autoLimit = true) {
        if (this.dbType === "pg") {
            clause = cleanPgSql(clause);
        }
        return origCount.call(this, type, clause, data, autoLimit);
    };

    const origStoreCore = RedBeanNode.prototype.storeCore;
    RedBeanNode.prototype.storeCore = async function (bean, changedFieldsOnly = true) {
        if (this.dbType === "pg" && !bean.id) {
            this.devLog("Store PG insert", bean.beanMeta.type);
            await bean.storeTypeBeanList();
            if (typeof bean.onUpdate === "function") {
                bean.onUpdate();
            }
            let obj = bean.export(false);
            delete obj.id;
            let queryPromise = this.knex(bean.getType()).insert(obj).returning("id");
            this.queryLog(queryPromise);
            let result = await queryPromise;
            bean.id = result && result[0] ? (typeof result[0] === "object" ? result[0].id : result[0]) : null;
            await bean.storeSharedList();
            await bean.storeOwnList();
            bean.beanMeta.old = {};
            if (typeof bean.onAfterUpdate === "function") {
                bean.onAfterUpdate();
            }
            return bean.id;
        }
        return origStoreCore.call(this, bean, changedFieldsOnly);
    };
}

patchRedBeanPostgres();

module.exports = { patchRedBeanPostgres };