SillyTavern/public/scripts/extensions/vectors/index.js

440 lines
15 KiB
JavaScript
Raw Normal View History

import { eventSource, event_types, extension_prompt_types, getCurrentChatId, getRequestHeaders, is_send_press, saveSettingsDebounced, setExtensionPrompt, substituteParams } from "../../../script.js";
2023-09-07 23:28:06 +02:00
import { ModuleWorkerWrapper, extension_settings, getContext, renderExtensionTemplate } from "../../extensions.js";
2023-09-09 20:26:04 +02:00
import { collapseNewlines, power_user, ui_mode } from "../../power-user.js";
2023-09-17 13:09:24 +02:00
import { debounce, getStringHash as calculateHash, waitUntilCondition, onlyUnique } from "../../utils.js";
2023-09-07 23:28:06 +02:00
const MODULE_NAME = 'vectors';
export const EXTENSION_PROMPT_TAG = '3_vectors';
2023-09-07 23:28:06 +02:00
const settings = {
enabled: false,
2023-09-17 13:09:24 +02:00
source: 'transformers',
2023-09-09 20:26:04 +02:00
template: `Past events: {{text}}`,
depth: 2,
position: extension_prompt_types.IN_PROMPT,
protect: 5,
insert: 3,
query: 2,
2023-09-07 23:28:06 +02:00
};
const moduleWorker = new ModuleWorkerWrapper(synchronizeChat);
2023-09-08 14:25:10 +02:00
async function onVectorizeAllClick() {
try {
if (!settings.enabled) {
return;
}
const chatId = getCurrentChatId();
if (!chatId) {
toastr.info('No chat selected', 'Vectorization aborted');
return;
}
2023-09-08 14:25:10 +02:00
const batchSize = 5;
const elapsedLog = [];
let finished = false;
$('#vectorize_progress').show();
$('#vectorize_progress_percent').text('0');
$('#vectorize_progress_eta').text('...');
while (!finished) {
if (is_send_press) {
toastr.info('Message generation is in progress.', 'Vectorization aborted');
throw new Error('Message generation is in progress.');
}
2023-09-08 14:25:10 +02:00
const startTime = Date.now();
const remaining = await synchronizeChat(batchSize);
const elapsed = Date.now() - startTime;
elapsedLog.push(elapsed);
finished = remaining <= 0;
const total = getContext().chat.length;
const processed = total - remaining;
const processedPercent = Math.round((processed / total) * 100); // percentage of the work done
const lastElapsed = elapsedLog.slice(-5); // last 5 elapsed times
const averageElapsed = lastElapsed.reduce((a, b) => a + b, 0) / lastElapsed.length; // average time needed to process one item
2023-09-08 14:25:10 +02:00
const pace = averageElapsed / batchSize; // time needed to process one item
const remainingTime = Math.round(pace * remaining / 1000);
$('#vectorize_progress_percent').text(processedPercent);
$('#vectorize_progress_eta').text(remainingTime);
if (chatId !== getCurrentChatId()) {
throw new Error('Chat changed');
}
}
} catch (error) {
console.error('Vectors: Failed to vectorize all', error);
} finally {
$('#vectorize_progress').hide();
}
}
let syncBlocked = false;
async function synchronizeChat(batchSize = 5) {
if (!settings.enabled) {
return -1;
}
try {
await waitUntilCondition(() => !syncBlocked && !is_send_press, 1000);
} catch {
console.log('Vectors: Synchronization blocked by another process');
return -1;
}
2023-09-07 23:28:06 +02:00
try {
syncBlocked = true;
2023-09-07 23:28:06 +02:00
const context = getContext();
const chatId = getCurrentChatId();
if (!chatId || !Array.isArray(context.chat)) {
console.debug('Vectors: No chat selected');
return -1;
2023-09-07 23:28:06 +02:00
}
const hashedMessages = context.chat.filter(x => !x.is_system).map(x => ({ text: String(x.mes), hash: getStringHash(x.mes) }));
const hashesInCollection = await getSavedHashes(chatId);
const newVectorItems = hashedMessages.filter(x => !hashesInCollection.includes(x.hash));
const deletedHashes = hashesInCollection.filter(x => !hashedMessages.some(y => y.hash === x));
if (newVectorItems.length > 0) {
console.log(`Vectors: Found ${newVectorItems.length} new items. Processing ${batchSize}...`);
2023-09-08 12:57:27 +02:00
await insertVectorItems(chatId, newVectorItems.slice(0, batchSize));
2023-09-07 23:28:06 +02:00
}
if (deletedHashes.length > 0) {
await deleteVectorItems(chatId, deletedHashes);
console.log(`Vectors: Deleted ${deletedHashes.length} old hashes`);
}
2023-09-08 12:57:27 +02:00
return newVectorItems.length - batchSize;
2023-09-07 23:28:06 +02:00
} catch (error) {
2023-09-09 20:36:04 +02:00
toastr.error('Check server console for more details', 'Vectorization failed');
2023-09-07 23:28:06 +02:00
console.error('Vectors: Failed to synchronize chat', error);
2023-09-09 20:36:04 +02:00
return -1;
} finally {
syncBlocked = false;
2023-09-07 23:28:06 +02:00
}
}
// Cache object for storing hash values
const hashCache = {};
/**
* Gets the hash value for a given string
* @param {string} str Input string
* @returns {number} Hash value
*/
function getStringHash(str) {
2023-09-08 12:57:27 +02:00
// Check if the hash is already in the cache
if (hashCache.hasOwnProperty(str)) {
return hashCache[str];
}
2023-09-07 23:28:06 +02:00
2023-09-08 12:57:27 +02:00
// Calculate the hash value
const hash = calculateHash(str);
2023-09-07 23:28:06 +02:00
2023-09-08 12:57:27 +02:00
// Store the hash in the cache
hashCache[str] = hash;
2023-09-07 23:28:06 +02:00
2023-09-08 12:57:27 +02:00
return hash;
2023-09-07 23:28:06 +02:00
}
/**
* Removes the most relevant messages from the chat and displays them in the extension prompt
2023-09-07 23:28:06 +02:00
* @param {object[]} chat Array of chat messages
*/
async function rearrangeChat(chat) {
try {
2023-09-08 12:57:27 +02:00
// Clear the extension prompt
setExtensionPrompt(EXTENSION_PROMPT_TAG, '', extension_prompt_types.IN_PROMPT, 0);
2023-09-07 23:28:06 +02:00
if (!settings.enabled) {
return;
}
const chatId = getCurrentChatId();
if (!chatId || !Array.isArray(chat)) {
console.debug('Vectors: No chat selected');
return;
}
2023-09-09 20:26:04 +02:00
if (chat.length < settings.protect) {
console.debug(`Vectors: Not enough messages to rearrange (less than ${settings.protect})`);
2023-09-07 23:28:06 +02:00
return;
}
const queryText = getQueryText(chat);
if (queryText.length === 0) {
console.debug('Vectors: No text to query');
return;
}
// Get the most relevant messages, excluding the last few
2023-09-17 13:09:24 +02:00
const queryHashes = (await queryCollection(chatId, queryText, settings.insert)).filter(onlyUnique);
2023-09-07 23:28:06 +02:00
const queriedMessages = [];
const insertedHashes = new Set();
2023-09-09 20:26:04 +02:00
const retainMessages = chat.slice(-settings.protect);
2023-09-07 23:28:06 +02:00
for (const message of chat) {
if (retainMessages.includes(message) || !message.mes) {
2023-09-07 23:28:06 +02:00
continue;
}
const hash = getStringHash(message.mes);
if (queryHashes.includes(hash) && !insertedHashes.has(hash)) {
2023-09-07 23:28:06 +02:00
queriedMessages.push(message);
insertedHashes.add(hash);
2023-09-07 23:28:06 +02:00
}
}
// Rearrange queried messages to match query order
// Order is reversed because more relevant are at the lower indices
queriedMessages.sort((a, b) => queryHashes.indexOf(getStringHash(b.mes)) - queryHashes.indexOf(getStringHash(a.mes)));
2023-09-07 23:28:06 +02:00
// Remove queried messages from the original chat array
for (const message of chat) {
if (queriedMessages.includes(message)) {
chat.splice(chat.indexOf(message), 1);
}
2023-09-07 23:28:06 +02:00
}
2023-09-08 12:57:27 +02:00
if (queriedMessages.length === 0) {
console.debug('Vectors: No relevant messages found');
return;
}
// Format queried messages into a single string
2023-09-09 20:26:04 +02:00
const insertedText = getPromptText(queriedMessages);
setExtensionPrompt(EXTENSION_PROMPT_TAG, insertedText, settings.position, settings.depth);
2023-09-07 23:28:06 +02:00
} catch (error) {
console.error('Vectors: Failed to rearrange chat', error);
}
}
2023-09-09 20:26:04 +02:00
/**
* @param {any[]} queriedMessages
* @returns {string}
*/
function getPromptText(queriedMessages) {
const queriedText = queriedMessages.map(x => collapseNewlines(`${x.name}: ${x.mes}`).trim()).join('\n\n');
console.log('Vectors: relevant past messages found.\n', queriedText);
return substituteParams(settings.template.replace(/{{text}}/i, queriedText));
}
2023-09-07 23:28:06 +02:00
window['vectors_rearrangeChat'] = rearrangeChat;
const onChatEvent = debounce(async () => await moduleWorker.update(), 500);
/**
* Gets the text to query from the chat
* @param {object[]} chat Chat messages
* @returns {string} Text to query
*/
2023-09-07 23:28:06 +02:00
function getQueryText(chat) {
let queryText = '';
let i = 0;
for (const message of chat.slice().reverse()) {
if (message.mes) {
queryText += message.mes + '\n';
i++;
}
2023-09-09 20:26:04 +02:00
if (i === settings.query) {
2023-09-07 23:28:06 +02:00
break;
}
}
return collapseNewlines(queryText).trim();
}
/**
* Gets the saved hashes for a collection
* @param {string} collectionId
* @returns {Promise<number[]>} Saved hashes
*/
async function getSavedHashes(collectionId) {
const response = await fetch('/api/vector/list', {
method: 'POST',
headers: getRequestHeaders(),
2023-09-08 12:57:27 +02:00
body: JSON.stringify({
collectionId: collectionId,
source: settings.source,
}),
2023-09-07 23:28:06 +02:00
});
if (!response.ok) {
throw new Error(`Failed to get saved hashes for collection ${collectionId}`);
}
const hashes = await response.json();
return hashes;
}
/**
* Inserts vector items into a collection
* @param {string} collectionId - The collection to insert into
* @param {{ hash: number, text: string }[]} items - The items to insert
* @returns {Promise<void>}
*/
async function insertVectorItems(collectionId, items) {
const response = await fetch('/api/vector/insert', {
method: 'POST',
headers: getRequestHeaders(),
2023-09-08 12:57:27 +02:00
body: JSON.stringify({
collectionId: collectionId,
items: items,
source: settings.source,
}),
2023-09-07 23:28:06 +02:00
});
if (!response.ok) {
throw new Error(`Failed to insert vector items for collection ${collectionId}`);
}
}
/**
* Deletes vector items from a collection
* @param {string} collectionId - The collection to delete from
* @param {number[]} hashes - The hashes of the items to delete
* @returns {Promise<void>}
*/
async function deleteVectorItems(collectionId, hashes) {
const response = await fetch('/api/vector/delete', {
method: 'POST',
headers: getRequestHeaders(),
2023-09-08 12:57:27 +02:00
body: JSON.stringify({
collectionId: collectionId,
hashes: hashes,
source: settings.source,
}),
2023-09-07 23:28:06 +02:00
});
if (!response.ok) {
throw new Error(`Failed to delete vector items for collection ${collectionId}`);
}
}
/**
* @param {string} collectionId - The collection to query
* @param {string} searchText - The text to query
* @param {number} topK - The number of results to return
2023-09-07 23:28:06 +02:00
* @returns {Promise<number[]>} - Hashes of the results
*/
async function queryCollection(collectionId, searchText, topK) {
2023-09-07 23:28:06 +02:00
const response = await fetch('/api/vector/query', {
method: 'POST',
headers: getRequestHeaders(),
2023-09-08 12:57:27 +02:00
body: JSON.stringify({
collectionId: collectionId,
searchText: searchText,
topK: topK,
source: settings.source,
}),
2023-09-07 23:28:06 +02:00
});
if (!response.ok) {
throw new Error(`Failed to query collection ${collectionId}`);
}
const results = await response.json();
return results;
}
2023-09-09 21:15:47 +02:00
async function purgeVectorIndex(collectionId) {
try {
if (!settings.enabled) {
return;
}
const response = await fetch('/api/vector/purge', {
method: 'POST',
headers: getRequestHeaders(),
body: JSON.stringify({
collectionId: collectionId,
}),
});
if (!response.ok) {
throw new Error(`Could not delete vector index for collection ${collectionId}`);
}
console.log(`Vectors: Purged vector index for collection ${collectionId}`);
} catch (error) {
console.error('Vectors: Failed to purge', error);
}
}
2023-09-07 23:28:06 +02:00
jQuery(async () => {
if (!extension_settings.vectors) {
extension_settings.vectors = settings;
}
Object.assign(settings, extension_settings.vectors);
2023-09-17 13:09:24 +02:00
// Migrate from TensorFlow to Transformers
settings.source = settings.source !== 'local' ? settings.source : 'transformers';
2023-09-07 23:28:06 +02:00
$('#extensions_settings2').append(renderExtensionTemplate(MODULE_NAME, 'settings'));
$('#vectors_enabled').prop('checked', settings.enabled).on('input', () => {
settings.enabled = $('#vectors_enabled').prop('checked');
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
2023-09-08 12:57:27 +02:00
$('#vectors_source').val(settings.source).on('change', () => {
settings.source = String($('#vectors_source').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
2023-09-09 20:26:04 +02:00
$('#vectors_template').val(settings.template).on('input', () => {
settings.template = String($('#vectors_template').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$('#vectors_depth').val(settings.depth).on('input', () => {
settings.depth = Number($('#vectors_depth').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$('#vectors_protect').val(settings.protect).on('input', () => {
settings.protect = Number($('#vectors_protect').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$('#vectors_insert').val(settings.insert).on('input', () => {
settings.insert = Number($('#vectors_insert').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$('#vectors_query').val(settings.query).on('input', () => {
settings.query = Number($('#vectors_query').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$(`input[name="vectors_position"][value="${settings.position}"]`).prop('checked', true);
$('input[name="vectors_position"]').on('change', () => {
settings.position = Number($('input[name="vectors_position"]:checked').val());
Object.assign(extension_settings.vectors, settings);
saveSettingsDebounced();
});
$('#vectors_advanced_settings').toggleClass('displayNone', power_user.ui_mode === ui_mode.SIMPLE);
2023-09-08 14:25:10 +02:00
$('#vectors_vectorize_all').on('click', onVectorizeAllClick);
2023-09-07 23:28:06 +02:00
eventSource.on(event_types.MESSAGE_DELETED, onChatEvent);
eventSource.on(event_types.MESSAGE_EDITED, onChatEvent);
eventSource.on(event_types.MESSAGE_SENT, onChatEvent);
eventSource.on(event_types.MESSAGE_RECEIVED, onChatEvent);
eventSource.on(event_types.MESSAGE_SWIPED, onChatEvent);
2023-09-09 21:15:47 +02:00
eventSource.on(event_types.CHAT_DELETED, purgeVectorIndex);
eventSource.on(event_types.GROUP_CHAT_DELETED, purgeVectorIndex);
2023-09-07 23:28:06 +02:00
});