Skip to main content
Ask your AI

Understanding walkerOS Mapping

Overview​

Mapping transforms data at multiple points in the walkerOS flow:

  1. Source → Collector: Transform raw input (HTTP requests, dataLayer pushes) into walkerOS events
  2. Collector → Destination: Transform walkerOS events into vendor-specific formats

Core principle: Mapping is the universal transformation layer. Same strategies work everywhere in the flow.

Core Functions​

See packages/core/src/mapping.ts for implementation.

FunctionPurpose
getMappingEvent(event, rules)Find mapping rule for an event
getMappingValue(value, data, { collector })Transform a value using mapping config
processEventMapping(event, config, collector)Unified processing for sources/destinations

processEventMapping Flow​

1. Apply config.policy (modifies event)
2. Find matching rule via getMappingEvent()
3. Apply rule.policy (modifies event)
4. Transform config.data (global)
5. Check rule.ignore (short-circuits if true)
5b. Read rule.silent (informational - destination honors it)
6. Override event.name if rule.name
7. Transform rule.data (event-specific)

Configuration Hierarchy​

Mapping.Config (Top Level)​

interface Config {
consent?: Consent; // Required consent for ALL events
data?: Value; // Global data transformation
include?: string[]; // Event sections to flatten into context.data
policy?: Policy; // Pre-processing for ALL events
mapping?: Rules; // Event-specific rules
}

Mapping.Config.include​

include lists event sections to flatten into the destination's PushContext.data before the rule runs. Sections are top-level keys of the event (globals, user, consent, data, context, nested, source, custom). The runtime helper flattenIncludeSections (in packages/core/src/include.ts) handles the merge.

Use this when your mapping needs values from multiple event sections without plumbing each path through a key:/map: config. include is also available on Mapping.Rule (rule-level overrides config-level).

{
include: ['globals', 'user'],
mapping: {
page: {
view: {
// user.id and globals.* are now reachable via top-level paths in
// data/key/map values, e.g. `key: 'id'` for user.id.
data: { map: { user_id: 'id', site: 'language' } },
},
},
},
}

Mapping.Rule (Per Event)​

interface Rule {
name?: string; // Override event name
data?: Value; // Event-specific data transformation
include?: string[]; // Event sections to flatten into context.data (rule-level)
ignore?: boolean; // Skip this event entirely (no processing, no push)
silent?: boolean; // Process settings side effects, skip destination default push
policy?: Policy; // Event-specific pre-processing
condition?: Function; // Match condition (for arrays)
consent?: Consent; // Not enforced yet; config.consent gates a destination
settings?: unknown; // Custom event configuration
batch?: number; // Batch size for grouping
extend?: RulePatch; // Config-layer merge onto a package-shipped default rule
remove?: string[]; // Output-layer: dotted paths stripped from the final payload
}

extend and remove (patching package-shipped rules)​

Some packages ship their own default mapping rules. A user rule at the same key normally replaces the default in full. Two keywords change that:

  • extend (config layer): a partial rule deep-merged onto the package-shipped default at init, before any event is evaluated. A null value clears an inherited field. Lets you add or override one field while keeping the rest.
  • remove (output layer): dotted paths stripped from the produced payload after evaluation, applied last. Useful for dropping PII or vendor-reserved fields without rewriting the full rule.

A rule with neither keyword keeps the standard replace behavior.

See the website mapping docs for the authoritative reference and the GA4 example.

{
"purchase": {
"extend": {
"data": { "map": { "affiliation": "params.ep.affiliation" } }
},
"remove": ["currency"]
}
}

Silent vs Ignore​

Both flags control rule behavior but have different semantics:

  • ignore: true - the rule matched but nothing happens. No data transform, no destination call, no side effects. Use for suppression.
  • silent: true - the rule matched and the destination push() is called. settings.identify, settings.revenue, settings.group, etc. still run. Only the destination's default forwarding call (e.g. track(), capture(), event()) is suppressed. Use for "identify without an event" style flows.

If both flags are set on the same rule, ignore wins.

Common use case: a user login event that should call amplitude.identify() but should not create a separate track("user login") event in Amplitude.

Mapping.ValueConfig (Value Extraction)​

interface ValueConfig {
key?: string; // Extract from path
value?: Primitive; // Static fallback value
fn?: Function; // Compute the value from the source
map?: Record; // Object transformation
loop?: [path, config]; // Array transformation
set?: Value[]; // Create array from values
condition?: Function; // Conditional extraction
consent?: Consent; // Consent-gated extraction
validate?: Function; // Value validation
}

