Zum Inhalt springen

Hook-Referenz

Hooks ermöglichen es Plugins, das Verhalten von EmDash an bestimmten Punkten im Lebenszyklus von Inhalten, Medien, E-Mails, Kommentaren und Seiten abzufangen und zu modifizieren.

HookAuslöserKann modifizierenExklusiv
content:beforeSaveBevor Inhalt gespeichert wirdInhaltsdatenNein
content:afterSaveNachdem Inhalt gespeichert wurdeNichtsNein
content:beforeDeleteBevor Inhalt gelöscht wirdKann abbrechenNein
content:afterDeleteNachdem Inhalt gelöscht wurdeNichtsNein
media:beforeUploadBevor Datei hochgeladen wirdDateimetadatenNein
media:afterUploadNachdem Datei hochgeladen wurdeNichtsNein
cronGeplante Aufgabe wird ausgeführtNichtsNein
email:beforeSendVor E-Mail-ZustellungNachricht, kann abbrechenNein
email:deliverZustellung der E-Mail via TransportNichtsJa
email:afterSendNach erfolgreicher E-Mail-ZustellungNichtsNein
comment:beforeCreateBevor Kommentar gespeichert wirdKommentar, kann abbrechenNein
comment:moderateEntscheidet über FreigabestatusStatusJa
comment:afterCreateNachdem Kommentar gespeichert wurdeNichtsNein
comment:afterModerateNach Admin-Änderung des KommentarstatusNichtsNein
page:metadataRendering des öffentlichen SeitenkopfsTags beisteuernNein
page:fragmentsRendering des öffentlichen SeitenkörpersSkripte einfügenNein
plugin:installWenn Plugin erstmals installiert wirdNichtsNein
plugin:activateWenn Plugin aktiviert wirdNichtsNein
plugin:deactivateWenn Plugin deaktiviert wirdNichtsNein
plugin:uninstallWenn Plugin entfernt wirdNichtsNein

Wird ausgeführt, bevor Inhalt in der Datenbank gespeichert wird. Dient zur Validierung, Transformation oder Anreicherung von Inhalten.

import { definePlugin } from "emdash";
export default definePlugin({
id: "my-plugin",
version: "1.0.0",
hooks: {
"content:beforeSave": async (event, ctx) => {
const { content, collection, isNew } = event;
// Zeitstempel hinzufügen
if (isNew) {
content.createdBy = "system";
}
content.modifiedAt = new Date().toISOString();
// Modifizierten Inhalt zurückgeben
return content;
},
},
});
interface ContentHookEvent {
content: Record<string, unknown>; // Content data
collection: string; // Collection slug
isNew: boolean; // True for creates, false for updates
}
  • Modifiziertes Inhaltsobjekt zurückgeben, um Änderungen anzuwenden
  • void zurückgeben, um unverändert durchzureichen

Wird ausgeführt, nachdem Inhalt gespeichert wurde. Dient für Nebeneffekte wie Benachrichtigungen, Cache-Invalidierung oder externe Synchronisierung.

hooks: {
"content:afterSave": async (event, ctx) => {
const { content, collection, isNew } = event;
if (collection === "posts" && content.status === "published") {
// Externen Dienst benachrichtigen
await ctx.http?.fetch("https://api.example.com/notify", {
method: "POST",
body: JSON.stringify({ postId: content.id }),
});
}
},
}

Kein Rückgabewert erwartet.

Wird ausgeführt, bevor Inhalt gelöscht wird. Dient zur Validierung der Löschung oder deren Verhinderung.

hooks: {
"content:beforeDelete": async (event, ctx) => {
const { id, collection } = event;
// Löschung geschützter Inhalte verhindern
const item = await ctx.content?.get(collection, id);
if (item?.data.protected) {
return false; // Cancel deletion
}
// Löschung erlauben
return true;
},
}
interface ContentDeleteEvent {
id: string; // Entry ID
collection: string; // Collection slug
}
  • false zurückgeben, um Löschung abzubrechen
  • true oder void zurückgeben, um zu erlauben

Wird ausgeführt, nachdem Inhalt gelöscht wurde. Dient für Aufräumarbeiten.

