import * as SQLite from '../deps/types/sqlite3.js';
import { createSQLiteHTTPPool } from '../dist/index.js';

import { assert } from 'chai';

const remoteURL = 'https://velivole.b-cdn.net/maptiler-osm-2017-07-03-v3.6.1-europe.mbtiles';

for (const type of ['sync', 'shared'] as const) {
  describe(`SQLite HTTP pool (${type})`, () => {
    const workers = 8;
    const requests = type === 'shared' ? 128 : 16;

    it('should automatically handle concurrent connections', (done) => {
      const poolq = createSQLiteHTTPPool({ workers, httpOptions: { backendType: type } });

      poolq.then((pool) => pool.open(remoteURL).then(() => {
        assert.strictEqual(pool.backendType, type);
        const r: Promise<SQLite.RowArray>[] = [];
        for (let i = 0; i < requests; i++)
          r.push(pool.exec('SELECT zoom_level, tile_column, tile_row, tile_data FROM tiles ' +
            'WHERE zoom_level = 10 AND tile_column = $col AND tile_row = $row',
            { $col: 500 + i, $row: 600 + i })
            .then((results) => {
              assert.lengthOf(results, 1);
              assert.sameMembers(results[0].columnNames, ['zoom_level', 'tile_column', 'tile_row', 'tile_data']);
              assert.strictEqual(results[0].row[0], 10);
              assert.strictEqual(results[0].row[1], 500 + i);
              assert.strictEqual(results[0].row[2], 600 + i);
              assert.instanceOf(results[0].row[3], Uint8Array);
              return results[0];
            }));

        return Promise.all(r).then((resp) => {
          const tiles = resp.flat();
          assert.lengthOf(tiles, requests);
          done();
        });
      }))
        .finally(() => {
          poolq.then((pool) => pool.close());
        })
        .catch(done);
    });

    it(`should handle SQL errors gracefully (${type})`, (done) => {
      const poolq = createSQLiteHTTPPool({ workers });

      poolq.then((pool) => pool.open(remoteURL).then(() => {
        const r: Promise<SQLite.RowArray[]>[] = [];
        for (let i = 0; i < requests; i++)
          r.push(pool.exec('SELECT zoom_level, tile_column, tile_row, tile_data FROM tiles ' +
            'WHERE zoom_level = -1 AND tile_column = $col AND tile_row = $row',
            { $col: 600 + i, $row: 600 + i })
            .then((results) => {
              assert.lengthOf(results, 0);
              return results;
            }));

        return Promise.all(r).then((resp) => {
          const tiles = resp.flat();
          assert.lengthOf(tiles, 0);
          done();
        });
      }))
        .finally(() => {
          poolq.then((pool) => pool.close());
        })
        .catch(done);
    });

    it(`should handle opening errors gracefully (${type})`, (done) => {
      createSQLiteHTTPPool({ workers: 1 })
        .then((pool) => pool.open('https://black.hole')
          .then(() => {
            done('beyond the event horizon');
          })
          .catch((e) => {
            pool.close();
            assert.include(e.result.message, 'sqlite3 result code 14: unable to open database file');
            done();
          })
          .catch((e) => {
            // Obviously a major malfunction, the above code should never throw
            done(e);
          })
        );
    });
  });
}