mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
* Upgrade dskit dependency to latest main * Revert upgrades to otel dependencies * rm kuberesolver/v5/README.md * Add kuberesolver/v5/README.md * no touch crlf?
57 lines
1.6 KiB
Go
57 lines
1.6 KiB
Go
// Provenance-includes-location: https://github.com/weaveworks/common/blob/main/user/id.go
|
|
// Provenance-includes-license: Apache-2.0
|
|
// Provenance-includes-copyright: Weaveworks Ltd.
|
|
|
|
package user
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
)
|
|
|
|
type contextKey int
|
|
|
|
const (
|
|
// Keys used in contexts to find the org or user ID
|
|
orgIDContextKey contextKey = 0
|
|
userIDContextKey contextKey = 1
|
|
)
|
|
|
|
// Errors that we return
|
|
var (
|
|
ErrNoOrgID = errors.New("no org id")
|
|
ErrDifferentOrgIDPresent = errors.New("different org ID already present")
|
|
ErrTooManyOrgIDs = errors.New("multiple org IDs present")
|
|
|
|
ErrNoUserID = errors.New("no user id")
|
|
ErrDifferentUserIDPresent = errors.New("different user ID already present")
|
|
)
|
|
|
|
// ExtractOrgID gets the org ID from the context.
|
|
func ExtractOrgID(ctx context.Context) (string, error) {
|
|
orgID, ok := ctx.Value(orgIDContextKey).(string)
|
|
if !ok {
|
|
return "", ErrNoOrgID
|
|
}
|
|
return orgID, nil
|
|
}
|
|
|
|
// InjectOrgID returns a derived context containing the org ID.
|
|
func InjectOrgID(ctx context.Context, orgID string) context.Context {
|
|
return context.WithValue(ctx, interface{}(orgIDContextKey), orgID)
|
|
}
|
|
|
|
// ExtractUserID gets the user ID from the context.
|
|
func ExtractUserID(ctx context.Context) (string, error) {
|
|
userID, ok := ctx.Value(userIDContextKey).(string)
|
|
if !ok {
|
|
return "", ErrNoUserID
|
|
}
|
|
return userID, nil
|
|
}
|
|
|
|
// InjectUserID returns a derived context containing the user ID.
|
|
func InjectUserID(ctx context.Context, userID string) context.Context {
|
|
return context.WithValue(ctx, interface{}(userIDContextKey), userID)
|
|
}
|