2024-05-16 20:15:02 +08:00
|
|
|
import { MessageType } from '@/constants/chat';
|
2024-02-28 16:28:33 +08:00
|
|
|
import { IConversation, IReference } from '@/interfaces/database/chat';
|
2024-02-26 18:38:54 +08:00
|
|
|
import { EmptyConversationId, variableEnabledFieldMap } from './constants';
|
2024-05-16 20:15:02 +08:00
|
|
|
import { IClientConversation, IMessage } from './interface';
|
2024-02-22 17:14:25 +08:00
|
|
|
|
|
|
|
|
export const excludeUnEnabledVariables = (values: any) => {
|
|
|
|
|
const unEnabledFields: Array<keyof typeof variableEnabledFieldMap> =
|
|
|
|
|
Object.keys(variableEnabledFieldMap).filter((key) => !values[key]) as Array<
|
|
|
|
|
keyof typeof variableEnabledFieldMap
|
|
|
|
|
>;
|
|
|
|
|
|
|
|
|
|
return unEnabledFields.map(
|
|
|
|
|
(key) => `llm_setting.${variableEnabledFieldMap[key]}`,
|
|
|
|
|
);
|
|
|
|
|
};
|
2024-02-26 18:38:54 +08:00
|
|
|
|
2024-02-28 16:28:33 +08:00
|
|
|
export const isConversationIdExist = (conversationId: string) => {
|
2024-02-26 18:38:54 +08:00
|
|
|
return conversationId !== EmptyConversationId && conversationId !== '';
|
|
|
|
|
};
|
2024-02-28 16:28:33 +08:00
|
|
|
|
|
|
|
|
export const getDocumentIdsFromConversionReference = (data: IConversation) => {
|
|
|
|
|
const documentIds = data.reference.reduce(
|
|
|
|
|
(pre: Array<string>, cur: IReference) => {
|
|
|
|
|
cur.doc_aggs
|
2024-05-16 20:15:02 +08:00
|
|
|
?.map((x) => x.doc_id)
|
2024-02-28 16:28:33 +08:00
|
|
|
.forEach((x) => {
|
|
|
|
|
if (pre.every((y) => y !== x)) {
|
|
|
|
|
pre.push(x);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
return pre;
|
|
|
|
|
},
|
|
|
|
|
[],
|
|
|
|
|
);
|
|
|
|
|
return documentIds.join(',');
|
|
|
|
|
};
|
2024-05-16 20:15:02 +08:00
|
|
|
|
|
|
|
|
export const buildMessageItemReference = (
|
|
|
|
|
conversation: IClientConversation,
|
|
|
|
|
message: IMessage,
|
|
|
|
|
) => {
|
|
|
|
|
const assistantMessages = conversation.message
|
|
|
|
|
?.filter((x) => x.role === MessageType.Assistant)
|
|
|
|
|
.slice(1);
|
|
|
|
|
const referenceIndex = assistantMessages.findIndex(
|
|
|
|
|
(x) => x.id === message.id,
|
|
|
|
|
);
|
|
|
|
|
const reference = message?.reference
|
|
|
|
|
? message?.reference
|
|
|
|
|
: conversation.reference[referenceIndex];
|
|
|
|
|
|
|
|
|
|
return reference;
|
|
|
|
|
};
|