Skip to content
Snippets Groups Projects
Commit 79485048 authored by Benjamin Wenger's avatar Benjamin Wenger
Browse files

Merge remote-tracking branch 'origin/restructure' into restructure

parents 7d0373ae 82d7c69b
No related branches found
No related tags found
3 merge requests!510Release,!207WIP: Client Restructure,!203Symmetric broadcast
package e2e package e2e
import ( import (
"encoding/json"
"github.com/pkg/errors"
"gitlab.com/elixxir/client/catalog" "gitlab.com/elixxir/client/catalog"
"gitlab.com/elixxir/client/e2e/parse" "gitlab.com/elixxir/client/e2e/parse"
"gitlab.com/elixxir/client/e2e/ratchet" "gitlab.com/elixxir/client/e2e/ratchet"
...@@ -31,12 +33,26 @@ type manager struct { ...@@ -31,12 +33,26 @@ type manager struct {
rekeyParams rekey.Params rekeyParams rekey.Params
} }
const e2eRekeyParamsKey = "e2eRekeyParams"
const e2eRekeyParamsVer = 0
// Init Creates stores. After calling, use load // Init Creates stores. After calling, use load
// Passes a default ID and public key which is used for relationship with // Passes a default ID and public key which is used for relationship with
// partners when no default ID is selected // partners when no default ID is selected
func Init(kv *versioned.KV, myDefaultID *id.ID, privKey *cyclic.Int, func Init(kv *versioned.KV, myDefaultID *id.ID, privKey *cyclic.Int,
grp *cyclic.Group, rekeyParams rekey.Params) error { grp *cyclic.Group, rekeyParams rekey.Params) error {
//store rekey params here rekeyParamsData, err := json.Marshal(rekeyParams)
if err != nil {
return errors.WithMessage(err, "Failed to marshal rekeyParams")
}
err = kv.Set(e2eRekeyParamsKey, e2eRekeyParamsVer, &versioned.Object{
Version: e2eRekeyParamsVer,
Timestamp: time.Now(),
Data: rekeyParamsData,
})
if err != nil {
return errors.WithMessage(err, "Failed to save rekeyParams")
}
return ratchet.New(kv, myDefaultID, privKey, grp) return ratchet.New(kv, myDefaultID, privKey, grp)
} }
...@@ -54,6 +70,7 @@ func Load(kv *versioned.KV, net network.Manager, myDefaultID *id.ID, ...@@ -54,6 +70,7 @@ func Load(kv *versioned.KV, net network.Manager, myDefaultID *id.ID,
myDefaultID: myDefaultID, myDefaultID: myDefaultID,
events: events, events: events,
grp: grp, grp: grp,
rekeyParams: rekey.Params{},
} }
var err error var err error
...@@ -65,6 +82,14 @@ func Load(kv *versioned.KV, net network.Manager, myDefaultID *id.ID, ...@@ -65,6 +82,14 @@ func Load(kv *versioned.KV, net network.Manager, myDefaultID *id.ID,
} }
//load rekey params here //load rekey params here
rekeyParams, err := kv.Get(e2eRekeyParamsKey, e2eRekeyParamsVer)
if err != nil {
return nil, errors.WithMessage(err, "Failed to load rekeyParams")
}
err = json.Unmarshal(rekeyParams.Data, &m.rekeyParams)
if err != nil {
return nil, errors.WithMessage(err, "Failed to unmarshal rekeyParams data")
}
//attach critical messages //attach critical messages
m.crit = newCritical(kv, net.AddHealthCallback, m.crit = newCritical(kv, net.AddHealthCallback,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment