Skip to content
Snippets Groups Projects
Commit 205aa30f authored by Jonah Husson's avatar Jonah Husson
Browse files

update all ephemerals

parent 3c815f86
No related branches found
No related tags found
1 merge request!2update all ephemerals
......@@ -3,6 +3,7 @@ package storage
import (
"fmt"
"github.com/pkg/errors"
jww "github.com/spf13/jwalterweatherman"
"gitlab.com/elixxir/crypto/hash"
"gitlab.com/xx_network/primitives/id/ephemeral"
"time"
......@@ -69,12 +70,12 @@ func (s *Storage) DeleteUser(transmissionRSA []byte) error {
}
func (s *Storage) AddEphemeralsForOffset(offset int64, epoch int32, size uint) error {
users, err := s.getUsersByOffset(offset)
users, err := s.GetAllUsers()
if err != nil {
return errors.WithMessage(err, "Failed to get users for given offset")
}
if len(users) > 0 {
fmt.Println(fmt.Sprintf("Adding ephemerals for users: %+v", users))
jww.INFO.Println(fmt.Sprintf("Adding ephemerals for users: %+v", users))
}
for _, u := range users {
eid, _, _, err := ephemeral.GetIdFromIntermediary(u.IntermediaryId, size, time.Now().UnixNano())
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment