Skip to content

Instantly share code, notes, and snippets.

@ammezie
Created September 30, 2019 09:15
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ammezie/cf1550b11eca8a532af080db30454644 to your computer and use it in GitHub Desktop.
Save ammezie/cf1550b11eca8a532af080db30454644 to your computer and use it in GitHub Desktop.
// resources/js/components/ChatRoom.vue
<template>
<div class="container">
<div class="row">
<div class="col-md-3">
<div class="card">
<div class="card-header">Members</div>
<div class="card-body">
<ul class="list-group list-group-flush">
<li
class="list-group-item"
v-for="(member, id) in members"
:key="id"
>{{ member.user.name }}</li>
</ul>
</div>
</div>
</div>
<div class="col-md-9">
<div class="card">
<div class="card-header">Chats</div>
<div class="card-body">
<dl v-for="message in messages" v-bind:key="message.id">
<dt :class="{ 'text-right': message.user.id === username }">{{ message.user.name }}</dt>
<dd :class="{ 'text-right': message.user.id === username }">{{ message.text }}</dd>
</dl>
<hr />
<form @submit.prevent="sendMessage" method="post">
<div class="input-group">
<input
type="text"
v-model="newMessage"
class="form-control"
placeholder="Type your message..."
/>
<div class="input-group-append">
<button class="btn btn-primary">Send</button>
</div>
</div>
</form>
</div>
</div>
</div>
</div>
</div>
</template>
<script>
import axios from "axios";
import { StreamChat } from "stream-chat";
export default {
name: "ChatRoom",
props: {
authUser: {
type: Object,
required: true
}
},
data() {
return {
token: null,
channel: null,
members: [],
client: null,
messages: [],
newMessage: ""
};
},
computed: {
username() {
return this.authUser.email.split("@")[0];
}
},
async created() {
// gerenrate clientside token from server
await this.getToken();
await this.initializeStream();
await this.initializeChannel();
},
methods: {
async getToken() {
const { data } = await axios.post("/api/generate-token", {
user_id: this.username
});
this.token = data.token;
},
async initializeStream() {
this.client = new StreamChat(process.env.MIX_STREAM_API_KEY, {
timeout: 9000
});
await this.client.setUser(
{ id: this.username, name: this.authUser.name },
this.token
);
},
async initializeChannel() {
this.channel = this.client.channel("messaging", "chatroom");
const { members, messages } = await this.channel.watch();
this.members = members;
this.messages = messages;
// listen for new messages
this.channel.on("message.new", event => {
this.messages.push({
text: event.message.text,
user: event.message.user
});
});
// listen for when a new member is added to channel
this.channel.on("member.added", event => {
this.members.push(event);
});
},
async sendMessage() {
await this.channel.sendMessage({
text: this.newMessage
});
this.newMessage = "";
}
}
};
</script>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment