lib/PXElator/httpd.pm

package httpd;

use warnings;
use strict;
use autodie;

=head1 httpd

Start with:

  perl -Ilib/PXElator -Mhttpd -e httpd::start

=cut

use Data::Dump qw/dump/;
use Carp qw/confess/;
use File::Slurp;
#use JSON;
use IO::Socket::INET;
use Regexp::Common qw/net/;

sub menu {qq{

<div style="font-size: 80%; color: #888">
<a href=/>home</a>
<a href=/server>server</a>
<a href=/brctl>brctl</a>
<a href=/ip>ip</a>
<a href=/client>client</a>
</div>

}}

our $port = 7777;

use server;
our $debug = server::debug;
our $url = "http://$server::ip:$port";

use html;
our $static_pids;
use progress_bar;
use config;
use client;
use log;
use x11;
use amt;
use boolean;
use daemons;

use kvm;
use browser;
use network;
use ip;
use wireshark;
use syslogd;

use CouchDB;

sub static {
        my ($client,$path) = @_;

        my $full = "$server::base_dir/tftp/$path";

        return if ! -f $full;

        if ( my $pid = fork ) {
                # parent
                close($client);
                $static_pids->{$pid} = $path;
                return 1;
        }

        my $type = 'application/octet-stream';
        $type = 'text/html' if $path =~ m{\.htm};
        $type = 'application/javascript' if $path =~ m{\.js};
        $type = 'text/plain' if $path =~ m{\.txt};

        my $size = -s $full || return;

        print $client "HTTP/1.0 200 OK\r\nContent-Type: $type\r\nContent-Length: $size\r\nConnection: close\r\n\r\n";

        open(my $fh, $full);

        my $block = 1400; # try not to fragment packages (pxelinux seems to have problems with it)
        my $buff;
        my $pos = 0;

        CouchDB::audit( 'static', { pid => $$, path => $path, type => $type, size => $size, block => $block, peerhost => $client->peerhost });

        progress_bar::start;

        while( my $len = read $fh, $buff, $block ) {
                print $client $buff;
                $client->flush;
                $pos += $len;
                progress_bar::tick( $path, $pos, $size );
        }
        close($fh);
        close($client);

        print STDERR "\n";

        exit(0);
}

sub ok {
        qq|HTTP/1.0 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n| . menu()
}

sub redirect {
        my $to = shift;
        $to ||= $url;
        qq|HTTP/1.1 302 Found\r\nContent-type: text/html\r\nLocation: $to\r\n\r\n|
}

