Function decodeFlow

flow/flow_encoding.go:25–40

(ctx context.Context, d decodeDependencies, enc string, p purpose)

}

func decodeFlow(ctx context.Context, d decodeDependencies, enc string, p purpose) (_ *Flow, err error) {
	f, err := Decode[Flow](ctx, d.FlowCipher(), enc, withPurpose(p))
	if err != nil {
		return nil, errors.WithStack(x.ErrNotFound.WithWrap(err))
	}

	if f.NID != d.Networker().NetworkID(ctx) {
		return nil, errors.WithStack(x.ErrNotFound.WithDescription("Network IDs are not matching."))
	}

	if f.RequestedAt.Add(d.Config().ConsentRequestMaxAge(ctx)).Before(time.Now()) {
		return nil, errors.WithStack(fosite.ErrRequestUnauthorized.WithHintf("The %s request has expired, please try again.", p.RequestType()))
	}

	return f, nil
}

func DecodeFromLoginChallenge(ctx context.Context, d decodeDependencies, challenge string) (_ *Flow, err error) {
	ctx, span := d.Tracer(ctx).Tracer().Start(ctx, "flow.DecodeFromLoginChallenge")