Merge branch 'develop' of github.com:Budibase/budibase into feature/table-fetching

This commit is contained in:
mike12345567 2023-05-22 12:56:10 +01:00
commit ad358fe1ca
32 changed files with 5950 additions and 284 deletions

View File

@ -22,43 +22,44 @@ jobs:
lint: lint:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
- name: Use Node.js 14.x - name: Use Node.js 14.x
uses: actions/setup-node@v1 uses: actions/setup-node@v3
with: with:
node-version: 14.x node-version: 14.x
cache: "yarn"
- run: yarn - run: yarn
- run: yarn lint - run: yarn lint
build: build:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
with: with:
submodules: true submodules: true
token: ${{ secrets.PERSONAL_ACCESS_TOKEN }} token: ${{ secrets.PERSONAL_ACCESS_TOKEN }}
- name: Use Node.js 14.x - name: Use Node.js 14.x
uses: actions/setup-node@v1 uses: actions/setup-node@v3
with: with:
node-version: 14.x node-version: 14.x
cache: "yarn"
- run: yarn - run: yarn
- run: yarn bootstrap
- run: yarn build - run: yarn build
test: test:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
with: with:
submodules: true submodules: true
token: ${{ secrets.PERSONAL_ACCESS_TOKEN }} token: ${{ secrets.PERSONAL_ACCESS_TOKEN }}
- name: Use Node.js 14.x - name: Use Node.js 14.x
uses: actions/setup-node@v1 uses: actions/setup-node@v3
with: with:
node-version: 14.x node-version: 14.x
cache: "yarn"
- run: yarn - run: yarn
- run: yarn bootstrap - run: yarn build --scope=@budibase/types --scope=@budibase/shared-core --scope=@budibase/string-templates
- run: yarn build
- run: yarn test --ignore=@budibase/pro - run: yarn test --ignore=@budibase/pro
- uses: codecov/codecov-action@v3 - uses: codecov/codecov-action@v3
with: with:
@ -69,32 +70,34 @@ jobs:
test-pro: test-pro:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
with: with:
submodules: true submodules: true
token: ${{ secrets.PERSONAL_ACCESS_TOKEN }} token: ${{ secrets.PERSONAL_ACCESS_TOKEN }}
- name: Use Node.js 14.x - name: Use Node.js 14.x
uses: actions/setup-node@v1 uses: actions/setup-node@v3
with: with:
node-version: 14.x node-version: 14.x
cache: "yarn"
- run: yarn - run: yarn
- run: yarn bootstrap
- run: yarn build --scope=@budibase/types --scope=@budibase/shared-core
- run: yarn test --scope=@budibase/pro - run: yarn test --scope=@budibase/pro
integration-test: integration-test:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v3
with: with:
submodules: true submodules: true
token: ${{ secrets.PERSONAL_ACCESS_TOKEN }} token: ${{ secrets.PERSONAL_ACCESS_TOKEN }}
- name: Use Node.js 14.x - name: Use Node.js 14.x
uses: actions/setup-node@v1 uses: actions/setup-node@v3
with: with:
node-version: 14.x node-version: 14.x
- run: yarn && yarn bootstrap && yarn build cache: "yarn"
- run: | - run: yarn
- run: yarn build
- name: Run tests
run: |
cd qa-core cd qa-core
yarn setup yarn setup
yarn test:ci yarn test:ci
@ -106,7 +109,7 @@ jobs:
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
- name: Checkout code - name: Checkout code
uses: actions/checkout@v2 uses: actions/checkout@v3
with: with:
submodules: true submodules: true
token: ${{ secrets.PERSONAL_ACCESS_TOKEN }} token: ${{ secrets.PERSONAL_ACCESS_TOKEN }}

View File

