Extract enhancer jobs to a speaker associated object

app/avo/actions/speaker_github.rb

@@ -2,8 +2,8 @@ class Avo::Actions::SpeakerGitHub < Avo::BaseAction
   self.name = "Try to enhance Speaker profile with GitHub"
 
   def handle(query:, fields:, current_user:, resource:, **args)
-    query.each do |record|
-      Speaker::EnhanceProfileJob.perform_later(speaker: record, sleep: 2) # sleep 2 seconds to avoid rate limit
+    query.each do |speaker|
+      speaker.profile_enhancer.enhance_all_later!
     end
   end
 end

app/controllers/speakers/enhance_controller.rb

@@ -2,8 +2,7 @@ class Speakers::EnhanceController < ApplicationController
   def update
     @speaker = Speaker.find_by(slug: params[:slug])
 
-    Speaker::EnhanceProfileJob.perform_later(speaker: @speaker) if @speaker.github.present?
-    Speaker::FetchBskyMetadata.perform_later(speaker: @speaker) if @speaker.bsky.present?
+    @speaker.profile_enhancer.enhance_all_later!
 
     flash[:notice] = "Speaker profile will be updated soon."
 

app/models/speaker.rb

@@ -59,6 +59,8 @@ class Speaker < ApplicationRecord
   belongs_to :canonical, class_name: "Speaker", optional: true
   belongs_to :user, primary_key: :github_handle, foreign_key: :github, optional: true
 
+  has_object :profile_enhancer
+
   # validations
   validates :canonical, exclusion: {in: ->(speaker) { [speaker] }, message: "can't be itself"}
 
@@ -161,10 +163,6 @@ def fallback_avatar_url(size: 200)
     "https://ui-avatars.com/api/?name=#{url_safe_initials}&size=#{size}&background=DC133C&color=fff"
   end
 
-  def fetch_bsky_metadata!
-    Speaker::FetchBskyMetadata.new.perform(speaker: self)
-  end
-
   def broadcast_header
     broadcast_update target: dom_id(self, :header_content), partial: "speakers/header_content", locals: {speaker: self}
   end

app/models/speaker/profile_enhancer.rb

@@ -0,0 +1,35 @@
+class Speaker::ProfileEnhancer < ActiveRecord::AssociatedObject
+  BSKY_HOST = "api.bsky.app".freeze
+
+  performs :enhance_all!, queue_as: :low do
+    retry_on StandardError, attempts: 3, wait: :polynomially_longer
+    limits_concurrency to: 1, key: "github_api"
+  end
+
+  def enhance_all!
+    enhance_with_github!
+    enhance_with_bsky!
+  end
+
+  def enhance_with_github!
+    # return unless speaker.github.present?
+
+    # TODO: implement
+  end
+
+  def enhance_with_bsky!
+    return unless speaker.bsky.present?
+
+    response = bsky.get_request("app.bsky.actor.getProfile", {
+      actor: speaker.bsky
+    })
+
+    speaker.update!(bsky_metadata: response)
+  end
+
+  private
+
+  def bsky
+    @bsky ||= Minisky.new(BSKY_HOST, nil)
+  end
+end

test/models/speaker/profile_enhancer_test.rb

@@ -0,0 +1,8 @@
+require "test_helper"
+
+class Speaker::ProfileEnhancerTest < ActiveSupport::TestCase
+  setup do
+    # @speaker = speakers(:TODO_fixture_name)
+    # @profile_enhancer = @speaker.profile_enhancer
+  end
+end