activities (with has_many on_replace: :ignore)

Author: lastcanal

lib/algora/accounts/schemas/identity.ex

@@ -15,6 +15,8 @@ defmodule Algora.Accounts.Identity do
     field :provider_id, :string
     field :provider_meta, :map
 
+    has_many :activities, {"identity_activities", Algora.Activities.Activity}, foreign_key: :assoc_id
+
     belongs_to :user, User
 
     timestamps()

lib/algora/accounts/schemas/user.ex

@@ -85,6 +85,7 @@ defmodule Algora.Accounts.User do
     has_many :connected_installations, Installation, foreign_key: :connected_user_id
     has_many :contractor_contracts, Contract, foreign_key: :contractor_id
     has_many :client_contracts, Contract, foreign_key: :client_id
+    has_many :activities, {"account_activities", Algora.Activities.Activity}, foreign_key: :assoc_id
 
     has_one :customer, Algora.Payments.Customer, foreign_key: :user_id
 

lib/algora/activities/activities.ex

@@ -0,0 +1,78 @@
+defmodule Algora.Activities do
+  @moduledoc false
+  import Ecto.Changeset
+  import Ecto.Query
+
+  alias Algora.Activities.Activity
+  alias Algora.Repo
+
+  @tables [
+    :account_activities,
+    :contract_activities
+  ]
+
+  def base_query do
+    [head | tail] = @tables
+
+    query = head |> to_string() |> base_query()
+
+    Enum.reduce(tail, query, fn table_name, acc ->
+      new_query = table_name |> to_string() |> base_query()
+      union_all(new_query, ^acc)
+    end)
+  end
+
+  def base_query(table_name) do
+    from(_e in {table_name, Activity})
+  end
+
+  def base_query_for_user(user_id) do
+    [head | tail] = [:client_contracts, :contractor_contracts]
+    first_query = base_query_for_user(user_id, head)
+
+    Enum.reduce(tail, first_query, fn relation_name, acc ->
+      new_query = base_query_for_user(user_id, relation_name)
+      union_all(new_query, ^acc)
+    end)
+  end
+
+  def base_query_for_user(user_id, name) do
+    from u in Algora.Accounts.User,
+      where: u.id == ^user_id,
+      join: c in assoc(u, ^name),
+      join: a in assoc(c, :activities),
+      select: a
+  end
+
+  def all(table_name) when is_binary(table_name) do
+    table_name
+    |> base_query()
+    |> order_by(desc: :inserted_at)
+    |> Repo.all()
+  end
+
+  def all(target) when is_map(target) do
+    Repo.all(Ecto.assoc(target, :activities))
+  end
+
+  def all do
+    base_query()
+    |> order_by(fragment("inserted_at DESC"))
+    |> limit(40)
+    |> Repo.all()
+  end
+
+  def all_for_user(user_id) do
+    user_id
+    |> base_query_for_user()
+    |> order_by(fragment("inserted_at DESC"))
+    |> limit(40)
+    |> Repo.all()
+  end
+
+  def insert(target, activity) do
+    target
+    |> Activity.build_activity(activity)
+    |> Algora.Repo.insert()
+  end
+end

lib/algora/activities/schemas/activity.ex

