Linux中國

構建一個即時消息應用（三）：對話

245 views0
By
Share

本文是該系列的第三篇。

在我們的即時消息應用中，消息表現為兩個參與者對話的堆疊。如果你想要開始一場對話，就應該嚮應用提供你想要交談的用戶，而當對話創建後（如果該對話此前並不存在），就可以向該對話發送消息。

就前端而言，我們可能想要顯示一份近期對話列表。並在此處顯示對話的最後一條消息以及另一個參與者的姓名和頭像。

在這篇帖子中，我們將會編寫一些 端點 endpoint 來完成像「創建對話」、「獲取對話列表」以及「找到單個對話」這樣的任務。

首先，要在主函數 main() 中添加下面的路由。

router.HandleFunc("POST", "/api/conversations", requireJSON(guard(createConversation)))
router.HandleFunc("GET", "/api/conversations", guard(getConversations))
router.HandleFunc("GET", "/api/conversations/:conversationID", guard(getConversation))

這三個端點都需要進行身份驗證，所以我們將會使用 guard() 中間件。我們也會構建一個新的中間件，用於檢查請求內容是否為 JSON 格式。

JSON 請求檢查中間件

func requireJSON(handler http.HandlerFunc) http.HandlerFunc {
    return func(w http.ResponseWriter, r *http.Request) {
        if ct := r.Header.Get("Content-Type"); !strings.HasPrefix(ct, "application/json") {
            http.Error(w, "Content type of application/json required", http.StatusUnsupportedMediaType)
            return
        }
        handler(w, r)
    }
}

如果 請求 request 不是 JSON 格式，那麼它會返回 415 Unsupported Media Type（不支持的媒體類型）錯誤。

創建對話

type Conversation struct {
    ID                string   `json:"id"`
    OtherParticipant  *User    `json:"otherParticipant"`
    LastMessage       *Message `json:"lastMessage"`
    HasUnreadMessages bool     `json:"hasUnreadMessages"`
}

就像上面的代碼那樣，對話中保持對另一個參與者和最後一條消息的引用，還有一個 bool 類型的欄位，用來告知是否有未讀消息。

type Message struct {
    ID             string    `json:"id"`
    Content        string    `json:"content"`
    UserID         string    `json:"-"`
    ConversationID string    `json:"conversationID,omitempty"`
    CreatedAt      time.Time `json:"createdAt"`
    Mine           bool      `json:"mine"`
    ReceiverID     string    `json:"-"`
}

我們會在下一篇文章介紹與消息相關的內容，但由於我們這裡也需要用到它，所以先定義了 Message 結構體。其中大多數欄位與資料庫表一致。我們需要使用 Mine 來斷定消息是否屬於當前已驗證用戶所有。一旦加入實時功能，ReceiverID 可以幫助我們過濾消息。

接下來讓我們編寫 HTTP 處理程序。儘管它有些長，但也沒什麼好怕的。

func createConversation(w http.ResponseWriter, r *http.Request) {
    var input struct {
        Username string `json:"username"`
    }
    defer r.Body.Close()
    if err := json.NewDecoder(r.Body).Decode(&input); err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    input.Username = strings.TrimSpace(input.Username)
    if input.Username == "" {
        respond(w, Errors{map[string]string{
            "username": "Username required",
        }}, http.StatusUnprocessableEntity)
        return
    }

    ctx := r.Context()
    authUserID := ctx.Value(keyAuthUserID).(string)

    tx, err := db.BeginTx(ctx, nil)
    if err != nil {
        respondError(w, fmt.Errorf("could not begin tx: %v", err))
        return
    }
    defer tx.Rollback()

    var otherParticipant User
    if err := tx.QueryRowContext(ctx, `
        SELECT id, avatar_url FROM users WHERE username = $1
    `, input.Username).Scan(
        &otherParticipant.ID,
        &otherParticipant.AvatarURL,
    ); err == sql.ErrNoRows {
        http.Error(w, "User not found", http.StatusNotFound)
        return
    } else if err != nil {
        respondError(w, fmt.Errorf("could not query other participant: %v", err))
        return
    }

    otherParticipant.Username = input.Username

    if otherParticipant.ID == authUserID {
        http.Error(w, "Try start a conversation with someone else", http.StatusForbidden)
        return
    }

    var conversationID string
    if err := tx.QueryRowContext(ctx, `
        SELECT conversation_id FROM participants WHERE user_id = $1
        INTERSECT
        SELECT conversation_id FROM participants WHERE user_id = $2
    `, authUserID, otherParticipant.ID).Scan(&conversationID); err != nil && err != sql.ErrNoRows {
        respondError(w, fmt.Errorf("could not query common conversation id: %v", err))
        return
    } else if err == nil {
        http.Redirect(w, r, "/api/conversations/"+conversationID, http.StatusFound)
        return
    }

    var conversation Conversation
    if err = tx.QueryRowContext(ctx, `
        INSERT INTO conversations DEFAULT VALUES
        RETURNING id
    `).Scan(&conversation.ID); err != nil {
        respondError(w, fmt.Errorf("could not insert conversation: %v", err))
        return
    }

    if _, err = tx.ExecContext(ctx, `
        INSERT INTO participants (user_id, conversation_id) VALUES
            ($1, $2),
            ($3, $2)
    `, authUserID, conversation.ID, otherParticipant.ID); err != nil {
        respondError(w, fmt.Errorf("could not insert participants: %v", err))
        return
    }

    if err = tx.Commit(); err != nil {
        respondError(w, fmt.Errorf("could not commit tx to create conversation: %v", err))
        return
    }

    conversation.OtherParticipant = &otherParticipant

    respond(w, conversation, http.StatusCreated)
}

