diff --git a/packages/rss-handler/src/index.ts b/packages/rss-handler/src/index.ts index 1c06b413b..03d53e85f 100644 --- a/packages/rss-handler/src/index.ts +++ b/packages/rss-handler/src/index.ts @@ -5,11 +5,7 @@ import * as dotenv from 'dotenv' // see https://github.com/motdotla/dotenv#how-d import * as jwt from 'jsonwebtoken' import Parser, { Item } from 'rss-parser' import { promisify } from 'util' -import { - CONTENT_FETCH_URL, - createCloudTask, - FOLLOWING_HANDLER_URL, -} from './task' +import { CONTENT_FETCH_URL, createCloudTask } from './task' interface RssFeedRequest { subscriptionIds: string[] @@ -189,8 +185,15 @@ const createFollowingTask = async ( try { console.log('Creating task', input.url) + const apiEndpoint = process.env.REST_BACKEND_ENDPOINT + const token = process.env.PUBSUB_VERIFICATION_TOKEN + if (!apiEndpoint || !token) { + throw 'Environment not configured correctly' + } + // save page - const task = await createCloudTask(FOLLOWING_HANDLER_URL, input) + const taskHandlerUrl = `${apiEndpoint}/svc/following/save?token=${token}` + const task = await createCloudTask(taskHandlerUrl, input) console.log('Created task', task) return !!task diff --git a/packages/rss-handler/src/task.ts b/packages/rss-handler/src/task.ts index 9fe02fca7..8a89fbd43 100644 --- a/packages/rss-handler/src/task.ts +++ b/packages/rss-handler/src/task.ts @@ -4,7 +4,6 @@ import { CloudTasksClient, protos } from '@google-cloud/tasks' const cloudTask = new CloudTasksClient() export const CONTENT_FETCH_URL = process.env.CONTENT_FETCH_GCF_URL -export const FOLLOWING_HANDLER_URL = process.env.FOLLOWING_HANDLER_URL export const createCloudTask = async ( taskHandlerUrl: string | undefined,