Merge branch 'master' into feature/add-session-service

Author: onlinejudge95

.deepsource.toml

@@ -0,0 +1,14 @@
+version = 1
+
+test_patterns = ["tests/**"]
+
+[[analyzers]]
+name = "secrets"
+enabled = true
+
+[[analyzers]]
+name = "python"
+enabled = true
+
+  [analyzers.meta]
+  runtime_version = "3.x.x"

.github/workflows/master_coverage.yml

@@ -1,4 +1,4 @@
-name: ArgoPy CI
+name: Master Coverage CI
 
 on:
   push:

.github/workflows/mr_ci.yml

@@ -38,5 +38,36 @@ jobs:
         flake8 --count --show-source --statistics --exclude .git,build_env,test_env,__init__.py --max-line-length 88 .
     - name: Coverage with pytest
       run: |
-        pytest --no-cov-on-fail --cov argocd --cov-report html --cov-report term --cov-report xml tests
-        ./codecov -t ${CODECOV_TOKEN}
+        pytest --no-cov-on-fail --cov argocd --cov-report html --cov-report term --cov-report xml tests/unit
+        ./codecov -t ${CODECOV_TOKEN} -F unit
+  scan:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+    steps:
+      - name: 'Checkout Repository'
+        uses: actions/checkout@v3
+      - name: 'Dependency Review'
+        uses: actions/dependency-review-action@v2
+  analyze:
+    runs-on: ubuntu-latest
+    permissions:
+      actions: read
+      contents: read
+      security-events: write
+    strategy:
+      fail-fast: false
+      matrix:
+        language: [ 'python' ]
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v3
+      - name: Initialize CodeQL
+        uses: github/codeql-action/init@v2
+        with:
+          languages: ${{ matrix.language }}
+      - name: Perform CodeQL Analysis
+        uses: github/codeql-action/analyze@v2
+        with:
+          category: "/language:${{matrix.language}}"
+

.gitignore

@@ -1,6 +1,5 @@
 .vscode/
-build_env/
-test_env/
+env*/
 argocd.egg-info/
 dist/
 __pycache__/

README.md

@@ -1,4 +1,35 @@
-argopy
+argocd
 ======
 
