Files
tasks/common/primitives/timestamp/parse_duration.go
Rodrigo ZhouandGitHub 2e8223e6aa Parse ExecutionDuration for SQL queries (#5027)
<!-- Describe what has changed in this PR -->
**What changed?**
Support duration expression (eg: "1m", "20h") in SQL queries involving
`ExecutionDuration`.

<!-- Tell your future self why have you made these changes -->
**Why?**
Better UX in advanced visibility with SQL (already supported with ES).
Raw field is in nanoseconds.

<!-- How have you verified this change? Tested locally? Added a unit
test? Checked in staging env? -->
**How did you test it?**
Created some workflows, and send some queries using those expression.

<!-- Assuming the worst case, what can be broken when deploying this
change to production? -->
**Potential risks**
No.

<!-- Is this PR a hotfix candidate or require that a notification be
sent to the broader community? (Yes/No) -->
**Is hotfix candidate?**
No.
2023-10-25 23:03:11 -05:00

95 lines
3.3 KiB
Go

// The MIT License
//
// Copyright (c) 2021 Temporal Technologies Inc. All rights reserved.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
package timestamp
import (
"errors"
"fmt"
"regexp"
"strconv"
"strings"
"time"
)
var (
reUnitless = regexp.MustCompile(`^(\d+(\.\d*)?|(\.\d+))$`)
reDays = regexp.MustCompile(`(\d+(\.\d*)?|(\.\d+))d`)
errInvalidDuration = errors.New("invalid duration")
errInvalidDurationHours = errors.New("invalid duration: hours must be a positive number")
errInvalidDurationMinutes = errors.New("invalid duration: minutes must be from 0 to 59")
errInvalidDurationSeconds = errors.New("invalid duration: seconds must be from 0 to 59")
)
// ParseDuration is like time.ParseDuration, but supports unit "d" for days
// (always interpreted as exactly 24 hours).
func ParseDuration(s string) (time.Duration, error) {
s = reDays.ReplaceAllStringFunc(s, func(v string) string {
fv, err := strconv.ParseFloat(strings.TrimSuffix(v, "d"), 64)
if err != nil {
return v // will cause time.ParseDuration to return an error
}
return fmt.Sprintf("%fh", 24*fv)
})
return time.ParseDuration(s)
}
// ParseDurationDefaultDays is like time.ParseDuration, but supports unit "d"
// for days (always interpreted as exactly 24 hours), and also supports
// unit-less numbers, which are interpreted as days.
func ParseDurationDefaultDays(s string) (time.Duration, error) {
if reUnitless.MatchString(s) {
s += "d"
}
return ParseDuration(s)
}
// ParseDurationDefaultSeconds is like time.ParseDuration, but supports unit "d"
// for days (always interpreted as exactly 24 hours), and also supports
// unit-less numbers, which are interpreted as seconds.
func ParseDurationDefaultSeconds(s string) (time.Duration, error) {
if reUnitless.MatchString(s) {
s += "s"
}
return ParseDuration(s)
}
func ParseHHMMSSDuration(d string) (time.Duration, error) {
var hours, minutes, seconds time.Duration
_, err := fmt.Sscanf(d, "%d:%d:%d", &hours, &minutes, &seconds)
if err != nil {
return 0, errInvalidDuration
}
if hours < 0 {
return 0, errInvalidDurationHours
}
if minutes < 0 || minutes > 59 {
return 0, errInvalidDurationMinutes
}
if seconds < 0 || seconds > 59 {
return 0, errInvalidDurationSeconds
}
return hours*time.Hour + minutes*time.Minute + seconds*time.Second, nil
}