pfSense

<?php

/*

	captiveportal.inc

	part of m0n0wall (http://m0n0.ch/wall)

	Copyright (C) 2009 Ermal Lu?i

	Copyright (C) 2003-2006 Manuel Kasper <mk@neon1.net>.

	All rights reserved.

	Redistribution and use in source and binary forms, with or without

	modification, are permitted provided that the following conditions are met:

	1. Redistributions of source code must retain the above copyright notice,

	   this list of conditions and the following disclaimer.

	2. Redistributions in binary form must reproduce the above copyright

	   notice, this list of conditions and the following disclaimer in the

	   documentation and/or other materials provided with the distribution.

	THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,

	INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY

	AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE

	AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,

	OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF

	SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS

	INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN

	CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)

	ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

	POSSIBILITY OF SUCH DAMAGE.

	This version of captiveportal.inc has been modified by Rob Parker

	<rob.parker@keycom.co.uk> to include changes for per-user bandwidth management

	via returned RADIUS attributes. This page has been modified to delete any

	added rules which may have been created by other per-user code (index.php, etc).

	These changes are (c) 2004 Keycom PLC.

	pfSense_BUILDER_BINARIES:	/sbin/ifconfig	/sbin/ipfw	/sbin/sysctl	/sbin/kldunload

	pfSense_BUILDER_BINARIES:	/usr/local/sbin/lighttpd	/usr/local/bin/minicron	/sbin/pfctl

	pfSense_BUILDER_BINARIES:	/bin/hostname	/bin/cp	

	pfSense_MODULE:	captiveportal

*/

/* include all configuration functions */

require_once("config.inc");

require_once("functions.inc");

require_once("radius.inc");

require_once("voucher.inc");

