@hocuspocus/extension-rocksdb - npm Package Compare versions

Comparing version 1.0.0-alpha.67 to 1.0.0-alpha.68

CHANGELOG.md

@@ -6,2 +6,10 @@ # Change Log
 
+# [1.0.0-alpha.68](https://github.com/ueberdosis/hocuspocus/compare/@hocuspocus/extension-rocksdb@1.0.0-alpha.67...@hocuspocus/extension-rocksdb@1.0.0-alpha.68) (2021-08-31)
+
+**Note:** Version bump only for package @hocuspocus/extension-rocksdb
+
+
+
+
+
 # [1.0.0-alpha.67](https://github.com/ueberdosis/hocuspocus/compare/@hocuspocus/extension-rocksdb@1.0.0-alpha.66...@hocuspocus/extension-rocksdb@1.0.0-alpha.67) (2021-08-29)
@@ -8,0 +16,0 @@

dist/packages/server/src/CloseEvents.d.ts

 import { CloseEvent } from './types';
 export declare const Forbidden: CloseEvent;
+export declare const ResetConnection: CloseEvent;
 export declare const CloseEvents: CloseEvent[];

dist/packages/server/src/Connection.d.ts

@@ -6,4 +6,6 @@ /// <reference types="node" />
 import Document from './Document';
+import { CloseEvent } from './types';
+import { MessageLogger } from './Debugger';
 declare class Connection {
-    connection: WebSocket;
+    webSocket: WebSocket;
     context: any;
@@ -19,2 +21,3 @@ document: Document;
     readOnly: Boolean;
+    debugger: MessageLogger;
     /**
@@ -33,5 +36,5 @@ * Constructor.
     /**
-     * Close the connection
+     * Graceful wrapper around the WebSocket close method.
      */
-    close(): void;
+    close(event?: CloseEvent): void;
     /**
@@ -54,5 +57,11 @@ * Check if pong was received and close the connection otherwise
      * Get the underlying connection instance
+     * @deprecated
      */
     get instance(): WebSocket;
+    /**
+     * Get the underlying connection instance
+     * @deprecated
+     */
+    get connection(): WebSocket;
 }
 export default Connection;

dist/packages/server/src/Document.d.ts

@@ -6,2 +6,3 @@ import WebSocket from 'ws';
 import Connection from './Connection';
+import { MessageLogger } from './Debugger';
 declare class Document extends Doc {
@@ -15,2 +16,3 @@ awareness: Awareness;
     mux: mutex;
+    debugger: MessageLogger;
     /**
@@ -17,0 +19,0 @@ * Constructor.

dist/packages/server/src/Hocuspocus.d.ts

@@ -5,2 +5,3 @@ /// <reference types="node" />
 import { Configuration } from './types';
+import { MessageLogger } from './Debugger';
 export declare const defaultConfiguration: {
@@ -17,3 +18,4 @@ port: number;
     httpServer?: HTTPServer;
-    websocketServer?: WebSocket.Server;
+    webSocketServer?: WebSocket.Server;
+    debugger: MessageLogger;
     /**
@@ -29,2 +31,6 @@ * Configure the server
     /**
+     * Force closes one or more connections
+     */
+    closeConnections(documentName?: string): void;
+    /**
      * Destroy the server
@@ -68,3 +74,9 @@ */
     private static getDocumentName;
+    enableDebugging(): void;
+    enableLogging(): void;
+    disableLogging(): void;
+    disableDebugging(): void;
+    flushMessageLogs(): this;
+    getMessageLogs(): any[];
 }
 export declare const Server: Hocuspocus;

dist/packages/server/src/MessageReceiver.d.ts

 import Connection from './Connection';
 import { IncomingMessage } from './IncomingMessage';
