Stop Searching.
Start Automating.

class JobScorer:
    """Score jobs 1-5 against candidate profile."""

    def _compute(self, job: Job) -> tuple[int, ScoreBreakdown]:
        w = self.weights

        title_pts = self._title_score(job.title)
        tech_pts, tech_matched = self._tech_score_with_keywords(job)
        remote_pts = self._location_score(job.location)
        salary_pts = self._salary_score(job)

        raw = (
            title_pts * w.title_match / 2.0
            + tech_pts * w.tech_overlap / 2.0
            + remote_pts * w.remote
            + salary_pts * w.salary
        )

        total = 5 if raw >= 5 else 4 if raw >= 4 else ...

        return total, ScoreBreakdown(
            title_points=title_pts, tech_points=tech_pts,
            tech_matched=tech_matched, remote_points=remote_pts,
            salary_points=salary_pts, total=total,
        )

def run(self, platforms: list[str] | None = None) -> None:
    """Execute the five-phase pipeline."""
    if platforms is None:
        platforms = self.settings.enabled_platforms()
    for name in platforms:
        get_platform(name)  # Validates registration

    try:
        self.phase_0_setup()
        self.phase_1_login(platforms)
        self.phase_2_search(platforms)
        self.phase_3_score()
        self.phase_4_apply()  # Human-in-the-loop
    finally:
        webdb.record_run(
            status="success" if not self._run_errors else "partial",
            total_raw=self._total_raw,
            total_scored=len(self.discovered_jobs),
        )

SYSTEM_PROMPT = """\
ABSOLUTE RULES — VIOLATION IS UNACCEPTABLE:
1. MUST NOT add skills, technologies, or achievements
   not already in the original resume.
2. MUST NOT invent certifications, awards, or credentials.
3. MUST NOT change dates, company names, or job titles.
4. MUST NOT fabricate quantified results or metrics.
"""

async def tailor_resume(
    resume_text: str, job_description: str,
    job_title: str, company_name: str,
) -> TailoredResume:
    """Structured output with Pydantic schema validation."""
    return await cli_run(
        system_prompt=SYSTEM_PROMPT,
        user_message=build_prompt(resume_text, job_title, company_name),
        output_model=TailoredResume,
        model="sonnet",
    )

async def apply(self, job: dict, mode: str, queue: asyncio.Queue):
    """Serialize applies, stream events via SSE."""
    async with self._semaphore:
        loop = asyncio.get_running_loop()
        emit = self._make_emitter(queue, loop)
        await asyncio.to_thread(self._apply_sync, job, mode, emit)

def _make_emitter(self, queue, loop):
    """Bridge sync Playwright thread -> async FastAPI."""
    def emit(event: ApplyEvent) -> None:
        loop.call_soon_threadsafe(queue.put_nowait, event.model_dump())
    return emit

# Confirmation gate in _apply_sync:
if config.confirm_before_submit:
    emit(ApplyEvent(type=ApplyEventType.AWAITING_CONFIRM))
    confirmed = self._confirmations[key].wait(timeout=300)
    if not confirmed:
        return  # User declined in dashboard