feat: Create lenra data service

apps/lenra/lib/lenra/services/data_service.ex

@@ -0,0 +1,59 @@
+defmodule Lenra.DataServices do
+ @moduledoc """
+ The service that manages application data.
+ """
+ import Ecto.Query, only: [from: 2]
+
+ alias Lenra.Repo
+ alias ApplicationRunner.{Data, DataServices, Datastore, UserData}
+
+ def create(environment_id, params) do
+ environment_id
+ |> DataServices.create(params)
+ |> Repo.transaction()
+ end
+
+ def create_and_link(user_id, environment_id, params) do
+ environment_id
+ |> DataServices.create(params)
+ |> Ecto.Multi.run(:user_data, fn repo, %{inserted_data: %Data{} = data} ->
+ repo.insert(UserData.new(%{user_id: user_id, data_id: data.id}))
+ end)
+ |> Repo.transaction()
+ end
+
+ def update(data_id, params) do
+ data_id
+ |> DataServices.update(params)
+ |> Repo.transaction()
+ end
+
+ def delete(data_id) do
+ data_id
+ |> DataServices.delete()
+ |> Repo.transaction()
+ end
+
+ def get_old_data(user_id, environement_id) do
+ Repo.one(
+ from(d in Data,
+ join: u in UserData,
+ on: d.id == u.data_id,
+ join: ds in Datastore,
+ on: ds.id == d.datastore_id,
+ where: u.user_id == ^user_id and ds.environment_id == ^environement_id and ds.name == "UserDatas",
+ select: d
+ )
+ )
+ end
+
+ def upsert_data(user_id, environment_id, data) do
+ case get_old_data(user_id, environment_id) do
+ nil ->
+ create_and_link(user_id, environment_id, data)
+
+ old_data_id ->
+ update(old_data_id.id, data)
+ end
+ end
+end

apps/lenra/test/lenra/services/data_services_test.exs

@@ -0,0 +1,58 @@
+defmodule Lenra.DataServicesTest do
+ @moduledoc """
+ Test the datastore services
+ """
+ use Lenra.RepoCase, async: true
+
+ alias ApplicationRunner.DatastoreServices
+ alias Lenra.{DataServices, Environment, LenraApplication, LenraApplicationServices, Repo}
+
+ setup do
+ {:ok, %{inserted_user: user}} = UserTestHelper.register_john_doe()
+
+ LenraApplicationServices.create(user.id, %{
+ name: "mine-sweeper",
+ color: "FFFFFF",
+ icon: "60189"
+ })
+
+ env = Repo.get_by(Environment, application_id: Enum.at(Repo.all(LenraApplication), 0).id)
+ {:ok, env_id: env.id, user_id: user.id}
+ end
+
+ describe "Lenra.DataServices.get_old_data_1/1" do
+ test "should return last data", %{env_id: env_id, user_id: user_id} do
+ env_id
+ |> DatastoreServices.create(%{"name" => "UserDatas"})
+ |> Repo.transaction()
+
+ DataServices.create_and_link(user_id, env_id, %{"datastore" => "UserDatas", "data" => %{"test" => "test"}})
+
+ assert %{"test" => "test"} = DataServices.get_old_data(user_id, env_id).data
+ end
+ end
+
+ describe "Lenra.DataServices.upsert_data_1/1" do
+ test "should update last data if data exist", %{env_id: env_id, user_id: user_id} do
+ env_id
+ |> DatastoreServices.create(%{"name" => "UserDatas"})
+ |> Repo.transaction()
+
+ DataServices.create_and_link(user_id, env_id, %{"datastore" => "UserDatas", "data" => %{"test" => "test"}})
+
+ DataServices.upsert_data(user_id, env_id, %{"datastore" => "UserDatas", "data" => %{"test" => "test2"}})
+
+ assert %{"test" => "test2"} = DataServices.get_old_data(user_id, env_id).data
+ end
+
+ test "should create data if data not exist", %{env_id: env_id, user_id: user_id} do
+ env_id
+ |> DatastoreServices.create(%{"name" => "UserDatas"})
+ |> Repo.transaction()
+
+ DataServices.upsert_data(user_id, env_id, %{"datastore" => "UserDatas", "data" => %{"test" => "test"}})
+
+ assert %{"test" => "test"} = DataServices.get_old_data(user_id, env_id).data
+ end
+ end
+end