remove all json serialization

Author: AndrewBarba

Sources/Compute/Cache.swift

@@ -48,23 +48,12 @@ public struct Cache: Sendable {
         return try .init(trx)
     }
 
-    public static func getOrSet(
-        _ key: String, _ handler: () async throws -> ([String: Sendable], CachePolicy)
-    ) async throws -> Entry {
-        let trx = try await Fastly.Cache.getOrSet(key) {
-            let (json, cachePolicy) = try await handler()
-            let data = try JSONSerialization.data(withJSONObject: json)
-            return (.bytes(data.bytes), cachePolicy)
-        }
-        return try .init(trx)
-    }
-
-    public static func getOrSet(
-        _ key: String, _ handler: () async throws -> ([Sendable], CachePolicy)
+    public static func getOrSet<T: Encodable>(
+        _ key: String, _ handler: () async throws -> (T, CachePolicy)
     ) async throws -> Entry {
         let trx = try await Fastly.Cache.getOrSet(key) {
             let (json, cachePolicy) = try await handler()
-            let data = try JSONSerialization.data(withJSONObject: json)
+            let data = try JSONEncoder().encode(json)
             return (.bytes(data.bytes), cachePolicy)
         }
         return try .init(trx)

Sources/Compute/Compute.swift

@@ -5,7 +5,11 @@
 //  Created by Andrew Barba on 1/11/22.
 //
 
-@_exported import Foundation
+#if canImport(FoundationEssentials)
+    @_exported import FoundationEssentials
+#else
+    @_exported import Foundation
+#endif
 
 @MainActor
 public func onIncomingRequest(

Sources/Compute/Console.swift

@@ -25,24 +25,6 @@ public struct Console: Sendable {
     }
 
     public func error(_ items: Any...) {
-        var errorStream = StandardErrorOutputStream()
-        let text = items.map { String(describing: $0) }.joined(separator: " ")
-        if let prefix = prefix {
-            print(prefix, text, to: &errorStream)
-        } else {
-            print(text, to: &errorStream)
-        }
-    }
-}
-
-private struct StandardErrorOutputStream: TextOutputStream {
-
-    private let stderr = FileHandle.standardError
-
-    func write(_ string: String) {
-        guard let data = string.data(using: .utf8) else {
-            return
-        }
-        stderr.write(data)
+        log("error:", items)
     }
 }

Sources/Compute/Fanout/FanoutClient.swift

@@ -52,29 +52,6 @@ public struct FanoutClient: Sendable {
         let content = try encoder.encode(value)
         return try await publish(content, to: channel)
     }
-
-    @discardableResult
-    public func publish(_ json: Any, to channel: String) async throws -> FetchResponse {
-        let data = try JSONSerialization.data(withJSONObject: json)
-        let content = String(data: data, encoding: .utf8)
-        return try await publish(content, to: channel)
-    }
-
-    @discardableResult
-    public func publish(_ jsonObject: [String: Any], to channel: String) async throws
-        -> FetchResponse
-    {
-        let data = try JSONSerialization.data(withJSONObject: jsonObject)
-        let content = String(data: data, encoding: .utf8)
-        return try await publish(content, to: channel)
-    }
-
-    @discardableResult
-    public func publish(_ jsonArray: [Any], to channel: String) async throws -> FetchResponse {
-        let data = try JSONSerialization.data(withJSONObject: jsonArray)
-        let content = String(data: data, encoding: .utf8)
-        return try await publish(content, to: channel)
-    }
 }
 
 extension FanoutClient {

Sources/Compute/Fanout/FanoutMessage.swift

@@ -74,18 +74,6 @@ extension FanoutMessage {
         return try decoder.decode(type, from: data())
     }
 
-    public func json<T: Sendable>() throws -> T {
-        return try JSONSerialization.jsonObject(with: data()) as! T
-    }
-
-    public func jsonObject() throws -> [String: Sendable] {
-        return try json()
-    }
-
-    public func jsonArray() throws -> [Sendable] {
-        return try json()
-    }
-
     public func data() throws -> Data {
         guard let data = content.data(using: .utf8) else {
             throw FanoutMessageError.invalidFormat

Sources/Compute/Fanout/IncomingRequest+Fanout.swift

@@ -38,7 +38,7 @@ extension IncomingRequest {
         guard let token = headers[.gripSig] else {
             throw FanoutRequestError.invalidSignature
         }
-        let jwt = try JWT(token: token)
+        let jwt = try JWT<EmptyJWTPayload>(token: token)
         try jwt.verify(key: fanoutPublicKey)
     }
 

Sources/Compute/Fastly/FastlyLogger.swift

@@ -37,24 +37,6 @@ extension Fastly {
             return try write(data)
         }
 
-        @discardableResult
-        public func write(
-            _ jsonObject: [String: Any],
-            options: JSONSerialization.WritingOptions = [.sortedKeys]
-        ) throws -> Int {
-            let data = try JSONSerialization.data(withJSONObject: jsonObject, options: options)
-            return try write(data)
-        }
-
-        @discardableResult
-        public func write(
-            _ jsonArray: [Any],
-            options: JSONSerialization.WritingOptions = [.sortedKeys]
-        ) throws -> Int {
-            let data = try JSONSerialization.data(withJSONObject: jsonArray, options: options)
-            return try write(data)
-        }
-
         @discardableResult
         public func write(_ data: Data) throws -> Int {
             let text = String(bytes: data, encoding: .utf8) ?? ""

Sources/Compute/Fastly/FastlyUtils.swift

@@ -94,8 +94,7 @@ extension DataProtocol {
     }
 }
 
-extension CharacterSet {
-
-    static let javascriptURLAllowed: CharacterSet =
-        .alphanumerics.union(.init(charactersIn: "-_.!~*'()"))  // as per RFC 3986
-}
+// extension CharacterSet {
+//     static let javascriptURLAllowed: CharacterSet =
+//         .alphanumerics.union(.init(charactersIn: "-_.!~*'()"))  // as per RFC 3986
+// }

Sources/Compute/Fetch/FetchRequest.swift

@@ -116,16 +116,6 @@ extension FetchRequest {
             return Body.json(data)
         }
 
-        public static func json(_ jsonObject: [String: Any]) throws -> Body {
-            let data = try JSONSerialization.data(withJSONObject: jsonObject)
-            return Body.json(data)
-        }
-
-        public static func json(_ jsonArray: [Any]) throws -> Body {
-            let data = try JSONSerialization.data(withJSONObject: jsonArray)
-            return Body.json(data)
-        }
-
         public var defaultContentType: String? {
             switch self {
             case .json:

Sources/Compute/Fetch/FetchResponse.swift

@@ -41,18 +41,6 @@ extension FetchResponse {
         return try await body.decode(type, decoder: decoder)
     }
 
-    public func json<T: Sendable>() async throws -> T {
-        return try await body.json()
-    }
-
-    public func jsonObject() async throws -> [String: Sendable] {
-        return try await body.jsonObject()
-    }
-
-    public func jsonArray() async throws -> [Sendable] {
-        return try await body.jsonArray()
-    }
-
     public func formValues() async throws -> HTTPSearchParams {
         return try await body.formValues()
     }