mirrors/homer
1
0
Fork 0
mirror of https://github.com/bastienwirtz/homer.git synced 2025-12-15 11:54:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Use service mixin fetch method with custom session handling for Transmission RPC

Browse Source
This commit is contained in:
Igor Kulman
2025-09-21 22:23:46 +02:00
committed by Bastien Wirtz
parent 9054bd8941
commit 68fb183c20
1 changed files with 22 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/components/services/Transmission.vue
View File

@@ -111,30 +111,31 @@ export default {
}
try {
const response = await fetch(
this.endpoint + "/transmission/rpc",
options,
);
return await this.fetch("transmission/rpc", options);
} catch (error) {
// Handle Transmission's 409 session requirement
if (error.message.includes("409")) {
// Make a direct request to get session ID
let url = this.endpoint;
if (url && !url.endsWith("/")) {
url += "/";
}
url += "transmission/rpc";
// Handle session ID requirement
if (response.status === 409) {
this.sessionId = response.headers.get("X-Transmission-Session-Id");
if (this.sessionId) {
options.headers["X-Transmission-Session-Id"] = this.sessionId;
const retryResponse = await fetch(
this.endpoint + "/transmission/rpc",
options,
);
return await retryResponse.json();
const sessionResponse = await fetch(url, {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({ method: "session-get" }),
});
if (sessionResponse.status === 409) {
this.sessionId = sessionResponse.headers.get("X-Transmission-Session-Id");
if (this.sessionId) {
options.headers["X-Transmission-Session-Id"] = this.sessionId;
return await this.fetch("transmission/rpc", options);
}
}
}
if (!response.ok) {
throw new Error(`HTTP error! status: ${response.status}`);
}
return await response.json();
} catch (error) {
console.error("Transmission RPC error:", error);
throw error;
}