function captiveportal_configure() {

	global $config, $g;

	$captiveportallck = lock('captiveportal');

	$cpactive = false;

	if (isset($config['captiveportal']['enable'])) {

		$cpips = array();

		$ifaces = get_configured_interface_list();

		foreach ($ifaces as $kiface => $kiface2) {

			$tmpif = get_real_interface($kiface);

			mwexec("/sbin/ifconfig {$tmpif} -ipfwfilter");

		}

		$cpinterfaces = explode(",", $config['captiveportal']['interface']);

		$firsttime = 0;

		foreach ($cpinterfaces as $cpifgrp) {

			if (!isset($ifaces[$cpifgrp]))

				continue;

			$tmpif = get_real_interface($cpifgrp);

			if (!empty($tmpif)) {

				if ($firsttime > 0)

					$cpinterface .= " or ";

				$cpinterface .= "via {$tmpif}"; 

				$firsttime = 1;

				$cpipm = get_interface_ip($cpifgrp);

				if (is_ipaddr($cpipm)) {

					$carpif = link_ip_to_carp_interface($cpipm);

					if (!empty($carpif)) {

						$carpsif = explode(" ", $carpif);

						foreach ($carpsif as $cpcarp) {

							mwexec("/sbin/ifconfig {$cpcarp} ipfwfilter");

							$carpip = find_interface_ip($cpcarp);

							if (is_ipaddr($carpip))

								$cpips[] = $carpip;

						}

					}

					$cpips[] = $cpipm;

					mwexec("/sbin/ifconfig {$tmpif} ipfwfilter");

				}

			}

		}

		if (count($cpips) > 0) {

			$cpactive = true;

			$cpinterface = "{ {$cpinterface} } ";

		}

	}

	if ($cpactive == true) {

		if ($g['booting'])

			echo "Starting captive portal... ";

		/* kill any running mini_httpd */

		killbypid("{$g['varrun_path']}/lighty-CaptivePortal.pid");

		killbypid("{$g['varrun_path']}/lighty-CaptivePortal-SSL.pid");

		/* remove old information */

		unlink_if_exists("{$g['vardb_path']}/captiveportal.db");

		unlink_if_exists("{$g['vardb_path']}/captiveportal_mac.db");

		unlink_if_exists("{$g['vardb_path']}/captiveportal_ip.db");

		unlink_if_exists("{$g['vardb_path']}/captiveportal_radius.db");

		mwexec("/sbin/ipfw table all flush");

		/* setup new database in case someone tries to access the status -> captive portal page */

		touch("{$g['vardb_path']}/captiveportal.db");

		/* kill any running minicron */

		killbypid("{$g['varrun_path']}/minicron.pid");

		/* make sure ipfw is loaded */

		if (!is_module_loaded("ipfw.ko"))

			filter_load_ipfw();

		if (isset($config['captiveportal']['peruserbw']) && !is_module_loaded("dummynet.ko"))

                        mwexec("/sbin/kldload dummynet");

		/* generate ipfw rules */

		captiveportal_init_ipfw_ruleno();

		$cprules = captiveportal_rules_generate($cpinterface, $cpips);

		$cprules .= "\n";

		/* generate passthru mac database */

		captiveportal_passthrumac_configure(true);

		/* allowed ipfw rules to make allowed ip work */

		$cprules .= captiveportal_allowedip_configure();

		/* stop accounting on all clients */

		captiveportal_radius_stop_all(true);

		/* initialize minicron interval value */

		$croninterval = $config['captiveportal']['croninterval'] ? $config['captiveportal']['croninterval'] : 60;

		/* double check if the $croninterval is numeric and at least 10 seconds. If not we set it to 60 to avoid problems */

		if ((!is_numeric($croninterval)) || ($croninterval < 10)) { $croninterval = 60; }

		/* write portal page */

		if ($config['captiveportal']['page']['htmltext'])

			$htmltext = base64_decode($config['captiveportal']['page']['htmltext']);

		else {

			/* example/template page */

			$htmltext = <<<EOD

<html>

<head>

<title>{$g['product_name']} captive portal</title>

</head>

<body>

<center>

<h2>{$g['product_name']} captive portal</h2>

Welcome to the {$g['product_name']} Captive Portal!  This is the default page since a custom page has not been defined.

<p>

<form method="post" action="\$PORTAL_ACTION\$">

<input name="redirurl" type="hidden" value="\$PORTAL_REDIRURL\$">

<table>

   <tr><td>Username:</td><td><input name="auth_user" type="text"></td></tr>

   <tr><td>Password:</td><td><input name="auth_pass" type="password"></td></tr>

   <tr><td>&nbsp;</td></tr>

   <tr>

     <td colspan="2">

	<center><input name="accept" type="submit" value="Continue"></center>

     </td>

   </tr>

</table>

</center>

</form>

</body>

</html>

EOD;

		}

		$fd = @fopen("{$g['varetc_path']}/captiveportal.html", "w");

		if ($fd) {

			fwrite($fd, $htmltext);

			fclose($fd);

		}

		/* write error page */

		if ($config['captiveportal']['page']['errtext'])

			$errtext = base64_decode($config['captiveportal']['page']['errtext']);

		else {

			/* example page */

			$errtext = <<<EOD

<html>

<head>

<title>Authentication error</title>

</head>

<body>

<font color="#cc0000"><h2>Authentication error</h2></font>

<b>

Username and/or password invalid.

<br><br>

<a href="javascript:history.back(); ">Go back</a>

</b>

</body>

</html>

EOD;

		}

		$fd = @fopen("{$g['varetc_path']}/captiveportal-error.html", "w");

		if ($fd) {

			fwrite($fd, $errtext);

			fclose($fd);

		}

		/* write elements */

		captiveportal_write_elements();

		/* load rules */

		mwexec("/sbin/ipfw -q flush");

		/* ipfw cannot accept rules directly on stdin,

		   so we have to write them to a temporary file first */

		$fd = @fopen("{$g['tmp_path']}/ipfw.cp.rules", "w");

		if (!$fd) {

			printf("Cannot open ipfw.cp.rules in captiveportal_configure()\n");

			return 1;

		}

		fwrite($fd, $cprules);

		fclose($fd);

		mwexec("/sbin/ipfw {$g['tmp_path']}/ipfw.cp.rules");

		@unlink("{$g['tmp_path']}/ipfw.cp.rules");

		/* filter on layer2 as well so we can check MAC addresses */

		mwexec("/sbin/sysctl net.link.ether.ipfw=1");

		chdir($g['captiveportal_path']);

		if ($config['captiveportal']['maxproc'])

			$maxproc = $config['captiveportal']['maxproc'];

		else

			$maxproc = 16;

		$use_fastcgi = true;

		if(isset($config['captiveportal']['httpslogin'])) {

			$cert = base64_decode($config['captiveportal']['certificate']);

			if (isset($config['captiveportal']['cacertificate']))

				$cacert = base64_decode($config['captiveportal']['cacertificate']);

			else

				$cacert = "";

			$key = base64_decode($config['captiveportal']['private-key']);

			/* generate lighttpd configuration */

			system_generate_lighty_config("{$g['varetc_path']}/lighty-CaptivePortal-SSL.conf",

				$cert, $key, $cacert, "lighty-CaptivePortal-ssl.pid", "8001", "/usr/local/captiveportal/",

					"cert-portal.pem", "ca-portal.pem", "1", $maxproc, $use_fastcgi, true);

		}

		/* generate lighttpd configuration */

		system_generate_lighty_config("{$g['varetc_path']}/lighty-CaptivePortal.conf",

			"", "", "", "lighty-CaptivePortal.pid", "8000", "/usr/local/captiveportal/",

				"cert-portal.pem", "ca-portal.pem", "1", $maxproc, $use_fastcgi, true);

		/* attempt to start lighttpd */

		$res = mwexec("/usr/local/sbin/lighttpd -f {$g['varetc_path']}/lighty-CaptivePortal.conf");

		/* fire up https instance */

		if(isset($config['captiveportal']['httpslogin']))

			$res = mwexec("/usr/local/sbin/lighttpd -f {$g['varetc_path']}/lighty-CaptivePortal-SSL.conf");

		/* start pruning process (interval defaults to 60 seconds) */

		mwexec("/usr/local/bin/minicron $croninterval {$g['varrun_path']}/minicron.pid " .

			"/etc/rc.prunecaptiveportal");

		/* generate radius server database */

		if ($config['captiveportal']['radiusip'] && (!isset($config['captiveportal']['auth_method']) ||

				($config['captiveportal']['auth_method'] == "radius"))) {

			$radiusip = $config['captiveportal']['radiusip'];

			$radiusip2 = ($config['captiveportal']['radiusip2']) ? $config['captiveportal']['radiusip2'] : null;

			if ($config['captiveportal']['radiusport'])

				$radiusport = $config['captiveportal']['radiusport'];

			else

				$radiusport = 1812;

			if ($config['captiveportal']['radiusacctport'])

				$radiusacctport = $config['captiveportal']['radiusacctport'];

			else

				$radiusacctport = 1813;

			if ($config['captiveportal']['radiusport2'])

				$radiusport2 = $config['captiveportal']['radiusport2'];

			else

				$radiusport2 = 1812;

			$radiuskey = $config['captiveportal']['radiuskey'];

			$radiuskey2 = ($config['captiveportal']['radiuskey2']) ? $config['captiveportal']['radiuskey2'] : null;

			$fd = @fopen("{$g['vardb_path']}/captiveportal_radius.db", "w");

			if (!$fd) {

				printf("Error: cannot open radius DB file in captiveportal_configure().\n");

				return 1;

			} else if (isset($radiusip2, $radiuskey2)) {

				fwrite($fd,$radiusip . "," . $radiusport . "," . $radiusacctport . "," . $radiuskey . "\n"

					 . $radiusip2 . "," . $radiusport2 . "," . $radiusacctport . "," . $radiuskey2);

			} else {

				fwrite($fd,$radiusip . "," . $radiusport . "," . $radiusacctport . "," . $radiuskey);

			}

			fclose($fd);

		}

		if ($g['booting'])

			echo "done\n";

	} else {

		killbypid("{$g['varrun_path']}/lighty-CaptivePortal.pid");

		killbypid("{$g['varrun_path']}/minicron.pid");

		captiveportal_radius_stop_all(true);

		mwexec("/sbin/sysctl net.link.ether.ipfw=0");

		/* unload ipfw */

		if (is_module_loaded("ipfw.ko"))		

			mwexec("/sbin/kldunload ipfw.ko");

		$listifs = get_configured_interface_list_by_realif();

		foreach ($listifs as $listrealif => $listif) {

			if (!empty($listrealif)) {

				mwexec("/sbin/ifconfig {$listrealif} -ipfwfilter");

				$carpif = link_ip_to_carp_interface(find_interface_ip($listrealif));

                        	if (!empty($carpif)) {

					$carpsif = explode(" ", $carpif);

					foreach ($carpsif as $cpcarp)

						mwexec("/sbin/ifconfig {$cpcarp} -ipfwfilter");

				}

			}

		}

	}

	unlock($captiveportallck);

	return 0;

}

