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
+
 ## [0.55.0] - 2024-08-22
 
 ### Added

graphql/schema.graphql

@@ -92,6 +92,10 @@ type Query {
   getOrganizationsByEmail(email: String): [B2BOrganization]
     @checkUserAccess
     @cacheControl(scope: PRIVATE)
+
+  getOrganizationsByEmailPaginated(email: String, page: Int, pageSize: Int): B2BOrganizationPagination
+    @checkUserAccess
+    @cacheControl(scope: PRIVATE)
 
   checkOrganizationIsActive(id: String): Boolean
     @cacheControl(scope: PRIVATE)
@@ -475,6 +479,11 @@ type B2BOrganization {
   costCenterName: String
 }
 
+type B2BOrganizationPagination {
+  data: [B2BOrganization]
+  pagination: Pagination
+}
+
 type SimpleRole {
   id: ID
   name: String!

node/clients/storefrontPermissions.ts

@@ -8,6 +8,7 @@
 import updateUser from '../mutations/updateUser'
 import getB2BUser from '../queries/getB2BUser'
 import getOrganizationsByEmail from '../queries/getOrganizationsByEmail'
+import getOrganizationsByEmailPaginated from '../queries/getOrganizationsByEmailPaginated'
 import getPermission from '../queries/getPermission'
 import getRole from '../queries/getRole'
 import getUser from '../queries/getUser'
@@ -22,7 +23,7 @@
     super('[email protected]', ctx, options)
   }
 
   public checkUserPermission = async (app?: string): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(app),
       query: getPermission,
@@ -30,7 +31,7 @@
     })
   }
 
   public getOrganizationsByEmail = async (email: string): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: getOrganizationsByEmail,
@@ -40,7 +41,23 @@
     })
   }
 
+  public getOrganizationsByEmailPaginated = async (
+    email: string,
+    page: number,
+    pageSize: number
+  ): Promise<any> => {
+    return this.query({
+      extensions: this.getPersistedQuery(),
+      query: getOrganizationsByEmailPaginated,
+      variables: {
+        email,
+        page,
+        pageSize,
+      },
+    })
+  }
+
   public listRoles = async (): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: listRoles,
@@ -48,7 +65,7 @@
     })
   }
 
   public getRole = async (roleId: string): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: getRole,
@@ -56,7 +73,7 @@
     })
   }
 
   public listAllUsers = async (): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: listAllUsers,
@@ -72,7 +89,7 @@
     roleId?: string
     organizationId?: string
     costCenterId?: string
   }): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: listUsers,
@@ -102,7 +119,7 @@
     pageSize?: number
     sortOrder?: string
     sortedBy?: string
   }): Promise<any> => {
     return this.query({
       extensions: this.getPersistedQuery(),
       query: listUsersPaginated,

node/queries/getOrganizationsByEmailPaginated.ts

@@ -0,0 +1,25 @@
+import { print } from 'graphql'
+import gql from 'graphql-tag'
+
+export default print(gql`
+  query organizationsPaginated($email: String!, $page: Int, $pageSize: Int) {
+    getOrganizationsByEmailPaginated(
+      email: $email
+      page: $page
+      pageSize: $pageSize
+    ) {
+      data {
+        costId
+        orgId
+        roleId
+        id
+        clId
+      }
+      pagination {
+        page
+        pageSize
+        total
+      }
+    }
+  }
+`)

node/resolvers/Queries/Organizations.ts

@@ -241,6 +241,111 @@ const Organizations = {
     }
   },
 
+  getOrganizationsByEmailPaginated: async (
+    _: void,
+    {
+      email,
+      page = 1,
+      pageSize = 25,
+    }: {
+      email: string
+      page: number
+      pageSize: number
+    },
+    {
+      clients: { storefrontPermissions, session },
+      vtex: { logger, sessionToken, adminUserAuthToken },
+    }: any
+  ) => {
+    const organizationFilters: string[] = []
+    let fromSession = false
+    const {
+      data: { checkUserPermission },
+    }: any = await storefrontPermissions
+      .checkUserPermission('[email protected]')
+      .catch((error: any) => {
+        logger.error({
+          error,
+          message: 'checkUserPermission-error',
+        })
+
+        return {
+          data: {
+            checkUserPermission: null,
+          },
+        }
+      })
+
+    if (
+      (!adminUserAuthToken &&
+        !checkUserPermission?.permissions.includes('add-sales-users-all')) ||
+      !(email?.length > 0)
+    ) {
+      const sessionData = await session
+        .getSession(sessionToken as string, ['*'])
+        .then((currentSession: any) => {
+          return currentSession.sessionData
+        })
+        .catch((error: any) => {
+          logger.warn({
+            error,
+            message: 'getOrganizationsByEmail-session-error',
+          })
+
+          return null
+        })
+
+      if (checkUserPermission?.permissions.includes('add-users-organization')) {
+        const orgId =
+          sessionData?.namespaces?.['storefront-permissions']?.organization
+            ?.value
+
+        if (!orgId) {
+          throw new Error('No permission for getting the organizations')
+        }
+
+        organizationFilters.push(orgId)
+      }
+
+      if (!(email?.length > 0)) {
+        email = sessionData?.namespaces?.profile?.email?.value
+        fromSession = true
+      }
+    }
+
+    const response =
+      await storefrontPermissions.getOrganizationsByEmailPaginated(
+        email,
+        page,
+        pageSize
+      )
+
+    const organizations =
+      response?.data?.getOrganizationsByEmailPaginated?.data?.filter(
+        ({ orgId }: { orgId: string }) => {
+          return (
+            fromSession ||
+            (organizationFilters.length > 0
+              ? organizationFilters.find((id: string) => orgId === id)
+              : true)
+          )
+        }
+      )
+
+    try {
+      return {
+        data: organizations,
+        pagination: response.data?.getOrganizationsByEmailPaginated?.pagination,
+      }
+    } catch (error) {
+      logger.error({
+        error,
+        message: 'getOrganizationsByEmail-error',
+      })
+      throw new GraphQLError(getErrorMessage(error))
+    }
+  },
+
   getOrganizationByIdStorefront: async (
     _: void,
     { id }: { id: string },