import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@JsonDetails
public Map<String, Object> getData() {
    HashMap<String, Object> data = new HashMap<>();
    Map<String, Class<? extends DataManipulator<?, ?>>> supData = WebAPI.getSerializeService().getSupportedData();
    for (Map.Entry<String, Class<? extends DataManipulator<?, ?>>> entry : supData.entrySet()) {
        try {
            if (!value.supports(entry.getValue()))
                continue;

            Optional<?> m = value.get(entry.getValue());

            if (!m.isPresent())
                continue;

            data.put(entry.getKey(), ((DataManipulator) m.get()).copy());
        } catch (IllegalArgumentException | IllegalStateException ignored) {
        }
    }
    return data;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
default boolean removeFast(Class<? extends DataManipulator<?,?>> containerClass) {
    checkNotNull(containerClass, "containerClass");
    // You cannot remove default data manipulators?
    final Optional optRegistration = DataManipulatorRegistry.get().getBy(containerClass);
    if (optRegistration.isPresent()) {
        return false;
    }

    if (this instanceof AdditionalContainerHolder) {
        final AdditionalContainerCollection<DataManipulator<?,?>> containers =
                ((AdditionalContainerHolder<DataManipulator<?,?>>) this).getAdditionalContainers();
        final Optional<DataManipulator<?,?>> old = containers.remove(containerClass);
        if (old.isPresent()) {
            return true;
        }
    }

    return false;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
default DataTransactionResult remove(Class<? extends DataManipulator<?,?>> containerClass) {
    checkNotNull(containerClass, "containerClass");
    // You cannot remove default data manipulators?
    final Optional optRegistration = DataManipulatorRegistry.get().getBy(containerClass);
    if (optRegistration.isPresent()) {
        return DataTransactionResult.failNoData();
    }

    if (this instanceof AdditionalContainerHolder) {
        final AdditionalContainerCollection<DataManipulator<?,?>> containers =
                ((AdditionalContainerHolder<DataManipulator<?,?>>) this).getAdditionalContainers();
        final Optional<DataManipulator<?,?>> old = containers.remove(containerClass);
        if (old.isPresent()) {
            return DataTransactionResult.successRemove(old.get().getValues());
        }
    }

    return DataTransactionResult.failNoData();
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
default boolean supports(Class<? extends DataManipulator<?,?>> containerClass) {
    checkNotNull(containerClass, "containerClass");

    // Offer all the default key values as long if they are supported
    final Optional<DataManipulatorRegistration> optRegistration = DataManipulatorRegistry.get().getBy(containerClass);
    if (optRegistration.isPresent()) {
        final DataManipulatorRegistration registration = optRegistration.get();
        for (Key key : (Set<Key>) registration.getRequiredKeys()) {
            if (!supports(key)) {
                return false;
            }
        }
        return true;
    }

    // Support all the additional manipulators
    return this instanceof AdditionalContainerHolder;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
default <T extends DataManipulator<?,?>> Optional<T> get(Class<T> containerClass) {
    checkNotNull(containerClass, "containerClass");

    // Check default registrations
    final Optional<DataManipulatorRegistration> optRegistration = DataManipulatorRegistry.get().getBy(containerClass);
    if (optRegistration.isPresent()) {
        final DataManipulator manipulator = DataHelper.create(this, optRegistration.get());
        return manipulator == null ? Optional.empty() : Optional.of(
                (T) (ImmutableDataManipulator.class.isAssignableFrom(containerClass) ? manipulator.asImmutable() : manipulator));
    }

    // Try the additional containers if they are supported
    if (this instanceof AdditionalContainerHolder) {
        final AdditionalContainerCollection<DataManipulator<?,?>> containers =
                ((AdditionalContainerHolder<DataManipulator<?,?>>) this).getAdditionalContainers();
        return containers.get(containerClass);
    }

    return Optional.empty();
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
default Collection<DataManipulator<?, ?>> getContainers() {
    final ImmutableList.Builder<DataManipulator<?, ?>> builder = ImmutableList.builder();
    for (DataManipulatorRegistration registration : DataManipulatorRegistry.get().getAll()) {
        final DataManipulator manipulator = DataHelper.create(this, registration);
        if (manipulator != null) {
            builder.add(manipulator);
        }
    }

    // Try the additional manipulators if they are supported
    if (this instanceof AdditionalContainerHolder) {
        final AdditionalContainerCollection<DataManipulator<?,?>> containers =
                ((AdditionalContainerHolder<DataManipulator<?,?>>) this).getAdditionalContainers();
        containers.getAll().forEach(manipulator -> builder.add(manipulator.copy()));
    }

    return builder.build();
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@SuppressWarnings({"rawtypes", "unchecked"})
public byte getDataValue(Collection<DataManipulator<?, ?>> manipulators, BlockType target) {
    final DataTypeConverter converter = getConverter(target);
    Collection<DataManipulator<?, ?>> data = Collections2.filter(manipulators, input -> {
        if (input == null) {
            return false;
        }
        try {
            Class<? extends DataManipulator<?, ?>> clazz = (Class<? extends DataManipulator<?, ?>>)
                    Class.forName(input.getClass().getName().split("\\$")[0]);
            return converter.getApplicableDataTypes().contains(clazz);
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
            return false;
        }
    });
    return converter.of(data);
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@SuppressWarnings({"rawtypes", "unchecked"})
public byte of(Collection<DataManipulator<?, ?>> data) {
    HashMap<String, DataManipulator> dataMap = Maps.newHashMap();
    for (DataManipulator datum : data) {
        dataMap.put(datum.getClass().getName().split("\\$")[0], datum);
    }
    BiMap<AbstractDataValue, Byte>[] biMapList = new BiMap[converters.size()];
    converters.keySet().toArray(biMapList);
    Byte[] bitSetSizes = new Byte[converters.size()];
    converters.values().toArray(bitSetSizes);
    byte finalValue = 0;
    byte bitOffset = 0;
    for (int i = 0; i < applicableTypes.size(); i++) {
        byte bitsToConsider = bitSetSizes[i];
        assert bitOffset + bitsToConsider <= 8;
        if (dataMap.containsKey(applicableTypes.get(i).getName())) {
            DataManipulator datum = dataMap.get(applicableTypes.get(i).getName());
            BiMap<AbstractDataValue, Byte> bm = biMapList[i];
            AbstractDataValue adv = AbstractDataValue.of(datum);
            finalValue |= bm.containsKey(adv) ? bm.get(adv) << bitOffset : 0; // mask the value onto the data byte
        }
        bitOffset += bitsToConsider;
    }
    return finalValue;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static void testAbstraction(BlockType blockType, byte rawData,
        Collection<? extends AbstractDataValue<? extends DataManipulator, ?>>
                abstractedData,
        boolean invert) throws Exception {
    Method getConverter = BlockDataConverter.class.getDeclaredMethod("getConverter", BlockType.class);
    getConverter.setAccessible(true);
    DataTypeConverter converter = (DataTypeConverter) getConverter.invoke(BlockDataConverter.INSTANCE, blockType);
    Collection<AbstractDataValue> derived = converter.of(rawData);
    if (invert) {
        assertFalse(derived.containsAll(abstractedData) && abstractedData.containsAll(derived));
    } else {
        assertTrue("Missing expected data values", derived.containsAll(abstractedData));
        assertTrue("Found unexpected data values", abstractedData.containsAll(derived));
    }
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@JsonDetails
public Map<String, Object> getData() {
    HashMap<String, Object> data = new HashMap<>();
    // Add properties
    for (Property<?, ?> property : value.getApplicableProperties()) {
        String key = property.getKey().toString();
        key = key.replace("Property", "");
        key = Character.toLowerCase(key.charAt(0)) + key.substring(1);
        data.put(key, property.getValue());
    }
    // Add data
    Map<String, Class<? extends DataManipulator<?, ?>>> supData = WebAPI.getSerializeService().getSupportedData();
    for (Map.Entry<String, Class<? extends DataManipulator<?, ?>>> entry : supData.entrySet()) {
        try {
            if (!value.supports(entry.getValue()))
                continue;

            Optional<?> m = value.get(entry.getValue());

            if (!m.isPresent())
                continue;

            data.put(entry.getKey(), ((DataManipulator) m.get()).copy());
        } catch (IllegalArgumentException | IllegalStateException ignored) {
        }
    }
    return data;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
public ItemStack deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
    JsonNode root = p.readValueAsTree();
    if (root.path("type").path("id").isMissingNode())
        throw new IOException("Missing item type");

    String id = root.path("type").path("id").asText();
    Optional<ItemType> optType = Sponge.getRegistry().getType(ItemType.class, id);
    if (!optType.isPresent())
        throw new IOException("Invalid item type " + id);

    Integer amount = root.path("quantity").isMissingNode() ? 1 : root.path("quantity").asInt();

    ItemType type = optType.get();

    ItemStack.Builder builder = ItemStack.builder().itemType(type).quantity(amount);
    ItemStack item = builder.build();

    if (!root.path("data").isMissingNode()) {
        Iterator<Map.Entry<String, JsonNode>> it = root.path("data").fields();
        while (it.hasNext()) {
            Map.Entry<String, JsonNode> entry = it.next();
            Class<? extends DataManipulator> c = WebAPI.getSerializeService().getSupportedData().get(entry.getKey());
            if (c == null) continue;
            Optional<? extends DataManipulator> optData = item.getOrCreate(c);
            if (!optData.isPresent())
                throw new IOException("Invalid item data: " + entry.getKey());
            DataManipulator data = optData.get();
            item.offer(data);
        }
    }

    return item;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@Override
public ItemStackSnapshot deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
    JsonNode root = p.readValueAsTree();
    if (root.path("type").path("id").isMissingNode())
        throw new IOException("Missing item type");

    String id = root.path("type").path("id").asText();
    Optional<ItemType> optType = Sponge.getRegistry().getType(ItemType.class, id);
    if (!optType.isPresent())
        throw new IOException("Invalid item type " + id);

    Integer amount = root.path("quantity").isMissingNode() ? 1 : root.path("quantity").asInt();

    ItemType type = optType.get();

    ItemStack.Builder builder = ItemStack.builder().itemType(type).quantity(amount);
    ItemStack item = builder.build();

    if (!root.path("data").isMissingNode()) {
        Iterator<Map.Entry<String, JsonNode>> it = root.path("data").fields();
        while (it.hasNext()) {
            Map.Entry<String, JsonNode> entry = it.next();
            Class<? extends DataManipulator> c = WebAPI.getSerializeService().getSupportedData().get(entry.getKey());
            if (c == null) continue;
            Optional<? extends DataManipulator> optData = item.getOrCreate(c);
            if (!optData.isPresent())
                throw new IOException("Invalid item data: " + entry.getKey());
            DataManipulator data = optData.get();
            item.offer(data);
        }
    }

    return item.createSnapshot();
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
public CachedObject(T value, boolean serializeDataHolder) {
    this.cachedAt = System.nanoTime();
    this.cacheService = WebAPIAPI.getCacheService().orElse(null);
    this.serializeService = WebAPIAPI.getJsonService().orElse(null);

    this.cacheDuration = cacheService.getCacheDurationFor(this.getClass());

    if (value != null) this.clazz = value.getClass();

    if (serializeDataHolder && value instanceof DataHolder) {
        DataHolder holder = (DataHolder)value;

        Map<String, Class<? extends DataManipulator<?, ?>>> supData = serializeService.getSupportedData();
        for (Map.Entry<String, Class<? extends DataManipulator<?, ?>>> entry : supData.entrySet()) {
            try {
                if (!holder.supports(entry.getValue()))
                    continue;

                Optional<?> m = holder.get(entry.getValue());

                if (!m.isPresent())
                    continue;

                data.put(entry.getKey(), ((DataManipulator) m.get()).copy());
            } catch (IllegalArgumentException | IllegalStateException ignored) {
            }
        }
    }
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
private LanternFluidStack(FluidType fluidType, int volume,
        ValueCollection valueCollection, AdditionalContainerCollection<DataManipulator<?, ?>> additionalContainers) {
    this.valueCollection = valueCollection;
    this.additionalContainers = additionalContainers;
    this.fluidType = fluidType;
    this.volume = volume;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
public static void serializeRawContainerData(DataView dataView, IValueContainer valueContainer, DataQuery query) {
    if (!(valueContainer instanceof AdditionalContainerHolder)) {
        return;
    }
    final ValueCollection valueCollection = valueContainer.getValueCollection();
    final AdditionalContainerCollection<ValueContainer<?>> containers =
            ((AdditionalContainerHolder) valueContainer).getAdditionalContainers();
    final ImmutableList.Builder<DataView> builder = ImmutableList.builder();
    final LanternDataManager dataManager = Lantern.getGame().getDataManager();
    for (ValueContainer<?> manipulator : containers.getAll()) {
        if (!(manipulator instanceof DataManipulator)) {
            continue;
        }
        final Class<?> manipulatorType;
        if (manipulator instanceof IDataManipulator) {
            manipulatorType = ((IDataManipulator) manipulator).getMutableType();
        } else {
            manipulatorType = manipulator.getClass();
        }
        final Optional<DataRegistration> optRegistration = dataManager.get(manipulatorType);
        if (!optRegistration.isPresent()) {
            getLogger().error("Could not serialize {}. No registration could be found.", manipulatorType.getName());
        } else {
            builder.add(DataContainer.createNew()
                    .set(DataQueries.MANIPULATOR_ID, optRegistration.get().getId())
                    .set(DataQueries.MANIPULATOR_DATA, ((DataManipulator) manipulator).toContainer()));
        }
    }
    Element<List<DataView>> holder = valueCollection.getElement(LanternKeys.FAILED_DATA_MANIPULATORS).orElse(null);
    if (holder != null) {
        builder.addAll(holder.get());
    }
    dataView.set(query, builder.build());
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Nullable
static DataManipulator create(ValueContainer<?> valueContainer, DataManipulatorRegistration registration) {
    DataManipulator manipulator = (DataManipulator<?, ?>) registration.createMutable();
    for (Key key : (Set<Key>) registration.getRequiredKeys()) {
        final Optional value = valueContainer.get(key);
        if (value.isPresent()) {
            manipulator.set(key, value.get());
        } else if (!valueContainer.supports(key)) {
            manipulator = null;
            break;
        }
    }
    return manipulator;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
default <E> boolean offerFastNoEvents(Key<? extends BaseValue<E>> key, E element) {
    // Check the local key registration
    final KeyRegistration<?, ?> localKeyRegistration = (KeyRegistration<?, ?>) getValueCollection().get((Key) key).orElse(null);
    if (localKeyRegistration != null) {
        return ((Processor<BaseValue<E>, E>) localKeyRegistration).offerFastTo(this, element);
    }

    // Check for a global registration
    final Optional<ValueProcessorKeyRegistration> globalRegistration = LanternValueFactory.get().getKeyRegistration((Key) key);
    if (globalRegistration.isPresent()) {
        return ((Processor<BaseValue<E>, E>) globalRegistration.get()).offerFastTo(this, element);
    }

    // Check if custom data is supported by this container
    if (this instanceof AdditionalContainerHolder) {
        // Check for the custom value containers
        final AdditionalContainerCollection<H> containers = ((AdditionalContainerHolder<H>) this).getAdditionalContainers();
        for (H valueContainer : containers.getAll()) {
            if (valueContainer.supports(key)) {
                if (valueContainer instanceof ICompositeValueStore) {
                    return ((ICompositeValueStore) valueContainer).offerFastNoEvents(key, element);
                } else if (valueContainer instanceof CompositeValueStore) {
                    return ((CompositeValueStore) valueContainer).offer(key, element).isSuccessful();
                } else if (valueContainer instanceof DataManipulator) {
                    ((DataManipulator) valueContainer).set(key, element);
                    return true;
                } else {
                    return false;
                }
            }
        }
    }

    return false;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
default boolean removeFastNoEvents(Key<?> key) {
    checkNotNull(key, "key");
    // Check the local key registration
    final KeyRegistration<?, ?> localKeyRegistration = (KeyRegistration<?, ?>) getValueCollection().get((Key) key).orElse(null);
    if (localKeyRegistration != null) {
        return ((Processor<BaseValue<?>, ?>) localKeyRegistration).removeFastFrom(this);
    }

    // Check for a global registration
    final Optional<ValueProcessorKeyRegistration> globalRegistration = LanternValueFactory.get().getKeyRegistration((Key) key);
    if (globalRegistration.isPresent()) {
        return ((Processor<BaseValue<?>, ?>) globalRegistration.get()).removeFastFrom(this);
    }

    // Check if custom data is supported by this container
    if (this instanceof AdditionalContainerHolder) {
        // Check for the custom value containers
        final AdditionalContainerCollection<H> containers = ((AdditionalContainerHolder<H>) this).getAdditionalContainers();
        for (H valueContainer : containers.getAll()) {
            if (valueContainer.supports(key)) {
                if (valueContainer instanceof ICompositeValueStore) {
                    return ((ICompositeValueStore) valueContainer).removeFastNoEvents(key);
                } else if (valueContainer instanceof CompositeValueStore) {
                    return ((CompositeValueStore) valueContainer).remove(key).isSuccessful();
                } else if (valueContainer instanceof DataManipulator ||
                        valueContainer instanceof ImmutableDataManipulator) {
                    return false;
                }
                return false;
            }
        }
    }

    return false;
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
@SuppressWarnings({"unchecked", "ConstantConditions"})
static <I extends ImmutableDataManipulator<I, M>, M extends DataManipulator<M, I>> Optional<I> get(
        IImmutableDataHolderBase<?> dataHolder, DataManipulatorRegistration<M, I> registration, Class<?> containerClass) {
    final DataManipulator manipulator = registration.createMutable();
    final ImmutableContainerCache cache = dataHolder.getContainerCache();
    if (cache != null && cache.manipulators == null) {
        cache.manipulators = new HashMap<>();
    }
    for (Key key : registration.getRequiredKeys()) {
        final Optional value = dataHolder.getValue(key);
        if (!value.isPresent()) {
            if (cache != null) {
                cache.manipulators.put(containerClass, ImmutableContainerCache.NONE);
            }
            return Optional.empty();
        }
        manipulator.set(key, value.get());
    }
    final I immutable = (I) manipulator.asImmutable();
    if (cache != null) {
        cache.manipulators.put(containerClass, immutable);
        // In case they are different, unlikely
        if (registration.getImmutableManipulatorClass() != containerClass) {
            cache.manipulators.put(registration.getImmutableManipulatorClass(), immutable);
        }
    }
    return Optional.of(immutable);
}
 

import org.spongepowered.api.data.manipulator.DataManipulator; //导入依赖的package包/类
<M extends DataManipulator<M, I>, I extends ImmutableDataManipulator<I, M>> void validateRegistration(
        LanternDataRegistration<M, I> registration) {
    checkState(this.allowRegistrations, "Registrations are no longer allowed");
    final Class<M> manipulatorClass = registration.getManipulatorClass();
    final Class<I> immutableClass = registration.getImmutableManipulatorClass();
    final DataManipulatorBuilder<M, I> manipulatorBuilder = registration.getDataManipulatorBuilder();
    checkState(!this.builders.containsKey(manipulatorClass), "DataManipulator already registered!");
    checkState(!this.builderMap.containsKey(manipulatorClass), "DataManipulator already registered!");
    checkState(!this.builderMap.containsValue(manipulatorBuilder), "DataManipulatorBuilder already registered!");
    checkState(!this.builders.containsKey(immutableClass), "ImmutableDataManipulator already registered!");
    checkState(!this.immutableBuilderMap.containsKey(immutableClass), "ImmutableDataManipulator already registered!");
    checkState(!this.immutableBuilderMap.containsValue(manipulatorBuilder), "DataManipulatorBuilder already registered!");
    checkState(!DataManipulatorRegistryModule.get().getById(registration.getId()).isPresent(),
            "There is already a DataRegistration registered with the ID: " + registration.getId());
}