summaryrefslogtreecommitdiff
path: root/src/server/api
diff options
context:
space:
mode:
authorAcid Chicken (硫酸鶏) <root@acid-chicken.com>2019-07-20 02:02:48 +0900
committerAcid Chicken (硫酸鶏) <root@acid-chicken.com>2019-07-20 02:02:48 +0900
commit42af8c76956416f8d7c99e3ea30cc5ec62cc3065 (patch)
treee06ee33209a56672e79677557ed8ffc856c01540 /src/server/api
parentNothing (diff)
parent[ImgBot] Optimize images (#5189) (diff)
downloadmisskey-42af8c76956416f8d7c99e3ea30cc5ec62cc3065.tar.gz
misskey-42af8c76956416f8d7c99e3ea30cc5ec62cc3065.tar.bz2
misskey-42af8c76956416f8d7c99e3ea30cc5ec62cc3065.zip
Merge branch 'develop' of https://github.com/syuilo/misskey into develop
Diffstat (limited to 'src/server/api')
-rw-r--r--src/server/api/common/signin.ts18
-rw-r--r--src/server/api/endpoints/admin/show-users.ts18
-rw-r--r--src/server/api/endpoints/admin/suspend-user.ts6
-rw-r--r--src/server/api/endpoints/admin/unsuspend-user.ts3
-rw-r--r--src/server/api/endpoints/i/delete-account.ts4
-rw-r--r--src/server/api/endpoints/i/update.ts15
-rw-r--r--src/server/api/private/signin.ts22
-rw-r--r--src/server/api/private/signup.ts12
8 files changed, 83 insertions, 15 deletions
diff --git a/src/server/api/common/signin.ts b/src/server/api/common/signin.ts
index 0f4ee4ca11..37229ad1bc 100644
--- a/src/server/api/common/signin.ts
+++ b/src/server/api/common/signin.ts
@@ -2,6 +2,9 @@ import * as Koa from 'koa';
import config from '../../../config';
import { ILocalUser } from '../../../models/entities/user';
+import { Signins } from '../../../models';
+import { genId } from '../../../misc/gen-id';
+import { publishMainStream } from '../../../services/stream';
export default function(ctx: Koa.BaseContext, user: ILocalUser, redirect = false) {
if (redirect) {
@@ -24,4 +27,19 @@ export default function(ctx: Koa.BaseContext, user: ILocalUser, redirect = false
ctx.body = { i: user.token };
ctx.status = 200;
}
+
+ (async () => {
+ // Append signin history
+ const record = await Signins.save({
+ id: genId(),
+ createdAt: new Date(),
+ userId: user.id,
+ ip: ctx.ip,
+ headers: ctx.headers,
+ success: true
+ });
+
+ // Publish signin event
+ publishMainStream(user.id, 'signin', await Signins.pack(record));
+ })();
}
diff --git a/src/server/api/endpoints/admin/show-users.ts b/src/server/api/endpoints/admin/show-users.ts
index 8733d87a38..89e0cf1e2a 100644
--- a/src/server/api/endpoints/admin/show-users.ts
+++ b/src/server/api/endpoints/admin/show-users.ts
@@ -49,6 +49,16 @@ export const meta = {
'remote',
]),
default: 'local'
+ },
+
+ username: {
+ validator: $.optional.str,
+ default: null
+ },
+
+ hostname: {
+ validator: $.optional.str,
+ default: null
}
}
};
@@ -70,6 +80,14 @@ export default define(meta, async (ps, me) => {
case 'remote': query.andWhere('user.host IS NOT NULL'); break;
}
+ if (ps.username) {
+ query.andWhere('user.usernameLower like :username', { username: ps.username.toLowerCase() + '%' });
+ }
+
+ if (ps.hostname) {
+ query.andWhere('user.host like :hostname', { hostname: '%' + ps.hostname.toLowerCase() + '%' });
+ }
+
switch (ps.sort) {
case '+follower': query.orderBy('user.followersCount', 'DESC'); break;
case '-follower': query.orderBy('user.followersCount', 'ASC'); break;
diff --git a/src/server/api/endpoints/admin/suspend-user.ts b/src/server/api/endpoints/admin/suspend-user.ts
index 09fdbb070e..6ba0d91505 100644
--- a/src/server/api/endpoints/admin/suspend-user.ts
+++ b/src/server/api/endpoints/admin/suspend-user.ts
@@ -5,6 +5,7 @@ import deleteFollowing from '../../../../services/following/delete';
import { Users, Followings } from '../../../../models';
import { User } from '../../../../models/entities/user';
import { insertModerationLog } from '../../../../services/insert-moderation-log';
+import { doPostSuspend } from '../../../../services/suspend-user';
export const meta = {
desc: {
@@ -51,7 +52,10 @@ export default define(meta, async (ps, me) => {
targetId: user.id,
});
- unFollowAll(user);
+ (async () => {
+ await doPostSuspend(user).catch(e => {});
+ await unFollowAll(user).catch(e => {});
+ })();
});
async function unFollowAll(follower: User) {
diff --git a/src/server/api/endpoints/admin/unsuspend-user.ts b/src/server/api/endpoints/admin/unsuspend-user.ts
index a1c80d3121..237585e276 100644
--- a/src/server/api/endpoints/admin/unsuspend-user.ts
+++ b/src/server/api/endpoints/admin/unsuspend-user.ts
@@ -3,6 +3,7 @@ import { ID } from '../../../../misc/cafy-id';
import define from '../../define';
import { Users } from '../../../../models';
import { insertModerationLog } from '../../../../services/insert-moderation-log';
+import { doPostUnsuspend } from '../../../../services/unsuspend-user';
export const meta = {
desc: {
@@ -40,4 +41,6 @@ export default define(meta, async (ps, me) => {
insertModerationLog(me, 'unsuspend', {
targetId: user.id,
});
+
+ doPostUnsuspend(user);
});
diff --git a/src/server/api/endpoints/i/delete-account.ts b/src/server/api/endpoints/i/delete-account.ts
index 8ec85c9f41..b4950cb1fb 100644
--- a/src/server/api/endpoints/i/delete-account.ts
+++ b/src/server/api/endpoints/i/delete-account.ts
@@ -3,6 +3,7 @@ import * as bcrypt from 'bcryptjs';
import define from '../../define';
import { Users, UserProfiles } from '../../../../models';
import { ensure } from '../../../../prelude/ensure';
+import { doPostSuspend } from '../../../../services/suspend-user';
export const meta = {
requireCredential: true,
@@ -26,5 +27,8 @@ export default define(meta, async (ps, user) => {
throw new Error('incorrect password');
}
+ // 物理削除する前にDelete activityを送信する
+ await doPostSuspend(user).catch(e => {});
+
await Users.delete(user.id);
});
diff --git a/src/server/api/endpoints/i/update.ts b/src/server/api/endpoints/i/update.ts
index a454cdb940..149081e50b 100644
--- a/src/server/api/endpoints/i/update.ts
+++ b/src/server/api/endpoints/i/update.ts
@@ -77,6 +77,13 @@ export const meta = {
}
},
+ fields: {
+ validator: $.optional.arr($.object()).range(1, 4),
+ desc: {
+ 'ja-JP': 'プロフィール補足情報'
+ }
+ },
+
isLocked: {
validator: $.optional.bool,
desc: {
@@ -226,6 +233,14 @@ export default define(meta, async (ps, user, app) => {
profileUpdates.pinnedPageId = null;
}
+ if (ps.fields) {
+ profileUpdates.fields = ps.fields
+ .filter(x => typeof x.name === 'string' && x.name !== '' && typeof x.value === 'string' && x.value !== '')
+ .map(x => {
+ return { name: x.name, value: x.value };
+ });
+ }
+
//#region emojis/tags
let emojis = [] as string[];
diff --git a/src/server/api/private/signin.ts b/src/server/api/private/signin.ts
index eb267aa604..de0e35f500 100644
--- a/src/server/api/private/signin.ts
+++ b/src/server/api/private/signin.ts
@@ -1,7 +1,6 @@
import * as Koa from 'koa';
import * as bcrypt from 'bcryptjs';
import * as speakeasy from 'speakeasy';
-import { publishMainStream } from '../../../services/stream';
import signin from '../common/signin';
import config from '../../../config';
import { Users, Signins, UserProfiles, UserSecurityKeys, AttestationChallenges } from '../../../models';
@@ -53,34 +52,30 @@ export default async (ctx: Koa.BaseContext) => {
// Compare password
const same = await bcrypt.compare(password, profile.password!);
- async function fail(status?: number, failure?: {error: string}) {
+ async function fail(status?: number, failure?: { error: string }) {
// Append signin history
- const record = await Signins.save({
+ await Signins.save({
id: genId(),
createdAt: new Date(),
userId: user.id,
ip: ctx.ip,
headers: ctx.headers,
- success: !!(status || failure)
+ success: false
});
- // Publish signin event
- publishMainStream(user.id, 'signin', await Signins.pack(record));
-
- if (status && failure) {
- ctx.throw(status, failure);
- }
+ ctx.throw(status || 500, failure || { error: 'someting happened' });
}
if (!profile.twoFactorEnabled) {
if (same) {
signin(ctx, user);
+ return;
} else {
await fail(403, {
error: 'incorrect password'
});
+ return;
}
- return;
}
if (token) {
@@ -169,6 +164,7 @@ export default async (ctx: Koa.BaseContext) => {
if (isValid) {
signin(ctx, user);
+ return;
} else {
await fail(403, {
error: 'invalid challenge data'
@@ -191,6 +187,7 @@ export default async (ctx: Koa.BaseContext) => {
await fail(403, {
error: 'no keys found'
});
+ return;
}
// 32 byte challenge
@@ -219,6 +216,5 @@ export default async (ctx: Koa.BaseContext) => {
ctx.status = 200;
return;
}
-
- await fail();
+ // never get here
};
diff --git a/src/server/api/private/signup.ts b/src/server/api/private/signup.ts
index ac99ea0d33..026fe7485b 100644
--- a/src/server/api/private/signup.ts
+++ b/src/server/api/private/signup.ts
@@ -5,7 +5,7 @@ import generateUserToken from '../common/generate-native-user-token';
import config from '../../../config';
import { fetchMeta } from '../../../misc/fetch-meta';
import * as recaptcha from 'recaptcha-promise';
-import { Users, RegistrationTickets } from '../../../models';
+import { Users, Signins, RegistrationTickets } from '../../../models';
import { genId } from '../../../misc/gen-id';
import { usersChart } from '../../../services/chart';
import { User } from '../../../models/entities/user';
@@ -137,6 +137,16 @@ export default async (ctx: Koa.BaseContext) => {
usersChart.update(account, true);
+ // Append signin history
+ await Signins.save({
+ id: genId(),
+ createdAt: new Date(),
+ userId: account.id,
+ ip: ctx.ip,
+ headers: ctx.headers,
+ success: true
+ });
+
const res = await Users.pack(account, account, {
detail: true,
includeSecrets: true