use common::{ comp::{ skills::{GeneralSkill, Skill, SkillGroupType}, CharacterState, Energy, EnergyChange, EnergySource, Health, Stats, }, event::{EventBus, ServerEvent}, metrics::SysMetrics, resources::DeltaTime, span, }; use hashbrown::HashSet; use specs::{Entities, Join, Read, ReadExpect, ReadStorage, System, WriteStorage}; const ENERGY_REGEN_ACCEL: f32 = 10.0; /// This system kills players, levels them up, and regenerates energy. pub struct Sys; impl<'a> System<'a> for Sys { #[allow(clippy::type_complexity)] type SystemData = ( Entities<'a>, Read<'a, DeltaTime>, Read<'a, EventBus>, ReadExpect<'a, SysMetrics>, ReadStorage<'a, CharacterState>, WriteStorage<'a, Stats>, WriteStorage<'a, Health>, WriteStorage<'a, Energy>, ); fn run( &mut self, ( entities, dt, server_event_bus, sys_metrics, character_states, mut stats, mut healths, mut energies, ): Self::SystemData, ) { let start_time = std::time::Instant::now(); span!(_guard, "run", "stats::Sys::run"); let mut server_event_emitter = server_event_bus.emitter(); // Increment last change timer healths.set_event_emission(false); // avoid unnecessary syncing for mut health in (&mut healths).join() { health.last_change.0 += f64::from(dt.0); } healths.set_event_emission(true); // Update stats for (entity, mut stats, mut health) in ( &entities, &mut stats.restrict_mut(), &mut healths.restrict_mut(), ) .join() { let set_dead = { let health = health.get_unchecked(); health.should_die() && !health.is_dead }; if set_dead { let mut health = health.get_mut_unchecked(); server_event_emitter.emit(ServerEvent::Destroy { entity, cause: health.last_change.1.cause, }); health.is_dead = true; } let mut skills_to_level = HashSet::::new(); let stat = stats.get_unchecked(); { for skill_group in stat.skill_set.skill_groups.iter() { if skill_group.exp >= 300 { skills_to_level.insert(skill_group.skill_group_type); } } } if !skills_to_level.is_empty() { let mut stat = stats.get_mut_unchecked(); for skill_group in skills_to_level.drain() { stat.skill_set.change_experience(skill_group, -300); stat.skill_set.add_skill_points(skill_group, 1); } } } // Apply effects from leveling skills for (mut stats, mut health, mut energy) in ( &mut stats.restrict_mut(), &mut healths.restrict_mut(), &mut energies.restrict_mut(), ) .join() { let stat = stats.get_unchecked(); if stat.skill_set.modify_health { let mut health = health.get_mut_unchecked(); let health_level = stat .skill_set .skills .get(&Skill::General(GeneralSkill::HealthIncrease)) .copied() .flatten() .unwrap_or(0); health.update_max_hp(Some(stat.body_type), health_level.into()); let mut stat = stats.get_mut_unchecked(); stat.skill_set.modify_health = false; } let stat = stats.get_unchecked(); if stat.skill_set.modify_energy { let mut energy = energy.get_mut_unchecked(); let energy_level = stat .skill_set .skills .get(&Skill::General(GeneralSkill::EnergyIncrease)) .copied() .flatten() .unwrap_or(0) as u32; let energy_max = stat.body_type.base_energy() + 50 * energy_level; energy.set_maximum(energy_max); let mut stat = stats.get_mut_unchecked(); stat.skill_set.modify_energy = false; } } // Update energies for (character_state, mut energy) in (&character_states, &mut energies.restrict_mut()).join() { match character_state { // Accelerate recharging energy. CharacterState::Idle { .. } | CharacterState::Sit { .. } | CharacterState::Dance { .. } | CharacterState::Sneak { .. } | CharacterState::GlideWield { .. } | CharacterState::Wielding { .. } | CharacterState::Equipping { .. } | CharacterState::Boost { .. } => { let res = { let energy = energy.get_unchecked(); energy.current() < energy.maximum() }; if res { let mut energy = energy.get_mut_unchecked(); let energy = &mut *energy; // Have to account for Calc I differential equations due to acceleration energy.change_by(EnergyChange { amount: (energy.regen_rate * dt.0 + ENERGY_REGEN_ACCEL * dt.0.powi(2) / 2.0) as i32, source: EnergySource::Regen, }); energy.regen_rate = (energy.regen_rate + ENERGY_REGEN_ACCEL * dt.0).min(100.0); } }, // Ability and glider use does not regen and sets the rate back to zero. CharacterState::Glide { .. } | CharacterState::BasicMelee { .. } | CharacterState::DashMelee { .. } | CharacterState::LeapMelee { .. } | CharacterState::SpinMelee { .. } | CharacterState::ComboMelee { .. } | CharacterState::BasicRanged { .. } | CharacterState::ChargedMelee { .. } | CharacterState::ChargedRanged { .. } | CharacterState::RepeaterRanged { .. } | CharacterState::Shockwave { .. } | CharacterState::BasicBeam { .. } => { if energy.get_unchecked().regen_rate != 0.0 { energy.get_mut_unchecked().regen_rate = 0.0 } }, // recover small amount of passive energy from blocking, and bonus energy from // blocking attacks? CharacterState::BasicBlock => { let res = { let energy = energy.get_unchecked(); energy.current() < energy.maximum() }; if res { energy.get_mut_unchecked().change_by(EnergyChange { amount: -3, source: EnergySource::Regen, }); } }, // Non-combat abilities that consume energy; // temporarily stall energy gain, but preserve regen_rate. CharacterState::Roll { .. } | CharacterState::Climb { .. } => {}, } } sys_metrics.stats_ns.store( start_time.elapsed().as_nanos() as u64, std::sync::atomic::Ordering::Relaxed, ); } }