summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorTobi Oetiker <tobi@oetiker.ch>2009-01-05 08:52:50 +0100
committerTobi Oetiker <tobi@oetiker.ch>2009-01-05 08:52:50 +0100
commit64ad4077fc99a8476a27ad61c243db1077300286 (patch)
tree754d7a8d186805da4d5612cc94702638358cf57e
parent2a08e0d8ca5f3e2f64ca2771e20764a953515d2f (diff)
downloadsmokeping-64ad4077fc99a8476a27ad61c243db1077300286.tar.gz
smokeping-64ad4077fc99a8476a27ad61c243db1077300286.tar.xz
minor qooxdoo updates
-rw-r--r--qooxdoo/source/perl/Qooxdoo/JSONRPC.pm14
-rw-r--r--qooxdoo/source/perl/Qooxdoo/Services/Tr.pm104
2 files changed, 112 insertions, 6 deletions
diff --git a/qooxdoo/source/perl/Qooxdoo/JSONRPC.pm b/qooxdoo/source/perl/Qooxdoo/JSONRPC.pm
index bf4541d..567250f 100644
--- a/qooxdoo/source/perl/Qooxdoo/JSONRPC.pm
+++ b/qooxdoo/source/perl/Qooxdoo/JSONRPC.pm
@@ -85,6 +85,8 @@ sub handle_request
my $error = new Qooxdoo::JSONRPC::error ($json);
+ $error->set_session($session);
+
my $script_transport_id = ScriptTransport_NotInUse;
#----------------------------------------------------------------------
@@ -251,7 +253,7 @@ sub handle_request
$@ = '';
$accessibility = eval $accessibility_method .
- '($method, $accessibility)';
+ '($method, $accessibility,$session)';
if ($@)
{
@@ -290,7 +292,7 @@ sub handle_request
$requestUriDomain .= ":" . $cgi->server_port
if $cgi->server_port != ($is_https ? 443 : 80);
- if ($cgi->referer !~ m|^(https?://[^/]*)|)
+ if ($cgi->referer and $cgi->referer !~ m|^(https?://[^/]*)|)
{
$error->set_error (JsonRpcError_PermissionDenied,
"Permission denied");
@@ -538,6 +540,14 @@ sub set_id
$self->{id} = $id;
}
+sub set_session
+{
+ my $self = shift;
+ my $session = shift;
+
+ $self->{session} = $session;
+}
+
sub set_script_transport_id
{
my $self = shift;
diff --git a/qooxdoo/source/perl/Qooxdoo/Services/Tr.pm b/qooxdoo/source/perl/Qooxdoo/Services/Tr.pm
index ddfa796..301e101 100644
--- a/qooxdoo/source/perl/Qooxdoo/Services/Tr.pm
+++ b/qooxdoo/source/perl/Qooxdoo/Services/Tr.pm
@@ -3,15 +3,89 @@ use strict;
use POSIX qw(setsid);
use Time::HiRes qw(usleep);
use Socket;
+
+my $variant = 'butskoy';
+my $config = {
+ # Modern traceroute for Linux, version 2.0.9, Nov 19 2007
+ # Copyright (c) 2006 Dmitry Butskoy, License: GPL
+ butskoy => [
+ -q => {
+ arg => 1,
+ type => 'static',
+ },
+ 0 => {
+ arg => 'HOST',
+ type => 'intern',
+ },
+ 1 => {
+ label => 'Packetlength',
+ type => 'spinner',
+ min => 0,
+ max => 1024,
+ def => 53,
+ },
+ -M => {
+ label => 'Traceroute Method',
+ type => 'select',
+ pick => [
+ default => 'Classic UDP',
+ icmp => 'ICMP ECHO',
+ tcp => 'TCP Syn',
+ udp => 'UDP to port 53',
+ udplite => 'UDPLITE Datagram',
+ ],
+ default => 'icmp',
+ },
+ -F => {
+ label => 'Do not Fragment',
+ type => 'boolean',
+ default => 0,
+ },
+ ],
+ # Version 1.4a12
+ lbl => [
+ -q => {
+ arg => 1,
+ type => 'static',
+ },
+ 0 => {
+ arg => 'HOST',
+ type => 'intern',
+ },
+ 1 => {
+ label => 'Packetlength',
+ type => 'spinner',
+ min => 0,
+ max => 1024,
+ def => 53,
+ },
+ -I => {
+ label => 'Use ICMP ECHO',
+ widget => 'boolean',
+ default => 1,
+ }
+ ]
+};
+
sub GetAccessibility {
- return "public";
+ my $method = shift;
+ my $access = shift;
+ my $session = shift;
+# if ($method eq 'auth' or $session->param('authenticated') eq 'yes'){
+ return 'public';
+# }
+# else {
+# return 'fail';
+# }
}
sub launch {
my $error = shift;
- my $rounds = shift;
- my $delay = shift;
my $host = shift;
+ my $cfg = shift;
+ my $delay = $cfg->{delay} || 1;
+ my $rounds = $cfg->{rounds} || 1;
+
defined(my $pid = fork) or do { $error->set_error(101,"Can't fork: $!");return $error};
if ($pid){
open my $x, ">/tmp/tr_session.$pid" or do {
@@ -31,7 +105,7 @@ sub launch {
open STDERR, '>&STDOUT' or die "Can't dup stdout: $!";
for (my $i = 0; $i<$rounds;$i++){
my $start = time;
- system "traceroute","-I","-q","1",$host;
+ system "traceroute",@{$config->{$variant}{arguments}},$host;
my $wait = $delay - (time - $start);
if ($wait > 0 and $i+1< $rounds){
print "SLEEP $wait\n";
@@ -154,5 +228,27 @@ sub method_run_tr
}
}
+sub method_auth {
+ my $error = shift;
+ my $user = shift;
+ my $password = shift;
+ my $session = $error->{session};
+ if ($user eq 'tobi' and $password eq 'robi'){
+ $session->param('authenticated','yes');
+ }
+}
+
+sub method_get_config {
+ my $error = shift;
+ my @list;
+ for (my $i=0;defined $config->{$variant}[$i]; $i+=2){
+ next if not defined $config->{$variant}[$i+1]{label};
+ push @list, $config->{$variant}[$i],$config->{$variant}[$i+1];
+ };
+ return \@list;
+}
+
+
+
1;