cancel.go

func (s *Service) ChunkUpload(ctx context.Context, r *multipart.Reader) error {
	chunk, err := s.parseChunk(r)
	if err != nil {
		return fmt.Errorf("failed parsing chunk %w", err)
	}

	// checkpoint
	select {
	case <-ctx.Done():
		// Abort / return early
		return ctx.Err()
	default:
	}

	if err := os.MkdirAll(chunk.UploadDir, 02750); err != nil {
		return err
	}

	// checkpoint
	select {
	case <-ctx.Done():
		// Abort / return early
		return ctx.Err()
	default:
	}

	if err := s.saveChunk(chunk); err != nil {
		return fmt.Errorf("failed saving chunk %w", err)
	}

	return nil
}