Ver código fonte

testing sending user from db

serg155alternate 2 anos atrás
pai
commit
8a3d015311
2 arquivos alterados com 32 adições e 7 exclusões
  1. 7 1
      client/src/App.js
  2. 25 6
      server/index.js

+ 7 - 1
client/src/App.js

@@ -1,13 +1,19 @@
 import './App.css';
 import { io } from "socket.io-client";
 
-const socket = io.connect('http://localhost:5000');
+const socket = io.connect(process.env.REACT_APP_SERVER_URL || 'http://localhost:5000');
+
 
 
 socket.on("connect", () => {
   console.log(socket.id); 
 });
 
+socket.on('connected', (data) => {
+  console.log(data);
+  }).on('error', (e) => {
+  console.log('On connected', e)
+}); 
 
 function App() {
   return (

+ 25 - 6
server/index.js

@@ -6,30 +6,49 @@ const mongoose = require('mongoose');
 const bcrypt = require('bcrypt');
 const User = require('./db/models/User');
 const jwt = require('jsonwebtoken');
+
+
+
 const PORT = process.env.PORT || 4000;
 const HASH_KEY = process.env.HASH_KEY;
-const {Server} = require('socket.io');
+const TOKEN_KEY = process.env.TOKEN_KEY || 'rGH452fdfhdfg06hgj7'; 
+
+
+const socket = require('socket.io');
 const cors = require('cors');
 
 app.get('/', (req, res) => {
   res.send('Hello from express server!')
 })
 
-
 app.use(cors());
 app.use(express.json());
 
-const io = new Server(server, {
+const io = socket(server, {
   cors: {
       origin: "http://localhost:3000" //client endpoint and port
   }
 });
 
-io.on("connection", (socket) => {
-  console.log(socket.id); 
-});
+const generateToken = (id, userName) => {
+  const payload = {
+      id,
+      userName,
+  }
+  return jwt.sign(payload, TOKEN_KEY);
+}
 
+const getOneUser = async (userName) => {
+  return userInDb;
+}
 
+const user = getOneUser('Sergey');
+
+io.on("connection", async (socket) => {
+  console.log(socket.id); 
+  const userInDb = await User.findOne({userName: 'Sergey'});
+  socket.emit('connected', userInDb);
+});