Guest User

Untitled

a guest
Jan 21st, 2018
85
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.17 KB | None | 0 0
  1. //data {userA,userB}
  2. socket.on("openConversation", async function (data) {
  3. let convDetail = await db.models.chat.findOne({
  4. where: {
  5. userA: data.userA,
  6. userB: data.userB
  7. }
  8. });
  9. if (convDetail) {
  10. let chatMessages = await db.models.message.findAll({
  11. where: {
  12. chatId: convDetail.id
  13. }
  14. });
  15. //console.log(convDetail);
  16. //console.log(chatMessages);
  17. socket.emit("responce", chatMessages);
  18. } else {
  19. let convinfo = await db.models.chat.findOne({
  20. where: {
  21. userA: data.userB,
  22. userB: data.userA
  23. }
  24. });
  25.  
  26. if (convinfo) {
  27. let convMessage = await db.models.message.findAll({
  28. where: {
  29. chatId: convinfo.id
  30. }
  31. });
  32. console.log(convMessage);
  33. socket.emit("responce", convMessage);
  34. } else {
  35. console.log("nooo");
  36. socket.emit("responce", {
  37. message: "no chat between that users"
  38. });
  39. }
  40. }
  41. });
  42.  
  43. //create new conversation event
  44. // data = {userA,userB }
  45. socket.on("createConversation", async function (data) {
  46. let check = await db.models.chat.findOne({
  47. where: {
  48. userA: data.userA,
  49. userB: data.userB
  50. }
  51. });
  52.  
  53. if (!check) {
  54. let newConv = await db.models.chat.create({
  55. userA: data.userA,
  56. userB: data.userB
  57. });
  58. // console.log(newConv);
  59. socket.emit("newConversation", newConv);
  60. } else {
  61. console.log('noo way')
  62. socket.emit("existing", {
  63. message: "already have conversation"
  64. });
  65. }
  66. });
  67.  
  68. //listen for event 'newMessage'
  69. // data = {msg, userId, chatId}
  70. socket.on("newMessage", async function (data) {
  71. let msg = await db.models.message.create({
  72. msg: data.msg,
  73. userId: data.userId,
  74. chatId: data.chatId
  75. });
  76. console.log(data);
  77. //send event by this data after save it in db
  78. socket.emit("msg", data);
  79. });
  80.  
  81. // event listner for retrive all conversation
  82. // socket.on('allConversation', function(data){
  83. // let conversations =
  84. // })
  85.  
  86. socket.on("disconnect", function () {
  87. console.log("A user disconnected");
  88. });
  89. });
Add Comment
Please, Sign In to add comment