feat: jsr + conninfo on handler + types - fix #5 (#6)

* feat: jsr + conninfo on handler + types - fix #5

* feat: jsr + conninfo on handler + types - fix #5

Author: pagoru

.github/workflows/build.yml

@@ -0,0 +1,30 @@
+name: Build
+on:
+  push:
+    branches: [master]
+  pull_request:
+
+jobs:
+  prettier:
+    name: "prettier"
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        deno-version: [1.45.3]
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-node@v4
+        with:
+          node-version: "20.x"
+          registry-url: "https://registry.npmjs.org"
+      - run: yarn install --frozen-lockfile
+
+      - name: run prettier checker
+        run: yarn prettier:check
+
+      - name: Use Deno Version ${{ matrix.deno-version }}
+        uses: denoland/setup-deno@v1
+        with:
+          deno-version: ${{ matrix.deno-version }}

.github/workflows/publish.yml

@@ -0,0 +1,49 @@
+name: Publish
+on:
+  push:
+    tags:
+      - "*"
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        deno-version: [1.45.3]
+
+    permissions:
+      contents: read
+      id-token: write
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Set Versions
+        uses: actions/github-script@v4
+        id: set_version
+        with:
+          script: |
+            const tag = context.ref.substring(10).replace('v', '')
+            core.setOutput('tag', tag)
+            console.log(tag)
+
+      - uses: actions/setup-node@v4
+        with:
+          node-version: "20.x"
+          registry-url: "https://registry.npmjs.org"
+      - run: yarn install --frozen-lockfile
+
+      - name: run prettier checker
+        run: yarn prettier:check
+
+      - name: Add version to package.json
+        uses: jaywcjlove/github-action-package@main
+        with:
+          path: "./deno.json"
+          data: |
+            {
+              "version": "${{ steps.set_version.outputs.tag }}"
+            }
+
+      - name: Publish package
+        run: npx jsr publish --allow-dirty

.gitignore

@@ -1 +1,2 @@
-.idea
+.idea
+node_modules

README.md

