Initial attempt at writing an example (broken)

Looks like Node doesn't like it when some
options are `undefined`...

Author: JordanMartinez

test.dhall

@@ -1,6 +1,28 @@
 { name = "node-http2-tests"
 , dependencies =
-  [ "console", "effect", "node-event-emitter", "prelude", "spec" ]
+  [ "arrays"
+  , "console"
+  , "datetime"
+  , "effect"
+  , "either"
+  , "exceptions"
+  , "foldable-traversable"
+  , "foreign-object"
+  , "functions"
+  , "maybe"
+  , "node-buffer"
+  , "node-fs"
+  , "node-net"
+  , "node-path"
+  , "node-streams"
+  , "nullable"
+  , "partial"
+  , "prelude"
+  , "refs"
+  , "spec"
+  , "typelevel-prelude"
+  , "unsafe-coerce"
+  ]
 , packages = ./packages.dhall
 , sources = [ "src/**/*.purs", "test/**/*.purs" ]
 }

test/Test/Main.purs

@@ -2,5 +2,101 @@ module Test.Main where
 
 import Prelude
 
+import Data.Array as Array
+import Data.FoldableWithIndex (forWithIndex_, traverseWithIndex_)
+import Data.Maybe (Maybe(..))
+import Effect (Effect)
+import Effect.Class.Console (log)
+import Effect.Exception as Exception
+import Effect.Ref as Ref
+import Foreign.Object (Object)
+import Node.Buffer as Buffer
+import Node.Buffer.Immutable (ImmutableBuffer)
+import Node.Encoding (Encoding(..))
+import Node.FS.Sync as FS
+import Node.Http2.Client as Client
+import Node.Http2.Constants as NGHTTP2
+import Node.Http2.Server as Server
+import Node.Http2.Session as Session
+import Node.Http2.Stream (session, toDuplex)
+import Node.Http2.Stream as H2Stream
+import Node.Path as Path
+import Node.Stream as Stream
+import Unsafe.Coerce (unsafeCoerce)
+
+unsafeToImmutableBuffer :: Buffer.Buffer -> Effect ImmutableBuffer
+unsafeToImmutableBuffer = Buffer.unsafeFreeze
+
 main :: Effect Unit
-main = pure unit
+main = do
+  privateKey <- FS.readFile (Path.concat [ "test", "localhost-privkey.pem" ]) >>= unsafeToImmutableBuffer
+  cert <- FS.readFile (Path.concat [ "test", "localhost-cert.pem" ]) >>= unsafeToImmutableBuffer
+  server <- Server.createSecureServer
+    ( _
+        { key = Just [ privateKey ]
+        , cert = Just [ cert ]
+        }
+    )
+  Server.onCheckContinue server \req res -> do
+    log "server - onCheckContinue"
+  Server.onConnection server \duplex -> do
+    log "server - onConnection"
+  Server.onSession server \session -> do
+    log "server - onSession"
+  Server.onSessionError server \err session -> do
+    log "server - onSessionError"
+    log (unsafeCoerce err)
+  Server.onStream server \stream headers flags rawHeaders -> do
+    streamId <- H2Stream.id stream
+    log $ "server - onStream for id: " <> show streamId
+    forWithIndex_ (unsafeCoerce headers :: Object String) \k v ->
+      log $ k <> ": " <> v
+    log $ "server - onStream - Flags: " <> show flags
+    log $ "server - onStream - Raw Headers: " <> show rawHeaders
+    let duplex = H2Stream.toDuplex stream
+    H2Stream.respond stream (unsafeCoerce { "an-http-header": "value" })
+      { endStream: true
+      , waitForTrailers: false
+      }
+    void $ Stream.writeString duplex UTF8 "hello from server" (const mempty)
+    void $ Stream.end duplex \_ -> do
+      H2Stream.close stream NGHTTP2.noError
+
+  Server.onTimeout server do
+    log "onTimeout"
+  Server.onUnknownProtocol server \duplex -> do
+    log "onUnknownProtocol"
+  let httpsPort = 443
+  Server.listen server
+    ( _
+        { port = Just httpsPort
+        }
+    )
+  session <- Client.connect' ("https://localhost:" <> show httpsPort)
+    (_ { ca = Just [ cert ] })
+  Session.onError session \error ->
+    log $ "Client session encountered error: " <> Exception.message error
+  stream <- Session.request session
+    ( unsafeCoerce
+        { ":method": "GET"
+        , ":path": "/"
+        }
+    )
+  let duplex = toDuplex stream
+  void $ Stream.end duplex (const mempty)
+  H2Stream.onResponse stream \headers flags -> do
+    log "client - onResponse"
+    forWithIndex_ (unsafeCoerce headers :: Object String) \k v ->
+      log $ k <> ": " <> v
+    log $ "Flags: " <> show flags
+    chunksRef <- Ref.new []
+    Stream.onData duplex \buf ->
+      Ref.modify_ (flip Array.snoc buf) chunksRef
+    Stream.onEnd duplex do
+      chunks <- Ref.read chunksRef
+      buffer <- Buffer.concat chunks :: Effect Buffer.Buffer
+      str <- Buffer.toString UTF8 buffer :: Effect String
+      log $ "client - onResponse body: " <> show str
+      H2Stream.close stream NGHTTP2.noError
+
+  Server.close server

