@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | private function getPagantisOrderId() |
| 208 | 208 | { |
| 209 | 209 | try { |
| 210 | - $this->pagantisOrderId= Db::getInstance()->getValue( |
|
| 210 | + $this->pagantisOrderId = Db::getInstance()->getValue( |
|
| 211 | 211 | 'select order_id from '._DB_PREFIX_.'pagantis_order where id = '.$this->merchantOrderId |
| 212 | 212 | ); |
| 213 | 213 | |
@@ -269,20 +269,20 @@ discard block |
||
| 269 | 269 | $merchantAmount = explode('.', explode(',', $merchantAmount)[0])[0]; |
| 270 | 270 | if ($totalAmount != $merchantAmount) { |
| 271 | 271 | try { |
| 272 | - $psTotalAmount = substr_replace($merchantAmount, '.', (Tools::strlen($merchantAmount) -2), 0); |
|
| 272 | + $psTotalAmount = substr_replace($merchantAmount, '.', (Tools::strlen($merchantAmount) - 2), 0); |
|
| 273 | 273 | |
| 274 | 274 | $pgTotalAmountInCents = (string) $this->pagantisOrder->getShoppingCart()->getTotalAmount(); |
| 275 | 275 | $pgTotalAmount = substr_replace( |
| 276 | 276 | $pgTotalAmountInCents, |
| 277 | 277 | '.', |
| 278 | - (Tools::strlen($pgTotalAmountInCents) -2), |
|
| 278 | + (Tools::strlen($pgTotalAmountInCents) - 2), |
|
| 279 | 279 | 0 |
| 280 | 280 | ); |
| 281 | 281 | |
| 282 | - $this->amountMismatchError = '. Amount mismatch in PrestaShop Order #'. $this->merchantOrderId . |
|
| 283 | - ' compared with Pagantis Order: ' . $this->pagantisOrderId . |
|
| 284 | - '. The order in PrestaShop has an amount of ' . $psTotalAmount . ' and in Pagantis ' . |
|
| 285 | - $pgTotalAmount . ' PLEASE REVIEW THE ORDER'; |
|
| 282 | + $this->amountMismatchError = '. Amount mismatch in PrestaShop Order #'.$this->merchantOrderId. |
|
| 283 | + ' compared with Pagantis Order: '.$this->pagantisOrderId. |
|
| 284 | + '. The order in PrestaShop has an amount of '.$psTotalAmount.' and in Pagantis '. |
|
| 285 | + $pgTotalAmount.' PLEASE REVIEW THE ORDER'; |
|
| 286 | 286 | $this->saveLog(array( |
| 287 | 287 | 'message' => $this->amountMismatchError |
| 288 | 288 | )); |
@@ -302,20 +302,20 @@ discard block |
||
| 302 | 302 | try { |
| 303 | 303 | if ($this->merchantOrder->orderExists() !== false) { |
| 304 | 304 | throw new WrongStatusException('PS->orderExists() cart_id = ' |
| 305 | - . $this->merchantOrderId . ' pagantis_id = ' |
|
| 306 | - . $this->pagantisOrderId . '): already_processed'); |
|
| 305 | + . $this->merchantOrderId.' pagantis_id = ' |
|
| 306 | + . $this->pagantisOrderId.'): already_processed'); |
|
| 307 | 307 | } |
| 308 | 308 | |
| 309 | 309 | // Double check |
| 310 | - $tableName = _DB_PREFIX_ . 'pagantis_order'; |
|
| 311 | - $sql = ('select ps_order_id from `' . $tableName . '` where `id` = ' . $this->merchantOrderId |
|
| 312 | - . ' and `order_id` = \'' . $this->pagantisOrderId . '\'' |
|
| 310 | + $tableName = _DB_PREFIX_.'pagantis_order'; |
|
| 311 | + $sql = ('select ps_order_id from `'.$tableName.'` where `id` = '.$this->merchantOrderId |
|
| 312 | + . ' and `order_id` = \''.$this->pagantisOrderId.'\'' |
|
| 313 | 313 | . ' and `ps_order_id` is not null'); |
| 314 | 314 | $results = Db::getInstance()->ExecuteS($sql); |
| 315 | 315 | if (is_array($results) && count($results) === 1) { |
| 316 | - throw new WrongStatusException('PS->record found in ' . $tableName |
|
| 317 | - . ' (cart_id = ' . $this->merchantOrderId . ' pagantis_id = ' |
|
| 318 | - . $this->pagantisOrderId . '): already_processed'); |
|
| 316 | + throw new WrongStatusException('PS->record found in '.$tableName |
|
| 317 | + . ' (cart_id = '.$this->merchantOrderId.' pagantis_id = ' |
|
| 318 | + . $this->pagantisOrderId.'): already_processed'); |
|
| 319 | 319 | } |
| 320 | 320 | } catch (\Exception $exception) { |
| 321 | 321 | throw new UnknownException($exception->getMessage()); |
@@ -344,9 +344,9 @@ discard block |
||
| 344 | 344 | Configuration::get('PS_OS_PAYMENT'), |
| 345 | 345 | $this->merchantOrder->getOrderTotal(true), |
| 346 | 346 | $this->module->displayName, |
| 347 | - 'pagantisOrderId: ' . $this->pagantisOrder->getId() . ' ' . |
|
| 348 | - 'pagantisOrderStatus: '. $this->pagantisOrder->getStatus() . |
|
| 349 | - $this->amountMismatchError . |
|
| 347 | + 'pagantisOrderId: '.$this->pagantisOrder->getId().' '. |
|
| 348 | + 'pagantisOrderStatus: '.$this->pagantisOrder->getStatus(). |
|
| 349 | + $this->amountMismatchError. |
|
| 350 | 350 | $metadataInfo, |
| 351 | 351 | array('transaction_id' => $this->pagantisOrderId), |
| 352 | 352 | null, |
@@ -360,7 +360,7 @@ discard block |
||
| 360 | 360 | Db::getInstance()->update( |
| 361 | 361 | 'pagantis_order', |
| 362 | 362 | array('ps_order_id' => $this->module->currentOrder), |
| 363 | - 'id = \''. $this->merchantOrderId . '\' and order_id = \'' . $this->pagantisOrderId . '\'' |
|
| 363 | + 'id = \''.$this->merchantOrderId.'\' and order_id = \''.$this->pagantisOrderId.'\'' |
|
| 364 | 364 | ); |
| 365 | 365 | } catch (\Exception $exception) { |
| 366 | 366 | // Do nothing |
@@ -378,9 +378,9 @@ discard block |
||
| 378 | 378 | $this->orderClient->confirmOrder($this->pagantisOrderId); |
| 379 | 379 | try { |
| 380 | 380 | $mode = ($_SERVER['REQUEST_METHOD'] == 'POST') ? 'NOTIFICATION' : 'REDIRECTION'; |
| 381 | - $message = 'Order CONFIRMED. The order was confirmed by a ' . $mode . |
|
| 382 | - '. Pagantis OrderId=' . $this->pagantisOrderId . |
|
| 383 | - '. Prestashop OrderId=' . $this->module->currentOrder; |
|
| 381 | + $message = 'Order CONFIRMED. The order was confirmed by a '.$mode. |
|
| 382 | + '. Pagantis OrderId='.$this->pagantisOrderId. |
|
| 383 | + '. Prestashop OrderId='.$this->module->currentOrder; |
|
| 384 | 384 | $this->saveLog(array( |
| 385 | 385 | 'message' => $message |
| 386 | 386 | )); |
@@ -427,7 +427,7 @@ discard block |
||
| 427 | 427 | ); |
| 428 | 428 | $resultSeconds = Db::getInstance()->getValue($query); |
| 429 | 429 | $restSeconds = isset($resultSeconds) ? ($resultSeconds) : 0; |
| 430 | - $secondsToExpire = ($restSeconds>self::CONCURRENCY_TIMEOUT) ? self::CONCURRENCY_TIMEOUT : $restSeconds; |
|
| 430 | + $secondsToExpire = ($restSeconds > self::CONCURRENCY_TIMEOUT) ? self::CONCURRENCY_TIMEOUT : $restSeconds; |
|
| 431 | 431 | |
| 432 | 432 | $logMessage = sprintf( |
| 433 | 433 | "Redirect concurrency, User have to wait %s seconds, default seconds %s, bd time to expire %s seconds", |
@@ -439,7 +439,7 @@ discard block |
||
| 439 | 439 | $this->saveLog(array( |
| 440 | 440 | 'message' => $logMessage |
| 441 | 441 | )); |
| 442 | - sleep($secondsToExpire+1); |
|
| 442 | + sleep($secondsToExpire + 1); |
|
| 443 | 443 | // After waiting...user continue the confirmation, hoping that previous call have finished. |
| 444 | 444 | return true; |
| 445 | 445 | } |
@@ -456,12 +456,12 @@ discard block |
||
| 456 | 456 | if (is_null($orderId)) { |
| 457 | 457 | Db::getInstance()->delete( |
| 458 | 458 | 'pagantis_cart_process', |
| 459 | - 'timestamp < ' . (time() - self::CONCURRENCY_TIMEOUT |
|
| 459 | + 'timestamp < '.(time() - self::CONCURRENCY_TIMEOUT |
|
| 460 | 460 | ) |
| 461 | 461 | ); |
| 462 | 462 | return; |
| 463 | 463 | } |
| 464 | - Db::getInstance()->delete('pagantis_cart_process', 'id = \'' . $orderId . '\''); |
|
| 464 | + Db::getInstance()->delete('pagantis_cart_process', 'id = \''.$orderId.'\''); |
|
| 465 | 465 | } catch (\Exception $exception) { |
| 466 | 466 | throw new ConcurrencyException(); |
| 467 | 467 | } |
@@ -483,8 +483,8 @@ discard block |
||
| 483 | 483 | $data = array( |
| 484 | 484 | 'merchantOrderId' => $this->merchantOrderId, |
| 485 | 485 | 'pagantisOrderId' => $this->pagantisOrderId, |
| 486 | - 'message' => ($exception)? $exception->getMessage() : 'Unable to get Exception message', |
|
| 487 | - 'statusCode' => ($exception)? $exception->getCode() : 'Unable to get Exception statusCode', |
|
| 486 | + 'message' => ($exception) ? $exception->getMessage() : 'Unable to get Exception message', |
|
| 487 | + 'statusCode' => ($exception) ? $exception->getCode() : 'Unable to get Exception statusCode', |
|
| 488 | 488 | 'method' => $method, |
| 489 | 489 | 'file' => __FILE__, |
| 490 | 490 | 'line' => $line, |
@@ -508,9 +508,9 @@ discard block |
||
| 508 | 508 | 'id_cart' => $this->merchantOrderId, |
| 509 | 509 | 'key' => $this->config['secureKey'], |
| 510 | 510 | 'id_module' => $this->module->id, |
| 511 | - 'id_order' => ($this->pagantisOrder)?$this->pagantisOrder->getId(): null, |
|
| 511 | + 'id_order' => ($this->pagantisOrder) ? $this->pagantisOrder->getId() : null, |
|
| 512 | 512 | ); |
| 513 | - $url = ($error)? $this->config['urlKO'] : $this->config['urlOK']; |
|
| 513 | + $url = ($error) ? $this->config['urlKO'] : $this->config['urlOK']; |
|
| 514 | 514 | return $this->redirect($url, $parameters); |
| 515 | 515 | } |
| 516 | 516 | } |
| 517 | 517 | \ No newline at end of file |
@@ -1,4 +1,4 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | |
| 3 | -require(__DIR__ . '/src/Httpful/Bootstrap.php'); |
|
| 3 | +require(__DIR__.'/src/Httpful/Bootstrap.php'); |
|
| 4 | 4 | \Httpful\Bootstrap::init(); |
@@ -64,30 +64,30 @@ discard block |
||
| 64 | 64 | |
| 65 | 65 | function testInit() |
| 66 | 66 | { |
| 67 | - $r = Request::init(); |
|
| 68 | - // Did we get a 'Request' object? |
|
| 69 | - $this->assertEquals('Httpful\Request', get_class($r)); |
|
| 67 | + $r = Request::init(); |
|
| 68 | + // Did we get a 'Request' object? |
|
| 69 | + $this->assertEquals('Httpful\Request', get_class($r)); |
|
| 70 | 70 | } |
| 71 | 71 | |
| 72 | 72 | function testDetermineLength() |
| 73 | 73 | { |
| 74 | - $r = Request::init(); |
|
| 75 | - $this->assertEquals(1, $r->_determineLength('A')); |
|
| 76 | - $this->assertEquals(2, $r->_determineLength('À')); |
|
| 77 | - $this->assertEquals(2, $r->_determineLength('Ab')); |
|
| 78 | - $this->assertEquals(3, $r->_determineLength('Àb')); |
|
| 79 | - $this->assertEquals(6, $r->_determineLength('世界')); |
|
| 74 | + $r = Request::init(); |
|
| 75 | + $this->assertEquals(1, $r->_determineLength('A')); |
|
| 76 | + $this->assertEquals(2, $r->_determineLength('À')); |
|
| 77 | + $this->assertEquals(2, $r->_determineLength('Ab')); |
|
| 78 | + $this->assertEquals(3, $r->_determineLength('Àb')); |
|
| 79 | + $this->assertEquals(6, $r->_determineLength('世界')); |
|
| 80 | 80 | } |
| 81 | 81 | |
| 82 | 82 | function testMethods() |
| 83 | 83 | { |
| 84 | - $valid_methods = array('get', 'post', 'delete', 'put', 'options', 'head'); |
|
| 85 | - $url = 'http://example.com/'; |
|
| 86 | - foreach ($valid_methods as $method) { |
|
| 84 | + $valid_methods = array('get', 'post', 'delete', 'put', 'options', 'head'); |
|
| 85 | + $url = 'http://example.com/'; |
|
| 86 | + foreach ($valid_methods as $method) { |
|
| 87 | 87 | $r = call_user_func(array('Httpful\Request', $method), $url); |
| 88 | 88 | $this->assertEquals('Httpful\Request', get_class($r)); |
| 89 | 89 | $this->assertEquals(strtoupper($method), $r->method); |
| 90 | - } |
|
| 90 | + } |
|
| 91 | 91 | } |
| 92 | 92 | |
| 93 | 93 | function testDefaults() |
@@ -124,12 +124,12 @@ discard block |
||
| 124 | 124 | function testSettingStrictSsl() |
| 125 | 125 | { |
| 126 | 126 | $r = Request::init() |
| 127 | - ->withStrictSsl(); |
|
| 127 | + ->withStrictSsl(); |
|
| 128 | 128 | |
| 129 | 129 | $this->assertTrue($r->strict_ssl); |
| 130 | 130 | |
| 131 | 131 | $r = Request::init() |
| 132 | - ->withoutStrictSsl(); |
|
| 132 | + ->withoutStrictSsl(); |
|
| 133 | 133 | |
| 134 | 134 | $this->assertFalse($r->strict_ssl); |
| 135 | 135 | } |
@@ -9,7 +9,7 @@ discard block |
||
| 9 | 9 | */ |
| 10 | 10 | namespace Httpful\Test; |
| 11 | 11 | |
| 12 | -require(dirname(dirname(dirname(__FILE__))) . '/bootstrap.php'); |
|
| 12 | +require(dirname(dirname(dirname(__FILE__))).'/bootstrap.php'); |
|
| 13 | 13 | \Httpful\Bootstrap::init(); |
| 14 | 14 | |
| 15 | 15 | use Httpful\Httpful; |
@@ -19,7 +19,7 @@ discard block |
||
| 19 | 19 | use Httpful\Response; |
| 20 | 20 | use Httpful\Handlers\JsonHandler; |
| 21 | 21 | |
| 22 | -define('TEST_SERVER', WEB_SERVER_HOST . ':' . WEB_SERVER_PORT); |
|
| 22 | +define('TEST_SERVER', WEB_SERVER_HOST.':'.WEB_SERVER_PORT); |
|
| 23 | 23 | |
| 24 | 24 | class HttpfulTest extends \PHPUnit_Framework_TestCase |
| 25 | 25 | { |
@@ -101,21 +101,21 @@ discard block |
||
| 101 | 101 | function testShortMime() |
| 102 | 102 | { |
| 103 | 103 | // Valid short ones |
| 104 | - $this->assertEquals(Mime::JSON, Mime::getFullMime('json')); |
|
| 105 | - $this->assertEquals(Mime::XML, Mime::getFullMime('xml')); |
|
| 106 | - $this->assertEquals(Mime::HTML, Mime::getFullMime('html')); |
|
| 107 | - $this->assertEquals(Mime::CSV, Mime::getFullMime('csv')); |
|
| 108 | - $this->assertEquals(Mime::UPLOAD, Mime::getFullMime('upload')); |
|
| 104 | + $this->assertEquals(Mime::JSON, Mime::getFullMime('json')); |
|
| 105 | + $this->assertEquals(Mime::XML, Mime::getFullMime('xml')); |
|
| 106 | + $this->assertEquals(Mime::HTML, Mime::getFullMime('html')); |
|
| 107 | + $this->assertEquals(Mime::CSV, Mime::getFullMime('csv')); |
|
| 108 | + $this->assertEquals(Mime::UPLOAD, Mime::getFullMime('upload')); |
|
| 109 | 109 | |
| 110 | 110 | // Valid long ones |
| 111 | 111 | $this->assertEquals(Mime::JSON, Mime::getFullMime(Mime::JSON)); |
| 112 | - $this->assertEquals(Mime::XML, Mime::getFullMime(Mime::XML)); |
|
| 112 | + $this->assertEquals(Mime::XML, Mime::getFullMime(Mime::XML)); |
|
| 113 | 113 | $this->assertEquals(Mime::HTML, Mime::getFullMime(Mime::HTML)); |
| 114 | 114 | $this->assertEquals(Mime::CSV, Mime::getFullMime(Mime::CSV)); |
| 115 | 115 | $this->assertEquals(Mime::UPLOAD, Mime::getFullMime(Mime::UPLOAD)); |
| 116 | 116 | |
| 117 | 117 | // No false positives |
| 118 | - $this->assertNotEquals(Mime::XML, Mime::getFullMime(Mime::HTML)); |
|
| 118 | + $this->assertNotEquals(Mime::XML, Mime::getFullMime(Mime::HTML)); |
|
| 119 | 119 | $this->assertNotEquals(Mime::JSON, Mime::getFullMime(Mime::XML)); |
| 120 | 120 | $this->assertNotEquals(Mime::HTML, Mime::getFullMime(Mime::JSON)); |
| 121 | 121 | $this->assertNotEquals(Mime::XML, Mime::getFullMime(Mime::CSV)); |
@@ -276,13 +276,13 @@ discard block |
||
| 276 | 276 | $this->assertEquals("object", gettype($sxe)); |
| 277 | 277 | $this->assertEquals("SimpleXMLElement", get_class($sxe)); |
| 278 | 278 | $bools = $sxe->xpath('/stdClass/boolProp'); |
| 279 | - list( , $bool ) = each($bools); |
|
| 279 | + list(, $bool) = each($bools); |
|
| 280 | 280 | $this->assertEquals("TRUE", (string) $bool); |
| 281 | 281 | $ints = $sxe->xpath('/stdClass/arrayProp/array/k1/myClass/intProp'); |
| 282 | - list( , $int ) = each($ints); |
|
| 282 | + list(, $int) = each($ints); |
|
| 283 | 283 | $this->assertEquals("2", (string) $int); |
| 284 | 284 | $strings = $sxe->xpath('/stdClass/stringProp'); |
| 285 | - list( , $string ) = each($strings); |
|
| 285 | + list(, $string) = each($strings); |
|
| 286 | 286 | $this->assertEquals("a string", (string) $string); |
| 287 | 287 | } |
| 288 | 288 | |
@@ -322,14 +322,14 @@ discard block |
||
| 322 | 322 | |
| 323 | 323 | function testAttach() { |
| 324 | 324 | $req = Request::init(); |
| 325 | - $testsPath = realpath(dirname(__FILE__) . DIRECTORY_SEPARATOR . '..'); |
|
| 326 | - $filename = $testsPath . DIRECTORY_SEPARATOR . 'test_image.jpg'; |
|
| 325 | + $testsPath = realpath(dirname(__FILE__).DIRECTORY_SEPARATOR.'..'); |
|
| 326 | + $filename = $testsPath.DIRECTORY_SEPARATOR.'test_image.jpg'; |
|
| 327 | 327 | $req->attach(array('index' => $filename)); |
| 328 | 328 | $payload = $req->payload['index']; |
| 329 | 329 | // PHP 5.5 + will take advantage of CURLFile while previous |
| 330 | 330 | // versions just use the string syntax |
| 331 | 331 | if (is_string($payload)) { |
| 332 | - $this->assertEquals($payload, '@' . $filename . ';type=image/jpeg'); |
|
| 332 | + $this->assertEquals($payload, '@'.$filename.';type=image/jpeg'); |
|
| 333 | 333 | } else { |
| 334 | 334 | $this->assertInstanceOf('CURLFile', $payload); |
| 335 | 335 | } |
@@ -418,7 +418,7 @@ discard block |
||
| 418 | 418 | |
| 419 | 419 | try { |
| 420 | 420 | Request::get('malformed://url') |
| 421 | - ->beforeSend(function($request) use(&$invoked,$self) { |
|
| 421 | + ->beforeSend(function($request) use(&$invoked, $self) { |
|
| 422 | 422 | $self->assertEquals('malformed://url', $request->uri); |
| 423 | 423 | $self->assertEquals('A payload', $request->serialized_payload); |
| 424 | 424 | $request->uri('malformed2://url'); |
@@ -448,7 +448,7 @@ discard block |
||
| 448 | 448 | { |
| 449 | 449 | $req = Request::init()->sendsAndExpects(Mime::JSON); |
| 450 | 450 | $response = new Response(self::SAMPLE_JSON_RESPONSE, self::SAMPLE_JSON_HEADER, $req); |
| 451 | - $this->assertEquals(self::SAMPLE_JSON_RESPONSE, (string)$response); |
|
| 451 | + $this->assertEquals(self::SAMPLE_JSON_RESPONSE, (string) $response); |
|
| 452 | 452 | } |
| 453 | 453 | |
| 454 | 454 | function test_parseHeaders() |
@@ -570,7 +570,7 @@ discard block |
||
| 570 | 570 | |
| 571 | 571 | try { |
| 572 | 572 | $result = $handler->parse('invalid{json'); |
| 573 | - } catch(\Exception $e) { |
|
| 573 | + } catch (\Exception $e) { |
|
| 574 | 574 | $this->assertEquals('Unable to parse response as JSON', $e->getMessage()); |
| 575 | 575 | return; |
| 576 | 576 | } |
@@ -26,12 +26,12 @@ |
||
| 26 | 26 | $server_logs = file_get_contents("./server.log"); |
| 27 | 27 | if (strpos($server_logs, "Fail") !== false) { |
| 28 | 28 | // server failed to start for some reason |
| 29 | - print "Failed to start server! Logs:" . PHP_EOL . PHP_EOL; |
|
| 29 | + print "Failed to start server! Logs:".PHP_EOL.PHP_EOL; |
|
| 30 | 30 | print_r($server_logs); |
| 31 | 31 | exit(1); |
| 32 | 32 | } |
| 33 | 33 | |
| 34 | - echo sprintf('%s - Web server started on %s:%d with PID %d', date('r'), WEB_SERVER_HOST, WEB_SERVER_PORT, $pid) . PHP_EOL; |
|
| 34 | + echo sprintf('%s - Web server started on %s:%d with PID %d', date('r'), WEB_SERVER_HOST, WEB_SERVER_PORT, $pid).PHP_EOL; |
|
| 35 | 35 | |
| 36 | 36 | register_shutdown_function(function() { |
| 37 | 37 | // cleanup after ourselves -- remove log file, shut down server |
@@ -43,12 +43,12 @@ |
||
| 43 | 43 | |
| 44 | 44 | protected function stripBom($body) |
| 45 | 45 | { |
| 46 | - if ( substr($body,0,3) === "\xef\xbb\xbf" ) // UTF-8 |
|
| 47 | - $body = substr($body,3); |
|
| 48 | - else if ( substr($body,0,4) === "\xff\xfe\x00\x00" || substr($body,0,4) === "\x00\x00\xfe\xff" ) // UTF-32 |
|
| 49 | - $body = substr($body,4); |
|
| 50 | - else if ( substr($body,0,2) === "\xff\xfe" || substr($body,0,2) === "\xfe\xff" ) // UTF-16 |
|
| 51 | - $body = substr($body,2); |
|
| 46 | + if (substr($body, 0, 3) === "\xef\xbb\xbf") // UTF-8 |
|
| 47 | + $body = substr($body, 3); |
|
| 48 | + else if (substr($body, 0, 4) === "\xff\xfe\x00\x00" || substr($body, 0, 4) === "\x00\x00\xfe\xff") // UTF-32 |
|
| 49 | + $body = substr($body, 4); |
|
| 50 | + else if (substr($body, 0, 2) === "\xff\xfe" || substr($body, 0, 2) === "\xfe\xff") // UTF-16 |
|
| 51 | + $body = substr($body, 2); |
|
| 52 | 52 | return $body; |
| 53 | 53 | } |
| 54 | 54 | } |
| 55 | 55 | \ No newline at end of file |
@@ -43,12 +43,16 @@ |
||
| 43 | 43 | |
| 44 | 44 | protected function stripBom($body) |
| 45 | 45 | { |
| 46 | - if ( substr($body,0,3) === "\xef\xbb\xbf" ) // UTF-8 |
|
| 46 | + if ( substr($body,0,3) === "\xef\xbb\xbf" ) { |
|
| 47 | + // UTF-8 |
|
| 47 | 48 | $body = substr($body,3); |
| 48 | - else if ( substr($body,0,4) === "\xff\xfe\x00\x00" || substr($body,0,4) === "\x00\x00\xfe\xff" ) // UTF-32 |
|
| 49 | + } else if ( substr($body,0,4) === "\xff\xfe\x00\x00" || substr($body,0,4) === "\x00\x00\xfe\xff" ) { |
|
| 50 | + // UTF-32 |
|
| 49 | 51 | $body = substr($body,4); |
| 50 | - else if ( substr($body,0,2) === "\xff\xfe" || substr($body,0,2) === "\xfe\xff" ) // UTF-16 |
|
| 52 | + } else if ( substr($body,0,2) === "\xff\xfe" || substr($body,0,2) === "\xfe\xff" ) { |
|
| 53 | + // UTF-16 |
|
| 51 | 54 | $body = substr($body,2); |
| 55 | + } |
|
| 52 | 56 | return $body; |
| 53 | 57 | } |
| 54 | 58 | } |
| 55 | 59 | \ No newline at end of file |
@@ -19,7 +19,7 @@ discard block |
||
| 19 | 19 | return null; |
| 20 | 20 | |
| 21 | 21 | $parsed = array(); |
| 22 | - $fp = fopen('data://text/plain;base64,' . base64_encode($body), 'r'); |
|
| 22 | + $fp = fopen('data://text/plain;base64,'.base64_encode($body), 'r'); |
|
| 23 | 23 | while (($r = fgetcsv($fp)) !== FALSE) { |
| 24 | 24 | $parsed[] = $r; |
| 25 | 25 | } |
@@ -35,10 +35,10 @@ discard block |
||
| 35 | 35 | */ |
| 36 | 36 | public function serialize($payload) |
| 37 | 37 | { |
| 38 | - $fp = fopen('php://temp/maxmemory:'. (6*1024*1024), 'r+'); |
|
| 38 | + $fp = fopen('php://temp/maxmemory:'.(6 * 1024 * 1024), 'r+'); |
|
| 39 | 39 | $i = 0; |
| 40 | 40 | foreach ($payload as $fields) { |
| 41 | - if($i++ == 0) { |
|
| 41 | + if ($i++ == 0) { |
|
| 42 | 42 | fputcsv($fp, array_keys($fields)); |
| 43 | 43 | } |
| 44 | 44 | fputcsv($fp, $fields); |
@@ -15,8 +15,9 @@ discard block |
||
| 15 | 15 | */ |
| 16 | 16 | public function parse($body) |
| 17 | 17 | { |
| 18 | - if (empty($body)) |
|
| 19 | - return null; |
|
| 18 | + if (empty($body)) { |
|
| 19 | + return null; |
|
| 20 | + } |
|
| 20 | 21 | |
| 21 | 22 | $parsed = array(); |
| 22 | 23 | $fp = fopen('data://text/plain;base64,' . base64_encode($body), 'r'); |
@@ -24,8 +25,9 @@ discard block |
||
| 24 | 25 | $parsed[] = $r; |
| 25 | 26 | } |
| 26 | 27 | |
| 27 | - if (empty($parsed)) |
|
| 28 | - throw new \Exception("Unable to parse response as CSV"); |
|
| 28 | + if (empty($parsed)) { |
|
| 29 | + throw new \Exception("Unable to parse response as CSV"); |
|
| 30 | + } |
|
| 29 | 31 | return $parsed; |
| 30 | 32 | } |
| 31 | 33 | |
@@ -23,11 +23,13 @@ |
||
| 23 | 23 | public function parse($body) |
| 24 | 24 | { |
| 25 | 25 | $body = $this->stripBom($body); |
| 26 | - if (empty($body)) |
|
| 27 | - return null; |
|
| 26 | + if (empty($body)) { |
|
| 27 | + return null; |
|
| 28 | + } |
|
| 28 | 29 | $parsed = json_decode($body, $this->decode_as_array); |
| 29 | - if (is_null($parsed) && 'null' !== strtolower($body)) |
|
| 30 | - throw new \Exception("Unable to parse response as JSON"); |
|
| 30 | + if (is_null($parsed) && 'null' !== strtolower($body)) { |
|
| 31 | + throw new \Exception("Unable to parse response as JSON"); |
|
| 32 | + } |
|
| 31 | 33 | return $parsed; |
| 32 | 34 | } |
| 33 | 35 | |
@@ -25,8 +25,8 @@ discard block |
||
| 25 | 25 | */ |
| 26 | 26 | public function __construct(array $conf = array()) |
| 27 | 27 | { |
| 28 | - $this->namespace = isset($conf['namespace']) ? $conf['namespace'] : ''; |
|
| 29 | - $this->libxml_opts = isset($conf['libxml_opts']) ? $conf['libxml_opts'] : 0; |
|
| 28 | + $this->namespace = isset($conf['namespace']) ? $conf['namespace'] : ''; |
|
| 29 | + $this->libxml_opts = isset($conf['libxml_opts']) ? $conf['libxml_opts'] : 0; |
|
| 30 | 30 | } |
| 31 | 31 | |
| 32 | 32 | /** |
@@ -65,7 +65,7 @@ discard block |
||
| 65 | 65 | { |
| 66 | 66 | $xml = new \XMLWriter; |
| 67 | 67 | $xml->openMemory(); |
| 68 | - $xml->startDocument('1.0','ISO-8859-1'); |
|
| 68 | + $xml->startDocument('1.0', 'ISO-8859-1'); |
|
| 69 | 69 | $this->serialize_node($xml, $payload); |
| 70 | 70 | return $xml->outputMemory(true); |
| 71 | 71 | } |
@@ -75,11 +75,11 @@ discard block |
||
| 75 | 75 | * @param mixed $node to serialize |
| 76 | 76 | * @author Ted Zellers |
| 77 | 77 | */ |
| 78 | - public function serialize_node(&$xmlw, $node){ |
|
| 79 | - if (!is_array($node)){ |
|
| 78 | + public function serialize_node(&$xmlw, $node) { |
|
| 79 | + if (!is_array($node)) { |
|
| 80 | 80 | $xmlw->text($node); |
| 81 | 81 | } else { |
| 82 | - foreach ($node as $k => $v){ |
|
| 82 | + foreach ($node as $k => $v) { |
|
| 83 | 83 | $xmlw->startElement($k); |
| 84 | 84 | $this->serialize_node($xmlw, $v); |
| 85 | 85 | $xmlw->endElement(); |
@@ -112,7 +112,7 @@ discard block |
||
| 112 | 112 | $node->appendChild($arrNode); |
| 113 | 113 | $this->_future_serializeArrayAsXml($value, $arrNode, $dom); |
| 114 | 114 | } else if (is_bool($value)) { |
| 115 | - $node->appendChild($dom->createTextNode($value?'TRUE':'FALSE')); |
|
| 115 | + $node->appendChild($dom->createTextNode($value ? 'TRUE' : 'FALSE')); |
|
| 116 | 116 | } else { |
| 117 | 117 | $node->appendChild($dom->createTextNode($value)); |
| 118 | 118 | } |
@@ -37,11 +37,13 @@ |
||
| 37 | 37 | public function parse($body) |
| 38 | 38 | { |
| 39 | 39 | $body = $this->stripBom($body); |
| 40 | - if (empty($body)) |
|
| 41 | - return null; |
|
| 40 | + if (empty($body)) { |
|
| 41 | + return null; |
|
| 42 | + } |
|
| 42 | 43 | $parsed = simplexml_load_string($body, null, $this->libxml_opts, $this->namespace); |
| 43 | - if ($parsed === false) |
|
| 44 | - throw new \Exception("Unable to parse response as XML"); |
|
| 44 | + if ($parsed === false) { |
|
| 45 | + throw new \Exception("Unable to parse response as XML"); |
|
| 46 | + } |
|
| 45 | 47 | return $parsed; |
| 46 | 48 | } |
| 47 | 49 | |
@@ -11,17 +11,17 @@ discard block |
||
| 11 | 11 | { |
| 12 | 12 | |
| 13 | 13 | public $body, |
| 14 | - $raw_body, |
|
| 15 | - $headers, |
|
| 16 | - $raw_headers, |
|
| 17 | - $request, |
|
| 18 | - $code = 0, |
|
| 19 | - $content_type, |
|
| 20 | - $parent_type, |
|
| 21 | - $charset, |
|
| 22 | - $meta_data, |
|
| 23 | - $is_mime_vendor_specific = false, |
|
| 24 | - $is_mime_personal = false; |
|
| 14 | + $raw_body, |
|
| 15 | + $headers, |
|
| 16 | + $raw_headers, |
|
| 17 | + $request, |
|
| 18 | + $code = 0, |
|
| 19 | + $content_type, |
|
| 20 | + $parent_type, |
|
| 21 | + $charset, |
|
| 22 | + $meta_data, |
|
| 23 | + $is_mime_vendor_specific = false, |
|
| 24 | + $is_mime_personal = false; |
|
| 25 | 25 | |
| 26 | 26 | private $parsers; |
| 27 | 27 | |
@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | : $this->parent_type; |
| 105 | 105 | } |
| 106 | 106 | |
| 107 | - return Httpful::get($parse_with)->parse($body); |
|
| 107 | + return Httpful::get($parse_with)->parse($body); |
|
| 108 | 108 | } |
| 109 | 109 | |
| 110 | 110 | /** |
@@ -43,7 +43,7 @@ discard block |
||
| 43 | 43 | |
| 44 | 44 | $this->_interpretHeaders(); |
| 45 | 45 | |
| 46 | - $this->body = $this->_parse($body); |
|
| 46 | + $this->body = $this->_parse($body); |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | 49 | /** |
@@ -127,7 +127,7 @@ discard block |
||
| 127 | 127 | // If a header appears more than once, it must also be able to |
| 128 | 128 | // be represented as a single header with a comma-separated |
| 129 | 129 | // list of values. We transform accordingly. |
| 130 | - $parse_headers[$key] .= ',' . $value; |
|
| 130 | + $parse_headers[$key] .= ','.$value; |
|
| 131 | 131 | } else { |
| 132 | 132 | $parse_headers[$key] = $value; |
| 133 | 133 | } |
@@ -138,7 +138,9 @@ |
||
| 138 | 138 | public function _parseCode($headers) |
| 139 | 139 | { |
| 140 | 140 | $end = strpos($headers, "\r\n"); |
| 141 | - if ($end === false) $end = strlen($headers); |
|
| 141 | + if ($end === false) { |
|
| 142 | + $end = strlen($headers); |
|
| 143 | + } |
|
| 142 | 144 | $parts = explode(' ', substr($headers, 0, $end)); |
| 143 | 145 | if (count($parts) < 2 || !is_numeric($parts[1])) { |
| 144 | 146 | throw new \Exception("Unable to parse response code from HTTP response due to malformed response"); |