Create backend/agents/remoteok_agent.py

backend/agents/remoteok_agent.py

@@ -0,0 +1,48 @@
+import requests
+from .normalizer import normalize_job_data
+
+def fetch_remoteok_jobs(limit=None):
+    """
+    Fetches job listings from the RemoteOK API and normalizes them.
+
+    Args:
+        limit (int, optional): The maximum number of jobs to return. Defaults to None.
+
+    Returns:
+        list: A list of dictionaries, where each dictionary represents a normalized job posting.
+              Returns an empty list if the API call fails.
+    """
+    url = "https://remoteok.com/api"
+    try:
+        response = requests.get(url)
+        response.raise_for_status()  # Raise an exception for bad status codes (4xx or 5xx)
+        jobs = response.json()
+
+        # The first element is often a header/legal notice, so we skip it.
+        if isinstance(jobs, list) and len(jobs) > 1:
+            valid_jobs = jobs[1:]
+            normalized_jobs = [normalize_job_data(job, "RemoteOK") for job in valid_jobs]
+
+            if limit:
+                return normalized_jobs[:limit]
+            return normalized_jobs
+        else:
+            print("RemoteOK API returned an unexpected format.")
+            return []
+
+    except requests.exceptions.RequestException as e:
+        print(f"Error fetching jobs from RemoteOK: {e}")
+        return []
+    except ValueError as e:
+        print(f"Error parsing JSON from RemoteOK: {e}")
+        return []
+
+if __name__ == '__main__':
+    # Example usage for testing
+    remote_jobs = fetch_remoteok_jobs(limit=5)
+    if remote_jobs:
+        print(f"Successfully fetched {len(remote_jobs)} jobs from RemoteOK.")
+        for job in remote_jobs:
+            print(f"- {job['title']} at {job['company']}")
+    else:
+        print("Failed to fetch jobs from RemoteOK.")