feat: hiring (job postings, screening, matching, profiles) (#127)

Author: zcesur

.gitignore

@@ -58,4 +58,5 @@ npm-debug.log
 /priv/db
 /priv/github
 /priv/migration
-/priv/dev
+/priv/dev
+/lib/algora_cloud*

.iex.exs

@@ -15,6 +15,9 @@ alias Algora.Contracts
 alias Algora.Contracts.Contract
 alias Algora.Contracts.Timesheet
 alias Algora.Github
+alias Algora.Jobs
+alias Algora.Jobs.JobApplication
+alias Algora.Jobs.JobPosting
 alias Algora.Organizations
 alias Algora.Organizations.Member
 alias Algora.Payments

assets/js/app.ts

@@ -389,7 +389,9 @@ const Hooks = {
   },
   DeriveDomain: {
     mounted() {
-      const domainInput = document.querySelector("[data-domain-source]");
+      const domainInput = (this.el.closest("form") || document).querySelector(
+        "[data-domain-source]"
+      );
       let shouldDerive = true;
 
       // Listen for manual edits to the domain field

config/config.exs

@@ -9,8 +9,7 @@ import Config
 
 config :algora,
   title: "Algora",
-  description:
-    "Discover GitHub bounties, contract work and jobs. Hire the top 1% open source developers.",
+  description: "Algora connects companies and engineers for full-time and contract work",
   ecto_repos: [Algora.Repo],
   generators: [timestamp_type: :utc_datetime_usec],
   redirects: [
@@ -57,7 +56,9 @@ config :algora, Oban,
     activity_notifier: 1,
     activity_mailer: 1,
     activity_discord: 10,
-    campaign_emails: 1
+    campaign_emails: 1,
+    fetch_top_contributions: 1,
+    sync_contribution: 20
   ]
 
 # Configures the mailer

config/test.exs

@@ -64,6 +64,8 @@ config :algora, :local_store,
   ttl: String.to_integer(System.get_env("LOCAL_STORE_TTL", "3600")),
   salt: System.get_env("LOCAL_STORE_SALT", "algora-local-store")
 
+config :algora, :discord, webhook_url: System.get_env("DISCORD_WEBHOOK_URL")
+
 config :algora,
   plausible_embed_url: System.get_env("PLAUSIBLE_EMBED_URL"),
   assets_url: System.get_env("ASSETS_URL"),

lib/algora/accounts/accounts.ex

@@ -43,6 +43,9 @@ defmodule Algora.Accounts do
       {:ids, ids}, query ->
         from([b] in query, where: b.id in ^ids)
 
+      {:limit, :infinity}, query ->
+        query
+
       {:limit, limit}, query ->
         from([b] in query, limit: ^limit)
 

lib/algora/accounts/schemas/user.ex

@@ -40,6 +40,7 @@ defmodule Algora.Accounts.User do
     field :priority, :integer, default: 0
     field :fee_pct, :integer, default: 9
     field :fee_pct_prev, :integer, default: 9
+    field :subscription_price, Money
     field :seeded, :boolean, default: false
     field :activated, :boolean, default: false
     field :max_open_attempts, :integer, default: 3
@@ -51,6 +52,7 @@ defmodule Algora.Accounts.User do
     field :seeking_contracts, :boolean, default: false
     field :seeking_jobs, :boolean, default: false
     field :hiring, :boolean, default: false
+    field :hiring_subscription, Ecto.Enum, values: [:inactive, :trial, :active], default: :inactive
 
     field :hourly_rate_min, Money
     field :hourly_rate_max, Money
@@ -81,6 +83,11 @@ defmodule Algora.Accounts.User do
     field :login_token, :string, virtual: true
     field :signup_token, :string, virtual: true
 
+    field :billing_name, :string
+    field :billing_address, :string
+    field :executive_name, :string
+    field :executive_role, :string
+
     has_many :identities, Identity
     has_many :memberships, Member, foreign_key: :user_id
     has_many :members, Member, foreign_key: :org_id

lib/algora/activities/activities.ex

@@ -300,7 +300,12 @@ defmodule Algora.Activities do
 
     discord_job =
       if discord_payload = DiscordViews.render(activity) do
-        [Algora.Activities.SendDiscord.changeset(%{payload: discord_payload})]
+        [
+          Algora.Activities.SendDiscord.changeset(%{
+            url: Algora.config([:discord, :webhook_url]),
+            payload: discord_payload
+          })
+        ]
       else
         []
       end

lib/algora/activities/jobs/send_discord.ex

@@ -11,7 +11,7 @@ defmodule Algora.Activities.SendDiscord do
   end
 
   @impl Oban.Worker
-  def perform(%Oban.Job{args: %{"payload" => payload}}) do
-    Algora.Discord.send_message(payload)
+  def perform(%Oban.Job{args: %{"url" => url, "payload" => payload}}) do
+    Algora.Discord.send_message(url, payload)
   end
 end

lib/algora/admin/admin.ex

@@ -1,5 +1,6 @@
 defmodule Algora.Admin do
   @moduledoc false
+  import Ecto.Changeset
   import Ecto.Query
 
   alias Algora.Accounts
@@ -10,6 +11,7 @@ defmodule Algora.Admin do
   alias Algora.Bounties.Bounty
   alias Algora.Bounties.Claim
   alias Algora.Github
+  alias Algora.Jobs.JobPosting
   alias Algora.Parser
   alias Algora.Payments
   alias Algora.Payments.Transaction
@@ -22,6 +24,71 @@ defmodule Algora.Admin do
 
   require Logger
 
+  def seed_job(opts \\ %{}) do
+    with {:ok, user} <- Repo.fetch_by(User, handle: opts.org.handle),
+         {:ok, user} <- user |> change(opts.org) |> Repo.update(),
+         {:ok, job} <-
+           Repo.insert(%JobPosting{
+             id: Nanoid.generate(),
+             user_id: user.id,
+             company_name: user.name,
+             company_url: user.website_url,
+             title: opts.title,
+             description: opts.description,
+             tech_stack: opts.tech_stack || Enum.take(user.tech_stack, 1)
+           }) do
+      dbg("#{AlgoraWeb.Endpoint.url()}/#{user.handle}/jobs/#{job.id}")
+    end
+  end
+
+  def sync_contributions(opts \\ []) do
+    query =
+      User
+      |> where([u], not is_nil(u.handle))
+      |> where([u], not is_nil(u.provider_login))
+      |> where([u], u.type == :individual)
+      |> where([u], fragment("not exists (select 1 from user_contributions where user_contributions.user_id = ?)", u.id))
+
+    query =
+      if handles = opts[:handles] do
+        where(query, [u], u.handle in ^handles)
+      else
+        query
+      end
+
+    query =
+      if limit = opts[:limit] do
+        limit(query, ^limit)
+      else
+        query
+      end
+
+    Repo.transaction(
+      fn ->
+        if opts[:dry_run] do
+          query
+          |> Repo.stream()
+          |> Enum.to_list()
+          |> length()
+          |> IO.puts()
+        else
+          query
+          |> Repo.stream()
+          |> Enum.each(fn user ->
+            %{provider_login: user.provider_login}
+            |> Workspace.Jobs.FetchTopContributions.new()
+            |> Oban.insert()
+            |> case do
+              {:ok, _job} -> IO.puts("Enqueued job for #{user.provider_login}")
+              {:error, error} -> IO.puts("Failed to enqueue job for #{user.provider_login}: #{inspect(error)}")
+            end
+          end)
+        end
+      end,
+      timeout: :infinity
+    )
+  end
+
   def release_payment(tx_id) do
     Repo.transact(fn ->
       {_, [tx]} =
@@ -402,6 +469,7 @@ defmodule Algora.Admin do
     Logger.error(message)
 
     %{
+      url: Algora.config([:discord, :webhook_url]),
       payload: %{
         embeds: [
           %{
@@ -422,16 +490,19 @@ defmodule Algora.Admin do
 
     email_job =
       Algora.Activities.SendEmail.changeset(%{
-        title: "Error: #{message}",
+        title: "#{message}",
         body: message,
-        name: "Algora Alert",
+        name: "Action required",
         email: "[email protected]"
       })
 
     discord_job =
       SendDiscord.changeset(%{
+        url: Algora.Settings.get("discord_webhook_url")["critical"] || Algora.config([:discord, :webhook_url]),
         payload: %{
-          embeds: [%{color: color(severity), title: "Error", description: message, timestamp: DateTime.utc_now()}]
+          embeds: [
+            %{color: color(severity), title: "Action required", description: message, timestamp: DateTime.utc_now()}
+          ]
         }
       })
 
@@ -442,6 +513,7 @@ defmodule Algora.Admin do
     Logger.info(message)
 
     %{
+      url: Algora.config([:discord, :webhook_url]),
       payload: %{
         embeds: [
           %{