File tree Expand file tree Collapse file tree 5 files changed +8
-9
lines changed
Expand file tree Collapse file tree 5 files changed +8
-9
lines changed Original file line number Diff line number Diff line change 11import { ActiveMQArtemisService } from "@queue/services/activeMQArtemis" ;
22import { MQFeedMessage } from "@queue/types/mq" ;
33import { MQQueueConfig } from "podverse-helpers" ;
4- import { ParseRSSFeedAndSaveToDatabase } from "podverse-parser" ;
4+ import { ParseRSSFeedAndSaveToDatabaseOptions } from "podverse-parser" ;
55
66type MQRSSAddOptions = MQQueueConfig & {
77 feedUrl : string ;
@@ -11,7 +11,7 @@ type MQRSSAddOptions = MQQueueConfig & {
1111export const mqRSSAdd = async (
1212 activeMQArtemisService : ActiveMQArtemisService ,
1313 options : MQRSSAddOptions ,
14- msgOptions : ParseRSSFeedAndSaveToDatabase
14+ msgOptions : ParseRSSFeedAndSaveToDatabaseOptions
1515) => {
1616 await activeMQArtemisService . initialize ( ) ;
1717
Original file line number Diff line number Diff line change @@ -2,14 +2,14 @@ import { FeedService } from "podverse-orm";
22import { ActiveMQArtemisService } from "@queue/services/activeMQArtemis" ;
33import { MQFeedMessage } from "@queue/types/mq" ;
44import { MQQueueConfig } from "podverse-helpers" ;
5- import { ParseRSSFeedAndSaveToDatabase } from "podverse-parser" ;
5+ import { ParseRSSFeedAndSaveToDatabaseOptions } from "podverse-parser" ;
66
77type MQRSSAddAllConfig = MQQueueConfig ;
88
99export const mqRSSAddAll = async (
1010 activeMQArtemisService : ActiveMQArtemisService ,
1111 options : MQRSSAddAllConfig ,
12- msgOptions : ParseRSSFeedAndSaveToDatabase
12+ msgOptions : ParseRSSFeedAndSaveToDatabaseOptions
1313) => {
1414 const feedService = new FeedService ( ) ;
1515 const feeds = await feedService . getAll ( ) ;
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ import { MQQueueConfig } from 'podverse-helpers';
33import { FeedService } from 'podverse-orm' ;
44import { ActiveMQArtemisService } from "@queue/services/activeMQArtemis" ;
55import { MQFeedMessage } from '@queue/types/mq' ;
6- import { ParseRSSFeedAndSaveToDatabase } from 'podverse-parser' ;
6+ import { ParseRSSFeedAndSaveToDatabaseOptions } from 'podverse-parser' ;
77
88type MQRSSAddAllRecentlyUpdatedFeedsOptions = MQQueueConfig & {
99 sinceRange : number ;
@@ -13,7 +13,7 @@ export const mqRSSAddRecentlyUpdatedFeedsFromPodcastIndex = async (
1313 activeMQArtemisService : ActiveMQArtemisService ,
1414 podcastIndexService : PodcastIndexService ,
1515 options : MQRSSAddAllRecentlyUpdatedFeedsOptions ,
16- msgOptions : ParseRSSFeedAndSaveToDatabase
16+ msgOptions : ParseRSSFeedAndSaveToDatabaseOptions
1717) => {
1818 const sinceRange = options . sinceRange ;
1919 const recentlyUpdatedFeeds = await podcastIndexService . recentGetData ( sinceRange ) ;
Original file line number Diff line number Diff line change @@ -95,7 +95,6 @@ export const mqRSSRunLiveItemListener = (
9595 } ,
9696 {
9797 forceParse : true ,
98- accountId : null ,
9998 onDemandParserEvent : {
10099 accountId : null ,
101100 remoteParentPodcastIndexId : null ,
Original file line number Diff line number Diff line change 1- import { ParseRSSFeedAndSaveToDatabase } from "podverse-parser" ;
1+ import { ParseRSSFeedAndSaveToDatabaseOptions } from "podverse-parser" ;
22
33export type MQFeedMessage = {
44 url : string ;
55 podcast_index_id : number ;
6- options : ParseRSSFeedAndSaveToDatabase ;
6+ options : ParseRSSFeedAndSaveToDatabaseOptions ;
77}
You can’t perform that action at this time.
0 commit comments