hooks: {
"content:afterDelete": async (event, ctx) => {
const { id, collection } = event;
// Verwandte Daten bereinigen
await ctx.storage.relatedItems.delete(`${collection}:${id}`);
},
}

Wird ausgeführt, bevor eine Datei hochgeladen wird. Dient zur Validierung, Umbenennung oder Ablehnung von Dateien.

hooks: {
"media:beforeUpload": async (event, ctx) => {
const { file } = event;
// Dateien über 10MB ablehnen
if (file.size > 10 * 1024 * 1024) {
throw new Error("File too large");
}
// Datei umbenennen
return {
name: `${Date.now()}-${file.name}`,
type: file.type,
size: file.size,
};
},
}
interface MediaUploadEvent {
file: {
name: string; // Original filename
type: string; // MIME type
size: number; // Size in bytes
};
}
  • Modifizierte Dateimetadaten zurückgeben, um Änderungen anzuwenden
  • void zurückgeben, um unverändert durchzureichen
  • Exception werfen, um den Upload abzulehnen

Wird ausgeführt, nachdem eine Datei hochgeladen wurde. Dient für Verarbeitung, Thumbnails oder Metadatenextraktion.

hooks: {
"media:afterUpload": async (event, ctx) => {
const { media } = event;
if (media.mimeType.startsWith("image/")) {
// Bildmetadaten speichern
await ctx.kv.set(`media:${media.id}:analyzed`, {
processedAt: new Date().toISOString(),
});
}
},
}
interface MediaAfterUploadEvent {
media: {
id: string;
filename: string;
mimeType: string;
size: number | null;
url: string;
createdAt: string;
};
}

Wird ausgeführt, wenn ein Plugin erstmals installiert wird. Dient für die Erstkonfiguration, das Anlegen von Speicherkollektionen oder das Einspielen von Startdaten.

hooks: {
"plugin:install": async (event, ctx) => {
// Initialize default settings
await ctx.kv.set("settings:enabled", true);
await ctx.kv.set("settings:threshold", 100);
ctx.log.info("Plugin erfolgreich installiert");
},
}

Wird ausgeführt, wenn ein Plugin aktiviert wird (nach der Installation oder erneuten Aktivierung).

hooks: {
"plugin:activate": async (event, ctx) => {
ctx.log.info("Plugin activated");
},
}

Wird ausgeführt, wenn ein Plugin deaktiviert wird.

hooks: {
"plugin:deactivate": async (event, ctx) => {
ctx.log.info("Plugin deactivated");
},
}

Wird ausgeführt, wenn ein Plugin entfernt wird. Dient für Aufräumarbeiten.

hooks: {
"plugin:uninstall": async (event, ctx) => {
const { deleteData } = event;
if (deleteData) {
// Alle Plugindaten bereinigen
const items = await ctx.kv.list("settings:");
for (const { key } of items) {
await ctx.kv.delete(key);
}
}
ctx.log.info("Plugin deinstalliert");
},
}
interface UninstallEvent {
deleteData: boolean; // User chose to delete data
}

Wird ausgelöst, wenn eine geplante Aufgabe ausgeführt wird. Aufgaben werden mit ctx.cron.schedule() geplant.

hooks: {
"cron": async (event, ctx) => {
if (event.name === "daily-sync") {
const data = await ctx.http?.fetch("https://api.example.com/data");
ctx.log.info("Sync complete");
}
},
}
interface CronEvent {
name: string;
data?: Record<string, unknown>;
scheduledAt: string;
}

E-Mail-Hooks bilden eine Pipeline: email:beforeSend → email:deliver → email:afterSend.

Fähigkeit: email:intercept

Middleware-Hook, der vor der Zustellung läuft. Transformiert Nachrichten oder bricht die Zustellung ab.

hooks: {
"email:beforeSend": async (event, ctx) => {
// Fuegt allen E-Mails eine Fusszeile hinzu
return {
...event.message,
text: event.message.text + "\n\n—Gesendet von Meine Website",
};
// Oder false zurückgeben, um Zustellung abzubrechen
},
}
interface EmailBeforeSendEvent {
message: { to: string; subject: string; text: string; html?: string };
source: string;
}
  • Modifizierte Nachricht zurückgeben, um zu transformieren
  • false zurückgeben, um Zustellung abzubrechen
  • void zurückgeben, um unverändert durchzureichen

