Function makeDiskStoreInt

packages/infra/src/Store/Disk.ts:15–160

(
  prefix: string,
  idKey: IdKey,
  namespace: string,
  dir: string,
  name: string,
  seed?: Effect.Effect<Iterable<Encoded>, E, R>,
  defaultValues?: Partial<Encoded>
)

import { makeMemoryStoreInt } from "./Memory.ts"

function makeDiskStoreInt<IdKey extends keyof Encoded, Encoded extends FieldValues, R, E>(
  prefix: string,
  idKey: IdKey,
  namespace: string,
  dir: string,
  name: string,
  seed?: Effect.Effect<Iterable<Encoded>, E, R>,
  defaultValues?: Partial<Encoded>
) {
  type PM = PersistenceModelType<Encoded>
  return Effect.gen(function*() {
    if (namespace !== "primary") {
      dir = dir + "/" + namespace
      if (!fs.existsSync(dir)) {
        fs.mkdirSync(dir)
      }
    }
    const file = dir + "/" + prefix + name + ".json"
    const fileExtra = { "disk.file.path": file }
    const fsStore = {
      get: fu
        .readTextFile(file)
        .pipe(
          annotateDb({
            operation: "read.readFile",
            system: "disk",
            collection: name,
            namespace,
            entity: name,
            extra: fileExtra
          }),
          Effect.flatMap((x) =>
            Effect.sync(() => JSON.parse(x) as PM[]).pipe(
              annotateDb({
                operation: "read.parse",
                system: "disk",
                collection: name,
                namespace,
                entity: name,
                extra: fileExtra
              })
            )
          ),
          Effect.orDie,
          annotateDb({
            operation: "read",
            system: "disk",
            collection: name,
            namespace,
            entity: name,
            extra: fileExtra
          })
        ),
      setRaw: (v: Iterable<PM>) =>
        Effect
          .sync(() => JSON.stringify([...v], undefined, 2))
          .pipe(
            annotateDb({