Umbrella_web/server/api/feeds.js at master · securityfirst/Umbrella_web · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
require("isomorphic-unfetch");

const express = require("express");
const router = express.Router();
const isUrl = require("is-url");
const Parser = require("rss-parser");
let parser = new Parser();

router.post("/", (req, res) => {
  try {
    const { location, sources } = req.body;

    if (
      !location ||
      !(typeof location === "string") ||
      !sources ||
      !(sources instanceof Array) ||
      !sources.length
    ) {
      console.error("[API] /feeds: Request incomplete");
      res.statusMessage = "Request incomplete";
      return res.status(400).end();
    }

    let since = new Date();
    since = since.valueOf() - 2592000000; // 30 days ago

    const url = `${
      process.env.API_HOST
    }v3/feed?country=${location.toUpperCase()}&sources=${sources.join(",")}`;

    fetch(url)
      .then((resp) => {
        if (!resp.ok) {
          console.error("[API] /feeds response error: ", resp);
          res.statusMessage = "Failed to retrieve feeds";
          return res.status(500).end();
        }

        return resp.json();
      })
      .then((data) => {
        return res.status(200).send(data);
      })
      .catch((err) => {
        console.error("[API] /feeds catch error: ", JSON.stringify(err));
        res.statusMessage = "Failed to retrieve feeds";
        return res.status(500).end();
      });
  } catch (e) {
    console.error("[API] /feeds exception: ", e);
    res.statusMessage = "Failed to retrieve feeds";
    res.status(500).end();
  }
});

router.post("/rss", async (req, res) => {
  try {
    const { sources } = req.body;

    if (!sources || !(sources instanceof Array) || !sources.length) {
      console.error("[API] /feeds/rss: Request incomplete");
      res.statusMessage = "Request incomplete";
      return res.status(400).end();
    }

    let data = [];

    for (let i = 0; i < sources.length; i++) {
      try {
        const rss = await parser.parseURL(sources[i]);
        data.push(rss);
      } catch (e) {
        console.error("[API] /feeds/rss parser exception: ", e);
      }

      if (i === sources.length - 1) {
        res.status(200).send(data);
      }
    }
  } catch (e) {
    console.error("[API] /feeds/rss exception: ", e);
    res.statusMessage = "Failed to retrieve RSS feeds";
    res.status(500).end();
  }
});

router.post("/rss/add", async (req, res) => {
  try {
    const { source } = req.body;

    if (!source || !isUrl(source)) {
      console.error("[API] /feeds/rss/add: Request incomplete");
      res.statusMessage = "Request incomplete";
      return res.status(400).end();
    }

    const rss = await parser.parseURL(source);

    if (!rss) {
      console.error("[API] /feeds/rss/add: RSS source is not valid");
      res.statusMessage = "RSS source is not valid";
      return res.status(500).end();
    }

    return res.status(200).send(rss);
  } catch (e) {
    console.error("[API] /feeds/rss/add exception: ", e);
    res.statusMessage = "Failed to add RSS source";
    res.status(500).end();
  }
});

module.exports = router;