Add test for #257

The problem is fixed in latest `http2`
(`7036a3429fb08bfcd5947230c37d1f3e63dfb3a6`).  See
kazu-yamamoto/http2#151 for the `http2` bug report.

Closes #257.

cabal.project

@@ -18,6 +18,11 @@ package grapesy
   benchmarks: True
   flags: +build-demo +build-stress-test 
 
+source-repository-package
+  type: git
+  location: https://github.com/kazu-yamamoto/http2
+  tag: 7036a3429fb08bfcd5947230c37d1f3e63dfb3a6
+
 --
 -- ghc 9.10
 --

grapesy/grapesy.cabal

@@ -223,6 +223,7 @@ test-suite test-grapesy
       Test.Sanity.EndOfStream
       Test.Sanity.Exception
       Test.Sanity.Interop
+      Test.Sanity.Reclamation
       Test.Sanity.StreamingType.CustomFormat
       Test.Sanity.StreamingType.NonStreaming
       Test.Util

grapesy/test-grapesy/Main.hs

@@ -20,6 +20,7 @@ import Test.Sanity.Disconnect                 qualified as Disconnect
 import Test.Sanity.EndOfStream                qualified as EndOfStream
 import Test.Sanity.Exception                  qualified as Exception
 import Test.Sanity.Interop                    qualified as Interop
+import Test.Sanity.Reclamation                qualified as Reclamation
 import Test.Sanity.StreamingType.CustomFormat qualified as StreamingType.CustomFormat
 import Test.Sanity.StreamingType.NonStreaming qualified as StreamingType.NonStreaming
 
@@ -38,6 +39,7 @@ main = do
           , Compression.tests
           , Exception.tests
           , Interop.tests
+          , Reclamation.tests
           , BrokenDeployments.tests
           ]
       , testGroup "Prop" [

grapesy/test-grapesy/Test/Sanity/Reclamation.hs

@@ -0,0 +1,61 @@
+module Test.Sanity.Reclamation (tests) where
+
+import Control.Exception
+import Control.Monad
+import Test.Tasty
+import Test.Tasty.HUnit
+
+import Network.GRPC.Client qualified as Client
+import Network.GRPC.Common
+import Network.GRPC.Common.Protobuf
+import Network.GRPC.Server qualified as Server
+
+import Test.Driver.ClientServer
+
+import Proto.API.Ping
+
+tests :: TestTree
+tests = testGroup "Test.Sanity.Reclamation" [
+      testCase "serverException1" serverException1
+    , testCase "serverException2" serverException2
+    ]
+
+{-------------------------------------------------------------------------------
+  Server-side exception
+-------------------------------------------------------------------------------}
+
+-- | Handler that throws immediately
+brokenHandler :: Server.Call Ping -> IO ()
+brokenHandler _call = throwIO $ DeliberateException $ userError "Broken handler"
+
+serverException1 :: Assertion
+serverException1 = testClientServer $ ClientServerTest {
+      config = def
+    , server = [Server.someRpcHandler $ Server.mkRpcHandler brokenHandler]
+    , client = \params testServer delimitTestScope -> delimitTestScope $
+        replicateM_ 1000 $ do
+          Client.withConnection params testServer $ \conn ->
+            Client.withRPC conn def (Proxy @Ping) $ \call -> do
+              resp <- try $ Client.recvFinalOutput call
+              case resp of
+                Left GrpcException{} -> return ()
+                Right _ -> assertFailure "Unexpected response"
+    }
+
+serverException2 :: Assertion
+serverException2 = testClientServer $ ClientServerTest {
+      config = def
+    , server = [Server.someRpcHandler $ Server.mkRpcHandler brokenHandler]
+    , client = \params testServer delimitTestScope -> delimitTestScope $
+        replicateM_ 1000 $
+          Client.withConnection params testServer $ \conn ->
+            Client.withRPC conn def (Proxy @Ping) $ \call -> do
+
+              -- The only difference between serverException1 is this line:
+              Client.sendFinalInput call defMessage
+
+              resp <- try $ Client.recvFinalOutput call
+              case resp of
+                Left GrpcException{} -> return ()
+                Right _ -> assertFailure "Unexpected response"
+    }