75 lines
1.8 KiB
TypeScript
75 lines
1.8 KiB
TypeScript
import { cache } from "@budibase/backend-core"
|
|
import { utils } from "@budibase/shared-core"
|
|
import { FieldSubtype } from "@budibase/types"
|
|
import { InvalidBBRefError } from "./errors"
|
|
|
|
export async function processInputBBReferences(
|
|
value: string | string[] | { _id: string } | { _id: string }[],
|
|
subtype: FieldSubtype
|
|
): Promise<string> {
|
|
const result: string[] = []
|
|
|
|
switch (subtype) {
|
|
case FieldSubtype.USER:
|
|
if (Array.isArray(value)) {
|
|
result.push(...value.map(x => (typeof x === "string" ? x : x._id)))
|
|
} else if (typeof value !== "string") {
|
|
result.push(value._id)
|
|
} else {
|
|
result.push(...value.split(",").map((id: string) => id.trim()))
|
|
}
|
|
|
|
for (const id of result) {
|
|
try {
|
|
const user = await cache.user.getUser(id)
|
|
if (!user) {
|
|
throw new InvalidBBRefError(id, FieldSubtype.USER)
|
|
}
|
|
} catch (err: any) {
|
|
if (err != null && err.status === 404 && err.error === "not_found") {
|
|
throw new InvalidBBRefError(id, FieldSubtype.USER)
|
|
}
|
|
throw err
|
|
}
|
|
}
|
|
break
|
|
default:
|
|
throw utils.unreachable(subtype)
|
|
}
|
|
|
|
return result.join(",")
|
|
}
|
|
|
|
export async function processOutputBBReferences(
|
|
value: string,
|
|
subtype: FieldSubtype
|
|
) {
|
|
if (typeof value !== "string") {
|
|
return value
|
|
}
|
|
|
|
const result = []
|
|
|
|
switch (subtype) {
|
|
case FieldSubtype.USER:
|
|
for (const id of value.split(",")) {
|
|
try {
|
|
const user = await cache.user.getUser(id)
|
|
if (user) {
|
|
result.push(user)
|
|
}
|
|
} catch {
|
|
// If user cannot be found, we just strip it
|
|
}
|
|
}
|
|
break
|
|
default:
|
|
throw utils.unreachable(subtype)
|
|
}
|
|
|
|
if (result.length > 1) {
|
|
return result
|
|
}
|
|
|
|
return result[0]
|
|
}
|