Add new query getOrganizationsByEmailPaginated

CHANGELOG.md

@@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+### Added 
+
+- Add new `getOrganizationsByEmailPaginated` query to allow pagination on organizations by email query
+
 ## [1.44.3] - 2024-08-22
 
 ### Fixed

graphql/schema.graphql

@@ -82,6 +82,14 @@ type Query {
   getOrganizationsByEmail(email: String!): [Organization]
     @cacheControl(scope: PRIVATE)
     @validateStoreUserAccess
+
+  getOrganizationsByEmailPaginated(
+    email: String!
+    page: Int
+    pageSize: Int
+  ): OrganizationPagination
+    @cacheControl(scope: PRIVATE)
+    @validateStoreUserAccess
 }
 
 type Mutation {
@@ -215,6 +223,11 @@ type Organization {
   roleId: ID
 }
 
+type OrganizationPagination {
+  data: [Organization]
+  pagination: Pagination
+}
+
 type Profile {
   id: ID
   name: String

node/resolvers/Queries/Users.ts

@@ -135,6 +135,63 @@ export const getAllUsersByEmail = async (_: any, params: any, ctx: Context) => {
   return getAllUsers({ masterdata, logger, where })
 }
 
+export const getUsersByEmailPaginated = async ({
+  masterdata,
+  logger,
+  email,
+  page = 1,
+  pageSize = 25,
+}: {
+  masterdata: any
+  logger: any
+  email: string
+  page: number
+  pageSize: number
+}) => {
+  try {
+    const users = [] as any[]
+
+    const resp = await masterdata.searchDocumentsWithPaginationInfo({
+      dataEntity: config.name,
+      fields: [
+        'id',
+        'roleId',
+        'clId',
+        'email',
+        'name',
+        'orgId',
+        'costId',
+        'userId',
+        'canImpersonate',
+        'active',
+      ],
+      pagination: {
+        page,
+        pageSize,
+      },
+      schema: config.version,
+      where: `email = "${email}"`,
+    })
+
+    const { data } = resp as unknown as {
+      pagination: {
+        total: number
+      }
+      data: any
+    }
+
+    users.push(...data)
+
+    return users
+  } catch (error) {
+    logger.error({
+      error,
+      message: 'Profiles.getUsersByEmailPaginated-error',
+    })
+    throw new Error(error)
+  }
+}
+
 export const getActiveUserByEmail = async (
   _: any,
   params: any,
@@ -815,6 +872,44 @@ export const getOrganizationsByEmail = async (
   }
 }
 
+export const getOrganizationsByEmailPaginated = async (
+  _: any,
+  {
+    email = '',
+    page = 1,
+    pageSize = 25,
+  }: {
+    email: string
+    page: number
+    pageSize: number
+  },
+  ctx: Context
+) => {
+  const {
+    clients: { masterdata },
+    vtex: { logger },
+  } = ctx
+
+  try {
+    const data = await masterdata.searchDocumentsWithPaginationInfo({
+      dataEntity: config.name,
+      fields: ['clId', 'costId', 'id', 'orgId', 'roleId'],
+      pagination: { page, pageSize },
+      schema: config.version,
+      where: `email = "${email}"`,
+    })
+
+    return data
+  } catch (error) {
+    logger.error({
+      error,
+      message: 'getOrganizationsByEmailPaginated-error',
+    })
+
+    return { status: 'error', message: error }
+  }
+}
+
 export const getUserByEmailOrgIdAndCostId = async (
   _: any,
   params: any,

node/resolvers/index.ts

@@ -26,6 +26,7 @@ import {
   getAllUsersByEmail,
   getB2BUserById,
   getOrganizationsByEmail,
+  getOrganizationsByEmailPaginated,
   getUser,
   getUserByEmail,
   listAllUsers,
@@ -59,6 +60,7 @@ export const resolvers = {
     getB2BUser: getB2BUserById,
     getFeaturesByModule,
     getOrganizationsByEmail,
+    getOrganizationsByEmailPaginated,
     getRole,
     getSessionWatcher,
     getUser,

node/yarn.lock

@@ -1428,7 +1428,7 @@ sprintf-js@~1.0.2:
   resolved "https://registry.yarnpkg.com/sprintf-js/-/sprintf-js-1.0.3.tgz#04e6926f662895354f3dd015203633b857297e2c"
   integrity sha1-BOaSb2YolTVPPdAVIDYzuFcpfiw=
 
-"stats-lite@github:vtex/node-stats-lite#dist":
+stats-lite@vtex/node-stats-lite#dist:
   version "2.2.0"
   resolved "https://codeload.github.com/vtex/node-stats-lite/tar.gz/1b0d39cc41ef7aaecfd541191f877887a2044797"
   dependencies: