enhancement: adds caching to DiscordResponseParser

Author: NightTripperID

api/src/main/java/com/javadiscord/jdi/core/api/DiscordResponseParser.java

@@ -6,16 +6,20 @@
 import com.javadiscord.jdi.internal.api.DiscordRequestDispatcher;
 import com.javadiscord.jdi.internal.api.DiscordResponse;
 import com.javadiscord.jdi.internal.api.DiscordResponseFuture;
+import com.javadiscord.jdi.internal.cache.Cache;
 
+import java.lang.reflect.Field;
 import java.util.List;
 import java.util.Map;
 
 public class DiscordResponseParser {
     private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
     private final DiscordRequestDispatcher dispatcher;
+    private final Cache cache;
 
-    public DiscordResponseParser(DiscordRequestDispatcher dispatcher) {
+    public DiscordResponseParser(DiscordRequestDispatcher dispatcher, Cache cache) {
         this.dispatcher = dispatcher;
+        this.cache = cache;
     }
 
     public <T> AsyncResponse<List<T>> callAndParseList(Class<T> clazz, DiscordRequest request) {
@@ -27,6 +31,10 @@ public <T> AsyncResponse<List<T>> callAndParseList(Class<T> clazz, DiscordReques
                         try {
                             List<T> resultList = parseResponseFromList(clazz, response.body());
                             asyncResponse.setResult(resultList);
+                            for (T result : resultList) {
+                                cacheResult(result);
+                            }
+                        } catch (NoSuchFieldException e) { // ignore
                         } catch (Exception e) {
                             asyncResponse.setException(e);
                         }
@@ -38,6 +46,13 @@ public <T> AsyncResponse<List<T>> callAndParseList(Class<T> clazz, DiscordReques
         return asyncResponse;
     }
 
+    private <T> List<T> parseResponseFromList(Class<T> elementType, String response)
+            throws JsonProcessingException {
+        return OBJECT_MAPPER.readValue(
+                response,
+                OBJECT_MAPPER.getTypeFactory().constructCollectionType(List.class, elementType));
+    }
+
     public <T> AsyncResponse<List<T>> callAndParseMap(String key, DiscordRequest request) {
         AsyncResponse<List<T>> asyncResponse = new AsyncResponse<>();
         DiscordResponseFuture future = dispatcher.queue(request);
@@ -47,7 +62,11 @@ public <T> AsyncResponse<List<T>> callAndParseMap(String key, DiscordRequest req
                         try {
                             List<T> resultList = parseResponseFromMap(key, response.body());
                             asyncResponse.setResult(resultList);
-                        } catch (Exception e) {
+                            for(T result : resultList) {
+                                cacheResult(result);
+                            }
+                        } catch (NoSuchFieldException e) { // ignore
+                        } catch (Exception e){
                             asyncResponse.setException(e);
                         }
                     } else {
@@ -58,13 +77,6 @@ public <T> AsyncResponse<List<T>> callAndParseMap(String key, DiscordRequest req
         return asyncResponse;
     }
 
-    private <T> List<T> parseResponseFromList(Class<T> elementType, String response)
-            throws JsonProcessingException {
-        return OBJECT_MAPPER.readValue(
-                response,
-                OBJECT_MAPPER.getTypeFactory().constructCollectionType(List.class, elementType));
-    }
-
     private <T> List<T> parseResponseFromMap(String key, String response)
             throws JsonProcessingException {
         Map<String, List<T>> res =
@@ -90,14 +102,34 @@ private <T> void success(
             try {
                 T result = OBJECT_MAPPER.readValue(response.body(), type);
                 asyncResponse.setResult(result);
-            } catch (JsonProcessingException e) {
+                cacheResult(result);
+            } catch(NoSuchFieldException e) { // ignore
+            } catch (JsonProcessingException | IllegalAccessException e) {
                 asyncResponse.setException(e);
             }
         } else {
             asyncResponse.setException(errorResponseException(response));
         }
     }
 
+    private <T> void cacheResult(T result) throws IllegalAccessException, NoSuchFieldException {
+        Field guildIdField = result.getClass().getDeclaredField("guildId");
+        Field idField = result.getClass().getDeclaredField("id");
+
+        long guildId = getLongFromField(guildIdField);
+        long id = getLongFromField(idField);
+
+        cache.getCacheForGuild(guildId).add(id, result);
+    }
+
+    private long getLongFromField(Field field) throws IllegalAccessException {
+        field.setAccessible(true);
+        if (field.getType() == String.class) {
+            return Long.parseLong((String) field.get(field.getName()));
+        }
+        return (long) field.get(field.getName());
+    }
+
     private boolean isSuccessfulResponse(DiscordResponse response) {
         return response.status() >= 200 && response.status() < 300;
     }

core/src/main/java/com/javadiscord/jdi/core/Guild.java

@@ -31,7 +31,7 @@ public Guild(com.javadiscord.jdi.core.models.guild.Guild guild, Cache cache, Dis
         long guildId = guild.id();
 
         DiscordResponseParser discordResponseParser =
-                new DiscordResponseParser(discord.getDiscordRequestDispatcher());
+                new DiscordResponseParser(discord.getDiscordRequestDispatcher(), cache);
 
         this.applicationRequest = new ApplicationRequest(discordResponseParser, guildId);
         this.applicationRoleConnectionMetaRequest =