@pnpm/server - npm Package Compare versions

Comparing version 0.1.0 to 0.2.0

lib/createServer.d.ts

 /// <reference types="node" />
-import { RequestPackageFunction } from '@pnpm/package-requester';
 import net = require('net');
-export default function (requestPackage: RequestPackageFunction, opts: {
+import { StoreController } from 'package-store';
+export default function (store: StoreController, opts: {
     port: number;
@@ -6,0 +6,0 @@ hostname?: string;

lib/createServer.js

@@ -13,3 +13,3 @@ "use strict";
 const net = require("net");
-function default_1(requestPackage, opts) {
+function default_1(store, opts) {
     const server = net.createServer();
@@ -19,21 +19,22 @@ server.listen(opts.port, opts.hostname);
         const jsonSocket = new JsonSocket(socket);
+        const requestPackage = requestPackageWithCtx.bind(null, { jsonSocket, store });
         jsonSocket.on('message', (message) => __awaiter(this, void 0, void 0, function* () {
-            const packageResponse = yield requestPackage(message.wantedDependency, message.options);
-            jsonSocket.sendMessage({
-                action: `packageResponse:${message.msgId}`,
-                body: packageResponse,
-            }, (err) => err && console.error(err));
-            if (!packageResponse.isLocal) {
-                packageResponse.fetchingFiles.then((packageFilesResponse) => {
-                    jsonSocket.sendMessage({
-                        action: `packageFilesResponse:${message.msgId}`,
-                        body: packageFilesResponse,
-                    }, (err) => err && console.error(err));
-                });
-                packageResponse.fetchingManifest.then((manifestResponse) => {
-                    jsonSocket.sendMessage({
-                        action: `manifestResponse:${message.msgId}`,
-                        body: manifestResponse,
-                    }, (err) => err && console.error(err));
-                });
+            switch (message.action) {
+                case 'requestPackage': {
+                    yield requestPackage(message.msgId, message.args[0], message.args[1]);
+                    return;
+                }
+                case 'prune': {
+                    yield store.prune();
+                    return;
+                }
+                case 'updateConnections': {
+                    yield store.updateConnections(message.args[0], message.args[1]);
+                    return;
+                }
+                case 'saveState':
+                case 'saveStateAndClose': {
+                    yield store.saveState();
+                    return;
+                }
             }
@@ -47,2 +48,25 @@ }));
 exports.default = default_1;
+function requestPackageWithCtx(ctx, msgId, wantedDependency, options) {
+    return __awaiter(this, void 0, void 0, function* () {
+        const packageResponse = yield ctx.store.requestPackage(wantedDependency, options);
+        ctx.jsonSocket.sendMessage({
+            action: `packageResponse:${msgId}`,
+            body: packageResponse,
+        }, (err) => err && console.error(err));
+        if (!packageResponse.isLocal) {
+            packageResponse.fetchingFiles.then((packageFilesResponse) => {
+                ctx.jsonSocket.sendMessage({
+                    action: `packageFilesResponse:${msgId}`,
+                    body: packageFilesResponse,
+                }, (err) => err && console.error(err));
+            });
+            packageResponse.fetchingManifest.then((manifestResponse) => {
+                ctx.jsonSocket.sendMessage({
+                    action: `manifestResponse:${msgId}`,
+                    body: manifestResponse,
+                }, (err) => err && console.error(err));
+            });
+        }
+    });
+}
 //# sourceMappingURL=createServer.js.map

lib/index.d.ts

@@ -1,3 +0,3 @@
-import connectPackageRequester from './connectPackageRequester';
+import connectStoreController from './connectStoreController';
 import createServer from './createServer';
-export { createServer, connectPackageRequester };
+export { createServer, connectStoreController };

lib/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-const connectPackageRequester_1 = require("./connectPackageRequester");
-exports.connectPackageRequester = connectPackageRequester_1.default;
+const connectStoreController_1 = require("./connectStoreController");
+exports.connectStoreController = connectStoreController_1.default;
 const createServer_1 = require("./createServer");
 exports.createServer = createServer_1.default;
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@pnpm/server",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "A pnpm installer server",
@@ -16,3 +16,3 @@ "main": "lib/index.js",
     "tsc": "rimraf lib && tsc",
-    "test": "rimraf .store && npm run lint && preview && ts-node test && mos t",
+    "test": "rimraf .store && npm run lint && preview && ts-node test --type-check && mos t",
     "md": "mos",
@@ -48,3 +48,3 @@ "prepublishOnly": "npm run tsc"
     "tape": "^4.8.0",
-    "ts-node": "^3.3.0",
+    "ts-node": "^4.0.1",
     "tslint": "^5.8.0",
@@ -62,3 +62,3 @@ "typescript": "^2.6.1"
   "dependencies": {
-    "@pnpm/package-requester": "^0.4.0",
+    "@pnpm/package-requester": "^0.5.0",
     "@types/json-socket": "^0.1.17",
@@ -68,4 +68,5 @@ "@types/node": "^8.0.57",
     "json-socket": "^0.3.0",
+    "package-store": "^0.11.0",
     "uuid": "^3.1.0"
   }
 }

New 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

16597

increased by32.25%

Lines of code

192

increased by39.13%

Worsened metrics

Dependency count

8

increased by14.29%

Number of medium supply chain risk alerts

3

increased by50%

Dependency changes

• + Addedpackage-store@^0.11.0

• + Added@pnpm/check-package@1.0.0(transitive)

• + Added@pnpm/fs-locker@1.0.3(transitive)

• + Added@pnpm/package-requester@0.5.1(transitive)

• + Added@pnpm/pkgid-to-filename@1.0.1(transitive)

• + Addednormalize-path@3.0.0(transitive)

• + Addedp-filter@1.0.0(transitive)

• + Addedpackage-store@0.11.0(transitive)

• + Addedproper-lockfile@2.0.1(transitive)

• + Addedretry@0.10.1(transitive)

• + Addedunpack-stream@3.0.3(transitive)

• - Removed@pnpm/package-requester@0.4.0(transitive)

• - Removednormalize-path@2.1.1(transitive)

• - Removedpackage-store@0.10.1(transitive)

• - Removedremove-trailing-separator@1.1.0(transitive)

• - Removedunpack-stream@2.2.0(transitive)

• Updated@pnpm/package-requester@^0.5.0