[WIP] feat: accept Redis URI and connect to Redis

deno.json

···
     "@atproto/api": "npm:@atproto/api@0.13.14",
     "@atproto/identity": "npm:@atproto/identity@^0.4.2",
     "@atproto/sync": "npm:@atproto/sync@^0.1.4",
+    "@iuioiua/r2d2": "jsr:@iuioiua/r2d2@^2.1.1",
     "@std/assert": "jsr:@std/assert@1",
     "@std/dotenv": "jsr:@std/dotenv@^0.225.2",
     "@cliffy/command": "jsr:@cliffy/command@1.0.0-rc.7"

deno.lock

···
     "jsr:@cliffy/flags@1.0.0-rc.7": "1.0.0-rc.7",
     "jsr:@cliffy/internal@1.0.0-rc.7": "1.0.0-rc.7",
     "jsr:@cliffy/table@1.0.0-rc.7": "1.0.0-rc.7",
+    "jsr:@iuioiua/r2d2@*": "2.1.1",
+    "jsr:@iuioiua/r2d2@^2.1.1": "2.1.1",
     "jsr:@std/assert@1": "1.0.7",
+    "jsr:@std/bytes@~0.220.1": "0.220.1",
+    "jsr:@std/collections@~0.220.1": "0.220.1",
     "jsr:@std/dotenv@~0.225.2": "0.225.2",
     "jsr:@std/fmt@~1.0.2": "1.0.3",
     "jsr:@std/internal@^1.0.5": "1.0.5",
+    "jsr:@std/io@~0.220.1": "0.220.1",
     "jsr:@std/text@~1.0.7": "1.0.8",
     "npm:@atproto/api@0.13.14": "0.13.14",
     "npm:@atproto/identity@~0.4.2": "0.4.2",
···
       "integrity": "9fdd9776eda28a0b397981c400eeb1aa36da2371b43eefe12e6ff555290e3180",
       "dependencies": [
         "jsr:@std/fmt"
+      ]
+    },
+    "@iuioiua/r2d2@2.1.1": {
+      "integrity": "ef7ca7c892f5345b553efaf426b95021e7eb7374e885f521e00de5a6e5b98df9",
+      "dependencies": [
+        "jsr:@std/bytes",
+        "jsr:@std/collections",
+        "jsr:@std/io"
       ]
     },
     "@std/assert@1.0.7": {
···
         "jsr:@std/internal"
       ]
     },
+    "@std/bytes@0.220.1": {
+      "integrity": "e522cdc7c152cfc8a09bd618618cbc710dcf57003ab6fab3a6c37ff4c88aa3db"
+    },
+    "@std/collections@0.220.1": {
+      "integrity": "5820a8d7f69ef93af6807249dfa4be5b97ebf8654c587826612744cf7ae57ef2"
+    },
     "@std/dotenv@0.225.2": {
       "integrity": "e2025dce4de6c7bca21dece8baddd4262b09d5187217e231b033e088e0c4dd23"
     },
