diff --git a/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts b/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts index fb99cdb9f550..b87f12186dc1 100644 --- a/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts +++ b/opencti-platform/opencti-graphql/src/manager/ingestionManager.ts @@ -104,7 +104,7 @@ const pushBundleToConnectorQueue = async (context: AuthContext, ingestion: Basic // endregion // region Rss ingestion -type Getter = (uri: string) => Promise; +type Getter = (uri: string) => Promise; interface RssElement { pubDate: { _: string } @@ -121,6 +121,7 @@ interface RssItem { 'content:encoded': { _: string } category: { _: string } | { _: string }[] pubDate: { _: string } + 'dc:date': { _: string } lastBuildDate: { _: string } updated: { _: string } } @@ -154,19 +155,14 @@ const rssItemV2Convert = (turndownService: TurndownService, channel: RssElement, link: isNotEmptyField(item.link) ? ((item.link as { _: string })._ ?? '').trim() : '', content: turndownService.turndown(item['content:encoded']?._ ?? item.content?._ ?? ''), labels: R.uniq(asArray(item.category).filter((c) => isNotEmptyField(c)).map((c) => (c as { _: string })._.trim())), - pubDate: utcDate(sanitizeForMomentParsing(item.pubDate?._ ?? pubDate?._ ?? FROM_START_STR)), + pubDate: utcDate(sanitizeForMomentParsing(item.pubDate?._ ?? item['dc:date']?._ ?? pubDate?._ ?? FROM_START_STR)), }; }; const rssHttpGetter = (): Getter => { - const httpClientOptions: GetHttpClient = { - responseType: 'text', - headers: { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:120.0) Gecko/20100101 Firefox/120.0' } - }; - const httpClient = getHttpClient(httpClientOptions); return async (uri: string) => { - const { data } = await httpClient.get(uri); - return data; + const fetchResponse = await fetch(uri); + return fetchResponse.text(); }; };