React-Admin / Custom sagas : unable to import ra-realtime

[vdieulesaint]

The ra-realtime import from app does not work in v2.0.0-beta1.

Please, find below the error : ./src/app/sagas/realtimeSaga.js Module not found: Can't resolve 'ra-realtime' in '...\src\app\sagas'

import realtimeSaga from './app/sagas/realtimeSaga';

Environment

• Admin-on-rest version: v2.0.0-beta1
• ra-realtime: 2.0.0-beta1

[djhi]

Can you post the content of your ./app/sagas/realtimeSaga file and your package.json ?

[vdieulesaint]

Hi,

Here my package.json

{
  "name": "ticatag-front",
  "version": "0.1.0",
  "private": true,
  "dependencies": {
    "jwt-decode": "^2.2.0",
    "material-ui": "^1.0.0-beta.31",
    "material-ui-icons": "^1.0.0-beta.17",
    "ra-language-french": "^2.0.0-alpha1",
    "ra-realtime": "^2.0.0-beta1",
    "react": "^16.2.0",
    "react-admin": "^2.0.0-beta1",
    "react-dom": "^16.2.0",
    "react-fontawesome": "^1.6.1",
    "react-google-maps": "^9.4.5",
    "react-scripts": "1.1.0",
    "webstomp-client": "^1.2.0"
  },
  "scripts": {
    "start": "react-scripts start",
    "build": "react-scripts build",
    "test": "react-scripts test --env=jsdom",
    "eject": "react-scripts eject"
  },
  "devDependencies": {}
}

And the realtimeSaga :

import realtimeSaga  from 'ra-realtime';
import webstomp from 'webstomp-client'
import SockJS from 'sockjs-client';

const onConnect = (client, observer) => {
    client.subscribe('/topic/users/'+ localStorage.getItem('userId') +'/locations', onMessage.bind(this, client, observer));
}

const onError = (client, error) => {
    console.log(error);
}

const onMessage = (client, observer, msg) => {
    const message = JSON.parse(msg.body);
    let resource = JSON.parse(localStorage.getItem('lastResource'));
    if(resource) {
        const recordIndex = resource.findIndex(r => (r.id === message.device_id));

        if(resource[recordIndex]) {
            resource[recordIndex].last_location.latitude = message.latitude;
            resource[recordIndex].last_location.longitude = message.longitude;
            resource[recordIndex].last_location.timestamp = message.timestamp;
            observer.next({ data: resource, total: resource.length});
        }
    }
}

const observeRequest = (restClient) => (type, resource, params) => {
    const token = localStorage.getItem('token');
    let endpoint;
    if (resource === 'map') {
        endpoint = process.env.REACT_APP_WS_URL + '?access_token=';
    } else {
        return;
    }
    const url = endpoint + token;
    const headers = {
        Authorization: 'Bearer: ' + token
    };

    return {
        subscribe(observer) {
            const client = webstomp.over(new SockJS(url, {heartbeat: false}));
            client.connect(headers, onConnect.bind(this, client, observer), onError);

            const subscription = {
                unsubscribe() {
                    if(client.connected){
                        client.disconnect();
                        observer.complete();
                    }
                }
            };

            return subscription;
        },
    };
};

export default (restClient, resources) => realtimeSaga(observeRequest(restClient, resources));

[djhi]

I can confirm it's a bug in our build.

[fzaninotto]

Fixed by #1485 (to be released)

[djhi]

Released with v2.0.0-beta2