2.0.61

.gitea/workflows/default_nottags.yaml

@@ -0,0 +1,67 @@
+name: Default (not tags)
+
+on:
+  push:
+    tags-ignore:
+      - '**'
+
+env:
+  IMAGE: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@gitea.lossless.digital/${{gitea.repository}}.git
+  NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
+  NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
+  NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
+  NPMCI_URL_CLOUDLY: ${{secrets.NPMCI_URL_CLOUDLY}}
+
+jobs:
+
+  security:
+    runs-on: ubuntu-latest
+    continue-on-error: true
+    container:
+      image: ${{ env.IMAGE }}
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Install pnpm and npmci
+      run: |
+        pnpm install -g pnpm
+        pnpm install -g @shipzone/npmci
+
+    - name: Run npm prepare
+      run: npmci npm prepare
+
+    - name: Audit production dependencies
+      run: |
+        npmci command npm config set registry https://registry.npmjs.org
+        npmci command pnpm audit --audit-level=high --prod
+      continue-on-error: true
+
+    - name: Audit development dependencies
+      run: |
+        npmci command npm config set registry https://registry.npmjs.org
+        npmci command pnpm audit --audit-level=high --dev
+      continue-on-error: true
+
+  test:
+    if: ${{ always() }}
+    needs: security
+    runs-on: ubuntu-latest
+    container:
+      image: ${{ env.IMAGE }}
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Test stable
+      run: |
+        npmci node install stable
+        npmci npm install
+        npmci npm test
+
+    - name: Test build
+      run: |
+        npmci node install stable
+        npmci npm install
+        npmci npm build

.gitea/workflows/default_tags.yaml

@@ -0,0 +1,110 @@
+name: Default (tags)
+
+on:
+  push:
+    tags:
+      - '*'
+
+env:
+  IMAGE: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  NPMCI_COMPUTED_REPOURL: https://${{gitea.repository_owner}}:${{secrets.GITEA_TOKEN}}@gitea.lossless.digital/${{gitea.repository}}.git
+  NPMCI_TOKEN_NPM: ${{secrets.NPMCI_TOKEN_NPM}}
+  NPMCI_TOKEN_NPM2: ${{secrets.NPMCI_TOKEN_NPM2}}
+  NPMCI_GIT_GITHUBTOKEN: ${{secrets.NPMCI_GIT_GITHUBTOKEN}}
+  NPMCI_URL_CLOUDLY: ${{secrets.NPMCI_URL_CLOUDLY}}
+
+jobs:
+
+  security:
+    runs-on: ubuntu-latest
+    continue-on-error: true
+    container:
+      image: ${{ env.IMAGE }}
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Install pnpm and npmci
+      run: |
+        pnpm install -g pnpm
+        pnpm install -g @shipzone/npmci
+
+    - name: Run npm prepare
+      run: npmci npm prepare
+
+    - name: Audit production dependencies
+      run: |
+        npmci command npm config set registry https://registry.npmjs.org
+        npmci command pnpm audit --audit-level=high --prod
+      continue-on-error: true
+
+    - name: Audit development dependencies
+      run: |
+        npmci command npm config set registry https://registry.npmjs.org
+        npmci command pnpm audit --audit-level=high --dev
+      continue-on-error: true
+
+  test:
+    if: ${{ always() }}
+    needs: security
+    runs-on: ubuntu-latest
+    container:
+      image: ${{ env.IMAGE }}
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Test stable
+      run: |
+        npmci node install stable
+        npmci npm install
+        npmci npm test
+
+    - name: Test build
+      run: |
+        npmci node install stable
+        npmci npm install
+        npmci npm build
+
+  release:
+    needs: test
+    if: github.event_name == 'push' && startsWith(github.ref, 'refs/tags/')
+    runs-on: ubuntu-latest
+    container:
+      image: ${{ env.IMAGE }}
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Release
+      run: |
+        npmci node install stable
+        npmci npm publish
+
+  metadata:
+    needs: test
+    if: github.event_name == 'push' && startsWith(github.ref, 'refs/tags/')
+    runs-on: ubuntu-latest
+    container:
+      image: ${{ env.IMAGE }}
+    continue-on-error: true
+
+    steps:
+    - uses: actions/checkout@v3
+
+    - name: Code quality
+      run: |
+        npmci command npm install -g typescript
+        npmci npm prepare
+        npmci npm install
+
+    - name: Trigger
+      run: npmci trigger
+
+    - name: Build docs and upload artifacts
+      run: |
+        npmci node install stable
+        npmci npm install
+        pnpm install -g @gitzone/tsdoc
+        npmci command tsdoc
+      continue-on-error: true

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apiglobal/typedserver",
-  "version": "2.0.49",
+  "version": "2.0.61",
   "description": "easy serving of static files",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
