Remove PAGI quickstart example for security check
Showing
3 changed files
with
0 additions
and
394 deletions
| <?php | ||
| /** | ||
| * PAGI basic use example. Please see run.sh in this same directory for an | ||
| * example of how to actually run this from your dialplan. | ||
| * | ||
| * Note: The client accepts an array with options. The available options are | ||
| * | ||
| * stdin => Optional. If set, should contain an already open stream from | ||
| * where the client will read data (useful to make it interact with fastagi | ||
| * servers or even text files to mock stuff when testing). If not set, stdin | ||
| * will be used by the client. | ||
| * | ||
| * stdout => Optional. Same as stdin but for the output of the client. | ||
| * | ||
| * | ||
| * PHP Version 5 | ||
| * | ||
| * @category Pagi | ||
| * @package examples | ||
| * @subpackage quickstart | ||
| * @author Marcelo Gornstein <[email protected]> | ||
| * @license http://marcelog.github.com/PAGI/ Apache License 2.0 | ||
| * @version SVN: $Id$ | ||
| * @link http://marcelog.github.com/PAGI/ | ||
| * | ||
| * Copyright 2011 Marcelo Gornstein <[email protected]> | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| * | ||
| */ | ||
| use PAGI\Application\PAGIApplication; | ||
| use PAGI\Client\ChannelStatus; | ||
| use PAGI\CallSpool\CallFile; | ||
| use PAGI\CallSpool\Impl\CallSpoolImpl; | ||
| declare(ticks=1); | ||
| /** | ||
| * PAGI basic use example. Please see run.sh in this same directory for an | ||
| * example of how to actually run this from your dialplan. | ||
| * | ||
| * Note: The client accepts an array with options. The available options are | ||
| * | ||
| * stdin => Optional. If set, should contain an already open stream from | ||
| * where the client will read data (useful to make it interact with fastagi | ||
| * servers or even text files to mock stuff when testing). If not set, stdin | ||
| * will be used by the client. | ||
| * | ||
| * stdout => Optional. Same as stdin but for the output of the client. | ||
| * | ||
| * PHP Version 5 | ||
| * | ||
| * @category Pagi | ||
| * @package examples | ||
| * @subpackage quickstart | ||
| * @author Marcelo Gornstein <[email protected]> | ||
| * @license http://marcelog.github.com/PAGI/ Apache License 2.0 | ||
| * @link http://marcelog.github.com/PAGI/ | ||
| */ | ||
| class MyPAGIApplication extends PAGIApplication | ||
| { | ||
| /** | ||
| * (non-PHPdoc) | ||
| * @see PAGI\Application.PAGIApplication::init() | ||
| */ | ||
| public function init() | ||
| { | ||
| $this->log('Init'); | ||
| $client = $this->getAgi(); | ||
| $client->answer(); | ||
| } | ||
| /** | ||
| * Logs to asterisk console. | ||
| * | ||
| * @param string $msg Message to log. | ||
| * | ||
| * @return void | ||
| */ | ||
| public function log($msg) | ||
| { | ||
| $agi = $this->getAgi(); | ||
| $this->logger->debug($msg); | ||
| $agi->consoleLog($msg); | ||
| } | ||
| /** | ||
| * (non-PHPdoc) | ||
| * @see PAGI\Application.PAGIApplication::shutdown() | ||
| */ | ||
| public function shutdown() | ||
| { | ||
| try | ||
| { | ||
| $this->log('Shutdown'); | ||
| $client = $this->getAgi(); | ||
| $client->hangup(); | ||
| } catch(\Exception $e) { | ||
| } | ||
| } | ||
| /** | ||
| * (non-PHPdoc) | ||
| * @see PAGI\Application.PAGIApplication::run() | ||
| */ | ||
| public function run() | ||
| { | ||
| $this->log('Run'); | ||
| $client = $this->getAgi(); | ||
| $loggerFacade = $client->getAsteriskLogger(); | ||
| $loggerFacade->notice('hello notice'); | ||
| $loggerFacade->warn('hello warn'); | ||
| $loggerFacade->debug('hello debug'); | ||
| $loggerFacade->error('hello error'); | ||
| $loggerFacade->dtmf('hello dtmf'); | ||
| //$this->log($client->faxReceive('/tmp/a.tiff')->__toString()); | ||
| //$this->log($client->faxSend('/tmp/a.tiff')->__toString()); | ||
| $variables = $client->getChannelVariables(); | ||
| $this->log('Config dir: ' . $variables->getDirectoryConfig()); | ||
| $this->log('Config file: ' . $variables->getConfigFile()); | ||
| $this->log('Module dir: ' . $variables->getDirectoryModules()); | ||
| $this->log('Spool dir: ' . $variables->getDirectorySpool()); | ||
| $this->log('Monitor dir: ' . $variables->getDirectoryMonitor()); | ||
| $this->log('Var dir: ' . $variables->getDirectoryVar()); | ||
| $this->log('Data dir: ' . $variables->getDirectoryData()); | ||
| $this->log('Log dir: ' . $variables->getDirectoryLog()); | ||
| $this->log('Agi dir: ' . $variables->getDirectoryAgi()); | ||
| $this->log('Key dir: ' . $variables->getDirectoryKey()); | ||
| $this->log('Run dir: ' . $variables->getDirectoryRun()); | ||
| $this->log('Request: '. $variables->getRequest()); | ||
| $this->log('Channel: '. $variables->getChannel()); | ||
| $this->log('Language: '. $variables->getLanguage()); | ||
| $this->log('Type: '. $variables->getType()); | ||
| $this->log('UniqueId: ' . $variables->getUniqueId()); | ||
| $this->log('Version: ' . $variables->getVersion()); | ||
| $this->log('CallerId: ' . $variables->getCallerId()); | ||
| $this->log('CallerId name: ' . $variables->getCallerIdName()); | ||
| $this->log('CallerId pres: ' . $variables->getCallingPres()); | ||
| $this->log('CallingAni2: ' . $variables->getCallingAni2()); | ||
| $this->log('CallingTon: ' . $variables->getCallingTon()); | ||
| $this->log('CallingTNS: ' . $variables->getCallingTns()); | ||
| $this->log('DNID: ' . $variables->getDNID()); | ||
| $this->log('RDNIS: ' . $variables->getRDNIS()); | ||
| $this->log('Context: ' . $variables->getContext()); | ||
| $this->log('Extension: ' . $variables->getDNIS()); | ||
| $this->log('Priority: ' . $variables->getPriority()); | ||
| $this->log('Enhanced: ' . $variables->getEnhanced()); | ||
| $this->log('AccountCode: ' . $variables->getAccountCode()); | ||
| $this->log('ThreadId: ' . $variables->getThreadId()); | ||
| $this->log('Arguments: ' . intval($variables->getTotalArguments())); | ||
| for ($i = 0; $i < $variables->getTotalArguments(); $i++) { | ||
| $this->log(' -- Argument ' . intval($i) . ': ' . $variables->getArgument($i)); | ||
| } | ||
| $result = $client->sayDigits('12345', '12#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say digits.'); | ||
| } | ||
| $result = $client->sayNumber('12345', '12#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say number.'); | ||
| } | ||
| $result = $client->getData('welcome', 10000, 4); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for get data with: ' . $result->getDigits()); | ||
| } | ||
| $result = $client->getOption('welcome', '0123456789*#', 10000); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for get option.'); | ||
| } | ||
| $result = $client->streamFile('welcome', '#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for stream file.'); | ||
| } | ||
| $this->log('Channel status: ' . ChannelStatus::toString($client->channelStatus())); | ||
| $this->log('Channel status: ' . ChannelStatus::toString($client->channelStatus($variables->getChannel()))); | ||
| $this->log('Variable: ' . $client->getVariable('EXTEN')); | ||
| $this->log('FullVariable: ' . $client->getFullVariable('EXTEN')); | ||
| $cdr = $client->getCDR(); | ||
| $this->log('CDRVariable: ' . $cdr->getSource()); | ||
| $cdr->setAccountCode('foo'); | ||
| $this->log('CDRVariable: ' . $cdr->getAccountCode()); | ||
| $callerId = $client->getCallerId(); | ||
| $this->log('CallerID: ' . $callerId); | ||
| $callerId->setName('pepe'); | ||
| $this->log('CallerID: ' . $callerId); | ||
| $client->setCallerId('foo', '123123'); | ||
| $this->log('CallerID: ' . $callerId); | ||
| $this->log($client->exec('Dial', array('SIP/sip', 30, 'r'))); | ||
| $this->log($client->dial('SIP/01', array(30, 'r'))); | ||
| $result = $client->sayPhonetic('marcelog', '123#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say phonetic.'); | ||
| } | ||
| $result = $client->sayAlpha('marcelog', '123#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say alpha.'); | ||
| } | ||
| $result = $client->sayTime(time(), '123#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say time.'); | ||
| } | ||
| $result = $client->sayDateTime(time(), 'mdYHMS', '123#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say datetime.'); | ||
| } | ||
| $result = $client->sayDate(time(), '123#'); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for say date.'); | ||
| } | ||
| $client->setPriority(1000); | ||
| $client->setExtension(1000); | ||
| $client->setContext('foo'); | ||
| $client->setMusic(true); | ||
| sleep(10); | ||
| $client->setMusic(false); | ||
| $result = $client->waitDigit(10000); | ||
| if (!$result->isTimeout()) { | ||
| $this->log('Read: ' . $result->getDigits()); | ||
| } else { | ||
| $this->log('Timeouted for waitdigit.'); | ||
| } | ||
| $result = $client->record('/tmp/asd', 'wav', '#'); | ||
| if ($result->isInterrupted()) { | ||
| if ($result->isHangup()) { | ||
| $this->log('hangup when recording.'); | ||
| } else { | ||
| $this->log('interrupted with: ' . $result->getDigits()); | ||
| } | ||
| $this->log('Recorded: ' . $result->getEndPos()); | ||
| } | ||
| //$this->log($client->databaseGet('SIP', 'Registry')); | ||
| //$client->setAutoHangup(10); | ||
| //sleep(20); | ||
| } | ||
| /** | ||
| * (non-PHPdoc) | ||
| * @see PAGI\Application.PAGIApplication::errorHandler() | ||
| */ | ||
| public function errorHandler($type, $message, $file, $line) | ||
| { | ||
| $this->log( | ||
| 'ErrorHandler: ' | ||
| . implode(' ', array($type, $message, $file, $line)) | ||
| ); | ||
| } | ||
| /** | ||
| * (non-PHPdoc) | ||
| * @see PAGI\Application.PAGIApplication::signalHandler() | ||
| */ | ||
| public function signalHandler($signal) | ||
| { | ||
| $this->log('SignalHandler got signal: ' . $signal); | ||
| $this->shutdown(); | ||
| exit(0); | ||
| } | ||
| } |
| <?php | ||
| /** | ||
| * Spooling calls exmaples. | ||
| * | ||
| * PHP Version 5.3 | ||
| * | ||
| * Copyright 2011 Marcelo Gornstein <[email protected]> | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| * | ||
| */ | ||
| use PAGI\CallSpool\CallFile; | ||
| use PAGI\CallSpool\Impl\CallSpoolImpl; | ||
| use PAGI\DialDescriptor\SIPDialDescriptor; | ||
| use PAGI\DialDescriptor\DAHDIDialDescriptor; | ||
| $dialDescriptor = new DAHDIDialDescriptor('1949890333', 1); | ||
| $callFile = new CallFile($dialDescriptor); | ||
| $callFile->setContext('campaign'); | ||
| $callFile->setExtension('failed'); | ||
| $callFile->setVariable('foo', 'bar'); | ||
| $callFile->setPriority('1'); | ||
| $callFile->setMaxRetries('0'); | ||
| $callFile->setWaitTime(10); | ||
| $callFile->setCallerId('some<123123>'); | ||
| echo "Call file generated (DAHDI dial descriptor):\n"; | ||
| echo $callFile->serialize(); | ||
| echo "\n\n"; | ||
| $dialDescriptor = new SIPDialDescriptor('24', 'example.com'); | ||
| $callFile = new CallFile($dialDescriptor); | ||
| $callFile->setContext('default'); | ||
| $callFile->setExtension('777'); | ||
| $callFile->setVariable('foo', 'bar'); | ||
| $callFile->setPriority('1'); | ||
| $callFile->setMaxRetries('0'); | ||
| $callFile->setWaitTime(10); | ||
| $callFile->setCallerId('some<123123>'); | ||
| echo "Call file generated (SIP dial descriptor):\n"; | ||
| echo $callFile->serialize(); | ||
| echo "\n\n\n"; | ||
| echo "Spooling generated SIP call\n"; | ||
| $spool = CallSpoolImpl::getInstance( | ||
| array( | ||
| 'tmpDir' => '/tmp', | ||
| 'spoolDir' => '/tmp/spoolExample' | ||
| ) | ||
| ); | ||
| $spool->spool($callFile); | ||
| echo "Spooling generated SIP call to run in 30 seconds\n"; | ||
| $spool->spool($callFile, time() + 30); |
-
Please register or sign in to post a comment