Update table

Author: rajsinghtech

main.go

@@ -243,14 +243,170 @@ func configurePostgreSQL(pgConfig *PostgreSQLConfig) (*sql.DB, error) {
 
 // createTelemetryTable creates the telemetry_data table if it does not exist
 func createTelemetryTable(db *sql.DB) error {
+	// Updated SQL query to include all fields from the protobuf definition
 	createTableQuery := `
 	CREATE TABLE IF NOT EXISTS telemetry_data (
 		id SERIAL PRIMARY KEY,
 		vin TEXT,
 		key INTEGER,
 		value JSONB,
 		created_at TIMESTAMPTZ,
-        UNIQUE (vin, key, created_at)
+		drive_rail INTEGER,
+		charge_state INTEGER,
+		bms_fullchargecomplete BOOLEAN,
+		vehicle_speed DOUBLE PRECISION,
+		odometer DOUBLE PRECISION,
+		pack_voltage DOUBLE PRECISION,
+		pack_current DOUBLE PRECISION,
+		soc DOUBLE PRECISION,
+		dcdc_enable BOOLEAN,
+		gear INTEGER,
+		isolation_resistance DOUBLE PRECISION,
+		pedal_position DOUBLE PRECISION,
+		brake_pedal BOOLEAN,
+		di_state_r INTEGER,
+		di_heatsink_tr DOUBLE PRECISION,
+		di_axle_speed_r DOUBLE PRECISION,
+		di_torquemotor DOUBLE PRECISION,
+		di_stator_temp_r DOUBLE PRECISION,
+		di_vbat_r DOUBLE PRECISION,
+		di_motor_current_r DOUBLE PRECISION,
+		location_latitude DOUBLE PRECISION,
+		location_longitude DOUBLE PRECISION,
+		gps_state INTEGER,
+		gps_heading DOUBLE PRECISION,
+		num_brick_voltage_max INTEGER,
+		brick_voltage_max DOUBLE PRECISION,
+		num_brick_voltage_min INTEGER,
+		brick_voltage_min DOUBLE PRECISION,
+		num_module_temp_max INTEGER,
+		module_temp_max DOUBLE PRECISION,
+		num_module_temp_min INTEGER,
+		module_temp_min DOUBLE PRECISION,
+		rated_range DOUBLE PRECISION,
+		hvil INTEGER,
+		dc_charging_energy_in DOUBLE PRECISION,
+		dc_charging_power DOUBLE PRECISION,
+		ac_charging_energy_in DOUBLE PRECISION,
+		ac_charging_power DOUBLE PRECISION,
+		charge_limit_soc DOUBLE PRECISION,
+		fast_charger_present BOOLEAN,
+		est_battery_range DOUBLE PRECISION,
+		ideal_battery_range DOUBLE PRECISION,
+		battery_level DOUBLE PRECISION,
+		time_to_full_charge DOUBLE PRECISION,
+		scheduled_charging_start_time TIMESTAMPTZ,
+		scheduled_charging_pending BOOLEAN,
+		scheduled_departure_time TIMESTAMPTZ,
+		preconditioning_enabled BOOLEAN,
+		scheduled_charging_mode INTEGER,
+		charge_amps DOUBLE PRECISION,
+		charge_enable_request BOOLEAN,
+		charger_phases INTEGER,
+		charge_port_cold_weather_mode BOOLEAN,
+		charge_current_request DOUBLE PRECISION,
+		semitruck_tpms_pressure_re2r0 DOUBLE PRECISION,
+		semitruck_tpms_pressure_re2r1 DOUBLE PRECISION,
+		tpms_last_seen_pressure_time_fl TIMESTAMPTZ,
+		tpms_last_seen_pressure_time_fr TIMESTAMPTZ,
+		tpms_last_seen_pressure_time_rl TIMESTAMPTZ,
+		tpms_last_seen_pressure_time_rr TIMESTAMPTZ,
+		inside_temp DOUBLE PRECISION,
+		outside_temp DOUBLE PRECISION,
+		seat_heater_left BOOLEAN,
+		seat_heater_right BOOLEAN,
+		seat_heater_rear_left BOOLEAN,
+		seat_heater_rear_right BOOLEAN,
+		seat_heater_rear_center BOOLEAN,
+		auto_seat_climate_left BOOLEAN,
+		auto_seat_climate_right BOOLEAN,
+		driver_seat_belt BOOLEAN,
+		passenger_seat_belt BOOLEAN,
+		driver_seat_occupied BOOLEAN,
+		semitruck_passenger_seat_fold_position INTEGER,
+		lateral_acceleration DOUBLE PRECISION,
+		longitudinal_acceleration DOUBLE PRECISION,
+		cruise_state INTEGER,
+		cruise_set_speed DOUBLE PRECISION,
+		lifetime_energy_used DOUBLE PRECISION,
+		lifetime_energy_used_drive DOUBLE PRECISION,
+		semitruck_tractor_park_brake_status BOOLEAN,
+		semitruck_trailer_park_brake_status BOOLEAN,
+		brake_pedal_pos DOUBLE PRECISION,
+		route_last_updated TIMESTAMPTZ,
+		route_line TEXT,
+		miles_to_arrival DOUBLE PRECISION,
+		minutes_to_arrival DOUBLE PRECISION,
+		origin_location TEXT,
+		destination_location TEXT,
+		car_type INTEGER,
+		trim TEXT,
+		exterior_color TEXT,
+		roof_color TEXT,
+		charge_port INTEGER,
+		charge_port_latch INTEGER,
+		experimental_1 BOOLEAN,
+		experimental_2 BOOLEAN,
+		experimental_3 BOOLEAN,
+		experimental_4 BOOLEAN,
+		guest_mode_enabled BOOLEAN,
+		pin_to_drive_enabled BOOLEAN,
+		paired_phone_key_and_key_fob_qty INTEGER,
+		cruise_follow_distance INTEGER,
+		automatic_blind_spot_camera BOOLEAN,
+		blind_spot_collision_warning_chime BOOLEAN,
+		speed_limit_warning BOOLEAN,
+		forward_collision_warning BOOLEAN,
+		lane_departure_avoidance BOOLEAN,
+		emergency_lane_departure_avoidance BOOLEAN,
+		automatic_emergency_braking_off BOOLEAN,
+		lifetime_energy_gained_regen DOUBLE PRECISION,
+		di_state_f INTEGER,
+		di_state_rel INTEGER,
+		di_state_rer INTEGER,
+		di_heatsink_tf DOUBLE PRECISION,
+		di_heatsink_trel DOUBLE PRECISION,
+		di_heatsink_trer DOUBLE PRECISION,
+		di_axle_speed_f DOUBLE PRECISION,
+		di_axle_speed_rel DOUBLE PRECISION,
+		di_axle_speed_rer DOUBLE PRECISION,
+		di_slave_torque_cmd DOUBLE PRECISION,
+		di_torque_actual_r DOUBLE PRECISION,
+		di_torque_actual_f DOUBLE PRECISION,
+		di_torque_actual_rel DOUBLE PRECISION,
+		di_torque_actual_rer DOUBLE PRECISION,
+		di_stator_temp_f DOUBLE PRECISION,
+		di_stator_temp_rel DOUBLE PRECISION,
+		di_stator_temp_rer DOUBLE PRECISION,
+		di_vbat_f DOUBLE PRECISION,
+		di_vbat_rel DOUBLE PRECISION,
+		di_vbat_rer DOUBLE PRECISION,
+		di_motor_current_f DOUBLE PRECISION,
+		di_motor_current_rel DOUBLE PRECISION,
+		di_motor_current_rer DOUBLE PRECISION,
+		energy_remaining DOUBLE PRECISION,
+		service_mode BOOLEAN,
+		bms_state INTEGER,
+		guest_mode_mobile_access_state INTEGER,
+		deprecated_1 BOOLEAN,
+		destination_name TEXT,
+		di_inverter_tr DOUBLE PRECISION,
+		di_inverter_tf DOUBLE PRECISION,
+		di_inverter_trel DOUBLE PRECISION,
+		di_inverter_trer DOUBLE PRECISION,
+		experimental_5 BOOLEAN,
+		experimental_6 BOOLEAN,
+		experimental_7 BOOLEAN,
+		experimental_8 BOOLEAN,
+		experimental_9 BOOLEAN,
+		experimental_10 BOOLEAN,
+		experimental_11 BOOLEAN,
+		experimental_12 BOOLEAN,
+		experimental_13 BOOLEAN,
+		experimental_14 BOOLEAN,
+		experimental_15 BOOLEAN,
+		detailed_charge_state INTEGER,
+		UNIQUE (vin, key, created_at)
 	);
 	`
 	_, err := db.Exec(createTableQuery)
@@ -471,7 +627,7 @@ func insertTelemetryData(db *sql.DB, vin string, datum *protos.Datum, createdAt
 	`
 
 	// Convert Datum to SQL values
-	values := make([]interface{}, 179)
+	values := make([]interface{}, 179) // Ensure this matches the number of columns
 	values[0] = vin
 	values[1] = createdAt