books/backends/sqlite.js

const frappe = require('frappe-core');
const sqlite3 = require('sqlite3').verbose();

class sqliteDatabase {
    constructor({db_path}) {
        this.db_path = db_path;
        this.init_type_map();
    }

    connect(db_path) {
        if (db_path) {
            this.db_path = db_path;
        }
        return new Promise(resolve => {
            this.conn = new sqlite3.Database(this.db_path, () => {
                // debug
                // this.conn.on('trace', (trace) => console.log(trace));
                resolve();
            });
        });
    }

    async migrate() {
        for (let doctype in frappe.models.data.doctype) {
            if (await this.table_exists(doctype)) {
                await this.alter_table(doctype);
            } else {
                await this.create_table(doctype);
            }
        }
        await this.commit();
    }

    async create_table(doctype) {
        let meta = frappe.get_meta(doctype);
        let columns = [];
        let values = [];

        for (let df of this.get_fields(meta)) {
            if (this.type_map[df.fieldtype]) {
                columns.push(this.get_column_definition(df));
                if (df.default) {
                    values.push(df.default);
                }
            }
        }

        const query = `CREATE TABLE IF NOT EXISTS ${frappe.slug(doctype)} (
            ${columns.join(", ")})`;

        return await this.run(query, values);
    }

    close() {
        this.conn.close();
    }

    get_column_definition(df) {
        return `${df.fieldname} ${this.type_map[df.fieldtype]} ${df.reqd ? "not null" : ""} ${df.default ? "default ?" : ""}`
    }

    async alter_table(doctype) {
        // get columns
        let table_columns = (await this.sql(`PRAGMA table_info(${doctype})`)).map(d => d.name);
        let meta = frappe.get_meta(doctype);
        let values = [];

        for (let df of this.get_fields(meta)) {
            if (!table_columns.includes(df.fieldname) && this.type_map[df.fieldtype]) {
                values = []
                if (df.default) {
                    values.push(df.default);
                }
                await this.run(`ALTER TABLE ${frappe.slug(doctype)} ADD COLUMN ${this.get_column_definition(df)}`, values);
            }
        }
    }

    get(doctype, name, fields='*') {
        if (fields instanceof Array) {
            fields = fields.join(", ");
        }
        return new Promise((resolve, reject) => {
            this.conn.get(`select ${fields} from ${frappe.slug(doctype)}
                where name = ?`, name,
                (err, row) => {
                    resolve(row || {});
                });
        });
    }

    async insert(doctype, doc) {
        let placeholders = Object.keys(doc).map(d => '?').join(', ');
        return await this.run(`insert into ${frappe.slug(doctype)}
            (${Object.keys(doc).join(", ")})
            values (${placeholders})`, this.get_formatted_values(doc));
    }

    async update(doctype, doc) {
        let assigns = Object.keys(doc).map(key => `${key} = ?`);
        let values = this.get_formatted_values(doc);
        values.push(doc.name);

        return await this.run(`update ${frappe.slug(doctype)}
                set ${assigns.join(", ")} where name=?`, values);
    }

    get_formatted_values(doc) {
        return Object.values(doc).map(value => {
            if (value instanceof Date) {
                return value.toISOString();
            } else {
                return value;
            }
        })
    }

    async delete(doctype, name) {
        return await this.run(`delete from ${frappe.slug(doctype)} where name=?`, name);
    }

    get_all({doctype, fields=['name'], filters, start, limit, order_by='modified', order='desc'} = {}) {
        return new Promise((resolve, reject) => {
            let conditions = this.get_filter_conditions(filters);

            this.conn.all(`select ${fields.join(", ")}
                from ${frappe.slug(doctype)}
                ${conditions.conditions ? "where" : ""} ${conditions.conditions}
                ${order_by ? ("order by " + order_by) : ""} ${order_by ? (order || "asc") : ""}
                ${limit ? ("limit " + limit) : ""} ${start ? ("offset " + start) : ""}`, conditions.values,
                (err, rows) => {
                    if (err) {
                        reject(err);
                    } else {
                        resolve(rows);
                    }
                });
        });
    }

    get_filter_conditions(filters) {
        // {"status": "Open"} => `status = "Open"`
        // {"status": "Open", "name": ["like", "apple%"]}
            // => `status="Open" and name like "apple%"
        let conditions = [];
        let values = [];
        for (let key in filters) {
            const value = filters[key];
            if (value instanceof Array) {
                conditions.push(`${key} ${value[0]} ?`);
                values.push(value[1]);
            } else {
                conditions.push(`${key} = ?`);
                values.push(value);
            }
        }
        return {
            conditions: conditions.length ? conditions.join(" and ") : "",
            values: values
        };
    }

    run(query, params) {
        return new Promise((resolve, reject) => {
            this.conn.run(query, params, (err) => {
                if (err) {
                    console.log(err);
                    reject(err);
                } else {
                    resolve();
                }
            });
        });
    }

    sql(query, params) {
        return new Promise((resolve) => {
            this.conn.all(query, params, (err, rows) => {
                resolve(rows);
            });
        });
    }

    async commit() {
        try {
            await this.run('commit');
        } catch (e) {
            if (e.errno !== 1) {
                throw e;
            }
        }
    }

    async get_value(doctype, filters, fieldname='name') {
        if (typeof filters==='string') {
            filters = {name: filters};
        }

        let row = await this.get_all({
            doctype:doctype,
            fields: [fieldname],
            filters: filters,
            start: 0,
            limit: 1});
        return row.length ? row[0][fieldname] : null;
    }

    get_fields(meta) {
        // add standard fields
        let fields = frappe.model.standard_fields.slice();
        if (meta.istable) {
            fields = fields.concat(frappe.model.child_fields);
        }

        // add model fields
        fields = fields.concat(meta.fields);

        return fields;
    }

    async table_exists(table) {
        const name = await this.sql(`SELECT name FROM sqlite_master WHERE type='table' AND name='${table}'`);
        return (name && name.length) ? true : false;
    }

    init_type_map() {
        this.type_map = {
            'Currency':        'real'
            ,'Int':            'integer'
            ,'Float':        'real'
            ,'Percent':        'real'
            ,'Check':        'integer'
            ,'Small Text':    'text'
            ,'Long Text':    'text'
            ,'Code':        'text'
            ,'Text Editor':    'text'
            ,'Date':        'text'
            ,'Datetime':    'text'
            ,'Time':        'text'
            ,'Text':        'text'
            ,'Data':        'text'
            ,'Link':        'text'
            ,'Dynamic Link':'text'
            ,'Password':    'text'
            ,'Select':        'text'
            ,'Read Only':    'text'
            ,'Attach':        'text'
            ,'Attach Image':'text'
            ,'Signature':    'text'
            ,'Color':        'text'
            ,'Barcode':        'text'
            ,'Geolocation':    'text'
        }
    }

}

module.exports = { Database: sqliteDatabase };