Started work on archived media collection.
This commit is contained in:
parent
8d7d08d5c0
commit
855343dfc3
3 changed files with 194 additions and 1 deletions
113
src/app/channel/media/archivedMedia.js
Normal file
113
src/app/channel/media/archivedMedia.js
Normal file
|
|
@ -0,0 +1,113 @@
|
|||
/*Canopy - The next generation of stoner streaming software
|
||||
Copyright (C) 2024-2025 Rainbownapkin and the TTN Community
|
||||
|
||||
This program is free software: you can redistribute it and/or modify
|
||||
it under the terms of the GNU Affero General Public License as
|
||||
published by the Free Software Foundation, either version 3 of the
|
||||
License, or (at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU Affero General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Affero General Public License
|
||||
along with this program. If not, see <https://www.gnu.org/licenses/>.*/
|
||||
|
||||
//Local Imports
|
||||
const media = require('./media');
|
||||
const queuedMedia = require('./queuedMedia');
|
||||
|
||||
/**
|
||||
* Class extending media which represents a queued piece of media
|
||||
* @extends media
|
||||
*/
|
||||
class archivedMedia extends queuedMedia{
|
||||
/**
|
||||
* Creates a new queued media object
|
||||
* @param {String} channel - Channel where object was queued
|
||||
*/
|
||||
constructor(title, fileName, url, id, type, duration, rawLink, startTime, startTimeStamp = 0, earlyEnd, uuid, channel){
|
||||
//Call derived constructor
|
||||
super(title, fileName, url, id, type, duration, rawLink, startTime, startTimeStamp, earlyEnd, uuid);
|
||||
|
||||
/**
|
||||
* Channel media was queued
|
||||
*/
|
||||
this.channel = channel;
|
||||
|
||||
/**
|
||||
* Media status type
|
||||
*/
|
||||
this.status = 'archived';
|
||||
}
|
||||
|
||||
//statics
|
||||
/**
|
||||
* Creates a archivedMedia object from a media object
|
||||
* @param {String} channel - Channel where object was queued
|
||||
* @returns {archivedMedia} queuedMedia object created from given media object
|
||||
*/
|
||||
static fromMedia(media, startTime, startTimeStamp, channel){
|
||||
//Create and return queuedMedia object from given media object and arguments
|
||||
return new this(
|
||||
media.title,
|
||||
media.fileName,
|
||||
media.url,
|
||||
media.id,
|
||||
media.type,
|
||||
media.duration,
|
||||
media.rawLink,
|
||||
startTime,
|
||||
startTimeStamp,
|
||||
null,
|
||||
null,
|
||||
channel);
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts array of media objects into array of archivedMedia objects
|
||||
* @param {String} channel - Channel where object was queued
|
||||
* @returns Array of converted queued media objects
|
||||
*/
|
||||
static fromMediaArray(mediaList, start, channel){
|
||||
//Queued Media List
|
||||
const archivedMediaList = [];
|
||||
//Start Time Offset
|
||||
let startOffset = 0;
|
||||
|
||||
for(let media of mediaList){
|
||||
//Convert mediaObj to queuedMedia and push to the back of the list
|
||||
archivedMediaList.push(this.fromMedia(media, start + startOffset, 0, channel));
|
||||
|
||||
//Set start offset to end of the current item
|
||||
startOffset += (media.duration * 1000) + 5;
|
||||
}
|
||||
|
||||
return archivedMediaList;
|
||||
}
|
||||
|
||||
//methods
|
||||
/**
|
||||
* Generates a unique clone of a given media object
|
||||
* @returns unique clone of media object
|
||||
*/
|
||||
clone(){
|
||||
return new archivedMedia(
|
||||
this.title,
|
||||
this.fileName,
|
||||
this.url,
|
||||
this.id,
|
||||
this.type,
|
||||
this.duration,
|
||||
this.rawLink,
|
||||
this.startTime,
|
||||
this.startTimeStamp,
|
||||
this.earlyEnd,
|
||||
null,
|
||||
this.channel
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = archivedMedia;
|
||||
|
|
@ -21,7 +21,7 @@ const loggerUtils = require("../../../utils/loggerUtils");
|
|||
const channelModel = require("../../../schemas/channel/channelSchema");
|
||||
|
||||
/**
|
||||
* Class containg global server-side private message relay logic
|
||||
* Class containg per-channel server-side queue broadcasting logic
|
||||
*
|
||||
* Exists to make broadcasting channel queues to groups of authenticated users with the 'read-queue' perm as painless as possible,
|
||||
* reducing DB call/perm checks to just connection time, and not requireing any out-of-library user iteration at broadcast time.
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue