Feat/data upload

src/@seed/api/column_mapping_profile/column_mapping_profile.service.ts

@@ -2,14 +2,16 @@ import type { HttpErrorResponse } from '@angular/common/http'
 import { HttpClient } from '@angular/common/http'
 import { inject, Injectable } from '@angular/core'
 import type { Observable } from 'rxjs'
-import { catchError, map, ReplaySubject } from 'rxjs'
+import { catchError, map, ReplaySubject, tap } from 'rxjs'
 import { ErrorService } from '@seed/services'
+import { SnackBarService } from 'app/core/snack-bar/snack-bar.service'
 import { UserService } from '../user'
 import type {
   ColumnMapping,
   ColumnMappingProfile,
   ColumnMappingProfileDeleteResponse,
   ColumnMappingProfilesRequest,
+  ColumnMappingProfileType,
   ColumnMappingProfileUpdateResponse,
   ColumnMappingSuggestionResponse,
 } from './column_mapping_profile.types'
@@ -20,6 +22,7 @@ export class ColumnMappingProfileService {
   private _userService = inject(UserService)
   private _profiles = new ReplaySubject<ColumnMappingProfile[]>(1)
   private _errorService = inject(ErrorService)
+  private _snackBar = inject(SnackBarService)
 
   profiles$ = this._profiles.asObservable()
 
@@ -30,9 +33,13 @@ export class ColumnMappingProfileService {
     })
   }
 
