feat(frontent): ft & nft list, token transfers in txn details

Author: bayulaksana479

apps/api/src/routes/v3/txns.ts

@@ -192,6 +192,26 @@ const routes = (app: Router) => {
    *         description: Success response
    */
   route.get('/:hash/nfts', validate(request.nfts), service.nfts);
+
+  /**
+   * @openapi
+   * /v3/txns/{hash}/mts:
+   *   get:
+   *     summary: Get txn mt events
+   *     tags:
+   *       - V3 / Txns
+   *     parameters:
+   *       - in: path
+   *         name: hash
+   *         required: true
+   *         description: Txn hash or RLP hash to retrieve mt events for
+   *         schema:
+   *           type: string
+   *     responses:
+   *       200:
+   *         description: Success response
+   */
+  route.get('/:hash/mts', validate(request.mts), service.mts);
 };
 
 export default routes;

apps/api/src/services/v3/fts/index.ts

@@ -49,6 +49,7 @@ const list = responseHandler(
         sort: cursor?.sort,
       },
       direction,
+      has_cursor: !!cursor,
       // Fetch one extra to check if there is a next page
       limit: limit + 1,
       order,
@@ -63,7 +64,7 @@ const list = responseHandler(
       direction,
       (token) => ({
         contract: token.contract,
-        sort,
+        sort: token[sort as keyof FTList],
       }),
       !!cursor,
     );

apps/api/src/services/v3/nfts/index.ts

@@ -48,6 +48,7 @@ const list = responseHandler(
         contract: cursor?.contract,
         sort: cursor?.sort,
       },
+      has_cursor: !!cursor,
       // Fetch one extra to check if there is a next page
       limit: limit + 1,
       order,
@@ -62,7 +63,7 @@ const list = responseHandler(
       direction,
       (token) => ({
         contract: token.contract,
-        sort,
+        sort: token[sort as keyof NFTList],
       }),
       !!cursor,
     );

apps/api/src/services/v3/txns/index.ts

@@ -4,6 +4,8 @@ import type {
   TxnCountReq,
   TxnFT,
   TxnFTsReq,
+  TxnMT,
+  TxnMTsReq,
   TxnNFT,
   TxnNFTsReq,
   TxnReceipt,
@@ -340,4 +342,67 @@ const nfts = responseHandler(
   },
 );
 
-export default { count, fts, latest, nfts, receipts, txn, txns };
+const mts = responseHandler(
+  response.mts,
+  async (req: RequestValidator<TxnMTsReq>) => {
+    const hash = req.validator.hash;
+
+    if (hash.startsWith('0x')) {
+      const receipts = await rollingWindow<
+        Pick<TxnMT, 'block_timestamp' | 'receipt_id'>[]
+      >(
+        async (start, end) => {
+          const receipts = await dbBase.any<TxnMT>(sql.eventsRlp, {
+            end,
+            hash,
+            start,
+          });
+
+          return receipts.length ? receipts : null;
+        },
+        { start: config.baseStart },
+      );
+
+      if (!receipts || !receipts.length) {
+        return { data: [] };
+      }
+
+      const queries = receipts.map((receipt) => {
+        return pgp.as.format(sql.mt, receipt);
+      });
+      const unionQuery = queries.join('\nUNION ALL\n');
+      const mts = await dbEvents.manyOrNone<TxnMT>(unionQuery);
+
+      return { data: mts };
+    }
+
+    const receipts = await rollingWindow<
+      Pick<TxnMT, 'block_timestamp' | 'receipt_id'>[]
+    >(
+      async (start, end) => {
+        const receipts = await dbBase.any<TxnMT>(sql.events, {
+          end,
+          hash,
+          start,
+        });
+
+        return receipts.length ? receipts : null;
+      },
+      { start: config.baseStart },
+    );
+
+    if (!receipts || !receipts.length) {
+      return { data: [] };
+    }
+
+    const queries = receipts.map((receipt) => {
+      return pgp.as.format(sql.mt, receipt);
+    });
+    const unionQuery = queries.join('\nUNION ALL\n');
+    const mts = await dbEvents.manyOrNone<TxnMT>(unionQuery);
+
+    return { data: mts };
+  },
+);
+
+export default { count, fts, latest, mts, nfts, receipts, txn, txns };

