update claim notif

Author: zcesur

lib/algora/bounties/bounties.ex

@@ -132,6 +132,7 @@ defmodule Algora.Bounties do
         provider: "github",
         provider_id: to_string(pull_request["id"]),
         provider_meta: Util.normalize_struct(pull_request),
+        type: :pull_request,
         title: pull_request["title"],
         url: pull_request["html_url"],
         merged_at: Util.to_date(pull_request["merged_at"])
@@ -177,7 +178,7 @@ defmodule Algora.Bounties do
       with {:ok, token} <- token_res,
            {:ok, ticket} <- Workspace.ensure_ticket(token, repo_owner, repo_name, number),
            {:ok, claim} <- do_claim_bounty(%{user: user, ticket: ticket, pull_request: pull_request}),
-           {:ok, _job} <- notify_claim(%{ticket_ref: ticket_ref}, installation_id: installation_id) do
+           {:ok, _job} <- notify_claim(%{claim: claim}, installation_id: installation_id) do
         broadcast()
         {:ok, claim}
       else
@@ -187,15 +188,12 @@ defmodule Algora.Bounties do
   end
 
   @spec notify_claim(
-          %{ticket_ref: %{owner: String.t(), repo: String.t(), number: integer()}},
+          %{claim: Claim.t()},
           opts :: [installation_id: integer()]
         ) ::
           {:ok, Oban.Job.t()} | {:error, atom()}
-  def notify_claim(%{ticket_ref: ticket_ref}, opts \\ []) do
-    %{
-      ticket_ref: %{owner: ticket_ref.owner, repo: ticket_ref.repo, number: ticket_ref.number},
-      installation_id: opts[:installation_id]
-    }
+  def notify_claim(%{claim: claim}, opts \\ []) do
+    %{claim_id: claim.id, installation_id: opts[:installation_id]}
     |> Jobs.NotifyClaim.new()
     |> Oban.insert()
   end

lib/algora/bounties/jobs/notify_claim.ex

@@ -2,27 +2,32 @@ defmodule Algora.Bounties.Jobs.NotifyClaim do
   @moduledoc false
   use Oban.Worker, queue: :notify_claim
 
+  alias Algora.Bounties.Claim
   alias Algora.Github
+  alias Algora.Repo
 
   require Logger
 
   @impl Oban.Worker
-  def perform(%Oban.Job{args: %{"ticket_ref" => _ticket_ref, "installation_id" => nil}}) do
+  def perform(%Oban.Job{args: %{"claim_id" => _claim_id, "installation_id" => nil}}) do
     :ok
   end
 
   @impl Oban.Worker
-  def perform(%Oban.Job{args: %{"ticket_ref" => ticket_ref, "installation_id" => installation_id}}) do
-    with {:ok, token} <- Github.get_installation_token(installation_id) do
-      # TODO: update message
-      body = "Claimed!"
+  def perform(%Oban.Job{args: %{"claim_id" => claim_id, "installation_id" => installation_id}}) do
+    with {:ok, token} <- Github.get_installation_token(installation_id),
+         {:ok, claim} <- Repo.fetch(Claim, claim_id) do
+      claim = Repo.preload(claim, ticket: [repository: [:user]], user: [])
+
+      # TODO: implement
+      claim_reward_url = "#{AlgoraWeb.Endpoint.url()}/claims/#{claim.id}"
 
       Github.create_issue_comment(
         token,
-        ticket_ref["owner"],
-        ticket_ref["repo"],
-        ticket_ref["number"],
-        body
+        claim.ticket.repository.user.provider_login,
+        claim.ticket.repository.name,
+        claim.ticket.number,
+        "💡 @#{claim.user.provider_login} submitted [#{Claim.type_label(claim.type)}](#{claim.url}) that claims the bounty. You can visit [Algora](#{claim_reward_url}) to reward."
       )
     end
   end

lib/algora/bounties/schemas/claim.ex

@@ -10,6 +10,8 @@ defmodule Algora.Bounties.Claim do
     field :provider_id, :string, null: false
     field :provider_meta, :map, null: false
 
+    field :type, Ecto.Enum, values: [:pull_request, :review, :video, :design, :article]
+
     field :merged_at, :utc_datetime_usec
     field :approved_at, :utc_datetime_usec
     field :rejected_at, :utc_datetime_usec
@@ -41,6 +43,7 @@ defmodule Algora.Bounties.Claim do
       :rejected_at,
       :charged_at,
       :paid_at,
+      :type,
       :title,
       :description,
       :url,
@@ -69,6 +72,13 @@ defmodule Algora.Bounties.Claim do
     end
   end
 
+  def type_label(:pull_request), do: "a pull request"
+  def type_label(:review), do: "a review"
+  def type_label(:video), do: "a video"
+  def type_label(:design), do: "a design"
+  def type_label(:article), do: "an article"
+  def type_label(nil), do: "a URL"
+
   def rewarded(query \\ Claim) do
     from c in query,
       where: c.state == :approved and not is_nil(c.charged_at)

priv/repo/migrations/20250112164132_recreate_claims.exs

@@ -18,6 +18,7 @@ defmodule Algora.Repo.Migrations.RecreateClaims do
       add :charged_at, :utc_datetime_usec
       add :paid_at, :utc_datetime_usec
 
+      add :type, :string, null: false
       add :title, :string, null: false
       add :description, :string
       add :url, :string, null: false