feat: bounty page (#78)

Author: zcesur

config/dev.exs

@@ -142,3 +142,5 @@ config :algora,
   plausible_url: System.get_env("PLAUSIBLE_URL"),
   assets_url: System.get_env("ASSETS_URL"),
   ingest_url: System.get_env("INGEST_URL")
+
+config :algora, AlgoraWeb.OGImageController, max_age: 0

config/prod.exs

@@ -32,5 +32,7 @@ config :algora,
   assets_url: System.get_env("ASSETS_URL"),
   ingest_url: System.get_env("INGEST_URL")
 
+config :algora, AlgoraWeb.OGImageController, max_age: 600
+
 # Runtime production configuration, including reading
 # of environment variables, is done on config/runtime.exs.

lib/algora/accounts/accounts.ex

@@ -147,6 +147,7 @@ defmodule Algora.Accounts do
       type: u.type,
       id: u.id,
       handle: u.handle,
+      provider_login: u.provider_login,
       name: u.name,
       provider_login: u.provider_login,
       provider_meta: u.provider_meta,

lib/algora/admin/admin.ex

@@ -2,6 +2,7 @@ defmodule Algora.Admin do
   @moduledoc false
   import Ecto.Query
 
+  alias Algora.Accounts
   alias Algora.Accounts.User
   alias Algora.Activities.SendDiscord
   alias Algora.Bounties.Claim
@@ -17,6 +18,57 @@ defmodule Algora.Admin do
 
   require Logger
 
+  def seed do
+    import Algora.Factory
+
+    title = "Monthly PR Review & Triage Bounty"
+
+    description = """
+    ## What needs doing
+
+    Review open pull requests across our repos and:
+
+    1. Test them locally
+    2. Leave helpful comments
+    3. Merge or close stale PRs
+    4. Tag relevant people when needed
+
+    ## Success looks like
+
+    - [ ] All PRs older than 2 weeks have been reviewed
+    - [ ] Clear comments left on PRs needing changes
+    - [ ] Stale PRs (>30 days old) closed with explanation
+    - [ ] Weekly summary posted in #dev channel
+    """
+
+    org = Repo.get_by!(User, handle: "piedpiper0")
+    user = Repo.get_by!(User, handle: "zcesur")
+
+    repository = insert!(:repository, user: org)
+    ticket = insert!(:ticket, title: title, repository: repository, description: description)
+    bounty = insert!(:bounty, ticket: ticket, owner: org, creator: user, amount: Money.new(1000, :USD))
+
+    for contributor <- Accounts.list_featured_developers() do
+      insert!(:transaction,
+        type: :debit,
+        net_amount: Money.new(1000, :USD),
+        user_id: org.id,
+        bounty_id: bounty.id,
+        status: :succeeded
+      )
+
+      insert!(:transaction,
+        type: :credit,
+        net_amount: Money.new(1000, :USD),
+        user_id: contributor.id,
+        bounty_id: bounty.id,
+        status: :succeeded
+      )
+    end
+
+    IO.puts("#{AlgoraWeb.Endpoint.url()}/org/#{org.handle}/bounties/#{bounty.id}")
+  end
+
   def magic(:email, email, return_to),
     do: AlgoraWeb.Endpoint.url() <> AlgoraWeb.UserAuth.generate_login_path(email, return_to)
 

lib/algora/bounties/bounties.ex

@@ -27,7 +27,8 @@ defmodule Algora.Bounties do
   def base_query, do: Bounty
 
   @type criterion ::
-          {:limit, non_neg_integer() | :infinity}
+          {:id, String.t()}
+          | {:limit, non_neg_integer() | :infinity}
           | {:ticket_id, String.t()}
           | {:owner_id, String.t()}
           | {:status, :open | :paid}
@@ -695,15 +696,16 @@ defmodule Algora.Bounties do
             bounty_id: String.t(),
             claims: [Claim.t()]
           },
