style: apply fantomas formatting

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: Nick Ficano

src/Arcp.Client/ArcpClient.fs

@@ -353,7 +353,9 @@ type ArcpClient(transport: ITransport, options: ArcpClientOptions) =
                 | Ok(Message.SessionError e) ->
                     return
                         raise (
-                            ArcpException(JobErrorMapper.ofWireWith e.Code e.Message e.Details e.Retryable (Some jobId.Value))
+                            ArcpException(
+                                JobErrorMapper.ofWireWith e.Code e.Message e.Details e.Retryable (Some jobId.Value)
+                            )
                         )
                 | _ -> return raise (ArcpException(ARCPError.InvalidRequest("Expected job.subscribed", None)))
         }

src/Arcp.Client/Internal/JobErrorMapper.fs

@@ -19,7 +19,9 @@ module internal JobErrorMapper =
         | _ -> None
 
     let private strField details name fallback =
-        prop details name |> Option.map (fun v -> v.GetString()) |> Option.defaultValue fallback
+        prop details name
+        |> Option.map (fun v -> v.GetString())
+        |> Option.defaultValue fallback
 
     let private intField details name fallback =
         prop details name

src/Arcp.Core/Json.fs

@@ -48,17 +48,24 @@ module internal JsonConverters =
             | Ok v -> v
             | Error e -> raise (JsonException e)
 
-        override _.Write(writer, value, _) = writer.WriteStringValue(JobStatus.toWire value)
+        override _.Write(writer, value, _) =
+            writer.WriteStringValue(JobStatus.toWire value)
 
     type LogLevelConverter() =
         inherit JsonConverter<LogLevel>()
         override _.Read(reader, _, _) = logLevelOfWire (reader.GetString())
-        override _.Write(writer, value, _) = writer.WriteStringValue(logLevelToWire value)
+
+        override _.Write(writer, value, _) =
+            writer.WriteStringValue(logLevelToWire value)
 
     type ChunkEncodingConverter() =
         inherit JsonConverter<ChunkEncoding>()
-        override _.Read(reader, _, _) = chunkEncodingOfWire (reader.GetString())
-        override _.Write(writer, value, _) = writer.WriteStringValue(chunkEncodingToWire value)
+
+        override _.Read(reader, _, _) =
+            chunkEncodingOfWire (reader.GetString())
+
+        override _.Write(writer, value, _) =
+            writer.WriteStringValue(chunkEncodingToWire value)
 
     /// `LeaseGrant` is wire-encoded as a bare namespace→patterns map
     /// (§9.1, §9.2), not a `{ "capabilities": {...} }` wrapper.
@@ -86,8 +93,12 @@ module internal JsonConverters =
                 | _ -> None
 
             {
-                CostBudget = prop "cost.budget" |> Option.map (fun v -> JsonSerializer.Deserialize<string list>(v.GetRawText(), options))
-                ModelUse = prop "model.use" |> Option.map (fun v -> JsonSerializer.Deserialize<string list>(v.GetRawText(), options))
+                CostBudget =
+                    prop "cost.budget"
+                    |> Option.map (fun v -> JsonSerializer.Deserialize<string list>(v.GetRawText(), options))
+                ModelUse =
+                    prop "model.use"
+                    |> Option.map (fun v -> JsonSerializer.Deserialize<string list>(v.GetRawText(), options))
                 ExpiresAt = prop "expires_at" |> Option.map (fun v -> v.GetDateTimeOffset())
             }
 
@@ -139,7 +150,8 @@ module internal JsonConverters =
 
             match value with
             | AgentInventory.Flat names -> names |> List.iter writer.WriteStringValue
-            | AgentInventory.Rich entries -> entries |> List.iter (fun e -> JsonSerializer.Serialize(writer, e, options))
+            | AgentInventory.Rich entries ->
+                entries |> List.iter (fun e -> JsonSerializer.Serialize(writer, e, options))
 
             writer.WriteEndArray()
 
@@ -226,12 +238,14 @@ module internal JsonConverters =
             | true, v when v.ValueKind <> JsonValueKind.Null -> Some v
             | _ -> None
 
