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

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

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

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

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

初回受付の電話順番

AdmittedSignedDocument first =
    new AdmissionService()
        .admitFirst(
            SignedDocumentKind.COMMAND,
            document,
            currentRegistry,
            admissionLog,
            trustedContext);

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

過去のリプレイとエラー

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

6 段階の障害は SignedDocumentVerificationException のままです。アドミッションステージの障害は、ワイヤコード AUTH_INVALID_SIGNATURE の AdmissionException、ステージ admission、および MWP-ADM-012 で要求されている型付き AdmissionReason です。デプロイメント・アダプターは AdmissionAdapterException をスローします。一般的な成功や可用性は、認証された証拠ではありません。

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

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

package org.missionweaveprotocol.examples;

import java.io.IOException;
import java.io.InputStream;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import org.missionweaveprotocol.sdk.AdmissionContextValue;
import org.missionweaveprotocol.sdk.AdmissionCurrentKeyResolver;
import org.missionweaveprotocol.sdk.AdmissionLog;
import org.missionweaveprotocol.sdk.AdmissionLookup;
import org.missionweaveprotocol.sdk.AdmissionService;
import org.missionweaveprotocol.sdk.AuthenticatedAdmissionRecord;
import org.missionweaveprotocol.sdk.KeyRegistrySnapshot;
import org.missionweaveprotocol.sdk.KeyResolutionRequest;
import org.missionweaveprotocol.sdk.KeyResolver;
import org.missionweaveprotocol.sdk.Principal;
import org.missionweaveprotocol.sdk.ProtocolBundle;
import org.missionweaveprotocol.sdk.SignedDocumentKind;
import org.missionweaveprotocol.sdk.TrustedAdmissionContext;

public final class AdmissionExample {
  private static final Principal ADMISSION_SERVICE =
      new Principal("service", "urn:missionweaveprotocol:service:admission");

  private AdmissionExample() {}

  private static final class CurrentRegistry implements AdmissionCurrentKeyResolver, KeyResolver {
    private final byte[] registry;

    private CurrentRegistry(byte[] registry) {
      this.registry = registry.clone();
    }

    @Override
    public KeyRegistrySnapshot resolveCurrent(KeyResolutionRequest request) {
      return snapshot();
    }

    @Override
    public KeyRegistrySnapshot resolve(KeyResolutionRequest request) {
      return snapshot();
    }

    private KeyRegistrySnapshot snapshot() {
      return KeyRegistrySnapshot.organizationWide(registry);
    }
  }

  private static final class FixedTrustedContext implements TrustedAdmissionContext {
    @Override
    public AdmissionContextValue issue(String organizationId, String signingHash) {
      return new AdmissionContextValue(
          "urn:missionweaveprotocol:admission-record:website-example",
          "2026-07-15T00:05:00Z",
          ADMISSION_SERVICE);
    }
  }

  private static final class InMemoryAdmissionLog implements AdmissionLog {
    private final Map<String, AuthenticatedAdmissionRecord> records = new HashMap<>();
    private int appendCount;

    @Override
    public AdmissionLookup lookup(String organizationId, String signingHash) {
      AuthenticatedAdmissionRecord record = records.get(key(organizationId, signingHash));
      return record == null
          ? new AdmissionLookup.AuthoritativeAbsence()
          : new AdmissionLookup.Found(copy(record));
    }

    @Override
    public AuthenticatedAdmissionRecord appendOrReturnExisting(
        String organizationId, String signingHash, byte[] candidateBytes) {
      String key = key(organizationId, signingHash);
      AuthenticatedAdmissionRecord existing = records.get(key);
      if (existing != null) {
        return copy(existing);
      }

      AuthenticatedAdmissionRecord committed =
          new AuthenticatedAdmissionRecord(candidateBytes, ADMISSION_SERVICE);
      records.put(key, committed);
      appendCount += 1;
      return copy(committed);
    }

    private int appendCount() {
      return appendCount;
    }

    private static String key(String organizationId, String signingHash) {
      return organizationId + "\0" + signingHash;
    }

    private static AuthenticatedAdmissionRecord copy(AuthenticatedAdmissionRecord record) {
      return new AuthenticatedAdmissionRecord(record.recordBytes(), record.authenticatedService());
    }
  }

  public static void main(String[] arguments) throws Exception {
    ProtocolBundle.verifyPackaged();
    ProtocolBundle.verifyPackagedCryptographyBundle();
    ProtocolBundle.verifyPackagedAdmissionBundle();

    byte[] document = resource("cryptography/vectors/signed-documents/valid/command.json");
    CurrentRegistry currentRegistry =
        new CurrentRegistry(resource("cryptography/keys/registry-valid.json"));
    InMemoryAdmissionLog admissionLog = new InMemoryAdmissionLog();
    AdmissionService service = new AdmissionService();

    var first =
        service.admitFirst(
            SignedDocumentKind.COMMAND,
            document,
            currentRegistry,
            admissionLog,
            new FixedTrustedContext());
    var historical =
        service.verifyHistoricalAdmission(
            SignedDocumentKind.COMMAND, document, currentRegistry, admissionLog);

    if (!first.record().admissionRecordId().equals(historical.record().admissionRecordId())) {
      throw new IllegalStateException("historical replay returned a different record ID");
    }
    if (!first.verified().signingHash().equals(historical.verified().signingHash())) {
      throw new IllegalStateException("historical replay returned a different signing hash");
    }
    if (!Arrays.equals(first.recordBytes(), historical.recordBytes())) {
      throw new IllegalStateException("historical replay returned different record bytes");
    }
    if (!(admissionLog.appendCount() == 1)) {
      throw new IllegalStateException("Admission Log did not append exactly once");
    }

    System.out.println("first admission: " + first.record().admissionRecordId());
    System.out.println("historical replay: " + historical.record().admissionRecordId());
  }

  private static byte[] resource(String path) throws IOException {
    try (InputStream input = AdmissionExample.class.getClassLoader().getResourceAsStream(path)) {
      if (input == null) {
        throw new IOException("Missing packaged protocol resource: " + path);
      }
      return input.readAllBytes();
    }
  }
}

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

cp /absolute/path/to/examples/sdk/java/AdmissionExample.java \
  examples/src/main/java/org/missionweaveprotocol/examples/AdmissionExample.java
./mvnw -B -ntp verify
./mvnw -q -Dexec.mainClass=org.missionweaveprotocol.examples.AdmissionExample \
  -Dexec.classpathScope=test exec:java

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