Event – Message Structure Concept

1
namespace:operation          ←  Event-Name
2
{ key, key, key }            ←  Payload

1
event.emit('controller:navigation:ready', {
2
    items: [...],
3
    count: 5,
4
});

1
{namespace}:{operation}
2
{namespace}:{area}:{operation}

1
@xpulse/controller  →  controller
2
@xpulse/http        →  http
3
@xpulse/router      →  router
4
@xpulse/template    →  template
5
@xpulse/logger      →  logger
6
@xpulse/app         →  app

1
auth:login
2
chat:message:received
3
peer:connected

1
✓  controller:ready           ← Discovery abgeschlossen
2
✓  http:request               ← Request eingegangen
3
✓  router:matched             ← Route gematcht
4
✓  navigation:collected       ← navItems gesammelt
5
✓  template:render:after      ← Rendering abgeschlossen
6
 
7
✗  controller:discovering     ← Verlaufsform – nicht verwenden
8
✗  http:will-receive-request  ← Zukunft – nicht verwenden
9
✗  router:match               ← Imperativ – nicht verwenden

1
✓  template:render:before     ← expliziter Pre-Hook, data noch mutierbar
2
✓  http:response:before       ← expliziter Pre-Hook, body noch mutierbar

1
{namespace}:init    ← Initialisierung beginnt
2
{namespace}:ready   ← Initialisierung abgeschlossen

1
app:init
2
app:ready
3
app:stopping
4
app:stopped
5
 
6
http:init
7
http:ready
8
http:started
9
http:stopped
10
http:request
11
http:response:before
12
http:response
13
 
14
controller:init
15
controller:ready
16
controller:discovered
17
controller:called
18
controller:navigation:collected
19
controller:navigation:ready
20
 
21
router:matched
22
router:not-found
23
 
24
template:render:before
25
template:render:after
26
 
27
logger:init
28
logger:ready
29
logger:write
30
 
31
dotenv:loaded
32
config:loaded

1
// ✓ Immer Objekt
2
event.emit('controller:ready', { count: 5, routes: 8 });
3
 
4
// ✗ Kein primitiver Wert
5
event.emit('controller:ready', 5);

1
// ✓ Flach
2
event.emit('http:request', {
3
    traceId: 'abc123',
4
    method:  'GET',
5
    path:    '/info',
6
    ip:      '192.168.1.0',
7
});
8
 
9
// ✗ Zu tief verschachtelt
10
event.emit('http:request', {
11
    request: {
12
        meta: {
13
            traceId: 'abc123',
14
        },
15
    },
16
});

1
// ✓ Array als Top-Level
2
event.emit('controller:navigation:collected', {
3
    items: [ ... ],
4
    count: 5,
5
});

1
// ✓
2
{ traceId, methodName, filePath, itemCount }
3
 
4
// ✗
5
{ trace_id, method_name, file_path, item_count }

1
// :init – was wird initialisiert
2
{ root?, config? }
3
 
4
// :ready – Ergebnis der Initialisierung
5
{ count?, routes?, items?, uptime? }

1
// Immer traceId damit Requests korrelierbar sind
2
{ traceId, method, path, ... }

1
// Immer count – wie viele wurden gefunden
2
{ count, ... }

1
// Immer message + optional err (das Error-Objekt selbst)
2
{ message: 'template not found', err, context? }

1
// template:render:before – data ist mutierbar
2
event.on('template:render:before', ({ data }) => {
3
    data._nav   = navigationRegistry.getItems();  // injizieren
4
    data._route = currentRoute;                   // injizieren
5
});

1
// Name:    controller:navigation:collected
2
//          ──────────┬────────── ─────────
3
//          namespace │area       operation
4
//                    └─ Unterbereich von controller
5
 
6
// Payload:
7
{
8
    items: NavItem[],   // mutable – Listener können filtern/erweitern
9
    count: number,      // Anzahl gesammelter Items vor Pipeline
10
}
11
 
12
// Verhalten: fired-and-forgotten, Payload ist mutable (Pre-Hook)

1
log.debug('navItem registered', { key: 'info_team' })
2
    ↓
3
logger:write event  →  @xpulse/debug sammelt
4
    ↓
5
Console / Datei     →  Entwickler liest

1
// Intern in @xpulse/controller beim init()
2
event.register('controller:navigation:collected', {
3
    description: 'navItems collected from all controllers – mutable, pipeline open',
4
    emittedBy:   '@xpulse/controller',
5
    payload:     '{ items: NavItem[], count: number }',
6
    mutable:     true,
7
});
8
 
9
event.register('controller:navigation:ready', {
10
    description: 'Navigation finalized – read-only',
11
    emittedBy:   '@xpulse/controller',
12
    payload:     '{ items: NavItem[], count: number }',
13
    mutable:     false,
14
});