soffee/mtproto_exporter
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

fix lint

Browse source
This commit is contained in:
soffee 2025-04-08 13:42:47 +03:00
parent d32ed657a1
commit 69695e265a
5 changed files with 15 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
README.md
View file

@ -42,12 +42,12 @@ This metric can be enabled with command line flag `--words-counter`
`--watch-file`, `-w` - watch for keywords file updates and reload keywords configuration in runtime `--watch-file`, `-w` - watch for keywords file updates and reload keywords configuration in runtime
`--include-peers`, `-i` - comma-separated list of `peer.id`s to gather metrics from. `--include-peers`, `-i` - comma-separated list of `peer.id`s to gather metrics from.
if set, only specified peers will be exposed in metrics. if set, only specified peers will be exposed in metrics.
can be specified multiple times. can not be used along with `--exclude-peers` can be specified multiple times. can not be used along with `--exclude-peers`
`--exclude-peers` `x` - comma-separated list of `peer.id`s to exclude from metrics. `--exclude-peers` `x` - comma-separated list of `peer.id`s to exclude from metrics.
if set, specified peers will not be exposed in metrics. if set, specified peers will not be exposed in metrics.
can be specified multiple times. can not be used along with `--include-peers` can be specified multiple times. can not be used along with `--include-peers`
## Environment Variables ## Environment Variables

4
src/config.ts
View file

@ -43,14 +43,14 @@ if (cli["include-peers"] && cli["exclude-peers"]) {
if (cli["include-peers"]) { if (cli["include-peers"]) {
config.includePeers = []; config.includePeers = [];
for (const o of cli["include-peers"] as string[]) { for (const o of cli["include-peers"] as string[]) {
config.includePeers.push(...o.split(",").map(i => parseInt(i)).filter(i => !isNaN(i))); config.includePeers.push(...o.split(",").map(i => Number.parseInt(i)).filter(i => !Number.isNaN(i)));
} }
} }
if (cli["exclude-peers"]) { if (cli["exclude-peers"]) {
config.excludePeers = []; config.excludePeers = [];
for (const o of cli["exclude-peers"] as string[]) { for (const o of cli["exclude-peers"] as string[]) {
config.excludePeers.push(...o.split(",").map(i => parseInt(i)).filter(i => !isNaN(i))); config.excludePeers.push(...o.split(",").map(i => Number.parseInt(i)).filter(i => !Number.isNaN(i)));
} }
} }

10
src/filters.ts
View file

@ -1,21 +1,21 @@
import type { Configuration } from "./config.js";
import { filters } from "@mtcute/dispatcher"; import { filters } from "@mtcute/dispatcher";
import { Configuration } from "./config.js";
export function peersConfigBoolFilter(conf: Configuration, peerId: number) { export function peersConfigBoolFilter(conf: Configuration, peerId: number) {
if(conf.excludePeers && conf.excludePeers.indexOf(peerId) !== -1) { if (conf.excludePeers && conf.excludePeers.includes(peerId)) {
return false; return false;
} }
if(conf.includePeers && conf.includePeers.indexOf(peerId) === -1) { if (conf.includePeers && !conf.includePeers.includes(peerId)) {
return false; return false;
} }
return true; return true;
} }
export function peersConfigFilter(conf: Configuration) { export function peersConfigFilter(conf: Configuration) {
if(conf.excludePeers) { if (conf.excludePeers) {
return filters.not(filters.chatId(conf.excludePeers)); return filters.not(filters.chatId(conf.excludePeers));
} else if (conf.includePeers) { } else if (conf.includePeers) {
return filters.chatId(conf.includePeers); return filters.chatId(conf.includePeers);
} }
return filters.any; return filters.any;
} }

2
src/keywords.ts
View file

@ -1,8 +1,8 @@
import type { Dispatcher } from "@mtcute/dispatcher"; import type { Dispatcher } from "@mtcute/dispatcher";
import { PropagationAction } from "@mtcute/dispatcher"; import { PropagationAction } from "@mtcute/dispatcher";
import { Counter } from "prom-client"; import { Counter } from "prom-client";
import { peersConfigFilter } from "./filters.js";
import { config } from "./config.js"; import { config } from "./config.js";
import { peersConfigFilter } from "./filters.js";
interface KeywordPattern { interface KeywordPattern {
name: string; name: string;

6
src/metrics.ts
View file

@ -3,9 +3,9 @@ import type { TelegramClient } from "@mtcute/node";
import { PropagationAction } from "@mtcute/dispatcher"; import { PropagationAction } from "@mtcute/dispatcher";
import { Counter, Gauge } from "prom-client"; import { Counter, Gauge } from "prom-client";
import { KeywordsCounter, newWordsCounter } from "./keywords.js";
import { config } from "./config.js"; import { config } from "./config.js";
import { peersConfigBoolFilter, peersConfigFilter } from "./filters.js"; import { peersConfigBoolFilter, peersConfigFilter } from "./filters.js";
import { KeywordsCounter, newWordsCounter } from "./keywords.js";
function newMessagesCounter(dp: Dispatcher) { function newMessagesCounter(dp: Dispatcher) {
const counter = new Counter({ const counter = new Counter({
@ -31,7 +31,7 @@ function newStaticPeerInfoGauge(tg: TelegramClient) {
collect: async () => { collect: async () => {
gauge.reset(); gauge.reset();
for await (const d of tg.iterDialogs()) { for await (const d of tg.iterDialogs()) {
if(!peersConfigBoolFilter(config, d.peer.id)) { if (!peersConfigBoolFilter(config, d.peer.id)) {
continue; continue;
} }
@ -54,7 +54,7 @@ function newUnreadCountGauge(tg: TelegramClient) {
collect: async () => { collect: async () => {
gauge.reset(); gauge.reset();
for await (const d of tg.iterDialogs()) { for await (const d of tg.iterDialogs()) {
if(!peersConfigBoolFilter(config, d.peer.id)) { if (!peersConfigBoolFilter(config, d.peer.id)) {
continue; continue;
} }