Receive localstack version as param

Author: Gabriel Galhari

src/main/java/xyz/fabiano/spring/localstack/LocalstackDockerBuilder.java

@@ -28,6 +28,8 @@ public class LocalstackDockerBuilder {
 
     private boolean cborEnable = false;
 
+    private String version = "latest";
+
     private Collection<String> options = new ArrayList<>();
 
     public LocalstackDocker build() {
@@ -44,6 +46,7 @@ public LocalstackDocker build() {
 
         docker.setEnvironmentVariables(environmentVariables);
         docker.setOptions(options);
+        docker.setVersion(version);
         return docker;
     }
 
@@ -125,4 +128,10 @@ public LocalstackDockerBuilder withOptions(Collection<String> options) {
         this.options = options;
         return this;
     }
+
+    public LocalstackDockerBuilder withVersion(String version) {
+        this.version = version;
+        return this;
+    }
+
 }

src/main/java/xyz/fabiano/spring/localstack/autoconfigure/LocalstackAutoConfiguration.java

@@ -34,6 +34,7 @@ public class LocalstackAutoConfiguration {
     private final String services;
     private final boolean autoRemove;
     private final String extraOptions;
+    private final String version;
 
     public LocalstackAutoConfiguration(
         @Value("${spring.localstack.async-clients.enabled:false}") boolean asyncClientsEnabled,
@@ -42,14 +43,16 @@ public LocalstackAutoConfiguration(
         @Value("${spring.localstack.external-host:localhost}") String externalHost,
         @Value("${spring.localstack.services:}") String services,
         @Value("${spring.localstack.auto-remove:true}") boolean autoRemove,
-        @Value("${spring.localstack.extra-options:}") String extraOptions) {
+        @Value("${spring.localstack.extra-options:}") String extraOptions,
+        @Value("${spring.localstack.version:latest}") String version) {
         this.asyncClientsEnabled = asyncClientsEnabled;
         this.pullNewImage = pullNewImage;
         this.randomPorts = randomPorts;
         this.externalHost = externalHost;
         this.services = services;
         this.autoRemove = autoRemove;
         this.extraOptions = extraOptions;
+        this.version = version;
     }
 
     @Bean
@@ -61,6 +64,7 @@ public LocalstackDocker localstackDocker() {
             .disableCBOR()
             .withServices(services())
             .withOptions(options())
+            .withVersion(version)
             .build();
 
         localstackDocker.startup();

src/main/java/xyz/fabiano/spring/localstack/legacy/Container.java

@@ -48,14 +48,16 @@ public static Container createLocalstackContainer(String externalHostName,
                                                       boolean pullNewImage,
                                                       boolean randomizePorts,
                                                       Map<String, String> environmentVariables,
-                                                      Collection<String> options) {
+                                                      Collection<String> options,
+                                                      String version) {
+        String imageName = LOCALSTACK_NAME + ":" + version;
 
         if(pullNewImage) {
             LOG.info("Pulling latest image...");
-            new PullCommand(LOCALSTACK_NAME).execute();
+            new PullCommand(imageName).execute();
         }
 
-        String containerId = new RunCommand(LOCALSTACK_NAME)
+        String containerId = new RunCommand(imageName)
                 .withOptions(options)
                 .withExposedPorts(LOCALSTACK_PORTS, randomizePorts)
                 .withEnvironmentVariable(LOCALSTACK_EXTERNAL_HOSTNAME, externalHostName)

src/main/java/xyz/fabiano/spring/localstack/legacy/LocalstackDocker.java

@@ -55,6 +55,8 @@ public class LocalstackDocker {
     private Map<String, String> environmentVariables = new HashMap<>();
     @Setter
     private Collection<String> options = new ArrayList<>();
+    @Setter
+    private String version = "latest";
 
     @Getter
     private static LocalstackDocker localstackDocker = new LocalstackDocker();
@@ -69,7 +71,7 @@ public void startup() {
         locked = true;
 
         try {
-            localStackContainer = Container.createLocalstackContainer(externalHostName, pullNewImage, randomizePorts, environmentVariables, options);
+            localStackContainer = Container.createLocalstackContainer(externalHostName, pullNewImage, randomizePorts, environmentVariables, options, version);
             loadServiceToPortMap();
 
             LOG.info("Waiting for localstack container to be ready...");