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

안쓰는 인덱스 제거

Browse Source
This commit is contained in:
mountain
2023-08-21 11:01:21 +09:00
parent a8df7d54bd
commit e8832f329a
2 changed files with 5 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/api.go
View File

@ -27,7 +27,6 @@ import (
) )
type FileDocumentDesc struct { type FileDocumentDesc struct {
Service string `bson:"service" json:"service"`
Key string `bson:"key" json:"key"` Key string `bson:"key" json:"key"`
Src string `bson:"src" json:"src"` Src string `bson:"src" json:"src"`
Link string `bson:"link" json:"link"` Link string `bson:"link" json:"link"`
@ -110,9 +109,8 @@ var seq = uint32(0)
func (caller apiCaller) uploadAPI(w http.ResponseWriter, r *http.Request) error { func (caller apiCaller) uploadAPI(w http.ResponseWriter, r *http.Request) error {
if r.Method == "PUT" { if r.Method == "PUT" {
servicename := r.FormValue("service")
hasher := md5.New() hasher := md5.New()
hasher.Write([]byte(servicename)) hasher.Write(caller.mg.service().serviceCodeBytes)
subfolder := hex.EncodeToString(hasher.Sum(nil))[:8] subfolder := hex.EncodeToString(hasher.Sum(nil))[:8]
infile, header, err := r.FormFile("file") infile, header, err := r.FormFile("file")
@ -151,12 +149,10 @@ func (caller apiCaller) uploadAPI(w http.ResponseWriter, r *http.Request) error
Link: link, Link: link,
Desc: desc, Desc: desc,
Key: rf, Key: rf,
Service: servicename,
} }
_, _, err = caller.mg.mongoClient.UpsertOne(CollectionFile, bson.M{ _, _, err = caller.mg.mongoClient.UpsertOne(CollectionFile, bson.M{
"_id": newidobj, "_id": newidobj,
"service": servicename, "key": rf,
"key": rf,
}, newdoc) }, newdoc)
if err == nil { if err == nil {

15
core/maingate.go
View File

@ -318,18 +318,6 @@ func (mg *Maingate) prepare(context context.Context) (err error) {
return err return err
} }
if err = mg.mongoClient.MakeIndices(CollectionWhitelist, map[string]bson.D{
"service": {{Key: "service", Value: 1}},
}); err != nil {
return err
}
if err = mg.mongoClient.MakeIndices(CollectionFile, map[string]bson.D{
"service": {{Key: "service", Value: 1}},
}); err != nil {
return err
}
if err = mg.mongoClient.MakeIndices(CollectionAccount, map[string]bson.D{ if err = mg.mongoClient.MakeIndices(CollectionAccount, map[string]bson.D{
"accid": {{Key: "accid", Value: 1}}, "accid": {{Key: "accid", Value: 1}},
}); err != nil { }); err != nil {
@ -337,11 +325,12 @@ func (mg *Maingate) prepare(context context.Context) (err error) {
} }
if err = mg.mongoClient.MakeUniqueIndices(CollectionFile, map[string]bson.D{ if err = mg.mongoClient.MakeUniqueIndices(CollectionFile, map[string]bson.D{
"sk": {{Key: "service", Value: 1}, {Key: "key", Value: 1}}, "keyonly": {{Key: "key", Value: 1}},
}); err != nil { }); err != nil {
return err return err
} }
// Delete대신 _ts로 expire시킴. pipeline에 삭제 알려주기 위함
if err = mg.mongoClient.MakeExpireIndex(CollectionWhitelist, 10); err != nil { if err = mg.mongoClient.MakeExpireIndex(CollectionWhitelist, 10); err != nil {
return err return err
} }