diff --git a/packages/api/src/jobs/ai/create_digest.ts b/packages/api/src/jobs/ai/create_digest.ts index a3be248a0..25f10dd94 100644 --- a/packages/api/src/jobs/ai/create_digest.ts +++ b/packages/api/src/jobs/ai/create_digest.ts @@ -24,7 +24,7 @@ import { sendMulticastPushNotifications } from '../../utils/sendNotification' export type CreateDigestJobSchedule = 'daily' | 'weekly' -export interface CreateDigestJobData { +export interface CreateDigestData { id: string userId: string voices?: string[] @@ -434,7 +434,7 @@ const generateByline = (summaries: RankedItem[]): string => .map((item) => item.libraryItem.author) .join(', ') -export const createDigestJob = async (jobData: CreateDigestJobData) => { +export const createDigest = async (jobData: CreateDigestData) => { try { digestDefinition = await fetchDigestDefinition() @@ -451,12 +451,17 @@ export const createDigestJob = async (jobData: CreateDigestJobData) => { }) } - const userProfile = await findOrCreateUserProfile(jobData.userId) - const rankedCandidates = await rankCandidates(candidates, userProfile) - const { finalSelections, rankedTopics } = - chooseRankedSelections(rankedCandidates) + // const userProfile = await findOrCreateUserProfile(jobData.userId) + // const rankedCandidates = await rankCandidates(candidates, userProfile) + // const { finalSelections, rankedTopics } = + // chooseRankedSelections(rankedCandidates) - const summaries = await summarizeItems(finalSelections) + const selections = candidates.map((item) => ({ + topic: '', + libraryItem: item, + summary: '', + })) + const summaries = await summarizeItems(selections) const filteredSummaries = filterSummaries(summaries) @@ -480,7 +485,8 @@ export const createDigestJob = async (jobData: CreateDigestJobData) => { wordCount: speechFiles[index].wordCount, })), createdAt: new Date(), - description: generateDescription(summaries, rankedTopics), + description: '', + // description: generateDescription(summaries, rankedTopics), byline: generateByline(summaries), urlsToAudio: [], } diff --git a/packages/api/src/queue-processor.ts b/packages/api/src/queue-processor.ts index 89448b96f..2d0bf5881 100644 --- a/packages/api/src/queue-processor.ts +++ b/packages/api/src/queue-processor.ts @@ -16,7 +16,7 @@ import { appDataSource } from './data_source' import { env } from './env' import { TaskState } from './generated/graphql' import { aiSummarize, AI_SUMMARIZE_JOB_NAME } from './jobs/ai-summarize' -import { createDigestJob, CREATE_DIGEST_JOB } from './jobs/ai/create_digest' +import { createDigest, CREATE_DIGEST_JOB } from './jobs/ai/create_digest' import { bulkAction, BULK_ACTION_JOB_NAME } from './jobs/bulk_action' import { callWebhook, CALL_WEBHOOK_JOB_NAME } from './jobs/call_webhook' import { @@ -181,7 +181,7 @@ export const createWorker = (connection: ConnectionOptions) => case FORWARD_EMAIL_JOB: return forwardEmailJob(job.data) case CREATE_DIGEST_JOB: - return createDigestJob(job.data) + return createDigest(job.data) default: logger.warning(`[queue-processor] unhandled job: ${job.name}`) } diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts index a8c6e2fb1..2383df98c 100644 --- a/packages/api/src/utils/createTask.ts +++ b/packages/api/src/utils/createTask.ts @@ -18,7 +18,7 @@ import { } from '../generated/graphql' import { AISummarizeJobData, AI_SUMMARIZE_JOB_NAME } from '../jobs/ai-summarize' import { - CreateDigestJobData, + CreateDigestData, CreateDigestJobResponse, CreateDigestJobSchedule, CREATE_DIGEST_JOB, @@ -856,7 +856,7 @@ export const enqueueSendEmail = async (jobData: SendEmailJobData) => { } export const enqueueCreateDigest = async ( - data: CreateDigestJobData, + data: CreateDigestData, schedule?: CreateDigestJobSchedule ): Promise => { const queue = await getBackendQueue()