Added AI summaries to update notfications

Author: barrymichaeldoyle

package.json

@@ -32,8 +32,8 @@
     "dev:cli": "pnpm --filter patch-pulse dev",
     "pp": "node --import tsx packages/cli/src/index.ts",
     "dev:vscode-extension": "pnpm --filter patch-pulse-vscode-extension watch",
-    "format": "pnpm exec oxfmt --write . '!packages/docs/.astro/**'",
-    "format:check": "pnpm exec oxfmt --check . '!packages/docs/.astro/**'",
+    "format": "pnpm exec oxfmt --write . '!packages/docs/.astro/**' '!packages/*/convex/_generated/**'",
+    "format:check": "pnpm exec oxfmt --check . '!packages/docs/.astro/**' '!packages/*/convex/_generated/**'",
     "ci:check": "pnpm lint && pnpm format:check && pnpm knip && pnpm typecheck && pnpm test:shared && pnpm test:cli && pnpm test:notifier && pnpm build:cli && pnpm build:vscode-extension && pnpm build:docs",
     "knip": "pnpm exec knip",
     "lint": "pnpm exec oxlint .",

packages/notifier-bot/.env.example

@@ -3,10 +3,14 @@ SLACK_CLIENT_ID=
 SLACK_CLIENT_SECRET=
 SLACK_SIGNING_SECRET=
 SLACK_REDIRECT_URI=
+OPENAI_API_KEY=
+OPENAI_SUMMARY_NANO_MODEL=
+OPENAI_SUMMARY_MINI_MODEL=
+GITHUB_TOKEN=
 
 # Deployment used by `npx convex dev`
 CONVEX_DEPLOYMENT=
 
 CONVEX_URL=
 
-CONVEX_SITE_URL=
+CONVEX_SITE_URL=

packages/notifier-bot/README.md

@@ -11,6 +11,7 @@ It currently supports:
 - Slack workspace subscriptions
 - npm package polling
 - Multi-channel Slack tracking per workspace
+- Delayed GitHub metadata enrichment and AI release summaries
 
 More detailed docs live here:
 
@@ -29,6 +30,7 @@ An hourly cron checks tracked packages for updates. When a newer version is foun
 2. GitHub repo metadata is stored on the package when it can be derived from npm metadata.
 3. Matching subscribers are grouped by Slack target channel.
 4. Slack notifications are sent to the relevant channel or the workspace default channel.
+5. If upstream metadata is incomplete, Patch Pulse retries later, updates the original post with release links, and adds an AI summary in the thread when the evidence is strong enough.
 
 ## Slack Summary
 
@@ -61,3 +63,4 @@ Useful commands from this package directory:
 - `/npmlist` does not perform live npm lookups. It uses stored package metadata so the response stays fast.
 - GitHub links in `/npmlist` appear after polling has enriched a package with repo metadata.
 - Update notifications can include richer release links because polling already fetches npm manifests during the update check.
+- Patch Pulse uses status reactions on the original Slack post: `⏳` queued/pending, `📝` summary added, `⚠️` no trustworthy release details found after retries, `❌` processing failed.

packages/notifier-bot/convex/_generated/api.d.ts

@@ -8,44 +8,48 @@
  * @module
  */
 
-import type * as crons from '../crons.js';
-import type * as http from '../http.js';
-import type * as packages from '../packages.js';
-import type * as polling from '../polling.js';
-import type * as releaseChecks from '../releaseChecks.js';
-import type * as slack_api from '../slack/api.js';
-import type * as slack_bannerAsset from '../slack/bannerAsset.js';
-import type * as slack_commands from '../slack/commands.js';
-import type * as slack_events from '../slack/events.js';
-import type * as slack_format from '../slack/format.js';
-import type * as slack_interactions from '../slack/interactions.js';
-import type * as slack_links from '../slack/links.js';
-import type * as slack_oauth from '../slack/oauth.js';
-import type * as slack_verify from '../slack/verify.js';
-import type * as subscribers from '../subscribers.js';
-import type * as subscriptions from '../subscriptions.js';
+import type * as aiSummary from "../aiSummary.js";
+import type * as crons from "../crons.js";
+import type * as http from "../http.js";
+import type * as packages from "../packages.js";
+import type * as polling from "../polling.js";
+import type * as releaseChecks from "../releaseChecks.js";
+import type * as releaseEvidence from "../releaseEvidence.js";
+import type * as slack_api from "../slack/api.js";
+import type * as slack_bannerAsset from "../slack/bannerAsset.js";
+import type * as slack_commands from "../slack/commands.js";
+import type * as slack_events from "../slack/events.js";
+import type * as slack_format from "../slack/format.js";
+import type * as slack_interactions from "../slack/interactions.js";
+import type * as slack_links from "../slack/links.js";
+import type * as slack_oauth from "../slack/oauth.js";
+import type * as slack_verify from "../slack/verify.js";
+import type * as subscribers from "../subscribers.js";
+import type * as subscriptions from "../subscriptions.js";
 
 import type {
   ApiFromModules,
   FilterApi,
   FunctionReference,
-} from 'convex/server';
+} from "convex/server";
 
 declare const fullApi: ApiFromModules<{
+  aiSummary: typeof aiSummary;
   crons: typeof crons;
   http: typeof http;
   packages: typeof packages;
   polling: typeof polling;
   releaseChecks: typeof releaseChecks;
-  'slack/api': typeof slack_api;
-  'slack/bannerAsset': typeof slack_bannerAsset;
-  'slack/commands': typeof slack_commands;
-  'slack/events': typeof slack_events;
-  'slack/format': typeof slack_format;
-  'slack/interactions': typeof slack_interactions;
-  'slack/links': typeof slack_links;
-  'slack/oauth': typeof slack_oauth;
-  'slack/verify': typeof slack_verify;
+  releaseEvidence: typeof releaseEvidence;
+  "slack/api": typeof slack_api;
+  "slack/bannerAsset": typeof slack_bannerAsset;
+  "slack/commands": typeof slack_commands;
+  "slack/events": typeof slack_events;
+  "slack/format": typeof slack_format;
+  "slack/interactions": typeof slack_interactions;
+  "slack/links": typeof slack_links;
+  "slack/oauth": typeof slack_oauth;
+  "slack/verify": typeof slack_verify;
   subscribers: typeof subscribers;
   subscriptions: typeof subscriptions;
 }>;
