first pass at syndicate integration

apps/delta/ponder.config.ts

@@ -1,6 +1,6 @@
 import { createConfig } from '@ponder/core'
 import { addresses, idRegistryABI, postGatewayABI } from 'scrypt'
-import { http } from 'viem'
+import { Hex, http } from 'viem'
 
 export default createConfig({
   networks: {

apps/site/.gitignore

@@ -27,6 +27,7 @@ yarn-error.log*
 # local env files
 .env*.local
 .env
+.env.*
 
 # vercel
 .vercel

apps/site/app/api/post/route.ts

@@ -1,41 +1,48 @@
-import { novaPubClient } from '@/config/publicClient'
-import { Defender } from '@openzeppelin/defender-sdk'
-import { ethers } from 'ethers'
 import type { NextRequest } from 'next/server'
-import { addresses, postGatewayABI } from 'scrypt'
-import type { Hex } from 'viem'
+import { syndicate } from '@/config/syndicateClient'
+import { addresses } from 'scrypt'
+import { waitUntilTx } from '@/lib'
 
 export async function POST(req: NextRequest) {
   const post = await req.json()
 
-  const credentials = {
-    relayerApiKey: process.env.NONCE_API_UNO,
-    relayerApiSecret: process.env.NONCE_SECRET_UNO,
-  }
-
   try {
-    const defenderClient = new Defender(credentials)
-    const provider = defenderClient.relaySigner.getProvider()
-    const signer = defenderClient.relaySigner.getSigner(provider, {
-      speed: 'fast',
-    })
-
-    const postGateway = new ethers.Contract(
-      addresses.postGateway.nova,
-      postGatewayABI,
-      signer as unknown as ethers.Signer,
-    )
+    const projectId = process.env.SYNDICATE_PROJECT_ID_POSTGATEWAY
 
-    const tx = await postGateway.post(post)
+    if (!projectId) {
+      throw new Error(
+        'SYNDICATE_PROJECT_ID_POSTGATEWAY is not defined in environment variables.',
+      )
+    }
 
-    await novaPubClient.waitForTransactionReceipt({
-      hash: tx.hash as Hex,
+    const postTx = await syndicate.transact.sendTransaction({
+      projectId: projectId,
+      contractAddress: addresses.postGateway.nova,
+      chainId: 42170,
+      functionSignature:
+        'post((address signer, (uint256 rid, uint256 timestamp, uint8 msgType, bytes msgBody) message, uint16 hashType, bytes32 hash, uint16 sigType, bytes sig) post)',
+      args: {
+        post: post,
+      },
     })
 
-    return new Response(JSON.stringify({ success: true, hash: tx.hash }), {
-      status: 200,
-      headers: { 'Content-Type': 'application/json' },
+    console.log({ postTx })
+
+    // Use the waitUntilTx function to wait for the transaction to be processed
+    const successfulTxHash = await waitUntilTx({
+      projectID: projectId,
+      txID: postTx.transactionId,
     })
+
+    console.log({ successfulTxHash })
+
+    return new Response(
+      JSON.stringify({ success: true, hash: successfulTxHash }),
+      {
+        status: 200,
+        headers: { 'Content-Type': 'application/json' },
+      },
+    )
   } catch (error) {
     let errorMessage = 'Unknown error'
     let statusCode = 500

apps/site/app/api/postBatch/route.ts

@@ -1,41 +1,44 @@
-import { novaPubClient } from '@/config/publicClient'
-import { Defender } from '@openzeppelin/defender-sdk'
-import { ethers } from 'ethers'
 import type { NextRequest } from 'next/server'
-import { addresses, postGatewayABI } from 'scrypt'
-import type { Hex } from 'viem'
+import { addresses } from 'scrypt'
+import { syndicate } from '@/config/syndicateClient'
+import { waitUntilTx } from '@/lib'
 
 export async function POST(req: NextRequest) {
   const postsArray = await req.json()
-  console.log({ postsArray })
-
-  const credentials = {
-    relayerApiKey: process.env.NONCE_API_UNO,
-    relayerApiSecret: process.env.NONCE_SECRET_UNO,
-  }
 
   try {
-    const defenderClient = new Defender(credentials)
-    const provider = defenderClient.relaySigner.getProvider()
-    const signer = defenderClient.relaySigner.getSigner(provider, {
-      speed: 'fast',
-    })
+    const projectId = process.env.SYNDICATE_PROJECT_ID_POSTGATEWAY
 
-    const postGateway = new ethers.Contract(
-      addresses.postGateway.nova,
-      postGatewayABI,
-      signer as unknown as ethers.Signer,
-    )
+    if (!projectId) {
+      throw new Error(
+        'SYNDICATE_PROJECT_ID_POSTGATEWAY is not defined in environment variables.',
+      )
+    }
 
-    const tx = await postGateway.postBatch(postsArray)
-    await novaPubClient.waitForTransactionReceipt({
-      hash: tx.hash as Hex,
+    const postBatchTx = await syndicate.transact.sendTransaction({
+      projectId: projectId,
+      contractAddress: addresses.postGateway.nova,
+      chainId: 42170,
+      functionSignature:
+        'postBatch((address signer, (uint256 rid, uint256 timestamp, uint8 msgType, bytes msgBody) message, uint16 hashType, bytes32 hash, uint16 sigType, bytes sig)[] posts)',
+      args: {
+        posts: postsArray,
+      },
     })
 
-    return new Response(JSON.stringify({ success: true, hash: tx.hash }), {
-      status: 200,
-      headers: { 'Content-Type': 'application/json' },
+    // Use the waitUntilTx function to wait for the transaction to be processed
+    const successfulTxHash = await waitUntilTx({
+      projectID: projectId,
+      txID: postBatchTx.transactionId,
     })
+
+    return new Response(
+      JSON.stringify({ success: true, hash: successfulTxHash }),
+      {
+        status: 200,
+        headers: { 'Content-Type': 'application/json' },
+      },
+    )
   } catch (error) {
     let errorMessage = 'Unknown error'
     let statusCode = 500

apps/site/config/syndicateClient.ts

@@ -0,0 +1,13 @@
+import { SyndicateClient } from '@syndicateio/syndicate-node'
+
+export const syndicate = new SyndicateClient({
+  token: () => {
+    const apiKey = process.env.SYNDICATE_API_KEY
+    if (typeof apiKey === 'undefined') {
+      throw new Error(
+        'SYNDICATE_API_KEY is not defined in environment variables.',
+      )
+    }
+    return apiKey
+  },
+})

apps/site/lib/api.ts

@@ -21,6 +21,98 @@ type User = {
   sig: string
 }
 
+export interface TransactionAttempt {
+  block: number
+  blockCreatedAt: string
+  chainId: number
+  createdAt: string
+  hash: string
+  nonce: number
+  reverted: boolean
+  signedTxn: string
+  status: string
+  transactionId: string
+  updatedAt: string
+  walletAddress: string
+}
+
+export interface SyndicateApiResponse {
+  chainId: number
+  contractAddress: string
+  createdAt: string
+  data: string
+  decodedData: object
+  functionSignature: string
+  invalid: boolean
+  projectId: string
+  transactionAttempts: TransactionAttempt[]
+  transactionId: string
+  updatedAt: string
+  value: string
+}
+
+export interface WaitUntilTxOptions {
+  projectID: string
+  txID: string
+  maxAttempts?: number
+  every?: number
+}
+
+export const getTransactionRequest = async ({
+  projectID,
+  txID,
+}: Pick<WaitUntilTxOptions, 'projectID' | 'txID'>) => {
+  const response = await fetch(
+    `https://api.syndicate.io/wallet/project/${projectID}/request/${txID}`,
+    {
+      method: 'GET',
+      headers: { Authorization: `Bearer ${process.env.SYNDICATE_API_KEY}` },
+    },
+  )
+  if (!response.ok) {
+    throw new Error(`Failed to get transaction request: ${response.statusText}`)
+  }
+  return response.json()
+}
+
+export async function waitUntilTx({
+  projectID,
+  txID,
+  maxAttempts = 20,
+  every = 1000,
+}: WaitUntilTxOptions) {
+  let currAttempts = 0
+  let transactionHash = null
+
+  while (!transactionHash) {
+    await new Promise((resolve) => setTimeout(resolve, every))
+
+    if (currAttempts >= maxAttempts) {
+      throw new Error('Max attempts reached')
+    }
+
+    const txAttempts = (await getTransactionRequest({ projectID, txID }))
+      ?.transactionAttempts
+
+    console.log({ txAttempts })
+
+    if (
+      txAttempts &&
+      txAttempts.length > 0 &&
+      txAttempts[txAttempts.length - 1].status === 'PENDING' &&
+      !txAttempts[txAttempts.length - 1].reverted
+    ) {
+      transactionHash = txAttempts[txAttempts.length - 1].hash
+      console.log(transactionHash)
+      break
+    }
+
+    currAttempts += 1
+  }
+
+  return transactionHash
+}
+
 /* API ROUTES */
 
 // This is in to help with serialization of bigints during json stringify

apps/site/package.json

@@ -29,6 +29,7 @@
     "@radix-ui/react-popover": "^1.0.7",
     "@radix-ui/react-separator": "^1.0.3",
     "@radix-ui/react-slot": "^1.0.2",
+    "@syndicateio/syndicate-node": "^0.0.449",
     "@vercel/analytics": "^1.0.2",
     "@vercel/kv": "^1.0.0",
     "base64url": "^3.0.1",