function captiveportal_rules_generate($cpif, &$cpiparray) {

	global $config, $g;

	$cprules =  "add 65301 set 1 allow pfsync from any to any\n";

	$cprules .= "add 65302 set 1 allow carp from any to any\n";

	$cprules .= <<<EOD

# add 65305 set 1 skipto 65534 all from any to any not layer2

# layer 2: pass ARP

add 65310 set 1 pass layer2 mac-type arp

# pfsense requires for WPA

add 65311 set 1 pass layer2 mac-type 0x888e

add 65312 set 1 pass layer2 mac-type 0x88c7

# PPP Over Ethernet Discovery Stage

add 65313 set 1 pass layer2 mac-type 0x8863

# PPP Over Ethernet Session Stage

add 65314 set 1 pass layer2 mac-type 0x8864

# Allow WPA

add 65315 set 1 pass layer2 mac-type 0x888e

# layer 2: block anything else non-IP

add 65316 set 1 deny layer2 not mac-type ip

EOD;

	$rulenum = 65320;

	$ips = "255.255.255.255 ";

	foreach ($cpiparray as $cpip)

		$ips .= "or {$cpip} ";

	$ips = "{ {$ips} }";

	//# allow access to our DHCP server (which needs to be able to ping clients as well)

	$cprules .= "add {$rulenum} set 1 pass udp from any 68 to {$ips} 67 in \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass udp from any 68 to {$ips} 67 in \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass udp from {$ips} 67 to any 68 out \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass icmp from {$ips} to any out icmptype 0\n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass icmp from any to {$ips} in icmptype 8 \n";

	$rulenum++;

	//# allow access to our DNS forwarder

	$cprules .= "add {$rulenum} set 1 pass udp from any to {$ips} 53 in \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass udp from {$ips} 53 to any out \n";

	$rulenum++;

	# allow access to our web server

	$cprules .= "add {$rulenum} set 1 pass tcp from any to {$ips} 8000 in \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass tcp from {$ips} 8000 to any out \n";

	if (isset($config['captiveportal']['httpslogin'])) {

		$rulenum++;

		$cprules .= "add {$rulenum} set 1 pass tcp from any to {$ips} 8001 in \n";

		$rulenum++;

		$cprules .= "add {$rulenum} set 1 pass tcp from {$ips} 8001 to any out \n";

	}

	if (!empty($config['system']['webgui']['port']))

		$port = $config['system']['webgui']['port'];

	else if ($config['system']['webgui']['proto'] == "https")

		$port = 443;

	else

		$port = 80;

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass tcp from any to {$ips} {$port} in \n";

	$rulenum++;

	$cprules .= "add {$rulenum} set 1 pass tcp from {$ips} {$port} to any out \n";

	$rulenum++;

	if (isset($config['captiveportal']['peruserbw'])) {

		$cprules .= "add {$rulenum} set 1 pipe tablearg ip from table(1) to any in\n";

		$rulenum++;

		$cprules .= "add {$rulenum} set 1 pipe tablearg ip from any to table(2) out\n";

		$rulenum++;

	} else {

		$cprules .= "add {$rulenum} set 1 allow ip from table(1) to any in\n";

                $rulenum++;

                $cprules .= "add {$rulenum} set 1 allow ip from any to table(2) out\n";

                $rulenum++;

	}

       $cprules .= <<<EOD

# redirect non-authenticated clients to captive portal

add 65531 set 1 fwd 127.0.0.1,8000 tcp from any to any in

# let the responses from the captive portal web server back out

add 65532 set 1 pass tcp from any to any out

# block everything else

add 65533 set 1 deny all from any to any

# pass everything else on layer2

add 65534 set 1 pass all from any to any layer2

EOD;

    return $cprules;

}

