Add support for account and trends data sharing.

Author: oneiros

debug_fasp/app/controllers/accounts_controller.rb

@@ -1,2 +1,22 @@
 class AccountsController < ApplicationController
+  before_action :load_account, only: [ :show, :destroy ]
+
+  def index
+    @accounts = Account.all
+  end
+
+  def show
+  end
+
+  def destroy
+    @account.destroy
+
+    redirect_to accounts_path, notice: t(".success")
+  end
+
+  private
+
+  def load_account
+    @account = Account.find(params[:id])
+  end
 end

debug_fasp/app/controllers/subscriptions_controller.rb

@@ -1,10 +1,13 @@
 class SubscriptionsController < ApplicationController
+  helper_method :current_server
+
   def index
-    @subscriptions = FaspDataSharing::Subscription.all
+    @subscriptions = FaspDataSharing::Subscription
+      .where(fasp_base_server: current_server).all
   end
 
   def create
-    FaspDataSharing::Subscription.subscribe_to_content(current_user.servers.first)
+    create_subscription
 
     redirect_to subscriptions_path, notice: t(".success")
   end
@@ -15,4 +18,21 @@ def destroy
 
     redirect_to subscriptions_path, notice: t(".success")
   end
+
+  private
+
+  def current_server
+    @current_server ||= current_user.servers.first
+  end
+
+  def create_subscription
+    case params[:type]
+    when "content"
+      FaspDataSharing::Subscription.subscribe_to_content(current_server)
+    when "account"
+      FaspDataSharing::Subscription.subscribe_to_accounts(current_server)
+    when "trends"
+      FaspDataSharing::Subscription.subscribe_to_trends(current_server)
+    end
+  end
 end

debug_fasp/app/controllers/trend_signals_controller.rb

@@ -0,0 +1,14 @@
+class TrendSignalsController < ApplicationController
+  def index
+    @trend_signals = TrendSignal
+      .includes(:content)
+      .order(created_at: :desc)
+  end
+
+  def destroy
+    trend_signal = TrendSignal.find(params[:id])
+    trend_signal.destroy
+
+    redirect_to trend_signals_path, notice: t(".success")
+  end
+end

debug_fasp/app/helpers/accounts_helper.rb

@@ -1,2 +1,32 @@
 module ApplicationHelper
+  DATA_SHARING_TABS = {
+    subscriptions: :subscriptions_path,
+    contents: :contents_path,
+    accounts: :accounts_path,
+    trend_signals: :trend_signals_path
+  }.freeze
+
+  def content_subscription_absent?
+    FaspDataSharing::Subscription
+      .where(fasp_base_server: current_server)
+      .content
+      .lifecycle
+      .none?
+  end
+
+  def account_subscription_absent?
+    FaspDataSharing::Subscription
+      .where(fasp_base_server: current_server)
+      .account
+      .lifecycle
+      .none?
+  end
+
+  def trends_subscription_absent?
+    FaspDataSharing::Subscription
+      .where(fasp_base_server: current_server)
+      .content
+      .trends
+      .none?
+  end
 end

debug_fasp/app/helpers/application_helper.rb

@@ -0,0 +1,7 @@
+class FaspDataSharing::ProcessAccountDeletionJob < ApplicationJob
+  queue_as :default
+
+  def perform(uri)
+    Account.where(uri:).destroy_all
+  end
+end

debug_fasp/app/helpers/contents_helper.rb

@@ -0,0 +1,9 @@
+class FaspDataSharing::ProcessAccountUpdateJob < ApplicationJob
+  queue_as :default
+
+  def perform(uri)
+    object = fetch_object(uri)
+    account = Account.find_or_initialize_by(uri:, object_type: object["type"])
+    account.update(full_object: object)
+  end
+end

debug_fasp/app/helpers/subscriptions_helper.rb

@@ -0,0 +1,14 @@
+class FaspDataSharing::ProcessNewAccountJob < 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