diff options
Diffstat (limited to 'src/backend/tau/services/http.clj')
-rw-r--r-- | src/backend/tau/services/http.clj | 73 |
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}))) |