sub get_request {
        my ( $client, $path, $param ) = @_;

        server->refresh;

        CouchDB::audit( 'request', { path => $path, param => $param, peerhost => $client->peerhost } );

        if ( my $found = static( $client,$path ) ) {
                warn "static $found" if $debug;
        } elsif ( $path eq '/' ) {

                my @rows = (
                        'debug',        qq|<a href=/our/debug/| . boolean::toggle($debug) . qq|>$debug</a>|,
                );

                my $debug_proc = '';

warn "XXX pids = ", dump( $daemons::pids );

                foreach my $name ( sort keys %$daemons::pids ) {
                        my $pid = $daemons::pids->{$name}; # || next;

                        my $html;

                        my $proc = "/proc/$pid/status";

                        if ( -e $proc ) {
                                $html .= qq|<a href=/start_stop/$name>$pid</a>|;
                                if ( $debug ) {
                                        $html .= qq| <a name=$pid href=#proc-$pid>?</a>| if $name->can('start');

                                        $debug_proc
                                                .= qq|<a name=proc-$pid href=#$pid>$proc</a><pre style="font-size: 10%">|
                                                .  read_file($proc)
                                                .  qq|</pre>|
                                                ;
                                }

                                if ( $name->can('fork_if_active') ) {
                                        $html .= qq| <a href=/start_stop/$name/$_>$_</a>| foreach $name->fork_if_active;
                                }

                                if ( $name->can('actions') ) {
                                        $html .= qq| <a href=/action/$name/$_>$_</a>| foreach $name->actions;
                                }
                        } else {
                                if ( $pid =~ m{^\d+$} ) {
                                        $html .= qq|$pid exited |
                                } else {
                                        $html .= qq|$pid |;
                                }
                                $html .= qq|<a href=/start_stop/$name>restart</a>| if $pid || $name->can('start');
                                if ( $name->can('fork_actions') ) {
                                        $html .= qq| <a href=/start_stop/$name/$_>$_</a>| foreach $name->fork_actions;
                                }
                        }

                        die "no html generated" unless $html;

                        push @rows, ( $name => $html );
                }

                my $below_table = '';

                warn 'static_pids: ', dump( $static_pids ) if $debug;
                foreach my $pid ( keys %$static_pids ) {
                        my $path = $static_pids->{$pid};
                        if ( -d "/proc/$pid" ) {
                                push @rows, ( $path => qq|<a href=/kill/static/$pid>$pid</a>| );
                        } elsif ( $param->{clean_completed_downloads} ) {
                                delete $static_pids->{$pid}
                        } else {
                                push @rows, ( $path => "$pid competed" );
                                $below_table = qq|<a href="/?clean_completed_downloads=1">clean completed downloads</a>|;
                        }
                }

                print $client ok
                        , html::table( 2, @rows )
                        , $below_table
                        , html::tabs( log::mac_changes )
                        , $debug_proc
                        ;

        } elsif ( $path =~ m{^/server} ) {
                print $client ok
                        , html::table( 2, map { ( $_, html::tt eval '$server::'.$_ ) } ( 'ip', 'netmask', 'ip_from', 'ip_to', 'domain_name', 'base_dir', 'conf' ) )
                        ;
        } elsif ( $path =~ m!^/client(?:/$RE{net}{IPv4}{-keep})?! ) {
                my $ip = $1 || $client->peerhost;

                if ( my $new_ip = $param->{change_ip} ) {
                        client::change_ip( $ip, $new_ip );
                        $ip = $new_ip;
                }

                if ( $ip ne $server::ip ) {
                        my $hostname = client::conf( $ip, 'hostname' => $param->{hostname} );

                        my @table = (
                                'ip' => qq|<input type=text name=change_ip value="$ip" onChange="document.getElementById('old_ip').style.display = '';"><span id=old_ip style="display: none; color: #888;">old: $ip<span>|,
                                'hostname' => qq|<input type=text name=hostname value="$hostname">|,
                        );

                        my $deploy;

                        if ( my $mac = client::mac_from_ip( $ip ) ) {
                                $deploy = client::conf( $ip, 'deploy' => $param->{deploy} );
                                push @table, (
                                        'mac' => format::mac( $mac => 'html' ),
                                        'deploy' => html::select( 'deploy', $deploy, config::available )
                                );
                                $deploy = qq|<h2>PXElinux</h2>| . html::pre( config::for_ip( $ip ) );
                        }

                        print $client ok
                                , qq|<form method=get>|
                                , html::table( 2, @table ),
                                , qq|<input type=submit value=change></form>|
                                , $deploy
                                ;

                        if ( my $amt = client::conf( $ip, 'amt' ) ) {
                                print $client qq|<h2>AMT</h2>|, amt::info( $amt );
                        }
                } else {

                        my $arp = {
                                map {
                                        my @c = split(/\s+/,$_);
                                        if ( $#c == 5 ) {
                                                ( uc $c[3] => [ $c[0] , $c[5] ] )
                                        } else {
                                        }
                                } read_file('/proc/net/arp')
                        };

                        warn "# arp ",dump( $arp );

                        print $client ok
                                , qq|<h2>Clients on $server::ip</h2>|
                                , html::table( -5,
                                        'ip', 'hostname', 'mac', 'deploy', 'arp',
                                        map {
                                                my $ip = $_;
                                                $ip =~ s{^.+/ip/}{};
                                                my $mac = client::mac_from_ip $ip;
                                                my $arp = $arp->{ $mac };
                                                $arp = $arp ? $arp->[1] : '';
                                                $arp =~ s{$ip}{};
                                                (
                                                        qq|<a href=/client/$ip>$ip</a>|
                                                        , client::conf( $ip, 'hostname' )
                                                        , format::mac( $mac => 'html' )
                                                        , html::tt( client::conf( $ip, 'deploy' ) )
                                                        , $arp
                                                );
                                        }
                                        glob("$server::conf/ip/*") 
                                )
                                , qq|<h2>ARP</h2>|
                                , html::table( -3, 'mac', 'dev', 'ip',
                                        map {
                                                my $c = $arp->{$_};
                                                ( format::mac( $_ => 'html' ), $c->[1], $c->[0] )
                                        } sort keys %$arp
                                )
                                ;
                }
        } elsif ( $path =~ m{^/brctl} ) {
                print $client ok
                        ,html::pre( `brctl show` )
                        ;
        } elsif ( $path =~ m{^/ip/?(\w+)?} ) {
                print $client ok
                        , join("\n", map { qq|<a href=/ip/$_>$_</a>| } ( qw/link addr route neigh ntable tunnel maddr mroute xfrm/ ))
                        , ip::html( $1 )
                        ;
        } elsif ( $path =~ m{^/our/(\w+)/(\S+)} ) {
                eval 'our $' . $1 . ' = ' . $2;
                warn $@ if $@;
                print $client redirect($url), qq|<big>$1 = $2</big><br>Location: <a href="$url">$url</a>|;
                server::debug( $debug ) if $1 eq 'debug';
        } elsif ( $path =~ m{^/start_stop/(\S+)} ) {
                print $client redirect, daemons::start_stop($1);
        } elsif ( $path =~ m{^/action/([^/]+)/(.+)} ) {
                $1->$2();
                print $client redirect;
        } elsif ( $path =~ m{^/kill/static/(\d+)} ) {
                print $client redirect;
                kill 1, $1 || kill 9, $2 && warn "killed $1";
        } else {
                print $client "HTTP/1.0 404 $path\r\nConnection: close\r\nContent-type: text/html\r\n\r\n<big>404 $path</big>";
                warn "404 $path";
        }

}

