From: Erik Bernhardson <ebernhardson@wikimedia.org>
Date: Mon, 28 Dec 2015 23:41:14 +0000 (-0800)
Subject: [debug] Remove BC code from AvroFormatter
X-Git-Tag: 1.31.0-rc.0~8088^2
X-Git-Url: https://git.cyclocoop.org/%7B%24www_url%7Dadmin/compta/banques/ajouter.php?a=commitdiff_plain;h=a964ca2ba918f64352a3bdf93fe746407e2cd8bf;p=lhc%2Fweb%2Fwiklou.git

[debug] Remove BC code from AvroFormatter

Deployed usages of avro now use the new format, allowing
this old style will only cause pain to those that attempt
to use it in the future.

Change-Id: Id27ed7b529153ef7983b9fc3c1250b19dc4a516f
---

diff --git a/includes/debug/logger/monolog/AvroFormatter.php b/includes/debug/logger/monolog/AvroFormatter.php
index 510d42aab0..eb1a0d0d64 100644
--- a/includes/debug/logger/monolog/AvroFormatter.php
+++ b/includes/debug/logger/monolog/AvroFormatter.php
@@ -85,7 +85,7 @@ class AvroFormatter implements FormatterInterface {
 		$this->io->truncate();
 		$schema = $this->getSchema( $record['channel'] );
 		$revId = $this->getSchemaRevisionId( $record['channel'] );
-		if ( $schema === null ) {
+		if ( $schema === null || $revId === null ) {
 			trigger_error( "The schema for channel '{$record['channel']}' is not available" );
 			return null;
 		}
@@ -97,11 +97,7 @@ class AvroFormatter implements FormatterInterface {
 			trigger_error( "Avro failed to serialize record for {$record['channel']} : {$json}" );
 			return null;
 		}
-		if ( $revId !== null ) {
-			return chr( self::MAGIC ) . $this->encode_long( $revId ) . $this->io->string();
-		}
-		// @todo: remove backward compat code and do not send messages without rev id.
-		return $this->io->string();
+		return chr( self::MAGIC ) . $this->encodeLong( $revId ) . $this->io->string();
 	}
 
 	/**
@@ -132,27 +128,23 @@ class AvroFormatter implements FormatterInterface {
 		if ( !isset( $this->schemas[$channel] ) ) {
 			return null;
 		}
-		$schemaDetails = &$this->schemas[$channel];
-		$schema = null;
-		if ( isset( $schemaDetails['revision'] ) && isset( $schemaDetails['schema'] ) ) {
-			$schema = &$schemaDetails['schema'];
-		} else {
-			// @todo: Remove backward compat code
-			$schema = &$schemaDetails;
+		if ( !isset( $this->schemas[$channel]['revision'], $this->schemas[$channel]['schema'] ) ) {
+			return null;
 		}
 
-		if ( !$schema instanceof AvroSchema ) {
+		if ( !$this->schemas[$channel]['schema'] instanceof AvroSchema ) {
+			$schema = $this->schemas[$channel]['schema'];
 			if ( is_string( $schema ) ) {
-				$schema = AvroSchema::parse( $schema );
+				$this->schemas[$channel]['schema'] = AvroSchema::parse( $schema );
 			} else {
-				$schema = AvroSchema::real_parse(
-					$this->schemas[$channel],
+				$this->schemas[$channel]['schema'] = AvroSchema::real_parse(
+					$schema,
 					null,
 					new AvroNamedSchemata()
 				);
 			}
 		}
-		return $schema;
+		return $this->schemas[$channel]['schema'];
 	}
 
 	/**
@@ -162,23 +154,19 @@ class AvroFormatter implements FormatterInterface {
 	 * @return int|null
 	 */
 	public function getSchemaRevisionId( $channel ) {
-		// @todo: remove backward compat code
-		if ( isset( $this->schemas[$channel] )
-				&& is_array( $this->schemas[$channel] )
-				&& isset( $this->schemas[$channel]['revision'] ) ) {
+		if ( isset( $this->schemas[$channel]['revision'] ) ) {
 			return (int) $this->schemas[$channel]['revision'];
 		}
 		return null;
 	}
 
-
 	/**
 	 * convert an integer to a 64bits big endian long (Java compatible)
 	 * NOTE: certainly only compatible with PHP 64bits
 	 * @param int $id
 	 * @return string the binary representation of $id
 	 */
-	private function encode_long( $id ) {
+	private function encodeLong( $id ) {
 		$high   = ( $id & 0xffffffff00000000 ) >> 32;
 		$low    = $id & 0x00000000ffffffff;
 		return pack( 'NN', $high, $low );
diff --git a/tests/phpunit/includes/debug/logger/monolog/AvroFormatterTest.php b/tests/phpunit/includes/debug/logger/monolog/AvroFormatterTest.php
index b0df61639c..b28de5797f 100644
--- a/tests/phpunit/includes/debug/logger/monolog/AvroFormatterTest.php
+++ b/tests/phpunit/includes/debug/logger/monolog/AvroFormatterTest.php
@@ -55,13 +55,19 @@ class AvroFormatterTest extends MediaWikiTestCase {
 	}
 
 	public function testDoesSomethingWhenSchemaAvailable() {
-		$formatter = new AvroFormatter( array( 'string' => array( 'type' => 'string' ) ) );
+		$formatter = new AvroFormatter( array(
+			'string' => array(
+				'schema' => array( 'type' => 'string' ),
+				'revision' => 1010101,
+			)
+		) );
 		$res = $formatter->format( array(
 			'channel' => 'string',
 			'context' => 'better to be',
 		) );
 		$this->assertNotNull( $res );
-		// basically just tell us if avro changes its string encoding
-		$this->assertEquals( base64_decode( 'GGJldHRlciB0byBiZQ==' ), $res );
+		// basically just tell us if avro changes its string encoding, or if
+		// we completely fail to generate a log message.
+		$this->assertEquals( 'AAAAAAAAD2m1GGJldHRlciB0byBiZQ==', base64_encode( $res ) );
 	}
 }