6ea90afbed
Smart Byte (1 crate, 2127 LOC, 35 tests)
smart-byte-atproto ATProto (Bluesky federation) adapter.
PLC + did:web resolution; XRPC client; CARv1 encode/decode
with CIDv1 (dag-cbor + raw, SHA-256); sketch MST with
order-independent BLAKE3 root; Repo + UnsignedCommit /
SignedCommit (Ed25519 over CBOR); firehose transport
trait + in-memory impl; AT URI ↔ smart-byte AID bridge
with SAID commitment.
OpenPay (1 crate, 2397 LOC, 44 tests)
op-openbanking UK OBIE R/W v3.1.10/3.1.11, Berlin Group NextGenPSD2
XS2A v1.3.13, STET PSD2 v1.7, Australia CDR Banking v1.31,
FDX v5/v6, SGFinDex shapes. AISP / PISP / PIIS / VRP
traits. FAPI 1.0 Advanced (PS256/ES256, mTLS, RFC 8705
certificate binding, JWK registration). Operators wire
their own JWS signer + HTTP transport — keeps the crate
KMS-agnostic.
EOC (1 crate, 2179 LOC, 32 tests)
eoc-distributed Distributed-inference scheduling. Worker trait with
Capability + Accelerator (CPU/GPU/TPU/NPU/Mixed) +
Load.busyness()/projected_micro_joules()/projected_g_co2e().
RoundRobin / LeastBusy / LatencyWeighted / JouleWeighted
(default) / CarbonWeighted routers. Work-stealing
scheduler. vLLM-style continuous batching with KV-block
budget. Ray-Serve-style auto-scaler with cooldown.
KV-cache-aware sticky-session routing.
Co-Authored-By: Claude Opus 4.7 <[email protected]>
104 lines
3.2 KiB
Rust
104 lines
3.2 KiB
Rust
//! VRP sweep + non-sweep cap-enforcement integration test.
|
|
|
|
use op_core::{Currency, Money};
|
|
use op_openbanking::aisp::ConsentId;
|
|
use op_openbanking::vrp::{
|
|
VrpConsent, VrpControlParameters, VrpExecution, VrpKind, VrpSweep, VrpWindow,
|
|
};
|
|
use op_openbanking::Error;
|
|
|
|
fn consent(kind: VrpKind, per: i64, window: i64) -> VrpConsent {
|
|
VrpConsent {
|
|
id: ConsentId("vrp".into()),
|
|
kind,
|
|
debtor_account: "GB29NWBK60161331926819".into(),
|
|
creditor_account: "GB33BUKB20201555555555".into(),
|
|
controls: VrpControlParameters {
|
|
max_individual_amount: Money::from_minor(per, Currency::GBP),
|
|
max_period_amount: Money::from_minor(window, Currency::GBP),
|
|
window: VrpWindow::Month,
|
|
valid_until: None,
|
|
},
|
|
}
|
|
}
|
|
|
|
fn exec(amount: i64) -> VrpExecution {
|
|
VrpExecution {
|
|
amount: Money::from_minor(amount, Currency::GBP),
|
|
end_to_end_id: format!("VRP-{}", amount),
|
|
remittance: None,
|
|
submitted_at: time::OffsetDateTime::UNIX_EPOCH,
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn sweep_within_caps_passes() {
|
|
let sweep = VrpSweep {
|
|
consent: consent(VrpKind::Sweeping, 10_000, 50_000),
|
|
execution: exec(5_000),
|
|
already_spent_in_window: Money::from_minor(20_000, Currency::GBP),
|
|
};
|
|
sweep.check_caps().expect("ok");
|
|
}
|
|
|
|
#[test]
|
|
fn non_sweep_per_payment_cap_fires() {
|
|
let sweep = VrpSweep {
|
|
consent: consent(VrpKind::NonSweeping, 10_000, 50_000),
|
|
execution: exec(15_000),
|
|
already_spent_in_window: Money::zero(Currency::GBP),
|
|
};
|
|
assert!(matches!(
|
|
sweep.check_caps().unwrap_err(),
|
|
Error::VrpLimitExceeded { .. }
|
|
));
|
|
}
|
|
|
|
#[test]
|
|
fn period_cap_fires_on_aggregation() {
|
|
let sweep = VrpSweep {
|
|
consent: consent(VrpKind::Sweeping, 10_000, 50_000),
|
|
execution: exec(8_000),
|
|
already_spent_in_window: Money::from_minor(45_000, Currency::GBP),
|
|
};
|
|
let err = sweep.check_caps().expect_err("period cap");
|
|
let Error::VrpLimitExceeded { reason } = err else {
|
|
panic!("wrong variant");
|
|
};
|
|
assert!(reason.contains("period"));
|
|
}
|
|
|
|
#[test]
|
|
fn currency_mismatch_caught_locally() {
|
|
let mut sweep = VrpSweep {
|
|
consent: consent(VrpKind::Sweeping, 10_000, 50_000),
|
|
execution: exec(1_000),
|
|
already_spent_in_window: Money::zero(Currency::GBP),
|
|
};
|
|
sweep.execution.amount = Money::from_minor(1_000, Currency::EUR);
|
|
assert!(matches!(
|
|
sweep.check_caps().unwrap_err(),
|
|
Error::CurrencyMismatch(_)
|
|
));
|
|
}
|
|
|
|
#[test]
|
|
fn expired_consent_rejected() {
|
|
let mut c = consent(VrpKind::Sweeping, 10_000, 50_000);
|
|
c.controls.valid_until = Some(time::OffsetDateTime::UNIX_EPOCH);
|
|
let sweep = VrpSweep {
|
|
consent: c,
|
|
execution: VrpExecution {
|
|
amount: Money::from_minor(1_000, Currency::GBP),
|
|
end_to_end_id: "E".into(),
|
|
remittance: None,
|
|
// Submitted strictly *after* the consent's valid_until.
|
|
submitted_at: time::OffsetDateTime::UNIX_EPOCH + time::Duration::days(1),
|
|
},
|
|
already_spent_in_window: Money::zero(Currency::GBP),
|
|
};
|
|
assert!(matches!(
|
|
sweep.check_caps().unwrap_err(),
|
|
Error::ConsentStateInvalid { .. }
|
|
));
|
|
}
|