/* remove clients that have been around for longer than the specified amount of time */

/* db file structure:

timestamp,ipfw_rule_no,clientip,clientmac,username,sessionid,password,session_timeout,idle_timeout,session_terminate_time */

/* (password is in Base64 and only saved when reauthentication is enabled) */

function captiveportal_prune_old() {

    global $g, $config;

    /* check for expired entries */

    if ($config['captiveportal']['timeout'])

        $timeout = $config['captiveportal']['timeout'] * 60;

    else

        $timeout = 0;

    if ($config['captiveportal']['idletimeout'])

        $idletimeout = $config['captiveportal']['idletimeout'] * 60;

    else

        $idletimeout = 0;

    if (!$timeout && !$idletimeout && !isset($config['captiveportal']['reauthenticate']) && 

		!isset($config['captiveportal']['radiussession_timeout']) && !isset($config['voucher']['enable']))

        return;

    $captiveportallck = lock('captiveportal');

    /* read database */

    $cpdb = captiveportal_read_db();

    $radiusservers = captiveportal_get_radius_servers();

    /*  To make sure we iterate over ALL accounts on every run the count($cpdb) is moved

     *  outside of the loop. Otherwise the loop would evaluate count() on every iteration

     *  and since $i would increase and count() would decrement they would meet before we

     *  had a chance to iterate over all accounts.

     */

    $unsetindexes = array();

    $no_users = count($cpdb);

    for ($i = 0; $i < $no_users; $i++) {

        $timedout = false;

        $term_cause = 1;

        /* hard timeout? */

        if ($timeout) {

            if ((time() - $cpdb[$i][0]) >= $timeout) {

                $timedout = true;

                $term_cause = 5; // Session-Timeout

            }

        }

        /* Session-Terminate-Time */

        if (!$timedout && !empty($cpdb[$i][9])) {

            if (time() >= $cpdb[$i][9]) {

                $timedout = true;

                $term_cause = 5; // Session-Timeout

            }

        }

        /* check if the radius idle_timeout attribute has been set and if its set change the idletimeout to this value */

        $idletimeout = (is_numeric($cpdb[$i][8])) ? $cpdb[$i][8] : $idletimeout;

        /* if an idle timeout is specified, get last activity timestamp from ipfw */

        if (!$timedout && $idletimeout) {

            $lastact = captiveportal_get_last_activity($cpdb[$i][2]);

			/*  If the user has logged on but not sent any traffic they will never be logged out.

			 *  We "fix" this by setting lastact to the login timestamp. 

			 */

			$lastact = $lastact ? $lastact : $cpdb[$i][0];

            if ($lastact && ((time() - $lastact) >= $idletimeout)) {

                $timedout = true;

                $term_cause = 4; // Idle-Timeout

                $stop_time = $lastact; // Entry added to comply with WISPr

            }

        }

	/* if vouchers are configured, activate session timeouts */

	if (!$timedout && isset($config['voucher']['enable']) && !empty($cpdb[$i][7])) {

		if (time() >= ($cpdb[$i][0] + $cpdb[$i][7])) {

			$timedout = true;

			$term_cause = 5; // Session-Timeout

		}

	}

        /* if radius session_timeout is enabled and the session_timeout is not null, then check if the user should be logged out */

        if (!$timedout && isset($config['captiveportal']['radiussession_timeout']) && !empty($cpdb[$i][7])) {

            if (time() >= ($cpdb[$i][0] + $cpdb[$i][7])) {

                $timedout = true;

                $term_cause = 5; // Session-Timeout

            }

        }

        if ($timedout) {

            captiveportal_disconnect($cpdb[$i], $radiusservers,$term_cause,$stop_time);

            captiveportal_logportalauth($cpdb[$i][4], $cpdb[$i][3], $cpdb[$i][2], "TIMEOUT");

	    $unsetindexes[$i] = $i;

        }

        /* do periodic RADIUS reauthentication? */

        if (!$timedout && isset($config['captiveportal']['reauthenticate']) &&

            !empty($radiusservers)) {

            if (isset($config['captiveportal']['radacct_enable'])) {

                if ($config['captiveportal']['reauthenticateacct'] == "stopstart") {

                    /* stop and restart accounting */

                    RADIUS_ACCOUNTING_STOP($cpdb[$i][1], // ruleno

                                           $cpdb[$i][4], // username

                                           $cpdb[$i][5], // sessionid

                                           $cpdb[$i][0], // start time

                                           $radiusservers,

                                           $cpdb[$i][2], // clientip

                                           $cpdb[$i][3], // clientmac

                                           10); // NAS Request

                    exec("/sbin/ipfw table 1 entryzerostats {$cpdb[$i][2]}");

                    exec("/sbin/ipfw table 2 entryzerostats {$cpdb[$i][2]}");

                    RADIUS_ACCOUNTING_START($cpdb[$i][1], // ruleno

                                            $cpdb[$i][4], // username

                                            $cpdb[$i][5], // sessionid

                                            $radiusservers,

                                            $cpdb[$i][2], // clientip

                                            $cpdb[$i][3]); // clientmac

                } else if ($config['captiveportal']['reauthenticateacct'] == "interimupdate") {

                    RADIUS_ACCOUNTING_STOP($cpdb[$i][1], // ruleno

                                           $cpdb[$i][4], // username

                                           $cpdb[$i][5], // sessionid

                                           $cpdb[$i][0], // start time

                                           $radiusservers,

                                           $cpdb[$i][2], // clientip

                                           $cpdb[$i][3], // clientmac

                                           10, // NAS Request

                                           true); // Interim Updates

                }

            }

            /* check this user against RADIUS again */

            $auth_list = RADIUS_AUTHENTICATION($cpdb[$i][4], // username

                                          base64_decode($cpdb[$i][6]), // password

                                            $radiusservers,

                                          $cpdb[$i][2], // clientip

                                          $cpdb[$i][3], // clientmac

                                          $cpdb[$i][1]); // ruleno

            if ($auth_list['auth_val'] == 3) {

                captiveportal_disconnect($cpdb[$i], $radiusservers, 17);

                captiveportal_logportalauth($cpdb[$i][4], $cpdb[$i][3], $cpdb[$i][2], "RADIUS_DISCONNECT", $auth_list['reply_message']);

	        $unsetindexes[$i] = $i;

            }

        }

    }

    /* This is a kludge to overcome some php weirdness */

    foreach($unsetindexes as $unsetindex)

	unset($cpdb[$unsetindex]);

    /* write database */

    captiveportal_write_db($cpdb);

    unlock($captiveportallck);

}

