Offer letter agents that act on-behalf-of your recruiters

def ensure_authorized(connect, connector_name, user_id):
    resp = connect.get_or_create_connected_account(
        connection_name=connector_name, identifier=user_id
    )
    if resp.connected_account.status != "ACTIVE":
        link = connect.get_authorization_link(
            connection_name=connector_name, identifier=user_id
        ).link
        logger.warning(f"Not authorized. {connector_name} ({user_id})\nOpen: {link}")
        input("Press Enter after authorizing...")

        resp = connect.get_or_create_connected_account(
            connection_name=connector_name, identifier=user_id
        )
        if resp.connected_account.status != "ACTIVE":
            raise RuntimeError(
                f"{connector_name} ({user_id}) is still not ACTIVE "
                f"— authorization did not complete"
            )

# Every call below is scoped to the recruiter's own identity
ensure_authorized(connect, settings.PANDADOC_CONNECTOR, settings.PANDADOC_USER)
ensure_authorized(connect, settings.SLACK_CONNECTOR, settings.SLACK_USER)
ensure_authorized(connect, settings.GMAIL_CONNECTOR, settings.GMAIL_USER)
if settings.REQUIRE_APPROVAL:
    ensure_authorized(connect, settings.SLACKMCP_CONNECTOR, settings.SLACKMCP_USER)

result = self.connect.execute_tool(
    tool_name="pandadocmcp_documents_create",
    identifier=self.user_id,
    connection_name=self.connection_name,
    tool_input={
        "request": {
            "source": "template",
            "template_uuid": template_uuid,
            "name": name,  # "Offer - Alex Chen - Staff Engineer"
            "recipients": [
                {
                    "email": candidate_email,
                    "first_name": candidate_first_name,
                    "last_name": candidate_last_name,
                    "role": recipient_role,  # PandaDoc's default is "Client"
                }
            ],
            "tokens": [{"name": k, "value": v} for k, v in tokens.items()],
        }
    },
)

def send_message(self, channel_id, message):
    parsed = self._call(
        "slackmcp_slack_send_message",
        {"channel_id": channel_id, "message": message},
    )
    return parsed.get("message_context", {})  # {"message_ts": ..., "channel_id": ...}

def get_reactions(self, channel_id, message_ts):
    # Returns (emoji, reactor_user_id) pairs — the gate checks
    # WHO reacted, not just which emoji was used
    parsed = self._call(
        "slackmcp_slack_get_reactions",
        {"channel_id": channel_id, "message_ts": message_ts},
    )
    return _parse_reactions(parsed)

deadline = now() + timeout_seconds

while now() < deadline:
    reactions = get_reactions()
    if approver_user_id is not None:
        reactions = [(e, uid) for e, uid in reactions if uid == approver_user_id]
    emojis = [e for e, _uid in reactions]

    if reject_emoji in emojis:
        return ApprovalResult(approved=False, timed_out=False, reacted_with=emojis)
    if approve_emoji in emojis:
        return ApprovalResult(approved=True, timed_out=False, reacted_with=emojis)

    sleep(min(poll_interval_seconds, max(int(deadline - now()), 0)))

return ApprovalResult(approved=False, timed_out=True, reacted_with=[])

sent = pandadoc.send(
    document_id=document_id,
    subject=f"Your offer from {settings.COMPANY_NAME}: {offer.role_title}",
    message=(
        f"Hi {offer.candidate_first_name}, we're excited to offer you the "
        f"{offer.role_title} role. Please review and sign at your convenience."
    ),
)

gmail_send_message(
    connect,
    settings.GMAIL_USER,
    connection_name=settings.GMAIL_CONNECTOR,
    to=offer.candidate_email,
    subject=f"Your offer from {settings.COMPANY_NAME}: {offer.role_title}",
    body=(
        f"Hi {offer.candidate_first_name},\n\n"
        f"Congratulations! Your offer document is ready for review "
        f"and e-signature:\n{document_url}\n\n"
        f"Welcome to the team!"
    ),
)