'use strict';

const axios = require('axios');
const conf = require('../conf/conf');

class PorkBun{
	baseUrl = 'https://api.porkbun.com/api/json/v3';

	constructor(apiKey, secretApiKey){
		this.apiKey = apiKey;
		this.secretApiKey = secretApiKey;
	}

	async post(url, data){
		let res;
		try{
			data = {
				...(data || {}),
				secretapikey: this.secretApiKey,
				apikey: this.apiKey,
			};
			res = await axios.post(`${this.baseUrl}${url}`, data);

			return res;
		}catch(error){
			throw new Error(`PorkPun API ${error.response.status}: ${error.response.data.message}`)
		}
	}

	__typeCheck(type){
		if(!['A', 'MX', 'CNAME', 'ALIAS', 'TXT', 'NS', 'AAAA', 'SRV', 'TLSA', 'CAA', 'HTTPS', 'SVCB'].includes(type)) throw new Error('PorkBun API: Invalid type passed')
	}

	__parseName(domain, name){
		if(name && !name.endsWith('.'+domain)){
			return `${name}.${domain}`
		}
		return name;
	}

	async getRecords(domain, options){
		let res = await this.post(`/dns/retrieve/${domain}`);
		if(!options) return res.data.records;

		if(options.type) this.__typeCheck(options.type);
		if(options.name) options.name = this.__parseName(domain, options.name);
		let records = [];

		for(let record of res.data.records){
			let matchCount = 0
			for(let option in options){
				if(record[option] === options[option] && ++matchCount === Object.keys(options).length){
					records.push(record)
				}
				// console.log('option', option, options[option], record[option], matchCount)
			}
		}

		return records;
	}

	async deleteRecordById(domain, id){
		let res = this.post(`/dns/delete/${domain}/${id}`);
		return res.data;
	}

	async deleteRecords(domain, options){
		let records = await this.getRecords(domain, options);
		// console.log('PorkBun.deleteRecords', records)
		for(let record of records){
			await this.deleteRecordById(domain, record.id)
		}
	}

	async createRecord(domain, options){
		this.__typeCheck(options.type);
		if(!options.content) throw new Error('PorkBun API: `content` key is required for this action')
		// if(options.name) options.name = this.__parseName(domain, options.name);
		// console.log('PorkBun.createRecord to send:', domain, options)

		let res = this.post(`/dns/create/${domain}`, options);
		return res.data;
	}

	async createRecordForce(domain, options){
		let {content, ...removed} = options;
		// console.log('new options', removed)
		let records = await this.getRecords(domain, removed);
		// console.log('createRecordForce', records)
		if(records.length){
			// console.log('calling delete on', records[0].id)
			// process.exit(0)
			await this.deleteRecordById(domain, records[0].id)
		}
		return await this.createRecord(domain, options)
	}
}

module.exports = PorkBun;


if(require.main === module){(async function(){try{
	let porkBun = new PorkBun(conf.porkBun.apiKey, conf.porkBun.secretApiKey);

	// console.log(await porkBun.deleteRecordById('holycore.quest', '415509355'))
	// console.log('IIFE', await porkBun.createRecordForce('holycore.quest', {type:'A', name: 'testapi', content: '127.0.0.5'}))
	console.log('IIFE', await porkBun.getRecords('holycore.quest', {type:'A', name: 'testapi'}))
}catch(error){
	console.log('IIFE Error:', error)
}})()}