sub start {

        warn 'network ', network::setup();

        daemons::start_stop 'browser', $url;
        daemons::start_stop $_ foreach ( qw/dhcpd tftpd dnsd syslogd/ );
        daemons::start_stop 'kvm' unless $ENV{DEV}; # skip kvm statup when running on real device

        my $server = IO::Socket::INET->new(
                        Proto     => 'tcp',
                        LocalAddr => $server::ip,
                        LocalPort => $httpd::port,
                        Listen    => SOMAXCONN,
                        Reuse     => 1
        ) || die "can't start server on $url: $!";

        print "url $url\n";

        while (1) {
                my $client = $server->accept() || next; # ALARM trickle us
                my $request = <$client>;

                warn "request $request\n" if $debug;

                if ($request =~ m{^GET (/.*) HTTP/1.[01]}) {
                        my $path = $1;
                        my $param;
                        if ( $path =~ s{\?(.+)}{} ) {
                                foreach my $p ( split(/[&;]/, $1) ) {
                                        my ($n,$v) = split(/=/, $p, 2);
                                        $param->{$n} = $v;
                                }
                                warn "param: ",dump( $param ) if $debug;
                        }
                        get_request $client, $path, $param;
                } else {
                        print $client "HTTP/1.0 500 No method\r\nConnection: close\r\nContent-type: text/plain\r\n\r\n500 $request";
                        warn "500 $request";
                }

                print $client menu() if $client->connected;

        }

        die "server died";
}

warn "loaded";

