aboutsummaryrefslogtreecommitdiff
path: root/utils/getRedisWithPrefix.js
diff options
context:
space:
mode:
authorFactiven <[email protected]>2023-09-26 23:35:35 +0700
committerFactiven <[email protected]>2023-09-26 23:35:35 +0700
commit20b8a7267827e3a07c1eef668c3b9c22fda43765 (patch)
tree2fec9006dfac5737d8b227bf5ccce73880800cc2 /utils/getRedisWithPrefix.js
parentUpdate release.md (diff)
downloadmoopa-20b8a7267827e3a07c1eef668c3b9c22fda43765.tar.xz
moopa-20b8a7267827e3a07c1eef668c3b9c22fda43765.zip
Update v4.1.2v4.1.2
Diffstat (limited to 'utils/getRedisWithPrefix.js')
-rw-r--r--utils/getRedisWithPrefix.js71
1 files changed, 71 insertions, 0 deletions
diff --git a/utils/getRedisWithPrefix.js b/utils/getRedisWithPrefix.js
new file mode 100644
index 0000000..31a466d
--- /dev/null
+++ b/utils/getRedisWithPrefix.js
@@ -0,0 +1,71 @@
+import { redis } from "@/lib/redis";
+
+export async function getValuesWithPrefix(prefix) {
+ let cursor = "0"; // Start at the beginning of the keyspace
+ let values = [];
+
+ do {
+ const [newCursor, matchingKeys] = await redis.scan(
+ cursor,
+ "MATCH",
+ prefix + "*",
+ "COUNT",
+ 100
+ );
+
+ // Retrieve values for matching keys and add them to the array
+ for (const key of matchingKeys) {
+ const value = await redis.get(key);
+ values.push(JSON.parse(value));
+ }
+
+ // Update the cursor for the next iteration
+ cursor = newCursor;
+ } while (cursor !== "0"); // Continue until the cursor is '0'
+
+ return values;
+}
+
+export async function countKeysWithPrefix(prefix) {
+ let cursor = "0"; // Start at the beginning of the keyspace
+ let count = 0;
+
+ do {
+ const [newCursor, matchingKeys] = await redis.scan(
+ cursor,
+ "MATCH",
+ prefix + "*",
+ "COUNT",
+ 100
+ );
+
+ // Increment the count by the number of matching keys in this iteration
+ count += matchingKeys.length;
+
+ // Update the cursor for the next iteration
+ cursor = newCursor;
+ } while (cursor !== "0"); // Continue until the cursor is '0'
+
+ return count;
+}
+
+export async function getValuesWithNumericKeys() {
+ const allKeys = await redis.keys("*"); // Fetch all keys in Redis
+ const numericKeys = allKeys.filter((key) => /^\d+$/.test(key)); // Filter keys that contain only numbers
+
+ const values = [];
+
+ for (const key of numericKeys) {
+ const value = await redis.get(key); // Retrieve the value for each numeric key
+ values.push(value);
+ }
+
+ return values;
+}
+
+export async function countNumericKeys() {
+ const allKeys = await redis.keys("*"); // Fetch all keys in Redis
+ const numericKeys = allKeys.filter((key) => /^\d+$/.test(key)); // Filter keys that contain only numbers
+
+ return numericKeys.length; // Return the count of numeric keys
+}