mirror of
https://github.com/algora-io/tv.git
synced 2025-01-05 01:20:24 +02:00
add route /:channel_handle/:video_id (#9)
This commit is contained in:
Zafer Cesur
GitHub
parent
9259aff7aa
commit
e62cba0317
@ -149,7 +149,6 @@ const Hooks = {
|
||||
this.player.play();
|
||||
this.player.el().parentElement.classList.remove("hidden");
|
||||
this.player.el().parentElement.classList.add("flex");
|
||||
window.scrollTo(0, 0);
|
||||
|
||||
if (backdrop) {
|
||||
backdrop.classList.remove("opacity-10");
|
||||
@ -157,9 +156,7 @@ const Hooks = {
|
||||
}
|
||||
};
|
||||
|
||||
window.addEventListener("js:play_video", playVideo);
|
||||
this.handleEvent("js:play_video", playVideo);
|
||||
|
||||
this.handleEvent("play_video", playVideo);
|
||||
this.handleEvent("join_chat", Chat.join);
|
||||
},
|
||||
},
|
||||
|
||||
@ -6,13 +6,6 @@ const init = () => {
|
||||
let socket = new Socket("/socket", { params: { token: window.userToken } });
|
||||
socket.connect();
|
||||
|
||||
const main = document.querySelector("body");
|
||||
const sidePanel = document.querySelector("#side-panel");
|
||||
|
||||
if (!main || !sidePanel) {
|
||||
throw new Error("Could not initialize chat");
|
||||
}
|
||||
|
||||
let channel: Channel;
|
||||
let chatInput;
|
||||
let chatMessages;
|
||||
@ -24,10 +17,6 @@ const init = () => {
|
||||
chatInput.value = "";
|
||||
chatInput.removeEventListener("keypress", handleSend);
|
||||
}
|
||||
sidePanel.classList.add("lg:w-0");
|
||||
sidePanel.classList.remove("lg:w-[24rem]");
|
||||
sidePanel.classList.remove("lg:flex");
|
||||
main.classList.remove("lg:mr-[24rem]");
|
||||
};
|
||||
|
||||
const join = ({ id }) => {
|
||||
@ -39,10 +28,6 @@ const init = () => {
|
||||
chatInput = document.querySelector("#chat-input");
|
||||
chatMessages = document.querySelector("#chat-messages");
|
||||
chatMessages.scrollTop = chatMessages.scrollHeight;
|
||||
sidePanel.classList.add("lg:w-[24rem]");
|
||||
sidePanel.classList.add("lg:flex");
|
||||
sidePanel.classList.remove("lg:w-0");
|
||||
main.classList.add("lg:mr-[24rem]");
|
||||
|
||||
handleSend = (event) => {
|
||||
if (event.key === "Enter" && chatInput.value.trim()) {
|
||||
|
||||
@ -197,7 +197,7 @@ defmodule Algora.Library do
|
||||
v.visibility == :public and
|
||||
is_nil(v.vertical_thumbnail_url) and
|
||||
(v.is_live == true or v.duration >= 120 or v.type == :vod),
|
||||
select_merge: %{channel_name: u.name}
|
||||
select_merge: %{channel_handle: u.handle, channel_name: u.name}
|
||||
)
|
||||
|> order_by_inserted(:desc)
|
||||
|> Repo.all()
|
||||
@ -209,7 +209,7 @@ defmodule Algora.Library do
|
||||
on: v.user_id == u.id,
|
||||
limit: ^limit,
|
||||
where: v.visibility == :public and not is_nil(v.vertical_thumbnail_url),
|
||||
select_merge: %{channel_name: u.name}
|
||||
select_merge: %{channel_handle: u.handle, channel_name: u.name}
|
||||
)
|
||||
|> order_by_inserted(:desc)
|
||||
|> Repo.all()
|
||||
@ -220,7 +220,7 @@ defmodule Algora.Library do
|
||||
limit: ^limit,
|
||||
join: u in User,
|
||||
on: v.user_id == u.id,
|
||||
select_merge: %{channel_name: u.name},
|
||||
select_merge: %{channel_handle: u.handle, channel_name: u.name},
|
||||
where: v.user_id == ^channel.user_id
|
||||
)
|
||||
|> order_by_inserted(:desc)
|
||||
|
||||
@ -17,6 +17,7 @@ defmodule Algora.Library.Video do
|
||||
field :url, :string
|
||||
field :url_root, :string
|
||||
field :uuid, :string
|
||||
field :channel_handle, :string, virtual: true
|
||||
field :channel_name, :string, virtual: true
|
||||
field :visibility, Ecto.Enum, values: [public: 1, unlisted: 2]
|
||||
belongs_to :user, Accounts.User
|
||||
|
||||
@ -75,16 +75,10 @@ defmodule AlgoraWeb.CoreComponents do
|
||||
|
||||
def short_entry(assigns) do
|
||||
~H"""
|
||||
<div
|
||||
<.link
|
||||
id={@id}
|
||||
class="cursor-pointer truncate"
|
||||
phx-click={
|
||||
JS.push("show", value: %{video_id: @video.id}, target: "#side-panel")
|
||||
|> JS.dispatch("js:play_video",
|
||||
to: "#video-player",
|
||||
detail: %{player: %{src: @video.url, type: Library.player_type(@video)}}
|
||||
)
|
||||
}
|
||||
navigate={~p"/#{@video.channel_handle}/#{@video.id}"}
|
||||
>
|
||||
<div class="relative flex items-center justify-center overflow-hidden rounded-2xl aspect-[9/16] bg-gray-800">
|
||||
<Heroicons.play :if={!@video.thumbnail_url} solid class="h-12 w-12 text-gray-500" />
|
||||
@ -104,7 +98,7 @@ defmodule AlgoraWeb.CoreComponents do
|
||||
<div class="pt-2 text-base font-semibold truncate"><%= @video.title %></div>
|
||||
<div class="text-gray-300 text-sm font-medium"><%= @video.channel_name %></div>
|
||||
<div class="text-gray-300 text-sm"><%= Timex.from_now(@video.inserted_at) %></div>
|
||||
</div>
|
||||
</.link>
|
||||
"""
|
||||
end
|
||||
|
||||
@ -113,16 +107,10 @@ defmodule AlgoraWeb.CoreComponents do
|
||||
|
||||
def video_entry(assigns) do
|
||||
~H"""
|
||||
<div
|
||||
<.link
|
||||
id={@id}
|
||||
class="cursor-pointer truncate"
|
||||
phx-click={
|
||||
JS.push("show", value: %{video_id: @video.id}, target: "#side-panel")
|
||||
|> JS.dispatch("js:play_video",
|
||||
to: "#video-player",
|
||||
detail: %{player: %{src: @video.url, type: Library.player_type(@video)}}
|
||||
)
|
||||
}
|
||||
navigate={~p"/#{@video.channel_handle}/#{@video.id}"}
|
||||
>
|
||||
<div class="relative flex items-center justify-center overflow-hidden rounded-2xl aspect-[16/9] bg-gray-800">
|
||||
<Heroicons.play :if={!@video.thumbnail_url} solid class="h-12 w-12 text-gray-500" />
|
||||
@ -149,7 +137,7 @@ defmodule AlgoraWeb.CoreComponents do
|
||||
<div class="pt-2 text-base font-semibold truncate"><%= @video.title %></div>
|
||||
<div class="text-gray-300 text-sm font-medium"><%= @video.channel_name %></div>
|
||||
<div class="text-gray-300 text-sm"><%= Timex.from_now(@video.inserted_at) %></div>
|
||||
</div>
|
||||
</.link>
|
||||
"""
|
||||
end
|
||||
|
||||
|
||||
@ -126,12 +126,6 @@
|
||||
|
||||
<.live_component module={AlgoraWeb.LayoutComponent} id="layout" />
|
||||
|
||||
<%= live_render(@socket, AlgoraWeb.SidePanelLive,
|
||||
id: "video-side-panel",
|
||||
session: %{},
|
||||
sticky: true
|
||||
) %>
|
||||
|
||||
<main class="flex-1 relative z-0 overflow-y-auto focus:outline-none">
|
||||
<%= live_render(@socket, AlgoraWeb.PlayerLive, id: "player", session: %{}, sticky: true) %>
|
||||
<%= @inner_content %>
|
||||
|
||||
@ -5,13 +5,15 @@ defmodule AlgoraWeb.PlayerLive do
|
||||
|
||||
def render(assigns) do
|
||||
~H"""
|
||||
<div class="px-4 w-full hidden">
|
||||
<video
|
||||
id="video-player"
|
||||
phx-hook="VideoPlayer"
|
||||
class="video-js vjs-default-skin min-w-xl max-w-2xl aspect-video vjs-fluid h-full w-full flex-1 rounded-2xl overflow-hidden"
|
||||
controls
|
||||
/>
|
||||
<div class="px-4">
|
||||
<div class="w-full hidden lg:pr-[24rem]">
|
||||
<video
|
||||
id="video-player"
|
||||
phx-hook="VideoPlayer"
|
||||
class="video-js vjs-default-skin min-w-xl max-w-2xl aspect-video vjs-fluid h-full w-full flex-1 rounded-2xl overflow-hidden"
|
||||
controls
|
||||
/>
|
||||
</div>
|
||||
</div>
|
||||
"""
|
||||
end
|
||||
|
||||
@ -1,218 +0,0 @@
|
||||
defmodule AlgoraWeb.SidePanelLive do
|
||||
use AlgoraWeb, {:live_view, container: {:div, []}}
|
||||
alias Algora.{Chat, Library}
|
||||
|
||||
on_mount {AlgoraWeb.UserAuth, :current_user}
|
||||
|
||||
def render(assigns) do
|
||||
tabs =
|
||||
[:chat]
|
||||
|> append_if(length(assigns.subtitles) > 0, :transcript)
|
||||
|
||||
assigns = assigns |> assign(:tabs, tabs)
|
||||
|
||||
~H"""
|
||||
<aside id="side-panel" class="hidden fixed top-[64px] right-0 w-0 pr-4">
|
||||
<div class="p-4 bg-gray-800/40 w-[23rem] backdrop-blur-xl rounded-2xl shadow-inner shadow-white/[10%] border border-white/[15%]">
|
||||
<div>
|
||||
<ul class="pb-2 flex items-center justify-center gap-2 mx-auto text-gray-400">
|
||||
<li :for={{tab, i} <- Enum.with_index(@tabs)}>
|
||||
<button
|
||||
id={"side-panel-tab-#{tab}"}
|
||||
class={[
|
||||
"text-xs font-semibold uppercase tracking-wide",
|
||||
i == 0 && "active-tab text-white pointer-events-none"
|
||||
]}
|
||||
phx-click={
|
||||
set_active_tab("#side-panel-tab-#{tab}")
|
||||
|> set_active_content("#side-panel-content-#{tab}")
|
||||
}
|
||||
>
|
||||
<%= tab %>
|
||||
</button>
|
||||
</li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<div
|
||||
:for={{tab, i} <- Enum.with_index(@tabs)}
|
||||
id={"side-panel-content-#{tab}"}
|
||||
class={["side-panel-content", i != 0 && "hidden"]}
|
||||
>
|
||||
<div :if={tab == :transcript}>
|
||||
<div
|
||||
id="show-transcript"
|
||||
phx-click={
|
||||
JS.hide(to: "#show-transcript")
|
||||
|> JS.show(to: "#edit-transcript")
|
||||
}
|
||||
>
|
||||
<div class={
|
||||
[
|
||||
"overflow-y-auto text-sm break-words flex-1",
|
||||
# HACK:
|
||||
if(@current_user.handle == "zaf",
|
||||
do: "h-[calc(100vh-11rem)]",
|
||||
else: "h-[calc(100vh-8.75rem)]"
|
||||
)
|
||||
]
|
||||
}>
|
||||
<div :for={subtitle <- @subtitles} id={"subtitle-#{subtitle.id}"}>
|
||||
<span class="font-semibold text-indigo-400">
|
||||
<%= Library.to_hhmmss(subtitle.start) %>
|
||||
</span>
|
||||
<span class="font-medium text-gray-100">
|
||||
<%= subtitle.body %>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<button
|
||||
:if={@current_user.handle == "zaf"}
|
||||
class="mt-2 w-full flex justify-center py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Edit
|
||||
</button>
|
||||
</div>
|
||||
<.simple_form
|
||||
:if={@current_user.handle == "zaf"}
|
||||
id="edit-transcript"
|
||||
for={@form}
|
||||
phx-submit="save"
|
||||
class="hidden h-full"
|
||||
>
|
||||
<.input
|
||||
field={@form[:subtitles]}
|
||||
type="textarea"
|
||||
label="Edit transcript"
|
||||
class="font-mono h-[calc(100vh-14.75rem)]"
|
||||
/>
|
||||
<div class="grid grid-cols-2 gap-4">
|
||||
<button
|
||||
name="save"
|
||||
value="naive"
|
||||
class="w-full flex justify-center z-10 py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Save naive
|
||||
</button>
|
||||
<button
|
||||
name="save"
|
||||
value="fast"
|
||||
class="w-full flex justify-center z-10 py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Save fast
|
||||
</button>
|
||||
</div>
|
||||
</.simple_form>
|
||||
</div>
|
||||
|
||||
<div :if={tab == :chat}>
|
||||
<div
|
||||
id="chat-messages"
|
||||
class="text-sm break-words flex-1 overflow-y-auto h-[calc(100vh-11rem)]"
|
||||
>
|
||||
<div :for={message <- @messages} id={"message-#{message.id}"}>
|
||||
<span class={"font-semibold #{if(system_message?(message), do: "text-emerald-400", else: "text-indigo-400")}"}>
|
||||
<%= message.sender_handle %>:
|
||||
</span>
|
||||
<span class="font-medium text-gray-100">
|
||||
<%= message.body %>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
<input
|
||||
:if={@current_user}
|
||||
id="chat-input"
|
||||
placeholder="Send a message"
|
||||
disabled={@current_user == nil}
|
||||
class="mt-2 bg-gray-950 h-[30px] text-white focus:outline-none focus:ring-purple-400 block w-full min-w-0 rounded-md sm:text-sm ring-1 ring-gray-600 px-2"
|
||||
/>
|
||||
<a
|
||||
:if={!@current_user}
|
||||
href={Algora.Github.authorize_url()}
|
||||
class="mt-2 w-full flex justify-center py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Sign in to chat
|
||||
</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</aside>
|
||||
"""
|
||||
end
|
||||
|
||||
def mount(_params, _session, socket) do
|
||||
{:ok, socket, layout: false, temporary_assigns: [subtitles: [], messages: []]}
|
||||
end
|
||||
|
||||
def handle_event("show", %{"video_id" => video_id}, socket) do
|
||||
subtitles = Library.list_subtitles(%Library.Video{id: video_id})
|
||||
|
||||
data = %{}
|
||||
|
||||
{:ok, encoded_subtitles} =
|
||||
subtitles
|
||||
|> Enum.map(&%{id: &1.id, start: &1.start, end: &1.end, body: &1.body})
|
||||
|> Jason.encode(pretty: true)
|
||||
|
||||
types = %{subtitles: :string}
|
||||
params = %{subtitles: encoded_subtitles}
|
||||
|
||||
changeset =
|
||||
{data, types}
|
||||
|> Ecto.Changeset.cast(params, Map.keys(types))
|
||||
|
||||
video = Library.get_video!(video_id)
|
||||
|
||||
socket =
|
||||
socket
|
||||
|> assign(video: video)
|
||||
|> assign(subtitles: subtitles)
|
||||
|> assign(messages: Chat.list_messages(video))
|
||||
|> assign_form(changeset)
|
||||
|> push_event("join_chat", %{id: video_id})
|
||||
|
||||
{:noreply, socket}
|
||||
end
|
||||
|
||||
def handle_event("save", %{"data" => %{"subtitles" => subtitles}, "save" => save_type}, socket) do
|
||||
save(save_type, subtitles)
|
||||
{:noreply, socket}
|
||||
end
|
||||
|
||||
defp save("naive", subtitles) do
|
||||
Library.save_subtitles(subtitles)
|
||||
end
|
||||
|
||||
defp save("fast", subtitles) do
|
||||
Fly.Postgres.rpc_and_wait(Library, :save_subtitles, [subtitles])
|
||||
end
|
||||
|
||||
defp set_active_content(js \\ %JS{}, to) do
|
||||
js
|
||||
|> JS.hide(to: ".side-panel-content")
|
||||
|> JS.show(to: to)
|
||||
end
|
||||
|
||||
defp set_active_tab(js \\ %JS{}, tab) do
|
||||
js
|
||||
|> JS.remove_class("active-tab text-white pointer-events-none",
|
||||
to: "#video-side-panel .active-tab"
|
||||
)
|
||||
|> JS.add_class("active-tab text-white pointer-events-none", to: tab)
|
||||
end
|
||||
|
||||
defp system_message?(%Chat.Message{} = message) do
|
||||
message.sender_handle == "algora"
|
||||
end
|
||||
|
||||
defp append_if(list, cond, extra) do
|
||||
if cond, do: list ++ [extra], else: list
|
||||
end
|
||||
|
||||
defp assign_form(socket, %Ecto.Changeset{} = changeset) do
|
||||
assign(socket, :form, to_form(changeset, as: :data))
|
||||
end
|
||||
end
|
||||
@ -45,7 +45,7 @@ defmodule AlgoraWeb.SubtitleLive.Index do
|
||||
|
||||
{:noreply,
|
||||
socket
|
||||
|> push_event("js:play_video", %{
|
||||
|> push_event("play_video", %{
|
||||
detail: %{player: %{src: video.url, type: Library.player_type(video)}}
|
||||
})}
|
||||
end
|
||||
|
||||
@ -18,7 +18,7 @@ defmodule AlgoraWeb.SubtitleLive.Show do
|
||||
|
||||
{:noreply,
|
||||
socket
|
||||
|> push_event("js:play_video", %{
|
||||
|> push_event("play_video", %{
|
||||
detail: %{player: %{src: video.url, type: Library.player_type(video)}}
|
||||
})}
|
||||
end
|
||||
|
||||
556
lib/algora_web/live/video_live.ex
Normal file
556
lib/algora_web/live/video_live.ex
Normal file
@ -0,0 +1,556 @@
|
||||
defmodule AlgoraWeb.VideoLive do
|
||||
use AlgoraWeb, :live_view
|
||||
require Logger
|
||||
|
||||
alias Algora.{Accounts, Library, Storage, Chat}
|
||||
alias AlgoraWeb.{LayoutComponent, Presence}
|
||||
alias AlgoraWeb.ChannelLive.{StreamFormComponent}
|
||||
|
||||
def render(assigns) do
|
||||
tabs =
|
||||
[:chat]
|
||||
|> append_if(length(assigns.subtitles) > 0, :transcript)
|
||||
|
||||
assigns = assigns |> assign(:tabs, tabs)
|
||||
|
||||
~H"""
|
||||
<%!-- <:actions>
|
||||
<.button
|
||||
:if={@owns_channel? && not @channel.is_live}
|
||||
id="stream-btn"
|
||||
primary
|
||||
patch={channel_stream_path(@current_user)}
|
||||
>
|
||||
<svg
|
||||
xmlns="http://www.w3.org/2000/svg"
|
||||
class="-ml-1 w-6 h-6 inline-block"
|
||||
width="24"
|
||||
height="24"
|
||||
viewBox="0 0 24 24"
|
||||
stroke-width="1.5"
|
||||
stroke="currentColor"
|
||||
fill="none"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
>
|
||||
<path stroke="none" d="M0 0h24v24H0z" fill="none" /><path d="M12 12l0 .01" /><path d="M14.828 9.172a4 4 0 0 1 0 5.656" /><path d="M17.657 6.343a8 8 0 0 1 0 11.314" /><path d="M9.168 14.828a4 4 0 0 1 0 -5.656" /><path d="M6.337 17.657a8 8 0 0 1 0 -11.314" />
|
||||
</svg>
|
||||
<span class="ml-2">
|
||||
Start streaming!
|
||||
</span>
|
||||
</.button>
|
||||
</:actions> --%>
|
||||
<aside id="side-panel" class="hidden lg:w-[24rem] lg:flex fixed top-[64px] right-0 w-0 pr-4">
|
||||
<div class="p-4 bg-gray-800/40 w-[23rem] backdrop-blur-xl rounded-2xl shadow-inner shadow-white/[10%] border border-white/[15%]">
|
||||
<div>
|
||||
<ul class="pb-2 flex items-center justify-center gap-2 mx-auto text-gray-400">
|
||||
<li :for={{tab, i} <- Enum.with_index(@tabs)}>
|
||||
<button
|
||||
id={"side-panel-tab-#{tab}"}
|
||||
class={[
|
||||
"text-xs font-semibold uppercase tracking-wide",
|
||||
i == 0 && "active-tab text-white pointer-events-none"
|
||||
]}
|
||||
phx-click={
|
||||
set_active_tab("#side-panel-tab-#{tab}")
|
||||
|> set_active_content("#side-panel-content-#{tab}")
|
||||
}
|
||||
>
|
||||
<%= tab %>
|
||||
</button>
|
||||
</li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<div
|
||||
:for={{tab, i} <- Enum.with_index(@tabs)}
|
||||
id={"side-panel-content-#{tab}"}
|
||||
class={["side-panel-content", i != 0 && "hidden"]}
|
||||
>
|
||||
<div :if={tab == :transcript}>
|
||||
<div
|
||||
id="show-transcript"
|
||||
phx-click={
|
||||
JS.hide(to: "#show-transcript")
|
||||
|> JS.show(to: "#edit-transcript")
|
||||
}
|
||||
>
|
||||
<div class={
|
||||
[
|
||||
"overflow-y-auto text-sm break-words flex-1",
|
||||
# HACK:
|
||||
if(@current_user && @current_user.handle == "zaf",
|
||||
do: "h-[calc(100vh-11rem)]",
|
||||
else: "h-[calc(100vh-8.75rem)]"
|
||||
)
|
||||
]
|
||||
}>
|
||||
<div :for={subtitle <- @subtitles} id={"subtitle-#{subtitle.id}"}>
|
||||
<span class="font-semibold text-indigo-400">
|
||||
<%= Library.to_hhmmss(subtitle.start) %>
|
||||
</span>
|
||||
<span class="font-medium text-gray-100">
|
||||
<%= subtitle.body %>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<button
|
||||
:if={@current_user && @current_user.handle == "zaf"}
|
||||
class="mt-2 w-full flex justify-center py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Edit
|
||||
</button>
|
||||
</div>
|
||||
<.simple_form
|
||||
:if={@current_user && @current_user.handle == "zaf"}
|
||||
id="edit-transcript"
|
||||
for={@form}
|
||||
phx-submit="save"
|
||||
class="hidden h-full"
|
||||
>
|
||||
<.input
|
||||
field={@form[:subtitles]}
|
||||
type="textarea"
|
||||
label="Edit transcript"
|
||||
class="font-mono h-[calc(100vh-14.75rem)]"
|
||||
/>
|
||||
<div class="grid grid-cols-2 gap-4">
|
||||
<button
|
||||
name="save"
|
||||
value="naive"
|
||||
class="w-full flex justify-center z-10 py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Save naive
|
||||
</button>
|
||||
<button
|
||||
name="save"
|
||||
value="fast"
|
||||
class="w-full flex justify-center z-10 py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Save fast
|
||||
</button>
|
||||
</div>
|
||||
</.simple_form>
|
||||
</div>
|
||||
|
||||
<div :if={tab == :chat}>
|
||||
<div
|
||||
id="chat-messages"
|
||||
phx-update="ignore"
|
||||
class="text-sm break-words flex-1 overflow-y-auto h-[calc(100vh-11rem)]"
|
||||
>
|
||||
<div :for={message <- @messages} id={"message-#{message.id}"}>
|
||||
<span class={"font-semibold #{if(system_message?(message), do: "text-emerald-400", else: "text-indigo-400")}"}>
|
||||
<%= message.sender_handle %>:
|
||||
</span>
|
||||
<span class="font-medium text-gray-100">
|
||||
<%= message.body %>
|
||||
</span>
|
||||
</div>
|
||||
</div>
|
||||
<input
|
||||
:if={@current_user}
|
||||
id="chat-input"
|
||||
placeholder="Send a message"
|
||||
disabled={@current_user == nil}
|
||||
class="mt-2 bg-gray-950 h-[30px] text-white focus:outline-none focus:ring-purple-400 block w-full min-w-0 rounded-md sm:text-sm ring-1 ring-gray-600 px-2"
|
||||
/>
|
||||
<a
|
||||
:if={!@current_user}
|
||||
href={Algora.Github.authorize_url()}
|
||||
class="mt-2 w-full flex justify-center py-2 px-4 border border-transparent rounded-md shadow-sm text-sm font-medium text-white bg-purple-600 hover:bg-purple-500 focus:outline-none focus:ring-2 focus:ring-offset-2 focus:ring-purple-400"
|
||||
>
|
||||
Sign in to chat
|
||||
</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</aside>
|
||||
<div class="lg:mr-[24rem]">
|
||||
<%!-- <div class="px-4 w-full">
|
||||
<video
|
||||
id="video-player"
|
||||
phx-hook="VideoPlayer"
|
||||
class="video-js vjs-default-skin min-w-xl max-w-2xl aspect-video vjs-fluid h-full w-full flex-1 rounded-2xl overflow-hidden"
|
||||
controls
|
||||
/>
|
||||
</div> --%>
|
||||
|
||||
<div class="border-b border-gray-700 px-4 py-4">
|
||||
<figure :if={@channel.is_live} class="relative isolate -mt-4 pt-4 pb-4">
|
||||
<svg
|
||||
viewBox="0 0 162 128"
|
||||
fill="none"
|
||||
aria-hidden="true"
|
||||
class="absolute left-0 top-0 -z-10 h-12 stroke-white/75"
|
||||
>
|
||||
<path
|
||||
id="b56e9dab-6ccb-4d32-ad02-6b4bb5d9bbeb"
|
||||
d="M65.5697 118.507L65.8918 118.89C68.9503 116.314 71.367 113.253 73.1386 109.71C74.9162 106.155 75.8027 102.28 75.8027 98.0919C75.8027 94.237 75.16 90.6155 73.8708 87.2314C72.5851 83.8565 70.8137 80.9533 68.553 78.5292C66.4529 76.1079 63.9476 74.2482 61.0407 72.9536C58.2795 71.4949 55.276 70.767 52.0386 70.767C48.9935 70.767 46.4686 71.1668 44.4872 71.9924L44.4799 71.9955L44.4726 71.9988C42.7101 72.7999 41.1035 73.6831 39.6544 74.6492C38.2407 75.5916 36.8279 76.455 35.4159 77.2394L35.4047 77.2457L35.3938 77.2525C34.2318 77.9787 32.6713 78.3634 30.6736 78.3634C29.0405 78.3634 27.5131 77.2868 26.1274 74.8257C24.7483 72.2185 24.0519 69.2166 24.0519 65.8071C24.0519 60.0311 25.3782 54.4081 28.0373 48.9335C30.703 43.4454 34.3114 38.345 38.8667 33.6325C43.5812 28.761 49.0045 24.5159 55.1389 20.8979C60.1667 18.0071 65.4966 15.6179 71.1291 13.7305C73.8626 12.8145 75.8027 10.2968 75.8027 7.38572C75.8027 3.6497 72.6341 0.62247 68.8814 1.1527C61.1635 2.2432 53.7398 4.41426 46.6119 7.66522C37.5369 11.6459 29.5729 17.0612 22.7236 23.9105C16.0322 30.6019 10.618 38.4859 6.47981 47.558L6.47976 47.558L6.47682 47.5647C2.4901 56.6544 0.5 66.6148 0.5 77.4391C0.5 84.2996 1.61702 90.7679 3.85425 96.8404L3.8558 96.8445C6.08991 102.749 9.12394 108.02 12.959 112.654L12.959 112.654L12.9646 112.661C16.8027 117.138 21.2829 120.739 26.4034 123.459L26.4033 123.459L26.4144 123.465C31.5505 126.033 37.0873 127.316 43.0178 127.316C47.5035 127.316 51.6783 126.595 55.5376 125.148L55.5376 125.148L55.5477 125.144C59.5516 123.542 63.0052 121.456 65.9019 118.881L65.5697 118.507Z"
|
||||
>
|
||||
</path>
|
||||
<use href="#b56e9dab-6ccb-4d32-ad02-6b4bb5d9bbeb" x="86"></use>
|
||||
</svg>
|
||||
<blockquote class="text-xl font-semibold leading-8 text-white sm:text-2xl sm:leading-9">
|
||||
<p><%= @channel.tagline %></p>
|
||||
</blockquote>
|
||||
</figure>
|
||||
|
||||
<div class="flex flex-col items-start justify-start md:flex-row md:items-center md:justify-between gap-8">
|
||||
<div class="flex items-center gap-4">
|
||||
<div class="relative h-20 w-20 shrink-0">
|
||||
<img
|
||||
src={@channel.avatar_url}
|
||||
alt={@channel.handle}
|
||||
class={[
|
||||
"w-full h-full p-1 ring-4 rounded-full",
|
||||
if(@channel.is_live, do: "ring-red-500", else: "ring-transparent")
|
||||
]}
|
||||
/>
|
||||
<div
|
||||
:if={@channel.is_live}
|
||||
class="absolute bottom-0 translate-y-1/2 ring-[3px] ring-gray-800 left-1/2 -translate-x-1/2 rounded px-1 font-medium mx-auto bg-red-500 text-xs"
|
||||
>
|
||||
LIVE
|
||||
</div>
|
||||
</div>
|
||||
<div>
|
||||
<div class="text-2xl font-semibold">
|
||||
<%= @channel.name %>
|
||||
</div>
|
||||
<div
|
||||
:if={@channel.tech}
|
||||
class="mt-2 relative flex flex-col overflow-hidden max-w-[256px]"
|
||||
>
|
||||
<div class="relative flex h-1.5 w-full items-center">
|
||||
<div class="flex h-full flex-1 items-center gap-2 overflow-hidden">
|
||||
<div
|
||||
:for={lang <- @channel.tech}
|
||||
class="h-full rounded-full"
|
||||
style={"width:#{lang.pct}%;background-color:#{lang.color}"}
|
||||
>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<ol class="relative mt-0.5 items-start overflow-hidden text-xs">
|
||||
<div tabindex="0" class="-ml-2 flex h-full flex-wrap">
|
||||
<li
|
||||
:for={lang <- @channel.tech}
|
||||
class="group inline-flex cursor-default items-center truncate whitespace-nowrap px-2 py-0.5 transition"
|
||||
>
|
||||
<svg
|
||||
class="mr-1.5 h-2 w-2 flex-none opacity-100"
|
||||
fill={lang.color}
|
||||
viewBox="0 0 8 8"
|
||||
>
|
||||
<circle cx="4" cy="4" r="4"></circle>
|
||||
</svg>
|
||||
<p class="truncate whitespace-nowrap font-medium text-sm"><%= lang.name %></p>
|
||||
</li>
|
||||
</div>
|
||||
</ol>
|
||||
</div>
|
||||
<div :if={!@channel.tech} class="text-sm text-gray-300">@<%= @channel.handle %></div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="flex gap-6">
|
||||
<div>
|
||||
<div class="text-xs font-medium text-gray-300 sm:text-sm">
|
||||
Watching now
|
||||
</div>
|
||||
<div class="flex items-center gap-1.5">
|
||||
<svg
|
||||
xmlns="http://www.w3.org/2000/svg"
|
||||
class="h-8 w-8"
|
||||
width="24"
|
||||
height="24"
|
||||
viewBox="0 0 24 24"
|
||||
stroke-width="1.5"
|
||||
stroke="currentColor"
|
||||
fill="none"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
>
|
||||
<path stroke="none" d="M0 0h24v24H0z" fill="none" /><path d="M8 7a4 4 0 1 0 8 0a4 4 0 0 0 -8 0" /><path d="M6 21v-2a4 4 0 0 1 4 -4h4a4 4 0 0 1 4 4v2" />
|
||||
</svg>
|
||||
<div class="font-display text-2xl font-semibold md:text-3xl">
|
||||
<div id="viewer-count" phx-update="stream">
|
||||
<div
|
||||
:for={{dom_id, %{id: id, metas: metas}} <- @streams.presences}
|
||||
:if={id == @channel.handle}
|
||||
id={dom_id}
|
||||
>
|
||||
<%= metas
|
||||
|> Enum.filter(fn meta -> meta.id != @channel.handle end)
|
||||
|> length() %>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div :if={@channel.bounties_count}>
|
||||
<div class="text-xs font-medium text-gray-300 sm:text-sm">
|
||||
Bounties collected
|
||||
</div>
|
||||
<div class="flex items-center gap-1.5">
|
||||
<svg
|
||||
xmlns="http://www.w3.org/2000/svg"
|
||||
class="h-8 w-8"
|
||||
width="24"
|
||||
height="24"
|
||||
viewBox="0 0 24 24"
|
||||
stroke-width="1.5"
|
||||
stroke="currentColor"
|
||||
fill="none"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
>
|
||||
<path stroke="none" d="M0 0h24v24H0z" fill="none" /><path d="M6 5h12l3 5l-8.5 9.5a.7 .7 0 0 1 -1 0l-8.5 -9.5l3 -5" /><path d="M10 12l-2 -2.2l.6 -1" />
|
||||
</svg>
|
||||
<div class="font-display text-2xl font-semibold md:text-3xl">
|
||||
<%= @channel.bounties_count %>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<div :if={length(@channel.orgs_contributed) > 0}>
|
||||
<div class="text-xs font-medium text-gray-300 sm:text-sm">
|
||||
OSS projects contributed
|
||||
</div>
|
||||
<div class="mt-2 line-clamp-1 space-x-2">
|
||||
<a
|
||||
:for={project <- @channel.orgs_contributed}
|
||||
href={"https://console.algora.io/org/#{project.handle}"}
|
||||
class="inline-flex items-center gap-2"
|
||||
>
|
||||
<span class="relative shrink-0 overflow-hidden flex h-6 w-6 items-center justify-center rounded-lg sm:h-8 sm:w-8">
|
||||
<img
|
||||
class="aspect-square h-full w-full"
|
||||
alt={project.handle}
|
||||
src={project.avatar_url}
|
||||
/>
|
||||
</span>
|
||||
</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<h2 class="text-gray-400 text-xs font-medium uppercase tracking-wide px-4 pt-4">
|
||||
Library
|
||||
</h2>
|
||||
<.playlist id="playlist" videos={@streams.videos} />
|
||||
</div>
|
||||
"""
|
||||
end
|
||||
|
||||
def mount(%{"channel_handle" => channel_handle, "video_id" => video_id}, _session, socket) do
|
||||
%{current_user: current_user} = socket.assigns
|
||||
|
||||
channel =
|
||||
Accounts.get_user_by!(handle: channel_handle)
|
||||
|> Library.get_channel!()
|
||||
|
||||
if connected?(socket) do
|
||||
Library.subscribe_to_livestreams()
|
||||
Library.subscribe_to_channel(channel)
|
||||
|
||||
Presence.track_user(channel_handle, %{
|
||||
id: if(current_user, do: current_user.handle, else: "")
|
||||
})
|
||||
|
||||
Presence.subscribe(channel_handle)
|
||||
end
|
||||
|
||||
videos = Library.list_channel_videos(channel, 50)
|
||||
|
||||
video = Library.get_video!(video_id)
|
||||
|
||||
subtitles = Library.list_subtitles(%Library.Video{id: video_id})
|
||||
|
||||
data = %{}
|
||||
|
||||
{:ok, encoded_subtitles} =
|
||||
subtitles
|
||||
|> Enum.map(&%{id: &1.id, start: &1.start, end: &1.end, body: &1.body})
|
||||
|> Jason.encode(pretty: true)
|
||||
|
||||
types = %{subtitles: :string}
|
||||
params = %{subtitles: encoded_subtitles}
|
||||
|
||||
changeset =
|
||||
{data, types}
|
||||
|> Ecto.Changeset.cast(params, Map.keys(types))
|
||||
|
||||
socket =
|
||||
socket
|
||||
|> assign(
|
||||
channel: channel,
|
||||
owns_channel?: current_user && Library.owns_channel?(current_user, channel),
|
||||
videos_count: Enum.count(videos),
|
||||
video: video,
|
||||
subtitles: subtitles,
|
||||
messages: Chat.list_messages(video)
|
||||
)
|
||||
|> assign_form(changeset)
|
||||
|> stream(:videos, videos)
|
||||
|> stream(:presences, Presence.list_online_users(channel_handle))
|
||||
|
||||
if connected?(socket), do: send(self(), {:play, video})
|
||||
|
||||
{:ok, socket}
|
||||
end
|
||||
|
||||
def handle_params(params, _url, socket) do
|
||||
LayoutComponent.hide_modal()
|
||||
{:noreply, socket |> apply_action(socket.assigns.live_action, params)}
|
||||
end
|
||||
|
||||
def handle_info({:play, video}, socket) do
|
||||
socket =
|
||||
socket
|
||||
|> push_event("play_video", %{
|
||||
detail: %{player: %{src: video.url, type: Library.player_type(video)}}
|
||||
})
|
||||
|> push_event("join_chat", %{id: video.id})
|
||||
|
||||
{:noreply, socket}
|
||||
end
|
||||
|
||||
def handle_info({Presence, {:join, presence}}, socket) do
|
||||
{:noreply, stream_insert(socket, :presences, presence)}
|
||||
end
|
||||
|
||||
def handle_info({Presence, {:leave, presence}}, socket) do
|
||||
if presence.metas == [] do
|
||||
{:noreply, stream_delete(socket, :presences, presence)}
|
||||
else
|
||||
{:noreply, stream_insert(socket, :presences, presence)}
|
||||
end
|
||||
end
|
||||
|
||||
def handle_info(
|
||||
{Storage, %Library.Events.ThumbnailsGenerated{video: video}},
|
||||
socket
|
||||
) do
|
||||
{:noreply,
|
||||
if video.user_id == socket.assigns.channel.user_id do
|
||||
socket
|
||||
|> stream_insert(:videos, video, at: 0)
|
||||
else
|
||||
socket
|
||||
end}
|
||||
end
|
||||
|
||||
def handle_info(
|
||||
{Library, %Library.Events.LivestreamStarted{video: video}},
|
||||
socket
|
||||
) do
|
||||
%{channel: channel} = socket.assigns
|
||||
|
||||
{:noreply,
|
||||
if video.user_id == channel.user_id do
|
||||
socket
|
||||
|> assign(channel: %{channel | is_live: true})
|
||||
|> stream_insert(:videos, video, at: 0)
|
||||
else
|
||||
socket
|
||||
end}
|
||||
end
|
||||
|
||||
def handle_info(
|
||||
{Library, %Library.Events.LivestreamEnded{video: video}},
|
||||
socket
|
||||
) do
|
||||
%{channel: channel} = socket.assigns
|
||||
|
||||
{:noreply,
|
||||
if video.user_id == channel.user_id do
|
||||
socket
|
||||
|> assign(channel: %{channel | is_live: false})
|
||||
|> stream_insert(:videos, video)
|
||||
else
|
||||
socket
|
||||
end}
|
||||
end
|
||||
|
||||
def handle_info({Library, _}, socket), do: {:noreply, socket}
|
||||
|
||||
def handle_event("save", %{"data" => %{"subtitles" => subtitles}, "save" => save_type}, socket) do
|
||||
save(save_type, subtitles)
|
||||
{:noreply, socket}
|
||||
end
|
||||
|
||||
defp save("naive", subtitles) do
|
||||
Library.save_subtitles(subtitles)
|
||||
end
|
||||
|
||||
defp save("fast", subtitles) do
|
||||
Fly.Postgres.rpc_and_wait(Library, :save_subtitles, [subtitles])
|
||||
end
|
||||
|
||||
defp set_active_content(js \\ %JS{}, to) do
|
||||
js
|
||||
|> JS.hide(to: ".side-panel-content")
|
||||
|> JS.show(to: to)
|
||||
end
|
||||
|
||||
defp set_active_tab(js \\ %JS{}, tab) do
|
||||
js
|
||||
|> JS.remove_class("active-tab text-white pointer-events-none",
|
||||
to: "#side-panel .active-tab"
|
||||
)
|
||||
|> JS.add_class("active-tab text-white pointer-events-none", to: tab)
|
||||
end
|
||||
|
||||
defp system_message?(%Chat.Message{} = message) do
|
||||
message.sender_handle == "algora"
|
||||
end
|
||||
|
||||
defp append_if(list, cond, extra) do
|
||||
if cond, do: list ++ [extra], else: list
|
||||
end
|
||||
|
||||
defp assign_form(socket, %Ecto.Changeset{} = changeset) do
|
||||
assign(socket, :form, to_form(changeset, as: :data))
|
||||
end
|
||||
|
||||
defp apply_action(socket, :stream, _params) do
|
||||
if socket.assigns.owns_channel? do
|
||||
socket
|
||||
|> assign(:page_title, "Start streaming")
|
||||
|> assign(:video, %Library.Video{})
|
||||
|> show_stream_modal()
|
||||
else
|
||||
socket
|
||||
|> put_flash(:error, "You can't do that")
|
||||
|> redirect(to: channel_path(socket.assigns.current_user))
|
||||
end
|
||||
end
|
||||
|
||||
defp apply_action(socket, :show, params) do
|
||||
socket
|
||||
|> assign(:page_title, socket.assigns.channel.name || params["channel_handle"])
|
||||
|> assign(:channel_handle, socket.assigns.channel.handle)
|
||||
|> assign(:channel_name, socket.assigns.channel.name)
|
||||
|> assign(:channel_tagline, socket.assigns.channel.tagline)
|
||||
|> assign(:video, nil)
|
||||
end
|
||||
|
||||
defp show_stream_modal(socket) do
|
||||
LayoutComponent.show_modal(StreamFormComponent, %{
|
||||
id: :stream,
|
||||
confirm: {"Save", type: "submit", form: "stream-form"},
|
||||
patch: channel_path(socket.assigns.current_user),
|
||||
video: socket.assigns.video,
|
||||
title: socket.assigns.page_title,
|
||||
current_user: socket.assigns.current_user,
|
||||
changeset: Accounts.change_settings(socket.assigns.current_user, %{})
|
||||
})
|
||||
|
||||
socket
|
||||
end
|
||||
end
|
||||
@ -62,6 +62,7 @@ defmodule AlgoraWeb.Router do
|
||||
live "/", HomeLive, :show
|
||||
live "/auth/login", SignInLive, :index
|
||||
live "/:channel_handle", ChannelLive, :show
|
||||
live "/:channel_handle/:video_id", VideoLive, :show
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
Loading…
Reference in New Issue
Block a user