Add. BLF indication for call forward. (#2664)

* Add. BLF indication for call forward.

To display general status of CallForward use blf like `forward+<extension>`
To display status for specific phone number use blf like `forward+<extension>/<number>`

* Fix. Escape variable in regex expression.

* Fix. Sync DND and CF blf.

* Add. `blf_subscribe` service which can handle all custom subscriptions.

To run for specific protocol it possible run as `luarun blf_subscribe.lua <PROTO>`

resources/install/scripts/blf_subscribe.lua

@@ -0,0 +1,174 @@
+local proto = argv[1] or 'all'
+
+local service_name
+if proto == 'all' then
+	service_name = 'blf'
+else
+	service_name = proto
+end
+
+require "resources.functions.config"
+require "resources.functions.split"
+
+local log = require "resources.functions.log"[service_name]
+local presence_in = require "resources.functions.presence_in"
+local Database = require "resources.functions.database"
+local BasicEventService = require "resources.functions.basic_event_service"
+
+local find_call_flow do
+
+local find_call_flow_sql = [[select t1.call_flow_uuid, t1.call_flow_status
+from v_call_flows t1 inner join v_domains t2 on t1.domain_uuid = t2.domain_uuid
+where t2.domain_name = :domain_name and (t1.call_flow_feature_code = :feature_code
+or t1.call_flow_feature_code = :short_feature_code)
+]]
+
+function find_call_flow(user)
+	local ext, domain_name = split_first(user, '@', true)
+	local _, short = split_first(ext, '+', true)
+	if not domain_name then return end
+	local dbh = Database.new('system')
+	if not dbh then return end
+	local row = dbh:first_row(find_call_flow_sql, {
+		domain_name = domain_name, feature_code = ext, short_feature_code = short
+	})
+	dbh:release()
+	if not row then return end
+	return row.call_flow_uuid, row.call_flow_status
+end
+
+end
+
+local find_dnd do
+
+local find_dnd_sql = [[select t1.do_not_disturb
+from v_extensions t1 inner join v_domains t2 on t1.domain_uuid = t2.domain_uuid
+where t2.domain_name = :domain_name and (t1.extension = :extension or t1.number_alias=:extension)]]
+
+find_dnd = function(user)
+	local ext, domain_name = split_first(user, '@', true)
+	if not domain_name then return end
+	local dbh = Database.new('system')
+	if not dbh then return end
+	local dnd = dbh:first_value(find_dnd_sql, {domain_name = domain_name, extension = ext})
+	dbh:release()
+	return dnd
+end
+
+end
+
+local find_call_forward do
+
+local find_call_forward_sql = [[select t1.forward_all_destination, t1.forward_all_enabled
+from v_extensions t1 inner join v_domains t2 on t1.domain_uuid = t2.domain_uuid
+where t2.domain_name = :domain_name and (t1.extension = :extension or t1.number_alias=:extension)]]
+
+find_call_forward = function(user)
+	local ext, domain_name, number = split_first(user, '@', true)
+	if not domain_name then return end
+	ext, number = split_first(ext, '/', true)
+	local dbh = Database.new('system')
+	if not dbh then return end
+	local row = dbh:first_row(find_call_forward_sql, {domain_name = domain_name, extension = ext})
+	dbh:release()
+	if not (row and row.forward_all_enabled) then return end
+	if row.forward_all_enabled ~= 'true' then return 'false' end
+	if number then
+		return number == row.forward_all_destination and 'true' or 'false',
+			row.forward_all_destination
+	end
+	return 'true', row.forward_all_destination
+end
+
+end
+
+local protocols = {}
+
+protocols.flow = function(event)
+	local from, to = event:getHeader('from'), event:getHeader('to')
+	local expires = tonumber(event:getHeader('expires'))
+	if expires and expires > 0 then
+		local call_flow_uuid, call_flow_status = find_call_flow(to)
+		if call_flow_uuid then
+			log.noticef("Find call flow: %s staus: %s", to, tostring(call_flow_status))
+			presence_in.turn_lamp(call_flow_status == "false", to, call_flow_uuid)
+		else
+			log.warningf("Can not find call flow: %s", to)
+		end
+	else
+		log.noticef("%s UNSUBSCRIBE from %s", from, to)
+	end
+end
+
+protocols.dnd = function(event)
+	local from, to = event:getHeader('from'), event:getHeader('to')
+	local expires = tonumber(event:getHeader('expires'))
+	if expires and expires > 0 then
+		local proto, user = split_first(to, '+', true)
+		user = user or proto
+		local dnd_status = find_dnd(user)
+		if dnd_status then
+			log.noticef("Find DND: %s staus: %s", to, tostring(dnd_status))
+			presence_in.turn_lamp(dnd_status == "true", to)
+		else
+			log.warningf("Can not find DND: %s", to)
+		end
+	else
+		log.noticef("%s UNSUBSCRIBE from %s", from, to)
+	end
+end
+
+protocols.forward = function(event)
+	local from, to = event:getHeader('from'), event:getHeader('to')
+	local expires = tonumber(event:getHeader('expires'))
+	if expires and expires > 0 then
+		local proto, user = split_first(to, '+', true)
+		user = user or proto
+		local status, number = find_call_forward(user)
+		if status then
+			if status == 'true' then
+				log.noticef("CF: %s to number %s", to, tostring(number))
+			else
+				log.noticef("CF: %s disabled", to)
+			end
+			presence_in.turn_lamp(status == "true", to)
+		else
+			log.warningf("Can not find CF: %s", to)
+		end
+	else
+		log.noticef("%s UNSUBSCRIBE from %s", from, to)
+	end
+end
+
+if proto ~= 'all' then
+	for name in pairs(protocols) do
+		if proto ~= name then
+			protocols[name] = nil
+		end
+	end
+end
+
+if not next(protocols) then
+	log.errorf('Unknown subscribe protocol: %s', proto)
+	return
+end
+
+for name in pairs(protocols) do
+	log.noticef('add subscribe protocol: %s', name)
+end
+
+local service = BasicEventService.new(log, service_name)
+
+-- FS receive SUBSCRIBE to BLF from device
+service:bind("PRESENCE_PROBE", function(self, name, event)
+	local proto = event:getHeader('proto')
+	local handler = proto and protocols[proto]
+	if not handler then return end
+	return handler(event)
+end)
+
+log.notice("start")
+
+service:run()
+
+log.notice("stop")