const mysql2 = require('mysql2/promise');
let connection;
class Parser {
    constructor() {
        this.defaultConf = {
            version: '0.1.88',
            results: {
                flat: [
                    ['price', 'price'],
                    ['model', 'model'],
                ]
            },
            results_format: '$query: $title\\n',
            parsecodes: {
                200: 1,
            },
            pagecount: 100,
            max_size: 200 * 1024,
            login: 'workflow',
            pass: 'pass',
            port: '3306',
            host: '127.0.0.1',
            db: 'app',
        };
         this.editableConf = [
            ['login', ['textfield', 'Login']],
            ['pass', ['textfield', 'Password']],
            ['port', ['textfield', 'port']],
            ['host',['textfield', 'host']],
            ['db', ['textfield', 'Database']],
        ];
    }
    async init(){
        connection = await mysql2.createConnection({
                host: this.conf.host,
                port: this.conf.port,
                user: this.conf.login,
                password: this.conf.pass,
                database: this.conf.db
            });
        let mainTable = await connection.query('create table if not exists main (id_ad int primary key, link varchar(200), title varchar(500), section varchar(200), countAd varchar(100),sqrent varchar(200),pricerent varchar(200), price bigint,oldprice varchar(500) ,phone varchar(500),seller varchar(200),description varchar(10000), views varchar(100), date varchar(500), city varchar(100), adres varchar(500), photo varchar(2000))');
    }

    *parse(set, results) {
        //this.logger.put("Start scraping query: " + set.query);


        let response = yield this.request('GET', set.query, {}, {
            'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.77 Safari/537.36',
            check_content: ['<\/html>'],
            decode: 'auto-html',
        });


        if(response.success) {
            let price = response.data.match(/<meta.*property="product:price:amount".*content="(.*)".*\/>/i);
            if(price)
                results.price = price[1];
            let model = response.data.match(/meta.*itemprop="productId".*content="(.*)".*\/>/i);
            if(model)
                results.model = model[1];


        }

        results.success = response.success;

        return results;

        this.logger.put('insert');
        //this.logger.put(JSON.stringify(charact));
        //let ins = await this.insert(results);

        let ins = yield* this.insert(results);

    }


    async insert(results){
    	let model ;
        let price ;
       let sqlins = `insert into sb_pricelog(id,sid,pprice) values(NULL,'${results.model}','${results.price}')`;
        let [charact,fields] = await connection.execute(sqlins);



    }





}