Class JSONDBDatabase

packages/common/storage/document-database.ts:10–104

import { useAppStore } from '../store/app-state';

export class JSONDBDatabase {
  documents: JSONDBClient<PersistedFullWorkflow>
  constructor() {
    this.documents = new JSONDBClient<PersistedFullWorkflow>("workflows");
  }

  async getDocs(): Promise<PersistedFullWorkflow[]> {
    const ret = await this.documents.getDocuments();
    if (ret.success) {
      return ret.data
    } else {
      throw new Error("Get docs failed" + ret.error);
    }
  }

  async getDoc(id: string): Promise<PersistedFullWorkflow> {
    const ret = await this.documents.getDocument(id);
    if (ret.success) {
      return ret.data
    } else {
      throw new Error("Get Doc failed: " + ret.error);
    }
  }

  async createDoc(docMeta: PersistedFullWorkflow) {
    const ret = await this.documents.createDocument(docMeta.id, docMeta);
    if (!ret.success) {
      throw new Error("Create Doc failed: " + ret.error);
    }
  }

  async updateDoc(docMeta: PersistedFullWorkflow) {
    const ret = await this.documents.updateDocument(docMeta.id, docMeta);
    if (!ret.success) {
      throw new Error("Update failed" + ret.error);
    }
  }

  async deleteDocSoft(docId: string) {
    const ret = await this.documents.updateDocument(docId, { 
      deleted: true,
      deleted_time: +(new Date())
    });
    if (!ret.success) {
      throw new Error("Delete failed: " + ret.error);
    }
  }

  async deleteDoc(docId: string) {
    const ret = await this.documents.deleteDocument(docId);
    if (!ret.success) {
      throw new Error("Delete failed_: " + ret.error);
      
    }
  }

  async createDocFromTemplate(key: string = "default"): Promise<PersistedFullWorkflow> {
    const template = getWorkflowTemplate(key);