Skip to content

fix: fixed premiumize connect #92

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Nat3z merged 1 commit into from
Mar 2, 2026
Merged

fix: fixed premiumize connect #92

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
340 changes: 183 additions & 157 deletions application/src/frontend/lib/downloads/services/PremiumizeService.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import { currentDownloads } from '../../../store';
import {
getConfigClientOption,
getDownloadPath,
Expand All @@ -19,7 +20,13 @@ type PremiumizeFolderContentItem = {
id: string;
name: string;
type: string;
size?: number;
created_at: number;
mime_type?: string;
transcode_status?: string;
link?: string;
stream_link?: string;
virus_scan?: string;
};

type PremiumizeErrorResponse = {
Expand All @@ -34,7 +41,8 @@ type PremiumizeFolderResponse =
content: PremiumizeFolderContentItem[];
name: string;
parent_id: string;
folder_id: string;
breadcrumbs: string;
folder_id?: string;
};

type PremiumizeTransferResponse =
Expand Down Expand Up @@ -88,192 +96,210 @@ export class PremiumizeService extends BaseService {
htmlButton.disabled = true;
}

const tempId = this.queueRequestDownload(result, appID, 'premiumize');
try {
console.log('PremiumizeService startDownload', result);
const optionHandled = getConfigClientOption<{ premiumizeApiKey?: string }>(
'premiumize'
);
const optionHandled = getConfigClientOption<{
premiumizeApiKey?: string;
}>('realdebrid');
if (!optionHandled || !optionHandled.premiumizeApiKey) {
throw new Error('Please set your Premiumize API key in the settings.');
}
const { premiumizeApiKey } = optionHandled;

const tempId = this.queueRequestDownload(result, appID, 'premiumize');
// create the opengameinstaller folder on premiumize

// create the opengameinstaller folder on premiumize
let folderId = '';
console.log(
'Creating folder on Premiumize... API Key:',
premiumizeApiKey
);

let folderId = '';
const responseFolder = await window.electronAPI.app.axios({
method: 'POST',
url: `${BASE_URL}/folder/create?apikey=${premiumizeApiKey}`,
data: {
name: 'OpenGameInstaller',
},
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
Accept: 'application/json',
},
});

const responseFolder = await window.electronAPI.app.axios({
method: 'POST',
url: `${BASE_URL}/folder/create?apikey=${premiumizeApiKey}`,
data: {
name: 'OpenGameInstaller',
},
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
},
});
// -- Step 1: Create the folder for OGI to download to --
const responseFolderData = responseFolder.data as ResponseFolder;
if (responseFolderData.status === 'success') {
folderId = responseFolderData.id;
} else if (responseFolderData.status === 'error') {
console.log('Error creating folder:', responseFolderData.message);
// get the folder from the root
const responseFolderContent = await window.electronAPI.app.axios({
method: 'GET',
url: `${BASE_URL}/folder/search?apikey=${premiumizeApiKey}&q=OpenGameInstaller`,
headers: {
Accept: 'application/json',
},
});

// -- Step 1: Create the folder for OGI to download to --
const responseFolderData = responseFolder.data as ResponseFolder;
if (responseFolderData.status === 'success') {
folderId = responseFolderData.id;
} else if (responseFolderData.status === 'error') {
// get the folder from the root
const responseFolderContent = await window.electronAPI.app.axios({
method: 'GET',
url: `${BASE_URL}/folder/content?apikey=${premiumizeApiKey}`,
});
const responseFolderContentData =
responseFolderContent.data as PremiumizeFolderResponse;

const responseFolderContentData =
responseFolderContent.data as PremiumizeFolderResponse;
if (responseFolderContentData.status === 'success') {
const folder = responseFolderContentData.content.find(
(item) => item.name === 'OpenGameInstaller'
);
if (folder) {
folderId = folder.id;
} else {
throw new Error('OpenGameInstaller folder not found in Premiumize');
console.log('Folder content: ', responseFolderContentData);
if (responseFolderContentData.status === 'success') {
const folder = responseFolderContentData.content.find(
(item) => item.name === 'OpenGameInstaller'
);
if (folder) {
folderId = folder.id;
} else {
throw new Error('OpenGameInstaller folder not found in Premiumize');
}
} else if (responseFolderContentData.status === 'error') {
throw new Error(responseFolderContentData.message);
}
} else if (responseFolderContentData.status === 'error') {
throw new Error(responseFolderContentData.message);
}
}

// -- Step 2: Add the torrent to the folder --
const formDataAddTorrent = new FormData();
if (result.downloadType === 'torrent') {
const torrentData = await window.electronAPI.downloadTorrentInto(
result.downloadURL!
);
formDataAddTorrent.append(
'file',
new Blob([torrentData.buffer as ArrayBuffer])
);
} else if (result.downloadType === 'magnet') {
formDataAddTorrent.append('src', result.downloadURL!);
}
formDataAddTorrent.append('folder_id', folderId);
// -- Step 2: Add the torrent to the folder --
const formDataAddTorrent = new FormData();
if (result.downloadType === 'torrent') {
const torrentData = await window.electronAPI.downloadTorrentInto(
result.downloadURL!
);
formDataAddTorrent.append(
'file',
new Blob([torrentData.buffer as ArrayBuffer])
);
} else if (result.downloadType === 'magnet') {
formDataAddTorrent.append('src', result.downloadURL!);
}
formDataAddTorrent.append('folder_id', folderId);

const responseAddTorrent =
await window.electronAPI.app.axios<PremiumizeTransferResponse>({
method: 'POST',
url: `${BASE_URL}/transfer/create?apikey=${premiumizeApiKey}`,
data: formDataAddTorrent,
headers: {
'Content-Type': 'multipart/form-data',
},
});
const responseAddTorrent =
await window.electronAPI.app.axios<PremiumizeTransferResponse>({
method: 'POST',
url: `${BASE_URL}/transfer/create?apikey=${premiumizeApiKey}`,
data: Object.fromEntries(formDataAddTorrent.entries()),
headers: {
'Content-Type': 'multipart/form-data',
Accept: 'application/json',
},
});

if (responseAddTorrent.data.status === 'error') {
throw new Error(responseAddTorrent.data.message);
}
const transferId = responseAddTorrent.data.id;
console.log('Transfer ID: ', transferId);
if (responseAddTorrent.data.status === 'error') {
throw new Error(responseAddTorrent.data.message);
}
const transferId = responseAddTorrent.data.id;
console.log('Transfer ID: ', transferId);

// -- Step 3: Wait for the torrent to be ready --
const foundFolderId = await new Promise<string>((resolve, reject) => {
let attempts = 0;
const interval = setInterval(async () => {
try {
if (attempts > 120) { // 120 * 2.5s = 5 minutes (adjust if needed, but 10 mins is standard)
clearInterval(interval);
reject(new Error('Timed out waiting for Premiumize transfer.'));
return;
}
const responseTransfersList =
await window.electronAPI.app.axios<PremiumizeTransfersListResponse>({
method: 'GET',
url: `${BASE_URL}/transfer/list?apikey=${premiumizeApiKey}`,
});
if (responseTransfersList.status !== 200) {
// -- Step 3: Wait for the torrent to be ready --
const foundFolderId = await new Promise<string>((resolve, reject) => {
let attempts = 0;
const interval = setInterval(async () => {
try {
if (attempts > 120) {
// 120 * 2.5s = 5 minutes (adjust if needed, but 10 mins is standard)
clearInterval(interval);
reject(new Error('Timed out waiting for Premiumize transfer.'));
return;
}
const responseTransfersList =
await window.electronAPI.app.axios<PremiumizeTransfersListResponse>(
{
method: 'GET',
url: `${BASE_URL}/transfer/list?apikey=${premiumizeApiKey}`,
}
);
if (responseTransfersList.status !== 200) {
attempts++;
return;
}
if (responseTransfersList.data.status === 'error') {
attempts++;
return;
}
const transfer = responseTransfersList.data.transfers.find(
(transfer) => transfer.id === transferId
);
if (transfer?.status === 'finished') {
clearInterval(interval);
resolve(transfer?.folder_id || '');
return;
}
attempts++;
return;
}
if (responseTransfersList.data.status === 'error') {
attempts++;
return;
}
const transfer = responseTransfersList.data.transfers.find(
(transfer) => transfer.id === transferId
);
if (transfer?.status === 'finished') {
} catch (err) {
clearInterval(interval);
resolve(transfer?.folder_id || '');
return;
reject(err);
}
attempts++;
} catch (err) {
clearInterval(interval);
reject(err);
}
}, 2500);
});
}, 2500);
});

if (!foundFolderId) {
throw new Error('Failed to download torrent from Premiumize');
}
if (!foundFolderId) {
throw new Error('Failed to download torrent from Premiumize');
}

// -- Step 4: Get the direct download --
const responseTorrentFile =
await window.electronAPI.app.axios<PremiumizeZipGenerateResponse>({
method: 'POST',
url: `${BASE_URL}/zip/generate?apikey=${premiumizeApiKey}`,
data: {
'folders[]': foundFolderId,
},
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
},
});
// -- Step 4: Get the direct download --
const responseTorrentFile =
await window.electronAPI.app.axios<PremiumizeZipGenerateResponse>({
method: 'POST',
url: `${BASE_URL}/zip/generate?apikey=${premiumizeApiKey}`,
data: {
'folders[]': foundFolderId,
},
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
Accept: 'application/json',
},
});

if (responseTorrentFile.status !== 200) {
console.log('Response: ', responseTorrentFile);
throw new Error('Failed to get direct download from Premiumize');
}
if (responseTorrentFile.status !== 200) {
console.log('Response: ', responseTorrentFile);
throw new Error('Failed to get direct download from Premiumize');
}

if (responseTorrentFile.data.status === 'error') {
console.log('Response: ', responseTorrentFile.data);
throw new Error(responseTorrentFile.data.message);
}
if (responseTorrentFile.data.status === 'error') {
console.log('Response: ', responseTorrentFile.data);
throw new Error(responseTorrentFile.data.message);
}

const directDownloadUrl = responseTorrentFile.data.location;
console.log('Direct download URL: ', directDownloadUrl);
const directDownloadUrl = responseTorrentFile.data.location;
console.log('Direct download URL: ', directDownloadUrl);

// -- Step 5: Send the direct download to the download handler --
const { flush } = listenUntilDownloadReady();
const downloadID = await window.electronAPI.ddl.download([
{
link: directDownloadUrl,
path:
getDownloadPath() +
'/' +
result.name +
'/' +
result.filename +
'.zip',
headers: {
'OGI-Parallel-Limit': '1',
// -- Step 5: Send the direct download to the download handler --
const { flush } = listenUntilDownloadReady();
const downloadID = await window.electronAPI.ddl.download([
{
link: directDownloadUrl,
path:
getDownloadPath() +
'/' +
result.name +
'/' +
result.filename +
'.zip',
headers: {
'OGI-Parallel-Limit': '1',
},
},
},
]);
const updatedState = flush();
if (downloadID === null) {
throw new Error('Failed to download the torrent.');
}
]);
const updatedState = flush();
if (downloadID === null) {
throw new Error('Failed to download the torrent.');
}

this.updateDownloadRequested(
downloadID,
tempId,
directDownloadUrl,
getDownloadPath() + '/' + result.name + '/' + result.filename + '.zip',
'premiumize',
updatedState,
result
);
this.updateDownloadRequested(
downloadID,
tempId,
directDownloadUrl,
getDownloadPath() + '/' + result.name + '/' + result.filename + '.zip',
'premiumize',
updatedState,
result
);
} finally {
currentDownloads.update((downloads) =>
downloads.filter((d) => d.id !== tempId)
);
if (htmlButton) {
htmlButton.textContent = originalText;
htmlButton.disabled = originalDisabled;
Expand Down