-
Notifications
You must be signed in to change notification settings - Fork 31
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Starts the new version of the ZITADEL SDK, which will provide more flexibility and better UX by (re)implementing the authorization feature. BREAKING CHANGES: - NewClient functions require context.Context - remove deprecated WithKeyPath client connection options --------- Co-authored-by: Tim Möhlmann <tim+github@zitadel.com>
- Loading branch information
Showing
101 changed files
with
21,634 additions
and
19,018 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,81 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "flag" | ||
| "fmt" | ||
| "net" | ||
| "os" | ||
|
|
||
| "golang.org/x/exp/slog" | ||
|
|
||
| "google.golang.org/grpc" | ||
| "google.golang.org/grpc/reflection" | ||
|
|
||
| v3alpha "github.com/zitadel/zitadel-go/v3/example/api/grpc/proto" | ||
| "github.com/zitadel/zitadel-go/v3/pkg/authorization/oauth" | ||
| "github.com/zitadel/zitadel-go/v3/pkg/grpc/middleware" | ||
| "github.com/zitadel/zitadel-go/v3/pkg/zitadel" | ||
| ) | ||
|
|
||
| var ( | ||
| // flags to be provided for running the example server | ||
| domain = flag.String("domain", "", "your ZITADEL instance domain (in the form: https://<instance>.zitadel.cloud or https://<yourdomain>)") | ||
| key = flag.String("key", "", "path to your key.json") | ||
| port = flag.String("port", "8089", "port to run the server on (default is 8089)") | ||
| ) | ||
|
|
||
| func main() { | ||
| flag.Parse() | ||
|
|
||
| ctx := context.Background() | ||
|
|
||
| // Initiate the zitadel sdk by providing its domain | ||
| // and as this example will focus on authorization (using Oauth2 Introspection), | ||
| // you will also need to initialize that with the downloaded api key.json | ||
| // | ||
| // it's a short form of: | ||
| // z, err := zitadel.New("https://your-domain.zitadel.cloud", | ||
| // zitadel.WithAuthorization(ctx, | ||
| // oauth.WithIntrospection[*oauth.IntrospectionContext]( | ||
| // oauth.JWTProfileIntrospectionAuthentication("./key.json"), | ||
| // ), | ||
| // ), | ||
| // ) | ||
| z, err := zitadel.New(*domain, | ||
| zitadel.WithAuthorization(ctx, | ||
| oauth.DefaultAuthorization(*key), | ||
| ), | ||
| ) | ||
| if err != nil { | ||
| slog.Error("zitadel sdk could not initialize", "error", err) | ||
| os.Exit(1) | ||
| } | ||
|
|
||
| // Initialize the GRPC middleware by providing the sdk and the authorization checks | ||
| mw := middleware.New(z.Authorization, checks) | ||
|
|
||
| // Create the GRPC server and provide the necessary interceptors | ||
| serverOptions := []grpc.ServerOption{ | ||
| grpc.UnaryInterceptor(mw.Unary()), | ||
| grpc.StreamInterceptor(mw.Stream()), | ||
| } | ||
| grpcServer := grpc.NewServer(serverOptions...) | ||
|
|
||
| // Register your server implementation | ||
| v3alpha.RegisterExampleServiceServer(grpcServer, NewServer(mw)) | ||
| // for easier use, we also register the grpc server reflection | ||
| reflection.Register(grpcServer) | ||
|
|
||
| // finally start the server on port 8099 | ||
| lis, err := net.Listen("tcp", fmt.Sprintf(":%s", *port)) | ||
| if err != nil { | ||
| slog.Error("creating listener failed", "error", err) | ||
| os.Exit(1) | ||
| } | ||
| err = grpcServer.Serve(lis) | ||
| if err != nil { | ||
| slog.Error("server terminated", "error", err) | ||
| os.Exit(1) | ||
| } | ||
| } |
Oops, something went wrong.