mirror of
https://github.com/zitadel/zitadel.git
synced 2024-12-14 03:54:21 +00:00
bb756482c7
* document analytics config
* rework configuration and docs
* describe HandleActiveInstances better
* describe active instances on quotas better
* only projected events are considered
* cleanup
* describe changes at runtime
* push milestones
* stop tracking events
* calculate and push 4 in 6 milestones
* reduce milestone pushed
* remove docs
* fix scheduled pseudo event projection
* push 5 in 6 milestones
* push 6 in 6 milestones
* ignore client ids
* fix text array contains
* push human readable milestone type
* statement unit tests
* improve dev and db performance
* organize imports
* cleanup
* organize imports
* test projection
* check rows.Err()
* test search query
* pass linting
* review
* test 4 milestones
* simplify milestone by instance ids query
* use type NamespacedCondition
* cleanup
* lint
* lint
* dont overwrite original error
* no opt-in in examples
* cleanup
* prerelease
* enable request headers
* make limit configurable
* review fixes
* only requeue special handlers secondly
* include integration tests
* Revert "include integration tests"
This reverts commit 96db9504ec
.
* pass reducers
* test handlers
* fix unit test
* feat: increment version
* lint
* remove prerelease
* fix integration tests
147 lines
4.0 KiB
Go
147 lines
4.0 KiB
Go
package query
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"time"
|
|
|
|
sq "github.com/Masterminds/squirrel"
|
|
|
|
"github.com/zitadel/zitadel/internal/api/authz"
|
|
"github.com/zitadel/zitadel/internal/api/call"
|
|
"github.com/zitadel/zitadel/internal/errors"
|
|
"github.com/zitadel/zitadel/internal/query/projection"
|
|
"github.com/zitadel/zitadel/internal/repository/milestone"
|
|
"github.com/zitadel/zitadel/internal/telemetry/tracing"
|
|
)
|
|
|
|
type Milestones struct {
|
|
SearchResponse
|
|
Milestones []*Milestone
|
|
}
|
|
|
|
type Milestone struct {
|
|
InstanceID string
|
|
Type milestone.Type
|
|
ReachedDate time.Time
|
|
PushedDate time.Time
|
|
PrimaryDomain string
|
|
}
|
|
|
|
type MilestonesSearchQueries struct {
|
|
SearchRequest
|
|
Queries []SearchQuery
|
|
}
|
|
|
|
func (q *MilestonesSearchQueries) toQuery(query sq.SelectBuilder) sq.SelectBuilder {
|
|
query = q.SearchRequest.toQuery(query)
|
|
for _, q := range q.Queries {
|
|
query = q.toQuery(query)
|
|
}
|
|
return query
|
|
}
|
|
|
|
var (
|
|
milestonesTable = table{
|
|
name: projection.MilestonesProjectionTable,
|
|
instanceIDCol: projection.MilestoneColumnInstanceID,
|
|
}
|
|
MilestoneInstanceIDColID = Column{
|
|
name: projection.MilestoneColumnInstanceID,
|
|
table: milestonesTable,
|
|
}
|
|
MilestoneTypeColID = Column{
|
|
name: projection.MilestoneColumnType,
|
|
table: milestonesTable,
|
|
}
|
|
MilestonePrimaryDomainColID = Column{
|
|
name: projection.MilestoneColumnPrimaryDomain,
|
|
table: milestonesTable,
|
|
}
|
|
MilestoneReachedDateColID = Column{
|
|
name: projection.MilestoneColumnReachedDate,
|
|
table: milestonesTable,
|
|
}
|
|
MilestonePushedDateColID = Column{
|
|
name: projection.MilestoneColumnPushedDate,
|
|
table: milestonesTable,
|
|
}
|
|
)
|
|
|
|
// SearchMilestones tries to defer the instanceID from the passed context if no instanceIDs are passed
|
|
func (q *Queries) SearchMilestones(ctx context.Context, instanceIDs []string, queries *MilestonesSearchQueries) (_ *Milestones, err error) {
|
|
ctx, span := tracing.NewSpan(ctx)
|
|
defer func() { span.EndWithError(err) }()
|
|
query, scan := prepareMilestonesQuery(ctx, q.client)
|
|
if len(instanceIDs) == 0 {
|
|
instanceIDs = []string{authz.GetInstance(ctx).InstanceID()}
|
|
}
|
|
stmt, args, err := queries.toQuery(query).Where(sq.Eq{MilestoneInstanceIDColID.identifier(): instanceIDs}).ToSql()
|
|
if err != nil {
|
|
return nil, errors.ThrowInternal(err, "QUERY-A9i5k", "Errors.Query.SQLStatement")
|
|
}
|
|
rows, err := q.client.QueryContext(ctx, stmt, args...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer func() {
|
|
if closeErr := rows.Close(); closeErr != nil && err == nil {
|
|
err = errors.ThrowInternal(closeErr, "QUERY-CK9mI", "Errors.Query.CloseRows")
|
|
}
|
|
}()
|
|
milestones, err := scan(rows)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if err = rows.Err(); err != nil {
|
|
return nil, errors.ThrowInternal(err, "QUERY-asLsI", "Errors.Internal")
|
|
}
|
|
milestones.LatestSequence, err = q.latestSequence(ctx, milestonesTable)
|
|
return milestones, err
|
|
|
|
}
|
|
|
|
func prepareMilestonesQuery(ctx context.Context, db prepareDatabase) (sq.SelectBuilder, func(*sql.Rows) (*Milestones, error)) {
|
|
return sq.Select(
|
|
MilestoneInstanceIDColID.identifier(),
|
|
MilestonePrimaryDomainColID.identifier(),
|
|
MilestoneReachedDateColID.identifier(),
|
|
MilestonePushedDateColID.identifier(),
|
|
MilestoneTypeColID.identifier(),
|
|
countColumn.identifier(),
|
|
).
|
|
From(milestonesTable.identifier() + db.Timetravel(call.Took(ctx))).
|
|
PlaceholderFormat(sq.Dollar),
|
|
func(rows *sql.Rows) (*Milestones, error) {
|
|
milestones := make([]*Milestone, 0)
|
|
var count uint64
|
|
for rows.Next() {
|
|
m := new(Milestone)
|
|
reachedDate := sql.NullTime{}
|
|
pushedDate := sql.NullTime{}
|
|
primaryDomain := sql.NullString{}
|
|
err := rows.Scan(
|
|
&m.InstanceID,
|
|
&primaryDomain,
|
|
&reachedDate,
|
|
&pushedDate,
|
|
&m.Type,
|
|
&count,
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
m.PrimaryDomain = primaryDomain.String
|
|
m.ReachedDate = reachedDate.Time
|
|
m.PushedDate = pushedDate.Time
|
|
milestones = append(milestones, m)
|
|
}
|
|
return &Milestones{
|
|
Milestones: milestones,
|
|
SearchResponse: SearchResponse{
|
|
Count: count,
|
|
},
|
|
}, nil
|
|
}
|
|
}
|