fix: actively retrieve the feed

Author: Steinertech9

src/data/index.js

@@ -22,7 +22,7 @@ const exitWithError = (message) => {
 	process.exit(1)
 }
 
-const download = async () => {
+const getARDFeed = async () => {
 	// download ard feed
 	const response = await undici.fetch(ARD_FEED_URL)
 	const feed = await response.json()
@@ -76,13 +76,8 @@ const download = async () => {
 		}
 	}
 
-	// save to local storage
-	await Bun.write(
-		`${__dirname}/../data/ard-core-livestreams.json`,
-		JSON.stringify(feed, null, '\t')
-	)
 	console.log('ARD feed downloaded successfully')
-	return null
+	return feed
 }
 
-download()
+module.exports = getARDFeed

src/ingest/subscriptions/post.js

@@ -17,23 +17,18 @@ const response = require('../../utils/response')
 const config = require('../../../config')
 
 // load api feed
-const feed = require('../../data')
+const getArdFeed = require('../../data')
 
 const source = 'ingest/subscriptions/post'
 
 module.exports = async (req, res) => {
-	// check if env was set
-	if (!process.env.ARD_FEED_URL)
-		console.log('Feed-URL was not set')
-
-	const coreApi = require('../../data/ard-core-livestreams.json')
-
 	try {
 		// generate subscription name
 		const prefix = `${config.pubSubPrefix}subscription.`
 
 		// check existence of user institution
-		const institutionExists = coreApi.items.some((entry) => {
+		const ardFeed = await getArdFeed()
+		const institutionExists = ardFeed.items.some((entry) => {
 			return req.user.institutionId === entry.publisher.institution.id
 		})
 

src/utils/core/getPublisher.js

@@ -4,12 +4,12 @@
 	by SWR Audio Lab
 
 */
-const feed = require('../../data')
+const getArdFeed = require('../../data')
 
 module.exports = async (publisherId) => {
-	const coreApi = require('../../data/ard-core-livestreams.json')
 
-	const publisher = coreApi.items.find((entry) => {
+	const ardFeed = await getArdFeed()
+	const publisher = ardFeed.items.find((entry) => {
 		return publisherId === entry.publisher.id ? entry.publisher : null
 	})