Method postgresTransaction

plugin-server/src/utils/db/db.ts:229–254

(
        tag: string,
        transaction: (client: PoolClient) => Promise<ReturnType>
    )

    }

    public postgresTransaction<ReturnType>(
        tag: string,
        transaction: (client: PoolClient) => Promise<ReturnType>
    ): Promise<ReturnType> {
        return instrumentQuery(this.statsd, 'query.postgres_transation', undefined, async () => {
            const timeout = timeoutGuard(`Postgres slow transaction warning after 30 sec!`)
            const client = await this.postgres.connect()
            try {
                await client.query('BEGIN')
                const response = await transaction(client)
                await client.query('COMMIT')
                return response
            } catch (e) {
                await client.query('ROLLBACK')

                // if Postgres is down the ROLLBACK above won't work, but the transaction shouldn't be committed either
                if (e.message && POSTGRES_UNAVAILABLE_ERROR_MESSAGES.some((message) => e.message.includes(message))) {
                    throw new DependencyUnavailableError(e.message, 'Postgres', e)
                }
                throw e
            } finally {
                client.release()
                clearTimeout(timeout)
            }
        })
    }

    public async postgresBulkInsert<T extends Array<any>>(
        // Should have {VALUES} as a placeholder