Function getPluginRows

plugin-server/src/utils/db/sql.ts:39–82

(hub: Hub)

}

export async function getPluginRows(hub: Hub): Promise<Plugin[]> {
    const { rows }: { rows: Plugin[] } = await hub.db.postgresQuery(
        // `posthog_plugin` columns have to be listed individually, as we want to exclude a few columns
        // and Postgres syntax unfortunately doesn't have a column exclusion feature. The excluded columns are:
        // - archive - this is a potentially large blob, only extracted in Django as a plugin server optimization
        // - latest_tag - not used in this service
        // - latest_tag_checked_at - not used in this service
        `SELECT
            posthog_plugin.id,
            posthog_plugin.name,
            posthog_plugin.url,
            posthog_plugin.tag,
            posthog_plugin.from_json,
            posthog_plugin.from_web,
            posthog_plugin.error,
            posthog_plugin.plugin_type,
            posthog_plugin.organization_id,
            posthog_plugin.is_global,
            posthog_plugin.capabilities,
            posthog_plugin.public_jobs,
            posthog_plugin.is_stateless,
            posthog_plugin.log_level,
            posthog_plugin.updated_at,
            psf__plugin_json.source as source__plugin_json,
            psf__index_ts.source as source__index_ts,
            psf__frontend_tsx.source as source__frontend_tsx,
            psf__site_ts.source as source__site_ts
        FROM posthog_plugin
        LEFT JOIN posthog_pluginsourcefile psf__plugin_json
            ON (psf__plugin_json.plugin_id = posthog_plugin.id AND psf__plugin_json.filename = 'plugin.json')
        LEFT JOIN posthog_pluginsourcefile psf__index_ts
            ON (psf__index_ts.plugin_id = posthog_plugin.id AND psf__index_ts.filename = 'index.ts')
        LEFT JOIN posthog_pluginsourcefile psf__frontend_tsx
            ON (psf__frontend_tsx.plugin_id = posthog_plugin.id AND psf__frontend_tsx.filename = 'frontend.tsx')
        LEFT JOIN posthog_pluginsourcefile psf__site_ts
            ON (psf__site_ts.plugin_id = posthog_plugin.id AND psf__site_ts.filename = 'site.ts')
        WHERE posthog_plugin.id IN (${pluginConfigsInForceQuery('plugin_id')}
        GROUP BY posthog_pluginconfig.plugin_id)`,
        undefined,
        'getPluginRows'
    )

    return rows
}

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