Class: Ayadn::NiceRank

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ NiceRank

Returns a new instance of NiceRank.



7
8
9
10
11
12
13
 
# File 'lib/ayadn/nicerank.rb', line 7

def initialize
  @url = 'http://api.nice.social/user/nicerank?ids='
  @store = FastCache::Cache.new(5_000, 120*60) # 5000 items with 2 hours TTL each
  @hits = 0
  @ids = 0
  @posts = 0
end

Instance Attribute Details

#store ⇒ Object (readonly)

Returns the value of attribute store.



5
6
7
 
# File 'lib/ayadn/nicerank.rb', line 5

def store
  @store
end

Instance Method Details

#from_ids(ids) ⇒ Object

This is for user lists, no scrolling: no need to cache Even with a lot of requests, it’s within the NR limits because of the slicing (upto 200 objects / call)



98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
 
# File 'lib/ayadn/nicerank.rb', line 98

def from_ids ids
  blocs, ranks = [], []
  blank = JSON.parse({'meta' => {'code' => 404}, 'data' => []}.to_json)
  until ids.empty?
    blocs << ids.shift(200)
  end
  blocs.each do |bloc|
    got = CNX.get("#{@url}#{bloc.join(',')}&show_details=Y")
    if got.nil? || got.empty?
      ranks << [{}]
    else
      resps = JSON.parse(got)
      ranks << resps['data']
    end
  end
  return ranks.flatten!
end

#get_posts_day(ids) ⇒ Object

This is for user info, no scrolling: no need to cache



80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/ayadn/nicerank.rb', line 80

def get_posts_day ids
  resp = JSON.parse(CNX.get("#{@url}#{ids.join(',')}&show_details=Y"))
  if resp.nil? || resp['meta']['code'] != 200
    []
  else
    resp['data'].map do |obj|
      pday = obj['user']['posts_day'] == -1 ? 0 : obj['user']['posts_day']
      {
        id: obj['user_id'],
        posts_day:pday.round(2)
      }
    end
  end
end

#get_ranks(stream) ⇒ Object

Get posts Get unique posters Get NR response Fetch IDs from store if absent, decode + save to dic + cache in store if present, save to dic from store (and count hits for debug)



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

def get_ranks stream
  user_ids, niceranks = [], {}
  stream['data'].each do |post|
    id = post['user']['id']
    user_ids << id if @store[id].nil?
  end
  user_ids.uniq!
  got = CNX.get "#{@url}#{user_ids.join(',')}&show_details=Y" unless user_ids.empty?
  if got.nil? || got == ""
    parsed = {'meta' => {'code' => 404}, 'data' => []}
  else
    parsed = JSON.parse(got)
  end
  parsed['data'].each do |obj|
    res = @store[obj['user_id']]
    if res.nil?
      obj['account']['is_human'] == true ? is_human = 1 : is_human = 0
      obj['account']['real_person'] == true ? real_person = 1 : real_person = 0
      content = {
        username: obj['user']['username'],
        rank: obj['rank'],
        is_human: is_human,
        real_person: real_person
      }
      @store[obj['user_id']] = content
      niceranks[obj['user_id']] = content
    else
      @hits += 1
      niceranks[obj['user_id']] = res
    end

  end

  @posts += stream['data'].size
  @ids += user_ids.size

  if Settings.options[:timeline][:debug] == true
    deb = "\n"
    deb << "+ NICERANK\n"
    deb << "* t#{Time.now.to_i}\n"
    deb << "Posts:\t\t#{stream['data'].size}\n"
    deb << "Requested NR:\t#{user_ids.size}\n"
    deb << "* TOTALS\n"
    deb << "Posts:\t\t#{@posts}\n"
    deb << "Fetched ranks:\t#{@ids}\n"
    deb << "DB hits:\t#{@hits}\n"
    deb << "Uniques:\t#{@store.count}\n"
    deb << "\n"
    puts deb.color(Settings.options[:colors][:debug])
    Logs.rec.debug "NICERANK/POSTS: #{@posts}"
    Logs.rec.debug "NICERANK/NR CALLS: #{@ids}"
    Logs.rec.debug "NICERANK/CACHE HITS: #{@hits}"
    Logs.rec.debug "NICERANK/CACHED IDS: #{@store.count}"
  end

  return niceranks
end