PgPubSubService

class

Subscribes to PostgreSQL pub/sub triggers and handles table changes.

onModuleDestroy()

Signature

onModuleDestroy(): Promise<void>

Returns

Promise<void>

onModuleInit()

Signature

onModuleInit(): Promise<void>

Returns

Promise<void>

pause()

Signature

pause(): Promise<void>

Returns

Promise<void>

resume()

Signature

resume(): Promise<void>

Returns

Promise<void>

susbcribe()

Signature

susbcribe(channel: string, callback: (payload: T) => void): Promise<void>

Parameters

• channel (string)
• callback ((payload: T) => void)

Returns

Promise<void>

suspendAndRun()

Signature

suspendAndRun(action: () => Promise<void>): Promise<void>

Parameters

• action (() => Promise<void>)

Returns

Promise<void>

withTriggersDisabled()

Signature

withTriggersDisabled(callback: (entityManager: EntityManager) => Promise<T>): Promise<T>

Parameters

• callback ((entityManager: EntityManager) => Promise<T>)

Returns

Promise<T>

withTriggersDisabledRaw()

Signature

withTriggersDisabledRaw(callback: (query: (sql: string, params: unknown[]) => Promise<R[]>) => Promise<T>): Promise<T>

Parameters

• callback ((query: (sql: string, params: unknown[]) => Promise<R[]>) => Promise<T>)

Returns

Promise<T>