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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
# -*- 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),
description: _("ユーザ @{user} のOAuth 認証が失敗しました (@{response})\n設定から、認証をやり直してください。",
user: service.user, response: res))
nil
end
world_setting(:twitter, _('Twitter')) do
builder = Plugin::Twitter::Builder.new(
Environment::TWITTER_CONSUMER_KEY,
Environment::TWITTER_CONSUMER_SECRET)
label _("Webページにアクセスして表示された番号を、「トークン」に入力して、次へボタンを押してください。")
link builder.authorize_url
input "トークン", :token
result = await_input
builder.build(result[:token])
end
end
|
