105 lines
3.7 KiB
JavaScript
105 lines
3.7 KiB
JavaScript
|
//------------------------------------------------------------------------------
|
|||
|
|
// Event-Service: asynchroner Nachrichtenaustausch
|
|||
|
|
//------------------------------------------------------------------------------
|
|||
|
|
|
|||
|
|
'use strict'
|
|||
|
|
|
|||
|
|
function each(object_opl, iterator_opl, context_opl) {
|
|||
|
|
for (let key_s in object_opl) {
|
|||
|
|
iterator_opl.call(context_opl, object_opl[key_s], key_s);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function findAll(object_opl, iterator_opl, context_opl) {
|
|||
|
|
let results_a = [];
|
|||
|
|
each(object_opl, function(value_opl, index_ipl) {
|
|||
|
|
if (iterator_opl.call(context_opl, value_opl, index_ipl))
|
|||
|
|
results_a.push(value_opl);
|
|||
|
|
});
|
|||
|
|
return results_a;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function compact(object_opl) {
|
|||
|
|
return findAll(object_opl, function(value_opl) {
|
|||
|
|
return value_opl != null;
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//------------------------------------------------------------------------------
|
|||
|
|
class EventService_cl {
|
|||
|
|
//------------------------------------------------------------------------------
|
|||
|
|
constructor () {
|
|||
|
|
this.queue_o = [];
|
|||
|
|
this.Subscriber_o = {};
|
|||
|
|
window.onhashchange = this.send_p.bind(this);
|
|||
|
|
}
|
|||
|
|
send_p (event_opl) {
|
|||
|
|
// der hash-Wert interessiert hier nicht
|
|||
|
|
// gibt es Elemente in der queue?
|
|||
|
|
if (this.queue_o.length > 0) {
|
|||
|
|
let qentry_o = this.queue_o[0];
|
|||
|
|
qentry_o[0].notify_px.apply(qentry_o[0], [qentry_o[0], qentry_o[1], qentry_o[2]]);
|
|||
|
|
this.queue_o.shift();
|
|||
|
|
}
|
|||
|
|
if (this.queue_o.length > 0) {
|
|||
|
|
let d_o = new Date();
|
|||
|
|
window.location.hash = d_o.getTime();
|
|||
|
|
}
|
|||
|
|
event_opl.preventDefault();
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
subscribe_px (Subscriber_opl, Message_spl) {
|
|||
|
|
if (Message_spl in this.Subscriber_o) {
|
|||
|
|
// Message bekannt, Liste der Subscriber untersuchen
|
|||
|
|
if (this.Subscriber_o[Message_spl].indexOf(Subscriber_opl) == -1) {
|
|||
|
|
this.Subscriber_o[Message_spl].push(Subscriber_opl);
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
// Message noch nicht vorhanden, neu eintragen
|
|||
|
|
this.Subscriber_o[Message_spl] = [Subscriber_opl];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
unSubscribe_px (Subscriber_opl, Message_spl) {
|
|||
|
|
if (Message_spl in this.Subscriber_o) {
|
|||
|
|
// Message bekannt, Liste der Subscriber untersuchen
|
|||
|
|
let Entry_a = this.Subscriber_o[Message_spl];
|
|||
|
|
let index_i = Entry_a.indexOf(Subscriber_opl);
|
|||
|
|
if (index_i >= 0) {
|
|||
|
|
// Eintrag entfernen
|
|||
|
|
Entry_a[index_i] = null;
|
|||
|
|
Entry_a = compact(Entry_a); // compact liefert Kopie!
|
|||
|
|
if (Entry_a.length == 0) {
|
|||
|
|
// keine Subscriber mehr, kann entfernt werden
|
|||
|
|
delete this.Subscriber_o[Message_spl];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
} else {
|
|||
|
|
// Message nicht vorhanden, falsche Anforderung
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
publish_px (Message_spl, Data_opl) {
|
|||
|
|
let data_s = "<null>";
|
|||
|
|
if ((Data_opl != undefined) && (Data_opl != null)) {
|
|||
|
|
data_s = Data_opl.toString();
|
|||
|
|
}
|
|||
|
|
console.info('es - publish ' + Message_spl + ' ' + data_s);
|
|||
|
|
let that = this;
|
|||
|
|
each(this.Subscriber_o, function (value_apl, key_spl) {
|
|||
|
|
// geliefert wird jeweils ein Wert, hier ein Array, und der Key
|
|||
|
|
if (key_spl == Message_spl) {
|
|||
|
|
// an alle Subscriber weitergeben
|
|||
|
|
each(value_apl, function (entry_opl, index_ipl) {
|
|||
|
|
// geliefert wird hier das Element und der Index
|
|||
|
|
that.queue_o.push([entry_opl, Message_spl, Data_opl]);
|
|||
|
|
let d_o = new Date();
|
|||
|
|
window.location.hash = d_o.getTime();
|
|||
|
|
}, this
|
|||
|
|
);
|
|||
|
|
}
|
|||
|
|
}, this
|
|||
|
|
)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// EOF
|