Skip to content

Commit

Permalink
fix(llm.gblib): Talk to data local db use fix.
Browse files Browse the repository at this point in the history
  • Loading branch information
rodrigorodriguez committed Nov 24, 2024
1 parent ba32048 commit 5b69a12
Show file tree
Hide file tree
Showing 3 changed files with 35 additions and 21 deletions.
9 changes: 5 additions & 4 deletions packages/kb.gbapp/services/KBService.ts
Original file line number Diff line number Diff line change
Expand Up @@ -656,9 +656,7 @@ export class KBService implements IGBKBService {

// Checks for text after the image markdown, after the element 4, there are text blocks.


const removeMarkdownImages = (text: string) => {
// Remove both inline images ![alt](url) and reference images ![alt][ref]
return text.replace(/!\[[^\]]*\](?:\([^)]*\)|\[[^\]]*\])/g, '').trim();
}

Expand Down Expand Up @@ -1046,7 +1044,8 @@ export class KBService implements IGBKBService {
const websiteIgnoreUrls = min.core.getParam<[]>(min.instance, 'Website Ignore URLs', null);
GBLogEx.info(min, `Website: ${website}, Max Depth: ${maxDepth}, Ignore URLs: ${websiteIgnoreUrls}`);


let shouldSave = false;

if (website) {
// Removes last slash if any.

Expand Down Expand Up @@ -1128,6 +1127,7 @@ export class KBService implements IGBKBService {

await CollectionUtil.asyncForEach(files, async file => {
let content = null;
shouldSave = true;

try {
const document = await this.loadAndSplitFile(file);
Expand All @@ -1144,6 +1144,7 @@ export class KBService implements IGBKBService {
files = await walkPromise(urlJoin(localPath, 'docs'));

if (files[0]) {
shouldSave = true;
GBLogEx.info(min, `Add embeddings from .gbkb: ${files.length}}...`);
await CollectionUtil.asyncForEach(files, async file => {
let content = null;
Expand All @@ -1154,7 +1155,7 @@ export class KBService implements IGBKBService {
await min['vectorStore'].addDocuments(flattenedDocuments);
});
}
if (min['vectorStore']) {
if (shouldSave && min['vectorStore']) {
await min['vectorStore'].save(min['vectorStorePath']);
}
}
Expand Down
44 changes: 29 additions & 15 deletions packages/llm.gblib/services/ChatServices.ts
Original file line number Diff line number Diff line change
Expand Up @@ -538,22 +538,36 @@ export class ChatServices {
logging: true
});
} else {
const host = con['storageServer'];
const port = con['storagePort'];
const storageName = con['storageName'];
const username = con['storageUsername'];
const password = con['storagePassword'];

dataSource = new DataSource({
type: dialect as any,
host: host,
port: port,
database: storageName,
username: username,
password: password,
synchronize: false,
logging: true
});

if (dialect === 'sqlite') {
const storageFile = con['storageFile'];
dataSource = new DataSource({
type: 'sqlite',
database: storageFile,
synchronize: false,
logging: true
});

}
else {
const host = con['storageServer'];
const port = con['storagePort'];
const storageName = con['storageName'];
const username = con['storageUsername'];
const password = con['storagePassword'];

dataSource = new DataSource({
type: dialect as any,
host: host,
port: port,
database: storageName,
username: username,
password: password,
synchronize: false,
logging: true
});
}
}

const db = await SqlDatabase.fromDataSourceParams({
Expand Down
3 changes: 1 addition & 2 deletions templates/talk-to-data.gbai/talk-to-data.gbot/config.csv
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
name,value
Admin, 5521999998888
Answer Mode,sql
Answer Source,cache
Answer Mode,chart
llm File,northwind.db
llm Driver,sqlite
Theme Color,red

0 comments on commit 5b69a12

Please sign in to comment.