Skip to content

Commit ff2d485

Browse files
committed
fixes #99 update DynamoDbCacheManager to add one more interface method
1 parent 3214312 commit ff2d485

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed

src/main/java/com/networknt/aws/lambda/cache/DynamoDbCacheManager.java

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,26 @@ public void addCache(String cacheName, long maxSize, long expiryInMinutes) {
3333
Table table = this.dynamoDB.getTable(cacheName);
3434
tables.put(cacheName, table);
3535
}
36+
@Override
37+
public Map<Object, Object> getCache(String cacheName) {
38+
// cacheName is serviceId + ":" + jwt or jwk
39+
String applicationId = cacheName.split(":")[0];
40+
String tableName = cacheName.split(":")[1];
41+
Item entry;
42+
try {
43+
Table table = tables.get(tableName);
44+
entry = table.getItem(HASH_ID_KEY, applicationId);
45+
if (entry == null)
46+
return null;
47+
} catch (NullPointerException e) {
48+
return null;
49+
}
50+
return convertMap(entry.asMap());
51+
}
52+
53+
public static Map<Object, Object> convertMap(Map<String, Object> originalMap) {
54+
return new HashMap<>(originalMap);
55+
}
3656

3757
@Override
3858
public void put(String cacheName, String key, Object value) {

0 commit comments

Comments
 (0)