2023-03-03 15:23:46 +00:00
|
|
|
import { inject, injectable } from "tsyringe";
|
|
|
|
|
|
|
|
import { DialogueHelper } from "../helpers/DialogueHelper";
|
|
|
|
import { IGetAllAttachmentsResponse } from "../models/eft/dialog/IGetAllAttachmentsResponse";
|
|
|
|
import { IGetFriendListDataResponse } from "../models/eft/dialog/IGetFriendListDataResponse";
|
2023-07-15 15:01:23 +01:00
|
|
|
import { IGetMailDialogViewRequestData } from "../models/eft/dialog/IGetMailDialogViewRequestData";
|
2023-03-03 15:23:46 +00:00
|
|
|
import {
|
|
|
|
IGetMailDialogViewResponseData
|
|
|
|
} from "../models/eft/dialog/IGetMailDialogViewResponseData";
|
2023-07-15 15:01:23 +01:00
|
|
|
import { ISendMessageRequest } from "../models/eft/dialog/ISendMessageRequest";
|
|
|
|
import { Dialogue, DialogueInfo, IAkiProfile, IUserDialogInfo, Message } from "../models/eft/profile/IAkiProfile";
|
2023-07-15 11:02:48 +01:00
|
|
|
import { MemberCategory } from "../models/enums/MemberCategory";
|
2023-03-03 15:23:46 +00:00
|
|
|
import { MessageType } from "../models/enums/MessageType";
|
|
|
|
import { SaveServer } from "../servers/SaveServer";
|
|
|
|
import { TimeUtil } from "../utils/TimeUtil";
|
|
|
|
|
|
|
|
@injectable()
|
|
|
|
export class DialogueController
|
|
|
|
{
|
|
|
|
constructor(
|
|
|
|
@inject("SaveServer") protected saveServer: SaveServer,
|
|
|
|
@inject("TimeUtil") protected timeUtil: TimeUtil,
|
|
|
|
@inject("DialogueHelper") protected dialogueHelper: DialogueHelper
|
|
|
|
)
|
|
|
|
{ }
|
|
|
|
|
2023-07-15 10:56:00 +01:00
|
|
|
/** Handle onUpdate spt event */
|
2023-03-03 15:23:46 +00:00
|
|
|
public update(): void
|
|
|
|
{
|
|
|
|
const profiles = this.saveServer.getProfiles();
|
|
|
|
for (const sessionID in profiles)
|
|
|
|
{
|
2023-04-22 22:41:04 +00:00
|
|
|
this.removeExpiredItemsFromMessages(sessionID);
|
2023-03-03 15:23:46 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2023-07-15 10:56:00 +01:00
|
|
|
/**
|
|
|
|
* Handle client/friend/list
|
|
|
|
* @returns IGetFriendListDataResponse
|
|
|
|
*/
|
2023-03-03 15:23:46 +00:00
|
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
|
|
public getFriendList(sessionID: string): IGetFriendListDataResponse
|
|
|
|
{
|
|
|
|
return {
|
2023-07-15 11:02:48 +01:00
|
|
|
"Friends": [
|
|
|
|
{
|
2023-07-15 15:01:23 +01:00
|
|
|
_id: "sptfriend",
|
2023-07-15 11:02:48 +01:00
|
|
|
Info: {
|
|
|
|
Level: 1,
|
|
|
|
MemberCategory: MemberCategory.DEVELOPER,
|
|
|
|
Nickname: "SPT",
|
2023-07-15 15:01:23 +01:00
|
|
|
Side: "Usec"
|
2023-07-15 11:02:48 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
],
|
2023-03-03 15:23:46 +00:00
|
|
|
"Ignore": [],
|
|
|
|
"InIgnoreList": []
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2023-07-15 10:56:00 +01:00
|
|
|
* Handle client/mail/dialog/list
|
2023-03-03 15:23:46 +00:00
|
|
|
* Create array holding trader dialogs and mail interactions with player
|
|
|
|
* Set the content of the dialogue on the list tab.
|
|
|
|
* @param sessionID Session Id
|
|
|
|
* @returns array of dialogs
|
|
|
|
*/
|
|
|
|
public generateDialogueList(sessionID: string): DialogueInfo[]
|
|
|
|
{
|
|
|
|
const data: DialogueInfo[] = [];
|
|
|
|
for (const dialogueId in this.saveServer.getProfile(sessionID).dialogues)
|
|
|
|
{
|
|
|
|
data.push(this.getDialogueInfo(dialogueId, sessionID));
|
|
|
|
}
|
|
|
|
|
|
|
|
return data;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Get the content of a dialogue
|
|
|
|
* @param dialogueID Dialog id
|
|
|
|
* @param sessionID Session Id
|
|
|
|
* @returns DialogueInfo
|
|
|
|
*/
|
|
|
|
public getDialogueInfo(dialogueID: string, sessionID: string): DialogueInfo
|
|
|
|
{
|
|
|
|
const dialogue = this.saveServer.getProfile(sessionID).dialogues[dialogueID];
|
|
|
|
|
2023-03-07 22:25:23 +00:00
|
|
|
const result: DialogueInfo = {
|
2023-03-03 15:23:46 +00:00
|
|
|
"_id": dialogueID,
|
2023-03-07 22:25:23 +00:00
|
|
|
"type": dialogue.type ? dialogue.type : MessageType.NPC_TRADER,
|
2023-03-03 15:23:46 +00:00
|
|
|
"message": this.dialogueHelper.getMessagePreview(dialogue),
|
|
|
|
"new": dialogue.new,
|
|
|
|
"attachmentsNew": dialogue.attachmentsNew,
|
2023-03-07 22:25:23 +00:00
|
|
|
"pinned": dialogue.pinned,
|
|
|
|
Users: dialogue.Users ? dialogue.Users : undefined
|
2023-03-03 15:23:46 +00:00
|
|
|
};
|
2023-03-07 22:25:23 +00:00
|
|
|
|
|
|
|
return result;
|
2023-03-03 15:23:46 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2023-07-15 10:56:00 +01:00
|
|
|
* Handle client/mail/dialog/view
|
2023-03-03 15:23:46 +00:00
|
|
|
* Handle player clicking 'messenger' and seeing all the messages they've recieved
|
|
|
|
* Set the content of the dialogue on the details panel, showing all the messages
|
|
|
|
* for the specified dialogue.
|
2023-07-15 15:01:23 +01:00
|
|
|
* @param request Get dialog request
|
|
|
|
* @param sessionId Session id
|
2023-03-03 15:23:46 +00:00
|
|
|
* @returns IGetMailDialogViewResponseData object
|
|
|
|
*/
|
2023-07-15 15:01:23 +01:00
|
|
|
public generateDialogueView(request: IGetMailDialogViewRequestData, sessionId: string): IGetMailDialogViewResponseData
|
2023-03-03 15:23:46 +00:00
|
|
|
{
|
2023-07-15 15:01:23 +01:00
|
|
|
const dialogueId = request.dialogId;
|
|
|
|
const profile = this.saveServer.getProfile(sessionId);
|
|
|
|
const dialogue = this.getDialogByIdFromProfile(profile, request);
|
|
|
|
|
2023-03-03 15:23:46 +00:00
|
|
|
dialogue.new = 0;
|
|
|
|
|
|
|
|
// Set number of new attachments, but ignore those that have expired.
|
2023-07-15 15:01:23 +01:00
|
|
|
dialogue.attachmentsNew = this.getUnreadMessagesWithAttachmentsCount(sessionId, dialogueId);
|
2023-03-03 15:23:46 +00:00
|
|
|
|
|
|
|
return {
|
|
|
|
messages: dialogue.messages,
|
2023-03-07 22:25:23 +00:00
|
|
|
profiles: this.getProfilesForMail(profile, dialogue.Users),
|
2023-03-03 15:23:46 +00:00
|
|
|
hasMessagesWithRewards: this.messagesHaveUncollectedRewards(dialogue.messages)
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
2023-07-15 15:01:23 +01:00
|
|
|
/**
|
|
|
|
* Get dialog from player profile, create if doesn't exist
|
|
|
|
* @param profile Player profile
|
|
|
|
* @param request get dialog request (params used when dialog doesnt exist in profile)
|
|
|
|
* @returns Dialogue
|
|
|
|
*/
|
|
|
|
protected getDialogByIdFromProfile(profile: IAkiProfile, request: IGetMailDialogViewRequestData): Dialogue
|
|
|
|
{
|
|
|
|
if (!profile.dialogues[request.dialogId])
|
|
|
|
{
|
|
|
|
profile.dialogues[request.dialogId] = {
|
|
|
|
_id: request.dialogId,
|
|
|
|
attachmentsNew: 0,
|
|
|
|
pinned: false,
|
|
|
|
messages: [],
|
|
|
|
new: 0,
|
|
|
|
type: request.type
|
|
|
|
};
|
|
|
|
|
|
|
|
if (request.type === MessageType.USER_MESSAGE)
|
|
|
|
{
|
|
|
|
profile.dialogues[request.dialogId].Users = [];
|
|
|
|
profile.dialogues[request.dialogId].Users.push({
|
|
|
|
_id: request.dialogId,
|
|
|
|
info: {
|
|
|
|
Level:1,
|
|
|
|
Nickname: "SPT",
|
|
|
|
Side: "Usec",
|
|
|
|
MemberCategory: MemberCategory.DEFAULT
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return profile.dialogues[request.dialogId];
|
|
|
|
}
|
|
|
|
|
2023-03-07 22:25:23 +00:00
|
|
|
protected getProfilesForMail(pmcProfile: IAkiProfile, dialogUsers: IUserDialogInfo[]): IUserDialogInfo[]
|
|
|
|
{
|
|
|
|
const result: IUserDialogInfo[] = [];
|
|
|
|
if (dialogUsers)
|
|
|
|
{
|
|
|
|
result.push(...dialogUsers);
|
|
|
|
const profile = pmcProfile.characters.pmc;
|
|
|
|
result.push({
|
|
|
|
_id: pmcProfile.info.id,
|
|
|
|
info: {
|
|
|
|
Nickname: profile.Info.Nickname,
|
|
|
|
Side: profile.Info.Side,
|
|
|
|
Level: profile.Info.Level,
|
|
|
|
MemberCategory: profile.Info.MemberCategory
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
2023-03-03 15:23:46 +00:00
|
|
|
/**
|
|
|
|
* Get a count of messages with attachments from a particular dialog
|
|
|
|
* @param sessionID Session id
|
|
|
|
* @param dialogueID Dialog id
|
|
|
|
* @returns Count of messages with attachments
|
|
|
|
*/
|
|
|
|
protected getUnreadMessagesWithAttachmentsCount(sessionID: string, dialogueID: string): number
|
|
|
|
{
|
|
|
|
let newAttachmentCount = 0;
|
|
|
|
const activeMessages = this.getActiveMessagesFromDialog(sessionID, dialogueID);
|
|
|
|
for (const message of activeMessages)
|
|
|
|
{
|
|
|
|
if (message.hasRewards && !message.rewardCollected)
|
|
|
|
{
|
|
|
|
newAttachmentCount++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return newAttachmentCount;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Does array have messages with uncollected rewards (includes expired rewards)
|
|
|
|
* @param messages Messages to check
|
|
|
|
* @returns true if uncollected rewards found
|
|
|
|
*/
|
|
|
|
protected messagesHaveUncollectedRewards(messages: Message[]): boolean
|
|
|
|
{
|
|
|
|
return messages.some(x => x.items?.data?.length > 0);
|
|
|
|
}
|
|
|
|
|
2023-07-15 10:56:00 +01:00
|
|
|
/** Handle client/mail/dialog/remove */
|
2023-03-03 15:23:46 +00:00
|
|
|
public removeDialogue(dialogueID: string, sessionID: string): void
|
|
|
|
{
|
|
|
|
delete this.saveServer.getProfile(sessionID).dialogues[dialogueID];
|
|
|
|
}
|
|
|
|
|
|
|
|
public setDialoguePin(dialogueID: string, shouldPin: boolean, sessionID: string): void
|
|
|
|
{
|
|
|
|
this.saveServer.getProfile(sessionID).dialogues[dialogueID].pinned = shouldPin;
|
|
|
|
}
|
|
|
|
|
2023-07-15 10:56:00 +01:00
|
|
|
/** Handle client/mail/dialog/read */
|
2023-03-03 15:23:46 +00:00
|
|
|
public setRead(dialogueIDs: string[], sessionID: string): void
|
|
|
|
{
|
|
|
|
const dialogueData = this.saveServer.getProfile(sessionID).dialogues;
|
|
|
|
for (const dialogID of dialogueIDs)
|
|
|
|
{
|
|
|
|
dialogueData[dialogID].new = 0;
|
|
|
|
dialogueData[dialogID].attachmentsNew = 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2023-07-15 10:56:00 +01:00
|
|
|
* Handle client/mail/dialog/getAllAttachments
|
2023-03-03 15:23:46 +00:00
|
|
|
* Get all uncollected items attached to mail in a particular dialog
|
|
|
|
* @param dialogueID Dialog to get mail attachments from
|
|
|
|
* @param sessionID Session id
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
public getAllAttachments(dialogueID: string, sessionID: string): IGetAllAttachmentsResponse
|
|
|
|
{
|
|
|
|
// Removes corner 'new messages' tag
|
|
|
|
this.saveServer.getProfile(sessionID).dialogues[dialogueID].attachmentsNew = 0;
|
|
|
|
|
|
|
|
const activeMessages = this.getActiveMessagesFromDialog(sessionID, dialogueID);
|
|
|
|
const messagesWithAttachments = this.getMessagesWithAttachments(activeMessages);
|
|
|
|
|
|
|
|
return {
|
|
|
|
messages: messagesWithAttachments,
|
|
|
|
profiles: [],
|
|
|
|
hasMessagesWithRewards: this.messagesHaveUncollectedRewards(messagesWithAttachments)
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
2023-07-15 15:01:23 +01:00
|
|
|
/** client/mail/msg/send */
|
|
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
|
|
public sendMessage(sessionId: string, request: ISendMessageRequest): string
|
|
|
|
{
|
|
|
|
const profile = this.saveServer.getProfile(sessionId);
|
|
|
|
const dialog = profile.dialogues[request.dialogId];
|
|
|
|
dialog.messages.push({
|
|
|
|
_id: sessionId,
|
|
|
|
dt: this.timeUtil.getTimestamp(),
|
|
|
|
hasRewards: false,
|
|
|
|
items: {},
|
|
|
|
uid: sessionId,
|
|
|
|
type: MessageType.USER_MESSAGE,
|
|
|
|
rewardCollected: false,
|
|
|
|
text: request.text
|
|
|
|
});
|
|
|
|
|
|
|
|
if (request.dialogId.includes("sptfriend") && request.text.includes("love you"))
|
|
|
|
{
|
|
|
|
dialog.messages.push({
|
|
|
|
_id: "sptfriend",
|
|
|
|
dt: this.timeUtil.getTimestamp()+1,
|
|
|
|
hasRewards: false,
|
|
|
|
items: {},
|
|
|
|
uid: "sptfriend",
|
|
|
|
type: MessageType.USER_MESSAGE,
|
|
|
|
rewardCollected: false,
|
|
|
|
text: "i love you too buddy :3"
|
|
|
|
});
|
|
|
|
dialog.new = 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
return request.dialogId;
|
|
|
|
}
|
|
|
|
|
2023-03-03 15:23:46 +00:00
|
|
|
/**
|
|
|
|
* Get messages from a specific dialog that have items not expired
|
|
|
|
* @param sessionId Session id
|
|
|
|
* @param dialogueId Dialog to get mail attachments from
|
|
|
|
* @returns Message array
|
|
|
|
*/
|
|
|
|
protected getActiveMessagesFromDialog(sessionId: string, dialogueId: string): Message[]
|
|
|
|
{
|
|
|
|
const timeNow = this.timeUtil.getTimestamp();
|
|
|
|
return this.saveServer.getProfile(sessionId).dialogues[dialogueId].messages.filter(x => timeNow < (x.dt + x.maxStorageTime));
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Return array of messages with uncollected items (includes expired)
|
|
|
|
* @param messages Messages to parse
|
|
|
|
* @returns messages with items to collect
|
|
|
|
*/
|
|
|
|
protected getMessagesWithAttachments(messages: Message[]): Message[]
|
|
|
|
{
|
|
|
|
return messages.filter(x => x.items?.data?.length > 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
2023-04-22 22:41:04 +00:00
|
|
|
* Delete expired items from all messages in player profile. triggers when updating traders.
|
|
|
|
* @param sessionId Session id
|
2023-03-03 15:23:46 +00:00
|
|
|
*/
|
2023-04-22 22:41:04 +00:00
|
|
|
protected removeExpiredItemsFromMessages(sessionId: string): void
|
2023-03-03 15:23:46 +00:00
|
|
|
{
|
2023-04-22 22:41:04 +00:00
|
|
|
for (const dialogueId in this.saveServer.getProfile(sessionId).dialogues)
|
2023-03-03 15:23:46 +00:00
|
|
|
{
|
2023-04-22 22:41:04 +00:00
|
|
|
this.removeExpiredItemsFromMessage(sessionId, dialogueId);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Removes expired items from a message in player profile
|
|
|
|
* @param sessionId Session id
|
|
|
|
* @param dialogueId Dialog id
|
|
|
|
*/
|
|
|
|
protected removeExpiredItemsFromMessage(sessionId: string, dialogueId: string): void
|
|
|
|
{
|
|
|
|
for (const message of this.saveServer.getProfile(sessionId).dialogues[dialogueId].messages)
|
|
|
|
{
|
|
|
|
if (this.messageHasExpired(message))
|
2023-03-03 15:23:46 +00:00
|
|
|
{
|
2023-04-22 22:41:04 +00:00
|
|
|
message.items = {};
|
2023-03-03 15:23:46 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2023-04-22 22:41:04 +00:00
|
|
|
|
|
|
|
/**
|
|
|
|
* Has a dialog message expired
|
|
|
|
* @param message Message to check expiry of
|
|
|
|
* @returns true or false
|
|
|
|
*/
|
|
|
|
protected messageHasExpired(message: Message): boolean
|
|
|
|
{
|
|
|
|
return (this.timeUtil.getTimestamp()) > (message.dt + message.maxStorageTime);
|
|
|
|
}
|
2023-03-03 15:23:46 +00:00
|
|
|
}
|