blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-06-03 06:01:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

third

Browse Source
This commit is contained in:
withchao 2023-03-29 11:04:34 +08:00
parent 23daab441c
commit 9b89b5c782
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/common/db/controller/storage.go
View File

@ -122,10 +122,11 @@ func (c *s3Database) ApplyPut(ctx context.Context, req *third.ApplyPutReq) (*thi
} }
if hash, err := c.hash.Take(ctx, req.Hash, c.obj.Name()); err == nil { if hash, err := c.hash.Take(ctx, req.Hash, c.obj.Name()); err == nil {
o := relation.ObjectInfoModel{ o := relation.ObjectInfoModel{
Name: req.Name, Name: req.Name,
Hash: hash.Hash, Hash: hash.Hash,
ValidTime: expirationTime, ValidTime: expirationTime,
CreateTime: time.Now(), ContentType: req.ContentType,
CreateTime: time.Now(),
} }
if err := c.info.SetObject(ctx, &o); err != nil { if err := c.info.SetObject(ctx, &o); err != nil {
return nil, err return nil, err
@ -240,10 +241,11 @@ func (c *s3Database) ConfirmPut(ctx context.Context, req *third.ConfirmPutReq) (
} }
if hash, err := c.hash.Take(ctx, put.Hash, c.obj.Name()); err == nil { if hash, err := c.hash.Take(ctx, put.Hash, c.obj.Name()); err == nil {
o := relation.ObjectInfoModel{ o := relation.ObjectInfoModel{
Name: put.Name, Name: put.Name,
Hash: hash.Hash, Hash: hash.Hash,
ValidTime: put.ValidTime, ValidTime: put.ValidTime,
CreateTime: time.Now(), ContentType: put.ContentType,
CreateTime: time.Now(),
} }
if err := c.info.SetObject(ctx, &o); err != nil { if err := c.info.SetObject(ctx, &o); err != nil {
return nil, err return nil, err