call proposal-status to get proposalEnd

server/helpers/proposal-status.ts

@@ -0,0 +1,30 @@
+import fetch from 'node-fetch';
+
+export async function getProposalStatus(id: string, space: string) {
+  const devUrl = 'https://develop.thelao.io/api/v1/governance/proposal-status';
+  const prodUrl = 'https://thelao.io/api/v1/governance/proposal-status';
+
+  const env = process.env.ENV;
+  const endpoint = env === 'prod' ? prodUrl : devUrl;
+
+  try {
+    const proposalStatus = await fetch(endpoint, {
+      method: 'POST',
+      body: JSON.stringify([{ id, space }]),
+      headers: {
+        'Content-Type': 'application/json'
+      }
+    });
+
+    if (!proposalStatus.ok) {
+      throw new Error(
+        `Something went wrong while fetching the proposals status for ${id} ${space}`
+      );
+    }
+
+    return await proposalStatus.json();
+  } catch (error) {
+    console.error(error);
+    return [];
+  }
+}

server/index.ts

@@ -43,6 +43,7 @@ import {
 } from './helpers/adapters/postgres';
 import pkg from '../package.json';
 import db from './helpers/postgres';
+import { getProposalStatus } from './helpers/proposal-status';
 
 /**
  * Values to insert into the `events` database.
@@ -453,9 +454,13 @@ router.post('/message', async (req, res) => {
     const { payload: payloadToParse } = proposals[0];
     const payload = jsonParse(payloadToParse, payloadToParse);
 
+    const proposalStatus = await getProposalStatus(payload.proposalId, space);
+    const proposalEnd =
+      proposalStatus.length > 0 ? proposalStatus[0].proposalEnd : payload.end;
+
     const isNotInVotingWindow: boolean = ignoreVoteEndConstraint
       ? payload.start > ts
-      : ts > payload.end || payload.start > ts;
+      : ts > proposalEnd || payload.start > ts;
 
     if (isNotInVotingWindow) return sendError(res, 'not in voting window');