process.js

import { processElementsAgent } from './process_elements_agent';
import { processPropertiesAgent } from './process_properties_agent';

import { processElementsAgentInstaller } from './process_elements_agent_installer';
import { processPropertiesAgentInstaller } from './process_properties_agent_installer';

import { processElementsCloud } from './process_elements_cloud';
import { processPropertiesCloud } from './process_properties_cloud';

import { processElementsStaging } from './process_elements_staging';
import { processPropertiesStaging } from './process_properties_staging';

import { processElementsTesting } from './process_elements_testing';
import { processPropertiesTesting } from './process_properties_testing';

import { processElementsWebsite } from './process_elements_website';
import { processPropertiesWebsite } from './process_properties_website';

import { processElementsLearn } from './process_elements_learn';
import { processPropertiesLearn } from './process_properties_learn';

import { processElementsCommunity } from './process_elements_community';
import { processPropertiesCommunity } from './process_properties_community';

import { processElementsBlog } from './process_elements_blog';
import { processPropertiesBlog } from './process_properties_blog';

import { isDemo } from "./utils";
//import URL from 'url';

const netdataPluginVersion = '0.0.15'

async function setupPlugin({ config, global }) {
    //console.log("Setting up the plugin!")
    //console.log(config)
    global.setupDone = true
}

async function processEvent(event, { config, cache }) {

    if (event.properties) {

        event.properties['event_ph'] = event.event
        event.properties['netdata_posthog_plugin_version'] = netdataPluginVersion

        // determine processing based on url
        if ('$current_url' in event.properties) {

            // try extract specific url params
            //if (event.properties['$current_url'].startsWith('http')) {
            //    const urlParams = new URL(event.properties['$current_url']).searchParams
            //    if (event.properties['$current_url'].includes('utm_source')) event.properties['url_param_utm_source'] = urlParams.get('utm_source');
            //}

            if (
                (['agent dashboard', 'agent backend'].includes(event.properties['$current_url']))
                ||
                (isDemo(event.properties['$current_url']))
                ||
                (event.properties['$current_url'].startsWith('https://netdata.corp.app.netdata.cloud'))
            ) {

                event.properties['event_source'] = 'agent'
                event = processElementsAgent(event)
                event = processPropertiesAgent(event)

            } else if (['agent installer'].includes(event.properties['$current_url'])) {

                event.properties['event_source'] = 'agent installer'
                event = processElementsAgentInstaller(event)
                event = processPropertiesAgentInstaller(event)

            } else if (event.properties['$current_url'].startsWith('https://www.netdata.cloud')) {

                event.properties['event_source'] = 'website'
                event = processElementsWebsite(event)
                event = processPropertiesWebsite(event)

            } else if (event.properties['$current_url'].includes('netdata-website.netlify.app')) 
            {

                event.properties['event_source'] = 'website_preview'
                event = processElementsWebsite(event)
                event = processPropertiesWebsite(event)

            } else if (event.properties['$current_url'].startsWith('https://learn.netdata.cloud')) {

                event.properties['event_source'] = 'learn'
                event = processElementsLearn(event)
                event = processPropertiesLearn(event)

            } else if (event.properties['$current_url'].includes('netdata-docusaurus.netlify.app')) {

                event.properties['event_source'] = 'learn_preview'
                event = processElementsLearn(event)
                event = processPropertiesLearn(event)

            } else if (event.properties['$current_url'].startsWith('https://blog.netdata.cloud')) {

                event.properties['event_source'] = 'blog'
                event = processElementsBlog(event)
                event = processPropertiesBlog(event)

            } else if (event.properties['$current_url'].includes('netdata-blog.netlify.app')) {

                event.properties['event_source'] = 'blog_preview'
                event = processElementsBlog(event)
                event = processPropertiesBlog(event)

            } else if (event.properties['$current_url'].startsWith('https://community.netdata.cloud')) {

                event.properties['event_source'] = 'community'
                event = processElementsCommunity(event)
                event = processPropertiesCommunity(event)

            } else if (event.properties['$current_url'].startsWith('https://staging.netdata.cloud')) {

                event.properties['event_source'] = 'staging'
                event = processElementsStaging(event)
                event = processPropertiesStaging(event)

            } else if (event.properties['$current_url'].startsWith('https://testing.netdata.cloud')) {

                event.properties['event_source'] = 'testing'
                event = processElementsTesting(event)
                event = processPropertiesTesting(event)

            } else if (event.properties['$current_url'].startsWith('https://app.netdata.cloud') 
            || event.properties['$current_url'].includes(':19999/spaces/')
            || event.properties['$current_url'].includes('/spaces/')
            ) {

                if (event.properties['$current_url'].startsWith('https://app.netdata.cloud')) {
                    event.properties['event_source'] = 'cloud';
                } else {
                    event.properties['event_source'] = 'cloud_agent';
                }

                event = processElementsCloud(event)
                event = processPropertiesCloud(event)

            } else {

                event.properties['event_source'] = 'unknown'

            }

        } else if (event.properties['event_ph'] === '$identify') {

            event.properties['event_source'] = 'cloud'
            event = processElementsCloud(event)
            event = processPropertiesCloud(event)

        } else {

            event.properties['event_source'] = 'unknown'

        }
    }

    return event
}

module.exports = {
    setupPlugin,
    processEvent,
}