Skip to content

Commit 026057f

Browse files
DavidSGKDavidSGK
committed
Migrate github.com/bufbuild/connect-go to connectrpc.com/connect
1 parent cacde22 commit 026057f

File tree

10 files changed

+61
-58
lines changed

10 files changed

+61
-58
lines changed

‎cmd/lekko/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ import (
2121
"os"
2222
"strconv"
2323

24+
"connectrpc.com/connect"
2425
"github.com/AlecAivazis/survey/v2"
25-
"github.com/bufbuild/connect-go"
2626
"github.com/lainio/err2"
2727
"github.com/pkg/errors"
2828
"github.com/spf13/cobra"

‎go.mod

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@ go 1.22
55
replace github.com/bazelbuild/buildtools => github.com/lekkodev/buildtools v0.0.0-20240325231538-96eefd799042
66

77
require (
8-
buf.build/gen/go/lekkodev/cli/bufbuild/connect-go v1.10.0-20240528213244-5fdc18b47eea.1
9-
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240923164736-6b09ba83efbf.2
8+
buf.build/gen/go/lekkodev/cli/connectrpc/go v1.17.0-20240926040046-3e1042256cdf.1
9+
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240926040046-3e1042256cdf.2
10+
connectrpc.com/connect v1.17.0
1011
github.com/AlecAivazis/survey/v2 v2.3.6
1112
github.com/atotto/clipboard v0.1.4
1213
github.com/bazelbuild/buildtools v0.0.0-20220907133145-b9bfff5d7f91
1314
github.com/briandowns/spinner v1.23.0
14-
github.com/bufbuild/connect-go v1.10.0
1515
github.com/cli/browser v1.0.0
1616
github.com/go-git/go-billy/v5 v5.5.0
1717
github.com/go-git/go-git/v5 v5.12.0

‎go.sum

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,12 @@
1-
buf.build/gen/go/lekkodev/cli/bufbuild/connect-go v1.10.0-20240528213244-5fdc18b47eea.1 h1:JqArhl+OClAdLQis1N2N6WmLv96CbOaNrQEYWL2ntlI=
2-
buf.build/gen/go/lekkodev/cli/bufbuild/connect-go v1.10.0-20240528213244-5fdc18b47eea.1/go.mod h1:gkMKhhTCMDLJVmimyqao6P3g7jB7wDe3r7u8hV2iShE=
3-
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240923164736-6b09ba83efbf.2 h1:JEiSyCH0wTycYIeIpm8xs/HcyPgHtJpdKBrUer8Jq6E=
4-
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240923164736-6b09ba83efbf.2/go.mod h1:j/ek65dWz+D5GM7p9QUiHQj5X5gtRUMfGl1+GpSfm6g=
1+
buf.build/gen/go/lekkodev/cli/connectrpc/go v1.17.0-20240926040046-3e1042256cdf.1 h1:agiFYCNijwOenKQtub2FQ3lUdZvXQTii7eVV7ByY6h4=
2+
buf.build/gen/go/lekkodev/cli/connectrpc/go v1.17.0-20240926040046-3e1042256cdf.1/go.mod h1:1ia6DcIYiqkQNmSTA00+Kys2yObN8ByxgcLbaTY1hNo=
3+
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240926040046-3e1042256cdf.2 h1:sS7KHlg3fCpYqz52WrRAOEr7uxezWXoGM7gopqB2gYQ=
4+
buf.build/gen/go/lekkodev/cli/protocolbuffers/go v1.34.2-20240926040046-3e1042256cdf.2/go.mod h1:j/ek65dWz+D5GM7p9QUiHQj5X5gtRUMfGl1+GpSfm6g=
55
buf.build/gen/go/lekkodev/sdk/protocolbuffers/go v1.34.2-20230810202034-1c821065b9a0.2 h1:ZEir2Lbw+XH5Dlnqiv0FUc8hC7QdUMpGSCIiREMriJ0=
66
buf.build/gen/go/lekkodev/sdk/protocolbuffers/go v1.34.2-20230810202034-1c821065b9a0.2/go.mod h1:YAvVDcY/tXuUXkpfm3LHCD6vz9SPv73CktuPGgqzJkI=
77
cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
8+
connectrpc.com/connect v1.17.0 h1:W0ZqMhtVzn9Zhn2yATuUokDLO5N+gIuBWMOnsQrfmZk=
9+
connectrpc.com/connect v1.17.0/go.mod h1:0292hj1rnx8oFrStN7cB4jjVBeqs+Yx5yDIC2prWDO8=
810
dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
911
dario.cat/mergo v1.0.0/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
1012
github.com/AlecAivazis/survey/v2 v2.3.6 h1:NvTuVHISgTHEHeBFqt6BHOe4Ny/NwGZr7w+F8S9ziyw=
@@ -31,8 +33,6 @@ github.com/atotto/clipboard v0.1.4 h1:EH0zSVneZPSuFR11BlR9YppQTVDbh5+16AmcJi4g1z
3133
github.com/atotto/clipboard v0.1.4/go.mod h1:ZY9tmq7sm5xIbd9bOK4onWV4S6X0u6GY7Vn0Yu86PYI=
3234
github.com/briandowns/spinner v1.23.0 h1:alDF2guRWqa/FOZZYWjlMIx2L6H0wyewPxo/CH4Pt2A=
3335
github.com/briandowns/spinner v1.23.0/go.mod h1:rPG4gmXeN3wQV/TsAY4w8lPdIM6RX3yqeBQJSrbXjuE=
34-
github.com/bufbuild/connect-go v1.10.0 h1:QAJ3G9A1OYQW2Jbk3DeoJbkCxuKArrvZgDt47mjdTbg=
35-
github.com/bufbuild/connect-go v1.10.0/go.mod h1:CAIePUgkDR5pAFaylSMtNK45ANQjp9JvpluG20rhpV8=
3636
github.com/buger/jsonparser v1.1.1/go.mod h1:6RYKKt7H4d4+iWqouImQ9R2FZql3VbhNgx27UK13J/0=
3737
github.com/bwesterb/go-ristretto v1.2.3/go.mod h1:fUIoIZaG73pV5biE2Blr2xEzDoMj7NFEuV9ekS419A0=
3838
github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=

‎make/go/dep_protoc_gen_connect_go.mk

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,16 @@ $(call _assert_var,CACHE_VERSIONS)
77
$(call _assert_var,CACHE_BIN)
88

99
# Settable
10-
# https://github.com/bufbuild/connect-go 20220531 checked 20220601
11-
CONNECT_VERSION ?= v0.1.0
10+
# https://github.com/connectrpc/connect-go 20240920 checked 20240920
11+
CONNECT_VERSION ?= v1.17.0
12+
13+
GO_GET_PKGS := $(GO_GET_PKGS) \
14+
connectrpc.com/connect@$(CONNECT_VERSION)
1215

1316
PROTOC_GEN_CONNECT_GO := $(CACHE_VERSIONS)/connect-go/$(CONNECT_VERSION)
1417
$(PROTOC_GEN_CONNECT_GO):
15-
@rm -f $(CACHE_BIN)/connect-go
16-
GOBIN=$(CACHE_BIN) go install github.com/bufbuild/connect-go/cmd/protoc-gen-connect-go@$(CONNECT_VERSION)
18+
@rm -f $(CACHE_BIN)/protoc-gen-connect-go
19+
GOBIN=$(CACHE_BIN) go install connectrpc.com/connect/cmd/protoc-gen-connect-go@$(CONNECT_VERSION)
1720
@rm -rf $(dir $(PROTOC_GEN_CONNECT_GO))
1821
@mkdir -p $(dir $(PROTOC_GEN_CONNECT_GO))
1922
@touch $(PROTOC_GEN_CONNECT_GO)

‎pkg/apikey/apikey.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,10 @@ package apikey
1717
import (
1818
"context"
1919

20-
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/bufbuild/connect-go/lekko/bff/v1beta1/bffv1beta1connect"
20+
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/connectrpc/go/lekko/bff/v1beta1/bffv1beta1connect"
2121
bffv1beta1 "buf.build/gen/go/lekkodev/cli/protocolbuffers/go/lekko/bff/v1beta1"
22+
"connectrpc.com/connect"
2223

23-
connect_go "github.com/bufbuild/connect-go"
2424
"github.com/pkg/errors"
2525
)
2626

@@ -34,7 +34,7 @@ func NewAPIKey(bff bffv1beta1connect.BFFServiceClient) *APIKeyManager {
3434
}
3535

3636
func (a *APIKeyManager) Create(ctx context.Context, teamname, nickname string) (*bffv1beta1.GenerateAPIKeyResponse, error) {
37-
resp, err := a.bff.GenerateAPIKey(ctx, connect_go.NewRequest(&bffv1beta1.GenerateAPIKeyRequest{
37+
resp, err := a.bff.GenerateAPIKey(ctx, connect.NewRequest(&bffv1beta1.GenerateAPIKeyRequest{
3838
Nickname: nickname,
3939
TeamName: teamname,
4040
}))
@@ -45,15 +45,15 @@ func (a *APIKeyManager) Create(ctx context.Context, teamname, nickname string) (
4545
}
4646

4747
func (a *APIKeyManager) List(ctx context.Context, teamname string) ([]*bffv1beta1.APIKey, error) {
48-
resp, err := a.bff.ListAPIKeys(ctx, connect_go.NewRequest(&bffv1beta1.ListAPIKeysRequest{TeamName: teamname}))
48+
resp, err := a.bff.ListAPIKeys(ctx, connect.NewRequest(&bffv1beta1.ListAPIKeysRequest{TeamName: teamname}))
4949
if err != nil {
5050
return nil, errors.Wrap(err, "list api keys")
5151
}
5252
return resp.Msg.GetApiKeys(), nil
5353
}
5454

5555
func (a *APIKeyManager) Check(ctx context.Context, apikey string) (*bffv1beta1.APIKey, error) {
56-
resp, err := a.bff.CheckAPIKey(ctx, connect_go.NewRequest(&bffv1beta1.CheckAPIKeyRequest{
56+
resp, err := a.bff.CheckAPIKey(ctx, connect.NewRequest(&bffv1beta1.CheckAPIKeyRequest{
5757
ApiKey: apikey,
5858
}))
5959
if err != nil {
@@ -63,7 +63,7 @@ func (a *APIKeyManager) Check(ctx context.Context, apikey string) (*bffv1beta1.A
6363
}
6464

6565
func (a *APIKeyManager) Delete(ctx context.Context, nickname string) error {
66-
_, err := a.bff.DeleteAPIKey(ctx, connect_go.NewRequest(&bffv1beta1.DeleteAPIKeyRequest{
66+
_, err := a.bff.DeleteAPIKey(ctx, connect.NewRequest(&bffv1beta1.DeleteAPIKeyRequest{
6767
Nickname: nickname,
6868
}))
6969
return err

‎pkg/lekko/client.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ import (
1919
"fmt"
2020
"net/http"
2121

22-
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/bufbuild/connect-go/lekko/bff/v1beta1/bffv1beta1connect"
23-
connect_go "github.com/bufbuild/connect-go"
22+
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/connectrpc/go/lekko/bff/v1beta1/bffv1beta1connect"
23+
"connectrpc.com/connect"
2424
)
2525

2626
const (
@@ -45,15 +45,15 @@ type AuthCredentials interface {
4545

4646
func NewBFFClient(creds AuthCredentials) bffv1beta1connect.BFFServiceClient {
4747
interceptor := NewUserAuthInterceptor(creds)
48-
return bffv1beta1connect.NewBFFServiceClient(http.DefaultClient, URL, connect_go.WithInterceptors(interceptor))
48+
return bffv1beta1connect.NewBFFServiceClient(http.DefaultClient, URL, connect.WithInterceptors(interceptor))
4949
}
5050

51-
func NewUserAuthInterceptor(a AuthCredentials) connect_go.UnaryInterceptorFunc {
52-
interceptor := func(next connect_go.UnaryFunc) connect_go.UnaryFunc {
53-
return connect_go.UnaryFunc(func(
51+
func NewUserAuthInterceptor(a AuthCredentials) connect.UnaryInterceptorFunc {
52+
interceptor := func(next connect.UnaryFunc) connect.UnaryFunc {
53+
return connect.UnaryFunc(func(
5454
ctx context.Context,
55-
req connect_go.AnyRequest,
56-
) (connect_go.AnyResponse, error) {
55+
req connect.AnyRequest,
56+
) (connect.AnyResponse, error) {
5757
if a.HasLekkoToken() {
5858
req.Header().Set(AuthorizationHeaderKey, fmt.Sprintf("Bearer %s", a.GetLekkoToken()))
5959
if lekkoTeam := a.GetLekkoTeam(); len(lekkoTeam) > 0 {
@@ -69,5 +69,5 @@ func NewUserAuthInterceptor(a AuthCredentials) connect_go.UnaryInterceptorFunc {
6969
return next(ctx, req)
7070
})
7171
}
72-
return connect_go.UnaryInterceptorFunc(interceptor)
72+
return connect.UnaryInterceptorFunc(interceptor)
7373
}

‎pkg/oauth/lekko.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@ import (
2323
"os"
2424
"time"
2525

26-
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/bufbuild/connect-go/lekko/bff/v1beta1/bffv1beta1connect"
26+
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/connectrpc/go/lekko/bff/v1beta1/bffv1beta1connect"
2727
bffv1beta1 "buf.build/gen/go/lekkodev/cli/protocolbuffers/go/lekko/bff/v1beta1"
28-
connect_go "github.com/bufbuild/connect-go"
28+
"connectrpc.com/connect"
2929
"github.com/cenkalti/backoff/v4"
3030
"github.com/cli/browser"
3131
"github.com/pkg/errors"
@@ -56,7 +56,7 @@ type AuthCredentials struct {
5656
}
5757

5858
func (f *DeviceFlow) Authorize(ctx context.Context) (*AuthCredentials, error) {
59-
resp, err := f.lekkoAuthClient.GetDeviceCode(ctx, connect_go.NewRequest(&bffv1beta1.GetDeviceCodeRequest{
59+
resp, err := f.lekkoAuthClient.GetDeviceCode(ctx, connect.NewRequest(&bffv1beta1.GetDeviceCodeRequest{
6060
ClientId: LekkoClientID,
6161
}))
6262
if err != nil {
@@ -76,7 +76,7 @@ func (f *DeviceFlow) pollToken(ctx context.Context, deviceCode string, interval
7676
var ret *AuthCredentials
7777

7878
operation := func() error {
79-
resp, err := f.lekkoAuthClient.GetAccessToken(ctx, connect_go.NewRequest(&bffv1beta1.GetAccessTokenRequest{
79+
resp, err := f.lekkoAuthClient.GetAccessToken(ctx, connect.NewRequest(&bffv1beta1.GetAccessTokenRequest{
8080
DeviceCode: deviceCode,
8181
ClientId: LekkoClientID,
8282
}))

‎pkg/oauth/oauth.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import (
2323
"sync"
2424
"time"
2525

26-
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/bufbuild/connect-go/lekko/bff/v1beta1/bffv1beta1connect"
26+
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/connectrpc/go/lekko/bff/v1beta1/bffv1beta1connect"
2727
bffv1beta1 "buf.build/gen/go/lekkodev/cli/protocolbuffers/go/lekko/bff/v1beta1"
28+
"connectrpc.com/connect"
2829
"github.com/briandowns/spinner"
29-
connect_go "github.com/bufbuild/connect-go"
3030
ghauth "github.com/cli/oauth"
3131
"github.com/lekkodev/cli/pkg/gh"
3232
"github.com/lekkodev/cli/pkg/lekko"
@@ -115,7 +115,7 @@ func (a *OAuth) PreRegister(ctx context.Context, username string, ws secrets.Wri
115115
s := spinner.New(spinner.CharSets[14], 100*time.Millisecond)
116116
s.Suffix = " Generating OAuth code..."
117117
s.Start()
118-
dcResp, err := a.lekkoAuthClient.GetDeviceCode(ctx, connect_go.NewRequest(&bffv1beta1.GetDeviceCodeRequest{
118+
dcResp, err := a.lekkoAuthClient.GetDeviceCode(ctx, connect.NewRequest(&bffv1beta1.GetDeviceCodeRequest{
119119
ClientId: LekkoClientID,
120120
}))
121121
s.Stop()
@@ -124,7 +124,7 @@ func (a *OAuth) PreRegister(ctx context.Context, username string, ws secrets.Wri
124124
}
125125
s.Suffix = " Connecting to Lekko..."
126126
s.Start()
127-
_, err = a.lekkoAuthClient.PreRegisterUser(ctx, connect_go.NewRequest(&bffv1beta1.PreRegisterUserRequest{
127+
_, err = a.lekkoAuthClient.PreRegisterUser(ctx, connect.NewRequest(&bffv1beta1.PreRegisterUserRequest{
128128
Username: username,
129129
// We're passing in user code just because that's what backend handles better at the moment
130130
DeviceCode: dcResp.Msg.UserCode,
@@ -155,7 +155,7 @@ func (a *OAuth) PreRegister(ctx context.Context, username string, ws secrets.Wri
155155
}
156156

157157
func (a *OAuth) Register(ctx context.Context, username, password, confirmPassword string) error {
158-
registerResp, err := a.lekkoAuthClient.RegisterUser(ctx, connect_go.NewRequest(&bffv1beta1.RegisterUserRequest{
158+
registerResp, err := a.lekkoAuthClient.RegisterUser(ctx, connect.NewRequest(&bffv1beta1.RegisterUserRequest{
159159
Username: username,
160160
Password: password,
161161
ConfirmPassword: confirmPassword,
@@ -170,7 +170,7 @@ func (a *OAuth) Register(ctx context.Context, username, password, confirmPasswor
170170
}
171171

172172
func (a *OAuth) ConfirmUser(ctx context.Context, username, code string) error {
173-
_, err := a.lekkoAuthClient.ConfirmUser(ctx, connect_go.NewRequest(&bffv1beta1.ConfirmUserRequest{
173+
_, err := a.lekkoAuthClient.ConfirmUser(ctx, connect.NewRequest(&bffv1beta1.ConfirmUserRequest{
174174
Username: username,
175175
Code: code,
176176
}))
@@ -188,7 +188,7 @@ func (a *OAuth) Tokens(ctx context.Context, rs secrets.ReadSecrets) []string {
188188
}
189189

190190
func (a *OAuth) ForgotPassword(ctx context.Context, email string) error {
191-
_, err := a.lekkoAuthClient.ForgotPassword(ctx, connect_go.NewRequest(
191+
_, err := a.lekkoAuthClient.ForgotPassword(ctx, connect.NewRequest(
192192
&bffv1beta1.ForgotPasswordRequest{Username: email}),
193193
)
194194
return err
@@ -197,7 +197,7 @@ func (a *OAuth) ForgotPassword(ctx context.Context, email string) error {
197197
func (a *OAuth) ConfirmForgotPassword(
198198
ctx context.Context, email string, newPassword string, confirmNewPassword string, verificationCode string,
199199
) error {
200-
_, err := a.lekkoAuthClient.ConfirmForgotPassword(ctx, connect_go.NewRequest(
200+
_, err := a.lekkoAuthClient.ConfirmForgotPassword(ctx, connect.NewRequest(
201201
&bffv1beta1.ConfirmForgotPasswordRequest{
202202
Username: email,
203203
NewPassword: newPassword,
@@ -209,7 +209,7 @@ func (a *OAuth) ConfirmForgotPassword(
209209
}
210210

211211
func (a *OAuth) ResendVerification(ctx context.Context, email string) error {
212-
_, err := a.lekkoAuthClient.ResendVerificationCode(ctx, connect_go.NewRequest(
212+
_, err := a.lekkoAuthClient.ResendVerificationCode(ctx, connect.NewRequest(
213213
&bffv1beta1.ResendVerificationCodeRequest{Username: email}),
214214
)
215215
return err
@@ -338,7 +338,7 @@ func (a *OAuth) loginGithub(ctx context.Context, ws secrets.WriteSecrets) error
338338
}
339339

340340
func (a *OAuth) checkLekkoAuth(ctx context.Context) (username string, err error) {
341-
req := connect_go.NewRequest(&bffv1beta1.GetUserLoggedInInfoRequest{})
341+
req := connect.NewRequest(&bffv1beta1.GetUserLoggedInInfoRequest{})
342342
resp, err := a.lekkoBFFClient.GetUserLoggedInInfo(ctx, req)
343343
if err != nil {
344344
return "", errors.Wrap(err, "check lekko auth")

‎pkg/repo/cmd.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,10 @@ import (
2121
"os"
2222
"path/filepath"
2323

24-
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/bufbuild/connect-go/lekko/bff/v1beta1/bffv1beta1connect"
24+
bffv1beta1connect "buf.build/gen/go/lekkodev/cli/connectrpc/go/lekko/bff/v1beta1/bffv1beta1connect"
2525
bffv1beta1 "buf.build/gen/go/lekkodev/cli/protocolbuffers/go/lekko/bff/v1beta1"
26+
"connectrpc.com/connect"
2627
"github.com/AlecAivazis/survey/v2"
27-
connect_go "github.com/bufbuild/connect-go"
2828
"github.com/go-git/go-git/v5"
2929
"github.com/go-git/go-git/v5/config"
3030
"github.com/go-git/go-git/v5/plumbing"
@@ -61,7 +61,7 @@ var ErrRemoteHasChanges = errors.New("Remote repository has new changes, " +
6161
fmt.Sprintf("please run %s to merge them locally and try again.", logging.Bold("lekko pull")))
6262

6363
func (r *RepoCmd) List(ctx context.Context) ([]*Repository, error) {
64-
resp, err := r.lekkoBFFClient.ListRepositories(ctx, connect_go.NewRequest(&bffv1beta1.ListRepositoriesRequest{}))
64+
resp, err := r.lekkoBFFClient.ListRepositories(ctx, connect.NewRequest(&bffv1beta1.ListRepositoriesRequest{}))
6565
if err != nil {
6666
return nil, errors.Wrap(err, "list repos")
6767
}
@@ -85,7 +85,7 @@ func repoFromProto(repo *bffv1beta1.Repository) *Repository {
8585
}
8686

8787
func (r *RepoCmd) Create(ctx context.Context, owner, repo, description string) (string, error) {
88-
resp, err := r.lekkoBFFClient.CreateRepository(ctx, connect_go.NewRequest(&bffv1beta1.CreateRepositoryRequest{
88+
resp, err := r.lekkoBFFClient.CreateRepository(ctx, connect.NewRequest(&bffv1beta1.CreateRepositoryRequest{
8989
RepoKey: &bffv1beta1.RepositoryKey{
9090
OwnerName: owner,
9191
RepoName: repo,
@@ -99,7 +99,7 @@ func (r *RepoCmd) Create(ctx context.Context, owner, repo, description string) (
9999
}
100100

101101
func (r *RepoCmd) Delete(ctx context.Context, owner, repo string, deleteOnRemote bool) error {
102-
_, err := r.lekkoBFFClient.DeleteRepository(ctx, connect_go.NewRequest(&bffv1beta1.DeleteRepositoryRequest{
102+
_, err := r.lekkoBFFClient.DeleteRepository(ctx, connect.NewRequest(&bffv1beta1.DeleteRepositoryRequest{
103103
RepoKey: &bffv1beta1.RepositoryKey{
104104
OwnerName: owner,
105105
RepoName: repo,
@@ -342,7 +342,7 @@ func (r *RepoCmd) Import(ctx context.Context, repoPath, owner, repoName, descrip
342342
}
343343

344344
// Import new repo into Lekko
345-
_, err = r.lekkoBFFClient.ImportRepository(ctx, connect_go.NewRequest(&bffv1beta1.ImportRepositoryRequest{
345+
_, err = r.lekkoBFFClient.ImportRepository(ctx, connect.NewRequest(&bffv1beta1.ImportRepositoryRequest{
346346
RepoKey: &bffv1beta1.RepositoryKey{
347347
OwnerName: owner,
348348
RepoName: repoName,

0 commit comments

Comments
 (0)