zitadel/internal/query/userinfo.go

package query

import (
	"context"
	"database/sql"
	_ "embed"
	"encoding/json"

	"github.com/zitadel/zitadel/internal/api/authz"
	"github.com/zitadel/zitadel/internal/errors"
	"github.com/zitadel/zitadel/internal/telemetry/tracing"
)

//go:embed embed/userinfo_by_id.sql
var oidcUserInfoQuery string

func (q *Queries) GetOIDCUserInfo(ctx context.Context, userID string) (_ *OIDCUserInfo, err error) {
	ctx, span := tracing.NewSpan(ctx)
	defer func() { span.EndWithError(err) }()

	var data []byte
	err = q.client.QueryRowContext(ctx, func(row *sql.Row) error {
		return row.Scan(&data)
	}, oidcUserInfoQuery, userID, authz.GetInstance(ctx).InstanceID())
	if err != nil {
		return nil, errors.ThrowInternal(err, "QUERY-Oath6", "Errors.Internal")
	}

	userInfo := new(OIDCUserInfo)
	if err = json.Unmarshal(data, userInfo); err != nil {
		return nil, errors.ThrowInternal(err, "QUERY-Vohs6", "Errors.Internal")
	}
	if userInfo.User == nil {
		return nil, errors.ThrowNotFound(nil, "QUERY-ahs4S", "Errors.User.NotFound")
	}

	return userInfo, nil
}

type OIDCUserInfo struct {
	User     *User          `json:"user,omitempty"`
	Metadata []UserMetadata `json:"metadata,omitempty"`
	Org      *userInfoOrg   `json:"org,omitempty"`
}

type userInfoOrg struct {
	ID            string `json:"id,omitempty"`
	Name          string `json:"name,omitempty"`
	PrimaryDomain string `json:"primary_domain,omitempty"`
}