import { h, Component, createRef } from '/js/web_modules/preact.js'; import htm from '/js/web_modules/htm.js'; const html = htm.bind(h); import '/js/web_modules/@justinribeiro/lite-youtube.js'; import Message from './message.js'; import ChatInput from './chat-input.js'; import { CALLBACKS, SOCKET_MESSAGE_TYPES } from '../../utils/websocket.js'; import { jumpToBottom, debounce } from '../../utils/helpers.js'; import { extraUserNamesFromMessageHistory } from '../../utils/chat.js'; import { URL_CHAT_HISTORY, MESSAGE_JUMPTOBOTTOM_BUFFER } from '../../utils/constants.js'; export default class Chat extends Component { constructor(props, context) { super(props, context); this.state = { webSocketConnected: true, messages: [], chatUserNames: [], }; this.scrollableMessagesContainer = createRef(); this.websocket = null; this.getChatHistory = this.getChatHistory.bind(this); this.receivedWebsocketMessage = this.receivedWebsocketMessage.bind(this); this.websocketConnected = this.websocketConnected.bind(this); this.websocketDisconnected = this.websocketDisconnected.bind(this); this.submitChat = this.submitChat.bind(this); this.submitChat = this.submitChat.bind(this); this.scrollToBottom = this.scrollToBottom.bind(this); this.handleWindowResize = debounce(this.handleWindowResize.bind(this), 500); } componentDidMount() { this.setupWebSocketCallbacks(); this.getChatHistory(); window.addEventListener('resize', this.handleWindowResize); } componentDidUpdate(prevProps, prevState) { const { username: prevName } = prevProps; const { username } = this.props; const { messages: prevMessages } = prevState; const { messages } = this.state; // if username updated, send a message if (prevName !== username) { this.sendUsernameChange(prevName, username); } // scroll to bottom of messages list when new ones come in if (messages.length > prevMessages.length) { if (!prevMessages.length || this.checkShouldScroll()) { this.scrollToBottom(); } } } componentWillUnmount() { window.removeEventListener('resize', this.handleWindowResize); } setupWebSocketCallbacks() { this.websocket = this.props.websocket; if (this.websocket) { this.websocket.addListener(CALLBACKS.RAW_WEBSOCKET_MESSAGE_RECEIVED, this.receivedWebsocketMessage); this.websocket.addListener(CALLBACKS.WEBSOCKET_CONNECTED, this.websocketConnected); this.websocket.addListener(CALLBACKS.WEBSOCKET_DISCONNECTED, this.websocketDisconnected); } } // fetch chat history getChatHistory() { fetch(URL_CHAT_HISTORY) .then(response => { if (!response.ok) { throw new Error(`Network response was not ok ${response.ok}`); } return response.json(); }) .then(data => { // extra user names const chatUserNames = extraUserNamesFromMessageHistory(data); this.setState({ messages: data, chatUserNames, }); }) .catch(error => { // this.handleNetworkingError(`Fetch getChatHistory: ${error}`); }); } sendUsernameChange(oldName, newName) { const nameChange = { type: SOCKET_MESSAGE_TYPES.NAME_CHANGE, oldName, newName, }; this.websocket.send(nameChange); } receivedWebsocketMessage(message) { this.addMessage(message); } addMessage(message) { const { messages: curMessages } = this.state; // if incoming message has same id as existing message, don't add it const existing = curMessages.filter(function (item) { return item.id === message.id; }) if (existing.length === 0 || !existing) { const newState = { messages: [...curMessages, message], }; const updatedChatUserNames = this.updateAuthorList(message); if (updatedChatUserNames.length) { newState.chatUserNames = [...updatedChatUserNames]; } this.setState(newState); } } websocketConnected() { this.setState({ webSocketConnected: true, }); } websocketDisconnected() { this.setState({ webSocketConnected: false, }); } submitChat(content) { if (!content) { return; } const { username } = this.props; const message = { body: content, author: username, type: SOCKET_MESSAGE_TYPES.CHAT, }; this.websocket.send(message); } updateAuthorList(message) { const { type } = message; const nameList = this.state.chatUserNames; if ( type === SOCKET_MESSAGE_TYPES.CHAT && !nameList.includes(message.author) ) { return nameList.push(message.author); } else if (type === SOCKET_MESSAGE_TYPES.NAME_CHANGE) { const { oldName, newName } = message; const oldNameIndex = nameList.indexOf(oldName); return nameList.splice(oldNameIndex, 1, newName); } return []; } scrollToBottom() { jumpToBottom(this.scrollableMessagesContainer.current); } checkShouldScroll() { const { scrollTop, scrollHeight, clientHeight } = this.scrollableMessagesContainer.current; const fullyScrolled = scrollHeight - clientHeight; return scrollHeight >= clientHeight && fullyScrolled - scrollTop < MESSAGE_JUMPTOBOTTOM_BUFFER; } handleWindowResize() { this.scrollToBottom(); } render(props, state) { const { username, messagesOnly, chatInputEnabled } = props; const { messages, chatUserNames, webSocketConnected } = state; const messageList = messages.map( (message) => html`<${Message} message=${message} username=${username} key=${message.id} />` ); if (messagesOnly) { return html`
`; } return html`