Merge pull request #62 from GeneralMagicio/add-endpoints-to-get-farcaster-delegations

add endpoints to get farcaster delegations

Author: mmahdigh

src/flow/flow.controller.ts

@@ -50,6 +50,7 @@ import {
   ProjectResponse,
 } from './dto/responses';
 import { InputJsonObject } from '@prisma/client/runtime/library';
+import { getDelegations } from '../neynar/utils';
 
 type AgoraBallotPost = {
   projects: {
@@ -491,6 +492,40 @@ export class FlowController {
     };
   }
 
+  @ApiOperation({
+    summary: 'Total farcaster delegations',
+  })
+  @Get('/delegate/farcaster')
+  async getTotalFarcasterDelegations() {
+    return await getDelegations(new Date('2022-01-01').getTime());
+  }
+
+  @ApiOperation({
+    summary: 'Daily farcaster delegations',
+  })
+  @Get('/delegate/farcaster/daily')
+  async getDailyFarcasterDelegations() {
+    const now = new Date();
+    const gmt1830Today = new Date(
+      Date.UTC(
+        now.getUTCFullYear(),
+        now.getUTCMonth(),
+        now.getUTCDate(),
+        18,
+        30,
+        0,
+      ),
+    );
+    if (now < gmt1830Today) {
+      gmt1830Today.setUTCDate(gmt1830Today.getUTCDate() - 1);
+    }
+    const endTimestamp = gmt1830Today.getTime();
+    return await getDelegations(
+      endTimestamp - 24 * 60 * 60 * 1000,
+      endTimestamp,
+    );
+  }
+
   @UseGuards(AuthGuard)
   @ApiOperation({
     summary: 'Used to delegate a category to a farcaster account',

src/neynar/utils.ts

@@ -8,7 +8,7 @@ import neynarClient from './neynarClient';
  * @param start starting time for the query. In milliseconds from epoch.
  * @param end end time for the query. In milliseconds from epoch. If not specified, defaults to `now`.
  */
-const getDelegations = async (start: number, end?: number) => {
+export const getDelegations = async (start: number, end?: number) => {
   const prisma = new PrismaClient({
     datasources: {
       db: {
@@ -78,8 +78,7 @@ const getDelegations = async (start: number, end?: number) => {
 };
 
 export const sendDailyCasts = async () => {
-  const currentTimestamp = new Date();
-  const endTimestamp = new Date(currentTimestamp);
+  const endTimestamp = new Date();
   endTimestamp.setMinutes(0, 0, 0); // set to xx:00:00
   const delegations = await getDelegations(
     endTimestamp.getTime() - 24 * 60 * 60 * 1000, // Get the timestamp for xx:00 of the previous day