@@ -0,0 +1,81 @@
+defmodule Algora.Activities.Activity do
+  @moduledoc false
+  use Algora.Schema
+
+  require Protocol
+
+  @activity_types ~w{
+    contract_paid
+    contract_prepaid
+    contract_created
+    contract_renewed
+    transaction_status_change
+    transaction_created
+    transaction_failed
+    transaction_processed
+  }a
+
+  typed_schema "activities" do
+    field :assoc_id, :string
+    field :type, Ecto.Enum, values: @activity_types
+    field :visibility, Ecto.Enum, values: [:public, :private, :internal], default: :internal
+    field :template, :string
+    field :meta, :map, default: %{}
+    field :changes, :map, default: %{}
+    field :trace_id, :string
+    field :notify_users, {:array, :string}, default: []
+
+    belongs_to :user, Algora.Accounts.User
+    belongs_to :previous_event, __MODULE__
+
+    timestamps()
+  end
+
+  @doc false
+  def changeset(activity, attrs) do
+    activity
+    |> cast(attrs, [:type, :visibility, :template, :meta, :changes, :trace_id, :user_id, :previous_event_id])
+    |> validate_required([:type])
+    |> foreign_key_constraint(:assoc_id)
+    |> foreign_key_constraint(:user_id)
+    |> foreign_key_constraint(:previous_event_id)
+    |> generate_id()
+  end
+
+  def build_activity(target, %{meta: %struct{}} = activity) when struct in [Stripe.Error] do
+    build_activity(target, %{activity | meta: Algora.Utils.normalize_struct(struct)})
+  end
+
+  def build_activity(target, activity) do
+    target
+    |> Ecto.build_assoc(:activities)
+    |> Algora.Activities.Activity.changeset(activity)
+  end
+
+  def put_activity(target, activity) do
+    put_activity(change(target), target, activity)
+  end
+
+  def put_activiies(target, activities) do
+    put_activities(change(target), target, activities)
+  end
+
+  def put_activity(changeset, target, activity) do
+    put_activities(changeset, target, [activity])
+  end
+
+  def put_activities(%Ecto.Changeset{changes: changes} = changeset, target, activities) do
+    put_assoc(
+      changeset,
+      :activities,
+      Enum.map(activities, fn activity ->
+        build_activity(target, put_changes(activity, changes))
+      end)
+    )
+  end
+
+  defp put_changes(activity, changes) do
+    changes = Map.delete(changes, :activities)
+    Map.put(activity, :changes, changes)
+  end
+end

lib/algora/bounties/schemas/bounty.ex

@@ -16,6 +16,7 @@ defmodule Algora.Bounties.Bounty do
     has_many :attempts, Algora.Bounties.Attempt
     has_many :claims, Algora.Bounties.Claim
     has_many :transactions, Algora.Payments.Transaction
+    has_many :activities, {"bounty_activities", Algora.Activities.Activity}, foreign_key: :assoc_id
 
     timestamps()
   end

lib/algora/contracts/contracts.ex

@@ -1,8 +1,10 @@
 defmodule Algora.Contracts do
   @moduledoc false
+  import Algora.Activities.Activity, only: [put_activity: 2, put_activity: 3]
   import Ecto.Changeset
   import Ecto.Query
 
+  alias Algora.Activities
   alias Algora.Contracts.Contract
   alias Algora.Contracts.Timesheet
   alias Algora.FeeTier
@@ -170,6 +172,12 @@ defmodule Algora.Contracts do
       total_fee: total_fee,
       line_items: line_items
     })
+    |> put_assoc(
+      :contract,
+      put_activity(contract, %{
+        type: :transaction_created
+      })
+    )
     |> Algora.Validations.validate_positive(:gross_amount)
     |> Algora.Validations.validate_positive(:net_amount)
     |> Algora.Validations.validate_positive(:total_fee)
@@ -196,6 +204,12 @@ defmodule Algora.Contracts do
       total_fee: Money.zero(:USD),
       linked_transaction_id: linked_transaction_id
     })
+    |> put_assoc(
+      :contract,
+      put_activity(contract, %{
+        type: :transaction_created
+      })
+    )
     |> Algora.Validations.validate_positive(:gross_amount)
     |> Algora.Validations.validate_positive(:net_amount)
     |> foreign_key_constraint(:original_contract_id)
@@ -221,6 +235,12 @@ defmodule Algora.Contracts do
       user_id: contract.contractor_id,
       linked_transaction_id: linked_transaction_id
     })
+    |> put_assoc(
+      :contract,
+      put_activity(contract, %{
+        type: :transaction_created
+      })
+    )
     |> Algora.Validations.validate_positive(:gross_amount)
     |> Algora.Validations.validate_positive(:net_amount)
     |> foreign_key_constraint(:original_contract_id)
@@ -245,6 +265,12 @@ defmodule Algora.Contracts do
       timesheet_id: contract.timesheet.id,
       user_id: contract.contractor_id
     })
+    |> put_assoc(
+      :contract,
+      put_activity(contract, %{
+        type: :transaction_created
+      })
+    )
     |> Algora.Validations.validate_positive(:gross_amount)
     |> Algora.Validations.validate_positive(:net_amount)
     |> foreign_key_constraint(:original_contract_id)
@@ -377,7 +403,16 @@ defmodule Algora.Contracts do
     with {:ok, txs} <- initialize_prepayment_transaction(contract),
          {:ok, invoice} <- maybe_generate_invoice(contract, txs.charge),
          {:ok, _invoice} <- maybe_pay_invoice(contract, invoice, txs) do
