socketsEvents.js 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. import { store } from "../store";
  2. import { getAllMessages, getAllUsers, addNewMessage, getUser,addNewPrivateMessage,getUsersOnline,friendsFromSocket } from "../reducers/socketReducer";
  3. import { removeToken } from "../reducers/userDataReducer";
  4. export const socketEvents = (socket) => {
  5. console.log('socket event...')
  6. socket.on('connected', data => {
  7. store.dispatch(getUser(data));
  8. console.log('getuserdata', data)
  9. })
  10. .on('allmessages', (data) => {
  11. store.dispatch(getAllMessages(data));
  12. })
  13. .on('allDbUsers', (data) => {
  14. store.dispatch(getAllUsers(data));
  15. })
  16. .on('newmessage', (data) => {
  17. store.dispatch(addNewMessage(data))
  18. })
  19. .on('private', (data) => {
  20. store.dispatch(addNewPrivateMessage(data))
  21. })
  22. .on('ban', (data) => {
  23. store.dispatch(removeToken());
  24. localStorage.removeItem('token');
  25. })
  26. .on('usersOnline', (data) => {
  27. store.dispatch(getUsersOnline(data))
  28. })
  29. .on('friends', data => {
  30. store.dispatch(friendsFromSocket(data))
  31. })
  32. .on('disconnect', (data) => {
  33. if( data === 'io server disconnect') {
  34. // socket.disconnect();
  35. store.dispatch(removeToken());
  36. }
  37. })
  38. .on('error', e => {console.log('On connected', e)});
  39. }