52:I[707087,["/_next/static/immutable/chunks/3arlv5bvukoo2.js","/_next/static/immutable/chunks/39v64hmfyo-sr.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/04j_o97cgxn2x.js","/_next/static/immutable/chunks/3upr08c9vtj8w.js","/_next/static/immutable/chunks/1ww0328si-u8x.js","/_next/static/immutable/chunks/11mfl5ymqld9-.js","/_next/static/immutable/chunks/2xxcqy6ppds3l.js","/_next/static/immutable/chunks/3j06ow7w40nxu.js","/_next/static/immutable/chunks/31nn7jwsjvqii.js","/_next/static/immutable/chunks/43_s7jweyypoh.js","/_next/static/immutable/chunks/0p6vao205o1jc.js","/_next/static/immutable/chunks/1_kyvgkyokw92.js","/_next/static/immutable/chunks/1lo-zn37dolb5.js","/_next/static/immutable/chunks/1v8k6yxw1rg0u.js"],"RegistryDependencies"] 53:I[314491,["/_next/static/immutable/chunks/3arlv5bvukoo2.js","/_next/static/immutable/chunks/39v64hmfyo-sr.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/04j_o97cgxn2x.js","/_next/static/immutable/chunks/3upr08c9vtj8w.js","/_next/static/immutable/chunks/1ww0328si-u8x.js","/_next/static/immutable/chunks/11mfl5ymqld9-.js","/_next/static/immutable/chunks/2xxcqy6ppds3l.js","/_next/static/immutable/chunks/3j06ow7w40nxu.js","/_next/static/immutable/chunks/31nn7jwsjvqii.js","/_next/static/immutable/chunks/43_s7jweyypoh.js","/_next/static/immutable/chunks/0p6vao205o1jc.js","/_next/static/immutable/chunks/1_kyvgkyokw92.js","/_next/static/immutable/chunks/1lo-zn37dolb5.js","/_next/static/immutable/chunks/1v8k6yxw1rg0u.js"],"FilesView"] 54: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() } } 51:["$","div",null,{"className":"mt-3 flex min-h-0 min-w-0 flex-1 flex-col gap-3","children":[["$","div",null,{"className":"flex shrink-0 items-start gap-3","children":[["$","div",null,{"className":"flex max-h-28 min-w-0 flex-1 flex-wrap items-center gap-2 overflow-y-auto","children":[["$","ul",null,{"className":"flex min-w-0 flex-wrap gap-2","aria-label":"Package dependencies","children":[["$","li","mysql2",{"className":"min-w-0 max-w-full","children":["$","a",null,{"href":"https://www.npmjs.com/package/mysql2","target":"_blank","rel":"noopener noreferrer","className":"flex max-w-full min-w-0 items-center gap-1.5 rounded-md border px-2 py-1.5 text-xs","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3 shrink-0","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":"min-w-0 break-all text-xs font-medium","children":"mysql2"}]]}]}],["$","li","@types/mysql2",{"className":"min-w-0 max-w-full","children":["$","a",null,{"href":"https://www.npmjs.com/package/%40types%2Fmysql2","target":"_blank","rel":"noopener noreferrer","className":"flex max-w-full min-w-0 items-center gap-1.5 rounded-md border px-2 py-1.5 text-xs","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3 shrink-0","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":"min-w-0 break-all text-xs font-medium","children":"@types/mysql2"}]]}]}]]}],["$","$L52",null,{"namespace":"@ramonclaudio-coderabbit","registryDependencies":["https://coderabbit-shadcn-registry.vercel.app/r/types.json","https://coderabbit-shadcn-registry.vercel.app/r/storage-adapter.json"]}]]}],null]}],["$","$L53",null,{"files":[{"path":"registry/default/lib/storage-mysql.ts","content":"$54","type":"registry:lib"}],"className":"h-[70svh] min-h-80"}]]}]