diff --git a/hosting/couchdb/runner.sh b/hosting/couchdb/runner.sh
index e56b8e0e7f..9f6a853ca7 100644
--- a/hosting/couchdb/runner.sh
+++ b/hosting/couchdb/runner.sh
@@ -76,6 +76,6 @@ done
# CouchDB needs the `_users` and `_replicator` databases to exist before it will
# function correctly, so we create them here.
-curl -X PUT http://${COUCHDB_USER}:${COUCHDB_PASSWORD}@localhost:5984/_users
-curl -X PUT http://${COUCHDB_USER}:${COUCHDB_PASSWORD}@localhost:5984/_replicator
+curl -X PUT -u "${COUCHDB_USER}:${COUCHDB_PASSWORD}" http://localhost:5984/_users
+curl -X PUT -u "${COUCHDB_USER}:${COUCHDB_PASSWORD}" http://localhost:5984/_replicator
sleep infinity
\ No newline at end of file
diff --git a/hosting/docker-compose.yaml b/hosting/docker-compose.yaml
index 7803916069..36b88466fe 100644
--- a/hosting/docker-compose.yaml
+++ b/hosting/docker-compose.yaml
@@ -26,7 +26,7 @@ services:
BB_ADMIN_USER_EMAIL: ${BB_ADMIN_USER_EMAIL}
BB_ADMIN_USER_PASSWORD: ${BB_ADMIN_USER_PASSWORD}
PLUGINS_DIR: ${PLUGINS_DIR}
- OFFLINE_MODE: ${OFFLINE_MODE}
+ OFFLINE_MODE: ${OFFLINE_MODE:-}
depends_on:
- worker-service
- redis-service
@@ -53,7 +53,7 @@ services:
INTERNAL_API_KEY: ${INTERNAL_API_KEY}
REDIS_URL: redis-service:6379
REDIS_PASSWORD: ${REDIS_PASSWORD}
- OFFLINE_MODE: ${OFFLINE_MODE}
+ OFFLINE_MODE: ${OFFLINE_MODE:-}
depends_on:
- redis-service
- minio-service
@@ -109,7 +109,7 @@ services:
redis-service:
restart: unless-stopped
image: redis
- command: redis-server --requirepass ${REDIS_PASSWORD}
+ command: redis-server --requirepass "${REDIS_PASSWORD}"
volumes:
- redis_data:/data
diff --git a/lerna.json b/lerna.json
index 71c53cd3fa..81b35e2a6e 100644
--- a/lerna.json
+++ b/lerna.json
@@ -1,5 +1,5 @@
{
- "version": "2.14.2",
+ "version": "2.14.5",
"npmClient": "yarn",
"packages": [
"packages/*",
diff --git a/packages/account-portal b/packages/account-portal
index b11e6b4737..b23fb3b179 160000
--- a/packages/account-portal
+++ b/packages/account-portal
@@ -1 +1 @@
-Subproject commit b11e6b47370d9b77c63648b45929c86bfed6360c
+Subproject commit b23fb3b17961fb04badd9487913a683fcf26dbe6
diff --git a/packages/backend-core/src/environment.ts b/packages/backend-core/src/environment.ts
index 138dbbd9e0..0fec786c31 100644
--- a/packages/backend-core/src/environment.ts
+++ b/packages/backend-core/src/environment.ts
@@ -166,6 +166,8 @@ const environment = {
DISABLE_JWT_WARNING: process.env.DISABLE_JWT_WARNING,
BLACKLIST_IPS: process.env.BLACKLIST_IPS,
SERVICE_TYPE: "unknown",
+ PASSWORD_MIN_LENGTH: process.env.PASSWORD_MIN_LENGTH,
+ PASSWORD_MAX_LENGTH: process.env.PASSWORD_MAX_LENGTH,
/**
* Enable to allow an admin user to login using a password.
* This can be useful to prevent lockout when configuring SSO.
diff --git a/packages/backend-core/src/middleware/authenticated.ts b/packages/backend-core/src/middleware/authenticated.ts
index 16f658b90a..d357dbdbdc 100644
--- a/packages/backend-core/src/middleware/authenticated.ts
+++ b/packages/backend-core/src/middleware/authenticated.ts
@@ -15,6 +15,7 @@ import * as identity from "../context/identity"
import env from "../environment"
import { Ctx, EndpointMatcher, SessionCookie } from "@budibase/types"
import { InvalidAPIKeyError, ErrorCode } from "../errors"
+import tracer from "dd-trace"
const ONE_MINUTE = env.SESSION_UPDATE_PERIOD
? parseInt(env.SESSION_UPDATE_PERIOD)
@@ -166,6 +167,16 @@ export default function (
if (!authenticated) {
authenticated = false
}
+
+ if (user) {
+ tracer.setUser({
+ id: user?._id,
+ tenantId: user?.tenantId,
+ budibaseAccess: user?.budibaseAccess,
+ status: user?.status,
+ })
+ }
+
// isAuthenticated is a function, so use a variable to be able to check authed state
finalise(ctx, { authenticated, user, internal, version, publicEndpoint })
diff --git a/packages/backend-core/src/redis/redlockImpl.ts b/packages/backend-core/src/redis/redlockImpl.ts
index e57a3721b5..7009dc6f55 100644
--- a/packages/backend-core/src/redis/redlockImpl.ts
+++ b/packages/backend-core/src/redis/redlockImpl.ts
@@ -2,7 +2,6 @@ import Redlock from "redlock"
import { getLockClient } from "./init"
import { LockOptions, LockType } from "@budibase/types"
import * as context from "../context"
-import { logWarn } from "../logging"
import { utils } from "@budibase/shared-core"
import { Duration } from "../utils"
diff --git a/packages/backend-core/src/security/auth.ts b/packages/backend-core/src/security/auth.ts
index c90d9df09b..1cce35a0af 100644
--- a/packages/backend-core/src/security/auth.ts
+++ b/packages/backend-core/src/security/auth.ts
@@ -1,7 +1,7 @@
-import { env } from ".."
+import env from "../environment"
-export const PASSWORD_MIN_LENGTH = +(process.env.PASSWORD_MIN_LENGTH || 8)
-export const PASSWORD_MAX_LENGTH = +(process.env.PASSWORD_MAX_LENGTH || 512)
+export const PASSWORD_MIN_LENGTH = +(env.PASSWORD_MIN_LENGTH || 8)
+export const PASSWORD_MAX_LENGTH = +(env.PASSWORD_MAX_LENGTH || 512)
export function validatePassword(
password: string
diff --git a/packages/backend-core/src/users/db.ts b/packages/backend-core/src/users/db.ts
index 3214b3ab63..4d0d216603 100644
--- a/packages/backend-core/src/users/db.ts
+++ b/packages/backend-core/src/users/db.ts
@@ -44,6 +44,12 @@ type GroupFns = {
getBulk: GroupGetFn
getGroupBuilderAppIds: GroupBuildersFn
}
+type CreateAdminUserOpts = {
+ ssoId?: string
+ hashPassword?: boolean
+ requirePassword?: boolean
+ skipPasswordValidation?: boolean
+}
type FeatureFns = { isSSOEnforced: FeatureFn; isAppBuildersEnabled: FeatureFn }
const bulkDeleteProcessing = async (dbUser: User) => {
@@ -112,9 +118,11 @@ export class UserDB {
throw new HTTPError("Password change is disabled for this user", 400)
}
- const passwordValidation = validatePassword(password)
- if (!passwordValidation.valid) {
- throw new HTTPError(passwordValidation.error, 400)
+ if (!opts.skipPasswordValidation) {
+ const passwordValidation = validatePassword(password)
+ if (!passwordValidation.valid) {
+ throw new HTTPError(passwordValidation.error, 400)
+ }
}
hashedPassword = opts.hashPassword ? await hash(password) : password
@@ -489,7 +497,7 @@ export class UserDB {
email: string,
password: string,
tenantId: string,
- opts?: { ssoId?: string; hashPassword?: boolean; requirePassword?: boolean }
+ opts?: CreateAdminUserOpts
) {
const user: User = {
email: email,
@@ -513,6 +521,7 @@ export class UserDB {
return await UserDB.save(user, {
hashPassword: opts?.hashPassword,
requirePassword: opts?.requirePassword,
+ skipPasswordValidation: opts?.skipPasswordValidation,
})
}
diff --git a/packages/bbui/src/ActionButton/ActionButton.svelte b/packages/bbui/src/ActionButton/ActionButton.svelte
index 427a98f888..0e6ec3d155 100644
--- a/packages/bbui/src/ActionButton/ActionButton.svelte
+++ b/packages/bbui/src/ActionButton/ActionButton.svelte
@@ -130,5 +130,6 @@
max-width: 150px;
transform: translateX(-50%);
text-align: center;
+ z-index: 1;
}
diff --git a/packages/bbui/src/DetailSummary/DetailSummary.svelte b/packages/bbui/src/DetailSummary/DetailSummary.svelte
index e5d6fda86b..2cbb6796f3 100644
--- a/packages/bbui/src/DetailSummary/DetailSummary.svelte
+++ b/packages/bbui/src/DetailSummary/DetailSummary.svelte
@@ -78,7 +78,7 @@
var(--spacing-xl);
}
.property-panel.no-title {
- padding: var(--spacing-xl);
+ padding-top: var(--spacing-xl);
}
.show {
diff --git a/packages/bbui/src/Form/Field.svelte b/packages/bbui/src/Form/Field.svelte
index 0c031b0235..1770438c3c 100644
--- a/packages/bbui/src/Form/Field.svelte
+++ b/packages/bbui/src/Form/Field.svelte
@@ -51,15 +51,13 @@
margin-top: var(--spectrum-global-dimension-size-75);
align-items: center;
}
-
.helpText :global(svg) {
- width: 14px;
- color: var(--grey-5);
+ width: 13px;
+ color: var(--spectrum-global-color-gray-600);
margin-right: 6px;
}
-
.helpText span {
- color: var(--grey-7);
+ color: var(--spectrum-global-color-gray-800);
font-size: var(--spectrum-global-dimension-font-size-75);
}
diff --git a/packages/builder/src/api.js b/packages/builder/src/api.js
index 37894d9bbc..ac878bf82f 100644
--- a/packages/builder/src/api.js
+++ b/packages/builder/src/api.js
@@ -5,7 +5,7 @@ import {
} from "@budibase/frontend-core"
import { store } from "./builderStore"
import { get } from "svelte/store"
-import { auth } from "./stores/portal"
+import { auth, navigation } from "./stores/portal"
export const API = createAPIClient({
attachHeaders: headers => {
@@ -45,4 +45,15 @@ export const API = createAPIClient({
}
}
},
+ onMigrationDetected: appId => {
+ const updatingUrl = `/builder/app/updating/${appId}`
+
+ if (window.location.pathname === updatingUrl) {
+ return
+ }
+
+ get(navigation).goto(
+ `${updatingUrl}?returnUrl=${encodeURIComponent(window.location.pathname)}`
+ )
+ },
})
diff --git a/packages/builder/src/builderStore/dataBinding.js b/packages/builder/src/builderStore/dataBinding.js
index d86e94aba2..52368a0723 100644
--- a/packages/builder/src/builderStore/dataBinding.js
+++ b/packages/builder/src/builderStore/dataBinding.js
@@ -465,8 +465,8 @@ const filterCategoryByContext = (component, context) => {
const { _component } = component
if (_component.endsWith("formblock")) {
if (
- (component.actionType == "Create" && context.type === "schema") ||
- (component.actionType == "View" && context.type === "form")
+ (component.actionType === "Create" && context.type === "schema") ||
+ (component.actionType === "View" && context.type === "form")
) {
return false
}
@@ -474,20 +474,21 @@ const filterCategoryByContext = (component, context) => {
return true
}
+// Enrich binding category information for certain components
const getComponentBindingCategory = (component, context, def) => {
let icon = def.icon
let category = component._instanceName
if (component._component.endsWith("formblock")) {
- let contextCategorySuffix = {
- form: "Fields",
- schema: "Row",
+ if (context.type === "form") {
+ category = `${component._instanceName} - Fields`
+ icon = "Form"
+ } else if (context.type === "schema") {
+ category = `${component._instanceName} - Row`
+ icon = "Data"
}
- category = `${component._instanceName} - ${
- contextCategorySuffix[context.type]
- }`
- icon = context.type === "form" ? "Form" : "Data"
}
+
return {
icon,
category,
diff --git a/packages/builder/src/builderStore/store/frontend.js b/packages/builder/src/builderStore/store/frontend.js
index aaa0eb0184..b05b127b1c 100644
--- a/packages/builder/src/builderStore/store/frontend.js
+++ b/packages/builder/src/builderStore/store/frontend.js
@@ -85,7 +85,6 @@ const INITIAL_FRONTEND_STATE = {
selectedScreenId: null,
selectedComponentId: null,
selectedLayoutId: null,
- hoverComponentId: null,
// Client state
selectedComponentInstance: null,
@@ -93,6 +92,9 @@ const INITIAL_FRONTEND_STATE = {
// Onboarding
onboarding: false,
tourNodes: null,
+
+ // UI state
+ hoveredComponentId: null,
}
export const getFrontendStore = () => {
@@ -610,12 +612,12 @@ export const getFrontendStore = () => {
// Use default config if the 'buttons' prop has never been initialised
if (!("buttons" in enrichedComponent)) {
enrichedComponent["buttons"] =
- Utils.buildDynamicButtonConfig(enrichedComponent)
+ Utils.buildFormBlockButtonConfig(enrichedComponent)
migrated = true
} else if (enrichedComponent["buttons"] == null) {
// Ignore legacy config if 'buttons' has been reset by 'resetOn'
const { _id, actionType, dataSource } = enrichedComponent
- enrichedComponent["buttons"] = Utils.buildDynamicButtonConfig({
+ enrichedComponent["buttons"] = Utils.buildFormBlockButtonConfig({
_id,
actionType,
dataSource,
@@ -1289,15 +1291,14 @@ export const getFrontendStore = () => {
const settings = getComponentSettings(component._component)
const updatedSetting = settings.find(setting => setting.key === name)
- // Can be a single string or array of strings
- const resetFields = settings.filter(setting => {
- return (
+ // Reset dependent fields
+ settings.forEach(setting => {
+ const needsReset =
name === setting.resetOn ||
(Array.isArray(setting.resetOn) && setting.resetOn.includes(name))
- )
- })
- resetFields?.forEach(setting => {
- component[setting.key] = null
+ if (needsReset) {
+ component[setting.key] = setting.defaultValue || null
+ }
})
if (
@@ -1414,6 +1415,18 @@ export const getFrontendStore = () => {
return state
})
},
+ hover: (componentId, notifyClient = true) => {
+ if (componentId === get(store).hoveredComponentId) {
+ return
+ }
+ store.update(state => {
+ state.hoveredComponentId = componentId
+ return state
+ })
+ if (notifyClient) {
+ store.actions.preview.sendEvent("hover-component", componentId)
+ }
+ },
},
links: {
save: async (url, title) => {
diff --git a/packages/builder/src/components/automation/AutomationBuilder/FlowChart/ActionModal.svelte b/packages/builder/src/components/automation/AutomationBuilder/FlowChart/ActionModal.svelte
index 0c97853dd6..c99de272f5 100644
--- a/packages/builder/src/components/automation/AutomationBuilder/FlowChart/ActionModal.svelte
+++ b/packages/builder/src/components/automation/AutomationBuilder/FlowChart/ActionModal.svelte
@@ -158,7 +158,7 @@
{#if isDisabled && !syncAutomationsEnabled && !triggerAutomationsEnabled && lockedFeatures.includes(action.stepId)}
- Business
+ Premium
{:else if isDisabled}
diff --git a/packages/builder/src/components/automation/SetupPanel/RowSelectorTypes.svelte b/packages/builder/src/components/automation/SetupPanel/RowSelectorTypes.svelte
index 851c5b39c9..937e3b6c69 100644
--- a/packages/builder/src/components/automation/SetupPanel/RowSelectorTypes.svelte
+++ b/packages/builder/src/components/automation/SetupPanel/RowSelectorTypes.svelte
@@ -41,7 +41,7 @@
{ label: "False", value: "false" },
]}
/>
-{:else if schema.type === "array"}
+{:else if schemaHasOptions(schema) && schema.type === "array"}
onChange(e, field)}
useLabel={false}
/>
-{:else if ["string", "number", "bigint", "barcodeqr"].includes(schema.type)}
+{:else if ["string", "number", "bigint", "barcodeqr", "array"].includes(schema.type)}
{
+ if (!Array.isArray(val)) {
+ return null
+ }
return val?.map(button => {
return button._component ? button : buildPseudoInstance(button)
})
diff --git a/packages/builder/src/components/design/settings/controls/DraggableList/DraggableList.svelte b/packages/builder/src/components/design/settings/controls/DraggableList/DraggableList.svelte
index cce11e4b17..384f9bf098 100644
--- a/packages/builder/src/components/design/settings/controls/DraggableList/DraggableList.svelte
+++ b/packages/builder/src/components/design/settings/controls/DraggableList/DraggableList.svelte
@@ -13,6 +13,8 @@
export let draggable = true
export let focus
+ let zoneType = generate()
+
let store = writable({
selected: null,
actions: {
@@ -46,6 +48,7 @@
return {
id: listItemKey ? item[listItemKey] : generate(),
item,
+ type: zoneType,
}
})
.filter(item => item.id)
@@ -83,6 +86,8 @@
items: draggableItems,
dropTargetStyle: { outline: "none" },
dragDisabled: !draggable || inactive,
+ type: zoneType,
+ dropFromOthersDisabled: true,
}}
on:finalize={handleFinalize}
on:consider={updateRowOrder}
diff --git a/packages/builder/src/components/design/settings/controls/FieldConfiguration/FieldConfiguration.svelte b/packages/builder/src/components/design/settings/controls/FieldConfiguration/FieldConfiguration.svelte
index 7f1ac1cf25..e864a4c2aa 100644
--- a/packages/builder/src/components/design/settings/controls/FieldConfiguration/FieldConfiguration.svelte
+++ b/packages/builder/src/components/design/settings/controls/FieldConfiguration/FieldConfiguration.svelte
@@ -14,6 +14,7 @@
import { convertOldFieldFormat, getComponentForField } from "./utils"
export let componentInstance
+ export let bindings
export let value
const dispatch = createEventDispatcher()
@@ -28,7 +29,9 @@
let selectAll = true
- $: bindings = getBindableProperties($selectedScreen, componentInstance._id)
+ $: resolvedBindings =
+ bindings || getBindableProperties($selectedScreen, componentInstance._id)
+
$: actionType = componentInstance.actionType
let componentBindings = []
@@ -39,7 +42,10 @@
)
}
- $: datasource = getDatasourceForProvider($currentAsset, componentInstance)
+ $: datasource =
+ componentInstance.dataSource ||
+ getDatasourceForProvider($currentAsset, componentInstance)
+
$: resourceId = datasource?.resourceId || datasource?.tableId
$: if (!isEqual(value, cachedValue)) {
@@ -179,7 +185,7 @@
listType={FieldSetting}
listTypeProps={{
componentBindings,
- bindings,
+ bindings: resolvedBindings,
}}
/>
{/if}
diff --git a/packages/builder/src/components/design/settings/controls/FormStepConfiguration.svelte b/packages/builder/src/components/design/settings/controls/FormStepConfiguration.svelte
new file mode 100644
index 0000000000..2941821dec
--- /dev/null
+++ b/packages/builder/src/components/design/settings/controls/FormStepConfiguration.svelte
@@ -0,0 +1,182 @@
+
+
+
+
+
+
+
diff --git a/packages/builder/src/components/design/settings/controls/FormStepControls.svelte b/packages/builder/src/components/design/settings/controls/FormStepControls.svelte
new file mode 100644
index 0000000000..638d80945d
--- /dev/null
+++ b/packages/builder/src/components/design/settings/controls/FormStepControls.svelte
@@ -0,0 +1,84 @@
+
+
+{#if stepCount === 1}
+
+
{
+ stepAction("addStep")
+ }}
+ >
+ Add Step
+
+
+{:else}
+
+
{
+ stepAction("previousStep")
+ }}
+ tooltip={"Previous step"}
+ />
+ {
+ stepAction("nextStep")
+ }}
+ tooltip={"Next step"}
+ />
+ {
+ stepAction("removeStep")
+ }}
+ tooltip={"Remove step"}
+ />
+ {
+ stepAction("addStep")
+ }}
+ tooltip={"Add step"}
+ />
+
+{/if}
+
+
diff --git a/packages/builder/src/components/design/settings/controls/GridColumnConfiguration/getColumns.js b/packages/builder/src/components/design/settings/controls/GridColumnConfiguration/getColumns.js
index 72fdbe4108..e7b1727b54 100644
--- a/packages/builder/src/components/design/settings/controls/GridColumnConfiguration/getColumns.js
+++ b/packages/builder/src/components/design/settings/controls/GridColumnConfiguration/getColumns.js
@@ -114,7 +114,7 @@ const getColumns = ({
primary,
sortable,
updateSortable: newDraggableList => {
- onChange(toGridFormat(newDraggableList.concat(primary)))
+ onChange(toGridFormat(newDraggableList.concat(primary || [])))
},
update: newEntry => {
const newDraggableList = draggableList.map(entry => {
diff --git a/packages/builder/src/components/design/settings/controls/PropertyControl.svelte b/packages/builder/src/components/design/settings/controls/PropertyControl.svelte
index a6f3d1b218..c20dd9310b 100644
--- a/packages/builder/src/components/design/settings/controls/PropertyControl.svelte
+++ b/packages/builder/src/components/design/settings/controls/PropertyControl.svelte
@@ -24,6 +24,7 @@
export let propertyFocus = false
export let info = null
export let disableBindings = false
+ export let wide
$: nullishValue = value == null || value === ""
$: allBindings = getAllBindings(bindings, componentBindings, nested)
@@ -78,7 +79,7 @@
@@ -104,6 +105,7 @@
{...props}
on:drawerHide
on:drawerShow
+ on:meta
/>
{#if info}
@@ -146,15 +148,28 @@
.control {
position: relative;
}
- .property-control.wide .control {
- grid-column: 1 / -1;
- }
.text {
font-size: var(--spectrum-global-dimension-font-size-75);
color: var(--grey-6);
grid-column: 2 / 2;
}
+
+ .property-control.wide .control {
+ flex: 1;
+ }
+ .property-control.wide {
+ grid-template-columns: unset;
+ display: flex;
+ flex-direction: column;
+ width: 100%;
+ }
+ .property-control.wide > * {
+ width: 100%;
+ }
.property-control.wide .text {
grid-column: 1 / -1;
}
+ .property-control.wide .label {
+ margin-bottom: -8px;
+ }
diff --git a/packages/builder/src/components/design/settings/controls/RelationshipFilterEditor.svelte b/packages/builder/src/components/design/settings/controls/RelationshipFilterEditor.svelte
index 7e63bf38df..0eb93732c3 100644
--- a/packages/builder/src/components/design/settings/controls/RelationshipFilterEditor.svelte
+++ b/packages/builder/src/components/design/settings/controls/RelationshipFilterEditor.svelte
@@ -1,6 +1,9 @@
@@ -120,9 +111,9 @@
on:dragover={dragover(component, index)}
on:iconClick={() => toggleNodeOpen(component._id)}
on:drop={onDrop}
- hovering={$store.hoverComponentId === component._id}
- on:mouseenter={() => handleMouseover(component._id)}
- on:mouseleave={() => handleMouseout(component._id)}
+ hovering={$store.hoveredComponentId === component._id}
+ on:mouseenter={() => hover(component._id)}
+ on:mouseleave={() => hover(null)}
text={getComponentText(component)}
icon={getComponentIcon(component)}
iconTooltip={getComponentName(component)}
diff --git a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/_components/ComponentList/index.svelte b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/_components/ComponentList/index.svelte
index 1e2ea47e63..d2ffc5de74 100644
--- a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/_components/ComponentList/index.svelte
+++ b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/_components/ComponentList/index.svelte
@@ -12,6 +12,9 @@
let scrolling = false
+ $: screenComponentId = `${$store.selectedScreenId}-screen`
+ $: navComponentId = `${$store.selectedScreenId}-navigation`
+
const toNewComponentRoute = () => {
if ($isActive(`./:componentId/new`)) {
$goto(`./:componentId`)
@@ -33,16 +36,7 @@
scrolling = e.target.scrollTop !== 0
}
- const handleMouseover = componentId => {
- if ($store.hoverComponentId !== componentId) {
- $store.hoverComponentId = componentId
- }
- }
- const handleMouseout = componentId => {
- if ($store.hoverComponentId === componentId) {
- $store.hoverComponentId = null
- }
- }
+ const hover = store.actions.components.hover
@@ -65,46 +59,31 @@
scrollable
icon="WebPage"
on:drop={onDrop}
- on:click={() => {
- $store.selectedComponentId = `${$store.selectedScreenId}-screen`
- }}
- hovering={$store.hoverComponentId ===
- `${$store.selectedScreenId}-screen`}
- on:mouseenter={() =>
- handleMouseover(`${$store.selectedScreenId}-screen`)}
- on:mouseleave={() =>
- handleMouseout(`${$store.selectedScreenId}-screen`)}
- id={`component-screen`}
- selectedBy={$userSelectedResourceMap[
- `${$store.selectedScreenId}-screen`
- ]}
+ on:click={() => ($store.selectedComponentId = screenComponentId)}
+ hovering={$store.hoveredComponentId === screenComponentId}
+ on:mouseenter={() => hover(screenComponentId)}
+ on:mouseleave={() => hover(null)}
+ id="component-screen"
+ selectedBy={$userSelectedResourceMap[screenComponentId]}
>
{
- $store.selectedComponentId = `${$store.selectedScreenId}-navigation`
- }}
- hovering={$store.hoverComponentId ===
- `${$store.selectedScreenId}-navigation`}
- on:mouseenter={() =>
- handleMouseover(`${$store.selectedScreenId}-navigation`)}
- on:mouseleave={() =>
- handleMouseout(`${$store.selectedScreenId}-navigation`)}
- id={`component-nav`}
- selectedBy={$userSelectedResourceMap[
- `${$store.selectedScreenId}-navigation`
- ]}
+ on:click={() => ($store.selectedComponentId = navComponentId)}
+ hovering={$store.hoveredComponentId === navComponentId}
+ on:mouseenter={() => hover(navComponentId)}
+ on:mouseleave={() => hover(null)}
+ id="component-nav"
+ selectedBy={$userSelectedResourceMap[navComponentId]}
/>
+ import { Updating } from "@budibase/frontend-core"
+ import { redirect, params } from "@roxi/routify"
+
+ import { API } from "api"
+
+ async function isMigrationDone() {
+ const response = await API.getMigrationStatus()
+ return response.migrated
+ }
+
+ async function onMigrationDone() {
+ // For some reason routify params is not stripping the ? properly, so we need to check both with and without ?
+ const returnUrl = $params.returnUrl || $params["?returnUrl"]
+ $redirect(returnUrl)
+ }
+
+
+
diff --git a/packages/builder/src/pages/builder/portal/settings/branding.svelte b/packages/builder/src/pages/builder/portal/settings/branding.svelte
index be2a61a8c7..17da5b87d7 100644
--- a/packages/builder/src/pages/builder/portal/settings/branding.svelte
+++ b/packages/builder/src/pages/builder/portal/settings/branding.svelte
@@ -214,7 +214,7 @@
Branding
{#if !isCloud && !brandingEnabled}
- Business
+ Premium
{/if}
{#if isCloud && !brandingEnabled}
diff --git a/packages/builder/src/pages/builder/portal/users/groups/index.svelte b/packages/builder/src/pages/builder/portal/users/groups/index.svelte
index a82da5cf34..ab0a0eb938 100644
--- a/packages/builder/src/pages/builder/portal/users/groups/index.svelte
+++ b/packages/builder/src/pages/builder/portal/users/groups/index.svelte
@@ -97,7 +97,7 @@
Groups
{#if !$licensing.groupsEnabled}
- Business
+ Enterpise
{/if}
diff --git a/packages/builder/src/stores/portal/index.js b/packages/builder/src/stores/portal/index.js
index e70df5c3ee..7f1b9e10f0 100644
--- a/packages/builder/src/stores/portal/index.js
+++ b/packages/builder/src/stores/portal/index.js
@@ -16,5 +16,6 @@ export { environment } from "./environment"
export { menu } from "./menu"
export { auditLogs } from "./auditLogs"
export { features } from "./features"
+export { navigation } from "./navigation"
export const sideBarCollapsed = writable(false)
diff --git a/packages/builder/src/stores/portal/navigation.js b/packages/builder/src/stores/portal/navigation.js
new file mode 100644
index 0000000000..67a06eff53
--- /dev/null
+++ b/packages/builder/src/stores/portal/navigation.js
@@ -0,0 +1,31 @@
+import { writable } from "svelte/store"
+
+export function createNavigationStore() {
+ const store = writable({
+ initialisated: false,
+ goto: undefined,
+ })
+ const { set, subscribe } = store
+
+ const init = gotoFunc => {
+ if (typeof gotoFunc !== "function") {
+ throw new Error(
+ `gotoFunc must be a function, found a "${typeof gotoFunc}" instead`
+ )
+ }
+
+ set({
+ initialisated: true,
+ goto: gotoFunc,
+ })
+ }
+
+ return {
+ subscribe,
+ actions: {
+ init,
+ },
+ }
+}
+
+export const navigation = createNavigationStore()
diff --git a/packages/client/manifest.json b/packages/client/manifest.json
index b59f6d0fad..1c62b90a64 100644
--- a/packages/client/manifest.json
+++ b/packages/client/manifest.json
@@ -4879,7 +4879,7 @@
},
"chartblock": {
"block": true,
- "name": "Chart block",
+ "name": "Chart Block",
"icon": "GraphPie",
"hasChildren": false,
"settings": [
@@ -5369,7 +5369,7 @@
},
"tableblock": {
"block": true,
- "name": "Table block",
+ "name": "Table Block",
"icon": "Table",
"styles": ["size"],
"size": {
@@ -5615,7 +5615,7 @@
},
"cardsblock": {
"block": true,
- "name": "Cards block",
+ "name": "Cards Block",
"icon": "PersonalizationField",
"styles": ["size"],
"size": {
@@ -5795,7 +5795,7 @@
},
"repeaterblock": {
"block": true,
- "name": "Repeater block",
+ "name": "Repeater Block",
"icon": "ViewList",
"illegalChildren": ["section"],
"hasChildren": true,
@@ -6035,6 +6035,164 @@
}
]
},
+ "multistepformblock": {
+ "name": "Multi-step Form Block",
+ "icon": "AssetsAdded",
+ "block": true,
+ "hasChildren": false,
+ "ejectable": false,
+ "size": {
+ "width": 400,
+ "height": 400
+ },
+ "styles": ["size"],
+ "settings": [
+ {
+ "type": "table",
+ "label": "Data",
+ "key": "dataSource"
+ },
+ {
+ "type": "radio",
+ "label": "Type",
+ "key": "actionType",
+ "options": ["Create", "Update", "View"],
+ "defaultValue": "Create"
+ },
+ {
+ "section": true,
+ "dependsOn": {
+ "setting": "actionType",
+ "value": "Create",
+ "invert": true
+ },
+ "name": "Row ID",
+ "info": "How to pass a row ID using bindings",
+ "settings": [
+ {
+ "type": "text",
+ "label": "Row ID",
+ "key": "rowId",
+ "nested": true
+ },
+ {
+ "type": "text",
+ "label": "No rows found",
+ "key": "noRowsMessage",
+ "defaultValue": "We couldn't find a row to display",
+ "nested": true
+ }
+ ]
+ },
+ {
+ "section": true,
+ "name": "Details",
+ "settings": [
+ {
+ "type": "stepConfiguration",
+ "key": "steps",
+ "nested": true,
+ "labelHidden": true,
+ "resetOn": [
+ "dataSource",
+ "actionType"
+ ],
+ "defaultValue": [
+ {}
+ ]
+ }
+ ]
+ }
+ ],
+ "actions": [
+ {
+ "type": "ValidateForm",
+ "suffix": "form"
+ },
+ {
+ "type": "ClearForm",
+ "suffix": "form"
+ },
+ {
+ "type": "UpdateFieldValue",
+ "suffix": "form"
+ },
+ {
+ "type": "ScrollTo",
+ "suffix": "form"
+ },
+ {
+ "type": "ChangeFormStep",
+ "suffix": "form"
+ }
+ ],
+ "context": [
+ {
+ "type": "form",
+ "suffix": "form"
+ },
+ {
+ "type": "static",
+ "suffix": "form",
+ "values": [
+ {
+ "label": "Value",
+ "key": "__value",
+ "type": "object"
+ },
+ {
+ "label": "Valid",
+ "key": "__valid",
+ "type": "boolean"
+ },
+ {
+ "label": "Current Step",
+ "key": "__currentStep",
+ "type": "number"
+ },
+ {
+ "label": "Current Step Valid",
+ "key": "__currentStepValid",
+ "type": "boolean"
+ }
+ ]
+ }
+ ]
+ },
+ "multistepformblockstep": {
+ "name": "Multi-step Form Block Step",
+ "settings": [
+ {
+ "type": "formStepControls",
+ "label": "Steps",
+ "key": "steps"
+ },
+ {
+ "type": "text",
+ "label": "Title",
+ "key": "title",
+ "nested": true
+ },
+ {
+ "type": "text",
+ "label": "Description",
+ "key": "desc",
+ "nested": true
+ },
+ {
+ "type": "fieldConfiguration",
+ "key": "fields",
+ "nested": true
+ },
+ {
+ "type": "buttonConfiguration",
+ "label": "Buttons",
+ "key": "buttons",
+ "wide": true,
+ "nested": true
+ }
+ ]
+ },
"formblock": {
"name": "Form Block",
"icon": "Form",
@@ -6290,7 +6448,7 @@
}
},
"gridblock": {
- "name": "Grid block",
+ "name": "Grid Block",
"icon": "Table",
"styles": ["size"],
"size": {
diff --git a/packages/client/package.json b/packages/client/package.json
index 39ddb4bd49..227c7b25d4 100644
--- a/packages/client/package.json
+++ b/packages/client/package.json
@@ -37,7 +37,6 @@
"downloadjs": "1.4.7",
"html5-qrcode": "^2.2.1",
"leaflet": "^1.7.1",
- "regexparam": "^1.3.0",
"sanitize-html": "^2.7.0",
"screenfull": "^6.0.1",
"shortid": "^2.2.15",
diff --git a/packages/client/src/api/api.js b/packages/client/src/api/api.js
index 8488b702b6..d4c8faa4d2 100644
--- a/packages/client/src/api/api.js
+++ b/packages/client/src/api/api.js
@@ -77,4 +77,10 @@ export const API = createAPIClient({
// Log all errors to console
console.warn(`[Client] HTTP ${status} on ${method}:${url}\n\t${message}`)
},
+ onMigrationDetected: _appId => {
+ if (!window.MIGRATING_APP) {
+ // We will force a reload, that will display the updating screen until the migration is running
+ window.location.reload()
+ }
+ },
})
diff --git a/packages/client/src/components/UpdatingApp.svelte b/packages/client/src/components/UpdatingApp.svelte
new file mode 100644
index 0000000000..74e5500715
--- /dev/null
+++ b/packages/client/src/components/UpdatingApp.svelte
@@ -0,0 +1,23 @@
+
+
+
+
+
+
+
diff --git a/packages/client/src/components/app/blocks/MultiStepFormblock.svelte b/packages/client/src/components/app/blocks/MultiStepFormblock.svelte
new file mode 100644
index 0000000000..b90d0d4c7b
--- /dev/null
+++ b/packages/client/src/components/app/blocks/MultiStepFormblock.svelte
@@ -0,0 +1,204 @@
+
+
+
+
+ {#each enrichedSteps as step, stepIdx}
+
+
+
+
+
+
+
+
+ {#each step.fields as field, fieldIdx (`${field.field || field.name}_${stepIdx}_${fieldIdx}`)}
+ {#if getComponentForField(field)}
+
+ {/if}
+ {/each}
+
+
+
+
+
+ {/each}
+
+
+
+
diff --git a/packages/client/src/components/app/blocks/TableBlock.svelte b/packages/client/src/components/app/blocks/TableBlock.svelte
index c8b6a07e3d..04a7134ca0 100644
--- a/packages/client/src/components/app/blocks/TableBlock.svelte
+++ b/packages/client/src/components/app/blocks/TableBlock.svelte
@@ -265,7 +265,7 @@
props={{
dataSource,
buttonPosition: "top",
- buttons: Utils.buildDynamicButtonConfig({
+ buttons: Utils.buildFormBlockButtonConfig({
_id: $component.id + "-form-edit",
showDeleteButton: deleteLabel !== "",
showSaveButton: true,
@@ -299,7 +299,7 @@
props={{
dataSource,
buttonPosition: "top",
- buttons: Utils.buildDynamicButtonConfig({
+ buttons: Utils.buildFormBlockButtonConfig({
_id: $component.id + "-form-new",
showDeleteButton: false,
showSaveButton: true,
diff --git a/packages/client/src/components/app/blocks/form/FormBlock.svelte b/packages/client/src/components/app/blocks/form/FormBlock.svelte
index f23ecf451d..cdf1a05628 100644
--- a/packages/client/src/components/app/blocks/form/FormBlock.svelte
+++ b/packages/client/src/components/app/blocks/form/FormBlock.svelte
@@ -1,10 +1,8 @@
-
- {#if actionType === "Create"}
-
-
-
- {:else}
-
-
-
-
-
- {/if}
-
+
+
+
diff --git a/packages/client/src/components/app/blocks/form/FormBlockWrapper.svelte b/packages/client/src/components/app/blocks/form/FormBlockWrapper.svelte
new file mode 100644
index 0000000000..26767f84b3
--- /dev/null
+++ b/packages/client/src/components/app/blocks/form/FormBlockWrapper.svelte
@@ -0,0 +1,64 @@
+
+
+
+ {#if actionType === "Create"}
+
+
+
+ {:else}
+
+
+
+
+
+ {/if}
+
diff --git a/packages/client/src/components/app/blocks/index.js b/packages/client/src/components/app/blocks/index.js
index f74d2f0e12..2c8d81cf96 100644
--- a/packages/client/src/components/app/blocks/index.js
+++ b/packages/client/src/components/app/blocks/index.js
@@ -4,3 +4,4 @@ export { default as repeaterblock } from "./RepeaterBlock.svelte"
export { default as formblock } from "./form/FormBlock.svelte"
export { default as chartblock } from "./ChartBlock.svelte"
export { default as rowexplorer } from "./RowExplorer.svelte"
+export { default as multistepformblock } from "./MultiStepFormblock.svelte"
diff --git a/packages/client/src/components/app/forms/Field.svelte b/packages/client/src/components/app/forms/Field.svelte
index 22420b7430..adf5d10df7 100644
--- a/packages/client/src/components/app/forms/Field.svelte
+++ b/packages/client/src/components/app/forms/Field.svelte
@@ -137,21 +137,23 @@
width: 100%;
}
+ .error :global(svg),
+ .helpText :global(svg) {
+ width: 13px;
+ margin-right: 6px;
+ }
+
.error {
display: flex;
margin-top: var(--spectrum-global-dimension-size-75);
align-items: center;
}
-
.error :global(svg) {
- width: 14px;
color: var(
--spectrum-semantic-negative-color-default,
var(--spectrum-global-color-red-500)
);
- margin-right: 4px;
}
-
.error span {
color: var(
--spectrum-semantic-negative-color-default,
@@ -165,17 +167,14 @@
margin-top: var(--spectrum-global-dimension-size-75);
align-items: center;
}
-
.helpText :global(svg) {
- width: 14px;
- color: var(--grey-7);
- margin-right: 6px;
+ color: var(--spectrum-global-color-gray-600);
}
-
.helpText span {
- color: var(--grey-5);
+ color: var(--spectrum-global-color-gray-800);
font-size: var(--spectrum-global-dimension-font-size-75);
}
+
.spectrum-FieldLabel--right,
.spectrum-FieldLabel--left {
padding-right: var(--spectrum-global-dimension-size-200);
diff --git a/packages/client/src/components/app/forms/Form.svelte b/packages/client/src/components/app/forms/Form.svelte
index 1a740585f3..94559ab7be 100644
--- a/packages/client/src/components/app/forms/Form.svelte
+++ b/packages/client/src/components/app/forms/Form.svelte
@@ -34,7 +34,7 @@
let loaded = false
let schema
let table
- let currentStep = writable(getInitialFormStep())
+ let currentStep = getContext("current-step") || writable(getInitialFormStep())
$: fetchSchema(dataSource)
$: schemaKey = generateSchemaKey(schema)
diff --git a/packages/client/src/components/app/forms/InnerForm.svelte b/packages/client/src/components/app/forms/InnerForm.svelte
index 6ebe9de7ec..9d0db43bf4 100644
--- a/packages/client/src/components/app/forms/InnerForm.svelte
+++ b/packages/client/src/components/app/forms/InnerForm.svelte
@@ -423,10 +423,14 @@
}
const fieldId = field.fieldState.fieldId
const fieldElement = document.getElementById(fieldId)
- fieldElement.focus({ preventScroll: true })
+ if (fieldElement) {
+ fieldElement.focus({ preventScroll: true })
+ }
const label = document.querySelector(`label[for="${fieldId}"]`)
- label.style.scrollMargin = "100px"
- label.scrollIntoView({ behavior: "smooth", block: "nearest" })
+ if (label) {
+ label.style.scrollMargin = "100px"
+ label.scrollIntoView({ behavior: "smooth", block: "nearest" })
+ }
}
// Action context to pass to children
diff --git a/packages/client/src/components/preview/HoverIndicator.svelte b/packages/client/src/components/preview/HoverIndicator.svelte
index ddef62ab74..164ec32ab4 100644
--- a/packages/client/src/components/preview/HoverIndicator.svelte
+++ b/packages/client/src/components/preview/HoverIndicator.svelte
@@ -1,9 +1,9 @@
+
+
+
+
+ {#if !timedOut}
+ Please wait and we will be back in a second!
+ {:else}
+ An error occurred, please try again later.
+
+ Contact
+ support if the
+ issue persists.
+ {/if}
+
+
+
diff --git a/packages/frontend-core/src/components/index.js b/packages/frontend-core/src/components/index.js
index 01a7c78cb8..f724e1e4d9 100644
--- a/packages/frontend-core/src/components/index.js
+++ b/packages/frontend-core/src/components/index.js
@@ -3,4 +3,5 @@ export { default as TestimonialPage } from "./TestimonialPage.svelte"
export { default as Testimonial } from "./Testimonial.svelte"
export { default as UserAvatar } from "./UserAvatar.svelte"
export { default as UserAvatars } from "./UserAvatars.svelte"
+export { default as Updating } from "./Updating.svelte"
export { Grid } from "./grid"
diff --git a/packages/frontend-core/src/utils/utils.js b/packages/frontend-core/src/utils/utils.js
index 93884c719f..65690cd535 100644
--- a/packages/frontend-core/src/utils/utils.js
+++ b/packages/frontend-core/src/utils/utils.js
@@ -116,7 +116,7 @@ export const domDebounce = callback => {
*
* @param {any} props
* */
-export const buildDynamicButtonConfig = props => {
+export const buildFormBlockButtonConfig = props => {
const {
_id,
actionType,
@@ -130,7 +130,6 @@ export const buildDynamicButtonConfig = props => {
} = props || {}
if (!_id) {
- console.log("MISSING ID")
return
}
const formId = `${_id}-form`
@@ -228,7 +227,7 @@ export const buildDynamicButtonConfig = props => {
})
}
- if (actionType == "Update" && showDeleteButton !== false) {
+ if (actionType === "Update" && showDeleteButton !== false) {
defaultButtons.push({
text: deleteText || "Delete",
_id: Helpers.uuid(),
@@ -241,3 +240,108 @@ export const buildDynamicButtonConfig = props => {
return defaultButtons
}
+
+export const buildMultiStepFormBlockDefaultProps = props => {
+ const { _id, stepCount, currentStep, actionType, dataSource } = props || {}
+
+ // Sanity check
+ if (!_id || !stepCount) {
+ return
+ }
+
+ const title = `Step {{ [${_id}-form].[__currentStep] }}`
+ const resourceId = dataSource?.resourceId
+ const formId = `${_id}-form`
+ let buttons = []
+
+ // Add previous step button if we aren't the first step
+ if (currentStep !== 0) {
+ buttons.push({
+ _id: Helpers.uuid(),
+ _component: "@budibase/standard-components/button",
+ _instanceName: Helpers.uuid(),
+ text: "Back",
+ type: "secondary",
+ size: "M",
+ onClick: [
+ {
+ parameters: {
+ type: "prev",
+ componentId: formId,
+ },
+ "##eventHandlerType": "Change Form Step",
+ },
+ ],
+ })
+ }
+
+ // Add a next button if we aren't the last step
+ if (currentStep !== stepCount - 1) {
+ buttons.push({
+ _id: Helpers.uuid(),
+ _component: "@budibase/standard-components/button",
+ _instanceName: Helpers.uuid(),
+ text: "Next",
+ type: "cta",
+ size: "M",
+ onClick: [
+ {
+ "##eventHandlerType": "Validate Form",
+ parameters: {
+ componentId: formId,
+ },
+ },
+ {
+ parameters: {
+ type: "next",
+ componentId: formId,
+ },
+ "##eventHandlerType": "Change Form Step",
+ },
+ ],
+ })
+ }
+
+ // Add save button if we are the last step
+ if (actionType !== "View" && currentStep === stepCount - 1) {
+ buttons.push({
+ _id: Helpers.uuid(),
+ _component: "@budibase/standard-components/button",
+ _instanceName: Helpers.uuid(),
+ text: "Save",
+ type: "cta",
+ size: "M",
+ onClick: [
+ {
+ "##eventHandlerType": "Validate Form",
+ parameters: {
+ componentId: formId,
+ },
+ },
+ {
+ "##eventHandlerType": "Save Row",
+ parameters: {
+ tableId: resourceId,
+ providerId: formId,
+ },
+ },
+ // Clear a create form once submitted
+ ...(actionType !== "Create"
+ ? []
+ : [
+ {
+ "##eventHandlerType": "Clear Form",
+ parameters: {
+ componentId: formId,
+ },
+ },
+ ]),
+ ],
+ })
+ }
+
+ return {
+ buttons,
+ title,
+ }
+}
diff --git a/packages/pro b/packages/pro
index 82de3443fd..a838419616 160000
--- a/packages/pro
+++ b/packages/pro
@@ -1 +1 @@
-Subproject commit 82de3443fd03b272555d23c42ead3a611302277d
+Subproject commit a838419616a35923cef029f5264e71e3dbd22a55
diff --git a/packages/server/nodemon.json b/packages/server/nodemon.json
index 33d277dd64..5535e0772e 100644
--- a/packages/server/nodemon.json
+++ b/packages/server/nodemon.json
@@ -7,7 +7,7 @@
"../shared-core",
"../string-templates"
],
- "ext": "js,ts,json",
+ "ext": "js,ts,json,svelte",
"ignore": ["src/**/*.spec.ts", "src/**/*.spec.js", "../*/dist/**/*"],
"exec": "yarn build && node ./dist/index.js"
}
diff --git a/packages/server/package.json b/packages/server/package.json
index 1e07623f49..e677d0ba51 100644
--- a/packages/server/package.json
+++ b/packages/server/package.json
@@ -80,7 +80,7 @@
"koa": "2.13.4",
"koa-body": "4.2.0",
"koa-compress": "4.0.1",
- "koa-send": "5.0.0",
+ "koa-send": "5.0.1",
"koa-useragent": "^4.1.0",
"koa2-ratelimit": "1.1.1",
"lodash": "4.17.21",
@@ -120,6 +120,7 @@
"@types/jest": "29.5.5",
"@types/koa": "2.13.4",
"@types/koa__router": "8.0.8",
+ "@types/koa-send": "^4.1.6",
"@types/lodash": "4.14.200",
"@types/mssql": "9.1.4",
"@types/node-fetch": "2.6.4",
diff --git a/packages/server/src/api/controllers/datasource.ts b/packages/server/src/api/controllers/datasource.ts
index 0a7430aa94..a702a8cd84 100644
--- a/packages/server/src/api/controllers/datasource.ts
+++ b/packages/server/src/api/controllers/datasource.ts
@@ -1,23 +1,17 @@
-import {
- DocumentType,
- generateDatasourceID,
- getQueryParams,
- getTableParams,
-} from "../../db/utils"
+import { getQueryParams, getTableParams } from "../../db/utils"
import { getIntegration } from "../../integrations"
import { invalidateDynamicVariables } from "../../threads/utils"
import { context, db as dbCore, events } from "@budibase/backend-core"
import {
+ BuildSchemaFromSourceRequest,
+ BuildSchemaFromSourceResponse,
CreateDatasourceRequest,
CreateDatasourceResponse,
Datasource,
DatasourcePlus,
FetchDatasourceInfoRequest,
FetchDatasourceInfoResponse,
- IntegrationBase,
- Schema,
SourceName,
- Table,
UpdateDatasourceResponse,
UserCtx,
VerifyDatasourceRequest,
@@ -25,68 +19,8 @@ import {
} from "@budibase/types"
import sdk from "../../sdk"
import { builderSocket } from "../../websockets"
-import { setupCreationAuth as googleSetupCreationAuth } from "../../integrations/googlesheets"
import { isEqual } from "lodash"
-async function getConnector(
- datasource: Datasource
-): Promise {
- const Connector = await getIntegration(datasource.source)
- // can't enrich if it doesn't have an ID yet
- if (datasource._id) {
- datasource = await sdk.datasources.enrich(datasource)
- }
- // Connect to the DB and build the schema
- return new Connector(datasource.config)
-}
-
-async function getAndMergeDatasource(datasource: Datasource) {
- let existingDatasource: undefined | Datasource
- if (datasource._id) {
- existingDatasource = await sdk.datasources.get(datasource._id)
- }
- let enrichedDatasource = datasource
- if (existingDatasource) {
- enrichedDatasource = sdk.datasources.mergeConfigs(
- datasource,
- existingDatasource
- )
- }
- return await sdk.datasources.enrich(enrichedDatasource)
-}
-
-async function buildSchemaHelper(datasource: Datasource): Promise {
- const connector = (await getConnector(datasource)) as DatasourcePlus
- return await connector.buildSchema(
- datasource._id!,
- datasource.entities! as Record
- )
-}
-
-async function buildFilteredSchema(
- datasource: Datasource,
- filter?: string[]
-): Promise {
- let schema = await buildSchemaHelper(datasource)
- if (!filter) {
- return schema
- }
-
- let filteredSchema: Schema = { tables: {}, errors: {} }
- for (let key in schema.tables) {
- if (filter.some(filter => filter.toLowerCase() === key.toLowerCase())) {
- filteredSchema.tables[key] = schema.tables[key]
- }
- }
-
- for (let key in schema.errors) {
- if (filter.some(filter => filter.toLowerCase() === key.toLowerCase())) {
- filteredSchema.errors[key] = schema.errors[key]
- }
- }
- return filteredSchema
-}
-
export async function fetch(ctx: UserCtx) {
ctx.body = await sdk.datasources.fetch()
}
@@ -95,8 +29,10 @@ export async function verify(
ctx: UserCtx
) {
const { datasource } = ctx.request.body
- const enrichedDatasource = await getAndMergeDatasource(datasource)
- const connector = await getConnector(enrichedDatasource)
+ const enrichedDatasource = await sdk.datasources.getAndMergeDatasource(
+ datasource
+ )
+ const connector = await sdk.datasources.getConnector(enrichedDatasource)
if (!connector.testConnection) {
ctx.throw(400, "Connection information verification not supported")
}
@@ -112,8 +48,12 @@ export async function information(
ctx: UserCtx
) {
const { datasource } = ctx.request.body
- const enrichedDatasource = await getAndMergeDatasource(datasource)
- const connector = (await getConnector(enrichedDatasource)) as DatasourcePlus
+ const enrichedDatasource = await sdk.datasources.getAndMergeDatasource(
+ datasource
+ )
+ const connector = (await sdk.datasources.getConnector(
+ enrichedDatasource
+ )) as DatasourcePlus
if (!connector.getTableNames) {
ctx.throw(400, "Table name fetching not supported by datasource")
}
@@ -123,19 +63,16 @@ export async function information(
}
}
-export async function buildSchemaFromDb(ctx: UserCtx) {
- const db = context.getAppDB()
+export async function buildSchemaFromSource(
+ ctx: UserCtx
+) {
+ const datasourceId = ctx.params.datasourceId
const tablesFilter = ctx.request.body.tablesFilter
- const datasource = await sdk.datasources.get(ctx.params.datasourceId)
- const { tables, errors } = await buildFilteredSchema(datasource, tablesFilter)
- datasource.entities = tables
-
- setDefaultDisplayColumns(datasource)
- const dbResp = await db.put(
- sdk.tables.populateExternalTableSchemas(datasource)
+ const { datasource, errors } = await sdk.datasources.buildSchemaFromSource(
+ datasourceId,
+ tablesFilter
)
- datasource._rev = dbResp.rev
ctx.body = {
datasource: await sdk.datasources.removeSecretSingle(datasource),
@@ -143,24 +80,6 @@ export async function buildSchemaFromDb(ctx: UserCtx) {
}
}
-/**
- * Make sure all datasource entities have a display name selected
- */
-function setDefaultDisplayColumns(datasource: Datasource) {
- //
- for (let entity of Object.values(datasource.entities || {})) {
- if (entity.primaryDisplay) {
- continue
- }
- const notAutoColumn = Object.values(entity.schema).find(
- schema => !schema.autocolumn
- )
- if (notAutoColumn) {
- entity.primaryDisplay = notAutoColumn.name
- }
- }
-}
-
/**
* Check for variables that have been updated or removed and invalidate them.
*/
@@ -258,51 +177,18 @@ export async function update(ctx: UserCtx) {
}
}
-const preSaveAction: Partial> = {
- [SourceName.GOOGLE_SHEETS]: async (datasource: Datasource) => {
- await googleSetupCreationAuth(datasource.config as any)
- },
-}
-
export async function save(
ctx: UserCtx
) {
- const db = context.getAppDB()
- const plus = ctx.request.body.datasource.plus
- const fetchSchema = ctx.request.body.fetchSchema
- const tablesFilter = ctx.request.body.tablesFilter
-
- const datasource = {
- _id: generateDatasourceID({ plus }),
- ...ctx.request.body.datasource,
- type: plus ? DocumentType.DATASOURCE_PLUS : DocumentType.DATASOURCE,
- }
-
- let errors: Record = {}
- if (fetchSchema) {
- const schema = await buildFilteredSchema(datasource, tablesFilter)
- datasource.entities = schema.tables
- setDefaultDisplayColumns(datasource)
- errors = schema.errors
- }
-
- if (preSaveAction[datasource.source]) {
- await preSaveAction[datasource.source](datasource)
- }
-
- const dbResp = await db.put(
- sdk.tables.populateExternalTableSchemas(datasource)
- )
- await events.datasource.created(datasource)
- datasource._rev = dbResp.rev
-
- // Drain connection pools when configuration is changed
- if (datasource.source) {
- const source = await getIntegration(datasource.source)
- if (source && source.pool) {
- await source.pool.end()
- }
- }
+ const {
+ datasource: datasourceData,
+ fetchSchema,
+ tablesFilter,
+ } = ctx.request.body
+ const { datasource, errors } = await sdk.datasources.save(datasourceData, {
+ fetchSchema,
+ tablesFilter,
+ })
ctx.body = {
datasource: await sdk.datasources.removeSecretSingle(datasource),
@@ -384,8 +270,10 @@ export async function query(ctx: UserCtx) {
export async function getExternalSchema(ctx: UserCtx) {
const datasource = await sdk.datasources.get(ctx.params.datasourceId)
- const enrichedDatasource = await getAndMergeDatasource(datasource)
- const connector = await getConnector(enrichedDatasource)
+ const enrichedDatasource = await sdk.datasources.getAndMergeDatasource(
+ datasource
+ )
+ const connector = await sdk.datasources.getConnector(enrichedDatasource)
if (!connector.getExternalSchema) {
ctx.throw(400, "Datasource does not support exporting external schema")
diff --git a/packages/server/src/api/controllers/query/index.ts b/packages/server/src/api/controllers/query/index.ts
index 4d307e9593..2aa5526c30 100644
--- a/packages/server/src/api/controllers/query/index.ts
+++ b/packages/server/src/api/controllers/query/index.ts
@@ -161,11 +161,8 @@ export async function preview(ctx: UserCtx) {
auth: { ...authConfigCtx },
},
}
- const runFn = () => Runner.run(inputs)
- const { rows, keys, info, extra } = await quotas.addQuery(runFn, {
- datasourceId: datasource._id,
- })
+ const { rows, keys, info, extra } = (await Runner.run(inputs)) as any
const schemaFields: any = {}
if (rows?.length > 0) {
for (let key of [...new Set(keys)] as string[]) {
@@ -259,14 +256,8 @@ async function execute(
},
schema: query.schema,
}
- const runFn = () => Runner.run(inputs)
- const { rows, pagination, extra, info } = await quotas.addQuery(
- runFn,
- {
- datasourceId: datasource._id,
- }
- )
+ const { rows, pagination, extra, info } = (await Runner.run(inputs)) as any
// remove the raw from execution incase transformer being used to hide data
if (extra?.raw) {
delete extra.raw
diff --git a/packages/server/src/api/controllers/row/index.ts b/packages/server/src/api/controllers/row/index.ts
index 7ff8d83e71..1ad8a2a695 100644
--- a/packages/server/src/api/controllers/row/index.ts
+++ b/packages/server/src/api/controllers/row/index.ts
@@ -4,20 +4,20 @@ import * as external from "./external"
import { isExternalTableID } from "../../../integrations/utils"
import {
Ctx,
- UserCtx,
- DeleteRowRequest,
DeleteRow,
+ DeleteRowRequest,
DeleteRows,
- Row,
- PatchRowRequest,
- PatchRowResponse,
- SearchRowResponse,
- SearchRowRequest,
- SearchParams,
- GetRowResponse,
- ValidateResponse,
ExportRowsRequest,
ExportRowsResponse,
+ GetRowResponse,
+ PatchRowRequest,
+ PatchRowResponse,
+ Row,
+ SearchParams,
+ SearchRowRequest,
+ SearchRowResponse,
+ UserCtx,
+ ValidateResponse,
} from "@budibase/types"
import * as utils from "./utils"
import { gridSocket } from "../../../websockets"
@@ -25,8 +25,8 @@ import { addRev } from "../public/utils"
import { fixRow } from "../public/rows"
import sdk from "../../../sdk"
import * as exporters from "../view/exporters"
-import { apiFileReturn } from "../../../utilities/fileSystem"
import { Format } from "../view/exporters"
+import { apiFileReturn } from "../../../utilities/fileSystem"
export * as views from "./views"
@@ -49,12 +49,7 @@ export async function patch(
return save(ctx)
}
try {
- const { row, table } = await quotas.addQuery(
- () => pickApi(tableId).patch(ctx),
- {
- datasourceId: tableId,
- }
- )
+ const { row, table } = await pickApi(tableId).patch(ctx)
if (!row) {
ctx.throw(404, "Row not found")
}
@@ -84,12 +79,7 @@ export const save = async (ctx: UserCtx) => {
return patch(ctx as UserCtx)
}
const { row, table, squashed } = await quotas.addRow(() =>
- quotas.addQuery(
- () => sdk.rows.save(tableId, ctx.request.body, ctx.user?._id),
- {
- datasourceId: tableId,
- }
- )
+ sdk.rows.save(tableId, ctx.request.body, ctx.user?._id)
)
ctx.status = 200
ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:save`, appId, row, table)
@@ -105,31 +95,21 @@ export async function fetchView(ctx: any) {
const { calculation, group, field } = ctx.query
- ctx.body = await quotas.addQuery(
- () =>
- sdk.rows.fetchView(tableId, viewName, {
- calculation,
- group: calculation ? group : null,
- field,
- }),
- {
- datasourceId: tableId,
- }
- )
+ ctx.body = await sdk.rows.fetchView(tableId, viewName, {
+ calculation,
+ group: calculation ? group : null,
+ field,
+ })
}
export async function fetch(ctx: any) {
const tableId = utils.getTableId(ctx)
- ctx.body = await quotas.addQuery(() => sdk.rows.fetch(tableId), {
- datasourceId: tableId,
- })
+ ctx.body = await sdk.rows.fetch(tableId)
}
export async function find(ctx: UserCtx) {
const tableId = utils.getTableId(ctx)
- ctx.body = await quotas.addQuery(() => pickApi(tableId).find(ctx), {
- datasourceId: tableId,
- })
+ ctx.body = await pickApi(tableId).find(ctx)
}
function isDeleteRows(input: any): input is DeleteRows {
@@ -160,15 +140,9 @@ async function deleteRows(ctx: UserCtx) {
let deleteRequest = ctx.request.body as DeleteRows
- const rowDeletes: Row[] = await processDeleteRowsRequest(ctx)
- deleteRequest.rows = rowDeletes
+ deleteRequest.rows = await processDeleteRowsRequest(ctx)
- const { rows } = await quotas.addQuery(
- () => pickApi(tableId).bulkDestroy(ctx),
- {
- datasourceId: tableId,
- }
- )
+ const { rows } = await pickApi(tableId).bulkDestroy(ctx)
await quotas.removeRows(rows.length)
for (let row of rows) {
@@ -183,9 +157,7 @@ async function deleteRow(ctx: UserCtx) {
const appId = ctx.appId
const tableId = utils.getTableId(ctx)
- const resp = await quotas.addQuery(() => pickApi(tableId).destroy(ctx), {
- datasourceId: tableId,
- })
+ const resp = await pickApi(tableId).destroy(ctx)
await quotas.removeRow()
ctx.eventEmitter && ctx.eventEmitter.emitRow(`row:delete`, appId, resp.row)
@@ -223,9 +195,7 @@ export async function search(ctx: Ctx) {
}
ctx.status = 200
- ctx.body = await quotas.addQuery(() => sdk.rows.search(searchParams), {
- datasourceId: tableId,
- })
+ ctx.body = await sdk.rows.search(searchParams)
}
export async function validate(ctx: Ctx) {
@@ -243,12 +213,7 @@ export async function validate(ctx: Ctx) {
export async function fetchEnrichedRow(ctx: any) {
const tableId = utils.getTableId(ctx)
- ctx.body = await quotas.addQuery(
- () => pickApi(tableId).fetchEnrichedRow(ctx),
- {
- datasourceId: tableId,
- }
- )
+ ctx.body = await pickApi(tableId).fetchEnrichedRow(ctx)
}
export const exportRows = async (
@@ -268,22 +233,15 @@ export const exportRows = async (
)
}
- ctx.body = await quotas.addQuery(
- async () => {
- const { fileName, content } = await sdk.rows.exportRows({
- tableId,
- format: format as Format,
- rowIds: rows,
- columns,
- query,
- sort,
- sortOrder,
- })
- ctx.attachment(fileName)
- return apiFileReturn(content)
- },
- {
- datasourceId: tableId,
- }
- )
+ const { fileName, content } = await sdk.rows.exportRows({
+ tableId,
+ format: format as Format,
+ rowIds: rows,
+ columns,
+ query,
+ sort,
+ sortOrder,
+ })
+ ctx.attachment(fileName)
+ ctx.body = apiFileReturn(content)
}
diff --git a/packages/server/src/api/controllers/row/views.ts b/packages/server/src/api/controllers/row/views.ts
index 36a0b588b6..188fe86f17 100644
--- a/packages/server/src/api/controllers/row/views.ts
+++ b/packages/server/src/api/controllers/row/views.ts
@@ -68,10 +68,7 @@ export async function searchView(
paginate: body.paginate,
}
- const result = await quotas.addQuery(() => sdk.rows.search(searchOptions), {
- datasourceId: view.tableId,
- })
-
+ const result = await sdk.rows.search(searchOptions)
result.rows.forEach(r => (r._viewId = view.id))
ctx.body = result
}
diff --git a/packages/server/src/api/controllers/static/index.ts b/packages/server/src/api/controllers/static/index.ts
index 2963546e7f..5f383e837d 100644
--- a/packages/server/src/api/controllers/static/index.ts
+++ b/packages/server/src/api/controllers/static/index.ts
@@ -25,8 +25,12 @@ import fs from "fs"
import sdk from "../../../sdk"
import * as pro from "@budibase/pro"
import { App, Ctx, ProcessAttachmentResponse } from "@budibase/types"
+import {
+ getAppMigrationVersion,
+ getLatestMigrationId,
+} from "../../../appMigrations"
-const send = require("koa-send")
+import send from "koa-send"
export const toggleBetaUiFeature = async function (ctx: Ctx) {
const cookieName = `beta:${ctx.params.feature}`
@@ -125,7 +129,26 @@ export const deleteObjects = async function (ctx: Ctx) {
)
}
+const requiresMigration = async (ctx: Ctx) => {
+ const appId = context.getAppId()
+ if (!appId) {
+ ctx.throw("AppId could not be found")
+ }
+
+ const latestMigration = getLatestMigrationId()
+ if (!latestMigration) {
+ return false
+ }
+
+ const latestMigrationApplied = await getAppMigrationVersion(appId)
+
+ const requiresMigrations = latestMigrationApplied !== latestMigration
+ return requiresMigrations
+}
+
export const serveApp = async function (ctx: Ctx) {
+ const needMigrations = await requiresMigration(ctx)
+
const bbHeaderEmbed =
ctx.request.get("x-budibase-embed")?.toLowerCase() === "true"
@@ -145,8 +168,8 @@ export const serveApp = async function (ctx: Ctx) {
let appId = context.getAppId()
if (!env.isJest()) {
- const App = require("./templates/BudibaseApp.svelte").default
const plugins = objectStore.enrichPluginURLs(appInfo.usedPlugins)
+ const App = require("./templates/BudibaseApp.svelte").default
const { head, html, css } = App.render({
metaImage:
branding?.metaImageUrl ||
@@ -167,6 +190,7 @@ export const serveApp = async function (ctx: Ctx) {
config?.logoUrl !== ""
? objectStore.getGlobalFileUrl("settings", "logoUrl")
: "",
+ appMigrating: needMigrations,
})
const appHbs = loadHandlebarsFile(appHbsPath)
ctx.body = await processString(appHbs, {
@@ -273,7 +297,6 @@ export const getSignedUploadURL = async function (ctx: Ctx) {
const { bucket, key } = ctx.request.body || {}
if (!bucket || !key) {
ctx.throw(400, "bucket and key values are required")
- return
}
try {
const s3 = new AWS.S3({
diff --git a/packages/server/src/api/controllers/static/templates/BudibaseApp.svelte b/packages/server/src/api/controllers/static/templates/BudibaseApp.svelte
index 32edb6dc7b..7819368fc0 100644
--- a/packages/server/src/api/controllers/static/templates/BudibaseApp.svelte
+++ b/packages/server/src/api/controllers/static/templates/BudibaseApp.svelte
@@ -8,6 +8,7 @@
export let clientLibPath
export let usedPlugins
+ export let appMigrating
@@ -110,6 +111,11 @@
+ {#if appMigrating}
+
+ {/if}
diff --git a/packages/server/src/api/controllers/static/templates/preview.hbs b/packages/server/src/api/controllers/static/templates/preview.hbs
index e5b97afd66..63c61baa9f 100644
--- a/packages/server/src/api/controllers/static/templates/preview.hbs
+++ b/packages/server/src/api/controllers/static/templates/preview.hbs
@@ -63,7 +63,6 @@
// Extract data from message
const {
selectedComponentId,
- hoverComponentId,
layout,
screen,
appId,
@@ -82,7 +81,6 @@
window["##BUDIBASE_PREVIEW_LAYOUT##"] = layout
window["##BUDIBASE_PREVIEW_SCREEN##"] = screen
window["##BUDIBASE_SELECTED_COMPONENT_ID##"] = selectedComponentId
- window["##BUDIBASE_HOVER_COMPONENT_ID##"] = hoverComponentId
window["##BUDIBASE_PREVIEW_ID##"] = Math.random()
window["##BUDIBASE_PREVIEW_THEME##"] = theme
window["##BUDIBASE_PREVIEW_CUSTOM_THEME##"] = customTheme
diff --git a/packages/server/src/api/routes/datasource.ts b/packages/server/src/api/routes/datasource.ts
index 7b4945806a..755088c56c 100644
--- a/packages/server/src/api/routes/datasource.ts
+++ b/packages/server/src/api/routes/datasource.ts
@@ -53,7 +53,7 @@ router
.post(
"/api/datasources/:datasourceId/schema",
authorized(permissions.BUILDER),
- datasourceController.buildSchemaFromDb
+ datasourceController.buildSchemaFromSource
)
.post(
"/api/datasources",
diff --git a/packages/server/src/api/routes/tests/row.spec.ts b/packages/server/src/api/routes/tests/row.spec.ts
index 2d47e5f54a..5b39652976 100644
--- a/packages/server/src/api/routes/tests/row.spec.ts
+++ b/packages/server/src/api/routes/tests/row.spec.ts
@@ -132,11 +132,6 @@ describe.each([
expect(usage).toBe(expected)
}
- const assertQueryUsage = async (expected: number) => {
- const usage = await getQueryUsage()
- expect(usage).toBe(expected)
- }
-
const defaultRowFields = isInternal
? {
type: "row",
@@ -181,7 +176,6 @@ describe.each([
expect(res.body.name).toEqual("Test Contact")
expect(res.body._rev).toBeDefined()
await assertRowUsage(rowUsage + 1)
- await assertQueryUsage(queryUsage + 1)
})
it("Increment row autoId per create row request", async () => {
@@ -232,7 +226,6 @@ describe.each([
}
await assertRowUsage(rowUsage + ids.length)
- await assertQueryUsage(queryUsage + ids.length)
})
it("updates a row successfully", async () => {
@@ -249,7 +242,6 @@ describe.each([
expect(res.name).toEqual("Updated Name")
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage + 1)
})
it("should load a row", async () => {
@@ -262,7 +254,6 @@ describe.each([
...existing,
...defaultRowFields,
})
- await assertQueryUsage(queryUsage + 1)
})
it("should list all rows for given tableId", async () => {
@@ -284,7 +275,6 @@ describe.each([
expect(res.length).toBe(2)
expect(res.find((r: Row) => r.name === newRow.name)).toBeDefined()
expect(res.find((r: Row) => r.name === firstRow.name)).toBeDefined()
- await assertQueryUsage(queryUsage + 1)
})
it("load should return 404 when row does not exist", async () => {
@@ -294,7 +284,6 @@ describe.each([
await config.api.row.get(tableId, "1234567", {
expectStatus: 404,
})
- await assertQueryUsage(queryUsage) // no change
})
isInternal &&
@@ -558,7 +547,6 @@ describe.each([
expect(savedRow.body.description).toEqual(existing.description)
expect(savedRow.body.name).toEqual("Updated Name")
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage + 2) // account for the second load
})
it("should throw an error when given improper types", async () => {
@@ -578,7 +566,6 @@ describe.each([
)
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage)
})
it("should not overwrite links if those links are not set", async () => {
@@ -668,7 +655,6 @@ describe.each([
const res = await config.api.row.delete(table._id!, [createdRow])
expect(res.body[0]._id).toEqual(createdRow._id)
await assertRowUsage(rowUsage - 1)
- await assertQueryUsage(queryUsage + 1)
})
})
@@ -687,7 +673,6 @@ describe.each([
expect(res.valid).toBe(true)
expect(Object.keys(res.errors)).toEqual([])
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage)
})
it("should errors on invalid row", async () => {
@@ -705,7 +690,6 @@ describe.each([
expect(Object.keys(res.errors)).toEqual([])
}
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage)
})
})
@@ -726,7 +710,6 @@ describe.each([
expect(res.body.length).toEqual(2)
await loadRow(row1._id!, table._id!, 404)
await assertRowUsage(rowUsage - 2)
- await assertQueryUsage(queryUsage + 1)
})
it("should be able to delete a variety of row set types", async () => {
@@ -747,7 +730,6 @@ describe.each([
expect(res.body.length).toEqual(3)
await loadRow(row1._id!, table._id!, 404)
await assertRowUsage(rowUsage - 3)
- await assertQueryUsage(queryUsage + 1)
})
it("should accept a valid row object and delete the row", async () => {
@@ -760,7 +742,6 @@ describe.each([
expect(res.body.id).toEqual(row1._id)
await loadRow(row1._id!, table._id!, 404)
await assertRowUsage(rowUsage - 1)
- await assertQueryUsage(queryUsage + 1)
})
it("Should ignore malformed/invalid delete requests", async () => {
@@ -787,7 +768,6 @@ describe.each([
expect(res3.body.message).toEqual("Invalid delete rows request")
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage)
})
})
@@ -808,7 +788,6 @@ describe.each([
expect(res.body.length).toEqual(1)
expect(res.body[0]._id).toEqual(row._id)
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage + 1)
})
it("should throw an error if view doesn't exist", async () => {
@@ -818,7 +797,6 @@ describe.each([
await config.api.legacyView.get("derp", { expectStatus: 404 })
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage)
})
it("should be able to run on a view", async () => {
@@ -837,7 +815,6 @@ describe.each([
expect(res.body[0]._id).toEqual(row._id)
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage + 1)
})
})
@@ -910,7 +887,6 @@ describe.each([
expect(resEnriched.body.link[0].name).toBe("Test Contact")
expect(resEnriched.body.link[0].description).toBe("original description")
await assertRowUsage(rowUsage)
- await assertQueryUsage(queryUsage + 2)
})
})
@@ -1129,7 +1105,6 @@ describe.each([
await config.api.row.delete(view.id, [createdRow])
await assertRowUsage(rowUsage - 1)
- await assertQueryUsage(queryUsage + 1)
await config.api.row.get(tableId, createdRow._id!, {
expectStatus: 404,
@@ -1157,7 +1132,6 @@ describe.each([
await config.api.row.delete(view.id, [rows[0], rows[2]])
await assertRowUsage(rowUsage - 2)
- await assertQueryUsage(queryUsage + 1)
await config.api.row.get(tableId, rows[0]._id!, {
expectStatus: 404,
diff --git a/packages/server/src/appMigrations/index.ts b/packages/server/src/appMigrations/index.ts
index b382d8b533..0758b9f324 100644
--- a/packages/server/src/appMigrations/index.ts
+++ b/packages/server/src/appMigrations/index.ts
@@ -17,7 +17,7 @@ export const getLatestMigrationId = () =>
.sort()
.reverse()[0]
-const getTimestamp = (versionId: string) => versionId?.split("_")[0]
+const getTimestamp = (versionId: string) => versionId?.split("_")[0] || ""
export async function checkMissingMigrations(
ctx: UserCtx,
diff --git a/packages/server/src/automations/steps/queryRows.ts b/packages/server/src/automations/steps/queryRows.ts
index e0680017e7..cde2d8fd5d 100644
--- a/packages/server/src/automations/steps/queryRows.ts
+++ b/packages/server/src/automations/steps/queryRows.ts
@@ -103,8 +103,7 @@ function typeCoercion(filters: SearchFilters, table: Table) {
return filters
}
for (let key of Object.keys(filters)) {
- // @ts-ignore
- const searchParam = filters[key]
+ const searchParam = filters[key as keyof SearchFilters]
if (typeof searchParam === "object") {
for (let [property, value] of Object.entries(searchParam)) {
// We need to strip numerical prefixes here, so that we can look up
@@ -117,7 +116,13 @@ function typeCoercion(filters: SearchFilters, table: Table) {
continue
}
if (column.type === FieldTypes.NUMBER) {
- searchParam[property] = parseFloat(value)
+ if (key === "oneOf") {
+ searchParam[property] = value
+ .split(",")
+ .map(item => parseFloat(item))
+ } else {
+ searchParam[property] = parseFloat(value)
+ }
}
}
}
diff --git a/packages/server/src/ddApm.ts b/packages/server/src/ddApm.ts
index 6c9b8aa289..f0f3ec6055 100644
--- a/packages/server/src/ddApm.ts
+++ b/packages/server/src/ddApm.ts
@@ -3,5 +3,9 @@ import apm from "dd-trace"
// enable APM if configured
if (process.env.DD_APM_ENABLED) {
console.log("Starting dd-trace")
- apm.init()
+ apm.init({
+ // @ts-ignore for some reason dd-trace types don't include this options,
+ // even though it's spoken about in the docs.
+ debug: process.env.DD_ENV === "qa",
+ })
}
diff --git a/packages/server/src/integration-test/postgres.spec.ts b/packages/server/src/integration-test/postgres.spec.ts
index 67e4fee81c..600566c813 100644
--- a/packages/server/src/integration-test/postgres.spec.ts
+++ b/packages/server/src/integration-test/postgres.spec.ts
@@ -1118,4 +1118,76 @@ describe("postgres integrations", () => {
})
})
})
+
+ describe("Integration compatibility with postgres search_path", () => {
+ let client: Client, pathDatasource: Datasource
+ const schema1 = "test1",
+ schema2 = "test-2"
+
+ beforeAll(async () => {
+ const dsConfig = await databaseTestProviders.postgres.getDsConfig()
+ const dbConfig = dsConfig.config!
+
+ client = new Client(dbConfig)
+ await client.connect()
+ await client.query(`CREATE SCHEMA "${schema1}";`)
+ await client.query(`CREATE SCHEMA "${schema2}";`)
+
+ const pathConfig: any = {
+ ...dsConfig,
+ config: {
+ ...dbConfig,
+ schema: `${schema1}, ${schema2}`,
+ },
+ }
+ pathDatasource = await config.api.datasource.create(pathConfig)
+ })
+
+ afterAll(async () => {
+ await client.query(`DROP SCHEMA "${schema1}" CASCADE;`)
+ await client.query(`DROP SCHEMA "${schema2}" CASCADE;`)
+ await client.end()
+ })
+
+ it("discovers tables from any schema in search path", async () => {
+ await client.query(
+ `CREATE TABLE "${schema1}".table1 (id1 SERIAL PRIMARY KEY);`
+ )
+ await client.query(
+ `CREATE TABLE "${schema2}".table2 (id2 SERIAL PRIMARY KEY);`
+ )
+ const response = await makeRequest("post", "/api/datasources/info", {
+ datasource: pathDatasource,
+ })
+ expect(response.status).toBe(200)
+ expect(response.body.tableNames).toBeDefined()
+ expect(response.body.tableNames).toEqual(
+ expect.arrayContaining(["table1", "table2"])
+ )
+ })
+
+ it("does not mix columns from different tables", async () => {
+ const repeated_table_name = "table_same_name"
+ await client.query(
+ `CREATE TABLE "${schema1}".${repeated_table_name} (id SERIAL PRIMARY KEY, val1 TEXT);`
+ )
+ await client.query(
+ `CREATE TABLE "${schema2}".${repeated_table_name} (id2 SERIAL PRIMARY KEY, val2 TEXT);`
+ )
+ const response = await makeRequest(
+ "post",
+ `/api/datasources/${pathDatasource._id}/schema`,
+ {
+ tablesFilter: [repeated_table_name],
+ }
+ )
+ expect(response.status).toBe(200)
+ expect(
+ response.body.datasource.entities[repeated_table_name].schema
+ ).toBeDefined()
+ const schema =
+ response.body.datasource.entities[repeated_table_name].schema
+ expect(Object.keys(schema).sort()).toEqual(["id", "val1"])
+ })
+ })
})
diff --git a/packages/server/src/integrations/postgres.ts b/packages/server/src/integrations/postgres.ts
index de3bf0e59e..78955c06dc 100644
--- a/packages/server/src/integrations/postgres.ts
+++ b/packages/server/src/integrations/postgres.ts
@@ -149,8 +149,6 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
private index: number = 1
private open: boolean
- COLUMNS_SQL!: string
-
PRIMARY_KEYS_SQL = () => `
SELECT pg_namespace.nspname table_schema
, pg_class.relname table_name
@@ -159,7 +157,8 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
JOIN pg_index ON pg_class.oid = pg_index.indrelid AND pg_index.indisprimary
JOIN pg_attribute ON pg_attribute.attrelid = pg_class.oid AND pg_attribute.attnum = ANY(pg_index.indkey)
JOIN pg_namespace ON pg_namespace.oid = pg_class.relnamespace
- WHERE pg_namespace.nspname = '${this.config.schema}';
+ WHERE pg_namespace.nspname = ANY(current_schemas(false))
+ AND pg_table_is_visible(pg_class.oid);
`
ENUM_VALUES = () => `
@@ -170,6 +169,11 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
JOIN pg_catalog.pg_namespace n ON n.oid = t.typnamespace;
`
+ COLUMNS_SQL = () => `
+ select * from information_schema.columns where table_schema = ANY(current_schemas(false))
+ AND pg_table_is_visible(to_regclass(format('%I.%I', table_schema, table_name)));
+ `
+
constructor(config: PostgresConfig) {
super(SqlClient.POSTGRES)
this.config = config
@@ -219,8 +223,10 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
if (!this.config.schema) {
this.config.schema = "public"
}
- await this.client.query(`SET search_path TO "${this.config.schema}"`)
- this.COLUMNS_SQL = `select * from information_schema.columns where table_schema = '${this.config.schema}'`
+ const search_path = this.config.schema
+ .split(",")
+ .map(item => `"${item.trim()}"`)
+ await this.client.query(`SET search_path TO ${search_path.join(",")};`)
this.open = true
}
@@ -307,7 +313,7 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
try {
const columnsResponse: { rows: PostgresColumn[] } =
- await this.client.query(this.COLUMNS_SQL)
+ await this.client.query(this.COLUMNS_SQL())
const tables: { [key: string]: Table } = {}
@@ -362,8 +368,8 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
})
}
- let finalizedTables = finaliseExternalTables(tables, entities)
- let errors = checkExternalTables(finalizedTables)
+ const finalizedTables = finaliseExternalTables(tables, entities)
+ const errors = checkExternalTables(finalizedTables)
return { tables: finalizedTables, errors }
} catch (err) {
// @ts-ignore
@@ -377,7 +383,7 @@ class PostgresIntegration extends Sql implements DatasourcePlus {
try {
await this.openConnection()
const columnsResponse: { rows: PostgresColumn[] } =
- await this.client.query(this.COLUMNS_SQL)
+ await this.client.query(this.COLUMNS_SQL())
const names = columnsResponse.rows.map(row => row.table_name)
return [...new Set(names)]
} finally {
diff --git a/packages/server/src/jsRunner.ts b/packages/server/src/jsRunner.ts
index a9dcd506d7..9594ffaf65 100644
--- a/packages/server/src/jsRunner.ts
+++ b/packages/server/src/jsRunner.ts
@@ -12,11 +12,19 @@ export function init() {
const perRequestLimit = env.JS_PER_REQUEST_TIME_LIMIT_MS
let track: TrackerFn = f => f()
if (perRequestLimit) {
- const bbCtx = context.getCurrentContext()
+ const bbCtx = tracer.trace("runJS.getCurrentContext", {}, span =>
+ context.getCurrentContext()
+ )
if (bbCtx) {
if (!bbCtx.jsExecutionTracker) {
- bbCtx.jsExecutionTracker =
- timers.ExecutionTimeTracker.withLimit(perRequestLimit)
+ span?.addTags({
+ createdExecutionTracker: true,
+ })
+ bbCtx.jsExecutionTracker = tracer.trace(
+ "runJS.createExecutionTimeTracker",
+ {},
+ span => timers.ExecutionTimeTracker.withLimit(perRequestLimit)
+ )
}
span?.addTags({
js: {
@@ -26,8 +34,12 @@ export function init() {
})
// We call checkLimit() here to prevent paying the cost of creating
// a new VM context below when we don't need to.
- bbCtx.jsExecutionTracker.checkLimit()
- track = bbCtx.jsExecutionTracker.track.bind(bbCtx.jsExecutionTracker)
+ tracer.trace("runJS.checkLimitAndBind", {}, span => {
+ bbCtx.jsExecutionTracker!.checkLimit()
+ track = bbCtx.jsExecutionTracker!.track.bind(
+ bbCtx.jsExecutionTracker
+ )
+ })
}
}
@@ -37,6 +49,7 @@ export function init() {
setInterval: undefined,
setTimeout: undefined,
}
+
vm.createContext(ctx)
return track(() =>
vm.runInNewContext(js, ctx, {
diff --git a/packages/server/src/sdk/app/datasources/datasources.ts b/packages/server/src/sdk/app/datasources/datasources.ts
index 51cceeab94..c71c3f1b31 100644
--- a/packages/server/src/sdk/app/datasources/datasources.ts
+++ b/packages/server/src/sdk/app/datasources/datasources.ts
@@ -1,4 +1,4 @@
-import { context, db as dbCore } from "@budibase/backend-core"
+import { context, db as dbCore, events } from "@budibase/backend-core"
import { findHBSBlocks, processObjectSync } from "@budibase/string-templates"
import {
Datasource,
@@ -14,16 +14,22 @@ import {
} from "@budibase/types"
import { cloneDeep } from "lodash/fp"
import { getEnvironmentVariables } from "../../utils"
-import { getDefinitions, getDefinition } from "../../../integrations"
+import {
+ getDefinitions,
+ getDefinition,
+ getIntegration,
+} from "../../../integrations"
import merge from "lodash/merge"
import {
BudibaseInternalDB,
+ generateDatasourceID,
getDatasourceParams,
getDatasourcePlusParams,
getTableParams,
+ DocumentType,
} from "../../../db/utils"
import sdk from "../../index"
-import datasource from "../../../api/routes/datasource"
+import { setupCreationAuth as googleSetupCreationAuth } from "../../../integrations/googlesheets"
const ENV_VAR_PREFIX = "env."
@@ -273,3 +279,75 @@ export async function getExternalDatasources(): Promise {
return externalDatasources.rows.map(r => r.doc!)
}
+
+export async function save(
+ datasource: Datasource,
+ opts?: { fetchSchema?: boolean; tablesFilter?: string[] }
+): Promise<{ datasource: Datasource; errors: Record }> {
+ const db = context.getAppDB()
+ const plus = datasource.plus
+
+ const fetchSchema = opts?.fetchSchema || false
+ const tablesFilter = opts?.tablesFilter || []
+
+ datasource = {
+ _id: generateDatasourceID({ plus }),
+ ...datasource,
+ type: plus ? DocumentType.DATASOURCE_PLUS : DocumentType.DATASOURCE,
+ }
+
+ let errors: Record = {}
+ if (fetchSchema) {
+ const schema = await sdk.datasources.buildFilteredSchema(
+ datasource,
+ tablesFilter
+ )
+ datasource.entities = schema.tables
+ setDefaultDisplayColumns(datasource)
+ errors = schema.errors
+ }
+
+ if (preSaveAction[datasource.source]) {
+ await preSaveAction[datasource.source](datasource)
+ }
+
+ const dbResp = await db.put(
+ sdk.tables.populateExternalTableSchemas(datasource)
+ )
+ await events.datasource.created(datasource)
+ datasource._rev = dbResp.rev
+
+ // Drain connection pools when configuration is changed
+ if (datasource.source) {
+ const source = await getIntegration(datasource.source)
+ if (source && source.pool) {
+ await source.pool.end()
+ }
+ }
+
+ return { datasource, errors }
+}
+
+const preSaveAction: Partial> = {
+ [SourceName.GOOGLE_SHEETS]: async (datasource: Datasource) => {
+ await googleSetupCreationAuth(datasource.config as any)
+ },
+}
+
+/**
+ * Make sure all datasource entities have a display name selected
+ */
+export function setDefaultDisplayColumns(datasource: Datasource) {
+ //
+ for (let entity of Object.values(datasource.entities || {})) {
+ if (entity.primaryDisplay) {
+ continue
+ }
+ const notAutoColumn = Object.values(entity.schema).find(
+ schema => !schema.autocolumn
+ )
+ if (notAutoColumn) {
+ entity.primaryDisplay = notAutoColumn.name
+ }
+ }
+}
diff --git a/packages/server/src/sdk/app/datasources/index.ts b/packages/server/src/sdk/app/datasources/index.ts
index 1ce6b0e689..8f06e989d3 100644
--- a/packages/server/src/sdk/app/datasources/index.ts
+++ b/packages/server/src/sdk/app/datasources/index.ts
@@ -1,5 +1,7 @@
import * as datasources from "./datasources"
+import * as plus from "./plus"
export default {
...datasources,
+ ...plus,
}
diff --git a/packages/server/src/sdk/app/datasources/plus.ts b/packages/server/src/sdk/app/datasources/plus.ts
new file mode 100644
index 0000000000..04cd508863
--- /dev/null
+++ b/packages/server/src/sdk/app/datasources/plus.ts
@@ -0,0 +1,85 @@
+import {
+ Datasource,
+ DatasourcePlus,
+ IntegrationBase,
+ Schema,
+} from "@budibase/types"
+import * as datasources from "./datasources"
+import tableSdk from "../tables"
+import { getIntegration } from "../../../integrations"
+import { context } from "@budibase/backend-core"
+
+export async function buildFilteredSchema(
+ datasource: Datasource,
+ filter?: string[]
+): Promise {
+ const schema = await buildSchemaHelper(datasource)
+ if (!filter) {
+ return schema
+ }
+
+ let filteredSchema: Schema = { tables: {}, errors: {} }
+ for (let key in schema.tables) {
+ if (filter.some(filter => filter.toLowerCase() === key.toLowerCase())) {
+ filteredSchema.tables[key] = schema.tables[key]
+ }
+ }
+
+ for (let key in schema.errors) {
+ if (filter.some(filter => filter.toLowerCase() === key.toLowerCase())) {
+ filteredSchema.errors[key] = schema.errors[key]
+ }
+ }
+ return filteredSchema
+}
+
+async function buildSchemaHelper(datasource: Datasource): Promise {
+ const connector = (await getConnector(datasource)) as DatasourcePlus
+ const externalSchema = await connector.buildSchema(
+ datasource._id!,
+ datasource.entities!
+ )
+ return externalSchema
+}
+
+export async function getConnector(
+ datasource: Datasource
+): Promise {
+ const Connector = await getIntegration(datasource.source)
+ // can't enrich if it doesn't have an ID yet
+ if (datasource._id) {
+ datasource = await datasources.enrich(datasource)
+ }
+ // Connect to the DB and build the schema
+ return new Connector(datasource.config)
+}
+
+export async function getAndMergeDatasource(datasource: Datasource) {
+ if (datasource._id) {
+ const existingDatasource = await datasources.get(datasource._id)
+
+ datasource = datasources.mergeConfigs(datasource, existingDatasource)
+ }
+ return await datasources.enrich(datasource)
+}
+
+export async function buildSchemaFromSource(
+ datasourceId: string,
+ tablesFilter?: string[]
+) {
+ const db = context.getAppDB()
+
+ const datasource = await datasources.get(datasourceId)
+
+ const { tables, errors } = await buildFilteredSchema(datasource, tablesFilter)
+ datasource.entities = tables
+
+ datasources.setDefaultDisplayColumns(datasource)
+ const dbResp = await db.put(tableSdk.populateExternalTableSchemas(datasource))
+ datasource._rev = dbResp.rev
+
+ return {
+ datasource,
+ errors,
+ }
+}
diff --git a/packages/server/src/startup.ts b/packages/server/src/startup.ts
index 6860fe5f9b..f9b5974eb2 100644
--- a/packages/server/src/startup.ts
+++ b/packages/server/src/startup.ts
@@ -138,7 +138,11 @@ export async function startup(app?: Koa, server?: Server) {
bbAdminEmail,
bbAdminPassword,
tenantId,
- { hashPassword: true, requirePassword: true }
+ {
+ hashPassword: true,
+ requirePassword: true,
+ skipPasswordValidation: true,
+ }
)
// Need to set up an API key for automated integration tests
if (env.isTest()) {
diff --git a/packages/shared-core/src/filters.ts b/packages/shared-core/src/filters.ts
index 5e24b640d4..46d765a7b5 100644
--- a/packages/shared-core/src/filters.ts
+++ b/packages/shared-core/src/filters.ts
@@ -143,100 +143,104 @@ export const buildLuceneQuery = (filter: SearchFilter[]) => {
oneOf: {},
containsAny: {},
}
- if (Array.isArray(filter)) {
- filter.forEach(expression => {
- let { operator, field, type, value, externalType, onEmptyFilter } =
- expression
- const isHbs =
- typeof value === "string" && (value.match(HBS_REGEX) || []).length > 0
- // Parse all values into correct types
- if (operator === "allOr") {
- query.allOr = true
+
+ if (!Array.isArray(filter)) {
+ return query
+ }
+
+ filter.forEach(expression => {
+ let { operator, field, type, value, externalType, onEmptyFilter } =
+ expression
+ const isHbs =
+ typeof value === "string" && (value.match(HBS_REGEX) || []).length > 0
+ // Parse all values into correct types
+ if (operator === "allOr") {
+ query.allOr = true
+ return
+ }
+ if (onEmptyFilter) {
+ query.onEmptyFilter = onEmptyFilter
+ return
+ }
+ if (
+ type === "datetime" &&
+ !isHbs &&
+ operator !== "empty" &&
+ operator !== "notEmpty"
+ ) {
+ // Ensure date value is a valid date and parse into correct format
+ if (!value) {
return
}
- if (onEmptyFilter) {
- query.onEmptyFilter = onEmptyFilter
+ try {
+ value = new Date(value).toISOString()
+ } catch (error) {
return
}
- if (
- type === "datetime" &&
- !isHbs &&
- operator !== "empty" &&
- operator !== "notEmpty"
+ }
+ if (type === "number" && typeof value === "string" && !isHbs) {
+ if (operator === "oneOf") {
+ value = value.split(",").map(item => parseFloat(item))
+ } else {
+ value = parseFloat(value)
+ }
+ }
+ if (type === "boolean") {
+ value = `${value}`?.toLowerCase() === "true"
+ }
+ if (
+ ["contains", "notContains", "containsAny"].includes(operator) &&
+ type === "array" &&
+ typeof value === "string"
+ ) {
+ value = value.split(",")
+ }
+ if (operator.startsWith("range") && query.range) {
+ const minint =
+ SqlNumberTypeRangeMap[
+ externalType as keyof typeof SqlNumberTypeRangeMap
+ ]?.min || Number.MIN_SAFE_INTEGER
+ const maxint =
+ SqlNumberTypeRangeMap[
+ externalType as keyof typeof SqlNumberTypeRangeMap
+ ]?.max || Number.MAX_SAFE_INTEGER
+ if (!query.range[field]) {
+ query.range[field] = {
+ low: type === "number" ? minint : "0000-00-00T00:00:00.000Z",
+ high: type === "number" ? maxint : "9999-00-00T00:00:00.000Z",
+ }
+ }
+ if ((operator as any) === "rangeLow" && value != null && value !== "") {
+ query.range[field].low = value
+ } else if (
+ (operator as any) === "rangeHigh" &&
+ value != null &&
+ value !== ""
) {
- // Ensure date value is a valid date and parse into correct format
- if (!value) {
- return
- }
- try {
- value = new Date(value).toISOString()
- } catch (error) {
- return
- }
- }
- if (type === "number" && typeof value === "string") {
- if (operator === "oneOf") {
- value = value.split(",").map(item => parseFloat(item))
- } else if (!isHbs) {
- value = parseFloat(value)
- }
+ query.range[field].high = value
}
+ } else if (query[operator] && operator !== "onEmptyFilter") {
if (type === "boolean") {
- value = `${value}`?.toLowerCase() === "true"
- }
- if (
- ["contains", "notContains", "containsAny"].includes(operator) &&
- type === "array" &&
- typeof value === "string"
- ) {
- value = value.split(",")
- }
- if (operator.startsWith("range") && query.range) {
- const minint =
- SqlNumberTypeRangeMap[
- externalType as keyof typeof SqlNumberTypeRangeMap
- ]?.min || Number.MIN_SAFE_INTEGER
- const maxint =
- SqlNumberTypeRangeMap[
- externalType as keyof typeof SqlNumberTypeRangeMap
- ]?.max || Number.MAX_SAFE_INTEGER
- if (!query.range[field]) {
- query.range[field] = {
- low: type === "number" ? minint : "0000-00-00T00:00:00.000Z",
- high: type === "number" ? maxint : "9999-00-00T00:00:00.000Z",
- }
- }
- if ((operator as any) === "rangeLow" && value != null && value !== "") {
- query.range[field].low = value
- } else if (
- (operator as any) === "rangeHigh" &&
- value != null &&
- value !== ""
- ) {
- query.range[field].high = value
- }
- } else if (query[operator] && operator !== "onEmptyFilter") {
- if (type === "boolean") {
- // Transform boolean filters to cope with null.
- // "equals false" needs to be "not equals true"
- // "not equals false" needs to be "equals true"
- if (operator === "equal" && value === false) {
- query.notEqual = query.notEqual || {}
- query.notEqual[field] = true
- } else if (operator === "notEqual" && value === false) {
- query.equal = query.equal || {}
- query.equal[field] = true
- } else {
- query[operator] = query[operator] || {}
- query[operator]![field] = value
- }
+ // Transform boolean filters to cope with null.
+ // "equals false" needs to be "not equals true"
+ // "not equals false" needs to be "equals true"
+ if (operator === "equal" && value === false) {
+ query.notEqual = query.notEqual || {}
+ query.notEqual[field] = true
+ } else if (operator === "notEqual" && value === false) {
+ query.equal = query.equal || {}
+ query.equal[field] = true
} else {
query[operator] = query[operator] || {}
query[operator]![field] = value
}
+ } else {
+ query[operator] = query[operator] || {}
+ query[operator]![field] = value
}
- })
- }
+ }
+ })
+
return query
}
diff --git a/packages/shared-core/src/tests/filters.test.ts b/packages/shared-core/src/tests/filters.test.ts
index bddd6cb1f0..8586d58777 100644
--- a/packages/shared-core/src/tests/filters.test.ts
+++ b/packages/shared-core/src/tests/filters.test.ts
@@ -1,6 +1,11 @@
-import { SearchQuery, SearchQueryOperators } from "@budibase/types"
-import { runLuceneQuery } from "../filters"
-import { expect, describe, it } from "vitest"
+import {
+ SearchQuery,
+ SearchQueryOperators,
+ FieldType,
+ SearchFilter,
+} from "@budibase/types"
+import { buildLuceneQuery, runLuceneQuery } from "../filters"
+import { expect, describe, it, test } from "vitest"
describe("runLuceneQuery", () => {
const docs = [
@@ -167,4 +172,186 @@ describe("runLuceneQuery", () => {
})
expect(runLuceneQuery(docs, query).map(row => row.order_id)).toEqual([2, 3])
})
+
+ test.each([[523, 259], "523,259"])(
+ "should return rows with matches on numeric oneOf filter",
+ input => {
+ let query = buildQuery("oneOf", {
+ customer_id: input,
+ })
+ expect(runLuceneQuery(docs, query).map(row => row.customer_id)).toEqual([
+ 259, 523,
+ ])
+ }
+ )
+})
+
+describe("buildLuceneQuery", () => {
+ it("should return a basic search query template if the input is not an array", () => {
+ const filter: any = "NOT_AN_ARRAY"
+ expect(buildLuceneQuery(filter)).toEqual({
+ string: {},
+ fuzzy: {},
+ range: {},
+ equal: {},
+ notEqual: {},
+ empty: {},
+ notEmpty: {},
+ contains: {},
+ notContains: {},
+ oneOf: {},
+ containsAny: {},
+ })
+ })
+
+ it("should parseFloat if the type is a number, but the value is a numeric string", () => {
+ const filter: SearchFilter[] = [
+ {
+ operator: SearchQueryOperators.EQUAL,
+ field: "customer_id",
+ type: FieldType.NUMBER,
+ value: "1212",
+ },
+ {
+ operator: SearchQueryOperators.ONE_OF,
+ field: "customer_id",
+ type: FieldType.NUMBER,
+ value: "1000,1212,3400",
+ },
+ ]
+ expect(buildLuceneQuery(filter)).toEqual({
+ string: {},
+ fuzzy: {},
+ range: {},
+ equal: {
+ customer_id: 1212,
+ },
+ notEqual: {},
+ empty: {},
+ notEmpty: {},
+ contains: {},
+ notContains: {},
+ oneOf: {
+ customer_id: [1000, 1212, 3400],
+ },
+ containsAny: {},
+ })
+ })
+
+ it("should not parseFloat if the type is a number, but the value is a handlebars binding string", () => {
+ const filter: SearchFilter[] = [
+ {
+ operator: SearchQueryOperators.EQUAL,
+ field: "customer_id",
+ type: FieldType.NUMBER,
+ value: "{{ customer_id }}",
+ },
+ {
+ operator: SearchQueryOperators.ONE_OF,
+ field: "customer_id",
+ type: FieldType.NUMBER,
+ value: "{{ list_of_customer_ids }}",
+ },
+ ]
+ expect(buildLuceneQuery(filter)).toEqual({
+ string: {},
+ fuzzy: {},
+ range: {},
+ equal: {
+ customer_id: "{{ customer_id }}",
+ },
+ notEqual: {},
+ empty: {},
+ notEmpty: {},
+ contains: {},
+ notContains: {},
+ oneOf: {
+ customer_id: "{{ list_of_customer_ids }}",
+ },
+ containsAny: {},
+ })
+ })
+
+ it("should cast string to boolean if the type is boolean", () => {
+ const filter: SearchFilter[] = [
+ {
+ operator: SearchQueryOperators.EQUAL,
+ field: "a",
+ type: FieldType.BOOLEAN,
+ value: "not_true",
+ },
+ {
+ operator: SearchQueryOperators.NOT_EQUAL,
+ field: "b",
+ type: FieldType.BOOLEAN,
+ value: "not_true",
+ },
+ {
+ operator: SearchQueryOperators.EQUAL,
+ field: "c",
+ type: FieldType.BOOLEAN,
+ value: "true",
+ },
+ ]
+ expect(buildLuceneQuery(filter)).toEqual({
+ string: {},
+ fuzzy: {},
+ range: {},
+ equal: {
+ b: true,
+ c: true,
+ },
+ notEqual: {
+ a: true,
+ },
+ empty: {},
+ notEmpty: {},
+ contains: {},
+ notContains: {},
+ oneOf: {},
+ containsAny: {},
+ })
+ })
+
+ it("should split the string for contains operators", () => {
+ const filter: SearchFilter[] = [
+ {
+ operator: SearchQueryOperators.CONTAINS,
+ field: "description",
+ type: FieldType.ARRAY,
+ value: "Large box,Heavy box,Small box",
+ },
+ {
+ operator: SearchQueryOperators.NOT_CONTAINS,
+ field: "description",
+ type: FieldType.ARRAY,
+ value: "Large box,Heavy box,Small box",
+ },
+ {
+ operator: SearchQueryOperators.CONTAINS_ANY,
+ field: "description",
+ type: FieldType.ARRAY,
+ value: "Large box,Heavy box,Small box",
+ },
+ ]
+ expect(buildLuceneQuery(filter)).toEqual({
+ string: {},
+ fuzzy: {},
+ range: {},
+ equal: {},
+ notEqual: {},
+ empty: {},
+ notEmpty: {},
+ contains: {
+ description: ["Large box", "Heavy box", "Small box"],
+ },
+ notContains: {
+ description: ["Large box", "Heavy box", "Small box"],
+ },
+ oneOf: {},
+ containsAny: {
+ description: ["Large box", "Heavy box", "Small box"],
+ },
+ })
+ })
})
diff --git a/packages/types/src/api/web/app/datasource.ts b/packages/types/src/api/web/app/datasource.ts
index 9cd3c8f4bb..4a3d07a952 100644
--- a/packages/types/src/api/web/app/datasource.ts
+++ b/packages/types/src/api/web/app/datasource.ts
@@ -35,3 +35,12 @@ export interface FetchDatasourceInfoResponse {
export interface UpdateDatasourceRequest extends Datasource {
datasource: Datasource
}
+
+export interface BuildSchemaFromSourceRequest {
+ tablesFilter?: string[]
+}
+
+export interface BuildSchemaFromSourceResponse {
+ datasource: Datasource
+ errors: Record
+}
diff --git a/packages/types/src/sdk/user.ts b/packages/types/src/sdk/user.ts
index 2b970da1a9..3f6f69d2d1 100644
--- a/packages/types/src/sdk/user.ts
+++ b/packages/types/src/sdk/user.ts
@@ -2,4 +2,5 @@ export interface SaveUserOpts {
hashPassword?: boolean
requirePassword?: boolean
currentUserId?: string
+ skipPasswordValidation?: boolean
}
diff --git a/qa-core/src/account-api/tests/licensing/license.manage.spec.ts b/qa-core/src/account-api/tests/licensing/license.manage.spec.ts
index bda0476c2b..9a8662ea3b 100644
--- a/qa-core/src/account-api/tests/licensing/license.manage.spec.ts
+++ b/qa-core/src/account-api/tests/licensing/license.manage.spec.ts
@@ -39,10 +39,10 @@ describe("license management", () => {
let premiumPriceId = null
let businessPriceId = ""
for (const plan of planBody) {
- if (plan.type === PlanType.PREMIUM) {
+ if (plan.type === PlanType.PREMIUM_PLUS) {
premiumPriceId = plan.prices[0].priceId
}
- if (plan.type === PlanType.BUSINESS) {
+ if (plan.type === PlanType.ENTERPRISE_BASIC) {
businessPriceId = plan.prices[0].priceId
}
}
@@ -97,7 +97,7 @@ describe("license management", () => {
await config.loginAsAccount(createAccountRequest)
await config.api.stripe.linkStripeCustomer(account.accountId, customer.id)
const [_, selfBodyPremium] = await config.api.accounts.self()
- expect(selfBodyPremium.license.plan.type).toBe(PlanType.PREMIUM)
+ expect(selfBodyPremium.license.plan.type).toBe(PlanType.PREMIUM_PLUS)
// Create portal session - Check URL
const [portalRes, portalSessionBody] =
@@ -109,7 +109,7 @@ describe("license management", () => {
// License updated to Business
const [selfRes, selfBodyBusiness] = await config.api.accounts.self()
- expect(selfBodyBusiness.license.plan.type).toBe(PlanType.BUSINESS)
+ expect(selfBodyBusiness.license.plan.type).toBe(PlanType.ENTERPRISE_BASIC)
})
})
})
diff --git a/yarn.lock b/yarn.lock
index 091dc04baa..5fcfecc065 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -639,15 +639,7 @@
dependencies:
tslib "^2.2.0"
-"@azure/core-auth@^1.3.0", "@azure/core-auth@^1.4.0":
- version "1.4.0"
- resolved "https://registry.yarnpkg.com/@azure/core-auth/-/core-auth-1.4.0.tgz#6fa9661c1705857820dbc216df5ba5665ac36a9e"
- integrity sha512-HFrcTgmuSuukRf/EdPmqBrc5l6Q5Uu+2TbuhaKbgaCpP2TfAeiNaQPAadxO+CYBRHGUzIDteMAjFspFLDLnKVQ==
- dependencies:
- "@azure/abort-controller" "^1.0.0"
- tslib "^2.2.0"
-
-"@azure/core-auth@^1.5.0":
+"@azure/core-auth@^1.3.0", "@azure/core-auth@^1.4.0", "@azure/core-auth@^1.5.0":
version "1.5.0"
resolved "https://registry.yarnpkg.com/@azure/core-auth/-/core-auth-1.5.0.tgz#a41848c5c31cb3b7c84c409885267d55a2c92e44"
integrity sha512-udzoBuYG1VBoHVohDTrvKjyzel34zt77Bhp7dQntVGGD0ehVq48owENbBG8fIgkHRNUBQH5k1r0hpoMu5L8+kw==
@@ -744,15 +736,7 @@
dependencies:
tslib "^2.2.0"
-"@azure/core-util@^1.0.0", "@azure/core-util@^1.1.1", "@azure/core-util@^1.3.0":
- version "1.3.2"
- resolved "https://registry.yarnpkg.com/@azure/core-util/-/core-util-1.3.2.tgz#3f8cfda1e87fac0ce84f8c1a42fcd6d2a986632d"
- integrity sha512-2bECOUh88RvL1pMZTcc6OzfobBeWDBf5oBbhjIhT1MV9otMVWCzpOJkkiKtrnO88y5GGBelgY8At73KGAdbkeQ==
- dependencies:
- "@azure/abort-controller" "^1.0.0"
- tslib "^2.2.0"
-
-"@azure/core-util@^1.1.0", "@azure/core-util@^1.6.1":
+"@azure/core-util@^1.0.0", "@azure/core-util@^1.1.0", "@azure/core-util@^1.1.1", "@azure/core-util@^1.3.0", "@azure/core-util@^1.6.1":
version "1.6.1"
resolved "https://registry.yarnpkg.com/@azure/core-util/-/core-util-1.6.1.tgz#fea221c4fa43c26543bccf799beb30c1c7878f5a"
integrity sha512-h5taHeySlsV9qxuK64KZxy4iln1BtMYlNt5jbuEFN3UFSAd1EwKg/Gjl5a6tZ/W8t6li3xPnutOx7zbDyXnPmQ==
@@ -1996,17 +1980,10 @@
resolved "https://registry.yarnpkg.com/@babel/regjsgen/-/regjsgen-0.8.0.tgz#f0ba69b075e1f05fb2825b7fad991e7adbb18310"
integrity sha512-x/rqGMdzj+fWZvCOYForTghzbtqPDZ5gPwaoNGHdgDfF2QA/XZbCBp4Moo5scrkAMPhB7z26XM/AaHuIJdgauA==
-"@babel/runtime@^7.12.5", "@babel/runtime@^7.15.4", "@babel/runtime@^7.7.2", "@babel/runtime@^7.8.4", "@babel/runtime@^7.9.2":
- version "7.23.6"
- resolved "https://registry.yarnpkg.com/@babel/runtime/-/runtime-7.23.6.tgz#c05e610dc228855dc92ef1b53d07389ed8ab521d"
- integrity sha512-zHd0eUrf5GZoOWVCXp6koAKQTfZV07eit6bGPmJgnZdnSAvvZee6zniW2XMF7Cmc4ISOOnPy3QaSiIJGJkVEDQ==
- dependencies:
- regenerator-runtime "^0.14.0"
-
-"@babel/runtime@^7.13.10":
- version "7.23.7"
- resolved "https://registry.yarnpkg.com/@babel/runtime/-/runtime-7.23.7.tgz#dd7c88deeb218a0f8bd34d5db1aa242e0f203193"
- integrity sha512-w06OXVOFso7LcbzMiDGt+3X7Rh7Ho8MmgPoWU3rarH+8upf+wSU/grlGbWzQyr3DkdN6ZeuMFjpdwW0Q+HxobA==
+"@babel/runtime@^7.12.5", "@babel/runtime@^7.13.10", "@babel/runtime@^7.15.4", "@babel/runtime@^7.7.2", "@babel/runtime@^7.8.4", "@babel/runtime@^7.9.2":
+ version "7.23.8"
+ resolved "https://registry.yarnpkg.com/@babel/runtime/-/runtime-7.23.8.tgz#8ee6fe1ac47add7122902f257b8ddf55c898f650"
+ integrity sha512-Y7KbAP984rn1VGMbGqKmBLio9V7y5Je9GvU4rQPCPinCyNfUcToxIXl06d59URp/F3LwinvODxab5N/G6qggkw==
dependencies:
regenerator-runtime "^0.14.0"
@@ -2019,15 +1996,6 @@
"@babel/parser" "^7.22.15"
"@babel/types" "^7.22.15"
-"@babel/template@^7.22.5", "@babel/template@^7.3.3":
- version "7.22.5"
- resolved "https://registry.yarnpkg.com/@babel/template/-/template-7.22.5.tgz#0c8c4d944509875849bd0344ff0050756eefc6ec"
- integrity sha512-X7yV7eiwAxdj9k94NEylvbVHLiVG1nvzCV2EAowhxLTwODV1jl9UzZ48leOC0sH7OnuHrIkllaBgneUykIcZaw==
- dependencies:
- "@babel/code-frame" "^7.22.5"
- "@babel/parser" "^7.22.5"
- "@babel/types" "^7.22.5"
-
"@babel/traverse@^7.22.5":
version "7.23.6"
resolved "https://registry.yarnpkg.com/@babel/traverse/-/traverse-7.23.6.tgz#b53526a2367a0dd6edc423637f3d2d0f2521abc5"
@@ -3381,7 +3349,7 @@
resolved "https://registry.yarnpkg.com/@jridgewell/sourcemap-codec/-/sourcemap-codec-1.4.14.tgz#add4c98d341472a289190b424efbdb096991bb24"
integrity sha512-XPSJHWmi394fuUuzDnGz1wiKqWfo1yXecHQMRf2l6hztTO+nPru658AyDngaBe7isIxEkRsPR3FZh+s7iVa4Uw==
-"@jridgewell/sourcemap-codec@^1.4.10", "@jridgewell/sourcemap-codec@^1.4.13", "@jridgewell/sourcemap-codec@^1.4.14":
+"@jridgewell/sourcemap-codec@^1.4.10", "@jridgewell/sourcemap-codec@^1.4.14", "@jridgewell/sourcemap-codec@^1.4.15":
version "1.4.15"
resolved "https://registry.yarnpkg.com/@jridgewell/sourcemap-codec/-/sourcemap-codec-1.4.15.tgz#d7c6e6755c78567a951e04ab52ef0fd26de59f32"
integrity sha512-eF2rxCRulEKXHTRiDrDy6erMYWqNw4LPdQ8UQA4huuxaQsVeRPFl2oM8oDGxMFhJUWZf9McpLtJasDDZb/Bpeg==
@@ -4043,12 +4011,12 @@
magic-string "^0.25.7"
"@rollup/plugin-replace@^5.0.2", "@rollup/plugin-replace@^5.0.3":
- version "5.0.3"
- resolved "https://registry.yarnpkg.com/@rollup/plugin-replace/-/plugin-replace-5.0.3.tgz#55a4550bd6d5e83a65df3d201e0b3d219be7b4b2"
- integrity sha512-je7fu05B800IrMlWjb2wzJcdXzHYW46iTipfChnBDbIbDXhASZs27W1B58T2Yf45jZtJUONegpbce+9Ut2Ti/Q==
+ version "5.0.5"
+ resolved "https://registry.yarnpkg.com/@rollup/plugin-replace/-/plugin-replace-5.0.5.tgz#33d5653dce6d03cb24ef98bef7f6d25b57faefdf"
+ integrity sha512-rYO4fOi8lMaTg/z5Jb+hKnrHHVn8j2lwkqwyS4kTRhKyWOLf2wST2sWXr4WzWiTcoHTp2sTjqUbqIj2E39slKQ==
dependencies:
"@rollup/pluginutils" "^5.0.1"
- magic-string "^0.27.0"
+ magic-string "^0.30.3"
"@rollup/plugin-typescript@8.3.0":
version "8.3.0"
@@ -5473,7 +5441,7 @@
"@types/koa" "*"
"@types/passport" "*"
-"@types/koa-send@*":
+"@types/koa-send@*", "@types/koa-send@^4.1.6":
version "4.1.6"
resolved "https://registry.yarnpkg.com/@types/koa-send/-/koa-send-4.1.6.tgz#15d90e95e3ccce669a15b6a3c56c3a650a167cea"
integrity sha512-vgnNGoOJkx7FrF0Jl6rbK1f8bBecqAchKpXtKuXzqIEdXTDO6dsSTjr+eZ5m7ltSjH4K/E7auNJEQCAd0McUPA==
@@ -5605,10 +5573,10 @@
"@types/node" "*"
form-data "^3.0.0"
-"@types/node@*", "@types/node@>=10.0.0", "@types/node@>=12.12.47", "@types/node@>=13.13.4", "@types/node@>=13.7.0":
- version "20.10.5"
- resolved "https://registry.yarnpkg.com/@types/node/-/node-20.10.5.tgz#47ad460b514096b7ed63a1dae26fad0914ed3ab2"
- integrity sha512-nNPsNE65wjMxEKI93yOP+NPGGBJz/PoN3kZsVLee0XMiJolxSekEVD8wRwBUBqkwc7UWop0edW50yrCQW4CyRw==
+"@types/node@*", "@types/node@>=10.0.0", "@types/node@>=12.12.47", "@types/node@>=13.13.4", "@types/node@>=13.7.0", "@types/node@>=8.1.0":
+ version "20.10.7"
+ resolved "https://registry.yarnpkg.com/@types/node/-/node-20.10.7.tgz#40fe8faf25418a75de9fe68a8775546732a3a901"
+ integrity sha512-fRbIKb8C/Y2lXxB5eVMj4IU7xpdox0Lh8bUPEdtLysaylsml1hOOx1+STloRs/B9nf7C6kPRmmg/V7aQW7usNg==
dependencies:
undici-types "~5.26.4"
@@ -5617,11 +5585,6 @@
resolved "https://registry.yarnpkg.com/@types/node/-/node-16.9.1.tgz#0611b37db4246c937feef529ddcc018cf8e35708"
integrity sha512-QpLcX9ZSsq3YYUUnD3nFDY8H7wctAhQj/TFKL8Ya8v5fMm3CFXxo8zStsLAl780ltoYoo1WvKUVGBQK+1ifr7g==
-"@types/node@18.17.0":
- version "18.17.0"
- resolved "https://registry.yarnpkg.com/@types/node/-/node-18.17.0.tgz#35d44267a33dd46b49ee0f73d31b05fd7407e290"
- integrity sha512-GXZxEtOxYGFchyUzxvKI14iff9KZ2DI+A6a37o6EQevtg6uO9t+aUZKcaC1Te5Ng1OnLM7K9NVVj+FbecD9cJg==
-
"@types/node@20.10.0":
version "20.10.0"
resolved "https://registry.yarnpkg.com/@types/node/-/node-20.10.0.tgz#16ddf9c0a72b832ec4fcce35b8249cf149214617"
@@ -5639,13 +5602,6 @@
resolved "https://registry.yarnpkg.com/@types/node/-/node-14.18.37.tgz#0bfcd173e8e1e328337473a8317e37b3b14fd30d"
integrity sha512-7GgtHCs/QZrBrDzgIJnQtuSvhFSwhyYSI2uafSwZoNt1iOGhEN5fwNrQMjtONyHm9+/LoA4453jH0CMYcr06Pg==
-"@types/node@>=8.1.0":
- version "20.10.6"
- resolved "https://registry.yarnpkg.com/@types/node/-/node-20.10.6.tgz#a3ec84c22965802bf763da55b2394424f22bfbb5"
- integrity sha512-Vac8H+NlRNNlAmDfGUP7b5h/KA+AtWIzuXy0E6OyP8f1tCLYAtPvKRRDJjAPqhpCb0t6U2j7/xqAuLEebW2kiw==
- dependencies:
- undici-types "~5.26.4"
-
"@types/nodemailer@^6.4.4":
version "6.4.14"
resolved "https://registry.yarnpkg.com/@types/nodemailer/-/nodemailer-6.4.14.tgz#5c81a5e856db7f8ede80013e6dbad7c5fb2283e2"
@@ -11183,9 +11139,9 @@ formidable@^2.1.2:
qs "^6.11.0"
fp-ts@^2.5.1:
- version "2.16.1"
- resolved "https://registry.yarnpkg.com/fp-ts/-/fp-ts-2.16.1.tgz#6abc401ce42b65364ca8f0b0d995c5840c68a930"
- integrity sha512-by7U5W8dkIzcvDofUcO42yl9JbnHTEDBrzu3pt5fKT+Z4Oy85I21K80EYJYdjQGC2qum4Vo55Ag57iiIK4FYuA==
+ version "2.16.2"
+ resolved "https://registry.yarnpkg.com/fp-ts/-/fp-ts-2.16.2.tgz#7faa90f6fc2e8cf84c711d2c4e606afe2be9e342"
+ integrity sha512-CkqAjnIKFqvo3sCyoBTqgJvF+bHrSik584S9nhTjtBESLx26cbtVMR/T9a6ApChOcSDAaM3JydDmWDUn4EEXng==
fragment-cache@^0.2.1:
version "0.2.1"
@@ -11265,9 +11221,9 @@ fs.realpath@^1.0.0:
integrity sha512-OO0pH2lK6a0hZnAdau5ItzHPI6pUlvI7jMVnxUQRtw4owF2wk8lOSabtGDCTP4Ggrg2MbGnWO9X8K1t4+fGMDw==
fsevents@^2.3.2, fsevents@~2.3.1, fsevents@~2.3.2:
- version "2.3.2"
- resolved "https://registry.yarnpkg.com/fsevents/-/fsevents-2.3.2.tgz#8a526f78b8fdf4623b709e0b975c52c24c02fd1a"
- integrity sha512-xiqMQR4xAeHTuB9uWm+fFRcIOgKBMiOBP+eXiyT7jsgVCq1bkVygt00oASowB7EdtpOHaaPgKt812P9ab+DDKA==
+ version "2.3.3"
+ resolved "https://registry.yarnpkg.com/fsevents/-/fsevents-2.3.3.tgz#cac6407785d03675a2a5e1a5305c697b347d90d6"
+ integrity sha512-5xoDfX+fL7faATnagmWPpbFtwh/R77WmMMqqHGS65C3vvB0YHrgF+B1YmZ3441tMj5n63k0212XNoJwzlhffQw==
function-bind@^1.1.1, function-bind@^1.1.2:
version "1.1.2"
@@ -14326,16 +14282,6 @@ koa-router@^10.0.0:
methods "^1.1.2"
path-to-regexp "^6.1.0"
-koa-send@5.0.0:
- version "5.0.0"
- resolved "https://registry.yarnpkg.com/koa-send/-/koa-send-5.0.0.tgz#5e8441e07ef55737734d7ced25b842e50646e7eb"
- integrity sha512-90ZotV7t0p3uN9sRwW2D484rAaKIsD8tAVtypw/aBU+ryfV+fR2xrcAwhI8Wl6WRkojLUs/cB9SBSCuIb+IanQ==
- dependencies:
- debug "^3.1.0"
- http-errors "^1.6.3"
- mz "^2.7.0"
- resolve-path "^1.4.0"
-
koa-send@5.0.1, koa-send@^5.0.0:
version "5.0.1"
resolved "https://registry.yarnpkg.com/koa-send/-/koa-send-5.0.1.tgz#39dceebfafb395d0d60beaffba3a70b4f543fe79"
@@ -15217,12 +15163,12 @@ magic-string@^0.26.7:
dependencies:
sourcemap-codec "^1.4.8"
-magic-string@^0.27.0:
- version "0.27.0"
- resolved "https://registry.yarnpkg.com/magic-string/-/magic-string-0.27.0.tgz#e4a3413b4bab6d98d2becffd48b4a257effdbbf3"
- integrity sha512-8UnnX2PeRAPZuN12svgR9j7M1uWMovg/CEnIwIG0LFkXSJJe4PdfUGiTGl8V9bsBHFUtfVINcSyYxd7q+kx9fA==
+magic-string@^0.30.3:
+ version "0.30.5"
+ resolved "https://registry.yarnpkg.com/magic-string/-/magic-string-0.30.5.tgz#1994d980bd1c8835dc6e78db7cbd4ae4f24746f9"
+ integrity sha512-7xlpfBaQaP/T6Vh8MO/EqXSW5En6INHEvEXQiuff7Gku0PWjU3uf6w/j9o7O+SpB5fOAkrI5HeoNgwjEO0pFsA==
dependencies:
- "@jridgewell/sourcemap-codec" "^1.4.13"
+ "@jridgewell/sourcemap-codec" "^1.4.15"
make-dir@3.1.0, make-dir@^3.0.0, make-dir@^3.1.0:
version "3.1.0"
@@ -15936,7 +15882,7 @@ mysql2@3.5.2:
seq-queue "^0.0.5"
sqlstring "^2.3.2"
-mz@^2.4.0, mz@^2.7.0:
+mz@^2.4.0:
version "2.7.0"
resolved "https://registry.yarnpkg.com/mz/-/mz-2.7.0.tgz#95008057a56cafadc2bc63dde7f9ff6955948e32"
integrity sha512-z81GNO7nnYMEhrGh9LeymoE4+Yr0Wn5McHIZMK5cfQCl+NDX08sCZgUc9/6MHni9IWuFLm1Z3HTCXu2z9fN62Q==
@@ -18774,17 +18720,7 @@ readable-stream@^2.0.0, readable-stream@^2.2.2, readable-stream@^2.3.0, readable
string_decoder "~1.1.1"
util-deprecate "~1.0.1"
-readable-stream@^4.0.0:
- version "4.3.0"
- resolved "https://registry.yarnpkg.com/readable-stream/-/readable-stream-4.3.0.tgz#0914d0c72db03b316c9733bb3461d64a3cc50cba"
- integrity sha512-MuEnA0lbSi7JS8XM+WNJlWZkHAAdm7gETHdFK//Q/mChGyj2akEFtdLZh32jSdkWGbRwCW9pn6g3LWDdDeZnBQ==
- dependencies:
- abort-controller "^3.0.0"
- buffer "^6.0.3"
- events "^3.3.0"
- process "^0.11.10"
-
-readable-stream@^4.2.0:
+readable-stream@^4.0.0, readable-stream@^4.2.0:
version "4.5.1"
resolved "https://registry.yarnpkg.com/readable-stream/-/readable-stream-4.5.1.tgz#3f2e4e66eab45606ac8f31597b9edb80c13b12ab"
integrity sha512-uQjbf34vmf/asGnOHQEw07Q4llgMACQZTWWa4MmICS0IKJoHbLwKCy71H3eR99Dw5iYejc6W+pqZZEeqRtUFAw==
@@ -18965,11 +18901,6 @@ regexparam@2.0.1:
resolved "https://registry.yarnpkg.com/regexparam/-/regexparam-2.0.1.tgz#c912f5dae371e3798100b3c9ce22b7414d0889fa"
integrity sha512-zRgSaYemnNYxUv+/5SeoHI0eJIgTL/A2pUtXUPLHQxUldagouJ9p+K6IbIZ/JiQuCEv2E2B1O11SjVQy3aMCkw==
-regexparam@^1.3.0:
- version "1.3.0"
- resolved "https://registry.yarnpkg.com/regexparam/-/regexparam-1.3.0.tgz#2fe42c93e32a40eff6235d635e0ffa344b92965f"
- integrity sha512-6IQpFBv6e5vz1QAqI+V4k8P2e/3gRrqfCJ9FI+O1FLQTO+Uz6RXZEZOPmTJ6hlGj7gkERzY5BRCv09whKP96/g==
-
regexpu-core@^5.3.1:
version "5.3.1"
resolved "https://registry.yarnpkg.com/regexpu-core/-/regexpu-core-5.3.1.tgz#66900860f88def39a5cb79ebd9490e84f17bcdfb"
@@ -21070,11 +21001,16 @@ timed-out@^4.0.1:
resolved "https://registry.yarnpkg.com/timed-out/-/timed-out-4.0.1.tgz#f32eacac5a175bea25d7fab565ab3ed8741ef56f"
integrity sha512-G7r3AhovYtr5YKOWQkta8RKAPb+J9IsO4uVmzjl8AZwfhs8UcUwTiD6gcJYSgOtzyjvQKrKYn41syHbUWMkafA==
-timekeeper@2.2.0, timekeeper@^2.2.0:
+timekeeper@2.2.0:
version "2.2.0"
resolved "https://registry.yarnpkg.com/timekeeper/-/timekeeper-2.2.0.tgz#9645731fce9e3280a18614a57a9d1b72af3ca368"
integrity sha512-W3AmPTJWZkRwu+iSNxPIsLZ2ByADsOLbbLxe46UJyWj3mlYLlwucKiq+/dPm0l9wTzqoF3/2PH0AGFCebjq23A==
+timekeeper@^2.2.0:
+ version "2.3.1"
+ resolved "https://registry.yarnpkg.com/timekeeper/-/timekeeper-2.3.1.tgz#2deb6e0b95d93625fda84c18d47f84a99e4eba01"
+ integrity sha512-LeQRS7/4JcC0PgdSFnfUiStQEdiuySlCj/5SJ18D+T1n9BoY7PxKFfCwLulpHXoLUFr67HxBddQdEX47lDGx1g==
+
timm@^1.6.1:
version "1.7.1"
resolved "https://registry.yarnpkg.com/timm/-/timm-1.7.1.tgz#96bab60c7d45b5a10a8a4d0f0117c6b7e5aff76f"