4 files changed, 56 insertions, 11 deletions
diff --git a/src/main/java/com/juick/service/PatreonService.java b/src/main/java/com/juick/service/PatreonService.java
index 08a828db..8f21f389 100644
--- a/src/main/java/com/juick/service/PatreonService.java
+++ b/src/main/java/com/juick/service/PatreonService.java
@@ -20,6 +20,8 @@ package com.juick.service;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
@@ -28,12 +30,17 @@ import org.springframework.web.util.UriComponentsBuilder;
 
 import jakarta.inject.Inject;
 import java.io.IOException;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.StreamSupport;
 
 @Component
 public class PatreonService {
 
+    private static final Logger logger = LoggerFactory.getLogger("Patreon");
+
+    @Inject
+    private UserService userService;
     @Inject
     private OkHttpClient httpClient;
     @Inject
@@ -89,4 +96,30 @@ public class PatreonService {
         }
         return List.of();
     }
+
+    public void updateStatus(List<String> updatedEmails) {
+        var campainsResponse = fetchCampaigns();
+        List<String> activeEmails = new ArrayList<>();
+        campainsResponse.forEach(campaign -> {
+            var pledgesResponse = fetchPledges(campaign);
+            pledgesResponse.forEach(pledge -> {
+                logger.debug("Pledge email: {}", pledge);
+                activeEmails.add(pledge);
+            });
+        });
+        activeEmails.forEach(email -> {
+            var user = userService.getUserByEmail(email);
+            if (!user.isAnonymous()) {
+                userService.setPremium(user.getUid(), true);
+            }
+        });
+        updatedEmails.stream().filter(email -> !activeEmails.contains(email))
+                .forEach(deleted -> {
+                    var user = userService.getUserByEmail(deleted);
+                    if (!user.isAnonymous() && user.isPremium()) {
+                        logger.debug("User is not a patron anymore: {}", deleted);
+                        userService.setPremium(user.getUid(), false);
+                    }
+                });
+    }
 }
diff --git a/src/main/java/com/juick/service/UserService.java b/src/main/java/com/juick/service/UserService.java
index 6f7cb58f..3c7a3235 100644
--- a/src/main/java/com/juick/service/UserService.java
+++ b/src/main/java/com/juick/service/UserService.java
@@ -170,7 +170,7 @@ public interface UserService {
 
     boolean updateFacebookUser(long fbID, String token, String fbName);
 
-    int getUIDbyVKID(long vkID);
+    Optional<User> getUserByVKID(long vkID);
 
     boolean createVKUser(long vkID, String loginhash, String token, String vkName, String vkLink);
 
diff --git a/src/main/java/com/juick/service/UserServiceImpl.java b/src/main/java/com/juick/service/UserServiceImpl.java
index 0bbeea91..a5ab8432 100644
--- a/src/main/java/com/juick/service/UserServiceImpl.java
+++ b/src/main/java/com/juick/service/UserServiceImpl.java
@@ -40,6 +40,7 @@ import org.springframework.jdbc.support.KeyHolder;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.lang.StackWalker.Option;
 import java.net.URI;
 import java.sql.*;
 import java.time.Instant;
@@ -815,10 +816,15 @@ public class UserServiceImpl extends BaseJdbcService implements UserService {
 
     @Transactional(readOnly = true)
     @Override
-    public int getUIDbyVKID(long vkID) {
-        var users = getJdbcTemplate().queryForList("""
-                    SELECT user_id FROM vk WHERE vk_id=? AND user_id IS NOT NULL""", Integer.class, vkID);
-        return users.isEmpty() ? 0 : users.get(0);
+    public Optional<User> getUserByVKID(long vkID) {
+        List<User> list = getJdbcTemplate().query(
+                "SELECT DISTINCT u.id, u.nick, u.passw, u.banned, u.last_seen, " +
+                        "COALESCE(f.fb_id, vk.vk_id, t.tg_id, e.user_id, 0) AS verified, premium " +
+                        "FROM users u LEFT JOIN facebook f ON f.user_id = u.id " +
+                        "LEFT JOIN vk ON u.id = vk.user_id LEFT JOIN telegram t ON u.id = t.user_id " +
+                        "LEFT JOIN emails e ON e.user_id = u.id WHERE vk.vk_id = ?", new UserMapper(), vkID);
+
+        return list.isEmpty() ? Optional.empty() : Optional.of(list.get(0));
     }
 
     @Transactional
diff --git a/src/main/java/com/juick/service/VKService.java b/src/main/java/com/juick/service/VKService.java
index 19fa5b58..7f6b2516 100644
--- a/src/main/java/com/juick/service/VKService.java
+++ b/src/main/java/com/juick/service/VKService.java
@@ -30,6 +30,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.web.util.UriComponentsBuilder;
 
 import jakarta.inject.Inject;
 
@@ -40,7 +41,8 @@ public class VKService {
     private String VK_APPID;
     @Value("${vk_secret:secret}")
     private String VK_SECRET;
-    private static final String VK_REDIRECT = "https://juick.com/_vklogin";
+    @Value("${ap_base_uri:http://localhost:8080/}")
+    private String baseUri;
     @Inject
     private ObjectMapper jsonMapper;
     @Inject
@@ -49,14 +51,16 @@ public class VKService {
 
     @PostConstruct
     public void init() {
+        UriComponentsBuilder redirectBuilder = UriComponentsBuilder.fromUriString(baseUri);
+        String redirectUri = redirectBuilder.replacePath("/_vklogin").build().toUriString();
         ServiceBuilder vkBuilder = new ServiceBuilder(VK_APPID);
         setVkAuthService(vkBuilder.apiSecret(VK_SECRET)
                 .defaultScope("friends,wall,offline,groups")
-                .callback(VK_REDIRECT)
+                .callback(redirectUri)
                 .build(VkontakteApi.instance()));
     }
 
-    public void updatePremiumStatus(Integer userId) {
+    public boolean updatePremiumStatus(Integer userId) {
         var vkUser = userService.getVkTokens(userId);
         if (vkUser != null) {
             OAuth2AccessToken token = new OAuth2AccessToken(vkUser.getRight());
@@ -65,12 +69,13 @@ public class VKService {
             getVkAuthService().signRequest(token, donRequest);
             try (Response vkResponse = getVkAuthService().execute(donRequest)) {
                 if (vkResponse.isSuccessful()) {
-                    logger.info(vkResponse.getBody());
+                    logger.debug(vkResponse.getBody());
                     var response = jsonMapper.readTree(vkResponse.getBody());
                     if (response.has("response")) {
                         var isDon = response.get("response").intValue() > 0;
-                        logger.info("{} is Don: {}", vkUser.getLeft(), isDon);
+                        logger.debug("{} is Don: {}", vkUser.getLeft(), isDon);
                         userService.setPremium(userId, isDon);
+                        return isDon;
                     } else {
                         // token is expired or does not have "groups" permissions
                         userService.updateVkToken(userId, "");
@@ -80,8 +85,9 @@ public class VKService {
                 logger.error("Don request error", e);
             }
         } else {
-            logger.warn("User is not connected to VK: {}", userId);
+            logger.debug("User is not connected to VK: {}", userId);
         }
+        return false;
     }
 
     public OAuth20Service getVkAuthService() {