/ 
Amon2-6.14
⭐ Starred 163 / Amon2::Plugin::Web::Streaming
Security Advisories (1)
CVE-2025-15604 (2026-03-28)

Amon2 versions before 6.17 for Perl use an insecure random_string implementation for security functions. In versions 6.06 through 6.16, the random_string function will attempt to read bytes from the /dev/urandom device, but if that is unavailable then it generates bytes by concatenating a SHA-1 hash seeded with the built-in rand() function, the PID, and the high resolution epoch time. The PID will come from a small set of numbers, and the epoch time may be guessed, if it is not leaked from the HTTP Date header. The built-in rand function is unsuitable for cryptographic usage. Before version 6.06, there was no fallback when /dev/urandom was not available. Before version 6.04, the random_string function used the built-in rand() function to generate a mixed-case alphanumeric string. This function may be used for generating session ids, generating secrets for signing or encrypting cookie session data and generating tokens used for Cross Site Request Forgery (CSRF) protection.

NAME

Amon2::Plugin::Web::Streaming - streaming support for Amon2

SYNOPSIS

use Amon2::Lite;

__PACKAGE__->load_plugin(qw/Web::Streaming/);

any '/poll' => sub {
    my $c = shift;
    return $c->streaming(sub {
        my $respond = shift;
        ...;
        $respond->write([200, [], ['OK']]);
    });
};

any '/poll_json' => sub {
    my $c = shift;
    return $c->streaming_json(sub {
        my $writer = shift;
        ...;
        $writer->write_json(+{ });
        $writer->close;
    });
};

DESCRIPTION

This is an Amon2 plugin to support streaming.

You MUST use the HTTP server supporting psgi.streaming.

EXPORTED METHODS

$c->streaming($code);

You can return delayed response for PSGI spec.

Argument for $code is $respond. It's same as a argument for PSGI callback.

$c->streaming_json($code);

It's a short hand utility to publish streaming JSON.

The argument is instance of Amon2::Plugin::Web::Streaming::Writer.

Amon2::Plugin::Streaming::Writer METHODS

new

Do not create the instance directly.

$writer->write_json($data)

Write a $data as JSON for the socket.

$writer->close()

Close the socket.

SEE ALSO

PSGI