Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //data {userA,userB}
- socket.on("openConversation", async function (data) {
- let convDetail = await db.models.chat.findOne({
- where: {
- userA: data.userA,
- userB: data.userB
- }
- });
- if (convDetail) {
- let chatMessages = await db.models.message.findAll({
- where: {
- chatId: convDetail.id
- }
- });
- //console.log(convDetail);
- //console.log(chatMessages);
- socket.emit("responce", chatMessages);
- } else {
- let convinfo = await db.models.chat.findOne({
- where: {
- userA: data.userB,
- userB: data.userA
- }
- });
- if (convinfo) {
- let convMessage = await db.models.message.findAll({
- where: {
- chatId: convinfo.id
- }
- });
- console.log(convMessage);
- socket.emit("responce", convMessage);
- } else {
- console.log("nooo");
- socket.emit("responce", {
- message: "no chat between that users"
- });
- }
- }
- });
- //create new conversation event
- // data = {userA,userB }
- socket.on("createConversation", async function (data) {
- let check = await db.models.chat.findOne({
- where: {
- userA: data.userA,
- userB: data.userB
- }
- });
- if (!check) {
- let newConv = await db.models.chat.create({
- userA: data.userA,
- userB: data.userB
- });
- // console.log(newConv);
- socket.emit("newConversation", newConv);
- } else {
- console.log('noo way')
- socket.emit("existing", {
- message: "already have conversation"
- });
- }
- });
- //listen for event 'newMessage'
- // data = {msg, userId, chatId}
- socket.on("newMessage", async function (data) {
- let msg = await db.models.message.create({
- msg: data.msg,
- userId: data.userId,
- chatId: data.chatId
- });
- console.log(data);
- //send event by this data after save it in db
- socket.emit("msg", data);
- });
- // event listner for retrive all conversation
- // socket.on('allConversation', function(data){
- // let conversations =
- // })
- socket.on("disconnect", function () {
- console.log("A user disconnected");
- });
- });
Add Comment
Please, Sign In to add comment