悠家娱乐|| Linux 中国，构建一个即时消息应用（四）：消息在这篇文章中

文章图片
在这篇文章中，我们将对端点进行编码，以创建一条消息并列出它们，同时还将编写一个端点以更新参与者上次阅读消息的时间。
?来源：linux.cn?作者：NicolásParada?译者：XianLeiGao?
（本文字数：7533 ，阅读时长大约：8分钟）
本文是该系列的第四篇。
第一篇:模式
第二篇:OAuth
第三篇:对话
在这篇文章中，我们将对端点进行编码，以创建一条消息并列出它们，同时还将编写一个端点以更新参与者上次阅读消息的时间。首先在main()函数中添加这些路由。
【悠家娱乐|| Linux 中国，构建一个即时消息应用（四）：消息】router.HandleFunc(''POST'',''/api/conversations/:conversationID/messages'',requireJSON(guard(createMessage)))router.HandleFunc(''GET'',''/api/conversations/:conversationID/messages'',guard(getMessages))router.HandleFunc(''POST'',''/api/conversations/:conversationID/read_messages'',guard(readMessages))
消息会进入对话，因此端点包含对话ID 。
创建消息
该端点处理对/api/conversations/{conversationID}/messages的POST请求，其JSON主体仅包含消息内容，并返回新创建的消息。它有两个副作用：更新对话last_message_id以及更新参与者messages_read_at 。
funccreateMessage(whttp.ResponseWriter,r*http.Request){varinputstruct{Contentstring`json:''content''`}deferr.Body.Close()iferr:=json.NewDecoder(r.Body).Decode(&input);err!=nil{http.Error(w,err.Error(),http.StatusBadRequest)return}errs:=make(map[string]string)input.Content=removeSpaces(input.Content)ifinput.Content==''''{errs[''content'']=''Messagecontentrequired''}elseiflen([]rune(input.Content))>480{errs[''content'']=''Messagetoolong.480max''}iflen(errs)!=0{respond(w,Errors{errs},http.StatusUnprocessableEntity)return}ctx:=r.Context()authUserID:=ctx.Value(keyAuthUserID).(string)conversationID:=way.Param(ctx,''conversationID'')tx,err:=db.BeginTx(ctx,nil)iferr!=nil{respondError(w,fmt.Errorf(''couldnotbegintx:%v'',err))return}defertx.Rollback()isParticipant,err:=queryParticipantExistance(ctx,tx,authUserID,conversationID)iferr!=nil{respondError(w,fmt.Errorf(''couldnotqueryparticipantexistance:%v'',err))return}if!isParticipant{http.Error(w,''Conversationnotfound'',http.StatusNotFound)return}varmessageMessageiferr:=tx.QueryRowContext(ctx,`INSERTINTOmessages(content,user_id,conversation_id)VALUES($1,$2,$3)RETURNINGid,created_at`,input.Content,authUserID,conversationID).Scan(&message.ID,&message.CreatedAt,);err!=nil{respondError(w,fmt.Errorf(''couldnotinsertmessage:%v'',err))return}if_,err:=tx.ExecContext(ctx,`UPDATEconversationsSETlast_message_id=$1WHEREid=$2`,message.ID,conversationID);err!=nil{respondError(w,fmt.Errorf(''couldnotupdateconversationlastmessageID:%v'',err))return}iferr=tx.Commit();err!=nil{respondError(w,fmt.Errorf(''couldnotcommittxtocreateamessage:%v'',err))return}gofunc(){iferr=updateMessagesReadAt(nil,authUserID,conversationID);err!=nil{log.Printf(''couldnotupdatemessagesreadat:%vn'',err)}}()message.Content=input.Contentmessage.UserID=authUserIDmessage.ConversationID=conversationID//TODO:notifyaboutnewmessage.message.Mine=truerespond(w,message,http.StatusCreated)}

悠家娱乐|| Linux 中国，构建一个即时消息应用（四）：消息

推荐阅读

「天津」北方城市需形成三足鼎立，继北京天津之后，谁能成为北方第三城

花草茶的冲泡要领,花草茶的挑选与保存

身材|26岁健身女教练，兼具马甲线和苹果臀，靠实力获封“女神”

2020匡威新款正品好鞋，尽在得物APP

吃完饭感觉到困，你有这种现象吗？

土土女排|张怡宁克星走马上任，国乒对手主帅更替：华裔铁娘子奥运后退位

这些生活小技巧太让人吃惊啦！

|男子裸身报警：前女友把我脱光绑树上说让我舒服

英国首相府：约翰逊已从ICU转回普通病房

青年|黄老爷的赏金如数奉还？斗鱼杯中国区战罢

华为■干货！全网第一影像旗舰华为P40 Pro上手

美式风的新房入住，复古风大气又温馨，入户玄关就很吸引人了

互相推诿！老人住院7名子女均不出钱孙子垫付，民警怒斥：你们怎么回事！

ZAKER生活|结果两人全部...，乱来！亲爹让00后儿子在高速上无证+超速驾驶

『乌鲁木齐已启动疫情应急响应预案』乌鲁木齐已启动疫情应急响应预案：不聚集戴口罩

科华恒盛■硬核！科华恒盛荣膺2019年领跑者逆变器5A企业大奖

电商内容运营具体工作是什么，电商产品的销售模式

美国将于11月3日举行大选|美国将于11月3日举行大选特朗普多次感叹“没人喜欢我”

几部喜剧电影介绍经典老电影喜剧片

财经界切分|拼多多黄峥卸任CEO，腾讯回应老干妈事件被骗