Mastodonを読む/タイムラインの表示その2（サーバ側） のバックアップ(No.1)

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13

-
|
|
|
|
|
|
|
|
|
|
|
!

  def home
    @statuses = Feed.new(:home, current_account).get(limit_param(DEFAULT_STATUSES_LIMIT), params[:max_id], params[:since_id])
    @statuses = cache_collection(@statuses)
 
    set_maps(@statuses)
 
    next_path = api_v1_home_timeline_url(pagination_params(max_id: @statuses.last.id))    unless @statuses.empty?
    prev_path = api_v1_home_timeline_url(pagination_params(since_id: @statuses.first.id)) unless @statuses.empty?
 
    set_pagination_headers(next_path, prev_path)
 
    render :index
  end

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25

-
-
|
|
!
|
-
|
|
|
|
|
|
!
|
|
|
-
|
!
|
-
|
!
!

class Feed
  def initialize(type, account)
    @type    = type
    @account = account
  end
 
  def get(limit, max_id = nil, since_id = nil)
    max_id     = '+inf' if max_id.blank?
    since_id   = '-inf' if since_id.blank?
    unhydrated = redis.zrevrangebyscore(key, "(#{max_id}", "(#{since_id}", limit: [0, limit], with_scores: true).map(&:last).map(&:to_i)
    status_map = Status.where(id: unhydrated).cache_ids.map { |s| [s.id, s] }.to_h
 
    unhydrated.map { |id| status_map[id] }.compact
  end
 
  private
 
  def key
    FeedManager.instance.key(@type, @account.id)
  end
 
  def redis
    Redis.current
  end
end

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19

-
-
|
|
-
-
-
|
|
!
!
!
|
|
|
-
|
!
!

class PrecomputeFeedService < BaseService
  # Fill up a user's home/mentions feed from DB and return a subset
  # @param [Symbol] type :home or :mentions
  # @param [Account] account
  def call(_, account)
    redis.pipelined do
      Status.as_home_timeline(account).limit(FeedManager::MAX_ITEMS / 4).each do |status|
        next if status.direct_visibility? || FeedManager.instance.filter?(:home, status, account.id)
        redis.zadd(FeedManager.instance.key(:home, account.id), status.id, status.reblog? ? status.reblog_of_id : status.id)
      end
    end
  end
 
  private
 
  def redis
    Redis.current
  end
end

  1
  2
  3
  4
  5
  6
  7
  8
  9

-
|
|
|
|
-
|
!
!

class RegenerationWorker
  include Sidekiq::Worker
 
  sidekiq_options queue: 'pull', backtrace: true, unique: :until_executed
 
  def perform(account_id, _ = :home)
    PrecomputeFeedService.new.call(:home, Account.find(account_id))
  end
end

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13

-
|
|
|
-
|
|
-
!
|
-
!
!

class ApplicationController < ActionController::Base
 
  before_action :set_user_activity
 
  def set_user_activity
    return unless !current_user.nil? && (current_user.current_sign_in_at.nil? || current_user.current_sign_in_at < 24.hours.ago)
 
    # Mark user as signed-in today
    current_user.update_tracked_fields(request)
 
    # If the sign in is after a two week break, we need to regenerate their feed
    RegenerationWorker.perform_async(current_user.account_id) if current_user.last_sign_in_at < 14.days.ago
  end

  1
  2

collection @statuses
extends('api/v1/statuses/show')