shumengya/cloud-mail
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复自动刷新问题

Browse Source
This commit is contained in:
eoao
2025-06-03 13:29:52 +08:00
parent 9b8598da57
commit 3190b47bb9
11 changed files with 45 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
mail-worker/dist/assets/index-Cy4AcSPU.js → mail-worker/dist/assets/index-BMdBWW7j.js vendored
View File

File diff suppressed because one or more lines are too long

2
mail-worker/dist/assets/index-B2XKi21Y.css → mail-worker/dist/assets/index-Blmh8UBo.css vendored
View File

File diff suppressed because one or more lines are too long

4
mail-worker/dist/index.html vendored
View File

@@ -6,8 +6,8 @@
<title></title>
<link rel="icon" href="/assets/favicon-C5dAZutX.svg" type="image/svg+xml">
<script src="https://challenges.cloudflare.com/turnstile/v0/api.js" async defer></script>
<script type="module" crossorigin src="/assets/index-Cy4AcSPU.js"></script>
<link rel="stylesheet" crossorigin href="/assets/index-B2XKi21Y.css">
<script type="module" crossorigin src="/assets/index-BMdBWW7j.js"></script>
<link rel="stylesheet" crossorigin href="/assets/index-Blmh8UBo.css">
</head>
<body>
<div id="loading-first">

3
mail-worker/src/const/entity-const.js
View File

@@ -33,7 +33,8 @@ export const emailConst = {
DELIVERED: 2,
BOUNCED: 3,
COMPLAINED: 4,
DELAYED: 5
DELAYED: 5,
SAVING: 6
}
}

6
mail-worker/src/email/email.js
View File

@@ -5,6 +5,7 @@ import settingService from '../service/setting-service';
import attService from '../service/att-service';
import constant from '../const/constant';
import fileUtils from '../utils/file-utils';
import { emailConst, isDel } from '../const/entity-const';
export async function email(message, env, ctx) {
@@ -35,7 +36,9 @@ export async function email(message, env, ctx) {
content: email.html,
text: email.text,
userId: account.userId,
accountId: account.accountId
accountId: account.accountId,
isDel: isDel.DELETE,
status: emailConst.status.SAVING
};
const attachments = [];
@@ -60,6 +63,7 @@ export async function email(message, env, ctx) {
})
await attService.addAtt({ env }, attachments);
await emailService.completeReceive({ env }, emailRow.emailId);
} catch (e) {
console.error('邮件接收异常: ', e);

26
mail-worker/src/service/email-service.js
View File

@@ -1,7 +1,7 @@
import orm from '../entity/orm';
import email from '../entity/email';
import { emailConst, isDel, settingConst } from '../const/entity-const';
import { and, desc, eq, gt, inArray, lt, count, asc, like } from 'drizzle-orm';
import { and, desc, eq, gt, inArray, lt, count, asc, like, ne } from 'drizzle-orm';
import { star } from '../entity/star';
import settingService from './setting-service';
import accountService from './account-service';
@@ -248,7 +248,7 @@ const emailService = {
const attsList = await attService.selectByEmailIds(c, [emailRow.emailId]);
emailRow.attList = attsList;
return emailRow;
},
@@ -261,7 +261,7 @@ const emailService = {
async latest(c, params, userId) {
let { emailId, accountId } = params;
const list = orm(c).select().from(email).where(
const list = await orm(c).select().from(email).where(
and(
eq(email.userId, userId),
eq(email.isDel, isDel.NORMAL),
@@ -273,12 +273,16 @@ const emailService = {
.limit(20);
const emailIds = list.map(item => item.emailId);
const attsList = await attService.selectByEmailIds(c, emailIds);
list.forEach(emailRow => {
const atts = attsList.filter(attsRow => attsRow.emailId === emailRow.emailId);
emailRow.attList = atts;
});
if (emailIds.length > 0) {
const attsList = await attService.selectByEmailIds(c, emailIds);
list.forEach(emailRow => {
const atts = attsList.filter(attsRow => attsRow.emailId === emailRow.emailId);
emailRow.attList = atts;
});
}
return list;
},
@@ -394,6 +398,8 @@ const emailService = {
conditions.push(like(email.subject, `${subject}%`));
}
conditions.push(ne(email.status, emailConst.status.SAVING))
const countConditions = [...conditions];
if (timeSort) {
@@ -438,6 +444,10 @@ const emailService = {
async restoreByUserId(c, userId) {
await orm(c).update(email).set({ isDel: isDel.NORMAL }).where(eq(email.userId, userId)).run();
},
async completeReceive(c, emailId) {
await orm(c).update(email).set({ isDel: isDel.NORMAL, status: emailConst.status.RECEIVE }).where(eq(email.emailId, emailId)).run();
}
};

8
mail-worker/src/service/login-service.js
View File

@@ -45,7 +45,7 @@ const loginService = {
}
if (accountRow) {
throw new BizError('该邮箱已被注册');
throw new BizError('该邮箱已被其他用户绑定');
}
if (await settingService.isRegisterVerify(c)) {
@@ -74,15 +74,15 @@ const loginService = {
const userRow = await userService.selectByEmailIncludeDel(c, email);
if (!userRow) {
throw new BizError('该邮箱不存在');
throw new BizError('该用户不存在');
}
if(userRow.isDel === isDel.DELETE) {
throw new BizError('该邮箱已被注销');
throw new BizError('该用户已被注销');
}
if(userRow.status === userConst.status.BAN) {
throw new BizError('该邮箱已被禁用');
throw new BizError('该用户已被禁用');
}
if (!await cryptoUtils.verifyPassword(password, userRow.salt, userRow.password)) {

6
mail-worker/src/service/turnstile-service.js
View File

@@ -1,4 +1,5 @@
import BizError from '../error/biz-error';
import settingService from './setting-service';
const turnstileService = {
@@ -7,13 +8,16 @@ const turnstileService = {
if (!token) {
throw new BizError('验证token不能为空');
}
const settingRow = await settingService.query(c)
const res = await fetch('https://challenges.cloudflare.com/turnstile/v0/siteverify', {
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded'
},
body: new URLSearchParams({
secret: c.env.secret_key,
secret: settingRow.secretKey,
response: token,
remoteip: c.req.header('cf-connecting-ip')
})

11
mail-worker/src/service/user-service.js
View File

@@ -103,6 +103,7 @@ const userService = {
const { userId } = params
await accountService.physicsDeleteByUserIds(c, [userId])
await orm(c).delete(user).where(eq(user.userId, userId)).run();
await c.env.kv.delete(kvConst.AUTH_INFO + userId);
},
async list(c, params, userId) {
@@ -281,7 +282,7 @@ const userService = {
.run();
if (status === userConst.status.BAN) {
c.env.kv.delete(KvConst.AUTH_INFO + userId);
await c.env.kv.delete(KvConst.AUTH_INFO + userId);
}
},
@@ -301,14 +302,6 @@ const userService = {
.where(eq(user.userId, userId))
.run();
if (type) {
const authInfo = await c.env.kv.get(KvConst.AUTH_INFO + userId, { type: 'json' });
if (authInfo) {
authInfo.user.type = type;
await c.env.kv.put(KvConst.AUTH_INFO + userId, JSON.stringify(authInfo));
}
}
},
async incrUserService(c, quantity, userId) {