Paymaster integration

examples/kc-submission-paymaster-demo.js

@@ -0,0 +1,123 @@
+import DKG from '../index.js';
+import { BLOCKCHAIN_IDS } from '../constants/constants.js';
+import { ethers } from 'ethers';
+import 'dotenv/config';
+
+const OT_NODE_HOSTNAME = 'http://localhost';
+const OT_NODE_PORT = '8900';
+const BLOCKCHAIN_NAME = BLOCKCHAIN_IDS.HARDHAT_1;
+
+// IMPORTANT: Don't forget to add your PRIVATE_KEY to the .env file.
+const DkgClient = new DKG({
+    endpoint: OT_NODE_HOSTNAME,
+    port: OT_NODE_PORT,
+    blockchain: {
+        name: BLOCKCHAIN_NAME,
+        privateKey: process.env.PRIVATE_KEY,
+    },
+    maxNumberOfRetries: 300,
+    frequency: 2,
+    contentType: 'all',
+    nodeApiVersion: '/v1',
+});
+
+function divider() {
+    console.log('==================================================');
+    console.log('==================================================');
+    console.log('==================================================');
+}
+
+(async () => {
+    const content = {
+        public: {
+            '@context': 'https://www.schema.org',
+            '@id': 'urn:us-cities:info:new-york',
+            '@type': 'City',
+            name: 'New York',
+            state: 'New York',
+            population: '8,336,817',
+            area: '468.9 sq mi',
+        },
+        private: {
+            '@context': 'https://www.schema.org',
+            '@id': 'urn:us-cities:data:new-york',
+            '@type': 'CityPrivateData',
+            crimeRate: 'Low',
+            averageIncome: '$63,998',
+            infrastructureScore: '8.5',
+            relatedCities: [
+                { '@id': 'urn:us-cities:info:los-angeles', name: 'Los Angeles' },
+                { '@id': 'urn:us-cities:info:chicago', name: 'Chicago' },
+            ],
+        },
+    };
+
+    const nodeInfo = await DkgClient.node.info();
+    console.log('======================== NODE INFO RECEIVED');
+    console.log(nodeInfo);
+
+    console.log('======================== DEPLOY PAYMASTER');
+    const { deployer, paymasterAddress } = await DkgClient.blockchain.createPaymaster();
+    console.log("Paymaster address: ", paymasterAddress);
+
+    console.log('======================== WHITELIST ADDRESS');
+    await DkgClient.blockchain.addAllowedAddressPaymaster(deployer, paymasterAddress);
+
+    const isAllowed = await DkgClient.blockchain.isAddressAllowedPaymaster(deployer, paymasterAddress);
+    console.log("Address whitelisted: ", isAllowed);
+
+    await DkgClient.asset.increaseAllowance(ethers.parseEther('100'), {spenderAddress: paymasterAddress});
+
+    console.log('======================== FUND PAYMASTER');
+    await DkgClient.blockchain.fundPaymaster(paymasterAddress, ethers.parseEther('10'));
+
+    let paymasterBalance = await DkgClient.blockchain.getPaymasterBalance(paymasterAddress);
+    console.log("Starting paymaster balance: ", paymasterBalance);
+
+    divider();
+
+    console.log('======================== PUBLISH');
+    console.time('Publish (1 replication, 3 finalizations)');
+    const create_result = await DkgClient.asset.create(content, {
+        epochsNum: 2,
+        minimumNumberOfFinalizationConfirmations: 3,
+        minimumNumberOfNodeReplications: 1,
+        paymaster: paymasterAddress,
+    });
+    console.timeEnd('Publish (1 replication, 3 finalizations)');
+
+    console.log(JSON.stringify(create_result));
+
+    divider();
+
+    paymasterBalance = await DkgClient.blockchain.getPaymasterBalance(paymasterAddress);
+    console.log("Paymaster balance after the publish: ", paymasterBalance);
+
+    console.time('get');
+    const get_result = await DkgClient.asset.get(create_result.UAL, {
+        contentType: 'all',
+    });
+    console.log('======================== ASSET GET');
+    console.log(get_result);
+    console.timeEnd('get');
+
+    divider();
+
+    const publishFinalityResult = await DkgClient.graph.publishFinality(create_result.UAL);
+    console.log('======================== ASSET FINALITY');
+    console.log(publishFinalityResult);
+
+    divider();
+    const queryOperationResult = await DkgClient.graph.query(
+        `
+        PREFIX schema: <http://schema.org/>
+        SELECT ?s ?stateName
+        WHERE {
+            ?s schema:state ?stateName .
+            }
+            `,
+        'SELECT',
+    );
+    console.log('======================== ASSET QUERY');
+    console.log(queryOperationResult);
+})();