Skip to content

Commit

Permalink
feat: move blip_server to node
Browse files Browse the repository at this point in the history
  • Loading branch information
@TGRHavoc
TGRHavoc committed Jun 9, 2019
1 parent 5bbee05 commit 744ac41
Showing 1 changed file with 253 additions and 22 deletions.
275 changes: 253 additions & 22 deletions src/blips.js
View file
@@ -1,13 +1,251 @@
const log = require("simple-console-logger").getLogger("LiveMap Blips");
const fs = require("fs");
const path = require("path");

const BlipController = (router) => {
const getBlips = function (ctx) {
log.debug("Sending blips");
ctx.body = "Hello";
};
let playerWhoGeneratedBlips = null;
let blips = null;
const blipFile = path.join("resources", GetCurrentResourceName(), GetConvar("blip_file", "server/blips.json"));

// Middleware to send the blips
const getBlips = (ctx) => {
if (blips === null){
ctx.body = JSON.stringify({
error: "blip cache is empty"
});
}else{
ctx.body = JSON.stringify(blips);
}
};

// function to save blips to blip file
const saveBlips = () => {
let exists = fs.existsSync(blipFile);
if (exists) {
try {
fs.writeFileSync(blipFile, JSON.stringify(blips, null, 4));
} catch (err) {
log.warn("Error when writing to blips.json file. %s", err.message);
}
} else {
try {
fs.writeFileSync(blipFile, "{}");
} catch (err) {
log.warn("Error writing empty blip file... %s", err.message);
}
}
};
// function to load blips from blip file
const loadBlips = () => {
let exists = fs.existsSync(blipFile);
if (exists) {
const rawData = fs.readFileSync(blipFile);
try {
blips = JSON.parse(rawData);
} catch (err) {
log.warn("Error when parsing blips.json file. Please make sure it's valid JSON. %s", err.message);
}
} else {
// Make an empty blip file?
blips = {};
try {
fs.writeFileSync(blipFile, "{}");
} catch (err) {
log.warn("Error writing empty blip file... %s", err.message);
}
}
};

const getDistanceBetween = (p1, p2) => {
let x = Math.pow(p2.x - p1.x, 2);
let y = Math.pow(p2.y - p1.y, 2);
let z = Math.pow(p2.z - p1.z, 2);

return Math.sqrt(x + y + z);
};

const getBlipIndex = (sprite, pos) => {
if (blips[sprite] === undefined){
return -1;
}

blips[sprite].forEach((blip, index) => {
if (blip.pos == pos){
return index;
}
});

return -1;
};

const validBlip = (blip) => {
if (blip["sprite"] === undefined || blip["sprite"] === null) {
log.debug("Blip didn't have sprite: %o", blip);
log.warn("Blip has no sprite...");
return false;
}

if (blip["pos"] === undefined || blip["pos"] === null) {
log.debug("Blip didn't have pos: %o", blip);
log.warn("Blip has no position...");
return false;
}

if (typeof(blip.pos) !== "object"){
log.warn("Blip position must be an object");
return false;
}

if (blip.pos["x"] === undefined || blip.pos["y"] === undefined || blip.pos["z"] === undefined){
log.debug("Invalid position: %o", blip.pos);
log.warn("Blip position invalid");
return false;
}

if (typeof(blip.pos.x) !== "number" || typeof(blip.pos.y) !== "number" || typeof(blip.pos.z) !== "number"){
log.warn("Blip pos must be numbers");
log.debug("Invalid position: %o", blip.pos);
return false;
}

return true;
};

on("onResourceStart", (name) => {
if (name === GetCurrentResourceName()){
loadBlips();
}
});
on("onResourceStop", (name) => {
if (name === GetCurrentResourceName()){
saveBlips();
}
});

onNet("livemap:blipsGenerated", (blipTable) => {
log.debug("Got blips: %O", blipTable);
let playerIdentifier = GetPlayerIdentifier(source, 0);
if (playerWhoGeneratedBlips === null || playerWhoGeneratedBlips !== playerIdentifier){
log.warn("playerWhoGeneratedBlips doesn't match... Not using the blips recieved");
return;
}

blips = blipTable;
saveBlips();
});

onNet("livemap:AddBlip", (blip) => {
if (!validBlip(blip)){
return;
}

//Extract the spite
const sprite = blip.sprite.toString();
delete blip.sprite;

// Make sure it's to 2 dp
blip.pos.x = blip.pos.x.toFixed(2);
blip.pos.y = blip.pos.y.toFixed(2);
blip.pos.z = blip.pos.z.toFixed(2);

// Get the index of the blip.. Making sure it exists
let blipIndex = getBlipIndex(sprite, blip);

if (blipIndex === -1){
log.debug("Duplicate blip: %d = %o", blipIndex, blip);
log.warn("Blip already exists... Cannot add it!");
return;
}

if (blips[sprite] === undefined){
blips[sprite] = [];
}

blips[sprite].push(blip);
//todo: trigger livemap:internal_AddBlip sprite, blip
});

onNet("livemap:UpdateBlip", (blip) => {
if(!validBlip(blip)){
return;
}

//Extract the spite
const sprite = blip.sprite.toString();
delete blip.sprite;

// Make sure it's to 2 dp
blip.pos.x = blip.pos.x.toFixed(2);
blip.pos.y = blip.pos.y.toFixed(2);
blip.pos.z = blip.pos.z.toFixed(2);

// Get the index of the blip.. Making sure it exists
let blipIndex = getBlipIndex(sprite, blip);

if (blipIndex !== -1){
blips[sprite][blipIndex] = blip;
//todo: trigger livemap_internal_UpdateBlip, sprite, blip
}else{
if (blips[sprite] === undefined){
blips[sprite] = [];
}

blips[sprite].push(blip);
//todo: trigger livemap:internal_AddBlip, sprite, blip
}
});

onNet("livemap:RemoveBlip", (blip) => {
if (!validBlip(blip)){
return;
}

//Extract the spire
const sprite = blip.sprite.toString();
delete blip.sprite;

// Make sure it's to 2 dp
blip.pos.x = blip.pos.x.toFixed(2);
blip.pos.y = blip.pos.y.toFixed(2);
blip.pos.z = blip.pos.z.toFixed(2);

// Get the index of the blip.. Making sure it exists
let blipIndex = getBlipIndex(sprite, blip);
if (blipIndex !== -1) {
delete blips[sprite][blipIndex];
log.info("Removed blip: %o", blip);
// TODO: Call livemap:internal_RemoveBlip
}else{
log.warn("Cannot delete a blip that doesn't exist");
}
});

onNet("livemap:RemoveClosestBlip", (playerPos) => {
let closest, sprite, currentBest;
for (let spriteId in blips){
blips[spriteId].forEach(blip => {
let myDistance = getDistanceBetween(playerPos, blip.pos);
if (currentBest === undefined || myDistance < currentBest){
currentBest = myDistance;
closest = blip;
sprite = spriteId;
}
});
}

if (currentBest === undefined) { // Possibly no blips..
return;
}

log.info("Removing closest blip. It's sprite is %d and position (dis=%d) is %o", sprite, closest.pos);

const blipToDelete = getBlipIndex(sprite, closest.pos);
if (blipToDelete == -1){
log.debug("Closest blip doesn't exist? %o\n%O", closest, blips);
return;
}

delete blips[sprite][blipToDelete];
//TODO: Trigger livemap:internal_RemoveBlip
});

RegisterCommand("blips", (src, args) => {
Expand All @@ -17,28 +255,21 @@ const BlipController = (router) => {
return;
}

let playerIdentifier = GetPlayerIdentifier(src, 0);
if (args[0] === "generate") {
log.warn("Generating blips using the in-game natives: Player %s is generating them.");
playerWhoGeneratedBlips = playerIdentifier;
log.warn("Generating blips using the in-game natives: Player %s is generating them.", playerIdentifier);
emitNet("livemap:getBlipsFromClient", src);
}
});
}, true);

router.get("/blips", getBlips);
};
router.get("/blips.json", getBlips);

//TODO: Return anything that might be important...
return {
};
};

/*
RegisterCommand("blips", function(source, args, rawCommand)
local playerId = GetPlayerIdentifier(source, 0)
if args[1] == "generate" then
print("Generating blips using the in-game native: Player " .. playerId .. " is generating (I hope you know them)")
playerWhoGeneratedBlips = playerId
TriggerClientEvent("livemap:getBlipsFromClient", source)
return
end
end, true)
*/

module.exports = BlipController;

0 comments on commit 744ac41

Please sign in to comment.