feat: support get scheme for h2 request header (#59)

Author: tzssangglass

src/http/ngx_http_wasm_api.c

@@ -21,6 +21,7 @@ typedef struct {
 enum {
     WASM_H2_HEADER_PATH = 1,
     WASM_H2_HEADER_METHOD,
+    WASM_H2_HEADER_SCHEME,
 };
 
 #define STR_BUF_SIZE    4096
@@ -77,6 +78,7 @@ static char *str_buf[STR_BUF_SIZE] = {0};
 static ngx_http_wasm_h2_header_t wasm_h2_header_static_table[] = {
     {ngx_string(":path"),   WASM_H2_HEADER_PATH},
     {ngx_string(":method"), WASM_H2_HEADER_METHOD},
+    {ngx_string(":scheme"), WASM_H2_HEADER_SCHEME},
 };
 
 
@@ -803,7 +805,11 @@ ngx_http_wasm_req_get_header(ngx_http_request_t *r, char *key,  int32_t key_size
                     val_len = r->method_name.len;
                     break;
 
-                /* todo: scheme https://github.com/api7/wasm-nginx-module/issues/47 */
+                case WASM_H2_HEADER_SCHEME:
+                    val = r->schema.data;
+                    val_len = r->schema.len;
+                    break;
+
                 default:
                     break;
                 }

t/http_req_header.t

@@ -367,3 +367,21 @@ DELETE /t
 qr/get request method: \S+/
 --- grep_error_log_out
 get request method: DELETE,
+
+
+
+=== TEST 20: get schema
+--- http2
+--- config
+location /t {
+    content_by_lua_block {
+        local wasm = require("resty.proxy-wasm")
+        local plugin = assert(wasm.load("plugin", "t/testdata/http_header/main.go.wasm"))
+        local ctx = assert(wasm.on_configure(plugin, 'req_scheme_get'))
+        assert(wasm.on_http_request_headers(ctx))
+    }
+}
+--- grep_error_log eval
+qr/get request scheme: \S+/
+--- grep_error_log_out
+get request scheme: http,

t/testdata/http_header/main.go

@@ -90,6 +90,14 @@ func (ctx *httpContext) OnHttpRequestHeaders(numHeaders int, endOfStream bool) t
 			return types.ActionContinue
 		}
 		proxywasm.LogWarnf("get request method: %v", res)
+
+	case "req_scheme_get":
+		res, err := proxywasm.GetHttpRequestHeader(":scheme")
+		if err != nil {
+			proxywasm.LogErrorf("error get request scheme: %v", err)
+			return types.ActionContinue
+		}
+		proxywasm.LogWarnf("get request scheme: %v", res)
 	}
 
 	return types.ActionContinue