Exactly one producer runs per value, in this order: loop, map, set, key, fn. The rest never run, so a fn next to a key is ignored. value is the fallback when the producer yields nothing, including a loop over something that is not a list. To transform a field, use fn alone (it receives the source), or rewrite it with policy and read it with key.


Event Matching​

Match events to transformation rules by entity and action.

const mapping = {
// Exact match: "product view" → view_item
product: {
view: { name: 'view_item' },
add: { name: 'add_to_cart' },
},

// Wildcard action: "foo *" → foo_interaction
foo: {
'*': { name: 'foo_interaction' },
},

// Wildcard entity: "* click" → generic_click
'*': {
click: { name: 'generic_click' },
},
};

Conditional Mapping (Array)​

Array of rules - first matching condition wins:

order: {
complete: [
{
condition: (event) => event.data?.value > 100,
name: 'high_value_purchase',
},
{ name: 'purchase' }, // Fallback (no condition)
],
}

JSON with $code:

{
"order": {
"complete": [
{
"condition": "$code:(event) => event.data?.value > 100",
"name": "high_value_purchase"
},
{ "name": "purchase" }
]
}
}

Value Mapping Strategies​

Common patterns shown below. For detailed examples of all 12 strategies, see value-strategies.md.

Essential Patterns​

// Key extraction (string shorthand)
'data.price' // → event.data.price

// Key with fallback
{ key: 'data.currency', value: 'USD' } // Use USD if missing

// Static value
{ value: 'USD' }

// Function transform
{ fn: (event) => event.data.price * 100 } // Convert to cents

// Object map
{ map: { item_id: 'data.id', item_name: 'data.name' } }

// Array loop
{ loop: ['nested', { map: { item_id: 'data.id' } }] }

// Loop with "this" (single item as array)
{ loop: ['this', { map: { item_id: 'data.id' } }] }

// Set (create array)
{ set: ['data.id'] } // → ["SKU-123"]

// Fallback chain: Value[] at any value position (first defined value wins)
[{ key: 'data.sku' }, { key: 'data.id' }, { value: 'unknown' }]

// Consent-gated (the event's consent decides, in a loop too: a `consent`
// key on a loop item is plain data)
{ key: 'user.email', consent: { marketing: true } }

// Validate
{ key: 'data.email', validate: (v) => v.includes('@') }

Policy (Pre-Processing)​

Policy modifies the event BEFORE mapping rules are applied. Use for:

  • Adding computed fields
  • Normalizing data structure
  • Consent-gated field injection

Config-Level Policy​

Applied to ALL events:

config: {
policy: {
'user_data.external_id': 'user.id',
'custom_data.server_processed': { value: true },
},
mapping: { /* ... */ }
}

Event-Level Policy​

Applied after config policy, only for specific event:

mapping: {
order: {
complete: {
policy: {
'enriched.total_cents': {
fn: (event) => Math.round(event.data.total * 100)
}
},
name: 'purchase',
data: { /* ... */ }
}
}
}

A policy entry that resolves to nothing removes the field, so a denied consent gate redacts it:

{
"policy": {
"user_data.em": {
"key": "user.email",
"consent": { "marketing": true }
}
}
}

Rule Features​

Ignore Events​

mapping: {
test: { '*': { ignore: true } }, // Ignore all test events
}

Batch Processing​

To batch all of a destination's events, set config.batch (no mapping rule needed):

config: {
batch: { size: 5 }, // Flush after every 5 events (a bare number is the wait window in ms)
}

A rule-level batch batches only that entity-action into its own buffer and overrides config.batch per field:

mapping: {
order: {
complete: {
batch: { wait: 1000 }, // Only order complete batches, with a 1s debounce
}
}
}

Custom Settings​

mapping: {
order: {
complete: {
name: 'purchase',
settings: { priority: 'high', retryCount: 3 }
}
}
}

$code: Prefix (JSON Configs)​

The $code: prefix enables JavaScript functions in JSON configurations:

{
"fn": "$code:(event) => event.data.price * 100",
"condition": "$code:(event) => event.data?.value > 100",
"validate": "$code:(value) => value > 0"
}

Important: The $code: prefix is processed by the CLI bundler. It converts JSON strings to actual JavaScript functions during build.

Function Signatures​

All mapping callbacks share (value, context). The second argument is a Mapping.Context object (see "Context object" below).

