Function get

packages/experimental/src/Persistence.ts:383–407

(method: string, key: string)

        Effect.map(Effect.clock, (clock) => {
          const store = KeyValueStore.prefix(backing, storeId)
          const get = (method: string, key: string) =>
            Effect.flatMap(
              Effect.mapError(
                store.get(key),
                (error) => PersistenceBackingError.make(method, error)
              ),
              Option.match({
                onNone: () => Effect.succeedNone,
                onSome: (s) =>
                  Effect.flatMap(
                    Effect.try({
                      try: () => JSON.parse(s),
                      catch: (error) => PersistenceBackingError.make(method, error)
                    }),
                    (_) => {
                      if (!Array.isArray(_)) return Effect.succeedNone
                      const [value, expires] = _ as [unknown, number | null]
                      if (expires !== null && expires <= clock.unsafeCurrentTimeMillis()) {
                        return Effect.as(Effect.ignore(store.remove(key)), Option.none())
                      }
                      return Effect.succeed(Option.some(value))
                    }
                  )
              })
            )
          return identity<BackingPersistenceStore>({
            get: (key) => get("get", key),
            getMany: (keys) => Effect.forEach(keys, (key) => get("getMany", key), { concurrency: "unbounded" }),