Compare commits

...

15 Commits

Author SHA1 Message Date
CrescentLeaf
082817d6cd feat(wip): 收發消息 2025-09-21 02:18:15 +08:00
CrescentLeaf
ee79e3eefa chore: RecentChat -> extends <- Chat 2025-09-21 02:18:05 +08:00
CrescentLeaf
6a1084eeca fix: Chat 創建失敗, 並修正了 ChatPrivate 獲取對方的邏輯 2025-09-21 02:17:44 +08:00
CrescentLeaf
71e6d24d6e fix: Chat 獲取 avatar 邏輯錯誤 2025-09-21 02:16:48 +08:00
CrescentLeaf
7686a9b7d1 chore: 使 Client.invoke 支持等待后請求, 解耦 updateCachedProfile 2025-09-21 02:16:01 +08:00
CrescentLeaf
4837c17c2e fix: Chat (客戶端側) title 設置為非空 2025-09-21 02:15:27 +08:00
CrescentLeaf
3d367711cc feat(wip): 聯絡人/群組對話框, 並打開對應的對話 2025-09-21 02:14:39 +08:00
CrescentLeaf
6f006f38a4 fix: app.use -> get 2025-09-21 02:13:55 +08:00
CrescentLeaf
cb4aeaed21 fix(ui): Avatar 不顯示文字 2025-09-21 02:13:28 +08:00
CrescentLeaf
791baf474c feat: 修復並正式支持聯絡人
* wip(ui): 增刪
2025-09-21 02:13:16 +08:00
CrescentLeaf
468de4f439 feat(ui): 編輯個人檔案對話框 2025-09-21 02:11:47 +08:00
CrescentLeaf
2ec4f634ae feat(wip): remove contact 2025-09-20 21:17:43 +08:00
CrescentLeaf
8f7e61dfd2 feat: Chat (instance) getAnotherUserForPrivate 2025-09-20 20:59:12 +08:00
CrescentLeaf
212c2fa5dc chore: 重命名易混淆的 ChatPrivate findFor 方法 2025-09-20 20:58:44 +08:00
CrescentLeaf
dd88e8d1b8 chore: 添加 ChatApi 注釋 2025-09-20 20:58:20 +08:00
18 changed files with 249 additions and 156 deletions

View File

@@ -3,11 +3,14 @@ export type CallMethod =
"User.register" |
"User.login" |
"User.setNickName" |
"User.setUserName" |
"User.setAvatar" |
"User.updateProfile" |
"User.getMyInfo" |
"User.getMyContacts" |
"User.addContact" |
"User.removeContacts" |
"Chat.getInfo" |
"Chat.sendMessage" |
"Chat.getMessageHistory"

View File

