2021-04-21 05:14:36 +12:00
|
|
|
const CouchDB = require("../../../db")
|
2021-04-23 04:57:38 +12:00
|
|
|
const {
|
|
|
|
generateConfigID,
|
|
|
|
StaticDatabases,
|
|
|
|
getConfigParams,
|
2021-05-06 07:58:31 +12:00
|
|
|
getGlobalUserParams,
|
2021-05-06 21:51:21 +12:00
|
|
|
getScopedFullConfig,
|
2021-04-23 04:57:38 +12:00
|
|
|
} = require("@budibase/auth").db
|
2021-04-24 00:49:47 +12:00
|
|
|
const { Configs } = require("../../../constants")
|
|
|
|
const email = require("../../../utilities/email")
|
2021-05-08 00:55:30 +12:00
|
|
|
const { upload, ObjectStoreBuckets } = require("@budibase/auth").objectStore
|
2021-05-06 07:58:31 +12:00
|
|
|
|
|
|
|
const APP_PREFIX = "app_"
|
2021-04-21 05:14:36 +12:00
|
|
|
|
|
|
|
const GLOBAL_DB = StaticDatabases.GLOBAL.name
|
|
|
|
|
2021-05-03 19:31:09 +12:00
|
|
|
exports.save = async function (ctx) {
|
2021-04-21 05:14:36 +12:00
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
2021-07-14 04:27:04 +12:00
|
|
|
const { type, workspace, user, config } = ctx.request.body
|
2021-04-21 05:14:36 +12:00
|
|
|
|
|
|
|
// Config does not exist yet
|
2021-05-05 04:31:06 +12:00
|
|
|
if (!ctx.request.body._id) {
|
|
|
|
ctx.request.body._id = generateConfigID({
|
2021-04-22 22:45:22 +12:00
|
|
|
type,
|
2021-07-14 04:27:04 +12:00
|
|
|
workspace,
|
2021-04-22 22:45:22 +12:00
|
|
|
user,
|
|
|
|
})
|
2021-04-21 05:14:36 +12:00
|
|
|
}
|
|
|
|
|
2021-06-10 02:45:54 +12:00
|
|
|
try {
|
|
|
|
// verify the configuration
|
|
|
|
switch (type) {
|
|
|
|
case Configs.SMTP:
|
|
|
|
await email.verifyConfig(config)
|
|
|
|
break
|
|
|
|
}
|
|
|
|
} catch (err) {
|
|
|
|
ctx.throw(400, err)
|
2021-04-24 00:49:47 +12:00
|
|
|
}
|
|
|
|
|
2021-04-21 05:14:36 +12:00
|
|
|
try {
|
2021-05-05 04:31:06 +12:00
|
|
|
const response = await db.put(ctx.request.body)
|
2021-04-21 05:14:36 +12:00
|
|
|
ctx.body = {
|
2021-04-22 22:45:22 +12:00
|
|
|
type,
|
2021-04-21 05:14:36 +12:00
|
|
|
_id: response.id,
|
|
|
|
_rev: response.rev,
|
|
|
|
}
|
|
|
|
} catch (err) {
|
2021-06-10 02:45:54 +12:00
|
|
|
ctx.throw(400, err)
|
2021-04-21 05:14:36 +12:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-05-03 19:31:09 +12:00
|
|
|
exports.fetch = async function (ctx) {
|
2021-04-21 05:14:36 +12:00
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
|
|
|
const response = await db.allDocs(
|
2021-05-06 03:00:15 +12:00
|
|
|
getConfigParams(
|
|
|
|
{ type: ctx.params.type },
|
|
|
|
{
|
|
|
|
include_docs: true,
|
|
|
|
}
|
|
|
|
)
|
2021-04-21 05:14:36 +12:00
|
|
|
)
|
2021-05-04 22:32:22 +12:00
|
|
|
ctx.body = response.rows.map(row => row.doc)
|
2021-04-21 05:14:36 +12:00
|
|
|
}
|
|
|
|
|
2021-04-22 22:45:22 +12:00
|
|
|
/**
|
|
|
|
* Gets the most granular config for a particular configuration type.
|
2021-07-14 04:27:04 +12:00
|
|
|
* The hierarchy is type -> workspace -> user.
|
2021-04-22 22:45:22 +12:00
|
|
|
*/
|
2021-05-03 19:31:09 +12:00
|
|
|
exports.find = async function (ctx) {
|
2021-04-21 05:14:36 +12:00
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
2021-04-22 22:45:22 +12:00
|
|
|
|
2021-07-14 04:27:04 +12:00
|
|
|
const { userId, workspaceId } = ctx.query
|
|
|
|
if (workspaceId && userId) {
|
|
|
|
const workspace = await db.get(workspaceId)
|
|
|
|
const userInWorkspace = workspace.users.some(workspaceUser => workspaceUser === userId)
|
|
|
|
if (!ctx.user.admin && !userInWorkspace) {
|
|
|
|
ctx.throw(400, `User is not in specified workspace: ${workspace}.`)
|
2021-04-22 22:45:22 +12:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-04-21 05:14:36 +12:00
|
|
|
try {
|
2021-04-22 22:45:22 +12:00
|
|
|
// Find the config with the most granular scope based on context
|
2021-05-06 21:51:21 +12:00
|
|
|
const scopedConfig = await getScopedFullConfig(db, {
|
2021-04-23 00:46:54 +12:00
|
|
|
type: ctx.params.type,
|
|
|
|
user: userId,
|
2021-07-14 04:27:04 +12:00
|
|
|
workspace: workspaceId,
|
2021-04-22 22:45:22 +12:00
|
|
|
})
|
|
|
|
|
|
|
|
if (scopedConfig) {
|
|
|
|
ctx.body = scopedConfig
|
|
|
|
} else {
|
2021-06-22 04:13:06 +12:00
|
|
|
// don't throw an error, there simply is nothing to return
|
|
|
|
ctx.body = {}
|
2021-04-22 22:45:22 +12:00
|
|
|
}
|
2021-04-21 05:14:36 +12:00
|
|
|
} catch (err) {
|
|
|
|
ctx.throw(err.status, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-06-22 05:01:25 +12:00
|
|
|
exports.publicSettings = async function (ctx) {
|
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
|
|
|
try {
|
|
|
|
// Find the config with the most granular scope based on context
|
2021-06-22 05:37:14 +12:00
|
|
|
const config = await getScopedFullConfig(db, {
|
2021-06-22 05:01:25 +12:00
|
|
|
type: Configs.SETTINGS,
|
|
|
|
})
|
2021-06-22 05:37:14 +12:00
|
|
|
if (!config) {
|
|
|
|
ctx.body = {}
|
|
|
|
} else {
|
|
|
|
ctx.body = config
|
|
|
|
}
|
2021-06-22 05:01:25 +12:00
|
|
|
} catch (err) {
|
|
|
|
ctx.throw(err.status, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-05-08 00:55:30 +12:00
|
|
|
exports.upload = async function (ctx) {
|
|
|
|
if (ctx.request.files == null || ctx.request.files.file.length > 1) {
|
|
|
|
ctx.throw(400, "One file must be uploaded.")
|
|
|
|
}
|
|
|
|
const file = ctx.request.files.file
|
|
|
|
const { type, name } = ctx.params
|
|
|
|
|
|
|
|
const fileExtension = [...file.name.split(".")].pop()
|
|
|
|
// filenames converted to UUIDs so they are unique
|
|
|
|
const processedFileName = `${name}.${fileExtension}`
|
|
|
|
|
|
|
|
const bucket = ObjectStoreBuckets.GLOBAL
|
|
|
|
const key = `${type}/${processedFileName}`
|
|
|
|
await upload({
|
|
|
|
bucket,
|
|
|
|
filename: key,
|
|
|
|
path: file.path,
|
|
|
|
type: file.type,
|
|
|
|
})
|
|
|
|
|
|
|
|
// add to configuration structure
|
|
|
|
// TODO: right now this only does a global level
|
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
2021-05-13 01:27:33 +12:00
|
|
|
let cfgStructure = await getScopedFullConfig(db, { type })
|
|
|
|
if (!cfgStructure) {
|
|
|
|
cfgStructure = {
|
2021-05-08 00:55:30 +12:00
|
|
|
_id: generateConfigID({ type }),
|
2021-05-13 01:27:33 +12:00
|
|
|
config: {},
|
2021-05-08 00:55:30 +12:00
|
|
|
}
|
|
|
|
}
|
|
|
|
const url = `/${bucket}/${key}`
|
2021-05-13 01:27:33 +12:00
|
|
|
cfgStructure.config[`${name}Url`] = url
|
2021-05-08 00:55:30 +12:00
|
|
|
// write back to db with url updated
|
2021-05-13 01:27:33 +12:00
|
|
|
await db.put(cfgStructure)
|
2021-05-08 00:55:30 +12:00
|
|
|
|
|
|
|
ctx.body = {
|
|
|
|
message: "File has been uploaded and url stored to config.",
|
|
|
|
url,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-05-03 19:31:09 +12:00
|
|
|
exports.destroy = async function (ctx) {
|
2021-04-21 05:14:36 +12:00
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
|
|
|
const { id, rev } = ctx.params
|
|
|
|
|
|
|
|
try {
|
|
|
|
await db.remove(id, rev)
|
|
|
|
ctx.body = { message: "Config deleted successfully" }
|
|
|
|
} catch (err) {
|
|
|
|
ctx.throw(err.status, err)
|
|
|
|
}
|
|
|
|
}
|
2021-05-06 07:58:31 +12:00
|
|
|
|
2021-05-06 21:57:24 +12:00
|
|
|
exports.configChecklist = async function (ctx) {
|
2021-05-06 07:58:31 +12:00
|
|
|
const db = new CouchDB(GLOBAL_DB)
|
|
|
|
|
|
|
|
try {
|
|
|
|
// TODO: Watch get started video
|
|
|
|
|
|
|
|
// Apps exist
|
2021-05-25 03:20:02 +12:00
|
|
|
let allDbs = await CouchDB.allDbs()
|
2021-05-06 07:58:31 +12:00
|
|
|
const appDbNames = allDbs.filter(dbName => dbName.startsWith(APP_PREFIX))
|
|
|
|
|
|
|
|
// They have set up SMTP
|
2021-05-06 23:09:35 +12:00
|
|
|
const smtpConfig = await getScopedFullConfig(db, {
|
2021-05-06 21:57:24 +12:00
|
|
|
type: Configs.SMTP,
|
2021-05-06 07:58:31 +12:00
|
|
|
})
|
|
|
|
|
2021-05-22 01:55:11 +12:00
|
|
|
// They have set up Google Auth
|
|
|
|
const oauthConfig = await getScopedFullConfig(db, {
|
|
|
|
type: Configs.GOOGLE,
|
|
|
|
})
|
|
|
|
|
2021-05-06 07:58:31 +12:00
|
|
|
// They have set up an admin user
|
|
|
|
const users = await db.allDocs(
|
|
|
|
getGlobalUserParams(null, {
|
|
|
|
include_docs: true,
|
|
|
|
})
|
|
|
|
)
|
|
|
|
const adminUser = users.rows.some(row => row.doc.admin)
|
|
|
|
|
2021-05-06 21:57:24 +12:00
|
|
|
ctx.body = {
|
2021-05-06 07:58:31 +12:00
|
|
|
apps: appDbNames.length,
|
|
|
|
smtp: !!smtpConfig,
|
2021-05-06 21:57:24 +12:00
|
|
|
adminUser,
|
2021-05-22 01:55:11 +12:00
|
|
|
oauth: !!oauthConfig,
|
2021-05-06 07:58:31 +12:00
|
|
|
}
|
|
|
|
} catch (err) {
|
|
|
|
ctx.throw(err.status, err)
|
|
|
|
}
|
|
|
|
}
|