[Do Not Merge]

adapter/internal/oasparser/envoyconf/http_filters.go

@@ -241,12 +241,12 @@ func getExtProcessHTTPFilter() *hcmv3.HttpFilter {
 		},
 		FailureModeAllow: true,
 		ProcessingMode: &ext_process.ProcessingMode{
-			ResponseBodyMode:   ext_process.ProcessingMode_BUFFERED,
+			// ResponseBodyMode:   ext_process.ProcessingMode_BUFFERED,
 			RequestHeaderMode:  ext_process.ProcessingMode_SEND,
-			ResponseHeaderMode: ext_process.ProcessingMode_SEND,
+			ResponseHeaderMode: ext_process.ProcessingMode_SKIP,
 			// RequestHeaderMode:  ext_process.ProcessingMode_SKIP,
 			// ResponseHeaderMode: ext_process.ProcessingMode_SKIP,
-			RequestBodyMode: ext_process.ProcessingMode_BUFFERED,
+			// RequestBodyMode: ext_process.ProcessingMode_BUFFERED,
 		},
 		MetadataOptions: &ext_process.MetadataOptions{
 			ForwardingNamespaces: &ext_process.MetadataOptions_MetadataNamespaces{
@@ -259,6 +259,7 @@ func getExtProcessHTTPFilter() *hcmv3.HttpFilter {
 		RequestAttributes:  []string{"xds.route_metadata", "request.method", "request.id"},
 		ResponseAttributes: []string{"xds.route_metadata"},
 		MessageTimeout:     durationpb.New(conf.Envoy.EnforcerResponseTimeoutInSeconds * time.Second),
+		AllowModeOverride: true,
 	}
 	ext, err2 := anypb.New(externalProcessor)
 	if err2 != nil {

gateway/enforcer/cmd/main.go

@@ -1,10 +1,14 @@
 package main
 
 import (
+	"log"
 	"time"
 
 	"strings"
 
+	"net/http"
+	_ "net/http/pprof"
+
 	"github.com/wso2/apk/gateway/enforcer/internal/config"
 	"github.com/wso2/apk/gateway/enforcer/internal/datastore"
 	"github.com/wso2/apk/gateway/enforcer/internal/extproc"
@@ -17,6 +21,9 @@ import (
 )
 
 func main() {
+	go func() {
+		log.Println(http.ListenAndServe("localhost:6060", nil))
+	}()
 	cfg := config.GetConfig()
 	port := cfg.CommonControllerXdsPort
 	host := cfg.CommonControllerHostname

gateway/enforcer/internal/datastore/api_store.go

@@ -105,7 +105,7 @@ func (s *APIStore) AddAPIs(apis []*api.Api) {
 			}
 
 		}
-		s.cfg.Logger.Sugar().Debug(fmt.Sprintf("Adding API: %+v", customAPI.BackendJwtConfiguration))
+		//s.cfg.Logger.Sugar().Debug(fmt.Sprintf("Adding API: %+v", customAPI.BackendJwtConfiguration))
 		s.apis[util.PrepareAPIKey(api.Vhost, api.BasePath, api.Version)] = &customAPI
 	}
 }