HTTPTransaction::wtCloseSession: send abort if ingress EOM not seen

proxygen/lib/http/session/HTTPTransaction.h

@@ -1989,6 +1989,9 @@ class HTTPTransaction
     if (!isEgressEOMSeen()) {
       sendEOM();
     }
+    if (!isIngressEOMSeen()) {
+      sendAbort(ErrorCode::NO_ERROR);
+    }
 
     return folly::unit;
   }

proxygen/lib/http/session/test/HQUpstreamSessionTest.cpp

@@ -2230,12 +2230,23 @@ class HQUpstreamSessionTestWebTransport : public HQUpstreamSessionTest {
     return handler;
   }
 
+  // Local-initiated close: app calls closeSession() before ingress EOF.
+  // closeSession() sends EOM + stop-sending (abort with NO_ERROR).
   void closeWTSession() {
-    // should this close INGRESS?
+    handler_->expectDetachTransaction();
     wt_->closeSession();
+    hqSession_->closeWhenIdle();
+    flushAndLoop();
+  }
+
+  // Peer-initiated close: peer sends EOF first, then local app closes.
+  // closeSession() sends only EOM (no abort since ingress EOM already seen).
+  void peerCloseWTSession() {
     handler_->expectEOM();
-    handler_->expectDetachTransaction();
     socketDriver_->addReadEOF(sessionId_, std::chrono::milliseconds(0));
+    flushAndLoopN(1);
+    wt_->closeSession();
+    handler_->expectDetachTransaction();
     hqSession_->closeWhenIdle();
     flushAndLoop();
   }
@@ -2282,6 +2293,12 @@ TEST_P(HQUpstreamSessionTestWebTransport, FilterInstallation) {
   closeWTSession();
 }
 
+// Test peer-initiated close: peer sends EOF first, then local app closes.
+// closeSession() sends only EOM (no stop-sending needed).
+TEST_P(HQUpstreamSessionTestWebTransport, PeerClose) {
+  peerCloseWTSession();
+}
+
 TEST_P(HQUpstreamSessionTestWebTransport, BidirectionalStream) {
   InSequence enforceOrder;
 

proxygen/lib/http/session/test/HTTPTransactionWebTransportTest.cpp

@@ -87,7 +87,9 @@ class HTTPTransactionWebTransportTest : public testing::Test {
 
   void TearDown() override {
     if (txn_) {
-      EXPECT_CALL(transport_, sendAbort(txn_.get(), _));
+      // closeSession() may have already sent an abort if ingress EOM was not
+      // seen, so allow 0 or 1 calls here.
+      EXPECT_CALL(transport_, sendAbort(txn_.get(), _)).Times(AtMost(1));
       txn_->sendAbort();
     }
   }
@@ -206,6 +208,7 @@ TEST_F(HTTPTransactionWebTransportTest, CreateStreams) {
             WebTransport::ErrorCode::STREAM_CREATION_ERROR);
 
   EXPECT_CALL(transport_, sendEOM(txn_.get(), nullptr));
+  EXPECT_CALL(transport_, sendAbort(txn_.get(), _));
   wt_->closeSession();
 }