vishes-shell
diff --git a/‎gitlab/__init__.py
Lines changed: 84 additions & 90 deletions b/‎gitlab/__init__.py
Lines changed: 84 additions & 90 deletions
diff --git a/‎gitlab/cli.py
Lines changed: 2 additions & 2 deletions b/‎gitlab/cli.py
Lines changed: 2 additions & 2 deletions
diff --git a/‎gitlab/exceptions.py
Lines changed: 2 additions & 2 deletions b/‎gitlab/exceptions.py
Lines changed: 2 additions & 2 deletions
diff --git a/‎gitlab/mixins.py
Lines changed: 47 additions & 46 deletions b/‎gitlab/mixins.py
Lines changed: 47 additions & 46 deletions
@@ -39,8 +39,8 @@
 def register_custom_action(cls_names, mandatory=tuple(), optional=tuple()):
     def wrap(f):
         @functools.wraps(f)
-        def wrapped_f(*args, **kwargs):
-            return f(*args, **kwargs)
+        async def wrapped_f(*args, **kwargs):
+            return await f(*args, **kwargs)
 
         # in_obj defines whether the method belongs to the obj or the manager
         in_obj = True
 
@@ -262,9 +262,9 @@ def on_http_error(error):
 
     def wrap(f):
         @functools.wraps(f)
-        def wrapped_f(*args, **kwargs):
+        async def wrapped_f(*args, **kwargs):
             try:
-                return f(*args, **kwargs)
+                return await f(*args, **kwargs)
             except GitlabHttpError as e:
                 raise error(e.error_message, e.response_code, e.response_body)
 
 
@@ -16,16 +16,15 @@
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
 import gitlab
-from gitlab import base
-from gitlab import cli
+from gitlab import base, cli
 from gitlab import exceptions as exc
 from gitlab import types as g_types
 from gitlab import utils
 
 
 class GetMixin(object):
     @exc.on_http_error(exc.GitlabGetError)
-    def get(self, id, lazy=False, **kwargs):
+    async def get(self, id, lazy=False, **kwargs):
         """Retrieve a single object.
 
         Args:
@@ -48,12 +47,12 @@ def get(self, id, lazy=False, **kwargs):
         if lazy is True:
             return self._obj_cls(self, {self._obj_cls._id_attr: id})
         server_data = self.gitlab.http_get(path, **kwargs)
-        return self._obj_cls(self, server_data)
+        return await self._obj_cls(self, server_data)
 
 
 class GetWithoutIdMixin(object):
     @exc.on_http_error(exc.GitlabGetError)
-    def get(self, id=None, **kwargs):
+    async def get(self, id=None, **kwargs):
         """Retrieve a single object.
 
         Args:
@@ -69,12 +68,12 @@ def get(self, id=None, **kwargs):
         server_data = self.gitlab.http_get(self.path, **kwargs)
         if server_data is None:
             return None
-        return self._obj_cls(self, server_data)
+        return await self._obj_cls(self, server_data)
 
 
 class RefreshMixin(object):
     @exc.on_http_error(exc.GitlabGetError)
-    def refresh(self, **kwargs):
+    async def refresh(self, **kwargs):
         """Refresh a single object from server.
 
         Args:
@@ -90,13 +89,13 @@ def refresh(self, **kwargs):
             path = "%s/%s" % (self.manager.path, self.id)
         else:
             path = self.manager.path
-        server_data = self.manager.gitlab.http_get(path, **kwargs)
+        server_data = await self.manager.gitlab.http_get(path, **kwargs)
         self._update_attrs(server_data)
 
 
 class ListMixin(object):
     @exc.on_http_error(exc.GitlabListError)
-    def list(self, **kwargs):
+    async def list(self, **kwargs):
         """Retrieve a list of objects.
 
         Args:
@@ -138,7 +137,7 @@ def list(self, **kwargs):
         # Allow to overwrite the path, handy for custom listings
         path = data.pop("path", self.path)
 
-        obj = self.gitlab.http_list(path, **data)
+        obj = await self.gitlab.http_list(path, **data)
         if isinstance(obj, list):
             return [self._obj_cls(self, item) for item in obj]
         else:
