Update lori dependency from 0.8.1 to 0.11.0 (#47)

Lori 0.9.0 added a `reason` parameter to `_on_connection_failure` that
identifies the failure stage (DNS, TCP, or SSL). Define redis-local
`ConnectionFailureReason` types and thread the reason through the state
machine to `SessionStatusNotify.redis_session_connection_failed`.

Also fix FFI type mismatch in `_mort.pony` — lori 0.11.0 declares
`@exit(I32)` and `@pony_os_stderr() -> Pointer[None]`, so our
declarations must match.

Author: SeanTAllen

CLAUDE.md

@@ -25,7 +25,7 @@ make stop-redis
 
 ## Dependencies
 
-- `ponylang/lori` (0.8.1) — TCP networking (transitively depends on `ponylang/ssl`, hence the `ssl=` build flag)
+- `ponylang/lori` (0.11.0) — TCP networking (transitively depends on `ponylang/ssl`, hence the `ssl=` build flag)
 
 ## Architecture
 
@@ -43,13 +43,14 @@ Package: `redis`
 
 - `Session` (actor in `session.pony`): Main entry point. Manages connection lifecycle and pub/sub via a state machine. Implements `lori.TCPConnectionActor & lori.ClientLifecycleEventReceiver`. All state machine classes (`_SessionUnopened`, `_SessionNegotiating`, `_SessionConnected`, `_SessionReady`, `_SessionSubscribed`, `_SessionClosed`) are in `session.pony`, following the postgres pattern.
 - `ConnectInfo` (in `connect_info.pony`): Connection configuration (host, port, optional password, SSL mode, optional username, protocol version, send buffer limit).
-- `SessionStatusNotify` (in `session_status_notify.pony`): Lifecycle callback interface. All callbacks have default no-op implementations. Callbacks: `redis_session_connected`, `redis_session_connection_failed`, `redis_session_ready`, `redis_session_authentication_failed`, `redis_session_throttled`, `redis_session_unthrottled`, `redis_session_closed`.
+- `SessionStatusNotify` (in `session_status_notify.pony`): Lifecycle callback interface. All callbacks have default no-op implementations. Callbacks: `redis_session_connected`, `redis_session_connection_failed(session, reason)`, `redis_session_ready`, `redis_session_authentication_failed`, `redis_session_throttled`, `redis_session_unthrottled`, `redis_session_closed`.
 - `ResultReceiver` (in `result_receiver.pony`): Command response callback interface. Callbacks: `redis_response`, `redis_command_failed`.
 - `SubscriptionNotify` (in `subscription_notify.pony`): Pub/sub callback interface. All callbacks have default no-op implementations. Callbacks: `redis_subscribed`, `redis_unsubscribed`, `redis_message`, `redis_psubscribed`, `redis_punsubscribed`, `redis_pmessage`.
 - `ClientError` (in `client_error.pony`): Client-side error trait with `SessionNotReady`, `SessionClosed`, `SessionConnectionLost`, `SessionProtocolError`, `SessionInSubscribedMode`, and `SessionBackpressureOverflow` primitives.
 - `_ResponseHandler` (in `_response_handler.pony`): Loops `_RespParser` over a `buffered.Reader`, routing `RespPush` to `on_push` and other `RespValue`s to `on_response`. Shuts down on `RespMalformed`.
 - `_BuildHelloCommand` / `_BuildAuthCommand` (primitives in `session.pony`): Build HELLO 3 and AUTH commands for protocol negotiation and authentication.
 - `_BufferedSend` (class val in `session.pony`): Serialized command buffered during backpressure. Holds wire-format bytes and an optional `_QueuedCommand` for response matching.
+- `ConnectionFailureReason` (type alias in `connection_failure_reason.pony`): `(ConnectionFailedDNS | ConnectionFailedTCP | ConnectionFailedSSL)`. Passed to `redis_session_connection_failed` to identify the failure stage.
 - `_IllegalState` / `_Unreachable` (in `_mort.pony`): Primitives for detecting impossible states.
 
 ### Command Builders

corral.json

@@ -13,7 +13,7 @@
   "deps": [
     {
       "locator": "github.com/ponylang/lori.git",
-      "version": "0.8.1"
+      "version": "0.11.0"
     }
   ]
 }

examples/backpressure/main.pony

@@ -37,7 +37,9 @@ actor Client is (SessionStatusNotify & ResultReceiver)
   be redis_session_unthrottled(session: Session) =>
     _out.print("Unthrottled — flushing buffered commands.")
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect.")
 
   be redis_response(session: Session, response: RespValue) =>

examples/basic/main.pony

@@ -24,7 +24,9 @@ actor Client is (SessionStatusNotify & ResultReceiver)
     _out.print("Connected and ready.")
     session.execute(RedisString.set("hello", "world"), this)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect.")
 
   be redis_response(session: Session, response: RespValue) =>

examples/pipeline/main.pony

