Implement weekly email schedule job (#2022)

We want to send an email with relevant data for the organizations using
Latitude. We'll do the processing of this data on monday 1:00 A.M and it
will be sent to be ready on users' inbox on monday morning

Author: andresgutgon

apps/web/src/actions/admin/weeklyEmail/enqueueWeeklyEmail.ts

@@ -0,0 +1,38 @@
+'use server'
+
+import { withAdmin } from '../../procedures'
+import { z } from 'zod'
+import { queues } from '@latitude-data/core/queues'
+
+export const enqueueWeeklyEmailAction = withAdmin
+  .inputSchema(
+    z.object({
+      workspaceId: z.number(),
+      emails: z.string().optional(),
+    }),
+  )
+  .action(async ({ parsedInput }) => {
+    const { workspaceId, emails } = parsedInput
+
+    // Parse comma-separated emails if provided
+    const emailList = emails
+      ? emails
+          .split(',')
+          .map((e) => e.trim())
+          .filter((e) => e.length > 0)
+      : undefined
+
+    const { maintenanceQueue } = await queues()
+    await maintenanceQueue.add(
+      'sendWeeklyEmailJob',
+      {
+        workspaceId,
+        emails: emailList,
+      },
+      {
+        jobId: `weekly-email-manual-${workspaceId}-${Date.now()}`,
+      },
+    )
+
+    return { success: true }
+  })

apps/web/src/app/(admin)/backoffice/_components/BackofficeTabs/index.tsx

@@ -61,6 +61,11 @@ export function BackofficeTabs({ children }: { children: ReactNode }) {
               value: BackofficeRoutes.integrations,
               route: ROUTES.backoffice.integrations.root,
             },
+            {
+              label: 'Weekly',
+              value: BackofficeRoutes.weekly,
+              route: ROUTES.backoffice.weekly.root,
+            },
           ]}
           selected={selected}
         />

apps/web/src/app/(admin)/backoffice/search/workspace/[id]/_components/WorkspaceDashboard/index.tsx

