Remove Fixed Dapr Version Constraint (drasi-project#147)

* updated mongo statestore

* updated e2e test settings

* nit

* updated devskim version

* updated timeout value

* test fix

* nit

* added a comment explaining the changes

* minor fix

* dapr label selector

* dapr label selector

* updated based on PR comments

* use service name in mongo connectionString

Author: ruokun-niu

cli/cmd/init.go

@@ -108,8 +108,8 @@ Usage examples:
 	initCommand.Flags().String("registry", config.Registry, "Container registry to pull images from.")
 	initCommand.Flags().String("version", config.Version, "Container image version tag.")
 	initCommand.Flags().StringP("namespace", "n", "drasi-system", "Kubernetes namespace to install Drasi into.")
-	initCommand.Flags().String("dapr-runtime-version", "1.10.0", "Dapr runtime version to install.")
-	initCommand.Flags().String("dapr-sidecar-version", "1.9.0", "Dapr sidecar (daprd) version to install.")
+	initCommand.Flags().String("dapr-runtime-version", "", "Dapr runtime version to install.")
+	initCommand.Flags().String("dapr-sidecar-version", "latest", "Dapr sidecar (daprd) version to install.")
 	initCommand.Flags().String("dapr-registry", "docker.io/daprio", "Container registry to pull Dapr images from.")
 	return initCommand
 }

cli/service/installer.go

@@ -329,7 +329,8 @@ func (t *Installer) installQueryContainer(output output.TaskOutput, namespace st
 	if err := drasiClient.Apply(manifests, subOutput); err != nil {
 		return err
 	}
-	if err := drasiClient.ReadyWait(manifests, 150, subOutput); err != nil {
+
+	if err := drasiClient.ReadyWait(manifests, 180, subOutput); err != nil {
 		return err
 	}
 	output.SucceedTask("Query-Container", "Query container created")
@@ -625,7 +626,7 @@ func (t *Installer) checkDaprInstallation(output output.TaskOutput) (bool, error
 	podsClient := t.kubeClient.CoreV1().Pods("dapr-system")
 
 	pods, err := podsClient.List(context.TODO(), metav1.ListOptions{
-		LabelSelector: "app.kubernetes.io/name=dapr",
+		LabelSelector: "app.kubernetes.io/part-of=dapr",
 	})
 	if err != nil {
 		output.FailTask("Dapr-Check", fmt.Sprintf("Error checking for Dapr: %v", err.Error()))

cli/service/resources/infra.yaml

@@ -1,17 +1,17 @@
-# Copyright 2024 The Drasi Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
+# Copyright 2024 The Drasi Authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
 apiVersion: scheduling.k8s.io/v1
 kind: PriorityClass
 metadata:
@@ -316,12 +316,12 @@ spec:
   type: state.mongodb
   version: v1
   metadata:
-    - name: host
-      value: drasi-mongo:27017
-    - name: username
-      value:
-    - name: password
-      value:
+    - name: connectionString
+      value: "mongodb://drasi-mongo:27017/?replicaSet=rs0"
+      # The replicaSet parameter is required to enable MongoDB transactions.
+      # Without this, MongoDB treats the connection as a standalone instance,
+      # which does not support transactions (which ultimately means we won't be
+      # able to use it as an actor statestore).
     - name: actorStateStore
       value: "true"
 ---
@@ -344,4 +344,3 @@ spec:
     - name: redisPassword
       value: ""
 
-

e2e-tests/03-kubernetes-scenario/k8s.test.js

@@ -50,7 +50,7 @@ beforeAll(async () => {
   dbClient.port = await dbPortForward.start();
   await dbClient.connect();
   await new Promise((r) => setTimeout(r, 5000));
-}, 120000);
+}, 180000);
 
 afterAll(async () => {
   await signalrFixture.stop();

e2e-tests/fixtures/signalr-fixture.js

@@ -189,7 +189,9 @@ function signalrReactionManifest(queryIds) {
   let result = {
     apiVersion: "v1",
     kind: "Reaction",
-    name: `signalr-${crypto.randomUUID().toString()}`,
+    name: `signalr-${crypto.randomUUID().toString()}`, 
+    // Sometimes the uuid will begin with a number, which is not allowed in k8s resource names
+    // as a result, we prepend the name with 'signalr-' to ensure it is a valid name
     spec: {
       kind: "SignalR",
       queries: queryIds.reduce((a, v) => ({ ...a, [v]: "" }), {}),

reactions/platform/result-reaction/Program.cs

@@ -32,7 +32,6 @@
 }
 
 
-
 builder.Services.AddSingleton<IResultViewClient, ResultViewClient>();
 
 
@@ -139,7 +138,7 @@ async IAsyncEnumerable<JsonElement> GetCurrentResultAtTimeStamp()
 });
 
 
-app.RunAsync();
+await app.RunAsync();
 
 bool isValidQueryId(string queryId)
 {