refactor: expose lastProcessdIpfsHash field

src/dataLoaders/sqlQueries/dripListsQueries.ts

@@ -47,7 +47,7 @@ async function getDripListsByIds(
   dripListIds: DripListId[],
 ) {
   const baseSQL = (schema: DbSchema) => `
-    SELECT "id", "isValid", "isVisible", "ownerAddress", "ownerAccountId", "name", "latestVotingRoundId", "description", "creator", "previousOwnerAddress", "createdAt", "updatedAt", '${schema}' AS chain
+    SELECT "id", "isValid", "isVisible", "ownerAddress", "ownerAccountId", "name", "latestVotingRoundId", "description", "creator", "previousOwnerAddress", "createdAt", "updatedAt", "lastProcessedIpfsHash", '${schema}' AS chain
     FROM "${schema}"."DripLists"
   `;
 

src/dataLoaders/sqlQueries/projectsQueries.ts

@@ -13,7 +13,7 @@ async function getProjectByUrl(
   url: string,
 ): Promise<ProjectDataValues[]> {
   const baseSQL = (schema: DbSchema) => `
-    SELECT "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", '${schema}' AS chain
+    SELECT "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", "lastProcessedIpfsHash", '${schema}' AS chain
     FROM "${schema}"."GitProjects"
   `;
 
@@ -43,7 +43,7 @@ async function getProjectsByFilter(
 ): Promise<ProjectDataValues[]> {
   const baseSQL = (schema: DbSchema) =>
     `SELECT 
-      "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", '${schema}' AS chain 
+      "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", "lastProcessedIpfsHash", '${schema}' AS chain 
      FROM "${schema}"."GitProjects" `;
 
   const conditions: string[] = ['"isValid" = true'];
@@ -91,7 +91,7 @@ async function getProjectsByIds(
   projectIds: ProjectId[],
 ): Promise<ProjectDataValues[]> {
   const baseSQL = (schema: DbSchema) => `
-  SELECT "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", '${schema}' AS chain
+  SELECT "id", "isValid", "isVisible", "name", "verificationStatus"::TEXT, "claimedAt", "forge"::TEXT, "ownerAddress", "ownerAccountId", "url", "emoji", "avatarCid", "color", "description", "createdAt", "updatedAt", "lastProcessedIpfsHash", '${schema}' AS chain
   FROM "${schema}"."GitProjects"
 `;
 

src/drip-list/DripListModel.ts

@@ -24,6 +24,7 @@ export default class DripListModel extends Model<
   public declare previousOwnerAddress: AddressLike;
   public declare latestVotingRoundId: UUID | null;
   public declare isVisible: boolean;
+  public declare lastProcessedIpfsHash: string | null;
 
   public static initialize(sequelize: Sequelize): void {
     this.init(
@@ -68,6 +69,10 @@ export default class DripListModel extends Model<
           type: DataTypes.BOOLEAN,
           allowNull: false,
         },
+        lastProcessedIpfsHash: {
+          type: DataTypes.TEXT,
+          allowNull: true,
+        },
       },
       {
         sequelize,

src/drip-list/dripListResolvers.ts

@@ -297,6 +297,8 @@ const dripListResolvers = {
       parentDripListInfo: { dripListChain, dripListId },
     }: ResolverDripListData) =>
       getLatestMetadataHashOnChain(dripListId, dripListChain),
+    lastProcessedIpfsHash: (dripListData: ResolverDripListData) =>
+      dripListData.lastProcessedIpfsHash,
   },
 };
 

src/drip-list/dripListTypeDef.ts

@@ -15,6 +15,7 @@ const dripListTypeDef = gql`
     totalEarned: [Amount!]!
     latestMetadataIpfsHash: String
     isVisible: Boolean!
+    lastProcessedIpfsHash: String
   }
 
   input DripListWhereInput {

src/project/ProjectModel.ts

@@ -42,6 +42,7 @@ export default class ProjectModel extends Model<
   public declare description: string | null;
   public declare verificationStatus: ProjectVerificationStatus;
   public declare isVisible: boolean;
+  public declare lastProcessedIpfsHash: string | null;
 
   public declare claimedAt: Date | null;
 
@@ -104,6 +105,10 @@ export default class ProjectModel extends Model<
           type: DataTypes.BOOLEAN,
           allowNull: false,
         },
+        lastProcessedIpfsHash: {
+          type: DataTypes.TEXT,
+          allowNull: true,
+        },
       },
       {
         sequelize,

src/project/projectResolvers.ts

@@ -380,6 +380,8 @@ const projectResolvers = {
       parentProjectInfo: { projectId, projectChain },
     }: ResolverUnClaimedProjectData) =>
       getLatestMetadataHashOnChain(projectId, projectChain),
+    lastProcessedIpfsHash: (projectData: ResolverClaimedProjectData) =>
+      projectData.lastProcessedIpfsHash,
   },
   UnClaimedProjectData: {
     verificationStatus: (projectData: ResolverUnClaimedProjectData) =>

src/project/projectTypeDef.ts

@@ -48,6 +48,7 @@ const projectTypeDef = gql`
     totalEarned: [Amount!]!
     withdrawableBalances: [WithdrawableBalance!]!
     latestMetadataIpfsHash: String!
+    lastProcessedIpfsHash: String
   }
 
   type UnClaimedProjectData {

src/project/projectUtils.ts

@@ -176,6 +176,7 @@ function mapClaimedProjectChainData(
     totalEarned: [], // Will be populated by the resolver.
     withdrawableBalances: [], // Will be populated by the resolver.
     latestMetadataIpfsHash: '', // Will be populated by the resolver.
+    lastProcessedIpfsHash: project.lastProcessedIpfsHash,
   } as ResolverClaimedProjectData;
 }