Skip to content
Snippets Groups Projects
Commit 0408196c authored by Josh Brooks's avatar Josh Brooks
Browse files

Revert ud/ Manager constructors to pass in a Comms interface

parent 943f65e8
Branches
Tags
2 merge requests!510Release,!260made ud package use e2e.ReceptionID
......@@ -82,11 +82,11 @@ var udCmd = &cobra.Command{
// Make user discovery manager
rng := client.GetRng()
userToRegister := viper.GetString("register")
userDiscoveryMgr, err := ud.NewManager(client,
userDiscoveryMgr, err := ud.NewManager(client, client.GetComms(),
client.NetworkFollowerStatus, userToRegister, nil)
if err != nil {
if strings.Contains(err.Error(), ud.IsRegisteredErr) {
userDiscoveryMgr, err = ud.LoadManager(client)
userDiscoveryMgr, err = ud.LoadManager(client, client.GetComms())
if err != nil {
jww.FATAL.Panicf("Failed to load UD manager: %+v", err)
}
......
package ud
import (
"gitlab.com/elixxir/client/cmix"
"gitlab.com/elixxir/client/e2e"
"gitlab.com/elixxir/client/event"
"gitlab.com/elixxir/client/single"
......@@ -21,10 +22,9 @@ type CMix interface {
// relevant to what is used in this package.
type E2E interface {
GetReceptionIdentity() xxdk.ReceptionIdentity
GetCmix() CMix
GetCmix() cmix.Client
GetE2E() e2e.Handler
GetEventReporter() event.Reporter
GetComms() Comms
GetRng() *fastRNG.StreamGenerator
GetStorage() storage.Session
GetTransmissionIdentity() xxdk.TransmissionIdentity
......
......@@ -74,7 +74,7 @@ type Manager struct {
// It requires that an updated
// NDF is available and will error if one is not.
// registrationValidationSignature may be set to nil
func NewManager(e2e E2E, follower NetworkStatus,
func NewManager(e2e E2E, comms Comms, follower NetworkStatus,
username string, registrationValidationSignature []byte) (*Manager, error) {
jww.INFO.Println("ud.NewManager()")
......@@ -88,7 +88,7 @@ func NewManager(e2e E2E, follower NetworkStatus,
network: e2e.GetCmix(),
e2e: e2e,
events: e2e.GetEventReporter(),
comms: e2e.GetComms(),
comms: comms,
kv: e2e.GetStorage().GetKV(),
rng: e2e.GetRng(),
registrationValidationSignature: registrationValidationSignature,
......@@ -133,7 +133,7 @@ func NewManager(e2e E2E, follower NetworkStatus,
// NewManagerFromBackup builds a new user discover manager from a backup.
// It will construct a manager that is already registered and restore
// already registered facts into store.
func NewManagerFromBackup(e2e E2E, follower NetworkStatus,
func NewManagerFromBackup(e2e E2E, comms Comms, follower NetworkStatus,
email, phone fact.Fact) (*Manager, error) {
jww.INFO.Println("ud.NewManagerFromBackup()")
if follower() != xxdk.Running {
......@@ -147,7 +147,7 @@ func NewManagerFromBackup(e2e E2E, follower NetworkStatus,
network: e2e.GetCmix(),
e2e: e2e,
events: e2e.GetEventReporter(),
comms: e2e.GetComms(),
comms: comms,
kv: e2e.GetStorage().GetKV(),
rng: e2e.GetRng(),
}
......@@ -212,13 +212,13 @@ func InitStoreFromBackup(kv *versioned.KV,
// LoadManager loads the state of the Manager
// from disk. This is meant to be called after any the first
// instantiation of the manager by NewUserDiscovery.
func LoadManager(e2e E2E) (*Manager, error) {
func LoadManager(e2e E2E, comms Comms) (*Manager, error) {
m := &Manager{
network: e2e.GetCmix(),
e2e: e2e,
events: e2e.GetEventReporter(),
comms: e2e.GetComms(),
comms: comms,
rng: e2e.GetRng(),
kv: e2e.GetStorage().GetKV(),
}
......
......@@ -3,6 +3,7 @@ package ud
import (
"github.com/cloudflare/circl/dh/sidh"
"gitlab.com/elixxir/client/catalog"
"gitlab.com/elixxir/client/cmix"
"gitlab.com/elixxir/client/cmix/message"
"gitlab.com/elixxir/client/e2e"
"gitlab.com/elixxir/client/e2e/ratchet/partner"
......@@ -78,11 +79,7 @@ func (m mockE2e) GetEventReporter() event.Reporter {
return mockReporter{}
}
func (m mockE2e) GetComms() Comms {
return &mockComms{}
}
func (m mockE2e) GetCmix() CMix {
func (m mockE2e) GetCmix() cmix.Client {
//TODO implement me
panic("implement me")
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment