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:T1cf7,import type { ReportStorageAdapter, ListReportsResponse, } from '@/registry/default/lib/storage-adapter' import type { StoredReport, ReportStatus, ReportResult, FilterConfig, } from '@/registry/default/lib/types' import type { Pool, RowDataPacket } from 'mysql2/promise' export interface MySQLStorageConfig { pool: Pool tableName?: string } /** * Database row type matching the MySQL schema (snake_case columns) */ interface DatabaseReportRow extends RowDataPacket { 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 extends RowDataPacket { count: number } /** * MySQL storage adapter for CodeRabbit reports * * @example * ```typescript * import mysql from 'mysql2/promise' * import { MySQLStorageAdapter } from '@/registry/default/lib/storage-mysql' * * const pool = mysql.createPool({ * host: process.env.MYSQL_HOST, * port: parseInt(process.env.MYSQL_PORT || '3306'), * database: process.env.MYSQL_DATABASE, * user: process.env.MYSQL_USER, * password: process.env.MYSQL_PASSWORD, * waitForConnections: true, * connectionLimit: 10, * queueLimit: 0 * }) * * const storage = new MySQLStorageAdapter({ pool }) * ``` * * Database schema: * ```sql * CREATE TABLE coderabbit_reports ( * id CHAR(36) PRIMARY KEY DEFAULT (UUID()), * status ENUM('pending', 'completed', 'failed') NOT NULL, * 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 JSON, * results JSON, * error TEXT, * duration_ms INT, * created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, * user_id VARCHAR(255), * INDEX idx_status (status), * INDEX idx_user_id (user_id), * INDEX idx_created_at (created_at DESC) * ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; * ``` */ export class MySQLStorageAdapter implements ReportStorageAdapter { private pool: Pool private tableName: string constructor(config: MySQLStorageConfig) { this.pool = config.pool this.tableName = config.tableName || 'coderabbit_reports' } async create(data: Omit): Promise { const query = ` INSERT INTO ${this.tableName} ( id, status, from_date, to_date, prompt_template, custom_prompt, group_by, subgroup_by, org_id, parameters, results, error, duration_ms ) VALUES (UUID(), ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ` 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 { await this.pool.execute(query, values) // For MySQL, we need to fetch the last inserted ID differently const [idRows] = await this.pool.execute( `SELECT id FROM ${this.tableName} ORDER BY created_at DESC LIMIT 1` ) return idRows[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 = ?, results = ?, duration_ms = ? WHERE id = ? ` const values = ['completed', JSON.stringify(results), durationMs, id] try { await this.pool.execute(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 = ?, error = ?, duration_ms = ? WHERE id = ? ` const values = ['failed', errorMessage, durationMs, id] try { await this.pool.execute(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 = ?` try { const [rows] = await this.pool.execute(query, [id]) if (rows.length === 0) { return null } return this.mapToStoredReport(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(*) as count FROM ${this.tableName}` const values: (string | number)[] = [] if (options?.status) { query += ' WHERE status = ?' countQuery += ' WHERE status = ?' values.push(options.status) } query += ' ORDER BY created_at DESC LIMIT ? OFFSET ?' const queryValues = [...values, limit, offset] const countValues = values try { const [dataRows] = await this.pool.execute(query, queryValues) const [countRows] = await this.pool.execute(countQuery, countValues) return { reports: dataRows.map((row) => this.mapToStoredReport(row)), total: countRows[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 = ?` try { await this.pool.execute(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","mysql2",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/mysql2","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":"mysql2"}]]}]}],["$","li","@types/mysql2",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/%40types%2Fmysql2","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/mysql2"}]]}]}]]}],["$","$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-mysql.json","proxyUrl":"https://shadcnregistry.com/r/ramonclaudio-coderabbit/storage-mysql","itemId":"@ramonclaudio-coderabbit/storage-mysql"}],["$","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-mysql.ts","content":"$53","type":"registry:lib"}]}]]}],"$L54"]}]

CodeRabbit MySQL Adapter

Installation

Files

lib

Styles