mantendo a conexão ativa

src/app/shared/nostr-api/nostr-api.module.ts

@@ -1,13 +1,15 @@
-import { NgModule } from '@angular/core';
 import { CommonModule } from '@angular/common';
+import { NgModule } from '@angular/core';
+import { NostrEventFactory } from './nostr-event.factory';
 import { NostrService } from './nostr.service';
 
 @NgModule({
   imports: [
     CommonModule
   ],
   providers: [
-    NostrService
+    NostrService,
+    NostrEventFactory
   ]
 })
 export class NostrApiModule { }

src/app/shared/nostr-api/nostr.service.ts

@@ -1,18 +1,26 @@
 import { Injectable } from '@angular/core';
-import { Event, Filter, SimplePool } from 'nostr-tools';
+import { Event, Filter, SimplePool, validateEvent, verifySignature } from 'nostr-tools';
 import { defaultRelays } from '../../default-relays.const';
 
-@Injectable({
-  providedIn: 'root'
-})
+@Injectable()
 export class NostrService {
-  private readonly relays = defaultRelays;
 
+  private static instance: NostrService | null = null;
+
+  pool = new SimplePool();
+
+  constructor() {
+    if (!NostrService.instance) {
+      NostrService.instance = this;
+    }
+
+    return NostrService.instance;
+  }
+
   get<K extends number>(filters: Filter<K>[]): Promise<Array<Event<K>>> {
-    const pool = new SimplePool();
     const events = new Array<Event<K>>();
-    const sub = pool.sub(
-      this.relays, filters
+    const sub = this.pool.sub(
+      defaultRelays, filters
     );
 
     sub.on('event', event => {
@@ -22,9 +30,21 @@ export class NostrService {
     return new Promise(resolve => {
       sub.on('eose', () => {
         resolve(events);
-        sub.unsub();
-        pool.close(this.relays);
       });
     });
   }
+
+  async publish<K extends number>(event: Event<K>): Promise<void> {
+    const ok = validateEvent(event);
+    const veryOk = verifySignature(event);
+
+    if (!ok || !veryOk) {
+      console.error(' :: event is not valid... aborting...');
+      return Promise.resolve();
+    }
+
+    await this.pool.publish(defaultRelays, event);
+
+    return Promise.resolve();
+  }
 }

src/app/shared/omegle/omegle.nostr.ts

@@ -2,17 +2,6 @@ import { Injectable } from '@angular/core';
 import { NostrService } from '../nostr-api/nostr.service';
 import { NostrEventKind } from '@domain/nostr-event-kind.enum';
 
-/**
- * Nip 38 e nip 4 vou usar
- * O nip 38 indica um status em que o usuário está (online, offline, ocupado e variações)
- * O 4 é chat direto criptografado
- * 1. O nsec é gerado
- * 2. Aplico um user status de interessado em bate papo
- * 3. Filtra nos relays eventos de user status interessado em bate papo
- * 4. Conecta os dois em chat criptografado e atualiza o user status pra ocupado
- * Cada nova conversa por ser um novo nsec
- */
-
 @Injectable()
 export class OmegleNostr {