@@ -2,6 +2,7 @@ import { io, Socket } from 'socket.io-client'
import { CallMethod, ClientEvent } from './ApiDeclare.ts'
import ApiCallbackMessage from './ApiCallbackMessage.ts'
import User from "./client_data/User.ts"
import data from "../Data.ts";
type UnknownObject = { [key: string]: unknown }
@@ -26,7 +27,11 @@ class Client {
})
}
static invoke(method: CallMethod, args: UnknownObject = {}, timeout: number = 5000): Promise<ApiCallbackMessage> {
if (this.socket == null) throw new Error("客戶端未與伺服器端建立連接!")
if (this.socket == null) {
return new Promise((reslove) => {
setTimeout(async () => reslove(await this.invoke(method, args, timeout)), 500)
})
}
return new Promise((resolve, reject) => {
this.socket!.timeout(timeout).emit("The_White_Silk", method, args, (err: string, res: ApiCallbackMessage) => {
if (err) return reject(err)
@@ -39,11 +44,14 @@ class Client {
access_token: token
}, timeout)
if (re.code == 200)
this.myUserProfile = (await Client.invoke("User.getMyInfo", {
token: token
})).data as unknown as User
await this.updateCachedProfile()
return re
}
static async updateCachedProfile() {
this.myUserProfile = (await Client.invoke("User.getMyInfo", {
token: data.access_token
})).data as unknown as User
}
static on(eventName: ClientEvent, func: (data: UnknownObject) => UnknownObject) {
this.events[eventName] = func
}

View File

@@ -1,7 +1,7 @@
export default class Chat {
declare type: "paivate" | "group"
declare id: string
declare title?: string
declare title: string
declare avatar_file_hash?: string
declare user_a_id?: string
declare user_b_id?: string

View File

@@ -1,6 +1,5 @@
export default class RecentChat {
declare id: string
declare title: string
declare avatar?: string
import Chat from "./Chat.ts"
export default class RecentChat extends Chat {
declare content: string
}

View File

@@ -18,6 +18,8 @@ import UserProfileDialog from "./dialog/UserProfileDialog.tsx"
import ContactsList from "./main/ContactsList.tsx"
import RecentsList from "./main/RecentsList.tsx"
import useAsyncEffect from "./useAsyncEffect.ts"
import ChatInfoDialog from "./dialog/ChatInfoDialog.tsx";
import Chat from "../api/client_data/Chat.ts";
declare global {
namespace React {
@@ -31,32 +33,7 @@ declare global {
}
export default function App() {
const [recentsList, setRecentsList] = React.useState([
{
id: '0',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
title: "麻油衣酱",
content: "成步堂君, 我又坐牢了("
},
{
id: '1',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
title: "Maya Fey",
content: "我是绫里真宵, 是一名灵媒师~"
},
] as RecentChat[])
const [contactsList, setContactsList] = React.useState([
{
id: '1',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
nickname: "麻油衣酱",
},
{
id: '0',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
nickname: "Maya Fey",
},
] as User[])
const [recentsList, setRecentsList] = React.useState([] as RecentChat[])
const [navigationItemSelected, setNavigationItemSelected] = React.useState('Recents')
@@ -80,7 +57,10 @@ export default function App() {
userProfileDialogRef.current!.open = true
})
const [myUserProfileCache, setMyUserProfileCache]: [User, React.Dispatch<React.SetStateAction<User>>] = React.useState(null as unknown as User)
const chatInfoDialogRef = React.useRef<Dialog>(null)
const [chatInfo, setChatInfo] = React.useState(null as unknown as Chat)
const [myUserProfileCache, setMyUserProfileCache] = React.useState(null as unknown as User)
const [isShowChatFragment, setIsShowChatFragment] = React.useState(false)
@@ -133,6 +113,14 @@ export default function App() {
userProfileDialogRef={userProfileDialogRef as any}
user={myUserProfileCache} />
<ChatInfoDialog
chatInfoDialogRef={chatInfoDialogRef as any}
openChatFragment={(id) => {
setCurrentChatId(id)
setIsShowChatFragment(true)
}}
chat={chatInfo} />
<mdui-navigation-rail contained value="Recents" ref={navigationRailRef}>
<mdui-button-icon slot="top">
<Avatar src={myUserProfileCache?.avatar} text={myUserProfileCache?.nickname} avatarRef={openMyUserProfileDialogButtonRef} />
@@ -162,9 +150,8 @@ export default function App() {
{
// 联系人列表
<ContactsList
openChatFragment={(id) => {
setIsShowChatFragment(true)
}}
setChatInfo={setChatInfo}
chatInfoDialogRef={chatInfoDialogRef as any}
display={navigationItemSelected == "Contacts"} />
}
</div>

View File

@@ -17,7 +17,7 @@ export default function Avatar({
else if (text != null)
return <mdui-avatar ref={avatarRef} {...props}>
{
text.substring(0, 0)
text.substring(0, 1)
}
</mdui-avatar>
else

View File

@@ -37,7 +37,26 @@ export default function ChatFragment({ target, ...props }: Args) {
setChatInfo(re.data as Chat)
}, [target])
console.log(tabItemSelected)
let page = 0
async function loadMore() {
const re = await Client.invoke("Chat.getMessageHistory", {
token: data.access_token,
target,
page,
})
if (checkApiSuccessOrSncakbar(re, "拉取歷史記錄失敗")) return
page++
setMessagesList(messagesList.concat())
}
React.useEffect(() => {
return () => {
}
})
return (
<div style={{
width: '100%',

View File

@@ -4,20 +4,28 @@ import useAsyncEffect from "../useAsyncEffect.ts"
import Client from "../../api/Client.ts"
import data from "../../Data.ts"
import { Dialog } from "mdui"
import Avatar from "../Avatar.tsx";
import { checkApiSuccessOrSncakbar } from "../snackbar.ts"
interface Args extends React.HTMLAttributes<HTMLElement> {
chat: Chat
openChatFragment: (id: string) => void
chatInfoDialogRef: React.MutableRefObject<Dialog>
}
export default function ChatInfoDialog({ chat, chatInfoDialogRef }: Args) {
const [isMySelf, setIsMySelf] = React.useState(false)
export default function ChatInfoDialog({ chat, chatInfoDialogRef, openChatFragment }: Args) {
const [chatInfo, setChatInfo] = React.useState(null as unknown as Chat)
const isMySelf = Client.myUserProfile?.id == chatInfo?.user_a_id && Client.myUserProfile?.id == chatInfo?.user_b_id
useAsyncEffect(async () => {
if (chat == null) return
const re = await Client.invoke("Chat.getInfo", {
token: data.access_token,
target: chat.id,
})
if (re.code != 200)
return checkApiSuccessOrSncakbar(re, '獲取對話訊息失敗')
setChatInfo(re.data!.chat_info as Chat)
})
return (
@@ -26,14 +34,14 @@ export default function ChatInfoDialog({ chat, chatInfoDialogRef }: Args) {
display: 'flex',
alignItems: 'center',
}}>
<Avatar src={chat?.avatar} text={chat?.nickname} style={{
<Avatar src={chat?.avatar as string} text={chat?.nickname as string} style={{
width: '50px',
height: '50px',
}} />
<span style={{
marginLeft: "15px",
fontSize: '16.5px',
}}>{user?.nickname}</span>
}}>{chat?.title}</span>
</div>
<mdui-divider style={{
marginTop: "10px",
@@ -41,14 +49,10 @@ export default function ChatInfoDialog({ chat, chatInfoDialogRef }: Args) {
}}></mdui-divider>
<mdui-list>
{!isMySelf && <mdui-list-item icon="edit" rounded></mdui-list-item>}
{
isMySelf && <>
<mdui-list-item icon="edit" rounded></mdui-list-item>
<mdui-list-item icon="settings" rounded></mdui-list-item>
<mdui-list-item icon="lock" rounded></mdui-list-item>
</>
}
<mdui-list-item icon="chat" rounded onClick={() => {
chatInfoDialogRef.current!.open = false
openChatFragment(chat.id)
}}></mdui-list-item>
</mdui-list>
</mdui-dialog>
)

View File

@@ -39,20 +39,20 @@ export default function UserProfileDialog({
})
})
return (
<mdui-dialog close-on-overlay-click close-on-esc ref={userProfileDialogRef}>
<div style={{
display: "none"
}}>
<input type="file" name="選擇頭像" ref={chooseAvatarFileRef}
accept="image/*" />
</div>
const userProfileEditDialogRef = React.useRef<Dialog>(null)
const editNickNameRef = React.useRef<TextField>(null)
const editUserNameRef = React.useRef<TextField>(null)
return (<>
{
// 公用 - 資料卡
}
<mdui-dialog close-on-overlay-click close-on-esc ref={userProfileDialogRef}>
<div style={{
display: 'flex',
alignItems: 'center',
}}>
<Avatar src={user?.avatar} text={user?.nickname} avatarRef={editAvatarButtonRef} style={{
<Avatar src={user?.avatar} text={user?.nickname} style={{
width: '50px',
height: '50px',
}} />
@@ -70,12 +70,58 @@ export default function UserProfileDialog({
{!isMySelf && <mdui-list-item icon="edit" rounded></mdui-list-item>}
{
isMySelf && <>
<mdui-list-item icon="edit" rounded></mdui-list-item>
<mdui-list-item icon="edit" rounded onClick={() => userProfileEditDialogRef.current!.open = true}></mdui-list-item>
<mdui-list-item icon="settings" rounded></mdui-list-item>
<mdui-list-item icon="lock" rounded></mdui-list-item>
</>
}
</mdui-list>
</mdui-dialog>
)
{
// 個人資料編輯
}
<mdui-dialog close-on-overlay-click close-on-esc ref={userProfileEditDialogRef}>
<div style={{
display: "none"
}}>
<input type="file" name="選擇頭像" ref={chooseAvatarFileRef}
accept="image/*" />
</div>
<div style={{
display: 'flex',
alignItems: 'center',
}}>
<Avatar src={user?.avatar} text={user?.nickname} avatarRef={editAvatarButtonRef} style={{
width: '50px',
height: '50px',
}} />
<mdui-text-field variant="outlined" placeholder="昵稱" ref={editNickNameRef as any} style={{
marginLeft: "15px",
}} value={user?.nickname}></mdui-text-field>
</div>
<mdui-divider style={{
marginTop: "10px",
marginBottom: "10px",
}}></mdui-divider>
<mdui-text-field variant="outlined" label="用戶名" value={user?.username || ''} ref={editUserNameRef as any}></mdui-text-field>
<mdui-button slot="action" variant="text" onClick={() => userProfileEditDialogRef.current!.open = false}></mdui-button>
<mdui-button slot="action" variant="text" onClick={async () => {
const re = await Client.invoke("User.updateProfile", {
token: data.access_token,
nickname: editNickNameRef.current?.value,
username: editUserNameRef.current?.value,
})
if (checkApiSuccessOrSncakbar(re, "修改失敗")) return
snackbar({
message: "修改成功 (刷新頁面以更新)",
placement: "top",
})
userProfileEditDialogRef.current!.open = false
}}></mdui-button>
</mdui-dialog>
</>)
}

View File

@@ -1,44 +1,42 @@
import React from "react"
import User from "../../api/client_data/User.ts"
import ContactsListItem from "./ContactsListItem.tsx"
import useEventListener from "../useEventListener.ts"
import { ListItem, TextField } from "mdui"
import { Dialog, ListItem, TextField } from "mdui"
import useAsyncEffect from "../useAsyncEffect.ts"
import Client from "../../api/Client.ts"
import data from "../../Data.ts"
import { checkApiSuccessOrSncakbar } from "../snackbar.ts"
import Chat from "../../api/client_data/Chat.ts"
interface Args extends React.HTMLAttributes<HTMLElement> {
display: boolean
openChatFragment: (id: string) => void
chatInfoDialogRef: React.MutableRefObject<Dialog>
setChatInfo: React.Dispatch<React.SetStateAction<Chat>>
}
export default function ContactsList({
display,
openChatFragment,
setChatInfo,
chatInfoDialogRef,
...props
}: Args) {
const searchRef = React.useRef<HTMLElement>(null)
const [isMultiSelecting, setIsMultiSelecting] = React.useState(false)
const [searchText, setSearchText] = React.useState('')
const [contactsList, setContactsList] = React.useState([
{
id: '1',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
nickname: "麻油衣酱",
},
{
id: '0',
avatar: "https://www.court-records.net/mugshot/aa6-004-maya.png",
nickname: "Maya Fey",
},
] as User[])
const [contactsList, setContactsList] = React.useState<Chat[]>([])
useEventListener(searchRef, 'input', (e) => {
setSearchText((e.target as unknown as TextField).value)
})
useAsyncEffect(async () => {
const re = await Client.invoke("User.getMyContacts", {
token: data.access_token,
})
if (re.code != 200)
return checkApiSuccessOrSncakbar(re, "获取联络人列表失败")
setContactsList(re.data!.contacts_list as Chat[])
})
return <mdui-list style={{
@@ -63,21 +61,21 @@ export default function ContactsList({
}} icon={ isMultiSelecting ? "done" : "edit"} onClick={() => setIsMultiSelecting(!isMultiSelecting)}>{ isMultiSelecting ? "關閉多選" : "多選模式" }</mdui-list-item> */}
{
contactsList.filter((user) =>
contactsList.filter((chat) =>
searchText == '' ||
user.nickname.includes(searchText) ||
user.id.includes(searchText) ||
user.username?.includes(searchText)
chat.title.includes(searchText) ||
chat.id.includes(searchText)
).map((v) =>
<ContactsListItem
/* active={!isMultiSelecting && false}
// active={!isMultiSelecting && false}
onClick={(e) => {
const self = (e.target as ListItem)
if (isMultiSelecting)
/*if (isMultiSelecting)
self.active = !self.active
else
void(0)
}} */
else*/
setChatInfo(v)
chatInfoDialogRef.current!.open = true
}}
key={v.id}
contact={v} />
)

View File

@@ -1,15 +1,14 @@
import { ListItem } from "mdui";
import User from "../../api/client_data/User.ts"
import Chat from "../../api/client_data/Chat.ts"
import Avatar from "../Avatar.tsx"
import React from 'react'
interface Args extends React.HTMLAttributes<HTMLElement> {
contact: User
contact: Chat
active?: boolean
}
export default function ContactsListItem({ contact, ...prop }: Args) {
const { id, nickname, avatar } = contact
const { id, title, avatar } = contact
const ref = React.useRef<HTMLElement>(null)
return (
@@ -20,8 +19,8 @@ export default function ContactsListItem({ contact, ...prop }: Args) {
}} {...prop as any}>
<span style={{
width: "100%",
}}>{nickname}</span>
<Avatar src={avatar} text="title" slot="icon" />
}}>{title}</span>
<Avatar src={avatar as string} text={title} slot="icon" />
</mdui-list-item>
)
}

View File

@@ -3,9 +3,8 @@ export type CallMethod =
"User.register" |
"User.login" |
"User.setNickName" |
"User.setUserName" |
"User.setAvatar" |
"User.updateProfile" |
"User.getMyInfo" |
"User.getMyContacts" |

View File

@@ -1,5 +1,6 @@
import Chat from "../data/Chat.ts";
import ChatPrivate from "../data/ChatPrivate.ts";
import MessagesManager from "../data/MessagesManager.ts";
import User from "../data/User.ts"
import BaseApi from "./BaseApi.ts"
import TokenManager from "./TokenManager.ts"
@@ -9,6 +10,11 @@ export default class ChatApi extends BaseApi {
return "Chat"
}
override onInit(): void {
/**
* 獲取對話訊息
* @param token 令牌
* @param target 目標對話
*/
this.registerEvent("Chat.getInfo", (args) => {
if (this.checkArgsMissing(args, ['token', 'target'])) return {
msg: "參數缺失",
@@ -36,8 +42,8 @@ export default class ChatApi extends BaseApi {
msg: "成功",
data: {
type: chat.bean.type,
title: chat.getTitleForPrivate(mine),
avatar: chat.bean.avatar_file_hash ? "uploaded_files/" + chat.bean.avatar_file_hash : chat.bean.avatar_file_hash
title: chat.getTitle(mine),
avatar: chat.getAvatarFileHash(mine) ? "uploaded_files/" + chat.getAvatarFileHash(mine) : undefined
}
}
}
@@ -47,6 +53,12 @@ export default class ChatApi extends BaseApi {
msg: "not implmented",
}
})
/**
* 發送訊息
* @param token 令牌
* @param target 目標對話
* @param
*/
this.registerEvent("Chat.sendMessage", (args) => {
if (this.checkArgsMissing(args, ['token', 'target'])) return {
msg: "參數缺失",
@@ -64,8 +76,14 @@ export default class ChatApi extends BaseApi {
msg: "未實現",
}
})
/**
* 拉取歷史訊息
* @param token 令牌
* @param target 目標對話
* @param page 頁面
*/
this.registerEvent("Chat.getMessageHistory", (args) => {
if (this.checkArgsMissing(args, ['token', 'target'])) return {
if (this.checkArgsMissing(args, ['token', 'target', 'page'])) return {
msg: "參數缺失",
code: 400,
}
@@ -76,9 +94,18 @@ export default class ChatApi extends BaseApi {
msg: "令牌無效",
}
const chat = Chat.findById(args.target as string)
if (chat == null) return {
code: 404,
msg: "對話不存在",
}
return {
code: 501,
msg: "未實現",
code: 200,
msg: "成功",
data: {
messages: MessagesManager.getInstanceForChat(chat).getMessagesWithPage(),
},
}
})
}

View File

@@ -18,7 +18,7 @@ export default class UserApi extends BaseApi {
}
try {
const access_token = TokenManager.decode(args.access_token as string)
if (access_token.expired_time < Date.now()) return {
msg: "登錄令牌失效",
code: 401,
@@ -129,13 +129,13 @@ export default class UserApi extends BaseApi {
code: 200,
}
})
// 更新昵稱
this.registerEvent("User.setNickName", (args) => {
if (this.checkArgsMissing(args, ['nickname', 'token'])) return {
// 更新資料
this.registerEvent("User.updateProfile", (args) => {
if (this.checkArgsMissing(args, ['token'])) return {
msg: "參數缺失",
code: 400,
}
const token = TokenManager.decode(args.token as string)
if (!this.checkToken(token)) return {
code: 401,
@@ -143,28 +143,10 @@ export default class UserApi extends BaseApi {
}
const user = User.findById(token.author)
user!.setNickName(args.nickname as string)
return {
msg: "成功",
code: 200,
}
})
// 更新用戶名
this.registerEvent("User.setUserName", (args) => {
if (this.checkArgsMissing(args, ['username', 'token'])) return {
msg: "參數缺失",
code: 400,
}
const token = TokenManager.decode(args.token as string)
if (!this.checkToken(token)) return {
code: 401,
msg: "令牌無效",
}
const user = User.findById(token.author)
user!.setUserName(args.username as string)
if (args.nickname != null)
user!.setNickName(args.nickname as string)
if (args.username != null)
user!.setUserName(args.username as string)
return {
msg: "成功",
@@ -210,14 +192,21 @@ export default class UserApi extends BaseApi {
msg: "令牌無效",
}
const user = User.findById(token.author)
const user = User.findById(token.author) as User
const contacts = user.getContactsList()
contacts.push(ChatPrivate.getChatIdByUsersId(token.author, token.author))
return {
msg: "成功",
code: 200,
data: {
contacts: user!.getContactsList().map((id) => {
title: Chat.findById(id)?.bean.title
contacts_list: contacts.map((id) => {
const chat = Chat.findById(id)
return {
id,
title: chat?.getTitle(user) || "未知",
avatar: chat?.getAvatarFileHash(user) ? "uploaded_files/" + chat?.getAvatarFileHash(user) : undefined
}
})
}
}
@@ -248,6 +237,6 @@ export default class UserApi extends BaseApi {
* 公開資料
* ================================================
*/
}
}

View File

@@ -25,7 +25,7 @@ export default class Chat {
/* Chat ID */ id TEXT NOT NULL,
/* 標題 (群組) */ title TEXT,
/* 頭像 (群組) */ avatar BLOB,
/* UserIdA (私信) */ user_a_id TEXT
/* UserIdA (私信) */ user_a_id TEXT,
/* UserIdB (私信) */ user_b_id TEXT,
/* 设置 */ settings TEXT NOT NULL
);
@@ -57,8 +57,8 @@ export default class Chat {
avatar,
user_a_id,
user_b_id,
settings,
) VALUES (?, ?);`).run(
settings
) VALUES (?, ?, ?, ?, ?, ?, ?);`).run(
type,
chatId,
null,
@@ -76,17 +76,26 @@ export default class Chat {
constructor(bean: ChatBean) {
this.bean = bean
}
private setAttr(key: string, value: SQLInputValue): void {
setAttr(key: string, value: SQLInputValue): void {
Chat.database.prepare(`UPDATE ${Chat.table_name} SET ${key} = ? WHERE id = ?`).run(value, this.bean.id)
this.bean[key] = value
}
getTitleForPrivate(userMySelf: User) {
getAnotherUserForPrivate(userMySelf: User) {
// 注意: 這裏已經確定了 Chat, 不需要再指定對方用戶
if (this.bean.user_a_id == userMySelf.bean.id)
return User.findById(this.bean?.user_b_id as string)?.getNickName() || "未知對話"
return User.findById(this.bean?.user_b_id as string)
if (this.bean.user_b_id == userMySelf.bean.id)
return userMySelf.getNickName()
return userMySelf
return "未知對話"
return null
}
getTitle(userMySelf?: User) {
if (this.bean.type == 'group') return this.bean.title
if (this.bean.type == 'private') return this.getAnotherUserForPrivate(userMySelf as User)?.getNickName()
}
getAvatarFileHash(userMySelf?: User) {
if (this.bean.type == 'group') return this.bean.avatar_file_hash
if (this.bean.type == 'private') return this.getAnotherUserForPrivate(userMySelf as User)?.getAvatarFileHash()
}
}

View File

@@ -12,16 +12,20 @@ export default class ChatPrivate extends Chat {
}
static createForPrivate(userA: User, userB: User) {
return this.create(this.getChatIdByUsersId(userA.bean.id, userB.bean.id), 'private')
const chat = this.create(this.getChatIdByUsersId(userA.bean.id, userB.bean.id), 'private')
chat.setAttr('user_a_id', userA.bean.id)
chat.setAttr('user_b_id', userB.bean.id)
}
static findForPrivate(userA: User, userB: User) {
return this.fromChat(this.findById(this.getChatIdByUsersId(userA.bean.id, userB.bean.id)) as Chat)
static findByUsersForPrivate(userA: User, userB: User) {
const chat = this.findById(this.getChatIdByUsersId(userA.bean.id, userB.bean.id))
if (chat)
return this.fromChat(chat as Chat)
}
static findOrCreateForPrivate(userA: User, userB: User) {
let a = this.findForPrivate(userA, userB)
let a = this.findByUsersForPrivate(userA, userB)
if (a == null) {
this.createForPrivate(userA, userB)
a = this.findForPrivate(userA, userB) as ChatPrivate
a = this.findByUsersForPrivate(userA, userB) as ChatPrivate
}
return a
}

View File

@@ -36,7 +36,7 @@ export default class User {
/* 用戶名, 可選 */ username TEXT,
/* 昵称 */ nickname TEXT NOT NULL,
/* 头像, 可选 */ avatar_file_hash TEXT,
/* 聯絡人組 */ contact_groups TEXT NOT NULL,
/* 聯絡人組 */ contacts_list TEXT NOT NULL,
/* 设置 */ settings TEXT NOT NULL
);
`)
@@ -80,7 +80,7 @@ export default class User {
)[0]
)
avatar && user.setAvatar(avatar)
user.addContact(ChatPrivate.getChatIdByUsersId(user.bean.id, user.bean.id))
ChatPrivate.findOrCreateForPrivate(user, user)
return user
}
@@ -124,14 +124,16 @@ export default class User {
ls.push(chatId)
this.setAttr("contacts_list", JSON.stringify(ls))
}
removeContacts(contacts: string[]) {
const ls = this.getContactsList().filter((v) => !contacts.includes(v))
this.setAttr("contacts_list", JSON.stringify(ls))
}
getContactsList() {
try {
return JSON.parse(this.bean.contacts_list) as string[]
} catch (e) {
console.log(chalk.yellow(`警告: 聯絡人組解析失敗: ${(e as Error).message}`))
return [
this.bean.id
]
return []
}
}
getNickName(): string {

View File

@@ -15,7 +15,7 @@ import path from "node:path"
const app = express()
app.use('/', express.static(config.data_path + '/page_compiled'))
app.use('/uploaded_files/:hash', (req, res) => {
app.get('/uploaded_files/:hash', (req, res) => {
const hash = req.params.hash as string
if (hash == null) {
res.sendStatus(404)
@@ -39,7 +39,7 @@ const httpServer: HttpServerLike = (
http.createServer(app)
)
const io = new SocketIo.Server(httpServer, {
maxHttpBufferSize: 1e9,
})
ApiManager.initServer(httpServer, io)