From obsidian-pack
Debounces vault events, throttles per-file operations, and batches bulk file processing in Obsidian plugins to prevent UI freezes.
npx claudepluginhub jeremylongshore/claude-code-plugins-plus-skills --plugin obsidian-packThis skill is limited to using the following tools:
Obsidian has no traditional API rate limits, but it runs on Electron with a single-threaded UI. This skill covers debouncing, batching, throttling, and async queue patterns to keep plugins responsive and prevent UI freezes.
Searches, retrieves, and installs Agent Skills from prompts.chat registry using MCP tools like search_skills and get_skill. Activates for finding skills, browsing catalogs, or extending Claude.
Searches prompts.chat for AI prompt templates by keyword or category, retrieves by ID with variable handling, and improves prompts via AI. Use for discovering or enhancing prompts.
Checks Next.js compilation errors using a running Turbopack dev server after code edits. Fixes actionable issues before reporting complete. Replaces `next build`.
Obsidian has no traditional API rate limits, but it runs on Electron with a single-threaded UI. This skill covers debouncing, batching, throttling, and async queue patterns to keep plugins responsive and prevent UI freezes.
requestAnimationFramevault.on('modify') fires on every keystroke when a user types in a note. Without debouncing, your handler runs hundreds of times per second.
import { Plugin, TFile, debounce } from 'obsidian';
export default class ThrottledPlugin extends Plugin {
async onload() {
// Obsidian provides a built-in debounce utility
const debouncedHandler = debounce(
(file: TFile) => this.handleFileModified(file),
500, // wait 500ms after last keystroke
true // run on leading edge too (immediate first call)
);
this.registerEvent(
this.app.vault.on('modify', debouncedHandler)
);
}
private async handleFileModified(file: TFile) {
// This runs at most once per 500ms per burst of edits
const cache = this.app.metadataCache.getFileCache(file);
if (cache?.frontmatter?.tracked) {
await this.updateIndex(file);
}
}
}
If you need per-file debouncing (common when multiple files change simultaneously):
private fileTimers = new Map<string, NodeJS.Timeout>();
private debouncedPerFile(file: TFile, fn: () => void, delay = 500) {
const existing = this.fileTimers.get(file.path);
if (existing) clearTimeout(existing);
const timer = setTimeout(() => {
this.fileTimers.delete(file.path);
fn();
}, delay);
// Use activeWindow for Obsidian's timeout tracking
this.fileTimers.set(file.path, timer);
}
Processing hundreds of files synchronously locks the UI. Yield back to the main thread between batches.
async processAllFiles(): Promise<void> {
const files = this.app.vault.getMarkdownFiles();
const BATCH_SIZE = 50;
const results: ProcessResult[] = [];
for (let i = 0; i < files.length; i += BATCH_SIZE) {
const batch = files.slice(i, i + BATCH_SIZE);
// Process one batch
for (const file of batch) {
const content = await this.app.vault.cachedRead(file);
results.push(this.processContent(file.path, content));
}
// Yield to UI thread between batches
await sleep(0);
// Update progress if you have a status bar or notice
const pct = Math.round(((i + batch.length) / files.length) * 100);
this.statusBar?.setText(`Processing: ${pct}%`);
}
this.statusBar?.setText(`Done: ${results.length} files processed`);
}
// Obsidian exports sleep(), or use this:
function sleep(ms: number): Promise<void> {
return new Promise(resolve => setTimeout(resolve, ms));
}
Updating DOM elements on every event causes layout thrashing. Throttle to animation frames.
class ThrottledStatusView {
private pendingUpdate = false;
private el: HTMLElement;
private data: { count: number; lastFile: string } = { count: 0, lastFile: '' };
constructor(el: HTMLElement) {
this.el = el;
}
// Call this as often as you want — it coalesces to one paint per frame
update(count: number, lastFile: string) {
this.data = { count, lastFile };
if (!this.pendingUpdate) {
this.pendingUpdate = true;
requestAnimationFrame(() => {
this.render();
this.pendingUpdate = false;
});
}
}
private render() {
this.el.empty();
this.el.createEl('span', { text: `${this.data.count} files` });
this.el.createEl('span', { text: this.data.lastFile, cls: 'nav-file-title' });
}
}
Concurrent writes to the same file corrupt data. Queue writes so only one runs at a time.
class WriteQueue {
private queue: Array<() => Promise<void>> = [];
private running = false;
async enqueue(fn: () => Promise<void>): Promise<void> {
return new Promise((resolve, reject) => {
this.queue.push(async () => {
try {
await fn();
resolve();
} catch (e) {
reject(e);
}
});
this.process();
});
}
private async process() {
if (this.running) return;
this.running = true;
while (this.queue.length > 0) {
const task = this.queue.shift()!;
await task();
// Small delay between writes to avoid overwhelming disk I/O
await sleep(10);
}
this.running = false;
}
}
// Usage in plugin
class MyPlugin extends Plugin {
private writeQueue = new WriteQueue();
async safeWrite(file: TFile, content: string) {
await this.writeQueue.enqueue(async () => {
await this.app.vault.modify(file, content);
});
}
}
Give users feedback during operations that take more than a second.
async bulkUpdateFrontmatter(
files: TFile[],
updater: (fm: any) => void
): Promise<{ success: number; failed: string[] }> {
const failed: string[] = [];
let success = 0;
// Use Notice with a timeout of 0 to create a persistent notice
const notice = new Notice(`Updating 0/${files.length} files...`, 0);
try {
for (let i = 0; i < files.length; i++) {
try {
await this.app.fileManager.processFrontMatter(files[i], updater);
success++;
} catch (e) {
failed.push(files[i].path);
}
// Update notice every 10 files to avoid DOM thrashing
if (i % 10 === 0 || i === files.length - 1) {
notice.setMessage(`Updating ${i + 1}/${files.length} files...`);
await sleep(0); // yield to UI
}
}
} finally {
// Replace persistent notice with a timed one
notice.hide();
new Notice(`Updated ${success} files. ${failed.length} failed.`);
}
return { success, failed };
}
Use Obsidian's registerInterval instead of raw setInterval — it auto-clears on plugin unload.
async onload() {
// Sync data every 5 minutes
this.registerInterval(
window.setInterval(() => {
this.syncData();
}, 5 * 60 * 1000)
);
}
private async syncData() {
// Guard against overlapping runs
if (this.syncing) return;
this.syncing = true;
try {
await this.performSync();
} finally {
this.syncing = false;
}
}
requestAnimationFrameregisterInterval and overlap guards| Issue | Cause | Solution |
|---|---|---|
| UI freezes during bulk operation | Processing all files synchronously | Batch with await sleep(0) between batches |
| Data corruption | Concurrent writes to same file | Use a write queue to serialize operations |
| Memory pressure on large vaults | Loading all file contents at once | Process in batches of 50, release references |
| Missed file changes | Debounce interval too long | Keep debounce under 500ms; use leading edge |
| Timers leak after disable | Using raw setInterval | Always use this.registerInterval() |
| Layout thrashing | Updating DOM on every event | Coalesce with requestAnimationFrame |
// Efficient vault scan that doesn't freeze UI
async getVaultStats(): Promise<{ total: number; words: number }> {
const files = this.app.vault.getMarkdownFiles();
let words = 0;
for (let i = 0; i < files.length; i += 50) {
const batch = files.slice(i, i + 50);
for (const file of batch) {
const content = await this.app.vault.cachedRead(file);
words += content.split(/\s+/).length;
}
await sleep(0);
}
return { total: files.length, words };
}
// Rebuild search index at most once per 2 seconds
private rebuildIndex = debounce(async () => {
const files = this.app.vault.getMarkdownFiles();
this.index.clear();
for (const file of files) {
const cache = this.app.metadataCache.getFileCache(file);
if (cache?.frontmatter) {
this.index.set(file.path, cache.frontmatter);
}
}
}, 2000, true);
For event handling patterns that complement these throttling strategies, see obsidian-webhooks-events. For production deployment readiness, see obsidian-prod-checklist.