[IMP] integrator: new module

integrator/__init__.py

@@ -0,0 +1 @@
+from . import models

integrator/__manifest__.py

@@ -0,0 +1,44 @@
+##############################################################################
+#
+#    Copyright (C) 2015  ADHOC SA  (http://www.adhoc.com.ar)
+#    All Rights Reserved.
+#
+#    This program is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU Affero General Public License as
+#    published by the Free Software Foundation, either version 3 of the
+#    License, or (at your option) any later version.
+#
+#    This program is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU Affero General Public License for more details.
+#
+#    You should have received a copy of the GNU Affero General Public License
+#    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+##############################################################################
+{
+    'name': 'Odoo Integrator',
+    'version': "16.0.1.0.0",
+    'category': 'SaaS',
+    'author': 'ADHOC SA',
+    'website': 'www.adhoc.com.ar',
+    'license': 'AGPL-3',
+    'depends': [
+        'base', 'mail',
+    ],
+    'data': [
+        'data/ir_server_action.xml',
+        'security/integrator_security.xml',
+        'security/ir.model.access.csv',
+        'views/ir_ui_menuitem.xml',
+        'views/integrator_account_views.xml',
+        'views/integrator_integration_views.xml',
+        'views/integrator_integration_script_views.xml',
+    ],
+    'installable': True,
+    'auto_install': False,
+    'application': True,
+    'demo': [
+    ],
+}

integrator/data/ir_server_action.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="utf-8"?>
+<odoo noupdate="1">
+
+    <record id="action_cron_execution_call" model="ir.actions.server">
+        <field name="name">Adelantar ejecución de cron</field>
+        <field name="model_id" ref="integrator.model_integrator_integration"/>
+        <field name="type">ir.actions.server</field>
+        <field name="state">code</field>
+        <field name="code">
+record.cron_id.sudo().write({'nextcall': datetime.datetime.now()})
+        </field>
+    </record>
+
+</odoo>

integrator/models/__init__.py

@@ -0,0 +1,4 @@
+from . import integrator_account
+from . import integrator_integration_script
+from . import integrator_integration
+from . import integrator_integration_script_line

integrator/models/integrator_account.py

@@ -0,0 +1,84 @@
+from odoo import api, models, fields, _
+from odoo.exceptions import UserError
+from odooly import Client
+import logging
+_logger = logging.getLogger(__name__)
+
+
+class IntegratorAccount(models.Model):
+
+    _name = 'integrator.account'
+    _inherit = ['mail.composer.mixin', 'mail.thread', 'mail.activity.mixin']
+    _description = 'Integration Account'
+    _mailing_enabled = True
+
+    name = fields.Char(required=True, tracking=True, store=True, compute='_compute_name', default=lambda self: _('New'))
+    odoo_hostname = fields.Char("Hostname", required=True, tracking=True)
+    odoo_db_name = fields.Char("Database Name", required=True, tracking=True)
+    odoo_user = fields.Char("Username or E-Mail", required=True, tracking=True)
+    odoo_password = fields.Char("Password", required=True,)
+    state = fields.Selection([('draft', 'Draft'), ('confirmed', 'Confirmed')], copy=False, default='draft',
+        required=True, tracking=True)
+    channel_alias = fields.Char('Alias', default=False)
+
+    @api.depends('odoo_db_name')
+    def _compute_name(self):
+        for rec in self:
+            rec.name = rec.odoo_db_name
+
+    def back_to_draft(self):
+        self.write({'state': 'draft'})
+
+    def test_and_confirm(self):
+        self.test_connection()
+        self.write({'state': 'confirmed'})
+
+    def test_connection(self):
+        """ Odoo Connection Test.
+        Returns True if successful.
+        Raises a UserError otherwise.
+        """
+        self.ensure_one()
+        try:
+            # Attempt to get client
+            client = self._odoo_get_client()
+        except Exception as e:
+            raise UserError("Unable to connect to Odoo. "
+                            "The server responded: {}".format(str(e)))
+        # Make sure version is correct
+        self._odoo_ensure_version(client)
+        # Notify Success
+        result = "Connection with Odoo was successful!"
+        return {
+            'type': 'ir.actions.client',
+            'tag': 'display_notification',
+            'params': {
+                'title': _('Success'),
+                'type': 'success',
+                'message': result,
+                'sticky': False,
+            }
+        }
+
+    def _odoo_get_client(self):
+        self.ensure_one()
+        try:
+            return Client(
+                # Use JSONRPC to prevent error when server responds with None
+                self.odoo_hostname.strip("/") + "/jsonrpc",
+                db=self.odoo_db_name,
+                user=self.odoo_user,
+                password=self.odoo_password,
+            )
+        except Exception as e:
+            raise UserError("Unable to Connect to Database. Error: %s" % e)
+
+    def _odoo_ensure_version(self, client):
+        """ Makes sure Odoo version is supported
+        """
+        odoo_version = int(client.server_version.split(".")[0])
+        if odoo_version < 13:
+            raise UserError(
+                "The Odoo version on the remote system is not supported. "
+                "Please upgrade to v13.0 or higher")
+        return True