@@ -170,7 +169,7 @@ def get_create_attrs(self):
         return getattr(self, "_create_attrs", (tuple(), tuple()))
 
     @exc.on_http_error(exc.GitlabCreateError)
-    def create(self, data, **kwargs):
+    async def create(self, data, **kwargs):
         """Create a new object.
 
         Args:
@@ -208,7 +207,9 @@ def create(self, data, **kwargs):
 
         # Handle specific URL for creation
         path = kwargs.pop("path", self.path)
-        server_data = self.gitlab.http_post(path, post_data=data, files=files, **kwargs)
+        server_data = await self.gitlab.http_post(
+            path, post_data=data, files=files, **kwargs
+        )
         return self._obj_cls(self, server_data)
 
 
@@ -247,7 +248,7 @@ def _get_update_method(self):
         return http_method
 
     @exc.on_http_error(exc.GitlabUpdateError)
-    def update(self, id=None, new_data=None, **kwargs):
+    async def update(self, id=None, new_data=None, **kwargs):
         """Update an object on the server.
 
         Args:
@@ -290,12 +291,12 @@ def update(self, id=None, new_data=None, **kwargs):
                         new_data[attr_name] = type_obj.get_for_api()
 
         http_method = self._get_update_method()
-        return http_method(path, post_data=new_data, files=files, **kwargs)
+        return await http_method(path, post_data=new_data, files=files, **kwargs)
 
 
 class SetMixin(object):
     @exc.on_http_error(exc.GitlabSetError)
-    def set(self, key, value, **kwargs):
+    async def set(self, key, value, **kwargs):
         """Create or update the object.
 
         Args:
@@ -312,13 +313,13 @@ def set(self, key, value, **kwargs):
         """
         path = "%s/%s" % (self.path, utils.clean_str_id(key))
         data = {"value": value}
-        server_data = self.gitlab.http_put(path, post_data=data, **kwargs)
+        server_data = await self.gitlab.http_put(path, post_data=data, **kwargs)
         return self._obj_cls(self, server_data)
 
 
 class DeleteMixin(object):
     @exc.on_http_error(exc.GitlabDeleteError)
-    def delete(self, id, **kwargs):
+    async def delete(self, id, **kwargs):
         """Delete an object on the server.
 
         Args:
@@ -335,7 +336,7 @@ def delete(self, id, **kwargs):
             if not isinstance(id, int):
                 id = utils.clean_str_id(id)
             path = "%s/%s" % (self.path, id)
-        self.gitlab.http_delete(path, **kwargs)
+        await self.gitlab.http_delete(path, **kwargs)
 
 
 class CRUDMixin(GetMixin, ListMixin, CreateMixin, UpdateMixin, DeleteMixin):
@@ -360,7 +361,7 @@ def _get_updated_data(self):
 
         return updated_data
 
-    def save(self, **kwargs):
+    async def save(self, **kwargs):
         """Save the changes made to the object to the server.
 
         The object is updated to match what the server returns.
@@ -379,15 +380,15 @@ def save(self, **kwargs):
 
         # call the manager
         obj_id = self.get_id()
-        server_data = self.manager.update(obj_id, updated_data, **kwargs)
+        server_data = await self.manager.update(obj_id, updated_data, **kwargs)
         if server_data is not None:
             self._update_attrs(server_data)
 
 
 class ObjectDeleteMixin(object):
     """Mixin for RESTObject's that can be deleted."""
 
-    def delete(self, **kwargs):
+    async def delete(self, **kwargs):
         """Delete the object from the server.
 
         Args:
@@ -397,13 +398,13 @@ def delete(self, **kwargs):
             GitlabAuthenticationError: If authentication is not correct
             GitlabDeleteError: If the server cannot perform the request
         """
-        self.manager.delete(self.get_id())
+        await self.manager.delete(self.get_id())
 
 
 class UserAgentDetailMixin(object):
     @cli.register_custom_action(("Snippet", "ProjectSnippet", "ProjectIssue"))
     @exc.on_http_error(exc.GitlabGetError)
