Completed
Push — master ( b57d1d...4bde78 )
by John
01:08
created

Extensions.get_department_members()   B

Complexity

Conditions 4

Size

Total Lines 25

Duplication

Lines 0
Ratio 0 %
Metric Value
cc 4
dl 0
loc 25
rs 8.5806
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