Add the sync task for Publisher.

test/decentralised_book_index/sync/data_transformers/publisher_transformer_test.exs

@@ -0,0 +1,64 @@
+defmodule DecentralisedBookIndex.Sync.DataTransformers.PublisherTransformerTest do
+  use ExUnit.Case, async: true
+
+  alias DecentralisedBookIndex.Sync.DataTransformers.PublisherTransformer
+  alias DecentralisedBookIndex.Metadata.Publisher
+
+  describe "correct transformations" do
+    test "a json contains correct publisher information" do
+      json_body = %{
+        "data" => %{
+          "attributes" => %{
+            "inserted_at" => "2025-03-21T09:20:48.791539Z",
+            "name" => "Publisher",
+            "updated_at" => "2025-03-21T09:20:48.791539Z"
+          },
+          "id" => "11349865-1b7b-454a-b999-6c4059888a78",
+          "links" => %{},
+          "meta" => %{},
+          "relationships" => %{},
+          "type" => "publisher"
+        },
+        "jsonapi" => %{"version" => "1.0"},
+        "links" => %{
+          "self" =>
+            "http://localhost:4000/api/v1/json/publishers/11349865-1b7b-454a-b999-6c4059888a78"
+        },
+        "meta" => %{}
+      }
+
+      assert {:ok, publisher} = PublisherTransformer.from_json(json_body)
+
+      assert %{
+               id: "11349865-1b7b-454a-b999-6c4059888a78",
+               name: "Publisher",
+               inserted_at: "2025-03-21T09:20:48.791539Z",
+               updated_at: "2025-03-21T09:20:48.791539Z"
+             } = publisher
+    end
+
+    test "a json doesn't contains publisher information \"data\" attribute" do
+      json_body = %{
+        "attributes" => %{
+          "inserted_at" => "2025-03-21T09:20:48.791539Z",
+          "name" => "Publisher",
+          "updated_at" => "2025-03-21T09:20:48.791539Z"
+        },
+        "id" => "11349865-1b7b-454a-b999-6c4059888a78",
+        "links" => %{},
+        "meta" => %{},
+        "relationships" => %{},
+        "type" => "publisher"
+      }
+
+      assert {:ok, publisher} = PublisherTransformer.from_json(json_body)
+
+      assert %{
+               id: "11349865-1b7b-454a-b999-6c4059888a78",
+               name: "Publisher",
+               inserted_at: "2025-03-21T09:20:48.791539Z",
+               updated_at: "2025-03-21T09:20:48.791539Z"
+             } = publisher
+    end
+  end
+end

test/decentralised_book_index/sync/sync/publisher_sync_test.exs

@@ -0,0 +1,53 @@
+defmodule DecentralisedBookIndex.Sync.DataTransformers.PublisherSyncTest do
+  use DecentralisedBookIndex.DataCase, async: true
+
+  alias DecentralisedBookIndex.Sync.PublisherSync
+  alias DecentralisedBookIndex.Metadata
+
+  alias DecentralisedBookIndex.TestEndpoints
+  @test_server_endpoint TestEndpoints.test_api_endpoint()
+
+  describe "sync publisher transformations" do
+    test "a new publisher will be created" do
+      server = generate(dbi_server(url: @test_server_endpoint))
+
+      publisher = %{
+        id: "11349865-1b7b-454a-b999-6c4059888a78",
+        name: "Publisher",
+        inserted_at: "2025-03-21T09:20:48.791539Z",
+        updated_at: "2025-03-21T09:20:48.791539Z"
+      }
+
+      {:ok, inserted_at, 0} = DateTime.from_iso8601(publisher[:inserted_at])
+      {:ok, updated_at, 0} = DateTime.from_iso8601(publisher[:updated_at])
+
+      assert :ok = PublisherSync.create_update(publisher, server.id)
+      assert {:ok, saved_publisher} = Metadata.get_publisher_by_id(publisher.id)
+
+      publisher =
+        publisher
+        |> Map.replace(:inserted_at, inserted_at)
+        |> Map.replace(:updated_at, updated_at)
+
+      assert publisher = saved_publisher
+    end
+
+    test "update an existing publisher" do
+      server = generate(dbi_server(url: @test_server_endpoint))
+
+      {:ok, publisher} = Metadata.create_publisher("Publisher")
+
+      publisher_attrs = %{
+        id: publisher.id,
+        name: "Publisher",
+        inserted_at: "2025-03-21T09:20:48.791539Z",
+        updated_at: "2025-03-21T09:20:48.791539Z"
+      }
+
+      assert :ok = PublisherSync.create_update(publisher_attrs, server.id)
+      assert {:ok, saved_publisher} = Metadata.get_publisher_by_id(publisher.id)
+
+      assert publisher_attrs = saved_publisher
+    end
+  end
+end

test/decentralised_book_index/sync/sync_tasks/sync_publishers_task_test.exs

@@ -0,0 +1,20 @@
+defmodule DecentralisedBookIndex.SyncTasks.SyncPublishersTaskTest do
+  use DecentralisedBookIndex.DataCase
+
+  alias DecentralisedBookIndex.SyncTasks.SyncPublishersTask
+  alias DecentralisedBookIndex.Metadata
+
+  alias DecentralisedBookIndex.TestEndpoints
+  @test_server_endpoint TestEndpoints.test_api_endpoint()
+
+  describe "sync publishers tasks" do
+    test "sync publisher" do
+      server = generate(dbi_server(url: @test_server_endpoint))
+
+      {:ok, _publisher} = Metadata.create_publisher("Publisher")
+      {:ok, _publisher} = Metadata.create_publisher("Publisher2")
+
+      assert server = SyncPublishersTask.sync(server)
+    end
+  end
+end