import { BaseService } from './base_service';
import { ITable, Column, COL_OPTION, DATA_TYPE, IDataBase } from 'jsstore';
import Axios from "axios";

export class DemoService extends BaseService {
    dbName = "Demo";
    constructor() {
        super();
    }

    isDemoDbExist() {
        return this.isDbExist(this.dbName);
    }

    createDemoDataBase() {
        return new Promise((resolve, reject) => {
            this.connection.createDb(this.getDbStructure()).then(() => {
                this.insertDemoDbData(resolve);
            }).catch((err) => {
                reject(err);
            });
        });
    }

    insertDemoDbData(callBack) {
        const filesList = ["Customers", "Categories", "Employees", "OrderDetails",
            "Orders", "Products", "Shippers", "Suppliers"];
        var filesProcessed = 0;
        var onFileProcessed = function () {
            filesProcessed++;
            console.log('inserted file:' + filesList[filesProcessed - 1]);
            if (filesProcessed === filesList.length) {
                callBack();
            }
        };
        filesList.forEach((file) => {
            const url = `assets/demo_database/${file}.json`;
            Axios.get(url).then((response) => {
                switch (file) {
                    case filesList[4]:
                        response.data.forEach(function (value) {
                            value.orderDate = new Date();
                        });
                        this.insert(file, response.data).then(onFileProcessed);
                        break;
                    case filesList[2]:
                        response.data.forEach(function (value) {
                            value.birthDate = new Date();
                        });
                        this.insert(file, response.data).then(onFileProcessed);
                        break;
                    case filesList[3]:
                        this.bulkInsert(file, response.data).then(onFileProcessed);
                        break;
                    default:
                        this.insert(file, response.data).then(onFileProcessed);
                }

            });
        });
    }

    insert(table: string, datas: any[]) {
        return this.connection.insert({
            into: table,
            values: datas
        });
    }

    bulkInsert(table: string, datas: any[]) {
        return this.connection.bulkInsert({
            into: table,
            values: datas
        });
    }

    getDbStructure() {
        const customers: ITable = {
            name: 'Customers',
            columns: [
                new Column('customerId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('customerName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('contactName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('address').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('city').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('postalCode').setDataType(DATA_TYPE.String),
                new Column('country').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String)
            ]
        };

        const categories: ITable = {
            name: 'Categories',
            columns: [
                new Column('categoryId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('categoryName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('description').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
            ]
        };

        const employees: ITable = {
            name: 'Employees',
            columns: [
                new Column('employeeId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('lastName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('birthDate').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.DateTime),
                new Column('photo').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('notes').setDataType(DATA_TYPE.String),
            ]
        };

        var order_details: ITable = {
            name: 'OrderDetails',
            columns: [
                new Column('orderDetailId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('orderId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('productId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('quantity').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number)
            ]
        };

        var orders: ITable = {
            name: 'Orders',
            columns: [
                new Column('orderId').options([COL_OPTION.PrimaryKey]),
                new Column('customerId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('employeeId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('state').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('jobSuspended_flag').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number)
            ]
        };

        var products: ITable = {
            name: 'Products',
            columns: [
                new Column('productId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('productName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('supplierId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('categoryId').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number),
                new Column('unit').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('price').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.Number)
            ]
        };

        var shippers: ITable = {
            name: 'Shippers',
            columns: [
                new Column('shipperId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('shipperName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('phone').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
            ]
        };

        var suppliers: ITable = {
            name: 'Suppliers',
            columns: [
                new Column('supplierId').options([COL_OPTION.PrimaryKey, COL_OPTION.AutoIncrement]),
                new Column('supplierName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('contactName').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('address').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('city').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('postalCode').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('country').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String),
                new Column('phone').options([COL_OPTION.NotNull]).setDataType(DATA_TYPE.String)
            ]
        };

        var dataBase: IDataBase = {
            name: this.dbName,
            tables: [
                customers,
                categories,
                employees,
                order_details,
                orders,
                products,
                shippers,
                suppliers
            ]
        };
        return dataBase;
    }
}