1

// svghmi.js

     2

     3

function dispatch_value(index, value) {

    23

};

    24

    25

// Open WebSocket to relative "/ws" address

    26

var ws = new WebSocket(window.location.href.replace(/^http(s?:\/\/[^\/]*)\/.*$/, 'ws$1/ws'));

    27

ws.binaryType = 'arraybuffer';

    28

    29

const dvgetters = {

    30

    INT: [DataView.prototype.getInt16, 2],

    31

    BOOL: [DataView.prototype.getInt8, 1]

    32

    /* TODO */

    33

};

    34

    35

// Register message reception handler 

    36

ws.onmessage = function (evt) {

    37

    38

    let data = evt.data;

    39

    let dv = new DataView(data);

    40

    let i = 0;

    41

    try {

    42

        for(let hash_int of hmi_hash) {

    43

            if(hash_int != dv.getUint8(i)){

    45

            };

    46

            i++;

    47

        };

    48

    49

        while(i < data.byteLength){

    50

            let index = dv.getUint32(i, true);

    51

            i += 4;

    52

            let iectype = hmitree_types[index];

    53

            if(iectype != undefined){

    54

                let [dvgetter, bytesize] = dvgetters[iectype];

    55

                let value = dvgetter.call(dv,i,true);

    56

                dispatch_value(index, value);

    57

                i += bytesize;

    58

            } else {

    59

                throw new Error("Unknown index "+index)

    60

            }

    61

        };

    62

    } catch(err) {

    63

        // 1003 is for "Unsupported Data"

    64

        // ws.close(1003, err.message);

    65

    66

        // TODO : remove debug alert ?

    67

        alert("Error : "+err.message+"\\\\nHMI will be reloaded.");

    68

    69

        // force reload ignoring cache

    70

        location.reload(true);

    71

    }

    72

};

    73

    74

    75

function send_blob(data) {

    76

    if(data.length > 0) {

    77

        ws.send(new Blob([new Uint8Array(hmi_hash)].concat(data)));

    78

    };

    79

};

    80

    81

const typedarray_types = {

    82

    INT: Int16Array,

    83

    BOOL: Uint8Array

    84

    /* TODO */

    85

};

    86

    87

function send_reset() {

    88

    send_blob(new Uint8Array([1])); /* reset = 1 */

    89

};

    90

    91

// subscription state, as it should be in hmi server

    92

// hmitree indexed array of integers

    93

var subscriptions =  hmitree_types.map(_ignored => 0);

    94

    95

// subscription state as needed by widget now

    96

// hmitree indexed array of Sets of widgets objects

    97

var subscribers = hmitree_types.map(_ignored => new Set());

    98

    99

function update_subscriptions() {

   100

    let delta = [];

   101

    for(let index = 0; index < subscribers.length; index++){

   102

        let widgets = subscribers[index];

   103

   104

        // periods are in ms

   105

        let previous_period = subscriptions[index];

   106

   107

        let new_period = 0;

   108

        if(widgets.size > 0) {

   109

            let maxfreq = 0;

   110

            for(let widget of widgets)

   111

                if(maxfreq < widget.frequency)

   112

                    maxfreq = widget.frequency;

   113

   114

            if(maxfreq != 0)

   115

                new_period = 1000/maxfreq;

   116

        }

   117

   118

        if(previous_period != new_period) {

   119

            subscriptions[index] = new_period;

   120

            delta.push(new Blob([

   121

                new Uint8Array([2]), /* subscribe = 2 */

   122

                new Uint32Array([index]), 

   123

                new Uint16Array([new_period])]));

   124

        }

   125

   126

    }

   127

    send_blob(delta);

   128

};

   129

   130

function update_value(index, value) {

   131

    iectype = hmitree_types[index];

   132

    jstype = typedarray_types[iectypes];

   133

    send_blob([

   134

        new Uint8Array([0]),  /* setval = 0 */

   135

        new jstype([value])

   136

        ]);

   137

   138

};

   139

   140

var current_page;

   141

   142

function switch_page(page_name) {

   143

    let old_desc = page_desc[current_page];

   144

    let new_desc = page_desc[page_name];

   145

    /* TODO hide / show widgets */

   146

    /* TODO move viewport */

   147

   148

    /* remove subsribers of previous page if any */

   149

    if(old_desc) for(let widget of old_desc.widgets){

   150

        for(let index of widget.indexes){

   151

            subscribers[index].delete(widget);

   152

        }

   153

    }

   154

    /* add new subsribers if any */

   155

    if(new_desc) for(let widget of new_desc.widgets){

   156

        for(let index of widget.indexes){

   157

            subscribers[index].add(widget);

   158

        }

   159

    }

   160

   161

    current_page = page_name;

   162

   163

    update_subscriptions();

   164

};

   165

   166

   167

// Once connection established

   168

ws.onopen = function (evt) {

   169

    send_reset();

   170

    // show main page

   171

    switch_page(default_page);

   172

};

   173

   174

ws.onclose = function (evt) {

   175

    // TODO : add visible notification while waiting for reload

   176

    console.log("Connection closed. code:"+evt.code+" reason:"+evt.reason+" wasClean:"+evt.wasClean+" Reload in 10s.");

   177

    // TODO : re-enable auto reload when not in debug

   178

    //window.setTimeout(() => location.reload(true), 10000);

   179

    alert("Connection closed. code:"+evt.code+" reason:"+evt.reason+" wasClean:"+evt.wasClean+".");

   180

   181

};