mirror of
https://github.com/zitadel/zitadel.git
synced 2024-12-13 11:34:26 +00:00
b5564572bc
This implementation increases parallel write capabilities of the eventstore. Please have a look at the technical advisories: [05](https://zitadel.com/docs/support/advisory/a10005) and [06](https://zitadel.com/docs/support/advisory/a10006). The implementation of eventstore.push is rewritten and stored events are migrated to a new table `eventstore.events2`. If you are using cockroach: make sure that the database user of ZITADEL has `VIEWACTIVITY` grant. This is used to query events.
63 lines
1.6 KiB
Go
63 lines
1.6 KiB
Go
package projection
|
|
|
|
import (
|
|
"database/sql"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
"github.com/zitadel/zitadel/internal/errors"
|
|
)
|
|
|
|
type testExecuter struct {
|
|
execIdx int
|
|
executions []execution
|
|
}
|
|
|
|
type execution struct {
|
|
expectedStmt string
|
|
gottenStmt string
|
|
|
|
expectedArgs []interface{}
|
|
gottenArgs []interface{}
|
|
}
|
|
|
|
type anyArg struct{}
|
|
|
|
func (e *testExecuter) Exec(stmt string, args ...interface{}) (sql.Result, error) {
|
|
if stmt == "SAVEPOINT stmt_exec" || stmt == "RELEASE SAVEPOINT stmt_exec" {
|
|
return nil, nil
|
|
}
|
|
|
|
if e.execIdx >= len(e.executions) {
|
|
return nil, errors.ThrowInternal(nil, "PROJE-8TNoE", "too many executions")
|
|
}
|
|
e.executions[e.execIdx].gottenArgs = args
|
|
e.executions[e.execIdx].gottenStmt = stmt
|
|
e.execIdx++
|
|
return nil, nil
|
|
}
|
|
|
|
func (e *testExecuter) Validate(t *testing.T) {
|
|
t.Helper()
|
|
if e.execIdx != len(e.executions) {
|
|
t.Errorf("not all expected execs executed. got: %d, want: %d", e.execIdx, len(e.executions))
|
|
return
|
|
}
|
|
for _, execution := range e.executions {
|
|
if len(execution.gottenArgs) != len(execution.expectedArgs) {
|
|
t.Errorf("wrong arg len expected: %d got: %d", len(execution.expectedArgs), len(execution.gottenArgs))
|
|
} else {
|
|
for i := 0; i < len(execution.expectedArgs); i++ {
|
|
if _, ok := execution.expectedArgs[i].(anyArg); ok {
|
|
continue
|
|
}
|
|
assert.Equal(t, execution.expectedArgs[i], execution.gottenArgs[i], "wrong argument at index %d", i)
|
|
}
|
|
}
|
|
if execution.gottenStmt != execution.expectedStmt {
|
|
t.Errorf("wrong stmt want:\n%s\ngot:\n%s", execution.expectedStmt, execution.gottenStmt)
|
|
}
|
|
}
|
|
}
|