Notion

integrations:
  notion:
    enabled: true
    credentials:
      api_key: ${NOTION_API_KEY}
    settings:
      api_version: "2022-06-28"           # Notion API version
      polling_interval: 60                 # Seconds between change-detection polls
      watched_databases:                   # Databases to monitor for changes
        - id: "a1b2c3d4e5f6..."
          events: ["page:created", "page:updated"]
        - id: "f6e5d4c3b2a1..."
          events: ["page:updated"]
      default_parent_page: "your-page-id"  # Default parent for new pages
      rich_text_max_length: 2000           # Truncate text blocks at this length

NOTION_API_KEY=ntn_your_internal_integration_token

import { Cognest } from "@cognest/sdk";
import { NotionIntegration } from "@cognest/integrations/notion";

const cognest = new Cognest();
const notion = cognest.integration<NotionIntegration>("notion");

// Create a new page in a database
await notion.createPage({
  parent: { database_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890" },
  properties: {
    Name: { title: [{ text: { content: "Weekly Standup Notes" } }] },
    Status: { select: { name: "In Progress" } },
    Assignee: { people: [{ id: "user-id-here" }] },
    "Due Date": { date: { start: "2025-02-15" } },
  },
});

// Query a database with filters
const results = await notion.queryDatabase({
  database_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  filter: {
    and: [
      { property: "Status", select: { equals: "In Progress" } },
      { property: "Assignee", people: { contains: "user-id-here" } },
    ],
  },
  sorts: [{ property: "Due Date", direction: "ascending" }],
  page_size: 20,
});

// Search across the workspace
const searchResults = await notion.search({
  query: "Q4 planning",
  filter: { property: "object", value: "page" },
  sort: { direction: "descending", timestamp: "last_edited_time" },
});

import { Cognest, Skill, IncomingEvent } from "@cognest/sdk";
import {
  NotionIntegration,
  NotionPageCreatedEvent,
} from "@cognest/integrations/notion";

const cognest = new Cognest();
const notion = cognest.integration<NotionIntegration>("notion");

const meetingNotes = new Skill({
  name: "meeting-notes",
  description: "Auto-generate structured meeting notes from raw transcripts",
});

meetingNotes.on(
  "notion:page:created",
  async (event: IncomingEvent<NotionPageCreatedEvent>) => {
    const { pageId, databaseId, properties } = event.payload;

    // Only process pages in the meetings database
    const MEETINGS_DB = process.env.NOTION_MEETINGS_DB!;
    if (databaseId !== MEETINGS_DB) return;

    // Get the full page content (raw transcript)
    const page = await notion.getPage(pageId);
    const titleProp = properties["Name"];
    const meetingTitle =
      titleProp?.type === "title"
        ? titleProp.title.map((t) => t.plain_text).join("")
        : "Untitled Meeting";

    // Use the Think Engine to structure the transcript
    const structured = await cognest.think({
      prompt: `You are a meeting notes assistant. Given the meeting titled "${meetingTitle}", generate structured notes.

Return JSON with:
{
  "summary": "2-3 sentence executive summary",
  "key_decisions": ["decision 1", "decision 2"],
  "action_items": [
    { "task": "description", "owner": "name", "due": "YYYY-MM-DD" }
  ],
  "open_questions": ["question 1"]
}`,
      responseFormat: "json",
    });

    const { summary, key_decisions, action_items, open_questions } =
      structured.parsed;

    // Update the page status property
    await notion.updatePage({
      page_id: pageId,
      properties: {
        Status: { select: { name: "Processed" } },
      },
    });

    // Append structured blocks to the page
    await notion.appendBlocks({
      block_id: pageId,
      children: [
        {
          type: "heading_2",
          heading_2: {
            rich_text: [{ type: "text", text: { content: "Summary" } }],
          },
        },
        {
          type: "paragraph",
          paragraph: {
            rich_text: [{ type: "text", text: { content: summary } }],
          },
        },
        {
          type: "heading_2",
          heading_2: {
            rich_text: [
              { type: "text", text: { content: "Key Decisions" } },
            ],
          },
        },
        ...key_decisions.map((decision: string) => ({
          type: "bulleted_list_item" as const,
          bulleted_list_item: {
            rich_text: [{ type: "text" as const, text: { content: decision } }],
          },
        })),
        {
          type: "heading_2",
          heading_2: {
            rich_text: [
              { type: "text", text: { content: "Action Items" } },
            ],
          },
        },
        ...action_items.map(
          (item: { task: string; owner: string; due: string }) => ({
            type: "to_do" as const,
            to_do: {
              rich_text: [
                {
                  type: "text" as const,
                  text: {
                    content: `${item.task} — @${item.owner} (due ${item.due})`,
                  },
                },
              ],
              checked: false,
            },
          })
        ),
        {
          type: "heading_2",
          heading_2: {
            rich_text: [
              { type: "text", text: { content: "Open Questions" } },
            ],
          },
        },
        ...open_questions.map((q: string) => ({
          type: "bulleted_list_item" as const,
          bulleted_list_item: {
            rich_text: [{ type: "text" as const, text: { content: q } }],
          },
        })),
      ],
    });

    cognest.log.info(
      `Processed meeting notes for "${meetingTitle}" (${pageId})`
    );
  }
);

cognest.register(meetingNotes);
cognest.start();