ayo/tavern
6
0
Fork 2
Code Issues Pull Requests Projects Releases Wiki Activity

방장 종료 처리

Browse Source
This commit is contained in:
mountain
2024-01-18 14:40:39 +09:00
parent 3f1e9ef5c9
commit a81549863a
1 changed files with 67 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

92
core/group_party.go
View File

@ -186,6 +186,17 @@ func (gd *partyDoc) addMember(mid accountID, character bson.M) (bson.M, error) {
return gd.loadMemberFull(tid) return gd.loadMemberFull(tid)
} }
func (gd *partyDoc) getIncharge() string {
if len(gd.InCharge) == 0 {
incharge, err := gd.rh.JSONGet(gd.strid(), "$._incharge")
if err == nil && incharge != nil {
gd.InCharge = strings.Trim(incharge.(string), "[]\"")
}
}
return gd.InCharge
}
func (gd *partyDoc) removeMemberByTid(tid string) error { func (gd *partyDoc) removeMemberByTid(tid string) error {
_, err := gd.rh.JSONDel(gd.strid(), "$._members."+tid) _, err := gd.rh.JSONDel(gd.strid(), "$._members."+tid)
if err != nil { if err != nil {
@ -372,15 +383,24 @@ func (gp *groupParty) ConditionalClearPartyMember(w http.ResponseWriter, r *http
id: gid, id: gid,
rh: gp.rh, rh: gp.rh,
} }
gd.removeMember(mid) if gd.getIncharge() == gd.tid(mid) {
// 방장이 나갔다.
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{ gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: "#" + doc.Gid, Target: "#" + doc.Gid,
Body: bson.M{ Body: bson.M{"gid": gid},
gd.tid(mid): bson.M{}, Tag: []string{"GroupDocFull", gid.Hex()},
}, })
Tag: []string{"MemberDocFull"}, gd.rh.Del(gd.rh.Context(), gd.strid()).Result()
}) } else {
gd.removeMember(mid)
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: "#" + doc.Gid,
Body: bson.M{
gd.tid(mid): bson.M{},
},
Tag: []string{"MemberDocFull"},
})
}
} }
if len(pids) == 0 { if len(pids) == 0 {
@ -784,7 +804,20 @@ func (gp *groupParty) ClientDisconnected(msg string, callby *wshandler.Sender) {
// 나를 먼저 룸에서 빼야 나한테 메시지가 안감 // 나를 먼저 룸에서 빼야 나한테 메시지가 안감
gp.leaveRoom(gid, callby.Accid) gp.leaveRoom(gid, callby.Accid)
if msg != "pending" { gd := &partyDoc{
rh: gp.rh,
id: gid,
}
if gd.getIncharge() == gd.tid(callby.Accid) {
// 방장이 나감. 방 폭파
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: "#" + gidstr,
Body: bson.M{"gid": gid},
Tag: []string{"GroupDocFull", gidstr},
})
gd.rh.Del(gd.rh.Context(), gd.strid()).Result()
} else if msg != "pending" {
// gid에는 제거 메시지 보냄 // gid에는 제거 메시지 보냄
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{ gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: "#" + gidstr, Target: "#" + gidstr,
@ -856,21 +889,31 @@ func (gp *groupParty) LeaveParty(ctx wshandler.ApiCallContext) {
return return
} }
// mid한테는 빈 GroupDocFull을 보낸다. 그러면 지워짐 if gd.getIncharge() == gd.tid(mid) {
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{ // 방장이 나감. 방 폭파
Target: mid.Hex(), gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Body: bson.M{"gid": gid}, Target: "#" + gidstr,
Tag: []string{"GroupDocFull", gid.Hex()}, Body: bson.M{"gid": gid},
}) Tag: []string{"GroupDocFull", gidstr},
})
gd.rh.Del(gd.rh.Context(), gd.strid()).Result()
} else {
// mid한테는 빈 GroupDocFull을 보낸다. 그러면 지워짐
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: mid.Hex(),
Body: bson.M{"gid": gid},
Tag: []string{"GroupDocFull", gid.Hex()},
})
// gid에는 제거 메시지 보냄 // gid에는 제거 메시지 보냄
gp.sendUpstreamMessage(&wshandler.UpstreamMessage{ gp.sendUpstreamMessage(&wshandler.UpstreamMessage{
Target: "#" + gd.strid(), Target: "#" + gd.strid(),
Body: bson.M{ Body: bson.M{
tid: bson.M{}, tid: bson.M{},
}, },
Tag: []string{"MemberDocFull"}, Tag: []string{"MemberDocFull"},
}) })
}
gp.leaveRoom(gid, mid) gp.leaveRoom(gid, mid)
} }
@ -894,4 +937,3 @@ func (gp *groupParty) DenyPartyInvitation(ctx wshandler.ApiCallContext) {
Tag: []string{"MemberDocFull"}, Tag: []string{"MemberDocFull"},
}) })
} }