feat: add auto sync functionality with configurable delay in settings

This commit is contained in:
Jiaxin Peng
2025-10-31 21:42:48 +00:00
parent 33f0848b32
commit c369c291a7
5 changed files with 163 additions and 1 deletions

View File

@@ -1,8 +1,9 @@
import { App, Editor, MarkdownView, Notice, Plugin, PluginSettingTab, Setting } from "obsidian";
import { App, Editor, MarkdownView, Notice, Plugin, PluginSettingTab, Setting, TFile, EventRef } from "obsidian";
import { addIcons } from 'src/ui/icon';
import { i18nConfig } from "src/lang/I18n";
import ribbonCommands from "src/commands/NotionCommands";
import { ObsidianSettingTab, PluginSettings, DEFAULT_SETTINGS, DatabaseDetails } from "src/ui/settingTabs";
import { uploadCommandNext, uploadCommandGeneral, uploadCommandCustom } from "src/upload/uploadCommand";
// Remember to rename these classes and interfaces!
@@ -11,6 +12,9 @@ export default class ObsidianSyncNotionPlugin extends Plugin {
settings: PluginSettings;
commands: ribbonCommands;
app: App;
modifyEventRef: EventRef | null = null;
autoSyncTimeout: NodeJS.Timeout | null = null;
private syncingFiles: Set<string> = new Set();
async onload() {
await this.loadSettings();
@@ -36,9 +40,18 @@ export default class ObsidianSyncNotionPlugin extends Plugin {
// This adds a settings tab so the user can configure various aspects of the plugin
this.addSettingTab(new ObsidianSettingTab(this.app, this));
// Setup auto sync listener
this.setupAutoSync();
}
onunload() {
if (this.modifyEventRef) {
this.app.vault.offref(this.modifyEventRef);
}
if (this.autoSyncTimeout) {
clearTimeout(this.autoSyncTimeout);
}
}
async loadSettings() {
@@ -80,6 +93,94 @@ export default class ObsidianSyncNotionPlugin extends Plugin {
await this.saveSettings();
}
setupAutoSync() {
// Remove existing listener if any
if (this.modifyEventRef) {
this.app.vault.offref(this.modifyEventRef);
}
// Only setup if autoSync is enabled
if (!this.settings.autoSync) {
return;
}
// Listen for file modifications
this.modifyEventRef = this.app.vault.on('modify', async (file: TFile) => {
// Only process markdown files
if (!(file instanceof TFile) || file.extension !== 'md') {
return;
}
// Debounce: clear existing timeout
if (this.autoSyncTimeout) {
clearTimeout(this.autoSyncTimeout);
}
// Set a new timeout to trigger sync after user-configured delay (in seconds)
const delayMs = (this.settings.autoSyncDelay || 2) * 1000;
this.autoSyncTimeout = setTimeout(async () => {
await this.autoSyncFile(file);
}, delayMs);
});
}
async autoSyncFile(file: TFile) {
// Check if file is already being synced
if (this.syncingFiles.has(file.path)) {
console.log(`[AutoSync] File ${file.path} is already being synced, skipping`);
return;
}
try {
this.syncingFiles.add(file.path);
// Get file's frontmatter
const frontMatter = this.app.metadataCache.getFileCache(file)?.frontmatter;
if (!frontMatter) {
console.log(`[AutoSync] No frontmatter found in ${file.path}`);
return;
}
// Find which database this file belongs to by checking for NotionID-{abName}
let foundDbDetails: DatabaseDetails | null = null;
let notionId: string | null = null;
for (const key in this.settings.databaseDetails) {
const dbDetails = this.settings.databaseDetails[key];
const notionIDKey = `NotionID-${dbDetails.abName}`;
if (frontMatter[notionIDKey]) {
foundDbDetails = dbDetails;
notionId = String(frontMatter[notionIDKey]);
break;
}
}
// If no NotionID found, skip auto sync
if (!foundDbDetails || !notionId) {
console.log(`[AutoSync] No NotionID found in ${file.path}, skipping auto sync`);
return;
}
console.log(`[AutoSync] ${new Date().toISOString()} Auto syncing ${file.basename} to ${foundDbDetails.fullName}`);
// Trigger appropriate upload command based on database format
if (foundDbDetails.format === 'next') {
await uploadCommandNext(this, this.settings, foundDbDetails, this.app);
} else if (foundDbDetails.format === 'general') {
await uploadCommandGeneral(this, this.settings, foundDbDetails, this.app);
} else if (foundDbDetails.format === 'custom') {
await uploadCommandCustom(this, this.settings, foundDbDetails, this.app);
}
} catch (error) {
console.error(`[AutoSync] Error syncing file ${file.path}:`, error);
new Notice(`Auto sync failed for ${file.basename}: ${error.message}`);
} finally {
this.syncingFiles.delete(file.path);
}
}
}