doneit-web/src/app/services/Repositorys/Agenda/agenda-local-data-source.service.ts

import { Injectable } from '@angular/core';

import { Dexie, EntityTable, liveQuery } from 'Dexie';
import { SharedCalendarListItemOutputDTO, SharedCalendarListOutputDTO } from './model/sharedCalendarOutputDTO';
import { any, z } from 'zod';
import { err, ok } from 'neverthrow';
import { from } from 'rxjs';


const tableScharedCalendar = z.object({
  wxUserId: z.number(),
  wxFullName: z.string(),
  wxeMail: z.string().email(),
  role: z.string(),
  roleId: z.number(),
  shareType: z.number(),
  date: z.string(),
})
export type TableSharedCalendar = z.infer<typeof tableScharedCalendar>

// Database declaration (move this to its own module also)
export const AgendaDataSource = new Dexie('AgendaDataSource') as Dexie & {
  shareCalendar: EntityTable<TableSharedCalendar, 'wxUserId'>;
};


AgendaDataSource.version(1).stores({
  shareCalendar: 'wxUserId, wxFullName, wxeMail, role, roleId, shareType, startDate, endDate'
});

@Injectable({
  providedIn: 'root'
})
export class AgendaLocalDataSourceService {

  constructor() { }

  async bulkCreate(data: SharedCalendarListItemOutputDTO[]) {
    // db.eve
    try {
      const result = await AgendaDataSource.shareCalendar.bulkAdd(data)
      return ok(result)
    } catch (e) {
      return err(false)
    }
  }

  async createCalendar(data: SharedCalendarListItemOutputDTO) {
    // db.eve
    try {
      const result = await AgendaDataSource.shareCalendar.add(data)
      return ok(result)
    } catch (e) {
      return err(false)
    }
  }

  clearSharedCalendar() {
    // db.eve
    try {
      const result = AgendaDataSource.shareCalendar.clear()
      return ok(result)
    } catch (e) {
      return err(false)
    }
  }

  async geCalendars() {
    return await AgendaDataSource.shareCalendar.toArray()
  }

  getShareCalendarItemsLive() {
    return from(liveQuery( () => {
      return  AgendaDataSource.shareCalendar.toArray()
    }))
  }
}