safe

Author: ovadiagal

go/delay.go

@@ -35,6 +35,9 @@ func (p *delayFilterFactory) Create(handle shared.HttpFilterHandle) shared.HttpF
 	return &delayFilter{handle: handle}
 }
 
+// OnDestroy implements [shared.HttpFilterFactory].
+func (p *delayFilterFactory) OnDestroy() {}
+
 // OnRequestHeaders implements [shared.HttpFilter].
 func (p *delayFilter) OnRequestHeaders(headers shared.HeaderMap, endOfStream bool) shared.HeadersStatus {
 	// Check if the headers contain the "do-delay" header to trigger the delay.

go/header_auth.go

@@ -36,14 +36,17 @@ func (p *headerAuthFilterFactory) Create(handle shared.HttpFilterHandle) shared.
 	return &headerAuthFilter{handle: handle, authHeaderName: p.authHeaderName}
 }
 
+// OnDestroy implements [shared.HttpFilterFactory].
+func (p *headerAuthFilterFactory) OnDestroy() {}
+
 // OnRequestHeaders implements [shared.HttpFilter].
 func (p *headerAuthFilter) OnRequestHeaders(headers shared.HeaderMap, endOfStream bool) shared.HeadersStatus {
 	v := headers.GetOne(p.authHeaderName)
-	if v == "" {
+	if v.Len == 0 {
 		p.handle.SendLocalResponse(http.StatusUnauthorized, [][2]string{{"Content-Type", "text/plain"}}, []byte("Unauthorized by Go Module at on_request_headers\n"), "unauthorized")
 		return shared.HeadersStatusStop
 	}
-	p.sendOnResponseHeaderPhase = v == "on_response_headers"
+	p.sendOnResponseHeaderPhase = v.ToString() == "on_response_headers"
 	return shared.HeadersStatusContinue
 }
 

go/javascript.go

@@ -61,6 +61,9 @@ func (p *javaScriptFilterConfigFactory) Create(handle shared.HttpFilterConfigHan
 	return c, nil
 }
 
+// OnDestroy implements [shared.HttpFilterFactory].
+func (p *javaScriptFilterFactory) OnDestroy() {}
+
 // Create implements [shared.HttpFilterFactory].
 func (p *javaScriptFilterFactory) Create(handle shared.HttpFilterHandle) shared.HttpFilter {
 	vm := p.vms[rand.Intn(numberOfVMPool)]
@@ -122,7 +125,7 @@ func newJavaScriptVM(script string, w io.Writer) (*javaScriptVM, error) {
 // OnRequestHeaders implements [shared.HttpFilter].
 func (p *javaScriptFilter) OnRequestHeaders(headers shared.HeaderMap, _ bool) shared.HeadersStatus {
 	for _, header := range headers.GetAll() {
-		p.requestHeaders[header[0]] = header[1]
+		p.requestHeaders[header[0].ToString()] = header[1].ToString()
 	}
 	p.vm.mux.Lock()
 	defer p.vm.mux.Unlock()
@@ -155,7 +158,7 @@ func (p *javaScriptFilter) OnRequestHeaders(headers shared.HeaderMap, _ bool) sh
 // OnResponseHeaders implements [shared.HttpFilter].
 func (p *javaScriptFilter) OnResponseHeaders(headers shared.HeaderMap, _ bool) shared.HeadersStatus {
 	for _, header := range headers.GetAll() {
-		p.responseHeaders[header[0]] = header[1]
+		p.responseHeaders[header[0].ToString()] = header[1].ToString()
 	}
 	p.vm.mux.Lock()
 	defer p.vm.mux.Unlock()

go/passthrough.go

@@ -30,20 +30,23 @@ func (p *passthroughFilterFactory) Create(handle shared.HttpFilterHandle) shared
 	return &passthroughFilter{handle: handle}
 }
 
+// OnDestroy implements [shared.HttpFilterFactory].
+func (p *passthroughFilterFactory) OnDestroy() {}
+
 // OnRequestHeaders implements [shared.HttpFilter].
 func (p *passthroughFilter) OnRequestHeaders(headers shared.HeaderMap, endOfStream bool) shared.HeadersStatus {
 	fooValue := headers.GetOne("foo")
-	fmt.Printf("gosdk: RequestHeaders, foo: %v\n", fooValue)
+	fmt.Printf("gosdk: RequestHeaders, foo: %v\n", fooValue.ToString())
 	fmt.Printf("gosdk: RequestHeaders, endOfStream: %v\n", endOfStream)
 	for _, header := range headers.GetAll() {
-		fmt.Printf("gosdk: RequestHeaders, header: %s: %s\n", header[0], header[1])
+		fmt.Printf("gosdk: RequestHeaders, header: %s: %s\n", header[0].ToString(), header[1].ToString())
 	}
 	sourceAddr, _ := p.handle.GetAttributeString(shared.AttributeIDSourceAddress)
 	destAddr, _ := p.handle.GetAttributeString(shared.AttributeIDDestinationAddress)
 	protocol, _ := p.handle.GetAttributeString(shared.AttributeIDRequestProtocol)
-	fmt.Printf("gosdk: RequestHeaders, source address: %s\n", sourceAddr)
-	fmt.Printf("gosdk: RequestHeaders, destination address: %s\n", destAddr)
-	fmt.Printf("gosdk: RequestHeaders, request protocol: %s\n", protocol)
+	fmt.Printf("gosdk: RequestHeaders, source address: %s\n", sourceAddr.ToString())
+	fmt.Printf("gosdk: RequestHeaders, destination address: %s\n", destAddr.ToString())
+	fmt.Printf("gosdk: RequestHeaders, request protocol: %s\n", protocol.ToString())
 	return shared.HeadersStatusContinue
 }
 
@@ -57,15 +60,15 @@ func (p *passthroughFilter) OnRequestBody(body shared.BodyBuffer, endOfStream bo
 	chunks := body.GetChunks()
 	var original []byte
 	for _, chunk := range chunks {
-		original = append(original, chunk...)
+		original = append(original, chunk.ToBytes()...)
 	}
 	fmt.Printf("gosdk: RequestBody, body: %s\n", original)
 	body.Drain(uint64(len(original)))
 	body.Append([]byte("hello world"))
 	chunks = body.GetChunks()
 	var modified []byte
 	for _, chunk := range chunks {
-		modified = append(modified, chunk...)
+		modified = append(modified, chunk.ToBytes()...)
 	}
 	if string(modified) != "hello world" {
 		panic("request body should be modified")
@@ -77,7 +80,7 @@ func (p *passthroughFilter) OnRequestBody(body shared.BodyBuffer, endOfStream bo
 	chunks = body.GetChunks()
 	modified = nil
 	for _, chunk := range chunks {
-		modified = append(modified, chunk...)
+		modified = append(modified, chunk.ToBytes()...)
 	}
 	if string(modified) != string(original) {
 		panic("request body should be modified")
@@ -88,13 +91,13 @@ func (p *passthroughFilter) OnRequestBody(body shared.BodyBuffer, endOfStream bo
 // OnResponseHeaders implements [shared.HttpFilter].
 func (p *passthroughFilter) OnResponseHeaders(headers shared.HeaderMap, endOfStream bool) shared.HeadersStatus {
 	status := headers.GetOne(":status")
-	if status == "" {
+	if status.Len == 0 {
 		panic("x-status header should be set")
 	}
-	fmt.Printf("gosdk: ResponseHeaders, status: %v\n", status)
+	fmt.Printf("gosdk: ResponseHeaders, status: %v\n", status.ToString())
 	headers.Set("x-passthrough-response-header", "true")
 	for _, header := range headers.GetAll() {
-		fmt.Printf("gosdk: ResponseHeaders, header: %s: %s\n", header[0], header[1])
+		fmt.Printf("gosdk: ResponseHeaders, header: %s: %s\n", header[0].ToString(), header[1].ToString())
 	}
 	return shared.HeadersStatusContinue
 }
@@ -109,15 +112,15 @@ func (p *passthroughFilter) OnResponseBody(body shared.BodyBuffer, endOfStream b
 	chunks := body.GetChunks()
 	var original []byte
 	for _, chunk := range chunks {
-		original = append(original, chunk...)
+		original = append(original, chunk.ToBytes()...)
 	}
 	fmt.Printf("gosdk: ResponseBody, body: %s\n", original)
 	body.Drain(uint64(len(original)))
 	body.Append([]byte("hello world"))
 	chunks = body.GetChunks()
 	var modified []byte
 	for _, chunk := range chunks {
-		modified = append(modified, chunk...)
+		modified = append(modified, chunk.ToBytes()...)
 	}
 	if string(modified) != "hello world" {
 		panic("response body should be modified")
@@ -128,7 +131,7 @@ func (p *passthroughFilter) OnResponseBody(body shared.BodyBuffer, endOfStream b
 	chunks = body.GetChunks()
 	modified = nil
 	for _, chunk := range chunks {
-		modified = append(modified, chunk...)
+		modified = append(modified, chunk.ToBytes()...)
 	}
 	if string(modified) != string(original) {
 		panic("response body should be modified")