Performance review automation that collects feedback into Notion

def ensure_airtable_table(airtable, base_id, table_name, ...):
    try:
        schema = airtable.execute_tool(
            "airtable_get_base_schema", base_id=base_id,
        ) or {}
    except ConnectorError as e:
        raise ProvisioningError(
            f"Cannot access Airtable base '{base_id}': {e}\n"
            f"Airtable's API cannot create a new base -- create an "
            f"empty base at airtable.com first."
        ) from e

    existing_tables = {t.get("name") for t in schema.get("tables", [])}
    if table_name in existing_tables:
        return

    airtable.execute_tool(
        "airtable_create_table",
        base_id=base_id,
        name=table_name,
        fields=fields,  # Employee Name, Manager Email, ratings, Comments
    )

def list_all_records(self, base_id, table_name, view="", page_size=100):
    records, offset = [], None
    while True:
        kwargs = {"base_id": base_id,
                  "table_id_or_name": table_name,
                  "page_size": page_size}
        if offset:
            kwargs["offset"] = offset
        data = self.execute_tool("airtable_list_records", **kwargs) or {}
        records.extend(data.get("records") or [])
        offset = data.get("offset")
        if not offset:
            return records

# Google Forms mirrors the same loop with pageToken
data = self.execute_tool(
    "googleforms_list_responses", form_id=form_id, page_size=100,
)

def summarize(feedback, review_period, openrouter_api_key, openrouter_model):
    """LLM first, rule-based fallback on any failure."""
    if openrouter_api_key:
        try:
            return _summarize_with_llm(
                feedback, review_period,
                openrouter_api_key, openrouter_model,
            )
        except Exception as e:
            logger.warning(
                f"LLM summarization failed for {feedback.name} ({e}) "
                f"-- using rule-based summary"
            )
    return _summarize_rule_based(feedback, review_period)

def upsert_employee_page(self, parent_page_id, title, markdown_body):
    existing_id = self.find_existing_child_page(parent_page_id, title)
    if existing_id:
        return self.execute_tool(
            "notionmcp_notion-update-page",
            page_id=existing_id,
            command="replace_content",
            new_str=markdown_body,
        )
    return self.execute_tool(
        "notionmcp_notion-create-pages",
        parent={"type": "page_id", "page_id": parent_page_id},
        pages=[{"properties": {"title": title},
                "content": markdown_body}],
    )

digest = build_slack_digest(cfg.manager_email, cfg.review_period, results)
slack.send_dm(cfg.manager_slack_id, digest)

# connectors.py -- MCP vs plain REST send shapes, detected by name
if "mcp" in connector_name.lower():
    self._send_tool = "slackmcp_slack_send_message"  # channel_id / message
else:
    self._send_tool = "slack_send_message"           # channel / text

state.mark_processed(cfg.manager_email, cfg.review_period)