[docker run] Make the version configurable (#411)

Author: eolivelli

.github/workflows/release.yml

@@ -50,6 +50,7 @@ jobs:
             docker push $repo/$image:$docker_tag
           }
           tag_and_push langstream-runtime
+          tag_and_push langstream-runtime-tester
           tag_and_push langstream-cli
           tag_and_push langstream-deployer
           tag_and_push langstream-control-plane

examples/instances/kafka-docker.yaml

@@ -20,4 +20,4 @@ instance:
     type: "kafka"
     configuration:
       admin:
-        bootstrap.servers: localhost:39092
+        bootstrap.servers: localhost:9092

langstream-cli/src/main/java/ai/langstream/cli/commands/VersionProvider.java

@@ -19,27 +19,32 @@
 import java.io.InputStream;
 import java.net.URL;
 import java.util.Enumeration;
+import java.util.List;
 import java.util.jar.Attributes;
 import java.util.jar.Manifest;
 import picocli.CommandLine;
 
 public class VersionProvider implements CommandLine.IVersionProvider {
 
-    private static final String[] VERSION = new String[] {getVersionFromJar()};
+    private static final List<String> VERSION_INFO = getVersionFromJar();
+
+    public static String getMavenVersion() {
+        return VERSION_INFO.get(1);
+    }
 
     public String[] getVersion() {
-        return VERSION;
+        return new String[] {VERSION_INFO.get(0)};
     }
 
-    private static String getVersionFromJar() {
+    private static List<String> getVersionFromJar() {
         try {
             Manifest manifest = getManifest();
             final String version = getVersionFromManifest(manifest);
             final String gitRevision = getGitRevisionFromManifest(manifest);
-            return String.format("LangStream CLI %s (%s)", version, gitRevision);
+            return List.of(String.format("LangStream CLI %s (%s)", version, gitRevision), version);
         } catch (Throwable t) {
             // never ever let this exception bubble up otherwise any command will fail
-            return String.format("Error: %s", t.getMessage());
+            return List.of(String.format("Error: %s", t.getMessage()), "unknown");
         }
     }
 

langstream-cli/src/main/java/ai/langstream/cli/commands/docker/LocalRunApplicationCmd.java

@@ -15,6 +15,7 @@
  */
 package ai.langstream.cli.commands.docker;
 
+import ai.langstream.cli.commands.VersionProvider;
 import ai.langstream.cli.util.LocalFileReferenceResolver;
 import java.io.File;
 import java.nio.charset.StandardCharsets;
@@ -87,9 +88,35 @@ public class LocalRunApplicationCmd extends BaseDockerCmd {
             description = "Command to run docker")
     private String dockerCommand = "docker";
 
+    @CommandLine.Option(
+            names = {"--langstream-runtime-version"},
+            description = "Version of the LangStream runtime to use")
+    private String dockerImageVersion = VersionProvider.getMavenVersion();
+
+    @CommandLine.Option(
+            names = {"--langstream-runtime-docker-image"},
+            description = "Docker image of the LangStream runtime to use")
+    private String dockerImageName;
+
     @Override
     @SneakyThrows
     public void run() {
+
+        if (dockerImageVersion != null && dockerImageVersion.endsWith("-SNAPSHOT")) {
+            // built-from-sources, not a release
+            dockerImageVersion = "latest-dev";
+        }
+
+        if (dockerImageName == null) {
+            if (dockerImageVersion != null && dockerImageVersion.equals("latest-dev")) {
+                // built-from-sources, not a release
+                dockerImageName = "langstream/langstream-runtime-tester";
+            } else {
+                // default to latest
+                dockerImageName = "ghcr.io/langstream/langstream-runtime-tester";
+            }
+        }
+
         final File appDirectory = checkFileExistsOrDownload(appPath);
         final File instanceFile = checkFileExistsOrDownload(instanceFilePath);
         final File secretsFile = checkFileExistsOrDownload(secretFilePath);
@@ -169,7 +196,7 @@ private void executeOnDocker(
         Files.write(tmpInstanceFile.toPath(), instanceContents.getBytes(StandardCharsets.UTF_8));
         File tmpSecretsFile = Files.createTempFile("secrets", ".yaml").toFile();
         Files.write(tmpSecretsFile.toPath(), secretsContents.getBytes(StandardCharsets.UTF_8));
-        String imageName = "langstream/langstream-runtime-tester:latest-dev";
+        String imageName = dockerImageName + ":" + dockerImageVersion;
         List<String> commandLine = new ArrayList<>();
         commandLine.add(dockerCommand);
         commandLine.add("run");

langstream-cli/src/main/java/ai/langstream/cli/commands/gateway/ChatGatewayCmd.java

@@ -41,8 +41,9 @@ public class ChatGatewayCmd extends BaseGatewayCmd {
     @CommandLine.Parameters(description = "Application ID")
     private String applicationId;
 
-    // optional
-    @CommandLine.Parameters(arity = "1..2", description = "Chat gateway ID")
+    @CommandLine.Option(
+            names = {"-g", "--chat-gateway"},
+            description = "Use a 'chat' gateway")
     private String chatGatewayId;
 
     @CommandLine.Option(