Compare commits
21 Commits
feat/users
...
feat/app-m
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e6fc6e6a0e | ||
|
|
66b84abf6d | ||
|
|
a9fc838577 | ||
|
|
2948875a96 | ||
|
|
b7175cc581 | ||
|
|
d40ebf65a2 | ||
|
|
816a13b920 | ||
|
|
248571dcde | ||
|
|
85bbabcbdf | ||
|
|
1314420fca | ||
|
|
33697a2766 | ||
|
|
6eb32a78bf | ||
|
|
fc35d59236 | ||
|
|
0c9f11558a | ||
|
|
39a6df2bfe | ||
|
|
d21cbdb164 | ||
|
|
700ae7b7d1 | ||
|
|
f16ff22a5a | ||
|
|
bd2258499e | ||
|
|
df691038d7 | ||
|
|
3688c26cb4 |
@@ -69,12 +69,14 @@ pub trait AdminUserRepository: Send + Sync {
|
||||
async fn list(&self) -> Result<Vec<AdminUserRow>, AdminUserRepositoryError>;
|
||||
/// Create a new admin. `instance_role` defaults to `Owner` for the
|
||||
/// env-var bootstrap path; admin-creates-admin flows pass an
|
||||
/// explicit role.
|
||||
/// explicit role. `email` is optional — pass `None` to leave the
|
||||
/// column NULL.
|
||||
async fn create(
|
||||
&self,
|
||||
username: &str,
|
||||
password_hash: &str,
|
||||
instance_role: InstanceRole,
|
||||
email: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError>;
|
||||
async fn update_username(
|
||||
&self,
|
||||
@@ -86,6 +88,12 @@ pub trait AdminUserRepository: Send + Sync {
|
||||
id: AdminUserId,
|
||||
password_hash: &str,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError>;
|
||||
/// Set or clear the email address. `None` writes NULL to the column.
|
||||
async fn update_email(
|
||||
&self,
|
||||
id: AdminUserId,
|
||||
email: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError>;
|
||||
/// Update the instance_role. Used by `PATCH /api/v1/admin/admins/{id}`;
|
||||
/// callers enforce the last-owner guard (`count_other_active_owners`)
|
||||
/// before invoking when role transitions away from `Owner`.
|
||||
@@ -192,24 +200,37 @@ impl AdminUserRepository for PostgresAdminUserRepository {
|
||||
username: &str,
|
||||
password_hash: &str,
|
||||
instance_role: InstanceRole,
|
||||
email: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError> {
|
||||
let res = sqlx::query_as::<_, AdminUserRecord>(
|
||||
"INSERT INTO admin_users (username, password_hash, instance_role) \
|
||||
VALUES ($1, $2, $3) \
|
||||
"INSERT INTO admin_users (username, password_hash, instance_role, email) \
|
||||
VALUES ($1, $2, $3, $4) \
|
||||
RETURNING id, username, is_active, instance_role, email, \
|
||||
created_at, updated_at, last_login_at",
|
||||
)
|
||||
.bind(username)
|
||||
.bind(password_hash)
|
||||
.bind(instance_role.as_str())
|
||||
.bind(email)
|
||||
.fetch_one(&self.pool)
|
||||
.await;
|
||||
|
||||
match res {
|
||||
Ok(row) => row.try_into(),
|
||||
Err(sqlx::Error::Database(e)) if e.is_unique_violation() => Err(
|
||||
AdminUserRepositoryError::DuplicateUsername(username.to_string()),
|
||||
),
|
||||
Err(sqlx::Error::Database(e)) if e.is_unique_violation() => {
|
||||
// username and email both have unique constraints; the
|
||||
// create path can collide on either, so peek at the
|
||||
// constraint name to surface the right error.
|
||||
if e.constraint() == Some("admin_users_email_key") {
|
||||
Err(AdminUserRepositoryError::DuplicateEmail(
|
||||
email.unwrap_or("").to_string(),
|
||||
))
|
||||
} else {
|
||||
Err(AdminUserRepositoryError::DuplicateUsername(
|
||||
username.to_string(),
|
||||
))
|
||||
}
|
||||
}
|
||||
Err(e) => Err(e.into()),
|
||||
}
|
||||
}
|
||||
@@ -259,6 +280,32 @@ impl AdminUserRepository for PostgresAdminUserRepository {
|
||||
.and_then(TryInto::try_into)
|
||||
}
|
||||
|
||||
async fn update_email(
|
||||
&self,
|
||||
id: AdminUserId,
|
||||
email: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError> {
|
||||
let res = sqlx::query_as::<_, AdminUserRecord>(
|
||||
"UPDATE admin_users SET email = $2, updated_at = NOW() \
|
||||
WHERE id = $1 \
|
||||
RETURNING id, username, is_active, instance_role, email, \
|
||||
created_at, updated_at, last_login_at",
|
||||
)
|
||||
.bind(id.into_inner())
|
||||
.bind(email)
|
||||
.fetch_optional(&self.pool)
|
||||
.await;
|
||||
|
||||
match res {
|
||||
Ok(Some(row)) => row.try_into(),
|
||||
Ok(None) => Err(AdminUserRepositoryError::NotFound(id)),
|
||||
Err(sqlx::Error::Database(e)) if e.is_unique_violation() => Err(
|
||||
AdminUserRepositoryError::DuplicateEmail(email.unwrap_or("").to_string()),
|
||||
),
|
||||
Err(e) => Err(e.into()),
|
||||
}
|
||||
}
|
||||
|
||||
async fn update_instance_role(
|
||||
&self,
|
||||
id: AdminUserId,
|
||||
|
||||
@@ -95,6 +95,9 @@ pub struct CreateAdminRequest {
|
||||
/// channel that defaults to `Owner`.
|
||||
#[serde(default = "default_create_role")]
|
||||
pub instance_role: InstanceRole,
|
||||
/// Optional contact email. Blank/whitespace is normalized to None.
|
||||
#[serde(default)]
|
||||
pub email: Option<String>,
|
||||
}
|
||||
|
||||
const fn default_create_role() -> InstanceRole {
|
||||
@@ -107,6 +110,26 @@ pub struct PatchAdminRequest {
|
||||
pub password: Option<String>,
|
||||
pub is_active: Option<bool>,
|
||||
pub instance_role: Option<InstanceRole>,
|
||||
/// JSON Merge Patch (RFC 7396) semantics for email:
|
||||
/// absent → don't change
|
||||
/// null → clear (set DB column to NULL)
|
||||
/// "<string>" → set to that string
|
||||
/// `Option<Option<T>>` is the idiomatic Rust shape for that
|
||||
/// tri-state; the custom deserializer below distinguishes the
|
||||
/// "missing" case from the "present-and-null" case that serde
|
||||
/// would otherwise collapse together.
|
||||
#[allow(clippy::option_option)]
|
||||
#[serde(default, deserialize_with = "deserialize_present_optional")]
|
||||
pub email: Option<Option<String>>,
|
||||
}
|
||||
|
||||
#[allow(clippy::option_option)]
|
||||
fn deserialize_present_optional<'de, T, D>(deserializer: D) -> Result<Option<Option<T>>, D::Error>
|
||||
where
|
||||
T: serde::Deserialize<'de>,
|
||||
D: serde::Deserializer<'de>,
|
||||
{
|
||||
Ok(Some(Option::<T>::deserialize(deserializer)?))
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
@@ -169,10 +192,11 @@ async fn create_admin(
|
||||
let username = input.username.trim();
|
||||
validate_username(username)?;
|
||||
validate_password(&input.password)?;
|
||||
let email = normalize_email(input.email.as_deref())?;
|
||||
let hash = hash_password(&input.password).map_err(|e| AdminApiError::Hash(e.to_string()))?;
|
||||
let row = state
|
||||
.users
|
||||
.create(username, &hash, input.instance_role)
|
||||
.create(username, &hash, input.instance_role, email.as_deref())
|
||||
.await?;
|
||||
Ok((StatusCode::CREATED, Json(row.into())))
|
||||
}
|
||||
@@ -216,6 +240,12 @@ async fn patch_admin(
|
||||
// for the initial cut.)
|
||||
}
|
||||
|
||||
if let Some(email_patch) = input.email.as_ref() {
|
||||
// email_patch is Some(None) → clear, Some(Some(s)) → set.
|
||||
let normalized = normalize_email(email_patch.as_deref())?;
|
||||
latest = Some(state.users.update_email(id, normalized.as_deref()).await?);
|
||||
}
|
||||
|
||||
if let Some(new_role) = input.instance_role {
|
||||
// Self-elevation guard: only an owner can promote anyone TO
|
||||
// owner. An admin cannot turn themselves (or anyone else)
|
||||
@@ -358,6 +388,26 @@ fn validate_password(s: &str) -> Result<(), AdminApiError> {
|
||||
Ok(())
|
||||
}
|
||||
|
||||
/// Trim and reject empty / pathological emails, returning the
|
||||
/// canonical form (or None when the input was blank). The shape
|
||||
/// check is intentionally loose — we mainly want to reject blanks
|
||||
/// and obvious junk; real verification is a future concern.
|
||||
fn normalize_email(raw: Option<&str>) -> Result<Option<String>, AdminApiError> {
|
||||
let Some(raw) = raw else {
|
||||
return Ok(None);
|
||||
};
|
||||
let trimmed = raw.trim();
|
||||
if trimmed.is_empty() {
|
||||
return Ok(None);
|
||||
}
|
||||
if trimmed.len() > 254 || !trimmed.contains('@') {
|
||||
return Err(AdminApiError::InvalidEmail(
|
||||
"email must contain '@' and be at most 254 characters".to_string(),
|
||||
));
|
||||
}
|
||||
Ok(Some(trimmed.to_string()))
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// Errors
|
||||
// ----------------------------------------------------------------------------
|
||||
@@ -373,6 +423,9 @@ pub enum AdminApiError {
|
||||
#[error("{0}")]
|
||||
InvalidPassword(String),
|
||||
|
||||
#[error("{0}")]
|
||||
InvalidEmail(String),
|
||||
|
||||
#[error("cannot leave the system with zero active admins")]
|
||||
LastActiveAdmin,
|
||||
|
||||
@@ -414,6 +467,7 @@ impl IntoResponse for AdminApiError {
|
||||
) => (StatusCode::CONFLICT, self.to_string()),
|
||||
Self::InvalidUsername(_)
|
||||
| Self::InvalidPassword(_)
|
||||
| Self::InvalidEmail(_)
|
||||
| Self::LastActiveAdmin
|
||||
| Self::LastActiveOwner
|
||||
| Self::CannotEscalate
|
||||
|
||||
331
crates/manager-core/src/app_members_api.rs
Normal file
331
crates/manager-core/src/app_members_api.rs
Normal file
@@ -0,0 +1,331 @@
|
||||
//! `/api/v1/admin/apps/{id_or_slug}/members/*` — CRUD over the
|
||||
//! `app_members` table (blueprint §11.6).
|
||||
//!
|
||||
//! Every endpoint is gated on `Capability::AppAdmin(app_id)` after
|
||||
//! resolving the app from `id_or_slug`. Editors and viewers receive
|
||||
//! 403 from list and never see the dashboard's Members tab.
|
||||
//!
|
||||
//! POST is **non-idempotent on purpose**: a duplicate `(app_id,
|
||||
//! user_id)` returns 409 rather than upsert-200, so the UI can show
|
||||
//! "already a member — promote / demote them instead" cleanly. Role
|
||||
//! changes go through PATCH.
|
||||
//!
|
||||
//! No last-app-admin guard: owners always implicitly satisfy
|
||||
//! `Capability::AppAdmin(_)` (authz::role_grants), so removing the
|
||||
//! final explicit `app_admin` membership cannot orphan an app.
|
||||
|
||||
use std::sync::Arc;
|
||||
|
||||
use axum::extract::{Path, State};
|
||||
use axum::http::StatusCode;
|
||||
use axum::response::{IntoResponse, Json, Response};
|
||||
use axum::routing::{get, patch};
|
||||
use axum::{Extension, Router};
|
||||
use chrono::{DateTime, Utc};
|
||||
use picloud_shared::{AdminUserId, AppRole, InstanceRole, Principal};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_json::json;
|
||||
use uuid::Uuid;
|
||||
|
||||
use crate::admin_user_repo::{AdminUserRepository, AdminUserRepositoryError, AdminUserRow};
|
||||
use crate::app_members_repo::{
|
||||
AppMembersRepository, AppMembersRepositoryError, AppMembershipDetail, AppMembershipRow,
|
||||
};
|
||||
use crate::app_repo::AppRepository;
|
||||
use crate::authz::{require, AuthzDenied, AuthzRepo, Capability};
|
||||
use crate::repo::ScriptRepositoryError;
|
||||
|
||||
#[derive(Clone)]
|
||||
pub struct AppMembersState {
|
||||
pub apps: Arc<dyn AppRepository>,
|
||||
pub users: Arc<dyn AdminUserRepository>,
|
||||
pub members: Arc<dyn AppMembersRepository>,
|
||||
pub authz: Arc<dyn AuthzRepo>,
|
||||
}
|
||||
|
||||
pub fn app_members_router(state: AppMembersState) -> Router {
|
||||
Router::new()
|
||||
.route(
|
||||
"/apps/{id_or_slug}/members",
|
||||
get(list_members).post(grant_member),
|
||||
)
|
||||
.route(
|
||||
"/apps/{id_or_slug}/members/{user_id}",
|
||||
patch(patch_member).delete(remove_member),
|
||||
)
|
||||
.with_state(state)
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// DTOs
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
#[derive(Debug, Serialize)]
|
||||
pub struct AppMemberDto {
|
||||
pub user_id: AdminUserId,
|
||||
pub username: String,
|
||||
pub email: Option<String>,
|
||||
pub instance_role: InstanceRole,
|
||||
pub is_active: bool,
|
||||
pub role: AppRole,
|
||||
pub created_at: DateTime<Utc>,
|
||||
}
|
||||
|
||||
impl From<AppMembershipDetail> for AppMemberDto {
|
||||
fn from(d: AppMembershipDetail) -> Self {
|
||||
Self {
|
||||
user_id: d.user_id,
|
||||
username: d.username,
|
||||
email: d.email,
|
||||
instance_role: d.instance_role,
|
||||
is_active: d.is_active,
|
||||
role: d.role,
|
||||
created_at: d.created_at,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// Compose a DTO from an `AdminUserRow` (fetched for validation) and
|
||||
/// the `AppMembershipRow` returned by `upsert`. Saves a re-fetch on
|
||||
/// POST/PATCH at the cost of trusting the two inputs reference the
|
||||
/// same user_id — caller's responsibility.
|
||||
fn compose_dto(user: AdminUserRow, membership: AppMembershipRow) -> AppMemberDto {
|
||||
AppMemberDto {
|
||||
user_id: user.id,
|
||||
username: user.username,
|
||||
email: user.email,
|
||||
instance_role: user.instance_role,
|
||||
is_active: user.is_active,
|
||||
role: membership.role,
|
||||
created_at: membership.created_at,
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
pub struct GrantMemberRequest {
|
||||
pub user_id: AdminUserId,
|
||||
pub role: AppRole,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
pub struct PatchMemberRequest {
|
||||
pub role: AppRole,
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// Handlers
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
async fn list_members(
|
||||
State(s): State<AppMembersState>,
|
||||
Extension(principal): Extension<Principal>,
|
||||
Path(id_or_slug): Path<String>,
|
||||
) -> Result<Json<Vec<AppMemberDto>>, AppMembersApiError> {
|
||||
let app = resolve_app(&*s.apps, &id_or_slug).await?;
|
||||
require(s.authz.as_ref(), &principal, Capability::AppAdmin(app.id)).await?;
|
||||
let rows = s.members.list_for_app_enriched(app.id).await?;
|
||||
Ok(Json(rows.into_iter().map(Into::into).collect()))
|
||||
}
|
||||
|
||||
async fn grant_member(
|
||||
State(s): State<AppMembersState>,
|
||||
Extension(principal): Extension<Principal>,
|
||||
Path(id_or_slug): Path<String>,
|
||||
Json(input): Json<GrantMemberRequest>,
|
||||
) -> Result<(StatusCode, Json<AppMemberDto>), AppMembersApiError> {
|
||||
let app = resolve_app(&*s.apps, &id_or_slug).await?;
|
||||
require(s.authz.as_ref(), &principal, Capability::AppAdmin(app.id)).await?;
|
||||
|
||||
let user = s
|
||||
.users
|
||||
.get(input.user_id)
|
||||
.await?
|
||||
.ok_or(AppMembersApiError::UserNotFound(input.user_id))?;
|
||||
validate_grant_target(&user)?;
|
||||
|
||||
// Atomic insert — if a row already exists, returns None and we 409.
|
||||
// Avoids the find-then-upsert race where two concurrent POSTs would
|
||||
// both pass the existence check and the second `upsert` would
|
||||
// silently rewrite the role.
|
||||
let row = s
|
||||
.members
|
||||
.try_insert(app.id, user.id, input.role)
|
||||
.await?
|
||||
.ok_or_else(|| AppMembersApiError::AlreadyMember {
|
||||
username: user.username.clone(),
|
||||
})?;
|
||||
Ok((StatusCode::CREATED, Json(compose_dto(user, row))))
|
||||
}
|
||||
|
||||
async fn patch_member(
|
||||
State(s): State<AppMembersState>,
|
||||
Extension(principal): Extension<Principal>,
|
||||
Path((id_or_slug, user_id)): Path<(String, Uuid)>,
|
||||
Json(input): Json<PatchMemberRequest>,
|
||||
) -> Result<Json<AppMemberDto>, AppMembersApiError> {
|
||||
let app = resolve_app(&*s.apps, &id_or_slug).await?;
|
||||
require(s.authz.as_ref(), &principal, Capability::AppAdmin(app.id)).await?;
|
||||
|
||||
let user_id = AdminUserId::from(user_id);
|
||||
let user = s
|
||||
.users
|
||||
.get(user_id)
|
||||
.await?
|
||||
.ok_or(AppMembersApiError::UserNotFound(user_id))?;
|
||||
|
||||
// Atomic update — returns None if no row exists, so 404 is decided
|
||||
// by the same statement that does the write. Eliminates the
|
||||
// find-then-upsert race where a concurrent DELETE between the two
|
||||
// calls would let PATCH silently re-create the row.
|
||||
let row = s
|
||||
.members
|
||||
.update_role(app.id, user_id, input.role)
|
||||
.await?
|
||||
.ok_or(AppMembersApiError::MembershipNotFound)?;
|
||||
Ok(Json(compose_dto(user, row)))
|
||||
}
|
||||
|
||||
async fn remove_member(
|
||||
State(s): State<AppMembersState>,
|
||||
Extension(principal): Extension<Principal>,
|
||||
Path((id_or_slug, user_id)): Path<(String, Uuid)>,
|
||||
) -> Result<StatusCode, AppMembersApiError> {
|
||||
let app = resolve_app(&*s.apps, &id_or_slug).await?;
|
||||
require(s.authz.as_ref(), &principal, Capability::AppAdmin(app.id)).await?;
|
||||
s.members.remove(app.id, AdminUserId::from(user_id)).await?;
|
||||
Ok(StatusCode::NO_CONTENT)
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// Validation + helpers
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
fn validate_grant_target(user: &AdminUserRow) -> Result<(), AppMembersApiError> {
|
||||
if !user.is_active {
|
||||
return Err(AppMembersApiError::TargetInactive {
|
||||
username: user.username.clone(),
|
||||
});
|
||||
}
|
||||
if user.instance_role != InstanceRole::Member {
|
||||
return Err(AppMembersApiError::TargetNotMember {
|
||||
username: user.username.clone(),
|
||||
instance_role: user.instance_role,
|
||||
});
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn resolve_app(
|
||||
apps: &dyn AppRepository,
|
||||
ident: &str,
|
||||
) -> Result<picloud_shared::App, AppMembersApiError> {
|
||||
crate::app_repo::resolve_app(apps, ident)
|
||||
.await?
|
||||
.map(|l| l.app)
|
||||
.ok_or_else(|| AppMembersApiError::AppNotFound(ident.to_string()))
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// Errors
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
#[derive(Debug, thiserror::Error)]
|
||||
pub enum AppMembersApiError {
|
||||
#[error("app not found: {0}")]
|
||||
AppNotFound(String),
|
||||
|
||||
#[error("user not found: {0}")]
|
||||
UserNotFound(AdminUserId),
|
||||
|
||||
#[error("no membership exists for this user on this app")]
|
||||
MembershipNotFound,
|
||||
|
||||
#[error("{username} is already a member of this app — use PATCH to change their role")]
|
||||
AlreadyMember { username: String },
|
||||
|
||||
#[error("{username} is deactivated and cannot be added as a member")]
|
||||
TargetInactive { username: String },
|
||||
|
||||
#[error(
|
||||
"{username} has instance_role {instance_role:?} and already has implicit access \
|
||||
on every app — no explicit membership needed"
|
||||
)]
|
||||
TargetNotMember {
|
||||
username: String,
|
||||
instance_role: InstanceRole,
|
||||
},
|
||||
|
||||
#[error("forbidden")]
|
||||
Forbidden,
|
||||
|
||||
#[error("authorization repo error: {0}")]
|
||||
AuthzRepo(String),
|
||||
|
||||
#[error("repository error: {0}")]
|
||||
Members(#[from] AppMembersRepositoryError),
|
||||
|
||||
#[error("user repository error: {0}")]
|
||||
Users(#[from] AdminUserRepositoryError),
|
||||
|
||||
#[error("repository error: {0}")]
|
||||
Apps(#[from] ScriptRepositoryError),
|
||||
}
|
||||
|
||||
impl From<AuthzDenied> for AppMembersApiError {
|
||||
fn from(d: AuthzDenied) -> Self {
|
||||
match d {
|
||||
AuthzDenied::Denied => Self::Forbidden,
|
||||
AuthzDenied::Repo(e) => Self::AuthzRepo(e.to_string()),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl IntoResponse for AppMembersApiError {
|
||||
fn into_response(self) -> Response {
|
||||
let (status, body) = match &self {
|
||||
Self::AppNotFound(_)
|
||||
| Self::UserNotFound(_)
|
||||
| Self::MembershipNotFound
|
||||
| Self::Apps(ScriptRepositoryError::NotFound(_)) => {
|
||||
(StatusCode::NOT_FOUND, json!({ "error": self.to_string() }))
|
||||
}
|
||||
Self::AlreadyMember { .. } | Self::Apps(ScriptRepositoryError::Conflict(_)) => {
|
||||
(StatusCode::CONFLICT, json!({ "error": self.to_string() }))
|
||||
}
|
||||
Self::TargetInactive { .. } | Self::TargetNotMember { .. } => (
|
||||
StatusCode::UNPROCESSABLE_ENTITY,
|
||||
json!({ "error": self.to_string() }),
|
||||
),
|
||||
Self::Forbidden => (StatusCode::FORBIDDEN, json!({ "error": self.to_string() })),
|
||||
Self::AuthzRepo(e) => {
|
||||
tracing::error!(error = %e, "app members authz repo error");
|
||||
(
|
||||
StatusCode::INTERNAL_SERVER_ERROR,
|
||||
json!({ "error": "internal error" }),
|
||||
)
|
||||
}
|
||||
Self::Members(e) => {
|
||||
tracing::error!(error = %e, "app members repo error");
|
||||
(
|
||||
StatusCode::INTERNAL_SERVER_ERROR,
|
||||
json!({ "error": "internal error" }),
|
||||
)
|
||||
}
|
||||
Self::Users(e) => {
|
||||
tracing::error!(error = %e, "admin users repo error");
|
||||
(
|
||||
StatusCode::INTERNAL_SERVER_ERROR,
|
||||
json!({ "error": "internal error" }),
|
||||
)
|
||||
}
|
||||
Self::Apps(ScriptRepositoryError::Db(e)) => {
|
||||
tracing::error!(error = %e, "apps repo error in app_members");
|
||||
(
|
||||
StatusCode::INTERNAL_SERVER_ERROR,
|
||||
json!({ "error": "internal error" }),
|
||||
)
|
||||
}
|
||||
};
|
||||
(status, Json(body)).into_response()
|
||||
}
|
||||
}
|
||||
@@ -8,7 +8,7 @@
|
||||
|
||||
use async_trait::async_trait;
|
||||
use chrono::{DateTime, Utc};
|
||||
use picloud_shared::{AdminUserId, AppId, AppRole};
|
||||
use picloud_shared::{AdminUserId, AppId, AppRole, InstanceRole};
|
||||
use sqlx::PgPool;
|
||||
|
||||
use crate::authz::{AuthzError, AuthzRepo};
|
||||
@@ -36,6 +36,20 @@ pub struct AppMembershipRow {
|
||||
pub created_at: DateTime<Utc>,
|
||||
}
|
||||
|
||||
/// `app_members` row joined with `admin_users` so the dashboard's
|
||||
/// Members tab can render usernames / emails / status without an N+1
|
||||
/// fetch per row. Drives `GET /apps/{id}/members`.
|
||||
#[derive(Debug, Clone)]
|
||||
pub struct AppMembershipDetail {
|
||||
pub user_id: AdminUserId,
|
||||
pub username: String,
|
||||
pub email: Option<String>,
|
||||
pub instance_role: InstanceRole,
|
||||
pub is_active: bool,
|
||||
pub role: AppRole,
|
||||
pub created_at: DateTime<Utc>,
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait AppMembersRepository: Send + Sync {
|
||||
/// Single (user, app) lookup. Returns `None` for non-members and
|
||||
@@ -55,6 +69,27 @@ pub trait AppMembersRepository: Send + Sync {
|
||||
role: AppRole,
|
||||
) -> Result<AppMembershipRow, AppMembersRepositoryError>;
|
||||
|
||||
/// Atomic insert. Returns `Some(row)` on success, `None` if a
|
||||
/// membership already exists. Lets the HTTP handler return 409
|
||||
/// without a separate `find` round-trip (no TOCTOU between check
|
||||
/// and insert).
|
||||
async fn try_insert(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> Result<Option<AppMembershipRow>, AppMembersRepositoryError>;
|
||||
|
||||
/// Atomic role update. Returns `Some(row)` on success, `None` if no
|
||||
/// membership row exists. Lets PATCH return 404 without a separate
|
||||
/// `find` round-trip (no TOCTOU between check and update).
|
||||
async fn update_role(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> Result<Option<AppMembershipRow>, AppMembersRepositoryError>;
|
||||
|
||||
/// Remove a membership. No-op (Ok) when the row doesn't exist —
|
||||
/// the user wasn't a member, which is the desired post-condition.
|
||||
async fn remove(
|
||||
@@ -78,6 +113,14 @@ pub trait AppMembersRepository: Send + Sync {
|
||||
&self,
|
||||
app_id: AppId,
|
||||
) -> Result<Vec<AppMembershipRow>, AppMembersRepositoryError>;
|
||||
|
||||
/// Like `list_for_app` but joined with `admin_users` so the
|
||||
/// dashboard can render member rows in one round-trip. Ordered by
|
||||
/// username for a stable list.
|
||||
async fn list_for_app_enriched(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
) -> Result<Vec<AppMembershipDetail>, AppMembersRepositoryError>;
|
||||
}
|
||||
|
||||
pub struct PostgresAppMembersRepository {
|
||||
@@ -143,6 +186,45 @@ impl AppMembersRepository for PostgresAppMembersRepository {
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn try_insert(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> Result<Option<AppMembershipRow>, AppMembersRepositoryError> {
|
||||
let row = sqlx::query_as::<_, AppMembershipRecord>(
|
||||
"INSERT INTO app_members (app_id, user_id, role) \
|
||||
VALUES ($1, $2, $3) \
|
||||
ON CONFLICT (app_id, user_id) DO NOTHING \
|
||||
RETURNING app_id, user_id, role, created_at",
|
||||
)
|
||||
.bind(app_id.into_inner())
|
||||
.bind(user_id.into_inner())
|
||||
.bind(role.as_str())
|
||||
.fetch_optional(&self.pool)
|
||||
.await?;
|
||||
row.map(TryInto::try_into).transpose()
|
||||
}
|
||||
|
||||
async fn update_role(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> Result<Option<AppMembershipRow>, AppMembersRepositoryError> {
|
||||
let row = sqlx::query_as::<_, AppMembershipRecord>(
|
||||
"UPDATE app_members SET role = $1 \
|
||||
WHERE app_id = $2 AND user_id = $3 \
|
||||
RETURNING app_id, user_id, role, created_at",
|
||||
)
|
||||
.bind(role.as_str())
|
||||
.bind(app_id.into_inner())
|
||||
.bind(user_id.into_inner())
|
||||
.fetch_optional(&self.pool)
|
||||
.await?;
|
||||
row.map(TryInto::try_into).transpose()
|
||||
}
|
||||
|
||||
async fn list_for_user(
|
||||
&self,
|
||||
user_id: AdminUserId,
|
||||
@@ -172,6 +254,24 @@ impl AppMembersRepository for PostgresAppMembersRepository {
|
||||
.await?;
|
||||
rows.into_iter().map(TryInto::try_into).collect()
|
||||
}
|
||||
|
||||
async fn list_for_app_enriched(
|
||||
&self,
|
||||
app_id: AppId,
|
||||
) -> Result<Vec<AppMembershipDetail>, AppMembersRepositoryError> {
|
||||
let rows = sqlx::query_as::<_, AppMembershipDetailRecord>(
|
||||
"SELECT au.id, au.username, au.email, au.instance_role, au.is_active, \
|
||||
am.role, am.created_at \
|
||||
FROM app_members am \
|
||||
JOIN admin_users au ON au.id = am.user_id \
|
||||
WHERE am.app_id = $1 \
|
||||
ORDER BY au.username",
|
||||
)
|
||||
.bind(app_id.into_inner())
|
||||
.fetch_all(&self.pool)
|
||||
.await?;
|
||||
rows.into_iter().map(TryInto::try_into).collect()
|
||||
}
|
||||
}
|
||||
|
||||
/// Forwarding impl so the Postgres repo satisfies `AuthzRepo` directly
|
||||
@@ -210,3 +310,31 @@ impl TryFrom<AppMembershipRecord> for AppMembershipRow {
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(sqlx::FromRow)]
|
||||
struct AppMembershipDetailRecord {
|
||||
id: uuid::Uuid,
|
||||
username: String,
|
||||
email: Option<String>,
|
||||
instance_role: String,
|
||||
is_active: bool,
|
||||
role: String,
|
||||
created_at: DateTime<Utc>,
|
||||
}
|
||||
|
||||
impl TryFrom<AppMembershipDetailRecord> for AppMembershipDetail {
|
||||
type Error = AppMembersRepositoryError;
|
||||
fn try_from(r: AppMembershipDetailRecord) -> Result<Self, Self::Error> {
|
||||
Ok(Self {
|
||||
user_id: r.id.into(),
|
||||
username: r.username,
|
||||
email: r.email,
|
||||
instance_role: InstanceRole::from_db_str(&r.instance_role)
|
||||
.ok_or(AppMembersRepositoryError::InvalidRole(r.instance_role))?,
|
||||
is_active: r.is_active,
|
||||
role: AppRole::from_db_str(&r.role)
|
||||
.ok_or(AppMembersRepositoryError::InvalidRole(r.role))?,
|
||||
created_at: r.created_at,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,6 +8,7 @@
|
||||
use async_trait::async_trait;
|
||||
use picloud_shared::{AdminUserId, App, AppId};
|
||||
use sqlx::PgPool;
|
||||
use uuid::Uuid;
|
||||
|
||||
use crate::repo::ScriptRepositoryError;
|
||||
|
||||
@@ -20,6 +21,32 @@ pub struct AppLookup {
|
||||
pub redirected: bool,
|
||||
}
|
||||
|
||||
/// Resolve a free-form path param (UUID *or* slug *or* historical slug)
|
||||
/// to an `AppLookup`. UUID lookups never set `redirected`; slug lookups
|
||||
/// fall through to `app_slug_history` and set `redirected: true` when
|
||||
/// they hit it.
|
||||
///
|
||||
/// Returns `Ok(None)` when nothing matches — callers map that to their
|
||||
/// own not-found error variant.
|
||||
///
|
||||
/// # Errors
|
||||
/// Propagates any underlying repository error.
|
||||
pub async fn resolve_app(
|
||||
apps: &dyn AppRepository,
|
||||
ident: &str,
|
||||
) -> Result<Option<AppLookup>, ScriptRepositoryError> {
|
||||
if let Ok(uuid) = ident.parse::<Uuid>() {
|
||||
return Ok(apps
|
||||
.get_by_id(AppId::from(uuid))
|
||||
.await?
|
||||
.map(|app| AppLookup {
|
||||
app,
|
||||
redirected: false,
|
||||
}));
|
||||
}
|
||||
apps.get_by_slug_or_history(ident).await
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait AppRepository: Send + Sync {
|
||||
/// Every app on the instance. For owner/admin callers — `member`
|
||||
|
||||
@@ -17,14 +17,14 @@ use axum::response::{IntoResponse, Json, Response};
|
||||
use axum::routing::{delete, get, post};
|
||||
use axum::{Extension, Router};
|
||||
use picloud_orchestrator_core::routing::{pattern, AppDomainTable, CompiledAppDomain};
|
||||
use picloud_shared::{App, AppDomain, AppId, InstanceRole, Principal};
|
||||
use picloud_shared::{App, AppDomain, AppId, AppRole, InstanceRole, Principal};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_json::json;
|
||||
use uuid::Uuid;
|
||||
|
||||
use crate::app_domain_repo::{AppDomainRepository, NewAppDomain};
|
||||
use crate::app_repo::AppRepository;
|
||||
use crate::authz::{require, AuthzDenied, AuthzRepo, Capability};
|
||||
use crate::authz::{require, AuthzDenied, AuthzError, AuthzRepo, Capability};
|
||||
use crate::repo::ScriptRepositoryError;
|
||||
use crate::route_repo::RouteRepository;
|
||||
|
||||
@@ -141,6 +141,12 @@ pub struct AppLookupResponse {
|
||||
/// at the live slug so dashboards can redirect.
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub redirect_to: Option<String>,
|
||||
/// The caller's role on this app, used by the dashboard to decide
|
||||
/// whether to render admin-only surfaces (Members tab, settings).
|
||||
/// `Owner` maps to `app_admin`, `Admin` to `editor` (both implicit
|
||||
/// per blueprint §11.6); `Member` carries its explicit
|
||||
/// `app_members.role`.
|
||||
pub my_role: Option<AppRole>,
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
@@ -209,12 +215,31 @@ async fn get_app(
|
||||
} else {
|
||||
None
|
||||
};
|
||||
let my_role = compute_my_role(s.authz.as_ref(), &principal, lookup.app.id).await?;
|
||||
Ok(Json(AppLookupResponse {
|
||||
app: lookup.app,
|
||||
redirect_to,
|
||||
my_role,
|
||||
}))
|
||||
}
|
||||
|
||||
/// Compute the caller's effective `AppRole` on a specific app. Mirrors
|
||||
/// the implicit-grant logic in `authz::role_grants` but returns the
|
||||
/// role itself (for UI gating) rather than a yes/no decision. `Owner`
|
||||
/// is implicit `AppAdmin` everywhere; `Admin` is implicit `Editor`
|
||||
/// everywhere; `Member` consults `app_members`.
|
||||
async fn compute_my_role(
|
||||
authz: &dyn AuthzRepo,
|
||||
principal: &Principal,
|
||||
app_id: AppId,
|
||||
) -> Result<Option<AppRole>, AppsApiError> {
|
||||
match principal.instance_role {
|
||||
InstanceRole::Owner => Ok(Some(AppRole::AppAdmin)),
|
||||
InstanceRole::Admin => Ok(Some(AppRole::Editor)),
|
||||
InstanceRole::Member => Ok(authz.membership(principal.user_id, app_id).await?),
|
||||
}
|
||||
}
|
||||
|
||||
async fn patch_app(
|
||||
State(s): State<AppsState>,
|
||||
Extension(principal): Extension<Principal>,
|
||||
@@ -429,16 +454,7 @@ async fn resolve_app(
|
||||
apps: &dyn AppRepository,
|
||||
ident: &str,
|
||||
) -> Result<crate::app_repo::AppLookup, AppsApiError> {
|
||||
if let Ok(uuid) = ident.parse::<Uuid>() {
|
||||
if let Some(app) = apps.get_by_id(AppId::from(uuid)).await? {
|
||||
return Ok(crate::app_repo::AppLookup {
|
||||
app,
|
||||
redirected: false,
|
||||
});
|
||||
}
|
||||
return Err(AppsApiError::AppNotFound(ident.to_string()));
|
||||
}
|
||||
apps.get_by_slug_or_history(ident)
|
||||
crate::app_repo::resolve_app(apps, ident)
|
||||
.await?
|
||||
.ok_or_else(|| AppsApiError::AppNotFound(ident.to_string()))
|
||||
}
|
||||
@@ -546,6 +562,12 @@ impl From<AuthzDenied> for AppsApiError {
|
||||
}
|
||||
}
|
||||
|
||||
impl From<AuthzError> for AppsApiError {
|
||||
fn from(e: AuthzError) -> Self {
|
||||
Self::AuthzRepo(e.to_string())
|
||||
}
|
||||
}
|
||||
|
||||
impl IntoResponse for AppsApiError {
|
||||
fn into_response(self) -> Response {
|
||||
let (status, body) = match &self {
|
||||
|
||||
@@ -18,7 +18,7 @@ use axum::response::{IntoResponse, Json, Response};
|
||||
use axum::routing::{get, post};
|
||||
use axum::Router;
|
||||
use chrono::{DateTime, Duration as ChronoDuration, Utc};
|
||||
use picloud_shared::AdminUserId;
|
||||
use picloud_shared::{AdminUserId, InstanceRole};
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_json::json;
|
||||
|
||||
@@ -63,6 +63,8 @@ pub struct LoginResponse {
|
||||
pub struct AdminUserDto {
|
||||
pub id: AdminUserId,
|
||||
pub username: String,
|
||||
pub instance_role: InstanceRole,
|
||||
pub email: Option<String>,
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
@@ -87,9 +89,11 @@ async fn login(State(state): State<AuthState>, Json(input): Json<LoginRequest>)
|
||||
}
|
||||
};
|
||||
|
||||
let (stored_hash, user_id, username, is_active) = match creds {
|
||||
Some(c) => (c.password_hash, Some(c.id), c.username, c.is_active),
|
||||
None => (DUMMY_HASH.to_string(), None, String::new(), false),
|
||||
// username from creds is discarded — the re-fetch below carries the
|
||||
// canonical row used in the response DTO.
|
||||
let (stored_hash, user_id, is_active) = match creds {
|
||||
Some(c) => (c.password_hash, Some(c.id), c.is_active),
|
||||
None => (DUMMY_HASH.to_string(), None, false),
|
||||
};
|
||||
|
||||
let password_ok = verify_password(&stored_hash, &input.password);
|
||||
@@ -98,6 +102,18 @@ async fn login(State(state): State<AuthState>, Json(input): Json<LoginRequest>)
|
||||
}
|
||||
let user_id = user_id.unwrap();
|
||||
|
||||
// Re-fetch the full row so the login response carries the same
|
||||
// shape /me does (instance_role, email). The credentials struct
|
||||
// intentionally omits email; one extra query per login is fine.
|
||||
let user_row = match state.users.get(user_id).await {
|
||||
Ok(Some(row)) => row,
|
||||
Ok(None) => return invalid_credentials(),
|
||||
Err(err) => {
|
||||
tracing::error!(?err, "admin_users lookup after login failed");
|
||||
return internal_error();
|
||||
}
|
||||
};
|
||||
|
||||
let token = generate_session_token();
|
||||
let expires_at = Utc::now()
|
||||
+ ChronoDuration::from_std(state.ttl).unwrap_or_else(|_| ChronoDuration::hours(24));
|
||||
@@ -130,8 +146,10 @@ async fn login(State(state): State<AuthState>, Json(input): Json<LoginRequest>)
|
||||
headers,
|
||||
Json(LoginResponse {
|
||||
user: AdminUserDto {
|
||||
id: user_id,
|
||||
username,
|
||||
id: user_row.id,
|
||||
username: user_row.username,
|
||||
instance_role: user_row.instance_role,
|
||||
email: user_row.email,
|
||||
},
|
||||
token: token.raw,
|
||||
expires_at,
|
||||
@@ -171,6 +189,8 @@ async fn me(
|
||||
Ok(Some(row)) => Json(AdminUserDto {
|
||||
id: row.id,
|
||||
username: row.username,
|
||||
instance_role: row.instance_role,
|
||||
email: row.email,
|
||||
})
|
||||
.into_response(),
|
||||
Ok(None) => invalid_credentials(),
|
||||
|
||||
@@ -123,6 +123,7 @@ pub async fn bootstrap_first_admin_with<R: AdminUserRepository + ?Sized>(
|
||||
&username,
|
||||
&password_hash,
|
||||
picloud_shared::InstanceRole::Owner,
|
||||
None,
|
||||
)
|
||||
.await?;
|
||||
info!(username = %username, "bootstrapped initial admin user");
|
||||
@@ -176,13 +177,14 @@ mod tests {
|
||||
username: &str,
|
||||
_password_hash: &str,
|
||||
instance_role: InstanceRole,
|
||||
email: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError> {
|
||||
let row = AdminUserRow {
|
||||
id: AdminUserId::new(),
|
||||
username: username.to_string(),
|
||||
is_active: true,
|
||||
instance_role,
|
||||
email: None,
|
||||
email: email.map(str::to_string),
|
||||
created_at: Utc::now(),
|
||||
updated_at: Utc::now(),
|
||||
last_login_at: None,
|
||||
@@ -204,6 +206,13 @@ mod tests {
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError> {
|
||||
unimplemented!()
|
||||
}
|
||||
async fn update_email(
|
||||
&self,
|
||||
_i: AdminUserId,
|
||||
_e: Option<&str>,
|
||||
) -> Result<AdminUserRow, AdminUserRepositoryError> {
|
||||
unimplemented!()
|
||||
}
|
||||
async fn update_instance_role(
|
||||
&self,
|
||||
_i: AdminUserId,
|
||||
@@ -272,7 +281,7 @@ mod tests {
|
||||
#[tokio::test]
|
||||
async fn populated_db_is_noop() {
|
||||
let repo = InMemoryRepo::default();
|
||||
repo.create("seeded", "x", InstanceRole::Owner)
|
||||
repo.create("seeded", "x", InstanceRole::Owner, None)
|
||||
.await
|
||||
.unwrap();
|
||||
let env = BootstrapEnv {
|
||||
|
||||
@@ -12,6 +12,7 @@ pub mod api_key_repo;
|
||||
pub mod api_keys_api;
|
||||
pub mod app_bootstrap;
|
||||
pub mod app_domain_repo;
|
||||
pub mod app_members_api;
|
||||
pub mod app_members_repo;
|
||||
pub mod app_repo;
|
||||
pub mod apps_api;
|
||||
@@ -45,10 +46,12 @@ pub use api_key_repo::{
|
||||
pub use api_keys_api::{api_keys_router, ApiKeysState};
|
||||
pub use app_bootstrap::{seed_hello_world_if_fresh, HelloWorldOutcome};
|
||||
pub use app_domain_repo::{AppDomainRepository, NewAppDomain, PostgresAppDomainRepository};
|
||||
pub use app_members_api::{app_members_router, AppMembersApiError, AppMembersState};
|
||||
pub use app_members_repo::{
|
||||
AppMembersRepository, AppMembersRepositoryError, AppMembershipRow, PostgresAppMembersRepository,
|
||||
AppMembersRepository, AppMembersRepositoryError, AppMembershipDetail, AppMembershipRow,
|
||||
PostgresAppMembersRepository,
|
||||
};
|
||||
pub use app_repo::{AppLookup, AppRepository, PostgresAppRepository};
|
||||
pub use app_repo::{resolve_app, AppLookup, AppRepository, PostgresAppRepository};
|
||||
pub use apps_api::{apps_router, AppsState};
|
||||
pub use auth_api::auth_router;
|
||||
pub use auth_bootstrap::{
|
||||
|
||||
@@ -10,14 +10,15 @@ use axum::middleware::from_fn_with_state;
|
||||
use axum::{routing::get, Json, Router};
|
||||
use picloud_executor_core::{Engine, Limits};
|
||||
use picloud_manager_core::{
|
||||
admin_router, admins_router, api_keys_router, apps_api, apps_router, auth_router,
|
||||
compile_routes, migrations, require_authenticated, route_admin_router, AdminSessionRepository,
|
||||
AdminState, AdminUserRepository, AdminsState, ApiKeyRepository, ApiKeysState,
|
||||
AppDomainRepository, AppRepository, AppsState, AuthState, AuthzRepo,
|
||||
PostgresAdminSessionRepository, PostgresAdminUserRepository, PostgresApiKeyRepository,
|
||||
PostgresAppDomainRepository, PostgresAppMembersRepository, PostgresAppRepository,
|
||||
PostgresExecutionLogRepository, PostgresExecutionLogSink, PostgresRouteRepository,
|
||||
PostgresScriptRepository, RepoResolver, RouteAdminState, RouteRepository, SandboxCeiling,
|
||||
admin_router, admins_router, api_keys_router, app_members_router, apps_api, apps_router,
|
||||
auth_router, compile_routes, migrations, require_authenticated, route_admin_router,
|
||||
AdminSessionRepository, AdminState, AdminUserRepository, AdminsState, ApiKeyRepository,
|
||||
ApiKeysState, AppDomainRepository, AppMembersRepository, AppMembersState, AppRepository,
|
||||
AppsState, AuthState, AuthzRepo, PostgresAdminSessionRepository, PostgresAdminUserRepository,
|
||||
PostgresApiKeyRepository, PostgresAppDomainRepository, PostgresAppMembersRepository,
|
||||
PostgresAppRepository, PostgresExecutionLogRepository, PostgresExecutionLogSink,
|
||||
PostgresRouteRepository, PostgresScriptRepository, RepoResolver, RouteAdminState,
|
||||
RouteRepository, SandboxCeiling,
|
||||
};
|
||||
use picloud_orchestrator_core::routing::{AppDomainTable, RouteTable};
|
||||
use picloud_orchestrator_core::{
|
||||
@@ -79,6 +80,7 @@ fn read_session_ttl() -> Duration {
|
||||
/// the `require_admin` middleware. The data plane
|
||||
/// (`/api/v1/execute/{id}`, the user-route fallthrough, `/healthz`,
|
||||
/// `/version`) stays open — it's the public ingress for user scripts.
|
||||
#[allow(clippy::too_many_lines)]
|
||||
pub async fn build_app(pool: PgPool, auth: AuthDeps) -> anyhow::Result<Router> {
|
||||
let engine = Arc::new(Engine::new(Limits::default()));
|
||||
|
||||
@@ -89,9 +91,13 @@ pub async fn build_app(pool: PgPool, auth: AuthDeps) -> anyhow::Result<Router> {
|
||||
let apps_repo: Arc<dyn AppRepository> = Arc::new(PostgresAppRepository::new(pool.clone()));
|
||||
let domains_repo: Arc<dyn AppDomainRepository> =
|
||||
Arc::new(PostgresAppDomainRepository::new(pool.clone()));
|
||||
// Authz: app_members repo doubles as the AuthzRepo impl for the
|
||||
// per-handler capability checks introduced in Phase 3.5.
|
||||
let authz: Arc<dyn AuthzRepo> = Arc::new(PostgresAppMembersRepository::new(pool));
|
||||
// The Postgres app_members repo implements both `AppMembersRepository`
|
||||
// (CRUD over the table) and `AuthzRepo` (single-row membership lookup
|
||||
// for capability checks). Construct it once and clone the Arc into
|
||||
// both trait views — same allocation, two vtables.
|
||||
let members_concrete = Arc::new(PostgresAppMembersRepository::new(pool));
|
||||
let members: Arc<dyn AppMembersRepository> = members_concrete.clone();
|
||||
let authz: Arc<dyn AuthzRepo> = members_concrete;
|
||||
|
||||
// Compile the routes table once at startup; admin writes refresh it.
|
||||
let route_table = Arc::new(RouteTable::new());
|
||||
@@ -159,9 +165,15 @@ pub async fn build_app(pool: PgPool, auth: AuthDeps) -> anyhow::Result<Router> {
|
||||
ttl: auth.ttl,
|
||||
};
|
||||
let admins_state = AdminsState {
|
||||
users: auth.users,
|
||||
users: auth.users.clone(),
|
||||
sessions: auth.sessions,
|
||||
keys: auth.keys.clone(),
|
||||
authz: authz.clone(),
|
||||
};
|
||||
let app_members_state = AppMembersState {
|
||||
apps: apps_state.apps.clone(),
|
||||
users: auth.users,
|
||||
members,
|
||||
authz,
|
||||
};
|
||||
let api_keys_state = ApiKeysState { keys: auth.keys };
|
||||
@@ -177,6 +189,7 @@ pub async fn build_app(pool: PgPool, auth: AuthDeps) -> anyhow::Result<Router> {
|
||||
.merge(route_admin_router(route_admin))
|
||||
.merge(admins_router(admins_state))
|
||||
.merge(apps_router(apps_state))
|
||||
.merge(app_members_router(app_members_state))
|
||||
.merge(api_keys_router(api_keys_state))
|
||||
.layer(from_fn_with_state(
|
||||
auth_state.clone(),
|
||||
|
||||
@@ -36,7 +36,7 @@ async fn server_with_app(pool: PgPool) -> (TestServer, String) {
|
||||
let auth = picloud::AuthDeps::from_pool(pool.clone());
|
||||
let hash = hash_password("test-pw").expect("hash");
|
||||
auth.users
|
||||
.create("test-admin", &hash, InstanceRole::Owner)
|
||||
.create("test-admin", &hash, InstanceRole::Owner, None)
|
||||
.await
|
||||
.expect("seed admin");
|
||||
|
||||
@@ -93,6 +93,68 @@ async fn healthz_responds_ok(pool: PgPool) {
|
||||
assert_eq!(r.text(), "ok");
|
||||
}
|
||||
|
||||
// ============================================================================
|
||||
// Auth
|
||||
// ============================================================================
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn auth_me_returns_principal_with_role_and_email(pool: PgPool) {
|
||||
let s = server(pool).await;
|
||||
let r = s.get("/api/v1/admin/auth/me").await;
|
||||
r.assert_status_ok();
|
||||
let body: Value = r.json();
|
||||
assert_eq!(body["username"], "test-admin");
|
||||
assert_eq!(body["instance_role"], "owner");
|
||||
// Seeded admin has no email — must round-trip as null, not be missing.
|
||||
assert!(
|
||||
body.get("email").is_some_and(Value::is_null),
|
||||
"email should be present and null, got: {body}"
|
||||
);
|
||||
assert!(body["id"].as_str().is_some());
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn create_admin_accepts_email_and_patch_clears_it(pool: PgPool) {
|
||||
let s = server(pool).await;
|
||||
// Create with email set.
|
||||
let created = s
|
||||
.post("/api/v1/admin/admins")
|
||||
.json(&json!({
|
||||
"username": "alice",
|
||||
"password": "correct-horse-battery",
|
||||
"instance_role": "member",
|
||||
"email": "alice@example.com",
|
||||
}))
|
||||
.await;
|
||||
created.assert_status(axum::http::StatusCode::CREATED);
|
||||
let body: Value = created.json();
|
||||
let alice_id = body["id"].as_str().expect("id").to_string();
|
||||
assert_eq!(body["email"], "alice@example.com");
|
||||
|
||||
// Patch with email present-and-null clears it.
|
||||
let cleared = s
|
||||
.patch(&format!("/api/v1/admin/admins/{alice_id}"))
|
||||
.json(&json!({ "email": null }))
|
||||
.await;
|
||||
cleared.assert_status_ok();
|
||||
assert!(cleared.json::<Value>()["email"].is_null());
|
||||
|
||||
// Patch with email omitted is a no-op (doesn't clobber a re-set).
|
||||
let reset = s
|
||||
.patch(&format!("/api/v1/admin/admins/{alice_id}"))
|
||||
.json(&json!({ "email": "alice2@example.com" }))
|
||||
.await;
|
||||
reset.assert_status_ok();
|
||||
let omit = s
|
||||
.patch(&format!("/api/v1/admin/admins/{alice_id}"))
|
||||
.json(&json!({ "username": "alice" })) // no email key
|
||||
.await;
|
||||
omit.assert_status_ok();
|
||||
assert_eq!(omit.json::<Value>()["email"], "alice2@example.com");
|
||||
}
|
||||
|
||||
// ============================================================================
|
||||
// Script CRUD
|
||||
// ============================================================================
|
||||
|
||||
@@ -53,7 +53,7 @@ async fn boot(pool: PgPool) -> Seeded {
|
||||
let hash = hash_password("owner-pw").expect("hash");
|
||||
let owner = auth
|
||||
.users
|
||||
.create("owner", &hash, InstanceRole::Owner)
|
||||
.create("owner", &hash, InstanceRole::Owner, None)
|
||||
.await
|
||||
.expect("seed owner");
|
||||
|
||||
@@ -119,7 +119,7 @@ async fn seed_user(
|
||||
) -> AdminUserId {
|
||||
let repo = PostgresAdminUserRepository::new(pool.clone());
|
||||
let hash = hash_password(password).expect("hash");
|
||||
repo.create(username, &hash, role)
|
||||
repo.create(username, &hash, role, None)
|
||||
.await
|
||||
.expect("seed user")
|
||||
.id
|
||||
@@ -160,6 +160,72 @@ async fn mint_key(server: &TestServer, cred_token: &str, body: Value) -> axum_te
|
||||
.await
|
||||
}
|
||||
|
||||
// --- app members helpers ----------------------------------------------------
|
||||
|
||||
async fn list_members(
|
||||
server: &TestServer,
|
||||
token: &str,
|
||||
app_ident: &str,
|
||||
) -> axum_test::TestResponse {
|
||||
server
|
||||
.get(&format!("/api/v1/admin/apps/{app_ident}/members"))
|
||||
.add_header("authorization", format!("Bearer {token}"))
|
||||
.await
|
||||
}
|
||||
|
||||
async fn add_member(
|
||||
server: &TestServer,
|
||||
token: &str,
|
||||
app_ident: &str,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> axum_test::TestResponse {
|
||||
server
|
||||
.post(&format!("/api/v1/admin/apps/{app_ident}/members"))
|
||||
.add_header("authorization", format!("Bearer {token}"))
|
||||
.json(&json!({ "user_id": user_id, "role": role.as_str() }))
|
||||
.await
|
||||
}
|
||||
|
||||
async fn patch_member_role(
|
||||
server: &TestServer,
|
||||
token: &str,
|
||||
app_ident: &str,
|
||||
user_id: AdminUserId,
|
||||
role: AppRole,
|
||||
) -> axum_test::TestResponse {
|
||||
server
|
||||
.patch(&format!("/api/v1/admin/apps/{app_ident}/members/{user_id}",))
|
||||
.add_header("authorization", format!("Bearer {token}"))
|
||||
.json(&json!({ "role": role.as_str() }))
|
||||
.await
|
||||
}
|
||||
|
||||
async fn remove_member(
|
||||
server: &TestServer,
|
||||
token: &str,
|
||||
app_ident: &str,
|
||||
user_id: AdminUserId,
|
||||
) -> axum_test::TestResponse {
|
||||
server
|
||||
.delete(&format!("/api/v1/admin/apps/{app_ident}/members/{user_id}",))
|
||||
.add_header("authorization", format!("Bearer {token}"))
|
||||
.await
|
||||
}
|
||||
|
||||
/// Direct-DB inactive-user seed — the create-then-deactivate dance
|
||||
/// through the API is more ceremony than the test needs.
|
||||
async fn seed_inactive_user(pool: &PgPool, username: &str, password: &str) -> AdminUserId {
|
||||
let repo = PostgresAdminUserRepository::new(pool.clone());
|
||||
let hash = hash_password(password).expect("hash");
|
||||
let row = repo
|
||||
.create(username, &hash, InstanceRole::Member, None)
|
||||
.await
|
||||
.expect("seed user");
|
||||
repo.set_active(row.id, false).await.expect("deactivate");
|
||||
row.id
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// 1. Bootstrap admin → owner
|
||||
// ----------------------------------------------------------------------------
|
||||
@@ -645,3 +711,389 @@ async fn list_active_owners_drives_the_multi_owner_warning(pool: PgPool) {
|
||||
.expect("count");
|
||||
assert_eq!(remaining, 1, "one other owner should remain (owner2)");
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// 12. `my_role` on GET /apps/{id_or_slug} reflects the caller's effective role
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn my_role_field_matches_caller_role(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
|
||||
// Owner → implicit app_admin everywhere.
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let r = s
|
||||
.server
|
||||
.get("/api/v1/admin/apps/default")
|
||||
.add_header("authorization", format!("Bearer {owner_token}"))
|
||||
.await;
|
||||
r.assert_status_ok();
|
||||
assert_eq!(
|
||||
r.json::<Value>()["my_role"].as_str(),
|
||||
Some("app_admin"),
|
||||
"owner reports app_admin"
|
||||
);
|
||||
|
||||
// Admin → implicit editor everywhere.
|
||||
seed_user(&s.pool, "alice", "alice-pw", InstanceRole::Admin).await;
|
||||
let admin_token = login_token(&s.server, "alice", "alice-pw").await;
|
||||
let r = s
|
||||
.server
|
||||
.get("/api/v1/admin/apps/default")
|
||||
.add_header("authorization", format!("Bearer {admin_token}"))
|
||||
.await;
|
||||
r.assert_status_ok();
|
||||
assert_eq!(
|
||||
r.json::<Value>()["my_role"].as_str(),
|
||||
Some("editor"),
|
||||
"admin reports editor"
|
||||
);
|
||||
|
||||
// Member with explicit `viewer` membership → viewer.
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
let r = s
|
||||
.server
|
||||
.get("/api/v1/admin/apps/default")
|
||||
.add_header("authorization", format!("Bearer {bob_token}"))
|
||||
.await;
|
||||
r.assert_status_ok();
|
||||
assert_eq!(
|
||||
r.json::<Value>()["my_role"].as_str(),
|
||||
Some("viewer"),
|
||||
"member with viewer row reports viewer"
|
||||
);
|
||||
}
|
||||
|
||||
// ----------------------------------------------------------------------------
|
||||
// 13. App members CRUD — `/api/v1/admin/apps/{id_or_slug}/members[/{user_id}]`
|
||||
// ----------------------------------------------------------------------------
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn list_members_includes_seeded_member(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
|
||||
let r = list_members(&s.server, &owner_token, "default").await;
|
||||
r.assert_status_ok();
|
||||
let rows = r.json::<Vec<Value>>();
|
||||
let bob_row = rows
|
||||
.iter()
|
||||
.find(|v| v["username"] == "bob")
|
||||
.expect("bob in list");
|
||||
assert_eq!(bob_row["role"], "viewer");
|
||||
assert_eq!(bob_row["instance_role"], "member");
|
||||
assert_eq!(bob_row["is_active"], true);
|
||||
assert!(bob_row["created_at"].is_string(), "carries created_at");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn list_members_requires_app_admin(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
|
||||
// Bob has explicit editor on default app — enough to read scripts,
|
||||
// not enough to see the member list.
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Editor).await;
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
|
||||
let r = list_members(&s.server, &bob_token, "default").await;
|
||||
r.assert_status(axum::http::StatusCode::FORBIDDEN);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_creates_row(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
|
||||
let r = add_member(&s.server, &owner_token, "default", bob, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::CREATED);
|
||||
let body = r.json::<Value>();
|
||||
assert_eq!(body["username"], "bob");
|
||||
assert_eq!(body["role"], "viewer");
|
||||
assert_eq!(body["instance_role"], "member");
|
||||
|
||||
// Visible on subsequent list.
|
||||
let rows = list_members(&s.server, &owner_token, "default")
|
||||
.await
|
||||
.json::<Vec<Value>>();
|
||||
assert!(rows.iter().any(|v| v["username"] == "bob"));
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_duplicate_returns_409(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
|
||||
let r = add_member(&s.server, &owner_token, "default", bob, AppRole::Editor).await;
|
||||
r.assert_status(axum::http::StatusCode::CONFLICT);
|
||||
let err = r.json::<Value>()["error"]
|
||||
.as_str()
|
||||
.expect("error message")
|
||||
.to_string();
|
||||
assert!(err.contains("already a member"), "got: {err}");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_inactive_user_returns_422(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_inactive_user(&s.pool, "bob", "bob-pw").await;
|
||||
|
||||
let r = add_member(&s.server, &owner_token, "default", bob, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::UNPROCESSABLE_ENTITY);
|
||||
let err = r.json::<Value>()["error"]
|
||||
.as_str()
|
||||
.expect("error message")
|
||||
.to_string();
|
||||
assert!(err.contains("deactivated"), "got: {err}");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_admin_target_returns_422(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let alice = seed_user(&s.pool, "alice", "alice-pw", InstanceRole::Admin).await;
|
||||
|
||||
let r = add_member(&s.server, &owner_token, "default", alice, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::UNPROCESSABLE_ENTITY);
|
||||
let err = r.json::<Value>()["error"]
|
||||
.as_str()
|
||||
.expect("error message")
|
||||
.to_string();
|
||||
assert!(err.contains("implicit access"), "got: {err}");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_owner_target_returns_422(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let other_owner = seed_user(&s.pool, "owner2", "ow2-pw", InstanceRole::Owner).await;
|
||||
|
||||
let r = add_member(
|
||||
&s.server,
|
||||
&owner_token,
|
||||
"default",
|
||||
other_owner,
|
||||
AppRole::Viewer,
|
||||
)
|
||||
.await;
|
||||
r.assert_status(axum::http::StatusCode::UNPROCESSABLE_ENTITY);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn patch_member_promotes_role(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
|
||||
let r = patch_member_role(&s.server, &owner_token, "default", bob, AppRole::Editor).await;
|
||||
r.assert_status_ok();
|
||||
assert_eq!(r.json::<Value>()["role"], "editor");
|
||||
|
||||
// Editor can now create a script (capability promotion observable
|
||||
// end-to-end, not just via the role string).
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
create_script_via_api(&s.server, &bob_token, s.default_app, "bob-script").await;
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn patch_member_without_existing_returns_404(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
|
||||
// No grant yet — PATCH must 404.
|
||||
let r = patch_member_role(&s.server, &owner_token, "default", bob, AppRole::Editor).await;
|
||||
r.assert_status(axum::http::StatusCode::NOT_FOUND);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn patch_member_same_role_is_idempotent(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
|
||||
let r = patch_member_role(&s.server, &owner_token, "default", bob, AppRole::Viewer).await;
|
||||
r.assert_status_ok();
|
||||
assert_eq!(r.json::<Value>()["role"], "viewer");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn delete_member_removes_row(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
|
||||
let r = remove_member(&s.server, &owner_token, "default", bob).await;
|
||||
r.assert_status(axum::http::StatusCode::NO_CONTENT);
|
||||
|
||||
let rows = list_members(&s.server, &owner_token, "default")
|
||||
.await
|
||||
.json::<Vec<Value>>();
|
||||
assert!(rows.iter().all(|v| v["username"] != "bob"));
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn delete_member_missing_returns_204(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
// No grant ever happened — delete is idempotent.
|
||||
|
||||
let r = remove_member(&s.server, &owner_token, "default", bob).await;
|
||||
r.assert_status(axum::http::StatusCode::NO_CONTENT);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn mutating_endpoints_require_app_admin(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::Viewer).await;
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
|
||||
let target = seed_user(&s.pool, "carol", "carol-pw", InstanceRole::Member).await;
|
||||
|
||||
let r = add_member(&s.server, &bob_token, "default", target, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::FORBIDDEN);
|
||||
|
||||
let r = patch_member_role(&s.server, &bob_token, "default", bob, AppRole::Editor).await;
|
||||
r.assert_status(axum::http::StatusCode::FORBIDDEN);
|
||||
|
||||
let r = remove_member(&s.server, &bob_token, "default", bob).await;
|
||||
r.assert_status(axum::http::StatusCode::FORBIDDEN);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn members_endpoint_resolves_by_id_or_slug(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
|
||||
let by_slug = list_members(&s.server, &owner_token, "default").await;
|
||||
by_slug.assert_status_ok();
|
||||
let by_id = list_members(&s.server, &owner_token, &s.default_app.to_string()).await;
|
||||
by_id.assert_status_ok();
|
||||
assert_eq!(
|
||||
by_slug.json::<Value>(),
|
||||
by_id.json::<Value>(),
|
||||
"id and slug return identical bodies",
|
||||
);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn member_app_admin_can_manage_members(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
|
||||
// Bob is a member with explicit app_admin role on default.
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
grant_membership(&s.pool, bob, s.default_app, AppRole::AppAdmin).await;
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
|
||||
// Bob can list members.
|
||||
let r = list_members(&s.server, &bob_token, "default").await;
|
||||
r.assert_status_ok();
|
||||
|
||||
// Bob can add carol as viewer.
|
||||
let carol = seed_user(&s.pool, "carol", "carol-pw", InstanceRole::Member).await;
|
||||
let r = add_member(&s.server, &bob_token, "default", carol, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::CREATED);
|
||||
|
||||
// Bob can promote carol to editor.
|
||||
let r = patch_member_role(&s.server, &bob_token, "default", carol, AppRole::Editor).await;
|
||||
r.assert_status_ok();
|
||||
|
||||
// Bob can remove carol.
|
||||
let r = remove_member(&s.server, &bob_token, "default", carol).await;
|
||||
r.assert_status(axum::http::StatusCode::NO_CONTENT);
|
||||
|
||||
// And bob can even remove himself — owner's implicit AppAdmin
|
||||
// means the app isn't orphaned. This is the load-bearing test for
|
||||
// the no-last-app-admin-guard decision.
|
||||
let r = remove_member(&s.server, &bob_token, "default", bob).await;
|
||||
r.assert_status(axum::http::StatusCode::NO_CONTENT);
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn membership_makes_app_appear_in_members_app_list(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
|
||||
let bob = seed_user(&s.pool, "bob", "bob-pw", InstanceRole::Member).await;
|
||||
let bob_token = login_token(&s.server, "bob", "bob-pw").await;
|
||||
|
||||
// Before grant: bob sees no apps.
|
||||
let r = s
|
||||
.server
|
||||
.get("/api/v1/admin/apps")
|
||||
.add_header("authorization", format!("Bearer {bob_token}"))
|
||||
.await;
|
||||
r.assert_status_ok();
|
||||
assert!(
|
||||
r.json::<Vec<Value>>().is_empty(),
|
||||
"bob has no memberships → empty apps list"
|
||||
);
|
||||
|
||||
// Grant via the public POST endpoint — exercises the full
|
||||
// round-trip the dashboard goes through, not just the repo seam.
|
||||
let r = add_member(&s.server, &owner_token, "default", bob, AppRole::Viewer).await;
|
||||
r.assert_status(axum::http::StatusCode::CREATED);
|
||||
|
||||
// After grant: bob sees the default app.
|
||||
let r = s
|
||||
.server
|
||||
.get("/api/v1/admin/apps")
|
||||
.add_header("authorization", format!("Bearer {bob_token}"))
|
||||
.await;
|
||||
r.assert_status_ok();
|
||||
let apps = r.json::<Vec<Value>>();
|
||||
assert_eq!(apps.len(), 1);
|
||||
assert_eq!(apps[0]["slug"], "default");
|
||||
}
|
||||
|
||||
#[ignore = "needs DATABASE_URL pointing at a running Postgres"]
|
||||
#[sqlx::test(migrations = "../manager-core/migrations")]
|
||||
async fn add_member_with_missing_user_id_is_rejected(pool: PgPool) {
|
||||
let s = boot(pool).await;
|
||||
let owner_token = login_token(&s.server, "owner", "owner-pw").await;
|
||||
|
||||
// Body missing `user_id` — Axum's Json extractor produces a 4xx
|
||||
// before our handler runs. Pinning the status to keep the contract
|
||||
// honest if anyone ever swaps the extractor.
|
||||
let r = s
|
||||
.server
|
||||
.post("/api/v1/admin/apps/default/members")
|
||||
.add_header("authorization", format!("Bearer {owner_token}"))
|
||||
.json(&json!({ "role": "viewer" }))
|
||||
.await;
|
||||
let status = r.status_code().as_u16();
|
||||
assert!(
|
||||
(400..500).contains(&status),
|
||||
"malformed body should produce a 4xx, got {status}"
|
||||
);
|
||||
}
|
||||
|
||||
256
dashboard/src/lib/ActionMenu.svelte
Normal file
256
dashboard/src/lib/ActionMenu.svelte
Normal file
@@ -0,0 +1,256 @@
|
||||
<!--
|
||||
Per-row "⋮" kebab menu. Hides secondary actions (edit, deactivate,
|
||||
delete, etc.) behind a single trigger so list rows stay tidy.
|
||||
|
||||
Usage:
|
||||
<ActionMenu
|
||||
items={[
|
||||
{ label: 'Edit', onClick: () => openEdit(row) },
|
||||
{ label: row.is_active ? 'Deactivate' : 'Reactivate',
|
||||
onClick: () => toggleActive(row) },
|
||||
{ label: 'Delete', danger: true, onClick: () => openDelete(row),
|
||||
disabled: !canDelete(row) },
|
||||
]}
|
||||
/>
|
||||
|
||||
Closes on: item click, click outside, ESC, scroll/resize. Keyboard:
|
||||
Enter/Space opens; Up/Down navigate; Enter activates; ESC closes and
|
||||
re-focuses the trigger. The popover is absolutely positioned relative
|
||||
to the trigger and right-anchored — the parent must allow overflow
|
||||
(`overflow: visible`) for it to extend past the row.
|
||||
-->
|
||||
<script lang="ts">
|
||||
export interface MenuItem {
|
||||
label: string;
|
||||
onClick: () => void;
|
||||
danger?: boolean;
|
||||
disabled?: boolean;
|
||||
}
|
||||
|
||||
interface Props {
|
||||
items: MenuItem[];
|
||||
/** Accessible label for the trigger button. */
|
||||
label?: string;
|
||||
}
|
||||
|
||||
let { items, label = 'More actions' }: Props = $props();
|
||||
|
||||
let open = $state(false);
|
||||
let triggerEl = $state<HTMLButtonElement | null>(null);
|
||||
let menuEl = $state<HTMLDivElement | null>(null);
|
||||
let activeIndex = $state(-1);
|
||||
|
||||
let enabledIndices = $derived(
|
||||
items
|
||||
.map((it, i) => (it.disabled ? -1 : i))
|
||||
.filter((i) => i >= 0)
|
||||
);
|
||||
|
||||
function toggle() {
|
||||
open ? close() : openMenu();
|
||||
}
|
||||
|
||||
function openMenu() {
|
||||
open = true;
|
||||
activeIndex = enabledIndices[0] ?? -1;
|
||||
}
|
||||
|
||||
function close(refocus = false) {
|
||||
open = false;
|
||||
activeIndex = -1;
|
||||
if (refocus) triggerEl?.focus();
|
||||
}
|
||||
|
||||
function activate(index: number) {
|
||||
const item = items[index];
|
||||
if (!item || item.disabled) return;
|
||||
close();
|
||||
item.onClick();
|
||||
}
|
||||
|
||||
function moveActive(step: 1 | -1) {
|
||||
if (enabledIndices.length === 0) return;
|
||||
const cur = enabledIndices.indexOf(activeIndex);
|
||||
const next =
|
||||
cur === -1
|
||||
? enabledIndices[0]
|
||||
: enabledIndices[(cur + step + enabledIndices.length) % enabledIndices.length];
|
||||
activeIndex = next;
|
||||
}
|
||||
|
||||
function onTriggerKeydown(e: KeyboardEvent) {
|
||||
if (e.key === 'ArrowDown' || e.key === 'Enter' || e.key === ' ') {
|
||||
e.preventDefault();
|
||||
if (!open) openMenu();
|
||||
}
|
||||
}
|
||||
|
||||
function onMenuKeydown(e: KeyboardEvent) {
|
||||
switch (e.key) {
|
||||
case 'ArrowDown':
|
||||
e.preventDefault();
|
||||
moveActive(1);
|
||||
break;
|
||||
case 'ArrowUp':
|
||||
e.preventDefault();
|
||||
moveActive(-1);
|
||||
break;
|
||||
case 'Enter':
|
||||
case ' ':
|
||||
e.preventDefault();
|
||||
if (activeIndex >= 0) activate(activeIndex);
|
||||
break;
|
||||
case 'Escape':
|
||||
e.preventDefault();
|
||||
close(true);
|
||||
break;
|
||||
case 'Tab':
|
||||
close();
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
function onWindowMouseDown(e: MouseEvent) {
|
||||
if (!open) return;
|
||||
const target = e.target as Node;
|
||||
if (menuEl?.contains(target) || triggerEl?.contains(target)) return;
|
||||
close();
|
||||
}
|
||||
|
||||
// Close on viewport changes — naive but enough; without a portal a
|
||||
// scrolling list would otherwise leave the popover drifting away from
|
||||
// its row.
|
||||
function onViewportChange() {
|
||||
if (open) close();
|
||||
}
|
||||
</script>
|
||||
|
||||
<svelte:window
|
||||
onmousedown={onWindowMouseDown}
|
||||
onscroll={onViewportChange}
|
||||
onresize={onViewportChange}
|
||||
/>
|
||||
|
||||
<div class="wrap">
|
||||
<button
|
||||
bind:this={triggerEl}
|
||||
type="button"
|
||||
class="trigger"
|
||||
class:open
|
||||
aria-label={label}
|
||||
aria-haspopup="menu"
|
||||
aria-expanded={open}
|
||||
onclick={toggle}
|
||||
onkeydown={onTriggerKeydown}
|
||||
>
|
||||
<!-- vertical ellipsis ⋮ — kept inline as text so it inherits color -->
|
||||
<span aria-hidden="true">⋮</span>
|
||||
</button>
|
||||
|
||||
{#if open}
|
||||
<div
|
||||
bind:this={menuEl}
|
||||
class="menu"
|
||||
role="menu"
|
||||
tabindex="-1"
|
||||
onkeydown={onMenuKeydown}
|
||||
>
|
||||
{#each items as item, i (i)}
|
||||
<button
|
||||
type="button"
|
||||
role="menuitem"
|
||||
class="item"
|
||||
class:danger={item.danger}
|
||||
class:active={i === activeIndex}
|
||||
disabled={item.disabled}
|
||||
onclick={() => activate(i)}
|
||||
onmouseenter={() => {
|
||||
if (!item.disabled) activeIndex = i;
|
||||
}}
|
||||
>
|
||||
{item.label}
|
||||
</button>
|
||||
{/each}
|
||||
</div>
|
||||
{/if}
|
||||
</div>
|
||||
|
||||
<style>
|
||||
.wrap {
|
||||
position: relative;
|
||||
display: inline-flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
|
||||
.trigger {
|
||||
background: transparent;
|
||||
color: #94a3b8;
|
||||
border: 1px solid transparent;
|
||||
width: 1.75rem;
|
||||
height: 1.75rem;
|
||||
border-radius: 0.25rem;
|
||||
font: inherit;
|
||||
font-size: 1.1rem;
|
||||
line-height: 1;
|
||||
cursor: pointer;
|
||||
display: inline-flex;
|
||||
align-items: center;
|
||||
justify-content: center;
|
||||
padding: 0;
|
||||
}
|
||||
|
||||
.trigger:hover,
|
||||
.trigger:focus-visible,
|
||||
.trigger.open {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
border-color: #334155;
|
||||
outline: none;
|
||||
}
|
||||
|
||||
.menu {
|
||||
position: absolute;
|
||||
top: calc(100% + 4px);
|
||||
right: 0;
|
||||
min-width: 9rem;
|
||||
background: #0f172a;
|
||||
border: 1px solid #334155;
|
||||
border-radius: 0.375rem;
|
||||
box-shadow: 0 10px 25px -10px rgba(0, 0, 0, 0.6);
|
||||
padding: 0.25rem;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
z-index: 50;
|
||||
}
|
||||
|
||||
.item {
|
||||
background: transparent;
|
||||
color: #cbd5e1;
|
||||
border: none;
|
||||
text-align: left;
|
||||
padding: 0.4rem 0.6rem;
|
||||
font: inherit;
|
||||
font-size: 0.8rem;
|
||||
border-radius: 0.25rem;
|
||||
cursor: pointer;
|
||||
}
|
||||
|
||||
.item.active:not(:disabled) {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.item.danger {
|
||||
color: #fca5a5;
|
||||
}
|
||||
|
||||
.item.danger.active:not(:disabled) {
|
||||
background: #450a0a;
|
||||
color: #fecaca;
|
||||
}
|
||||
|
||||
.item:disabled {
|
||||
opacity: 0.45;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
</style>
|
||||
69
dashboard/src/lib/RoleChip.svelte
Normal file
69
dashboard/src/lib/RoleChip.svelte
Normal file
@@ -0,0 +1,69 @@
|
||||
<script lang="ts">
|
||||
import type { InstanceRole } from '$lib/auth';
|
||||
import type { AppRole } from '$lib/api';
|
||||
|
||||
interface Props {
|
||||
role?: InstanceRole;
|
||||
appRole?: AppRole;
|
||||
size?: 'sm' | 'md';
|
||||
}
|
||||
|
||||
let { role, appRole, size = 'md' }: Props = $props();
|
||||
|
||||
// Display label: app roles read better with a space ("app admin")
|
||||
// than their wire form ("app_admin").
|
||||
const label = $derived(
|
||||
appRole ? appRole.replace('_', ' ') : (role ?? '')
|
||||
);
|
||||
const cls = $derived(appRole ? `chip-${appRole}` : `chip-${role}`);
|
||||
</script>
|
||||
|
||||
<span class="chip {cls}" class:sm={size === 'sm'}>{label}</span>
|
||||
|
||||
<style>
|
||||
.chip {
|
||||
display: inline-flex;
|
||||
align-items: center;
|
||||
padding: 0.15rem 0.55rem;
|
||||
border-radius: 999px;
|
||||
font-size: 0.7rem;
|
||||
font-weight: 600;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.04em;
|
||||
border: 1px solid transparent;
|
||||
}
|
||||
.chip.sm {
|
||||
font-size: 0.625rem;
|
||||
padding: 0.1rem 0.45rem;
|
||||
}
|
||||
.chip-owner {
|
||||
background: #78350f;
|
||||
color: #fbbf24;
|
||||
border-color: #b45309;
|
||||
}
|
||||
.chip-admin {
|
||||
background: #164e63;
|
||||
color: #67e8f9;
|
||||
border-color: #0e7490;
|
||||
}
|
||||
.chip-member {
|
||||
background: #1e293b;
|
||||
color: #cbd5e1;
|
||||
border-color: #334155;
|
||||
}
|
||||
.chip-app_admin {
|
||||
background: #4c1d95;
|
||||
color: #c4b5fd;
|
||||
border-color: #6d28d9;
|
||||
}
|
||||
.chip-editor {
|
||||
background: #1e3a8a;
|
||||
color: #93c5fd;
|
||||
border-color: #1d4ed8;
|
||||
}
|
||||
.chip-viewer {
|
||||
background: #1f2937;
|
||||
color: #9ca3af;
|
||||
border-color: #374151;
|
||||
}
|
||||
</style>
|
||||
@@ -8,7 +8,9 @@
|
||||
import { goto } from '$app/navigation';
|
||||
import { base } from '$app/paths';
|
||||
import { browser } from '$app/environment';
|
||||
import { clearSession, getToken, setSession, type AdminUser } from './auth';
|
||||
import { clearSession, getToken, setSession, type InstanceRole } from './auth';
|
||||
|
||||
export type { InstanceRole };
|
||||
|
||||
export interface ScriptSandbox {
|
||||
max_operations?: number;
|
||||
@@ -42,6 +44,8 @@ export interface App {
|
||||
updated_at: string;
|
||||
}
|
||||
|
||||
export type AppRole = 'app_admin' | 'editor' | 'viewer';
|
||||
|
||||
export type DomainShape = 'exact' | 'wildcard' | 'parameterized';
|
||||
|
||||
export interface AppDomain {
|
||||
@@ -62,6 +66,11 @@ export interface AppLookupResponse {
|
||||
updated_at: string;
|
||||
/// Present only when the requested slug was a retired redirect.
|
||||
redirect_to?: string;
|
||||
/// The caller's role on this app — owners are implicit `app_admin`,
|
||||
/// admins implicit `editor`, members carry their `app_members.role`.
|
||||
/// `null` only when a member somehow reaches the endpoint without
|
||||
/// a membership (the server normally 403s first).
|
||||
my_role: AppRole | null;
|
||||
}
|
||||
|
||||
export interface SlugCheckResponse {
|
||||
@@ -232,10 +241,42 @@ function safeJson(text: string): unknown {
|
||||
}
|
||||
}
|
||||
|
||||
export interface AdminUserRecord {
|
||||
export type Scope =
|
||||
| 'script:read'
|
||||
| 'script:write'
|
||||
| 'route:write'
|
||||
| 'domain:manage'
|
||||
| 'log:read'
|
||||
| 'app:admin'
|
||||
| 'instance:admin';
|
||||
|
||||
export const ALL_SCOPES: readonly Scope[] = [
|
||||
'script:read',
|
||||
'script:write',
|
||||
'route:write',
|
||||
'domain:manage',
|
||||
'log:read',
|
||||
'app:admin',
|
||||
'instance:admin'
|
||||
] as const;
|
||||
|
||||
export function isInstanceScope(s: Scope): boolean {
|
||||
return s.startsWith('instance:');
|
||||
}
|
||||
|
||||
export interface MeDto {
|
||||
id: string;
|
||||
username: string;
|
||||
instance_role: InstanceRole;
|
||||
email: string | null;
|
||||
}
|
||||
|
||||
export interface AdminDto {
|
||||
id: string;
|
||||
username: string;
|
||||
is_active: boolean;
|
||||
instance_role: InstanceRole;
|
||||
email: string | null;
|
||||
created_at: string;
|
||||
last_login_at: string | null;
|
||||
}
|
||||
@@ -243,16 +284,57 @@ export interface AdminUserRecord {
|
||||
export interface CreateAdminInput {
|
||||
username: string;
|
||||
password: string;
|
||||
instance_role?: InstanceRole;
|
||||
email?: string | null;
|
||||
}
|
||||
|
||||
export interface PatchAdminInput {
|
||||
username?: string;
|
||||
password?: string;
|
||||
is_active?: boolean;
|
||||
instance_role?: InstanceRole;
|
||||
email?: string | null;
|
||||
}
|
||||
|
||||
export interface AppMemberDto {
|
||||
user_id: string;
|
||||
username: string;
|
||||
email: string | null;
|
||||
instance_role: InstanceRole;
|
||||
is_active: boolean;
|
||||
role: AppRole;
|
||||
created_at: string;
|
||||
}
|
||||
|
||||
export interface GrantAppMemberInput {
|
||||
user_id: string;
|
||||
role: AppRole;
|
||||
}
|
||||
|
||||
export interface ApiKeyDto {
|
||||
id: string;
|
||||
prefix: string;
|
||||
name: string;
|
||||
scopes: Scope[];
|
||||
app_id: string | null;
|
||||
expires_at: string | null;
|
||||
last_used_at: string | null;
|
||||
created_at: string;
|
||||
}
|
||||
|
||||
export interface MintApiKeyInput {
|
||||
name: string;
|
||||
scopes: Scope[];
|
||||
app_id?: string | null;
|
||||
expires_at?: string | null;
|
||||
}
|
||||
|
||||
export interface MintApiKeyResponse extends ApiKeyDto {
|
||||
raw_token: string;
|
||||
}
|
||||
|
||||
interface LoginResponse {
|
||||
user: AdminUser;
|
||||
user: MeDto;
|
||||
token: string;
|
||||
expires_at: string;
|
||||
}
|
||||
@@ -263,7 +345,7 @@ export const api = {
|
||||
version: () => adminRequest<VersionInfo>('/version'),
|
||||
|
||||
auth: {
|
||||
login: async (username: string, password: string): Promise<AdminUser> => {
|
||||
login: async (username: string, password: string): Promise<MeDto> => {
|
||||
const r = await adminRequest<LoginResponse>('/api/v1/admin/auth/login', {
|
||||
method: 'POST',
|
||||
body: JSON.stringify({ username, password })
|
||||
@@ -282,19 +364,19 @@ export const api = {
|
||||
clearSession();
|
||||
}
|
||||
},
|
||||
me: () => adminRequest<AdminUser>('/api/v1/admin/auth/me')
|
||||
me: () => adminRequest<MeDto>('/api/v1/admin/auth/me')
|
||||
},
|
||||
|
||||
admins: {
|
||||
list: () => adminRequest<AdminUserRecord[]>('/api/v1/admin/admins'),
|
||||
get: (id: string) => adminRequest<AdminUserRecord>(`/api/v1/admin/admins/${id}`),
|
||||
list: () => adminRequest<AdminDto[]>('/api/v1/admin/admins'),
|
||||
get: (id: string) => adminRequest<AdminDto>(`/api/v1/admin/admins/${id}`),
|
||||
create: (input: CreateAdminInput) =>
|
||||
adminRequest<AdminUserRecord>('/api/v1/admin/admins', {
|
||||
adminRequest<AdminDto>('/api/v1/admin/admins', {
|
||||
method: 'POST',
|
||||
body: JSON.stringify(input)
|
||||
}),
|
||||
update: (id: string, input: PatchAdminInput) =>
|
||||
adminRequest<AdminUserRecord>(`/api/v1/admin/admins/${id}`, {
|
||||
adminRequest<AdminDto>(`/api/v1/admin/admins/${id}`, {
|
||||
method: 'PATCH',
|
||||
body: JSON.stringify(input)
|
||||
}),
|
||||
@@ -302,6 +384,17 @@ export const api = {
|
||||
adminRequest<null>(`/api/v1/admin/admins/${id}`, { method: 'DELETE' })
|
||||
},
|
||||
|
||||
apiKeys: {
|
||||
list: () => adminRequest<ApiKeyDto[]>('/api/v1/admin/api-keys'),
|
||||
mint: (input: MintApiKeyInput) =>
|
||||
adminRequest<MintApiKeyResponse>('/api/v1/admin/api-keys', {
|
||||
method: 'POST',
|
||||
body: JSON.stringify(input)
|
||||
}),
|
||||
revoke: (id: string) =>
|
||||
adminRequest<null>(`/api/v1/admin/api-keys/${id}`, { method: 'DELETE' })
|
||||
},
|
||||
|
||||
routes: {
|
||||
listForScript: (scriptId: string) =>
|
||||
adminRequest<Route[]>(`/api/v1/admin/scripts/${scriptId}/routes`),
|
||||
@@ -401,6 +494,28 @@ export const api = {
|
||||
)
|
||||
},
|
||||
|
||||
appMembers: {
|
||||
list: (idOrSlug: string) =>
|
||||
adminRequest<AppMemberDto[]>(
|
||||
`/api/v1/admin/apps/${encodeURIComponent(idOrSlug)}/members`
|
||||
),
|
||||
add: (idOrSlug: string, input: GrantAppMemberInput) =>
|
||||
adminRequest<AppMemberDto>(
|
||||
`/api/v1/admin/apps/${encodeURIComponent(idOrSlug)}/members`,
|
||||
{ method: 'POST', body: JSON.stringify(input) }
|
||||
),
|
||||
setRole: (idOrSlug: string, userId: string, role: AppRole) =>
|
||||
adminRequest<AppMemberDto>(
|
||||
`/api/v1/admin/apps/${encodeURIComponent(idOrSlug)}/members/${userId}`,
|
||||
{ method: 'PATCH', body: JSON.stringify({ role }) }
|
||||
),
|
||||
remove: (idOrSlug: string, userId: string) =>
|
||||
adminRequest<null>(
|
||||
`/api/v1/admin/apps/${encodeURIComponent(idOrSlug)}/members/${userId}`,
|
||||
{ method: 'DELETE' }
|
||||
)
|
||||
},
|
||||
|
||||
execute: async (
|
||||
id: string,
|
||||
body: unknown,
|
||||
|
||||
@@ -10,9 +10,13 @@
|
||||
import { writable, get } from 'svelte/store';
|
||||
import { browser } from '$app/environment';
|
||||
|
||||
export type InstanceRole = 'owner' | 'admin' | 'member';
|
||||
|
||||
export interface AdminUser {
|
||||
id: string;
|
||||
username: string;
|
||||
instance_role: InstanceRole;
|
||||
email: string | null;
|
||||
}
|
||||
|
||||
const TOKEN_KEY = 'picloud.admin.token';
|
||||
|
||||
25
dashboard/src/lib/password-gen.ts
Normal file
25
dashboard/src/lib/password-gen.ts
Normal file
@@ -0,0 +1,25 @@
|
||||
// Cryptographically random password generator for the user-create
|
||||
// and reset-password flows. PiCloud has no email yet, so the admin
|
||||
// invites a user by generating a password locally, posting it to the
|
||||
// backend, and copying the cleartext out of the one-time reveal panel
|
||||
// to share through whatever channel they trust.
|
||||
//
|
||||
// Charset is alphanumeric plus a small printable symbol set — enough
|
||||
// entropy at 16 chars (~95 bits) to be uncopyable by hand mistakes,
|
||||
// avoidant of characters that ship awkwardly through chat clients
|
||||
// (no quotes, slashes, or backticks).
|
||||
|
||||
const CHARSET = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789!#$%&*+-?@';
|
||||
|
||||
export function generatePassword(length = 16): string {
|
||||
if (length < 8) {
|
||||
throw new Error('password length must be at least 8');
|
||||
}
|
||||
const buf = new Uint32Array(length);
|
||||
crypto.getRandomValues(buf);
|
||||
let out = '';
|
||||
for (let i = 0; i < length; i++) {
|
||||
out += CHARSET[buf[i] % CHARSET.length];
|
||||
}
|
||||
return out;
|
||||
}
|
||||
@@ -5,6 +5,7 @@
|
||||
import { page } from '$app/state';
|
||||
import { api } from '$lib/api';
|
||||
import { currentUser, getToken } from '$lib/auth';
|
||||
import RoleChip from '$lib/RoleChip.svelte';
|
||||
|
||||
let { children } = $props();
|
||||
|
||||
@@ -46,12 +47,17 @@
|
||||
<a href={base + '/'} class="brand">PiCloud</a>
|
||||
<nav>
|
||||
<a href={base + '/apps'}>Apps</a>
|
||||
<a href={base + '/admins'}>Admins</a>
|
||||
{#if user && user.instance_role !== 'member'}
|
||||
<a href={base + '/users'}>Users</a>
|
||||
{/if}
|
||||
</nav>
|
||||
<div class="spacer"></div>
|
||||
{#if user}
|
||||
<div class="usermenu">
|
||||
<a href={base + '/profile'} class="profile-chip" title="View profile">
|
||||
<RoleChip role={user.instance_role} size="sm" />
|
||||
<span class="username">{user.username}</span>
|
||||
</a>
|
||||
<button type="button" class="logout" onclick={handleLogout}>Logout</button>
|
||||
</div>
|
||||
{/if}
|
||||
@@ -121,6 +127,20 @@
|
||||
font-size: 0.875rem;
|
||||
}
|
||||
|
||||
.profile-chip {
|
||||
display: inline-flex;
|
||||
align-items: center;
|
||||
gap: 0.4rem;
|
||||
padding: 0.25rem 0.55rem;
|
||||
border-radius: 0.375rem;
|
||||
text-decoration: none;
|
||||
border: 1px solid transparent;
|
||||
}
|
||||
.profile-chip:hover {
|
||||
background: #1e293b;
|
||||
border-color: #334155;
|
||||
}
|
||||
|
||||
.username {
|
||||
color: #cbd5e1;
|
||||
}
|
||||
|
||||
@@ -1,687 +0,0 @@
|
||||
<script lang="ts">
|
||||
import { goto } from '$app/navigation';
|
||||
import { base } from '$app/paths';
|
||||
import { onMount } from 'svelte';
|
||||
import { api, ApiError, type AdminUserRecord } from '$lib/api';
|
||||
import { currentUser } from '$lib/auth';
|
||||
|
||||
let admins = $state<AdminUserRecord[]>([]);
|
||||
let loadError = $state<string | null>(null);
|
||||
let banner = $state<{ kind: 'error' | 'info'; message: string } | null>(null);
|
||||
|
||||
const me = $derived($currentUser);
|
||||
|
||||
let createOpen = $state(false);
|
||||
let createForm = $state({ username: '', password: '', confirm: '' });
|
||||
let createPending = $state(false);
|
||||
let createError = $state<string | null>(null);
|
||||
|
||||
let passwordTarget = $state<AdminUserRecord | null>(null);
|
||||
let passwordForm = $state({ password: '', confirm: '' });
|
||||
let passwordPending = $state(false);
|
||||
let passwordError = $state<string | null>(null);
|
||||
|
||||
let deleteTarget = $state<AdminUserRecord | null>(null);
|
||||
let deletePending = $state(false);
|
||||
|
||||
let actionsOpenFor = $state<string | null>(null);
|
||||
|
||||
onMount(refresh);
|
||||
|
||||
async function refresh() {
|
||||
loadError = null;
|
||||
try {
|
||||
admins = await api.admins.list();
|
||||
} catch (e) {
|
||||
loadError = e instanceof ApiError ? e.message : 'failed to load admins';
|
||||
}
|
||||
}
|
||||
|
||||
function flash(kind: 'error' | 'info', message: string) {
|
||||
banner = { kind, message };
|
||||
setTimeout(() => {
|
||||
if (banner?.message === message) banner = null;
|
||||
}, 6000);
|
||||
}
|
||||
|
||||
function openCreate() {
|
||||
createForm = { username: '', password: '', confirm: '' };
|
||||
createError = null;
|
||||
createOpen = true;
|
||||
}
|
||||
|
||||
async function submitCreate(event: SubmitEvent) {
|
||||
event.preventDefault();
|
||||
createError = null;
|
||||
if (createForm.password !== createForm.confirm) {
|
||||
createError = 'Passwords do not match';
|
||||
return;
|
||||
}
|
||||
createPending = true;
|
||||
try {
|
||||
await api.admins.create({
|
||||
username: createForm.username.trim(),
|
||||
password: createForm.password
|
||||
});
|
||||
createOpen = false;
|
||||
await refresh();
|
||||
flash('info', `Created admin "${createForm.username.trim()}".`);
|
||||
} catch (e) {
|
||||
createError = e instanceof ApiError ? e.message : 'failed to create admin';
|
||||
} finally {
|
||||
createPending = false;
|
||||
}
|
||||
}
|
||||
|
||||
function openPassword(row: AdminUserRecord) {
|
||||
passwordTarget = row;
|
||||
passwordForm = { password: '', confirm: '' };
|
||||
passwordError = null;
|
||||
actionsOpenFor = null;
|
||||
}
|
||||
|
||||
async function submitPassword(event: SubmitEvent) {
|
||||
event.preventDefault();
|
||||
if (!passwordTarget) return;
|
||||
passwordError = null;
|
||||
if (passwordForm.password !== passwordForm.confirm) {
|
||||
passwordError = 'Passwords do not match';
|
||||
return;
|
||||
}
|
||||
passwordPending = true;
|
||||
try {
|
||||
await api.admins.update(passwordTarget.id, { password: passwordForm.password });
|
||||
const name = passwordTarget.username;
|
||||
passwordTarget = null;
|
||||
flash('info', `Password updated for "${name}".`);
|
||||
} catch (e) {
|
||||
passwordError = e instanceof ApiError ? e.message : 'failed to update password';
|
||||
} finally {
|
||||
passwordPending = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function toggleActive(row: AdminUserRecord) {
|
||||
actionsOpenFor = null;
|
||||
try {
|
||||
const updated = await api.admins.update(row.id, { is_active: !row.is_active });
|
||||
admins = admins.map((a) => (a.id === updated.id ? updated : a));
|
||||
flash('info', `${updated.username} ${updated.is_active ? 'reactivated' : 'deactivated'}.`);
|
||||
} catch (e) {
|
||||
flash('error', e instanceof ApiError ? e.message : 'failed to update admin');
|
||||
}
|
||||
}
|
||||
|
||||
function openDelete(row: AdminUserRecord) {
|
||||
deleteTarget = row;
|
||||
actionsOpenFor = null;
|
||||
}
|
||||
|
||||
async function confirmDelete() {
|
||||
if (!deleteTarget) return;
|
||||
deletePending = true;
|
||||
const target = deleteTarget;
|
||||
try {
|
||||
await api.admins.remove(target.id);
|
||||
deleteTarget = null;
|
||||
if (me && me.id === target.id) {
|
||||
// Just deleted ourselves — sign out and bounce.
|
||||
await api.auth.logout();
|
||||
await goto(`${base}/login`);
|
||||
return;
|
||||
}
|
||||
await refresh();
|
||||
flash('info', `Deleted "${target.username}".`);
|
||||
} catch (e) {
|
||||
flash('error', e instanceof ApiError ? e.message : 'failed to delete admin');
|
||||
} finally {
|
||||
deletePending = false;
|
||||
}
|
||||
}
|
||||
|
||||
function toggleActions(id: string) {
|
||||
actionsOpenFor = actionsOpenFor === id ? null : id;
|
||||
}
|
||||
|
||||
function relative(iso: string | null): string {
|
||||
if (!iso) return 'Never';
|
||||
const then = new Date(iso).getTime();
|
||||
const now = Date.now();
|
||||
const sec = Math.round((now - then) / 1000);
|
||||
if (sec < 60) return `${sec} second${sec === 1 ? '' : 's'} ago`;
|
||||
const min = Math.round(sec / 60);
|
||||
if (min < 60) return `${min} minute${min === 1 ? '' : 's'} ago`;
|
||||
const hr = Math.round(min / 60);
|
||||
if (hr < 24) return `${hr} hour${hr === 1 ? '' : 's'} ago`;
|
||||
const day = Math.round(hr / 24);
|
||||
if (day === 1) return 'Yesterday';
|
||||
if (day < 7) return `${day} days ago`;
|
||||
return new Date(iso).toLocaleDateString();
|
||||
}
|
||||
|
||||
function absolute(iso: string | null): string {
|
||||
return iso ? new Date(iso).toISOString() : '';
|
||||
}
|
||||
|
||||
function shortDate(iso: string): string {
|
||||
return new Date(iso).toISOString().slice(0, 10);
|
||||
}
|
||||
</script>
|
||||
|
||||
<header class="head">
|
||||
<h1>Admin Users</h1>
|
||||
<button type="button" class="primary" onclick={openCreate}>+ New admin user</button>
|
||||
</header>
|
||||
|
||||
{#if banner}
|
||||
<div class="banner banner-{banner.kind}">{banner.message}</div>
|
||||
{/if}
|
||||
|
||||
{#if loadError}
|
||||
<div class="error">
|
||||
{loadError}
|
||||
<button type="button" class="retry" onclick={refresh}>Retry</button>
|
||||
</div>
|
||||
{:else if admins.length === 0}
|
||||
<p class="empty">No admin users yet. Add one to get started.</p>
|
||||
{:else}
|
||||
<div class="table">
|
||||
<div class="row head-row">
|
||||
<div>Username</div>
|
||||
<div>Status</div>
|
||||
<div>Created</div>
|
||||
<div>Last login</div>
|
||||
<div class="actions-col"></div>
|
||||
</div>
|
||||
{#each admins as row (row.id)}
|
||||
<div class="row">
|
||||
<div class="username-cell">
|
||||
<span class="name">{row.username}</span>
|
||||
{#if me && me.id === row.id}
|
||||
<span class="you-tag">(you)</span>
|
||||
{/if}
|
||||
</div>
|
||||
<div>
|
||||
{#if row.is_active}
|
||||
<span class="status status-active">● Active</span>
|
||||
{:else}
|
||||
<span class="status status-inactive">○ Inactive</span>
|
||||
{/if}
|
||||
</div>
|
||||
<div>{shortDate(row.created_at)}</div>
|
||||
<div title={absolute(row.last_login_at)}>{relative(row.last_login_at)}</div>
|
||||
<div class="actions-col">
|
||||
<button
|
||||
type="button"
|
||||
class="kebab"
|
||||
aria-label="Actions for {row.username}"
|
||||
onclick={() => toggleActions(row.id)}
|
||||
>
|
||||
⋮
|
||||
</button>
|
||||
{#if actionsOpenFor === row.id}
|
||||
<div class="menu">
|
||||
<button type="button" onclick={() => openPassword(row)}>Change password</button>
|
||||
<button type="button" onclick={() => toggleActive(row)}>
|
||||
{row.is_active ? 'Deactivate' : 'Reactivate'}
|
||||
</button>
|
||||
<button type="button" class="danger" onclick={() => openDelete(row)}>Delete</button>
|
||||
</div>
|
||||
{/if}
|
||||
</div>
|
||||
</div>
|
||||
{/each}
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- New admin modal -->
|
||||
{#if createOpen}
|
||||
<div
|
||||
class="modal-backdrop"
|
||||
role="presentation"
|
||||
onclick={(e) => {
|
||||
if (e.target === e.currentTarget) createOpen = false;
|
||||
}}
|
||||
>
|
||||
<form class="modal" onsubmit={submitCreate}>
|
||||
<div class="modal-head">
|
||||
<h2>New admin user</h2>
|
||||
<button
|
||||
type="button"
|
||||
class="x"
|
||||
aria-label="Close"
|
||||
onclick={() => (createOpen = false)}>✕</button
|
||||
>
|
||||
</div>
|
||||
<label>
|
||||
<span>Username</span>
|
||||
<input
|
||||
type="text"
|
||||
autocomplete="off"
|
||||
spellcheck="false"
|
||||
bind:value={createForm.username}
|
||||
required
|
||||
/>
|
||||
<small>Lowercase letters, digits, . _ -</small>
|
||||
</label>
|
||||
<label>
|
||||
<span>Password</span>
|
||||
<input
|
||||
type="password"
|
||||
autocomplete="new-password"
|
||||
bind:value={createForm.password}
|
||||
required
|
||||
/>
|
||||
<small>Minimum 8 characters</small>
|
||||
</label>
|
||||
<label>
|
||||
<span>Confirm password</span>
|
||||
<input
|
||||
type="password"
|
||||
autocomplete="new-password"
|
||||
bind:value={createForm.confirm}
|
||||
required
|
||||
/>
|
||||
</label>
|
||||
{#if createError}
|
||||
<div class="error">{createError}</div>
|
||||
{/if}
|
||||
<div class="modal-actions">
|
||||
<button type="button" class="ghost" onclick={() => (createOpen = false)}>Cancel</button>
|
||||
<button type="submit" class="primary" disabled={createPending}>
|
||||
{createPending ? 'Creating…' : 'Create user'}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Change password modal -->
|
||||
{#if passwordTarget}
|
||||
<div
|
||||
class="modal-backdrop"
|
||||
role="presentation"
|
||||
onclick={(e) => {
|
||||
if (e.target === e.currentTarget) passwordTarget = null;
|
||||
}}
|
||||
>
|
||||
<form class="modal" onsubmit={submitPassword}>
|
||||
<div class="modal-head">
|
||||
<h2>Change password — {passwordTarget.username}</h2>
|
||||
<button type="button" class="x" aria-label="Close" onclick={() => (passwordTarget = null)}
|
||||
>✕</button
|
||||
>
|
||||
</div>
|
||||
<label>
|
||||
<span>New password</span>
|
||||
<input
|
||||
type="password"
|
||||
autocomplete="new-password"
|
||||
bind:value={passwordForm.password}
|
||||
required
|
||||
/>
|
||||
</label>
|
||||
<label>
|
||||
<span>Confirm password</span>
|
||||
<input
|
||||
type="password"
|
||||
autocomplete="new-password"
|
||||
bind:value={passwordForm.confirm}
|
||||
required
|
||||
/>
|
||||
</label>
|
||||
{#if passwordError}
|
||||
<div class="error">{passwordError}</div>
|
||||
{/if}
|
||||
<div class="modal-actions">
|
||||
<button type="button" class="ghost" onclick={() => (passwordTarget = null)}>Cancel</button>
|
||||
<button type="submit" class="primary" disabled={passwordPending}>
|
||||
{passwordPending ? 'Updating…' : 'Update'}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Delete confirmation modal -->
|
||||
{#if deleteTarget}
|
||||
<div
|
||||
class="modal-backdrop"
|
||||
role="presentation"
|
||||
onclick={(e) => {
|
||||
if (e.target === e.currentTarget) deleteTarget = null;
|
||||
}}
|
||||
>
|
||||
<div class="modal">
|
||||
<div class="modal-head">
|
||||
<h2>Delete {deleteTarget.username}?</h2>
|
||||
<button type="button" class="x" aria-label="Close" onclick={() => (deleteTarget = null)}
|
||||
>✕</button
|
||||
>
|
||||
</div>
|
||||
{#if me && me.id === deleteTarget.id}
|
||||
<p>
|
||||
You are about to delete <strong>your own</strong> account. You will be signed out immediately
|
||||
and will not be able to sign back in with these credentials.
|
||||
</p>
|
||||
{:else}
|
||||
<p>
|
||||
This permanently removes <strong>{deleteTarget.username}</strong> and all their sessions.
|
||||
This cannot be undone.
|
||||
</p>
|
||||
{/if}
|
||||
<div class="modal-actions">
|
||||
<button type="button" class="ghost" onclick={() => (deleteTarget = null)}>Cancel</button>
|
||||
<button type="button" class="danger" disabled={deletePending} onclick={confirmDelete}>
|
||||
{deletePending ? 'Deleting…' : 'Delete'}
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<style>
|
||||
.head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
margin-bottom: 1.5rem;
|
||||
}
|
||||
|
||||
h1 {
|
||||
font-size: 1.25rem;
|
||||
margin: 0;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.banner {
|
||||
padding: 0.5rem 0.75rem;
|
||||
border-radius: 0.375rem;
|
||||
margin-bottom: 1rem;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.banner-error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
}
|
||||
.banner-info {
|
||||
background: #0c2a36;
|
||||
border: 1px solid #155e75;
|
||||
color: #a5f3fc;
|
||||
}
|
||||
|
||||
.empty {
|
||||
color: #64748b;
|
||||
text-align: center;
|
||||
padding: 3rem 0;
|
||||
border: 1px dashed #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
}
|
||||
|
||||
.table {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
overflow: visible;
|
||||
background: #0b1220;
|
||||
}
|
||||
|
||||
.row {
|
||||
display: grid;
|
||||
grid-template-columns: 1.5fr 0.9fr 1fr 1.2fr 3rem;
|
||||
align-items: center;
|
||||
gap: 1rem;
|
||||
padding: 0.75rem 1rem;
|
||||
border-bottom: 1px solid #1e293b;
|
||||
font-size: 0.9rem;
|
||||
}
|
||||
|
||||
.row:last-child {
|
||||
border-bottom: none;
|
||||
}
|
||||
|
||||
.head-row {
|
||||
color: #94a3b8;
|
||||
font-size: 0.75rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
background: #0f172a;
|
||||
}
|
||||
|
||||
.username-cell {
|
||||
display: flex;
|
||||
align-items: baseline;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
|
||||
.name {
|
||||
color: #e2e8f0;
|
||||
font-weight: 500;
|
||||
}
|
||||
|
||||
.you-tag {
|
||||
color: #64748b;
|
||||
font-size: 0.75rem;
|
||||
}
|
||||
|
||||
.status {
|
||||
font-size: 0.8rem;
|
||||
}
|
||||
.status-active {
|
||||
color: #34d399;
|
||||
}
|
||||
.status-inactive {
|
||||
color: #64748b;
|
||||
}
|
||||
|
||||
.actions-col {
|
||||
position: relative;
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
|
||||
.kebab {
|
||||
background: transparent;
|
||||
border: none;
|
||||
color: #94a3b8;
|
||||
font-size: 1.25rem;
|
||||
cursor: pointer;
|
||||
padding: 0 0.5rem;
|
||||
border-radius: 0.25rem;
|
||||
}
|
||||
.kebab:hover {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.menu {
|
||||
position: absolute;
|
||||
top: 100%;
|
||||
right: 0;
|
||||
background: #0b1220;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
min-width: 12rem;
|
||||
z-index: 10;
|
||||
box-shadow: 0 6px 16px rgba(0, 0, 0, 0.4);
|
||||
}
|
||||
|
||||
.menu button {
|
||||
background: transparent;
|
||||
border: none;
|
||||
color: #cbd5e1;
|
||||
text-align: left;
|
||||
padding: 0.5rem 0.75rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.menu button:hover {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
.menu button.danger {
|
||||
color: #fca5a5;
|
||||
}
|
||||
.menu button.danger:hover {
|
||||
background: #450a0a;
|
||||
color: #fecaca;
|
||||
}
|
||||
|
||||
.error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.5rem 0.75rem;
|
||||
border-radius: 0.375rem;
|
||||
font-size: 0.85rem;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
gap: 1rem;
|
||||
}
|
||||
|
||||
.retry {
|
||||
background: transparent;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.25rem 0.6rem;
|
||||
border-radius: 0.25rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.75rem;
|
||||
}
|
||||
|
||||
button.primary {
|
||||
background: #38bdf8;
|
||||
color: #0b1220;
|
||||
border: none;
|
||||
padding: 0.55rem 0.9rem;
|
||||
border-radius: 0.375rem;
|
||||
font-weight: 600;
|
||||
cursor: pointer;
|
||||
font-size: 0.875rem;
|
||||
}
|
||||
button.primary:disabled {
|
||||
opacity: 0.6;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
|
||||
button.ghost {
|
||||
background: transparent;
|
||||
color: #94a3b8;
|
||||
border: 1px solid #334155;
|
||||
padding: 0.5rem 0.9rem;
|
||||
border-radius: 0.375rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.875rem;
|
||||
}
|
||||
button.ghost:hover {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
button.danger {
|
||||
background: #b91c1c;
|
||||
color: #fef2f2;
|
||||
border: none;
|
||||
padding: 0.55rem 0.9rem;
|
||||
border-radius: 0.375rem;
|
||||
cursor: pointer;
|
||||
font-weight: 600;
|
||||
font-size: 0.875rem;
|
||||
}
|
||||
button.danger:disabled {
|
||||
opacity: 0.6;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
|
||||
.modal-backdrop {
|
||||
position: fixed;
|
||||
inset: 0;
|
||||
background: rgba(15, 23, 42, 0.7);
|
||||
display: flex;
|
||||
justify-content: center;
|
||||
align-items: center;
|
||||
z-index: 50;
|
||||
}
|
||||
|
||||
.modal {
|
||||
background: #0b1220;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
padding: 1.5rem;
|
||||
min-width: 24rem;
|
||||
max-width: 28rem;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 1rem;
|
||||
box-shadow: 0 12px 32px rgba(0, 0, 0, 0.5);
|
||||
}
|
||||
|
||||
.modal-head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
}
|
||||
|
||||
.modal h2 {
|
||||
margin: 0;
|
||||
font-size: 1rem;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.x {
|
||||
background: transparent;
|
||||
border: none;
|
||||
color: #64748b;
|
||||
font-size: 1.1rem;
|
||||
cursor: pointer;
|
||||
}
|
||||
.x:hover {
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.modal label {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.4rem;
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
}
|
||||
|
||||
.modal label small {
|
||||
color: #64748b;
|
||||
font-size: 0.75rem;
|
||||
}
|
||||
|
||||
.modal input {
|
||||
background: #0f172a;
|
||||
color: #e2e8f0;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.55rem 0.75rem;
|
||||
font-size: 0.9rem;
|
||||
box-sizing: border-box;
|
||||
}
|
||||
.modal input:focus {
|
||||
outline: none;
|
||||
border-color: #38bdf8;
|
||||
}
|
||||
|
||||
.modal-actions {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
gap: 0.75rem;
|
||||
margin-top: 0.5rem;
|
||||
}
|
||||
|
||||
p {
|
||||
color: #cbd5e1;
|
||||
font-size: 0.9rem;
|
||||
margin: 0;
|
||||
line-height: 1.5;
|
||||
}
|
||||
</style>
|
||||
@@ -5,26 +5,38 @@
|
||||
import {
|
||||
api,
|
||||
ApiError,
|
||||
type AdminDto,
|
||||
type App,
|
||||
type AppDomain,
|
||||
type AppMemberDto,
|
||||
type AppRole,
|
||||
type Script
|
||||
} from '$lib/api';
|
||||
import CodeEditor from '$lib/CodeEditor.svelte';
|
||||
import ConfirmModal from '$lib/ConfirmModal.svelte';
|
||||
import ActionMenu from '$lib/ActionMenu.svelte';
|
||||
import RoleChip from '$lib/RoleChip.svelte';
|
||||
import { currentUser } from '$lib/auth';
|
||||
|
||||
const me = $derived($currentUser);
|
||||
|
||||
const SAMPLE_SOURCE =
|
||||
'#{\n statusCode: 200,\n body: #{ ok: true, echo: ctx.request.body }\n}';
|
||||
|
||||
type Tab = 'scripts' | 'domains' | 'settings';
|
||||
type Tab = 'scripts' | 'domains' | 'members' | 'settings';
|
||||
|
||||
let slug = $derived(page.params.slug ?? '');
|
||||
let app = $state<App | null>(null);
|
||||
let myRole = $state<AppRole | null>(null);
|
||||
let loadError = $state<string | null>(null);
|
||||
let loading = $state(true);
|
||||
let activeTab = $state<Tab>('scripts');
|
||||
|
||||
let scripts = $state<Script[]>([]);
|
||||
let domains = $state<AppDomain[]>([]);
|
||||
let members = $state<AppMemberDto[]>([]);
|
||||
|
||||
const canAdminMembers = $derived(myRole === 'app_admin');
|
||||
|
||||
// Script create
|
||||
let showCreateScript = $state(false);
|
||||
@@ -55,6 +67,19 @@
|
||||
let removingDomain = $state(false);
|
||||
let removeDomainError = $state<string | null>(null);
|
||||
|
||||
// Members tab
|
||||
let eligibleUsers = $state<AdminDto[]>([]);
|
||||
let eligibleLoadError = $state<string | null>(null);
|
||||
let addMemberUserId = $state('');
|
||||
let addMemberRole = $state<AppRole>('viewer');
|
||||
let addingMember = $state(false);
|
||||
let addMemberError = $state<string | null>(null);
|
||||
let memberToRemove = $state<AppMemberDto | null>(null);
|
||||
let removingMember = $state(false);
|
||||
let removeMemberError = $state<string | null>(null);
|
||||
let roleChangeBusy = $state<string | null>(null);
|
||||
let memberActionError = $state<string | null>(null);
|
||||
|
||||
async function loadApp() {
|
||||
loading = true;
|
||||
loadError = null;
|
||||
@@ -72,10 +97,15 @@
|
||||
created_at: fetched.created_at,
|
||||
updated_at: fetched.updated_at
|
||||
};
|
||||
myRole = fetched.my_role;
|
||||
editName = app.name;
|
||||
editDescription = app.description ?? '';
|
||||
editSlug = app.slug;
|
||||
await Promise.all([loadScripts(app.id), loadDomains(app.id)]);
|
||||
const loaders: Promise<unknown>[] = [loadScripts(app.id), loadDomains(app.id)];
|
||||
if (canAdminMembers) {
|
||||
loaders.push(loadMembers(app.id), loadEligibleUsers());
|
||||
}
|
||||
await Promise.all(loaders);
|
||||
} catch (e) {
|
||||
loadError = e instanceof Error ? e.message : String(e);
|
||||
} finally {
|
||||
@@ -101,6 +131,42 @@
|
||||
}
|
||||
}
|
||||
|
||||
async function loadMembers(appId: string) {
|
||||
try {
|
||||
members = await api.appMembers.list(appId);
|
||||
} catch (e) {
|
||||
members = [];
|
||||
memberActionError = e instanceof Error ? e.message : String(e);
|
||||
}
|
||||
}
|
||||
|
||||
async function loadEligibleUsers() {
|
||||
eligibleLoadError = null;
|
||||
try {
|
||||
const all = await api.admins.list();
|
||||
// Only inactive=false members are valid invite targets — the
|
||||
// API rejects everyone else anyway, so filter upfront.
|
||||
eligibleUsers = all.filter(
|
||||
(u) => u.is_active && u.instance_role === 'member'
|
||||
);
|
||||
} catch (e) {
|
||||
eligibleUsers = [];
|
||||
// member-with-app_admin can hit /apps/.../members but cannot
|
||||
// browse /admins (gated on InstanceManageUsers). The add form
|
||||
// will render disabled with the explanatory message below.
|
||||
eligibleLoadError =
|
||||
e instanceof ApiError && e.status === 403
|
||||
? 'Only instance owners/admins can browse the user directory to invite new members.'
|
||||
: e instanceof Error
|
||||
? e.message
|
||||
: String(e);
|
||||
}
|
||||
}
|
||||
|
||||
const eligibleAfterFilter = $derived(
|
||||
eligibleUsers.filter((u) => !members.some((m) => m.user_id === u.id))
|
||||
);
|
||||
|
||||
async function submitCreateScript(event: Event) {
|
||||
event.preventDefault();
|
||||
if (!app) return;
|
||||
@@ -201,6 +267,76 @@
|
||||
}
|
||||
}
|
||||
|
||||
async function submitAddMember(event: Event) {
|
||||
event.preventDefault();
|
||||
if (!app || !addMemberUserId) return;
|
||||
addingMember = true;
|
||||
addMemberError = null;
|
||||
try {
|
||||
await api.appMembers.add(app.id, {
|
||||
user_id: addMemberUserId,
|
||||
role: addMemberRole
|
||||
});
|
||||
addMemberUserId = '';
|
||||
addMemberRole = 'viewer';
|
||||
await loadMembers(app.id);
|
||||
} catch (e) {
|
||||
addMemberError = e instanceof Error ? e.message : String(e);
|
||||
} finally {
|
||||
addingMember = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function changeMemberRole(member: AppMemberDto, role: AppRole) {
|
||||
if (!app || member.role === role) return;
|
||||
roleChangeBusy = member.user_id;
|
||||
memberActionError = null;
|
||||
try {
|
||||
await api.appMembers.setRole(app.id, member.user_id, role);
|
||||
await loadMembers(app.id);
|
||||
} catch (e) {
|
||||
memberActionError = e instanceof Error ? e.message : String(e);
|
||||
} finally {
|
||||
roleChangeBusy = null;
|
||||
}
|
||||
}
|
||||
|
||||
function askRemoveMember(member: AppMemberDto) {
|
||||
removeMemberError = null;
|
||||
memberToRemove = member;
|
||||
}
|
||||
|
||||
async function confirmRemoveMember() {
|
||||
if (!app || !memberToRemove) return;
|
||||
removingMember = true;
|
||||
removeMemberError = null;
|
||||
try {
|
||||
const removedSelf = !!me && memberToRemove.user_id === me.id;
|
||||
await api.appMembers.remove(app.id, memberToRemove.user_id);
|
||||
memberToRemove = null;
|
||||
if (removedSelf) {
|
||||
// We just revoked our own access to this app; the next
|
||||
// fetch of /apps/{slug} would 403. Bounce back to the
|
||||
// apps list rather than render a broken tab.
|
||||
await goto(`${base}/apps`);
|
||||
return;
|
||||
}
|
||||
await loadMembers(app.id);
|
||||
} catch (e) {
|
||||
removeMemberError = e instanceof Error ? e.message : String(e);
|
||||
} finally {
|
||||
removingMember = false;
|
||||
}
|
||||
}
|
||||
|
||||
function shortDate(iso: string): string {
|
||||
try {
|
||||
return new Date(iso).toLocaleDateString();
|
||||
} catch {
|
||||
return iso;
|
||||
}
|
||||
}
|
||||
|
||||
function askDeleteApp() {
|
||||
deleteAppError = null;
|
||||
confirmingDeleteApp = true;
|
||||
@@ -258,6 +394,13 @@
|
||||
class:active={activeTab === 'domains'}
|
||||
onclick={() => (activeTab = 'domains')}>Domains ({domains.length})</button
|
||||
>
|
||||
{#if canAdminMembers}
|
||||
<button
|
||||
type="button"
|
||||
class:active={activeTab === 'members'}
|
||||
onclick={() => (activeTab = 'members')}>Members ({members.length})</button
|
||||
>
|
||||
{/if}
|
||||
<button
|
||||
type="button"
|
||||
class:active={activeTab === 'settings'}
|
||||
@@ -365,6 +508,121 @@
|
||||
</ul>
|
||||
{/if}
|
||||
</section>
|
||||
{:else if activeTab === 'members' && canAdminMembers}
|
||||
<section>
|
||||
<h2>Members</h2>
|
||||
<p class="muted">
|
||||
Users with explicit access to this app. Instance owners and admins
|
||||
already have implicit access — they are not listed here. Use the Users
|
||||
page to invite a <code>member</code> first, then grant them app access
|
||||
below.
|
||||
</p>
|
||||
|
||||
<form class="create-form" onsubmit={submitAddMember}>
|
||||
<div class="row">
|
||||
<label class="grow">
|
||||
<span>User</span>
|
||||
<select
|
||||
bind:value={addMemberUserId}
|
||||
disabled={!!eligibleLoadError || eligibleAfterFilter.length === 0}
|
||||
required
|
||||
>
|
||||
<option value="" disabled>Pick a member to invite…</option>
|
||||
{#each eligibleAfterFilter as u (u.id)}
|
||||
<option value={u.id}>{u.username}{u.email ? ` (${u.email})` : ''}</option>
|
||||
{/each}
|
||||
</select>
|
||||
</label>
|
||||
<label>
|
||||
<span>Role</span>
|
||||
<select bind:value={addMemberRole} disabled={!!eligibleLoadError}>
|
||||
<option value="viewer">viewer</option>
|
||||
<option value="editor">editor</option>
|
||||
<option value="app_admin">app admin</option>
|
||||
</select>
|
||||
</label>
|
||||
</div>
|
||||
{#if eligibleLoadError}
|
||||
<p class="muted">{eligibleLoadError}</p>
|
||||
{:else if eligibleAfterFilter.length === 0}
|
||||
<p class="muted">
|
||||
No eligible users to invite. Create a <code>member</code> on the Users
|
||||
page first.
|
||||
</p>
|
||||
{/if}
|
||||
{#if addMemberError}
|
||||
<div class="error">{addMemberError}</div>
|
||||
{/if}
|
||||
<div class="actions">
|
||||
<button
|
||||
type="submit"
|
||||
disabled={addingMember || !addMemberUserId || !!eligibleLoadError}
|
||||
>
|
||||
{addingMember ? 'Adding…' : 'Add member'}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
|
||||
{#if memberActionError}
|
||||
<div class="error">{memberActionError}</div>
|
||||
{/if}
|
||||
|
||||
{#if members.length === 0}
|
||||
<p class="muted">No explicit members yet.</p>
|
||||
{:else}
|
||||
<div class="table">
|
||||
<div class="row head-row">
|
||||
<div>User</div>
|
||||
<div>Instance</div>
|
||||
<div>App role</div>
|
||||
<div>Joined</div>
|
||||
<div class="actions-col"></div>
|
||||
</div>
|
||||
{#each members as m (m.user_id)}
|
||||
<div class="row member-row" class:inactive={!m.is_active}>
|
||||
<div>
|
||||
<strong>{m.username}</strong>
|
||||
{#if m.email}<span class="muted">{m.email}</span>{/if}
|
||||
{#if !m.is_active}<span class="muted">(inactive)</span>{/if}
|
||||
</div>
|
||||
<div><RoleChip role={m.instance_role} size="sm" /></div>
|
||||
<div><RoleChip appRole={m.role} size="sm" /></div>
|
||||
<div>{shortDate(m.created_at)}</div>
|
||||
<div class="actions-col">
|
||||
<ActionMenu
|
||||
label="Member actions for {m.username}"
|
||||
items={[
|
||||
{
|
||||
label: 'Make app admin',
|
||||
disabled:
|
||||
m.role === 'app_admin' || roleChangeBusy === m.user_id,
|
||||
onClick: () => changeMemberRole(m, 'app_admin')
|
||||
},
|
||||
{
|
||||
label: 'Make editor',
|
||||
disabled:
|
||||
m.role === 'editor' || roleChangeBusy === m.user_id,
|
||||
onClick: () => changeMemberRole(m, 'editor')
|
||||
},
|
||||
{
|
||||
label: 'Make viewer',
|
||||
disabled:
|
||||
m.role === 'viewer' || roleChangeBusy === m.user_id,
|
||||
onClick: () => changeMemberRole(m, 'viewer')
|
||||
},
|
||||
{
|
||||
label: 'Remove from app',
|
||||
danger: true,
|
||||
onClick: () => askRemoveMember(m)
|
||||
}
|
||||
]}
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
{/each}
|
||||
</div>
|
||||
{/if}
|
||||
</section>
|
||||
{:else if activeTab === 'settings'}
|
||||
<section>
|
||||
<h2>Settings</h2>
|
||||
@@ -502,6 +760,26 @@
|
||||
{/if}
|
||||
</ConfirmModal>
|
||||
{/if}
|
||||
|
||||
{#if memberToRemove}
|
||||
<ConfirmModal
|
||||
title="Remove {memberToRemove.username} from {app.name}"
|
||||
variant="danger"
|
||||
confirmLabel="Remove member"
|
||||
busyLabel="Removing…"
|
||||
busy={removingMember}
|
||||
onConfirm={confirmRemoveMember}
|
||||
onCancel={() => (memberToRemove = null)}
|
||||
>
|
||||
<p>
|
||||
<strong>{memberToRemove.username}</strong> will lose access to this
|
||||
app. Their other app memberships and account are untouched.
|
||||
</p>
|
||||
{#if removeMemberError}
|
||||
<p class="modal-error">{removeMemberError}</p>
|
||||
{/if}
|
||||
</ConfirmModal>
|
||||
{/if}
|
||||
{/if}
|
||||
|
||||
<style>
|
||||
@@ -744,4 +1022,60 @@
|
||||
border-radius: 0.5rem;
|
||||
background: #1e0a0a;
|
||||
}
|
||||
|
||||
.create-form select {
|
||||
background: #0b1220;
|
||||
color: #e2e8f0;
|
||||
border: 1px solid #334155;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.5rem 0.75rem;
|
||||
font: inherit;
|
||||
}
|
||||
|
||||
.create-form .row > label.grow {
|
||||
grid-column: span 2;
|
||||
}
|
||||
|
||||
.table {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.25rem;
|
||||
}
|
||||
|
||||
.table .row {
|
||||
display: grid;
|
||||
grid-template-columns: 2fr 1fr 1fr 1fr 3rem;
|
||||
gap: 0.75rem;
|
||||
padding: 0.85rem 1rem;
|
||||
background: #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
align-items: center;
|
||||
margin: 0;
|
||||
}
|
||||
|
||||
.table .head-row {
|
||||
background: transparent;
|
||||
padding: 0.25rem 1rem;
|
||||
color: #64748b;
|
||||
font-size: 0.75rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
}
|
||||
|
||||
.table .member-row.inactive {
|
||||
opacity: 0.55;
|
||||
}
|
||||
|
||||
.table .member-row strong {
|
||||
margin-right: 0.4rem;
|
||||
}
|
||||
|
||||
.table .member-row .muted {
|
||||
font-size: 0.8rem;
|
||||
}
|
||||
|
||||
.table .actions-col {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
</style>
|
||||
|
||||
760
dashboard/src/routes/profile/+page.svelte
Normal file
760
dashboard/src/routes/profile/+page.svelte
Normal file
@@ -0,0 +1,760 @@
|
||||
<!--
|
||||
/admin/profile — every authenticated principal lands here for their
|
||||
own identity + API-key management. No role gating: a member can mint
|
||||
keys for the apps they belong to just like an admin can. Users-admin
|
||||
actions live under /admin/users.
|
||||
-->
|
||||
<script lang="ts">
|
||||
import { onMount } from 'svelte';
|
||||
import { page } from '$app/state';
|
||||
import {
|
||||
api,
|
||||
ApiError,
|
||||
ALL_SCOPES,
|
||||
isInstanceScope,
|
||||
type ApiKeyDto,
|
||||
type App,
|
||||
type MintApiKeyResponse,
|
||||
type Scope
|
||||
} from '$lib/api';
|
||||
import { currentUser } from '$lib/auth';
|
||||
import RoleChip from '$lib/RoleChip.svelte';
|
||||
import ConfirmModal from '$lib/ConfirmModal.svelte';
|
||||
|
||||
const me = $derived($currentUser);
|
||||
|
||||
let keys = $state<ApiKeyDto[]>([]);
|
||||
let apps = $state<App[]>([]);
|
||||
let appBySlug = $derived(new Map(apps.map((a) => [a.id, a])));
|
||||
let loadError = $state<string | null>(null);
|
||||
let banner = $state<{ kind: 'error' | 'info'; message: string } | null>(null);
|
||||
|
||||
// Surface the cross-page "access denied" notice when /users bounces
|
||||
// a member back here. One-shot — clears as soon as the user
|
||||
// navigates away or dismisses.
|
||||
const deniedFromUsers = $derived(page.url.searchParams.get('denied') === 'users');
|
||||
|
||||
let mintOpen = $state(false);
|
||||
let mintForm = $state<{
|
||||
name: string;
|
||||
scopes: Set<Scope>;
|
||||
app_id: string | '';
|
||||
expires_at: string;
|
||||
}>({ name: '', scopes: new Set(), app_id: '', expires_at: '' });
|
||||
let mintPending = $state(false);
|
||||
let mintError = $state<string | null>(null);
|
||||
|
||||
let reveal = $state<MintApiKeyResponse | null>(null);
|
||||
let revealAck = $state(false);
|
||||
let copyState = $state<'idle' | 'copied'>('idle');
|
||||
|
||||
let revokeTarget = $state<ApiKeyDto | null>(null);
|
||||
let revokePending = $state(false);
|
||||
|
||||
const NAME_MAX = 64;
|
||||
const scopeIsInstance = (s: Scope) => isInstanceScope(s);
|
||||
const boundToApp = $derived(mintForm.app_id !== '');
|
||||
|
||||
const canSubmit = $derived(
|
||||
mintForm.name.trim().length > 0 &&
|
||||
mintForm.name.trim().length <= NAME_MAX &&
|
||||
mintForm.scopes.size > 0 &&
|
||||
!mintPending
|
||||
);
|
||||
|
||||
onMount(async () => {
|
||||
await Promise.all([refreshKeys(), loadApps()]);
|
||||
});
|
||||
|
||||
async function refreshKeys() {
|
||||
try {
|
||||
keys = await api.apiKeys.list();
|
||||
loadError = null;
|
||||
} catch (e) {
|
||||
loadError = e instanceof ApiError ? e.message : 'failed to load API keys';
|
||||
}
|
||||
}
|
||||
|
||||
async function loadApps() {
|
||||
try {
|
||||
apps = await api.apps.list();
|
||||
} catch {
|
||||
// Non-fatal: the form falls back to "no app options" and the
|
||||
// list shows the bare UUID in the binding column.
|
||||
apps = [];
|
||||
}
|
||||
}
|
||||
|
||||
function flash(kind: 'error' | 'info', message: string) {
|
||||
banner = { kind, message };
|
||||
setTimeout(() => {
|
||||
if (banner?.message === message) banner = null;
|
||||
}, 6000);
|
||||
}
|
||||
|
||||
function openMint() {
|
||||
mintForm = { name: '', scopes: new Set(), app_id: '', expires_at: '' };
|
||||
mintError = null;
|
||||
mintOpen = true;
|
||||
}
|
||||
|
||||
function cancelMint() {
|
||||
mintOpen = false;
|
||||
mintError = null;
|
||||
}
|
||||
|
||||
function toggleScope(s: Scope) {
|
||||
const next = new Set(mintForm.scopes);
|
||||
if (next.has(s)) next.delete(s);
|
||||
else next.add(s);
|
||||
mintForm = { ...mintForm, scopes: next };
|
||||
}
|
||||
|
||||
// When the user binds the key to an app, instance:* scopes are
|
||||
// mutually exclusive — drop them from the selection so submit
|
||||
// doesn't 422.
|
||||
$effect(() => {
|
||||
if (!boundToApp) return;
|
||||
const filtered = new Set<Scope>();
|
||||
let dropped = false;
|
||||
for (const s of mintForm.scopes) {
|
||||
if (scopeIsInstance(s)) dropped = true;
|
||||
else filtered.add(s);
|
||||
}
|
||||
if (dropped) {
|
||||
mintForm = { ...mintForm, scopes: filtered };
|
||||
}
|
||||
});
|
||||
|
||||
async function submitMint(event: SubmitEvent) {
|
||||
event.preventDefault();
|
||||
if (!canSubmit) return;
|
||||
mintPending = true;
|
||||
mintError = null;
|
||||
try {
|
||||
const r = await api.apiKeys.mint({
|
||||
name: mintForm.name.trim(),
|
||||
scopes: Array.from(mintForm.scopes),
|
||||
app_id: mintForm.app_id === '' ? null : mintForm.app_id,
|
||||
expires_at: mintForm.expires_at === ''
|
||||
? null
|
||||
: new Date(mintForm.expires_at + 'T23:59:59Z').toISOString()
|
||||
});
|
||||
reveal = r;
|
||||
revealAck = false;
|
||||
copyState = 'idle';
|
||||
mintOpen = false;
|
||||
await refreshKeys();
|
||||
} catch (e) {
|
||||
mintError = e instanceof ApiError ? e.message : 'failed to mint API key';
|
||||
} finally {
|
||||
mintPending = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function copyToken() {
|
||||
if (!reveal) return;
|
||||
try {
|
||||
await navigator.clipboard.writeText(reveal.raw_token);
|
||||
copyState = 'copied';
|
||||
setTimeout(() => (copyState = 'idle'), 2000);
|
||||
} catch {
|
||||
flash('error', 'Clipboard write failed — select and copy manually.');
|
||||
}
|
||||
}
|
||||
|
||||
function dismissReveal() {
|
||||
reveal = null;
|
||||
revealAck = false;
|
||||
}
|
||||
|
||||
function openRevoke(key: ApiKeyDto) {
|
||||
revokeTarget = key;
|
||||
}
|
||||
|
||||
async function confirmRevoke() {
|
||||
if (!revokeTarget) return;
|
||||
revokePending = true;
|
||||
const target = revokeTarget;
|
||||
try {
|
||||
await api.apiKeys.revoke(target.id);
|
||||
revokeTarget = null;
|
||||
keys = keys.filter((k) => k.id !== target.id);
|
||||
flash('info', `Revoked "${target.name}".`);
|
||||
} catch (e) {
|
||||
flash('error', e instanceof ApiError ? e.message : 'failed to revoke key');
|
||||
} finally {
|
||||
revokePending = false;
|
||||
}
|
||||
}
|
||||
|
||||
function appLabel(app_id: string | null): string {
|
||||
if (!app_id) return 'Instance-wide';
|
||||
const a = appBySlug.get(app_id);
|
||||
return a ? a.slug : app_id.slice(0, 8) + '…';
|
||||
}
|
||||
|
||||
function shortDate(iso: string | null): string {
|
||||
if (!iso) return '—';
|
||||
return new Date(iso).toISOString().slice(0, 10);
|
||||
}
|
||||
|
||||
function relative(iso: string | null): string {
|
||||
if (!iso) return 'Never';
|
||||
const then = new Date(iso).getTime();
|
||||
const sec = Math.round((Date.now() - then) / 1000);
|
||||
if (sec < 60) return `${sec}s ago`;
|
||||
const min = Math.round(sec / 60);
|
||||
if (min < 60) return `${min}m ago`;
|
||||
const hr = Math.round(min / 60);
|
||||
if (hr < 24) return `${hr}h ago`;
|
||||
const day = Math.round(hr / 24);
|
||||
if (day < 7) return `${day}d ago`;
|
||||
return shortDate(iso);
|
||||
}
|
||||
</script>
|
||||
|
||||
{#if me}
|
||||
<section class="identity">
|
||||
<div class="identity-head">
|
||||
<h1>{me.username}</h1>
|
||||
<RoleChip role={me.instance_role} />
|
||||
</div>
|
||||
<dl class="identity-meta">
|
||||
<div>
|
||||
<dt>Email</dt>
|
||||
<dd>{me.email ?? 'No email set'}</dd>
|
||||
</div>
|
||||
<div>
|
||||
<dt>User ID</dt>
|
||||
<dd class="mono">{me.id}</dd>
|
||||
</div>
|
||||
</dl>
|
||||
</section>
|
||||
{/if}
|
||||
|
||||
{#if deniedFromUsers}
|
||||
<div class="banner banner-info">
|
||||
You don't have access to the Users page. Ask an admin if you need to manage users.
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
{#if banner}
|
||||
<div class="banner banner-{banner.kind}">{banner.message}</div>
|
||||
{/if}
|
||||
|
||||
<section class="keys-section">
|
||||
<header class="section-head">
|
||||
<h2>API keys</h2>
|
||||
{#if !mintOpen && !reveal}
|
||||
<button type="button" class="primary" onclick={openMint}>+ Mint API key</button>
|
||||
{/if}
|
||||
</header>
|
||||
|
||||
{#if reveal}
|
||||
<div class="reveal">
|
||||
<h3>Save this token now — it will never be shown again.</h3>
|
||||
<p class="reveal-sub">
|
||||
Paste it into your CLI config or external integration. PiCloud only ever stores a hash; if
|
||||
you lose it, mint a new one.
|
||||
</p>
|
||||
<div class="token-row">
|
||||
<code class="token">{reveal.raw_token}</code>
|
||||
<button type="button" class="ghost" onclick={copyToken}>
|
||||
{copyState === 'copied' ? 'Copied ✓' : 'Copy'}
|
||||
</button>
|
||||
</div>
|
||||
<label class="ack">
|
||||
<input type="checkbox" bind:checked={revealAck} />
|
||||
<span>I've saved this token somewhere safe.</span>
|
||||
</label>
|
||||
<div class="reveal-actions">
|
||||
<button type="button" class="primary" disabled={!revealAck} onclick={dismissReveal}>
|
||||
Done
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
{#if mintOpen}
|
||||
<form class="mint" onsubmit={submitMint}>
|
||||
<div class="form-row">
|
||||
<label class="field">
|
||||
<span>Name</span>
|
||||
<input
|
||||
type="text"
|
||||
bind:value={mintForm.name}
|
||||
maxlength={NAME_MAX}
|
||||
autocomplete="off"
|
||||
placeholder="e.g. ci-deploy"
|
||||
required
|
||||
/>
|
||||
<small>1–{NAME_MAX} chars. Only you see it.</small>
|
||||
</label>
|
||||
|
||||
<label class="field">
|
||||
<span>Binding</span>
|
||||
<select bind:value={mintForm.app_id}>
|
||||
<option value="">Instance-wide</option>
|
||||
{#each apps as a (a.id)}
|
||||
<option value={a.id}>{a.slug} ({a.name})</option>
|
||||
{/each}
|
||||
</select>
|
||||
<small>Pick an app to scope this key, or leave instance-wide.</small>
|
||||
</label>
|
||||
|
||||
<label class="field">
|
||||
<span>Expires</span>
|
||||
<input type="date" bind:value={mintForm.expires_at} />
|
||||
<small>Leave blank for no expiry.</small>
|
||||
</label>
|
||||
</div>
|
||||
|
||||
<fieldset class="scopes">
|
||||
<legend>Scopes</legend>
|
||||
<div class="scope-grid">
|
||||
{#each ALL_SCOPES as scope (scope)}
|
||||
{@const instanceScope = scopeIsInstance(scope)}
|
||||
{@const disabled = boundToApp && instanceScope}
|
||||
<label
|
||||
class="scope-chip"
|
||||
class:disabled
|
||||
title={disabled ? "Bound keys can't carry instance scopes" : undefined}
|
||||
>
|
||||
<input
|
||||
type="checkbox"
|
||||
checked={mintForm.scopes.has(scope)}
|
||||
disabled={disabled || mintPending}
|
||||
onchange={() => toggleScope(scope)}
|
||||
/>
|
||||
<span class="scope-name">{scope}</span>
|
||||
</label>
|
||||
{/each}
|
||||
</div>
|
||||
<small class="scope-hint">
|
||||
{mintForm.scopes.size === 0
|
||||
? 'Pick at least one scope.'
|
||||
: `${mintForm.scopes.size} scope${mintForm.scopes.size === 1 ? '' : 's'} selected.`}
|
||||
</small>
|
||||
</fieldset>
|
||||
|
||||
{#if mintError}
|
||||
<div class="error">{mintError}</div>
|
||||
{/if}
|
||||
|
||||
<div class="form-actions">
|
||||
<button type="button" class="ghost" onclick={cancelMint}>Cancel</button>
|
||||
<button type="submit" class="primary" disabled={!canSubmit}>
|
||||
{mintPending ? 'Minting…' : 'Mint key'}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
{/if}
|
||||
|
||||
{#if loadError}
|
||||
<div class="error">
|
||||
{loadError}
|
||||
<button type="button" class="retry" onclick={refreshKeys}>Retry</button>
|
||||
</div>
|
||||
{:else if keys.length === 0 && !reveal && !mintOpen}
|
||||
<p class="empty">
|
||||
No API keys yet. Mint one to authenticate the CLI or external integrations.
|
||||
</p>
|
||||
{:else if keys.length > 0}
|
||||
<div class="table">
|
||||
<div class="row head-row">
|
||||
<div>Name</div>
|
||||
<div>Prefix</div>
|
||||
<div>Scopes</div>
|
||||
<div>Binding</div>
|
||||
<div>Created</div>
|
||||
<div>Last used</div>
|
||||
<div>Expires</div>
|
||||
<div class="actions-col"></div>
|
||||
</div>
|
||||
{#each keys as key (key.id)}
|
||||
<div class="row">
|
||||
<div class="name-cell">{key.name}</div>
|
||||
<div class="mono prefix">pic_{key.prefix}…</div>
|
||||
<div class="scopes-cell">
|
||||
{#each key.scopes as s (s)}
|
||||
<span class="scope-pill">{s}</span>
|
||||
{/each}
|
||||
</div>
|
||||
<div>{appLabel(key.app_id)}</div>
|
||||
<div>{shortDate(key.created_at)}</div>
|
||||
<div title={key.last_used_at ?? ''}>{relative(key.last_used_at)}</div>
|
||||
<div>{key.expires_at ? shortDate(key.expires_at) : 'Never'}</div>
|
||||
<div class="actions-col">
|
||||
<button
|
||||
type="button"
|
||||
class="danger-link"
|
||||
onclick={() => openRevoke(key)}
|
||||
aria-label="Revoke {key.name}"
|
||||
>
|
||||
Revoke
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
{/each}
|
||||
</div>
|
||||
{/if}
|
||||
</section>
|
||||
|
||||
{#if revokeTarget}
|
||||
<ConfirmModal
|
||||
title="Revoke API key?"
|
||||
variant="danger"
|
||||
confirmLabel="Revoke"
|
||||
busy={revokePending}
|
||||
busyLabel="Revoking…"
|
||||
onConfirm={confirmRevoke}
|
||||
onCancel={() => (revokeTarget = null)}
|
||||
>
|
||||
<p>
|
||||
Revoking <strong>{revokeTarget.name}</strong> (<code>{revokeTarget.prefix}</code>) takes
|
||||
effect immediately. Any CLI or integration using it will start returning <code>401</code>
|
||||
on the next request.
|
||||
</p>
|
||||
<p class="muted">This can't be undone — mint a new key if you need one again.</p>
|
||||
</ConfirmModal>
|
||||
{/if}
|
||||
|
||||
<style>
|
||||
.identity {
|
||||
background: #0b1220;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
padding: 1.25rem 1.5rem;
|
||||
margin-bottom: 1.5rem;
|
||||
}
|
||||
.identity-head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.75rem;
|
||||
margin-bottom: 0.75rem;
|
||||
}
|
||||
.identity h1 {
|
||||
margin: 0;
|
||||
font-size: 1.25rem;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
.identity-meta {
|
||||
display: grid;
|
||||
grid-template-columns: repeat(auto-fit, minmax(14rem, 1fr));
|
||||
gap: 0.75rem 1.5rem;
|
||||
margin: 0;
|
||||
}
|
||||
.identity-meta div {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.15rem;
|
||||
}
|
||||
.identity-meta dt {
|
||||
color: #64748b;
|
||||
font-size: 0.7rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
}
|
||||
.identity-meta dd {
|
||||
margin: 0;
|
||||
color: #cbd5e1;
|
||||
font-size: 0.9rem;
|
||||
}
|
||||
|
||||
.banner {
|
||||
padding: 0.55rem 0.85rem;
|
||||
border-radius: 0.375rem;
|
||||
margin-bottom: 1rem;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.banner-error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
}
|
||||
.banner-info {
|
||||
background: #0c2a36;
|
||||
border: 1px solid #155e75;
|
||||
color: #a5f3fc;
|
||||
}
|
||||
|
||||
.section-head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
margin-bottom: 1rem;
|
||||
}
|
||||
.section-head h2 {
|
||||
margin: 0;
|
||||
font-size: 1.05rem;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.reveal {
|
||||
background: #0b1220;
|
||||
border: 1px solid #ca8a04;
|
||||
border-radius: 0.5rem;
|
||||
padding: 1.25rem 1.5rem;
|
||||
margin-bottom: 1.25rem;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.75rem;
|
||||
}
|
||||
.reveal h3 {
|
||||
margin: 0;
|
||||
font-size: 0.95rem;
|
||||
color: #fbbf24;
|
||||
}
|
||||
.reveal-sub {
|
||||
margin: 0;
|
||||
color: #cbd5e1;
|
||||
font-size: 0.85rem;
|
||||
line-height: 1.4;
|
||||
}
|
||||
.token-row {
|
||||
display: flex;
|
||||
align-items: stretch;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
.token {
|
||||
flex: 1;
|
||||
background: #020617;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.6rem 0.75rem;
|
||||
color: #e2e8f0;
|
||||
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||
font-size: 0.85rem;
|
||||
overflow-x: auto;
|
||||
white-space: nowrap;
|
||||
}
|
||||
.ack {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.5rem;
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
cursor: pointer;
|
||||
}
|
||||
.reveal-actions {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
|
||||
.mint {
|
||||
background: #0b1220;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
padding: 1.25rem 1.5rem;
|
||||
margin-bottom: 1.5rem;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 1rem;
|
||||
}
|
||||
.form-row {
|
||||
display: grid;
|
||||
grid-template-columns: repeat(auto-fit, minmax(12rem, 1fr));
|
||||
gap: 1rem;
|
||||
}
|
||||
.field {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.3rem;
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
}
|
||||
.field input,
|
||||
.field select {
|
||||
background: #0f172a;
|
||||
color: #e2e8f0;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.5rem 0.7rem;
|
||||
font-size: 0.9rem;
|
||||
}
|
||||
.field input:focus,
|
||||
.field select:focus {
|
||||
outline: none;
|
||||
border-color: #38bdf8;
|
||||
}
|
||||
.field small {
|
||||
color: #64748b;
|
||||
font-size: 0.72rem;
|
||||
}
|
||||
|
||||
.scopes {
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.75rem 0.85rem;
|
||||
color: #cbd5e1;
|
||||
}
|
||||
.scopes legend {
|
||||
font-size: 0.75rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
color: #94a3b8;
|
||||
padding: 0 0.4rem;
|
||||
}
|
||||
.scope-grid {
|
||||
display: grid;
|
||||
grid-template-columns: repeat(auto-fit, minmax(11rem, 1fr));
|
||||
gap: 0.4rem 0.75rem;
|
||||
margin-top: 0.25rem;
|
||||
}
|
||||
.scope-chip {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.4rem;
|
||||
font-size: 0.85rem;
|
||||
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||
cursor: pointer;
|
||||
}
|
||||
.scope-chip.disabled {
|
||||
opacity: 0.45;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
.scope-hint {
|
||||
display: block;
|
||||
margin-top: 0.55rem;
|
||||
font-size: 0.75rem;
|
||||
color: #64748b;
|
||||
}
|
||||
|
||||
.form-actions {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
|
||||
.error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.55rem 0.8rem;
|
||||
border-radius: 0.375rem;
|
||||
font-size: 0.85rem;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
gap: 1rem;
|
||||
margin-top: 0.25rem;
|
||||
}
|
||||
.retry {
|
||||
background: transparent;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.2rem 0.55rem;
|
||||
border-radius: 0.25rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.75rem;
|
||||
}
|
||||
|
||||
.empty {
|
||||
color: #64748b;
|
||||
text-align: center;
|
||||
padding: 2.5rem 0;
|
||||
border: 1px dashed #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
}
|
||||
|
||||
.table {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
background: #0b1220;
|
||||
overflow: hidden;
|
||||
}
|
||||
.row {
|
||||
display: grid;
|
||||
grid-template-columns: 1.3fr 0.9fr 2fr 1fr 0.8fr 0.8fr 0.8fr 0.7fr;
|
||||
align-items: center;
|
||||
gap: 0.75rem;
|
||||
padding: 0.7rem 1rem;
|
||||
border-bottom: 1px solid #1e293b;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.row:last-child {
|
||||
border-bottom: none;
|
||||
}
|
||||
.head-row {
|
||||
color: #94a3b8;
|
||||
font-size: 0.7rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
background: #0f172a;
|
||||
}
|
||||
.name-cell {
|
||||
color: #e2e8f0;
|
||||
font-weight: 500;
|
||||
}
|
||||
.mono {
|
||||
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||
}
|
||||
.prefix {
|
||||
color: #94a3b8;
|
||||
}
|
||||
.scopes-cell {
|
||||
display: flex;
|
||||
flex-wrap: wrap;
|
||||
gap: 0.25rem;
|
||||
}
|
||||
.scope-pill {
|
||||
background: #1e293b;
|
||||
color: #cbd5e1;
|
||||
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||
font-size: 0.7rem;
|
||||
padding: 0.1rem 0.4rem;
|
||||
border-radius: 0.25rem;
|
||||
}
|
||||
.actions-col {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
.danger-link {
|
||||
background: transparent;
|
||||
color: #fca5a5;
|
||||
border: none;
|
||||
font-size: 0.8rem;
|
||||
cursor: pointer;
|
||||
padding: 0.2rem 0.4rem;
|
||||
border-radius: 0.25rem;
|
||||
}
|
||||
.danger-link:hover {
|
||||
background: #450a0a;
|
||||
color: #fecaca;
|
||||
}
|
||||
|
||||
button.primary {
|
||||
background: #38bdf8;
|
||||
color: #0b1220;
|
||||
border: none;
|
||||
padding: 0.5rem 0.9rem;
|
||||
border-radius: 0.375rem;
|
||||
font-weight: 600;
|
||||
cursor: pointer;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
button.primary:disabled {
|
||||
opacity: 0.6;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
button.ghost {
|
||||
background: transparent;
|
||||
color: #94a3b8;
|
||||
border: 1px solid #334155;
|
||||
padding: 0.45rem 0.85rem;
|
||||
border-radius: 0.375rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
button.ghost:hover {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.muted {
|
||||
color: #94a3b8;
|
||||
}
|
||||
</style>
|
||||
937
dashboard/src/routes/users/+page.svelte
Normal file
937
dashboard/src/routes/users/+page.svelte
Normal file
@@ -0,0 +1,937 @@
|
||||
<!--
|
||||
/admin/users — owner + admin only. Members get bounced to /profile
|
||||
with ?denied=users. Replaces the pre-3.5 /admin/admins page; this
|
||||
one knows about roles, email, and the last-owner/last-admin guards.
|
||||
-->
|
||||
<script lang="ts">
|
||||
import { onMount } from 'svelte';
|
||||
import { goto } from '$app/navigation';
|
||||
import { base } from '$app/paths';
|
||||
import {
|
||||
api,
|
||||
ApiError,
|
||||
type AdminDto,
|
||||
type InstanceRole
|
||||
} from '$lib/api';
|
||||
import { currentUser } from '$lib/auth';
|
||||
import RoleChip from '$lib/RoleChip.svelte';
|
||||
import ConfirmModal from '$lib/ConfirmModal.svelte';
|
||||
import ActionMenu from '$lib/ActionMenu.svelte';
|
||||
import { generatePassword } from '$lib/password-gen';
|
||||
|
||||
const me = $derived($currentUser);
|
||||
const myRole = $derived(me?.instance_role);
|
||||
const isOwner = $derived(myRole === 'owner');
|
||||
|
||||
// Member guard. The backend already 403s the list call, but
|
||||
// surfacing a friendly redirect avoids the dead-end empty page.
|
||||
$effect(() => {
|
||||
if (me && me.instance_role === 'member') {
|
||||
void goto(`${base}/profile?denied=users`);
|
||||
}
|
||||
});
|
||||
|
||||
let admins = $state<AdminDto[]>([]);
|
||||
let loadError = $state<string | null>(null);
|
||||
let banner = $state<{ kind: 'error' | 'info'; message: string } | null>(null);
|
||||
|
||||
let search = $state('');
|
||||
const filtered = $derived(
|
||||
(() => {
|
||||
const q = search.trim().toLowerCase();
|
||||
if (!q) return admins;
|
||||
return admins.filter(
|
||||
(a) =>
|
||||
a.username.toLowerCase().includes(q) ||
|
||||
(a.email ?? '').toLowerCase().includes(q)
|
||||
);
|
||||
})()
|
||||
);
|
||||
|
||||
// Invite (create) modal --------------------------------------------------
|
||||
let inviteOpen = $state(false);
|
||||
let inviteForm = $state<{ username: string; email: string; instance_role: 'admin' | 'member' }>({
|
||||
username: '',
|
||||
email: '',
|
||||
instance_role: 'admin'
|
||||
});
|
||||
let invitePending = $state(false);
|
||||
let inviteError = $state<string | null>(null);
|
||||
|
||||
// One-time password reveal (used by both invite + reset)
|
||||
let revealPassword = $state<string | null>(null);
|
||||
let revealForUsername = $state<string>('');
|
||||
let revealKind = $state<'invite' | 'reset'>('invite');
|
||||
let revealAck = $state(false);
|
||||
let copyState = $state<'idle' | 'copied'>('idle');
|
||||
|
||||
// Edit modal -------------------------------------------------------------
|
||||
let editTarget = $state<AdminDto | null>(null);
|
||||
let editForm = $state<{
|
||||
username: string;
|
||||
email: string;
|
||||
instance_role: InstanceRole;
|
||||
}>({ username: '', email: '', instance_role: 'admin' });
|
||||
let editPending = $state(false);
|
||||
let editError = $state<string | null>(null);
|
||||
|
||||
// Delete modal -----------------------------------------------------------
|
||||
let deleteTarget = $state<AdminDto | null>(null);
|
||||
let deletePending = $state(false);
|
||||
|
||||
// Validation rules (mirror backend: 2-32, [a-z0-9._-]) -------------------
|
||||
const USERNAME_RE = /^[a-z0-9._-]{2,32}$/;
|
||||
const EMAIL_RE = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
|
||||
|
||||
const inviteUsernameValid = $derived(USERNAME_RE.test(inviteForm.username));
|
||||
const inviteEmailValid = $derived(
|
||||
inviteForm.email.trim() === '' || EMAIL_RE.test(inviteForm.email.trim())
|
||||
);
|
||||
const canInvite = $derived(inviteUsernameValid && inviteEmailValid && !invitePending);
|
||||
|
||||
const editUsernameValid = $derived(USERNAME_RE.test(editForm.username));
|
||||
const editEmailValid = $derived(
|
||||
editForm.email.trim() === '' || EMAIL_RE.test(editForm.email.trim())
|
||||
);
|
||||
const canSubmitEdit = $derived(editUsernameValid && editEmailValid && !editPending);
|
||||
|
||||
// Admin (non-owner) cannot touch owner rows for delete or role demote.
|
||||
function canDelete(row: AdminDto): boolean {
|
||||
if (isOwner) return true;
|
||||
return row.instance_role !== 'owner';
|
||||
}
|
||||
|
||||
const editRoleOptions = $derived<InstanceRole[]>(
|
||||
isOwner ? ['owner', 'admin', 'member'] : ['admin', 'member']
|
||||
);
|
||||
|
||||
onMount(refresh);
|
||||
|
||||
async function refresh() {
|
||||
loadError = null;
|
||||
try {
|
||||
admins = await api.admins.list();
|
||||
} catch (e) {
|
||||
loadError = e instanceof ApiError ? e.message : 'failed to load users';
|
||||
}
|
||||
}
|
||||
|
||||
function flash(kind: 'error' | 'info', message: string) {
|
||||
banner = { kind, message };
|
||||
setTimeout(() => {
|
||||
if (banner?.message === message) banner = null;
|
||||
}, 6000);
|
||||
}
|
||||
|
||||
function openInvite() {
|
||||
inviteForm = { username: '', email: '', instance_role: 'admin' };
|
||||
inviteError = null;
|
||||
inviteOpen = true;
|
||||
}
|
||||
|
||||
async function submitInvite(event: SubmitEvent) {
|
||||
event.preventDefault();
|
||||
if (!canInvite) return;
|
||||
invitePending = true;
|
||||
inviteError = null;
|
||||
const password = generatePassword(16);
|
||||
try {
|
||||
const created = await api.admins.create({
|
||||
username: inviteForm.username,
|
||||
password,
|
||||
instance_role: inviteForm.instance_role,
|
||||
email: inviteForm.email.trim() === '' ? null : inviteForm.email.trim()
|
||||
});
|
||||
admins = [...admins, created].sort((a, b) => a.username.localeCompare(b.username));
|
||||
inviteOpen = false;
|
||||
revealPassword = password;
|
||||
revealForUsername = created.username;
|
||||
revealKind = 'invite';
|
||||
revealAck = false;
|
||||
copyState = 'idle';
|
||||
} catch (e) {
|
||||
inviteError = e instanceof ApiError ? e.message : 'failed to create user';
|
||||
} finally {
|
||||
invitePending = false;
|
||||
}
|
||||
}
|
||||
|
||||
function openEdit(row: AdminDto) {
|
||||
editTarget = row;
|
||||
editForm = {
|
||||
username: row.username,
|
||||
email: row.email ?? '',
|
||||
instance_role: row.instance_role
|
||||
};
|
||||
editError = null;
|
||||
}
|
||||
|
||||
async function submitEdit(event: SubmitEvent) {
|
||||
event.preventDefault();
|
||||
if (!editTarget || !canSubmitEdit) return;
|
||||
editPending = true;
|
||||
editError = null;
|
||||
const patch: {
|
||||
username?: string;
|
||||
email?: string | null;
|
||||
instance_role?: InstanceRole;
|
||||
} = {};
|
||||
if (editForm.username !== editTarget.username) patch.username = editForm.username;
|
||||
if ((editTarget.email ?? '') !== editForm.email.trim()) {
|
||||
patch.email = editForm.email.trim() === '' ? null : editForm.email.trim();
|
||||
}
|
||||
if (editForm.instance_role !== editTarget.instance_role) {
|
||||
patch.instance_role = editForm.instance_role;
|
||||
}
|
||||
try {
|
||||
const updated = await api.admins.update(editTarget.id, patch);
|
||||
admins = admins
|
||||
.map((a) => (a.id === updated.id ? updated : a))
|
||||
.sort((a, b) => a.username.localeCompare(b.username));
|
||||
const name = updated.username;
|
||||
editTarget = null;
|
||||
flash('info', `Updated "${name}".`);
|
||||
} catch (e) {
|
||||
editError = e instanceof ApiError ? e.message : 'failed to update user';
|
||||
} finally {
|
||||
editPending = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function resetPassword() {
|
||||
if (!editTarget) return;
|
||||
const target = editTarget;
|
||||
const password = generatePassword(16);
|
||||
editPending = true;
|
||||
editError = null;
|
||||
try {
|
||||
await api.admins.update(target.id, { password });
|
||||
editTarget = null;
|
||||
revealPassword = password;
|
||||
revealForUsername = target.username;
|
||||
revealKind = 'reset';
|
||||
revealAck = false;
|
||||
copyState = 'idle';
|
||||
} catch (e) {
|
||||
editError = e instanceof ApiError ? e.message : 'failed to reset password';
|
||||
} finally {
|
||||
editPending = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function toggleActive(row: AdminDto) {
|
||||
try {
|
||||
const updated = await api.admins.update(row.id, { is_active: !row.is_active });
|
||||
admins = admins.map((a) => (a.id === updated.id ? updated : a));
|
||||
flash(
|
||||
'info',
|
||||
`${updated.username} ${updated.is_active ? 'reactivated' : 'deactivated'}.`
|
||||
);
|
||||
} catch (e) {
|
||||
flash('error', e instanceof ApiError ? e.message : 'failed to update user');
|
||||
}
|
||||
}
|
||||
|
||||
function openDelete(row: AdminDto) {
|
||||
deleteTarget = row;
|
||||
}
|
||||
|
||||
async function confirmDelete() {
|
||||
if (!deleteTarget) return;
|
||||
deletePending = true;
|
||||
const target = deleteTarget;
|
||||
try {
|
||||
await api.admins.remove(target.id);
|
||||
deleteTarget = null;
|
||||
if (me && me.id === target.id) {
|
||||
// Self-delete: bail out to login.
|
||||
await api.auth.logout();
|
||||
await goto(`${base}/login`);
|
||||
return;
|
||||
}
|
||||
admins = admins.filter((a) => a.id !== target.id);
|
||||
flash('info', `Deleted "${target.username}".`);
|
||||
} catch (e) {
|
||||
flash('error', e instanceof ApiError ? e.message : 'failed to delete user');
|
||||
} finally {
|
||||
deletePending = false;
|
||||
}
|
||||
}
|
||||
|
||||
async function copyPassword() {
|
||||
if (!revealPassword) return;
|
||||
try {
|
||||
await navigator.clipboard.writeText(revealPassword);
|
||||
copyState = 'copied';
|
||||
setTimeout(() => (copyState = 'idle'), 2000);
|
||||
} catch {
|
||||
flash('error', 'Clipboard write failed — select and copy manually.');
|
||||
}
|
||||
}
|
||||
|
||||
function dismissReveal() {
|
||||
revealPassword = null;
|
||||
revealAck = false;
|
||||
}
|
||||
|
||||
function relative(iso: string | null): string {
|
||||
if (!iso) return 'Never';
|
||||
const sec = Math.round((Date.now() - new Date(iso).getTime()) / 1000);
|
||||
if (sec < 60) return `${sec}s ago`;
|
||||
const min = Math.round(sec / 60);
|
||||
if (min < 60) return `${min}m ago`;
|
||||
const hr = Math.round(min / 60);
|
||||
if (hr < 24) return `${hr}h ago`;
|
||||
const day = Math.round(hr / 24);
|
||||
if (day < 7) return `${day}d ago`;
|
||||
return new Date(iso).toISOString().slice(0, 10);
|
||||
}
|
||||
|
||||
function shortDate(iso: string): string {
|
||||
return new Date(iso).toISOString().slice(0, 10);
|
||||
}
|
||||
</script>
|
||||
|
||||
<header class="head">
|
||||
<h1>Users</h1>
|
||||
<div class="head-controls">
|
||||
<input
|
||||
type="search"
|
||||
placeholder="Search by username or email…"
|
||||
bind:value={search}
|
||||
class="search"
|
||||
/>
|
||||
<button type="button" class="primary" onclick={openInvite}>+ Invite user</button>
|
||||
</div>
|
||||
</header>
|
||||
|
||||
{#if banner}
|
||||
<div class="banner banner-{banner.kind}">{banner.message}</div>
|
||||
{/if}
|
||||
|
||||
{#if loadError}
|
||||
<div class="error">
|
||||
{loadError}
|
||||
<button type="button" class="retry" onclick={refresh}>Retry</button>
|
||||
</div>
|
||||
{:else if admins.length === 0}
|
||||
<p class="empty">No users yet. Invite one to get started.</p>
|
||||
{:else}
|
||||
<div class="table">
|
||||
<div class="row head-row">
|
||||
<div>Username</div>
|
||||
<div>Role</div>
|
||||
<div>Email</div>
|
||||
<div>Status</div>
|
||||
<div>Created</div>
|
||||
<div>Last login</div>
|
||||
<div class="actions-col"></div>
|
||||
</div>
|
||||
{#each filtered as row (row.id)}
|
||||
<div class="row">
|
||||
<div class="name-cell">
|
||||
<span class="name">{row.username}</span>
|
||||
{#if me && me.id === row.id}
|
||||
<span class="you-tag">(you)</span>
|
||||
{/if}
|
||||
</div>
|
||||
<div><RoleChip role={row.instance_role} size="sm" /></div>
|
||||
<div class="email-cell">{row.email ?? '—'}</div>
|
||||
<div>
|
||||
{#if row.is_active}
|
||||
<span class="status status-active">● Active</span>
|
||||
{:else}
|
||||
<span class="status status-inactive">○ Inactive</span>
|
||||
{/if}
|
||||
</div>
|
||||
<div>{shortDate(row.created_at)}</div>
|
||||
<div title={row.last_login_at ?? ''}>{relative(row.last_login_at)}</div>
|
||||
<div class="actions-col">
|
||||
<ActionMenu
|
||||
label="User actions for {row.username}"
|
||||
items={[
|
||||
{ label: 'Edit', onClick: () => openEdit(row) },
|
||||
{
|
||||
label: row.is_active ? 'Deactivate' : 'Reactivate',
|
||||
onClick: () => toggleActive(row)
|
||||
},
|
||||
{
|
||||
label: 'Delete',
|
||||
danger: true,
|
||||
disabled: !canDelete(row),
|
||||
onClick: () => openDelete(row)
|
||||
}
|
||||
]}
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
{/each}
|
||||
{#if filtered.length === 0 && admins.length > 0}
|
||||
<div class="row empty-row">No matches for "{search}".</div>
|
||||
{/if}
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Invite modal -->
|
||||
{#if inviteOpen}
|
||||
<div
|
||||
class="modal-backdrop"
|
||||
role="presentation"
|
||||
onclick={(e) => {
|
||||
if (e.target === e.currentTarget && !invitePending) inviteOpen = false;
|
||||
}}
|
||||
>
|
||||
<form class="modal" onsubmit={submitInvite}>
|
||||
<div class="modal-head">
|
||||
<h2>Invite user</h2>
|
||||
<button
|
||||
type="button"
|
||||
class="x"
|
||||
aria-label="Close"
|
||||
disabled={invitePending}
|
||||
onclick={() => (inviteOpen = false)}>✕</button
|
||||
>
|
||||
</div>
|
||||
<p class="modal-intro">
|
||||
A random password will be generated and shown to you exactly once. PiCloud cannot send
|
||||
email — copy and share through your own channel.
|
||||
</p>
|
||||
<label class="field">
|
||||
<span>Username</span>
|
||||
<input
|
||||
type="text"
|
||||
autocomplete="off"
|
||||
spellcheck="false"
|
||||
bind:value={inviteForm.username}
|
||||
required
|
||||
/>
|
||||
<small>2–32 chars. Lowercase letters, digits, <code>.</code> <code>_</code> <code>-</code>.</small>
|
||||
{#if inviteForm.username && !inviteUsernameValid}
|
||||
<small class="invalid">Doesn't match the allowed pattern.</small>
|
||||
{/if}
|
||||
</label>
|
||||
<label class="field">
|
||||
<span>Email <span class="opt">(optional)</span></span>
|
||||
<input
|
||||
type="email"
|
||||
autocomplete="off"
|
||||
spellcheck="false"
|
||||
bind:value={inviteForm.email}
|
||||
/>
|
||||
{#if !inviteEmailValid}
|
||||
<small class="invalid">Doesn't look like an email address.</small>
|
||||
{/if}
|
||||
</label>
|
||||
<fieldset class="field">
|
||||
<legend>Role</legend>
|
||||
<label class="radio">
|
||||
<input type="radio" bind:group={inviteForm.instance_role} value="admin" />
|
||||
<span>Admin — can manage users, scripts, and all apps.</span>
|
||||
</label>
|
||||
<label class="radio">
|
||||
<input type="radio" bind:group={inviteForm.instance_role} value="member" />
|
||||
<span>Member — only sees apps they're added to.</span>
|
||||
</label>
|
||||
<small>
|
||||
Owners can't be created here — promote via Edit after creation.
|
||||
</small>
|
||||
</fieldset>
|
||||
{#if inviteError}
|
||||
<div class="error">{inviteError}</div>
|
||||
{/if}
|
||||
<div class="modal-actions">
|
||||
<button type="button" class="ghost" onclick={() => (inviteOpen = false)} disabled={invitePending}>
|
||||
Cancel
|
||||
</button>
|
||||
<button type="submit" class="primary" disabled={!canInvite}>
|
||||
{invitePending ? 'Creating…' : 'Create user'}
|
||||
</button>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Edit modal -->
|
||||
{#if editTarget}
|
||||
{@const target = editTarget}
|
||||
<div
|
||||
class="modal-backdrop"
|
||||
role="presentation"
|
||||
onclick={(e) => {
|
||||
if (e.target === e.currentTarget && !editPending) editTarget = null;
|
||||
}}
|
||||
>
|
||||
<form class="modal" onsubmit={submitEdit}>
|
||||
<div class="modal-head">
|
||||
<h2>Edit {target.username}</h2>
|
||||
<button
|
||||
type="button"
|
||||
class="x"
|
||||
aria-label="Close"
|
||||
disabled={editPending}
|
||||
onclick={() => (editTarget = null)}>✕</button
|
||||
>
|
||||
</div>
|
||||
<label class="field">
|
||||
<span>Username</span>
|
||||
<input
|
||||
type="text"
|
||||
autocomplete="off"
|
||||
spellcheck="false"
|
||||
bind:value={editForm.username}
|
||||
required
|
||||
/>
|
||||
{#if editForm.username && !editUsernameValid}
|
||||
<small class="invalid">2–32 chars, lowercase + digits + . _ - only.</small>
|
||||
{/if}
|
||||
</label>
|
||||
<label class="field">
|
||||
<span>Email <span class="opt">(optional)</span></span>
|
||||
<input
|
||||
type="email"
|
||||
autocomplete="off"
|
||||
spellcheck="false"
|
||||
bind:value={editForm.email}
|
||||
/>
|
||||
{#if !editEmailValid}
|
||||
<small class="invalid">Doesn't look like an email address.</small>
|
||||
{/if}
|
||||
</label>
|
||||
<label class="field">
|
||||
<span>Role</span>
|
||||
<select bind:value={editForm.instance_role}>
|
||||
{#each editRoleOptions as r (r)}
|
||||
<option value={r}>{r}</option>
|
||||
{/each}
|
||||
</select>
|
||||
<small>
|
||||
{#if target.instance_role === 'owner' && !isOwner}
|
||||
Only owners can change another owner's role.
|
||||
{:else if !isOwner}
|
||||
Admins can grant admin or member; only owners can grant owner.
|
||||
{:else}
|
||||
The last active owner can't be demoted — the request will 422 if that's the case.
|
||||
{/if}
|
||||
</small>
|
||||
</label>
|
||||
{#if editError}
|
||||
<div class="error">{editError}</div>
|
||||
{/if}
|
||||
<div class="modal-actions split">
|
||||
<button type="button" class="ghost" onclick={resetPassword} disabled={editPending}>
|
||||
Reset password
|
||||
</button>
|
||||
<div class="modal-actions">
|
||||
<button
|
||||
type="button"
|
||||
class="ghost"
|
||||
onclick={() => (editTarget = null)}
|
||||
disabled={editPending}
|
||||
>
|
||||
Cancel
|
||||
</button>
|
||||
<button type="submit" class="primary" disabled={!canSubmitEdit}>
|
||||
{editPending ? 'Saving…' : 'Save'}
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Password reveal (post-invite or post-reset) -->
|
||||
{#if revealPassword}
|
||||
<div class="modal-backdrop" role="presentation">
|
||||
<div class="modal reveal-modal">
|
||||
<div class="modal-head">
|
||||
<h2>
|
||||
{revealKind === 'invite' ? 'User created' : 'Password reset'} — {revealForUsername}
|
||||
</h2>
|
||||
</div>
|
||||
<p class="banner banner-warn">
|
||||
Save this password now — it will never be shown again. PiCloud cannot send email yet,
|
||||
so copy it and share through your own channel.
|
||||
</p>
|
||||
<div class="token-row">
|
||||
<code class="token">{revealPassword}</code>
|
||||
<button type="button" class="ghost" onclick={copyPassword}>
|
||||
{copyState === 'copied' ? 'Copied ✓' : 'Copy'}
|
||||
</button>
|
||||
</div>
|
||||
<label class="ack">
|
||||
<input type="checkbox" bind:checked={revealAck} />
|
||||
<span>I've shared this with the user.</span>
|
||||
</label>
|
||||
<div class="modal-actions">
|
||||
<button type="button" class="primary" disabled={!revealAck} onclick={dismissReveal}>
|
||||
Done
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<!-- Delete confirmation -->
|
||||
{#if deleteTarget}
|
||||
{@const dt = deleteTarget}
|
||||
<ConfirmModal
|
||||
title="Delete user?"
|
||||
variant="danger"
|
||||
confirmLabel="Delete user"
|
||||
confirmPhrase={dt.username}
|
||||
confirmPhrasePrompt="Type the username to confirm:"
|
||||
busy={deletePending}
|
||||
busyLabel="Deleting…"
|
||||
onConfirm={confirmDelete}
|
||||
onCancel={() => (deleteTarget = null)}
|
||||
>
|
||||
{#if me && me.id === dt.id}
|
||||
<p>
|
||||
You're about to delete <strong>your own</strong> account. You'll be signed out
|
||||
immediately and won't be able to sign back in.
|
||||
</p>
|
||||
{:else}
|
||||
<p>
|
||||
This permanently removes <strong>{dt.username}</strong>, all their sessions, and all
|
||||
their API keys. This cannot be undone.
|
||||
</p>
|
||||
{/if}
|
||||
<p class="muted">
|
||||
If they're the only remaining owner or active admin the server will reject the request
|
||||
with a 422 — promote/activate someone else first.
|
||||
</p>
|
||||
</ConfirmModal>
|
||||
{/if}
|
||||
|
||||
<style>
|
||||
.head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
gap: 1rem;
|
||||
margin-bottom: 1.5rem;
|
||||
flex-wrap: wrap;
|
||||
}
|
||||
.head h1 {
|
||||
font-size: 1.25rem;
|
||||
margin: 0;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
.head-controls {
|
||||
display: flex;
|
||||
gap: 0.5rem;
|
||||
align-items: center;
|
||||
}
|
||||
.search {
|
||||
background: #0b1220;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.5rem 0.75rem;
|
||||
color: #e2e8f0;
|
||||
font-size: 0.85rem;
|
||||
min-width: 16rem;
|
||||
}
|
||||
.search:focus {
|
||||
outline: none;
|
||||
border-color: #38bdf8;
|
||||
}
|
||||
|
||||
.banner {
|
||||
padding: 0.55rem 0.85rem;
|
||||
border-radius: 0.375rem;
|
||||
margin-bottom: 1rem;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.banner-error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
}
|
||||
.banner-info {
|
||||
background: #0c2a36;
|
||||
border: 1px solid #155e75;
|
||||
color: #a5f3fc;
|
||||
}
|
||||
.banner-warn {
|
||||
background: #2a1d04;
|
||||
border: 1px solid #ca8a04;
|
||||
color: #fde68a;
|
||||
margin: 0;
|
||||
}
|
||||
|
||||
.empty {
|
||||
color: #64748b;
|
||||
text-align: center;
|
||||
padding: 2.5rem 0;
|
||||
border: 1px dashed #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
}
|
||||
|
||||
.table {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.5rem;
|
||||
background: #0b1220;
|
||||
overflow: visible;
|
||||
}
|
||||
.row {
|
||||
display: grid;
|
||||
grid-template-columns: 1.3fr 0.7fr 1.5fr 0.9fr 0.8fr 0.9fr 2.5rem;
|
||||
align-items: center;
|
||||
gap: 0.75rem;
|
||||
padding: 0.7rem 1rem;
|
||||
border-bottom: 1px solid #1e293b;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
.row:last-child {
|
||||
border-bottom: none;
|
||||
}
|
||||
.head-row {
|
||||
color: #94a3b8;
|
||||
font-size: 0.7rem;
|
||||
text-transform: uppercase;
|
||||
letter-spacing: 0.05em;
|
||||
background: #0f172a;
|
||||
}
|
||||
.empty-row {
|
||||
grid-column: 1 / -1;
|
||||
color: #64748b;
|
||||
text-align: center;
|
||||
padding: 1.25rem;
|
||||
}
|
||||
.name-cell {
|
||||
display: flex;
|
||||
align-items: baseline;
|
||||
gap: 0.4rem;
|
||||
}
|
||||
.name {
|
||||
color: #e2e8f0;
|
||||
font-weight: 500;
|
||||
}
|
||||
.you-tag {
|
||||
color: #64748b;
|
||||
font-size: 0.72rem;
|
||||
}
|
||||
.email-cell {
|
||||
color: #cbd5e1;
|
||||
font-size: 0.82rem;
|
||||
overflow: hidden;
|
||||
text-overflow: ellipsis;
|
||||
white-space: nowrap;
|
||||
}
|
||||
.status {
|
||||
font-size: 0.8rem;
|
||||
}
|
||||
.status-active {
|
||||
color: #34d399;
|
||||
}
|
||||
.status-inactive {
|
||||
color: #64748b;
|
||||
}
|
||||
.actions-col {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
}
|
||||
|
||||
button.primary {
|
||||
background: #38bdf8;
|
||||
color: #0b1220;
|
||||
border: none;
|
||||
padding: 0.5rem 0.9rem;
|
||||
border-radius: 0.375rem;
|
||||
font-weight: 600;
|
||||
cursor: pointer;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
button.primary:disabled {
|
||||
opacity: 0.6;
|
||||
cursor: not-allowed;
|
||||
}
|
||||
button.ghost {
|
||||
background: transparent;
|
||||
color: #94a3b8;
|
||||
border: 1px solid #334155;
|
||||
padding: 0.45rem 0.85rem;
|
||||
border-radius: 0.375rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.85rem;
|
||||
}
|
||||
button.ghost:hover {
|
||||
background: #1e293b;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
|
||||
.error {
|
||||
background: #450a0a;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.55rem 0.8rem;
|
||||
border-radius: 0.375rem;
|
||||
font-size: 0.85rem;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
gap: 1rem;
|
||||
}
|
||||
.retry {
|
||||
background: transparent;
|
||||
border: 1px solid #b91c1c;
|
||||
color: #fecaca;
|
||||
padding: 0.2rem 0.55rem;
|
||||
border-radius: 0.25rem;
|
||||
cursor: pointer;
|
||||
font-size: 0.75rem;
|
||||
}
|
||||
|
||||
.modal-backdrop {
|
||||
position: fixed;
|
||||
inset: 0;
|
||||
background: rgba(2, 6, 23, 0.7);
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: center;
|
||||
padding: 1rem;
|
||||
z-index: 50;
|
||||
}
|
||||
.modal {
|
||||
background: #0b1220;
|
||||
border: 1px solid #334155;
|
||||
border-radius: 0.5rem;
|
||||
padding: 1.5rem;
|
||||
width: 100%;
|
||||
max-width: 28rem;
|
||||
max-height: calc(100vh - 2rem);
|
||||
overflow-y: auto;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 1rem;
|
||||
box-shadow: 0 25px 50px -12px rgba(0, 0, 0, 0.7);
|
||||
}
|
||||
.reveal-modal {
|
||||
border-color: #ca8a04;
|
||||
}
|
||||
.modal-head {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
justify-content: space-between;
|
||||
}
|
||||
.modal h2 {
|
||||
margin: 0;
|
||||
font-size: 1rem;
|
||||
color: #e2e8f0;
|
||||
}
|
||||
.x {
|
||||
background: transparent;
|
||||
border: none;
|
||||
color: #64748b;
|
||||
font-size: 1.1rem;
|
||||
cursor: pointer;
|
||||
}
|
||||
.x:hover {
|
||||
color: #e2e8f0;
|
||||
}
|
||||
.modal-intro {
|
||||
margin: 0;
|
||||
font-size: 0.82rem;
|
||||
color: #94a3b8;
|
||||
line-height: 1.45;
|
||||
}
|
||||
.field {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.3rem;
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
border: none;
|
||||
padding: 0;
|
||||
margin: 0;
|
||||
}
|
||||
.field legend {
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
padding: 0;
|
||||
margin-bottom: 0.3rem;
|
||||
}
|
||||
.field input[type='text'],
|
||||
.field input[type='email'],
|
||||
.field select {
|
||||
background: #0f172a;
|
||||
color: #e2e8f0;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.5rem 0.7rem;
|
||||
font-size: 0.9rem;
|
||||
}
|
||||
.field input:focus,
|
||||
.field select:focus {
|
||||
outline: none;
|
||||
border-color: #38bdf8;
|
||||
}
|
||||
.field small {
|
||||
color: #64748b;
|
||||
font-size: 0.72rem;
|
||||
}
|
||||
.field small.invalid {
|
||||
color: #fca5a5;
|
||||
}
|
||||
.field small code {
|
||||
background: #1e293b;
|
||||
color: #cbd5e1;
|
||||
padding: 0 0.2rem;
|
||||
border-radius: 0.2rem;
|
||||
}
|
||||
.opt {
|
||||
color: #64748b;
|
||||
font-weight: 400;
|
||||
}
|
||||
|
||||
.radio {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.5rem;
|
||||
padding: 0.25rem 0;
|
||||
font-size: 0.82rem;
|
||||
color: #cbd5e1;
|
||||
}
|
||||
|
||||
|
||||
.token-row {
|
||||
display: flex;
|
||||
align-items: stretch;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
.token {
|
||||
flex: 1;
|
||||
background: #020617;
|
||||
border: 1px solid #1e293b;
|
||||
border-radius: 0.375rem;
|
||||
padding: 0.6rem 0.75rem;
|
||||
color: #e2e8f0;
|
||||
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||
font-size: 0.85rem;
|
||||
overflow-x: auto;
|
||||
white-space: nowrap;
|
||||
}
|
||||
.ack {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.5rem;
|
||||
font-size: 0.85rem;
|
||||
color: #cbd5e1;
|
||||
cursor: pointer;
|
||||
}
|
||||
|
||||
.modal-actions {
|
||||
display: flex;
|
||||
justify-content: flex-end;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
.modal-actions.split {
|
||||
justify-content: space-between;
|
||||
}
|
||||
|
||||
.muted {
|
||||
color: #94a3b8;
|
||||
}
|
||||
</style>
|
||||
@@ -1,7 +1,7 @@
|
||||
# Project Blueprint: Lightweight Event-Based Serverless Cloud
|
||||
|
||||
**Status**: Phase 4 — Blueprint Complete
|
||||
**Last Updated**: 2026-04-10
|
||||
**Last Updated**: 2026-05-27
|
||||
**Audience**: Solo developer (DIY self-hosted)
|
||||
|
||||
---
|
||||
@@ -1156,6 +1156,35 @@ DELETE /api/v1/admin/api-keys/{id} — caller's own only
|
||||
|
||||
Every existing `/api/v1/admin/*` endpoint is re-gated from "any authed admin" to a specific `Capability`. Request/response shapes are unchanged; what changes is the set of callers each endpoint accepts (a `member` now gets 403 on app surfaces they're not part of, where before they would have been 401-or-200 depending only on session validity).
|
||||
|
||||
### App Member Management Endpoints
|
||||
|
||||
Exposes the `app_members` table as a first-class CRUD surface so app admins can manage who they share an app with from the dashboard, not just from SQL.
|
||||
|
||||
```
|
||||
GET /api/v1/admin/apps/{id_or_slug}/members — list members (ordered by username),
|
||||
joined with admin_users for
|
||||
username / email / instance_role / is_active
|
||||
POST /api/v1/admin/apps/{id_or_slug}/members — { user_id, role } → 201 enriched DTO
|
||||
409 on duplicate (promotions go through PATCH)
|
||||
422 if target user is_active = false
|
||||
422 if target user instance_role != 'member'
|
||||
(owners/admins have implicit authority;
|
||||
an explicit row would be dead weight)
|
||||
PATCH /api/v1/admin/apps/{id_or_slug}/members/{user_id} — { role } → 200 enriched DTO
|
||||
404 if no existing membership
|
||||
DELETE /api/v1/admin/apps/{id_or_slug}/members/{user_id} — 204 (idempotent — 204 also when missing)
|
||||
```
|
||||
|
||||
All four are gated on `Capability::AppAdmin(app_id)`. Editors and viewers get 403 on list and never see the dashboard's Members tab.
|
||||
|
||||
**`my_role` on the app lookup endpoint.** `GET /api/v1/admin/apps/{id_or_slug}` now returns an additional `my_role: Option<AppRole>`, computed server-side from the principal: `Owner → app_admin`, `Admin → editor`, `Member → app_members.role`. The dashboard uses this single field to decide whether to render the Members tab (visible iff `my_role == app_admin`), keeping API and UI gate logic identical.
|
||||
|
||||
**No last-app-admin guard.** Unlike the last-owner protection on `admin_users`, removing the final `app_admin` row from `app_members` is allowed. Every `owner` instance-role user implicitly satisfies `Capability::AppAdmin(_)` via the top-level `role_grants` branch, so no app can become permanently orphaned — an owner can always re-issue grants. The `admin` instance role is only implicit *editor*, so it does **not** provide a fallback path; the owner guarantee alone is what makes the no-guard position safe.
|
||||
|
||||
**Dead-row sweep on promotion (deferred).** Promoting a user from `member` → `admin`/`owner` leaves their `app_members` rows in place. They become inert (implicit grants supersede), but are not auto-deleted. A future hook can sweep them; harmless for now.
|
||||
|
||||
Additive within `/api/v1/admin/...` — no API major bump per [docs/versioning.md](docs/versioning.md).
|
||||
|
||||
### Out of Scope (Phase 3.5)
|
||||
|
||||
Schema room only, not built:
|
||||
@@ -1164,7 +1193,7 @@ Schema room only, not built:
|
||||
- **MFA / TOTP** — `mfa_secret` column reserved on `admin_users`.
|
||||
- **Service accounts** — reserved as a future table; for now, every API key belongs to a human `admin_users` row.
|
||||
|
||||
Defer to follow-up sessions: dashboard surfaces for invites / member management / key minting (curl is the supported interface this phase), OIDC / SAML / SCIM, the `picloud` CLI binary itself, email/SMTP delivery of invites, audit log shipping.
|
||||
Defer to follow-up sessions: dashboard surfaces for invites / key minting (curl is the supported interface this phase — member management has a dashboard tab; see above), OIDC / SAML / SCIM, the `picloud` CLI binary itself, email/SMTP delivery of invites, audit log shipping.
|
||||
|
||||
---
|
||||
|
||||
|
||||
Reference in New Issue
Block a user