Initial code (#1)

* first code

* add namespace API class

Author: Leemoonsoo

.github/workflows/build-test.yml

@@ -0,0 +1,29 @@
+name: Build and Test
+
+on:
+  push:
+    tags-ignore:
+      - '*.*'
+    branches:
+      - master
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        python-version: [3.6, 3.7, 3.8]
+    steps:
+    - name: Checkout latest code
+      uses: actions/checkout@v2
+    - name: Set up Python ${{ matrix.python-version }}
+      uses: actions/setup-python@v2
+      with:
+        python-version: ${{ matrix.python-version }}
+    - name: Install dependencies
+      run: |
+        make init
+    - name: Test
+      run: |
+        make test

.github/workflows/publish-release.yml

@@ -0,0 +1,31 @@
+name: Publish release
+
+on:
+  release:
+    types: [created]
+
+jobs:
+  publish-release:
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout latest code
+      uses: actions/checkout@v2
+    - name: Set up Python 3.7
+      uses: actions/setup-python@v2
+      with:
+        python-version: 3.7
+    - name: Install dependencies
+      run: |
+        make init
+    - name: Test
+      run: |
+        make test
+    - name: bulid package
+      run: |
+        python setup.py sdist
+    - name: Publish a Python distribution to PyPI
+      uses: pypa/gh-action-pypi-publish@master
+      with:
+        user: __token__
+        password: ${{ secrets.pypi_password }}

.gitignore

@@ -127,3 +127,5 @@ dmypy.json
 
 # Pyre type checker
 .pyre/
+
+py3/

Makefile

@@ -0,0 +1,8 @@
+
+init:
+	pip install -r requirements.txt
+
+test:
+	python -m unittest
+
+.PHONY: init test

README.md

@@ -1,2 +1,29 @@
 # staroid-python
 Staroid python client library
+
+## Install
+
+```bash
+pip install staroid
+```
+
+## Quickstart
+
+
+Initialize
+
+```python
+from staroid import Staroid
+
+# with no argument, it searches configuration ~/.staroid/config first and then try in-cluster configuration
+strd = Staroid()
+
+# alternatively, pass access token through the argument
+strd = Staroid(access_token="<access token>", org="<org_name>")
+```
+
+Select cluster
+
+```python
+cluster1 = strd.cluster("<cluster_name>")
+```

requirements.txt

@@ -0,0 +1,2 @@
+pyyaml
+requests

setup.py

@@ -0,0 +1,45 @@
+import setuptools
+
+with open("README.md", "r") as fh:
+    long_description = fh.read()
+
+setuptools.setup(
+    name="staroid", # Replace with your own username
+    version="0.0.1",
+    author="Staroid",
+    author_email="support@staroid.com",
+    description="Python client library for Staroid cloud platform",
+    long_description=long_description,
+    long_description_content_type="text/markdown",
+    url="https://github.com/staroids/staroid-python",
+    packages=setuptools.find_packages(),
+    # See https://pypi.python.org/pypi?%3Aaction=list_classifiers
+    classifiers=[
+        # How mature is this project? Common values are
+        #   3 - Alpha
+        #   4 - Beta
+        #   5 - Production/Stable
+        # Indicate who your project is intended for
+        'Development Status :: 5 - Production/Stable',
+
+        # Indicate who your project is intended for
+        'Intended Audience :: Developers',
+        'Topic :: Software Development :: Libraries',
+
+
+        # Specify the Python versions you support here. In particular, ensure
+        'Programming Language :: Python :: 3.6',
+        'Programming Language :: Python :: 3.7',
+        'Programming Language :: Python :: 3.8'
+
+        # Pick your license as you wish (should match "license" above)
+        "License :: OSI Approved :: MIT License",
+        "Operating System :: OS Independent",
+    ],
+    python_requires='>=3.6',
+    install_requires=[
+        'requests',
+        'pyyaml',
+
+    ]
+)

staroid/__init__.py

@@ -0,0 +1,3 @@
+from .staroid import Staroid
+from .cluster import ClusterApi
+from .namespace import NamespaceApi

staroid/cluster.py

@@ -0,0 +1,17 @@
+import requests
+import logging
+import json
+
+class ClusterApi:
+    """Cluster api"""
+
+    def __init__(self, staroid):
+        self.__staroid = staroid
+
+    def get_all(self):
+        r = self.__staroid._api_get("orgs/{}/vc".format(self.__staroid.get_org()))
+        if r.status_code == 200:
+            return json.loads(r.text)
+        else:
+            logging.error("Can not get clusters {}", r.status_code)
+            return None

staroid/namespace.py

@@ -0,0 +1,22 @@
+import requests
+import logging
+import json
+
+class NamespaceApi:
+    """Namespace api"""
+
+    def __init__(self, cluster_api):
+        self.__staroid = cluster_api.__staroid
+        self.__cluster_api = cluster_api
+
+    def get_all(self):
+        r = self.__staroid._api_get(
+            "orgs/{}/vc/{}/instance".format(
+                self.__staroid.get_org(),
+
+                ))
+        if r.status_code == 200:
+            return json.loads(r.text)
+        else:
+            logging.error("Can not get clusters {}", r.status_code)
+            return None

staroid/staroid.py

@@ -0,0 +1,78 @@
+import os
+import yaml
+import logging
+import requests
+import json
+from .cluster import ClusterApi
+
+class Staroid:
+    """Staroid client object"""
+
+    def __init__(self, access_token=None, org=None, config_path="~/.staroid/config.yaml"):
+        self.__api_addr = "https://staroid.com/api"
+        self.__read_config(config_path)
+
+        if access_token != None:
+            self.__access_token = access_token
+        
+        if org != None:
+            self.__org = org
+
+    def __read_config(self, config_path):
+        try:
+            with open(config_path, "r") as f:
+                logging.info("Read configuration from " + config_path)
+                data = yaml.load(f, Loader=yaml.FullLoader)
+                self.__access_token = data.get("access_token", None)
+                self.__org = data.get("default_org", None)
+        except EnvironmentError:
+            pass
+
+
+    def cluster(self):
+        c = ClusterApi(self)
+        return c
+
+    def get_access_token(self):
+        return self.__access_token
+
+    def get_org(self):
+        return self.__org
+
+    def with_org(self, org):
+        self.__org = org
+        return self
+
+    def get_all_orgs(self):
+        r = self._api_get(self, "orgs/")
+        if r.status_code == 200:
+            return json.loads(r.text)
+        else:
+            logging.error("Can't get orgs")
+            return None
+
+    def __get_request_url(self, path):
+        request_url = "{}/{}".format(self.__api_addr, path)
+        return request_url
+
+    def __get_request_headers(self):
+        headers = {
+            "Authorization": "token {}".format(self.__access_token),
+            "Content-Type": "application/json"
+        }
+        return headers
+
+    def _api_get(self, path):
+        url = self.__get_request_url(path);
+        headers = self.__get_request_headers()
+
+        r = requests.get(url, headers=headers)
+        return r
+
+    
+    def _api_post(self, path, payload):
+        url = self.__get_request_url(path);
+        headers = self.__get_request_headers()
+
+        r = requests.get(url, headers=headers, data=json.dumps(payload))
+        return r

tests/__init__.py

@@ -0,0 +1,21 @@
+import unittest
+import tempfile
+
+from staroid import Staroid
+
+class TestStaroid(unittest.TestCase):
+    def test_initialize(self):
+        s = Staroid()
+
+    def test_read_config(self):
+        # given
+        fp = tempfile.NamedTemporaryFile()
+        fp.write(b"access_token: abc\ndefault_org: GITHUB/user1")
+        fp.flush()
+
+        # when
+        s = Staroid(config_path=fp.name)
+
+        # then
+        self.assertEqual("abc", s.get_access_token())
+        self.assertEqual("GITHUB/user1", s.get_org())