Function insertAuditLog

packages/audit/src/log.ts:41–76

(params: AuditLogParams)

}

async function insertAuditLog(params: AuditLogParams): Promise<void> {
  const ipAddress = params.request ? getClientIp(params.request) : undefined
  const userAgent = params.request?.headers.get('user-agent') ?? undefined

  let { actorName, actorEmail } = params

  if (actorName === undefined && actorEmail === undefined && params.actorId) {
    try {
      const [row] = await db
        .select({ name: user.name, email: user.email })
        .from(user)
        .where(eq(user.id, params.actorId))
        .limit(1)
      actorName = row?.name ?? undefined
      actorEmail = row?.email ?? undefined
    } catch (error) {
      logger.warn('Failed to resolve actor info', { error, actorId: params.actorId })
    }
  }

  await db.insert(auditLog).values({
    id: generateShortId(),
    workspaceId: params.workspaceId || null,
    actorId: params.actorId,
    action: params.action,
    resourceType: params.resourceType,
    resourceId: params.resourceId,
    actorName: actorName ?? undefined,
    actorEmail: actorEmail ?? undefined,
    resourceName: params.resourceName,
    description: params.description,
    metadata: params.metadata ?? {},
    ipAddress,
    userAgent,
  })
}