X-Git-Url: https://njoseph.me/gitweb/nimcoon.git/blobdiff_plain/26229fac9c93a427a85e86b899ed54639116de9a..f114ff9a9ec2477cf9b8fe62283b28794d49fcab:/src/lib.nim

diff --git a/src/lib.nim b/src/lib.nim
index 16082c5..4064ae4 100644
--- a/src/lib.nim
+++ b/src/lib.nim
@@ -1,6 +1,4 @@
 import
-  httpClient,
-  json,
   os,
   osproc,
   re,
@@ -12,12 +10,14 @@ import
 
 import
   config,
-  types
+  peertube,
+  types,
+  youtube
 
 
 let
-  processOptions = {poStdErrToStdOut, poUsePath} # poEchoCmd can be added to options for debugging
-  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}"
+  processOptions = {poStdErrToStdOut, poUsePath} # Add poEchoCmd to debug
+  PEERTUBE_REGEX = re"w\/[0-9a-zA-z]{22}"
 
 
 proc isInstalled(program: string): bool =
@@ -33,21 +33,35 @@ 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()
+proc printTitle(action: string, title: string) =
+    styledEcho "\n", fgGreen, &"{action} ", styleBright, fgMagenta, title
 
 
-proc presentVideoOptions*(searchResults: SearchResults) =
-  eraseScreen()
-  for index, (title, url) in searchResults:
-    styledEcho $index, ". ", styleBright, fgMagenta, title, "\n", resetStyle, fgCyan, "   ", url, "\n"
+###############
+# 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=")
+
+
+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: ""
@@ -58,13 +72,31 @@ func buildPlayerArgs(url: string, options: Table[string, bool], player: string):
 proc play*(player: string, options: Table[string, bool], url: string, title: string = "") =
   let args = buildPlayerArgs(url, options, player)
   if title != "":
-    styledEcho "\n", fgGreen, "Playing ", styleBright, fgMagenta, title
+    printTitle("Playing", title)
   if "--no-video" in args:
     discard execShellCmd(&"{player} {args.join(\" \")}")
   else:
-    discard startProcess(player, args=args, options=processOptions)
+    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, options["musicOnly"])
+    else: url
+  if url.startswith("magnet:") or url.endswith(".torrent"):
+    if options["musicOnly"]:
+      discard execShellCmd(&"webtorrent '{url}' --{player} --player-args='--no-video'")
+    else:
+      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'"
@@ -78,50 +110,90 @@ func buildVideoDownloadArgs(url: string): seq[string] =
     @["-f", "best", "-o", downloadLocation, 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 buildDownloadArgs(url: string, options: Options): seq[string] =
+  if options["musicOnly"]: buildMusicDownloadArgs(url)
+  else: buildVideoDownloadArgs(url)
 
 
-func rewriteInvidiousToYouTube(url: string): string =
-  {.noSideEffect.}:
-    if rewriteInvidiousURLs: url.replace("invidio.us", "www.youtube.com") else: url
+proc download*(args: openArray[string], title: string) =
+  printTitle("Downloading", title)
+  discard execShellCmd(&"yt-dlp {args.join(\" \")}")
 
 
-func stripZshEscaping(url: string): string = url.replace("\\", "")
+proc directDownload*(url: string, options: Options) =
+  let args = buildDownloadArgs(url, options)
+  if "aria2c".isInstalled:
+    discard execShellCmd(&"yt-dlp {args.join(\" \")} --external-downloader aria2c --external-downloader-args '-x 16 -s 16 -k 2M'")
+  else:
+    discard execShellCmd(&"yt-dlp {args.join(\" \")}")
+
+proc luckyDownload*(searchQuery: string, options: Options) =
+  let args = @[&"ytsearch1:\"{searchQuery}\""] & buildDownloadArgs("", options)
+  let title = execProcess(&"yt-dlp --get-title {args.join(\" \")}").split("\n")[0]
+  download(args, title)
+
+proc luckyPlay*(searchQuery: string, player: string, options: Options) =
+  let args = @[&"ytsearch:\"{searchQuery}\""] & buildDownloadArgs("", options)
+  let output = execProcess(&"yt-dlp --get-url --get-title {args.join(\" \")}").split("\n")
+  let
+    title = output[0]
+    url = &"\"{output[1]}\""
+  play(player, options, url, title)
+
+###########
+# OPTIONS #
+###########
+
+proc isValidOptions*(options: Options): bool =
+  # Check for invalid combinations of options
+  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:
+      stderr.writeLine "Invalid option provided!"
+      quit(2)
 
+  if(not isValidOptions(result)):
+    quit(2)
 
-func sanitizeURL*(url: string): string =
-  rewriteInvidiousToYouTube(urlLongen(stripZshEscaping(url)))
 
+################
+# PRESENTATION #
+################
 
-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)
+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, url)
+    play(player, options, searchResult.url, searchResult.title)
 
 
-proc directDownload*(url: string, musicOnly: bool) =
-  let args =
-    if musicOnly: buildMusicDownloadArgs(url)
-    else: buildVideoDownloadArgs(url)
-  if isInstalled("aria2c"):
-    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 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 =
@@ -132,16 +204,6 @@ proc offerSelection(searchResults: SearchResults, options: Table[string, bool],
     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 present*(searchResults: SearchResults, options: Table[string, bool], selectionRange: SelectionRange, player: string) =
   ##[ Continuously present options till the user quits the application
 
@@ -170,8 +232,14 @@ proc present*(searchResults: SearchResults, options: Table[string, bool], select
   of "q":
     quit(0)
   else:
-    let searchResult = searchResults[selectionRange.begin .. selectionRange.until][parseInt(userInput)]
-    handleUserInput(searchResult, options, player)
+    if " " in userInput:
+      let selection = parseInt(userInput.split(" ")[0])
+      let updatedOptions = updateOptions(options, userInput.split(" ")[1])
+      let searchResult = searchResults[selectionRange.begin .. selectionRange.until][selection]
+      handleUserInput(searchResult, updatedOptions, player)
+    else:
+      let searchResult = searchResults[selectionRange.begin .. selectionRange.until][parseInt(userInput)]
+      handleUserInput(searchResult, options, player)
     if options["feelingLucky"]:
       quit(0)
     else: