3 files changed, 80 insertions, 1 deletions
diff --git a/pages/api/radio/stations.js b/pages/api/radio/stations.js
new file mode 100644
index 0000000..9ebb55e
--- /dev/null
+++ b/pages/api/radio/stations.js
@@ -0,0 +1,45 @@
+import withSession from 'hocs/withSession'
+import * as cheerio from 'cheerio';
+
+const DOMAIN = 'https://streema.com'
+
+export default withSession(async (req, res) => {
+  switch (req.method) {
+    case 'POST':
+      try {
+        const user = req.session.get('user')
+        const { query } = JSON.parse(req.body)
+
+        if (!user || !user?.isVerified || !query) {
+          throw new Error('Something went wrong')
+        }
+
+        const response = await fetch(`${DOMAIN}/radios/search/?q=${query.replaceAll(' ', '+')}`)
+        const data = await response.text()
+        const $ = cheerio.load(data);
+        const results = []
+
+        $('.item', '.items-list').each((_, item) => {
+          const link = $(item).find('.item-name a')
+          results.push({
+            logo: $(item).find('.item-logo img').attr('src'),
+            title: link.attr('title').replace('Listen to', ''),
+            url: DOMAIN + link.attr('href'),
+            genres: $(item).find('.item-extra .genre span')
+              .map((_, g) => ($(g).text().trim())).toArray(),
+            locations: $(item).find('.item-extra .location span')
+              .map((_, l) => ($(l).text().trim())).toArray(),
+          })
+        });
+
+        res.status(200).json(results)
+      } catch (e) {
+        console.error(e)
+        res.status(400).send('')
+      }
+      break
+    default:
+      res.status(400).send('')
+      break
+  }
+})
diff --git a/pages/api/radio/stream.js b/pages/api/radio/stream.js
new file mode 100644
index 0000000..42e8521
--- /dev/null
+++ b/pages/api/radio/stream.js
@@ -0,0 +1,34 @@
+import withSession from 'hocs/withSession'
+
+export default withSession(async (req, res) => {
+  switch (req.method) {
+    case 'POST':
+      try {
+        const user = req.session.get('user')
+        const { station } = JSON.parse(req.body)
+
+        if (!user || !user?.isVerified || !station) {
+          throw new Error('Something went wrong')
+        }
+
+        const response = await fetch(station.replace('radios', 'radios/play'))
+        const data = await response.text()
+
+        const script = /(?<=ST\.radio = {)[\s\S]*?(?=script)/.exec(data)?.[0]
+        const url = /(?<=url: ").*(?=")/.exec(script)?.[0]
+        const mimeType = /(?<=content_type: ").*(?=")/.exec(script)?.[0]
+
+        const songImage = /(?<="song-image")[\s\S]*?(?=div)/.exec(data)?.[0]
+        const thumbnail = /(?<=src\=").*(?=")/.exec(songImage)?.[0]
+
+        res.status(200).json({url, mimeType, thumbnail})
+      } catch (error) {
+        console.log(error)
+        res.status(400).send('')
+      }
+      break
+    default:
+      res.status(400).send('')
+      break
+  }
+})
diff --git a/pages/api/youtube/video.js b/pages/api/youtube/video.js
index aeb2e8b..f04c7f0 100644
--- a/pages/api/youtube/video.js
+++ b/pages/api/youtube/video.js
@@ -16,7 +16,7 @@ export default withSession(async (req, res) => {
 
         res.status(200).json(info)
       } catch (error) {
-        res.status(400).json([])
+        res.status(400).send()
       }
       break
     default: