Compare commits

..

No commits in common. "b48c834d367efe9bfc365240d048cc1b460941e9" and "e43ab6cfe180de13faf880ab4dbe8e398e7dcd9f" have entirely different histories.

7 changed files with 60 additions and 114 deletions

View File

@ -13,38 +13,29 @@ import { Request, Response } from "express";
import statusCodes from "../utils/statusCodes";
import logger from "../system/Logger";
export const validateCreateAccount = ajv.compile(createAccountSchema);
export const validateGetAccounts = ajv.compile(getAccountSchema);
export const validateGetRooms = ajv.compile(getRoomSchema);
export const validateGetMessages = ajv.compile(getMessagesSchema);
export const validateGetMembers = ajv.compile(getMembersSchema);
export const validateSetFlag = ajv.compile(setFlagSchema);
class Validator {
validateCreateAccount: any;
validateGetAccounts: any;
validateGetRooms: any;
validateGetMessages: any;
validateGetMembers: any;
validateSetFlag: any;
constructor() {
this.validateCreateAccount = ajv.compile(createAccountSchema);
this.validateGetAccounts = ajv.compile(getAccountSchema);
this.validateGetRooms = ajv.compile(getRoomSchema);
this.validateGetMessages = ajv.compile(getMessagesSchema);
this.validateGetMembers = ajv.compile(getMembersSchema);
this.validateSetFlag = ajv.compile(setFlagSchema);
}
_getSchema(name: string): any {
switch (name) {
case "createAccount":
return this.validateCreateAccount;
return validateCreateAccount;
case "getAccounts":
return this.validateGetAccounts;
return validateGetAccounts;
case "getRooms":
return this.validateGetRooms;
return validateGetRooms;
case "getMessages":
return this.validateGetMessages;
return validateGetMessages;
case "getMembers":
return this.validateGetMembers;
return validateGetMembers;
case "addFlag":
case "removeFlag":
return this.validateSetFlag;
return validateSetFlag;
default:
logger.err(`Schema ${name} not found`);
break;

View File

@ -110,7 +110,7 @@ function mailChange() {
<template>
<div>
<button @click="modal = true">Add Account</button>
<button @click="modal = true">Open Modal!</button>
<Modal v-if="modal" title="Add new account" @close-modal="modal = false">
<template v-slot:body>
<div class="field">

View File

@ -10,6 +10,8 @@ import { isSeenFc } from "@/utils/flagsUtils";
const props = defineProps({
msg: Object as PropType<Message>,
members: Array as PropType<Address[]>,
mailboxId: Number,
roomId: Number,
});
const displayAddresses = (addressIds: string[] | undefined): string => {
@ -64,7 +66,7 @@ const classes = (): string => {
</div>
<div class="content" :class="[classes()]">
<Content :content="props.msg?.content" />
<Options class="options" :msg="props.msg" />
<Options class="options" :mailboxId="props.mailboxId" :roomId="props.roomId" :msg="props.msg" />
</div>
</div>
</template>

View File

@ -1,5 +1,5 @@
<script setup lang="ts">
import { defineProps, inject, PropType } from "vue";
import { defineProps, PropType } from "vue";
import { Message } from "@/store/models/model";
import API from "@/services/imapAPI";
import store from "@/store/store";
@ -7,24 +7,24 @@ import { isSeenFc } from "@/utils/flagsUtils";
const props = defineProps({
msg: Object as PropType<Message>,
mailboxId: Number,
roomId: Number,
});
const room: any = inject("room");
const setFlag = (flag: string) => {
// todo loading
if (!room?.value || !props.msg) return;
if (!props.mailboxId || !props.msg) return;
let apiCall = isSeenFc(props.msg?.flags) ? API.removeFlag : API.addFlag;
apiCall({
mailboxId: room.value?.mailboxId,
mailboxId: props.mailboxId,
messageId: props.msg?.id,
flag: flag,
})
.then((res) => {
if (isSeenFc(props.msg?.flags)) {
store.commit("removeFlag", { roomId: room.value?.id, messageId: props.msg?.id, flag: flag });
store.commit("removeFlag", { roomId: props.roomId, messageId: props.msg?.id, flag: flag });
} else {
store.commit("addFlag", { roomId: room.value?.id, messageId: props.msg?.id, flag: flag });
store.commit("addFlag", { roomId: props.roomId, messageId: props.msg?.id, flag: flag });
}
})
.catch((err) => {

View File

@ -23,6 +23,7 @@ export enum LoadingState {
loaded = 2,
}
// todo store messages outside of the room
export interface Room {
id: number;
roomName: string;
@ -32,6 +33,8 @@ export interface Room {
userId: number;
members: Address[];
notSeen: number;
messages: Message[];
messageLoading: LoadingState;
threadIds: number[];
}

View File

@ -1,5 +1,4 @@
import API from "@/services/imapAPI";
import { isSeenFc } from "@/utils/flagsUtils";
import { decodeEmojis } from "@/utils/string";
import { AxiosError, AxiosResponse } from "axios";
import { createStore } from "vuex";
@ -34,61 +33,30 @@ function createRoom(options: RoomFromBack): Room {
members: [],
user: options.user,
notSeen: options.notSeen,
messages: [],
messageLoading: LoadingState.notLoaded,
threadIds: [],
};
}
interface roomMessage {
roomId: number;
fetch: LoadingState;
messages: Message[];
}
export interface State {
rooms: Room[];
accounts: Account[];
activeAccount: number;
rooms: Room[];
activeRoom: number;
roomMessages: roomMessage[];
}
const roomOnId = (state: State, roomId: number): Room | undefined =>
state.rooms.find((room: Room) => room.id == roomId);
const msgOnRoomId = (state: State, roomId: number) => state.roomMessages.find((roomMsg) => roomMsg.roomId == roomId);
const roomOnId = (state: State, roomId: number) => state.rooms.find((room: Room) => room.id == roomId);
function updateSeen(state: State, roomId: number, flag: string[], adding: boolean) {
// if is seen flag decrement unread value
if (isSeenFc(flag)) {
const room = roomOnId(state, roomId);
if (!room) return;
if (adding) {
room.notSeen--;
} else {
room.notSeen++;
}
// if is thread change seen on parent
if (room.roomType == RoomType.THREAD) {
const parentRoom = state.rooms.find((room) => room.threadIds.includes(roomId));
if (parentRoom) {
if (adding) {
parentRoom.notSeen--;
} else {
parentRoom.notSeen++;
}
}
}
}
}
// define injection key todo
// // define injection key todo
// export const key: InjectionKey<Store<State>> = Symbol()
const store = createStore<State>({
state: {
rooms: [], //createRoom({ id: 12, userId: 1, user: "user", roomName: "room name", mailboxId: 2, roomType: 1 })
accounts: [{ id: 0, email: "All", fetched: false }],
activeAccount: 0,
rooms: [],
activeRoom: 0,
roomMessages: [],
},
mutations: {
setActiveAccount(state, payload) {
@ -101,15 +69,7 @@ const store = createStore<State>({
// todo load room on load page
const room = state.rooms.find((room) => room.id == payload);
if (!room) return;
let roomMessage = msgOnRoomId(state, payload);
if (!roomMessage) {
state.roomMessages.push({ messages: [], fetch: LoadingState.notLoaded, roomId: payload });
roomMessage = msgOnRoomId(state, payload);
}
store.dispatch("fetchMessages", {
roomId: payload,
obj: roomMessage,
});
store.dispatch("fetchMessages", { roomId: payload, room: room });
},
addAccounts(state, payload) {
payload.forEach((account: AccountFromBack) => {
@ -138,16 +98,9 @@ const store = createStore<State>({
// todo add if not exist
const room = roomOnId(state, payload.roomId);
if (!room) return;
let roomMessage = msgOnRoomId(state, payload.roomId);
if (!roomMessage) {
state.roomMessages.push({ roomId: payload.roomId, messages: [], fetch: LoadingState.notLoaded });
roomMessage = msgOnRoomId(state, payload.roomId);
}
if (!roomMessage) return;
payload.messages.forEach((message: any) => {
message.flags = message.flags?.split(",") ?? [];
roomMessage?.messages.push(message);
room.messages.push(message);
});
},
addAddress(state, payload) {
@ -159,17 +112,16 @@ const store = createStore<State>({
});
},
addFlag(state, payload) {
const msg = msgOnRoomId(state, payload.roomId)?.messages.find((msg) => msg.id == payload.messageId);
// todo if seen notif
const msg = roomOnId(state, payload.roomId)?.messages.find((msg) => msg.id == payload.messageId);
if (msg) {
msg.flags.push(payload.flag);
updateSeen(state, payload.roomId, payload.flag, true);
}
},
removeFlag(state, payload) {
const msg = msgOnRoomId(state, payload.roomId)?.messages.find((msg) => msg.id == payload.messageId);
const msg = roomOnId(state, payload.roomId)?.messages.find((msg) => msg.id == payload.messageId);
if (msg) {
msg.flags?.splice(msg.flags?.indexOf(payload.flag), 1);
updateSeen(state, payload.roomId, payload.flag, false);
}
},
},
@ -195,11 +147,12 @@ const store = createStore<State>({
messages:
(state) =>
(roomId: number): Message[] => {
const roomMessage = msgOnRoomId(state, roomId);
if (roomMessage) return roomMessage.messages;
state.roomMessages.push({ messages: [], roomId: roomId, fetch: LoadingState.notLoaded });
store.dispatch("fetchMessages", { roomId: roomId, obj: msgOnRoomId(state, roomId) });
return msgOnRoomId(state, roomId)?.messages ?? [];
const room = roomOnId(state, roomId);
if (!room) return [];
if (room.messageLoading === LoadingState.notLoaded) {
store.dispatch("fetchMessages", { roomId: room.id, room: room });
}
return room.messages;
},
},
actions: {
@ -225,16 +178,16 @@ const store = createStore<State>({
}
},
fetchMessages: async (context, data) => {
if (data.obj.fetch === LoadingState.notLoaded) {
data.obj.fetch = LoadingState.loading;
if (!data.room || data.room.messageLoading === LoadingState.notLoaded) {
data.room.messageLoading = LoadingState.loading;
store.dispatch("fetchRoomMembers", { roomId: data.roomId });
API.getMessages(data.roomId)
.then((res: AxiosResponse) => {
data.obj.fetch = LoadingState.loaded;
data.room.messageLoading = LoadingState.loaded;
context.commit("addMessages", { messages: res.data, roomId: data.roomId });
})
.catch((err: AxiosError) => {
data.obj.fetch = LoadingState.notLoaded;
data.room.messageLoading = LoadingState.notLoaded;
console.log(err);
});
}

View File

@ -1,10 +1,10 @@
<script setup>
import { useStore } from "vuex";
import { useRoute, onBeforeRouteUpdate } from "vue-router";
import { onBeforeMount, provide, ref } from "vue";
import { RoomType } from "@/store/models/model";
import { onBeforeMount, ref } from "vue";
import Header from "./Header.vue";
import Message from "../../components/structure/message/Message.vue";
import { Room, RoomType } from "@/store/models/model";
import MessageViewModal from "@/components/modals/MessageViewModal.vue";
const store = useStore();
@ -12,34 +12,29 @@ const route = useRoute();
const messageIdView = ref(-1);
const message = ref(undefined);
const id = ref(parseInt(route.params.id));
let room = ref();
let room;
onBeforeMount(async () => {
store.commit("setActiveRoom", id.value);
room.value = store.getters.room(id.value);
console.log(room.value);
room = store.getters.room(id.value);
});
onBeforeRouteUpdate(async (to, from) => {
if (to.params.id !== from.params.id) {
id.value = parseInt(to.params.id);
store.commit("setActiveRoom", id.value);
room.value = await store.getters.room(id.value);
console.log(room.value);
room = await store.getters.room(id.value);
}
});
const shouldDisplayComposer = () => {
if (!room?.value) return false;
return room.value.roomType == RoomType.THREAD || room.value.roomType == RoomType.GROUP;
if (!room) return false;
return room.roomType == RoomType.THREAD || room.roomType == RoomType.GROUP;
};
function openMessageView(id) {
messageIdView.value = id;
message.value = room.value?.messages.find((message) => message.id == id);
message.value = room?.messages.find((message) => message.id == id);
}
provide("room", room);
</script>
<template>
@ -48,10 +43,12 @@ provide("room", room);
<div id="RoomViewBody">
<div class="content">
<Message
v-for="(message, index) in store.getters.messages(room?.id)"
v-for="(message, index) in room?.messages"
:key="index"
:msg="message"
:members="room?.members"
:mailboxId="room.mailboxId"
:roomId="room.id"
@open-message-view="(id) => openMessageView(id)"
/>
</div>