peter/doneit-web
1
0
Fork 0
mirror of https://code.equilibrium.co.ao/ITO/doneit-web.git synced 2026-04-19 04:57:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

add interface

Browse Source
This commit is contained in:
Peter Maquiran
2024-08-27 23:36:24 +01:00
parent ee30dd2d5b
commit 97ad62e2b6
62 changed files with 332 additions and 361 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/app/module/chat/data/repository/attachment/attachment-local-repository.service.ts
+1 -1
View File
@@ -1,6 +1,6 @@
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs';
import { IAttachmentLocalRepository } from 'src/app/core/chat/repository/attachment/attachment-local-repository';
import { IAttachmentLocalRepository } from 'src/app/core/chat/repository/typing/typing-local-repository';
import { AttachmentTable, AttachmentTableSchema } from 'src/app/infra/database/dexie/instance/chat/schema/attachment';
import { chatDatabase } from 'src/app/infra/database/dexie/service';
import { DexieRepository } from 'src/app/infra/repository/dexie/dexie-repository.service';
src/app/module/chat/data/repository/member/member-list-local-repository.service.ts
+6 -6
View File
@@ -8,7 +8,7 @@ import { MemberListUPdateStatusInputDTO } from '../../../domain/use-case/socket/
import { from } from 'rxjs';
import { MemberTable, MemberTableSchema } from 'src/app/infra/database/dexie/instance/chat/schema/members';
import { chatDatabase } from 'src/app/infra/database/dexie/service';
import { IMemberLocalRepository } from 'src/app/core/chat/repository/member/member-local-repository';
import { IDirectMemberInput, IGetMemberLive, IMemberLocalRepository } from 'src/app/core/chat/repository/member/member-local-repository';
@Injectable({
providedIn: 'root'
@@ -20,14 +20,14 @@ export class MemberListLocalRepository extends DexieRepository<MemberTable, Memb
}
async directMember({roomId, currentUserId}) {
async directMember({roomId, currentUserId}:IDirectMemberInput) {
try {
let a = await chatDatabase.members.where('roomId')
.equals(roomId)
.and(message => message.wxUserId !== currentUserId)
.first()
return ok(a)
return ok(a as MemberTable)
} catch (e) {
return err(e)
}
@@ -51,7 +51,7 @@ export class MemberListLocalRepository extends DexieRepository<MemberTable, Memb
}
}
async updateMembersStatus(data: MemberListUPdateStatusInputDTO) {
async updateMembersStatus(data: MemberListUPdateStatusInputDTO): Promise<Result<true, any>> {
try {
await chatDatabase.members.toCollection().modify({ status: 'offline' });
for (const item of data) {
@@ -93,9 +93,9 @@ export class MemberListLocalRepository extends DexieRepository<MemberTable, Memb
}
getMemberLive(data: {roomId, wxUserId}) {
getMemberLive(data: IGetMemberLive) {
const $roomIdUserId = data.roomId + data.wxUserId
return liveQuery(() => chatDatabase.members.get($roomIdUserId)) as any;
return liveQuery(() => chatDatabase.members.get($roomIdUserId));
}
async getRoomMemberById(roomId: any) {
src/app/module/chat/data/repository/member/member-list-remote-repository.service.ts
+6 -1
View File
@@ -4,8 +4,9 @@ import { ValidateSchema } from 'src/app/services/decorators/validate-schema.deco
import { HttpService } from 'src/app/services/http.service';
import { DataSourceReturn } from 'src/app/services/Repositorys/type';
import { IMemberRemoteRepository } from 'src/app/core/chat/repository/member/member-remote-repository';
import { UserRemoveListInputDTO, UserRemoveListInputDTOSchema } from "src/app/module/chat/data/dto/room/userRemoveListInputDTO";
import { AddMemberToRoomInputDTO, AddMemberToRoomInputDTOSchema } from '../../../domain/use-case/member/member-add-use-case.service';
import { MemberSetAdminDTO } from '../../../domain/use-case/member/member-admin-use-case.service';
import { UserRemoveListInputDTOSchema, UserRemoveListInputDTO } from '../../../domain/use-case/room/room-leave-by-id-use-case.service';
@Injectable({
providedIn: 'root'
})
@@ -27,4 +28,8 @@ export class MemberListRemoteRepository implements IMemberRemoteRepository {
return await this.httpService.delete<any>(`${this.baseUrl}/Room/${data.id}/Member`, {members:data.members});
}
async setAmin(data: MemberSetAdminDTO): Promise<Result<any ,any>> {
return await this.httpService.patch<any>(`${this.baseUrl}/Room/${data.roomId}/Member/${data.memberId}/admin`);
}
}
src/app/module/chat/data/repository/message/message-live-signalr-data-source.service.ts
+2 -2
View File
@@ -1,9 +1,7 @@
import { Injectable } from '@angular/core';
import { MessageDeleteInputDTO } from '../../dto/message/messageDeleteInputDTO';
import { v4 as uuidv4 } from 'uuid'
import { InstanceId } from '../../../domain/chat-service.service';
import { MessageUpdateInput } from '../../../domain/use-case/message/message-update-by-id-use-case.service';
import { MessageOutPutDataDTO } from '../../dto/message/messageOutputDTO';
import { MessageReactionInput } from '../../../domain/use-case/message/message-reaction-by-id-use-case.service';
import { SignalRService } from 'src/app/infra/socket/signalR/signal-r.service';
import { filter, map } from 'rxjs/operators';
@@ -12,6 +10,8 @@ import { IMessageSocketRepository } from 'src/app/core/chat/repository/message/m
import { MessageCreateOutPutDataDTO } from '../../../domain/use-case/message/message-create-use-case.service';
import { MessageInputDTO } from 'src/app/core/chat/repository/dto/messageInputDtO'
import { MessageMarkAsReadInput } from '../../../domain/use-case/message/message-mark-as-read-use-case.service';
import { MessageOutPutDataDTO } from 'src/app/core/chat/repository/dto/messageOutputDTO';
import { MessageDeleteInputDTO } from '../../../domain/use-case/message/message-delete-by-id-live-use-case.service';
interface sendDeliverAt {
src/app/module/chat/data/repository/room/room-local-repository.service.ts
+3 -2
View File
@@ -4,17 +4,18 @@ import { DexieRepository } from 'src/app/infra/repository/dexie/dexie-repository
import { from } from 'rxjs';
import { RoomTable, RoomTableSchema } from 'src/app/infra/database/dexie/instance/chat/schema/room';
import { chatDatabase } from 'src/app/infra/database/dexie/service';
import { IRoomLocalRepository } from 'src/app/core/chat/repository/room/room-local-repository';
@Injectable({
providedIn: 'root'
})
export class RoomLocalRepository extends DexieRepository<RoomTable, RoomTable> {
export class RoomLocalRepository extends DexieRepository<RoomTable, RoomTable> implements IRoomLocalRepository {
constructor() {
super(chatDatabase.room, RoomTableSchema)
}
getItemsLive(){
getItemsLive() {
return from (liveQuery(() => chatDatabase.room.toArray()));
}
src/app/module/chat/data/repository/room/room-remote-repository.service.ts
+8 -26
View File
@@ -1,27 +1,24 @@
import { Injectable } from '@angular/core';
import { Result } from 'neverthrow';
import { HttpService } from 'src/app/services/http.service';
import { RoomListOutPutDTO, RoomListOutPutDTOSchema } from '../../dto/room/roomListOutputDTO';
import { RoomInputDTO, RoomInputDTOSchema } from '../../dto/room/roomInputDTO';
import { RoomOutPutDTO, RoomOutPutDTOSchema } from '../../dto/room/roomOutputDTO';
import { AddMemberToRoomInputDTO, AddMemberToRoomInputDTOSchema } from '../../../domain/use-case/member/member-add-use-case.service';
import { ValidateSchema } from 'src/app/services/decorators/validate-schema.decorator';
import { RoomByIdInputDTO, RoomByIdInputDTOSchema } from '../../dto/room/roomByIdInputDTO';
import { RoomByIdOutputDTO, RoomByIdOutputDTOSchema } from '../../dto/room/roomByIdOutputDTO';
import { APIReturn } from 'src/app/services/decorators/api-validate-schema.decorator';
import { UserRemoveListInputDTO, UserRemoveListInputDTOSchema } from '../../dto/room/userRemoveListInputDTO';
import { RoomUpdateInputDTO, RoomUpdateInputDTOSchema } from '../../dto/room/roomUpdateInputDTO';
import { RoomUpdateOutputDTO } from '../../dto/room/roomUpdateOutputDTO';
import { DataSourceReturn } from 'src/app/services/Repositorys/type';
import { SessionStore } from 'src/app/store/session.service';
import { MemberSetAdminDTO } from '../../../domain/use-case/member/member-admin-use-case.service';
import { SignalRService } from 'src/app/infra/socket/signalR/signal-r.service';
import { v4 as uuidv4 } from 'uuid'
import { CreateRoomInputDTOSchema, CreateRoomInputDTO, RoomOutPutDTOSchema, RoomOutPutDTO } from '../../../domain/use-case/room/room-create-use-case.service';
import { IRoomRemoteRepository } from 'src/app/core/chat/repository/room/room-remote-repository';
import { RoomByIdInputDTO, RoomByIdInputDTOSchema, RoomByIdOutputDTO, RoomByIdOutputDTOSchema } from 'src/app/module/chat/domain/use-case/room/room-get-by-id-use-case.service';
import { RoomUpdateInputDTO, RoomUpdateInputDTOSchema, RoomUpdateOutputDTO } from 'src/app/module/chat/domain/use-case/room/room-update-by-id-use-case.service';
import { RoomListOutPutDTO, RoomListOutPutDTOSchema } from '../../../domain/use-case/room/room-get-list-use-case.service';
@Injectable({
providedIn: 'root'
})
export class RoomRemoteDataSourceService {
export class RoomRemoteDataSourceService implements IRoomRemoteRepository {
private baseUrl = 'https://gdapi-dev.dyndns.info/stage/api/v2/Chat'; // Your base URL
@@ -31,9 +28,9 @@ export class RoomRemoteDataSourceService {
) {}
@ValidateSchema(RoomInputDTOSchema)
@ValidateSchema(CreateRoomInputDTOSchema)
@APIReturn(RoomOutPutDTOSchema, 'post/Room')
async createRoom(data: RoomInputDTO): DataSourceReturn<RoomOutPutDTO> {
async createRoom(data: CreateRoomInputDTO): DataSourceReturn<RoomOutPutDTO> {
return await this.httpService.post<RoomOutPutDTO>(`${this.baseUrl}/Room`, data);
}
@@ -61,21 +58,6 @@ export class RoomRemoteDataSourceService {
return await this.httpService.delete<any>(`${this.baseUrl}/Room/${id}`, {});
}
@ValidateSchema(AddMemberToRoomInputDTOSchema)
async addMemberToRoom(data: AddMemberToRoomInputDTO): DataSourceReturn<AddMemberToRoomInputDTO> {
return await this.httpService.post<any>(`${this.baseUrl}/Room/${data.id}/Member`, { members:data.members });
}
@ValidateSchema(UserRemoveListInputDTOSchema)
async removeMemberFromRoom(data: UserRemoveListInputDTO): Promise<Result<any ,any>> {
return await this.httpService.delete<any>(`${this.baseUrl}/Room/${data.id}/Member`, {members:data.members});
}
async setAmin(data: MemberSetAdminDTO): Promise<Result<any ,any>> {
return await this.httpService.patch<any>(`${this.baseUrl}/Room/${data.roomId}/Member/${data.memberId}/admin`);
}
async addMemberToRoomSocket(data: AddMemberToRoomInputDTO) {
src/app/module/chat/data/repository/room/room-socket-repository.service.ts
+4 -4
View File
@@ -3,9 +3,9 @@ import { SignalRService } from 'src/app/infra/socket/signalR/signal-r.service';
import { filter, map } from 'rxjs/operators';
import { z } from 'zod';
import { SocketMessage } from 'src/app/infra/socket/signalR/signalR';
import { RoomInputDTO } from '../../dto/room/roomInputDTO';
import { RoomOutPutDTO } from '../../dto/room/roomOutputDTO';
import { v4 as uuidv4 } from 'uuid'
import { IRoomSocketRepository } from 'src/app/core/chat/repository/room/room-socket-repository';
import { CreateRoomInputDTO } from '../../../domain/use-case/room/room-create-use-case.service';
const listenToDeleteRoomInputSchema = z.object({
roomId: z.string()
@@ -29,14 +29,14 @@ export type ListenToDeleteRoomInput = z.infer<typeof listenToDeleteRoomInputSche
@Injectable({
providedIn: 'root'
})
export class RoomSocketRepositoryService {
export class RoomSocketRepositoryService implements IRoomSocketRepository {
constructor(
private socket: SignalRService
) { }
async CreateGroup(data: RoomInputDTO) {
async CreateGroup(data: CreateRoomInputDTO) {
const result = await this.socket.sendData<RoomSocketOutPutDTO>({
method: 'CreateGroup',
data: {
src/app/module/chat/data/repository/typing/user-typing-live-data-source.service.ts
+13 -2
View File
@@ -3,12 +3,23 @@ import { SignalRService } from 'src/app/infra/socket/signalR/signal-r.service';
import { SessionStore } from 'src/app/store/session.service';
import { filter, map } from 'rxjs/operators';
import { SocketMessage } from 'src/app/infra/socket/signalR/signalR';
import { UserTypingDTO } from '../../dto/typing/typingInputDTO';
import { ITypingRemoteRepository } from 'src/app/core/chat/repository/typing/typing-remote-repository';
import { z } from "zod"
export const UserTypingDTOSchema = z.object({
requestId: z.string(),
roomId: z.string(),
userId: z.number(),
userName: z.string()
})
export type UserTypingDTO = z.infer<typeof UserTypingDTOSchema>
@Injectable({
providedIn: 'root'
})
export class UserTypingRemoteRepositoryService {
export class UserTypingRemoteRepositoryService implements ITypingRemoteRepository {
constructor(
private socket: SignalRService
src/app/module/chat/data/repository/typing/user-typing-local-data-source.service.ts
+5 -2
View File
@@ -3,16 +3,19 @@ import { z } from 'zod';
import { Dexie, EntityTable, liveQuery, Observable } from 'Dexie';
import { err, ok } from 'neverthrow';
import { chatDatabase } from 'src/app/infra/database/dexie/service';
import { TypingTable } from 'src/app/infra/database/dexie/instance/chat/schema/typing';
import { TypingTable, TypingTableSchema } from 'src/app/infra/database/dexie/instance/chat/schema/typing';
import { ITypingLocalRepository } from 'src/app/core/chat/repository/attachment/attachment-local-repository';
import { DexieRepository } from 'src/app/infra/repository/dexie/dexie-repository.service';
@Injectable({
providedIn: 'root'
})
export class UserTypingLocalRepository {
export class UserTypingLocalRepository extends DexieRepository<TypingTable, TypingTable> implements ITypingLocalRepository {
constructor() {
super(chatDatabase.typing, TypingTableSchema)
this.clear();
}