Use @fedify/redis

.env.sample

@@ -1,4 +1,5 @@
 DATABASE_URL=postgresql://user:password@localhost:5432/dbname
+REDIS_URL=redis://localhost/0
 SECRET_KEY=secret_key  # generate a secret key with `openssl rand -base64 32`
 LOG_LEVEL=info
 BEHIND_PROXY=false

README.md

@@ -67,6 +67,7 @@ database and an S3-compatible object storage for media storage.  You can use
 the following environment variables to configure Hollo:
 
  -  `DATABASE_URL`: The URL of the PostgreSQL database.
+ -  `REDIS_URL`: The URL of the Redis server.
  -  `SECRET_KEY`: The secret key for securing the session.
  -  `LOG_LEVEL`: The log level for the application.  `debug`, `info`, `warning`,
     `error`, and `fatal` are available.
@@ -82,6 +83,7 @@ The image exposes the port 3000, so you can run it like this:
 ~~~~ sh
 docker run -d -p 3000:3000 \
   -e DATABASE_URL=postgres://user:password@host:port/database \
+  -e REDIS_URL=redis://host:port/0 \
   -e SECRET_KEY=your-secret-key \
   -e LOG_LEVEL=info \
   -e BEHIND_PROXY=true \

package.json

@@ -13,9 +13,10 @@
   "dependencies": {
     "@aws-sdk/client-s3": "^3.577.0",
     "@aws-sdk/credential-providers": "^3.577.0",
-    "@fedify/fedify": "0.10.0-dev.211",
+    "@fedify/fedify": "^0.11.0-dev.234",
     "@fedify/markdown-it-hashtag": "0.2.0",
     "@fedify/markdown-it-mention": "^0.1.1",
+    "@fedify/redis": "^0.1.1",
     "@hono/zod-validator": "^0.2.1",
     "@js-temporal/polyfill": "^0.4.4",
     "@logtape/logtape": "^0.4.0",
@@ -25,6 +26,7 @@
     "cheerio": "^1.0.0-rc.12",
     "drizzle-orm": "^0.30.10",
     "hono": "^4.3.4",
+    "ioredis": "^5.4.1",
     "iso-639-1": "^3.1.2",
     "markdown-it": "^14.1.0",
     "markdown-it-replace-link": "^1.2.1",

src/federation/index.ts

@@ -6,26 +6,26 @@ import {
   Create,
   Delete,
   Endpoints,
-  Federation,
   Follow,
   Image,
-  InProcessMessageQueue,
   Like,
-  MemoryKvStore,
   Note,
   PropertyValue,
   Reject,
   Undo,
   Update,
+  createFederation,
   getActorClassByTypeName,
   importJwk,
   isActor,
 } from "@fedify/fedify";
+import { RedisKvStore, RedisMessageQueue } from "@fedify/redis";
 import { getLogger } from "@logtape/logtape";
 import { parse } from "@std/semver";
 import { and, count, eq, ilike, inArray, like, sql } from "drizzle-orm";
 import metadata from "../../package.json" with { type: "json" };
 import db from "../db";
+import redis, { createRedis } from "../redis";
 import {
   type NewLike,
   accountOwners,
@@ -38,9 +38,11 @@ import { persistAccount } from "./account";
 import { toTemporalInstant } from "./date";
 import { persistPost, persistSharingPost, toObject } from "./post";
 
-export const federation = new Federation({
-  kv: new MemoryKvStore(),
-  queue: new InProcessMessageQueue(),
+export const federation = createFederation({
+  kv: new RedisKvStore(redis),
+  queue: new RedisMessageQueue(createRedis, {
+    loopInterval: { seconds: 2, milliseconds: 500 },
+  }),
 });
 
 federation

src/redis.ts

@@ -0,0 +1,10 @@
+import { Redis } from "ioredis";
+
+export function createRedis(): Redis {
+  // biome-ignore lint/complexity/useLiteralKeys: tsc rants about this (TS4111)
+  const redisUrl = process.env["REDIS_URL"];
+  if (redisUrl == null) throw new Error("REDIS_URL must be defined");
+  return new Redis(redisUrl);
+}
+
+export default createRedis();