+      Activities.insert(contract, %{type: :contract_prepaid})
+
       {:ok, txs}
+    else
+      error ->
+        Activities.insert(contract, %{
+          type: :contract_prepayment_failed
+        })
+
+        error
     end
   end
 
@@ -483,6 +518,7 @@ defmodule Algora.Contracts do
 
       {:error, error} ->
         update_transaction_status(transaction, {:error, error})
+        Activities.insert(contract, %{type: :contract_prepayment_failed})
         {:error, error}
     end
   end
@@ -493,6 +529,13 @@ defmodule Algora.Contracts do
       provider_meta: Util.normalize_struct(%{error: error}),
       status: :failed
     })
+    |> put_assoc(
+      :contract,
+      put_activity(transaction.contract, %{
+        type: :transaction_status_change,
+        meta: %{status: :failed, transaction_id: transaction.id}
+      })
+    )
     |> Repo.update()
   end
 
@@ -504,12 +547,26 @@ defmodule Algora.Contracts do
       status: status,
       succeeded_at: if(status == :succeeded, do: DateTime.utc_now())
     })
+    |> put_assoc(
+      :contract,
+      put_activity(transaction.contract, %{
+        type: :transaction_status_change,
+        meta: %{status: status, transaction_id: transaction.id}
+      })
+    )
     |> Repo.update()
   end
 
   defp mark_contract_as_paid(contract) do
     contract
     |> change(%{status: :paid})
+    |> put_activity(contract, %{
+      type: :contract_paid,
+      meta: %{},
+      template: "",
+      trace_id: Nanoid.generate(),
+      notify_users: []
+    })
     |> Repo.update()
   end
 
@@ -527,6 +584,10 @@ defmodule Algora.Contracts do
       hourly_rate: contract.hourly_rate,
       hours_per_week: contract.hours_per_week
     })
+    |> put_activity(contract, %{
+      type: :contract_renewed,
+      trace_id: Nanoid.generate()
+    })
     |> Repo.insert()
   end
 
@@ -601,6 +662,7 @@ defmodule Algora.Contracts do
       on: tt.original_contract_id == c.original_contract_id,
       as: :tt
     )
+    |> join(:left, [c], act in assoc(c, :activities), as: :act)
     |> select_merge([ta: ta, tt: tt], %{
       amount_credited: Algora.SQL.money_or_zero(ta.amount_credited),
       amount_debited: Algora.SQL.money_or_zero(ta.amount_debited),
@@ -611,11 +673,12 @@ defmodule Algora.Contracts do
       total_transferred: Algora.SQL.money_or_zero(tt.total_transferred),
       total_withdrawn: Algora.SQL.money_or_zero(tt.total_withdrawn)
     })
