Skip to Content
This question has been flagged
problembugfix
3 Replies
8894 Views
Avatar
Jan van der Wel

Hi all,

Can some help to setup communication between server and client, where I want to update the standard progresBarField in real-time:


/** @odoo-module **/

import { registry } from "@web/core/registry";

import { patch } from "@web/core/utils/patch";

import { ProgressBarField } from "@web/views/fields/progress_bar/progress_bar_field";

const fieldRegistry = registry.category("fields");

console.log("Progress listener setup");

patch(ProgressBarField.prototype, {

    setup() {

        super.setup();

        console.log("Setup progress bar");

        this.busService = this.env.services.bus_service;

        console.log("busService active is %B", this.busService.isActive);

        this.channel = "progress_bar_channel";

        this.busService.addChannel(this.channel);

        this.busService.addEventListener("notification", this.onBusMessage.bind(this));

    },

    onBusMessage({detail: notifications}) {

        console.log("onBusMessage", notifications);

        notifications = notifications.filter(item => item.type === 'notification')

        notifications.forEach(item => {

           console.log("Progress: %d on field %s", item.payload.progress, item.payload.field);

           this.setProgress(item.payload.field, item.payload.progress);

        })

    }, 

    setProgress(fieldName,newProgress) {

        if (newProgress >= 0 && newProgress <= 100) { // Ensure the progress is within bounds

            console.log("newProgress", newProgress);

            let value = String(newProgress);

            this.onValueChange(value, fieldName);

       }

    }

});  

At the Odoo server side I send progress information from a Model in Python as follows:

class MyImportWizard(models.TransientModel):

    _name = 'myapp.import.wizard'

    _description = 'Import Wizard '

    _inherit = ['bus.listener.mixin'] # Inherit the mixin for bus notifications

    file = fields.Binary("Select File", required=True, file_name = fields.Char()

    progress = fields.Integer(string="Progress", default=0)   


    def import_file(self):

        records = self.env['myapp.data'].search([])

        rows_to_process = records.__len__()

        rows_processed = 0

        for record in records:

            .... # Do some model and other model and database update work

            rows_processed = rows_processed + 1

            self.progress = (int)((rows_processed * 100) / rows_to_process)

            self.env['bus.bus']._sendone('progress_bar_channel', 'notification',

                                             {'field': 'progress','progress': self.progress})                                                       

            self.env.cr.commit(). # Needed in Odoo 17 to release (send) bus messages to the client


        self.progress = 100 # Complete the task

        self.env['bus.bus']._sendone('progress_bar_channel', 'notification',

                                             {'field': 'progress', 'progress': self.progress})


What changed in Odoo 18, that this is not working anymore. I see a lot of guessing work and changes over the different Odoo versions, where the Bus (bus.bus) API changed from version to version. In Odoo 17 I see all the console messages in the browser. In both Odoo 17 and 18 the bus_service is seen as active.

Can someone provide a good and working example on how this should work for Odoo 18 

Thanks for your help and I hope that the answer contributes to a better Odoo



Avatar
Discard
Avatar
Jan van der Wel
Author Best Answer

Hi finally I solved it as follows because Odoo 18 is quite different especially at frontend by using OWL better. By this code you have a simple progress bar when uploading a large amount of data in the database.

At the frontend using OWL:

import { patch } from "@web/core/utils/patch";
import { ProgressBarField } from "@web/views/fields/progress_bar/progress_bar_field";
import { useService, useBus } from "@web/core/utils/hooks";

console.log("Progress listener setup");

patch(ProgressBarField.prototype, {
    setup() {
        super.setup();
        console.log("Setup progress bar");

        this.busService = useService("bus_service");

        this.busService.subscribe("progress_update", (payload, {id: notifyID}) => {
            const {progress: progress, field: field} = payload;
            console.log("Progress: %d for field %s", progress, field);
            this.setProgress(field, progress)
        });
        this.busService.start();
    },

    setProgress(fieldName,newProgress) {
        if (newProgress >= 0 && newProgress <= 100) { // Ensure the progress is within bounds
            console.log("newProgress", newProgress);
            let value = String(newProgress);
            this.onValueChange(value, fieldName);
        }
    }
});

At the backend:

            rows_processed = rows_processed + 1
            self.progress = (int)((rows_processed * 100) / rows_to_process)
            self.env.user._bus_send("progress_update", {
                'field': "progress",
                'progress': self.progress,
            })
            self.env.cr.commit()

So thank you all for your response and maybe it helps you.

Avatar
Discard
Avatar
Maurel Reyes
Best Answer

En odoo 18 no funcionaba, tube que pasar el partner_id en vez del canal, solicitud realizada desde un controlador

user_list = request.env['res.users'].search([])
for current_user in user_list:
​request.env["bus.bus"]._sendone(current_user.partner_id, "turno.new_ticket", message)

Avatar
Discard
Avatar
Adam Heinz
Best Answer

I am also struggling with this, but have made some progress receiving messages from a non-custom Odoo channel:

    setup() {
        this.bus = useService("bus_service");
        this.bus.subscribe("bus.bus/im_status_updated", message => console.log("received", message));
    }

yields logs in the browser console

received Object { im_status: "online", partner_id: 3 }

Unfortunately, when I attempt to manually send messages using odoo shell​, I don't see anything in my browser console.

self.env['bus.bus']._sendone('odoo-presence-res.partner_3', 'bus.bus/im_status_updated', {'im_status': 'away'})


Avatar
Discard
Related Posts Replies Views Activity
my website is deleted.
problem
Avatar
Avatar
1
मई 24
2112
Problema - Cierre de PTV
problem
Avatar
Avatar
1
जून 23
3152
Why can't i use free versions? Solved
bugfix
Avatar
Avatar
1
अक्तू॰ 22
2197
How to install pysftp in Odoo 18 App on TrueNAS SCALE (App Store Deployment)?
problem pysftp
Avatar
Avatar
1
जुल॰ 25
1318
Odoo 17 Disconnect when Printing
debug problem
Avatar
Avatar
Avatar
Avatar
4
मार्च 24
3583