Update code to use new dependencies

Author: JordanMartinez

spago.dhall

@@ -7,6 +7,7 @@
   , "functions"
   , "maybe"
   , "node-buffer"
+  , "node-event-emitter"
   , "node-fs"
   , "node-net"
   , "node-path"
@@ -15,7 +16,7 @@
   , "nullable"
   , "partial"
   , "prelude"
-  , "typelevel-prelude"
+  , "unsafe-coerce"
   ]
 , packages = ./packages.dhall
 , sources = [ "src/**/*.purs" ]

src/Node/Http2/Client.js

@@ -2,6 +2,3 @@ import http2 from "node:http2";
 
 export const connectAuthImpl = (auth) => http2.connect(auth);
 export const connectAuthOptionsImpl = (auth, options) => http2.connect(auth, options);
-
-const undefined_ = undefined;
-export { undefined_ as undefined }

src/Node/Http2/Client.purs

@@ -1,101 +1,27 @@
 module Node.Http2.Client
-  ( ConnectOptions
-  , connect
+  ( connect
   , connect'
   ) where
 
 import Effect (Effect)
 import Effect.Uncurried (EffectFn1, EffectFn2, runEffectFn1, runEffectFn2)
-import Node.Buffer.Immutable (ImmutableBuffer)
-import Node.Http2.Types (Client, Http2Session, Settings, TlsSecureContextOptions)
-import Node.Net.Socket (Socket)
+import Node.Http2.Types (Http2ClientConnectOptions, Http2Session)
+import Node.Net.Types (ConnectTcpOptions)
+import Node.TLS.Types (Client, ConnectTlsSocketOptions, CreateSecureContextOptions)
 import Prim.Row as Row
-import Type.Row (type (+))
 
 connect :: String -> Effect (Http2Session Client)
 connect authority = runEffectFn1 connectAuthImpl authority
 
 foreign import connectAuthImpl :: EffectFn1 (String) (Http2Session Client)
 
--- | `maxDeflateDynamicTableSize` <number> Sets the maximum dynamic table size for deflating header fields. Default: 4Kib.
--- | `maxSettings` <number> Sets the maximum number of settings entries per SETTINGS frame. The minimum value allowed is 1. Default: 32.
--- | `maxSessionMemory`<number> Sets the maximum memory that the Http2Session is permitted to use. The value is expressed in terms of number of megabytes, e.g. 1 equal 1 megabyte. The minimum value allowed is 1. This is a credit based limit, existing Http2Streams may cause this limit to be exceeded, but new Http2Stream instances will be rejected while this limit is exceeded. The current number of Http2Stream sessions, the current memory use of the header compression tables, current data queued to be sent, and unacknowledged PING and SETTINGS frames are all counted towards the current limit. Default: 10.
--- | `maxHeaderListPairs` <number> Sets the maximum number of header entries. This is similar to server.maxHeadersCount or request.maxHeadersCount in the node:http module. The minimum value is 1. Default: 128.
--- | `maxOutstandingPings` <number> Sets the maximum number of outstanding, unacknowledged pings. Default: 10.
--- | `maxReservedRemoteStreams` <number> Sets the maximum number of reserved push streams the client will accept at any given time. Once the current number of currently reserved push streams exceeds reaches this limit, new push streams sent by the server will be automatically rejected. The minimum allowed value is 0. The maximum allowed value is 232-1. A negative value sets this option to the maximum allowed value. Default: 200.
--- | `maxSendHeaderBlockLength` <number> Sets the maximum allowed size for a serialized, compressed block of headers. Attempts to send headers that exceed this limit will result in a 'frameError' event being emitted and the stream being closed and destroyed.
--- | `paddingStrategy` <number> Strategy used for determining the amount of padding to use for HEADERS and DATA frames. Default: http2.constants.PADDING_STRATEGY_NONE. Value may be one of:
--- | `peerMaxConcurrentStreams` <number> Sets the maximum number of concurrent streams for the remote peer as if a SETTINGS frame had been received. Will be overridden if the remote peer sets its own value for maxConcurrentStreams. Default: 100.
--- | `protocol` <string> The protocol to connect with, if not set in the authority. Value may be either 'http:' or 'https:'. Default: 'https:'
--- | `settings` <HTTP/2 Settings Object> The initial settings to send to the remote peer upon connection.
--- | `createConnection` <Function> An optional callback that receives the URL instance passed to connect and the options object, and returns any Duplex stream that is to be used as the connection for this session.
--- | `unknownProtocolTimeout` <number> Specifies a timeout in milliseconds that a server should wait when an 'unknownProtocol' event is emitted. If the socket has not been destroyed by that time the server will destroy it. Default: 10000.
--- |
--- | Note: `createConnection` is not supported for now.
-type ConnectOptions :: (Type -> Type) -> Row Type -> Row Type
-type ConnectOptions f r =
-  ( maxDeflateDynamicTableSize :: f Int
-  , maxSettings :: f Int
-  , maxSessionMemory :: f Int
-  , maxHeaderListPairs :: f Int
-  , maxOutstandingPings :: f Int
-  , maxReservedRemoteStreams :: f Int
-  , maxSendHeaderBlockLength :: f Int
-  , paddingStrategy :: f Int
-  , peerMaxConcurrentStreams :: f Int
-  , protocol :: f String
-  , settings :: f Settings
-  -- , createConnection :: Function -- not supported for now.
-  , unknownProtocolTimeout :: f Int
-  | r
-  )
-
-type TlsConnectOptions :: (Type -> Type) -> Row Type -> Row Type
-type TlsConnectOptions f r =
-  ( enableTrace :: f Boolean
-  , socket :: f Socket
-  , allowHalfOpen :: f Boolean
-  , rejectUnauthorized :: f Boolean
-  -- , pskCallback :: <Function
-  , "ALPNProtocols" :: f (Array ImmutableBuffer)
-  , servername :: f String
-  -- , checkServerIdentity :: EffectFn2 String ? (Nullable Error) -- ignoring for now
-  , session :: f ImmutableBuffer
-  , minDHSize :: f Int
-  , highWaterMark :: f Int
-  -- , secureContext :: f TlsSecureContext -- ignoring for now
-  -- , onread :: <Object> -- ignoring
-  | r
-  )
-
-type TcpConnectOptions :: (Type -> Type) -> Row Type -> Row Type
-type TcpConnectOptions f r =
-  ( port :: f Int
-  , host :: f String
-  , localAddress :: f String
-  , localPort :: f Int
-  , family :: f Int
-  -- , hints :: f number
-  -- , lookup :: f Function
-  , noDelay :: f Boolean
-  , keepAlive :: f Boolean
-  , keepAliveInitialDelay :: f Number -- is this milliseconds or seconds?
-  -- , autoSelectFamily :: f Boolean
-  -- , autoSelectFamilyAttemptTimeout :: f number
-  | r
-  )
-
 connect'
   :: forall rec trash
-   . Row.Union rec trash (ConnectOptions Unlift + TlsConnectOptions Unlift + TlsSecureContextOptions Unlift + TcpConnectOptions Unlift + ())
+   . Row.Union rec trash (Http2ClientConnectOptions (ConnectTlsSocketOptions Client (CreateSecureContextOptions (ConnectTcpOptions ()))))
   => String
   -> { | rec }
   -> Effect (Http2Session Client)
 connect' authority rec = runEffectFn2 connectAuthOptionsImpl authority rec
 
 foreign import connectAuthOptionsImpl :: forall r. EffectFn2 (String) ({ | r }) (Http2Session Client)
 
-type Unlift :: Type -> Type
-type Unlift a = a
-
-foreign import undefined :: forall a. a

src/Node/Http2/Server.js

@@ -1,20 +1,6 @@
 import http2 from "node:http2";
 
 export const createSecureServerImpl = (opts) => http2.createSecureServer(opts);
-export const listenImpl = (s, o) => s.listen(o);
-
-const undefined_ = undefined;
-export { undefined_ as undefined }
-
-export const onCheckContinueImpl = (s, cb) => s.on("checkContinue", cb);
-export const onConnectionImpl = (s, cb) => s.on("connection", cb);
-export const onRequestImpl = (s, cb) => s.on("request", cb);
-export const onSessionImpl = (s, cb) => s.on("session", cb);
-export const onSessionErrorImpl = (s, cb) => s.on("sessionError", cb);
-export const onStreamImpl = (s, cb) => s.on("stream", cb);
-export const onTimeoutImpl = (s, cb) => s.on("timeout", cb);
-export const onUnknownProtocolImpl = (s, cb) => s.on("unknownProtocol", cb);
-export const closeImpl = (s) => s.close();
 export const setTimeoutImpl = (s, msecs) => s.setTimeout(msecs);
 export const timeoutImpl = (s) => s.timeout;
 export const updateSettingsImpl = (s, settings) => s.updateSettings(settings);