Fähigkeit: email:provide | Exklusiv: Ja

Der Transport-Provider. Nur ein Plugin kann E-Mails zustellen. Verantwortlich für das tatsächliche Senden der Nachricht über einen E-Mail-Dienst.

hooks: {
"email:deliver": {
exclusive: true,
handler: async (event, ctx) => {
await sendViaSES(event.message);
},
},
}

Fähigkeit: email:intercept

Fire-and-Forget-Hook nach erfolgreicher Zustellung. Fehler werden protokolliert, breiten sich aber nicht aus.

hooks: {
"email:afterSend": async (event, ctx) => {
await ctx.kv.set(`email:log:${Date.now()}`, {
to: event.message.to,
subject: event.message.subject,
});
},
}

Kommentar-Hooks bilden eine Pipeline: comment:beforeCreate → comment:moderate → comment:afterCreate. Der comment:afterModerate-Hook wird separat ausgelöst, wenn ein Administrator den Status eines Kommentars ändert.

Berechtigung: read:users

Middleware-Hook, bevor ein Kommentar gespeichert wird. Kommentare anreichern, validieren oder ablehnen.

hooks: {
"comment:beforeCreate": async (event, ctx) => {
// Reject comments with links
if (event.comment.body.includes("http")) {
return false;
}
},
}
interface CommentBeforeCreateEvent {
comment: {
collection: string;
contentId: string;
parentId: string | null;
authorName: string;
authorEmail: string;
authorUserId: string | null;
body: string;
ipHash: string | null;
userAgent: string | null;
};
metadata: Record<string, unknown>;
}
  • Modifiziertes Event zurückgeben, um es zu transformieren
  • false zurückgeben, um abzulehnen
  • void zurückgeben, um durchzureichen

Berechtigung: read:users | Exklusiv: Ja

Entscheidet, ob ein Kommentar genehmigt, ausstehend oder Spam ist. Nur ein Moderations-Provider ist aktiv.

hooks: {
"comment:moderate": {
exclusive: true,
handler: async (event, ctx) => {
const score = await checkSpam(event.comment);
return {
status: score > 0.8 ? "spam" : score > 0.5 ? "pending" : "approved",
reason: `Spam score: ${score}`,
};
},
},
}
interface CommentModerateEvent {
comment: { /* same as beforeCreate */ };
metadata: Record<string, unknown>;
collectionSettings: {
commentsEnabled: boolean;
commentsModeration: "all" | "first_time" | "none";
commentsClosedAfterDays: number;
commentsAutoApproveUsers: boolean;
};
priorApprovedCount: number;
}
{ status: "approved" | "pending" | "spam"; reason?: string }

Berechtigung: read:users

Fire-and-Forget-Hook, nachdem ein Kommentar gespeichert wurde. Für Benachrichtigungen verwenden.

hooks: {
"comment:afterCreate": async (event, ctx) => {
if (event.comment.status === "approved") {
await ctx.email?.send({
to: event.contentAuthor?.email,
subject: `New comment on "${event.content.title}"`,
text: `${event.comment.authorName} commented: ${event.comment.body}`,
});
}
},
}

Berechtigung: read:users

Fire-and-Forget-Hook, wenn ein Administrator den Status eines Kommentars manuell ändert.

interface CommentAfterModerateEvent {
comment: { id: string; /* ... */ };
previousStatus: string;
newStatus: string;
moderator: { id: string; name: string | null };
}

Seiten-Hooks laufen beim Rendern öffentlicher Seiten. Sie erlauben es Plugins, Metadaten und Skripte einzufügen.

Berechtigung: page:inject

Meta-Tags, Open-Graph-Eigenschaften, JSON-LD-Strukturierte-Daten oder Link-Tags zum Seitenkopf beitragen.

