1
0

HttpResponse.swift 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. //
  2. // HttpResponse.swift
  3. // Swifter
  4. //
  5. // Copyright (c) 2014-2016 Damian Kołakowski. All rights reserved.
  6. //
  7. import Foundation
  8. public enum SerializationError: Error {
  9. case invalidObject
  10. case notSupported
  11. }
  12. public protocol HttpResponseBodyWriter {
  13. func write(_ file: String.File) throws
  14. func write(_ data: [UInt8]) throws
  15. func write(_ data: ArraySlice<UInt8>) throws
  16. func write(_ data: NSData) throws
  17. func write(_ data: Data) throws
  18. }
  19. public enum HttpResponseBody {
  20. case json(AnyObject)
  21. case html(String)
  22. case text(String)
  23. case data(Data)
  24. case custom(Any, (Any) throws -> String)
  25. func content() -> (Int, ((HttpResponseBodyWriter) throws -> Void)?) {
  26. do {
  27. switch self {
  28. case .json(let object):
  29. #if os(Linux)
  30. let data = [UInt8]("Not ready for Linux.".utf8)
  31. return (data.count, {
  32. try $0.write(data)
  33. })
  34. #else
  35. guard JSONSerialization.isValidJSONObject(object) else {
  36. throw SerializationError.invalidObject
  37. }
  38. let data = try JSONSerialization.data(withJSONObject: object)
  39. return (data.count, {
  40. try $0.write(data)
  41. })
  42. #endif
  43. case .text(let body):
  44. let data = [UInt8](body.utf8)
  45. return (data.count, {
  46. try $0.write(data)
  47. })
  48. case .html(let body):
  49. let serialised = "<html><meta charset=\"UTF-8\"><body>\(body)</body></html>"
  50. let data = [UInt8](serialised.utf8)
  51. return (data.count, {
  52. try $0.write(data)
  53. })
  54. case .data(let data):
  55. return (data.count, {
  56. try $0.write(data)
  57. })
  58. case .custom(let object, let closure):
  59. let serialised = try closure(object)
  60. let data = [UInt8](serialised.utf8)
  61. return (data.count, {
  62. try $0.write(data)
  63. })
  64. }
  65. } catch {
  66. let data = [UInt8]("Serialisation error: \(error)".utf8)
  67. return (data.count, {
  68. try $0.write(data)
  69. })
  70. }
  71. }
  72. }
  73. // swiftlint:disable cyclomatic_complexity
  74. public enum HttpResponse {
  75. case switchProtocols([String: String], (Socket) -> Void)
  76. case ok(HttpResponseBody), created, accepted
  77. case movedPermanently(String)
  78. case movedTemporarily(String)
  79. case badRequest(HttpResponseBody?), unauthorized, forbidden, notFound
  80. case internalServerError
  81. case raw(Int, String, [String:String]?, ((HttpResponseBodyWriter) throws -> Void)? )
  82. public var statusCode: Int {
  83. switch self {
  84. case .switchProtocols : return 101
  85. case .ok : return 200
  86. case .created : return 201
  87. case .accepted : return 202
  88. case .movedPermanently : return 301
  89. case .movedTemporarily : return 307
  90. case .badRequest : return 400
  91. case .unauthorized : return 401
  92. case .forbidden : return 403
  93. case .notFound : return 404
  94. case .internalServerError : return 500
  95. case .raw(let code, _, _, _) : return code
  96. }
  97. }
  98. public var reasonPhrase: String {
  99. switch self {
  100. case .switchProtocols : return "Switching Protocols"
  101. case .ok : return "OK"
  102. case .created : return "Created"
  103. case .accepted : return "Accepted"
  104. case .movedPermanently : return "Moved Permanently"
  105. case .movedTemporarily : return "Moved Temporarily"
  106. case .badRequest : return "Bad Request"
  107. case .unauthorized : return "Unauthorized"
  108. case .forbidden : return "Forbidden"
  109. case .notFound : return "Not Found"
  110. case .internalServerError : return "Internal Server Error"
  111. case .raw(_, let phrase, _, _) : return phrase
  112. }
  113. }
  114. public func headers() -> [String: String] {
  115. var headers = ["Server": "Swifter \(HttpServer.VERSION)"]
  116. switch self {
  117. case .switchProtocols(let switchHeaders, _):
  118. for (key, value) in switchHeaders {
  119. headers[key] = value
  120. }
  121. case .ok(let body):
  122. switch body {
  123. case .json: headers["Content-Type"] = "application/json"
  124. case .html: headers["Content-Type"] = "text/html"
  125. default:break
  126. }
  127. case .movedPermanently(let location):
  128. headers["Location"] = location
  129. case .movedTemporarily(let location):
  130. headers["Location"] = location
  131. case .raw(_, _, let rawHeaders, _):
  132. if let rawHeaders = rawHeaders {
  133. for (key, value) in rawHeaders {
  134. headers.updateValue(value, forKey: key)
  135. }
  136. }
  137. default:break
  138. }
  139. return headers
  140. }
  141. func content() -> (length: Int, write: ((HttpResponseBodyWriter) throws -> Void)?) {
  142. switch self {
  143. case .ok(let body) : return body.content()
  144. case .badRequest(let body) : return body?.content() ?? (-1, nil)
  145. case .raw(_, _, _, let writer) : return (-1, writer)
  146. default : return (-1, nil)
  147. }
  148. }
  149. func socketSession() -> ((Socket) -> Void)? {
  150. switch self {
  151. case .switchProtocols(_, let handler) : return handler
  152. default: return nil
  153. }
  154. }
  155. }
  156. /**
  157. Makes it possible to compare handler responses with '==', but
  158. ignores any associated values. This should generally be what
  159. you want. E.g.:
  160. let resp = handler(updatedRequest)
  161. if resp == .NotFound {
  162. print("Client requested not found: \(request.url)")
  163. }
  164. */
  165. func == (inLeft: HttpResponse, inRight: HttpResponse) -> Bool {
  166. return inLeft.statusCode == inRight.statusCode
  167. }