sync

Documentation

Overview

Package sync converts libgm events into store rows. The Pump is meant to be registered as an EventHandler on gm.Client. All persistence work runs inline on the libgm callback goroutine — SQLite writes against a local file are fast enough that this hasn't been measured to be a bottleneck. If it ever becomes one, swap Handle for a buffered-channel pump without changing the public interface.

Index

• type Pump
  • func New(st *store.Store, logger zerolog.Logger) *Pump
  • func (p *Pump) Fatal() <-chan error
  • func (p *Pump) Handle(evt any)
  • func (p *Pump) ImportContacts(ctx context.Context, contacts []*gmproto.Contact) int
  • func (p *Pump) ImportMessages(ctx context.Context, messages []*gmproto.Message) int

Types

type Pump

type Pump struct {
	// contains filtered or unexported fields
}

Pump owns the conversion of libgm events into store writes.

func New

func New(st *store.Store, logger zerolog.Logger) *Pump

New constructs a Pump that writes into st.

func (*Pump) Fatal

func (p *Pump) Fatal() <-chan error

Fatal returns a channel that receives terminal connection/auth errors. Long-running commands should select on this and exit non-zero so supervisors can restart or alert instead of silently idling after libgm gives up.

func (*Pump) Handle

func (p *Pump) Handle(evt any)

Handle is the entry point registered with gm.Client.Subscribe. It must not block; errors are logged but do not propagate.

func (*Pump) ImportContacts

func (p *Pump) ImportContacts(ctx context.Context, contacts []*gmproto.Contact) int

ImportContacts persists a full contact-list response from libgm.

func (*Pump) ImportMessages

func (p *Pump) ImportMessages(ctx context.Context, messages []*gmproto.Message) int

ImportMessages persists message-history rows fetched on demand. These are marked old so they don't advance the live-event freshness timestamp.