在此端點，你會向 /api/conversations 發送 POST 請求，請求的 JSON 主體中包含要對話的用戶的用戶名。

因此，首先需要將請求主體解析成包含用戶名的結構。然後，校驗用戶名不能為空。

type Errors struct {
    Errors map[string]string `json:"errors"`
}

這是錯誤消息的結構體 Errors，它僅僅是一個映射。如果輸入空用戶名，你就會得到一段帶有 422 Unprocessable Entity（無法處理的實體）錯誤消息的 JSON 。

{
    "errors": {
        "username": "Username required"
    }
}

然後，我們開始執行 SQL 事務。收到的僅僅是用戶名，但事實上，我們需要知道實際的用戶 ID 。因此，事務的第一項內容是查詢另一個參與者的 ID 和頭像。如果找不到該用戶，我們將會返回 404 Not Found（未找到） 錯誤。另外，如果找到的用戶恰好和「當前已驗證用戶」相同，我們應該返回 403 Forbidden（拒絕處理）錯誤。這是由於對話只應當在兩個不同的用戶之間發起，而不能是同一個。

然後，我們試圖找到這兩個用戶所共有的對話，所以需要使用 INTERSECT 語句。如果存在，只需要通過 /api/conversations/{conversationID} 重定向到該對話並將其返回。

如果未找到共有的對話，我們需要創建一個新的對話並添加指定的兩個參與者。最後，我們 COMMIT 該事務並使用新創建的對話進行響應。

獲取對話列表

端點 /api/conversations 將獲取當前已驗證用戶的所有對話。

func getConversations(w http.ResponseWriter, r *http.Request) {
    ctx := r.Context()
    authUserID := ctx.Value(keyAuthUserID).(string)

    rows, err := db.QueryContext(ctx, `
        SELECT
            conversations.id,
            auth_user.messages_read_at < messages.created_at AS has_unread_messages,
            messages.id,
            messages.content,
            messages.created_at,
            messages.user_id = $1 AS mine,
            other_users.id,
            other_users.username,
            other_users.avatar_url
        FROM conversations
        INNER JOIN messages ON conversations.last_message_id = messages.id
        INNER JOIN participants other_participants
            ON other_participants.conversation_id = conversations.id
                AND other_participants.user_id != $1
        INNER JOIN users other_users ON other_participants.user_id = other_users.id
        INNER JOIN participants auth_user
            ON auth_user.conversation_id = conversations.id
                AND auth_user.user_id = $1
        ORDER BY messages.created_at DESC
    `, authUserID)
    if err != nil {
        respondError(w, fmt.Errorf("could not query conversations: %v", err))
        return
    }
    defer rows.Close()

    conversations := make([]Conversation, 0)
    for rows.Next() {
        var conversation Conversation
        var lastMessage Message
        var otherParticipant User
        if err = rows.Scan(
            &conversation.ID,
            &conversation.HasUnreadMessages,
            &lastMessage.ID,
            &lastMessage.Content,
            &lastMessage.CreatedAt,
            &lastMessage.Mine,
            &otherParticipant.ID,
            &otherParticipant.Username,
            &otherParticipant.AvatarURL,
        ); err != nil {
            respondError(w, fmt.Errorf("could not scan conversation: %v", err))
            return
        }

        conversation.LastMessage = &lastMessage
        conversation.OtherParticipant = &otherParticipant
        conversations = append(conversations, conversation)
    }

    if err = rows.Err(); err != nil {
        respondError(w, fmt.Errorf("could not iterate over conversations: %v", err))
        return
    }

    respond(w, conversations, http.StatusOK)
}

