negentropy: fix one stupid bug and rename Initiate() to Start().

This commit is contained in:
fiatjaf 2024-09-19 15:53:01 -03:00
parent 15aa7ac31e
commit e9e96be95e
4 changed files with 7 additions and 7 deletions

View File

@ -56,7 +56,7 @@ func (n *Negentropy) String() string {
return fmt.Sprintf("<Negentropy %s with %d items>", label, n.storage.Size())
}
func (n *Negentropy) Initiate() string {
func (n *Negentropy) Start() string {
n.initialized = true
n.isClient = true

View File

@ -22,8 +22,8 @@ func New() *Vector {
}
func (v *Vector) Insert(createdAt nostr.Timestamp, id string) error {
if len(id)/2 != 32 {
return fmt.Errorf("bad id size for added item: expected %d, got %d", 32, len(id)/2)
if len(id) != 64 {
return fmt.Errorf("bad id size for added item: expected %d bytes, got %d", 32, len(id)/2)
}
item := negentropy.Item{Timestamp: createdAt, ID: id}

View File

@ -79,12 +79,12 @@ func runTestWith(t *testing.T,
n1 = negentropy.New(n1s, 1<<16)
for _, r := range n1Ranges {
for i := r[0]; i < r[1]; i++ {
n1s.Insert(events[i].CreatedAt, events[1].ID)
n1s.Insert(events[i].CreatedAt, events[i].ID)
}
}
n1s.Seal()
q = n1.Initiate()
q = n1.Start()
}
{
@ -92,7 +92,7 @@ func runTestWith(t *testing.T,
n2 = negentropy.New(n2s, 1<<16)
for _, r := range n2Ranges {
for i := r[0]; i < r[1]; i++ {
n2s.Insert(events[i].CreatedAt, events[1].ID)
n2s.Insert(events[i].CreatedAt, events[i].ID)
}
}
n2s.Seal()

View File

@ -59,7 +59,7 @@ func NegentropySync(ctx context.Context, store nostr.RelayStore, url string, fil
return err
}
msg := neg.Initiate()
msg := neg.Start()
open, _ := OpenEnvelope{id, filter, msg}.MarshalJSON()
err = <-r.Write(open)
if err != nil {