Data access object

Dao.ts

import { Observable, Observer } from "rxjs";
import { AppDatabase } from "./AppDatabase";
import { IRepositroy } from "./models/Repository";
export class Dao {
  private db: AppDatabase;
  private observablesList: Array<Observer<IRepositroy[]>> = [];
  constructor() {
    this.db = new AppDatabase();
  }

  public getItems(): Observable<IRepositroy[]> {
    return Observable.create(async (observer: Observer<IRepositroy[]>) => {
      this.observablesList.push(observer);
      try {
        observer.next(await this.db.repos.toArray());
      } catch (error) {
        observer.error(error);
      }
    });
  }

  public addItems(items: IRepositroy[]): Observable<IRepositroy[]> {
    return Observable.create(async (observer: Observer<IRepositroy[]>) => {
      try {
        await this.db.repos.bulkAdd(items);
        const updatedItems = await this.db.repos.toArray();
        this.observablesList.forEach(item => item.next(updatedItems));
        observer.next(items);
        observer.complete();
      } catch (error) {
        observer.error(error);
        observer.complete();
      }
    });
  }

  public async clearTable() {
    await this.db.repos.clear();
    this.observablesList.forEach(item => item.next([]));
  }
}