tests/e2e: add test for multiple services matching same pod

Adds a test for the scenario where multiple services have
the same label selector that matches the same pod.

This is possible with routesV2 after commit ff5f421
added support to program multiple services per proxy.

Part of #2610 and #2134.

Signed-off-by: Shashank Ram <shashr2204@gmail.com>

tests/e2e/e2e_multiple_services_per_pod_test.go

@@ -0,0 +1,149 @@
+package e2e
+
+import (
+	"fmt"
+	"time"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	. "github.com/openservicemesh/osm/tests/framework"
+)
+
+var _ = OSMDescribe("Test access via multiple services matching the same pod",
+	OSMDescribeInfo{
+		Tier:   2,
+		Bucket: 2,
+	},
+	func() {
+		Context("Multiple services matching same pod", func() {
+			testMultipleServicePerPod()
+		})
+	})
+
+// testMultipleServicePerPod tests that multiple services having selectors matching the
+// same pod can be individually used to access that pod.
+// In addition to the client and server pods, it creates 2 services 'server' and 'server-second'
+// that have the same label selector, matching the labels on the destination pod that hosts the HTTP server.
+// It tests HTTP traffic as follows:
+// 1. 'client' pod -> service 'server' -> 'server' pod
+// 2. 'client' pod -> service 'server-second' -> 'server' pod
+func testMultipleServicePerPod() {
+	{
+		const sourceName = "client"
+		const destName = "server"
+		var ns = []string{sourceName, destName}
+
+		It("Tests traffic to multiple services matching the same pod", func() {
+			// Install OSM
+			Expect(Td.InstallOSM(Td.GetOSMInstallOpts())).To(Succeed())
+
+			// Create Test NS
+			for _, n := range ns {
+				Expect(Td.CreateNs(n, nil)).To(Succeed())
+				Expect(Td.AddNsToMesh(true, n)).To(Succeed())
+			}
+
+			// Create an HTTP server that clients will send requests to
+			svcAccDef, podDef, svcDef := Td.SimplePodApp(
+				SimplePodAppDef{
+					Name:      destName,
+					Namespace: destName,
+					Image:     "kennethreitz/httpbin",
+					Ports:     []int{80},
+				})
+
+			_, err := Td.CreateServiceAccount(destName, &svcAccDef)
+			Expect(err).NotTo(HaveOccurred())
+			_, err = Td.CreatePod(destName, podDef)
+			Expect(err).NotTo(HaveOccurred())
+			firstSvc, err := Td.CreateService(destName, svcDef)
+			Expect(err).NotTo(HaveOccurred())
+
+			// Create a 2nd service, which has the same label selectors as the first service created above.
+			// This will be used to verify that multiple services having label selectors matching the
+			// same pod can work as expected.
+			secondSvcDef := svcDef
+			secondSvcDef.Name = fmt.Sprintf("%s-second", svcDef.Name)
+			secondSvc, err := Td.CreateService(destName, secondSvcDef)
+			Expect(err).NotTo(HaveOccurred())
+
+			// Expect it to be up and running in it's receiver namespace
+			Expect(Td.WaitForPodsRunningReady(destName, 90*time.Second, 1)).To(Succeed())
+
+			srcPod := setupSource(sourceName, false /* no service for client */)
+
+			By("Creating SMI policies")
+			// Deploy allow rule client->server
+			httpRG, trafficTarget := Td.CreateSimpleAllowPolicy(
+				SimpleAllowPolicy{
+					RouteGroupName:    "routes",
+					TrafficTargetName: "test-target",
+
+					SourceNamespace:      sourceName,
+					SourceSVCAccountName: sourceName,
+
+					DestinationNamespace:      destName,
+					DestinationSvcAccountName: destName,
+				})
+
+			// Configs have to be put into a monitored NS
+			_, err = Td.CreateHTTPRouteGroup(sourceName, httpRG)
+			Expect(err).NotTo(HaveOccurred())
+			_, err = Td.CreateTrafficTarget(sourceName, trafficTarget)
+			Expect(err).NotTo(HaveOccurred())
+
+			// Expect client to reach HTTP server using the first service as FQDN
+			clientToFirstService := HTTPRequestDef{
+				SourceNs:        sourceName,
+				SourcePod:       srcPod.Name,
+				SourceContainer: sourceName,
+
+				Destination: fmt.Sprintf("%s.%s", firstSvc.Name, firstSvc.Namespace),
+			}
+
+			srcToDestStr := fmt.Sprintf("%s -> %s",
+				fmt.Sprintf("%s/%s", sourceName, srcPod.Name),
+				clientToFirstService.Destination)
+
+			cond := Td.WaitForRepeatedSuccess(func() bool {
+				result := Td.HTTPRequest(clientToFirstService)
+
+				if result.Err != nil || result.StatusCode != 200 {
+					Td.T.Logf("> (%s) HTTP Req failed %d %v",
+						srcToDestStr, result.StatusCode, result.Err)
+					return false
+				}
+				Td.T.Logf("> (%s) HTTP Req succeeded: %d", srcToDestStr, result.StatusCode)
+				return true
+			}, 5, 90*time.Second)
+			Expect(cond).To(BeTrue(), "Failed testing HTTP traffic: %s", srcToDestStr)
+
+			// Expect client to reach HTTP server using the second service as FQDN
+			clientToSecondService := HTTPRequestDef{
+				SourceNs:        sourceName,
+				SourcePod:       srcPod.Name,
+				SourceContainer: sourceName,
+
+				Destination: fmt.Sprintf("%s.%s", secondSvc.Name, secondSvc.Namespace),
+			}
+
+			srcToDestStr = fmt.Sprintf("%s -> %s",
+				fmt.Sprintf("%s/%s", sourceName, srcPod.Name),
+				clientToSecondService.Destination)
+
+			cond = Td.WaitForRepeatedSuccess(func() bool {
+				result := Td.HTTPRequest(clientToSecondService)
+
+				if result.Err != nil || result.StatusCode != 200 {
+					Td.T.Logf("> (%s) HTTP Req failed %d %v",
+						srcToDestStr, result.StatusCode, result.Err)
+					return false
+				}
+				Td.T.Logf("> (%s) HTTP Req succeeded: %d", srcToDestStr, result.StatusCode)
+				return true
+			}, 5, 90*time.Second)
+			Expect(cond).To(BeTrue(), "Failed testing HTTP traffic: %s", srcToDestStr)
+		})
+	}
+}