summaryrefslogtreecommitdiff
path: root/misc/freeswitch/scripts/phones/phone.lua
blob: a256b12fd3cda6e01576a65cd5215dd9462e58a2 (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
149
150
151
-- Gemeinschaft 5 module: phone class
-- (c) AMOOMA GmbH 2012-2013
-- 

module(...,package.seeall)

Phone = {}

-- create phone object
function Phone.new(self, arg)
  arg = arg or {}
  object = arg.object or {}
  setmetatable(object, self);
  self.__index = self;
  self.log = arg.log;
  self.database = arg.database;
  return object;
end


function Phone.list_by_sql(self, sql_query)
  local account_phones = {};

  self.database:query(sql_query, function(account_entry)
    local phone = Phone:new(self, {object = parent_class});
    phone.record = account_entry;
    phone.record.ieee_name = common.str.downcase(account_entry.ieee_name);

    if phone.record.ieee_name == 'snom technology ag' then
      require 'phones.snom'
      phone.model = phones.snom.Snom:new{ log = self.log };
    elseif account_entry.ieee_name == 'siemens enterprise communicationsgmbh & co. kg' then
      require 'phones.siemens'
      phone.model = phones.siemens.Siemens:new{ log = self.log };
    end
    table.insert(account_phones, phone);
  end)

  return account_phones;
end

-- Find a hot-deskable phone by sip-account
function Phone.find_all_hot_deskable_by_account(self, account_id)
  require 'common.str'

  local sql_query = 'SELECT \
  `b`.`id`, `b`.`mac_address`, `b`.`ip_address`, `b`.`http_user`, `b`.`http_password`, `b`.`phoneable_type`, `b`.`phoneable_id`, \
  `b`.`tenant_id`, `b`.`fallback_sip_account_id`, `d`.`ieee_name` \
  FROM `phone_sip_accounts` `a` \
  JOIN `phones` `b` ON `a`.`phone_id` = `b`.`id` \
  JOIN `phone_models` `c` ON `b`.`phone_model_id` = `c`.`id` \
  JOIN `manufacturers` `d` ON `c`.`manufacturer_id` = `d`.`id` \
  WHERE `b`.`hot_deskable` IS TRUE \
  AND `c`.`state` = "active" \
  AND `d`.`state` = "active" \
  AND `a`.`sip_account_id` = ' .. tonumber(account_id);

  local account_phones = self:list_by_sql(sql_query);

  if #account_phones == 0 then
    sql_query = 'SELECT `b`.`id`, `b`.`mac_address`, `b`.`ip_address`, `b`.`http_user`, `b`.`http_password`, `b`.`phoneable_type`, `b`.`phoneable_id`, \
    `b`.`tenant_id`, `b`.`fallback_sip_account_id`, `d`.`ieee_name` \
    FROM `phones` `b` \
    JOIN `phone_models` `c` ON `b`.`phone_model_id` = `c`.`id` \
    JOIN `manufacturers` `d` ON `c`.`manufacturer_id` = `d`.`id` \
    WHERE `b`.`hot_deskable` IS TRUE \
    AND `c`.`state` = "active" \
    AND `d`.`state` = "active" \
    AND `b`.`fallback_sip_account_id` = ' .. tonumber(account_id);

    account_phones = self:list_by_sql(sql_query);
  end

  return account_phones;
end


function Phone.find_hot_deskable_by_account(self, account_id)
  return self:find_all_hot_deskable_by_account(account_id)[1];
end


function Phone.phoneable_set(self, phoneable_id, phoneable_type)
  sql_query = 'UPDATE `phones` SET `phoneable_type` = "' .. phoneable_type ..'", `phoneable_id` = ' .. phoneable_id .. ' \
    WHERE `id` = ' .. tonumber(self.record.id);
  self.database:query(sql_query);
end

function Phone.logout(self, account_id)
  local tenant_id = tonumber(self.record.tenant_id);

  if not tenant_id then
    self.log:info('PHONE_LOGOUT - tenant not found');
    return false;
  end

  self:phoneable_set(tenant_id, 'Tenant');

  if account_id then
    sql_query = 'DELETE FROM `phone_sip_accounts` WHERE `sip_account_id` = ' .. tonumber(account_id);
    self.database:query(sql_query);
  end

  sql_query = 'DELETE FROM `phone_sip_accounts` WHERE `phone_id` = ' .. self.record.id;
  return self.database:query(sql_query);
end

function Phone.login(self, account_id, owner_id, owner_type)
  self:phoneable_set(owner_id, owner_type);
  sql_query = 'INSERT INTO `phone_sip_accounts` (`phone_id`, `sip_account_id`, `position`, `created_at`, `updated_at`) \
      VALUES ('.. tonumber(self.record.id) .. ', '.. tonumber(account_id) .. ', 1,  NOW(),  NOW())';

  return self.database:query(sql_query);
end

function Phone.resync(self, arg)
  local result = nil;
  arg.ip_address = arg.ip_address or self.record.ip_address;
  arg.http_user = arg.http_user or self.record.http_user;
  arg.http_password = arg.http_password or self.record.http_password;
  
  if self.model then
    result = self.model:resync(arg);
  else
    self.log:notice('PHONE_RESYNC phone model not found - trying Snom resync');
    require 'phones.snom';
    result = phones.snom.Snom:new{ log = self.log }:resync(arg);
  end

  self:resync_extension_modules(arg);

  return result;
end


function Phone.resync_extension_modules(self, arg)
  require('common.object');
  local object_class = common.object.Object:new{ log = self.log };
 
  local sql_query = 'SELECT * FROM `extension_modules` WHERE `active` IS TRUE AND `phone_id` = ' .. common.str.to_i(self.record.id);
  self.database:query(sql_query, function(extension_module)
    local extension_module_class, error_message = object_class:load_one('phones.' .. extension_module.model);
    if not extension_module_class then
      self.log:error('RESYNC_EXTENSION_MODULE - unsupported model: ', extension_module.model, ', error: ', error_message);
    end

    arg.ip_address = extension_module.ip_address;
    local result = extension_module_class:new{log = self.log}:resync(arg);
    self.log:debug('RESYNC_EXTENSION_MODULE - ', extension_module_class.class, '=', extension_module.id, ', mac_address: ', extension_module.mac_address, ', ip_address: ', extension_module.ip_address, ', executed: ', tostring(result));
  end);
end