mirror of
https://relay.ngit.dev/npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/ngit-grasp.git
synced 2026-10-05 23:18:24 +00:00
DanConwayDev
91b43bc157
Reverse-proxied production deployments currently attribute every WebSocket connection to the proxy peer, collapsing per-IP limits, abuse metrics, and logs onto localhost. Blindly trusting forwarding headers would let direct clients spoof the same controls. Add an opt-in CIDR trust boundary and resolve X-Forwarded-For, Forwarded, or X-Real-IP only when the TCP peer is trusted. Walk proxy chains from the peer inward, stop at the first untrusted hop, and fall back to the peer on malformed input. Feed the resolved address consistently into rust-nostr connection policy, connection metrics, and lifecycle logs. Expose the setting across CLI/environment, NixOS, examples, and reference documentation. Multi-hop correctness assumes every trusted proxy appends or overwrites the forwarding chain and the backend is unreachable from untrusted networks. HTTP Git request accounting and PROXY protocol support remain out of scope. Unit coverage exercises direct clients, trusted single and multi-proxy paths, spoofed headers, malformed chains, IPv6, and configuration parsing.
2471 lines
90 KiB
Rust
2471 lines
90 KiB
Rust
use anyhow::{anyhow, Context, Result};
|
|
use clap::{Parser, ValueEnum};
|
|
use ipnet::IpNet;
|
|
use nostr_sdk::prelude::*;
|
|
use serde::{Deserialize, Serialize};
|
|
use std::fs;
|
|
use std::io::Write;
|
|
use std::path::{Path, PathBuf};
|
|
use std::time::Duration;
|
|
|
|
const RELAY_OWNER_NSEC_ENV: &str = "NGIT_RELAY_OWNER_NSEC";
|
|
const RELAY_OWNER_NSEC_CREDENTIAL: &str = "relay_owner_nsec";
|
|
const DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS: u64 = 30 * 24 * 60 * 60;
|
|
const DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS: u64 =
|
|
180 * 24 * 60 * 60;
|
|
// Retention months are fixed 30-day periods, avoiding calendar-month ambiguity.
|
|
const DEFAULT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS: u64 = 270 * 24 * 60 * 60;
|
|
const DEFAULT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS: u64 =
|
|
90 * 24 * 60 * 60;
|
|
const DEFAULT_USER_INDEX_RELAYS: &str =
|
|
"wss://purplepag.es,wss://index.hzrd149.com,wss://indexer.coracle.social";
|
|
const DEFAULT_SYNC_PLUS_FALLBACK_RELAYS: &str =
|
|
"wss://relay.ditto.pub,wss://relay.damus.io,wss://nos.lol,wss://relay.primal.net";
|
|
|
|
/// Whitelist entry for repository/archive filtering
|
|
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
|
|
#[serde(rename_all = "lowercase")]
|
|
pub enum WhitelistEntry {
|
|
/// All repos from this pubkey: "npub1..."
|
|
Pubkey(String),
|
|
|
|
/// Specific repo: "npub1.../identifier"
|
|
Repository { npub: String, identifier: String },
|
|
|
|
/// Any repo with this identifier: "identifier"
|
|
Identifier(String),
|
|
}
|
|
|
|
impl WhitelistEntry {
|
|
/// Parse a whitelist entry from string
|
|
///
|
|
/// Formats:
|
|
/// - "npub1..." -> Pubkey
|
|
/// - "npub1.../identifier" -> Repository
|
|
/// - "identifier" -> Identifier
|
|
///
|
|
/// Validates npub format at parse time (fail fast)
|
|
pub fn parse(s: &str) -> Result<Self> {
|
|
let trimmed = s.trim();
|
|
|
|
if trimmed.contains('/') {
|
|
// Format: npub1.../identifier
|
|
let parts: Vec<&str> = trimmed.split('/').collect();
|
|
if parts.len() != 2 {
|
|
return Err(anyhow!(
|
|
"Invalid whitelist entry format '{}'. Expected 'npub/identifier'",
|
|
s
|
|
));
|
|
}
|
|
|
|
let npub = parts[0];
|
|
let identifier = parts[1];
|
|
|
|
// Validate npub format (fail fast)
|
|
if !npub.starts_with("npub1") {
|
|
return Err(anyhow!(
|
|
"Invalid whitelist entry '{}'. First part must be npub",
|
|
s
|
|
));
|
|
}
|
|
|
|
PublicKey::from_bech32(npub)
|
|
.context(format!("Invalid npub in whitelist entry '{}'", s))?;
|
|
|
|
Ok(Self::Repository {
|
|
npub: npub.to_string(),
|
|
identifier: identifier.to_string(),
|
|
})
|
|
} else if trimmed.starts_with("npub1") {
|
|
// Format: npub1...
|
|
// Validate npub format (fail fast)
|
|
PublicKey::from_bech32(trimmed)
|
|
.context(format!("Invalid npub in whitelist entry '{}'", s))?;
|
|
|
|
Ok(Self::Pubkey(trimmed.to_string()))
|
|
} else {
|
|
// Format: identifier
|
|
Ok(Self::Identifier(trimmed.to_string()))
|
|
}
|
|
}
|
|
|
|
/// Check if this entry matches the given npub and identifier
|
|
pub fn matches(&self, npub: &str, identifier: &str) -> bool {
|
|
match self {
|
|
Self::Pubkey(p) => npub == p,
|
|
Self::Repository {
|
|
npub: p,
|
|
identifier: i,
|
|
} => npub == p && identifier == i,
|
|
Self::Identifier(i) => identifier == i,
|
|
}
|
|
}
|
|
|
|
/// Parse whitelist from comma-separated string
|
|
///
|
|
/// Skips invalid entries with warnings instead of failing.
|
|
/// This allows the config to load even if some whitelist entries are malformed.
|
|
pub fn parse_whitelist(input: &str) -> Vec<Self> {
|
|
if input.trim().is_empty() {
|
|
return Vec::new();
|
|
}
|
|
|
|
input
|
|
.split(',')
|
|
.map(|s| s.trim())
|
|
.filter(|s| !s.is_empty())
|
|
.filter_map(|s| match Self::parse(s) {
|
|
Ok(entry) => Some(entry),
|
|
Err(e) => {
|
|
tracing::warn!("Skipping invalid whitelist entry '{}': {}", s, e);
|
|
None
|
|
}
|
|
})
|
|
.collect()
|
|
}
|
|
}
|
|
|
|
/// GRASP-05 Archive mode configuration
|
|
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
|
|
pub struct ArchiveConfig {
|
|
/// Accept all repository announcements (no filtering)
|
|
///
|
|
/// WARNING: Setting this to true allows anyone to mirror any repository
|
|
/// to this relay, potentially causing storage/bandwidth exhaustion.
|
|
#[serde(default)]
|
|
pub archive_all: bool,
|
|
|
|
/// Whitelist entries for selective archiving
|
|
///
|
|
/// If empty and archive_all is false, GRASP-05 is disabled (GRASP-01 strict mode).
|
|
#[serde(default)]
|
|
pub whitelist: Vec<WhitelistEntry>,
|
|
|
|
/// GRASP server domains to archive (archive all repositories from these domains)
|
|
///
|
|
/// If non-empty, archives all repositories from the specified GRASP server domains.
|
|
#[serde(default)]
|
|
pub grasp_services: Vec<String>,
|
|
|
|
/// Read-only archive mode: relay is a read-only sync of archived repositories
|
|
///
|
|
/// When true, the relay ONLY accepts announcements matching the archive whitelist/all.
|
|
/// Announcements listing the relay but not in the whitelist are rejected.
|
|
/// When false, the relay operates in GRASP-01 mode for unwhitelisted repos.
|
|
#[serde(default)]
|
|
pub read_only: bool,
|
|
}
|
|
|
|
impl ArchiveConfig {
|
|
/// Check if GRASP-05 is enabled (either archive_all, non-empty whitelist, or non-empty grasp_services)
|
|
pub fn enabled(&self) -> bool {
|
|
self.archive_all || !self.whitelist.is_empty() || !self.grasp_services.is_empty()
|
|
}
|
|
|
|
/// Check if an announcement matches the archive configuration
|
|
///
|
|
/// Returns true if:
|
|
/// - archive_all is true, OR
|
|
/// - announcement matches any whitelist entry
|
|
///
|
|
/// Note: grasp_services matching is handled via matches_grasp_services()
|
|
pub fn matches(&self, npub: &str, identifier: &str) -> bool {
|
|
if self.archive_all {
|
|
return true;
|
|
}
|
|
|
|
self.whitelist
|
|
.iter()
|
|
.any(|entry| entry.matches(npub, identifier))
|
|
}
|
|
|
|
/// Check if any of the given domains match the configured grasp_services
|
|
///
|
|
/// Returns true if any domain in the list matches any configured grasp_services entry.
|
|
pub fn matches_grasp_services(&self, domains: &[String]) -> bool {
|
|
if self.grasp_services.is_empty() {
|
|
return false;
|
|
}
|
|
|
|
domains
|
|
.iter()
|
|
.any(|domain| self.grasp_services.iter().any(|service| service == domain))
|
|
}
|
|
}
|
|
|
|
/// Repository whitelist configuration
|
|
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
|
|
pub struct RepositoryConfig {
|
|
/// Whitelist entries for selective repository acceptance
|
|
///
|
|
/// If empty, all repositories listing the service are accepted (GRASP-01 mode).
|
|
#[serde(default)]
|
|
pub whitelist: Vec<WhitelistEntry>,
|
|
}
|
|
|
|
impl RepositoryConfig {
|
|
/// Check if repository whitelist is enabled (non-empty whitelist)
|
|
pub fn enabled(&self) -> bool {
|
|
!self.whitelist.is_empty()
|
|
}
|
|
|
|
/// Check if an announcement matches the repository whitelist
|
|
///
|
|
/// Returns true if announcement matches any whitelist entry
|
|
pub fn matches(&self, npub: &str, identifier: &str) -> bool {
|
|
self.whitelist
|
|
.iter()
|
|
.any(|entry| entry.matches(npub, identifier))
|
|
}
|
|
}
|
|
|
|
/// Repository blacklist configuration
|
|
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
|
|
pub struct BlacklistConfig {
|
|
/// Blacklist entries for blocking specific repositories
|
|
///
|
|
/// If empty, no repositories are blacklisted.
|
|
/// Blacklist takes precedence over both archive and repository whitelists.
|
|
#[serde(default)]
|
|
pub blacklist: Vec<WhitelistEntry>,
|
|
}
|
|
|
|
impl BlacklistConfig {
|
|
/// Check if repository blacklist is enabled (non-empty blacklist)
|
|
pub fn enabled(&self) -> bool {
|
|
!self.blacklist.is_empty()
|
|
}
|
|
|
|
/// Check if an announcement matches the repository blacklist
|
|
///
|
|
/// Returns Some(reason) if blacklisted, None if not blacklisted.
|
|
/// The reason indicates what type of match occurred (npub, npub/identifier, or identifier).
|
|
pub fn check(&self, npub: &str, identifier: &str) -> Option<String> {
|
|
for entry in &self.blacklist {
|
|
if entry.matches(npub, identifier) {
|
|
let reason = match entry {
|
|
WhitelistEntry::Pubkey(_) => {
|
|
format!("Repository owner {} is blacklisted", npub)
|
|
}
|
|
WhitelistEntry::Repository { .. } => {
|
|
format!("Repository {}/{} is blacklisted", npub, identifier)
|
|
}
|
|
WhitelistEntry::Identifier(_) => {
|
|
format!("Repository identifier {} is blacklisted", identifier)
|
|
}
|
|
};
|
|
return Some(reason);
|
|
}
|
|
}
|
|
None
|
|
}
|
|
}
|
|
|
|
/// Event blacklist configuration for blocking events by author npub
|
|
#[derive(Debug, Clone, Serialize, Deserialize, Default)]
|
|
pub struct EventBlacklistConfig {
|
|
/// Blacklisted npubs - events from these authors are rejected
|
|
///
|
|
/// If empty, no events are blacklisted by author.
|
|
/// Applies to ALL event types, preventing events from reaching both the relay and purgatory.
|
|
#[serde(default)]
|
|
pub blacklisted_npubs: Vec<String>,
|
|
}
|
|
|
|
impl EventBlacklistConfig {
|
|
/// Check if event blacklist is enabled (non-empty blacklist)
|
|
pub fn enabled(&self) -> bool {
|
|
!self.blacklisted_npubs.is_empty()
|
|
}
|
|
|
|
/// Check if an event author is blacklisted
|
|
///
|
|
/// Returns Some(reason) if blacklisted, None if not blacklisted.
|
|
pub fn check(&self, npub: &str) -> Option<String> {
|
|
if self.blacklisted_npubs.contains(&npub.to_string()) {
|
|
Some(format!("Event author {} is blacklisted", npub))
|
|
} else {
|
|
None
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Database backend type for the relay
|
|
#[derive(Debug, Clone, Copy, Serialize, Deserialize, PartialEq, Eq, Default, ValueEnum)]
|
|
#[serde(rename_all = "lowercase")]
|
|
pub enum DatabaseBackend {
|
|
/// LMDB backend (persistent, general purpose)
|
|
#[default]
|
|
Lmdb,
|
|
/// In-memory database (fastest, no persistence - uses temp directory for git data)
|
|
Memory,
|
|
}
|
|
|
|
impl std::fmt::Display for DatabaseBackend {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
|
match self {
|
|
Self::Memory => write!(f, "memory"),
|
|
Self::Lmdb => write!(f, "lmdb"),
|
|
}
|
|
}
|
|
}
|
|
|
|
/// ngit-grasp - A GRASP (Git Relays Authorized via Signed-Nostr Proofs) implementation
|
|
///
|
|
/// Configuration is loaded with the following priority (highest to lowest):
|
|
/// 1. CLI flags (e.g., --domain example.com)
|
|
/// 2. Environment variables (e.g., NGIT_DOMAIN=example.com)
|
|
/// 3. .env file (loaded automatically if present)
|
|
/// 4. Built-in defaults
|
|
#[derive(Debug, Clone, Serialize, Deserialize, Parser)]
|
|
#[command(author, version, about, long_about = None)]
|
|
#[command(propagate_version = true)]
|
|
pub struct Config {
|
|
/// Domain where this instance is hosted (required, used in GRASP validation)
|
|
#[arg(long, env = "NGIT_DOMAIN")]
|
|
pub domain: String,
|
|
|
|
/// Relay operator's nsec (private key) for signing and authentication.
|
|
///
|
|
/// Used for:
|
|
/// - NIP-11 relay information document (pubkey field derived from this nsec)
|
|
/// - NIP-42 authentication when syncing from other relays
|
|
/// - Future: signing events, WoT-based rate limiting of syncing relays
|
|
///
|
|
/// Loaded from the `relay_owner_nsec` systemd credential,
|
|
/// `NGIT_RELAY_OWNER_NSEC`, or `.relay-owner.nsec`; never accepted on argv.
|
|
#[arg(skip)]
|
|
pub relay_owner_nsec: Option<String>,
|
|
|
|
/// Relay name for NIP-11 information document (defaults to "${domain} grasp relay")
|
|
#[arg(long = "relay-name", env = "NGIT_RELAY_NAME")]
|
|
pub relay_name_override: Option<String>,
|
|
|
|
/// Relay description for NIP-11 information document
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_RELAY_DESCRIPTION",
|
|
default_value = "Git Nostr Relay - a grasp implementation"
|
|
)]
|
|
pub relay_description: String,
|
|
|
|
/// Path to store Git repositories
|
|
#[arg(long, env = "NGIT_GIT_DATA_PATH", default_value = "./data/git")]
|
|
pub git_data_path: String,
|
|
|
|
/// Path to store Nostr relay data
|
|
#[arg(long, env = "NGIT_RELAY_DATA_PATH", default_value = "./data/relay")]
|
|
pub relay_data_path: String,
|
|
|
|
/// Server bind address (IP:PORT)
|
|
#[arg(long, env = "NGIT_BIND_ADDRESS", default_value = "127.0.0.1:7334")]
|
|
pub bind_address: String,
|
|
|
|
/// Proxy address ranges allowed to supply client IP forwarding headers.
|
|
///
|
|
/// Empty by default so forwarded headers from direct clients are ignored.
|
|
#[arg(long, env = "NGIT_TRUSTED_PROXY_CIDRS", value_delimiter = ',')]
|
|
pub trusted_proxy_cidrs: Vec<IpNet>,
|
|
|
|
/// Database backend type
|
|
#[arg(long, env = "NGIT_DATABASE_BACKEND", value_enum, default_value_t = DatabaseBackend::Lmdb)]
|
|
pub database_backend: DatabaseBackend,
|
|
|
|
/// Enable Prometheus metrics endpoint
|
|
#[arg(long, env = "NGIT_METRICS_ENABLED", default_value_t = true)]
|
|
pub metrics_enabled: bool,
|
|
|
|
/// Connections per IP before flagging as potential abuse in metrics (display only, no rate limiting)
|
|
#[arg(
|
|
long = "metrics-connection-per-ip-abuse-threshold",
|
|
env = "NGIT_METRICS_CONNECTION_PER_IP_ABUSE_THRESHOLD",
|
|
default_value_t = 10
|
|
)]
|
|
pub metrics_connection_per_ip_abuse_threshold: u32,
|
|
|
|
/// Number of top bandwidth repos to track in metrics
|
|
#[arg(
|
|
long = "metrics-top-n-repos",
|
|
env = "NGIT_METRICS_TOP_N_REPOS",
|
|
default_value_t = 10
|
|
)]
|
|
pub metrics_top_n_repos: usize,
|
|
|
|
/// URL of bootstrap relay to sync from on startup (optional)
|
|
/// Sync discovers additional relays from repository announcements that list our service
|
|
/// If no scheme is provided (wss:// or ws://), wss:// is assumed
|
|
/// Examples: "relay.example.com" -> "wss://relay.example.com", "wss://relay.example.com" -> unchanged
|
|
#[arg(long, env = "NGIT_SYNC_BOOTSTRAP_RELAY_URL")]
|
|
pub sync_bootstrap_relay_url: Option<String>,
|
|
|
|
/// Enable GRASP-03 Sync+ mailbox discovery on top of proactive GRASP-02 sync.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_SYNC_PLUS_ENABLED",
|
|
default_value_t = true,
|
|
action = clap::ArgAction::Set
|
|
)]
|
|
pub sync_plus_enabled: bool,
|
|
|
|
/// Comma-separated relays used to discover eligible accepted repository participants'
|
|
/// NIP-65 relay lists.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_USER_INDEX_RELAYS",
|
|
default_value = DEFAULT_USER_INDEX_RELAYS
|
|
)]
|
|
pub user_index_relays: String,
|
|
|
|
/// Comma-separated inbox fallbacks for eligible authors whose NIP-65 relay list is absent.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_SYNC_PLUS_FALLBACK_RELAYS",
|
|
default_value = DEFAULT_SYNC_PLUS_FALLBACK_RELAYS
|
|
)]
|
|
pub sync_plus_fallback_relays: String,
|
|
|
|
/// Maximum backoff time in seconds for sync relay reconnection (default: 3600 = 1 hour)
|
|
#[arg(long, env = "NGIT_SYNC_MAX_BACKOFF_SECS", default_value_t = 3600)]
|
|
pub sync_max_backoff_secs: u64,
|
|
|
|
/// Interval in seconds for checking disconnected relays and attempting reconnection (default: 60)
|
|
/// Set to lower value for faster reconnection testing
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_SYNC_DISCONNECT_CHECK_INTERVAL_SECS",
|
|
default_value_t = 60
|
|
)]
|
|
pub sync_disconnect_check_interval_secs: u64,
|
|
|
|
/// Base backoff time in seconds for relay reconnection (default: 5)
|
|
/// Used for exponential backoff: base * 2^(failures-1)
|
|
/// Set to 1 for faster test cycles
|
|
/// Note: The connection timeout is capped at this value
|
|
#[arg(long, env = "NGIT_SYNC_BASE_BACKOFF_SECS", default_value_t = 5)]
|
|
pub sync_base_backoff_secs: u64,
|
|
|
|
/// Disable NIP-77 negentropy sync (default: false)
|
|
/// When enabled, sync will use REQ+EOSE instead of negentropy for history sync.
|
|
/// Primarily useful for testing that sync works without negentropy support.
|
|
#[arg(long, env = "NGIT_SYNC_DISABLE_NEGENTROPY", default_value_t = false)]
|
|
pub sync_disable_negentropy: bool,
|
|
|
|
/// Allow event-directed sync targets that are not globally reachable (default: false)
|
|
///
|
|
/// Repository announcements and PR events are untrusted; by default their
|
|
/// relay and clone URLs may only point at globally reachable hosts.
|
|
/// Loopback, private, link-local and other special-purpose addresses,
|
|
/// local hostnames, and hosts resolving to such addresses are rejected
|
|
/// before any outbound connection or git fetch (SSRF protection).
|
|
///
|
|
/// Setting this to true disables the reachability checks. Intended only
|
|
/// for integration tests and closed development networks; production
|
|
/// relays must leave it false. The operator-configured bootstrap relay is
|
|
/// always allowed regardless of this setting.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_SYNC_ALLOW_NON_GLOBAL_TARGETS",
|
|
default_value_t = false
|
|
)]
|
|
pub sync_allow_non_global_targets: bool,
|
|
|
|
/// Hot cache duration in seconds for rejected announcements (default: 120 = 2 minutes)
|
|
/// Stores full event objects for immediate re-processing when dependencies resolve.
|
|
/// Too short (<30s): Miss events from slow relays
|
|
/// Too long (>5min): Waste memory
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_REJECTED_HOT_CACHE_DURATION_SECS",
|
|
default_value_t = 120
|
|
)]
|
|
pub rejected_hot_cache_duration_secs: u64,
|
|
|
|
/// Cold index expiry in seconds for rejected announcements (default: 604800 = 7 days)
|
|
/// Stores metadata only to prevent repeated downloads of rejected events.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_REJECTED_COLD_INDEX_EXPIRY_SECS",
|
|
default_value_t = 604800
|
|
)]
|
|
pub rejected_cold_index_expiry_secs: u64,
|
|
|
|
/// Hours before removing relay from naughty list (default: 12)
|
|
/// Relays with persistent infrastructure issues (DNS, TLS, protocol errors) are
|
|
/// tracked separately and retried after this expiration period.
|
|
#[arg(long, env = "NGIT_NAUGHTY_LIST_EXPIRATION_HOURS", default_value_t = 12)]
|
|
pub naughty_list_expiration_hours: u64,
|
|
|
|
/// Retention window in seconds for deleted events kept in holding DB.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_HOLDING_RETENTION_SECS",
|
|
default_value_t = crate::nostr::lifecycle::DEFAULT_RETENTION.as_secs()
|
|
)]
|
|
pub holding_retention_secs: u64,
|
|
|
|
/// Interval in seconds between background holding cleanup passes.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_HOLDING_CLEANUP_INTERVAL_SECS",
|
|
default_value_t = crate::nostr::lifecycle::DEFAULT_CLEANUP_INTERVAL.as_secs()
|
|
)]
|
|
pub holding_cleanup_interval_secs: u64,
|
|
|
|
// Retention is expressed in seconds for configuration consistency and short
|
|
// tests. Production deployments are expected to use periods of at least one
|
|
// day, comfortably exceeding worst-case deletion/archive processing time.
|
|
/// How long an unused deletion or vanish request remains served after relay-observed first_seen_at.
|
|
#[arg(
|
|
long = "deletion-request-retention-unused-served-secs",
|
|
env = "NGIT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS",
|
|
default_value_t = DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS
|
|
)]
|
|
pub deletion_request_retention_unused_served_secs: u64,
|
|
|
|
/// Additional time an unused deletion or vanish request remains unserved but eligible to gate.
|
|
#[arg(
|
|
long = "deletion-request-retention-unused-unserved-gating-additional-secs",
|
|
env = "NGIT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
default_value_t = DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS
|
|
)]
|
|
pub deletion_request_retention_unused_unserved_gating_additional_secs: u64,
|
|
|
|
/// Normal-mode time a used deletion or vanish request remains served after last_used_at.
|
|
#[arg(
|
|
long = "deletion-request-retention-used-served-after-last-used-secs",
|
|
env = "NGIT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS",
|
|
default_value_t = DEFAULT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS
|
|
)]
|
|
pub deletion_request_retention_used_served_after_last_used_secs: u64,
|
|
|
|
/// Additional normal-mode time a used request remains unserved but continues gating after serving ends.
|
|
#[arg(
|
|
long = "deletion-request-retention-used-unserved-gating-additional-secs",
|
|
env = "NGIT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
default_value_t = DEFAULT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS
|
|
)]
|
|
pub deletion_request_retention_used_unserved_gating_additional_secs: u64,
|
|
|
|
/// Enable GRASP-05 archive mode: accept all announcements regardless of listing (WARNING: storage risk)
|
|
#[arg(long, env = "NGIT_ARCHIVE_ALL", default_value_t = false)]
|
|
pub archive_all: bool,
|
|
|
|
/// GRASP-05 archive whitelist: comma-separated list of npub/identifier/npub/identifier entries
|
|
/// Formats: "npub1...", "npub1.../identifier", "identifier"
|
|
#[arg(long, env = "NGIT_ARCHIVE_WHITELIST", default_value = "")]
|
|
pub archive_whitelist: String,
|
|
|
|
/// GRASP-05 archive GRASP services: comma-separated list of GRASP server domains to archive
|
|
/// When set, archives all repositories from the specified GRASP server domains
|
|
/// Mutually exclusive with archive_all and archive_whitelist
|
|
#[arg(long, env = "NGIT_ARCHIVE_GRASP_SERVICES", default_value = "")]
|
|
pub archive_grasp_services: String,
|
|
|
|
/// Archive read-only mode: relay is a read-only sync of archived repositories
|
|
/// Defaults to true if archive_all, archive_whitelist, or archive_grasp_services is set, false otherwise
|
|
/// Throws error if set to true without archive_all, archive_whitelist, or archive_grasp_services
|
|
#[arg(long, env = "NGIT_ARCHIVE_READ_ONLY")]
|
|
pub archive_read_only: Option<bool>,
|
|
|
|
/// Enable GRASP-06 contributor PR submission endpoint at /prs/<npub>/<identifier>.git
|
|
///
|
|
/// When enabled, the relay exposes an unauthenticated PR submission endpoint
|
|
/// at `/prs/<npub>/<identifier>.git` that accepts pushes of `refs/nostr/<event-id>`
|
|
/// from any contributor. Security relies on the signed PR/PR-Update events
|
|
/// the refs reference, not on HTTP-level auth.
|
|
///
|
|
/// Default: false. This is an opt-in feature that adds an unauthenticated
|
|
/// write surface; operators must understand the tradeoffs (see GRASP-06 spec
|
|
/// and `docs/explanation/grasp-06-contributor-pr-submission.md`) before
|
|
/// enabling it.
|
|
#[arg(long, env = "NGIT_GRASP06_ENABLE", default_value_t = false)]
|
|
pub grasp06_enable: bool,
|
|
|
|
/// Repository whitelist: comma-separated list of npub/identifier/npub/identifier entries
|
|
/// Formats: "npub1...", "npub1.../identifier", "identifier"
|
|
/// When set, only announcements matching the whitelist AND listing the service are accepted
|
|
#[arg(long, env = "NGIT_REPOSITORY_WHITELIST", default_value = "")]
|
|
pub repository_whitelist: String,
|
|
|
|
/// Repository blacklist: comma-separated list of npub/identifier/npub/identifier entries to reject
|
|
/// Formats: "npub1...", "npub1.../identifier", "identifier"
|
|
/// Blacklist takes precedence over all whitelists (archive and repository)
|
|
#[arg(long, env = "NGIT_REPOSITORY_BLACKLIST", default_value = "")]
|
|
pub repository_blacklist: String,
|
|
|
|
/// Automatically restore blacklist-deleted repositories on startup when
|
|
/// they are no longer blacklisted and still within holding retention.
|
|
#[arg(long, env = "NGIT_BLACKLIST_AUTO_RESTORE", default_value_t = false)]
|
|
pub blacklist_auto_restore: bool,
|
|
|
|
/// Event blacklist: comma-separated list of npubs whose events are rejected
|
|
/// All events from these authors are blocked from both relay storage and purgatory
|
|
#[arg(long, env = "NGIT_EVENT_BLACKLIST", default_value = "")]
|
|
pub event_blacklist: String,
|
|
|
|
/// Deletion request disrespector: ignore NIP-09 and NIP-62 requests (archival mode)
|
|
///
|
|
/// When `true`, the relay stores incoming NIP-09 (kind 5) deletion requests and
|
|
/// NIP-62 request-to-vanish events but does NOT act on them: their targets remain
|
|
/// fully accessible. This makes the relay an archival server, preventing
|
|
/// "left-pad" scenarios by ensuring at least some relays preserve deleted content.
|
|
///
|
|
/// This setting ONLY affects NIP-09 and NIP-62 user-initiated requests.
|
|
/// Policy-driven blacklist/whitelist deletion flows still run because they
|
|
/// enforce local relay serving policy rather than client requests.
|
|
///
|
|
/// When `true`, NIP-09 (`"deletion"`) and NIP-62 (`"request to vanish"`) are NOT
|
|
/// advertised in the NIP-11 supported NIPs list so clients can discover that the
|
|
/// relay does not honour either request type.
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_DELETION_REQUEST_DISRESPECTOR",
|
|
default_value_t = false
|
|
)]
|
|
pub deletion_request_disrespector: bool,
|
|
|
|
/// Maximum total connections to the relay (default: unlimited, defers to OS/infrastructure limits)
|
|
#[arg(long, env = "NGIT_MAX_CONNECTIONS")]
|
|
pub max_connections: Option<usize>,
|
|
|
|
/// Maximum active REQ subscriptions per WebSocket connection
|
|
#[arg(long, env = "NGIT_RELAY_MAX_SUBSCRIPTIONS", default_value_t = 500)]
|
|
pub relay_max_subscriptions: usize,
|
|
|
|
/// Maximum serialized event size in bytes
|
|
#[arg(
|
|
long,
|
|
env = "NGIT_RELAY_MAX_EVENT_SIZE_BYTES",
|
|
default_value_t = 192 * 1024
|
|
)]
|
|
pub relay_max_event_size_bytes: usize,
|
|
|
|
/// Per-filter result cap, including when a filter omits limit
|
|
#[arg(long, env = "NGIT_RELAY_FILTER_LIMIT", default_value_t = 500)]
|
|
pub relay_filter_limit: usize,
|
|
|
|
/// Log level for application logging
|
|
#[arg(long, env = "NGIT_LOG_LEVEL", default_value = "info")]
|
|
pub log_level: String,
|
|
}
|
|
|
|
impl Config {
|
|
/// Path to the relay owner key file
|
|
const RELAY_OWNER_KEY_FILE: &'static str = ".relay-owner.nsec";
|
|
|
|
/// Load configuration from CLI args, environment variables, and defaults.
|
|
///
|
|
/// Priority (highest to lowest):
|
|
/// 1. CLI flags
|
|
/// 2. Environment variables
|
|
/// 3. .env file
|
|
/// 4. Built-in defaults
|
|
pub fn load() -> Result<Self> {
|
|
// Load .env file if present (before clap parses, so env vars are available)
|
|
dotenvy::dotenv().ok();
|
|
|
|
// Parse CLI args (clap automatically handles env var fallback)
|
|
let mut config = Self::parse();
|
|
|
|
config.relay_owner_nsec = Some(Self::load_relay_owner_key()?);
|
|
|
|
Ok(config)
|
|
}
|
|
|
|
/// Load the relay owner key without ever accepting the secret on argv.
|
|
///
|
|
/// A systemd credential is the most deliberate provision, followed by the
|
|
/// environment (including `.env` loaded by [`Self::load`]), then the
|
|
/// persistent `.relay-owner.nsec` file.
|
|
pub fn load_relay_owner_key() -> Result<String> {
|
|
let credentials_dir = std::env::var_os("CREDENTIALS_DIRECTORY").map(PathBuf::from);
|
|
let env_value = std::env::var(RELAY_OWNER_NSEC_ENV).ok();
|
|
Self::load_relay_owner_key_from_sources(
|
|
credentials_dir.as_deref(),
|
|
env_value,
|
|
Self::load_or_generate_relay_owner_key,
|
|
)
|
|
}
|
|
|
|
fn load_relay_owner_key_from_sources<F>(
|
|
credentials_dir: Option<&Path>,
|
|
env_value: Option<String>,
|
|
fallback: F,
|
|
) -> Result<String>
|
|
where
|
|
F: FnOnce() -> Result<String>,
|
|
{
|
|
if let Some(dir) = credentials_dir {
|
|
if let Some(nsec) = Self::load_relay_owner_key_credential_from_dir(dir)? {
|
|
Self::validate_relay_owner_nsec(&nsec, "relay_owner_nsec credential")?;
|
|
tracing::info!(
|
|
credential = RELAY_OWNER_NSEC_CREDENTIAL,
|
|
"Loaded relay owner key"
|
|
);
|
|
return Ok(nsec);
|
|
}
|
|
}
|
|
|
|
if let Some(nsec) = Self::relay_owner_key_from_env_value(env_value)? {
|
|
Self::validate_relay_owner_nsec(&nsec, RELAY_OWNER_NSEC_ENV)?;
|
|
tracing::info!(env = RELAY_OWNER_NSEC_ENV, "Loaded relay owner key");
|
|
return Ok(nsec);
|
|
}
|
|
|
|
fallback()
|
|
}
|
|
|
|
fn load_relay_owner_key_credential_from_dir(dir: &Path) -> Result<Option<String>> {
|
|
let key_path = dir.join(RELAY_OWNER_NSEC_CREDENTIAL);
|
|
if !key_path.exists() {
|
|
return Ok(None);
|
|
}
|
|
if !key_path
|
|
.metadata()
|
|
.with_context(|| format!("stat relay owner credential '{}'", key_path.display()))?
|
|
.is_file()
|
|
{
|
|
return Err(anyhow!(
|
|
"Relay owner credential '{}' is not a regular file",
|
|
key_path.display()
|
|
));
|
|
}
|
|
let nsec = fs::read_to_string(&key_path)
|
|
.with_context(|| format!("read relay owner credential '{}'", key_path.display()))?
|
|
.trim()
|
|
.to_string();
|
|
if nsec.is_empty() {
|
|
return Err(anyhow!(
|
|
"Relay owner credential '{}' is empty",
|
|
key_path.display()
|
|
));
|
|
}
|
|
Ok(Some(nsec))
|
|
}
|
|
|
|
fn relay_owner_key_from_env_value(value: Option<String>) -> Result<Option<String>> {
|
|
let Some(raw) = value else {
|
|
return Ok(None);
|
|
};
|
|
let nsec = raw.trim().to_string();
|
|
if nsec.is_empty() {
|
|
return Err(anyhow!(
|
|
"{RELAY_OWNER_NSEC_ENV} is set but empty; unset it to load/generate \
|
|
{key_file}, or provide a valid nsec",
|
|
key_file = Self::RELAY_OWNER_KEY_FILE
|
|
));
|
|
}
|
|
Ok(Some(nsec))
|
|
}
|
|
|
|
fn validate_relay_owner_nsec(nsec: &str, source: &str) -> Result<()> {
|
|
Keys::parse(nsec).with_context(|| format!("Invalid relay owner nsec in {source}"))?;
|
|
Ok(())
|
|
}
|
|
|
|
/// Load relay owner key from file, or generate and save a new one
|
|
pub fn load_or_generate_relay_owner_key() -> Result<String> {
|
|
let key_path = PathBuf::from(Self::RELAY_OWNER_KEY_FILE);
|
|
Self::load_or_generate_relay_owner_key_at(&key_path)
|
|
}
|
|
|
|
fn load_or_generate_relay_owner_key_at(key_path: &Path) -> Result<String> {
|
|
// Try to load existing key
|
|
if key_path.exists() {
|
|
secure_secret_file_permissions(key_path).with_context(|| {
|
|
format!(
|
|
"Failed to secure relay owner key file {}",
|
|
key_path.display()
|
|
)
|
|
})?;
|
|
|
|
let nsec = fs::read_to_string(key_path)
|
|
.context("Failed to read relay owner key file")?
|
|
.trim()
|
|
.to_string();
|
|
|
|
Self::validate_relay_owner_nsec(
|
|
&nsec,
|
|
&format!("relay owner key file {}", key_path.display()),
|
|
)?;
|
|
|
|
tracing::info!("Loaded relay owner key from {}", key_path.display());
|
|
return Ok(nsec);
|
|
}
|
|
|
|
// Generate new key
|
|
let keys = Keys::generate();
|
|
let nsec = keys.secret_key().to_bech32()?;
|
|
|
|
write_secret_file(key_path, &nsec).context("Failed to write relay owner key file")?;
|
|
|
|
tracing::info!(
|
|
"Generated new relay owner key and saved to {}",
|
|
key_path.display()
|
|
);
|
|
|
|
Ok(nsec)
|
|
}
|
|
|
|
/// Get the relay owner's Keys object
|
|
pub fn relay_owner_keys(&self) -> Result<Keys> {
|
|
let nsec = self
|
|
.relay_owner_nsec
|
|
.as_ref()
|
|
.context("relay_owner_nsec not set (should be set by Config::load())")?;
|
|
Keys::parse(nsec).context("Invalid relay_owner_nsec")
|
|
}
|
|
|
|
/// Get the relay owner's public key (hex format) for NIP-11
|
|
pub fn relay_owner_pubkey_hex(&self) -> Result<String> {
|
|
let keys = self.relay_owner_keys()?;
|
|
Ok(keys.public_key().to_hex())
|
|
}
|
|
|
|
/// Get the relay owner's public key (npub format)
|
|
pub fn relay_owner_npub(&self) -> Result<String> {
|
|
let keys = self.relay_owner_keys()?;
|
|
Ok(keys.public_key().to_bech32()?)
|
|
}
|
|
|
|
/// Get relay name (defaults to "${domain} grasp relay" if not set)
|
|
pub fn relay_name(&self) -> String {
|
|
self.relay_name_override
|
|
.clone()
|
|
.unwrap_or_else(|| format!("{} grasp relay", self.domain))
|
|
}
|
|
|
|
/// Get effective git data path
|
|
/// Returns a temp directory when using memory backend with default path, otherwise the configured path
|
|
pub fn effective_git_data_path(&self) -> String {
|
|
if self.database_backend == DatabaseBackend::Memory && self.git_data_path == "./data/git" {
|
|
// Only use default temp directory if git_data_path is still the default value
|
|
std::env::temp_dir()
|
|
.join("ngit-grasp-git")
|
|
.to_string_lossy()
|
|
.into_owned()
|
|
} else {
|
|
self.git_data_path.clone()
|
|
}
|
|
}
|
|
|
|
/// Validate configuration and return fatal errors
|
|
///
|
|
/// This should be called immediately after Config::load() to fail fast on config errors.
|
|
/// Recoverable issues (e.g., malformed whitelist entries) are logged as warnings and skipped.
|
|
pub fn validate(&self) -> Result<()> {
|
|
// Validate relay owner nsec (should always be set by Config::load())
|
|
let nsec = self
|
|
.relay_owner_nsec
|
|
.as_ref()
|
|
.context("relay_owner_nsec not set (should be set by Config::load())")?;
|
|
Keys::parse(nsec).context("Invalid relay_owner_nsec format")?;
|
|
|
|
// Validate archive configuration
|
|
let archive_whitelist = WhitelistEntry::parse_whitelist(&self.archive_whitelist);
|
|
let archive_grasp_services = self.parse_archive_grasp_services();
|
|
let archive_enabled =
|
|
self.archive_all || !archive_whitelist.is_empty() || !archive_grasp_services.is_empty();
|
|
|
|
// Fatal error: archive_grasp_services cannot be used with archive_all or archive_whitelist
|
|
if !archive_grasp_services.is_empty() {
|
|
if self.archive_all {
|
|
return Err(anyhow!(
|
|
"NGIT_ARCHIVE_GRASP_SERVICES cannot be used with NGIT_ARCHIVE_ALL=true. \
|
|
These options are mutually exclusive."
|
|
));
|
|
}
|
|
if !archive_whitelist.is_empty() {
|
|
return Err(anyhow!(
|
|
"NGIT_ARCHIVE_GRASP_SERVICES cannot be used with NGIT_ARCHIVE_WHITELIST. \
|
|
These options are mutually exclusive."
|
|
));
|
|
}
|
|
}
|
|
|
|
// Fatal error: archive_read_only=true without archive mode enabled
|
|
if let Some(true) = self.archive_read_only {
|
|
if !archive_enabled {
|
|
return Err(anyhow!(
|
|
"NGIT_ARCHIVE_READ_ONLY=true requires either NGIT_ARCHIVE_ALL=true, \
|
|
NGIT_ARCHIVE_WHITELIST, or NGIT_ARCHIVE_GRASP_SERVICES to be set"
|
|
));
|
|
}
|
|
}
|
|
|
|
// Validate repository whitelist configuration
|
|
let repository_whitelist = WhitelistEntry::parse_whitelist(&self.repository_whitelist);
|
|
|
|
if self.holding_retention_secs == 0 {
|
|
return Err(anyhow!(
|
|
"NGIT_HOLDING_RETENTION_SECS must be greater than 0"
|
|
));
|
|
}
|
|
|
|
if self.holding_cleanup_interval_secs == 0 {
|
|
return Err(anyhow!(
|
|
"NGIT_HOLDING_CLEANUP_INTERVAL_SECS must be greater than 0"
|
|
));
|
|
}
|
|
|
|
Self::validate_deletion_request_retention_duration(
|
|
self.deletion_request_retention_unused_served_secs,
|
|
"NGIT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS",
|
|
)?;
|
|
Self::validate_deletion_request_retention_duration(
|
|
self.deletion_request_retention_unused_unserved_gating_additional_secs,
|
|
"NGIT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
)?;
|
|
Self::validate_deletion_request_retention_duration(
|
|
self.deletion_request_retention_used_served_after_last_used_secs,
|
|
"NGIT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS",
|
|
)?;
|
|
Self::validate_deletion_request_retention_duration(
|
|
self.deletion_request_retention_used_unserved_gating_additional_secs,
|
|
"NGIT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
)?;
|
|
|
|
Self::validate_deletion_request_retention_deadline(
|
|
self.deletion_request_retention_unused_served_secs,
|
|
self.deletion_request_retention_unused_unserved_gating_additional_secs,
|
|
"unused",
|
|
)?;
|
|
Self::validate_deletion_request_retention_deadline(
|
|
self.deletion_request_retention_used_served_after_last_used_secs,
|
|
self.deletion_request_retention_used_unserved_gating_additional_secs,
|
|
"used",
|
|
)?;
|
|
|
|
let relay_limits = [
|
|
("NGIT_RELAY_MAX_SUBSCRIPTIONS", self.relay_max_subscriptions),
|
|
(
|
|
"NGIT_RELAY_MAX_EVENT_SIZE_BYTES",
|
|
self.relay_max_event_size_bytes,
|
|
),
|
|
("NGIT_RELAY_FILTER_LIMIT", self.relay_filter_limit),
|
|
];
|
|
if let Some((name, _)) = relay_limits.iter().find(|(_, value)| *value == 0) {
|
|
return Err(anyhow!("{name} must be greater than 0"));
|
|
}
|
|
|
|
if self.relay_max_event_size_bytes > 5 * 1024 * 1024 {
|
|
return Err(anyhow!(
|
|
"NGIT_RELAY_MAX_EVENT_SIZE_BYTES must not exceed the 5 MiB WebSocket message limit"
|
|
));
|
|
}
|
|
|
|
// Fatal error: repository_whitelist with archive_read_only=true (incompatible)
|
|
if !repository_whitelist.is_empty() {
|
|
let read_only = self.archive_read_only.unwrap_or(archive_enabled);
|
|
if read_only {
|
|
return Err(anyhow!(
|
|
"NGIT_REPOSITORY_WHITELIST cannot be used with NGIT_ARCHIVE_READ_ONLY=true. \
|
|
Archive read-only mode rejects announcements that don't match the archive whitelist, \
|
|
regardless of service listing. Either set NGIT_ARCHIVE_READ_ONLY=false or use \
|
|
NGIT_ARCHIVE_WHITELIST instead of NGIT_REPOSITORY_WHITELIST."
|
|
));
|
|
}
|
|
}
|
|
|
|
Ok(())
|
|
}
|
|
|
|
/// Parse archive GRASP services from comma-separated string
|
|
///
|
|
/// Returns a list of domain names (GRASP server domains to archive).
|
|
/// Whitespace is trimmed and empty entries are ignored.
|
|
pub fn parse_archive_grasp_services(&self) -> Vec<String> {
|
|
if self.archive_grasp_services.trim().is_empty() {
|
|
return Vec::new();
|
|
}
|
|
|
|
self.archive_grasp_services
|
|
.split(',')
|
|
.map(|s| s.trim())
|
|
.filter(|s| !s.is_empty())
|
|
.map(|s| s.to_string())
|
|
.collect()
|
|
}
|
|
|
|
/// Parse the comma-separated user-index relay URLs.
|
|
pub fn parse_user_index_relays(&self) -> Vec<String> {
|
|
self.user_index_relays
|
|
.split(',')
|
|
.map(str::trim)
|
|
.filter(|relay| !relay.is_empty())
|
|
.map(str::to_owned)
|
|
.collect()
|
|
}
|
|
|
|
/// Parse the comma-separated Sync+ fallback relay URLs.
|
|
pub fn parse_sync_plus_fallback_relays(&self) -> Vec<String> {
|
|
self.sync_plus_fallback_relays
|
|
.split(',')
|
|
.map(str::trim)
|
|
.filter(|relay| !relay.is_empty())
|
|
.map(str::to_owned)
|
|
.collect()
|
|
}
|
|
|
|
/// Get parsed archive configuration with computed read-only mode
|
|
///
|
|
/// Read-only mode defaults to true if archive mode is enabled, false otherwise.
|
|
/// This method assumes config has been validated - call Config::validate() first!
|
|
pub fn archive_config(&self) -> ArchiveConfig {
|
|
let whitelist = WhitelistEntry::parse_whitelist(&self.archive_whitelist);
|
|
let archive_grasp_services = self.parse_archive_grasp_services();
|
|
let archive_enabled =
|
|
self.archive_all || !whitelist.is_empty() || !archive_grasp_services.is_empty();
|
|
|
|
let read_only = match self.archive_read_only {
|
|
Some(true) => true, // Already validated in validate()
|
|
Some(false) => false,
|
|
None => {
|
|
// Default: true if archive mode enabled, false otherwise
|
|
archive_enabled
|
|
}
|
|
};
|
|
|
|
ArchiveConfig {
|
|
archive_all: self.archive_all,
|
|
whitelist,
|
|
grasp_services: archive_grasp_services,
|
|
read_only,
|
|
}
|
|
}
|
|
|
|
/// Get parsed repository whitelist configuration
|
|
///
|
|
/// This method assumes config has been validated - call Config::validate() first!
|
|
pub fn repository_config(&self) -> RepositoryConfig {
|
|
let whitelist = WhitelistEntry::parse_whitelist(&self.repository_whitelist);
|
|
RepositoryConfig { whitelist }
|
|
}
|
|
|
|
/// Get parsed repository blacklist configuration
|
|
///
|
|
/// This method assumes config has been validated - call Config::validate() first!
|
|
pub fn blacklist_config(&self) -> BlacklistConfig {
|
|
let blacklist = WhitelistEntry::parse_whitelist(&self.repository_blacklist);
|
|
BlacklistConfig { blacklist }
|
|
}
|
|
|
|
/// Get parsed event blacklist configuration
|
|
///
|
|
/// This method assumes config has been validated - call Config::validate() first!
|
|
pub fn event_blacklist_config(&self) -> EventBlacklistConfig {
|
|
let blacklisted_npubs: Vec<String> = self
|
|
.event_blacklist
|
|
.split(',')
|
|
.map(|s| s.trim())
|
|
.filter(|s| !s.is_empty())
|
|
.map(|s| s.to_string())
|
|
.collect();
|
|
EventBlacklistConfig { blacklisted_npubs }
|
|
}
|
|
|
|
/// Holding DB retention as a duration.
|
|
pub fn holding_retention(&self) -> Duration {
|
|
Duration::from_secs(self.holding_retention_secs)
|
|
}
|
|
|
|
/// Holding DB periodic cleanup interval as a duration.
|
|
pub fn holding_cleanup_interval(&self) -> Duration {
|
|
Duration::from_secs(self.holding_cleanup_interval_secs)
|
|
}
|
|
|
|
/// How long an unused request remains served from relay-observed first_seen_at.
|
|
pub fn deletion_request_retention_unused_served(&self) -> Duration {
|
|
Duration::from_secs(self.deletion_request_retention_unused_served_secs)
|
|
}
|
|
|
|
/// Additional time an unused request remains unserved but eligible to gate.
|
|
pub fn deletion_request_retention_unused_unserved_gating_additional(&self) -> Duration {
|
|
Duration::from_secs(self.deletion_request_retention_unused_unserved_gating_additional_secs)
|
|
}
|
|
|
|
/// Normal-mode time a used request remains served after last_used_at.
|
|
pub fn deletion_request_retention_used_served_after_last_used(&self) -> Duration {
|
|
Duration::from_secs(self.deletion_request_retention_used_served_after_last_used_secs)
|
|
}
|
|
|
|
/// Additional normal-mode time a used request remains unserved but continues gating.
|
|
pub fn deletion_request_retention_used_unserved_gating_additional(&self) -> Duration {
|
|
Duration::from_secs(self.deletion_request_retention_used_unserved_gating_additional_secs)
|
|
}
|
|
|
|
fn validate_deletion_request_retention_duration(value: u64, name: &str) -> Result<()> {
|
|
if value == 0 {
|
|
return Err(anyhow!("{name} must be greater than 0"));
|
|
}
|
|
Ok(())
|
|
}
|
|
|
|
fn validate_deletion_request_retention_deadline(
|
|
served_secs: u64,
|
|
additional_gating_secs: u64,
|
|
lifecycle: &str,
|
|
) -> Result<()> {
|
|
if served_secs.checked_add(additional_gating_secs).is_none() {
|
|
return Err(anyhow!(
|
|
"{lifecycle} deletion-request retention served and additional gating durations must not overflow when combined"
|
|
));
|
|
}
|
|
Ok(())
|
|
}
|
|
|
|
/// Create config for testing
|
|
#[cfg(test)]
|
|
pub fn for_testing() -> Self {
|
|
// Generate a test key deterministically for consistent tests
|
|
let keys = Keys::generate();
|
|
let nsec = keys
|
|
.secret_key()
|
|
.to_bech32()
|
|
.expect("Failed to generate test nsec");
|
|
|
|
Self {
|
|
domain: "localhost:7334".to_string(),
|
|
relay_owner_nsec: Some(nsec),
|
|
relay_name_override: Some("test relay".to_string()),
|
|
relay_description: "test description".to_string(),
|
|
git_data_path: "./test_data/git".to_string(),
|
|
relay_data_path: "./test_data/relay".to_string(),
|
|
bind_address: "127.0.0.1:7334".to_string(),
|
|
trusted_proxy_cidrs: Vec::new(),
|
|
database_backend: DatabaseBackend::Memory,
|
|
metrics_enabled: true,
|
|
metrics_connection_per_ip_abuse_threshold: 10,
|
|
metrics_top_n_repos: 10,
|
|
sync_bootstrap_relay_url: None,
|
|
sync_plus_enabled: true,
|
|
user_index_relays: DEFAULT_USER_INDEX_RELAYS.to_string(),
|
|
sync_plus_fallback_relays: DEFAULT_SYNC_PLUS_FALLBACK_RELAYS.to_string(),
|
|
sync_max_backoff_secs: 3600,
|
|
sync_disconnect_check_interval_secs: 60,
|
|
sync_base_backoff_secs: 5,
|
|
sync_disable_negentropy: false,
|
|
sync_allow_non_global_targets: false,
|
|
rejected_hot_cache_duration_secs: 120,
|
|
rejected_cold_index_expiry_secs: 604800,
|
|
naughty_list_expiration_hours: 12,
|
|
holding_retention_secs: crate::nostr::lifecycle::DEFAULT_RETENTION.as_secs(),
|
|
holding_cleanup_interval_secs: crate::nostr::lifecycle::DEFAULT_CLEANUP_INTERVAL
|
|
.as_secs(),
|
|
deletion_request_retention_unused_served_secs:
|
|
DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS,
|
|
deletion_request_retention_unused_unserved_gating_additional_secs:
|
|
DEFAULT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS,
|
|
deletion_request_retention_used_served_after_last_used_secs:
|
|
DEFAULT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS,
|
|
deletion_request_retention_used_unserved_gating_additional_secs:
|
|
DEFAULT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS,
|
|
archive_all: false,
|
|
archive_whitelist: String::new(),
|
|
archive_grasp_services: String::new(),
|
|
archive_read_only: None,
|
|
grasp06_enable: false,
|
|
repository_whitelist: String::new(),
|
|
repository_blacklist: String::new(),
|
|
blacklist_auto_restore: false,
|
|
event_blacklist: String::new(),
|
|
deletion_request_disrespector: false,
|
|
max_connections: None,
|
|
relay_max_subscriptions: 500,
|
|
relay_max_event_size_bytes: 192 * 1024,
|
|
relay_filter_limit: 500,
|
|
log_level: "debug".to_string(),
|
|
}
|
|
}
|
|
}
|
|
|
|
fn write_secret_file(path: &Path, contents: &str) -> Result<()> {
|
|
let mut options = fs::OpenOptions::new();
|
|
options.write(true).create_new(true);
|
|
#[cfg(unix)]
|
|
{
|
|
use std::os::unix::fs::OpenOptionsExt;
|
|
options.mode(0o600);
|
|
}
|
|
|
|
let mut file = options.open(path)?;
|
|
file.write_all(contents.as_bytes())?;
|
|
Ok(())
|
|
}
|
|
|
|
fn secure_secret_file_permissions(path: &Path) -> Result<()> {
|
|
#[cfg(unix)]
|
|
{
|
|
use std::os::unix::fs::PermissionsExt;
|
|
|
|
let metadata = fs::metadata(path)
|
|
.with_context(|| format!("Failed to inspect secret file {}", path.display()))?;
|
|
let mut permissions = metadata.permissions();
|
|
if permissions.mode() & 0o777 != 0o600 {
|
|
permissions.set_mode(0o600);
|
|
fs::set_permissions(path, permissions).with_context(|| {
|
|
format!(
|
|
"Failed to restrict secret file {} to mode 0600",
|
|
path.display()
|
|
)
|
|
})?;
|
|
}
|
|
}
|
|
|
|
#[cfg(not(unix))]
|
|
let _ = path;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod tests {
|
|
use super::*;
|
|
use std::net::IpAddr;
|
|
use std::sync::Mutex;
|
|
|
|
static CONFIG_ENV_LOCK: Mutex<()> = Mutex::new(());
|
|
|
|
#[test]
|
|
fn test_default_values() {
|
|
let config = Config::for_testing();
|
|
assert_eq!(config.domain, "localhost:7334");
|
|
assert_eq!(config.bind_address, "127.0.0.1:7334");
|
|
assert!(config.trusted_proxy_cidrs.is_empty());
|
|
// for_testing() uses Memory, but the actual default is Lmdb
|
|
assert_eq!(config.database_backend, DatabaseBackend::Memory);
|
|
}
|
|
|
|
#[test]
|
|
fn test_trusted_proxy_cidrs_parse_from_cli() {
|
|
let config = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--trusted-proxy-cidrs",
|
|
"127.0.0.1/32,10.0.0.0/8,2001:db8::/32",
|
|
])
|
|
.expect("trusted proxy CIDRs should parse");
|
|
|
|
assert_eq!(config.trusted_proxy_cidrs.len(), 3);
|
|
assert!(config.trusted_proxy_cidrs[0].contains(&"127.0.0.1".parse::<IpAddr>().unwrap()));
|
|
assert!(config.trusted_proxy_cidrs[1].contains(&"10.2.3.4".parse::<IpAddr>().unwrap()));
|
|
assert!(config.trusted_proxy_cidrs[2].contains(&"2001:db8::1".parse::<IpAddr>().unwrap()));
|
|
}
|
|
|
|
#[test]
|
|
fn test_trusted_proxy_cidrs_reject_invalid_networks() {
|
|
let error = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--trusted-proxy-cidrs",
|
|
"127.0.0.1/32,not-a-network",
|
|
])
|
|
.expect_err("invalid trusted proxy CIDRs must stop startup");
|
|
|
|
assert!(error.to_string().contains("not-a-network"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_trusted_proxy_cidrs_parse_from_environment() {
|
|
const VARIABLE: &str = "NGIT_TRUSTED_PROXY_CIDRS";
|
|
let _environment_guard = CONFIG_ENV_LOCK.lock().expect("lock must not be poisoned");
|
|
let original = std::env::var_os(VARIABLE);
|
|
std::env::set_var(VARIABLE, "127.0.0.1/32,::1/128");
|
|
|
|
let result = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"]);
|
|
|
|
match original {
|
|
Some(value) => std::env::set_var(VARIABLE, value),
|
|
None => std::env::remove_var(VARIABLE),
|
|
}
|
|
|
|
let config = result.expect("trusted proxy CIDRs should parse from the environment");
|
|
assert_eq!(config.trusted_proxy_cidrs.len(), 2);
|
|
}
|
|
|
|
#[test]
|
|
fn relay_hardening_defaults_are_explicit() {
|
|
let config = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("relay hardening defaults should parse");
|
|
|
|
assert_eq!(config.relay_max_subscriptions, 500);
|
|
assert_eq!(config.relay_max_event_size_bytes, 192 * 1024);
|
|
assert_eq!(config.relay_filter_limit, 500);
|
|
}
|
|
|
|
#[test]
|
|
fn user_index_relay_defaults_are_explicit() {
|
|
let config = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("user-index relay defaults should parse");
|
|
|
|
assert_eq!(
|
|
config.parse_user_index_relays(),
|
|
vec![
|
|
"wss://purplepag.es",
|
|
"wss://index.hzrd149.com",
|
|
"wss://indexer.coracle.social",
|
|
]
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn sync_plus_fallback_defaults_and_empty_override_are_explicit() {
|
|
let default = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("Sync+ fallback defaults should parse");
|
|
assert_eq!(
|
|
default.parse_sync_plus_fallback_relays(),
|
|
vec![
|
|
"wss://relay.ditto.pub",
|
|
"wss://relay.damus.io",
|
|
"wss://nos.lol",
|
|
"wss://relay.primal.net",
|
|
]
|
|
);
|
|
|
|
let disabled = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--sync-plus-fallback-relays=",
|
|
])
|
|
.expect("empty Sync+ fallback override should parse");
|
|
assert!(disabled.parse_sync_plus_fallback_relays().is_empty());
|
|
}
|
|
|
|
#[test]
|
|
fn sync_plus_is_enabled_by_default_and_can_be_disabled() {
|
|
let default = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("Sync+ default should parse");
|
|
assert!(default.sync_plus_enabled);
|
|
|
|
let disabled = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--sync-plus-enabled=false",
|
|
])
|
|
.expect("Sync+ opt-out should parse");
|
|
assert!(!disabled.sync_plus_enabled);
|
|
}
|
|
|
|
#[test]
|
|
fn user_index_relays_parse_cli_list_and_ignore_empty_entries() {
|
|
let config = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--user-index-relays",
|
|
" wss://one.example ,, wss://two.example, ",
|
|
])
|
|
.expect("user-index relay override should parse");
|
|
|
|
assert_eq!(
|
|
config.parse_user_index_relays(),
|
|
vec!["wss://one.example", "wss://two.example"]
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn event_limit_cannot_exceed_websocket_limit() {
|
|
let mut config = Config::for_testing();
|
|
config.relay_max_event_size_bytes = 5 * 1024 * 1024 + 1;
|
|
|
|
let error = config
|
|
.validate()
|
|
.expect_err("inconsistent size limits must fail");
|
|
assert!(error
|
|
.to_string()
|
|
.contains("NGIT_RELAY_MAX_EVENT_SIZE_BYTES must not exceed"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_retention_cli_defaults() {
|
|
let _environment_guard = CONFIG_ENV_LOCK.lock().expect("lock must not be poisoned");
|
|
let config = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("default deletion-request retention configuration should parse");
|
|
|
|
assert_eq!(
|
|
config.deletion_request_retention_unused_served(),
|
|
Duration::from_secs(2_592_000)
|
|
);
|
|
assert_eq!(
|
|
config.deletion_request_retention_unused_unserved_gating_additional(),
|
|
Duration::from_secs(15_552_000)
|
|
);
|
|
assert_eq!(
|
|
config.deletion_request_retention_used_served_after_last_used(),
|
|
Duration::from_secs(23_328_000)
|
|
);
|
|
assert_eq!(
|
|
config.deletion_request_retention_used_unserved_gating_additional(),
|
|
Duration::from_secs(7_776_000)
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_retention_cli_overrides() {
|
|
let config = Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--deletion-request-retention-unused-served-secs",
|
|
"1",
|
|
"--deletion-request-retention-unused-unserved-gating-additional-secs",
|
|
"2",
|
|
"--deletion-request-retention-used-served-after-last-used-secs",
|
|
"3",
|
|
"--deletion-request-retention-used-unserved-gating-additional-secs",
|
|
"4",
|
|
])
|
|
.expect("custom deletion-request retention configuration should parse");
|
|
|
|
assert_eq!(config.deletion_request_retention_unused_served_secs, 1);
|
|
assert_eq!(
|
|
config.deletion_request_retention_unused_unserved_gating_additional_secs,
|
|
2
|
|
);
|
|
assert_eq!(
|
|
config.deletion_request_retention_used_served_after_last_used_secs,
|
|
3
|
|
);
|
|
assert_eq!(
|
|
config.deletion_request_retention_used_unserved_gating_additional_secs,
|
|
4
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_retention_environment_override() {
|
|
let _environment_guard = CONFIG_ENV_LOCK.lock().expect("lock must not be poisoned");
|
|
const VARIABLE: &str = "NGIT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS";
|
|
let original = std::env::var_os(VARIABLE);
|
|
std::env::set_var(VARIABLE, "42");
|
|
|
|
let config = Config::try_parse_from(["ngit-grasp", "--domain", "example.com"])
|
|
.expect("environment deletion-request retention configuration should parse");
|
|
|
|
match original {
|
|
Some(value) => std::env::set_var(VARIABLE, value),
|
|
None => std::env::remove_var(VARIABLE),
|
|
}
|
|
|
|
assert_eq!(config.deletion_request_retention_unused_served_secs, 42);
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_retention_rejects_zero_durations() {
|
|
let cases = [
|
|
(
|
|
"NGIT_DELETION_REQUEST_RETENTION_UNUSED_SERVED_SECS",
|
|
Config {
|
|
deletion_request_retention_unused_served_secs: 0,
|
|
..Config::for_testing()
|
|
},
|
|
),
|
|
(
|
|
"NGIT_DELETION_REQUEST_RETENTION_UNUSED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
Config {
|
|
deletion_request_retention_unused_unserved_gating_additional_secs: 0,
|
|
..Config::for_testing()
|
|
},
|
|
),
|
|
(
|
|
"NGIT_DELETION_REQUEST_RETENTION_USED_SERVED_AFTER_LAST_USED_SECS",
|
|
Config {
|
|
deletion_request_retention_used_served_after_last_used_secs: 0,
|
|
..Config::for_testing()
|
|
},
|
|
),
|
|
(
|
|
"NGIT_DELETION_REQUEST_RETENTION_USED_UNSERVED_GATING_ADDITIONAL_SECS",
|
|
Config {
|
|
deletion_request_retention_used_unserved_gating_additional_secs: 0,
|
|
..Config::for_testing()
|
|
},
|
|
),
|
|
];
|
|
|
|
for (variable, config) in cases {
|
|
let error = config.validate().expect_err("zero duration must fail");
|
|
assert!(error.to_string().contains(variable));
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_retention_rejects_deadline_overflow() {
|
|
let config = Config {
|
|
deletion_request_retention_unused_served_secs: u64::MAX,
|
|
deletion_request_retention_unused_unserved_gating_additional_secs: 1,
|
|
..Config::for_testing()
|
|
};
|
|
|
|
let error = config
|
|
.validate()
|
|
.expect_err("combined duration overflow must fail");
|
|
assert!(error
|
|
.to_string()
|
|
.contains("unused deletion-request retention"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_lmdb_is_default() {
|
|
// Verify the actual default via the enum's Default trait
|
|
assert_eq!(DatabaseBackend::default(), DatabaseBackend::Lmdb);
|
|
}
|
|
|
|
#[test]
|
|
fn test_memory_backend_uses_temp_dir_with_default_path() {
|
|
// When git_data_path is the default value, memory backend uses temp dir
|
|
let config = Config {
|
|
database_backend: DatabaseBackend::Memory,
|
|
git_data_path: "./data/git".to_string(), // Default value
|
|
..Config::for_testing()
|
|
};
|
|
let git_path = config.effective_git_data_path();
|
|
assert!(git_path.contains("ngit-grasp-git"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_memory_backend_respects_custom_path() {
|
|
// When git_data_path is explicitly set, memory backend respects it
|
|
let config = Config {
|
|
database_backend: DatabaseBackend::Memory,
|
|
git_data_path: "./custom/git/path".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let git_path = config.effective_git_data_path();
|
|
assert_eq!(git_path, "./custom/git/path");
|
|
}
|
|
|
|
#[test]
|
|
fn test_lmdb_backend_uses_configured_path() {
|
|
let config = Config {
|
|
database_backend: DatabaseBackend::Lmdb,
|
|
git_data_path: "./my/git/path".to_string(),
|
|
relay_data_path: "./my/relay/path".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
assert_eq!(config.effective_git_data_path(), "./my/git/path");
|
|
}
|
|
|
|
#[test]
|
|
fn test_database_backend_display() {
|
|
assert_eq!(DatabaseBackend::Memory.to_string(), "memory");
|
|
assert_eq!(DatabaseBackend::Lmdb.to_string(), "lmdb");
|
|
}
|
|
|
|
#[test]
|
|
fn test_relay_name_default() {
|
|
let config = Config {
|
|
domain: "example.com".to_string(),
|
|
relay_name_override: None,
|
|
..Config::for_testing()
|
|
};
|
|
assert_eq!(config.relay_name(), "example.com grasp relay");
|
|
}
|
|
|
|
#[test]
|
|
fn test_relay_name_override() {
|
|
let config = Config {
|
|
domain: "example.com".to_string(),
|
|
relay_name_override: Some("My Custom Relay".to_string()),
|
|
..Config::for_testing()
|
|
};
|
|
assert_eq!(config.relay_name(), "My Custom Relay");
|
|
}
|
|
|
|
#[test]
|
|
fn test_relay_owner_keys() {
|
|
let config = Config::for_testing();
|
|
let keys = config.relay_owner_keys().expect("Should have valid keys");
|
|
let npub = config.relay_owner_npub().expect("Should derive npub");
|
|
|
|
// Verify the npub matches the keys
|
|
assert_eq!(npub, keys.public_key().to_bech32().unwrap());
|
|
assert!(npub.starts_with("npub1"));
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_is_not_accepted_on_argv() {
|
|
let nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
assert!(Config::try_parse_from([
|
|
"ngit-grasp",
|
|
"--domain",
|
|
"example.com",
|
|
"--relay-owner-nsec",
|
|
nsec.as_str(),
|
|
])
|
|
.is_err());
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_credential_is_loaded_and_trimmed() {
|
|
let tempdir = tempfile::tempdir().unwrap();
|
|
let nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
fs::write(
|
|
tempdir.path().join(RELAY_OWNER_NSEC_CREDENTIAL),
|
|
format!(" {nsec}\n"),
|
|
)
|
|
.unwrap();
|
|
|
|
let loaded = Config::load_relay_owner_key_credential_from_dir(tempdir.path())
|
|
.unwrap()
|
|
.unwrap();
|
|
assert_eq!(loaded, nsec);
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_credential_rejects_empty_and_invalid_files() {
|
|
let tempdir = tempfile::tempdir().unwrap();
|
|
let credential = tempdir.path().join(RELAY_OWNER_NSEC_CREDENTIAL);
|
|
fs::write(&credential, "\n").unwrap();
|
|
assert!(Config::load_relay_owner_key_credential_from_dir(tempdir.path()).is_err());
|
|
|
|
fs::write(&credential, "nsec1invalid").unwrap();
|
|
let error = Config::load_relay_owner_key_from_sources(
|
|
Some(tempdir.path()),
|
|
None,
|
|
|| -> Result<String> { panic!("invalid credential must not fall through") },
|
|
)
|
|
.unwrap_err();
|
|
assert!(error.to_string().contains("relay_owner_nsec credential"));
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_credential_takes_precedence_over_environment() {
|
|
let tempdir = tempfile::tempdir().unwrap();
|
|
let credential_nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
fs::write(
|
|
tempdir.path().join(RELAY_OWNER_NSEC_CREDENTIAL),
|
|
&credential_nsec,
|
|
)
|
|
.unwrap();
|
|
|
|
let loaded = Config::load_relay_owner_key_from_sources(
|
|
Some(tempdir.path()),
|
|
Some("nsec1invalid".to_string()),
|
|
|| -> Result<String> { panic!("credential must prevent fallback") },
|
|
)
|
|
.unwrap();
|
|
assert_eq!(loaded, credential_nsec);
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_environment_is_trimmed_and_precedes_fallback() {
|
|
let nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
let loaded = Config::load_relay_owner_key_from_sources(
|
|
None,
|
|
Some(format!(" {nsec}\n")),
|
|
|| -> Result<String> { panic!("environment must prevent fallback") },
|
|
)
|
|
.unwrap();
|
|
assert_eq!(loaded, nsec);
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_environment_rejects_empty_and_invalid_values() {
|
|
for raw in ["", " ", "\n"] {
|
|
assert!(
|
|
Config::relay_owner_key_from_env_value(Some(raw.to_string())).is_err(),
|
|
"{raw:?} should be rejected"
|
|
);
|
|
}
|
|
|
|
let error = Config::load_relay_owner_key_from_sources(
|
|
None,
|
|
Some("nsec1invalid".to_string()),
|
|
|| -> Result<String> { panic!("invalid environment must not fall through") },
|
|
)
|
|
.unwrap_err();
|
|
assert!(error.to_string().contains(RELAY_OWNER_NSEC_ENV));
|
|
}
|
|
|
|
#[test]
|
|
fn relay_owner_nsec_missing_sources_use_persistent_fallback() {
|
|
let fallback_nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
let loaded =
|
|
Config::load_relay_owner_key_from_sources(None, None, || Ok(fallback_nsec.clone()))
|
|
.unwrap();
|
|
assert_eq!(loaded, fallback_nsec);
|
|
}
|
|
|
|
#[cfg(unix)]
|
|
#[test]
|
|
fn generated_relay_owner_key_file_is_private() {
|
|
use std::os::unix::fs::PermissionsExt;
|
|
|
|
let tempdir = tempfile::tempdir().unwrap();
|
|
let key_path = tempdir.path().join(".relay-owner.nsec");
|
|
write_secret_file(&key_path, "secret").unwrap();
|
|
|
|
assert_eq!(
|
|
fs::metadata(key_path).unwrap().permissions().mode() & 0o777,
|
|
0o600
|
|
);
|
|
}
|
|
|
|
#[cfg(unix)]
|
|
#[test]
|
|
fn existing_relay_owner_key_file_permissions_are_repaired_before_loading() {
|
|
use std::os::unix::fs::PermissionsExt;
|
|
|
|
let tempdir = tempfile::tempdir().unwrap();
|
|
let key_path = tempdir.path().join(".relay-owner.nsec");
|
|
let nsec = Keys::generate().secret_key().to_bech32().unwrap();
|
|
fs::write(&key_path, &nsec).unwrap();
|
|
fs::set_permissions(&key_path, fs::Permissions::from_mode(0o644)).unwrap();
|
|
|
|
let loaded = Config::load_or_generate_relay_owner_key_at(&key_path).unwrap();
|
|
|
|
assert_eq!(loaded, nsec);
|
|
assert_eq!(
|
|
fs::metadata(key_path).unwrap().permissions().mode() & 0o777,
|
|
0o600
|
|
);
|
|
}
|
|
|
|
#[test]
|
|
fn test_metrics_config_defaults() {
|
|
let config = Config::for_testing();
|
|
assert!(config.metrics_enabled);
|
|
assert_eq!(config.metrics_connection_per_ip_abuse_threshold, 10);
|
|
assert_eq!(config.metrics_top_n_repos, 10);
|
|
}
|
|
|
|
#[test]
|
|
fn test_metrics_config_custom_values() {
|
|
let config = Config {
|
|
metrics_enabled: false,
|
|
metrics_connection_per_ip_abuse_threshold: 50,
|
|
metrics_top_n_repos: 25,
|
|
..Config::for_testing()
|
|
};
|
|
assert!(!config.metrics_enabled);
|
|
assert_eq!(config.metrics_connection_per_ip_abuse_threshold, 50);
|
|
assert_eq!(config.metrics_top_n_repos, 25);
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_entry_pubkey() {
|
|
// Generate a valid test npub
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let entry = WhitelistEntry::parse(&test_npub).unwrap();
|
|
assert!(matches!(entry, WhitelistEntry::Pubkey(_)));
|
|
if let WhitelistEntry::Pubkey(npub) = entry {
|
|
assert_eq!(npub, test_npub);
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_entry_repository() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let entry = WhitelistEntry::parse(&format!("{}/linux", test_npub)).unwrap();
|
|
assert!(matches!(entry, WhitelistEntry::Repository { .. }));
|
|
if let WhitelistEntry::Repository { npub, identifier } = entry {
|
|
assert_eq!(npub, test_npub);
|
|
assert_eq!(identifier, "linux");
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_entry_identifier() {
|
|
let entry = WhitelistEntry::parse("bitcoin-core").unwrap();
|
|
assert!(matches!(entry, WhitelistEntry::Identifier(_)));
|
|
if let WhitelistEntry::Identifier(id) = entry {
|
|
assert_eq!(id, "bitcoin-core");
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_entry_invalid_npub() {
|
|
let result = WhitelistEntry::parse("npub1invalid");
|
|
assert!(result.is_err());
|
|
}
|
|
|
|
#[test]
|
|
fn test_whitelist_entry_matches() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let entry = WhitelistEntry::Pubkey(test_npub.clone());
|
|
assert!(entry.matches(&test_npub, "any-identifier"));
|
|
assert!(!entry.matches("npub1different", "any-identifier"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_whitelist_entry_matches_repository() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let entry = WhitelistEntry::Repository {
|
|
npub: test_npub.clone(),
|
|
identifier: "linux".to_string(),
|
|
};
|
|
assert!(entry.matches(&test_npub, "linux"));
|
|
assert!(!entry.matches(&test_npub, "bitcoin"));
|
|
assert!(!entry.matches("npub1different", "linux"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_whitelist_entry_matches_identifier() {
|
|
let entry = WhitelistEntry::Identifier("bitcoin-core".to_string());
|
|
assert!(entry.matches("npub1alice", "bitcoin-core"));
|
|
assert!(entry.matches("npub1bob", "bitcoin-core"));
|
|
assert!(!entry.matches("npub1alice", "other-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_enabled() {
|
|
let config = ArchiveConfig::default();
|
|
assert!(!config.enabled());
|
|
|
|
let config = ArchiveConfig {
|
|
archive_all: true,
|
|
whitelist: Vec::new(),
|
|
grasp_services: Vec::new(),
|
|
read_only: true,
|
|
};
|
|
assert!(config.enabled());
|
|
|
|
let config = ArchiveConfig {
|
|
archive_all: false,
|
|
whitelist: vec![WhitelistEntry::Identifier("test".into())],
|
|
grasp_services: Vec::new(),
|
|
read_only: true,
|
|
};
|
|
assert!(config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_matches() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = ArchiveConfig {
|
|
archive_all: false,
|
|
whitelist: vec![
|
|
WhitelistEntry::Pubkey(test_npub.clone()),
|
|
WhitelistEntry::Identifier("bitcoin-core".into()),
|
|
],
|
|
grasp_services: Vec::new(),
|
|
read_only: false,
|
|
};
|
|
|
|
assert!(config.matches(&test_npub, "any-repo"));
|
|
assert!(config.matches("npub1bob", "bitcoin-core"));
|
|
assert!(!config.matches("npub1bob", "other-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_matches_archive_all() {
|
|
let config = ArchiveConfig {
|
|
archive_all: true,
|
|
whitelist: Vec::new(),
|
|
grasp_services: Vec::new(),
|
|
read_only: true,
|
|
};
|
|
|
|
assert!(config.matches("npub1alice", "any-repo"));
|
|
assert!(config.matches("npub1bob", "other-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_empty() {
|
|
let whitelist = WhitelistEntry::parse_whitelist("");
|
|
assert!(whitelist.is_empty());
|
|
|
|
let whitelist = WhitelistEntry::parse_whitelist(" ");
|
|
assert!(whitelist.is_empty());
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_multiple() {
|
|
let keys1 = Keys::generate();
|
|
let keys2 = Keys::generate();
|
|
let test_npub1 = keys1.public_key().to_bech32().unwrap();
|
|
let test_npub2 = keys2.public_key().to_bech32().unwrap();
|
|
let whitelist = WhitelistEntry::parse_whitelist(&format!(
|
|
"{},bitcoin-core,{}/linux",
|
|
test_npub1, test_npub2
|
|
));
|
|
assert_eq!(whitelist.len(), 3);
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_whitelist_invalid_npub_skipped() {
|
|
// Invalid entries should be skipped with warnings, not fail
|
|
let whitelist = WhitelistEntry::parse_whitelist("npub1invalid,bitcoin-core");
|
|
assert_eq!(whitelist.len(), 1); // Only bitcoin-core should be parsed
|
|
assert!(matches!(
|
|
&whitelist[0],
|
|
WhitelistEntry::Identifier(id) if id == "bitcoin-core"
|
|
));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_parsing() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_whitelist: format!("{},bitcoin-core", test_npub),
|
|
..Config::for_testing()
|
|
};
|
|
let archive_config = config.archive_config();
|
|
assert_eq!(archive_config.whitelist.len(), 2);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_read_only_defaults() {
|
|
// Default: false when no archive mode
|
|
let config = Config::for_testing();
|
|
assert!(!config.archive_config().read_only);
|
|
|
|
// Default: true when archive_all is set
|
|
let config = Config {
|
|
archive_all: true,
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.archive_config().read_only);
|
|
|
|
// Default: true when archive_whitelist is set
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_whitelist: test_npub,
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.archive_config().read_only);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_read_only_explicit() {
|
|
// Explicit true with archive_all
|
|
let config = Config {
|
|
archive_all: true,
|
|
archive_read_only: Some(true),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.archive_config().read_only);
|
|
|
|
// Explicit false with archive_all (unusual but allowed)
|
|
let config = Config {
|
|
archive_all: true,
|
|
archive_read_only: Some(false),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(!config.archive_config().read_only);
|
|
|
|
// Explicit false without archive mode
|
|
let config = Config {
|
|
archive_read_only: Some(false),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(!config.archive_config().read_only);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_read_only_validation_error() {
|
|
// Error: true without archive mode should fail validation
|
|
let config = Config {
|
|
archive_read_only: Some(true),
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
assert!(result.unwrap_err().to_string().contains("requires either"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_repository_whitelist_parsing() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
repository_whitelist: format!("{},bitcoin-core", test_npub),
|
|
..Config::for_testing()
|
|
};
|
|
let repo_config = config.repository_config();
|
|
assert_eq!(repo_config.whitelist.len(), 2);
|
|
assert!(repo_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_repository_whitelist_empty() {
|
|
let config = Config::for_testing();
|
|
let repo_config = config.repository_config();
|
|
assert!(repo_config.whitelist.is_empty());
|
|
assert!(!repo_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_repository_whitelist_validation_incompatible_with_archive_read_only() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_all: true,
|
|
archive_read_only: Some(true),
|
|
repository_whitelist: test_npub,
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
let err = result.unwrap_err().to_string();
|
|
assert!(err.contains("cannot be used with"));
|
|
assert!(err.contains("NGIT_ARCHIVE_READ_ONLY=true"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_repository_whitelist_compatible_with_archive_read_only_false() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_all: true,
|
|
archive_read_only: Some(false),
|
|
repository_whitelist: test_npub,
|
|
..Config::for_testing()
|
|
};
|
|
// Should not error on validation
|
|
assert!(config.validate().is_ok());
|
|
}
|
|
|
|
#[test]
|
|
fn test_repository_config_matches() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = RepositoryConfig {
|
|
whitelist: vec![
|
|
WhitelistEntry::Pubkey(test_npub.clone()),
|
|
WhitelistEntry::Identifier("bitcoin-core".into()),
|
|
],
|
|
};
|
|
|
|
assert!(config.matches(&test_npub, "any-repo"));
|
|
assert!(config.matches("npub1bob", "bitcoin-core"));
|
|
assert!(!config.matches("npub1bob", "other-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_validate_success_with_valid_config() {
|
|
// Valid config should pass validation
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_whitelist: format!("{},bitcoin-core", test_npub),
|
|
archive_read_only: Some(false),
|
|
repository_whitelist: "rust".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.validate().is_ok());
|
|
}
|
|
|
|
#[test]
|
|
fn test_validate_with_all_invalid_whitelist_entries() {
|
|
// All invalid entries should be skipped with warnings, but validation should succeed
|
|
let config = Config {
|
|
archive_whitelist: "npub1invalid,npub1bad,npub1wrong".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.validate().is_ok());
|
|
// All entries should be skipped
|
|
let archive_config = config.archive_config();
|
|
assert_eq!(archive_config.whitelist.len(), 0);
|
|
assert!(!archive_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_validate_with_mixed_valid_invalid_entries() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
// Mixed valid and invalid entries - should keep valid ones
|
|
let config = Config {
|
|
repository_whitelist: format!("npub1invalid,{},bitcoin-core,npub1bad", test_npub),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.validate().is_ok());
|
|
let repo_config = config.repository_config();
|
|
// Should have 2 valid entries: the test_npub and bitcoin-core
|
|
assert_eq!(repo_config.whitelist.len(), 2);
|
|
}
|
|
|
|
#[test]
|
|
fn test_whitelist_entry_with_extra_whitespace() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
// Whitespace should be trimmed
|
|
let whitelist =
|
|
WhitelistEntry::parse_whitelist(&format!(" {} , bitcoin-core , rust ", test_npub));
|
|
assert_eq!(whitelist.len(), 3);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_with_all_invalid_entries_not_enabled() {
|
|
// If all whitelist entries are invalid, archive mode should not be enabled
|
|
let config = Config {
|
|
archive_whitelist: "npub1invalid,npub1bad".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let archive_config = config.archive_config();
|
|
assert!(!archive_config.enabled());
|
|
assert_eq!(archive_config.whitelist.len(), 0);
|
|
}
|
|
|
|
#[test]
|
|
fn test_validate_detects_invalid_relay_owner_nsec() {
|
|
// Invalid nsec should fail validation
|
|
let config = Config {
|
|
relay_owner_nsec: Some("nsec1invalid".to_string()),
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
assert!(result
|
|
.unwrap_err()
|
|
.to_string()
|
|
.contains("Invalid relay_owner_nsec"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_validate_requires_relay_owner_nsec() {
|
|
// Missing nsec should fail validation
|
|
let config = Config {
|
|
relay_owner_nsec: None,
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
assert!(result
|
|
.unwrap_err()
|
|
.to_string()
|
|
.contains("relay_owner_nsec not set"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_config_parsing() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
repository_blacklist: format!("{},bitcoin-core", test_npub),
|
|
..Config::for_testing()
|
|
};
|
|
let blacklist_config = config.blacklist_config();
|
|
assert_eq!(blacklist_config.blacklist.len(), 2);
|
|
assert!(blacklist_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_config_empty() {
|
|
let config = Config::for_testing();
|
|
let blacklist_config = config.blacklist_config();
|
|
assert!(blacklist_config.blacklist.is_empty());
|
|
assert!(!blacklist_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_check_npub() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = BlacklistConfig {
|
|
blacklist: vec![WhitelistEntry::Pubkey(test_npub.clone())],
|
|
};
|
|
|
|
let result = config.check(&test_npub, "any-repo");
|
|
assert!(result.is_some());
|
|
let reason = result.unwrap();
|
|
assert!(reason.contains("owner"));
|
|
assert!(reason.contains(&test_npub));
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_check_identifier() {
|
|
let config = BlacklistConfig {
|
|
blacklist: vec![WhitelistEntry::Identifier("banned-repo".to_string())],
|
|
};
|
|
|
|
let result = config.check("npub1alice", "banned-repo");
|
|
assert!(result.is_some());
|
|
let reason = result.unwrap();
|
|
assert!(reason.contains("identifier"));
|
|
assert!(reason.contains("banned-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_check_repository() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = BlacklistConfig {
|
|
blacklist: vec![WhitelistEntry::Repository {
|
|
npub: test_npub.clone(),
|
|
identifier: "specific-repo".to_string(),
|
|
}],
|
|
};
|
|
|
|
let result = config.check(&test_npub, "specific-repo");
|
|
assert!(result.is_some());
|
|
let reason = result.unwrap();
|
|
assert!(reason.contains(&test_npub));
|
|
assert!(reason.contains("specific-repo"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_blacklist_check_not_blacklisted() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = BlacklistConfig {
|
|
blacklist: vec![WhitelistEntry::Identifier("banned-repo".to_string())],
|
|
};
|
|
|
|
let result = config.check(&test_npub, "allowed-repo");
|
|
assert!(result.is_none());
|
|
}
|
|
|
|
#[test]
|
|
fn test_event_blacklist_config_parsing() {
|
|
let keys1 = Keys::generate();
|
|
let keys2 = Keys::generate();
|
|
let npub1 = keys1.public_key().to_bech32().unwrap();
|
|
let npub2 = keys2.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
event_blacklist: format!("{},{}", npub1, npub2),
|
|
..Config::for_testing()
|
|
};
|
|
let event_blacklist_config = config.event_blacklist_config();
|
|
assert_eq!(event_blacklist_config.blacklisted_npubs.len(), 2);
|
|
assert!(event_blacklist_config.enabled());
|
|
assert!(event_blacklist_config.blacklisted_npubs.contains(&npub1));
|
|
assert!(event_blacklist_config.blacklisted_npubs.contains(&npub2));
|
|
}
|
|
|
|
#[test]
|
|
fn test_event_blacklist_config_empty() {
|
|
let config = Config::for_testing();
|
|
let event_blacklist_config = config.event_blacklist_config();
|
|
assert!(event_blacklist_config.blacklisted_npubs.is_empty());
|
|
assert!(!event_blacklist_config.enabled());
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_disrespector_default() {
|
|
let config = Config::for_testing();
|
|
assert!(!config.deletion_request_disrespector);
|
|
}
|
|
|
|
#[test]
|
|
fn test_deletion_request_disrespector_enabled() {
|
|
let config = Config {
|
|
deletion_request_disrespector: true,
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.deletion_request_disrespector);
|
|
}
|
|
|
|
#[test]
|
|
fn test_event_blacklist_check_blacklisted() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = EventBlacklistConfig {
|
|
blacklisted_npubs: vec![test_npub.clone()],
|
|
};
|
|
|
|
let result = config.check(&test_npub);
|
|
assert!(result.is_some());
|
|
let reason = result.unwrap();
|
|
assert!(reason.contains("author"));
|
|
assert!(reason.contains(&test_npub));
|
|
}
|
|
|
|
#[test]
|
|
fn test_event_blacklist_check_not_blacklisted() {
|
|
let keys1 = Keys::generate();
|
|
let keys2 = Keys::generate();
|
|
let banned_npub = keys1.public_key().to_bech32().unwrap();
|
|
let allowed_npub = keys2.public_key().to_bech32().unwrap();
|
|
let config = EventBlacklistConfig {
|
|
blacklisted_npubs: vec![banned_npub],
|
|
};
|
|
|
|
let result = config.check(&allowed_npub);
|
|
assert!(result.is_none());
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_archive_grasp_services_empty() {
|
|
let config = Config::for_testing();
|
|
let services = config.parse_archive_grasp_services();
|
|
assert!(services.is_empty());
|
|
|
|
let config = Config {
|
|
archive_grasp_services: " ".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let services = config.parse_archive_grasp_services();
|
|
assert!(services.is_empty());
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_archive_grasp_services_single() {
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let services = config.parse_archive_grasp_services();
|
|
assert_eq!(services.len(), 1);
|
|
assert_eq!(services[0], "git.example.com");
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_archive_grasp_services_multiple() {
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com,git.nostr.dev,relay.gitnostr.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let services = config.parse_archive_grasp_services();
|
|
assert_eq!(services.len(), 3);
|
|
assert_eq!(services[0], "git.example.com");
|
|
assert_eq!(services[1], "git.nostr.dev");
|
|
assert_eq!(services[2], "relay.gitnostr.com");
|
|
}
|
|
|
|
#[test]
|
|
fn test_parse_archive_grasp_services_with_whitespace() {
|
|
let config = Config {
|
|
archive_grasp_services: " git.example.com , git.nostr.dev , relay.gitnostr.com "
|
|
.to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let services = config.parse_archive_grasp_services();
|
|
assert_eq!(services.len(), 3);
|
|
assert_eq!(services[0], "git.example.com");
|
|
assert_eq!(services[1], "git.nostr.dev");
|
|
assert_eq!(services[2], "relay.gitnostr.com");
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_grasp_services_validation_error_with_archive_all() {
|
|
let config = Config {
|
|
archive_all: true,
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
let err = result.unwrap_err().to_string();
|
|
assert!(err.contains("NGIT_ARCHIVE_GRASP_SERVICES"));
|
|
assert!(err.contains("NGIT_ARCHIVE_ALL"));
|
|
assert!(err.contains("mutually exclusive"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_grasp_services_validation_error_with_archive_whitelist() {
|
|
let keys = Keys::generate();
|
|
let test_npub = keys.public_key().to_bech32().unwrap();
|
|
let config = Config {
|
|
archive_whitelist: test_npub,
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let result = config.validate();
|
|
assert!(result.is_err());
|
|
let err = result.unwrap_err().to_string();
|
|
assert!(err.contains("NGIT_ARCHIVE_GRASP_SERVICES"));
|
|
assert!(err.contains("NGIT_ARCHIVE_WHITELIST"));
|
|
assert!(err.contains("mutually exclusive"));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_grasp_services_enables_archive_mode() {
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
let archive_config = config.archive_config();
|
|
assert!(archive_config.enabled());
|
|
assert!(archive_config.read_only); // Default to true
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_grasp_services_read_only_default() {
|
|
// Default: true when archive_grasp_services is set
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.archive_config().read_only);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_grasp_services_read_only_explicit_false() {
|
|
// Explicit false should be respected
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
archive_read_only: Some(false),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(!config.archive_config().read_only);
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_read_only_validation_with_grasp_services() {
|
|
// Should succeed with archive_grasp_services set
|
|
let config = Config {
|
|
archive_grasp_services: "git.example.com".to_string(),
|
|
archive_read_only: Some(true),
|
|
..Config::for_testing()
|
|
};
|
|
assert!(config.validate().is_ok());
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_matches_grasp_services() {
|
|
let config = ArchiveConfig {
|
|
archive_all: false,
|
|
whitelist: Vec::new(),
|
|
grasp_services: vec!["git.example.com".to_string(), "gitlab.org".to_string()],
|
|
read_only: true,
|
|
};
|
|
|
|
// Should match configured services
|
|
assert!(config.matches_grasp_services(&["git.example.com".to_string()]));
|
|
assert!(config.matches_grasp_services(&["gitlab.org".to_string()]));
|
|
|
|
// Should not match unconfigured services
|
|
assert!(!config.matches_grasp_services(&["github.com".to_string()]));
|
|
assert!(!config.matches_grasp_services(&["other.com".to_string()]));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_matches_grasp_services_empty() {
|
|
let config = ArchiveConfig {
|
|
archive_all: false,
|
|
whitelist: Vec::new(),
|
|
grasp_services: Vec::new(),
|
|
read_only: true,
|
|
};
|
|
|
|
// Should not match anything when grasp_services is empty
|
|
assert!(!config.matches_grasp_services(&["git.example.com".to_string()]));
|
|
assert!(!config.matches_grasp_services(&[]));
|
|
}
|
|
|
|
#[test]
|
|
fn test_archive_config_matches_grasp_services_multiple_domains() {
|
|
let config = ArchiveConfig {
|
|
archive_all: false,
|
|
whitelist: Vec::new(),
|
|
grasp_services: vec!["git.example.com".to_string()],
|
|
read_only: true,
|
|
};
|
|
|
|
// Should match if any domain matches
|
|
assert!(config.matches_grasp_services(&[
|
|
"github.com".to_string(),
|
|
"git.example.com".to_string(),
|
|
"gitlab.org".to_string(),
|
|
]));
|
|
|
|
// Should not match if no domain matches
|
|
assert!(
|
|
!config.matches_grasp_services(&["github.com".to_string(), "gitlab.org".to_string(),])
|
|
);
|
|
}
|
|
}
|