Class: Akane::Storages::File

Inherits:
AbstractStorage show all
Defined in:
lib/akane/storages/file.rb

Instance Method Summary collapse

Methods inherited from AbstractStorage

#exitable?, #status, #stop!

Constructor Details

#initialize ⇒ File

Returns a new instance of File.



10
11
12
13
14
15
16
17
 
# File 'lib/akane/storages/file.rb', line 10

def initialize(*)
  super
  @screen_name_to_id_cache = {}
  @dir = Pathname.new(@config["dir"])
  [@dir, @dir.join('names'), @dir.join('users'), @dir.join('event'), @dir.join('timeline')].each do |d|
    d.mkdir unless d.exist?
  end
end

Instance Method Details

#mark_as_deleted(account, user_id, tweet_id) ⇒ Object 



32
33
34
35
36
37
 
# File 'lib/akane/storages/file.rb', line 32

def mark_as_deleted(, user_id, tweet_id)
  timeline_deletion_io.puts "#{Time.now.xmlschema},#{user_id},#{tweet_id}"
  tweets_deletion_io_for_user(user_id) do |io|
    io.puts "#{Time.now.xmlschema},#{user_id},#{tweet_id}"
  end
end

#name ⇒ Object 



19
20
21
 
# File 'lib/akane/storages/file.rb', line 19

def name
  @name ||= "#{self.class.name}:#{@config["dir"]}"
end

#record_event(account, event) ⇒ Object 



39
40
41
 
# File 'lib/akane/storages/file.rb', line 39

def record_event(, event)
  event_io.puts event.merge(:happened_on => ).to_json
end

#record_message(account, message) ⇒ Object 



43
44
45
46
47
48
49
50
51
 
# File 'lib/akane/storages/file.rb', line 43

def record_message(, message)
  messages_raw_io_for_user(message[:sender][:id], message[:sender][:screen_name]) do |io|
    io.puts message.attrs.to_json
  end
  messages_io_for_user(message[:sender][:id], message[:sender][:screen_name]) do |io|
    io.puts "[#{message[:created_at].xmlschema}] #{message[:sender][:screen_name]} -> #{message[:recipient][:screen_name]}:" \
                     " #{message[:text]} (#{message[:sender][:id]} -> #{message[:recipient][:id]},#{message[:id]})"
  end
end

#record_tweet(account, tweet) ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/akane/storages/file.rb', line 23

def record_tweet(, tweet)
  timeline_io.puts "[#{tweet[:created_at].xmlschema}][#{}] #{tweet[:user][:screen_name]}: " \
                   "#{tweet[:text].gsub(/\r?\n/,' ')} (#{tweet[:user][:id]},#{tweet[:id]})"

  tweets_io_for_user(tweet[:user][:id], tweet[:user][:screen_name]) do |io|
    io.puts tweet.attrs.to_json
  end
end