add deploy action

.github/workflows/deploy-run-test.yml

@@ -0,0 +1,174 @@
+name: Deploy and Test
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    types: [ opened, synchronize, reopened ]
+jobs:
+  test:
+    name: Deploy and Test
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+      - name: Set up Maven
+        run: |
+          sudo apt-get update
+          sudo apt-get install -y maven
+      - name: Set up JDK 17
+        uses: actions/setup-java@v3
+        with:
+          java-version: 17
+          distribution: 'temurin'
+
+      - name: Build and package
+        run: mvn clean package -am && echo "Maven Build and package succeeded" || { echo "Maven Build and package failed."; exit 1; }
+
+      - name: Run Internal Test
+        run: mvn test && echo "Maven Run Internal Test succeeded"|| { echo "Run Internal Test failed."; exit 1; }
+
+      - name: Install Docker Compose
+        run: |
+          sudo curl -L "https://github.com/docker/compose/releases/latest/download/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
+          sudo chmod +x /usr/local/bin/docker-compose
+
+      - name: Deploy with Docker Compose
+        run: |
+          cd docker
+          docker-compose up -d
+
+      - name: Wait for service to start
+        run: sleep 2s
+
+      - name: Run API Test
+        run: |
+          set response $(curl --location 'http://localhost:8080/flow/bg/manage/descriptor/add_descriptor.json?business_id=rillFlowSample&feature_name=choiceSample&alias=release' \
+          --header 'Content-Type: text/plain' \
+          --data-raw "$(cat docs/samples/choice-sample.yaml)")
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API choiceSample add descriptor test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API choiceSample add descriptor test succeeded."
+          else
+            echo "API choiceSample add descriptor test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/submit.json?descriptor_id=rillFlowSample:choiceSample' \
+          --header 'Content-Type: application/json' \
+          --data '{"input_num":10}')
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API choiceSample submit test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API choiceSample submit test succeeded."
+          else
+            echo "API choiceSample submit test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/bg/manage/descriptor/add_descriptor.json?business_id=rillFlowSample&feature_name=callApiSample&alias=release' \
+          --header 'Content-Type: text/plain' \
+          --data-raw "$(cat docs/samples/call-api-sample.yaml)")
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API callApiSample add descriptor test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API callApiSample add descriptor test succeeded."
+          else
+            echo "API callApiSample add descriptor test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/submit.json?descriptor_id=rillFlowSample:callApiSample' \
+          --header 'Content-Type: application/json' \
+          --data '{"input_num":10}')
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API callApiSample submit test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API callApiSample submit test succeeded."
+          else
+            echo "API callApiSample submit test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/bg/manage/descriptor/add_descriptor.json?business_id=rillFlowSample&feature_name=parallelAsyncTask&alias=release' \
+          --header 'Content-Type: text/plain' \
+          --data-raw "$(cat docs/samples/parallel-async-dag.yaml)")
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API parallelAsyncTask add descriptor test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API parallelAsyncTask add descriptor test succeeded."
+          else
+            echo "API parallelAsyncTask add descriptor test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/submit.json?descriptor_id=rillFlowSample:parallelAsyncTask' \
+          --header 'Content-Type: application/json' \
+          --data '{"rand_num":20}')
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API parallelAsyncTask submit test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API parallelAsyncTask submit test succeeded."
+          else
+            echo "API parallelAsyncTask submit test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/bg/manage/descriptor/add_descriptor.json?business_id=rillFlowSample&feature_name=subdagTask&alias=release' \
+          --header 'Content-Type: text/plain' \
+          --data-raw "$(cat docs/samples/ref-dag.yaml)")
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API subdagTask add descriptor test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API subdagTask add descriptor test succeeded."
+          else
+            echo "API subdagTask add descriptor test failed. Response: $response"
+            exit 1
+          fi
+
+          set response $(curl --location 'http://localhost:8080/flow/submit.json?descriptor_id=rillFlowSample:subdagTask' \
+          --header 'Content-Type: application/json' \
+          --data '{"parent_rand_num":20}')
+
+          if [[ "$?" -ne 0 ]]; then
+          echo "Failed to connect to server. API subdagTask submit test failed."
+          exit 1
+          fi
+
+          if [[ "$response" != *"\"error_code\":"* ]]; then
+            echo "API subdagTask submit test succeeded."
+          else
+            echo "API subdagTask submit test failed. Response: $response"
+            exit 1
+          fi
+

docker/docker-compose.yml

@@ -0,0 +1,35 @@
+version: '3'
+services:
+  rill-flow:
+    image: weibocom/rill-flow
+    depends_on:
+      - cache
+      - jaeger
+    ports:
+      - "8080:8080"
+    environment:
+      - RILL_FLOW_DESCRIPTOR_REDIS_HOST=cache
+      - RILL_FLOW_DEFAULT_REDIS_HOST=cache
+      - RILL_FLOW_TRACE_ENDPOINT=http://jaeger:4317
+      - RILL_FLOW_CALLBACK_URL=http://rill-flow:8080/flow/finish.json
+      - RILL_FLOW_TRACE_QUERY_HOST=http://jaeger:16686
+  cache:
+    image: redis:6.2-alpine
+    restart: always
+    command: redis-server --save 20 1 --loglevel warning
+  jaeger:
+    image: jaegertracing/all-in-one:1.39
+    restart: always
+    environment:
+      - COLLECTOR_OTLP_ENABLED=true
+  ui:
+    image: weibocom/rill-flow-ui
+    ports:
+      - "8088:80"
+    depends_on:
+      - rill-flow
+      - jaeger
+    environment:
+      - BACKEND_SERVER=http://rill-flow:8080
+  sample-executor:
+    image: weibocom/rill-flow-sample:sample-executor