@ -1,5 +1,5 @@
{ {
"version": "2.6.19-alpha.0", "version": "2.6.19-alpha.2",
"npmClient": "yarn", "npmClient": "yarn",
"packages": [ "packages": [
"packages/backend-core", "packages/backend-core",

View File

@ -4,12 +4,7 @@
"composite": true, "composite": true,
"declaration": true, "declaration": true,
"sourceMap": true, "sourceMap": true,
"baseUrl": ".", "baseUrl": "."
"paths": {
"@budibase/types": ["../types/src"],
"@budibase/backend-core": ["../backend-core/src"],
"@budibase/backend-core/*": ["../backend-core/*.js"]
}
}, },
"ts-node": { "ts-node": {
"require": ["tsconfig-paths/register"] "require": ["tsconfig-paths/register"]

@ -1 +1 @@
Subproject commit 64a2025727c25d5813832c92eb360de3947b7aa6 Subproject commit a590dc237a16983b8f39dc8e65005b7736d23467

View File

@ -35,7 +35,7 @@ export const getComponentLibraryManifest = async (library: string) => {
const filename = "manifest.json" const filename = "manifest.json"
if (env.isDev() || env.isTest()) { if (env.isDev() || env.isTest()) {
const path = join(NODE_MODULES_PATH, "@budibase", "client", filename) const path = join(TOP_LEVEL_PATH, "../client", filename)
// always load from new so that updates are refreshed // always load from new so that updates are refreshed
delete require.cache[require.resolve(path)] delete require.cache[require.resolve(path)]
return require(path) return require(path)

View File

@ -21,4 +21,5 @@ export interface Screen extends Document {
width?: string width?: string
routing: ScreenRouting routing: ScreenRouting
props: ScreenProps props: ScreenProps
name?: string
} }

View File

@ -16,6 +16,7 @@ const config: Config.InitialOptions = {
"@budibase/backend-core/(.*)": "<rootDir>/../backend-core/$1", "@budibase/backend-core/(.*)": "<rootDir>/../backend-core/$1",
"@budibase/backend-core": "<rootDir>/../backend-core/src", "@budibase/backend-core": "<rootDir>/../backend-core/src",
"@budibase/types": "<rootDir>/../types/src", "@budibase/types": "<rootDir>/../types/src",
"@budibase/shared-core": ["<rootDir>/../shared-core/src"],
}, },
} }

View File

@ -18,7 +18,7 @@ export const UserGroup = () => {
apps: [], apps: [],
color: generator.color(), color: generator.color(),
icon: generator.word(), icon: generator.word(),
name: generator.word({ length: 2 }), name: generator.word(),
roles: roles, roles: roles,
users: [], users: [],
} }

View File

@ -16,11 +16,7 @@
"require": ["tsconfig-paths/register"], "require": ["tsconfig-paths/register"],
"swc": true "swc": true
}, },
"references": [ "references": [{ "path": "../types" }, { "path": "../backend-core" }],
{ "path": "../types" },
{ "path": "../backend-core" },
{ "path": "../../../budibase-pro/packages/pro" }
],
"include": ["src/**/*"], "include": ["src/**/*"],
"exclude": ["dist"] "exclude": ["dist"]
} }

5669
qa-core/package-lock.json generated Normal file

File diff suppressed because it is too large Load Diff

View File

