feat: dynamic job matching

Author: zcesur

lib/algora/settings/settings.ex

@@ -2,7 +2,10 @@ defmodule Algora.Settings do
   @moduledoc false
   use Ecto.Schema
 
+  import Ecto.Query
+
   alias Algora.Accounts
+  alias Algora.Accounts.User
   alias Algora.Repo
 
   @primary_key {:key, :string, []}
@@ -91,10 +94,37 @@ defmodule Algora.Settings do
     set("org_matches:#{org_handle}", %{"matches" => matches})
   end
 
-  def get_job_matches(job_id) do
-    case get("job_matches:#{job_id}") do
-      %{"matches" => matches} when is_list(matches) -> load_matches(matches)
-      _ -> []
+  def get_job_matches(job) do
+    case get("job_matches:#{job.id}") do
+      %{"matches" => matches} when is_list(matches) ->
+        load_matches(matches)
+
+      _ ->
+        [
+          tech_stack: job.tech_stack,
+          limit: 50,
+          users: apply_job_criteria(User, get_job_criteria(job.id))
+        ]
+        |> Algora.Cloud.list_top_matches()
+        |> load_matches_2()
+    end
+  end
+
+  def apply_job_criteria(query, criteria) do
+    Enum.reduce(criteria, query, fn
+      {"country", country}, query ->
+        from([u] in query, where: u.country == ^country)
+    end)
+  end
+
+  def set_job_criteria(job_id, criteria) when is_binary(job_id) and is_map(criteria) do
+    set("job_criteria:#{job_id}", %{"criteria" => criteria})
+  end
+
+  def get_job_criteria(job_id) do
+    case get("job_criteria:#{job_id}") do
+      %{"criteria" => criteria} when is_map(criteria) -> criteria
+      _ -> %{}
     end
   end
 
@@ -145,6 +175,22 @@ defmodule Algora.Settings do
     end)
   end
 
+  def load_matches_2(matches) do
+    user_map =
+      [ids: Enum.map(matches, & &1[:user_id]), limit: :infinity]
+      |> Accounts.list_developers()
+      |> Enum.filter(& &1.provider_login)
+      |> Map.new(fn user -> {user.id, user} end)
+
+    Enum.flat_map(matches, fn match ->
+      if user = Map.get(user_map, match[:user_id]) do
+        [%{user: user, contribution_score: match["contribution_score"]}]
+      else
+        []
+      end
+    end)
+  end
+
   def get_blocked_users do
     case get("blocked_users") do
       %{"handles" => handles} when is_list(handles) -> handles

lib/algora_web/live/org/job_live.ex

@@ -832,7 +832,7 @@ defmodule AlgoraWeb.Org.JobLive do
     all_applicants = Jobs.list_job_applications(socket.assigns.job)
     applicants = Enum.reject(all_applicants, & &1.imported_at)
     imports = Enum.filter(all_applicants, & &1.imported_at)
-    matches = Settings.get_job_matches(socket.assigns.job.id)
+    matches = Settings.get_job_matches(socket.assigns.job)
 
     developers = matches |> Enum.concat(all_applicants) |> Enum.map(& &1.user)
 

lib/algora_web/live/org/jobs_live.ex

@@ -41,7 +41,7 @@ defmodule AlgoraWeb.Org.JobsLive do
           ])
         }>
           <h2 class="font-display text-3xl font-semibold tracking-tight text-foreground sm:text-6xl mb-2">
-            Jobs
+            Join {@current_org.name}
           </h2>
           <p class="font-medium text-base text-muted-foreground">
             Open positions at {@current_org.name}