fix!: include direct emitter results in ltp export

docs/docs/changelog/changelog.md

@@ -47,6 +47,7 @@
 * remove economy from ecalc ([#282](https://github.com/equinor/ecalc/issues/282))
 * graph.components and graph.get_component renamed to nodes and get_node
 * add type to consumers in system
+* change name from DIRECT_EMITTERS to VENTING_EMITTERS in input Yaml-file ([#303](https://github.com/equinor/ecalc/pull/303))
 
 ### Features
 

src/libecalc/presentation/exporter/queries.py

@@ -190,6 +190,27 @@ def query(
                                 if self.fuel_type_category is None or fuel_category == self.fuel_type_category:
                                     if self.emission_type is None or emission.name == self.emission_type:
                                         aggregated_result[timestep] += emission_volume
+
+            # Add emissions from direct emitters, but ensure that emissions are not counted twice.
+            # Direct emissions have no fuel, and should not count when asking for emissions for a given fuel
+            if self.fuel_type_category is None:
+                for venting_emitter in installation_dto.venting_emitters:
+                    temporal_category = TemporalModel(venting_emitter.user_defined_category)
+                    for period, category in temporal_category.items():
+                        if self.consumer_categories is None or category in self.consumer_categories:
+                            emissions = installation_graph.get_emissions(venting_emitter.id)
+
+                            for emission in emissions.values():
+                                emission_volumes = (
+                                    TimeSeriesRate.from_timeseries_stream_day_rate(emission.rate, regularity=regularity)
+                                    .for_period(period)
+                                    .to_volumes()
+                                )
+                                unit_in = emission_volumes.unit
+                                for timestep, emission_volume in emission_volumes.datapoints():
+                                    if self.emission_type is None or emission.name == self.emission_type:
+                                        aggregated_result[timestep] += emission_volume
+
             if aggregated_result:
                 sorted_result = dict(dict(sorted(zip(aggregated_result.keys(), aggregated_result.values()))).items())
                 sorted_result = {**dict.fromkeys(installation_time_steps, 0.0), **sorted_result}