Function createDb

packages/baseai/src/utils/memory/db/lib.ts:51–79

(memoryName: string)

// Create a new database
// basePath. The path to
export async function createDb(memoryName: string): Promise<Low<Schema>> {
	const baseDir = path.join(process.cwd(), '.baseai', 'db');
	const dbFilePath = path.join(baseDir, `${memoryName}.json`);

	// Ensure the directory exists
	await fs.mkdir(baseDir, { recursive: true });

	// Check if the file exists, if not, create it with default data
	try {
		await fs.access(dbFilePath);
	} catch (error) {
		// File doesn't exist, create it with default data
		await fs.writeFile(dbFilePath, JSON.stringify(defaultData, null, 2));
	}

	const adapter = new JSONFile<Schema>(dbFilePath);
	const db = new Low(adapter, defaultData);

	// Read the existing data or initialize with default
	await db.read();

	// If the file was empty or invalid JSON, write the default data
	if (db.data === null) {
		db.data = defaultData;
		await db.write();
	}

	return db;
}

// Read an existing database
export async function readDb(dbPath: string): Promise<Low<Schema>> {