Method CreateLock

component/git_http.go:439–481

(ctx context.Context, req types.LfsLockReq)

}

func (c *GitHTTPComponent) CreateLock(ctx context.Context, req types.LfsLockReq) (*database.LfsLock, error) {
	var (
		lock *database.LfsLock
	)
	repo, err := c.repo.FindByPath(ctx, req.RepoType, req.Namespace, req.Name)
	if err != nil {
		return nil, fmt.Errorf("failed to find repo, error: %w", err)
	}

	user, err := c.user.FindByUsername(ctx, req.CurrentUser)
	if err != nil {
		return nil, ErrUnauthorized
	}

	allowed, err := c.AllowWriteAccess(ctx, req.RepoType, req.Namespace, req.Name, req.CurrentUser)
	if err != nil {
		slog.Error("Unable to check user write access:", slog.Any("error", err))
		return nil, err
	}

	if !allowed {
		return nil, ErrUnauthorized
	}
	lfsLock := database.LfsLock{
		Path:         req.Path,
		UserID:       user.ID,
		RepositoryID: repo.ID,
	}

	lock, err = c.lfsLockStore.FindByPath(ctx, lfsLock.RepositoryID, lfsLock.Path)
	if err != nil {
		if errors.Is(err, sql.ErrNoRows) {
			lock, err = c.lfsLockStore.Create(ctx, lfsLock)
			if err != nil {
				return nil, ErrAlreadyExists
			}
			return lock, nil
		}
		return lock, fmt.Errorf("failed to find lfs lock, error: %w", err)
	}

	return lock, ErrAlreadyExists
}

func (c *GitHTTPComponent) ListLocks(ctx context.Context, req types.ListLFSLockReq) (*types.LFSLockList, error) {
	repo, err := c.repo.FindByPath(ctx, req.RepoType, req.Namespace, req.Name)