-  getProfiles(org_id: number): Observable<ColumnMappingProfile[]> {
-    const url = `/api/v3/column_mapping_profiles/filter/?organization_id=${org_id}`
-    return this._httpClient.post<ColumnMappingProfilesRequest>(url, {}).pipe(
+  getProfiles(orgId: number, columnMappingProfileTypes: ColumnMappingProfileType[] = []): Observable<ColumnMappingProfile[]> {
+    const url = `/api/v3/column_mapping_profiles/filter/?organization_id=${orgId}`
+    const data: Record<string, unknown> = {}
+    if (columnMappingProfileTypes.length) {
+      data.profile_type = columnMappingProfileTypes
+    }
+    return this._httpClient.post<ColumnMappingProfilesRequest>(url, data).pipe(
       map((response) => {
         this._profiles.next(response.data)
         return response.data
@@ -44,8 +51,8 @@ export class ColumnMappingProfileService {
     )
   }
 
-  updateMappings(org_id: number, profile_id: number, mappings: ColumnMapping[]): Observable<ColumnMappingProfile> {
-    const url = `/api/v3/column_mapping_profiles/${profile_id}/?organization_id=${org_id}`
+  updateMappings(orgId: number, profile_id: number, mappings: ColumnMapping[]): Observable<ColumnMappingProfile> {
+    const url = `/api/v3/column_mapping_profiles/${profile_id}/?organization_id=${orgId}`
     return this._httpClient.put<ColumnMappingProfileUpdateResponse>(url, { mappings }).pipe(
       map((response) => {
         return response.data
@@ -56,20 +63,21 @@ export class ColumnMappingProfileService {
     )
   }
 
-  update(org_id: number, profile: ColumnMappingProfile): Observable<ColumnMappingProfile> {
-    const url = `/api/v3/column_mapping_profiles/${profile.id}/?organization_id=${org_id}`
-    return this._httpClient.put<ColumnMappingProfileUpdateResponse>(url, { name: profile.name }).pipe(
+  update(orgId: number, profile: ColumnMappingProfile): Observable<ColumnMappingProfile> {
+    const url = `/api/v3/column_mapping_profiles/${profile.id}/?organization_id=${orgId}`
+    return this._httpClient.put<ColumnMappingProfileUpdateResponse>(url, profile).pipe(
       map((response) => {
         return response.data
       }),
+      tap(() => { this._snackBar.success('Profile updated successfully') }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error updating profile')
       }),
     )
   }
 
-  delete(org_id: number, profile_id: number): Observable<ColumnMappingProfileDeleteResponse> {
-    const url = `/api/v3/column_mapping_profiles/${profile_id}/?organization_id=${org_id}`
+  delete(orgId: number, profile_id: number): Observable<ColumnMappingProfileDeleteResponse> {
+    const url = `/api/v3/column_mapping_profiles/${profile_id}/?organization_id=${orgId}`
     return this._httpClient.delete<ColumnMappingProfileDeleteResponse>(url).pipe(
       map((response) => {
         return response
@@ -80,17 +88,18 @@ export class ColumnMappingProfileService {
     )
   }
 
-  create(org_id: number, profile: ColumnMappingProfile): Observable<ColumnMappingProfileUpdateResponse> {
-    const url = `/api/v3/column_mapping_profiles/?organization_id=${org_id}`
+  create(orgId: number, profile: ColumnMappingProfile): Observable<ColumnMappingProfileUpdateResponse> {
+    const url = `/api/v3/column_mapping_profiles/?organization_id=${orgId}`
     return this._httpClient.post<ColumnMappingProfileUpdateResponse>(url, { ...profile }).pipe(
+      tap(() => { this._snackBar.success('Profile created successfully') }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error creating profile')
       }),
     )
   }
 
-  export(org_id: number, profile_id: number) {
-    const url = `/api/v3/column_mapping_profiles/${profile_id}/csv/?organization_id=${org_id}`
+  export(orgId: number, profile_id: number) {
+    const url = `/api/v3/column_mapping_profiles/${profile_id}/csv/?organization_id=${orgId}`
     return this._httpClient.get(url, { responseType: 'text' }).pipe(
       map((response) => {
         return new Blob([response], { type: 'text/csv;charset: utf-8' })
@@ -101,8 +110,8 @@ export class ColumnMappingProfileService {
     )
   }
 
-  suggestions(org_id: number, headers: string[]) {
-    const url = `/api/v3/column_mapping_profiles/suggestions/?organization_id=${org_id}`
+  suggestions(orgId: number, headers: string[]) {
+    const url = `/api/v3/column_mapping_profiles/suggestions/?organization_id=${orgId}`
     return this._httpClient.post<ColumnMappingSuggestionResponse>(url, { headers }).pipe(
       map((response) => {
         return response.data

src/@seed/api/column_mapping_profile/column_mapping_profile.types.ts

@@ -33,3 +33,5 @@ export type ColumnMappingSuggestionResponse = {
   status: string;
   data: Record<string, ['PropertyState' | 'TaxLotState', string, number]>;
 }
+
+export type ColumnMappingProfileType = 'Normal' | 'BuildingSync Default' | 'BuildingSync Custom'

src/@seed/api/cycle/cycle.service.ts

@@ -3,15 +3,15 @@ import { HttpClient } from '@angular/common/http'
 import { inject, Injectable } from '@angular/core'
 import type { Observable } from 'rxjs'
 import { BehaviorSubject, catchError, map, take, tap } from 'rxjs'
-import { OrganizationService } from '@seed/api/organization'
 import { ErrorService } from '@seed/services'
 import { SnackBarService } from 'app/core/snack-bar/snack-bar.service'
+import { UserService } from '../user'
 import type { Cycle, CycleResponse, CyclesResponse } from './cycle.types'
 
 @Injectable({ providedIn: 'root' })
 export class CycleService {
   private _httpClient = inject(HttpClient)
-  private _organizationService = inject(OrganizationService)
+  private _userService = inject(UserService)
   private _snackBar = inject(SnackBarService)
   private _errorService = inject(ErrorService)
   private _cycles = new BehaviorSubject<Cycle[]>([])
@@ -20,21 +20,20 @@ export class CycleService {
   cycles$ = this._cycles.asObservable()
 
   constructor() {
-    this._organizationService.currentOrganization$
+    this._userService.currentOrganizationId$
       .pipe(
-        tap(({ org_id }) => {
-          this.get(org_id)
+        tap((orgId) => {
+          this.getCycles(orgId)
         }),
       )
       .subscribe()
   }
 
-  get(orgId: number) {
+  getCycles(orgId: number) {
     const url = `/api/v3/cycles/?organization_id=${orgId}`
     this._httpClient
       .get<CyclesResponse>(url)
       .pipe(
-        take(1),
         map(({ cycles }) => cycles),
         tap((cycles) => {
           this._cycles.next(cycles)
@@ -46,12 +45,25 @@ export class CycleService {
       .subscribe()
   }
 
+  getCycle(orgId: number, cycleId: number): Observable<Cycle> {
+    const url = `/api/v3/cycles/${cycleId}?organization_id=${orgId}`
+    return this._httpClient
+      .get<CycleResponse>(url)
+      .pipe(
+        take(1),
+        map(({ cycles }) => cycles),
+        catchError((error: HttpErrorResponse) => {
+          return this._errorService.handleError(error, 'Error fetching cycles')
+        }),
+      )
+  }
+
   post({ data, orgId }): Observable<CycleResponse | null> {
     const url = `/api/v3/cycles/?organization_id=${orgId}`
     return this._httpClient.post<CycleResponse>(url, data).pipe(
       tap((response) => {
         this._snackBar.success(`Created Cycle ${response.cycles.name}`)
-        this.get(orgId as number)
+        this.getCycles(orgId as number)
       }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error creating cycle')
@@ -64,7 +76,7 @@ export class CycleService {
     return this._httpClient.put<CycleResponse>(url, data).pipe(
       tap((response) => {
         this._snackBar.success(`Updated Cycle ${response.cycles.name}`)
-        this.get(orgId as number)
+        this.getCycles(orgId as number)
       }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error updating cycle')
@@ -76,7 +88,7 @@ export class CycleService {
     const url = `/api/v3/cycles/${id}/?organization_id=${orgId}`
     return this._httpClient.delete(url).pipe(
       tap(() => {
-        this.get(orgId)
+        this.getCycles(orgId)
       }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error deleting cycle')

src/@seed/api/data-quality/data-quality.service.ts

@@ -1,10 +1,11 @@
 import { HttpClient, type HttpErrorResponse } from '@angular/common/http'
 import { inject, Injectable } from '@angular/core'
-import { catchError, type Observable, ReplaySubject, switchMap, tap } from 'rxjs'
+import { catchError, map, type Observable, ReplaySubject, switchMap, tap } from 'rxjs'
 import { OrganizationService } from '@seed/api/organization'
 import { ErrorService } from '@seed/services'
 import { SnackBarService } from 'app/core/snack-bar/snack-bar.service'
-import type { Rule } from './data-quality.types'
+import type { DQCProgressResponse } from '../progress'
+import type { DataQualityResults, DataQualityResultsResponse, Rule } from './data-quality.types'
 
 @Injectable({ providedIn: 'root' })
 export class DataQualityService {
@@ -79,4 +80,38 @@ export class DataQualityService {
       }),
     )
   }
+
+  startDataQualityCheckForImportFile(orgId: number, importFileId: number): Observable<DQCProgressResponse> {
+    const url = `/api/v3/import_files/${importFileId}/start_data_quality_checks/?organization_id=${orgId}`
+    return this._httpClient.post<DQCProgressResponse>(url, {})
+      .pipe(
+        catchError((error: HttpErrorResponse) => {
+          return this._errorService.handleError(error, 'Error starting data quality checks for import file')
+        }),
+      )
+  }
+
+  startDataQualityCheckForOrg(orgId: number, property_view_ids: number[], taxlot_view_ids: number[], goal_id: number): Observable<DQCProgressResponse> {
+    const url = `/api/v3/data_quality_checks/${orgId}/start/`
+    const data = {
+      property_view_ids,
+      taxlot_view_ids,
+      goal_id,
+    }
+    return this._httpClient.post<DQCProgressResponse>(url, data).pipe(
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error fetching data quality results for organization')
+      }),
+    )
+  }
+
+  getDataQualityResults(orgId: number, runId: number): Observable<DataQualityResults[]> {
+    const url = `/api/v3/data_quality_checks/results/?organization_id=${orgId}&run_id=${runId}`
+    return this._httpClient.get<DataQualityResultsResponse>(url).pipe(
+      map(({ data }) => data),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error fetching data quality results')
+      }),
+    )
+  }
 }

src/@seed/api/data-quality/data-quality.types.ts

@@ -60,3 +60,24 @@ export type UnitNames =
   | 'MJ/m²/year'
   | 'kWh/m²/year'
   | 'kBtu/m²/year'
+
+export type DataQualityResultsResponse = {
+  data: DataQualityResults[];
+}
+
+export type DataQualityResults = {
+  [key: string]: unknown;
+  data_quality_results: DataQualityResult[];
+}
+
+export type DataQualityResult = {
+  condition: string;
+  detailed_message: string;
+  field: string;
+  formatted_field: string;
+  label: string;
+  message: string;
+  severity: string;
+  table_name: string;
+  value: unknown;
+}