cui fliter
35f4265a4b
For golang/go#45557 Change-Id: I447530cc66896aef7a8d528ccb8d095b80e3cf47 GitHub-Last-Rev: 5f385ff46487ac318bd1147cdbbd26bb0ffd0426 GitHub-Pull-Request: golang/crypto#230 Reviewed-on: https://go-review.googlesource.com/c/crypto/+/430797 Auto-Submit: Ian Lance Taylor <iant@google.com> Reviewed-by: Ian Lance Taylor <iant@google.com> Reviewed-by: Meng Zhuo <mzh@golangcn.org> Run-TryBot: Ian Lance Taylor <iant@google.com> TryBot-Result: Gopher Robot <gobot@golang.org> Reviewed-by: Cherry Mui <cherryyz@google.com>
123 lines
2.7 KiB
Go
123 lines
2.7 KiB
Go
// Copyright 2011 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package packet
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/sha1"
|
|
"encoding/hex"
|
|
"golang.org/x/crypto/openpgp/errors"
|
|
"io"
|
|
"testing"
|
|
)
|
|
|
|
// TestReader wraps a []byte and returns reads of a specific length.
|
|
type testReader struct {
|
|
data []byte
|
|
stride int
|
|
}
|
|
|
|
func (t *testReader) Read(buf []byte) (n int, err error) {
|
|
n = t.stride
|
|
if n > len(t.data) {
|
|
n = len(t.data)
|
|
}
|
|
if n > len(buf) {
|
|
n = len(buf)
|
|
}
|
|
copy(buf, t.data)
|
|
t.data = t.data[n:]
|
|
if len(t.data) == 0 {
|
|
err = io.EOF
|
|
}
|
|
return
|
|
}
|
|
|
|
func testMDCReader(t *testing.T) {
|
|
mdcPlaintext, _ := hex.DecodeString(mdcPlaintextHex)
|
|
|
|
for stride := 1; stride < len(mdcPlaintext)/2; stride++ {
|
|
r := &testReader{data: mdcPlaintext, stride: stride}
|
|
mdcReader := &seMDCReader{in: r, h: sha1.New()}
|
|
body, err := io.ReadAll(mdcReader)
|
|
if err != nil {
|
|
t.Errorf("stride: %d, error: %s", stride, err)
|
|
continue
|
|
}
|
|
if !bytes.Equal(body, mdcPlaintext[:len(mdcPlaintext)-22]) {
|
|
t.Errorf("stride: %d: bad contents %x", stride, body)
|
|
continue
|
|
}
|
|
|
|
err = mdcReader.Close()
|
|
if err != nil {
|
|
t.Errorf("stride: %d, error on Close: %s", stride, err)
|
|
}
|
|
}
|
|
|
|
mdcPlaintext[15] ^= 80
|
|
|
|
r := &testReader{data: mdcPlaintext, stride: 2}
|
|
mdcReader := &seMDCReader{in: r, h: sha1.New()}
|
|
_, err := io.ReadAll(mdcReader)
|
|
if err != nil {
|
|
t.Errorf("corruption test, error: %s", err)
|
|
return
|
|
}
|
|
err = mdcReader.Close()
|
|
if err == nil {
|
|
t.Error("corruption: no error")
|
|
} else if _, ok := err.(*errors.SignatureError); !ok {
|
|
t.Errorf("corruption: expected SignatureError, got: %s", err)
|
|
}
|
|
}
|
|
|
|
const mdcPlaintextHex = "a302789c3b2d93c4e0eb9aba22283539b3203335af44a134afb800c849cb4c4de10200aff40b45d31432c80cb384299a0655966d6939dfdeed1dddf980"
|
|
|
|
func TestSerialize(t *testing.T) {
|
|
buf := bytes.NewBuffer(nil)
|
|
c := CipherAES128
|
|
key := make([]byte, c.KeySize())
|
|
|
|
w, err := SerializeSymmetricallyEncrypted(buf, c, key, nil)
|
|
if err != nil {
|
|
t.Errorf("error from SerializeSymmetricallyEncrypted: %s", err)
|
|
return
|
|
}
|
|
|
|
contents := []byte("hello world\n")
|
|
|
|
w.Write(contents)
|
|
w.Close()
|
|
|
|
p, err := Read(buf)
|
|
if err != nil {
|
|
t.Errorf("error from Read: %s", err)
|
|
return
|
|
}
|
|
|
|
se, ok := p.(*SymmetricallyEncrypted)
|
|
if !ok {
|
|
t.Errorf("didn't read a *SymmetricallyEncrypted")
|
|
return
|
|
}
|
|
|
|
r, err := se.Decrypt(c, key)
|
|
if err != nil {
|
|
t.Errorf("error from Decrypt: %s", err)
|
|
return
|
|
}
|
|
|
|
contentsCopy := bytes.NewBuffer(nil)
|
|
_, err = io.Copy(contentsCopy, r)
|
|
if err != nil {
|
|
t.Errorf("error from io.Copy: %s", err)
|
|
return
|
|
}
|
|
if !bytes.Equal(contentsCopy.Bytes(), contents) {
|
|
t.Errorf("contents not equal got: %x want: %x", contentsCopy.Bytes(), contents)
|
|
}
|
|
}
|