'use strict'; const router = require('express').Router(); const permission = require('../utils/permission'); const { Resource, ResourceEdge, ResourceGroup } = require('../models/resource'); const { Group } = require('../models/group_ldap'); const { User } = require('../models/user_ldap'); const { cnFromDn } = require('../utils/user_groups'); const { projectResources } = require('@simpleworkjs/directory-schema'); const SUPER_ADMIN_GROUP = permission.SUPER_ADMIN_GROUP; const groups = require('../utils/groups'); // Make `childCn` a member of `parentCn`, i.e. everyone in the child is // transitively in the parent. Idempotent and non-fatal: "already a member" is // the goal state, and a missing group (e.g. god_admin absent on a // directory seeded by an older entrypoint) is a reason to skip, not to fail the // caller's real work. async function nestGroup(childCn, parentCn) { try { const parent = await Group.get(parentCn); const child = await Group.get(childCn); if (await Group.wouldCycle(parentCn, child.dn)) { console.error(`nestGroup: refusing ${childCn} -> ${parentCn} (would create a cycle)`); return; } await parent.addMember({ dn: child.dn }); } catch (err) { const benign = err.name === 'TypeOrValueExistsError' || err.code === 20 || err.name === 'GroupNotFound'; if (!benign) console.error(`nestGroup: ${childCn} -> ${parentCn} failed:`, err.message); } } // ── Group-model provisioning (docs/GROUPS.md) ─────────────────────────────── // The directory is the single place groups are created, as a projection of the // resource graph. These helpers materialize the group-inheritance lattice for // a resource so it exists in LDAP as well as in the resolver (utils/groups.js). // All of them are idempotent, so calling them again for a resource a newer // release is backfilling is a no-op. // Map a directory resource kind onto a group-model kind (GROUPS.md §2). // host -> host; service -> app (services/consoles are the group model's "apps"); // site gets site-level groups (handled separately); oauth/container get no // per-resource groups (oauth clients hang off their owning service). function groupKind(resource) { if (resource.kind === 'host') return 'host'; if (resource.kind === 'service') return 'app'; return null; } // Create a groupOfNames if it doesn't already exist. Idempotent; `ownerDn` // seeds the mandatory first member. Returns true when created. async function ensureGroup(name, ownerDn, description) { try { await Group.add({ name, owner: ownerDn, description }); return true; } catch (err) { if (err.name !== 'EntryAlreadyExistsError' && err.code !== 68) { console.error(`ensureGroup: failed to create ${name}:`, err); } return false; } } // Provision the site-level groups + the aggregates the per-resource groups nest // into. Idempotent -- called on every directory list so a site seeded by an // older release gets its groups without a rebuild: // // god_admin -> {site}_super_admin // {site}_super_admin -> {site}_hosts_admin, {site}_apps_admin // {site}_hosts_admin -> {site}_hosts_access ; {site}_apps_admin -> {site}_apps_access // // `{site}_everyone` is created for completeness; it has implicit membership and // is granted to a resource as a grantee, never enumerated. async function ensureSiteGroups(siteSlug, ownerDn, siteName, siteResourceId) { if (!siteSlug) return; // Link a site group to the site resource (so it shows + is member-manageable // on the site's modal). Idempotent. Admin groups link as owner; access/meta // groups as member. const link = async (cn, isAdmin) => { if (!siteResourceId) return; await ResourceGroup.create({ resourceId: siteResourceId, groupCn: cn, accessLevel: isAdmin ? 'owner' : 'member' }).catch(() => {}); }; const sAdmin = groups.siteSuperAdminCns(siteSlug); await ensureGroup(sAdmin, ownerDn, `Site admin for ${siteName || siteSlug}`); await link(sAdmin, true); for (const kind of ['host', 'app']) { const aggAdmin = groups.aggregateGroupCns(siteSlug, kind, 'admin'); const aggAccess = groups.aggregateGroupCns(siteSlug, kind, 'access'); await ensureGroup(aggAdmin, ownerDn, `Admin on all ${kind}s at ${siteSlug}`); await ensureGroup(aggAccess, ownerDn, `Access to all ${kind}s at ${siteSlug}`); await link(aggAdmin, true); await link(aggAccess, false); } await ensureGroup(groups.siteEveryoneCns(siteSlug), ownerDn, `All users at ${siteSlug}`); await link(groups.siteEveryoneCns(siteSlug), false); // god_admin is the global group; surface it on the site modal so its members // can be managed from the Directory (it has no home on a single resource). await link(groups.GOD_ADMIN, true); // Wire the lattice as nesting so LDAP-level consumers (SSSD, sudo, anything // binding directly) resolve it transitively, not just utils/permission.js. // nestGroup(child, parent) makes child a member of parent -- membership flows // child -> parent ("up"), so a group's members inherit what its parents hold. await nestGroup(groups.GOD_ADMIN, sAdmin); // god admins are site admins everywhere for (const kind of ['host', 'app']) { const aggAdmin = groups.aggregateGroupCns(siteSlug, kind, 'admin'); const aggAccess = groups.aggregateGroupCns(siteSlug, kind, 'access'); await nestGroup(sAdmin, aggAdmin); // site admins administer all hosts/apps await nestGroup(aggAdmin, aggAccess); // site admin implies site access } } // Provision the per-resource groups for a host/app and nest them into the site // aggregates (so a site/aggregate admin reaches this resource by membership). // The specific group name uses the resource's slug verbatim // (`{site}_{slug}_{level}` -- the kind is carried in the slug, e.g. `host_theta-env`); // `kind` (host/app) selects which aggregate the group nests into: // // {site}_{slug}_admin -> {site}_{slug}_access // {site}_{slug}_admin -> {site}_{kind}s_admin (aggregate) // {site}_{slug}_access -> {site}_{kind}s_access (aggregate) // god_admin -> {site}_{slug}_admin (global super admin) async function provisionResourceGroups(resource, kind, siteSlug, ownerDn) { const accessCn = groups.resourceGroupCns(siteSlug, resource.slug, 'access'); const adminCn = groups.resourceGroupCns(siteSlug, resource.slug, 'admin'); await ensureGroup(accessCn, ownerDn, `Access group for ${resource.name}`); await ensureGroup(adminCn, ownerDn, `Admin group for ${resource.name}`); // Link both groups to the resource so the Directory can show/revoke them. await ResourceGroup.create({ resourceId: resource.id, groupCn: accessCn, accessLevel: 'member' }).catch(() => {}); await ResourceGroup.create({ resourceId: resource.id, groupCn: adminCn, accessLevel: 'owner' }).catch(() => {}); await nestGroup(adminCn, accessCn); // administering implies using await nestGroup(adminCn, groups.aggregateGroupCns(siteSlug, kind, 'admin')); // aggregate admin reaches this resource await nestGroup(accessCn, groups.aggregateGroupCns(siteSlug, kind, 'access')); // aggregate access reaches this resource await nestGroup(SUPER_ADMIN_GROUP, adminCn); // legacy cross-app super admin } // The group CNs it is valid to associate with a given resource (docs/GROUPS.md // §2/§3). This is what "force the correct naming convention" means: a group // linked to a resource must be one that parses for consumers -- the resource's // own specific groups, its site's aggregates, site-level groups, or the global // god_admin. Returns a Set of the fixed valid CNs plus a RegExp for opaque // capability groups following the same shapes. function validGroupCnsForResource(resource, siteSlug) { const valid = new Set(); if (resource.kind === 'site') { valid.add(groups.siteSuperAdminCns(siteSlug)); valid.add(groups.siteEveryoneCns(siteSlug)); for (const k of ['host', 'app']) { valid.add(groups.aggregateGroupCns(siteSlug, k, 'admin')); valid.add(groups.aggregateGroupCns(siteSlug, k, 'access')); } return { valid, capRe: new RegExp(`^${siteSlug}_(hosts|apps)_[a-z0-9-]+$`) }; } const kind = groupKind(resource); // 'host'|'app'|null if (kind) { const slug = resource.slug; // verbatim (kind is carried in the slug) valid.add(groups.resourceGroupCns(siteSlug, slug, 'admin')); valid.add(groups.resourceGroupCns(siteSlug, slug, 'access')); valid.add(groups.aggregateGroupCns(siteSlug, kind, 'admin')); valid.add(groups.aggregateGroupCns(siteSlug, kind, 'access')); valid.add(groups.siteSuperAdminCns(siteSlug)); valid.add(groups.siteEveryoneCns(siteSlug)); return { valid, capRe: new RegExp(`^${siteSlug}_(${slug}_|${kind}s_)[a-z0-9-]+$`) }; } // oauth/container etc. — only the global god_admin makes sense to pin here. valid.add(groups.siteSuperAdminCns(siteSlug)); return { valid, capRe: null }; } // Require the admin group router.use(async (req, res, next) => { try { await permission.byGroup(req.user, ['app_sso_directory_admin', 'app_sso_admin']); next(); } catch(err) { next(err); } }); // --- Resources --- router.get('/resources', async (req, res, next) => { try { let resources = await Resource.list(); resources = resources.filter(r => { const isAuto = r.metadata?.discovery_sources?.length > 0 && !r.metadata.discovery_sources.includes('manual'); const isManaged = r.metadata?.managed === true; return !isAuto || isManaged; }); // Even admins never receive secret metadata (e.g. client_secret_hash) over // the wire; projectResources strips it unconditionally. // Self-heal the group model (docs/GROUPS.md): ensure every site has its // site-level groups (S_super_admin, S_hosts_*, S_apps_*, S_everyone) + the // aggregates, and every host/app resource has its per-resource groups nested // into them. Idempotent, so this is a cheap no-op once present -- it's what // backfills a directory seeded by an older release without a rebuild. // Never fails the list. const sites = resources.filter(r => r.kind === 'site'); await Promise.all(sites.map(site => ensureSiteGroups(site.slug, req.user.dn, site.name, site.id) .catch(err => console.error(`ensureSiteGroups(${site.slug}) failed:`, err.message)) )); const siteByResource = new Map(); for (const site of sites) siteByResource.set(site.id, site.slug); const siteOf = async (r) => { const direct = siteByResource.get(r.id); if (direct) return direct; // findAncestorSiteSlug returns the site's full slug (`site_local`) -- the // group-model builders take it verbatim, so do NOT strip the `site_` prefix. return await Resource.findAncestorSiteSlug(r.id).catch(() => null); }; await Promise.all(resources.map(async (r) => { const gKind = groupKind(r); if (!gKind) return; const siteSlug = await siteOf(r); if (!siteSlug) return; await provisionResourceGroups(r, gKind, siteSlug, req.user.dn) .catch(err => console.error(`provisionResourceGroups(${r.slug}) failed:`, err.message)); })); res.json({ results: projectResources(resources, { fullMetadata: true }) }); } catch (err) { next(err); } }); router.post('/resources', async (req, res, next) => { try { if (!req.body.hostId && req.body.parentSlug) { const parents = await Resource.list({ where: { slug: req.body.parentSlug } }); if (parents.length > 0) req.body.hostId = parents[0].id; } if (req.body.kind === 'host' && !req.body.hostId) { return res.status(400).json({ error: 'Hosts must have a parent Site or Host' }); } if (req.body.kind === 'service' && !req.body.hostId) { return res.status(400).json({ error: 'Services must have a parent Host' }); } if (req.body.kind === 'oauth' && !req.body.hostId) { return res.status(400).json({ error: 'OAuth Integrations must have a parent Service' }); } req.body.owner = req.body.owner || req.user.uid; const now = Date.now(); req.body.created_by = req.body.created_by || req.user.uid; req.body.created_on = now; req.body.updated_by = req.user.uid; req.body.updated_on = now; let r; if (req.body.kind === 'oauth') { const { OAuthClient } = require('../models/oauth_client'); // Pass created_by explicitly for the wrapper (overrides the generic // assignment above -- this is OAuthClient-wrapper-specific behavior). req.body.created_by = req.body.owner; // In the UI we might pass slug, but OAuthClient wrapper expects name r = await OAuthClient.add(req.body); } else { r = await Resource.create(req.body); } if ((r.kind === 'host' || r.kind === 'service' || r.kind === 'oauth') && req.body.hostId) { await ResourceEdge.create({ parentId: req.body.hostId, childId: r.id, relation: r.kind === 'oauth' ? 'oauth' : 'hosts' }); } // ── Group provisioning (docs/GROUPS.md) ─────────────────────────────── // Materialize the group-model for the new resource. Site resources get the // site-level groups; host/app resources get their per-resource groups nested // into the site aggregates. Idempotent -- safe for a resource created by an // older release. A provisioning failure must not fail resource creation: the // resource already exists and the groups are repairable (re-run ensures them). // // `siteSlug` is the site resource's slug verbatim (`site_local`) -- the // group-model builders treat it as opaque (docs/GROUPS.md §3) and re-apply // the kind prefix themselves. const gKind = groupKind(r); const ancestorSite = await Resource.findAncestorSiteSlug(r.id); if (r.kind === 'site') { await ensureSiteGroups(r.slug, req.user.dn, r.name, r.id); } else if (gKind && ancestorSite) { await ensureSiteGroups(ancestorSite, req.user.dn, r.name); // backfill site tier if missing await provisionResourceGroups(r, gKind, ancestorSite, req.user.dn); } res.json({ results: r }); } catch (err) { if (err.name === 'SequelizeUniqueConstraintError') { return res.status(400).json({ error: 'A resource with this slug already exists.' }); } if (err.name === 'SequelizeValidationError') { return res.status(400).json({ error: err.message }); } next(err); } }); router.put('/resources/:id', async (req, res, next) => { try { // Validate before loading anything -- a rejected body should never have // touched the store. if (req.body.kind === 'host' && !req.body.hostId) { return res.status(400).json({ error: 'Hosts must have a parent Site or Host' }); } if (req.body.kind === 'service' && !req.body.hostId) { return res.status(400).json({ error: 'Services must have a parent Host' }); } if (req.body.kind === 'oauth' && !req.body.hostId) { return res.status(400).json({ error: 'OAuth Integrations must have a parent Service' }); } // OAuthClient is a wrapper over the same `resource` row, but its .update() // handles the oauth-specific body fields (redirect_uris, scopes, // token_lifetime) that a bare Resource would drop into metadata unvalidated. const { OAuthClient } = require('../models/oauth_client'); const model = req.body.kind === 'oauth' ? OAuthClient : Resource; const r = await model.get(req.params.id); if (!r) return res.status(404).json({ error: 'Not found' }); req.body.updated_by = req.user.uid; req.body.updated_on = Date.now(); const updated = await r.update(req.body); if ((updated.kind === 'host' || updated.kind === 'service' || updated.kind === 'oauth') && req.body.hostId !== undefined) { const existingEdges = await ResourceEdge.list({ where: { childId: r.id } }); for (const e of existingEdges) { if (e.relation === 'hosts' || e.relation === 'oauth') await e.delete(); } if (req.body.hostId) { await ResourceEdge.create({ parentId: req.body.hostId, childId: r.id, relation: updated.kind === 'oauth' ? 'oauth' : 'hosts' }); } } res.json({ results: updated }); } catch (err) { next(err); } }); router.post('/resources/:id/rotate-secret', async (req, res, next) => { try { const { OAuthClient } = require('../models/oauth_client'); const client = await OAuthClient.get(req.params.id); const secret = await client.rotateSecret(); res.json({ secret }); } catch (err) { next(err); } }); router.post('/resources/:id/service-token', async (req, res, next) => { try { const { ServiceToken } = require('../models/token'); const token = await ServiceToken.issue(req.params.id, req.user.uid); res.json({ results: { token: token.token } }); } catch (err) { next(err); } }); router.delete('/resources/:id', async (req, res, next) => { try { const r = await Resource.get(req.params.id); if (!r) return res.status(404).json({ error: 'Not found' }); // Clear the dependents FIRST. There is no transaction here, so ordering is // the only thing protecting us: if a dependent delete throws after the // resource row is gone, the leftovers are edges/links pointing at a // nonexistent id -- invisible in the UI and poisonous to getGraph(). Failing // with the resource still present is the recoverable direction (retry the // delete); the caller sees the error either way. const edgesParent = await ResourceEdge.list({ where: { parentId: req.params.id } }); const edgesChild = await ResourceEdge.list({ where: { childId: req.params.id } }); const groups = await ResourceGroup.list({ where: { resourceId: req.params.id } }); for (const e of [...edgesParent, ...edgesChild]) await e.delete(); for (const g of groups) await g.delete(); await r.delete(); res.json({ results: true }); } catch (err) { next(err); } }); // --- Edges --- router.get('/edges', async (req, res, next) => { try { const edges = await ResourceEdge.list(); res.json({ results: edges }); } catch (err) { next(err); } }); router.post('/edges', async (req, res, next) => { try { const edge = await ResourceEdge.create(req.body); res.json({ results: edge }); } catch (err) { next(err); } }); router.delete('/edges/:id', async (req, res, next) => { try { const edge = await ResourceEdge.get(req.params.id); if (!edge) return res.status(404).json({ error: 'Not found' }); await edge.delete(); res.json({ results: true }); } catch (err) { next(err); } }); // --- Groups --- router.get('/groups', async (req, res, next) => { try { const groups = await ResourceGroup.list(); res.json({ results: groups }); } catch (err) { next(err); } }); router.post('/groups', async (req, res, next) => { try { const { resourceId, groupCn } = req.body; if (!resourceId || !groupCn) return res.status(400).json({ error: 'resourceId and groupCn are required' }); // Enforce the group-model naming convention (docs/GROUPS.md §3). The CN must // be a valid group for this resource; reject free-form names so the groups // consumers read are always parseable. god_admin is always allowed (it is // the global group and is managed from a site's modal). const resource = await Resource.get(resourceId); // Full site slug verbatim (`site_local`) -- the builders take it as-is. A // site resource's own slug is its site; a host/app uses its ancestor site. const siteSlug = resource && resource.kind === 'site' ? resource.slug : await Resource.findAncestorSiteSlug(resourceId); if (resource && siteSlug && groupCn !== groups.GOD_ADMIN) { const { valid, capRe } = validGroupCnsForResource(resource, siteSlug); if (!valid.has(groupCn) && !(capRe && capRe.test(groupCn))) { const err = new Error(`"${groupCn}" is not a valid group for this ${resource.kind}. Use the resource's own groups, a site aggregate, a site-level group, or god_admin (e.g. ${[...valid].join(', ')}).`); err.status = 400; throw err; } } const g = await ResourceGroup.create(req.body); res.json({ results: g }); } catch (err) { next(err); } }); router.delete('/groups/:id', async (req, res, next) => { try { const g = await ResourceGroup.get(req.params.id); if (!g) return res.status(404).json({ error: 'Not found' }); await g.delete(); res.json({ results: true }); } catch (err) { next(err); } }); // --- Access visibility --- // // The two questions an access-control pane has to answer, neither of which the // directory could answer before: "who can reach this resource" (a column on the // table, rather than three clicks into a modal) and "what can this user reach" // (which had no UI at all). Both are joins of the same two sets, so both are // served from one cached Group.listDetail() rather than a lookup per row. // dn -> uid, so member DNs can be reported as the uids admins actually think in. async function dnToUidMap() { const users = await User.listDetail(); return new Map(users.map(u => [String(u.dn).toLowerCase(), u.uid])); } // GET /access-summary — { resourceId: { groups: [...], memberCount } } router.get('/access-summary', async (req, res, next) => { try { const [links, groups, uidByDn] = await Promise.all([ ResourceGroup.list(), Group.listDetail(), dnToUidMap(), ]); const groupByCn = new Map(groups.map(g => [g.cn, g])); const summary = {}; for (const link of links) { const group = groupByCn.get(link.groupCn); // A link whose LDAP group has been deleted out from under it: report it // rather than skipping, since a dangling link grants nothing and the // admin needs to see that it is dead. // // Counts come from the transitive closure, not from `member`. Reading the // attribute would report only who is listed on the group, missing anyone // who reaches it through a nested group -- and since god_admin is // nested into every resource's _admin group, that is not an edge case. let members = []; if (group) { const eff = await Group.effectiveMembers(link.groupCn); members = eff.effective.map(dn => uidByDn.get(String(dn).toLowerCase()) || cnFromDn(dn)); } const entry = summary[link.resourceId] || (summary[link.resourceId] = { groups: [], members: [] }); entry.groups.push({ cn: link.groupCn, accessLevel: link.accessLevel, exists: !!group, memberCount: members.length, }); for (const uid of members) { if (!entry.members.includes(uid)) entry.members.push(uid); } } for (const id of Object.keys(summary)) { summary[id].memberCount = summary[id].members.length; } res.json({ results: summary }); } catch (err) { next(err); } }); // GET /user-access/:uid — every resource a given user can reach, and via which // group. This is the reverse lookup; previously an admin could only see their // own access, via /api/discovery/me. router.get('/user-access/:uid', async (req, res, next) => { try { const user = await User.get({ uid: req.params.uid }); if (!user) return res.status(404).json({ error: 'User not found' }); const dn = String(user.dn).toLowerCase(); const groups = await Group.listDetail(); const memberOf = groups .filter(g => [].concat(g.member || []).some(m => String(m).toLowerCase() === dn)) .map(g => g.cn); const [links, resources] = await Promise.all([ResourceGroup.list(), Resource.list()]); const byId = new Map(resources.map(r => [r.id, r])); const results = []; for (const link of links) { if (!memberOf.includes(link.groupCn)) continue; const resource = byId.get(link.resourceId); if (!resource) continue; results.push({ id: resource.id, name: resource.name, slug: resource.slug, kind: resource.kind, groupCn: link.groupCn, accessLevel: link.accessLevel, }); } res.json({ results: { uid: user.uid, groups: memberOf, resources: results } }); } catch (err) { next(err); } }); // Tail the last `lines` lines of a log file without shelling out. Reads at most // the trailing MAX_TAIL_BYTES so an unrotated multi-GB log can't blow up the // heap. A missing/unreadable file is normal (the log only exists once slapd has // written to it), so it yields '' rather than an error. const MAX_TAIL_BYTES = 256 * 1024; async function tailFile(filePath, lines = 100) { const fs = require('fs/promises'); let fh; try { fh = await fs.open(filePath, 'r'); const { size } = await fh.stat(); const start = Math.max(0, size - MAX_TAIL_BYTES); const buf = Buffer.alloc(Math.min(size, MAX_TAIL_BYTES)); await fh.read(buf, 0, buf.length, start); const text = buf.toString('utf8'); // A partial first line when we started mid-file; drop it. const rows = (start > 0 ? text.slice(text.indexOf('\n') + 1) : text).split('\n'); return rows.slice(-lines).join('\n'); } catch (err) { return ''; } finally { if (fh) await fh.close().catch(() => {}); } } router.get('/audit-logs', async (req, res, next) => { try { const [ldap, oauth, audit] = await Promise.all([ tailFile('/var/lib/ldap/slapd.log'), tailFile('/var/lib/ldap/oauth.log'), tailFile('/var/lib/ldap/auditlog.ldif'), ]); res.json({ results: { ldap, oauth, audit } }); } catch (err) { next(err); } }); module.exports = router;