Hog Function

import * as posthog from "pulumi-posthog";const transform = new posthog.HogFunction("event-transform", {    name: "Add Processed Flag",    enabled: true,    type: "transformation",    hog: `        fun transform(event) {            event.properties.processed = true            event.properties.processed_at = now()            return event        }    `,});

const filteredTransform = new posthog.HogFunction("pageview-transform", {    name: "Enhance Pageviews",    enabled: true,    type: "transformation",    hog: `        fun transform(event) {            event.properties.enhanced = true            return event        }    `,    filtersJson: JSON.stringify({        events: [{ id: "$pageview" }],    }),});

const webhook = new posthog.HogFunction("webhook-destination", {    name: "Send to Webhook",    enabled: true,    type: "destination",    hog: `        fun send(event) {            fetch('https://api.example.com/webhook', {                method: 'POST',                body: event            })        }    `,    filtersJson: JSON.stringify({        events: [{ id: "purchase_completed" }],    }),});

const configurable = new posthog.HogFunction("configurable-transform", {    name: "Configurable Transform",    enabled: true,    type: "transformation",    hog: `        fun transform(event, inputs) {            event.properties.custom_field = inputs.fieldValue            return event        }    `,    inputsJson: JSON.stringify({        fieldValue: {            value: "default_value",        },    }),});

const orderedFunction = new posthog.HogFunction("first-transform", {    name: "First Transformation",    enabled: true,    type: "transformation",    executionOrder: 1, // Runs first    hog: `        fun transform(event) {            event.properties.step = 1            return event        }    `,});const secondFunction = new posthog.HogFunction("second-transform", {    name: "Second Transformation",    enabled: true,    type: "transformation",    executionOrder: 2, // Runs second    hog: `        fun transform(event) {            event.properties.step = 2            return event        }    `,});

type: "transformation"

type: "destination"

type: "siteDestination"

type: "siteApp"

hog: `    fun transform(event) {        // Add properties        event.properties.new_field = "value"                // Modify properties        event.properties.user_id = upper(event.properties.user_id)                // Return modified event        return event    }`

hog: `    fun transform(event) {        if event.event == '$pageview' {            event.properties.is_pageview = true        } else {            event.properties.is_pageview = false        }        return event    }`

hog: `    fun transform(event, inputs) {        event.properties.custom = inputs.customValue.value        return event    }`

// ✅ Goodconst fn = new posthog.HogFunction("add-user-segment", {    name: "Add User Segment Classification",    description: "Classify users into segments based on behavior",});// ❌ Avoidconst fn = new posthog.HogFunction("fn1", {    name: "Function 1",});

const fn = new posthog.HogFunction("purchase-enrichment", {    name: "Enrich Purchase Events",    filtersJson: JSON.stringify({        events: [{ id: "purchase_completed" }], // Only purchases    }),    hog: `        fun transform(event) {            // Expensive enrichment only for purchases            return event        }    `,});

// First: Clean dataconst cleaner = new posthog.HogFunction("clean", {    name: "Clean Event Data",    executionOrder: 1,});// Second: Enrich dataconst enricher = new posthog.HogFunction("enrich", {    name: "Enrich Event Data",    executionOrder: 2,});// Third: Format dataconst formatter = new posthog.HogFunction("format", {    name: "Format Event Data",    executionOrder: 3,});

const timestamp = new posthog.HogFunction("add-timestamp", {    name: "Add Processing Timestamp",    type: "transformation",    hog: `        fun transform(event) {            event.properties.processed_timestamp = now()            return event        }    `,});

const classify = new posthog.HogFunction("user-classification", {    name: "Classify User Type",    type: "transformation",    hog: `        fun transform(event) {            let revenue = event.properties.total_revenue || 0            if revenue > 1000 {                event.properties.user_segment = 'premium'            } else if revenue > 100 {                event.properties.user_segment = 'standard'            } else {                event.properties.user_segment = 'free'            }            return event        }    `,});

const webhookFn = new posthog.HogFunction("slack-notification", {    name: "Notify Slack on High-Value Purchase",    type: "destination",    filtersJson: JSON.stringify({        events: [{ id: "purchase_completed" }],    }),    hog: `        fun send(event) {            if event.properties.amount > 1000 {                fetch('https://hooks.slack.com/your-webhook', {                    method: 'POST',                    body: {                        text: 'High-value purchase: $' + event.properties.amount                    }                })            }        }    `,});

const sanitize = new posthog.HogFunction("pii-removal", {    name: "Remove PII from Events",    type: "transformation",    executionOrder: 1, // Run first    hog: `        fun transform(event) {            // Remove sensitive fields (check if they exist first)            if has(event.properties, 'email') {                delete event.properties.email            }            if has(event.properties, 'phone') {                delete event.properties.phone            }            if has(event.properties, 'ssn') {                delete event.properties.ssn            }                        // Hash user identifiers if present            if has(event.properties, 'user_id') {                event.properties.user_id = sha256(event.properties.user_id)            }                        return event        }    `,});