From 702935b76e043a239421dccb8a834c7910c4e18f Mon Sep 17 00:00:00 2001
From: ExoHayvan <18trevor3695@gmail.com>
Date: Thu, 16 Jul 2026 17:05:13 -0400
Subject: [PATCH 1/4] chore: complete phase-1 step-148

---
 src/aethermesh_core/contribution_record.py |  1 +
 src/aethermesh_core/local_audit_event.py   | 18 +++++++++-
 src/aethermesh_core/local_shutdown.py      |  1 +
 src/aethermesh_core/local_startup.py       |  5 ++-
 src/aethermesh_core/runtime_service.py     |  5 +++
 tests/test_local_audit_event.py            |  3 ++
 tests/test_runtime_service_api_cli.py      | 39 ++++++++++++++++++++++
 7 files changed, 70 insertions(+), 2 deletions(-)

diff --git a/src/aethermesh_core/contribution_record.py b/src/aethermesh_core/contribution_record.py
index 4eeaeae..20d2984 100644
--- a/src/aethermesh_core/contribution_record.py
+++ b/src/aethermesh_core/contribution_record.py
@@ -344,6 +344,7 @@ def _append_ledger_update_audit(
         "actor_node_id": contributor,
         "creator_node_id": creator,
         "local_run_id": update_id,
+        "event_sequence": 1,
         "validation_status": outcome,
     }
     if contribution:
diff --git a/src/aethermesh_core/local_audit_event.py b/src/aethermesh_core/local_audit_event.py
index 13b5360..e8f77e5 100644
--- a/src/aethermesh_core/local_audit_event.py
+++ b/src/aethermesh_core/local_audit_event.py
@@ -1,4 +1,11 @@
-"""Canonical local JSONL audit events for prototype actions."""
+"""Canonical local JSONL audit events for prototype actions.
+
+Every event records UTC ``timestamp``, a stable per-flow ``local_run_id``, and
+the positive ``event_sequence`` offset within that run. Together with actor
+and creator IDs plus event-specific manifest, receipt, lineage, and
+contribution references, these are the minimum local-only reconstruction
+fields. References are relative paths to avoid disclosing host locations.
+"""
 
 from __future__ import annotations
 
@@ -36,6 +43,7 @@
         "actor_node_id",
         "creator_node_id",
         "local_run_id",
+        "event_sequence",
         "schema_version",
     }
 )
@@ -114,6 +122,14 @@ def validate_local_audit_event(event: Mapping[str, Any]) -> dict[str, Any]:
         raise LocalAuditEventError("local audit event.schema_version must be integer 1")
     for field in ("event_id", "actor_node_id", "local_run_id"):
         _require_text(document[field], f"local audit event.{field}")
+    if (
+        not isinstance(document["event_sequence"], int)
+        or isinstance(document["event_sequence"], bool)
+        or document["event_sequence"] < 1
+    ):
+        raise LocalAuditEventError(
+            "local audit event.event_sequence must be a positive integer"
+        )
     _require_timestamp(document["timestamp"])
     creator_node_id = document["creator_node_id"]
     if creator_node_id is not None:
