mirror/Checkmate
1
0
Fork 0
mirror of https://github.com/bluewave-labs/Checkmate.git synced 2026-01-05 09:19:45 -06:00
Code Issues Packages Projects Releases Wiki Activity

Added formating.

Browse Source
This commit is contained in:
Owaise Imdad
2025-06-18 23:30:39 +05:30
parent 0f298d6450
commit 8fe3ed9bd1
2 changed files with 63 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
server/db/models/NetworkCheck.js
View File

@@ -2,45 +2,45 @@ import mongoose from "mongoose";
import { BaseCheckSchema } from "./Check.js";
const networkInterfaceSchema = mongoose.Schema({
name: { type: String, required: true },
bytes_sent: { type: Number, default: 0 },
bytes_recv: { type: Number, default: 0 },
packets_sent: { type: Number, default: 0 },
packets_recv: { type: Number, default: 0 },
err_in: { type: Number, default: 0 },
err_out: { type: Number, default: 0 },
drop_in: { type: Number, default: 0 },
drop_out: { type: Number, default: 0 },
fifo_in: { type: Number, default: 0 },
fifo_out: { type: Number, default: 0 }
name: { type: String, required: true },
bytes_sent: { type: Number, default: 0 },
bytes_recv: { type: Number, default: 0 },
packets_sent: { type: Number, default: 0 },
packets_recv: { type: Number, default: 0 },
err_in: { type: Number, default: 0 },
err_out: { type: Number, default: 0 },
drop_in: { type: Number, default: 0 },
drop_out: { type: Number, default: 0 },
fifo_in: { type: Number, default: 0 },
fifo_out: { type: Number, default: 0 },
});
const captureSchema = mongoose.Schema({
version: { type: String, default: "" },
mode: { type: String, default: "" }
version: { type: String, default: "" },
mode: { type: String, default: "" },
});
const NetworkCheckSchema = mongoose.Schema(
{
...BaseCheckSchema.obj,
data: {
type: [networkInterfaceSchema],
default: () => []
},
capture: {
type: captureSchema,
default: () => ({})
},
errors: {
type: mongoose.Schema.Types.Mixed,
default: null
}
},
{ timestamps: true }
{
...BaseCheckSchema.obj,
data: {
type: [networkInterfaceSchema],
default: () => [],
},
capture: {
type: captureSchema,
default: () => ({}),
},
errors: {
type: mongoose.Schema.Types.Mixed,
default: null,
},
},
{ timestamps: true }
);
NetworkCheckSchema.index({ createdAt: 1 });
NetworkCheckSchema.index({ monitorId: 1, createdAt: 1 });
NetworkCheckSchema.index({ monitorId: 1, createdAt: -1 });
export default mongoose.model("NetworkCheck", NetworkCheckSchema);
export default mongoose.model("NetworkCheck", NetworkCheckSchema);

69
server/db/mongo/modules/networkCheckModule.js
View File

@@ -4,46 +4,43 @@ import logger from "../../../utils/logger.js";
const SERVICE_NAME = "networkCheckModule";
const createNetworkCheck = async (networkCheckData) => {
try {
const { monitorId, status } = networkCheckData;
const n = (await NetworkCheck.countDocuments({ monitorId })) + 1;
try {
const { monitorId, status } = networkCheckData;
const n = (await NetworkCheck.countDocuments({ monitorId })) + 1;
const networkCheck = await new NetworkCheck({
...networkCheckData,
n,
});
const networkCheck = await new NetworkCheck({
...networkCheckData,
n,
});
await networkCheck.save();
return networkCheck;
} catch (error) {
logger.error({
message: error.message,
service: SERVICE_NAME,
method: "createNetworkCheck",
stack: error.stack,
});
throw error;
}
await networkCheck.save();
return networkCheck;
} catch (error) {
logger.error({
message: error.message,
service: SERVICE_NAME,
method: "createNetworkCheck",
stack: error.stack,
});
throw error;
}
};
const getNetworkChecksByMonitorId = async (monitorId, limit = 100) => {
try {
const networkChecks = await NetworkCheck.find({ monitorId })
.sort({ createdAt: -1 })
.limit(limit);
return networkChecks;
} catch (error) {
logger.error({
message: error.message,
service: SERVICE_NAME,
method: "getNetworkChecksByMonitorId",
stack: error.stack,
});
throw error;
}
try {
const networkChecks = await NetworkCheck.find({ monitorId })
.sort({ createdAt: -1 })
.limit(limit);
return networkChecks;
} catch (error) {
logger.error({
message: error.message,
service: SERVICE_NAME,
method: "getNetworkChecksByMonitorId",
stack: error.stack,
});
throw error;
}
};
export {
createNetworkCheck,
getNetworkChecksByMonitorId,
};
export { createNetworkCheck, getNetworkChecksByMonitorId };