v1.14.1 -> v1.16.0, no more *stores.EventReady event?

[mrusme]

I'm experiencing an issue in one of my projects, in which I've upgraded from v1.14.1 to v1.15.1 and I don't seem to be getting the *stores.EventReady event anymore from the documentstore that I'm using.

Did something change / is there a replacement for this event? Thank you.

[mrusme]

Just tried v1.16.0 and it's the same, the application won't start because it looks like the stores.EventReady event won't show up. I quickly checked the go-orbit-db code and it seems the event is still present. Has something else changed that would require initializing the database differently in order for it to become ready?

Appreciate any help here.

[gfanton]

@mrusme sorry for the delay, i've update the event system in favor of https://github.com/libp2p/go-eventbus you should use EventBus instead of the deprecated Subscribe method. Also Events doesn't have pointer anymore, so you should update *stores.EventReady to stores.EventReady

usage example:

go-orbit-db/tests/persistence_test.go

Lines 163 to 201 in 07c8fba

	t.Run("loading a database emits 'ready' event", func(t *testing.T) {
	defer setup(t)()
	db, err := orbitdb1.Log(ctx, address.String(), nil)
	require.NoError(t, err)
	l := sync.RWMutex{}
	var items []operation.Operation
	ctx, cancel := context.WithTimeout(ctx, time.Second*5)
	defer cancel()
	sub, err := db.EventBus().Subscribe(new(stores.EventReady))
	require.NoError(t, err)
	defer sub.Close()
	go func() {
	for evt := range sub.Out() {
	switch evt.(type) {
	case stores.EventReady:
	l.Lock()
	items, err = db.List(ctx, &orbitdb.StreamOptions{Amount: &infinity})
	l.Unlock()
	cancel()
	continue
	}
	}
	}()
	require.Nil(t, db.Load(ctx, infinity))
	<-ctx.Done()
	l.RLock()
	require.Equal(t, len(items), entryCount)
	require.Equal(t, string(items[0].GetValue()), "hello0")
	require.Equal(t, string(items[len(items)-1].GetValue()), fmt.Sprintf("hello%d", entryCount-1))
	l.RUnlock()
	})

GitHub

GitHub - libp2p/go-eventbus: a simple and fast eventbus for type-based local event delivery.

a simple and fast eventbus for type-based local event delivery. - GitHub - libp2p/go-eventbus: a simple and fast eventbus for type-based local event delivery.

[mrusme]

Thank you, that was the info I needed. Upgrade has worked and the EventReady event is now firing. Appreciate it!