Update ws.ts

ws.ts

@@ -189,7 +189,6 @@ async function handle_cmd_event(args: {
             connections,
         )
     ) {
-        console.log(policy);
         if (policy.read === false) {
             return;
         }
@@ -205,19 +204,26 @@ async function handle_cmd_req(
         resolvePolicyByKind: func_ResolvePolicyByKind;
     } & EventReadWriter,
 ) {
-    const { this_socket, resolvePolicyByKind, get_events_by_IDs } = args;
+    const { this_socket } = args;
     const sub_id = nostr_ws_msg[1];
     const filters = nostr_ws_msg.slice(2) as NostrFilter[];
 
-    args.connections.get(this_socket)?.set(
-        sub_id,
-        filters.map((f) => {
-            return {
-                filter: f,
-                eventSent: 0,
-            };
-        }),
-    );
+    const subscriptions = args.connections.get(this_socket)
+    if(subscriptions) {
+        if(subscriptions.size > 10) {
+            send(this_socket, JSON.stringify(respond_notice(`${sub_id}:only accept at most 10 subscriptions`)));
+            return;
+        }
+        subscriptions.set(
+            sub_id,
+            filters.map((f) => {
+                return {
+                    filter: f,
+                    eventSent: 0,
+                };
+            }),
+        );
+    }
 
     // query this filter
     for (const filter of filters) {