From 5140e5a44225543d22b400da96dd84b5bf11eddc Mon Sep 17 00:00:00 2001 From: Pavel Gnedov Date: Fri, 11 Nov 2022 09:21:37 +0700 Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5?= =?UTF-8?q?=D0=BD=20=D0=BF=D0=B5=D1=80=D0=B5=D1=85=D0=B2=D0=B0=D1=82=20?= =?UTF-8?q?=D0=BE=D1=88=D0=B8=D0=B1=D0=BE=D0=BA=20=D1=87=D1=82=D0=B5=D0=BD?= =?UTF-8?q?=D0=B8=D1=8F=20rss?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- libs/event-emitter/src/rsslistener/rsslistener.ts | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/libs/event-emitter/src/rsslistener/rsslistener.ts b/libs/event-emitter/src/rsslistener/rsslistener.ts index 2d3aa23..3669cdb 100644 --- a/libs/event-emitter/src/rsslistener/rsslistener.ts +++ b/libs/event-emitter/src/rsslistener/rsslistener.ts @@ -1,4 +1,4 @@ -import { Injectable } from '@nestjs/common'; +import { Injectable, Logger } from '@nestjs/common'; import { RssListenerDefaultParams, RssListenerParams, @@ -14,6 +14,8 @@ const parser = new Parser(); @Injectable() export class RssListener implements EventsListener { + private logger = new Logger(RssListener.name); + issues = new BehaviorSubject([]); private updateTimeout; @@ -56,7 +58,15 @@ export class RssListener implements EventsListener { const url = subscription.url; const regexp = new RegExp(subscription.issueNumberParser); const subjectParser = CreateSubjectsParserByRegExp(regexp); - const feed = await parser.parseURL(url); + let feed; + try { + feed = await parser.parseURL(url); + } catch (ex) { + this.logger.error( + `Error at load data from rss by url ${url} with error message ${ex.message}`, + ); + return []; + } const issueNumbers: number[] = feed.items .filter((item) => { const itemDate = new Date(item.pubDate);