ByteOps-swe / MVP / 8229813241

coverage: 79.004% (+0.2%) from 78.799%
8229813241

push

github

web-flow 
Merge pull request #4 from ByteOps-swe/Action-test

Action test

129 of 159 new or added lines in 10 files covered. (81.13%)

1460 of 1848 relevant lines covered (79.0%)

0.79 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/PythonSensorsSimulator/main.py
1 
import os
×
2 









3



from .Model.Simulators.SensorFactory import SensorFactory




×







4



from .Model.SimulatorExecutorFactory import SimulatorExecutorFactory




×







5



from .Model.Writers.CompositeWriter import CompositeWriter




×







6












7



KAFKA_HOST = os.environ.get("KAFKA_HOST", "kafka")




×







8



KAFKA_PORT = os.environ.get("KAFKA_PORT", "9092")




×







9



# Uso generale di una interfaccia Writer al fine di poter implementare quante politiche diverse di writing si vuole,










10



# senza dover cambiare nulla sul resto del codice.










11












12



temp_writers = CompositeWriter().add_kafkaConfluent_writer("temperature", KAFKA_HOST, KAFKA_PORT)




×







13



umd_writers = CompositeWriter().add_kafkaConfluent_writer("humidity", KAFKA_HOST, KAFKA_PORT)




×







14



chS_writers = CompositeWriter().add_kafkaConfluent_writer("chargingStation", KAFKA_HOST, KAFKA_PORT)




×








NEW


15



ecoIs_writers = CompositeWriter().add_kafkaConfluent_writer("ecoIslands", KAFKA_HOST, KAFKA_PORT)




×







16



waPr_writers = CompositeWriter().add_kafkaConfluent_writer("waterPresence", KAFKA_HOST, KAFKA_PORT)




×







17



dust_writers = CompositeWriter().add_kafkaConfluent_writer("dust_PM10", KAFKA_HOST, KAFKA_PORT)




×








NEW


18



eletricalFault_writers = CompositeWriter().add_kafkaConfluent_writer("electricalFault", KAFKA_HOST, KAFKA_PORT)




×







19



symExecAggregator = SimulatorExecutorFactory()




×







20












21



symExecAggregator \




×







22



    .add_simulator(SensorFactory.create_temperature_sensor(45.4065, 11.8793, "Centro storico"), temp_writers, 1) \










23



    .add_simulator(SensorFactory.create_temperature_sensor(45.396661, 11.898114, "Terranegra"), temp_writers, 1) \










24



    .add_simulator(SensorFactory.create_temperature_sensor(45.398438, 11.861783, "Sacra Famiglia"), temp_writers, 1) \










25



    .add_simulator(SensorFactory.create_humidity_sensor(45.4068, 11.8794, "Centro storico"), umd_writers, 1) \










26



    .add_simulator(SensorFactory.create_humidity_sensor(45.398319, 11.903093, "Terranegra"), umd_writers, 1) \










27



    .add_simulator(SensorFactory.create_humidity_sensor(45.396324, 11.863110, "Sacra Famiglia"), umd_writers, 1) \










28



    .add_simulator(SensorFactory.create_charging_station_sensor(45.4059, 11.8785, "Centro storico"), chS_writers, 1) \










29



    .add_simulator(SensorFactory.create_charging_station_sensor(45.399434, 11.905925, "Terranegra"), chS_writers, 1) \










30



    .add_simulator(SensorFactory.create_charging_station_sensor(45.398259, 11.864335, "Sacra Famiglia"), chS_writers, 1) \










31



    .add_simulator(SensorFactory.create_ecological_island_sensor(45.4045, 11.8797, "Centro storico"), ecoIs_writers, 1) \










32



    .add_simulator(SensorFactory.create_ecological_island_sensor(45.394024, 11.899316, "Terranegra"), ecoIs_writers, 1) \










33



    .add_simulator(SensorFactory.create_ecological_island_sensor(45.395392, 11.862549, "Sacra Famiglia"), ecoIs_writers, 1) \










34



    .add_simulator(SensorFactory.create_dust_PM10_sensor(45.4069, 11.8800, "Centro storico"), dust_writers, 1) \










35



    .add_simulator(SensorFactory.create_dust_PM10_sensor(45.397430, 11.907513, "Terranegra"), dust_writers, 1) \










36



    .add_simulator(SensorFactory.create_dust_PM10_sensor(45.395679, 11.864794, "Sacra Famiglia"), dust_writers, 1) \










37



    .add_simulator(SensorFactory.create_eletrical_fault_sensor(45.4056, 11.8788, "Centro storico"), eletricalFault_writers, 1) \










38



    .add_simulator(SensorFactory.create_eletrical_fault_sensor(45.393181, 11.907685, "Terranegra"), eletricalFault_writers, 1) \










39



    .add_simulator(SensorFactory.create_eletrical_fault_sensor(45.395320, 11.859793, "Sacra Famiglia"), eletricalFault_writers, 1) \










40



    .add_simulator(SensorFactory.create_water_presence_sensor(45.4070, 11.8805, "Centro storico"), waPr_writers, 1) \










41



    .add_simulator(SensorFactory.create_water_presence_sensor(45.393142, 11.895443, "Terranegra"), waPr_writers, 1) \










42



    .add_simulator(SensorFactory.create_water_presence_sensor(45.398187, 11.865407, "Sacra Famiglia"), waPr_writers, 1) \










43



    .run()
























    

  • 

    •