/* remove a single client according to the DB entry */

function captiveportal_disconnect($dbent, $radiusservers,$term_cause = 1,$stop_time = null) {

	global $g, $config;

	$stop_time = (empty($stop_time)) ? time() : $stop_time;

	/* this client needs to be deleted - remove ipfw rules */

	if (isset($config['captiveportal']['radacct_enable']) && !empty($radiusservers)) {

		RADIUS_ACCOUNTING_STOP($dbent[1], // ruleno

							   $dbent[4], // username

							   $dbent[5], // sessionid

							   $dbent[0], // start time

							   $radiusservers,

							   $dbent[2], // clientip

							   $dbent[3], // clientmac

							   $term_cause, // Acct-Terminate-Cause

							   false,

							   $stop_time);

	}

	/* Delete client's ip entry from tables 3 and 4. */

	mwexec("/sbin/ipfw table 1 delete {$dbent[2]}");

	mwexec("/sbin/ipfw table 2 delete {$dbent[2]}");

	/* Release the ruleno so it can be reallocated to new clients. */

	captiveportal_free_ipfw_ruleno($dbent[1]);

	/* 

	* These are the pipe numbers we use to control traffic shaping for each logged in user via captive portal

	* We could get an error if the pipe doesn't exist but everything should still be fine

	*/

	if (isset($config['captiveportal']['peruserbw'])) {

		mwexec("/sbin/ipfw pipe " . ($dbent[1]+20000) . " delete");

		mwexec("/sbin/ipfw pipe " . ($dbent[1]+20001) . " delete");

	}

	/* XXX: Redundant?! Ensure all pf(4) states are killed. */

	mwexec("pfctl -k {$dbent[2]}");

	mwexec("pfctl -K {$dbent[2]}");

}

