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

update format message zulip

This commit is contained in:
joseph le 2023-09-18 10:38:12 +07:00
parent 613eb22614
commit 425ca91172
8 changed files with 149 additions and 2139 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/store/logs/20230912-fjghsk.log
View File

@ -1,2 +0,0 @@
sdfgsdfg
sdf

7
app/store/logs/20230918-TESTLOG.log Normal file
View File

@ -0,0 +1,7 @@
adfasf
anfasll ak shflks as klhfalk la EHWIC- fsjl
123 PVDM3- hui 800G2-POE-2
sdhgksd sjk hk error
abc 123 fail
abc 123 fail
sdhgksd sjk hk error

15
app/store/logs/abc.log
View File

@ -1,15 +0,0 @@
WS-X68
WS-X68
WS-X68
WS-X68
WS-X68
SM-
SM-
SM-
WS-X68
WS-X68
WS-X68
yellow
SM-
WS-X68
fksdfk trace ak

236
app/store/logs/sdsdfjk.log
View File

@ -1,236 +0,0 @@
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err
set_radius_extended_configsdf
set_radius_extended_configsdfsdf
fsdsdfsf
xe xich low
set_radius_extended_configsdfsdfdfhfg
fghgf
fghgfdfjgdfkjgerr
dfhkhjh
cong hoa xa hoi chu nghia
djgkdbsk
dfhjđhd
error
con co be begkklg
dhmkfhd
err
dfkbdfnlkbndflbd
trace
err
fault
err
trace
set_radius_extended_configsdfsdfdfhfg err

1753
app/store/logs/test.log
View File

File diff suppressed because it is too large Load Diff

147
app/utils/runtimeCheckLogs.ts
View File

