Seasx\SeasLogger\Kafka\RecordValidator::validate()

Complexity

Conditions	8
Paths	8

Size

Total Lines	28
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    public function validate(array $record, array $topicList): void
    {
        if (!isset($record['topic'])) {
            throw InvalidRecordInSet::missingTopic();
        }

        if (!is_string($record['topic'])) {
            throw InvalidRecordInSet::topicIsNotString();
        }

        if (trim($record['topic']) === '') {
            throw InvalidRecordInSet::missingTopic();
        }

        if (!isset($topicList[$record['topic']])) {
            throw InvalidRecordInSet::nonExististingTopic($record['topic']);
        }

        if (!isset($record['value'])) {
            throw InvalidRecordInSet::missingValue();
        }

        if (!is_string($record['value'])) {
            throw InvalidRecordInSet::valueIsNotString();
        }

        if (trim($record['value']) === '') {
            throw InvalidRecordInSet::missingValue();
        }