123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156
// Copyright 2020-2021 the AloeDB authors. All rights reserved. MIT license.
import { isUndefined, getPathDirname } from './utils.ts';
/** * Database storage file reader. */export class Reader {
	/**	 * Read database storage file. Creates a new file if its not exists.	 * @param path Path to the file.	 * @returns File content.	 */	public static async read(path: string): Promise<string> {		if (isUndefined(path)) return '[]';
		if (await exists(path) === false) {			await ensureFile(path, '[]');			return '[]';		}
		const content: string = await Deno.readTextFile(path);		return content;	}
	/**	 * Read database storage file synchronously. Creates a new file if its not exists.	 * @param path Path to the file.	 * @returns File content.	 */	public static readSync(path: string): string {		if (isUndefined(path)) return '[]';
		if (existsSync(path) === false) {			ensureFileSync(path, '[]');			return '[]';		}
		const content: string = Deno.readTextFileSync(path);		return content;	}}
/** * Test whether or not the given path exists. * @param path Path to the file. * @returns Is file exists. */async function exists(path: string): Promise<boolean> {	try {		await Deno.lstat(path);		return true;	} catch (error) {		if (error instanceof Deno.errors.NotFound) return false;		throw error;	}}
/** * Synchronously test whether or not the given path exists. * @param path Path to the file. * @returns Is file exists. */function existsSync(path: string): boolean {	try {		Deno.lstatSync(path);		return true;	} catch (error) {		if (error instanceof Deno.errors.NotFound) return false;		throw error;	}}
/** * Ensures that the file exists. * @param path Path to the file. * @param data Data to write to if file not exists. * @returns Is file created. */async function ensureFile(path: string, data: string = ''): Promise<void> {	try {		const info = await Deno.lstat(path);		if (!info.isFile) throw new Error('Invalid file specified');	} catch (error) {		if (error instanceof Deno.errors.NotFound) {			const dirname: string = getPathDirname(path);			await ensureDir(dirname);			await Deno.writeTextFile(path, data);			return;		}
		throw error;	}}
/** * Ensures that the file exists synchronously. * @param path Path to the file. * @param data Data to write to if file not exists. * @returns Is file created. */function ensureFileSync(path: string, data: string = ''): void {	try {		const info = Deno.lstatSync(path);		if (!info.isFile) throw new Error('Invalid file specified');	} catch (error) {		if (error instanceof Deno.errors.NotFound) {			const dirname: string = getPathDirname(path);			ensureDirSync(dirname);			Deno.writeTextFileSync(path, data);			return;		}
		throw error;	}}
/** * Ensures that the file directory. * @param path Path to the directory. * @returns Is directory created. */async function ensureDir(path: string): Promise<void> {	try {		const info: Deno.FileInfo = await Deno.lstat(path);		if (!info.isDirectory) throw new Error('Invalid directory specified');	} catch (error) {		if (error instanceof Deno.errors.NotFound) {			await Deno.mkdir(path, { recursive: true });			return;		}
		throw error;	}}
/** * Ensures that the file directory synchronously. * @param path Path to the directory. * @returns Is directory created. */function ensureDirSync(path: string): void {	try {		const info: Deno.FileInfo = Deno.lstatSync(path);		if (!info.isDirectory) throw new Error('Invalid directory specified');	} catch (error) {		if (error instanceof Deno.errors.NotFound) {			Deno.mkdirSync(path, { recursive: true });			return;		}
		throw error;	}}