originalmk/archat-server
1
0
Fork 0
mirror of https://github.com/originalmk/archat-server.git synced 2024-10-03 11:16:10 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Changing initiation status to D when got ChatStartDRequest

Browse Source
This commit is contained in:
Maciej Krzyżanowski 2024-04-29 14:00:07 +02:00
parent 24ee719de3
commit 67eda0d069
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
client/client.go
View File

@ -114,6 +114,9 @@ func (cliCtx *Context) handleStartChatB(reqFrame cm.RFrame) (res cm.Response, er
}
func (cliCtx *Context) handleStartChatD(reqFrame cm.RFrame) (res cm.Response, err error) {
cliCtx.initiationsLock.Lock()
defer cliCtx.initiationsLock.Unlock()
startChatDReq, err := cm.RequestFromFrame[cm.StartChatDRequest](reqFrame)
if err != nil {
return nil, err
@ -123,6 +126,17 @@ func (cliCtx *Context) handleStartChatD(reqFrame cm.RFrame) (res cm.Response, er
startChatDReq.Nickname, startChatDReq.PunchCode)
logger.Warn("handleStartChatD not implemented yet")
idx := slices.IndexFunc(cliCtx.initiations, func(i *cm.Initiation) bool {
return i.AbBNick == startChatDReq.Nickname
})
if idx == -1 {
logger.Error("there is no initation related to chatstartd's nickname, ignoring")
return nil, nil
}
cliCtx.initiations[idx].Stage = cm.InitiationStageD
return nil, nil
}
@ -271,6 +285,9 @@ func sendStartChatA(ctx *Context, nick string) {
}
func sendStartChatC(ctx *Context, nick string) {
ctx.initiationsLock.Lock()
defer ctx.initiationsLock.Unlock()
idx := slices.IndexFunc(ctx.initiations, func(i *cm.Initiation) bool {
return i.AbANick == nick
})
@ -287,6 +304,8 @@ func sendStartChatC(ctx *Context, nick string) {
return
}
ctx.initiations[idx].Stage = cm.InitiationStageC
logger.Debug("request sent, no wait for response")
}