diff --git a/packages/backend-core/src/queue/queue.ts b/packages/backend-core/src/queue/queue.ts index e2f9ea9d94..b4eeeb31aa 100644 --- a/packages/backend-core/src/queue/queue.ts +++ b/packages/backend-core/src/queue/queue.ts @@ -4,7 +4,7 @@ import { JobQueue } from "./constants" import InMemoryQueue from "./inMemoryQueue" import BullQueue from "bull" import { addListeners, StalledFn } from "./listeners" -const { opts, redisProtocolUrl } = getRedisOptions() +const { opts: redisOpts, redisProtocolUrl } = getRedisOptions() const CLEANUP_PERIOD_MS = 60 * 1000 let QUEUES: BullQueue.Queue[] | InMemoryQueue[] = [] @@ -18,9 +18,9 @@ async function cleanup() { export function createQueue( jobQueue: JobQueue, - opts: { removeStalledCb?: StalledFn } + opts: { removeStalledCb?: StalledFn } = {} ): BullQueue.Queue { - const queueConfig: any = redisProtocolUrl || { redis: opts } + const queueConfig: any = redisProtocolUrl || { redis: redisOpts } let queue: any if (!env.isTest()) { queue = new BullQueue(jobQueue, queueConfig) diff --git a/packages/types/src/index.ts b/packages/types/src/index.ts index 92d2ceb050..4adb2fda97 100644 --- a/packages/types/src/index.ts +++ b/packages/types/src/index.ts @@ -1,4 +1,3 @@ export * from "./documents" export * from "./sdk" export * from "./api" -export * from "./core" diff --git a/packages/types/src/sdk/koa.ts b/packages/types/src/sdk/koa.ts index 56666f7e2a..8004ba72ae 100644 --- a/packages/types/src/sdk/koa.ts +++ b/packages/types/src/sdk/koa.ts @@ -1,4 +1,4 @@ -import { Context } from "koa" +import { Context, Request } from "koa" import { User } from "../documents" import { License } from "../sdk" @@ -7,15 +7,11 @@ export interface ContextUser extends User { license: License } -export interface BBContext { - user?: ContextUser - status?: number - request: { - body: any - } - params: any - body?: any - redirect?: any - attachment: any - throw: any +export interface BBRequest extends Request { + body: any +} + +export interface BBContext extends Context { + request: BBRequest + user?: ContextUser }