Method LfsBatch

api/handler/git_http.go:154–202

(ctx *gin.Context)

}

func (h *GitHTTPHandler) LfsBatch(ctx *gin.Context) {
	var batchRequest types.BatchRequest
	if err := ctx.ShouldBindJSON(&batchRequest); err != nil {
		slog.Error("Bad request format", "error", err)
		httpbase.BadRequest(ctx, err.Error())
		return
	}
	batchRequest.CurrentUser = httpbase.GetCurrentUser(ctx)
	batchRequest.Authorization = ctx.Request.Header.Get("Authorization")
	batchRequest.Namespace = ctx.GetString("namespace")
	batchRequest.Name = ctx.GetString("name")
	batchRequest.RepoType = types.RepositoryType(ctx.GetString("repo_type"))

	var isUpload bool
	if batchRequest.Operation == "upload" {
		isUpload = true
	} else if batchRequest.Operation == "download" {
		isUpload = false
	} else {
		slog.Error("Invalid lfs batch operation", slog.String("operation", batchRequest.Operation))
		httpbase.BadRequest(ctx, fmt.Sprintf("Invalid lfs batch operation: %s", batchRequest.Operation))
		return
	}

	s3Internal := ctx.GetHeader("X-OPENCSG-S3-Internal")
	if s3Internal == "true" {
		ctx.Set("X-OPENCSG-S3-Internal", true)
	}

	objectResponse, err := h.c.BuildObjectResponse(ctx, batchRequest, isUpload)
	if err != nil {
		if errors.Is(err, component.ErrUnauthorized) {
			ctx.Header("WWW-Authenticate", "Basic realm=opencsg-git")
			ctx.PureJSON(http.StatusUnauthorized, nil)
			return
		}

		if errors.Is(err, component.ErrForbidden) {
			ctx.PureJSON(http.StatusForbidden, gin.H{
				"error": "You do not have permission to access this repository.",
			})
			return
		}
		httpbase.ServerError(ctx, err)
		return
	}
	ctx.Header("Content-Type", types.LfsMediaType)
	ctx.PureJSON(http.StatusOK, objectResponse)
}

func (h *GitHTTPHandler) LfsUpload(ctx *gin.Context) {
	var err error