changed server creation added missing index.js

Author: randilfernando

README.md

@@ -0,0 +1,39 @@
+# Link Protocol Libraries
+
+This repository contains the TypeScript implementations for the Link protocol, a lightweight, multiplexed communication protocol over WebSockets.
+
+## Packages
+
+- **[@marketrix-ai/link-server](./server)**: The server-side library.
+- **[@marketrix-ai/link-client](./client)**: The client-side library.
+
+## Getting Started
+
+To install these packages, you must configure your npm client to use the GitHub Package Registry for the `@marketrix-ai` scope.
+
+### 1. Configure Authentication
+
+Create or update an `.npmrc` file in your project root or user home directory (`~/.npmrc`) with the following content:
+
+```ini
+@marketrix-ai:registry=https://npm.pkg.github.com
+//npm.pkg.github.com/:_authToken=YOUR_GITHUB_PAT
+```
+
+Replace `YOUR_GITHUB_PAT` with a GitHub Personal Access Token that has `read:packages` scope.
+
+### 2. Install
+
+Once configured, you can install the packages as usual:
+
+```bash
+npm install @marketrix-ai/link-server
+npm install @marketrix-ai/link-client
+```
+
+## Documentation
+
+Please refer to the README files in each package directory for detailed usage instructions:
+
+- [Server Documentation](./server/README.md)
+- [Client Documentation](./client/README.md)

client/README.md

@@ -0,0 +1,52 @@
+# Link Client
+
+This is the client-side library for the Link protocol. It allows you to connect to a Link server and manage multiplexed streams over a single WebSocket connection.
+
+## Installation
+
+```bash
+npm install @marketrix-ai/link-client
+```
+
+**Note**: You need to configure your `.npmrc` to install packages from the GitHub registry.
+
+### Configuration (`.npmrc`)
+
+Add the following to your `.npmrc` file (either in your project root or user home directory):
+
+```
+@marketrix-ai:registry=https://npm.pkg.github.com
+```
+
+You will also need to authenticate with GitHub Packages using a Personal Access Token (PAT).
+
+## Usage
+
+```typescript
+import { Client } from '@marketrix-ai/link-client';
+
+const client = new Client({ 
+    url: 'ws://localhost:8080',
+    connectionId: 'client-1', // Optional
+    retryInterval: 1000 // Optional: retry connection every 1s
+});
+
+client.connect();
+
+client.on('open', () => {
+    console.log('Connected to server');
+
+    // Create a new stream
+    const stream = client.createStream('my-stream-1');
+
+    stream.on('data', (data) => {
+        console.log('Received data:', data);
+    });
+
+    stream.send({ message: 'Hello World' });
+});
+
+client.on('close', () => {
+    console.log('Disconnected from server');
+});
+```

client/src/index.ts

@@ -0,0 +1,3 @@
+export * from './client';
+export * from './stream';
+export * from './protocol';

server/README.md

@@ -0,0 +1,73 @@
+# Link Server
+
+This is the server-side library for the Link protocol. It provides a WebSocket server implementation with support for multiplexed streams.
+
+## Installation
+
+```bash
+npm install @marketrix-ai/link-server
+```
+
+**Note**: You need to configure your `.npmrc` to install packages from the GitHub registry.
+
+### Configuration (`.npmrc`)
+
+Add the following to your `.npmrc` file (either in your project root or user home directory):
+
+```
+@marketrix-ai:registry=https://npm.pkg.github.com
+```
+
+You will also need to authenticate with GitHub Packages using a Personal Access Token (PAT).
+
+## Usage
+
+You can use the `LinkServer` class to create a WebSocket server or integrate it into an existing application.
+
+### Basic Usage
+
+```typescript
+import { LinkServer } from '@marketrix-ai/link-server';
+
+const server = new LinkServer({ port: 8080 });
+
+server.on('listening', () => {
+    console.log('Server is listening on port 8080');
+});
+
+server.on('connection', (connection) => {
+    console.log('Client connected:', connection.id);
+
+    // Handle new streams created by the client
+    connection.on('newStream', (stream) => {
+        console.log(`New stream ${stream.id} created`);
+
+        stream.on('data', (data) => {
+            console.log(`Received data on stream ${stream.id}:`, data);
+            
+            // Example: sending data back
+            // stream.send({ message: 'Hello from server' });
+        });
+
+        stream.on('close', () => {
+            console.log(`Stream ${stream.id} closed`);
+        });
+    });
+
+    connection.on('close', () => {
+        console.log('Client disconnected');
+    });
+});
+```
+
+### Options
+
+The `LinkServer` constructor accepts the same options as the `ws` WebSocket.Server:
+
+```typescript
+const server = new LinkServer({ 
+    port: 8080,
+    // host: '0.0.0.0',
+    // ... other ws options
+});
+```

server/src/index.ts

@@ -0,0 +1,4 @@
+export * from './server';
+export * from './connection';
+export * from './stream';
+export * from './protocol';

server/src/server.ts

@@ -1,30 +1,37 @@
+import { EventEmitter } from 'events';
 import WebSocket from 'ws';
 import { Connection } from './connection';
-import { Stream } from './stream';
 
-const wss = new WebSocket.Server({ port: 8080 });
+export interface LinkServerOptions extends WebSocket.ServerOptions {
+    // You can add additional options here if needed, 
+    // for now we just extend standard WS server options
+}
 
-console.log('WebSocket server started on port 8080');
+export class LinkServer extends EventEmitter {
+    private wss: WebSocket.Server;
 
-wss.on('connection', (ws: WebSocket) => {
-    const connection = new Connection(ws);
+    constructor(options: LinkServerOptions) {
+        super();
+        this.wss = new WebSocket.Server(options);
+        this.init();
+    }
 
-    connection.on('newStream', (stream: Stream) => {
-        console.log(`New stream created: ${stream.id} on connection ${connection.id}`);
+    private init() {
+        this.wss.on('connection', (ws: WebSocket) => {
+            const connection = new Connection(ws);
+            this.emit('connection', connection);
+        });
 
-        // Example: Echo back data
-        stream.on('data', (data: any) => {
-            console.log(`Received data on stream ${stream.id}:`, data);
-            // Echoing back
-            // stream.send({ echoed: data }); 
+        this.wss.on('error', (error) => {
+            this.emit('error', error);
         });
 
-        stream.on('close', () => {
-            console.log(`Stream ${stream.id} closed`);
+        this.wss.on('listening', () => {
+            this.emit('listening');
         });
-    });
+    }
 
-    connection.on('close', () => {
-        console.log(`Connection ${connection.id || 'unknown'} closed`);
-    });
-});
+    public close(cb?: (err?: Error) => void) {
+        this.wss.close(cb);
+    }
+}