apps/api/src/sql/queries/accounts/fts/txns.sql

@@ -41,6 +41,7 @@ FROM
       ft_meta fm
     WHERE
       fm.contract = ft.contract_account_id
+      AND fm.modified_at IS NOT NULL
   ) m ON TRUE
 WHERE
   affected_account_id = ${account}

apps/api/src/sql/queries/accounts/mts/txns.sql

@@ -55,6 +55,7 @@ FROM
     WHERE
       mbm.contract = mt.contract_account_id
       AND mbm.token = mt.token_id
+      AND mbm.modified_at IS NOT NULL
   ) bm ON TRUE
   JOIN LATERAL (
     SELECT
@@ -75,6 +76,7 @@ FROM
     WHERE
       mtm.contract = mt.contract_account_id
       AND mtm.token = mt.token_id
+      AND mtm.modified_at IS NOT NULL
   ) tm ON TRUE
 WHERE
   affected_account_id = ${account}

apps/api/src/sql/queries/accounts/nfts/txns.sql

@@ -38,9 +38,10 @@ FROM
         reference
       ) AS meta
     FROM
-      nft_meta nfm
+      nft_meta nm
     WHERE
-      nfm.contract = nft.contract_account_id
+      nm.contract = nft.contract_account_id
+      AND nm.modified_at IS NOT NULL
   ) m ON TRUE
   JOIN LATERAL (
     SELECT
@@ -61,6 +62,7 @@ FROM
     WHERE
       ntm.contract = nft.contract_account_id
       AND ntm.token = nft.token_id
+      AND ntm.modified_at IS NOT NULL
   ) tm ON TRUE
 WHERE
   affected_account_id = ${account}

apps/api/src/sql/queries/fts/contract.sql

@@ -27,3 +27,4 @@ FROM
   ft_meta
 WHERE
   contract = ${contract}
+  AND modified_at IS NOT NULL

apps/api/src/sql/queries/fts/contractTxns.sql

@@ -41,6 +41,7 @@ FROM
       ft_meta fm
     WHERE
       fm.contract = ft.contract_account_id
+      AND fm.modified_at IS NOT NULL
   ) m ON TRUE
 WHERE
   ft.contract_account_id = ${contract}

apps/api/src/sql/queries/fts/list.sql

@@ -22,24 +22,50 @@ WHERE
     OR name ILIKE ${search}
   )
   AND (
-    ${cursor.sort} IS NULL
+    NOT ${has_cursor}
     OR (
       ${order} = 'desc'
       AND (
-        (${sort:name} < ${cursor.sort})
+        (
+          ${cursor.sort} IS NOT NULL
+          AND (
+            (${sort:name} < ${cursor.sort})
+            OR (
+              ${sort:name} = ${cursor.sort}
+              AND contract > ${cursor.contract}
+            )
+            OR (${sort:name} IS NULL)
+          )
+        )
         OR (
-          ${sort:name} = ${cursor.sort}
+          ${cursor.sort} IS NULL
+          AND ${sort:name} IS NULL
           AND contract > ${cursor.contract}
         )
       )
     )
     OR (
       ${order} = 'asc'
       AND (
-        (${sort:name} > ${cursor.sort})
+        (
+          ${cursor.sort} IS NOT NULL
+          AND (
+            (${sort:name} > ${cursor.sort})
+            OR (
+              ${sort:name} = ${cursor.sort}
+              AND contract > ${cursor.contract}
+            )
+          )
+        )
         OR (
-          ${sort:name} = ${cursor.sort}
-          AND contract > ${cursor.contract}
+          ${cursor.sort} IS NULL
+          AND (
+            (
+              ${sort:name} IS NULL
+              AND contract > ${cursor.contract}
+            )
+            OR (${sort:name} IS NOT NULL)
+          )
         )
       )
     )