-
-
Notifications
You must be signed in to change notification settings - Fork 621
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by pedrobaeza
- Loading branch information
Showing
18 changed files
with
763 additions
and
384 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,3 +1,5 @@ | ||
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl). | ||
|
||
from . import controllers | ||
from . import models | ||
from . import wizards |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
from . import main |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,75 @@ | ||
# Copyright 2021 Tecnativa - Jairo Llopis | ||
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl). | ||
|
||
import hashlib | ||
import hmac | ||
import logging | ||
from datetime import datetime, timedelta | ||
|
||
from werkzeug.exceptions import NotAcceptable | ||
|
||
from odoo import _ | ||
from odoo.exceptions import ValidationError | ||
from odoo.http import request, route | ||
|
||
from ...mail_tracking.controllers import main | ||
from ...web.controllers.main import ensure_db | ||
|
||
_logger = logging.getLogger(__name__) | ||
|
||
|
||
class MailTrackingController(main.MailTrackingController): | ||
def _mail_tracking_mailgun_webhook_verify(self, timestamp, token, signature): | ||
"""Avoid mailgun webhook attacks. | ||
See https://documentation.mailgun.com/en/latest/user_manual.html#securing-webhooks | ||
""" # noqa: E501 | ||
# Request cannot be old | ||
processing_time = datetime.utcnow() - datetime.utcfromtimestamp(int(timestamp)) | ||
if not timedelta() < processing_time < timedelta(minutes=10): | ||
raise ValidationError(_("Request is too old")) | ||
# Avoid replay attacks | ||
try: | ||
processed_tokens = ( | ||
request.env.registry._mail_tracking_mailgun_processed_tokens | ||
) | ||
except AttributeError: | ||
processed_tokens = ( | ||
request.env.registry._mail_tracking_mailgun_processed_tokens | ||
) = set() | ||
if token in processed_tokens: | ||
raise ValidationError(_("Request was already processed")) | ||
processed_tokens.add(token) | ||
params = request.env["mail.tracking.email"]._mailgun_values() | ||
# Assert signature | ||
if not params.webhook_signing_key: | ||
_logger.warning( | ||
"Skipping webhook payload verification. " | ||
"Set `mailgun.webhook_signing_key` config parameter to enable" | ||
) | ||
return | ||
hmac_digest = hmac.new( | ||
key=params.webhook_signing_key.encode(), | ||
msg=("{}{}".format(timestamp, token)).encode(), | ||
digestmod=hashlib.sha256, | ||
).hexdigest() | ||
if not hmac.compare_digest(str(signature), str(hmac_digest)): | ||
raise ValidationError(_("Wrong signature")) | ||
|
||
@route(["/mail/tracking/mailgun/all"], auth="none", type="json", csrf=False) | ||
def mail_tracking_mailgun_webhook(self): | ||
"""Process webhooks from Mailgun.""" | ||
ensure_db() | ||
# Verify and return 406 in case of failure, to avoid retries | ||
# See https://documentation.mailgun.com/en/latest/user_manual.html#routes | ||
try: | ||
self._mail_tracking_mailgun_webhook_verify( | ||
**request.jsonrequest["signature"] | ||
) | ||
except ValidationError as error: | ||
raise NotAcceptable from error | ||
# Process event | ||
request.env["mail.tracking.email"].sudo()._mailgun_event_process( | ||
request.jsonrequest["event-data"], | ||
self._request_metadata(), | ||
) |
34 changes: 34 additions & 0 deletions
34
mail_tracking_mailgun/migrations/14.0.2.0.0/post-migration.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,34 @@ | ||
# Copyright 2021 Tecnativa - Jairo Llopis | ||
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl). | ||
|
||
import logging | ||
|
||
from openupgradelib import openupgrade | ||
|
||
_logger = logging.getLogger(__name__) | ||
|
||
|
||
@openupgrade.migrate() | ||
def migrate(env, version): | ||
"""Update webhooks. | ||
This version dropped support for legacy webhooks and added support for | ||
webhook auto registering. Do that process now. | ||
""" | ||
if version != "14.0.1.0.0": | ||
return | ||
settings = env["res.config.settings"].create({}) | ||
if not settings.mail_tracking_mailgun_enabled: | ||
_logger.warning("Not updating webhooks because mailgun is not configured") | ||
return | ||
_logger.info("Updating mailgun webhooks") | ||
try: | ||
settings.mail_tracking_mailgun_unregister_webhooks() | ||
settings.mail_tracking_mailgun_register_webhooks() | ||
except Exception: | ||
# Don't fail the update if you can't register webhooks; it can be a | ||
# failing network condition or air-gapped upgrade, and that's OK, you | ||
# can just update them later | ||
_logger.warning( | ||
"Failed to update mailgun webhooks; do that manually", exc_info=True | ||
) |
Oops, something went wrong.