[md]redis

mcp-redis · JVM

Redis-backed implementations of the per-session state primitives used by the streaming HTTP server: SessionStore, SessionRefs, StateRef, and the notification sink. Wraps an McpHttp.streaming builder via McpRedis.configure(...) so each session's state lives in Redis instead of in-memory — the right move for multi-replica deployments and when sessions need to survive process restarts.

libraryDependencies += "net.andimiller.mcp" %% "mcp-redis" % "0.10.0"

McpRedis.configure returns a function that swaps a streaming builder's in-memory factories for Redis-backed ones — session store, session refs, and notification sink. Apply it before any .stateful / .authenticated chains and the rest of the builder is unchanged:

import cats.effect.IO
import com.comcast.ip4s.*
import dev.profunktor.redis4cats.RedisCommands
import dev.profunktor.redis4cats.pubsub.PubSubCommands
import fs2.Stream
import net.andimiller.mcp.http4s.McpHttp
import net.andimiller.mcp.redis.McpRedis

def withRedis(
    redis: RedisCommands[IO, String, String],
    pubSub: PubSubCommands[IO, [x] =>> Stream[IO, x], String, String]
) =
  McpRedis.configure[IO, Unit](redis, pubSub)
    .apply(McpHttp.streaming[IO].name("my-server").version("1.0.0").port(port"8080"))
    .serve
    .useForever

The Chat example server uses this module end-to-end.