-    def user_agent_detail(self, **kwargs):
+    async def user_agent_detail(self, **kwargs):
         """Get the user agent detail.
 
         Args:
@@ -414,15 +415,15 @@ def user_agent_detail(self, **kwargs):
             GitlabGetError: If the server cannot perform the request
         """
         path = "%s/%s/user_agent_detail" % (self.manager.path, self.get_id())
-        return self.manager.gitlab.http_get(path, **kwargs)
+        return await self.manager.gitlab.http_get(path, **kwargs)
 
 
 class AccessRequestMixin(object):
     @cli.register_custom_action(
         ("ProjectAccessRequest", "GroupAccessRequest"), tuple(), ("access_level",)
     )
     @exc.on_http_error(exc.GitlabUpdateError)
-    def approve(self, access_level=gitlab.DEVELOPER_ACCESS, **kwargs):
+    async def approve(self, access_level=gitlab.DEVELOPER_ACCESS, **kwargs):
         """Approve an access request.
 
         Args:
@@ -436,7 +437,7 @@ def approve(self, access_level=gitlab.DEVELOPER_ACCESS, **kwargs):
 
         path = "%s/%s/approve" % (self.manager.path, self.id)
         data = {"access_level": access_level}
-        server_data = self.manager.gitlab.http_put(path, post_data=data, **kwargs)
+        server_data = await self.manager.gitlab.http_put(path, post_data=data, **kwargs)
         self._update_attrs(server_data)
 
 
@@ -445,7 +446,7 @@ class SubscribableMixin(object):
         ("ProjectIssue", "ProjectMergeRequest", "ProjectLabel", "GroupLabel")
     )
     @exc.on_http_error(exc.GitlabSubscribeError)
-    def subscribe(self, **kwargs):
+    async def subscribe(self, **kwargs):
         """Subscribe to the object notifications.
 
         Args:
@@ -456,14 +457,14 @@ def subscribe(self, **kwargs):
             GitlabSubscribeError: If the subscription cannot be done
         """
         path = "%s/%s/subscribe" % (self.manager.path, self.get_id())
-        server_data = self.manager.gitlab.http_post(path, **kwargs)
+        server_data = await self.manager.gitlab.http_post(path, **kwargs)
         self._update_attrs(server_data)
 
     @cli.register_custom_action(
         ("ProjectIssue", "ProjectMergeRequest", "ProjectLabel", "GroupLabel")
     )
     @exc.on_http_error(exc.GitlabUnsubscribeError)
-    def unsubscribe(self, **kwargs):
+    async def unsubscribe(self, **kwargs):
         """Unsubscribe from the object notifications.
 
         Args:
@@ -474,14 +475,14 @@ def unsubscribe(self, **kwargs):
             GitlabUnsubscribeError: If the unsubscription cannot be done
         """
         path = "%s/%s/unsubscribe" % (self.manager.path, self.get_id())
-        server_data = self.manager.gitlab.http_post(path, **kwargs)
+        server_data = await self.manager.gitlab.http_post(path, **kwargs)
         self._update_attrs(server_data)
 
 
 class TodoMixin(object):
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"))
     @exc.on_http_error(exc.GitlabTodoError)
-    def todo(self, **kwargs):
+    async def todo(self, **kwargs):
         """Create a todo associated to the object.
 
         Args:
@@ -492,13 +493,13 @@ def todo(self, **kwargs):
             GitlabTodoError: If the todo cannot be set
         """
         path = "%s/%s/todo" % (self.manager.path, self.get_id())
-        self.manager.gitlab.http_post(path, **kwargs)
+        await self.manager.gitlab.http_post(path, **kwargs)
 
 
 class TimeTrackingMixin(object):
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"))
     @exc.on_http_error(exc.GitlabTimeTrackingError)
-    def time_stats(self, **kwargs):
+    async def time_stats(self, **kwargs):
         """Get time stats for the object.
 
         Args:
@@ -514,11 +515,11 @@ def time_stats(self, **kwargs):
             return self.attributes["time_stats"]
 
         path = "%s/%s/time_stats" % (self.manager.path, self.get_id())
