// tslint:disable:no-var-requires
import { createRequire } from "module";
import RpcQuery from "./rpcQuery.js";
const require = createRequire(import.meta.url);
const DHT = require("@hyperswarm/dht");
export default class RpcNetwork {
    constructor(dht = new DHT()) {
        this._majorityThreshold = 0.75;
        this._maxTtl = 12 * 60 * 60;
        this._queryTimeout = 30;
        this._relays = [];
        this._force = false;
        this._dht = dht;
        this._ready = this._dht.ready();
    }
    get ready() {
        return this._ready;
    }
    get relays() {
        return this._relays;
    }
    get dht() {
        return this._dht;
    }
    get maxTtl() {
        return this._maxTtl;
    }
    set maxTtl(value) {
        this._maxTtl = value;
    }
    get queryTimeout() {
        return this._queryTimeout;
    }
    set queryTimeout(value) {
        this._queryTimeout = value;
    }
    get majorityThreshold() {
        return this._majorityThreshold;
    }
    set majorityThreshold(value) {
        this._majorityThreshold = value;
    }
    get force() {
        return this._force;
    }
    set force(value) {
        this._force = value;
    }
    addRelay(pubkey) {
        this._relays.push(pubkey);
        this._relays = [...new Set(this._relays)];
    }
    removeRelay(pubkey) {
        if (!this._relays.includes(pubkey)) {
            return false;
        }
        delete this._relays[this._relays.indexOf(pubkey)];
        this._relays = Object.values(this._relays);
        return true;
    }
    clearRelays() {
        this._relays = [];
    }
    query(query, chain, data = {}, force = false) {
        return new RpcQuery(this, {
            query,
            chain,
            data,
            force: force || this._force,
        });
    }
}