AssetManagement.ts

/*
 * Copyright 2020-2021 Hyperledger Cactus Contributors
 * SPDX-License-Identifier: Apache-2.0
 *
 * AssetManagement.ts
 */

import { LPInfoHolder } from "../../packages/cactus-cmd-socketio-server/src/main/typescript/routing-interface/util/LPInfoHolder";
import { Verifier } from "../../packages/cactus-cmd-socketio-server/src/main/typescript/verifier/Verifier";
import { ContractInfoHolder } from "../../packages/cactus-cmd-socketio-server/src/main/typescript/routing-interface/util/ContractInfoHolder";
import { ConfigUtil } from "../../packages/cactus-cmd-socketio-server/src/main/typescript/routing-interface/util/ConfigUtil";

const fs = require("fs");
const path = require("path");
const config: any = ConfigUtil.getConfig();
import { getLogger } from "log4js";
const moduleName = "AssetManagement";
const logger = getLogger(`${moduleName}`);
logger.level = config.logLevel;

export class AssetManagement {
  private connectInfo: LPInfoHolder = null; // connection information
  private contractInfoholder: ContractInfoHolder = null; // contract information
  private verifierEthereum: Verifier = null;

  constructor() {
    this.connectInfo = new LPInfoHolder();
    this.contractInfoholder = new ContractInfoHolder();
  }

  addAsset(amount: string): Promise<any> {
    return new Promise((resolve, reject) => {
      if (this.verifierEthereum === null) {
        logger.debug("create verifierEthereum");
        const ledgerPluginInfo: string =
          this.connectInfo.getLegerPluginInfo("84jUisrs");
        this.verifierEthereum = new Verifier(ledgerPluginInfo);
      }

      // for Neo
      const contractInfo: string =
        this.contractInfoholder.getContractInfo("AssetContract");
      const contractInfoObj: {} = JSON.parse(contractInfo);
      const coinbase = contractInfoObj["_eth"]["coinbase"];
      const address = contractInfoObj["address"];
      const abi = contractInfoObj["abi"];
      const contract = {
        address: address,
        abi: abi,
      };
      const method = {
        type: "contract",
        command: "addAsset",
        function: "sendTransaction",
      };
      const template = "default";
      const args = { args: [amount, { from: coinbase }] };
      // const method = "default";
      // const args = {"method": {type: "contract", command: "addAsset", function: "sendTransaction"}, "args": {"args": [amount, {from: coinbase}]}};

      this.verifierEthereum
        .sendSyncRequest(contract, method, args)
        .then((result) => {
          const response = {
            status: result.status,
            "Transaction hash": result.data,
          };
          resolve(response);
        })
        .catch((err) => {
          logger.error(err);
          reject(err);
        });
    });
  }

  getAsset(): Promise<any> {
    return new Promise((resolve, reject) => {
      if (this.verifierEthereum === null) {
        logger.debug("create verifierEthereum");
        const ledgerPluginInfo: string =
          this.connectInfo.getLegerPluginInfo("84jUisrs");
        this.verifierEthereum = new Verifier(ledgerPluginInfo);
      }

      // for Neo
      const contractInfo: string =
        this.contractInfoholder.getContractInfo("AssetContract");
      const contractInfoObj: {} = JSON.parse(contractInfo);
      const address = contractInfoObj["address"];
      const abi = contractInfoObj["abi"];
      const contract = {
        address: address,
        abi: abi,
      };
      const method = {
        type: "contract",
        command: "getAsset",
        function: "call",
      };
      const template = "default";
      const args = { args: [] };
      // const method = "default";
      // const args = {"method": {type: "contract", command: "getAsset", function: "call"}, "args": {"args": []}};

      this.verifierEthereum
        .sendSyncRequest(contract, method, args)
        .then((result) => {
          const response = {
            status: result.status,
            asset: parseFloat(result.data),
          };
          resolve(response);
        })
        .catch((err) => {
          logger.error(err);
          reject(err);
        });
    });
  }
}