/* remove a single client by ipfw rule number */

function captiveportal_disconnect_client($id,$term_cause = 1) {

	global $g, $config;

	$captiveportallck = lock('captiveportal');

	/* read database */

	$cpdb = captiveportal_read_db();

	$radiusservers = captiveportal_get_radius_servers();

	/* find entry */

	$tmpindex = 0;

	$cpdbcount = count($cpdb);

	for ($i = 0; $i < $cpdbcount; $i++) {

		if ($cpdb[$i][1] == $id) {

			captiveportal_disconnect($cpdb[$i], $radiusservers, $term_cause);

			captiveportal_logportalauth($cpdb[$i][4], $cpdb[$i][3], $cpdb[$i][2], "DISCONNECT");

			unset($cpdb[$i]);

			break;

		}

	}		

	/* write database */

	captiveportal_write_db($cpdb);

	unlock($captiveportallck);

}

/* send RADIUS acct stop for all current clients */

function captiveportal_radius_stop_all($lock = false) {

	global $g, $config;

	if (!isset($config['captiveportal']['radacct_enable']))

		return;

	if (!$lock)

		$captiveportallck = lock('captiveportal');

	$cpdb = captiveportal_read_db();

	$radiusservers = captiveportal_get_radius_servers();

	if (!empty($radiusservers)) {

		for ($i = 0; $i < count($cpdb); $i++) {

			RADIUS_ACCOUNTING_STOP($cpdb[$i][1], // ruleno

								   $cpdb[$i][4], // username

								   $cpdb[$i][5], // sessionid

								   $cpdb[$i][0], // start time

								   $radiusservers,

								   $cpdb[$i][2], // clientip

								   $cpdb[$i][3], // clientmac

								   7); // Admin Reboot

		}

	}

	if (!$lock)

		unlock($captiveportallck);

}

