feat(dh): add include related filter to message archive

apps/dh/api-dh/source/DataHub.WebApi.Tests/Snapshots/SchemaTests.ChangeTest.verified.graphql

@@ -526,7 +526,7 @@ type Query {
   gridAreas: [GridAreaDto!]!
   imbalancePricesOverview: ImbalancePricesOverview!
   imbalancePricesForMonth(year: Int! month: Int! areaCode: PriceAreaCode!): [ImbalancePriceDaily!]!
-  archivedMessages(created: DateRange! senderNumber: String receiverNumber: String documentTypes: [DocumentType!] businessReasons: [BusinessReason!] filter: String "Returns the first _n_ elements from the list." first: Int "Returns the elements in the list that come after the specified cursor." after: String "Returns the last _n_ elements from the list." last: Int "Returns the elements in the list that come before the specified cursor." before: String order: [ArchivedMessageSortInput!]): ArchivedMessagesConnection
+  archivedMessages(created: DateRange! senderNumber: String receiverNumber: String documentTypes: [DocumentType!] businessReasons: [BusinessReason!] includeRelated: Boolean filter: String "Returns the first _n_ elements from the list." first: Int "Returns the elements in the list that come after the specified cursor." after: String "Returns the last _n_ elements from the list." last: Int "Returns the elements in the list that come before the specified cursor." before: String order: [ArchivedMessageSortInput!]): ArchivedMessagesConnection
   organizationAuditLogs(organizationId: UUID!): [OrganizationAuditedChangeAuditLogDto!]!
   organizationById(id: UUID!): Organization!
   organizations: [Organization!]!

apps/dh/api-dh/source/DataHub.WebApi/GraphQL/Query/MessageArchiveQuery.cs

@@ -29,11 +29,16 @@ public async Task<IEnumerable<ArchivedMessageResult>> GetArchivedMessagesAsync(
         string? receiverNumber,
         DocumentType[]? documentTypes,
         BusinessReason[]? businessReasons,
+        bool? includeRelated,
         string? filter,
         [Service] IEdiB2CWebAppClient_V1 client)
     {
         var search = !string.IsNullOrWhiteSpace(filter)
-            ? new SearchArchivedMessagesCriteria() { MessageId = filter, IncludeRelatedMessages = true }
+            ? new SearchArchivedMessagesCriteria()
+            {
+                MessageId = filter,
+                IncludeRelatedMessages = includeRelated ?? false,
+            }
             : new SearchArchivedMessagesCriteria()
             {
                 CreatedDuringPeriod = new MessageCreationPeriod()

libs/dh/globalization/assets-localization/src/assets/i18n/da.json

@@ -151,6 +151,9 @@
     "new": "Ny søgning",
     "results": "Resultater",
     "searchById": "Søg på ID",
+    "filters": {
+      "includeRelated": "Inkluder relaterede"
+    },
     "drawer": {
       "message": "Besked",
       "sender": "Afsender",

libs/dh/globalization/assets-localization/src/assets/i18n/en.json

@@ -151,6 +151,9 @@
     "new": "New search",
     "results": "Results",
     "searchById": "Search by ID",
+    "filters": {
+      "includeRelated": "Include related"
+    },
     "drawer": {
       "message": "Message",
       "receiver": "Receiver",

libs/dh/message-archive/data-access-graphql/query/get-archived-messages.graphql

@@ -4,6 +4,7 @@ query GetArchivedMessages(
   $receiverNumber: String
   $documentTypes: [DocumentType!]
   $businessReasons: [BusinessReason!]
+  $includeRelated: Boolean
   $first: Int
   $last: Int
   $after: String
@@ -17,6 +18,7 @@ query GetArchivedMessages(
     receiverNumber: $receiverNumber
     documentTypes: $documentTypes
     businessReasons: $businessReasons
+    includeRelated: $includeRelated
     first: $first
     last: $last
     after: $after

libs/dh/message-archive/feature-search/src/lib/table.component.ts

@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { Component, output, signal } from '@angular/core';
+import { Component, OnInit, output, signal, viewChild } from '@angular/core';
 import { TranslocoDirective } from '@ngneat/transloco';
 
 import { VaterUtilityDirective } from '@energinet-datahub/watt/vater';
 import { WattButtonComponent } from '@energinet-datahub/watt/button';
-import { WattDataTableComponent } from '@energinet-datahub/watt/data';
+import { WattDataTableComponent, WattDataFiltersComponent } from '@energinet-datahub/watt/data';
 import { WattDatePipe } from '@energinet-datahub/watt/date';
 import { WattEmptyStateComponent } from '@energinet-datahub/watt/empty-state';
 import { WattTableColumnDef, WATT_TABLE } from '@energinet-datahub/watt/table';
@@ -30,18 +30,28 @@ import {
 } from '@energinet-datahub/dh/shared/domain/graphql';
 import { GetArchivedMessagesDataSource } from '@energinet-datahub/dh/shared/domain/graphql/data-source';
 import { ArchivedMessage } from '@energinet-datahub/dh/message-archive/domain';
+import { WattFilterChipComponent } from '@energinet-datahub/watt/chip';
+import { FormControl, FormGroup, ReactiveFormsModule } from '@angular/forms';
+import { takeUntilDestroyed } from '@angular/core/rxjs-interop';
+import { WattFormChipDirective } from '@energinet-datahub/watt/field';
+
+type Variables = Partial<GetArchivedMessagesQueryVariables>;
 
 @Component({
   selector: 'dh-message-archive-search-table',
   standalone: true,
   imports: [
+    ReactiveFormsModule,
     TranslocoDirective,
     VaterUtilityDirective,
     WATT_TABLE,
     WattButtonComponent,
+    WattDataFiltersComponent,
     WattDataTableComponent,
     WattDatePipe,
     WattEmptyStateComponent,
+    WattFilterChipComponent,
+    WattFormChipDirective,
   ],
   template: `
     <watt-data-table
@@ -57,6 +67,15 @@ import { ArchivedMessage } from '@energinet-datahub/dh/message-archive/domain';
       <watt-button variant="secondary" icon="plus" (click)="new.emit()">
         {{ t('new') }}
       </watt-button>
+      @if (dataSource.filter) {
+        <watt-data-filters>
+          <form [formGroup]="form">
+            <watt-filter-chip [formControl]="this.form.controls.includeRelated">
+              {{ t('filters.includeRelated') }}
+            </watt-filter-chip>
+          </form>
+        </watt-data-filters>
+      }
       <watt-table
         *transloco="let resolveHeader; read: 'messageArchive.columns'"
         #table
@@ -92,10 +111,13 @@ import { ArchivedMessage } from '@energinet-datahub/dh/message-archive/domain';
     </watt-data-table>
   `,
 })
-export class DhMessageArchiveSearchTableComponent {
+export class DhMessageArchiveSearchTableComponent implements OnInit {
   new = output();
   open = output<ArchivedMessage>();
   selection = signal<ArchivedMessage | undefined>(undefined);
+  dataTable = viewChild.required(WattDataTableComponent);
+  form = new FormGroup({ includeRelated: new FormControl(false) });
+  filterChanges = this.form.valueChanges.pipe(takeUntilDestroyed());
 
   columns: WattTableColumnDef<ArchivedMessage> = {
     messageId: { accessor: 'messageId' },
@@ -113,10 +135,22 @@ export class DhMessageArchiveSearchTableComponent {
     },
   });
 
-  fetch = (variables: GetArchivedMessagesQueryVariables) => this.dataSource.refetch(variables);
-  reset = () => this.dataSource.reset();
+  ngOnInit() {
+    this.filterChanges.subscribe((variables) => this.dataSource.refetch(variables));
+  }
+
   clearSelection = () => this.selection.set(undefined);
 
+  fetch = (variables: Variables) => {
+    this.dataTable().reset();
+    this.dataSource.refetch(variables);
+  };
+
+  reset = () => {
+    this.dataTable().reset();
+    this.dataSource.reset();
+  };
+
   onRowClick = (row: ArchivedMessage) => {
     this.selection.set(row);
     this.open.emit(row);

libs/dh/shared/util-apollo/src/lib/dataSource.ts

@@ -48,7 +48,7 @@ export class ApolloDataSource<TResult, TVariables extends ConnectionVariables, T
 {
   private _query: QueryResult<TResult, TVariables>;
   private _connection: Observable<Connection<TNode>>;
-  private _inputChange: ReplaySubject<TVariables | undefined> = new ReplaySubject(1);
+  private _inputChange: ReplaySubject<Partial<TVariables> | undefined> = new ReplaySubject(1);
   private _subscription?: Subscription;
 
   private _totalCount = signal(0);
@@ -125,7 +125,7 @@ export class ApolloDataSource<TResult, TVariables extends ConnectionVariables, T
     if (!options?.skip) this._inputChange.next(options?.variables);
   }
 
-  refetch = (variables?: TVariables) => this._inputChange.next(variables);
+  refetch = (variables?: Partial<TVariables>) => this._inputChange.next(variables);
   subscribeToMore: QueryResult<TResult, TVariables>['subscribeToMore'] = (options) =>
     this._query.subscribeToMore(options);
 

libs/watt/src/lib/components/chip/watt-filter-chip.component.ts

@@ -50,6 +50,7 @@ export class WattFilterChipComponent<T = string> {
   isFirstRender = useIsFirstRender();
 
   onChange(input: HTMLInputElement): void {
-    this.selectionChange.emit(input.value as T);
+    const value = this.choice ? input.value : input.checked;
+    this.selectionChange.emit(value as T);
   }
 }

libs/watt/src/lib/components/data/watt-data-table.component.ts

@@ -14,7 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { Component, ViewEncapsulation, contentChild, inject, input, output } from '@angular/core';
+import {
+  Component,
+  ViewEncapsulation,
+  contentChild,
+  inject,
+  input,
+  output,
+  viewChild,
+} from '@angular/core';
 
 import {
   VaterFlexComponent,
@@ -127,6 +135,9 @@ export class WattDataTableComponent {
 
   table = contentChild.required(WattTableComponent<unknown>, { descendants: true });
 
+  search = viewChild(WattSearchComponent);
+  reset = () => this.search()?.clear();
+
   onSearch(value: string) {
     this.table().dataSource.filter = value;
     if (!value) this.clear.emit();