first commit

__init__.py

@@ -0,0 +1,59 @@
+from opsdroid.matchers import match_regex, match_webhook
+from opsdroid.message import Message
+from opsdroid.skill import Skill
+import logging
+import aiohttp
+import json
+import random
+
+
+logger = logging.getLogger(__name__)
+
+
+class GitlabPipelineSkill(Skill):
+
+    async def _rest_call(self, site, api_url, call_method):
+        token = self.config["gitlab"][site]["access_token"],
+        headers = {f"Authorization: Bearer {token}"}
+        timeout = aiohttp.ClientTimeout(total=60)
+        async with aiohttp.ClientSession(headers=headers, timeout=timeout) as session:
+            if call_method == "get":
+                async with session.get(api_url) as resp:
+                    data = await resp.json()
+                    return data
+            else:
+                async with session.post(api_url) as resp:
+                    data = await resp.json()
+                    return data
+
+    async def get_latest_pipeline(self, site, project_id):
+        api_url = f"{self.config["gitlab"][site]["url"]}/api/v4/projects/{project_id}/pipelines/latest"
+        data = await self._rest_call(site, api_url, "get")
+        return_text = f"*For site {site} latest - Pipline*\n"
+        for i in data["results"]:
+            return_text = f"{return_text}```Pipeline ID: {i['id']} Project ID: {i['project_id']} 
+                                            Name: {i['name']}` Status: {i['status']}  ``\n"
+        return return_text
+
+    async def _get_help(self):
+        return_text = f"*Help*\n"
+        return_text = f"{return_text}```/gitlab help - returns this help screen```\n"
+        return_text = f"{return_text}```/gitlab list projects - Returns project keywords and urls```\n"
+        return_text = f"{return_text}```/gitlab <project>  pipeline last  - Returns name, status and id for last pipeline in specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> update inventory  <id> - Updates inventory sources for inventory in specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list running jobs  - Returns information about running jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list failed jobs  - Returns information about last 5 failed jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list failed jobs yesterday  - Returns information about last 24 hours of failed jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list failed jobs  num:<#> - Returns information about last # failed jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list scheduled jobs  - Returns information about next 5 scheduled jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list scheduled jobs num:<#> - Returns information about next # scheduled jobs for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> list scheduled jobs past - Returns information about  scheduled jobs with next_run in the past```\n"
+        # return_text = f"{return_text}```gitlab <project> list projects - Returns information about project for specific project```\n"
+        # return_text = f"{return_text}```gitlab <project> update project <id> - Updated a project by id```\n"
+        return return_text
+
+    @match_regex(r"^/gitlab help$")
+    async def list_help(self, message):
+        help_print = await self._get_help()
+
+        await message.respond(f"{help_print}")