@@ -39,39 +39,40 @@
   "dependencies": {
     "@apiglobal/typedrequest": "^2.0.12",
     "@apiglobal/typedrequest-interfaces": "^2.0.1",
-    "@apiglobal/typedsocket": "^2.0.23",
+    "@apiglobal/typedsocket": "^2.0.24",
     "@pushrocks/lik": "^6.0.2",
     "@pushrocks/smartchok": "^1.0.23",
-    "@pushrocks/smartdelay": "^2.0.13",
+    "@pushrocks/smartdelay": "^3.0.1",
     "@pushrocks/smartenv": "^5.0.5",
     "@pushrocks/smartfeed": "^1.0.11",
-    "@pushrocks/smartfile": "^10.0.7",
-    "@pushrocks/smartlog": "^3.0.1",
+    "@pushrocks/smartfile": "^10.0.25",
+    "@pushrocks/smartlog": "^3.0.2",
     "@pushrocks/smartlog-destination-devtools": "^1.0.10",
-    "@pushrocks/smartmanifest": "^1.0.8",
+    "@pushrocks/smartmanifest": "^2.0.2",
     "@pushrocks/smartmime": "^1.0.5",
     "@pushrocks/smartopen": "^2.0.0",
     "@pushrocks/smartpath": "^5.0.5",
-    "@pushrocks/smartpromise": "^3.1.7",
-    "@pushrocks/smartrequest": "^2.0.11",
-    "@pushrocks/smartrx": "^3.0.0",
+    "@pushrocks/smartpromise": "^4.0.2",
+    "@pushrocks/smartrequest": "^2.0.15",
+    "@pushrocks/smartrx": "^3.0.2",
     "@pushrocks/smartsitemap": "^2.0.1",
     "@pushrocks/smarttime": "^4.0.1",
-    "@pushrocks/webstore": "^2.0.5",
-    "@tsclass/tsclass": "^4.0.34",
+    "@pushrocks/webstore": "^2.0.8",
+    "@tsclass/tsclass": "^4.0.42",
+    "@types/express": "^4.17.17",
     "body-parser": "^1.20.2",
     "cors": "^2.8.5",
     "express": "^4.18.2",
     "express-force-ssl": "^0.3.2",
-    "lit": "^2.7.0"
+    "lit": "^2.7.5"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.63",
-    "@gitzone/tsbundle": "^2.0.6",
-    "@gitzone/tsrun": "^1.2.39",
-    "@gitzone/tstest": "^1.0.72",
-    "@pushrocks/tapbundle": "^5.0.4",
-    "@types/node": "^18.15.11"
+    "@gitzone/tsbuild": "^2.1.66",
+    "@gitzone/tsbundle": "^2.0.8",
+    "@gitzone/tsrun": "^1.2.42",
+    "@gitzone/tstest": "^1.0.74",
+    "@pushrocks/tapbundle": "^5.0.8",
+    "@types/node": "^20.3.3"
   },
   "private": false,
   "browserslist": [

readme.md

@@ -1,4 +1,4 @@
-# @apiglobal/typedserver
+# @pushrocks/typedserver
 easy serving of static files
 
 ## Availabililty and Links

test/test.server.ts

@@ -64,7 +64,9 @@ tap.test('should add handler to route', async () => {
 
 tap.test('should create a valid StaticHandler', async () => {
   testRoute2.addHandler(
-    new typedserver.servertools.HandlerStatic(smartpath.get.dirnameFromImportMetaUrl(import.meta.url))
+    new typedserver.servertools.HandlerStatic(
+      smartpath.get.dirnameFromImportMetaUrl(import.meta.url)
+    )
   );
 });
 

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@apiglobal/typedserver',
-  version: '2.0.49',
+  version: '2.0.61',
   description: 'easy serving of static files'
 }

ts/index.ts

@@ -2,9 +2,7 @@ import * as plugins from './typedserver.plugins.js';
 
 import * as servertools from './servertools/index.js';
 
-export {
-  servertools
-}
+export { servertools };
 
 export * from './typedserver.classes.typedserver.js';
 // Type helpers

ts/interfaces/typedrequests.ts

@@ -1,23 +1,25 @@
 import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
 
-export interface IReq_PushLatestServerChangeTime extends typedrequestInterfaces.implementsTR<
-  typedrequestInterfaces.ITypedRequest,
-  IReq_PushLatestServerChangeTime
-> {
-  method: 'pushLatestServerChangeTime',
+export interface IReq_PushLatestServerChangeTime
+  extends typedrequestInterfaces.implementsTR<
+    typedrequestInterfaces.ITypedRequest,
+    IReq_PushLatestServerChangeTime
+  > {
+  method: 'pushLatestServerChangeTime';
   request: {
     time: number;
   };
-  response: {}
+  response: {};
 }
 
-export interface IReq_GetLatestServerChangeTime extends typedrequestInterfaces.implementsTR<
-  typedrequestInterfaces.ITypedRequest,
-  IReq_GetLatestServerChangeTime
-> {
-  method: 'getLatestServerChangeTime',
+export interface IReq_GetLatestServerChangeTime
+  extends typedrequestInterfaces.implementsTR<
+    typedrequestInterfaces.ITypedRequest,
+    IReq_GetLatestServerChangeTime
+  > {
+  method: 'getLatestServerChangeTime';
   request: {};
   response: {
     time: number;
-  }
+  };
 }

ts/servertools/classes.handler.ts

@@ -1,5 +1,5 @@
 import * as plugins from '../typedserver.plugins.js';
-import { Request, Response } from 'express';
+import { type Request, type Response } from 'express';
 
 export interface IHandlerFunction {
   (requestArg: Request, responseArg: Response): void;

ts/servertools/classes.route.ts

@@ -3,7 +3,7 @@ import { Handler } from './classes.handler.js';
 import { Server } from './classes.server.js';
 
 import { ObjectMap } from '@pushrocks/lik';
-import { IRoute as IExpressRoute } from 'express';
+import { type IRoute as IExpressRoute } from 'express';
 
 export class Route {
   public routeString: string;

ts/servertools/classes.server.ts

@@ -9,7 +9,7 @@ import { setupRobots } from './tools.robots.js';
 import { setupManifest } from './tools.manifest.js';
 import { Sitemap } from './classes.sitemap.js';
 import { Feed } from './classes.feed.js';
-import { IServerOptions } from '../typedserver.classes.typedserver.js'
+import { type IServerOptions } from '../typedserver.classes.typedserver.js';
 export type TServerStatus = 'initiated' | 'running' | 'stopped';
 
 /**
@@ -101,16 +101,10 @@ export class Server {
       console.log('Using externally supplied http server');
     }
     this.httpServer.keepAliveTimeout = 600 * 1000;
-    this.httpServer.headersTimeout = 600 * 1000;
+    this.httpServer.headersTimeout = 20 * 1000;
 
     // general request handlling
     this.expressAppInstance.use((req, res, next) => {
-      req.on('error', () => {
-        req.destroy();
-      });
-      req.on('timeout', () => {
-        req.destroy();
-      });
       next();
     });
 
@@ -224,25 +218,24 @@ export class Server {
     this.httpServer.on('connection', (connection: plugins.net.Socket) => {
       this.socketMap.add(connection);
       console.log(`added connection. now ${this.socketMap.getArray().length} sockets connected.`);
+      const cleanListener = () => {
+        cleanupConnection();
+      }
       const cleanupConnection = () => {
+        connection.removeListener('close', cleanListener);
+        connection.removeListener('error', cleanListener);
+        connection.removeListener('end', cleanListener);
+        connection.removeListener('timeout', cleanListener);
         if (this.socketMap.checkForObject(connection)) {
           this.socketMap.remove(connection);
           console.log(`removed connection. ${this.socketMap.getArray().length} sockets remaining.`);
           connection.destroy();
         }
       };
-      connection.on('close', () => {
-        cleanupConnection();
-      });
-      connection.on('error', () => {
-        cleanupConnection();
-      });
-      connection.on('end', () => {
-        cleanupConnection();
-      });
-      connection.on('timeout', () => {
-        cleanupConnection();
-      });
+      connection.addListener('close', cleanListener);
+      connection.addListener('error', cleanListener);
+      connection.addListener('end', cleanListener);
+      connection.addListener('timeout', cleanListener);
     });
 
     // finally listen on a port

ts/servertools/classes.sitemap.ts

@@ -1,7 +1,7 @@
 import { Server } from './classes.server.js';
 import { Handler } from './classes.handler.js';
 import * as plugins from '../typedserver.plugins.js';
-import { IUrlInfo } from '@pushrocks/smartsitemap';
+import { type IUrlInfo } from '@pushrocks/smartsitemap';
 
 export class Sitemap {
   public smartexpressRef: Server;

ts/typedserver.classes.typedserver.ts

@@ -115,7 +115,7 @@ export class TypedServer {
    * inits and starts the server
    */
   public async start() {
-    if(this.options.serveDir) {
+    if (this.options.serveDir) {
       this.server.addRoute(
         '/*',
         new servertools.HandlerStatic(this.options.serveDir, {
@@ -129,7 +129,7 @@ export class TypedServer {
                   <script async defer type="module" src="/typedserver/devtools"></script>
                   <script>
                     globalThis.typedserver = {
-                      lastReload: '${this.lastReload}',
+                      lastReload: ${this.lastReload},
                       versionInfo: ${JSON.stringify({}, null, 2)},
                     }
                   </script>
@@ -156,7 +156,9 @@ export class TypedServer {
         })
       );
     } else if (this.options.injectReload) {
-      throw new Error('You set to inject the reload script without a serve dir. This is not supported at the moment.')
+      throw new Error(
+        'You set to inject the reload script without a serve dir. This is not supported at the moment.'
+      );
     }
     if (this.options.watch && this.options.serveDir) {
       this.smartchokInstance = new plugins.smartchok.Smartchok([this.options.serveDir], {});
@@ -177,11 +179,13 @@ export class TypedServer {
     );
 
     // lets setup typedrouter
-    this.typedrouter.addTypedHandler<interfaces.IReq_GetLatestServerChangeTime>(new plugins.typedrequest.TypedHandler('getLatestServerChangeTime', async reqDataArg => {
-      return {
-        time: this.lastReload,
-      }
-    }))
+    this.typedrouter.addTypedHandler<interfaces.IReq_GetLatestServerChangeTime>(
+      new plugins.typedrequest.TypedHandler('getLatestServerChangeTime', async (reqDataArg) => {
+        return {
+          time: this.lastReload,
+        };
+      })
+    );
 
     // console.log('open url in browser');
     // await plugins.smartopen.openUrl(`http://testing.git.zone:${this.options.port}`);
@@ -192,7 +196,9 @@ export class TypedServer {
    */
   public async reload() {
     this.lastReload = Date.now();
-    for (const connectionArg of await this.typedsocket.findAllTargetConnections(async () => true)) {
+    for (const connectionArg of await this.typedsocket.findAllTargetConnectionsByTag(
+      'typedserver_frontend'
+    )) {
       const pushTime =
         this.typedsocket.createTypedRequest<interfaces.IReq_PushLatestServerChangeTime>(
           'pushLatestServerChangeTime',

ts/typedserver.plugins.ts

@@ -9,20 +9,14 @@ export { http, https, net, path };
 // @tsclass scope
 import * as tsclass from '@tsclass/tsclass';
 
-export {
-  tsclass
-}
+export { tsclass };
 
 // @apiglobal scope
 import * as typedrequest from '@apiglobal/typedrequest';
 import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
 import * as typedsocket from '@apiglobal/typedsocket';
 
-export {
-  typedrequest,
-  typedrequestInterfaces,
-  typedsocket,
-}
+export { typedrequest, typedrequestInterfaces, typedsocket };
 
 // @pushrocks scope
 import * as lik from '@pushrocks/lik';

ts_web/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@apiglobal/typedserver',
-  version: '2.0.49',
+  version: '2.0.61',
   description: 'easy serving of static files'
 }

ts_web/index.ts

@@ -61,7 +61,11 @@ export class ReloadChecker {
 
   public async checkReload(lastServerChange: number) {
     let reloadJustified = false;
-    (await this.store.get(this.storeKey)) !== lastServerChange ? (reloadJustified = true) : null;
+    let storedLastServerChange = await this.store.get(this.storeKey);
+    if (storedLastServerChange && storedLastServerChange !== lastServerChange) {
+      reloadJustified = true;
+    } else {
+    }
 
     if (reloadJustified) {
       this.store.set(this.storeKey, lastServerChange);
@@ -98,22 +102,29 @@ export class ReloadChecker {
         this.typedrouter,
         plugins.typedsocket.TypedSocket.useWindowLocationOriginUrl()
       );
-      this.typedsocket.eventSubject.subscribe(async eventArg => {
+      this.typedsocket.addTag('typedserver_frontend', {});
+      this.typedsocket.eventSubject.subscribe(async (eventArg) => {
         console.log(`typedsocket event subscription: ${eventArg}`);
-        if (eventArg === 'disconnected' || eventArg === 'disconnecting' || eventArg === 'timedOut') {
+        if (
+          eventArg === 'disconnected' ||
+          eventArg === 'disconnecting' ||
+          eventArg === 'timedOut'
+        ) {
           this.backendConnectionLost = true;
-          this.infoscreen.setText(`typedsocket ${eventArg}!`)
+          this.infoscreen.setText(`typedsocket ${eventArg}!`);
         } else if (eventArg === 'connected' && this.backendConnectionLost) {
           this.backendConnectionLost = false;
           this.infoscreen.setSuccess('typedsocket connected!');
           // lets check if a reload is necessary
-          const getLatestServerChangeTime = this.typedsocket.createTypedRequest<interfaces.IReq_GetLatestServerChangeTime>('getLatestServerChangeTime');
+          const getLatestServerChangeTime =
+            this.typedsocket.createTypedRequest<interfaces.IReq_GetLatestServerChangeTime>(
+              'getLatestServerChangeTime'
+            );
           const response = await getLatestServerChangeTime.fire({});
           this.checkReload(response.time);
         }
-
       });
-      logger.log('success', `ReloadChecker connected through typedsocket!`)
+      logger.log('success', `ReloadChecker connected through typedsocket!`);
     }
   }