summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/dialplan/callthrough.lua
blob: 59f170aa40e28eb05c6b2465172d4c21ea99c322 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
-- CommonModule: Callthrough
--
module(...,package.seeall)

Callthrough = {}

-- Create Callthrough object
function Callthrough.new(self, arg)
  arg = arg or {}
  object = arg.object or {}
  setmetatable(object, self)
  self.__index = self
  self.log = arg.log
  self.database = arg.database
  self.record = arg.record
  self.access_authorizations = arg.access_authorizations
  return object
end

-- Find Callthrough by ID
function Callthrough.find_by_id(self, id)
  local sql_query = string.format("SELECT * FROM `callthroughs` WHERE `id`=%d LIMIT 1", id)
  local record = nil

  self.database:query(sql_query, function(callthrough_entry)
    record = callthrough_entry
  end)

  if record then
    local callthrough = Callthrough:new(self);
    callthrough.record = record

    require 'dialplan.access_authorizations'
    callthrough.access_authorizations = dialplan.access_authorizations.AccessAuthorization:new{ log = self.log, database = self.database }:list_by_owner(record.id, 'Callthrough');
    return callthrough
  end

  return nil 
end

function Callthrough.authenticate(self, caller)
  local authorizations = {}
  local logins = {}
  local pins = {}

  caller:answer();
  caller:sleep(1000);

  if not self.access_authorizations or table.getn(self.access_authorizations) == 0 then
    self.log:debug('CALLTHROUGH_AUTHENTICATE - authorization disabled');
    return true;
  end

  self.log:debug('CALLTHROUGH_AUTHENTICATE - access_authorizations: ', #self.access_authorizations);
  for index, authorization in ipairs(self.access_authorizations) do
    if not common.str.blank(authorization.phone_number) then
      if authorization.phone_number == caller.caller_phone_number then
        if authorization.pin and authorization.pin ~= "" then
          if caller.session:read(authorization.pin:len(), authorization.pin:len(), "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#") ~= authorization.pin then
            self.log:debug("CALLTHROUGH_AUTHENTICATE - Wrong PIN");
            return false;
          else
            self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by caller id: " .. caller.caller_phone_number .. " and PIN");
            return authorization;
          end
        end
        self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by caller id: " .. caller.caller_phone_number);
        return authorization;
      end
    else
      self.log:debug('CALLTHROUGH_AUTHENTICATE - access_authorization=', authorization.id);
      if authorization.id then
        authorizations[authorization.id] = authorization;
        if authorization.login and authorization.login ~= "" then
          logins[authorization.login] = authorization;
        elseif authorization.pin and authorization.pin ~= "" then
          pins[authorization.pin] = authorization;
        end
      end
    end
  end

  local login = nil;
  local pin = nil;


  if next(logins) ~= nil then

    caller.session:streamFile('ivr/ivr-please_enter_the.wav');
    caller.session:streamFile('ivr/ivr-id_number.wav');
    login = caller.session:read(2, 10, 'ivr/ivr-followed_by_pound.wav', 3000, '#');
  end

  if login and logins[tostring(login)] then
    if not logins[tostring(login)].pin or logins[tostring(login)].pin == '' then
      self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by login: " .. login .. " without PIN");
      return logins[tostring(login)];
    end
    pin = caller.session:read(2, 10, "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#");
    if logins[tostring(login)].pin == pin then
      self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by login: " .. login .. " and PIN");
      return logins[tostring(login)];
    else
      self.log:debug("CALLTHROUGH_AUTHENTICATE - Wrong PIN");
      return false
    end
  end

  if next(pins) ~= nil then
    pin = caller.session:read(2, 10, "ivr/ivr-please_enter_pin_followed_by_pound.wav", 3000, "#");
  end

  self.log:debug("CALLTHROUGH_AUTHENTICATE - No such login, try PIN");

  if pin and pins[tostring(pin)] then
    self.log:debug("CALLTHROUGH_AUTHENTICATE - Caller was authenticated by PIN");
    return pins[tostring(pin)];
  end
  
  self.log:debug("CALLTHROUGH_AUTHENTICATE - No login, wrong PIN - giving up");

  return false;
end

function Callthrough.whitelist(self, number)
  local sql_query = 'SELECT `id` FROM `whitelists` WHERE `whitelistable_type` = "Callthrough" AND `whitelistable_id` = ' .. self.record.id;
  local whitelist_ids = {}

  self.database:query(sql_query, function(entry)
    table.insert(whitelist_ids, entry.id);
  end)

  if next(whitelist_ids) == nil then
    return true;
  end

  -- OPTIMIZE Make sure number contains only valid characters
  local sql_query = 'SELECT `id` FROM `phone_numbers` WHERE \
    `number` = "' .. number .. '" AND \
    `phone_numberable_type` = "Whitelist" AND `phone_numberable_id` IN (' .. table.concat(whitelist_ids, ',') .. ') LIMIT 1';

  local authorized = false
  self.database:query(sql_query, function(entry)
    authorized = true
  end)

  return authorized;
end