Add more data tests.

Author: nasdf

data/author_test.go

@@ -0,0 +1,52 @@
+package data
+
+import (
+	"context"
+	"os"
+	"testing"
+
+	"github.com/ipfs/go-merkledag/dagutils"
+)
+
+func TestAuthorRoundtrip(t *testing.T) {
+	ctx := context.Background()
+	dag := dagutils.NewMemoryDagService()
+
+	data, err := os.ReadFile("testdata/author.json")
+	if err != nil {
+		t.Fatal("failed to read file")
+	}
+
+	author, err := AuthorFromJSON(data)
+	if err != nil {
+		t.Fatal("failed to decode author json")
+	}
+
+	id, err := AddAuthor(ctx, dag, author)
+	if err != nil {
+		t.Fatal("failed to add author to dag")
+	}
+
+	author, err = GetAuthor(ctx, dag, id)
+	if err != nil {
+		t.Fatal("failed to get author from dag")
+	}
+
+	if len(author.Metadata) != 1 {
+		t.Error("unexpected metadata")
+	}
+
+	meta, ok := author.Metadata["foo"]
+	if !ok || meta != "bar" {
+		t.Error("unexpected metadata value")
+	}
+
+	if len(author.Repositories) != 1 {
+		t.Error("unexpected repositories")
+	}
+
+	repo, ok := author.Repositories["test"]
+	if !ok || repo.String() != "bafyreib2rnmsqouz67uvb4jcjsqdvsmakdn3zrpswt4ud7aegbfohyrkbe" {
+		t.Error("unexpected repository value")
+	}
+}

data/commit_test.go

@@ -1,73 +1,44 @@
 package data
 
 import (
+	"context"
+	"os"
 	"testing"
 	"time"
 
-	"github.com/ipfs/go-ipld-cbor"
+	"github.com/ipfs/go-merkledag/dagutils"
 )
 