@ -79,7 +79,7 @@ export async function runtimeCheckLogs(folderPath) {
const filePath = `${folderPath}/${fileName}`;
const scan = fs.watchFile(
filePath,
{ interval: 10000 },
{ interval: 300000 },
async (eventType) => {
//check special item, extra RAM, error in log
let lines = [];
@ -94,11 +94,10 @@ export async function runtimeCheckLogs(folderPath) {
);
let lastLine = Math.max(...logsDetect[0].map((obj) => obj.line));
let content = await fs
let contentFile = await fs
.readFileSync(filePath)
.toString()
?.split("\n")
.slice();
?.split("\n");
let allValue = await KeyValue.all();
let listKeyValues = allValue.filter(
@ -115,7 +114,7 @@ export async function runtimeCheckLogs(folderPath) {
.filter((i) => i.$original.key === "MODEL_SPECIAL")
.map((obj) => obj.$original.value);
content.map((line, index) => {
contentFile.map((line, index) => {
listKeyValues
.map((obj) => obj.$original.value)
.map(async (value) => {
@ -176,72 +175,78 @@ export async function runtimeCheckLogs(folderPath) {
"select * from log_reports where id_file = " +
fileDetect?.id_ldf
);
const timeImage = Date.now()
await screenShot(fileName, timeImage);
setTimeout(async() => {
const uriImage = await uploadFileToZulip(timeImage);
let listReport = await getListLineByItem(
logsDetect[0].filter((l) => l.line > lastLine)
);
let content =
"| |Last updated at | Item/error | Line | Report \n|---|:---:|:---|:---|:-----------:\n";
let spoiler = "";
listReport.map((log, index) => {
let item = listExtraItem.includes(log.detected_content)
? ":medal: **" + log.detected_content + "**"
: ":small_orange_diamond: " + log.detected_content;
content =
content +
"|" +
(index + 1) +
"|**" +
moment(log.created_at).format("HH:mm - DD/MM") +
"**|" +
item +
"|" +
log.line +
"|[View](https://logs.danielvu.com/logs/" +
fileName +
"#" +
log.line +
")\n";
});
// }
// setTimeout(() => {
sendMessToZulip(
"stream",
"Result test - auto.nswteam.net",
"Log Alert",
"------------\n\n:warning: :warning: **" +
fileName +
"**\n\n" +
content +
"\n\n" +
spoiler
+
"\n\n[image](" +
uriImage +
")\n"
);
sendMessToZulip(
"stream",
"AUS_VN_Test",
"Test Log Alerts",
"------------\n\n:warning: :warning: **" +
fileName +
"**\n\n" +
content +
"\n\n" +
spoiler
+
"\n\n[image](" +
uriImage +
")\n"
);
}, 10000);
// const timeImage = Date.now()
// await screenShot(fileName, timeImage);
// setTimeout(async() => {
// const uriImage = await uploadFileToZulip(timeImage);
let listReport = await getListLineByItem(
logsDetect[0].filter((l) => l.line > lastLine)
);
let content =
"| |Last updated at | Item/error | Line | Report \n|---|:---:|:---|:---|:-----------:\n";
let spoiler = "";
let issueFound = "";
listReport.map((log, index) => {
let item = listExtraItem.includes(log.detected_content)
? ":medal: **" + log.detected_content + "**"
: ":small_orange_diamond: " + log.detected_content;
log.line?.map((line)=>{
issueFound =
issueFound +
"\n" +
line +
"$" +
contentFile[line-1]?.replace(log.detected_content, "`" + log.detected_content + "`")
})
content =
content +
"|" +
(index + 1) +
"|**" +
moment(log.created_at).format("HH:mm - DD/MM") +
"**|" +
item +
"|" +
log.line +
"|[View](https://logs.danielvu.com/logs/" +
fileName +
"#" +
log.line +
")\n";
});
// }
// setTimeout(() => {
sendMessToZulip(
"stream",
"Result test - auto.nswteam.net",
"Log Alert",
"------------\n\n:warning: :warning: **" +
fileName +
"**\n\n" +
content +
"\n\n" +
spoiler +
"\n\n*Issue found:*\n" + issueFound
// uriImage +
// ")\n"
);
sendMessToZulip(
"stream",
"AUS_VN_Test",
"Test Log Alerts",
"------------\n\n:warning: :warning: **" +
fileName +
"**\n\n" +
content +
"\n\n" +
spoiler +
"\n\n*Issue found:*\n" + issueFound
);
// }, 10000);
// }, 3000);
}
}, 3000);

124
screenshot.js
View File

@ -1,73 +1,73 @@
const puppeteer = require("puppeteer");
// const puppeteer = require("puppeteer");
(async () => {
// Launch a headless browser
const browser = await puppeteer.launch({
headless: true,
args: ["--no-sandbox"],
});
// (async () => {
// // Launch a headless browser
// const browser = await puppeteer.launch({
// headless: true,
// args: ["--no-sandbox"],
// });
// Open a new page
const page = await browser.newPage();
await page.goto(
"https://logs.danielvu.com/screenShot/20230913-TEST01-Session.Port4-6-172.16.20.7.log"
);
const bodyHandle = await page.$("body");
const { height } = await bodyHandle.boundingBox();
await bodyHandle.dispose();
await page.setViewport({ width: 1920, height: 500 });
setTimeout(async () => {
await page.screenshot({ path: "screenshot.png" });
await browser.close();
}, 5000);
// } else {
// console.error(`Element with class name '${className}' not found.`);
// }
// Close the browser
})();
// // Open a new page
// const page = await browser.newPage();
// await page.goto(
// "https://logs.danielvu.com/screenShot/20230913-TEST01-Session.Port4-6-172.16.20.7.log"
// );
// const bodyHandle = await page.$("body");
// const { height } = await bodyHandle.boundingBox();
// await bodyHandle.dispose();
// await page.setViewport({ width: 1920, height: 500 });
// setTimeout(async () => {
// await page.screenshot({ path: "screenshot.png" });
// await browser.close();
// }, 5000);
// // } else {
// // console.error(`Element with class name '${className}' not found.`);
// // }
// // Close the browser
// })();
// const zulip = require("zulip-js");
const zulip = require("zulip-js");
// const config = {
// zuliprc: "./download",
// zulipVersion: "v2",
// };
const config = {
zuliprc: "./zuliprc",
zulipVersion: "v2",
};
// async function deleteMessages() {
// const client = await zulip(config);
async function deleteMessages() {
const client = await zulip(config);
// // Thay thế "stream-name", "topic-name", và các mốc thời gian cụ thể
// const streamName = "Result test - auto.nswteam.net";
// const topicName = "Log Alert";
// const startTime = Date.parse("2023-09-11T00:00:00Z");
// const endTime = Date.parse("2023-09-11T23:59:59Z");
// Thay thế "stream-name", "topic-name", và các mốc thời gian cụ thể
const streamName = "Result test - auto.nswteam.net";
const topicName = "AU-dev";
const startTime = Date.parse("2023-09-11T00:00:00Z");
const endTime = Date.parse("2023-09-11T23:59:59Z");
// try {
// const messages = await client.messages.retrieve({
// anchor: "oldest",
// num_before: 0,
// num_after: 5000, // Điều chỉnh theo nhu cầu của bạn
// narrow: [
// { operator: "stream", operand: streamName },
// { operator: "topic", operand: topicName },
// // {
// // operator: ,
// // operand: `169457100,1694571399`,
// // },
// ],
// });
// console.log(messages.messages.length)
// // for (const message of messages.messages) {
// // const res = await client.messages.deleteById({ message_id: message.id });
// // console.log(`Deleted message ID ${message.id}`);
// // console.log(res)
// // }
// } catch (error) {
// console.error("Error:", error);
// }
// }
try {
const messages = await client.messages.retrieve({
anchor: "oldest",
num_before: 0,
num_after: 3, // Điều chỉnh theo nhu cầu của bạn
narrow: [
{ operator: "stream", operand: streamName },
{ operator: "topic", operand: topicName },
// {
// operator: ,
// operand: `169457100,1694571399`,
// },
],
});
console.log(messages.messages.map(obj=>obj.reactions))
// for (const message of messages.messages) {
// const res = await client.messages.deleteById({ message_id: message.id });
// console.log(`Deleted message ID ${message.id}`);
// console.log(res)
// }
} catch (error) {
console.error("Error:", error);
}
}
// deleteMessages();
deleteMessages();
// const zulip = require("zulip-js");
// const fs = require("fs");

4
zuliprc Normal file
View File

@ -0,0 +1,4 @@
[api]
email=networktool-bot@zulip.ipsupply.com.au
key=0jMAmOuhfLvBqKJikv5oAkyNM4RIEoAM
site=https://zulip.ipsupply.com.au