Alex Galey
b578ea5951
# Fireflies Automatically (with cli util : webhook not working and no cron added) captures meeting notes with AI-generated summaries and insights from Fireflies.ai into your Twenty CRM. ## Current Status - Doesn't work with Fireflies webhook yet due to missing headers forwarding in twenty serverless func - Meeting ingestion utility script are available for individual meeting insertion and historical meetings with filters with yarn meeting:all - You have to push the secrets as application.config.ts values (despite env variables in .env in docker compose or container I couldn't push the secrets with the cli) ## Current Platform Limitation (Headers) - Twenty serverless route triggers currently do **not forward HTTP headers** to functions. Fireflies signatures sent in headers are stripped, so header-based verification does not work in production. - Workaround: the provided test script also includes the signature inside the payload; the handler falls back to that payload signature. Use this only for testing until header forwarding is supported. ## Utilities for meeting insertion (workarounds) - Ingest a specific Fireflies meeting into Twenty: `yarn meeting:ingest <meetingId>` or `MEETING_ID=... yarn meeting:ingest` - Fetch all/historical Fireflies meetings into Twenty: `yarn meeting:all [--from 2024-01-01] [--to 2024-02-01] [--organizer a@x.com] [--participant b@x.com] [--channel <channelId>] [--mine] [--dry-run]` - Filters (combine as needed): - `--from` / `--to`: ISO or date string range filter - `--organizer` / `--participant`: comma-separated emails - `--channel`: Fireflies channel id - `--mine`: only meetings for the current Fireflies user - Controls: - `--dry-run`: list and transform without writing to Twenty - `--page-size`: pagination size (default 50) - `--max-records`: stop after N transcripts (default 500) I am closing previous #16378 as this one includes it all
94 lines
2.4 KiB
TypeScript
94 lines
2.4 KiB
TypeScript
/* eslint-disable no-console */
|
|
/**
|
|
* Fetch a Fireflies meeting by ID and insert it into Twenty using the same path
|
|
* as the webhook handler.
|
|
*
|
|
* Usage:
|
|
* yarn meeting:ingest <meetingId>
|
|
* Or
|
|
* MEETING_ID=... yarn meeting:ingest
|
|
*
|
|
* Required env:
|
|
* FIREFLIES_API_KEY
|
|
* FIREFLIES_WEBHOOK_SECRET
|
|
* TWENTY_API_KEY
|
|
*
|
|
* Optional env:
|
|
* SERVER_URL (defaults to http://localhost:3000)
|
|
* FIREFLIES_PLAN (free|pro|business|enterprise)
|
|
*/
|
|
|
|
import { createHmac } from 'crypto';
|
|
import * as dotenv from 'dotenv';
|
|
import { existsSync } from 'fs';
|
|
import { dirname, join } from 'path';
|
|
import { fileURLToPath } from 'url';
|
|
|
|
import { WebhookHandler } from '../src/webhook-handler';
|
|
|
|
const __filename = fileURLToPath(import.meta.url);
|
|
const __dirname = dirname(__filename);
|
|
|
|
const envPath = join(__dirname, '..', '.env');
|
|
if (existsSync(envPath)) {
|
|
dotenv.config({ path: envPath });
|
|
}
|
|
|
|
const args = process.argv.slice(2);
|
|
const meetingId = args[0] || process.env.MEETING_ID;
|
|
|
|
if (!meetingId) {
|
|
console.error('❌ meetingId is required (arg or MEETING_ID env)');
|
|
process.exit(1);
|
|
}
|
|
|
|
const firefliesApiKey = process.env.FIREFLIES_API_KEY || '';
|
|
const twentyApiKey = process.env.TWENTY_API_KEY || '';
|
|
const webhookSecret = process.env.FIREFLIES_WEBHOOK_SECRET || '';
|
|
|
|
if (!firefliesApiKey) {
|
|
console.error('❌ FIREFLIES_API_KEY is required');
|
|
process.exit(1);
|
|
}
|
|
if (!twentyApiKey) {
|
|
console.error('❌ TWENTY_API_KEY is required');
|
|
process.exit(1);
|
|
}
|
|
if (!webhookSecret) {
|
|
console.error('❌ FIREFLIES_WEBHOOK_SECRET is required to generate signature');
|
|
process.exit(1);
|
|
}
|
|
|
|
const payload = {
|
|
meetingId,
|
|
eventType: 'Transcription completed',
|
|
};
|
|
|
|
const body = JSON.stringify(payload);
|
|
const signature = `sha256=${createHmac('sha256', webhookSecret)
|
|
.update(body, 'utf8')
|
|
.digest('hex')}`;
|
|
|
|
const main = async (): Promise<void> => {
|
|
console.log(`🚀 Ingesting meeting ${meetingId} via webhook handler`);
|
|
const handler = new WebhookHandler();
|
|
const result = await handler.handle(payload, {
|
|
'x-hub-signature': signature,
|
|
body,
|
|
});
|
|
|
|
console.log('✅ Result:');
|
|
console.log(JSON.stringify(result, null, 2));
|
|
|
|
if (result.errors && result.errors.length > 0) {
|
|
process.exitCode = 1;
|
|
}
|
|
};
|
|
|
|
main().catch((error) => {
|
|
console.error('❌ Failed to ingest meeting');
|
|
console.error(error instanceof Error ? error.message : String(error));
|
|
process.exit(1);
|
|
});
|
|
|