RENAME: bbs -> channel

This commit is contained in:
syuilo
2017-10-31 21:42:11 +09:00
parent 0e95cdb04c
commit dc9fddf839
8 changed files with 65 additions and 67 deletions

View File

@@ -2,11 +2,11 @@
* Module dependencies
*/
import $ from 'cafy';
import Thread from '../../../models/bbs-thread';
import serialize from '../../../serializers/bbs-thread';
import Channel from '../../../models/channel';
import serialize from '../../../serializers/channel';
/**
* Create a thread
* Create a channel
*
* @param {any} params
* @param {any} user
@@ -17,13 +17,13 @@ module.exports = async (params, user) => new Promise(async (res, rej) => {
const [title, titleErr] = $(params.title).string().range(1, 100).$;
if (titleErr) return rej('invalid title param');
// Create a thread
const thread = await Thread.insert({
// Create a channel
const channel = await Channel.insert({
created_at: new Date(),
user_id: user._id,
title: title
});
// Response
res(await serialize(thread));
res(await serialize(channel));
});

View File

@@ -1,11 +1,11 @@
import * as mongo from 'mongodb';
import db from '../../db/mongodb';
const collection = db.get('bbs_threads');
const collection = db.get('channels');
export default collection as any; // fuck type definition
export type IBbsThread = {
export type IChannel = {
_id: mongo.ObjectID;
created_at: Date;
title: string;

View File

@@ -1,44 +0,0 @@
/**
* Module dependencies
*/
import * as mongo from 'mongodb';
import deepcopy = require('deepcopy');
import { IUser } from '../models/user';
import { default as Thread, IBbsThread } from '../models/bbs-thread';
/**
* Serialize a thread
*
* @param thread target
* @param me? serializee
* @return response
*/
export default (
thread: string | mongo.ObjectID | IBbsThread,
me?: string | mongo.ObjectID | IUser
) => new Promise<any>(async (resolve, reject) => {
let _thread: any;
// Populate the thread if 'thread' is ID
if (mongo.ObjectID.prototype.isPrototypeOf(thread)) {
_thread = await Thread.findOne({
_id: thread
});
} else if (typeof thread === 'string') {
_thread = await Thread.findOne({
_id: new mongo.ObjectID(thread)
});
} else {
_thread = deepcopy(thread);
}
// Rename _id to id
_thread.id = _thread._id;
delete _thread._id;
// Remove needless properties
delete _thread.user_id;
resolve(_thread);
});

View File

@@ -0,0 +1,44 @@
/**
* Module dependencies
*/
import * as mongo from 'mongodb';
import deepcopy = require('deepcopy');
import { IUser } from '../models/user';
import { default as Channel, IChannel } from '../models/channel';
/**
* Serialize a channel
*
* @param channel target
* @param me? serializee
* @return response
*/
export default (
channel: string | mongo.ObjectID | IChannel,
me?: string | mongo.ObjectID | IUser
) => new Promise<any>(async (resolve, reject) => {
let _channel: any;
// Populate the channel if 'channel' is ID
if (mongo.ObjectID.prototype.isPrototypeOf(channel)) {
_channel = await Channel.findOne({
_id: channel
});
} else if (typeof channel === 'string') {
_channel = await Channel.findOne({
_id: new mongo.ObjectID(channel)
});
} else {
_channel = deepcopy(channel);
}
// Rename _id to id
_channel.id = _channel._id;
delete _channel._id;
// Remove needless properties
delete _channel.user_id;
resolve(_channel);
});