100 lines
2.2 KiB
TypeScript
100 lines
2.2 KiB
TypeScript
import $ from 'cafy'; import ID from '../../../../../misc/cafy-id';
|
|
import Matching, { pack as packMatching } from '../../../../../models/games/reversi/matching';
|
|
import ReversiGame, { pack as packGame } from '../../../../../models/games/reversi/game';
|
|
import User, { ILocalUser } from '../../../../../models/user';
|
|
import { publishUserStream, publishReversiStream } from '../../../../../stream';
|
|
import { eighteight } from '../../../../../games/reversi/maps';
|
|
|
|
export const meta = {
|
|
requireCredential: true
|
|
};
|
|
|
|
export default (params: any, user: ILocalUser) => new Promise(async (res, rej) => {
|
|
// Get 'userId' parameter
|
|
const [childId, childIdErr] = $.type(ID).get(params.userId);
|
|
if (childIdErr) return rej('invalid userId param');
|
|
|
|
// Myself
|
|
if (childId.equals(user._id)) {
|
|
return rej('invalid userId param');
|
|
}
|
|
|
|
// Find session
|
|
const exist = await Matching.findOne({
|
|
parentId: childId,
|
|
childId: user._id
|
|
});
|
|
|
|
if (exist) {
|
|
// Destroy session
|
|
Matching.remove({
|
|
_id: exist._id
|
|
});
|
|
|
|
// Create game
|
|
const game = await ReversiGame.insert({
|
|
createdAt: new Date(),
|
|
user1Id: exist.parentId,
|
|
user2Id: user._id,
|
|
user1Accepted: false,
|
|
user2Accepted: false,
|
|
isStarted: false,
|
|
isEnded: false,
|
|
logs: [],
|
|
settings: {
|
|
map: eighteight.data,
|
|
bw: 'random',
|
|
isLlotheo: false
|
|
}
|
|
});
|
|
|
|
// Reponse
|
|
res(await packGame(game, user));
|
|
|
|
publishReversiStream(exist.parentId, 'matched', await packGame(game, exist.parentId));
|
|
|
|
const other = await Matching.count({
|
|
childId: user._id
|
|
});
|
|
|
|
if (other == 0) {
|
|
publishUserStream(user._id, 'reversi_no_invites');
|
|
}
|
|
} else {
|
|
// Fetch child
|
|
const child = await User.findOne({
|
|
_id: childId
|
|
}, {
|
|
fields: {
|
|
_id: true
|
|
}
|
|
});
|
|
|
|
if (child === null) {
|
|
return rej('user not found');
|
|
}
|
|
|
|
// 以前のセッションはすべて削除しておく
|
|
await Matching.remove({
|
|
parentId: user._id
|
|
});
|
|
|
|
// セッションを作成
|
|
const matching = await Matching.insert({
|
|
createdAt: new Date(),
|
|
parentId: user._id,
|
|
childId: child._id
|
|
});
|
|
|
|
// Reponse
|
|
res();
|
|
|
|
const packed = await packMatching(matching, child);
|
|
|
|
// 招待
|
|
publishReversiStream(child._id, 'invited', packed);
|
|
|
|
publishUserStream(child._id, 'reversi_invited', packed);
|
|
}
|
|
});
|