Column Mappings

package.json

@@ -53,6 +53,7 @@
     "ag-grid-community": "^33.1.1",
     "crypto-es": "^2.1.0",
     "cspell": "^8.17.3",
+    "file-saver": "^2.0.5",
     "jwt-decode": "^4.0.0",
     "lodash-es": "^4.17.21",
     "luxon": "^3.5.0",

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

@@ -1,2 +1,3 @@
 export * from './column.service'
 export * from './column.types'
+export * from './mappable_column.service'

src/@seed/api/column/mappable_column.service.ts

@@ -0,0 +1,59 @@
+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, Subject, takeUntil } from 'rxjs'
+import { ErrorService } from '@seed/services'
+import { UserService } from '../user'
+import type { Column, ColumnsResponse } from './column.types'
+
+@Injectable({ providedIn: 'root' })
+export class MappableColumnService {
+  private _httpClient = inject(HttpClient)
+  private _userService = inject(UserService)
+  private _propertyColumns = new ReplaySubject<Column[]>(1)
+  private _taxLotColumns = new ReplaySubject<Column[]>(1)
+  private _errorService = inject(ErrorService)
+  private readonly _unsubscribeAll$ = new Subject<void>()
+
+  propertyColumns$ = this._propertyColumns.asObservable()
+  taxLotColumns$ = this._taxLotColumns.asObservable()
+
+  constructor() {
+    // Fetch current org data whenever user org id changes
+    this._userService.currentOrganizationId$.pipe(takeUntil(this._unsubscribeAll$)).subscribe((organizationId) => {
+      this.getPropertyColumns(organizationId).subscribe()
+      this.getTaxLotColumns(organizationId).subscribe()
+    })
+  }
+
+  getPropertyColumns(org_id: number): Observable<Column[]> {
+    const url = `/api/v3/columns/mappable/?inventory_type=property&organization_id=${org_id}`
+    return this._httpClient.get<ColumnsResponse>(url).pipe(
+      map((cr) => {
+        const cols = cr.columns.filter((c) => c.table_name === 'PropertyState')
+        this._propertyColumns.next(cols)
+        return cols
+      }),
+      catchError((error: HttpErrorResponse) => {
+        // TODO need to figure out error handling
+        return this._errorService.handleError(error, 'Error fetching columns')
+      }),
+    )
+  }
+
+  getTaxLotColumns(org_id: number): Observable<Column[]> {
+    const url = `/api/v3/columns/mappable/?inventory_type=taxlot&organization_id=${org_id}`
+    return this._httpClient.get<ColumnsResponse>(url).pipe(
+      map((cr) => {
+        const cols = cr.columns.filter((c) => c.table_name === 'TaxLotState')
+        this._taxLotColumns.next(cols)
+        return cols
+      }),
+      catchError((error: HttpErrorResponse) => {
+        // TODO need to figure out error handling
+        return this._errorService.handleError(error, 'Error fetching columns')
+      }),
+    )
+  }
+}

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

@@ -0,0 +1,109 @@
+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, Subject, takeUntil } from 'rxjs'
+import { ErrorService } from '@seed/services'
+import { UserService } from '../user'
+import type { ColumnMapping, ColumnMappingProfile, ColumnMappingProfileDeleteResponse, ColumnMappingProfilesRequest, ColumnMappingProfileUpdateResponse, ColumnMappingSuggestionResponse } from './column_mapping_profile.types'
+
+@Injectable({ providedIn: 'root' })
+export class ColumnMappingProfileService {
+  private _httpClient = inject(HttpClient)
+  private _userService = inject(UserService)
+  private _profiles = new ReplaySubject<ColumnMappingProfile[]>(1)
+  private _errorService = inject(ErrorService)
+  private readonly _unsubscribeAll$ = new Subject<void>()
+
+  profiles$ = this._profiles.asObservable()
+
+  constructor() {
+    // Fetch current org data whenever user org id changes
+    this._userService.currentOrganizationId$.pipe(takeUntil(this._unsubscribeAll$)).subscribe((organizationId) => {
+      this.getProfiles(organizationId).subscribe()
+    })
+  }
+
+  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(
+      map((response) => {
+        this._profiles.next(response.data)
+        return response.data
+      }),
+      catchError((error: HttpErrorResponse) => {
+        // TODO need to figure out error handling
+        return this._errorService.handleError(error, 'Error fetching column mapping profiles')
+      }),
+    )
+  }
+
+  updateMappings(org_id: number, profile_id: number, mappings: ColumnMapping[]): Observable<ColumnMappingProfile> {
+    const url = `/api/v3/column_mapping_profiles/${profile_id}/?organization_id=${org_id}`
+    return this._httpClient.put<ColumnMappingProfileUpdateResponse>(url, { mappings }).pipe(
+      map((response) => {
+        return response.data
+      }),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error updating profile')
+      }),
+    )
+  }
+
+  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(
+      map((response) => {
+        return response.data
+      }),
+      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}`
+    return this._httpClient.delete<ColumnMappingProfileDeleteResponse>(url).pipe(
+      map((response) => {
+        return response
+      }),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error removing profile')
+      }),
+    )
+  }
+
+  create(org_id: number, profile: ColumnMappingProfile): Observable<ColumnMappingProfileUpdateResponse> {
+    const url = `/api/v3/column_mapping_profiles/?organization_id=${org_id}`
+    return this._httpClient.post<ColumnMappingProfileUpdateResponse>(url, { ...profile }).pipe(
+      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}`
+    return this._httpClient.get(url, { responseType: 'text' }).pipe(
+      map((response) => {
+        return new Blob([response], { type: 'text/csv;charset: utf-8' })
+      }),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error retrieving csv')
+      }),
+    )
+  }
+
+  suggestions(org_id: number, headers: string[]) {
+    const url = `/api/v3/column_mapping_profiles/suggestions/?organization_id=${org_id}`
+    return this._httpClient.post<ColumnMappingSuggestionResponse>(url, { headers }).pipe(
+      map((response) => {
+        return response.data
+      }),
+      catchError((error: HttpErrorResponse) => {
+        return this._errorService.handleError(error, 'Error retrieving suggestions')
+      }),
+    )
+  }
+}