Function makeRedisClient

packages/infra/src/redis-client.ts:15–95

(makeClient: () => Client)

}

export const makeRedisClient = (makeClient: () => Client) =>
  Effect.acquireRelease(
    Effect
      .sync(() => {
        const client = createClient(makeClient)
        const lock = new Redlock([client])

        function get(key: string) {
          return Effect
            .callback<Option.Option<string>, ConnectionException>((res) => {
              client.get(key, (err, v) =>
                err
                  ? res(Effect.fail(new ConnectionException(err)))
                  : res(Effect.sync(() => Option.fromNullishOr(v))))
            })
            .pipe(Effect.uninterruptible)
        }

        function set(key: string, val: string) {
          return Effect
            .callback<void, ConnectionException>((res) => {
              client.set(key, val, (err) =>
                err
                  ? res(Effect.fail(new ConnectionException(err)))
                  : res(Effect.sync(() => void 0)))
            })
            .pipe(Effect.uninterruptible)
        }

        function hset(key: string, field: string, value: string) {
          return Effect
            .callback<void, ConnectionException>((res) => {
              client.hset(key, field, value, (err) =>
                err
                  ? res(Effect.fail(new ConnectionException(err)))
                  : res(Effect.sync(() => void 0)))
            })
            .pipe(Effect.uninterruptible)
        }

        function hget(key: string, field: string) {
          return Effect
            .callback<Option.Option<string>, ConnectionException>((res) => {
              client.hget(key, field, (err, v) =>
                err
                  ? res(Effect.fail(new ConnectionException(err)))
                  : res(Effect.sync(() => Option.fromNullishOr(v))))
            })
            .pipe(Effect.uninterruptible)
        }
        function hmgetAll(key: string) {
          return Effect
            .callback<Option.Option<{ [key: string]: string }>, ConnectionException>(
              (res) => {
                client.hgetall(key, (err, v) =>
                  err
                    ? res(Effect.fail(new ConnectionException(err)))
                    : res(Effect.sync(() => Option.fromNullishOr(v))))