pavel/pinkmine
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

Linter errors fixed

Browse source
This commit is contained in:
Pavel Gnedov 2022-05-01 22:16:13 +07:00
parent c0cf36a892
commit f47268fea3
1 changed files with 44 additions and 33 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

63
libs/event-emitter/src/events/redmine-events.gateway.ts
View file

@ -1,21 +1,27 @@
import { MessageBody, SubscribeMessage, WebSocketGateway, WebSocketServer, WsResponse } from "@nestjs/websockets"; import {
import { Server } from "socket.io"; MessageBody,
import { Observable } from "rxjs"; SubscribeMessage,
import { map } from "rxjs/operators"; WebSocketGateway,
import { MailListener } from "../maillistener/maillistener"; WebSocketServer,
import { Queue } from "../queue/queue"; WsResponse,
import { RedmineDataLoader } from "../redmine-data-loader/redmine-data-loader"; } from '@nestjs/websockets';
import { RedmineIssueData } from "../models/RedmineIssueData"; import { Server } from 'socket.io';
import { ConfigService } from "@nestjs/config"; import { Observable } from 'rxjs';
import axios from "axios"; import { map } from 'rxjs/operators';
import { WebhookConfigItemModel } from "../models/webhook-config-item-model"; import { MailListener } from '../maillistener/maillistener';
import { RssListener } from "../rsslistener/rsslistener"; import { Queue } from '../queue/queue';
import { EventsListener } from "./events-listener"; import { RedmineDataLoader } from '../redmine-data-loader/redmine-data-loader';
import { RedmineIssueData } from '../models/RedmineIssueData';
import { ConfigService } from '@nestjs/config';
import axios from 'axios';
import { WebhookConfigItemModel } from '../models/webhook-config-item-model';
import { RssListener } from '../rsslistener/rsslistener';
import { EventsListener } from './events-listener';
type IssuesChangesQueueParams = { type IssuesChangesQueueParams = {
updateInterval: number, updateInterval: number;
itemsLimit: number itemsLimit: number;
} };
@WebSocketGateway({ namespace: 'redmine-events' }) @WebSocketGateway({ namespace: 'redmine-events' })
export class RedmineEventsGateway { export class RedmineEventsGateway {
@ -25,18 +31,21 @@ export class RedmineEventsGateway {
issuesChangesObservable: Observable<WsResponse<RedmineIssueData[]>>; issuesChangesObservable: Observable<WsResponse<RedmineIssueData[]>>;
private issueNumberParser: RegExp; private issueNumberParser: RegExp;
private issuesChangesQueueParams: IssuesChangesQueueParams private issuesChangesQueueParams: IssuesChangesQueueParams;
constructor( constructor(
private config: ConfigService, private config: ConfigService,
private redmineDataLoader: RedmineDataLoader private redmineDataLoader: RedmineDataLoader,
) { ) {
this.issuesChangesQueueParams = this.config.get<IssuesChangesQueueParams>("issueChangesQueue") this.issuesChangesQueueParams =
this.config.get<IssuesChangesQueueParams>('issueChangesQueue');
this.initRedmineEventsGateway(); this.initRedmineEventsGateway();
} }
@SubscribeMessage('issues-changes') @SubscribeMessage('issues-changes')
issuesChanges(@MessageBody() data: any): Observable<WsResponse<RedmineIssueData[]>> { issuesChanges(
@MessageBody() data: any,
): Observable<WsResponse<RedmineIssueData[]>> {
return this.issuesChangesObservable; return this.issuesChangesObservable;
} }
@ -55,7 +64,7 @@ export class RedmineEventsGateway {
return []; return [];
} }
return res; return res;
} },
); );
this.issuesChangesQueue.start(); this.issuesChangesQueue.start();
} }
@ -137,14 +146,16 @@ export class RedmineEventsGateway {
private initWebSocketsSendData(): void { private initWebSocketsSendData(): void {
const queue: Queue<number, RedmineIssueData> = this.getIssuesChangesQueue(); const queue: Queue<number, RedmineIssueData> = this.getIssuesChangesQueue();
this.issuesChangesObservable = queue.queue.pipe(map(data => { this.issuesChangesObservable = queue.queue.pipe(
return {event: 'issues-changes', data: data} map((data) => {
})); return { event: 'issues-changes', data: data };
}),
);
} }
private initWebHooksSendData(): void { private initWebHooksSendData(): void {
const queue: Queue<number, RedmineIssueData> = this.getIssuesChangesQueue(); const queue: Queue<number, RedmineIssueData> = this.getIssuesChangesQueue();
queue.queue.subscribe(data => this.sendWebHookFullDataEvents(data)); queue.queue.subscribe((data) => this.sendWebHookFullDataEvents(data));
} }
private initRedmineEventsGateway(): boolean { private initRedmineEventsGateway(): boolean {
@ -154,7 +165,7 @@ export class RedmineEventsGateway {
return false; return false;
} }
const issuesChangesQueue = this.getIssuesChangesQueue(); const issuesChangesQueue = this.getIssuesChangesQueue();
listener.issues.subscribe(issues => { listener.issues.subscribe((issues) => {
issuesChangesQueue.add(issues); issuesChangesQueue.add(issues);
}); });
this.initWebSocketsSendData(); this.initWebSocketsSendData();