Add backfill request support to debug provider

Author: oneiros

debug_fasp/app/controllers/accounts_controller.rb

@@ -14,6 +14,12 @@ def destroy
     redirect_to accounts_path, notice: t(".success")
   end
 
+  def destroy_all
+    Account.delete_all
+
+    redirect_to contents_path, notice: t(".success")
+  end
+
   private
 
   def load_account

debug_fasp/app/controllers/application_controller.rb

@@ -3,4 +3,10 @@ class ApplicationController < ActionController::Base
 
   # Only allow modern browsers supporting webp images, web push, badges, import maps, CSS nesting, and CSS :has.
   allow_browser versions: :modern
+
+  private
+
+  def current_server
+    @current_server ||= current_user&.servers&.first
+  end
 end

debug_fasp/app/controllers/backfill_requests_controller.rb

@@ -0,0 +1,45 @@
+class BackfillRequestsController < ApplicationController
+  helper_method :current_server
+
+  before_action :load_backfill_request, only: [ :update, :destroy ]
+
+  def index
+    @backfill_requests = FaspDataSharing::BackfillRequest
+      .where(fasp_base_server: current_server).all
+  end
+
+  def create
+    create_backfill_request
+
+    redirect_to backfill_requests_path, notice: t(".success")
+  end
+
+  def update
+    @backfill_request.continue!
+
+    redirect_to backfill_requests_path, notice: t(".success")
+  end
+
+  def destroy
+    @backfill_request.destroy
+
+    redirect_to backfill_requests_path, notice: t(".success")
+  end
+
+  private
+
+  def load_backfill_request
+    @backfill_request = FaspDataSharing::BackfillRequest
+      .where(fasp_base_server_id: current_user.server_ids)
+      .find(params[:id])
+  end
+
+  def create_backfill_request
+    case params[:type]
+    when "content"
+      FaspDataSharing::BackfillRequest.make(current_server, category: "content", max_count: 5)
+    when "account"
+      FaspDataSharing::BackfillRequest.make(current_server, category: "account", max_count: 5)
+    end
+  end
+end

debug_fasp/app/controllers/contents_controller.rb

@@ -14,6 +14,13 @@ def destroy
     redirect_to contents_path, notice: t(".success")
   end
 
+  def destroy_all
+    TrendSignal.delete_all
+    Content.delete_all
+
+    redirect_to contents_path, notice: t(".success")
+  end
+
   private
 
   def load_content

debug_fasp/app/controllers/subscriptions_controller.rb

@@ -21,10 +21,6 @@ def destroy
 
   private
 
-  def current_server
-    @current_server ||= current_user.servers.first
-  end
-
   def create_subscription
     case params[:type]
     when "content"

debug_fasp/app/controllers/trend_signals_controller.rb

@@ -11,4 +11,10 @@ def destroy
 
     redirect_to trend_signals_path, notice: t(".success")
   end
+
+  def destroy_all
+    TrendSignal.delete_all
+
+    redirect_to contents_path, notice: t(".success")
+  end
 end

debug_fasp/app/helpers/application_helper.rb

@@ -3,6 +3,7 @@ module ApplicationHelper
 
   DATA_SHARING_TABS = {
     subscriptions: :subscriptions_path,
+    backfill_requests: :backfill_requests_path,
     contents: :contents_path,
     accounts: :accounts_path,
     trend_signals: :trend_signals_path

debug_fasp/app/jobs/fasp_data_sharing/process_account_backfill_job.rb

@@ -0,0 +1,14 @@
+class FaspDataSharing::ProcessAccountBackfillJob < ApplicationJob
+  queue_as :default
+
+  def perform(uri)
+    unless Account.where(uri:).exists?
+      object = fetch_object(uri)
+      Account.create!(
+        uri: object["id"],
+        object_type: object["type"],
+        full_object: object
+      )
+    end
+  end
+end

debug_fasp/app/jobs/fasp_data_sharing/process_content_backfill_job.rb

@@ -0,0 +1,14 @@
+class FaspDataSharing::ProcessContentBackfillJob < ApplicationJob
+  queue_as :default
+
+  def perform(uri)
+    unless Content.where(uri:).exists?
+      object = fetch_object(uri)
+      Content.create!(
+        uri: object["id"],
+        object_type: object["type"],
+        full_object: object
+      )
+    end
+  end
+end

debug_fasp/app/views/accounts/index.html.erb

@@ -1,8 +1,11 @@
 <%= render "shared/data_sharing_tabs", active: :accounts %>
 
-<%= page_header do %>
-  <%= t(".accounts") %>
-<% end %>
+<div class="flex justify-between items-center">
+  <%= page_header do %>
+    <%= t(".accounts") %>
+  <% end %>
+  <%= button_link_to t(".destroy_all"), accounts_path, data: {turbo_confirm: t('are_you_sure'), turbo_method: :delete} %>
+</div>
 
 <table>
   <thead>