import { expect, assert } from "chai";

const mysql = require('mysql')
const config = require('../src/background/config')
const {pool} = require('../src/background/mysql')

describe("sphinx", () => {
	let sphinx;

	it("init", function() {
		sphinx = mysql.createPool({
			connectionLimit: config.sphinx.connectionLimit,
			host     : config.sphinx.host,
			port     : config.sphinx.port
		});
		expect(sphinx)
	})

	it("insert",  function(done) {
		sphinx.query("INSERT INTO files(id, hash, path, pathIndex, size) VALUES(50001, 'a', 'bashaa', 'bashaa', '50')", (err) => {
			if(err)
				throw new Error(err)
      
			sphinx.query("INSERT INTO files(id, hash, path, pathIndex, size) VALUES(50002, 'b', 'biotu', 'biotu', '30')", (err) => {
				if(err)
					throw new Error(err)

				done()
			})
		})
	})

	it("select",  function(done) {
		sphinx.query("select * from files where hash = 'a'", (err, result) => {
			if(!result)
				throw new Error(err)
			if(result.length !== 1)
				throw new Error('not one result')
      
			if(result[0].size != 50)
				throw new Error('not 50 in field')

			done()
		})
	})

	it("search",  function(done) {
		sphinx.query("select * from files where MATCH('bashaa')", (err, result) => {
			if(!result)
				throw new Error(err)
			if(result.length !== 1)
				throw new Error('not one result')
      
			if(result[0].hash !== 'a')
				throw new Error('not a in hash')
			if(result[0].size != 50)
				throw new Error('not 50 in field')

			done()
		})
	})

	it("query limit", function(done) {
		this.timeout(15000);
		const test = async () => {
			const sphinx = await pool()
			let promises = []
			sphinx.query(`delete from feed where id >= 0`, () => {
				for(let i = 0; i < 500; i++)
					promises.push(sphinx.query(`insert into feed(id, data) values(${i}, 'a')`))
				Promise.all(promises).then(() => {
					sphinx.query(`delete from feed where id >= 0`, async () => { 
						await sphinx.end()
						done() 
					}) 
				})
			})
		}
		test()
	})

	it("escape", function () {
		assert.equal(sphinx.escape(`naru'to`), `'naru\\'to'`)
	})

	it("close pool", function(done) {
		sphinx.end(done)
	})
});