Compare commits
16 Commits
v2024.6.25
...
v2024.7.18
| Author | SHA1 | Date | |
|---|---|---|---|
| dbc25e5730 | |||
| a3ebf59b29 | |||
| 8dd8e49051 | |||
| 029981b7ee | |||
| d423e4486f | |||
| 4c7a63c970 | |||
| 4822127e3f | |||
| 4f25878f2f | |||
| aec56e3a03 | |||
| e06e050f95 | |||
| 5a10015634 | |||
| 0d5a41fd35 | |||
| 8f91c4e6a2 | |||
| 7f1daf90ca | |||
| bb0e104b7e | |||
| c0b8dec520 |
@@ -16,24 +16,28 @@ jobs:
|
|||||||
if: "! contains(toJSON(github.event.commits.*.message), '[skip ci]')"
|
if: "! contains(toJSON(github.event.commits.*.message), '[skip ci]')"
|
||||||
env:
|
env:
|
||||||
COMPOSE_FILE: ./docker-compose.ci.yml
|
COMPOSE_FILE: ./docker-compose.ci.yml
|
||||||
|
MIX_ENV: test
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout code
|
- name: Checkout code
|
||||||
uses: actions/checkout@v3
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Pull prebuilt images
|
- name: Pull prebuilt images
|
||||||
run: docker compose pull
|
run: docker compose pull
|
||||||
|
|
||||||
- name: Setup Docker layer caching
|
- name: Set up Docker Buildx
|
||||||
uses: jpribyl/action-docker-layer-caching@v0.1.1
|
uses: docker/setup-buildx-action@v3
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
key: ci-docker-cache-{hash}
|
|
||||||
restore-keys: |
|
|
||||||
ci-docker-cache-
|
|
||||||
layer-ci-docker-cache-
|
|
||||||
|
|
||||||
- name: Build and Run Docker image
|
- name: Build docker image
|
||||||
|
uses: docker/build-push-action@v5
|
||||||
|
with:
|
||||||
|
context: .
|
||||||
|
file: ./docker/dev.Dockerfile
|
||||||
|
load: true
|
||||||
|
cache-from: type=gha
|
||||||
|
cache-to: type=gha,mode=max
|
||||||
|
|
||||||
|
- name: Run Docker image
|
||||||
run: docker compose up --detach
|
run: docker compose up --detach
|
||||||
|
|
||||||
# NOTE: All exec commands use the -T flag to compensate for
|
# NOTE: All exec commands use the -T flag to compensate for
|
||||||
@@ -43,8 +47,7 @@ jobs:
|
|||||||
# See https://github.com/actions/runner/issues/241 and https://github.com/docker/compose/issues/8537
|
# See https://github.com/actions/runner/issues/241 and https://github.com/docker/compose/issues/8537
|
||||||
- name: Install Elixir and JS deps
|
- name: Install Elixir and JS deps
|
||||||
run: |
|
run: |
|
||||||
docker compose exec -T phx yarn install && cd assets && yarn install && cd ..
|
docker compose exec -T phx mix deps.get && yarn install && cd assets && yarn install && cd ..
|
||||||
docker compose exec -T phx mix deps.get
|
|
||||||
|
|
||||||
- name: Create and Migrate database
|
- name: Create and Migrate database
|
||||||
run: |
|
run: |
|
||||||
|
|||||||
+1
-1
@@ -102,7 +102,7 @@ config :tailwind,
|
|||||||
|
|
||||||
# Configures Elixir's Logger
|
# Configures Elixir's Logger
|
||||||
config :logger, :console,
|
config :logger, :console,
|
||||||
format: "$time $metadata[$level] $message\n",
|
format: "$date $time $metadata[$level] | $message\n",
|
||||||
metadata: [:request_id]
|
metadata: [:request_id]
|
||||||
|
|
||||||
# Use Jason for JSON parsing in Phoenix
|
# Use Jason for JSON parsing in Phoenix
|
||||||
|
|||||||
@@ -7,6 +7,9 @@ services:
|
|||||||
- MIX_ENV=test
|
- MIX_ENV=test
|
||||||
volumes:
|
volumes:
|
||||||
- '.:/app'
|
- '.:/app'
|
||||||
|
# These lines ensure the deps can be saved as build artifacts for caching
|
||||||
|
- '/app/deps'
|
||||||
|
- '/app/_build'
|
||||||
ports:
|
ports:
|
||||||
- '4008:4008'
|
- '4008:4008'
|
||||||
command: tail -F /dev/null
|
command: tail -F /dev/null
|
||||||
|
|||||||
+21
-23
@@ -9,8 +9,8 @@ ARG TARGETPLATFORM
|
|||||||
RUN echo "Building for ${TARGETPLATFORM:?}"
|
RUN echo "Building for ${TARGETPLATFORM:?}"
|
||||||
|
|
||||||
# Install debian packages
|
# Install debian packages
|
||||||
RUN apt-get update -qq
|
RUN apt-get update -qq && \
|
||||||
RUN apt-get install -y inotify-tools curl git openssh-client jq \
|
apt-get install -y inotify-tools curl git openssh-client jq \
|
||||||
python3 python3-setuptools python3-wheel python3-dev pipx \
|
python3 python3-setuptools python3-wheel python3-dev pipx \
|
||||||
python3-mutagen locales procps build-essential graphviz
|
python3-mutagen locales procps build-essential graphviz
|
||||||
|
|
||||||
@@ -23,31 +23,28 @@ RUN export FFMPEG_DOWNLOAD=$(case ${TARGETPLATFORM:-linux/amd64} in \
|
|||||||
tar -xf /tmp/ffmpeg.tar.xz --strip-components=2 --no-anchored -C /usr/bin/ "ffmpeg" && \
|
tar -xf /tmp/ffmpeg.tar.xz --strip-components=2 --no-anchored -C /usr/bin/ "ffmpeg" && \
|
||||||
tar -xf /tmp/ffmpeg.tar.xz --strip-components=2 --no-anchored -C /usr/bin/ "ffprobe"
|
tar -xf /tmp/ffmpeg.tar.xz --strip-components=2 --no-anchored -C /usr/bin/ "ffprobe"
|
||||||
|
|
||||||
# Install nodejs
|
# Install nodejs and Yarn
|
||||||
RUN curl -sL https://deb.nodesource.com/setup_20.x -o nodesource_setup.sh
|
RUN curl -sL https://deb.nodesource.com/setup_20.x -o nodesource_setup.sh && \
|
||||||
RUN bash nodesource_setup.sh
|
bash nodesource_setup.sh && \
|
||||||
RUN apt-get install nodejs
|
apt-get install -y nodejs && \
|
||||||
RUN npm install -g yarn
|
npm install -g yarn && \
|
||||||
|
# Install baseline Elixir packages
|
||||||
# Install baseline Elixir packages
|
mix local.hex --force && \
|
||||||
RUN mix local.hex --force
|
mix local.rebar --force && \
|
||||||
RUN mix local.rebar --force
|
# Download and update YT-DLP
|
||||||
|
curl -L https://github.com/yt-dlp/yt-dlp/releases/latest/download/yt-dlp -o /usr/local/bin/yt-dlp && \
|
||||||
# Download and update YT-DLP
|
chmod a+rx /usr/local/bin/yt-dlp && \
|
||||||
RUN curl -L https://github.com/yt-dlp/yt-dlp/releases/latest/download/yt-dlp -o /usr/local/bin/yt-dlp
|
yt-dlp -U && \
|
||||||
RUN chmod a+rx /usr/local/bin/yt-dlp
|
# Install Apprise
|
||||||
RUN yt-dlp -U
|
export PIPX_HOME=/opt/pipx && \
|
||||||
|
|
||||||
# Install Apprise
|
|
||||||
RUN export PIPX_HOME=/opt/pipx && \
|
|
||||||
export PIPX_BIN_DIR=/usr/local/bin && \
|
export PIPX_BIN_DIR=/usr/local/bin && \
|
||||||
pipx install apprise
|
pipx install apprise
|
||||||
|
|
||||||
# Set the locale
|
# Set the locale
|
||||||
RUN sed -i '/en_US.UTF-8/s/^# //g' /etc/locale.gen && locale-gen
|
RUN sed -i '/en_US.UTF-8/s/^# //g' /etc/locale.gen && locale-gen
|
||||||
ENV LANG en_US.UTF-8
|
ENV LANG=en_US.UTF-8
|
||||||
ENV LANGUAGE en_US:en
|
ENV LANGUAGE=en_US:en
|
||||||
ENV LC_ALL en_US.UTF-8
|
ENV LC_ALL=en_US.UTF-8
|
||||||
|
|
||||||
# Create app directory and copy the Elixir projects into it.
|
# Create app directory and copy the Elixir projects into it.
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
@@ -55,7 +52,8 @@ COPY . ./
|
|||||||
|
|
||||||
# Install Elixir deps
|
# Install Elixir deps
|
||||||
# RUN mix archive.install github hexpm/hex branch latest
|
# RUN mix archive.install github hexpm/hex branch latest
|
||||||
RUN mix deps.get
|
RUN MIX_ENV=dev mix deps.get && MIX_ENV=dev mix deps.compile
|
||||||
|
RUN MIX_ENV=test mix deps.get && MIX_ENV=test mix deps.compile
|
||||||
# Gives us iex shell history
|
# Gives us iex shell history
|
||||||
ENV ERL_AFLAGS="-kernel shell_history enabled"
|
ENV ERL_AFLAGS="-kernel shell_history enabled"
|
||||||
|
|
||||||
|
|||||||
@@ -2,12 +2,12 @@
|
|||||||
|
|
||||||
set -e
|
set -e
|
||||||
|
|
||||||
# Ensure the app's deps are installed
|
echo "\nInstalling Elixir deps..."
|
||||||
mix deps.get
|
mix deps.get
|
||||||
|
|
||||||
# Install JS deps
|
# Install both project-level and assets-level JS dependencies
|
||||||
echo "\nInstalling JS..."
|
echo "\nInstalling JS deps..."
|
||||||
cd assets && yarn install
|
yarn install && cd assets && yarn install
|
||||||
cd ..
|
cd ..
|
||||||
|
|
||||||
# Potentially Set up the database
|
# Potentially Set up the database
|
||||||
|
|||||||
@@ -74,6 +74,9 @@ defmodule Pinchflat.Downloading.DownloadOptionBuilder do
|
|||||||
{{:download_auto_subs, true}, %{download_subs: true}} ->
|
{{:download_auto_subs, true}, %{download_subs: true}} ->
|
||||||
acc ++ [:write_auto_subs]
|
acc ++ [:write_auto_subs]
|
||||||
|
|
||||||
|
{{:download_auto_subs, true}, %{embed_subs: true}} ->
|
||||||
|
acc ++ [:write_auto_subs]
|
||||||
|
|
||||||
{{:embed_subs, true}, %{preferred_resolution: pr}} when pr != :audio ->
|
{{:embed_subs, true}, %{preferred_resolution: pr}} when pr != :audio ->
|
||||||
acc ++ [:embed_subs]
|
acc ++ [:embed_subs]
|
||||||
|
|
||||||
@@ -203,10 +206,8 @@ defmodule Pinchflat.Downloading.DownloadOptionBuilder do
|
|||||||
"source_collection_id" => source.collection_id,
|
"source_collection_id" => source.collection_id,
|
||||||
"source_collection_name" => source.collection_name,
|
"source_collection_name" => source.collection_name,
|
||||||
"source_collection_type" => to_string(source.collection_type),
|
"source_collection_type" => to_string(source.collection_type),
|
||||||
"media_upload_date_index" =>
|
"media_playlist_index" => pad_int(media_item_with_preloads.playlist_index),
|
||||||
media_item_with_preloads.upload_date_index
|
"media_upload_date_index" => pad_int(media_item_with_preloads.upload_date_index)
|
||||||
|> to_string()
|
|
||||||
|> String.pad_leading(2, "0")
|
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -223,6 +224,12 @@ defmodule Pinchflat.Downloading.DownloadOptionBuilder do
|
|||||||
|> build_output_path(media_item_with_preloads)
|
|> build_output_path(media_item_with_preloads)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
defp pad_int(integer, count \\ 2, padding \\ "0") do
|
||||||
|
integer
|
||||||
|
|> to_string()
|
||||||
|
|> String.pad_leading(count, padding)
|
||||||
|
end
|
||||||
|
|
||||||
defp base_directory do
|
defp base_directory do
|
||||||
Application.get_env(:pinchflat, :media_directory)
|
Application.get_env(:pinchflat, :media_directory)
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -54,7 +54,12 @@ defmodule Pinchflat.Downloading.OutputPathBuilder do
|
|||||||
"season_from_date" => "%(upload_date>%Y)S",
|
"season_from_date" => "%(upload_date>%Y)S",
|
||||||
"season_episode_from_date" => "s%(upload_date>%Y)Se%(upload_date>%m%d)S",
|
"season_episode_from_date" => "s%(upload_date>%Y)Se%(upload_date>%m%d)S",
|
||||||
"season_episode_index_from_date" => "s%(upload_date>%Y)Se%(upload_date>%m%d)S{{ media_upload_date_index }}",
|
"season_episode_index_from_date" => "s%(upload_date>%Y)Se%(upload_date>%m%d)S{{ media_upload_date_index }}",
|
||||||
"artist_name" => "%(artist,creator,uploader,uploader_id)S"
|
"artist_name" => "%(artist,creator,uploader,uploader_id)S",
|
||||||
|
"static_season__episode_by_index" => "Season 1/s01e{{ media_playlist_index }}",
|
||||||
|
"static_season__episode_by_date" => "Season 1/s01e%(upload_date>%y%m%d)S",
|
||||||
|
"season_by_year__episode_by_date" => "Season %(upload_date>%Y)S/s%(upload_date>%Y)Se%(upload_date>%m%d)S",
|
||||||
|
"season_by_year__episode_by_date_and_index" =>
|
||||||
|
"Season %(upload_date>%Y)S/s%(upload_date>%Y)Se%(upload_date>%m%d)S{{ media_upload_date_index }}"
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -142,12 +142,17 @@ defmodule Pinchflat.Media do
|
|||||||
"""
|
"""
|
||||||
def create_media_item_from_backend_attrs(source, media_attrs_struct) do
|
def create_media_item_from_backend_attrs(source, media_attrs_struct) do
|
||||||
attrs = Map.merge(%{source_id: source.id}, Map.from_struct(media_attrs_struct))
|
attrs = Map.merge(%{source_id: source.id}, Map.from_struct(media_attrs_struct))
|
||||||
|
# Some fields should only be set on insert and not on update.
|
||||||
|
fields_to_drop_on_update = [:playlist_index]
|
||||||
|
|
||||||
%MediaItem{}
|
%MediaItem{}
|
||||||
|> MediaItem.changeset(attrs)
|
|> MediaItem.changeset(attrs)
|
||||||
|> Repo.insert(
|
|> Repo.insert(
|
||||||
on_conflict: [
|
on_conflict: [
|
||||||
set: Map.to_list(attrs)
|
set:
|
||||||
|
attrs
|
||||||
|
|> Map.drop(fields_to_drop_on_update)
|
||||||
|
|> Map.to_list()
|
||||||
],
|
],
|
||||||
conflict_target: [:source_id, :media_id]
|
conflict_target: [:source_id, :media_id]
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -18,6 +18,8 @@ defmodule Pinchflat.Media.MediaItem do
|
|||||||
alias Pinchflat.Media.MediaItemsSearchIndex
|
alias Pinchflat.Media.MediaItemsSearchIndex
|
||||||
|
|
||||||
@allowed_fields [
|
@allowed_fields [
|
||||||
|
# these fields are only captured on index
|
||||||
|
:playlist_index,
|
||||||
# these fields are captured on indexing (and again on download)
|
# these fields are captured on indexing (and again on download)
|
||||||
:title,
|
:title,
|
||||||
:media_id,
|
:media_id,
|
||||||
@@ -72,6 +74,7 @@ defmodule Pinchflat.Media.MediaItem do
|
|||||||
field :uploaded_at, :utc_datetime
|
field :uploaded_at, :utc_datetime
|
||||||
field :upload_date_index, :integer, default: 0
|
field :upload_date_index, :integer, default: 0
|
||||||
field :duration_seconds, :integer
|
field :duration_seconds, :integer
|
||||||
|
field :playlist_index, :integer, default: 0
|
||||||
|
|
||||||
field :media_filepath, :string
|
field :media_filepath, :string
|
||||||
field :media_size_bytes, :integer
|
field :media_size_bytes, :integer
|
||||||
|
|||||||
@@ -124,6 +124,21 @@ defmodule Pinchflat.Metadata.MetadataFileHelpers do
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@doc """
|
||||||
|
Attempts to determine the season and episode number from a media filepath.
|
||||||
|
|
||||||
|
Returns {:ok, {binary(), binary()}} | {:error, :indeterminable}
|
||||||
|
"""
|
||||||
|
def season_and_episode_from_media_filepath(media_filepath) do
|
||||||
|
# matches s + 1 or more digits + e + 1 or more digits (case-insensitive)
|
||||||
|
season_episode_regex = ~r/s(\d+)e(\d+)/i
|
||||||
|
|
||||||
|
case Regex.scan(season_episode_regex, media_filepath) do
|
||||||
|
[[_, season, episode] | _] -> {:ok, {season, episode}}
|
||||||
|
_ -> {:error, :indeterminable}
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
defp generate_filepath_for(database_record, filename) do
|
defp generate_filepath_for(database_record, filename) do
|
||||||
Path.join([
|
Path.join([
|
||||||
metadata_directory_for(database_record),
|
metadata_directory_for(database_record),
|
||||||
|
|||||||
@@ -6,8 +6,8 @@ defmodule Pinchflat.Metadata.NfoBuilder do
|
|||||||
|
|
||||||
import Pinchflat.Utils.XmlUtils, only: [safe: 1]
|
import Pinchflat.Utils.XmlUtils, only: [safe: 1]
|
||||||
|
|
||||||
alias Pinchflat.Metadata.MetadataFileHelpers
|
|
||||||
alias Pinchflat.Utils.FilesystemUtils
|
alias Pinchflat.Utils.FilesystemUtils
|
||||||
|
alias Pinchflat.Metadata.MetadataFileHelpers
|
||||||
|
|
||||||
@doc """
|
@doc """
|
||||||
Builds an NFO file for a media item (read: single "episode") and
|
Builds an NFO file for a media item (read: single "episode") and
|
||||||
@@ -15,12 +15,12 @@ defmodule Pinchflat.Metadata.NfoBuilder do
|
|||||||
|
|
||||||
Returns the filepath of the NFO file.
|
Returns the filepath of the NFO file.
|
||||||
"""
|
"""
|
||||||
def build_and_store_for_media_item(filepath, metadata) do
|
def build_and_store_for_media_item(nfo_filepath, metadata) do
|
||||||
nfo = build_for_media_item(metadata)
|
nfo = build_for_media_item(nfo_filepath, metadata)
|
||||||
|
|
||||||
FilesystemUtils.write_p!(filepath, nfo)
|
FilesystemUtils.write_p!(nfo_filepath, nfo)
|
||||||
|
|
||||||
filepath
|
nfo_filepath
|
||||||
end
|
end
|
||||||
|
|
||||||
@doc """
|
@doc """
|
||||||
@@ -37,10 +37,15 @@ defmodule Pinchflat.Metadata.NfoBuilder do
|
|||||||
filepath
|
filepath
|
||||||
end
|
end
|
||||||
|
|
||||||
defp build_for_media_item(metadata) do
|
defp build_for_media_item(nfo_filepath, metadata) do
|
||||||
upload_date = MetadataFileHelpers.parse_upload_date(metadata["upload_date"])
|
upload_date = MetadataFileHelpers.parse_upload_date(metadata["upload_date"])
|
||||||
|
# NOTE: the filepath here isn't the path of the media item, it's the path that
|
||||||
|
# the NFO should be saved to. This works because the NFO's path is the same as
|
||||||
|
# the media's path, just with a different extension. If this ever changes I'll
|
||||||
|
# need to pass in the media item's path as well.
|
||||||
|
{season, episode} = determine_season_and_episode_number(nfo_filepath, upload_date)
|
||||||
|
|
||||||
# Cribbed from a combination of the Kodi wiki, ytdl-nfo, and ytdl-sub.
|
# Cribbed from a combination of the Kodi wiki, ytdl-nfo, and ytdl-sub.
|
||||||
# WHO NEEDS A FANCY XML PARSER ANYWAY?!
|
|
||||||
"""
|
"""
|
||||||
<?xml version="1.0" encoding="UTF-8" standalone="yes" ?>
|
<?xml version="1.0" encoding="UTF-8" standalone="yes" ?>
|
||||||
<episodedetails>
|
<episodedetails>
|
||||||
@@ -49,8 +54,8 @@ defmodule Pinchflat.Metadata.NfoBuilder do
|
|||||||
<uniqueid type="youtube" default="true">#{safe(metadata["id"])}</uniqueid>
|
<uniqueid type="youtube" default="true">#{safe(metadata["id"])}</uniqueid>
|
||||||
<plot>#{safe(metadata["description"])}</plot>
|
<plot>#{safe(metadata["description"])}</plot>
|
||||||
<aired>#{safe(upload_date)}</aired>
|
<aired>#{safe(upload_date)}</aired>
|
||||||
<season>#{safe(upload_date.year)}</season>
|
<season>#{safe(season)}</season>
|
||||||
<episode>#{Calendar.strftime(upload_date, "%m%d")}</episode>
|
<episode>#{episode}</episode>
|
||||||
<genre>YouTube</genre>
|
<genre>YouTube</genre>
|
||||||
</episodedetails>
|
</episodedetails>
|
||||||
"""
|
"""
|
||||||
@@ -67,4 +72,11 @@ defmodule Pinchflat.Metadata.NfoBuilder do
|
|||||||
</tvshow>
|
</tvshow>
|
||||||
"""
|
"""
|
||||||
end
|
end
|
||||||
|
|
||||||
|
defp determine_season_and_episode_number(filepath, upload_date) do
|
||||||
|
case MetadataFileHelpers.season_and_episode_from_media_filepath(filepath) do
|
||||||
|
{:ok, {season, episode}} -> {season, episode}
|
||||||
|
{:error, _} -> {upload_date.year, Calendar.strftime(upload_date, "%m%d")}
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -20,29 +20,49 @@ defmodule Pinchflat.Metadata.SourceImageParser do
|
|||||||
def store_source_images(base_directory, source_metadata) do
|
def store_source_images(base_directory, source_metadata) do
|
||||||
(source_metadata["thumbnails"] || [])
|
(source_metadata["thumbnails"] || [])
|
||||||
|> Enum.filter(&(&1["filepath"] != nil))
|
|> Enum.filter(&(&1["filepath"] != nil))
|
||||||
|> select_useful_images()
|
|> select_useful_images(source_metadata)
|
||||||
|> Enum.map(&move_image(&1, base_directory))
|
|> Enum.map(&move_image(&1, base_directory))
|
||||||
|> Enum.into(%{})
|
|> Enum.into(%{})
|
||||||
end
|
end
|
||||||
|
|
||||||
defp select_useful_images(images) do
|
defp select_useful_images(images, source_metadata) do
|
||||||
labelled_images =
|
labelled_images =
|
||||||
Enum.reduce(images, [], fn image_map, acc ->
|
Enum.reduce(images, %{}, fn image_map, acc ->
|
||||||
case image_map do
|
case image_map do
|
||||||
%{"id" => "avatar_uncropped"} ->
|
%{"id" => "avatar_uncropped"} -> put_image_key(acc, :poster, image_map["filepath"])
|
||||||
acc ++ [{:poster, :poster_filepath, image_map["filepath"]}]
|
%{"id" => "banner_uncropped"} -> put_image_key(acc, :fanart, image_map["filepath"])
|
||||||
|
_ -> acc
|
||||||
%{"id" => "banner_uncropped"} ->
|
|
||||||
acc ++ [{:fanart, :fanart_filepath, image_map["filepath"]}]
|
|
||||||
|
|
||||||
_ ->
|
|
||||||
acc
|
|
||||||
end
|
end
|
||||||
end)
|
end)
|
||||||
|
|
||||||
labelled_images
|
labelled_images
|
||||||
|> Enum.concat([{:banner, :banner_filepath, determine_best_banner(images)}])
|
|> add_fallback_poster(source_metadata)
|
||||||
|> Enum.filter(fn {_, _, tmp_filepath} -> tmp_filepath end)
|
|> put_image_key(:banner, determine_best_banner(images))
|
||||||
|
|> Enum.filter(fn {_key, attrs} -> attrs.current_filepath end)
|
||||||
|
end
|
||||||
|
|
||||||
|
# If a poster is set, short-circuit and return the images as-is
|
||||||
|
defp add_fallback_poster(%{poster: _} = images, _), do: images
|
||||||
|
|
||||||
|
# If a poster is NOT set, see if we can find a suitable image to use as a fallback
|
||||||
|
defp add_fallback_poster(images, source_metadata) do
|
||||||
|
case source_metadata["entries"] do
|
||||||
|
nil -> images
|
||||||
|
[] -> images
|
||||||
|
[first_entry | _] -> add_poster_from_entry_thumbnail(images, first_entry)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
defp add_poster_from_entry_thumbnail(images, entry) do
|
||||||
|
thumbnail =
|
||||||
|
(entry["thumbnails"] || [])
|
||||||
|
|> Enum.reverse()
|
||||||
|
|> Enum.find(& &1["filepath"])
|
||||||
|
|
||||||
|
case thumbnail do
|
||||||
|
nil -> images
|
||||||
|
_ -> put_image_key(images, :poster, thumbnail["filepath"])
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
defp determine_best_banner(images) do
|
defp determine_best_banner(images) do
|
||||||
@@ -58,12 +78,22 @@ defmodule Pinchflat.Metadata.SourceImageParser do
|
|||||||
Map.get(best_candidate || %{}, "filepath")
|
Map.get(best_candidate || %{}, "filepath")
|
||||||
end
|
end
|
||||||
|
|
||||||
defp move_image({filename, source_attr_name, tmp_filepath}, base_directory) do
|
defp move_image({_key, attrs}, base_directory) do
|
||||||
extension = Path.extname(tmp_filepath)
|
extension = Path.extname(attrs.current_filepath)
|
||||||
final_filepath = Path.join([base_directory, "#{filename}#{extension}"])
|
final_filepath = Path.join([base_directory, "#{attrs.final_filename}#{extension}"])
|
||||||
|
|
||||||
FilesystemUtils.cp_p!(tmp_filepath, final_filepath)
|
FilesystemUtils.cp_p!(attrs.current_filepath, final_filepath)
|
||||||
|
|
||||||
{source_attr_name, final_filepath}
|
{attrs.attribute_name, final_filepath}
|
||||||
|
end
|
||||||
|
|
||||||
|
defp put_image_key(map, key, image) do
|
||||||
|
attribute_atom = String.to_existing_atom("#{key}_filepath")
|
||||||
|
|
||||||
|
Map.put(map, key, %{
|
||||||
|
attribute_name: attribute_atom,
|
||||||
|
final_filename: to_string(key),
|
||||||
|
current_filepath: image
|
||||||
|
})
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -77,10 +77,8 @@ defmodule Pinchflat.Metadata.SourceMetadataStorageWorker do
|
|||||||
|
|
||||||
defp fetch_source_metadata_and_images(series_directory, source) do
|
defp fetch_source_metadata_and_images(series_directory, source) do
|
||||||
metadata_directory = MetadataFileHelpers.metadata_directory_for(source)
|
metadata_directory = MetadataFileHelpers.metadata_directory_for(source)
|
||||||
tmp_output_path = "#{tmp_directory()}/#{StringUtils.random_string(16)}/source_image.%(ext)S"
|
|
||||||
opts = [:write_all_thumbnails, convert_thumbnails: "jpg", output: tmp_output_path]
|
|
||||||
|
|
||||||
{:ok, metadata} = MediaCollection.get_source_metadata(source.original_url, opts)
|
{:ok, metadata} = fetch_metadata_for_source(source)
|
||||||
metadata_image_attrs = SourceImageParser.store_source_images(metadata_directory, metadata)
|
metadata_image_attrs = SourceImageParser.store_source_images(metadata_directory, metadata)
|
||||||
|
|
||||||
if source.media_profile.download_source_images && series_directory do
|
if source.media_profile.download_source_images && series_directory do
|
||||||
@@ -110,6 +108,20 @@ defmodule Pinchflat.Metadata.SourceMetadataStorageWorker do
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
defp fetch_metadata_for_source(source) do
|
||||||
|
tmp_output_path = "#{tmp_directory()}/#{StringUtils.random_string(16)}/source_image.%(ext)S"
|
||||||
|
base_opts = [convert_thumbnails: "jpg", output: tmp_output_path]
|
||||||
|
|
||||||
|
opts =
|
||||||
|
if source.collection_type == :channel do
|
||||||
|
base_opts ++ [:write_all_thumbnails, playlist_items: 0]
|
||||||
|
else
|
||||||
|
base_opts ++ [:write_thumbnail, playlist_items: 1]
|
||||||
|
end
|
||||||
|
|
||||||
|
MediaCollection.get_source_metadata(source.original_url, opts)
|
||||||
|
end
|
||||||
|
|
||||||
defp tmp_directory do
|
defp tmp_directory do
|
||||||
Application.get_env(:pinchflat, :tmpfile_directory)
|
Application.get_env(:pinchflat, :tmpfile_directory)
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -22,7 +22,8 @@ defmodule Pinchflat.YtDlp.Media do
|
|||||||
:livestream,
|
:livestream,
|
||||||
:short_form_content,
|
:short_form_content,
|
||||||
:uploaded_at,
|
:uploaded_at,
|
||||||
:duration_seconds
|
:duration_seconds,
|
||||||
|
:playlist_index
|
||||||
]
|
]
|
||||||
|
|
||||||
alias __MODULE__
|
alias __MODULE__
|
||||||
@@ -63,7 +64,7 @@ defmodule Pinchflat.YtDlp.Media do
|
|||||||
@doc """
|
@doc """
|
||||||
Returns a map representing the media at the given URL.
|
Returns a map representing the media at the given URL.
|
||||||
|
|
||||||
Returns {:ok, [map()]} | {:error, any, ...}.
|
Returns {:ok, %Media{}} | {:error, any, ...}.
|
||||||
"""
|
"""
|
||||||
def get_media_attributes(url) do
|
def get_media_attributes(url) do
|
||||||
runner = Application.get_env(:pinchflat, :yt_dlp_runner)
|
runner = Application.get_env(:pinchflat, :yt_dlp_runner)
|
||||||
@@ -84,9 +85,11 @@ defmodule Pinchflat.YtDlp.Media do
|
|||||||
|
|
||||||
@doc """
|
@doc """
|
||||||
Returns the output template for yt-dlp's indexing command.
|
Returns the output template for yt-dlp's indexing command.
|
||||||
|
|
||||||
|
NOTE: playlist_index is really only useful for playlists that will never change their order.
|
||||||
"""
|
"""
|
||||||
def indexing_output_template do
|
def indexing_output_template do
|
||||||
"%(.{id,title,was_live,webpage_url,description,aspect_ratio,duration,upload_date,timestamp})j"
|
"%(.{id,title,was_live,webpage_url,description,aspect_ratio,duration,upload_date,timestamp,playlist_index})j"
|
||||||
end
|
end
|
||||||
|
|
||||||
@doc """
|
@doc """
|
||||||
@@ -104,7 +107,8 @@ defmodule Pinchflat.YtDlp.Media do
|
|||||||
livestream: !!response["was_live"],
|
livestream: !!response["was_live"],
|
||||||
duration_seconds: response["duration"] && round(response["duration"]),
|
duration_seconds: response["duration"] && round(response["duration"]),
|
||||||
short_form_content: response["webpage_url"] && short_form_content?(response),
|
short_form_content: response["webpage_url"] && short_form_content?(response),
|
||||||
uploaded_at: response["upload_date"] && parse_uploaded_at(response)
|
uploaded_at: response["upload_date"] && parse_uploaded_at(response),
|
||||||
|
playlist_index: response["playlist_index"] || 0
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -99,10 +99,21 @@ defmodule Pinchflat.YtDlp.MediaCollection do
|
|||||||
as a compressed blob for possible future use. That's why it's not getting formatted like
|
as a compressed blob for possible future use. That's why it's not getting formatted like
|
||||||
`get_source_details/1`
|
`get_source_details/1`
|
||||||
|
|
||||||
|
! IMPORTANT ! - you'll always want to set `playlist_items: int` in `addl_opts.
|
||||||
|
This is great if you want to also return details about the videos in the playlists,
|
||||||
|
but it should be set in all cases to not over-fetch data.
|
||||||
|
For channels you should usually set this to 0 since channels return all the
|
||||||
|
metadata we need without needing to fetch the videos. On the other hand, playlists
|
||||||
|
don't return very useful images so you can set this to 1 to get the first video's
|
||||||
|
images, for instance.
|
||||||
|
|
||||||
Returns {:ok, map()} | {:error, any, ...}.
|
Returns {:ok, map()} | {:error, any, ...}.
|
||||||
"""
|
"""
|
||||||
def get_source_metadata(source_url, addl_opts \\ []) do
|
def get_source_metadata(source_url, addl_opts \\ [playlist_items: 0]) do
|
||||||
opts = [playlist_items: 0] ++ addl_opts
|
# This only validates that the `playlist_items` key is present. It's otherwise unused
|
||||||
|
_playlist_items = Keyword.fetch!(addl_opts, :playlist_items)
|
||||||
|
|
||||||
|
opts = [:skip_download] ++ addl_opts
|
||||||
output_template = "playlist:%()j"
|
output_template = "playlist:%()j"
|
||||||
|
|
||||||
with {:ok, output} <- backend_runner().run(source_url, opts, output_template),
|
with {:ok, output} <- backend_runner().run(source_url, opts, output_template),
|
||||||
|
|||||||
@@ -19,6 +19,7 @@ defmodule PinchflatWeb.CoreComponents do
|
|||||||
import PinchflatWeb.Gettext
|
import PinchflatWeb.Gettext
|
||||||
|
|
||||||
alias Phoenix.LiveView.JS
|
alias Phoenix.LiveView.JS
|
||||||
|
alias PinchflatWeb.CustomComponents.TextComponents
|
||||||
|
|
||||||
@doc """
|
@doc """
|
||||||
Renders a modal.
|
Renders a modal.
|
||||||
@@ -644,7 +645,11 @@ defmodule PinchflatWeb.CoreComponents do
|
|||||||
<li :for={{k, v} <- @iterable_attributes} class="mb-2 w-2/3">
|
<li :for={{k, v} <- @iterable_attributes} class="mb-2 w-2/3">
|
||||||
<strong><%= k %>:</strong>
|
<strong><%= k %>:</strong>
|
||||||
<code class="inline-block text-sm font-mono text-gray p-0.5 mx-0.5">
|
<code class="inline-block text-sm font-mono text-gray p-0.5 mx-0.5">
|
||||||
|
<%= if is_binary(v) && URI.parse(v).scheme && URI.parse(v).scheme =~ "http" do %>
|
||||||
|
<TextComponents.inline_link href={v}><%= v %></TextComponents.inline_link>
|
||||||
|
<% else %>
|
||||||
<%= v %>
|
<%= v %>
|
||||||
|
<% end %>
|
||||||
</code>
|
</code>
|
||||||
</li>
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
|||||||
@@ -53,12 +53,24 @@ defmodule PinchflatWeb.MediaProfiles.MediaProfileHTML do
|
|||||||
]
|
]
|
||||||
end
|
end
|
||||||
|
|
||||||
def custom_output_template_options do
|
def media_center_custom_output_template_options do
|
||||||
|
%{
|
||||||
|
season_by_year__episode_by_date: "<code>Season YYYY/sYYYYeMMDD</code>",
|
||||||
|
season_by_year__episode_by_date_and_index:
|
||||||
|
"same as the above but it handles dates better. <strong>This is the recommended option</strong>",
|
||||||
|
static_season__episode_by_index:
|
||||||
|
"<code>Season 1/s01eXX</code> where <code>XX</code> is the video's position in the playlist. Only recommended for playlists (not channels) that don't change",
|
||||||
|
static_season__episode_by_date:
|
||||||
|
"<code>Season 1/s01eYYMMDD</code>. Recommended for playlists that might change or where order isn't important"
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def other_custom_output_template_options do
|
||||||
%{
|
%{
|
||||||
upload_day: nil,
|
upload_day: nil,
|
||||||
upload_month: nil,
|
upload_month: nil,
|
||||||
upload_year: nil,
|
upload_year: nil,
|
||||||
upload_yyyy_mm_dd: "the upload date in the format YYYY-MM-DD",
|
upload_yyyy_mm_dd: "the upload date in the format <code>YYYY-MM-DD</code>",
|
||||||
source_custom_name: "the name of the sources that use this profile",
|
source_custom_name: "the name of the sources that use this profile",
|
||||||
source_collection_id: "the YouTube ID of the sources that use this profile",
|
source_collection_id: "the YouTube ID of the sources that use this profile",
|
||||||
source_collection_name:
|
source_collection_name:
|
||||||
@@ -66,9 +78,11 @@ defmodule PinchflatWeb.MediaProfiles.MediaProfileHTML do
|
|||||||
source_collection_type: "the collection type of the sources using this profile. Either 'channel' or 'playlist'",
|
source_collection_type: "the collection type of the sources using this profile. Either 'channel' or 'playlist'",
|
||||||
artist_name: "the name of the artist with fallbacks to other uploader fields",
|
artist_name: "the name of the artist with fallbacks to other uploader fields",
|
||||||
season_from_date: "alias for upload_year",
|
season_from_date: "alias for upload_year",
|
||||||
season_episode_from_date: "the upload date formatted as sYYYYeMMDD",
|
season_episode_from_date: "the upload date formatted as <code>sYYYYeMMDD</code>",
|
||||||
season_episode_index_from_date:
|
season_episode_index_from_date:
|
||||||
"the upload date formatted as sYYYYeMMDDII where II is an index to prevent date collisions"
|
"the upload date formatted as <code>sYYYYeMMDDII</code> where <code>II</code> is an index to prevent date collisions",
|
||||||
|
media_playlist_index:
|
||||||
|
"the place of the media item in the playlist. Do not use with channels. May not work if the playlist is updated"
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -77,7 +91,6 @@ defmodule PinchflatWeb.MediaProfiles.MediaProfileHTML do
|
|||||||
id
|
id
|
||||||
ext
|
ext
|
||||||
title
|
title
|
||||||
fulltitle
|
|
||||||
uploader
|
uploader
|
||||||
channel
|
channel
|
||||||
upload_date
|
upload_date
|
||||||
@@ -99,7 +112,7 @@ defmodule PinchflatWeb.MediaProfiles.MediaProfileHTML do
|
|||||||
end
|
end
|
||||||
|
|
||||||
defp media_center_output_template do
|
defp media_center_output_template do
|
||||||
"/shows/{{ source_custom_name }}/Season {{ season_from_date }}/{{ season_episode_index_from_date }} - {{ title }}.{{ ext }}"
|
"/shows/{{ source_custom_name }}/{{ season_by_year__episode_by_date_and_index }} - {{ title }}.{{ ext }}"
|
||||||
end
|
end
|
||||||
|
|
||||||
defp audio_output_template do
|
defp audio_output_template do
|
||||||
|
|||||||
+11
-11
@@ -84,22 +84,22 @@
|
|||||||
/>
|
/>
|
||||||
</section>
|
</section>
|
||||||
|
|
||||||
<section x-data="{ presets: { default: false, media_center: false, audio: false, archiving: false } }">
|
|
||||||
<.input
|
|
||||||
field={f[:download_auto_subs]}
|
|
||||||
type="toggle"
|
|
||||||
label="Download Autogenerated Subtitles"
|
|
||||||
help="Prefers normal subs but will download autogenerated if needed. Requires 'Download Subtitles' to be enabled"
|
|
||||||
x-init="$watch('selectedPreset', p => p && (enabled = presets[p]))"
|
|
||||||
/>
|
|
||||||
</section>
|
|
||||||
|
|
||||||
<section x-data="{ presets: { default: true, media_center: true, audio: false, archiving: true } }">
|
<section x-data="{ presets: { default: true, media_center: true, audio: false, archiving: true } }">
|
||||||
<.input
|
<.input
|
||||||
field={f[:embed_subs]}
|
field={f[:embed_subs]}
|
||||||
type="toggle"
|
type="toggle"
|
||||||
label="Embed Subtitles"
|
label="Embed Subtitles"
|
||||||
help="Downloads and embeds subtitles in the media file itself, if supported. Uneffected by 'Download Subtitles' (recommended)"
|
help="Downloads and embeds subtitles in the media file itself, if supported. Uneffected by 'Download Subtitles'"
|
||||||
|
x-init="$watch('selectedPreset', p => p && (enabled = presets[p]))"
|
||||||
|
/>
|
||||||
|
</section>
|
||||||
|
|
||||||
|
<section x-data="{ presets: { default: false, media_center: false, audio: false, archiving: false } }">
|
||||||
|
<.input
|
||||||
|
field={f[:download_auto_subs]}
|
||||||
|
type="toggle"
|
||||||
|
label="Use Autogenerated Subtitles"
|
||||||
|
help="Prefers normal subs with 'Download Subtitles' or 'Embed Subtitles' but will use autogenerated subs if needed."
|
||||||
x-init="$watch('selectedPreset', p => p && (enabled = presets[p]))"
|
x-init="$watch('selectedPreset', p => p && (enabled = presets[p]))"
|
||||||
/>
|
/>
|
||||||
</section>
|
</section>
|
||||||
|
|||||||
+14
-7
@@ -1,7 +1,7 @@
|
|||||||
<%!-- The heex HTML formatter is really struggling with this file - I apologize in advance --%>
|
<%!-- The heex HTML formatter is really struggling with this file - I apologize in advance --%>
|
||||||
<aside>
|
<aside>
|
||||||
<h2 class="text-xl font-bold mb-2">Output Template Syntax</h2>
|
<h2 class="text-xl font-bold mb-2">Output Template Syntax</h2>
|
||||||
<section class="ml-2 md:ml-4 mb-4 max-w-prose">
|
<section class="ml-2 md:ml-4 mb-4 max-w-prose overflow-auto">
|
||||||
<p>When generating an output template, you have 3 options for syntax:</p>
|
<p>When generating an output template, you have 3 options for syntax:</p>
|
||||||
<ul class="list-disc list-inside ml-2 md:ml-5">
|
<ul class="list-disc list-inside ml-2 md:ml-5">
|
||||||
<li>
|
<li>
|
||||||
@@ -46,7 +46,7 @@
|
|||||||
</section>
|
</section>
|
||||||
|
|
||||||
<h2 class="text-xl font-bold mb-2">Template Options</h2>
|
<h2 class="text-xl font-bold mb-2">Template Options</h2>
|
||||||
<section class="ml-2 md:ml-4 mb-4">
|
<section class="ml-2 md:ml-4 mb-4 overflow-auto">
|
||||||
<p class="max-w-prose">
|
<p class="max-w-prose">
|
||||||
Any single-word <code class="text-sm">yt-dlp</code>
|
Any single-word <code class="text-sm">yt-dlp</code>
|
||||||
option
|
option
|
||||||
@@ -56,16 +56,23 @@
|
|||||||
can be used with the curly braced liquid-style syntax.
|
can be used with the curly braced liquid-style syntax.
|
||||||
This is just a list of the most common options as well as some custom aliases
|
This is just a list of the most common options as well as some custom aliases
|
||||||
</p>
|
</p>
|
||||||
<h3 class="text-lg font-bold mb-2">Custom Aliases</h3>
|
<h3 class="text-lg font-bold my-2">Media Center Custom Aliases</h3>
|
||||||
<ul class="list-disc list-inside ml-2 md:ml-5">
|
<ul class="list-disc list-inside mb-4 ml-2 md:ml-5 max-w-prose">
|
||||||
<li :for={{k, v} <- custom_output_template_options()}>
|
<li :for={{k, v} <- media_center_custom_output_template_options()} class="mt-1">
|
||||||
<.inline_code>{{ <%= k %> }}</.inline_code>
|
<.inline_code>{{ <%= k %> }}</.inline_code>
|
||||||
<span :if={v}>- <%= v %></span>
|
<span :if={v}>- <%= html_escape({:safe, v}) %></span>
|
||||||
|
</li>
|
||||||
|
</ul>
|
||||||
|
<h3 class="text-lg font-bold mb-2">Other Custom Aliases</h3>
|
||||||
|
<ul class="list-disc list-inside mb-4 ml-2 md:ml-5 max-w-prose">
|
||||||
|
<li :for={{k, v} <- other_custom_output_template_options()} class="mt-1">
|
||||||
|
<.inline_code>{{ <%= k %> }}</.inline_code>
|
||||||
|
<span :if={v}>- <%= html_escape({:safe, v}) %></span>
|
||||||
</li>
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
<h3 class="text-lg font-bold mb-2">Common Options</h3>
|
<h3 class="text-lg font-bold mb-2">Common Options</h3>
|
||||||
<ul class="list-disc list-inside ml-2 md:ml-5">
|
<ul class="list-disc list-inside ml-2 md:ml-5">
|
||||||
<li :for={opt <- common_output_template_options()}>
|
<li :for={opt <- common_output_template_options()} class="mt-1">
|
||||||
<.inline_code>{{ <%= opt %> }}</.inline_code>
|
<.inline_code>{{ <%= opt %> }}</.inline_code>
|
||||||
</li>
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
|||||||
@@ -41,13 +41,30 @@ defmodule PinchflatWeb.Sources.SourceController do
|
|||||||
render(conn, :index, sources: Repo.all(source_query))
|
render(conn, :index, sources: Repo.all(source_query))
|
||||||
end
|
end
|
||||||
|
|
||||||
def new(conn, _params) do
|
def new(conn, params) do
|
||||||
changeset = Sources.change_source(%Source{})
|
# This lets me preload the settings from another source for more efficient creation
|
||||||
|
cs_struct =
|
||||||
|
case to_string(params["template_id"]) do
|
||||||
|
"" -> %Source{}
|
||||||
|
template_id -> Repo.get(Source, template_id) || %Source{}
|
||||||
|
end
|
||||||
|
|
||||||
render(conn, :new,
|
render(conn, :new,
|
||||||
changeset: changeset,
|
|
||||||
media_profiles: media_profiles(),
|
media_profiles: media_profiles(),
|
||||||
layout: get_onboarding_layout()
|
layout: get_onboarding_layout(),
|
||||||
|
# Most of these don't actually _need_ to be nullified at this point,
|
||||||
|
# but if I don't do it now I know it'll bite me
|
||||||
|
changeset:
|
||||||
|
Sources.change_source(%Source{
|
||||||
|
cs_struct
|
||||||
|
| id: nil,
|
||||||
|
uuid: nil,
|
||||||
|
custom_name: nil,
|
||||||
|
collection_name: nil,
|
||||||
|
collection_id: nil,
|
||||||
|
collection_type: nil,
|
||||||
|
original_url: nil
|
||||||
|
})
|
||||||
)
|
)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ defmodule PinchflatWeb.Sources.SourceHTML do
|
|||||||
attr :changeset, Ecto.Changeset, required: true
|
attr :changeset, Ecto.Changeset, required: true
|
||||||
attr :action, :string, required: true
|
attr :action, :string, required: true
|
||||||
attr :media_profiles, :list, required: true
|
attr :media_profiles, :list, required: true
|
||||||
|
attr :method, :string, required: true
|
||||||
|
|
||||||
def source_form(assigns)
|
def source_form(assigns)
|
||||||
|
|
||||||
|
|||||||
@@ -26,6 +26,11 @@
|
|||||||
<span x-show="copied" x-transition.duration.150ms><.icon name="hero-check" class="ml-2 h-4 w-4" /></span>
|
<span x-show="copied" x-transition.duration.150ms><.icon name="hero-check" class="ml-2 h-4 w-4" /></span>
|
||||||
</span>
|
</span>
|
||||||
</:option>
|
</:option>
|
||||||
|
<:option>
|
||||||
|
<.link href={~p"/sources/new?template_id=#{@source}"} method="get">
|
||||||
|
Use as Template
|
||||||
|
</.link>
|
||||||
|
</:option>
|
||||||
<:option>
|
<:option>
|
||||||
<div class="h-px w-full bg-bodydark2"></div>
|
<div class="h-px w-full bg-bodydark2"></div>
|
||||||
</:option>
|
</:option>
|
||||||
|
|||||||
@@ -10,7 +10,12 @@
|
|||||||
<div class="rounded-sm border border-stroke bg-white px-5 pb-2.5 pt-6 shadow-default dark:border-strokedark dark:bg-boxdark sm:px-7.5 xl:pb-1">
|
<div class="rounded-sm border border-stroke bg-white px-5 pb-2.5 pt-6 shadow-default dark:border-strokedark dark:bg-boxdark sm:px-7.5 xl:pb-1">
|
||||||
<div class="max-w-full">
|
<div class="max-w-full">
|
||||||
<div class="flex flex-col gap-10">
|
<div class="flex flex-col gap-10">
|
||||||
<.source_form changeset={@changeset} media_profiles={@media_profiles} action={~p"/sources/#{@source}"} />
|
<.source_form
|
||||||
|
changeset={@changeset}
|
||||||
|
media_profiles={@media_profiles}
|
||||||
|
action={~p"/sources/#{@source}"}
|
||||||
|
method="patch"
|
||||||
|
/>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -8,7 +8,7 @@
|
|||||||
<div class="rounded-sm border border-stroke bg-white px-5 pb-2.5 pt-6 shadow-default dark:border-strokedark dark:bg-boxdark sm:px-7.5 xl:pb-1">
|
<div class="rounded-sm border border-stroke bg-white px-5 pb-2.5 pt-6 shadow-default dark:border-strokedark dark:bg-boxdark sm:px-7.5 xl:pb-1">
|
||||||
<div class="max-w-full">
|
<div class="max-w-full">
|
||||||
<div class="flex flex-col gap-10">
|
<div class="flex flex-col gap-10">
|
||||||
<.source_form changeset={@changeset} media_profiles={@media_profiles} action={~p"/sources"} />
|
<.source_form changeset={@changeset} media_profiles={@media_profiles} action={~p"/sources"} method="post" />
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -2,6 +2,7 @@
|
|||||||
:let={f}
|
:let={f}
|
||||||
for={@changeset}
|
for={@changeset}
|
||||||
action={@action}
|
action={@action}
|
||||||
|
method={@method}
|
||||||
x-data="{ advancedMode: !!JSON.parse(localStorage.getItem('advancedMode')) }"
|
x-data="{ advancedMode: !!JSON.parse(localStorage.getItem('advancedMode')) }"
|
||||||
x-init="$watch('advancedMode', value => localStorage.setItem('advancedMode', JSON.stringify(value)))"
|
x-init="$watch('advancedMode', value => localStorage.setItem('advancedMode', JSON.stringify(value)))"
|
||||||
>
|
>
|
||||||
@@ -10,7 +11,7 @@
|
|||||||
</.error>
|
</.error>
|
||||||
|
|
||||||
<section x-data="{ mediaProfileId: null }">
|
<section x-data="{ mediaProfileId: null }">
|
||||||
<section class="flex justify-between items-center mt-8">
|
<section class="flex justify-between items-center mt-4">
|
||||||
<h3 class=" text-2xl text-black dark:text-white">
|
<h3 class=" text-2xl text-black dark:text-white">
|
||||||
General Options
|
General Options
|
||||||
</h3>
|
</h3>
|
||||||
@@ -19,6 +20,14 @@
|
|||||||
</span>
|
</span>
|
||||||
</section>
|
</section>
|
||||||
|
|
||||||
|
<.input
|
||||||
|
field={f[:original_url]}
|
||||||
|
type="text"
|
||||||
|
label="Source URL"
|
||||||
|
help="URL of a channel or playlist (required)"
|
||||||
|
x-init="$el.focus()"
|
||||||
|
/>
|
||||||
|
|
||||||
<.input
|
<.input
|
||||||
field={f[:custom_name]}
|
field={f[:custom_name]}
|
||||||
type="text"
|
type="text"
|
||||||
@@ -26,8 +35,6 @@
|
|||||||
help="Does not impact indexing or downloading. Will be inferred from the source if left blank"
|
help="Does not impact indexing or downloading. Will be inferred from the source if left blank"
|
||||||
/>
|
/>
|
||||||
|
|
||||||
<.input field={f[:original_url]} type="text" label="Source URL" help="URL of a channel or playlist (required)" />
|
|
||||||
|
|
||||||
<.input
|
<.input
|
||||||
field={f[:media_profile_id]}
|
field={f[:media_profile_id]}
|
||||||
options={Enum.map(@media_profiles, &{&1.name, &1.id})}
|
options={Enum.map(@media_profiles, &{&1.name, &1.id})}
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ defmodule Pinchflat.MixProject do
|
|||||||
def project do
|
def project do
|
||||||
[
|
[
|
||||||
app: :pinchflat,
|
app: :pinchflat,
|
||||||
version: "2024.6.25",
|
version: "2024.7.18",
|
||||||
elixir: "~> 1.17",
|
elixir: "~> 1.17",
|
||||||
elixirc_paths: elixirc_paths(Mix.env()),
|
elixirc_paths: elixirc_paths(Mix.env()),
|
||||||
start_permanent: Mix.env() == :prod,
|
start_permanent: Mix.env() == :prod,
|
||||||
|
|||||||
Binary file not shown.
|
Before Width: | Height: | Size: 468 KiB After Width: | Height: | Size: 424 KiB |
@@ -0,0 +1,9 @@
|
|||||||
|
defmodule Pinchflat.Repo.Migrations.AddPlaylistIndexToMediaItems do
|
||||||
|
use Ecto.Migration
|
||||||
|
|
||||||
|
def change do
|
||||||
|
alter table(:media_items) do
|
||||||
|
add :playlist_index, :integer, null: false, default: 0
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@@ -93,15 +93,23 @@ defmodule Pinchflat.Downloading.DownloadOptionBuilderTest do
|
|||||||
end
|
end
|
||||||
|
|
||||||
test "includes :write_auto_subs option when specified", %{media_item: media_item} do
|
test "includes :write_auto_subs option when specified", %{media_item: media_item} do
|
||||||
media_item = update_media_profile_attribute(media_item, %{download_subs: true, download_auto_subs: true})
|
media_item_1 = update_media_profile_attribute(media_item, %{download_subs: true, download_auto_subs: true})
|
||||||
|
media_item_2 = update_media_profile_attribute(media_item, %{embed_subs: true, download_auto_subs: true})
|
||||||
|
|
||||||
assert {:ok, res} = DownloadOptionBuilder.build(media_item)
|
assert {:ok, res_1} = DownloadOptionBuilder.build(media_item_1)
|
||||||
|
assert {:ok, res_2} = DownloadOptionBuilder.build(media_item_2)
|
||||||
|
|
||||||
assert :write_auto_subs in res
|
assert :write_auto_subs in res_1
|
||||||
|
assert :write_auto_subs in res_2
|
||||||
end
|
end
|
||||||
|
|
||||||
test "doesn't include :write_auto_subs option when download_subs is false", %{media_item: media_item} do
|
test "doesn't include :write_auto_subs option when download_subs and embed_subs is false", %{media_item: media_item} do
|
||||||
media_item = update_media_profile_attribute(media_item, %{download_subs: false, download_auto_subs: true})
|
media_item =
|
||||||
|
update_media_profile_attribute(media_item, %{
|
||||||
|
download_subs: false,
|
||||||
|
embed_subs: false,
|
||||||
|
download_auto_subs: true
|
||||||
|
})
|
||||||
|
|
||||||
assert {:ok, res} = DownloadOptionBuilder.build(media_item)
|
assert {:ok, res} = DownloadOptionBuilder.build(media_item)
|
||||||
|
|
||||||
|
|||||||
@@ -689,7 +689,24 @@ defmodule Pinchflat.MediaTest do
|
|||||||
assert {:ok, %MediaItem{} = media_item_2} = Media.create_media_item_from_backend_attrs(source, different_attrs)
|
assert {:ok, %MediaItem{} = media_item_2} = Media.create_media_item_from_backend_attrs(source, different_attrs)
|
||||||
|
|
||||||
assert media_item_1.id == media_item_2.id
|
assert media_item_1.id == media_item_2.id
|
||||||
assert media_item_2.title == different_attrs.title
|
assert Repo.reload(media_item_2).title == different_attrs.title
|
||||||
|
end
|
||||||
|
|
||||||
|
test "doesn't update fields like playlist_index" do
|
||||||
|
source = source_fixture()
|
||||||
|
|
||||||
|
media_attrs =
|
||||||
|
media_attributes_return_fixture()
|
||||||
|
|> Phoenix.json_library().decode!()
|
||||||
|
|> Map.put("playlist_index", 1)
|
||||||
|
|> YtDlpMedia.response_to_struct()
|
||||||
|
|
||||||
|
different_attrs = %YtDlpMedia{media_attrs | playlist_index: 9999}
|
||||||
|
|
||||||
|
assert {:ok, %MediaItem{} = _media_item_1} = Media.create_media_item_from_backend_attrs(source, media_attrs)
|
||||||
|
assert {:ok, %MediaItem{} = media_item_2} = Media.create_media_item_from_backend_attrs(source, different_attrs)
|
||||||
|
|
||||||
|
assert Repo.reload(media_item_2).playlist_index == media_attrs.playlist_index
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -11,6 +11,16 @@ defmodule Pinchflat.Metadata.MetadataFileHelpersTest do
|
|||||||
{:ok, %{media_item: media_item}}
|
{:ok, %{media_item: media_item}}
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe "metadata_directory_for/1" do
|
||||||
|
test "returns the metadata directory for the given record", %{media_item: media_item} do
|
||||||
|
base_metadata_directory = Application.get_env(:pinchflat, :metadata_directory)
|
||||||
|
|
||||||
|
metadata_directory = Helpers.metadata_directory_for(media_item)
|
||||||
|
|
||||||
|
assert metadata_directory == Path.join([base_metadata_directory, "media_items", "#{media_item.id}"])
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
describe "compress_and_store_metadata_for/2" do
|
describe "compress_and_store_metadata_for/2" do
|
||||||
test "returns the filepath", %{media_item: media_item} do
|
test "returns the filepath", %{media_item: media_item} do
|
||||||
metadata_map = %{"foo" => "bar"}
|
metadata_map = %{"foo" => "bar"}
|
||||||
@@ -142,13 +152,20 @@ defmodule Pinchflat.Metadata.MetadataFileHelpersTest do
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "metadata_directory_for/1" do
|
describe "season_and_episode_from_media_filepath/1" do
|
||||||
test "returns the metadata directory for the given record", %{media_item: media_item} do
|
test "returns a season and episode if one can be determined" do
|
||||||
base_metadata_directory = Application.get_env(:pinchflat, :metadata_directory)
|
assert {:ok, {"1", "2"}} = Helpers.season_and_episode_from_media_filepath("/foo/s1e2 - test.mp4")
|
||||||
|
assert {:ok, {"1", "2"}} = Helpers.season_and_episode_from_media_filepath("/foo/S1E2 - test.mp4")
|
||||||
|
assert {:ok, {"001", "002"}} = Helpers.season_and_episode_from_media_filepath("/foo/s001e002 - test.mp4")
|
||||||
|
assert {:ok, {"1", "2"}} = Helpers.season_and_episode_from_media_filepath("/foo/s1e2bar - test.mp4")
|
||||||
|
assert {:ok, {"1", "2"}} = Helpers.season_and_episode_from_media_filepath("/foo/bar s1e2 - test.mp4")
|
||||||
|
end
|
||||||
|
|
||||||
metadata_directory = Helpers.metadata_directory_for(media_item)
|
test "returns an error if a season and episode can't be determined" do
|
||||||
|
assert {:error, :indeterminable} = Helpers.season_and_episode_from_media_filepath("/foo/test.mp4")
|
||||||
assert metadata_directory == Path.join([base_metadata_directory, "media_items", "#{media_item.id}"])
|
assert {:error, :indeterminable} = Helpers.season_and_episode_from_media_filepath("/foo/s1 - test.mp4")
|
||||||
|
assert {:error, :indeterminable} = Helpers.season_and_episode_from_media_filepath("/foo/s1e - test.mp4")
|
||||||
|
assert {:error, :indeterminable} = Helpers.season_and_episode_from_media_filepath("/foo/s1etest.mp4")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -5,7 +5,7 @@ defmodule Pinchflat.Metadata.NfoBuilderTest do
|
|||||||
alias Pinchflat.Utils.FilesystemUtils
|
alias Pinchflat.Utils.FilesystemUtils
|
||||||
|
|
||||||
setup do
|
setup do
|
||||||
filepath = FilesystemUtils.generate_metadata_tmpfile(:json)
|
filepath = FilesystemUtils.generate_metadata_tmpfile(:nfo)
|
||||||
|
|
||||||
on_exit(fn -> File.rm!(filepath) end)
|
on_exit(fn -> File.rm!(filepath) end)
|
||||||
|
|
||||||
@@ -45,6 +45,43 @@ defmodule Pinchflat.Metadata.NfoBuilderTest do
|
|||||||
|
|
||||||
assert String.contains?(nfo, "hello' & <world>")
|
assert String.contains?(nfo, "hello' & <world>")
|
||||||
end
|
end
|
||||||
|
|
||||||
|
test "uses the season and episode number from the filepath if it can be determined" do
|
||||||
|
metadata = %{
|
||||||
|
"title" => "title",
|
||||||
|
"uploader" => "uploader",
|
||||||
|
"id" => "id",
|
||||||
|
"description" => "description",
|
||||||
|
"upload_date" => "20210101"
|
||||||
|
}
|
||||||
|
|
||||||
|
tmpfile_directory = Application.get_env(:pinchflat, :tmpfile_directory)
|
||||||
|
filepath = Path.join([tmpfile_directory, "foo/s0123e456.nfo"])
|
||||||
|
|
||||||
|
result = NfoBuilder.build_and_store_for_media_item(filepath, metadata)
|
||||||
|
nfo = File.read!(result)
|
||||||
|
|
||||||
|
assert String.contains?(nfo, "<season>0123</season>")
|
||||||
|
assert String.contains?(nfo, "<episode>456</episode>")
|
||||||
|
|
||||||
|
File.rm!(filepath)
|
||||||
|
end
|
||||||
|
|
||||||
|
test "uses the upload date if the season and episode number can't be determined", %{filepath: filepath} do
|
||||||
|
metadata = %{
|
||||||
|
"title" => "title",
|
||||||
|
"uploader" => "uploader",
|
||||||
|
"id" => "id",
|
||||||
|
"description" => "description",
|
||||||
|
"upload_date" => "20210101"
|
||||||
|
}
|
||||||
|
|
||||||
|
result = NfoBuilder.build_and_store_for_media_item(filepath, metadata)
|
||||||
|
nfo = File.read!(result)
|
||||||
|
|
||||||
|
assert String.contains?(nfo, "<season>2021</season>")
|
||||||
|
assert String.contains?(nfo, "<episode>0101</episode>")
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "build_and_store_for_source/2" do
|
describe "build_and_store_for_source/2" do
|
||||||
|
|||||||
@@ -75,4 +75,51 @@ defmodule Pinchflat.Metadata.SourceImageParserTest do
|
|||||||
assert SourceImageParser.store_source_images(@base_dir, metadata) == %{}
|
assert SourceImageParser.store_source_images(@base_dir, metadata) == %{}
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe "store_source_images/2 when testing fallbacks" do
|
||||||
|
test "uses the entries list for a fallback poster if needed" do
|
||||||
|
metadata = %{
|
||||||
|
"thumbnails" => [],
|
||||||
|
"entries" => [
|
||||||
|
%{
|
||||||
|
"thumbnails" => [%{"filepath" => "/app/test/support/files/channel_photos/a.0.jpg"}]
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
expected = %{
|
||||||
|
poster_filepath: "#{@base_dir}/poster.jpg"
|
||||||
|
}
|
||||||
|
|
||||||
|
assert SourceImageParser.store_source_images(@base_dir, metadata) == expected
|
||||||
|
end
|
||||||
|
|
||||||
|
test "doesn't blow up if the entries list doesn't have any suitable thumbnails" do
|
||||||
|
metadata = %{
|
||||||
|
"thumbnails" => [],
|
||||||
|
"entries" => [
|
||||||
|
%{"thumbnails" => [%{"id" => "1"}]}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
|
assert SourceImageParser.store_source_images(@base_dir, metadata) == %{}
|
||||||
|
end
|
||||||
|
|
||||||
|
test "doesn't use the entries list if it's empty" do
|
||||||
|
metadata = %{
|
||||||
|
"thumbnails" => [],
|
||||||
|
"entries" => []
|
||||||
|
}
|
||||||
|
|
||||||
|
assert SourceImageParser.store_source_images(@base_dir, metadata) == %{}
|
||||||
|
end
|
||||||
|
|
||||||
|
test "doesn't use the entries list if it's not present" do
|
||||||
|
metadata = %{
|
||||||
|
"thumbnails" => []
|
||||||
|
}
|
||||||
|
|
||||||
|
assert SourceImageParser.store_source_images(@base_dir, metadata) == %{}
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -143,7 +143,9 @@ defmodule Pinchflat.Metadata.SourceMetadataStorageWorkerTest do
|
|||||||
|
|
||||||
{:ok, source_details_return_fixture(%{filename: filename})}
|
{:ok, source_details_return_fixture(%{filename: filename})}
|
||||||
|
|
||||||
_url, _opts, ot when ot == @metadata_ot ->
|
_url, opts, ot when ot == @metadata_ot ->
|
||||||
|
assert {:convert_thumbnails, "jpg"} in opts
|
||||||
|
|
||||||
{:ok, render_metadata(:channel_source_metadata)}
|
{:ok, render_metadata(:channel_source_metadata)}
|
||||||
end)
|
end)
|
||||||
|
|
||||||
@@ -164,6 +166,42 @@ defmodule Pinchflat.Metadata.SourceMetadataStorageWorkerTest do
|
|||||||
Sources.delete_source(source, delete_files: true)
|
Sources.delete_source(source, delete_files: true)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
test "calls one set of yt-dlp metadata opts for channels" do
|
||||||
|
stub(YtDlpRunnerMock, :run, fn
|
||||||
|
_url, _opts, ot when ot == @source_details_ot ->
|
||||||
|
{:ok, source_details_return_fixture()}
|
||||||
|
|
||||||
|
_url, opts, ot when ot == @metadata_ot ->
|
||||||
|
assert {:playlist_items, 0} in opts
|
||||||
|
assert :write_all_thumbnails in opts
|
||||||
|
|
||||||
|
{:ok, render_metadata(:channel_source_metadata)}
|
||||||
|
end)
|
||||||
|
|
||||||
|
profile = media_profile_fixture(%{download_source_images: true})
|
||||||
|
source = source_fixture(media_profile_id: profile.id, collection_type: :channel)
|
||||||
|
|
||||||
|
perform_job(SourceMetadataStorageWorker, %{id: source.id})
|
||||||
|
end
|
||||||
|
|
||||||
|
test "calls another set of yt-dlp metadata opts for playlists" do
|
||||||
|
stub(YtDlpRunnerMock, :run, fn
|
||||||
|
_url, _opts, ot when ot == @source_details_ot ->
|
||||||
|
{:ok, source_details_return_fixture()}
|
||||||
|
|
||||||
|
_url, opts, ot when ot == @metadata_ot ->
|
||||||
|
assert {:playlist_items, 1} in opts
|
||||||
|
assert :write_thumbnail in opts
|
||||||
|
|
||||||
|
{:ok, render_metadata(:channel_source_metadata)}
|
||||||
|
end)
|
||||||
|
|
||||||
|
profile = media_profile_fixture(%{download_source_images: true})
|
||||||
|
source = source_fixture(media_profile_id: profile.id, collection_type: :playlist)
|
||||||
|
|
||||||
|
perform_job(SourceMetadataStorageWorker, %{id: source.id})
|
||||||
|
end
|
||||||
|
|
||||||
test "does not store source images if the profile is not set to" do
|
test "does not store source images if the profile is not set to" do
|
||||||
stub(YtDlpRunnerMock, :run, fn
|
stub(YtDlpRunnerMock, :run, fn
|
||||||
_url, _opts, ot when ot == @source_details_ot ->
|
_url, _opts, ot when ot == @source_details_ot ->
|
||||||
|
|||||||
@@ -129,7 +129,7 @@ defmodule Pinchflat.YtDlp.MediaCollectionTest do
|
|||||||
|
|
||||||
test "it passes the expected args to the backend runner" do
|
test "it passes the expected args to the backend runner" do
|
||||||
expect(YtDlpRunnerMock, :run, fn @channel_url, opts, ot ->
|
expect(YtDlpRunnerMock, :run, fn @channel_url, opts, ot ->
|
||||||
assert opts == [playlist_items: 0]
|
assert opts == [:skip_download, playlist_items: 0]
|
||||||
assert ot == "playlist:%()j"
|
assert ot == "playlist:%()j"
|
||||||
|
|
||||||
{:ok, "{}"}
|
{:ok, "{}"}
|
||||||
@@ -152,12 +152,18 @@ defmodule Pinchflat.YtDlp.MediaCollectionTest do
|
|||||||
|
|
||||||
test "allows you to pass additional opts" do
|
test "allows you to pass additional opts" do
|
||||||
expect(YtDlpRunnerMock, :run, fn _url, opts, _ot ->
|
expect(YtDlpRunnerMock, :run, fn _url, opts, _ot ->
|
||||||
assert opts == [playlist_items: 0, real_opt: :yup]
|
assert opts == [:skip_download, playlist_items: 1, real_opt: :yup]
|
||||||
|
|
||||||
{:ok, "{}"}
|
{:ok, "{}"}
|
||||||
end)
|
end)
|
||||||
|
|
||||||
assert {:ok, _} = MediaCollection.get_source_metadata(@channel_url, real_opt: :yup)
|
assert {:ok, _} = MediaCollection.get_source_metadata(@channel_url, playlist_items: 1, real_opt: :yup)
|
||||||
|
end
|
||||||
|
|
||||||
|
test "blows up if you pass addl opts but don't pass playlist items" do
|
||||||
|
assert_raise KeyError, fn ->
|
||||||
|
MediaCollection.get_source_metadata(@channel_url, real_opt: :yup)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -110,8 +110,10 @@ defmodule Pinchflat.YtDlp.MediaTest do
|
|||||||
|
|
||||||
describe "indexing_output_template/0" do
|
describe "indexing_output_template/0" do
|
||||||
test "contains all the greatest hits" do
|
test "contains all the greatest hits" do
|
||||||
assert "%(.{id,title,was_live,webpage_url,description,aspect_ratio,duration,upload_date,timestamp})j" ==
|
attrs = ~w(id title was_live webpage_url description aspect_ratio duration upload_date timestamp playlist_index)a
|
||||||
Media.indexing_output_template()
|
formatted_attrs = "%(.{#{Enum.join(attrs, ",")}})j"
|
||||||
|
|
||||||
|
assert formatted_attrs == Media.indexing_output_template()
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -126,7 +128,8 @@ defmodule Pinchflat.YtDlp.MediaTest do
|
|||||||
"aspect_ratio" => 1.0,
|
"aspect_ratio" => 1.0,
|
||||||
"duration" => 60,
|
"duration" => 60,
|
||||||
"upload_date" => "20210101",
|
"upload_date" => "20210101",
|
||||||
"timestamp" => 1_600_000_000
|
"timestamp" => 1_600_000_000,
|
||||||
|
"playlist_index" => 1
|
||||||
}
|
}
|
||||||
|
|
||||||
assert %Media{
|
assert %Media{
|
||||||
@@ -137,7 +140,8 @@ defmodule Pinchflat.YtDlp.MediaTest do
|
|||||||
livestream: false,
|
livestream: false,
|
||||||
short_form_content: false,
|
short_form_content: false,
|
||||||
uploaded_at: ~U[2020-09-13 12:26:40Z],
|
uploaded_at: ~U[2020-09-13 12:26:40Z],
|
||||||
duration_seconds: 60
|
duration_seconds: 60,
|
||||||
|
playlist_index: 1
|
||||||
} == Media.response_to_struct(response)
|
} == Media.response_to_struct(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
@@ -217,6 +221,17 @@ defmodule Pinchflat.YtDlp.MediaTest do
|
|||||||
|
|
||||||
assert %Media{livestream: false} = Media.response_to_struct(response)
|
assert %Media{livestream: false} = Media.response_to_struct(response)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
test "doesn't blow up if playlist_index is missing" do
|
||||||
|
response = %{
|
||||||
|
"webpage_url" => "https://www.youtube.com/watch?v=TiZPUDkDYbk",
|
||||||
|
"aspect_ratio" => 1.0,
|
||||||
|
"duration" => nil,
|
||||||
|
"upload_date" => "20210101"
|
||||||
|
}
|
||||||
|
|
||||||
|
assert %Media{playlist_index: 0} = Media.response_to_struct(response)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "response_to_struct/1 when testing uploaded_at" do
|
describe "response_to_struct/1 when testing uploaded_at" do
|
||||||
|
|||||||
@@ -50,6 +50,15 @@ defmodule PinchflatWeb.SourceControllerTest do
|
|||||||
|
|
||||||
refute html_response(conn, 200) =~ "MENU"
|
refute html_response(conn, 200) =~ "MENU"
|
||||||
end
|
end
|
||||||
|
|
||||||
|
test "preloads some attributes when using a template", %{conn: conn} do
|
||||||
|
source = source_fixture(custom_name: "My first source", download_cutoff_date: "2021-01-01")
|
||||||
|
|
||||||
|
conn = get(conn, ~p"/sources/new", %{"template_id" => source.id})
|
||||||
|
assert html_response(conn, 200) =~ "New Source"
|
||||||
|
assert html_response(conn, 200) =~ "2021-01-01"
|
||||||
|
refute html_response(conn, 200) =~ source.custom_name
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "create source" do
|
describe "create source" do
|
||||||
|
|||||||
Reference in New Issue
Block a user