feat: initial Plutia release — verifiable high-performance PLC mirror (mirror + resolver modes)

1 files changed, 38 insertions, 0 deletions

diff --git a/internal/ingest/client_test.go b/internal/ingest/client_test.go
new file mode 100644
index 0000000..ff80225
--- /dev/null
+++ b/internal/ingest/client_test.go
@@ -0,0 +1,38 @@
+package ingest
+
+import (
+	"strings"
+	"testing"
+)
+
+func TestDecodeExportBody_IgnoresTrailingPartialNDJSONLine(t *testing.T) {
+	body := strings.Join([]string{
+		`{"seq":1,"did":"did:plc:alice","cid":"cid1","operation":{"x":1}}`,
+		`{"seq":2,"did":"did:plc:bob","cid":"cid2","operation":{"x":2}}`,
+		`{"seq":3,"did":"did:plc:carol","cid":"cid3","operation":{"x":3}`,
+	}, "\n")
+
+	records, err := decodeExportBody(strings.NewReader(body), 0)
+	if err != nil {
+		t.Fatalf("decode export body: %v", err)
+	}
+	if len(records) != 2 {
+		t.Fatalf("record count mismatch: got %d want 2", len(records))
+	}
+	if records[0].Seq != 1 || records[1].Seq != 2 {
+		t.Fatalf("unexpected sequences: got [%d %d], want [1 2]", records[0].Seq, records[1].Seq)
+	}
+}
+
+func TestDecodeExportBody_FailsOnMalformedNonTrailingNDJSONLine(t *testing.T) {
+	body := strings.Join([]string{
+		`{"seq":1,"did":"did:plc:alice","cid":"cid1","operation":{"x":1}}`,
+		`{"seq":2,"did":"did:plc:bob","cid":"cid2","operation":{"x":2}`,
+		`{"seq":3,"did":"did:plc:carol","cid":"cid3","operation":{"x":3}}`,
+	}, "\n")
+
+	_, err := decodeExportBody(strings.NewReader(body), 0)
+	if err == nil {
+		t.Fatalf("expected malformed middle line to fail")
+	}
+}