mirror of
https://github.com/status-im/status-go.git
synced 2026-08-31 09:01:16 +00:00
Igor Sirotin
f9cc782a6f
Part of the Go project layout migration, item 31. Pure move plus import-path rewrite across 687 files. No API or behaviour change. The services keep their grouping under pkg/services/<name> rather than being promoted to pkg/<name>: 27 top-level directories in pkg/ would read worse than what we have, and the grouping is what makes "an RPC service" identifiable at a glance. Paths that follow the move: the logosstorage test target and generate step, the two wallet token-list tools, the migration-order check (and the pre-rebase hook symlinked to it), and the storage env helper. refs #7067
108 lines
2.6 KiB
Go
108 lines
2.6 KiB
Go
package pairing
|
|
|
|
import (
|
|
"crypto/ecdsa"
|
|
"crypto/elliptic"
|
|
"crypto/rand"
|
|
"crypto/tls"
|
|
"net"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/status-im/status-go/internal/httpserver"
|
|
"github.com/status-im/status-go/internal/protocol/common"
|
|
)
|
|
|
|
type TestPairingServerComponents struct {
|
|
EphemeralPK *ecdsa.PrivateKey
|
|
EphemeralAES []byte
|
|
IPAddresses []net.IP
|
|
Cert tls.Certificate
|
|
SS *SenderServer
|
|
RS *ReceiverServer
|
|
}
|
|
|
|
func (tpsc *TestPairingServerComponents) SetupPairingServerComponents(t *testing.T) {
|
|
var err error
|
|
|
|
// Get 4 key components for tls.cert generation
|
|
// 1) Ephemeral private key
|
|
tpsc.EphemeralPK, err = ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
|
|
require.NoError(t, err)
|
|
|
|
// 2) AES encryption key
|
|
tpsc.EphemeralAES, err = common.MakeECDHSharedKey(tpsc.EphemeralPK, &tpsc.EphemeralPK.PublicKey)
|
|
require.NoError(t, err)
|
|
|
|
// 3) Device IP address
|
|
tpsc.IPAddresses, err = httpserver.GetLocalAddressesForPairingServer()
|
|
require.NoError(t, err)
|
|
|
|
// Generate tls.Certificate and Server
|
|
tpsc.Cert, _, err = GenerateCertFromKey(tpsc.EphemeralPK, time.Now(), tpsc.IPAddresses, []string{})
|
|
require.NoError(t, err)
|
|
|
|
sc := &ServerConfig{
|
|
PK: &tpsc.EphemeralPK.PublicKey,
|
|
EK: tpsc.EphemeralAES,
|
|
Cert: &tpsc.Cert,
|
|
IPAddresses: tpsc.IPAddresses,
|
|
ListenIP: net.IPv4zero,
|
|
}
|
|
|
|
tpsc.SS, err = NewSenderServer(nil, &SenderServerConfig{ServerConfig: sc, SenderConfig: &SenderConfig{}})
|
|
require.NoError(t, err)
|
|
tpsc.RS, err = NewReceiverServer(nil, &ReceiverServerConfig{
|
|
ServerConfig: sc,
|
|
ReceiverConfig: &ReceiverConfig{},
|
|
})
|
|
require.NoError(t, err)
|
|
}
|
|
|
|
type MockPayloadReceiver struct {
|
|
encryptor *PayloadEncryptor
|
|
}
|
|
|
|
func NewMockPayloadReceiver(aesKey []byte) *MockPayloadReceiver {
|
|
return &MockPayloadReceiver{NewPayloadEncryptor(aesKey)}
|
|
}
|
|
|
|
func (m *MockPayloadReceiver) Receive(data []byte) error {
|
|
return m.encryptor.decrypt(data)
|
|
}
|
|
|
|
func (m *MockPayloadReceiver) Received() []byte {
|
|
return m.encryptor.getDecrypted()
|
|
}
|
|
|
|
func (m *MockPayloadReceiver) LockPayload() {}
|
|
|
|
type MockPayloadMounter struct {
|
|
encryptor *PayloadEncryptor
|
|
}
|
|
|
|
func NewMockPayloadMounter(aesKey []byte) *MockPayloadMounter {
|
|
return &MockPayloadMounter{NewPayloadEncryptor(aesKey)}
|
|
}
|
|
|
|
func (m *MockPayloadMounter) Mount() error {
|
|
// Make a random payload
|
|
data := make([]byte, 32)
|
|
_, err := rand.Read(data)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return m.encryptor.encrypt(data)
|
|
}
|
|
|
|
func (m *MockPayloadMounter) ToSend() []byte {
|
|
return m.encryptor.getEncrypted()
|
|
}
|
|
|
|
func (m *MockPayloadMounter) LockPayload() {
|
|
m.encryptor.lockPayload()
|
|
}
|