Switch to official redis lib

deno.json

···
     "@atcute/lexicons": "npm:@atcute/lexicons@^1.2.2",
     "@atcute/xrpc-server": "npm:@atcute/xrpc-server@^0.1.2",
     "@db/sqlite": "jsr:@db/sqlite@^0.12.0",
-    "@iuioiua/redis": "jsr:@iuioiua/redis@^1.1.9",
-    "@skyware/jetstream": "npm:@skyware/jetstream@^0.2.5"
+    "@skyware/jetstream": "npm:@skyware/jetstream@^0.2.5",
+    "redis": "npm:redis@^5.8.3"
   },
   "tasks": {
     "start-feedgen": "deno serve --no-prompt --env-file --allow-net --allow-env --allow-ffi --allow-read --port=4000 feedgen.ts",

deno.lock

···
   "specifiers": {
     "jsr:@db/sqlite@0.12": "0.12.0",
     "jsr:@denosaurs/plug@1": "1.1.0",
-    "jsr:@iuioiua/redis@^1.1.9": "1.1.9",
     "jsr:@std/assert@0.217": "0.217.0",
     "jsr:@std/encoding@1": "1.0.10",
     "jsr:@std/fmt@1": "1.0.8",
···
     "npm:@atcute/identity-resolver@^1.1.4": "1.1.4_@atcute+identity@1.1.1",
     "npm:@atcute/lexicons@^1.2.2": "1.2.2",
     "npm:@atcute/xrpc-server@~0.1.2": "0.1.2_@atcute+identity@1.1.1",
-    "npm:@skyware/jetstream@~0.2.5": "0.2.5"
+    "npm:@skyware/jetstream@~0.2.5": "0.2.5",
+    "npm:redis@^5.8.3": "5.8.3_@redis+client@5.8.3"
   },
   "jsr": {
     "@db/sqlite@0.12.0": {
···
         "jsr:@std/fs",
         "jsr:@std/path@1"
       ]
-    },
-    "@iuioiua/redis@1.1.9": {
-      "integrity": "167d9031d0b8cf050d63756cf6b2d59872d9095784b2dff2b8a40adcf744c1e4"
     },
     "@std/assert@0.217.0": {
       "integrity": "c98e279362ca6982d5285c3b89517b757c1e3477ee9f14eb2fdf80a45aaa9642"
···
     "@noble/secp256k1@2.3.0": {
       "integrity": "sha512-0TQed2gcBbIrh7Ccyw+y/uZQvbJwm7Ao4scBUxqpBCcsOlZG0O4KGfjtNAy/li4W8n1xt3dxrwJ0beZ2h2G6Kw=="
     },
+    "@redis/bloom@5.8.3_@redis+client@5.8.3": {
+      "integrity": "sha512-1eldTzHvdW3Oi0TReb8m1yiFt8ZwyF6rv1NpZyG5R4TpCwuAdKQetBKoCw7D96tNFgsVVd6eL+NaGZZCqhRg4g==",
+      "dependencies": [
+        "@redis/client"
+      ]
+    },
+    "@redis/client@5.8.3": {
+      "integrity": "sha512-MZVUE+l7LmMIYlIjubPosruJ9ltSLGFmJqsXApTqPLyHLjsJUSAbAJb/A3N34fEqean4ddiDkdWzNu4ZKPvRUg==",
+      "dependencies": [
+        "cluster-key-slot"
+      ]
+    },
+    "@redis/json@5.8.3_@redis+client@5.8.3": {
+      "integrity": "sha512-DRR09fy/u8gynHGJ4gzXYeM7D8nlS6EMv5o+h20ndTJiAc7RGR01fdk2FNjnn1Nz5PjgGGownF+s72bYG4nZKQ==",
+      "dependencies": [
+        "@redis/client"
+      ]
+    },
+    "@redis/search@5.8.3_@redis+client@5.8.3": {
+      "integrity": "sha512-EMIvEeGRR2I0BJEz4PV88DyCuPmMT1rDtznlsHY3cKSDcc9vj0Q411jUnX0iU2vVowUgWn/cpySKjpXdZ8m+5g==",
+      "dependencies": [
+        "@redis/client"
+      ]
+    },
+    "@redis/time-series@5.8.3_@redis+client@5.8.3": {
+      "integrity": "sha512-5Jwy3ilsUYQjzpE7WZ1lEeG1RkqQ5kHtwV1p8yxXHSEmyUbC/T/AVgyjMcm52Olj/Ov/mhDKjx6ndYUi14bXsw==",
+      "dependencies": [
+        "@redis/client"
+      ]
+    },
     "@skyware/jetstream@0.2.5": {
       "integrity": "sha512-fM/zs03DLwqRyzZZJFWN20e76KrdqIp97Tlm8Cek+vxn96+tu5d/fx79V6H85L0QN6HvGiX2l9A8hWFqHvYlOA==",
       "dependencies": [
···
     "@standard-schema/spec@1.0.0": {
       "integrity": "sha512-m2bOd0f2RT9k8QJx1JN85cZYyH1RqFBdlwtkSlf4tBDYLCiiZnv1fIIwacK6cqwXavOydf0NPToMQgpKq+dVlA=="
     },
+    "cluster-key-slot@1.1.2": {
+      "integrity": "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA=="
+    },
     "esm-env@1.2.2": {
       "integrity": "sha512-Epxrv+Nr/CaL4ZcFGPJIYLWFom+YeV1DqMLHJoEd9SYRxNbaFruBwfEX/kkHUJf55j2+TUbmDcmuilbP1TmXHA=="
     },
···
         "event-target-polyfill"
       ]
     },
+    "redis@5.8.3_@redis+client@5.8.3": {
+      "integrity": "sha512-MfSrfV6+tEfTw8c4W0yFp6XWX8Il4laGU7Bx4kvW4uiYM1AuZ3KGqEGt1LdQHeD1nEyLpIWetZ/SpY3kkbgrYw==",
+      "dependencies": [
+        "@redis/bloom",
+        "@redis/client",
+        "@redis/json",
+        "@redis/search",
+        "@redis/time-series"
+      ]
+    },
     "tiny-emitter@2.1.0": {
       "integrity": "sha512-NB6Dk1A9xgQPMoGqC5CVXn123gWyte215ONT5Pp5a0yt4nlEoO1ZWeCwpncaekPHXO60i47ihFnZPiRPjRMq4Q=="
     }
···
   "workspace": {
     "dependencies": [
       "jsr:@db/sqlite@0.12",
-      "jsr:@iuioiua/redis@^1.1.9",
       "npm:@atcute/atproto@^3.1.7",
       "npm:@atcute/bluesky@^3.2.7",
       "npm:@atcute/client@^4.0.5",
       "npm:@atcute/identity-resolver@^1.1.4",
       "npm:@atcute/lexicons@^1.2.2",
       "npm:@atcute/xrpc-server@~0.1.2",
-      "npm:@skyware/jetstream@~0.2.5"
+      "npm:@skyware/jetstream@~0.2.5",
+      "npm:redis@^5.8.3"
     ]
   }
 }

ingest.ts

···
   WebDidDocumentResolver,
 } from "@atcute/identity-resolver";
 import type { ResourceUri } from "@atcute/lexicons/syntax";