-    |> preload([ts: ts, txs: txs, cl: cl, ct: ct, cu: cu, dpm: dpm],
+    |> preload([ts: ts, txs: txs, cl: cl, ct: ct, cu: cu, dpm: dpm, act: act],
       timesheet: ts,
       transactions: txs,
       client: {cl, customer: {cu, default_payment_method: dpm}},
-      contractor: ct
+      contractor: ct,
+      activities: act
     )
     |> Repo.all()
     |> Enum.map(&Contract.after_load/1)

lib/algora/contracts/schemas/contract.ex

@@ -3,6 +3,7 @@ defmodule Algora.Contracts.Contract do
   use Algora.Schema
 
   alias Algora.Accounts.User
+  alias Algora.Activities.Activity
   alias Algora.Contracts.Contract
   alias Algora.MoneyUtils
 
@@ -36,6 +37,8 @@ defmodule Algora.Contracts.Contract do
     has_many :reviews, Algora.Reviews.Review
     has_one :timesheet, Algora.Contracts.Timesheet
 
+    has_many :activities, {"contract_activities", Activity}, foreign_key: :assoc_id, on_replace: :ignore
+
     timestamps()
   end
 

lib/algora/payments/schemas/transaction.ex

@@ -2,6 +2,7 @@ defmodule Algora.Payments.Transaction do
   @moduledoc false
   use Algora.Schema
 
+  alias Algora.Activities.Activity
   alias Algora.Contracts.Contract
   alias Algora.Types.Money
 

mix.exs

@@ -38,6 +38,7 @@ defmodule Algora.MixProject do
   # Type `mix help deps` for examples and options.
   defp deps do
     [
+      {:ecto, github: "lastcanal/ecto", branch: "has_many_on_replace_ignore", override: true},
       {:phoenix, "~> 1.7.11"},
       {:phoenix_ecto, "~> 4.5"},
       {:ecto_sql, "~> 3.10"},

mix.lock

@@ -16,7 +16,7 @@
   "dialyxir": {:hex, :dialyxir, "1.4.5", "ca1571ac18e0f88d4ab245f0b60fa31ff1b12cbae2b11bd25d207f865e8ae78a", [:mix], [{:erlex, ">= 0.2.7", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "b0fb08bb8107c750db5c0b324fa2df5ceaa0f9307690ee3c1f6ba5b9eb5d35c3"},
   "digital_token": {:hex, :digital_token, "1.0.0", "454a4444061943f7349a51ef74b7fb1ebd19e6a94f43ef711f7dae88c09347df", [:mix], [{:cldr_utils, "~> 2.17", [hex: :cldr_utils, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}], "hexpm", "8ed6f5a8c2fa7b07147b9963db506a1b4c7475d9afca6492136535b064c9e9e6"},
   "dns_cluster": {:hex, :dns_cluster, "0.1.3", "0bc20a2c88ed6cc494f2964075c359f8c2d00e1bf25518a6a6c7fd277c9b0c66", [:mix], [], "hexpm", "46cb7c4a1b3e52c7ad4cbe33ca5079fbde4840dedeafca2baf77996c2da1bc33"},
-  "ecto": {:hex, :ecto, "3.12.5", "4a312960ce612e17337e7cefcf9be45b95a3be6b36b6f94dfb3d8c361d631866", [:mix], [{:decimal, "~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "6eb18e80bef8bb57e17f5a7f068a1719fbda384d40fc37acb8eb8aeca493b6ea"},
+  "ecto": {:git, "https://github.com/lastcanal/ecto.git", "c730389a3965004dca68a8a173ddd6d102b15b4f", [branch: "has_many_on_replace_ignore"]},
   "ecto_sql": {:hex, :ecto_sql, "3.12.1", "c0d0d60e85d9ff4631f12bafa454bc392ce8b9ec83531a412c12a0d415a3a4d0", [:mix], [{:db_connection, "~> 2.4.1 or ~> 2.5", [hex: :db_connection, repo: "hexpm", optional: false]}, {:ecto, "~> 3.12", [hex: :ecto, repo: "hexpm", optional: false]}, {:myxql, "~> 0.7", [hex: :myxql, repo: "hexpm", optional: true]}, {:postgrex, "~> 0.19 or ~> 1.0", [hex: :postgrex, repo: "hexpm", optional: true]}, {:tds, "~> 2.1.1 or ~> 2.2", [hex: :tds, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.0 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "aff5b958a899762c5f09028c847569f7dfb9cc9d63bdb8133bff8a5546de6bf5"},
   "erlex": {:hex, :erlex, "0.2.7", "810e8725f96ab74d17aac676e748627a07bc87eb950d2b83acd29dc047a30595", [:mix], [], "hexpm", "3ed95f79d1a844c3f6bf0cea61e0d5612a42ce56da9c03f01df538685365efb0"},
   "ex_aws": {:hex, :ex_aws, "2.5.8", "0393cfbc5e4a9e7017845451a015d836a670397100aa4c86901980e2a2c5f7d4", [:mix], [{:configparser_ex, "~> 4.0", [hex: :configparser_ex, repo: "hexpm", optional: true]}, {:hackney, "~> 1.16", [hex: :hackney, repo: "hexpm", optional: true]}, {:jason, "~> 1.1", [hex: :jason, repo: "hexpm", optional: true]}, {:jsx, "~> 2.8 or ~> 3.0", [hex: :jsx, repo: "hexpm", optional: true]}, {:mime, "~> 1.2 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:req, "~> 0.3", [hex: :req, repo: "hexpm", optional: true]}, {:sweet_xml, "~> 0.7", [hex: :sweet_xml, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.3 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "8f79777b7932168956c8cc3a6db41f5783aa816eb50de356aed3165a71e5f8c3"},