MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Respond to PR comments.

This commit is contained in:
Sam Rose 2024-07-10 11:32:34 +01:00
parent 2fa14ab35f
commit 76d22dfffd
No known key found for this signature in database
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/server/src/api/controllers/table/utils.ts
View File

@ -15,7 +15,7 @@ import { getViews, saveView } from "../view/utils"
import viewTemplate from "../view/viewBuilder" import viewTemplate from "../view/viewBuilder"
import { cloneDeep } from "lodash/fp" import { cloneDeep } from "lodash/fp"
import { quotas } from "@budibase/pro" import { quotas } from "@budibase/pro"
import { events, context, db } from "@budibase/backend-core" import { events, context, db as dbCore } from "@budibase/backend-core"
import { import {
AutoFieldSubType, AutoFieldSubType,
ContextUser, ContextUser,
@ -498,16 +498,16 @@ export function setStaticSchemas(datasource: Datasource, table: Table) {
} }
export async function internalTableCleanup(table: Table, rows?: Row[]) { export async function internalTableCleanup(table: Table, rows?: Row[]) {
const appDb = context.getAppDB() const db = context.getAppDB()
const tableId = table._id! const tableId = table._id!
// remove table search index // remove table search index
if (!env.isTest() || env.COUCH_DB_URL) { if (!env.isTest() || env.COUCH_DB_URL) {
const currentIndexes = await appDb.getIndexes() const currentIndexes = await db.getIndexes()
const existingIndex = currentIndexes.indexes.find( const existingIndex = currentIndexes.indexes.find(
(existing: any) => existing.name === `search:${tableId}` (existing: any) => existing.name === `search:${tableId}`
) )
if (existingIndex) { if (existingIndex) {
await appDb.deleteIndex(existingIndex) await db.deleteIndex(existingIndex)
} }
} }
@ -518,7 +518,7 @@ export async function internalTableCleanup(table: Table, rows?: Row[]) {
if (rows) { if (rows) {
await AttachmentCleanup.tableDelete(table, rows) await AttachmentCleanup.tableDelete(table, rows)
} }
if (db.isSqsEnabledForTenant()) { if (dbCore.isSqsEnabledForTenant()) {
await sdk.tables.sqs.removeTable(table) await sdk.tables.sqs.removeTable(table)
} }
} }