ObjectReaderRootName.java

package com.alibaba.fastjson2.reader;

import com.alibaba.fastjson2.JSONException;
import com.alibaba.fastjson2.JSONReader;
import com.alibaba.fastjson2.schema.JSONSchema;
import com.alibaba.fastjson2.util.Fnv;

import java.lang.reflect.Type;
import java.util.Map;
import java.util.function.Function;
import java.util.function.Supplier;

public final class ObjectReaderRootName<T>
        extends ObjectReaderAdapter<T> {
    final String rootName;
    final long rootNameHashCode;

    public ObjectReaderRootName(
            Class objectClass,
            String typeKey,
            String typeName,
            String rootName,
            long features,
            JSONSchema schema,
            Supplier creator,
            Function buildFunction,
            Class[] seeAlso,
            String[] seeAlsoNames,
            Class seeAlsoDefault,
            FieldReader[] fieldReaders) {
        super(
                objectClass,
                typeKey,
                typeName,
                features,
                schema,
                creator,
                buildFunction,
                seeAlso,
                seeAlsoNames,
                seeAlsoDefault,
                fieldReaders
        );
        this.rootName = rootName;
        this.rootNameHashCode = rootName == null ? 0 : Fnv.hashCode64(rootName);
    }

    public T createInstance(Map map, long features) {
        Map object = (Map) map.get(rootName);
        if (object == null) {
            return null;
        }
        return super.createInstance(object, features);
    }

    @Override
    public T readJSONBObject(JSONReader jsonReader, Type fieldType, Object fieldName, long features) {
        if (jsonReader.nextIfNullOrEmptyString()) {
            return null;
        }
        boolean objectStart = jsonReader.nextIfObjectStart();
        if (!objectStart) {
            throw new JSONException(jsonReader.info("read rootName error " + typeName));
        }

        T object = null;
        for (int i = 0; ; i++) {
            if (jsonReader.nextIfObjectEnd()) {
                break;
            }
            if (rootNameHashCode == jsonReader.readFieldNameHashCode()) {
                object = super.readJSONBObject(jsonReader, fieldType, fieldName, features);
            } else {
                jsonReader.skipValue();
            }
        }
        return object;
    }

    @Override
    public T readObject(JSONReader jsonReader, Type fieldType, Object fieldName, long features) {
        if (jsonReader.nextIfNullOrEmptyString()) {
            return null;
        }
        boolean objectStart = jsonReader.nextIfObjectStart();
        if (!objectStart) {
            throw new JSONException(jsonReader.info("read rootName error " + typeName));
        }

        T object = null;
        for (int i = 0; ; i++) {
            if (jsonReader.nextIfObjectEnd()) {
                break;
            }
            if (rootNameHashCode == jsonReader.readFieldNameHashCode()) {
                object = super.readObject(jsonReader, fieldType, fieldName, features);
            } else {
                jsonReader.skipValue();
            }
        }
        return object;
    }
}