ed
This commit is contained in:
Nordi98
parent
57069485d5
commit
8d5055a73d
1412 changed files with 5583 additions and 0 deletions
209
resources/[jobs]/[police]/ProLaser4/UTIL/sv_lidar.lua
Normal file
209
resources/[jobs]/[police]/ProLaser4/UTIL/sv_lidar.lua
Normal file
|
|
@ -0,0 +1,209 @@
|
|||
local cfg = cfg
|
||||
|
||||
-- ShowLidar, repeater event to nearest player to show lidar to.
|
||||
RegisterServerEvent('prolaser4:SendDisplayData')
|
||||
AddEventHandler('prolaser4:SendDisplayData', function(target, data)
|
||||
TriggerClientEvent('prolaser4:ReturnDisplayData', target, data)
|
||||
end)
|
||||
|
||||
-- Database timeout event from client->server for server console log.
|
||||
RegisterServerEvent('prolaser4:DatabaseTimeout')
|
||||
AddEventHandler('prolaser4:DatabaseTimeout', function()
|
||||
print(string.format('^8[ERROR]: ^3Database timed out for %s after 5 seconds. Lidar records tablet unavailable.\n\t\t1) Ensure your database is online.\n\t\t2) restart oxmysql.\n\t\t3) restart ProLaser4.^7', GetPlayerName(source)))
|
||||
end)
|
||||
|
||||
function DebugPrint(text)
|
||||
if cfg.serverDebugging then
|
||||
print(text)
|
||||
end
|
||||
end
|
||||
|
||||
--[[--------------- ADVANCED LOGGING --------------]]
|
||||
if cfg.logging and MySQL ~= nil then
|
||||
local isInsertActive = false
|
||||
LOGGED_EVENTS = { }
|
||||
TEMP_LOGGED_EVENTS = { }
|
||||
|
||||
---------------- QUERIES ----------------
|
||||
local insertQuery = [[
|
||||
INSERT INTO prolaser4
|
||||
(timestamp, speed, distance, targetX, targetY, player, street, selfTestTimestamp)
|
||||
VALUES
|
||||
(STR_TO_DATE(?, "%m/%d/%Y %H:%i:%s"), ?, ?, ?, ?, ?, ?, STR_TO_DATE(?, "%m/%d/%Y %H:%i:%s"))
|
||||
]]
|
||||
local selectQueryRaw = [[
|
||||
SELECT
|
||||
rid,
|
||||
DATE_FORMAT(timestamp, "%c/%d/%y %H:%i") AS timestamp,
|
||||
speed,
|
||||
distance as 'range',
|
||||
targetX,
|
||||
targetY,
|
||||
player,
|
||||
street,
|
||||
DATE_FORMAT(selfTestTimestamp, "%m/%d/%Y %H:%i") AS selfTestTimestamp
|
||||
FROM prolaser4
|
||||
ORDER BY timestamp
|
||||
LIMIT
|
||||
]]
|
||||
local selectQuery = string.format("%s %s", selectQueryRaw, cfg.loggingSelectLimit)
|
||||
local countQuery = 'SELECT COUNT(*) FROM prolaser4'
|
||||
local cleanupQuery = 'DELETE FROM prolaser4 WHERE timestamp < DATE_SUB(NOW(), INTERVAL ? DAY);'
|
||||
-----------------------------------------
|
||||
-- Debugging Command
|
||||
RegisterCommand('lidarsqlupdate', function(source, args)
|
||||
-- check if from server console
|
||||
if source == 0 then
|
||||
DebugPrint('^3[INFO]: Manually inserting records to SQL.^7')
|
||||
InsertRecordsToSQL()
|
||||
else
|
||||
DebugPrint(string.format('^3[INFO]: Attempted to manually insert records but got source %s.^7', source))
|
||||
TriggerClientEvent('chat:addMessage', source, { args = { '^1Error', 'This command can only be executed from the console.' } })
|
||||
end
|
||||
end)
|
||||
|
||||
-----------------------------------------
|
||||
-- Main thread, every restart remove old records if needed, insert records every X minutes as defined by cfg.loggingInsertInterval.
|
||||
CreateThread(function()
|
||||
local insertWait = cfg.loggingInsertInterval * 60000
|
||||
if cfg.loggingCleanUpInterval ~= -1 then
|
||||
CleanUpRecordsFromSQL()
|
||||
end
|
||||
while true do
|
||||
InsertRecordsToSQL()
|
||||
Wait(insertWait)
|
||||
end
|
||||
end)
|
||||
|
||||
---------------- SETTER / INSERT ----------------
|
||||
-- Shared event handler colate all lidar data from all players for SQL submission.
|
||||
RegisterServerEvent('prolaser4:SendLogData')
|
||||
AddEventHandler('prolaser4:SendLogData', function(logData)
|
||||
local playerName = GetPlayerName(source)
|
||||
if not isInsertActive then
|
||||
for i, entry in ipairs(logData) do
|
||||
entry.player = playerName
|
||||
table.insert(LOGGED_EVENTS, entry)
|
||||
end
|
||||
else
|
||||
-- since the insertion is active, inserting now may result in lost data, store temporarily.
|
||||
for i, entry in ipairs(logData) do
|
||||
entry.player = playerName
|
||||
table.insert(TEMP_LOGGED_EVENTS, entry)
|
||||
end
|
||||
end
|
||||
end)
|
||||
|
||||
-- Inserts records to SQL table
|
||||
function InsertRecordsToSQL()
|
||||
if not isInsertActive then
|
||||
if #LOGGED_EVENTS > 0 then
|
||||
DebugPrint(string.format('^3[INFO]: Started inserting %s records.^7', #LOGGED_EVENTS))
|
||||
isInsertActive = true
|
||||
-- Execute the insert statement for each entry
|
||||
for _, entry in ipairs(LOGGED_EVENTS) do
|
||||
MySQL.insert(insertQuery, {entry.time, entry.speed, entry.range, entry.targetX, entry.targetY, entry.player, entry.street, entry.selfTestTimestamp}, function(returnData) end)
|
||||
end
|
||||
-- Remove processed records
|
||||
LOGGED_EVENTS = {}
|
||||
isInsertActive = false
|
||||
-- Copy over temp entries to be processed next run
|
||||
for _, entry in ipairs(TEMP_LOGGED_EVENTS) do
|
||||
table.insert(LOGGED_EVENTS, entry)
|
||||
end
|
||||
-- Remove copied over values.
|
||||
TEMP_LOGGED_EVENTS = {}
|
||||
DebugPrint('^3[INFO]: Finished inserting records.^7')
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
---------------- GETTER / SELECT ----------------
|
||||
-- C->S request all record data
|
||||
RegisterNetEvent('prolaser4:GetLogData')
|
||||
AddEventHandler('prolaser4:GetLogData', function()
|
||||
SelectRecordsFromSQL(source)
|
||||
end)
|
||||
|
||||
-- Get all record data and return to client
|
||||
function SelectRecordsFromSQL(source)
|
||||
DebugPrint(string.format('^3[INFO]: Getting records for %s.^7', GetPlayerName(source)))
|
||||
MySQL.query(selectQuery, {}, function(result)
|
||||
DebugPrint(string.format('^3[INFO]: Returned %s from select query.^7', #result))
|
||||
if result then
|
||||
TriggerClientEvent('prolaser4:ReturnLogData', source, result)
|
||||
end
|
||||
end)
|
||||
end
|
||||
|
||||
------------------ AUTO CLEANUP -----------------
|
||||
-- Remove old records after X days old.
|
||||
function CleanUpRecordsFromSQL()
|
||||
DebugPrint('^3[INFO]: Removing old records.^7');
|
||||
MySQL.query(cleanupQuery, {cfg.loggingCleanUpInterval}, function(returnData)
|
||||
DebugPrint(string.format('^3[INFO]: Removed %s records (older than %s days)^7', returnData.affectedRows, cfg.loggingCleanUpInterval));
|
||||
end)
|
||||
end
|
||||
|
||||
------------------ RECORD COUNT -----------------
|
||||
function GetRecordCount()
|
||||
local recordCount = '^8FAILED TO RETRIEVE ^7'
|
||||
MySQL.query(countQuery, {}, function(returnData)
|
||||
if returnData and returnData[1] and returnData[1]['COUNT(*)'] then
|
||||
recordCount = returnData[1]['COUNT(*)']
|
||||
end
|
||||
end)
|
||||
Wait(500)
|
||||
return recordCount
|
||||
end
|
||||
end
|
||||
|
||||
--[[------------ STARTUP / VERSION CHECKING -----------]]
|
||||
CreateThread( function()
|
||||
local currentVersion = semver(GetResourceMetadata(GetCurrentResourceName(), 'version', 0))
|
||||
local repoVersion = semver('0.0.0')
|
||||
local recordCount = 0
|
||||
|
||||
-- Get prolaser4 version from github
|
||||
PerformHttpRequest('https://raw.githubusercontent.com/TrevorBarns/ProLaser4/main/version', function(err, responseText, headers)
|
||||
if responseText ~= nil and responseText ~= '' then
|
||||
repoVersion = semver(responseText:gsub('\n', ''))
|
||||
end
|
||||
end)
|
||||
|
||||
if cfg.logging then
|
||||
if MySQL == nil then
|
||||
print('^3[WARNING]: logging enabled, but oxmysql not found. Did you uncomment the oxmysql\n\t\t lines in fxmanifest.lua?\n\n\t\t Remember, changes to fxmanifest are only loaded after running `refresh`, then `restart`.^7')
|
||||
recordCount = '^8NO CONNECTION^7'
|
||||
else
|
||||
recordCount = GetRecordCount()
|
||||
end
|
||||
end
|
||||
|
||||
Wait(1000)
|
||||
print('\n\t^7 _______________________________________________________')
|
||||
print('\t|^8 ____ __ __ __ ^7|')
|
||||
print('\t|^8 / __ \\_________ / / ____ ________ _____/ // / ^7|')
|
||||
print('\t|^8 / /_/ / ___/ __ \\/ / / __ `/ ___/ _ \\/ ___/ // /_ ^7|')
|
||||
print('\t|^8 / ____/ / / /_/ / /___/ /_/ (__ ) __/ / /__ __/ ^7|')
|
||||
print('\t|^8 /_/ /_/ \\____/_____/\\__,_/____/\\___/_/ /_/ ^7|')
|
||||
print('\t^7|_______________________________________________________|')
|
||||
print(('\t|\t INSTALLED: %-26s|'):format(currentVersion))
|
||||
print(('\t|\t LATEST: %-26s|'):format(repoVersion))
|
||||
if cfg.logging then
|
||||
if type(recordCount) == 'number' then
|
||||
print(('\t|\t RECORD COUNT: %-26s|'):format(recordCount))
|
||||
else
|
||||
print(('\t|\t RECORD COUNT: %-30s|'):format(recordCount))
|
||||
end
|
||||
end
|
||||
if currentVersion < repoVersion then
|
||||
print('\t^7|_______________________________________________________|')
|
||||
print('\t|\t ^8STABLE UPDATE AVAILABLE ^7|')
|
||||
print('\t|^8 DOWNLOAD AT: ^7|')
|
||||
print('\t|^5 github.com/TrevorBarns/ProLaser4/releases ^7|')
|
||||
end
|
||||
print('\t^7|_______________________________________________________|')
|
||||
print('\t^7| Updates, Support, Feedback: ^5discord.gg/PXQ4T8wB9 ^7|')
|
||||
print('\t^7|_______________________________________________________|\n\n')
|
||||
end)
|
||||
Loading…
Add table
Add a link
Reference in a new issue