use std::any::Any;
use std::error::Error;
use std::fmt;
use crate::block::{BlockLogic, DataConvertError, DeserializeError, make_register, SerializeError};
use crate::block::simple::{BuildCost, cost, SimpleBlock, state_impl};
use crate::block::transport::BridgeBlock;
use crate::content;
use crate::data::GridPos;
use crate::data::dynamic::{DynData, DynType};
use crate::fluid;
use crate::item::storage::Storage;
make_register!
(
MECHANICAL_PUMP: "mechanical-pump" => SimpleBlock::new(1, true, cost!(Copper: 15, Metaglass: 10));
ROTARY_PUMP: "rotary-pump" => SimpleBlock::new(2, true, cost!(Copper: 70, Metaglass: 50, Titanium: 35, Silicon: 20));
IMPULSE_PUMP: "impulse-pump" => SimpleBlock::new(3, true, cost!(Copper: 80, Metaglass: 90, Titanium: 40, Thorium: 35, Silicon: 30));
CONDUIT: "conduit" => SimpleBlock::new(1, false, cost!(Metaglass: 1));
PULSE_CONDUIT: "pulse-conduit" => SimpleBlock::new(1, false, cost!(Metaglass: 1, Titanium: 2));
PLATED_CONDUIT: "plated-conduit" => SimpleBlock::new(1, false, cost!(Metaglass: 1, Thorium: 2, Plastanium: 1));
LIQUID_ROUTER: "liquid-router" => SimpleBlock::new(1, true, cost!(Metaglass: 2, Graphite: 4));
LIQUID_CONTAINER: "liquid-container" => SimpleBlock::new(2, true, cost!(Metaglass: 15, Titanium: 10));
LIQUID_TANK: "liquid-tank" => SimpleBlock::new(3, true, cost!(Metaglass: 40, Titanium: 30));
LIQUID_JUNCTION: "liquid-junction" => SimpleBlock::new(1, true, cost!(Metaglass: 8, Graphite: 4));
BRIDGE_CONDUIT: "bridge-conduit" => BridgeBlock::new(1, true, cost!(Metaglass: 8, Graphite: 4), 4, true);
PHASE_CONDUIT: "phase-conduit" => BridgeBlock::new(1, true, cost!(Metaglass: 20, Titanium: 10, Silicon: 7, PhaseFabric: 5), 12, true);
// sandbox only
LIQUID_SOURCE: "liquid-source" => FluidBlock::new(1, true, &[]);
LIQUID_VOID: "liquid-void" => SimpleBlock::new(1, true, &[]);
);
pub struct FluidBlock
{
size: u8,
symmetric: bool,
build_cost: BuildCost,
}
impl FluidBlock
{
pub const fn new(size: u8, symmetric: bool, build_cost: BuildCost) -> Self
{
if size == 0
{
panic!("invalid size");
}
Self{size, symmetric, build_cost}
}
state_impl!(pub Option<fluid::Type>);
}
impl BlockLogic for FluidBlock
{
fn get_size(&self) -> u8
{
self.size
}
fn is_symmetric(&self) -> bool
{
self.symmetric
}
fn create_build_cost(&self) -> Option<Storage>
{
if !self.build_cost.is_empty()
{
let mut storage = Storage::new();
for (ty, cnt) in self.build_cost
{
storage.add(*ty, *cnt, u32::MAX);
}
Some(storage)
}
else {None}
}
fn data_from_i32(&self, config: i32, _: GridPos) -> Result<DynData, DataConvertError>
{
if config < 0 || config > u16::MAX as i32
{
return Err(DataConvertError::Custom(Box::new(FluidConvertError(config))));
}
Ok(DynData::Content(content::Type::Fluid, config as u16))
}
fn deserialize_state(&self, data: DynData) -> Result<Option<Box<dyn Any>>, DeserializeError>
{
match data
{
DynData::Empty => Ok(Some(Self::create_state(None))),
DynData::Content(content::Type::Fluid, id) => Ok(Some(Self::create_state(Some(FluidDeserializeError::forward(fluid::Type::try_from(id))?)))),
DynData::Content(have, ..) => Err(DeserializeError::Custom(Box::new(FluidDeserializeError::ContentType(have)))),
_ => Err(DeserializeError::InvalidType{have: data.get_type(), expect: DynType::Content}),
}
}
fn clone_state(&self, state: &dyn Any) -> Box<dyn Any>
{
let state = Self::get_state(state);
Box::new(Self::create_state(*state))
}
fn mirror_state(&self, _: &mut dyn Any, _: bool, _: bool)
{
}
fn rotate_state(&self, _: &mut dyn Any, _: bool)
{
}
fn serialize_state(&self, state: &dyn Any) -> Result<DynData, SerializeError>
{
match Self::get_state(state)
{
None => Ok(DynData::Empty),
Some(fluid) => Ok(DynData::Content(content::Type::Fluid, (*fluid).into())),
}
}
}
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct FluidConvertError(pub i32);
impl fmt::Display for FluidConvertError
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result
{
write!(f, "invalid config ({}) for fluid", self.0)
}
}
impl Error for FluidConvertError {}
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum FluidDeserializeError
{
ContentType(content::Type),
NotFound(fluid::TryFromU16Error),
}
impl FluidDeserializeError
{
pub fn forward<T, E: Into<Self>>(result: Result<T, E>) -> Result<T, DeserializeError>
{
match result
{
Ok(v) => Ok(v),
Err(e) => Err(DeserializeError::Custom(Box::new(e.into()))),
}
}
}
impl From<fluid::TryFromU16Error> for FluidDeserializeError
{
fn from(err: fluid::TryFromU16Error) -> Self
{
Self::NotFound(err)
}
}
impl fmt::Display for FluidDeserializeError
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result
{
match self
{
Self::ContentType(have) => write!(f, "expected content {:?} but got {have:?}", content::Type::Fluid),
Self::NotFound(..) => f.write_str("fluid not found"),
}
}
}
impl Error for FluidDeserializeError
{
fn source(&self) -> Option<&(dyn Error + 'static)>
{
match self
{
Self::NotFound(e) => Some(e),
_ => None,
}
}
}