rainbownapkin/canopy
1
0
Fork 0
Code Issues 2 Pull requests Actions Packages Projects Releases Wiki Activity

Continued work on Playlist Queueing

Browse source
This commit is contained in:
rainbow napkin 2025-03-26 23:08:32 -04:00
parent 0325b645ca
commit 1167b2dd76
1 changed files with 100 additions and 82 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

182
src/app/channel/media/queue.js
View file

@ -263,6 +263,9 @@ module.exports = class{
return now; return now;
} }
} }
//If we fell through, just return input
return start;
} }
refreshNextTimer(volatile = false){ refreshNextTimer(volatile = false){
@ -522,95 +525,111 @@ module.exports = class{
https://community.appsmith.com/content/blog/dark-side-foreach-why-you-should-think-twice-using-it https://community.appsmith.com/content/blog/dark-side-foreach-why-you-should-think-twice-using-it
*/ */
let mediaObj = media[0]; for(let mediaObj of media){
//If someone is trying to schedule something that starts and ends in the past
//If someone is trying to schedule something that starts and ends in the past if((mediaObj.getEndTime() < new Date().getTime()) && !force){
if((mediaObj.getEndTime() < new Date().getTime()) && !force){ //If an originating socket was provided for this request
//If an originating socket was provided for this request if(socket != null){
if(socket != null){ //Yell at the user for being an asshole
//Yell at the user for being an asshole loggerUtils.socketErrorHandler(socket, "You cannot alter the past!", "queue");
loggerUtils.socketErrorHandler(socket, "You cannot alter the past!", "queue"); }
return false;
} }
return false;
}
//If the item has already started //If the item has already started
if((mediaObj.startTime < new Date().getTime()) && !force){ if((mediaObj.startTime < new Date().getTime()) && !force){
//Set time stamp to existing timestamp plus the difference between the orginal start-date and now //Set time stamp to existing timestamp plus the difference between the orginal start-date and now
const calculatedTimeStamp = mediaObj.startTimeStamp + ((new Date().getTime() - mediaObj.startTime) / 1000) const calculatedTimeStamp = mediaObj.startTimeStamp + ((new Date().getTime() - mediaObj.startTime) / 1000)
//If the calculated time stamp is more than negligible, and therefore not simply caused by serverside processing time //If the calculated time stamp is more than negligible, and therefore not simply caused by serverside processing time
if(calculatedTimeStamp > 5){ if(calculatedTimeStamp > 5){
//Set the media timestamp //Set the media timestamp
mediaObj.startTimeStamp = calculatedTimeStamp; mediaObj.startTimeStamp = calculatedTimeStamp;
//Start the item now //Start the item now
mediaObj.startTime = new Date().getTime(); mediaObj.startTime = new Date().getTime();
}
}
//If there's already something queued right now
if(this.getItemAtEpoch(mediaObj.startTime) != null || this.getItemAtEpoch(mediaObj.getEndTime())){
//If an originating socket was provided for this request
if(socket != null){
//Yell at the user for being an asshole
loggerUtils.socketErrorHandler(socket, "This time slot has already been taken in the queue!", "queue");
}
//Ignore it
return false;
}
//Create an empty temp array to sparsley populate with our schedule
const tempSchedule = [];
//Create new map to replace our current schedule map
const newSchedule = new Map();
//For every item that's already been scheduled
for(let item of this.schedule){
//add it to the slot corresponding to it's start epoch in seconds
tempSchedule[Math.round(item[0] / 1000)] = item[1];
}
//Inject the media object into the slot corresponding to it's epoch in the temp schedule array
tempSchedule[Math.round(mediaObj.startTime / 1000)] = mediaObj;
//For every populated key in our array
for(let startTime of Object.keys(tempSchedule)){
//Add item to replacement schedule map
newSchedule.set(tempSchedule[startTime].startTime, tempSchedule[startTime]);
}
//Replace the existing schedule map with our new one
this.schedule = newSchedule;
//Broadcast the channel queue
this.broadcastQueue();
//Refresh the next timer to ensure whatever comes on next is right
this.refreshNextTimer(startVolatile);
//If media has more than a minute before starting and DB transactions are enabled
if(mediaObj.startTime - new Date().getTime() > 1000 && !volatile){
//fuck you yoda you fucking nerd
try{
//If we didn't get handed a freebie
if(chanDB == null){
//Go out and get it done ourselves
chanDB = await channelModel.findOne({name:this.channel.name});
}
//If we couldn't find the channel
if(chanDB == null){
//FUCK
throw new Error(`Unable to find channel document ${this.channel.name} while saving item to queue!`);
}
//Add media to the persistant schedule
chanDB.media.scheduled.push(mediaObj);
//If something fucked up
}catch(err){
//If this was originated by someone
if(socket != null){
//Bitch at them
loggerUtils.socketExceptionHandler(socket, err);
//If not
}else{
//Bitch to the console
loggerUtils.localExceptionHandler(err);
}
}
} }
} }
//If there's already something queued right now //If we fucked with the DB during the main loop
if(this.getItemAtEpoch(mediaObj.startTime) != null || this.getItemAtEpoch(mediaObj.getEndTime())){ if(chanDB == null && !volatile){
//If an originating socket was provided for this request
if(socket != null){
//Yell at the user for being an asshole
loggerUtils.socketErrorHandler(socket, "This time slot has already been taken in the queue!", "queue");
}
//Ignore it
return false;
}
//Create an empty temp array to sparsley populate with our schedule
const tempSchedule = [];
//Create new map to replace our current schedule map
const newSchedule = new Map();
//For every item that's already been scheduled
for(let item of this.schedule){
//add it to the slot corresponding to it's start epoch in seconds
tempSchedule[Math.round(item[0] / 1000)] = item[1];
}
//Inject the media object into the slot corresponding to it's epoch in the temp schedule array
tempSchedule[Math.round(mediaObj.startTime / 1000)] = mediaObj;
//For every populated key in our array
for(let startTime of Object.keys(tempSchedule)){
//Add item to replacement schedule map
newSchedule.set(tempSchedule[startTime].startTime, tempSchedule[startTime]);
}
//Replace the existing schedule map with our new one
this.schedule = newSchedule;
//Broadcast the channel queue
this.broadcastQueue();
//Refresh the next timer to ensure whatever comes on next is right
this.refreshNextTimer(startVolatile);
//If media has more than a minute before starting and DB transactions are enabled
if(mediaObj.startTime - new Date().getTime() > 1000 && !volatile){
//fuck you yoda you fucking nerd
try{ try{
//If we didn't get handed a freebie
if(chanDB == null){
//Go out and get it done ourselves
chanDB = await channelModel.findOne({name:this.channel.name});
}
//If we couldn't find the channel
if(chanDB == null){
//FUCK
throw new Error(`Unable to find channel document ${this.channel.name} while saving item to queue!`);
}
//Add media to the persistant schedule
chanDB.media.scheduled.push(mediaObj);
//Save the database //Save the database
chanDB.save(); chanDB.save();
//If something fucked up //If something fucked up
}catch(err){ }catch(err){
//If this was originated by someone //If this was originated by someone
@ -625,8 +644,8 @@ module.exports = class{
} }
} }
//return media object for use //return true to let everyone know this shit worked
return mediaObj; return true;
} }
async start(mediaObj, timestamp = mediaObj.startTimeStamp, volatile = false){ async start(mediaObj, timestamp = mediaObj.startTimeStamp, volatile = false){
@ -964,7 +983,6 @@ module.exports = class{
//Add record to new schedule //Add record to new schedule
newSched.push(record); newSched.push(record);
//Re-Schedule it in RAM //Re-Schedule it in RAM
await this.scheduleMedia([mediaObj], null, chanDB, true, true, false); await this.scheduleMedia([mediaObj], null, chanDB, true, true, false);
}else{ }else{