joseph
/
Log_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Refactor code #1

Merged
joseph merged 3 commits from that into main 2025-04-09 17:17:23 +10:00
Conversation 0 Commits 3 Files Changed 16 +417 -516
16 changed files with 417 additions and 516 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.env.example
View File

@ -15,3 +15,5 @@ REDIS_CONNECTION=local
REDIS_HOST=127.0.0.1 REDIS_HOST=127.0.0.1
REDIS_PORT=6379 REDIS_PORT=6379
REDIS_PASSWORD= REDIS_PASSWORD=
BASE_URL_LOG="http://172.16.5.7:8080"
FOLDER_LOGS="/logs"

1
.gitignore vendored
View File

@ -8,3 +8,4 @@ app/utils/indexSN.txt
app/store app/store
tmp tmp
.npm .npm
logs

19
README.md
View File

@ -0,0 +1,19 @@
# BACK-END
### 1. Copy .env.example -> .env
### 2. npm install
### 3. node ace migration:run
### 4. npm run dev
# FRONT-END
### 1. cd manage-view
### 2. Copy .env.example -> .env
### 3. npm install
### 4. npm start

370
app/Controllers/Http/ErpsController.ts
View File

@ -1,6 +1,11 @@
import fs from "fs"; import fs from "fs";
import type { HttpContextContract } from "@ioc:Adonis/Core/HttpContext"; import type { HttpContextContract } from "@ioc:Adonis/Core/HttpContext";
import axios from "axios"; import axios from "axios";
import Env from "@ioc:Adonis/Core/Env";
const path = require("path");
const BASE_URL = Env.get("BASE_URL_LOG");
const BASE_URL_AUTO = Env.get(`${BASE_URL}/AUTOlog/`);
export default class ErpsController { export default class ErpsController {
/** /**
@ -17,10 +22,8 @@ export default class ErpsController {
try { try {
// console.log("check!") // console.log("check!")
const listLog: string[] = []; const listLog: string[] = [];
const response = await axios.get("http://172.16.5.7:8080/"); const response = await axios.get(BASE_URL);
const responseAUTO = await axios.get( const responseAUTO = await axios.get(BASE_URL_AUTO);
"http://172.16.5.7:8080/AUTOlog/"
);
let data1 = response.data let data1 = response.data
.split("\n") .split("\n")
@ -49,8 +52,8 @@ export default class ErpsController {
.slice(u.search("<a ") + 9, u.search("</a>")) .slice(u.search("<a ") + 9, u.search("</a>"))
.split(">")[1] .split(">")[1]
.includes("AUTO") .includes("AUTO")
? "http://172.16.5.7:8080/AUTOlog/" ? BASE_URL_AUTO
: "http://172.16.5.7:8080/") + : BASE_URL + "/") +
u.slice(u.search("<a ") + 9, u.search("</a>")).split(">")[1] + u.slice(u.search("<a ") + 9, u.search("</a>")).split(">")[1] +
" " " "
); );
@ -63,235 +66,156 @@ export default class ErpsController {
} }
}; };
const fetchWithRetry = async (url) => {
let retries = 0;
const MAX_RETRIES = 10;
while (retries < MAX_RETRIES) {
try {
const response = await axios.get(url);
return response.data;
} catch (error) {
if (error.code) {
retries++;
continue;
} else {
console.error("Error fetching file:", error);
return null;
}
}
}
return null;
};
const extractInfoFromLine = (line, index, fName) => {
const cleanedLine = line.replace(/\r/g, "");
const results: any = [];
const getWarehouse = (fileName) =>
/(US(?!A)|-US|\.US|US-)/.test(fileName) ? "US" : "AU";
const extractSN = (str) =>
str?.replace(/[!@#$%^&*()_+{}\[\]:;<>,.?~\\/]/g, "").trim();
// PID & SN
if (
cleanedLine.includes("PID:") &&
cleanedLine.includes("SN:") &&
!cleanedLine.includes("%")
) {
const parts = cleanedLine.split(",");
const SN = extractSN(
parts.find((p) => p.includes("SN:"))?.split(":")[1] ?? ""
);
const PID = extractSN(
parts.find((p) => p.includes("PID:"))?.split(":")[1] ?? ""
);
const VID = extractSN(
parts.find((p) => p.includes("VID:"))?.split(":")[1] ?? ""
);
if (SN && SN !== "N/A" && SN.length > 4) {
results.push({
PID,
VID,
SN,
line: [index + 1],
fileName: fName,
warehouse: getWarehouse(fName),
});
}
}
// Serial Number
if (cleanedLine.includes("Serial Number")) {
const PCB_SN = extractSN(cleanedLine.split(":")[1]);
if (PCB_SN) {
results.push({
PID: "",
VID: "",
SN: PCB_SN,
line: [index + 1],
fileName: fName,
warehouse: getWarehouse(fName),
});
}
}
// Processor board ID
if (cleanedLine.includes("Processor board ID")) {
const PBID = extractSN(cleanedLine.split(" ").pop());
if (PBID?.length >= 8) {
results.push({
PID: "",
VID: "",
SN: PBID,
line: [index + 1],
fileName: fName,
warehouse: getWarehouse(fName),
});
}
}
return results;
};
const mergeLines = (output, lineResult) => {
lineResult.forEach((entry) => {
const existing = output.find((o) => o.SN === entry.SN);
if (existing) {
existing.line = [...new Set([...existing.line, ...entry.line])];
if (entry.PID) existing.PID = entry.PID;
if (entry.VID) existing.VID = entry.VID;
} else {
output.push(entry);
}
});
};
const fetchFiles = async (from, to) => { const fetchFiles = async (from, to) => {
try { try {
const urls = await getListLog(from, to); const urls = await getListLog(from, to);
let report = []; if (!urls || urls.length === 0) {
console.log("No logs found");
return [];
}
const fileContents = await Promise.all( const fileContents = await Promise.all(
urls.map(async (url) => { urls.map((u) => fetchWithRetry(u?.split(" ")[0]))
const maxRetries = 10;
let retries = 0;
while (retries < maxRetries) {
try {
const response = await axios.get(url?.split(" ")[0]);
return response.data;
} catch (error) {
if (error.code !== "") {
//=== "ETIMEDOUT" || error.code === "ECONNRESET"
// console.log("Connection timed out. Retrying...");
retries++;
} else {
console.error("Error fetching file:", error);
return;
}
}
}
})
); );
// Handle the file contents let report: any = [];
fileContents.forEach((content, index) => { fileContents.forEach((content, index) => {
console.log(`Content of file ${index + 1}:`); const lines = content?.split("\n");
const arrayLine = content?.split("\n"); if (!lines) return;
let output = [];
if (arrayLine !== undefined) {
for (let i = 0; i < arrayLine.length; i++) {
let SN = arrayLine[i]
?.split("SN:")[1]
?.trim()
.replace(/[!@#$%^&*()_+{}\[\]:;<>,.?~\\/]/g, "");
if (
arrayLine[i].search("PID:") !== -1 &&
arrayLine[i].search("SN:") !== -1 &&
arrayLine[i].search("%") === -1 &&
arrayLine[i]
?.split(",")[2]
?.split(":")[1]
?.replace("\r", "")
.trim() !== "" &&
SN !== "N/A" && SN.length>4
) {
if (output.some((u) => u.SN === SN)) {
output.map((u, index) => {
if (u.SN === SN) {
output[index].PID =
arrayLine[i]?.split("VID:")[0] !== undefined
? arrayLine[i]
?.split("VID:")[0]
?.slice(
arrayLine[i]?.split("VID:")[0]?.search("PID")
)
?.split(":")[1]
?.split(",")[0]
?.trim()
: "";
(output[index].VID =
arrayLine[i]?.split("SN:")[0] !== undefined
? arrayLine[i]
?.split("SN:")[0]
?.split("VID:")[1]
?.split(",")[0]
?.trim()
: ""),
(output[index].line = output[index].line.concat([
i + 1,
]));
}
});
} else {
let fName = urls[index]
?.split("/")
[urls[index]?.split("/")?.length - 1]?.trim();
output.push({
PID:
arrayLine[i]?.split("VID:")[0] !== undefined
? arrayLine[i]
?.split("VID:")[0]
?.slice(
arrayLine[i]?.split("VID:")[0]?.search("PID")
)
?.split(":")[1]
?.split(",")[0]
?.trim()
: "",
VID:
arrayLine[i]?.split("SN:")[0] !== undefined
? arrayLine[i]
?.split("SN:")[0]
?.split("VID:")[1]
?.split(",")[0]
?.trim()
: "",
SN:
arrayLine[i].split("SN:")[1] !== undefined
? SN.search(" ") !== -1
? SN?.split(" ")[0]
: SN
: "",
line: [i + 1],
fileName: fName,
warehouse:
(fName.search("-US") !== -1 ||
fName.search(".US") !== -1 ||
fName.search("US-") !== -1) &&
fName.search("AUS") === -1
? "US"
: "AU",
});
}
}
if (arrayLine[i].search("Serial Number") !== -1) { const fName = path.basename(urls[index] ?? "").trim();
let PCB_SN = arrayLine[i] const output = [];
?.split("Serial Number")[1]
.split(":")[1]
?.replace("\r", "")
.trim()
.replace(/[!@#$%^&*()_+{}\[\]:;<>,.?~\\/]/g, "");
if (
//Neu SN da nam trong output
output.some((u) => u.SN === PCB_SN)
) {
output.map((u, index) => {
if (u.SN === PCB_SN) {
output[index].line = output[index].line.concat([i + 1]);
}
});
} else {
// if (
// /^[A-Z0-9-]{5,}$/.test(
// PCB_SN
// )
// ) {
let fName = urls[index]
?.split("/")
[urls[index]?.split("/")?.length - 1]?.trim();
output.push({
PID: "",
VID: "",
SN:
PCB_SN?.search(" ") !== -1
? PCB_SN?.split(" ")[0]
: PCB_SN,
line: [i + 1],
fileName: fName,
warehouse:
(fName.search("-US") !== -1 ||
fName.search(".US") !== -1 ||
fName.search("US-") !== -1) &&
fName.search("AUS") === -1
? "US"
: "AU",
});
// }
}
}
if (arrayLine[i].search("Processor board ID") !== -1) { lines.forEach((line, i) => {
let PBID = arrayLine[i] const lineResult = extractInfoFromLine(line, i, fName);
?.split(" ") mergeLines(output, lineResult);
[arrayLine[i]?.split(" ").length - 1]?.replace("\r", "") });
.trim()
.replace(/[!@#$%^&*()_+{}\[\]:;<>,.?~\\/]/g, ""); report = [...report, ...output];
if (
//Neu SN da nam trong output
output.some((u) => u.SN === PBID)
) {
output.map((u, index) => {
if (u.SN === PBID) {
output[index].line = output[index].line.concat([i + 1]);
}
});
} else {
if (PBID?.length >= 8) {
let fName = urls[index]
?.split("/")
[urls[index]?.split("/")?.length - 1]?.trim();
output.push({
PID: "",
VID: "",
SN: PBID?.search(" ") !== -1 ? PBID?.split(" ")[0] : PBID,
line: [i + 1],
fileName: fName,
warehouse:
(fName.search("-US") !== -1 ||
fName.search(".US") !== -1 ||
fName.search("US-") !== -1) &&
fName.search("AUS") === -1
? "US"
: "AU",
});
}
}
}
}
report = report.concat(output);
}
}); });
fs.writeFile( const finalReport = report.filter(
(i) => i.SN && /^[A-Z0-9-]{5,}$/.test(i.SN) && i.PID
);
fs.writeFileSync(
"./app/utils/indexSN.txt", "./app/utils/indexSN.txt",
JSON.stringify(report) JSON.stringify(finalReport, null, 2).replace(/\\u0000/g, ""),
.replace(/,{/g, "\n,{") "utf-8"
.replace(/\\u0000/g, ""),
function (err) {
if (err) {
return console.error(err);
}
console.log("Write loggg !");
}
); );
// console.log(report); console.log("Write loggg !");
return report.filter( return finalReport;
(i) => i.SN !== "" && /^[A-Z0-9-]{5,}$/.test(i.SN) === true && i.PID !==""
);
// }, 15000);
} catch (error) { } catch (error) {
response console.error("GET INFORMATION FAIL", error);
.status(500) throw error;
.send({ mess: "GET INFORMATION FAIL", error: error });
} }
}; };
const result = await fetchFiles(from, to); const result = await fetchFiles(from, to);
response.status(200).json(result); response.status(200).json(result);
} }
@ -309,10 +233,10 @@ export default class ErpsController {
try { try {
let fName = let fName =
fileName.search("AUTO") !== -1 ? "AUTOlog/" + fileName : fileName; fileName.search("AUTO") !== -1 ? "AUTOlog/" + fileName : fileName;
const res = await axios.get("http://172.16.5.7:8080/" + fName); const res = await axios.get(BASE_URL + "/" + fName);
const arrayLine = res?.data?.split("\n"); const arrayLine = res?.data?.split("\n");
if (range >= line) { if (Number(range) >= Number(line)) {
response.status(200).json({ response.status(200).json({
content: arrayLine?.slice(0, line + range)?.join("\n"), content: arrayLine?.slice(0, line + range)?.join("\n"),
}); });
@ -323,9 +247,7 @@ export default class ErpsController {
} }
} catch (error) { } catch (error) {
console.log(error); console.log(error);
response response.status(202).send({ mess: "FILE NOT FOUND", error: error });
.status(202)
.send({ mess: "FILE NOT FOUND", error: error });
} }
} }

223
app/Controllers/Http/LogsController.ts
View File

@ -1,162 +1,127 @@
import type { HttpContextContract } from '@ioc:Adonis/Core/HttpContext' import type { HttpContextContract } from "@ioc:Adonis/Core/HttpContext";
import Database from '@ioc:Adonis/Lucid/Database'; import Database from "@ioc:Adonis/Lucid/Database";
import KeyValue from 'App/Models/KeyValue'; import KeyValue from "App/Models/KeyValue";
import LogDetectFile from 'App/Models/LogDetectFile'; import LogDetectFile from "App/Models/LogDetectFile";
import axios from 'axios'; import axios from "axios";
import Env from "@ioc:Adonis/Core/Env";
import { checkSpecialVersion } from "App/utils/helper";
const BASE_URL = Env.get("BASE_URL_LOG");
export default class LogsController { export default class LogsController {
public async showLog({ request, response }: HttpContextContract) { public async showLog({ request, response }: HttpContextContract) {
try { try {
// fghf const fileName = request.params().name;
const checkSpecialVersion = (paragraph) => { const fileDetect = await LogDetectFile.findBy("file_name", fileName);
try {
const regex = /\(CAT[1-9]K.*Version 16\.9\.[2-9]/;
const regex1 =
/\(CAT[1-9]K.*Version 1[7-9]\.[0-9]\.[0-9]/;
const regex2 =
/\(CAT[1-9]K.*Version [2-9][0-9]\.[0-9]\.[0-9]/;
// Use the regular expression to find the match
const match = paragraph.match(regex);
const match1 = paragraph.match(regex1);
const match2 = paragraph.match(regex2);
if (match || match1 || match2) {
if (match) {
return match[0];
}
if (match1) { if (!fileDetect) {
return match1[0]; return response.status(203).send("FILE NOT FOUND");
} }
if (match2) { const logsDetect = await Database.rawQuery(
return match2[0]; "SELECT * FROM log_reports WHERE id_file = ?",
} [fileDetect.id_ldf]
} else {
return "";
}
} catch (error) {
console.log(error);
}
};
let fileDetect = await LogDetectFile.findBy(
"file_name",
request.params().name
);
let logsDetect = await Database.rawQuery(
"select * from log_reports where id_file = " + fileDetect?.id_ldf
); );
let modelSpecialDetected = []; const lines = [...new Set(logsDetect[0].map((obj) => obj.line))].sort(
let issueSpecialDetected = []; (a: number, b: number) => a - b
let listLine = logsDetect[0]
.map((obj) => obj.line)
.filter((value, index, self) => {
return self.indexOf(value) === index;
})
.sort((a, b) => a - b);
const content = await axios.get(
request.params().name.search("AUTO") !== -1
? "http://172.16.5.7:8080/AUTOlog/" + request.params().name
: "http://172.16.5.7:8080/" + request.params().name
);
let allValue = await KeyValue.all();
let listKeyValues = allValue.filter(
(i) =>
i.$original.key === "MODEL_SPECIAL" ||
i.$original.key === "CATCH_FAULTY"
); );
let MODEL_SPECIAL = allValue const logUrl = fileName.includes("AUTO")
.filter((i) => i.$original.key === "MODEL_SPECIAL") ? `${BASE_URL}/AUTOlog/${fileName}`
.map((obj) => obj.$original.value); : `${BASE_URL}/${fileName}`;
let listExcludeErr = allValue const content = await axios.get(logUrl);
.filter((i) => i.$original.key === "EXCLUDE_ERR") const allKeyValues = await KeyValue.all();
.map((obj) => obj.$original.value);
let data = content.data.split("\n"); const keyValueMap = allKeyValues.reduce((acc, { $original }) => {
data.map(async (line, index) => { acc[$original.key] = acc[$original.key] || [];
data[index] = index + 1 + "|-|" + line; acc[$original.key].push($original.value);
return acc;
}, {} as Record<string, string[]>);
if (checkSpecialVersion(line) !== "") { const MODEL_SPECIAL = keyValueMap["MODEL_SPECIAL"] || [];
const specialVersion = checkSpecialVersion(line) const CATCH_FAULTY = keyValueMap["CATCH_FAULTY"] || [];
data[index] = const EXCLUDE_ERR = keyValueMap["EXCLUDE_ERR"] || [];
data[index].slice(0, data[index].indexOf(specialVersion))
+ const rawData = content.data.split("\n");
const processedData: string[] = [];
const modelSpecialDetected: string[] = [];
const issueSpecialDetected: string[] = [];
for (let i = 0; i < rawData.length; i++) {
let line = rawData[i];
let numberedLine = `${i + 1}|-|${line}`;
const specialVersion = checkSpecialVersion(line);
if (specialVersion) {
const index = numberedLine.indexOf(specialVersion);
numberedLine =
numberedLine.slice(0, index) +
"|-|" + "|-|" +
specialVersion + specialVersion +
"|-|" + "|-|" +
data[index].slice(data[index].indexOf(specialVersion) + specialVersion.length); numberedLine.slice(index + specialVersion.length);
} }
listKeyValues for (const value of [...MODEL_SPECIAL, ...CATCH_FAULTY]) {
.map((obj) => obj.$original.value) if (
.map(async (value) => { line.includes(value) &&
if ( !EXCLUDE_ERR.some((err) => line.includes(err))
line.indexOf(value) !== -1 && ) {
listExcludeErr.filter((err) => line.includes(err)).length === 0 const index = numberedLine.indexOf(value);
) { numberedLine =
data[index] = numberedLine.slice(0, index) +
data[index].slice(0, data[index].indexOf(value)) + "|-|" +
"|-|" + value +
value + "|-|" +
"|-|" + numberedLine.slice(index + value.length);
data[index].slice(data[index].indexOf(value) + value.length); break;
// }
}
});
});
listLine.map(async (u) => {
if (
listExcludeErr.filter((err) => data[u - 1].includes(err)).length === 0
) {
if (MODEL_SPECIAL.filter((i) => data[u - 1].includes(i)).length > 0) {
modelSpecialDetected.push(data[u - 1]);
} else {
if (checkSpecialVersion(data[u - 1]) !== "") {
modelSpecialDetected.push(data[u - 1]);
} else {
issueSpecialDetected.push(data[u - 1]);
}
} }
} }
});
let modelSpecial = processedData.push(numberedLine);
modelSpecialDetected.length > 0 ? modelSpecialDetected.join("\n") : ""; }
let issueItem =
issueSpecialDetected.length > 0 ? issueSpecialDetected.join("\n") : ""; for (const lineIndex of lines) {
const line = processedData[Number(lineIndex) - 1];
if (!line) continue;
if (EXCLUDE_ERR.some((err) => line.includes(err))) continue;
if (
MODEL_SPECIAL.some((model) => line.includes(model)) ||
checkSpecialVersion(line)
) {
modelSpecialDetected.push(line);
} else {
issueSpecialDetected.push(line);
}
}
response.status(200).send({ response.status(200).send({
modelSpecial: modelSpecial, modelSpecial: modelSpecialDetected.join("\n"),
issueItem: issueItem, issueItem: issueSpecialDetected.join("\n"),
contentFile: data.join("\n"), contentFile: processedData.join("\n"),
}); });
} catch (error) { } catch (error) {
// console.error(error); console.error("Error fetching log:", error);
response.status(203).send("FILE NOT FOUND"); response.status(203).send("FILE NOT FOUND");
} }
} }
public async getAllLogDetect({ request, response }: HttpContextContract) { public async getAllLogDetect({ response }: HttpContextContract) {
try { try {
let fileDetect = await LogDetectFile.all(); const files = await LogDetectFile.all();
let listFiles = fileDetect.map((obj) => obj.file_name); const fileNames = files.map((file) => file.file_name);
response.status(200).send(listFiles); response.status(200).send(fileNames);
} catch (error) { } catch {
response.status(203).send("NO FILE"); response.status(203).send("NO FILE");
} }
} }
public async store({ }: HttpContextContract) { } public async store({}: HttpContextContract) {}
public async show({}: HttpContextContract) {}
public async show({ }: HttpContextContract) { } public async edit({}: HttpContextContract) {}
public async update({}: HttpContextContract) {}
public async edit({ }: HttpContextContract) { } public async destroy({}: HttpContextContract) {}
public async update({ }: HttpContextContract) { }
public async destroy({ }: HttpContextContract) { }
} }

4
app/Controllers/Http/UsersController.ts
View File

@ -23,7 +23,9 @@ export default class UsersController {
const data = await request.validate({ schema: userSchema }); const data = await request.validate({ schema: userSchema });
const user = await Users.create(data); const user = await Users.create(data);
return response.status(201).send({ mess: "REGISTER_SUCCESS" }); return response
.status(201)
.send({ mess: "REGISTER_SUCCESS", data: user });
} else { } else {
return response.status(203).send({ mess: "USERNAME EXIST" }); return response.status(203).send({ mess: "USERNAME EXIST" });
} }

4
app/Controllers/Http/ValuesController.ts
View File

@ -14,7 +14,7 @@ export default class ValuesController {
value: request.all().value, value: request.all().value,
model: "All", model: "All",
}); });
response.status(200).send("ADD VALUE SUCCESS!"); response.status(200).send({ mess: "ADD VALUE SUCCESS!", data: value });
} catch (error) { } catch (error) {
response.status(500).send("ADD VALUE FAIL!"); response.status(500).send("ADD VALUE FAIL!");
} }
@ -29,7 +29,7 @@ export default class ValuesController {
const value = await KeyValue.findOrFail(request.all().id); const value = await KeyValue.findOrFail(request.all().id);
value.value = request.all().value; value.value = request.all().value;
await value.save(); await value.save();
response.status(200).send("EDIT VALUE SUCCESS!"); response.status(200).send({ mess: "EDIT VALUE SUCCESS!", data: value });
} catch (error) { } catch (error) {
response.status(500).send("EDIT VALUE FAIL!"); response.status(500).send("EDIT VALUE FAIL!");
} }

16
app/utils/helper.ts Normal file
View File

@ -0,0 +1,16 @@
export const checkSpecialVersion = (paragraph: string): string => {
try {
const patterns = [
/\(CAT[1-9]K.*Version 16\.9\.[2-9]/,
/\(CAT[1-9]K.*Version 1[7-9]\.[0-9]\.[0-9]/,
/\(CAT[1-9]K.*Version [2-9][0-9]\.[0-9]\.[0-9]/,
];
for (const regex of patterns) {
const match = paragraph.match(regex);
if (match) return match[0];
}
return "";
} catch {
return "";
}
};

144
app/utils/runtimeCheckLogs.ts
View File

@ -9,9 +9,11 @@ import moment from "moment";
import { checkIndexSN } from "./checkIndexSN"; import { checkIndexSN } from "./checkIndexSN";
import { getListLineByItem } from "./getListLineByItem"; import { getListLineByItem } from "./getListLineByItem";
import { sendMessToZulip } from "./sendMessToZulip"; import { sendMessToZulip } from "./sendMessToZulip";
export async function runtimeCheckLogs(folderPath) { import { checkSpecialVersion } from "./helper";
export async function runtimeCheckLogs(folderPath: string) {
try { try {
let cacheFile = [] let cacheFile: any = [];
let fileList = Array(); let fileList = Array();
let fileList_old = Array(); let fileList_old = Array();
// Function to update the list of files // Function to update the list of files
@ -34,36 +36,6 @@ export async function runtimeCheckLogs(folderPath) {
}); });
} }
const checkSpecialVersion = (paragraph) => {
try {
const regex = /\(CAT[1-9]K.*Version 16\.9\.[2-9]/;
const regex1 =
/\(CAT[1-9]K.*Version 1[7-9]\.[0-9]\.[0-9]/;
const regex2 =
/\(CAT[1-9]K.*Version [2-9][0-9]\.[0-9]\.[0-9]/;
// Use the regular expression to find the match
const match = paragraph.match(regex);
const match1 = paragraph.match(regex1);
const match2 = paragraph.match(regex2);
if (match || match1 || match2) {
if (match) {
return match[0];
}
if (match1) {
return match1[0];
}
if (match2) {
return match2[0];
}
} else {
return "";
}
} catch (error) {
console.log(error);
}
};
// Watch the folder for new files // Watch the folder for new files
const folderWatcher = chokidar.watch(folderPath); const folderWatcher = chokidar.watch(folderPath);
@ -73,9 +45,9 @@ export async function runtimeCheckLogs(folderPath) {
if ( if (
filePath?.split(".")[filePath.split(".").length - 1] === "log" && filePath?.split(".")[filePath.split(".").length - 1] === "log" &&
filePath.split("/")[filePath.split("/").length - 1]?.split("-")[0] === filePath.split("/")[filePath.split("/").length - 1]?.split("-")[0] ===
//localhost //localhost
// filePath.split("\\")[filePath.split("\\").length - 1]?.split("-")[0] === // filePath.split("\\")[filePath.split("\\").length - 1]?.split("-")[0] ===
moment(Date.now()).format("YYYYMMDD").toString() moment(Date.now()).format("YYYYMMDD").toString()
) { ) {
//add information file to database //add information file to database
console.log("New file added: ", filePath); console.log("New file added: ", filePath);
@ -102,7 +74,9 @@ export async function runtimeCheckLogs(folderPath) {
try { try {
//only check new file ---> fileList - fileList_old = new file //only check new file ---> fileList - fileList_old = new file
let listFileWatch = fileList let listFileWatch = fileList
?.filter((i) => fileList_old.includes(i) === false && i.includes(".log")) ?.filter(
(i) => fileList_old.includes(i) === false && i.includes(".log")
)
.map((file) => folderPath + "/" + file); .map((file) => folderPath + "/" + file);
const watcher = chokidar.watch(listFileWatch, { const watcher = chokidar.watch(listFileWatch, {
persistent: true, persistent: true,
@ -119,7 +93,7 @@ export async function runtimeCheckLogs(folderPath) {
const fileName = path.split("/")[path.split("/").length - 1]; const fileName = path.split("/")[path.split("/").length - 1];
// const fileName = path.split("\\")[path.split("\\").length - 1]; // const fileName = path.split("\\")[path.split("\\").length - 1];
const filePath = path; const filePath = path;
let lines = []; let lines: any = [];
const today = DateTime.now().toFormat("yyyy-MM-dd"); const today = DateTime.now().toFormat("yyyy-MM-dd");
let allFile = await LogDetectFile.query().whereRaw( let allFile = await LogDetectFile.query().whereRaw(
`DATE(created_at) = ?`, `DATE(created_at) = ?`,
@ -132,7 +106,11 @@ export async function runtimeCheckLogs(folderPath) {
[today] [today]
); );
cacheFile = cacheFile.concat(allFile.filter(obj2 => !cacheFile.some(obj1 => obj1.id_ldf === obj2.id_ldf))); cacheFile = cacheFile.concat(
allFile.filter(
(obj2) => !cacheFile.some((obj1) => obj1.id_ldf === obj2.id_ldf)
)
);
//get information file //get information file
let fileDetect = allFile?.filter( let fileDetect = allFile?.filter(
@ -198,13 +176,10 @@ export async function runtimeCheckLogs(folderPath) {
report.$original.detected_content === value report.$original.detected_content === value
); );
if ( if (!log?.id_ldf) {
log?.id_ldf === "" || let logBackup = cacheFile.filter(
log?.id_ldf === null || (i) => i.file_name === fileName
log?.id_ldf === undefined )[0];
) {
let logBackup = cacheFile.filter((i) => i.file_name === fileName)[0]
if (logBackup !== undefined) { if (logBackup !== undefined) {
let checkLog2 = allReport?.filter( let checkLog2 = allReport?.filter(
(report) => (report) =>
@ -221,7 +196,7 @@ export async function runtimeCheckLogs(folderPath) {
lines.push(index + 1); lines.push(index + 1);
} }
} else { } else {
console.log("ERROR CHECK ", fileName) console.log("ERROR CHECK ", fileName);
} }
} }
if (checkLog?.length === 0) { if (checkLog?.length === 0) {
@ -233,24 +208,19 @@ export async function runtimeCheckLogs(folderPath) {
lines.push(index + 1); lines.push(index + 1);
} }
} }
}); });
if ( if (
checkSpecialVersion(line) !== "" && checkSpecialVersion(line) !== "" &&
listExcludeErr.filter((err) => line.includes(err)).length === listExcludeErr.filter((err) => line.includes(err)).length ===
0 0
) { ) {
let checkVersion = checkSpecialVersion(line); let checkVersion = checkSpecialVersion(line);
let log = allFile?.filter( let log = allFile?.filter(
(i) => i.$original.file_name === fileName (i) => i.$original.file_name === fileName
)[0]; )[0];
if ( if (!log?.id_ldf) {
log?.id_ldf === "" || console.log("ERROR CHECK ", fileName);
log?.id_ldf === null ||
log?.id_ldf === undefined
) {
console.log("ERROR CHECK ", fileName)
} }
let checkLog = allReport?.filter( let checkLog = allReport?.filter(
(report) => (report) =>
@ -276,7 +246,6 @@ export async function runtimeCheckLogs(folderPath) {
listKeyValues listKeyValues
.map((obj) => obj.$original.value) .map((obj) => obj.$original.value)
.map(async (value) => { .map(async (value) => {
if ( if (
line.includes(value) && line.includes(value) &&
listExcludeErr.filter((err) => line.includes(err)) listExcludeErr.filter((err) => line.includes(err))
@ -285,12 +254,8 @@ export async function runtimeCheckLogs(folderPath) {
let log = allFile?.filter( let log = allFile?.filter(
(i) => i.$original.file_name === fileName (i) => i.$original.file_name === fileName
)[0]; )[0];
if ( if (!log?.id_ldf) {
log?.id_ldf === "" || console.log("ERROR CHECK ", fileName);
log?.id_ldf === null ||
log?.id_ldf === undefined
) {
console.log("ERROR CHECK ", fileName)
} }
let checkLog = allReport?.filter( let checkLog = allReport?.filter(
(report) => (report) =>
@ -320,12 +285,8 @@ export async function runtimeCheckLogs(folderPath) {
let log = allFile?.filter( let log = allFile?.filter(
(i) => i.$original.file_name === fileName (i) => i.$original.file_name === fileName
)[0]; )[0];
if ( if (!log?.id_ldf) {
log?.id_ldf === "" || console.log("ERROR CHECK ", fileName);
log?.id_ldf === null ||
log?.id_ldf === undefined
) {
console.log("ERROR CHECK ", fileName)
} }
let checkLog = allReport?.filter( let checkLog = allReport?.filter(
(report) => (report) =>
@ -355,10 +316,10 @@ export async function runtimeCheckLogs(folderPath) {
} else { } else {
console.log( console.log(
fileName + fileName +
"has changed(" + "has changed(" +
contentFile.length + contentFile.length +
") ---SOS---" + ") ---SOS---" +
lines.length lines.length
); );
let allReport_new = await LogReport.query().whereRaw( let allReport_new = await LogReport.query().whereRaw(
`DATE(created_at) = ?`, `DATE(created_at) = ?`,
@ -374,7 +335,7 @@ export async function runtimeCheckLogs(folderPath) {
); );
//Get all report newest //Get all report newest
let listReport = await getListLineByItem( let listReport: any = await getListLineByItem(
logsDetect logsDetect
.map((obj) => obj.$original) .map((obj) => obj.$original)
.filter((l) => l.line > lastLine) .filter((l) => l.line > lastLine)
@ -403,12 +364,12 @@ export async function runtimeCheckLogs(folderPath) {
contentFile[line - 1]?.replace( contentFile[line - 1]?.replace(
log.detected_content, log.detected_content,
"[" + "[" +
log.detected_content + log.detected_content +
"](https://logs.danielvu.com/logs/" + "](https://logs.danielvu.com/logs/" +
fileName + fileName +
"#" + "#" +
line + line +
")" ")"
); );
}); });
content = content =
@ -428,25 +389,30 @@ export async function runtimeCheckLogs(folderPath) {
")\n"; ")\n";
}); });
let icon = "" let icon = "";
if (checkSpecialVersion(content) !== "" || important.filter((i) => content.includes(i)).length > 0) { if (
icon += "------------\n\n:no_entry: :no_entry:**" + checkSpecialVersion(content) !== "" ||
important.filter((i) => content.includes(i)).length > 0
) {
icon +=
"------------\n\n:no_entry: :no_entry:**" +
fileName + fileName +
"**:no_entry: :no_entry:" "**:no_entry: :no_entry:";
} else { } else {
icon += "------------\n\n:warning: :warning: **" + fileName + "**"; icon +=
"------------\n\n:warning: :warning: **" + fileName + "**";
} }
sendMessToZulip( sendMessToZulip(
"stream", "stream",
Env.get("ZULIP_STREAM_ALERT"), Env.get("ZULIP_STREAM_ALERT"),
Env.get("ZULIP_TOPIC_ALERT"), Env.get("ZULIP_TOPIC_ALERT"),
icon + icon +
"\n\n" + "\n\n" +
content + content +
"\n\n" + "\n\n" +
spoiler + spoiler +
"\n\n***Issue found:***\n" + "\n\n***Issue found:***\n" +
issueFound issueFound
); );
} }
}, 3000); }, 3000);

61
app/utils/sendDeviceInfor.ts
View File

@ -20,8 +20,8 @@ export const sendDeviceInfora = async () => {
.filter((i) => i.$attributes.key === "MEMORY_DEFAULT") .filter((i) => i.$attributes.key === "MEMORY_DEFAULT")
.map((obj) => obj.$attributes.value); .map((obj) => obj.$attributes.value);
console.log(memDefault) console.log(memDefault);
let listInformation = []; let listInformation: any = [];
let dataFile = await LogDetectFile.all(); let dataFile = await LogDetectFile.all();
let html = ""; let html = "";
@ -53,13 +53,13 @@ export const sendDeviceInfora = async () => {
} else { } else {
//Array line //Array line
const lines = data?.split("\n"); const lines = data?.split("\n");
const linesInventory = []; const linesInventory: any = [];
let DBFileCheck = dataFile.filter( let DBFileCheck = dataFile.filter(
(i) => i.$attributes.file_name === file (i) => i.$attributes.file_name === file
)[0]; )[0];
if (DBFileCheck !== undefined) { if (DBFileCheck !== undefined) {
if (lines.length > DBFileCheck?.$extras.last_check_SN) { if (lines.length > DBFileCheck?.$extras.last_check_SN) {
const DBFile = await LogDetectFile.find( const DBFile: any = await LogDetectFile.find(
DBFileCheck?.$attributes.id_ldf DBFileCheck?.$attributes.id_ldf
); );
@ -91,13 +91,13 @@ export const sendDeviceInfora = async () => {
//cut content with content1 = [linesInventory[index],linesInventory[index+1]] ... //cut content with content1 = [linesInventory[index],linesInventory[index+1]] ...
linesInventory?.map((line, index) => { linesInventory?.map((line, index) => {
const deviceContent = lines?.slice( const deviceContent: any = lines?.slice(
linesInventory[index], linesInventory[index],
linesInventory[index + 1] linesInventory[index + 1]
); );
let backgroundColor = "rgb(200 200 200 / 30%)"; let backgroundColor = "rgb(200 200 200 / 30%)";
const showInventory = []; const showInventory: any = [];
let check = true; let check = true;
let begin = 0; let begin = 0;
let end = 4; let end = 4;
@ -195,36 +195,38 @@ export const sendDeviceInfora = async () => {
(line) => (line) =>
line.includes("bytes of memory") || line.includes("bytes of memory") ||
line.includes("bytes of physical memory") line.includes("bytes of physical memory")
) );
const mathches = stringMem[0]?.match(regexSPE) const mathches = stringMem[0]?.match(regexSPE);
if(mathches && stringMem[0]?.includes("CHASSIS")){ if (mathches && stringMem[0]?.includes("CHASSIS")) {
console.log(mathches) console.log(mathches);
memDefaultForPID = memDefaultForPID =
memDefault.filter((i) => memDefault.filter((i) =>
mathches[0].trim().includes(i.split(":")[0]) mathches[0].trim().includes(i.split(":")[0])
)[0] !== undefined )[0] !== undefined
? memDefault.filter((i) => ? memDefault.filter((i) =>
mathches[0].trim().includes(i.split(":")[0]) mathches[0].trim().includes(i.split(":")[0])
)[0] )[0]
: mathches[0].trim() + ":N/A:N/A"; : mathches[0].trim() + ":N/A:N/A";
PID = mathches[0].trim(); PID = mathches[0].trim();
SN = showInventoryContent.filter((i)=>i.includes(mathches[0].trim()))[0]?.split("SN:")[1]?.replace(/,/g, "").trim(); SN = showInventoryContent
VID = showInventoryContent.filter((i)=>i.includes(mathches[0].trim()))[0]?.split("VID:")[1] .filter((i) => i.includes(mathches[0].trim()))[0]
?.split("SN:")[1]
?.replace(/,/g, "")
.trim();
VID = showInventoryContent
.filter((i) => i.includes(mathches[0].trim()))[0]
?.split("VID:")[1]
?.split("SN:")[0] ?.split("SN:")[0]
?.replace(/,/g, "") ?.replace(/,/g, "")
.trim(); .trim();
} }
let RAM = let RAM =
stringMem stringMem.join("<br>").match(regexMemory) !== null
.join("<br>")
.match(regexMemory) !== null
? ( ? (
parseInt( parseInt(
stringMem stringMem.join("<br>").match(regexMemory)[0]
.join("<br>")
.match(regexMemory)[0]
) / ) /
1024 / 1024 /
1024 1024
@ -312,14 +314,18 @@ export const sendDeviceInfora = async () => {
let specialModel = allKeyValue let specialModel = allKeyValue
.filter((i) => i.key === "MODEL_SPECIAL") .filter((i) => i.key === "MODEL_SPECIAL")
.map((obj) => obj.$attributes.value); .map((obj) => obj.$attributes.value);
let pattern = /[\x00-\x20\x7F]/g; let pattern = /[\x00-\x20\x7F]/g;
listInformation = listInformation.filter((i)=>i.PID.match(pattern)===null) listInformation = listInformation.filter(
(i) => i.PID.match(pattern) === null
);
listInformation = listInformation.filter( listInformation = listInformation.filter(
(i) => (i) =>
i.RAM !== "" || i.RAM !== "" ||
i.flash !== "" || i.flash !== "" ||
specialModel.filter((m) => i.PID.includes(m)).length > 0 specialModel.filter((m) => i.PID.includes(m)).length > 0
); );
//Check if listInformation has data
if (listInformation.length > 0) { if (listInformation.length > 0) {
console.log(listInformation); console.log(listInformation);
listInformation.map((inf) => { listInformation.map((inf) => {
@ -352,13 +358,16 @@ export const sendDeviceInfora = async () => {
"</tbody>\ "</tbody>\
</table>", </table>",
}; };
//Send mail
transporter.sendMail(options); transporter.sendMail(options);
await InfoDevice.createMany(listInformation); await InfoDevice.createMany(listInformation);
//Write log
const fileName = const fileName =
"./app/store/logsAPI/" + "./app/store/logsAPI/" +
moment(Date.now()).format("DD_MM_YYYY").toString() + moment(Date.now()).format("DD_MM_YYYY").toString() +
".log"; ".log";
addLogFunction( addLogFunction(
fileName, fileName,
JSON.stringify(listInformation[0], null, 2), JSON.stringify(listInformation[0], null, 2),

3
database/migrations/1692586422677_users.ts
View File

@ -9,8 +9,7 @@ export default class extends BaseSchema {
table.string("username", 50).notNullable(); table.string("username", 50).notNullable();
table.string("password", 300).notNullable(); table.string("password", 300).notNullable();
table.timestamp("created_at", { useTz: true }); table.timestamps(true, true);
table.timestamp("updated_at", { useTz: true });
}); });
} }

23
database/migrations/1692588201278_key_values.ts
View File

@ -1,23 +1,22 @@
import BaseSchema from '@ioc:Adonis/Lucid/Schema' import BaseSchema from "@ioc:Adonis/Lucid/Schema";
export default class extends BaseSchema { export default class extends BaseSchema {
protected tableName = 'key_values' protected tableName = "key_values";
public async up () { public async up() {
this.schema.createTable(this.tableName, (table) => { this.schema.createTable(this.tableName, (table) => {
table.increments('id_key').primary() table.increments("id_key").primary();
table.string("key", 100).notNullable() table.string("key", 100).notNullable();
table.string("value", 200).notNullable() table.string("value", 200).notNullable();
table.string("model", 30).notNullable().defaultTo("All") table.string("model", 30).notNullable().defaultTo("All");
/** /**
* Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL * Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL
*/ */
table.timestamp('created_at', { useTz: true }) table.timestamps(true, true);
table.timestamp('updated_at', { useTz: true }) });
})
} }
public async down () { public async down() {
this.schema.dropTable(this.tableName) this.schema.dropTable(this.tableName);
} }
} }

