Compare commits

..

3 Commits

5 changed files with 21 additions and 8 deletions

View File

@ -3,6 +3,7 @@ package controller
import ( import (
"git.lumeweb.com/LumeWeb/portal/controller/request" "git.lumeweb.com/LumeWeb/portal/controller/request"
"git.lumeweb.com/LumeWeb/portal/controller/response" "git.lumeweb.com/LumeWeb/portal/controller/response"
"git.lumeweb.com/LumeWeb/portal/middleware"
"git.lumeweb.com/LumeWeb/portal/service/auth" "git.lumeweb.com/LumeWeb/portal/service/auth"
"github.com/kataras/iris/v12" "github.com/kataras/iris/v12"
) )
@ -99,3 +100,13 @@ func (a *AuthController) PostLogout() {
// Return a success response to the client. // Return a success response to the client.
a.Ctx.StatusCode(iris.StatusNoContent) a.Ctx.StatusCode(iris.StatusNoContent)
} }
func (a *AuthController) GetStatus() {
middleware.VerifyJwt(a.Ctx)
if a.Ctx.IsStopped() {
return
}
a.respondJSON(&response.AuthStatusResponse{Status: true})
}

View File

@ -128,7 +128,7 @@ func (f *FilesController) GetStatusBy(cidString string) {
break break
} }
f.respondJSON(&response.StatusResponse{Status: statusCode}) f.respondJSON(&response.FileStatusResponse{Status: statusCode})
} }

View File

@ -0,0 +1,5 @@
package response
type AuthStatusResponse struct {
Status bool `json:"status"`
}

View File

@ -1,5 +1,5 @@
package response package response
type StatusResponse struct { type FileStatusResponse struct {
Status string `json:"status"` Status string `json:"status"`
} }

View File

@ -80,18 +80,15 @@ func Upload(r io.ReadSeeker, size int64, hash []byte) (model.Upload, error) {
} }
result := db.Get().Where(&model.Upload{Hash: hashHex}).First(&upload) result := db.Get().Where(&model.Upload{Hash: hashHex}).First(&upload)
if (result.Error != nil && !errors.Is(result.Error, gorm.ErrRecordNotFound)) || result.RowsAffected > 0 { if !errors.Is(result.Error, gorm.ErrRecordNotFound) {
err := result.Row().Scan(&upload)
if err != nil { if err != nil {
logger.Get().Error(ErrFailedQueryUpload.Error(), zap.Error(err)) logger.Get().Error(ErrFailedQueryUpload.Error(), zap.Error(err))
return upload, ErrFailedQueryUpload return upload, ErrFailedQueryUpload
} }
if result.RowsAffected > 0 && upload.ID > 0 {
logger.Get().Info(ErrAlreadyExists.Error()) logger.Get().Info(ErrAlreadyExists.Error())
return upload, nil return upload, nil
} }
}
objectExistsResult, err := client.R().Get(getBusObjectUrl(hashHex)) objectExistsResult, err := client.R().Get(getBusObjectUrl(hashHex))