Project-PAL/socket.js at master · markrdecello/Project-PAL · 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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
var app = require('express')();
var server = require('http').Server(app);
var io_server = require('socket.io')(server);
var io_client = require('socket.io-client')('http://localhost:3000');
var redis = require('redis');
var subscriber = redis.createClient();
var publisher  = redis.createClient();

server.listen(3000);

subscriber.subscribe("index");

subscriber.on("message", function(channel, data) {
    io_server.emit("new message", data);
    //message = JSON.parse(message);
    // users & user_name
});

io_server.on("connection", function(socket){

    console.log('user connected')

    socket.on('join', function (name) {

        console.log(name + " : has joined the chat " + socket.id);

    });

    socket.on('add', function (name, student_name) {
        console.log("add user " + student_name + " WeeklyForm");
        console.log(name + student_name);
    });

    socket.on("new message",function(message){

    });

    socket.on('typing', function(data){

    });

    socket.on('stop typing', function(data){

    });

    socket.on("disconnect",function(data){

    });
});


io_client.on("new message", function(data){
    console.log(data);
    io_client.emit('typing', "s");
});


/*redis.psubscribe('*', function(err, count){
    //does something, i hope...
    console.log('watching all channels...');
});*/

/*redis.on('pmessage', function(subscriber, channel, message){
    console.log("7trtrdtd");
    console.log(message);
    message = JSON.parse(message);
    io.emit(channel, message.data);
});*/

/*
const express = require('express'),
    http = require('http'),
    app = express(),
    server = http.createServer(app),
    io = require('socket.io').listen(server);
app.get('/', (req, res) => {

    res.send('Chat Server is running on port 3000')
});

io.on('connection', (socket) => {

    console.log('user connected')

    socket.on('join', function (name) {

        console.log(name + " : has joined the chat " + socket.id);

    });

    console.log('Client connected');

    socket.on("new message", function (message) {

    });

    socket.on('typing', function (data) {

    });

    socket.on('stop typing', function (data) {

    });

    socket.on("disconnect", function (data) {

    });


})


server.listen(3000, () => {

    console.log('Node app is running on port 3000')

})*/