All files / src/queues queueArgs.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { BaseJob, BudgetJob, EndpointJob, TransactionJob } from "./jobs/BaseJob"
 
type JobArgs = { job: string; delayedMessageId?: string; retryCount?: number }
 
export type EndpointJobArgs = { transactionId: string; data: unknown } & JobArgs
 
export type TransactionJobArgs = { transactionId: string } & JobArgs
 
export type BudgetJobArgs = { budgetId: string } & JobArgs
 
export function isTransactionJob(job: BaseJob): job is TransactionJob {
  return job instanceof TransactionJob
}
 
export function isBudgetJob(job: BaseJob): job is BudgetJob {
  return job instanceof BudgetJob
}
 
export function isEndpointJob(job: BaseJob): job is EndpointJob {
  return job instanceof EndpointJob
}
 
export type QueueArgs = TransactionJobArgs | BudgetJobArgs | EndpointJobArgs | JobArgs