UBERF-12966: Send messages from Gmail threads (#9657)

Signed-off-by: Artem Savchenko <[email protected]>
Signed-off-by: Artyom Savchenko <[email protected]>
Co-authored-by: Copilot Autofix powered by AI <62310815+github-advanced-security[bot]@users.noreply.github.com>

Author: ArtyomSavchenko

common/config/rush/pnpm-lock.yaml

@@ -65,6 +65,7 @@
     "@hcengineering/client": "^0.6.18",
     "@hcengineering/client-resources": "^0.6.27",
     "@hcengineering/communication-sdk-types": "^0.1.0",
+    "@hcengineering/communication-rest-client": "^0.1.0",
     "@hcengineering/contact": "^0.6.24",
     "@hcengineering/kvs-client": "^0.6.0",
     "@hcengineering/mail-common": "^0.6.0",
@@ -77,6 +78,7 @@
     "@hcengineering/server-storage": "^0.6.0",
     "@hcengineering/server-token": "^0.6.11",
     "@hcengineering/integration-client": "^0.6.0",
+    "@hcengineering/kafka": "^0.6.0",
     "cors": "^2.8.5",
     "dotenv": "~16.0.0",
     "express": "^4.21.2",

services/gmail/pod-gmail/package.json

@@ -39,11 +39,23 @@ jest.mock('@hcengineering/core', () => {
     WorkspaceUuid: String,
     // Provide missing properties
     configUserAccountUuid: 'test-user-id',
+    systemAccountUuid: 'system-user-id',
     core: {
       space: {
         Workspace: 'workspace'
       }
     },
+    // Add toFindResult function to fix the import error
+    toFindResult: jest.fn().mockImplementation((items: any[]) => ({
+      items,
+      total: items.length
+    })),
+    // Add withContext decorator mock
+    withContext: jest.fn().mockImplementation((name: string) => {
+      return function (target: any, propertyKey: string, descriptor: PropertyDescriptor) {
+        return descriptor
+      }
+    }),
     TxOperations: jest.fn().mockImplementation(() => ({
       findAll: jest.fn().mockResolvedValue([]),
       findOne: jest.fn().mockResolvedValue(undefined),
@@ -60,7 +72,9 @@ jest.mock('@hcengineering/core', () => {
 })
 
 jest.mock('@hcengineering/mail-common', () => ({
-  createMessages: jest.fn().mockResolvedValue(undefined)
+  createMessages: jest.fn().mockResolvedValue(undefined),
+  getChannel: jest.fn().mockResolvedValue({ _id: 'test-channel-id' }),
+  isSyncedMessage: jest.fn().mockReturnValue(false)
 }))
 
 jest.mock('googleapis', () => ({
@@ -79,8 +93,12 @@ jest.mock('../tokens')
 jest.mock('../message/adapter')
 jest.mock('../message/sync')
 jest.mock('../message/attachments')
-jest.mock('@hcengineering/server-client', () => ({
-  getAccountClient: jest.fn()
+jest.mock('@hcengineering/server-core', () => ({
+  withContext: jest.fn().mockImplementation((name: string) => {
+    return function (target: any, propertyKey: string, descriptor: PropertyDescriptor) {
+      return descriptor
+    }
+  })
 }))
 jest.mock('../accounts', () => ({
   getOrCreateSocialId: jest.fn().mockResolvedValue({ _id: 'test-social-id' })
@@ -89,7 +107,7 @@ jest.mock('../gmail/utils', () => ({
   getEmail: jest.fn().mockResolvedValue('[email protected]')
 }))
 jest.mock('../integrations', () => ({
-  createIntegrationIfNotEsixts: jest.fn().mockResolvedValue({ _id: 'test-integration-id' }),
+  createIntegrationIfNotExists: jest.fn().mockResolvedValue({ _id: 'test-integration-id' }),
   disableIntegration: jest.fn(),
   removeIntegration: jest.fn()
 }))
@@ -133,6 +151,15 @@ jest.mock('@hcengineering/account-client', () => ({
       endpoint: 'wss://test-endpoint.com',
       workspace: 'mockWorkspaceId',
       token: 'test-token'
+    }),
+    getPersonInfo: jest.fn().mockResolvedValue({
+      socialIds: [
+        {
+          _id: 'test-social-id',
+          value: '[email protected]',
+          type: 'email'
+        }
+      ]
     })
   })),
   isWorkspaceLoginInfo: jest.fn().mockImplementation(() => true)

services/gmail/pod-gmail/src/__tests__/gmailClient.test.ts

@@ -14,11 +14,33 @@
 // limitations under the License.
 //
 
-import { type Client } from '@hcengineering/core'
+import { WorkspaceUuid, type Client } from '@hcengineering/core'
 import { createClient, getTransactorEndpoint } from '@hcengineering/server-client'
+import { generateToken } from '@hcengineering/server-token'
+import { systemAccountUuid } from '@hcengineering/core'
+import {
+  createRestClient as createCommunicationRestClient,
+  RestClient as CommunicationRestClient
+} from '@hcengineering/communication-rest-client'
 
 export async function getClient (token: string): Promise<Client> {
   const endpoint = await getTransactorEndpoint(token)
   console.log('connecting to', endpoint)
   return await createClient(endpoint, token)
 }
+
+export async function getCommunicationClient (workspace: WorkspaceUuid): Promise<CommunicationRestClient> {
+  const token = generateToken(systemAccountUuid, workspace, { service: 'gmail' })
+  const endpoint = toHttpUrl(await getTransactorEndpoint(token))
+  return createCommunicationRestClient(endpoint, workspace, token)
+}
+
+function toHttpUrl (url: string): string {
+  if (url.startsWith('ws://')) {
+    return url.replace('ws://', 'http://')
+  }
+  if (url.startsWith('wss://')) {
+    return url.replace('wss://', 'https://')
+  }
+  return url
+}