martincamen/laravel-nzbget

Laravel integration for NZBGet PHP SDK

Installs: 0

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 0

Forks: 0

Open Issues: 0

pkg:composer/martincamen/laravel-nzbget

1.0.0 2025-12-22 10:58 UTC

This package is auto-updated.

Last update: 2025-12-22 11:01:45 UTC


README

Laravel wrapper for the NZBGet PHP SDK.

Requirements

  • PHP 8.3+
  • Laravel 11.0+ or 12.0+

Installation

composer require martincamen/laravel-nzbget

The package will auto-register its service provider.

Configuration

Publish the configuration file:

php artisan vendor:publish --provider="NZBGet\NZBGetServiceProvider"

Add the following environment variables to your .env file:

NZBGET_HOST=localhost
NZBGET_PORT=6789
NZBGET_USERNAME=your-username
NZBGET_PASSWORD=your-password
NZBGET_USE_HTTPS=false
NZBGET_TIMEOUT=30

Usage

use NZBGet\Facades\NZBGet;

// Program actions
$version = NZBGet::program()->version(); // Returns "21.1"
NZBGet::program()->reload();             // Reload configuration
NZBGet::program()->shutdown();           // Shutdown server

// Status actions
$status = NZBGet::status()->get();                             // Returns Status DTO
echo $status->remainingSizeMB;                                 // Get remaining download size
echo $status->downloadPaused;                                  // Check if downloads paused
echo $status->isDownloading();                                 // Check if actively downloading
NZBGet::status()->serverVolumes();                             // Returns ServerVolumeCollection
NZBGet::status()->resetServerVolume(1, ServerCounter::Custom); // Reset server volume counter

// Download actions
NZBGet::download()->pause();              // Pause all downloads
NZBGet::download()->resume();             // Resume all downloads
NZBGet::download()->pausePost();          // Pause post-processing
NZBGet::download()->resumePost();         // Resume post-processing
NZBGet::download()->pauseScan();          // Pause scanning
NZBGet::download()->resumeScan();         // Resume scanning
NZBGet::download()->rate(5000);           // Set speed limit to 5000 KB/s
NZBGet::download()->scheduleResume(3600); // Resume in 1 hour (3600 seconds)

// Queue actions
$queue = NZBGet::queue()->listGroups();      // Returns QueueGroupCollection
NZBGet::queue()->pause([1, 2, 3]);           // Pause specific items
NZBGet::queue()->resume([1, 2, 3]);          // Resume specific items
NZBGet::queue()->delete([1, 2, 3]);          // Delete specific items
NZBGet::queue()->setPriority([1], 100);      // Set priority
NZBGet::queue()->setCategory([1], 'movies'); // Set category
NZBGet::queue()->moveTop([1, 2]);            // Move to top of queue
NZBGet::queue()->moveBottom([1, 2]);         // Move to bottom of queue

// History actions
$history = NZBGet::history()->get();                   // Returns HistoryItemCollection
$hidden = NZBGet::history()->get(includeHidden: true); // Returns HistoryItemCollection with hidden items
NZBGet::history()->hide([1, 2, 3]);                    // Hide items (soft delete)
NZBGet::history()->delete([1, 2]);                     // Permanently delete
NZBGet::history()->returnToQueue([1]);                 // Return to download queue
NZBGet::history()->redownload([1]);                    // Redownload item
NZBGet::history()->markGood([1, 2]);                   // Mark as good
NZBGet::history()->markBad([1, 2]);                    // Mark as bad

Dependency Injection

use NZBGet\NZBGet;

class MyController
{
    public function __construct(private NZBGet $nzbget) {}

    public function index()
    {
        $history = $this->nzbget->history()->get();

        return view('history', ['items' => $history]);
    }
}

Working with Collections

The SDK returns typed DTOs and collections:

use NZBGet\Facades\NZBGet;

// Get history as a typed collection
$history = NZBGet::history()->get();

// Iterate with typed items
foreach ($history as $item) {
    echo $item->nzbName;  // string
    echo $item->status;   // string
    echo $item->health;   // int
    echo $item->dupeMode; // DupeMode enum
}

// Collection methods
$first = $history->first();     // ?HistoryItem
$last = $history->last();       // ?HistoryItem
$found = $history->find(123);   // ?HistoryItem by ID
$count = $history->count();     // int
$isEmpty = $history->isEmpty(); // bool

// Filter items
$movies = $history->filter(fn(HistoryItem $item) => $item->category === 'movies');

// Map collection
$names = $history->map(fn(HistoryItem $item) => $item->nzbName);

// Convert to array
$array = $history->toArray();

Using Enums

The SDK provides typed enums for commands and modes:

use NZBGet\Facades\NZBGet;
use NZBGet\Data\Enums\DupeMode;
use NZBGet\Data\Enums\ServerCounter;

