11 Commits

17 changed files with 443 additions and 103 deletions

View File

@@ -1,4 +1,6 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from . import controllers from . import controllers
from . import models from . import models
from . import wizard
from .hooks import post_init_hook

View File

@@ -11,12 +11,16 @@
'author': "Open2bizz", 'author': "Open2bizz",
'website': "http://www.open2bizz.tech", 'website': "http://www.open2bizz.tech",
'category': 'Uncategorized', 'category': 'Tools',
'version': '18.0.1.0.0', 'license': "AGPL-3",
'version': '19.0.1.0.0',
'module_type': 'official', 'module_type': 'official',
'depends': ['mail','base',], 'depends': ['mail','base',],
'data': [ 'data': [
'wizard/install_warning_wizard_view.xml',
'views/views.xml', 'views/views.xml',
'data/data.xml' 'data/data.xml',
'security/ir.model.access.csv',
], ],
'post_init_hook': 'post_init_hook',
} }

View File

@@ -1,21 +1,55 @@
# -*- coding: utf-8 -*- # Copyright 2024 Open2Bizz <info@open2bizz.nl>
# from odoo import http # License LGPL-3
import logging
import requests
from odoo import http
from odoo.http import request, Response
_logger = logging.getLogger(__name__)
MAILHOG_BASE = "http://localhost:8025"
# class TestserverO2b(http.Controller): class MailcatcherProxy(http.Controller):
# @http.route('/testserver_o2b/testserver_o2b/', auth='public')
# def index(self, **kw):
# return "Hello, world"
# @http.route('/testserver_o2b/testserver_o2b/objects/', auth='public') @http.route(['/mailcatcher', '/mailcatcher/<path:subpath>'],
# def list(self, **kw): type='http', auth='user', website=False, csrf=False)
# return http.request.render('testserver_o2b.listing', { def mailcatcher_proxy(self, subpath='', **kw):
# 'root': '/testserver_o2b/testserver_o2b', """Proxy requests to the local MailHog instance."""
# 'objects': http.request.env['testserver_o2b.testserver_o2b'].search([]), target_url = f"{MAILHOG_BASE}/{subpath}"
# }) if request.httprequest.query_string:
target_url += '?' + request.httprequest.query_string.decode('utf-8')
# @http.route('/testserver_o2b/testserver_o2b/objects/<model("testserver_o2b.testserver_o2b"):obj>/', auth='public') try:
# def object(self, obj, **kw): headers = {
# return http.request.render('testserver_o2b.object', { k: v for k, v in request.httprequest.headers
# 'object': obj if k.lower() not in ('host', 'cookie', 'authorization')
# }) }
resp = requests.request(
method=request.httprequest.method,
url=target_url,
headers=headers,
data=request.httprequest.get_data(),
timeout=30,
allow_redirects=False,
)
except requests.exceptions.ConnectionError:
_logger.warning("Could not connect to MailHog at %s", MAILHOG_BASE)
return Response("MailHog is not available", status=502)
excluded_headers = {
'content-encoding', 'content-length', 'transfer-encoding',
'connection',
}
response_headers = [
(k, v) for k, v in resp.headers.items()
if k.lower() not in excluded_headers
]
return Response(
resp.content,
status=resp.status_code,
headers=response_headers,
)

View File

@@ -1,5 +1,4 @@
<odoo> <odoo>
<data> <data>
<function model="ir.config_parameter" name="_mailcatcher_url"/>
</data> </data>
</odoo> </odoo>

40
mailcatcher_menu/hooks.py Normal file
View File

