Skip to content

feat(ampcc): add ability to authenticate if not authenticated #1595

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
cmwhited merged 3 commits into from
Jan 23, 2026
Merged

feat(ampcc): add ability to authenticate if not authenticated #1595

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
2315659
feat(auth flow): add ability to authenticate ampcc if not authenticated
cmwhited Jan 20, 2026
748aa8e
feat(ampcc): PR comments. add error handling for copy to clipboard an…
cmwhited Jan 22, 2026
7861c45
feat(ampcc): format and clippy
cmwhited Jan 22, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
544 changes: 432 additions & 112 deletions Cargo.lock
View file
Open in desktop

Large diffs are not rendered by default.

9 changes: 9 additions & 0 deletions crates/bin/ampcc/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,13 +1,22 @@
[package]
name = "ampcc"
description = "TUI to interact with Amp Datasets. View published Datasets, fetch and view their manifest and schemas. Search for Datasets."
edition.workspace = true
version.workspace = true
license-file.workspace = true

[dependencies]
alloy.workspace = true
anyhow.workspace = true
arboard = "3.6.1"
base64 = "0.22.1"
chrono.workspace = true
crossterm = "0.29.0"
dirs = "6.0.0"
open = "5.3.3"
rand = "0.9.2"
ratatui = "0.30"
sha2 = "0.10.9"
tokio.workspace = true
admin-client = { path = "../../clients/admin" }
worker = { path = "../../services/worker" }
Expand Down
193 changes: 193 additions & 0 deletions crates/bin/ampcc/src/action.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,193 @@
//! Application actions for state management.
//!
//! Actions are the single source of truth for state mutations.
//! All state changes flow through the action handler.

use admin_client::{
jobs::JobInfo,
workers::{WorkerDetailResponse, WorkerInfo},
};
use worker::job::JobId;

use crate::{app::DataSource, auth::AuthStorage};

/// Actions that can be dispatched to mutate application state.
#[derive(Debug)]
pub enum Action {
/// No-op action (used for events that don't need handling).
None,

/// Quit the application.
Quit,

// ========================================================================
// Navigation Actions
// ========================================================================
/// Navigate to next item in focused pane.
NavigateDown,

/// Navigate to previous item in focused pane.
NavigateUp,

/// Page down in focused pane.
PageDown(u16),

/// Page up in focused pane.
PageUp(u16),

/// Cycle to next pane.
NextPane,

/// Cycle to previous pane.
PrevPane,

/// Toggle expand/collapse on selected dataset.
ToggleExpand,

/// Enter detail view for selected item.
EnterDetail,

// ========================================================================
// Source Switching
// ========================================================================
/// Switch to local data source.
SwitchToLocal,

/// Switch to registry data source.
SwitchToRegistry,

/// Source switch completed.
SourceSwitched(Result<DataSource, String>),

// ========================================================================
// Search Actions
// ========================================================================
/// Enter search mode.
EnterSearchMode,

/// Exit search mode.
ExitSearchMode,

/// Add character to search query.
SearchInput(char),

/// Remove character from search query.
SearchBackspace,

/// Submit search (exit search mode and refresh).
SearchSubmit,

// ========================================================================
// Dataset Actions
// ========================================================================
/// Trigger dataset refresh.
RefreshDatasets,

/// Datasets loaded from source.
DatasetsLoaded(Result<Vec<crate::app::DatasetEntry>, String>),

/// Dataset versions loaded.
VersionsLoaded {
dataset_index: usize,
versions: Result<Vec<crate::app::VersionEntry>, String>,
},

// ========================================================================
// Manifest Actions
// ========================================================================
/// Load manifest for selected dataset.
LoadManifest,

/// Manifest loaded.
ManifestLoaded(Option<serde_json::Value>),

// ========================================================================
// Jobs Actions (Local mode)
// ========================================================================
/// Refresh jobs list.
RefreshJobs,

/// Jobs loaded.
JobsLoaded(Vec<JobInfo>),

/// Stop a job.
StopJob(JobId),

/// Job stopped result.
JobStopped(Result<(), String>),

/// Delete a job.
DeleteJob(JobId),

/// Job deleted result.
JobDeleted(Result<(), String>),

// ========================================================================
// Workers Actions (Local mode)
// ========================================================================
/// Refresh workers list.
RefreshWorkers,

/// Workers loaded.
WorkersLoaded(Vec<WorkerInfo>),

/// Load worker details.
LoadWorkerDetail(String),

/// Worker detail loaded.
WorkerDetailLoaded(Option<WorkerDetailResponse>),

// ========================================================================
// Auth Actions
// ========================================================================
/// Check auth state on startup.
AuthCheckOnStartup,

/// Auth state loaded from disk.
AuthStateLoaded(Option<AuthStorage>),

/// Start the login flow.
AuthLogin,

/// Logout and clear credentials.
AuthLogout,

/// Device flow initiated - waiting for user confirmation.
AuthDeviceFlowPending {
user_code: String,
verification_uri: String,
device_code: String,
code_verifier: String,
interval: i64,
},

/// User confirmed device flow - open browser and start polling.
AuthDeviceFlowConfirm,

/// Poll for device token.
AuthDeviceFlowPoll {
device_code: String,
code_verifier: String,
interval: i64,
/// If true, poll immediately without delay (first poll after user confirms).
is_first_poll: bool,
},

/// Device flow completed successfully.
AuthDeviceFlowComplete(AuthStorage),

/// Cancel device flow.
AuthDeviceFlowCancel,

/// Auth error occurred.
AuthError(String),

/// Token refresh completed.
AuthRefreshComplete(Result<AuthStorage, String>),

// ========================================================================
// Error Actions
// ========================================================================
/// Display an error message.
Error(String),
}
Loading