feat: adds token mint endpoint and token_txn messaging queue workflow

backend/api/src/routes/token.ts

@@ -1,6 +1,9 @@
 import {
+  MintTokenSchema,
   Network,
   TokenCreateSchema,
+  TopicTypes,
+  TxnTopic,
   dbResStatus,
   responseStatus,
 } from "@paybox/common";
@@ -10,6 +13,7 @@ import { checkPassword, getNetworkPrivateKey } from "@paybox/backend-common";
 import { insertToken } from "../db/token";
 import { insertAta } from "../db/ata";
 import { decryptWithPassword } from "../auth";
+import { Worker } from "../workers/txn";
 
 export const tokenRouter = Router();
 
@@ -108,3 +112,103 @@ tokenRouter.post("/create", checkPassword, async (req, res) => {
     });
   }
 });
+
+tokenRouter.post("/mint", checkPassword, async (req, res) => {
+  try {
+    //@ts-ignore
+    const id = req.id;
+    //@ts-ignore
+    const hashPassword = req.hashPassword;
+
+    if (id && hashPassword) {
+      const { mint, authority, network, tokens, ata, username } =
+        MintTokenSchema.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().mintToken(
+            privateKey,
+            mint,
+            ata,
+            tokens,
+          );
+          break;
+
+        case Network.Eth:
+          break;
+
+        default:
+          return res.status(404).json({
+            msg: `${network} is not yet Supported...`,
+            status: responseStatus.Error,
+          });
+      }
+
+      if (!instance) {
+        return res.status(404).json({
+          msg: "Sorry, We don't yet Support tokens on that chain",
+          status: responseStatus.Error,
+        });
+      }
+
+      console.log(instance);
+
+      try {
+        //publishing to push the txn
+        await Worker.getInstance().publishOne({
+          topic: TopicTypes.Txn,
+          message: [
+            {
+              partition: 0,
+              key: instance,
+              value: JSON.stringify({
+                type: TxnTopic.Finalized,
+                chain: network,
+                from: id,
+                to: username,
+                hash: instance,
+                isTokenTxn: true,
+                isMint: true,
+              }),
+            },
+          ],
+        });
+      } catch (e) {
+        console.log(e);
+        return res.status(500).json({
+          msg: "Error publishing the txn",
+          status: responseStatus.Error,
+        });
+      }
+
+      return res.status(200).json({
+        msg: `${tokens} minted successfully...`,
+        status: responseStatus.Ok,
+      });
+    }
+
+    return res.status(401).json({
+      msg: "Auth Error",
+      status: responseStatus.Error,
+    });
+  } catch (e) {
+    console.log(e);
+    return res.status(500).json({
+      msg: "Internal Server Error",
+      status: responseStatus.Error,
+    });
+  }
+});

backend/hasura/hasura/metadata/databases/default/tables/public_ata.yaml

@@ -21,3 +21,18 @@ object_relationships:
   - name: tokenByToken
     using:
       foreign_key_constraint_on: token
+array_relationships:
+  - name: tokenTxnsByToata
+    using:
+      foreign_key_constraint_on:
+        column: toAta
+        table:
+          name: token_txn
+          schema: public
+  - name: token_txns
+    using:
+      foreign_key_constraint_on:
+        column: fromAta
+        table:
+          name: token_txn
+          schema: public

backend/hasura/hasura/metadata/databases/default/tables/public_client.yaml

@@ -97,6 +97,13 @@ array_relationships:
         table:
           name: notification
           schema: public
+  - name: token_txns
+    using:
+      foreign_key_constraint_on:
+        column: clientId
+        table:
+          name: token_txn
+          schema: public
   - name: tokens
     using:
       foreign_key_constraint_on:

backend/hasura/hasura/metadata/databases/default/tables/public_token.yaml

@@ -23,3 +23,10 @@ array_relationships:
         table:
           name: ata
           schema: public
+  - name: token_txns
+    using:
+      foreign_key_constraint_on:
+        column: token
+        table:
+          name: token_txn
+          schema: public

backend/hasura/hasura/metadata/databases/default/tables/public_token_txn.yaml

