Himanshu-Sangshetti
41a9701d7f
A programmatic n8n community node wrapping the hosted Mem0 v3 REST API: add, search, get, get-many, update, delete, plus usableAsTool so the n8n AI Agent can call it. - Zero runtime dependencies (calls REST directly), TypeScript, ESLint clean — meets n8n verified-node requirements - Add supports custom_instructions, custom_categories, includes, excludes, a client-side entity-id guard, and async event polling (itemIndex on errors) - Anonymous opt-out telemetry (MEM0_TELEMETRY=false) - Docs page + docs.json/llms.txt entry, ci-gate + release wiring, AGENTS.md rows - Verified: tsc + ESLint + live E2E (add → search → get → delete) vs api.mem0.ai Split out of #6057 per review (separate PRs per integration).
41 lines
1.3 KiB
TypeScript
41 lines
1.3 KiB
TypeScript
import { createHash } from 'crypto';
|
|
|
|
// Anonymous usage telemetry via PostHog, mirroring the Mem0 CLI / plugins.
|
|
// Fire-and-forget: never awaited, never throws, so it can neither slow down
|
|
// nor break a workflow. Opt out with MEM0_TELEMETRY=false.
|
|
// Uses native fetch + crypto only — no runtime dependencies (verified-node rule).
|
|
const POSTHOG_API_KEY = 'phc_hgJkUVJFYtmaJqrvf6CYN67TIQ8yhXAkWzUn9AMU4yX';
|
|
const POSTHOG_HOST = 'https://us.i.posthog.com/i/v0/e/';
|
|
|
|
export function captureEvent(
|
|
event: string,
|
|
apiKey: string | undefined,
|
|
properties: Record<string, unknown> = {},
|
|
): void {
|
|
if (process.env.MEM0_TELEMETRY === 'false') return;
|
|
try {
|
|
// Hash the API key so events are attributable to one account without
|
|
// ever transmitting the key itself.
|
|
const distinctId = apiKey ? createHash('md5').update(apiKey).digest('hex') : 'n8n-anon';
|
|
const payload = {
|
|
api_key: POSTHOG_API_KEY,
|
|
event,
|
|
distinct_id: distinctId,
|
|
properties: {
|
|
source: 'N8N',
|
|
$process_person_profile: false,
|
|
...properties,
|
|
},
|
|
};
|
|
void fetch(POSTHOG_HOST, {
|
|
method: 'POST',
|
|
headers: { 'Content-Type': 'application/json' },
|
|
body: JSON.stringify(payload),
|
|
}).catch(() => {
|
|
/* swallow — telemetry must never surface to the user */
|
|
});
|
|
} catch {
|
|
/* swallow — telemetry must never break the workflow */
|
|
}
|
|
}
|