<?php
/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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
 *
 *     https://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.
 */

namespace Apache\Avro\Tests;

use Apache\Avro\Schema\AvroSchema;
use Apache\Avro\Schema\AvroSchemaParseException;
use PHPUnit\Framework\TestCase;

class SchemaExample
{
    public $schema_string;
    public $is_valid;
    public $name;
    public $comment;
    public $normalized_schema_string;

    public function __construct(
        $schema_string,
        $is_valid,
        $normalized_schema_string = null,
        $name = null,
        $comment = null
    ) {
        $this->schema_string = $schema_string;
        $this->is_valid = $is_valid;
        $this->name = $name ? $name : $schema_string;
        $this->normalized_schema_string = $normalized_schema_string
            ? $normalized_schema_string : json_encode(json_decode($schema_string, true));
        $this->comment = $comment;
    }
}

class SchemaTest extends TestCase
{
    static $examples = array();
    static $valid_examples = array();

    public function test_json_decode()
    {
        $this->assertEquals(json_decode('null', true), null);
        $this->assertEquals(json_decode('32', true), 32);
        $this->assertEquals(json_decode('"32"', true), '32');
        $this->assertEquals((array) json_decode('{"foo": 27}'), array("foo" => 27));
        $this->assertTrue(is_array(json_decode('{"foo": 27}', true)));
        $this->assertEquals(json_decode('{"foo": 27}', true), array("foo" => 27));
        $this->assertEquals(json_decode('["bar", "baz", "blurfl"]', true),
            array("bar", "baz", "blurfl"));
        $this->assertFalse(is_array(json_decode('null', true)));
        $this->assertEquals(json_decode('{"type": "null"}', true), array("type" => 'null'));

        // PHP now only accept lowercase true, and rejects TRUE etc.
        // https://php.net/manual/en/migration56.incompatible.php#migration56.incompatible.json-decode
        $this->assertEquals(json_decode('true', true), true, 'true');

        $this->assertEquals(json_decode('"boolean"'), 'boolean');
    }

    public function schema_examples_provider()
    {
        self::make_examples();
        $ary = array();
        foreach (self::$examples as $example) {
            $ary[] = array($example);
        }
        return $ary;
    }

