const {getApisWithFullAccess, getApisForSession} = require("./budibaseApi"); const getDatastore = require("./datastore"); const getDatabaseManager = require("./databaseManager"); const {$, splitKey} = require("budibase-core").common; const { keyBy, last } = require("lodash/fp"); const {unauthorized} = require("./exceptions"); const { masterAppPackage, applictionVersionPackage } = require("../utilities/createAppPackage"); const isMaster = appname => appname === "_master"; module.exports = async (config) => { const datastoreModule = getDatastore(config); const databaseManager = getDatabaseManager( datastoreModule, config.datastoreConfig); const masterDatastore = datastoreModule.getDatastore( databaseManager.masterDatastoreConfig); const bb = await getApisWithFullAccess( masterDatastore, masterAppPackage(config)); let applications; const loadApplications = async () => applications = $(await bb.indexApi.listItems("/all_applications"), [ keyBy("name") ]); await loadApplications(); const getInstanceDatastore = (instanceDatastoreConfig) => datastoreModule.getDatastore(instanceDatastoreConfig); const getCustomSessionId = (appname, sessionId) => isMaster(appname) ? bb.recordApi.customId("mastersession", sessionId) : bb.recordApi.customId("session", sessionId); const getApplication = async (name) => { if(applications[name]) return applications[name]; await loadApplications(); return applications[name]; }; const getSession = async (sessionId, appname) => { const customSessionId = getCustomSessionId(appname, sessionId); if(isMaster(appname)) { return await bb.recordApi.load(`/sessions/${customSessionId}`); } else { const app = await getApplication(appname); return await bb.recordApi.load(`/applications/${app.id}/sessions/${customSessionId}`); } }; const deleteSession = async (sessionId, appname) => { const customSessionId = getCustomSessionId(appname, sessionId); if(isMaster(appname)) { return await bb.recordApi.delete(`/sessions/${customSessionId}`); } else { const app = await getApplication(appname); return await bb.recordApi.delete(`/applications/${app.id}/sessions/${customSessionId}`); } }; const authenticate = async (sessionId, appname, username, password, instanceName="default") => { if(isMaster(appname)) { const authUser = await bb.authApi.authenticate(username, password); if(!authUser) { return null; } const session = bb.recordApi.getNew("/sessions", "mastersession"); bb.recordApi.setCustomId(session, sessionId); session.user_json = JSON.stringify(authUser); session.username = username; await bb.recordApi.save(session); return session; } const app = await getApplication(appname); const userInMaster = await bb.indexApi.listItems( `/applications/${app.id}/users_by_name`, {name:username} ).find(u => u.name === username); const instance = await bb.recordApi.load( userInMaster.instance.key); const versionId = $(instance.version.key, [ splitKey, last ]); const bbInstance = await getApisWithFullAccess( datastoreModule.getDatastore(instance.datastoreconfig), applictionVersionPackage(appname, versionId) ); const authUser = await bbInstance.authApi.authenticate(username, password); if(!authUser) { return null; } const session = bb.recordApi.getNew(`/applications/${app.id}/sessions`, "session"); bb.recordApi.setCustomId(session, sessionId); session.user_json = JSON.stringify(authUser); session.instanceDatastoreConfig = instance.datastoreconfig; session.username = username; await bb.recordApi.save(session); return session; }; const getInstanceApiForSession = async (appname, sessionId) => { if(isMaster(appname)) { const customId = bb.recordApi.customId("mastersession", sessionId); try { const session = await bb.recordApi.load(`/sessions/${customId}`); return await getApisForSession( masterDatastore, masterAppPackage(config), session); } catch(_) { return null; } } else { const app = await getApplication(appname); const customId = bb.recordApi.customId("session", sessionId); try { const session = await bb.recordApi.load(`/applications/${app.id}/sessions/${customId}`); const instanceDatastore = getInstanceDatastore(session.instanceDatastoreConfig) return await getApisForSession( instanceDatastore, applictionVersionPackage(appname, session.instanceVersion), session); } catch(_) { return null; } } }; const getFullAccessInstanceApiForUsername = async (appname, username) => { if(isMaster(appname)) { const user = bb.authApi.getUsers() .find(u => u.name === username); if(!user) return; if(!user.enabled) return; return user; } else { const app = await getApplication(appname); const matches = bb.indexApi.listItems( `/applications/${app.id}/user_name_lookup`, { rangeStartParams:{name:username}, rangeEndParams:{name:username}, searchPhrase:`name:${username}` } ); if(matches.length !== 1) return; const instanceDatastore = getInstanceDatastore( matches[0].instanceDatastoreConfig); return await getApisWithFullAccess(instanceDatastore); } }; const removeSessionsForUser = async (appname, username) => { if(isMaster(appname)) { const sessions = await bb.indexApi.listItems( "/mastersessions_by_user", { rangeStartParams:{username}, rangeEndParams:{username}, searchPhrase:`username:${username}` } ); for(let session of sessions) { await bb.recordApi.delete(session.key); } } else { const app = await getApplication(appname); const sessions = await bb.indexApi.listItems( `/applications/${app.id}/sessions_by_user`, { rangeStartParams:{name:username}, rangeEndParams:{name:username}, searchPhrase:`username:${username}` } ); for(let session of sessions) { await bb.recordApi.delete(session.key); } } } return ({ getApplication, getSession, deleteSession, authenticate, getInstanceApiForSession, getFullAccessInstanceApiForUsername, removeSessionsForUser, bbMaster:bb }); }