Merge pull request #545 from shawakash/token_ata

feat: adds associated token account create endpoint

.changeset/feat: silver-baboons-hope.md

@@ -0,0 +1,6 @@
+---
+"@paybox/common": patch
+"@paybox/api": patch
+---
+
+feat: adds associated token account create endpoint

backend/api/src/db/token.ts

@@ -133,3 +133,44 @@ export const getToken = async (
     status: dbResStatus.Error,
   };
 };
+
+// insert one ata object to db
+export const insertAtaOne = async (
+  owner: string,
+  clientId: string,
+  isMinter: boolean,
+  pubKey: string,
+  token: string,
+): Promise<{
+  status: dbResStatus;
+  ataId?: string;
+}> => {
+  const response = await chain("mutation")(
+    {
+      insert_ata_one: [
+        {
+          object: {
+            owner,
+            clientId,
+            isMinter,
+            pubKey,
+            token,
+          },
+        },
+        {
+          id: true,
+        },
+      ],
+    },
+    { operationName: "insertAtaOne" },
+  );
+  if (response.insert_ata_one?.id) {
+    return {
+      status: dbResStatus.Ok,
+      ataId: response.insert_ata_one.id as string,
+    };
+  }
+  return {
+    status: dbResStatus.Error,
+  };
+};

backend/api/src/routes/token.ts

@@ -1,4 +1,5 @@
 import {
+  GenAtaSchema,
   GetTokenSchema,
   MintTokenSchema,
   Network,
@@ -11,7 +12,7 @@ import {
 import { Router } from "express";
 import { SolTokenOps } from "@paybox/blockchain";
 import { checkPassword, getNetworkPrivateKey } from "@paybox/backend-common";
-import { getToken, getTokens, insertToken } from "../db/token";
+import { getToken, getTokens, insertAtaOne, insertToken } from "../db/token";
 import { insertAta } from "../db/ata";
 import { decryptWithPassword } from "../auth";
 import { Worker } from "../workers/txn";
@@ -295,3 +296,74 @@ tokenRouter.get("/", async (req, res) => {
     });
   }
 });
+
+tokenRouter.post("/ata", checkPassword, async (req, res) => {
+  try {
+    //@ts-ignore;
+    const id = req.id;
+    //@ts-ignore;
+    const hashPassword = req.hashPassword;
+    if (id) {
+      const { token, authority, network } = GenAtaSchema.parse(req.body);
+
+      let { status, privateKey } = await getNetworkPrivateKey(
+        authority,
+        network,
+      );
+      if (status == dbResStatus.Error || !privateKey) {
+        return res.status(404).json({
+          msg: "That account is not Found in Database...",
+          status: responseStatus.Error,
+        });
+      }
+      privateKey = await decryptWithPassword(privateKey, hashPassword);
+
+      let instance;
+      switch (network) {
+        case Network.Sol:
+          instance = await SolTokenOps.getInstance().genAta(token, privateKey);
+          break;
+        case Network.Eth:
+          break;
+        default:
+          break;
+      }
+
+      if (!instance) {
+        return res.status(404).json({
+          status: responseStatus.Error,
+          msg: `Sorry, ${network} is not yet supported...`,
+        });
+      }
+
+      const { status: insertAtaStatus, ataId } = await insertAtaOne(
+        authority,
+        id,
+        false,
+        instance,
+        token,
+      );
+      if (insertAtaStatus == dbResStatus.Error || !ataId) {
+        return res.status(500).json({
+          msg: "Insert Db Error",
+          status: responseStatus.Error,
+        });
+      }
+
+      return res.status(200).json({
+        status: responseStatus.Ok,
+        ataId,
+      });
+    }
+    return res.status(401).json({
+      status: responseStatus.Error,
+      msg: "Auth Error",
+    });
+  } catch (e) {
+    console.log(e);
+    return res.status(500).json({
+      msg: "Internal Server Error",
+      status: responseStatus.Error,
+    });
+  }
+});

packages/common/src/validations/token.ts

@@ -31,3 +31,9 @@ export const GetTokenSchema = z.object({
       "should be a valid UUID.",
     ),
 });
+
+export const GenAtaSchema = z.object({
+  token: z.string(),
+  authority: publicKeyType,
+  network: z.nativeEnum(Network),
+});