mirror of
https://code.castopod.org/adaures/castopod
synced 2025-06-06 18:31:05 +00:00
5182d5d67a
This removes computing latency when retrieving episodes list with download count in admin. The more analytics records, the more it took to calculate the sum of hits to get the downloads count for each episode.
1054 lines
36 KiB
PHP
1054 lines
36 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
/**
|
|
* @copyright 2020 Ad Aures
|
|
* @license https://www.gnu.org/licenses/agpl-3.0.en.html AGPL3
|
|
* @link https://castopod.org/
|
|
*/
|
|
|
|
namespace Modules\Admin\Controllers;
|
|
|
|
use App\Entities\Episode;
|
|
use App\Entities\EpisodeComment;
|
|
use App\Entities\Location;
|
|
use App\Entities\Podcast;
|
|
use App\Entities\Post;
|
|
use App\Models\EpisodeCommentModel;
|
|
use App\Models\EpisodeModel;
|
|
use App\Models\PodcastModel;
|
|
use App\Models\PostModel;
|
|
use CodeIgniter\Exceptions\PageNotFoundException;
|
|
use CodeIgniter\HTTP\Files\UploadedFile;
|
|
use CodeIgniter\HTTP\RedirectResponse;
|
|
use CodeIgniter\I18n\Time;
|
|
use Modules\Media\Entities\Chapters;
|
|
use Modules\Media\Entities\Transcript;
|
|
use Modules\Media\Models\MediaModel;
|
|
|
|
class EpisodeController extends BaseController
|
|
{
|
|
protected Podcast $podcast;
|
|
|
|
protected Episode $episode;
|
|
|
|
public function _remap(string $method, string ...$params): mixed
|
|
{
|
|
if (
|
|
! ($podcast = (new PodcastModel())->getPodcastById((int) $params[0])) instanceof Podcast
|
|
) {
|
|
throw PageNotFoundException::forPageNotFound();
|
|
}
|
|
|
|
$this->podcast = $podcast;
|
|
|
|
if (count($params) > 1) {
|
|
if (
|
|
! ($episode = (new EpisodeModel())
|
|
->where([
|
|
'id' => $params[1],
|
|
'podcast_id' => $params[0],
|
|
])
|
|
->first()) instanceof Episode
|
|
) {
|
|
throw PageNotFoundException::forPageNotFound();
|
|
}
|
|
|
|
$this->episode = $episode;
|
|
|
|
unset($params[1]);
|
|
unset($params[0]);
|
|
}
|
|
|
|
return $this->{$method}(...$params);
|
|
}
|
|
|
|
public function list(): string
|
|
{
|
|
/** @var ?string $query */
|
|
$query = $this->request->getGet('q');
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if ($query !== null && $query !== '') {
|
|
// Default value for MySQL Full-Text Search's minimum length of words is 4.
|
|
// Use LIKE operator as a fallback.
|
|
if (strlen($query) < 4) {
|
|
$episodes = $episodeModel
|
|
->where('podcast_id', $this->podcast->id)
|
|
->like('title', $episodeModel->db->escapeLikeString($query))
|
|
->orLike('description_markdown', $episodeModel->db->escapeLikeString($query))
|
|
->orLike('slug', $episodeModel->db->escapeLikeString($query))
|
|
->orLike('location_name', $episodeModel->db->escapeLikeString($query))
|
|
->orderBy('-`published_at`', '', false)
|
|
->orderBy('created_at', 'desc');
|
|
} else {
|
|
$episodes = $episodeModel
|
|
->where('podcast_id', $this->podcast->id)
|
|
->where(
|
|
"MATCH (title, description_markdown, slug, location_name) AGAINST ('{$episodeModel->db->escapeString(
|
|
$query
|
|
)}')"
|
|
);
|
|
}
|
|
} else {
|
|
$episodes = $episodeModel
|
|
->where('podcast_id', $this->podcast->id)
|
|
->orderBy('-`published_at`', '', false)
|
|
->orderBy('created_at', 'desc');
|
|
}
|
|
|
|
helper('form');
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episodes' => $episodes->paginate(10),
|
|
'pager' => $episodes->pager,
|
|
'query' => $query,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
]);
|
|
return view('episode/list', $data);
|
|
}
|
|
|
|
public function view(): string
|
|
{
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/view', $data);
|
|
}
|
|
|
|
public function create(): string
|
|
{
|
|
helper(['form']);
|
|
|
|
$currentSeasonNumber = (new EpisodeModel())->getCurrentSeasonNumber($this->podcast->id);
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'currentSeasonNumber' => $currentSeasonNumber,
|
|
'nextEpisodeNumber' => (new EpisodeModel())->getNextEpisodeNumber(
|
|
$this->podcast->id,
|
|
$currentSeasonNumber
|
|
),
|
|
];
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
]);
|
|
return view('episode/create', $data);
|
|
}
|
|
|
|
public function attemptCreate(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'title' => 'required',
|
|
'slug' => 'required|max_length[128]',
|
|
'audio_file' => 'uploaded[audio_file]|ext_in[audio_file,mp3,m4a]',
|
|
'cover' => 'is_image[cover]|ext_in[cover,jpg,jpeg,png]|min_dims[cover,1400,1400]|is_image_ratio[cover,1,1]',
|
|
'transcript_file' => 'ext_in[transcript_file,srt,vtt]',
|
|
'chapters_file' => 'ext_in[chapters_file,json]|is_json[chapters_file]',
|
|
];
|
|
|
|
if ($this->podcast->type === 'serial' && $this->request->getPost('type') === 'full') {
|
|
$rules['episode_number'] = 'required';
|
|
}
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$validData = $this->validator->getValidated();
|
|
|
|
if ((new EpisodeModel())
|
|
->where([
|
|
'slug' => $validData['slug'],
|
|
'podcast_id' => $this->podcast->id,
|
|
])
|
|
->first() instanceof Episode) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.messages.sameSlugError'));
|
|
}
|
|
|
|
$db = db_connect();
|
|
$db->transStart();
|
|
|
|
$newEpisode = new Episode([
|
|
'created_by' => user_id(),
|
|
'updated_by' => user_id(),
|
|
'podcast_id' => $this->podcast->id,
|
|
'title' => $this->request->getPost('title'),
|
|
'slug' => $this->request->getPost('slug'),
|
|
'guid' => null,
|
|
'audio' => $this->request->getFile('audio_file'),
|
|
'cover' => $this->request->getFile('cover'),
|
|
'description_markdown' => $this->request->getPost('description'),
|
|
'location' => $this->request->getPost('location_name') === '' ? null : new Location(
|
|
$this->request->getPost('location_name')
|
|
),
|
|
'transcript' => $this->request->getFile('transcript'),
|
|
'chapters' => $this->request->getFile('chapters'),
|
|
'parental_advisory' => $this->request->getPost('parental_advisory') !== 'undefined'
|
|
? $this->request->getPost('parental_advisory')
|
|
: null,
|
|
'number' => $this->request->getPost('episode_number')
|
|
? (int) $this->request->getPost('episode_number')
|
|
: null,
|
|
'season_number' => $this->request->getPost('season_number')
|
|
? (int) $this->request->getPost('season_number')
|
|
: null,
|
|
'type' => $this->request->getPost('type'),
|
|
'is_blocked' => $this->request->getPost('block') === 'yes',
|
|
'custom_rss_string' => $this->request->getPost('custom_rss'),
|
|
'is_premium' => $this->request->getPost('premium') === 'yes',
|
|
'published_at' => null,
|
|
]);
|
|
|
|
$transcriptChoice = $this->request->getPost('transcript-choice');
|
|
if ($transcriptChoice === 'upload-file') {
|
|
$newEpisode->setTranscript($this->request->getFile('transcript_file'));
|
|
} elseif ($transcriptChoice === 'remote-url') {
|
|
$newEpisode->transcript_remote_url = $this->request->getPost(
|
|
'transcript_remote_url'
|
|
) === '' ? null : $this->request->getPost('transcript_remote_url');
|
|
}
|
|
|
|
$chaptersChoice = $this->request->getPost('chapters-choice');
|
|
if ($chaptersChoice === 'upload-file') {
|
|
$newEpisode->setChapters($this->request->getFile('chapters_file'));
|
|
} elseif ($chaptersChoice === 'remote-url') {
|
|
$newEpisode->chapters_remote_url = $this->request->getPost(
|
|
'chapters_remote_url'
|
|
) === '' ? null : $this->request->getPost('chapters_remote_url');
|
|
}
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! ($newEpisodeId = $episodeModel->insert($newEpisode, true))) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
// update podcast's episode_description_footer_markdown if changed
|
|
$this->podcast->episode_description_footer_markdown = $this->request->getPost(
|
|
'description_footer'
|
|
) === '' ? null : $this->request->getPost('description_footer');
|
|
|
|
if ($this->podcast->hasChanged('episode_description_footer_markdown')) {
|
|
$podcastModel = new PodcastModel();
|
|
|
|
if (! $podcastModel->update($this->podcast->id, $this->podcast)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $podcastModel->errors());
|
|
}
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $newEpisodeId])->with(
|
|
'message',
|
|
lang('Episode.messages.createSuccess')
|
|
);
|
|
}
|
|
|
|
public function edit(): string
|
|
{
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/edit', $data);
|
|
}
|
|
|
|
public function attemptEdit(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'title' => 'required',
|
|
'slug' => 'required|max_length[128]',
|
|
'audio_file' => 'ext_in[audio_file,mp3,m4a]',
|
|
'cover' => 'is_image[cover]|ext_in[cover,jpg,jpeg,png]|min_dims[cover,1400,1400]|is_image_ratio[cover,1,1]',
|
|
'transcript_file' => 'ext_in[transcript_file,srt,vtt]',
|
|
'chapters_file' => 'ext_in[chapters_file,json]|is_json[chapters_file]',
|
|
];
|
|
|
|
if ($this->podcast->type === 'serial' && $this->request->getPost('type') === 'full') {
|
|
$rules['episode_number'] = 'required';
|
|
}
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$validData = $this->validator->getValidated();
|
|
|
|
$this->episode->title = $this->request->getPost('title');
|
|
$this->episode->slug = $validData['slug'];
|
|
$this->episode->description_markdown = $this->request->getPost('description');
|
|
$this->episode->location = $this->request->getPost('location_name') === '' ? null : new Location(
|
|
$this->request->getPost('location_name')
|
|
);
|
|
$this->episode->parental_advisory =
|
|
$this->request->getPost('parental_advisory') !== 'undefined'
|
|
? $this->request->getPost('parental_advisory')
|
|
: null;
|
|
$this->episode->number = $this->request->getPost('episode_number') ?: null;
|
|
$this->episode->season_number = $this->request->getPost('season_number') ?: null;
|
|
$this->episode->type = $this->request->getPost('type');
|
|
$this->episode->is_blocked = $this->request->getPost('block') === 'yes';
|
|
$this->episode->custom_rss_string = $this->request->getPost('custom_rss');
|
|
$this->episode->is_premium = $this->request->getPost('premium') === 'yes';
|
|
|
|
$this->episode->updated_by = (int) user_id();
|
|
$this->episode->setAudio($this->request->getFile('audio_file'));
|
|
$this->episode->setCover($this->request->getFile('cover'));
|
|
|
|
// republish on websub hubs upon edit
|
|
$this->episode->is_published_on_hubs = false;
|
|
|
|
$transcriptChoice = $this->request->getPost('transcript-choice');
|
|
if ($transcriptChoice === 'upload-file') {
|
|
$transcriptFile = $this->request->getFile('transcript_file');
|
|
if ($transcriptFile instanceof UploadedFile && $transcriptFile->isValid()) {
|
|
$this->episode->setTranscript($transcriptFile);
|
|
$this->episode->transcript_remote_url = null;
|
|
}
|
|
} elseif ($transcriptChoice === 'remote-url') {
|
|
if (
|
|
($transcriptRemoteUrl = $this->request->getPost('transcript_remote_url')) &&
|
|
(($transcriptFile = $this->episode->transcript_id) !== null)
|
|
) {
|
|
(new MediaModel())->deleteMedia($this->episode->transcript);
|
|
}
|
|
|
|
$this->episode->transcript_remote_url = $transcriptRemoteUrl === '' ? null : $transcriptRemoteUrl;
|
|
}
|
|
|
|
$chaptersChoice = $this->request->getPost('chapters-choice');
|
|
if ($chaptersChoice === 'upload-file') {
|
|
$chaptersFile = $this->request->getFile('chapters_file');
|
|
if ($chaptersFile instanceof UploadedFile && $chaptersFile->isValid()) {
|
|
$this->episode->setChapters($chaptersFile);
|
|
$this->episode->chapters_remote_url = null;
|
|
}
|
|
} elseif ($chaptersChoice === 'remote-url') {
|
|
if (
|
|
($chaptersRemoteUrl = $this->request->getPost('chapters_remote_url')) &&
|
|
(($chaptersFile = $this->episode->chapters) instanceof Chapters)
|
|
) {
|
|
(new MediaModel())->deleteMedia($this->episode->chapters);
|
|
}
|
|
|
|
$this->episode->chapters_remote_url = $chaptersRemoteUrl === '' ? null : $chaptersRemoteUrl;
|
|
}
|
|
|
|
$db = db_connect();
|
|
$db->transStart();
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
$db->transRollback();
|
|
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
// update podcast's episode_description_footer_markdown if changed
|
|
$this->podcast->episode_description_footer_markdown = $this->request->getPost(
|
|
'description_footer'
|
|
) === '' ? null : $this->request->getPost('description_footer');
|
|
|
|
if ($this->podcast->hasChanged('episode_description_footer_markdown')) {
|
|
$podcastModel = new PodcastModel();
|
|
if (! $podcastModel->update($this->podcast->id, $this->podcast)) {
|
|
$db->transRollback();
|
|
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $podcastModel->errors());
|
|
}
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-edit', [$this->podcast->id, $this->episode->id])->with(
|
|
'message',
|
|
lang('Episode.messages.editSuccess')
|
|
);
|
|
}
|
|
|
|
public function transcriptDelete(): RedirectResponse
|
|
{
|
|
if (! $this->episode->transcript instanceof Transcript) {
|
|
return redirect()->back();
|
|
}
|
|
|
|
$mediaModel = new MediaModel();
|
|
if (! $mediaModel->deleteMedia($this->episode->transcript)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $mediaModel->errors());
|
|
}
|
|
|
|
return redirect()->back();
|
|
}
|
|
|
|
public function chaptersDelete(): RedirectResponse
|
|
{
|
|
if (! $this->episode->chapters instanceof Chapters) {
|
|
return redirect()->back();
|
|
}
|
|
|
|
$mediaModel = new MediaModel();
|
|
if (! $mediaModel->deleteMedia($this->episode->chapters)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $mediaModel->errors());
|
|
}
|
|
|
|
return redirect()->back();
|
|
}
|
|
|
|
public function publish(): string | RedirectResponse
|
|
{
|
|
if ($this->episode->publication_status === 'not_published') {
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/publish', $data);
|
|
}
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'error',
|
|
lang('Episode.publish_error')
|
|
);
|
|
}
|
|
|
|
public function attemptPublish(): RedirectResponse
|
|
{
|
|
if ($this->podcast->publication_status === 'published') {
|
|
$rules = [
|
|
'publication_method' => 'required',
|
|
'scheduled_publication_date' => 'valid_date[Y-m-d H:i]|permit_empty',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
}
|
|
|
|
$db = db_connect();
|
|
$db->transStart();
|
|
|
|
$newPost = new Post([
|
|
'actor_id' => $this->podcast->actor_id,
|
|
'episode_id' => $this->episode->id,
|
|
'message' => $this->request->getPost('message'),
|
|
'created_by' => user_id(),
|
|
]);
|
|
|
|
if ($this->podcast->publication_status === 'published') {
|
|
$publishMethod = $this->request->getPost('publication_method');
|
|
if ($publishMethod === 'schedule') {
|
|
$scheduledPublicationDate = $this->request->getPost('scheduled_publication_date');
|
|
if ($scheduledPublicationDate) {
|
|
$this->episode->published_at = Time::createFromFormat(
|
|
'Y-m-d H:i',
|
|
$scheduledPublicationDate,
|
|
$this->request->getPost('client_timezone'),
|
|
)->setTimezone(app_timezone());
|
|
} else {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.messages.scheduleDateError'));
|
|
}
|
|
} else {
|
|
$this->episode->published_at = Time::now();
|
|
}
|
|
} elseif ($this->podcast->publication_status === 'scheduled') {
|
|
// podcast publication date has already been set
|
|
$this->episode->published_at = $this->podcast->published_at->addSeconds(1);
|
|
} else {
|
|
$this->episode->published_at = Time::now();
|
|
}
|
|
|
|
$newPost->published_at = $this->episode->published_at;
|
|
|
|
$postModel = new PostModel();
|
|
if (! $postModel->addPost($newPost)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $postModel->errors());
|
|
}
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'message',
|
|
lang('Episode.messages.publishSuccess', [
|
|
'publication_status' => $this->episode->publication_status,
|
|
])
|
|
);
|
|
}
|
|
|
|
public function publishEdit(): string | RedirectResponse
|
|
{
|
|
if (in_array($this->episode->publication_status, ['scheduled', 'with_podcast'], true)) {
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
'post' => (new PostModel())
|
|
->where([
|
|
'actor_id' => $this->podcast->actor_id,
|
|
'episode_id' => $this->episode->id,
|
|
])
|
|
->first(),
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/publish_edit', $data);
|
|
}
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'error',
|
|
lang('Episode.publish_edit_error')
|
|
);
|
|
}
|
|
|
|
public function attemptPublishEdit(): RedirectResponse
|
|
{
|
|
if ($this->podcast->publication_status === 'published') {
|
|
$rules = [
|
|
'post_id' => 'required',
|
|
'publication_method' => 'required',
|
|
'scheduled_publication_date' => 'valid_date[Y-m-d H:i]|permit_empty',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
}
|
|
|
|
$db = db_connect();
|
|
$db->transStart();
|
|
|
|
if ($this->podcast->publication_status === 'published') {
|
|
$publishMethod = $this->request->getPost('publication_method');
|
|
if ($publishMethod === 'schedule') {
|
|
$scheduledPublicationDate = $this->request->getPost('scheduled_publication_date');
|
|
if ($scheduledPublicationDate) {
|
|
$this->episode->published_at = Time::createFromFormat(
|
|
'Y-m-d H:i',
|
|
$scheduledPublicationDate,
|
|
$this->request->getPost('client_timezone'),
|
|
)->setTimezone(app_timezone());
|
|
} else {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.messages.scheduleDateError'));
|
|
}
|
|
} else {
|
|
$this->episode->published_at = Time::now();
|
|
}
|
|
} elseif ($this->podcast->publication_status === 'scheduled') {
|
|
// podcast publication date has already been set
|
|
$this->episode->published_at = $this->podcast->published_at->addSeconds(1);
|
|
} else {
|
|
$this->episode->published_at = Time::now();
|
|
}
|
|
|
|
$post = (new PostModel())->getPostById($this->request->getPost('post_id'));
|
|
|
|
if ($post instanceof Post) {
|
|
$post->message = $this->request->getPost('message');
|
|
$post->published_at = $this->episode->published_at;
|
|
|
|
$postModel = new PostModel();
|
|
if (! $postModel->editPost($post)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $postModel->errors());
|
|
}
|
|
}
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'message',
|
|
lang('Episode.messages.publishSuccess', [
|
|
'publication_status' => $this->episode->publication_status,
|
|
])
|
|
);
|
|
}
|
|
|
|
public function publishCancel(): RedirectResponse
|
|
{
|
|
if (in_array($this->episode->publication_status, ['scheduled', 'with_podcast'], true)) {
|
|
$db = db_connect();
|
|
$db->transStart();
|
|
|
|
$postModel = new PostModel();
|
|
$post = $postModel
|
|
->where([
|
|
'actor_id' => $this->podcast->actor_id,
|
|
'episode_id' => $this->episode->id,
|
|
])
|
|
->first();
|
|
$postModel->removePost($post);
|
|
|
|
$this->episode->published_at = null;
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'message',
|
|
lang('Episode.messages.publishCancelSuccess')
|
|
);
|
|
}
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id]);
|
|
}
|
|
|
|
public function publishDateEdit(): string|RedirectResponse
|
|
{
|
|
// only accessible if episode is already published
|
|
if ($this->episode->publication_status !== 'published') {
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'error',
|
|
lang('Episode.publish_date_edit_error')
|
|
);
|
|
}
|
|
|
|
helper('form');
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->title,
|
|
1 => $this->episode->title,
|
|
]);
|
|
|
|
return view('episode/publish_date_edit', $data);
|
|
}
|
|
|
|
/**
|
|
* Allows to set an episode's publication date to a past date
|
|
*
|
|
* Prevents setting a future date as it does not make sense to set a future published date to an already published
|
|
* episode. This also prevents any side-effects from occurring.
|
|
*/
|
|
public function attemptPublishDateEdit(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'new_publication_date' => 'valid_date[Y-m-d H:i]',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$validData = $this->validator->getValidated();
|
|
|
|
$newPublicationDate = $validData['new_publication_date'];
|
|
|
|
$newPublicationDate = Time::createFromFormat(
|
|
'Y-m-d H:i',
|
|
$newPublicationDate,
|
|
$this->request->getPost('client_timezone'),
|
|
)->setTimezone(app_timezone());
|
|
|
|
if ($newPublicationDate->isAfter(Time::now())) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.publish_date_edit_future_error'));
|
|
}
|
|
|
|
$this->episode->published_at = $newPublicationDate;
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'message',
|
|
lang('Episode.publish_date_edit_success')
|
|
);
|
|
}
|
|
|
|
public function unpublish(): string | RedirectResponse
|
|
{
|
|
if ($this->episode->publication_status !== 'published') {
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id])->with(
|
|
'error',
|
|
lang('Episode.unpublish_error')
|
|
);
|
|
}
|
|
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->title,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/unpublish', $data);
|
|
}
|
|
|
|
public function attemptUnpublish(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'understand' => 'required',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$db = db_connect();
|
|
|
|
$db->transStart();
|
|
|
|
$allPostsLinkedToEpisode = (new PostModel())
|
|
->where([
|
|
'episode_id' => $this->episode->id,
|
|
'in_reply_to_id' => null,
|
|
'reblog_of_id' => null,
|
|
])
|
|
->findAll();
|
|
foreach ($allPostsLinkedToEpisode as $post) {
|
|
(new PostModel())->removePost($post);
|
|
}
|
|
|
|
$allCommentsLinkedToEpisode = (new EpisodeCommentModel())
|
|
->where([
|
|
'episode_id' => $this->episode->id,
|
|
'in_reply_to_id' => null,
|
|
])
|
|
->findAll();
|
|
foreach ($allCommentsLinkedToEpisode as $comment) {
|
|
(new EpisodeCommentModel())->removeComment($comment);
|
|
}
|
|
|
|
// set episode published_at to null to unpublish
|
|
$this->episode->published_at = null;
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
if (! $episodeModel->update($this->episode->id, $this->episode)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
// set podcast is_published_on_hubs to false to trigger websub push
|
|
(new PodcastModel())->update($this->episode->podcast->id, [
|
|
'is_published_on_hubs' => 0,
|
|
]);
|
|
|
|
$db->transComplete();
|
|
|
|
return redirect()->route('episode-view', [$this->podcast->id, $this->episode->id]);
|
|
}
|
|
|
|
public function delete(): string
|
|
{
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/delete', $data);
|
|
}
|
|
|
|
public function attemptDelete(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'understand' => 'required',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
if ($this->episode->published_at instanceof Time) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.messages.deletePublishedEpisodeError'));
|
|
}
|
|
|
|
$db = db_connect();
|
|
|
|
$db->transStart();
|
|
|
|
$episodeModel = new EpisodeModel();
|
|
|
|
if (! $episodeModel->delete($this->episode->id)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $episodeModel->errors());
|
|
}
|
|
|
|
$episodeMediaList = [$this->episode->transcript, $this->episode->chapters, $this->episode->audio];
|
|
|
|
//only delete episode cover if different from podcast's
|
|
if ($this->episode->cover_id !== null) {
|
|
$episodeMediaList[] = $this->episode->cover;
|
|
}
|
|
|
|
$mediaModel = new MediaModel();
|
|
|
|
//delete episode media records from database
|
|
foreach ($episodeMediaList as $episodeMedia) {
|
|
if ($episodeMedia !== null && ! $mediaModel->delete($episodeMedia->id)) {
|
|
$db->transRollback();
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('error', lang('Episode.messages.deleteError', [
|
|
'type' => $episodeMedia->type,
|
|
]));
|
|
}
|
|
}
|
|
|
|
$db->transComplete();
|
|
|
|
$warnings = [];
|
|
|
|
//remove episode media files from disk
|
|
foreach ($episodeMediaList as $episodeMedia) {
|
|
if ($episodeMedia === null) {
|
|
continue;
|
|
}
|
|
|
|
if ($episodeMedia->deleteFile()) {
|
|
continue;
|
|
}
|
|
|
|
$warnings[] = lang('Episode.messages.deleteFileError', [
|
|
'type' => $episodeMedia->type,
|
|
'file_key' => $episodeMedia->file_key,
|
|
]);
|
|
}
|
|
|
|
if ($warnings !== []) {
|
|
return redirect()
|
|
->route('episode-list', [$this->podcast->id])
|
|
->with('message', lang('Episode.messages.deleteSuccess'))
|
|
->with('warnings', $warnings);
|
|
}
|
|
|
|
return redirect()->route('episode-list', [$this->podcast->id])->with(
|
|
'message',
|
|
lang('Episode.messages.deleteSuccess')
|
|
);
|
|
}
|
|
|
|
public function embed(): string
|
|
{
|
|
helper(['form']);
|
|
|
|
$data = [
|
|
'podcast' => $this->podcast,
|
|
'episode' => $this->episode,
|
|
'themes' => EpisodeModel::$themes,
|
|
];
|
|
|
|
replace_breadcrumb_params([
|
|
0 => $this->podcast->at_handle,
|
|
1 => $this->episode->title,
|
|
]);
|
|
return view('episode/embed', $data);
|
|
}
|
|
|
|
public function attemptCommentCreate(): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'message' => 'required|max_length[500]',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$validData = $this->validator->getValidated();
|
|
|
|
$newComment = new EpisodeComment([
|
|
'actor_id' => interact_as_actor_id(),
|
|
'episode_id' => $this->episode->id,
|
|
'message' => $validData['message'],
|
|
'created_at' => new Time('now'),
|
|
'created_by' => user_id(),
|
|
]);
|
|
|
|
$commentModel = new EpisodeCommentModel();
|
|
if (
|
|
! $commentModel->addComment($newComment, true)
|
|
) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $commentModel->errors());
|
|
}
|
|
|
|
// Comment has been successfully created
|
|
return redirect()->back();
|
|
}
|
|
|
|
public function attemptCommentReply(string $commentId): RedirectResponse
|
|
{
|
|
$rules = [
|
|
'message' => 'required|max_length[500]',
|
|
];
|
|
|
|
if (! $this->validate($rules)) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $this->validator->getErrors());
|
|
}
|
|
|
|
$validData = $this->validator->getValidated();
|
|
|
|
$newReply = new EpisodeComment([
|
|
'actor_id' => interact_as_actor_id(),
|
|
'episode_id' => $this->episode->id,
|
|
'message' => $validData['message'],
|
|
'in_reply_to_id' => $commentId,
|
|
'created_at' => new Time('now'),
|
|
'created_by' => user_id(),
|
|
]);
|
|
|
|
$commentModel = new EpisodeCommentModel();
|
|
if (
|
|
! $commentModel->addComment($newReply, true)
|
|
) {
|
|
return redirect()
|
|
->back()
|
|
->withInput()
|
|
->with('errors', $commentModel->errors());
|
|
}
|
|
|
|
// Reply has been successfully created
|
|
return redirect()->back();
|
|
}
|
|
}
|