日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

 
 
 
 

  
  
  
  
import http from '../http.js' 
  
  
  
  
import { navigate } from '../router.js' 
  
  
  
  
import { avatar, escapeHTML } from '../shared.js' 
  
  
  
  
 
  
  
  
  
export default async function conversationPage(conversationID) { 
  
  
  
  
    let conversation 
  
  
  
  
    try { 
  
  
  
  
        conversation = await getConversation(conversationID) 
  
  
  
  
    } catch (err) { 
  
  
  
  
        alert(err.message) 
  
  
  
  
        navigate('/', true) 
  
  
  
  
        return 
  
  
  
  
    } 
  
  
  
  
 
  
  
  
  
    const template = document.createElement('template') 
  
  
  
  
    template.innerHTML = ` 
  
  
  
  
        
 
  
  
  
  
            ← Back 
  
  
  
  
            ${avatar(conversation.otherParticipant)} 
  
  
  
  
            ${conversation.otherParticipant.username} 
  
  
  
  
        

此頁面接收路由從 URL 中提取的會話 ID。

首先，它向 /api/ conversations/{conversationID} 發(fā)起一個 GET 請求，以獲取有關對話的信息。 如果出現(xiàn)錯誤，我們會將其顯示，并重定向回 /。然后我們呈現(xiàn)有關其他參與者的信息。

對話列表

我們也會獲取最新的消息并顯示它們。

 
 
 
 

  
  
  
  
let conversation, messages 
  
  
  
  
try { 
  
  
  
  
    [conversation, messages] = await Promise.all([ 
  
  
  
  
        getConversation(conversationID), 
  
  
  
  
        getMessages(conversationID), 
  
  
  
  
    ]) 
  
  
  
  
} 
 
 
 
 

更新 conversationPage() 函數(shù)以獲取消息。我們使用 Promise.all() 同時執(zhí)行這兩個請求。

 
 
 
 

  
  
  
  
function getMessages(conversationID) { 
  
  
  
  
    return http.get(`/api/conversations/${conversationID}/messages`) 
  
  
  
  
} 
 
 
 
 

發(fā)起對 /api/conversations/{conversationID}/messages 的 GET 請求可以獲取對話中的最新消息。

現(xiàn)在，將該列表添加到標記中。

 
 
 
 

  
  
  
  
const messagesOList = page.getElementById('messages') 
  
  
  
  
for (const message of messages.reverse()) { 
  
  
  
  
    messagesOList.appendChild(renderMessage(message)) 
  
  
  
  
} 
 
 
 
 

這樣我們就可以將消息附加到列表中了。我們以時間倒序來顯示它們。

 
 
 
 

  
  
  
  
function renderMessage(message) { 
  
  
  
  
    const messageContent = escapeHTML(message.content) 
  
  
  
  
    const messageDate = new Date(message.createdAt).toLocaleString() 
  
  
  
  
 
  
  
  
  
    const li = document.createElement('li') 
  
  
  
  
    if (message.mine) { 
  
  
  
  
        li.classList.add('owned') 
  
  
  
  
    } 
  
  
  
  
    li.innerHTML = ` 
  
  
  
  
        
${messageContent}
 
  
  
  
  
        ${messageDate} 
  
  
  
  
    ` 
  
  
  
  
    return li 
  
  
  
  
} 
 
 
 
 

每個消息條目顯示消息內容本身及其時間戳。使用 .mine，我們可以將不同的 css 類附加到條目，這樣您就可以將消息顯示在右側。

消息表單

 
 
 
 

  
  
  
  
 
  
  
  
  
     
  
  
  
  
    Send 
  
  
  
  
 
 
 
 
 

將該表單添加到當前標記中。

 
 
 
 

  
  
  
  
page.getElementById('message-form').onsubmit = messageSubmitter(conversationID) 
 
 
 
 

將事件監(jiān)聽器附加到 “submit” 事件。

 
 
 
 

  
  
  
  
function messageSubmitter(conversationID) { 
  
  
  
  
    return async ev => { 
  
  
  
  
        ev.preventDefault() 
  
  
  
  
 
  
  
  
  
        const form = ev.currentTarget 
  
  
  
  
        const input = form.querySelector('input') 
  
  
  
  
        const submitButton = form.querySelector('button') 
  
  
  
  
 
  
  
  
  
        input.disabled = true 
  
  
  
  
        submitButton.disabled = true 
  
  
  
  
 
  
  
  
  
        try { 
  
  
  
  
            const message = await createMessage(input.value, conversationID) 
  
  
  
  
            input.value = '' 
  
  
  
  
            const messagesOList = document.getElementById('messages') 
  
  
  
  
            if (messagesOList === null) { 
  
  
  
  
                return 
  
  
  
  
            } 
  
  
  
  
 
  
  
  
  
            messagesOList.appendChild(renderMessage(message)) 
  
  
  
  
        } catch (err) { 
  
  
  
  
            if (err.statusCode === 422) { 
  
  
  
  
                input.setCustomValidity(err.body.errors.content) 
  
  
  
  
            } else { 
  
  
  
  
                alert(err.message) 
  
  
  
  
            } 
  
  
  
  
        } finally { 
  
  
  
  
            input.disabled = false 
  
  
  
  
            submitButton.disabled = false 
  
  
  
  
 
  
  
  
  
            setTimeout(() => { 
  
  
  
  
                input.focus() 
  
  
  
  
            }, 0) 
  
  
  
  
        } 
  
  
  
  
    } 
  
  
  
  
} 
  
  
  
  
 
  
  
  
  
function createMessage(content, conversationID) { 
  
  
  
  
    return http.post(`/api/conversations/${conversationID}/messages`, { content }) 
  
  
  
  
} 
 
 
 
 

我們利用 partial application 在 “submit” 事件處理程序中獲取對話 ID。它 從輸入中獲取消息內容，并用它對 /api/conversations/{conversationID}/messages 發(fā)出 POST 請求。 然后將新創(chuàng)建的消息添加到列表中。

消息訂閱

為了實現(xiàn)實時，我們還將訂閱此頁面中的消息流。

 
 
 
 

  
  
  
  
page.addEventListener('disconnect', subscribeToMessages(messageArriver(conversationID))) 
 
 
 
 

將該行添加到 conversationPage() 函數(shù)中。

 
 
 
 

  
  
  
  
function subscribeToMessages(cb) { 
  
  
  
  
    return http.subscribe('/api/messages', cb) 
  
  
  
  
} 
  
  
  
  
 
  
  
  
  
function messageArriver(conversationID) { 
  
  
  
  
    return message => { 
  
  
  
  
        if (message.conversationID !== conversationID) { 
  
  
  
  
            return 
  
  
  
  
        } 
  
  
  
  
 
  
  
  
  
        const messagesOList = document.getElementById('messages') 
  
  
  
  
        if (messagesOList === null) { 
  
  
  
  
            return 
  
  
  
  
 
  
  
  
  
        } 
  
  
  
  
        messagesOList.appendChild(renderMessage(message)) 
  
  
  
  
        readMessages(message.conversationID) 
  
  
  
  
    } 
  
  
  
  
} 
  
  
  
  
 
  
  
  
  
function readMessages(conversationID) { 
  
  
  
  
    return http.post(`/api/conversations/${conversationID}/read_messages`) 
  
  
  
  
} 
 
 
 
 

在這里我們仍然使用這個應用的部分來獲取會話 ID。 當新消息到達時，我們首先檢查它是否來自此對話。如果是，我們會將消息條目預先添加到列表中，并向 /api/conversations/{conversationID}/read_messages 發(fā)起 POST 一個請求，以更新參與者上次閱讀消息的時間。

本系列到此結束。 消息應用現(xiàn)在可以運行了。

• 源代碼
• 演示