From e14d4612d313b7424b2163ba247843655c4dfca1 Mon Sep 17 00:00:00 2001
From: Vitaly Takmazov
Date: Fri, 19 Jul 2024 13:25:06 +0300
Subject: Update premium status on login

---
 .../com/juick/www/api/webhooks/PatreonWebhook.java | 24 +---------------------
 1 file changed, 1 insertion(+), 23 deletions(-)

(limited to 'src/main/java/com/juick/www')

diff --git a/src/main/java/com/juick/www/api/webhooks/PatreonWebhook.java b/src/main/java/com/juick/www/api/webhooks/PatreonWebhook.java
index d8467ff0..c05585ac 100644
--- a/src/main/java/com/juick/www/api/webhooks/PatreonWebhook.java
+++ b/src/main/java/com/juick/www/api/webhooks/PatreonWebhook.java
@@ -67,28 +67,6 @@ public class PatreonWebhook {
         var updatedEmails = StreamSupport.stream(json.get("included").spliterator(), false)
                 .filter(node -> node.get("type").textValue().equals("user"))
                 .map(node -> node.get("attributes").get("email").textValue()).toList();
-        var campainsResponse = patreonService.fetchCampaigns();
-        List<String> activeEmails = new ArrayList<>();
-        campainsResponse.forEach(campaign -> {
-            var pledgesResponse = patreonService.fetchPledges(campaign);
-            pledgesResponse.forEach(pledge -> {
-                logger.info("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()) {
-                        logger.info("User is not a patron anymore: {}", deleted);
-                        userService.setPremium(user.getUid(), false);
-                    }
-                });
+        patreonService.updateStatus(updatedEmails);
     }
 }
-- 
cgit v1.2.3