Revert "Fix etcd device requests (dexidp#3119)"

This reverts commit dddbe19.
mdpradeep · Oct 20, 2023 · 17941fb · 17941fb
1 parent 03e446a
commit 17941fb
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 29 deletions.
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
@@ -16,16 +16,12 @@ jobs:
     services:
       postgres:
         image: postgres:10.8
-        env:
-          TZ: UTC
         ports:
           - 5432
         options: --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5
 
       postgres-ent:
         image: postgres:10.8
-        env:
-          TZ: UTC
         ports:
           - 5432
         options: --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5

diff --git a/storage/conformance/conformance.go b/storage/conformance/conformance.go
@@ -8,7 +8,6 @@ import (
 	"time"
 
 	"github.com/kylelemons/godebug/pretty"
-	"github.com/stretchr/testify/require"
 	"golang.org/x/crypto/bcrypt"
 	jose "gopkg.in/square/go-jose.v2"
 
@@ -981,7 +980,7 @@ func testDeviceRequestCRUD(t *testing.T, s storage.Storage) {
 		ClientID:     "client1",
 		ClientSecret: "secret1",
 		Scopes:       []string{"openid", "email"},
-		Expiry:       neverExpire.Round(time.Second),
+		Expiry:       neverExpire,
 	}
 
 	if err := s.CreateDeviceRequest(d1); err != nil {
@@ -992,13 +991,6 @@ func testDeviceRequestCRUD(t *testing.T, s storage.Storage) {
 	err := s.CreateDeviceRequest(d1)
 	mustBeErrAlreadyExists(t, "device request", err)
 
-	got, err := s.GetDeviceRequest(d1.UserCode)
-	if err != nil {
-		t.Fatalf("failed to get device request: %v", err)
-	}
-
-	require.Equal(t, d1, got)
-
 	// No manual deletes for device requests, will be handled by garbage collection routines
 	// see testGC
 }

diff --git a/storage/etcd/etcd.go b/storage/etcd/etcd.go
@@ -577,11 +577,8 @@ func (c *conn) CreateDeviceRequest(d storage.DeviceRequest) error {
 func (c *conn) GetDeviceRequest(userCode string) (r storage.DeviceRequest, err error) {
 	ctx, cancel := context.WithTimeout(context.Background(), defaultStorageTimeout)
 	defer cancel()
-	var dr DeviceRequest
-	if err = c.getKey(ctx, keyID(deviceRequestPrefix, userCode), &dr); err == nil {
-		r = toStorageDeviceRequest(dr)
-	}
-	return
+	err = c.getKey(ctx, keyID(deviceRequestPrefix, userCode), &r)
+	return r, err
 }
 
 func (c *conn) listDeviceRequests(ctx context.Context) (requests []DeviceRequest, err error) {

diff --git a/storage/etcd/types.go b/storage/etcd/types.go
@@ -277,17 +277,6 @@ func fromStorageDeviceRequest(d storage.DeviceRequest) DeviceRequest {
 	}
 }
 
-func toStorageDeviceRequest(d DeviceRequest) storage.DeviceRequest {
-	return storage.DeviceRequest{
-		UserCode:     d.UserCode,
-		DeviceCode:   d.DeviceCode,
-		ClientID:     d.ClientID,
-		ClientSecret: d.ClientSecret,
-		Scopes:       d.Scopes,
-		Expiry:       d.Expiry,
-	}
-}
-
 // DeviceToken is a mirrored struct from storage with JSON struct tags
 type DeviceToken struct {
 	DeviceCode          string    `json:"device_code"`