File tree 3 files changed +23
-3
lines changed
3 files changed +23
-3
lines changed Original file line number Diff line number Diff line change 1
1
import app from './' ; < % if ( filters . mongoose ) { % >
2
2
import mongoose from 'mongoose' ; < % } % >
3
3
4
+ < % _ if ( ! filters . ws ) { - % >
4
5
after ( function ( done ) {
5
6
app . angularFullstack . on ( 'close' , ( ) => done ( ) ) ; < % if ( filters . mongoose ) { % >
6
7
mongoose . connection . close ( ) ; < % } % >
7
8
app . angularFullstack . close ( ) ;
8
- } ) ;
9
+ app . primus . end ( ) ;
10
+ } ) ; < % } % >
11
+ < % _ if ( filters . ws ) { - % >
12
+ let count = 0 ;
13
+ after ( function ( done ) {
14
+ app . angularFullstack . on ( 'close' , ( ) => {
15
+ if ( ++ count === 2 ) done ( ) ;
16
+ } ) ;
17
+ mongoose . connection . close ( ) ;
18
+ app . angularFullstack . close ( ) ;
19
+ app . primus . end ( ( ) => {
20
+ if ( ++ count === 2 ) done ( ) ;
21
+ } ) ;
22
+ } ) ; < % } % >
Original file line number Diff line number Diff line change @@ -45,14 +45,20 @@ function startServer() {
45
45
< % if ( filters . sequelize ) { % >
46
46
sqldb.sequelize.sync()
47
47
< % _ if ( filters . ws ) { - % >
48
- .then(wsInitPromise)< % } % >
48
+ .then(wsInitPromise)
49
+ .then(primus => {
50
+ app . primus = primus ;
51
+ } )< % } % >
49
52
.then(startServer)
50
53
.catch(err => {
51
54
console . log ( 'Server failed to start due to error: %s' , err ) ;
52
55
} );
53
56
< % } else { % >
54
57
< % _ if ( filters . ws ) { - % >
55
58
wsInitPromise
59
+ . then ( primus => {
60
+ app . primus = primus ;
61
+ } )
56
62
. then ( startServer )
57
63
. catch ( err => {
58
64
console . log ( 'Server failed to start due to error: %s' , err ) ;
Original file line number Diff line number Diff line change @@ -53,7 +53,7 @@ export default function initWebSocketServer(server) {
53
53
primus . save ( path . join ( __dirname , '../../client/components/socket/primus.js' ) , err => {
54
54
if ( err ) return reject ( err ) ;
55
55
56
- resolve ( ) ;
56
+ resolve ( primus ) ;
57
57
} ) ;
58
58
} ) ;
59
59
}
You can’t perform that action at this time.
0 commit comments