Update README.md

:Why/What:
Ver 23.03.13 Release 진행함.

.gitignore

@@ -0,0 +1 @@
+__pycache__

Dockerfile.cicd

@@ -0,0 +1,4 @@
+FROM python:3.11-slim
+WORKDIR app
+COPY requirements-cicd.txt requirements-cicd.txt
+RUN pip install --upgrade pip && pip install -r requirements-cicd.txt

Dockerfile.dashboard

@@ -0,0 +1,17 @@
+From python:3.11-slim
+
+WORKDIR app
+
+RUN apt-get update \
+    && apt-get -y install --no-install-recommends curl vim git openssh-client \
+    && rm -rf /var/lib/apt/lists/*
+
+COPY requirements-dashboard.txt requirements-dashboard.txt
+RUN pip install --no-cache-dir --upgrade pip && pip install -r requirements-dashboard.txt
+
+ENV PYTHONUNBUFFERED=1
+ENV PYTHONIOENCODING=UTF-8
+
+COPY . .
+
+ENTRYPOINT ["streamlit", "run", "dashboard/main.py"]

README.md

@@ -1 +1,34 @@
-# dsk-version-management
+# DataSaker
+### dsk-23.03.12
+
+# Service Version
+|   Type   | Name                          |  Candidate Version  |  Release Version  |  Product Version  |
+|:--------:|:------------------------------|:-------------------:|:-----------------:|:-----------------:|
+|  front   | dsk-ui                        |   release-0.2.22    |  release-0.2.22   |  release-0.2.22   |
+|   api    | dsk-agent-api                 |   release-0.1.14    |  release-0.1.14   |  release-0.1.14   |
+|   api    | dsk-agentmanager-api          |    release-0.1.6    |   release-0.1.6   |   release-0.1.6   |
+|   api    | dsk-alert-api                 |   release-0.1.17    |  release-0.1.17   |  release-0.1.17   |
+|   api    | dsk-apm-api                   |   release-0.1.15    |  release-0.1.15   |  release-0.1.15   |
+|   api    | dsk-chart-api                 |    release-0.2.8    |   release-0.2.8   |   release-0.2.8   |
+|   api    | dsk-dashboard-api             |   release-0.1.16    |  release-0.1.16   |  release-0.1.16   |
+|   api    | dsk-database-api              |   release-0.1.22    |  release-0.1.22   |  release-0.1.22   |
+|   api    | dsk-infrastructure-api        |   release-0.1.15    |  release-0.1.15   |  release-0.1.15   |
+|   api    | dsk-log-api                   |   release-0.1.12    |  release-0.1.12   |  release-0.1.12   |
+|   api    | dsk-notification-api          |    release-0.2.6    |   release-0.2.6   |   release-0.2.6   |
+|   api    | dsk-usergate-api              |   release-0.1.13    |  release-0.1.13   |  release-0.1.13   |
+|   api    | dsk-app-sender                |    release-0.2.0    |   release-0.2.0   |   release-0.2.0   |
+|   api    | dsk-backoffice                |                     |                   |                   |
+|   api    | dsk-metering-batch            |                     |   release-0.0.3   |                   |
+|   api    | dsk-metering-blocking-batch   |                     |                   |                   |
+|   api    | dsk-live-api                  |                     |                   |                   |
+|   api    | dsk-billing-api               |    release-0.1.2    |   release-0.1.2   |   release-0.1.2   |
+|  stream  | dsk-database-plan-stream      |    release-0.1.1    |   release-0.1.1   |                   |
+|  stream  | dsk-metric-base-agg-stream    |    release-0.1.3    |   release-0.1.3   |   release-0.1.3   |
+|  stream  | dsk-metric-base-flat-stream   |    release-0.1.6    |   release-0.1.6   |   release-0.1.6   |
+|  stream  | dsk-trace-stream              |    release-0.1.3    |   release-0.1.3   |   release-0.1.3   |
+|  stream  | dsk-metric-custom-flat-stream |    release-0.1.3    |   release-0.1.3   |   release-0.1.3   |
+|  stream  | dsk-tagging-connector         |   release-0.1.10    |  release-0.1.10   |  release-0.1.10   |
+|  stream  | dsk-kafka2storage             |    release-0.1.3    |   release-0.1.3   |   release-0.1.3   |
+|  stream  | dsk-log-connector             |    release-0.1.3    |   release-0.1.3   |   release-0.1.3   |
+| datagate | dsk-datagate                  |    release-0.1.6    |   release-0.1.6   |   release-0.1.6   |
+| datagate | dsk-loggate                   |    release-0.1.5    |   release-0.1.5   |   release-0.1.5   |

dashboard/main.py

@@ -0,0 +1,60 @@
+import pandas as pd
+import streamlit as st
+from datetime import datetime
+from streamlit_js_eval import streamlit_js_eval
+from settings import *
+from sidebar import show_sidebar
+
+def highlight_disabled_col(value):
+    return 'background-color: #F0F2F6'
+
+if __name__=='__main__':
+    
+    st.set_page_config(
+        page_title='DataSaker Version Management',
+        layout='wide'
+    )
+    
+    tab1, tab2 = st.tabs(["Deploy DataSaker", "Release Info"])
+    
+    with tab1:
+        st.header('DataSaker')
+        st.write(f"##### {get_datasaker()}")
+            
+        col1, col2 = st.columns([7, 3])
+        with col1:
+            st.subheader('Service')
+            
+            if st.button('Data Reload'):
+                git_pull()
+                streamlit_js_eval(js_expressions='parent.window.location.reload()')
+            
+            df = pd.DataFrame.from_dict(get_service())
+            regex = '^release-[0-9]+.[0-9]+.[0-9]+$'
+            edited_df = st.data_editor(
+                df.style.applymap(highlight_disabled_col), 
+                key='data_editor',
+                column_config={
+                    'type': st.column_config.TextColumn('Type', disabled=True),
+                    'name': st.column_config.TextColumn('Name', disabled=True, width='medium'),
+                    'latest_candidate_version': st.column_config.TextColumn('Candidate Latest Version', disabled=True),
+                    'candidate_version': st.column_config.TextColumn('Candidate Version', validate=regex),
+                    'release_version': st.column_config.TextColumn('Release Version', validate=regex),
+                    'product_version': st.column_config.TextColumn('Product Version', validate=regex)
+                }
+            )
+        with col2:
+            st.text('Edited Rows')
+            st.write(st.session_state['data_editor']['edited_rows'])
+        
+    with tab2:
+        releases = get_github_releases()
+        for release in releases:        
+            st.write(f"### {release['name']}")
+            st.write(release['html_url'])
+            st.write(datetime.strptime(release['published_at'], "%Y-%m-%dT%H:%M:%SZ"))
+            # st.write(datetime.strptime(release['published_at'], "%Y-%m-%dT%H:%M:%SZ").strftime('%Y-%m-%d %H:%M:%S'))
+            st.write(release['body'].replace('#', ''))
+            st.divider()
+            
+    show_sidebar(df, edited_df)

dashboard/settings.py

@@ -0,0 +1,64 @@
+import json, requests, os
+from git import Repo
+
+repo = Repo('.')
+file_path = './version.json'
+repo.config_writer().set_value('user', 'name', 'dsk-minchulahn').release()
+repo.config_writer().set_value('user', 'email', 'minchulahn@ex-em.com').release()
+
+def get_datasaker():
+    return json.load(open(file_path, 'r'))['datasaker']
+
+def get_service():
+    return json.load(open(file_path, 'r'))['service']
+
+def get_commit_id():
+    return repo.head.commit
+
+def get_tags():
+    return repo.tags
+
+def get_github_releases():
+    api_url = 'https://api.github.com/repos/cloudmoa/dsk-version-management/releases'
+    github_token = os.environ.get('GITHUB_TOKEN')
+    headers = {'Authorization': f'Bearer {github_token}', 'Accept': 'application/vnd.github.v3+json'}
+    releases = requests.get(api_url, headers=headers).json()
+    return releases
+
+def diff():
+    if len(repo.index.diff(repo.head.commit)) > 0:
+        return True
+    return False
+
+def diff_remote_head():
+    repo.remote().fetch()
+    remote_head = repo.remote().refs['main'].commit
+    
+    if repo.head.commit == remote_head:
+        return True
+    else:
+        return False
+
+def git_pull():
+    repo.remote().fetch()
+    repo.remotes.origin.pull()
+
+def git_push(commit_message, extended_description):
+    repo.git.add('version.json')
+    
+    if len(repo.index.diff(repo.head.commit)) > 0:
+        repo.index.commit(f'{commit_message}\n\n{extended_description}')
+        repo.git.push(force=False)
+
+def publish_release(selected_tag, release_title, release_describe):
+    api_url = 'https://api.github.com/repos/cloudmoa/sample-app/releases'
+    github_token = os.environ.get('GITHUB_TOKEN')
+    headers = {'Authorization': f'Bearer {github_token}', 'Accept': 'application/vnd.github.v3+json'}
+    release_data = {
+        'tag_name': selected_tag,
+        'name': release_title,
+        'body': release_describe,
+        'draft': False,
+        'prerelease': False
+    }
+    return requests.post(api_url, json=release_data, headers=headers)

dashboard/sidebar.py

@@ -0,0 +1,78 @@
+import json, time
+import streamlit as st
+from streamlit_js_eval import streamlit_js_eval
+from settings import *
+
+def set_extended_description(edited_df):
+    json_edited_df = json.loads(edited_df.to_json(orient='records'))
+    extended_description_value = []
+    for idx, changed_idx in enumerate(st.session_state['data_editor']['edited_rows']):
+        if idx == 0: 
+            extended_description_value.append(json_edited_df[changed_idx]['name'])
+        else: 
+            extended_description_value.append('\n' + json_edited_df[changed_idx]['name'])
+        
+        if 'candidate_version' in st.session_state['data_editor']['edited_rows'][changed_idx]:
+            extended_description_value.append(f"candidate: {st.session_state['data_editor']['edited_rows'][changed_idx]['candidate_version']}")
+        if 'release_version' in st.session_state['data_editor']['edited_rows'][changed_idx]:
+            extended_description_value.append(f"release: {st.session_state['data_editor']['edited_rows'][changed_idx]['release_version']}")
+        if 'product_version' in st.session_state['data_editor']['edited_rows'][changed_idx]:
+            extended_description_value.append(f"product: {st.session_state['data_editor']['edited_rows'][changed_idx]['product_version']}")
+    return '\n'.join(extended_description_value)
+
+def set_version_json(edited_df):
+    data = {'datasaker': get_datasaker(),'service': json.loads(edited_df.to_json(orient='records'))}
+    with open('version.json', 'w') as file: 
+        json.dump(data, file, indent=4)
+
+def show_sidebar(df, edited_df):
+    with st.sidebar:
+        st.subheader('Git Push')
+        with st.expander('Git Push'):
+            commit_message = st.text_input('Commit Message', value='Update version.json')
+            extended_description = st.text_area('Extended description', value=set_extended_description(edited_df), height=200)
+                
+            if st.button(key='push', label='Commit changes'):
+                if commit_message:
+                    if diff_remote_head():
+                        if df.equals(edited_df):
+                            st.warning('No changes have been made', icon='⚠️')
+                        else:
+                            set_version_json(edited_df)
+                            git_push(commit_message, extended_description)
+                            st.success('Success', icon='✅')
+                            time.sleep(1)
+                            streamlit_js_eval(js_expressions='parent.window.location.reload()')
+                    else:
+                        st.error('Updates were rejected because the tip of your current branch is behind', icon='🚨')
+                        
+        st.divider()
+        
+        st.subheader('Draft a new release')
+        with st.expander('Draft a new release'):
+            tags = [tag.name for tag in get_tags()]
+            tags.insert(0, "")
+            new_tag = st.text_input('Create a new tag')
+            
+            if new_tag:
+                if new_tag in tags:
+                    st.warning('Existing tag', icon='⚠️')
+                else:
+                    tags.insert(0, new_tag)
+            
+            selected_tag = st.selectbox('Choose a tag', tags)
+            release_title = st.text_input('Release title', value=selected_tag)
+            release_describe = st.text_area('Describe this release', value='## Production에 변경된 Version')
+            
+            if st.button(key='release', label='Publish release'):
+                response = publish_release(selected_tag, release_title, release_describe)
+                
+                if response.status_code == 201:
+                    st.success('Release created successfully', icon='✅')
+                    git_pull()
+                    streamlit_js_eval(js_expressions='parent.window.location.reload()')
+                else:
+                    st.error(f'Failed to create release. Status code: {response.status_code}', icon='🚨')
+                    st.error(f'Response: {response.text}', icon='🚨')
+        
+        st.divider()

main.py

@@ -1,28 +0,0 @@
-import json, sys, traceback
-
-def get_service_index():
-    for index, value in enumerate(json_data['service']):
-        if(value['name'] == serviceName):
-            return index
-    exit(traceback.print_exc())
-    
-def set_latest_version():
-    service_index = get_service_index()
-    json_data["service"][service_index]["latest_candidate_version"] = releaseTag
-    
-if __name__ == '__main__':
-    if len(sys.argv) != 3:
-        exit(traceback.print_exc())
-        
-    
-    releaseTag = sys.argv[1]
-    serviceName = sys.argv[2]    
-    file_path = "./version.json"
-    
-    with open(file_path, 'r') as json_file:
-        json_data = json.load(json_file)
-    
-    set_latest_version()
-
-    with open(file_path, 'w') as file: 
-        json.dump(json_data, file, indent=4)

requirements-cicd.txt

@@ -0,0 +1,4 @@
+jsontemplates==0.1.0
+PyYAML==6.0
+pandas==2.0.2
+tabulate==0.9.0

requirements-dashboard.txt

@@ -0,0 +1,3 @@
+GitPython==3.1.32
+streamlit==1.25.0
+streamlit_js_eval==0.1.5

requirements.txt

@@ -1,2 +0,0 @@
-jsontemplates==0.1.0
-PyYAML==6.0

update_dsk_version.py

@@ -0,0 +1,15 @@
+import json, sys, traceback
+
+if len(sys.argv) != 2:
+    exit(traceback.print_exc())
+
+releaseTag = sys.argv[1]
+file_path = "./version.json"
+
+with open(file_path, 'r') as file:
+    data = json.load(file)
+
+data["datasaker"] = releaseTag
+
+with open(file_path, 'w') as file: 
+    json.dump(data, file, indent=4)

update_readme.py

@@ -0,0 +1,13 @@
+import json, pandas
+
+version_file_path= "./version.json"
+readme_file_path= "./README.md"
+
+data = json.load(open(version_file_path, 'r'))
+
+df = pandas.DataFrame.from_dict(data['service']).rename(columns={'type':'Type', 'name':'Name', 'candidate_version':'Candidate Version', 'release_version':'Release Version', 'product_version':'Product Version'})
+df.drop(['latest_candidate_version'], axis=1, inplace=True)
+
+with open(readme_file_path, 'w') as file:
+    file.write("# DataSaker\n### {}\n\n".format(data["datasaker"]))
+    file.write("# Service Version\n{}".format(df.to_markdown(index=False, colalign=("center", "left", "center", "center", "center"))))

update_version.py

@@ -0,0 +1,26 @@
+import json, sys, traceback
+
+if len(sys.argv) != 3:
+    exit(traceback.print_exc())
+
+def get_service_index():
+    for index, value in enumerate(json_data['service']):
+        if(value['name'] == serviceName):
+            return index
+    exit(traceback.print_exc())
+    
+def set_latest_version():
+    service_index = get_service_index()
+    json_data["service"][service_index]["latest_candidate_version"] = releaseTag
+    
+releaseTag = sys.argv[1]
+serviceName = sys.argv[2]
+file_path = "./version.json"
+
+with open(file_path, 'r') as json_file:
+    json_data = json.load(json_file)
+
+set_latest_version()
+
+with open(file_path, 'w') as file: 
+    json.dump(json_data, file, indent=4)

version.json

@@ -1,109 +1,109 @@
 {
-    "datasaker": "dsk-23.02.1",
+    "datasaker": "dsk-23.03.12",
     "service": [
         {
             "type": "front",
             "name": "dsk-ui",
-            "latest_candidate_version": "release-0.1.15",
-            "candidate_version": "release-0.1.15",
-            "release_version": "release-0.1.15",
-            "product_version": ""
+            "latest_candidate_version": "release-0.2.22",
+            "candidate_version": "release-0.2.22",
+            "release_version": "release-0.2.22",
+            "product_version": "release-0.2.22"
         },
         {
             "type": "api",
             "name": "dsk-agent-api",
-            "latest_candidate_version": "release-0.1.4",
-            "candidate_version": "release-0.1.4",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.14",
+            "candidate_version": "release-0.1.14",
+            "release_version": "release-0.1.14",
+            "product_version": "release-0.1.14"
         },
         {
             "type": "api",
             "name": "dsk-agentmanager-api",
-            "latest_candidate_version": "release-0.1.4",
-            "candidate_version": "release-0.1.4",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.6",
+            "candidate_version": "release-0.1.6",
+            "release_version": "release-0.1.6",
+            "product_version": "release-0.1.6"
         },
         {
             "type": "api",
             "name": "dsk-alert-api",
-            "latest_candidate_version": "release-0.1.4",
-            "candidate_version": "release-0.1.4",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.17",
+            "candidate_version": "release-0.1.17",
+            "release_version": "release-0.1.17",
+            "product_version": "release-0.1.17"
         },
         {
             "type": "api",
             "name": "dsk-apm-api",
-            "latest_candidate_version": "release-0.1.5",
-            "candidate_version": "release-0.1.5",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.15",
+            "candidate_version": "release-0.1.15",
+            "release_version": "release-0.1.15",
+            "product_version": "release-0.1.15"
         },
         {
             "type": "api",
             "name": "dsk-chart-api",
-            "latest_candidate_version": "release-0.1.7",
-            "candidate_version": "release-0.1.7",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.2.8",
+            "candidate_version": "release-0.2.8",
+            "release_version": "release-0.2.8",
+            "product_version": "release-0.2.8"
         },
         {
             "type": "api",
             "name": "dsk-dashboard-api",
-            "latest_candidate_version": "release-0.1.6",
-            "candidate_version": "release-0.1.6",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.16",
+            "candidate_version": "release-0.1.16",
+            "release_version": "release-0.1.16",
+            "product_version": "release-0.1.16"
         },
         {
             "type": "api",
             "name": "dsk-database-api",
-            "latest_candidate_version": "release-0.1.8",
-            "candidate_version": "release-0.1.8",
-            "release_version": "release-0.1.7",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.22",
+            "candidate_version": "release-0.1.22",
+            "release_version": "release-0.1.22",
+            "product_version": "release-0.1.22"
         },
         {
             "type": "api",
             "name": "dsk-infrastructure-api",
-            "latest_candidate_version": "release-0.1.6",
-            "candidate_version": "release-0.1.6",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.15",
+            "candidate_version": "release-0.1.15",
+            "release_version": "release-0.1.15",
+            "product_version": "release-0.1.15"
         },
         {
             "type": "api",
             "name": "dsk-log-api",
-            "latest_candidate_version": "release-0.1.6",
-            "candidate_version": "release-0.1.6",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.12",
+            "candidate_version": "release-0.1.12",
+            "release_version": "release-0.1.12",
+            "product_version": "release-0.1.12"
         },
         {
             "type": "api",
             "name": "dsk-notification-api",
-            "latest_candidate_version": "release-0.1.4",
-            "candidate_version": "release-0.1.4",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.2.6",
+            "candidate_version": "release-0.2.6",
+            "release_version": "release-0.2.6",
+            "product_version": "release-0.2.6"
         },
         {
             "type": "api",
             "name": "dsk-usergate-api",
-            "latest_candidate_version": "release-0.1.6",
-            "candidate_version": "release-0.1.5",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.13",
+            "candidate_version": "release-0.1.13",
+            "release_version": "release-0.1.13",
+            "product_version": "release-0.1.13"
         },
         {
             "type": "api",
             "name": "dsk-app-sender",
-            "latest_candidate_version": "release-0.1.4",
-            "candidate_version": "release-0.1.4",
-            "release_version": "release-0.1.4",
-            "product_version": ""
+            "latest_candidate_version": "release-0.2.0",
+            "candidate_version": "release-0.2.0",
+            "release_version": "release-0.2.0",
+            "product_version": "release-0.2.0"
         },
         {
             "type": "api",
@@ -116,6 +116,14 @@
         {
             "type": "api",
             "name": "dsk-metering-batch",
+            "latest_candidate_version": "release-0.0.3",
+            "candidate_version": "",
+            "release_version": "release-0.0.3",
+            "product_version": ""
+        },
+        {
+            "type": "api",
+            "name": "dsk-metering-blocking-batch",
             "latest_candidate_version": "",
             "candidate_version": "",
             "release_version": "",
@@ -129,6 +137,14 @@
             "release_version": "",
             "product_version": ""
         },
+        {
+            "type": "api",
+            "name": "dsk-billing-api",
+            "latest_candidate_version": "release-0.1.2",
+            "candidate_version": "release-0.1.2",
+            "release_version": "release-0.1.2",
+            "product_version": "release-0.1.2"
+        },
         {
             "type": "stream",
             "name": "dsk-database-plan-stream",
@@ -140,66 +156,74 @@
         {
             "type": "stream",
             "name": "dsk-metric-base-agg-stream",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": "release-0.1.2"
+            "latest_candidate_version": "release-0.1.3",
+            "candidate_version": "release-0.1.3",
+            "release_version": "release-0.1.3",
+            "product_version": "release-0.1.3"
         },
         {
             "type": "stream",
             "name": "dsk-metric-base-flat-stream",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": "release-0.1.2"
+            "latest_candidate_version": "release-0.1.6",
+            "candidate_version": "release-0.1.6",
+            "release_version": "release-0.1.6",
+            "product_version": "release-0.1.6"
         },
         {
             "type": "stream",
             "name": "dsk-trace-stream",
-            "latest_candidate_version": "release-0.1.1",
-            "candidate_version": "release-0.1.1",
-            "release_version": "release-0.1.1",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.3",
+            "candidate_version": "release-0.1.3",
+            "release_version": "release-0.1.3",
+            "product_version": "release-0.1.3"
         },
         {
             "type": "stream",
             "name": "dsk-metric-custom-flat-stream",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": "release-0.1.2"
+            "latest_candidate_version": "release-0.1.3",
+            "candidate_version": "release-0.1.3",
+            "release_version": "release-0.1.3",
+            "product_version": "release-0.1.3"
         },
         {
             "type": "stream",
             "name": "dsk-tagging-connector",
-            "latest_candidate_version": "release-0.1.1",
-            "candidate_version": "release-0.1.1",
-            "release_version": "release-0.1.1",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.10",
+            "candidate_version": "release-0.1.10",
+            "release_version": "release-0.1.10",
+            "product_version": "release-0.1.10"
         },
         {
             "type": "stream",
             "name": "dsk-kafka2storage",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.3",
+            "candidate_version": "release-0.1.3",
+            "release_version": "release-0.1.3",
+            "product_version": "release-0.1.3"
+        },
+        {
+            "type": "stream",
+            "name": "dsk-log-connector",
+            "latest_candidate_version": "release-0.1.3",
+            "candidate_version": "release-0.1.3",
+            "release_version": "release-0.1.3",
+            "product_version": "release-0.1.3"
         },
         {
             "type": "datagate",
             "name": "dsk-datagate",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.6",
+            "candidate_version": "release-0.1.6",
+            "release_version": "release-0.1.6",
+            "product_version": "release-0.1.6"
         },
         {
             "type": "datagate",
             "name": "dsk-loggate",
-            "latest_candidate_version": "release-0.1.2",
-            "candidate_version": "release-0.1.2",
-            "release_version": "release-0.1.2",
-            "product_version": ""
+            "latest_candidate_version": "release-0.1.5",
+            "candidate_version": "release-0.1.5",
+            "release_version": "release-0.1.5",
+            "product_version": "release-0.1.5"
         }
     ]
 }