From 56041fd503d1199401210cba8ee92cb293e73975 Mon Sep 17 00:00:00 2001
From: Chris Guida <chrisguida@gmail.com>
Date: Tue, 30 Mar 2021 19:19:24 -0600
Subject: [PATCH] disable buffering in nginx

---
 appmgr/src/nginx-standard.conf.template |  2 ++
 appmgr/src/nginx.conf.template          |  2 ++
 appmgr/src/version/v0_2_12.rs           | 38 +++++++++++++++++++++++++
 3 files changed, 42 insertions(+)
 create mode 100644 appmgr/src/version/v0_2_12.rs

diff --git a/appmgr/src/nginx-standard.conf.template b/appmgr/src/nginx-standard.conf.template
index eb4243320..7e630becc 100644
--- a/appmgr/src/nginx-standard.conf.template
+++ b/appmgr/src/nginx-standard.conf.template
@@ -10,6 +10,8 @@ server {{
         proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
         proxy_set_header X-Forwarded-Proto $scheme;
         client_max_body_size 0;
+        proxy_request_buffering off;
+        proxy_buffering off;
     }}
 }}
 server {{
diff --git a/appmgr/src/nginx.conf.template b/appmgr/src/nginx.conf.template
index 0f19c850f..4f244becb 100644
--- a/appmgr/src/nginx.conf.template
+++ b/appmgr/src/nginx.conf.template
@@ -5,5 +5,7 @@ server {{
         proxy_pass http://{app_ip}:{internal_port}/;
         proxy_set_header Host $host;
         client_max_body_size 0;
+        proxy_request_buffering off;
+        proxy_buffering off;
     }}
 }}
diff --git a/appmgr/src/version/v0_2_12.rs b/appmgr/src/version/v0_2_12.rs
new file mode 100644
index 000000000..d2be542a8
--- /dev/null
+++ b/appmgr/src/version/v0_2_12.rs
@@ -0,0 +1,38 @@
+use super::*;
+use std::os::unix::process::ExitStatusExt;
+
+const V0_2_12: emver::Version = emver::Version::new(0, 2, 12, 0);
+
+pub struct Version;
+#[async_trait]
+impl VersionT for Version {
+    type Previous = v0_2_11::Version;
+    fn new() -> Self {
+        Version
+    }
+    fn semver(&self) -> &'static emver::Version {
+        &V0_2_12
+    }
+    async fn up(&self) -> Result<(), Error> {
+        crate::tor::write_lan_services(
+            &crate::tor::services_map(&PersistencePath::from_ref(crate::SERVICES_YAML)).await?,
+        )
+        .await?;
+        let svc_exit = std::process::Command::new("service")
+            .args(&["nginx", "reload"])
+            .status()?;
+        crate::ensure_code!(
+            svc_exit.success(),
+            crate::error::GENERAL_ERROR,
+            "Failed to Reload Nginx: {}",
+            svc_exit
+                .code()
+                .or_else(|| { svc_exit.signal().map(|a| 128 + a) })
+                .unwrap_or(0)
+        );
+        Ok(())
+    }
+    async fn down(&self) -> Result<(), Error> {
+        Ok(())
+    }
+}