50:I[707087,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"RegistryDependencies"] 51:I[512940,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"Installation"] 52:I[314491,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"FilesView"] 53:T1c95,import type { ReportStorageAdapter, ListReportsResponse, } from '@/registry/default/lib/storage-adapter' import type { StoredReport, ReportStatus, ReportResult, FilterConfig, } from '@/registry/default/lib/types' import type { Pool } from 'pg' export interface PostgresStorageConfig { pool: Pool tableName?: string } /** * Database row type matching the PostgreSQL schema (snake_case columns) */ interface DatabaseReportRow { id: string status: ReportStatus from_date: string to_date: string prompt_template: string | null custom_prompt: string | null group_by: string | null subgroup_by: string | null org_id: string | null parameters: FilterConfig[] | null results: ReportResult[] | null error: string | null duration_ms: number | null created_at: Date user_id: string | null } interface CountRow { count: string } /** * PostgreSQL storage adapter for CodeRabbit reports * * @example * ```typescript * import { Pool } from 'pg' * import { PostgresStorageAdapter } from '@/registry/default/lib/storage-postgres' * * const pool = new Pool({ * host: process.env.POSTGRES_HOST, * port: parseInt(process.env.POSTGRES_PORT || '5432'), * database: process.env.POSTGRES_DATABASE, * user: process.env.POSTGRES_USER, * password: process.env.POSTGRES_PASSWORD, * }) * * const storage = new PostgresStorageAdapter({ pool }) * ``` * * Database schema: * ```sql * CREATE TABLE coderabbit_reports ( * id UUID PRIMARY KEY DEFAULT gen_random_uuid(), * status VARCHAR(20) NOT NULL CHECK (status IN ('pending', 'completed', 'failed')), * from_date VARCHAR(255) NOT NULL, * to_date VARCHAR(255) NOT NULL, * prompt_template VARCHAR(255), * custom_prompt TEXT, * group_by VARCHAR(50), * subgroup_by VARCHAR(50), * org_id VARCHAR(255), * parameters JSONB DEFAULT '[]'::jsonb, * results JSONB, * error TEXT, * duration_ms INTEGER, * created_at TIMESTAMPTZ DEFAULT NOW(), * user_id VARCHAR(255) * ); * * -- Indexes for better performance * CREATE INDEX idx_reports_status ON coderabbit_reports(status); * CREATE INDEX idx_reports_user_id ON coderabbit_reports(user_id); * CREATE INDEX idx_reports_created_at ON coderabbit_reports(created_at DESC); * ``` */ export class PostgresStorageAdapter implements ReportStorageAdapter { private pool: Pool private tableName: string constructor(config: PostgresStorageConfig) { this.pool = config.pool this.tableName = config.tableName || 'coderabbit_reports' } async create(data: Omit): Promise { const query = ` INSERT INTO ${this.tableName} ( status, from_date, to_date, prompt_template, custom_prompt, group_by, subgroup_by, org_id, parameters, results, error, duration_ms ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) RETURNING id ` const values = [ data.status, data.fromDate, data.toDate, data.promptTemplate, data.customPrompt, data.groupBy, data.subgroupBy, data.orgId, JSON.stringify(data.parameters || []), data.results ? JSON.stringify(data.results) : null, data.error, data.durationMs, ] try { const result = await this.pool.query<{ id: string }>(query, values) return result.rows[0].id } catch (error) { throw new Error( `Failed to create report: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } async updateSuccess( id: string, results: ReportResult[], durationMs: number ): Promise { const query = ` UPDATE ${this.tableName} SET status = $1, results = $2, duration_ms = $3 WHERE id = $4 ` const values = ['completed', JSON.stringify(results), durationMs, id] try { await this.pool.query(query, values) } catch (error) { throw new Error( `Failed to update report: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } async updateFailure( id: string, errorMessage: string, durationMs: number ): Promise { const query = ` UPDATE ${this.tableName} SET status = $1, error = $2, duration_ms = $3 WHERE id = $4 ` const values = ['failed', errorMessage, durationMs, id] try { await this.pool.query(query, values) } catch (error) { throw new Error( `Failed to update report: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } async get(id: string): Promise { const query = `SELECT * FROM ${this.tableName} WHERE id = $1` try { const result = await this.pool.query(query, [id]) if (result.rows.length === 0) { return null } return this.mapToStoredReport(result.rows[0]) } catch (error) { throw new Error( `Failed to get report: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } async list(options?: { limit?: number offset?: number status?: ReportStatus }): Promise { const limit = options?.limit || 10 const offset = options?.offset || 0 // Build query with optional status filter let query = `SELECT * FROM ${this.tableName}` let countQuery = `SELECT COUNT(*) FROM ${this.tableName}` const values: (string | number)[] = [] if (options?.status) { query += ' WHERE status = $1' countQuery += ' WHERE status = $1' values.push(options.status) } query += ' ORDER BY created_at DESC LIMIT $' + (values.length + 1) + ' OFFSET $' + (values.length + 2) values.push(limit, offset) try { const [dataResult, countResult] = await Promise.all([ this.pool.query(query, values), this.pool.query(countQuery, options?.status ? [options.status] : []), ]) return { reports: dataResult.rows.map((row) => this.mapToStoredReport(row)), total: parseInt(countResult.rows[0].count), } } catch (error) { throw new Error( `Failed to list reports: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } async delete(id: string): Promise { const query = `DELETE FROM ${this.tableName} WHERE id = $1` try { await this.pool.query(query, [id]) } catch (error) { throw new Error( `Failed to delete report: ${error instanceof Error ? error.message : 'Unknown error'}` ) } } private mapToStoredReport(row: DatabaseReportRow): StoredReport { return { id: row.id, status: row.status, fromDate: row.from_date, toDate: row.to_date, promptTemplate: row.prompt_template, customPrompt: row.custom_prompt, groupBy: row.group_by, subgroupBy: row.subgroup_by, orgId: row.org_id, parameters: row.parameters || [], results: row.results, error: row.error, durationMs: row.duration_ms, createdAt: new Date(row.created_at).getTime(), } } /** * Close the database pool * Call this when your application is shutting down */ async close(): Promise { await this.pool.end() } } 4c:["$","div",null,{"className":"flex flex-col gap-12","children":[["$","div",null,{"className":"pt-10 flex flex-col gap-4","children":[["$","ul",null,{"className":"flex gap-2 flex-wrap","children":[["$","li","pg",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/pg","target":"_blank","rel":"noopener noreferrer","className":"rounded-md border p-2 text-sm flex items-center gap-1 ","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"text-xs font-medium","children":"pg"}]]}]}],["$","li","@types/pg",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/%40types%2Fpg","target":"_blank","rel":"noopener noreferrer","className":"rounded-md border p-2 text-sm flex items-center gap-1 ","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"text-xs font-medium","children":"@types/pg"}]]}]}]]}],["$","$L50",null,{"registryDependencies":["https://coderabbit-shadcn-registry.vercel.app/r/types.json","https://coderabbit-shadcn-registry.vercel.app/r/storage-adapter.json"]}]]}],["$","$L51",null,{"sourceUrl":"https://coderabbit-shadcn-registry.vercel.app/r/storage-postgres.json","proxyUrl":"https://shadcnregistry.com/r/ramonclaudio-coderabbit/storage-postgres","itemId":"@ramonclaudio-coderabbit/storage-postgres"}],["$","section",null,{"className":"flex flex-col gap-4","id":"files","children":[["$","h2",null,{"className":"text-lg md:text-2xl font-bold font-mono","children":"Files"}],["$","$L52",null,{"files":[{"path":"registry/default/lib/storage-postgres.ts","content":"$53","type":"registry:lib"}]}]]}],"$L54"]}]

CodeRabbit PostgreSQL Adapter

Installation

Files

lib

Styles