hooks: {
"page:metadata": async (event, ctx) => {
return [
{ kind: "meta", name: "generator", content: "EmDash" },
{ kind: "property", property: "og:site_name", content: event.page.siteName },
{ kind: "jsonld", graph: { "@type": "WebSite", name: event.page.siteName } },
];
},
}
type PageMetadataContribution =
| { kind: "meta"; name: string; content: string; key?: string }
| { kind: "property"; property: string; content: string; key?: string }
| { kind: "link"; rel: string; href: string; hreflang?: string; key?: string }
| { kind: "jsonld"; id?: string; graph: Record<string, unknown> };

Das key-Feld dedupliziert Beiträge – nur der letzte Beitrag mit einem bestimmten Schlüssel wird verwendet.

Berechtigung: page:inject

Skripte oder HTML in Seiten einfügen. Nur für vertrauenswürdige (native) Plugins verfügbar.

hooks: {
"page:fragments": async (event, ctx) => {
return [
{
kind: "external-script",
placement: "body:end",
src: "https://analytics.example.com/script.js",
async: true,
},
{
kind: "inline-script",
placement: "head",
code: `window.siteId = "abc123";`,
},
];
},
}
type PageFragmentContribution =
| {
kind: "external-script";
placement: "head" | "body:start" | "body:end";
src: string;
async?: boolean;
defer?: boolean;
attributes?: Record<string, string>;
key?: string;
}
| {
kind: "inline-script";
placement: "head" | "body:start" | "body:end";
code: string;
attributes?: Record<string, string>;
key?: string;
}
| {
kind: "html";
placement: "head" | "body:start" | "body:end";
html: string;
key?: string;
};

Hooks akzeptieren entweder eine Handler-Funktion oder ein Konfigurationsobjekt:

hooks: {
// Simple handler
"content:afterSave": async (event, ctx) => { ... },
// Mit Konfiguration
"content:beforeSave": {
priority: 50, // Niedriger = läuft zuerst (Standard: 100)
timeout: 10000, // Maximale Ausführungszeit in ms (Standard: 5000)
dependencies: [], // Nach diesen Plugins ausführen
errorPolicy: "abort", // "continue" oder "abort" (Standard)
handler: async (event, ctx) => { ... },
},
}
OptionTypStandardBeschreibung
prioritynumber100Ausführungsreihenfolge (niedriger = früher)
timeoutnumber5000Maximale Ausführungszeit in Millisekunden
dependenciesstring[][]Plugin-IDs, die zuerst ausgeführt werden müssen
errorPolicystring"abort""continue", um Fehler zu ignorieren
exclusivebooleanfalseNur ein Plugin kann der aktive Provider sein (für Provider-Pattern-Hooks wie email:deliver, comment:moderate)

Alle Hooks erhalten ein Kontextobjekt mit Zugriff auf Plugin-APIs:

interface PluginContext {
plugin: { id: string; version: string };
storage: PluginStorage;
kv: KVAccess;
content?: ContentAccess;
media?: MediaAccess;
http?: HttpAccess;
log: LogAccess;
site: { name: string; url: string; locale: string };
url(path: string): string;
users?: UserAccess;
cron?: CronAccess;
email?: EmailAccess;
}

Siehe Plugin-Übersicht — Plugin-Kontext für Berechtigungsanforderungen und Methodendetails.

Fehler in Hooks werden protokolliert und basierend auf errorPolicy behandelt:

  • "abort" (Standard) — Ausführung stoppen, Transaktion bei Anwendbarkeit zurücksetzen
  • "continue" — Fehler protokollieren und mit dem nächsten Hook fortfahren
hooks: {
"content:beforeSave": {
errorPolicy: "continue", // Don't block save if this fails
handler: async (event, ctx) => {
try {
await ctx.http?.fetch("https://api.example.com/validate");
} catch (error) {
ctx.log.warn("Validation service unavailable", error);
}
},
},
}

Hooks werden in dieser Reihenfolge ausgeführt:

  1. Sortiert nach priority (aufsteigend)
  2. Plugins mit dependencies laufen nach ihren Abhängigkeiten
  3. Innerhalb derselben Priorität ist die Reihenfolge deterministisch, aber nicht spezifiziert
// This runs first (priority 10)
{ priority: 10, handler: ... }
// Dies läuft als Zweites (Priorität 50)
{ priority: 50, handler: ... }
// Dies läuft als Letztes (Standardpriorität 100)
{ handler: ... }