test/localhost-cert.pem

@@ -0,0 +1,19 @@
+-----BEGIN CERTIFICATE-----
+MIIDCTCCAfGgAwIBAgIUXP5btASG8+hVETpcuFm9zvUv+E8wDQYJKoZIhvcNAQEL
+BQAwFDESMBAGA1UEAwwJbG9jYWxob3N0MB4XDTIzMDYxMzE2MjcyMVoXDTIzMDcx
+MzE2MjcyMVowFDESMBAGA1UEAwwJbG9jYWxob3N0MIIBIjANBgkqhkiG9w0BAQEF
+AAOCAQ8AMIIBCgKCAQEAnu6ejy4B8T7Z3oBa9pk+pwPliV6bwpjPYRzAN4NkuEVV
+1N5rnoTWGpWmgTD8oJkaopghZoDqEOxYuVs9bHmaiZID7pPydfgMkolrBwaHS15R
+/k5VizLPwYZJzdEvqnK4iqAM7JlCdJshZ6rDbOxtj7d/gbKEwqdWheTgOaEkPSO6
+/vtf1emCNDtvYGdNNkDFd1WoawVYRo3RXoGWxyrtC/dh7kW7jQbWZxxuzdYRSAVA
+LVja4jIn5Fhrno0bva3sIYjAoBiq/EYUsE1bUXrLW+lRYKSDUYE8jugJ8ZI2djTR
+IOedKecH4ymCYtSv9oIcjXTSA8Kwjm+t1SlrXUH86wIDAQABo1MwUTAdBgNVHQ4E
+FgQUpD9sHX3wId8wtXvY9t/vwQORB8gwHwYDVR0jBBgwFoAUpD9sHX3wId8wtXvY
+9t/vwQORB8gwDwYDVR0TAQH/BAUwAwEB/zANBgkqhkiG9w0BAQsFAAOCAQEAF7dM
+/O9Y0PRG1CVPlT6MRdaAlkiHYXviQSuZusUD4PKD74InOh/FZsE/JQ8+8+mkv2eX
+2WXtettBBTJI7uZqgiyNVMxS5OwZjB/dm9MfnL8IDQjOSy+/C2QdjXPHG44zAfqx
+b2yf6aJGzo+7ETQSFYXGVmipdYHX5Gg1m+pKVQWE3zFiKoaTg20rSRDPfLf6jm0V
+WeAtk7Fb+x6Mc7QT3FR+E2auC9UhSPh2kbgMraZKSqxlLURF+WOJ888tQAEAcywu
+doJhKR7NYKqdpqrA+NCghrDgT8vFhddaRw/XLOTuGJd90yuDPGnggV/OCcNKdD3l
+nlNX0boLyIjFSbqvnQ==
+-----END CERTIFICATE-----

