ptarmigan.service.ts

import { Injectable } from '@nestjs/common';
import { exec, execSync } from 'child_process';
import { ConfigService } from 'nestjs-config';
import * as rp from 'request-promise';
import * as jayson from 'jayson/promise';
import { Logger } from '@nestjs/common';
import * as fs from 'fs';
import * as dotenv from 'dotenv';

@Injectable()
export class PtarmiganService {
    private port: number;
    private host: string;
    private client: jayson.Client;
    private path: string;
    private nodePath: string;

    constructor(
        private readonly config: ConfigService,
    ) {
        this.config = config;
        this.port = Number.parseInt(this.config.get('ptarmigan.ptarmdRpcPort'), 10),
            this.host = this.config.get('ptarmigan.ptarmdHost'),
            this.path = this.config.get('ptarmigan.ptarmdPath'),
            this.nodePath = this.config.get('ptarmigan.ptarmdNodePath'),
            this.client = jayson.Client.tcp({
                port: this.port,
                host: this.host,
            });
    }

    async requestTCP(method, params): Promise<string> {
        const req = this.client.request(method, params);
        Logger.log(params);
        return Promise.resolve(req)
            .then((res) => {
                Logger.log(res);
                return res;
            })
            .catch((err) => {
                Logger.log(err);
                return err;
            });
    }

    commandExecute(command: string, params: string[]): Buffer {
        let param = '';
        params.forEach(s => {
            param = param + ' ' + s;
        });
        return execSync(this.path + '/' + command + '' + param, { timeout: 30000 });
    }

    commandExecuteShowdbGetChannels(): Buffer {
        return execSync(this.path + '/showdb' + ' --datadir ' + this.nodePath + ' -c ', { timeout: 30000 });
    }

    commandExecuteShowdbListGossipNode(): Buffer {
        return execSync(this.path + '/showdb' + ' --datadir ' + this.nodePath + ' -n ', { timeout: 30000 });
    }

    commandExecuteRoutingGetRoute(senderNodeId: string, receiverNodeId: string): Buffer {
        return execSync(this.path + '/routing' + ' -d ' + this.nodePath + ' -s ' + senderNodeId + ' -r ' + receiverNodeId, { timeout: 30000 });
    }

    async commandExecuteOpenChannel(peerNodeId: string, fundingSat: number, pushMsat: number, feeratePerKw: number): Promise<string> {
        try {
            return await this.requestTCP('fund', [peerNodeId, '0.0.0.0', 0, '', 0, fundingSat, pushMsat, feeratePerKw]);
        } catch (error) {
            return error.stderr.toString();
        }
    }
}