mirror of
https://dev.azure.com/schwarzit/schwarzit.stackit-public/_git/audit-go
synced 2026-02-08 17:17:25 +00:00
105 lines
3.1 KiB
Go
105 lines
3.1 KiB
Go
package api
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"github.com/stretchr/testify/assert"
|
|
"testing"
|
|
)
|
|
|
|
func Test_ToBase64(t *testing.T) {
|
|
|
|
t.Run("cloud event nil", func(t *testing.T) {
|
|
var cloudEvent *CloudEvent = nil
|
|
routableIdentifier := RoutableSystemIdentifier
|
|
operation := "organization.create"
|
|
|
|
base64str, err := ToBase64(cloudEvent, routableIdentifier, operation)
|
|
assert.ErrorIs(t, err, ErrCloudEventNil)
|
|
assert.Nil(t, base64str)
|
|
})
|
|
|
|
t.Run("routable identifier nil", func(t *testing.T) {
|
|
cloudEvent := &CloudEvent{}
|
|
var routableIdentifier *RoutableIdentifier = nil
|
|
operation := "organization.create"
|
|
|
|
base64str, err := ToBase64(cloudEvent, routableIdentifier, operation)
|
|
assert.ErrorIs(t, err, ErrRoutableIdentifierNil)
|
|
assert.Nil(t, base64str)
|
|
})
|
|
|
|
t.Run("Operation empty", func(t *testing.T) {
|
|
cloudEvent := &CloudEvent{}
|
|
routableIdentifier := RoutableSystemIdentifier
|
|
operation := ""
|
|
|
|
base64str, err := ToBase64(cloudEvent, routableIdentifier, operation)
|
|
assert.ErrorIs(t, err, ErrOperationEmpty)
|
|
assert.Nil(t, base64str)
|
|
})
|
|
|
|
t.Run("encoded event", func(t *testing.T) {
|
|
e := &CloudEvent{}
|
|
r := RoutableSystemIdentifier
|
|
o := "organization.create"
|
|
base64str, err := ToBase64(e, r, o)
|
|
assert.NoError(t, err)
|
|
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64(*base64str)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, e, cloudEvent)
|
|
assert.Equal(t, r, routableIdentifier)
|
|
assert.Equal(t, o, *operation)
|
|
})
|
|
}
|
|
|
|
func Test_FromBase64(t *testing.T) {
|
|
|
|
t.Run("empty string", func(t *testing.T) {
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64("")
|
|
assert.ErrorIs(t, err, ErrBase64StringEmpty)
|
|
assert.Nil(t, cloudEvent)
|
|
assert.Nil(t, routableIdentifier)
|
|
assert.Nil(t, operation)
|
|
})
|
|
|
|
t.Run("without version suffix", func(t *testing.T) {
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64("ey")
|
|
assert.ErrorIs(t, err, ErrUnsupportedBase64StringVersion)
|
|
assert.Nil(t, cloudEvent)
|
|
assert.Nil(t, routableIdentifier)
|
|
assert.Nil(t, operation)
|
|
})
|
|
|
|
t.Run("no base64 string", func(t *testing.T) {
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64("no base 64 v1")
|
|
assert.EqualError(t, err, "illegal base64 data at input byte 2")
|
|
assert.Nil(t, cloudEvent)
|
|
assert.Nil(t, routableIdentifier)
|
|
assert.Nil(t, operation)
|
|
})
|
|
|
|
t.Run("no json serialized event", func(t *testing.T) {
|
|
base64Str := base64.StdEncoding.EncodeToString([]byte("not expected"))
|
|
base64Str = base64Str + "v1"
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64(base64Str)
|
|
assert.EqualError(t, err, "invalid character 'o' in literal null (expecting 'u')")
|
|
assert.Nil(t, cloudEvent)
|
|
assert.Nil(t, routableIdentifier)
|
|
assert.Nil(t, operation)
|
|
})
|
|
|
|
t.Run("decoded event", func(t *testing.T) {
|
|
e := &CloudEvent{}
|
|
r := RoutableSystemIdentifier
|
|
o := "organization.create"
|
|
base64str, err := ToBase64(e, r, o)
|
|
assert.NoError(t, err)
|
|
|
|
cloudEvent, routableIdentifier, operation, err := FromBase64(*base64str)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, e, cloudEvent)
|
|
assert.Equal(t, r, routableIdentifier)
|
|
assert.Equal(t, o, *operation)
|
|
})
|
|
}
|