wieerwill/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2025-06-09 09:20:54 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

UBERF-10925: Add js doc

Browse Source 
Signed-off-by: Artem Savchenko <armisav@gmail.com>
This commit is contained in:
Artem Savchenko 2025-05-22 18:47:02 +07:00
parent 66f840c4e5
commit 1563c96133
2 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
services/gmail/pod-gmail/src/message/v2/message.ts
View File

@ -16,7 +16,7 @@ import { type GaxiosResponse } from 'gaxios'
import { gmail_v1 } from 'googleapis'
import sanitizeHtml from 'sanitize-html'
import { PersonId, TxOperations, type MeasureContext } from '@hcengineering/core'
import { type MeasureContext, PersonId, TxOperations } from '@hcengineering/core'
import {
createMessages,
parseEmailHeader,

27
services/mail/mail-common/src/message.ts
View File

@ -46,6 +46,32 @@ import { PersonSpacesCacheFactory } from './personSpaces'
import { ChannelCache, ChannelCacheFactory } from './channel'
import { ThreadLookupService } from './thread'
/**
* Creates mail messages in the platform
*
* This function processes an email message and creates corresponding chat messages. It handles:
* - Ensuring persons exist for email addresses
* - Finding or creating channels for participants
* - Creating threads for messages
* - Uploading attachments to storage
* - Sending message events to Kafka
*
* @param {BaseConfig} config - Configuration options including storage and Kafka settings
* @param {MeasureContext} ctx - Context for logging and performance measurement
* @param {TxOperations} txClient - Client for database transactions
* @param {KeyValueClient} keyValueClient - Client for key-value storage operations
* @param {Producer} producer - Kafka producer for sending message events
* @param {string} token - Authentication token for API calls
* @param {WorkspaceLoginInfo} wsInfo - Workspace information including ID and URLs
* @param {EmailMessage} message - The email message to process
* @param {Attachment[]} attachments - Array of attachments for the message
* @param {PersonId[]} [targetPersons] - Optional list of specific persons who should receive the message.
* If not provided, all existing accounts from email addresses will be used.
* @returns {Promise<void>} A promise that resolves when all messages have been created
* @throws Will log errors but not throw exceptions for partial failures
*
* @public
*/
export async function createMessages (
config: BaseConfig,
ctx: MeasureContext,
@ -56,7 +82,6 @@ export async function createMessages (
wsInfo: WorkspaceLoginInfo,
message: EmailMessage,
attachments: Attachment[],
// Persons who should receive messages in the platform, all existing accounts from email addresses by default
targetPersons?: PersonId[]
): Promise<void> {
const { mailId, from, subject, replyTo } = message