Question about liveProvider

[artemsiberiangit]

I created my own custom provider based on centrifuge (https://github.com/centrifugal/centrifuge-js )

import { LiveProvider } from "@refinedev/core";
import { Subscription, Centrifuge } from "centrifuge";

export const liveProvider = (centrifugeClient: Centrifuge): LiveProvider => {
    return {
        subscribe: ({ channel, types, params, callback }): Subscription => {
            const resource = channel.replace("resources/", "");
            const listener = (data: any) => {
                const eventType = data.data.type;
                if (types.includes("*") || types.includes(eventType)) {
                    if (
                        eventType !== "created" &&
                        params?.ids !== undefined &&
                        data.payload?.id !== undefined
                    ) {
                        if (params.ids.map(String).includes(data.payload.id.toString())) {
                            callback({
                                channel,
                                type: eventType,
                                date: new Date(data.data.date),
                                payload: data.data.payload,
                            });
                        }
                    } else {
                        callback({
                            channel,
                            type: eventType,
                            date: new Date(data.data.date),
                            payload: data.data.payload,
                        });
                    }
                }
            };

            let subscription = centrifugeClient.getSubscription(channel)
            if (!subscription) {
                subscription = centrifugeClient.newSubscription(channel);
            }

            subscription.subscribe()
            subscription.on("publication", listener);

            return subscription;
        },

        unsubscribe: (subscription: Subscription) => {
            subscription.unsubscribe();
        },
    };
};

Connected it

  <Refine
    liveProvider={liveProvider(centrifuge)}

Next, on the page with the table, I did this:

    const { tableProps, tableQueryResult, filters } = useTable<IUser, HttpError>({
        liveMode: "manual",
        metaData: {
            fields: [
                "id",
                'username'
            ],
        },
        onLiveEvent: (event) => {
            console.log('event', event)
        },
        resource: "users",
        sorters: {
            initial: [{field: "id", order: "desc"}]
        },
        hasPagination: true,
        syncWithLocation: true,
    });

Since I use a simple-rest client, I do not understand in what format I need to send data to update the record in the table, now I am adding data in the form of a test, they come in this form to the event variable from onLiveEvent :

{
    "channel": "resources/users",
    "type": "updated",
    "date": "1970-01-20T15:57:37.152Z",
    "payload": {
        "id": "ffa169b8-72de-4007-9a2a-e2b1c5453870",
        "username": "updateUserNameTest"
    }
}

But there is no update of the record in the table, what am I doing wrong? or do I need to send data in a different format?
When data is received, it is not a specific record that is changed, but a refetch is made

[BatuhanW]

Hello @artemsiberiangit it seems you set liveMode to manual, if you do this, you need to handle refetch logic yourself.

Here is a link to the documentation: https://refine.dev/docs/api-reference/core/providers/live-provider/#manual

[artemsiberiangit]

Oh yes, I'm sorry, this is not the actual code, I have auto installed, I wrote in the description that I expect a specific record to be updated, since refetch is a relatively useless function, if I am on the first page, and someone updated the record from the second page, then I have a refetch... I don't understand how to make useTable work in such a way that it subscribes only to certain IDs

if at all possible?

[BatuhanW]

Hello @artemsiberiangit, as you guessed it's not possible at the moment. You can create an issue with title FEAT, we are open to community contributions. If this issue is critical for you, we can prioritize this feature in our enterprise package. https://s.refine.dev/enterprise