fix type strict errors

package.json

@@ -7,32 +7,31 @@
     "build": "ng build",
     "test": "ng test",
     "lint": "ng lint",
-    "e2e": "ng e2e",
     "build-data": "ng build ngx-data --configuration production",
     "publish-data": "npm publish dist/openharbor/ngx-data --access public"
   },
   "private": true,
   "dependencies": {
-    "@angular/animations": "^18.2.1",
+    "@angular/animations": "^18.0.0",
-    "@angular/common": "^18.2.1",
+    "@angular/common": "^18.0.0",
-    "@angular/compiler": "^18.2.1",
+    "@angular/compiler": "^18.0.0",
-    "@angular/core": "^18.2.1",
+    "@angular/core": "^18.0.0",
-    "@angular/forms": "^18.2.1",
+    "@angular/forms": "^18.0.0",
-    "@angular/platform-browser": "^18.2.1",
+    "@angular/platform-browser": "^18.0.0",
-    "@angular/platform-browser-dynamic": "^18.2.1",
+    "@angular/platform-browser-dynamic": "^18.0.0",
-    "@angular/router": "^18.2.1",
+    "@angular/router": "^18.0.0",
-    "@poweredsoft/data": "0.0.32",
+    "@openharbor/data": "^1.0.0-alpha.1",
     "graphql": "^14.5.0",
     "graphql-tag": "^2.10.0",
-    "rxjs": "~6.5.3",
+    "rxjs": "~7.8.0",
     "tslib": "^2.0.0",
     "zone.js": "~0.14.10"
   },
   "devDependencies": {
-    "@angular-devkit/build-angular": "^18.2.1",
+    "@angular-devkit/build-angular": "^18.0.0",
-    "@angular/cli": "^18.2.1",
+    "@angular/cli": "^18.0.0",
-    "@angular/compiler-cli": "^18.2.1",
+    "@angular/compiler-cli": "^18.0.0",
-    "@angular/language-service": "^18.2.1",
+    "@angular/language-service": "^18.0.0",
     "@types/jasmine": "~3.6.0",
     "@types/jasminewd2": "~2.0.3",
     "@types/node": "^12.11.1",

projects/openharbor/ngx-data/package.json

@@ -1,14 +1,14 @@
 {
   "name": "@openharbor/ngx-data",
-  "version": "18.0.0-alpha.3",
+  "version": "18.0.0-alpha.7",
   "repository": "https://git.openharbor.io/Open-Harbor/ngx-data",
+  "license": "MIT",
   "dependencies": {
     "tslib": "^2.7.0"
   },
   "peerDependencies": {
     "@angular/common": "^18.0.0",
     "@angular/core": "^18.0.0",
-    "@poweredsoft/data": "^0.0.31",
+    "@openharbor/data": "^1.0.0"
-    "rxjs": "^6.5.3||^7.4.0"
   }
 }

projects/openharbor/ngx-data/src/lib/BaseHttpDataSourceOptionsBuilder.ts

@@ -11,50 +11,47 @@ import {
   IDataSourceValidationError,
   IQueryCriteria,
   IResolveCommandModelEvent
-} from "@poweredsoft/data";
+} from "@openharbor/data";
 import {Observable, of, throwError} from "rxjs";
 import {catchError, switchMap} from "rxjs/operators";
 
