TypeScript Mongoose

database.service.ts

/**
 * Database management
 */
import * as mongoose from 'mongoose';
import logging from './logging.service';
import config from '../config/environment';
const logger = logging.getLogger('database.service');
mongoose.Promise = Promise;

// 链接数据库
mongoose.connect(config.mongo.uris, config.mongo.options);
let database = mongoose.connection;
database.on('connected', function() {
    logger.info('[MongoDB]: connected.');
});
database.once('open', function() {
    logger.info('[MongoDB]: opened.'); /*global.gfs = Grid(database.db);*/
});
database.on('error', function(err) {
    logger.error(err);
});
database.on('disconnected', function() {
    logger.warn('[MongoDB]: disconnected.');
});
database.on('reconnected', function() {
    logger.info('[MongoDB]: reconnected.');
});
process.on('SIGINT', function() {
    database.close(function() {
        logger.info('[MongoDB]: App exits.');
        process.exit(0);
    });
});

export {database, mongoose};

message.model.ts

/**
 * Message Model
 */
// https://github.com/Appsilon/styleguide/wiki/mongoose-typescript-models
import {mongoose} from '../services/database.service';
import * as timestamps from 'mongoose-timestamp';

interface IMessage {
    sender: string;
    recipient: string;
    group: string;
    channel: string;
    agent: string;
    textMessage: string;
};

interface IMessageModel extends IMessage, mongoose.Document { }

var messageSchema = new mongoose.Schema({
    sender: String,
    recipient: String,
    group: String,
    channel: String,
    agent: String,
    textMessage: String
});

messageSchema.plugin(timestamps);

var Message = mongoose.model<IMessageModel>("Message", messageSchema);

export {IMessage, IMessageModel, Message};

message.test.ts

import { test } from 'ava';
import *  as  MessageModel from '../models/message.model';
let Message = MessageModel.Message;

test.only('Message Test', async t => {
  console.log('saving ...');
  try {
    let msg = await (new Message({
      agent: 'foo',
      channel: 'bar',
      sender: 'send',
      recipient: 'foo',
      group: 'ss',
      textMessage: 'foo'
    })).save();
    console.log('saved', JSON.stringify(msg));
    t.pass();
  } catch (e) {
    t.fail(e);
  }
});