DataSpiderSDKによるスマートコントラクトアダプタの作成 #ブロックチェーン

スマートコントラクトアダプタの作成その１

今回から、DataSpiderSDKを用いてスマートコントラクトアダプタの作成例について紹介します。

なにをやるか

前回までの記事では、ブロックチェーンとNFT連携の実現に向けて紹介してきました。
実現したいことに対して実装をしてきたため、本来のパッケージアプリケーションソフトウェアとしてのアダプタとしては汎用性の低い実装となっていました。
今回からアダプタのブラッシュアップとして、汎用的なスマートコントラクトアダプタの実装とDataSpiderSDKが提供する機能について掲載します。
参照系のスマートコントラクト関数呼び出しを前提に紹介します。

実装方針

前回までの実装内容から、基本的にべた書きになっていた部分を動的に設定できるようにします。
基本的な実装コンセプトは、利用者が使用する機能に必要な情報を動的に指定できるようにするということです。

課題と改善点

TRONネットワークへの接続先が固定だったため、グローバルリソースモジュールを用いて接続先を動的に変更できるようにします。
呼び出すスマートコントラクトが固定だったため、スマートコントラクトアドレスの入力欄を設けて指定したスマートコントラクトへアクセスできるようにします。
呼び出すスマートコントラクト関数が固定だったため、指定したスマートコントラクトから関数情報を取得し指定できる設定項目を設けます。
スマートコントラクト関数と入出力するための項目が固定だったため、UIのテーブルモジュールを用いて必要な項目を追加、定義できるようにします。
その他、内部的に処理については、DataSpiderのお作法に馴染ませるように実装をすすめます。

DataSpiderSDKの主要な利用機能

接続先（エンドポイント）を動的に設定可能とするのがグローバルリソースです。
設定プロパティ画面にグローバルリソースを選択できる項目を設け実装します。

グローバルリソースとは、すべてのプロジェクトから利用できる共有リソースです。データベースやメールサーバ、FTP サーバなど外部システムへの接続はグローバルリソースとなります。グローバルリソースはシステムで非常に
重要なリソースとなります。
※ DataSpider Servista Component SDK 4.2 Getting Started ガイド第７章グローバルリソースについてより引用

画面イメージ

グローバルリースの画面イメージ

接続先設定欄を設けます。また、スマートコントラクトのアドレス、利用者の秘密鍵も併せて設定できるようにします。
参照系スマートコントラクトアダプタの設定画面
「接続先」欄にてグローバルリソースの設定項目を設けました。

関数名は、上記で入力したスマートコントラクトより取得し一覧から選択できるようにしました。

参照系スマートコントラクトが使用する入力側項目を設定できるテーブルを設けました。

出力側も同様です。参照系スマートコントラクトの戻り値（出力側パラメータ）を出力する項目設定です。

実行時の設定項目として、そのつど処理タイミングでアカウントを切り替える、さらにスマートコントラクトを選択できるようにしました。

DataSpiderSDKによるグローバルリソースの実装

アダプタに対応するグローバルリソースの実装にあたり、SDKのサンプルコードとして提供がされていました。

サンプルソース：sample_resource_adapter
AdapterModuleComponent内でResourceFactoryのインスタンスを生成することにより、アダプタからグローバルリソースのUIを呼び出すことができます。
今回のスマートコントラクトアダプタの実装においても同様の作法に従いました。

ソースコードの構成

スマートコントラクトアダプタのblockchain_tron配下に、ResourceFactoryを置きます。

グローバルリソースの実装例

TronAdapterModuleComponent内で、BlockchainTronGlobalResourceFactoryインスタンスを生成します。

package com.jpn.linux.dp.modules.adapter.Tron;

import com.appresso.ds.dp.spi.AdapterModuleComponent;
import com.appresso.ds.dp.spi.OperationFactory;
import com.appresso.ds.dp.spi.ResourceFactory;

public class TronAdapterModuleComponent extends AdapterModuleComponent {


