Class: Ayadn::Databases

Inherits:
Object
  • Object
show all
Defined in:
lib/ayadn/databases.rb

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.aliases ⇒ Object

Returns the value of attribute aliases.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def aliases
  @aliases
end

.blacklist ⇒ Object

Returns the value of attribute blacklist.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def blacklist
  @blacklist
end

.bookmarks ⇒ Object

Returns the value of attribute bookmarks.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def bookmarks
  @bookmarks
end

.index ⇒ Object

Returns the value of attribute index.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def index
  @index
end

.nicerank ⇒ Object

Returns the value of attribute nicerank.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def nicerank
  @nicerank
end

.pagination ⇒ Object

Returns the value of attribute pagination.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def pagination
  @pagination
end

.users ⇒ Object

Returns the value of attribute users.



7
8
9
 
# File 'lib/ayadn/databases.rb', line 7

def users
  @users
end

Class Method Details

.add_bookmark(bookmark) ⇒ Object 



159
160
161
 
# File 'lib/ayadn/databases.rb', line 159

def self.add_bookmark bookmark
  @bookmarks[bookmark[:id]] = bookmark
end

.add_client_to_blacklist(target) ⇒ Object 



70
71
72
 
# File 'lib/ayadn/databases.rb', line 70

def self.add_client_to_blacklist(target)
  target.each {|source| @blacklist[source.downcase] = :client}
end

.add_hashtag_to_blacklist(target) ⇒ Object 



73
74
75
 
# File 'lib/ayadn/databases.rb', line 73

def self.add_hashtag_to_blacklist(target)
  target.each {|tag| @blacklist[tag.downcase] = :hashtag}
end

.add_mention_to_blacklist(target) ⇒ Object 



67
68
69
 
# File 'lib/ayadn/databases.rb', line 67

def self.add_mention_to_blacklist(target)
  target.each {|username| @blacklist[username.downcase] = :mention}
end

.add_niceranks(niceranks) ⇒ Object 



54
55
56
 
# File 'lib/ayadn/databases.rb', line 54

def self.add_niceranks niceranks
  niceranks.each {|id,infos| @nicerank[id] = infos}
end

.add_to_users_db(id, username, name) ⇒ Object 



151
152
153
 
# File 'lib/ayadn/databases.rb', line 151

def self.add_to_users_db(id, username, name)
  @users[id] = {username => name}
end

.add_to_users_db_from_list(list) ⇒ Object 



147
148
149
 
# File 'lib/ayadn/databases.rb', line 147

def self.add_to_users_db_from_list(list)
  list.each { |id, content_array| @users[id] = {content_array[0] => content_array[1]} }
end

.add_user_to_blacklist(target) ⇒ Object 



64
65
66
 
# File 'lib/ayadn/databases.rb', line 64

def self.add_user_to_blacklist(target)
  target.each {|username| @blacklist["-#{username.downcase}"] = :user}
end

.all_dbs ⇒ Object 



20
21
22
 
# File 'lib/ayadn/databases.rb', line 20

def self.all_dbs
  [@users, @index, @pagination, @aliases, @blacklist, @bookmarks, @nicerank]
end

.clear_aliases ⇒ Object 



102
103
104
 
# File 'lib/ayadn/databases.rb', line 102

def self.clear_aliases
  @aliases.clear
end

.clear_blacklist ⇒ Object 



106
107
108
 
# File 'lib/ayadn/databases.rb', line 106

def self.clear_blacklist
  @blacklist.clear
end

.clear_bookmarks ⇒ Object 



110
111
112
 
# File 'lib/ayadn/databases.rb', line 110

def self.clear_bookmarks
  @bookmarks.clear
end

.close_all ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/ayadn/databases.rb', line 24

def self.close_all

  if @nicerank.size > 10000
    limit = Time.now - (3600 * 168)
    @nicerank.each {|k,v| @nicerank.delete(k) if v[:cached] < limit}
    if @nicerank.size > 10000
      limit = Time.now - (3600 * 48)
      @nicerank.each {|k,v| @nicerank.delete(k) if v[:cached] < limit}
    end
  end

  Debug.db all_dbs

  all_dbs.each do |db|
    db.flush
    db.compact
    db.close
  end
end

.convert_blacklist ⇒ Object 



84
85
86
87
88
89
 
# File 'lib/ayadn/databases.rb', line 84

def self.convert_blacklist
  dummy = {}
  @blacklist.each {|v,k| dummy[v.downcase] = k}
  @blacklist.clear
  dummy.each {|v,k| @blacklist[v] = k}
end

.create_alias(channel_id, channel_alias) ⇒ Object 



94
95
96
 
# File 'lib/ayadn/databases.rb', line 94

def self.create_alias(channel_id, channel_alias)
  @aliases[channel_alias] = channel_id
end

.delete_alias(channel_alias) ⇒ Object 



