mirror of
https://github.com/SrIzan10/hctv.git
synced 2026-06-06 00:56:56 +00:00
feat/nginx-rtmp-move (#33)
* feat: initial and probably final rtmp server backend * feat: video player and next-ws * chore: cleanup livekit api routes * feat: chat * feat: move to nginx flv * feat: no viewer streaminfo implementation
This commit is contained in:
GitHub
3
.gitignore
vendored
3
.gitignore
vendored
@@ -37,5 +37,4 @@ yarn-error.log*
|
||||
next-env.d.ts
|
||||
|
||||
certificates
|
||||
dev/
|
||||
!dev/docker-compose.yml
|
||||
dev/psql
|
||||
85
benchmark.py
Normal file
85
benchmark.py
Normal file
@@ -0,0 +1,85 @@
|
||||
#!/usr/bin/env python3
|
||||
import asyncio
|
||||
import aiohttp
|
||||
import argparse
|
||||
import time
|
||||
import random
|
||||
from tqdm import tqdm
|
||||
|
||||
async def simulate_viewer(session, base_url, stream_name, viewer_id, duration):
|
||||
"""Simulate a viewer watching an HLS stream"""
|
||||
hls_url = f"{base_url}/hls/{stream_name}.m3u8"
|
||||
|
||||
# First request the playlist
|
||||
try:
|
||||
start_time = time.time()
|
||||
end_time = start_time + duration
|
||||
|
||||
while time.time() < end_time:
|
||||
# Get the master playlist
|
||||
async with session.get(hls_url) as response:
|
||||
if response.status != 200:
|
||||
print(f"Viewer {viewer_id}: Failed to get playlist: {response.status}")
|
||||
return
|
||||
|
||||
playlist = await response.text()
|
||||
|
||||
# Parse the playlist to find segments
|
||||
segments = [line for line in playlist.splitlines() if line.endswith('.ts')]
|
||||
|
||||
if segments:
|
||||
# Request a random segment to simulate viewing
|
||||
segment = random.choice(segments)
|
||||
segment_url = f"{base_url}/hls/{segment}"
|
||||
|
||||
async with session.get(segment_url) as seg_response:
|
||||
if seg_response.status != 200:
|
||||
print(f"Viewer {viewer_id}: Failed to get segment: {seg_response.status}")
|
||||
|
||||
# Wait a bit before requesting again (simulating segment download)
|
||||
await asyncio.sleep(2)
|
||||
|
||||
except Exception as e:
|
||||
print(f"Viewer {viewer_id} error: {str(e)}")
|
||||
|
||||
async def run_benchmark(base_url, stream_name, num_viewers, duration):
|
||||
"""Run the benchmark with the specified number of viewers"""
|
||||
print(f"Starting benchmark with {num_viewers} viewers for {duration} seconds")
|
||||
|
||||
all_tasks = [] # Keep track of all tasks
|
||||
|
||||
async with aiohttp.ClientSession() as session:
|
||||
with tqdm(total=num_viewers, desc="Connecting viewers") as pbar:
|
||||
# Start viewers gradually to avoid overwhelming the server
|
||||
for i in range(0, num_viewers, 10):
|
||||
batch = []
|
||||
for j in range(i, min(i+10, num_viewers)):
|
||||
task = asyncio.create_task(simulate_viewer(session, base_url, stream_name, j, duration))
|
||||
batch.append(task)
|
||||
all_tasks.append(task)
|
||||
|
||||
pbar.update(len(batch))
|
||||
await asyncio.sleep(0.5) # Small delay between batches
|
||||
|
||||
print(f"All {num_viewers} viewers connected. Running for {duration} seconds...")
|
||||
|
||||
# Wait for all tasks to complete
|
||||
await asyncio.gather(*all_tasks)
|
||||
|
||||
print(f"Benchmark completed after {duration} seconds.")
|
||||
|
||||
if __name__ == "__main__":
|
||||
parser = argparse.ArgumentParser(description='Benchmark NGINX-RTMP HLS streaming with simulated viewers')
|
||||
parser.add_argument('--url', default='http://localhost:8888', help='Base URL of the NGINX server')
|
||||
parser.add_argument('--stream', required=True, help='Stream name to connect to')
|
||||
parser.add_argument('--viewers', type=int, default=100, help='Number of simulated viewers')
|
||||
parser.add_argument('--duration', type=int, default=60, help='Duration in seconds to run the test')
|
||||
|
||||
args = parser.parse_args()
|
||||
|
||||
print(f"Benchmarking stream: {args.stream}")
|
||||
print(f"Server: {args.url}")
|
||||
print(f"Viewers: {args.viewers}")
|
||||
print(f"Duration: {args.duration} seconds")
|
||||
|
||||
asyncio.run(run_benchmark(args.url, args.stream, args.viewers, args.duration))
|
||||
@@ -9,3 +9,38 @@ services:
|
||||
- ./psql:/var/lib/postgresql/data
|
||||
ports:
|
||||
- 5555:5432
|
||||
nginx-rtmp:
|
||||
# ports:
|
||||
# - 1935:1935
|
||||
# - 8888:8888
|
||||
network_mode: host
|
||||
environment:
|
||||
UID: 1000
|
||||
GID: 1000
|
||||
API_AUTH: skibiditoilet
|
||||
volumes:
|
||||
- ./nginx.conf:/etc/nginx/templates/nginx.conf.template
|
||||
- ./html:/var/www/html
|
||||
- /dev/shm/hls:/dev/shm/hls
|
||||
image: flv-module
|
||||
entrypoint:
|
||||
- /bin/sh
|
||||
- -c
|
||||
- |
|
||||
# Process the template file
|
||||
mkdir -p /usr/local/nginx/conf
|
||||
envsubst '$${API_AUTH}' < /etc/nginx/templates/nginx.conf.template > /usr/local/nginx/conf/nginx.conf
|
||||
|
||||
echo "Setting UID to $${UID} and GID to $${GID}"
|
||||
usermod -u $${UID} nginx || echo "failed to change uid"
|
||||
groupmod -g $${GID} nginx || echo "failed to change gid"
|
||||
|
||||
mkdir -p /usr/local/nginx/proxy_temp /usr/local/nginx/client_body_temp
|
||||
chown -R nginx:nginx /usr/local/nginx
|
||||
mkdir -p /var/www/html
|
||||
chown -R nginx:nginx /var/www/html
|
||||
|
||||
echo "testing nginx config..."
|
||||
/usr/local/nginx/sbin/nginx -t
|
||||
|
||||
/usr/local/nginx/sbin/nginx -g 'daemon off;'
|
||||
0
dev/html/.gitkeep
Normal file
0
dev/html/.gitkeep
Normal file
74
dev/nginx.conf
Normal file
74
dev/nginx.conf
Normal file
@@ -0,0 +1,74 @@
|
||||
events {
|
||||
worker_connections 1024;
|
||||
}
|
||||
|
||||
rtmp {
|
||||
server {
|
||||
listen 1935;
|
||||
|
||||
application live {
|
||||
live on;
|
||||
record off;
|
||||
|
||||
on_publish http://localhost:3000/api/rtmp/publish;
|
||||
}
|
||||
|
||||
application channel-live {
|
||||
live on;
|
||||
record off;
|
||||
|
||||
allow publish 127.0.0.1;
|
||||
deny publish all;
|
||||
|
||||
hls on;
|
||||
hls_type live;
|
||||
hls_path /dev/shm/hls;
|
||||
hls_fragment 2s;
|
||||
hls_playlist_length 10s;
|
||||
hls_cleanup on;
|
||||
|
||||
hls_variant _low BANDWIDTH=500000;
|
||||
hls_variant _mid BANDWIDTH=1000000;
|
||||
hls_variant _hi BANDWIDTH=1500000;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
http {
|
||||
include mime.types;
|
||||
default_type application/octet-stream;
|
||||
|
||||
# performance optimizations
|
||||
sendfile on;
|
||||
tcp_nopush on;
|
||||
tcp_nodelay on;
|
||||
keepalive_timeout 65;
|
||||
|
||||
map $http_authorization $is_authorized {
|
||||
default 0;
|
||||
$API_AUTH 1;
|
||||
}
|
||||
|
||||
server {
|
||||
listen 8888;
|
||||
|
||||
location /stat {
|
||||
if ($is_authorized = 0) {
|
||||
return 401 "Unauthorized";
|
||||
}
|
||||
rtmp_stat all;
|
||||
rtmp_stat_format json;
|
||||
}
|
||||
|
||||
location /hls {
|
||||
alias /dev/shm/hls;
|
||||
add_header Cache-Control no-cache;
|
||||
add_header Access-Control-Allow-Origin *;
|
||||
|
||||
types {
|
||||
application/vnd.apple.mpegurl m3u8;
|
||||
video/mp2t ts;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
56
flv-module/Dockerfile
Normal file
56
flv-module/Dockerfile
Normal file
@@ -0,0 +1,56 @@
|
||||
FROM alpine:3.19 as builder
|
||||
|
||||
RUN apk add --no-cache \
|
||||
build-base \
|
||||
pcre-dev \
|
||||
zlib-dev \
|
||||
openssl-dev \
|
||||
wget \
|
||||
git && \
|
||||
wget http://nginx.org/download/nginx-1.26.3.tar.gz && \
|
||||
tar -zxf nginx-1.26.3.tar.gz && \
|
||||
git clone https://github.com/winshining/nginx-http-flv-module.git && \
|
||||
cd nginx-1.26.3 && \
|
||||
./configure --add-module=../nginx-http-flv-module && \
|
||||
make -j$(nproc) && make install && \
|
||||
rm -rf /nginx-1.26.3.tar.gz /nginx-1.26.3 /nginx-http-flv-module
|
||||
|
||||
FROM alpine:3.19
|
||||
|
||||
COPY --from=builder /usr/local/nginx /usr/local/nginx
|
||||
|
||||
# Install runtime dependencies including gettext for envsubst
|
||||
RUN apk add --no-cache \
|
||||
pcre \
|
||||
zlib \
|
||||
openssl \
|
||||
ffmpeg \
|
||||
shadow \
|
||||
gettext && \
|
||||
addgroup -S nginx && \
|
||||
adduser -S -D -H -G nginx -s /sbin/nologin nginx && \
|
||||
mkdir -p /usr/local/nginx/proxy_temp /usr/local/nginx/client_body_temp && \
|
||||
chown -R nginx:nginx /usr/local/nginx
|
||||
|
||||
# Create directory for template files
|
||||
RUN mkdir -p /etc/nginx/templates
|
||||
|
||||
EXPOSE 80 1935 8888
|
||||
|
||||
# Create an entrypoint script to handle environment variable substitution
|
||||
RUN echo '#!/bin/sh \n\
|
||||
# Replace environment variables in configuration templates \n\
|
||||
for template in /etc/nginx/templates/*.conf.template; do \n\
|
||||
if [ -f "$template" ]; then \n\
|
||||
output_file="/usr/local/nginx/conf/$(basename $template .template)" \n\
|
||||
echo "Processing template: $template -> $output_file" \n\
|
||||
envsubst "$(env | awk -F= "{printf \\\"\\\$%s \\\",\\\$1}")" < $template > $output_file \n\
|
||||
fi \n\
|
||||
done \n\
|
||||
\n\
|
||||
# Start Nginx \n\
|
||||
exec "$@"' > /docker-entrypoint.sh && \
|
||||
chmod +x /docker-entrypoint.sh
|
||||
|
||||
ENTRYPOINT ["/docker-entrypoint.sh"]
|
||||
CMD ["/usr/local/nginx/sbin/nginx", "-g", "daemon off;"]
|
||||
@@ -10,7 +10,9 @@ const nextConfig = {
|
||||
}
|
||||
]
|
||||
},
|
||||
transpilePackages: ['livekit-server-sdk']
|
||||
env: {
|
||||
LIVE_SERVER_URL: process.env.NODE_ENV === 'production' ? 'https://backend.hctv.srizan.dev' : 'http://localhost:8888',
|
||||
}
|
||||
};
|
||||
|
||||
export default nextConfig;
|
||||
|
||||
12
package.json
12
package.json
@@ -3,14 +3,16 @@
|
||||
"version": "0.1.0",
|
||||
"private": true,
|
||||
"scripts": {
|
||||
"dev": "docker compose --file dev/docker-compose.yml up -d && next dev --experimental-https --turbo",
|
||||
"dev": "docker compose --file dev/docker-compose.yml up -d && next dev --turbo",
|
||||
"donly": "docker compose --file dev/docker-compose.yml up",
|
||||
"setup": "docker compose --file dev/docker-compose.yml up -d && prisma migrate deploy",
|
||||
"build": "prisma generate && next build",
|
||||
"start": "prisma migrate deploy && next start",
|
||||
"lint": "next lint",
|
||||
"db:generate": "prisma generate",
|
||||
"db:migrate": "prisma migrate dev --name",
|
||||
"ui:add": "shadcn add"
|
||||
"ui:add": "shadcn add",
|
||||
"prepare": "next-ws patch"
|
||||
},
|
||||
"dependencies": {
|
||||
"@hookform/resolvers": "^3.9.1",
|
||||
@@ -29,15 +31,19 @@
|
||||
"@radix-ui/react-tooltip": "^1.1.6",
|
||||
"@uidotdev/usehooks": "^2.4.1",
|
||||
"arctic": "^3.1.1",
|
||||
"cheerio": "^1.0.0",
|
||||
"class-variance-authority": "^0.7.1",
|
||||
"clsx": "^2.1.0",
|
||||
"cmdk": "1.0.0",
|
||||
"hls-video-element": "^1.5.0",
|
||||
"livekit-client": "^2.8.0",
|
||||
"livekit-server-sdk": "^2.9.7",
|
||||
"lucia": "^3.2.2",
|
||||
"lucide-react": "^0.473.0",
|
||||
"media-chrome": "^4.8.0",
|
||||
"next": "^15.1.6",
|
||||
"next-themes": "^0.4.4",
|
||||
"next-ws": "^2.0.4",
|
||||
"react": "19",
|
||||
"react-dom": "19",
|
||||
"react-hook-form": "^7.54.2",
|
||||
@@ -47,12 +53,14 @@
|
||||
"tailwindcss-animate": "^1.0.7",
|
||||
"util-utils": "^1.0.3",
|
||||
"valtio": "^2.1.2",
|
||||
"ws": "^8.18.1",
|
||||
"zod": "^3.24.1"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/node": "^20",
|
||||
"@types/react": "^18",
|
||||
"@types/react-dom": "^18",
|
||||
"@types/ws": "^8.18.0",
|
||||
"eslint": "^8",
|
||||
"eslint-config-next": "15.1.3",
|
||||
"postcss": "^8",
|
||||
|
||||
@@ -0,0 +1,17 @@
|
||||
-- CreateTable
|
||||
CREATE TABLE "StreamKey" (
|
||||
"id" TEXT NOT NULL,
|
||||
"key" TEXT NOT NULL,
|
||||
"channelId" TEXT NOT NULL,
|
||||
|
||||
CONSTRAINT "StreamKey_pkey" PRIMARY KEY ("id")
|
||||
);
|
||||
|
||||
-- CreateIndex
|
||||
CREATE UNIQUE INDEX "StreamKey_key_key" ON "StreamKey"("key");
|
||||
|
||||
-- CreateIndex
|
||||
CREATE UNIQUE INDEX "StreamKey_channelId_key" ON "StreamKey"("channelId");
|
||||
|
||||
-- AddForeignKey
|
||||
ALTER TABLE "StreamKey" ADD CONSTRAINT "StreamKey_channelId_fkey" FOREIGN KEY ("channelId") REFERENCES "Channel"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
|
||||
@@ -46,6 +46,7 @@ model Channel {
|
||||
managers User[] @relation("ChannelManagers")
|
||||
streamInfo StreamInfo[]
|
||||
followers Follow[] @relation("ChannelFollowers")
|
||||
streamKey StreamKey?
|
||||
|
||||
@@index([ownerId])
|
||||
}
|
||||
@@ -90,3 +91,11 @@ model Follow {
|
||||
@@index([userId])
|
||||
@@index([channelId])
|
||||
}
|
||||
|
||||
model StreamKey {
|
||||
id String @id @default(cuid())
|
||||
key String @unique
|
||||
|
||||
channelId String @unique
|
||||
channel Channel @relation(fields: [channelId], references: [id])
|
||||
}
|
||||
@@ -1,102 +0,0 @@
|
||||
import { validateRequest } from '@/lib/auth';
|
||||
import prisma from '@/lib/db';
|
||||
import { Track, VideoQuality } from 'livekit-client';
|
||||
import { IngressAudioEncodingPreset, IngressAudioOptions, IngressInput, IngressVideoEncodingPreset, IngressVideoOptions, TrackSource, VideoCodec } from 'livekit-server-sdk';
|
||||
|
||||
export async function POST(request: Request) {
|
||||
const { ingressClient, roomService } = await import('@/lib/services/livekit');
|
||||
try {
|
||||
const { user } = await validateRequest();
|
||||
if (!user) {
|
||||
return new Response('Unauthorized', { status: 401 });
|
||||
}
|
||||
|
||||
const body = await request.json();
|
||||
const { channel } = body;
|
||||
|
||||
const channelInfo = await prisma.channel.findUnique({
|
||||
where: { name: channel },
|
||||
include: {
|
||||
owner: true,
|
||||
managers: true
|
||||
}
|
||||
});
|
||||
|
||||
if (!channelInfo) {
|
||||
return new Response('Channel not found', { status: 404 });
|
||||
}
|
||||
|
||||
const isBroadcaster =
|
||||
channelInfo.ownerId === user.id ||
|
||||
channelInfo.managers.some(m => m.id === user.id);
|
||||
|
||||
if (!isBroadcaster) {
|
||||
return new Response('Unauthorized', { status: 401 });
|
||||
}
|
||||
|
||||
// clean up existing resources
|
||||
const ingresses = await ingressClient.listIngress();
|
||||
const channelIngresses = ingresses.filter(ingress => ingress.name === channel);
|
||||
|
||||
for (const ingress of channelIngresses) {
|
||||
await ingressClient.deleteIngress(ingress.ingressId);
|
||||
}
|
||||
|
||||
// reset and create room
|
||||
const existingRoom = await roomService.listRooms()
|
||||
.then(rooms => rooms.find(r => r.name === channel));
|
||||
|
||||
if (existingRoom) {
|
||||
await roomService.deleteRoom(existingRoom.name);
|
||||
}
|
||||
|
||||
await roomService.createRoom({ name: channel });
|
||||
|
||||
// create new ingress
|
||||
const ingress = await ingressClient.createIngress(IngressInput.RTMP_INPUT, {
|
||||
name: channel,
|
||||
roomName: channel,
|
||||
participantIdentity: 'streamer',
|
||||
video: new IngressVideoOptions({
|
||||
source: TrackSource.CAMERA,
|
||||
encodingOptions: {
|
||||
case: 'options',
|
||||
value: {
|
||||
videoCodec: VideoCodec.H264_BASELINE,
|
||||
frameRate: 30,
|
||||
layers: [
|
||||
{
|
||||
quality: VideoQuality.MEDIUM,
|
||||
width: 1280,
|
||||
height: 720,
|
||||
bitrate: 2_500_000, // 2.5 mbps
|
||||
},
|
||||
{
|
||||
quality: VideoQuality.LOW,
|
||||
width: 640,
|
||||
height: 360,
|
||||
bitrate: 500_000, // 500 kbps
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
}),
|
||||
audio: new IngressAudioOptions({
|
||||
source: TrackSource.MICROPHONE,
|
||||
encodingOptions: {
|
||||
case: 'preset',
|
||||
value: IngressAudioEncodingPreset.OPUS_STEREO_96KBPS,
|
||||
}
|
||||
})
|
||||
});
|
||||
|
||||
return Response.json({
|
||||
key: ingress.streamKey,
|
||||
url: ingress.url
|
||||
});
|
||||
|
||||
} catch (error) {
|
||||
console.error('Broadcaster token error:', error);
|
||||
return new Response('Internal Server Error', { status: 500 });
|
||||
}
|
||||
}
|
||||
@@ -1,34 +0,0 @@
|
||||
import { validateRequest } from '@/lib/auth';
|
||||
import { getPersonalChannel } from '@/lib/auth/personalChannel';
|
||||
import { AccessToken } from 'livekit-server-sdk';
|
||||
import { NextRequest } from 'next/server';
|
||||
import { randomString } from 'util-utils';
|
||||
|
||||
export async function GET(request: NextRequest) {
|
||||
const { user } = await validateRequest();
|
||||
const personalChannel = await getPersonalChannel();
|
||||
const userSalt = randomString(8);
|
||||
const room = request.nextUrl.searchParams.get('room');
|
||||
if (!room) {
|
||||
return new Response('Room is required', { status: 400 });
|
||||
}
|
||||
if (!user) {
|
||||
return new Response('Unauthorized', { status: 401 });
|
||||
}
|
||||
|
||||
const at = new AccessToken(process.env.LIVEKIT_API_KEY, process.env.LIVEKIT_SECRET, {
|
||||
identity: `${user.id}-${userSalt}`,
|
||||
name: `${personalChannel!.name}-${userSalt}`,
|
||||
ttl: 3600,
|
||||
});
|
||||
|
||||
at.addGrant({
|
||||
room,
|
||||
roomJoin: true,
|
||||
canSubscribe: true,
|
||||
canPublish: false,
|
||||
canPublishData: false,
|
||||
});
|
||||
|
||||
return Response.json({ token: await at.toJwt() });
|
||||
}
|
||||
30
src/app/(protected)/api/rtmp/publish/route.ts
Normal file
30
src/app/(protected)/api/rtmp/publish/route.ts
Normal file
@@ -0,0 +1,30 @@
|
||||
import prisma from '@/lib/db';
|
||||
import { NextRequest } from 'next/server';
|
||||
|
||||
export async function POST(request: NextRequest) {
|
||||
const formData = await request.formData();
|
||||
const streamKey = formData.get('name')?.toString() || '';
|
||||
|
||||
const key = await prisma.streamKey.findFirst({
|
||||
where: {
|
||||
key: streamKey,
|
||||
},
|
||||
include: {
|
||||
channel: true,
|
||||
},
|
||||
});
|
||||
|
||||
if (!key) {
|
||||
return new Response('nay', {
|
||||
status: 403,
|
||||
});
|
||||
}
|
||||
|
||||
const headers = new Headers();
|
||||
headers.append('Location', `rtmp://127.0.0.1/channel-live/${key.channel.name}`);
|
||||
|
||||
return new Response(null, {
|
||||
status: 302,
|
||||
headers: headers,
|
||||
});
|
||||
}
|
||||
52
src/app/(protected)/api/rtmp/streamKey/route.ts
Normal file
52
src/app/(protected)/api/rtmp/streamKey/route.ts
Normal file
@@ -0,0 +1,52 @@
|
||||
import { validateRequest } from "@/lib/auth";
|
||||
import prisma from "@/lib/db";
|
||||
import { NextRequest } from "next/server";
|
||||
|
||||
export async function POST(request: NextRequest) {
|
||||
const { user } = await validateRequest();
|
||||
const body = await request.json();
|
||||
const { channel } = body;
|
||||
|
||||
if (!user) {
|
||||
return new Response('Unauthorized', { status: 401 });
|
||||
}
|
||||
|
||||
const channelInfo = await prisma.channel.findUnique({
|
||||
where: { name: channel },
|
||||
include: {
|
||||
owner: true,
|
||||
managers: true
|
||||
}
|
||||
});
|
||||
|
||||
if (!channelInfo) {
|
||||
return new Response('Channel not found', { status: 404 });
|
||||
}
|
||||
|
||||
const isBroadcaster =
|
||||
channelInfo.ownerId === user.id ||
|
||||
channelInfo.managers.some(m => m.id === user.id);
|
||||
if (!isBroadcaster) {
|
||||
return new Response('Unauthorized', { status: 401 });
|
||||
}
|
||||
|
||||
const dbUpdate = await prisma.streamKey.upsert({
|
||||
create: {
|
||||
key: crypto.randomUUID(),
|
||||
channelId: channelInfo.id
|
||||
},
|
||||
update: {
|
||||
key: crypto.randomUUID()
|
||||
},
|
||||
where: {
|
||||
channelId: channelInfo.id
|
||||
}
|
||||
})
|
||||
|
||||
return new Response(JSON.stringify({ key: dbUpdate.key }), {
|
||||
status: 200,
|
||||
headers: {
|
||||
'Content-Type': 'application/json'
|
||||
}
|
||||
});
|
||||
}
|
||||
59
src/app/(protected)/api/stream/chat/route.ts
Normal file
59
src/app/(protected)/api/stream/chat/route.ts
Normal file
@@ -0,0 +1,59 @@
|
||||
import { lucia } from '@/lib/auth';
|
||||
import { resolveUserPersonalChannel } from '@/lib/db/resolve';
|
||||
|
||||
export async function SOCKET(
|
||||
client: import('ws').WebSocket,
|
||||
request: import('http').IncomingMessage,
|
||||
server: import('ws').WebSocketServer
|
||||
) {
|
||||
const cookies = parseCookieString(request.headers.cookie!);
|
||||
const { user } = await lucia.validateSession(cookies.auth_session);
|
||||
if (!user) {
|
||||
client.close();
|
||||
return;
|
||||
}
|
||||
|
||||
const personalChannel = await resolveUserPersonalChannel(user.id);
|
||||
if (!personalChannel) {
|
||||
client.close();
|
||||
return;
|
||||
}
|
||||
|
||||
client.on('message', (message) => {
|
||||
const msg = message.toString();
|
||||
server.clients.forEach((client) => {
|
||||
if (client.readyState === client.OPEN) {
|
||||
client.send(
|
||||
JSON.stringify({
|
||||
user: {
|
||||
id: user.id,
|
||||
username: personalChannel.name,
|
||||
pfpUrl: user.pfpUrl,
|
||||
},
|
||||
message: msg,
|
||||
})
|
||||
);
|
||||
/* if (msg === 'BOMB') {
|
||||
for (let i = 0; i < 10000; i++) {
|
||||
client.send(JSON.stringify({
|
||||
user: {
|
||||
id: user.id,
|
||||
username: personalChannel.name,
|
||||
pfpUrl: user.pfpUrl,
|
||||
},
|
||||
message: 'HIIIII',
|
||||
}));
|
||||
}
|
||||
} */
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
function parseCookieString(cookie: string) {
|
||||
return cookie.split(';').reduce((acc, cookie) => {
|
||||
const [key, value] = cookie.split('=');
|
||||
acc[key.trim()] = value;
|
||||
return acc;
|
||||
}, {} as Record<string, string>);
|
||||
}
|
||||
@@ -126,3 +126,61 @@ h1 {
|
||||
h2 {
|
||||
@apply scroll-m-20 pb-2 text-3xl font-semibold tracking-tight first:mt-0;
|
||||
}
|
||||
|
||||
media-controller {
|
||||
--media-primary-color: #ffffff;
|
||||
--media-secondary-color: hsla(var(--background), 0.85);
|
||||
--media-control-hover-background: hsla(var(--accent), 0.85);
|
||||
--media-control-background: hsla(var(--secondary), 0.85);
|
||||
--media-loading-icon-color: #ffffff;
|
||||
border-radius: var(--radius);
|
||||
overflow: hidden;
|
||||
border: 1px solid hsl(var(--border));
|
||||
}
|
||||
|
||||
media-control-bar {
|
||||
background-color: hsla(var(--background), 0.8);
|
||||
backdrop-filter: blur(8px);
|
||||
width: 100%;
|
||||
box-sizing: border-box;
|
||||
justify-content: space-between;
|
||||
}
|
||||
|
||||
media-time-range {
|
||||
--media-range-track-height: 6px;
|
||||
--media-range-thumb-height: 14px;
|
||||
--media-range-thumb-width: 14px;
|
||||
--media-range-thumb-border-radius: 50%;
|
||||
--media-range-bar-color: #ffffff;
|
||||
--media-range-thumb-background: #ffffff;
|
||||
--media-preview-background: hsla(var(--card), 0.9);
|
||||
--media-preview-border-radius: var(--radius);
|
||||
}
|
||||
|
||||
media-time-display {
|
||||
--media-text-color: #ffffff;
|
||||
}
|
||||
|
||||
media-controller::part(centered-layer) {
|
||||
background-color: hsla(var(--background), 0.2);
|
||||
transition: opacity 0.3s ease;
|
||||
}
|
||||
|
||||
media-controller:not([mediapaused])[userinactive]::part(centered-layer) {
|
||||
opacity: 0;
|
||||
transition: opacity 1s ease;
|
||||
}
|
||||
|
||||
media-loading-indicator {
|
||||
--media-loading-icon-width: 48px;
|
||||
--media-loading-icon-height: 48px;
|
||||
--media-loading-icon-color: #ffffff;
|
||||
}
|
||||
|
||||
media-play-button:hover,
|
||||
media-mute-button:hover,
|
||||
media-fullscreen-button:hover,
|
||||
media-seek-backward-button:hover,
|
||||
media-seek-forward-button:hover {
|
||||
--media-control-hover-background: rgba(255, 255, 255, 0.2);
|
||||
}
|
||||
71
src/components/app/ChatPanel/ChatPanel.livekit.tsx
Normal file
71
src/components/app/ChatPanel/ChatPanel.livekit.tsx
Normal file
@@ -0,0 +1,71 @@
|
||||
'use client';
|
||||
|
||||
import { useState, useRef, useEffect } from 'react';
|
||||
import { Send } from 'lucide-react';
|
||||
import { Input } from '@/components/ui/input';
|
||||
import { Button } from '@/components/ui/button';
|
||||
import { useChat } from '@livekit/components-react';
|
||||
|
||||
export default function ChatPanel() {
|
||||
const [message, setMessage] = useState('');
|
||||
const chat = useChat();
|
||||
const scrollRef = useRef<HTMLDivElement>(null);
|
||||
|
||||
// auto scroll to bottom when messages change
|
||||
useEffect(() => {
|
||||
if (scrollRef.current) {
|
||||
scrollRef.current.scrollTop = scrollRef.current.scrollHeight;
|
||||
}
|
||||
}, [chat.chatMessages]);
|
||||
|
||||
return (
|
||||
<div className="border-l flex flex-col w-[350px] min-w-[350px] h-full">
|
||||
<div ref={scrollRef} className="flex-1 p-4 overflow-y-auto flex flex-col">
|
||||
<div className="space-y-4 flex-1">
|
||||
{chat.chatMessages.map((msg, i) => {
|
||||
const splitName = msg.from?.name?.split('-');
|
||||
const name = splitName?.slice(0, -1).join('-');
|
||||
return (
|
||||
// jank asf, but works (thanks claude)
|
||||
<div key={i} className="flex space-x-2">
|
||||
<div className="font-bold shrink-0">{name}</div>
|
||||
<div
|
||||
lang="en"
|
||||
className="max-w-[calc(100%-4rem)] break-all whitespace-pre-wrap hyphens-auto"
|
||||
>
|
||||
{msg.message}
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
})}
|
||||
</div>
|
||||
</div>
|
||||
<div className="p-4 border-t">
|
||||
<div className="flex space-x-2">
|
||||
<Input
|
||||
value={message}
|
||||
onChange={(e) => setMessage(e.target.value)}
|
||||
onKeyDown={(e) => {
|
||||
if (e.key === 'Enter') {
|
||||
chat.send(message);
|
||||
setMessage('');
|
||||
}
|
||||
}}
|
||||
placeholder="Type a message"
|
||||
className="flex-1 bg-transparent focus-visible:ring-offset-0"
|
||||
/>
|
||||
<Button
|
||||
size="icon"
|
||||
className="text-black transition-colors"
|
||||
onClick={() => {
|
||||
chat.send(message);
|
||||
setMessage('');
|
||||
}}
|
||||
>
|
||||
<Send className="h-4 w-4" />
|
||||
</Button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -4,31 +4,83 @@ import { useState, useRef, useEffect } from 'react';
|
||||
import { Send } from 'lucide-react';
|
||||
import { Input } from '@/components/ui/input';
|
||||
import { Button } from '@/components/ui/button';
|
||||
import { useChat } from '@livekit/components-react';
|
||||
|
||||
interface User {
|
||||
id: string;
|
||||
username: string;
|
||||
pfpUrl: string;
|
||||
}
|
||||
|
||||
interface ChatMessage {
|
||||
user: User;
|
||||
message: string;
|
||||
}
|
||||
|
||||
export default function ChatPanel() {
|
||||
const [message, setMessage] = useState('');
|
||||
const chat = useChat();
|
||||
const [chatMessages, setChatMessages] = useState<ChatMessage[]>([]);
|
||||
const scrollRef = useRef<HTMLDivElement>(null);
|
||||
const socketRef = useRef<WebSocket | null>(null);
|
||||
|
||||
useEffect(() => {
|
||||
const socket = new WebSocket('ws://localhost:3000/api/stream/chat');
|
||||
socketRef.current = socket;
|
||||
|
||||
socket.onopen = () => {
|
||||
console.log('WebSocket connected');
|
||||
};
|
||||
|
||||
socket.onmessage = (event) => {
|
||||
try {
|
||||
const data = JSON.parse(event.data);
|
||||
setChatMessages(prev => [...prev, data]);
|
||||
} catch (e) {
|
||||
console.log('Received message confirmation:', event.data);
|
||||
}
|
||||
};
|
||||
|
||||
socket.onclose = () => {
|
||||
console.log('WebSocket closed');
|
||||
};
|
||||
|
||||
return () => {
|
||||
socket.close();
|
||||
};
|
||||
}, []);
|
||||
|
||||
// auto scroll to bottom when messages change
|
||||
useEffect(() => {
|
||||
if (scrollRef.current) {
|
||||
scrollRef.current.scrollTop = scrollRef.current.scrollHeight;
|
||||
}
|
||||
}, [chat.chatMessages]);
|
||||
if (chatMessages.length > 100) {
|
||||
setChatMessages(prev => prev.slice(chatMessages.length - 100));
|
||||
}
|
||||
}, [chatMessages]);
|
||||
|
||||
const sendMessage = () => {
|
||||
if (!message.trim()) return;
|
||||
|
||||
if (socketRef.current && socketRef.current.readyState === WebSocket.OPEN) {
|
||||
socketRef.current.send(message);
|
||||
setMessage('');
|
||||
} else {
|
||||
const socket = new WebSocket('ws://localhost:3000/api/stream/chat');
|
||||
socket.onopen = () => {
|
||||
socket.send(message);
|
||||
setMessage('');
|
||||
};
|
||||
}
|
||||
};
|
||||
|
||||
return (
|
||||
<div className="border-l flex flex-col w-[350px] min-w-[350px] h-full">
|
||||
<div ref={scrollRef} className="flex-1 p-4 overflow-y-auto flex flex-col">
|
||||
<div className="space-y-4 flex-1">
|
||||
{chat.chatMessages.map((msg, i) => {
|
||||
const splitName = msg.from?.name?.split('-');
|
||||
const name = splitName?.slice(0, -1).join('-');
|
||||
return (
|
||||
// jank asf, but works (thanks claude)
|
||||
{chatMessages.map((msg, i) => (
|
||||
<div key={i} className="flex space-x-2">
|
||||
<div className="font-bold shrink-0">{name}</div>
|
||||
<div className="flex items-center gap-2">
|
||||
<div className="font-bold shrink-0">{msg.user.username}</div>
|
||||
</div>
|
||||
<div
|
||||
lang="en"
|
||||
className="max-w-[calc(100%-4rem)] break-all whitespace-pre-wrap hyphens-auto"
|
||||
@@ -36,8 +88,7 @@ export default function ChatPanel() {
|
||||
{msg.message}
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
})}
|
||||
))}
|
||||
</div>
|
||||
</div>
|
||||
<div className="p-4 border-t">
|
||||
@@ -47,8 +98,7 @@ export default function ChatPanel() {
|
||||
onChange={(e) => setMessage(e.target.value)}
|
||||
onKeyDown={(e) => {
|
||||
if (e.key === 'Enter') {
|
||||
chat.send(message);
|
||||
setMessage('');
|
||||
sendMessage();
|
||||
}
|
||||
}}
|
||||
placeholder="Type a message"
|
||||
@@ -57,10 +107,7 @@ export default function ChatPanel() {
|
||||
<Button
|
||||
size="icon"
|
||||
className="text-black transition-colors"
|
||||
onClick={() => {
|
||||
chat.send(message);
|
||||
setMessage('');
|
||||
}}
|
||||
onClick={sendMessage}
|
||||
>
|
||||
<Send className="h-4 w-4" />
|
||||
</Button>
|
||||
|
||||
@@ -1,25 +1,12 @@
|
||||
'use client';
|
||||
|
||||
import { LiveKitRoom } from '@livekit/components-react';
|
||||
import { useEffect, useState } from 'react';
|
||||
import StreamPlayer from '../StreamPlayer/StreamPlayer';
|
||||
import UserInfoCard from '../UserInfoCard/UserInfoCard';
|
||||
import ChatPanel from '../ChatPanel/ChatPanel';
|
||||
import type { StreamInfo, User } from '@prisma/client';
|
||||
|
||||
export default function LiveStream(props: Props) {
|
||||
const [token, setToken] = useState('');
|
||||
|
||||
useEffect(() => {
|
||||
fetch(`/api/livekit/viewerToken?room=${props.username}`)
|
||||
.then((res) => res.json())
|
||||
.then((data) => setToken(data.token));
|
||||
}, [props.username]);
|
||||
|
||||
if (!token) return <div>Loading...</div>;
|
||||
|
||||
return (
|
||||
<LiveKitRoom token={token} serverUrl={process.env.NEXT_PUBLIC_LIVEKIT_URL} connect={true}>
|
||||
<div className="flex h-[calc(100vh-64px)] w-full">
|
||||
<div className="flex-1">
|
||||
<StreamPlayer />
|
||||
@@ -27,7 +14,6 @@ export default function LiveStream(props: Props) {
|
||||
</div>
|
||||
<ChatPanel />
|
||||
</div>
|
||||
</LiveKitRoom>
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
@@ -39,10 +39,10 @@ export default function Navbar(props: Props) {
|
||||
<>
|
||||
<nav className="flex items-center h-16 px-4 border-b gap-3 w-full z-20 fixed top-0 left-0 shadow-md bg-mantle">
|
||||
<div className="flex items-center space-x-5">
|
||||
<SidebarTrigger />
|
||||
<Link href="/" className="flex items-center">
|
||||
<Button variant={'ghost'}>hackclub.tv</Button>
|
||||
</Link>
|
||||
<SidebarTrigger />
|
||||
</div>
|
||||
<MobileNavbarLinks />
|
||||
<div className="flex-1" />
|
||||
|
||||
@@ -7,7 +7,7 @@ import { toast } from 'sonner';
|
||||
import useSWR from 'swr/mutation';
|
||||
|
||||
export default function RegenerateKey(props: Props) {
|
||||
const { error, isMutating, trigger } = useSWR('/api/livekit/broadcasterToken', async (url) =>
|
||||
const { error, isMutating, trigger } = useSWR('/api/rtmp/streamKey', async (url) =>
|
||||
defaultFetcher(url, { body: JSON.stringify({ channel: props.channel }), method: 'POST' })
|
||||
);
|
||||
|
||||
|
||||
@@ -97,7 +97,7 @@ function StreamerItem({ streamer }: { streamer: StreamInfoResponse[0] }) {
|
||||
<div className="flex-1">
|
||||
<p className="font-medium truncate">{streamer.username}</p>
|
||||
<p className="text-sm truncate">{streamer.category}</p>
|
||||
{streamer.isLive && (
|
||||
{false && streamer.isLive && (
|
||||
<p className="text-sm">
|
||||
{streamer.viewers} viewer{streamer.viewers === 1 ? '' : 's'}
|
||||
</p>
|
||||
|
||||
@@ -1,168 +1,53 @@
|
||||
'use client';
|
||||
|
||||
import useFullscreen from '@/lib/hooks/useFullscreen';
|
||||
import { useParams } from 'next/navigation';
|
||||
import {
|
||||
useTracks,
|
||||
useParticipants,
|
||||
useConnectionState,
|
||||
TrackRefContext,
|
||||
VideoTrack,
|
||||
StartAudio,
|
||||
AudioTrack,
|
||||
} from '@livekit/components-react';
|
||||
import { getTrackReferenceId } from '@livekit/components-core';
|
||||
import { Track } from 'livekit-client';
|
||||
import { LoaderCircleIcon, Minimize, Maximize, VolumeX, Volume2 } from 'lucide-react';
|
||||
import { useState, useRef, useEffect } from 'react';
|
||||
MediaController,
|
||||
MediaLoadingIndicator,
|
||||
MediaControlBar,
|
||||
MediaPlayButton,
|
||||
MediaSeekBackwardButton,
|
||||
MediaSeekForwardButton,
|
||||
MediaMuteButton,
|
||||
MediaVolumeRange,
|
||||
MediaFullscreenButton
|
||||
} from 'media-chrome/react';
|
||||
import HlsVideo from 'hls-video-element/react'
|
||||
|
||||
export default function StreamPlayer() {
|
||||
const [volume, setVolume] = useState(1);
|
||||
const [isMuted, setIsMuted] = useState(false);
|
||||
const handleVolumeChange = (newVolume: number, muted: boolean) => {
|
||||
setVolume(newVolume);
|
||||
setIsMuted(muted);
|
||||
};
|
||||
const containerRef = useRef<HTMLDivElement>(null);
|
||||
const { isFullscreen, toggleFullscreen } = useFullscreen(containerRef);
|
||||
|
||||
const tracks = useTracks([
|
||||
Track.Source.Camera,
|
||||
Track.Source.Microphone,
|
||||
Track.Source.ScreenShare,
|
||||
Track.Source.ScreenShareAudio,
|
||||
]);
|
||||
const participants = useParticipants();
|
||||
const connectionState = useConnectionState();
|
||||
const [isConnecting, setIsConnecting] = useState(true);
|
||||
|
||||
const broadcasterTracks = tracks.filter((track) => track.participant.identity === 'streamer');
|
||||
const audioTracks = broadcasterTracks.filter(track =>
|
||||
track.publication.kind === "audio" ||
|
||||
track.source === Track.Source.Microphone ||
|
||||
track.source === Track.Source.ScreenShareAudio
|
||||
);
|
||||
|
||||
// very hacky but works
|
||||
useEffect(() => {
|
||||
if (connectionState === 'connected') {
|
||||
const timer = setTimeout(() => setIsConnecting(false), 2000);
|
||||
return () => clearTimeout(timer);
|
||||
}
|
||||
}, [connectionState]);
|
||||
useEffect(() => {
|
||||
console.log('participants', participants);
|
||||
}, [participants]);
|
||||
|
||||
if (connectionState === 'connecting' || isConnecting) {
|
||||
return (
|
||||
<div className="w-full aspect-video bg-black flex items-center justify-center">
|
||||
<div className="flex flex-col items-center gap-2">
|
||||
<LoaderCircleIcon size={32} className="animate-spin text-white" />
|
||||
<p className="text-white">Connecting to stream...</p>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
if (connectionState === 'disconnected') {
|
||||
return (
|
||||
<div className="w-full aspect-video bg-black flex items-center justify-center">
|
||||
<p className="text-white">Connection lost. Trying to reconnect...</p>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
if (!broadcasterTracks.length) {
|
||||
return (
|
||||
<div className="w-full aspect-video bg-black flex items-center justify-center">
|
||||
<p className="text-white">Stream is currently offline</p>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
const trackRef = broadcasterTracks[0];
|
||||
const { username } = useParams();
|
||||
|
||||
return (
|
||||
<div className="w-full aspect-video bg-black relative group" ref={containerRef}>
|
||||
<TrackRefContext.Provider value={trackRef}>
|
||||
<VideoTrack trackRef={trackRef} className="w-full h-full" />
|
||||
<StartAudio
|
||||
label="Click to allow audio playback"
|
||||
className="absolute top-0 h-full w-full bg-gray-2-translucent text-white"
|
||||
/>
|
||||
{audioTracks.map((trackRef) => (
|
||||
<AudioTrack
|
||||
key={getTrackReferenceId(trackRef)}
|
||||
trackRef={trackRef}
|
||||
volume={volume}
|
||||
muted={isMuted}
|
||||
/>
|
||||
))}
|
||||
</TrackRefContext.Provider>
|
||||
|
||||
{/* controls */}
|
||||
<div className="absolute flex bottom-0 left-0 right-0 bg-black bg-opacity-50 text-white p-2 opacity-0 group-hover:opacity-100 transition-opacity duration-200">
|
||||
<VolumeControl
|
||||
onChange={handleVolumeChange}
|
||||
initialVolume={volume}
|
||||
initialMuted={isMuted}
|
||||
/>
|
||||
<div className="flex-1" />
|
||||
<button onClick={toggleFullscreen} className="hover:text-primary transition-colors">
|
||||
{isFullscreen ? <Minimize size={20} /> : <Maximize size={20} />}
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
);
|
||||
}
|
||||
|
||||
function VolumeControl({
|
||||
onChange,
|
||||
initialVolume = 1,
|
||||
initialMuted = false,
|
||||
}: {
|
||||
onChange: (volume: number, muted: boolean) => void;
|
||||
initialVolume?: number;
|
||||
initialMuted?: boolean;
|
||||
}) {
|
||||
const [volume, setVolume] = useState(initialVolume);
|
||||
const [isMuted, setIsMuted] = useState(initialMuted);
|
||||
const [showVolume, setShowVolume] = useState(false);
|
||||
|
||||
const handleVolumeChange = (newVolume: number) => {
|
||||
setVolume(newVolume);
|
||||
onChange(newVolume, newVolume === 0);
|
||||
};
|
||||
|
||||
const toggleMute = () => {
|
||||
setIsMuted(!isMuted);
|
||||
onChange(volume, !isMuted);
|
||||
};
|
||||
|
||||
return (
|
||||
<div
|
||||
className="relative flex items-center gap-2"
|
||||
onMouseEnter={() => setShowVolume(true)}
|
||||
onMouseLeave={() => setShowVolume(false)}
|
||||
>
|
||||
<button onClick={toggleMute} className="hover:text-primary transition-colors">
|
||||
{isMuted || volume === 0 ? <VolumeX size={20} /> : <Volume2 size={20} />}
|
||||
</button>
|
||||
|
||||
<div
|
||||
className={`flex items-center transition-all duration-200 ${
|
||||
showVolume ? 'w-24 opacity-100' : 'w-0 opacity-0'
|
||||
}`}
|
||||
>
|
||||
<input
|
||||
type="range"
|
||||
min="0"
|
||||
max="1"
|
||||
step="0.01"
|
||||
value={isMuted ? 0 : volume}
|
||||
onChange={(e) => handleVolumeChange(parseFloat(e.target.value))}
|
||||
className="w-full h-1 bg-gray-600 rounded-lg appearance-none cursor-pointer"
|
||||
<MediaController className='w-full aspect-video'>
|
||||
<HlsVideo
|
||||
src={`${process.env.LIVE_SERVER_URL}/hls/${username}.m3u8`}
|
||||
slot="media"
|
||||
crossOrigin="anonymous"
|
||||
autoplay
|
||||
config={{
|
||||
lowLatencyMode: true,
|
||||
liveSyncDurationCount: 2, // Use only 1 segment for sync
|
||||
liveMaxLatencyDurationCount: 3, // Maximum latency allowed
|
||||
liveDurationInfinity: true,
|
||||
enableWorker: true,
|
||||
backBufferLength: 0, // No back buffer
|
||||
startLevel: -1, // Auto level selection
|
||||
maxBufferLength: 4, // Maximum buffer length in seconds
|
||||
maxMaxBufferLength: 6,
|
||||
debug: false,
|
||||
}}
|
||||
/>
|
||||
<MediaLoadingIndicator slot="centered-chrome" noAutohide />
|
||||
<MediaControlBar className='w-full px-2'>
|
||||
<div className="flex items-center gap-2">
|
||||
<MediaPlayButton />
|
||||
<MediaMuteButton />
|
||||
<MediaVolumeRange />
|
||||
</div>
|
||||
<div className="flex items-center gap-2">
|
||||
<MediaFullscreenButton />
|
||||
</div>
|
||||
</MediaControlBar>
|
||||
</MediaController>
|
||||
);
|
||||
}
|
||||
|
||||
@@ -35,15 +35,17 @@ export default function FollowButton(props: Props) {
|
||||
}
|
||||
}, [data]);
|
||||
|
||||
const followingCn = 'text-destructive';
|
||||
const notFollowingCn = 'text-white';
|
||||
return (
|
||||
<Button
|
||||
size={'icon'}
|
||||
onClick={() => trigger()}
|
||||
disabled={isMutating || isLoadingFollowing}
|
||||
ref={ref}
|
||||
variant={following ? 'destructive' : 'default'}
|
||||
variant='outlineMantle'
|
||||
>
|
||||
{isHovering && following ? <HeartCrack /> : <Heart />}
|
||||
{isHovering && following ? <HeartCrack className={followingCn} /> : <Heart className={following ? followingCn : notFollowingCn} />}
|
||||
</Button>
|
||||
);
|
||||
}
|
||||
|
||||
@@ -20,6 +20,7 @@ const buttonVariants = cva(
|
||||
"bg-secondary text-secondary-foreground hover:bg-secondary/80",
|
||||
ghost: "hover:bg-accent hover:text-accent-foreground",
|
||||
link: "text-primary underline-offset-4 hover:underline",
|
||||
outlineMantle: "border border-input bg-mantle hover:bg-accent",
|
||||
},
|
||||
size: {
|
||||
default: "h-10 px-4 py-2",
|
||||
|
||||
@@ -271,7 +271,7 @@ const SidebarTrigger = React.forwardRef<
|
||||
data-sidebar="trigger"
|
||||
variant="ghost"
|
||||
size="icon"
|
||||
className={cn("h-7 w-7", className)}
|
||||
className={cn("h-8 w-8", className)}
|
||||
onClick={(event) => {
|
||||
onClick?.(event)
|
||||
toggleSidebar()
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
'use server'
|
||||
import db from '@/lib/db';
|
||||
|
||||
export async function resolveChannelNameId(channelName: string) {
|
||||
@@ -14,3 +13,19 @@ export async function resolveChannelNameId(channelName: string) {
|
||||
|
||||
return channel.id;
|
||||
}
|
||||
|
||||
export async function resolveUserPersonalChannel(userId: string) {
|
||||
const channel = await db.channel.findFirst({
|
||||
where: {
|
||||
personalFor: {
|
||||
id: userId,
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
if (!channel) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return channel;
|
||||
}
|
||||
@@ -1,9 +1,9 @@
|
||||
import prisma from "@/lib/db";
|
||||
import { roomService } from "@/lib/services/livekit";
|
||||
import prisma from '@/lib/db';
|
||||
import { HttpFlv } from '../types/liveBackendJson';
|
||||
|
||||
export default async function runner() {
|
||||
// if there are no users it explodes so yeah
|
||||
if (await prisma.user.count() === 0) {
|
||||
if ((await prisma.user.count()) === 0) {
|
||||
return;
|
||||
}
|
||||
await initializeStreamInfo();
|
||||
@@ -14,11 +14,11 @@ export default async function runner() {
|
||||
export async function initializeStreamInfo(channelId?: string) {
|
||||
const channels = await prisma.channel.findMany({
|
||||
where: {
|
||||
id: channelId
|
||||
id: channelId,
|
||||
},
|
||||
include: {
|
||||
streamInfo: true
|
||||
}
|
||||
streamInfo: true,
|
||||
},
|
||||
});
|
||||
|
||||
for (const channel of channels) {
|
||||
@@ -33,34 +33,41 @@ export async function initializeStreamInfo(channelId?: string) {
|
||||
viewers: 0,
|
||||
isLive: false,
|
||||
channel: {
|
||||
connect: { id: channel.id }
|
||||
connect: { id: channel.id },
|
||||
},
|
||||
ownedBy: {
|
||||
connect: { id: channel.ownerId }
|
||||
}
|
||||
}
|
||||
connect: { id: channel.ownerId },
|
||||
},
|
||||
},
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
export async function syncStream() {
|
||||
try {
|
||||
// get all active rooms
|
||||
const rooms = await roomService.listRooms();
|
||||
const request = (
|
||||
await (
|
||||
await fetch(`${process.env.LIVE_SERVER_URL}/stat`, {
|
||||
headers: {
|
||||
Authorization: process.env.STAT_AUTH!,
|
||||
},
|
||||
})
|
||||
).json()
|
||||
)['http-flv'] as HttpFlv;
|
||||
|
||||
const rooms = request.servers[0].applications.filter(app => app.name === 'channel-live')[0].live.streams;
|
||||
|
||||
// process each room
|
||||
for (const room of rooms) {
|
||||
const isLive = room.numPublishers >= 1;
|
||||
|
||||
const isLive = room.active;
|
||||
const originalStreamInfo = await prisma.streamInfo.findUnique({
|
||||
where: { username: room.name }
|
||||
where: { username: room.name },
|
||||
});
|
||||
|
||||
// upsert stream info
|
||||
await prisma.streamInfo.upsert({
|
||||
where: {
|
||||
username: room.name
|
||||
username: room.name,
|
||||
},
|
||||
create: {
|
||||
username: room.name,
|
||||
@@ -70,23 +77,22 @@ export async function syncStream() {
|
||||
thumbnail: 'https://picsum.photos/600/400',
|
||||
viewers: 0,
|
||||
channel: {
|
||||
connect: { id: room.name }
|
||||
connect: { id: room.name },
|
||||
},
|
||||
isLive,
|
||||
ownedBy: {
|
||||
connect: { id: room.name }
|
||||
}
|
||||
connect: { id: room.name },
|
||||
},
|
||||
},
|
||||
update: {
|
||||
isLive,
|
||||
viewers: room.numParticipants - 1,
|
||||
startedAt: !isLive ? new Date(0) :
|
||||
(originalStreamInfo?.isLive ? originalStreamInfo.startedAt : new Date())
|
||||
}
|
||||
viewers: room.clients.filter(c => !c.publishing).length,
|
||||
startedAt: !isLive
|
||||
? new Date(0)
|
||||
: originalStreamInfo?.isLive
|
||||
? originalStreamInfo.startedAt
|
||||
: new Date(),
|
||||
},
|
||||
});
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error syncing room streams:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
117
src/lib/types/liveBackendJson.ts
Normal file
117
src/lib/types/liveBackendJson.ts
Normal file
@@ -0,0 +1,117 @@
|
||||
/**
|
||||
* Types for nginx-http-flv module statistics
|
||||
*/
|
||||
|
||||
// Client information
|
||||
interface Client {
|
||||
id: number;
|
||||
address: string;
|
||||
time: number;
|
||||
flashver: string;
|
||||
swfurl?: string;
|
||||
dropped: number;
|
||||
avsync: number;
|
||||
timestamp: number;
|
||||
publishing: boolean;
|
||||
active: boolean;
|
||||
}
|
||||
|
||||
// Video metadata
|
||||
interface VideoMeta {
|
||||
width: number;
|
||||
height: number;
|
||||
frame_rate: number;
|
||||
codec: string;
|
||||
profile: string;
|
||||
compat: number;
|
||||
level: number;
|
||||
}
|
||||
|
||||
// Audio metadata
|
||||
interface AudioMeta {
|
||||
codec: string;
|
||||
profile: string;
|
||||
channels: number;
|
||||
sample_rate: number;
|
||||
}
|
||||
|
||||
// Stream metadata
|
||||
interface StreamMeta {
|
||||
video: VideoMeta;
|
||||
audio: AudioMeta;
|
||||
}
|
||||
|
||||
// Stream information
|
||||
interface Stream {
|
||||
name: string;
|
||||
time: number;
|
||||
bw_in: number;
|
||||
bytes_in: number;
|
||||
bw_out: number;
|
||||
bytes_out: number;
|
||||
bw_audio: number;
|
||||
bw_video: number;
|
||||
clients: Client[];
|
||||
records: any[]; // Empty array in the provided example
|
||||
meta: StreamMeta;
|
||||
nclients: number;
|
||||
publishing: boolean;
|
||||
active: boolean;
|
||||
}
|
||||
|
||||
// Live application section
|
||||
interface Live {
|
||||
streams: Stream[];
|
||||
nclients: number;
|
||||
}
|
||||
|
||||
// Recorder configuration
|
||||
interface Recorder {
|
||||
id: string;
|
||||
flags: string[];
|
||||
unique: boolean;
|
||||
append: boolean;
|
||||
lock_file: boolean;
|
||||
notify: boolean;
|
||||
path: string;
|
||||
max_size: number;
|
||||
max_frames: number;
|
||||
interval: number;
|
||||
suffix: string;
|
||||
}
|
||||
|
||||
// Recorders section
|
||||
interface Recorders {
|
||||
count: number;
|
||||
lists: Recorder[];
|
||||
}
|
||||
|
||||
// Application information
|
||||
interface Application {
|
||||
name: string;
|
||||
live: Live;
|
||||
recorders: Recorders;
|
||||
}
|
||||
|
||||
// Server information
|
||||
interface Server {
|
||||
port: number;
|
||||
server_index: number;
|
||||
applications: Application[];
|
||||
}
|
||||
|
||||
// Root HTTP-FLV structure
|
||||
export interface HttpFlv {
|
||||
nginx_version: string;
|
||||
nginx_http_flv_version: string;
|
||||
compiler: string;
|
||||
built: string;
|
||||
pid: number;
|
||||
uptime: number;
|
||||
naccepted: number;
|
||||
bw_in: number;
|
||||
bytes_in: number;
|
||||
bw_out: number;
|
||||
bytes_out: number;
|
||||
servers: Server[];
|
||||
}
|
||||
226
yarn.lock
226
yarn.lock
@@ -1349,6 +1349,13 @@
|
||||
resolved "https://registry.yarnpkg.com/@types/json5/-/json5-0.0.29.tgz#ee28707ae94e11d2b827bcbe5270bcea7f3e71ee"
|
||||
integrity sha512-dRLjCWHYg4oaA77cxO64oO+7JwCwnIzkZPdrrC71jQmQtlhM556pwKo5bUzqvZndkVbeFLIIi+9TC40JNF5hNQ==
|
||||
|
||||
"@types/node@*":
|
||||
version "22.13.10"
|
||||
resolved "https://registry.yarnpkg.com/@types/node/-/node-22.13.10.tgz#df9ea358c5ed991266becc3109dc2dc9125d77e4"
|
||||
integrity sha512-I6LPUvlRH+O6VRUqYOcMudhaIdUVWfsjnZavnsraHvpBwaEyMN29ry+0UVJhImYL16xsscu0aske3yA+uPOWfw==
|
||||
dependencies:
|
||||
undici-types "~6.20.0"
|
||||
|
||||
"@types/node@^20":
|
||||
version "20.17.12"
|
||||
resolved "https://registry.yarnpkg.com/@types/node/-/node-20.17.12.tgz#ee3b7d25a522fd95608c1b3f02921c97b93fcbd6"
|
||||
@@ -1374,6 +1381,13 @@
|
||||
"@types/prop-types" "*"
|
||||
csstype "^3.0.2"
|
||||
|
||||
"@types/ws@^8.18.0":
|
||||
version "8.18.0"
|
||||
resolved "https://registry.yarnpkg.com/@types/ws/-/ws-8.18.0.tgz#8a2ec491d6f0685ceaab9a9b7ff44146236993b5"
|
||||
integrity sha512-8svvI3hMyvN0kKCJMvTJP/x6Y/EoQbepff882wL+Sn5QsXb3etnamgrJq4isrBxSJj5L2AuXcI0+bgkoAXGUJw==
|
||||
dependencies:
|
||||
"@types/node" "*"
|
||||
|
||||
"@typescript-eslint/eslint-plugin@^5.4.2 || ^6.0.0 || ^7.0.0 || ^8.0.0":
|
||||
version "8.19.1"
|
||||
resolved "https://registry.yarnpkg.com/@typescript-eslint/eslint-plugin/-/eslint-plugin-8.19.1.tgz#5f26c0a833b27bcb1aa402b82e76d3b8dda0b247"
|
||||
@@ -1697,6 +1711,11 @@ bl@^5.0.0:
|
||||
inherits "^2.0.4"
|
||||
readable-stream "^3.4.0"
|
||||
|
||||
boolbase@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/boolbase/-/boolbase-1.0.0.tgz#68dff5fbe60c51eb37725ea9e3ed310dcc1e776e"
|
||||
integrity sha512-JZOSA7Mo9sNGB8+UjSgzdLtokWAky1zbztM3WRLCbZ70/3cTANmQmOdR7y2g+J0e2WXywy1yS468tY+IruqEww==
|
||||
|
||||
brace-expansion@^1.1.7:
|
||||
version "1.1.11"
|
||||
resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-1.1.11.tgz#3c7fcbf529d87226f3d2f52b966ff5271eb441dd"
|
||||
@@ -1800,6 +1819,11 @@ caniuse-lite@^1.0.30001579, caniuse-lite@^1.0.30001688:
|
||||
resolved "https://registry.yarnpkg.com/caniuse-lite/-/caniuse-lite-1.0.30001692.tgz#4585729d95e6b95be5b439da6ab55250cd125bf9"
|
||||
integrity sha512-A95VKan0kdtrsnMubMKxEKUKImOPSuCpYgxSQBo036P5YYgVIcOYJEgt/txJWqObiRQeISNCfef9nvlQ0vbV7A==
|
||||
|
||||
ce-la-react@^0.1.3:
|
||||
version "0.1.3"
|
||||
resolved "https://registry.yarnpkg.com/ce-la-react/-/ce-la-react-0.1.3.tgz#ccb34ec24091bd8be3da40ddcedb4a99ae1db72f"
|
||||
integrity sha512-zZwEEJv9XukeEGbswQXObaDJjYAufOIilSnDg4BWCpKNEYN84H9fpaB+wl+rYKWOIH4wBBPbLnOxKvDIwsL/JQ==
|
||||
|
||||
chalk@^4.0.0:
|
||||
version "4.1.2"
|
||||
resolved "https://registry.yarnpkg.com/chalk/-/chalk-4.1.2.tgz#aac4e2b7734a740867aeb16bf02aad556a1e7a01"
|
||||
@@ -1813,6 +1837,35 @@ chalk@^5.0.0:
|
||||
resolved "https://registry.yarnpkg.com/chalk/-/chalk-5.4.1.tgz#1b48bf0963ec158dce2aacf69c093ae2dd2092d8"
|
||||
integrity sha512-zgVZuo2WcZgfUEmsn6eO3kINexW8RAE4maiQ8QNs8CtpPCSyMiYsULR3HQYkm3w8FIA3SberyMJMSldGsW+U3w==
|
||||
|
||||
cheerio-select@^2.1.0:
|
||||
version "2.1.0"
|
||||
resolved "https://registry.yarnpkg.com/cheerio-select/-/cheerio-select-2.1.0.tgz#4d8673286b8126ca2a8e42740d5e3c4884ae21b4"
|
||||
integrity sha512-9v9kG0LvzrlcungtnJtpGNxY+fzECQKhK4EGJX2vByejiMX84MFNQw4UxPJl3bFbTMw+Dfs37XaIkCwTZfLh4g==
|
||||
dependencies:
|
||||
boolbase "^1.0.0"
|
||||
css-select "^5.1.0"
|
||||
css-what "^6.1.0"
|
||||
domelementtype "^2.3.0"
|
||||
domhandler "^5.0.3"
|
||||
domutils "^3.0.1"
|
||||
|
||||
cheerio@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/cheerio/-/cheerio-1.0.0.tgz#1ede4895a82f26e8af71009f961a9b8cb60d6a81"
|
||||
integrity sha512-quS9HgjQpdaXOvsZz82Oz7uxtXiy6UIsIQcpBj7HRw2M63Skasm9qlDocAM7jNuaxdhpPU7c4kJN+gA5MCu4ww==
|
||||
dependencies:
|
||||
cheerio-select "^2.1.0"
|
||||
dom-serializer "^2.0.0"
|
||||
domhandler "^5.0.3"
|
||||
domutils "^3.1.0"
|
||||
encoding-sniffer "^0.2.0"
|
||||
htmlparser2 "^9.1.0"
|
||||
parse5 "^7.1.2"
|
||||
parse5-htmlparser2-tree-adapter "^7.0.0"
|
||||
parse5-parser-stream "^7.1.2"
|
||||
undici "^6.19.5"
|
||||
whatwg-mimetype "^4.0.0"
|
||||
|
||||
chokidar@^3.6.0:
|
||||
version "3.6.0"
|
||||
resolved "https://registry.yarnpkg.com/chokidar/-/chokidar-3.6.0.tgz#197c6cc669ef2a8dc5e7b4d97ee4e092c3eb0d5b"
|
||||
@@ -1942,6 +1995,22 @@ cross-spawn@^7.0.0, cross-spawn@^7.0.2, cross-spawn@^7.0.3:
|
||||
shebang-command "^2.0.0"
|
||||
which "^2.0.1"
|
||||
|
||||
css-select@^5.1.0:
|
||||
version "5.1.0"
|
||||
resolved "https://registry.yarnpkg.com/css-select/-/css-select-5.1.0.tgz#b8ebd6554c3637ccc76688804ad3f6a6fdaea8a6"
|
||||
integrity sha512-nwoRF1rvRRnnCqqY7updORDsuqKzqYJ28+oSMaJMMgOauh3fvwHqMS7EZpIPqK8GL+g9mKxF1vP/ZjSeNjEVHg==
|
||||
dependencies:
|
||||
boolbase "^1.0.0"
|
||||
css-what "^6.1.0"
|
||||
domhandler "^5.0.2"
|
||||
domutils "^3.0.1"
|
||||
nth-check "^2.0.1"
|
||||
|
||||
css-what@^6.1.0:
|
||||
version "6.1.0"
|
||||
resolved "https://registry.yarnpkg.com/css-what/-/css-what-6.1.0.tgz#fb5effcf76f1ddea2c81bdfaa4de44e79bac70f4"
|
||||
integrity sha512-HTUrgRJ7r4dsZKU6GjmpfRK1O76h97Z8MfS1G0FozR+oF2kG6Vfe8JE6zwrkbxigziPHinCJ+gCPjA9EaBDtRw==
|
||||
|
||||
cssesc@^3.0.0:
|
||||
version "3.0.0"
|
||||
resolved "https://registry.yarnpkg.com/cssesc/-/cssesc-3.0.0.tgz#37741919903b868565e1c09ea747445cd18983ee"
|
||||
@@ -1952,6 +2021,11 @@ csstype@^3.0.2:
|
||||
resolved "https://registry.yarnpkg.com/csstype/-/csstype-3.1.3.tgz#d80ff294d114fb0e6ac500fbf85b60137d7eff81"
|
||||
integrity sha512-M1uQkMl8rQK/szD0LNhtqxIPLpimGm8sOBwU7lLnCpSbTyY3yeU1Vc7l4KT5zT4s/yOxHH5O7tIuuLOCnLADRw==
|
||||
|
||||
custom-media-element@^1.4.2:
|
||||
version "1.4.2"
|
||||
resolved "https://registry.yarnpkg.com/custom-media-element/-/custom-media-element-1.4.2.tgz#5d70d357b7605deadce72341b7c0b97a447908d4"
|
||||
integrity sha512-AM6FRWqJyW7pWTvXb4uJj6yvHE7C6UutdhJ5o3XO5NEl5aWFcfnpz8/TuW8qr1+/wfbj50wRvdArnSNjTmjmVw==
|
||||
|
||||
damerau-levenshtein@^1.0.8:
|
||||
version "1.0.8"
|
||||
resolved "https://registry.yarnpkg.com/damerau-levenshtein/-/damerau-levenshtein-1.0.8.tgz#b43d286ccbd36bc5b2f7ed41caf2d0aba1f8a6e7"
|
||||
@@ -2082,6 +2156,36 @@ doctrine@^3.0.0:
|
||||
dependencies:
|
||||
esutils "^2.0.2"
|
||||
|
||||
dom-serializer@^2.0.0:
|
||||
version "2.0.0"
|
||||
resolved "https://registry.yarnpkg.com/dom-serializer/-/dom-serializer-2.0.0.tgz#e41b802e1eedf9f6cae183ce5e622d789d7d8e53"
|
||||
integrity sha512-wIkAryiqt/nV5EQKqQpo3SToSOV9J0DnbJqwK7Wv/Trc92zIAYZ4FlMu+JPFW1DfGFt81ZTCGgDEabffXeLyJg==
|
||||
dependencies:
|
||||
domelementtype "^2.3.0"
|
||||
domhandler "^5.0.2"
|
||||
entities "^4.2.0"
|
||||
|
||||
domelementtype@^2.3.0:
|
||||
version "2.3.0"
|
||||
resolved "https://registry.yarnpkg.com/domelementtype/-/domelementtype-2.3.0.tgz#5c45e8e869952626331d7aab326d01daf65d589d"
|
||||
integrity sha512-OLETBj6w0OsagBwdXnPdN0cnMfF9opN69co+7ZrbfPGrdpPVNBUj02spi6B1N7wChLQiPn4CSH/zJvXw56gmHw==
|
||||
|
||||
domhandler@^5.0.2, domhandler@^5.0.3:
|
||||
version "5.0.3"
|
||||
resolved "https://registry.yarnpkg.com/domhandler/-/domhandler-5.0.3.tgz#cc385f7f751f1d1fc650c21374804254538c7d31"
|
||||
integrity sha512-cgwlv/1iFQiFnU96XXgROh8xTeetsnJiDsTc7TYCLFd9+/WNkIqPTxiM/8pSd8VIrhXGTf1Ny1q1hquVqDJB5w==
|
||||
dependencies:
|
||||
domelementtype "^2.3.0"
|
||||
|
||||
domutils@^3.0.1, domutils@^3.1.0:
|
||||
version "3.2.2"
|
||||
resolved "https://registry.yarnpkg.com/domutils/-/domutils-3.2.2.tgz#edbfe2b668b0c1d97c24baf0f1062b132221bc78"
|
||||
integrity sha512-6kZKyUajlDuqlHKVX1w7gyslj9MPIXzIFiz/rGu35uC1wMi+kMhQwGhl4lt9unC9Vb9INnY9Z3/ZA3+FhASLaw==
|
||||
dependencies:
|
||||
dom-serializer "^2.0.0"
|
||||
domelementtype "^2.3.0"
|
||||
domhandler "^5.0.3"
|
||||
|
||||
dunder-proto@^1.0.0, dunder-proto@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/dunder-proto/-/dunder-proto-1.0.1.tgz#d7ae667e1dc83482f8b70fd0f6eefc50da30f58a"
|
||||
@@ -2111,6 +2215,14 @@ emoji-regex@^9.2.2:
|
||||
resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-9.2.2.tgz#840c8803b0d8047f4ff0cf963176b32d4ef3ed72"
|
||||
integrity sha512-L18DaJsXSUk2+42pv8mLs5jJT2hqFkFE4j21wOmgbUqsZ2hL72NsUU785g9RXgo3s0ZNgVl42TiHp3ZtOv/Vyg==
|
||||
|
||||
encoding-sniffer@^0.2.0:
|
||||
version "0.2.0"
|
||||
resolved "https://registry.yarnpkg.com/encoding-sniffer/-/encoding-sniffer-0.2.0.tgz#799569d66d443babe82af18c9f403498365ef1d5"
|
||||
integrity sha512-ju7Wq1kg04I3HtiYIOrUrdfdDvkyO9s5XM8QAj/bN61Yo/Vb4vgJxy5vi4Yxk01gWHbrofpPtpxM8bKger9jhg==
|
||||
dependencies:
|
||||
iconv-lite "^0.6.3"
|
||||
whatwg-encoding "^3.1.1"
|
||||
|
||||
enhanced-resolve@^5.15.0:
|
||||
version "5.18.0"
|
||||
resolved "https://registry.yarnpkg.com/enhanced-resolve/-/enhanced-resolve-5.18.0.tgz#91eb1db193896b9801251eeff1c6980278b1e404"
|
||||
@@ -2119,6 +2231,11 @@ enhanced-resolve@^5.15.0:
|
||||
graceful-fs "^4.2.4"
|
||||
tapable "^2.2.0"
|
||||
|
||||
entities@^4.2.0, entities@^4.5.0:
|
||||
version "4.5.0"
|
||||
resolved "https://registry.yarnpkg.com/entities/-/entities-4.5.0.tgz#5d268ea5e7113ec74c4d033b79ea5a35a488fb48"
|
||||
integrity sha512-V0hjH4dGPh9Ao5p0MoRY6BVqtwCjhz6vI5LT8AJ55H+4g9/4vbHx1I54fS0XuclLhDHArPQCiMjDxjaL8fPxhw==
|
||||
|
||||
error-ex@^1.3.1:
|
||||
version "1.3.2"
|
||||
resolved "https://registry.yarnpkg.com/error-ex/-/error-ex-1.3.2.tgz#b4ac40648107fdcdcfae242f428bea8a14d4f1bf"
|
||||
@@ -2826,6 +2943,30 @@ hasown@^2.0.0, hasown@^2.0.2:
|
||||
dependencies:
|
||||
function-bind "^1.1.2"
|
||||
|
||||
hls-video-element@^1.5.0:
|
||||
version "1.5.0"
|
||||
resolved "https://registry.yarnpkg.com/hls-video-element/-/hls-video-element-1.5.0.tgz#99d444ecc0a20520b7071f8d673dc5a47f3d07b3"
|
||||
integrity sha512-ghFzkmd9kmeUjmHuZ/aw55V/n1OQCTy05U7yrs8oN5vmmd/pue+MxbQBXl2oXV7VupLB+LnxzZHycireLUy0VQ==
|
||||
dependencies:
|
||||
custom-media-element "^1.4.2"
|
||||
hls.js "^1.5.11"
|
||||
media-tracks "^0.3.3"
|
||||
|
||||
hls.js@^1.5.11:
|
||||
version "1.5.20"
|
||||
resolved "https://registry.yarnpkg.com/hls.js/-/hls.js-1.5.20.tgz#7eb23bb5e2595311d4e2761038ca6882673de7e2"
|
||||
integrity sha512-uu0VXUK52JhihhnN/MVVo1lvqNNuhoxkonqgO3IpjvQiGpJBdIXMGkofjQb/j9zvV7a1SW8U9g1FslWx/1HOiQ==
|
||||
|
||||
htmlparser2@^9.1.0:
|
||||
version "9.1.0"
|
||||
resolved "https://registry.yarnpkg.com/htmlparser2/-/htmlparser2-9.1.0.tgz#cdb498d8a75a51f739b61d3f718136c369bc8c23"
|
||||
integrity sha512-5zfg6mHUoaer/97TxnGpxmbR7zJtPwIYFMZ/H5ucTlPZhKvtum05yiPK3Mgai3a0DyVxv7qYqoweaEd2nrYQzQ==
|
||||
dependencies:
|
||||
domelementtype "^2.3.0"
|
||||
domhandler "^5.0.3"
|
||||
domutils "^3.1.0"
|
||||
entities "^4.5.0"
|
||||
|
||||
https-proxy-agent@^6.2.0:
|
||||
version "6.2.1"
|
||||
resolved "https://registry.yarnpkg.com/https-proxy-agent/-/https-proxy-agent-6.2.1.tgz#0965ab47371b3e531cf6794d1eb148710a992ba7"
|
||||
@@ -2839,6 +2980,13 @@ human-signals@^4.3.0:
|
||||
resolved "https://registry.yarnpkg.com/human-signals/-/human-signals-4.3.1.tgz#ab7f811e851fca97ffbd2c1fe9a958964de321b2"
|
||||
integrity sha512-nZXjEF2nbo7lIw3mgYjItAfgQXog3OjJogSbKa2CQIIvSGWcKgeJnQlNXip6NglNzYH45nSRiEVimMvYL8DDqQ==
|
||||
|
||||
iconv-lite@0.6.3, iconv-lite@^0.6.3:
|
||||
version "0.6.3"
|
||||
resolved "https://registry.yarnpkg.com/iconv-lite/-/iconv-lite-0.6.3.tgz#a52f80bf38da1952eb5c681790719871a1a72501"
|
||||
integrity sha512-4fCk79wshMdzMp2rH06qWrJE4iolqLhCUH+OiuIgU++RB0+94NlDL81atO7GX55uUKueo0txHNtvEyI6D7WdMw==
|
||||
dependencies:
|
||||
safer-buffer ">= 2.1.2 < 3.0.0"
|
||||
|
||||
ieee754@^1.2.1:
|
||||
version "1.2.1"
|
||||
resolved "https://registry.yarnpkg.com/ieee754/-/ieee754-1.2.1.tgz#8eb7a10a63fff25d15a57b001586d177d1b0d352"
|
||||
@@ -3397,6 +3545,18 @@ math-intrinsics@^1.1.0:
|
||||
resolved "https://registry.yarnpkg.com/math-intrinsics/-/math-intrinsics-1.1.0.tgz#a0dd74be81e2aa5c2f27e65ce283605ee4e2b7f9"
|
||||
integrity sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==
|
||||
|
||||
media-chrome@^4.8.0:
|
||||
version "4.8.0"
|
||||
resolved "https://registry.yarnpkg.com/media-chrome/-/media-chrome-4.8.0.tgz#ff881a5466fe02ad07344a370a8a1106988ca245"
|
||||
integrity sha512-oioEGlluW+1RqknqsszrKHDs3NZ9AaatEaE2kYYOSWxnwvVmhRTfDWT4JeMgtUr5r3i2dAI3e/qbeb1j+a0MhA==
|
||||
dependencies:
|
||||
ce-la-react "^0.1.3"
|
||||
|
||||
media-tracks@^0.3.3:
|
||||
version "0.3.3"
|
||||
resolved "https://registry.yarnpkg.com/media-tracks/-/media-tracks-0.3.3.tgz#cca72bd791dcb76cd6427dfa6b2baa25601ea192"
|
||||
integrity sha512-9P2FuUHnZZ3iji+2RQk7Zkh5AmZTnOG5fODACnjhCVveX1McY3jmCRHofIEI+yTBqplz7LXy48c7fQ3Uigp88w==
|
||||
|
||||
merge-stream@^2.0.0:
|
||||
version "2.0.0"
|
||||
resolved "https://registry.yarnpkg.com/merge-stream/-/merge-stream-2.0.0.tgz#52823629a14dd00c9770fb6ad47dc6310f2c1f60"
|
||||
@@ -3490,6 +3650,11 @@ next-themes@^0.4.4:
|
||||
resolved "https://registry.yarnpkg.com/next-themes/-/next-themes-0.4.4.tgz#ce6f68a4af543821bbc4755b59c0d3ced55c2d13"
|
||||
integrity sha512-LDQ2qIOJF0VnuVrrMSMLrWGjRMkq+0mpgl6e0juCLqdJ+oo8Q84JRWT6Wh11VDQKkMMe+dVzDKLWs5n87T+PkQ==
|
||||
|
||||
next-ws@^2.0.4:
|
||||
version "2.0.4"
|
||||
resolved "https://registry.yarnpkg.com/next-ws/-/next-ws-2.0.4.tgz#704a61dfcb4911d561f49a38128d184a43a71737"
|
||||
integrity sha512-r5w6X8J5i7/Cs/cUez7FF+3ZSVAe7aRjuGZ0BuyICKhE71x8RBSlTzluFZ5LmPcXZixGDlKDZoP1brNSPh73eQ==
|
||||
|
||||
next@^15.1.6:
|
||||
version "15.1.6"
|
||||
resolved "https://registry.yarnpkg.com/next/-/next-15.1.6.tgz#ce22fd0a8f36da1fc4aba86e3ec7e98eb248c555"
|
||||
@@ -3544,6 +3709,13 @@ npm-run-path@^5.1.0:
|
||||
dependencies:
|
||||
path-key "^4.0.0"
|
||||
|
||||
nth-check@^2.0.1:
|
||||
version "2.1.1"
|
||||
resolved "https://registry.yarnpkg.com/nth-check/-/nth-check-2.1.1.tgz#c9eab428effce36cd6b92c924bdb000ef1f1ed1d"
|
||||
integrity sha512-lqjrjmaOoAnWfMmBPL+XNnynZh2+swxiX3WUE0s4yEHI6m+AwrK2UZOimIRl3X/4QctVqS8AiZjFqyOGrMXb/w==
|
||||
dependencies:
|
||||
boolbase "^1.0.0"
|
||||
|
||||
object-assign@^4.0.1, object-assign@^4.1.1:
|
||||
version "4.1.1"
|
||||
resolved "https://registry.yarnpkg.com/object-assign/-/object-assign-4.1.1.tgz#2109adc7965887cfc05cbbd442cac8bfbb360863"
|
||||
@@ -3707,6 +3879,28 @@ parse-json@^5.2.0:
|
||||
json-parse-even-better-errors "^2.3.0"
|
||||
lines-and-columns "^1.1.6"
|
||||
|
||||
parse5-htmlparser2-tree-adapter@^7.0.0:
|
||||
version "7.1.0"
|
||||
resolved "https://registry.yarnpkg.com/parse5-htmlparser2-tree-adapter/-/parse5-htmlparser2-tree-adapter-7.1.0.tgz#b5a806548ed893a43e24ccb42fbb78069311e81b"
|
||||
integrity sha512-ruw5xyKs6lrpo9x9rCZqZZnIUntICjQAd0Wsmp396Ul9lN/h+ifgVV1x1gZHi8euej6wTfpqX8j+BFQxF0NS/g==
|
||||
dependencies:
|
||||
domhandler "^5.0.3"
|
||||
parse5 "^7.0.0"
|
||||
|
||||
parse5-parser-stream@^7.1.2:
|
||||
version "7.1.2"
|
||||
resolved "https://registry.yarnpkg.com/parse5-parser-stream/-/parse5-parser-stream-7.1.2.tgz#d7c20eadc37968d272e2c02660fff92dd27e60e1"
|
||||
integrity sha512-JyeQc9iwFLn5TbvvqACIF/VXG6abODeB3Fwmv/TGdLk2LfbWkaySGY72at4+Ty7EkPZj854u4CrICqNk2qIbow==
|
||||
dependencies:
|
||||
parse5 "^7.0.0"
|
||||
|
||||
parse5@^7.0.0, parse5@^7.1.2:
|
||||
version "7.2.1"
|
||||
resolved "https://registry.yarnpkg.com/parse5/-/parse5-7.2.1.tgz#8928f55915e6125f430cc44309765bf17556a33a"
|
||||
integrity sha512-BuBYQYlv1ckiPdQi/ohiivi9Sagc9JG+Ozs0r7b/0iK3sKmrb0b9FdWdBbOdx6hBCM/F9Ir82ofnBhtZOjCRPQ==
|
||||
dependencies:
|
||||
entities "^4.5.0"
|
||||
|
||||
path-browserify@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/path-browserify/-/path-browserify-1.0.1.tgz#d98454a9c3753d5790860f16f68867b9e46be1fd"
|
||||
@@ -4119,6 +4313,11 @@ safe-regex-test@^1.0.3, safe-regex-test@^1.1.0:
|
||||
es-errors "^1.3.0"
|
||||
is-regex "^1.2.1"
|
||||
|
||||
"safer-buffer@>= 2.1.2 < 3.0.0":
|
||||
version "2.1.2"
|
||||
resolved "https://registry.yarnpkg.com/safer-buffer/-/safer-buffer-2.1.2.tgz#44fa161b0187b9549dd84bb91802f9bd8385cd6a"
|
||||
integrity sha512-YZo3K82SD7Riyi0E1EQPojLz7kpepnSQI9IyPbHHg1XXXevb5dJI7tpyN2ADxGcQbHG7vcyRHk0cbwqcQriUtg==
|
||||
|
||||
scheduler@^0.25.0:
|
||||
version "0.25.0"
|
||||
resolved "https://registry.yarnpkg.com/scheduler/-/scheduler-0.25.0.tgz#336cd9768e8cceebf52d3c80e3dcf5de23e7e015"
|
||||
@@ -4736,6 +4935,16 @@ undici-types@~6.19.2:
|
||||
resolved "https://registry.yarnpkg.com/undici-types/-/undici-types-6.19.8.tgz#35111c9d1437ab83a7cdc0abae2f26d88eda0a02"
|
||||
integrity sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==
|
||||
|
||||
undici-types@~6.20.0:
|
||||
version "6.20.0"
|
||||
resolved "https://registry.yarnpkg.com/undici-types/-/undici-types-6.20.0.tgz#8171bf22c1f588d1554d55bf204bc624af388433"
|
||||
integrity sha512-Ny6QZ2Nju20vw1SRHe3d9jVu6gJ+4e3+MMpqu7pqE5HT6WsTSlce++GQmK5UXS8mzV8DSYHrQH+Xrf2jVcuKNg==
|
||||
|
||||
undici@^6.19.5:
|
||||
version "6.21.2"
|
||||
resolved "https://registry.yarnpkg.com/undici/-/undici-6.21.2.tgz#49c5884e8f9039c65a89ee9018ef3c8e2f1f4928"
|
||||
integrity sha512-uROZWze0R0itiAKVPsYhFov9LxrPMHLMEQFszeI2gCN6bnIIZ8twzBCJcN2LJrBBLfrP0t1FW0g+JmKVl8Vk1g==
|
||||
|
||||
universalify@^2.0.0:
|
||||
version "2.0.1"
|
||||
resolved "https://registry.yarnpkg.com/universalify/-/universalify-2.0.1.tgz#168efc2180964e6386d061e094df61afe239b18d"
|
||||
@@ -4819,6 +5028,18 @@ webrtc-adapter@^9.0.0:
|
||||
dependencies:
|
||||
sdp "^3.2.0"
|
||||
|
||||
whatwg-encoding@^3.1.1:
|
||||
version "3.1.1"
|
||||
resolved "https://registry.yarnpkg.com/whatwg-encoding/-/whatwg-encoding-3.1.1.tgz#d0f4ef769905d426e1688f3e34381a99b60b76e5"
|
||||
integrity sha512-6qN4hJdMwfYBtE3YBTTHhoeuUrDBPZmbQaxWAqSALV/MeEnR5z1xd8UKud2RAkFoPkmB+hli1TZSnyi84xz1vQ==
|
||||
dependencies:
|
||||
iconv-lite "0.6.3"
|
||||
|
||||
whatwg-mimetype@^4.0.0:
|
||||
version "4.0.0"
|
||||
resolved "https://registry.yarnpkg.com/whatwg-mimetype/-/whatwg-mimetype-4.0.0.tgz#bc1bf94a985dc50388d54a9258ac405c3ca2fc0a"
|
||||
integrity sha512-QaKxh0eNIi2mE9p2vEdzfagOKHCcj1pJ56EEHGQOVxp8r9/iszLUUV7v89x9O1p/T+NlTM5W7jW6+cz4Fq1YVg==
|
||||
|
||||
which-boxed-primitive@^1.1.0, which-boxed-primitive@^1.1.1:
|
||||
version "1.1.1"
|
||||
resolved "https://registry.yarnpkg.com/which-boxed-primitive/-/which-boxed-primitive-1.1.1.tgz#d76ec27df7fa165f18d5808374a5fe23c29b176e"
|
||||
@@ -4906,6 +5127,11 @@ wrappy@1:
|
||||
resolved "https://registry.yarnpkg.com/wrappy/-/wrappy-1.0.2.tgz#b5243d8f3ec1aa35f1364605bc0d1036e30ab69f"
|
||||
integrity sha512-l4Sp/DRseor9wL6EvV2+TuQn63dMkPjZ/sp9XkghTEbV9KlPS1xUsZ3u7/IQO4wxtcFB4bgpQPRcR3QCvezPcQ==
|
||||
|
||||
ws@^8.18.1:
|
||||
version "8.18.1"
|
||||
resolved "https://registry.yarnpkg.com/ws/-/ws-8.18.1.tgz#ea131d3784e1dfdff91adb0a4a116b127515e3cb"
|
||||
integrity sha512-RKW2aJZMXeMxVpnZ6bck+RswznaxmzdULiBr6KY7XkTnW8uvt0iT9H5DkHUChXrc+uurzwa0rVI16n/Xzjdz1w==
|
||||
|
||||
yallist@^3.0.2:
|
||||
version "3.1.1"
|
||||
resolved "https://registry.yarnpkg.com/yallist/-/yallist-3.1.1.tgz#dbb7daf9bfd8bac9ab45ebf602b8cbad0d5d08fd"
|
||||
|
||||
Reference in New Issue
Block a user