Adds majority of remaining list actions (#53)

* action group modal

* move to shared dir

* better analyses fxnal

* bsynr analysis fxnal

* simple analyses config fxnal

* analyses modal fxnal

* dqc from actions

* update derived data fxnal

* bugs

* base data

* label action

* export modal fxnal

* refresh metadata fxnal

* geocode in progress

* lint

* lint

* dev

* geocode modal fxnal

* valid status

* geocode and merge fxnal

* pinning

* track settings$

* decode ubid fxnal

* compare ubid fxnal

* ubid editor

* email modal fxnal

* FEMP fxnal

* lint

* email refactor

* prettier

* Lint fixes

* Remove unused code

* More consistent functionality with the original code

---------

Co-authored-by: Alex Swindler <Alex.Swindler@nrel.gov>

Author: perryr16

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

@@ -13,7 +13,7 @@ export class GeocodeService {
   private _errorService = inject(ErrorService)
 
   geocode(orgId: number, viewIds: number[], type: InventoryType): Observable<unknown> {
-    const url = `/api/v3/geocode/geocode_by_ids/&organization_id=${orgId}`
+    const url = `/api/v3/geocode/geocode_by_ids/?organization_id=${orgId}`
     const data = {
       property_view_ids: type === 'taxlots' ? [] : viewIds,
       taxlot_view_ids: type === 'taxlots' ? viewIds : [],

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

@@ -1,6 +1,6 @@
 export type ConfidenceSummary = {
-  properties: InventoryConfidenceSummary;
-  taxlots: InventoryConfidenceSummary;
+  properties?: InventoryConfidenceSummary;
+  taxlots?: InventoryConfidenceSummary;
 }
 
 export type InventoryConfidenceSummary = {

src/@seed/api/index.ts

@@ -14,6 +14,7 @@ export * from './groups'
 export * from './inventory'
 export * from './label'
 export * from './mapping'
+export * from './matching'
 export * from './meters'
 export * from './notes'
 export * from './organization'

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

@@ -389,4 +389,33 @@ export class InventoryService {
       }),
     )
   }
+
+  propertiesMetersExist(orgId: number, propertyViewIds: number[]): Observable<boolean> {
+    const url = `/api/v3/properties/meters_exist/?organization_id=${orgId}`
+    return this._httpClient.post<boolean>(url, { property_view_ids: propertyViewIds }).pipe(
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error checking if meters exist for properties')
+      }),
+    )
+  }
+
+  evaluationExportToCts(orgId: number, viewIds: number[], filename: string): Observable<Blob> {
+    const url = `/api/v3/properties/evaluation_export_to_cts/?organization_id=${orgId}`
+    return this._httpClient.post(url, { filename, property_view_ids: viewIds }, { responseType: 'arraybuffer' }).pipe(
+      map((response) => new Blob([response], { type: 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' })),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error exporting to CTS')
+      }),
+    )
+  }
+
+  facilityBpsExportToCts(orgId: number, viewIds: number[], filename: string): Observable<Blob> {
+    const url = `/api/v3/properties/facility_bps_export_to_cts/?organization_id=${orgId}`
+    return this._httpClient.post(url, { filename, property_view_ids: viewIds }, { responseType: 'arraybuffer' }).pipe(
+      map((response) => new Blob([response], { type: 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' })),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error exporting to CTS')
+      }),
+    )
+  }
 }

src/@seed/api/matching/index.ts

@@ -0,0 +1,2 @@
+export * from './matching.service'
+export * from './matching.types'

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

@@ -0,0 +1,29 @@
+import { HttpClient } from '@angular/common/http'
+import { inject, Injectable } from '@angular/core'
+import type { Observable } from 'rxjs'
+import { catchError, tap } from 'rxjs'
+import { ErrorService } from '@seed/services'
+import { SnackBarService } from 'app/core/snack-bar/snack-bar.service'
+import type { InventoryType } from 'app/modules/inventory'
+import type { MergingResponse } from './matching.types'
+
+@Injectable({ providedIn: 'root' })
+export class MatchingService {
+  private _httpClient = inject(HttpClient)
+  private _errorService = inject(ErrorService)
+  private _snackBar = inject(SnackBarService)
+
+  mergeInventory(orgId: number, viewIds: number[], type: InventoryType): Observable<MergingResponse> {
+    const url = `/api/v3/${type}/merge/?organization_id=${orgId}`
+    const key = type === 'taxlots' ? 'taxlot_view_ids' : 'property_view_ids'
+    const data = { [key]: viewIds }
+    return this._httpClient.post<MergingResponse>(url, data).pipe(
+      tap(() => {
+        this._snackBar.success('Successfully merged inventory')
+      }),
+      catchError(() => {
+        return this._errorService.handleError(null, 'Error merging inventory')
+      }),
+    )
+  }
+}

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

