mikutter

      Plugin.call(:gui_timeline_message_removed, @tl.imaginary, iter[Gtk::TimeLine::InnerTL::MESSAGE])

---

name: extract_load more

slug: extract_load_more

description: 抽出タブの遡り機能を実装します。

depends:

  mikutter: '3.8'

  plugin:

  - extract

  - load_more_timeline

  - gui

version: '1.0'

author: cobodo

Plugin.create(:extract_load_more) do

  # データソース単位のload moreイベント

  # 第1引数： timeline slug

  # 第2引数： datasource slug

  # 第3引数： 抽出タブ内にある、そのdatasourceの最古のDiva::Model。

  defevent :extract_load_more_datasource, prototype: [Symbol, Symbol, Diva::Model]

  # 特定のデータソースにDiva::Model群を追加し、必要に応じてtimeline_maxの拡大も行なう。

  # 第1引数： timeline slug

  # 第2引数： datasource slug

  # 第3引数： datasourceに追加するDiva::Modelの配列

  defevent :extract_load_more_messages, prototype: [Symbol, Symbol, [Diva::Model]]

  def tl_uris

    @tl_uris ||= Hash.new # timeline_slug -> datasource_slug -> URI -> time

  end

  tl_uris

  def extract_tabs

    Plugin[:extract].extract_tabs

  end

  on_extract_receive_message do |source, messages|

    tabs = extract_tabs.values.select{ |r| r.sources && r.using?(source) }

    next if tabs.empty?

    tabs.each do |record|

      @tl_uris[record.slug] ||= Hash.new

      @tl_uris[record.slug][source] ||= Hash.new

      messages.each do |m|

        if m && m.uri

          unless m.retweet_source && tl_uris[record.slug][source].has_key?(m.retweet_source.uri.to_s)

            @tl_uris[record.slug][source][m.uri.to_s] = m.retweet_source ? m.modified : m.created

          end

        end

      end

    end

  end

  # n=TLあたりのメッセージ保持数、m=タブあたりの平均データソース数として、O(nm)

  on_gui_timeline_message_removed do |i_timeline, message|

    next unless (message && message.uri)

    @tl_uris[i_timeline.slug] ||= Hash.new

    @tl_uris[i_timeline.slug].keys.each do |source|

      @tl_uris[i_timeline.slug][source].delete(message.uri.to_s)

    end

  end

  # O(n)

  on_load_more_timeline do |tl_slug|

    next unless @tl_uris[tl_slug]

    @tl_uris[tl_slug].keys.each do |source|

      pair = @tl_uris[tl_slug][source].to_a.min{|a, b| a[1] <=> b[1] }

      oldest = timeline(tl_slug).find {|m| m && m.uri && m.uri == pair[0] }

      Plugin.call(:extract_load_more_datasource, tl_slug, source, oldest) if oldest

    end

  end

  on_extract_load_more_messages do |tl_slug, source, messages|

    pp "on_extract_load_more_messages: #{tl_slug} #{source} #{messages}"

    i_tl = timeline(tl_slug)

    i_tl.timeline_max = [messages.size + i_tl.size, i_tl.timeline_max].max

    @tl_uris[tl_slug] ||= Hash.new

    @tl_uris[tl_slug][source] ||= Hash.new

    messages.each do |m|

      @tl_uris[tl_slug][source][m.uri] = m.retweet_source ? m.modified : m.created

    end

    i_tl << messages

  end

end

  # timeline_maxを取得するフィルタ

  filter_gui_timeline_get_timeline_max do |i_tl, _|

    [i_tl, widgetof(i_tl).timeline_max]

  end

  # timeline_maxを設定するフィルタ

  filter_gui_timeline_set_timeline_max do |i_tl, n|

    widgetof(i_tl).timeline_max = n

    [i_tl, n]

  end

  # タイムラインのメッセージを順に処理するフィルタ

  filter_gui_timeline_each_messages do |i_tl, y|

    widgetof(i_tl).each do |m|

      y << m

    end

    [i_tl, y]

  end

  # timeline_maxを取得するフィルタ

  defevent :gui_timeline_get_timeline_max, prototype: [Plugin::GUI::Timeline, Integer]

  # timeline_maxを設定するフィルタ

  defevent :gui_timeline_set_timeline_max, prototype: [Plugin::GUI::Timeline, Integer]

  # タイムラインのメッセージを順に処理するフィルタ

  defevent :gui_timeline_each_messages, prototype: [Plugin::GUI::Timeline, :<<]

  # タイムラインからメッセージが除去された際に発生させるイベント

  defevent :gui_timeline_message_removed, prototype: [Plugin::GUI::Timeline, Diva::Model]

  include Enumerable

  # このタイムライン内の _message_ を繰り返し処理する

  def each

    enum = Enumerator.new do |y|

      Plugin.filtering(:gui_timeline_each_messages, self, y)

    end.lazy

    return enum unless block_given?

    enum.each do |m|

      yield m

    end

  end

  def size

    to_a.size

  end

  # timeline_maxを取得する

  def timeline_max

    Plugin.filtering(:gui_timeline_get_timeline_max, self, nil)[1] || UserConfig[:timeline_max]

  end

  # timeline_maxを設定する

  def timeline_max=(n)

    Plugin.filtering(:gui_timeline_set_timeline_max, self, n)

  end

