CHANGELOG.md

 
+<a name="v3.1.2"></a>
+## [v3.1.2] - 2023-01-06
+### Bug Fixes
+- check read/write call
+- check socket state
+
+
 <a name="v3.1.1"></a>
 ## [v3.1.1] - 2023-01-06
 ### Bug Fixes
@@ -136,6 +143,7 @@
 <a name="1.8.0"></a>
 ## 1.8.0 - 2021-08-15
 
+[v3.1.2]: https://gitlab.schukai.com/oss/libraries/javascript/monster/compare/v3.1.1...v3.1.2
 [v3.1.1]: https://gitlab.schukai.com/oss/libraries/javascript/monster/compare/v3.1.0...v3.1.1
 [v3.1.0]: https://gitlab.schukai.com/oss/libraries/javascript/monster/compare/v3.0.0...v3.1.0
 [v3.0.0]: https://gitlab.schukai.com/oss/libraries/javascript/monster/compare/v2.2.1...v3.0.0

application/package.json

 {
   "name": "@schukai/monster",
-  "version": "3.1.0",
+  "version": "3.1.1",
   "description": "Monster is a simple library for creating fast, robust and lightweight websites.",
   "keywords": [
     "framework",

application/source/data/datasource/websocket.mjs

@@ -231,14 +231,15 @@ class WebSocketDatasource extends Datasource {
 
     /**
      * @return {Promise}
-     * @throws {Error} the options does not contain a valid json definition
-     * @throws {Error} the data cannot be read
-     * @throws {TypeError} value is not an object
      */
     read() {
         const self = this;
         let response;
 
+        if (self[connectionSymbol]?.socket?.readyState!==1) {
+            return Promise.reject('The connection is not established.');
+        }        
+
         return new Promise((resolve, reject) => {
             if (self[receiveQueueSymbol].isEmpty()) {
                 resolve();
@@ -291,6 +292,10 @@ class WebSocketDatasource extends Datasource {
     write() {
         const self = this;
         
+        if (self[connectionSymbol]?.socket?.readyState!==1) {
+            return Promise.reject('The connection is not established.');
+        }
+
         let obj = self.get();
         let transformation = self.getOption('write.mapping.transformer');
         if (transformation !== undefined) {

application/source/types/version.mjs

@@ -149,7 +149,7 @@ function getMonsterVersion() {
     }
 
     /** don't touch, replaced by make with package.json version */
-    monsterVersion = new Version('3.1.0')
+    monsterVersion = new Version('3.1.1')
 
     return monsterVersion;
 

development/package.json

 {
   "name": "monster",
-  "version": "3.1.0",
+  "version": "3.1.1",
   "description": "monster",
   "repository": {
     "type": "git",

development/test/cases/data/datasource/websocket.mjs

@@ -98,7 +98,8 @@ describe('Websocket', function () {
             }).catch((err) => {
                 done(new Error(err));
             })
-        }, 1000)
+        }, 
+            500)
 
 
     }).timeout(10000);

development/test/cases/monster.mjs

@@ -7,7 +7,7 @@ describe('Monster', function () {
         let monsterVersion
 
         /** don´t touch, replaced by make with package.json version */
-        monsterVersion = new Version('3.1.0')
+        monsterVersion = new Version('3.1.1')
 
         let m = getMonsterVersion();
 

release.json

-{"version":"3.1.1"}
+{"version":"3.1.2"}