lint fix wip
This commit is contained in:
parent
64e2f7f826
commit
ec50e564b2
@ -256,7 +256,7 @@ export function KeyManagementManager(): React.ReactElement {
|
|||||||
|
|
||||||
{/* Sync Progress Bar - Always show if connected, even if publicKeys not loaded yet */}
|
{/* Sync Progress Bar - Always show if connected, even if publicKeys not loaded yet */}
|
||||||
{(() => {
|
{(() => {
|
||||||
console.log('[KeyManagementManager] Rendering SyncProgressBar')
|
console.warn('[KeyManagementManager] Rendering SyncProgressBar')
|
||||||
return <SyncProgressBar />
|
return <SyncProgressBar />
|
||||||
})()}
|
})()}
|
||||||
|
|
||||||
|
|||||||
@ -107,7 +107,7 @@ class PlatformSyncService {
|
|||||||
})
|
})
|
||||||
|
|
||||||
try {
|
try {
|
||||||
console.log(`[PlatformSync] Synchronizing from relay ${i + 1}/${activeRelays.length}: ${relayUrl}`)
|
console.warn(`[PlatformSync] Synchronizing from relay ${i + 1}/${activeRelays.length}: ${relayUrl}`)
|
||||||
|
|
||||||
const { createSubscription } = require('@/types/nostr-tools-extended')
|
const { createSubscription } = require('@/types/nostr-tools-extended')
|
||||||
const sub = createSubscription(pool, [relayUrl], filters)
|
const sub = createSubscription(pool, [relayUrl], filters)
|
||||||
@ -130,15 +130,45 @@ class PlatformSyncService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
console.log(`[PlatformSync] Relay ${relayUrl} completed, received ${relayEvents.length} events`)
|
console.warn(`[PlatformSync] Relay ${relayUrl} completed, received ${relayEvents.length} events`)
|
||||||
}
|
}
|
||||||
|
|
||||||
await new Promise<void>((resolve) => {
|
await new Promise<void>((resolve) => {
|
||||||
sub.on('event', (event: Event): void => {
|
sub.on('event', (event: Event): void => {
|
||||||
|
// Log target event for debugging
|
||||||
|
if (event.id === '527d83e0af20bf23c3e104974090ccc21536ece72c24eb784b3642890f63b763') {
|
||||||
|
console.warn(`[PlatformSync] Received target event from relay ${relayUrl}:`, {
|
||||||
|
id: event.id,
|
||||||
|
created_at: event.created_at,
|
||||||
|
created_at_date: new Date(event.created_at * 1000).toISOString(),
|
||||||
|
pubkey: event.pubkey,
|
||||||
|
allTags: event.tags,
|
||||||
|
serviceTags: event.tags.filter((tag) => tag[0] === 'service'),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
// Only process events with service='zapwall.fr'
|
// Only process events with service='zapwall.fr'
|
||||||
const tags = extractTagsFromEvent(event)
|
const tags = extractTagsFromEvent(event)
|
||||||
|
|
||||||
|
if (event.id === '527d83e0af20bf23c3e104974090ccc21536ece72c24eb784b3642890f63b763') {
|
||||||
|
console.warn(`[PlatformSync] Extracted tags for target event:`, {
|
||||||
|
extractedTags: tags,
|
||||||
|
hasServiceTag: tags.service === PLATFORM_SERVICE,
|
||||||
|
serviceValue: tags.service,
|
||||||
|
expectedService: PLATFORM_SERVICE,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
if (tags.service === PLATFORM_SERVICE) {
|
if (tags.service === PLATFORM_SERVICE) {
|
||||||
relayEvents.push(event)
|
relayEvents.push(event)
|
||||||
|
if (event.id === '527d83e0af20bf23c3e104974090ccc21536ece72c24eb784b3642890f63b763') {
|
||||||
|
console.warn(`[PlatformSync] Target event accepted and added to relayEvents`)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// Log events that match filter but don't have service tag
|
||||||
|
if (event.id === '527d83e0af20bf23c3e104974090ccc21536ece72c24eb784b3642890f63b763') {
|
||||||
|
console.warn(`[PlatformSync] Event ${event.id} rejected: service tag is "${tags.service}", expected "${PLATFORM_SERVICE}"`)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
@ -180,7 +210,7 @@ class PlatformSyncService {
|
|||||||
|
|
||||||
// Process all collected events
|
// Process all collected events
|
||||||
await this.processAndCacheEvents(allEvents)
|
await this.processAndCacheEvents(allEvents)
|
||||||
console.log(`[PlatformSync] Total events collected from all relays: ${allEvents.length}`)
|
console.warn(`[PlatformSync] Total events collected from all relays: ${allEvents.length}`)
|
||||||
|
|
||||||
this.lastSyncTime = Date.now()
|
this.lastSyncTime = Date.now()
|
||||||
}
|
}
|
||||||
|
|||||||
@ -258,19 +258,19 @@ async function fetchAndCacheSeries(
|
|||||||
sub.on('event', (event: Event): void => {
|
sub.on('event', (event: Event): void => {
|
||||||
const tags = extractTagsFromEvent(event)
|
const tags = extractTagsFromEvent(event)
|
||||||
if (tags.type === 'series' && !tags.hidden) {
|
if (tags.type === 'series' && !tags.hidden) {
|
||||||
console.log('[Sync] Received series event:', event.id)
|
console.warn('[Sync] Received series event:', event.id)
|
||||||
events.push(event)
|
events.push(event)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
sub.on('eose', (): void => {
|
sub.on('eose', (): void => {
|
||||||
console.log(`[Sync] EOSE for series, received ${events.length} events`)
|
console.warn(`[Sync] EOSE for series, received ${events.length} events`)
|
||||||
void done()
|
void done()
|
||||||
})
|
})
|
||||||
|
|
||||||
setTimeout((): void => {
|
setTimeout((): void => {
|
||||||
if (!finished) {
|
if (!finished) {
|
||||||
console.log(`[Sync] Timeout for series, received ${events.length} events`)
|
console.warn(`[Sync] Timeout for series, received ${events.length} events`)
|
||||||
}
|
}
|
||||||
void done()
|
void done()
|
||||||
}, 10000).unref?.()
|
}, 10000).unref?.()
|
||||||
|
|||||||
@ -79,19 +79,19 @@ export default function App({ Component, pageProps }: AppProps): React.ReactElem
|
|||||||
|
|
||||||
const startUserSync = async (): Promise<void> => {
|
const startUserSync = async (): Promise<void> => {
|
||||||
if (syncInProgress) {
|
if (syncInProgress) {
|
||||||
console.log('[App] Sync already in progress, skipping')
|
console.warn('[App] Sync already in progress, skipping')
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
const state = nostrAuthService.getState()
|
const state = nostrAuthService.getState()
|
||||||
console.log('[App] Checking connection state:', { connected: state.connected, hasPubkey: Boolean(state.pubkey) })
|
console.warn('[App] Checking connection state:', { connected: state.connected, hasPubkey: Boolean(state.pubkey) })
|
||||||
if (!state.connected || !state.pubkey) {
|
if (!state.connected || !state.pubkey) {
|
||||||
console.log('[App] Not connected or no pubkey, skipping sync')
|
console.warn('[App] Not connected or no pubkey, skipping sync')
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
syncInProgress = true
|
syncInProgress = true
|
||||||
console.log('[App] Starting user content sync...')
|
console.warn('[App] Starting user content sync...')
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await syncUserContentToCache(state.pubkey, (progress) => {
|
await syncUserContentToCache(state.pubkey, (progress) => {
|
||||||
@ -100,7 +100,7 @@ export default function App({ Component, pageProps }: AppProps): React.ReactElem
|
|||||||
syncProgressManager.setProgress(null)
|
syncProgressManager.setProgress(null)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
console.log('[App] User content sync completed')
|
console.warn('[App] User content sync completed')
|
||||||
syncProgressManager.setProgress(null)
|
syncProgressManager.setProgress(null)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error('[App] Error during user content sync:', error)
|
console.error('[App] Error during user content sync:', error)
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user