Release v0.8.0: Dynamic Reconfiguration, Leader Election, and Docs Refactor

Author: mrdevrobot

docs/index.md

@@ -4,12 +4,59 @@ layout: default
 
 # EntglDb Node.js Documentation
 
-Welcome to the documentation for **EntglDb Node.js**.
+**EntglDb** is a decentralized, offline-first peer-to-peer database. This repository contains the **Node.js** implementation.
 
-## Active Versions
+## Installation
 
-*   [**v0.7.0 (Latest)**](https://www.entgldb.com/docs/v0.7.0) - *Hosted on EntglDb.com*
+```bash
+npm install @entgldb/core @entgldb/persistence-sqlite @entgldb/network
+```
+
+## Getting Started
+
+### 1. Initialize
+
+```typescript
+import { EntglDb } from '@entgldb/core';
+import { SqlitePeerStore } from '@entgldb/persistence-sqlite';
+import { TcpSyncServer, UdpDiscoveryService } from '@entgldb/network';
+
+const store = new SqlitePeerStore('my-db.sqlite');
+await store.initialize();
+
+const db = new EntglDb(store);
+
+// Network
+const discovery = new UdpDiscoveryService(db.nodeId, 25000);
+const server = new TcpSyncServer({
+    store,
+    nodeId: db.nodeId,
+    port: 25000
+});
+
+server.start();
+discovery.start();
+```
+
+### 2. Save Data
+
+```typescript
+await db.put('todos', 'todo-1', { title: 'Buy Milk' });
+```
+
+### 3. Subscribe to Changes
+
+```typescript
+db.on('change', (collections) => {
+    console.log('Collections changed:', collections);
+});
+```
+
+## Dynamic Reconfiguration (v0.8.0)
+
+See [Dynamic Reconfiguration](https://github.com/EntglDb/EntglDb.Net/blob/main/docs/dynamic-reconfiguration.md) in the main documentation.
 
 ## Links
 
+*   [**Central Documentation**](https://github.com/EntglDb/EntglDb.Net/tree/main/docs) - Architecture, Protocol, and Concepts.
 *   [GitHub Repository](https://github.com/EntglDb/EntglDb.NodeJs)

docs/v0.7.0/getting-started.md

@@ -1,6 +1,6 @@
 {
     "name": "@entgldb/core",
-    "version": "0.7.0",
+    "version": "0.8.0",
     "description": "EntglDb core database engine",
     "repository": {
         "type": "git",

docs/v0.7.0/index.md

@@ -19,3 +19,8 @@ export type { HLCTimestamp, Document, OplogEntry } from '@entgldb/protocol';
 export * from './query/query-node';
 export * from './query/translator';
 
+
+// Network abstractions
+export * from './network/PeerNode';
+export * from './network/IDiscoveryService';
+export * from './network/PeerNodeConfigurationProvider';

docs/v0.7.0/querying.md

@@ -0,0 +1,7 @@
+import { PeerNode } from './PeerNode';
+
+export interface IDiscoveryService {
+    start(): Promise<void>;
+    stop(): Promise<void>;
+    getActivePeers(): PeerNode[];
+}

packages/core/package.json

@@ -0,0 +1,18 @@
+export enum PeerType {
+    LanDiscovered = 0,
+    StaticRemote = 1,
+    CloudRemote = 2
+}
+
+export interface PeerNode {
+    nodeId: string;
+    host: string; // address in .NET
+    port: number;
+    lastSeen: Date;
+    type: PeerType;
+}
+
+export enum NodeRole {
+    Member = 0,
+    CloudGateway = 1
+}

packages/core/src/index.ts

@@ -0,0 +1,31 @@
+export interface PeerNodeConfiguration {
+    nodeId: string;
+    tcpPort: number;
+    // Add other config fields as needed matching .NET
+}
+
+export type ConfigurationChangedHandler = (config: PeerNodeConfiguration) => void;
+
+export interface IPeerNodeConfigurationProvider {
+    getConfiguration(): Promise<PeerNodeConfiguration>;
+    onConfigurationChanged(handler: ConfigurationChangedHandler): void;
+}
+
+export class StaticPeerNodeConfigurationProvider implements IPeerNodeConfigurationProvider {
+    private handlers: ConfigurationChangedHandler[] = [];
+
+    constructor(private configuration: PeerNodeConfiguration) { }
+
+    async getConfiguration(): Promise<PeerNodeConfiguration> {
+        return this.configuration;
+    }
+
+    onConfigurationChanged(handler: ConfigurationChangedHandler): void {
+        this.handlers.push(handler);
+    }
+
+    updateConfiguration(newConfig: PeerNodeConfiguration): void {
+        this.configuration = newConfig;
+        this.handlers.forEach(h => h(newConfig));
+    }
+}

packages/core/src/network/IDiscoveryService.ts

@@ -1,4 +1,5 @@
 import { HLCTimestamp, Document, OplogEntry } from '@entgldb/protocol';
+import { PeerNode } from '../network/PeerNode';
 export type { OplogEntry };
 
 /**
@@ -50,6 +51,21 @@ export interface IPeerStore {
      */
     findDocuments(collection: string, query: any /* QueryNode */): Promise<Document[]>;
 
+    /**
+     * Get all persistent remote peers
+     */
+    getRemotePeers(): Promise<PeerNode[]>;
+
+    /**
+     * Save a remote peer configuration
+     */
+    saveRemotePeer(peer: PeerNode): Promise<void>;
+
+    /**
+     * Remove a remote peer configuration
+     */
+    removeRemotePeer(nodeId: string): Promise<void>;
+
     /**
      * Close the store
      */