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)



104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/ayadn/nicerank.rb', line 104

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



86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
# File 'lib/ayadn/nicerank.rb', line 86

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
78
79
80
81
82
83
 
# 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

    begin
      parsed = JSON.parse(got)
    rescue JSON::ParserError => e
      parsed = {'meta' => {'code' => 404}, 'data' => []}
    end

  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