// tslint:disable:max-line-length
// tslint:disable:no-console
import knexConnection from '@player1os/knex-utility'
import env from '@player1os/config' // tslint:disable-line

// let lastDone = new Date(2600,1,1)
// let lastRowsFetched = 1000

const execute = async () => {
    await knexConnection.connect({
        client: 'pg',
        searchPath: 'public',
        connection: {
            host: env.APP_DATABASE_HOST,
            port: env.APP_DATABASE_PORT,
            database: env.APP_DATABASE_NAME,
            user: env.APP_DATABASE_USERNAME,
            password: env.APP_DATABASE_PASSWORD,
        },
        pool: {
            min: env.APP_DATABASE_MIN_POOL_SIZE,
            max: env.APP_DATABASE_MAX_POOL_SIZE,
        },
    })
    try {
        await knexConnection.transaction(async (trx) => {
            const gg1 = await trx.raw(`select * from test_insert_table`)
            console.log(gg1)

            const gg2 = /* DONT FORGET TO */ await /* PLS */ trx.raw(`insert into test_insert_table values ('2017-08-12 10:13:37')`)
            console.log(gg2)

            const gg3 = await trx.raw(`select * from test_insert_table`)
            console.log(gg3)
            /*
                                                                         `.`
                                                                .,`     .i;i.
                                                               ,i;i.    ;:,:;
                                                              `i:,::   `;,.,;
                                                              `;..,:   ,:..,:   `..
                                                              .:..,:   :,..:,  `i;i;
                                                              .:..,:  `;...;.  ::,,i.
                                                              ,:..,:  .:..,;` `;,.,;.
                                                              ,,..,,  :,..,;  ,:..,;
                                                       ,:.    :,..:,  ;,..,:  ;,..,:
                                                      :;;i.   :,..:, .:...:, .;...:,
                                                      ;:,::   ;,..:. ,,...;` :,..,;`
                                                      ::.,;`  ;...:. :,..,; `;...,:
                                                      .:..:,  ;...;``;,..,: ,:...:,
                                                      `;..,: `;...;``;...:, ;,...;`
                                                       :,.,;`.:...; ,:...;..:...,;
                                                       ,:..:,.:..,; :,..,; :,...:,
                                                       .;..,;,,...; ;...,:`;....;`
                                                        ;,..::....::,....::,...,;
                                                        :,...............,,....,:
                                                        .:.....................:,
                                                        `;.....................,,
                                                         :,....................,:
                                                         :,.......,......,......;.
                                                         ,:........,....,,......,;,
                                                         .:......,,....,,........,:;::;;::,`
                                                         `;......,.....,,..........,,,,,,:;i.
                                                          ;,....,......,...................:;
                                                          ;,...........,...................,i`
                                                          .;,......................,.......,i`
                                                           ,;,.................,:;:;;:,,,,,;:
                                                            .;:,.............,:;,`  `.::;;;,
                                                             `,;;:::::,....,:;,`
                                                                `,,,.,:;;;;:,`
                                                                 ` ` `` ``
                                                                 ` ` ``
                                                                 ` ` ``
                                                                 ` ` ``
                                                                 ` . ``
                                                                 . . ``
                                                                 . . ``
                                                                 . . ``
                                                                 . .```
                                                       `:;##nz#+**:;...
                                                       #xnxnxxxxxxMMMMxnz+*i;:.`     `.:i***+:
                                                      ,xxnxnxxxxxxxxxxxxxxxMMMMMMxn#+zzzzz+MWWz`
                                                      :xxnxnxxxxxxxxxxxxxxxxxxxxxxx#zzzzz#*WWWWn`
                                                      :Mxnxnxxxxxxxxxxxxxxxxxxxxxxx+####z+#WWWWW*
                                                      `nMnMnMMxxxxxxxxxxxxxxxxxxxxn+#####*nWWWWWx
                                                        ,+xxMMMMMMMMMMxxxxxxxxxxxxz######iMWWWWWW`
                                                           :i*#zxMMMMMMMMMMMMMMMxxnzzzzz#iWWWWWWW`
                                                                  .,;i+znxMMMMMMMMnzzzzzz*WWWWWWx
                                                                          `,:i+#nxxznzzzz*WWWWWW*
                                                                                  .:#nnnn+WWWWWx`
                                                                                     ,*zn#MWWWn.
                                                                                        .:+z#:








                                                                    ``````````````````````````````
                                                            `````......,,,,,,,,,..........`````````
                                                           ````.....,,,,,,,,,,,,,,,.........```````
                                                                `````````....`.````````````````````
                                                                                 `````````````````
*/
        })
    } catch (err) {
        throw err
    } finally {
        await knexConnection.disconnect()
    }
}
/*
let runRepeater = () => {} // tslint:disable-line:no-empty
const repeater = async () => {
    await execute()

    if (lastRowsFetched < 100) {
        await Promise.delay(600000)
    } else {
        await Promise.delay(500)
    }

    runRepeater()
}

runRepeater = () => {
    process.nextTick(() => {
        repeater()
            .then(() => {
                console.log('Execute done') // tslint:disable-line:no-console
            })
            .catch((err) => {
                throw err
            })
    })
}

runRepeater()
*/

execute()
    .then(() => {
        console.log('Execute done') // tslint:disable-line:no-console
    })