@4c/graphql-subscription-server
Advanced tools
| <a name="0.2.0"></a> | ||
| # [0.2.0](https://github.com/4Catalyzer/graphql-subscription-server/compare/v0.1.1...v0.2.0) (2018-04-18) | ||
| ### Features | ||
| * **logging:** expliclty log updates ([08c5f8f](https://github.com/4Catalyzer/graphql-subscription-server/commit/08c5f8f)) |
@@ -18,4 +18,18 @@ function _asyncIterator(iterable) { if (typeof Symbol === "function") { if (Symbol.asyncIterator) { var method = iterable[Symbol.asyncIterator]; if (method != null) return method.call(iterable); } if (Symbol.iterator) { return iterable[Symbol.iterator](); } } throw new TypeError("Object is not async iterable"); } | ||
| constructor(config) { | ||
| this.isAuthorized = data => !!(this.config.credentialsManager.isAuthenticated() && this.config.hasPermission(data, this.getCredentials())); | ||
| this.isAuthorized = data => { | ||
| const isAuthenticated = this.config.credentialsManager.isAuthenticated(); | ||
| const credentials = this.getCredentials(); | ||
| const isAuthorized = !!(isAuthenticated && this.config.hasPermission(data, credentials)); | ||
| if (!isAuthorized) { | ||
| this.log('info', 'unauthorized', { | ||
| payload: data, | ||
| isAuthenticated, | ||
| credentials | ||
| }); | ||
| } | ||
| return isAuthorized; | ||
| }; | ||
| this.handleAuthenticate = async (authorization, cb) => { | ||
@@ -123,5 +137,5 @@ try { | ||
| const payload = _value; | ||
| this.log('debug', 'processing subscription update', { | ||
| id, | ||
| payload | ||
| this.log('info', 'emit', { | ||
| payload, | ||
| credentials: this.getCredentials() | ||
| }); | ||
@@ -128,0 +142,0 @@ this.config.socket.emit('subscription update', { |
@@ -29,4 +29,18 @@ "use strict"; | ||
| constructor(config) { | ||
| this.isAuthorized = data => !!(this.config.credentialsManager.isAuthenticated() && this.config.hasPermission(data, this.getCredentials())); | ||
| this.isAuthorized = data => { | ||
| const isAuthenticated = this.config.credentialsManager.isAuthenticated(); | ||
| const credentials = this.getCredentials(); | ||
| const isAuthorized = !!(isAuthenticated && this.config.hasPermission(data, credentials)); | ||
| if (!isAuthorized) { | ||
| this.log('info', 'unauthorized', { | ||
| payload: data, | ||
| isAuthenticated, | ||
| credentials | ||
| }); | ||
| } | ||
| return isAuthorized; | ||
| }; | ||
| this.handleAuthenticate = async (authorization, cb) => { | ||
@@ -134,5 +148,5 @@ try { | ||
| const payload = _value; | ||
| this.log('debug', 'processing subscription update', { | ||
| id, | ||
| payload | ||
| this.log('info', 'emit', { | ||
| payload, | ||
| credentials: this.getCredentials() | ||
| }); | ||
@@ -139,0 +153,0 @@ this.config.socket.emit('subscription update', { |
+13
-2
| { | ||
| "name": "@4c/graphql-subscription-server", | ||
| "version": "0.1.1", | ||
| "version": "0.2.0", | ||
| "author": "4Catalyzer", | ||
@@ -46,4 +46,10 @@ "license": "MIT", | ||
| }, | ||
| "release": { | ||
| "extends": [ | ||
| "@4c/semantic-release-config" | ||
| ] | ||
| }, | ||
| "devDependencies": { | ||
| "@4c/babel-preset-4catalyzer": "^1.3.0", | ||
| "@4c/semantic-release-config": "^1.0.1", | ||
| "@babel/cli": "^7.0.0-beta.43", | ||
@@ -73,3 +79,4 @@ "@babel/core": "^7.0.0-beta.40", | ||
| "prettier": "^1.11.1", | ||
| "redis-mock": "^0.21.0" | ||
| "redis-mock": "^0.21.0", | ||
| "semantic-release": "^15.1.7" | ||
| }, | ||
@@ -83,3 +90,7 @@ "peerDependencies": { | ||
| "socket.io": "^2.1.0" | ||
| }, | ||
| "repository": { | ||
| "type": "git", | ||
| "url": "https://github.com/4Catalyzer/graphql-subscription-server.git" | ||
| } | ||
| } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
No repository
Supply chain riskPackage does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.
Found 1 instance in 1 package
75571
2.38%40
2.56%989
2.49%1
-50%28
7.69%