{"header":{"message":"hydra-notify: extract runPluginsForEvent to a TaskDispatcher","description":null,"timestamp":"2021-08-26T19:39:29Z","authors":[{"email":"graham@grahamc.com","name":"Graham Christensen"}]},"hash":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC","authors":[],"deps":{"hashes":[["SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC","hydra-notify: extract runPluginsForEvent to a TaskDispatcher"],["AA",null],["JXJPLS22LTPDVUEM6AELNRQOKFUXCO36LRULKOMMTSL5ONCYO3AQC","hydra-notify: properly call new_event"],["BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC","hydra-notify: pre-declare metrics"],["3ELC3W2DNZLEMIIOGJ4VPWSYDPVTVP5SXRDCAGBKVAW66DBJWNIAC","hydra-notify: support sending diagnostic dumps to STDERR on request"],["IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","hydra-queue-runner: Send build notifications"],["4ZCUCACYWDLCZUKIH2OLFC4NCPBE2YO7Y7AZ7WL3AESZQ3TSIYXQC","hydra-notify: Fix processing notifications"],["T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC","hydra-notify: move BuildFinished processing to an Event"],["2HCWJE5WNCO66RVMAIUG4RYYG3ZCOAGHZMFNCQQPKH6FG3DN3RTQC","hydra-notify: fixup printing of build IDs"],["OPSWSU4LKI2F6UJXL7B7MH4C3L7DVVKYW5FARAJ44XYH4WXELLCQC","hydra-notify: move BuildStarted processing to an Event"],["IZVNPQASEBGBMFM5SA4GULUOMFFPLWLZZA4ZKANWKXKCIVJTAUDQC","fixup! hydra-notify: pre-declare metrics"],["FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC","hydra-notify: Create a helper for running each plugin on an event"],["4H6FVIWGOKFWAUB6TLR7XIWHHSSHCJOVCWRIYCTNQOQDJHGIQIAQC","hydra-notify: make the prometheus endpoint configurable, default-off"],["I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC","hydra-notify: initial scratch take of prometheus events"],["GE7LFZHQHT2ENWSZRNF6KWNBRXTHLA2SQGHT5ARACU4CZWDPWOZQC","hydra-notify: move buildFinished query in to the function impl"],["CQZQE32VR5JFHR2AQZVPXCGBHLJCLIZ3IX6NA3SWO2R44XVBSAGAC","Improve handling of Perl's block eval errors"],["P4SME2BCHKBETP4SFPOWOJM23K57VRFX3RAS634CQKTASXOXYRKQC","Abstract over postgres' LISTEN/NOTIFY"],["32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC","Turn hydra-notify into a daemon"],["3AKZKWCRQZTASQO5BZ4KCEFJ5OMP7LVF6YOPDJN5KCRIZIW75MCAC","RunCommand: Test"],["D5QIOJGPKQJIYBUCSC3MFJ3TXLPNZ2XMI37GXMFRVRFWWR2VMTFAC","* Move everything up one directory."],["2JJP76737U2JWJWQ6UDFEAQCGWRAQH46HC6OCIKWMB5QYRXF6DQQC","tests: move to t, allow `yath test` from root"]],"deps":["JXJPLS22LTPDVUEM6AELNRQOKFUXCO36LRULKOMMTSL5ONCYO3AQC","BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC","3ELC3W2DNZLEMIIOGJ4VPWSYDPVTVP5SXRDCAGBKVAW66DBJWNIAC"],"known":["IE2PRAQUCQVFPJ4CAIJRPXXEFC5VBAE3EO5I5FG4XWEDRNONNHKQC","32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC","4ZCUCACYWDLCZUKIH2OLFC4NCPBE2YO7Y7AZ7WL3AESZQ3TSIYXQC","CQZQE32VR5JFHR2AQZVPXCGBHLJCLIZ3IX6NA3SWO2R44XVBSAGAC","3AKZKWCRQZTASQO5BZ4KCEFJ5OMP7LVF6YOPDJN5KCRIZIW75MCAC","GE7LFZHQHT2ENWSZRNF6KWNBRXTHLA2SQGHT5ARACU4CZWDPWOZQC","P4SME2BCHKBETP4SFPOWOJM23K57VRFX3RAS634CQKTASXOXYRKQC","FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC","OPSWSU4LKI2F6UJXL7B7MH4C3L7DVVKYW5FARAJ44XYH4WXELLCQC","T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC","2HCWJE5WNCO66RVMAIUG4RYYG3ZCOAGHZMFNCQQPKH6FG3DN3RTQC","I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC","4H6FVIWGOKFWAUB6TLR7XIWHHSSHCJOVCWRIYCTNQOQDJHGIQIAQC","IZVNPQASEBGBMFM5SA4GULUOMFFPLWLZZA4ZKANWKXKCIVJTAUDQC"]},"hunks":[{"FileAdd":{"meta":{"basename":"Task.pm","metadata":0},"context":[{"change":20,"pos":53}],"contents":[{"Add":{"text":"package Hydra::Task;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:22"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:23"}},{"Add":{"text":"use strict;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:35"}},{"Add":{"text":"use warnings;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:49"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:50"}},{"Add":{"text":"sub new {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:60"}},{"Add":{"text":" my ($self, $event, $plugin_name) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:103"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:104"}},{"Add":{"text":" return bless {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:123"}},{"Add":{"text":" \"event\" => $event,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:150"}},{"Add":{"text":" \"plugin_name\" => $plugin_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:189"}},{"Add":{"text":" }, $self;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:203"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:205"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:206"}},{"Add":{"text":"1;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:209"}}]}},{"FileAdd":{"meta":{"basename":"TaskDispatcher.pm","metadata":0},"context":[{"change":20,"pos":53}],"contents":[{"Add":{"text":"package Hydra::TaskDispatcher;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:275"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:276"}},{"Add":{"text":"use strict;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:288"}},{"Add":{"text":"use warnings;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:302"}},{"Add":{"text":"use Hydra::Task;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:319"}},{"Add":{"text":"use Time::HiRes qw( gettimeofday tv_interval );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:367"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:368"}},{"Add":{"text":"=head1 Hydra::TaskDispatcher","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:397"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:398"}},{"Add":{"text":"Excecute many plugins with Hydra::Event as its input.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:452"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:453"}},{"Add":{"text":"The TaskDispatcher is responsible for dealing with fanout","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:511"}},{"Add":{"text":"from one incoming Event being executed across many plugins,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:571"}},{"Add":{"text":"or one Event being executed against a single plugin by first","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:632"}},{"Add":{"text":"wrapping it in a Task.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:655"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:656"}},{"Add":{"text":"Its execution model is based on creating a Hydra::Task for","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:715"}},{"Add":{"text":"each plugin's execution. The task represents the name of","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:772"}},{"Add":{"text":"the plugin to run and the Event to process.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:816"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:817"}},{"Add":{"text":"=cut","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:822"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:823"}},{"Add":{"text":"=head2 new","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:834"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:835"}},{"Add":{"text":"Arguments:","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:846"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:847"}},{"Add":{"text":"=over 1","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:855"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:856"}},{"Add":{"text":"=item C<$dbh>","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:870"}},{"Add":{"text":"L The database connection.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:906"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:907"}},{"Add":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:913"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:914"}},{"Add":{"text":"=item C<$prometheus>","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:935"}},{"Add":{"text":"L A Promethues implementation, either Prometheus::Tiny","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1008"}},{"Add":{"text":"or Prometheus::Tiny::Shared. Not compatible with Net::Prometheus.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1074"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1075"}},{"Add":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1081"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1082"}},{"Add":{"text":"=item C<%plugins>","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1100"}},{"Add":{"text":"L A list of Hydra plugins to execute events and tasks against.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1178"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1179"}},{"Add":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1185"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1186"}},{"Add":{"text":"=cut","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1191"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1192"}},{"Add":{"text":"sub new {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1202"}},{"Add":{"text":" my ($self, $db, $prometheus, $plugins) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1251"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1252"}},{"Add":{"text":" $prometheus->declare(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1278"}},{"Add":{"text":" \"notify_plugin_executions\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1314"}},{"Add":{"text":" type => \"counter\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1341"}},{"Add":{"text":" help => \"Number of times each plugin has been called by channel.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1415"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1422"}},{"Add":{"text":" $prometheus->declare(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1448"}},{"Add":{"text":" \"notify_plugin_runtime\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1481"}},{"Add":{"text":" type => \"histogram\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1510"}},{"Add":{"text":" help => \"Number of seconds spent executing each plugin by channel.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1586"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1593"}},{"Add":{"text":" $prometheus->declare(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1619"}},{"Add":{"text":" \"notify_plugin_success\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1652"}},{"Add":{"text":" type => \"counter\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1679"}},{"Add":{"text":" help => \"Number of successful executions of this plugin on this channel.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1761"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1768"}},{"Add":{"text":" $prometheus->declare(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1794"}},{"Add":{"text":" \"notify_plugin_error\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1825"}},{"Add":{"text":" type => \"counter\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1852"}},{"Add":{"text":" help => \"Number of failed executions of this plugin on this channel.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1930"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1937"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1938"}},{"Add":{"text":" my %plugins_by_name = map { ref $_ => $_ } @{$plugins};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1998"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1999"}},{"Add":{"text":" my $obj = bless {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2021"}},{"Add":{"text":" \"db\" => $db,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2042"}},{"Add":{"text":" \"prometheus\" => $prometheus,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2079"}},{"Add":{"text":" \"plugins_by_name\" => \\%plugins_by_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2127"}},{"Add":{"text":" }, $self;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2141"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2143"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2144"}},{"Add":{"text":"=head2 dispatch_event","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2166"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2167"}},{"Add":{"text":"Execute each configured plugin against the provided L.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2236"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2237"}},{"Add":{"text":"Arguments:","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2248"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2249"}},{"Add":{"text":"=over 1","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2257"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2258"}},{"Add":{"text":"=item C<$event>","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2274"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2275"}},{"Add":{"text":"L the event, usually from L.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2343"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2344"}},{"Add":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2350"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2351"}},{"Add":{"text":"=cut","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2356"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2357"}},{"Add":{"text":"sub dispatch_event {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2378"}},{"Add":{"text":" my ($self, $event) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2407"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2408"}},{"Add":{"text":" foreach my $plugin_name (keys %{$self->{\"plugins_by_name\"}}) {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2475"}},{"Add":{"text":" my $task = Hydra::Task->new($event, $plugin_name);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2534"}},{"Add":{"text":" $self->dispatch_task($task);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2571"}},{"Add":{"text":" }","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2577"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2579"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2580"}},{"Add":{"text":"=head2 dispatch_task","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2601"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2602"}},{"Add":{"text":"Execute a specifi plugin against the provided L.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2664"}},{"Add":{"text":"The Task includes information about what plugin should be executed.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2732"}},{"Add":{"text":"If the provided plugin does not exist, an error logged is logged and the","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2805"}},{"Add":{"text":"function returns falsey.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2830"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2831"}},{"Add":{"text":"Arguments:","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2842"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2843"}},{"Add":{"text":"=over 1","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2851"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2852"}},{"Add":{"text":"=item C<$task>","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2867"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2868"}},{"Add":{"text":"L the task, usually from L.","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2944"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2945"}},{"Add":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2951"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2952"}},{"Add":{"text":"=cut","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2957"}},{"Add":{"text":"sub dispatch_task {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:2977"}},{"Add":{"text":" my ($self, $task) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3005"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3006"}},{"Add":{"text":" my $channel_name = $task->{\"event\"}->{'channel_name'};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3065"}},{"Add":{"text":" my $plugin_name = $task->{\"plugin_name\"};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3111"}},{"Add":{"text":" my $event_labels = {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3136"}},{"Add":{"text":" channel => $channel_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3170"}},{"Add":{"text":" plugin => $plugin_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3202"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3209"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3210"}},{"Add":{"text":" my $plugin = $self->{\"plugins_by_name\"}->{$plugin_name};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3271"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3272"}},{"Add":{"text":" if (!defined($plugin)) {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3301"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_no_such_plugin\", $event_labels);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3384"}},{"Add":{"text":" print STDERR \"No plugin named $plugin_name\\n\";","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3439"}},{"Add":{"text":" return 0;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3457"}},{"Add":{"text":" }","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3463"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3464"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_executions\", $event_labels);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3539"}},{"Add":{"text":" eval {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3550"}},{"Add":{"text":" my $start_time = [gettimeofday()];","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3593"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3594"}},{"Add":{"text":" $task->{\"event\"}->execute($self->{\"db\"}, $plugin);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3653"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3654"}},{"Add":{"text":" $self->{\"prometheus\"}->histogram_observe(\"notify_plugin_runtime\", tv_interval($start_time), $event_labels);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3770"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_success\", $event_labels);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3846"}},{"Add":{"text":" 1;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3857"}},{"Add":{"text":" } or do {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3871"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_error\", $event_labels);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3945"}},{"Add":{"text":" print STDERR \"error running $channel_name hooks: $@\\n\";","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4009"}},{"Add":{"text":" return 0;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4027"}},{"Add":{"text":" }","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4033"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4035"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4036"}},{"Add":{"text":"1;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4039"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":13,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":1752}],"down_context":[{"change":5,"pos":62}],"flag":"BLOCK","start":4083,"end":4110,"inode":{"change":5,"pos":2994}}},"contents":[{"Add":{"text":"use Hydra::TaskDispatcher;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4109"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":16,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":119},"to":{"change":5,"start":119,"end":167},"introduced_by":5}],"inode":{"change":5,"pos":2994}}},"contents":[{"Del":{"text":"use Time::HiRes qw( gettimeofday tv_interval );","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:166"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":28,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":188},"to":{"change":3,"start":188,"end":626},"introduced_by":3}],"inode":{"change":5,"pos":2994}}},"contents":[{"Del":{"text":"$prom->declare(","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:203"}},{"Del":{"text":" \"notify_plugin_executions\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:235"}},{"Del":{"text":" type => \"counter\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:258"}},{"Del":{"text":" help => \"Number of times each plugin has been called by channel.\"","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:328"}},{"Del":{"text":");","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:331"}},{"Del":{"text":"$prom->declare(","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:347"}},{"Del":{"text":" \"notify_plugin_runtime\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:376"}},{"Del":{"text":" type => \"histogram\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:401"}},{"Del":{"text":" help => \"Number of seconds spent executing each plugin by channel.\"","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:473"}},{"Del":{"text":");","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:476"}},{"Del":{"text":"$prom->declare(","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:492"}},{"Del":{"text":" \"notify_plugin_success\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:521"}},{"Del":{"text":" type => \"counter\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:544"}},{"Del":{"text":" help => \"Number of successful executions of this plugin on this channel.\"","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:622"}},{"Del":{"text":");","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:625"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":29,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":642},"to":{"change":3,"start":642,"end":785},"introduced_by":3}],"inode":{"change":5,"pos":2994}}},"contents":[{"Del":{"text":" \"notify_plugin_error\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:668"}},{"Del":{"text":" type => \"counter\",","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:691"}},{"Del":{"text":" help => \"Number of failed executions of this plugin on this channel.\"","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:765"}},{"Del":{"text":");","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:768"}},{"Del":{"text":"$prom->declare(","pos":"BJJLHGFCE6RDMBF3HEEJ4DB6VOLTNA72UA5PWTMFJHVATEKV4EDAC:784"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":76,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":3326}],"down_context":[{"change":5,"pos":1457}],"flag":"BLOCK","start":4111,"end":4185,"inode":{"change":5,"pos":2994}}},"contents":[{"Add":{"text":"my $task_dispatcher = Hydra::TaskDispatcher->new($db, $prom, [@plugins]);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4184"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":85,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":482},"to":{"change":5,"start":0,"end":48},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1922},"to":{"change":5,"start":0,"end":48},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":48},"to":{"change":5,"start":475,"end":524},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":48},"to":{"change":5,"start":1591,"end":1592},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":524},"to":{"change":5,"start":1591,"end":1592},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":1922},"to":{"change":5,"start":1591,"end":1592},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1591},"to":{"change":5,"start":1591,"end":1592},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1592},"to":{"change":5,"start":49,"end":85},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":85},"to":{"change":5,"start":525,"end":625},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":625},"to":{"change":5,"start":85,"end":100},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":85},"to":{"change":5,"start":85,"end":100},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":100},"to":{"change":5,"start":626,"end":672},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":672},"to":{"change":5,"start":100,"end":143},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":100},"to":{"change":5,"start":100,"end":143},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":143},"to":{"change":5,"start":673,"end":915},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":915},"to":{"change":5,"start":143,"end":176},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":143},"to":{"change":5,"start":143,"end":176},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":176},"to":{"change":5,"start":916,"end":1015},"introduced_by":5},{"previous":"","flag":"DELETED","from":{"change":5,"pos":1015},"to":{"change":5,"start":176,"end":273},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":176},"to":{"change":5,"start":176,"end":273},"introduced_by":5}],"inode":{"change":5,"pos":2994}}},"contents":[{"Del":{"text":"","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:0"}},{"Del":{"text":"sub runPluginsForEvent {","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:25"}},{"Del":{"text":" my ($event) = @_;","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:47"}},{"Del":{"text":"","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:475"}},{"Del":{"text":" my $channelName = $event->{'channel_name'};","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:523"}},{"Del":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:1591"}},{"Del":{"text":" foreach my $plugin (@plugins) {","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:84"}},{"Del":{"text":" $prom->inc(\"notify_plugin_executions\", { channel => $channelName, plugin => ref $plugin });","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:624"}},{"Del":{"text":" eval {","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:99"}},{"Del":{"text":" my $startTime = [gettimeofday()];","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:671"}},{"Del":{"text":" $event->execute($db, $plugin);","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:142"}},{"Del":{"text":"","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:673"}},{"Del":{"text":" $prom->histogram_observe(\"notify_plugin_runtime\", tv_interval($startTime), { channel => $channelName, plugin => ref $plugin });","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:813"}},{"Del":{"text":" $prom->inc(\"notify_plugin_success\", { channel => $channelName, plugin => ref $plugin });","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:914"}},{"Del":{"text":" 1;","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:157"}},{"Del":{"text":" } or do {","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:175"}},{"Del":{"text":" $prom->inc(\"notify_plugin_error\", { channel => $channelName, plugin => ref $plugin });","pos":"I7DFJWL64QNNEZVTYQYJO2YI6NYKMWXXBV2TG6G3YAVID5ANPZ2AC:1014"}},{"Del":{"text":" print STDERR \"error running $event->{'channel_name'} hooks: $@\\n\";","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:254"}},{"Del":{"text":" }","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:264"}},{"Del":{"text":" }","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:270"}},{"Del":{"text":"}","pos":"FN3QFV6VB2BPYLKNYBUCV7HTSXCLKKLBD43TSEQUZNNAJVQACDZQC:272"}}]}},{"Replacement":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":92,"ins":{"up_context":[{"change":5,"pos":1460}],"down_context":[{"change":5,"pos":2593}],"flag":"BLOCK","start":4186,"end":4303,"inode":{"change":5,"pos":2994}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1460},"to":{"change":5,"start":1460,"end":1555},"introduced_by":5}],"inode":{"change":5,"pos":2994}},"ins_contents":[{"Add":{"text":" my $event = Hydra::Event->new_event(\"build_finished\", $build->id);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4256"}},{"Add":{"text":" $task_dispatcher->dispatch_event($event);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4302"}}],"del_contents":[{"Del":{"text":"","pos":"T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC:1460"}},{"Del":{"text":" my $event = Hydra::Event::BuildFinished->new($build->id);","pos":"T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC:1522"}},{"Del":{"text":" runPluginsForEvent($event);","pos":"T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC:1554"}}]}},{"Edit":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":95,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":2595},"to":{"change":5,"start":2595,"end":2596},"introduced_by":5}],"inode":{"change":5,"pos":2994}}},"contents":[{"Del":{"text":"","pos":"32KJOERMPFWZZZCIN6TGGVX72GMAJT6VCCIP7S65EHNF3KM42KWAC:2595"}}]}},{"Replacement":{"inode":{"change":5,"pos":2994},"path":"src/script/hydra-notify","line":115,"ins":{"up_context":[{"change":2,"pos":86}],"down_context":[{"change":5,"pos":1682}],"flag":"BLOCK","start":4304,"end":4358,"inode":{"change":5,"pos":2994}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":86},"to":{"change":5,"start":1642,"end":1682},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1642},"to":{"change":5,"start":1642,"end":1682},"introduced_by":5}],"inode":{"change":5,"pos":2994}},"ins_contents":[{"Add":{"text":" $task_dispatcher->dispatch_event($event);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4357"}}],"del_contents":[{"Del":{"text":" runPluginsForEvent($event);","pos":"T3OHZDYPABJBSN2G2BMQ47RL5PI5WVMAYQJVPT6TCPEFVGRLPEFQC:1681"}}]}},{"FileAdd":{"meta":{"basename":"TaskDispatcher.t","metadata":0},"context":[{"change":21,"pos":697}],"contents":[{"Add":{"text":"use strict;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4372"}},{"Add":{"text":"use warnings;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4386"}},{"Add":{"text":"use Setup;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4397"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4398"}},{"Add":{"text":"use Hydra::TaskDispatcher;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4425"}},{"Add":{"text":"use Prometheus::Tiny::Shared;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4455"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4456"}},{"Add":{"text":"use Test2::V0;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4471"}},{"Add":{"text":"use Test2::Tools::Mock qw(mock_obj);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4508"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4509"}},{"Add":{"text":"my $db = \"bogus db\";","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4530"}},{"Add":{"text":"my $prometheus = Prometheus::Tiny::Shared->new;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4579"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4580"}},{"Add":{"text":"sub make_noop_plugin {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4603"}},{"Add":{"text":" my ($name) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4624"}},{"Add":{"text":" my $plugin = {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4643"}},{"Add":{"text":" \"name\" => $name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4668"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4675"}},{"Add":{"text":" my $mock_plugin = mock_obj $plugin => ();","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4721"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4722"}},{"Add":{"text":" return $mock_plugin;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4747"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4749"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4750"}},{"Add":{"text":"sub make_fake_event {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4772"}},{"Add":{"text":" my ($channel_name) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4801"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4802"}},{"Add":{"text":" my $event = {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4820"}},{"Add":{"text":" channel_name => $channel_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4859"}},{"Add":{"text":" called_with => [],","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4886"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4893"}},{"Add":{"text":" my $mock_event = mock_obj $event => (","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4935"}},{"Add":{"text":" add => [","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4952"}},{"Add":{"text":" \"execute\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:4983"}},{"Add":{"text":" my ($self, $db, $plugin) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5030"}},{"Add":{"text":" push @{$self->{\"called_with\"}}, $plugin;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5087"}},{"Add":{"text":" }","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5101"}},{"Add":{"text":" ]","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5111"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5118"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5119"}},{"Add":{"text":" return $mock_event;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5143"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5145"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5146"}},{"Add":{"text":"sub make_failing_event {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5171"}},{"Add":{"text":" my ($channel_name) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5200"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5201"}},{"Add":{"text":" my $event = {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5219"}},{"Add":{"text":" channel_name => $channel_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5258"}},{"Add":{"text":" called_with => [],","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5285"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5292"}},{"Add":{"text":" my $mock_event = mock_obj $event => (","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5334"}},{"Add":{"text":" add => [","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5351"}},{"Add":{"text":" \"execute\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5382"}},{"Add":{"text":" my ($self, $db, $plugin) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5429"}},{"Add":{"text":" push @{$self->{\"called_with\"}}, $plugin;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5486"}},{"Add":{"text":" die \"Failing plugin.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5524"}},{"Add":{"text":" }","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5538"}},{"Add":{"text":" ]","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5548"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5555"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5556"}},{"Add":{"text":" return $mock_event;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5580"}},{"Add":{"text":"}","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5582"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5583"}},{"Add":{"text":"subtest \"dispatch_event\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5617"}},{"Add":{"text":" subtest \"every plugin gets called once, even if it fails all of them.\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5701"}},{"Add":{"text":" my @plugins = [make_noop_plugin(\"bogus-1\"), make_noop_plugin(\"bogus-2\")];","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5783"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5784"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, @plugins);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5865"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5866"}},{"Add":{"text":" my $event = make_failing_event(\"bogus-channel\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5923"}},{"Add":{"text":" $dispatcher->dispatch_event($event);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5968"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:5969"}},{"Add":{"text":" is(@{$event->{\"called_with\"}}, 2, \"Both plugins should be called\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6045"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6046"}},{"Add":{"text":" my @expected_names = [ \"bogus-1\", \"bogus-2\" ];","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6101"}},{"Add":{"text":" my @actual_names = sort([","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6135"}},{"Add":{"text":" $event->{\"called_with\"}[0]->name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6185"}},{"Add":{"text":" $event->{\"called_with\"}[1]->name","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6234"}},{"Add":{"text":" ]);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6246"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6247"}},{"Add":{"text":" is(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6259"}},{"Add":{"text":" @actual_names,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6286"}},{"Add":{"text":" @expected_names,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6315"}},{"Add":{"text":" \"Both plugins should be executed, but not in any particular order.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6395"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6406"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6413"}},{"Add":{"text":"};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6416"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6417"}},{"Add":{"text":"subtest \"dispatch_task\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6450"}},{"Add":{"text":" subtest \"every plugin gets called once\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6503"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6559"}},{"Add":{"text":" my @plugins = [$bogus_plugin, make_noop_plugin(\"bogus-2\")];","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6627"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6628"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, @plugins);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6709"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6710"}},{"Add":{"text":" my $event = make_fake_event(\"bogus-channel\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6764"}},{"Add":{"text":" my $task = Hydra::Task->new($event, ref $bogus_plugin);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6828"}},{"Add":{"text":" is($dispatcher->dispatch_task($task), 1, \"Calling dispatch_task returns truthy.\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6919"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6920"}},{"Add":{"text":" is(@{$event->{\"called_with\"}}, 1, \"Just one plugin should be called\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:6999"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7000"}},{"Add":{"text":" is(","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7012"}},{"Add":{"text":" $event->{\"called_with\"}[0]->name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7058"}},{"Add":{"text":" \"bogus-1\",","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7081"}},{"Add":{"text":" \"Just bogus-1 should be executed.\"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7128"}},{"Add":{"text":" );","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7139"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7146"}},{"Add":{"text":" subtest \"a task with an invalid plugin is not fatal\" => sub {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7212"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7268"}},{"Add":{"text":" my @plugins = [$bogus_plugin, make_noop_plugin(\"bogus-2\")];","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7336"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7337"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, @plugins);","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7418"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7419"}},{"Add":{"text":" my $event = make_fake_event(\"bogus-channel\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7473"}},{"Add":{"text":" my $task = Hydra::Task->new($event, \"this-plugin-does-not-exist\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7548"}},{"Add":{"text":" is($dispatcher->dispatch_task($task), 0, \"Calling dispatch_task returns falsey.\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7639"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7640"}},{"Add":{"text":" is(@{$event->{\"called_with\"}}, 0, \"No plugins are called\");","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7708"}},{"Add":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7715"}},{"Add":{"text":"};","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7718"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7719"}},{"Add":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7720"}},{"Add":{"text":"done_testing;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:7734"}}]}}],"owner":"grahamc","repo":"hydra","token":"bz1bvgsestJoZuO52wGqxRmIjmMQ4ME08lVqVORD53c=","login":null}

…

Dependencies

Change contents

Review