Method CreateAccessTokenSession

internal/oauth/storage.go:300–323

───────────────────────── AccessTokenStorage ─────────────────────────

(ctx context.Context, signature string, request fosite.Requester)

// ───────────────────────── AccessTokenStorage ─────────────────────────

func (s *Storage) CreateAccessTokenSession(ctx context.Context, signature string, request fosite.Requester) error {
	raw, err := marshalRequest(request)
	if err != nil {
		return err
	}
	sess, _ := request.GetSession().(*Session)
	userID := ""
	expiresAt := request.GetRequestedAt().Add(time.Hour) // fosite default
	if sess != nil {
		userID = sess.UserID
		if t := sess.GetExpiresAt(fosite.AccessToken); !t.IsZero() {
			expiresAt = t
		}
	}
	_, err = s.db(ctx).Exec(ctx, `
		INSERT INTO oauth_access_tokens
		    (signature, request_id, client_id, user_id, request,
		     requested_at, expires_at)
		VALUES ($1, $2, $3, $4, $5, $6, $7)
	`, signature, request.GetID(), request.GetClient().GetID(), userID,
		raw, request.GetRequestedAt(), expiresAt,
	)
	return err
}

func (s *Storage) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error) {
	var raw []byte