330 lines
11 KiB
JavaScript
330 lines
11 KiB
JavaScript
// ===========================================================================
|
|
// Asshat Gaming Roleplay
|
|
// https://github.com/VortrexFTW/agrp_main
|
|
// (c) 2022 Asshat Gaming
|
|
// ===========================================================================
|
|
// FILE: radio.js
|
|
// DESC: Provides radio station streaming
|
|
// TYPE: Server (JavaScript)
|
|
// ===========================================================================
|
|
|
|
class RadioStationData {
|
|
constructor(dbAssoc = false) {
|
|
this.databaseId = 0;
|
|
this.name = "";
|
|
this.url = "";
|
|
this.genre = "";
|
|
this.codec = "";
|
|
this.index = -1;
|
|
|
|
if (dbAssoc) {
|
|
this.databaseId = dbAssoc["radio_id"];
|
|
this.name = dbAssoc["radio_name"];
|
|
this.url = dbAssoc["radio_url"];
|
|
this.genre = dbAssoc["radio_genre"];
|
|
this.codec = dbAssoc["radio_codec"];
|
|
}
|
|
}
|
|
};
|
|
|
|
// ===========================================================================
|
|
|
|
function initRadioScript() {
|
|
logToConsole(LOG_INFO, "[VRR.Radio]: Initializing radio script ...");
|
|
logToConsole(LOG_INFO, "[VRR.Radio]: Radio script initialized successfully!");
|
|
return true;
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
function loadRadioStationsFromDatabase() {
|
|
logToConsole(LOG_INFO, "[VRR.Radio]: Loading radio stations from database ...");
|
|
let dbConnection = connectToDatabase();
|
|
let tempRadioStations = [];
|
|
let dbAssoc;
|
|
if (dbConnection) {
|
|
let dbQueryString = `SELECT * FROM radio_main`;
|
|
let dbQuery = queryDatabase(dbConnection, dbQueryString);
|
|
if (dbQuery) {
|
|
while (dbAssoc = fetchQueryAssoc(dbQuery)) {
|
|
let tempRadioStationData = new RadioStationData(dbAssoc);
|
|
tempRadioStations.push(tempRadioStationData);
|
|
}
|
|
freeDatabaseQuery(dbQuery);
|
|
}
|
|
disconnectFromDatabase(dbConnection);
|
|
}
|
|
|
|
logToConsole(LOG_INFO, `[VRR.Radio]: ${tempRadioStations.length} radio stations loaded from database successfully!`);
|
|
return tempRadioStations;
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
/**
|
|
* This is a command handler function.
|
|
*
|
|
* @param {string} command - The command name used by the player
|
|
* @param {string} params - The parameters/args string used with the command by the player
|
|
* @param {Client} client - The client/player that used the command
|
|
* @return {bool} Whether or not the command was successful
|
|
*
|
|
*/
|
|
function playStreamingRadioCommand(command, params, client) {
|
|
if (areParamsEmpty(params)) {
|
|
messagePlayerSyntax(client, getCommandSyntaxText(command));
|
|
messagePlayerInfo(client, "Use /radiostations for a list of available radio stations.");
|
|
return false;
|
|
}
|
|
|
|
let radioStationId = getRadioStationFromParams(params);
|
|
|
|
if (radioStationId != 0 && typeof getServerData().radioStations[radioStationId - 1] == "undefined") {
|
|
messagePlayerError(client, getLocaleString(client, "InvalidRadioStation"));
|
|
return false;
|
|
}
|
|
|
|
if (isPlayerInAnyVehicle(client)) {
|
|
let vehicle = getPlayerVehicle(client);
|
|
|
|
if (!getVehicleData(vehicle)) {
|
|
messagePlayerError(client, getLocaleString(client, "RandomVehicleCommandsDisabled"));
|
|
return false;
|
|
}
|
|
|
|
if (radioStationId == 0) {
|
|
getVehicleData(vehicle).streamingRadioStation = -1;
|
|
getVehicleData(vehicle).needsSaved = true;
|
|
getPlayerData(client).streamingRadioStation = -1;
|
|
meActionToNearbyPlayers(client, `turns off their vehicle's radio`);
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (getPlayerVehicle(client) == getPlayerVehicle(clients[i])) {
|
|
playRadioStreamForPlayer(clients[i], "");
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
getVehicleData(vehicle).streamingRadioStation = radioStationId - 1;
|
|
getPlayerData(client).streamingRadioStation = radioStationId - 1;
|
|
meActionToNearbyPlayers(client, getLocaleString(client, "ActionVehicleRadioStationChange", getRadioStationData(radioStationId - 1).name, getRadioStationData(radioStationId - 1).genre));
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (vehicle == getPlayerVehicle(clients[i])) {
|
|
playRadioStreamForPlayer(clients[i], getRadioStationData(radioStationId - 1).url, true, getPlayerStreamingRadioVolume(client));
|
|
}
|
|
}
|
|
} else {
|
|
if (isPlayerInAnyHouse(client)) {
|
|
let houseId = getPlayerHouse(client);
|
|
if (radioStationId == 0) {
|
|
getHouseData(houseId).streamingRadioStationIndex = -1;
|
|
getHouseData(houseId).streamingRadioStationIndex = 0;
|
|
getHouseData(houseId).needsSaved = true;
|
|
getPlayerData(client).streamingRadioStation = -1;
|
|
meActionToNearbyPlayers(client, `turns off the house radio`);
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (getEntityData(clients[i], "agrp.inHouse") == houseId) {
|
|
playRadioStreamForPlayer(clients[i], "");
|
|
}
|
|
}
|
|
} else {
|
|
getHouseData(houseId).streamingRadioStationIndex = radioStationId - 1;
|
|
getHouseData(houseId).streamingRadioStation = getRadioStationData(radioStationId - 1).databaseId;
|
|
getHouseData(houseId).needsSaved = true;
|
|
getPlayerData(client).streamingRadioStation = radioStationId - 1;
|
|
meActionToNearbyPlayers(client, getLocaleString(client, "ActionHouseRadioStationChange", getRadioStationData(radioStationId - 1).name, getRadioStationData(radioStationId - 1).genre));
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (getEntityData(clients[i], "agrp.inHouse") == houseId) {
|
|
playRadioStreamForPlayer(clients[i], getRadioStationData(radioStationId - 1).url, true, getPlayerStreamingRadioVolume(clients[i]));
|
|
}
|
|
}
|
|
}
|
|
} else if (isPlayerInAnyBusiness(client)) {
|
|
let businessId = getPlayerBusiness(client);
|
|
if (radioStationId == 0) {
|
|
getBusinessData(businessId).streamingRadioStation = 0;
|
|
getBusinessData(businessId).streamingRadioStationIndex = -1;
|
|
getBusinessData(businessId).needsSaved = true;
|
|
getPlayerData(client).streamingRadioStation = -1;
|
|
meActionToNearbyPlayers(client, `turns off the business radio`);
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (getPlayerBusiness(clients[i]) == businessId) {
|
|
stopRadioStreamForPlayer(clients[i]);
|
|
}
|
|
}
|
|
} else {
|
|
getBusinessData(businessId).streamingRadioStationIndex = radioStationId - 1;
|
|
getBusinessData(businessId).streamingRadioStation = getRadioStationData(radioStationId - 1).databaseId;
|
|
getBusinessData(businessId).needsSaved = true;
|
|
getPlayerData(client).streamingRadioStation = radioStationId - 1;
|
|
meActionToNearbyPlayers(client, getLocaleString(client, "ActionBusinessRadioStationChange", getRadioStationData(radioStationId - 1).name, getRadioStationData(radioStationId - 1).genre));
|
|
|
|
let clients = getClients();
|
|
for (let i in clients) {
|
|
if (getPlayerBusiness(clients[i]) == businessId) {
|
|
playRadioStreamForPlayer(clients[i], getRadioStationData(radioStationId - 1).url, true, getPlayerStreamingRadioVolume(clients[i]));
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
messagePlayerError(client, getLocaleString(client, "RadioStationLocationInvalid"));
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
/**
|
|
* This is a command handler function.
|
|
*
|
|
* @param {string} command - The command name used by the player
|
|
* @param {string} params - The parameters/args string used with the command by the player
|
|
* @param {Client} client - The client/player that used the command
|
|
* @return {bool} Whether or not the command was successful
|
|
*
|
|
*/
|
|
function setStreamingRadioVolumeCommand(command, params, client) {
|
|
if (areParamsEmpty(params)) {
|
|
messagePlayerSyntax(client, getCommandSyntaxText(command));
|
|
return false;
|
|
}
|
|
|
|
let volumeLevel = params;
|
|
|
|
if (isNaN(volumeLevel)) {
|
|
messagePlayerError(client, getLocaleString(client, "RadioVolumeNotNumber"));
|
|
return false;
|
|
}
|
|
|
|
setPlayerStreamingRadioVolume(client, toInteger(volumeLevel));
|
|
getPlayerData(client).accountData.streamingRadioVolume = toInteger(volumeLevel);
|
|
let volumeEmoji = '';
|
|
if (volumeLevel >= 60) {
|
|
volumeEmoji = '🔊';
|
|
} else if (volumeLevel >= 30 && volumeLevel < 60) {
|
|
volumeEmoji = '🔉';
|
|
} else if (volumeLevel > 0 && volumeLevel < 30) {
|
|
volumeEmoji = '🔈';
|
|
} else if (volumeLevel <= 0) {
|
|
volumeEmoji = '🔇';
|
|
}
|
|
|
|
messagePlayerSuccess(client, getLocaleString(client, "RadioVolumeChanged", volumeEmoji, volumeLevel));
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
function getPlayerStreamingRadioVolume(client) {
|
|
if (!getPlayerData(client) || !isPlayerLoggedIn(client) || !isPlayerSpawned(client)) {
|
|
return 20;
|
|
}
|
|
return getPlayerData(client).accountData.streamingRadioVolume;
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
/**
|
|
* This is a command handler function.
|
|
*
|
|
* @param {string} command - The command name used by the player
|
|
* @param {string} params - The parameters/args string used with the command by the player
|
|
* @param {Client} client - The client/player that used the command
|
|
* @return {bool} Whether or not the command was successful
|
|
*
|
|
*/
|
|
function showRadioStationListCommand(command, params, client) {
|
|
let stationList = getServerData().radioStations.map(function (x) { return `{ALTCOLOUR}${toInteger(x.index) + 1}: {MAINCOLOUR}${x.name}`; });
|
|
|
|
let chunkedList = splitArrayIntoChunks(stationList, 4);
|
|
|
|
messagePlayerNormal(client, makeChatBoxSectionHeader(getLocaleString(client, "HeaderRadioStationsList")));
|
|
|
|
for (let i in chunkedList) {
|
|
messagePlayerInfo(client, chunkedList[i].join(", "));
|
|
}
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
function setAllRadioStationIndexes() {
|
|
for (let i in getServerData().radioStations) {
|
|
getServerData().radioStations[i].index = i;
|
|
}
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
/**
|
|
* @param {number} radioStationId - The data index of the radio station
|
|
* @return {RadioStationData} The radio station's data (class instance)
|
|
*/
|
|
function getRadioStationData(radioStationId) {
|
|
return getServerData().radioStations[radioStationId];
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
/**
|
|
* This is a command handler function.
|
|
*
|
|
* @param {string} command - The command name used by the player
|
|
* @param {string} params - The parameters/args string used with the command by the player
|
|
* @param {Client} client - The client/player that used the command
|
|
* @return {bool} Whether or not the command was successful
|
|
*
|
|
*/
|
|
function reloadAllRadioStationsCommand(command, params, client) {
|
|
stopRadioStreamForPlayer(null);
|
|
clearArray(getServerData().radioStations);
|
|
getServerData().radioStations = loadRadioStationsFromDatabase();
|
|
setRadioStationIndexes();
|
|
|
|
announceAdminAction(`AllRadioStationsReloaded`);
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
function getRadioStationFromParams(params) {
|
|
if (isNaN(params)) {
|
|
for (let i in getServerData().radioStations) {
|
|
if (toLowerCase(getServerData().radioStations[i].name).indexOf(toLowerCase(params)) != -1) {
|
|
return i;
|
|
}
|
|
}
|
|
} else {
|
|
if (typeof getServerData().radioStations[params] != "undefined") {
|
|
return toInteger(params);
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
// ===========================================================================
|
|
|
|
function getRadioStationIdFromDatabaseId(databaseId) {
|
|
if (databaseId <= 0) {
|
|
return -1;
|
|
}
|
|
|
|
for (let i in getServerData().radioStations) {
|
|
if (getServerData().radioStations[i].databaseId == databaseId) {
|
|
return i;
|
|
}
|
|
}
|
|
|
|
return -1;
|
|
}
|
|
|
|
// ===========================================================================
|