Rithmic Integration

import { setRithmicSynchronization } from '@/app/[locale]/dashboard/components/import/rithmic/sync/actions'

const synchronization = {
  service: 'rithmic',
  accountId: 'your-account-id',
  lastSyncedAt: new Date()
}

await setRithmicSynchronization(synchronization)

import { getRithmicSynchronizations } from '@/app/[locale]/dashboard/components/import/rithmic/sync/actions'

const synchronizations = await getRithmicSynchronizations()

console.log('Active Rithmic synchronizations:', synchronizations)

{
  success: boolean
  data: Array<{
    userId: string
    service: 'rithmic'
    accountId: string
    lastSyncedAt: Date
    createdAt: Date
    updatedAt: Date
  }>
}

{
  service?: 'rithmic'     // Default: 'rithmic'
  accountId: string       // Required: Account identifier
  lastSyncedAt?: Date     // Optional: Last sync timestamp
}

{
  success: boolean
  message: string
}

{
  accountId: string  // Required: Account to remove
}

{
  success: boolean
  message: string
}

model Synchronization {
  userId         String
  service        String   // 'rithmic'
  accountId      String
  token          String?  // Not used for Rithmic
  tokenExpiresAt DateTime?
  lastSyncedAt   DateTime
  createdAt      DateTime @default(now())
  updatedAt      DateTime @updatedAt
  
  @@unique([userId, service, accountId])
}

await prisma.synchronization.upsert({
  where: { 
    userId_service_accountId: {
      userId: userId,
      service: 'rithmic',
      accountId: synchronization.accountId
    }
  },
  update: {
    lastSyncedAt: synchronization.lastSyncedAt || new Date(),
    updatedAt: new Date()
  },
  create: {
    userId: userId,
    service: 'rithmic',
    accountId: synchronization.accountId,
    lastSyncedAt: synchronization.lastSyncedAt || new Date()
  }
})

// DO NOT store plain-text credentials
// Instead, use encrypted storage or secure vaults

const encryptedCredentials = await encryptCredentials({
  username: rithmicUsername,
  password: rithmicPassword
})

await setRithmicSynchronization({
  accountId: accountId,
  token: encryptedCredentials  // Encrypted!
})

export async function getRithmicSynchronizations() {
  const userId = await getUserId()  // Get current user
  
  // Only return this user's synchronizations
  const synchronizations = await prisma.synchronization.findMany({
    where: { 
      userId: userId,      // User-specific
      service: "rithmic" 
    },
  })
  
  return synchronizations
}

const syncs = await getRithmicSynchronizations()
if (syncs.length === 0) {
  console.log('No synchronizations configured')
}

syncs.forEach(sync => {
  const hoursSinceSync = 
    (Date.now() - sync.lastSyncedAt.getTime()) / (1000 * 60 * 60)
  console.log(`Last synced ${hoursSinceSync.toFixed(1)} hours ago`)
})