@@ -60,7 +64,7 @@ declare const fullApi: ApiFromModules<{
  */
 export declare const api: FilterApi<
   typeof fullApi,
-  FunctionReference<any, 'public'>
+  FunctionReference<any, "public">
 >;
 
 /**
@@ -73,7 +77,7 @@ export declare const api: FilterApi<
  */
 export declare const internal: FilterApi<
   typeof fullApi,
-  FunctionReference<any, 'internal'>
+  FunctionReference<any, "internal">
 >;
 
 export declare const components: {};

packages/notifier-bot/convex/_generated/api.js

@@ -8,7 +8,7 @@
  * @module
  */
 
-import { anyApi, componentsGeneric } from 'convex/server';
+import { anyApi, componentsGeneric } from "convex/server";
 
 /**
  * A utility for referencing Convex functions in your app's API.

packages/notifier-bot/convex/_generated/dataModel.d.ts

@@ -13,9 +13,9 @@ import type {
   DocumentByName,
   TableNamesInDataModel,
   SystemTableNames,
-} from 'convex/server';
-import type { GenericId } from 'convex/values';
-import schema from '../schema.js';
+} from "convex/server";
+import type { GenericId } from "convex/values";
+import schema from "../schema.js";
 
 /**
  * The names of all of your Convex tables.

packages/notifier-bot/convex/_generated/server.d.ts

@@ -18,8 +18,8 @@ import {
   GenericQueryCtx,
   GenericDatabaseReader,
   GenericDatabaseWriter,
-} from 'convex/server';
-import type { DataModel } from './dataModel.js';
+} from "convex/server";
+import type { DataModel } from "./dataModel.js";
 
 /**
  * Define a query in this Convex app's public API.
@@ -29,7 +29,7 @@ import type { DataModel } from './dataModel.js';
  * @param func - The query function. It receives a {@link QueryCtx} as its first argument.
  * @returns The wrapped query. Include this as an `export` to name it and make it accessible.
  */
-export declare const query: QueryBuilder<DataModel, 'public'>;
+export declare const query: QueryBuilder<DataModel, "public">;
 
 /**
  * Define a query that is only accessible from other Convex functions (but not from the client).
@@ -39,7 +39,7 @@ export declare const query: QueryBuilder<DataModel, 'public'>;
  * @param func - The query function. It receives a {@link QueryCtx} as its first argument.
  * @returns The wrapped query. Include this as an `export` to name it and make it accessible.
  */
-export declare const internalQuery: QueryBuilder<DataModel, 'internal'>;
+export declare const internalQuery: QueryBuilder<DataModel, "internal">;
 
 /**
  * Define a mutation in this Convex app's public API.
@@ -49,7 +49,7 @@ export declare const internalQuery: QueryBuilder<DataModel, 'internal'>;
  * @param func - The mutation function. It receives a {@link MutationCtx} as its first argument.
  * @returns The wrapped mutation. Include this as an `export` to name it and make it accessible.
  */
-export declare const mutation: MutationBuilder<DataModel, 'public'>;
+export declare const mutation: MutationBuilder<DataModel, "public">;
 
 /**
  * Define a mutation that is only accessible from other Convex functions (but not from the client).
@@ -59,7 +59,7 @@ export declare const mutation: MutationBuilder<DataModel, 'public'>;
  * @param func - The mutation function. It receives a {@link MutationCtx} as its first argument.
  * @returns The wrapped mutation. Include this as an `export` to name it and make it accessible.
  */
-export declare const internalMutation: MutationBuilder<DataModel, 'internal'>;
+export declare const internalMutation: MutationBuilder<DataModel, "internal">;
 
 /**
  * Define an action in this Convex app's public API.
@@ -72,15 +72,15 @@ export declare const internalMutation: MutationBuilder<DataModel, 'internal'>;
  * @param func - The action. It receives an {@link ActionCtx} as its first argument.
  * @returns The wrapped action. Include this as an `export` to name it and make it accessible.
  */
-export declare const action: ActionBuilder<DataModel, 'public'>;
+export declare const action: ActionBuilder<DataModel, "public">;
 
 /**
  * Define an action that is only accessible from other Convex functions (but not from the client).
  *
  * @param func - The function. It receives an {@link ActionCtx} as its first argument.
  * @returns The wrapped function. Include this as an `export` to name it and make it accessible.
  */
-export declare const internalAction: ActionBuilder<DataModel, 'internal'>;
+export declare const internalAction: ActionBuilder<DataModel, "internal">;
 
 /**
  * Define an HTTP action.

packages/notifier-bot/convex/_generated/server.js

@@ -16,7 +16,7 @@ import {
   internalActionGeneric,
   internalMutationGeneric,
   internalQueryGeneric,
-} from 'convex/server';
+} from "convex/server";
 
 /**
  * Define a query in this Convex app's public API.

packages/notifier-bot/convex/aiSummary.ts

@@ -0,0 +1,111 @@
+import { type UpdateType } from '@patch-pulse/shared';
+import { type ReleaseEvidence } from './releaseEvidence';
+
+const OPENAI_API_URL = 'https://api.openai.com/v1/responses';
+const DEFAULT_NANO_MODEL = 'gpt-5-nano';
+const DEFAULT_MINI_MODEL = 'gpt-5-mini';
+
+function buildSummaryPrompt(args: {
+  packageName: string;
+  fromVersion: string;
+  toVersion: string;
+  updateType: UpdateType;
+  evidence: ReleaseEvidence;
+}): string {
+  const { packageName, fromVersion, toVersion, updateType, evidence } = args;
+
+  const sections = [
+    `Package: ${packageName}`,
+    `Update: ${fromVersion} -> ${toVersion} (${updateType})`,
+  ];
+
+  if (evidence.releaseTag) {
+    sections.push(`Release tag: ${evidence.releaseTag}`);
+  }
+  if (evidence.releaseName) {
+    sections.push(`Release name: ${evidence.releaseName}`);
+  }
+  if (evidence.releaseBody) {
+    sections.push(`Release notes:\n${evidence.releaseBody}`);
+  }
+  if (evidence.commitTitles.length > 0) {
+    sections.push(
+      `Commit titles:\n${evidence.commitTitles.map((title) => `- ${title}`).join('\n')}`,
+    );
+  }
+  if (evidence.changedFiles.length > 0) {
+    sections.push(
+      `Changed files:\n${evidence.changedFiles.map((file) => `- ${file}`).join('\n')}`,
+    );
+  }
+
+  return sections.join('\n\n');
+}
+
+async function callOpenAiSummary(
+  model: string,
+  prompt: string,
+): Promise<string> {
+  const apiKey = process.env.OPENAI_API_KEY;
+  if (!apiKey) return '';
+
+  const response = await fetch(OPENAI_API_URL, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      Authorization: `Bearer ${apiKey}`,
+    },
+    body: JSON.stringify({
+      model,
+      input: [
+        {
+          role: 'system',
+          content: [
+            {
+              type: 'input_text',
+              text:
+                'You summarize software releases for Slack. Use only the provided evidence. ' +
+                'Do not speculate. Return a single plain-text sentence under 240 characters. ' +
+                'If the evidence is insufficient, return exactly INSUFFICIENT.',
+            },
+          ],
+        },
+        {
+          role: 'user',
+          content: [{ type: 'input_text', text: prompt }],
+        },
+      ],
+    }),
+  });
+
+  if (!response.ok) {
+    throw new Error(`OpenAI API error ${response.status}`);
+  }
+
+  const data = (await response.json()) as {
+    output_text?: string;
+  };
+
+  return data.output_text?.trim() ?? '';
+}
+
+export async function summarizeReleaseEvidence(args: {
+  packageName: string;
+  fromVersion: string;
+  toVersion: string;
+  updateType: UpdateType;
+  evidence: ReleaseEvidence;
+}): Promise<{ model: string; summary: string } | null> {
+  const prompt = buildSummaryPrompt(args);
+
+  for (const model of [
+    process.env.OPENAI_SUMMARY_NANO_MODEL ?? DEFAULT_NANO_MODEL,
+    process.env.OPENAI_SUMMARY_MINI_MODEL ?? DEFAULT_MINI_MODEL,
+  ]) {
+    const summary = await callOpenAiSummary(model, prompt);
+    if (!summary || summary === 'INSUFFICIENT') continue;
+    return { model, summary };
+  }
+
+  return null;
+}