aboutsummaryrefslogtreecommitdiff
path: root/juick-server-jdbc/src/main/java
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2018-03-20 11:36:13 +0300
committerGravatar Vitaly Takmazov2018-03-20 11:36:13 +0300
commitbe91c5f5771282f2798cb687f915b0df44eaa59e (patch)
tree1d216e62851bf7cdc065a73d3a6d3d55e3137775 /juick-server-jdbc/src/main/java
parent4a1e9c4d8868ad1f14cd1c8df57db80bfbd897ce (diff)
jdbc: no more notifications from banned users
Diffstat (limited to 'juick-server-jdbc/src/main/java')
-rw-r--r--juick-server-jdbc/src/main/java/com/juick/service/SubscriptionServiceImpl.java14
1 files changed, 9 insertions, 5 deletions
diff --git a/juick-server-jdbc/src/main/java/com/juick/service/SubscriptionServiceImpl.java b/juick-server-jdbc/src/main/java/com/juick/service/SubscriptionServiceImpl.java
index eb3f79a9..77735b0c 100644
--- a/juick-server-jdbc/src/main/java/com/juick/service/SubscriptionServiceImpl.java
+++ b/juick-server-jdbc/src/main/java/com/juick/service/SubscriptionServiceImpl.java
@@ -17,6 +17,7 @@
package com.juick.service;
+import com.juick.Message;
import com.juick.Tag;
import com.juick.User;
import com.juick.server.helpers.NotifyOpts;
@@ -27,6 +28,7 @@ import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.Assert;
+import javax.annotation.Nonnull;
import javax.inject.Inject;
import java.util.Collections;
import java.util.HashSet;
@@ -102,15 +104,17 @@ public class SubscriptionServiceImpl extends BaseJdbcService implements Subscrip
@Transactional(readOnly = true)
@Override
- public List<User> getUsersSubscribedToComments(final int mid, final int ignore_uid) {
+ public List<User> getUsersSubscribedToComments(@Nonnull final Message msg, @Nonnull final Message reply) {
List<Integer> userids = getJdbcTemplate().queryForList(
"SELECT suser_id FROM subscr_messages WHERE message_id=? AND suser_id!=?",
Integer.class,
- mid, ignore_uid);
-
- if (!userids.isEmpty())
- return userService.getUsersByID(userids);
+ msg.getMid(), reply.getUser().getUid());
+ if (!userids.isEmpty()) {
+ return userService.getUsersByID(userids.stream()
+ .filter(u -> !userService.isInBLAny(u, reply.getUser().getUid()))
+ .collect(Collectors.toList()));
+ }
return Collections.emptyList();
}