2023-07-06 16:44:38 -07:00
|
|
|
from fastapi import APIRouter
|
|
|
|
|
2023-07-07 19:00:59 -07:00
|
|
|
from api.core.scrapers.indeed import IndeedScraper
|
2023-07-08 04:57:36 -07:00
|
|
|
from api.core.scrapers.ziprecruiter import ZipRecruiterScraper
|
2023-07-08 07:34:55 -07:00
|
|
|
from api.core.scrapers.linkedin import LinkedInScraper
|
2023-07-07 19:00:59 -07:00
|
|
|
from api.core.scrapers import ScraperInput
|
|
|
|
|
2023-07-06 16:44:38 -07:00
|
|
|
router = APIRouter(prefix="/jobs")
|
2023-07-07 19:00:59 -07:00
|
|
|
|
|
|
|
|
|
|
|
@router.get("/")
|
2023-07-08 19:16:34 -07:00
|
|
|
async def scrape_jobs(site_type: str, search_term: str, location: str, page: int = 1):
|
2023-07-08 04:57:36 -07:00
|
|
|
job_response = {"message": "site type not found"}
|
2023-07-08 07:34:55 -07:00
|
|
|
|
|
|
|
scraper_dict = {
|
|
|
|
"indeed": IndeedScraper,
|
|
|
|
"linkedin": LinkedInScraper,
|
|
|
|
"zip": ZipRecruiterScraper,
|
|
|
|
}
|
|
|
|
|
|
|
|
scraper_class = scraper_dict.get(site_type)
|
|
|
|
if scraper_class:
|
|
|
|
scraper = scraper_class()
|
2023-07-08 04:57:36 -07:00
|
|
|
scraper_input = ScraperInput(
|
|
|
|
search_term=search_term, location=location, page=page
|
|
|
|
)
|
2023-07-08 07:34:55 -07:00
|
|
|
job_response = scraper.scrape(scraper_input)
|
2023-07-07 19:00:59 -07:00
|
|
|
|
|
|
|
return job_response
|