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 



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

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

.add_client_to_blacklist(target) ⇒ Object 



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

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

.add_hashtag_to_blacklist(target) ⇒ Object 



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

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

.add_mention_to_blacklist(target) ⇒ Object 



57
58
59
 
# File 'lib/ayadn/databases.rb', line 57

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

.add_niceranks(niceranks) ⇒ Object 



44
45
46
 
# File 'lib/ayadn/databases.rb', line 44

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

.add_to_users_db(id, username, name) ⇒ Object 



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

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

.add_to_users_db_from_list(list) ⇒ Object 



143
144
145
 
# File 'lib/ayadn/databases.rb', line 143

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 



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

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 



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

def self.clear_aliases
  @aliases.clear
end

.clear_blacklist ⇒ Object 



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

def self.clear_blacklist
  @blacklist.clear
end

.clear_bookmarks ⇒ Object 



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

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
 
# File 'lib/ayadn/databases.rb', line 24

def self.close_all

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

  Debug.db all_dbs

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

.convert_blacklist ⇒ Object 



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

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 



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

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

.delete_alias(channel_alias) ⇒ Object 



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

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

.delete_bookmark(post_id) ⇒ Object 



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

def self.delete_bookmark post_id
  @bookmarks.delete post_id
end

.get_alias_from_id(channel_id) ⇒ Object 



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

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 



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

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

.get_index_length ⇒ Object 



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

def self.get_index_length
  @index.length
end

.get_niceranks(user_ids) ⇒ Object 



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

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

.get_post_from_index(number) ⇒ Object 



134
135
136
137
138
139
140
141
 
# File 'lib/ayadn/databases.rb', line 134

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({error: "Out of range", caller: caller, data: [number]})
  end
end

.has_new?(stream, title) ⇒ Boolean

Returns:

  • (Boolean) 


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

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

.import_aliases(aliases) ⇒ Object 



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

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 



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

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 



40
41
42
 
# File 'lib/ayadn/databases.rb', line 40

def self.init(path)
    Daybreak::DB.new "#{path}"
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 



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

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

.rename_bookmark(post_id, new_title) ⇒ Object 



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

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

.save_indexed_posts(posts) ⇒ Object 



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

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

.save_max_id(stream, name = 'unknown') ⇒ Object 



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

def self.save_max_id(stream, name = 'unknown')
  if stream['meta']['marker'].nil?
    key = name
  else
    key = stream['meta']['marker']['name']
  end
  @pagination[key] = stream['meta']['max_id']
end