Java Première admission et confiance historique

Java Première admission et confiance historique

Le Java AdmissionService superpose la première admission et la confiance historique au-dessus du vérificateur Signed Document en six étapes (MWP-ADM-005). Le flux indépendant de la langue est la page d’exécution de première admission et de confiance historique locale, et les exigences exactes sont les clauses d’admission locales.

## Adaptateurs et résultats publics

Public API	Responsabilité
AdmissionCurrentKeyResolver.resolveCurrent	Renvoie la preuve complète Organization Registry selon laquelle le déploiement affirme qu’elle est à jour pour cette décision.
TrustedAdmissionContext.issue	Émettez l’ID d’enregistrement, l’acceptation de confiance instantanée et l’acceptation du service uniquement après une absence faisant autorité.
AdmissionLog.lookup	Renvoyez AdmissionLookup.Found ou AdmissionLookup.AuthoritativeAbsence. Échec d’échec de cache, d’expiration de délai ou d’absence non authentifiée sous MWP-ADM-003.
AdmissionLog.appendOrReturnExisting	Ajoutez atomiquement des octets candidats ou renvoyez le gagnant faisant autorité simultané via une identité de service authentifiée.
AuthenticatedAdmissionRecord	Bind a renvoyé des octets d’enregistrement au service authentifié par l’adaptateur pour MWP-ADM-009.
AdmissionService.prepareFirstAdmission	Créer et valider des preuves de candidat à partir d’un SDK produit par VerifiedSignedDocument ; cela n’ajoute ni n’implique l’admission.
AdmissionService.admitFirst	Vérifiez les preuves actuelles, recherchez, préparez-vous après une absence, ajoutez ou retournez l’existant et validez l’enregistrement renvoyé sous MWP-ADM-006.
AdmissionService.verifyHistoricalAdmission	Réexécutez la vérification avec les preuves historiques Registry et exigez un enregistrement existant sans émettre de contexte ni ajouter sous MWP-ADM-008.
PreparedFirstAdmission, AdmittedSignedDocument	Préservez la vérification immuable et enregistrez les preuves et renvoyez des copies d’octets d’enregistrement défensives.

Un booléen de confiance fourni par l’appelant n’est pas un résultat de recherche d’admission et ne doit jamais sélectionner le chemin de réussite.

Ordre d’appel de première admission

Informative example

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

admitFirst termine les six étapes de vérification avant l’accès au journal. Un enregistrement trouvé est validé et renvoyé sans émettre de contexte fiable ni ajout. Après une absence faisant autorité, le service émet le contexte, prépare les octets candidats canoniques, appelle appendOrReturnExisting et valide l’enregistrement effectivement renvoyé. Un gagnant simultané ne réussit que lorsque le schéma, l’authentification, la liaison de document et l’heure de confiance satisfont MWP-ADM-009 et MWP-ADM-010.

Relecture historique et erreurs

verifyHistoricalAdmission utilise KeyResolver, réexécute les six étapes, nécessite AdmissionLookup.Found et n’appelle jamais TrustedAdmissionContext.issue ou AdmissionLog.appendOrReturnExisting. Les ID d’enregistrement correspondant récupèrent le même enregistrement faisant autorité mais ne prouvent pas la fraîcheur Command, l’autorisation du signataire, l’acceptation de la machine d’état ou la vérification de preuve de journal portable sous MWP-ADM-013 et MWP-ADM-014.

Les défauts à six niveaux restent SignedDocumentVerificationException. Les défauts de l’étape d’admission sont AdmissionException avec le code filaire AUTH_INVALID_SIGNATURE, l’étape admission et un AdmissionReason typé, comme requis par MWP-ADM-012. Les adaptateurs de déploiement lancent AdmissionAdapterException ; le succès ou la disponibilité générique ne constitue pas une preuve authentifiée.

Exemple d’exécution exacte épinglée

Informative example

L’exemple lit les Command et Registry signés à partir de ressources regroupées dans le fichier JAR exact, puis fournit des adaptateurs d’autorité saisis en mémoire. Il ne lit pas les fichiers du référentiel. Il affirme des ID d’enregistrement, des hachages de signature et des octets d’enregistrement identiques pour la première admission et la relecture historique, avec exactement un ajout.

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();
    }
  }
}

Copiez-le dans un checkout exact et exécutez :

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

La sortie attendue contient le même ID d’enregistrement pour first admission et historical replay.

Implementation note

Remplacez CurrentRegistry par des adaptateurs Registry actuels et historiques authentifiés, InMemoryAdmissionLog par un journal durable authentifié dont l’opération d’ajout ou de retour existante est atomique et FixedTrustedContext par Organization contrôlé. temps de confiance et émission de service d’acceptation. Conservez les copies défensives et ne réduisez jamais ces limites d’autorité en un seul booléen de confiance fourni par l’appelant.