feat: microcks#1020 Enable building the new uber-async-minion contain…

…er image

Signed-off-by: Laurent Broudoux <laurent.broudoux@gmail.com>

Signed-off-by: Appadoo Apoorva Srinivas <apoorva.appadoo@orange.com>

.github/workflows/build-verify.yml

@@ -115,4 +115,18 @@ jobs:
             --provenance=false \
             --build-arg TAG=$IMAGE_TAG \
             --file src/main/docker/Dockerfile \
-            --tag=quay.io/microcks/microcks-uber:$IMAGE_TAG .
+            --tag=quay.io/microcks/microcks-uber:$IMAGE_TAG .
+
+      - name: Build and push container for async minion in uber distro
+        if: github.repository_owner == 'microcks' && env.PACKAGE_IMAGE == 'true'
+        run: |
+          cd ${{github.workspace}}/distro/uber-async-minion
+          mvn -B -q -DskipTests package
+          #docker build -f src/main/docker/Dockerfile.jvm -t quay.io/microcks/microcks-user-async-minion:$IMAGE_TAG .
+          docker buildx build --push \
+            --platform=linux/amd64,linux/arm64 \
+            --builder=buildx-multi-arch \
+            --provenance=false \
+            --build-arg TAG=$IMAGE_TAG \
+            --file src/main/docker/Dockerfile.jvm \
+            --tag=quay.io/microcks/microcks-uber-async-minion:$IMAGE_TAG .

distro/uber/src/main/java/io/github/microcks/listener/WebSocketServiceChangeEventChannel.java

@@ -0,0 +1,72 @@
+/*
+ * Copyright The Microcks 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.
+ */
+
+package io.github.microcks.listener;
+
+import io.github.microcks.event.ServiceViewChangeEvent;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Primary;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.CloseStatus;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+import org.springframework.web.socket.handler.TextWebSocketHandler;
+
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+/**
+ * This is an implementation of {@code ServiceChangeEventChannel} that uses a WebSocket endpoint as
+ * a destination recipient for {@code ServiceViewChangeEvent}.
+ * @author laurent
+ */
+@Component
+@Primary
+@Profile("uber")
+public class WebSocketServiceChangeEventChannel extends TextWebSocketHandler
+      implements ServiceChangeEventChannel {
+
+   /** A simple logger for diagnostic messages. */
+   private static Logger log = LoggerFactory.getLogger(WebSocketServiceChangeEventChannel.class);
+
+   private ObjectMapper mapper = new ObjectMapper();
+
+   private List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
+
+   @Override
+   public void sendServiceViewChangeEvent(ServiceViewChangeEvent event) throws Exception {
+      log.debug("Sending ServiceViewChangeEvent to {} connected WS sessions", sessions.size());
+      for (WebSocketSession wsSession : sessions) {
+         wsSession.sendMessage(new TextMessage(mapper.writeValueAsString(event)));
+      }
+   }
+
+   @Override
+   public void afterConnectionEstablished(WebSocketSession session) throws Exception {
+      log.debug("afterConnectionEstablished, session: {}", session.getId());
+      sessions.add(session);
+   }
+
+   @Override
+   public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
+      log.debug("afterConnectionClosed, session: {}", session.getId());
+      sessions.remove(session);
+   }
+}