feat: activity notifications (#31)

* activities (with has_many on_replace: :ignore)

* add more tables, test helpers

add accounts test

* add more user activity attributes

* add Repo.insert_with_activity/2

* add notifier

* rename

* Repo.update/delete_with_activity

* test register github user activities

* add coveralls

* add basic coverage for bounties, chat and reviews and coveralls.json

* remove redundant

* remove ecto fork

* Setup notifier and signal module

Send error signals when failing to link stripe accounts

* account coverage

* update coveralls

* rename

* fetch user activities from nested children

* add notifier job template

* satisfy the dialyzer

format

* filter out bounties without solver when onboarding dev, fix KeyError

* lower Drawer z-index; it was hiding flash messages

* load association for activities

drop transaction activities and 'second' level activities associated
with a user

* use Dataloader for loading activity associations

* add Mox to dev

* add create_session to Stripe SeedImpl

* format

* use map for activity table lookups

* add owned|created_tips to User

* add bounty and tip activities

* test

* add activities dropdown in main nav and on company admin page

* implement Algora.Analytics.get_company_analytics/0-2

* remove transaction activities

* zero not implemented demo data

* add activity redirect controller

* add User#received_tips

* cleanup

* typo

* load target association with Activities.get

* show activities in header

broadcast from Oban job

enqueue email deilvery

add mail templates

* fix merge

* Protocol.UndefinedError for claims when creating tips

* adapt bounty testing to claims

* add on true to inner_lateral_join

* add redirect url to email body

* remove vars from email subjects

* use schema.preload/1

* add claim_submitted and bounty_awarded activities

* add utility for making admins

* remove unused alias

* add mix algora.create_tip

* send email job

* rework activity views

* assert mail job enqueued

* add todos

Author: lastcanal

config/config.exs

@@ -33,7 +33,9 @@ config :algora, Oban,
     github_og_image: 5,
     notify_bounty: 1,
     notify_tip_intent: 1,
-    notify_claim: 1
+    notify_claim: 1,
+    activity_notifier: 1,
+    activity_mailer: 1
   ]
 
 # Configures the mailer

config/test.exs

@@ -47,3 +47,7 @@ config :algora,
   cloudflare_tunnel: System.get_env("CLOUDFLARE_TUNNEL"),
   swift_mode: false,
   auto_start_pollers: System.get_env("AUTO_START_POLLERS") == "true"
+
+config :algora, :stripe,
+  test_customer_id: System.get_env("STRIPE_TEST_CUSTOMER_ID"),
+  test_account_id: System.get_env("STRIPE_TEST_ACCOUNT_ID")

coveralls.json

@@ -0,0 +1,29 @@
+{
+  "skip_files": [
+    "lib/algora/integrations",
+    "lib/algora/shared/*",
+    "lib/algora/admin/admin.ex",
+    "lib/algora_web/components",
+    "lib/algora_web",
+    "lib/mix/tasks",
+    "priv/",
+    "test/support"
+  ],
+  "default_stop_words": [
+    "defmodule",
+    "defrecord",
+    "defimpl",
+    "def.+(.+\/\/.+).+do",
+    "typed_schema",
+    "use .+"
+  ],
+
+  "custom_stop_words": [
+  ],
+
+  "coverage_options": {
+    "treat_no_relevant_lines_as_covered": true,
+    "output_dir": "cover/",
+    "html_filter_full_covered": true
+  }
+}

lib/algora/accounts/accounts.ex

@@ -312,6 +312,16 @@ defmodule Algora.Accounts do
     Repo.one(query)
   end
 
+  def get_user_by_handle(handle) do
+    query =
+      from(u in User,
+        where: u.handle == ^handle,
+        select: u
+      )
+
+    Repo.one(query)
+  end
+
   def get_access_token(%User{} = user) do
     case Repo.one(from(i in Identity, where: i.user_id == ^user.id and i.provider == "github")) do
       %Identity{provider_token: token} -> {:ok, token}

lib/algora/accounts/schemas/identity.ex

@@ -4,6 +4,7 @@ defmodule Algora.Accounts.Identity do
 
   alias Algora.Accounts.Identity
   alias Algora.Accounts.User
+  alias Algora.Activities.Activity
 
   @derive {Inspect, except: [:provider_token, :provider_meta]}
   typed_schema "identities" do
@@ -17,6 +18,8 @@ defmodule Algora.Accounts.Identity do
 
     belongs_to :user, User
 
+    has_many :activities, {"identity_activities", Activity}, foreign_key: :assoc_id
+
     timestamps()
   end
 
@@ -40,6 +43,7 @@ defmodule Algora.Accounts.Identity do
       :provider_name,
       :provider_id
     ])
+    |> Activity.put_activity(%Identity{}, %{type: :identity_created})
     |> generate_id()
     |> validate_required([:provider_token, :provider_email, :provider_name, :provider_id])
     |> validate_length(:provider_meta, max: 10_000)
@@ -66,6 +70,7 @@ defmodule Algora.Accounts.Identity do
       :provider_name,
       :provider_id
     ])
+    |> Activity.put_activity(%Identity{}, %{type: :identity_created})
     |> generate_id()
     |> validate_required([:provider_token, :provider_email, :provider_name, :provider_id])
     |> validate_length(:provider_meta, max: 10_000)

lib/algora/accounts/schemas/user.ex

@@ -4,7 +4,9 @@ defmodule Algora.Accounts.User do
 
   alias Algora.Accounts.Identity
   alias Algora.Accounts.User
+  alias Algora.Activities.Activity
   alias Algora.Bounties.Bounty
+  alias Algora.Bounties.Tip
   alias Algora.Contracts.Contract
   alias Algora.MoneyUtils
   alias Algora.Organizations.Member
@@ -78,6 +80,9 @@ defmodule Algora.Accounts.User do
     has_many :members, Member, foreign_key: :org_id
     has_many :owned_bounties, Bounty, foreign_key: :owner_id
     has_many :created_bounties, Bounty, foreign_key: :creator_id
+    has_many :owned_tips, Tip, foreign_key: :owner_id
+    has_many :created_tips, Tip, foreign_key: :creator_id
+    has_many :received_tips, Tip, foreign_key: :recipient_id
     has_many :attempts, Algora.Bounties.Attempt
     has_many :claims, Algora.Bounties.Claim
     has_many :projects, Algora.Projects.Project
@@ -87,6 +92,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, {"user_activities", Activity}, foreign_key: :assoc_id
 
     has_one :customer, Algora.Payments.Customer, foreign_key: :user_id
 
@@ -302,6 +308,10 @@ defmodule Algora.Accounts.User do
     |> unique_constraint([:provider, :provider_id])
   end
 
+  def is_admin_changeset(user, is_admin) do
+    cast(user, %{is_admin: is_admin}, [:is_admin])
+  end
+
   def validate_timezone(changeset) do
     validate_inclusion(changeset, :timezone, Tzdata.zone_list())
   end