mirror of
https://github.com/OCA/server-backend.git
synced 2025-02-18 09:52:42 +02:00
75 lines
2.3 KiB
Python
75 lines
2.3 KiB
Python
# Copyright 2017 LasLabs Inc.
|
|
# License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html).
|
|
|
|
from contextlib import contextmanager
|
|
|
|
from odoo import _, api, fields, models
|
|
from odoo.exceptions import UserError
|
|
|
|
|
|
class ExternalSystemAdapter(models.AbstractModel):
|
|
"""This is the model that should be inherited for new external systems.
|
|
|
|
Methods provided are prefixed with ``external_`` in order to keep from
|
|
"""
|
|
|
|
_name = "external.system.adapter"
|
|
_description = "External System Adapter"
|
|
_inherits = {"external.system": "system_id"}
|
|
|
|
system_id = fields.Many2one(
|
|
string="System",
|
|
comodel_name="external.system",
|
|
required=True,
|
|
ondelete="cascade",
|
|
)
|
|
|
|
@contextmanager
|
|
def client(self):
|
|
"""Client object usable as a context manager to include destruction.
|
|
|
|
Yields the result from ``external_get_client``, then calls
|
|
``external_destroy_client`` to cleanup the client.
|
|
|
|
Yields:
|
|
mixed: An object representing the client connection to the remote
|
|
system.
|
|
"""
|
|
client = self.external_get_client()
|
|
try:
|
|
yield client
|
|
finally:
|
|
self.external_destroy_client(client)
|
|
|
|
def external_get_client(self):
|
|
"""Return a usable client representing the remote system."""
|
|
self.ensure_one()
|
|
|
|
def external_destroy_client(self, client):
|
|
"""Perform any logic necessary to destroy the client connection.
|
|
|
|
Args:
|
|
client (mixed): The client that was returned by
|
|
``external_get_client``.
|
|
"""
|
|
self.ensure_one()
|
|
|
|
def external_test_connection(self):
|
|
"""Adapters should override this method, then call super if valid.
|
|
|
|
If the connection is invalid, adapters should raise an instance of
|
|
``odoo.ValidationError``.
|
|
|
|
Raises:
|
|
odoo.exceptions.UserError: In the event of a good connection.
|
|
"""
|
|
raise UserError(_("The connection was a success."))
|
|
|
|
@api.model
|
|
def create(self, vals):
|
|
context_self = self.with_context(no_create_interface=True)
|
|
vals.update({"system_type": self._name})
|
|
record = super(ExternalSystemAdapter, context_self).create(vals)
|
|
record.system_id.interface = record
|
|
return record
|