Rust 初回アドミッションと履歴信頼

Rust 初回アドミッションと履歴信頼

Rust AdmissionService は、6 段階の Signed Document 検証者 (MWP-ADM-005) の上に、初回アドミッションと履歴信頼を重ねます。言語に依存しないフローはローカルの 初回アドミッションおよび履歴信頼ランタイムページであり、正確な要件はローカル アドミッション条項 です。

パブリックアダプターと結果

パブリック API	責任
AdmissionCurrentKeyResolver::resolve_current	デプロイメントがこの決定に対して最新であると主張する完全な Organization 全体の Registry 証拠を返します。
TrustedAdmissionContext::issue	権威ある不存在判定の後にだけ、レコード ID、信頼できる受け入れ時刻、および受け入れサービスを発行します。
AdmissionLog::lookup	AdmissionLookup::Found または AdmissionLookup::AuthoritativeAbsence を返します。キャッシュミス、タイムアウト、または認証されていない不在により、MWP-ADM-003 に基づいてクローズが失敗します。
AdmissionLog::append_or_return_existing	候補バイトをアトミックに追加するか、認証されたサービス ID を通じて同時に権威のある勝者を返します。
AuthenticatedAdmissionRecord	返されたレコード バイトを、MWP-ADM-009 のログ アダプターによって認証されたサービス ID にバインドします。
AdmissionService::prepare_first_admission	SDK によって生成された VerifiedSignedDocument から候補証拠を作成および検証します。追加したり、承認を暗示したりするものではありません。
AdmissionService::admit_first	MWP-ADM-006 に基づいて、現在の証拠を確認し、検索し、不在後の準備をし、既存の追加または返却を行い、返されたレコードを検証します。
AdmissionService::verify_historical_admission	過去の Registry 証拠を使用して検証を再実行し、コンテキストを発行したり MWP-ADM-008 に基づいて追加したりせずに既存のレコードを要求します。
PreparedFirstAdmission、AdmittedSignedDocument	不変の検証を保存し、証拠を記録します。 FirstAdmissionRecord::bytes は検証されたバイトを返します。

呼び出し元が提供する信頼ブール値はアドミッション検索結果ではないため、成功パスを選択してはなりません。

初回受付の電話順番

Informative example

let first = AdmissionService::new()?.admit_first(
    SignedDocumentKind::Command,
    document,
    &current_registry,
    &admission_log,
    &trusted_context,
)?;

admit_first は、ログにアクセスする前に 6 つの検証段階をすべて完了します。見つかったレコードは検証され、信頼できるコンテキストの発行や追加を行わずに返されます。権威ある不存在判定の後、サービスはコンテキストを発行し、正規の候補バイトを準備し、append_or_return_existing を呼び出し、実際に返されたレコードを検証します。同時勝者は、スキーマ、認証、ドキュメント バインディング、および信頼できる時間が MWP-ADM-009 および MWP-ADM-010 を満たす場合にのみ成功します。

過去のリプレイとエラー

verify_historical_admission は KeyResolver を使用し、6 つのステージすべてを再実行します。AdmissionLookup::Found を必要とし、TrustedAdmissionContext::issue または AdmissionLog::append_or_return_existing を呼び出しません。レコード ID が一致すると、同じ権威あるレコードが復元されますが、MWP-ADM-013 および MWP-ADM-014 に基づく Command の鮮度、署名者の認可、ステートマシンの受け入れ、またはポータブル ログプルーフ検証は証明されません。

AdmissionOperationError は、元の 6 段階検証の失敗または AdmissionError のいずれかを保持します。アドミッションの失敗により、MWP-ADM-012 で要求されているように、ワイヤー コード AUTH_INVALID_SIGNATURE、保護ステージ admission、および型指定された AdmissionReason が公開されます。アダプターは AdmissionAdapterError を返します。一般的な成功や可用性は、認証された証拠ではありません。

実行可能な完全に固定された例

Informative example

この例では、SDK の検証済み埋め込み ProtocolBundle から署名付き Command および Registry を読み取り、型指定されたメモリ内権限アダプターを提供します。リポジトリ ファイルは読み取りません。これは、初回受付と履歴再生に対して同一のレコード ID、署名ハッシュ、レコード バイトを 1 回の追加でアサートします。

use std::cell::{Cell, RefCell};

use missionweaveprotocol::{
    AdapterError, AdmissionAdapterError, AdmissionContextValue, AdmissionCurrentKeyResolver,
    AdmissionLog, AdmissionLookup, AdmissionService, AuthenticatedAdmissionRecord,
    KeyRegistrySnapshot, KeyResolutionRequest, KeyResolver, ProtocolBundle, SignedDocumentKind,
    TrustedAdmissionContext,
};

const SERVICE_ID: &str = "urn:missionweaveprotocol:service:admission";

