Compare commits
4 Commits
main
...
fix/multip
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8abfec3303 | ||
|
|
2534c03e3b | ||
|
|
0e53072782 | ||
|
|
fabd397478 |
@@ -33,6 +33,11 @@ RUN pip3 install --break-system-packages ruff
|
|||||||
|
|
||||||
COPY --from=builder /app/target/release/compliance-agent /usr/local/bin/compliance-agent
|
COPY --from=builder /app/target/release/compliance-agent /usr/local/bin/compliance-agent
|
||||||
|
|
||||||
|
# Copy documentation for the help chat assistant
|
||||||
|
COPY --from=builder /app/README.md /app/README.md
|
||||||
|
COPY --from=builder /app/docs /app/docs
|
||||||
|
ENV HELP_DOCS_PATH=/app
|
||||||
|
|
||||||
# Ensure SSH key directory exists
|
# Ensure SSH key directory exists
|
||||||
RUN mkdir -p /data/compliance-scanner/ssh
|
RUN mkdir -p /data/compliance-scanner/ssh
|
||||||
|
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ uuid = { workspace = true }
|
|||||||
secrecy = { workspace = true }
|
secrecy = { workspace = true }
|
||||||
regex = { workspace = true }
|
regex = { workspace = true }
|
||||||
axum = "0.8"
|
axum = "0.8"
|
||||||
tower-http = { version = "0.6", features = ["cors", "trace"] }
|
tower-http = { version = "0.6", features = ["cors", "trace", "set-header"] }
|
||||||
git2 = "0.20"
|
git2 = "0.20"
|
||||||
octocrab = "0.44"
|
octocrab = "0.44"
|
||||||
tokio-cron-scheduler = "0.13"
|
tokio-cron-scheduler = "0.13"
|
||||||
|
|||||||
@@ -104,28 +104,58 @@ fn load_docs(root: &Path) -> String {
|
|||||||
|
|
||||||
/// Returns a reference to the cached doc context string, initialised on
|
/// Returns a reference to the cached doc context string, initialised on
|
||||||
/// first call via `OnceLock`.
|
/// first call via `OnceLock`.
|
||||||
|
///
|
||||||
|
/// Discovery order:
|
||||||
|
/// 1. `HELP_DOCS_PATH` env var (explicit override)
|
||||||
|
/// 2. Walk up from the binary location
|
||||||
|
/// 3. Current working directory
|
||||||
|
/// 4. Common Docker paths (/app, /opt/compliance-scanner)
|
||||||
fn doc_context() -> &'static str {
|
fn doc_context() -> &'static str {
|
||||||
DOC_CONTEXT.get_or_init(|| {
|
DOC_CONTEXT.get_or_init(|| {
|
||||||
|
// 1. Explicit env var
|
||||||
|
if let Ok(path) = std::env::var("HELP_DOCS_PATH") {
|
||||||
|
let p = PathBuf::from(&path);
|
||||||
|
if p.join("README.md").is_file() || p.join("docs").is_dir() {
|
||||||
|
tracing::info!("help_chat: loading docs from HELP_DOCS_PATH={path}");
|
||||||
|
return load_docs(&p);
|
||||||
|
}
|
||||||
|
tracing::warn!("help_chat: HELP_DOCS_PATH={path} has no README.md or docs/");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. Walk up from binary location
|
||||||
let start = std::env::current_exe()
|
let start = std::env::current_exe()
|
||||||
.ok()
|
.ok()
|
||||||
.and_then(|p| p.parent().map(Path::to_path_buf))
|
.and_then(|p| p.parent().map(Path::to_path_buf))
|
||||||
.unwrap_or_else(|| PathBuf::from("."));
|
.unwrap_or_else(|| PathBuf::from("."));
|
||||||
|
|
||||||
match find_project_root(&start) {
|
if let Some(root) = find_project_root(&start) {
|
||||||
Some(root) => load_docs(&root),
|
return load_docs(&root);
|
||||||
None => {
|
}
|
||||||
// Fallback: try current working directory
|
|
||||||
let cwd = std::env::current_dir().unwrap_or_else(|_| PathBuf::from("."));
|
// 3. Current working directory
|
||||||
|
if let Ok(cwd) = std::env::current_dir() {
|
||||||
|
if let Some(root) = find_project_root(&cwd) {
|
||||||
|
return load_docs(&root);
|
||||||
|
}
|
||||||
if cwd.join("README.md").is_file() {
|
if cwd.join("README.md").is_file() {
|
||||||
return load_docs(&cwd);
|
return load_docs(&cwd);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. Common Docker/deployment paths
|
||||||
|
for candidate in ["/app", "/opt/compliance-scanner", "/srv/compliance-scanner"] {
|
||||||
|
let p = PathBuf::from(candidate);
|
||||||
|
if p.join("README.md").is_file() || p.join("docs").is_dir() {
|
||||||
|
tracing::info!("help_chat: found docs at {candidate}");
|
||||||
|
return load_docs(&p);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
tracing::error!(
|
tracing::error!(
|
||||||
"help_chat: could not locate project root from {}; doc context will be empty",
|
"help_chat: could not locate project root; doc context will be empty. \
|
||||||
start.display()
|
Set HELP_DOCS_PATH to the directory containing README.md and docs/"
|
||||||
);
|
);
|
||||||
String::new()
|
String::new()
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,8 +1,10 @@
|
|||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
|
||||||
|
use axum::http::HeaderValue;
|
||||||
use axum::{middleware, Extension};
|
use axum::{middleware, Extension};
|
||||||
use tokio::sync::RwLock;
|
use tokio::sync::RwLock;
|
||||||
use tower_http::cors::CorsLayer;
|
use tower_http::cors::CorsLayer;
|
||||||
|
use tower_http::set_header::SetResponseHeaderLayer;
|
||||||
use tower_http::trace::TraceLayer;
|
use tower_http::trace::TraceLayer;
|
||||||
|
|
||||||
use crate::agent::ComplianceAgent;
|
use crate::agent::ComplianceAgent;
|
||||||
@@ -14,7 +16,24 @@ pub async fn start_api_server(agent: ComplianceAgent, port: u16) -> Result<(), A
|
|||||||
let mut app = routes::build_router()
|
let mut app = routes::build_router()
|
||||||
.layer(Extension(Arc::new(agent.clone())))
|
.layer(Extension(Arc::new(agent.clone())))
|
||||||
.layer(CorsLayer::permissive())
|
.layer(CorsLayer::permissive())
|
||||||
.layer(TraceLayer::new_for_http());
|
.layer(TraceLayer::new_for_http())
|
||||||
|
// Security headers (defense-in-depth, primary enforcement via Traefik)
|
||||||
|
.layer(SetResponseHeaderLayer::overriding(
|
||||||
|
axum::http::header::STRICT_TRANSPORT_SECURITY,
|
||||||
|
HeaderValue::from_static("max-age=31536000; includeSubDomains"),
|
||||||
|
))
|
||||||
|
.layer(SetResponseHeaderLayer::overriding(
|
||||||
|
axum::http::header::X_FRAME_OPTIONS,
|
||||||
|
HeaderValue::from_static("DENY"),
|
||||||
|
))
|
||||||
|
.layer(SetResponseHeaderLayer::overriding(
|
||||||
|
axum::http::header::X_CONTENT_TYPE_OPTIONS,
|
||||||
|
HeaderValue::from_static("nosniff"),
|
||||||
|
))
|
||||||
|
.layer(SetResponseHeaderLayer::overriding(
|
||||||
|
axum::http::header::REFERRER_POLICY,
|
||||||
|
HeaderValue::from_static("strict-origin-when-cross-origin"),
|
||||||
|
));
|
||||||
|
|
||||||
if let (Some(kc_url), Some(kc_realm)) =
|
if let (Some(kc_url), Some(kc_realm)) =
|
||||||
(&agent.config.keycloak_url, &agent.config.keycloak_realm)
|
(&agent.config.keycloak_url, &agent.config.keycloak_realm)
|
||||||
|
|||||||
@@ -315,8 +315,15 @@ impl PipelineOrchestrator {
|
|||||||
.await?;
|
.await?;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Persist CVE alerts (upsert by cve_id + repo_id)
|
// Persist CVE alerts and create notifications
|
||||||
|
{
|
||||||
|
use compliance_core::models::notification::{parse_severity, CveNotification};
|
||||||
|
|
||||||
|
let repo_name = repo.name.clone();
|
||||||
|
let mut new_notif_count = 0u32;
|
||||||
|
|
||||||
for alert in &cve_alerts {
|
for alert in &cve_alerts {
|
||||||
|
// Upsert the alert
|
||||||
let filter = doc! {
|
let filter = doc! {
|
||||||
"cve_id": &alert.cve_id,
|
"cve_id": &alert.cve_id,
|
||||||
"repo_id": &alert.repo_id,
|
"repo_id": &alert.repo_id,
|
||||||
@@ -329,6 +336,46 @@ impl PipelineOrchestrator {
|
|||||||
.update_one(filter, update)
|
.update_one(filter, update)
|
||||||
.upsert(true)
|
.upsert(true)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
|
// Create notification (dedup by cve_id + repo + package + version)
|
||||||
|
let notif_filter = doc! {
|
||||||
|
"cve_id": &alert.cve_id,
|
||||||
|
"repo_id": &alert.repo_id,
|
||||||
|
"package_name": &alert.affected_package,
|
||||||
|
"package_version": &alert.affected_version,
|
||||||
|
};
|
||||||
|
let severity = parse_severity(alert.severity.as_deref(), alert.cvss_score);
|
||||||
|
let mut notification = CveNotification::new(
|
||||||
|
alert.cve_id.clone(),
|
||||||
|
repo_id.clone(),
|
||||||
|
repo_name.clone(),
|
||||||
|
alert.affected_package.clone(),
|
||||||
|
alert.affected_version.clone(),
|
||||||
|
severity,
|
||||||
|
);
|
||||||
|
notification.cvss_score = alert.cvss_score;
|
||||||
|
notification.summary = alert.summary.clone();
|
||||||
|
notification.url = Some(format!("https://osv.dev/vulnerability/{}", alert.cve_id));
|
||||||
|
|
||||||
|
let notif_update = doc! {
|
||||||
|
"$setOnInsert": mongodb::bson::to_bson(¬ification).unwrap_or_default()
|
||||||
|
};
|
||||||
|
if let Ok(result) = self
|
||||||
|
.db
|
||||||
|
.cve_notifications()
|
||||||
|
.update_one(notif_filter, notif_update)
|
||||||
|
.upsert(true)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
if result.upserted_id.is_some() {
|
||||||
|
new_notif_count += 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if new_notif_count > 0 {
|
||||||
|
tracing::info!("[{repo_id}] Created {new_notif_count} CVE notification(s)");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Stage 6: Issue Creation
|
// Stage 6: Issue Creation
|
||||||
|
|||||||
@@ -3877,3 +3877,15 @@ tbody tr:last-child td {
|
|||||||
.notification-item-pkg { font-size: 12px; color: var(--text-primary); font-family: 'JetBrains Mono', monospace; }
|
.notification-item-pkg { font-size: 12px; color: var(--text-primary); font-family: 'JetBrains Mono', monospace; }
|
||||||
.notification-item-repo { font-size: 11px; color: var(--text-secondary); margin-bottom: 4px; }
|
.notification-item-repo { font-size: 11px; color: var(--text-secondary); margin-bottom: 4px; }
|
||||||
.notification-item-summary { font-size: 11px; color: var(--text-secondary); line-height: 1.4; display: -webkit-box; -webkit-line-clamp: 2; -webkit-box-orient: vertical; overflow: hidden; }
|
.notification-item-summary { font-size: 11px; color: var(--text-secondary); line-height: 1.4; display: -webkit-box; -webkit-line-clamp: 2; -webkit-box-orient: vertical; overflow: hidden; }
|
||||||
|
|
||||||
|
/* ═══════════════════════════════════════════════════════════════
|
||||||
|
COPY BUTTON — Reusable clipboard copy component
|
||||||
|
═══════════════════════════════════════════════════════════════ */
|
||||||
|
.copy-btn { background: none; border: 1px solid var(--border); border-radius: 6px; padding: 5px 7px; color: var(--text-secondary); cursor: pointer; display: inline-flex; align-items: center; transition: color 0.15s, border-color 0.15s, background 0.15s; flex-shrink: 0; }
|
||||||
|
.copy-btn:hover { color: var(--accent); border-color: var(--accent); background: var(--accent-muted); }
|
||||||
|
.copy-btn-sm { padding: 3px 5px; border-radius: 4px; }
|
||||||
|
/* Copyable inline field pattern: value + copy button side by side */
|
||||||
|
.copyable { display: flex; align-items: center; gap: 6px; }
|
||||||
|
.copyable code, .copyable .mono { flex: 1; min-width: 0; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
|
||||||
|
.code-snippet-wrapper { position: relative; }
|
||||||
|
.code-snippet-header { display: flex; align-items: center; justify-content: space-between; margin-bottom: 4px; gap: 8px; }
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
use dioxus::prelude::*;
|
use dioxus::prelude::*;
|
||||||
|
|
||||||
|
use crate::components::copy_button::CopyButton;
|
||||||
|
|
||||||
#[component]
|
#[component]
|
||||||
pub fn CodeSnippet(
|
pub fn CodeSnippet(
|
||||||
code: String,
|
code: String,
|
||||||
@@ -7,16 +9,19 @@ pub fn CodeSnippet(
|
|||||||
#[props(default)] line_number: u32,
|
#[props(default)] line_number: u32,
|
||||||
) -> Element {
|
) -> Element {
|
||||||
rsx! {
|
rsx! {
|
||||||
div {
|
div { class: "code-snippet-wrapper",
|
||||||
|
div { class: "code-snippet-header",
|
||||||
if !file_path.is_empty() {
|
if !file_path.is_empty() {
|
||||||
div {
|
span {
|
||||||
style: "font-size: 12px; color: var(--text-secondary); margin-bottom: 4px; font-family: monospace;",
|
style: "font-size: 12px; color: var(--text-secondary); font-family: monospace;",
|
||||||
"{file_path}"
|
"{file_path}"
|
||||||
if line_number > 0 {
|
if line_number > 0 {
|
||||||
":{line_number}"
|
":{line_number}"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
CopyButton { value: code.clone(), small: true }
|
||||||
|
}
|
||||||
pre { class: "code-block", "{code}" }
|
pre { class: "code-block", "{code}" }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
49
compliance-dashboard/src/components/copy_button.rs
Normal file
49
compliance-dashboard/src/components/copy_button.rs
Normal file
@@ -0,0 +1,49 @@
|
|||||||
|
use dioxus::prelude::*;
|
||||||
|
use dioxus_free_icons::icons::bs_icons::*;
|
||||||
|
use dioxus_free_icons::Icon;
|
||||||
|
|
||||||
|
/// A small copy-to-clipboard button that shows a checkmark after copying.
|
||||||
|
///
|
||||||
|
/// Usage: `CopyButton { value: "text to copy" }`
|
||||||
|
#[component]
|
||||||
|
pub fn CopyButton(value: String, #[props(default = false)] small: bool) -> Element {
|
||||||
|
let mut copied = use_signal(|| false);
|
||||||
|
|
||||||
|
let size = if small { 12 } else { 14 };
|
||||||
|
let class = if small {
|
||||||
|
"copy-btn copy-btn-sm"
|
||||||
|
} else {
|
||||||
|
"copy-btn"
|
||||||
|
};
|
||||||
|
|
||||||
|
rsx! {
|
||||||
|
button {
|
||||||
|
class: class,
|
||||||
|
title: if copied() { "Copied!" } else { "Copy to clipboard" },
|
||||||
|
onclick: move |_| {
|
||||||
|
let val = value.clone();
|
||||||
|
// Escape for JS single-quoted string
|
||||||
|
let escaped = val
|
||||||
|
.replace('\\', "\\\\")
|
||||||
|
.replace('\'', "\\'")
|
||||||
|
.replace('\n', "\\n")
|
||||||
|
.replace('\r', "\\r");
|
||||||
|
let js = format!("navigator.clipboard.writeText('{escaped}')");
|
||||||
|
document::eval(&js);
|
||||||
|
copied.set(true);
|
||||||
|
spawn(async move {
|
||||||
|
#[cfg(feature = "web")]
|
||||||
|
gloo_timers::future::TimeoutFuture::new(2000).await;
|
||||||
|
#[cfg(not(feature = "web"))]
|
||||||
|
tokio::time::sleep(std::time::Duration::from_secs(2)).await;
|
||||||
|
copied.set(false);
|
||||||
|
});
|
||||||
|
},
|
||||||
|
if copied() {
|
||||||
|
Icon { icon: BsCheckLg, width: size, height: size }
|
||||||
|
} else {
|
||||||
|
Icon { icon: BsClipboard, width: size, height: size }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -2,6 +2,7 @@ pub mod app_shell;
|
|||||||
pub mod attack_chain;
|
pub mod attack_chain;
|
||||||
pub mod code_inspector;
|
pub mod code_inspector;
|
||||||
pub mod code_snippet;
|
pub mod code_snippet;
|
||||||
|
pub mod copy_button;
|
||||||
pub mod file_tree;
|
pub mod file_tree;
|
||||||
pub mod help_chat;
|
pub mod help_chat;
|
||||||
pub mod notification_bell;
|
pub mod notification_bell;
|
||||||
|
|||||||
@@ -259,7 +259,10 @@ pub fn McpServersPage() -> Element {
|
|||||||
div { class: "mcp-detail-row",
|
div { class: "mcp-detail-row",
|
||||||
Icon { icon: BsGlobe, width: 13, height: 13 }
|
Icon { icon: BsGlobe, width: 13, height: 13 }
|
||||||
span { class: "mcp-detail-label", "Endpoint" }
|
span { class: "mcp-detail-label", "Endpoint" }
|
||||||
|
div { class: "copyable",
|
||||||
code { class: "mcp-detail-value", "{server.endpoint_url}" }
|
code { class: "mcp-detail-value", "{server.endpoint_url}" }
|
||||||
|
crate::components::copy_button::CopyButton { value: server.endpoint_url.clone(), small: true }
|
||||||
|
}
|
||||||
}
|
}
|
||||||
div { class: "mcp-detail-row",
|
div { class: "mcp-detail-row",
|
||||||
Icon { icon: BsHddNetwork, width: 13, height: 13 }
|
Icon { icon: BsHddNetwork, width: 13, height: 13 }
|
||||||
|
|||||||
@@ -137,13 +137,20 @@ pub fn RepositoriesPage() -> Element {
|
|||||||
"For SSH URLs: add this deploy key (read-only) to your repository"
|
"For SSH URLs: add this deploy key (read-only) to your repository"
|
||||||
}
|
}
|
||||||
div {
|
div {
|
||||||
style: "margin-top: 4px; padding: 8px; background: var(--bg-secondary); border-radius: 4px; font-family: monospace; font-size: 11px; word-break: break-all; user-select: all;",
|
class: "copyable",
|
||||||
|
style: "margin-top: 4px; padding: 8px; background: var(--bg-secondary); border-radius: 4px;",
|
||||||
|
code {
|
||||||
|
style: "font-size: 11px; word-break: break-all; user-select: all;",
|
||||||
if ssh_public_key().is_empty() {
|
if ssh_public_key().is_empty() {
|
||||||
"Loading..."
|
"Loading..."
|
||||||
} else {
|
} else {
|
||||||
"{ssh_public_key}"
|
"{ssh_public_key}"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if !ssh_public_key().is_empty() {
|
||||||
|
crate::components::copy_button::CopyButton { value: ssh_public_key(), small: true }
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// HTTPS auth fields
|
// HTTPS auth fields
|
||||||
@@ -390,29 +397,38 @@ pub fn RepositoriesPage() -> Element {
|
|||||||
}
|
}
|
||||||
div { class: "form-group",
|
div { class: "form-group",
|
||||||
label { "Webhook URL" }
|
label { "Webhook URL" }
|
||||||
input {
|
{
|
||||||
r#type: "text",
|
|
||||||
readonly: true,
|
|
||||||
style: "font-family: monospace; font-size: 12px;",
|
|
||||||
value: {
|
|
||||||
#[cfg(feature = "web")]
|
#[cfg(feature = "web")]
|
||||||
let origin = web_sys::window()
|
let origin = web_sys::window()
|
||||||
.and_then(|w: web_sys::Window| w.location().origin().ok())
|
.and_then(|w: web_sys::Window| w.location().origin().ok())
|
||||||
.unwrap_or_default();
|
.unwrap_or_default();
|
||||||
#[cfg(not(feature = "web"))]
|
#[cfg(not(feature = "web"))]
|
||||||
let origin = String::new();
|
let origin = String::new();
|
||||||
format!("{origin}/webhook/{}/{eid}", edit_webhook_tracker())
|
let webhook_url = format!("{origin}/webhook/{}/{eid}", edit_webhook_tracker());
|
||||||
},
|
rsx! {
|
||||||
|
div { class: "copyable",
|
||||||
|
input {
|
||||||
|
r#type: "text",
|
||||||
|
readonly: true,
|
||||||
|
style: "font-family: monospace; font-size: 12px; flex: 1;",
|
||||||
|
value: "{webhook_url}",
|
||||||
|
}
|
||||||
|
crate::components::copy_button::CopyButton { value: webhook_url.clone() }
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
div { class: "form-group",
|
div { class: "form-group",
|
||||||
label { "Webhook Secret" }
|
label { "Webhook Secret" }
|
||||||
|
div { class: "copyable",
|
||||||
input {
|
input {
|
||||||
r#type: "text",
|
r#type: "text",
|
||||||
readonly: true,
|
readonly: true,
|
||||||
style: "font-family: monospace; font-size: 12px;",
|
style: "font-family: monospace; font-size: 12px; flex: 1;",
|
||||||
value: "{secret}",
|
value: "{secret}",
|
||||||
}
|
}
|
||||||
|
crate::components::copy_button::CopyButton { value: secret.clone() }
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
div { class: "modal-actions",
|
div { class: "modal-actions",
|
||||||
|
|||||||
Reference in New Issue
Block a user