import * as SQLite from 'expo-sqlite';
import {
    ResultRow,
    Transaction,
    ResultSet,
    InsertObject,
    SQLError
} from './Types';
let databaseName = '';

export const Databse = (
    database_name: string = 'esqh.db',
    version: string = '1.0'
) => {
    databaseName = database_name;
    return SQLite.openDatabase(databaseName, version);
};

export const executeSql = async (
    sql: string,
    arg: string[] | number[] = []
) => {
    return new Promise(
        (resolve: (arg: ResultSet) => void, reject: (err: SQLError) => void) =>
            Databse(databaseName).transaction((tx: Transaction) => {
                tx.executeSql(
                    sql,
                    arg,
                    (_, { rows, rowAffected, insertId }: ResultSet) =>
                        resolve({
                            rows,
                            rowAffected,
                            insertId,
                            lastQuery: sql
                        }),
                    (err) => reject({ error: err, lastQuery: sql })
                );
            })
    );
};

export const insert = async (tableName: string, data: InsertObject[]) => {
    if (!Array.isArray(data)) {
        throw `Provided data is not an array please provide array of object to insert, Given data`;
    }
    const valuesQ = data
        .map((values) =>
            Object.values(values)
                .map((val) =>
                    val ? `'${val.toString().replace(/'/g, '`')}'` : 'null'
                )
                .join(',')
        )
        .join('), (');
    const query = `INSERT INTO ${tableName} (${Object.keys(data[0]).join(
        ','
    )}) VALUES (${valuesQ});`;
    return executeSql(query, []);
};

export const update = async (
    tableName: string,
    data: InsertObject,
    where: { [key: string]: string }
) => {
    if (!Array.isArray(data)) {
        throw `Provided data is not an array please provide array of object to update, Given data`;
    }
    const valuesQ = Object.keys(data).map(
        (cols) => `${cols}=${data[cols] ? `'${data[cols]}'` : 'null'}`
    );
    const query = `UPDATE ${tableName} SET ${valuesQ} WHERE ${
        Object.keys(where)[0]
    }=${Object.values(where)[0]}  ;`;
    return executeSql(query, []);
};

export const search = async (
    tableName: string,
    param: InsertObject | null = null,
    order_by: InsertObject | null = null,
    limit: number | null = null,
    extra: string = ''
) => {
    const query = `SELECT ${extra} * FROM ${tableName} ${
        param
            ? `WHERE ${Object.keys(param)[0]}='${Object.values(param)[0]}'`
            : ``
    } ${
        order_by
            ? `ORDER BY ${Object.keys(order_by)[0]} ${
                  Object.values(order_by)[0]
              }`
            : ''
    } ${limit ? `LIMIT ${limit}` : ``} `;
    return executeSql(query, []);
};

export const createTable = async (tableName: string, columns: InsertObject) => {
    const query = `CREATE TABLE IF NOT EXISTS ${tableName} (
        ${Object.keys(columns)
            .map((cols) => `${cols} ${columns[cols]}`)
            .join(',')}
    )`;
    return executeSql(query, []);
};

export const dropTable = async (tableName: string) => {
    const query = `DROP TABLE IF EXISTS ${tableName}`;
    return executeSql(query, []);
};

export const deleteData = async (
    tableName: string,
    param: InsertObject | null = null,
    extra: string = ''
) => {
    const query = `DELETE FROM ${tableName} ${
        param
            ? `WHERE ${Object.keys(param)[0]}='${Object.values(param)[0]}'`
            : ``
    } ${extra}`;
    return executeSql(query, []);
};