-        return self.manager.gitlab.http_get(path, **kwargs)
+        return await self.manager.gitlab.http_get(path, **kwargs)
 
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"), ("duration",))
     @exc.on_http_error(exc.GitlabTimeTrackingError)
-    def time_estimate(self, duration, **kwargs):
+    async def time_estimate(self, duration, **kwargs):
         """Set an estimated time of work for the object.
 
         Args:
@@ -531,11 +532,11 @@ def time_estimate(self, duration, **kwargs):
         """
         path = "%s/%s/time_estimate" % (self.manager.path, self.get_id())
         data = {"duration": duration}
-        return self.manager.gitlab.http_post(path, post_data=data, **kwargs)
+        return await self.manager.gitlab.http_post(path, post_data=data, **kwargs)
 
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"))
     @exc.on_http_error(exc.GitlabTimeTrackingError)
-    def reset_time_estimate(self, **kwargs):
+    async def reset_time_estimate(self, **kwargs):
         """Resets estimated time for the object to 0 seconds.
 
         Args:
@@ -546,11 +547,11 @@ def reset_time_estimate(self, **kwargs):
             GitlabTimeTrackingError: If the time tracking update cannot be done
         """
         path = "%s/%s/reset_time_estimate" % (self.manager.path, self.get_id())
-        return self.manager.gitlab.http_post(path, **kwargs)
+        return await self.manager.gitlab.http_post(path, **kwargs)
 
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"), ("duration",))
     @exc.on_http_error(exc.GitlabTimeTrackingError)
-    def add_spent_time(self, duration, **kwargs):
+    async def add_spent_time(self, duration, **kwargs):
         """Add time spent working on the object.
 
         Args:
@@ -563,11 +564,11 @@ def add_spent_time(self, duration, **kwargs):
         """
         path = "%s/%s/add_spent_time" % (self.manager.path, self.get_id())
         data = {"duration": duration}
-        return self.manager.gitlab.http_post(path, post_data=data, **kwargs)
+        return await self.manager.gitlab.http_post(path, post_data=data, **kwargs)
 
     @cli.register_custom_action(("ProjectIssue", "ProjectMergeRequest"))
     @exc.on_http_error(exc.GitlabTimeTrackingError)
-    def reset_spent_time(self, **kwargs):
+    async def reset_spent_time(self, **kwargs):
         """Resets the time spent working on the object.
 
         Args:
@@ -578,13 +579,13 @@ def reset_spent_time(self, **kwargs):
             GitlabTimeTrackingError: If the time tracking update cannot be done
         """
         path = "%s/%s/reset_spent_time" % (self.manager.path, self.get_id())
-        return self.manager.gitlab.http_post(path, **kwargs)
+        return await self.manager.gitlab.http_post(path, **kwargs)
 
 
 class ParticipantsMixin(object):
     @cli.register_custom_action(("ProjectMergeRequest", "ProjectIssue"))
     @exc.on_http_error(exc.GitlabListError)
-    def participants(self, **kwargs):
+    async def participants(self, **kwargs):
         """List the participants.
 
@@ -604,15 +605,15 @@ def participants(self, **kwargs):
         """
 
         path = "%s/%s/participants" % (self.manager.path, self.get_id())
-        return self.manager.gitlab.http_get(path, **kwargs)
+        return await self.manager.gitlab.http_get(path, **kwargs)
 
 
 class BadgeRenderMixin(object):
     @cli.register_custom_action(
         ("GroupBadgeManager", "ProjectBadgeManager"), ("link_url", "image_url")
     )
     @exc.on_http_error(exc.GitlabRenderError)
-    def render(self, link_url, image_url, **kwargs):
+    async def render(self, link_url, image_url, **kwargs):
         """Preview link_url and image_url after interpolation.
 
         Args:
@@ -629,4 +630,4 @@ def render(self, link_url, image_url, **kwargs):
         """
         path = "%s/render" % self.path
         data = {"link_url": link_url, "image_url": image_url}
-        return self.gitlab.http_get(path, data, **kwargs)
+        return await self.gitlab.http_get(path, data, **kwargs)