Merge pull request #56 from pentops/new-o5-go

Update to latest o5-go

go.mod

@@ -12,7 +12,7 @@ require (
 	github.com/pentops/flowtest v0.0.0-20231213175137-ac050902e7fb
 	github.com/pentops/jsonapi v0.0.0-20240125182748-28bbbf8f7311
 	github.com/pentops/log.go v0.0.0-20231218074934-67aedcab3fa4
-	github.com/pentops/o5-go v0.0.0-20240306185104-17c6e899663b
+	github.com/pentops/o5-go v0.0.0-20240318210923-9e96edcd2e31
 	github.com/pentops/pgtest.go v0.0.0-20230712031943-dd86c8524dcb
 	github.com/pentops/protostate v0.0.0-20240315215838-b375646b3871
 	github.com/pentops/sqrlx.go v0.0.0-20240108202916-8687fdf983c0

go.sum

@@ -99,8 +99,8 @@ github.com/pentops/jsonapi v0.0.0-20240125182748-28bbbf8f7311 h1:JeqazO7kfp3xmgg
 github.com/pentops/jsonapi v0.0.0-20240125182748-28bbbf8f7311/go.mod h1:+G29pelqimEuvqxtzUS3or1tZKssK8Mc0+JBInSR5k0=
 github.com/pentops/log.go v0.0.0-20231218074934-67aedcab3fa4 h1:7kPDmBAQxMxcFIYt1rEco/AipZmm1CUoND3wSDmIOeI=
 github.com/pentops/log.go v0.0.0-20231218074934-67aedcab3fa4/go.mod h1:UXhrs+VZ6cWZ7b/v8AtuvBZc5nwS5WFHP94JoFrZQA8=
-github.com/pentops/o5-go v0.0.0-20240306185104-17c6e899663b h1:8OIZwtms0CvNb5t1qpmOQvLUufjzLpskfAXiCj6b2Mg=
-github.com/pentops/o5-go v0.0.0-20240306185104-17c6e899663b/go.mod h1:8OCaJmBMRQ9oboVy1eV400SQp6yuXWk7n2XCgHlc4EE=
+github.com/pentops/o5-go v0.0.0-20240318210923-9e96edcd2e31 h1:0Vix22z3BPl5t9wZGYb0Wq1p+YLgWg1cYCwg5ZvSLpE=
+github.com/pentops/o5-go v0.0.0-20240318210923-9e96edcd2e31/go.mod h1:VpCdb0FteYtJ5A2Kmgfesunf7IskQC/IFajOX39wnqQ=
 github.com/pentops/outbox.pg.go v0.0.0-20231222014950-493c01cfbcc7 h1:rBLoeUeI1acxd6GbJjJbK6CeVF/q/Xab+xqQYePvNSw=
 github.com/pentops/outbox.pg.go v0.0.0-20231222014950-493c01cfbcc7/go.mod h1:yMefMPLP0eBAxdELkAgjTtnhWFfc0Wk2H2kePByDHRo=
 github.com/pentops/pgtest.go v0.0.0-20230712031943-dd86c8524dcb h1:1OIQFqb6RU4OmKXdonwvYHNex0JPQy5gOs0eZTeIwfI=

integration/dead_test.go

@@ -68,6 +68,7 @@ func TestUpdate(tt *testing.T) {
 			QueueName:      "new-queue-name",
 			GrpcName:       msg.GrpcName,
 			Payload:        msg.Payload,
+			CreatedAt:      timestamppb.Now(),
 		}
 		req := &dante_spb.UpdateDeadMessageRequest{
 			MessageId: msg.MessageId,