	@Override
	// リソースファクトリのインスタンスを配列で返します。
	public ResourceFactory[] getResourceFactories() throws Exception {
		return new ResourceFactory[] {
				new BlockchainTronGlobalResourceFactory()
		};
	}

	@Override
	public OperationFactory[] getOperationFactories() throws Exception {
		return new OperationFactory[] {
				new GetTronOperationFactory()
		};
	}
}

あとは、BlockchainTronGlobalResourceFactory内でMetaDataを定義することよりよりグローバルリソースに表示されるようになります。

	@Override
	public ResourceMetaData getResourceMetaData(
			ResourceContext context) throws Exception {

		// ResourceMetaData を生成
		ResourceMetaData meta = new ResourceMetaData(this, context);
		// リソースのアイコン名を設定
		meta.setLabel("Tron接続設定(TronGrid)");
		meta.setDefaultType(ResourceInfo.TYPE_GLOBAL_RESOURCE);
		// プールのサポートを有効に設定
		meta.setPoolSupported(true);
		meta.setPoolDisabled(false);
		return meta;
	}

スマートコントラクト呼び出しと入出力マッピング部分の実装例

GetTronOperation.java

	public Map execute(Map inputData) throws Exception {
		Map res = new HashMap();

		LoggingContext log = getContext().log();

		Type[] smartContractFunctionInputParams;
		Column outCol;
		String outColValue;
		String smartContractResult;

		int outputSize = this.outputMappingItems.length;

		LocalDateTime now = LocalDateTime.now();
		DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy/MM/dd");

		Object data = inputData.get(KEY_INPUT);

		// 出力側TableDataBuilderを生成する。
		TableDataBuilder builder = DataBuilderFactory.newTableDataBuilder(getColumnOutputTypes(), isLargeData());

		log.info(builder.toString());

		try (TableRowIterator rowIterator = DataParserFactory.newTableRowIterator(data)) {

			// 出力側項目の出力開始を宣言する
			builder.startConstruction();

			// 入力側レコードの繰り返し処理
			while (rowIterator.hasNext()) {
				Row record = rowIterator.next();

				builder.startRow(); // 出力側行単位のデータを格納するバッファ

				/* スマートコントラクトの引数を生成
                *  入力側の項目を読み取りスマートコントラクトに渡す引数を生成します
                *  転送する内容は、はあらかじめ入力側の情報をもとに生成しておきます
                */
				smartContractFunctionInputParams = getSmartContractFunctionInputParams(
													record,
													this.inputItemIndex,
													this.inputSmartcontractItemIndexType);

				/* 生成したスマートコントラクト引数を渡しスマコン関数の実行
                *  生成した引数をスマートコントラクト関数を呼び出し、スマコン関数を実行します
                *  
                */
				smartContractResult = doSmartContract(smartContractFunctionInputParams);

				/* スマートコントラクトの戻り値を含め出力側バッファに転送します
                *  転送する内容は、はあらかじめ入力側および出力側の情報をもとに生成しておきます
                */
				for (int i = 0; i < outputSize; i++) {
					if (this.outputMappingItems[i].type == OUTPUT_TYPE_NONE ) {
						builder.column("");
					} else if (this.outputMappingItems[i].type == OUTPUT_TYPE_FROM_INPUT ) {
						outCol = record.getColumn(this.outputMappingItems[i].fromIndex);
						outColValue = getColumnValue(outCol);
						builder.column(outColValue);
					} else if (this.outputMappingItems[i].type == OUTPUT_TYPE_FROM_SMRESULT ) {
						builder.column(smartContractResult);
					}
				}

				builder.endRow();

			}

			builder.endConstruction();
			Object result = builder.getResult();

			res.put(KEY_OUTPUT, result);

		}

		return res;
	}

スクリプト実装例

スクリプトメイン
入力側マッピング
出力側マッピング

※ 入力側項目を出力する設定が有効な場合

次回は

更新系のスマートコントラクト関数呼び出しのためのアダプタについて紹介したいと思います。