test/localhost-privkey.pem

@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQCe7p6PLgHxPtne
+gFr2mT6nA+WJXpvCmM9hHMA3g2S4RVXU3muehNYalaaBMPygmRqimCFmgOoQ7Fi5
+Wz1seZqJkgPuk/J1+AySiWsHBodLXlH+TlWLMs/BhknN0S+qcriKoAzsmUJ0myFn
+qsNs7G2Pt3+BsoTCp1aF5OA5oSQ9I7r++1/V6YI0O29gZ002QMV3VahrBVhGjdFe
+gZbHKu0L92HuRbuNBtZnHG7N1hFIBUAtWNriMifkWGuejRu9rewhiMCgGKr8RhSw
+TVtRestb6VFgpINRgTyO6AnxkjZ2NNEg550p5wfjKYJi1K/2ghyNdNIDwrCOb63V
+KWtdQfzrAgMBAAECggEAD902TLw+0f0mk5JqjtC0IGKzFkR9Arsf51jB1qi4Z7mQ
+CQjPydZtMq3uaiXg8Am1G9BYp40sEAovcjnckzsK+G48eaOHh7JkIUczPKCW5g7u
+Dn1BbHzjBpu1B6TSTIHzNrvyhLY1nA/iETsXEusBcqxSP2vgDms6p6NopSGXGiN4
+tmZoA3Vnltkrc9dfQNT+0RLOsu48gIMhFnHLfhxWmvJx1wFD1mlG5oGpLNiCUgk4
+MNQp10LIRAsYmioL3H2xqcbgTBNYPrALgmBWGN0OryJ128lj6Q2q5HOPd4R7MO9x
+LCGLqB4ekBgM+3PBaQYXrWW6T0K36Ec/eFgBV56V1QKBgQDDmfidbhli+6mUQ+6r
+K9wFVOK4aILOaIFPy2o18t3mmoIFQvGHUeoIb5VY8mX4ApQIZwQ1pFcOL9SCT++j
+JxHpfbiaA82XjejsqL2fwY0f19ggXRpaTWZp+zJp7Xu4V8U1TlHAagpMzlQ/pOsF
+2WMq5IstG1lai9g1NEmvbzoGDQKBgQDQAfyKYR7UVDofUhFND9nNDsSMOL5lXZh7
+pJiwkU+TeCj6Sxps8rcBh6l5BnhCZxx4HMFHCtMlvdqiKfDwIc4paSB6NaLwEZoj
+aDMy0F0T06K7vI2srd71SqgjkHVDFdRGijYKVGsGa7iDngp4vWBpFIadzjniRdMr
+5UnIXZCI1wKBgQChHtOL2oVO475sQwj2NsqmGaYoAO6+15atBAIZLlVa/yra6qnJ
+rc/54vBCtGkKQhVuVm1BQn3zUbLbJL1gx24Zx1WoiDlx/ZNAXj7Uubpl4IZHImny
+uI8D/ccpOlYPIz1vC3SL6s1RNyRuyIpP5yGo01lRbpXL4CXYrZmEyToigQKBgQDE
+H+tfCn3IE/aNi5LWh0iESRVXZTVYXCynACYb7ZcLY/O3M9MhwKR/I8vOWiRP7+ru
+8aXndzRpVJ5t4n/T2vwJHZ9Ku4H7O42LLvd/ROlOBXFd9EXc+D/OJmtsxQtbipyR
+OkYD7V7QOgdKylvzRhQ+X+Uhq832JIIc1F+CNX5PFwKBgDxGNLrvn6JEj7yKdud7
+0Jq3Hle7Xwsp2YSrmTIoF0z3CRovXaxb74ZeKctd4/qVo2BPD7Y0X2Mv4fhHXRjv
+nlovFyl+QO73IoVnPg5LNaiOLbJiq67aeZwxfNm9CSMW80dC56k6LVLNkPooboLA
+qJa24h6KBFVqBxJ2aDl0KU4h
+-----END PRIVATE KEY-----