Add gateway version to topology

Client.IntegrationTests/BrokerTopologyTest.cs

@@ -11,7 +11,7 @@ namespace Client.IntegrationTests
     [TestFixture]
     public class BrokerTopologyTest
     {
-        private readonly ZeebeIntegrationTestHelper testHelper = new ZeebeIntegrationTestHelper();
+        private readonly ZeebeIntegrationTestHelper testHelper = ZeebeIntegrationTestHelper.latest();
         private IZeebeClient zeebeClient;
 
         [OneTimeSetUp]
@@ -37,6 +37,9 @@ public async Task RequestTopology()
             // then
             Console.WriteLine(topology);
 
+            var gatewayVersion = topology.GatewayVersion;
+            Assert.AreEqual("0.23.0", gatewayVersion);
+
             var topologyBrokers = topology.Brokers;
             Assert.AreEqual(1, topologyBrokers.Count);
 

Client.IntegrationTests/JobWorkerTest.cs

@@ -14,7 +14,7 @@ public class JobWorkerTest
         private static readonly string DemoProcessPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Resources", "oneTaskProcess.bpmn");
         private static readonly string WorkflowInstanceVariables = "{\"a\":123, \"b\":true}";
 
-        private readonly ZeebeIntegrationTestHelper testHelper = new ZeebeIntegrationTestHelper();
+        private readonly ZeebeIntegrationTestHelper testHelper = ZeebeIntegrationTestHelper.latest();
         private IZeebeClient zeebeClient;
         private long workflowKey;
 

Client.IntegrationTests/OldVersionBrokerTopologyTest.cs

@@ -0,0 +1,62 @@
+using System;
+using System.Threading.Tasks;
+using NUnit.Framework;
+using TestContainers.Core.Builders;
+using TestContainers.Core.Containers;
+using Zeebe.Client;
+using Zeebe.Client.Api.Responses;
+
+namespace Client.IntegrationTests
+{
+    [TestFixture]
+    public class OldVersionBrokerTopologyTest
+    {
+        private const string Version = "0.22.2";
+        private readonly ZeebeIntegrationTestHelper testHelper = ZeebeIntegrationTestHelper.ofVersion(Version);
+        private IZeebeClient zeebeClient;
+
+        [OneTimeSetUp]
+        public async Task Setup()
+        {
+            zeebeClient = await testHelper.SetupIntegrationTest();
+        }
+
+        [OneTimeTearDown]
+        public async Task Stop()
+        {
+            await testHelper.TearDownIntegrationTest();
+        }
+
+        [Test]
+        public async Task RequestTopology()
+        {
+            // given
+
+            // when
+            var topology = await zeebeClient.TopologyRequest().Send();
+
+            // then
+            Console.WriteLine(topology);
+
+            var gatewayVersion = topology.GatewayVersion;
+            Assert.AreEqual("lower then 0.23", gatewayVersion);
+
+            var topologyBrokers = topology.Brokers;
+            Assert.AreEqual(1, topologyBrokers.Count);
+
+            var topologyBroker = topologyBrokers[0];
+            Assert.AreEqual(0, topologyBroker.NodeId);
+
+            // assert host and port ?!
+            // Assert.AreEqual(container.GetMappedPort(26500), topologyBroker.Port);
+
+            var partitions = topologyBroker.Partitions;
+            Assert.AreEqual(1, partitions.Count);
+
+            var partitionInfo = partitions[0];
+            Assert.AreEqual(PartitionBrokerRole.LEADER, partitionInfo.Role);
+            Assert.AreEqual(true, partitionInfo.IsLeader);
+            Assert.AreEqual(1, partitionInfo.PartitionId);
+        }
+    }
+}

Client.IntegrationTests/WorkflowInstanceTest.cs

@@ -15,7 +15,7 @@ public class WorkflowInstanceTest
         private static readonly string SimpleProcessPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Resources", "simpleProcess.bpmn");
         private static readonly string WorkflowInstanceVariables = "{\"a\":123, \"b\":true}";
 
-        private readonly ZeebeIntegrationTestHelper testHelper = new ZeebeIntegrationTestHelper();
+        private readonly ZeebeIntegrationTestHelper testHelper = ZeebeIntegrationTestHelper.latest();
         private IZeebeClient zeebeClient;
 
         [OneTimeSetUp]

Client.IntegrationTests/WorkflowTest.cs

@@ -11,7 +11,7 @@ public class WorkflowTest
     {
         private static readonly string DemoProcessPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Resources", "simpleProcess.bpmn");
 
-        private readonly ZeebeIntegrationTestHelper testHelper = new ZeebeIntegrationTestHelper();
+        private readonly ZeebeIntegrationTestHelper testHelper = ZeebeIntegrationTestHelper.latest();
         private IZeebeClient zeebeClient;
 
         [OneTimeSetUp]

Client.IntegrationTests/ZeebeIntegrationTestHelper.cs

@@ -11,9 +11,28 @@ namespace Client.IntegrationTests
 {
     public class ZeebeIntegrationTestHelper
     {
+        private const string LatestVersion = "0.23.0";
+
         private Container container;
         private IZeebeClient client;
 
+        private readonly string version;
+
+        private ZeebeIntegrationTestHelper(string version)
+        {
+            this.version = version;
+        }
+
+        public static ZeebeIntegrationTestHelper latest()
+        {
+            return new ZeebeIntegrationTestHelper(LatestVersion);
+        }
+
+        public static ZeebeIntegrationTestHelper ofVersion(string version)
+        {
+            return new ZeebeIntegrationTestHelper(version);
+        }
+
         public async Task<IZeebeClient> SetupIntegrationTest()
         {
             container = CreateZeebeContainer();
@@ -36,7 +55,7 @@ private Container CreateZeebeContainer()
         {
             return new GenericContainerBuilder<Container>()
                 .Begin()
-                .WithImage("camunda/zeebe:0.23.0")
+                .WithImage("camunda/zeebe:" + version)
                 .WithExposedPorts(26500)
                 .Build();
         }

Client/Api/Responses/ITopology.cs

@@ -18,7 +18,14 @@ namespace Zeebe.Client.Api.Responses
 {
     public interface ITopology
     {
-        /// <returns>all (known) brokers of the cluster </returns>
+        /// <returns>
+        /// All (known) brokers of the cluster
+        /// </returns>
         IList<IBrokerInfo> Brokers { get; }
+
+        /// <returns>
+        /// The gateway version or 'lower then 0.23' if none was found.
+        /// </returns>
+        string GatewayVersion { get; }
     }
 }

Client/Impl/Responses/Topology.cs

@@ -13,6 +13,7 @@
 //    See the License for the specific language governing permissions and
 //    limitations under the License.
 
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using GatewayProtocol;
@@ -22,16 +23,22 @@ namespace Zeebe.Client.Impl.Responses
 {
     public class Topology : ITopology
     {
+        private const string FallbackVersion = "lower then 0.23";
+
         public IList<IBrokerInfo> Brokers { get; }
+        public string GatewayVersion { get; }
 
         public Topology(TopologyResponse response)
         {
             Brokers = response.Brokers.Select(broker => new BrokerInfo(broker)).Cast<IBrokerInfo>().ToList();
+            GatewayVersion = string.IsNullOrEmpty(response.GatewayVersion) ? FallbackVersion : response.GatewayVersion;
         }
 
         public override string ToString()
         {
-            return "Brokers:\n" + string.Join(",\n", Brokers);
+            return
+                "GatewayVersion: " + GatewayVersion + "\n"
+                + "Brokers:\n" + string.Join(",\n", Brokers);
         }
     }
 }