From 83787aed1c804ba669887f752250f0c21498f8a6 Mon Sep 17 00:00:00 2001
From: Jay <jay@wisehodl.dev>
Date: Fri, 22 May 2026 16:36:16 -0400
Subject: [PATCH] Phase 5: promote EventTraveller.Event to ValidatedEvent;
 remove temporary adapter

---
 write.go      | 16 +++++++---------
 write_test.go |  4 ++--
 2 files changed, 9 insertions(+), 11 deletions(-)

diff --git a/write.go b/write.go
index a4a23aa..fb44a48 100644
--- a/write.go
+++ b/write.go
@@ -19,7 +19,7 @@ type WriteOptions struct {
 type EventTraveller struct {
 	ID       string
 	JSON     []byte
-	Event    roots.Event
+	Event    roots.ValidatedEvent
 	Subgraph *EventSubgraph
 	Error    error
 }
@@ -95,23 +95,23 @@ func createEventTravellers(jsons [][]byte) []EventTraveller {
 
 func parseEventJSON(in []EventTraveller) (parsed []EventTraveller, excluded []EventTraveller) {
 	for _, traveller := range in {
-		var event roots.Event
-		err := json.Unmarshal(traveller.JSON, &event)
+		var raw roots.Event
+		err := json.Unmarshal(traveller.JSON, &raw)
 		if err != nil {
 			traveller.Error = fmt.Errorf("rejected: %w: %w", ErrMalformedJSON, err)
 			excluded = append(excluded, traveller)
 			continue
 		}
 
-		err = roots.Validate(event)
+		validated, err := roots.NewValidatedEvent(raw)
 		if err != nil {
 			traveller.Error = fmt.Errorf("rejected: %w: %w", ErrInvalidEvent, err)
 			excluded = append(excluded, traveller)
 			continue
 		}
 
-		traveller.ID = event.ID
-		traveller.Event = event
+		traveller.ID = validated.ID()
+		traveller.Event = validated
 		parsed = append(parsed, traveller)
 	}
 	return parsed, excluded
@@ -146,9 +146,7 @@ func enforcePolicyRules(in []EventTraveller, boltdb *bolt.DB, batchSize int) (qu
 
 func convertEventsToSubgraphs(in []EventTraveller, expanders ExpanderPipeline) []EventTraveller {
 	for i, traveller := range in {
-		// TODO: temporary adapter — removed in Phase 5
-		validated, _ := roots.NewValidatedEvent(traveller.Event)
-		in[i].Subgraph = EventToSubgraph(validated, expanders)
+		in[i].Subgraph = EventToSubgraph(traveller.Event, expanders)
 	}
 	return in
 }
diff --git a/write_test.go b/write_test.go
index deacd4c..f4c568d 100644
--- a/write_test.go
+++ b/write_test.go
@@ -133,7 +133,7 @@ func TestParseEventJSON(t *testing.T) {
 
 			for _, reject := range rejected {
 				assert.NotNil(t, reject.Error)
-				assert.Empty(t, reject.Event.ID)
+				assert.Empty(t, reject.Event.ID())
 			}
 		})
 	}
@@ -224,7 +224,7 @@ func TestConvertEventsToSubgraphs(t *testing.T) {
 	}{
 		{
 			name:          "event with no tags",
-			traveller:     EventTraveller{Event: fx.ValidatedEvent(t, "bare").Event()},
+			traveller:     EventTraveller{Event: fx.ValidatedEvent(t, "bare")},
 			wantNodeCount: 2, // event + user
 			wantRelCount:  1, // signed
 		},