[TT-10414] [release-4-lts] Fix python coprocess tests, pin protobuf d…

…ependency in CI (#5737) Co-authored-by: Tit Petric <tit@tyk.io>
TykTechnologies · Jan 22, 2024 · 9a42e8f · 9a42e8f
1 parent 6158f50
commit 9a42e8f
Show file tree

Hide file tree

Showing 3 changed files with 185 additions and 118 deletions.
diff --git a/.github/workflows/ci-tests.yml b/.github/workflows/ci-tests.yml
@@ -21,7 +21,9 @@ jobs:
 
     steps:
       - name: Checkout Tyk
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
+        with:
+          ref: ${{ github.event.pull_request.head.ref }}
 
       - name: Setup Golang
         uses: actions/setup-go@v2
@@ -42,7 +44,7 @@ jobs:
           python -m pip install --upgrade pip
           pip install setuptools
           pip install google
-          pip install protobuf
+          pip install 'protobuf==4.24.4'
 
       - name: Start Redis
         uses: supercharge/redis-github-action@1.1.0

diff --git a/coprocess/python/coprocess_id_extractor_python_test.go b/coprocess/python/coprocess_id_extractor_python_test.go
@@ -3,16 +3,40 @@ package python
 import (
 	"net/http"
 	"net/url"
+	"strings"
 	"testing"
-	"time"
 
 	"github.com/TykTechnologies/tyk/config"
 	"github.com/TykTechnologies/tyk/gateway"
+	"github.com/TykTechnologies/tyk/internal/uuid"
 	"github.com/TykTechnologies/tyk/test"
 )
 
-var pythonIDExtractorHeaderValue = map[string]string{
-	"manifest.json": `
+var pythonIDExtractorHeaderValue = func(token string) map[string]string {
+	middleware := `
+import time
+from tyk.decorators import *
+from gateway import TykGateway as tyk
+
+counter = 0
+
+@Hook
+def MyAuthHook(request, session, metadata, spec):
+    global counter
+    counter = counter + 1
+    auth_header = request.get_header('Authorization')
+    if auth_header == 'valid_token' and counter < 2:
+        session.rate = 1000.0
+        session.per = 1.0
+        session.id_extractor_deadline = int(time.time()) + 60
+        metadata["token"] = "valid_token"
+    return request, session, metadata
+	`
+
+	middleware = strings.ReplaceAll(middleware, "valid_token", token)
+
+	return map[string]string{
+		"manifest.json": `
 		{
 		    "file_list": [
 		        "middleware.py"
@@ -32,29 +56,36 @@ var pythonIDExtractorHeaderValue = map[string]string{
 		    }
 		}
 	`,
-	"middleware.py": `
+		"middleware.py": middleware,
+	}
+}
+
+var pythonIDExtractorFormValue = func(token string) map[string]string {
+	middleware := `
 import time
 from tyk.decorators import *
 from gateway import TykGateway as tyk
+from urllib import parse
 
 counter = 0
 
 @Hook
 def MyAuthHook(request, session, metadata, spec):
     global counter
     counter = counter + 1
-    auth_header = request.get_header('Authorization')
-    if auth_header == 'valid_token' and counter < 2:
+    auth_param = parse.parse_qs(request.object.body)["auth"]
+    if auth_param and auth_param[0] == 'valid_token' and counter < 2:
         session.rate = 1000.0
         session.per = 1.0
         session.id_extractor_deadline = int(time.time()) + 60
         metadata["token"] = "valid_token"
     return request, session, metadata
-	`,
-}
+`
 
-var pythonIDExtractorFormValue = map[string]string{
-	"manifest.json": `
+	middleware = strings.ReplaceAll(middleware, "valid_token", token)
+
+	return map[string]string{
+		"manifest.json": `
 		{
 		    "file_list": [
 		        "middleware.py"
@@ -74,30 +105,36 @@ var pythonIDExtractorFormValue = map[string]string{
 		    }
 		}
 	`,
-	"middleware.py": `
+		"middleware.py": middleware,
+	}
+}
+
+var pythonIDExtractorHeaderRegex = func(token string) map[string]string {
+	middleware := `
 import time
 from tyk.decorators import *
 from gateway import TykGateway as tyk
-from urllib import parse
 
 counter = 0
 
 @Hook
 def MyAuthHook(request, session, metadata, spec):
+    print("MyAuthHook3 is called")
     global counter
     counter = counter + 1
-    auth_param = parse.parse_qs(request.object.body)["auth"]
-    if auth_param and auth_param[0] == 'valid_token' and counter < 2:
+    _, auth_header = request.get_header('Authorization').split('-')
+    if auth_header and auth_header == '12345' and counter < 2:
         session.rate = 1000.0
         session.per = 1.0
         session.id_extractor_deadline = int(time.time()) + 60
         metadata["token"] = "valid_token"
     return request, session, metadata
-`,
-}
+	`
 
-var pythonIDExtractorHeaderRegex = map[string]string{
-	"manifest.json": `
+	middleware = strings.ReplaceAll(middleware, "valid_token", token)
+
+	return map[string]string{
+		"manifest.json": `
 		{
 		    "file_list": [
 		        "middleware.py"
@@ -119,86 +156,88 @@ var pythonIDExtractorHeaderRegex = map[string]string{
 		    }
 		}
 	`,
-	"middleware.py": `
-import time
-from tyk.decorators import *
-from gateway import TykGateway as tyk
-
-counter = 0
-
-@Hook
-def MyAuthHook(request, session, metadata, spec):
-    print("MyAuthHook3 is called")
-    global counter
-    counter = counter + 1
-    _, auth_header = request.get_header('Authorization').split('-')
-    if auth_header and auth_header == '12345' and counter < 2:
-        session.rate = 1000.0
-        session.per = 1.0
-        session.id_extractor_deadline = int(time.time()) + 60
-        metadata["token"] = "valid_token"
-    return request, session, metadata
-	`,
+		"middleware.py": middleware,
+	}
 }
 
 /* Value Extractor tests, using "header" source */
 // Goal of ID extractor is to cache auth plugin calls
 // Our `pythonBundleWithAuthCheck` plugin restrict more then 1 call
 // With ID extractor, it should run multiple times (because cache)
 func TestValueExtractorHeaderSource(t *testing.T) {
-	test.Flaky(t)
-	ts := gateway.StartTest(nil, gateway.TestConfig{
-		CoprocessConfig: config.CoProcessConfig{
-			EnableCoProcess:  true,
-			PythonPathPrefix: pkgPath,
-			PythonVersion:    "3.5",
-		},
-		Delay: 10 * time.Millisecond,
-	})
-	defer ts.Close()
-
-	spec := gateway.BuildAPI(func(spec *gateway.APISpec) {
-		spec.Proxy.ListenPath = "/"
-		spec.UseKeylessAccess = false
-		spec.EnableCoProcessAuth = true
-	})[0]
 	t.Run("Header value", func(t *testing.T) {
-		bundleID := ts.RegisterBundle("id_extractor_header_value", pythonIDExtractorHeaderValue)
-		spec.CustomMiddlewareBundle = bundleID
-		spec.APIID = "api1"
-
-		ts.Gw.LoadAPI(spec)
-		time.Sleep(1 * time.Second)
+		ts := gateway.StartTest(nil, gateway.TestConfig{
+			CoprocessConfig: config.CoProcessConfig{
+				EnableCoProcess:  true,
+				PythonPathPrefix: pkgPath,
+			},
+		})
+		defer ts.Close()
+
+		validToken := uuid.NewHex()
+		bundleID := ts.RegisterBundle("id_extractor_header_value", pythonIDExtractorHeaderValue(validToken))
+
+		ts.Gw.BuildAndLoadAPI(func(spec *gateway.APISpec) {
+			spec.Proxy.ListenPath = "/"
+			spec.UseKeylessAccess = false
+			spec.EnableCoProcessAuth = true
+			spec.CustomMiddlewareBundle = bundleID
+			spec.APIID = "api1"
+		})
 
 		ts.Run(t, []test.TestCase{
-			{Path: "/", Headers: map[string]string{"Authorization": "valid_token"}, Code: http.StatusOK},
-			{Path: "/", Headers: map[string]string{"Authorization": "valid_token"}, Code: http.StatusOK},
+			{Path: "/", Headers: map[string]string{"Authorization": validToken}, Code: http.StatusOK},
+			{Path: "/", Headers: map[string]string{"Authorization": validToken}, Code: http.StatusOK},
 			{Path: "/", Headers: map[string]string{"Authorization": "invalid_token"}, Code: http.StatusForbidden},
 		}...)
 	})
 	t.Run("Form value", func(t *testing.T) {
-		bundleID := ts.RegisterBundle("id_extractor_form_value", pythonIDExtractorFormValue)
-		spec.CustomMiddlewareBundle = bundleID
-		spec.APIID = "api2"
-
-		ts.Gw.LoadAPI(spec)
-		time.Sleep(1 * time.Second)
+		ts := gateway.StartTest(nil, gateway.TestConfig{
+			CoprocessConfig: config.CoProcessConfig{
+				EnableCoProcess:  true,
+				PythonPathPrefix: pkgPath,
+			},
+		})
+		defer ts.Close()
+
+		validToken := uuid.NewHex()
+		bundleID := ts.RegisterBundle("id_extractor_form_value", pythonIDExtractorFormValue(validToken))
+
+		ts.Gw.BuildAndLoadAPI(func(spec *gateway.APISpec) {
+			spec.Proxy.ListenPath = "/"
+			spec.UseKeylessAccess = false
+			spec.EnableCoProcessAuth = true
+			spec.CustomMiddlewareBundle = bundleID
+			spec.APIID = "api2"
+		})
 
 		formHeaders := map[string]string{"Content-Type": "application/x-www-form-urlencoded"}
 
 		ts.Run(t, []test.TestCase{
-			{Method: "POST", Path: "/", Headers: formHeaders, Data: url.Values{"auth": []string{"valid_token"}}.Encode(), Code: http.StatusOK},
-			{Method: "POST", Path: "/", Headers: formHeaders, Data: url.Values{"auth": []string{"valid_token"}}.Encode(), Code: http.StatusOK},
+			{Method: "POST", Path: "/", Headers: formHeaders, Data: url.Values{"auth": []string{validToken}}.Encode(), Code: http.StatusOK},
+			{Method: "POST", Path: "/", Headers: formHeaders, Data: url.Values{"auth": []string{validToken}}.Encode(), Code: http.StatusOK},
 			{Method: "POST", Path: "/", Headers: formHeaders, Data: url.Values{"auth": []string{"invalid_token"}}.Encode(), Code: http.StatusForbidden},
 		}...)
 	})
 	t.Run("Header regex", func(t *testing.T) {
-		bundleID := ts.RegisterBundle("id_extractor_header_regex", pythonIDExtractorHeaderRegex)
-		spec.CustomMiddlewareBundle = bundleID
-		spec.APIID = "api3"
-
-		ts.Gw.LoadAPI(spec)
-		time.Sleep(1 * time.Second)
+		ts := gateway.StartTest(nil, gateway.TestConfig{
+			CoprocessConfig: config.CoProcessConfig{
+				EnableCoProcess:  true,
+				PythonPathPrefix: pkgPath,
+			},
+		})
+		defer ts.Close()
+
+		validToken := uuid.NewHex()
+		bundleID := ts.RegisterBundle("id_extractor_header_regex", pythonIDExtractorHeaderRegex(validToken))
+
+		ts.Gw.BuildAndLoadAPI(func(spec *gateway.APISpec) {
+			spec.Proxy.ListenPath = "/"
+			spec.UseKeylessAccess = false
+			spec.EnableCoProcessAuth = true
+			spec.CustomMiddlewareBundle = bundleID
+			spec.APIID = "api3"
+		})
 
 		ts.Run(t, []test.TestCase{
 			{Path: "/", Headers: map[string]string{"Authorization": "prefix-12345"}, Code: http.StatusOK},