Merge pull request #13 from gaveshalabs/feat/weatherdata-metadata-ref…

…actor fixes
gaveshalabs · Jan 8, 2024 · c17fb5b · c17fb5b
2 parents 5d0dc2f + 6d78e45
commit c17fb5b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 6 deletions.
diff --git a/src/modules/weather-data/entities/weather-datum.entity.ts b/src/modules/weather-data/entities/weather-datum.entity.ts
@@ -7,7 +7,7 @@ import {
 } from '../schema/weatherdata-metadata.schema';
 
 @Schema({
-  timestamps: { createdAt: false, updatedAt: true },
+  timestamps: true,
   collection: 'weather_data',
   timeseries: {
     timeField: 'timestamp',

diff --git a/src/modules/weather-data/schema/weatherdata-metadata.schema.ts b/src/modules/weather-data/schema/weatherdata-metadata.schema.ts
@@ -1,10 +1,11 @@
 import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
 import { ICoordinates } from 'src/modules/common/interfaces/coordinates.interface';
+import { User } from 'src/modules/users/entities/user.entity';
 import { WeatherStation } from 'src/modules/weather-stations/entities/weather-station.entity';
 
 @Schema({ timestamps: { createdAt: true, updatedAt: false } })
 export class WeatherDataMetadata {
-  @Prop({ type: String, ref: WeatherStation.name })
+  @Prop({ type: String, ref: User.name })
   author_user_id: string;
 
   @Prop({ type: String, ref: WeatherStation.name })

diff --git a/src/modules/weather-data/weather-data.service.ts b/src/modules/weather-data/weather-data.service.ts
@@ -85,9 +85,6 @@ export class WeatherDataService {
         const populatedData = filteredDataPoints.map((dataPoint) => {
           return {
             ...dataPoint,
-            author_user_id,
-            weather_station_id,
-            coordinates,
             metadata: {
               author_user_id: author_user_id,
               weather_station_id: weather_station_id,
@@ -100,7 +97,7 @@ export class WeatherDataService {
         insertedData = await this.weatherDatumModel.insertMany(populatedData);
 
         // Hacky checks to check if the data was inserted.
-        if (!insertedData || insertedData.length !== data.length) {
+        if (!insertedData || insertedData.length !== populatedData.length) {
           throw new Error('Error inserting weather data');
         }
       } catch (error) {