hapkido-api-node/app-staging.js at master · rapelt/hapkido-api-node · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
'use strict';
const awsServerlessExpress = require('aws-serverless-express');
import {connectDB} from "./db/typeorm-connect";
const apps = require('./index');
const server = awsServerlessExpress.createServer(apps);


exports.handler = (event, context, callback) => {
    const startServer = async () => {
        awsServerlessExpress.proxy(server, event, context);

        const io = require('./src/io/io').init(server);

        io.on('connection', (socket) => {
            console.log('Client Connected');

            io.emit('posts', {message: 'I am connected'});

        });

        io.on('connect_failed', function() {
            console.log("Sorry, there seems to be an issue with the connection!");
        })
    };


    (async () => {
        await connectDB();
        await startServer();
    })();


};

// const server = awsServerlessExpress.createServer(apps);
// awsServerlessExpress.proxy(server, event, context);


// createConnection().then(connection => {
//
//     awsServerlessExpress.proxy(server, event, context);
//
//     //var app = apps.listen(port, () => {
//
//         // const io = require('./src/io/io').init(app);
//         //
//         // io.on('connection', (socket: any) => {
//         //     console.log('Client Connected');
//         // });
//         //
//         // io.emit('posts', {message: 'I am connected'});
//
//         // io.connect(app, null).then(() => {
//         //     console.log(`IO is connected`);
//         // });
//     //});


//let counter = 0;

// counter++;
// console.log(counter)
// callback(null, { count: counter })
// context.callbackWaitsForEmptyEventLoop = false;


// const connectionManager = getConnectionManager();
//
// if(connectionManager.connections.length === 0){
//     createConnection().then(connection => {
//         console.log('TypeORM is connected: ', connection.isConnected);
//     }).catch((err) => {
//         console.log('Connection Error', err);
//     })
// } else {
//     connectionManager.getConnection(ormconfig).then(connection => {
//         console.log('TypeORM is connected: ', connection.isConnected);
//     });
//     console.log("connections", connectionManager.connections.length);
// }