From 41b30d90f8fe0eb3817a2eef9d2ccd04d4637c31 Mon Sep 17 00:00:00 2001
From: Artem Medvedev <i@ddtkey.com>
Date: Mon, 24 Jul 2023 18:59:27 +0200
Subject: [PATCH] fix: do not ignore result of `ensure_recv_open` (#687)

---
 src/proto/streams/recv.rs    | 8 +++++++-
 src/proto/streams/streams.rs | 6 +++++-
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/proto/streams/recv.rs b/src/proto/streams/recv.rs
index d0db00dd..0063942a 100644
--- a/src/proto/streams/recv.rs
+++ b/src/proto/streams/recv.rs
@@ -318,7 +318,13 @@ impl Recv {
             Some(Event::Headers(Client(response))) => Poll::Ready(Ok(response)),
             Some(_) => panic!("poll_response called after response returned"),
             None => {
-                stream.state.ensure_recv_open()?;
+                if !stream.state.ensure_recv_open()? {
+                    proto_err!(stream: "poll_response: stream={:?} is not opened;",  stream.id);
+                    return Poll::Ready(Err(Error::library_reset(
+                        stream.id,
+                        Reason::PROTOCOL_ERROR,
+                    )));
+                }
 
                 stream.recv_task = Some(cx.waker().clone());
                 Poll::Pending
diff --git a/src/proto/streams/streams.rs b/src/proto/streams/streams.rs
index eab362f7..02a0f61b 100644
--- a/src/proto/streams/streams.rs
+++ b/src/proto/streams/streams.rs
@@ -726,7 +726,11 @@ impl Inner {
                 }
 
                 // The stream must be receive open
-                stream.state.ensure_recv_open()?;
+                if !stream.state.ensure_recv_open()? {
+                    proto_err!(conn: "recv_push_promise: initiating stream is not opened");
+                    return Err(Error::library_go_away(Reason::PROTOCOL_ERROR));
+                }
+
                 stream.key()
             }
             None => {