Function pluginConfigsInForceQuery

plugin-server/src/utils/db/sql.ts:13–37

(specificField?: keyof PluginConfig)

} from '../../types'

function pluginConfigsInForceQuery(specificField?: keyof PluginConfig): string {
    const fields = specificField
        ? `posthog_pluginconfig.${specificField}`
        : `
        posthog_pluginconfig.id,
        posthog_pluginconfig.team_id,
        posthog_pluginconfig.plugin_id,
        posthog_pluginconfig.enabled,
        posthog_pluginconfig.order,
        posthog_pluginconfig.config,
        posthog_pluginconfig.updated_at,
        posthog_pluginconfig.created_at,
        posthog_pluginconfig.error IS NOT NULL AS has_error
    `

    return `SELECT ${fields}
       FROM posthog_pluginconfig
       LEFT JOIN posthog_team ON posthog_team.id = posthog_pluginconfig.team_id
       LEFT JOIN posthog_organization ON posthog_organization.id = posthog_team.organization_id
       LEFT JOIN posthog_plugin ON posthog_plugin.id = posthog_pluginconfig.plugin_id
       WHERE (
           posthog_pluginconfig.enabled='t' AND posthog_organization.plugins_access_level > 0
           AND (posthog_plugin.organization_id = posthog_organization.id OR posthog_plugin.is_global)
       )`
}

export async function getPluginRows(hub: Hub): Promise<Plugin[]> {
    const { rows }: { rows: Plugin[] } = await hub.db.postgresQuery(