@@ -1,9 +1,9 @@
-# SOCKET.ionic
+# @da/socket
 
 ## Server
 
 ```ts
-import { getServerSocket } from "https://deno.land/x/socket_ionic/mod.ts";
+import { getServerSocket } from "@da/socket";
 
 const server = getServerSocket(1994);
 

deno.json

@@ -0,0 +1,5 @@
+{
+  "name": "@da/socket",
+  "version": "0.0.0",
+  "exports": "./index.ts"
+}

mod.ts renamed to index.ts

@@ -0,0 +1,10 @@
+{
+  "scripts": {
+    "prettier:check": "prettier -c ./",
+    "prettier:write": "prettier --write ."
+  },
+  "devDependencies": {
+    "prettier": "3.3.3"
+  },
+  "packageManager": "[email protected]"
+}

package.json

@@ -7,17 +7,31 @@ type Props = {
   protocols?: string[];
 };
 
+type Mutable = {
+  connect: () => Promise<void>;
+  emit: (
+    event: string,
+    message?: unknown,
+    response?: (message?: unknown) => void,
+  ) => void;
+  on: (
+    event: "connected" | "disconnected" | "error",
+    callback: (data?: unknown) => void,
+  ) => () => void;
+  close: () => void;
+};
+
 enum ReadyState {
   CONNECTING,
   OPEN,
   CLOSING,
-  CLOSED
+  CLOSED,
 }
 
 const getRandomString = (length: number) => {
-  let result = '';
+  let result = "";
   const characters =
-    'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
+    "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
   const charactersLength = characters.length;
   let counter = 0;
   while (counter < length) {
@@ -34,101 +48,115 @@ export const getClientSocket = ({
   reconnectInterval = 1_000,
   silent = false,
   protocols = [],
-}: Props) => {
-  const events: Record<string, any[]> = {};
+}: Props): Mutable => {
+  const events: Record<string, ((data?: unknown) => unknown | null)[]> = {};
 
-  let socket;
+  let socket: WebSocket;
   let reconnects = 0;
   let isConnected = false;
-  let isClosed = false
-  
-  const emitEventCallback = (event: string, data?: any) => {
-    if(!events[event]) return;
-    
-    for (const callback of events[event]) callback?.(data)
-  }
-  
-  const connect = async () =>
-    new Promise((resolve, reject) => {
+  let isClosed = false;
+
+  const emitEventCallback = (event: string, data?: unknown) => {
+    if (!events[event]) return;
+
+    for (const callback of events[event]) callback?.(data);
+  };
+
+  const connect = (): Promise<void> =>
+    new Promise<void>((resolve, reject) => {
       try {
-        if (isConnected) return resolve(null);
-        
+        if (isConnected) return resolve();
+
         !silent && reconnects === 0 && console.log(`Connecting to ${url}!`);
         socket = new WebSocket(url, protocols);
-        
+
         // Connection opened
         socket.addEventListener("open", () => {
           isConnected = true;
           !silent && console.log(`Connected to ${url}!`);
-          emitEventCallback('connected')
-          resolve(null);
+          emitEventCallback("connected");
+          resolve();
           reconnects = 0;
         });
-        
+
         // Listen for messages
-        socket.addEventListener("message", async ({ data }) => {
+        socket.addEventListener("message", ({ data }) => {
           const { event, message } = JSON.parse(data);
-          if(!events[event]) return
-          
-          emitEventCallback(event, message)
+          if (!events[event]) return;
+
+          emitEventCallback(event, message);
         });
-        
-        socket.addEventListener("error", (message) => emitEventCallback('error', message));
-        
+
+        socket.addEventListener("error", (message) =>
+          emitEventCallback("error", message),
+        );
+
         socket.addEventListener("close", (message) => {
           !silent && isConnected && console.log(`Disconnected from ${url}!`);
-          
+
           // resovle if it's already closed
-          if(isClosed) return resolve(null);
-          
+          if (isClosed) return resolve();
+
           isConnected = false;
           if (reconnect && reconnectIntents > reconnects) {
             reconnects++;
             !silent &&
-            console.log(
-              `(${reconnects}/${reconnectIntents}) Reconnecting to ${url} in ${reconnectInterval}ms...`,
-            );
+              console.log(
+                `(${reconnects}/${reconnectIntents}) Reconnecting to ${url} in ${reconnectInterval}ms...`,
+              );
             setTimeout(async () => {
               await connect();
-              resolve(null);
+              resolve();
             }, reconnectInterval);
             return;
           }
-          emitEventCallback('disconnected', message)
-          resolve(null);
+          emitEventCallback("disconnected", message);
+          resolve();
         });
       } catch (e) {
-        reject(e)
+        reject(e);
       }
     });
 
-  const emit = (event: string, message?: any, response?: (message?: any) => void) => {
-    if(socket.readyState !== ReadyState.OPEN)
-      throw new Error(`Socket is not open (${ReadyState[socket.readyState]}}) {${event}:${message}}!`)
-    
-    let responseEventId = null
-    if(response) {
-      responseEventId = getRandomString(32)
-      
-      on(`${event}#${responseEventId}`, (data) => response(data))
+  const emit = (
+    event: string,
+    message?: unknown,
+    response?: (message?: unknown) => void,
+  ): void => {
+    if (socket.readyState !== ReadyState.OPEN)
+      throw new Error(
+        `Socket is not open (${ReadyState[socket.readyState]}}) {${event}:${message}}!`,
+      );
+
+    let responseEventId = null;
+    if (response) {
+      responseEventId = getRandomString(32);
+
+      on(`${event}#${responseEventId}`, (data) => response(data));
     }
-    socket.send(JSON.stringify({ event, message: message || {}, responseEventId }));
-  }
+    socket.send(
+      JSON.stringify({ event, message: message || {}, responseEventId }),
+    );
+  };
 
   const on = (
     event: "connected" | "disconnected" | "error" | string,
-    callback: (data?: any) => void,
-  ) => {
-    if(!events[event]) events[event] = []
-    
-    const index = events[event].push(callback) - 1
-    return () => events[event] = events[event].map((callback, $index) => index === $index ? null : callback)
-  }
+    callback: (data?: unknown) => void,
+  ): (() => void) => {
+    if (!events[event]) events[event] = [];
+
+    const index = events[event].push(callback) - 1;
+    return () =>
+      (events[event] = events[event].map<(data?: unknown) => unknown>(
+        (callback, $index) =>
+          (index === $index ? null : callback) as (data?: unknown) => unknown,
+      ));
+  };
 
   const close = () => {
-    isClosed = true
+    isClosed = true;
     socket.close();
-  }
+  };
 
   return {
     connect,