3e83d8d7d5
Includes: - Odoo 19 framework (odoo/) - 27 custom EnCoach addons (new_project/custom_addons/) - encoach_core, encoach_api, encoach_lms_api, encoach_adaptive_api - encoach_exam, encoach_taxonomy, encoach_adaptive, encoach_assignment - encoach_ai, encoach_ai_grading, encoach_ai_generation, encoach_ai_media - encoach_courseware, encoach_communication, encoach_subscription - encoach_notification, encoach_approval, encoach_branding - encoach_classroom, encoach_registration, encoach_stats - encoach_faq, encoach_ticket, encoach_training, encoach_resources - encoach_adaptive_ai, encoach_sis - 21 OpenEduCat Enterprise modules (new_project/enterprise-19/) - 14 OpenEduCat Community modules (new_project/openeducat_erp-19.0/) - Configuration: odoo.conf, requirements.txt, scripts - 200+ REST API endpoints with JWT authentication - SRS and test documentation Made-with: Cursor
115 lines
4.2 KiB
Python
115 lines
4.2 KiB
Python
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
|
|
|
import logging
|
|
import requests
|
|
from threading import Thread
|
|
import time
|
|
|
|
from odoo.addons.iot_drivers.main import iot_devices, manager
|
|
from odoo.addons.iot_drivers.tools import helpers, upgrade, wifi
|
|
from odoo.addons.iot_drivers.tools.system import IS_RPI, IS_TEST
|
|
|
|
_logger = logging.getLogger(__name__)
|
|
|
|
|
|
class ConnectionManager(Thread):
|
|
|
|
def __init__(self):
|
|
super().__init__(daemon=True)
|
|
self.pairing_code = False
|
|
self.pairing_uuid = False
|
|
self.pairing_code_expired = False
|
|
self.new_database_url = False
|
|
|
|
self.iot_box_registered = False
|
|
self.n_times_polled = -1
|
|
|
|
requests.packages.urllib3.disable_warnings()
|
|
|
|
def _register_iot_box(self):
|
|
""" This method is called to register the IoT Box on odoo.com and get a pairing code"""
|
|
req = self._call_iot_proxy()
|
|
if all(key in req for key in ['pairing_code', 'pairing_uuid']):
|
|
self.pairing_code = req['pairing_code']
|
|
self.pairing_uuid = req['pairing_uuid']
|
|
if IS_RPI:
|
|
self._try_print_pairing_code()
|
|
self.iot_box_registered = True
|
|
|
|
def _get_next_polling_interval(self):
|
|
# To avoid spamming odoo.com with requests we gradually space out the requests
|
|
# e.g If the pairing code is valid for 2 hours this would lead to max 329 requests
|
|
# Starting with 15 seconds and ending with 40s interval, staying under 20s for 50 min
|
|
self.n_times_polled += 1
|
|
return 14 + 1.01 ** self.n_times_polled
|
|
|
|
def run(self):
|
|
# Double loop is needed in case the IoT Box isn't initially connected to the internet
|
|
while True:
|
|
while self._should_poll_to_connect_database():
|
|
if not self.iot_box_registered:
|
|
self._register_iot_box()
|
|
|
|
self._poll_pairing_result()
|
|
time.sleep(self._get_next_polling_interval())
|
|
time.sleep(5)
|
|
|
|
def _should_poll_to_connect_database(self):
|
|
return (
|
|
not helpers.get_odoo_server_url() and
|
|
helpers.get_ip() and
|
|
not (IS_RPI and wifi.is_access_point()) and
|
|
not self.pairing_code_expired
|
|
)
|
|
|
|
def _call_iot_proxy(self):
|
|
data = {
|
|
'params': {
|
|
'pairing_code': self.pairing_code,
|
|
'pairing_uuid': self.pairing_uuid,
|
|
'serial_number': helpers.get_identifier(),
|
|
}
|
|
}
|
|
|
|
try:
|
|
req = requests.post(
|
|
'https://iot-proxy.odoo.com/odoo-enterprise/iot/connect-box',
|
|
json=data,
|
|
timeout=5,
|
|
)
|
|
req.raise_for_status()
|
|
if req.json().get('error') == 'expired':
|
|
self.pairing_code_expired = True
|
|
self.pairing_code = False
|
|
self.pairing_uuid = False
|
|
return req.json().get('result', {})
|
|
except Exception:
|
|
_logger.exception('Could not reach iot-proxy.odoo.com')
|
|
return {}
|
|
|
|
def _poll_pairing_result(self):
|
|
result = self._call_iot_proxy()
|
|
if all(key in result for key in ['url', 'token', 'db_uuid', 'enterprise_code']):
|
|
self._connect_to_server(result['url'], result['token'], result['db_uuid'], result['enterprise_code'])
|
|
|
|
def _connect_to_server(self, url, token, db_uuid, enterprise_code):
|
|
self.new_database_url = url
|
|
# Save DB URL and token
|
|
helpers.save_conf_server(url, token, db_uuid, enterprise_code)
|
|
# Send already detected devices and IoT Box info to the database
|
|
manager._send_all_devices()
|
|
# Switch git branch before restarting, this avoids restarting twice
|
|
upgrade.check_git_branch()
|
|
# Restart to get a certificate, load the IoT handlers...
|
|
helpers.odoo_restart(2)
|
|
|
|
def _try_print_pairing_code(self):
|
|
printers = [device for device in iot_devices.values() if device.device_type == 'printer' and device.connected_by_usb and device.device_subtype in ['receipt_printer', 'label_printer']]
|
|
for printer in printers:
|
|
printer.print_status()
|
|
|
|
|
|
connection_manager = ConnectionManager()
|
|
if not IS_TEST:
|
|
connection_manager.start()
|