---

name: load more timeline

slug: load_more_timeline

description: mikutterのタイムラインを遡るためのイベントを定義し、コマンドを提供します。

depends:

  mikutter: '3.8'

  plugin:

  - gui

version: '1.0'

author: cobodo

Plugin.create(:load_more_timeline) do

  defevent :load_more_timeline, prototype: [Symbol]

  # 遡るコマンド

  # プラグインは、on_load_more_timelineに渡されたタイムラインslugを見て遡ることができる。

  command(:load_more_timeline,

          name: _('タイムラインを遡る'),

          condition: lambda{ |opt| true },

          visible: true,

          role: :timeline) do |opt|

    i_tl = opt.widget

    Plugin.call(:load_more_timeline, i_tl.slug)

  end

end

---

name: twitter_load more

slug: twitter_load_more

description: twitterのHome Timeline、リプライ、ユーザータイムライン、リストの遡り機能を実装します。

depends:

  mikutter: '3.8'

  plugin:

  - twitter

  - list

  - load_more_timeline

  - extract_load_more

  - gui

  - world

version: '1.0'

author: cobodo

Plugin.create(:twitter_load_more) do

  def load_more(tl_slug, source = nil, oldest = nil, &adder)

    notice "twitter_load_more: tl_slug=#{tl_slug} source=#{source} oldest=#{oldest}"

    world = Plugin.filtering(:worlds, []).first.find{|w| w.class.slug == :twitter }

    if tl_slug == :home_timeline

      oldest = timeline(tl_slug).min {|a, b| a.modified.to_i <=> b.modified.to_i }

      params = {

        count: 200,

        max_id: oldest.id - 1,

        tweet_mode: 'extended'.freeze

      }

      world.home_timeline(params).next(&adder).terminate("twitter_load_more: home_timeline の追加取得に失敗しました")

    elsif tl_slug == :mentions

      oldest = timeline(tl_slug).min {|a, b| a.modified.to_i <=> b.modified.to_i }

      params = {

        count: 200,

        max_id: oldest.id - 1,

        tweet_mode: 'extended'.freeze

      }

      world.mentions(params).next(&adder).terminate("twitter_load_more: reply の追加取得に失敗しました")

    elsif timeline(tl_slug).parent.is_a?(Plugin::GUI::Fragment)

      oldest = timeline(tl_slug).min {|a, b| a.modified.to_i <=> b.modified.to_i }

      fragment_slug = timeline(tl_slug).parent.slug

      %r!\Ausertimeline_(.+)_[0-9]+_[0-9A-Fa-f]{8}_[0-9A-Fa-f]{8}\z!.match(fragment_slug.to_s) do |m|

        params = {

          # profile-http://twitter.com/username -> username

          screen_name: m[1].split('/').last,

          max_id: oldest.id - 1,

          count: 200,

          include_rts: 1,

          tweet_mode: 'extended'.freeze

        }

        world.user_timeline(params).next(&adder).terminate("twitter_load_more: usertimeline の追加取得に失敗しました")

      end

    elsif source

      list = Plugin[:list].using_lists.find{|list| Plugin[:list].datasource_slug(list) == source }

      return unless list

      world = Plugin.filtering(:worlds, []).first.find{|w| w.class.slug == :twitter }

      params = {

        count: 200,

        max_id: oldest.id - 1,

        list_id: list[:id],

        cache: :keep

      }

      world.list_statuses(params).next(&adder).terminate("twitter_load_more: home_timeline の追加取得に失敗しました")

    end

  end

  on_load_more_timeline do |tl_slug|

    notice "twitter_load_more: on_load_more_timeline: tl_slug=#{tl_slug}"

    load_more(tl_slug) do |messages|

      notice "on_load_more_timeline: add #{messages} to #{tl_slug}"

      i_tl = timeline(tl_slug)

      i_tl.timeline_max = [messages.size + i_tl.size, i_tl.timeline_max].max

      i_tl << messages

    end

  end

  on_extract_load_more_datasource do |tl_slug, source, oldest|

    notice "twitter_load_more: on_extract_load_more_datasource: tl_slug=#{tl_slug} source=#{source} oldest=#{oldest}"

    load_more(tl_slug, source, oldest) do |messages|

      notice "on_extract_load_more_datasource: add #{messages} to #{tl_slug}, #{source}"

      Plugin.call(:extract_load_more_messages, tl_slug, source, messages)

    end

  end

end