@@ -0,0 +1,6 @@
+export type MergingResponse = {
+  status: string;
+  match_link_count?: number;
+  match_merged_count?: number;
+  message?: string;
+}

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

@@ -28,6 +28,7 @@ import type {
   OrganizationsResponse,
   OrganizationUser,
   OrganizationUserResponse,
+  OrganizationUserSettings,
   OrganizationUsersResponse,
   StartSavingAccessLevelInstancesRequest,
   UpdateAccessLevelsRequest,
@@ -44,13 +45,15 @@ export class OrganizationService {
 
   private _organizations = new ReplaySubject<BriefOrganization[]>(1)
   private _currentOrganization = new ReplaySubject<Organization>(1)
+  private _orgUserSettings = new ReplaySubject<OrganizationUserSettings>(1)
   private _organizationUsers = new ReplaySubject<OrganizationUser[]>(1)
   private _accessLevelTree = new ReplaySubject<AccessLevelTree>(1)
   private _accessLevelInstancesByDepth = new ReplaySubject<AccessLevelsByDepth>(1)
   private _inventoryService = inject(InventoryService)
 
   organizations$ = this._organizations.asObservable()
   currentOrganization$ = this._currentOrganization.asObservable()
+  orgUserSettings$ = this._orgUserSettings.asObservable()
   organizationUsers$ = this._organizationUsers.asObservable()
   accessLevelTree$ = this._accessLevelTree.asObservable()
   accessLevelInstancesByDepth$ = this._accessLevelInstancesByDepth.asObservable()
@@ -113,6 +116,9 @@ export class OrganizationService {
     const data = { settings }
     const url = `/api/v4/organization_users/${orgUserId}/?organization_id=${orgId}`
     return this._httpClient.put<OrganizationUserResponse>(url, data).pipe(
+      tap(({ data }) => {
+        this._orgUserSettings.next(data.settings)
+      }),
       catchError((error: HttpErrorResponse) => {
         return this._errorService.handleError(error, 'Error updating organization user')
       }),

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

@@ -107,6 +107,7 @@ export type OrganizationUserSettings = {
   profile?: UserSettingsProfiles;
   crossCycles?: UserSettingsCrossCycles;
   labels?: UserLabelSettings;
+  pins?: UserPinSettings;
   insights?: InsightsUserSettings;
 }
 
@@ -130,6 +131,17 @@ type UserSettingsCrossCycles = {
   taxlots?: number[];
 }
 
+type UserPinSettings = {
+  properties?: {
+    left: string[];
+    right: string[];
+  };
+  taxlots?: {
+    left: string[];
+    right: string[];
+  };
+}
+
 type UserLabelSettings = { ids: number[]; operator: LabelOperator }
 
 export type InsightDatasetVisibility = 'compliant' | 'non-compliant' | 'unknown' | 'whisker'

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

@@ -3,14 +3,16 @@ import { inject, Injectable } from '@angular/core'
 import { catchError, map, type Observable, ReplaySubject, Subject, takeUntil, tap } from 'rxjs'
 import { UserService } from '@seed/api'
 import { ErrorService } from '@seed/services'
-import type { CreateEmailTemplateResponse, EmailTemplate, ListEmailTemplatesResponse } from './postoffice.types'
+import { SnackBarService } from 'app/core/snack-bar/snack-bar.service'
+import type { CreateEmailTemplateResponse, EmailTemplate, ListEmailTemplatesResponse, SendEmailResponse } from './postoffice.types'
 
 @Injectable({ providedIn: 'root' })
 export class PostOfficeService {
   private _httpClient = inject(HttpClient)
   private _userService = inject(UserService)
   private _errorService = inject(ErrorService)
   private _emailTemplates = new ReplaySubject<EmailTemplate[]>()
+  private _snackBar = inject(SnackBarService)
   private readonly _unsubscribeAll$ = new Subject<void>()
   orgId: number
   emailTemplates$ = this._emailTemplates.asObservable()
@@ -66,4 +68,26 @@ export class PostOfficeService {
       }),
     )
   }
+
+  sendEmail(orgId: number, stateIds: number[], template_id: number, inventory_type: string): Observable<SendEmailResponse> {
+    const url = `/api/v3/postoffice_email/?organization_id=${orgId}`
+    const data = {
+      from_email: 'blankl@example.com', // Dummy email. The backend will assign the appropriate email.
+      template_id,
+      inventory_id: stateIds,
+      inventory_type,
+    }
+    return this._httpClient.post<SendEmailResponse>(url, data).pipe(
+      tap(({ status }) => {
+        if (status === 'success') {
+          this._snackBar.success('Successfully sent email')
+        } else {
+          this._snackBar.alert('Error sending email')
+        }
+      }),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error sending email')
+      }),
+    )
+  }
 }