diff --git a/src/aethermesh_core/local_shutdown.py b/src/aethermesh_core/local_shutdown.py
index 8101533..7042ff0 100644
--- a/src/aethermesh_core/local_shutdown.py
+++ b/src/aethermesh_core/local_shutdown.py
@@ -382,6 +382,7 @@ def _append_shutdown_audit_event(
                 "actor_node_id": node_id,
                 "creator_node_id": creator_node_id,
                 "local_run_id": node_instance_id,
+                "event_sequence": 1,
                 "node_instance_id": node_instance_id,
                 "shutdown_reason": "normal local shutdown",
                 "exit_mode": exit_mode,
diff --git a/src/aethermesh_core/local_startup.py b/src/aethermesh_core/local_startup.py
index da8fc5d..1372e78 100644
--- a/src/aethermesh_core/local_startup.py
+++ b/src/aethermesh_core/local_startup.py
@@ -730,7 +730,9 @@ def _append_capability_advertisement_audit_events(
 ) -> None:
     """Append one digest-only audit event for each validated local claim."""
 
-    for advertisement in cast(list[dict[str, object]], advertisements):
+    for event_sequence, advertisement in enumerate(
+        cast(list[dict[str, object]], advertisements), start=1
+    ):
         validation = cast(dict[str, object], advertisement["validation"])
         attribution = cast(dict[str, object], advertisement["contribution_attribution"])
         required_receipt_ref = cast(str, validation["required_receipt_ref"])
@@ -749,6 +751,7 @@ def _append_capability_advertisement_audit_events(
                 "actor_node_id": node_id,
                 "creator_node_id": creator_node_id,
                 "local_run_id": f"local-startup:{validation_receipt_ref}",
+                "event_sequence": event_sequence,
                 "capability_advertisement_action": action,
                 "node_id": node_id,
                 "capability_id": capability_id,
diff --git a/src/aethermesh_core/runtime_service.py b/src/aethermesh_core/runtime_service.py
index 3af04b9..7bba62f 100644
--- a/src/aethermesh_core/runtime_service.py
+++ b/src/aethermesh_core/runtime_service.py
@@ -1019,6 +1019,7 @@ def submit_local_job(self, request: dict[str, Any]) -> dict[str, Any]:
                     "local_node_id": local_node_id,
                     "creator_node_id": creator_node_id,
                     "local_run_id": job_id,
+                    "event_sequence": 1,
                     "job_id": job_id,
                     "work_id": job_id,
                     "manifest_id": job_id,
@@ -2618,6 +2619,7 @@ def _append_validation_receipt_created_audit_event(
                     "actor_node_id": worker_node_id,
                     "creator_node_id": creator_node_id,
                     "local_run_id": job_id,
+                    "event_sequence": 3,
                     "work_id": job_id,
                     "manifest_id": manifest_id,
                     "manifest_ref": manifest_ref,
@@ -2674,6 +2676,7 @@ def _append_job_execution_started_audit_event(
                     "actor_node_id": worker_node_id,
                     "creator_node_id": creator_node_id,
                     "local_run_id": job_id,
+                    "event_sequence": 2,
                     "job_id": job_id,
                     "work_id": job_id,
                     "executing_node_id": worker_node_id,
@@ -2743,6 +2746,7 @@ def _append_result_reported_audit_event(
                     "actor_node_id": worker_node_id,
                     "creator_node_id": creator_node_id,
                     "local_run_id": job_id,
+                    "event_sequence": 5,
                     "reporting_node_id": worker_node_id,
                     "work_id": job_id,
                     "manifest_id": manifest_id,
@@ -2826,6 +2830,7 @@ def _append_job_execution_finished_audit_event(
                     "actor_node_id": actor_node_id,
                     "creator_node_id": creator_node_id,
                     "local_run_id": job_id,
+                    "event_sequence": 4,
                     "job_id": job_id,
                     "work_id": job_id,
                     "execution_id": f"local-execution-{job_id}",
diff --git a/tests/test_local_audit_event.py b/tests/test_local_audit_event.py
index e774274..df71279 100644
--- a/tests/test_local_audit_event.py
+++ b/tests/test_local_audit_event.py
@@ -50,6 +50,8 @@ def test_rejects_invalid_required_fields_and_unknown_event_type(self) -> None:
             ({**_minimal_event(), "schema_version": 2}, "schema_version"),
             ({**_minimal_event(), "schema_version": True}, "schema_version"),
             ({**_minimal_event(), "timestamp": "not-utc"}, "timestamp"),
+            ({**_minimal_event(), "event_sequence": 0}, "event_sequence"),
+            ({**_minimal_event(), "event_sequence": True}, "event_sequence"),
             ({**_minimal_event(), "event_type": "unknown"}, "event_type"),
             ({**_minimal_event(), "event_type": []}, "event_type"),
             ({**_minimal_event(), "creator_node_id": ""}, "creator_node_id"),
@@ -168,6 +170,7 @@ def _minimal_event() -> dict[str, object]:
         "actor_node_id": "local-node-a",
         "creator_node_id": None,
         "local_run_id": "run-001",
+        "event_sequence": 1,
     }
 
 
diff --git a/tests/test_runtime_service_api_cli.py b/tests/test_runtime_service_api_cli.py
index f499d50..861014f 100644
--- a/tests/test_runtime_service_api_cli.py
+++ b/tests/test_runtime_service_api_cli.py
@@ -2608,6 +2608,45 @@ def run_after_asserting_report_is_absent(*args: Any, **kwargs: Any) -> Any:
             )
             self.assertNotIn("output_payload", audit_event)
 
+            audit_paths = (
+                root / "data" / "audit" / "job-submissions.jsonl",
+                root / "data" / "audit" / "job-executions.jsonl",
+                root / "data" / "audit" / "validation-receipt-creations.jsonl",
+                root / "data" / "audit" / "result-reports.jsonl",
+            )
+            run_events = [
+                json.loads(line)
+                for path in audit_paths
+                for line in path.read_text(encoding="utf-8").splitlines()
+                if json.loads(line)["local_run_id"] == job_id
+            ]
+            self.assertEqual(
+                [
+                    event["event_sequence"]
+                    for event in sorted(
+                        run_events, key=lambda event: event["event_sequence"]
+                    )
+                ],
+                [1, 2, 3, 4, 5],
+            )
+            for event in run_events:
+                self.assertEqual(event["local_run_id"], job_id)
+                self.assertEqual(event["creator_node_id"], request["creator_node_id"])
+                self.assertRegex(event["timestamp"], r"^\d{4}-\d{2}-\d{2}T.*Z$")
+                self.assertTrue(event["manifest_id"])
+            receipt_event = next(
+                event
+                for event in run_events
+                if event["event_type"] == "validation_receipt_created"
+            )
+            self.assertEqual(
+                receipt_event["validation_receipt_id"], report["validation_receipt_id"]
+            )
+            self.assertEqual(
+                receipt_event["lineage_refs"],
+                [submission["manifest_ref"], *request["lineage_parent_refs"]],
+            )
+
             service._append_result_reported_audit_event(
                 job_id=job_id,
                 worker_node_id="worker-local-fixture",

From 747a97ef83d9d13f982bc074cbe72cedd47b3d07 Mon Sep 17 00:00:00 2001
From: ExoHayvan <18trevor3695@gmail.com>
Date: Thu, 16 Jul 2026 17:20:44 -0400
Subject: [PATCH 2/4] fix: address automated review feedback

---
 src/aethermesh_core/contribution_record.py |  2 +-
 src/aethermesh_core/local_audit_event.py   |  4 ++--
 src/aethermesh_core/local_shutdown.py      |  2 +-
 src/aethermesh_core/local_startup.py       |  2 +-
 src/aethermesh_core/runtime_service.py     | 10 +++++-----
 tests/test_local_audit_event.py            |  4 ++--
 6 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/aethermesh_core/contribution_record.py b/src/aethermesh_core/contribution_record.py
index 20d2984..400dc96 100644
--- a/src/aethermesh_core/contribution_record.py
+++ b/src/aethermesh_core/contribution_record.py
@@ -337,7 +337,7 @@ def _append_ledger_update_audit(
         "sha256:"
     )
     event: dict[str, Any] = {
-        "schema_version": 1,
+        "schema_version": 2,
         "event_id": update_id,
         "timestamp": _utc_timestamp(clock()),
         "event_type": "contribution_record_updated",
diff --git a/src/aethermesh_core/local_audit_event.py b/src/aethermesh_core/local_audit_event.py
index e8f77e5..8461bd6 100644
--- a/src/aethermesh_core/local_audit_event.py
+++ b/src/aethermesh_core/local_audit_event.py
@@ -16,7 +16,7 @@
 from pathlib import Path, PureWindowsPath
 from typing import Any
 
-AUDIT_EVENT_SCHEMA_VERSION = 1
+AUDIT_EVENT_SCHEMA_VERSION = 2
 AUDIT_EVENT_TYPES = frozenset(
     {
         "node_initialized",
@@ -119,7 +119,7 @@ def validate_local_audit_event(event: Mapping[str, Any]) -> dict[str, Any]:
         or isinstance(document["schema_version"], bool)
         or document["schema_version"] != AUDIT_EVENT_SCHEMA_VERSION
     ):
-        raise LocalAuditEventError("local audit event.schema_version must be integer 1")
+        raise LocalAuditEventError("local audit event.schema_version must be integer 2")
     for field in ("event_id", "actor_node_id", "local_run_id"):
         _require_text(document[field], f"local audit event.{field}")
     if (
diff --git a/src/aethermesh_core/local_shutdown.py b/src/aethermesh_core/local_shutdown.py
index 7042ff0..3ad5151 100644
--- a/src/aethermesh_core/local_shutdown.py
+++ b/src/aethermesh_core/local_shutdown.py
@@ -375,7 +375,7 @@ def _append_shutdown_audit_event(
         append_local_audit_event(
             path,
             {
-                "schema_version": 1,
+                "schema_version": 2,
                 "event_id": event_id,
                 "timestamp": timestamp,
                 "event_type": "node.shutdown",
diff --git a/src/aethermesh_core/local_startup.py b/src/aethermesh_core/local_startup.py
index 1372e78..1866763 100644
--- a/src/aethermesh_core/local_startup.py
+++ b/src/aethermesh_core/local_startup.py
@@ -741,7 +741,7 @@ def _append_capability_advertisement_audit_events(
         append_local_audit_event(
             root / "logs" / "local-audit-events.jsonl",
             {
-                "schema_version": 1,
+                "schema_version": 2,
                 "event_id": (
                     f"capability-advertisement:{action}:{validation_receipt_ref}:"
                     f"{capability_id}"
diff --git a/src/aethermesh_core/runtime_service.py b/src/aethermesh_core/runtime_service.py
index 7bba62f..8f007ff 100644
--- a/src/aethermesh_core/runtime_service.py
+++ b/src/aethermesh_core/runtime_service.py
@@ -1011,7 +1011,7 @@ def submit_local_job(self, request: dict[str, Any]) -> dict[str, Any]:
             append_local_audit_event(
                 self.paths.data_dir / "audit" / "job-submissions.jsonl",
                 {
-                    "schema_version": 1,
+                    "schema_version": 2,
                     "event_id": f"local-audit-{job_id}-submitted",
                     "timestamp": datetime.now(UTC).strftime("%Y-%m-%dT%H:%M:%SZ"),
                     "event_type": "job_submitted",
@@ -2612,7 +2612,7 @@ def _append_validation_receipt_created_audit_event(
             append_local_audit_event(
                 self.paths.data_dir / "audit" / "validation-receipt-creations.jsonl",
                 {
-                    "schema_version": 1,
+                    "schema_version": 2,
                     "event_id": f"local-audit-{job_id}-validation-receipt-created",
                     "timestamp": datetime.now(UTC).strftime("%Y-%m-%dT%H:%M:%SZ"),
                     "event_type": "validation_receipt_created",
@@ -2669,7 +2669,7 @@ def _append_job_execution_started_audit_event(
             append_local_audit_event(
                 self.paths.data_dir / "audit" / "job-executions.jsonl",
                 {
-                    "schema_version": 1,
+                    "schema_version": 2,
                     "event_id": f"local-audit-{job_id}-execution-started",
                     "timestamp": datetime.now(UTC).strftime("%Y-%m-%dT%H:%M:%SZ"),
                     "event_type": "job.execution.started",
@@ -2739,7 +2739,7 @@ def _append_result_reported_audit_event(
             append_local_audit_event(
                 audit_path,
                 {
-                    "schema_version": 1,
+                    "schema_version": 2,
                     "event_id": event_id,
                     "timestamp": datetime.now(UTC).strftime("%Y-%m-%dT%H:%M:%SZ"),
                     "event_type": "result.reported",
@@ -2823,7 +2823,7 @@ def _append_job_execution_finished_audit_event(
             append_local_audit_event(
                 audit_path,
                 {
-                    "schema_version": 1,
+                    "schema_version": 2,
                     "event_id": f"local-audit-{job_id}-execution-finished",
                     "timestamp": audit_finished_at,
                     "event_type": "job.execution.finished",
diff --git a/tests/test_local_audit_event.py b/tests/test_local_audit_event.py
index df71279..0cff853 100644
--- a/tests/test_local_audit_event.py
+++ b/tests/test_local_audit_event.py
@@ -47,7 +47,7 @@ def test_rejects_invalid_required_fields_and_unknown_event_type(self) -> None:
                 },
                 "missing required",
             ),
-            ({**_minimal_event(), "schema_version": 2}, "schema_version"),
+            ({**_minimal_event(), "schema_version": 1}, "schema_version"),
             ({**_minimal_event(), "schema_version": True}, "schema_version"),
             ({**_minimal_event(), "timestamp": "not-utc"}, "timestamp"),
             ({**_minimal_event(), "event_sequence": 0}, "event_sequence"),
@@ -163,7 +163,7 @@ def test_execution_started_requires_compact_execution_provenance(self) -> None:
 
 def _minimal_event() -> dict[str, object]:
     return {
-        "schema_version": 1,
+        "schema_version": 2,
         "event_id": "audit-init-001",
         "timestamp": "2026-07-15T06:00:00Z",
         "event_type": "node_initialized",

From 725c10c7011cc7ece58acf37e5a806fbde2b639d Mon Sep 17 00:00:00 2001
From: ExoHayvan <18trevor3695@gmail.com>
Date: Thu, 16 Jul 2026 17:50:21 -0400
Subject: [PATCH 3/4] fix: address automated review feedback

---
 src/aethermesh_core/local_audit_event.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/aethermesh_core/local_audit_event.py b/src/aethermesh_core/local_audit_event.py
index 8461bd6..81745c8 100644
--- a/src/aethermesh_core/local_audit_event.py
+++ b/src/aethermesh_core/local_audit_event.py
@@ -95,7 +95,7 @@
 
 
 class LocalAuditEventError(ValueError):
-    """Raised when a local audit event does not match the stable v1 format."""
+    """Raised when a local audit event does not match the canonical format."""
 
 
 def validate_local_audit_event(event: Mapping[str, Any]) -> dict[str, Any]:

From aaba66f48c70d1b0d09578c0d303c52b31deb182 Mon Sep 17 00:00:00 2001
From: ExoHayvan <18trevor3695@gmail.com>
Date: Thu, 16 Jul 2026 18:03:55 -0400
Subject: [PATCH 4/4] fix: address automated review feedback

---
 docs/local-audit-event-schema.md | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/docs/local-audit-event-schema.md b/docs/local-audit-event-schema.md
index feb8209..befd0aa 100644
--- a/docs/local-audit-event-schema.md
+++ b/docs/local-audit-event-schema.md
@@ -1,6 +1,6 @@
 # Local Audit Event Schema
 
-`aethermesh_core.local_audit_event` defines the small, stable v1 event format for a local JSONL audit log. It makes prototype actions traceable on one machine. It is not a production security log, peer protocol, blockchain, consensus record, reward ledger, or claim of decentralized finality.
+`aethermesh_core.local_audit_event` defines the small, stable v2 event format for a local JSONL audit log. It makes prototype actions traceable on one machine. It is not a production security log, peer protocol, blockchain, consensus record, reward ledger, or claim of decentralized finality.
 
 ## Storage and append-only rule
 
@@ -10,13 +10,16 @@ Store one event per UTF-8 newline-delimited JSON (JSONL) line, normally under th
 
 | Field | Type | Meaning |
 | --- | --- | --- |
-| `schema_version` | integer `1` | Event-format version. |
+| `schema_version` | integer `2` | Event-format version. |
 | `event_id` | non-empty string | Locally unique event identifier chosen by the caller. |
 | `timestamp` | UTC timestamp (`YYYY-MM-DDTHH:MM:SSZ`) | Human-readable timestamp recorded by the caller. |
 | `event_type` | enum | Prototype action listed below. |
 | `actor_node_id` | non-empty string | Node performing or recording the action. |
 | `creator_node_id` | non-empty string or `null` | Original creator node when known; `null` explicitly records that it is not known. |
 | `local_run_id` | non-empty string | Local invocation/run that produced the event. |
+| `event_sequence` | positive integer | Stable ordering position of the event within its local run. |
+
+Version 2 adds `event_sequence` so events from separate JSONL files can be reconstructed in flow order without relying on equal-second timestamps. Existing version 1 lines remain immutable historical evidence; the current validator accepts newly produced version 2 events.
 
 Supported event types are `node_initialized`, `manifest_created`, `work_submitted`, `job_submitted`, `validation_attempted`, `validation_result`, `validation_receipt_created`, `lineage_linked`, `contribution_record_updated`, `capability_advertised`, and `node.shutdown`.
 
@@ -62,13 +65,13 @@ A `validation_receipt_created` event is appended to `data/audit/validation-recei
 A minimal initialization event intentionally has no optional references:
 
 ```json
-{"actor_node_id":"local-node-a","creator_node_id":"local-node-a","event_id":"audit-init-001","event_type":"node_initialized","local_run_id":"run-001","schema_version":1,"timestamp":"2026-07-15T06:00:00Z"}
+{"actor_node_id":"local-node-a","creator_node_id":"local-node-a","event_id":"audit-init-001","event_sequence":1,"event_type":"node_initialized","local_run_id":"run-001","schema_version":2,"timestamp":"2026-07-15T06:00:00Z"}
 ```
 
 This validation-result event links local manifest, work, receipt, lineage, contribution attribution, and related artifacts without any network access:
 
 ```json
-{"actor_node_id":"validator-local-a","contribution_attribution_ids":["local-contribution-work-001"],"creator_node_id":"creator-local-a","event_id":"audit-validation-001","event_type":"validation_result","hashes":{"result_hash":"sha256:example"},"lineage_parent_ids":["work-parent-001"],"local_run_id":"run-001","manifest_id":"manifest-work-001","related_file_paths":["data/manifests/work-001.json","data/receipts/work-001.json"],"schema_version":1,"timestamp":"2026-07-15T06:01:00Z","validation_receipt_id":"receipt-work-001","work_id":"work-001"}
+{"actor_node_id":"validator-local-a","contribution_attribution_ids":["local-contribution-work-001"],"creator_node_id":"creator-local-a","event_id":"audit-validation-001","event_sequence":2,"event_type":"validation_result","hashes":{"result_hash":"sha256:example"},"lineage_parent_ids":["work-parent-001"],"local_run_id":"run-001","manifest_id":"manifest-work-001","related_file_paths":["data/manifests/work-001.json","data/receipts/work-001.json"],"schema_version":2,"timestamp":"2026-07-15T06:01:00Z","validation_receipt_id":"receipt-work-001","work_id":"work-001"}
 ```
 
 The examples are individual JSONL lines. They remain readable with ordinary JSON tooling, and a local script can parse each non-empty line with `json.loads` before calling `validate_local_audit_event`.