diff --git a/packages/infra/src/postgres.ts b/packages/infra/src/postgres.ts index 461c325..8eee43a 100644 --- a/packages/infra/src/postgres.ts +++ b/packages/infra/src/postgres.ts @@ -1,8 +1,8 @@ -import { PrismaClient, type PrismaClientOptions } from '@prisma/client'; +import { Prisma, PrismaClient } from '@prisma/client'; export interface PostgresConfig { url: string; - log?: PrismaClientOptions['log']; + log?: Prisma.PrismaClientOptions['log']; } export interface PostgresConnector { diff --git a/packages/infra/src/redis.ts b/packages/infra/src/redis.ts index e5b6d6c..5a6895e 100644 --- a/packages/infra/src/redis.ts +++ b/packages/infra/src/redis.ts @@ -1,4 +1,4 @@ -import { createClient, type RedisClientOptions, type RedisClientType } from 'redis'; +import { createClient, type RedisClientOptions } from 'redis'; export interface RedisConfig { url: string; @@ -7,7 +7,7 @@ export interface RedisConfig { } export interface RedisConnector { - readonly client: RedisClientType; + readonly client: ReturnType; connect(): Promise; disconnect(): Promise; } @@ -37,7 +37,11 @@ export const createRedisConnector = (config: RedisConfig): RedisConnector => { return { client, - connect: () => client.connect(), - disconnect: () => client.quit(), + connect: async () => { + await client.connect(); + }, + disconnect: async () => { + await client.quit(); + }, }; };