@ -5,80 +5,71 @@ import {
AppPackageResponse, AppPackageResponse,
DeployConfig, DeployConfig,
MessageResponse, MessageResponse,
CreateAppRequest,
} from "../../../types" } from "../../../types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class AppAPI { interface RenameAppBody {
client: BudibaseInternalAPIClient name: string
}
export default class AppAPI extends BaseAPI {
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
// TODO Fix the fetch apps to receive an optional number of apps and compare if the received app is more or less. // TODO Fix the fetch apps to receive an optional number of apps and compare if the received app is more or less.
// each possible scenario should have its own method. // each possible scenario should have its own method.
async fetchEmptyAppList(): Promise<[Response, App[]]> { async fetchEmptyAppList(): Promise<[Response, App[]]> {
const [response, json] = await this.client.get(`/applications?status=all`) const [response, json] = await this.get(`/applications?status=all`)
expect(response).toHaveStatusCode(200)
expect(json.length).toBeGreaterThanOrEqual(0) expect(json.length).toBeGreaterThanOrEqual(0)
return [response, json] return [response, json]
} }
async fetchAllApplications(): Promise<[Response, App[]]> { async fetchAllApplications(): Promise<[Response, App[]]> {
const [response, json] = await this.client.get(`/applications?status=all`) const [response, json] = await this.get(`/applications?status=all`)
expect(response).toHaveStatusCode(200)
expect(json.length).toBeGreaterThanOrEqual(1) expect(json.length).toBeGreaterThanOrEqual(1)
return [response, json] return [response, json]
} }
async canRender(): Promise<[Response, boolean]> { async canRender(): Promise<[Response, boolean]> {
const [response, json] = await this.client.get("/routing/client") const [response, json] = await this.get("/routing/client")
expect(response).toHaveStatusCode(200)
const publishedAppRenders = Object.keys(json.routes).length > 0 const publishedAppRenders = Object.keys(json.routes).length > 0
expect(publishedAppRenders).toBe(true) expect(publishedAppRenders).toBe(true)
return [response, publishedAppRenders] return [response, publishedAppRenders]
} }
async getAppPackage(appId: string): Promise<[Response, AppPackageResponse]> { async getAppPackage(appId: string): Promise<[Response, AppPackageResponse]> {
const [response, json] = await this.client.get( const [response, json] = await this.get(`/applications/${appId}/appPackage`)
`/applications/${appId}/appPackage`
)
expect(response).toHaveStatusCode(200)
expect(json.application.appId).toEqual(appId) expect(json.application.appId).toEqual(appId)
return [response, json] return [response, json]
} }
async publish(appId: string | undefined): Promise<[Response, DeployConfig]> { async publish(appId: string | undefined): Promise<[Response, DeployConfig]> {
const [response, json] = await this.client.post( const [response, json] = await this.post(`/applications/${appId}/publish`)
`/applications/${appId}/publish`
)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async create(body: any): Promise<App> { async create(body: CreateAppRequest): Promise<App> {
const [response, json] = await this.client.post(`/applications`, { body }) const [response, json] = await this.post(`/applications`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toBeDefined() expect(json._id).toBeDefined()
return json return json
} }
async read(id: string): Promise<[Response, App]> { async read(id: string): Promise<[Response, App]> {
const [response, json] = await this.client.get(`/applications/${id}`) const [response, json] = await this.get(`/applications/${id}`)
return [response, json.data] return [response, json.data]
} }
async sync(appId: string): Promise<[Response, MessageResponse]> { async sync(appId: string): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.post( const [response, json] = await this.post(`/applications/${appId}/sync`)
`/applications/${appId}/sync`
)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
// TODO // TODO
async updateClient(appId: string, body: any): Promise<[Response, App]> { async updateClient(appId: string, body: any): Promise<[Response, App]> {
const [response, json] = await this.client.put( const [response, json] = await this.put(
`/applications/${appId}/client/update`, `/applications/${appId}/client/update`,
{ body } { body }
) )
@ -86,8 +77,7 @@ export default class AppAPI {
} }
async revertPublished(appId: string): Promise<[Response, MessageResponse]> { async revertPublished(appId: string): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.post(`/dev/${appId}/revert`) const [response, json] = await this.post(`/dev/${appId}/revert`)
expect(response).toHaveStatusCode(200)
expect(json).toEqual({ expect(json).toEqual({
message: "Reverted changes successfully.", message: "Reverted changes successfully.",
}) })
@ -95,8 +85,11 @@ export default class AppAPI {
} }
async revertUnpublished(appId: string): Promise<[Response, MessageResponse]> { async revertUnpublished(appId: string): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.post(`/dev/${appId}/revert`) const [response, json] = await this.post(
expect(response).toHaveStatusCode(400) `/dev/${appId}/revert`,
undefined,
400
)
expect(json).toEqual({ expect(json).toEqual({
message: "App has not yet been deployed", message: "App has not yet been deployed",
status: 400, status: 400,
@ -105,32 +98,22 @@ export default class AppAPI {
} }
async delete(appId: string): Promise<Response> { async delete(appId: string): Promise<Response> {
const [response, _] = await this.client.del(`/applications/${appId}`) const [response, _] = await this.del(`/applications/${appId}`)
expect(response).toHaveStatusCode(200)
return response return response
} }
async rename( async rename(
appId: string, appId: string,
oldName: string, oldName: string,
body: any body: RenameAppBody
): Promise<[Response, App]> { ): Promise<[Response, App]> {
const [response, json] = await this.client.put(`/applications/${appId}`, { const [response, json] = await this.put(`/applications/${appId}`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.name).not.toEqual(oldName) expect(json.name).not.toEqual(oldName)
return [response, json] return [response, json]
} }
async addScreentoApp(body: any): Promise<[Response, App]> {
const [response, json] = await this.client.post(`/screens`, { body })
return [response, json]
}
async getRoutes(screenExists?: boolean): Promise<[Response, RouteConfig]> { async getRoutes(screenExists?: boolean): Promise<[Response, RouteConfig]> {
const [response, json] = await this.client.get(`/routing`) const [response, json] = await this.get(`/routing`)
expect(response).toHaveStatusCode(200)
if (screenExists) { if (screenExists) {
expect(json.routes["/test"]).toBeTruthy() expect(json.routes["/test"]).toBeTruthy()
} else { } else {
@ -141,16 +124,16 @@ export default class AppAPI {
} }
async unpublish(appId: string): Promise<[Response]> { async unpublish(appId: string): Promise<[Response]> {
const [response, json] = await this.client.post( const [response, json] = await this.post(
`/applications/${appId}/unpublish` `/applications/${appId}/unpublish`,
undefined,
204
) )
expect(response).toHaveStatusCode(204)
return [response] return [response]
} }
async unlock(appId: string): Promise<[Response, MessageResponse]> { async unlock(appId: string): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.del(`/dev/${appId}/lock`) const [response, json] = await this.del(`/dev/${appId}/lock`)
expect(response).toHaveStatusCode(200)
expect(json.message).toEqual("Lock released successfully.") expect(json.message).toEqual("Lock released successfully.")
return [response, json] return [response, json]
} }
@ -162,10 +145,7 @@ export default class AppAPI {
color: "var(--spectrum-global-color-red-400)", color: "var(--spectrum-global-color-red-400)",
}, },
} }
const [response, json] = await this.client.put(`/applications/${appId}`, { const [response, json] = await this.put(`/applications/${appId}`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.icon.name).toEqual(body.icon.name) expect(json.icon.name).toEqual(body.icon.name)
expect(json.icon.color).toEqual(body.icon.color) expect(json.icon.color).toEqual(body.icon.color)
return [response, json] return [response, json]

View File

@ -0,0 +1,56 @@
import { Response } from "node-fetch"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
export default class BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) {
this.client = client
}
async get(url: string): Promise<[Response, any]> {
const [response, json] = await this.client.get(url)
expect(response).toHaveStatusCode(200)
return [response, json]
}
async post(
url: string,
body?: any,
statusCode?: number
): Promise<[Response, any]> {
const [response, json] = await this.client.post(url, { body })
expect(response).toHaveStatusCode(statusCode ? statusCode : 200)
return [response, json]
}
async put(
url: string,
body?: any,
statusCode?: number
): Promise<[Response, any]> {
const [response, json] = await this.client.put(url, { body })
expect(response).toHaveStatusCode(statusCode ? statusCode : 200)
return [response, json]
}
async patch(
url: string,
body?: any,
statusCode?: number
): Promise<[Response, any]> {
const [response, json] = await this.client.patch(url, { body })
expect(response).toHaveStatusCode(statusCode ? statusCode : 200)
return [response, json]
}
async del(
url: string,
statusCode?: number,
body?: any
): Promise<[Response, any]> {
const [response, json] = await this.client.del(url, { body })
expect(response).toHaveStatusCode(statusCode ? statusCode : 200)
return [response, json]
}
}

View File

@ -5,91 +5,58 @@ import {
UpdateDatasourceResponse, UpdateDatasourceResponse,
} from "@budibase/types" } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
import { DatasourceRequest } from "../../../types"
export default class DatasourcesAPI { export default class DatasourcesAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getIntegrations(): Promise<[Response, any]> { async getIntegrations(): Promise<[Response, any]> {
const [response, json] = await this.client.get(`/integrations`) const [response, json] = await this.get(`/integrations`)
expect(response).toHaveStatusCode(200)
const integrationsCount = Object.keys(json).length const integrationsCount = Object.keys(json).length
expect(integrationsCount).toBe(16) expect(integrationsCount).toBe(16)
return [response, json] return [response, json]
} }
async getAll(): Promise<[Response, Datasource[]]> { async getAll(): Promise<[Response, Datasource[]]> {
const [response, json] = await this.client.get(`/datasources`) const [response, json] = await this.get(`/datasources`)
expect(response).toHaveStatusCode(200)
expect(json.length).toBeGreaterThan(0) expect(json.length).toBeGreaterThan(0)
return [response, json] return [response, json]
} }
async getTable(dataSourceId: string): Promise<[Response, Datasource]> { async getTable(dataSourceId: string): Promise<[Response, Datasource]> {
const [response, json] = await this.client.get( const [response, json] = await this.get(`/datasources/${dataSourceId}`)
`/datasources/${dataSourceId}`
)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(dataSourceId) expect(json._id).toEqual(dataSourceId)
return [response, json] return [response, json]
} }
async add(body: any): Promise<[Response, CreateDatasourceResponse]> { async add(
const [response, json] = await this.client.post(`/datasources`, { body }) body: DatasourceRequest
expect(response).toHaveStatusCode(200) ): Promise<[Response, CreateDatasourceResponse]> {
const [response, json] = await this.post(`/datasources`, body)
expect(json.datasource._id).toBeDefined() expect(json.datasource._id).toBeDefined()
expect(json.datasource._rev).toBeDefined() expect(json.datasource._rev).toBeDefined()
return [response, json] return [response, json]
} }
async update(body: any): Promise<[Response, UpdateDatasourceResponse]> { async update(
const [response, json] = await this.client.put(`/datasources/${body._id}`, { body: Datasource
body, ): Promise<[Response, UpdateDatasourceResponse]> {
}) const [response, json] = await this.put(`/datasources/${body._id}`, body)
expect(response).toHaveStatusCode(200)
expect(json.datasource._id).toBeDefined() expect(json.datasource._id).toBeDefined()
expect(json.datasource._rev).toBeDefined() expect(json.datasource._rev).toBeDefined()
return [response, json] 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<Response> { async delete(dataSourceId: string, revId: string): Promise<Response> {
const [response, json] = await this.client.del( const [response, json] = await this.del(
`/datasources/${dataSourceId}/${revId}` `/datasources/${dataSourceId}/${revId}`
) )
expect(response).toHaveStatusCode(200)
return response return response
} }
} }

View File

@ -1,16 +1,14 @@
import { Response } from "node-fetch" import { Response } from "node-fetch"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class IntegrationsAPI { export default class IntegrationsAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getAll(): Promise<[Response, any]> { async getAll(): Promise<[Response, any]> {
const [response, json] = await this.client.get(`/integrations`) const [response, json] = await this.get(`/integrations`)
expect(response).toHaveStatusCode(200)
const integrationsCount = Object.keys(json).length const integrationsCount = Object.keys(json).length
expect(integrationsCount).toBeGreaterThan(0) expect(integrationsCount).toBeGreaterThan(0)
return [response, json] return [response, json]

View File

@ -1,16 +1,14 @@
import { Response } from "node-fetch" import { Response } from "node-fetch"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class PermissionsAPI { export default class PermissionsAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getAll(id: string): Promise<[Response, any]> { async getAll(id: string): Promise<[Response, any]> {
const [response, json] = await this.client.get(`/permissions/${id}`) const [response, json] = await this.get(`/permissions/${id}`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
} }

View File

@ -1,33 +1,25 @@
import { Response } from "node-fetch" import { Response } from "node-fetch"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import { PreviewQueryRequest, Query } from "@budibase/types" import { PreviewQueryRequest, Query } from "@budibase/types"
import BaseAPI from "./BaseAPI"
export default class DatasourcesAPI { export default class QueriesAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async preview(body: PreviewQueryRequest): Promise<[Response, any]> { async preview(body: PreviewQueryRequest): Promise<[Response, any]> {
const [response, json] = await this.client.post(`/queries/preview`, { const [response, json] = await this.post(`/queries/preview`, body)
body,
})
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async save(body: Query): Promise<[Response, any]> { async save(body: Query): Promise<[Response, any]> {
const [response, json] = await this.client.post(`/queries`, { const [response, json] = await this.post(`/queries`, body)
body,
})
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async get(queryId: string): Promise<[Response, any]> { async getQuery(queryId: string): Promise<[Response, any]> {
const [response, json] = await this.client.get(`/queries/${queryId}`) const [response, json] = await this.get(`/queries/${queryId}`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
} }

View File

@ -1,23 +1,20 @@
import { Response } from "node-fetch" import { Response } from "node-fetch"
import { Role, UserRoles } from "@budibase/types" import { Role, UserRoles } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class RoleAPI { export default class RoleAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getRoles(): Promise<[Response, Role[]]> { async getRoles(): Promise<[Response, Role[]]> {
const [response, json] = await this.client.get(`/roles`) const [response, json] = await this.get(`/roles`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async createRole(body: Partial<UserRoles>): Promise<[Response, UserRoles]> { async createRole(body: Partial<UserRoles>): Promise<[Response, UserRoles]> {
const [response, json] = await this.client.post(`/roles`, { body }) const [response, json] = await this.post(`/roles`, body)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
} }

View File

@ -1,29 +1,25 @@
import { Response } from "node-fetch" import { Response } from "node-fetch"
import { Row } from "@budibase/types" import { Row } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class RowAPI { export default class RowAPI extends BaseAPI {
rowAdded: boolean rowAdded: boolean
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
this.rowAdded = false this.rowAdded = false
} }
async getAll(tableId: string): Promise<[Response, Row[]]> { async getAll(tableId: string): Promise<[Response, Row[]]> {
const [response, json] = await this.client.get(`/${tableId}/rows`) const [response, json] = await this.get(`/${tableId}/rows`)
if (this.rowAdded) { if (this.rowAdded) {
expect(response).toHaveStatusCode(200)
expect(json.length).toBeGreaterThanOrEqual(1) expect(json.length).toBeGreaterThanOrEqual(1)
} }
return [response, json] return [response, json]
} }
async add(tableId: string, body: any): Promise<[Response, Row]> { async add(tableId: string, body: Row): Promise<[Response, Row]> {
const [response, json] = await this.client.post(`/${tableId}/rows`, { const [response, json] = await this.post(`/${tableId}/rows`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json._id).toBeDefined() expect(json._id).toBeDefined()
expect(json._rev).toBeDefined() expect(json._rev).toBeDefined()
expect(json.tableId).toEqual(tableId) expect(json.tableId).toEqual(tableId)
@ -31,34 +27,29 @@ export default class RowAPI {
return [response, json] return [response, json]
} }
async delete(tableId: string, body: any): Promise<[Response, Row[]]> { async delete(tableId: string, body: Row): Promise<[Response, Row[]]> {
const [response, json] = await this.client.del(`/${tableId}/rows/`, { const [response, json] = await this.del(
body, `/${tableId}/rows/`,
}) undefined,
expect(response).toHaveStatusCode(200) body
)
return [response, json] return [response, json]
} }
async searchNoPagination( async searchNoPagination(
tableId: string, tableId: string,
body: any body: string
): Promise<[Response, Row[]]> { ): Promise<[Response, Row[]]> {
const [response, json] = await this.client.post(`/${tableId}/search`, { const [response, json] = await this.post(`/${tableId}/search`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.hasNextPage).toEqual(false) expect(json.hasNextPage).toEqual(false)
return [response, json.rows] return [response, json.rows]
} }
async searchWithPagination( async searchWithPagination(
tableId: string, tableId: string,
body: any body: string
): Promise<[Response, Row[]]> { ): Promise<[Response, Row[]]> {
const [response, json] = await this.client.post(`/${tableId}/search`, { const [response, json] = await this.post(`/${tableId}/search`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.hasNextPage).toEqual(true) expect(json.hasNextPage).toEqual(true)
expect(json.rows.length).toEqual(10) expect(json.rows.length).toEqual(10)
return [response, json.rows] return [response, json.rows]

View File

@ -1,27 +1,23 @@
import { Screen } from "@budibase/types"
import { Response } from "node-fetch" import { Response } from "node-fetch"
import { Screen } from "@budibase/types"
import { ScreenRequest } from "../../../types/screens"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import BaseAPI from "./BaseAPI"
export default class ScreenAPI { export default class ScreenAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async create(body: any): Promise<[Response, Screen]> { async create(body: ScreenRequest): Promise<[Response, Screen]> {
const [response, json] = await this.client.post(`/screens`, { body }) const [response, json] = await this.post(`/screens`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toBeDefined() expect(json._id).toBeDefined()
expect(json.routing.roleId).toBe(body.routing.roleId) expect(json.routing.roleId).toBe(body.routing.roleId)
return [response, json] return [response, json]
} }
async delete(screenId: string, rev: string): Promise<[Response, Screen]> { async delete(screenId: string, rev: string): Promise<[Response, Screen]> {
const [response, json] = await this.client.del( const [response, json] = await this.del(`/screens/${screenId}/${rev}`)
`/screens/${screenId}/${rev}`
)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
} }

View File

@ -2,31 +2,27 @@ import { Response } from "node-fetch"
import { User } from "@budibase/types" import { User } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import { ApiKeyResponse } from "../../../types" import { ApiKeyResponse } from "../../../types"
import BaseAPI from "./BaseAPI"
export default class SelfAPI { export default class SelfAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getSelf(): Promise<[Response, Partial<User>]> { async getSelf(): Promise<[Response, Partial<User>]> {
const [response, json] = await this.client.get(`/global/self`) const [response, json] = await this.get(`/global/self`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async changeSelfPassword(body: Partial<User>): Promise<[Response, User]> { async changeSelfPassword(body: Partial<User>): Promise<[Response, User]> {
const [response, json] = await this.client.post(`/global/self`, { body }) const [response, json] = await this.post(`/global/self`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(body._id) expect(json._id).toEqual(body._id)
expect(json._rev).not.toEqual(body._rev) expect(json._rev).not.toEqual(body._rev)
return [response, json] return [response, json]
} }
async getApiKey(): Promise<ApiKeyResponse> { async getApiKey(): Promise<ApiKeyResponse> {
const [response, json] = await this.client.get(`/global/self/api_key`) const [response, json] = await this.get(`/global/self/api_key`)
expect(response).toHaveStatusCode(200)
expect(json).toHaveProperty("apiKey") expect(json).toHaveProperty("apiKey")
return json return json
} }

View File

@ -2,31 +2,27 @@ import { Response } from "node-fetch"
import { Table } from "@budibase/types" import { Table } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import { MessageResponse } from "../../../types" import { MessageResponse } from "../../../types"
import BaseAPI from "./BaseAPI"
export default class TableAPI { export default class TableAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async getAll(expectedNumber: Number): Promise<[Response, Table[]]> { async getAll(expectedNumber: Number): Promise<[Response, Table[]]> {
const [response, json] = await this.client.get(`/tables`) const [response, json] = await this.get(`/tables`)
expect(response).toHaveStatusCode(200)
expect(json.length).toBe(expectedNumber) expect(json.length).toBe(expectedNumber)
return [response, json] return [response, json]
} }
async getTableById(id: string): Promise<[Response, Table]> { async getTableById(id: string): Promise<[Response, Table]> {
const [response, json] = await this.client.get(`/tables/${id}`) const [response, json] = await this.get(`/tables/${id}`)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(id) expect(json._id).toEqual(id)
return [response, json] return [response, json]
} }
async save(body: any, columnAdded?: boolean): Promise<[Response, Table]> { async save(body: any, columnAdded?: boolean): Promise<[Response, Table]> {
const [response, json] = await this.client.post(`/tables`, { body }) const [response, json] = await this.post(`/tables`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toBeDefined() expect(json._id).toBeDefined()
expect(json._rev).toBeDefined() expect(json._rev).toBeDefined()
if (columnAdded) { if (columnAdded) {
@ -37,9 +33,7 @@ export default class TableAPI {
} }
async forbiddenSave(body: any): Promise<[Response, Table]> { async forbiddenSave(body: any): Promise<[Response, Table]> {
const [response, json] = await this.client.post(`/tables`, { body }) const [response, json] = await this.post(`/tables`, body, 403)
expect(response).toHaveStatusCode(403)
return [response, json] return [response, json]
} }
@ -47,8 +41,7 @@ export default class TableAPI {
id: string, id: string,
revId: string revId: string
): Promise<[Response, MessageResponse]> { ): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.del(`/tables/${id}/${revId}`) const [response, json] = await this.del(`/tables/${id}/${revId}`)
expect(response).toHaveStatusCode(200)
expect(json.message).toEqual(`Table ${id} deleted.`) expect(json.message).toEqual(`Table ${id} deleted.`)
return [response, json] return [response, json]
} }

View File

@ -2,30 +2,29 @@ import { Response } from "node-fetch"
import { Role, User, UserDeletedEvent, UserRoles } from "@budibase/types" import { Role, User, UserDeletedEvent, UserRoles } from "@budibase/types"
import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient" import BudibaseInternalAPIClient from "../BudibaseInternalAPIClient"
import { MessageResponse } from "../../../types" import { MessageResponse } from "../../../types"
import BaseAPI from "./BaseAPI"
export default class UserAPI { export default class UserAPI extends BaseAPI {
client: BudibaseInternalAPIClient
constructor(client: BudibaseInternalAPIClient) { constructor(client: BudibaseInternalAPIClient) {
this.client = client super(client)
} }
async search(): Promise<[Response, Partial<User>[]]> { async search(): Promise<[Response, Partial<User>[]]> {
const [response, json] = await this.client.post(`/global/users/search`, {}) const [response, json] = await this.post(`/global/users/search`, {})
expect(response).toHaveStatusCode(200)
expect(json.data.length).toBeGreaterThan(0) expect(json.data.length).toBeGreaterThan(0)
return [response, json] return [response, json]
} }
async getSelf(): Promise<[Response, Partial<User>]> { async getSelf(): Promise<[Response, Partial<User>]> {
const [response, json] = await this.client.get(`/global/self`) const [response, json] = await this.get(`/global/self`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async getAll(): Promise<[Response, Partial<User>[]]> { async getAll(): Promise<[Response, Partial<User>[]]> {
const [response, json] = await this.client.get(`/global/users`) const [response, json] = await this.get(`/global/users`)
expect(response).toHaveStatusCode(200)
expect(json.length).toBeGreaterThan(0) expect(json.length).toBeGreaterThan(0)
return [response, json] return [response, json]
} }
@ -38,10 +37,8 @@ export default class UserAPI {
groups: [], groups: [],
}, },
} }
const [response, json] = await this.client.post(`/global/users/bulk`, { const [response, json] = await this.post(`/global/users/bulk`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.created.unsuccessful.length).toEqual(0) expect(json.created.unsuccessful.length).toEqual(0)
expect(json.created.successful.length).toEqual(body.create.users.length) expect(json.created.successful.length).toEqual(body.create.users.length)
return [response, json] return [response, json]
@ -53,73 +50,58 @@ export default class UserAPI {
userIds: [userId], userIds: [userId],
}, },
} }
const [response, json] = await this.client.post(`/global/users/bulk`, { const [response, json] = await this.post(`/global/users/bulk`, body)
body,
})
expect(response).toHaveStatusCode(200)
expect(json.deleted.successful.length).toEqual(1) expect(json.deleted.successful.length).toEqual(1)
expect(json.deleted.unsuccessful.length).toEqual(0) expect(json.deleted.unsuccessful.length).toEqual(0)
expect(json.deleted.successful[0].userId).toEqual(userId) expect(json.deleted.successful[0].userId).toEqual(userId)
return [response, json] return [response, json]
} }
async delete(userId: string): Promise<[Response, UserDeletedEvent]> { async delete(userId: string): Promise<[Response, UserDeletedEvent]> {
const [response, json] = await this.client.del(`/global/users/${userId}`) const [response, json] = await this.del(`/global/users/${userId}`)
expect(response).toHaveStatusCode(200)
expect(json.message).toEqual(`User ${userId} deleted.`) expect(json.message).toEqual(`User ${userId} deleted.`)
return [response, json] return [response, json]
} }
async invite(body: any): Promise<[Response, MessageResponse]> { async invite(body: any): Promise<[Response, MessageResponse]> {
const [response, json] = await this.client.post( const [response, json] = await this.post(`/global/users/multi/invite`, body)
`/global/users/multi/invite`,
{ body }
)
expect(response).toHaveStatusCode(200)
expect(json.unsuccessful.length).toEqual(0) expect(json.unsuccessful.length).toEqual(0)
expect(json.successful.length).toEqual(body.length) expect(json.successful.length).toEqual(body.length)
return [response, json] return [response, json]
} }
async getRoles(): Promise<[Response, Role[]]> { async getRoles(): Promise<[Response, Role[]]> {
const [response, json] = await this.client.get(`/roles`) const [response, json] = await this.get(`/roles`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async updateInfo(body: any): Promise<[Response, User]> { async updateInfo(body: any): Promise<[Response, User]> {
const [response, json] = await this.client.post(`/global/users/`, { body }) const [response, json] = await this.post(`/global/users/`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(body._id) expect(json._id).toEqual(body._id)
expect(json._rev).not.toEqual(body._rev) expect(json._rev).not.toEqual(body._rev)
return [response, json] return [response, json]
} }
async forcePasswordReset(body: any): Promise<[Response, User]> { async forcePasswordReset(body: any): Promise<[Response, User]> {
const [response, json] = await this.client.post(`/global/users/`, { body }) const [response, json] = await this.post(`/global/users/`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(body._id) expect(json._id).toEqual(body._id)
expect(json._rev).not.toEqual(body._rev) expect(json._rev).not.toEqual(body._rev)
return [response, json] return [response, json]
} }
async getInfo(userId: string): Promise<[Response, User]> { async getInfo(userId: string): Promise<[Response, User]> {
const [response, json] = await this.client.get(`/global/users/${userId}`) const [response, json] = await this.get(`/global/users/${userId}`)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
async changeSelfPassword(body: Partial<User>): Promise<[Response, User]> { async changeSelfPassword(body: Partial<User>): Promise<[Response, User]> {
const [response, json] = await this.client.post(`/global/self`, { body }) const [response, json] = await this.post(`/global/self`, body)
expect(response).toHaveStatusCode(200)
expect(json._id).toEqual(body._id) expect(json._id).toEqual(body._id)
expect(json._rev).not.toEqual(body._rev) expect(json._rev).not.toEqual(body._rev)
return [response, json] return [response, json]
} }
async createRole(body: Partial<UserRoles>): Promise<[Response, UserRoles]> { async createRole(body: Partial<UserRoles>): Promise<[Response, UserRoles]> {
const [response, json] = await this.client.post(`/roles`, { body }) const [response, json] = await this.post(`/roles`, body)
expect(response).toHaveStatusCode(200)
return [response, json] return [response, json]
} }
} }

View File

@ -1,5 +1,6 @@
import { DatasourceRequest } from "../../types"
// Add information about the data source to the fixtures file from 1password // Add information about the data source to the fixtures file from 1password
export const mongoDB = () => { export const mongoDB = (): DatasourceRequest => {
return { return {
datasource: { datasource: {
name: "MongoDB", name: "MongoDB",
@ -15,7 +16,7 @@ export const mongoDB = () => {
} }
} }
export const postgresSQL = () => { export const postgresSQL = (): DatasourceRequest => {
return { return {
datasource: { datasource: {
name: "PostgresSQL", name: "PostgresSQL",
@ -34,7 +35,7 @@ export const postgresSQL = () => {
fetchSchema: true, fetchSchema: true,
} }
} }
export const mariaDB = () => { export const mariaDB = (): DatasourceRequest => {
return { return {
datasource: { datasource: {
name: "MariaDB", name: "MariaDB",
@ -54,7 +55,7 @@ export const mariaDB = () => {
} }
} }
export const restAPI = () => { export const restAPI = (): DatasourceRequest => {
return { return {
datasource: { datasource: {
name: "RestAPI", name: "RestAPI",

View File

@ -57,7 +57,7 @@ export const expectedSchemaFields = {
running_time_secs: "number", running_time_secs: "number",
title: "string", title: "string",
year: "number", year: "number",
_id: "json", _id: "string",
}, },
postgres: { postgres: {
address: "string", address: "string",

View File

@ -1,8 +1,8 @@
import { generator } from "../../shared" import { generator } from "../../shared"
import { ScreenRequest } from "../../types"
const randomId = generator.guid() const randomId = generator.guid()
export const generateScreen = (roleId: string): any => ({ export const generateScreen = (roleId: string): ScreenRequest => ({
showNavigation: true, showNavigation: true,
width: "Large", width: "Large",
name: randomId, name: randomId,

View File

@ -52,7 +52,7 @@ describe("Internal API - Data Sources: MariaDB", () => {
datasourcetoSave datasourcetoSave
) )
// Get Query // Get Query
const [getQueryResponse, getQueryJson] = await config.api.queries.get( const [getQueryResponse, getQueryJson] = await config.api.queries.getQuery(
<string>saveQueryJson._id <string>saveQueryJson._id
) )

View File

@ -52,7 +52,7 @@ describe("Internal API - Data Sources: MongoDB", () => {
datasourcetoSave datasourcetoSave
) )
// Get Query // Get Query
const [getQueryResponse, getQueryJson] = await config.api.queries.get( const [getQueryResponse, getQueryJson] = await config.api.queries.getQuery(
<string>saveQueryJson._id <string>saveQueryJson._id
) )

View File

@ -52,7 +52,7 @@ describe("Internal API - Data Sources: PostgresSQL", () => {
datasourcetoSave datasourcetoSave
) )
// Get Query // Get Query
const [getQueryResponse, getQueryJson] = await config.api.queries.get( const [getQueryResponse, getQueryJson] = await config.api.queries.getQuery(
saveQueryJson._id! saveQueryJson._id!
) )

View File

@ -52,7 +52,7 @@ describe("Internal API - Data Sources: REST API", () => {
datasourcetoSave datasourcetoSave
) )
// Get Query // Get Query
const [getQueryResponse, getQueryJson] = await config.api.queries.get( const [getQueryResponse, getQueryJson] = await config.api.queries.getQuery(
saveQueryJson._id! saveQueryJson._id!
) )

View File

@ -0,0 +1,22 @@
export interface DatasourceRequest {
datasource: {
name: string
plus?: boolean
source: string
type: string
config: {
connectionString?: string
db?: string
database?: string
host?: string
password?: string
port?: string
schema?: string
user?: string
defaultHeaders?: {}
rejectUnauthorized?: boolean
url?: string
}
}
fetchSchema: boolean
}

View File

@ -8,7 +8,7 @@ export * from "./responseMessage"
export * from "./routing" export * from "./routing"
export * from "./state" export * from "./state"
export * from "./unpublishAppResponse" export * from "./unpublishAppResponse"
export * from "./addedDatasource" export * from "./screens"
export * from "./datasources"
// re-export public api types // re-export public api types
export * from "@budibase/server/api/controllers/public/mapping/types" export * from "@budibase/server/api/controllers/public/mapping/types"

View File

@ -0,0 +1,32 @@
export interface ScreenRequest {
showNavigation: boolean
width: string
name: string
template: string
props: ScreenProps
routing: ScreenRouting
}
interface ScreenProps {
_id: string
_component: string
_styles: {
normal: {}
hover: {}
active: {}
selected: {}
}
_children: []
_instanceName: string
direction: string
hAlign: string
vAlign: string
size: string
gap: string
}
interface ScreenRouting {
route: string
roleId: string
homeScreen: boolean
}