sintonia/airtime_mvc/application/forms/LiveStreamingPreferences.php

<?php

class Application_Form_LiveStreamingPreferences extends Zend_Form_SubForm
{

    public function init()
    {
        $defaultFade = Application_Model_Preference::GetDefaultTransitionFade();
        if($defaultFade == ""){
            $defaultFade = '00.000000';
        }
        
        //Default transition fade
        $transition_fade = new Zend_Form_Element_Text("transition_fade");
        $transition_fade->setLabel("Switch Transition Fade (s)")
                        ->setFilters(array('StringTrim'))
                        ->addValidator('regex', false, array('/^[0-9]{1,2}(\.\d{1,6})?$/',
                        'messages' => 'enter a time in seconds 00{.000000}'))
                        ->setValue($defaultFade)
                        ->setDecorators(array('ViewHelper'));
        $this->addElement($transition_fade);
        
        //Master username
        $master_username = new Zend_Form_Element_Text('master_username');
        $master_username->setAttrib('autocomplete', 'off')
                        ->setAllowEmpty(true)
                        ->setLabel('Master Username')
                        ->setFilters(array('StringTrim'))
                        ->setValue(Application_Model_Preference::GetLiveSteamMasterUsername())
                        ->setDecorators(array('ViewHelper'));
        $this->addElement($master_username);
        
        //Master password
        $master_password = new Zend_Form_Element_Password('master_password');
        $master_password->setAttrib('autocomplete', 'off')
                        ->setAttrib('renderPassword','true')
                        ->setAllowEmpty(true)
                        ->setValue(Application_Model_Preference::GetLiveSteamMasterPassword())
                        ->setLabel('Master Password')
                        ->setFilters(array('StringTrim'))
                        ->setDecorators(array('ViewHelper'));
        $this->addElement($master_password);
        
        //liquidsoap harbor.input port
        $m_port = Application_Model_StreamSetting::GetMasterLiveSteamPort();
        $master_dj_port = new Zend_Form_Element_Text('master_harbor_input_port');
        $master_dj_port->setLabel("Master Source Port")
                ->setValue($m_port)
                ->setValidators(array(new Zend_Validate_Between(array('min'=>1024, 'max'=>49151))))
                ->addValidator('regex', false, array('pattern'=>'/^[0-9]+$/', 'messages'=>array('regexNotMatch'=>'Only numbers are allowed.')))
                ->setDecorators(array('ViewHelper'));
        $this->addElement($master_dj_port);
        
        $m_mount = Application_Model_StreamSetting::GetMasterLiveSteamMountPoint();
        $master_dj_mount = new Zend_Form_Element_Text('master_harbor_input_mount_point');
        $master_dj_mount->setLabel("Master Source Mount Point")
                ->setValue($m_mount)
                ->setValidators(array(
                        array('regex', false, array('/^[^ &<>]+$/', 'messages' => 'Invalid character entered'))))
                ->setDecorators(array('ViewHelper'));
        $this->addElement($master_dj_mount);
        
        //liquidsoap harbor.input port
        $l_port = Application_Model_StreamSetting::GetDJLiveSteamPort();
        $live_dj_port = new Zend_Form_Element_Text('dj_harbor_input_port');
        $live_dj_port->setLabel("Show Source Port")
                ->setValue($l_port)
                ->setValidators(array(new Zend_Validate_Between(array('min'=>1024, 'max'=>49151))))
                ->addValidator('regex', false, array('pattern'=>'/^[0-9]+$/', 'messages'=>array('regexNotMatch'=>'Only numbers are allowed.')))
                ->setDecorators(array('ViewHelper'));
        $this->addElement($live_dj_port);
        
        $l_mount = Application_Model_StreamSetting::GetDJLiveSteamMountPoint();
        $live_dj_mount = new Zend_Form_Element_Text('dj_harbor_input_mount_point');
        $live_dj_mount->setLabel("Show Source Mount Point")
                ->setValue($l_mount)
                ->setValidators(array(
                        array('regex', false, array('/^[^ &<>]+$/', 'messages' => 'Invalid character entered'))))
                ->setDecorators(array('ViewHelper'));
        $this->addElement($live_dj_mount);
    }
    
    public function updateVariables(){
        $m_port = Application_Model_StreamSetting::GetMasterLiveSteamPort();
        $m_mount = Application_Model_StreamSetting::GetMasterLiveSteamMountPoint();
        $l_port = Application_Model_StreamSetting::GetDJLiveSteamPort();
        $l_mount = Application_Model_StreamSetting::GetDJLiveSteamMountPoint();
        
        $master_dj_connection_url = Application_Model_Preference::GetMasterDJSourceConnectionURL();
        $live_dj_connection_url = Application_Model_Preference::GetLiveDJSourceConnectionURL();
        
        $master_dj_connection_url = ($master_dj_connection_url == "")?("http://".$_SERVER['SERVER_NAME'].":".$m_port."/".$m_mount):$master_dj_connection_url;
        $live_dj_connection_url = ($live_dj_connection_url == "")?"http://".$_SERVER['SERVER_NAME'].":".$l_port."/".$l_mount:$live_dj_connection_url;
        
        if($m_port=="" || $m_mount==""){
            $master_dj_connection_url = "N/A";
        }
        if($l_port=="" || $l_mount==""){
            $live_dj_connection_url = "N/A";
        }
        
        $overrideDescription = "If Airtime is behind a router or firewall, you may need to configure port forwarding and this field information will be incorrect. In this case you will need to manually update this field so it shows the correct host/port/mount that your DJ's need to connect to. The allowed range is between 1024 and 49151. For more detail, please read the <a target=\"_blank\" href=\"http://manuals.sourcefabric.org/\">Airtime manual</a>.";
        
        $this->setDecorators(array(
        array('ViewScript', array('viewScript' => 'form/preferences_livestream.phtml', 'master_dj_connection_url'=>$master_dj_connection_url, 'live_dj_connection_url'=>$live_dj_connection_url,'overrideDescription' => $overrideDescription))
        ));
    }
    
    public function isValid($data){
        $isValid = parent::isValid($data);
        
        $master_harbor_input_port = $data['master_harbor_input_port'];
        $dj_harbor_input_port = $data['dj_harbor_input_port'];
        
        if($master_harbor_input_port == $dj_harbor_input_port && $master_harbor_input_port != ""){
            $element = $this->getElement("dj_harbor_input_port");
            $element->addError("You cannot use same port as Master DJ port.");
        }
        if($master_harbor_input_port != ""){
            if(is_numeric($master_harbor_input_port)){
                if($master_harbor_input_port != Application_Model_StreamSetting::GetMasterLiveSteamPort()){
                    $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
                    $res = socket_bind($sock, 0, $master_harbor_input_port);
                    if(!$res){
                        $element = $this->getElement("master_harbor_input_port");
                        $element->addError("Port '$master_harbor_input_port' is not available.");
                        $isValid = false;
                    }
                    socket_close($sock);
                }
            }else{
                $isValid = false;
            }
        }
        if($dj_harbor_input_port != ""){
            if(is_numeric($dj_harbor_input_port)){
                if($dj_harbor_input_port != Application_Model_StreamSetting::GetDJLiveSteamPort()){
                    $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
                    $res = socket_bind($sock, 0, $dj_harbor_input_port);
                    if(!$res){
                        $element = $this->getElement("dj_harbor_input_port");
                        $element->addError("Port '$dj_harbor_input_port' is not available.");
                        $isValid = false;
                    }
                    socket_close($sock);
                }
            }else{
                $isValid = false;
            }
        }
        return $isValid;
    }
    
}