Marxpark

import React from 'react';
import logo from './logo.svg';
import withSocket from "./withSocket"
import './App.css';

function App({socketListen, socketSend}) {

  socketListen("loginResponse", (response) => {
    console.log(response)
  })

Marxpark

const express = require("express")
const socketIO = require('socket.io');
const http = require('http')
var rabbit = require('amqplib/callback_api');

const pino = require('pino');
require('dotenv').config();

const LOGGER = pino({ level: process.env.LOG_LEVEL || 'info' });
const queues = ["userLogin", "frontendMessage"]

Marxpark

var rabbit = require('amqplib/callback_api');
const pino = require('pino');
require('dotenv').config();

const LOGGER = pino({ level: process.env.LOG_LEVEL || 'info' });

const queues = ["userLogin", "frontendMessage"]


LOGGER.info(`Connecting to RabbitMQ`)

Marxpark

io.on('connection', (socket)=>{
    LOGGER.debug(`New user connected ${socket.id}`)

    socket.on("message", (data) => {
        let event = JSON.parse(data)
        LOGGER.debug(event)
        event.socketId = socket.id        
        rabbit.channel.send("userLogin", event)
    })
});

Marxpark

const express = require("express")
const socketIO = require('socket.io');
const http = require('http')
var rabbit = require('amqplib/callback_api');

const pino = require('pino');
require('dotenv').config();

const LOGGER = pino({ level: process.env.LOG_LEVEL || 'info' });

Marxpark

var rabbit = require('amqplib/callback_api');
const pino = require('pino');
require('dotenv').config();
const LOGGER = pino({ level: process.env.LOG_LEVEL || 'info' });


LOGGER.info(`Connecting to RabbitMQ`)
rabbit.connect('amqp://localhost', (error0, connection) => {
    if (error0) {
        throw error0;

Marxpark

import React from 'react';
import logo from './logo.svg';
import withSocket from "./withSocket"
import './App.css';

function App({socketListen, socketSend}) {

  socketSend("message", {name: "i am connected"})

  return (

Marxpark

import React from "react"
import socketIOClient from "socket.io-client";

// link should be in environemnt file!
let socket = socketIOClient(process.env.REACT_APP_SOCKET_URL)

// component wrapper that allows us to use socket globaly
function withSocket (WrappedComponent) { 
  const WithSocket = props => {

Marxpark

const express = require("express")
const socketIO = require('socket.io');
const http = require('http')

const pino = require('pino');
require('dotenv').config();

const LOGGER = pino({ level: process.env.LOG_LEVEL || 'info' });

LOGGER.info("Starting server")

Marxpark

{
  "name": "msrouter",
  "version": "1.0.0",
  "description": "",
  "main": "msRouter.js",
  "scripts": {
    "start": "nodemon --exec babel-node msRouter.js",
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "author": "",