mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Alex ShtinandGitHub
8e8f1b0f7c
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.
## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
65 lines
1.7 KiB
Go
65 lines
1.7 KiB
Go
package serviceerror
|
|
|
|
import (
|
|
"go.temporal.io/api/serviceerror"
|
|
errordetailsspb "go.temporal.io/server/api/errordetails/v1"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
// FromStatus converts gRPC status to service error.
|
|
func FromStatus(st *status.Status) error {
|
|
if st == nil || st.Code() == codes.OK {
|
|
return nil
|
|
}
|
|
|
|
errDetails := extractErrorDetails(st)
|
|
|
|
switch st.Code() {
|
|
case codes.InvalidArgument:
|
|
switch errDetails := errDetails.(type) {
|
|
case *errordetailsspb.CurrentBranchChangedFailure:
|
|
return newCurrentBranchChanged(st, errDetails)
|
|
}
|
|
case codes.AlreadyExists:
|
|
switch errDetails.(type) {
|
|
case *errordetailsspb.TaskAlreadyStartedFailure:
|
|
return newTaskAlreadyStarted(st)
|
|
}
|
|
case codes.Aborted:
|
|
switch errDetails := errDetails.(type) {
|
|
case *errordetailsspb.ShardOwnershipLostFailure:
|
|
return newShardOwnershipLost(st, errDetails)
|
|
case *errordetailsspb.RetryReplicationFailure:
|
|
return newRetryReplication(st, errDetails)
|
|
case *errordetailsspb.SyncStateFailure:
|
|
return newSyncState(st, errDetails)
|
|
}
|
|
case codes.Unavailable:
|
|
switch errDetails.(type) {
|
|
case *errordetailsspb.StickyWorkerUnavailableFailure:
|
|
return newStickyWorkerUnavailable(st)
|
|
}
|
|
case codes.FailedPrecondition:
|
|
switch errDetails.(type) {
|
|
case *errordetailsspb.ObsoleteDispatchBuildIdFailure:
|
|
return newObsoleteDispatchBuildId(st)
|
|
case *errordetailsspb.ObsoleteMatchingTaskFailure:
|
|
return newObsoleteMatchingTask(st)
|
|
case *errordetailsspb.ActivityStartDuringTransitionFailure:
|
|
return newActivityStartDuringTransition(st)
|
|
}
|
|
}
|
|
|
|
return serviceerror.FromStatus(st)
|
|
}
|
|
|
|
func extractErrorDetails(st *status.Status) interface{} {
|
|
details := st.Details()
|
|
if len(details) > 0 {
|
|
return details[0]
|
|
}
|
|
|
|
return nil
|
|
}
|