function captiveportal_passthrumac_configure($lock = false) {

	global $config, $g;

	if (!$lock)

		$captiveportallck = lock('captiveportal');

	/* clear out passthru macs, if necessary */

	unlink_if_exists("{$g['vardb_path']}/captiveportal_mac.db");

	if (is_array($config['captiveportal']['passthrumac'])) {

		$macdb = array();

		foreach ($config['captiveportal']['passthrumac'] as $macent) {

			$macdb[$macent['mac']]['active']  = true;

			if (isset($macent['bw_up']))

				$macdb[$macent['mac']]['bw_up']  = $macent['bw_up'];

			if (isset($macent['bw_down']))

				$macdb[$macent['mac']]['bw_down']  = $macent['bw_down'];

		}

		/* record passthru MACs so can be recognized and let thru */

		file_put_contents("{$g['vardb_path']}/captiveportal_mac.db", serialize($macdb));

	}

	if (!$lock)

		unlock($captiveportallck);

}

function captiveportal_allowedip_configure() {

	global $config, $g;

	$rules = "";

	if (is_array($config['captiveportal']['allowedip'])) {

		$peruserbw = isset($config['captiveportal']['peruserbw']);

		foreach ($config['captiveportal']['allowedip'] as $ipent) {

                	$ruleno = captiveportal_get_next_ipfw_ruleno();

			$bw_up = "";

			$bw_down = "";

                        if ($peruserbw) {

                                $bwup = isset($ipent['bw_up']) ? trim($ipent['bw_up']) : $config['captiveportal']['bwdefaultup'];

                                $bwdown = isset($ipent['bw_down']) ? trim($ipent['bw_down']) : $config['captiveportal']['bwdefaultdn'];

                                if (!empty($bwup) && is_numeric($bwup)) {

                                        $bw_up = $ruleno + 20000;

                                        $rules .= "pipe {$bw_up} config bw {$bw_up}Kbit/s queue 100\n";

                                }

                                if (!empty($bwdown) && is_numeric($bwdown)) {

                                        $bw_down = $ruleno + 20001;

                                        $rules .= "pipe {$bw_down} config bw {$bw_down}Kbit/s queue 100\n";

                                }

                        }

			/* insert address in ipfw table */

			$rules .= "table 1 add {$ipent['ip']} ${bw_up}\n";

			$rules .= "table 2 add {$ipent['ip']} ${bw_down}\n";

		}

	}

	return $rules;

}

