This commit is contained in:
@@ -186,15 +186,20 @@ func (ctl *posts) Play(ctx fiber.Ctx, post *models.Post, user *models.User) (*Pl
|
|||||||
// return &PlayUrl{
|
// return &PlayUrl{
|
||||||
// Url: "https://github.com/mediaelement/mediaelement-files/raw/refs/heads/master/big_buck_bunny.mp4",
|
// Url: "https://github.com/mediaelement/mediaelement-files/raw/refs/heads/master/big_buck_bunny.mp4",
|
||||||
// }, nil
|
// }, nil
|
||||||
|
if post.Status != fields.PostStatusPublished {
|
||||||
preview := true
|
return nil, fiber.ErrNotFound
|
||||||
bought, err := services.Users.HasBought(ctx, user.ID, post.ID)
|
|
||||||
if err != nil {
|
|
||||||
preview = false
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if bought {
|
preview := true
|
||||||
preview = false
|
if user != nil {
|
||||||
|
bought, err := services.Users.HasBought(ctx, user.ID, post.ID)
|
||||||
|
if err != nil {
|
||||||
|
preview = false
|
||||||
|
}
|
||||||
|
|
||||||
|
if bought {
|
||||||
|
preview = false
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Infof("Fetching play URL for post ID: %d", post.ID)
|
log.Infof("Fetching play URL for post ID: %d", post.ID)
|
||||||
|
|||||||
@@ -22,7 +22,9 @@ func (f *Middlewares) AuthFrontend(ctx fiber.Ctx) error {
|
|||||||
if strings.HasPrefix(ctx.Path(), "/v1/posts/") && strings.HasSuffix(ctx.Path(), "show") {
|
if strings.HasPrefix(ctx.Path(), "/v1/posts/") && strings.HasSuffix(ctx.Path(), "show") {
|
||||||
return ctx.Next()
|
return ctx.Next()
|
||||||
}
|
}
|
||||||
if strings.HasPrefix(ctx.Path(), "/v1/posts/") && strings.HasSuffix(ctx.Path(), "play") {
|
|
||||||
|
token := ctx.Get("Authorization")
|
||||||
|
if token == "" && strings.HasPrefix(ctx.Path(), "/v1/posts/") && strings.HasSuffix(ctx.Path(), "play") {
|
||||||
return ctx.Next()
|
return ctx.Next()
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -47,7 +49,6 @@ func (f *Middlewares) AuthFrontend(ctx fiber.Ctx) error {
|
|||||||
fullUrl = u.String()
|
fullUrl = u.String()
|
||||||
|
|
||||||
// 仅使用 Header 的 Bearer Token(前端 localStorage 存储,随请求透传)。
|
// 仅使用 Header 的 Bearer Token(前端 localStorage 存储,随请求透传)。
|
||||||
token := ctx.Get("Authorization")
|
|
||||||
if token == "" {
|
if token == "" {
|
||||||
log.Infof("auth redirect_uri: %s", fullUrl)
|
log.Infof("auth redirect_uri: %s", fullUrl)
|
||||||
if ctx.XHR() {
|
if ctx.XHR() {
|
||||||
@@ -73,6 +74,7 @@ func (f *Middlewares) AuthFrontend(ctx fiber.Ctx) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
ctx.Locals("user", user)
|
ctx.Locals("user", user)
|
||||||
|
log.Infof("jwt login user id: %d", user.ID)
|
||||||
|
|
||||||
return ctx.Next()
|
return ctx.Next()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user