bug fix
This commit is contained in:
+4
-3
@@ -307,9 +307,9 @@
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
var am;
|
var am, user;
|
||||||
if (params.user) {
|
if (params.user) {
|
||||||
var user = topic.subscriber(params.user);
|
user = topic.subscriber(params.user);
|
||||||
if (!user) {
|
if (!user) {
|
||||||
console.log("Subscriber not found: " + params.topicName + "[" + params.user + "]");
|
console.log("Subscriber not found: " + params.topicName + "[" + params.user + "]");
|
||||||
return;
|
return;
|
||||||
@@ -318,8 +318,9 @@
|
|||||||
} else {
|
} else {
|
||||||
am = topic.getAccessMode().updateWant(mode).getWant();
|
am = topic.getAccessMode().updateWant(mode).getWant();
|
||||||
}
|
}
|
||||||
|
|
||||||
var instance = this;
|
var instance = this;
|
||||||
topic.setMeta({sub: {user: uid, mode: am}}).catch(function(err) {
|
topic.setMeta({sub: {user: params.user, mode: am}}).catch(function(err) {
|
||||||
if (errorHandler) {
|
if (errorHandler) {
|
||||||
errorHandler(err.message, "err");
|
errorHandler(err.message, "err");
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user