struct CurrentRegistry(Vec<u8>);

impl CurrentRegistry {
    fn snapshot(&self) -> KeyRegistrySnapshot {
        KeyRegistrySnapshot::organization_wide(self.0.clone())
    }
}

impl AdmissionCurrentKeyResolver for CurrentRegistry {
    fn resolve_current(
        &self,
        _request: &KeyResolutionRequest,
    ) -> Result<KeyRegistrySnapshot, AdapterError> {
        Ok(self.snapshot())
    }
}

impl KeyResolver for CurrentRegistry {
    fn resolve(
        &self,
        _request: &KeyResolutionRequest,
    ) -> Result<KeyRegistrySnapshot, AdapterError> {
        Ok(self.snapshot())
    }
}

struct FixedTrustedContext;

impl TrustedAdmissionContext for FixedTrustedContext {
    fn issue(
        &self,
        _organization_id: &str,
        _signing_hash: &str,
    ) -> Result<AdmissionContextValue, AdmissionAdapterError> {
        Ok(AdmissionContextValue::new(
            "urn:missionweaveprotocol:admission-record:website-example",
            "2026-07-15T00:05:00Z",
            SERVICE_ID,
        ))
    }
}

struct InMemoryAdmissionLog {
    record: RefCell<Option<AuthenticatedAdmissionRecord>>,
    append_count: Cell<usize>,
}

impl InMemoryAdmissionLog {
    fn new() -> Self {
        Self {
            record: RefCell::new(None),
            append_count: Cell::new(0),
        }
    }

    fn append_count(&self) -> usize {
        self.append_count.get()
    }
}

impl AdmissionLog for InMemoryAdmissionLog {
    fn lookup(
        &self,
        _organization_id: &str,
        _signing_hash: &str,
    ) -> Result<AdmissionLookup, AdmissionAdapterError> {
        Ok(match self.record.borrow().as_ref() {
            Some(record) => AdmissionLookup::Found(record.clone()),
            None => AdmissionLookup::AuthoritativeAbsence,
        })
    }

    fn append_or_return_existing(
        &self,
        _organization_id: &str,
        _signing_hash: &str,
        candidate_bytes: &[u8],
    ) -> Result<AuthenticatedAdmissionRecord, AdmissionAdapterError> {
        if let Some(record) = self.record.borrow().as_ref() {
            return Ok(record.clone());
        }

        let committed = AuthenticatedAdmissionRecord::new(candidate_bytes.to_vec(), SERVICE_ID);
        *self.record.borrow_mut() = Some(committed.clone());
        self.append_count.set(self.append_count.get() + 1);
        Ok(committed)
    }
}

fn main() -> Result<(), Box<dyn std::error::Error>> {
    ProtocolBundle::verify()?;
    ProtocolBundle::verify_cryptography()?;
    ProtocolBundle::verify_admission()?;

    let document = ProtocolBundle::cryptography("vectors/signed-documents/valid/command.json")
        .ok_or("packaged Command is missing")?;
    let registry = ProtocolBundle::cryptography("keys/registry-valid.json")
        .ok_or("packaged Registry is missing")?;

    let current_registry = CurrentRegistry(registry.to_vec());
    let admission_log = InMemoryAdmissionLog::new();
    let service = AdmissionService::new()?;

    let first = service.admit_first(
        SignedDocumentKind::Command,
        document,
        &current_registry,
        &admission_log,
        &FixedTrustedContext,
    )?;
    let historical = service.verify_historical_admission(
        SignedDocumentKind::Command,
        document,
        &current_registry,
        &admission_log,
    )?;

    assert!(first.record().admission_record_id() == historical.record().admission_record_id());
    assert!(first.verified().signing_hash() == historical.verified().signing_hash());
    assert!(first.record().bytes() == historical.record().bytes());
    assert!(admission_log.append_count() == 1);

    println!("first admission: {}", first.record().admission_record_id());
    println!(
        "historical replay: {}",
        historical.record().admission_record_id()
    );
    Ok(())
}

それを正確なチェックアウトにコピーして実行します。

cp /absolute/path/to/examples/sdk/rust/admission.rs examples/website_admission.rs
cargo test --locked --all-features
cargo run --locked --example website_admission

予期される出力には、first admission と historical replay の同じレコード ID が含まれています。

Implementation note

CurrentRegistry を認証された現在および過去の Registry アダプタに置き換え、InMemoryAdmissionLog を既存の追加または返却操作がアトミックである認証された永続ログに置き換え、FixedTrustedContext を次のアダプタに置き換えます。 Organization によって制御される信頼できる時間とサービスの発行を受け付ける。防御的なコピーを保持し、これらの権限境界を呼び出し側が提供する 1 つの信頼ブール値に決して分解しないでください。