- {getStatusIcon(row.status)}
-
- ),
- },
- {
- field: 'component' as keyof HealthStatus,
- header: 'Component',
- type: ColumnType.TEXT,
- renderCell: (value: unknown, row: HealthStatus) => (
- {row.component}
- ),
- },
- {
- field: 'lastSync' as keyof HealthStatus,
- header: 'Last Sync',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) => (
-
-
- ),
- },
- {
- field: 'syncRate' as keyof HealthStatus,
- header: 'Success Rate',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) => (
-
-
- {children}
-
-
-
- )
-}
diff --git a/apps/blend-monitor/app/login/page.tsx b/apps/blend-monitor/app/login/page.tsx
deleted file mode 100644
index 2a97f1b9c..000000000
--- a/apps/blend-monitor/app/login/page.tsx
+++ /dev/null
@@ -1,162 +0,0 @@
-'use client'
-
-import React, { useEffect, useState } from 'react'
-import { useAuth } from '@/frontend/contexts/AuthContext'
-import { useRouter } from 'next/navigation'
-import { Button, ButtonType, ButtonSize } from '@juspay/blend-design-system'
-import { Zap, AlertCircle } from 'lucide-react'
-import Loader from '@/frontend/components/shared/Loader'
-
-export default function LoginPage() {
- const { user, loading, signInWithGoogle } = useAuth()
- const router = useRouter()
- const [error, setError] = useState(null)
- const [isSigningIn, setIsSigningIn] = useState(false)
- const [isRedirecting, setIsRedirecting] = useState(false)
-
- useEffect(() => {
- if (!loading && user) {
- setIsRedirecting(true)
- router.push('/')
- }
- }, [user, loading, router])
-
- const handleGoogleSignIn = async () => {
- setError(null)
- setIsSigningIn(true)
- try {
- await signInWithGoogle()
- // Show redirecting state after successful sign in
- setIsRedirecting(true)
- } catch (error) {
- setError(
- error instanceof Error
- ? error.message
- : 'Failed to sign in with Google'
- )
- setIsSigningIn(false)
- }
- }
-
- if (loading || isRedirecting) {
- return (
-
-}) {
- return (
-
-}
-
-interface UserData {
- uid: string
- email: string
- displayName?: string
- photoURL?: string
- role?: string
-}
-
-// Mock services
-const activityService = {
- // eslint-disable-next-line @typescript-eslint/no-unused-vars
- getUserActivity: async (_uid: string) => [],
- subscribeToUserActivity:
- // eslint-disable-next-line @typescript-eslint/no-unused-vars
- (_uid: string, _callback: (activities: ActivityLog[]) => void) =>
- () => {},
- formatActivityMessage: (
- action: string,
- // eslint-disable-next-line @typescript-eslint/no-unused-vars
- _details?: Record
- ) => `Activity: ${action}`,
-}
-
-const roleService = {
- // eslint-disable-next-line @typescript-eslint/no-unused-vars
- getUserData: async (_uid: string): Promise => null,
-}
-
-export default function UserActivityPage() {
- return (
-
-
- )
-}
-
-function UserActivity() {
- const params = useParams()
- const router = useRouter()
- const userId = params.userId as string
-
- const [activities, setActivities] = useState([])
- const [userData, setUserData] = useState(null)
- const [loading, setLoading] = useState(true)
- const [error, setError] = useState(null)
- const { canManageUsers } = usePermissions()
-
- // Check if user can view this activity
- const canViewActivity = userId === auth.currentUser?.uid || canManageUsers
-
- useEffect(() => {
- if (!canViewActivity) {
- setError("You do not have permission to view this user's activity")
- setLoading(false)
- return
- }
-
- const loadUserData = async () => {
- try {
- const data = await roleService.getUserData(userId)
- setUserData(data)
- } catch (error) {
- console.error('Error loading user data:', error)
- }
- }
-
- loadUserData()
-
- // Subscribe to real-time activity updates
- const unsubscribe = activityService.subscribeToUserActivity(
- userId,
- (activities: ActivityLog[]) => {
- setActivities(activities)
- setLoading(false)
- }
- )
-
- return () => unsubscribe()
- }, [userId, canViewActivity])
-
- const formatTimestamp = (timestamp: string) => {
- const date = new Date(timestamp)
- const now = new Date()
- const diffMs = now.getTime() - date.getTime()
- const diffMins = Math.floor(diffMs / 60000)
- const diffHours = Math.floor(diffMs / 3600000)
- const diffDays = Math.floor(diffMs / 86400000)
-
- if (diffMins < 1) return 'Just now'
- if (diffMins < 60)
- return `${diffMins} minute${diffMins > 1 ? 's' : ''} ago`
- if (diffHours < 24)
- return `${diffHours} hour${diffHours > 1 ? 's' : ''} ago`
- if (diffDays < 7) return `${diffDays} day${diffDays > 1 ? 's' : ''} ago`
-
- return date.toLocaleDateString('en-US', {
- year: 'numeric',
- month: 'short',
- day: 'numeric',
- hour: '2-digit',
- minute: '2-digit',
- })
- }
-
- const getActivityIcon = (action: string) => {
- switch (action) {
- case 'user_login':
- case 'user_logout':
- return (null)
- const [loading, setLoading] = useState(true)
- const router = useRouter()
-
- useEffect(() => {
- const unsubscribe = onAuthStateChanged(auth, (user) => {
- if (user) {
- setUser(user)
- } else {
- router.push('/login')
- }
- setLoading(false)
- })
-
- return () => unsubscribe()
- }, [router])
-
- if (loading) {
- return (
-
-
- )
-}
-
-function UserManagement() {
- const router = useRouter()
- const [showInviteModal, setShowInviteModal] = useState(false)
- const [inviteEmail, setInviteEmail] = useState('')
- const [inviteRole, setInviteRole] = useState('viewer')
- const [inviting, setInviting] = useState(false)
- const [emailError, setEmailError] = useState('')
- const { canManageUsers } = usePermissions()
-
- // Use PostgreSQL user management hooks
- const { users, loading, updateUserRole, updateUserStatus, createUser } =
- useUserManagement()
-
- const handleRoleChange = async (userId: string, newRole: string) => {
- if (!canManageUsers) return
-
- try {
- await updateUserRole(userId, newRole)
- console.log(`Updated user ${userId} role to ${newRole}`)
- } catch (error) {
- console.error('Error updating user role:', error)
- alert('Failed to update role')
- }
- }
-
- const handleStatusChange = async (userId: string, isActive: boolean) => {
- if (!canManageUsers) return
-
- try {
- await updateUserStatus(userId, isActive)
- console.log(
- `Updated user ${userId} status to ${isActive ? 'active' : 'inactive'}`
- )
- } catch (error) {
- console.error('Error updating user status:', error)
- alert('Failed to update user status')
- }
- }
-
- const validateEmail = (email: string): boolean => {
- const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/
-
- if (!emailRegex.test(email)) {
- setEmailError('Please enter a valid email address')
- return false
- }
-
- const existingUser = users.find(
- (u: UserData) => u.email.toLowerCase() === email.toLowerCase()
- )
- if (existingUser) {
- setEmailError('This user already exists in the system')
- return false
- }
-
- setEmailError('')
- return true
- }
-
- const handleEmailChange = (e: React.ChangeEvent) => {
- const email = e.target.value
- setInviteEmail(email)
-
- if (email && !validateEmail(email)) {
- // Validate as user types
- }
- }
-
- const handleInviteUser = async () => {
- if (!canManageUsers || !inviteEmail) return
-
- if (!validateEmail(inviteEmail)) {
- return
- }
-
- setInviting(true)
- try {
- await createUser({
- firebase_uid: `invite_${Date.now()}`, // Temporary UID for invited users
- email: inviteEmail,
- display_name: inviteEmail.split('@')[0],
- role: inviteRole,
- })
-
- // Reset form
- setInviteEmail('')
- setInviteRole('viewer')
- setEmailError('')
- setShowInviteModal(false)
-
- console.log(`User ${inviteEmail} invited with role: ${inviteRole}`)
- } catch (error) {
- console.error('Error inviting user:', error)
- setEmailError('Failed to invite user')
- } finally {
- setInviting(false)
- }
- }
-
- const formatDate = (dateString: string) => {
- if (dateString === 'Never' || !dateString) {
- return 'Not logged in yet'
- }
- return new Date(dateString).toLocaleDateString('en-US', {
- year: 'numeric',
- month: 'short',
- day: 'numeric',
- hour: '2-digit',
- minute: '2-digit',
- })
- }
-
- const getRoleBadgeColor = (role: string) => {
- switch (role) {
- case 'admin':
- return 'bg-red-100 text-red-800 border-red-200'
- case 'developer':
- return 'bg-blue-100 text-blue-800 border-blue-200'
- case 'viewer':
- return 'bg-gray-100 text-gray-800 border-gray-200'
- default:
- return 'bg-gray-100 text-gray-800 border-gray-200'
- }
- }
-
- // Define columns for DataTable
- const columns: ColumnDefinition[] = [
- {
- field: 'display_name' as keyof UserData,
- header: 'User',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: UserData) => (
-
- versions: Record<
- string,
- {
- name: string
- version: string
- description?: string
- dist?: {
- unpackedSize?: number
- fileCount?: number
- size?: number
- }
- dependencies?: Record
- _npmUser?: {
- name: string
- }
- }
- >
- time: Record
-}
-
-export class NPMClient {
- private registryUrl: string
- private packageName: string
-
- constructor(packageName: string = '@juspay/blend-design-system') {
- this.registryUrl =
- process.env.NPM_REGISTRY_API_URL || 'https://registry.npmjs.org'
- this.packageName = packageName
- }
-
- async getPackageStats(): Promise {
- try {
- // Fetch package metadata
- const packageData = await this.fetchPackageData()
-
- // Fetch download stats
- const downloadStats = await this.fetchDownloadStats()
-
- if (!packageData || !downloadStats) {
- return null
- }
-
- const latestVersion = packageData['dist-tags']?.latest || ''
- const versionData = packageData.versions?.[latestVersion]
-
- return {
- name: this.packageName,
- version: latestVersion,
- downloads: {
- daily: downloadStats.daily || 0,
- weekly: downloadStats.weekly || 0,
- monthly: downloadStats.monthly || 0,
- total: downloadStats.total || 0,
- },
- size: {
- unpacked: versionData?.dist?.unpackedSize || 0,
- gzipped: versionData?.dist?.fileCount || 0,
- },
- dependencies: Object.keys(versionData?.dependencies || {})
- .length,
- lastPublish: packageData.time?.[latestVersion] || '',
- }
- } catch (error) {
- console.error('Error fetching package stats:', error)
- return null
- }
- }
-
- async getVersionHistory(): Promise {
- try {
- const packageData = await this.fetchPackageData()
-
- if (!packageData || !packageData.versions) {
- return []
- }
-
- const versions: VersionInfo[] = []
- const versionNumbers = Object.keys(packageData.versions).reverse() // Latest first
-
- for (const version of versionNumbers.slice(0, 20)) {
- // Last 20 versions
- const versionData = packageData.versions[version]
- const publishTime = packageData.time?.[version]
-
- versions.push({
- version,
- publishedAt: publishTime || '',
- publisher: versionData._npmUser?.name || 'unknown',
- downloads: 0, // Will be updated with actual download count
- changelog: this.extractChangelog(versionData),
- size: {
- unpacked: versionData.dist?.unpackedSize || 0,
- gzipped: versionData.dist?.size || 0,
- },
- breaking: this.isBreakingChange(version),
- })
- }
-
- // Fetch download counts for each version
- await this.enrichVersionDownloads(versions)
-
- return versions
- } catch (error) {
- console.error('Error fetching version history:', error)
- return []
- }
- }
-
- async getDownloadTrends(days: number = 30): Promise {
- try {
- const endDate = new Date()
- const startDate = new Date()
- startDate.setDate(startDate.getDate() - days)
-
- const start = startDate.toISOString().split('T')[0]
- const end = endDate.toISOString().split('T')[0]
-
- const response = await fetch(
- `https://api.npmjs.org/downloads/range/${start}:${end}/${this.packageName}`
- )
-
- if (!response.ok) {
- throw new Error('Failed to fetch download trends')
- }
-
- const data = await response.json()
-
- return data.downloads.map(
- (item: { day: string; downloads: number }) => ({
- date: item.day,
- downloads: item.downloads,
- })
- )
- } catch (error) {
- console.error('Error fetching download trends:', error)
- return []
- }
- }
-
- private async fetchPackageData(): Promise {
- try {
- const response = await fetch(
- `${this.registryUrl}/${this.packageName}`
- )
-
- if (!response.ok) {
- throw new Error('Failed to fetch package data')
- }
-
- return await response.json()
- } catch (error) {
- console.error('Error fetching package data:', error)
- return null
- }
- }
-
- private async fetchDownloadStats(): Promise<{
- daily: number
- weekly: number
- monthly: number
- total: number
- }> {
- try {
- // Fetch different time ranges
- const [daily, weekly, monthly] = await Promise.all([
- this.fetchDownloadCount('last-day'),
- this.fetchDownloadCount('last-week'),
- this.fetchDownloadCount('last-month'),
- ])
-
- // Fetch total downloads (point count)
- const totalResponse = await fetch(
- `https://api.npmjs.org/downloads/point/2015-01-01:${new Date().toISOString().split('T')[0]}/${this.packageName}`
- )
-
- const totalData = totalResponse.ok
- ? await totalResponse.json()
- : { downloads: 0 }
-
- return {
- daily: daily?.downloads || 0,
- weekly: weekly?.downloads || 0,
- monthly: monthly?.downloads || 0,
- total: totalData?.downloads || 0,
- }
- } catch (error) {
- console.error('Error fetching download stats:', error)
- return {
- daily: 0,
- weekly: 0,
- monthly: 0,
- total: 0,
- }
- }
- }
-
- private async fetchDownloadCount(
- period: string
- ): Promise<{ downloads: number }> {
- try {
- const response = await fetch(
- `https://api.npmjs.org/downloads/point/${period}/${this.packageName}`
- )
-
- if (!response.ok) {
- return { downloads: 0 }
- }
-
- return await response.json()
- } catch (error) {
- console.error(`Error fetching ${period} downloads:`, error)
- return { downloads: 0 }
- }
- }
-
- private async enrichVersionDownloads(
- versions: VersionInfo[]
- ): Promise {
- // NPM doesn't provide per-version download stats easily
- // We'll estimate based on publish dates and total downloads
- // This is a simplified approach
-
- const totalDownloads = await this.fetchDownloadStats()
- const totalCount = totalDownloads.total || 0
-
- // Distribute downloads based on version age (newer versions get more downloads)
- let remainingDownloads = totalCount
- const now = new Date().getTime()
-
- versions.forEach((version) => {
- const publishDate = new Date(version.publishedAt).getTime()
- const ageInDays = (now - publishDate) / (1000 * 60 * 60 * 24)
-
- // Estimate downloads (newer versions get more)
- const weight = Math.max(1, 100 - ageInDays)
- const estimatedDownloads = Math.floor(
- remainingDownloads * (weight / 100)
- )
-
- version.downloads = Math.max(estimatedDownloads, 10) // Minimum 10 downloads
- remainingDownloads -= version.downloads
- })
- }
-
- private extractChangelog(versionData: { description?: string }): string {
- // Try to extract changelog from package.json or README
- // This is a placeholder - in real implementation, you might parse CHANGELOG.md
- return versionData.description || 'No changelog available'
- }
-
- private isBreakingChange(version: string): boolean {
- // Check if it's a major version change
- const parts = version.split('.')
- const major = parseInt(parts[0], 10)
- return major > 0 && parts[1] === '0' && parts[2] === '0'
- }
-
- // Get package size history
- async getPackageSizeHistory(): Promise<
- Array<{ version: string; size: number; date: string }>
- > {
- try {
- const packageData = await this.fetchPackageData()
-
- if (!packageData || !packageData.versions) {
- return []
- }
-
- const sizeHistory: Array<{
- version: string
- size: number
- date: string
- }> = []
- const versions = Object.keys(packageData.versions)
- .reverse()
- .slice(0, 10)
-
- for (const version of versions) {
- const versionData = packageData.versions[version]
- const publishTime = packageData.time?.[version]
-
- sizeHistory.push({
- version,
- size: versionData.dist?.unpackedSize || 0,
- date: publishTime || '',
- })
- }
-
- return sizeHistory
- } catch (error) {
- console.error('Error fetching package size history:', error)
- return []
- }
- }
-}
diff --git a/apps/blend-monitor/src/backend/lib/auth-middleware.ts b/apps/blend-monitor/src/backend/lib/auth-middleware.ts
deleted file mode 100644
index 45b4dcd86..000000000
--- a/apps/blend-monitor/src/backend/lib/auth-middleware.ts
+++ /dev/null
@@ -1,109 +0,0 @@
-import { NextRequest } from 'next/server'
-import { getAdminAuth } from './firebase-admin'
-import { roleService } from './role-service'
-
-export interface AuthenticatedUser {
- uid: string
- email: string
- role: string
- permissions: Record
-}
-
-export async function authenticateRequest(
- request: NextRequest
-): Promise {
- try {
- const authHeader = request.headers.get('authorization')
- if (!authHeader || !authHeader.startsWith('Bearer ')) {
- return null
- }
-
- const token = authHeader.substring(7)
- const adminAuth = getAdminAuth()
-
- // Verify the Firebase token
- const decodedToken = await adminAuth.verifyIdToken(token)
-
- // Get user role and permissions
- const userRole = await roleService.getUserRole(decodedToken.uid)
- if (!userRole) {
- return null
- }
-
- return {
- uid: decodedToken.uid,
- email: decodedToken.email || '',
- role: userRole.id,
- permissions: userRole.permissions,
- }
- } catch (error) {
- console.error('Authentication error:', error)
- return null
- }
-}
-
-export function hasPermission(
- user: AuthenticatedUser,
- resource: string,
- action: string
-): boolean {
- const resourcePermissions = user.permissions[resource]
- if (!resourcePermissions) return false
-
- return resourcePermissions.includes(action)
-}
-
-export function requirePermission(resource: string, action: string) {
- return async (request: NextRequest, user: AuthenticatedUser | null) => {
- if (!user) {
- return new Response(
- JSON.stringify({ error: 'Authentication required' }),
- { status: 401, headers: { 'Content-Type': 'application/json' } }
- )
- }
-
- if (!hasPermission(user, resource, action)) {
- return new Response(
- JSON.stringify({
- error: `Insufficient permissions. Required: ${resource}:${action}`,
- userRole: user.role,
- requiredPermission: `${resource}:${action}`,
- }),
- { status: 403, headers: { 'Content-Type': 'application/json' } }
- )
- }
-
- return null // No error, permission granted
- }
-}
-
-// Audit logging for sensitive actions
-export async function logAuditEvent(
- user: AuthenticatedUser,
- action: string,
- resource: string,
- details: Record = {},
- result: 'success' | 'failed' = 'success'
-) {
- try {
- const auditLog = {
- id: `${Date.now()}-${Math.random().toString(36).substr(2, 9)}`,
- action,
- user: user.email,
- timestamp: new Date().toISOString(),
- details,
- result,
- resource,
- }
-
- // In a real implementation, you would save this to your database
- console.log('Audit Log:', auditLog)
-
- // You could also save to Firebase Realtime Database
- // const { getAdminDatabase } = require('./firebase-admin')
- // const db = getAdminDatabase()
- // await db.ref(`audit-logs/${auditLog.id}`).set(auditLog)
- } catch (error) {
- console.error('Failed to log audit event:', error)
- }
-}
diff --git a/apps/blend-monitor/src/backend/lib/database-service.ts b/apps/blend-monitor/src/backend/lib/database-service.ts
deleted file mode 100644
index 385a6b9b1..000000000
--- a/apps/blend-monitor/src/backend/lib/database-service.ts
+++ /dev/null
@@ -1,689 +0,0 @@
-import {
- query,
- withTransaction,
- SQL,
- DatabaseUser,
- DatabaseComponent,
- DatabaseActivityLog,
-} from './database'
-import {
- ComponentInfo,
- CoverageMetrics,
- PackageStats,
- Activity,
- UserRole,
- VersionInfo,
-} from '@/shared/types'
-
-export class DatabaseService {
- // ==================== USER MANAGEMENT ====================
-
- async createOrUpdateUser(
- firebaseUid: string,
- userData: {
- email: string
- displayName?: string
- photoURL?: string
- role?: string
- }
- ): Promise {
- // Check if user exists
- const existingUser = await this.getUserByFirebaseUid(firebaseUid)
-
- if (existingUser) {
- // Update existing user
- const result = await query(SQL.users.update, [
- firebaseUid,
- userData.displayName,
- userData.photoURL,
- new Date(),
- ])
- return result.rows[0]
- } else {
- // Create new user
- const result = await query(SQL.users.create, [
- firebaseUid,
- userData.email,
- userData.displayName,
- userData.photoURL,
- userData.role || 'viewer',
- new Date(),
- ])
- return result.rows[0]
- }
- }
-
- async getUserByFirebaseUid(
- firebaseUid: string
- ): Promise {
- const result = await query(SQL.users.findByFirebaseUid, [
- firebaseUid,
- ])
- return result.rows[0] || null
- }
-
- async getUserByEmail(email: string): Promise {
- const result = await query(SQL.users.findByEmail, [email])
- return result.rows[0] || null
- }
-
- // User management methods
- async getAllUsers(limit?: number, offset?: number) {
- const limitClause = limit ? `LIMIT ${limit}` : ''
- const offsetClause = offset ? `OFFSET ${offset}` : ''
-
- const queryText = `
- SELECT
- id, firebase_uid, email, display_name, photo_url,
- role, is_active, created_at, last_login, updated_at
- FROM users
- ORDER BY created_at DESC
- ${limitClause} ${offsetClause}
- `
-
- const result = await query(queryText)
- return result.rows.map(this.mapUserRow)
- }
-
- async updateUserStatus(firebaseUid: string, isActive: boolean) {
- const queryText = `
- UPDATE users
- SET is_active = $1, updated_at = NOW()
- WHERE firebase_uid = $2
- RETURNING id, firebase_uid, email, display_name, photo_url,
- role, is_active, created_at, last_login, updated_at
- `
-
- const result = await query(queryText, [
- isActive,
- firebaseUid,
- ])
- return result.rows.length > 0 ? this.mapUserRow(result.rows[0]) : null
- }
-
- async updateUserDisplayName(firebaseUid: string, displayName: string) {
- const queryText = `
- UPDATE users
- SET display_name = $1, updated_at = NOW()
- WHERE firebase_uid = $2
- RETURNING id, firebase_uid, email, display_name, photo_url,
- role, is_active, created_at, last_login, updated_at
- `
-
- const result = await query(queryText, [
- displayName,
- firebaseUid,
- ])
- return result.rows.length > 0 ? this.mapUserRow(result.rows[0]) : null
- }
-
- async deleteUser(firebaseUid: string) {
- const queryText = `DELETE FROM users WHERE firebase_uid = $1`
- await query(queryText, [firebaseUid])
- }
-
- async updateUserRole(
- userId: string,
- newRole: string
- ): Promise {
- const result = await query(SQL.users.updateRole, [
- userId,
- newRole,
- ])
- return result.rows[0]
- }
-
- async getRoles(): Promise {
- const result = await query('SELECT * FROM roles ORDER BY name')
- return result.rows.map((row) => ({
- id: row.id,
- name: row.name,
- permissions: row.permissions,
- isCustom: row.is_custom,
- }))
- }
-
- // ==================== COMPONENT MANAGEMENT ====================
-
- async getComponents(): Promise {
- const result = await query(SQL.components.list)
- return result.rows.map(this.mapDatabaseComponentToInfo)
- }
-
- async getComponentById(componentId: string): Promise {
- const result = await query(SQL.components.findById, [
- componentId,
- ])
- return result.rows[0]
- ? this.mapDatabaseComponentToInfo(result.rows[0])
- : null
- }
-
- async upsertComponent(component: ComponentInfo): Promise {
- await query(SQL.components.upsert, [
- component.id,
- component.name,
- component.path,
- component.category,
- component.hasStorybook,
- component.hasFigmaConnect,
- component.hasTests,
- component.lastModified ? new Date(component.lastModified) : null,
- ])
- }
-
- async batchUpsertComponents(components: ComponentInfo[]): Promise {
- await withTransaction(async (client) => {
- for (const component of components) {
- await client.query(SQL.components.upsert, [
- component.id,
- component.name,
- component.path,
- component.category,
- component.hasStorybook,
- component.hasFigmaConnect,
- component.hasTests,
- component.lastModified
- ? new Date(component.lastModified)
- : null,
- ])
- }
- })
- }
-
- async getComponentCoverage(): Promise {
- const result = await query(SQL.components.coverage)
- const row = result.rows[0]
-
- return {
- total: parseInt(row.total_components),
- integrated: parseInt(row.integrated_components),
- percentage: parseFloat(row.percentage),
- lastUpdated: new Date().toISOString(),
- }
- }
-
- async getCoverageByCategory(): Promise<
- Record
- > {
- const result = await query(SQL.components.coverageByCategory)
- const coverage: Record =
- {}
-
- for (const row of result.rows) {
- coverage[row.category] = {
- total: parseInt(row.total),
- integrated: parseInt(row.integrated),
- }
- }
-
- return coverage
- }
-
- async saveCoverageMetrics(
- metrics: CoverageMetrics,
- byCategory: Record
- ): Promise {
- await query(
- `INSERT INTO coverage_metrics (total_components, integrated_components, percentage, category_breakdown)
- VALUES ($1, $2, $3, $4)`,
- [
- metrics.total,
- metrics.integrated,
- metrics.percentage,
- JSON.stringify(byCategory),
- ]
- )
- }
-
- // ==================== NPM PACKAGE STATS ====================
-
- async getPackageStats(): Promise {
- try {
- const result = await query(
- 'SELECT * FROM npm_package_stats ORDER BY created_at DESC LIMIT 1'
- )
-
- if (result.rows.length === 0) return null
-
- const row = result.rows[0]
- return {
- name: row.package_name || '@juspay/blend-design-system',
- version: row.version || '0.0.0',
- downloads: {
- daily: row.downloads_daily || 0,
- weekly: row.downloads_weekly || 0,
- monthly: row.downloads_monthly || 0,
- total: row.downloads_total || 0,
- },
- size: {
- unpacked: row.size_unpacked || 0,
- gzipped: row.size_gzipped || 0,
- },
- dependencies: row.dependencies_count || 0,
- lastPublish: row.last_publish?.toISOString() || '',
- }
- } catch (error) {
- console.error('Error in getPackageStats:', error)
- // Return null instead of throwing to prevent 500 errors
- return null
- }
- }
-
- async savePackageStats(stats: PackageStats): Promise {
- await query(
- `INSERT INTO npm_package_stats (
- package_name, version, downloads_daily, downloads_weekly,
- downloads_monthly, downloads_total, size_unpacked, size_gzipped,
- dependencies_count, last_publish
- ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)`,
- [
- stats.name,
- stats.version,
- stats.downloads.daily,
- stats.downloads.weekly,
- stats.downloads.monthly,
- stats.downloads.total,
- stats.size.unpacked,
- stats.size.gzipped,
- stats.dependencies,
- stats.lastPublish ? new Date(stats.lastPublish) : null,
- ]
- )
- }
-
- async getDownloadTrends(
- days: number = 30
- ): Promise> {
- try {
- const result = await query(
- `SELECT date, downloads FROM download_trends
- WHERE date >= CURRENT_DATE - INTERVAL '${days} days'
- ORDER BY date ASC`
- )
-
- if (!result.rows || result.rows.length === 0) {
- return []
- }
-
- return result.rows.map((row) => ({
- date: row.date
- ? row.date.toISOString().split('T')[0]
- : new Date().toISOString().split('T')[0],
- downloads: row.downloads || 0,
- }))
- } catch (error) {
- console.error('Error in getDownloadTrends:', error)
- // Return empty array instead of throwing to prevent 500 errors
- return []
- }
- }
-
- async saveDownloadTrend(
- date: string,
- downloads: number,
- packageName: string = '@juspay/blend-design-system'
- ): Promise {
- await query(
- `INSERT INTO download_trends (date, downloads, package_name)
- VALUES ($1, $2, $3)
- ON CONFLICT (date, package_name)
- DO UPDATE SET downloads = EXCLUDED.downloads`,
- [date, downloads, packageName]
- )
- }
-
- async getVersionHistory(): Promise {
- try {
- const result = await query(
- 'SELECT * FROM npm_versions ORDER BY published_at DESC'
- )
-
- if (!result.rows || result.rows.length === 0) {
- return []
- }
-
- return result.rows.map((row) => ({
- version: row.version || 'unknown',
- publishedAt: row.published_at
- ? row.published_at.toISOString()
- : new Date().toISOString(),
- publisher: row.publisher || 'unknown',
- downloads: row.downloads || 0,
- changelog: row.changelog || '',
- size: {
- unpacked: row.size_unpacked || 0,
- gzipped: row.size_gzipped || 0,
- },
- breaking: row.is_breaking || false,
- }))
- } catch (error) {
- console.error('Error in getVersionHistory:', error)
- // Return empty array instead of throwing to prevent 500 errors
- return []
- }
- }
-
- async saveVersionInfo(versionInfo: VersionInfo): Promise {
- await query(
- `INSERT INTO npm_versions (
- version, published_at, publisher, downloads, changelog,
- size_unpacked, size_gzipped, is_breaking, is_prerelease
- ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
- ON CONFLICT (version) DO UPDATE SET
- downloads = EXCLUDED.downloads,
- changelog = COALESCE(EXCLUDED.changelog, npm_versions.changelog),
- size_unpacked = COALESCE(EXCLUDED.size_unpacked, npm_versions.size_unpacked),
- size_gzipped = COALESCE(EXCLUDED.size_gzipped, npm_versions.size_gzipped),
- updated_at = NOW()`,
- [
- versionInfo.version,
- new Date(versionInfo.publishedAt),
- versionInfo.publisher,
- versionInfo.downloads || 0,
- versionInfo.changelog,
- versionInfo.size?.unpacked,
- versionInfo.size?.gzipped,
- versionInfo.breaking || false,
- versionInfo.version.includes('-'),
- ]
- )
- }
-
- // Batch save version info with better conflict handling
- async batchSaveVersionInfo(
- versions: VersionInfo[]
- ): Promise<{ saved: number; updated: number }> {
- let saved = 0
- let updated = 0
-
- for (const versionInfo of versions) {
- try {
- const result = await query(
- `INSERT INTO npm_versions (
- version, published_at, publisher, downloads, changelog,
- size_unpacked, size_gzipped, is_breaking, is_prerelease
- ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
- ON CONFLICT (version) DO UPDATE SET
- downloads = EXCLUDED.downloads,
- changelog = COALESCE(EXCLUDED.changelog, npm_versions.changelog),
- size_unpacked = COALESCE(EXCLUDED.size_unpacked, npm_versions.size_unpacked),
- size_gzipped = COALESCE(EXCLUDED.size_gzipped, npm_versions.size_gzipped),
- updated_at = NOW()
- RETURNING (xmax = 0) AS inserted`,
- [
- versionInfo.version,
- new Date(versionInfo.publishedAt),
- versionInfo.publisher,
- versionInfo.downloads || 0,
- versionInfo.changelog,
- versionInfo.size?.unpacked,
- versionInfo.size?.gzipped,
- versionInfo.breaking || false,
- versionInfo.version.includes('-'),
- ]
- )
-
- if (result.rows[0]?.inserted) {
- saved++
- } else {
- updated++
- }
- } catch (error) {
- console.error(
- `Error saving version ${versionInfo.version}:`,
- error
- )
- }
- }
-
- return { saved, updated }
- }
-
- // Check for new versions by comparing with latest in database
- async getLatestVersionFromDatabase(): Promise {
- try {
- const result = await query(
- 'SELECT version FROM npm_versions ORDER BY published_at DESC LIMIT 1'
- )
- return result.rows[0]?.version || null
- } catch (error) {
- console.error('Error getting latest version:', error)
- return null
- }
- }
-
- // Sync NPM data with database - comprehensive update
- async syncNPMData(): Promise<{
- versions: { saved: number; updated: number }
- trends: { saved: number }
- stats: { updated: boolean }
- errors: string[]
- }> {
- const errors: string[] = []
- const result = {
- versions: { saved: 0, updated: 0 },
- trends: { saved: 0 },
- stats: { updated: false },
- errors,
- }
-
- try {
- // Import NPMClient here to avoid circular dependencies
- const { NPMClient } = await import('@/backend/external/npm-client')
- const npmClient = new NPMClient('@juspay/blend-design-system')
-
- // Sync version history
- try {
- const versionHistory = await npmClient.getVersionHistory()
- if (versionHistory && versionHistory.length > 0) {
- const versionResult =
- await this.batchSaveVersionInfo(versionHistory)
- result.versions = versionResult
- console.log(
- `Synced ${versionResult.saved + versionResult.updated} versions (${versionResult.saved} new, ${versionResult.updated} updated)`
- )
- }
- } catch (error) {
- errors.push(
- `Version sync failed: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Sync download trends
- try {
- const downloadTrends = await npmClient.getDownloadTrends(30)
- if (downloadTrends && downloadTrends.length > 0) {
- let trendsSaved = 0
- for (const trend of downloadTrends) {
- try {
- await this.saveDownloadTrend(
- trend.date,
- trend.downloads
- )
- trendsSaved++
- } catch {
- // Skip individual trend errors (likely duplicates)
- }
- }
- result.trends.saved = trendsSaved
- console.log(`Synced ${trendsSaved} download trends`)
- }
- } catch (error) {
- errors.push(
- `Trends sync failed: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Sync package stats
- try {
- const packageStats = await npmClient.getPackageStats()
- if (packageStats) {
- await this.savePackageStats(packageStats)
- result.stats.updated = true
- console.log('Synced package stats')
- }
- } catch (error) {
- errors.push(
- `Stats sync failed: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Log sync activity
- try {
- await this.logSystemActivity('npm_data_sync', {
- ...result,
- timestamp: new Date().toISOString(),
- })
- } catch (error) {
- console.warn('Could not log sync activity:', error)
- }
- } catch (error) {
- errors.push(
- `Sync initialization failed: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- return result
- }
-
- // ==================== ACTIVITY LOGS ====================
-
- async logUserActivity(
- userId: string,
- action: string,
- details?: Record,
- metadata?: Record
- ): Promise {
- await query(SQL.activity.log, [
- userId,
- action,
- details ? JSON.stringify(details) : null,
- metadata ? JSON.stringify(metadata) : null,
- new Date(),
- ])
- }
-
- async logSystemActivity(
- action: string,
- details?: Record
- ): Promise {
- await query(SQL.activity.systemLog, [
- action,
- details ? JSON.stringify(details) : null,
- new Date(),
- ])
- }
-
- async getUserActivity(
- userId: string,
- limit: number = 50,
- offset: number = 0
- ) {
- const queryText = `
- SELECT
- al.id, al.action, al.timestamp, al.details,
- u.display_name, u.email
- FROM activity_logs al
- LEFT JOIN users u ON al.user_id = u.id
- WHERE al.user_id = $1
- ORDER BY al.timestamp DESC
- LIMIT $2 OFFSET $3
- `
-
- const result = await query(queryText, [userId, limit, offset])
- return result.rows.map((row) => ({
- id: row.id,
- action: row.action,
- timestamp: row.timestamp,
- details: row.details,
- user: {
- display_name: row.display_name,
- email: row.email,
- },
- }))
- }
-
- async getRecentActivity(limit: number = 10): Promise {
- const result = await query(SQL.activity.getRecentActivity, [limit])
-
- return result.rows.map((row) => ({
- id: row.id,
- type: row.action as Activity['type'],
- timestamp: row.timestamp.toISOString(),
- user: row.display_name || row.email,
- details: typeof row.details === 'string' ? row.details : undefined,
- component:
- typeof row.details?.component === 'string'
- ? row.details.component
- : undefined,
- version:
- typeof row.details?.version === 'string'
- ? row.details.version
- : undefined,
- }))
- }
-
- // ==================== HELPER METHODS ====================
-
- private mapDatabaseComponentToInfo(
- dbComponent: DatabaseComponent
- ): ComponentInfo {
- return {
- id: dbComponent.component_id,
- name: dbComponent.name,
- path: dbComponent.path,
- category: dbComponent.category,
- hasStorybook: dbComponent.has_storybook,
- hasFigmaConnect: dbComponent.has_figma_connect,
- hasTests: dbComponent.has_tests,
- lastModified:
- dbComponent.last_modified?.toISOString() ||
- new Date().toISOString(),
- }
- }
-
- private mapDatabaseActivityToActivity(
- dbActivity: DatabaseActivityLog
- ): Activity {
- return {
- id: dbActivity.id,
- type: dbActivity.action as Activity['type'],
- timestamp: dbActivity.timestamp.toISOString(),
- details:
- typeof dbActivity.details?.details === 'string'
- ? dbActivity.details.details
- : undefined,
- component:
- typeof dbActivity.details?.component === 'string'
- ? dbActivity.details.component
- : undefined,
- version:
- typeof dbActivity.details?.version === 'string'
- ? dbActivity.details.version
- : undefined,
- user:
- typeof dbActivity.details?.user === 'string'
- ? dbActivity.details.user
- : undefined,
- }
- }
-
- private mapUserRow(row: DatabaseUser): DatabaseUser {
- return {
- id: row.id,
- firebase_uid: row.firebase_uid,
- email: row.email,
- display_name: row.display_name,
- photo_url: row.photo_url,
- role: row.role,
- is_active: row.is_active,
- created_at: row.created_at,
- last_login: row.last_login,
- updated_at: row.updated_at,
- }
- }
-}
-
-// Export singleton instance
-export const databaseService = new DatabaseService()
diff --git a/apps/blend-monitor/src/backend/lib/database.ts b/apps/blend-monitor/src/backend/lib/database.ts
deleted file mode 100644
index 08a0808cd..000000000
--- a/apps/blend-monitor/src/backend/lib/database.ts
+++ /dev/null
@@ -1,384 +0,0 @@
-import { Pool, PoolClient, QueryResult, QueryResultRow } from 'pg'
-
-// Database connection configuration
-const dbConfig = {
- host:
- process.env.NODE_ENV === 'production' &&
- process.env.INSTANCE_CONNECTION_NAME
- ? `/cloudsql/${process.env.INSTANCE_CONNECTION_NAME}`
- : process.env.DATABASE_HOST || 'localhost',
- port:
- process.env.NODE_ENV === 'production' &&
- process.env.INSTANCE_CONNECTION_NAME
- ? undefined
- : parseInt(process.env.DATABASE_PORT || '5432'),
- database: process.env.DATABASE_NAME || 'blend_monitor',
- user: process.env.DATABASE_USER || 'postgres',
- password: process.env.DATABASE_PASSWORD,
- ssl:
- process.env.NODE_ENV === 'production'
- ? false // Cloud SQL uses Unix socket, no SSL needed
- : process.env.DATABASE_HOST
- ? { rejectUnauthorized: false }
- : false,
- max: 20, // Increased back to 20 for better concurrency
- idleTimeoutMillis: 30000, // Increased to 30 seconds
- connectionTimeoutMillis: 20000, // Increased to 20 seconds
- acquireTimeoutMillis: 30000, // Increased to 30 seconds
- createTimeoutMillis: 30000, // Increased to 30 seconds
- destroyTimeoutMillis: 10000, // Increased to 10 seconds
- reapIntervalMillis: 5000, // Increased to 5 seconds
- createRetryIntervalMillis: 500, // Increased retry interval
-}
-
-// Global connection pool
-let pool: Pool | null = null
-
-export function getPool(): Pool {
- if (!pool) {
- pool = new Pool(dbConfig)
-
- // Handle pool errors
- pool.on('error', (err: Error) => {
- console.error('Unexpected error on idle client', err)
- })
-
- // Handle pool connection events for debugging
- if (process.env.NODE_ENV === 'development') {
- pool.on('connect', () => {
- console.log('Database client connected')
- })
-
- pool.on('remove', () => {
- console.log('Database client removed')
- })
- }
- }
- return pool
-}
-
-// Query helper with automatic connection management
-export async function query(
- text: string,
- params?: unknown[]
-): Promise> {
- const pool = getPool()
- const start = Date.now()
-
- try {
- const result = await pool.query(text, params)
- const duration = Date.now() - start
-
- if (process.env.NODE_ENV === 'development') {
- console.log('Executed query', {
- text,
- duration,
- rows: result.rowCount,
- })
- }
-
- return result
- } catch (error) {
- console.error('Database query error:', { text, params, error })
- throw error
- }
-}
-
-// Transaction helper
-export async function withTransaction(
- callback: (client: PoolClient) => Promise
-): Promise {
- const pool = getPool()
- const client = await pool.connect()
-
- try {
- await client.query('BEGIN')
- const result = await callback(client)
- await client.query('COMMIT')
- return result
- } catch (error) {
- await client.query('ROLLBACK')
- throw error
- } finally {
- client.release()
- }
-}
-
-// Database health check
-export async function checkDatabaseHealth(): Promise<{
- healthy: boolean
- latency?: number
- error?: string
-}> {
- try {
- const start = Date.now()
- await query('SELECT 1')
- const latency = Date.now() - start
-
- return { healthy: true, latency }
- } catch (error) {
- return {
- healthy: false,
- error: error instanceof Error ? error.message : 'Unknown error',
- }
- }
-}
-
-// Clean shutdown
-export async function closeDatabasePool(): Promise {
- if (pool) {
- await pool.end()
- pool = null
- console.log('Database pool closed')
- }
-}
-
-// Initialize database (run migrations, check connection)
-export async function initializeDatabase(): Promise {
- try {
- const health = await checkDatabaseHealth()
- if (!health.healthy) {
- throw new Error(`Database connection failed: ${health.error}`)
- }
-
- console.log(
- `Database connected successfully (latency: ${health.latency}ms)`
- )
-
- // Create tables if they don't exist
- await createTablesIfNotExists()
- } catch (error) {
- console.error('Failed to initialize database:', error)
- throw error
- }
-}
-
-// Create essential tables if they don't exist
-async function createTablesIfNotExists(): Promise {
- const client = getPool()
-
- try {
- // Enable UUID extension
- await client.query('CREATE EXTENSION IF NOT EXISTS "uuid-ossp"')
-
- // Create npm_versions table
- await client.query(`
- CREATE TABLE IF NOT EXISTS npm_versions (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- version VARCHAR(50) UNIQUE NOT NULL,
- published_at TIMESTAMP WITH TIME ZONE NOT NULL,
- publisher VARCHAR(255),
- downloads INTEGER NOT NULL DEFAULT 0,
- changelog TEXT,
- size_unpacked INTEGER,
- size_gzipped INTEGER,
- is_breaking BOOLEAN NOT NULL DEFAULT false,
- is_prerelease BOOLEAN NOT NULL DEFAULT false,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
- )
- `)
-
- // Create download_trends table
- await client.query(`
- CREATE TABLE IF NOT EXISTS download_trends (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- date DATE NOT NULL,
- downloads INTEGER NOT NULL DEFAULT 0,
- package_name VARCHAR(255) NOT NULL DEFAULT '@juspay/blend-design-system',
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- UNIQUE(date, package_name)
- )
- `)
-
- // Create npm_package_stats table
- await client.query(`
- CREATE TABLE IF NOT EXISTS npm_package_stats (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- package_name VARCHAR(255) NOT NULL,
- version VARCHAR(50) NOT NULL,
- downloads_daily INTEGER NOT NULL DEFAULT 0,
- downloads_weekly INTEGER NOT NULL DEFAULT 0,
- downloads_monthly INTEGER NOT NULL DEFAULT 0,
- downloads_total INTEGER NOT NULL DEFAULT 0,
- size_unpacked INTEGER NOT NULL DEFAULT 0,
- size_gzipped INTEGER NOT NULL DEFAULT 0,
- dependencies_count INTEGER NOT NULL DEFAULT 0,
- last_publish TIMESTAMP WITH TIME ZONE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
- )
- `)
-
- // Create users table
- await client.query(`
- CREATE TABLE IF NOT EXISTS users (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- firebase_uid VARCHAR(255) UNIQUE NOT NULL,
- email VARCHAR(255) UNIQUE NOT NULL,
- display_name VARCHAR(255),
- photo_url TEXT,
- role VARCHAR(50) NOT NULL DEFAULT 'viewer',
- is_active BOOLEAN NOT NULL DEFAULT true,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- last_login TIMESTAMP WITH TIME ZONE,
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
- )
- `)
-
- // Create activity_logs table
- await client.query(`
- CREATE TABLE IF NOT EXISTS activity_logs (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- user_id UUID REFERENCES users(id) ON DELETE CASCADE,
- action VARCHAR(255) NOT NULL,
- details JSONB,
- metadata JSONB,
- timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
- )
- `)
-
- // Create system_activity table
- await client.query(`
- CREATE TABLE IF NOT EXISTS system_activity (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- action VARCHAR(255) NOT NULL,
- details JSONB,
- timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
- )
- `)
-
- console.log('Database tables created/verified successfully')
- } catch (error) {
- console.error('Error creating database tables:', error)
- throw error
- }
-}
-
-// Types for better TypeScript support
-export interface DatabaseUser {
- id: string
- firebase_uid: string
- email: string
- display_name?: string
- photo_url?: string
- role: string
- is_active: boolean
- created_at: Date
- last_login?: Date
- updated_at: Date
-}
-
-export interface DatabaseComponent {
- id: string
- component_id: string
- name: string
- path: string
- category: string
- has_storybook: boolean
- has_figma_connect: boolean
- has_tests: boolean
- last_modified?: Date
- created_at: Date
- updated_at: Date
-}
-
-export interface DatabaseActivityLog {
- id: string
- user_id?: string
- action: string
- details?: Record
- metadata?: Record
- timestamp: Date
- created_at: Date
-}
-
-// SQL query builders for common operations
-export const SQL = {
- // User queries
- users: {
- findByFirebaseUid: 'SELECT * FROM users WHERE firebase_uid = $1',
- findByEmail: 'SELECT * FROM users WHERE email = $1',
- create: `
- INSERT INTO users (firebase_uid, email, display_name, photo_url, role, last_login)
- VALUES ($1, $2, $3, $4, $5, $6)
- RETURNING *
- `,
- update: `
- UPDATE users
- SET display_name = $2, photo_url = $3, last_login = $4, updated_at = NOW()
- WHERE firebase_uid = $1
- RETURNING *
- `,
- updateRole: `
- UPDATE users SET role = $2, updated_at = NOW()
- WHERE id = $1
- RETURNING *
- `,
- list: 'SELECT * FROM users ORDER BY created_at DESC',
- },
-
- // Component queries
- components: {
- list: 'SELECT * FROM components ORDER BY name',
- findById: 'SELECT * FROM components WHERE component_id = $1',
- upsert: `
- INSERT INTO components (component_id, name, path, category, has_storybook, has_figma_connect, has_tests, last_modified)
- VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
- ON CONFLICT (component_id)
- DO UPDATE SET
- name = EXCLUDED.name,
- path = EXCLUDED.path,
- category = EXCLUDED.category,
- has_storybook = EXCLUDED.has_storybook,
- has_figma_connect = EXCLUDED.has_figma_connect,
- has_tests = EXCLUDED.has_tests,
- last_modified = EXCLUDED.last_modified,
- updated_at = NOW()
- RETURNING *
- `,
- coverage: `
- SELECT
- COUNT(*) as total_components,
- COUNT(*) FILTER (WHERE has_figma_connect = true) as integrated_components,
- ROUND(
- (COUNT(*) FILTER (WHERE has_figma_connect = true) * 100.0 / COUNT(*)), 2
- ) as percentage
- FROM components
- `,
- coverageByCategory: `
- SELECT
- category,
- COUNT(*) as total,
- COUNT(*) FILTER (WHERE has_figma_connect = true) as integrated
- FROM components
- GROUP BY category
- `,
- },
-
- // Activity queries
- activity: {
- log: `
- INSERT INTO activity_logs (user_id, action, details, metadata, timestamp)
- VALUES ($1, $2, $3, $4, $5)
- RETURNING *
- `,
- getUserActivity: `
- SELECT * FROM activity_logs
- WHERE user_id = $1
- ORDER BY timestamp DESC
- LIMIT $2
- `,
- getRecentActivity: `
- SELECT al.*, u.display_name, u.email
- FROM activity_logs al
- LEFT JOIN users u ON al.user_id = u.id
- ORDER BY al.timestamp DESC
- LIMIT $1
- `,
- systemLog: `
- INSERT INTO system_activity (action, details, timestamp)
- VALUES ($1, $2, $3)
- RETURNING *
- `,
- },
-}
diff --git a/apps/blend-monitor/src/backend/lib/firebase-admin.ts b/apps/blend-monitor/src/backend/lib/firebase-admin.ts
deleted file mode 100644
index 450f0f321..000000000
--- a/apps/blend-monitor/src/backend/lib/firebase-admin.ts
+++ /dev/null
@@ -1,80 +0,0 @@
-import * as admin from 'firebase-admin'
-import { App } from 'firebase-admin/app'
-
-let adminApp: App | undefined
-
-export function initializeAdmin() {
- if (admin.apps.length === 0) {
- // In production, you would use service account credentials
- // For now, we'll use environment variables
- const projectId =
- process.env.FIREBASE_PROJECT_ID ||
- process.env.NEXT_PUBLIC_FIREBASE_PROJECT_ID
-
- if (!projectId) {
- console.warn(
- 'Firebase Admin SDK not properly configured. Some features may not work.'
- )
- return
- }
-
- try {
- const storageBucket =
- process.env.FIREBASE_STORAGE_BUCKET ||
- process.env.NEXT_PUBLIC_FIREBASE_STORAGE_BUCKET ||
- `${projectId}.appspot.com`
-
- adminApp = admin.initializeApp({
- projectId,
- storageBucket,
- credential: admin.credential.cert({
- projectId: process.env.FIREBASE_PROJECT_ID || '',
- clientEmail: process.env.FIREBASE_CLIENT_EMAIL || '',
- privateKey:
- process.env.FIREBASE_PRIVATE_KEY?.replace(
- /\\n/g,
- '\n'
- ) || '',
- }),
- })
- } catch (error) {
- console.error('Error initializing Firebase Admin:', error)
- }
- } else {
- adminApp = admin.apps[0] as App | undefined
- }
-
- return adminApp
-}
-
-export function getAdminAuth() {
- initializeAdmin()
- if (!adminApp) {
- throw new Error('Firebase Admin not initialized')
- }
- return admin.auth(adminApp)
-}
-
-export function getAdminFirestore() {
- initializeAdmin()
- if (!adminApp) {
- throw new Error('Firebase Admin not initialized')
- }
- return admin.firestore(adminApp)
-}
-
-export function getAdminStorage() {
- initializeAdmin()
- if (!adminApp) {
- throw new Error('Firebase Admin not initialized')
- }
- return admin.storage(adminApp)
-}
-
-export function getAdminDatabase() {
- initializeAdmin()
- if (!adminApp) {
- throw new Error('Firebase Admin not initialized')
- }
- return admin.database(adminApp)
-}
diff --git a/apps/blend-monitor/src/backend/lib/role-service.ts b/apps/blend-monitor/src/backend/lib/role-service.ts
deleted file mode 100644
index ffbe4f435..000000000
--- a/apps/blend-monitor/src/backend/lib/role-service.ts
+++ /dev/null
@@ -1,79 +0,0 @@
-import { query } from './database'
-
-export interface Role {
- id: string
- name: string
- permissions: Record
-}
-
-export class RoleService {
- async getUserRole(userId: string): Promise {
- try {
- const result = await query<{ role: string }>(
- `SELECT role FROM users WHERE firebase_uid = $1`,
- [userId]
- )
-
- if (!result.rows[0]) {
- return null
- }
-
- const roleName = result.rows[0].role || 'viewer'
-
- // Define role permissions
- const rolePermissions: Record = {
- admin: {
- id: 'admin',
- name: 'Administrator',
- permissions: {
- users: ['read', 'write', 'delete'],
- components: ['read', 'write', 'delete'],
- npm: ['read', 'write', 'sync'],
- system: ['read', 'write', 'configure'],
- },
- },
- editor: {
- id: 'editor',
- name: 'Editor',
- permissions: {
- users: ['read'],
- components: ['read', 'write'],
- npm: ['read', 'sync'],
- system: ['read'],
- },
- },
- viewer: {
- id: 'viewer',
- name: 'Viewer',
- permissions: {
- users: ['read'],
- components: ['read'],
- npm: ['read'],
- system: ['read'],
- },
- },
- }
-
- return rolePermissions[roleName] || rolePermissions.viewer
- } catch (error) {
- console.error('Error getting user role:', error)
- return null
- }
- }
-
- async updateUserRole(userId: string, newRole: string): Promise {
- try {
- const result = await query(
- `UPDATE users SET role = $1 WHERE firebase_uid = $2`,
- [newRole, userId]
- )
-
- return (result.rowCount || 0) > 0
- } catch (error) {
- console.error('Error updating user role:', error)
- return false
- }
- }
-}
-
-export const roleService = new RoleService()
diff --git a/apps/blend-monitor/src/backend/scanners/component-scanner.ts b/apps/blend-monitor/src/backend/scanners/component-scanner.ts
deleted file mode 100644
index ff0d2475b..000000000
--- a/apps/blend-monitor/src/backend/scanners/component-scanner.ts
+++ /dev/null
@@ -1,275 +0,0 @@
-import { ComponentInfo } from '@/shared/types'
-import fs from 'fs'
-import path from 'path'
-
-export class ComponentScanner {
- private componentsPath: string
- private storybookPath: string
-
- constructor() {
- // Paths relative to the monorepo root
- this.componentsPath = path.join(
- process.cwd(),
- '../../packages/blend/lib/components'
- )
- this.storybookPath = path.join(
- process.cwd(),
- '../../apps/storybook/stories/components'
- )
- }
-
- async scanComponents(): Promise {
- try {
- const components: ComponentInfo[] = []
-
- // Read all directories in the components folder
- const componentDirs = await this.getComponentDirectories()
-
- for (const dir of componentDirs) {
- const componentInfo = await this.analyzeComponent(dir)
- if (componentInfo) {
- components.push(componentInfo)
- }
- }
-
- return components
- } catch (error) {
- console.error('Error scanning components:', error)
- return []
- }
- }
-
- private async getComponentDirectories(): Promise {
- try {
- const items = await fs.promises.readdir(this.componentsPath)
- const dirs: string[] = []
-
- for (const item of items) {
- const itemPath = path.join(this.componentsPath, item)
- const stat = await fs.promises.stat(itemPath)
-
- if (stat.isDirectory() && !item.startsWith('.')) {
- dirs.push(item)
- }
- }
-
- return dirs
- } catch (error) {
- console.error('Error reading component directories:', error)
- return []
- }
- }
-
- private async analyzeComponent(
- dirName: string
- ): Promise {
- try {
- const componentPath = path.join(this.componentsPath, dirName)
-
- // Check if index.ts exists
- const indexPath = path.join(componentPath, 'index.ts')
- const hasIndex = await this.fileExists(indexPath)
-
- if (!hasIndex) {
- return null
- }
-
- // Get component stats
- const stat = await fs.promises.stat(componentPath)
-
- // Check for Figma Connect file
- const hasFigmaConnect = await this.checkFigmaConnect(dirName)
-
- // Check for Storybook
- const hasStorybook = await this.checkStorybook(dirName)
-
- // Check for tests
- const hasTests = await this.checkTests(componentPath)
-
- // Determine category
- const category = this.determineCategory(dirName)
-
- return {
- id: this.generateId(dirName),
- name: dirName,
- path: `packages/blend/lib/components/${dirName}`,
- category,
- hasStorybook,
- hasFigmaConnect,
- hasTests,
- lastModified: stat.mtime.toISOString(),
- }
- } catch (error) {
- console.error(`Error analyzing component ${dirName}:`, error)
- return null
- }
- }
-
- private async checkFigmaConnect(componentName: string): Promise {
- // Check in storybook directory for .figma.tsx files
- const figmaConnectPaths = [
- path.join(
- this.storybookPath,
- componentName,
- `${componentName}.figma.tsx`
- ),
- path.join(
- this.storybookPath,
- componentName,
- `${componentName}.figma.ts`
- ),
- // Check for variations in naming
- path.join(this.storybookPath, 'Button', 'Button.figma.tsx'), // Updated for Button component
- ]
-
- for (const figmaPath of figmaConnectPaths) {
- if (await this.fileExists(figmaPath)) {
- return true
- }
- }
-
- return false
- }
-
- private async checkStorybook(componentName: string): Promise {
- const storyPaths = [
- path.join(this.storybookPath, `${componentName}.stories.tsx`),
- path.join(this.storybookPath, `${componentName}.stories.ts`),
- path.join(
- this.storybookPath,
- componentName,
- `${componentName}.stories.tsx`
- ),
- ]
-
- for (const storyPath of storyPaths) {
- if (await this.fileExists(storyPath)) {
- return true
- }
- }
-
- return false
- }
-
- private async checkTests(componentPath: string): Promise {
- const testFiles = [
- 'test.tsx',
- 'test.ts',
- 'spec.tsx',
- 'spec.ts',
- '__tests__',
- ]
-
- for (const testFile of testFiles) {
- const testPath = path.join(componentPath, testFile)
- if (await this.fileExists(testPath)) {
- return true
- }
- }
-
- return false
- }
-
- private async fileExists(filePath: string): Promise {
- try {
- await fs.promises.access(filePath)
- return true
- } catch {
- return false
- }
- }
-
- private generateId(name: string): string {
- return name.toLowerCase().replace(/[^a-z0-9]/g, '-')
- }
-
- private determineCategory(componentName: string): string {
- // Categorize based on component name patterns
- const categories: Record = {
- inputs: [
- 'Button',
- 'TextInput',
- 'NumberInput',
- 'Checkbox',
- 'Radio',
- 'Switch',
- 'Slider',
- 'Select',
- 'DatePicker',
- 'TimePicker',
- 'ColorPicker',
- 'OTPInput',
- 'SearchInput',
- 'TextArea',
- 'UnitInput',
- 'MultiValueInput',
- 'DropdownInput',
- ],
- display: [
- 'Card',
- 'Avatar',
- 'Badge',
- 'Tag',
- 'Chip',
- 'Alert',
- 'Toast',
- 'Tooltip',
- 'Popover',
- 'Modal',
- 'Drawer',
- 'StatCard',
- 'Charts',
- ],
- navigation: [
- 'Tabs',
- 'Breadcrumb',
- 'Menu',
- 'Sidebar',
- 'Navbar',
- 'Pagination',
- 'Stepper',
- ],
- feedback: [
- 'Progress',
- 'Spinner',
- 'Skeleton',
- 'Snackbar',
- 'Loading',
- ],
- layout: [
- 'Grid',
- 'Stack',
- 'Container',
- 'Divider',
- 'Spacer',
- 'Block',
- ],
- data: ['Table', 'DataTable', 'List', 'Tree'],
- forms: ['Form', 'FormField', 'FormGroup'],
- }
-
- for (const [category, components] of Object.entries(categories)) {
- if (components.some((comp) => componentName.includes(comp))) {
- return category
- }
- }
-
- return 'other'
- }
-
- // Get integration status for a specific component
- async getComponentIntegrationStatus(componentId: string): Promise<{
- hasFigmaConnect: boolean
- hasStorybook: boolean
- hasTests: boolean
- }> {
- const components = await this.scanComponents()
- const component = components.find((c) => c.id === componentId)
-
- return {
- hasFigmaConnect: component?.hasFigmaConnect || false,
- hasStorybook: component?.hasStorybook || false,
- hasTests: component?.hasTests || false,
- }
- }
-}
diff --git a/apps/blend-monitor/src/frontend/app/code-connect/health/page.tsx b/apps/blend-monitor/src/frontend/app/code-connect/health/page.tsx
deleted file mode 100644
index 6c3466b1b..000000000
--- a/apps/blend-monitor/src/frontend/app/code-connect/health/page.tsx
+++ /dev/null
@@ -1,370 +0,0 @@
-'use client'
-
-import React, { useState, useMemo } from 'react'
-import { useComponents } from '../../../hooks/usePostgreSQLData'
-import Loader from '../../../components/shared/Loader'
-import {
- Button,
- ButtonSize,
- ButtonType,
- Tag,
- TagVariant,
- TagColor,
- TagSize,
- DataTable,
- ColumnDefinition,
- ColumnType,
-} from '@juspay/blend-design-system'
-import {
- AlertCircle,
- CheckCircle,
- XCircle,
- RefreshCw,
- Eye,
- Clock,
-} from 'lucide-react'
-
-interface HealthStatus {
- component: string
- status: 'active' | 'warning' | 'error'
- lastSync: string
- syncRate: number
- errors: string[]
- avgSyncDuration: number
-}
-
-export default function IntegrationHealthPage() {
- const { components, loading } = useComponents()
- const [refreshing, setRefreshing] = useState(false)
- const [selectedComponent, setSelectedComponent] = useState(
- null
- )
-
- // Mock health data - in production, this would come from Firebase
- const healthData = useMemo(() => {
- return components.map((comp) => ({
- component: comp.name,
- status: comp.hasFigmaConnect
- ? Math.random() > 0.8
- ? ('warning' as const)
- : ('active' as const)
- : ('error' as const),
- lastSync: comp.hasFigmaConnect
- ? new Date(Date.now() - Math.random() * 86400000).toISOString()
- : 'Never',
- syncRate: comp.hasFigmaConnect
- ? Math.floor(Math.random() * 20 + 80)
- : 0,
- errors:
- comp.hasFigmaConnect && Math.random() > 0.8
- ? ['Props mismatch detected', 'Variant not found in Figma']
- : [],
- avgSyncDuration: comp.hasFigmaConnect
- ? Math.floor(Math.random() * 5000 + 1000)
- : 0,
- }))
- }, [components])
-
- // Calculate metrics
- const metrics = useMemo(() => {
- const active = healthData.filter((h) => h.status === 'active').length
- const warning = healthData.filter((h) => h.status === 'warning').length
- const error = healthData.filter((h) => h.status === 'error').length
- const avgSyncRate =
- healthData
- .filter((h) => h.syncRate > 0)
- .reduce((acc, h) => acc + h.syncRate, 0) /
- (active + warning) || 0
-
- return { active, warning, error, avgSyncRate }
- }, [healthData])
-
- const handleRefresh = async () => {
- setRefreshing(true)
- try {
- await fetch('/api/components', { method: 'POST' })
- } catch (error) {
- console.error('Error refreshing:', error)
- }
- setRefreshing(false)
- }
-
- const getStatusIcon = (status: string) => {
- switch (status) {
- case 'active':
- return [] = [
- {
- field: 'status' as keyof HealthStatus,
- header: 'Status',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) => (
-
-
- ),
- },
- {
- field: 'errors' as keyof HealthStatus,
- header: 'Issues',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) =>
- row.errors.length > 0 ? (
- = 90
- ? 'bg-green-500'
- : row.syncRate >= 70
- ? 'bg-yellow-500'
- : 'bg-red-500'
- }`}
- style={{ width: `${row.syncRate}%` }}
- />
-
- {row.syncRate}%
-
- }
- size={ButtonSize.SMALL}
- onClick={() => setSelectedComponent(row.component)}
- />
- }
- size={ButtonSize.SMALL}
- buttonType={ButtonType.SECONDARY}
- />
-
- ),
- },
- ]
-
- if (loading) {
- return
-
- )
-}
diff --git a/apps/blend-monitor/app/code-connect/page.tsx b/apps/blend-monitor/app/code-connect/page.tsx
deleted file mode 100644
index 6a2706291..000000000
--- a/apps/blend-monitor/app/code-connect/page.tsx
+++ /dev/null
@@ -1,2 +0,0 @@
-// Re-export from frontend
-export { default } from '@/frontend/app/code-connect/page'
diff --git a/apps/blend-monitor/app/favicon.ico b/apps/blend-monitor/app/favicon.ico
deleted file mode 100644
index 718d6fea4..000000000
Binary files a/apps/blend-monitor/app/favicon.ico and /dev/null differ
diff --git a/apps/blend-monitor/app/globals.css b/apps/blend-monitor/app/globals.css
deleted file mode 100644
index 4122f3fcd..000000000
--- a/apps/blend-monitor/app/globals.css
+++ /dev/null
@@ -1,210 +0,0 @@
-@import 'tailwindcss';
-
-:root {
- --background: #ffffff;
- --foreground: #171717;
-}
-
-@theme inline {
- --color-background: var(--background);
- --color-foreground: var(--foreground);
- --font-sans: var(--font-geist-sans);
- --font-mono: var(--font-geist-mono);
-}
-
-@media (prefers-color-scheme: dark) {
- :root {
- --background: #0a0a0a;
- --foreground: #ededed;
- }
-}
-
-body {
- background: var(--background);
- color: var(--foreground);
- font-family: Arial, Helvetica, sans-serif;
-}
-
-/* Ensure the Sidebar component from @juspay/blend-design-system has sticky behavior */
-/* The Sidebar component already handles sticky positioning internally */
-/* These styles ensure proper layout and scrolling behavior */
-
-/* Prevent body scroll when sidebar is present */
-body {
- overflow: hidden;
-}
-
-/* Ensure full height for the app container */
-#__next,
-html,
-body {
- height: 100%;
- margin: 0;
- padding: 0;
-}
-
-/* Animation for fade in effect */
-@keyframes fadeIn {
- from {
- opacity: 0;
- transform: translateY(10px);
- }
- to {
- opacity: 1;
- transform: translateY(0);
- }
-}
-
-.animate-fadeIn {
- animation: fadeIn 0.5s ease-out;
-}
-
-/* Custom scrollbar styling for better aesthetics */
-::-webkit-scrollbar {
- width: 8px;
- height: 8px;
-}
-
-::-webkit-scrollbar-track {
- background: #f1f1f1;
- border-radius: 4px;
-}
-
-::-webkit-scrollbar-thumb {
- background: #888;
- border-radius: 4px;
-}
-
-::-webkit-scrollbar-thumb:hover {
- background: #555;
-}
-
-/* Smooth scrolling */
-* {
- scroll-behavior: smooth;
-}
-
-/* Ensure proper z-index layering */
-.z-50 {
- z-index: 50;
-}
-
-.z-40 {
- z-index: 40;
-}
-
-.z-30 {
- z-index: 30;
-}
-
-/* Gradient text animation for the logo */
-@keyframes gradient {
- 0% {
- background-position: 0% 50%;
- }
- 50% {
- background-position: 100% 50%;
- }
- 100% {
- background-position: 0% 50%;
- }
-}
-
-.bg-gradient-to-r {
- background-size: 200% 200%;
- animation: gradient 3s ease infinite;
-}
-
-/* Pulse animation */
-@keyframes pulse {
- 0%,
- 100% {
- opacity: 1;
- }
- 50% {
- opacity: 0.5;
- }
-}
-
-.animate-pulse {
- animation: pulse 2s cubic-bezier(0.4, 0, 0.6, 1) infinite;
-}
-
-/* Hover effects for interactive elements */
-.hover\:shadow-md {
- transition: box-shadow 0.3s ease;
-}
-
-.hover\:shadow-lg {
- transition: box-shadow 0.3s ease;
-}
-
-.hover\:shadow-xl {
- transition: box-shadow 0.3s ease;
-}
-
-/* Focus styles for accessibility */
-input:focus,
-button:focus {
- outline: 2px solid #3b82f6;
- outline-offset: 2px;
-}
-
-/* Loading skeleton animation */
-@keyframes shimmer {
- 0% {
- background-position: -200% 0;
- }
- 100% {
- background-position: 200% 0;
- }
-}
-
-.animate-shimmer {
- background: linear-gradient(90deg, #f0f0f0 25%, #e0e0e0 50%, #f0f0f0 75%);
- background-size: 200% 100%;
- animation: shimmer 1.5s infinite;
-}
-
-/* Ensure metric cards have consistent styling */
-.metric-card {
- transition: all 0.3s ease;
-}
-
-.metric-card:hover {
- transform: translateY(-2px);
-}
-
-/* Tab transitions */
-[role='tablist'] button {
- transition: all 0.2s ease;
-}
-
-[role='tablist'] button[data-state='active'] {
- border-bottom: 2px solid #3b82f6;
-}
-
-/* Activity feed hover effects */
-.group:hover .group-hover\:bg-gray-200 {
- transition: background-color 0.2s ease;
-}
-
-/* Chart container styling */
-.chart-container {
- position: relative;
- height: 100%;
- width: 100%;
-}
-
-/* Responsive design helpers */
-@media (max-width: 768px) {
- .hide-mobile {
- display: none;
- }
-}
-
-@media (min-width: 769px) {
- .hide-desktop {
- display: none;
- }
-}
diff --git a/apps/blend-monitor/app/layout.tsx b/apps/blend-monitor/app/layout.tsx
deleted file mode 100644
index d29e0da11..000000000
--- a/apps/blend-monitor/app/layout.tsx
+++ /dev/null
@@ -1,33 +0,0 @@
-import '../polyfills'
-import type { Metadata } from 'next'
-import { Inter } from 'next/font/google'
-import './globals.css'
-import { AuthProvider } from '@/frontend/contexts/AuthContext'
-import ClientLayout from '@/frontend/components/shared/ClientLayout'
-
-const inter = Inter({ subsets: ['latin'] })
-
-export const metadata: Metadata = {
- title: 'Blend Monitor - Design System Dashboard',
- description:
- 'Monitor and track the Blend Design System components, usage, and NPM statistics',
-}
-
-// Force dynamic rendering for all pages to avoid SSR issues with Highcharts
-export const dynamic = 'force-dynamic'
-
-export default function RootLayout({
- children,
-}: Readonly<{
- children: React.ReactNode
-}>) {
- return (
-
-
-
-
-
- {/* Health Metrics */}
-
-
-
- }
- onClick={handleRefresh}
- disabled={refreshing}
- />
- - Integration Health Monitor -
-- Track the health and validity of Code Connect - integrations -
-
-
-
- {/* Alert Conditions */}
-
-
-
-
-
-
- - Active -
-- {metrics.active} -
-
-
-
-
-
-
- - Warnings -
-- {metrics.warning} -
-
-
-
-
-
-
- - Errors -
-- {metrics.error} -
-
-
-
-
-
-
- - Avg Success Rate -
-- {metrics.avgSyncRate.toFixed(1)}% -
-
- %
-
-
-
-
- {/* Health Status Grid */}
-
-
-
-
- - Active Alerts -
--
- {healthData
- .filter(
- (h) =>
- h.status === 'warning' ||
- h.status === 'error'
- )
- .map((h, idx) => (
-
- - β’ {h.component}:{' '} - {h.errors.join(', ') || - 'Integration failing'} - - ))} -
- []}
- columns={
- columns as ColumnDefinition>[]
- }
- idField="component"
- onRowClick={(row) =>
- setSelectedComponent(
- (row as unknown as HealthStatus).component
- )
- }
- />
-
-
- {/* Component Details Modal (placeholder) */}
- {selectedComponent && (
-
-
- - Component Health Status -
-
-
- )}
-
-
- - {selectedComponent} Details -
-- Component integration details would appear here... -
-
- {/* Keep the page content visible but dimmed */}
-
-
- )
- }
-
- return (
-
-
- )
-}
diff --git a/apps/blend-monitor/app/not-found.tsx b/apps/blend-monitor/app/not-found.tsx
deleted file mode 100644
index ef0117efc..000000000
--- a/apps/blend-monitor/app/not-found.tsx
+++ /dev/null
@@ -1,23 +0,0 @@
-'use client'
-
-import Link from 'next/link'
-
-export default function NotFound() {
- return (
-
-
-
- {/* Logo and App Name inside card */}
-
-
-
-
- {error && (
-
-
- - Blend Monitor -
-- Sign in to your account -
-
-
- )}
-
- {/* Full width Google button - Primary style */}
-
-
- - Sign in failed -
-- {error} -
-
-
- )
-}
-
-// Force dynamic rendering
-export const dynamic = 'force-dynamic'
diff --git a/apps/blend-monitor/app/npm/page.tsx b/apps/blend-monitor/app/npm/page.tsx
deleted file mode 100644
index cfb948858..000000000
--- a/apps/blend-monitor/app/npm/page.tsx
+++ /dev/null
@@ -1,2 +0,0 @@
-// Re-export from frontend
-export { default } from '@/frontend/app/npm/page'
diff --git a/apps/blend-monitor/app/page.tsx b/apps/blend-monitor/app/page.tsx
deleted file mode 100644
index b5bca14a9..000000000
--- a/apps/blend-monitor/app/page.tsx
+++ /dev/null
@@ -1,5 +0,0 @@
-// Re-export from frontend
-export { default } from '@/frontend/app/page'
-
-// Force dynamic rendering to avoid SSR issues with Charts
-export const dynamic = 'force-dynamic'
diff --git a/apps/blend-monitor/app/users/[userId]/activity/page.tsx b/apps/blend-monitor/app/users/[userId]/activity/page.tsx
deleted file mode 100644
index f65000f2f..000000000
--- a/apps/blend-monitor/app/users/[userId]/activity/page.tsx
+++ /dev/null
@@ -1,309 +0,0 @@
-'use client'
-
-import React, { useState, useEffect } from 'react'
-import { useParams, useRouter } from 'next/navigation'
-import { auth } from '@/frontend/lib/firebase'
-import { usePermissions } from '@/frontend/components/auth/PermissionGuard'
-import ProtectedRoute from '@/frontend/components/auth/ProtectedRoute'
-import Loader from '@/frontend/components/shared/Loader'
-import { Button, ButtonType, ButtonSize } from '@juspay/blend-design-system'
-import { ArrowLeft, Activity, Clock, User as LucideUser } from 'lucide-react'
-
-// Mock interfaces and services to replace the deleted ones
-interface ActivityLog {
- id: string
- action: string
- timestamp: string
- details?: Record
-
- 404
-Page not found
- - Go back home - -
-
- )
- }
-
- return (
-
-
- - Access Denied -
-{error}
-
- }
- onClick={() => router.push('/users')}
- />
-
-
- {/* Header */}
-
- )
-}
diff --git a/apps/blend-monitor/app/users/page.tsx b/apps/blend-monitor/app/users/page.tsx
deleted file mode 100644
index 6b19dd962..000000000
--- a/apps/blend-monitor/app/users/page.tsx
+++ /dev/null
@@ -1,487 +0,0 @@
-'use client'
-
-import React, { useState, useEffect } from 'react'
-import { auth } from '@/frontend/lib/firebase'
-import { onAuthStateChanged, User } from 'firebase/auth'
-import { useRouter } from 'next/navigation'
-import Loader from '@/frontend/components/shared/Loader'
-import {
- Button,
- ButtonType,
- ButtonSize,
- Modal,
- TextInput,
- TextInputSize,
- SingleSelect,
- DataTable,
- ColumnDefinition,
- ColumnType,
-} from '@juspay/blend-design-system'
-import { UserPlus, Activity } from 'lucide-react'
-import { useUserManagement } from '@/frontend/hooks/usePostgreSQLData'
-
-// Default roles
-const DEFAULT_ROLES = {
- admin: { name: 'Administrator', permissions: ['*'] },
- developer: { name: 'Developer', permissions: ['read', 'write'] },
- viewer: { name: 'Viewer', permissions: ['read'] },
-}
-
-// User interface
-interface UserData {
- id: string
- firebase_uid: string
- email: string
- display_name?: string
- photo_url?: string
- role: string
- is_active: boolean
- last_login: string
- created_at: string
-}
-
-// Mock permissions hook
-const usePermissions = () => ({
- canManageUsers: true,
- isAdmin: true,
- userData: { email: 'admin@example.com' },
-})
-
-// Mock ProtectedRoute component
-const ProtectedRoute: React.FC<{ children: React.ReactNode }> = ({
- children,
-}) => {
- const [user, setUser] = useState
- }
- onClick={() => router.push('/users')}
- />
-
-
-
- {/* Activity Timeline */}
-
-
- - User Activity -
- {userData && ( -
-
- )}
-
- {userData.photoURL ? (
- 
- ) : (
-
-
-
- {userData.displayName?.charAt(0) ||
- userData.email
- .charAt(0)
- .toUpperCase()}
-
-
- )}
-
-
- - {userData.displayName || 'No name'} -
-- {userData.email} -
-
-
- - Activity Timeline -
- - {activities.length === 0 ? ( -
-
- ) : (
- - No activity yet -
-- User activities will appear here as they occur. -
-
- {activities.map((activity) => (
-
- )}
-
-
- ))}
-
- {getActivityIcon(activity.action)}
-
-
-
- - {activityService.formatActivityMessage( - activity.action, - activity.details - )} -
- {activity.details && - Object.keys(activity.details).length > - 0 && ( -
- {Object.entries(
- activity.details
- )
- .filter(
- ([key]) =>
- ![
- 'targetUserId',
- 'userId',
- 'changedBy',
- 'invitedBy',
- 'removedBy',
- ].includes(key)
- )
- .map(([key, value]) => (
-
- {key}:{' '}
-
- {String(value)}
-
-
- ))}
-
- )}
-
-
-
-
- ),
- },
- {
- field: 'role' as keyof UserData,
- header: 'Role',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: UserData) =>
- canManageUsers ? (
-
- {row.photo_url ? (
- 
- ) : (
-
-
-
- {row.display_name?.charAt(0) ||
- row.email.charAt(0).toUpperCase()}
-
-
- )}
-
-
-
- {row.display_name || 'No name'}
-
- {row.email}
-
-
- handleRoleChange(row.firebase_uid, value)
- }
- items={[
- {
- items: Object.entries(DEFAULT_ROLES).map(
- ([roleId, roleData]) => ({
- value: roleId,
- label: roleData.name,
- })
- ),
- },
- ]}
- placeholder="Select role"
- />
-
- ) : (
-
- {DEFAULT_ROLES[row.role as keyof typeof DEFAULT_ROLES]
- ?.name || row.role}
-
- ),
- },
- {
- field: 'is_active' as keyof UserData,
- header: 'Status',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: UserData) =>
- canManageUsers ? (
-
-
- handleStatusChange(
- row.firebase_uid,
- value === 'active'
- )
- }
- items={[
- {
- items: [
- {
- value: 'active',
- label: 'Active',
- },
- {
- value: 'inactive',
- label: 'Inactive',
- },
- ],
- },
- ]}
- placeholder="Select status"
- />
-
- ) : (
-
- {row.is_active ? 'Active' : 'Inactive'}
-
- ),
- },
- {
- field: 'last_login' as keyof UserData,
- header: 'Last Login',
- type: ColumnType.TEXT,
- isSortable: true,
- renderCell: (value: unknown, row: UserData) =>
- formatDate(row.last_login),
- },
- {
- field: 'created_at' as keyof UserData,
- header: 'Created',
- type: ColumnType.TEXT,
- isSortable: true,
- renderCell: (value: unknown, row: UserData) =>
- formatDate(row.created_at),
- },
- ]
-
- // Add actions column if user can manage users
- if (canManageUsers) {
- columns.push({
- field: 'firebase_uid' as keyof UserData,
- header: 'Actions',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: UserData) => (
-
- }
- onClick={() =>
- router.push(`/users/${row.firebase_uid}/activity`)
- }
- title="View activity"
- />
-
- ),
- })
- }
-
- if (loading) {
- return
- {/* Users DataTable */}
- []}
- columns={columns as ColumnDefinition>[]}
- idField="firebase_uid"
- title="All Users"
- description={`${users.length} users in the system`}
- enableSearch={false}
- enableColumnManager={false}
- isHoverable={true}
- pagination={{
- currentPage: 1,
- pageSize: 10,
- totalRows: users.length,
- pageSizeOptions: [10, 20, 50],
- }}
- headerSlot1={
- canManageUsers ? (
- }
- onClick={() => setShowInviteModal(true)}
- />
- ) : null
- }
- />
-
- {/* Invite User Modal */}
- {
- setShowInviteModal(false)
- setInviteEmail('')
- setInviteRole('viewer')
- }}
- title="Invite New User"
- showFooter={false}
- >
-
-
- {/* TODO: Add proper snackbar notifications once Snackbar component interface is fixed */}
-
- )
-}
diff --git a/apps/blend-monitor/cloudbuild.yaml b/apps/blend-monitor/cloudbuild.yaml
deleted file mode 100644
index c81dbf367..000000000
--- a/apps/blend-monitor/cloudbuild.yaml
+++ /dev/null
@@ -1,83 +0,0 @@
-steps:
- # Build the container image with build arguments
- - name: 'gcr.io/cloud-builders/docker'
- args:
- - 'build'
- - '-t'
- - 'gcr.io/$PROJECT_ID/blend-monitor:$BUILD_ID'
- - '-t'
- - 'gcr.io/$PROJECT_ID/blend-monitor:latest'
- - '-f'
- - 'apps/blend-monitor/Dockerfile'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_API_KEY=$_FIREBASE_API_KEY'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_AUTH_DOMAIN=$_FIREBASE_AUTH_DOMAIN'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_PROJECT_ID=$_FIREBASE_PROJECT_ID'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_STORAGE_BUCKET=$_FIREBASE_STORAGE_BUCKET'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_MESSAGING_SENDER_ID=$_FIREBASE_MESSAGING_SENDER_ID'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_APP_ID=$_FIREBASE_APP_ID'
- - '--build-arg'
- - 'NEXT_PUBLIC_FIREBASE_DATABASE_URL=$_FIREBASE_DATABASE_URL'
- - '.'
-
- # Push the container image to Container Registry
- - name: 'gcr.io/cloud-builders/docker'
- args: ['push', '--all-tags', 'gcr.io/$PROJECT_ID/blend-monitor']
-
- # Deploy container image to Cloud Run
- - name: 'gcr.io/google.com/cloudsdktool/cloud-sdk'
- entrypoint: gcloud
- args:
- - 'run'
- - 'deploy'
- - 'blend-monitor'
- - '--image'
- - 'gcr.io/$PROJECT_ID/blend-monitor:$BUILD_ID'
- - '--region'
- - 'us-central1'
- - '--platform'
- - 'managed'
- - '--allow-unauthenticated'
- - '--add-cloudsql-instances'
- - '$_INSTANCE_CONNECTION_NAME'
- - '--set-env-vars'
- - 'NODE_ENV=production,INSTANCE_CONNECTION_NAME=$_INSTANCE_CONNECTION_NAME,DATABASE_NAME=$_DATABASE_NAME,DATABASE_USER=$_DATABASE_USER,NEXT_PUBLIC_FIREBASE_API_KEY=$_FIREBASE_API_KEY,NEXT_PUBLIC_FIREBASE_AUTH_DOMAIN=$_FIREBASE_AUTH_DOMAIN,NEXT_PUBLIC_FIREBASE_PROJECT_ID=$_FIREBASE_PROJECT_ID,NEXT_PUBLIC_FIREBASE_STORAGE_BUCKET=$_FIREBASE_STORAGE_BUCKET,NEXT_PUBLIC_FIREBASE_MESSAGING_SENDER_ID=$_FIREBASE_MESSAGING_SENDER_ID,NEXT_PUBLIC_FIREBASE_APP_ID=$_FIREBASE_APP_ID,NEXT_PUBLIC_FIREBASE_DATABASE_URL=$_FIREBASE_DATABASE_URL,FIREBASE_PROJECT_ID=$_FIREBASE_PROJECT_ID,FIREBASE_CLIENT_EMAIL=$_FIREBASE_CLIENT_EMAIL'
- - '--set-secrets'
- - 'DATABASE_PASSWORD=blend-monitor-db-password:latest,FIREBASE_PRIVATE_KEY=blend-monitor-firebase-key:latest'
- - '--memory'
- - '512Mi'
- - '--cpu'
- - '1'
- - '--timeout'
- - '300'
- - '--min-instances'
- - '0'
- - '--max-instances'
- - '10'
- - '--service-account'
- - 'blend-monitor-sa@storybook-452807.iam.gserviceaccount.com'
-
-images:
- - 'gcr.io/$PROJECT_ID/blend-monitor:$BUILD_ID'
- - 'gcr.io/$PROJECT_ID/blend-monitor:latest'
-
-substitutions:
- _INSTANCE_CONNECTION_NAME: 'storybook-452807:us-central1:blend-dashboard'
- _DATABASE_NAME: 'blend_monitor'
- _DATABASE_USER: 'admin'
- _FIREBASE_API_KEY: 'AIzaSyD2aRkOI4iCwiZOW5kEejrL9jv9JvytKpo'
- _FIREBASE_AUTH_DOMAIN: 'storybook-452807.firebaseapp.com'
- _FIREBASE_PROJECT_ID: 'storybook-452807'
- _FIREBASE_STORAGE_BUCKET: 'storybook-452807.firebasestorage.app'
- _FIREBASE_MESSAGING_SENDER_ID: '567047894553'
- _FIREBASE_APP_ID: '1:567047894553:web:f2e38d23fbc9bdbbff5c88'
- _FIREBASE_DATABASE_URL: 'https://storybook-452807-default-rtdb.asia-southeast1.firebasedatabase.app'
- _FIREBASE_CLIENT_EMAIL: 'blend-firebase-10281134@storybook-452807.iam.gserviceaccount.com'
-
-options:
- logging: CLOUD_LOGGING_ONLY
diff --git a/apps/blend-monitor/database/schema.sql b/apps/blend-monitor/database/schema.sql
deleted file mode 100644
index f1188d20c..000000000
--- a/apps/blend-monitor/database/schema.sql
+++ /dev/null
@@ -1,315 +0,0 @@
--- Blend Monitor PostgreSQL Schema
--- Migration from Firebase Realtime Database
-
--- Enable necessary extensions
-CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
-CREATE EXTENSION IF NOT EXISTS "pg_trgm";
-
--- Users and Authentication
-CREATE TABLE users (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- firebase_uid VARCHAR(128) UNIQUE NOT NULL, -- Keep Firebase UID for auth compatibility
- email VARCHAR(255) UNIQUE NOT NULL,
- display_name VARCHAR(255),
- photo_url TEXT,
- role VARCHAR(50) NOT NULL DEFAULT 'viewer',
- is_active BOOLEAN NOT NULL DEFAULT true,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- last_login TIMESTAMP WITH TIME ZONE,
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Roles and Permissions
-CREATE TABLE roles (
- id VARCHAR(50) PRIMARY KEY,
- name VARCHAR(100) NOT NULL,
- permissions JSONB NOT NULL,
- is_custom BOOLEAN NOT NULL DEFAULT false,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Components
-CREATE TABLE components (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- component_id VARCHAR(255) UNIQUE NOT NULL, -- Original component identifier
- name VARCHAR(255) NOT NULL,
- path TEXT NOT NULL,
- category VARCHAR(100) NOT NULL,
- has_storybook BOOLEAN NOT NULL DEFAULT false,
- has_figma_connect BOOLEAN NOT NULL DEFAULT false,
- has_tests BOOLEAN NOT NULL DEFAULT false,
- last_modified TIMESTAMP WITH TIME ZONE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Integration Status
-CREATE TABLE component_integrations (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- component_id UUID NOT NULL REFERENCES components(id) ON DELETE CASCADE,
- status VARCHAR(50) NOT NULL DEFAULT 'not_integrated',
- last_sync TIMESTAMP WITH TIME ZONE,
- validation_errors JSONB,
- figma_url TEXT,
- variants JSONB,
- props_mapping JSONB,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Coverage Metrics
-CREATE TABLE coverage_metrics (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- total_components INTEGER NOT NULL,
- integrated_components INTEGER NOT NULL,
- percentage DECIMAL(5,2) NOT NULL,
- category_breakdown JSONB,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- NPM Package Stats
-CREATE TABLE npm_package_stats (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- package_name VARCHAR(255) NOT NULL,
- version VARCHAR(50) NOT NULL,
- downloads_daily INTEGER NOT NULL DEFAULT 0,
- downloads_weekly INTEGER NOT NULL DEFAULT 0,
- downloads_monthly INTEGER NOT NULL DEFAULT 0,
- downloads_total INTEGER NOT NULL DEFAULT 0,
- size_unpacked INTEGER NOT NULL DEFAULT 0,
- size_gzipped INTEGER NOT NULL DEFAULT 0,
- dependencies_count INTEGER NOT NULL DEFAULT 0,
- last_publish TIMESTAMP WITH TIME ZONE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- NPM Version History
-CREATE TABLE npm_versions (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- version VARCHAR(50) UNIQUE NOT NULL,
- published_at TIMESTAMP WITH TIME ZONE NOT NULL,
- publisher VARCHAR(255),
- downloads INTEGER NOT NULL DEFAULT 0,
- changelog TEXT,
- size_unpacked INTEGER,
- size_gzipped INTEGER,
- is_breaking BOOLEAN NOT NULL DEFAULT false,
- is_prerelease BOOLEAN NOT NULL DEFAULT false,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Download Trends
-CREATE TABLE download_trends (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- date DATE NOT NULL,
- downloads INTEGER NOT NULL,
- package_name VARCHAR(255) NOT NULL DEFAULT '@juspay/blend-design-system',
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- UNIQUE(date, package_name)
-);
-
--- Deployments
-CREATE TABLE deployments (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- environment VARCHAR(100) NOT NULL,
- version VARCHAR(100) NOT NULL,
- deployer_name VARCHAR(255) NOT NULL,
- deployer_email VARCHAR(255) NOT NULL,
- start_time TIMESTAMP WITH TIME ZONE NOT NULL,
- end_time TIMESTAMP WITH TIME ZONE,
- status VARCHAR(50) NOT NULL,
- duration_seconds INTEGER,
- commit_sha VARCHAR(40),
- build_logs_url TEXT,
- configuration JSONB,
- rollback_available BOOLEAN NOT NULL DEFAULT false,
- source VARCHAR(50) DEFAULT 'database',
- service VARCHAR(255),
- site_url TEXT,
- branch VARCHAR(255),
- build_logs TEXT[],
- deployment_logs TEXT[],
- build_cache_key VARCHAR(255),
- preview_url TEXT,
- scheduled_for TIMESTAMP WITH TIME ZONE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Deployment Approvals
-CREATE TABLE deployment_approvals (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- deployment_id UUID NOT NULL REFERENCES deployments(id) ON DELETE CASCADE,
- requested_by UUID NOT NULL REFERENCES users(id),
- requested_at TIMESTAMP WITH TIME ZONE NOT NULL,
- approved_by UUID REFERENCES users(id),
- approved_at TIMESTAMP WITH TIME ZONE,
- rejected_by UUID REFERENCES users(id),
- rejected_at TIMESTAMP WITH TIME ZONE,
- status VARCHAR(50) NOT NULL DEFAULT 'pending',
- comments TEXT,
- expires_at TIMESTAMP WITH TIME ZONE NOT NULL,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Environments
-CREATE TABLE environments (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- name VARCHAR(100) UNIQUE NOT NULL,
- status VARCHAR(50) NOT NULL DEFAULT 'unknown',
- uptime_percentage DECIMAL(5,2),
- current_version VARCHAR(100),
- last_deployment TIMESTAMP WITH TIME ZONE,
- url TEXT,
- channel VARCHAR(100),
- response_time_p50 INTEGER,
- response_time_p95 INTEGER,
- response_time_p99 INTEGER,
- request_rate INTEGER,
- error_rate DECIMAL(5,2),
- active_users INTEGER,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Activity Logs
-CREATE TABLE activity_logs (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- user_id UUID REFERENCES users(id) ON DELETE SET NULL,
- action VARCHAR(100) NOT NULL,
- details JSONB,
- metadata JSONB,
- timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- System Activity
-CREATE TABLE system_activity (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- action VARCHAR(100) NOT NULL,
- details JSONB,
- timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Audit Logs
-CREATE TABLE audit_logs (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- action VARCHAR(100) NOT NULL,
- user_id UUID REFERENCES users(id) ON DELETE SET NULL,
- resource VARCHAR(255),
- resource_id VARCHAR(255),
- old_values JSONB,
- new_values JSONB,
- result VARCHAR(50) NOT NULL,
- timestamp TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Cloud Functions
-CREATE TABLE cloud_functions (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- name VARCHAR(255) NOT NULL,
- version VARCHAR(50),
- status VARCHAR(50) NOT NULL,
- avg_response_time INTEGER,
- error_rate DECIMAL(5,2),
- invocations INTEGER,
- executions_per_hour INTEGER,
- executions_per_day INTEGER,
- schedule VARCHAR(255),
- last_execution TIMESTAMP WITH TIME ZONE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
- updated_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Firebase Usage Tracking
-CREATE TABLE firebase_usage (
- id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
- service VARCHAR(100) NOT NULL,
- metric VARCHAR(100) NOT NULL,
- used_amount BIGINT NOT NULL,
- limit_amount BIGINT,
- unit VARCHAR(50) NOT NULL,
- current_cost DECIMAL(10,2),
- projected_cost DECIMAL(10,2),
- billing_period_end DATE,
- created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW()
-);
-
--- Indexes for better query performance
-CREATE INDEX idx_users_firebase_uid ON users(firebase_uid);
-CREATE INDEX idx_users_email ON users(email);
-CREATE INDEX idx_users_role ON users(role);
-CREATE INDEX idx_users_is_active ON users(is_active);
-
-CREATE INDEX idx_components_component_id ON components(component_id);
-CREATE INDEX idx_components_category ON components(category);
-CREATE INDEX idx_components_name ON components USING gin(name gin_trgm_ops);
-
-CREATE INDEX idx_component_integrations_component_id ON component_integrations(component_id);
-CREATE INDEX idx_component_integrations_status ON component_integrations(status);
-
-CREATE INDEX idx_deployments_environment ON deployments(environment);
-CREATE INDEX idx_deployments_status ON deployments(status);
-CREATE INDEX idx_deployments_start_time ON deployments(start_time DESC);
-
-CREATE INDEX idx_activity_logs_user_id ON activity_logs(user_id);
-CREATE INDEX idx_activity_logs_action ON activity_logs(action);
-CREATE INDEX idx_activity_logs_timestamp ON activity_logs(timestamp DESC);
-
-CREATE INDEX idx_system_activity_action ON system_activity(action);
-CREATE INDEX idx_system_activity_timestamp ON system_activity(timestamp DESC);
-
-CREATE INDEX idx_download_trends_date ON download_trends(date DESC);
-CREATE INDEX idx_download_trends_package ON download_trends(package_name);
-
-CREATE INDEX idx_npm_versions_published_at ON npm_versions(published_at DESC);
-CREATE INDEX idx_npm_versions_version ON npm_versions(version);
-
-CREATE INDEX idx_audit_logs_timestamp ON audit_logs(timestamp DESC);
-CREATE INDEX idx_audit_logs_action ON audit_logs(action);
-CREATE INDEX idx_audit_logs_user_id ON audit_logs(user_id);
-
-CREATE INDEX idx_firebase_usage_service ON firebase_usage(service);
-CREATE INDEX idx_firebase_usage_created_at ON firebase_usage(created_at DESC);
-
--- Triggers for updated_at timestamps
-CREATE OR REPLACE FUNCTION update_updated_at_column()
-RETURNS TRIGGER AS $$
-BEGIN
- NEW.updated_at = NOW();
- RETURN NEW;
-END;
-$$ language 'plpgsql';
-
-CREATE TRIGGER update_users_updated_at BEFORE UPDATE ON users
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
-CREATE TRIGGER update_components_updated_at BEFORE UPDATE ON components
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
-CREATE TRIGGER update_component_integrations_updated_at BEFORE UPDATE ON component_integrations
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
-CREATE TRIGGER update_deployments_updated_at BEFORE UPDATE ON deployments
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
-CREATE TRIGGER update_environments_updated_at BEFORE UPDATE ON environments
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
-CREATE TRIGGER update_cloud_functions_updated_at BEFORE UPDATE ON cloud_functions
- FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-
--- Insert default roles
-INSERT INTO roles (id, name, permissions, is_custom) VALUES
-('admin', 'Administrator', '{"deployments": ["read", "write", "deploy", "rollback"], "users": ["read", "write", "delete", "create", "assign_roles"], "components": ["read", "write"], "settings": ["read", "write"]}', false),
-('developer', 'Developer', '{"deployments": ["read", "deploy", "rollback"], "components": ["read", "write"], "users": ["read"]}', false),
-('viewer', 'Viewer', '{"deployments": ["read"], "components": ["read"], "users": ["read"]}', false);
-
--- Insert default environments
-INSERT INTO environments (name, status) VALUES
-('production', 'unknown'),
-('staging', 'unknown'),
-('development', 'unknown');
\ No newline at end of file
diff --git a/apps/blend-monitor/middleware.ts b/apps/blend-monitor/middleware.ts
deleted file mode 100644
index 863a77f9a..000000000
--- a/apps/blend-monitor/middleware.ts
+++ /dev/null
@@ -1,27 +0,0 @@
-import { NextResponse } from 'next/server'
-import type { NextRequest } from 'next/server'
-
-export function middleware(request: NextRequest) {
- const path = request.nextUrl.pathname
-
- // Define public paths that don't require authentication
- const isPublicPath = path === '/login'
-
- // For now, we'll let the client-side handle auth redirects
- // since Firebase auth state is managed client-side
- return NextResponse.next()
-}
-
-// Configure which routes the middleware should run on
-export const config = {
- matcher: [
- /*
- * Match all request paths except for the ones starting with:
- * - api (API routes)
- * - _next/static (static files)
- * - _next/image (image optimization files)
- * - favicon.ico (favicon file)
- */
- '/((?!api|_next/static|_next/image|favicon.ico).*)',
- ],
-}
diff --git a/apps/blend-monitor/next.config.ts b/apps/blend-monitor/next.config.ts
deleted file mode 100644
index 23c3c7fae..000000000
--- a/apps/blend-monitor/next.config.ts
+++ /dev/null
@@ -1,35 +0,0 @@
-import type { NextConfig } from 'next'
-
-const nextConfig: NextConfig = {
- output: 'standalone',
- // Transpile workspace packages
- transpilePackages: ['@juspay/blend-design-system'],
- webpack: (config, { isServer }) => {
- if (!isServer) {
- // Don't resolve 'net', 'tls', 'fs' modules on the client side
- config.resolve.fallback = {
- ...config.resolve.fallback,
- net: false,
- tls: false,
- fs: false,
- dns: false,
- child_process: false,
- http2: false,
- }
- }
-
- return config
- },
- // Ensure server-only code doesn't leak to client
- serverExternalPackages: [],
- // Disable image optimization for Docker deployment
- images: {
- unoptimized: true,
- },
- // Environment variables for build time
- env: {
- SKIP_BUILD_STATIC_GENERATION: process.env.CI ? 'true' : 'false',
- },
-}
-
-export default nextConfig
diff --git a/apps/blend-monitor/package.json b/apps/blend-monitor/package.json
deleted file mode 100644
index 1184f493a..000000000
--- a/apps/blend-monitor/package.json
+++ /dev/null
@@ -1,40 +0,0 @@
-{
- "name": "blend-monitor",
- "version": "0.1.0",
- "private": true,
- "scripts": {
- "dev": "next dev",
- "build": "next build",
- "start": "next start",
- "lint": "next lint",
- "db:init": "node scripts/init-database.js",
- "cleanup": "node scripts/cleanup-empty-dirs.js",
- "populate-data": "node scripts/populate-all-deployment-data.js"
- },
- "dependencies": {
- "@types/pg": "^8.15.4",
- "@juspay/blend-design-system": "workspace:*",
- "dotenv": "^17.2.1",
- "firebase": "^11.10.0",
- "firebase-admin": "^12.7.0",
- "googleapis": "^153.0.0",
- "lucide-react": "^0.525.0",
- "next": "15.4.8",
- "pg": "^8.16.3",
- "react": "19.1.2",
- "react-dom": "19.1.2",
- "react-spinners": "^0.17.0"
- },
- "devDependencies": {
- "@eslint/eslintrc": "^3",
- "@tailwindcss/postcss": "^4",
- "@types/node": "^20",
- "@types/react": "^19",
- "@types/react-dom": "^19",
- "@types/uuid": "^10.0.0",
- "eslint": "^9",
- "eslint-config-next": "15.4.1",
- "tailwindcss": "^4",
- "typescript": "^5"
- }
-}
diff --git a/apps/blend-monitor/postcss.config.mjs b/apps/blend-monitor/postcss.config.mjs
deleted file mode 100644
index cf7ba0378..000000000
--- a/apps/blend-monitor/postcss.config.mjs
+++ /dev/null
@@ -1,5 +0,0 @@
-const config = {
- plugins: ['@tailwindcss/postcss'],
-}
-
-export default config
diff --git a/apps/blend-monitor/src/README.md b/apps/blend-monitor/src/README.md
deleted file mode 100644
index 776fbe6f2..000000000
--- a/apps/blend-monitor/src/README.md
+++ /dev/null
@@ -1,52 +0,0 @@
-# Blend Monitor - Modular Architecture
-
-This application follows a modular architecture with clear separation between frontend and backend code.
-
-## Directory Structure
-
-```
-src/
-βββ frontend/ # Client-side code
-β βββ app/ # Next.js pages
-β βββ components/ # React components
-β βββ contexts/ # React contexts
-β βββ hooks/ # Custom React hooks
-β βββ lib/ # Frontend utilities
-β βββ services/ # API client services
-β
-βββ backend/ # Server-side code
-β βββ api/ # API route handlers
-β βββ external/ # External API clients
-β βββ lib/ # Backend utilities
-β βββ repositories/ # Data access layer
-β βββ scanners/ # Data scanners
-β βββ services/ # Business logic
-β
-βββ shared/ # Shared code
- βββ constants/ # Shared constants
- βββ types/ # TypeScript types
-```
-
-## Key Principles
-
-1. **Separation of Concerns**: Frontend and backend code are completely separated
-2. **Layered Architecture**: Clear layers for API, services, and data access
-3. **Shared Types**: Common types are shared between frontend and backend
-4. **Re-export Pattern**: The root `/app` directory re-exports from `/src`
-
-## Import Aliases
-
-- `@/frontend/*` - Frontend code
-- `@/backend/*` - Backend code
-- `@/shared/*` - Shared code
-- `@/*` - Root imports (legacy)
-
-## Migration Notes
-
-### Old Structure β New Structure
-
-- `/lib` β `/src/backend/lib`
-- `/components` β `/src/frontend/components`
-- `/hooks` β `/src/frontend/hooks`
-- `/types` β `/src/shared/types`
-- `/app/api` β `/src/backend/api` (with re-exports in `/app/api`)
diff --git a/apps/blend-monitor/src/backend/api/activity/recent/route.ts b/apps/blend-monitor/src/backend/api/activity/recent/route.ts
deleted file mode 100644
index d7c723f53..000000000
--- a/apps/blend-monitor/src/backend/api/activity/recent/route.ts
+++ /dev/null
@@ -1,23 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-// GET /api/activity/recent - Get recent activity
-export async function GET(request: Request) {
- try {
- await initializeDatabase()
-
- const { searchParams } = new URL(request.url)
- const limit = parseInt(searchParams.get('limit') || '10')
-
- const activities = await databaseService.getRecentActivity(limit)
-
- return NextResponse.json(activities)
- } catch (error) {
- console.error('Error fetching recent activity:', error)
- return NextResponse.json(
- { error: 'Failed to fetch recent activity' },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/components/components-pg/route.ts b/apps/blend-monitor/src/backend/api/components/components-pg/route.ts
deleted file mode 100644
index 9969cf1d7..000000000
--- a/apps/blend-monitor/src/backend/api/components/components-pg/route.ts
+++ /dev/null
@@ -1,172 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { ComponentScanner } from '@/backend/scanners/component-scanner'
-import { initializeDatabase } from '@/backend/lib/database'
-import {
- authenticateRequest,
- requirePermission,
-} from '@/backend/lib/auth-middleware'
-
-// GET /api/components-pg - Fetch components from PostgreSQL
-export async function GET(request: NextRequest) {
- try {
- // Ensure database is initialized
- await initializeDatabase()
-
- // Authenticate the request
- const user = await authenticateRequest(request)
-
- // Check permissions - users with 'read' permission can view components
- const permissionCheck = await requirePermission('components', 'read')(
- request,
- user
- )
- if (permissionCheck) {
- return permissionCheck
- }
-
- const components = await databaseService.getComponents()
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- return NextResponse.json({
- components,
- coverage,
- categories,
- lastUpdated: new Date().toISOString(),
- })
- } catch (error) {
- console.error('Error fetching components:', error)
- return NextResponse.json(
- {
- error: 'Failed to fetch components',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-// POST /api/components-pg - Scan and update components in PostgreSQL
-export async function POST(request: NextRequest) {
- try {
- console.log('Starting component scan and database update...')
-
- // Ensure database is initialized
- await initializeDatabase()
-
- // Authenticate the request
- const user = await authenticateRequest(request)
-
- // Check permissions - only admins can trigger component scans
- const permissionCheck = await requirePermission('components', 'write')(
- request,
- user
- )
- if (permissionCheck) {
- return permissionCheck
- }
-
- // Scan components from filesystem
- const scanner = new ComponentScanner()
- const components = await scanner.scanComponents()
-
- console.log(`Found ${components.length} components`)
-
- // Batch update components in PostgreSQL
- await databaseService.batchUpsertComponents(components)
-
- // Calculate and save coverage metrics
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- // Save coverage snapshot for historical tracking
- await databaseService.saveCoverageMetrics(coverage, categories)
-
- // Log system activity
- await databaseService.logSystemActivity('component_scan', {
- componentsFound: components.length,
- coverage: coverage.percentage,
- timestamp: new Date().toISOString(),
- })
-
- console.log('Component scan completed successfully')
-
- return NextResponse.json({
- success: true,
- message: 'Components updated successfully',
- data: {
- components,
- coverage,
- categories,
- summary: {
- total: components.length,
- integrated: components.filter((c) => c.hasFigmaConnect)
- .length,
- withStorybook: components.filter((c) => c.hasStorybook)
- .length,
- withTests: components.filter((c) => c.hasTests).length,
- },
- },
- })
- } catch (error) {
- console.error('Error updating components:', error)
- return NextResponse.json(
- {
- error: 'Failed to update components',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-// Additional endpoints for specific component operations
-
-// GET /api/components-pg/coverage - Get coverage metrics
-export async function getCoverage() {
- try {
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- return NextResponse.json({
- coverage,
- categories,
- lastUpdated: new Date().toISOString(),
- })
- } catch (error) {
- console.error('Error fetching coverage:', error)
- return NextResponse.json(
- { error: 'Failed to fetch coverage data' },
- { status: 500 }
- )
- }
-}
-
-// GET /api/components-pg/[id] - Get specific component
-export async function getComponent(
- request: Request,
- { params }: { params: { id: string } }
-) {
- try {
- const { id } = params
- const component = await databaseService.getComponentById(id)
-
- if (!component) {
- return NextResponse.json(
- { error: 'Component not found' },
- { status: 404 }
- )
- }
-
- return NextResponse.json({ component })
- } catch (error) {
- console.error('Error fetching component:', error)
- return NextResponse.json(
- { error: 'Failed to fetch component' },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/components/route.ts b/apps/blend-monitor/src/backend/api/components/route.ts
deleted file mode 100644
index ccdf02ffc..000000000
--- a/apps/blend-monitor/src/backend/api/components/route.ts
+++ /dev/null
@@ -1,144 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { ComponentScanner } from '@/backend/scanners/component-scanner'
-import { initializeDatabase } from '@/backend/lib/database'
-
-// GET /api/components-pg - Fetch components from PostgreSQL
-export async function GET() {
- try {
- // Ensure database is initialized
- await initializeDatabase()
-
- const components = await databaseService.getComponents()
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- return NextResponse.json({
- components,
- coverage,
- categories,
- lastUpdated: new Date().toISOString(),
- })
- } catch (error) {
- console.error('Error fetching components:', error)
- return NextResponse.json(
- {
- error: 'Failed to fetch components',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-// POST /api/components-pg - Scan and update components in PostgreSQL
-export async function POST() {
- try {
- console.log('Starting component scan and database update...')
-
- // Ensure database is initialized
- await initializeDatabase()
-
- // Scan components from filesystem
- const scanner = new ComponentScanner()
- const components = await scanner.scanComponents()
-
- console.log(`Found ${components.length} components`)
-
- // Batch update components in PostgreSQL
- await databaseService.batchUpsertComponents(components)
-
- // Calculate and save coverage metrics
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- // Save coverage snapshot for historical tracking
- await databaseService.saveCoverageMetrics(coverage, categories)
-
- // Log system activity
- await databaseService.logSystemActivity('component_scan', {
- componentsFound: components.length,
- coverage: coverage.percentage,
- timestamp: new Date().toISOString(),
- })
-
- console.log('Component scan completed successfully')
-
- return NextResponse.json({
- success: true,
- message: 'Components updated successfully',
- data: {
- components,
- coverage,
- categories,
- summary: {
- total: components.length,
- integrated: components.filter((c) => c.hasFigmaConnect)
- .length,
- withStorybook: components.filter((c) => c.hasStorybook)
- .length,
- withTests: components.filter((c) => c.hasTests).length,
- },
- },
- })
- } catch (error) {
- console.error('Error updating components:', error)
- return NextResponse.json(
- {
- error: 'Failed to update components',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-// Additional endpoints for specific component operations
-
-// GET /api/components-pg/coverage - Get coverage metrics
-export async function getCoverage() {
- try {
- const coverage = await databaseService.getComponentCoverage()
- const categories = await databaseService.getCoverageByCategory()
-
- return NextResponse.json({
- coverage,
- categories,
- lastUpdated: new Date().toISOString(),
- })
- } catch (error) {
- console.error('Error fetching coverage:', error)
- return NextResponse.json(
- { error: 'Failed to fetch coverage data' },
- { status: 500 }
- )
- }
-}
-
-// GET /api/components-pg/[id] - Get specific component
-export async function getComponent(
- request: Request,
- { params }: { params: { id: string } }
-) {
- try {
- const { id } = params
- const component = await databaseService.getComponentById(id)
-
- if (!component) {
- return NextResponse.json(
- { error: 'Component not found' },
- { status: 404 }
- )
- }
-
- return NextResponse.json({ component })
- } catch (error) {
- console.error('Error fetching component:', error)
- return NextResponse.json(
- { error: 'Failed to fetch component' },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/health/route.ts b/apps/blend-monitor/src/backend/api/health/route.ts
deleted file mode 100644
index f77cc1cab..000000000
--- a/apps/blend-monitor/src/backend/api/health/route.ts
+++ /dev/null
@@ -1,80 +0,0 @@
-import { NextResponse } from 'next/server'
-import { checkDatabaseHealth } from '@/backend/lib/database'
-
-// GET /api/health - Check system health including database connectivity
-export async function GET() {
- const health = {
- status: 'unknown',
- timestamp: new Date().toISOString(),
- services: {
- database: {
- status: 'unknown',
- latency: null as number | null,
- error: null as string | null,
- },
- npm: {
- status: 'unknown',
- error: null as string | null,
- },
- },
- }
-
- // Test database connection
- try {
- const dbHealth = await checkDatabaseHealth()
- if (dbHealth.healthy) {
- health.services.database.status = 'healthy'
- health.services.database.latency = dbHealth.latency || null
- } else {
- health.services.database.status = 'unhealthy'
- health.services.database.error =
- dbHealth.error || 'Unknown database error'
- }
- } catch (error) {
- health.services.database.status = 'error'
- health.services.database.error =
- error instanceof Error
- ? error.message
- : 'Database connection failed'
- }
-
- // Test NPM API
- try {
- const npmResponse = await fetch(
- 'https://registry.npmjs.org/@juspay/blend-design-system',
- {
- method: 'HEAD',
- signal: AbortSignal.timeout(5000), // 5 second timeout
- }
- )
- if (npmResponse.ok) {
- health.services.npm.status = 'healthy'
- } else {
- health.services.npm.status = 'unhealthy'
- health.services.npm.error = `HTTP ${npmResponse.status}`
- }
- } catch (error) {
- health.services.npm.status = 'error'
- health.services.npm.error =
- error instanceof Error ? error.message : 'NPM registry unreachable'
- }
-
- // Overall health status
- const allHealthy = Object.values(health.services).every(
- (service) => service.status === 'healthy'
- )
- const anyError = Object.values(health.services).some(
- (service) => service.status === 'error'
- )
-
- health.status = allHealthy ? 'healthy' : anyError ? 'error' : 'degraded'
-
- const statusCode =
- health.status === 'healthy'
- ? 200
- : health.status === 'error'
- ? 503
- : 200
-
- return NextResponse.json(health, { status: statusCode })
-}
diff --git a/apps/blend-monitor/src/backend/api/npm/route.ts b/apps/blend-monitor/src/backend/api/npm/route.ts
deleted file mode 100644
index c90faf643..000000000
--- a/apps/blend-monitor/src/backend/api/npm/route.ts
+++ /dev/null
@@ -1,243 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { NPMClient } from '@/backend/external/npm-client'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-import { VersionInfo } from '@/shared/types'
-import {
- authenticateRequest,
- requirePermission,
-} from '@/backend/lib/auth-middleware'
-
-export async function GET(request: NextRequest) {
- try {
- // Initialize PostgreSQL database
- await initializeDatabase()
-
- // Authenticate the request
- const user = await authenticateRequest(request)
-
- // Check permissions - users with 'read' permission can view npm data
- const permissionCheck = await requirePermission('npm', 'read')(
- request,
- user
- )
- if (permissionCheck) {
- return permissionCheck
- }
-
- const npmClient = new NPMClient('@juspay/blend-design-system')
-
- let successfulOperations = 0
- const errors: string[] = []
-
- // Fetch package stats with fallback
- let packageStats = null
- try {
- packageStats = await npmClient.getPackageStats()
- if (packageStats) {
- await databaseService.savePackageStats(packageStats)
- successfulOperations++
- } else {
- // Try to get from database as fallback
- packageStats = await databaseService.getPackageStats()
- errors.push(
- 'Failed to fetch package stats from NPM, using cached data'
- )
- }
- } catch (error) {
- console.error('Error fetching package stats:', error)
- packageStats = await databaseService.getPackageStats()
- errors.push(
- `Package stats error: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Fetch download trends with fallback
- let downloadTrends: { date: string; downloads: number }[] = []
- try {
- downloadTrends = await npmClient.getDownloadTrends(30)
- if (downloadTrends.length > 0) {
- for (const trend of downloadTrends) {
- await databaseService.saveDownloadTrend(
- trend.date,
- trend.downloads
- )
- }
- successfulOperations++
- } else {
- // Try to get from database as fallback
- downloadTrends = await databaseService.getDownloadTrends(30)
- errors.push(
- 'Failed to fetch download trends from NPM, using cached data'
- )
- }
- } catch (error) {
- console.error('Error fetching download trends:', error)
- downloadTrends = await databaseService.getDownloadTrends(30)
- errors.push(
- `Download trends error: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Fetch version history with fallback
- let versionHistory: VersionInfo[] = []
- try {
- versionHistory = await npmClient.getVersionHistory()
- if (versionHistory.length > 0) {
- for (const version of versionHistory) {
- await databaseService.saveVersionInfo(version)
- }
- successfulOperations++
- } else {
- // Try to get from database as fallback
- versionHistory = await databaseService.getVersionHistory()
- errors.push(
- 'Failed to fetch version history from NPM, using cached data'
- )
- }
- } catch (error) {
- console.error('Error fetching version history:', error)
- versionHistory = await databaseService.getVersionHistory()
- errors.push(
- `Version history error: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Fetch package size history with fallback
- let sizeHistory: { version: string; size: number; date: string }[] = []
- try {
- sizeHistory = await npmClient.getPackageSizeHistory()
- successfulOperations++
- } catch (error) {
- console.error('Error fetching package size history:', error)
- sizeHistory = []
- errors.push(
- `Size history error: ${error instanceof Error ? error.message : 'Unknown error'}`
- )
- }
-
- // Log system activity
- try {
- await databaseService.logSystemActivity('npm_stats_updated', {
- version: packageStats?.version || 'unknown',
- downloads: packageStats?.downloads?.total || 0,
- successfulOperations,
- errors: errors.length,
- timestamp: new Date().toISOString(),
- })
- } catch (error) {
- console.error('Error logging system activity:', error)
- }
-
- // Return success even if some operations failed
- return NextResponse.json({
- success: true,
- data: {
- packageStats,
- downloadTrends,
- versionHistory,
- sizeHistory,
- },
- metadata: {
- successfulOperations,
- totalOperations: 4,
- errors: errors.length > 0 ? errors : undefined,
- lastUpdated: new Date().toISOString(),
- fallbackUsed: errors.length > 0,
- },
- })
- } catch (error) {
- console.error('Error in NPM API:', error)
-
- // Try to return cached data even on complete failure
- try {
- await initializeDatabase()
- const packageStats = await databaseService.getPackageStats()
- const downloadTrends = await databaseService.getDownloadTrends(30)
- const versionHistory = await databaseService.getVersionHistory()
-
- return NextResponse.json({
- success: true,
- data: {
- packageStats,
- downloadTrends,
- versionHistory,
- sizeHistory: [],
- },
- metadata: {
- successfulOperations: 0,
- totalOperations: 4,
- errors: [
- 'Complete NPM API failure, using cached data only',
- ],
- lastUpdated: new Date().toISOString(),
- fallbackUsed: true,
- },
- })
- } catch (fallbackError) {
- console.error('Error fetching fallback data:', fallbackError)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to fetch NPM data and no cached data available',
- details:
- error instanceof Error
- ? error.message
- : 'Unknown error',
- },
- { status: 500 }
- )
- }
- }
-}
-
-// POST endpoint to trigger NPM data refresh
-export async function POST(request: NextRequest) {
- try {
- await initializeDatabase()
-
- // Authenticate the request
- const user = await authenticateRequest(request)
-
- // Check permissions - only admins can trigger npm refresh
- const permissionCheck = await requirePermission('npm', 'write')(
- request,
- user
- )
- if (permissionCheck) {
- return permissionCheck
- }
-
- // Trigger NPM data fetch and update
- const response = await fetch(
- `${process.env.NEXTAUTH_URL || 'http://localhost:3003'}/api/npm`,
- {
- method: 'GET',
- }
- )
-
- if (!response.ok) {
- throw new Error('Failed to refresh NPM data')
- }
-
- const data = await response.json()
-
- return NextResponse.json({
- success: true,
- message: 'NPM data refreshed successfully',
- lastUpdated: new Date().toISOString(),
- metadata: data.metadata,
- })
- } catch (error) {
- console.error('Error refreshing NPM data:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to refresh NPM data',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/npm/stats/route.ts b/apps/blend-monitor/src/backend/api/npm/stats/route.ts
deleted file mode 100644
index efb6672dd..000000000
--- a/apps/blend-monitor/src/backend/api/npm/stats/route.ts
+++ /dev/null
@@ -1,68 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-import { NPMClient } from '@/backend/external/npm-client'
-
-// GET /api/npm/stats - Get NPM package statistics
-export async function GET() {
- let dbError: string | null = null
- let npmError: string | null = null
-
- // Try database first
- try {
- await initializeDatabase()
- const packageStats = await databaseService.getPackageStats()
-
- if (packageStats) {
- console.log('Returning package stats from database')
- return NextResponse.json(packageStats)
- }
- console.log('Database connected but no stats found')
- } catch (error) {
- dbError =
- error instanceof Error
- ? error.message
- : 'Database connection failed'
- console.error('Database error:', dbError)
- }
-
- // Try NPM API as fallback
- try {
- console.log('Trying NPM API for package stats...')
- const npmClient = new NPMClient('@juspay/blend-design-system')
- const stats = await npmClient.getPackageStats()
-
- if (stats) {
- // Try to save to database if it's available
- if (!dbError) {
- try {
- await databaseService.savePackageStats(stats)
- console.log('Fetched and saved package stats from NPM')
- } catch (saveError) {
- console.warn('Could not save to database:', saveError)
- }
- }
-
- console.log('Returning package stats from NPM API')
- return NextResponse.json(stats)
- }
- npmError = 'No package stats available from NPM'
- } catch (error) {
- npmError = error instanceof Error ? error.message : 'NPM API failed'
- console.error('NPM API error:', npmError)
- }
-
- // Both sources failed - return error with details
- return NextResponse.json(
- {
- error: 'Unable to fetch package statistics',
- details: {
- database: dbError || 'Connected but no data found',
- npm: npmError || 'Unknown error',
- suggestion:
- 'Check database connection and NPM API availability',
- },
- },
- { status: 503 } // Service Unavailable
- )
-}
diff --git a/apps/blend-monitor/src/backend/api/npm/sync/route.ts b/apps/blend-monitor/src/backend/api/npm/sync/route.ts
deleted file mode 100644
index 39807469b..000000000
--- a/apps/blend-monitor/src/backend/api/npm/sync/route.ts
+++ /dev/null
@@ -1,130 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-// POST /api/npm/sync - Manually trigger NPM data synchronization
-export async function POST() {
- try {
- console.log('Starting NPM data synchronization...')
- await initializeDatabase()
-
- const startTime = Date.now()
- const syncResult = await databaseService.syncNPMData()
- const duration = Date.now() - startTime
-
- const summary = {
- success: true,
- duration: `${duration}ms`,
- results: {
- versions: {
- total:
- syncResult.versions.saved + syncResult.versions.updated,
- new: syncResult.versions.saved,
- updated: syncResult.versions.updated,
- },
- trends: {
- saved: syncResult.trends.saved,
- },
- stats: {
- updated: syncResult.stats.updated,
- },
- },
- errors: syncResult.errors,
- hasErrors: syncResult.errors.length > 0,
- timestamp: new Date().toISOString(),
- }
-
- console.log('NPM sync completed:', summary)
-
- return NextResponse.json(summary)
- } catch (error) {
- console.error('NPM sync failed:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to sync NPM data',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- timestamp: new Date().toISOString(),
- },
- { status: 500 }
- )
- }
-}
-
-// GET /api/npm/sync - Get sync status/info
-export async function GET() {
- try {
- await initializeDatabase()
-
- // Get latest version info from database
- const latestVersion =
- await databaseService.getLatestVersionFromDatabase()
-
- // Get database statistics
- const [versionsResult, trendsResult, statsResult] =
- await Promise.allSettled([
- databaseService.getVersionHistory(),
- databaseService.getDownloadTrends(30),
- databaseService.getPackageStats(),
- ])
-
- const status = {
- database: {
- versions: {
- count:
- versionsResult.status === 'fulfilled'
- ? versionsResult.value.length
- : 0,
- latest: latestVersion,
- lastUpdate: 'Unknown',
- },
- trends: {
- count:
- trendsResult.status === 'fulfilled'
- ? trendsResult.value.length
- : 0,
- lastUpdate: 'Unknown',
- },
- stats: {
- hasData:
- statsResult.status === 'fulfilled' &&
- statsResult.value !== null,
- version:
- statsResult.status === 'fulfilled' && statsResult.value
- ? statsResult.value.version
- : null,
- lastUpdate: 'Unknown',
- },
- },
- lastSyncAttempt: 'Manual trigger only',
- nextScheduledSync: 'Not scheduled',
- recommendations: [] as string[],
- }
-
- // Add recommendations based on data status
- if (status.database.versions.count === 0) {
- status.recommendations.push('Run sync to populate version history')
- }
- if (status.database.trends.count < 30) {
- status.recommendations.push(
- 'Run sync to get complete download trends'
- )
- }
- if (!status.database.stats.hasData) {
- status.recommendations.push('Run sync to get package statistics')
- }
-
- return NextResponse.json(status)
- } catch (error) {
- console.error('Error getting sync status:', error)
- return NextResponse.json(
- {
- error: 'Failed to get sync status',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/npm/trends/route.ts b/apps/blend-monitor/src/backend/api/npm/trends/route.ts
deleted file mode 100644
index 282c0c3eb..000000000
--- a/apps/blend-monitor/src/backend/api/npm/trends/route.ts
+++ /dev/null
@@ -1,77 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-import { NPMClient } from '@/backend/external/npm-client'
-
-// GET /api/npm/trends - Get NPM download trends
-export async function GET() {
- let dbError: string | null = null
- let npmError: string | null = null
-
- // Try database first
- try {
- await initializeDatabase()
- const trends = await databaseService.getDownloadTrends(30)
-
- if (trends && trends.length > 0) {
- console.log(`Returning ${trends.length} trends from database`)
- return NextResponse.json(trends)
- }
- console.log('Database connected but no trends found')
- } catch (error) {
- dbError =
- error instanceof Error
- ? error.message
- : 'Database connection failed'
- console.error('Database error:', dbError)
- }
-
- // Try NPM API as fallback
- try {
- console.log('Trying NPM API for download trends...')
- const npmClient = new NPMClient('@juspay/blend-design-system')
- const downloadTrends = await npmClient.getDownloadTrends(30)
-
- if (downloadTrends && downloadTrends.length > 0) {
- // Try to save to database if it's available
- if (!dbError) {
- try {
- for (const trend of downloadTrends) {
- await databaseService.saveDownloadTrend(
- trend.date,
- trend.downloads
- )
- }
- console.log(
- `Fetched and saved ${downloadTrends.length} trends from NPM`
- )
- } catch (saveError) {
- console.warn('Could not save to database:', saveError)
- }
- }
-
- console.log(
- `Returning ${downloadTrends.length} trends from NPM API`
- )
- return NextResponse.json(downloadTrends)
- }
- npmError = 'No trend data available from NPM'
- } catch (error) {
- npmError = error instanceof Error ? error.message : 'NPM API failed'
- console.error('NPM API error:', npmError)
- }
-
- // Both sources failed - return error with details
- return NextResponse.json(
- {
- error: 'Unable to fetch download trends',
- details: {
- database: dbError || 'Connected but no data found',
- npm: npmError || 'Unknown error',
- suggestion:
- 'Check database connection and NPM API availability',
- },
- },
- { status: 503 } // Service Unavailable
- )
-}
diff --git a/apps/blend-monitor/src/backend/api/npm/versions/route.ts b/apps/blend-monitor/src/backend/api/npm/versions/route.ts
deleted file mode 100644
index d2848057f..000000000
--- a/apps/blend-monitor/src/backend/api/npm/versions/route.ts
+++ /dev/null
@@ -1,73 +0,0 @@
-import { NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-import { NPMClient } from '@/backend/external/npm-client'
-
-export async function GET() {
- let dbError: string | null = null
- let npmError: string | null = null
-
- // Try database first
- try {
- await initializeDatabase()
- const versions = await databaseService.getVersionHistory()
-
- if (versions && versions.length > 0) {
- console.log(`Returning ${versions.length} versions from database`)
- return NextResponse.json(versions)
- }
- console.log('Database connected but no versions found')
- } catch (error) {
- dbError =
- error instanceof Error
- ? error.message
- : 'Database connection failed'
- console.error('Database error:', dbError)
- }
-
- // Try NPM API as fallback
- try {
- console.log('Trying NPM API for version history...')
- const npmClient = new NPMClient('@juspay/blend-design-system')
- const versionHistory = await npmClient.getVersionHistory()
-
- if (versionHistory && versionHistory.length > 0) {
- // Try to save to database if it's available
- if (!dbError) {
- try {
- for (const version of versionHistory) {
- await databaseService.saveVersionInfo(version)
- }
- console.log(
- `Fetched and saved ${versionHistory.length} versions from NPM`
- )
- } catch (saveError) {
- console.warn('Could not save to database:', saveError)
- }
- }
-
- console.log(
- `Returning ${versionHistory.length} versions from NPM API`
- )
- return NextResponse.json(versionHistory)
- }
- npmError = 'No version data available from NPM'
- } catch (error) {
- npmError = error instanceof Error ? error.message : 'NPM API failed'
- console.error('NPM API error:', npmError)
- }
-
- // Both sources failed - return error with details
- return NextResponse.json(
- {
- error: 'Unable to fetch version history',
- details: {
- database: dbError || 'Connected but no data found',
- npm: npmError || 'Unknown error',
- suggestion:
- 'Check database connection and NPM API availability',
- },
- },
- { status: 503 } // Service Unavailable
- )
-}
diff --git a/apps/blend-monitor/src/backend/api/users/[userId]/role/route.ts b/apps/blend-monitor/src/backend/api/users/[userId]/role/route.ts
deleted file mode 100644
index bbf98cb67..000000000
--- a/apps/blend-monitor/src/backend/api/users/[userId]/role/route.ts
+++ /dev/null
@@ -1,100 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import {
- authenticateRequest,
- requirePermission,
- logAuditEvent,
-} from '@/backend/lib/auth-middleware'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-export async function PUT(
- request: NextRequest,
- { params }: { params: { userId: string } }
-) {
- try {
- await initializeDatabase()
-
- // Authenticate the request
- const user = await authenticateRequest(request)
-
- // Check permissions
- const permissionCheck = await requirePermission('users', 'write')(
- request,
- user
- )
- if (permissionCheck) {
- return permissionCheck
- }
-
- const { newRole } = await request.json()
-
- if (!newRole) {
- return NextResponse.json(
- { error: 'New role is required' },
- { status: 400 }
- )
- }
-
- // Get current user data for audit logging
- const currentUserData = await databaseService.getUserByFirebaseUid(
- params.userId
- )
- if (!currentUserData) {
- return NextResponse.json(
- { error: 'User not found' },
- { status: 404 }
- )
- }
-
- const oldRole = currentUserData.role
-
- // Update the user role
- await databaseService.updateUserRole(params.userId, newRole)
-
- // Log the audit event
- await logAuditEvent(
- user!,
- 'role_change',
- `user:${params.userId}`,
- {
- targetUser: currentUserData.email,
- oldRole,
- newRole,
- userId: params.userId,
- },
- 'success'
- )
-
- return NextResponse.json({
- success: true,
- message: 'User role updated successfully',
- oldRole,
- newRole,
- })
- } catch (error) {
- console.error('Error updating user role:', error)
-
- // Log failed attempt
- const user = await authenticateRequest(request)
- if (user) {
- await logAuditEvent(
- user,
- 'role_change',
- `user:${params.userId}`,
- {
- error:
- error instanceof Error
- ? error.message
- : 'Unknown error',
- userId: params.userId,
- },
- 'failed'
- )
- }
-
- return NextResponse.json(
- { error: 'Failed to update user role' },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/users/[userId]/route.ts b/apps/blend-monitor/src/backend/api/users/[userId]/route.ts
deleted file mode 100644
index 2789d2956..000000000
--- a/apps/blend-monitor/src/backend/api/users/[userId]/route.ts
+++ /dev/null
@@ -1,115 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-export async function GET(
- request: NextRequest,
- { params }: { params: { userId: string } }
-) {
- try {
- await initializeDatabase()
-
- const user = await databaseService.getUserByFirebaseUid(params.userId)
-
- if (!user) {
- return NextResponse.json(
- { success: false, error: 'User not found' },
- { status: 404 }
- )
- }
-
- return NextResponse.json({
- success: true,
- user,
- })
- } catch (error) {
- console.error('Error fetching user:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to fetch user',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-export async function PATCH(
- request: NextRequest,
- { params }: { params: { userId: string } }
-) {
- try {
- await initializeDatabase()
-
- const body = await request.json()
- const { role, is_active, display_name } = body
-
- // Update user role if provided
- if (role !== undefined) {
- await databaseService.updateUserRole(params.userId, role)
- }
-
- // Update user status if provided
- if (is_active !== undefined) {
- await databaseService.updateUserStatus(params.userId, is_active)
- }
-
- // Update display name if provided
- if (display_name !== undefined) {
- await databaseService.updateUserDisplayName(
- params.userId,
- display_name
- )
- }
-
- // Get updated user
- const updatedUser = await databaseService.getUserByFirebaseUid(
- params.userId
- )
-
- return NextResponse.json({
- success: true,
- user: updatedUser,
- })
- } catch (error) {
- console.error('Error updating user:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to update user',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-export async function DELETE(
- request: NextRequest,
- { params }: { params: { userId: string } }
-) {
- try {
- await initializeDatabase()
-
- await databaseService.deleteUser(params.userId)
-
- return NextResponse.json({
- success: true,
- message: 'User deleted successfully',
- })
- } catch (error) {
- console.error('Error deleting user:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to delete user',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/users/activity/route.ts b/apps/blend-monitor/src/backend/api/users/activity/route.ts
deleted file mode 100644
index 491591ab2..000000000
--- a/apps/blend-monitor/src/backend/api/users/activity/route.ts
+++ /dev/null
@@ -1,99 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-export async function POST(request: NextRequest) {
- try {
- await initializeDatabase()
-
- const body = await request.json()
- const { user_id, action, details } = body
-
- if (!user_id || !action) {
- return NextResponse.json(
- { success: false, error: 'user_id and action are required' },
- { status: 400 }
- )
- }
-
- // Get user from database using firebase_uid
- const user = await databaseService.getUserByFirebaseUid(user_id)
-
- if (!user) {
- return NextResponse.json(
- { success: false, error: 'User not found' },
- { status: 404 }
- )
- }
-
- // Log the activity
- await databaseService.logUserActivity(user.id, action, details)
-
- return NextResponse.json({
- success: true,
- message: 'Activity logged successfully',
- })
- } catch (error) {
- console.error('Error logging activity:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to log activity',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-export async function GET(request: NextRequest) {
- try {
- await initializeDatabase()
-
- const searchParams = request.nextUrl.searchParams
- const userId = searchParams.get('userId')
- const limit = searchParams.get('limit')
- const offset = searchParams.get('offset')
-
- if (!userId) {
- return NextResponse.json(
- { success: false, error: 'userId parameter is required' },
- { status: 400 }
- )
- }
-
- // Get user from database using firebase_uid
- const user = await databaseService.getUserByFirebaseUid(userId)
-
- if (!user) {
- return NextResponse.json(
- { success: false, error: 'User not found' },
- { status: 404 }
- )
- }
-
- const activities = await databaseService.getUserActivity(
- user.id,
- limit ? parseInt(limit) : undefined,
- offset ? parseInt(offset) : undefined
- )
-
- return NextResponse.json({
- success: true,
- activities,
- total: activities.length,
- })
- } catch (error) {
- console.error('Error fetching user activity:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to fetch user activity',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/api/users/route.ts b/apps/blend-monitor/src/backend/api/users/route.ts
deleted file mode 100644
index 51035293e..000000000
--- a/apps/blend-monitor/src/backend/api/users/route.ts
+++ /dev/null
@@ -1,83 +0,0 @@
-import { NextRequest, NextResponse } from 'next/server'
-import { databaseService } from '@/backend/lib/database-service'
-import { initializeDatabase } from '@/backend/lib/database'
-
-export async function GET(request: NextRequest) {
- try {
- await initializeDatabase()
-
- const searchParams = request.nextUrl.searchParams
- const limit = searchParams.get('limit')
- const offset = searchParams.get('offset')
-
- const users = await databaseService.getAllUsers(
- limit ? parseInt(limit) : undefined,
- offset ? parseInt(offset) : undefined
- )
-
- return NextResponse.json({
- success: true,
- users,
- total: users.length,
- })
- } catch (error) {
- console.error('Error fetching users:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to fetch users',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
-
-export async function POST(request: NextRequest) {
- try {
- await initializeDatabase()
-
- const body = await request.json()
- const {
- firebase_uid,
- email,
- display_name,
- photo_url,
- role = 'viewer',
- } = body
-
- if (!firebase_uid || !email) {
- return NextResponse.json(
- {
- success: false,
- error: 'firebase_uid and email are required',
- },
- { status: 400 }
- )
- }
-
- const user = await databaseService.createOrUpdateUser(firebase_uid, {
- email,
- displayName: display_name,
- photoURL: photo_url,
- role,
- })
-
- return NextResponse.json({
- success: true,
- user,
- })
- } catch (error) {
- console.error('Error creating/updating user:', error)
- return NextResponse.json(
- {
- success: false,
- error: 'Failed to create/update user',
- details:
- error instanceof Error ? error.message : 'Unknown error',
- },
- { status: 500 }
- )
- }
-}
diff --git a/apps/blend-monitor/src/backend/external/npm-client.ts b/apps/blend-monitor/src/backend/external/npm-client.ts
deleted file mode 100644
index 9b87c8115..000000000
--- a/apps/blend-monitor/src/backend/external/npm-client.ts
+++ /dev/null
@@ -1,301 +0,0 @@
-import { PackageStats, VersionInfo, DownloadTrend } from '@/shared/types'
-
-interface NPMPackageData {
- name: string
- version: string
- 'dist-tags': Record
- setInviteRole(value)}
- items={[
- {
- items: Object.entries(DEFAULT_ROLES).map(
- ([roleId, roleData]) => ({
- value: roleId,
- label: roleData.name,
- })
- ),
- },
- ]}
- placeholder="Select a role"
- />
-
-
-
-
-
- - {emailError} -
- )} -- Enter the email address of the user you want to - invite. -
-
-
-
- {getStatusIcon(row.status)}
-
- ),
- },
- {
- field: 'component' as keyof HealthStatus,
- header: 'Component',
- type: ColumnType.TEXT,
- renderCell: (value: unknown, row: HealthStatus) => (
- {row.component}
- ),
- },
- {
- field: 'lastSync' as keyof HealthStatus,
- header: 'Last Sync',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) => (
-
-
- ),
- },
- {
- field: 'syncRate' as keyof HealthStatus,
- header: 'Success Rate',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) => (
-
- (null)
- const [isSigningIn, setIsSigningIn] = useState(false)
- const [isRedirecting, setIsRedirecting] = useState(false)
-
- useEffect(() => {
- if (!loading && user) {
- setIsRedirecting(true)
- router.push('/')
- }
- }, [user, loading, router])
-
- const handleGoogleSignIn = async () => {
- setError(null)
- setIsSigningIn(true)
- try {
- await signInWithGoogle()
- // Show redirecting state after successful sign in
- setIsRedirecting(true)
- } catch (error) {
- setError(
- error instanceof Error
- ? error.message
- : 'Failed to sign in with Google'
- )
- setIsSigningIn(false)
- }
- }
-
- if (loading || isRedirecting) {
- return (
-
-}) {
- return (
-
-
- ),
- },
- {
- field: 'errors' as keyof HealthStatus,
- header: 'Issues',
- type: ColumnType.REACT_ELEMENT,
- isSortable: false,
- renderCell: (value: unknown, row: HealthStatus) =>
- row.errors.length > 0 ? (
- = 90
- ? 'bg-green-500'
- : row.syncRate >= 70
- ? 'bg-yellow-500'
- : 'bg-red-500'
- }`}
- style={{ width: `${row.syncRate}%` }}
- />
-
- {row.syncRate}%
-
- }
- size={ButtonSize.SMALL}
- onClick={() => setSelectedComponent(row.component)}
- />
- }
- size={ButtonSize.SMALL}
- buttonType={ButtonType.SECONDARY}
- />
-
- ),
- },
- ]
-
- if (loading) {
- return
-
- )
-}
diff --git a/apps/blend-monitor/src/frontend/app/code-connect/page.tsx b/apps/blend-monitor/src/frontend/app/code-connect/page.tsx
deleted file mode 100644
index 15c510b8b..000000000
--- a/apps/blend-monitor/src/frontend/app/code-connect/page.tsx
+++ /dev/null
@@ -1,20 +0,0 @@
-'use client'
-
-import React from 'react'
-import dynamic from 'next/dynamic'
-import Loader from '../../components/shared/Loader'
-
-// Dynamically import the component to avoid SSR issues
-const CodeConnectContent = dynamic(
- () => import('../../components/dashboard/CodeConnectContent'),
- {
- loading: () => (
-
-
-
- {/* Health Metrics */}
-
-
-
- }
- onClick={handleRefresh}
- disabled={refreshing}
- />
- - Integration Health Monitor -
-- Track the health and validity of Code Connect - integrations -
-
-
-
- {/* Alert Conditions */}
-
-
-
-
-
-
- - Active -
-- {metrics.active} -
-
-
-
-
-
-
- - Warnings -
-- {metrics.warning} -
-
-
-
-
-
-
- - Errors -
-- {metrics.error} -
-
-
-
-
-
-
- - Avg Success Rate -
-- {metrics.avgSyncRate.toFixed(1)}% -
-
- %
-
-
-
-
- {/* Health Status Grid */}
-
-
-
-
- - Active Alerts -
--
- {healthData
- .filter(
- (h) =>
- h.status === 'warning' ||
- h.status === 'error'
- )
- .map((h, idx) => (
-
- - β’ {h.component}:{' '} - {h.errors.join(', ') || - 'Integration failing'} - - ))} -
- []}
- columns={
- columns as ColumnDefinition>[]
- }
- idField="component"
- onRowClick={(row) =>
- setSelectedComponent(
- (row as unknown as HealthStatus).component
- )
- }
- />
-
-
- {/* Component Details Modal (placeholder) */}
- {selectedComponent && (
-
-
- - Component Health Status -
-
-
- )}
-
-
- - {selectedComponent} Details -
-- Component integration details would appear here... -
-
- {/* Keep the page content visible but dimmed */}
-
-
- )
- }
-
- return (
-
-
-
- {/* Logo and App Name inside card */}
-
-
-