@hocuspocus/extension-rocksdb
Advanced tools
Comparing version 1.0.0-alpha.103 to 1.0.0-alpha.104
import RedisClient from 'ioredis'; | ||
import Redlock from 'redlock'; | ||
import { Document, Extension, afterLoadDocumentPayload, afterStoreDocumentPayload, onDisconnectPayload, onStoreDocumentPayload, onAwarenessUpdatePayload, Debugger, onConfigurePayload, onListenPayload } from '@hocuspocus/server'; | ||
import { Document, Extension, afterLoadDocumentPayload, afterStoreDocumentPayload, onDisconnectPayload, onStoreDocumentPayload, onAwarenessUpdatePayload, onChangePayload, Debugger, onConfigurePayload, onListenPayload } from '@hocuspocus/server'; | ||
export interface Configuration { | ||
@@ -86,2 +86,6 @@ /** | ||
/** | ||
* if the ydoc changed, we'll need to inform other Hocuspocus servers about it. | ||
*/ | ||
onChange(data: onChangePayload): Promise<any>; | ||
/** | ||
* Make sure to *not* listen for further changes, when there’s | ||
@@ -88,0 +92,0 @@ * noone connected anymore. |
@@ -123,2 +123,3 @@ import * as Y from 'yjs'; | ||
setConfiguration(configuration?: Partial<HocuspocusProviderConfiguration>): void; | ||
boundConnect: () => Promise<void>; | ||
connect(): Promise<void>; | ||
@@ -133,2 +134,4 @@ createWebSocketConnection(): Promise<unknown>; | ||
forceSync(): void; | ||
boundBeforeUnload: () => void; | ||
beforeUnload(): void; | ||
registerEventListeners(): void; | ||
@@ -153,2 +156,3 @@ documentUpdateHandler(update: Uint8Array, origin: any): void; | ||
get broadcastChannel(): string; | ||
boundBroadcastChannelSubscriber: (data: ArrayBuffer) => void; | ||
broadcastChannelSubscriber(data: ArrayBuffer): void; | ||
@@ -155,0 +159,0 @@ subscribeToBroadcastChannel(): void; |
@@ -22,3 +22,3 @@ import WebSocket from 'ws'; | ||
*/ | ||
constructor(name: string, logger: Debugger); | ||
constructor(name: string, logger: Debugger, yDocOptions: {}); | ||
/** | ||
@@ -25,0 +25,0 @@ * Check if the Document is empty |
@@ -15,2 +15,6 @@ /// <reference types="node" /> | ||
quiet: boolean; | ||
yDocOptions: { | ||
gc: boolean; | ||
gcFilter: () => boolean; | ||
}; | ||
}; | ||
@@ -17,0 +21,0 @@ /** |
@@ -11,4 +11,4 @@ import { Awareness } from 'y-protocols/awareness'; | ||
apply(document: Document, connection?: Connection, reply?: (message: Uint8Array) => void): void; | ||
readSyncMessage(message: IncomingMessage, document: Document, connection?: Connection, reply?: (message: Uint8Array) => void): 0 | 2 | 1; | ||
readSyncMessage(message: IncomingMessage, document: Document, connection?: Connection, reply?: (message: Uint8Array) => void, requestFirstSync?: boolean): 0 | 2 | 1; | ||
applyQueryAwarenessMessage(awareness: Awareness, reply?: (message: Uint8Array) => void): void; | ||
} |
@@ -10,2 +10,3 @@ import { Encoder } from 'lib0/encoding'; | ||
createSyncMessage(): OutgoingMessage; | ||
createSyncReplyMessage(): OutgoingMessage; | ||
createAwarenessUpdateMessage(awareness: Awareness, changedClients?: Array<any>): OutgoingMessage; | ||
@@ -12,0 +13,0 @@ writeQueryAwareness(): OutgoingMessage; |
@@ -12,3 +12,4 @@ /// <reference types="node" /> | ||
Auth = 2, | ||
QueryAwareness = 3 | ||
QueryAwareness = 3, | ||
SyncReply = 4 | ||
} | ||
@@ -84,2 +85,9 @@ export interface AwarenessUpdate { | ||
/** | ||
* options to pass to the ydoc document | ||
*/ | ||
yDocOptions: { | ||
gc: boolean; | ||
gcFilter: () => boolean; | ||
}; | ||
/** | ||
* Function which returns the (customized) document name based on the request | ||
@@ -86,0 +94,0 @@ */ |
{ | ||
"name": "@hocuspocus/extension-rocksdb", | ||
"description": "hocuspocus persistence driver for RocksDB", | ||
"version": "1.0.0-alpha.103", | ||
"version": "1.0.0-alpha.104", | ||
"homepage": "https://hocuspocus.dev", | ||
@@ -30,3 +30,3 @@ "keywords": [ | ||
"dependencies": { | ||
"@hocuspocus/server": "^1.0.0-alpha.102", | ||
"@hocuspocus/server": "^1.0.0-alpha.103", | ||
"@types/encoding-down": "^5.0.0", | ||
@@ -41,3 +41,3 @@ "@types/levelup": "^4.3.3", | ||
}, | ||
"gitHead": "450e12c89b027bc62683f151330a98074cd8e8fb" | ||
"gitHead": "af278e7c5d91c74afefd9234379c8179c8b91e6d" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
69158
1721