vybe/src/send_message.js

const db = require("../db");
const authwrap = require("./authwrap");

const send_message = async (msg, respond, socket) => {
  if (!msg.thread) {
    return respond({
      success: false,
      message: "thread ID required",
    });
  }
  // add message and send it to everyone
  const id = await db.query(
    "insert into posts (user, thread, content) values (?, ?, ?) returning id",
    [msg.auth_user.id, msg.thread, msg.message]
  );
  socket.broadcast.emit("new_message", {
    id: id.rows[0].id,
    name: msg.auth_user.name,
    message: msg.message,
    thread: msg.thread,
  });
  return respond({
    success: true,
    id: id.rows[0].id,
  });
};

module.exports = authwrap(send_message);