hopefully fixing aiven extras issue

This commit is contained in:
Kristaps Fabians Geikins 2024-11-12 13:17:28 +02:00
Родитель db11ef46ab
Коммит 8087f3a223
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: 16D20A16730A0111
1 изменённых файлов: 7 добавлений и 0 удалений

Просмотреть файл

@ -56,6 +56,10 @@ const inEachDb = async (fn: (db: Knex) => MaybeAsync<void>) => {
}
}
const ensureAivenExtrasFactory = (deps: { db: Knex }) => async () => {
await deps.db.raw('CREATE EXTENSION IF NOT EXISTS "aiven_extras";')
}
const setupMultiregionMode = async () => {
const db = mainDb
const getAvailableRegionKeys = getAvailableRegionKeysFactory({
@ -113,6 +117,9 @@ export const resetPubSubFactory = (deps: { db: Knex }) => async () => {
return { drop: async () => {}, reenable: async () => {} }
}
const ensureAivenExtras = ensureAivenExtrasFactory(deps)
await ensureAivenExtras()
const subscriptions = (await deps.db.raw(
`SELECT subname, subconninfo, subpublications, subslotname FROM aiven_extras.pg_list_all_subscriptions() WHERE subname ILIKE 'test_%';`
)) as {