ayo/maingate
8
1
Fork 3
Code Issues Pull Requests Projects Releases Wiki Activity

[이민권] 계정 삭제

Browse Source 
- 계정 삭제 취소 기능 추가
This commit is contained in:
mklee
2024-01-10 17:28:24 +09:00
parent d8e18d7ffc
commit 763b0fc4bd
1 changed files with 25 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
core/service.go
View File

@ -673,18 +673,27 @@ func (sh *serviceDescription) authorize(w http.ResponseWriter, r *http.Request)
link, err := sh.mongoClient.FindOneAndUpdate(CollectionLink, bson.M{
"platform": authtype,
"uid": uid,
"_ts": bson.M{"$exists": false},
}, bson.M{
"$setOnInsert": bson.M{
"create": createtime,
"email": email,
},
}, options.FindOneAndUpdate().SetReturnDocument(options.After).SetUpsert(true).SetProjection(bson.M{"_id": 1}))
}, options.FindOneAndUpdate().SetReturnDocument(options.After).SetUpsert(true).SetProjection(bson.M{
"_id": 1,
"_ts": 1,
}))
if err != nil {
logger.Error("authorize failed :", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
delts := link["_ts"].(primitive.Timestamp)
if !delts.IsZero() {
// 삭제된 계정. 삭제 되었다고 알려주자
w.Header().Add("MG-ACCOUNT-DELETED", "TRUE")
w.WriteHeader(http.StatusUnauthorized)
return
}
linkid := link["_id"].(primitive.ObjectID)
newaccid := primitive.NewObjectID()
@ -825,6 +834,7 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) {
sType := queryvals.Get("stype")
sId := queryvals.Get("sid")
sk := queryvals.Get("sk")
cancel := queryvals.Has("cancel")
authInfo := sh.auths.Find(sk)
if authInfo == nil {
@ -857,20 +867,25 @@ func (sh *serviceDescription) delacc(w http.ResponseWriter, r *http.Request) {
}
delfilter := primitive.M{"_id": bson.M{"$in": addIdFilter}}
curtime := primitive.NewDateTimeFromTime(time.Now().UTC())
updated, _, err := sh.mongoClient.Update(CollectionAccount, delfilter, bson.M{
"$set": bson.M{"_ts": curtime},
}, options.Update().SetUpsert(false))
var delop primitive.M
if !cancel {
curtime := primitive.NewDateTimeFromTime(time.Now().UTC())
delop = primitive.M{
"$set": primitive.M{"_ts": curtime},
}
} else {
delop = primitive.M{
"$unset": primitive.M{"_ts": true},
}
}
updated, _, err := sh.mongoClient.Update(CollectionAccount, delfilter, delop, options.Update().SetUpsert(false))
if !updated || err != nil {
logger.Error("delacc failed. Update CollectionAccount timestamp err :", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
updated, _, err = sh.mongoClient.Update(CollectionLink, delfilter, bson.M{
"$set": bson.M{"_ts": curtime},
}, options.Update().SetUpsert(false))
updated, _, err = sh.mongoClient.Update(CollectionLink, delfilter, delop, options.Update().SetUpsert(false))
if !updated || err != nil {
logger.Error("delacc failed. Update CollectionLink timestamp err :", err)
w.WriteHeader(http.StatusInternalServerError)