class Graphql::Dashboard::Subscriptions::TopicsController

# File lib/graphql/dashboard/subscriptions.rb, line 55
def index
  page = params[:page]&.to_i || 1
  per_page = params[:per_page]&.to_i || 20
  offset = per_page * (page - 1)
  limit = per_page
  topics, all_topics_count, has_next_page = schema_class.subscriptions.topics(offset: offset, limit: limit)

  @topics = topics
  @all_topics_count = all_topics_count
  @has_next_page = has_next_page
  @page = page
end

# File lib/graphql/dashboard/subscriptions.rb, line 24
def show
  topic_name = params[:name]
  all_subscription_ids = []
  schema_class.subscriptions.each_subscription_id(topic_name) do |sid|
    all_subscription_ids << sid
  end

  page = params[:page]&.to_i || 1
  limit = params[:per_page]&.to_i || 20
  offset = limit * (page - 1)
  subscription_ids = all_subscription_ids[offset, limit]
  subs = schema_class.subscriptions.read_subscriptions(subscription_ids)
  show_broadcast_subscribers_count = schema_class.subscriptions.show_broadcast_subscribers_count?
  subs.each do |sub|
    sub[:is_broadcast] = is_broadcast = schema_class.subscriptions.broadcast_subscription_id?(sub[:id])
    if is_broadcast && show_broadcast_subscribers_count
      sub[:subscribers_count] = sub_count =schema_class.subscriptions.count_broadcast_subscribed(sub[:id])
      sub[:still_subscribed] = sub_count > 0
    else
      sub[:still_subscribed] = schema_class.subscriptions.still_subscribed?(sub[:id])
      sub[:subscribers_count] = nil
    end
  end

  @topic_last_triggered_at = schema_class.subscriptions.topic_last_triggered_at(topic_name)
  @subscriptions = subs
  @subscriptions_count = all_subscription_ids.size
  @show_broadcast_subscribers_count = show_broadcast_subscribers_count
  @has_next_page = all_subscription_ids.size > offset + limit ? page + 1 : false
end