@@ -0,0 +1,16 @@
+table:
+  name: token_txn
+  schema: public
+object_relationships:
+  - name: token_txn_to_client
+    using:
+      foreign_key_constraint_on: clientId
+  - name: token_txn_to_token
+    using:
+      foreign_key_constraint_on: token
+  - name: txn_fromAta_to_ata
+    using:
+      foreign_key_constraint_on: fromAta
+  - name: txn_toAta_to_ata
+    using:
+      foreign_key_constraint_on: toAta

backend/hasura/hasura/metadata/databases/default/tables/tables.yaml

@@ -17,5 +17,6 @@
 - "!include public_notification_subscription.yaml"
 - "!include public_sol.yaml"
 - "!include public_token.yaml"
+- "!include public_token_txn.yaml"
 - "!include public_transactions.yaml"
 - "!include public_wallet.yaml"

backend/hasura/hasura/migrations/default/1715417904215_create_table_public_token_txn/down.sql

@@ -0,0 +1 @@
+DROP TABLE "public"."token_txn";

backend/hasura/hasura/migrations/default/1715417904215_create_table_public_token_txn/up.sql

@@ -0,0 +1,18 @@
+CREATE TABLE "public"."token_txn" ("id" uuid NOT NULL DEFAULT gen_random_uuid(), "blockHash" text NOT NULL, "fee" float8 NOT NULL, "hash" text NOT NULL, "amount" float8 NOT NULL, "fromAta" text NOT NULL, "toAta" text NOT NULL, "isMint" boolean NOT NULL DEFAULT false, "token" text NOT NULL, "network" text NOT NULL, "slot" int8 NOT NULL, "status" text NOT NULL DEFAULT 'pending', "time" time NOT NULL, "created_at" timestamptz NOT NULL DEFAULT now(), "updated_at" timestamptz NOT NULL DEFAULT now(), "clientId" uuid NOT NULL, PRIMARY KEY ("id") , FOREIGN KEY ("clientId") REFERENCES "public"."client"("id") ON UPDATE no action ON DELETE no action, FOREIGN KEY ("token") REFERENCES "public"."token"("pubKey") ON UPDATE no action ON DELETE no action, FOREIGN KEY ("fromAta") REFERENCES "public"."ata"("pubKey") ON UPDATE no action ON DELETE no action, FOREIGN KEY ("toAta") REFERENCES "public"."ata"("pubKey") ON UPDATE no action ON DELETE no action, UNIQUE ("id"));COMMENT ON TABLE "public"."token_txn" IS E'all the token transactions';
+CREATE OR REPLACE FUNCTION "public"."set_current_timestamp_updated_at"()
+RETURNS TRIGGER AS $$
+DECLARE
+  _new record;
+BEGIN
+  _new := NEW;
+  _new."updated_at" = NOW();
+  RETURN _new;
+END;
+$$ LANGUAGE plpgsql;
+CREATE TRIGGER "set_public_token_txn_updated_at"
+BEFORE UPDATE ON "public"."token_txn"
+FOR EACH ROW
+EXECUTE PROCEDURE "public"."set_current_timestamp_updated_at"();
+COMMENT ON TRIGGER "set_public_token_txn_updated_at" ON "public"."token_txn" 
+IS 'trigger to set value of column "updated_at" to current timestamp on row update';
+CREATE EXTENSION IF NOT EXISTS pgcrypto;

backend/hasura/hasura/migrations/default/1715420911708_alter_table_public_token_txn_alter_column_time/down.sql

@@ -0,0 +1 @@
+ALTER TABLE "public"."token_txn" ALTER COLUMN "time" TYPE time without time zone;

backend/hasura/hasura/migrations/default/1715420911708_alter_table_public_token_txn_alter_column_time/up.sql

@@ -0,0 +1 @@
+ALTER TABLE "public"."token_txn" ALTER COLUMN "time" TYPE timetz;

backend/hasura/hasura/migrations/default/1715420992766_alter_table_public_token_txn_drop_column_time/down.sql

@@ -0,0 +1,3 @@
+comment on column "public"."token_txn"."time" is E'all the token transactions';
+alter table "public"."token_txn" alter column "time" drop not null;
+alter table "public"."token_txn" add column "time" timetz;