-var data = []byte(`{
-	"date": "2020-10-25T15:26:12.168056-07:00",
-	"message": "big changes",
-	"parents": [{"/": "bagaybqabciqeutn2u7n3zuk5b4ykgfwpkekb7ctgnlwik5zfr6bcukvknj2jtpa"}],
-	"tree": {"/": "QmQycvPQd5tAVP4Xx1dp1Yfb9tmjKQAa5uxPoTfUQr9tFZ"},
-	"metadata": {"foo": "bar"}
-}`)
+func TestCommitRoundtrip(t *testing.T) {
+	ctx := context.Background()
+	dag := dagutils.NewMemoryDagService()
 
-func TestCommitFromJSON(t *testing.T) {
-	commit, err := CommitFromJSON(data)
+	data, err := os.ReadFile("testdata/commit.json")
 	if err != nil {
-		t.Fatalf("failed to decode commit json")
-	}
-
-	if commit.Message != "big changes" {
-		t.Error("message does not match")
+		t.Fatal("failed to read file")
 	}
 
-	if commit.Date.Format(time.RFC3339) != "2020-10-25T15:26:12-07:00" {
-		t.Error("date does not match")
-	}
-
-	if len(commit.Parents) != 1 {
-		t.Error("parents does not match")
-	}
-
-	if commit.Parents[0].String() != "bagaybqabciqeutn2u7n3zuk5b4ykgfwpkekb7ctgnlwik5zfr6bcukvknj2jtpa" {
-		t.Error("parents does not match")
-	}
-
-	if commit.Tree.String() != "QmQycvPQd5tAVP4Xx1dp1Yfb9tmjKQAa5uxPoTfUQr9tFZ" {
-		t.Error("work tree does not match")
-	}
-
-	if commit.Metadata["foo"] != "bar" {
-		t.Error("metadata does not match")
-	}
-}
-
-func TestCommitFromCBOR(t *testing.T) {
 	commit, err := CommitFromJSON(data)
 	if err != nil {
-		t.Fatalf("failed to decode commit")
+		t.Fatal("failed to decode commit json")
 	}
 
-	data, err := cbornode.DumpObject(commit)
+	id, err := AddCommit(ctx, dag, commit)
 	if err != nil {
-		t.Fatalf("failed to encode commit")
+		t.Fatal("failed to add commit to dag")
 	}
 
-	commit, err = CommitFromCBOR(data)
+	commit, err = GetCommit(ctx, dag, id)
 	if err != nil {
-		t.Fatalf("failed to decode commit")
+		t.Fatal("failed to add commit to dag")
 	}
 
 	if commit.Message != "big changes" {
 		t.Error("message does not match")
 	}
 
 	if commit.Date.Format(time.RFC3339) != "2020-10-25T15:26:12-07:00" {
-		t.Errorf("date does not match")
+		t.Error("date does not match")
 	}
 
 	if len(commit.Parents) != 1 {
@@ -82,12 +53,18 @@ func TestCommitFromCBOR(t *testing.T) {
 		t.Error("work tree does not match")
 	}
 
-	if commit.Metadata["foo"] != "bar" {
+	meta, ok := commit.Metadata["foo"]
+	if !ok || meta != "bar" {
 		t.Error("metadata does not match")
 	}
 }
 
 func TestCommitParentLinks(t *testing.T) {
+	data, err := os.ReadFile("testdata/commit.json")
+	if err != nil {
+		t.Fatal("failed to read file")
+	}
+
 	commit, err := CommitFromJSON(data)
 	if err != nil {
 		t.Fatal("failed to decode commit")

data/repository_test.go

@@ -0,0 +1,65 @@
+package data
+
+import (
+	"context"
+	"os"
+	"testing"
+
+	"github.com/ipfs/go-merkledag/dagutils"
+)
+
+func TestRepositoryRoundtrip(t *testing.T) {
+	ctx := context.Background()
+	dag := dagutils.NewMemoryDagService()
+
+	data, err := os.ReadFile("testdata/repository.json")
+	if err != nil {
+		t.Fatal("failed to read file")
+	}
+
+	repo, err := RepositoryFromJSON(data)
+	if err != nil {
+		t.Fatal("failed to decode repo json")
+	}
+
+	id, err := AddRepository(ctx, dag, repo)
+	if err != nil {
+		t.Fatal("failed to add repo to dag")
+	}
+
+	repo, err = GetRepository(ctx, dag, id)
+	if err != nil {
+		t.Fatal("failed to get repo from dag")
+	}
+
+	if repo.DefaultBranch != "default" {
+		t.Error("default branch does not match")
+	}
+
+	if len(repo.Branches) != 1 {
+		t.Fatal("unexpected branches")
+	}
+
+	branch, ok := repo.Branches["default"]
+	if !ok || branch.String() != "bafyreieo2mhnqyqntenwyndzxoovw5nhbpit727kjrl3mjbyb5nv6zs2pu" {
+		t.Error("unexpected branch value")
+	}
+
+	if len(repo.Tags) != 1 {
+		t.Fatal("unexpected tags")
+	}
+
+	tag, ok := repo.Tags["v0.0.1"]
+	if !ok || tag.String() != "bafyreieo2mhnqyqntenwyndzxoovw5nhbpit727kjrl3mjbyb5nv6zs3pu" {
+		t.Error("unexpected tag value")
+	}
+
+	if len(repo.Metadata) != 1 {
+		t.Fatal("unexpected metadata")
+	}
+
+	meta, ok := repo.Metadata["foo"]
+	if !ok || meta != "bar" {
+		t.Error("unexpected metadata value")
+	}
+}

data/testdata/author.json

@@ -0,0 +1,6 @@
+{
+	"repositories": {
+		"test": {"/": "bafyreib2rnmsqouz67uvb4jcjsqdvsmakdn3zrpswt4ud7aegbfohyrkbe"}
+	},
+	"metadata": {"foo": "bar"}
+}

data/testdata/commit.json

@@ -0,0 +1,7 @@
+{
+	"date": "2020-10-25T15:26:12.168056-07:00",
+	"message": "big changes",
+	"parents": [{"/": "bagaybqabciqeutn2u7n3zuk5b4ykgfwpkekb7ctgnlwik5zfr6bcukvknj2jtpa"}],
+	"tree": {"/": "QmQycvPQd5tAVP4Xx1dp1Yfb9tmjKQAa5uxPoTfUQr9tFZ"},
+	"metadata": {"foo": "bar"}
+}

data/testdata/repository.json

@@ -0,0 +1,10 @@
+{
+	"default_branch": "default",
+	"branches": {
+		"default": {"/": "bafyreieo2mhnqyqntenwyndzxoovw5nhbpit727kjrl3mjbyb5nv6zs2pu"}
+	},
+	"tags": {
+		"v0.0.1": {"/": "bafyreieo2mhnqyqntenwyndzxoovw5nhbpit727kjrl3mjbyb5nv6zs3pu"}
+	},
+	"metadata": {"foo": "bar"}
+}