mirror of
https://github.com/status-im/go-waku.git
synced 2025-02-04 09:55:08 +00:00
3d8aae5b81
- Partially implements #20. Requires some tests - Extracts wakurelay code to separate file - Extracts request id gen to separate file - Initial implementation of lightpush protocol - Adds utils functions to obtain a message hash - Publish receives a context to send a message
46 lines
900 B
Go
46 lines
900 B
Go
package protocol
|
|
|
|
import (
|
|
"crypto/rand"
|
|
"sync"
|
|
|
|
"github.com/cruxic/go-hmac-drbg/hmacdrbg"
|
|
logging "github.com/ipfs/go-log"
|
|
)
|
|
|
|
var log = logging.Logger("request-gen")
|
|
|
|
var brHmacDrbgPool = sync.Pool{New: func() interface{} {
|
|
seed := make([]byte, 48)
|
|
_, err := rand.Read(seed)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
return hmacdrbg.NewHmacDrbg(256, seed, nil)
|
|
}}
|
|
|
|
func GenerateRequestId() []byte {
|
|
rng := brHmacDrbgPool.Get().(*hmacdrbg.HmacDrbg)
|
|
defer brHmacDrbgPool.Put(rng)
|
|
|
|
randData := make([]byte, 32)
|
|
if !rng.Generate(randData) {
|
|
//Reseed is required every 10,000 calls
|
|
seed := make([]byte, 48)
|
|
_, err := rand.Read(seed)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
err = rng.Reseed(seed)
|
|
if err != nil {
|
|
//only happens if seed < security-level
|
|
log.Fatal(err)
|
|
}
|
|
|
|
if !rng.Generate(randData) {
|
|
log.Error("could not generate random request id")
|
|
}
|
|
}
|
|
return randData
|
|
}
|