add basic apis for converting to web Request/Response (#5896)

Author: tim-smart

.changeset/blue-onions-stop.md

@@ -0,0 +1,5 @@
+---
+"@effect/platform": patch
+---
+
+add basic apis for converting to web Request/Response

packages/platform/src/HttpServerRequest.ts

@@ -5,17 +5,17 @@ import type { Channel } from "effect/Channel"
 import type { Chunk } from "effect/Chunk"
 import type * as Context from "effect/Context"
 import type * as Effect from "effect/Effect"
-import type { Option } from "effect/Option"
+import * as Option from "effect/Option"
 import type * as ParseResult from "effect/ParseResult"
 import type { ReadonlyRecord } from "effect/Record"
 import type * as Schema from "effect/Schema"
 import type { ParseOptions } from "effect/SchemaAST"
 import type * as Scope from "effect/Scope"
-import type * as Stream from "effect/Stream"
+import * as Stream from "effect/Stream"
 import type * as FileSystem from "./FileSystem.js"
 import type * as Headers from "./Headers.js"
 import type * as IncomingMessage from "./HttpIncomingMessage.js"
-import type { HttpMethod } from "./HttpMethod.js"
+import { hasBody, type HttpMethod } from "./HttpMethod.js"
 import type * as Error from "./HttpServerError.js"
 import * as internal from "./internal/httpServerRequest.js"
 import type * as Multipart from "./Multipart.js"
@@ -235,4 +235,21 @@ export const fromWeb: (request: Request) => HttpServerRequest = internal.fromWeb
  * @since 1.0.0
  * @category conversions
  */
-export const toURL: (self: HttpServerRequest) => Option<URL> = internal.toURL
+export const toWeb = (self: HttpServerRequest): Request | undefined => {
+  if (self.source instanceof Request) {
+    return self.source
+  }
+  const ourl = toURL(self)
+  if (Option.isNone(ourl)) return undefined
+  return new Request(ourl.value, {
+    method: self.method,
+    body: hasBody(self.method) ? Stream.toReadableStream(self.stream) : undefined,
+    headers: self.headers
+  })
+}
+
+/**
+ * @since 1.0.0
+ * @category conversions
+ */
+export const toURL: (self: HttpServerRequest) => Option.Option<URL> = internal.toURL

packages/platform/src/HttpServerResponse.ts

@@ -6,12 +6,13 @@ import type { Inspectable } from "effect/Inspectable"
 import type * as Runtime from "effect/Runtime"
 import type * as Schema from "effect/Schema"
 import type { ParseOptions } from "effect/SchemaAST"
-import type * as Stream from "effect/Stream"
-import type { Cookie, Cookies, CookiesError } from "./Cookies.js"
+import * as Stream from "effect/Stream"
+import type { Cookie, CookiesError } from "./Cookies.js"
+import * as Cookies from "./Cookies.js"
 import type * as PlatformError from "./Error.js"
 import type * as FileSystem from "./FileSystem.js"
 import type * as Headers from "./Headers.js"
-import type * as Body from "./HttpBody.js"
+import * as Body from "./HttpBody.js"
 import type * as Platform from "./HttpPlatform.js"
 import type { Respondable } from "./HttpServerRespondable.js"
 import * as internal from "./internal/httpServerResponse.js"
@@ -39,7 +40,7 @@ export interface HttpServerResponse extends Effect.Effect<HttpServerResponse>, I
   readonly status: number
   readonly statusText?: string | undefined
   readonly headers: Headers.Headers
-  readonly cookies: Cookies
+  readonly cookies: Cookies.Cookies
   readonly body: Body.HttpBody
 }
 
@@ -51,7 +52,7 @@ export interface Options {
   readonly status?: number | undefined
   readonly statusText?: string | undefined
   readonly headers?: Headers.Input | undefined
-  readonly cookies?: Cookies | undefined
+  readonly cookies?: Cookies.Cookies | undefined
   readonly contentType?: string | undefined
   readonly contentLength?: number | undefined
 }
@@ -246,8 +247,8 @@ export const expireCookie: {
  * @category combinators
  */
 export const replaceCookies: {
-  (cookies: Cookies): (self: HttpServerResponse) => HttpServerResponse
-  (self: HttpServerResponse, cookies: Cookies): HttpServerResponse
+  (cookies: Cookies.Cookies): (self: HttpServerResponse) => HttpServerResponse
+  (self: HttpServerResponse, cookies: Cookies.Cookies): HttpServerResponse
 } = internal.replaceCookies
 
 /**
@@ -299,17 +300,17 @@ export const unsafeSetCookie: {
  * @category combinators
  */
 export const updateCookies: {
-  (f: (cookies: Cookies) => Cookies): (self: HttpServerResponse) => HttpServerResponse
-  (self: HttpServerResponse, f: (cookies: Cookies) => Cookies): HttpServerResponse
+  (f: (cookies: Cookies.Cookies) => Cookies.Cookies): (self: HttpServerResponse) => HttpServerResponse
+  (self: HttpServerResponse, f: (cookies: Cookies.Cookies) => Cookies.Cookies): HttpServerResponse
 } = internal.updateCookies
 
 /**
  * @since 1.0.0
  * @category combinators
  */
 export const mergeCookies: {
-  (cookies: Cookies): (self: HttpServerResponse) => HttpServerResponse
-  (self: HttpServerResponse, cookies: Cookies): HttpServerResponse
+  (cookies: Cookies.Cookies): (self: HttpServerResponse) => HttpServerResponse
+  (self: HttpServerResponse, cookies: Cookies.Cookies): HttpServerResponse
 } = internal.mergeCookies
 
 /**
@@ -393,3 +394,29 @@ export const toWeb: (
     readonly runtime?: Runtime.Runtime<never> | undefined
   }
 ) => Response = internal.toWeb
+
+/**
+ * @since 1.0.0
+ * @category conversions
+ */
+export const fromWeb = (response: Response): HttpServerResponse => {
+  const headers = response.headers
+  const setCookieHeaders = headers.getSetCookie()
+  headers.delete("set-cookie")
+  let self = empty({
+    status: response.status,
+    statusText: response.statusText,
+    headers: headers as any,
+    cookies: Cookies.fromSetCookie(setCookieHeaders)
+  })
+  if (response.body) {
+    self = setBody(
+      self,
+      Body.stream(Stream.fromReadableStream({
+        evaluate: () => response.body!,
+        onError: (e) => e
+      }))
+    )
+  }
+  return self
+}