Benature/omnivore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

do not create user profile and topics

Browse Source
This commit is contained in:
Hongbo Wu
2024-04-29 13:46:09 +08:00
parent d0d088aae3
commit 14e91d338d
3 changed files with 18 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
packages/api/src/jobs/ai/create_digest.ts
View File

@ -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: [],
}

4
packages/api/src/queue-processor.ts
View File

@ -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}`)
}

4
packages/api/src/utils/createTask.ts
View File

@ -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<CreateDigestJobResponse> => {
const queue = await getBackendQueue()