feat: native request

package.json

@@ -8,7 +8,9 @@
     "prepare": "husky install",
     "retrieve": "node src/retrieveRequest.js",
     "create": "node src/createRequest.js",
-    "pay": "node src/payRequest.js"
+    "create-native": "node src/createRequestNative.js",
+    "pay": "node src/payRequest.js",
+    "pay-native": "node src/payRequestNative.js"
   },
   "author": "",
   "license": "ISC",

src/createRequestNative.js

@@ -0,0 +1,74 @@
+(async () => {
+  const {
+    RequestNetwork,
+    Types,
+    Utils,
+  } = require("@requestnetwork/request-client.js");
+  const {
+    EthereumPrivateKeySignatureProvider,
+  } = require("@requestnetwork/epk-signature");
+  const { config } = require("dotenv");
+  const { Wallet } = require("ethers");
+
+  // Load environment variables from .env file
+  config();
+
+  const epkSignatureProvider = new EthereumPrivateKeySignatureProvider({
+    method: Types.Signature.METHOD.ECDSA,
+    privateKey: process.env.PAYEE_PRIVATE_KEY, // Must include 0x prefix
+  });
+
+  const requestClient = new RequestNetwork({
+    nodeConnectionConfig: {
+      baseURL: "https://sepolia.gateway.request.network/",
+    },
+    signatureProvider: epkSignatureProvider,
+  });
+
+  // In this example, the payee is also the payer and payment recipient.
+  const payeeIdentity = new Wallet(process.env.PAYEE_PRIVATE_KEY).address;
+  const payerIdentity = payeeIdentity;
+  const paymentRecipient = payeeIdentity;
+  const feeRecipient = "0x0000000000000000000000000000000000000000";
+
+  const requestCreateParameters = {
+    requestInfo: {
+      currency: {
+        type: Types.RequestLogic.CURRENCY.ETH,
+        value: "ETH",
+        network: "sepolia",
+      },
+      expectedAmount: "1000000000000000000",
+      payee: {
+        type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+        value: payeeIdentity,
+      },
+      payer: {
+        type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+        value: payerIdentity,
+      },
+      timestamp: Utils.getCurrentTimestampInSecond(),
+    },
+    paymentNetwork: {
+      id: Types.Extension.PAYMENT_NETWORK_ID.ETH_FEE_PROXY_CONTRACT,
+      parameters: {
+        paymentNetworkName: "sepolia",
+        paymentAddress: paymentRecipient,
+        feeAddress: feeRecipient,
+        feeAmount: "0",
+      },
+    },
+    contentData: {
+      reason: "🍕",
+      dueDate: "2023.06.16",
+    },
+    signer: {
+      type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+      value: payeeIdentity,
+    },
+  };
+
+  const request = await requestClient.createRequest(requestCreateParameters);
+  const requestData = await request.waitForConfirmation();
+  console.log(JSON.stringify(requestData));
+})();

src/payRequest.js

@@ -15,7 +15,6 @@
   } = require("@requestnetwork/payment-processor");
   const { providers, Wallet } = require("ethers");
   const { config } = require("dotenv");
-  const { Wallet } = require("ethers");
 
   // Load environment variables from .env file
   config();

src/payRequestNative.js

