aboutsummaryrefslogtreecommitdiff
path: root/src/backend/tau/services
diff options
context:
space:
mode:
authorMiguel Ángel Moreno <mail@migalmoreno.com>2022-11-21 17:55:28 +0100
committerMiguel Ángel Moreno <mail@migalmoreno.com>2022-12-20 00:54:46 +0100
commit452ccfd567f79126e108f69bb7ebca07b5993bdd (patch)
tree4bc2688977dcd461259683bc89ea7eb94848f627 /src/backend/tau/services
feat: Initial commit
Diffstat (limited to 'src/backend/tau/services')
-rw-r--r--src/backend/tau/services/http.clj73
1 files changed, 73 insertions, 0 deletions
diff --git a/src/backend/tau/services/http.clj b/src/backend/tau/services/http.clj
new file mode 100644
index 0000000..6101b52
--- /dev/null
+++ b/src/backend/tau/services/http.clj
@@ -0,0 +1,73 @@
+(ns tau.services.http
+ (:require
+ [org.httpkit.server :refer [run-server]]
+ [ring.middleware.reload :refer [wrap-reload]]
+ [ring.middleware.params :refer [wrap-params]]
+ [ring.middleware.json :refer [wrap-json-response]]
+ [ring.util.response :refer [response]]
+ [compojure.route :as route]
+ [compojure.core :refer :all]
+ [compojure.coercions :refer [as-int]]
+ [clojure.string :as str]
+ [tau.api.stream :as stream]
+ [tau.api.search :as search]
+ [tau.api.channel :as channel]
+ [tau.api.playlist :as playlist]
+ [tau.api.comment :as comment]
+ [tau.api.kiosk :as kiosk]
+ [tau.api.service :as service])
+ (:import
+ tau.DownloaderImpl
+ org.schabi.newpipe.extractor.NewPipe
+ org.schabi.newpipe.extractor.localization.Localization))
+
+(defonce server (atom nil))
+
+(defn stop-server!
+ []
+ (when @server
+ (@server :timeout 100)
+ (reset! server nil)))
+
+(defroutes app-routes
+ (context "/api" []
+ (GET "/stream" [url]
+ (response (stream/get-stream-info url)))
+ (GET "/search" [serviceId :<< as-int q sortFilter contentFilters nextPage]
+ (let [content-filters (when contentFilters (str/split contentFilters #","))]
+ (response (if nextPage
+ (search/get-search-info serviceId q content-filters sortFilter nextPage)
+ (search/get-search-info serviceId q content-filters sortFilter)))))
+ (GET "/channel" [url nextPage]
+ (if nextPage
+ (response (channel/get-channel-info url nextPage))
+ (response (channel/get-channel-info url))))
+ (GET "/playlist" [url nextPage]
+ (if nextPage
+ (response (playlist/get-playlist-info url nextPage))
+ (response (playlist/get-playlist-info url))))
+ (GET "/comments" [url nextPage]
+ (if nextPage
+ (response (comment/get-comments-info url nextPage))
+ (response (comment/get-comments-info url))))
+ (GET "/services" []
+ (response (service/get-service-list-info)))
+ (context "/kiosks" []
+ (GET "/" [serviceId :<< as-int]
+ (response (kiosk/get-kiosk-list-info serviceId)))
+ (GET "/:kioskId" [kioskId serviceId :<< as-int nextPage]
+ (if nextPage
+ (response (kiosk/get-kiosk-info kioskId serviceId nextPage))
+ (response (kiosk/get-kiosk-info kioskId serviceId)))))))
+
+(defn make-handler
+ []
+ (-> #'app-routes
+ wrap-params
+ (wrap-json-response {:pretty true})
+ wrap-reload))
+
+(defn start-server!
+ [port]
+ (NewPipe/init (DownloaderImpl/init) (Localization. "en" "GB"))
+ (reset! server (run-server (make-handler) {:port port})))