該處理程序僅對資料庫進行查詢。它通過一些聯接來查詢對話表……首先，從消息表中獲取最後一條消息。然後依據「ID 與當前已驗證用戶不同」的條件，從參與者表找到對話的另一個參與者。然後聯接到用戶表以獲取該用戶的用戶名和頭像。最後，再次聯接參與者表，並以相反的條件從該表中找出參與對話的另一個用戶，其實就是當前已驗證用戶。我們會對比消息中的 messages_read_at 和 created_at 兩個欄位，以確定對話中是否存在未讀消息。然後，我們通過 user_id 欄位來判定該消息是否屬於「我」（指當前已驗證用戶）。

注意，此查詢過程假定對話中只有兩個用戶參與，它也僅僅適用於這種情況。另外,該設計也不很適用於需要顯示未讀消息數量的情況。如果需要顯示未讀消息的數量，我認為可以在 participants 表上添加一個unread_messages_count INT 欄位，並在每次創建新消息的時候遞增它，如果用戶已讀則重置該欄位。

接下來需要遍歷每一條記錄，通過掃描每一個存在的對話來建立一個 對話切片 slice of conversations 並在最後進行響應。

找到單個對話

端點 /api/conversations/{conversationID} 會根據 ID 對單個對話進行響應。

func getConversation(w http.ResponseWriter, r *http.Request) {
    ctx := r.Context()
    authUserID := ctx.Value(keyAuthUserID).(string)
    conversationID := way.Param(ctx, "conversationID")

    var conversation Conversation
    var otherParticipant User
    if err := db.QueryRowContext(ctx, `
        SELECT
            IFNULL(auth_user.messages_read_at < messages.created_at, false) AS has_unread_messages,
            other_users.id,
            other_users.username,
            other_users.avatar_url
        FROM conversations
        LEFT JOIN messages ON conversations.last_message_id = messages.id
        INNER JOIN participants other_participants
            ON other_participants.conversation_id = conversations.id
                AND other_participants.user_id != $1
        INNER JOIN users other_users ON other_participants.user_id = other_users.id
        INNER JOIN participants auth_user
            ON auth_user.conversation_id = conversations.id
                AND auth_user.user_id = $1
        WHERE conversations.id = $2
    `, authUserID, conversationID).Scan(
        &conversation.HasUnreadMessages,
        &otherParticipant.ID,
        &otherParticipant.Username,
        &otherParticipant.AvatarURL,
    ); err == sql.ErrNoRows {
        http.Error(w, "Conversation not found", http.StatusNotFound)
        return
    } else if err != nil {
        respondError(w, fmt.Errorf("could not query conversation: %v", err))
        return
    }

    conversation.ID = conversationID
    conversation.OtherParticipant = &otherParticipant

    respond(w, conversation, http.StatusOK)
}

這裡的查詢與之前有點類似。儘管我們並不關心最後一條消息的顯示問題，並因此忽略了與之相關的一些欄位，但是我們需要根據這條消息來判斷對話中是否存在未讀消息。此時，我們使用 LEFT JOIN 來代替 INNER JOIN，因為 last_message_id 欄位是 NULLABLE（可以為空）的；而其他情況下，我們無法得到任何記錄。基於同樣的理由，我們在 has_unread_messages 的比較中使用了 IFNULL 語句。最後，我們按 ID 進行過濾。

如果查詢沒有返回任何記錄，我們的響應會返回 404 Not Found 錯誤，否則響應將會返回 200 OK 以及找到的對話。

本篇帖子以創建了一些對話端點結束。

在下一篇帖子中，我們將會看到如何創建並列出消息。

via: https://nicolasparada.netlify.com/posts/go-messenger-conversations/

作者：Nicolás Parada 選題：lujun9972 譯者：PsiACE 校對：wxy

本文由 LCTT 原創編譯，Linux中國 榮譽推出

本文轉載來自 Linux 中國: https://github.com/Linux-CN/archive

對這篇文章感覺如何？

太棒了
0
不錯
0
愛死了
0
不太好
0
感覺很糟
0
雨落清風。心向陽
    Previous
    Next

    You may also like

    Leave a reply

    您的電子郵箱地址不會被公開。 必填項已用 * 標註

    此站點使用Akismet來減少垃圾評論。了解我們如何處理您的評論數據。

    More in:Linux中國