|
|
|
|
@ -183,7 +183,7 @@ func Test_NewEntry(t *testing.T) {
|
|
|
|
|
ticketer,
|
|
|
|
|
)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "error creating entry: entry aggregate name is not set")
|
|
|
|
|
assert.Equal("error creating entry: entry aggregate name is not set", err.Error())
|
|
|
|
|
})
|
|
|
|
|
t.Run("bad cipherer", func(t *testing.T) {
|
|
|
|
|
assert, require := assert.New(t), require.New(t)
|
|
|
|
|
@ -201,7 +201,7 @@ func Test_NewEntry(t *testing.T) {
|
|
|
|
|
ticketer,
|
|
|
|
|
)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "error creating entry: entry Cipherer is nil")
|
|
|
|
|
assert.Equal("error creating entry: entry Cipherer is nil", err.Error())
|
|
|
|
|
})
|
|
|
|
|
t.Run("bad ticket", func(t *testing.T) {
|
|
|
|
|
assert, require := assert.New(t), require.New(t)
|
|
|
|
|
@ -217,7 +217,7 @@ func Test_NewEntry(t *testing.T) {
|
|
|
|
|
nil,
|
|
|
|
|
)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "error creating entry: entry Ticketer is nil")
|
|
|
|
|
assert.Equal("error creating entry: entry Ticketer is nil", err.Error())
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -282,7 +282,7 @@ func Test_UnmarshalData(t *testing.T) {
|
|
|
|
|
entry.Data = queue.Bytes()
|
|
|
|
|
_, err = entry.UnmarshalData(types)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "no Data to unmarshal")
|
|
|
|
|
assert.Equal("no Data to unmarshal", err.Error())
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
t.Run("nil types", func(t *testing.T) {
|
|
|
|
|
@ -307,7 +307,7 @@ func Test_UnmarshalData(t *testing.T) {
|
|
|
|
|
require.NoError(err)
|
|
|
|
|
_, err = entry.UnmarshalData(nil)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "TypeCatalog is nil")
|
|
|
|
|
assert.Equal("TypeCatalog is nil", err.Error())
|
|
|
|
|
})
|
|
|
|
|
|
|
|
|
|
t.Run("missing type", func(t *testing.T) {
|
|
|
|
|
@ -335,7 +335,7 @@ func Test_UnmarshalData(t *testing.T) {
|
|
|
|
|
require.NoError(err)
|
|
|
|
|
_, err = entry.UnmarshalData(types)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "error removing item from queue: error getting the TypeName for Remove: error typeName is not found for Get")
|
|
|
|
|
assert.Equal("error removing item from queue: error getting the TypeName for Remove: error typeName is not found for Get", err.Error())
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -492,11 +492,11 @@ func Test_Replay(t *testing.T) {
|
|
|
|
|
|
|
|
|
|
var foundUser2 oplog_test.TestUser
|
|
|
|
|
err = tx2.Where("id = ?", userCreate2.Id).First(&foundUser2).Error
|
|
|
|
|
assert.Equal(err, gorm.ErrRecordNotFound)
|
|
|
|
|
assert.Equal(gorm.ErrRecordNotFound, err, err.Error())
|
|
|
|
|
|
|
|
|
|
var foundReplayedUser2 oplog_test.TestUser
|
|
|
|
|
err = tx2.Where("id = ?", userCreate2.Id).First(&foundReplayedUser2).Error
|
|
|
|
|
assert.Equal(err, gorm.ErrRecordNotFound)
|
|
|
|
|
assert.Equal(gorm.ErrRecordNotFound, err, err.Error())
|
|
|
|
|
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
@ -572,7 +572,7 @@ func Test_WriteEntryWith(t *testing.T) {
|
|
|
|
|
&Message{Message: &u, TypeName: "user", OpType: OpType_OP_TYPE_CREATE},
|
|
|
|
|
&Message{Message: &u2, TypeName: "user", OpType: OpType_OP_TYPE_CREATE})
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "bad writer")
|
|
|
|
|
assert.Equal("bad writer", err.Error())
|
|
|
|
|
})
|
|
|
|
|
t.Run("nil ticket", func(t *testing.T) {
|
|
|
|
|
assert, require := assert.New(t), require.New(t)
|
|
|
|
|
@ -591,7 +591,7 @@ func Test_WriteEntryWith(t *testing.T) {
|
|
|
|
|
&Message{Message: &u, TypeName: "user", OpType: OpType_OP_TYPE_CREATE},
|
|
|
|
|
&Message{Message: &u2, TypeName: "user", OpType: OpType_OP_TYPE_CREATE})
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "bad ticket")
|
|
|
|
|
assert.Equal("bad ticket", err.Error())
|
|
|
|
|
})
|
|
|
|
|
t.Run("nil ticket", func(t *testing.T) {
|
|
|
|
|
assert, require := assert.New(t), require.New(t)
|
|
|
|
|
@ -608,7 +608,7 @@ func Test_WriteEntryWith(t *testing.T) {
|
|
|
|
|
require.NoError(err)
|
|
|
|
|
err = newLogEntry.WriteEntryWith(context.Background(), &GormWriter{db}, ticket, nil)
|
|
|
|
|
require.Error(err)
|
|
|
|
|
assert.Equal(err.Error(), "bad message")
|
|
|
|
|
assert.Equal("bad message", err.Error())
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|