Spaces:
Paused
Paused
File size: 2,002 Bytes
529090e | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 | // Google Keep JSON adapter (placeholder, OAuth to be added later)
import { DataSourceAdapter } from '../../services/ingestion/DataIngestionEngine.js';
import { readFile } from 'fs/promises';
import { existsSync } from 'fs';
export class GoogleKeepAdapter implements DataSourceAdapter {
name = 'Google Keep';
type: 'other' = 'other';
private filePath: string;
private notes: any[] = [];
private lastLoaded = 0;
constructor(filePath?: string) {
this.filePath = filePath || `${process.cwd()}/apps/backend/data/google-keep.json`;
}
private async load(): Promise<void> {
if (!existsSync(this.filePath)) {
console.warn(`[GoogleKeepAdapter] File not found: ${this.filePath}`);
this.notes = [];
return;
}
try {
const data = await readFile(this.filePath, 'utf-8');
const json = JSON.parse(data);
this.notes = Array.isArray(json) ? json : json.items || [];
this.lastLoaded = Date.now();
console.log(`[GoogleKeepAdapter] Loaded ${this.notes.length} notes`);
} catch (e) {
console.error(`[GoogleKeepAdapter] Failed to parse JSON:`, e);
this.notes = [];
}
}
async fetch(): Promise<any[]> {
const STALE = 5 * 60 * 1000;
if (this.notes.length === 0 || Date.now() - this.lastLoaded > STALE) {
await this.load();
}
return this.notes;
}
async transform(raw: any[]): Promise<any[]> {
return raw.map(item => ({
sourceId: item.id ?? item.title,
type: 'note',
content: item.title ?? '',
metadata: {
provider: 'Google Keep',
raw: item,
labels: item.labels ?? []
},
timestamp: new Date(item.createdTime ?? Date.now())
}));
}
async isAvailable(): Promise<boolean> {
return existsSync(this.filePath);
}
}
|