feat: Add all deprecated transformations

plugin-server/src/cdp/consumers/cdp-cyclotron-plugins-worker.consumer.ts

@@ -15,7 +15,7 @@ export class CdpCyclotronWorkerPlugins extends CdpCyclotronWorker {
 
     constructor(hub: Hub) {
         super(hub)
-        this.pluginExecutor = new LegacyPluginExecutorService()
+        this.pluginExecutor = new LegacyPluginExecutorService(hub)
     }
 
     public async processInvocations(invocations: HogFunctionInvocation[]): Promise<HogFunctionInvocationResult[]> {

plugin-server/src/cdp/consumers/cdp-cyclotron-plugins-worker.test.ts

@@ -127,6 +127,9 @@ describe('CdpCyclotronWorkerPlugins', () => {
                     "useEuropeanDataStorage": "No",
                   },
                   "fetch": [Function],
+                  "geoip": {
+                    "locate": [Function],
+                  },
                   "global": {},
                   "logger": {
                     "debug": [Function],

plugin-server/src/cdp/hog-transformations/hog-transformer.service.ts

@@ -43,7 +43,7 @@ export class HogTransformerService {
         this.hub = hub
         this.hogFunctionManager = new HogFunctionManagerService(hub)
         this.hogExecutor = new HogExecutorService(hub, this.hogFunctionManager)
-        this.pluginExecutor = new LegacyPluginExecutorService()
+        this.pluginExecutor = new LegacyPluginExecutorService(hub)
     }
 
     private getTransformationFunctions() {

plugin-server/src/cdp/legacy-plugins/_destinations/customerio/index.ts

@@ -5,7 +5,6 @@ import { Response } from '~/src/utils/fetch'
 
 import { LegacyDestinationPlugin, LegacyDestinationPluginMeta } from '../../types'
 import metadata from './plugin.json'
-
 const DEFAULT_HOST = 'track.customer.io'
 const DEFAULT_SEND_EVENTS_FROM_ANONYMOUS_USERS = 'Send all events'
 
@@ -257,7 +256,7 @@ function getEmailFromEvent(event: ProcessedPluginEvent): string | null {
 
 export const customerioPlugin: LegacyDestinationPlugin = {
     id: 'customerio-plugin',
-    metadata: metadata as any,
+    metadata,
     setupPlugin: setupPlugin as any,
     onEvent,
 }

plugin-server/src/cdp/legacy-plugins/_destinations/intercom/index.ts

@@ -4,7 +4,6 @@ import { Response } from '~/src/utils/fetch'
 
 import { LegacyDestinationPlugin, LegacyDestinationPluginMeta } from '../../types'
 import metadata from './plugin.json'
-
 type IntercomMeta = LegacyDestinationPluginMeta & {
     global: {
         intercomUrl: string
@@ -191,7 +190,7 @@ function getTimestamp(meta: IntercomMeta, event: ProcessedPluginEvent): number {
 
 export const intercomPlugin: LegacyDestinationPlugin = {
     id: 'posthog-intercom-plugin',
-    metadata: metadata as any,
+    metadata,
     onEvent,
     setupPlugin: () => Promise.resolve(),
 }

plugin-server/src/cdp/legacy-plugins/_transformations/Plugin-Stonly-Clean-Campaign-Name/index.ts

@@ -0,0 +1,39 @@
+import { PluginEvent } from '@posthog/plugin-scaffold'
+
+import { LegacyTransformationPlugin, LegacyTransformationPluginMeta } from '../../types'
+import metadata from './plugin.json'
+
+const cleanUtmCampain = (utmCampaign: string) => {
+    return utmCampaign
+        .replace('com-', 'comp-')
+        .replace('compp-', 'comp-')
+        .split('_')[0]
+        .split('-')
+        .slice(0, 2)
+        .join(' ')
+}
+
+export function processEvent(event: PluginEvent, _: LegacyTransformationPluginMeta) {
+    // Some events (such as $identify) don't have properties
+    if (event.properties && event.properties['utm_campaign']) {
+        const cleanCampaign = cleanUtmCampain(event.properties['utm_campaign'])
+        if (event.properties['$set']) {
+            event.properties['$set']['campaign'] = cleanCampaign
+        } else {
+            event.properties['$set'] = { campaign: cleanCampaign }
+        }
+        if (event.properties['$set_once']) {
+            event.properties['$set_once']['initial_campaign'] = cleanCampaign
+        } else {
+            event.properties['$set_once'] = { initial_campaign: cleanCampaign }
+        }
+    }
+    // Return the event to be ingested, or return null to discard
+    return event
+}
+
+export const pluginStonlyCleanCampaignName: LegacyTransformationPlugin = {
+    id: 'plugin-stonly-clean-campaign-name',
+    metadata,
+    processEvent,
+}

plugin-server/src/cdp/legacy-plugins/_transformations/Plugin-Stonly-Clean-Campaign-Name/plugin.json

@@ -0,0 +1,6 @@
+{
+    "name": "Clean Campaign Name",
+    "url": "https://github.com/posthog/Plugin-Stonly-Clean-Campaign-Name",
+    "description": "",
+    "config": []
+}

plugin-server/src/cdp/legacy-plugins/_transformations/Plugin-Stonly-Clean-Campaign-Name/template.ts

@@ -0,0 +1,14 @@
+import { HogFunctionTemplate } from '../../../templates/types'
+
+// NOTE: This is a deprecated plugin and should never be shown to new users
+export const template: HogFunctionTemplate = {
+    status: 'alpha',
+    type: 'transformation',
+    id: 'plugin-stonly-clean-campaign-name',
+    name: 'Clean Campaign Name',
+    description: '',
+    icon_url: '/static/hedgehog/builder-hog-01.png',
+    category: ['Custom'],
+    hog: `return event`,
+    inputs_schema: [],
+}

plugin-server/src/cdp/legacy-plugins/_transformations/downsampling-plugin/index.ts

@@ -39,7 +39,7 @@ export function processEvent(event: PluginEvent, { global }: LegacyTransformatio
 
 export const downsamplingPlugin: LegacyTransformationPlugin = {
     id: 'downsampling-plugin',
-    metadata: metadata as any,
+    metadata,
     processEvent,
     setupPlugin,
 }

plugin-server/src/cdp/legacy-plugins/_transformations/drop-events-on-property-plugin/index.ts

@@ -0,0 +1,28 @@
+// Learn more about plugins at: https://posthog.com/docs/plugins/build/overview
+
+import { PluginEvent } from '@posthog/plugin-scaffold'
+
+import { LegacyTransformationPlugin, LegacyTransformationPluginMeta } from '../../types'
+import metadata from './plugin.json'
+
+// Processes each event, optionally transforming it
+export function processEvent(event: PluginEvent, { config }: LegacyTransformationPluginMeta) {
+    // Some events (such as $identify) don't have properties
+    if (event.properties && event.properties[config.property_key]) {
+        if (!config.property_values || config.property_values == '') {
+            return null
+        }
+        const values = config.property_values.split(',')
+        if (values.indexOf(event.properties[config.property_key]) > -1) {
+            return null
+        }
+    }
+    // Return the event to be ingested, or return null to discard
+    return event
+}
+
+export const dropEventsOnPropertyPlugin: LegacyTransformationPlugin = {
+    id: 'drop-events-on-property-plugin',
+    metadata,
+    processEvent,
+}

plugin-server/src/cdp/legacy-plugins/_transformations/drop-events-on-property-plugin/plugin.json

@@ -0,0 +1,26 @@
+{
+    "name": "Drop Events Based On Property",
+    "url": "https://github.com/posthog/drop-events-on-property-plugin",
+    "description": "This plugin will drop any events that have a specific key. If you supply a value, it will drop any event with the combination of they key and the value. You will not be billed for any events that this plugin drops.",
+    "main": "index.js",
+    "posthogVersion": ">= 1.25.0",
+    "config": [
+        {
+            "markdown": "Configure the key and optional value to filter events on"
+        },
+        {
+            "key": "property_key",
+            "hint": "Which property key to filter on. If you do not specify a value, all events with this key will be dropped.",
+            "name": "Property key to filter on",
+            "type": "string",
+            "required": true
+        },
+        {
+            "key": "property_values",
+            "hint": "Which value to match to drop events. Split multiple values by comma to filter.",
+            "name": "Property value to filter on",
+            "type": "string",
+            "required": false
+        }
+    ]
+}

plugin-server/src/cdp/legacy-plugins/_transformations/drop-events-on-property-plugin/template.ts

@@ -0,0 +1,33 @@
+import { HogFunctionTemplate } from '../../../templates/types'
+
+// NOTE: This is a deprecated plugin and should never be shown to new users
+export const template: HogFunctionTemplate = {
+    status: 'alpha',
+    type: 'transformation',
+    id: 'plugin-drop-events-on-property-plugin',
+    name: 'Drop Events Based On Property',
+    description:
+        'This plugin will drop any events that have a specific key. If you supply a value, it will drop any event with the combination of they key and the value. You will not be billed for any events that this plugin drops.',
+    icon_url: 'https://raw.githubusercontent.com/posthog/drop-events-on-property-plugin/main/logo.png',
+    category: ['Custom'],
+    hog: `return event`,
+    inputs_schema: [
+        {
+            key: 'property_key',
+            templating: false,
+            description:
+                'Which property key to filter on. If you do not specify a value, all events with this key will be dropped.',
+            label: 'Property key to filter on',
+            type: 'string',
+            required: true,
+        },
+        {
+            key: 'property_values',
+            templating: false,
+            description: 'Which value to match to drop events. Split multiple values by comma to filter.',
+            label: 'Property value to filter on',
+            type: 'string',
+            required: false,
+        },
+    ],
+}