socketsEvents.js 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  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. console.log(data)
  21. store.dispatch(addNewPrivateMessage(data))
  22. })
  23. .on('ban', (data) => {
  24. store.dispatch(removeToken());
  25. localStorage.removeItem('token');
  26. })
  27. .on('usersOnline', (data) => {
  28. store.dispatch(getUsersOnline(data))
  29. })
  30. .on('friends', data => {
  31. store.dispatch(friendsFromSocket(data))
  32. })
  33. .on('disconnect', (data) => {
  34. if( data === 'io server disconnect') {
  35. // socket.disconnect();
  36. store.dispatch(removeToken());
  37. }
  38. })
  39. .on('error', e => {console.log('On connected', e)});
  40. }