Add method to get contract call transaction

xiuxiufxx · xiuxiufxx · commit 8dac34eaddf5 · 2022-03-25T15:48:59.000+08:00
diff --git a/src/index.js b/src/index.js
@@ -577,6 +577,48 @@ ChainsqlAPI.prototype.getAccountTransactions = function (address, opts, cb) {
 	}
 };
 
+ChainsqlAPI.prototype.getContractTransactions = function (address, opts, cb) {
+	let callback, newOpt, singleArg;
+	let isCallback = false;
+	switch (arguments.length) {
+	case 1:
+		newOpt = {};
+		break;
+	case 2:
+		singleArg = arguments[1];
+		if ((typeof singleArg) === "function") {
+			callback = singleArg;
+			isCallback = true;
+		} else if ((typeof singleArg) === "object") {
+			newOpt = singleArg;
+		} else {
+			throw chainsqlError("wrong params, please check");
+		}
+		break;
+	case 3:
+		newOpt = opts;
+		if ((typeof cb) === "function") {
+			callback = cb;
+			isCallback = true;
+		} else {
+			throw chainsqlError("wrong params, please check");
+		}
+		break;
+	default:
+		throw chainsqlError("wrong params, please check");
+	}
+
+	if (isCallback) {
+		this.api.getContractTransactions(address, newOpt).then(function (data) {
+			callback(null, data);
+		}).catch(function (err) {
+			callback(err, null);
+		});
+	} else {
+		return this.api.getContractTransactions(address, newOpt);
+	}
+};
+
 ChainsqlAPI.prototype.getTransaction = function (hash,meta,meta_chain,cb) {
 	if ((typeof cb) != 'function') {
 		return this.api.getTransaction(hash,meta,meta_chain);
diff --git a/test/testRipple.js b/test/testRipple.js
@@ -33,6 +33,7 @@ var user3 = {
 var tagStep = {
     active: 1, gateWay: 2, escrow: 3,
     balances: 4, getLedger: 5, getTxs: 6,authorize:7,
+    getContractTxs:8,getContractTxsAsync:9,
 }
 var sCurrency = "aaa"
 var whiteLists = [
@@ -50,7 +51,7 @@ async function main() {
     c.as(root);
     c.setRestrict(true);
     /**************************************/
-    let nStep = tagStep.authorize;
+    let nStep = tagStep.getContractTxs;
     switch (nStep) {
         case tagStep.active: testActive(); break;// 激活若干账户
         case tagStep.gateWay: testGateWay(); break;//部署网管，信任，发行币转账
@@ -59,6 +60,8 @@ async function main() {
         case tagStep.getTxs: testTransactions(); break;
         case tagStep.getLedger: testGetLedger(); break;
         case tagStep.authorize: testAuthorize();break;
+        case tagStep.getContractTxs: getContractTransactions();break;
+        case tagStep.getContractTxsAsync: getContractTransactionsAsync();break;
         default: break;
     }
     /**************************************/
@@ -199,7 +202,7 @@ var testBalances = async function () {
 var testTransactions = async function () {
     let res;
     //
-    let bAll_one = true;
+    let bAll_one = false;
     let bMore = true;
     //
     if (bAll_one) {
@@ -216,7 +219,7 @@ var testTransactions = async function () {
     if (bMore) {
         let nLimit = 10;
         var options = {
-            limit: nLimit
+            limit: nLimit,
         };
         while (true) {
             res = await c.api.getTransactions(root.address, options);
@@ -263,4 +266,47 @@ var testAuthorize = async function(){
         console.error("accountAuthorize ", error);
     }
     
+}
+
+var getContractTransactions = async function(){
+    try {
+        var options = {
+            limit: 3,
+            ledgerIndexMin:1,
+            ledgerIndexMax:100,
+             marker:{
+                ledger:53,
+                seq:5300002
+             }
+        };
+		var obj = await c.getContractTransactions("zwCkG85oeRsmMpQs2auAV8Tc6kQF5aWsr6", options);
+		console.log("getContractTransactions ", obj);
+    } catch (error) {
+        console.error("accountAuthorize ", error);
+    }
+    
+}
+
+var getContractTransactionsAsync = async function(){
+    try {
+        var options = {
+            limit: 3,
+            ledgerIndexMin:1,
+            ledgerIndexMax:100,
+             marker:{
+                ledger:53,
+                seq:5300002
+             }
+        };
+		var obj = await c.getContractTransactions("zwCkG85oeRsmMpQs2auAV8Tc6kQF5aWsr6", options,  function callback(err,data){
+            if(err)
+                console.err("getContractTransactionsAsync", err)
+            else
+                console.info("getContractTransactionsAsync", data)
+        });
+		//console.log("getContractTransactions ", obj);
+    } catch (error) {
+        console.error("accountAuthorize ", error);
+    }
+    
 }
