X-Git-Url: http://njoseph.me/gitweb/nimcoon.git/blobdiff_plain/9ed70b9e0ee8ebf8e0b1fc1bbe1b77178d1f008c..6697cfd20fbad109b18302ab0bb2c094bfdc4b5c:/src/lib.nim

diff --git a/src/lib.nim b/src/lib.nim
index 17761f3..25a8016 100644
--- a/src/lib.nim
+++ b/src/lib.nim
@@ -1,6 +1,4 @@
 import
-  httpClient,
-  json,
   os,
   osproc,
   re,
@@ -12,11 +10,13 @@ import
 
 import
   config,
-  types
+  peertube,
+  types,
+  youtube
 
 
 let
-  processOptions = {poStdErrToStdOut, poUsePath, poEchoCmd}
+  processOptions = {poStdErrToStdOut, poUsePath} # Add poEchoCmd to debug
   PEERTUBE_REGEX = re"videos\/watch\/[0-9a-f]{8}\b-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-\b[0-9a-f]{12}"
 
 
@@ -33,23 +33,32 @@ proc selectMediaPlayer*(): string =
     return availablePlayers[0]
 
 
-proc getPeerTubeMagnetLink(url: string): string =
-  ## Gets the magnet link of the best possible resolution from PeerTube
-  let uuid = url.substr(find(url, PEERTUBE_REGEX) + "videos/watch/".len)
-  let domainName = url.substr(8, find(url, '/', start=8) - 1)
-  let apiURL = &"https://{domainName}/api/v1/videos/{uuid}"
-  let client = newHttpClient()
-  let response = get(client, apiURL)
-  let jsonNode = parseJson($response.body)
-  jsonNode["files"][0]["magnetUri"].getStr()
+###############
+# URL CLEANUP #
+###############
 
+func rewriteInvidiousToYouTube*(url: string): string =
+  {.noSideEffect.}:
+    if rewriteInvidiousURLs and url.replace(".", "").contains("invidious"):
+       &"https://www.youtube.com/watch?v={url.split(\"=\")[1]}"
+    else: url
+
+
+func urlLongen(url: string): string =
+  url.replace("youtu.be/", "www.youtube.com/watch?v=")
 
-proc presentVideoOptions*(searchResults: SearchResults) =
-  eraseScreen()
-  for index, (title, url) in searchResults:
-    styledEcho $index, ". ", styleBright, fgMagenta, title, "\n", resetStyle, fgCyan, "   ", url, "\n"
+
+func stripZshEscaping(url: string): string = url.replace("\\", "")
 
 
+func sanitizeURL*(url: string): string =
+  rewriteInvidiousToYouTube(urlLongen(stripZshEscaping(url)))
+
+
+########
+# PLAY #
+########
+
 func buildPlayerArgs(url: string, options: Table[string, bool], player: string): seq[string] =
   let musicOnly = if options["musicOnly"]: "--no-video" else: ""
   let fullScreen = if options["fullScreen"]: "--fullscreen" else: ""