-export abstract class BaseHttpDataSourceOptionsBuilder<TModel, TKey> {
+export abstract class BaseHttpDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel extends {}> {
   protected _commands: { [key: string]: IDataSourceCommandAdapterOptions<any>; } = {};
-  protected _keyResolver: (model: TModel) => TKey;
+  protected _keyResolver?: (model: TModel) => TModel[keyof TModel];
-  protected _defaultCriteria: IQueryCriteria;
+  protected _defaultCriteria!: IQueryCriteria;
-  protected _query: IDataSourceQueryAdapterOptions<TModel>;
+  protected _query!: IDataSourceQueryAdapterOptions<TQuery, TModel>;
 
   constructor(protected http: HttpClient) {
   }
 
-  createDataSource(): IDataSource<TModel> {
+  createDataSource(): IDataSource<TQuery, TModel> {
-    return new DataSource<TModel>(this.createOptions());
+    return new DataSource<TQuery, TModel>(this.createOptions());
   }
 
-  protected createTransport(): IDataSourceTransportOptions<TModel> {
+  protected createTransport(): IDataSourceTransportOptions<TQuery, TModel> {
-    let ret: IDataSourceTransportOptions<TModel> = {
+    return {
       query: this._query,
       commands: this._commands
     };
-    return ret;
   }
 
-  public keyResolver(resolver: (model: TModel) => TKey) {
+  public keyResolver(resolver: (model: TModel) => TModel[keyof TModel]) {
     this._keyResolver = resolver;
     return this;
   }
 
 
-  createOptions(): IDataSourceOptions<TModel> {
+  createOptions(): IDataSourceOptions<TQuery, TModel> {
-    let ret: IDataSourceOptions<TModel> = {
+    return {
       resolveIdField: this._keyResolver,
       defaultCriteria: this._defaultCriteria,
       transport: this.createTransport()
     };
-    return ret;
   }
 
   private _messageErrorHandler(err: HttpErrorResponse) {
-
     if (typeof err.error == "object") {
-      // if status not okay then its an exception error
+      // if status not okay then it's an exception error
       if (err.error.hasOwnProperty('Message') && typeof (err.error['Message']) == "string") {
         return throwError(<IDataSourceErrorMessage>{
           type: 'message',
@@ -96,11 +93,8 @@ export abstract class BaseHttpDataSourceOptionsBuilder<TModel, TKey> {
     return this._messageErrorHandler(err);
   }
 
-
-
-
   public addCommandByCallback<TCommand, TCommandResult>(name: string, commandHandler: (command: TCommand) => Observable<TCommandResult>, resolveCommandModel?: (event: IResolveCommandModelEvent<TModel>) => Observable<TCommand & any>) {
-    const handleWrapper = command => {
+    const handleWrapper = (command: TCommand) => {
       return commandHandler(command).pipe(catchError(this._handleErrorPipe.bind(this)));
     };
 
@@ -115,7 +109,7 @@ export abstract class BaseHttpDataSourceOptionsBuilder<TModel, TKey> {
   }
 
   public addCommandByUrl<TCommand, TCommandResult>(name: string, url: string, resolveCommandModel?: (event: IResolveCommandModelEvent<TModel>) => Observable<TCommand & any>, beforeCommand?: (command: TCommand) => Observable<TCommand>) {
-    const handleWrapper = command => {
+    const handleWrapper = (command: TCommand) => {
       const finalBeforeCommand = beforeCommand || (_ => of(command));
       return finalBeforeCommand(command)
         .pipe(

projects/openharbor/ngx-data/src/lib/HttpDataSourceOptionsBuilder.ts

@@ -1,18 +1,18 @@
-import {HttpClient} from "@angular/common/http";
+import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@openharbor/data";
-import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@poweredsoft/data";
 import {Observable, of} from "rxjs";
 import {switchMap} from "rxjs/operators";
 import {BaseHttpDataSourceOptionsBuilder} from "./BaseHttpDataSourceOptionsBuilder";
+import {HttpClient} from "@angular/common/http";
 
-export class HttpDataSourceOptionsBuilder<TModel, TKey> extends BaseHttpDataSourceOptionsBuilder<TModel, TKey>
+export class HttpDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel extends {}> extends BaseHttpDataSourceOptionsBuilder<TQuery, TModel>
 {
-  private _beforeRead: (TQuery: IQueryCriteria) => Observable<IQueryCriteria>;
-
   constructor(http: HttpClient) {
     super(http);
   }
 
-  public beforeRead<TDynamicQuery extends IQueryCriteria>(beforeRead: (query: TDynamicQuery) => Observable<TDynamicQuery>) {
+  private _beforeRead?: (query: IQueryCriteria) => Observable<TQuery>;
+
+  public beforeRead(beforeRead: (query: IQueryCriteria) => Observable<TQuery>) {
     this._beforeRead = beforeRead;
     return this;
   }
@@ -21,7 +21,7 @@ export class HttpDataSourceOptionsBuilder<TModel, TKey> extends BaseHttpDataSour
     this._query = {
       adapter: {
         handle: (query: IQueryCriteria) => {
-          const finalBeforeRead = this._beforeRead || (t => of(query));
+          const finalBeforeRead = this._beforeRead || (() => of(query));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {
@@ -35,11 +35,11 @@ export class HttpDataSourceOptionsBuilder<TModel, TKey> extends BaseHttpDataSour
     return this;
   }
 
-  public queryHandler<TQuery extends IQueryCriteria>(queryHandler: (query: TQuery) => Observable<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>) {
+  public queryHandler(queryHandler: (query: TQuery) => Observable<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>) {
     this._query = {
       adapter: {
         handle: (query: TQuery) => {
-          const finalBeforeRead = this._beforeRead || (t => of(query));
+          const finalBeforeRead = this._beforeRead || (() => of(query));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {
@@ -49,7 +49,6 @@ export class HttpDataSourceOptionsBuilder<TModel, TKey> extends BaseHttpDataSour
         }
       }
     }
-
     return this;
   }
 

projects/openharbor/ngx-data/src/lib/ListDataSourceBuilder.ts

@@ -1,13 +1,13 @@
-import {HttpClient} from "@angular/common/http";
+import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@openharbor/data";
-import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@poweredsoft/data";
 import {Observable, of} from "rxjs";
 import {map, switchMap} from "rxjs/operators";
 import {BaseHttpDataSourceOptionsBuilder} from "./BaseHttpDataSourceOptionsBuilder";
+import {HttpClient} from "@angular/common/http";
 
-export class ListDataSourceOptionsBuilder<TQuery, TModel, TKey>
+export class ListDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel extends {}>
-  extends BaseHttpDataSourceOptionsBuilder<TModel, TKey>
+  extends BaseHttpDataSourceOptionsBuilder<TQuery, TModel>
 {
-  private _beforeRead: (query: IQueryCriteria) => Observable<TQuery>;
+  private _beforeRead?: (query: IQueryCriteria) => Observable<TQuery>;
 
   constructor(http: HttpClient) {
     super(http);
@@ -46,10 +46,9 @@ export class ListDataSourceOptionsBuilder<TQuery, TModel, TKey>
     return this;
   }
 
-  protected convertToParams(finalQuery: TQuery)
+  protected convertToParams(finalQuery: TQuery) {
-  {
     return Object.keys(finalQuery).reduce((prev, key) => {
-      prev[key] = finalQuery[key];
+      prev[key] = (finalQuery as any)[key]; // Cast finalQuery to any to bypass the error
       return prev;
     }, {} as { [param: string]: string | string[]; });
   }
@@ -75,7 +74,7 @@ export class ListDataSourceOptionsBuilder<TQuery, TModel, TKey>
             );
         }
       }
-    }
+    };
 
     return this;
   }
@@ -84,7 +83,7 @@ export class ListDataSourceOptionsBuilder<TQuery, TModel, TKey>
     this._query = {
       adapter: {
         handle: (query: TQuery) => {
-          const finalBeforeRead = this._beforeRead || (t => of({}));
+          const finalBeforeRead = this._beforeRead || (() => of({}));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {

projects/openharbor/ngx-data/src/lib/SingleObjectDataSourceBuilder.ts

@@ -1,12 +1,12 @@
-import {HttpClient} from '@angular/common/http';
+import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from '@openharbor/data';
-import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from '@poweredsoft/data';
 import {Observable, of} from 'rxjs';
 import {map, switchMap} from 'rxjs/operators';
 import {BaseHttpDataSourceOptionsBuilder} from './BaseHttpDataSourceOptionsBuilder';
+import {HttpClient} from "@angular/common/http";
 
-export class SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>
+export class SingleDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel extends {}>
-  extends BaseHttpDataSourceOptionsBuilder<TModel, TKey> {
+  extends BaseHttpDataSourceOptionsBuilder<TQuery, TModel> {
-  private _beforeRead: (query: IQueryCriteria) => Observable<TQuery>;
+  private _beforeRead?: (query: IQueryCriteria) => Observable<TQuery>;
 
   constructor(http: HttpClient) {
     super(http);
@@ -21,7 +21,7 @@ export class SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>
     this._query = {
       adapter: {
         handle: (query: IQueryCriteria) => {
-          const finalBeforeRead = this._beforeRead || ((query: IQueryCriteria) => of({} as TQuery));
+          const finalBeforeRead = this._beforeRead || (() => of({} as TQuery));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {
@@ -46,7 +46,7 @@ export class SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>
 
   protected convertToParams(finalQuery: TQuery) {
     return Object.keys(finalQuery).reduce((prev, key) => {
-      prev[key] = finalQuery[key];
+      prev[key] = (finalQuery as any)[key]; // Cast finalQuery to any to bypass the error
       return prev;
     }, {} as { [param: string]: string | string[]; });
   }
@@ -80,7 +80,7 @@ export class SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>
     this._query = {
       adapter: {
         handle: (query: TQuery) => {
-          const finalBeforeRead = this._beforeRead || (t => of({}));
+          const finalBeforeRead = this._beforeRead || (() => of({}));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {

projects/openharbor/ngx-data/src/lib/http-data-source-service.service.ts

@@ -1,25 +0,0 @@
-import {Inject, Injectable} from "@angular/core";
-import { HttpClient } from '@angular/common/http';
-import { HttpDataSourceOptionsBuilder } from "./HttpDataSourceBuilder";
-import { SingleDataSourceOptionsBuilder } from "./SingleObjectDataSourceBuilder";
-import { ListDataSourceOptionsBuilder } from "./ListDataSourceBuilder";
-
-
-@Injectable({
-  providedIn: 'root'
-})
-export class HttpDataSourceService {
-  @Inject(HttpClient) protected http!: HttpClient;
-
-  builder<TModel, TKey>() {
-    return new HttpDataSourceOptionsBuilder<TModel, TKey>(this.http);
-  }
-
-  singleBuilder<TQuery, TModel, TKey>() {
-    return new SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>(this.http);
-  }
-
-  listBuilder<TQuery, TModel, TKey>() {
-    return new ListDataSourceOptionsBuilder<TQuery, TModel, TKey>(this.http);
-  }
-}

projects/openharbor/ngx-data/src/lib/http-data-source.service.ts

@@ -0,0 +1,27 @@
+import {Injectable} from "@angular/core";
+import {HttpClient} from '@angular/common/http';
+import {HttpDataSourceOptionsBuilder} from "./HttpDataSourceOptionsBuilder";
+import {SingleDataSourceOptionsBuilder} from "./SingleObjectDataSourceBuilder";
+import {ListDataSourceOptionsBuilder} from "./ListDataSourceBuilder";
+import {IQueryCriteria} from "@openharbor/data";
+
+
+@Injectable({
+  providedIn: 'root'
+})
+export class HttpDataSourceService {
+  constructor(private http: HttpClient) {
+  }
+
+  builder<TQuery extends IQueryCriteria, TModel extends {}>() {
+    return new HttpDataSourceOptionsBuilder<TQuery, TModel>(this.http);
+  }
+
+  singleBuilder<TQuery extends IQueryCriteria, TModel extends {}>() {
+    return new SingleDataSourceOptionsBuilder<TQuery, TModel>(this.http);
+  }
+
+  listBuilder<TQuery extends IQueryCriteria, TModel extends {}>() {
+    return new ListDataSourceOptionsBuilder<TQuery, TModel>(this.http);
+  }
+}

projects/openharbor/ngx-data/src/lib/in-memory/core/InMemoryDataSourceOptionBuilderAbstraction.ts

@@ -0,0 +1,35 @@
+import {
+  DataSource,
+  IDataSource,
+  IDataSourceCommandAdapterOptions,
+  IDataSourceOptions,
+  IDataSourceQueryAdapterOptions,
+  IDataSourceTransportOptions,
+  IQueryCriteria
+} from "@openharbor/data";
+
+export abstract class InMemoryDataSourceOptionBuilderAbstraction<TQuery, TModel> {
+  protected _commands: { [key: string]: IDataSourceCommandAdapterOptions<any>; } = {};
+  protected _keyResolver: (model: TModel) => TModel[keyof TModel];
+  protected _defaultCriteria: IQueryCriteria;
+  protected _query: IDataSourceQueryAdapterOptions<TQuery, TModel>;
+
+  createDataSource(): IDataSource<TQuery, TModel> {
+    return new DataSource<TQuery, TModel>(this.createOptions());
+  }
+
+  createOptions(): IDataSourceOptions<TQuery, TModel> {
+    return {
+      resolveIdField: this._keyResolver,
+      defaultCriteria: this._defaultCriteria,
+      transport: this.createTransport()
+    };
+  }
+
+  protected createTransport(): IDataSourceTransportOptions<TQuery, TModel> {
+    return {
+      query: this._query,
+      commands: this._commands
+    };
+  }
+}

projects/openharbor/ngx-data/src/lib/ngx-data.service.ts

@@ -1,6 +1,7 @@
-import {Inject, Injectable} from '@angular/core';
+import {inject, Inject, Injectable} from '@angular/core';
 import {HttpClient, HttpErrorResponse} from '@angular/common/http';
 import {
+  ICommand,
   IDataSourceCommandAdapterOptions,
   IDataSourceError,
   IDataSourceErrorMessage,
@@ -12,33 +13,16 @@ import {
   IQueryExecutionGroupResult,
   IQueryExecutionResult,
   IResolveCommandModelEvent
-} from '@poweredsoft/data';
+} from '@openharbor/data';
 import {catchError, switchMap} from 'rxjs/operators';
 import {Observable, of, throwError} from 'rxjs';
 
-/**
- * providedIn: "root"
- *
- * Automatic Injection: When you use providedIn: "root", Angular automatically
- * provides the service in the root injector, making it a singleton and available
- * throughout the application without needing any manual import in a module.
- *
- * Tree-shakable: This method is tree-shakable, meaning if the service is not
- * used anywhere in the application, it can be removed during the build process,
- * reducing the final bundle size.
- *
- * Convenience: It is simpler for the user, as they do not need to worry about
- * importing the module for the service. They can just inject the service wherever
- * they need it.
- *
- */
-
 @Injectable({
   providedIn: 'root'
 })
 export class GenericRestDataSourceService
 {
-  @Inject(HttpClient) protected http!: HttpClient;
+  protected readonly http = inject(HttpClient);
 
   private _handleErrorPipe(err: HttpErrorResponse) : Observable<IDataSourceError> {
 
@@ -80,29 +64,27 @@ export class GenericRestDataSourceService
     });
   }
 
-  createDataSourceOptions<TModel, TKey>(route: string, keyResolver: (model: TModel) => TKey, defaultCriteria: IQueryCriteria, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceOptions<TModel>
+  createDataSourceOptions<TQuery extends IQueryCriteria, TModel extends ICommand>(route: string, keyResolver: (model: TModel) => TModel[keyof TModel], defaultCriteria: IQueryCriteria, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceOptions<TQuery, TModel>
   {
-    const dataSourceTransportOptions = this.createStandardRestTransportOptions<TModel, TKey>(route, keyResolver, beforeRead);
+    const dataSourceTransportOptions = this.createStandardRestTransportOptions<TQuery, TModel>(route, keyResolver, beforeRead);
 
-    const dataSourceOptions: IDataSourceOptions<TModel> = {
+    return {
       defaultCriteria: defaultCriteria,
       resolveIdField: keyResolver,
       transport: dataSourceTransportOptions
     };
-
-    return dataSourceOptions;
   }
 
-  setResolveCommand<TModel>(options: IDataSourceOptions<TModel>, name: string, resolveCommandModel: (event: IResolveCommandModelEvent<TModel>) => Observable<any>) {
+  setResolveCommand<TQuery extends IQueryCriteria, TModel>(options: IDataSourceOptions<TQuery, TModel>, name: string, resolveCommandModel: (event: IResolveCommandModelEvent<TModel>) => Observable<any>) {
     options.transport.commands[name].resolveCommandModel = resolveCommandModel;
   }
 
-  createStandardRestTransportOptions<TModel, TKey>(route: string, keyResolver: (model: TModel) => TKey, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceTransportOptions<TModel> {
+  createStandardRestTransportOptions<TQuery extends IQueryCriteria, TModel extends ICommand>(route: string, keyResolver: (model: TModel) => TModel[keyof TModel], beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceTransportOptions<TQuery, TModel> {
-    const query: IDataSourceQueryAdapterOptions<TModel> = {
+    const query: IDataSourceQueryAdapterOptions<TQuery, TModel> = {
       adapter: {
         handle: (criteria: IQueryCriteria) => {
           const queryRoute = `${route}/read`;
-          const finalBeforeRead = beforeRead || (t => of(criteria));
+          const finalBeforeRead = beforeRead || (() => of(criteria));
           return finalBeforeRead(criteria)
             .pipe(switchMap(finalQuery => {
               return this.http.post<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>(queryRoute, finalQuery);

projects/openharbor/ngx-data/src/public-api.ts

@@ -2,4 +2,4 @@
  * Public API Surface of ngx-data
  */
 export * from './lib/ngx-data.service';
-export * from './lib/http-data-source-service.service'
+export * from './lib/http-data-source.service'

src/app/app-routing.module.ts

@@ -5,7 +5,7 @@ import { Routes, RouterModule } from '@angular/router';
 const routes: Routes = [];
 
 @NgModule({
-  imports: [RouterModule.forRoot(routes, { relativeLinkResolution: 'legacy' })],
+  imports: [RouterModule.forRoot(routes)],
   exports: [RouterModule]
 })
 export class AppRoutingModule { }

src/app/app.component.ts

@@ -1,6 +1,6 @@
 import {Component, OnInit} from '@angular/core';
 import {of} from 'rxjs';
-import {IDataSource, IQueryCriteria} from '@poweredsoft/data';
+import {IDataSource, IQueryCriteria} from '@openharbor/data';
 import {HttpDataSourceService} from '@openharbor/ngx-data';
 
 export interface IContact
@@ -24,17 +24,17 @@ export interface IEchoCommand {
   message: string;
 }
 
-export interface IMyQuery extends IQueryCriteria{
+export interface IMyQuery extends IQueryCriteria {
   params: {
     showDisabled: boolean;
   }
 }
 
-export interface IOnePersonQuery {
+export interface IOnePersonQuery extends IQueryCriteria {
   personId: number;
 }
 
-export interface IListPersonQuery {
+export interface IListPersonQuery extends IQueryCriteria {
   search?: string;
 }
 
@@ -45,17 +45,17 @@ export interface IListPersonQuery {
 })
 export class AppComponent implements OnInit {
   title = 'ngx-data';
-  dataSource: IDataSource<IContact>;
+  dataSource: IDataSource<IMyQuery, IContact>;
   latestData: any;
 
-  onePersonDs: IDataSource<IPerson>;
+  onePersonDs: IDataSource<IOnePersonQuery, IPerson>;
-  listPersonDs: IDataSource<IPerson>;
+  listPersonDs: IDataSource<IListPersonQuery, IPerson>;
   latestSingle: any;
   latestList: any;
 
   constructor(private hdss: HttpDataSourceService) {
 
-    this.onePersonDs = hdss.singleBuilder<IOnePersonQuery, IPerson, number>()
+    this.onePersonDs = hdss.singleBuilder<IOnePersonQuery, IPerson>()
       .keyResolver(t => t.id)
       .queryUrl('https://localhost:5001/api/query/onePerson')
       .beforeRead(_ => {
@@ -65,7 +65,7 @@ export class AppComponent implements OnInit {
       })
       .createDataSource();
 
-    this.listPersonDs = hdss.listBuilder<IListPersonQuery, IPerson, number>()
+    this.listPersonDs = hdss.listBuilder<IListPersonQuery, IPerson>()
       .keyResolver(t => t.id)
       .queryUrl('https://localhost:5001/api/query/listPerson')
       .beforeRead(criteria => {
@@ -76,7 +76,7 @@ export class AppComponent implements OnInit {
       .createDataSource();
 
     const ds = hdss
-      .builder<IContact, number>()
+      .builder<IMyQuery, IContact>()
       .keyResolver(m => m.id)
       .defaultCriteria({
         page: 1,

src/app/app.module.ts

@@ -1,15 +1,15 @@
-import { BrowserModule } from '@angular/platform-browser';
+import {BrowserModule} from '@angular/platform-browser';
-import { NgModule } from '@angular/core';
+import {NgModule} from '@angular/core';
 
-import { AppRoutingModule } from './app-routing.module';
+import {AppRoutingModule} from './app-routing.module';
-import { AppComponent } from './app.component';
+import {AppComponent} from './app.component';
-import { provideHttpClient, withInterceptorsFromDi } from '@angular/common/http';
+import {provideHttpClient, withInterceptorsFromDi} from '@angular/common/http';
-import { GraphQLModule } from './graphql.module';
 
 @NgModule({ declarations: [
-        AppComponent
+    AppComponent
-    ],
+  ],
-    bootstrap: [AppComponent], imports: [BrowserModule,
+  bootstrap: [AppComponent],
-        AppRoutingModule,
+  imports: [BrowserModule, AppRoutingModule],
-        GraphQLModule], providers: [provideHttpClient(withInterceptorsFromDi())] })
+  providers: [provideHttpClient(withInterceptorsFromDi())]
+})
 export class AppModule { }