mirror of
https://github.com/khoaliber/khoj.git
synced 2026-03-06 13:22:12 +00:00
Remove the unnecessary async/await func chains on Desktop app
This commit is contained in:
@@ -120,7 +120,7 @@ function isSupportedFileType(filePath) {
|
|||||||
return validFileTypes.includes(fileExtension);
|
return validFileTypes.includes(fileExtension);
|
||||||
}
|
}
|
||||||
|
|
||||||
async function processDirectory(filesToPush, folder) {
|
function processDirectory(filesToPush, folder) {
|
||||||
const files = fs.readdirSync(folder.path, { withFileTypes: true });
|
const files = fs.readdirSync(folder.path, { withFileTypes: true });
|
||||||
|
|
||||||
for (const file of files) {
|
for (const file of files) {
|
||||||
@@ -136,12 +136,12 @@ async function processDirectory(filesToPush, folder) {
|
|||||||
}
|
}
|
||||||
// Recursively process subdirectories
|
// Recursively process subdirectories
|
||||||
if (file.isDirectory()) {
|
if (file.isDirectory()) {
|
||||||
await processDirectory(filesToPush, {'path': filePath});
|
processDirectory(filesToPush, {'path': filePath});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function pushDataToKhoj (regenerate = false) {
|
function pushDataToKhoj (regenerate = false) {
|
||||||
// Don't sync if token or hostURL is not set or if already syncing
|
// Don't sync if token or hostURL is not set or if already syncing
|
||||||
if (store.get('khojToken') === '' || store.get('hostURL') === '' || syncing === true) {
|
if (store.get('khojToken') === '' || store.get('hostURL') === '' || syncing === true) {
|
||||||
const win = BrowserWindow.getAllWindows()[0];
|
const win = BrowserWindow.getAllWindows()[0];
|
||||||
@@ -163,7 +163,7 @@ async function pushDataToKhoj (regenerate = false) {
|
|||||||
|
|
||||||
// Collect paths of all indexable files in configured folders
|
// Collect paths of all indexable files in configured folders
|
||||||
for (const folder of folders) {
|
for (const folder of folders) {
|
||||||
await processDirectory(filesToPush, folder);
|
processDirectory(filesToPush, folder);
|
||||||
}
|
}
|
||||||
|
|
||||||
const lastSync = store.get('lastSync') || [];
|
const lastSync = store.get('lastSync') || [];
|
||||||
@@ -347,7 +347,7 @@ async function removeFolder (event, folderPath) {
|
|||||||
|
|
||||||
async function syncData (regenerate = false) {
|
async function syncData (regenerate = false) {
|
||||||
try {
|
try {
|
||||||
await pushDataToKhoj(regenerate);
|
pushDataToKhoj(regenerate);
|
||||||
const date = new Date();
|
const date = new Date();
|
||||||
console.log('Pushing data to Khoj at: ', date);
|
console.log('Pushing data to Khoj at: ', date);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@@ -359,7 +359,7 @@ async function deleteAllFiles () {
|
|||||||
try {
|
try {
|
||||||
store.set('files', []);
|
store.set('files', []);
|
||||||
store.set('folders', []);
|
store.set('folders', []);
|
||||||
await pushDataToKhoj(true);
|
pushDataToKhoj(true);
|
||||||
const date = new Date();
|
const date = new Date();
|
||||||
console.log('Pushing data to Khoj at: ', date);
|
console.log('Pushing data to Khoj at: ', date);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@@ -395,9 +395,9 @@ const createWindow = (tab = 'chat.html') => {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
const job = new cron('0 */10 * * * *', async function() {
|
const job = new cron('0 */10 * * * *', function() {
|
||||||
try {
|
try {
|
||||||
await pushDataToKhoj();
|
pushDataToKhoj();
|
||||||
const date = new Date();
|
const date = new Date();
|
||||||
console.log('Pushing data to Khoj at: ', date);
|
console.log('Pushing data to Khoj at: ', date);
|
||||||
win.webContents.send('update-state', state);
|
win.webContents.send('update-state', state);
|
||||||
|
|||||||
Reference in New Issue
Block a user