Remove Celery and its related tasks

src/api-engine/api/routes/node/views.py

@@ -53,7 +53,6 @@
     NodeUserListSerializer,
     NodeConfigFileSerializer,
 )
-from api.tasks import operate_node
 from api.utils.common import with_common_response
 from api.lib.pki import CryptoGen, CryptoConfig
 from api.utils import zip_dir, zip_file
@@ -919,59 +918,6 @@ def block_file(self, request, pk=None):
         except Exception as e:
             return Response(err(e.args), status=status.HTTP_400_BAD_REQUEST)
 
-    def _register_user(self, request, pk=None):
-        serializer = NodeUserCreateSerializer(data=request.data)
-        if serializer.is_valid(raise_exception=True):
-            name = serializer.validated_data.get("name")
-            secret = serializer.validated_data.get("secret")
-            user_type = serializer.validated_data.get("user_type")
-            attrs = serializer.validated_data.get("attrs", "")
-            try:
-                node = Node.objects.get(
-                    id=pk, organization=request.user.organization
-                )
-                # Name is unique for each node
-                user_count = NodeUser.objects.filter(
-                    node=node, name=name
-                ).count()
-                if user_count > 0:
-                    raise ResourceExists("Users Exist")
-            except ObjectDoesNotExist:
-                raise ResourceNotFound("Users Not Found")
-
-            node_user = NodeUser(
-                name=name,
-                secret=secret,
-                user_type=user_type,
-                attrs=attrs,
-                node=node,
-            )
-            node_user.save()
-
-            agent_config_file = request.build_absolute_uri(
-                node.agent.config_file.url
-            )
-            node_file_url = request.build_absolute_uri(node.file.url)
-            user_patch_url = self.reverse_action(
-                "patch-user", kwargs={"pk": pk, "user_pk": node_user.id}
-            )
-            user_patch_url = request.build_absolute_uri(user_patch_url)
-            operate_node.delay(
-                str(node.id),
-                AgentOperation.FabricCARegister.value,
-                agent_config_file=agent_config_file,
-                node_file_url=node_file_url,
-                user_patch_url=user_patch_url,
-                fabric_ca_user={
-                    "name": name,
-                    "secret": secret,
-                    "type": user_type,
-                    "attrs": attrs,
-                },
-            )
-            response = NodeUserIDSerializer(node_user)
-            return Response(data=response.data, status=status.HTTP_201_CREATED)
-
     def _list_user(self, request, pk=None):
         serializer = NodeUserQuerySerializer(data=request.GET)
         if serializer.is_valid(raise_exception=True):
@@ -997,15 +943,6 @@ def _list_user(self, request, pk=None):
             )
             return Response(ok(response.data), status=status.HTTP_200_OK)
 
-    @swagger_auto_schema(
-        methods=["post"],
-        operation_description="Register user to node",
-        operation_summary="Register user to node",
-        request_body=NodeUserCreateSerializer,
-        responses=with_common_response(
-            {status.HTTP_201_CREATED: NodeUserIDSerializer}
-        ),
-    )
     @swagger_auto_schema(
         methods=["get"],
         operation_description="List user of node",
@@ -1022,10 +959,7 @@ def _list_user(self, request, pk=None):
         url_name="users",
     )
     def users(self, request, pk=None):
-        if request.method == "POST":
-            return self._register_user(request, pk)
-        elif request.method == "GET":
-            return self._list_user(request, pk)
+        return self._list_user(request, pk)
 
     @swagger_auto_schema(
         methods=["patch"],

src/api-engine/api_engine/__init__.py

@@ -1,10 +0,0 @@
-#
-# SPDX-License-Identifier: Apache-2.0
-#
-from __future__ import absolute_import, unicode_literals
-
-# This will make sure the app is always imported when
-# Django starts so that shared_task will use this app.
-from .celery import app as celery_app
-
-__all__ = ("celery_app",)

src/api-engine/requirements.txt

@@ -1,7 +1,6 @@
 asgiref==3.6.0
 attrs==20.3.0
 cachetools==4.1.1
-celery==5.2.6
 certifi==2024.7.4
 chardet==3.0.4
 coreapi==2.3.3