-          opts :: [ticket_ref: %{owner: String.t(), repo: String.t(), number: integer()}]
+          opts :: [ticket_ref: %{owner: String.t(), repo: String.t(), number: integer()}, recipient: User.t()]
         ) ::
           {:ok, String.t()} | {:error, atom()}
   def reward_bounty(%{owner: owner, amount: amount, bounty_id: bounty_id, claims: claims}, opts \\ []) do
     create_payment_session(
       %{owner: owner, amount: amount, description: "Bounty payment for OSS contributions"},
       ticket_ref: opts[:ticket_ref],
       bounty_id: bounty_id,
-      claims: claims
+      claims: claims,
+      recipient: opts[:recipient]
     )
   end
 
@@ -997,6 +999,9 @@ defmodule Algora.Bounties do
   @spec apply_criteria(Ecto.Queryable.t(), [criterion()]) :: Ecto.Queryable.t()
   defp apply_criteria(query, criteria) do
     Enum.reduce(criteria, query, fn
+      {:id, id}, query ->
+        from([b] in query, where: b.id == ^id)
+
       {:limit, :infinity}, query ->
         query
 

lib/algora/bounties/schemas/bounty.ex

@@ -14,6 +14,7 @@ defmodule Algora.Bounties.Bounty do
     field :autopay_disabled, :boolean, default: false
     field :visibility, Ecto.Enum, values: [:community, :exclusive, :public], null: false, default: :community
     field :shared_with, {:array, :string}, null: false, default: []
+    field :deadline, :utc_datetime_usec
 
     belongs_to :ticket, Algora.Workspace.Ticket
     belongs_to :owner, User
@@ -42,6 +43,13 @@ defmodule Algora.Bounties.Bounty do
     |> Algora.Validations.validate_money_positive(:amount)
   end
 
+  def settings_changeset(bounty, attrs) do
+    bounty
+    |> cast(attrs, [:visibility, :shared_with, :deadline])
+    |> Algora.Validations.validate_date_in_future(:deadline)
+    |> validate_required([:visibility, :shared_with])
+  end
+
   def url(%{repository: %{name: name, owner: %{login: login}}, ticket: %{provider: "github", number: number}}) do
     "https://github.com/#{login}/#{name}/issues/#{number}"
   end

lib/algora/chat/chat.ex

@@ -8,8 +8,13 @@ defmodule Algora.Chat do
   alias Algora.Chat.Thread
   alias Algora.Repo
 
-  def broadcast(message) do
-    Phoenix.PubSub.broadcast(Algora.PubSub, "chat:thread:#{message.thread_id}", message)
+  defmodule MessageCreated do
+    @moduledoc false
+    defstruct message: nil, participant: nil
+  end
+
+  def broadcast(%MessageCreated{} = event) do
+    Phoenix.PubSub.broadcast(Algora.PubSub, "chat:thread:#{event.message.thread_id}", event)
   end
 
   def subscribe(thread_id) do
@@ -23,7 +28,6 @@ defmodule Algora.Chat do
         |> Thread.changeset(%{title: "#{User.handle(user_1)} <> #{User.handle(user_2)}"})
         |> Repo.insert()
 
-      # Add participants
       for user <- [user_1, user_2] do
         %Participant{}
         |> Participant.changeset(%{
@@ -46,7 +50,7 @@ defmodule Algora.Chat do
         |> Repo.insert()
 
       participants = Enum.uniq_by([user | admins], & &1.id)
-      # Add participants
+
       for u <- participants do
         %Participant{}
         |> Participant.changeset(%{
@@ -61,20 +65,41 @@ defmodule Algora.Chat do
     end)
   end
 
+  defp ensure_participant(thread_id, user_id) do
+    case Repo.fetch_by(Participant, thread_id: thread_id, user_id: user_id) do
+      {:ok, participant} ->
+        {:ok, participant}
+
+      {:error, _} ->
+        %Participant{}
+        |> Participant.changeset(%{
+          thread_id: thread_id,
+          user_id: user_id,
+          last_read_at: DateTime.utc_now()
+        })
+        |> Repo.insert()
+    end
+  end
+
+  defp insert_message(thread_id, sender_id, content) do
+    %Message{}
+    |> Message.changeset(%{
+      thread_id: thread_id,
+      sender_id: sender_id,
+      content: content
+    })
+    |> Repo.insert()
+  end
+
   def send_message(thread_id, sender_id, content) do
-    case %Message{}
-         |> Message.changeset(%{
-           thread_id: thread_id,
-           sender_id: sender_id,
-           content: content
-         })
-         |> Repo.insert() do
-      {:ok, message} ->
-        message |> Repo.preload(:sender) |> broadcast()
-        {:ok, message}
-
-      {:error, changeset} ->
-        {:error, changeset}
+    with {:ok, participant} <- ensure_participant(thread_id, sender_id),
+         {:ok, message} <- insert_message(thread_id, sender_id, content) do
+      broadcast(%MessageCreated{
+        message: Repo.preload(message, :sender),
+        participant: Repo.preload(participant, :user)
+      })
+
+      {:ok, message}
     end
   end
 
@@ -107,6 +132,12 @@ defmodule Algora.Chat do
     |> Repo.all()
   end
 
+  def list_participants(thread_id) do
+    Participant
+    |> where(thread_id: ^thread_id)
+    |> Repo.all()
+  end
+
   def mark_as_read(thread_id, user_id) do
     Participant
     |> where(thread_id: ^thread_id, user_id: ^user_id)
@@ -145,4 +176,16 @@ defmodule Algora.Chat do
       thread -> {:ok, thread}
     end
   end
+
+  def get_or_create_bounty_thread(bounty) do
+    case Repo.fetch_by(Thread, bounty_id: bounty.id) do
+      {:ok, thread} ->
+        {:ok, thread}
+
+      {:error, _} ->
+        %Thread{}
+        |> Thread.changeset(%{title: "Contributor chat", bounty_id: bounty.id})
+        |> Repo.insert()
+    end
+  end
 end

lib/algora/chat/schemas/thread.ex

@@ -6,7 +6,7 @@ defmodule Algora.Chat.Thread do
 
   typed_schema "threads" do
     field :title, :string
-
+    field :bounty_id, :string
     has_many :messages, Algora.Chat.Message
     has_many :participants, Algora.Chat.Participant
     has_many :activities, {"thread_activities", Activity}, foreign_key: :assoc_id
@@ -16,8 +16,9 @@ defmodule Algora.Chat.Thread do
 
   def changeset(thread, attrs) do
     thread
-    |> cast(attrs, [:title])
+    |> cast(attrs, [:title, :bounty_id])
     |> validate_required([:title])
     |> generate_id()
+    |> unique_constraint(:bounty_id)
   end
 end

lib/algora/shared/validations.ex

@@ -39,4 +39,14 @@ defmodule Algora.Validations do
       _ -> changeset
     end
   end
+
+  def validate_date_in_future(changeset, field) do
+    validate_change(changeset, field, fn _, date ->
+      if date && Date.before?(date, DateTime.utc_now()) do
+        [{field, "must be in the future"}]
+      else
+        []
+      end
+    end)
+  end
 end

lib/algora/workspace/workspace.ex

@@ -200,6 +200,13 @@ defmodule Algora.Workspace do
     end
   end
 
+  def ensure_user_by_provider_id(token, provider_id) do
+    case Repo.get_by(User, provider: "github", provider_id: provider_id) do
+      %User{} = user -> {:ok, user}
+      nil -> create_user_from_github(token, provider_id)
+    end
+  end
+
   def sync_user(user, repository, owner, repo) do
     github_user = repository["owner"]