928 lines
24 KiB
PHP
928 lines
24 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Viewdata/Videotex Server
|
|
*
|
|
* Inspired by Rob O'Donnell at irrelevant.com
|
|
*/
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Classes\Frame;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Database\Eloquent\ModelNotFoundException;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Sock\{SocketClient,SocketServer,SocketException};
|
|
|
|
class Server extends Command
|
|
{
|
|
// @todo Understand how is this used.
|
|
private $fieldoptions = ['f'=>['edit'=>TRUE],'a'=>['edit'=>TRUE]];
|
|
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'server';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Start Videotex Server';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return mixed
|
|
* @throws \Sock\SocketException
|
|
*/
|
|
public function handle()
|
|
{
|
|
/**
|
|
* Check dependencies
|
|
*/
|
|
if (! extension_loaded('sockets' ) ) {
|
|
throw new SocketException(SocketException::CANT_ACCEPT,'Missing sockets extension');
|
|
}
|
|
|
|
if (! extension_loaded('pcntl' ) ) {
|
|
throw new SocketException(SocketException::CANT_ACCEPT,'Missing pcntl extension');
|
|
}
|
|
|
|
// @todo Deprecate this function
|
|
define('MSG_TIMEWARP_ON', WHITE . 'TIMEWARP ON' . GREEN . 'VIEW INFO WITH *02');
|
|
define('MSG_TIMEWARP_OFF', WHITE . 'TIMEWARP OFF' . GREEN . 'VIEWING DATE IS FIXED');
|
|
define('MSG_TIMEWARP_TO', GREEN . 'TIMEWARP TO %s');
|
|
define('MSG_TIMEWARP', WHITE . 'OTHER VERSIONS EXIST' . GREEN . 'KEY *02 TO VIEW');
|
|
|
|
// @todo Deprecate this
|
|
include_once('classes/vvdatabase.class.php');
|
|
|
|
$server = new SocketServer(config('app.port'),config('app.bind'));
|
|
$server->init();
|
|
$server->setConnectionHandler([$this,'onConnect']);
|
|
$server->listen();
|
|
}
|
|
|
|
/**
|
|
* Connection handler
|
|
*/
|
|
function onConnect(SocketClient $client) {
|
|
Log::info('Connection from: ',['client'=>$client->getAddress()]);
|
|
|
|
// @todo To Deprecate in favour of config()
|
|
global $config;
|
|
include ('config/config.php');
|
|
|
|
$childpid = pcntl_fork();
|
|
|
|
if ($childpid == -1)
|
|
throw new SocketException(SocketException::CANT_ACCEPT,'Could not fork process');
|
|
|
|
// Parent return ready for next connection
|
|
elseif ($childpid)
|
|
return;
|
|
|
|
// We are now the child.
|
|
// @todo Need to intercept any crashes and close the TCP port.
|
|
|
|
$session_init = $session_option = FALSE;
|
|
$session_note = ''; // TCP Session Notice
|
|
$session_term = ''; // TCP Terminal Type
|
|
|
|
$client->send(TCP_IAC.TCP_DO.TCP_OPT_SUP_GOAHEAD); // DO SUPPRES GO AHEAD
|
|
$client->send(TCP_IAC.TCP_WONT.TCP_OPT_LINEMODE); // WONT LINEMODE
|
|
$client->send(TCP_IAC.TCP_DO.TCP_OPT_ECHO); // DO ECHO
|
|
// $client->send(TCP_IAC.TCP_AYT); // AYT
|
|
$client->send(TCP_IAC.TCP_DO.TCP_OPT_TERMTYPE.TCP_IAC.TCP_SB.TCP_OPT_TERMTYPE.TCP_OPT_ECHO.TCP_IAC.TCP_SE); // Request Term Type
|
|
|
|
$client->send(CLS);
|
|
$read = '';
|
|
|
|
// @todo Deprecate and have an exception handler handle this.
|
|
// like throw new FatalClientException(CLS.UP.ERR_DATABASE,500,NULL,$client);
|
|
|
|
// @todo Get the login page, and if it is not available, throw the ERR_DATEBASE error.
|
|
|
|
$db = new \vvdb();
|
|
// Connect to database. Returns error message if unable to connect.
|
|
$r = $db->connect($config['dbserver'],$config['database'],$config['dbuser'], $config['dbpass']);
|
|
/*
|
|
if (!empty($r)) {
|
|
http_response_code(500);
|
|
$client->send(CLS . UP . ERR_DATABASE);
|
|
die ($r);
|
|
}
|
|
*/
|
|
|
|
// $user will eventually contain validated user details.
|
|
$user = array( 'systel' => '019990001',
|
|
'username' => 'DEMONSTRATION DATA USER',
|
|
'address1' => '8 HERBAL HILL',
|
|
'address2' => 'LONDON',
|
|
'address3' => 'EC1R 5EJ',
|
|
'address4' => '',
|
|
'address5' => '',
|
|
'CUGS' => array( 7800, 15500), // Closed User Groups this user has access to
|
|
);
|
|
|
|
$history = array(); // backup history
|
|
|
|
$cmd = ''; // current *command being typed in
|
|
$mode = false; // input mode.
|
|
$prevmode = false; // previous mode
|
|
$timewarp = false;
|
|
$action = ACTION_GOTO; // do something if set. used here to trigger a goto to the login form.
|
|
if (isset($config['loginpage'])) {
|
|
$page = $config['loginpage'];
|
|
$subpage = 'a';
|
|
} else if (!empty($service['start_page'])) {
|
|
$page = $service['start_page'];
|
|
$subpage = 'a';
|
|
} else {
|
|
$page = '999'; // next page
|
|
$subpage = 'a';
|
|
}
|
|
$curpage = ''; // current page
|
|
$cursub = '';
|
|
$curfield = null; // current input field
|
|
$curfp = 0; // current field, position within.
|
|
$blp = 0; // botton line polluted (by this no. of characters)
|
|
$resetpsn = false; // flag to reset position (used in fields)
|
|
|
|
if (! isset($config['varient_id']))
|
|
$config['varient_id'] = NULL;
|
|
$service = $db->getServiceById($config['service_id']);
|
|
//dd($service);
|
|
$varient = $db->getAllVarients($config['service_id'], $config['varient_id']);
|
|
if ($varient === false) {
|
|
die ("no varient");
|
|
}
|
|
$varient = reset($varient);
|
|
|
|
|
|
$matches = array();
|
|
if (preg_match('@'.$service['page_format'].'@',$service['start_frame'],$matches)) {
|
|
$page = $matches[1];
|
|
$subpage = $matches[2];
|
|
echo " Using start page ".$page.$subpage."\n";
|
|
}
|
|
// $start = $service['start_frame'];
|
|
// where to start from
|
|
|
|
while( $action != ACTION_TERMINATE ) {
|
|
// Read a character from the client session
|
|
$read = $client->read(1);
|
|
|
|
if ($read != '') {
|
|
dump(sprintf('Mode: [%s] CMD: [%s] frame: [%s] Received [%s (%s)]',$mode,$cmd,$page,$read,ord($read)));
|
|
|
|
// Client initiation input
|
|
// TELNET http://pcmicro.com/netfoss/telnet.html
|
|
if ($read == TCP_IAC OR $session_init OR $session_option)
|
|
{
|
|
Log::debug(sprintf('Session Char (%s)',ord($read)),['init'=>$session_init,'option'=>$session_option]);
|
|
|
|
switch ($read) {
|
|
// Command being sent.
|
|
case TCP_IAC:
|
|
$session_init = TRUE;
|
|
$session_note = 'IAC ';
|
|
|
|
continue 2;
|
|
|
|
case TCP_SB:
|
|
$session_option = TRUE;
|
|
|
|
continue 2;
|
|
|
|
case TCP_SE:
|
|
$session_option = $session_init = FALSE;
|
|
Log::debug('Session Terminal: '.$session_term);
|
|
|
|
break;
|
|
|
|
case TCP_DO:
|
|
$session_note .= 'DO ';
|
|
|
|
continue 2;
|
|
|
|
case TCP_WILL:
|
|
$session_note .= 'WILL ';
|
|
|
|
continue 2;
|
|
|
|
case TCP_WONT:
|
|
$session_note .= 'WONT ';
|
|
|
|
continue 2;
|
|
|
|
case TCP_OPT_TERMTYPE:
|
|
|
|
continue 2;
|
|
|
|
case TCP_OPT_ECHO:
|
|
$session_note .= 'ECHO';
|
|
$session_init = FALSE;
|
|
$read = '';
|
|
Log::debug($session_note);
|
|
|
|
continue;
|
|
|
|
case TCP_OPT_SUP_GOAHEAD:
|
|
$session_note .= 'SUPPRESS GO AHEAD';
|
|
$session_init = FALSE;
|
|
$read = '';
|
|
Log::debug($session_note);
|
|
|
|
continue;
|
|
|
|
default:
|
|
if ($session_option AND $read) {
|
|
$session_term .= $read;
|
|
$read = '';
|
|
|
|
} else {
|
|
Log::debug(sprintf('Unhandled char in session_init :%s (%s)',$read,ord($read)));
|
|
}
|
|
}
|
|
}
|
|
|
|
switch($mode){
|
|
// Key presses during field input.
|
|
case MODE_FIELD:
|
|
//dump(sprintf('** Processing Keypress in MODE_FIELD [%s (%s)]. Last POS [%s]',$read,ord($read),$curfp));
|
|
$cmd = '';
|
|
$action = FALSE;
|
|
|
|
switch ($fo->type()) {
|
|
// Input frame.
|
|
case 'a':
|
|
switch ($read) {
|
|
// End of field entry.
|
|
case HASH:
|
|
// Next Field
|
|
$curfield++;
|
|
|
|
//dump(['current'=>$curfield, 'numfields'=>count($fields)]);
|
|
|
|
if ($curfield < count($fields)) { // skip past non-editable fields
|
|
for ($i = $curfield; $i < count($fields); $i++) {
|
|
if (isset($this->fieldoptions[$fields[$i]['type']]) &&
|
|
$this->fieldoptions[$fields[$i]['type']]['edit']) {
|
|
$curfield = $i;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if ($curfield !== false) {
|
|
$client->send(outputPosition($fields[$curfield]['x'],$fields[$curfield]['y']).CON);
|
|
$mode = MODE_FIELD;
|
|
$fielddate[$curfield] = '';
|
|
|
|
} else {
|
|
// there were no (more) editable fields.
|
|
$action = ACTION_SUBMITRF;
|
|
}
|
|
|
|
} else {
|
|
// done them all editable fields.
|
|
$action = ACTION_SUBMITRF;
|
|
}
|
|
break;
|
|
|
|
case STAR:
|
|
$prevmode = MODE_FIELD;
|
|
$action = ACTION_STAR;
|
|
break;
|
|
|
|
case KEY_LEFT:
|
|
if ($curfp) {
|
|
$client->send(LEFT);
|
|
$curfp--;
|
|
};
|
|
break;
|
|
|
|
case KEY_RIGHT:
|
|
if ($curfp++ < $fields[$curfield]['length']) {
|
|
$client->send(RIGHT);
|
|
//$curfp++;
|
|
};
|
|
break;
|
|
|
|
case KEY_DOWN:
|
|
if ($curfp + 40 < $fields[$curfield]['length']) {
|
|
$client->send(DOWN);
|
|
$curfp = $curfp + 40;
|
|
};
|
|
break;
|
|
|
|
case KEY_UP:
|
|
if ($curfp - 40 >= 0) {
|
|
$client->send($read);
|
|
$curfp = $curfp - 40;
|
|
};
|
|
break;
|
|
|
|
case CR:
|
|
if ($curfp + $fields[$curfield]['x'] > 40) { // on second or later line of a field
|
|
$client->send($read);
|
|
$curfp = (($curfp + $fields[$curfield]['x'])%40)*40;
|
|
} else {
|
|
$client->send(outputPosition($fields[$curfield]['x'],$fields[$curfield]['y']).CON);
|
|
$curfp = 0;
|
|
}
|
|
break;
|
|
|
|
case ESC:
|
|
break; ;
|
|
|
|
// Record Data Entry
|
|
default:
|
|
if (ord($read) > 31 && $curfp < $fields[$curfield]['length']) {
|
|
$fielddata[$curfield]{$curfp} = $read;
|
|
$curfp++;
|
|
$client->send($read);
|
|
}
|
|
}
|
|
|
|
break;
|
|
|
|
// Other Frame Types - Shouldnt get here.
|
|
default:
|
|
throw new \Exception('Shouldnt get here',500);
|
|
|
|
} // switch frame types
|
|
|
|
break;
|
|
|
|
// Form submission: 1 to send, 2 not to send.
|
|
case MODE_SUBMITRF:
|
|
switch($read){
|
|
// @todo Input received, process it.
|
|
case '1':
|
|
dump(['s'=>$service,'f'=>$fielddata]);
|
|
if(TRUE) {
|
|
sendBaseline($client, $blp, MSG_SENT);
|
|
$mode = MODE_RFSENT;
|
|
} else {
|
|
sendBaseline($client, $blp, ERR_NOTSENT);
|
|
$mode = MODE_RFERROR;
|
|
}
|
|
break;
|
|
case '2':
|
|
|
|
sendBaseline($client, $blp, MSG_NOTSENT);;
|
|
$mode = MODE_RFNOTSENT;
|
|
break;
|
|
|
|
case STAR:
|
|
$action = ACTION_STAR;
|
|
break;
|
|
|
|
}
|
|
break;
|
|
|
|
// Response form after Sent processing
|
|
// @todo To fix.
|
|
case MODE_RFSENT:
|
|
$client->send(COFF);
|
|
|
|
if ($read == HASH) {
|
|
if (!empty($pagedata['route1'])) {
|
|
$action = ACTION_GOTO;
|
|
$page = $pagedata['route1'];
|
|
$subpage = 'a';
|
|
|
|
} else if ($r = $db->getFrame($service['service_id'],$varient['varient_id'],$page,chr(1+ord($subpage)))) {
|
|
$action = ACTION_GOTO;
|
|
$page = $curpage;
|
|
$subpage = chr(1+ord($subpage));
|
|
|
|
} else if (!empty($pagedata['route0'])) {
|
|
$action = ACTION_GOTO;
|
|
$page = $pagedata['route0'];
|
|
$subpage = 'a';
|
|
|
|
// No further routes defined, go home.
|
|
} else {
|
|
$action = ACTION_GOTO;
|
|
$page = '0';
|
|
$subpage = 'a';
|
|
}
|
|
|
|
} elseif ($read == STAR) {
|
|
$action = ACTION_STAR;
|
|
|
|
break;
|
|
}
|
|
|
|
break;
|
|
|
|
// Response form after NOT sending
|
|
case MODE_RFNOTSENT:
|
|
|
|
// Response form ERROR
|
|
// @todo To fix
|
|
case MODE_RFERROR:
|
|
$client->send(COFF);
|
|
|
|
if ($read == HASH) {
|
|
if (!empty($pagedata['route2'])) {
|
|
$action = ACTION_GOTO;
|
|
$page = $pagedata['route2'];
|
|
$subpage = 'a';
|
|
|
|
} else if ($r = $db->getFrame($service['service_id'],$varient['varient_id'],$page,chr(1+ord($subpage)))) {
|
|
$action = ACTION_GOTO;
|
|
$page = $curpage;
|
|
$subpage = chr(1+ord($subpage));
|
|
|
|
} else if (!empty($pagedata['route0'])) {
|
|
$action = ACTION_GOTO;
|
|
$page = $pagedata['route0'];
|
|
$subpage = 'a';
|
|
|
|
// No further routes defined, go home.
|
|
} else {
|
|
$action = ACTION_GOTO;
|
|
$page = '0';
|
|
$subpage = 'a';
|
|
}
|
|
|
|
} else if ($read == STAR) {
|
|
$action = ACTION_STAR;
|
|
|
|
break;
|
|
}
|
|
|
|
break;
|
|
|
|
/*
|
|
List of alternate options has been presented
|
|
*/
|
|
|
|
case MODE_WARPTO: // expecting a timewarp selection
|
|
if (isset($alts[$read - 1 ])) {
|
|
$v = $db->getAllVarients($config['service_id'], $alts[$read - 1]['varient_id']);
|
|
if (!empty($v)) {
|
|
$varient = reset($v);
|
|
$page = $curpage;
|
|
$subpage = $cursub;
|
|
$action = ACTION_GOTO;
|
|
break;
|
|
}
|
|
}
|
|
// if wasn't a valid warpto keypress,
|
|
//drop into
|
|
|
|
// Not doing anything in particular.
|
|
case FALSE:
|
|
$cmd = '';
|
|
Log::debug('Idle',['pid'=>'TBA']);
|
|
|
|
switch ($read) {
|
|
case HASH:
|
|
$action = ACTION_NEXT;
|
|
break;
|
|
|
|
case STAR:
|
|
$action = ACTION_STAR;
|
|
break;
|
|
|
|
// Frame Routing
|
|
case '0':
|
|
case '1':
|
|
case '2':
|
|
case '3':
|
|
case '4':
|
|
case '5':
|
|
case '6':
|
|
case '7':
|
|
case '8':
|
|
case '9':
|
|
if (isset($pagedata['route' . $read]) && $pagedata['route' . $read] != '*') {
|
|
$action = ACTION_GOTO;
|
|
$page = $pagedata['route' . $read];
|
|
$subpage = 'a';
|
|
break;
|
|
} else {
|
|
sendBaseline($client, $blp, ERR_ROUTE);
|
|
$mode = $action = false;
|
|
}
|
|
break;
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
/*
|
|
currently accepting baseline imput after a * was received
|
|
*/
|
|
|
|
case MODE_BL: // entering a baseline command
|
|
echo "was waiting for page number\n";
|
|
// if it's a number, continue entry
|
|
if (strpos('0123456789',$read) !== false) { // numeric
|
|
$cmd .= $read;
|
|
$client->send($read);
|
|
$blp++;
|
|
}
|
|
// if we hit a special numeric command, deal with it.
|
|
if ($cmd === '00') { // refresh page
|
|
$client->send(COFF);
|
|
$action = ACTION_RELOAD;
|
|
$cmd = '';
|
|
break;
|
|
}
|
|
if ($cmd === '09') { // reload page
|
|
$client->send(COFF);
|
|
$action = ACTION_GOTO;
|
|
$cmd = '';
|
|
break;
|
|
|
|
}
|
|
if ($cmd === '02') { // new for emulator
|
|
$client->send(COFF);
|
|
$action = ACTION_INFO;
|
|
$cmd = '';
|
|
break;
|
|
}
|
|
if (($cmd === '01')) { // new for emulator
|
|
$client->send(COFF);
|
|
$timewarp = !$timewarp;
|
|
sendBaseline($client, $blp,
|
|
( $timewarp ? MSG_TIMEWARP_ON : MSG_TIMEWARP_OFF));
|
|
$cmd = '';
|
|
$action = $mode = false;
|
|
}
|
|
// another star aborts the command.
|
|
if ($read === "*") { // abort command or reset input field.
|
|
$action = false;
|
|
sendBaseline($client, $blp, '');
|
|
$cmd = '';
|
|
|
|
if ($prevmode == MODE_FIELD) {
|
|
$mode = $prevmode;
|
|
$prevmode = false;
|
|
$client->send(outputPosition($fields[$curfield]['x'],$fields[$curfield]['y']).CON);
|
|
$client->send(str_repeat(' ',$fields[$curfield]['length']));
|
|
// tood reset stored entered text
|
|
$resetpsn = $curfield;
|
|
} else {
|
|
$mode = false;
|
|
}
|
|
break;
|
|
}
|
|
// user hit # to complete request
|
|
if ($read === '_') { // really the # key,
|
|
$client->send(COFF);
|
|
if ($cmd === '') { // nothing typed between * and #
|
|
$action = ACTION_BACKUP;
|
|
} else { // *# means go back
|
|
$page = $cmd;
|
|
$subpage = 'a';
|
|
$action = ACTION_GOTO;
|
|
}
|
|
$cmd = ''; // finished with this now
|
|
break;
|
|
}
|
|
break;
|
|
|
|
|
|
default:
|
|
echo "not sure what we were doing\n";
|
|
} // switch $mode
|
|
} // something in $read
|
|
|
|
/*
|
|
This section performs some action if it is deemed necessary
|
|
*/
|
|
if ($action) {
|
|
echo "Performing action $action\n";
|
|
}
|
|
switch($action){
|
|
case ACTION_STAR:
|
|
echo " star command started\n";
|
|
sendBaseline($client, $blp, GREEN . '*', true);
|
|
$client->send(CON);
|
|
$action = false;
|
|
$mode = MODE_BL;
|
|
break;
|
|
|
|
|
|
|
|
case ACTION_SUBMITRF:
|
|
$action = false;
|
|
sendBaseline($client, $bpl, MSG_SENDORNOT);
|
|
$mode = MODE_SUBMITRF;
|
|
break;
|
|
|
|
|
|
|
|
|
|
case ACTION_BACKUP:
|
|
// do we have anywhere to go?
|
|
if (count($history) > 1) { // because current page should always be in there.
|
|
array_pop($history); // drop current page to reveal previous
|
|
}
|
|
list($page, $subpage) = end($history); // get new last entry,
|
|
echo "Backing up to $page$subpage\n";
|
|
// drop into
|
|
case ACTION_NEXT:
|
|
if ($action == ACTION_NEXT) {
|
|
$cursub = $subpage;
|
|
$subpage = chr(ord($subpage)+1);
|
|
}
|
|
case ACTION_GOTO:
|
|
// $client->send(HOME . UP . GREEN . "Searching for page $page");
|
|
// $blp = 20 + strlenv($page);
|
|
// look for requested page
|
|
|
|
try {
|
|
$fo = (new \App\Models\Frame)->fetch($page,$subpage);
|
|
|
|
} catch (ModelNotFoundException $e) {
|
|
Log::debug(sprintf('Frame: %s%s NOT found',$page,$subpage));
|
|
if ($action == ACTION_NEXT) {
|
|
$subpage = $cursub; // Put subpage back as it was
|
|
}
|
|
|
|
sendBaseline($client, $blp, ERR_PAGE);
|
|
$mode = $action = FALSE;
|
|
break;
|
|
}
|
|
|
|
dump(['m'=>__METHOD__,'service'=>$service['service_id'],'varient'=>$varient['varient_id'],'frame'=>$fo->framenum(),'type'=>$fo->type()]);
|
|
|
|
// validate if we have access top it
|
|
/* if (isset($m['access']) && $m['access'] == 'n') {
|
|
sendBaseline($client, $blp, ERR_PAGE);
|
|
$mode = $action = false;
|
|
break;
|
|
}
|
|
if (isset($m['cug']) && is_numeric($m['cug']) && $m['cug'] && !in_array($m['cug'],$usercugs)) {
|
|
sendBaseline($client, $blp, ERR_PRIVATE);
|
|
$mode = $action = false;
|
|
break;
|
|
}
|
|
*/
|
|
|
|
// we have access...
|
|
if ($r['varient_id'] != $varient['varient_id']) {
|
|
if (empty($v['varient_date'])) {
|
|
sendBaseline($client, $blp, sprintf(MSG_TIMEWARP_TO, 'unknown date') );
|
|
} else {
|
|
sendBaseline($client, $blp, sprintf(MSG_TIMEWARP_TO,date('j f Y',strtotime($v['varient_date']))) );
|
|
}
|
|
$varient = array_merge($varient, array_intersect_key($r, $varient));
|
|
}
|
|
//var_dump(['B','r'=>$r,'m'=>$m]);
|
|
//$pagedata = array_merge($r, $m);
|
|
//$varient = $v;
|
|
$curpage = $page;
|
|
$cursub = $subpage;
|
|
$cufield = 0;
|
|
$curfp = 0;
|
|
//$pageflags = $db->getFrameTypeFlags($pagedata['type']); // method missing.
|
|
$pageflags = [];
|
|
|
|
if ($action == ACTION_GOTO || $action == ACTION_NEXT) { // only if new location, not going backwards
|
|
$history[] = array($page,$subpage);
|
|
}
|
|
|
|
// drop into
|
|
case ACTION_RELOAD:
|
|
//
|
|
/* if ($pageflags['clear']) {
|
|
$output = CLS;
|
|
$blp = 0;
|
|
} else {
|
|
$output = HOME;
|
|
}
|
|
*/
|
|
// print_r($pageflags); print_r($pagedata);
|
|
|
|
switch($fo->type()){
|
|
default:
|
|
case 'i': // standard frame
|
|
if ($timewarp && 1 < count(
|
|
$alts = $db->getAlternateFrames($service['service_id'],$varient['varient_id'],$curpage,$cursub)
|
|
)) {
|
|
$msg = MSG_TIMEWARP;
|
|
} else {
|
|
$msg = '';
|
|
}
|
|
|
|
$output = getOutputx($curpage, $cursub, [], $pageflags, $msg);
|
|
//var_dump(['output'=>$output,'curpage'=>$curpage,'cursub'=>$cursub,'pagedata'=>$pagedata,'pageflag'=>$pageflags,'m'=>$msg]);
|
|
$blp = strlenv($msg);
|
|
$client->send($output);
|
|
$mode = $action = false;
|
|
break;
|
|
|
|
case 'a': // active frame. Prestel uses this for Response Framea.
|
|
|
|
/*
|
|
if ($timewarp && 1 < count(
|
|
$alts = $db->getAlternateFrames($service['service_id'],$varient['varient_id'],$curpage,$cursub)
|
|
)) {
|
|
$msg = MSG_TIMEWARP;
|
|
} else {
|
|
$msg = '';
|
|
}
|
|
*/
|
|
|
|
// this is a glorious hack to fix three out of 30,000 pages but might
|
|
// break lots more.
|
|
//$pagedata = str_replace(chr(12),chr(27),$pagedata);
|
|
|
|
// holds data entered by user.
|
|
$fielddata = array();
|
|
|
|
$fields = $fo->fields;
|
|
$msg = '?';
|
|
$output = getOutputx($curpage, $cursub, [], $pageflags, $msg, $user, $fields);
|
|
$blp = strlenv($msg);
|
|
$client->send($output);
|
|
|
|
if ($fields->count()) {
|
|
// dump($fields,count($fields));
|
|
// need t skip to first field that is..
|
|
// of a field type that is editable
|
|
// or finish.
|
|
$curfield = FALSE;
|
|
|
|
for ($i = 0; $i < count($fields); $i++) {
|
|
//dump($this->fieldoptions,$i,isset($this->fieldoptions[$fields[$i]['type']]));
|
|
|
|
if (isset($this->fieldoptions[$fields[$i]['type']]) &&
|
|
$this->fieldoptions[$fields[$i]['type']]['edit']) {
|
|
$curfield = $i;
|
|
break;
|
|
}
|
|
}
|
|
|
|
$resetpsn = $curfield;
|
|
|
|
if ($curfield !== false) {
|
|
$mode = MODE_FIELD;
|
|
|
|
} else {
|
|
// there were no editable fields.
|
|
$mode = MODE_COMPLETE;
|
|
}
|
|
|
|
$curfp = 0;
|
|
|
|
//dump(['curfield'=>$curfield,'mode'=>$mode]);
|
|
}
|
|
|
|
break;
|
|
|
|
case 't': // terminate
|
|
$output = getOutputx($curpage, $cursub, [], $pageflags);
|
|
$client->send($output);
|
|
$action = ACTION_TERMINATE;
|
|
break;
|
|
|
|
} // switch
|
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
case ACTION_INFO: // special emulator command
|
|
$mode = false;
|
|
$cmd='';
|
|
$action = false;
|
|
|
|
$output = outputPosition(0,0) . WHITE . NEWBG . RED . 'TIMEWARP INFO FOR Pg.' . BLUE . $curpage . $cursub . WHITE;
|
|
$output .= outputPosition(0,1) . WHITE . NEWBG . BLUE . 'Service : ' . substr($service['service_name'] . str_repeat(' ',27),0,27) ;
|
|
$output .= outputPosition(0,2) . WHITE . NEWBG . BLUE . 'Varient : ' . substr($varient['varient_name'] . str_repeat(' ',27),0,27) ;
|
|
$output .= outputPosition(0,3) . WHITE . NEWBG . BLUE . 'Dated : ' . substr(date('j F Y',strtotime($varient['varient_date'])) . str_repeat(' ',27),0,27);
|
|
|
|
$alts = $db->getAlternateFrames($service['service_id'],$varient['varient_id'],$curpage,$cursub);
|
|
if (count($alts) > 1) {
|
|
$n = 1;
|
|
$output .= outputPosition(0,4) . WHITE . NEWBG . RED . 'ALTERNATIVE VERSIONS:' . str_repeat(' ',16);
|
|
$y = 5;
|
|
foreach ($alts as $ss){
|
|
// if (is_numeric($ss['varient_date'])) {
|
|
$date = date('d M Y', strtotime($ss['varient_date']));
|
|
// } else {
|
|
// $date = 'unknown';
|
|
// }
|
|
$line = WHITE . NEWBG;
|
|
if ($timewarp) {
|
|
$line .= RED . $n;
|
|
}
|
|
$line .= BLUE . $date . ' ' . $ss['varient_name'];
|
|
|
|
|
|
$output .= outputPosition(0,$y) . $line . str_repeat(' ',40-strlenv($line));
|
|
$y++;
|
|
$n++;
|
|
|
|
}
|
|
if ($timewarp) {
|
|
$mode = MODE_WARPTO;
|
|
}
|
|
}
|
|
$client->send($output);
|
|
|
|
break;
|
|
|
|
default:
|
|
;
|
|
} // switch $action
|
|
|
|
if ($resetpsn !== false && isset($fields[$resetpsn])) {
|
|
$client->send(outputPosition($fields[$resetpsn]['x'],$fields[$resetpsn]['y']).CON);
|
|
$resetpsn = false;
|
|
}
|
|
|
|
|
|
if( $read === null || socket_last_error()) {
|
|
printf( "[%s] Disconnected\n", $client->getaddress() );
|
|
return false;
|
|
}
|
|
}
|
|
|
|
$client->close();
|
|
printf( "[%s] Disconnected\n", $client->getaddress() );
|
|
}
|
|
}
|
|
|
|
function strlenv($text){
|
|
return strlen($text) - substr_count($text, ESC);
|
|
}
|
|
|
|
function sendBaseline($client, &$blp, $text, $reposition = false){
|
|
$client->send(HOME . UP . $text .
|
|
( $blp > strlenv($text) ? str_repeat(' ',$blp-strlenv($text)) .
|
|
( $reposition ? HOME . UP . str_repeat(RIGHT, strlenv($text)) : '' )
|
|
: '')
|
|
);
|
|
$blp = strlenv($text);
|
|
return;
|
|
}
|
|
|
|
function outputPosition($x,$y){
|
|
|
|
if ($y < 12) {
|
|
if ($x < 21) {
|
|
return HOME . str_repeat(DOWN, $y) . str_repeat(RIGHT, $x);
|
|
} else {
|
|
return HOME . str_repeat(DOWN, $y+1) . str_repeat(LEFT, 40-$x);
|
|
}
|
|
} else {
|
|
if ($x < 21) {
|
|
return HOME . str_repeat(UP, 24-$y) . str_repeat(RIGHT, $x);
|
|
} else {
|
|
return HOME . str_repeat(UP, 24-$y) . str_repeat(LEFT, 40-$x);
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
/*
|
|
|
|
return a screen output ... $msg sent on baseline just after the cls.
|
|
remember to update $blp manually after calling this.
|
|
|
|
*/
|
|
|
|
function getOutputx($page, $subpage, $pagedata, $pageflags, $msg = '', $user = array(), &$fields = null, &$frame_content = null) {
|
|
global $blp;
|
|
global $fieldmap; // @todo this is not set outside of the class.
|
|
|
|
$price = isset($pagerecord['price']) ? $pagerecord['price'] : 0;
|
|
|
|
// get textual content.
|
|
|
|
$fo = (new \App\Models\Frame)->fetch($page,$subpage);
|
|
$text = (string)$fo;
|
|
//$text = $pagedata['frame_content'];
|
|
|
|
|
|
|
|
// dump(['C'=>__METHOD__,'frame_content'=>$text,'msg'=>$output,'p'=>$page,'s'=>$subpage,'startline'=>$startline,'frame'=>$fo,'fields'=>$fo->fields($startline)]);
|
|
|
|
return (string)$fo;
|
|
} |