19
database/migrations/1692588436912_log_detect_files.ts
View File

@ -1,21 +1,20 @@
import BaseSchema from '@ioc:Adonis/Lucid/Schema' import BaseSchema from "@ioc:Adonis/Lucid/Schema";
export default class extends BaseSchema { export default class extends BaseSchema {
protected tableName = 'log_detect_files' protected tableName = "log_detect_files";
public async up () { public async up() {
this.schema.createTable(this.tableName, (table) => { this.schema.createTable(this.tableName, (table) => {
table.increments('id_ldf').primary() table.increments("id_ldf").primary();
table.string("file_name", 100).notNullable() table.string("file_name", 100).notNullable();
/** /**
* Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL * Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL
*/ */
table.timestamp('created_at', { useTz: true }) table.timestamps(true, true);
table.timestamp('updated_at', { useTz: true }) });
})
} }
public async down () { public async down() {
this.schema.dropTable(this.tableName) this.schema.dropTable(this.tableName);
} }
} }

23
database/migrations/1692588646452_log_reports.ts
View File

@ -1,24 +1,23 @@
import BaseSchema from '@ioc:Adonis/Lucid/Schema' import BaseSchema from "@ioc:Adonis/Lucid/Schema";
export default class extends BaseSchema { export default class extends BaseSchema {
protected tableName = 'log_reports' protected tableName = "log_reports";
public async up () { public async up() {
this.schema.createTable(this.tableName, (table) => { this.schema.createTable(this.tableName, (table) => {
table.increments('id_report').primary() table.increments("id_report").primary();
table.string("detected_content", 200).notNullable() table.string("detected_content", 200).notNullable();
table.integer("line", 6).notNullable() table.integer("line", 6).notNullable();
table.integer("id_file").notNullable() table.integer("id_file").notNullable();
/** /**
* Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL * Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL
*/ */
table.timestamp('created_at', { useTz: true }) table.timestamps(true, true);
table.timestamp('updated_at', { useTz: true }) });
})
} }
public async down () { public async down() {
this.schema.dropTable(this.tableName) this.schema.dropTable(this.tableName);
} }
} }

17
database/migrations/1696904362937_info_devices.ts
View File

@ -1,21 +1,20 @@
import BaseSchema from '@ioc:Adonis/Lucid/Schema' import BaseSchema from "@ioc:Adonis/Lucid/Schema";
export default class extends BaseSchema { export default class extends BaseSchema {
protected tableName = 'info_devices' protected tableName = "info_devices";
public async up () { public async up() {
this.schema.createTable(this.tableName, (table) => { this.schema.createTable(this.tableName, (table) => {
table.increments('id') table.increments("id");
/** /**
* Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL * Uses timestamptz for PostgreSQL and DATETIME2 for MSSQL
*/ */
table.timestamp('created_at', { useTz: true }) table.timestamps(true, true);
table.timestamp('updated_at', { useTz: true }) });
})
} }
public async down () { public async down() {
this.schema.dropTable(this.tableName) this.schema.dropTable(this.tableName);
} }
} }

4
manage-view/.env.example Normal file
View File

@ -0,0 +1,4 @@
PORT=3000
HOST=0.0.0.0
NODE_ENV=development
REACT_APP_API_SERVER_ADDRESS="http://127.0.0.1:3333/api"