    protected static function make_examples()
    {
        $primitive_examples = array_merge(array(
            new SchemaExample('"True"', false),
            new SchemaExample('{"no_type": "test"}', false),
            new SchemaExample('{"type": "panther"}', false)
        ),
            self::make_primitive_examples());

        $array_examples = array(
            new SchemaExample('{"type": "array", "items": "long"}', true),
            new SchemaExample('
    {"type": "array",
     "items": {"type": "enum", "name": "Test", "symbols": ["A", "B"]}}
    ', true)
        );

        $map_examples = array(
            new SchemaExample('{"type": "map", "values": "long"}', true),
            new SchemaExample('
    {"type": "map",
     "values": {"type": "enum", "name": "Test", "symbols": ["A", "B"]}}
    ', true)
        );

        $union_examples = array(
            new SchemaExample('["string", "null", "long"]', true),
            new SchemaExample('["null", "null"]', false),
            new SchemaExample('["long", "long"]', false),
            new SchemaExample('
    [{"type": "array", "items": "long"}
     {"type": "array", "items": "string"}]
    ', false),
            new SchemaExample('["long",
                          {"type": "long"},
                          "int"]', false),
            new SchemaExample('["long",
                          {"type": "array", "items": "long"},
                          {"type": "map", "values": "long"},
                          "int"]', true),
            new SchemaExample('["long",
                          ["string", "null"],
                          "int"]', false),
            new SchemaExample('["long",
                          ["string", "null"],
                          "int"]', false),
            new SchemaExample('["null", "boolean", "int", "long", "float", "double",
                          "string", "bytes",
                          {"type": "array", "items":"int"},
                          {"type": "map", "values":"int"},
                          {"name": "bar", "type":"record",
                           "fields":[{"name":"label", "type":"string"}]},
                          {"name": "foo", "type":"fixed",
                           "size":16},
                          {"name": "baz", "type":"enum", "symbols":["A", "B", "C"]}
                         ]', true,
                '["null","boolean","int","long","float","double","string","bytes",{"type":"array","items":"int"},{"type":"map","values":"int"},{"type":"record","name":"bar","fields":[{"name":"label","type":"string"}]},{"type":"fixed","name":"foo","size":16},{"type":"enum","name":"baz","symbols":["A","B","C"]}]'),
            new SchemaExample('
    [{"name":"subtract", "namespace":"com.example",
      "type":"record",
      "fields":[{"name":"minuend", "type":"int"},
                {"name":"subtrahend", "type":"int"}]},
      {"name": "divide", "namespace":"com.example",
      "type":"record",
      "fields":[{"name":"quotient", "type":"int"},
                {"name":"dividend", "type":"int"}]},
      {"type": "array", "items": "string"}]
    ', true,
                '[{"type":"record","name":"subtract","namespace":"com.example","fields":[{"name":"minuend","type":"int"},{"name":"subtrahend","type":"int"}]},{"type":"record","name":"divide","namespace":"com.example","fields":[{"name":"quotient","type":"int"},{"name":"dividend","type":"int"}]},{"type":"array","items":"string"}]'),
        );

        $fixed_examples = [
            new SchemaExample('{"type": "fixed", "name": "Test", "size": 1}', true),
            new SchemaExample('
    {"type": "fixed",
     "name": "MyFixed",
     "namespace": "org.apache.hadoop.avro",
     "size": 1}
    ', true),
            new SchemaExample('
    {"type": "fixed",
     "name": "Missing size"}
    ', false),
            new SchemaExample('
    {"type": "fixed",
     "size": 314}
    ', false),
            new SchemaExample('{"type":"fixed","name":"ex","doc":"this should be ignored","size": 314}',
                true,
                '{"type":"fixed","name":"ex","size":314}'),
            new SchemaExample('{"name": "bar",
                          "namespace": "com.example",
                          "type": "fixed",
                          "size": 32 }', true,
                '{"type":"fixed","name":"bar","namespace":"com.example","size":32}'),
            new SchemaExample('{"name": "com.example.bar",
                          "type": "fixed",
                          "size": 32 }', true,
                '{"type":"fixed","name":"bar","namespace":"com.example","size":32}')
        ];

        $fixed_examples [] = new SchemaExample(
            '{"type":"fixed","name":"_x.bar","size":4}', true,
            '{"type":"fixed","name":"bar","namespace":"_x","size":4}');
        $fixed_examples [] = new SchemaExample(
            '{"type":"fixed","name":"baz._x","size":4}', true,
            '{"type":"fixed","name":"_x","namespace":"baz","size":4}');
        $fixed_examples [] = new SchemaExample(
            '{"type":"fixed","name":"baz.3x","size":4}', false);
        $fixed_examples[] = new SchemaExample(
            '{"type":"fixed", "name":"Fixed2", "aliases":["Fixed1"], "size": 2}', true);

        $enum_examples = array(
            new SchemaExample('{"type": "enum", "name": "Test", "symbols": ["A", "B"]}', true),
            new SchemaExample('
    {"type": "enum",
     "name": "Status",
     "symbols": "Normal Caution Critical"}
    ', false),
            new SchemaExample('
    {"type": "enum",
     "name": [ 0, 1, 1, 2, 3, 5, 8 ],
     "symbols": ["Golden", "Mean"]}
    ', false),
            new SchemaExample('
    {"type": "enum",
     "symbols" : ["I", "will", "fail", "no", "name"]}
    ', false),
            new SchemaExample('
    {"type": "enum",
     "name": "Test"
     "symbols" : ["AA", "AA"]}
    ', false),
            new SchemaExample('{"type":"enum","name":"Test","symbols":["AA", 16]}',
                false),
            new SchemaExample('
    {"type": "enum",
     "name": "blood_types",
     "doc": "AB is freaky.",
     "symbols" : ["A", "AB", "B", "O"]}
    ', true),
            new SchemaExample('
    {"type": "enum",
     "name": "blood-types",
     "doc": 16,
     "symbols" : ["A", "AB", "B", "O"]}
    ', false)
        );


        $record_examples = array();
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Test",
     "fields": [{"name": "f",
                 "type": "long"}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "error",
     "name": "Test",
     "fields": [{"name": "f",
                 "type": "long"}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Node",
     "fields": [{"name": "label", "type": "string"},
                {"name": "children",
                 "type": {"type": "array", "items": "Node"}}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "ListLink",
     "fields": [{"name": "car", "type": "int"},
                {"name": "cdr", "type": "ListLink"}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Lisp",
     "fields": [{"name": "value",
                 "type": ["null", "string"]}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Lisp",
     "fields": [{"name": "value",
                 "type": ["null", "string",
                          {"type": "record",
                           "name": "Cons",
                           "fields": [{"name": "car", "type": "string"},
                                      {"name": "cdr", "type": "string"}]}]}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Lisp",
     "fields": [{"name": "value",
                 "type": ["null", "string",
                          {"type": "record",
                           "name": "Cons",
                           "fields": [{"name": "car", "type": "Lisp"},
                                      {"name": "cdr", "type": "Lisp"}]}]}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "HandshakeRequest",
     "namespace": "org.apache.avro.ipc",
     "fields": [{"name": "clientHash",
                 "type": {"type": "fixed", "name": "MD5", "size": 16}},
                {"name": "meta",
                 "type": ["null", {"type": "map", "values": "bytes"}]}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "HandshakeRequest",
     "namespace": "org.apache.avro.ipc",
     "fields": [{"name": "clientHash",
                 "type": {"type": "fixed", "name": "MD5", "size": 16}},
                {"name": "clientProtocol", "type": ["null", "string"]},
                {"name": "serverHash", "type": "MD5"},
                {"name": "meta",
                 "type": ["null", {"type": "map", "values": "bytes"}]}]}
    ', true);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "HandshakeResponse",
     "namespace": "org.apache.avro.ipc",
     "fields": [{"name": "match",
                 "type": {"type": "enum",
                          "name": "HandshakeMatch",
                          "symbols": ["BOTH", "CLIENT", "NONE"]}},
                {"name": "serverProtocol", "type": ["null", "string"]},
                {"name": "serverHash",
                 "type": ["null",
                          {"name": "MD5", "size": 16, "type": "fixed"}]},
                {"name": "meta",
                 "type": ["null", {"type": "map", "values": "bytes"}]}]}
    ', true,
            '{"type":"record","name":"HandshakeResponse","namespace":"org.apache.avro.ipc","fields":[{"name":"match","type":{"type":"enum","name":"HandshakeMatch","symbols":["BOTH","CLIENT","NONE"]}},{"name":"serverProtocol","type":["null","string"]},{"name":"serverHash","type":["null",{"type":"fixed","name":"MD5","size":16}]},{"name":"meta","type":["null",{"type":"map","values":"bytes"}]}]}'
        );
        $record_examples [] = new SchemaExample('{"type": "record",
 "namespace": "org.apache.avro",
 "name": "Interop",
 "fields": [{"type": {"fields": [{"type": {"items": "org.apache.avro.Node",
                                           "type": "array"},
                                  "name": "children"}],
                      "type": "record",
                      "name": "Node"},
             "name": "recordField"}]}
', true,
            '{"type":"record","name":"Interop","namespace":"org.apache.avro","fields":[{"name":"recordField","type":{"type":"record","name":"Node","fields":[{"name":"children","type":{"type":"array","items":"Node"}}]}}]}');
        $record_examples [] = new SchemaExample('{"type": "record",
 "namespace": "org.apache.avro",
 "name": "Interop",
 "fields": [{"type": {"symbols": ["A", "B", "C"], "type": "enum", "name": "Kind"},
             "name": "enumField"},
            {"type": {"fields": [{"type": "string", "name": "label"},
                                 {"type": {"items": "org.apache.avro.Node", "type": "array"},
                                  "name": "children"}],
                      "type": "record",
                      "name": "Node"},
             "name": "recordField"}]}', true,
            '{"type":"record","name":"Interop","namespace":"org.apache.avro","fields":[{"name":"enumField","type":{"type":"enum","name":"Kind","symbols":["A","B","C"]}},{"name":"recordField","type":{"type":"record","name":"Node","fields":[{"name":"label","type":"string"},{"name":"children","type":{"type":"array","items":"Node"}}]}}]}');

        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Interop",
     "namespace": "org.apache.avro",
     "fields": [{"name": "intField", "type": "int"},
                {"name": "longField", "type": "long"},
                {"name": "stringField", "type": "string"},
                {"name": "boolField", "type": "boolean"},
                {"name": "floatField", "type": "float"},
                {"name": "doubleField", "type": "double"},
                {"name": "bytesField", "type": "bytes"},
                {"name": "nullField", "type": "null"},
                {"name": "arrayField",
                 "type": {"type": "array", "items": "double"}},
                {"name": "mapField",
                 "type": {"type": "map",
                          "values": {"name": "Foo",
                                     "type": "record",
                                     "fields": [{"name": "label",
                                                 "type": "string"}]}}},
                {"name": "unionField",
                 "type": ["boolean",
                          "double",
                          {"type": "array", "items": "bytes"}]},
                {"name": "enumField",
                 "type": {"type": "enum",
                          "name": "Kind",
                          "symbols": ["A", "B", "C"]}},
                {"name": "fixedField",
                 "type": {"type": "fixed", "name": "MD5", "size": 16}},
                {"name": "recordField",
                 "type": {"type": "record",
                          "name": "Node",
                          "fields": [{"name": "label", "type": "string"},
                                     {"name": "children",
                                      "type": {"type": "array",
                                               "items": "Node"}}]}}]}
    ', true,
            '{"type":"record","name":"Interop","namespace":"org.apache.avro","fields":[{"name":"intField","type":"int"},{"name":"longField","type":"long"},{"name":"stringField","type":"string"},{"name":"boolField","type":"boolean"},{"name":"floatField","type":"float"},{"name":"doubleField","type":"double"},{"name":"bytesField","type":"bytes"},{"name":"nullField","type":"null"},{"name":"arrayField","type":{"type":"array","items":"double"}},{"name":"mapField","type":{"type":"map","values":{"type":"record","name":"Foo","fields":[{"name":"label","type":"string"}]}}},{"name":"unionField","type":["boolean","double",{"type":"array","items":"bytes"}]},{"name":"enumField","type":{"type":"enum","name":"Kind","symbols":["A","B","C"]}},{"name":"fixedField","type":{"type":"fixed","name":"MD5","size":16}},{"name":"recordField","type":{"type":"record","name":"Node","fields":[{"name":"label","type":"string"},{"name":"children","type":{"type":"array","items":"Node"}}]}}]}');
        $record_examples [] = new SchemaExample('{"type": "record", "namespace": "org.apache.avro", "name": "Interop", "fields": [{"type": "int", "name": "intField"}, {"type": "long", "name": "longField"}, {"type": "string", "name": "stringField"}, {"type": "boolean", "name": "boolField"}, {"type": "float", "name": "floatField"}, {"type": "double", "name": "doubleField"}, {"type": "bytes", "name": "bytesField"}, {"type": "null", "name": "nullField"}, {"type": {"items": "double", "type": "array"}, "name": "arrayField"}, {"type": {"type": "map", "values": {"fields": [{"type": "string", "name": "label"}], "type": "record", "name": "Foo"}}, "name": "mapField"}, {"type": ["boolean", "double", {"items": "bytes", "type": "array"}], "name": "unionField"}, {"type": {"symbols": ["A", "B", "C"], "type": "enum", "name": "Kind"}, "name": "enumField"}, {"type": {"type": "fixed", "name": "MD5", "size": 16}, "name": "fixedField"}, {"type": {"fields": [{"type": "string", "name": "label"}, {"type": {"items": "org.apache.avro.Node", "type": "array"}, "name": "children"}], "type": "record", "name": "Node"}, "name": "recordField"}]}
', true,
            '{"type":"record","name":"Interop","namespace":"org.apache.avro","fields":[{"name":"intField","type":"int"},{"name":"longField","type":"long"},{"name":"stringField","type":"string"},{"name":"boolField","type":"boolean"},{"name":"floatField","type":"float"},{"name":"doubleField","type":"double"},{"name":"bytesField","type":"bytes"},{"name":"nullField","type":"null"},{"name":"arrayField","type":{"type":"array","items":"double"}},{"name":"mapField","type":{"type":"map","values":{"type":"record","name":"Foo","fields":[{"name":"label","type":"string"}]}}},{"name":"unionField","type":["boolean","double",{"type":"array","items":"bytes"}]},{"name":"enumField","type":{"type":"enum","name":"Kind","symbols":["A","B","C"]}},{"name":"fixedField","type":{"type":"fixed","name":"MD5","size":16}},{"name":"recordField","type":{"type":"record","name":"Node","fields":[{"name":"label","type":"string"},{"name":"children","type":{"type":"array","items":"Node"}}]}}]}');
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "ipAddr",
     "fields": [{"name": "addr",
                 "type": [{"name": "IPv6", "type": "fixed", "size": 16},
                          {"name": "IPv4", "type": "fixed", "size": 4}]}]}
    ', true,
            '{"type":"record","name":"ipAddr","fields":[{"name":"addr","type":[{"type":"fixed","name":"IPv6","size":16},{"type":"fixed","name":"IPv4","size":4}]}]}');
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Address",
     "fields": [{"type": "string"},
                {"type": "string", "name": "City"}]}
    ', false);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "name": "Event",
     "fields": [{"name": "Sponsor"},
                {"name": "City", "type": "string"}]}
    ', false);
        $record_examples [] = new SchemaExample('
    {"type": "record",
     "fields": "His vision, from the constantly passing bars,"
     "name", "Rainer"}
    ', false);
        $record_examples [] = new SchemaExample('
    {"name": ["Tom", "Jerry"],
     "type": "record",
     "fields": [{"name": "name", "type": "string"}]}
    ', false);
        $record_examples [] = new SchemaExample('
    {"type":"record","name":"foo","doc":"doc string",
     "fields":[{"name":"bar", "type":"int", "order":"ascending", "default":1}]}
',
            true,
            '{"type":"record","name":"foo","doc":"doc string","fields":[{"name":"bar","type":"int","default":1,"order":"ascending"}]}');
        $record_examples [] = new SchemaExample('
    {"type":"record", "name":"foo", "doc":"doc string",
     "fields":[{"name":"bar", "type":"int", "order":"bad"}]}
', false);
        $record_examples[] = new SchemaExample(
            '{"type":"record", "name":"Record2", "aliases":["Record1"]}', false);

        self::$examples = array_merge($primitive_examples,
            $fixed_examples,
            $enum_examples,
            $array_examples,
            $map_examples,
            $union_examples,
            $record_examples);
        self::$valid_examples = array();
        foreach (self::$examples as $example) {
            if ($example->is_valid) {
                self::$valid_examples [] = $example;
            }
        }
    }

    protected static function make_primitive_examples()
    {
        $examples = array();
        foreach ([
                     'null',
                     'boolean',
                     'int',
                     'long',
                     'float',
                     'double',
                     'bytes',
                     'string'
                 ]
                 as $type) {
            $examples [] = new SchemaExample(sprintf('"%s"', $type), true);
            $examples [] = new SchemaExample(sprintf('{"type": "%s"}', $type), true, sprintf('"%s"', $type));
        }
        return $examples;
    }

    /**
     * @dataProvider schema_examples_provider
     */
    function test_parse($example)
    {
        $schema_string = $example->schema_string;
        try {
            $normalized_schema_string = $example->normalized_schema_string;
            $schema = AvroSchema::parse($schema_string);
            $this->assertTrue($example->is_valid,
                sprintf("schema_string: %s\n",
                    $schema_string));
            $this->assertEquals($normalized_schema_string, (string) $schema);
        } catch (AvroSchemaParseException $e) {
            $this->assertFalse($example->is_valid,
                sprintf("schema_string: %s\n%s",
                    $schema_string,
                    $e->getMessage()));
        }
    }

    public function testToAvroIncludesAliases()
    {
        $hash = <<<SCHEMA
{
    "type": "record",
    "name": "test_record",
    "aliases": ["alt_record"],
    "fields": [
        { "name": "f", "type": { "type": "fixed", "size": 2, "name": "test_fixed", "aliases": ["alt_fixed"] } },
        { "name": "e", "type": { "type": "enum", "symbols": ["A", "B"], "name": "test_enum", "aliases": ["alt_enum"] } }
    ]
}
SCHEMA;
        $schema = AvroSchema::parse($hash);
        $this->assertEquals($schema->toAvro(), json_decode($hash, true));
    }

    public function testValidateFieldAliases()
    {
        $this->expectException(AvroSchemaParseException::class);
        $this->expectExceptionMessage('Invalid aliases value. Must be an array of strings.');
        AvroSchema::parse(<<<SCHEMA
{
    "type": "record",
    "name": "fruits",
    "fields": [
        {
            "name": "banana",
            "type": "string",
            "aliases": "banane"
        }
    ]
}
SCHEMA);
    }

    public function testValidateRecordAliases()
    {
        $this->expectException(AvroSchemaParseException::class);
        $this->expectExceptionMessage('Invalid aliases value. Must be an array of strings.');
        AvroSchema::parse(<<<SCHEMA
{
    "type": "record",
    "name": "fruits",
    "aliases": ["foods", 2],
    "fields": []
}
SCHEMA);
    }

    public function testValidateFixedAliases()
    {
        $this->expectException(AvroSchemaParseException::class);
        $this->expectExceptionMessage('Invalid aliases value. Must be an array of strings.');
        AvroSchema::parse(<<<SCHEMA
{
    "type": "fixed",
    "name": "uuid",
    "size": 36,
    "aliases": "unique_id"
}
SCHEMA);
    }

    public function testValidateEnumAliases()
    {
        $this->expectException(AvroSchemaParseException::class);
        $this->expectExceptionMessage('Invalid aliases value. Must be an array of strings.');
        AvroSchema::parse(<<<SCHEMA
{
    "type": "enum",
    "name": "vowels",
    "aliases": [1, 2],
    "symbols": ["A", "E", "I", "O", "U"]
}
SCHEMA);
    }

    public function testValidateSameAliasMultipleFields()
    {
        $this->expectException(AvroSchemaParseException::class);
        $this->expectExceptionMessage('Alias already in use');
        AvroSchema::parse(<<<SCHEMA
{
    "type": "record",
    "name": "fruits",
    "fields": [
        {"name": "banana", "type": "string", "aliases": [ "yellow" ]},
        {"name": "lemo", "type": "string", "aliases": [ "yellow" ]}
    ]
}
SCHEMA);
    }

    public function testValidateRepeatedAliases()
    {
        $this->expectNotToPerformAssertions();
        AvroSchema::parse(<<<SCHEMA
{
    "type": "record",
    "name": "fruits",
    "fields": [
        {
            "name": "banana",
            "type": "string",
            "aliases": [
                "yellow",
                "yellow"
            ]
        }
    ]
}
SCHEMA);
    }
}