mirror of
https://github.com/tailscale/tailscale.git
synced 2025-06-30 12:08:46 +00:00
183 lines
4.0 KiB
Go
183 lines
4.0 KiB
Go
// Copyright (c) Tailscale Inc & AUTHORS
|
|
// SPDX-License-Identifier: BSD-3-Clause
|
|
|
|
package tpm
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/rand"
|
|
"errors"
|
|
"path/filepath"
|
|
"strconv"
|
|
"testing"
|
|
|
|
"tailscale.com/ipn"
|
|
"tailscale.com/ipn/store"
|
|
)
|
|
|
|
func TestPropToString(t *testing.T) {
|
|
for prop, want := range map[uint32]string{
|
|
0: "",
|
|
0x4D534654: "MSFT",
|
|
0x414D4400: "AMD",
|
|
0x414D440D: "AMD",
|
|
} {
|
|
if got := propToString(prop); got != want {
|
|
t.Errorf("propToString(0x%x): got %q, want %q", prop, got, want)
|
|
}
|
|
}
|
|
}
|
|
|
|
func skipWithoutTPM(t testing.TB) {
|
|
tpm, err := open()
|
|
if err != nil {
|
|
t.Skip("TPM not available")
|
|
}
|
|
tpm.Close()
|
|
}
|
|
|
|
func TestSealUnseal(t *testing.T) {
|
|
skipWithoutTPM(t)
|
|
|
|
data := make([]byte, 100*1024)
|
|
rand.Read(data)
|
|
var key [32]byte
|
|
rand.Read(key[:])
|
|
|
|
sealed, err := seal(t.Logf, decryptedData{Key: key, Data: data})
|
|
if err != nil {
|
|
t.Fatalf("seal: %v", err)
|
|
}
|
|
if bytes.Contains(sealed.Data, data) {
|
|
t.Fatalf("sealed data %q contains original input %q", sealed.Data, data)
|
|
}
|
|
|
|
unsealed, err := unseal(t.Logf, *sealed)
|
|
if err != nil {
|
|
t.Fatalf("unseal: %v", err)
|
|
}
|
|
if !bytes.Equal(data, unsealed.Data) {
|
|
t.Errorf("got unsealed data: %q, want: %q", unsealed, data)
|
|
}
|
|
if key != unsealed.Key {
|
|
t.Errorf("got unsealed key: %q, want: %q", unsealed.Key, key)
|
|
}
|
|
}
|
|
|
|
func TestStore(t *testing.T) {
|
|
skipWithoutTPM(t)
|
|
|
|
path := storePrefix + filepath.Join(t.TempDir(), "state")
|
|
store, err := newStore(t.Logf, path)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
checkState := func(t *testing.T, store ipn.StateStore, k ipn.StateKey, want []byte) {
|
|
got, err := store.ReadState(k)
|
|
if err != nil {
|
|
t.Errorf("ReadState(%q): %v", k, err)
|
|
}
|
|
if !bytes.Equal(want, got) {
|
|
t.Errorf("ReadState(%q): got %q, want %q", k, got, want)
|
|
}
|
|
}
|
|
|
|
k1, k2 := ipn.StateKey("k1"), ipn.StateKey("k2")
|
|
v1, v2 := []byte("v1"), []byte("v2")
|
|
|
|
t.Run("read-non-existent-key", func(t *testing.T) {
|
|
_, err := store.ReadState(k1)
|
|
if !errors.Is(err, ipn.ErrStateNotExist) {
|
|
t.Errorf("ReadState succeeded, want %v", ipn.ErrStateNotExist)
|
|
}
|
|
})
|
|
|
|
t.Run("read-write-k1", func(t *testing.T) {
|
|
if err := store.WriteState(k1, v1); err != nil {
|
|
t.Errorf("WriteState(%q, %q): %v", k1, v1, err)
|
|
}
|
|
checkState(t, store, k1, v1)
|
|
})
|
|
|
|
t.Run("read-write-k2", func(t *testing.T) {
|
|
if err := store.WriteState(k2, v2); err != nil {
|
|
t.Errorf("WriteState(%q, %q): %v", k2, v2, err)
|
|
}
|
|
checkState(t, store, k2, v2)
|
|
})
|
|
|
|
t.Run("update-k2", func(t *testing.T) {
|
|
v2 = []byte("new v2")
|
|
if err := store.WriteState(k2, v2); err != nil {
|
|
t.Errorf("WriteState(%q, %q): %v", k2, v2, err)
|
|
}
|
|
checkState(t, store, k2, v2)
|
|
})
|
|
|
|
t.Run("reopen-store", func(t *testing.T) {
|
|
store, err := newStore(t.Logf, path)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
checkState(t, store, k1, v1)
|
|
checkState(t, store, k2, v2)
|
|
})
|
|
}
|
|
|
|
func BenchmarkStore(b *testing.B) {
|
|
skipWithoutTPM(b)
|
|
b.StopTimer()
|
|
|
|
stores := make(map[string]ipn.StateStore)
|
|
key := ipn.StateKey(b.Name())
|
|
|
|
// Set up tpmStore
|
|
tpmStore, err := newStore(b.Logf, filepath.Join(b.TempDir(), "tpm.store"))
|
|
if err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
if err := tpmStore.WriteState(key, []byte("-1")); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
stores["tpmStore"] = tpmStore
|
|
|
|
// Set up FileStore
|
|
fileStore, err := store.NewFileStore(b.Logf, filepath.Join(b.TempDir(), "file.store"))
|
|
if err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
if err := fileStore.WriteState(key, []byte("-1")); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
stores["fileStore"] = fileStore
|
|
|
|
b.StartTimer()
|
|
|
|
for name, store := range stores {
|
|
b.Run(name, func(b *testing.B) {
|
|
b.Run("write-noop", func(b *testing.B) {
|
|
for range b.N {
|
|
if err := store.WriteState(key, []byte("-1")); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
}
|
|
})
|
|
b.Run("write", func(b *testing.B) {
|
|
for i := range b.N {
|
|
if err := store.WriteState(key, []byte(strconv.Itoa(i))); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
}
|
|
})
|
|
b.Run("read", func(b *testing.B) {
|
|
for range b.N {
|
|
if _, err := store.ReadState(key); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
}
|
|
})
|
|
})
|
|
}
|
|
}
|