@@ -66,6 +75,26 @@ proc play*(player: string, options: Table[string, bool], url: string, title: str
     discard execProcess(player, args=args, options=processOptions)
 
 
+proc directPlay*(url: string, player: string, options: Table[string, bool]) =
+  let url =
+    if find(url, PEERTUBE_REGEX) != -1 and "webtorrent".isInstalled:
+      getPeerTubeMagnetLink(url)
+    else: url
+  if url.startswith("magnet:") or url.endswith(".torrent"):
+    if options["musicOnly"]:
+      # TODO Replace with WebTorrent once it supports media player options
+      discard execShellCmd(&"peerflix '{url}' -a --{player} -- --no-video")
+    else:
+      # WebTorrent is so much faster!
+      discard execProcess("webtorrent", args=[url, &"--{player}"], options=processOptions)
+  else:
+    play(player, options, url)
+
+
+############
+# DOWNLOAD #
+############
+
 func buildMusicDownloadArgs(url: string): seq[string] =
   {.noSideEffect.}:
     let downloadLocation = &"'{expandTilde(musicDownloadDirectory)}/%(title)s.%(ext)s'"
@@ -79,98 +108,98 @@ func buildVideoDownloadArgs(url: string): seq[string] =
     @["-f", "best", "-o", downloadLocation, url]
 
 
+func buildDownloadArgs(url: string, options: Options): seq[string] =
+  if options["musicOnly"]: buildMusicDownloadArgs(url)
+  else: buildVideoDownloadArgs(url)
+
+
 proc download*(args: openArray[string], title: string) =
   styledEcho "\n", fgGreen, "Downloading ", styleBright, fgMagenta, title
   discard execShellCmd(&"youtube-dl {args.join(\" \")}")
 
 
-func urlLongen(url: string): string = url.replace("youtu.be/", "www.youtube.com/watch?v=")
-
-
-func rewriteInvidiousToYouTube*(url: string): string =
-  {.noSideEffect.}:
-    if rewriteInvidiousURLs and url.replace(".", "").contains("invidious"):
-       &"https://www.youtube.com/watch?v={url.split(\"=\")[1]}"
-    else: url
-
-
-func stripZshEscaping(url: string): string = url.replace("\\", "")
-
-
-func sanitizeURL*(url: string): string =
-  rewriteInvidiousToYouTube(urlLongen(stripZshEscaping(url)))
-
-
-proc directPlay*(url: string, player: string, options: Table[string, bool]) =
-  let url =
-    if find(url, PEERTUBE_REGEX) != -1 and isInstalled("webtorrent"):
-      getPeerTubeMagnetLink(url)
-    else: url
-  if url.startswith("magnet:") or url.endswith(".torrent"):
-    if options["musicOnly"]:
-      # TODO Replace with WebTorrent once it supports media player options
-      discard execShellCmd(&"peerflix '{url}' -a --{player} -- --no-video")
-    else:
-      # WebTorrent is so much faster!
-      discard execProcess("webtorrent", args=[url, &"--{player}"], options=processOptions)
-  else:
-    play(player, options, url)
-
-
-proc directDownload*(url: string, musicOnly: bool) =
-  let args =
-    if musicOnly: buildMusicDownloadArgs(url)
-    else: buildVideoDownloadArgs(url)
-  if isInstalled("aria2c"):
+proc directDownload*(url: string, options: Options) =
+  let args = buildDownloadArgs(url, options)
+  if "aria2c".isInstalled:
     discard execShellCmd(&"youtube-dl {args.join(\" \")} --external-downloader aria2c --external-downloader-args '-x 16 -s 16 -k 2M'")
   else:
     discard execShellCmd(&"youtube-dl {args.join(\" \")}")
 
+proc luckyDownload*(searchQuery: string, options: Options) =
+  let args = @[&"ytsearch:\"{searchQuery}\""] & buildDownloadArgs("", options)
+  styledEcho "\n", fgGreen, "Searching and downloading using youtube-dl"
+  discard execShellCmd(&"youtube-dl {args.join(\" \")}")
 
-proc offerSelection(searchResults: SearchResults, options: Table[string, bool], selectionRange: SelectionRange): string =
-  if options["feelingLucky"]: "0"
-  else:
-    presentVideoOptions(searchResults[selectionRange.begin .. selectionRange.until])
-    stdout.styledWrite(fgYellow, "Choose video number: ")
-    readLine(stdin)
-
-
-proc handleUserInput(searchResult: SearchResult, options: Table[string, bool], player: string) =
-  if options["download"]:
-    if options["musicOnly"]:
-      download(buildMusicDownloadArgs(searchResult.url), searchResult.title)
-    else:
-      download(buildVideoDownloadArgs(searchResult.url), searchResult.title)
-  else:
-    play(player, options, searchResult.url, searchResult.title)
+proc luckyPlay*(searchQuery: string, player: string, options: Options) =
+  let args = @[&"ytsearch:\"{searchQuery}\""] & buildDownloadArgs("", options)
+  let output = execProcess(&"youtube-dl --get-url {args.join(\" \")}")
+  let url = output.split("\n")[0]
+  play(player, options, url)
 
+###########
+# OPTIONS #
+###########
 
 proc isValidOptions*(options: Options): bool =
   # Check for invalid combinations of options
-  var invalidCombinations = [("musicOnly", "fullScreen"), ("download", "fullScreen")]
+  var invalidCombinations = [("musicOnly", "fullScreen"), ("download", "fullScreen"), ("download", "autoPlay")]
   result = true
   for combination in invalidCombinations:
     if options[combination[0]] and options[combination[1]]:
      stderr.writeLine fmt"Incompatible options provided: {combination[0]} and {combination[1]}"
      result = false
+  # TODO Make this overridable in configuration
+  if options["autoPlay"] and not options["musicOnly"]:
+    stderr.writeLine "--music-only must be provided with --auto-play. This is to prevent binge-watching."
+    result = false
 
 
 proc updateOptions(options: Options, newOptions: string): Options =
   result = options
 
+  # Interactive options
   for option in newOptions:
     case option
     of 'm': result["musicOnly"] = true
     of 'f': result["fullScreen"] = true
     of 'd': result["download"] = true
+    of 'a': result["autoPlay"] = true
     else:
-      echo "Invalid option provided!"
+      stderr.writeLine "Invalid option provided!"
       quit(2)
 
   if(not isValidOptions(result)):
     quit(2)
 
 
+################
+# PRESENTATION #
+################
+
+proc handleUserInput(searchResult: SearchResult, options: Table[string, bool], player: string) =
+  if options["autoPlay"]:
+    play(player, options, searchResult.url, searchResult.title)
+    handleUserInput(getAutoPlayVideo(searchResult), options, player) # inifinite playlist till user quits
+  elif options["download"]:
+    download(buildDownloadArgs(searchResult.url, options), searchResult.title)
+  else:
+    play(player, options, searchResult.url, searchResult.title)
+
+
+proc presentVideoOptions(searchResults: SearchResults) =
+  eraseScreen()
+  for index, (title, url) in searchResults:
+    styledEcho $index, ". ", styleBright, fgMagenta, title, "\n", resetStyle, fgCyan, "   ", url, "\n"
+
+
+proc offerSelection(searchResults: SearchResults, options: Table[string, bool], selectionRange: SelectionRange): string =
+  if options["feelingLucky"]: "0"
+  else:
+    presentVideoOptions(searchResults[selectionRange.begin .. selectionRange.until])
+    stdout.styledWrite(fgYellow, "Choose video number: ")
+    readLine(stdin)
+
+
 proc present*(searchResults: SearchResults, options: Table[string, bool], selectionRange: SelectionRange, player: string) =
   ##[ Continuously present options till the user quits the application