@@ -40,7 +40,9 @@ actor Client is (SessionStatusNotify & ResultReceiver)
       session.execute(cmd, this)
     end
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect.")
 
   be redis_response(session: Session, response: RespValue) =>

examples/pubsub/main.pony

@@ -68,7 +68,9 @@ actor PubSubDemo is
     _subscriber.close()
     _publisher.close()
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect.")
 
   be redis_response(session: Session, response: RespValue) =>

examples/resp3/main.pony

@@ -28,7 +28,9 @@ actor Client is (SessionStatusNotify & ResultReceiver)
       ["HSET"; "_resp3_example"; "name"; "Pony"; "version"; "0.60"]
     session.execute(cmd, this)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect.")
 
   be redis_response(session: Session, response: RespValue) =>

examples/ssl/main.pony

@@ -48,7 +48,9 @@ actor Client is (SessionStatusNotify & ResultReceiver)
     let cmd: Array[ByteSeq] val = ["PING"]
     session.execute(cmd, this)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _out.print("Failed to connect (TLS handshake or TCP failure).")
 
   be redis_response(session: Session, response: RespValue) =>

redis/_mort.pony

@@ -1,6 +1,6 @@
-use @exit[None](status: U8)
-use @fprintf[I32](stream: Pointer[U8] tag, fmt: Pointer[U8] tag, ...)
-use @pony_os_stderr[Pointer[U8]]()
+use @exit[None](status: I32)
+use @fprintf[I32](stream: Pointer[None] tag, fmt: Pointer[U8] tag, ...)
+use @pony_os_stderr[Pointer[None]]()
 
 primitive _IllegalState
   """

redis/_test_session.pony

@@ -51,7 +51,9 @@ actor \nodoc\ _ConnectAndReadyNotify is SessionStatusNotify
     _done = true
     _h.complete(true)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -140,7 +142,9 @@ actor \nodoc\ _SetAndGetClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -175,7 +179,9 @@ actor \nodoc\ _ConnectionFailureNotify is SessionStatusNotify
   new create(h: TestHelper) =>
     _h = h
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _done = true
     _h.complete(true)
 
@@ -285,7 +291,9 @@ actor \nodoc\ _ExecuteAfterCloseClient is
     _h.fail("Should not have received a response")
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -380,7 +388,9 @@ actor \nodoc\ _MultipleCommandsClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -480,7 +490,9 @@ actor \nodoc\ _PipelineClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -583,7 +595,9 @@ actor \nodoc\ _PipelineMixedClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -659,7 +673,9 @@ actor \nodoc\ _PipelineCloseClient is (SessionStatusNotify & ResultReceiver)
       _h.complete(false)
     end
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -709,7 +725,9 @@ actor \nodoc\ _ServerErrorClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -798,7 +816,9 @@ actor \nodoc\ _PubSubClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -895,7 +915,9 @@ actor \nodoc\ _PubSubPatternClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -967,7 +989,9 @@ actor \nodoc\ _ExecuteWhileSubscribedClient is
     _h.fail("Should not have received a response while subscribed")
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1050,7 +1074,9 @@ actor \nodoc\ _PubSubBackToReadyClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1168,7 +1194,9 @@ actor \nodoc\ _PipelineDrainClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1211,7 +1239,9 @@ actor \nodoc\ _SSLConnectionFailureNotify is SessionStatusNotify
   new create(h: TestHelper) =>
     _h = h
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _done = true
     _h.complete(true)
 
@@ -1260,7 +1290,9 @@ actor \nodoc\ _SSLConnectAndReadyNotify is SessionStatusNotify
     _done = true
     _h.complete(true)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("SSL connection failed")
     _h.complete(false)
 
@@ -1356,7 +1388,9 @@ actor \nodoc\ _SSLSetAndGetClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("SSL connection failed")
     _h.complete(false)
 
@@ -1394,7 +1428,9 @@ actor \nodoc\ _Resp3ConnectAndReadyNotify is SessionStatusNotify
     _done = true
     _h.complete(true)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1484,7 +1520,9 @@ actor \nodoc\ _Resp3SetAndGetClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1575,7 +1613,9 @@ actor \nodoc\ _Resp3FallbackClient is (SessionStatusNotify & ResultReceiver)
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection to RESP2-only server failed")
     _h.complete(false)
 
@@ -1653,7 +1693,9 @@ actor \nodoc\ _CommandApiSetAndGetClient is
     _h.fail("Command failed: " + failure.message())
     _h.complete(false)
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection failed")
     _h.complete(false)
 
@@ -1783,7 +1825,9 @@ actor \nodoc\ _BackpressureOverflowClient is
       _h.complete(false)
     end
 
-  be redis_session_connection_failed(session: Session) =>
+  be redis_session_connection_failed(session: Session,
+    reason: ConnectionFailureReason)
+  =>
     _h.fail("Connection to fake server failed")
     _h.complete(false)