test: malformed test crashes the bg worker

Author: steve-chavez

nix/nginx/conf/custom.conf

@@ -45,3 +45,7 @@ location /redirect_me {
 location /to_here {
   echo 'I got redirected';
 }
+
+location /pathological {
+  pathological;
+}

nix/nginxScript.nix

@@ -1,9 +1,23 @@
-{ nginx, nginxModules, writeShellScriptBin } :
+{ lib, fetchFromGitHub, nginx, nginxModules, writeShellScriptBin } :
 
 let
+  ngx_pathological = rec {
+    name = "ngx_pathological";
+    version = "0.1";
+    src = fetchFromGitHub {
+      owner  = "steve-chavez";
+      repo   = name;
+      rev    = "46a6d48910b482cf82ecd8a3fce448498cc9f886";
+      sha256 = "sha256-unPSFxbuvv5chyPKDRaKvxuekz3tPmhHiVzZzX1D4lk=";
+    };
+    meta = with lib; {
+      license = with licenses; [ mit ];
+    };
+  };
   customNginx = nginx.override {
     modules = [
       nginxModules.echo
+      ngx_pathological
     ];
   };
   script = ''

nix/ngx_pathological.nix

@@ -0,0 +1,17 @@
+{ stdenv, postgresql, curl }:
+
+stdenv.mkDerivation {
+  name = "pg_net";
+
+  buildInputs = [ postgresql curl ];
+
+  src = ../.;
+
+  installPhase = ''
+    mkdir -p $out/bin
+    install -D pg_net.so -t $out/lib
+
+    install -D -t $out/share/postgresql/extension sql/*.sql
+    install -D -t $out/share/postgresql/extension pg_net.control
+  '';
+}

test/test_http_malformed_headers.py

@@ -0,0 +1,30 @@
+from sqlalchemy import text
+
+
+def test_http_malformed_headers(sess):
+    """Check that malformed headers are processed correctly"""
+    # Create a request
+    (request_id,) = sess.execute(text(
+        """
+        select net.http_get(
+            url:='http://localhost:8080/pathological?malformed-header=missing-value'
+        );
+    """
+    )).fetchone()
+
+    # Commit so background worker can start
+    sess.commit()
+
+    # Collect the response, waiting as needed
+    response = sess.execute(
+        text(
+            """
+        select * from net._http_collect_response(:request_id, async:=false);
+    """
+        ),
+        {"request_id": request_id},
+    ).fetchone()
+    print(response)
+    assert response is not None
+    assert response[0] == "SUCCESS"
+    assert "MissingValue" in response[2]