Files
simplex-chat/packages/simplex-chat-nodejs/src/util.ts
T
sh c8f20bcc91 core, libs: configurable queue size, library fixes (#7542)
* core: add chat_migrate_init_queue FFI export

* bots: fix BadgeServiceErrorCode API type

* nodejs: pass required command fields

* nodejs: fix migration error types

* nodejs: install libsimplex from SIMPLEX_LIBS_DIR

* nodejs: add queue size option

* nodejs: regenerate docs

* python: add queue size option

* bots: pass incognito in APIConnect

* nodejs: accept documented success responses

* python: accept documented success responses

* nodejs: dispatch each bot message once

* nodejs: fix startChat events loop lifecycle

* nodejs, python: parse multi-line bot commands

* nodejs: fix file buffer handling in addon

* nodejs: keep events loop when chat stop fails

* python: fix send_and_wait race, load lib off loop

* python: make queue size export optional

* nodejs: receive events on a dedicated thread

* nodejs: release haskell thread after receive

* python: receive on a dedicated thread per chat

* python: test receive shutdown order

* nodejs: one receive thread per chat controller

* nodejs: harden receiver shutdown and tests

* nodejs: stop chat before closing store

* python: stop chat before closing store

* nodejs, python: harden close regression and retry

* python: free results with ucrt on windows

* nodejs: enable c++ exceptions on mac and windows
2026-09-19 12:18:46 +01:00

93 lines
3.2 KiB
TypeScript

import {T} from "@simplex-chat/types"
import {BotAddressSettings} from "./api"
export function chatInfoRef(cInfo: T.ChatInfo): T.ChatRef | undefined {
switch (cInfo.type) {
case T.ChatType.Direct: return {chatType: T.ChatType.Direct, chatId: cInfo.contact.contactId}
case T.ChatType.Group: {
const chatScope: T.GroupChatScope | undefined =
cInfo.groupChatScope?.type == "memberSupport"
? {type: "memberSupport", groupMemberId_: cInfo.groupChatScope.groupMember_?.groupMemberId}
: undefined
return {chatType: T.ChatType.Group, chatId: cInfo.groupInfo.groupId, chatScope}
}
default: return undefined
}
}
export function chatInfoName(cInfo: T.ChatInfo): string {
switch (cInfo.type) {
case "direct": return `@${cInfo.contact.profile.displayName}`
case "group": {
const scope = cInfo.groupChatScope
const scopeName = scope?.type === "memberSupport"
? `(support${scope.groupMember_ ? ` ${scope.groupMember_.memberProfile.displayName}` : ""})`
: ""
return `#${cInfo.groupInfo.groupProfile.displayName}${scopeName}`
}
case "local": return "private notes"
case "contactRequest": return `request from @${cInfo.contactRequest.profile.displayName}`
case "contactConnection": {
const alias = cInfo.contactConnection.localAlias
return `pending connection${alias ? ` (@${alias})` : ""}`
}
}
}
export function senderName(cInfo: T.ChatInfo, chatDir: T.CIDirection) {
const sender = chatDir.type === "groupRcv"
? ` @${chatDir.groupMember.memberProfile.displayName}`
: ""
return chatInfoName(cInfo) + sender
}
export function contactAddressStr(link: T.CreatedConnLink): string {
return link.connShortLink || link.connFullLink
}
export function botAddressSettings({addressSettings}: T.UserContactLink): BotAddressSettings {
return {
autoAccept: addressSettings.autoAccept ? true : false,
welcomeMessage: addressSettings.autoReply,
businessAddress: addressSettings.businessAddress
}
}
export function fromLocalProfile({displayName, fullName, shortDescr, image, contactLink, preferences, peerType}: T.LocalProfile): T.Profile {
const profile = {displayName, fullName, shortDescr, image, contactLink, preferences, peerType}
for (const key in profile) {
if (typeof (profile as any)[key] === "undefined") delete (profile as any)[key]
}
return profile
}
export function ciContentText({content}: T.ChatItem): string | undefined {
switch (content.type) {
case "sndMsgContent": return content.msgContent.text;
case "rcvMsgContent": return content.msgContent.text;
default: return undefined;
}
}
export interface BotCommand {
keyword: string
params: string
}
// returns command (without /) and trimmed parameters
export function ciBotCommand(chatItem: T.ChatItem): BotCommand | undefined {
const msg = ciContentText(chatItem)?.trim()
if (msg) {
const r = msg.match(/^\/([^\s]+)([\s\S]*)/)
if (r && r.length >= 3) {
return {keyword: r[1], params: r[2].trim()}
}
}
return undefined
}
export function reactionText(reaction: T.ACIReaction): string {
const r = reaction.chatReaction
return r.reaction.type === "emoji" ? r.reaction.emoji : r.reaction.tag
}