1
|
|
|
require 'time' |
2
|
|
|
require 'uri' |
3
|
|
|
|
4
|
|
|
module RingCentralSdk::REST::Cache |
5
|
|
|
class Extensions |
6
|
|
|
attr_accessor :client |
7
|
|
|
attr_accessor :account_id |
8
|
|
|
attr_reader :extensions_hash |
9
|
|
|
attr_reader :extensions_num2id |
10
|
|
|
attr_reader :last_retrieved |
11
|
|
|
|
12
|
|
|
def initialize(client) |
13
|
|
|
@client = client |
14
|
|
|
@account_id = '~' |
15
|
|
|
flush() |
16
|
|
|
end |
17
|
|
|
|
18
|
|
|
def flush |
19
|
|
|
@extensions_hash = {} |
20
|
|
|
@extensions_num2id = {} |
21
|
|
|
@last_retrieved = -1 |
22
|
|
|
end |
23
|
|
|
|
24
|
|
|
def retrieve(params={}, retrieve_all=true) |
25
|
|
|
@last_retrieved = Time.now.to_i |
26
|
|
|
uri = URI.parse "account/#{@account_id}/extension" |
27
|
|
|
if params.length > 0 |
28
|
|
|
uri.query = URI.encode_www_form params |
29
|
|
|
end |
30
|
|
|
res = @client.http.get do |req| |
31
|
|
|
req.url uri.to_s |
32
|
|
|
if retrieve_all |
33
|
|
|
req.params['page'] = 1 |
34
|
|
|
req.params['perPage'] = 1000 |
35
|
|
|
end |
36
|
|
|
end |
37
|
|
|
res.body['records'].each do |extension| |
38
|
|
|
if extension.key?('id') && extension['id'] > 0 |
39
|
|
|
@extensions_hash[extension['id'].to_s] = extension |
40
|
|
|
end |
41
|
|
|
end |
42
|
|
|
if retrieve_all |
43
|
|
|
while res.body.key?('navigation') && res.body['navigation'].key?('nextPage') |
44
|
|
|
res = @client.http.get do |req| |
45
|
|
|
req.url res.body['navigation']['nextPage']['uri'] |
46
|
|
|
end |
47
|
|
|
res.body['records'].each do |extension| |
48
|
|
|
if extension.key?('id') && extension['id'] > 0 |
49
|
|
|
@extensions_hash[extension['id'].to_s] = extension |
50
|
|
|
end |
51
|
|
|
end |
52
|
|
|
end |
53
|
|
|
end |
54
|
|
|
inflate_num2id() |
55
|
|
|
return @extensions_hash |
56
|
|
|
end |
57
|
|
|
|
58
|
|
|
def retrieve_all() |
59
|
|
|
retrieve({}, true) |
60
|
|
|
end |
61
|
|
|
|
62
|
|
|
def inflate_num2id() |
63
|
|
|
num2id = {} |
64
|
|
|
@extensions_hash.each do |k,v| |
65
|
|
|
if v.key?('id') && v['id'] > 0 && |
66
|
|
|
v.key?('extensionNumber') && v['extensionNumber'].length>0 |
67
|
|
|
num2id[v['extensionNumber']] = v['id'].to_s |
68
|
|
|
end |
69
|
|
|
end |
70
|
|
|
@extensions_num2id = num2id |
71
|
|
|
return num2id |
72
|
|
|
end |
73
|
|
|
|
74
|
|
|
def get_extension_by_id(extension_id) |
75
|
|
|
if !extension_id.is_a?(String) |
76
|
|
|
extension_id = extension_id.to_s |
77
|
|
|
end |
78
|
|
|
if @extensions_hash.key? extension_id |
79
|
|
|
return @extensions_hash[extension_id] |
80
|
|
|
end |
81
|
|
|
return nil |
82
|
|
|
end |
83
|
|
|
|
84
|
|
|
def get_extension_by_number(extension_number) |
85
|
|
|
if !extension_number.is_a?(String) |
86
|
|
|
extension_number = extension_number.to_s |
87
|
|
|
end |
88
|
|
|
if @extensions_num2id.key?(extension_number) |
89
|
|
|
extension_id = @extensions_num2id[extension_number] |
90
|
|
|
if @extensions_hash.key?(extension_id) |
91
|
|
|
return @extensions_hash[extension_id] |
92
|
|
|
end |
93
|
|
|
end |
94
|
|
|
return nil |
95
|
|
|
end |
96
|
|
|
|
97
|
|
|
def get_department_members(department_id) |
98
|
|
|
if !department_id.is_a?(String) |
99
|
|
|
department_id = department_id.to_s |
100
|
|
|
end |
101
|
|
|
if department_id !~ /^[0-9]+$/ |
102
|
|
|
raise 'department_id parameter must be a positive integer' |
103
|
|
|
end |
104
|
|
|
|
105
|
|
|
members = [] |
106
|
|
|
|
107
|
|
|
res = @client.http.get do |req| |
108
|
|
|
req.url "account/#{account_id}/department/#{department_id}/members" |
109
|
|
|
end |
110
|
|
|
|
111
|
|
|
if res.body.key? 'records' |
112
|
|
|
res.body['records'].each do |extension| |
113
|
|
|
if extension.key? 'id' |
114
|
|
|
member = get_extension_by_id extension['id'] |
115
|
|
|
members.push member unless member.nil? |
116
|
|
|
end |
117
|
|
|
end |
118
|
|
|
end |
119
|
|
|
|
120
|
|
|
return members |
121
|
|
|
end |
122
|
|
|
end |
123
|
|
|
end |
124
|
|
|
|