feat(rclone): rclone yükleme durumunu güncelle
Dosyaların GDrive'a taşınması sırasında yükleme durumunu izler ve durum güncellemelerini yayınlar.
This commit is contained in:
@@ -2087,7 +2087,8 @@ async function finalizeYoutubeJob(job, exitCode) {
|
|||||||
startRcloneStatsPolling();
|
startRcloneStatsPolling();
|
||||||
const moveResult = await moveRootFolderToGdrive(job.folderId);
|
const moveResult = await moveRootFolderToGdrive(job.folderId);
|
||||||
if (moveResult.ok) {
|
if (moveResult.ok) {
|
||||||
// Upload tamamlanma durumu RC stats ile belirlenecek
|
job.moveStatus = "uploading";
|
||||||
|
scheduleSnapshotBroadcast();
|
||||||
} else {
|
} else {
|
||||||
job.moveStatus = "error";
|
job.moveStatus = "error";
|
||||||
job.moveError = moveResult.error || "GDrive taşıma hatası";
|
job.moveError = moveResult.error || "GDrive taşıma hatası";
|
||||||
@@ -2433,7 +2434,8 @@ async function finalizeMailRuJob(job, exitCode) {
|
|||||||
startRcloneStatsPolling();
|
startRcloneStatsPolling();
|
||||||
const moveResult = await movePathToGdrive(relPath);
|
const moveResult = await movePathToGdrive(relPath);
|
||||||
if (moveResult.ok) {
|
if (moveResult.ok) {
|
||||||
// Upload tamamlanma durumu RC stats ile belirlenecek
|
job.moveStatus = "uploading";
|
||||||
|
scheduleSnapshotBroadcast();
|
||||||
} else {
|
} else {
|
||||||
job.moveStatus = "error";
|
job.moveStatus = "error";
|
||||||
job.moveError = moveResult.error || "GDrive taşıma hatası";
|
job.moveError = moveResult.error || "GDrive taşıma hatası";
|
||||||
@@ -7279,7 +7281,8 @@ async function onTorrentDone({ torrent }) {
|
|||||||
startRcloneStatsPolling();
|
startRcloneStatsPolling();
|
||||||
const moveResult = await moveRootFolderToGdrive(rootFolder);
|
const moveResult = await moveRootFolderToGdrive(rootFolder);
|
||||||
if (moveResult.ok) {
|
if (moveResult.ok) {
|
||||||
// Upload tamamlanma durumu RC stats ile belirlenecek
|
entry.moveStatus = "uploading";
|
||||||
|
scheduleSnapshotBroadcast();
|
||||||
} else {
|
} else {
|
||||||
entry.moveStatus = "error";
|
entry.moveStatus = "error";
|
||||||
entry.moveError = moveResult.error || "GDrive taşıma hatası";
|
entry.moveError = moveResult.error || "GDrive taşıma hatası";
|
||||||
|
|||||||
Reference in New Issue
Block a user