Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| c46f27edef | |||
| 542a607b53 | |||
| a31d05b7c2 |
98
scripts/verify-team.mjs
Normal file
98
scripts/verify-team.mjs
Normal file
@@ -0,0 +1,98 @@
|
||||
// Standalone JS port of `lib/team.ts::isValidInviteRole` and the
|
||||
// org-membership decision used by POST /api/tenants/[name]/assignments.
|
||||
|
||||
function isValidInviteRole(role) {
|
||||
return role === "owner" || role === "user";
|
||||
}
|
||||
|
||||
// Mirrors the assignment-time check: target user must exist in the
|
||||
// org's member list. Returns true if assign should proceed.
|
||||
function canAssign(targetUserId, orgMembers) {
|
||||
return orgMembers.some((m) => m.userId === targetUserId);
|
||||
}
|
||||
|
||||
// Mirrors the dropdown candidate-filter on the AssignedUsersPanel:
|
||||
// only `user`-role members who aren't already assigned, excluding
|
||||
// owners (who have implicit access).
|
||||
function pickCandidates(orgMembers, alreadyAssigned) {
|
||||
const assigned = new Set(alreadyAssigned);
|
||||
return orgMembers.filter(
|
||||
(m) =>
|
||||
!assigned.has(m.userId) &&
|
||||
m.roles.includes("user") &&
|
||||
!m.roles.includes("owner")
|
||||
);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Test fixtures
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
const orgMembers = [
|
||||
{ userId: "u-1", roles: ["owner"] },
|
||||
{ userId: "u-2", roles: ["user"] },
|
||||
{ userId: "u-3", roles: ["user"] },
|
||||
{ userId: "u-4", roles: [] }, // member with no role yet
|
||||
{ userId: "u-5", roles: ["owner", "user"] }, // dual-role
|
||||
];
|
||||
|
||||
let pass = 0, fail = 0;
|
||||
|
||||
console.log("--- isValidInviteRole ---");
|
||||
const inviteCases = [
|
||||
["owner", true, "owner is valid"],
|
||||
["user", true, "user is valid"],
|
||||
["viewer", false, "viewer rejected (dropped in Slice 5)"],
|
||||
["platform_admin", false, "platform_admin not invitable"],
|
||||
["platform_operator", false, "platform_operator not invitable"],
|
||||
["", false, "empty rejected"],
|
||||
["OWNER", false, "case-sensitive"],
|
||||
];
|
||||
for (const [role, expected, note] of inviteCases) {
|
||||
const got = isValidInviteRole(role);
|
||||
const ok = got === expected;
|
||||
console.log(`${ok ? "PASS" : "FAIL"} got=${got} want=${expected} [${note}]`);
|
||||
if (ok) pass++; else fail++;
|
||||
}
|
||||
|
||||
console.log("\n--- canAssign (membership check) ---");
|
||||
const assignCases = [
|
||||
["u-1", true, "owner can be assigned (idempotent for owners)"],
|
||||
["u-2", true, "user-role member can be assigned"],
|
||||
["u-99", false, "non-member rejected"],
|
||||
["", false, "empty userId rejected"],
|
||||
];
|
||||
for (const [targetId, expected, note] of assignCases) {
|
||||
const got = canAssign(targetId, orgMembers);
|
||||
const ok = got === expected;
|
||||
console.log(`${ok ? "PASS" : "FAIL"} got=${got} want=${expected} [${note}]`);
|
||||
if (ok) pass++; else fail++;
|
||||
}
|
||||
|
||||
console.log("\n--- pickCandidates (assign dropdown) ---");
|
||||
const candidateCases = [
|
||||
{
|
||||
assigned: [],
|
||||
expected: ["u-2", "u-3"],
|
||||
note: "user-role members minus owners (u-5 is owner+user, excluded)",
|
||||
},
|
||||
{
|
||||
assigned: ["u-2"],
|
||||
expected: ["u-3"],
|
||||
note: "u-2 already assigned, only u-3 remains",
|
||||
},
|
||||
{
|
||||
assigned: ["u-2", "u-3"],
|
||||
expected: [],
|
||||
note: "everyone assigned",
|
||||
},
|
||||
];
|
||||
for (const c of candidateCases) {
|
||||
const got = pickCandidates(orgMembers, c.assigned).map((m) => m.userId);
|
||||
const ok = JSON.stringify(got) === JSON.stringify(c.expected);
|
||||
console.log(`${ok ? "PASS" : "FAIL"} got=${JSON.stringify(got)} want=${JSON.stringify(c.expected)} [${c.note}]`);
|
||||
if (ok) pass++; else fail++;
|
||||
}
|
||||
|
||||
console.log(`\n${pass} pass, ${fail} fail`);
|
||||
process.exit(fail === 0 ? 0 : 1);
|
||||
506
scripts/zitadel-roles.mjs
Normal file
506
scripts/zitadel-roles.mjs
Normal file
@@ -0,0 +1,506 @@
|
||||
#!/usr/bin/env node
|
||||
/**
|
||||
* zitadel-roles.mjs — diagnose and repair the OpenClaw Platform project's
|
||||
* role keys + customer authorizations. Group A of the bug triage.
|
||||
*
|
||||
* Subcommands
|
||||
* -----------
|
||||
* diagnose Print the project's current roles and a raw dump
|
||||
* of all authorizations granted on the project.
|
||||
* Read-only. Safe to run any time.
|
||||
*
|
||||
* apply Idempotently create the four canonical role keys
|
||||
* (owner, user, platform_admin, platform_operator)
|
||||
* if they are missing. Existing roles are left as
|
||||
* they are; legacy keys (e.g. "customer") are NOT
|
||||
* deleted by this command — see `migrate-auth`.
|
||||
*
|
||||
* migrate-auth <user> Drop every authorization the given user holds
|
||||
* on the project and replace with a single
|
||||
* authorization carrying ["owner"]. Use after
|
||||
* `apply` to promote a legacy customer to the
|
||||
* new role keys. Idempotent.
|
||||
*
|
||||
* migrate-grants Ensure every existing project grant on the
|
||||
* OpenClaw Platform project includes both
|
||||
* `owner` and `user` role keys. Without `user`
|
||||
* in the grant, `CreateAuthorization` for an
|
||||
* invited member returns Errors.Project.Role.NotFound
|
||||
* (Bug 21). Idempotent: grants already containing
|
||||
* both keys are skipped.
|
||||
*
|
||||
* Env vars (loaded from .env if you run with `node --env-file=.env`):
|
||||
* ZITADEL_ISSUER e.g. https://auth.pieced.ch
|
||||
* ZITADEL_SA_PAT PAT for pieced-sa (IAM_OWNER)
|
||||
* ZITADEL_PROJECT_ID e.g. 367435120493199793
|
||||
*
|
||||
* Examples
|
||||
* --------
|
||||
* node --env-file=.env scripts/zitadel-roles.mjs diagnose
|
||||
* node --env-file=.env scripts/zitadel-roles.mjs apply
|
||||
* node --env-file=.env scripts/zitadel-roles.mjs migrate-auth 12345...
|
||||
*
|
||||
* The script does not import from src/ on purpose — it must be runnable
|
||||
* even when the portal can't start (which is the failure mode we're
|
||||
* here to repair).
|
||||
*/
|
||||
|
||||
const ISSUER = process.env.ZITADEL_ISSUER;
|
||||
const PAT = process.env.ZITADEL_SA_PAT;
|
||||
const PROJECT_ID = process.env.ZITADEL_PROJECT_ID;
|
||||
|
||||
if (!ISSUER || !PAT || !PROJECT_ID) {
|
||||
console.error(
|
||||
"Missing env. Need ZITADEL_ISSUER, ZITADEL_SA_PAT, ZITADEL_PROJECT_ID."
|
||||
);
|
||||
console.error("Run with: node --env-file=.env scripts/zitadel-roles.mjs ...");
|
||||
process.exit(2);
|
||||
}
|
||||
|
||||
// Canonical role set — must match types/index.ts (CustomerRole + PlatformRole).
|
||||
const CANONICAL = [
|
||||
{ key: "owner", displayName: "Customer Owner", group: "Customer" },
|
||||
{ key: "user", displayName: "Customer User", group: "Customer" },
|
||||
{ key: "platform_admin", displayName: "Platform Admin", group: "Platform" },
|
||||
{
|
||||
key: "platform_operator",
|
||||
displayName: "Platform Operator",
|
||||
group: "Platform",
|
||||
},
|
||||
];
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// HTTP plumbing — Connect RPC against ZITADEL v2 services.
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
async function rpc(service, method, body) {
|
||||
const url = `${ISSUER}/${service}/${method}`;
|
||||
const res = await fetch(url, {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
Accept: "application/json",
|
||||
Authorization: `Bearer ${PAT}`,
|
||||
"Connect-Protocol-Version": "1",
|
||||
},
|
||||
body: JSON.stringify(body),
|
||||
});
|
||||
const text = await res.text();
|
||||
if (!res.ok) {
|
||||
const err = new Error(`${service}/${method} -> ${res.status}: ${text}`);
|
||||
err.status = res.status;
|
||||
err.body = text;
|
||||
throw err;
|
||||
}
|
||||
return text ? JSON.parse(text) : {};
|
||||
}
|
||||
|
||||
const projectSvc = "zitadel.project.v2.ProjectService";
|
||||
const authSvc = "zitadel.authorization.v2.AuthorizationService";
|
||||
|
||||
async function listProjectRoles() {
|
||||
const data = await rpc(projectSvc, "ListProjectRoles", {
|
||||
projectId: PROJECT_ID,
|
||||
});
|
||||
return Array.isArray(data?.projectRoles) ? data.projectRoles : [];
|
||||
}
|
||||
|
||||
async function addProjectRole(roleKey, displayName, group) {
|
||||
return rpc(projectSvc, "AddProjectRole", {
|
||||
projectId: PROJECT_ID,
|
||||
roleKey,
|
||||
displayName,
|
||||
...(group ? { group } : {}),
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* The Connect RPC filter shape for ListAuthorizations is a oneof variant
|
||||
* map — each filter has a discriminator key matching one of the variants
|
||||
* documented as `authorization_ids|in_user_ids|organization_id|project_id|
|
||||
* role_key|...`. Different ZITADEL services and versions differ on the
|
||||
* exact wrapper naming (e.g. `projectId` vs `projectIdFilter`) and on
|
||||
* whether ID values are bare strings or wrapped in `{ id: "..." }`.
|
||||
*
|
||||
* Rather than guess, we probe candidate shapes until ZITADEL accepts one.
|
||||
* The winner tells us exactly what to bake into `lib/zitadel.ts`. Each
|
||||
* candidate is labelled so the diagnostic output makes the right choice
|
||||
* obvious.
|
||||
*/
|
||||
const FILTER_CANDIDATES = [
|
||||
// No filter at all — ZITADEL returns whatever the SA can see. Slowest
|
||||
// but always works; useful as a control.
|
||||
{
|
||||
label: "no-filter",
|
||||
build: () => ({}),
|
||||
},
|
||||
// Pattern from discussion #8831 (roleKey -> key+method). Plausible
|
||||
// generalisation: project_id -> projectId.id
|
||||
{
|
||||
label: "projectId.id",
|
||||
build: (projectId) => ({ filters: [{ projectId: { id: projectId } }] }),
|
||||
},
|
||||
// Pattern from ProjectService.ListProjects (organizationIdFilter -> organizationId).
|
||||
{
|
||||
label: "projectIdFilter.id",
|
||||
build: (projectId) => ({
|
||||
filters: [{ projectIdFilter: { id: projectId } }],
|
||||
}),
|
||||
},
|
||||
// Same family but with the value field named after the filter, like the
|
||||
// user search API uses (`organizationIdQuery: { organizationId: "..." }`).
|
||||
{
|
||||
label: "projectIdFilter.projectId",
|
||||
build: (projectId) => ({
|
||||
filters: [{ projectIdFilter: { projectId } }],
|
||||
}),
|
||||
},
|
||||
// Bare-string variant — just in case.
|
||||
{
|
||||
label: "projectId (bare string)",
|
||||
build: (projectId) => ({ filters: [{ projectId }] }),
|
||||
},
|
||||
];
|
||||
|
||||
const USER_FILTER_CANDIDATES = [
|
||||
{ label: "userId.id", key: "userId", build: (id) => ({ id }) },
|
||||
{ label: "userIdFilter.id", key: "userIdFilter", build: (id) => ({ id }) },
|
||||
{ label: "userIdFilter.userId", key: "userIdFilter", build: (id) => ({ userId: id }) },
|
||||
];
|
||||
|
||||
/**
|
||||
* Try every candidate; return on the first one that returns 200. Logs each
|
||||
* attempt so a reader can see which shape won.
|
||||
*/
|
||||
async function probeListAuthorizations(extraFilters = []) {
|
||||
for (const c of FILTER_CANDIDATES) {
|
||||
const body = c.build(PROJECT_ID);
|
||||
if (extraFilters.length > 0) {
|
||||
body.filters = (body.filters || []).concat(extraFilters);
|
||||
}
|
||||
body.pagination = { limit: 500 };
|
||||
try {
|
||||
const data = await rpc(authSvc, "ListAuthorizations", body);
|
||||
const count = Array.isArray(data?.authorizations)
|
||||
? data.authorizations.length
|
||||
: 0;
|
||||
console.log(` OK ${c.label.padEnd(28)} -> ${count} authorization(s)`);
|
||||
return { label: c.label, body, data };
|
||||
} catch (err) {
|
||||
const oneLine = String(err.body || err.message)
|
||||
.replace(/\s+/g, " ")
|
||||
.slice(0, 110);
|
||||
console.log(` FAIL ${c.label.padEnd(28)} -> ${oneLine}`);
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
async function listUserAuthorizations(userId) {
|
||||
// Use the same project-filter shape that won the probe, plus a user-id
|
||||
// filter probed independently.
|
||||
const probed = await probeListAuthorizations();
|
||||
if (!probed) throw new Error("No filter shape accepted by ZITADEL");
|
||||
|
||||
for (const u of USER_FILTER_CANDIDATES) {
|
||||
const body = JSON.parse(JSON.stringify(probed.body));
|
||||
body.filters = (body.filters || []).concat([
|
||||
{ [u.key]: u.build(userId) },
|
||||
]);
|
||||
try {
|
||||
const data = await rpc(authSvc, "ListAuthorizations", body);
|
||||
console.log(` user filter ${u.label} accepted.`);
|
||||
return data;
|
||||
} catch (err) {
|
||||
// Try next.
|
||||
}
|
||||
}
|
||||
// Fallback: return all and filter client-side from the user dump.
|
||||
return probed.data;
|
||||
}
|
||||
|
||||
async function deleteAuthorization(authorizationId) {
|
||||
return rpc(authSvc, "DeleteAuthorization", { id: authorizationId });
|
||||
}
|
||||
|
||||
async function createAuthorization(userId, organizationId, roleKeys) {
|
||||
return rpc(authSvc, "CreateAuthorization", {
|
||||
userId,
|
||||
projectId: PROJECT_ID,
|
||||
organizationId,
|
||||
roleKeys,
|
||||
});
|
||||
}
|
||||
|
||||
async function listProjectGrants() {
|
||||
// Same approach as authorizations: skip server-side filters, narrow
|
||||
// client-side by projectId. Pilot scale; cheap.
|
||||
const data = await rpc(projectSvc, "ListProjectGrants", {
|
||||
pagination: { limit: 500 },
|
||||
});
|
||||
const all = Array.isArray(data?.projectGrants) ? data.projectGrants : [];
|
||||
return all.filter((g) => g?.projectId === PROJECT_ID);
|
||||
}
|
||||
|
||||
async function updateProjectGrant(grantedOrganizationId, roleKeys) {
|
||||
return rpc(projectSvc, "UpdateProjectGrant", {
|
||||
projectId: PROJECT_ID,
|
||||
grantedOrganizationId,
|
||||
roleKeys,
|
||||
});
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Subcommands
|
||||
// ---------------------------------------------------------------------------
|
||||
|
||||
async function diagnose() {
|
||||
console.log(`Project: ${PROJECT_ID}`);
|
||||
console.log(`Issuer: ${ISSUER}\n`);
|
||||
|
||||
console.log("--- Project roles ---");
|
||||
const roles = await listProjectRoles();
|
||||
if (roles.length === 0) {
|
||||
console.log(" (none)");
|
||||
} else {
|
||||
for (const r of roles) {
|
||||
console.log(` key=${r.key.padEnd(20)} displayName=${r.displayName ?? ""} group=${r.group ?? ""}`);
|
||||
}
|
||||
}
|
||||
|
||||
const present = new Set(roles.map((r) => r.key));
|
||||
const missing = CANONICAL.filter((c) => !present.has(c.key));
|
||||
const legacy = roles.filter((r) => !CANONICAL.some((c) => c.key === r.key));
|
||||
|
||||
console.log("\n--- Canonical key check ---");
|
||||
for (const c of CANONICAL) {
|
||||
console.log(` ${present.has(c.key) ? "OK " : "MISS"} ${c.key}`);
|
||||
}
|
||||
if (legacy.length > 0) {
|
||||
console.log("\n Non-canonical keys still on the project:");
|
||||
for (const r of legacy) console.log(` ${r.key}`);
|
||||
console.log(" (consider migrating any authorizations off these.)");
|
||||
}
|
||||
|
||||
console.log("\n--- Authorizations on project (probing filter shape) ---");
|
||||
const probed = await probeListAuthorizations();
|
||||
if (!probed) {
|
||||
console.log(
|
||||
"\nNo filter shape was accepted. Cannot enumerate authorizations."
|
||||
);
|
||||
process.exitCode = 1;
|
||||
return;
|
||||
}
|
||||
console.log(`\nWinning filter shape: ${probed.label}`);
|
||||
console.log("Raw response (first 2 entries):");
|
||||
const trimmed = {
|
||||
...probed.data,
|
||||
authorizations: (probed.data.authorizations || []).slice(0, 2),
|
||||
};
|
||||
console.log(JSON.stringify(trimmed, null, 2));
|
||||
|
||||
// Parsed view — what `lib/zitadel.ts::listOrgAuthorizations` SHOULD return
|
||||
// once the parser is fixed. Useful for confirming the response field
|
||||
// names without wading through the raw blob.
|
||||
const auths = probed.data.authorizations || [];
|
||||
console.log(`\nParsed (${auths.length} authorization(s)):`);
|
||||
for (const a of auths) {
|
||||
const userId = a.user?.id ?? "?";
|
||||
const userName = a.user?.displayName ?? a.user?.preferredLoginName ?? "";
|
||||
const orgId = a.organization?.id ?? "?";
|
||||
const orgName = a.organization?.name ?? "";
|
||||
const roleKeys = Array.isArray(a.roles)
|
||||
? a.roles.map((r) => r.key).join(",")
|
||||
: "(none)";
|
||||
console.log(
|
||||
` ${a.id?.slice(0, 12) ?? "?"}… user=${userName} (${userId.slice(0, 10)}…) org=${orgName} roles=[${roleKeys}]`
|
||||
);
|
||||
}
|
||||
|
||||
if (missing.length > 0) {
|
||||
console.log(
|
||||
`\nNext step: run \`apply\` to create ${missing.length} missing role(s).`
|
||||
);
|
||||
process.exitCode = 1;
|
||||
} else {
|
||||
console.log("\nAll canonical roles present.");
|
||||
}
|
||||
}
|
||||
|
||||
async function apply() {
|
||||
const existing = await listProjectRoles();
|
||||
const present = new Set(existing.map((r) => r.key));
|
||||
|
||||
let created = 0;
|
||||
for (const c of CANONICAL) {
|
||||
if (present.has(c.key)) {
|
||||
console.log(`SKIP ${c.key} (already exists)`);
|
||||
continue;
|
||||
}
|
||||
try {
|
||||
await addProjectRole(c.key, c.displayName, c.group);
|
||||
console.log(`ADD ${c.key}`);
|
||||
created++;
|
||||
} catch (err) {
|
||||
// ZITADEL returns AlreadyExists if a role with the same key was
|
||||
// created in a race; treat as success so the script stays idempotent.
|
||||
if (
|
||||
err.body &&
|
||||
/already.*exist/i.test(err.body)
|
||||
) {
|
||||
console.log(`SKIP ${c.key} (already exists, race)`);
|
||||
continue;
|
||||
}
|
||||
console.error(`FAIL ${c.key}: ${err.message}`);
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
console.log(`\nDone. ${created} role(s) created.`);
|
||||
}
|
||||
|
||||
async function migrateAuth(userId) {
|
||||
if (!userId) {
|
||||
console.error("Usage: migrate-auth <userId>");
|
||||
process.exit(2);
|
||||
}
|
||||
|
||||
// Verify owner role exists before we touch anything; otherwise we'd
|
||||
// delete authorizations and fail to recreate them.
|
||||
const roles = await listProjectRoles();
|
||||
if (!roles.some((r) => r.key === "owner")) {
|
||||
console.error("Project has no `owner` role. Run `apply` first.");
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
console.log(`Listing authorizations for user ${userId} on project ${PROJECT_ID}...`);
|
||||
const auths = await listUserAuthorizations(userId);
|
||||
const list = Array.isArray(auths?.authorizations) ? auths.authorizations : [];
|
||||
// Filter client-side to the requested user, in case the user filter probe
|
||||
// didn't narrow things down.
|
||||
const userAuths = list.filter((a) => a.user?.id === userId);
|
||||
|
||||
if (userAuths.length === 0) {
|
||||
console.log("No existing authorizations found. Cannot infer organizationId.");
|
||||
console.log("Pass it explicitly via the env: ORG_ID=... or use the portal flow.");
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
// Pick the organizationId from any of the existing authorizations — it
|
||||
// should be the same across all of them for a single user/project pair.
|
||||
const orgIds = [...new Set(userAuths.map((a) => a.organization?.id).filter(Boolean))];
|
||||
if (orgIds.length !== 1) {
|
||||
console.error(`Expected exactly 1 organizationId, got ${orgIds.length}: ${orgIds.join(", ")}`);
|
||||
process.exit(1);
|
||||
}
|
||||
const orgId = orgIds[0];
|
||||
|
||||
console.log(`Found ${userAuths.length} authorization(s) in org ${orgId}:`);
|
||||
for (const a of userAuths) {
|
||||
const id = a.id ?? "?";
|
||||
const keys = Array.isArray(a.roles) ? a.roles.map((r) => r.key).join(",") : "(none)";
|
||||
console.log(` ${id} roles=[${keys}]`);
|
||||
}
|
||||
|
||||
// Already correct?
|
||||
if (
|
||||
userAuths.length === 1 &&
|
||||
Array.isArray(userAuths[0].roles) &&
|
||||
userAuths[0].roles.length === 1 &&
|
||||
userAuths[0].roles[0].key === "owner"
|
||||
) {
|
||||
console.log("Already correct — no changes needed.");
|
||||
return;
|
||||
}
|
||||
|
||||
console.log("\nDeleting existing authorizations...");
|
||||
for (const a of userAuths) {
|
||||
if (!a.id) continue;
|
||||
await deleteAuthorization(a.id);
|
||||
console.log(` deleted ${a.id}`);
|
||||
}
|
||||
|
||||
console.log("Creating fresh owner authorization...");
|
||||
const created = await createAuthorization(userId, orgId, ["owner"]);
|
||||
console.log(` created ${JSON.stringify(created)}`);
|
||||
console.log("Done.");
|
||||
}
|
||||
|
||||
async function migrateGrants() {
|
||||
// Ensure every existing project grant for the OpenClaw Platform project
|
||||
// includes the `user` role alongside `owner`. Without `user` in the
|
||||
// grant, the granted org cannot invite members in `user` role —
|
||||
// `CreateAuthorization` returns `Errors.Project.Role.NotFound`.
|
||||
//
|
||||
// Idempotent: grants already containing both keys are skipped.
|
||||
// Per UpdateProjectGrant docs, `roleKeys` is REPLACE not MERGE — we
|
||||
// re-send the full desired set every time.
|
||||
const desired = ["owner", "user"];
|
||||
const grants = await listProjectGrants();
|
||||
|
||||
if (grants.length === 0) {
|
||||
console.log("No project grants found on this project.");
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(`Found ${grants.length} grant(s) on project ${PROJECT_ID}:`);
|
||||
for (const g of grants) {
|
||||
const current = Array.isArray(g.grantedRoleKeys)
|
||||
? g.grantedRoleKeys
|
||||
: [];
|
||||
const hasAll = desired.every((k) => current.includes(k));
|
||||
const action = hasAll ? "SKIP" : "FIX ";
|
||||
console.log(
|
||||
` ${action} ${g.grantedOrganizationName.padEnd(30)} current=[${current.join(",")}]`
|
||||
);
|
||||
}
|
||||
|
||||
let fixed = 0;
|
||||
for (const g of grants) {
|
||||
const current = Array.isArray(g.grantedRoleKeys)
|
||||
? g.grantedRoleKeys
|
||||
: [];
|
||||
if (desired.every((k) => current.includes(k))) continue;
|
||||
// Preserve any extra roles the grant already has on top of the
|
||||
// desired set (e.g. someone manually added `viewer` for a special
|
||||
// case). Set semantics: union.
|
||||
const merged = [...new Set([...current, ...desired])];
|
||||
try {
|
||||
await updateProjectGrant(g.grantedOrganizationId, merged);
|
||||
console.log(
|
||||
` updated ${g.grantedOrganizationName} -> [${merged.join(",")}]`
|
||||
);
|
||||
fixed++;
|
||||
} catch (err) {
|
||||
console.error(
|
||||
` FAIL ${g.grantedOrganizationName}: ${err.message}`
|
||||
);
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
console.log(`\nDone. ${fixed} grant(s) updated.`);
|
||||
}
|
||||
|
||||
const [, , cmd, ...rest] = process.argv;
|
||||
|
||||
const commands = {
|
||||
diagnose,
|
||||
apply,
|
||||
"migrate-auth": () => migrateAuth(rest[0]),
|
||||
"migrate-grants": migrateGrants,
|
||||
};
|
||||
|
||||
const fn = commands[cmd];
|
||||
if (!fn) {
|
||||
console.error(
|
||||
"Usage: zitadel-roles.mjs <diagnose|apply|migrate-auth <userId>|migrate-grants>"
|
||||
);
|
||||
process.exit(2);
|
||||
}
|
||||
|
||||
fn().catch((err) => {
|
||||
console.error(err.message ?? err);
|
||||
if (err.body) console.error("body:", err.body);
|
||||
process.exit(1);
|
||||
});
|
||||
@@ -2,7 +2,7 @@ import { getSessionUser, canMutate } from "@/lib/session";
|
||||
import { getTranslations } from "next-intl/server";
|
||||
import { redirect } from "next/navigation";
|
||||
import { OnboardingFlow } from "@/components/onboarding/onboarding-flow";
|
||||
import Link from "next/link";
|
||||
import { BackLink } from "@/components/ui/back-link";
|
||||
|
||||
/**
|
||||
* /dashboard/new — wizard for creating an additional instance for an
|
||||
@@ -33,12 +33,7 @@ export default async function NewInstancePage() {
|
||||
return (
|
||||
<div>
|
||||
<div className="mb-8 animate-in">
|
||||
<Link
|
||||
href="/dashboard"
|
||||
className="inline-flex items-center gap-1.5 mb-4 text-xs font-medium text-text-muted hover:text-text-primary transition-colors"
|
||||
>
|
||||
<span>←</span> {t("title")}
|
||||
</Link>
|
||||
<BackLink href="/dashboard" label={t("title")} />
|
||||
<h1 className="font-display text-2xl font-semibold accent-rule mb-2">
|
||||
{t("createInstance")}
|
||||
</h1>
|
||||
|
||||
64
src/app/[locale]/team/page.tsx
Normal file
64
src/app/[locale]/team/page.tsx
Normal file
@@ -0,0 +1,64 @@
|
||||
import { getSessionUser, canMutate, isCustomerOwner } from "@/lib/session";
|
||||
import { getTranslations } from "next-intl/server";
|
||||
import { redirect } from "next/navigation";
|
||||
import { getOrgMembers } from "@/lib/team";
|
||||
import { Card } from "@/components/ui/card";
|
||||
import { BackLink } from "@/components/ui/back-link";
|
||||
import { TeamList } from "@/components/team/team-list";
|
||||
import { InviteForm } from "@/components/team/invite-form";
|
||||
|
||||
/**
|
||||
* /team — manage org members.
|
||||
*
|
||||
* Visible to owners and platform users only (`canMutate`). User-role
|
||||
* members are redirected away — they shouldn't browse the roster.
|
||||
*
|
||||
* The page loads members server-side for the initial render. The
|
||||
* `<TeamList>` and `<InviteForm>` client components handle live
|
||||
* updates after invites and refreshes.
|
||||
*/
|
||||
export default async function TeamPage() {
|
||||
const user = await getSessionUser();
|
||||
if (!user) redirect("/login");
|
||||
if (!canMutate(user)) redirect("/dashboard");
|
||||
|
||||
const t = await getTranslations("team");
|
||||
const tDashboard = await getTranslations("dashboard");
|
||||
|
||||
const members = await getOrgMembers(user.orgId);
|
||||
|
||||
return (
|
||||
<div>
|
||||
<div className="mb-8 animate-in">
|
||||
<BackLink href="/dashboard" label={tDashboard("title")} />
|
||||
<h1 className="font-display text-2xl font-semibold accent-rule mb-2">
|
||||
{t("title")}
|
||||
</h1>
|
||||
<p className="text-text-secondary text-sm mt-4">{t("description")}</p>
|
||||
</div>
|
||||
|
||||
<section className="mb-8 animate-in animate-in-delay-1">
|
||||
<h2 className="text-xs font-semibold uppercase tracking-wider text-text-muted mb-3">
|
||||
{t("inviteSectionTitle")}
|
||||
</h2>
|
||||
<Card>
|
||||
<InviteForm />
|
||||
</Card>
|
||||
</section>
|
||||
|
||||
<section className="animate-in animate-in-delay-2">
|
||||
<h2 className="text-xs font-semibold uppercase tracking-wider text-text-muted mb-3">
|
||||
{t("membersSectionTitle")}{" "}
|
||||
<span className="text-text-muted/60 tabular-nums">
|
||||
({members.length})
|
||||
</span>
|
||||
</h2>
|
||||
<TeamList
|
||||
initialMembers={members}
|
||||
currentUserId={user.id}
|
||||
canEditRoles={isCustomerOwner(user)}
|
||||
/>
|
||||
</section>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -8,6 +8,7 @@ import { UsageDisplay } from "@/components/dashboard/usage-display";
|
||||
import { PackageList } from "@/components/packages/package-list";
|
||||
import { WorkspaceEditor } from "@/components/packages/workspace-editor";
|
||||
import { ChannelUsers } from "@/components/channel-users/channel-users";
|
||||
import { AssignedUsersPanel } from "@/components/tenants/assigned-users-panel";
|
||||
import { formatDateTime, formatRelative } from "@/lib/format";
|
||||
|
||||
const CHANNEL_PACKAGES = ["telegram", "discord", "email"];
|
||||
@@ -128,6 +129,16 @@ export default async function TenantDetailPage({
|
||||
</h2>
|
||||
<WorkspaceEditor tenantName={name} files={workspaceFiles} canEdit={canEdit} />
|
||||
</section>
|
||||
|
||||
{/* Slice 7: Assigned users — visible to anyone who can see the
|
||||
tenant, editable only by owners/platform users. The component
|
||||
fetches its own data so the page doesn't need to await. */}
|
||||
<section className="mt-8 animate-in animate-in-delay-4">
|
||||
<h2 className="text-xs font-semibold uppercase tracking-wider text-text-muted mb-3">
|
||||
{t("assignedUsers")}
|
||||
</h2>
|
||||
<AssignedUsersPanel tenantName={name} canEdit={canEdit} />
|
||||
</section>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
148
src/app/api/team/[userId]/role/route.ts
Normal file
148
src/app/api/team/[userId]/role/route.ts
Normal file
@@ -0,0 +1,148 @@
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
import { z } from "zod";
|
||||
import { getSessionUser, isCustomerOwner } from "@/lib/session";
|
||||
import { getOrgMembers, isValidInviteRole } from "@/lib/team";
|
||||
import { updateAuthorizationRoles } from "@/lib/zitadel";
|
||||
import { safeError } from "@/lib/errors";
|
||||
|
||||
const patchSchema = z.object({
|
||||
role: z.enum(["owner", "user"]),
|
||||
});
|
||||
|
||||
/**
|
||||
* PATCH /api/team/[userId]/role
|
||||
*
|
||||
* Change the role of an existing member of the caller's org.
|
||||
*
|
||||
* Body: { role: "owner" | "user" }
|
||||
*
|
||||
* Authorization
|
||||
* -------------
|
||||
* Customer-side: only an `owner` of the caller's org may change roles.
|
||||
* `isCustomerOwner` is the right gate — `canMutate` would also accept
|
||||
* platform users, but cross-org role mutation by platform staff
|
||||
* belongs in ZITADEL Console with audited admin tooling, not here.
|
||||
*
|
||||
* Safety guards
|
||||
* -------------
|
||||
* 1. Self-demotion is blocked. An owner demoting themself to `user`
|
||||
* could lose access to /team and never come back. If the user
|
||||
* genuinely wants to step down they should promote a colleague to
|
||||
* `owner` first, then ask that colleague to demote them.
|
||||
* 2. Last-owner demotion is blocked. Demoting the org's only owner
|
||||
* to `user` would lock the org out of all future role changes,
|
||||
* invites, and tenant requests. We count owners across the whole
|
||||
* member list and refuse if this change would leave zero.
|
||||
* 3. The target must already have an authorization on the project.
|
||||
* A member without one — orphan, mid-invite race — has nothing
|
||||
* for `UpdateAuthorization` to update; we return a clear 409.
|
||||
*
|
||||
* The mutation itself is replace-not-merge: see
|
||||
* `lib/zitadel.ts::updateAuthorizationRoles`. Passing `[role]` revokes
|
||||
* any other roles the member happened to hold.
|
||||
*/
|
||||
export async function PATCH(
|
||||
req: NextRequest,
|
||||
{ params }: { params: Promise<{ userId: string }> }
|
||||
) {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
// Only customer owners — platform staff use Console.
|
||||
if (!isCustomerOwner(user)) {
|
||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
||||
}
|
||||
|
||||
const { userId } = await params;
|
||||
|
||||
if (userId === user.id) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
error:
|
||||
"You cannot change your own role. Ask another owner, or promote a colleague to owner first.",
|
||||
code: "self_change_blocked",
|
||||
},
|
||||
{ status: 403 }
|
||||
);
|
||||
}
|
||||
|
||||
const body = await req.json().catch(() => null);
|
||||
const parsed = patchSchema.safeParse(body);
|
||||
if (!parsed.success) {
|
||||
return NextResponse.json(
|
||||
{ error: "Invalid input", details: parsed.error.flatten() },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
const { role } = parsed.data;
|
||||
// Defensive — the Zod enum already enforces this.
|
||||
if (!isValidInviteRole(role)) {
|
||||
return NextResponse.json(
|
||||
{ error: "Role must be 'owner' or 'user'." },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
|
||||
try {
|
||||
const members = await getOrgMembers(user.orgId);
|
||||
const target = members.find((m) => m.userId === userId);
|
||||
if (!target) {
|
||||
return NextResponse.json(
|
||||
{ error: "Target user is not a member of this organization." },
|
||||
{ status: 404 }
|
||||
);
|
||||
}
|
||||
if (!target.authorizationId) {
|
||||
// Should be very rare — implies the row was created out-of-band
|
||||
// (e.g. directly in Console) without an authorization. Surface a
|
||||
// clear message rather than a confusing 500 from ZITADEL.
|
||||
return NextResponse.json(
|
||||
{
|
||||
error:
|
||||
"Member has no authorization record on the project. Re-invite them or contact support.",
|
||||
code: "no_authorization",
|
||||
},
|
||||
{ status: 409 }
|
||||
);
|
||||
}
|
||||
|
||||
// Last-owner protection: this matters when the target is currently
|
||||
// an owner AND the new role is something other than owner. We could
|
||||
// narrow the count to "before this change" but the simpler form is
|
||||
// equivalent: if there's only one owner and that owner is the
|
||||
// target, refuse.
|
||||
const currentlyOwner = target.roles.includes("owner");
|
||||
if (currentlyOwner && role !== "owner") {
|
||||
const ownerCount = members.filter((m) => m.roles.includes("owner")).length;
|
||||
if (ownerCount <= 1) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
error:
|
||||
"This is the only owner. Promote another member to owner before demoting this one.",
|
||||
code: "last_owner",
|
||||
},
|
||||
{ status: 409 }
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
// No-op: target already has the requested role and ONLY that role.
|
||||
if (target.roles.length === 1 && target.roles[0] === role) {
|
||||
return NextResponse.json({ message: "No change.", role }, { status: 200 });
|
||||
}
|
||||
|
||||
await updateAuthorizationRoles(target.authorizationId, [role]);
|
||||
|
||||
return NextResponse.json(
|
||||
{ message: "Role updated.", userId, role },
|
||||
{ status: 200 }
|
||||
);
|
||||
} catch (e: any) {
|
||||
console.error("Role update failed:", e);
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to update role") },
|
||||
{ status: e.statusCode || 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
95
src/app/api/team/invite/route.ts
Normal file
95
src/app/api/team/invite/route.ts
Normal file
@@ -0,0 +1,95 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { getSessionUser, canMutate } from "@/lib/session";
|
||||
import { inviteOrgMember, isValidInviteRole } from "@/lib/team";
|
||||
import { z } from "zod";
|
||||
import { safeError } from "@/lib/errors";
|
||||
|
||||
const inviteSchema = z.object({
|
||||
email: z.string().email(),
|
||||
givenName: z.string().min(1).max(100),
|
||||
familyName: z.string().min(1).max(100),
|
||||
role: z.enum(["owner", "user"]),
|
||||
preferredLanguage: z.enum(["en", "de", "fr", "it"]).optional(),
|
||||
});
|
||||
|
||||
/**
|
||||
* POST /api/team/invite
|
||||
*
|
||||
* Invite a new member into the caller's org. Body shape:
|
||||
* { email, givenName, familyName, role: "owner" | "user" }
|
||||
*
|
||||
* Allowed roles are explicitly only the customer-side ones —
|
||||
* `isValidInviteRole` enforces this server-side too as a belt
|
||||
* alongside the Zod enum (the Zod enum is the primary check; the
|
||||
* helper exists because future callers in admin tooling may want the
|
||||
* same predicate).
|
||||
*
|
||||
* Platform users can also call this — they'd be inviting members
|
||||
* into their own platform org, which is uncommon but legal.
|
||||
*/
|
||||
export async function POST(req: Request) {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
if (!canMutate(user)) {
|
||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
||||
}
|
||||
|
||||
const body = await req.json().catch(() => null);
|
||||
const parsed = inviteSchema.safeParse(body);
|
||||
if (!parsed.success) {
|
||||
return NextResponse.json(
|
||||
{ error: "Invalid input", details: parsed.error.flatten() },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
const input = parsed.data;
|
||||
|
||||
// Defensive recheck — the Zod enum already guarantees this, but it
|
||||
// makes the intent explicit at the call site.
|
||||
if (!isValidInviteRole(input.role)) {
|
||||
return NextResponse.json(
|
||||
{ error: "Role must be 'owner' or 'user'." },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
|
||||
try {
|
||||
const result = await inviteOrgMember({
|
||||
orgId: user.orgId,
|
||||
email: input.email,
|
||||
givenName: input.givenName,
|
||||
familyName: input.familyName,
|
||||
role: input.role,
|
||||
preferredLanguage: input.preferredLanguage,
|
||||
});
|
||||
return NextResponse.json(
|
||||
{
|
||||
userId: result.userId,
|
||||
message:
|
||||
"Invitation sent. The user will receive an email with a link to set their password.",
|
||||
},
|
||||
{ status: 201 }
|
||||
);
|
||||
} catch (e: any) {
|
||||
console.error("Invite failed:", e);
|
||||
// ZITADEL "user already exists" surfaces as a 4xx error; pass it
|
||||
// through with a clean message so the client can render localized
|
||||
// text.
|
||||
const msg = e?.message ?? "";
|
||||
if (msg.includes("already exists") || msg.includes("9.User.AlreadyExisting")) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
error: "A user with this email already exists.",
|
||||
code: "user_already_exists",
|
||||
},
|
||||
{ status: 409 }
|
||||
);
|
||||
}
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to invite user") },
|
||||
{ status: e.statusCode || 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
38
src/app/api/team/route.ts
Normal file
38
src/app/api/team/route.ts
Normal file
@@ -0,0 +1,38 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import { getSessionUser, canMutate } from "@/lib/session";
|
||||
import { getOrgMembers } from "@/lib/team";
|
||||
import { safeError } from "@/lib/errors";
|
||||
|
||||
/**
|
||||
* GET /api/team
|
||||
*
|
||||
* Returns the joined members-with-roles view for the caller's org.
|
||||
* Gated on `canMutate` — only owners and platform users can see the
|
||||
* full member list. A `user`-role member shouldn't be browsing the
|
||||
* roster.
|
||||
*
|
||||
* Platform admins viewing this endpoint see members of their OWN
|
||||
* platform org. To inspect customer org membership cross-cut, use
|
||||
* ZITADEL Console — that's the deliberate boundary between portal
|
||||
* (customer self-service) and console (full IAM).
|
||||
*/
|
||||
export async function GET() {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
if (!canMutate(user)) {
|
||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
||||
}
|
||||
|
||||
try {
|
||||
const members = await getOrgMembers(user.orgId);
|
||||
return NextResponse.json({ members });
|
||||
} catch (e: any) {
|
||||
console.error("Failed to list team members:", e);
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to list team members") },
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
57
src/app/api/tenants/[name]/assignments/[userId]/route.ts
Normal file
57
src/app/api/tenants/[name]/assignments/[userId]/route.ts
Normal file
@@ -0,0 +1,57 @@
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
import { getSessionUser, canMutate } from "@/lib/session";
|
||||
import { getTenant } from "@/lib/k8s";
|
||||
import { removeTenantAssignment } from "@/lib/db";
|
||||
import { safeError } from "@/lib/errors";
|
||||
|
||||
/**
|
||||
* DELETE /api/tenants/[name]/assignments/[userId]
|
||||
*
|
||||
* Revoke a user's assignment to a tenant. Owner+platform only.
|
||||
*
|
||||
* No-op if the assignment didn't exist (delete is idempotent at the
|
||||
* DB layer). We don't surface "not found" because that would let a
|
||||
* caller probe for assignment existence — the boolean response is
|
||||
* just "you're authorized to do this".
|
||||
*
|
||||
* Note on self-revocation: an owner can revoke their own row even
|
||||
* though it has no practical effect (owners see all tenants). A
|
||||
* `user`-role member cannot revoke their own assignment because
|
||||
* they're already gated out by canMutate.
|
||||
*/
|
||||
export async function DELETE(
|
||||
_req: NextRequest,
|
||||
{ params }: { params: Promise<{ name: string; userId: string }> }
|
||||
) {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
if (!canMutate(user)) {
|
||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
||||
}
|
||||
|
||||
const { name, userId } = await params;
|
||||
|
||||
const tenant = await getTenant(name);
|
||||
if (!tenant) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
// Same cross-org boundary as assign: customer owners can only manage
|
||||
// their own org's tenants; platform users can manage anywhere.
|
||||
const tenantOrgId = tenant.metadata.labels?.["pieced.ch/zitadel-org-id"];
|
||||
if (!user.isPlatform && tenantOrgId !== user.orgId) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
try {
|
||||
await removeTenantAssignment(name, userId);
|
||||
return NextResponse.json({ message: "Assignment revoked." });
|
||||
} catch (e: any) {
|
||||
console.error("Failed to remove tenant assignment:", e);
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to revoke assignment") },
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
176
src/app/api/tenants/[name]/assignments/route.ts
Normal file
176
src/app/api/tenants/[name]/assignments/route.ts
Normal file
@@ -0,0 +1,176 @@
|
||||
import { NextRequest, NextResponse } from "next/server";
|
||||
import { getSessionUser, canMutate } from "@/lib/session";
|
||||
import { canUserSeeTenant } from "@/lib/visibility";
|
||||
import { getTenant } from "@/lib/k8s";
|
||||
import {
|
||||
listAssignmentsForTenant,
|
||||
addTenantAssignment,
|
||||
} from "@/lib/db";
|
||||
import { getOrgMembers } from "@/lib/team";
|
||||
import { safeError } from "@/lib/errors";
|
||||
import { z } from "zod";
|
||||
|
||||
const assignSchema = z.object({
|
||||
userId: z.string().min(1).max(200),
|
||||
});
|
||||
|
||||
/**
|
||||
* GET /api/tenants/[name]/assignments
|
||||
*
|
||||
* Returns the list of users assigned to a tenant, joined with their
|
||||
* ZITADEL profile (display name, email, role) so the UI can render
|
||||
* a useful list without an extra round-trip.
|
||||
*
|
||||
* Visibility: any caller who can see the tenant can see its
|
||||
* assignments. This includes user-role members who are themselves
|
||||
* assigned — they see their fellow assignees, which is intentional
|
||||
* (so they know who else has access).
|
||||
*/
|
||||
export async function GET(
|
||||
_req: NextRequest,
|
||||
{ params }: { params: Promise<{ name: string }> }
|
||||
) {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
|
||||
const { name } = await params;
|
||||
|
||||
const tenant = await getTenant(name);
|
||||
if (!tenant) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
if (!(await canUserSeeTenant(user, tenant))) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
try {
|
||||
const orgId = tenant.metadata.labels?.["pieced.ch/zitadel-org-id"];
|
||||
const [rows, members] = await Promise.all([
|
||||
listAssignmentsForTenant(name),
|
||||
orgId ? getOrgMembers(orgId) : Promise.resolve([]),
|
||||
]);
|
||||
|
||||
const memberById = new Map(members.map((m) => [m.userId, m]));
|
||||
|
||||
// Enrich assignments with member metadata. If the member can't be
|
||||
// found in ZITADEL (stale row, e.g. user was removed from the org
|
||||
// outside the portal), surface the orphan with a placeholder name
|
||||
// so admins can clean it up.
|
||||
const assignments = rows.map((r) => {
|
||||
const m = memberById.get(r.zitadelUserId);
|
||||
return {
|
||||
userId: r.zitadelUserId,
|
||||
displayName: m?.displayName ?? "(removed user)",
|
||||
email: m?.email ?? "",
|
||||
roles: m?.roles ?? [],
|
||||
assignedAt: r.assignedAt,
|
||||
assignedBy: r.assignedBy,
|
||||
orphan: !m,
|
||||
};
|
||||
});
|
||||
|
||||
return NextResponse.json({ assignments });
|
||||
} catch (e: any) {
|
||||
console.error("Failed to list tenant assignments:", e);
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to list assignments") },
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* POST /api/tenants/[name]/assignments
|
||||
*
|
||||
* Body: { userId }
|
||||
*
|
||||
* Assign a user to a tenant. Owner+platform only. The target user must
|
||||
* already be a member of the tenant's org (we verify via the team list)
|
||||
* — to add a brand-new user, the owner first invites them via
|
||||
* POST /api/team/invite, then assigns them here.
|
||||
*
|
||||
* Idempotent: re-assigning is a no-op (DB INSERT ... ON CONFLICT DO
|
||||
* NOTHING). The original `assignedAt`/`assignedBy` are preserved.
|
||||
*
|
||||
* Owners technically don't need to be assigned (they see all of their
|
||||
* org's tenants anyway) but we don't reject the operation — just lets
|
||||
* future bookkeeping work consistently.
|
||||
*/
|
||||
export async function POST(
|
||||
req: NextRequest,
|
||||
{ params }: { params: Promise<{ name: string }> }
|
||||
) {
|
||||
const user = await getSessionUser();
|
||||
if (!user) {
|
||||
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
||||
}
|
||||
if (!canMutate(user)) {
|
||||
return NextResponse.json({ error: "Forbidden" }, { status: 403 });
|
||||
}
|
||||
|
||||
const { name } = await params;
|
||||
|
||||
const tenant = await getTenant(name);
|
||||
if (!tenant) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
// Customer owners can only assign within their own org. Platform
|
||||
// users can assign anywhere (rare, but consistent with admin scope).
|
||||
const tenantOrgId = tenant.metadata.labels?.["pieced.ch/zitadel-org-id"];
|
||||
if (!user.isPlatform && tenantOrgId !== user.orgId) {
|
||||
return NextResponse.json({ error: "Not found" }, { status: 404 });
|
||||
}
|
||||
if (!tenantOrgId) {
|
||||
return NextResponse.json(
|
||||
{ error: "Tenant is missing the org-id label; cannot assign." },
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
|
||||
const body = await req.json().catch(() => null);
|
||||
const parsed = assignSchema.safeParse(body);
|
||||
if (!parsed.success) {
|
||||
return NextResponse.json(
|
||||
{ error: "Invalid input", details: parsed.error.flatten() },
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
|
||||
// Verify the target user is actually a member of the tenant's org.
|
||||
// This is the audit boundary — without it, an owner could grant
|
||||
// access to arbitrary user IDs they made up.
|
||||
try {
|
||||
const members = await getOrgMembers(tenantOrgId);
|
||||
const target = members.find((m) => m.userId === parsed.data.userId);
|
||||
if (!target) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
error:
|
||||
"Target user is not a member of this organization. Invite them first.",
|
||||
code: "user_not_in_org",
|
||||
},
|
||||
{ status: 400 }
|
||||
);
|
||||
}
|
||||
|
||||
await addTenantAssignment({
|
||||
tenantName: name,
|
||||
orgId: tenantOrgId,
|
||||
userId: parsed.data.userId,
|
||||
assignedBy: user.id,
|
||||
});
|
||||
|
||||
return NextResponse.json(
|
||||
{ message: "User assigned.", userId: parsed.data.userId },
|
||||
{ status: 201 }
|
||||
);
|
||||
} catch (e: any) {
|
||||
console.error("Failed to add tenant assignment:", e);
|
||||
return NextResponse.json(
|
||||
{ error: safeError(e, "Failed to assign user") },
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -40,6 +40,17 @@ function NavBar() {
|
||||
<NavLink href="/dashboard" active={pathname === "/dashboard"}>
|
||||
{t("dashboard")}
|
||||
</NavLink>
|
||||
{/* Slice 7: /team is owner+platform only. Match server-side
|
||||
gate (canMutate). The roles array carries either "owner"
|
||||
or "user" for customer sessions; isPlatform covers the
|
||||
platform side. */}
|
||||
{user &&
|
||||
(user.isPlatform ||
|
||||
(Array.isArray(user.roles) && user.roles.includes("owner"))) && (
|
||||
<NavLink href="/team" active={pathname === "/team"}>
|
||||
{t("team")}
|
||||
</NavLink>
|
||||
)}
|
||||
{user?.isPlatform && (
|
||||
<NavLink href="/admin" active={pathname === "/admin"}>
|
||||
{t("admin")}
|
||||
|
||||
150
src/components/team/invite-form.tsx
Normal file
150
src/components/team/invite-form.tsx
Normal file
@@ -0,0 +1,150 @@
|
||||
"use client";
|
||||
|
||||
import { useState } from "react";
|
||||
import { useTranslations } from "next-intl";
|
||||
|
||||
type FormState = "idle" | "submitting" | "success" | "error";
|
||||
|
||||
/**
|
||||
* InviteForm — owner submits email + name + role to /api/team/invite.
|
||||
* On success, broadcasts `team:refresh` so the sibling TeamList
|
||||
* re-fetches the member list.
|
||||
*
|
||||
* Form fields mirror the POST body:
|
||||
* { email, givenName, familyName, role: "owner" | "user" }
|
||||
*
|
||||
* Role defaults to "user" — the more conservative grant. Owner
|
||||
* promotion happens in ZITADEL Console for now.
|
||||
*/
|
||||
export function InviteForm() {
|
||||
const t = useTranslations("team");
|
||||
const tCommon = useTranslations("common");
|
||||
|
||||
const [form, setForm] = useState({
|
||||
email: "",
|
||||
givenName: "",
|
||||
familyName: "",
|
||||
role: "user" as "owner" | "user",
|
||||
});
|
||||
const [state, setState] = useState<FormState>("idle");
|
||||
const [error, setError] = useState("");
|
||||
|
||||
function handleChange(e: React.ChangeEvent<HTMLInputElement | HTMLSelectElement>) {
|
||||
setForm((prev) => ({ ...prev, [e.target.name]: e.target.value }));
|
||||
}
|
||||
|
||||
async function handleSubmit(e: React.FormEvent) {
|
||||
e.preventDefault();
|
||||
setError("");
|
||||
setState("submitting");
|
||||
|
||||
try {
|
||||
const res = await fetch("/api/team/invite", {
|
||||
method: "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(form),
|
||||
});
|
||||
if (!res.ok) {
|
||||
const data = await res.json();
|
||||
if (data.code === "user_already_exists") {
|
||||
throw new Error(t("inviteUserExists"));
|
||||
}
|
||||
throw new Error(data.error || "Invite failed");
|
||||
}
|
||||
setState("success");
|
||||
setForm({ email: "", givenName: "", familyName: "", role: "user" });
|
||||
// Tell the TeamList sibling to refresh
|
||||
window.dispatchEvent(new Event("team:refresh"));
|
||||
|
||||
// Auto-clear the success banner after a moment so the form
|
||||
// doesn't permanently look "done"
|
||||
setTimeout(() => setState("idle"), 3500);
|
||||
} catch (err: any) {
|
||||
setError(err.message);
|
||||
setState("error");
|
||||
}
|
||||
}
|
||||
|
||||
return (
|
||||
<form onSubmit={handleSubmit} className="space-y-4">
|
||||
<div className="grid grid-cols-2 gap-3">
|
||||
<div>
|
||||
<label className="block text-xs font-semibold uppercase tracking-wider text-text-muted mb-1.5">
|
||||
{t("givenName")}
|
||||
</label>
|
||||
<input
|
||||
name="givenName"
|
||||
type="text"
|
||||
required
|
||||
value={form.givenName}
|
||||
onChange={handleChange}
|
||||
className="w-full px-3 py-2 bg-surface-2 border border-border rounded-lg text-sm text-text-primary placeholder:text-text-muted focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent transition-colors"
|
||||
/>
|
||||
</div>
|
||||
<div>
|
||||
<label className="block text-xs font-semibold uppercase tracking-wider text-text-muted mb-1.5">
|
||||
{t("familyName")}
|
||||
</label>
|
||||
<input
|
||||
name="familyName"
|
||||
type="text"
|
||||
required
|
||||
value={form.familyName}
|
||||
onChange={handleChange}
|
||||
className="w-full px-3 py-2 bg-surface-2 border border-border rounded-lg text-sm text-text-primary placeholder:text-text-muted focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent transition-colors"
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<label className="block text-xs font-semibold uppercase tracking-wider text-text-muted mb-1.5">
|
||||
{t("email")}
|
||||
</label>
|
||||
<input
|
||||
name="email"
|
||||
type="email"
|
||||
required
|
||||
value={form.email}
|
||||
onChange={handleChange}
|
||||
placeholder="colleague@company.ch"
|
||||
className="w-full px-3 py-2 bg-surface-2 border border-border rounded-lg text-sm text-text-primary placeholder:text-text-muted focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent transition-colors"
|
||||
/>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<label className="block text-xs font-semibold uppercase tracking-wider text-text-muted mb-1.5">
|
||||
{t("role")}
|
||||
</label>
|
||||
<select
|
||||
name="role"
|
||||
value={form.role}
|
||||
onChange={handleChange}
|
||||
className="w-full px-3 py-2 bg-surface-2 border border-border rounded-lg text-sm text-text-primary focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent transition-colors"
|
||||
>
|
||||
<option value="user">{t("roleUser")}</option>
|
||||
<option value="owner">{t("roleOwner")}</option>
|
||||
</select>
|
||||
<p className="text-xs text-text-muted mt-1">{t("roleHint")}</p>
|
||||
</div>
|
||||
|
||||
{error && (
|
||||
<div className="text-xs text-red-400 bg-red-400/10 border border-red-400/20 rounded-lg px-3 py-2">
|
||||
{error}
|
||||
</div>
|
||||
)}
|
||||
{state === "success" && (
|
||||
<div className="text-xs text-emerald-400 bg-emerald-400/10 border border-emerald-400/20 rounded-lg px-3 py-2">
|
||||
{t("inviteSent")}
|
||||
</div>
|
||||
)}
|
||||
|
||||
<button
|
||||
type="submit"
|
||||
disabled={state === "submitting"}
|
||||
className="w-full py-2.5 px-4 bg-accent text-white text-sm font-medium rounded-lg hover:bg-accent-dim transition-colors disabled:opacity-50 disabled:cursor-not-allowed"
|
||||
>
|
||||
{state === "submitting" ? tCommon("loading") : t("inviteButton")}
|
||||
</button>
|
||||
</form>
|
||||
);
|
||||
}
|
||||
235
src/components/team/team-list.tsx
Normal file
235
src/components/team/team-list.tsx
Normal file
@@ -0,0 +1,235 @@
|
||||
"use client";
|
||||
|
||||
import { useState, useEffect } from "react";
|
||||
import { useTranslations } from "next-intl";
|
||||
|
||||
interface OrgMember {
|
||||
userId: string;
|
||||
email: string;
|
||||
displayName: string;
|
||||
givenName: string;
|
||||
familyName: string;
|
||||
roles: string[];
|
||||
authorizationId: string;
|
||||
}
|
||||
|
||||
interface Props {
|
||||
initialMembers: OrgMember[];
|
||||
currentUserId: string;
|
||||
/**
|
||||
* Whether the viewing user can change other members' roles. True only
|
||||
* for customer owners. Server enforces this independently — this prop
|
||||
* is purely UX (don't render the control if the action would 403).
|
||||
*/
|
||||
canEditRoles: boolean;
|
||||
}
|
||||
|
||||
type RoleOption = "owner" | "user";
|
||||
|
||||
/**
|
||||
* TeamList — renders the org's members. Refreshes after invites by
|
||||
* polling the API; the InviteForm broadcasts a `team:refresh` window
|
||||
* event after a successful invite so the list updates immediately
|
||||
* rather than waiting for the next reload.
|
||||
*
|
||||
* Slice 7 + Bug 25: owners can change other members' roles inline.
|
||||
* Clicking the "Change role" button on a row swaps the badge for a
|
||||
* dropdown + Save/Cancel pair. We deliberately don't use a modal —
|
||||
* the change is a single-field edit and the user already sees the row
|
||||
* context, so inline is faster.
|
||||
*
|
||||
* Self-row never shows the editor (server enforces too). Last-owner
|
||||
* demotion is enforced server-side; we surface the resulting 409 as a
|
||||
* row-local error rather than pre-validating client-side, because the
|
||||
* client doesn't know the org's full owner count without an extra
|
||||
* round trip.
|
||||
*/
|
||||
export function TeamList({
|
||||
initialMembers,
|
||||
currentUserId,
|
||||
canEditRoles,
|
||||
}: Props) {
|
||||
const t = useTranslations("team");
|
||||
const [members, setMembers] = useState<OrgMember[]>(initialMembers);
|
||||
|
||||
// Per-row editor state. `editingId` is the userId currently being
|
||||
// edited (only one at a time). `pendingRole` is the dropdown value.
|
||||
// `rowError` carries server-rejection messages keyed by userId.
|
||||
const [editingId, setEditingId] = useState<string | null>(null);
|
||||
const [pendingRole, setPendingRole] = useState<RoleOption>("user");
|
||||
const [submitting, setSubmitting] = useState(false);
|
||||
const [rowError, setRowError] = useState<Record<string, string>>({});
|
||||
|
||||
useEffect(() => {
|
||||
function refresh() {
|
||||
fetch("/api/team")
|
||||
.then((r) => (r.ok ? r.json() : null))
|
||||
.then((data) => {
|
||||
if (data?.members) setMembers(data.members);
|
||||
})
|
||||
.catch(() => {});
|
||||
}
|
||||
window.addEventListener("team:refresh", refresh);
|
||||
return () => window.removeEventListener("team:refresh", refresh);
|
||||
}, []);
|
||||
|
||||
function startEdit(m: OrgMember) {
|
||||
const current = (m.roles[0] === "owner" ? "owner" : "user") as RoleOption;
|
||||
setEditingId(m.userId);
|
||||
setPendingRole(current);
|
||||
setRowError((e) => ({ ...e, [m.userId]: "" }));
|
||||
}
|
||||
|
||||
function cancelEdit() {
|
||||
setEditingId(null);
|
||||
setSubmitting(false);
|
||||
}
|
||||
|
||||
async function saveEdit(m: OrgMember) {
|
||||
setSubmitting(true);
|
||||
setRowError((e) => ({ ...e, [m.userId]: "" }));
|
||||
try {
|
||||
const res = await fetch(
|
||||
`/api/team/${encodeURIComponent(m.userId)}/role`,
|
||||
{
|
||||
method: "PATCH",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify({ role: pendingRole }),
|
||||
}
|
||||
);
|
||||
if (!res.ok) {
|
||||
const data = await res.json().catch(() => ({}));
|
||||
throw new Error(data.error || t("roleUpdateFailed"));
|
||||
}
|
||||
// Optimistic update — replace the row's roles locally rather than
|
||||
// re-fetching the whole list. The list will eventually re-fetch
|
||||
// on the next `team:refresh` event anyway.
|
||||
setMembers((prev) =>
|
||||
prev.map((x) =>
|
||||
x.userId === m.userId ? { ...x, roles: [pendingRole] } : x
|
||||
)
|
||||
);
|
||||
setEditingId(null);
|
||||
} catch (err: any) {
|
||||
setRowError((e) => ({ ...e, [m.userId]: err.message }));
|
||||
} finally {
|
||||
setSubmitting(false);
|
||||
}
|
||||
}
|
||||
|
||||
if (members.length === 0) {
|
||||
return (
|
||||
<div className="text-sm text-text-secondary text-center py-6 border border-border rounded-xl bg-surface-1">
|
||||
{t("noMembers")}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
return (
|
||||
<div className="bg-surface-1 border border-border rounded-xl overflow-hidden">
|
||||
<ul className="divide-y divide-border">
|
||||
{members.map((m) => {
|
||||
const isSelf = m.userId === currentUserId;
|
||||
const isEditing = editingId === m.userId;
|
||||
// Hide editor for self even when the viewer is an owner —
|
||||
// self-demotion is server-blocked and offering it as a UI
|
||||
// affordance would just produce errors.
|
||||
const showEditor = canEditRoles && !isSelf;
|
||||
const err = rowError[m.userId];
|
||||
|
||||
return (
|
||||
<li
|
||||
key={m.userId}
|
||||
className="px-5 py-3 flex items-center justify-between gap-4"
|
||||
>
|
||||
<div className="min-w-0">
|
||||
<div className="flex items-center gap-2">
|
||||
<span className="text-sm font-medium text-text-primary truncate">
|
||||
{m.displayName || m.email}
|
||||
</span>
|
||||
{isSelf && (
|
||||
<span className="text-[10px] uppercase tracking-wider text-accent">
|
||||
{t("you")}
|
||||
</span>
|
||||
)}
|
||||
</div>
|
||||
<div className="text-xs text-text-muted truncate font-mono">
|
||||
{m.email}
|
||||
</div>
|
||||
{err && (
|
||||
<div className="text-xs text-red-400 mt-1">{err}</div>
|
||||
)}
|
||||
</div>
|
||||
|
||||
<div className="flex items-center gap-2 shrink-0">
|
||||
{isEditing ? (
|
||||
<>
|
||||
<select
|
||||
value={pendingRole}
|
||||
onChange={(e) =>
|
||||
setPendingRole(e.target.value as RoleOption)
|
||||
}
|
||||
disabled={submitting}
|
||||
className="text-xs bg-surface-2 border border-border rounded-md px-2 py-1 text-text-primary focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent"
|
||||
>
|
||||
<option value="user">{t("roleUser")}</option>
|
||||
<option value="owner">{t("roleOwner")}</option>
|
||||
</select>
|
||||
<button
|
||||
type="button"
|
||||
onClick={() => saveEdit(m)}
|
||||
disabled={submitting || !m.authorizationId}
|
||||
className="text-xs px-2.5 py-1 rounded-md bg-accent text-white hover:bg-accent-dim transition-colors disabled:opacity-50"
|
||||
>
|
||||
{t("save")}
|
||||
</button>
|
||||
<button
|
||||
type="button"
|
||||
onClick={cancelEdit}
|
||||
disabled={submitting}
|
||||
className="text-xs px-2.5 py-1 rounded-md border border-border text-text-secondary hover:text-text-primary transition-colors"
|
||||
>
|
||||
{t("cancel")}
|
||||
</button>
|
||||
</>
|
||||
) : (
|
||||
<>
|
||||
<div className="flex flex-wrap gap-1.5 justify-end">
|
||||
{m.roles.length === 0 && (
|
||||
<span className="text-[10px] uppercase tracking-wider text-text-muted bg-surface-3 px-2 py-0.5 rounded-full">
|
||||
{t("noRole")}
|
||||
</span>
|
||||
)}
|
||||
{m.roles.map((r) => (
|
||||
<span
|
||||
key={r}
|
||||
className={`text-[10px] uppercase tracking-wider px-2 py-0.5 rounded-full ${
|
||||
r === "owner"
|
||||
? "bg-accent/15 text-accent border border-accent/20"
|
||||
: "bg-surface-3 text-text-secondary border border-border"
|
||||
}`}
|
||||
>
|
||||
{r}
|
||||
</span>
|
||||
))}
|
||||
</div>
|
||||
{showEditor && (
|
||||
<button
|
||||
type="button"
|
||||
onClick={() => startEdit(m)}
|
||||
title={t("changeRole")}
|
||||
className="text-xs text-text-muted hover:text-text-primary px-2 py-1 rounded-md transition-colors"
|
||||
>
|
||||
{t("changeRole")}
|
||||
</button>
|
||||
)}
|
||||
</>
|
||||
)}
|
||||
</div>
|
||||
</li>
|
||||
);
|
||||
})}
|
||||
</ul>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
231
src/components/tenants/assigned-users-panel.tsx
Normal file
231
src/components/tenants/assigned-users-panel.tsx
Normal file
@@ -0,0 +1,231 @@
|
||||
"use client";
|
||||
|
||||
import { useState, useEffect, useCallback } from "react";
|
||||
import { useTranslations } from "next-intl";
|
||||
import { Card } from "@/components/ui/card";
|
||||
|
||||
interface Assignment {
|
||||
userId: string;
|
||||
displayName: string;
|
||||
email: string;
|
||||
roles: string[];
|
||||
assignedAt: string;
|
||||
assignedBy: string;
|
||||
orphan: boolean;
|
||||
}
|
||||
|
||||
interface OrgMember {
|
||||
userId: string;
|
||||
email: string;
|
||||
displayName: string;
|
||||
roles: string[];
|
||||
}
|
||||
|
||||
interface Props {
|
||||
tenantName: string;
|
||||
/**
|
||||
* When false, the panel renders read-only — assignments are visible
|
||||
* but the add-user form and remove ✕ buttons are hidden. Pass
|
||||
* `canEdit` from the parent server component (= canMutate(user)).
|
||||
*/
|
||||
canEdit: boolean;
|
||||
}
|
||||
|
||||
/**
|
||||
* AssignedUsersPanel — manages the tenant_user_assignments rows for
|
||||
* one tenant. Owner sees:
|
||||
* - List of currently-assigned users with name, email, role, and
|
||||
* an "X" button to revoke.
|
||||
* - Dropdown of org members not yet assigned + "Assign" button.
|
||||
*
|
||||
* `user`-role members see the panel read-only (canEdit=false): they
|
||||
* see who else has access to the tenant they're working with, but
|
||||
* can't change anything.
|
||||
*/
|
||||
export function AssignedUsersPanel({ tenantName, canEdit }: Props) {
|
||||
const t = useTranslations("assignments");
|
||||
const [assignments, setAssignments] = useState<Assignment[] | null>(null);
|
||||
const [members, setMembers] = useState<OrgMember[] | null>(null);
|
||||
const [error, setError] = useState("");
|
||||
const [busy, setBusy] = useState(false);
|
||||
const [pickedUserId, setPickedUserId] = useState("");
|
||||
|
||||
const refresh = useCallback(async () => {
|
||||
setError("");
|
||||
try {
|
||||
const [aRes, mRes] = await Promise.all([
|
||||
fetch(`/api/tenants/${tenantName}/assignments`),
|
||||
canEdit
|
||||
? fetch(`/api/team`)
|
||||
: Promise.resolve(null),
|
||||
]);
|
||||
if (!aRes.ok) throw new Error("Failed to load assignments");
|
||||
const aData = await aRes.json();
|
||||
setAssignments(aData.assignments ?? []);
|
||||
|
||||
if (mRes && mRes.ok) {
|
||||
const mData = await mRes.json();
|
||||
setMembers(mData.members ?? []);
|
||||
}
|
||||
} catch (err: any) {
|
||||
setError(err.message);
|
||||
}
|
||||
}, [tenantName, canEdit]);
|
||||
|
||||
useEffect(() => {
|
||||
refresh();
|
||||
}, [refresh]);
|
||||
|
||||
async function handleAssign() {
|
||||
if (!pickedUserId || busy) return;
|
||||
setBusy(true);
|
||||
setError("");
|
||||
try {
|
||||
const res = await fetch(`/api/tenants/${tenantName}/assignments`, {
|
||||
method: "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify({ userId: pickedUserId }),
|
||||
});
|
||||
if (!res.ok) {
|
||||
const data = await res.json();
|
||||
throw new Error(data.error || "Assign failed");
|
||||
}
|
||||
setPickedUserId("");
|
||||
await refresh();
|
||||
} catch (err: any) {
|
||||
setError(err.message);
|
||||
} finally {
|
||||
setBusy(false);
|
||||
}
|
||||
}
|
||||
|
||||
async function handleRevoke(userId: string) {
|
||||
if (busy) return;
|
||||
setBusy(true);
|
||||
setError("");
|
||||
try {
|
||||
const res = await fetch(
|
||||
`/api/tenants/${tenantName}/assignments/${encodeURIComponent(userId)}`,
|
||||
{ method: "DELETE" }
|
||||
);
|
||||
if (!res.ok) {
|
||||
const data = await res.json();
|
||||
throw new Error(data.error || "Revoke failed");
|
||||
}
|
||||
await refresh();
|
||||
} catch (err: any) {
|
||||
setError(err.message);
|
||||
} finally {
|
||||
setBusy(false);
|
||||
}
|
||||
}
|
||||
|
||||
if (assignments === null) {
|
||||
return (
|
||||
<Card>
|
||||
<div className="text-xs text-text-muted">{t("loading")}</div>
|
||||
</Card>
|
||||
);
|
||||
}
|
||||
|
||||
// Compute candidates for the assign dropdown: members of the org
|
||||
// who hold the `user` role (not owners — they have implicit access)
|
||||
// and aren't already assigned.
|
||||
const assignedIds = new Set(assignments.map((a) => a.userId));
|
||||
const candidates = (members ?? []).filter(
|
||||
(m) =>
|
||||
!assignedIds.has(m.userId) &&
|
||||
m.roles.includes("user") &&
|
||||
!m.roles.includes("owner")
|
||||
);
|
||||
|
||||
return (
|
||||
<Card>
|
||||
{error && (
|
||||
<div className="text-xs text-red-400 bg-red-400/10 border border-red-400/20 rounded-lg px-3 py-2 mb-3">
|
||||
{error}
|
||||
<button
|
||||
onClick={() => setError("")}
|
||||
className="ml-2 text-red-300 hover:text-red-200"
|
||||
>
|
||||
✕
|
||||
</button>
|
||||
</div>
|
||||
)}
|
||||
|
||||
{assignments.length === 0 ? (
|
||||
<p className="text-sm text-text-secondary text-center py-3">
|
||||
{t("noneAssigned")}
|
||||
</p>
|
||||
) : (
|
||||
<ul className="divide-y divide-border -mx-2">
|
||||
{assignments.map((a) => (
|
||||
<li
|
||||
key={a.userId}
|
||||
className="px-2 py-2 flex items-center justify-between gap-3"
|
||||
>
|
||||
<div className="min-w-0">
|
||||
<div className="text-sm font-medium text-text-primary truncate">
|
||||
{a.orphan ? (
|
||||
<span className="text-text-muted italic">
|
||||
{a.displayName}
|
||||
</span>
|
||||
) : (
|
||||
a.displayName
|
||||
)}
|
||||
</div>
|
||||
{a.email && (
|
||||
<div className="text-xs text-text-muted truncate font-mono">
|
||||
{a.email}
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
{canEdit && (
|
||||
<button
|
||||
onClick={() => handleRevoke(a.userId)}
|
||||
disabled={busy}
|
||||
className="text-text-muted/60 hover:text-red-400 transition-colors disabled:opacity-50 text-sm px-2"
|
||||
title={t("revoke")}
|
||||
>
|
||||
✕
|
||||
</button>
|
||||
)}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
)}
|
||||
|
||||
{canEdit && (
|
||||
<div className="mt-4 pt-4 border-t border-border">
|
||||
{candidates.length === 0 ? (
|
||||
<p className="text-xs text-text-muted text-center py-2">
|
||||
{t("noCandidates")}
|
||||
</p>
|
||||
) : (
|
||||
<div className="flex gap-2">
|
||||
<select
|
||||
value={pickedUserId}
|
||||
onChange={(e) => setPickedUserId(e.target.value)}
|
||||
className="flex-1 px-3 py-2 bg-surface-2 border border-border rounded-lg text-sm text-text-primary focus:outline-none focus:ring-1 focus:ring-accent focus:border-accent transition-colors"
|
||||
>
|
||||
<option value="">{t("pickUser")}</option>
|
||||
{candidates.map((m) => (
|
||||
<option key={m.userId} value={m.userId}>
|
||||
{m.displayName || m.email}
|
||||
</option>
|
||||
))}
|
||||
</select>
|
||||
<button
|
||||
onClick={handleAssign}
|
||||
disabled={busy || !pickedUserId}
|
||||
className="px-4 py-2 text-sm font-medium bg-accent text-white rounded-lg hover:bg-accent-dim transition-colors disabled:opacity-50 disabled:cursor-not-allowed"
|
||||
>
|
||||
{busy ? "…" : t("assign")}
|
||||
</button>
|
||||
</div>
|
||||
)}
|
||||
</div>
|
||||
)}
|
||||
</Card>
|
||||
);
|
||||
}
|
||||
43
src/components/ui/back-link.tsx
Normal file
43
src/components/ui/back-link.tsx
Normal file
@@ -0,0 +1,43 @@
|
||||
import Link from "next/link";
|
||||
|
||||
/**
|
||||
* BackLink — small "← Page" navigation cue that sits above a page's
|
||||
* `<h1 className="accent-rule">` heading.
|
||||
*
|
||||
* Why this exists
|
||||
* ---------------
|
||||
* The pattern was originally written inline on /team and /dashboard/new
|
||||
* as `<Link className="inline-flex …"><span>←</span> Title</Link>`.
|
||||
* That's wrong because `.accent-rule` (defined in globals.css) sets
|
||||
* `display: inline-block` on the H1 — so an inline-flex link followed by
|
||||
* an inline-block H1 are both inline-level, and end up on the same
|
||||
* baseline whenever there's horizontal room for them. The `mb-4` on the
|
||||
* link does nothing because vertical margin between inline boxes
|
||||
* doesn't push siblings to a new line.
|
||||
*
|
||||
* Solving it: this component renders the link as a block-level flex
|
||||
* container with `w-fit` so it shrinks to its content (and its hover
|
||||
* area doesn't span the gutter). The trailing block element below sits
|
||||
* cleanly on its own line.
|
||||
*
|
||||
* Use it whenever a page has a back-link above an `accent-rule` H1.
|
||||
* The two prior callsites (/team and /dashboard/new) have been
|
||||
* migrated; new pages should just use this directly.
|
||||
*/
|
||||
export function BackLink({
|
||||
href,
|
||||
label,
|
||||
}: {
|
||||
href: string;
|
||||
label: string;
|
||||
}) {
|
||||
return (
|
||||
<Link
|
||||
href={href}
|
||||
className="flex w-fit items-center gap-1.5 mb-4 text-xs font-medium text-text-muted hover:text-text-primary transition-colors"
|
||||
>
|
||||
<span aria-hidden="true">←</span>
|
||||
<span>{label}</span>
|
||||
</Link>
|
||||
);
|
||||
}
|
||||
54
src/instrumentation.ts
Normal file
54
src/instrumentation.ts
Normal file
@@ -0,0 +1,54 @@
|
||||
/**
|
||||
* Next.js instrumentation hook — runs once when the server boots.
|
||||
*
|
||||
* Scope is intentionally narrow: warn early about ZITADEL misconfigurations
|
||||
* that would otherwise cause silent feature failures (Bugs 20, 21, 23, 24
|
||||
* from the test triage). The check is fire-and-forget — it must NEVER
|
||||
* crash the server, even if ZITADEL is briefly unreachable at boot.
|
||||
*
|
||||
* Add new self-checks here only if they meet the same bar: cheap, side-effect
|
||||
* free, and useful at the precise moment a misconfiguration would otherwise
|
||||
* go unnoticed.
|
||||
*
|
||||
* Docs: https://nextjs.org/docs/app/building-your-application/optimizing/instrumentation
|
||||
*/
|
||||
|
||||
const REQUIRED_ROLE_KEYS = [
|
||||
"owner",
|
||||
"user",
|
||||
"platform_admin",
|
||||
"platform_operator",
|
||||
] as const;
|
||||
|
||||
export async function register() {
|
||||
if (process.env.NEXT_RUNTIME !== "nodejs") return;
|
||||
// Skip during `next build` — there's no need to talk to ZITADEL just to
|
||||
// produce a static build, and we don't want CI builds to depend on it.
|
||||
if (process.env.NEXT_PHASE === "phase-production-build") return;
|
||||
|
||||
// Lazy import: the instrumentation file runs in a constrained context
|
||||
// before app code; importing at top-level would pull NextAuth/etc.
|
||||
const { listProjectRoles } = await import("@/lib/zitadel");
|
||||
|
||||
try {
|
||||
const present = new Set(await listProjectRoles());
|
||||
const missing = REQUIRED_ROLE_KEYS.filter((k) => !present.has(k));
|
||||
|
||||
if (missing.length === 0) {
|
||||
console.log(
|
||||
`[startup] ZITADEL project roles OK (${REQUIRED_ROLE_KEYS.length} canonical keys present).`
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
console.warn(
|
||||
`[startup] ZITADEL project ${process.env.ZITADEL_PROJECT_ID} is missing canonical role key(s): ${missing.join(", ")}. ` +
|
||||
`Customer invites and team-page badges will not work. ` +
|
||||
`Run \`node --env-file=.env scripts/zitadel-roles.mjs apply\` to repair.`
|
||||
);
|
||||
} catch (err) {
|
||||
// Never block startup. The portal can still serve unauthenticated
|
||||
// pages and the operator can investigate at leisure.
|
||||
console.warn("[startup] ZITADEL self-check failed (continuing):", err);
|
||||
}
|
||||
}
|
||||
189
src/lib/team.ts
Normal file
189
src/lib/team.ts
Normal file
@@ -0,0 +1,189 @@
|
||||
/**
|
||||
* Team management — high-level operations on top of `lib/zitadel.ts`.
|
||||
*
|
||||
* Two responsibilities:
|
||||
* 1. Fetching the joined "members + roles" view for an org, used by
|
||||
* the /team page and the assigned-users panel.
|
||||
* 2. Inviting a new member end-to-end (create user + send invite +
|
||||
* assign role) with rollback on partial failure, mirroring
|
||||
* `registerCustomer` for new orgs.
|
||||
*
|
||||
* Allowed customer roles
|
||||
* ----------------------
|
||||
* Slice 7 reduced scope: invitations may only set the customer roles
|
||||
* `owner` or `user`. Platform roles cannot be granted via the portal —
|
||||
* those are managed in ZITADEL Console with stricter access. The
|
||||
* `viewer` role is gone since Slice 5.
|
||||
*/
|
||||
|
||||
import {
|
||||
listOrgUsers,
|
||||
listOrgAuthorizations,
|
||||
createHumanUser,
|
||||
createInviteCode,
|
||||
createAuthorization,
|
||||
type OrgUser,
|
||||
} from "./zitadel";
|
||||
import type { CustomerRole } from "@/types";
|
||||
|
||||
const ALLOWED_INVITE_ROLES: CustomerRole[] = ["owner", "user"];
|
||||
|
||||
export function isValidInviteRole(role: string): role is CustomerRole {
|
||||
return (ALLOWED_INVITE_ROLES as string[]).includes(role);
|
||||
}
|
||||
|
||||
export interface OrgMember {
|
||||
userId: string;
|
||||
email: string;
|
||||
displayName: string;
|
||||
givenName: string;
|
||||
familyName: string;
|
||||
/**
|
||||
* Roles held by this member on the org's project grant. Usually a
|
||||
* single-element array (one of "owner" / "user"). Could be empty
|
||||
* if the user exists in the org but has no project authorization
|
||||
* yet — appears as "no role" in the UI.
|
||||
*/
|
||||
roles: string[];
|
||||
/**
|
||||
* The ZITADEL authorization ID backing the role assignment, if any.
|
||||
* Used by the team UI's role-change flow to call UpdateAuthorization.
|
||||
* Empty string if the member has no authorization (orphan / pre-Slice-7
|
||||
* legacy / mid-invite race).
|
||||
*
|
||||
* If a member somehow holds multiple authorization rows (not expected
|
||||
* at our project-grant scope of [owner, user]), only the first is
|
||||
* surfaced here. The team page joins per-user, so the UI sees one
|
||||
* row per member; mutations target that authorization.
|
||||
*/
|
||||
authorizationId: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* Fetch the joined members-with-roles view for an org. Two ZITADEL
|
||||
* calls run in parallel (users + authorizations) then joined in memory.
|
||||
*
|
||||
* If either call fails, returns whatever the other one produced —
|
||||
* users without roles render as "no role" badges; missing users are
|
||||
* just absent. Better degraded than empty.
|
||||
*/
|
||||
export async function getOrgMembers(orgId: string): Promise<OrgMember[]> {
|
||||
const [users, auths] = await Promise.all([
|
||||
listOrgUsers(orgId),
|
||||
listOrgAuthorizations(orgId),
|
||||
]);
|
||||
|
||||
// Group authorizations by userId. We track BOTH the union of role
|
||||
// keys (for display) and the first authorizationId we see (for the
|
||||
// role-change flow). A user could in principle hold multiple
|
||||
// authorization rows, but at our project-grant scope of [owner, user]
|
||||
// each member ends up with exactly one. If a future config produces
|
||||
// multi-row members the UI surfaces the first; cleanup belongs in
|
||||
// ZITADEL Console.
|
||||
const rolesByUser = new Map<string, Set<string>>();
|
||||
const authIdByUser = new Map<string, string>();
|
||||
for (const a of auths) {
|
||||
const set = rolesByUser.get(a.userId) ?? new Set<string>();
|
||||
for (const r of a.roleKeys) set.add(r);
|
||||
rolesByUser.set(a.userId, set);
|
||||
if (!authIdByUser.has(a.userId) && a.authorizationId) {
|
||||
authIdByUser.set(a.userId, a.authorizationId);
|
||||
}
|
||||
}
|
||||
|
||||
return users.map((u) => ({
|
||||
userId: u.userId,
|
||||
email: u.email,
|
||||
displayName: u.displayName,
|
||||
givenName: u.givenName,
|
||||
familyName: u.familyName,
|
||||
roles: Array.from(rolesByUser.get(u.userId) ?? []),
|
||||
authorizationId: authIdByUser.get(u.userId) ?? "",
|
||||
}));
|
||||
}
|
||||
|
||||
/**
|
||||
* Look up a single org member by userId. Convenience wrapper used to
|
||||
* resolve a userId in an assignment row to a display name. Returns
|
||||
* null if the user no longer exists in the org (stale assignment row).
|
||||
*/
|
||||
export async function getOrgMember(
|
||||
orgId: string,
|
||||
userId: string
|
||||
): Promise<OrgMember | null> {
|
||||
const all = await getOrgMembers(orgId);
|
||||
return all.find((m) => m.userId === userId) ?? null;
|
||||
}
|
||||
|
||||
export interface InviteResult {
|
||||
userId: string;
|
||||
emailAlreadyExists: boolean;
|
||||
}
|
||||
|
||||
/**
|
||||
* Invite a new member into an existing customer org.
|
||||
*
|
||||
* Three steps:
|
||||
* 1. createHumanUser — create the ZITADEL human, no password.
|
||||
* 2. createInviteCode — send the invite email (set password + verify).
|
||||
* 3. createAuthorization — assign the chosen customer role.
|
||||
*
|
||||
* If any step after (1) fails, the user is NOT rolled back. Reasoning:
|
||||
* unlike registration where a half-created org is useless, a
|
||||
* half-invited user can be cleaned up manually in ZITADEL Console and
|
||||
* re-invited. The mid-failure cost of partial state is low; the cost of
|
||||
* a wrong rollback is double-creation on retry. So we surface the
|
||||
* error and let the operator decide.
|
||||
*
|
||||
* The invite-email step is best-effort — if SMTP is misconfigured the
|
||||
* user is created and authorized but no email goes out. Owner can
|
||||
* resend manually from ZITADEL Console.
|
||||
*
|
||||
* Note: ZITADEL rejects creating a user with an email that already
|
||||
* exists in the same instance. The error is surfaced as-is from the
|
||||
* `extractZitadelMessage`-aware caller.
|
||||
*/
|
||||
export async function inviteOrgMember(params: {
|
||||
orgId: string;
|
||||
email: string;
|
||||
givenName: string;
|
||||
familyName: string;
|
||||
role: CustomerRole;
|
||||
preferredLanguage?: string;
|
||||
}): Promise<InviteResult> {
|
||||
// Step 1: create the user
|
||||
const user = await createHumanUser({
|
||||
orgId: params.orgId,
|
||||
email: params.email,
|
||||
givenName: params.givenName,
|
||||
familyName: params.familyName,
|
||||
preferredLanguage: params.preferredLanguage,
|
||||
});
|
||||
|
||||
// Step 2: send invite — best-effort
|
||||
try {
|
||||
await createInviteCode(user.id);
|
||||
} catch (err) {
|
||||
console.warn(
|
||||
`Invite email could not be sent for user ${user.id} (SMTP may not be configured):`,
|
||||
err
|
||||
);
|
||||
}
|
||||
|
||||
// Step 3: assign role
|
||||
await createAuthorization({
|
||||
userId: user.id,
|
||||
organizationId: params.orgId,
|
||||
roleKeys: [params.role],
|
||||
});
|
||||
|
||||
return {
|
||||
userId: user.id,
|
||||
emailAlreadyExists: false,
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Re-export for convenience.
|
||||
*/
|
||||
export type { OrgUser };
|
||||
@@ -156,6 +156,18 @@ export interface ProjectGrantResult {
|
||||
|
||||
/**
|
||||
* Grant the "OpenClaw Platform" project to a customer organization.
|
||||
*
|
||||
* The grant's `roleKeys` whitelist what authorizations the customer org
|
||||
* may self-manage: a grant containing only "owner" prevents the customer
|
||||
* from inviting members in the `user` role, because ZITADEL rejects
|
||||
* `CreateAuthorization` for any role outside the grant with
|
||||
* `Errors.Project.Role.NotFound`.
|
||||
*
|
||||
* Default is therefore `["owner", "user"]` — the full set of customer
|
||||
* roles defined in `types/index.ts::CustomerRole`. Platform roles are
|
||||
* intentionally NOT granted; those are administered separately and
|
||||
* should never be assignable from inside a customer org.
|
||||
*
|
||||
* Connect RPC: zitadel.project.v2.ProjectService/CreateProjectGrant
|
||||
*/
|
||||
export async function createProjectGrant(
|
||||
@@ -168,11 +180,44 @@ export async function createProjectGrant(
|
||||
{
|
||||
projectId: ZITADEL_PROJECT_ID,
|
||||
grantedOrganizationId: grantedOrgId,
|
||||
roleKeys: roleKeys || ["owner"],
|
||||
roleKeys: roleKeys || ["owner", "user"],
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* List the role keys defined on the OpenClaw Platform project.
|
||||
*
|
||||
* Used by the instrumentation self-check on startup to warn loudly if
|
||||
* the canonical role keys (owner / user / platform_admin / platform_operator)
|
||||
* are missing — a misconfiguration that silently breaks team management
|
||||
* and customer registration. See `scripts/zitadel-roles.mjs` for repair.
|
||||
*
|
||||
* Returns [] on any error (network, auth, shape drift) so callers can
|
||||
* decide what to do without inheriting a thrown exception during boot.
|
||||
*
|
||||
* Connect RPC: zitadel.project.v2.ProjectService/ListProjectRoles
|
||||
*/
|
||||
export async function listProjectRoles(): Promise<string[]> {
|
||||
try {
|
||||
const data = await connectRpc<{ projectRoles?: any[] }>(
|
||||
"zitadel.project.v2.ProjectService",
|
||||
"ListProjectRoles",
|
||||
{ projectId: ZITADEL_PROJECT_ID }
|
||||
);
|
||||
if (!data?.projectRoles || !Array.isArray(data.projectRoles)) return [];
|
||||
return data.projectRoles
|
||||
.map((r: any) => (typeof r?.key === "string" ? r.key : ""))
|
||||
.filter(Boolean);
|
||||
} catch (err) {
|
||||
console.warn(
|
||||
`Failed to list project roles for ${ZITADEL_PROJECT_ID} (returning empty):`,
|
||||
err
|
||||
);
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// v2 Authorization API — Connect RPC
|
||||
// ---------------------------------------------------------------------------
|
||||
@@ -205,6 +250,35 @@ export async function createAuthorization(params: {
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Replace the role keys on an existing authorization.
|
||||
*
|
||||
* Connect RPC: zitadel.authorization.v2.AuthorizationService/UpdateAuthorization
|
||||
*
|
||||
* Replace, not merge: any role keys previously held by this authorization
|
||||
* that are NOT in the new list are revoked. Pass the complete desired
|
||||
* role set every time. The authorization's user/org/project bindings
|
||||
* are immutable — to move a user to a different org, delete and recreate.
|
||||
*
|
||||
* Used by the team UI's role change flow (Bug 25). For new role grants
|
||||
* use {@link createAuthorization}; for revocations of an entire role
|
||||
* assignment, delete the authorization (not yet exposed; not needed at
|
||||
* the time of writing).
|
||||
*/
|
||||
export async function updateAuthorizationRoles(
|
||||
authorizationId: string,
|
||||
roleKeys: string[]
|
||||
): Promise<{ changeDate?: string }> {
|
||||
return connectRpc<{ changeDate?: string }>(
|
||||
"zitadel.authorization.v2.AuthorizationService",
|
||||
"UpdateAuthorization",
|
||||
{
|
||||
id: authorizationId,
|
||||
roleKeys,
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Delete Organization (for rollback on partial failure)
|
||||
// ---------------------------------------------------------------------------
|
||||
@@ -213,6 +287,158 @@ export async function deleteOrganization(orgId: string): Promise<void> {
|
||||
await zitadelFetch(`/v2/organizations/${orgId}`, "DELETE");
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Slice 7: search/list APIs for team management
|
||||
// ---------------------------------------------------------------------------
|
||||
//
|
||||
// Two endpoints used by the Team UI:
|
||||
// - listOrgUsers → POST /v2/users (search with organizationIdQuery)
|
||||
// - listOrgAuthorizations → Connect RPC to AuthorizationService.ListAuthorizations
|
||||
//
|
||||
// Caveats
|
||||
// -------
|
||||
// ZITADEL's v2 API surface evolves; the request/response shapes below were
|
||||
// written against the v2 schema as documented at the time of authoring
|
||||
// (organizationIdQuery filter on UserService.SearchUsers; ListAuthorizations
|
||||
// with a ListQuery + filter pair). If your installed ZITADEL version uses
|
||||
// slightly different field names, parsing here is intentionally tolerant —
|
||||
// the helpers return [] rather than throwing on shape drift, log a warning,
|
||||
// and the caller's UI shows an empty team list (which is recoverable).
|
||||
//
|
||||
// If you find a discrepancy, fix the request shape here and re-deploy; the
|
||||
// rest of the team UI doesn't care about the on-the-wire format.
|
||||
|
||||
export interface OrgUser {
|
||||
userId: string;
|
||||
email: string;
|
||||
givenName: string;
|
||||
familyName: string;
|
||||
displayName: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* List all users belonging to a given ZITADEL organization. Paginated;
|
||||
* we cap at 200 per call which is generous for the pilot scale.
|
||||
*/
|
||||
export async function listOrgUsers(orgId: string): Promise<OrgUser[]> {
|
||||
try {
|
||||
const data = await zitadelFetch<{ result?: any[] }>(
|
||||
"/v2/users",
|
||||
"POST",
|
||||
{
|
||||
queries: [{ organizationIdQuery: { organizationId: orgId } }],
|
||||
// Sort by username so the team list is deterministic across reloads
|
||||
sortingColumn: "USER_FIELD_NAME_USERNAME",
|
||||
query: { limit: 200, asc: true },
|
||||
}
|
||||
);
|
||||
if (!data?.result || !Array.isArray(data.result)) return [];
|
||||
|
||||
return data.result.flatMap((row: any) => {
|
||||
// ZITADEL distinguishes human and machine users; we only want humans.
|
||||
const human = row?.human;
|
||||
if (!human) return [];
|
||||
const profile = human.profile ?? {};
|
||||
const email = human.email?.email ?? "";
|
||||
const userId = row.userId ?? row.id ?? "";
|
||||
if (!userId) return [];
|
||||
return [
|
||||
{
|
||||
userId,
|
||||
email,
|
||||
givenName: profile.givenName ?? "",
|
||||
familyName: profile.familyName ?? "",
|
||||
displayName:
|
||||
profile.displayName ??
|
||||
`${profile.givenName ?? ""} ${profile.familyName ?? ""}`.trim() ??
|
||||
email,
|
||||
} as OrgUser,
|
||||
];
|
||||
});
|
||||
} catch (err) {
|
||||
console.warn(
|
||||
`Failed to list users for org ${orgId} (returning empty):`,
|
||||
err
|
||||
);
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
export interface OrgAuthorization {
|
||||
authorizationId: string;
|
||||
userId: string;
|
||||
organizationId: string;
|
||||
projectId: string;
|
||||
roleKeys: string[];
|
||||
}
|
||||
|
||||
/**
|
||||
* List authorizations for the OpenClaw Platform project, filtered to a
|
||||
* single organization. Used by the team UI to render each member's
|
||||
* effective role.
|
||||
*
|
||||
* Connect RPC: zitadel.authorization.v2.AuthorizationService/ListAuthorizations
|
||||
*
|
||||
* Implementation note (filter shape & response parsing)
|
||||
* -----------------------------------------------------
|
||||
* The v2 AuthorizationService accepts a `filters` array of oneof variants
|
||||
* (project_id, organization_id, role_key, …) but the JSON-over-Connect
|
||||
* wrapper naming differs between ZITADEL versions and isn't well-documented
|
||||
* for ID filters. Rather than chase a moving target, we fetch all
|
||||
* authorizations the SA can see and narrow client-side by project+org.
|
||||
* At pilot scale this is a single sub-100-row query — well within budget.
|
||||
*
|
||||
* Response shape (v2 stable, confirmed against ZITADEL v4.12):
|
||||
* authorizations: [{
|
||||
* id, state,
|
||||
* project: { id, name, organizationId },
|
||||
* organization: { id, name },
|
||||
* user: { id, displayName, preferredLoginName, … },
|
||||
* roles: [{ key, displayName, group }],
|
||||
* }]
|
||||
*
|
||||
* Returns [] on any error so the team page can render a degraded view
|
||||
* (members visible, roles blank) rather than blowing up entirely.
|
||||
*/
|
||||
export async function listOrgAuthorizations(
|
||||
orgId: string
|
||||
): Promise<OrgAuthorization[]> {
|
||||
try {
|
||||
const data = await connectRpc<{ authorizations?: any[] }>(
|
||||
"zitadel.authorization.v2.AuthorizationService",
|
||||
"ListAuthorizations",
|
||||
{ pagination: { limit: 1000 } }
|
||||
);
|
||||
if (!data?.authorizations || !Array.isArray(data.authorizations)) {
|
||||
return [];
|
||||
}
|
||||
|
||||
return data.authorizations
|
||||
.filter(
|
||||
(row: any) =>
|
||||
row?.project?.id === ZITADEL_PROJECT_ID &&
|
||||
row?.organization?.id === orgId
|
||||
)
|
||||
.map((row: any) => ({
|
||||
authorizationId: row.id ?? "",
|
||||
userId: row.user?.id ?? "",
|
||||
organizationId: row.organization?.id ?? orgId,
|
||||
projectId: row.project?.id ?? ZITADEL_PROJECT_ID,
|
||||
roleKeys: Array.isArray(row.roles)
|
||||
? row.roles
|
||||
.map((r: any) => (typeof r?.key === "string" ? r.key : ""))
|
||||
.filter(Boolean)
|
||||
: [],
|
||||
}));
|
||||
} catch (err) {
|
||||
console.warn(
|
||||
`Failed to list authorizations for org ${orgId} (returning empty):`,
|
||||
err
|
||||
);
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
// ---------------------------------------------------------------------------
|
||||
// Full registration flow
|
||||
// ---------------------------------------------------------------------------
|
||||
@@ -265,8 +491,12 @@ export async function registerCustomer(params: {
|
||||
);
|
||||
}
|
||||
|
||||
// 4. Grant project to org
|
||||
const grant = await createProjectGrant(org.organizationId, ["owner"]);
|
||||
// 4. Grant project to org with both customer roles so the org's
|
||||
// owner can invite users in either `owner` or `user` role afterwards.
|
||||
const grant = await createProjectGrant(org.organizationId, [
|
||||
"owner",
|
||||
"user",
|
||||
]);
|
||||
|
||||
// 5. Assign "owner" role to user
|
||||
await createAuthorization({
|
||||
|
||||
@@ -11,7 +11,8 @@
|
||||
"cancel": "Abbrechen",
|
||||
"save": "Speichern",
|
||||
"error": "Ein Fehler ist aufgetreten",
|
||||
"register": "Registrieren"
|
||||
"register": "Registrieren",
|
||||
"team": "Team"
|
||||
},
|
||||
"login": {
|
||||
"title": "PieCed Portal",
|
||||
@@ -116,7 +117,8 @@
|
||||
"workspaceFiles": "Workspace-Dateien",
|
||||
"notFound": "Tenant nicht gefunden.",
|
||||
"usage": "Nutzung & Kosten",
|
||||
"provisioned": "Bereitgestellt"
|
||||
"provisioned": "Bereitgestellt",
|
||||
"assignedUsers": "Zugewiesene Benutzer"
|
||||
},
|
||||
"usage": {
|
||||
"inputTokens": "Input-Tokens",
|
||||
@@ -269,5 +271,38 @@
|
||||
"telegramIdHelp": "So finden Sie Ihre Telegram-Benutzer-ID:\n1. Öffnen Sie Telegram und schreiben Sie @userinfobot\n2. Der Bot antwortet sofort mit Ihrer numerischen ID\n3. Geben Sie diese Nummer hier ein",
|
||||
"discordIdHelp": "So finden Sie Ihre Discord-Benutzer-ID:\n1. Aktivieren Sie den Entwicklermodus in den Discord-Einstellungen (Erweitert)\n2. Rechtsklick auf Ihren Namen → Benutzer-ID kopieren\n3. Geben Sie diese Nummer hier ein",
|
||||
"emailIdHelp": "Geben Sie die E-Mail-Adresse ein, die zur Interaktion mit dem Assistenten autorisiert werden soll."
|
||||
},
|
||||
"team": {
|
||||
"title": "Team",
|
||||
"description": "Verwalten Sie die Mitglieder Ihrer Organisation. Laden Sie Kollegen ein und weisen Sie sie Instanzen zu.",
|
||||
"inviteSectionTitle": "Mitglied einladen",
|
||||
"membersSectionTitle": "Mitglieder",
|
||||
"noMembers": "Noch keine Mitglieder.",
|
||||
"you": "Sie",
|
||||
"noRole": "keine Rolle",
|
||||
"givenName": "Vorname",
|
||||
"familyName": "Nachname",
|
||||
"email": "E-Mail",
|
||||
"role": "Rolle",
|
||||
"roleUser": "Benutzer (nur Lesezugriff, muss Instanzen zugewiesen werden)",
|
||||
"roleOwner": "Eigentümer (Vollzugriff auf alle Instanzen)",
|
||||
"roleHint": "Eigentümer können Instanzen, Abrechnung und Teammitglieder verwalten. Benutzer können nur die ihnen zugewiesenen Instanzen anzeigen.",
|
||||
"inviteButton": "Einladung senden",
|
||||
"inviteSent": "Einladung gesendet. Der Benutzer erhält eine E-Mail mit einem Link zum Festlegen des Passworts.",
|
||||
"inviteUserExists": "Ein Benutzer mit dieser E-Mail-Adresse ist bereits registriert.",
|
||||
"changeRole": "Rolle ändern",
|
||||
"roleUpdated": "Rolle aktualisiert.",
|
||||
"roleUpdateFailed": "Rolle konnte nicht aktualisiert werden.",
|
||||
"cancel": "Abbrechen",
|
||||
"save": "Speichern",
|
||||
"selfChangeBlocked": "Sie können Ihre eigene Rolle nicht ändern."
|
||||
},
|
||||
"assignments": {
|
||||
"loading": "Zuweisungen werden geladen…",
|
||||
"noneAssigned": "Dieser Instanz sind noch keine Benutzer zugewiesen.",
|
||||
"noCandidates": "Keine Teammitglieder verfügbar zum Zuweisen. Laden Sie zuerst Benutzer auf der Team-Seite ein.",
|
||||
"pickUser": "Benutzer auswählen…",
|
||||
"assign": "Zuweisen",
|
||||
"revoke": "Entfernen"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,7 +11,8 @@
|
||||
"cancel": "Cancel",
|
||||
"save": "Save",
|
||||
"error": "An error occurred",
|
||||
"register": "Register"
|
||||
"register": "Register",
|
||||
"team": "Team"
|
||||
},
|
||||
"login": {
|
||||
"title": "PieCed Portal",
|
||||
@@ -116,7 +117,8 @@
|
||||
"workspaceFiles": "Workspace Files",
|
||||
"notFound": "Tenant not found.",
|
||||
"usage": "Usage & Spend",
|
||||
"provisioned": "Provisioned"
|
||||
"provisioned": "Provisioned",
|
||||
"assignedUsers": "Assigned users"
|
||||
},
|
||||
"usage": {
|
||||
"inputTokens": "Input Tokens",
|
||||
@@ -269,5 +271,38 @@
|
||||
"telegramIdHelp": "To find your Telegram user ID:\n1. Open Telegram and message @userinfobot\n2. It instantly replies with your numeric ID\n3. Enter that number here",
|
||||
"discordIdHelp": "To find your Discord user ID:\n1. Enable Developer Mode in Discord settings (Advanced)\n2. Right-click your name → Copy User ID\n3. Enter that number here",
|
||||
"emailIdHelp": "Enter the email address that should be authorized to interact with the assistant."
|
||||
},
|
||||
"team": {
|
||||
"title": "Team",
|
||||
"description": "Manage members of your organization. Invite colleagues and assign them to instances.",
|
||||
"inviteSectionTitle": "Invite a member",
|
||||
"membersSectionTitle": "Members",
|
||||
"noMembers": "No members yet.",
|
||||
"you": "You",
|
||||
"noRole": "no role",
|
||||
"givenName": "First name",
|
||||
"familyName": "Last name",
|
||||
"email": "Email",
|
||||
"role": "Role",
|
||||
"roleUser": "User (read-only, must be assigned to instances)",
|
||||
"roleOwner": "Owner (full access to all instances)",
|
||||
"roleHint": "Owners can manage instances, billing, and team members. Users can only view instances they've been assigned to.",
|
||||
"inviteButton": "Send invitation",
|
||||
"inviteSent": "Invitation sent. The user will receive an email with a link to set their password.",
|
||||
"inviteUserExists": "A user with this email is already registered.",
|
||||
"changeRole": "Change role",
|
||||
"roleUpdated": "Role updated.",
|
||||
"roleUpdateFailed": "Could not update role.",
|
||||
"cancel": "Cancel",
|
||||
"save": "Save",
|
||||
"selfChangeBlocked": "You cannot change your own role."
|
||||
},
|
||||
"assignments": {
|
||||
"loading": "Loading assignments…",
|
||||
"noneAssigned": "No users are assigned to this instance yet.",
|
||||
"noCandidates": "No team members available to assign. Invite users from the Team page first.",
|
||||
"pickUser": "Select a user…",
|
||||
"assign": "Assign",
|
||||
"revoke": "Remove"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,7 +11,8 @@
|
||||
"cancel": "Annuler",
|
||||
"save": "Enregistrer",
|
||||
"error": "Une erreur est survenue",
|
||||
"register": "S'inscrire"
|
||||
"register": "S'inscrire",
|
||||
"team": "Équipe"
|
||||
},
|
||||
"login": {
|
||||
"title": "Portail PieCed",
|
||||
@@ -116,7 +117,8 @@
|
||||
"workspaceFiles": "Fichiers workspace",
|
||||
"notFound": "Locataire non trouvé.",
|
||||
"usage": "Utilisation et coûts",
|
||||
"provisioned": "Provisionné"
|
||||
"provisioned": "Provisionné",
|
||||
"assignedUsers": "Utilisateurs attribués"
|
||||
},
|
||||
"usage": {
|
||||
"inputTokens": "Tokens d'entrée",
|
||||
@@ -269,5 +271,38 @@
|
||||
"telegramIdHelp": "Pour trouver votre identifiant Telegram :\n1. Ouvrez Telegram et envoyez un message à @userinfobot\n2. Il répond instantanément avec votre identifiant numérique\n3. Entrez ce numéro ici",
|
||||
"discordIdHelp": "Pour trouver votre identifiant Discord :\n1. Activez le mode développeur dans les paramètres Discord (Avancé)\n2. Clic droit sur votre nom → Copier l'identifiant\n3. Entrez ce numéro ici",
|
||||
"emailIdHelp": "Entrez l'adresse e-mail qui doit être autorisée à interagir avec l'assistant."
|
||||
},
|
||||
"team": {
|
||||
"title": "Équipe",
|
||||
"description": "Gérez les membres de votre organisation. Invitez des collègues et attribuez-leur des instances.",
|
||||
"inviteSectionTitle": "Inviter un membre",
|
||||
"membersSectionTitle": "Membres",
|
||||
"noMembers": "Aucun membre pour l'instant.",
|
||||
"you": "Vous",
|
||||
"noRole": "aucun rôle",
|
||||
"givenName": "Prénom",
|
||||
"familyName": "Nom de famille",
|
||||
"email": "E-mail",
|
||||
"role": "Rôle",
|
||||
"roleUser": "Utilisateur (lecture seule, doit être affecté à des instances)",
|
||||
"roleOwner": "Propriétaire (accès complet à toutes les instances)",
|
||||
"roleHint": "Les propriétaires peuvent gérer les instances, la facturation et les membres de l'équipe. Les utilisateurs ne peuvent voir que les instances qui leur sont attribuées.",
|
||||
"inviteButton": "Envoyer l'invitation",
|
||||
"inviteSent": "Invitation envoyée. L'utilisateur recevra un e-mail avec un lien pour définir son mot de passe.",
|
||||
"inviteUserExists": "Un utilisateur avec cette adresse e-mail est déjà enregistré.",
|
||||
"changeRole": "Modifier le rôle",
|
||||
"roleUpdated": "Rôle mis à jour.",
|
||||
"roleUpdateFailed": "Impossible de mettre à jour le rôle.",
|
||||
"cancel": "Annuler",
|
||||
"save": "Enregistrer",
|
||||
"selfChangeBlocked": "Vous ne pouvez pas modifier votre propre rôle."
|
||||
},
|
||||
"assignments": {
|
||||
"loading": "Chargement des attributions…",
|
||||
"noneAssigned": "Aucun utilisateur n'est encore attribué à cette instance.",
|
||||
"noCandidates": "Aucun membre de l'équipe disponible pour l'attribution. Invitez d'abord des utilisateurs depuis la page Équipe.",
|
||||
"pickUser": "Sélectionner un utilisateur…",
|
||||
"assign": "Attribuer",
|
||||
"revoke": "Retirer"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,7 +11,8 @@
|
||||
"cancel": "Annulla",
|
||||
"save": "Salva",
|
||||
"error": "Si è verificato un errore",
|
||||
"register": "Registrati"
|
||||
"register": "Registrati",
|
||||
"team": "Team"
|
||||
},
|
||||
"login": {
|
||||
"title": "Portale PieCed",
|
||||
@@ -116,7 +117,8 @@
|
||||
"workspaceFiles": "File workspace",
|
||||
"notFound": "Tenant non trovato.",
|
||||
"usage": "Utilizzo e costi",
|
||||
"provisioned": "Attivato"
|
||||
"provisioned": "Attivato",
|
||||
"assignedUsers": "Utenti assegnati"
|
||||
},
|
||||
"usage": {
|
||||
"inputTokens": "Token di input",
|
||||
@@ -269,5 +271,38 @@
|
||||
"telegramIdHelp": "Per trovare il tuo ID Telegram:\n1. Apri Telegram e invia un messaggio a @userinfobot\n2. Risponde istantaneamente con il tuo ID numerico\n3. Inserisci quel numero qui",
|
||||
"discordIdHelp": "Per trovare il tuo ID Discord:\n1. Attiva la Modalità sviluppatore nelle impostazioni Discord (Avanzate)\n2. Clic destro sul tuo nome → Copia ID utente\n3. Inserisci quel numero qui",
|
||||
"emailIdHelp": "Inserisci l'indirizzo e-mail che deve essere autorizzato a interagire con l'assistente."
|
||||
},
|
||||
"team": {
|
||||
"title": "Team",
|
||||
"description": "Gestisci i membri della tua organizzazione. Invita colleghi e assegnali alle istanze.",
|
||||
"inviteSectionTitle": "Invita un membro",
|
||||
"membersSectionTitle": "Membri",
|
||||
"noMembers": "Nessun membro ancora.",
|
||||
"you": "Tu",
|
||||
"noRole": "nessun ruolo",
|
||||
"givenName": "Nome",
|
||||
"familyName": "Cognome",
|
||||
"email": "E-mail",
|
||||
"role": "Ruolo",
|
||||
"roleUser": "Utente (sola lettura, deve essere assegnato a istanze)",
|
||||
"roleOwner": "Proprietario (accesso completo a tutte le istanze)",
|
||||
"roleHint": "I proprietari possono gestire istanze, fatturazione e membri del team. Gli utenti possono solo visualizzare le istanze a loro assegnate.",
|
||||
"inviteButton": "Invia invito",
|
||||
"inviteSent": "Invito inviato. L'utente riceverà un'e-mail con un link per impostare la password.",
|
||||
"inviteUserExists": "Un utente con questa e-mail è già registrato.",
|
||||
"changeRole": "Modifica ruolo",
|
||||
"roleUpdated": "Ruolo aggiornato.",
|
||||
"roleUpdateFailed": "Impossibile aggiornare il ruolo.",
|
||||
"cancel": "Annulla",
|
||||
"save": "Salva",
|
||||
"selfChangeBlocked": "Non puoi modificare il tuo ruolo."
|
||||
},
|
||||
"assignments": {
|
||||
"loading": "Caricamento assegnazioni…",
|
||||
"noneAssigned": "Nessun utente è ancora assegnato a questa istanza.",
|
||||
"noCandidates": "Nessun membro del team disponibile per l'assegnazione. Invita prima gli utenti dalla pagina Team.",
|
||||
"pickUser": "Seleziona un utente…",
|
||||
"assign": "Assegna",
|
||||
"revoke": "Rimuovi"
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user