fix(core): update

.gitlab-ci.yml

@@ -12,6 +12,9 @@ stages:
   - release
   - metadata
 
+before_script:
+  - npm install -g @shipzone/npmci
+
 # ====================
 # security stage
 # ====================
@@ -38,7 +41,6 @@ auditProductionDependencies:
     - docker
   allow_failure: true
 
-
 auditDevDependencies:
   image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
   stage: security
@@ -98,10 +100,9 @@ codequality:
   only:
     - tags
   script:
-    - npmci command npm install -g tslint typescript
+    - npmci command npm install -g typescript
     - npmci npm prepare
     - npmci npm install
-    - npmci command "tslint -c tslint.json ./ts/**/*.ts"
   tags:
     - lossless
     - docker

.vscode/launch.json

@@ -2,28 +2,10 @@
   "version": "0.2.0",
   "configurations": [
     {
-      "name": "current file",
-      "type": "node",
+      "command": "npm test",
+      "name": "Run npm test",
       "request": "launch",
-      "args": [
-        "${relativeFile}"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
-    },
-    {
-      "name": "test.ts",
-      "type": "node",
-      "request": "launch",
-      "args": [
-        "test/test.ts"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
+      "type": "node-terminal"
     }
   ]
 }

npmextra.json

@@ -8,7 +8,7 @@
       "githost": "gitlab.com",
       "gitscope": "pushrocks",
       "gitrepo": "smartbucket",
-      "shortDescription": "simple cloud independent object storage",
+      "description": "simple cloud independent object storage",
       "npmPackagename": "@pushrocks/smartbucket",
       "license": "MIT"
     }

package.json

@@ -4,28 +4,27 @@
   "description": "simple cloud independent object storage",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
+  "type": "module",
   "author": "Lossless GmbH",
   "license": "UNLICENSED",
   "scripts": {
     "test": "(tstest test/)",
-    "format": "(gitzone format)",
     "build": "(tsbuild --web)"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.28",
-    "@gitzone/tstest": "^1.0.60",
-    "@pushrocks/tapbundle": "^3.2.15",
-    "tslint": "^6.1.3",
-    "tslint-config-prettier": "^1.18.0"
+    "@gitzone/tsbuild": "^2.1.61",
+    "@gitzone/tstest": "^1.0.70",
+    "@pushrocks/tapbundle": "^5.0.3"
   },
   "dependencies": {
     "@pushrocks/qenv": "^4.0.10",
-    "@pushrocks/smartpath": "^4.0.3",
-    "@pushrocks/smartpromise": "^3.1.6",
-    "@pushrocks/smartrx": "^2.0.19",
-    "@pushrocks/streamfunction": "^2.0.1",
-    "@types/minio": "^7.0.11",
-    "minio": "^7.0.25"
+    "@pushrocks/smartpath": "^5.0.5",
+    "@pushrocks/smartpromise": "^3.1.7",
+    "@pushrocks/smartrx": "^2.0.25",
+    "@pushrocks/smartstream": "^2.0.1",
+    "@pushrocks/streamfunction": "^3.0.4",
+    "@types/minio": "^7.0.12",
+    "minio": "^7.0.26"
   },
   "private": false,
   "files": [
@@ -43,4 +42,4 @@
   "browserslist": [
     "last 1 chrome versions"
   ]
-}
+}

test/test.ts

@@ -1,7 +1,7 @@
-import { expect, tap } from '@pushrocks/tapbundle';
+import { expect, expectAsync, tap } from '@pushrocks/tapbundle';
 import { Qenv } from '@pushrocks/qenv';
 
-import * as smartbucket from '../ts/index';
+import * as smartbucket from '../ts/index.js';
 
 const testQenv = new Qenv('./', './.nogit/');
 
