Class SyncManager

Sync Manager

Coordinates background synchronization:

Periodically fetches new messages
Processes the send queue when online
Tracks online/offline state

Index

Constructors

Accessors

currentState online sendQueue

Methods

addConversation getConversation getConversations getOrCreateConversation on processQueue queueMessage setEvents setOnline start stop sync syncConversation

Constructors

constructor

new SyncManager(
    service: AlgorandService,
    chatAccount: ChatAccount,
    queue?: SendQueue,
    config?: SyncManagerConfig,
): SyncManager
Parameters
- service: AlgorandService
- chatAccount: ChatAccount
- queue: SendQueue = ...
- config: SyncManagerConfig = {}
Returns SyncManager
- Defined in src/queue/SyncManager.ts:60

Accessors

currentState

get currentState(): SyncState
Gets the current sync state

Returns SyncState
- Defined in src/queue/SyncManager.ts:349

online

get online(): boolean
Gets whether we're online

Returns boolean
- Defined in src/queue/SyncManager.ts:356

sendQueue

get sendQueue(): SendQueue
Gets the send queue

Returns SendQueue
- Defined in src/queue/SyncManager.ts:363

Methods

addConversation

addConversation(conversation: Conversation): void
Adds a conversation
Parameters
- conversation: Conversation
  Conversation to add
Returns void
- Defined in src/queue/SyncManager.ts:322

getConversation

getConversation(participant: string): Conversation | undefined
Gets a conversation if it exists
Parameters
- participant: string
  Address of the participant
Returns Conversation | undefined
- Defined in src/queue/SyncManager.ts:306

getConversations

getConversations(): Conversation[]
Gets all conversations

Returns Conversation[]
- Defined in src/queue/SyncManager.ts:313

getOrCreateConversation

getOrCreateConversation(participant: string): Conversation
Gets or creates a conversation
Parameters
- participant: string
  Address of the participant
Returns Conversation
- Defined in src/queue/SyncManager.ts:292

on

on<K extends keyof SyncEvents>(event: K, callback: SyncEvents[K]): void
Sets a single event callback
Type Parameters
- K extends keyof SyncEvents
Parameters
- event: K
- callback: SyncEvents[K]
Returns void
- Defined in src/queue/SyncManager.ts:340

processQueue

processQueue(): Promise<void>
Processes all queued messages

Returns Promise<void>
- Defined in src/queue/SyncManager.ts:243

queueMessage

queueMessage(options: EnqueueOptions): string
Queues a message for sending

Message will be sent when online.
Parameters
- options: EnqueueOptions
  Message options
Returns string
- Defined in src/queue/SyncManager.ts:227

setEvents

setEvents(events: SyncEvents): void
Sets event callbacks
Parameters
- events: SyncEvents
  Event callbacks
Returns void
- Defined in src/queue/SyncManager.ts:333

setOnline

setOnline(online: boolean): void
Sets online/offline state
Parameters
- online: boolean
  Whether we're online
Returns void
- Defined in src/queue/SyncManager.ts:138

start

start(): void
Starts background synchronization

Returns void
- Defined in src/queue/SyncManager.ts:104

stop

stop(): void
Stops background synchronization

Returns void
- Defined in src/queue/SyncManager.ts:126

sync

sync(): Promise<void>
Performs a full sync
- Fetches new messages for all known conversations
- Processes the send queue
Returns Promise<void>
- Defined in src/queue/SyncManager.ts:164

syncConversation

syncConversation(participant: string): Promise<Message[]>
Syncs a specific conversation
Parameters
- participant: string
  Address of the participant
Returns Promise<Message[]>
- Defined in src/queue/SyncManager.ts:189