@@ -0,0 +1,40 @@
# Copyright 2024 Open2Bizz <info@open2bizz.nl>
# License LGPL-3
import logging
import os
import subprocess
_logger = logging.getLogger(__name__)
def post_init_hook(env):
"""Install MailHog as a systemd service when the module is installed."""
script_path = os.path.join(
os.path.dirname(os.path.abspath(__file__)),
'install_mailhog_as_service.sh',
)
if not os.path.isfile(script_path):
_logger.error("MailHog install script not found at %s", script_path)
return
_logger.info("Running MailHog install script: %s", script_path)
try:
result = subprocess.run(
['bash', script_path],
capture_output=True,
text=True,
timeout=300,
)
if result.returncode == 0:
_logger.info("MailHog installed successfully.\n%s", result.stdout)
else:
_logger.error(
"MailHog install script failed (exit %s):\n%s\n%s",
result.returncode, result.stdout, result.stderr,
)
except subprocess.TimeoutExpired:
_logger.error("MailHog install script timed out after 300 seconds")
except Exception as e:
_logger.error("Failed to run MailHog install script: %s", e)

View File

@@ -0,0 +1,86 @@
#!/bin/bash
set -e # stop bij fouten
echo ""
echo "==================================="
echo "Update apt..."
echo "==================================="
apt update
echo ""
echo "==================================="
echo "Install dependencies..."
echo "==================================="
apt-get -y install wget tar
echo ""
echo "==================================="
echo "Install Go 1.24.3..."
echo "==================================="
GO_VERSION=1.24.3
wget https://go.dev/dl/go${GO_VERSION}.linux-amd64.tar.gz
sudo rm -rf /usr/local/go
sudo tar -C /usr/local -xzf go${GO_VERSION}.linux-amd64.tar.gz
# Go environment correct instellen
export GOROOT=/usr/local/go
export GOPATH=$HOME/go
export PATH=$GOROOT/bin:$GOPATH/bin:$PATH
echo "Go version:"
go version
echo ""
echo "==================================="
echo "Installing MailHog..."
echo "==================================="
/usr/local/go/bin/go install github.com/mailhog/MailHog@latest
if [ -f "$HOME/go/bin/MailHog" ]; then
echo "MailHog installed successfully"
else
echo "ERROR: MailHog binary not found!"
exit 1
fi
echo ""
echo "==================================="
echo "Copy MailHog to /usr/local/bin..."
echo "==================================="
sudo cp "$HOME/go/bin/MailHog" /usr/local/bin/MailHog
echo ""
echo "==================================="
echo "Create MailHog service..."
echo "==================================="
sudo tee /etc/systemd/system/mailhog.service > /dev/null <<EOL
[Unit]
Description=MailHog
After=network.target
[Service]
User=root
ExecStart=/usr/local/bin/MailHog
Restart=always
Environment="PATH=/usr/local/go/bin:/usr/bin:/bin"
[Install]
WantedBy=multi-user.target
EOL
echo ""
echo "==================================="
echo "Enable + start MailHog service..."
echo "==================================="
systemctl daemon-reload
systemctl enable mailhog
systemctl start mailhog
echo ""
echo "==================================="
echo "MailHog is running!"
echo "Web UI: http://localhost:8025"
echo "SMTP: localhost:1025"
echo "==================================="

View File

@@ -1,3 +1,3 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from . import mailcatcher_menu # No models needed — MailHog is accessed via the proxy controller

View File

@@ -1,27 +1,7 @@
# Copyright 2024 Open2Bizz <info@open2bizz.nl> # Copyright 2024 Open2Bizz <info@open2bizz.nl>
# License LGPL-3 # License LGPL-3
from odoo import api, fields, models, _ # MailHog is now accessed via the internal proxy controller at /mailcatcher/
# so no dynamic URL computation is needed anymore.
import logging
_logger = logging.getLogger(__name__)
class IrActionUrl(models.Model):
_inherit = "ir.config_parameter"
@api.model
#def init(self):
def _mailcatcher_url(self):
parameters = self.env['ir.config_parameter'].search([('key','=', 'web.base.url')])
if parameters:
parameter = parameters[0]
cont_nr = parameter.value.split("//",1)[1] #Haal https:// van string
cont_nr = cont_nr[0:3] #De eerste 3 karakters is het containernummer
act_url = "https://" + cont_nr + "-mailcatcher.staging.open2bizz.com"
_logger.info('---------- ACT_URL ---------- %s', act_url)
action_id = self.env['ir.model.data']._xmlid_to_res_id('mailcatcher_menu.action_mailcatcher_url')
action = self.env['ir.actions.act_url'].browse(action_id)
if action:
action.write({'url':act_url})

