b2105de36f
It might not be a good idea to start a possibly long lasting http call during a running DB transaction. I.E. in the case of failing transaction we already sent some data into the world which might not be valid.
205 lines
5.7 KiB
Go
205 lines
5.7 KiB
Go
// Copyright 2016 The Gogs Authors. All rights reserved.
|
|
// Copyright 2020 The Gitea Authors.
|
|
// Copyright 2024 The forgejo Authors.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package user
|
|
|
|
import (
|
|
std_context "context"
|
|
"net/http"
|
|
|
|
"code.gitea.io/gitea/models/db"
|
|
access_model "code.gitea.io/gitea/models/perm/access"
|
|
repo_model "code.gitea.io/gitea/models/repo"
|
|
user_model "code.gitea.io/gitea/models/user"
|
|
"code.gitea.io/gitea/modules/context"
|
|
api "code.gitea.io/gitea/modules/structs"
|
|
"code.gitea.io/gitea/routers/api/v1/utils"
|
|
"code.gitea.io/gitea/services/convert"
|
|
)
|
|
|
|
// getStarredRepos returns the repos that the user with the specified userID has
|
|
// starred
|
|
func getStarredRepos(ctx std_context.Context, user *user_model.User, private bool, listOptions db.ListOptions) ([]*api.Repository, error) {
|
|
starredRepos, err := repo_model.GetStarredRepos(ctx, user.ID, private, listOptions)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
repos := make([]*api.Repository, len(starredRepos))
|
|
for i, starred := range starredRepos {
|
|
permission, err := access_model.GetUserRepoPermission(ctx, starred, user)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
repos[i] = convert.ToRepo(ctx, starred, permission)
|
|
}
|
|
return repos, nil
|
|
}
|
|
|
|
// GetStarredRepos returns the repos that the given user has starred
|
|
func GetStarredRepos(ctx *context.APIContext) {
|
|
// swagger:operation GET /users/{username}/starred user userListStarred
|
|
// ---
|
|
// summary: The repos that the given user has starred
|
|
// produces:
|
|
// - application/json
|
|
// parameters:
|
|
// - name: username
|
|
// in: path
|
|
// description: username of user
|
|
// type: string
|
|
// required: true
|
|
// - name: page
|
|
// in: query
|
|
// description: page number of results to return (1-based)
|
|
// type: integer
|
|
// - name: limit
|
|
// in: query
|
|
// description: page size of results
|
|
// type: integer
|
|
// responses:
|
|
// "200":
|
|
// "$ref": "#/responses/RepositoryList"
|
|
// "404":
|
|
// "$ref": "#/responses/notFound"
|
|
|
|
private := ctx.ContextUser.ID == ctx.Doer.ID
|
|
repos, err := getStarredRepos(ctx, ctx.ContextUser, private, utils.GetListOptions(ctx))
|
|
if err != nil {
|
|
ctx.Error(http.StatusInternalServerError, "getStarredRepos", err)
|
|
return
|
|
}
|
|
|
|
ctx.SetTotalCountHeader(int64(ctx.ContextUser.NumStars))
|
|
ctx.JSON(http.StatusOK, &repos)
|
|
}
|
|
|
|
// GetMyStarredRepos returns the repos that the authenticated user has starred
|
|
func GetMyStarredRepos(ctx *context.APIContext) {
|
|
// swagger:operation GET /user/starred user userCurrentListStarred
|
|
// ---
|
|
// summary: The repos that the authenticated user has starred
|
|
// parameters:
|
|
// - name: page
|
|
// in: query
|
|
// description: page number of results to return (1-based)
|
|
// type: integer
|
|
// - name: limit
|
|
// in: query
|
|
// description: page size of results
|
|
// type: integer
|
|
// produces:
|
|
// - application/json
|
|
// responses:
|
|
// "200":
|
|
// "$ref": "#/responses/RepositoryList"
|
|
|
|
repos, err := getStarredRepos(ctx, ctx.Doer, true, utils.GetListOptions(ctx))
|
|
if err != nil {
|
|
ctx.Error(http.StatusInternalServerError, "getStarredRepos", err)
|
|
}
|
|
|
|
ctx.SetTotalCountHeader(int64(ctx.Doer.NumStars))
|
|
ctx.JSON(http.StatusOK, &repos)
|
|
}
|
|
|
|
// IsStarring returns whether the authenticated is starring the repo
|
|
func IsStarring(ctx *context.APIContext) {
|
|
// swagger:operation GET /user/starred/{owner}/{repo} user userCurrentCheckStarring
|
|
// ---
|
|
// summary: Whether the authenticated is starring the repo
|
|
// parameters:
|
|
// - name: owner
|
|
// in: path
|
|
// description: owner of the repo
|
|
// type: string
|
|
// required: true
|
|
// - name: repo
|
|
// in: path
|
|
// description: name of the repo
|
|
// type: string
|
|
// required: true
|
|
// responses:
|
|
// "204":
|
|
// "$ref": "#/responses/empty"
|
|
// "404":
|
|
// "$ref": "#/responses/notFound"
|
|
|
|
if repo_model.IsStaring(ctx, ctx.Doer.ID, ctx.Repo.Repository.ID) {
|
|
ctx.Status(http.StatusNoContent)
|
|
} else {
|
|
ctx.NotFound()
|
|
}
|
|
}
|
|
|
|
// Star the repo specified in the APIContext, as the authenticated user
|
|
func Star(ctx *context.APIContext) {
|
|
// swagger:operation PUT /user/starred/{owner}/{repo} user userCurrentPutStar
|
|
// ---
|
|
// summary: Star the given repo
|
|
// parameters:
|
|
// - name: owner
|
|
// in: path
|
|
// description: owner of the repo to star
|
|
// type: string
|
|
// required: true
|
|
// - name: repo
|
|
// in: path
|
|
// description: name of the repo to star
|
|
// type: string
|
|
// required: true
|
|
// responses:
|
|
// "204":
|
|
// "$ref": "#/responses/empty"
|
|
// "404":
|
|
// "$ref": "#/responses/notFound"
|
|
|
|
userID := ctx.Doer.ID
|
|
repoID := ctx.Repo.Repository.ID
|
|
|
|
// TODO: why is this *context.APIContext passed, where a context.Context is expected?
|
|
err := repo_model.StarRepo(ctx, userID, repoID, true)
|
|
if err != nil {
|
|
ctx.Error(http.StatusInternalServerError, "StarRepo", err)
|
|
return
|
|
}
|
|
|
|
if err := repo_model.SendLikeActivities(ctx, userID, repoID); err != nil {
|
|
ctx.Error(http.StatusInternalServerError, "StarRepo", err)
|
|
return
|
|
}
|
|
|
|
ctx.Status(http.StatusNoContent)
|
|
}
|
|
|
|
// Unstar the repo specified in the APIContext, as the authenticated user
|
|
func Unstar(ctx *context.APIContext) {
|
|
// swagger:operation DELETE /user/starred/{owner}/{repo} user userCurrentDeleteStar
|
|
// ---
|
|
// summary: Unstar the given repo
|
|
// parameters:
|
|
// - name: owner
|
|
// in: path
|
|
// description: owner of the repo to unstar
|
|
// type: string
|
|
// required: true
|
|
// - name: repo
|
|
// in: path
|
|
// description: name of the repo to unstar
|
|
// type: string
|
|
// required: true
|
|
// responses:
|
|
// "204":
|
|
// "$ref": "#/responses/empty"
|
|
// "404":
|
|
// "$ref": "#/responses/notFound"
|
|
|
|
err := repo_model.StarRepo(ctx, ctx.Doer.ID, ctx.Repo.Repository.ID, false)
|
|
if err != nil {
|
|
ctx.Error(http.StatusInternalServerError, "StarRepo", err)
|
|
return
|
|
}
|
|
ctx.Status(http.StatusNoContent)
|
|
}
|