mirror of
https://github.com/sp-tarkov/server.git
synced 2025-02-13 09:50:43 -05:00
Refringe
50c7a26a58
This is the first pass of ESLint on the codebase. ESLint formatting is less strict when it comes to line-length and line-breaks then dprint/biome, so if you see formatting that you don't like... fix it! It shouldn't require a configuration change. - This should merge clean into master (when the time comes). - This will not merge clean into `3.9.0-DEV`, but the conflicts aren't that bad.
83 lines
3.3 KiB
TypeScript
83 lines
3.3 KiB
TypeScript
import { inject, injectable } from "tsyringe";
|
|
import { NotifierController } from "@spt-aki/controllers/NotifierController";
|
|
import { HttpServerHelper } from "@spt-aki/helpers/HttpServerHelper";
|
|
import { IEmptyRequestData } from "@spt-aki/models/eft/common/IEmptyRequestData";
|
|
import { IUIDRequestData } from "@spt-aki/models/eft/common/request/IUIDRequestData";
|
|
import { IGetBodyResponseData } from "@spt-aki/models/eft/httpResponse/IGetBodyResponseData";
|
|
import { INotifierChannel } from "@spt-aki/models/eft/notifier/INotifier";
|
|
import { ISelectProfileResponse } from "@spt-aki/models/eft/notifier/ISelectProfileResponse";
|
|
import { HttpResponseUtil } from "@spt-aki/utils/HttpResponseUtil";
|
|
import { JsonUtil } from "@spt-aki/utils/JsonUtil";
|
|
|
|
@injectable()
|
|
export class NotifierCallbacks
|
|
{
|
|
constructor(
|
|
@inject("HttpServerHelper") protected httpServerHelper: HttpServerHelper,
|
|
@inject("HttpResponseUtil") protected httpResponse: HttpResponseUtil,
|
|
@inject("JsonUtil") protected jsonUtil: JsonUtil,
|
|
@inject("NotifierController") protected notifierController: NotifierController,
|
|
)
|
|
{}
|
|
|
|
/**
|
|
* If we don't have anything to send, it's ok to not send anything back
|
|
* because notification requests can be long-polling. In fact, we SHOULD wait
|
|
* until we actually have something to send because otherwise we'd spam the client
|
|
* and the client would abort the connection due to spam.
|
|
*/
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
public sendNotification(sessionID: string, req: any, resp: any, data: any): void
|
|
{
|
|
const splittedUrl = req.url.split("/");
|
|
const tmpSessionID = splittedUrl[splittedUrl.length - 1].split("?last_id")[0];
|
|
|
|
/**
|
|
* Take our array of JSON message objects and cast them to JSON strings, so that they can then
|
|
* be sent to client as NEWLINE separated strings... yup.
|
|
*/
|
|
this.notifierController.notifyAsync(tmpSessionID).then((messages: any) =>
|
|
messages.map((message: any) => this.jsonUtil.serialize(message)).join("\n"),
|
|
).then(text => this.httpServerHelper.sendTextJson(resp, text));
|
|
}
|
|
|
|
/** Handle push/notifier/get */
|
|
/** Handle push/notifier/getwebsocket */
|
|
// TODO: removed from client?
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
public getNotifier(url: string, info: any, sessionID: string): IGetBodyResponseData<any[]>
|
|
{
|
|
return this.httpResponse.emptyArrayResponse();
|
|
}
|
|
|
|
/** Handle client/notifier/channel/create */
|
|
public createNotifierChannel(
|
|
url: string,
|
|
info: IEmptyRequestData,
|
|
sessionID: string,
|
|
): IGetBodyResponseData<INotifierChannel>
|
|
{
|
|
return this.httpResponse.getBody(this.notifierController.getChannel(sessionID));
|
|
}
|
|
|
|
/**
|
|
* Handle client/game/profile/select
|
|
* @returns ISelectProfileResponse
|
|
*/
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
public selectProfile(
|
|
url: string,
|
|
info: IUIDRequestData,
|
|
sessionID: string,
|
|
): IGetBodyResponseData<ISelectProfileResponse>
|
|
{
|
|
return this.httpResponse.getBody({ status: "ok" });
|
|
}
|
|
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
public notify(url: string, info: any, sessionID: string): string
|
|
{
|
|
return "NOTIFY";
|
|
}
|
|
}
|