Method GetDeviceCodeSessionByRequestID

persistence/sql/persister_device.go:240–264

GetDeviceCodeSessionByRequestID returns a device code session from the database. Implements FositeStorer.

(ctx context.Context, requestID string, session fosite.Session)

// GetDeviceCodeSessionByRequestID returns a device code session from the database. Implements FositeStorer.
func (p *Persister) GetDeviceCodeSessionByRequestID(ctx context.Context, requestID string, session fosite.Session) (_ fosite.DeviceRequester, deviceCodeSignature string, err error) {
	ctx, span := p.r.Tracer(ctx).Tracer().Start(ctx, "persistence.sql.GetDeviceCodeSessionByRequestID")
	defer otelx.End(span, &err)

	r := DeviceRequestSQL{}
	if err = p.QueryWithNetwork(ctx).Where("request_id = ?", requestID).First(&r); errors.Is(err, sql.ErrNoRows) {
		return nil, "", errors.WithStack(fosite.ErrNotFound)
	} else if err != nil {
		return nil, "", sqlcon.HandleError(err)
	}

	if !r.DeviceCodeActive {
		fr, err := r.toRequest(ctx, session, p)
		if err != nil {
			return nil, "", err
		}
		return fr, r.ID, errors.WithStack(fosite.ErrInactiveToken)
	}

	fr, err := r.toRequest(ctx, session, p)
	if err != nil {
		return nil, "", err
	}
	return fr, r.ID, nil
}

// UpdateDeviceCodeSessionBySignature updates a device code session by the device_code signature. Implements FositeStorer.
func (p *Persister) UpdateDeviceCodeSessionBySignature(ctx context.Context, signature string, requester fosite.DeviceRequester) (err error) {