BigQuery Plugin

npm install @google-cloud/bigquery

import { BigQueryPlugin } from '@consenti/api/plugins'

createConsenti({
  plugins: [
    new BigQueryPlugin({
      projectId: 'my-gcp-project',
      datasetId: 'consenti',
      tableId: 'consent_records',
      keyFilename: '/path/to/service-account.json',
    }),
  ],
})

CREATE TABLE `project.consenti.consent_records` (
  visitor_id STRING NOT NULL,
  profile_id STRING NOT NULL,
  profile_version INT64 NOT NULL,
  tenant_id STRING NOT NULL,
  consent_json JSON,
  source STRING,
  gpc_detected BOOL,
  created_at TIMESTAMP NOT NULL
)
PARTITION BY DATE(created_at)
CLUSTER BY tenant_id, profile_id;

import { ConsentiPlugin } from '@consenti/api'
import type { ConsentDbRecord } from '@consenti/types'
import { BigQuery } from '@google-cloud/bigquery'

export class BigQueryPlugin extends ConsentiPlugin {
  name = 'bigquery'
  private bq: BigQuery
  private table: ReturnType<BigQuery['dataset']>['table']

  constructor(private opts: BigQueryPluginOptions) {
    super()
    this.bq = new BigQuery({ projectId: opts.projectId, keyFilename: opts.keyFilename })
    const dataset = this.bq.dataset(opts.datasetId)
    this.table = dataset.table(opts.tableId)
  }

  override async afterConsentSave(record: ConsentDbRecord): Promise<void> {
    try {
      await this.table.insert({
        visitor_id: record.visitorId,
        profile_id: record.profileId,
        profile_version: record.profileVersion,
        tenant_id: record.tenantId ?? 'default',
        consent_json: record.consentJson,
        source: record.source,
        gpc_detected: record.gpcDetected ?? false,
        created_at: record.createdAt,
      })
    } catch (err) {
      console.warn('[consenti:bigquery] Insert failed:', err)
    }
  }
}