diff --git a/lerna.json b/lerna.json
index ee4d8e8598..5ad64883d4 100644
--- a/lerna.json
+++ b/lerna.json
@@ -1,5 +1,5 @@
{
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"npmClient": "yarn",
"useWorkspaces": true,
"packages": ["packages/*"],
diff --git a/packages/backend-core/package.json b/packages/backend-core/package.json
index 7477406505..1302568db5 100644
--- a/packages/backend-core/package.json
+++ b/packages/backend-core/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/backend-core",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase backend core libraries used in server and worker",
"main": "dist/src/index.js",
"types": "dist/src/index.d.ts",
@@ -24,7 +24,7 @@
"dependencies": {
"@budibase/nano": "10.1.2",
"@budibase/pouchdb-replication-stream": "1.2.10",
- "@budibase/types": "2.5.6-alpha.30",
+ "@budibase/types": "2.5.6-alpha.42",
"@shopify/jest-koa-mocks": "5.0.1",
"@techpass/passport-openidconnect": "0.3.2",
"aws-cloudfront-sign": "2.2.0",
diff --git a/packages/backend-core/src/events/publishers/license.ts b/packages/backend-core/src/events/publishers/license.ts
index aff3286c87..d1ff4d7609 100644
--- a/packages/backend-core/src/events/publishers/license.ts
+++ b/packages/backend-core/src/events/publishers/license.ts
@@ -3,7 +3,6 @@ import {
Event,
LicenseActivatedEvent,
LicensePlanChangedEvent,
- LicenseTierChangedEvent,
PlanType,
Account,
LicensePortalOpenedEvent,
@@ -11,22 +10,22 @@ import {
LicenseCheckoutOpenedEvent,
LicensePaymentFailedEvent,
LicensePaymentRecoveredEvent,
+ PriceDuration,
} from "@budibase/types"
-async function tierChanged(account: Account, from: number, to: number) {
- const properties: LicenseTierChangedEvent = {
- accountId: account.accountId,
- to,
- from,
- }
- await publishEvent(Event.LICENSE_TIER_CHANGED, properties)
-}
-
-async function planChanged(account: Account, from: PlanType, to: PlanType) {
+async function planChanged(
+ account: Account,
+ from: PlanType,
+ to: PlanType,
+ quantity: number | undefined,
+ duration: PriceDuration | undefined
+) {
const properties: LicensePlanChangedEvent = {
accountId: account.accountId,
to,
from,
+ quantity,
+ duration,
}
await publishEvent(Event.LICENSE_PLAN_CHANGED, properties)
}
@@ -74,7 +73,6 @@ async function paymentRecovered(account: Account) {
}
export default {
- tierChanged,
planChanged,
activated,
checkoutOpened,
diff --git a/packages/backend-core/tests/core/utilities/mocks/events.ts b/packages/backend-core/tests/core/utilities/mocks/events.ts
index dacf7dcce8..81de1f8175 100644
--- a/packages/backend-core/tests/core/utilities/mocks/events.ts
+++ b/packages/backend-core/tests/core/utilities/mocks/events.ts
@@ -123,7 +123,6 @@ beforeAll(async () => {
jest.spyOn(events.plugin, "imported")
jest.spyOn(events.plugin, "deleted")
- jest.spyOn(events.license, "tierChanged")
jest.spyOn(events.license, "planChanged")
jest.spyOn(events.license, "activated")
jest.spyOn(events.license, "checkoutOpened")
diff --git a/packages/backend-core/tests/core/utilities/structures/licenses.ts b/packages/backend-core/tests/core/utilities/structures/licenses.ts
index 24b120451e..810f31cf4f 100644
--- a/packages/backend-core/tests/core/utilities/structures/licenses.ts
+++ b/packages/backend-core/tests/core/utilities/structures/licenses.ts
@@ -7,16 +7,29 @@ import {
PlanType,
PriceDuration,
PurchasedPlan,
+ PurchasedPrice,
Quotas,
Subscription,
} from "@budibase/types"
+export function price(): PurchasedPrice {
+ return {
+ amount: 10000,
+ amountMonthly: 10000,
+ currency: "usd",
+ duration: PriceDuration.MONTHLY,
+ priceId: "price_123",
+ dayPasses: undefined,
+ isPerUser: true,
+ }
+}
+
export const plan = (type: PlanType = PlanType.FREE): PurchasedPlan => {
return {
type,
usesInvoicing: false,
- minUsers: 1,
model: PlanModel.PER_USER,
+ price: price(),
}
}
diff --git a/packages/bbui/package.json b/packages/bbui/package.json
index 6d4ba0a882..ff82bbc2c4 100644
--- a/packages/bbui/package.json
+++ b/packages/bbui/package.json
@@ -1,7 +1,7 @@
{
"name": "@budibase/bbui",
"description": "A UI solution used in the different Budibase projects.",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"license": "MPL-2.0",
"svelte": "src/index.js",
"module": "dist/bbui.es.js",
@@ -38,8 +38,8 @@
],
"dependencies": {
"@adobe/spectrum-css-workflow-icons": "1.2.1",
- "@budibase/shared-core": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
+ "@budibase/shared-core": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
"@spectrum-css/accordion": "3.0.24",
"@spectrum-css/actionbutton": "1.0.1",
"@spectrum-css/actiongroup": "1.0.1",
diff --git a/packages/builder/package.json b/packages/builder/package.json
index ac8a626b0e..0015174bcf 100644
--- a/packages/builder/package.json
+++ b/packages/builder/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/builder",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"license": "GPL-3.0",
"private": true,
"scripts": {
@@ -58,11 +58,10 @@
}
},
"dependencies": {
- "@budibase/bbui": "2.5.6-alpha.30",
- "@budibase/client": "2.5.6-alpha.30",
- "@budibase/frontend-core": "2.5.6-alpha.30",
- "@budibase/shared-core": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
+ "@budibase/bbui": "2.5.6-alpha.42",
+ "@budibase/frontend-core": "2.5.6-alpha.42",
+ "@budibase/shared-core": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
"@fortawesome/fontawesome-svg-core": "^6.2.1",
"@fortawesome/free-brands-svg-icons": "^6.2.1",
"@fortawesome/free-solid-svg-icons": "^6.2.1",
diff --git a/packages/builder/src/builderStore/store/frontend.js b/packages/builder/src/builderStore/store/frontend.js
index 3fc0eb769e..e264dc099b 100644
--- a/packages/builder/src/builderStore/store/frontend.js
+++ b/packages/builder/src/builderStore/store/frontend.js
@@ -134,6 +134,7 @@ export const getFrontendStore = () => {
previousTopNavPath: {},
version: application.version,
revertableVersion: application.revertableVersion,
+ upgradableVersion: application.upgradableVersion,
navigation: application.navigation || {},
usedPlugins: application.usedPlugins || [],
}))
diff --git a/packages/builder/src/components/deploy/VersionModal.svelte b/packages/builder/src/components/deploy/VersionModal.svelte
index f357cc7820..75acc974ce 100644
--- a/packages/builder/src/components/deploy/VersionModal.svelte
+++ b/packages/builder/src/components/deploy/VersionModal.svelte
@@ -9,7 +9,6 @@
} from "@budibase/bbui"
import { store } from "builderStore"
import { API } from "api"
- import clientPackage from "@budibase/client/package.json"
export function show() {
updateModal.show()
@@ -25,9 +24,9 @@
$: appId = $store.appId
$: updateAvailable =
- clientPackage.version &&
+ $store.upgradableVersion &&
$store.version &&
- clientPackage.version !== $store.version
+ $store.upgradableVersion !== $store.version
$: revertAvailable = $store.revertableVersion != null
const refreshAppPackage = async () => {
@@ -46,7 +45,7 @@
// Don't wait for the async refresh, since this causes modal flashing
refreshAppPackage()
notifications.success(
- `App updated successfully to version ${clientPackage.version}`
+ `App updated successfully to version ${$store.upgradableVersion}`
)
} catch (err) {
notifications.error(`Error updating app: ${err}`)
@@ -91,7 +90,7 @@
{#if updateAvailable}
This app is currently using version {$store.version} , but version
- {clientPackage.version} is available. Updates can contain new features,
+ {$store.upgradableVersion} is available. Updates can contain new features,
performance improvements and bug fixes.
{:else}
diff --git a/packages/builder/src/components/usage/Usage.svelte b/packages/builder/src/components/usage/Usage.svelte
index 6e81abfe63..23d8ddc2f3 100644
--- a/packages/builder/src/components/usage/Usage.svelte
+++ b/packages/builder/src/components/usage/Usage.svelte
@@ -27,7 +27,7 @@
onMount(() => {
unlimited = isUnlimited()
percentage = getPercentage()
- if (warnWhenFull && percentage === 100) {
+ if (warnWhenFull && percentage >= 100) {
showWarning = true
}
})
diff --git a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/layouts/[layoutId]/_components/LayoutSettingsPanel.svelte b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/layouts/[layoutId]/_components/LayoutSettingsPanel.svelte
index 8e6ac603e7..bfc2f94f43 100644
--- a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/layouts/[layoutId]/_components/LayoutSettingsPanel.svelte
+++ b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/layouts/[layoutId]/_components/LayoutSettingsPanel.svelte
@@ -35,7 +35,7 @@
}
-
+
Custom layouts are being deprecated. They will be removed in a future
diff --git a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/navigation/_components/NavigationInfoPanel.svelte b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/navigation/_components/NavigationInfoPanel.svelte
index dbd23c462f..614e1eed80 100644
--- a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/navigation/_components/NavigationInfoPanel.svelte
+++ b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/navigation/_components/NavigationInfoPanel.svelte
@@ -9,7 +9,7 @@
}
-
+
{#if $selectedScreen.layoutId}
{#if $selectedScreen.layoutId}
diff --git a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/theme/_components/ThemeInfoPanel.svelte b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/theme/_components/ThemeInfoPanel.svelte
index 9593f0bff5..c3325852c8 100644
--- a/packages/builder/src/pages/builder/app/[application]/design/[screenId]/theme/_components/ThemeInfoPanel.svelte
+++ b/packages/builder/src/pages/builder/app/[application]/design/[screenId]/theme/_components/ThemeInfoPanel.svelte
@@ -3,7 +3,7 @@
import { Body, Layout } from "@budibase/bbui"
-
+
Your theme is set across all the screens within your app.
diff --git a/packages/builder/src/pages/builder/portal/account/usage.svelte b/packages/builder/src/pages/builder/portal/account/usage.svelte
index 80e42d52a8..8dc02c6c80 100644
--- a/packages/builder/src/pages/builder/portal/account/usage.svelte
+++ b/packages/builder/src/pages/builder/portal/account/usage.svelte
@@ -43,12 +43,18 @@
}
$: quotaUsage = $licensing.quotaUsage
+
$: license = $auth.user?.license
+ $: plan = license?.plan
+ $: usesInvoicing = plan?.usesInvoicing
+
$: accountPortalAccess = $auth?.user?.accountPortalAccess
$: quotaReset = quotaUsage?.quotaReset
$: canManagePlan =
($admin.cloud && accountPortalAccess) || (!$admin.cloud && $auth.isAdmin)
+ $: showButton = !usesInvoicing && accountPortalAccess
+
const setMonthlyUsage = () => {
monthlyUsage = []
if (quotaUsage.monthly) {
@@ -121,7 +127,7 @@
const setTextRows = () => {
textRows = []
- if (cancelAt) {
+ if (cancelAt && !usesInvoicing) {
textRows.push({ message: "Subscription has been cancelled" })
textRows.push({
message: `${getDaysRemaining(cancelAt)} days remaining`,
@@ -213,7 +219,7 @@
description="YOUR CURRENT PLAN"
title={planTitle()}
{primaryActionText}
- primaryAction={accountPortalAccess ? goToAccountPortal : undefined}
+ primaryAction={showButton ? goToAccountPortal : undefined}
{textRows}
>
@@ -224,33 +230,23 @@
{/each}
+
+ Monthly limits
+
+
+
+ Resets in {daysRemainingInMonth} days
+
+
+
+
+
+ {#each monthlyUsage as usage}
+
+ {/each}
+
-
- {#if monthlyUsage.length}
-
-
-
- Monthly limits
-
-
-
- Resets in {daysRemainingInMonth} days
-
-
-
-
-
- {#each monthlyUsage as usage}
-
- {/each}
-
-
-
- {/if}
diff --git a/packages/builder/src/pages/builder/portal/overview/[appId]/backups/index.svelte b/packages/builder/src/pages/builder/portal/overview/[appId]/backups/index.svelte
index 4ff9ea386a..77d76c9609 100644
--- a/packages/builder/src/pages/builder/portal/overview/[appId]/backups/index.svelte
+++ b/packages/builder/src/pages/builder/portal/overview/[appId]/backups/index.svelte
@@ -176,7 +176,7 @@
Backups
{#if !$licensing.backupsEnabled}
- Pro plan
+ Premium
{/if}
diff --git a/packages/builder/src/pages/builder/portal/overview/[appId]/overview.svelte b/packages/builder/src/pages/builder/portal/overview/[appId]/overview.svelte
index 2d2b6775fb..c049a610b6 100644
--- a/packages/builder/src/pages/builder/portal/overview/[appId]/overview.svelte
+++ b/packages/builder/src/pages/builder/portal/overview/[appId]/overview.svelte
@@ -13,7 +13,6 @@
notifications,
} from "@budibase/bbui"
import { store } from "builderStore"
- import clientPackage from "@budibase/client/package.json"
import { processStringSync } from "@budibase/string-templates"
import { users, auth, apps, groups, overview } from "stores/portal"
import { fetchData } from "@budibase/frontend-core"
@@ -40,7 +39,7 @@
},
},
})
- $: updateAvailable = clientPackage.version !== $store.version
+ $: updateAvailable = $store.upgradableVersion !== $store.version
$: isPublished = app?.status === AppStatus.DEPLOYED
$: appEditorId = !app?.updatedBy ? $auth.user._id : app?.updatedBy
$: appEditorText = appEditor?.firstName || appEditor?.email
@@ -172,8 +171,8 @@
{$store.version}
{#if updateAvailable}
- New version {clientPackage.version} is available
- -
+ New version {$store.upgradableVersion} is
+ available -
{
$goto("./version")
diff --git a/packages/builder/src/pages/builder/portal/overview/[appId]/version.svelte b/packages/builder/src/pages/builder/portal/overview/[appId]/version.svelte
index 676d0b4f59..723e32984d 100644
--- a/packages/builder/src/pages/builder/portal/overview/[appId]/version.svelte
+++ b/packages/builder/src/pages/builder/portal/overview/[appId]/version.svelte
@@ -1,12 +1,11 @@
@@ -18,7 +17,7 @@
{#if updateAvailable}
The app is currently using version {$store.version}
- but version {clientPackage.version} is available.
+ but version {$store.upgradableVersion} is available.
Updates can contain new features, performance improvements and bug fixes.
diff --git a/packages/builder/src/pages/builder/portal/settings/auth/index.svelte b/packages/builder/src/pages/builder/portal/settings/auth/index.svelte
index 60f84049a3..38f5e0788b 100644
--- a/packages/builder/src/pages/builder/portal/settings/auth/index.svelte
+++ b/packages/builder/src/pages/builder/portal/settings/auth/index.svelte
@@ -378,7 +378,7 @@
{#if !$licensing.enforceableSSO}
- Enterprise plan
+ Enterprise
{/if}
diff --git a/packages/builder/src/pages/builder/portal/settings/branding.svelte b/packages/builder/src/pages/builder/portal/settings/branding.svelte
index 2184280e89..ae22d310a1 100644
--- a/packages/builder/src/pages/builder/portal/settings/branding.svelte
+++ b/packages/builder/src/pages/builder/portal/settings/branding.svelte
@@ -213,7 +213,7 @@
{/if}
{#if isCloud && !brandingEnabled}
- Pro
+ Premium
{/if}
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 1a0bad7b11..6abc63811f 100644
--- a/packages/builder/src/pages/builder/portal/users/groups/index.svelte
+++ b/packages/builder/src/pages/builder/portal/users/groups/index.svelte
@@ -94,7 +94,7 @@
Groups
{#if !$licensing.groupsEnabled}
- Pro plan
+ Business
{/if}
diff --git a/packages/builder/src/pages/builder/portal/users/users/_components/ImportUsersModal.svelte b/packages/builder/src/pages/builder/portal/users/users/_components/ImportUsersModal.svelte
index be0023ec21..b35c6c998f 100644
--- a/packages/builder/src/pages/builder/portal/users/users/_components/ImportUsersModal.svelte
+++ b/packages/builder/src/pages/builder/portal/users/users/_components/ImportUsersModal.svelte
@@ -25,7 +25,7 @@
$: invalidEmails = []
$: userCount = $licensing.userCount + userEmails.length
- $: willExceed = userCount > $licensing.userLimit
+ $: willExceed = licensing.willExceedUserLimit(userCount)
$: importDisabled =
!userEmails.length || !validEmails(userEmails) || !usersRole || willExceed
diff --git a/packages/builder/src/stores/portal/users.js b/packages/builder/src/stores/portal/users.js
index d223239f67..898d47c0e2 100644
--- a/packages/builder/src/stores/portal/users.js
+++ b/packages/builder/src/stores/portal/users.js
@@ -114,11 +114,13 @@ export function createUsersStore() {
const getUserRole = ({ admin, builder }) =>
admin?.global ? "admin" : builder?.global ? "developer" : "appUser"
- const refreshUsage = fn => async args => {
- const response = await fn(args)
- await licensing.setQuotaUsage()
- return response
- }
+ const refreshUsage =
+ fn =>
+ async (...args) => {
+ const response = await fn(...args)
+ await licensing.setQuotaUsage()
+ return response
+ }
return {
subscribe,
@@ -133,7 +135,7 @@ export function createUsersStore() {
updateInvite,
getUserCountByApp,
// any operation that adds or deletes users
- acceptInvite: refreshUsage(acceptInvite),
+ acceptInvite,
create: refreshUsage(create),
save: refreshUsage(save),
bulkDelete: refreshUsage(bulkDelete),
diff --git a/packages/cli/package.json b/packages/cli/package.json
index bdb41bec15..87f8885baa 100644
--- a/packages/cli/package.json
+++ b/packages/cli/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/cli",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase CLI, for developers, self hosting and migrations.",
"main": "dist/index.js",
"bin": {
@@ -29,9 +29,9 @@
"outputPath": "build"
},
"dependencies": {
- "@budibase/backend-core": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
- "@budibase/types": "2.5.6-alpha.30",
+ "@budibase/backend-core": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
+ "@budibase/types": "2.5.6-alpha.42",
"axios": "0.21.2",
"chalk": "4.1.0",
"cli-progress": "3.11.2",
diff --git a/packages/client/manifest.json b/packages/client/manifest.json
index 84ffca314c..71637723c1 100644
--- a/packages/client/manifest.json
+++ b/packages/client/manifest.json
@@ -5225,36 +5225,5 @@
"type": "schema",
"suffix": "repeater"
}
- },
- "spreadsheet": {
- "name": "Spreadsheet",
- "icon": "ViewGrid",
- "settings": [
- {
- "key": "table",
- "type": "table",
- "label": "Table"
- },
- {
- "type": "filter",
- "label": "Filtering",
- "key": "filter"
- },
- {
- "type": "field/sortable",
- "label": "Sort Column",
- "key": "sortColumn"
- },
- {
- "type": "select",
- "label": "Sort Order",
- "key": "sortOrder",
- "options": [
- "Ascending",
- "Descending"
- ],
- "defaultValue": "Ascending"
- }
- ]
}
}
diff --git a/packages/client/package.json b/packages/client/package.json
index 66bd6d4c1e..7ff0ddae9c 100644
--- a/packages/client/package.json
+++ b/packages/client/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/client",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"license": "MPL-2.0",
"module": "dist/budibase-client.js",
"main": "dist/budibase-client.js",
@@ -19,11 +19,11 @@
"dev:builder": "rollup -cw"
},
"dependencies": {
- "@budibase/bbui": "2.5.6-alpha.30",
- "@budibase/frontend-core": "2.5.6-alpha.30",
- "@budibase/shared-core": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
- "@budibase/types": "2.5.6-alpha.30",
+ "@budibase/bbui": "2.5.6-alpha.42",
+ "@budibase/frontend-core": "2.5.6-alpha.42",
+ "@budibase/shared-core": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
+ "@budibase/types": "2.5.6-alpha.42",
"@spectrum-css/button": "^3.0.3",
"@spectrum-css/card": "^3.0.3",
"@spectrum-css/divider": "^1.0.3",
diff --git a/packages/frontend-core/package.json b/packages/frontend-core/package.json
index 3f5345ef94..c0b60cb091 100644
--- a/packages/frontend-core/package.json
+++ b/packages/frontend-core/package.json
@@ -1,13 +1,13 @@
{
"name": "@budibase/frontend-core",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase frontend core libraries used in builder and client",
"author": "Budibase",
"license": "MPL-2.0",
"svelte": "src/index.js",
"dependencies": {
- "@budibase/bbui": "2.5.6-alpha.30",
- "@budibase/shared-core": "2.5.6-alpha.30",
+ "@budibase/bbui": "2.5.6-alpha.42",
+ "@budibase/shared-core": "2.5.6-alpha.42",
"dayjs": "^1.11.7",
"lodash": "^4.17.21",
"socket.io-client": "^4.6.1",
diff --git a/packages/frontend-core/src/components/grid/cells/DataCell.svelte b/packages/frontend-core/src/components/grid/cells/DataCell.svelte
index 5a2e02340f..0aa0cd54f4 100644
--- a/packages/frontend-core/src/components/grid/cells/DataCell.svelte
+++ b/packages/frontend-core/src/components/grid/cells/DataCell.svelte
@@ -19,6 +19,7 @@
export let updateValue = rows.actions.updateValue
export let invertX = false
export let invertY = false
+ export let contentLines = 1
const emptyError = writable(null)
@@ -84,5 +85,7 @@
{readonly}
{invertY}
{invertX}
+ {contentLines}
/>
+
diff --git a/packages/frontend-core/src/components/grid/cells/GridCell.svelte b/packages/frontend-core/src/components/grid/cells/GridCell.svelte
index dfc53f6f0c..6589c18d07 100644
--- a/packages/frontend-core/src/components/grid/cells/GridCell.svelte
+++ b/packages/frontend-core/src/components/grid/cells/GridCell.svelte
@@ -117,6 +117,9 @@
.cell.error {
--cell-color: var(--spectrum-global-color-red-500);
}
+ .cell.readonly {
+ --cell-color: var(--spectrum-global-color-gray-600);
+ }
.cell:not(.focused) {
user-select: none;
}
diff --git a/packages/frontend-core/src/components/grid/cells/HeaderCell.svelte b/packages/frontend-core/src/components/grid/cells/HeaderCell.svelte
index 165711c51f..72b0ad0ff1 100644
--- a/packages/frontend-core/src/components/grid/cells/HeaderCell.svelte
+++ b/packages/frontend-core/src/components/grid/cells/HeaderCell.svelte
@@ -37,6 +37,8 @@
$: sortedBy = column.name === $sort.column
$: canMoveLeft = orderable && idx > 0
$: canMoveRight = orderable && idx < $renderedColumns.length - 1
+ $: ascendingLabel = column.schema?.type === "number" ? "low-high" : "A-Z"
+ $: descendingLabel = column.schema?.type === "number" ? "high-low" : "Z-A"
const editColumn = () => {
dispatch("edit-column", column.schema)
@@ -179,14 +181,14 @@
on:click={sortAscending}
disabled={column.name === $sort.column && $sort.order === "ascending"}
>
- Sort A-Z
+ Sort {ascendingLabel}
- Sort Z-A
+ Sort {descendingLabel}
Move left
diff --git a/packages/frontend-core/src/components/grid/cells/LongFormCell.svelte b/packages/frontend-core/src/components/grid/cells/LongFormCell.svelte
index 00e12dc6a3..886d4ef8b0 100644
--- a/packages/frontend-core/src/components/grid/cells/LongFormCell.svelte
+++ b/packages/frontend-core/src/components/grid/cells/LongFormCell.svelte
@@ -1,5 +1,6 @@
-
+
diff --git a/packages/frontend-core/src/components/grid/cells/OptionsCell.svelte b/packages/frontend-core/src/components/grid/cells/OptionsCell.svelte
index f3b6b9b59d..9399617eb7 100644
--- a/packages/frontend-core/src/components/grid/cells/OptionsCell.svelte
+++ b/packages/frontend-core/src/components/grid/cells/OptionsCell.svelte
@@ -1,5 +1,5 @@
+
+
+ {#each parsedKeys as key}
+
+ {key}
+
+ {/each}
+
+
+
diff --git a/packages/frontend-core/src/components/grid/layout/NewRow.svelte b/packages/frontend-core/src/components/grid/layout/NewRow.svelte
index 54fef78301..71c390c946 100644
--- a/packages/frontend-core/src/components/grid/layout/NewRow.svelte
+++ b/packages/frontend-core/src/components/grid/layout/NewRow.svelte
@@ -7,6 +7,7 @@
import { GutterWidth } from "../lib/constants"
import { NewRowID } from "../lib/constants"
import GutterCell from "../cells/GutterCell.svelte"
+ import KeyboardShortcut from "./KeyboardShortcut.svelte"
const {
hoveredRowId,
@@ -27,13 +28,14 @@
columnHorizontalInversionIndex,
} = getContext("grid")
+ let visible = false
let isAdding = false
let newRow = {}
let offset = 0
$: firstColumn = $stickyColumn || $renderedColumns[0]
$: width = GutterWidth + ($stickyColumn?.width || 0)
- $: $tableId, (isAdding = false)
+ $: $tableId, (visible = false)
$: invertY = shouldInvertY(offset, $rowVerticalInversionIndex, $renderedRows)
const shouldInvertY = (offset, inversionIndex, rows) => {
@@ -45,7 +47,8 @@
const addRow = async () => {
// Blur the active cell and tick to let final value updates propagate
- $focusedCellAPI?.blur()
+ isAdding = true
+ $focusedCellId = null
await tick()
// Create row
@@ -60,17 +63,19 @@
$focusedCellId = `${savedRow._id}-${firstColumn.name}`
}
}
+ isAdding = false
}
const clear = () => {
isAdding = false
+ visible = false
$focusedCellId = null
$hoveredRowId = null
document.removeEventListener("keydown", handleKeyPress)
}
const startAdding = async () => {
- if (isAdding) {
+ if (visible) {
return
}
@@ -95,7 +100,7 @@
// Update state and select initial cell
newRow = {}
- isAdding = true
+ visible = true
$hoveredRowId = NewRowID
if (firstColumn) {
$focusedCellId = `${NewRowID}-${firstColumn.name}`
@@ -115,7 +120,7 @@
}
const handleKeyPress = e => {
- if (!isAdding) {
+ if (!visible) {
return
}
if (e.key === "Escape") {
@@ -137,7 +142,7 @@
-{#if isAdding}
+{#if visible}
0}
@@ -148,6 +153,9 @@
+ {#if isAdding}
+
+ {/if}
{#if $stickyColumn}
{@const cellId = `${NewRowID}-${$stickyColumn.name}`}
@@ -161,7 +169,14 @@
{updateValue}
rowIdx={0}
{invertY}
- />
+ >
+ {#if $stickyColumn?.schema?.autocolumn}
+
Can't edit auto column
+ {/if}
+ {#if isAdding}
+
+ {/if}
+
{/if}
@@ -181,15 +196,32 @@
rowIdx={0}
invertX={columnIdx >= $columnHorizontalInversionIndex}
{invertY}
- />
+ >
+ {#if column?.schema?.autocolumn}
+
Can't edit auto column
+ {/if}
+ {#if isAdding}
+
+ {/if}
+
{/key}
{/each}
{/if}
@@ -240,6 +272,14 @@
top: calc(var(--row-height) + var(--offset) + 24px);
left: var(--gutter-width);
}
+ .button-with-keys {
+ display: flex;
+ gap: 6px;
+ align-items: center;
+ }
+ .button-with-keys :global(> div) {
+ padding-top: 2px;
+ }
/* Sticky column styles */
.sticky-column {
@@ -262,4 +302,33 @@
width: 0;
display: flex;
}
+
+ /* Readonly cell overlay */
+ .readonly-overlay {
+ position: absolute;
+ top: 0;
+ left: 0;
+ height: var(--row-height);
+ width: 100%;
+ padding: var(--cell-padding);
+ font-style: italic;
+ color: var(--spectrum-global-color-gray-600);
+ z-index: 1;
+ user-select: none;
+ overflow: hidden;
+ white-space: nowrap;
+ text-overflow: ellipsis;
+ }
+
+ /* Overlay while row is being added */
+ .loading-overlay {
+ position: absolute;
+ top: 0;
+ left: 0;
+ height: var(--row-height);
+ width: 100%;
+ z-index: 1;
+ background: var(--spectrum-global-color-gray-400);
+ opacity: 0.25;
+ }
diff --git a/packages/frontend-core/src/components/grid/layout/StickyColumn.svelte b/packages/frontend-core/src/components/grid/layout/StickyColumn.svelte
index 6f10c30695..6301112110 100644
--- a/packages/frontend-core/src/components/grid/layout/StickyColumn.svelte
+++ b/packages/frontend-core/src/components/grid/layout/StickyColumn.svelte
@@ -7,6 +7,7 @@
import HeaderCell from "../cells/HeaderCell.svelte"
import { GutterWidth, BlankRowID } from "../lib/constants"
import GutterCell from "../cells/GutterCell.svelte"
+ import KeyboardShortcut from "./KeyboardShortcut.svelte"
const {
rows,
@@ -21,6 +22,7 @@
focusedRow,
scrollLeft,
dispatch,
+ contentLines,
} = getContext("grid")
$: rowCount = $rows.length
@@ -85,6 +87,7 @@
selectedUser={$selectedCellMap[cellId]}
width={$stickyColumn.width}
column={$stickyColumn}
+ contentLines={$contentLines}
/>
{/if}
@@ -103,7 +106,9 @@
+ >
+
+
{/if}
{/if}
diff --git a/packages/frontend-core/src/components/grid/overlays/KeyboardManager.svelte b/packages/frontend-core/src/components/grid/overlays/KeyboardManager.svelte
index e0e842dc16..f0f56118d9 100644
--- a/packages/frontend-core/src/components/grid/overlays/KeyboardManager.svelte
+++ b/packages/frontend-core/src/components/grid/overlays/KeyboardManager.svelte
@@ -15,8 +15,22 @@
selectedRows,
} = getContext("grid")
+ const ignoredOriginSelectors = [
+ ".spectrum-Modal",
+ "#builder-side-panel-container",
+ ]
+
// Global key listener which intercepts all key events
const handleKeyDown = e => {
+ // Avoid processing events sourced from certain origins
+ if (e.target?.closest) {
+ for (let selector of ignoredOriginSelectors) {
+ if (e.target.closest(selector)) {
+ return
+ }
+ }
+ }
+
// If nothing selected avoid processing further key presses
if (!$focusedCellId) {
if (e.key === "Tab" || e.key?.startsWith("Arrow")) {
@@ -60,11 +74,6 @@
return
}
}
-
- // Avoid processing events sourced from modals
- if (e.target?.closest?.(".spectrum-Modal")) {
- return
- }
e.preventDefault()
// Handle the key ourselves
diff --git a/packages/sdk/package.json b/packages/sdk/package.json
index 0307ebfa6b..13cc20f9e9 100644
--- a/packages/sdk/package.json
+++ b/packages/sdk/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/sdk",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase Public API SDK",
"author": "Budibase",
"license": "MPL-2.0",
diff --git a/packages/server/package.json b/packages/server/package.json
index 6aadfd15a0..cc8a8208dc 100644
--- a/packages/server/package.json
+++ b/packages/server/package.json
@@ -1,7 +1,7 @@
{
"name": "@budibase/server",
"email": "hi@budibase.com",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase Web Server",
"main": "src/index.ts",
"repository": {
@@ -45,12 +45,12 @@
"license": "GPL-3.0",
"dependencies": {
"@apidevtools/swagger-parser": "10.0.3",
- "@budibase/backend-core": "2.5.6-alpha.30",
- "@budibase/client": "2.5.6-alpha.30",
- "@budibase/pro": "2.5.6-alpha.30",
- "@budibase/shared-core": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
- "@budibase/types": "2.5.6-alpha.30",
+ "@budibase/backend-core": "2.5.6-alpha.42",
+ "@budibase/client": "2.5.6-alpha.42",
+ "@budibase/pro": "2.5.6-alpha.42",
+ "@budibase/shared-core": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
+ "@budibase/types": "2.5.6-alpha.42",
"@bull-board/api": "3.7.0",
"@bull-board/koa": "3.9.4",
"@elastic/elasticsearch": "7.10.0",
diff --git a/packages/server/src/api/controllers/application.ts b/packages/server/src/api/controllers/application.ts
index ec68ca4c72..ff0dbe015b 100644
--- a/packages/server/src/api/controllers/application.ts
+++ b/packages/server/src/api/controllers/application.ts
@@ -223,7 +223,7 @@ export async function fetchAppPackage(ctx: UserCtx) {
)
ctx.body = {
- application,
+ application: { ...application, upgradableVersion: envCore.VERSION },
screens,
layouts,
clientLibPath,
diff --git a/packages/server/src/api/controllers/datasource.ts b/packages/server/src/api/controllers/datasource.ts
index 3d41cd89af..b61b168980 100644
--- a/packages/server/src/api/controllers/datasource.ts
+++ b/packages/server/src/api/controllers/datasource.ts
@@ -12,7 +12,15 @@ import { getIntegration } from "../../integrations"
import { getDatasourceAndQuery } from "./row/utils"
import { invalidateDynamicVariables } from "../../threads/utils"
import { db as dbCore, context, events } from "@budibase/backend-core"
-import { UserCtx, Datasource, Row } from "@budibase/types"
+import {
+ UserCtx,
+ Datasource,
+ Row,
+ CreateDatasourceResponse,
+ UpdateDatasourceResponse,
+ UpdateDatasourceRequest,
+ CreateDatasourceRequest,
+} from "@budibase/types"
import sdk from "../../sdk"
export async function fetch(ctx: UserCtx) {
@@ -146,7 +154,7 @@ async function invalidateVariables(
await invalidateDynamicVariables(toInvalidate)
}
-export async function update(ctx: UserCtx) {
+export async function update(ctx: UserCtx) {
const db = context.getAppDB()
const datasourceId = ctx.params.datasourceId
let datasource = await sdk.datasources.get(datasourceId)
@@ -187,15 +195,17 @@ export async function update(ctx: UserCtx) {
}
}
-export async function save(ctx: UserCtx) {
+export async function save(
+ ctx: UserCtx
+) {
const db = context.getAppDB()
const plus = ctx.request.body.datasource.plus
const fetchSchema = ctx.request.body.fetchSchema
const datasource = {
_id: generateDatasourceID({ plus }),
- type: plus ? DocumentType.DATASOURCE_PLUS : DocumentType.DATASOURCE,
...ctx.request.body.datasource,
+ type: plus ? DocumentType.DATASOURCE_PLUS : DocumentType.DATASOURCE,
}
let schemaError = null
@@ -218,7 +228,7 @@ export async function save(ctx: UserCtx) {
}
}
- const response: any = {
+ const response: CreateDatasourceResponse = {
datasource: await sdk.datasources.removeSecretSingle(datasource),
}
if (schemaError) {
diff --git a/packages/server/src/db/utils.ts b/packages/server/src/db/utils.ts
index 50341e4abc..e08392c3a1 100644
--- a/packages/server/src/db/utils.ts
+++ b/packages/server/src/db/utils.ts
@@ -27,6 +27,7 @@ export const isProdAppID = dbCore.isProdAppID
export const USER_METDATA_PREFIX = `${DocumentType.ROW}${SEPARATOR}${dbCore.InternalTable.USER_METADATA}${SEPARATOR}`
export const LINK_USER_METADATA_PREFIX = `${DocumentType.LINK}${SEPARATOR}${dbCore.InternalTable.USER_METADATA}${SEPARATOR}`
export const TABLE_ROW_PREFIX = `${DocumentType.ROW}${SEPARATOR}${DocumentType.TABLE}`
+export const AUTOMATION_LOG_PREFIX = `${DocumentType.AUTOMATION_LOG}${SEPARATOR}`
export const ViewName = dbCore.ViewName
export const InternalTables = dbCore.InternalTable
export const UNICODE_MAX = dbCore.UNICODE_MAX
diff --git a/packages/server/src/integration-test/postgres.spec.ts b/packages/server/src/integration-test/postgres.spec.ts
index 36285e2831..78075b4e54 100644
--- a/packages/server/src/integration-test/postgres.spec.ts
+++ b/packages/server/src/integration-test/postgres.spec.ts
@@ -349,7 +349,7 @@ describe("row api - postgres", () => {
},
plus: true,
source: "POSTGRES",
- type: "datasource",
+ type: "datasource_plus",
_id: expect.any(String),
_rev: expect.any(String),
createdAt: expect.any(String),
diff --git a/packages/server/src/sdk/app/backups/exports.ts b/packages/server/src/sdk/app/backups/exports.ts
index 27a907fceb..57342e7462 100644
--- a/packages/server/src/sdk/app/backups/exports.ts
+++ b/packages/server/src/sdk/app/backups/exports.ts
@@ -3,6 +3,7 @@ import { budibaseTempDir } from "../../../utilities/budibaseDir"
import { streamFile, createTempFolder } from "../../../utilities/fileSystem"
import { ObjectStoreBuckets } from "../../../constants"
import {
+ AUTOMATION_LOG_PREFIX,
LINK_USER_METADATA_PREFIX,
TABLE_ROW_PREFIX,
USER_METDATA_PREFIX,
@@ -20,11 +21,15 @@ const uuid = require("uuid/v4")
const tar = require("tar")
const MemoryStream = require("memorystream")
-type ExportOpts = {
+interface DBDumpOpts {
filter?: any
exportPath?: string
+}
+
+interface ExportOpts extends DBDumpOpts {
tar?: boolean
excludeRows?: boolean
+ excludeLogs?: boolean
}
function tarFilesToTmp(tmpDir: string, files: string[]) {
@@ -49,7 +54,7 @@ function tarFilesToTmp(tmpDir: string, files: string[]) {
* a filter function or the name of the export.
* @return {*} either a readable stream or a string
*/
-export async function exportDB(dbName: string, opts: ExportOpts = {}) {
+export async function exportDB(dbName: string, opts: DBDumpOpts = {}) {
const exportOpts = {
filter: opts?.filter,
batch_size: 1000,
@@ -76,11 +81,14 @@ export async function exportDB(dbName: string, opts: ExportOpts = {}) {
})
}
-function defineFilter(excludeRows?: boolean) {
+function defineFilter(excludeRows?: boolean, excludeLogs?: boolean) {
const ids = [USER_METDATA_PREFIX, LINK_USER_METADATA_PREFIX]
if (excludeRows) {
ids.push(TABLE_ROW_PREFIX)
}
+ if (excludeLogs) {
+ ids.push(AUTOMATION_LOG_PREFIX)
+ }
return (doc: any) =>
!ids.map(key => doc._id.includes(key)).reduce((prev, curr) => prev || curr)
}
@@ -130,8 +138,7 @@ export async function exportApp(appId: string, config?: ExportOpts) {
// enforce an export of app DB to the tmp path
const dbPath = join(tmpPath, DB_EXPORT_FILE)
await exportDB(appId, {
- ...config,
- filter: defineFilter(config?.excludeRows),
+ filter: defineFilter(config?.excludeRows, config?.excludeLogs),
exportPath: dbPath,
})
// if tar requested, return where the tarball is
@@ -155,6 +162,10 @@ export async function exportApp(appId: string, config?: ExportOpts) {
* @returns {*} a readable stream of the backup which is written in real time
*/
export async function streamExportApp(appId: string, excludeRows: boolean) {
- const tmpPath = await exportApp(appId, { excludeRows, tar: true })
+ const tmpPath = await exportApp(appId, {
+ excludeRows,
+ excludeLogs: true,
+ tar: true,
+ })
return streamFile(tmpPath)
}
diff --git a/packages/shared-core/package.json b/packages/shared-core/package.json
index 75fe1950dc..4ea3deea5f 100644
--- a/packages/shared-core/package.json
+++ b/packages/shared-core/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/shared-core",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Shared data utils",
"main": "dist/cjs/src/index.js",
"types": "dist/mjs/src/index.d.ts",
@@ -20,7 +20,7 @@
"dev:builder": "yarn prebuild && concurrently \"tsc -p tsconfig.build.json --watch\" \"tsc -p tsconfig-cjs.build.json --watch\""
},
"dependencies": {
- "@budibase/types": "2.5.6-alpha.30"
+ "@budibase/types": "2.5.6-alpha.42"
},
"devDependencies": {
"concurrently": "^7.6.0",
diff --git a/packages/string-templates/package.json b/packages/string-templates/package.json
index 30ed86b2a7..e1397182dc 100644
--- a/packages/string-templates/package.json
+++ b/packages/string-templates/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/string-templates",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Handlebars wrapper for Budibase templating.",
"main": "src/index.cjs",
"module": "dist/bundle.mjs",
diff --git a/packages/types/package.json b/packages/types/package.json
index 95f04b8495..3068068d4c 100644
--- a/packages/types/package.json
+++ b/packages/types/package.json
@@ -1,6 +1,6 @@
{
"name": "@budibase/types",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase types",
"main": "dist/cjs/index.js",
"types": "dist/mjs/index.d.ts",
diff --git a/packages/types/src/api/web/app/datasource.ts b/packages/types/src/api/web/app/datasource.ts
new file mode 100644
index 0000000000..d54259eab5
--- /dev/null
+++ b/packages/types/src/api/web/app/datasource.ts
@@ -0,0 +1,19 @@
+import { Datasource } from "../../../documents"
+
+export interface CreateDatasourceResponse {
+ datasource: Datasource
+ error?: any
+}
+
+export interface UpdateDatasourceResponse {
+ datasource: Datasource
+}
+
+export interface CreateDatasourceRequest {
+ datasource: Datasource
+ fetchSchema?: boolean
+}
+
+export interface UpdateDatasourceRequest extends Datasource {
+ datasource: Datasource
+}
diff --git a/packages/types/src/api/web/app/index.ts b/packages/types/src/api/web/app/index.ts
index 1d73755cb6..9be15ecfe3 100644
--- a/packages/types/src/api/web/app/index.ts
+++ b/packages/types/src/api/web/app/index.ts
@@ -1 +1,2 @@
export * from "./backup"
+export * from "./datasource"
diff --git a/packages/types/src/documents/account/account.ts b/packages/types/src/documents/account/account.ts
index 8678085df0..dad8abed30 100644
--- a/packages/types/src/documents/account/account.ts
+++ b/packages/types/src/documents/account/account.ts
@@ -39,6 +39,7 @@ export interface Account extends CreateAccount {
// licensing
tier: string // deprecated
planType?: PlanType
+ /** @deprecated */
planTier?: number
license?: License
installId?: string
@@ -47,6 +48,7 @@ export interface Account extends CreateAccount {
stripeCustomerId?: string
licenseKey?: string
licenseKeyActivatedAt?: number
+ licenseRequestedAt?: number
licenseOverrides?: LicenseOverrides
quotaUsage?: QuotaUsage
}
diff --git a/packages/types/src/documents/app/query.ts b/packages/types/src/documents/app/query.ts
index 72b6c288a5..31a3a3ba09 100644
--- a/packages/types/src/documents/app/query.ts
+++ b/packages/types/src/documents/app/query.ts
@@ -42,3 +42,10 @@ export interface PaginationValues {
page: string | number | null
limit: number | null
}
+
+export interface PreviewQueryRequest extends Omit {
+ parameters: {}
+ flags?: {
+ urlName?: boolean
+ }
+}
diff --git a/packages/types/src/sdk/events/event.ts b/packages/types/src/sdk/events/event.ts
index c4990f869b..0d0b166253 100644
--- a/packages/types/src/sdk/events/event.ts
+++ b/packages/types/src/sdk/events/event.ts
@@ -138,7 +138,6 @@ export enum Event {
// LICENSE
LICENSE_PLAN_CHANGED = "license:plan:changed",
- LICENSE_TIER_CHANGED = "license:tier:changed",
LICENSE_ACTIVATED = "license:activated",
LICENSE_PAYMENT_FAILED = "license:payment:failed",
LICENSE_PAYMENT_RECOVERED = "license:payment:recovered",
@@ -328,7 +327,6 @@ export const AuditedEventFriendlyName: Record = {
// LICENSE - NOT AUDITED
[Event.LICENSE_PLAN_CHANGED]: undefined,
- [Event.LICENSE_TIER_CHANGED]: undefined,
[Event.LICENSE_ACTIVATED]: undefined,
[Event.LICENSE_PAYMENT_FAILED]: undefined,
[Event.LICENSE_PAYMENT_RECOVERED]: undefined,
diff --git a/packages/types/src/sdk/events/license.ts b/packages/types/src/sdk/events/license.ts
index a12fc6bbb5..b92c556cc8 100644
--- a/packages/types/src/sdk/events/license.ts
+++ b/packages/types/src/sdk/events/license.ts
@@ -1,15 +1,15 @@
-import { PlanType } from "../licensing"
-
-export interface LicenseTierChangedEvent {
- accountId: string
- from: number
- to: number
-}
+import { PlanType, PriceDuration } from "../licensing"
export interface LicensePlanChangedEvent {
accountId: string
from: PlanType
to: PlanType
+ // may not be on historical events
+ // free plans won't have a duration
+ duration: PriceDuration | undefined
+ // may not be on historical events
+ // free plans won't have a quantity
+ quantity: number | undefined
}
export interface LicenseActivatedEvent {
diff --git a/packages/types/src/sdk/licensing/plan.ts b/packages/types/src/sdk/licensing/plan.ts
index 360d7d08e5..3e214a01ff 100644
--- a/packages/types/src/sdk/licensing/plan.ts
+++ b/packages/types/src/sdk/licensing/plan.ts
@@ -17,7 +17,6 @@ export enum PriceDuration {
export interface AvailablePlan {
type: PlanType
maxUsers: number
- minUsers: number
prices: AvailablePrice[]
}
@@ -38,7 +37,6 @@ export interface PurchasedPlan {
type: PlanType
model: PlanModel
usesInvoicing: boolean
- minUsers: number
price?: PurchasedPrice
}
diff --git a/packages/types/src/sdk/licensing/quota.ts b/packages/types/src/sdk/licensing/quota.ts
index ea51f7a490..73afa1ed05 100644
--- a/packages/types/src/sdk/licensing/quota.ts
+++ b/packages/types/src/sdk/licensing/quota.ts
@@ -55,12 +55,6 @@ export const isConstantQuota = (
return quotaType === QuotaType.CONSTANT
}
-export interface Minimums {
- users: number
-}
-
-export type PlanMinimums = { [key in PlanType]: Minimums }
-
export type PlanQuotas = { [key in PlanType]: Quotas | undefined }
export type MonthlyQuotas = {
diff --git a/packages/worker/package.json b/packages/worker/package.json
index c0d50cab28..ae9358f084 100644
--- a/packages/worker/package.json
+++ b/packages/worker/package.json
@@ -1,7 +1,7 @@
{
"name": "@budibase/worker",
"email": "hi@budibase.com",
- "version": "2.5.6-alpha.30",
+ "version": "2.5.6-alpha.42",
"description": "Budibase background service",
"main": "src/index.ts",
"repository": {
@@ -37,10 +37,10 @@
"author": "Budibase",
"license": "GPL-3.0",
"dependencies": {
- "@budibase/backend-core": "2.5.6-alpha.30",
- "@budibase/pro": "2.5.6-alpha.30",
- "@budibase/string-templates": "2.5.6-alpha.30",
- "@budibase/types": "2.5.6-alpha.30",
+ "@budibase/backend-core": "2.5.6-alpha.42",
+ "@budibase/pro": "2.5.6-alpha.42",
+ "@budibase/string-templates": "2.5.6-alpha.42",
+ "@budibase/types": "2.5.6-alpha.42",
"@koa/router": "8.0.8",
"@sentry/node": "6.17.7",
"@techpass/passport-openidconnect": "0.3.2",
diff --git a/packages/worker/src/api/controllers/global/users.ts b/packages/worker/src/api/controllers/global/users.ts
index 8db2d29691..d9ebc87517 100644
--- a/packages/worker/src/api/controllers/global/users.ts
+++ b/packages/worker/src/api/controllers/global/users.ts
@@ -424,7 +424,9 @@ export const inviteAccept = async (
if (err.code === ErrorCode.USAGE_LIMIT_EXCEEDED) {
// explicitly re-throw limit exceeded errors
ctx.throw(400, err)
+ return
}
+ console.warn("Error inviting user", err)
ctx.throw(400, "Unable to create new user, invitation invalid.")
}
}
diff --git a/packages/worker/src/sdk/accounts/metadata.ts b/packages/worker/src/sdk/accounts/metadata.ts
index 64065e8b78..11ab069839 100644
--- a/packages/worker/src/sdk/accounts/metadata.ts
+++ b/packages/worker/src/sdk/accounts/metadata.ts
@@ -18,8 +18,17 @@ export const saveMetadata = async (
if (existing) {
metadata._rev = existing._rev
}
- const res = await db.put(metadata)
- metadata._rev = res.rev
+ try {
+ const res = await db.put(metadata)
+ metadata._rev = res.rev
+ } catch (e: any) {
+ // account can be updated frequently
+ // ignore 409
+ if (e.status !== 409) {
+ throw e
+ }
+ }
+
return metadata
})
}
diff --git a/qa-core/src/environment.ts b/qa-core/src/environment.ts
index 734d057475..0257b10831 100644
--- a/qa-core/src/environment.ts
+++ b/qa-core/src/environment.ts
@@ -14,6 +14,20 @@ const env = {
ACCOUNT_PORTAL_API_KEY: process.env.ACCOUNT_PORTAL_API_KEY,
BB_ADMIN_USER_EMAIL: process.env.BB_ADMIN_USER_EMAIL,
BB_ADMIN_USER_PASSWORD: process.env.BB_ADMIN_USER_PASSWORD,
+ POSTGRES_HOST: process.env.POSTGRES_HOST,
+ POSTGRES_PORT: process.env.POSTGRES_PORT,
+ POSTGRES_DB: process.env.POSTGRES_DB,
+ POSTGRES_USER: process.env.POSTGRES_USER,
+ POSTGRES_PASSWORD: process.env.POSTGRES_PASSWORD,
+ MONGODB_CONNECTION_STRING: process.env.MONGODB_CONNECTION_STRING,
+ MONGODB_DB: process.env.MONGODB_DB,
+ REST_API_BASE_URL: process.env.REST_API_BASE_URL,
+ REST_API_KEY: process.env.REST_API_KEY,
+ MARIADB_HOST: process.env.MARIADB_HOST,
+ MARIADB_PORT: process.env.MARIADB_PORT,
+ MARIADB_DB: process.env.MARIADB_DB,
+ MARIADB_USER: process.env.MARIADB_USER,
+ MARIADB_PASSWORD: process.env.MARIADB_PASSWORD,
}
export = env
diff --git a/qa-core/src/internal-api/api/BudibaseInternalAPI.ts b/qa-core/src/internal-api/api/BudibaseInternalAPI.ts
index 5bb6b72ef0..316775b1b9 100644
--- a/qa-core/src/internal-api/api/BudibaseInternalAPI.ts
+++ b/qa-core/src/internal-api/api/BudibaseInternalAPI.ts
@@ -7,6 +7,10 @@ import ScreenAPI from "./apis/ScreenAPI"
import SelfAPI from "./apis/SelfAPI"
import TableAPI from "./apis/TableAPI"
import UserAPI from "./apis/UserAPI"
+import DatasourcesAPI from "./apis/DatasourcesAPI"
+import IntegrationsAPI from "./apis/IntegrationsAPI"
+import QueriesAPI from "./apis/QueriesAPI"
+import PermissionsAPI from "./apis/PermissionsAPI"
import BudibaseInternalAPIClient from "./BudibaseInternalAPIClient"
import { State } from "../../types"
@@ -22,6 +26,10 @@ export default class BudibaseInternalAPI {
self: SelfAPI
tables: TableAPI
users: UserAPI
+ datasources: DatasourcesAPI
+ integrations: IntegrationsAPI
+ queries: QueriesAPI
+ permissions: PermissionsAPI
constructor(state: State) {
this.client = new BudibaseInternalAPIClient(state)
@@ -35,5 +43,9 @@ export default class BudibaseInternalAPI {
this.self = new SelfAPI(this.client)
this.tables = new TableAPI(this.client)
this.users = new UserAPI(this.client)
+ this.datasources = new DatasourcesAPI(this.client)
+ this.integrations = new IntegrationsAPI(this.client)
+ this.queries = new QueriesAPI(this.client)
+ this.permissions = new PermissionsAPI(this.client)
}
}
diff --git a/qa-core/src/internal-api/api/apis/DatasourcesAPI.ts b/qa-core/src/internal-api/api/apis/DatasourcesAPI.ts
new file mode 100644
index 0000000000..f29bb9d6bc
--- /dev/null
+++ b/qa-core/src/internal-api/api/apis/DatasourcesAPI.ts
@@ -0,0 +1,95 @@
+import { Response } from "node-fetch"
+import {
+ Datasource,
+ CreateDatasourceResponse,
+ UpdateDatasourceResponse,
+} from "@budibase/types"
+import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
+
+export default class DatasourcesAPI {
+ client: BudibaseInternalAPIClient
+
+ constructor(client: BudibaseInternalAPIClient) {
+ this.client = client
+ }
+
+ async getIntegrations(): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/integrations`)
+ expect(response).toHaveStatusCode(200)
+ const integrationsCount = Object.keys(json).length
+ expect(integrationsCount).toBe(16)
+ return [response, json]
+ }
+
+ async getAll(): Promise<[Response, Datasource[]]> {
+ const [response, json] = await this.client.get(`/datasources`)
+ expect(response).toHaveStatusCode(200)
+ expect(json.length).toBeGreaterThan(0)
+ return [response, json]
+ }
+
+ async getTable(dataSourceId: string): Promise<[Response, Datasource]> {
+ const [response, json] = await this.client.get(
+ `/datasources/${dataSourceId}`
+ )
+ expect(response).toHaveStatusCode(200)
+ expect(json._id).toEqual(dataSourceId)
+ return [response, json]
+ }
+
+ async add(body: any): Promise<[Response, CreateDatasourceResponse]> {
+ const [response, json] = await this.client.post(`/datasources`, { body })
+ expect(response).toHaveStatusCode(200)
+ expect(json.datasource._id).toBeDefined()
+ expect(json.datasource._rev).toBeDefined()
+
+ return [response, json]
+ }
+
+ async update(body: any): Promise<[Response, UpdateDatasourceResponse]> {
+ const [response, json] = await this.client.put(`/datasources/${body._id}`, {
+ body,
+ })
+ expect(response).toHaveStatusCode(200)
+ expect(json.datasource._id).toBeDefined()
+ expect(json.datasource._rev).toBeDefined()
+
+ return [response, json]
+ }
+
+ async previewQuery(body: any): Promise<[Response, any]> {
+ const [response, json] = await this.client.post(`/queries/preview`, {
+ body,
+ })
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async saveQuery(body: any): Promise<[Response, any]> {
+ const [response, json] = await this.client.post(`/queries`, {
+ body,
+ })
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async getQuery(queryId: string): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/queries/${queryId}`)
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async getQueryPermissions(queryId: string): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/permissions/${queryId}`)
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async delete(dataSourceId: string, revId: string): Promise {
+ const [response, json] = await this.client.del(
+ `/datasources/${dataSourceId}/${revId}`
+ )
+ expect(response).toHaveStatusCode(200)
+ return response
+ }
+}
diff --git a/qa-core/src/internal-api/api/apis/IntegrationsAPI.ts b/qa-core/src/internal-api/api/apis/IntegrationsAPI.ts
new file mode 100644
index 0000000000..2478823bfa
--- /dev/null
+++ b/qa-core/src/internal-api/api/apis/IntegrationsAPI.ts
@@ -0,0 +1,18 @@
+import { Response } from "node-fetch"
+import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
+
+export default class IntegrationsAPI {
+ client: BudibaseInternalAPIClient
+
+ constructor(client: BudibaseInternalAPIClient) {
+ this.client = client
+ }
+
+ async getAll(): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/integrations`)
+ expect(response).toHaveStatusCode(200)
+ const integrationsCount = Object.keys(json).length
+ expect(integrationsCount).toBeGreaterThan(0)
+ return [response, json]
+ }
+}
diff --git a/qa-core/src/internal-api/api/apis/PermissionsAPI.ts b/qa-core/src/internal-api/api/apis/PermissionsAPI.ts
new file mode 100644
index 0000000000..e78ef7560d
--- /dev/null
+++ b/qa-core/src/internal-api/api/apis/PermissionsAPI.ts
@@ -0,0 +1,16 @@
+import { Response } from "node-fetch"
+import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
+
+export default class PermissionsAPI {
+ client: BudibaseInternalAPIClient
+
+ constructor(client: BudibaseInternalAPIClient) {
+ this.client = client
+ }
+
+ async getAll(id: string): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/permissions/${id}`)
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+}
diff --git a/qa-core/src/internal-api/api/apis/QueriesAPI.ts b/qa-core/src/internal-api/api/apis/QueriesAPI.ts
new file mode 100644
index 0000000000..5c8ac9883e
--- /dev/null
+++ b/qa-core/src/internal-api/api/apis/QueriesAPI.ts
@@ -0,0 +1,33 @@
+import { Response } from "node-fetch"
+import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
+import { PreviewQueryRequest, Query } from "@budibase/types"
+
+export default class DatasourcesAPI {
+ client: BudibaseInternalAPIClient
+
+ constructor(client: BudibaseInternalAPIClient) {
+ this.client = client
+ }
+
+ async preview(body: PreviewQueryRequest): Promise<[Response, any]> {
+ const [response, json] = await this.client.post(`/queries/preview`, {
+ body,
+ })
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async save(body: Query): Promise<[Response, any]> {
+ const [response, json] = await this.client.post(`/queries`, {
+ body,
+ })
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+
+ async get(queryId: string): Promise<[Response, any]> {
+ const [response, json] = await this.client.get(`/queries/${queryId}`)
+ expect(response).toHaveStatusCode(200)
+ return [response, json]
+ }
+}
diff --git a/qa-core/src/internal-api/fixtures/datasources.ts b/qa-core/src/internal-api/fixtures/datasources.ts
new file mode 100644
index 0000000000..dcf6af824a
--- /dev/null
+++ b/qa-core/src/internal-api/fixtures/datasources.ts
@@ -0,0 +1,71 @@
+// Add information about the data source to the fixtures file from 1password
+export const mongoDB = () => {
+ return {
+ datasource: {
+ name: "MongoDB",
+ source: "MONGODB",
+ type: "datasource",
+ config: {
+ connectionString: process.env.MONGODB_CONNECTION_STRING,
+ db: process.env.MONGODB_DB,
+ },
+ },
+
+ fetchSchema: false,
+ }
+}
+
+export const postgresSQL = () => {
+ return {
+ datasource: {
+ name: "PostgresSQL",
+ plus: true,
+ source: "POSTGRES",
+ type: "datasource",
+ config: {
+ database: process.env.POSTGRES_DB,
+ host: process.env.POSTGRES_HOST,
+ password: process.env.POSTGRES_PASSWORD,
+ port: process.env.POSTGRES_PORT,
+ schema: "public",
+ user: process.env.POSTGRES_USER,
+ },
+ },
+ fetchSchema: true,
+ }
+}
+export const mariaDB = () => {
+ return {
+ datasource: {
+ name: "MariaDB",
+ plus: true,
+ source: "MYSQL",
+ type: "datasource",
+ config: {
+ database: process.env.MARIADB_DB,
+ host: process.env.MARIADB_HOST,
+ password: process.env.MARIADB_PASSWORD,
+ port: process.env.MARIADB_PORT,
+ schema: "public",
+ user: process.env.MARIADB_USER,
+ },
+ },
+ fetchSchema: true,
+ }
+}
+
+export const restAPI = () => {
+ return {
+ datasource: {
+ name: "RestAPI",
+ source: "REST",
+ type: "datasource",
+ config: {
+ defaultHeaders: {},
+ rejectUnauthorized: true,
+ url: process.env.REST_API_BASE_URL,
+ },
+ },
+ fetchSchema: false,
+ }
+}
diff --git a/qa-core/src/internal-api/fixtures/index.ts b/qa-core/src/internal-api/fixtures/index.ts
index d97c5f76b7..38291052b8 100644
--- a/qa-core/src/internal-api/fixtures/index.ts
+++ b/qa-core/src/internal-api/fixtures/index.ts
@@ -4,3 +4,5 @@ export * as rows from "./rows"
export * as screens from "./screens"
export * as tables from "./tables"
export * as users from "./users"
+export * as datasources from "./datasources"
+export * as queries from "./queries"
diff --git a/qa-core/src/internal-api/fixtures/queries.ts b/qa-core/src/internal-api/fixtures/queries.ts
new file mode 100644
index 0000000000..83839a0b41
--- /dev/null
+++ b/qa-core/src/internal-api/fixtures/queries.ts
@@ -0,0 +1,123 @@
+import { PreviewQueryRequest } from "@budibase/types"
+
+const query = (datasourceId: string, fields: any): any => {
+ return {
+ datasourceId: datasourceId,
+ fields: fields,
+ name: "Query 1",
+ parameters: {},
+ queryVerb: "read",
+ schema: {},
+ transformer: "return data",
+ }
+}
+
+export const mariaDB = (datasourceId: string): PreviewQueryRequest => {
+ const fields = {
+ sql: "SELECT * FROM employees LIMIT 10;",
+ }
+ return query(datasourceId, fields)
+}
+
+export const mongoDB = (datasourceId: string): PreviewQueryRequest => {
+ const fields = {
+ extra: {
+ collection: "movies",
+ actionType: "find",
+ },
+ json: "",
+ }
+ return query(datasourceId, fields)
+}
+
+export const postgres = (datasourceId: string): PreviewQueryRequest => {
+ const fields = {
+ sql: "SELECT * FROM customers;",
+ }
+ return query(datasourceId, fields)
+}
+
+export const expectedSchemaFields = {
+ mariaDB: {
+ birth_date: "string",
+ emp_no: "number",
+ first_name: "string",
+ gender: "string",
+ hire_date: "string",
+ last_name: "string",
+ },
+ mongoDB: {
+ directors: "array",
+ genres: "array",
+ image: "string",
+ plot: "string",
+ rank: "number",
+ rating: "number",
+ release_date: "string",
+ running_time_secs: "number",
+ title: "string",
+ year: "number",
+ _id: "json",
+ },
+ postgres: {
+ address: "string",
+ city: "string",
+ company_name: "string",
+ contact_name: "string",
+ contact_title: "string",
+ country: "string",
+ customer_id: "string",
+ fax: "string",
+ phone: "string",
+ postal_code: "string",
+ region: "string",
+ },
+ restAPI: {
+ abilities: "array",
+ base_experience: "number",
+ forms: "array",
+ game_indices: "array",
+ height: "number",
+ held_items: "array",
+ id: "number",
+ is_default: "string",
+ location_area_encounters: "string",
+ moves: "array",
+ name: "string",
+ order: "number",
+ past_types: "array",
+ species: "json",
+ sprites: "json",
+ stats: "array",
+ types: "array",
+ weight: "number",
+ },
+}
+
+const request = (datasourceId: string, fields: any, flags: any): any => {
+ return {
+ datasourceId: datasourceId,
+ fields: fields,
+ flags: flags,
+ name: "Query 1",
+ parameters: {},
+ queryVerb: "read",
+ schema: {},
+ transformer: "return data",
+ }
+}
+export const restAPI = (datasourceId: string): PreviewQueryRequest => {
+ const fields = {
+ authConfigId: null,
+ bodyType: "none",
+ disabledHeaders: {},
+ headers: {},
+ pagination: {},
+ path: `${process.env.REST_API_BASE_URL}/pokemon/ditto`,
+ queryString: "",
+ }
+ const flags = {
+ urlName: true,
+ }
+ return request(datasourceId, fields, flags)
+}
diff --git a/qa-core/src/internal-api/tests/dataSources/example.spec.ts b/qa-core/src/internal-api/tests/dataSources/example.spec.ts
deleted file mode 100644
index 0b8bc38a45..0000000000
--- a/qa-core/src/internal-api/tests/dataSources/example.spec.ts
+++ /dev/null
@@ -1,27 +0,0 @@
-import TestConfiguration from "../../config/TestConfiguration"
-import * as fixtures from "../../fixtures"
-
-describe("Internal API - Data Sources", () => {
- const config = new TestConfiguration()
-
- beforeAll(async () => {
- await config.beforeAll()
- })
-
- afterAll(async () => {
- await config.afterAll()
- })
-
- it("Create an app with a data source", async () => {
- // Create app
- await config.createApp()
-
- // Create Screen
- const roleArray = ["BASIC", "POWER", "ADMIN", "PUBLIC"]
- for (let role in roleArray) {
- const [response, screen] = await config.api.screens.create(
- fixtures.screens.generateScreen(roleArray[role])
- )
- }
- })
-})
diff --git a/qa-core/src/internal-api/tests/dataSources/mariaDB.spec.ts b/qa-core/src/internal-api/tests/dataSources/mariaDB.spec.ts
new file mode 100644
index 0000000000..44c2c03c8b
--- /dev/null
+++ b/qa-core/src/internal-api/tests/dataSources/mariaDB.spec.ts
@@ -0,0 +1,69 @@
+import TestConfiguration from "../../config/TestConfiguration"
+import * as fixtures from "../../fixtures"
+import { Query } from "@budibase/types"
+
+describe("Internal API - Data Sources: MariaDB", () => {
+ const config = new TestConfiguration()
+
+ beforeAll(async () => {
+ await config.beforeAll()
+ })
+
+ afterAll(async () => {
+ await config.afterAll()
+ })
+
+ it("Create an app with a data source - MariaDB", async () => {
+ // Create app
+ await config.createApp()
+
+ // Get all integrations
+ await config.api.integrations.getAll()
+
+ // Add data source
+ const [dataSourceResponse, dataSourceJson] =
+ await config.api.datasources.add(fixtures.datasources.mariaDB())
+
+ // Update data source
+ const newDataSourceInfo = {
+ ...dataSourceJson.datasource,
+ name: "MariaDB2",
+ }
+ const [updatedDataSourceResponse, updatedDataSourceJson] =
+ await config.api.datasources.update(newDataSourceInfo)
+
+ // Query data source
+ const [queryResponse, queryJson] = await config.api.queries.preview(
+ fixtures.queries.mariaDB(updatedDataSourceJson.datasource._id!)
+ )
+
+ expect(queryJson.rows.length).toEqual(10)
+ expect(queryJson.schemaFields).toEqual(
+ fixtures.queries.expectedSchemaFields.mariaDB
+ )
+
+ // Save query
+ const datasourcetoSave: Query = {
+ ...fixtures.queries.mariaDB(updatedDataSourceJson.datasource._id!),
+ parameters: [],
+ }
+
+ const [saveQueryResponse, saveQueryJson] = await config.api.queries.save(
+ datasourcetoSave
+ )
+ // Get Query
+ const [getQueryResponse, getQueryJson] = await config.api.queries.get(
+ saveQueryJson._id
+ )
+
+ // Get Query permissions
+ const [getQueryPermissionsResponse, getQueryPermissionsJson] =
+ await config.api.permissions.getAll(saveQueryJson._id!)
+
+ // Delete data source
+ const deleteResponse = await config.api.datasources.delete(
+ updatedDataSourceJson.datasource._id!,
+ updatedDataSourceJson.datasource._rev!
+ )
+ })
+})
diff --git a/qa-core/src/internal-api/tests/dataSources/mongoDB.spec.ts b/qa-core/src/internal-api/tests/dataSources/mongoDB.spec.ts
new file mode 100644
index 0000000000..ed5178b57c
--- /dev/null
+++ b/qa-core/src/internal-api/tests/dataSources/mongoDB.spec.ts
@@ -0,0 +1,69 @@
+import TestConfiguration from "../../config/TestConfiguration"
+import * as fixtures from "../../fixtures"
+import { Query } from "@budibase/types"
+
+describe("Internal API - Data Sources: MongoDB", () => {
+ const config = new TestConfiguration()
+
+ beforeAll(async () => {
+ await config.beforeAll()
+ })
+
+ afterAll(async () => {
+ await config.afterAll()
+ })
+
+ it("Create an app with a data source - MongoDB", async () => {
+ // Create app
+ await config.createApp()
+
+ // Get all integrations
+ await config.api.integrations.getAll()
+
+ // Add data source
+ const [dataSourceResponse, dataSourceJson] =
+ await config.api.datasources.add(fixtures.datasources.mongoDB())
+
+ // Update data source
+ const newDataSourceInfo = {
+ ...dataSourceJson.datasource,
+ name: "MongoDB2",
+ }
+ const [updatedDataSourceResponse, updatedDataSourceJson] =
+ await config.api.datasources.update(newDataSourceInfo)
+
+ // Query data source
+ const [queryResponse, queryJson] = await config.api.queries.preview(
+ fixtures.queries.mongoDB(updatedDataSourceJson.datasource._id!)
+ )
+
+ expect(queryJson.rows.length).toBeGreaterThan(10)
+ expect(queryJson.schemaFields).toEqual(
+ fixtures.queries.expectedSchemaFields.mongoDB
+ )
+
+ // Save query
+ const datasourcetoSave: Query = {
+ ...fixtures.queries.mongoDB(updatedDataSourceJson.datasource._id!),
+ parameters: [],
+ }
+
+ const [saveQueryResponse, saveQueryJson] = await config.api.queries.save(
+ datasourcetoSave
+ )
+ // Get Query
+ const [getQueryResponse, getQueryJson] = await config.api.queries.get(
+ saveQueryJson._id
+ )
+
+ // Get Query permissions
+ const [getQueryPermissionsResponse, getQueryPermissionsJson] =
+ await config.api.permissions.getAll(saveQueryJson._id!)
+
+ // Delete data source
+ const deleteResponse = await config.api.datasources.delete(
+ updatedDataSourceJson.datasource._id!,
+ updatedDataSourceJson.datasource._rev!
+ )
+ })
+})
diff --git a/qa-core/src/internal-api/tests/dataSources/postgresSQL.spec.ts b/qa-core/src/internal-api/tests/dataSources/postgresSQL.spec.ts
new file mode 100644
index 0000000000..bc8d86b862
--- /dev/null
+++ b/qa-core/src/internal-api/tests/dataSources/postgresSQL.spec.ts
@@ -0,0 +1,69 @@
+import TestConfiguration from "../../config/TestConfiguration"
+import * as fixtures from "../../fixtures"
+import { Query } from "@budibase/types"
+
+describe("Internal API - Data Sources: PostgresSQL", () => {
+ const config = new TestConfiguration()
+
+ beforeAll(async () => {
+ await config.beforeAll()
+ })
+
+ afterAll(async () => {
+ await config.afterAll()
+ })
+
+ it("Create an app with a data source - PostgresSQL", async () => {
+ // Create app
+ await config.createApp()
+
+ // Get all integrations
+ await config.api.integrations.getAll()
+
+ // Add data source
+ const [dataSourceResponse, dataSourceJson] =
+ await config.api.datasources.add(fixtures.datasources.postgresSQL())
+
+ // Update data source
+ const newDataSourceInfo = {
+ ...dataSourceJson.datasource,
+ name: "PostgresSQL2",
+ }
+ const [updatedDataSourceResponse, updatedDataSourceJson] =
+ await config.api.datasources.update(newDataSourceInfo)
+
+ // Query data source
+ const [queryResponse, queryJson] = await config.api.queries.preview(
+ fixtures.queries.postgres(updatedDataSourceJson.datasource._id!)
+ )
+
+ expect(queryJson.rows.length).toEqual(91)
+ expect(queryJson.schemaFields).toEqual(
+ fixtures.queries.expectedSchemaFields.postgres
+ )
+
+ // Save query
+ const datasourcetoSave: Query = {
+ ...fixtures.queries.postgres(updatedDataSourceJson.datasource._id!),
+ parameters: [],
+ }
+
+ const [saveQueryResponse, saveQueryJson] = await config.api.queries.save(
+ datasourcetoSave
+ )
+ // Get Query
+ const [getQueryResponse, getQueryJson] = await config.api.queries.get(
+ saveQueryJson._id!
+ )
+
+ // Get Query permissions
+ const [getQueryPermissionsResponse, getQueryPermissionsJson] =
+ await config.api.permissions.getAll(saveQueryJson._id!)
+
+ // Delete data source
+ const deleteResponse = await config.api.datasources.delete(
+ updatedDataSourceJson.datasource._id!,
+ updatedDataSourceJson.datasource._rev!
+ )
+ })
+})
diff --git a/qa-core/src/internal-api/tests/dataSources/restAPI.spec.ts b/qa-core/src/internal-api/tests/dataSources/restAPI.spec.ts
new file mode 100644
index 0000000000..d7b75db514
--- /dev/null
+++ b/qa-core/src/internal-api/tests/dataSources/restAPI.spec.ts
@@ -0,0 +1,69 @@
+import TestConfiguration from "../../config/TestConfiguration"
+import * as fixtures from "../../fixtures"
+import { Query } from "@budibase/types"
+
+describe("Internal API - Data Sources: REST API", () => {
+ const config = new TestConfiguration()
+
+ beforeAll(async () => {
+ await config.beforeAll()
+ })
+
+ afterAll(async () => {
+ await config.afterAll()
+ })
+
+ it("Create an app with a data source - REST API", async () => {
+ // Create app
+ await config.createApp()
+
+ // Get all integrations
+ await config.api.integrations.getAll()
+
+ // Add data source
+ const [dataSourceResponse, dataSourceJson] =
+ await config.api.datasources.add(fixtures.datasources.restAPI())
+
+ // Update data source
+ const newDataSourceInfo = {
+ ...dataSourceJson.datasource,
+ name: "RestAPI - Updated",
+ }
+ const [updatedDataSourceResponse, updatedDataSourceJson] =
+ await config.api.datasources.update(newDataSourceInfo)
+
+ // Query data source
+ const [queryResponse, queryJson] = await config.api.queries.preview(
+ fixtures.queries.restAPI(updatedDataSourceJson.datasource._id!)
+ )
+
+ expect(queryJson.rows.length).toEqual(1)
+ expect(queryJson.schemaFields).toEqual(
+ fixtures.queries.expectedSchemaFields.restAPI
+ )
+
+ // Save query
+ const datasourcetoSave: Query = {
+ ...fixtures.queries.postgres(updatedDataSourceJson.datasource._id!),
+ parameters: [],
+ }
+
+ const [saveQueryResponse, saveQueryJson] = await config.api.queries.save(
+ datasourcetoSave
+ )
+ // Get Query
+ const [getQueryResponse, getQueryJson] = await config.api.queries.get(
+ saveQueryJson._id!
+ )
+
+ // Get Query permissions
+ const [getQueryPermissionsResponse, getQueryPermissionsJson] =
+ await config.api.permissions.getAll(saveQueryJson._id!)
+
+ // Delete data source
+ const deleteResponse = await config.api.datasources.delete(
+ updatedDataSourceJson.datasource._id!,
+ updatedDataSourceJson.datasource._rev!
+ )
+ })
+})
diff --git a/qa-core/src/types/index.ts b/qa-core/src/types/index.ts
index bc75da46f8..6c3740200c 100644
--- a/qa-core/src/types/index.ts
+++ b/qa-core/src/types/index.ts
@@ -8,6 +8,7 @@ export * from "./responseMessage"
export * from "./routing"
export * from "./state"
export * from "./unpublishAppResponse"
+export * from "./addedDatasource"
// re-export public api types
export * from "@budibase/server/api/controllers/public/mapping/types"
diff --git a/yarn.lock b/yarn.lock
index 260f0ae6a6..3b403d6444 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -1486,15 +1486,15 @@
pouchdb-promise "^6.0.4"
through2 "^2.0.0"
-"@budibase/pro@2.5.6-alpha.29":
- version "2.5.6-alpha.29"
- resolved "https://registry.yarnpkg.com/@budibase/pro/-/pro-2.5.6-alpha.29.tgz#71414f68a296535ef53ffb0453352ea137c4aeab"
- integrity sha512-tQuzMOo2WFxKvsUgYAfUEcLabRpmAD7hPlhBhCFzYasaXNbJiPhcwv4i52US0i0Wr2IXMb2X0d7fwa8tnbKzIA==
+"@budibase/pro@2.5.6-alpha.41":
+ version "2.5.6-alpha.41"
+ resolved "https://registry.yarnpkg.com/@budibase/pro/-/pro-2.5.6-alpha.41.tgz#2632b398159211bf64bf6caff9753c877b6fc09d"
+ integrity sha512-8Zfm+RtcXY77gdXXHti8QT+Vt+1ApuVqYL3KCkxBVbpzgQci/F3mipNXUX8bEy/y+QYAdgn6psDTWAqyr9VALg==
dependencies:
- "@budibase/backend-core" "2.5.6-alpha.29"
+ "@budibase/backend-core" "2.5.6-alpha.41"
"@budibase/shared-core" "2.4.44-alpha.1"
"@budibase/string-templates" "2.4.44-alpha.1"
- "@budibase/types" "2.5.6-alpha.29"
+ "@budibase/types" "2.5.6-alpha.41"
"@koa/router" "8.0.8"
bull "4.10.1"
joi "17.6.0"