98
99
100
 
# File 'lib/ayadn/databases.rb', line 98

def self.delete_alias(channel_alias)
  @aliases.delete(channel_alias)
end

.delete_bookmark(post_id) ⇒ Object 



163
164
165
 
# File 'lib/ayadn/databases.rb', line 163

def self.delete_bookmark post_id
  @bookmarks.delete post_id
end

.get_alias_from_id(channel_id) ⇒ Object 



124
125
126
127
 
# File 'lib/ayadn/databases.rb', line 124

def self.get_alias_from_id(channel_id)
  @aliases.each {|al, id| return al if id == channel_id}
  nil
end

.get_channel_id(channel_alias) ⇒ Object 



114
115
116
 
# File 'lib/ayadn/databases.rb', line 114

def self.get_channel_id(channel_alias)
  @aliases[channel_alias]
end

.get_index_length ⇒ Object 



134
135
136
 
# File 'lib/ayadn/databases.rb', line 134

def self.get_index_length
  @index.length
end

.get_niceranks(user_ids) ⇒ Object 



58
59
60
61
62
 
# File 'lib/ayadn/databases.rb', line 58

def self.get_niceranks user_ids
  ids = {}
  user_ids.each {|id| ids[id] = @nicerank[id]}
  ids
end

.get_post_from_index(number) ⇒ Object 



138
139
140
141
142
143
144
145
 
# File 'lib/ayadn/databases.rb', line 138

def self.get_post_from_index(number)
  unless number > @index.length || number <= 0
    @index.each {|id, values| return values if values[:count] == number}
  else
    puts Status.must_be_in_index
    Errors.global_error("databases/get_post_from_index", number, "out of range")
  end
end

.has_new?(stream, title) ⇒ Boolean

Returns:

  • (Boolean) 


155
156
157
 
# File 'lib/ayadn/databases.rb', line 155

def self.has_new?(stream, title)
  stream['meta']['max_id'].to_i > @pagination[title].to_i
end

.import_aliases(aliases) ⇒ Object 



118
119
120
121
122
 
# File 'lib/ayadn/databases.rb', line 118

def self.import_aliases(aliases)
  new_aliases = self.init aliases
  new_aliases.each {|al,id| @aliases[al] = id}
  new_aliases.close
end

.import_blacklist(blacklist) ⇒ Object 



79
80
81
82
83
 
# File 'lib/ayadn/databases.rb', line 79

def self.import_blacklist(blacklist)
  new_list = self.init blacklist
  new_list.each {|name,type| @blacklist[name] = type}
  new_list.close
end

.init(path) ⇒ Object 



44
45
46
47
48
49
50
51
52
 
# File 'lib/ayadn/databases.rb', line 44

def self.init(path)
  # winPlatforms = ['mswin', 'mingw', 'mingw_18', 'mingw_19', 'mingw_20', 'mingw32']
  # case RbConfig::CONFIG['host_os']
  # when *winPlatforms
  #   abort("\nSorry, Ayadn doesn't work on Windows.\n\n".color(:red))
  # else
    Daybreak::DB.new "#{path}"
  # end
end

.open_databases ⇒ Object 



10
11
12
13
14
15
16
17
18
 
# File 'lib/ayadn/databases.rb', line 10

def self.open_databases
  @users = self.init "#{Settings.config[:paths][:db]}/users.db"
  @index = self.init "#{Settings.config[:paths][:pagination]}/index.db"
  @pagination = self.init "#{Settings.config[:paths][:pagination]}/pagination.db"
  @aliases = self.init "#{Settings.config[:paths][:db]}/aliases.db"
  @blacklist = self.init "#{Settings.config[:paths][:db]}/blacklist.db"
  @bookmarks = self.init "#{Settings.config[:paths][:db]}/bookmarks.db"
  @nicerank = self.init "#{Settings.config[:paths][:db]}/nicerank.db"
end

.remove_from_blacklist(target) ⇒ Object 



76
77
78
 
# File 'lib/ayadn/databases.rb', line 76

def self.remove_from_blacklist(target)
  target.each {|el| @blacklist.delete(el.downcase)}
end

.rename_bookmark(post_id, new_title) ⇒ Object 



167
168
169
 
# File 'lib/ayadn/databases.rb', line 167

def self.rename_bookmark post_id, new_title
  @bookmarks[post_id][:title] = new_title
end

.save_indexed_posts(posts) ⇒ Object 



129
130
131
132
 
# File 'lib/ayadn/databases.rb', line 129

def self.save_indexed_posts(posts)
  @index.clear
  posts.each {|id, hash| @index[id] = hash}
end

.save_max_id(stream) ⇒ Object 



90
91
92
 
# File 'lib/ayadn/databases.rb', line 90

def self.save_max_id(stream)
  @pagination[stream['meta']['marker']['name']] = stream['meta']['max_id']
end