mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
30 lines
977 B
Go
30 lines
977 B
Go
package authorization
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/hanzoai/tasks/common/config"
|
|
"google.golang.org/grpc"
|
|
)
|
|
|
|
// AudienceMapper is a simple implementation of JWTAudienceMapper that returns the configured audience string.
|
|
type AudienceMapper struct {
|
|
JwtAudience string
|
|
}
|
|
|
|
// Audience returns the configured audience string.
|
|
func (m *AudienceMapper) Audience(ctx context.Context, req any, info *grpc.UnaryServerInfo) string {
|
|
return m.JwtAudience
|
|
}
|
|
|
|
// NewAudienceMapper returns a JWTAudienceMapper that always returns the given audience string.
|
|
func NewAudienceMapper(audience string) JWTAudienceMapper {
|
|
return &AudienceMapper{JwtAudience: audience}
|
|
}
|
|
|
|
// GetAudienceMapperFromConfig returns a JWTAudienceMapper based on the provided Authorization config.
|
|
// Currently, it returns a static audience mapper using the Audience field.
|
|
func GetAudienceMapperFromConfig(cfg *config.Authorization) (JWTAudienceMapper, error) {
|
|
return NewAudienceMapper(cfg.Audience), nil
|
|
}
|