Works kind of, wip

This commit is contained in:
Daniel Ponte 2025-02-01 08:52:03 -05:00
parent 1c0734f19d
commit 8a223b8897
9 changed files with 135 additions and 136 deletions

View file

@ -27,8 +27,7 @@
}
}
],
"navigationUrls":
[
"navigationUrls": [
"/**",
"!/**/*.*",
"!/**/****",

View file

@ -1,10 +1,4 @@
import {
Component,
inject,
Pipe,
PipeTransform,
ViewChild,
} from '@angular/core';
import { Component, inject, ViewChild } from '@angular/core';
import { CommonModule, AsyncPipe } from '@angular/common';
import { MatProgressSpinnerModule } from '@angular/material/progress-spinner';
import { MatTableModule } from '@angular/material/table';
@ -17,13 +11,20 @@ import { PrefsService } from '../prefs/prefs.service';
import { MatIconModule } from '@angular/material/icon';
import { SelectionModel } from '@angular/cdk/collections';
import { MatCheckboxModule } from '@angular/material/checkbox';
import { BehaviorSubject, Observable, Subscription } from 'rxjs';
import { map, switchMap } from 'rxjs/operators';
import { CallsListParams, CallsService } from './calls.service';
import { BehaviorSubject, Subscription } from 'rxjs';
import { switchMap } from 'rxjs/operators';
import {
CallsListParams,
CallsService,
DatePipe,
DownloadURLPipe,
FixedPointPipe,
TalkgroupPipe,
TimePipe,
} from './calls.service';
import { CallRecord } from '../calls';
import { TalkgroupService } from '../talkgroups/talkgroups.service';
import { Talkgroup } from '../talkgroup';
import { MatFormFieldModule } from '@angular/material/form-field';
import {
FormControl,
@ -49,94 +50,6 @@ import {
import { IncidentRecord } from '../incidents';
import { SelectIncidentDialogComponent } from '../incidents/select-incident-dialog/select-incident-dialog.component';
@Pipe({
name: 'grabDate',
standalone: true,
pure: true,
})
export class DatePipe implements PipeTransform {
transform(ts: string, args?: any): string {
const timestamp = new Date(ts);
return timestamp.getMonth() + 1 + '/' + timestamp.getDate();
}
}
@Pipe({
name: 'time',
standalone: true,
pure: true,
})
export class TimePipe implements PipeTransform {
transform(ts: string, args?: any): string {
const timestamp = new Date(ts);
return timestamp.toLocaleTimeString(navigator.language, {
hour: '2-digit',
minute: '2-digit',
hourCycle: 'h23',
});
}
}
@Pipe({
name: 'talkgroup',
standalone: true,
pure: true,
})
export class TalkgroupPipe implements PipeTransform {
constructor(private tgService: TalkgroupService) {}
transform(call: CallRecord, field: string): Observable<string> {
return this.tgService.getTalkgroup(call.system_id, call.tgid).pipe(
map((tg: Talkgroup) => {
switch (field) {
case 'alpha': {
return tg.alpha_tag ?? call.tgid;
break;
}
case 'group': {
return tg.tg_group ?? '\u2014';
break;
}
case 'system': {
return tg.system?.name ?? tg.system_id.toString();
}
default: {
return tg.name ?? '\u2014';
break;
}
}
}),
);
}
}
@Pipe({
name: 'fixedPoint',
standalone: true,
pure: true,
})
export class FixedPointPipe implements PipeTransform {
constructor() {}
transform(quant: number, divisor: number, places: number): string {
const seconds = quant / divisor;
return seconds.toFixed(places);
}
}
@Pipe({
name: 'audioDownloadURL',
standalone: true,
pure: true,
})
export class DownloadURLPipe implements PipeTransform {
constructor(private callsSvc: CallsService) {}
transform(call: CallRecord, args?: any): string {
return this.callsSvc.callAudioDownloadURL(call.id);
}
}
const reqPageSize = 200;
@Component({
selector: 'app-calls',
@ -144,8 +57,8 @@ const reqPageSize = 200;
MatIconModule,
FixedPointPipe,
TalkgroupPipe,
DatePipe,
TimePipe,
DatePipe,
MatPaginatorModule,
MatTableModule,
AsyncPipe,

View file

@ -1,8 +1,98 @@
import { Injectable } from '@angular/core';
import { Injectable, Pipe, PipeTransform } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs';
import { map, Observable } from 'rxjs';
import { CallRecord } from '../calls';
import { environment } from '.././../environments/environment';
import { TalkgroupService } from '../talkgroups/talkgroups.service';
import { Talkgroup } from '../talkgroup';
@Pipe({
name: 'grabDate',
standalone: true,
pure: true,
})
export class DatePipe implements PipeTransform {
transform(ts: string, args?: any): string {
const timestamp = new Date(ts);
return timestamp.getMonth() + 1 + '/' + timestamp.getDate();
}
}
@Pipe({
name: 'time',
standalone: true,
pure: true,
})
export class TimePipe implements PipeTransform {
transform(ts: string, args?: any): string {
const timestamp = new Date(ts);
return timestamp.toLocaleTimeString(navigator.language, {
hour: '2-digit',
minute: '2-digit',
hourCycle: 'h23',
});
}
}
@Pipe({
name: 'talkgroup',
standalone: true,
pure: true,
})
export class TalkgroupPipe implements PipeTransform {
constructor(private tgService: TalkgroupService) {}
transform(call: CallRecord, field: string): Observable<string> {
return this.tgService.getTalkgroup(call.system_id, call.tgid).pipe(
map((tg: Talkgroup) => {
switch (field) {
case 'alpha': {
return tg.alpha_tag ?? call.tgid;
break;
}
case 'group': {
return tg.tg_group ?? '\u2014';
break;
}
case 'system': {
return tg.system?.name ?? tg.system_id.toString();
}
default: {
return tg.name ?? '\u2014';
break;
}
}
}),
);
}
}
@Pipe({
name: 'fixedPoint',
standalone: true,
pure: true,
})
export class FixedPointPipe implements PipeTransform {
constructor() {}
transform(quant: number, divisor: number, places: number): string {
const seconds = quant / divisor;
return seconds.toFixed(places);
}
}
@Pipe({
name: 'audioDownloadURL',
standalone: true,
pure: true,
})
export class DownloadURLPipe implements PipeTransform {
constructor(private callsSvc: CallsService) {}
transform(call: CallRecord, args?: any): string {
return this.callsSvc.callAudioDownloadURL(call.id);
}
}
export interface CallsListParams {
start: Date | null;

View file

@ -35,7 +35,7 @@ import {
TimePipe,
DatePipe,
DownloadURLPipe,
} from '../../calls/calls.component';
} from '../../calls/calls.service';
import { CallPlayerComponent } from '../../calls/player/call-player/call-player.component';
import { FmtDatePipe } from '../incidents.component';
import { MatMenuModule } from '@angular/material/menu';
@ -183,7 +183,8 @@ export class IncidentComponent {
ngOnInit() {
let incOb: Observable<IncidentRecord>;
if (this.route.component === this.constructor) { // loaded by route
if (this.route.component === this.constructor) {
// loaded by route
this.incID = this.route.snapshot.paramMap.get('id')!;
incOb = this.incSvc.getIncident(this.incID);
} else {

View file

@ -1,10 +1,6 @@
@let sh = share | async;
@if (sh == null) {
} @else if (sh.shareType == 'incident') {
} @else if (sh.shareType == "incident") {
<app-incident [incident]="sh"></app-incident>
} @else if (sh.shareType == 'call') {
} @else {
}
} @else if (sh.shareType == "call") {
} @else {}

View file

@ -8,9 +8,8 @@ describe('ShareComponent', () => {
beforeEach(async () => {
await TestBed.configureTestingModule({
imports: [ShareComponent]
})
.compileComponents();
imports: [ShareComponent],
}).compileComponents();
fixture = TestBed.createComponent(ShareComponent);
component = fixture.componentInstance;

View file

@ -5,19 +5,15 @@ import { Observable, Subscription, switchMap } from 'rxjs';
import { IncidentComponent } from '../incidents/incident/incident.component';
import { AsyncPipe } from '@angular/common';
@Component({
selector: 'app-share',
imports: [
AsyncPipe,
IncidentComponent,
],
imports: [AsyncPipe, IncidentComponent],
templateUrl: './share.component.html',
styleUrl: './share.component.scss'
styleUrl: './share.component.scss',
})
export class ShareComponent {
shareID!: string;
share!: Observable<Share|null>;
share!: Observable<Share | null>;
constructor(
private route: ActivatedRoute,
private shareSvc: ShareService,

View file

@ -9,26 +9,28 @@ export interface Share {
share: ShareType;
}
@Injectable({
providedIn: 'root'
providedIn: 'root',
})
export class ShareService {
constructor(private http: HttpClient) {}
constructor(
private http: HttpClient,
) { }
getShare(id: string): Observable<Share|null> {
return this.http.get<ShareType>(`/share/${id}`, {observe: 'response'}).pipe(
getShare(id: string): Observable<Share | null> {
return this.http
.get<ShareType>(`/share/${id}`, { observe: 'response' })
.pipe(
map((res) => {
let typ = res.headers.get('X-Share-Type');
switch(typ) {
switch (typ) {
case 'call':
return <Share>{shareType: typ, share: (res.body as ArrayBuffer)};
return <Share>{ shareType: typ, share: res.body as ArrayBuffer };
case 'incident':
return <Share>{shareType: typ, share: (res.body as IncidentRecord)};
return <Share>{
shareType: typ,
share: res.body as IncidentRecord,
};
}
return null;
})
}),
);
}
}

View file

@ -33,7 +33,10 @@ export class TalkgroupService {
private subscriptions = new Subscription();
constructor(private http: HttpClient) {
this.tgs$ = this.fetchAll.pipe(switchMap(() => this.getTalkgroups()));
this.tags$ = this.fetchAll.pipe(switchMap(() => this.getAllTags()), shareReplay());
this.tags$ = this.fetchAll.pipe(
switchMap(() => this.getAllTags()),
shareReplay(),
);
this.fillTgMap();
}