Autovote on contests

.github/workflows/CI.yml

@@ -7,7 +7,7 @@ env:
   NODE_ENV: 'test'
   ROLLBAR_ENV: 'GitHubCI'
   TEST_WITHOUT_LOGS: 'true'
-  PRIVATE_KEY: 'web3-pk'
+  PRIVATE_KEY: '0x83c65f24efbc8f4bc54ad425e897fc3ea01f760d5e71671a30eacb075ebe2313'
   USES_DOCKER_PGSQL: true
   PORT: 8080
   REDIS_URL: redis://localhost:6379

libs/core/src/integration/events.schemas.ts

@@ -262,3 +262,7 @@ export const FarcasterReplyCastCreated = FarcasterCast.describe(
 export const FarcasterVoteCreated = FarcasterAction.extend({
   contest_address: z.string(),
 }).describe('When a farcaster action is initiated on a cast reply');
+
+export const CheckContests = z.object({});
+
+export const RolloverContests = z.object({});

libs/core/src/integration/events.ts

@@ -35,6 +35,8 @@ export enum EventNames {
   FarcasterCastCreated = 'FarcasterCastCreated',
   FarcasterReplyCastCreated = 'FarcasterReplyCastCreated',
   FarcasterVoteCreated = 'FarcasterVoteCreated',
+  CheckContests = 'CheckContests',
+  RolloverContests = 'RolloverContests',
 
   // Preferences
   SubscriptionPreferencesUpdated = 'SubscriptionPreferencesUpdated',
@@ -113,6 +115,14 @@ export type EventPairs =
       event_name: EventNames.FarcasterVoteCreated;
       event_payload: z.infer<typeof events.FarcasterVoteCreated>;
     }
+  | {
+      event_name: EventNames.CheckContests;
+      event_payload: z.infer<typeof events.CheckContests>;
+    }
+  | {
+      event_name: EventNames.RolloverContests;
+      event_payload: z.infer<typeof events.RolloverContests>;
+    }
   | {
       event_name: EventNames.DiscordThreadCreated;
       event_payload: z.infer<typeof events.DiscordThreadCreated>;

libs/core/src/integration/outbox.schema.ts

@@ -125,6 +125,18 @@ export const Outbox = z.union([
       event_payload: events.FarcasterVoteCreated,
     })
     .merge(BaseOutboxProperties),
+  z
+    .object({
+      event_name: z.literal(EventNames.CheckContests),
+      event_payload: events.CheckContests,
+    })
+    .merge(BaseOutboxProperties),
+  z
+    .object({
+      event_name: z.literal(EventNames.RolloverContests),
+      event_payload: events.RolloverContests,
+    })
+    .merge(BaseOutboxProperties),
   z
     .object({
       event_name: z.literal(EventNames.DiscordThreadCreated),

libs/model/src/contest/GetActiveContestManagers.query.ts

@@ -20,6 +20,7 @@ export function GetActiveContestManagers(): Query<
         url: string;
         private_url: string;
         contest_address: string;
+        end_time: string;
         max_contest_id: number;
         actions: Array<z.infer<typeof schemas.ContestAction>>;
       }>(
@@ -29,6 +30,7 @@ export function GetActiveContestManagers(): Query<
                    cn.url,
                    cm.contest_address,
                    co.max_contest_id,
+                   co.end_time,
                    COALESCE(JSON_AGG(ca) FILTER (WHERE ca IS NOT NULL), '[]'::json) as actions
             FROM "Communities" c
                      JOIN "ChainNodes" cn ON c.chain_node_id = cn.id
@@ -40,24 +42,26 @@ export function GetActiveContestManagers(): Query<
                            FROM "Contests"
                            GROUP BY contest_address) co ON cm.contest_address = co.contest_address
                      LEFT JOIN "ContestActions" ca on (
-                ca.contest_address = cm.contest_address AND
-                ca.created_at > co.start_time AND
-                ca.created_at < co.end_time
-                )
-            WHERE cm.topic_id = :topic_id
-              AND cm.community_id = :community_id
-              AND cm.cancelled IS NOT TRUE
+                      ca.contest_address = cm.contest_address AND
+                      ca.created_at > co.start_time AND
+                      ca.created_at < co.end_time
+                     )
+            WHERE
+              cm.cancelled IS NOT TRUE
+              AND cm.ended IS NOT TRUE
+              ${payload.topic_id ? 'AND cm.topic_id = :topic_id' : ''}
+              ${payload.community_id ? 'AND cm.community_id = :community_id' : ''}
               AND (
                 cm.interval = 0 AND NOW() < co.end_time
                     OR
                 cm.interval > 0
                 )
-            GROUP BY cn.eth_chain_id, cn.private_url, cn.url, cm.contest_address, co.max_contest_id
+            GROUP BY cn.eth_chain_id, cn.private_url, cn.url, cm.contest_address, co.max_contest_id, co.end_time
         `,
         {
           type: QueryTypes.SELECT,
           replacements: {
-            topic_id: payload.topic_id!,
+            topic_id: payload.topic_id,
             community_id: payload.community_id,
           },
         },
@@ -67,6 +71,7 @@ export function GetActiveContestManagers(): Query<
         eth_chain_id: r.eth_chain_id,
         url: getChainNodeUrl(r),
         contest_address: r.contest_address,
+        end_time: new Date(r.end_time),
         max_contest_id: r.max_contest_id,
         actions: r.actions,
       }));

libs/model/src/contest/index.ts

@@ -10,5 +10,4 @@ export * from './GetContest.query';
 export * from './GetContestLog.query';
 export * from './GetFarcasterContestCasts';
 export * from './GetFarcasterUpvoteActionMetadata.query';
-export * from './PerformContestRollovers.command';
 export * from './UpdateContestManagerMetadata.command';