Method LfsVerify

component/git_http.go:405–437

(ctx context.Context, req types.VerifyRequest, p types.Pointer)

}

func (c *GitHTTPComponent) LfsVerify(ctx context.Context, req types.VerifyRequest, p types.Pointer) error {
	repo, err := c.repo.FindByPath(ctx, req.RepoType, req.Namespace, req.Name)
	if err != nil {
		return fmt.Errorf("failed to find repo, error: %w", err)
	}

	// _, err = c.lfsMetaObjectStore.FindByOID(ctx, repo.ID, p.Oid)
	// if err != nil {
	// 	return fmt.Errorf("failed to find lfs meta object, error: %w", err)
	// }
	objectKey := path.Join("lfs", p.RelativePath())
	fileInfo, err := c.s3Client.StatObject(ctx, c.config.S3.Bucket, objectKey, minio.StatObjectOptions{})
	if err != nil {
		slog.Error("failed to stat object in s3", slog.Any("error", err))
		return fmt.Errorf("failed to stat object in s3, error: %w", err)
	}

	if fileInfo.Size != p.Size {
		return types.ErrSizeMismatch
	}

	_, err = c.lfsMetaObjectStore.Create(ctx, database.LfsMetaObject{
		Oid:          p.Oid,
		Size:         p.Size,
		RepositoryID: repo.ID,
		Existing:     true,
	})
	if err != nil {
		return fmt.Errorf("failed to create lfs meta object in database: %w", err)
	}

	return nil
}

func (c *GitHTTPComponent) CreateLock(ctx context.Context, req types.LfsLockReq) (*database.LfsLock, error) {
	var (