View File

@@ -1,2 +1,2 @@
"id","name","model_id:id","group_id:id","perm_read","perm_write","perm_create","perm_unlink" "id","name","model_id:id","group_id:id","perm_read","perm_write","perm_create","perm_unlink"
"access_mailcatcher_menu_mailcatcher_menu","mailcatcher_menu.mailcatcher_menu","model_mailcatcher_menu_mailcatcher_menu","base.group_user",1,1,1,1 "access_mailcatcher_install_warning_wizard","mailcatcher.install.warning.wizard","model_mailcatcher_install_warning_wizard","base.group_user",1,1,1,1
1 id name model_id:id group_id:id perm_read perm_write perm_create perm_unlink
2 access_mailcatcher_menu_mailcatcher_menu access_mailcatcher_install_warning_wizard mailcatcher_menu.mailcatcher_menu mailcatcher.install.warning.wizard model_mailcatcher_menu_mailcatcher_menu model_mailcatcher_install_warning_wizard base.group_user 1 1 1 1

View File

@@ -3,7 +3,7 @@
<record model="ir.actions.act_url" id="action_mailcatcher_url"> <record model="ir.actions.act_url" id="action_mailcatcher_url">
<field name="name">Open Mailcatcher</field> <field name="name">Open Mailcatcher</field>
<field name="url">https://mailcatcher.staging.open2bizz.com</field> <field name="url">/mailcatcher/</field>
<field name="target">new</field> <field name="target">new</field>
</record> </record>

View File

@@ -0,0 +1,3 @@
# -*- coding: utf-8 -*-
from . import install_warning_wizard

View File

@@ -0,0 +1,43 @@
# Copyright 2024 Open2Bizz <info@open2bizz.nl>
# License LGPL-3
from odoo import models, fields, api, _
class MailcatcherInstallWarningWizard(models.TransientModel):
_name = 'mailcatcher.install.warning.wizard'
_description = 'MailCatcher Install Warning'
module_id = fields.Many2one('ir.module.module', string='Module', readonly=True)
def action_confirm_install(self):
"""User confirmed — proceed with the actual module installation."""
self.ensure_one()
return self.module_id.with_context(
skip_mailcatcher_warning=True
).button_immediate_install()
class IrModuleModule(models.Model):
_inherit = 'ir.module.module'
def button_immediate_install(self):
"""Override to show a warning before installing mailcatcher_menu."""
if self.env.context.get('skip_mailcatcher_warning'):
return super().button_immediate_install()
mailcatcher_modules = self.filtered(lambda m: m.name == 'mailcatcher_menu')
if mailcatcher_modules:
wizard = self.env['mailcatcher.install.warning.wizard'].create({
'module_id': mailcatcher_modules[0].id,
})
return {
'name': _('Install MailCatcher Module'),
'type': 'ir.actions.act_window',
'res_model': 'mailcatcher.install.warning.wizard',
'res_id': wizard.id,
'view_mode': 'form',
'target': 'new',
}
return super().button_immediate_install()

View File

@@ -0,0 +1,28 @@
<odoo>
<record id="view_mailcatcher_install_warning_wizard" model="ir.ui.view">
<field name="name">mailcatcher.install.warning.wizard.form</field>
<field name="model">mailcatcher.install.warning.wizard</field>
<field name="arch" type="xml">
<form string="Install MailCatcher">
<div class="alert alert-warning" role="alert">
<h4 class="alert-heading">Warning</h4>
<p>
You are about to install the <strong>MailCatcher</strong> module.
</p>
<p>
This will also install <strong>MailHog</strong> as a systemd service on this server.
MailHog will listen on port <strong>8025</strong> (Web UI) and port <strong>1025</strong> (SMTP).
</p>
<p>
Do you want to proceed with the installation?
</p>
</div>
<footer>
<button name="action_confirm_install" type="object"
string="Confirm Install" class="btn-primary"/>
<button string="Cancel" class="btn-secondary" special="cancel"/>
</footer>
</form>
</field>
</record>
</odoo>