@@ -27,8 +27,8 @@ tap.skip.test('should remove testbucket', async () => {
 
 tap.test('should get a bucket', async () => {
   myBucket = await testSmartbucket.getBucketByName('testzone');
-  expect(myBucket).to.be.instanceOf(smartbucket.Bucket);
-  expect(myBucket.name).to.equal('testzone');
+  expect(myBucket).toBeInstanceOf(smartbucket.Bucket);
+  expect(myBucket.name).toEqual('testzone');
 });
 
 // Fast operations
@@ -62,16 +62,16 @@ tap.test('should get base directory', async () => {
   const directories = await baseDirectory.listDirectories();
   console.log('Found the following directories:');
   console.log(directories);
-  expect(directories.length).to.equal(3);
+  expect(directories.length).toEqual(3);
   const files = await baseDirectory.listFiles();
   console.log('Found the following files:');
   console.log(files);
-  expect(files.length).to.equal(1);
+  expect(files.length).toEqual(1);
 });
 
 tap.test('should correctly build paths for sub directories', async () => {
   const dir4 = await baseDirectory.getSubDirectoryByName('dir3/dir4');
-  expect(dir4).to.be.instanceOf(smartbucket.Directory);
+  expect(dir4).toBeInstanceOf(smartbucket.Directory);
   const dir4BasePath = dir4.getBasePath();
   console.log(dir4BasePath);
 });

ts/index.ts

@@ -1,4 +1,4 @@
-export * from './smartbucket.classes.smartbucket';
-export * from './smartbucket.classes.bucket';
-export * from './smartbucket.classes.directory';
-export * from './smartbucket.classes.file';
+export * from './smartbucket.classes.smartbucket.js';
+export * from './smartbucket.classes.bucket.js';
+export * from './smartbucket.classes.directory.js';
+export * from './smartbucket.classes.file.js';

ts/smartbucket.classes.bucket.ts

@@ -1,7 +1,6 @@
-import * as plugins from './smartbucket.plugins';
-import { SmartBucket } from './smartbucket.classes.smartbucket';
-import { Directory } from './smartbucket.classes.directory';
-import { Observable } from 'rxjs';
+import * as plugins from './smartbucket.plugins.js';
+import { SmartBucket } from './smartbucket.classes.smartbucket.js';
+import { Directory } from './smartbucket.classes.directory.js';
 
 export class Bucket {
   public static async getBucketByName(smartbucketRef: SmartBucket, bucketNameArg: string) {
@@ -107,7 +106,12 @@ export class Bucket {
       return null;
     }
 
-    fileStream.pipe(duplexStream);
+    const smartstream = new plugins.smartstream.Smartstream([
+      fileStream,
+      duplexStream,
+      plugins.smartstream.cleanPipe(),
+    ]);
+    smartstream.run();
     return replaySubject;
   }
 

ts/smartbucket.classes.directory.ts

@@ -1,6 +1,6 @@
-import * as plugins from './smartbucket.plugins';
-import { Bucket } from './smartbucket.classes.bucket';
-import { File } from './smartbucket.classes.file';
+import * as plugins from './smartbucket.plugins.js';
+import { Bucket } from './smartbucket.classes.bucket.js';
+import { File } from './smartbucket.classes.file.js';
 
 export class Directory {
   public bucketRef: Bucket;
@@ -169,7 +169,7 @@ export class Directory {
    */
   public async move() {
     // TODO
-    throw new Error('moving a directory is not yet implemented')
+    throw new Error('moving a directory is not yet implemented');
   }
 
   /**

ts/smartbucket.classes.file.ts

@@ -1,5 +1,5 @@
-import * as plugins from './smartbucket.plugins';
-import { Directory } from './smartbucket.classes.directory';
+import * as plugins from './smartbucket.plugins.js';
+import { Directory } from './smartbucket.classes.directory.js';
 
 export interface IFileMetaData {
   name: string;

ts/smartbucket.classes.smartbucket.ts

@@ -1,5 +1,5 @@
-import * as plugins from './smartbucket.plugins';
-import { Bucket } from './smartbucket.classes.bucket';
+import * as plugins from './smartbucket.plugins.js';
+import { Bucket } from './smartbucket.classes.bucket.js';
 
 export interface ISmartBucketConfig {
   endpoint: string;

ts/smartbucket.plugins.ts

@@ -7,8 +7,9 @@ import * as smartpath from '@pushrocks/smartpath';
 import * as smartpromise from '@pushrocks/smartpromise';
 import * as smartrx from '@pushrocks/smartrx';
 import * as streamfunction from '@pushrocks/streamfunction';
+import * as smartstream from '@pushrocks/smartstream';
 
-export { smartpath, smartpromise, smartrx, streamfunction };
+export { smartpath, smartpromise, smartrx, streamfunction, smartstream };
 
 // third party scope
 import * as minio from 'minio';

tsconfig.json

@@ -0,0 +1,9 @@
+{
+  "compilerOptions": {
+    "experimentalDecorators": true,
+    "useDefineForClassFields": false,
+    "target": "ES2022",
+    "module": "ES2022",
+    "moduleResolution": "nodenext"
+  }
+}

tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": ["tslint:latest", "tslint-config-prettier"],
-  "rules": {
-    "semicolon": [true, "always"],
-    "no-console": false,
-    "ordered-imports": false,
-    "object-literal-sort-keys": false,
-    "member-ordering": {
-      "options":{
-        "order": [
-          "static-method"
-        ]
-      }
-    }
-  },
-  "defaultSeverity": "warning"
-}