mirror of
https://github.com/thingsboard/thingsboard-gateway
synced 2025-10-26 22:31:42 +08:00
64 lines
2.5 KiB
Python
64 lines
2.5 KiB
Python
# Copyright 2022. ThingsBoard
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
from simplejson import dumps
|
|
|
|
from thingsboard_gateway.connectors.connector import log
|
|
|
|
|
|
class BackwardCompatibilityAdapter:
|
|
config_files_count = 1
|
|
CONFIG_PATH = None
|
|
|
|
def __init__(self, config, config_dir):
|
|
self.__config = config
|
|
self.__config_dir = config_dir
|
|
BackwardCompatibilityAdapter.CONFIG_PATH = self.__config_dir
|
|
self.__keys = ['host', 'port', 'type', 'method', 'timeout', 'byteOrder', 'wordOrder', 'retries', 'retryOnEmpty',
|
|
'retryOnInvalid', 'baudrate']
|
|
|
|
@staticmethod
|
|
def __save_json_config_file(config):
|
|
with open(
|
|
f'{BackwardCompatibilityAdapter.CONFIG_PATH}modbus_new_{BackwardCompatibilityAdapter.config_files_count}.json',
|
|
'w') as file:
|
|
file.writelines(dumps(config, sort_keys=False, indent=' ', separators=(',', ': ')))
|
|
BackwardCompatibilityAdapter.config_files_count += 1
|
|
|
|
def convert(self):
|
|
if not self.__config.get('server'):
|
|
return self.__config
|
|
|
|
log.warning(
|
|
'You are using old configuration structure for Modbus connector. It will be DEPRECATED in the future '
|
|
'version! New config file "modbus_new.json" was generated in %s folder. Please, use it.', self.CONFIG_PATH)
|
|
log.warning('You have to manually connect the new generated config file to tb_gateway.yaml!')
|
|
|
|
slaves = []
|
|
for device in self.__config['server'].get('devices', []):
|
|
slave = {**device}
|
|
|
|
for key in self.__keys:
|
|
if not device.get(key):
|
|
slave[key] = self.__config['server'].get(key)
|
|
|
|
slave['pollPeriod'] = slave['timeseriesPollPeriod']
|
|
|
|
slaves.append(slave)
|
|
|
|
result_dict = {'master': {'slaves': slaves}, 'slave': self.__config.get('slave')}
|
|
self.__save_json_config_file(result_dict)
|
|
|
|
return result_dict
|