-import { RedisClient } from "@iuioiua/redis";
+import { createClient } from "redis";
 import { Jetstream, CommitType } from "@skyware/jetstream";
 
 import type {} from "@atcute/atproto";
···
 
 type ShallowPost = Omit<Post, "cid" | "indexed_at" | "author">;
 
-const redisConn = await Deno.connect({ port: 6379 });
-const redisClient = new RedisClient(redisConn);
+const redis = createClient();
+redis.on("error", (err) => console.log("Redis Client Error", err));
+await redis.connect();
 
 const insertPost = db.prepare(
   `INSERT INTO posts ("uri", "cid", "author", "indexed_at") VALUES (?1, ?2, ?3, ?4) ON CONFLICT DO NOTHING;`
···
     );
     if (changes > 0) {
       const pdsKey = `posts:${post.pds}`;
-      redisClient
-        .sendCommand(["LPUSH", pdsKey, `${post.uri};${post.indexed_at}`])
+      redis
+        .lPush(pdsKey, `${post.uri};${post.indexed_at}`)
         .then((length) => {
-          if (typeof length !== "number") {
-            console.error(`Incorrect LPUSH return type! Got ${length}`);
-            return;
-          }
           if (length > 30000) {
-            redisClient.sendCommand(["LTRIM", pdsKey, 0, 29999]); // let it run in background
-            return redisClient.sendCommand(["RPOP", pdsKey]);
+            redis.lTrim(pdsKey, 0, 29999);
+            return redis.rPop(pdsKey);
           }
         })
         .then((last) => {
           if (last) {
-            if (typeof last !== "string") {
-              console.error(`Incorrect RPOP return type! Got ${last}`);
-              return;
-            }
             const indexTime = last.split(";")[1];
             if (indexTime?.trim()) {
               removePostByPDS.run(post.pds, indexTime);
···
     const dbResult =
       removePostByURL.get<Omit<Post, "uri" | "cid" | "pds">>(atUri);
     if (dbResult) {
-      await redisClient.sendCommand([
-        "LREM",
-        `posts:${pds}`,
-        0,
-        `${atUri};${dbResult.indexed_at}`,
-      ]);
+      await redis.lRem(`posts:${pds}`, 0, `${atUri};${dbResult.indexed_at}`);
     }
   }
 });