123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433 |
- <?php
- namespace App\Http\Controllers;
- use Illuminate\Http\Request;
- use App\Models\LiveStream;
- use Illuminate\Support\Str;
- use Illuminate\Support\Facades\Storage;
- use App\Services\AccountService;
- use App\Services\FollowerService;
- use App\Services\LiveStreamService;
- use App\User;
- use App\Events\LiveStream\NewChatComment;
- use App\Events\LiveStream\DeleteChatComment;
- use App\Events\LiveStream\BanUser;
- use App\Events\LiveStream\PinChatMessage;
- use App\Events\LiveStream\UnpinChatMessage;
- use App\Events\LiveStream\StreamStart;
- use App\Events\LiveStream\StreamEnd;
- class LiveStreamController extends Controller
- {
- public function createStream(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- if(config('livestreaming.broadcast.limits.enabled')) {
- if($request->user()->is_admin) {
- } else {
- $limits = config('livestreaming.broadcast.limits');
- $user = $request->user();
- abort_if($limits['admins_only'] && $user->is_admin == false, 401, 'LSE:003');
- if($limits['min_account_age']) {
- abort_if($user->created_at->gt(now()->subDays($limits['min_account_age'])), 403, 'LSE:005');
- }
- if($limits['min_follower_count']) {
- $account = AccountService::get($user->profile_id);
- abort_if($account['followers_count'] < $limits['min_follower_count'], 403, 'LSE:008');
- }
- }
- }
- $this->validate($request, [
- 'name' => 'nullable|string|max:80',
- 'description' => 'nullable|string|max:240',
- 'visibility' => 'required|in:public,private'
- ]);
- $stream = new LiveStream;
- $stream->name = $request->input('name');
- $stream->description = $request->input('description');
- $stream->visibility = $request->input('visibility');
- $stream->profile_id = $request->user()->profile_id;
- $stream->stream_id = Str::random(40) . '_' . $stream->profile_id;
- $stream->stream_key = 'streamkey-' . Str::random(64);
- $stream->save();
- return [
- 'host' => $stream->getStreamServer(),
- 'key' => $stream->stream_key,
- 'url' => $stream->getStreamKeyUrl(),
- 'id' => $stream->stream_id
- ];
- }
- public function getUserStream(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $stream = LiveStream::whereProfileId($request->input('profile_id'))
- ->whereNotNull('live_at')
- ->orderByDesc('live_at')
- ->first();
- if(!$stream) {
- return [];
- }
- $res = [];
- $owner = $request->user() ? $stream->profile_id == $request->user()->profile_id : false;
- if($stream->visibility === 'private') {
- abort_if(!$owner && !FollowerService::follows($request->user()->profile_id, $stream->profile_id), 403, 'LSE:011');
- }
- $res = [
- 'hls_url' => $stream->getHlsUrl(),
- 'name' => $stream->name,
- 'description' => $stream->description
- ];
- return response()->json($res, 200, [], JSON_UNESCAPED_SLASHES);
- }
- public function getUserStreamAsGuest(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- $stream = LiveStream::whereProfileId($request->input('profile_id'))
- ->whereVisibility('public')
- ->whereNotNull('live_at')
- ->orderByDesc('live_at')
- ->first();
- if(!$stream) {
- return [];
- }
- $res = [];
- $res = [
- 'hls_url' => $stream->getHlsUrl(),
- 'name' => $stream->name,
- 'description' => $stream->description
- ];
- return response()->json($res, 200, [], JSON_UNESCAPED_SLASHES);
- }
- public function showProfilePlayer(Request $request, $username)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- $user = User::whereUsername($username)->firstOrFail();
- $id = (string) $user->profile_id;
- $stream = LiveStream::whereProfileId($id)
- ->whereNotNull('live_at')
- ->first();
- abort_if(!$request->user() && $stream && $stream->visibility !== 'public', 404);
- return view('live.player', compact('id'));
- }
- public function deleteStream(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- LiveStream::whereProfileId($request->user()->profile_id)
- ->get()
- ->each(function($stream) {
- Storage::deleteDirectory("public/live-hls/{$stream->stream_id}");
- LiveStreamService::clearChat($stream->profile_id);
- StreamEnd::dispatch($stream->profile_id);
- $stream->delete();
- });
- return [200];
- }
- public function getActiveStreams(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- return LiveStream::whereIn('visibility', ['local', 'public'])->whereNotNull('live_at')->get()->map(function($stream) {
- return [
- 'account' => AccountService::get($stream->profile_id),
- 'stream_id' => $stream->stream_id
- ];
- });
- }
- public function getLatestChat(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $stream = LiveStream::whereProfileId($request->input('profile_id'))
- ->whereNotNull('live_at')
- ->first();
- if(!$stream) {
- return [];
- }
- $owner = $stream->profile_id == $request->user()->profile_id;
- if($stream->visibility === 'private') {
- abort_if(!$owner && !FollowerService::follows($request->user()->profile_id, $stream->profile_id), 403, 'LSE:021');
- }
- $res = collect(LiveStreamService::getComments($stream->profile_id))
- ->map(function($res) {
- return json_decode($res);
- });
- return $res;
- }
- public function addChatComment(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'profile_id' => 'required|exists:profiles,id',
- 'message' => 'required|max:140'
- ]);
- $stream = LiveStream::whereProfileId($request->input('profile_id'))
- ->whereNotNull('live_at')
- ->firstOrFail();
- $owner = $stream->profile_id == $request->user()->profile_id;
- if($stream->visibility === 'private') {
- abort_if(!$owner && !FollowerService::follows($request->user()->profile_id, $stream->profile_id), 403);
- }
- $user = AccountService::get($request->user()->profile_id);
- abort_if(!$user, 422);
- $res = [
- 'id' => (string) Str::uuid(),
- 'pid' => (string) $request->user()->profile_id,
- 'avatar' => $user['avatar'],
- 'username' => $user['username'],
- 'text' => $request->input('message'),
- 'ts' => now()->timestamp
- ];
- LiveStreamService::addComment($stream->profile_id, json_encode($res, JSON_UNESCAPED_SLASHES));
- NewChatComment::dispatch($stream, $res);
- return $res;
- }
- public function editStream(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'name' => 'nullable|string|max:80',
- 'description' => 'nullable|string|max:240'
- ]);
- $stream = LiveStream::whereProfileId($request->user()->profile_id)->firstOrFail();
- $stream->name = $request->input('name');
- $stream->description = $request->input('description');
- $stream->save();
- return;
- }
- public function deleteChatComment(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'profile_id' => 'required|exists:profiles,id',
- 'message' => 'required'
- ]);
- $uid = $request->user()->profile_id;
- $pid = $request->input('profile_id');
- $msg = $request->input('message');
- $admin = $uid == $request->input('profile_id');
- $owner = $uid == $msg['pid'];
- abort_if(!$admin && !$owner, 403);
- $stream = LiveStream::whereProfileId($pid)->firstOrFail();
- $payload = $request->input('message');
- broadcast(new DeleteChatComment($stream, $payload))->toOthers();
- $payload = json_encode($payload, JSON_UNESCAPED_SLASHES);
- LiveStreamService::deleteComment($stream->profile_id, $payload);
- return;
- }
- public function banChatUser(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'profile_id' => 'required|exists:profiles,id',
- ]);
- abort_if($request->user()->profile_id == $request->input('profile_id'), 403);
- $stream = LiveStream::whereProfileId($request->user()->profile_id)->firstOrFail();
- $pid = $request->input('profile_id');
- BanUser::dispatch($stream, $pid);
- return;
- }
- public function pinChatComment(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'profile_id' => 'required|exists:profiles,id',
- 'message' => 'required'
- ]);
- $uid = $request->user()->profile_id;
- $pid = $request->input('profile_id');
- $msg = $request->input('message');
- abort_if($uid != $pid, 403);
- $stream = LiveStream::whereProfileId($request->user()->profile_id)->firstOrFail();
- PinChatMessage::dispatch($stream, $msg);
- return;
- }
- public function unpinChatComment(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $this->validate($request, [
- 'profile_id' => 'required|exists:profiles,id',
- 'message' => 'required'
- ]);
- $uid = $request->user()->profile_id;
- $pid = $request->input('profile_id');
- $msg = $request->input('message');
- abort_if($uid != $pid, 403);
- $stream = LiveStream::whereProfileId($request->user()->profile_id)->firstOrFail();
- UnpinChatMessage::dispatch($stream, $msg);
- return;
- }
- public function getConfig(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->user(), 403);
- $res = [
- 'enabled' => config('livestreaming.enabled'),
- 'broadcast' => [
- 'sources' => config('livestreaming.broadcast.sources'),
- 'limits' => config('livestreaming.broadcast.limits')
- ],
- ];
- return response()->json($res, 200, [], JSON_UNESCAPED_SLASHES);
- }
- public function clientBroadcastPublish(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- $key = $request->input('name');
- $name = $request->input('name');
- abort_if(!$name, 400);
- if(empty($key)) {
- abort_if(!$request->filled('tcurl'), 400);
- $url = $this->parseStreamUrl($request->input('tcurl'));
- $key = $request->filled('name') ? $request->input('name') : $url['name'];
- }
- $token = substr($name, 0, 10) === 'streamkey-';
- if($token) {
- $stream = LiveStream::whereStreamKey($key)->firstOrFail();
- return redirect($stream->getStreamRtmpUrl(), 301);
- } else {
- $stream = LiveStream::whereStreamId($key)->firstOrFail();
- }
- if($request->filled('name') && $token == false) {
- $stream->live_at = now();
- $stream->save();
- StreamStart::dispatch($stream->profile_id);
- return [];
- } else {
- abort(400);
- }
- abort(400);
- }
- public function clientBroadcastFinish(Request $request)
- {
- abort_if(!config('livestreaming.enabled'), 400);
- abort_if(!$request->filled('tcurl'), 400);
- $url = $this->parseStreamUrl($request->input('tcurl'));
- $name = $url['name'] ?? $request->input('name');
- $stream = LiveStream::whereStreamId($name)->whereStreamKey($url['key'])->firstOrFail();
- StreamEnd::dispatch($stream->profile_id);
- LiveStreamService::clearChat($stream->profile_id);
- if(config('livestreaming.broadcast.delete_token_after_finished')) {
- $stream->delete();
- } else {
- $stream->live_at = null;
- $stream->save();
- }
- return [];
- }
- protected function parseStreamUrl($url)
- {
- $name = null;
- $key = null;
- $query = parse_url($url, PHP_URL_QUERY);
- $parts = explode('&', $query);
- foreach($parts as $part) {
- if (!strlen(trim($part))) {
- continue;
- }
- $s = explode('=', $part);
- if(in_array($s[0], ['name', 'key'])) {
- if($s[0] === 'name') {
- $name = $s[1];
- }
- if($s[0] === 'key') {
- $key = $s[1];
- }
- }
- }
- return ['name' => $name, 'key' => $key];
- }
- }
|