--- /dev/null
+#!/usr/bin/perl -w
+use Cwd;
+
+if ($ENV{'SERVER_SOFTWARE'} =~ /HTTP-?i/i) {
+ &htsponse(200, "OK");
+ }
+print "Content-type: text/html\n\n";
+
+
+
+my $pwd = &Cwd::cwd();
+
+my $file = "pwr.conf";
+if ($ENV{'SERVER_SOFTWARE'} =~ /HTTPi/i) {
+ $file = "htdocs/".$file;
+ }
+
+
+open(LESEN,$file)
+ or die "Fehler beim oeffnen von : $!\n";
+
+while(defined(my $i = <LESEN>)) {
+
+ if( $i =~ /^PWRSPLY:([^:]+):([^:]+):([^:]+):([^:]+):([^:]+)/g ) {
+ my @arr = split(':',$i);
+ shift @arr;
+ my $ser_dev = shift @arr;
+ my $speed = shift @arr;
+ my $dev_id = shift @arr;
+ my $type = shift @arr;
+ my $channels = shift @arr;
+ my $names = join(':',@arr);
+
+if($type eq "PSP") {
+print <<EOF;
+<p>
+<iframe name="inlineframe" src="pwr_psp.htm?device=$ser_dev&id=$dev_id&speed=$speed&type=$type" frameborder="0" scrolling="auto" width="800" height="340" style="float:left" ></iframe>
+</p>
+EOF
+}
+
+if($type =~ /HMP/ or $type =~ /HMC/ or $type =~ /PST/) {
+print <<EOF;
+<p>
+<iframe name="inlineframe" src="pwr_hmp.htm?device=$ser_dev&id=$dev_id&type=$type&channels=$channels&speed=$speed&names=$names" frameborder="0" scrolling="auto" width="800" height="340" style="float:left" ></iframe>
+</p>
+EOF
+}
+
+if($type =~ /PWRSW/) {
+print <<EOF;
+<p>
+<iframe name="inlineframe" src="pwr_switch.htm?device=$ser_dev&id=$dev_id&type=$type&channels=$channels&speed=$speed&names=$names" frameborder="0" scrolling="auto" width="800" height="340" style="float:left" ></iframe>
+</p>
+EOF
+}
+
+
+ }
+}
+
+
+
+#print "CWD: ".$pwd."<br>(for debug)\n";
+
+
+return true;
--- /dev/null
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
+
+ <html>
+ <head>
+ <link href="styles.css" rel="stylesheet" type="text/css"/>
+<script src="scripts.js" type="text/javascript"></script>
+ <title>Access all POWER!</title>
+
+ </head>
+
+ <body>
+<h2>Basic power supply control</h2>
+<p id="content">
+Platzhalter
+</p>
+
+<script language="javascript">
+
+function update(data) {
+ if(!document.getElementById("content").innerHTML) return;
+ document.getElementById("content").innerHTML = data;
+ }
+
+getdata('build_index.pl',update);
+</script>
+
+<p id="conf_area" style="clear:both">
+Note that you need to have libdevice-serialport-perl or perl-Device-SerialPort<br>
+installed and that the /dev/ttyUSBn need to be accessible by normal users.<br>
+Feel free to alter the config file to accommodate your needs!<br>
+Please don't use the # character to comment out lines<br>
+Tested with HMC8043, HMP4040, HMP4030, PSP405, PSP2010, PST3202, PWRSW
+<br><pre>
+//PWRSPLY:/path/to/device:Speed:Name:Type:Channels
+//PWRSPLY:IP0.0.0.0:Port:Name:Type:Channels
+PWRSPLY:/dev/ttyUSB0:9600:PST3202:PST:3
+PWRSPLY:/dev/ttyUSB0:115200:HMP4030:HMP:3
+PWRSPLY:IP192.168.0.56:5050:HMP4040:HMP:4
+PWRSPLY:/dev/FTDI_FT232R_USB_UART_AH02HFZW:2400:PSP2010:PSP:1
+PWRSPLY:/dev/FTDI_FT232R_USB_UART_A900LJXB:0:Desk:PWRSW:4</pre>
+<br>
+<TEXTAREA NAME="Address" id="config_field" ROWS=10 COLS=100 >
+Platzhalter
+</TEXTAREA>
+<br>
+<input type="button" onClick="save_conf()" value="save">
+<input type="button" onClick="reload_page()" value="reload page">
+
+<script language="javascript">
+
+function save_conf() {
+ var field_content = document.getElementById("config_field").value;
+ field_content = field_content.replace(/\n\r?/g, '&');
+ //alert(field_content);
+ getdata('save_conf.pl?'+field_content,alert);
+
+ //debug//document.getElementById("content").innerHTML = field_content;
+ }
+
+function reload_page() {
+ window.location.reload();
+}
+
+function write_field(data) {
+ if(!document.getElementById("config_field").value) return;
+ document.getElementById("config_field").value = data;
+ }
+
+
+getdata('pwr.conf',write_field);
+</script>
+
+</p>
+
+
+ </body>
+
+ </html>
+
+
+
+
+
+
+
+
--- /dev/null
+//PWRSPLY:/path/to/device:speed:Name:Type:Channels
+//type can be HMP, HMC, PSP, PST
+
+//PWRSPLY:/dev/ttyUSB0:9600:PST3202:PST:3
+//PWRSPLY:/dev/ttyUSB0:115200:HMP4030:HMP:3
+//PWRSPLY:IP192.168.0.56:5050:HMP4040:HMP:4
+PWRSPLY:/dev/FTDI_FT232R_USB_UART_AH02HFZW:2400:PSP2010:PSP:1
+//PWRSPLY:/dev/FTDI_FT232R_USB_UART_A702HE33:2400:PSP405:PSP:1
+//PWRSPLY:IP192.168.0.56:5050:HMP4040 DiRich:HMP:4:LP1:LP2:LP3:DCDC
+PWRSPLY:/dev/FTDI_Xmatter_TTL_ALR1AJS:57600:Desk:PWRSW:6:TestAdrian:Pulser:::TrgDistr:ADC
+//PWRSPLY:SERpi@192.168.0.230/dev/FTDI_FT232R_USB_UART_AH02HFZW:2400:PSP2010:PSP:1
+//PWRSPLY:SERpi@192.168.0.230/dev/TRB3_Power48_00002:0:Rack48:PWRSW:4:Crate:::
+//PWRSPLY:/dev/HAMEG_HO732_VCP023842636:0:HMP4040:HMP:4
+//PWRSPLY:IP192.168.0.56:5050:HMP4040 DiRich:HMP:4:LP1:LP2:LP3:DCDC
+//PWRSPLY:/dev/TRB3_Power48_00002:0:Rack48:PWRSW:4:Desk:::
--- /dev/null
+#!/usr/bin/perl -w
+if ($ENV{'SERVER_SOFTWARE'} =~ /HTTP-?i/i) {
+ &htsponse(200, "OK");
+ }
+print "Content-type: text/html\n\n";
+
+
+use strict;
+use warnings;
+# use Device::SerialPort;
+use IO::Socket;
+use IO::Handle;
+use feature 'state';
+use URI::Escape;
+use Time::HiRes qw( usleep);
+use POSIX qw/floor ceil strftime/;
+use Fcntl;
+use Storable qw(lock_store lock_retrieve);
+
+my $envstring = $ENV{'QUERY_STRING'};
+$envstring =~ s/%20/ /g;
+
+
+my @new_command = split('&',$envstring);
+my $ser_dev = shift(@new_command);
+my $ser_type = shift(@new_command);
+my $ser_speed = shift(@new_command); #speed or port number
+
+if (!defined $ser_dev || !defined $ser_type || !defined $ser_speed) {
+ exit 0;
+ }
+
+
+my $port;
+my $isIP = 0;
+my $cnt = 0;
+my $isRemote = undef;
+
+# Load stored values
+my $file = $ser_dev;
+ $file =~ s/\W//g;
+ $file = "/dev/shm/pwrsup-".$file.".dump";
+my $db;
+if(-e $file && -r $file) {
+ $db = lock_retrieve($file);
+ }
+
+
+if($ser_dev =~ /^IP(.*)/) {
+ $ser_dev = $1;
+ $isIP = 1;
+ }
+# elsif($ser_dev =~ /^SER(.*)/) {
+# my $str = $1;
+# ($isRemote,$ser_dev) = split('/',$str,2);
+# $ser_dev = '/'.$ser_dev;
+# }
+else {
+ if ($ser_speed != 0){
+ my $command = "stty -F $ser_dev speed $ser_speed";
+ $command .= " -ixoff " if $ser_type eq 'PSP';
+ my $res = qx($command);
+ }
+ }
+
+# if(defined $isRemote) {
+# my $env = $ENV{'QUERY_STRING'};
+# $env =~ s/&/!/g;
+# my $cmd = "bash -c \"ssh $isRemote 'QUERY_STRING=".$env." perl'\" <htdocs/tools/pwr/pwr_remote.pl";
+# print qx($cmd);
+# }
+# else {
+ print HMP_serial() if (($ser_type eq "HMP" or $ser_type eq "HMC") && $isIP == 0) or $ser_type eq "PST";
+ print PWRSW_serial() if $ser_type eq "PWRSW";
+ print HMP_ethernet() if (($ser_type eq "HMP" or $ser_type eq "HMC") && $isIP == 1);
+ print PSP() if $ser_type eq 'PSP';
+# }
+
+
+
+
+
+
+
+
+
+sub PSP {
+ my $fh;
+ if(-e $ser_dev && -w $ser_dev) {
+ sysopen($fh, $ser_dev, O_RDWR|O_NDELAY) or die $!;
+ }
+ else { print "Device not found"; return;}
+
+ while ( my $command = shift(@new_command) ) {
+ $command = uri_unescape($command);
+# $port->write("$command\r");
+ getValue($fh,$command,$cnt++);
+ #print "i sent the command: $command";
+ #print "\n\nokay.\n";
+ usleep 1E5;
+ }
+
+
+ my %state_lookup = (
+ 0 => 'off',
+ 1 => 'on' );
+
+ my $a = getValue($fh,"L",$cnt++,1);
+ if ($a =~ m/V(\d\d\.\d\d)A(\d\.\d\d\d)W(\d\d\d\.\d)U(\d\d)I(\d\.\d\d)P(\d\d\d)F(\d\d\d\d\d\d)/) {
+ my $c_volt = $1;
+ my $c_cur = $2;
+ my $c_pwr = $3;
+ my $l_volt = $4;
+ my $l_cur = $5;
+ my $l_pwr = $6;
+ my $state_string = $7;
+ my $relais_state = $state_lookup{substr $state_string, 0,1};
+ printf("
+ <table>
+ <tr>
+ <td align=right>%2.2f<td align=left> V
+ <tr>
+ <td align=right>%1.3f<td align=left> A
+ <tr>
+ <td align=right>%3.1f<td align=left> W
+ <tr>
+ <tr>
+ <td align=right>voltage limit: %d<td align=left> V
+ <tr>
+ <td align=right>current limit: %1.2f<td align=left> A
+ <tr>
+ <td align=right>power limit: %d<td align=left> W
+ <tr>
+ <tr>
+ <td align=right>output relais:<td align=left> $relais_state </td>
+ </table>"
+ ,$c_volt,$c_cur,$c_pwr,$l_volt,$l_cur,$l_pwr);
+ }
+}
+
+sub PWRSW_serial {
+ print strftime("%H:%M:%S &", localtime());
+ my $fh;
+ if(-e $ser_dev && -w $ser_dev) {
+ sysopen($fh, $ser_dev, O_RDWR|O_NDELAY) or die $!;
+ }
+ else { print "Device not found"; return;}
+
+ while ( my $command = shift(@new_command) ) {
+ $command = uri_unescape($command);
+ my $x = getValue($fh,$command,$cnt++);
+ if ($command =~ /\?/) {
+ if ($x =~ /^\w[a-f0-9]{3}/) {print hex(substr($x,1,3)).'&';}
+ elsif ($x =~ /^\w[a-f0-9]{2}/) {print hex(substr($x,1,2)).'&';}
+# else {print '&';}
+ }
+ }
+ close $fh;
+ return;
+ }
+
+
+sub HMP_serial {
+ print strftime("%H:%M:%S &", localtime());
+ my $fh;
+ if(-e $ser_dev && -w $ser_dev) {
+ sysopen($fh, $ser_dev, O_RDWR|O_NDELAY) or die $!;
+ }
+ else { print "Device not found"; return;}
+
+ while ( my $command = shift(@new_command) ) {
+ $command = uri_unescape($command);
+ my $x = getValue($fh,$command,$cnt++);
+ $x =~ s/\&//;
+ print $x."&" if $command =~ /\?/;
+ usleep(40000) if $ser_type eq "PST";
+ }
+ close $fh;
+ return;
+ }
+
+
+
+sub HMP_ethernet {
+ print strftime("%H:%M:%S &", localtime());
+
+ my $port = IO::Socket::INET->new(PeerAddr => $ser_dev, PeerPort => $ser_speed, Proto => "tcp", Type => SOCK_STREAM, Timeout => 1)
+ or (print("Device not found") && return);
+
+ while ( my $command = shift(@new_command) ) {
+ $command = uri_unescape($command);
+ my $x = getValue($port,$command,$cnt++);
+ $x =~ s/\&//;
+ print $x."&" if $command =~ /\?/;
+ }
+ return;
+ }
+
+
+sub serial_rw {
+ my ($fh, $command,$forceread) = @_;
+ my $x = "";
+ if ($ser_type eq 'PSP') {$command .= "\r";} else {$command .= "\n";}
+ print $fh "$command";
+ if($ser_type eq 'PWRSW' || $forceread || $command =~ /\?/) {
+ for my $i (0..500) {
+ $x .= <$fh>;
+ if($x && ($x =~ /\n/ || $x =~ /\r/) ) {
+ chomp $x;
+ last;
+ }
+ usleep(1000);
+ }
+ }
+ return $x;
+ }
+
+
+sub getValue {
+ my ($fh,$cmd,$cnt,$forceread) = @_;
+ if (0 && defined $db->{$cmd.$cnt}{tim} && $db->{$cmd.$cnt}{tim} > time()-2) {
+ return $db->{$cmd.$cnt}{val};
+ }
+ else {
+ my $val = serial_rw($fh,$cmd,$forceread);
+ addDB($cmd.$cnt,$val);
+ return $val;
+ }
+ }
+
+
+sub addDB {
+ my ($cmd,$val) = @_;
+ $db->{$cmd}{val} = $val;
+ $db->{$cmd}{tim} = time();
+ }
+
+lock_store($db,$file);
+print "\n";
+
+exit 1;
+
+
+
+
--- /dev/null
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
+<link href="../styles.css" rel="stylesheet" type="text/css"/>
+<script src="../scripts.js" type="text/javascript"></script>
+<title>Power Supply Monitor and Access</title>
+</head>
+<body style="font-family: sans-serif;" >
+
+
+<h3 id="headline">Power Supply Access</h3>
+
+
+
+<form acion="">
+<table id="settings" class="smallboxes">
+<tr><th><th colspan=2 id="chan1">Chan 1<th colspan=2 id="chan2">Chan 2<th colspan=2 id="chan3">Chan 3<th colspan=2 id="chan4">Chan 4
+<tr class="sep"><td align="right">Voltage [V]
+ <td><input type="text" id="form_v1" name="voltage" value=""><td><input type="button" onClick="set_v(1)" value="set">
+ <td><input type="text" id="form_v2" name="voltage" value=""><td><input type="button" onClick="set_v(2)" value="set">
+ <td><input type="text" id="form_v3" name="voltage" value=""><td><input type="button" onClick="set_v(3)" value="set">
+ <td><input type="text" id="form_v4" name="voltage" value=""><td><input type="button" onClick="set_v(4)" value="set">
+
+<tr><td align="right">Actual[V/A]
+ <td> <input type="text" id="vol1" disabled> <td> <input type="text" id="cur1" disabled>
+ <td> <input type="text" id="vol2" disabled> <td> <input type="text" id="cur2" disabled>
+ <td> <input type="text" id="vol3" disabled> <td> <input type="text" id="cur3" disabled>
+ <td> <input type="text" id="vol4" disabled> <td> <input type="text" id="cur4" disabled>
+
+<tr><td align="right">Limits[V/A]
+ <td><input type="text" id="form_v_lim1" name="voltage_limit" onChange="set_v_lim(1)" value=""><td><input type="text" id="form_c_lim1" name="current_limit" onChange="set_c_lim(1)" value="">
+ <td><input type="text" id="form_v_lim2" name="voltage_limit" onChange="set_v_lim(2)" value=""><td><input type="text" id="form_c_lim2" name="current_limit" onChange="set_c_lim(2)" value="">
+ <td><input type="text" id="form_v_lim3" name="voltage_limit" onChange="set_v_lim(3)" value=""><td><input type="text" id="form_c_lim3" name="current_limit" onChange="set_c_lim(3)" value="">
+ <td><input type="text" id="form_v_lim4" name="voltage_limit" onChange="set_v_lim(4)" value=""><td><input type="text" id="form_c_lim4" name="current_limit" onChange="set_c_lim(4)" value="">
+
+<tr class="sep"><td>Output Relais
+ <td class="state"><input type="button" onClick="turn_on(1)" value="on"><td class="state"><input type="button" onClick="turn_off(1)" value="off">
+ <td class="state"><input type="button" onClick="turn_on(2)" value="on"><td class="state"><input type="button" onClick="turn_off(2)" value="off">
+ <td class="state"><input type="button" onClick="turn_on(3)" value="on"><td class="state"><input type="button" onClick="turn_off(3)" value="off">
+ <td class="state"><input type="button" onClick="turn_on(4)" value="on"><td class="state"><input type="button" onClick="turn_off(4)" value="off">
+<tr class="sep"><td id="master">Global Switch<td colspan=8><input type="button" onClick="globalOn()" value="ON">
+<input type="button" onClick="globalOff()" value="OFF">
+<tr class="sep"><td colspan=5><input type="checkbox" value="1" id="showreadings">Enable read-back of values<td colspan=4>
+Read settings<input type="button" onClick="readSettings()" value="Go">
+<tr><td colspan=9 id="info">
+</table>
+</form>
+
+
+<script language="javascript">
+var updaterate = 2000;
+var updateTask;
+var new_commands = new Array();
+var ser_dev = getParameterByName("device");
+var dev_id = getParameterByName("id");
+var type = getParameterByName("type");
+var channels = getParameterByName("channels");
+var speed = getParameterByName("speed");
+var names = getParameterByName("names");
+var readSettingsRequest = 1;
+var forceShowReadings = 1;
+var Vnames = names.split(':');
+
+if (channels<2) {
+ document.getElementById("chan2").style.color = "#eee";
+ }
+if (channels<3) {
+ document.getElementById("chan3").style.color = "#eee";
+ }
+if (channels<4) {
+ document.getElementById("chan4").style.color = "#eee";
+ }
+
+function set_v(chan) {
+ if (chan > channels) return;
+ var value = parseFloat(document.getElementById("form_v"+chan).value);
+ var command;
+ if(type=="HMP" || type=="HMC") command = "INST OUT"+chan+"&VOLT "+value.toFixed(3);
+ if(type=="PST") command = ":CHAN"+chan+":VOLT "+value.toFixed(3);
+ new_commands.push(command);
+ forceShowReadings = 1;
+}
+
+function set_v_lim(chan) {
+ if (chan > channels) return;
+ var value = parseInt(document.getElementById("form_v_lim"+chan).value);
+ var command;
+ if(type=="HMP") command = "INST OUT"+chan+"&VOLT:PROT "+value.toFixed(3);
+ if(type=="HMC") command = "INST OUT"+chan+"&VOLT:PROT ON&VOLT:PROT:LEV "+value.toFixed(3);
+ if(type=="PST") command = ":CHAN"+chan+":PROT:VOLT "+value.toFixed(3);
+ new_commands.push(command);
+ forceShowReadings = 1;
+}
+
+function set_c_lim(chan) {
+ if (chan > channels) return;
+ var value = parseFloat(document.getElementById("form_c_lim"+chan).value);
+ var command;
+ if(type=="HMP" || type=="HMC") command = "INST OUT"+chan+"&CURR "+value.toFixed(3);
+ if(type=="PST") command = ":CHAN"+chan+":PROT:CURR "+value.toFixed(3);
+ new_commands.push(command);
+ forceShowReadings = 1;
+}
+
+function turn_on(chan) {
+ if (chan > channels) return;
+ if(type=="HMP") new_commands.push("INST OUT"+chan+"&OUTP:SEL ON");
+ if(type=="HMC") new_commands.push("INST OUT"+chan+"&OUTP:CHAN ON");
+ if(type=="PST") new_commands.push(":OUTP:STAT ON");
+ forceShowReadings = 1;
+}
+
+function turn_off(chan) {
+ if (chan > channels) return;
+ if(type=="HMP") new_commands.push("INST OUT"+chan+"&OUTP:SEL OFF");
+ if(type=="HMC") new_commands.push("INST OUT"+chan+"&OUTP:CHAN OFF");
+ if(type=="PST") new_commands.push(":OUTP:STAT OFF");
+ forceShowReadings = 1;
+}
+
+function globalOn() {
+ if(type=="HMP") new_commands.push("OUTP:GEN ON");
+ if(type=="HMC") new_commands.push("OUTP:MAST ON");
+ forceShowReadings = 1;
+}
+
+function globalOff() {
+ if(type=="HMP") new_commands.push("OUTP:GEN OFF");
+ if(type=="HMC") new_commands.push("OUTP:MAST OFF");
+ forceShowReadings = 1;
+}
+
+function update(data) {
+ updateTask = setTimeout("communication()",updaterate);
+ }
+
+
+function updatereads(data) {
+ var e = data.split("&");
+ document.getElementById("info").innerHTML = e.shift();
+ document.getElementById("master").style.background=(e.shift()=='1')?"limegreen":"#C00";
+ for(i=0;i<channels;i++) {
+ document.getElementById("vol"+(i+1)).value=(+e[i*3+0]).toFixed(3);
+ document.getElementById("cur"+(i+1)).value=(+e[i*3+1]).toFixed(3);
+ document.getElementById("chan"+(i+1)).style.background=(e[i*3+2]=="1")?"limegreen":"#C00";
+ }
+ updateTask = setTimeout("communication()",updaterate);
+ }
+
+function updatesettings(data) {
+ var e = data.split("&");
+// var id = e.shift();
+// e.shift();
+ document.getElementById("info").innerHTML = e.shift()+" Device Info: "+e.shift();
+ document.getElementById("master").style.background=(e.shift()=='1')?"limegreen":"#C00";
+ for(i=0;i<channels;i++) {
+ document.getElementById("form_v"+(i+1)).value=(+e[i*3+0]).toFixed(3);
+ document.getElementById("form_c_lim"+(i+1)).value=(+e[i*3+1]).toFixed(3);
+ document.getElementById("form_v_lim"+(i+1)).value=(+e[i*3+2]).toFixed(3);
+ }
+ updateTask = setTimeout("communication()",updaterate);
+ }
+
+function communication() {
+ cmds = new_commands.join('&');
+ if (cmds != "") {
+ getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+'&'+cmds,update);
+ }
+ else if(readSettingsRequest == 1) {
+ readSettingsRequest = 0;
+ if(type=="HMP" || type=="HMC") {
+ cmds = "&SYST:MIX&%2AIDN%3F";
+ if(type=="HMP") cmds += '&OUTP:GEN%3F';
+ if(type=="HMC") cmds += '&OUTP:MAST%3F';
+ for(i=1;i<=channels;i++){
+ if(type=="HMP") cmds +="&INST OUT"+i+"&SOUR:VOLT%3F&SOUR:CURR%3F&VOLT:PROT%3F";
+ if(type=="HMC") cmds +="&INST OUT"+i+"&SOUR:VOLT%3F&SOUR:CURR%3F&VOLT:PROT:LEV%3F";
+ }
+ }
+ if(type=="PST") {
+ cmds="&%2AIDN%3F";
+ for(i=1;i<=channels;i++)
+ cmds +="&:CHAN"+i+":VOLT%3F&:CHAN"+i+":CURR%3F&:CHAN"+i+":PROT:VOLT%3F";
+ }
+ getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+cmds,updatesettings);
+ }
+ else if(document.getElementById("showreadings").checked || forceShowReadings) {
+ forceShowReadings = 0;
+ cmds = "";
+ if(type=="HMP") cmds += '&OUTP:GEN%3F';
+ if(type=="HMC") cmds += '&OUTP:MAST%3F';
+ if(type=="HMP" || type=="HMC") {
+ for(i=1;i<=channels;i++)
+ cmds +="&INST OUT"+i+"&MEAS:VOLT%3F&MEAS:CURR%3F&OUTP:STAT%3F";
+ }
+ if(type=="PST") {
+ for(i=1;i<=channels;i++)
+ cmds +="&:CHAN"+i+":MEAS:VOLT%3F&:CHAN"+i+":MEAS:CURR%3F&OUTP:STAT%3F";
+ }
+ getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+cmds,updatereads);
+ }
+ else {
+ updateTask = setTimeout("communication()",updaterate);
+ }
+ new_commands = new Array();
+}
+
+
+
+function getParameterByName(name)
+{
+ name = name.replace(/[\[]/, "\\\[").replace(/[\]]/, "\\\]");
+ var regexS = "[\\?&]" + name + "=([^&#]*)";
+ var regex = new RegExp(regexS);
+ var results = regex.exec(window.location.search);
+ if(results == null)
+ return "";
+ else
+ return decodeURIComponent(results[1].replace(/\+/g, " "));
+}
+
+
+function readSettings() {
+ readSettingsRequest = 1;
+ }
+
+updateTask = setTimeout("update()",updaterate);
+document.getElementById("headline").innerHTML = "Power Supply "+'<b>'+dev_id+'</b>'+" [connected to "+'<b>'+ser_dev+'</b>'+"]" ;
+
+for(i=1;i<=channels;i++) {
+ if(typeof Vnames[i-1] !== 'undefined')
+ document.getElementById("chan"+i).innerHTML = i+' - '+Vnames[i-1];
+ }
+
+</script>
+</body></html>
--- /dev/null
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
+<link href="../styles.css" rel="stylesheet" type="text/css"/>
+<script src="../scripts.js" type="text/javascript"></script>
+<title>Power Supply Monitor and Access</title>
+</head>
+<body style="font-family: sans-serif;" >
+
+
+<p style="bold" id="headline">Power Supply Access</p>
+
+
+<table align=center id="layout" style="
+ border-width: 1px;
+ border-style: solid;
+ border-color: black;
+">
+
+<tr>
+<th align="left">Readings:</th><TD rowspan=2 style="border-left: 1px solid black; padding: 5px;"> <th align="left">Settings:</th>
+</tr>
+
+<tr>
+<td>
+
+<table id="readings" width="300" >
+</table>
+</td>
+
+
+
+
+<td>
+
+<form acion="">
+<table id="settings" >
+<tr>
+<td align="right">Voltage [V]<td><input type="text" id="form_v" name="voltage" value="">
+<td><input type="button" onClick="set_v()" value="set">
+<tr><td colspan=3><hr />
+<tr>
+<td align="right">Voltage limit [V]<td><input type="text" id="form_v_lim" name="voltage_limit" value="">
+<td><input type="button" onClick="set_v_lim()" value="set">
+<tr><td align="right">Current limit [A]<td><input type="text" id="form_c_lim" name="current_limit" value="">
+<td><input type="button" onClick="set_c_lim()" value="set">
+<tr><td align="right">Power limit [W]<td><input type="text" id="form_p_lim" name="power_limit" value="">
+<td><input type="button" onClick="set_p_lim()" value="set">
+<tr><td colspan=2>Save settings to EEPROM<td><input type="button" onClick="save_to_eep()" value="save">
+<tr><td colspan=3><hr />
+
+<tr>
+<tr><td colspan=2>Output Relais<td><input type="button" onClick="turn_on()" value="on"><input type="button" onClick="turn_off()" value="off">
+<tr><td colspan=3><hr />
+<tr><td colspan=3><input type="checkbox" value="1" id="showreadings">Enable read-back of values.
+</table>
+</form>
+
+</td>
+</tr>
+</table>
+
+
+
+
+<script language="javascript">
+var updaterate = 1000;
+var updateTask;
+var new_commands = new Array();
+var ser_dev = getParameterByName("device");
+var dev_id = getParameterByName("id");
+var type = getParameterByName("type");
+var speed = getParameterByName("speed");
+
+function set_v() {
+ var value = parseFloat(document.getElementById("form_v").value);
+ var command = "SV "+padZeros(value.toFixed(2),5);
+ new_commands.push(command);
+}
+
+function set_v_lim() {
+ var value = parseInt(document.getElementById("form_v_lim").value);
+ var command = "SU "+padZeros(value,2);
+ new_commands.push(command);
+}
+
+function set_c_lim() {
+ var value = parseFloat(document.getElementById("form_c_lim").value);
+ var command = "SI "+padZeros(value.toFixed(2),4);
+ new_commands.push(command);
+}
+
+function set_p_lim() {
+ var value = parseInt(document.getElementById("form_p_lim").value);
+ var command = "SP "+padZeros(value,3);
+ new_commands.push(command);
+}
+
+function turn_on() {
+ if(type=="PSP") new_commands.push("KOE");
+}
+
+function turn_off() {
+ if(type=="PSP") new_commands.push("KOD");
+}
+
+function save_to_eep() {
+ if(type=="PSP") new_commands.push("EEP");
+}
+
+function update(data) {
+ if(!document.getElementById("readings").innerHTML) return;
+ document.getElementById("readings").innerHTML = data;
+updateTask = setInterval("communication()",updaterate);
+ }
+
+
+function communication() {
+// getdata('pwr.pl?/dev/ttyUSB0-KOD',update);
+ cmds = new_commands.join('&');
+ if (cmds != "" || document.getElementById("showreadings").checked) {
+ clearInterval(updateTask);
+ getdata('pwr.pl?'+ser_dev+'&'+type+"&"+speed+'&'+cmds,update);
+ }
+ new_commands = new Array();
+}
+
+
+function padZeros(theNumber, max) {
+ var numStr = String(theNumber);
+
+ while ( numStr.length < max) {
+ numStr = '0' + numStr;
+ }
+
+ return numStr;
+}
+
+
+function getParameterByName(name)
+{
+ name = name.replace(/[\[]/, "\\\[").replace(/[\]]/, "\\\]");
+ var regexS = "[\\?&]" + name + "=([^&#]*)";
+ var regex = new RegExp(regexS);
+ var results = regex.exec(window.location.search);
+ if(results == null)
+ return "";
+ else
+ return decodeURIComponent(results[1].replace(/\+/g, " "));
+}
+
+
+
+
+updateTask = setInterval("communication()",updaterate);
+document.getElementById("headline").innerHTML = "Power Supply "+'<b>'+dev_id+'</b>'+" [connected to "+'<b>'+ser_dev+'</b>'+"]" ;
+
+
+</script>
+</body></html>
--- /dev/null
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
+<link href="../styles.css" rel="stylesheet" type="text/css"/>
+<script src="../scripts.js" type="text/javascript"></script>
+<title>Power Supply Monitor and Access</title>
+</head>
+<body style="font-family: sans-serif;" class="powerswitch">
+
+
+<h3 id="headline"></h3>
+
+
+
+<form acion="">
+<table id="settings" class="smallboxes">
+<tr><th colspan='2'>Channel<th colspan='2'>Status<th>Current<th>Average<th>Limit
+
+<tfoot>
+<tr class="sep">
+<td colspan=5><input type="checkbox" checked="1" id="showreadings">Enable read-back of values
+<td colspan=4 id="date">
+<tr><td colspan=9 id="info">
+</tfoot>
+<tbody id="display"></tbody>
+</table>
+</form>
+
+
+<script language="javascript">
+var updaterate = 2000;
+var updateTask;
+var new_commands = new Array();
+var ser_dev = getParameterByName("device");
+var dev_id = getParameterByName("id");
+var type = getParameterByName("type");
+var channels = getParameterByName("channels");
+var speed = getParameterByName("speed");
+var names = getParameterByName("names");
+var readSettingsRequest = 1;
+var forceUpdate = 1;
+
+var Vstatus = new Array();
+var Vcurrent = new Array();
+var Vaverage = new Array();
+var Vlimit = new Array();
+var Vdate = "x";
+var Vnames = names.split(':');
+
+function maketable() {
+ out = "";
+ for(i=0;i<channels;i++) {
+ out += "<tr><td>"+i+"<td>";
+ if(typeof Vnames[i] !== 'undefined') out += Vnames[i];
+ if (Vstatus[i] == 1) {
+ out += '<td id="status'+i+'" class="status" style="background:limegreen"> ';
+ }
+ else {
+ out += '<td id="status'+i+'" class="status" style="background:#C00"> ';
+ }
+ out += '<td><input type="button" onClick="turn_on('+i+')" value="on">\
+ <input type="button" onClick="turn_off('+i+')" value="off"> ';
+ out += '<td id="curr'+i+'">'+Vcurrent[i]+'<td id="avg'+i+'">'+Vaverage[i]+
+ '<td><input type="text" id="limit'+i+'" name="limit'+i+'" onChange="set_lim('+i+')" value="'+Vlimit[i]+'">'+"\n";
+ }
+ document.getElementById("display").innerHTML = out;
+ document.getElementById("date").innerHTML = Vdate;
+ }
+
+
+function set_lim(chan) {
+ if (chan > channels) return;
+ myi = chan.toString(16);
+ if (chan<16) {myi = '0'+myi;}
+ myv = (document.getElementById('limit'+chan).value*1.).toString(16);
+ if (myv<16) {myv = '00'+myv;}
+ if (myv<256) {myv = '0'+myv;}
+ new_commands.push('L'+myi+myv);
+}
+
+function turn_on(chan) {
+ if (chan > channels) return;
+ myi = chan.toString(16);
+ if (chan<10) {myi = '0'+myi;}
+ new_commands.push('S'+myi+'1');
+}
+
+function turn_off(chan) {
+ if (chan > channels) return;
+ myi = chan.toString(16);
+ if (chan<10) {myi = '0'+myi;}
+ new_commands.push('S'+myi+'0');
+}
+
+function communication() {
+ if (document.getElementById("showreadings").checked == 1 || new_commands.length != 0) {
+ for(i=0;i<channels;i++) {
+ myi = i.toString(16);
+ if (i<10) {myi = '0'+myi;}
+ new_commands.push('S'+myi+'%3F');
+ new_commands.push('C'+myi+'%3F');
+ new_commands.push('D'+myi+'%3F');
+ new_commands.push('L'+myi+'%3F');
+ }
+ }
+
+ cmds = new_commands.join('&');
+ if (cmds != "") {
+ getdata('pwr.pl?'+ser_dev+'&PWRSW&'+speed+'&'+cmds,update);
+ }
+ else {
+ updateTask = setTimeout("communication()",updaterate);
+ }
+ new_commands = new Array();
+}
+
+function update(data) {
+ var e = data.split("&");
+ Vdate = e.shift();
+ for(i=0;i<channels;i++) {
+ Vstatus[i] = e.shift();
+ Vcurrent[i] = e.shift();
+ Vaverage[i] = e.shift();
+ Vlimit[i] = e.shift();
+ }
+ document.getElementById("date").innerHTML = Vdate;
+ for(i=0;i<channels;i++) {
+ document.getElementById("status"+i).style.background=(Vstatus[i]=="1")?"limegreen":"#C00";
+ document.getElementById("curr"+i).innerHTML = Vcurrent[i];
+ document.getElementById("avg"+i).innerHTML = Vaverage[i];
+ document.getElementById("limit"+i).value = Vlimit[i];
+ }
+ updateTask = setTimeout("communication()",updaterate);
+ }
+
+function getParameterByName(name)
+{
+ name = name.replace(/[\[]/, "\\\[").replace(/[\]]/, "\\\]");
+ var regexS = "[\\?&]" + name + "=([^&#]*)";
+ var regex = new RegExp(regexS);
+ var results = regex.exec(window.location.search);
+ if(results == null)
+ return "";
+ else
+ return decodeURIComponent(results[1].replace(/\+/g, " "));
+}
+
+
+function readSettings() {
+ readSettingsRequest = 1;
+ }
+
+updateTask = setTimeout("communication()",updaterate);
+document.getElementById("headline").innerHTML = "Power Switch "+'<b>'+dev_id+'</b>'+" [connected to "+'<b>'+ser_dev+'</b>'+"]" ;
+
+maketable();
+</script>
+</body></html>
--- /dev/null
+#!/usr/bin/perl -w
+
+if ($ENV{'SERVER_SOFTWARE'} =~ /HTTP-?i/i) {
+ &htsponse(200, "OK");
+ }
+print "Content-type: text/html\n\n";
+
+
+my $envstring = $ENV{'QUERY_STRING'};
+$envstring =~ s/%20/ /g;
+$envstring =~ s/&/\n/g;
+##$envstring =~ s/&/\n/g;
+
+
+my $file = "pwr.conf";
+if ($ENV{'SERVER_SOFTWARE'} =~ /HTTPi/i) {
+ $file = "htdocs/".$file;
+ }
+
+
+open(SCHREIBEN,">$file")
+ or print "Fehler beim oeffnen von : $!\n";
+
+print SCHREIBEN $envstring;
+close(SCHREIBEN);
+
+print "saved!";
+
+
+return true;
--- /dev/null
+
+
+function getdata(command,callback,option) {
+ var xmlhttp = null;
+ var cb = null;
+ xmlhttp=new XMLHttpRequest();
+ cb = callback;
+
+ xmlhttp.onreadystatechange = function() {
+ if(xmlhttp.readyState == 4) {
+ if(cb && option)
+ cb(xmlhttp.responseText,option);
+ else if(cb)
+ cb(xmlhttp.responseText);
+ }
+ }
+ xmlhttp.open("GET",command,true);
+ xmlhttp.send(null);
+ }
+
+
+// function reload() {
+// xmlhttp=new XMLHttpRequest();
+// xmlhttp.onreadystatechange = function() {
+// if(xmlhttp.readyState == 4) {
+// document.getElementById("content").innerHTML=xmlhttp.responseText;
+// if(document.getElementById('logbox')) {
+// if(saveScrollTop) {
+// document.getElementById('logbox').scrollTop = saveScrollTop;
+// }
+// }
+//
+// document.getElementById("stop").style.background="#444";
+// reloadevery = setTimeout('reload()',$.($delay*1000).qq$);
+// }
+// };
+// if(document.getElementById('logbox')) {
+// saveScrollTop = document.getElementById('logbox').scrollTop;
+// if (saveScrollTop == 0) {saveScrollTop = 0.1;}
+// }
+// xmlhttp.open("GET","get.cgi?$.$ENV{'QUERY_STRING'}.qq$",true);
+// xmlhttp.send(null);
+// document.getElementById("stop").style.background="#111";
+// }
\ No newline at end of file
--- /dev/null
+body {
+ background:#eee;
+}
+
+.smallboxes {
+ border-collapse:collapse;
+ border:1px solid black;
+}
+
+
+#headline {
+font-weight:normal;
+font-size:90%;
+}
+
+
+.smallboxes input {
+ width:50px;
+ }
+
+.smallboxes .sep {
+ border-bottom:1px solid black;
+}
+
+.smallboxes td:nth-child(even), .smallboxes th {
+ border-left:1px solid black;
+ }
+
+.smallboxes td {
+ padding:1px;
+}
+
+td.state {
+ padding-left:10px;
+ text-align:center;
+
+}
+
+
+#info {
+font-size:70%;
+text-align:right;
+}
+
+.powerswitch .status {
+ min-width:20px;
+ width:20px;
+}
+
+tfoot>tr:first-child {
+ border-top:1px solid black;
+}
+
+.powerswitch td {
+ border-left:1px solid black;
+ text-align:center;
+}
\ No newline at end of file
--- /dev/null
+#!/usr/bin/perl
+use POSIX qw(SIGALRM SIGTERM sigaction);
+
+use lib ".";
+use Digest::SHA::PurePerl qw(sha1_base64);
+
+
+$VERSION = "1.7 (Demonic/Linux)";
+
+# HTTPi Hypertext Tiny Truncated Process Implementation
+# Copyright 1999-2010 Cameron Kaiser and Contributors # All rights reserved
+# Please read LICENSE # Do not strip this copyright message.
+
+###############################################################
+# WHITE HATS ONLY BELOW THIS POINT -- SEE DOCUMENTATION FIRST #
+###############################################################
+
+%system_content_types =
+ ("html" => "text/html",
+ "htm" => "text/html",
+ "txt" => "text/plain",
+ "xml" => "text/xml",
+ "xsl" => "text/xml",
+ "xhtml" => "application/xhtml+xml",
+ "css" => "text/css",
+ "gif" => "image/gif",
+ "jpeg" => "image/jpeg",
+ "jpg" => "image/jpeg",
+ "bmp" => "image/bmp",
+ "png" => "image/png",
+ "tif" => "image/tiff",
+ "tiff" => "image/tiff",
+ "ico" => "image/x-icon",
+ "svg" => "image/svg+xml",
+ "svgz" => "image/svg+xml",
+ "wbmp" => "image/vnd.wap.wbmp",
+ "wbm" => "image/vnd.wap.wbmp",
+ "xbm" => "image/x-xbitmap",
+ "mp3" => "audio/x-mpeg",
+ "wma" => "audio/x-ms-wma",
+ "wav" => "audio/x-wav",
+ "au" => "audio/basic",
+ "aif" => "audio/x-aiff",
+ "aiff" => "audio/x-aiff",
+ "ogg" => "audio/x-ogg",
+ "oga" => "audio/x-ogg",
+ "mid" => "audio/midi",
+ "wma" => "audio/x-ms-wma",
+ "mpeg" => "video/mpeg",
+ "mpg" => "video/mpeg",
+ "aac" => "audio/aac",
+ "ogv" => "video/x-ogg",
+ "ogx" => "application/x-ogg",
+ "avi" => "video/x-msvideo",
+ "wmv" => "video/x-ms-wmv",
+ "asf" => "video/x-ms-asf",
+ "mov" => "video/quicktime",
+ "mp4" => "video/mp4",
+ "rv" => "video/vnd.m-realvideo",
+ "rm" => "application/vnd.m-realmedia",
+ "ra" => "audio/vnd.m-realaudio",
+ "ram" => "audio/vnd.m-realaudio",
+ "pdf" => "application/pdf",
+ "fdf" => "application/vnd.fdf",
+ "class" => "application/octet-stream",
+ "jar" => "application/octet-stream",
+ "js" => "application/x-javascript",
+ "lnk" => "application/x-hyperlink",
+ "prg" => "application/x-c64-prg-binary",
+ "d64" => "application/x-c64-disk-image",
+ "tar" => "application/x-tar",
+ "sit" => "application/x-stuffit",
+ "Z" => "application/x-compress",
+ "gz" => "application/x-gzip",
+ "dmg" => "application/octet-stream",
+ "img" => "application/octet-stream",
+ "lzh" => "application/octet-stream",
+ "lha" => "application/octet-stream",
+ "exe" => "application/octet-stream",
+ "com" => "application/octet-stream",
+ "zip" => "application/x-zip-compressed",
+ "hqx" => "application/x-binhex",
+ "swf" => "x-shockwave-flash",
+ "flv" => "video/x-flv",
+
+ "bin" => "application/octet-stream");
+
+# comment in to enable logs
+#$logfile = "./access.log";
+$path = "./htdocs";
+$sockaddr = 'S n a4 x8';
+
+$server_host = $ARGV[0];
+$server_port = $ARGV[1];
+
+die("$0 [host] [port] required. got >$server_host< >$server_port<") unless ($server_host and $server_port);
+
+%content_types =
+ ("html" => "text/html",
+ "htm" => "text/html",
+ "shtml" => "text/html"
+ );
+%restrictions = (
+ "/nw" => "^10\.##^Mozilla#MSIE",
+ "/status" => "####voyeur:daNrZR3TcSwD2",
+ "/" => "###(NPBot|WebZIP|HTTrack|eCatch|Offline Explorer|UdmSearch|WebCopier|internetseer|MSIECrawler|SuperBot|LinkWalker|Tutorial Crawler|WebReaper)",
+ );
+ # See documentation for interpreting this string.
+
+$headers = <<"EOF";
+Server: TRB based on HTTPi/$VERSION
+MIME-Version: 1.0
+EOF
+
+
+%content_types = (%system_content_types, %content_types);
+undef %system_content_types;
+
+#if ($pid = fork()) { exit; }
+$0 = "dhttpi: binding port ...";
+$bindthis = pack($sockaddr, 2, $server_port, pack('C4', 0, 0, 0, 0));
+socket(S, 2, 1, 6);
+setsockopt(S, 1, 2, 1);
+bind(S, $bindthis) || die("$0: while binding port $server_port:\n\"$!\"\n");
+listen(S, 128);
+$0 = "dhttpi: connected and waiting ANY:$server_port";
+
+$statiosuptime = time();
+
+sub sock_to_host {
+ return ($cache_hn, $cache_port, $cache_ip)
+ if (length($cache_ip));
+
+ return (undef, undef, undef) if (!$sock);
+ my($AFC, $cache_port, $thataddr, $zero) = unpack($sockaddr, $sock);
+ $cache_ip = join('.', unpack("C4", $thataddr));
+ $cache_hn =
+ gethostbyaddr($thataddr, 2) ||
+ $cache_ip;
+ return ($cache_hn, $cache_port, $cache_ip);
+}
+
+
+sub htsponse {
+ ($currentcode, $currentstring) = (@_);
+ return if (0+$httpver < 1);
+ my($what) = <<"EOF";
+HTTP/$httpver $currentcode $currentstring
+${headers}Date: $rfcdate
+EOF
+ $what =~ s/\n/\r\n/g;
+ print STDOUT $what;
+ &hthead("Connection: close") if (0+$httpver > 1);
+}
+
+sub hthead {
+ my($header, $term) = (@_);
+ return if (0+$httpver < 1);
+ print STDOUT "$header\r\n" , ($term) ? "\r\n" : "";
+}
+
+sub htcontent {
+ my($what, $ctype, $mode) = (@_);
+ ($contentlength) = $mode || length($what);
+ &hthead("Content-Length: $contentlength");
+ &hthead("Content-Type: $ctype", 1);
+ return if ($method eq 'HEAD' || $mode);
+ print STDOUT $what;
+}
+
+sub log {
+ if ($logfile && open(J, ">>$logfile")) {
+ my $q = $address . (($variables) ? "?$variables" : "");
+ $contentlength += 0;
+ $contentlength = 0 if ($method eq 'HEAD');
+ my ($hostname, $port, $ip) = &sock_to_host();
+ $hostname ||= "-";
+ $httpuser ||= "-";
+ print J <<"EOF";
+$hostname - $httpuser [$date] "$method $q HTTP/$httpver" $currentcode $contentlength "$httpref" "$httpua"
+EOF
+ close(J);
+ }
+}
+
+
+sub bye { exit; }
+sub byebye { kill(9,$secondary_pid) if ($secondary_pid); exit; }
+
+sub dead {
+ &htsponse(500, "Server Error");
+ &hterror("Server Error", <<"EOF");
+The server cannot comply with your request for resource <tt>$::address</tt>.
+Please attempt to notify the administrators.
+<p>Useful(?) debugging information:
+<pre>
+@_
+</pre>
+EOF
+ &log; exit;
+}
+
+sub defaultsignals {
+ $SIG{'__DIE__'} = \&dead;
+ sigaction SIGALRM, new POSIX::SigAction \&bye
+ or die "sigalrm failed: $!\n";
+ sigaction SIGTERM, new POSIX::SigAction \&byebye
+ or die "sigterm failed: $!\n";
+}
+&defaultsignals;
+
+sub alarmsignals {
+ undef $SIG{'__DIE__'};
+ sigaction SIGALRM, new POSIX::SigAction sub { die; }
+ or die "sigalrm failed: $!\n";
+}
+
+sub master {
+ $0 = "dhttpi: handling request";
+$sock = getpeername(STDIN);
+$rfcdate = &rfctime(scalar gmtime, 1);
+$date = scalar localtime;
+($dow, $mon, $dt, $tm, $yr) = ($date =~
+ m/(...) (...) (..) (..:..:..) (....)/);
+$dt += 0;
+$dt = substr("0$dt", length("0$dt") - 2, 2);
+$date = "$dt/$mon/$yr:$tm +0000";
+
+select(STDOUT); $|=1; $address = 0;
+alarm 5;
+while (<STDIN>) {
+ if(/^([A-Z]+)\s+([^\s]+)\s+([^\s\r\l\n]*)/) {
+ $method = $1;
+ $address = $2;
+ $httpver = $3;
+ $httpref = '';
+ $httpua = '';
+ $httpver = ($httpver =~ m#HTTP/([0-9]\.[0-9]+)#) ?
+ ($1) : (0.9);
+ $address =~ s#^http://[^/]+/#/#;
+ $0 = $execstring = "dhttpi: $method $address $httpver";
+ next unless ($httpver < 1);
+ } else {
+ s/[\r\l\n\s]+$//;
+ (/^Host:\s+(.+)/i) && ($httphost = substr($1, 0, 255))
+ && ($httphost =~ s/:\d+$//);
+ (/^Referer:\s+(.+)/i) && ($httpref = substr($1, 0, 1024));
+ (/^User-agent:\s+(.+)/i) && ($httpua = substr($1, 0, 1024));
+ (/^Content-length:\s+(\d+)/i) &&
+ ($ENV{'CONTENT_LENGTH'} = $httpcl = 0+$1);
+ (/^Content-type:\s+(.+)/i) &&
+ ($ENV{'CONTENT_TYPE'} = $httpct = substr($1, 0, 255));
+ (/^Expect:\s+/) && ($expect = 1);
+ (/^Cookie:\s+(.+)/i) &&
+ ($ENV{'HTTP_COOKIE'} = substr($1, 0, 16384));
+ (/^Authorization:\s+Basic (.+)/i) &&
+ ($httprawu = substr($1, 0, 1024));
+ (/^Range:\s+(.+)/i) &&
+ ($ENV{'CONTENT_RANGE'} = substr($1, 0, 255));
+ (/^If-Modified-Since:\s+(.+)/i) &&
+ ($modsince = $ENV{'HTTP_IF_MODIFIED_SINCE'} =
+ substr($1, 0, 255));
+ (/^Accept:\s+(.+)/i) &&
+ ($ENV{'HTTP_ACCEPT'} = substr($1, 0, 255));
+ (/^Accept-([a-zA-Z0-9]+):\s+(.+)/i) &&
+ ($ENV{'HTTP_ACCEPT_'.uc(substr($1, 0, 16))} =
+ substr($2, 0, 255));
+ (/^X-Requested-With:\s+(.+)/i) &&
+ ($ENV{'HTTP_X_REQUESTED_WITH'} = substr($1, 0, 1024));
+
+ (/^Origin:\s+(.+)/i) &&
+ ($ENV{'HTTP_ORIGIN'} = substr($1, 0, 1024));
+ (/^Upgrade:\s+(.+)/i) &&
+ ($ENV{'HTTP_UPGRADE'} = substr($1, 0, 1024));
+ (/^Sec-WebSocket-Protocol:\s+(.+)/i) &&
+ ($ENV{'WEBSOCKET_PROTOCOL'} = substr($1, 0, 1024));
+ (/^Sec-WebSocket-Version:\s+(-?\d+)/i) &&
+ ($ENV{'WEBSOCKET_VERSION'} = substr($1, 0, 8));
+ (/^Sec-WebSocket-Extensions:\s+(-?\d+)/i) &&
+ ($ENV{'WEBSOCKET_EXTENSIONS'} = substr($1, 0, 1024));
+ (/^Sec-WebSocket-Key:\s+(\S+)/i) &&
+ ($ENV{'WEBSOCKET_KEY'} = substr($1, 0, 1024));
+
+ next unless (/^$/);
+ }
+ if ($expect) {
+ &htsponse(417, "Expectation Failed");
+ &hterror("Expectation Failed",
+ "The server does not support this method.");
+ &log; exit;
+ }
+ if (!length($address) || (0+$httpver > 1 && !$httphost)) {
+ &htsponse(400, "Bad Request");
+ &hterror("Bad Request",
+ "The server cannot understand your request.");
+ &log; exit;
+ }
+ if ($method !~ /^(GET|HEAD|POST)$/) {
+ &htsponse(501, "Not Implemented");
+ &hterror("Not Implemented",
+ "Only GET, HEAD and POST are supported.");
+ &log; exit;
+ }
+
+
+ if ($ENV{'HTTP_UPGRADE'} eq 'websocket') {
+ if ($method ne "GET" || !$ENV{'WEBSOCKET_KEY'}) {
+ &htsponse(400, "Bad request");
+ &hterror("Bad request",
+ "Illegal websocket opening handshake");
+ &log; exit;
+ }
+
+ $ENV{'WEBSOCKET_ACCEPT'} =
+ sha1_base64($ENV{'WEBSOCKET_KEY'} . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11") . "=";
+
+
+ }
+
+
+
+ ($address, $variables) = split(/\?/, $address);
+ $address =~ s/%([0-9a-fA-F]{2})/pack("H2", $1)/eg;
+ $address=~ s#^/?#/#;
+ 1 while $address =~ s#/\.(/|$)#\1#;
+ 1 while $address =~ s#/[^/]*/\.\.(/|$)#\1#;
+ 1 while $address =~ s#^/\.\.(/|$)#\1#;
+ $fail = 0;
+ J: foreach(sort { length $a <=> length $b }
+ keys %restrictions) {
+ next if ($address !~ /^$_/);
+ ($allowip, $denyip, $allowua, $denyua, $auser) =
+ split(/#/, $restrictions{$_});
+ if ($allowip || $denyip) {
+ ($hostname, $port, $ip) = &sock_to_host();
+ ($allowip && $ip !~ /$allowip/) && ($fail = 1,
+ last J);
+ ($denyip && $ip =~ /$denyip/) && ($fail = 1,
+ last J);
+ }
+ ($allowua && $httpua !~ /$allowua/) &&
+ ($fail = 2, last J);
+ ($denyua && $httpua =~ /$denyua/) &&
+ ($fail = 2, last J);
+ }
+ if ($fail) {
+ &htsponse(403, "Forbidden");
+ if ($fail == 1) {
+ &hterror("Forbidden (Client Disallowed)", <<"EOF");
+Your network address (<i>$ip</i>) is not allowed to access this resource.
+EOF
+ &log; exit;
+ } else {
+ &hterror("Forbidden (Browser Disallowed)", <<"EOF");
+The browser you are using (<i>$httpua</i>) is not capable of or
+is not allowed access to this resource.
+EOF
+ &log; exit;
+ }
+ }
+ if ($auser) {
+ $httprawu =~ tr#A-Za-z0-9+/##cd;
+ $httprawu =~ tr#A-Za-z0-9+/# -_#;
+ $httprawu = unpack("u", pack("c", 32+0.75*length($httprawu))
+ . $httprawu);
+ ($httpuser, $httppw) = split(/:/, $httprawu);
+ $fail = 1;
+ foreach $user (split(/,/, $auser)) {
+ ($user, $pw) = split(/:/, $user);
+ ($fail = 0, last) if ($user eq $httpuser &&
+ crypt($httppw, substr($pw, 0, 2)) eq $pw);
+ }
+ if ($fail) {
+ $httpuser = '';
+ &htsponse(401, "Authorization Required");
+ &hthead("WWW-Authenticate: Basic realm=\"$address\"");
+ &hterror("Authorization Required", <<"EOF");
+You must provide a username and password to use this resource. Either you
+entered this information incorrectly, or your browser does not know how to
+present the credentials required.
+EOF
+ &log; exit;
+ }
+ }
+
+ alarm 0;
+
+
+
+
+ $raddress = "$path$address"
+ ;
+ 1 while ($raddress =~ s#//#/#);
+ &hterror301("http://$server_host:$server_port$address/")
+ if ($address !~ m#/$# && -d $raddress);
+ $raddress = (-r "${raddress}index.shtml") ?
+ "${raddress}index.shtml" : "${raddress}index.html"
+ if (-d $raddress);
+ IRED: ($hostname, $port, $ip) = &sock_to_host();
+ if(!sysopen(S, $raddress, 0)) { &hterror404; } else {
+ if ((-x $raddress)
+ ) {
+ $currentcode = 100; &nsecmodel;
+ $ENV{'REQUEST_METHOD'} = $method;
+ $ENV{'SERVER_NAME'} = $server_host;
+ $ENV{'SERVER_PROTOCOL'} = "HTTP/$httpver";
+ $ENV{'SERVER_SOFTWARE'} = "HTTPi/$VERSION";
+ $ENV{'SERVER_PORT'} = "$server_port";
+ $ENV{'SERVER_URL'} = "http://$server_host:$server_port/";
+ $ENV{'SCRIPT_FILENAME'} = $raddress;
+ $ENV{'SCRIPT_NAME'} = $address;
+ $ENV{'REMOTE_HOST'} = $hostname;
+ $ENV{'REMOTE_ADDR'} = $ip;
+ $ENV{'REMOTE_PORT'} = $port;
+ $ENV{'QUERY_STRING'} = $variables;
+ $ENV{'HTTP_USER_AGENT'} = $httpua;
+ $ENV{'HTTP_REFERER'} = $httpref;
+ undef $pid;
+ if ($pid = fork()) { kill 15, $$; exit; }
+ elsif (!defined($pid)) {
+ die
+ "temporary(?) fork error, please retry request: $!\n";
+ } else {
+ require $raddress;
+ exit;
+ }
+ }
+ ($x,$x,$x,$x,$x,$x,$x,$length,$x,$mtime) = stat(S);
+ $ctype = 0;
+ foreach(keys %content_types) {
+ if ($raddress =~ /\.$_$/i) {
+ $ctype = $content_types{$_};
+ }
+ }
+ $mtime = &rfctime($mtime);
+SERVEIT:
+ if ($mtime eq $modsince) {
+ &htsponse(304, "Not Modified");
+ &hthead("Last-Modified: $mtime", 1);
+ &log; exit;
+ }
+ $ctype ||= 'text/plain';
+ if ($pid = fork()) { kill 15, $$; exit; }
+ $contentlength ||= $length;
+ &htsponse(200, "OK");
+ &hthead("Last-Modified: $mtime");
+ &htcontent("", $ctype, $length);
+ &nsecmodel;
+ $bytecount = 0;
+ unless ($method eq 'HEAD') {
+ while(!eof(S)) {
+ read(S, $q, 32768);
+ print STDOUT $q;
+ $bytecount += 32768;
+ $0 = $execstring .
+ " ($bytecount bytes sent)";
+ }
+ }
+ alarm 0;
+ }
+ exit;
+}
+
+exit;
+}
+
+
+sub nsecmodel {
+ &log;
+ ($x,$x,$x,$x,$uid,$gid) = stat(S);
+ (!$uid || !$gid || $uid < 2 ) &&
+ die "resource is root-owned, secured or not stat-able\n";
+ if (!$<) {
+ ($) = "$gid $gid") || die "can't set egid to $gid";
+ ($> = $uid) || die "can't set euid to $uid";
+ ($( = "$gid $gid") || die "can't set rgid to $gid";
+ ($< = $uid) || die "can't set ruid to $uid";
+ }
+}
+
+sub rfctime {
+ my $mtime = shift;
+ $mtime = (scalar gmtime $mtime) if (!(shift));
+ my ($dow, $mon, $dt, $tm, $yr) =
+ ($mtime =~ m/(...) (...) (..) (..:..:..) (....)/);
+ $dt += 0; $yr += 0;
+ return "$dow, $dt $mon $yr $tm GMT";
+}
+
+sub hterror {
+ my($errstr, @expl) = (@_);
+ &htcontent(<<"EOF", "text/html");
+<html>
+<body>
+<h1>$errstr</h1>
+@expl
+<hr>
+<address><a href = "http://httpi.floodgap.com/">httpi/$VERSION</a>
+by Cameron Kaiser</address>
+</body>
+</html>
+EOF
+ }
+
+sub hterror404 {
+ &htsponse(404, "Not Found");
+ &hterror("Not Found",
+ "The resource <tt>$address</tt> was not found on this system.");
+ &log; exit;
+}
+
+sub hterror301 {
+ &htsponse(301, "Moved Permanently");
+ &hthead("Location: @_");
+ &hterror("Resource Moved Permanently",
+ "This resource has moved <a href = \"@_\">here</a>.");
+ &log; exit;
+}
+
+
+$0 = "dhttpi: on ANY:$server_port, ready!";
+$master_pid = $$;
+for (;;) {
+ if ($secondary_pid = fork()) {
+ waitpid($secondary_pid, 0);
+ $0 = "dhttpi: on ANY:$server_port, last request " .
+ scalar localtime;
+ } else {
+ $0 = "dhttpi (child of $master_pid): waiting for connect";
+ $addr=accept(NS,S);
+ open(STDIN, "<&NS");
+ open(STDOUT, ">&NS");
+ &defaultsignals;
+ &master;
+ exit;
+ }
+}
jspc29 / labtools.git / commitdiff