// Set duplicate mode with enum
NZBGet::history()->setDupeMode([1, 2], DupeMode::Force);

// Available DupeMode values
DupeMode::Score; // 'SCORE'
DupeMode::All;   // 'ALL'
DupeMode::Force; // 'FORCE'

// Reset server volume counter with enum
NZBGet::status()->resetServerVolume(1, ServerCounter::Custom);

// Available ServerCounter values
ServerCounter::Custom; // Reset custom counter only
ServerCounter::All;    // Reset all counters

Error Handling

The SDK throws specific exceptions for different error types:

use NZBGet\Facades\NZBGet;
use NZBGet\Exceptions\AuthenticationException;
use NZBGet\Exceptions\ConnectionException;
use NZBGet\Exceptions\JsonRpcException;

try {
    $version = NZBGet::program()->version();
} catch (AuthenticationException $e) {
    // Invalid username or password
} catch (ConnectionException $e) {
    // Could not connect to the server
} catch (JsonRpcException $e) {
    // JSON-RPC error from NZBGet
    echo $e->rpcCode;    // Error code
    echo $e->getMessage(); // Error message
}

Testing

The SDK provides testing utilities for easy mocking:

use NZBGet\Testing\NZBGetFake;
use NZBGet\Testing\Factories\HistoryItemFactory;
use NZBGet\Testing\Factories\QueueGroupFactory;
use NZBGet\Testing\Factories\StatusFactory;
use PHPUnit\Framework\Attributes\Test;

class MyTest extends TestCase
{
    #[Test]
    public function itDisplaysHistory(): void
    {
        // Create a fake NZBGet instance
        $fake = new NZBGetFake([
            'history' => HistoryItemFactory::new()->count(5)->makeArray(),
            'status'  => StatusFactory::new()->makeArray(),
            'version' => '21.1',
        ]);

        // Use it in your code
        $history = $fake->history()->get();

        // Assert calls were made
        $fake->assertCalled('history');
        $fake->assertCalledWith('history', [false]);
        $fake->assertNotCalled('shutdown');
        $fake->assertCalledTimes('history', 1);
    }

    #[Test]
    public function itCanHideItems(): void
    {
        $fake = new NZBGetFake();

        $fake->history()->hide([1, 2, 3]);

        $fake->assertCalledWith('editqueue', ['HistoryDelete', 0, '', [1, 2, 3]]);
    }
}

Using Factories

use NZBGet\Testing\Factories\HistoryItemFactory;
use NZBGet\Testing\Factories\QueueGroupFactory;

// Create a single item
$item = HistoryItemFactory::new()->make();

// Create multiple items
$collection = HistoryItemFactory::new()->count(5)->make();

// Create with custom attributes
$item = HistoryItemFactory::new()
    ->withAttributes([
        'NZBID'    => 123,
        'Category' => 'movies',
        'Status'   => 'SUCCESS/ALL',
    ])
    ->make();

// Get raw array data (for API mocking)
$data = HistoryItemFactory::new()->count(3)->makeArray();

Available Actions

ProgramActions

Method Description
version() Get the NZBGet version
shutdown() Shutdown the NZBGet server
reload() Reload the configuration

StatusActions

Method Description
get() Get current server status
serverVolumes() Get server volume statistics
resetServerVolume(int $serverId, ServerCounter $counter) Reset server volume counter

DownloadActions

Method Description
pause() Pause all downloads
resume() Resume all downloads
pausePost() Pause post-processing
resumePost() Resume post-processing
pauseScan() Pause directory scanning
resumeScan() Resume directory scanning
rate(int $limitKbPerSecond) Set speed limit (Limit disabled by default (0))
scheduleResume(int $secondsToWait) Schedule automatic resume

QueueActions

Method Description
listGroups(int $logEntries = 0) List all queue groups
pause(array $ids) Pause specific items
resume(array $ids) Resume specific items
delete(array $ids) Delete specific items
setPriority(array $ids, int $priority) Set priority
setCategory(array $ids, string $category) Set category
setName(array $ids, string $name) Rename items
moveTop(array $ids) Move to top of queue
moveBottom(array $ids) Move to bottom of queue

HistoryActions

Method Description
get(bool $includeHidden = false) Get history items
hide(array $ids) Hide items (soft delete)
delete(array $ids) Permanently delete items
returnToQueue(array $ids) Return items to queue
process(array $ids) Re-run post-processing
redownload(array $ids) Redownload items
setName(array $ids, string $name) Rename items
setDupeKey(array $ids, string $key) Set duplicate key
setDupeScore(array $ids, int $score) Set duplicate score
setDupeMode(array $ids, DupeMode $mode) Set duplicate mode
markBad(array $ids) Mark as bad
markGood(array $ids) Mark as good
markSuccess(array $ids) Mark as success

License

The MIT License (MIT). Please see License File for more information.