Method GetCurrentUser

cli/pkg/local/server.go:605–652

GetCurrentUser implements localv1connect.LocalServiceHandler.

(ctx context.Context, r *connect.Request[localv1.GetCurrentUserRequest])

// GetCurrentUser implements localv1connect.LocalServiceHandler.
func (s *Server) GetCurrentUser(ctx context.Context, r *connect.Request[localv1.GetCurrentUserRequest]) (*connect.Response[localv1.GetCurrentUserResponse], error) {
	if !s.app.ch.IsAuthenticated() {
		return connect.NewResponse(&localv1.GetCurrentUserResponse{
			User: nil,
		}), nil
	}

	c, err := s.app.ch.Client()
	if err != nil {
		return nil, err
	}

	userResp, err := c.GetCurrentUser(ctx, &adminv1.GetCurrentUserRequest{})
	if err != nil {
		return nil, err
	}
	if userResp.User == nil {
		return nil, errors.New("failed to get current user")
	}

	// get rill user orgs
	resp, err := c.ListOrganizations(ctx, &adminv1.ListOrganizationsRequest{PageSize: 1000})
	if err != nil {
		return nil, err
	}

	userOrgs := make([]string, 0, len(resp.Organizations))
	for _, org := range resp.Organizations {
		userOrgs = append(userOrgs, org.Name)
	}

	representingUser, err := s.app.ch.DotRill.GetRepresentingUser()
	if err != nil {
		return nil, errors.New("failed to get assumed user email")
	}
	isRepresentingUser := representingUser != ""

	return connect.NewResponse(&localv1.GetCurrentUserResponse{
		User: &adminv1.User{
			Id:          userResp.User.Id,
			Email:       userResp.User.Email,
			DisplayName: userResp.User.DisplayName,
			PhotoUrl:    userResp.User.PhotoUrl,
		},
		RillUserOrgs:       userOrgs,
		IsRepresentingUser: isRepresentingUser,
	}), nil
}

// GetCurrentProject implements localv1connect.LocalServiceHandler.
// Remove this endpoint once UI cleans up code referring to it.