Add account method to get full social ids by person ids (#9654)

Signed-off-by: Artem Savchenko <[email protected]>

Author: ArtyomSavchenko

packages/account-client/src/client.ts

@@ -124,6 +124,7 @@ export interface AccountClient {
   findPersonBySocialId: (socialId: PersonId, requireAccount?: boolean) => Promise<PersonUuid | undefined>
   findSocialIdBySocialKey: (socialKey: string) => Promise<PersonId | undefined>
   findFullSocialIdBySocialKey: (socialKey: string) => Promise<SocialId | undefined>
+  findFullSocialIds: (socialIds: PersonId[]) => Promise<SocialId[]>
   getMailboxOptions: () => Promise<MailboxOptions>
   createMailbox: (name: string, domain: string) => Promise<{ mailbox: string, socialId: PersonId }>
   getMailboxes: () => Promise<MailboxInfo[]>
@@ -740,6 +741,14 @@ class AccountClientImpl implements AccountClient {
     return await this.rpc(request)
   }
 
+  async findFullSocialIds (socialIds: PersonId[]): Promise<SocialId[]> {
+    const request = {
+      method: 'findFullSocialIds' as const,
+      params: { socialIds }
+    }
+    return await this.rpc(request)
+  }
+
   async listWorkspaces (region?: string | null, mode: WorkspaceMode | null = null): Promise<WorkspaceInfoWithStatus[]> {
     const request = {
       method: 'listWorkspaces' as const,

server/account/src/serviceOperations.ts

@@ -555,7 +555,7 @@ export async function getPersonInfo (
 ): Promise<PersonInfo> {
   const { account } = params
   const { extra } = decodeTokenVerbose(ctx, token)
-  verifyAllowedServices(['workspace', 'tool'], extra)
+  verifyAllowedServices(['workspace', 'tool', 'gmail'], extra)
 
   if (account == null || account === '') {
     throw new PlatformError(new Status(Severity.ERROR, platform.status.BadRequest, {}))
@@ -908,6 +908,24 @@ export async function findFullSocialIdBySocialKey (
   return await db.socialId.findOne({ key: socialKey })
 }
 
+export async function findFullSocialIds (
+  ctx: MeasureContext,
+  db: AccountDB,
+  branding: Branding | null,
+  token: string,
+  params: { socialIds: PersonId[] }
+): Promise<SocialId[]> {
+  const { socialIds } = params
+  const { extra } = decodeTokenVerbose(ctx, token)
+  verifyAllowedServices(['gmail', 'tool', 'workspace'], extra)
+
+  if (socialIds == null || socialIds.length === 0) {
+    throw new PlatformError(new Status(Severity.ERROR, platform.status.BadRequest, {}))
+  }
+
+  return await db.socialId.find({ _id: { $in: socialIds } })
+}
+
 export async function mergeSpecifiedPersons (
   ctx: MeasureContext,
   db: AccountDB,
@@ -1009,6 +1027,7 @@ export type AccountServiceMethods =
   | 'mergeSpecifiedAccounts'
   | 'findPersonBySocialKey'
   | 'listAccounts'
+  | 'findFullSocialIds'
 
 /**
  * @public
@@ -1037,6 +1056,7 @@ export function getServiceMethods (): Partial<Record<AccountServiceMethods, Acco
     getIntegrationSecret: wrap(getIntegrationSecret),
     listIntegrationsSecrets: wrap(listIntegrationsSecrets),
     findFullSocialIdBySocialKey: wrap(findFullSocialIdBySocialKey),
+    findFullSocialIds: wrap(findFullSocialIds),
     mergeSpecifiedPersons: wrap(mergeSpecifiedPersons),
     mergeSpecifiedAccounts: wrap(mergeSpecifiedAccounts),
     findPersonBySocialKey: wrap(findPersonBySocialKey),