coreプラグインにあった、Twitterのためのコードをtwitterプラグインに移植

3 files changed, 134 insertions, 114 deletions

diff --git a/core/plugin/core/core.rb b/core/plugin/core/core.rb
index 4fd82249..36ab3df8 100644
--- a/core/plugin/core/core.rb
+++ b/core/plugin/core/core.rb
@@ -1,127 +1,13 @@
 # -*- coding: utf-8 -*-
-require 'json'
-
-Plugin.create :core do
-
-  # Serviceと、Messageの配列を受け取り、一度以上受け取ったことのあるものを除外して返すフィルタを作成して返す。
-  # ただし、除外したかどうかはService毎に記録する。
-  # また、アカウント登録前等、serviceがnilの時はシステムメッセージ以外を全て削除し、記録しない。
-  # ==== Return
-  # フィルタのプロシージャ(Proc)
-  def gen_message_filter_with_service
-    service_filters = Hash.new{|h,k|h[k] = gen_message_filter}
-    ->(service, messages, &cancel) {
-      if service
-        [service] + service_filters[service.user_obj.id].(messages)
-      else
-        system = messages.select(&:system?)
-        if system.empty?
-          cancel.call
-        else
-          [nil, system] end end } end
-
-  # Messageの配列を受け取り、一度以上受け取ったことのあるものを除外して返すフィルタを作成して返す
-  # ==== Return
-  # フィルタのプロシージャ(Proc)
-  def gen_message_filter
-    appeared = Set.new
-    ->(messages){
-      [messages.select{ |message|
-         appeared.add(message.id) unless appeared.include?(message.id) }] } end
-
-  # URL _url_ がTwitterに投稿された時に何文字としてカウントされるかを返す
-  # ==== Args
-  # [url] String URL
-  # ==== Return
-  # Fixnum URLの長さ
-  def posted_url_length(url)
-    if url.start_with?('https://'.freeze)
-      @twitter_configuration[:short_url_length_https] || 23
-    else
-      @twitter_configuration[:short_url_length] || 22 end end
-
-  filter_update(&gen_message_filter_with_service)
-
-  filter_mention(&gen_message_filter_with_service)
-
-  filter_direct_messages(&gen_message_filter_with_service)
-
-  filter_appear(&gen_message_filter)
-
-  # リツイートを削除した時、ちゃんとリツイートリストからそれを削除する
-  on_destroyed do |messages|
-    messages.each{ |message|
-      if message.retweet?
-        source = message.retweet_source(false)
-        if source
-          Plugin.call(:retweet_destroyed, source, message.user, message[:id])
-          source.retweeted_sources.delete(message) end end } end
-
-end
 
 Module.new do
 
   Plugin.create(:core) do
 
-    defevent :favorite,
-    priority: :ui_favorited,
-    prototype: [Diva::Model, User, Message]
-
-    defevent :unfavorite,
-    priority: :ui_favorited,
-    prototype: [Diva::Model, User, Message]
-
-    favorites = Hash.new{ |h, k| h[k] = Set.new } # {user_id: set(message_id)}
-    unfavorites = Hash.new{ |h, k| h[k] = Set.new } # {user_id: set(message_id)}
-    @twitter_configuration = JSON.parse(file_get_contents(File.join(__dir__, 'configuration.json'.freeze)), symbolize_names: true)
-
-    onappear do |messages|
-      retweets = messages.select(&:retweet?).map do |message|
-        result = message.retweet_ancestors.to_a[-2]
-        fail "invalid retweet #{message.inspect}. ancestors: #{message.retweet_ancestors.to_a.inspect}" unless result.is_a?(Message)
-        result
-      end
-      if not(retweets.empty?)
-        Plugin.call(:retweet, retweets) end end
-
     # イベントフィルタを他のスレッドで並列実行する
     Delayer.new do
       Event.filter_another_thread = true end
 
-    # Twitter API help/configuration.json を叩いて最新情報を取得する
-    Delayer.new do
-      service = Service.primary
-      if service
-        (service/:help/:configuration).json(cache: true).next do |configuration|
-          @twitter_configuration = configuration.symbolize end end end
-
-    # 同じツイートに対するfavoriteイベントは一度しか発生させない
-    filter_favorite do |service, user, message|
-      Plugin.filter_cancel! if favorites[user[:id]].include? message[:id]
-      favorites[user[:id]] << message[:id]
-      [service, user, message]
-    end
-
-    # 同じツイートに対するunfavoriteイベントは一度しか発生させない
-    filter_unfavorite do |service, user, message|
-      Plugin.filter_cancel! if unfavorites[user[:id]].include? message[:id]
-      unfavorites[user[:id]] << message[:id]
-      [service, user, message]
-    end
-
-    # followers_createdイベントが発生したら、followイベントも発生させる
-    on_followers_created do |service, users|
-      users.each{ |user|
-        Plugin.call(:follow, user, service.user_obj) } end
-
-    # followings_createdイベントが発生したら、followイベントも発生させる
-    on_followings_created do |service, users|
-      users.each{ |user|
-        Plugin.call(:follow, service.user_obj, user) } end
-
-    # t.coによって短縮されたURLの長さを求める
-    filter_tco_url_length do |url, length|
-      [url, posted_url_length(url)] end
   end
 
 end