View File

@@ -8,10 +8,12 @@
'author': "Open2bizz", 'author': "Open2bizz",
'website': "http://www.open2bizz.tech", 'website': "http://www.open2bizz.tech",
'category': 'Uncategorized', 'category': 'Tools',
'version': '18.0.1.0.0', 'license': "AGPL-3",
'version': '19.0.1.0.0',
'depends': ['mail','base','mailcatcher_menu',], 'depends': ['mail','base','mailcatcher_menu',],
'data': [ 'data': [
'views/templates.xml', 'views/templates.xml',
'data/ir_cron.xml',
], ],
} }

View File

@@ -0,0 +1,10 @@
<?xml version="1.0" encoding="utf-8"?>
<odoo>
<record id="ir_cron_set_db_parameter" model="ir.cron">
<field name="name">Testserver: Set Date (ONLY FOR TEST ENV.)</field>
<field name="model_id" ref="base.model_ir_logging"/>
<field name="state">code</field>
<field name="code">model.set_db_param()</field>
<field name="interval_type">days</field>
</record>
</odoo>

View File

@@ -1,66 +1,174 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from odoo import tools from odoo import tools
from odoo import api, fields, models from odoo import api, fields, models
from collections.abc import Mapping from datetime import datetime, timedelta
import logging
_logger = logging.getLogger(__name__)
import os import os
import uuid import uuid
import odoo import odoo
import logging
_logger = logging.getLogger(__name__)
class IrLogging(models.Model): class IrLogging(models.Model):
_inherit = 'ir.logging' _inherit = 'ir.logging'
MAIL_SERVERS = (
('127.0.0.1', '1025', 'Lokale mailcatcher', 'login', 'name', 't'),
('192.168.78.199', '1025', 'Algemene mailcatcher', 'login', 'name', 'f'),
('hnode6.openworx.nl', '1025', 'Algemene mailcatcher vanaf hnode4', 'login', 'name', 'f'),
)
EXPECTED_IP_PREFIX = '192.168.78.'
REPORT_URL = 'http://127.0.0.1:8069'
ENTERPRISE_CODE = 'M160129258730'
def init(self): def init(self):
db_id = uuid.uuid1() database_uuid = str(uuid.uuid1())
_logger.error(db_id) _logger.debug(f"____ Database UID: {database_uuid}")
self._reset_base_configuration(database_uuid)
_logger.debug(f"_____ reset_base_configuration ____")
self._remove_param_if_exists('web.base.url.freeze')
_logger.debug(f"______ remove_param_if_exists web.base.url.freeze ____")
self._create_param_if_missing('report.url', self.REPORT_URL)
_logger.debug(f"_______ create_param_if_missing report.url ____")
self._disable_web_push_notifications()
_logger.debug(f"_______ disable_web_push_notifications ____")
self._disable_delivery_carrier_prod_environment()
_logger.debug(f"_______ disable_delivery_carrier_prod_environment ____")
self._disable_payment_providers()
_logger.debug(f"_______ disable_delivery_carrier_prod_environment ____")
self._clear_account_online_links()
_logger.debug(f"_______ _disable_payment_providers ____")
self._reset_bank_statement_source()
_logger.debug(f"_______ _reset_bank_statement_source ____")
self._set_warning_ribbon_if_ip_is_invalid()
_logger.debug(f"_______ _set_warning_ribbon_if_ip_is_invalid ____")
self._run_testserver_script()
_logger.debug(f"_______ _run_testserver_script ____")
def _reset_base_configuration(self, database_uuid):
self.env.cr.execute(""" self.env.cr.execute("""
UPDATE ir_mail_server set active = 'f'; UPDATE ir_mail_server SET active = 'f';
UPDATE fetchmail_server set active = 'f'; UPDATE fetchmail_server SET active = 'f';
UPDATE ir_cron set active = 'f'; UPDATE ir_cron SET active = 'f';
DELETE FROM mail_mail; DELETE FROM mail_mail;
UPDATE ir_config_parameter set value = 'M160129258730' where key = 'database.enterprise_code'; UPDATE ir_config_parameter
UPDATE ir_config_parameter set value = (NOW() + INTERVAL '30 DAY') where key = 'database.expiration_date'; SET value = %s
UPDATE ir_config_parameter set value = '%s' where key = 'database.uuid'; WHERE key = 'database.enterprise_code';
INSERT INTO ir_mail_server(smtp_host,smtp_port,name,smtp_authentication,smtp_encryption,active) VALUES ('127.0.0.1','1025','Lokale mailcatcher','login','name','t'); UPDATE ir_config_parameter
INSERT INTO ir_mail_server(smtp_host,smtp_port,name,smtp_authentication,smtp_encryption,active) VALUES ('192.168.78.199','1025','Algemene mailcatcher','login','name','t'); SET value = (NOW() + INTERVAL '30 DAY')
INSERT INTO ir_mail_server(smtp_host,smtp_port,name,smtp_authentication,smtp_encryption,active) VALUES ('hnode6.openworx.nl','1025','Algemene mailcatcher vanaf hnode4','login','name','t'); WHERE key = 'database.expiration_date';
""" %(db_id)) UPDATE ir_config_parameter
if self.env['ir.config_parameter'].search([('key','=','web.base.url.freeze')]): SET value = %s
self.env.cr.execute("""DELETE FROM ir_config_parameter WHERE key = 'web.base.url.freeze';""") WHERE key = 'database.uuid';
if not self.env['ir.config_parameter'].search([('key','=','report.url')]): """, (self.ENTERPRISE_CODE, database_uuid))
self.env.cr.execute("""INSERT INTO ir_config_parameter(key,value) VALUES ('report.url','http://127.0.0.1:8069');""")
model = self.env['ir.model'].search([('model','=','delivery.carrier')]) for mail_server in self.MAIL_SERVERS:
if model:
field = self.env['ir.model.fields'].search([('name','=','prod_environment'),('model_id','=',model.id)])
if field:
self.env.cr.execute("""UPDATE delivery_carrier SET prod_environment = False WHERE id>0;""")
model = self.env['ir.model'].search([('model','=','payment.provider')])
if model:
field = self.env['ir.model.fields'].search([('name','=','state'),('model_id','=',model.id)])
if field:
self.env.cr.execute("""UPDATE payment_provider SET state = 'disabled' WHERE id>0;""")
model = self.env['ir.model'].search([('model','=','account.online.link')])
if model:
field = self.env['ir.model.fields'].search([('id','>',0),('model_id','=',model.id)])
if field:
self.env.cr.execute("""DELETE FROM account_online_link WHERE id > 0;""")
if self.env['ir.model'].search([('model','=','account.journal')]):
self.env.cr.execute("""UPDATE account_journal set bank_statements_source = 'undefined';""")
ip_ok = False
with os.popen("ip a") as f:
for x in f.readlines():
if float(x.find('192.168.78.')) > -1:
ip_ok = True
if not ip_ok:
self.env.cr.execute(""" self.env.cr.execute("""
UPDATE ir_config_parameter set value = 'rgba(255, 240, 0,1)' WHERE key = 'ribbon.background.color'; INSERT INTO ir_mail_server(
UPDATE ir_config_parameter set value = '#000000' WHERE key = 'ribbon.color'; smtp_host, smtp_port, name, smtp_authentication, smtp_encryption, active
UPDATE ir_config_parameter set value = '!!! IP WRONG !!!' WHERE key = 'ribbon.name'; ) VALUES (%s, %s, %s, %s, %s, %s);
""") """, mail_server)
ADDONS_PATH = odoo.tools.config['addons_path']
_logger.error(ADDONS_PATH) def _remove_param_if_exists(self, key):
for ap in ADDONS_PATH.split(','): if self.env['ir.config_parameter'].search([('key', '=', key)], limit=1):
if ap[-10:] == 'testserver': self.env.cr.execute("DELETE FROM ir_config_parameter WHERE key = %s;", (key,))
_logger.error(os.system('./%s/testserver.sh' %(ap)))
def _create_param_if_missing(self, key, value):
if not self.env['ir.config_parameter'].search([('key', '=', key)], limit=1):
self.env.cr.execute(
"INSERT INTO ir_config_parameter(key, value) VALUES (%s, %s);",
(key, value),
)
def _disable_web_push_notifications(self):
parameter = self.env['ir.config_parameter'].sudo()
parameter.set_param('web_push.notification.enabled', '0')
parameters = self.env['ir.config_parameter'].sudo().search([
('key', 'in', ('mail.web_push_vapid_private_key', 'mail.web_push_vapid_public_key', 'mail.sfu_server_key'))])
for parameter in parameters:
parameter.sudo().unlink()
if self.env['ir.model'].search([('model','=','mail.partner.device')]):
self.env.cr.execute("""DELETE FROM mail_partner_device;""")
def _model_has_field(self, model_name, field_name=None):
model = self.env['ir.model'].search([('model', '=', model_name)], limit=1)
if not model:
return False
if field_name is None:
return True
return bool(
self.env['ir.model.fields'].search(
[('name', '=', field_name), ('model_id', '=', model.id)],
limit=1,
)
)
def _disable_delivery_carrier_prod_environment(self):
if self._model_has_field('delivery.carrier', 'prod_environment'):
self.env.cr.execute(
"UPDATE delivery_carrier SET prod_environment = False WHERE id > 0;"
)
def _disable_payment_providers(self):
if self._model_has_field('payment.provider', 'state'):
self.env.cr.execute(
"UPDATE payment_provider SET state = 'disabled' WHERE id > 0;"
)
def _clear_account_online_links(self):
model = self.env['ir.model'].search([('model', '=', 'account.online.link')], limit=1)
if not model:
return
has_any_field = self.env['ir.model.fields'].search(
[('id', '>', 0), ('model_id', '=', model.id)],
limit=1,
)
if has_any_field:
self.env.cr.execute("DELETE FROM account_online_link WHERE id > 0;")
def _reset_bank_statement_source(self):
if self.env['ir.model'].search([('model', '=', 'account.journal')], limit=1):
self.env.cr.execute(
"UPDATE account_journal SET bank_statements_source = 'undefined';"
)
def _has_expected_ip(self):
with os.popen("ip a") as command_output:
return any(self.EXPECTED_IP_PREFIX in line for line in command_output.readlines())
def _set_warning_ribbon_if_ip_is_invalid(self):
if self._has_expected_ip():
return
self.env.cr.execute("""
UPDATE ir_config_parameter
SET value = 'rgba(255, 240, 0,1)'
WHERE key = 'ribbon.background.color';
UPDATE ir_config_parameter
SET value = '#000000'
WHERE key = 'ribbon.color';
UPDATE ir_config_parameter
SET value = '!!! IP WRONG !!!'
WHERE key = 'ribbon.name';
""")
def _run_testserver_script(self):
addons_path = odoo.tools.config['addons_path']
_logger.error(addons_path)
addons_list = addons_path.split(',') if isinstance(addons_path, str) else list(addons_path)
for addon_path in addons_list:
if addon_path.endswith('testserver'):
_logger.error(os.system(f'./{addon_path}/testserver.sh'))
def set_db_param(self):
## Script to set database expiration date, when enterprise and test env.
parameter = self.env['ir.config_parameter'].search(
[('key', '=', 'database.expiration_date')],
limit=1,
)
if parameter:
new_date_time = datetime.now() + timedelta(days=30)
parameter.write({'value': str(new_date_time)[:19]})

View File

@@ -8,8 +8,9 @@
'author': "Open2bizz", 'author': "Open2bizz",
'website': "http://www.open2bizz.tech", 'website': "http://www.open2bizz.tech",
'category': 'Uncategorized', 'category': 'Tools',
'version': '18.0.1.0.0', 'license': "AGPL-3",
'version': '19.0.1.0.0',
'depends': ['testserver_o2b','website'], 'depends': ['testserver_o2b','website'],
'data': [ 'data': [
'views/templates.xml', 'views/templates.xml',