Start of GS5.

1 files changed, 114 insertions, 0 deletions

diff --git a/misc/freeswitch/scripts/phones/phone.lua b/misc/freeswitch/scripts/phones/phone.lua
new file mode 100644
index 0000000..5cd210b
--- /dev/null
+++ b/misc/freeswitch/scripts/phones/phone.lua
@@ -0,0 +1,114 @@
+-- Gemeinschaft 5 module: phone class
+-- (c) AMOOMA GmbH 2012
+-- 
+
+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
+
+
+
+-- 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`, \
+  `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.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();
+    elseif account_entry.ieee_name == 'siemens enterprise communicationsgmbh & co. kg' then
+      require 'phones.siemens'
+      phone.model = phones.siemens.Siemens:new();
+    end
+    table.insert(account_phones, phone);
+  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.tenant_id_get(self)
+  local sql_query = 'SELECT `c`.`sip_accountable_id` \
+    FROM `phones` `a` LEFT JOIN `phone_sip_accounts` `b` ON `a`.`id` = `b`.`phone_id` \
+    JOIN `sip_accounts` `c` ON `b`.`sip_account_id` = `c`.`id` AND `sip_accountable_type` = "Tenant" \
+    WHERE `a`.`id` = ' .. tonumber(self.record.id) .. ' LIMIT 1';
+
+  local tenant_id = nil;
+  self.database:query(sql_query, function(tenant_entry)
+    tenant_id = tenant_entry.sip_accountable_id;
+  end)
+
+  return tenant_id;
+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 = self:tenant_id_get();
+
+  if not tenant_id then
+    self.log:info('PHONE_LOGOUT - tenant not found');
+    return false;
+  end
+
+  self:phoneable_set(tenant_id, 'Tenant');
+
+  sql_query = 'DELETE FROM `phone_sip_accounts` WHERE `sip_account_id` = ' .. tonumber(account_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)
+  if not self.model then
+    self.log:notice('PHONE_RESYNC - unsupported phone model');
+    return false;
+  end
+
+  arg.ip_address = arg.ip_address or self.record.ip_address;
+  return self.model:resync(arg);
+end
\ No newline at end of file