WIP: E2E wallet generation

Author: mohammadalfaiyazbitgo

src/kms/kmsClient.ts

@@ -25,20 +25,20 @@ export class KmsClient {
   async postKey(params: PostKeyParams): Promise<PostKeyResponse> {
     debugLogger('Posting key to KMS: %O', params);
 
-    const kmsResponse = await superagent
-      .post(`${this.url}/key`)
-      .set('x-api-key', 'abc')
-      .send(params);
-
-    try {
-      PostKeyKmsSchema.parse(kmsResponse.body);
-    } catch (error: any) {
-      throw new Error(
-        `KMS returned unexpected response${error.message ? `: ${error.message}` : ''}`,
-      );
-    }
-
-    const { pub, coin, source } = kmsResponse.body;
+    // const kmsResponse = await superagent
+    //   .post(`${this.url}/key`)
+    //   .set('x-api-key', 'abc')
+    //   .send(params);
+    //
+    // try {
+    //   PostKeyKmsSchema.parse(kmsResponse.body);
+    // } catch (error: any) {
+    //   throw new Error(
+    //     `KMS returned unexpected response${error.message ? `: ${error.message}` : ''}`,
+    //   );
+    // }
+
+    const { pub, coin, source } = params;
     return { pub, coin, source } as PostKeyResponse;
   }
 }

src/masterBitgoExpress/enclavedExpressClient.ts

@@ -70,7 +70,7 @@ export class EnclavedExpressClient {
     try {
       debugLogger('Creating independent keychain for coin: %s', this.coin);
       const { body: keychain } = await superagent
-        .post(`${this.url}/api/${this.coin}/key/independent`)
+        .post(`${this.url}/${this.coin}/key/independentKey`)
         .ca(this.sslCert)
         .agent(
           new https.Agent({

src/masterBitgoExpress/generateWallet.ts

@@ -54,7 +54,7 @@ export async function handleGenerateWalletOnPrem({
     n: 3,
     keys: [],
     type: 'cold',
-    subType: 'onprem',
+    subType: 'onPrem',
     multisigType: 'onchain',
   } as unknown as SupplementGenerateWalletOptions; // TODO: Add onprem to the SDK subType and remove "unknown" type casting
 

src/masterExpressApi.ts

@@ -105,11 +105,10 @@ export const GenerateWalletRequest = h.httpRoute({
     params: {
       coin: t.string,
     },
-    headers: {
-      authorization: t.union([t.string, t.undefined]),
-      'user-agent': t.union([t.string, t.undefined]),
+    body: {
+      label: t.string,
+      enterprise: t.string,
     },
-    body: WalletGenerateRequest,
   }),
   response: {
     200: WalletGenerateResponse,

src/masterExpressApp.ts

@@ -6,6 +6,7 @@ import debug from 'debug';
 import https from 'https';
 import http from 'http';
 import superagent from 'superagent';
+import bodyParser from 'body-parser';
 
 import {
   createServer as createExpressApp,
@@ -29,7 +30,6 @@ import {
   prepareIpc,
   readCertificates,
 } from './shared/appUtils';
-import bodyParser from 'body-parser';
 import { ProxyAgent } from 'proxy-agent';
 import pjson from '../package.json';
 import { handleGenerateWalletOnPrem } from './masterBitgoExpress/generateWallet';
@@ -197,8 +197,6 @@ const handleGenerateWallet: ServiceFunction<typeof GenerateWalletRequest> = asyn
   coin,
   enterprise,
   label,
-  authorization,
-  'user-agent': userAgent,
 }) => {
   try {
     const cfg = config() as MasterExpressConfig;
@@ -207,29 +205,24 @@ const handleGenerateWallet: ServiceFunction<typeof GenerateWalletRequest> = asyn
     const bitGo = new BitGo({
       env: cfg.env,
       customRootURI: cfg.customRootUri,
-      accessToken: authorization?.startsWith('Bearer ') ? authorization.substring(7) : undefined,
-      userAgent: userAgent ? BITGOEXPRESS_USER_AGENT + ' ' + userAgent : BITGOEXPRESS_USER_AGENT,
+      // accessToken: Authorization?.startsWith('Bearer ') ? Authorization.substring(7) : undefined,
+      accessToken: 'v2xa0f0fa5fffa0ff7529b47c969cf544f4df1b21a5508109bed488a9d2c9d74f54',
+      // userAgent: userAgent ? BITGOEXPRESS_USER_AGENT + ' ' + userAgent : BITGOEXPRESS_USER_AGENT,
     });
 
-    // Prepare the request object for the existing handler
-    // const bitgoReq = {
-    //   bitgo,
-    //   body: req.body,
-    //   params: req.pathParams,
-    //   config: cfg,
-    // } as BitGoRequest;
-
     // Call the existing implementation
+    console.log('here', bitGo);
     const result = await handleGenerateWalletOnPrem({
       bitGo,
       params: {
         coin,
-        label,
-        enterprise,
+        label: 'world',
+        enterprise: '6750c2d327511bc4e5f83ccfcfe1b3eb',
         multisigType: 'onchain', // Default multisig type
         isDistributedCustody: false, // Default value
       },
     });
+    console.log(result);
     return Response.ok(result);
   } catch (error) {
     debugLogger('Failed to generate wallet:', error);
@@ -258,7 +251,8 @@ export function app(cfg: MasterExpressConfig): express.Application {
   console.log('Certificate length:', cfg.enclavedExpressSSLCert.length);
   console.log('Certificate content:', cfg.enclavedExpressSSLCert);
 
-  const app = createExpressApp(MasterExpressApi, (_app) => {
+  const app = createExpressApp(MasterExpressApi, (app) => {
+    app.use(bodyParser.json({ limit: '1mb' }));
     return {
       'api.v1.health.pingMasterExpress': {
         post: routeHandler({