1
- 'use strict'
2
1
// external modules
3
- var Sequelize = require ( 'sequelize' )
4
- var async = require ( 'async' )
5
- var moment = require ( 'moment' )
6
- var childProcess = require ( 'child_process' )
7
- var shortId = require ( 'shortid' )
8
- var path = require ( 'path' )
9
- var util = require ( 'util' )
10
-
11
- var Op = Sequelize . Op
2
+ import * as Sequelize from "sequelize" ;
3
+ import * as async from "async" ;
4
+ import * as moment from "moment" ;
5
+ import * as childProcess from "child_process" ;
6
+ import * as shortId from "shortid" ;
7
+ import * as path from "path" ;
8
+ import * as util from "util" ;
12
9
13
10
// core
14
- var config = require ( '../config' )
15
- var logger = require ( '../logger' )
11
+ import * as config from "../config" ;
12
+ import * as logger from "../logger" ;
13
+
14
+ var Op = Sequelize . Op
16
15
17
16
var dmpWorker = createDmpWorker ( )
18
17
var dmpCallbackCache = { }
19
18
20
- function createDmpWorker ( ) {
19
+ function createDmpWorker ( ) {
21
20
var worker = childProcess . fork ( path . resolve ( __dirname , '../workers/dmpWorker.js' ) , {
22
21
stdio : 'ignore'
23
22
} )
@@ -44,7 +43,7 @@ function createDmpWorker () {
44
43
return worker
45
44
}
46
45
47
- function sendDmpWorker ( data , callback ) {
46
+ function sendDmpWorker ( data , callback ) {
48
47
if ( ! dmpWorker ) dmpWorker = createDmpWorker ( )
49
48
var cacheKey = Date . now ( ) + '_' + shortId . generate ( )
50
49
dmpCallbackCache [ cacheKey ] = callback
0 commit comments