backend/hasura/hasura/migrations/default/1715420992766_alter_table_public_token_txn_drop_column_time/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" drop column "time" cascade;

backend/hasura/hasura/migrations/default/1715421005669_alter_table_public_token_txn_add_column_time/down.sql

@@ -0,0 +1,4 @@
+-- Could not auto-generate a down migration.
+-- Please write an appropriate down migration for the SQL below:
+-- alter table "public"."token_txn" add column "time" timestamptz
+--  not null;

backend/hasura/hasura/migrations/default/1715421005669_alter_table_public_token_txn_add_column_time/up.sql

@@ -0,0 +1,2 @@
+alter table "public"."token_txn" add column "time" timestamptz
+ not null;

backend/hasura/hasura/migrations/default/1715421272013_alter_table_public_token_txn_alter_column_fromAta/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "fromAtaOwner" to "fromAta";

backend/hasura/hasura/migrations/default/1715421272013_alter_table_public_token_txn_alter_column_fromAta/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "fromAta" to "fromAtaOwner";

backend/hasura/hasura/migrations/default/1715421280245_alter_table_public_token_txn_alter_column_toAta/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "toAtaOwner" to "toAta";

backend/hasura/hasura/migrations/default/1715421280245_alter_table_public_token_txn_alter_column_toAta/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "toAta" to "toAtaOwner";

backend/hasura/hasura/migrations/default/1715421364959_delete_fk_public_token_txn_token_txn_fromAta_fkey/down.sql

@@ -0,0 +1,5 @@
+alter table "public"."token_txn"
+  add constraint "token_txn_fromAta_fkey"
+  foreign key ("fromAtaOwner")
+  references "public"."ata"
+  ("pubKey") on update no action on delete no action;

backend/hasura/hasura/migrations/default/1715421364959_delete_fk_public_token_txn_token_txn_fromAta_fkey/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" drop constraint "token_txn_fromAta_fkey";

backend/hasura/hasura/migrations/default/1715421372066_delete_fk_public_token_txn_token_txn_toAta_fkey/down.sql

@@ -0,0 +1,5 @@
+alter table "public"."token_txn"
+  add constraint "token_txn_toAta_fkey"
+  foreign key ("toAtaOwner")
+  references "public"."ata"
+  ("pubKey") on update no action on delete no action;

backend/hasura/hasura/migrations/default/1715421372066_delete_fk_public_token_txn_token_txn_toAta_fkey/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" drop constraint "token_txn_toAta_fkey";

backend/hasura/hasura/migrations/default/1715421504584_alter_table_public_token_txn_alter_column_fromAtaOwner/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "fromAta" to "fromAtaOwner";

backend/hasura/hasura/migrations/default/1715421504584_alter_table_public_token_txn_alter_column_fromAtaOwner/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "fromAtaOwner" to "fromAta";

backend/hasura/hasura/migrations/default/1715421512395_alter_table_public_token_txn_alter_column_toAtaOwner/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "toAta" to "toAtaOwner";

backend/hasura/hasura/migrations/default/1715421512395_alter_table_public_token_txn_alter_column_toAtaOwner/up.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" rename column "toAtaOwner" to "toAta";

backend/hasura/hasura/migrations/default/1715421530803_set_fk_public_token_txn_fromAta/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" drop constraint "token_txn_fromAta_fkey";

backend/hasura/hasura/migrations/default/1715421530803_set_fk_public_token_txn_fromAta/up.sql

@@ -0,0 +1,5 @@
+alter table "public"."token_txn"
+  add constraint "token_txn_fromAta_fkey"
+  foreign key ("fromAta")
+  references "public"."ata"
+  ("pubKey") on update no action on delete no action;

backend/hasura/hasura/migrations/default/1715421545537_set_fk_public_token_txn_toAta/down.sql

@@ -0,0 +1 @@
+alter table "public"."token_txn" drop constraint "token_txn_toAta_fkey";

backend/hasura/hasura/migrations/default/1715421545537_set_fk_public_token_txn_toAta/up.sql

@@ -0,0 +1,5 @@
+alter table "public"."token_txn"
+  add constraint "token_txn_toAta_fkey"
+  foreign key ("toAta")
+  references "public"."ata"
+  ("pubKey") on update no action on delete no action;