40073-vm/backend/src/db/api/conversations.js
2026-05-25 13:04:02 +00:00

610 lines
15 KiB
JavaScript

const db = require('../models');
const FileDBApi = require('./file');
const crypto = require('crypto');
const Utils = require('../utils');
const Sequelize = db.Sequelize;
const Op = Sequelize.Op;
function buildOwnedConversationWhere(currentUser) {
if (!currentUser || !currentUser.id) {
return {};
}
return {
userId: currentUser.id,
};
}
function mergeWhere(left, right) {
const hasLeft = left && Object.keys(left).length;
const hasRight = right && Object.keys(right).length;
if (!hasLeft) {
return right || {};
}
if (!hasRight) {
return left || {};
}
return {
[Op.and]: [left, right],
};
}
module.exports = class ConversationsDBApi {
static async create(data, options) {
const currentUser = (options && options.currentUser) || { id: null };
const transaction = (options && options.transaction) || undefined;
const conversations = await db.conversations.create(
{
id: data.id || undefined,
title: data.title
||
null
,
summary: data.summary
||
null
,
status: data.status
||
null
,
is_pinned: data.is_pinned
||
false
,
last_message_at: data.last_message_at
||
null
,
client_context_json: data.client_context_json
||
null
,
importHash: data.importHash || null,
createdById: currentUser.id,
updatedById: currentUser.id,
},
{ transaction },
);
await conversations.setUser( currentUser.id || null, {
transaction,
});
await conversations.setAgent( data.agent || null, {
transaction,
});
return conversations;
}
static async bulkImport(data, options) {
const currentUser = (options && options.currentUser) || { id: null };
const transaction = (options && options.transaction) || undefined;
// Prepare data - wrapping individual data transformations in a map() method
const conversationsData = data.map((item, index) => ({
id: item.id || undefined,
title: item.title
||
null
,
summary: item.summary
||
null
,
status: item.status
||
null
,
is_pinned: item.is_pinned
||
false
,
last_message_at: item.last_message_at
||
null
,
client_context_json: item.client_context_json
||
null
,
importHash: item.importHash || null,
createdById: currentUser.id,
updatedById: currentUser.id,
createdAt: new Date(Date.now() + index * 1000),
}));
// Bulk create items
const conversations = await db.conversations.bulkCreate(conversationsData, { transaction });
// For each item created, replace relation files
return conversations;
}
static async update(id, data, options) {
const currentUser = (options && options.currentUser) || {id: null};
const transaction = (options && options.transaction) || undefined;
const conversations = await db.conversations.findOne({
where: mergeWhere(
{ id },
buildOwnedConversationWhere(currentUser),
),
transaction,
});
if (!conversations) {
throw new Error('Conversation not found.');
}
const updatePayload = {};
if (data.title !== undefined) updatePayload.title = data.title;
if (data.summary !== undefined) updatePayload.summary = data.summary;
if (data.status !== undefined) updatePayload.status = data.status;
if (data.is_pinned !== undefined) updatePayload.is_pinned = data.is_pinned;
if (data.last_message_at !== undefined) updatePayload.last_message_at = data.last_message_at;
if (data.client_context_json !== undefined) updatePayload.client_context_json = data.client_context_json;
updatePayload.updatedById = currentUser.id;
await conversations.update(updatePayload, {transaction});
if (data.user !== undefined) {
await conversations.setUser(
data.user,
{ transaction }
);
}
if (data.agent !== undefined) {
await conversations.setAgent(
data.agent,
{ transaction }
);
}
return conversations;
}
static async deleteByIds(ids, options) {
const currentUser = (options && options.currentUser) || { id: null };
const transaction = (options && options.transaction) || undefined;
const conversations = await db.conversations.findAll({
where: mergeWhere(
{
id: {
[Op.in]: ids,
},
},
buildOwnedConversationWhere(currentUser),
),
transaction,
});
if (conversations.length !== ids.length) {
throw new Error('One or more conversations were not found.');
}
await db.sequelize.transaction(async (transaction) => {
for (const record of conversations) {
await record.update(
{deletedBy: currentUser.id},
{transaction}
);
}
for (const record of conversations) {
await record.destroy({transaction});
}
});
return conversations;
}
static async remove(id, options) {
const currentUser = (options && options.currentUser) || {id: null};
const transaction = (options && options.transaction) || undefined;
const conversations = await db.conversations.findOne({
where: mergeWhere(
{ id },
buildOwnedConversationWhere(currentUser),
),
transaction,
});
if (!conversations) {
throw new Error('Conversation not found.');
}
await conversations.update({
deletedBy: currentUser.id
}, {
transaction,
});
await conversations.destroy({
transaction
});
return conversations;
}
static async findBy(where, options) {
const currentUser = (options && options.currentUser) || { id: null };
const transaction = (options && options.transaction) || undefined;
const conversations = await db.conversations.findOne(
{
where: mergeWhere(
where,
buildOwnedConversationWhere(currentUser),
),
transaction,
},
);
if (!conversations) {
return conversations;
}
const output = conversations.get({plain: true});
output.messages_conversation = await conversations.getMessages_conversation({
transaction
});
output.usage_events_conversation = await conversations.getUsage_events_conversation({
transaction
});
output.user = await conversations.getUser({
transaction
});
output.agent = await conversations.getAgent({
transaction
});
return output;
}
static async findAll(
filter,
options
) {
const currentUser = (options && options.currentUser) || { id: null };
const limit = filter.limit || 0;
let offset = 0;
let where = {};
const currentPage = +filter.page;
offset = currentPage * limit;
const orderBy = null;
const transaction = (options && options.transaction) || undefined;
let include = [
{
model: db.users,
as: 'user',
where: filter.user ? {
[Op.or]: [
{ id: { [Op.in]: filter.user.split('|').map(term => Utils.uuid(term)) } },
{
firstName: {
[Op.or]: filter.user.split('|').map(term => ({ [Op.iLike]: `%${term}%` }))
}
},
]
} : {},
},
{
model: db.agents,
as: 'agent',
where: filter.agent ? {
[Op.or]: [
{ id: { [Op.in]: filter.agent.split('|').map(term => Utils.uuid(term)) } },
{
name: {
[Op.or]: filter.agent.split('|').map(term => ({ [Op.iLike]: `%${term}%` }))
}
},
]
} : {},
},
];
if (filter) {
if (filter.id) {
where = {
...where,
['id']: Utils.uuid(filter.id),
};
}
if (filter.title) {
where = {
...where,
[Op.and]: Utils.ilike(
'conversations',
'title',
filter.title,
),
};
}
if (filter.summary) {
where = {
...where,
[Op.and]: Utils.ilike(
'conversations',
'summary',
filter.summary,
),
};
}
if (filter.client_context_json) {
where = {
...where,
[Op.and]: Utils.ilike(
'conversations',
'client_context_json',
filter.client_context_json,
),
};
}
if (filter.last_message_atRange) {
const [start, end] = filter.last_message_atRange;
if (start !== undefined && start !== null && start !== '') {
where = {
...where,
last_message_at: {
...where.last_message_at,
[Op.gte]: start,
},
};
}
if (end !== undefined && end !== null && end !== '') {
where = {
...where,
last_message_at: {
...where.last_message_at,
[Op.lte]: end,
},
};
}
}
if (filter.active !== undefined) {
where = {
...where,
active: filter.active === true || filter.active === 'true'
};
}
if (filter.status) {
where = {
...where,
status: filter.status,
};
}
if (filter.is_pinned) {
where = {
...where,
is_pinned: filter.is_pinned,
};
}
if (filter.createdAtRange) {
const [start, end] = filter.createdAtRange;
if (start !== undefined && start !== null && start !== '') {
where = {
...where,
['createdAt']: {
...where.createdAt,
[Op.gte]: start,
},
};
}
if (end !== undefined && end !== null && end !== '') {
where = {
...where,
['createdAt']: {
...where.createdAt,
[Op.lte]: end,
},
};
}
}
}
const queryOptions = {
where: mergeWhere(
where,
buildOwnedConversationWhere(currentUser),
),
include,
distinct: true,
order: filter.field && filter.sort
? [[filter.field, filter.sort]]
: [['createdAt', 'desc']],
transaction: options?.transaction,
logging: console.log
};
if (!options?.countOnly) {
queryOptions.limit = limit ? Number(limit) : undefined;
queryOptions.offset = offset ? Number(offset) : undefined;
}
try {
const { rows, count } = await db.conversations.findAndCountAll(queryOptions);
return {
rows: options?.countOnly ? [] : rows,
count: count
};
} catch (error) {
console.error('Error executing query:', error);
throw error;
}
}
static async findAllAutocomplete(query, limit, offset, options) {
const currentUser = (options && options.currentUser) || { id: null };
let where = {};
if (query) {
where = {
[Op.or]: [
{ ['id']: Utils.uuid(query) },
Utils.ilike(
'conversations',
'title',
query,
),
],
};
}
const records = await db.conversations.findAll({
attributes: [ 'id', 'title' ],
where: mergeWhere(
where,
buildOwnedConversationWhere(currentUser),
),
limit: limit ? Number(limit) : undefined,
offset: offset ? Number(offset) : undefined,
orderBy: [['title', 'ASC']],
});
return records.map((record) => ({
id: record.id,
label: record.title,
}));
}
};