ContextSignature
fn(value, context) => result
condition (value)(value, context) => boolean
condition (rule)(event, context) => boolean
validate(value, context) => boolean
loop condition(value, context) => boolean

One-arg signatures like (value) => value.toUpperCase() continue to work, TypeScript ignores the unused second arg.

Context object​

FieldTypeRequiredDescription
eventWalkerOS.DeepPartialEventyesThe root event being mapped
mappingMapping.Value | Mapping.RuleyesThe surrounding mapping config (or rule)
collectorCollector.InstanceyesActive collector, use for push and queue
loggerLogger.InstanceyesUse for info/warn/error/debug
consentWalkerOS.Consent (optional)noResolved consent at this evaluation point

Quick Reference​

Value Extraction Cheatsheet​

PatternResult
"data.id"Extract event.data.id
{ value: "USD" }Static "USD"
{ key: "x", value: "y" }Extract x, fallback to "y"
{ fn: (e) => ... }Custom function
{ map: {...} }Object transformation
{ loop: ["nested", {...}] }Array transformation
{ loop: ["this", {...}] }Single-item as array
{ set: ["a", "b"] }Create array [valA, valB]
[m1, m2, m3]Fallback chain
{ consent: {...} }Consent-gated
{ condition: fn }Conditional
{ validate: fn }Validated

Rule Features Cheatsheet​

FeaturePurpose
nameOverride event name
dataTransform event data
ignoreSkip event entirely (no processing, no push)
silentRun settings side effects, skip default forwarding
policyPre-process event
conditionMatch condition (arrays)
consentNot enforced yet; config.consent gates a destination
settingsCustom configuration
batchBatch size
extendConfig-layer merge onto a package-shipped default (null clears a field)
removeOutput-layer: dotted paths stripped from the final payload

Config Features Cheatsheet​

FeaturePurpose
consentRequired consent (all events)
dataGlobal data transformation
policyGlobal pre-processing
mappingEvent-specific rules

Complete Examples​

For full destination configuration examples (TypeScript + JSON), see complete-examples.md.


Mapping at the Transformer Position​

Mapping.Config accepts the same shape at three positions in the flow, but the semantic differs by position:

PositionWhat the mapping produces
SourceA walkerOS event from raw input
TransformerA mutated walkerOS event that continues through the chain
DestinationA vendor-shaped payload that the destination consumes

When a transformer step declares only a mapping (no code, no package), the collector synthesizes a push that runs processEventMapping against each event. A config.mapping wins over the step-level mapping. Next to code or package, a mapping never runs; init and validateFlowStructure warn about it. Same keyword as the destination field, different semantic at this step position. See walkeros-understanding-transformers for the pass-through-step model.

Which fields apply at the transformer position​

Only event-mutating fields run; every other field is a no-op, named in a one-time init warning (rules in array form included):

FieldTransformer position
policyApplies, pre-processes the event before rule matching
mapping[].conditionApplies, picks the rule (awaited in order, first match wins)
mapping[].policyApplies, per-event policy
mapping[].nameApplies, renames the event (mutation is observable downstream)
mapping[].ignoreApplies, drops the event from the chain entirely (no downstream step sees it)
consent, include, dataNo-op (no vendor payload, no destination to gate)
mapping[].consent, include, remove, batch, settings, extend, data, silentNo-op (destination-only concepts)

Note the ignore: true semantic shift: at a destination it skips delivery to that destination only; at a transformer step it drops the event from the chain so no downstream step (transformer or destination) sees it.

{
"transformers": {
"redactPII": {
"mapping": {
"policy": {
"user.email": { "value": "[redacted]" }
},
"mapping": {
"test": {
"*": { "ignore": true }
},
"order": {
"complete": { "name": "purchase" }
}
}
}
}
}
}

Where Mapping Lives​

LocationPurpose
Source configTransform raw input → walkerOS events
Transformer step configMutate walkerOS events in-flight
Destination configTransform walkerOS events → vendor format
state.mappingShape a store read or write (paths relative to the value read)
packages/core/src/mapping.tsCore mapping functions
packages/core/src/types/mapping.tsType definitions
packages/cli/examples/flow-complete.jsonTested example, features by id

Source Files:

Detailed References:

Examples:

💡 Need implementation support?
elbwalker offers hands-on support: setup review, measurement planning, destination mapping, and live troubleshooting. Book a 2-hour session (€399)