feat: Adds alertsConnection under Partner type to access search criteria + partner facing search crit data

_schemaV2.graphql

@@ -14682,6 +14682,15 @@ type Partner implements Node {
   ): LocationConnection
   meta: PartnerMeta
   name: String
+  partnerAlertsConnection(
+    after: String
+    before: String
+    first: Int
+    last: Int
+    page: Int
+    size: Int
+    totalCount: Boolean
+  ): PartnerAlertsConnection
   partnerPageEligible: Boolean
   partnerType: String
   profile: Profile
@@ -14755,6 +14764,43 @@ type PartnerAgreement {
 # A partner agreement or errors object
 union PartnerAgreementOrErrorsUnion = Errors | PartnerAgreement
 
+type PartnerAlert {
+  artistId: String
+  collectorProfilesConnection(
+    after: String
+    before: String
+    first: Int
+    last: Int
+    totalCount: Boolean
+  ): PartnerCollectorProfilesConnection
+  id: String
+  matchedAt: String
+  partnerId: String
+  score: String
+  searchCriteriaId: String
+  userIds: [String]
+}
+
+# A connection to a list of items.
+type PartnerAlertsConnection {
+  # A list of edges.
+  edges: [PartnerAlertsEdge]
+  pageCursors: PageCursors!
+
+  # Information to aid in pagination.
+  pageInfo: PageInfo!
+  totalCount: Int
+}
+
+# An edge in a connection.
+type PartnerAlertsEdge {
+  # A cursor for use in pagination
+  cursor: String!
+
+  # The item at the end of the edge
+  node: PartnerAlert
+}
+
 type PartnerArtist {
   artist: Artist
   artworksConnection(
@@ -14971,6 +15017,26 @@ enum PartnerClassification {
   PRIVATE_DEALER
 }
 
+# A connection to a list of items.
+type PartnerCollectorProfilesConnection {
+  # A list of edges.
+  edges: [PartnerCollectorProfilesEdge]
+  pageCursors: PageCursors!
+
+  # Information to aid in pagination.
+  pageInfo: PageInfo!
+  totalCount: Int
+}
+
+# An edge in a connection.
+type PartnerCollectorProfilesEdge {
+  # A cursor for use in pagination
+  cursor: String!
+
+  # The item at the end of the edge
+  node: CollectorProfileType
+}
+
 # A connection to a list of items.
 type PartnerConnection {
   # A list of edges.

src/lib/loaders/loaders_with_authentication/gravity.ts

@@ -643,6 +643,22 @@ export default (accessToken, userID, opts) => {
       {},
       { headers: true }
     ),
+    partnerSearchCriteriaLoader: gravityLoader(
+      (id) => `/partner/${id}/partner_search_criterias`,
+      {},
+      { headers: true }
+    ),
+    partnerCollectorProfilesLoader: gravityLoader<
+      any,
+      { partner_id: string; user_ids: string[] }
+    >(
+      ({ partner_id, user_ids }) => {
+        const userIdsParams = user_ids.map((id) => `user_ids[]=${id}`).join("&")
+        return `/partner_collector_profiles?partner_id=${partner_id}&${userIdsParams}`
+      },
+      {},
+      { headers: true }
+    ),
     partnerShowsLoader: gravityLoader(
       (partner_id) => `partner/${partner_id}/shows`,
       {},

src/schema/v2/partner/__tests__/partner.test.js

@@ -1421,6 +1421,69 @@ describe("Partner type", () => {
     })
   })
 
+  describe("#partnerAlertsConnection", () => {
+    it("returns the summary of artists with recently enabled user search criteria", async () => {  
+     const response = 
+       {
+        body: {
+          hits: [
+          {
+            id: '8754ff90-b020-425b-8dae-894ce5ad9d1f',
+            search_criteria_id: '3f980bbe-7b9b-4fa9-beb1-69d13e94fb0c',
+            partner_id: '5f80bfefe8d808000ea212c1',
+
+          },
+          {
+            id: 'b4adc50d-a584-4820-9140-4d49d7b6c7dc',
+            search_criteria_id: '614af56c-88cb-4ea7-bec5-fbdf9b67c24a',
+            partner_id: '5f80bfefe8d808000ea212c1',
+          },
+        ],
+        },
+         headers: {
+           "x-total-count": 2,
+         },
+       }
+
+      const query = gql`
+        {
+          partner(id: "catty-partner") {
+            partnerAlertsConnection(first: 10) {
+              edges {
+                node {
+                  id
+                }
+              }
+            }
+          }
+        }
+      `
+      const partnerSearchCriteriaLoader = () => Promise.resolve(response)
+      const data = await runAuthenticatedQuery(query, {
+        ...context,
+        partnerSearchCriteriaLoader,
+      })
+      expect(data).toEqual({
+        partner: {
+          partnerAlertsConnection: {
+            edges: [
+              {
+                node: {
+                  id: "8754ff90-b020-425b-8dae-894ce5ad9d1f",
+                },
+              },
+              {
+                node: {
+                  id: "b4adc50d-a584-4820-9140-4d49d7b6c7dc"
+                }
+              }
+            ],
+          },
+        },
+      })
+    })
+  })
+
   describe("#alertsSummaryArtistsConnection", () => {
     it("returns the summary of artists with recently enabled user search criteria", async () => {
       const summaryResponse = {

src/schema/v2/partner/partner.ts

@@ -51,6 +51,7 @@ import {
   ArtworkVisibility,
   ArtworkVisibilityEnumValues,
 } from "schema/v2/artwork/artworkVisibility"
+import { PartnerAlertType } from "./partnerAlerts"
 
 const isFairOrganizer = (type) => type === "FairOrganizer"
 const isGallery = (type) => type === "PartnerGallery"
@@ -154,6 +155,11 @@ export const PartnerType = new GraphQLObjectType<any, ResolverContext>({
       nodeType: ArtistType,
     }).connectionType
 
+    const PartnerAlertsConnectionType = connectionWithCursorInfo({
+      name: "PartnerAlerts",
+      nodeType: PartnerAlertType,
+    }).connectionType
+
     return {
       ...SlugAndInternalIDFields,
       cached,
@@ -222,6 +228,54 @@ export const PartnerType = new GraphQLObjectType<any, ResolverContext>({
           })
         },
       },
+      partnerAlertsConnection: {
+        type: PartnerAlertsConnectionType,
+        args: pageable({
+          page: {
+            type: GraphQLInt,
+          },
+          size: {
+            type: GraphQLInt,
+          },
+          totalCount: {
+            type: GraphQLBoolean,
+          },
+        }),
+        resolve: async ({ _id }, args, { partnerSearchCriteriaLoader }) => {
+          if (!partnerSearchCriteriaLoader) return null
+          const { page, size, offset } = convertConnectionArgsToGravityArgs(
+            args
+          )
+
+          type GravityArgs = {
+            page: number
+            size: number
+            total_count?: number
+          }
+
+          const gravityArgs: GravityArgs = {
+            page,
+            size,
+            total_count: args.totalCount,
+          }
+
+          const { body, headers } = await partnerSearchCriteriaLoader?.(
+            _id,
+            gravityArgs
+          )
+          const totalCount = parseInt(headers["x-total-count"] || "0", 10)
+
+          return paginationResolver({
+            totalCount,
+            offset,
+            page,
+            size,
+            body: body.hits,
+            args,
+            resolveNode: (node) => node,
+          })
+        },
+      },
       articlesConnection: {
         description: "A connection of articles related to a partner.",
         type: articleConnection.connectionType,

src/schema/v2/partner/partnerAlerts.ts

@@ -0,0 +1,99 @@
+import { pageable } from "relay-cursor-paging"
+import {
+  GraphQLString,
+  GraphQLObjectType,
+  GraphQLList,
+  GraphQLBoolean,
+} from "graphql"
+import {
+  connectionWithCursorInfo,
+  createPageCursors,
+} from "schema/v2/fields/pagination"
+import { connectionFromArraySlice } from "graphql-relay"
+import { convertConnectionArgsToGravityArgs } from "lib/helpers"
+import { CollectorProfileType } from "schema/v2/CollectorProfile/collectorProfile"
+
+const PartnerCollectorProfilesConnectionType = connectionWithCursorInfo({
+  name: "PartnerCollectorProfiles",
+  nodeType: CollectorProfileType,
+}).connectionType
+
+export const PartnerAlertType = new GraphQLObjectType({
+  name: "PartnerAlert",
+  fields: {
+    id: { type: GraphQLString },
+    searchCriteriaId: {
+      type: GraphQLString,
+      resolve: ({ search_criteria_id }) => search_criteria_id,
+    },
+    partnerId: {
+      type: GraphQLString,
+      resolve: ({ partner_id }) => partner_id,
+    },
+    score: { type: GraphQLString },
+    matchedAt: {
+      type: GraphQLString,
+      resolve: ({ matched_at }) => matched_at,
+    },
+    userIds: {
+      type: new GraphQLList(GraphQLString),
+      resolve: ({ user_ids }) => user_ids,
+    },
+    artistId: {
+      type: GraphQLString,
+      resolve: ({ artist_id }) => artist_id,
+    },
+    collectorProfilesConnection: {
+      type: PartnerCollectorProfilesConnectionType,
+      args: pageable({
+        totalCount: {
+          type: GraphQLBoolean,
+        },
+      }),
+      resolve: async (parent, args, { partnerCollectorProfilesLoader }) => {
+        if (!partnerCollectorProfilesLoader) return null
+
+        const { page, size, offset } = convertConnectionArgsToGravityArgs(args)
+
+        console.log("inside seconds api call")
+        type GravityArgs = {
+          page: number
+          size: number
+          partner_id: string
+          user_ids: string[]
+          total_count?: number
+        }
+
+        const gravityArgs: GravityArgs = {
+          page,
+          size,
+          total_count: args.totalCount,
+          partner_id: parent.partner_id,
+          user_ids: parent.user_ids,
+        }
+
+        const data = await partnerCollectorProfilesLoader(gravityArgs)
+
+        console.log("data", data)
+
+        const collectorProfiles = data.body.flatMap((item) =>
+          item.collector_profile ? [item.collector_profile].flat() : []
+        )
+
+        return {
+          totalCount: collectorProfiles.length,
+          pageCursors: createPageCursors(
+            { ...args, page, size },
+            collectorProfiles.length
+          ),
+          ...connectionFromArraySlice(collectorProfiles, args, {
+            arrayLength: collectorProfiles.length,
+            sliceStart: offset,
+          }),
+        }
+      },
+    },
+  },
+})
+
+// export default PartnerAlertType