Enhance HTTP handling with X-Forwarded-For support and connection management

- Added "X-Forwarded-For" header to requests to forward the real client IP address.
- Updated hop-by-hop headers to include "x-forwarded-for".
- Implemented logic to set "Connection: close" in responses when keep-alive is disabled, ensuring proper connection lifecycle management.

Author: mikecovlee

netutils.csp

@@ -1,6 +1,6 @@
 # Generated by Extended CovScript Compiler
 # DO NOT MODIFY
-# Date: Wed Jul 15 23:03:06 2026
+# Date: Thu Jul 16 11:20:16 2026
 @charset: utf8
 import ecs as netutils_ecs
 struct __netutils_ecs_lambda_impl_1__
@@ -44,7 +44,7 @@ struct __netutils_ecs_lambda_impl_3__
 		if session.args != null && !session.args.empty()
 			url.append("?" + session.args)
 		end
-		var hop_by_hop = netutils_ecs.type_constructor.__hash_map({"host" : 1, "connection" : 1, "content-length" : 1, "transfer-encoding" : 1, "keep-alive" : 1, "proxy-connection" : 1, "proxy-authenticate" : 1, "proxy-authorization" : 1, "te" : 1, "trailer" : 1, "upgrade" : 1})
+		var hop_by_hop = netutils_ecs.type_constructor.__hash_map({"host" : 1, "connection" : 1, "content-length" : 1, "transfer-encoding" : 1, "keep-alive" : 1, "proxy-connection" : 1, "proxy-authenticate" : 1, "proxy-authorization" : 1, "te" : 1, "trailer" : 1, "upgrade" : 1, "x-forwarded-for" : 1})
 		var req_headers = new array
 		if session.request_headers != null
 			foreach it in session.request_headers
@@ -54,6 +54,7 @@ struct __netutils_ecs_lambda_impl_3__
 				end
 			end
 		end
+		req_headers.push_back("X-Forwarded-For: " + session.sock.remote_endpoint().address())
 		var resp = null
 		try 
 			if session.content_length != null && session.content_length > 0
@@ -107,6 +108,7 @@ constant default_http_thread_count = 4
 constant default_http_worker_count = 32
 var request_line_reg = regex.build_optimize("^([A-Z]+) ([^ ?]+)(?:\\?([^ ]*))? HTTP/([0-9.]+)$")
 var request_header_reg = regex.build_optimize("^([^:]*): ?(.*)$")
+var keep_alive_replace_reg = regex.build_optimize("Connection: keep-alive")
 namespace state_codes
 	constant code_200 = "200 OK"
 	constant code_400 = "400 Bad Request"
@@ -862,6 +864,9 @@ function master_response_worker(self)
 		while !conn->request_queue.empty()
 			link session = conn->request_queue.front
 			if session != null && session.response != null
+				if !conn->keep_alive
+					session.response = regex.replace(keep_alive_replace_reg, session.response, "Connection: close")
+				end
 				var response_state = async.write(conn->sock, session.response)
 				if !response_state.wait()
 					log("Write response error: " + response_state.get_error())