You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
101 lines
4.4 KiB
101 lines
4.4 KiB
# -*- coding: utf-8 -*-
|
|
#############################################################################
|
|
#
|
|
# Cybrosys Technologies Pvt. Ltd.
|
|
#
|
|
# Copyright (C) 2023-TODAY Cybrosys Technologies(<https://www.cybrosys.com>)
|
|
# Author: Gokul PI (<https://www.cybrosys.com>)
|
|
#
|
|
# You can modify it under the terms of the GNU LESSER
|
|
# GENERAL PUBLIC LICENSE (LGPL v3), Version 3.
|
|
#
|
|
# 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 LESSER GENERAL PUBLIC LICENSE (LGPL v3) for more details.
|
|
#
|
|
# You should have received a copy of the GNU LESSER GENERAL PUBLIC LICENSE
|
|
# (LGPL v3) along with this program.
|
|
# If not, see <http://www.gnu.org/licenses/>.
|
|
#
|
|
#############################################################################
|
|
from firebase_admin import messaging, initialize_app, credentials, _apps
|
|
from odoo import models
|
|
|
|
|
|
class MailThread(models.AbstractModel):
|
|
"""Inherits MailThread to send notifications using chatterbox"""
|
|
_inherit = 'mail.thread'
|
|
|
|
def _notify_thread(self, message, msg_vals=False, **kwargs):
|
|
"""Override the _notify_thread() function to fetch chat message details
|
|
and push that message as a notification."""
|
|
res = super()._notify_thread(message, msg_vals=msg_vals, **kwargs)
|
|
msg = message.read()
|
|
if (self.env.company.push_notification and
|
|
self.env.user.has_group('base.group_user')):
|
|
try:
|
|
domain = []
|
|
receiver_ids = self._get_receiver_ids(msg)
|
|
user_list = [rec.id for rec in receiver_ids]
|
|
if receiver_ids:
|
|
domain = [('user_id', 'in', user_list)]
|
|
self._send_push_notification(msg, domain)
|
|
except Exception as e:
|
|
self.env['ir.logging'].sudo().create({
|
|
'name': 'Push Notification Error',
|
|
'type': 'server',
|
|
'level': 'ERROR',
|
|
'message': str(e),
|
|
'path': 'mail.thread',
|
|
'func': '_notify_thread',
|
|
'line': '45',
|
|
})
|
|
return res
|
|
|
|
def _get_receiver_ids(self, msg):
|
|
"""Identify the receiver of the notification."""
|
|
receiver_ids = []
|
|
receiver_id = False
|
|
if self.channel_type != 'channel':
|
|
for partner in self.channel_partner_ids:
|
|
if partner.id != msg[0]['author_id'][0]:
|
|
receiver_id = self.env['res.users'].search(
|
|
[('partner_id', '=', partner.id)])
|
|
if receiver_id:
|
|
receiver_ids.append(receiver_id)
|
|
else:
|
|
for partner in self.channel_partner_ids:
|
|
receiver_id = self.env['res.users'].search(
|
|
[('partner_id', '=', partner.id)])
|
|
if receiver_id:
|
|
receiver_ids.append(receiver_id)
|
|
return receiver_ids
|
|
|
|
def _send_push_notification(self, msg, domain):
|
|
"""Send a push notification using Firebase."""
|
|
if not _apps:
|
|
cred = credentials.Certificate({
|
|
"type": "service_account",
|
|
"project_id": self.env.company.project_id_firebase,
|
|
"private_key_id": self.env.company.private_key_ref,
|
|
"private_key": self.env.company.private_key.replace('\\n',
|
|
'\n'),
|
|
"client_email": self.env.company.client_email,
|
|
"client_id": self.env.company.client_id_firebase,
|
|
"auth_uri": "https://accounts.google.com/o/oauth2/auth",
|
|
"token_uri": "https://oauth2.googleapis.com/token",
|
|
"auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
|
|
"client_x509_cert_url": self.env.company.client_cert_url,
|
|
"universe_domain": "googleapis.com"
|
|
})
|
|
initialize_app(cred)
|
|
message = messaging.MulticastMessage(
|
|
notification=messaging.Notification(
|
|
title='Message from ' + msg[0]['author_id'][1],
|
|
body=msg[0]['body']
|
|
),
|
|
tokens=[reg_id.register_id for reg_id in
|
|
self.env['push.notification'].search(domain)]
|
|
)
|
|
messaging.send_each_for_multicast(message)
|
|
|