-        let optStr name = opt name |> Option.map (fun v -> v.GetString())
+        let optStr name =
+            opt name |> Option.map (fun v -> v.GetString())
 
         match kind with
         | "log" -> JobEventBody.Log(logLevelOfWire ((req "level").GetString()), (req "message").GetString())
         | "thought" -> JobEventBody.Thought((req "text").GetString())
-        | "tool_call" -> JobEventBody.ToolCall((req "tool").GetString(), (req "args").Clone(), (req "call_id").GetString())
+        | "tool_call" ->
+            JobEventBody.ToolCall((req "tool").GetString(), (req "args").Clone(), (req "call_id").GetString())
         | "tool_result" ->
             let callId = (req "call_id").GetString()
 

src/Arcp.Runtime/ArcpServer.fs

@@ -260,10 +260,18 @@ type ArcpServer(options: ArcpServerOptions) =
                         )
 
                     let redactedBody =
-                        JobEventBody.Status(StatusPhases.CredentialRotated, Some(Json.serialize {| id = credentialId |}))
+                        JobEventBody.Status(
+                            StatusPhases.CredentialRotated,
+                            Some(Json.serialize {| id = credentialId |})
+                        )
 
                     let! ownerSeq =
-                        EnvelopeOut.pushJobEventSeq sessions options.TimeProvider record.SessionId record.JobId ownerBody
+                        EnvelopeOut.pushJobEventSeq
+                            sessions
+                            options.TimeProvider
+                            record.SessionId
+                            record.JobId
+                            ownerBody
 
                     for sid in jobs.Subscriptions.Subscribers record.JobId do
                         do! EnvelopeOut.pushJobEvent sessions options.TimeProvider sid record.JobId redactedBody
@@ -468,7 +476,9 @@ type ArcpServer(options: ArcpServerOptions) =
                         | None -> true
                         | Some f ->
                             (f.Status |> Option.map (List.contains r.Status) |> Option.defaultValue true)
-                            && (f.Agent |> Option.map (fun a -> agentMatches a r.Agent) |> Option.defaultValue true)
+                            && (f.Agent
+                                |> Option.map (fun a -> agentMatches a r.Agent)
+                                |> Option.defaultValue true)
                             && (f.CreatedAfter
                                 |> Option.map (fun ca -> r.CreatedAt >= ca)
                                 |> Option.defaultValue true))
@@ -657,7 +667,8 @@ type ArcpServer(options: ArcpServerOptions) =
         (ct: CancellationToken)
         : Task<bool> =
         task {
-            let windowError = ARCPError.ResumeWindowExpired(resume.LastEventSeq, options.ResumeWindowSec)
+            let windowError =
+                ARCPError.ResumeWindowExpired(resume.LastEventSeq, options.ResumeWindowSec)
 
             let writeError (err: ARCPError) : Task =
                 let payload: SessionErrorPayload =

src/Arcp.Runtime/Auth/Bearer.fs

@@ -25,7 +25,12 @@ type StaticBearerVerifier(tokens: IReadOnlyDictionary<string, string>) =
                     |> Seq.tryPick (fun kv ->
                         let candidate = Encoding.UTF8.GetBytes kv.Key
 
-                        if CryptographicOperations.FixedTimeEquals(ReadOnlySpan<byte>(presented), ReadOnlySpan<byte>(candidate)) then
+                        if
+                            CryptographicOperations.FixedTimeEquals(
+                                ReadOnlySpan<byte>(presented),
+                                ReadOnlySpan<byte>(candidate)
+                            )
+                        then
                             Some kv.Value
                         else
                             None)

src/Arcp.Runtime/CredentialProvisioner.fs

@@ -69,4 +69,6 @@ type InMemoryCredentialStore() =
 type NoOpCredentialProvisioner() =
     interface ICredentialProvisioner with
         member _.IssueAsync(_ctx, _ct) = Task.FromResult []
-        member _.RevokeAsync(_id, _ct) = Task.FromResult RevocationOutcome.Revoked
+
+        member _.RevokeAsync(_id, _ct) =
+            Task.FromResult RevocationOutcome.Revoked