/* get last activity timestamp given client IP address */

function captiveportal_get_last_activity($ip) {

	$ipfwoutput = "";

	exec("/sbin/ipfw table 1 entrystats {$ip} 2>/dev/null", $ipfwoutput);

	/* Reading only from one of the tables is enough of approximation. */

	if ($ipfwoutput[0]) {

		$ri = explode(" ", $ipfwoutput[0]);

		if ($ri[4])

			return $ri[4];

	}

	return 0;

}

/* read RADIUS servers into array */

function captiveportal_get_radius_servers() {

        global $g;

        if (file_exists("{$g['vardb_path']}/captiveportal_radius.db")) {

                $radiusservers = array();

		$cpradiusdb = file("{$g['vardb_path']}/captiveportal_radius.db", 

			FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);

		if ($cpradiusdb)

		foreach($cpradiusdb as $cpradiusentry) {

                	$line = trim($cpradiusentry);

                        if ($line) {

                        	$radsrv = array();

                                list($radsrv['ipaddr'],$radsrv['port'],$radsrv['acctport'],$radsrv['key']) = explode(",",$line);

                        	$radiusservers[] = $radsrv;

                        }

		}

		return $radiusservers;

        }

        return false;

}

/* log successful captive portal authentication to syslog */

/* part of this code from php.net */

function captiveportal_logportalauth($user,$mac,$ip,$status, $message = null) {

	$message = trim($message);

	// Log it

	if (!$message)

		$message = "$status: $user, $mac, $ip";

	else

		$message = "$status: $user, $mac, $ip, $message";

	captiveportal_syslog($message);

	closelog();

}

/* log simple messages to syslog */

function captiveportal_syslog($message) {

	define_syslog_variables();

	$message = trim($message);

	openlog("logportalauth", LOG_PID, LOG_LOCAL4);

	// Log it

	syslog(LOG_INFO, $message);

	closelog();