public-mirrors/Kokoro-FastAPI
1
0
Fork 0
mirror of https://github.com/remsky/Kokoro-FastAPI.git synced 2025-04-13 09:39:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update AudioService.js

Browse source 
Change tab to space
This commit is contained in:
Chuui9739 2025-03-05 17:30:11 +08:00 • committed by GitHub
parent f4970a92f4
commit d69a4c3b6e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 93 additions and 93 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

186
web/src/services/AudioService.js
View file

@ -258,56 +258,56 @@ export class AudioService {
}
processNextOperation() {
if (this.sourceBuffer.updating || this.pendingOperations.length === 0) {
return;
}
if (this.sourceBuffer.updating || this.pendingOperations.length === 0) {
return;
}
// Don't process if audio is in error state
if (this.audio.error) {
console.warn("Skipping operation due to audio error");
return;
}
// Don't process if audio is in error state
if (this.audio.error) {
console.warn("Skipping operation due to audio error");
return;
}
const operation = this.pendingOperations.shift();
const operation = this.pendingOperations.shift();
try {
this.sourceBuffer.appendBuffer(operation.chunk);
try {
this.sourceBuffer.appendBuffer(operation.chunk);
// Set up event listeners
const onUpdateEnd = () => {
operation.resolve();
this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.sourceBuffer.removeEventListener(
"updateerror",
onUpdateError
);
// Process the next operation
this.processNextOperation();
};
// Set up event listeners
const onUpdateEnd = () => {
operation.resolve();
this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.sourceBuffer.removeEventListener(
"updateerror",
onUpdateError
);
// Process the next operation
this.processNextOperation();
};
const onUpdateError = (event) => {
operation.reject(event);
this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.sourceBuffer.removeEventListener(
"updateerror",
onUpdateError
);
// Decide whether to continue processing
if (event.name !== "InvalidStateError") {
this.processNextOperation();
}
};
const onUpdateError = (event) => {
operation.reject(event);
this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.sourceBuffer.removeEventListener(
"updateerror",
onUpdateError
);
// Decide whether to continue processing
if (event.name !== "InvalidStateError") {
this.processNextOperation();
}
};
this.sourceBuffer.addEventListener("updateend", onUpdateEnd);
this.sourceBuffer.addEventListener("updateerror", onUpdateError);
} catch (error) {
operation.reject(error);
// Only continue processing if it's not a fatal error
if (error.name !== "InvalidStateError") {
this.processNextOperation();
}
}
}
this.sourceBuffer.addEventListener("updateend", onUpdateEnd);
this.sourceBuffer.addEventListener("updateerror", onUpdateError);
} catch (error) {
operation.reject(error);
// Only continue processing if it's not a fatal error
if (error.name !== "InvalidStateError") {
this.processNextOperation();
}
}
}
play() {
if (this.audio && this.audio.readyState >= 2 && !this.audio.error) {
@ -387,64 +387,64 @@ export class AudioService {
}
cancel() {
if (this.controller) {
this.controller.abort();
this.controller = null;
}
if (this.controller) {
this.controller.abort();
this.controller = null;
}
if (this.audio) {
this.audio.pause();
this.audio.src = "";
this.audio = null;
}
if (this.audio) {
this.audio.pause();
this.audio.src = "";
this.audio = null;
}
if (this.mediaSource && this.mediaSource.readyState === "open") {
try {
this.mediaSource.endOfStream();
} catch (e) {
// Ignore errors during cleanup
}
}
if (this.mediaSource && this.mediaSource.readyState === "open") {
try {
this.mediaSource.endOfStream();
} catch (e) {
// Ignore errors during cleanup
}
}
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
}
cleanup() {
if (this.audio) {
this.eventListeners.forEach((listeners, event) => {
listeners.forEach((callback) => {
this.audio.removeEventListener(event, callback);
});
});
if (this.audio) {
this.eventListeners.forEach((listeners, event) => {
listeners.forEach((callback) => {
this.audio.removeEventListener(event, callback);
});
});
this.audio.pause();
this.audio.src = "";
this.audio = null;
}
this.audio.pause();
this.audio.src = "";
this.audio = null;
}
if (this.mediaSource && this.mediaSource.readyState === "open") {
try {
this.mediaSource.endOfStream();
} catch (e) {
// Ignore errors during cleanup
}
}
if (this.mediaSource && this.mediaSource.readyState === "open") {
try {
this.mediaSource.endOfStream();
} catch (e) {
// Ignore errors during cleanup
}
}
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
}
getDownloadUrl() {