(ctx context.Context, _ zerolog.Logger, specBytes []byte)
| 111 | } |
| 112 | |
| 113 | func TestConnection(ctx context.Context, _ zerolog.Logger, specBytes []byte) error { |
| 114 | var s Spec |
| 115 | if err := json.Unmarshal(specBytes, &s); err != nil { |
| 116 | return &plugin.TestConnError{ |
| 117 | Code: "INVALID_SPEC", |
| 118 | Message: fmt.Errorf("failed to unmarshal spec: %w", err), |
| 119 | } |
| 120 | } |
| 121 | s.SetDefaults() |
| 122 | if err := s.Validate(); err != nil { |
| 123 | return err |
| 124 | } |
| 125 | |
| 126 | c, err := bqClient(ctx, s) |
| 127 | if err != nil { |
| 128 | return err |
| 129 | } |
| 130 | |
| 131 | if err := validateCreds(ctx, c, s.DatasetID, s.ProjectID); err != nil { |
| 132 | return err |
| 133 | } |
| 134 | |
| 135 | return c.Close() |
| 136 | } |
nothing calls this directly
no test coverage detected