+import { MessageLogger } from './Debugger';
 export declare class MessageReceiver {
     message: IncomingMessage;
+    debugger: MessageLogger;
     constructor(message: IncomingMessage);
@@ -6,0 +8,0 @@ apply(connection: Connection): void;

dist/packages/server/src/OutgoingMessage.d.ts

@@ -6,2 +6,4 @@ import { Encoder } from 'lib0/encoding';
     encoder: Encoder;
+    type?: number;
+    category?: string;
     constructor();
@@ -8,0 +10,0 @@ createSyncMessage(): OutgoingMessage;

dist/packages/server/src/types.d.ts

@@ -6,2 +6,3 @@ /// <reference types="node" />
 import Document from './Document';
+import { Hocuspocus } from './Hocuspocus';
 export declare enum MessageType {
@@ -13,3 +14,9 @@ Unknown = -1,
 }
+/**
+ * State of the WebSocket connection.
+ * https://developer.mozilla.org/de/docs/Web/API/WebSocket/readyState
+ */
 export declare enum WsReadyStates {
+    Connecting = 0,
+    Open = 1,
     Closing = 2,
@@ -23,2 +30,6 @@ Closed = 3
 }
+export interface ConnectionConfig {
+    readOnly: boolean;
+    isAuthenticated: boolean;
+}
 export interface Extension {
@@ -37,4 +48,13 @@ onAuthenticate?(data: onAuthenticatePayload): Promise<any>;
 export interface Configuration extends Extension {
+    /**
+     * A list of hocuspocus extenions.
+     */
     extensions: Array<Extension>;
+    /**
+     * The port which the server listens on.
+     */
     port: number | null;
+    /**
+     * Defines in which interval the server sends a ping, and closes the connection when no pong is sent back.
+     */
     timeout: number;
@@ -44,2 +64,3 @@ }
     documentName: string;
+    instance: Hocuspocus;
     requestHeaders: IncomingHttpHeaders;
@@ -49,8 +70,7 @@ requestParameters: URLSearchParams;
     token: string;
-    connection: {
-        readOnly: boolean;
-    };
+    connection: ConnectionConfig;
 }
 export interface onConnectPayload {
     documentName: string;
+    instance: Hocuspocus;
     request: IncomingMessage;
@@ -60,5 +80,3 @@ requestHeaders: IncomingHttpHeaders;
     socketId: string;
-    connection: {
-        readOnly: boolean;
-    };
+    connection: ConnectionConfig;
 }
@@ -72,2 +90,3 @@ export interface onCreateDocumentPayload {
     socketId: string;
+    connection: ConnectionConfig;
 }
@@ -96,2 +115,3 @@ export interface onChangePayload {
     response: ServerResponse;
+    instance: Hocuspocus;
 }
@@ -102,2 +122,3 @@ export interface onUpgradePayload {
     socket: Socket;
+    instance: Hocuspocus;
 }
@@ -113,2 +134,3 @@ export interface onListenPayload {
     yjsVersion: string;
+    instance: Hocuspocus;
 }
@@ -115,0 +137,0 @@ export interface CloseEvent {

package.json

 {
   "name": "@hocuspocus/extension-rocksdb",
   "description": "hocuspocus persistence driver for RocksDB",
-  "version": "1.0.0-alpha.67",
+  "version": "1.0.0-alpha.68",
   "homepage": "https://hocuspocus.dev",
@@ -25,13 +25,13 @@ "keywords": [
   "dependencies": {
-    "@hocuspocus/server": "^1.0.0-alpha.65",
+    "@hocuspocus/server": "^1.0.0-alpha.66",
     "@types/encoding-down": "^5.0.0",
     "@types/levelup": "^4.3.0",
     "@types/rocksdb": "^3.0.0",
-    "encoding-down": "^6.3.0",
-    "levelup": "^4.4.0",
-    "rocksdb": "^4.1.0",
+    "encoding-down": "^7.0.0",
+    "levelup": "^5.0.1",
+    "rocksdb": "^5.1.0",
     "y-leveldb": "^0.1.0",
     "yjs": "^13.5.0"
   },
-  "gitHead": "b0e575f7941fc52e0d11f28c61af5dd024caa981"
+  "gitHead": "f4b2c62f0322daa4c95f6be2009fc7a9c48557cb"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

60926

increased by3.7%

Number of package files

59

increased by1.72%

Lines of code

1148

increased by6%

Dependency changes

• + Addedabstract-leveldown@7.2.0(transitive)

• + Addedbuffer@6.0.3(transitive)

• + Addedcatering@2.1.1(transitive)

• + Addeddeferred-leveldown@7.0.0(transitive)

• + Addedencoding-down@7.1.0(transitive)

• + Addedis-buffer@2.0.5(transitive)

• + Addedlevel-codec@10.0.0(transitive)

• + Addedlevel-concat-iterator@3.1.0(transitive)

• + Addedlevel-errors@3.0.1(transitive)

• + Addedlevel-iterator-stream@5.0.0(transitive)

• + Addedlevel-supports@2.1.0(transitive)

• + Addedlevelup@5.1.1(transitive)

• + Addednapi-macros@2.2.2(transitive)

• + Addednode-gyp-build@4.8.3(transitive)

• + Addedqueue-microtask@1.2.3(transitive)

• + Addedrocksdb@5.2.1(transitive)

• - Removedabstract-leveldown@6.1.1(transitive)

• - Removedrocksdb@4.1.0(transitive)

• Updated@hocuspocus/server@^1.0.0-alpha.66

• Updatedencoding-down@^7.0.0

• Updatedlevelup@^5.0.1

• Updatedrocksdb@^5.1.0