ecs ci/cd

Author: amish kohli

.github/workflows/aws.yml

@@ -2,7 +2,7 @@ name: Deploy to Amazon ECS
 
 on:
   push:
-    branches: [ "main" ]
+    branches: [ "main", "feat/indexer" ]
 
 env:
   AWS_REGION: us-east-1
@@ -51,9 +51,11 @@ jobs:
         # push it to ECR so that it can
         # be deployed to ECS.
         aws ecr get-login-password --region us-east-1 | docker login --username AWS --password-stdin 058264122535.dkr.ecr.us-east-1.amazonaws.com
-        docker build -t ponder/indexer .
-        docker tag ponder/indexer:latest 058264122535.dkr.ecr.us-east-1.amazonaws.com/ponder/indexer:latest
-        docker push 058264122535.dkr.ecr.us-east-1.amazonaws.com/ponder/indexer:latest
+        docker buildx build \
+          --platform linux/amd64 \
+          --push \
+          -t 058264122535.dkr.ecr.us-east-1.amazonaws.com/ponder/indexer:latest \
+          .
 
     - name: Fill in the new image ID in the Amazon ECS task definition
       id: task-def

Dockerfile

@@ -1,10 +1,8 @@
-# Use a more compatible image for cross-platform support
-FROM node:18-bullseye-slim
+FROM node:18.17.1
 
-# Set the working directory
 WORKDIR /app
 
-# Copy package.json and package-lock.json
+# Copy package files
 COPY package*.json ./
 
 # Install dependencies
@@ -13,11 +11,14 @@ RUN npm install
 # Copy the rest of the application code
 COPY . .
 
-# Expose the port the app runs on
-
-
 # Expose ports
-EXPOSE 3000
+EXPOSE 3000 3001 42069
+
+# Run the application with necessary flags
+CMD ["node", \
+     "--experimental-fetch", \
+     "--loader", "ts-node/esm", \
+     "--no-warnings", \
+     "node_modules/.bin/ponder", \
+     "dev"]
 
-# Run the application
-CMD ["npm", "run", "ponder"]

src/api/server.ts

@@ -15,28 +15,54 @@ const supabase = createClient(supabaseUrl, supabaseKey);
 
 app.use(express.json());
 
-// Example endpoint to fetch rewards for a specific user with total rewards
-app.get('/api/rewards/:user', async (req, res) => {
+// Updated endpoint to include chain parameter
+app.get('/api/rewards/:chain/:user', async (req : any , res : any) => {
   try {
-    const { user } = req.params;
+    const { chain, user } = req.params;
+    const validChains = ['mode', 'base']; // Add supported chains here
+
+    // Hardcoded ionTokenAddress for each chain
+    const ionTokenAddresses: { [key: string]: string } = {
+      mode: '0x18470019bF0E94611f15852F7e93cf5D65BC34CA', // Replace with actual address
+      base: '0x3eE5e23eEE121094f1cFc0Ccc79d6C809Ebd22e5', // Replace with actual address
+    };
+
+    // Validate chain parameter
+    if (!validChains.includes(chain.toLowerCase())) {
+      return res.status(400).json({ error: 'Invalid chain. Supported chains are: ' + validChains.join(', ') });
+    }
+
     const { data, error } = await supabase
       .from('accrue_rewards_events')
       .select('*')
       .eq('user', user.toLowerCase())
+      .eq('chain', chain.toLowerCase()) // Add chain filter
       .order('timestamp', { ascending: false });
 
     if (error) throw error;
 
-    // Sum up the amount in each reward event
-    const totalAmount = data.reduce((acc: bigint, event: any) => {
-      const amount = BigInt(event.allEventArgs.amount); // Convert amount to BigInt
-      return acc + amount; // Add the amount to the accumulator
-    }, BigInt(0)); // Start with 0 as the initial value for the accumulator
+    // Create a Map to track unique events using transactionHash as the key
+    const uniqueEvents = new Map();
+    data.forEach((event: any) => {
+      const eventKey = event.transactionHash; // Or use: `${event.blockNumber}-${event.logIndex}`
+      if (!uniqueEvents.has(eventKey)) {
+        uniqueEvents.set(eventKey, event);
+      }
+    });
+
+    // Sum up the amount only for unique events
+    const totalAmount = Array.from(uniqueEvents.values()).reduce((acc: bigint, event: any) => {
+      const amount = BigInt(event.allEventArgs.amount);
+      return acc + amount;
+    }, BigInt(0));
 
     res.json({
+      chain: chain.toLowerCase(),
       user: user.toLowerCase(),
-      totalRewards: totalAmount.toString(), // Convert BigInt to string to avoid precision issues in JSON
-      events: data, // Return the original events data as well
+      totalRewards: totalAmount.toString(),
+      ionTokenAddress: ionTokenAddresses[chain.toLowerCase()], // Include ionTokenAddress in response
+      // uniqueEventsCount: uniqueEvents.size,
+      // totalEventsCount: data.length,
     });
   } catch (error) {
     console.error('Error fetching user rewards:', error);