+## Actions
+![GitHub Workflow Status](https://img.shields.io/github/workflow/status/onlinejudge95/argocd/ArgoPy%20CI)
+![GitHub Workflow Status](https://img.shields.io/github/workflow/status/onlinejudge95/argocd/Production%20CD?label=release)
+
+## Coverage
+[![codecov](https://codecov.io/gh/onlinejudge95/argocd/branch/master/graph/badge.svg?token=GMiBQNT6jf)](https://codecov.io/gh/onlinejudge95/argocd)
+![Codecov branch](https://img.shields.io/codecov/c/github/onlinejudge95/argocd/master?label=master%20coverage)
+
+## GitHub
+![GitHub top language](https://img.shields.io/github/languages/top/onlinejudge95/argocd)
+![GitHub repo size](https://img.shields.io/github/repo-size/onlinejudge95/argocd)
+![GitHub repo file count](https://img.shields.io/github/directory-file-count/onlinejudge95/argocd)
+![GitHub commit activity](https://img.shields.io/github/commit-activity/m/onlinejudge95/argocd)
+
+## PyPI
+![PyPI - Downloads](https://img.shields.io/pypi/dm/argocd)
+![PyPI - Status](https://img.shields.io/pypi/status/argocd)
+![PyPI](https://img.shields.io/pypi/v/argocd)
+![PyPI - Implementation](https://img.shields.io/pypi/implementation/argocd)
+![PyPI - Wheel](https://img.shields.io/pypi/wheel/argocd)
+![PyPI - Python Version](https://img.shields.io/pypi/pyversions/argocd)
+
+## License
+![GitHub](https://img.shields.io/github/license/onlinejudge95/argocd)
+
+## DeepSource
+[![DeepSource](https://deepsource.io/gh/onlinejudge95/argocd.svg/?label=active+issues&show_trend=true&token=k4vYSD7ZovLMXroo2Kxi9z3q)](https://deepsource.io/gh/onlinejudge95/argocd/?ref=repository-badge)
+
+## GitLocalization
+[![gitlocalized ](https://gitlocalize.com/repo/8068/whole_project/badge.svg)](https://gitlocalize.com/repo/8068/whole_project?utm_source=badge)
+
 Python client for argocd server. This provides unique interface for the argocd REST APIs.

argocd/config.py

@@ -8,3 +8,6 @@ class Config:
     server_url: str = dataclasses.field(
         default_factory=functools.partial(os.environ.get, "ARGOCD_API_BASE_URL")
     )
+    authentication_token: str = dataclasses.field(
+        default_factory=functools.partial(os.environ.get, "ARGOCD_API_AUTH_TOKEN")
+    )

argocd/services/certificate.py

@@ -0,0 +1,60 @@
+from requests import sessions
+
+from argocd import config
+
+
+class CertificateService:
+    def __init__(self, token=None):
+        self.config = config.Config()
+        self.session = sessions.Session()
+        self.base_url = self.config.server_url
+        token = token or self.config.authentication_token
+
+        self.session.headers.update({"Authorization": f"Bearer {token}"})
+
+    def list(self, host_name_pattern="", cert_type="", cert_sub_type=""):
+        """
+        List all available repository certificates
+        """
+        params = {}
+        if host_name_pattern:
+            params["hostNamePattern"] = host_name_pattern
+        if cert_type:
+            params["certYype"] = cert_type
+        if cert_sub_type:
+            params["certSubType"] = cert_sub_type
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/certificates", params=params
+        )
+        return response.json()
+
+    def create(self, payload, upsert=False):
+        """
+        Creates repository certificates on the server
+        """
+        params = {}
+        if upsert:
+            params["upsert"] = upsert
+
+        response = self.session.post(
+            f"{self.base_url}/api/v1/certificates", params=params, json=payload
+        )
+        return response.json()
+
+    def delete(self, host_name_pattern="", cert_type="", cert_sub_type=""):
+        """
+        Delete the certificates that match the RepositoryCertificateQuery
+        """
+        params = {}
+        if host_name_pattern:
+            params["hostNamePattern"] = host_name_pattern
+        if cert_type:
+            params["certYype"] = cert_type
+        if cert_sub_type:
+            params["certSubType"] = cert_sub_type
+
+        response = self.session.delete(
+            f"{self.base_url}/api/v1/certificates", params=params
+        )
+        return response.json()

argocd/services/repository.py

@@ -0,0 +1,164 @@
+from requests import sessions
+
+from argocd import config
+
+
+class RepositoryService:
+    def __init__(self, token=None):
+        self.config = config.Config()
+        self.session = sessions.Session()
+        self.base_url = self.config.server_url
+        token = token or self.config.authentication_token
+
+        self.session.headers.update({"Authorization": f"Bearer {token}"})
+
+    def list(self, repo=None, force_refresh=False):
+        """ListRepositories gets a list of all configured repositories"""
+        params = {}
+        if repo:
+            params["repo"] = repo
+        if force_refresh:
+            params["forceRefresh"] = force_refresh
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/repositories", params=params
+        )
+        return response.json()
+
+    def create(self, payload, upsert=False, creds_only=False):
+        """CreateRepository creates a new repository configuration"""
+        params = {}
+        if upsert:
+            params["upsert"] = upsert
+        if creds_only:
+            params["credsOnly"] = creds_only
+
+        response = self.session.post(
+            f"{self.base_url}/api/v1/repositories", params=params, json=payload
+        )
+        return response.json()
+
+    def update(self, repo, payload):
+        """UpdateRepository updates a repository configuration"""
+        response = self.session.put(
+            f"{self.base_url}/api/v1/repositories/{repo}", json=payload
+        )
+        return response.json()
+
+    def get(self, repo, force_refresh=False):
+        """Get returns a repository or its credentials"""
+        params = {}
+        if force_refresh:
+            params["forceRefresh"] = force_refresh
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/repositories{repo}", params=params
+        )
+        return response.json()
+
+    def delete(self, repo, force_refresh=False):
+        """DeleteRepository deletes a repository from the configuration"""
+        params = {}
+        if force_refresh:
+            params["forceRefresh"] = force_refresh
+
+        response = self.session.delete(
+            f"{self.base_url}/api/v1/repositories{repo}", params=params
+        )
+        return response.json()
+
+    def list_apps(self, repo, revision=None):
+        """ListApps returns list of apps in the repo"""
+        params = {}
+        if revision:
+            params["revision"] = revision
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/repositories/{repo}/apps", params=params
+        )
+        return response.json()
+
+    def list_charts(self, repo, force_refresh=False):
+        """GetHelmCharts returns list of helm charts in the specified repository"""
+        params = {}
+        if force_refresh:
+            params["forceRefresh"] = force_refresh
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/repositories{repo}/helmcharts", params=params
+        )
+        return response.json()
+
+    def list_refs(self, repo, force_refresh=False):
+        """RepositoryService_ListRefs"""
+        params = {}
+        if force_refresh:
+            params["forceRefresh"] = force_refresh
+
+        response = self.session.get(
+            f"{self.base_url}/api/v1/repositories{repo}/refs", params=params
+        )
+        return response.json()
+
+    def validate_access(
+        self,
+        repo,
+        username="",
+        password="",
+        ssh_private_key="",
+        insecure=False,
+        tls_client_cert_data="",
+        tls_client_cert_key="",
+        access_type="",
+        name="",
+        enable_oci=False,
+        github_app_private_key="",
+        github_app_id="",
+        github_app_installation_id="",
+        github_app_enterprise_base_url="",
+        proxy="",
+        project="",
+    ):
+        """ValidateAccess validates access to a repository with given parameters"""
+        params = {}
+        if username != "":
+            params["username"] = username
+        if password != "":
+            params["password"] = password
+        if ssh_private_key != "":
+            params["sshPrivateKey"] = ssh_private_key
+        if insecure:
+            params["insecure"] = insecure
+        if tls_client_cert_data != "":
+            params["tlsClientCertData"] = tls_client_cert_data
+        if tls_client_cert_key != "":
+            params["tlsClientCertKey"] = tls_client_cert_key
+        if access_type != "":
+            params["type"] = access_type
+        if name != "":
+            params["name"] = name
+        if enable_oci:
+            params["enableOci"] = enable_oci
+        if github_app_private_key != "":
+            params["githubAppPrivateKey"] = github_app_private_key
+        if github_app_id != "":
+            params["githubAppID"] = github_app_id
+        if github_app_installation_id != "":
+            params["githubAppInstallationID"] = github_app_installation_id
+        if github_app_enterprise_base_url != "":
+            params["githubAppEnterpriseBaseUrl"] = github_app_enterprise_base_url
+        if proxy != "":
+            params["proxy"] = proxy
+        if project != "":
+            params["project"] = project
+        response = self.session.post(
+            f"{self.base_url}/api/v1/repositories{repo}/validate", json=repo
+        )
+        return response.json()
+
+    def get_app(self, repo, payload):
+        """GetAppDetails returns application details by given path"""
+        response = self.session.post(
+            f"{self.base_url}/api/v1/repositories{repo}/appdetails", json=payload
+        )
+        return response.json()

argocd/services/repository_creds.py

@@ -0,0 +1,55 @@
+from requests import sessions
+
+from argocd import config
+
+
+class RepositoryCredsService:
+    def __init__(self, token=None):
+        self.config = config.Config()
+        self.session = sessions.Session()
+        self.base_url = self.config.server_url
+        token = token or self.config.authentication_token
+
+        self.session.headers.update({"Authorization": f"Bearer {token}"})
+
+    def list(self, repo=""):
+        """
+        ListRepositoryCredentials gets a list of all configured
+        repository credential sets
+        """
+        params = {}
+        if repo != "":
+            params["repo"] = repo
+
+        response = self.session.get(f"{self.base_url}/api/v1/repocreds", params=params)
+        return response.json()
+
+    def create(self, payload, upsert=False):
+        """
+        CreateRepositoryCredentials creates a new repository credential set
+        """
+        params = {}
+        if upsert:
+            params["upsert"] = upsert
+
+        response = self.session.post(
+            f"{self.base_url}/api/v1/repocreds", params=params, json=payload
+        )
+        return response.json()
+
+    def update(self, creds, payload):
+        """
+        UpdateRepositoryCredentials updates a repository credential set
+        """
+        response = self.session.put(
+            f"{self.base_url}/api/v1/repocreds/{creds}", json=payload
+        )
+        return response.json()
+
+    def delete(self, creds):
+        """
+        DeleteRepositoryCredentials deletes a repository credential set
+        from the configuration
+        """
+        response = self.session.delete(f"{self.base_url}/api/v1/repocreds/{creds}")
+        return response.json()