import {EndPoint} from '../../entities'
import {Transactions} from '../Transactions'

export abstract class Query<T = any, R = any> extends Transactions {
    public abstract ENDPOINT: `chain/${EndPoint}`

    public isEncrypted = false

    public requestTimeout = 5000

    public abstract getData(): T

    public async execute(publicKey: string, privateKey: string = ''): Promise<R> {
        this.publicKey = publicKey
        this.privateKey = privateKey

        const result = await this.multicastServers({
            body: JSON.stringify(this.getData()),
            endpoint: this.getEndPoint(),
            requestTimeout: this.requestTimeout,
        })

        try {
            return this.isEncrypted ? await this.decrypt(result) : result
        } catch (error) {
            this.config.logger?.({
                context: {error: error as Error},
                type: 'decrypt',
            })
            throw error
        }
    }

    public async decrypt(result: any): Promise<R> {
        throw new Error('Not implemented')
    }

    public getEndPoint(): string {
        return this.ENDPOINT
    }
}