diff --git a/core/plugin/core/configuration.json b/core/plugin/twitter/configuration.json
index 1f02bc0f..1f02bc0f 100644
--- a/core/plugin/core/configuration.json
+++ b/core/plugin/twitter/configuration.json
diff --git a/core/plugin/twitter/twitter.rb b/core/plugin/twitter/twitter.rb
index d99b26b9..59b99fdf 100644
--- a/core/plugin/twitter/twitter.rb
+++ b/core/plugin/twitter/twitter.rb
@@ -1,8 +1,142 @@
 # -*- coding: utf-8 -*-
+require 'json'
 require_relative 'builder'
 require_relative 'model/world'
 
 Plugin.create(:twitter) do
+
+  defevent :favorite,
+           priority: :ui_favorited,
+           prototype: [Diva::Model, User, Message]
+
+  defevent :unfavorite,
+           priority: :ui_favorited,
+           prototype: [Diva::Model, User, Message]
+
+  favorites = Hash.new{ |h, k| h[k] = Set.new } # {user_id: set(message_id)}
+  unfavorites = Hash.new{ |h, k| h[k] = Set.new } # {user_id: set(message_id)}
+
+  @twitter_configuration = JSON.parse(file_get_contents(File.join(__dir__, 'configuration.json'.freeze)), symbolize_names: true)
+
+  # Twitter API help/configuration.json を叩いて最新情報を取得する
+  Delayer.new do
+    twitter = Enumerator.new{|y|
+      Plugin.filtering(:worlds, y)
+    }.find{|world|
+      world.class.slug == :twitter
+    }
+    if twitter
+      (twitter/:help/:configuration).json(cache: true).next do |configuration|
+        @twitter_configuration = configuration.symbolize
+      end
+    end
+  end
+
+  # Serviceと、Messageの配列を受け取り、一度以上受け取ったことのあるものを除外して返すフィルタを作成して返す。
+  # ただし、除外したかどうかはService毎に記録する。
+  # また、アカウント登録前等、serviceがnilの時はシステムメッセージ以外を全て削除し、記録しない。
+  # ==== Return
+  # フィルタのプロシージャ(Proc)
+  def gen_message_filter_with_service
+    service_filters = Hash.new{|h,k|h[k] = gen_message_filter}
+    ->(service, messages, &cancel) do
+      if service
+        [service] + service_filters[service.user_obj.id].(messages)
+      else
+        system = messages.select(&:system?)
+        if system.empty?
+          cancel.call
+        else
+          [nil, system]
+        end
+      end
+    end
+  end
+
+  # Messageの配列を受け取り、一度以上受け取ったことのあるものを除外して返すフィルタを作成して返す
+  # ==== Return
+  # フィルタのプロシージャ(Proc)
+  def gen_message_filter
+    appeared = Set.new
+    ->(messages) do
+      [messages.select{ |message| appeared.add(message.id) unless appeared.include?(message.id) }]
+    end
+  end
+
+  # URL _url_ がTwitterに投稿された時に何文字としてカウントされるかを返す
+  # ==== Args
+  # [url] String URL
+  # ==== Return
+  # Fixnum URLの長さ
+  def posted_url_length(url)
+    if url.start_with?('https://'.freeze)
+      @twitter_configuration[:short_url_length_https] || 23
+    else
+      @twitter_configuration[:short_url_length] || 22
+    end
+  end
+
+  filter_update(&gen_message_filter_with_service)
+
+  filter_mention(&gen_message_filter_with_service)
+
+  filter_direct_messages(&gen_message_filter_with_service)
+
+  filter_appear(&gen_message_filter)
+
+  # リツイートを削除した時、ちゃんとリツイートリストからそれを削除する
+  on_destroyed do |messages|
+    messages.each{ |message|
+      if message.retweet?
+        source = message.retweet_source(false)
+        if source
+          Plugin.call(:retweet_destroyed, source, message.user, message[:id])
+          source.retweeted_sources.delete(message) end end } end
+
+  onappear do |messages|
+    retweets = messages.select(&:retweet?).map do |message|
+      result = message.retweet_ancestors.to_a[-2]
+      fail "invalid retweet #{message.inspect}. ancestors: #{message.retweet_ancestors.to_a.inspect}" unless result.is_a?(Message)
+      result
+    end
+    if not retweets.empty?
+      Plugin.call(:retweet, retweets)
+    end
+  end
+
+  # 同じツイートに対するfavoriteイベントは一度しか発生させない
+  filter_favorite do |service, user, message|
+    Plugin.filter_cancel! if favorites[user[:id]].include? message[:id]
+    favorites[user[:id]] << message[:id]
+    [service, user, message]
+  end
+
+  # 同じツイートに対するunfavoriteイベントは一度しか発生させない
+  filter_unfavorite do |service, user, message|
+    Plugin.filter_cancel! if unfavorites[user[:id]].include? message[:id]
+    unfavorites[user[:id]] << message[:id]
+    [service, user, message]
+  end
+
+  # followers_createdイベントが発生したら、followイベントも発生させる
+  on_followers_created do |service, users|
+    users.each do |user|
+      Plugin.call(:follow, user, service.user_obj)
+    end
+  end
+
+  # followings_createdイベントが発生したら、followイベントも発生させる
+  on_followings_created do |service, users|
+    users.each do |user|
+      Plugin.call(:follow, service.user_obj, user)
+    end
+  end
+
+  # t.coによって短縮されたURLの長さを求める
+  filter_tco_url_length do |url, length|
+    [url, posted_url_length(url)]
+  end
+
   # トークン切れの警告
   MikuTwitter::AuthenticationFailedAction.register do |service, method = nil, url = nil, options = nil, res = nil|
     activity(:system, _("アカウントエラー (@{user})", user: service.user),