feat: add qbx_management event logging integration

config.json

@@ -27,6 +27,10 @@
 		"oxInventoryEvents": {
 			"enabled": true,
 			"dataset": "default"
+		},
+		"qbxManagementEvents": {
+			"enabled": false,
+			"dataset": "default"
 		}
 	}
 }

config.schema.json

@@ -132,6 +132,23 @@
 					}
 				},
 				"default": { "enabled": false, "dataset": "default" }
+			},
+			"qbxManagementEvents": {
+				"description": "qbx_management job/gang management events configuration.",
+				"type": "object",
+				"properties": {
+					"enabled": {
+						"description": "Enable qbx_management events to be logged.",
+						"type": "boolean",
+						"default": false
+					},
+					"dataset": {
+						"description": "Dataset to use for qbx_management events.",
+						"type": "string",
+						"default": "default"
+					}
+				},
+				"default": { "enabled": false, "dataset": "default" }
 			}
 			},
 			"required": [
@@ -144,7 +161,8 @@
 				"playerEvents",
 				"chatEvents",
 				"txAdminEvents",
-				"oxInventoryEvents"
+				"oxInventoryEvents",
+				"qbxManagementEvents"
 			]
 		}
 	},

features/logs/server/logger.ts

@@ -20,6 +20,7 @@ import './chat';
 import './txadmin'
 import './baseevents'
 import './third-party/ox-inventory'
+import './third-party/qbx-management'
 
 const levels = config.logs.levels.reduce<Record<string, number>>(
 	(acc, curr, idx) => {

features/logs/server/third-party/qbx-management.ts

@@ -0,0 +1,65 @@
+import { ingest } from "../logger";
+import { config } from "~/utils/common/config";
+
+if (config.logs.qbxManagementEvents.enabled) {
+	const dataset = config.logs.qbxManagementEvents.dataset;
+
+	onNet("QBCore:Server:OnPlayerLoaded", () => {
+		const _source = global.source;
+
+		ingest(dataset, "info", "qbx_management.player.loaded", {
+			playerSource: _source,
+			playerName: GetPlayerName(_source.toString()),
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+
+	on("QBCore:Server:OnPlayerUnload", () => {
+		const source = global.source;
+
+		ingest(dataset, "info", "qbx_management.player.unloaded", {
+			playerSource: source,
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+
+	on("QBCore:Server:SetDuty", (source: number, duty: boolean) => {
+		ingest(dataset, "info", duty ? "qbx_management.player.clockedIn" : "qbx_management.player.clockedOut", {
+			playerSource: source,
+			playerName: GetPlayerName(source.toString()),
+			onDuty: duty,
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+
+	on("QBCore:Server:OnJobUpdate", (source: number, job: unknown) => {
+		ingest(dataset, "info", "qbx_management.player.jobUpdated", {
+			playerSource: source,
+			playerName: GetPlayerName(source.toString()),
+			job,
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+
+	on("qbx_core:server:onJobUpdate", (jobName: string, job: unknown) => {
+		ingest(dataset, "info", "qbx_management.job.definitionUpdated", {
+			jobName,
+			job,
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+
+	on("qbx_core:server:onGangUpdate", (gangName: string, gang: unknown) => {
+		ingest(dataset, "info", "qbx_management.gang.definitionUpdated", {
+			gangName,
+			gang,
+		}, {
+			_internal_RESOURCE: "qbx_management",
+		});
+	});
+}

features/utils/common/config.ts

@@ -29,6 +29,7 @@ const ConfigSchema = object({
 		chatEvents: EventConfigSchema,
 		txAdminEvents: EventConfigSchema,
 		oxInventoryEvents: EventConfigSchema,
+		qbxManagementEvents: EventConfigSchema,
 	}),
 });