feat(server): deploy contract

aeternity · Jul 18, 2022 · 05c89a0 · 05c89a0
1 parent 168ebfa
commit 05c89a0
Show file tree

Hide file tree

Showing 6 changed files with 65 additions and 6 deletions.
diff --git a/server/.eslintrc.js b/server/.eslintrc.js
@@ -40,6 +40,8 @@ module.exports = {
       { devDependencies: ["**/*.test.ts", "**/*.spec.ts"] },
     ],
     "@typescript-eslint/no-unsafe-return": 0,
+    "@typescript-eslint/no-unsafe-call": 0,
+    "@typescript-eslint/ban-ts-comment": 0,
     "@typescript-eslint/no-shadow": 0,
     "@typescript-eslint/no-explicit-any": 0,
     "@typescript-eslint/no-unsafe-member-access": 0,

diff --git a/server/src/services/bot/bot.service.ts b/server/src/services/bot/bot.service.ts
@@ -9,7 +9,7 @@ import { EncodedData } from '@aeternity/aepp-sdk/es/utils/encoder';
 import BigNumber from 'bignumber.js';
 import axios, { AxiosError } from 'axios';
 import { setTimeout } from 'timers/promises';
-import { genesisFund } from '../sdk/sdk.service';
+import { deployContract, genesisFund } from '../sdk/sdk.service';
 import { IS_USING_LOCAL_NODE, FAUCET_PUBLIC_ADDRESS, sdk } from '../sdk';
 import logger from '../../logger';
 
@@ -137,6 +137,7 @@ export async function registerEvents(
 
     if (status === 'open') {
       if (!channelPool.has(configuration.initiatorId)) {
+        void deployContract(configuration.initiatorId, channel);
         addChannel(channel, configuration);
       }
     }

diff --git a/server/src/services/sdk/sdk.constants.ts b/server/src/services/sdk/sdk.constants.ts
@@ -22,3 +22,15 @@ export const FAUCET_ACCOUNT = IS_USING_LOCAL_NODE
     },
   })
   : null;
+
+export const CONTRACT_CONFIGURATION = {
+  deposit: 4.4e18,
+  vmVersion: 5,
+  abiVersion: 3,
+};
+
+// TODO: Remove me
+export const CONTRACT_SOURCE = `
+  contract Identity =
+    entrypoint getArg(x : int) : int = x
+  `;
diff --git a/server/src/services/sdk/sdk.service.ts b/server/src/services/sdk/sdk.service.ts
@@ -1,5 +1,5 @@
 import { EncodedData } from '@aeternity/aepp-sdk/es/utils/encoder';
-import { AeSdk, Node } from '@aeternity/aepp-sdk';
+import { AeSdk, Channel, Node } from '@aeternity/aepp-sdk';
 import {
   COMPILER_URL,
   FAUCET_PUBLIC_ADDRESS,
@@ -8,6 +8,8 @@ import {
   IS_USING_LOCAL_NODE,
   NETWORK_ID,
   NODE_URL,
+  CONTRACT_CONFIGURATION,
+  CONTRACT_SOURCE,
 } from './sdk.constants';
 
 export const sdk = new AeSdk({
@@ -22,6 +24,30 @@ export const sdk = new AeSdk({
   ],
 });
 
+export async function getCompiledContract() {
+  const contract = await sdk.getContractInstance({ source: CONTRACT_SOURCE });
+  await contract.compile();
+  return contract;
+}
+
+export async function deployContract(
+  address: EncodedData<'ak'>,
+  channel: Channel,
+) {
+  const contract = await getCompiledContract();
+  return channel.createContract(
+    {
+      ...CONTRACT_CONFIGURATION,
+      code: contract.bytecode,
+      callData: contract.calldata.encode('Identity', 'init', []) as string,
+    },
+    async (tx) => {
+      sdk.selectAccount(address);
+      return sdk.signTransaction(tx);
+    },
+  );
+}
+
 /**
  * ! LOCAL NODE USAGE ONLY
  * a helper function to fund account
@@ -31,5 +57,5 @@ export const genesisFund = async (address: EncodedData<'ak'>) => {
   await sdk.addAccount(FAUCET_ACCOUNT, { select: true });
   await sdk.awaitHeight(2);
   await sdk.spend(1e25, address);
-  sdk.removeAccount(FAUCET_PUBLIC_ADDRESS);
+  if (sdk.accounts[FAUCET_PUBLIC_ADDRESS]) sdk.removeAccount(FAUCET_PUBLIC_ADDRESS);
 };
diff --git a/server/test/integration/bot.service.spec.ts b/server/test/integration/bot.service.spec.ts
@@ -1,5 +1,5 @@
 import { EncodedData } from '@aeternity/aepp-sdk/es/utils/encoder';
-import { Channel } from '@aeternity/aepp-sdk';
+import { buildContractId, Channel, unpackTx } from '@aeternity/aepp-sdk';
 import BigNumber from 'bignumber.js';
 import { FAUCET_PUBLIC_ADDRESS } from '../../src/services/sdk/sdk.constants';
 import botService from '../../src/services/bot';
@@ -22,12 +22,28 @@ describe('botService', () => {
       3001,
     );
 
+    let contractCreationRound = '-1';
     const playerChannel = await Channel.initialize({
       ...responderConfig,
       role: 'responder',
-      sign: (_tag: string, tx: EncodedData<'tx'>) => playerSdk.signTransaction(tx),
+      sign: (_tag: string, tx: EncodedData<'tx'>, options) => {
+        // @ts-expect-error
+        if (options?.updates[0]?.op === 'OffChainNewContract') {
+          // @ts-expect-error
+          contractCreationRound = unpackTx(tx).tx.round as string;
+        }
+        return playerSdk.signTransaction(tx);
+      },
     });
-    expect(playerChannel.status()).toBe('connected');
+
+    await timeout(3000);
+    expect(playerChannel.status()).toBe('open');
+    await timeout(2000);
+    const contractAddress = buildContractId(
+      responderConfig.initiatorId,
+      parseInt(contractCreationRound, 10),
+    );
+    expect(await playerChannel.getContractState(contractAddress)).toBeDefined();
     await playerChannel.shutdown(playerSdk.signTransaction.bind(playerSdk));
   });
 
@@ -50,6 +66,7 @@ describe('botService', () => {
       role: 'responder',
       sign: (_tag: string, tx: EncodedData<'tx'>) => playerSdk.signTransaction(tx),
     });
+    await timeout(1000);
     await playerChannel.shutdown(playerSdk.signTransaction.bind(playerSdk));
     await timeout(1000);
 

diff --git a/server/test/mocks.ts b/server/test/mocks.ts
@@ -12,6 +12,7 @@ export const mockChannel = () => {
       id() {
         return `ch_${randomUUID()}`;
       },
+      createContract: jest.fn(),
     } as ChannelMock),
   );
 };