API view added for refreshing employees from BambooHR

apps/bamboohr/tasks.py

@@ -0,0 +1,9 @@
+from apps.bamboohr.models import BambooHr
+from apps.fyle_hrms_mappings.models import DestinationAttribute
+from fyle_employee_imports.bamboo_hr import BambooHrEmployeeImport
+
+def refresh_employees(org_id, user):
+
+    bambooHrImporter = BambooHrEmployeeImport(org_id=org_id, user=user)
+    bambooHrImporter.sync_employees()
+

apps/bamboohr/views.py

@@ -13,7 +13,7 @@
 from apps.bamboohr.actions import disconnect_bamboohr, sync_employees
 from apps.names import BAMBOO_HR
 
-from rest_framework.views import APIView
+from django_q.tasks import async_task
 
 logger = logging.getLogger(__name__)
 logger.level = logging.INFO
@@ -230,20 +230,9 @@ class SyncEmployeesView(generics.UpdateAPIView):
 
     def post(self, request, *args, **kwargs):
 
-        try:
-            config = BambooHrConfiguration.objects.get(org__id=kwargs['org_id'])
-            sync_recipe = sync_employees(kwargs['org_id'], config)
+        async_task('apps.bamboohr.tasks.refresh_employees')
 
-            # in case of an error response
-            if isinstance(sync_recipe, Response):
-                return sync_recipe
-
-            return Response(
-                data=sync_recipe,
-                status=status.HTTP_200_OK
-            )
-        except BambooHrConfiguration.DoesNotExist:
-            return Response(
-                data={'message': 'BambooHr Configuration does not exist for this Workspace'},
-                status=status.HTTP_404_NOT_FOUND
-            )
+        return Response(
+            data = {'message': 'success'},
+            status=status.HTTP_201_CREATED
+        )