@@ -0,0 +1,134 @@
+(async () => {
+  const {
+    RequestNetwork,
+    Types,
+    Utils,
+  } = require("@requestnetwork/request-client.js");
+  const {
+    EthereumPrivateKeySignatureProvider,
+  } = require("@requestnetwork/epk-signature");
+  const {
+    approveErc20,
+    hasSufficientFunds,
+    hasErc20Approval,
+    payRequest,
+  } = require("@requestnetwork/payment-processor");
+  const { providers, Wallet } = require("ethers");
+  const { config } = require("dotenv");
+
+  // Load environment variables from .env file
+  config();
+
+  const epkSignatureProvider = new EthereumPrivateKeySignatureProvider({
+    method: Types.Signature.METHOD.ECDSA,
+    privateKey: process.env.PAYEE_PRIVATE_KEY, // Must include 0x prefix
+  });
+
+  const requestClient = new RequestNetwork({
+    nodeConnectionConfig: {
+      baseURL: "https://sepolia.gateway.request.network/",
+    },
+    signatureProvider: epkSignatureProvider,
+  });
+
+  const payeeIdentity = new Wallet(process.env.PAYEE_PRIVATE_KEY).address;
+  const payerIdentity = payeeIdentity;
+  const paymentRecipient = payeeIdentity;
+  const feeRecipient = "0x0000000000000000000000000000000000000000";
+
+  const requestCreateParameters = {
+    requestInfo: {
+      currency: {
+        type: Types.RequestLogic.CURRENCY.ETH,
+        value: "ETH",
+        network: "sepolia",
+      },
+      expectedAmount: "100000000000000000", // 0.1 ETH
+      payee: {
+        type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+        value: payeeIdentity,
+      },
+      payer: {
+        type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+        value: payerIdentity,
+      },
+      timestamp: Utils.getCurrentTimestampInSecond(),
+    },
+    paymentNetwork: {
+      id: Types.Extension.PAYMENT_NETWORK_ID.ETH_FEE_PROXY_CONTRACT,
+      parameters: {
+        paymentNetworkName: "sepolia",
+        paymentAddress: paymentRecipient,
+        feeAddress: feeRecipient,
+        feeAmount: "0",
+      },
+    },
+    contentData: {
+      reason: "🍕",
+      dueDate: "2023.06.16",
+    },
+    signer: {
+      type: Types.Identity.TYPE.ETHEREUM_ADDRESS,
+      value: payeeIdentity,
+    },
+  };
+
+  const request = await requestClient.createRequest(requestCreateParameters);
+  let requestData = await request.waitForConfirmation();
+  console.log(`Created Request: ${JSON.stringify(requestData)}`);
+
+  const provider = new providers.JsonRpcProvider(
+    process.env.JSON_RPC_PROVIDER_URL,
+  );
+  const payerWallet = new Wallet(
+    process.env.PAYER_PRIVATE_KEY, // Must have 0x prefix
+    provider,
+  );
+
+  console.log(
+    `Checking if payer ${payerWallet.address} has sufficient funds...`,
+  );
+  const _hasSufficientFunds = await hasSufficientFunds(
+    requestData,
+    payerWallet.address,
+    {
+      provider: provider,
+    },
+  );
+  console.log(`_hasSufficientFunds = ${_hasSufficientFunds}`);
+  if (!_hasSufficientFunds) {
+    throw new Error(`Insufficient Funds: ${payerWallet.address}`);
+  }
+
+  console.log(
+    `Checking if payer ${payerWallet.address} has sufficient approval...`,
+  );
+  const _hasErc20Approval = await hasErc20Approval(
+    requestData,
+    payerWallet.address,
+    provider,
+  );
+  console.log(`_hasErc20Approval = ${_hasErc20Approval}`);
+  if (!_hasErc20Approval) {
+    console.log(`Requesting approval...`);
+    const approvalTx = await approveErc20(requestData, payerWallet);
+    await approvalTx.wait(2);
+    console.log(`Approval granted. ${approvalTx.hash}`);
+  }
+
+  const paymentTx = await payRequest(requestData, payerWallet);
+  await paymentTx.wait(2);
+  console.log(`Payment complete. ${paymentTx.hash}`);
+
+  let startTime = Date.now();
+  while (requestData.balance?.balance < requestData.expectedAmount) {
+    requestData = await request.refresh();
+    console.log(`current balance = ${requestData.balance?.balance}`);
+    await new Promise((resolve) => setTimeout(resolve, 1000));
+    // Check if 5 seconds have passed, and if so, break out of the loop
+    if (Date.now() - startTime >= 5000) {
+      console.log("Timeout: Exiting loop after 5 seconds.");
+      break;
+    }
+  }
+})();