GeneralBots/generalbots
1
0
Fork 0
Code Activity Actions 5

new(core.gbapp): LLM alerts for data.

Browse source
This commit is contained in:
me@rodrigorodriguez.com 2024-10-16 12:56:09 -03:00
parent 7500148252
commit 90c1e2b461
2 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/basic.gblib/services/SystemKeywords.ts
View file

@ -750,7 +750,7 @@ export class SystemKeywords {
public async saveToStorageBatch({ pid, table, rows }): Promise<void> { public async saveToStorageBatch({ pid, table, rows }): Promise<void> {
const { min } = await DialogKeywords.getProcessInfo(pid); const { min } = await DialogKeywords.getProcessInfo(pid);
if (typeof rows === 'object' && rows !== null) { if (!Array.isArray(data) && typeof rows === 'object' && rows !== null) {
rows = [rows]; rows = [rows];
} }

12
packages/llm.gblib/services/ChatServices.ts
View file

@ -545,12 +545,20 @@ export class ChatServices {
} else if (LLMMode === 'sql' || LLMMode === 'chart') { } else if (LLMMode === 'sql' || LLMMode === 'chart') {
const con = min[`llm`]['gbconnection']; const con = min[`llm`]['gbconnection'];
const dialect = con['storageDriver']; const dialect = con['storageDriver'];
const answerSource = await (min.core as any)['getParam'](min.instance,
'Answer Source', false);
let dataSource; let dataSource;
if (dialect === 'sqlite') { if (dialect === 'sqlite' || answerSource === 'cache') {
let sqliteFilePath = answerSource === 'cache' ?
path.join('work', GBUtil.getGBAIPath(min.botId), `${con['name']}.sqlite`):
con['storageFile'];
dataSource = new DataSource({ dataSource = new DataSource({
type: 'sqlite', type: 'sqlite',
database: con['storageFile'], database: sqliteFilePath,
synchronize: false, synchronize: false,
logging: true logging: true
}); });