autonomic-cooperative/hubl
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update: unsubscribe subscriptions

Browse Source
This commit is contained in:
Matthieu Fesselier
2021-05-20 16:01:13 +02:00
parent 83a02135fc
commit d113148053
4 changed files with 31 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/components/hubl-reactivity.js
View File

@ -14,10 +14,7 @@ export const HublReactivity = {
callback: function () {
this.subscribe();
}
},
refreshData: {
type: String,
},
}
},
async fetchData(value) {
this.resourceId = null;
@ -30,11 +27,26 @@ export const HublReactivity = {
}
this.subscribe();
},
unsubscribe(resourceId, targetSrc) {
const resourcesSub = store.subscriptionVirtualContainersIndex.get(resourceId);
const targetSub = store.subscriptionVirtualContainersIndex.get(targetSrc);
const newResourceSub = resourcesSub.filter(r => r !== targetSrc);
const newTargetSub = targetSub.filter(r => r !== resourceId);
store.subscriptionVirtualContainersIndex.set(resourceId, newResourceSub);
store.subscriptionVirtualContainersIndex.set(targetSrc, newTargetSub);
},
detached() {
this.unsubscribe(this.resourceId, this.targetSrc)
},
subscribe() {
if (this.refreshData === '') { // clears cache and re-fetch data
if (this.oldResourceId && this.oldTargetSrc && (this.oldResourceId !== this.resourceId || this.oldTargetSrc !== this.targetSrc)) {
this.unsubscribe(this.oldResourceId, this.oldTargetSrc);
}
if (this.resourceId && this.targetSrc) {
store.subscribeVirtualContainerTo(this.resourceId, this.targetSrc);
} else { // notifies components
store.subscribeResourceTo(this.resourceId, this.targetSrc);
store.subscribeVirtualContainerTo(this.targetSrc, this.resourceId);
this.oldResourceId = this.resourceId;
this.oldTargetSrc = this.targetSrc;
}
}
}