@pnpm/server - npm Package Compare versions

Comparing version 0.2.0 to 0.3.0

lib/connectStoreController.d.ts

 import { StoreController } from 'package-store';
-export default function (initOpts: {
-    port: number;
-    hostname?: string;
-}): Promise<StoreController & {
-    close: () => void;
-}>;
+export default function (initOpts: object): Promise<StoreController>;

lib/connectStoreController.js

@@ -16,3 +16,3 @@ "use strict";
     const socket = new JsonSocket(new net.Socket());
-    socket.connect(initOpts.port, initOpts.hostname || '127.0.0.1');
+    socket.connect(initOpts); // tslint:disable-line
     return new Promise((resolve, reject) => {
@@ -22,6 +22,13 @@ socket.on('connect', () => {
             socket.on('message', (message) => {
-                waiters.resolve(message.action, message.body);
+                if (message.err) {
+                    waiters.reject(message.action, message.err);
+                }
+                else {
+                    waiters.resolve(message.action, message.body);
+                }
             });
             resolve({
-                close: () => socket.end(),
+                close: () => __awaiter(this, void 0, void 0, function* () {
+                    socket.end();
+                }),
                 prune: () => __awaiter(this, void 0, void 0, function* () {
@@ -38,7 +45,2 @@ socket.sendMessage({
                 }),
-                saveStateAndClose: () => __awaiter(this, void 0, void 0, function* () {
-                    socket.sendMessage({
-                        action: 'saveStateAndClose',
-                    }, (err) => err && console.error(err));
-                }),
                 updateConnections: (prefix, opts) => __awaiter(this, void 0, void 0, function* () {
@@ -67,2 +69,7 @@ socket.sendMessage({
         },
+        reject(id, err) {
+            if (waiters[id]) {
+                waiters[id].reject(err);
+            }
+        },
     };
@@ -69,0 +76,0 @@ }

lib/createServer.d.ts

 /// <reference types="node" />
 import net = require('net');
 import { StoreController } from 'package-store';
-export default function (store: StoreController, opts: {
-    port: number;
-    hostname?: string;
-}): {
+export default function (store: StoreController, opts: object): {
     close: () => net.Server;
 };

lib/createServer.js

@@ -15,3 +15,3 @@ "use strict";
     const server = net.createServer();
-    server.listen(opts.port, opts.hostname);
+    server.listen(opts);
     server.on('connection', (socket) => {
@@ -34,4 +34,3 @@ const jsonSocket = new JsonSocket(socket);
                 }
-                case 'saveState':
-                case 'saveStateAndClose': {
+                case 'saveState': {
                     yield store.saveState();
@@ -50,3 +49,3 @@ return;
     return __awaiter(this, void 0, void 0, function* () {
-        const packageResponse = yield ctx.store.requestPackage(wantedDependency, options);
+        const packageResponse = yield ctx.store.requestPackage(wantedDependency, options); // TODO: If this fails, also return the error
         ctx.jsonSocket.sendMessage({
@@ -57,3 +56,4 @@ action: `packageResponse:${msgId}`,
         if (!packageResponse.isLocal) {
-            packageResponse.fetchingFiles.then((packageFilesResponse) => {
+            packageResponse.fetchingFiles
+                .then((packageFilesResponse) => {
                 ctx.jsonSocket.sendMessage({
@@ -63,4 +63,11 @@ action: `packageFilesResponse:${msgId}`,
                 }, (err) => err && console.error(err));
+            })
+                .catch((err) => {
+                ctx.jsonSocket.sendMessage({
+                    action: `packageFilesResponse:${msgId}`,
+                    err,
+                }, (merr) => merr && console.error(merr));
             });
-            packageResponse.fetchingManifest.then((manifestResponse) => {
+            packageResponse.fetchingManifest
+                .then((manifestResponse) => {
                 ctx.jsonSocket.sendMessage({
@@ -70,2 +77,8 @@ action: `manifestResponse:${msgId}`,
                 }, (err) => err && console.error(err));
+            })
+                .catch((err) => {
+                ctx.jsonSocket.sendMessage({
+                    action: `manifestResponse:${msgId}`,
+                    err,
+                }, (merr) => merr && console.error(merr));
             });
@@ -72,0 +85,0 @@ }

package.json

 {
   "name": "@pnpm/server",
-  "version": "0.2.0",
+  "version": "0.3.0",
   "description": "A pnpm installer server",
@@ -65,5 +65,5 @@ "main": "lib/index.js",
     "json-socket": "^0.3.0",
-    "package-store": "^0.11.0",
+    "package-store": "^0.12.0",
     "uuid": "^3.1.0"
   }
 }

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

17625

increased by6.19%

Lines of code

204

increased by6.25%

Number of medium supply chain risk alerts

2

decreased by-33.33%

Dependency changes

• + Addedpackage-store@0.12.0(transitive)

• - Removedpackage-store@0.11.0(transitive)

• Updatedpackage-store@^0.12.0