···
     },
     "@std/internal@1.0.5": {
       "integrity": "54a546004f769c1ac9e025abd15a76b6671ddc9687e2313b67376125650dc7ba"
+    },
+    "@std/io@0.220.1": {
+      "integrity": "c14c3237cfc73dd8086ac82673212939f8c49f0803d6da68eea32249caffdd67",
+      "dependencies": [
+        "jsr:@std/bytes"
+      ]
     },
     "@std/text@1.0.8": {
       "integrity": "40ba34caa095f393e78796e5eda37b8b4e2cc6cfd6f51f34658ad7487b1451e4"
···
   "workspace": {
     "dependencies": [
       "jsr:@cliffy/command@1.0.0-rc.7",
+      "jsr:@iuioiua/r2d2@^2.1.1",
       "jsr:@std/assert@1",
       "jsr:@std/dotenv@~0.225.2",
       "npm:@atproto/api@0.13.14",

main.ts

···
 import { pollFeed } from "./src/poll_feed.ts";
 import { pollBlueskyList } from "./src/poll_list.ts";
 import { firehoseEventToRecordView } from "./src/convert.ts";
+import { RedisClient } from "jsr:@iuioiua/r2d2";
 const { BskyAgent } = api; // RIP need module export
 
 // load .env file
···
 const IDENTIFIER = Deno.env.get("BLUESKY_IDENTIFIER") || env["BLUESKY_IDENTIFIER"];
 const PASSWORD =  Deno.env.get("BLUESKY_PASSWORD") || env["BLUESKY_PASSWORD"];
 const OZONE_DID = Deno.env.get("BLUESKY_OZONE_DID") || env["BLUESKY_OZONE_DID"];
+const REDIS_URI = Deno.env.get("STAR_SPANGLED_REDIS_URI") || env["STAR_SPANGLED_REDIS_URI"];
 export const ESCALATION_THRESHOLD = parseInt(Deno.env.get("STAR_SPANGLED_ESCALATION_THRESHOLD") || env["STAR_SPANGLED_ESCALATION_THRESHOLD"]) || 50;
 export const ESCALATE_AND_LABEL_THRESHOLD = parseInt(Deno.env.get("STAR_SPANGLED_ESCALATE_AND_LABEL_THRESHOLD") || env["STAR_SPANGLED_ESCALATE_AND_LABEL_THRESHOLD"]) || 1000;
 export const LABEL_THRESHOLD = parseInt(Deno.env.get("STAR_SPANGLED_LABEL_THRESHOLD") || env["STAR_SPANGLED_LABEL_THRESHOLD"]) || 100;
···
   .env("BLUESKY_IDENTIFIER=<handle:string>", "The ATProto handle to sign in with.")
   .env("BLUESKY_PASSWORD=<password:string>", "The Bluesky app password to sign in with.")
   .env("BLUESKY_OZONE_DID=<did:string>", "The DID of the Ozone instance to connect to. ")
+  .env("STAR_SPANGLED_REDIS_URI=<uri:string>", "The URI of the Redis instance to use. Functionality that uses Redis will be unavailable if this is not set, or if Redis fails to connect.")
   .env("STAR_SPANGLED_ESCALATION_THRESHOLD=<threshold:number>", "The keyword score threshold at which a post gets escalated for manual review.", {prefix: "STAR_SPANGLED_"})
   .env("STAR_SPANGLED_LABEL_THRESHOLD=<threshold:number>", "The keyword score threshold at which a post gets automatically labeled (and not escalated).", {prefix: "STAR_SPANGLED_"})
   .env("STAR_SPANGLED_ESCALATE_AND_LABEL_THRESHOLD=<threshold:number>", "The keyword score threshold at which a post gets automatically labeled AND escalated.", {prefix: "STAR_SPANGLED_"})
···
 
 // it's you!
 const me = await agent.getProfile({ actor: IDENTIFIER });
+
+// try to connect to Redis
+const _redisUri = URL.parse(REDIS_URI ?? "")
+// deno-lint-ignore no-var
+export var redis: RedisClient;
+if (REDIS_URI && _redisUri?.protocol == "redis:") {
+  console.info("Connecting to Redis")
+  try {
+    const redisConnection = await Deno.connect(
+      {hostname: _redisUri?.hostname ?? "localhost", port: _redisUri?.port ? parseInt(_redisUri?.port) : 6379}
+    );
+    redis = new RedisClient(redisConnection);
+    await redis.sendCommand(["HELLO", 3]);
+    console.info("Connected to Redis")
+  } catch(e) {
+    console.error("Could not connect to Redis, disabling Redis functionality: ", e,)
+  }
+}/* else if (REDIS_URI && _redisUri?.protocol == "redis-socket") {
+  const redisConnection = await Deno.connect(
+    {path: _redisUri?.pathname ?? "/run/redis.sock", transport: "unix"}
+  );
+  redis = new RedisClient(redisConnection);
+  await redis.sendCommand(["HELLO", 3]);
+}*/ else {
+  console.warn("Redis functionality, including restart recovery and double-auto-review prevention, has been turned off. Set STAR_SPANGLED_REDIS_URI to use Redis functionality.")
+}
 
 // deno-lint-ignore no-var
 export var keywordList = await getKeywordsFromFile();

overrides.tsv.example

···
 # Subject (DID)	Bonus points (or "skip")
-did:plc:5bzztbxvhii56ryi3az7lvzh	skip	# yours truly
+#did:plc:5bzztbxvhii56ryi3az7lvzh	skip	# yours truly
 did:plc:p7gxyfr5vii5ntpwo7f6dhe2	100	# AOC
 # note to self: run :CsvViewEnable comment=#
 # vim: softtabstop=0:noexpandtab