1;
1	dpavlin	42	package httpd;
2
3			use warnings;
4			use strict;
5			use autodie;
6
7			=head1 httpd
8
9			Start with:
10
11			perl -Ilib/PXElator -Mhttpd -e httpd::start
12
13			=cut
14
15			use Data::Dump qw/dump/;
16			use Carp qw/confess/;
17			use File::Slurp;
18			#use JSON;
19			use IO::Socket::INET;
20	dpavlin	162	use Regexp::Common qw/net/;
21	dpavlin	42
22	dpavlin	149	sub menu {qq{
23
24			<div style="font-size: 80%; color: #888">
25			<a href=/>home</a>
26			<a href=/server>server</a>
27	dpavlin	229	<a href=/brctl>brctl</a>
28	dpavlin	224	<a href=/ip>ip</a>
29	dpavlin	153	<a href=/client>client</a>
30	dpavlin	149	</div>
31
32			}}
33
34	dpavlin	42	our $port = 7777;
35
36			use server;
37	dpavlin	67	our $debug = server::debug;
38	dpavlin	64	our $url = "http://$server::ip:$port";
39	dpavlin	42
40	dpavlin	43	use html;
41	dpavlin	70	our $static_pids;
42	dpavlin	115	use progress_bar;
43	dpavlin	153	use config;
44	dpavlin	159	use client;
45			use log;
46	dpavlin	173	use x11;
47	dpavlin	181	use amt;
48	dpavlin	185	use boolean;
49			use daemons;
50	dpavlin	43
51	dpavlin	185	use kvm;
52			use browser;
53			use network;
54	dpavlin	224	use ip;
55	dpavlin	225	use wireshark;
56	dpavlin	231	use syslogd;
57	dpavlin	185
58	dpavlin	207	use CouchDB;
59	dpavlin	185
60	dpavlin	42	sub static {
61			my ($client,$path) = @_;
62
63	dpavlin	65	my $full = "$server::base_dir/tftp/$path";
64	dpavlin	42
65	dpavlin	65	return if ! -f $full;
66	dpavlin	42
67	dpavlin	70	if ( my $pid = fork ) {
68			# parent
69			close($client);
70			$static_pids->{$pid} = $path;
71			return 1;
72			}
73
74	dpavlin	65	my $type = 'application/octet-stream';
75	dpavlin	42	$type = 'text/html' if $path =~ m{\.htm};
76			$type = 'application/javascript' if $path =~ m{\.js};
77	dpavlin	65	$type = 'text/plain' if $path =~ m{\.txt};
78	dpavlin	42
79	dpavlin	65	my $size = -s $full \|\| return;
80
81			print $client "HTTP/1.0 200 OK\r\nContent-Type: $type\r\nContent-Length: $size\r\nConnection: close\r\n\r\n";
82
83			open(my $fh, $full);
84
85	dpavlin	96	my $block = 1400; # try not to fragment packages (pxelinux seems to have problems with it)
86	dpavlin	65	my $buff;
87			my $pos = 0;
88
89	dpavlin	208	CouchDB::audit( 'static', { pid => $$, path => $path, type => $type, size => $size, block => $block, peerhost => $client->peerhost });
90	dpavlin	96
91	dpavlin	115	progress_bar::start;
92	dpavlin	105
93	dpavlin	65	while( my $len = read $fh, $buff, $block ) {
94	dpavlin	107	print $client $buff;
95	dpavlin	105	$client->flush;
96	dpavlin	65	$pos += $len;
97	dpavlin	115	progress_bar::tick( $path, $pos, $size );
98	dpavlin	42	}
99	dpavlin	65	close($fh);
100			close($client);
101	dpavlin	42
102	dpavlin	105	print STDERR "\n";
103	dpavlin	65
104	dpavlin	107	exit(0);
105	dpavlin	42	}
106
107	dpavlin	199	sub ok {
108			qq\|HTTP/1.0 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\n\r\n\| . menu()
109			}
110	dpavlin	67
111	dpavlin	199	sub redirect {
112			my $to = shift;
113			$to \|\|= $url;
114			qq\|HTTP/1.1 302 Found\r\nContent-type: text/html\r\nLocation: $to\r\n\r\n\|
115			}
116
117	dpavlin	43	sub get_request {
118			my ( $client, $path, $param ) = @_;
119
120	dpavlin	128	server->refresh;
121
122	dpavlin	208	CouchDB::audit( 'request', { path => $path, param => $param, peerhost => $client->peerhost } );
123	dpavlin	43
124			if ( my $found = static( $client,$path ) ) {
125			warn "static $found" if $debug;
126			} elsif ( $path eq '/' ) {
127	dpavlin	53
128	dpavlin	66	my @rows = (
129	dpavlin	64	'debug', qq\|<a href=/our/debug/\| . boolean::toggle($debug) . qq\|>$debug</a>\|,
130	dpavlin	43	);
131	dpavlin	70
132	dpavlin	96	my $debug_proc = '';
133	dpavlin	71
134	dpavlin	243	warn "XXX pids = ", dump( $daemons::pids );
135
136	dpavlin	185	foreach my $name ( sort keys %$daemons::pids ) {
137	dpavlin	243	my $pid = $daemons::pids->{$name}; # \|\| next;
138	dpavlin	43
139	dpavlin	173	my $html;
140	dpavlin	66
141	dpavlin	81	my $proc = "/proc/$pid/status";
142	dpavlin	71
143	dpavlin	81	if ( -e $proc ) {
144	dpavlin	173	$html .= qq\|<a href=/start_stop/$name>$pid</a>\|;
145	dpavlin	81	if ( $debug ) {
146	dpavlin	225	$html .= qq\| <a name=$pid href=#proc-$pid>?</a>\| if $name->can('start');
147	dpavlin	81
148			$debug_proc
149			.= qq\|<a name=proc-$pid href=#$pid>$proc</a><pre style="font-size: 10%">\|
150			. read_file($proc)
151			. qq\|</pre>\|
152			;
153			}
154
155	dpavlin	225	if ( $name->can('fork_if_active') ) {
156			$html .= qq\| <a href=/start_stop/$name/$_>$_</a>\| foreach $name->fork_if_active;
157	dpavlin	81	}
158	dpavlin	88
159			if ( $name->can('actions') ) {
160	dpavlin	225	$html .= qq\| <a href=/action/$name/$_>$_</a>\| foreach $name->actions;
161	dpavlin	88	}
162	dpavlin	173	} else {
163	dpavlin	243	if ( $pid =~ m{^\d+$} ) {
164			$html .= qq\|$pid exited \|
165			} else {
166			$html .= qq\|$pid \|;
167			}
168			$html .= qq\|<a href=/start_stop/$name>restart</a>\| if $pid \|\| $name->can('start');
169	dpavlin	225	if ( $name->can('fork_actions') ) {
170			$html .= qq\| <a href=/start_stop/$name/$_>$_</a>\| foreach $name->fork_actions;
171			}
172	dpavlin	71	}
173
174	dpavlin	243	die "no html generated" unless $html;
175
176	dpavlin	66	push @rows, ( $name => $html );
177			}
178
179	dpavlin	91	my $below_table = '';
180
181	dpavlin	78	warn 'static_pids: ', dump( $static_pids ) if $debug;
182	dpavlin	70	foreach my $pid ( keys %$static_pids ) {
183			my $path = $static_pids->{$pid};
184			if ( -d "/proc/$pid" ) {
185			push @rows, ( $path => qq\|<a href=/kill/static/$pid>$pid</a>\| );
186	dpavlin	91	} elsif ( $param->{clean_completed_downloads} ) {
187			delete $static_pids->{$pid}
188	dpavlin	70	} else {
189			push @rows, ( $path => "$pid competed" );
190	dpavlin	91	$below_table = qq\|<a href="/?clean_completed_downloads=1">clean completed downloads</a>\|;
191	dpavlin	70	}
192			}
193
194	dpavlin	199	print $client ok
195	dpavlin	72	, html::table( 2, @rows )
196	dpavlin	91	, $below_table
197	dpavlin	72	, html::tabs( log::mac_changes )
198			, $debug_proc
199			;
200	dpavlin	66
201	dpavlin	149	} elsif ( $path =~ m{^/server} ) {
202	dpavlin	199	print $client ok
203	dpavlin	185	, html::table( 2, map { ( $_, html::tt eval '$server::'.$_ ) } ( 'ip', 'netmask', 'ip_from', 'ip_to', 'domain_name', 'base_dir', 'conf' ) )
204	dpavlin	149	;
205	dpavlin	162	} elsif ( $path =~ m!^/client(?:/$RE{net}{IPv4}{-keep})?! ) {
206			my $ip = $1 \|\| $client->peerhost;
207	dpavlin	200
208			if ( my $new_ip = $param->{change_ip} ) {
209			client::change_ip( $ip, $new_ip );
210			$ip = $new_ip;
211			}
212
213	dpavlin	162	if ( $ip ne $server::ip ) {
214			my $hostname = client::conf( $ip, 'hostname' => $param->{hostname} );
215	dpavlin	188
216			my @table = (
217	dpavlin	199	'ip' => qq\|<input type=text name=change_ip value="$ip" onChange="document.getElementById('old_ip').style.display = '';"><span id=old_ip style="display: none; color: #888;">old: $ip<span>\|,
218			'hostname' => qq\|<input type=text name=hostname value="$hostname">\|,
219	dpavlin	188	);
220
221			my $deploy;
222
223	dpavlin	216	if ( my $mac = client::mac_from_ip( $ip ) ) {
224	dpavlin	188	$deploy = client::conf( $ip, 'deploy' => $param->{deploy} );
225			push @table, (
226	dpavlin	216	'mac' => format::mac( $mac => 'html' ),
227	dpavlin	188	'deploy' => html::select( 'deploy', $deploy, config::available )
228			);
229			$deploy = qq\|<h2>PXElinux</h2>\| . html::pre( config::for_ip( $ip ) );
230			}
231
232	dpavlin	199	print $client ok
233	dpavlin	162	, qq\|<form method=get>\|
234	dpavlin	188	, html::table( 2, @table ),
235	dpavlin	162	, qq\|<input type=submit value=change></form>\|
236	dpavlin	188	, $deploy
237	dpavlin	162	;
238	dpavlin	181
239			if ( my $amt = client::conf( $ip, 'amt' ) ) {
240	dpavlin	188	print $client qq\|<h2>AMT</h2>\|, amt::info( $amt );
241	dpavlin	181	}
242	dpavlin	162	} else {
243	dpavlin	190
244			my $arp = {
245			map {
246			my @c = split(/\s+/,$_);
247			if ( $#c == 5 ) {
248			( uc $c[3] => [ $c[0] , $c[5] ] )
249			} else {
250			}
251			} read_file('/proc/net/arp')
252			};
253
254			warn "# arp ",dump( $arp );
255
256	dpavlin	199	print $client ok
257	dpavlin	162	, qq\|<h2>Clients on $server::ip</h2>\|
258	dpavlin	190	, html::table( -5,
259			'ip', 'hostname', 'mac', 'deploy', 'arp',
260	dpavlin	162	map {
261			my $ip = $_;
262			$ip =~ s{^.+/ip/}{};
263	dpavlin	216	my $mac = client::mac_from_ip $ip;
264			my $arp = $arp->{ $mac };
265	dpavlin	190	$arp = $arp ? $arp->[1] : '';
266			$arp =~ s{$ip}{};
267			(
268			qq\|<a href=/client/$ip>$ip</a>\|
269			, client::conf( $ip, 'hostname' )
270	dpavlin	216	, format::mac( $mac => 'html' )
271	dpavlin	190	, html::tt( client::conf( $ip, 'deploy' ) )
272			, $arp
273			);
274	dpavlin	162	}
275			glob("$server::conf/ip/*")
276			)
277	dpavlin	190	, qq\|<h2>ARP</h2>\|
278	dpavlin	193	, html::table( -3, 'mac', 'dev', 'ip',
279			map {
280			my $c = $arp->{$_};
281	dpavlin	216	( format::mac( $_ => 'html' ), $c->[1], $c->[0] )
282	dpavlin	193	} sort keys %$arp
283			)
284	dpavlin	162	;
285			}
286	dpavlin	229	} elsif ( $path =~ m{^/brctl} ) {
287			print $client ok
288			,html::pre( `brctl show` )
289			;
290	dpavlin	224	} elsif ( $path =~ m{^/ip/?(\w+)?} ) {
291			print $client ok
292			, join("\n", map { qq\|<a href=/ip/$_>$_</a>\| } ( qw/link addr route neigh ntable tunnel maddr mroute xfrm/ ))
293			, ip::html( $1 )
294			;
295	dpavlin	43	} elsif ( $path =~ m{^/our/(\w+)/(\S+)} ) {
296			eval 'our $' . $1 . ' = ' . $2;
297			warn $@ if $@;
298	dpavlin	199	print $client redirect($url), qq\|<big>$1 = $2</big><br>Location: <a href="$url">$url</a>\|;
299	dpavlin	67	server::debug( $debug ) if $1 eq 'debug';
300	dpavlin	158	} elsif ( $path =~ m{^/start_stop/(\S+)} ) {
301	dpavlin	199	print $client redirect, daemons::start_stop($1);
302	dpavlin	88	} elsif ( $path =~ m{^/action/([^/]+)/(.+)} ) {
303			$1->$2();
304	dpavlin	199	print $client redirect;
305	dpavlin	70	} elsif ( $path =~ m{^/kill/static/(\d+)} ) {
306	dpavlin	199	print $client redirect;
307	dpavlin	86	kill 1, $1 \|\| kill 9, $2 && warn "killed $1";
308	dpavlin	43	} else {
309			print $client "HTTP/1.0 404 $path\r\nConnection: close\r\nContent-type: text/html\r\n\r\n<big>404 $path</big>";
310			warn "404 $path";
311			}
312
313			}
314	dpavlin	53
315	dpavlin	42	sub start {
316
317	dpavlin	229	warn 'network ', network::setup();
318	dpavlin	140
319	dpavlin	189	daemons::start_stop 'browser', $url;
320	dpavlin	231	daemons::start_stop $_ foreach ( qw/dhcpd tftpd dnsd syslogd/ );
321	dpavlin	189	daemons::start_stop 'kvm' unless $ENV{DEV}; # skip kvm statup when running on real device
322
323	dpavlin	42	my $server = IO::Socket::INET->new(
324			Proto => 'tcp',
325	dpavlin	185	LocalAddr => $server::ip,
326	dpavlin	42	LocalPort => $httpd::port,
327			Listen => SOMAXCONN,
328			Reuse => 1
329	dpavlin	43	) \|\| die "can't start server on $url: $!";
330	dpavlin	42
331			print "url $url\n";
332
333	dpavlin	118	while (1) {
334			my $client = $server->accept() \|\| next; # ALARM trickle us
335	dpavlin	42	my $request = <$client>;
336
337			warn "request $request\n" if $debug;
338
339			if ($request =~ m{^GET (/.*) HTTP/1.[01]}) {
340	dpavlin	43	my $path = $1;
341	dpavlin	42	my $param;
342	dpavlin	43	if ( $path =~ s{\?(.+)}{} ) {
343	dpavlin	42	foreach my $p ( split(/[&;]/, $1) ) {
344			my ($n,$v) = split(/=/, $p, 2);
345			$param->{$n} = $v;
346			}
347			warn "param: ",dump( $param ) if $debug;
348			}
349	dpavlin	43	get_request $client, $path, $param;
350	dpavlin	42	} else {
351			print $client "HTTP/1.0 500 No method\r\nConnection: close\r\nContent-type: text/plain\r\n\r\n500 $request";
352			warn "500 $request";
353			}
354
355	dpavlin	149	print $client menu() if $client->connected;
356	dpavlin	42
357			}
358
359			die "server died";
360			}
361
362	dpavlin	45	warn "loaded";
363
364	dpavlin	42	1;