@@ -92,6 +92,15 @@ export function WorkspaceDashboard({ workspace }: Props) {
             issuesUnlocked={workspace.issuesUnlocked}
           />
           <div className='flex gap-2'>
+            <Link
+              href={ROUTES.backoffice[BackofficeRoutes.weekly].withWorkspaceId(
+                workspace.id,
+              )}
+            >
+              <Button fancy variant='outline'>
+                <Text.H5B noWrap>See Weekly</Text.H5B>
+              </Button>
+            </Link>
             <ChangePlanButton
               workspaceId={workspace.id}
               currentPlan={workspace.subscription.plan}

apps/web/src/app/(admin)/backoffice/weekly/_components/WeeklyEmailForm/index.tsx

@@ -0,0 +1,109 @@
+'use client'
+
+import { FormEvent, useCallback, useEffect, useState } from 'react'
+import { useSearchParams } from 'next/navigation'
+import { Button } from '@latitude-data/web-ui/atoms/Button'
+import { Input } from '@latitude-data/web-ui/atoms/Input'
+import { TextArea } from '@latitude-data/web-ui/atoms/TextArea'
+import { Text } from '@latitude-data/web-ui/atoms/Text'
+import { useToast } from '@latitude-data/web-ui/atoms/Toast'
+import { enqueueWeeklyEmailAction } from '$/actions/admin/weeklyEmail/enqueueWeeklyEmail'
+import useLatitudeAction from '$/hooks/useLatitudeAction'
+
+export function WeeklyEmailForm() {
+  const searchParams = useSearchParams()
+  const { toast } = useToast()
+  const [workspaceId, setWorkspaceId] = useState('')
+  const [emails, setEmails] = useState('')
+
+  // Pre-fill workspaceId from query params if present
+  useEffect(() => {
+    const workspaceIdParam = searchParams.get('workspaceId')
+    if (workspaceIdParam) {
+      setWorkspaceId(workspaceIdParam)
+    }
+  }, [searchParams])
+
+  const { execute: enqueueEmail, isPending } = useLatitudeAction(
+    enqueueWeeklyEmailAction,
+    {
+      onSuccess: () => {
+        toast({
+          title: 'Success',
+          description: 'Weekly email job has been enqueued successfully',
+        })
+        // Clear form
+        setWorkspaceId('')
+        setEmails('')
+      },
+      onError: (error) => {
+        toast({
+          title: 'Error',
+          description: error.message,
+          variant: 'destructive',
+        })
+      },
+    },
+  )
+
+  const handleSubmit = useCallback(
+    (e: FormEvent) => {
+      e.preventDefault()
+
+      const parsedWorkspaceId = parseInt(workspaceId)
+      if (isNaN(parsedWorkspaceId)) {
+        toast({
+          title: 'Invalid Workspace ID',
+          description: 'Please enter a valid numeric workspace ID',
+          variant: 'destructive',
+        })
+        return
+      }
+
+      enqueueEmail({
+        workspaceId: parsedWorkspaceId,
+        emails: emails.trim() || undefined,
+      })
+    },
+    [workspaceId, emails, enqueueEmail, toast],
+  )
+
+  return (
+    <form onSubmit={handleSubmit} className='flex flex-col gap-y-4 max-w-2xl'>
+      <div className='flex flex-col gap-y-2'>
+        <Text.H5 weight='medium'>Workspace ID</Text.H5>
+        <Input
+          type='number'
+          placeholder='Enter workspace ID'
+          value={workspaceId}
+          onChange={(e) => setWorkspaceId(e.target.value)}
+          required
+        />
+        <Text.H6 color='foregroundMuted'>
+          The ID of the workspace to send the weekly email for
+        </Text.H6>
+      </div>
+
+      <div className='flex flex-col gap-y-2'>
+        <Text.H5 weight='medium'>Email Addresses (Optional)</Text.H5>
+        <TextArea
+          placeholder='email1@example.com, email2@example.com'
+          value={emails}
+          onChange={(e) => setEmails(e.target.value)}
+          rows={4}
+        />
+        <Text.H6 color='foregroundMuted'>
+          Comma-separated list of email addresses. If left empty, the email will
+          be sent to all workspace members who have opted in to receive weekly
+          emails.
+        </Text.H6>
+      </div>
+
+      <div className='flex gap-2'>
+        <Button type='submit' fancy disabled={isPending}>
+          {isPending ? 'Enqueueing...' : 'Enqueue Weekly Email'}
+        </Button>
+      </div>
+    </form>
+  )
+}

apps/web/src/app/(admin)/backoffice/weekly/page.tsx

@@ -0,0 +1,20 @@
+'use client'
+
+import { Text } from '@latitude-data/web-ui/atoms/Text'
+import { WeeklyEmailForm } from './_components/WeeklyEmailForm'
+
+export default function AdminWeeklyEmail() {
+  return (
+    <div className='container flex flex-col gap-y-8'>
+      <section className='flex flex-col gap-y-4'>
+        <Text.H1>Weekly Email</Text.H1>
+        <Text.H4 color='foregroundMuted'>
+          Manually trigger weekly email reports for specific workspaces. You can
+          optionally provide a comma-separated list of email addresses to send
+          the report to instead of the workspace members.
+        </Text.H4>
+        <WeeklyEmailForm />
+      </section>
+    </div>
+  )
+}

apps/web/src/app/(private)/projects/[projectId]/versions/[commitUuid]/_components/Sidebar/ProjectSection/index.tsx

@@ -1,7 +1,7 @@
 'use client'
 
 import { useMemo } from 'react'
-import { formatCount } from '$/lib/formatCount'
+import { formatCount } from '@latitude-data/constants/formatCount'
 import { ROUTES } from '$/services/routes'
 
 import { RunSourceGroup } from '@latitude-data/constants'

apps/web/src/app/(private)/projects/[projectId]/versions/[commitUuid]/documents/[documentUuid]/(withTabs)/evaluations/[evaluationUuid]/_components/charts/DailyOverview.tsx

@@ -1,7 +1,7 @@
 import { formatCostInMillicents } from '$/app/_lib/formatUtils'
 import { useCurrentEvaluationV2 } from '$/app/providers/EvaluationV2Provider'
 import { EVALUATION_SPECIFICATIONS } from '$/components/evaluations'
-import { formatCount } from '$/lib/formatCount'
+import { formatCount } from '@latitude-data/constants/formatCount'
 import { ChartBlankSlate } from '@latitude-data/web-ui/atoms/ChartBlankSlate'
 import { Text } from '@latitude-data/web-ui/atoms/Text'
 import { AreaChart, ChartWrapper } from '@latitude-data/web-ui/molecules/Charts'

apps/web/src/app/(private)/projects/[projectId]/versions/[commitUuid]/documents/[documentUuid]/(withTabs)/evaluations/[evaluationUuid]/_components/charts/VersionOverview.tsx

@@ -1,7 +1,7 @@
 import { formatCostInMillicents } from '$/app/_lib/formatUtils'
 import { useCurrentEvaluationV2 } from '$/app/providers/EvaluationV2Provider'
 import { EVALUATION_SPECIFICATIONS } from '$/components/evaluations'
-import { formatCount } from '$/lib/formatCount'
+import { formatCount } from '@latitude-data/constants/formatCount'
 import { Badge } from '@latitude-data/web-ui/atoms/Badge'
 import { ChartBlankSlate } from '@latitude-data/web-ui/atoms/ChartBlankSlate'
 import { Text } from '@latitude-data/web-ui/atoms/Text'

apps/web/src/app/(private)/projects/[projectId]/versions/[commitUuid]/documents/[documentUuid]/(withTabs)/experiments/_components/ExperimentsTable/index.tsx

@@ -18,7 +18,7 @@ import { useCurrentProject } from '$/app/providers/ProjectProvider'
 import { DurationCell } from './DurationCell'
 import { ScoreCell } from './ScoreCell'
 import { cn } from '@latitude-data/web-ui/utils'
-import { formatCount } from '$/lib/formatCount'
+import { formatCount } from '@latitude-data/constants/formatCount'
 import { useSearchParams } from 'next/navigation'
 import { LinkableTablePaginationFooter } from '$/components/TablePaginationFooter'
 import { DocumentRoutes, ROUTES } from '$/services/routes'

apps/web/src/app/api/spans/limited/route.ts

@@ -56,9 +56,9 @@ export const GET = errorHandler(
         : null
 
       let spansResult
+      const spansRepository = new SpansRepository(workspace.id)
+
       if (filters.traceId) {
-        // If traceId is present in filters, fetch spans for that specific trace
-        const spansRepository = new SpansRepository(workspace.id)
         const spans = await spansRepository
           .list({ traceId: filters.traceId })
           .then((r) =>
@@ -70,13 +70,9 @@ export const GET = errorHandler(
           next: null,
         }
       } else {
-        // Otherwise, fetch spans directly from the repository
-        const spansRepository = new SpansRepository(workspace.id)
-
         let result: { items: any[]; next: any } = { items: [], next: null }
 
         if (documentUuid) {
-          // Document queries require commitUuid
           if (!commitUuid) {
             return NextResponse.json(
               { error: 'commitUuid is required when documentUuid is provided' },