package.json

@@ -7,6 +7,7 @@
     "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"
   },
@@ -20,7 +21,7 @@
     "@angular/platform-browser": "^18.2.1",
     "@angular/platform-browser-dynamic": "^18.2.1",
     "@angular/router": "^18.2.1",
-    "@openharbor/data": "^1.0.0-alpha.1",
+    "@poweredsoft/data": "0.0.32",
     "graphql": "^14.5.0",
     "graphql-tag": "^2.10.0",
     "rxjs": "~6.5.3",

projects/openharbor/ngx-data/package.json

@@ -1,15 +1,14 @@
 {
   "name": "@openharbor/ngx-data",
-  "version": "18.0.0-alpha.5",
+  "version": "18.0.0-alpha.3",
   "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",
-    "@openharbor/data": "^1.0.0",
+    "@poweredsoft/data": "^0.0.31",
     "rxjs": "^6.5.3||^7.4.0"
   }
 }

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

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

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

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

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

@@ -1,13 +1,18 @@
-import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@openharbor/data";
+import {HttpClient} from "@angular/common/http";
+import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from "@poweredsoft/data";
 import {Observable, of} from "rxjs";
 import {map, switchMap} from "rxjs/operators";
 import {BaseHttpDataSourceOptionsBuilder} from "./BaseHttpDataSourceOptionsBuilder";
 
-export class ListDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel>
-  extends BaseHttpDataSourceOptionsBuilder<TQuery, TModel>
+export class ListDataSourceOptionsBuilder<TQuery, TModel, TKey>
+  extends BaseHttpDataSourceOptionsBuilder<TModel, TKey>
 {
   private _beforeRead: (query: IQueryCriteria) => Observable<TQuery>;
 
+  constructor(http: HttpClient) {
+    super(http);
+  }
+
   public beforeRead(beforeRead: (query: IQueryCriteria) => Observable<TQuery>) {
     this._beforeRead = beforeRead;
     return this;
@@ -70,7 +75,7 @@ export class ListDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel>
             );
         }
       }
-    };
+    }
 
     return this;
   }
