85 lines
2.1 KiB
TypeScript
85 lines
2.1 KiB
TypeScript
import {
|
|
FieldType,
|
|
FieldTypeSubtypes,
|
|
SearchParams,
|
|
Table,
|
|
DocumentType,
|
|
SEPARATOR,
|
|
FieldSubtype,
|
|
} from "@budibase/types"
|
|
import { db as dbCore } from "@budibase/backend-core"
|
|
import { utils } from "@budibase/shared-core"
|
|
|
|
function findColumnInQueries(
|
|
column: string,
|
|
options: SearchParams,
|
|
callback: (filter: any) => any
|
|
) {
|
|
if (!options.query) {
|
|
return
|
|
}
|
|
for (let filterBlock of Object.values(options.query)) {
|
|
if (typeof filterBlock !== "object") {
|
|
continue
|
|
}
|
|
for (let [key, filter] of Object.entries(filterBlock)) {
|
|
if (key.endsWith(column)) {
|
|
filterBlock[key] = callback(filter)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function userColumnMapping(column: string, options: SearchParams) {
|
|
findColumnInQueries(column, options, (filterValue: any): any => {
|
|
const isArray = Array.isArray(filterValue),
|
|
isString = typeof filterValue === "string"
|
|
if (!isString && !isArray) {
|
|
return filterValue
|
|
}
|
|
const processString = (input: string) => {
|
|
const rowPrefix = DocumentType.ROW + SEPARATOR
|
|
if (input.startsWith(rowPrefix)) {
|
|
return dbCore.getGlobalIDFromUserMetadataID(input)
|
|
} else {
|
|
return input
|
|
}
|
|
}
|
|
if (isArray) {
|
|
return filterValue.map(el => {
|
|
if (typeof el === "string") {
|
|
return processString(el)
|
|
} else {
|
|
return el
|
|
}
|
|
})
|
|
} else {
|
|
return processString(filterValue)
|
|
}
|
|
})
|
|
}
|
|
|
|
// maps through the search parameters to check if any of the inputs are invalid
|
|
// based on the table schema, converts them to something that is valid.
|
|
export function searchInputMapping(table: Table, options: SearchParams) {
|
|
if (!table?.schema) {
|
|
return options
|
|
}
|
|
for (let [key, column] of Object.entries(table.schema)) {
|
|
switch (column.type) {
|
|
case FieldType.BB_REFERENCE:
|
|
const subtype = column.subtype as FieldSubtype
|
|
switch (subtype) {
|
|
case FieldSubtype.USER:
|
|
case FieldSubtype.USERS:
|
|
userColumnMapping(key, options)
|
|
break
|
|
default:
|
|
utils.unreachable(subtype)
|
|
}
|
|
break
|
|
}
|
|
}
|
|
return options
|
|
}
|