diff --git a/bubble-server/src/main/java/bubble/resources/stream/FilterHttpResource.java b/bubble-server/src/main/java/bubble/resources/stream/FilterHttpResource.java index 01723072..3edfcb90 100644 --- a/bubble-server/src/main/java/bubble/resources/stream/FilterHttpResource.java +++ b/bubble-server/src/main/java/bubble/resources/stream/FilterHttpResource.java @@ -292,7 +292,7 @@ public class FilterHttpResource { data.setMatcher(fdc.matcher.getUuid()); if (log.isDebugEnabled()) log.debug("writeData: recording data="+json(data, COMPACT_MAPPER)); - return ok(dataDAO.create(data)); + return ok(dataDAO.set(data)); } private class FilterDataContext { diff --git a/bubble-server/src/main/resources/bubble/rule/social/block/JsUserBlocker.js.hbs b/bubble-server/src/main/resources/bubble/rule/social/block/JsUserBlocker.js.hbs index db6542f3..95d5b007 100644 --- a/bubble-server/src/main/resources/bubble/rule/social/block/JsUserBlocker.js.hbs +++ b/bubble-server/src/main/resources/bubble/rule/social/block/JsUserBlocker.js.hbs @@ -1,5 +1,6 @@ -const {{JS_PREFIX}}_blocked_users = []; +let {{JS_PREFIX}}_blocked_users = null; const {{JS_PREFIX}}_request_id = '{{BUBBLE_REQUEST_ID}}'; +const {{JS_PREFIX}}_interval = 50; function {{JS_PREFIX}}_onReady(callback) { const intervalId = window.setInterval(function() { @@ -7,23 +8,36 @@ function {{JS_PREFIX}}_onReady(callback) { window.clearInterval(intervalId); callback.call(this); } - }, 1000); + }, {{JS_PREFIX}}_interval); } -function {{JS_PREFIX}}_fetch_blocks () { +function {{JS_PREFIX}}_fetch_blocks (do_apply) { const requestOptions = { method: 'GET' }; const blocked_users_url = '/__bubble/api/filter/data/{{BUBBLE_DATA_ID}}/read'; fetch(blocked_users_url, requestOptions) .then((resp) => resp.json()) .then(data => { - {{JS_PREFIX}}_blocked_users.length = 0; + const blocked_users = []; for (let i=0; i