mirror of
https://github.com/dergigi/boris.git
synced 2026-02-16 12:34:41 +01:00
adf73cb9d1
- Fix empty catch blocks by adding explanatory comments - Remove unused variables or prefix with underscore - Remove orphaned object literals from removed console.log statements - Fix unnecessary dependency array entries - Ensure all empty code blocks have comments to satisfy eslint no-empty rule
58 lines
1.9 KiB
TypeScript
58 lines
1.9 KiB
TypeScript
import { RelayPool } from 'applesauce-relay'
|
|
import { NostrEvent } from 'nostr-tools'
|
|
import { IEventStore } from 'applesauce-core'
|
|
import { RELAYS } from '../config/relays'
|
|
import { isLocalRelay, areAllRelaysLocal } from '../utils/helpers'
|
|
import { markEventAsOfflineCreated } from './offlineSyncService'
|
|
|
|
/**
|
|
* Unified write helper: add event to EventStore, detect connectivity,
|
|
* mark for offline sync if needed, and publish in background.
|
|
*/
|
|
export async function publishEvent(
|
|
relayPool: RelayPool,
|
|
eventStore: IEventStore,
|
|
event: NostrEvent
|
|
): Promise<void> {
|
|
const isProgressEvent = event.kind === 39802
|
|
const logPrefix = isProgressEvent ? '[progress]' : ''
|
|
|
|
// Store the event in the local EventStore FIRST for immediate UI display
|
|
eventStore.add(event)
|
|
|
|
// Check current connection status - are we online or in flight mode?
|
|
const connectedRelays = Array.from(relayPool.relays.values())
|
|
.filter(relay => relay.connected)
|
|
.map(relay => relay.url)
|
|
|
|
const hasRemoteConnection = connectedRelays.some(url => !isLocalRelay(url))
|
|
|
|
// Determine which relays we expect to succeed
|
|
const expectedSuccessRelays = hasRemoteConnection
|
|
? RELAYS
|
|
: RELAYS.filter(isLocalRelay)
|
|
|
|
const isLocalOnly = areAllRelaysLocal(expectedSuccessRelays)
|
|
|
|
// Publishing event
|
|
|
|
// If we're in local-only mode, mark this event for later sync
|
|
if (isLocalOnly) {
|
|
markEventAsOfflineCreated(event.id)
|
|
}
|
|
|
|
// Publish to all configured relays in the background (non-blocking)
|
|
relayPool.publish(RELAYS, event)
|
|
.then(() => {
|
|
})
|
|
.catch((error) => {
|
|
console.warn(`${logPrefix} ⚠️ Failed to publish event to relays (event still saved locally):`, error)
|
|
|
|
// Surface common bunker signing errors for debugging
|
|
if (error instanceof Error && error.message.includes('permission')) {
|
|
console.warn('💡 Hint: This may be a bunker permission issue. Ensure your bunker connection has signing permissions.')
|
|
}
|
|
})
|
|
}
|
|
|