Update Create Employee on Webhook trigger

apps/bamboohr/tasks.py

@@ -1,9 +1,37 @@
 from apps.bamboohr.models import BambooHr
 from apps.fyle_hrms_mappings.models import DestinationAttribute
 from fyle_employee_imports.bamboo_hr import BambooHrEmployeeImport
+from apps.users.models import User
 
 def refresh_employees(org_id, user):
 
     bambooHrImporter = BambooHrEmployeeImport(org_id=org_id, user=user)
     bambooHrImporter.sync_employees()
 
+def update_employee(org_id: int, user: User, payload: dict):
+
+    """
+        Update employee in fyle when employee in Bamboohr is added or updated
+    """
+    bamboohr = BambooHr.objects.get(org_id__in=org_id, is_credentials_expired=False)
+    bamboohr_importer = BambooHrEmployeeImport(org_id=org_id, user=user)
+
+    employee_payload = {'employees': []}
+    payload = payload['employees'][0]
+    employee = {}
+    for field in payload['changedFields']:
+        employee['id'] = payload['id']
+        employee[field] = payload['fields'][field]['value']
+
+    employee_payload['employees'].append(employee)
+
+    bamboohr_importer.upsert_employees(employees=employee_payload)
+
+    hrms_employees = DestinationAttribute.objects.filter(
+            attribute_type='EMPLOYEE',
+            org_id=org_id,
+            updated_at__gte=bamboohr.employee_exported_at,
+        ).order_by('value', 'id')
+
+    bamboohr_importer.import_departments(hrms_employees=hrms_employees)
+    bamboohr_importer.fyle_employee_import(hrms_employees=hrms_employees)

apps/bamboohr/views.py

@@ -48,6 +48,24 @@ def get(self, request, *args, **kwargs):
                 status=status.HTTP_404_NOT_FOUND
             )
 
+
+class WebhookAPIView(generics.CreateAPIView):
+
+    def post(self, request, *args, **kwargs):
+
+        org_id = kwargs['org_id']
+        user = self.request.user
+        payload = request.data
+
+        async_task('apps.bamboohr.tasks.update_employee', org_id, user, payload)
+
+        return Response(
+            {
+                'status': 'success'
+            },
+            status=status.HTTP_201_OK
+        )
+
 class BambooHrView(generics.ListAPIView):
     serializer_class = BambooHrSerializer
 

fyle_employee_imports/bamboo_hr.py

@@ -20,7 +20,7 @@ def sync_hrms_employees(self):
     def upsert_employees(self, employees: Dict):
         attributes = []
         for employee in employees['employees']:
-            supervisor = [employee['supervisorEmail']]
+            supervisor = [employee['supervisorEmail']] if employee['supervisorEmail'] else None
             active_status = True if employee['status'] == 'Active' else False
             detail = {
                 'email': employee['workEmail'] if employee['workEmail'] else None,