@@ -79,7 +84,7 @@ export class ListDataSourceOptionsBuilder<TQuery extends IQueryCriteria, TModel>
     this._query = {
       adapter: {
         handle: (query: TQuery) => {
-          const finalBeforeRead = this._beforeRead || (() => of({}));
+          const finalBeforeRead = this._beforeRead || (t => of({}));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {

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

@@ -1,12 +1,17 @@
-import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from '@openharbor/data';
+import {HttpClient} from '@angular/common/http';
+import {IQueryCriteria, IQueryExecutionGroupResult, IQueryExecutionResult} from '@poweredsoft/data';
 import {Observable, of} from 'rxjs';
 import {map, switchMap} from 'rxjs/operators';
 import {BaseHttpDataSourceOptionsBuilder} from './BaseHttpDataSourceOptionsBuilder';
 
-export class SingleDataSourceOptionsBuilder<TQuery, TModel>
-  extends BaseHttpDataSourceOptionsBuilder<TQuery, TModel> {
+export class SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>
+  extends BaseHttpDataSourceOptionsBuilder<TModel, TKey> {
   private _beforeRead: (query: IQueryCriteria) => Observable<TQuery>;
 
+  constructor(http: HttpClient) {
+    super(http);
+  }
+
   public beforeRead(beforeRead: (query: IQueryCriteria) => Observable<TQuery>) {
     this._beforeRead = beforeRead;
     return this;
@@ -16,7 +21,7 @@ export class SingleDataSourceOptionsBuilder<TQuery, TModel>
     this._query = {
       adapter: {
         handle: (query: IQueryCriteria) => {
-          const finalBeforeRead = this._beforeRead || (() => of({} as TQuery));
+          const finalBeforeRead = this._beforeRead || ((query: IQueryCriteria) => of({} as TQuery));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {
@@ -75,7 +80,7 @@ export class SingleDataSourceOptionsBuilder<TQuery, TModel>
     this._query = {
       adapter: {
         handle: (query: TQuery) => {
-          const finalBeforeRead = this._beforeRead || (() => of({}));
+          const finalBeforeRead = this._beforeRead || (t => of({}));
           return finalBeforeRead(query)
             .pipe(
               switchMap(finalQuery => {

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

@@ -11,15 +11,15 @@ import { ListDataSourceOptionsBuilder } from "./ListDataSourceBuilder";
 export class HttpDataSourceService {
   @Inject(HttpClient) protected http!: HttpClient;
 
-  builder<TQuery, TModel>() {
-    return new HttpDataSourceOptionsBuilder<TQuery, TModel>();
+  builder<TModel, TKey>() {
+    return new HttpDataSourceOptionsBuilder<TModel, TKey>(this.http);
   }
 
-  singleBuilder<TQuery, TModel>() {
-    return new SingleDataSourceOptionsBuilder<TQuery, TModel>();
+  singleBuilder<TQuery, TModel, TKey>() {
+    return new SingleDataSourceOptionsBuilder<TQuery, TModel, TKey>(this.http);
   }
 
-  listBuilder<TQuery, TModel>() {
-    return new ListDataSourceOptionsBuilder<TQuery, TModel>();
+  listBuilder<TQuery, TModel, TKey>() {
+    return new ListDataSourceOptionsBuilder<TQuery, TModel, TKey>(this.http);
   }
 }

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

@@ -1,35 +0,0 @@
-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

@@ -12,10 +12,27 @@ import {
   IQueryExecutionGroupResult,
   IQueryExecutionResult,
   IResolveCommandModelEvent
-} from '@openharbor/data';
+} from '@poweredsoft/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'
 })
@@ -63,27 +80,29 @@ export class GenericRestDataSourceService
     });
   }
 
-  createDataSourceOptions<TQuery, TModel>(route: string, keyResolver: (model: TModel) => TModel[keyof TModel], defaultCriteria: IQueryCriteria, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceOptions<TQuery, TModel>
+  createDataSourceOptions<TModel, TKey>(route: string, keyResolver: (model: TModel) => TKey, defaultCriteria: IQueryCriteria, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceOptions<TModel>
   {
-    const dataSourceTransportOptions = this.createStandardRestTransportOptions<TQuery, TModel>(route, keyResolver, beforeRead);
+    const dataSourceTransportOptions = this.createStandardRestTransportOptions<TModel, TKey>(route, keyResolver, beforeRead);
 
-    return {
+    const dataSourceOptions: IDataSourceOptions<TModel> = {
       defaultCriteria: defaultCriteria,
       resolveIdField: keyResolver,
       transport: dataSourceTransportOptions
     };
+
+    return dataSourceOptions;
   }
 
-  setResolveCommand<TQuery, TModel>(options: IDataSourceOptions<TQuery, TModel>, name: string, resolveCommandModel: (event: IResolveCommandModelEvent<TModel>) => Observable<any>) {
+  setResolveCommand<TModel>(options: IDataSourceOptions<TModel>, name: string, resolveCommandModel: (event: IResolveCommandModelEvent<TModel>) => Observable<any>) {
     options.transport.commands[name].resolveCommandModel = resolveCommandModel;
   }
 
-  createStandardRestTransportOptions<TQuery, TModel>(route: string, keyResolver: (model: TModel) => TModel[keyof TModel], beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceTransportOptions<TQuery, TModel> {
-    const query: IDataSourceQueryAdapterOptions<TQuery, TModel> = {
+  createStandardRestTransportOptions<TModel, TKey>(route: string, keyResolver: (model: TModel) => TKey, beforeRead?: (query: IQueryCriteria) => Observable<IQueryCriteria>) : IDataSourceTransportOptions<TModel> {
+    const query: IDataSourceQueryAdapterOptions<TModel> = {
       adapter: {
         handle: (criteria: IQueryCriteria) => {
           const queryRoute = `${route}/read`;
-          const finalBeforeRead = beforeRead || (() => of(criteria));
+          const finalBeforeRead = beforeRead || (t => of(criteria));
           return finalBeforeRead(criteria)
             .pipe(switchMap(finalQuery => {
               return this.http.post<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>(queryRoute, finalQuery);

src/app/app-routing.module.ts

@@ -5,7 +5,7 @@ import { Routes, RouterModule } from '@angular/router';
 const routes: Routes = [];
 
 @NgModule({
-  imports: [RouterModule.forRoot(routes)],
+  imports: [RouterModule.forRoot(routes, { relativeLinkResolution: 'legacy' })],
   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 '@openharbor/data';
+import {IDataSource, IQueryCriteria} from '@poweredsoft/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 extends IQueryCriteria {
+export interface IOnePersonQuery {
   personId: number;
 }
 
-export interface IListPersonQuery extends IQueryCriteria {
+export interface IListPersonQuery {
   search?: string;
 }
 
@@ -45,17 +45,17 @@ export interface IListPersonQuery extends IQueryCriteria {
 })
 export class AppComponent implements OnInit {
   title = 'ngx-data';
-  dataSource: IDataSource<IMyQuery, IContact>;
+  dataSource: IDataSource<IContact>;
   latestData: any;
 
-  onePersonDs: IDataSource<IOnePersonQuery, IPerson>;
-  listPersonDs: IDataSource<IListPersonQuery, IPerson>;
+  onePersonDs: IDataSource<IPerson>;
+  listPersonDs: IDataSource<IPerson>;
   latestSingle: any;
   latestList: any;
 
   constructor(private hdss: HttpDataSourceService) {
 
-    this.onePersonDs = hdss.singleBuilder<IOnePersonQuery, IPerson>()
+    this.onePersonDs = hdss.singleBuilder<IOnePersonQuery, IPerson, number>()
       .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>()
+    this.listPersonDs = hdss.listBuilder<IListPersonQuery, IPerson, number>()
       .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<IMyQuery, IContact>()
+      .builder<IContact, number>()
       .keyResolver(m => m.id)
       .defaultCriteria({
         page: 1,

src/app/app.module.ts

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

yarn.lock

@@ -1995,18 +1995,18 @@
     proc-log "^4.0.0"
     which "^4.0.0"
 
-"@openharbor/data@^1.0.0-alpha.1":
-  version "1.0.0-alpha.1"
-  resolved "https://registry.yarnpkg.com/@openharbor/data/-/data-1.0.0-alpha.1.tgz#69c2bf7a0e1bac6e54459d0123fd006dce86553a"
-  integrity sha512-MLcfYd8ZFLxcFi13z8PnRiKLnt2Hn1FbHiXts9KBix/R8FIOSeIRZwrOFIBSrYRqk+muBvif9IGYx+uxHQlk8Q==
-  dependencies:
-    tslib "^2.3.0"
-
 "@pkgjs/parseargs@^0.11.0":
   version "0.11.0"
   resolved "https://registry.yarnpkg.com/@pkgjs/parseargs/-/parseargs-0.11.0.tgz#a77ea742fab25775145434eb1d2328cf5013ac33"
   integrity sha512-+1VkjdD0QBLPodGrJUeqarH8VAIvQODIbwh9XpP5Syisf7YoQgsJKPNFoqqLQlu+VQ/tVSshMR6loPMn8U+dPg==
 
+"@poweredsoft/data@0.0.32":
+  version "0.0.32"
+  resolved "https://registry.yarnpkg.com/@poweredsoft/data/-/data-0.0.32.tgz#61e4868d94f87a774aa367ab6f3ad7c6993254a0"
+  integrity sha512-vBsjBjKeNvjj3R0QwhBa+eKDZR3rK5lCueYUXIMU5iVFmw1UxVM3tW/0dbWmsDYnXi+/nm53Uz2MlqX9xpCStQ==
+  dependencies:
+    tslib "^1.9.0"
+
 "@rollup/plugin-json@^6.1.0":
   version "6.1.0"
   resolved "https://registry.yarnpkg.com/@rollup/plugin-json/-/plugin-json-6.1.0.tgz#fbe784e29682e9bb6dee28ea75a1a83702e7b805"