feat: bounty claims

Author: zcesur

lib/algora/bounties/schemas/claim.ex

@@ -6,36 +6,67 @@ defmodule Algora.Bounties.Claim do
 
   @derive {Inspect, except: [:provider_meta]}
   typed_schema "claims" do
-    field :provider, :string
-    field :provider_id, :string
-    field :provider_meta, :map
+    field :provider, :string, null: false
+    field :provider_id, :string, null: false
+    field :provider_meta, :map, null: false
 
-    field :type, Ecto.Enum, values: [:code, :video, :design, :article]
-
-    field :status, Ecto.Enum, values: [:pending, :merged, :approved, :rejected, :charged, :paid]
+    field :status, Ecto.Enum,
+      values: [:pending, :merged, :approved, :rejected, :charged, :paid],
+      default: :pending,
+      null: false
 
     field :merged_at, :utc_datetime_usec
     field :approved_at, :utc_datetime_usec
     field :rejected_at, :utc_datetime_usec
     field :charged_at, :utc_datetime_usec
     field :paid_at, :utc_datetime_usec
 
-    field :title, :string
+    field :title, :string, null: false
     field :description, :string
-    field :url, :string
-    field :group_id, :string
+    field :url, :string, null: false
+    field :group_id, :string, null: false
 
-    belongs_to :bounty, Algora.Bounties.Bounty
-    belongs_to :user, Algora.Accounts.User
+    belongs_to :ticket, Algora.Workspace.Ticket, null: false
+    belongs_to :user, Algora.Accounts.User, null: false
     # has_one :transaction, Algora.Payments.Transaction
 
     timestamps()
   end
 
   def changeset(claim, attrs) do
     claim
-    |> cast(attrs, [:bounty_id, :user_id])
-    |> validate_required([:bounty_id, :user_id])
+    |> cast(attrs, [
+      :ticket_id,
+      :user_id,
+      :provider,
+      :provider_id,
+      :provider_meta,
+      :status,
+      :merged_at,
+      :approved_at,
+      :rejected_at,
+      :charged_at,
+      :paid_at,
+      :title,
+      :description,
+      :url,
+      :group_id
+    ])
+    |> validate_required([
+      :ticket_id,
+      :user_id,
+      :provider,
+      :provider_id,
+      :provider_meta,
+      :status,
+      :title,
+      :url,
+      :group_id
+    ])
+    |> validate_inclusion(:status, [:pending, :merged, :approved, :rejected, :charged, :paid])
+    |> foreign_key_constraint(:ticket_id)
+    |> foreign_key_constraint(:user_id)
+    |> unique_constraint([:ticket_id, :user_id])
   end
 
   def rewarded(query \\ Claim) do

lib/algora_web/controllers/webhooks/github_controller.ex

@@ -3,8 +3,10 @@ defmodule AlgoraWeb.Webhooks.GithubController do
 
   alias Algora.Accounts
   alias Algora.Bounties
+  alias Algora.Bounties.Claim
   alias Algora.Github
   alias Algora.Github.Webhook
+  alias Algora.Repo
   alias Algora.Workspace
 
   require Logger
@@ -113,12 +115,30 @@ defmodule AlgoraWeb.Webhooks.GithubController do
     end
   end
 
-  defp execute_command({:claim, args}, _author, _params) when not is_nil(args) do
-    owner = Keyword.get(args, :owner)
-    repo = Keyword.get(args, :repo)
-    number = Keyword.get(args, :number)
+  defp execute_command({:claim, args}, author, params) when not is_nil(args) do
+    owner = args[:owner]
+    repo = args[:repo]
+    number = args[:number]
+    installation_id = params["installation"]["id"]
 
-    Logger.info("Claim #{owner}/#{repo}##{number}")
+    with {:ok, token} <- Github.get_installation_token(installation_id),
+         {:ok, ticket} <- Workspace.ensure_ticket(token, owner, repo, number),
+         {:ok, user} <- Workspace.ensure_user(token, author["login"]) do
+      id = Nanoid.generate()
+
+      Repo.insert(%Claim{
+        id: id,
+        ticket_id: ticket.id,
+        user_id: user.id,
+        provider: "github",
+        provider_id: params["pull_request"]["id"] || params["issue"]["id"],
+        provider_meta: %{},
+        title: params["pull_request"]["title"] || params["issue"]["title"],
+        url: params["pull_request"]["html_url"] || params["issue"]["html_url"],
+        group_id: id,
+        status: :pending
+      })
+    end
   end
 
   defp execute_command({command, _} = args, _author, _params),

priv/repo/migrations/20250112164132_recreate_claims.exs

@@ -0,0 +1,73 @@
+defmodule Algora.Repo.Migrations.RecreateClaims do
+  use Ecto.Migration
+
+  def up do
+    drop index(:claims, [:bounty_id])
+    drop index(:claims, [:user_id])
+    drop table(:claims)
+
+    create table(:claims) do
+      add :provider, :string, null: false
+      add :provider_id, :string, null: false
+      add :provider_meta, :map, null: false
+
+      add :status, :string, null: false
+
+      add :merged_at, :utc_datetime_usec
+      add :approved_at, :utc_datetime_usec
+      add :rejected_at, :utc_datetime_usec
+      add :charged_at, :utc_datetime_usec
+      add :paid_at, :utc_datetime_usec
+
+      add :title, :string, null: false
+      add :description, :string
+      add :url, :string, null: false
+      add :group_id, :string, null: false
+
+      add :ticket_id, references(:tickets, on_delete: :nothing), null: false
+      add :user_id, references(:users, on_delete: :nothing), null: false
+
+      timestamps()
+    end
+
+    create unique_index(:claims, [:ticket_id, :user_id])
+    create index(:claims, [:ticket_id])
+    create index(:claims, [:user_id])
+  end
+
+  def down do
+    drop unique_index(:claims, [:ticket_id, :user_id])
+    drop index(:claims, [:ticket_id])
+    drop index(:claims, [:user_id])
+    drop table(:claims)
+
+    create table(:claims) do
+      add :provider, :string
+      add :provider_id, :string
+      add :provider_meta, :map
+
+      add :type, :string
+
+      add :status, :string
+
+      add :merged_at, :utc_datetime_usec
+      add :approved_at, :utc_datetime_usec
+      add :rejected_at, :utc_datetime_usec
+      add :charged_at, :utc_datetime_usec
+      add :paid_at, :utc_datetime_usec
+
+      add :title, :string
+      add :description, :string
+      add :url, :string
+      add :group_id, :string
+
+      add :bounty_id, references(:bounties, on_delete: :nothing)
+      add :user_id, references(:users, on_delete: :nothing)
+
+      timestamps()
+    end
+
+    create index(:claims, [:bounty_id])
+    create index(:claims, [:user_id])
+  end
+end

test/support/factory.ex

@@ -199,7 +199,6 @@ defmodule Algora.Factory do
       id: Nanoid.generate(),
       provider: "github",
       provider_id: sequence(:provider_id, &"#{&1}"),
-      type: :code,
       status: :pending,
       title: "Implemented compression optimization",
       description: "Added parallel processing for large files",