From b7720e5c39bb01d004a4fa0d8f7415b8dbb4a882 Mon Sep 17 00:00:00 2001
From: omar-zr <omar.zr98@gmail.com>
Date: Tue, 3 Sep 2024 09:26:31 +0400
Subject: [PATCH] add: apply_to_job func init struct

---
 src/linkedin-api.py | 105 ++++++++++++++++++++++++++++++++++++++++----
 1 file changed, 96 insertions(+), 9 deletions(-)

diff --git a/src/linkedin-api.py b/src/linkedin-api.py
index a34e381..633908e 100644
--- a/src/linkedin-api.py
+++ b/src/linkedin-api.py
@@ -8,7 +8,6 @@ import json
 # set log to all debug
 logging.basicConfig(level=logging.INFO)
 
-
 class LinkedInEvolvedAPI(Linkedin):
     def __init__(self, username, password):
         super().__init__(username, password)
@@ -167,7 +166,7 @@ class LinkedInEvolvedAPI(Linkedin):
 
         return results
     
-    def get_fields_for_easy_apply(self,job_id:str) -> List[Dict]:
+    def get_fields_for_easy_apply(self,job_id: str) -> List[Dict]:
         """Get fields needed for easy apply jobs.
 
         :param job_id: Job ID
@@ -220,7 +219,7 @@ class LinkedInEvolvedAPI(Linkedin):
         form_components = []
 
         for item in data.get("included", []):
-            if 'formComponent' in item:
+            if 'formComponent' in item:                
                 urn = item['urn']
                 try:
                     title = item['title']['text']
@@ -251,18 +250,106 @@ class LinkedInEvolvedAPI(Linkedin):
                 form_components.append(component_info)
 
         return form_components
+    
+    import json
 
-## EXAMPLE USAGE
+def apply_to_job(self, job_id: str, fields: dict, followCompany: bool = True) -> bool:
+    """Apply to a job on LinkedIn using the easy apply feature.
+
+    :param job_id: Job ID
+    :type job_id: str
+    :param fields: Fields required for the application
+    :type fields: dict
+    :param followCompany: Whether to follow the company after applying
+    :type followCompany: bool, optional
+    :return: True if the application was successful, False otherwise
+    :rtype: bool
+    """
+    # Fetch the fields for easy apply job
+    form_components = self.get_fields_for_easy_apply(job_id)
+    
+    # Fill the fields with the data
+    responses = []
+    for component in form_components:
+        if component['formComponentType'] == 'singleLineTextFormComponent':
+            response = input(f"Enter response for '{component['title']}': ") # Need to replace this with AI answer
+            responses.append({
+                "formElementUrn": component['urn'],
+                "formElementInputValues": [
+                    {
+                        "textInputValue": response
+                    }
+                ]
+            })
+        elif component['formComponentType'] == 'multipleChoiceFormComponent':
+            print(f"Select an option for '{component['title']}':")
+            for i, option in enumerate(component['selectableOptions']):
+                print(f"{i+1}. {option}")
+            choice = int(input("Enter the number of your choice: ")) - 1
+            responses.append({
+                "formElementUrn": component['urn'],
+                "formElementInputValues": [
+                    {
+                        "entityInputValue": {
+                            "inputEntityName": component['selectableOptions'][choice]
+                        }
+                    }
+                ]
+            })
+        # Need to add more elif clauses for other form component types
+    
+    # Build the payload
+    payload = {
+        "followCompany": followCompany,
+        "responses": responses,
+        "referenceId": "",
+        "trackingCode": "d_flagship3_search_srp_jobs",
+        "fileUploadResponses": [],
+        "trackingId": ""
+    }
+    
+    # Send the payload to apply for the job
+    cookies = self.client.session.cookies.get_dict()
+    cookie_str = "; ".join([f"{k}={v}" for k, v in cookies.items()])
+
+    headers = self._headers()
+    headers["Accept"] = "application/vnd.linkedin.normalized+json+2.1"
+    headers["csrf-token"] = cookies["JSESSIONID"].replace('"', "")
+    headers["Cookie"] = cookie_str
+    headers["Connection"] = "keep-alive"
+
+    default_params = {
+        "decorationId": "com.linkedin.voyager.dash.deco.jobs.OnsiteApplyApplication-67",
+        "jobPostingUrn": f"urn:li:fsd_jobPosting:{job_id}",
+        "q": "jobPosting",
+    }
+
+    default_params = urlencode(default_params)
+    res = self._fetch(
+        f"/voyagerJobsDashOnsiteApplyApplication?{default_params}",
+        method="POST",
+        headers=headers,
+        cookies=cookies,
+        data=json.dumps(payload)
+    )
+
+    if res.status_code == 200:
+        self.logger.info(f"Successfully applied to job {job_id}")
+        return True
+    else:
+        self.logger.error(f"Failed to apply to job {job_id}. Status code: {res.status_code}")
+        return False
+
+# Example usage
 if __name__ == "__main__":
-    api: LinkedInEvolvedAPI = LinkedInEvolvedAPI(username="", password="")     
+    api = LinkedInEvolvedAPI(username="", password="")    
     jobs = api.search_jobs(keywords="Frontend Developer", location_name="Italia", limit=5, easy_apply=True, offset=1)
     for job in jobs:
-        job_id: str = job["job_id"]
+        job_id = job["job_id"]
 
         fields = api.get_fields_for_easy_apply(job_id)
         for field in fields:
             print(field)
-
         
-
-    
\ No newline at end of file
+        if api.apply_to_job(job_id, fields):
+            break
\ No newline at end of file