Skip to content

Commit a81069d

Browse files
cmagliecmaglie
committed
Inlining methods in ArduinoCoreServiceImpl (part 6: Init)
Added helpers to get init progress.
1 parent 8bd0eef commit a81069d

19 files changed

+103
-53
lines changed

‎commands/grpc_streaming_helpers.go

+42
Original file line numberDiff line numberDiff line change
@@ -76,3 +76,45 @@ func (w *streamingResponseProxyToChan[T]) SetHeader(metadata.MD) error {
7676

7777
func (w *streamingResponseProxyToChan[T]) SetTrailer(tr metadata.MD) {
7878
}
79+
80+
// streamingResponseProxyToCallback is a streaming response proxy that
81+
// forwards the responses to a callback function
82+
type streamingResponseProxyToCallback[T any] struct {
83+
ctx context.Context
84+
cb func(*T) error
85+
}
86+
87+
// creates a streaming response proxy that forwards the responses to a callback function
88+
func streamResponseToCallback[T any](ctx context.Context, cb func(*T) error) *streamingResponseProxyToCallback[T] {
89+
if cb == nil {
90+
cb = func(*T) error { return nil }
91+
}
92+
return &streamingResponseProxyToCallback[T]{ctx: ctx, cb: cb}
93+
}
94+
95+
func (w *streamingResponseProxyToCallback[T]) Send(resp *T) error {
96+
return w.cb(resp)
97+
}
98+
99+
func (w *streamingResponseProxyToCallback[T]) Context() context.Context {
100+
return w.ctx
101+
}
102+
103+
func (w *streamingResponseProxyToCallback[T]) RecvMsg(m any) error {
104+
return errors.New("RecvMsg not implemented")
105+
}
106+
107+
func (w *streamingResponseProxyToCallback[T]) SendHeader(metadata.MD) error {
108+
return errors.New("SendHeader not implemented")
109+
}
110+
111+
func (w *streamingResponseProxyToCallback[T]) SendMsg(m any) error {
112+
return errors.New("SendMsg not implemented")
113+
}
114+
115+
func (w *streamingResponseProxyToCallback[T]) SetHeader(metadata.MD) error {
116+
return errors.New("SetHeader not implemented")
117+
}
118+
119+
func (w *streamingResponseProxyToCallback[T]) SetTrailer(tr metadata.MD) {
120+
}

‎commands/instances.go

+13-6
Original file line numberDiff line numberDiff line change
@@ -96,23 +96,30 @@ func (s *arduinoCoreServerImpl) Create(ctx context.Context, req *rpc.CreateReque
9696
return &rpc.CreateResponse{Instance: inst}, nil
9797
}
9898

99+
// InitStreamResponseToCallbackFunction returns a gRPC stream to be used in Init that sends
100+
// all responses to the callback function.
101+
func InitStreamResponseToCallbackFunction(ctx context.Context, cb func(r *rpc.InitResponse) error) rpc.ArduinoCoreService_InitServer {
102+
return streamResponseToCallback(ctx, cb)
103+
}
104+
99105
// Init loads installed libraries and Platforms in CoreInstance with specified ID,
100106
// a gRPC status error is returned if the CoreInstance doesn't exist.
101107
// All responses are sent through responseCallback, can be nil to ignore all responses.
102108
// Failures don't stop the loading process, in case of loading failure the Platform or library
103109
// is simply skipped and an error gRPC status is sent to responseCallback.
104-
func Init(req *rpc.InitRequest, responseCallback func(r *rpc.InitResponse)) error {
105-
if responseCallback == nil {
106-
responseCallback = func(r *rpc.InitResponse) {}
107-
}
110+
func (s *arduinoCoreServerImpl) Init(req *rpc.InitRequest, stream rpc.ArduinoCoreService_InitServer) error {
108111
instance := req.GetInstance()
109112
if !instances.IsValid(instance) {
110113
return &cmderrors.InvalidInstanceError{}
111114
}
112115

113116
// Setup callback functions
114-
if responseCallback == nil {
115-
responseCallback = func(r *rpc.InitResponse) {}
117+
var responseCallback func(*rpc.InitResponse) error
118+
if stream != nil {
119+
syncSend := NewSynchronizedSend(stream.Send)
120+
responseCallback = syncSend.Send
121+
} else {
122+
responseCallback = func(*rpc.InitResponse) error { return nil }
116123
}
117124
responseError := func(st *status.Status) {
118125
responseCallback(&rpc.InitResponse{

‎commands/service.go

+6-12
Original file line numberDiff line numberDiff line change
@@ -78,12 +78,6 @@ func (s *arduinoCoreServerImpl) UpdateLibrariesIndex(req *rpc.UpdateLibrariesInd
7878
return err
7979
}
8080

81-
// Init FIXMEDOC
82-
func (s *arduinoCoreServerImpl) Init(req *rpc.InitRequest, stream rpc.ArduinoCoreService_InitServer) error {
83-
syncSend := NewSynchronizedSend(stream.Send)
84-
return Init(req, func(message *rpc.InitResponse) { syncSend.Send(message) })
85-
}
86-
8781
// Version FIXMEDOC
8882
func (s *arduinoCoreServerImpl) Version(ctx context.Context, req *rpc.VersionRequest) (*rpc.VersionResponse, error) {
8983
return &rpc.VersionResponse{Version: s.versionString}, nil
@@ -144,7 +138,7 @@ func (s *arduinoCoreServerImpl) Compile(req *rpc.CompileRequest, stream rpc.Ardu
144138
func (s *arduinoCoreServerImpl) PlatformInstall(req *rpc.PlatformInstallRequest, stream rpc.ArduinoCoreService_PlatformInstallServer) error {
145139
syncSend := NewSynchronizedSend(stream.Send)
146140
resp, err := PlatformInstall(
147-
stream.Context(), req,
141+
stream.Context(), s, req,
148142
func(p *rpc.DownloadProgress) { syncSend.Send(&rpc.PlatformInstallResponse{Progress: p}) },
149143
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.PlatformInstallResponse{TaskProgress: p}) },
150144
)
@@ -171,7 +165,7 @@ func (s *arduinoCoreServerImpl) PlatformDownload(req *rpc.PlatformDownloadReques
171165
func (s *arduinoCoreServerImpl) PlatformUninstall(req *rpc.PlatformUninstallRequest, stream rpc.ArduinoCoreService_PlatformUninstallServer) error {
172166
syncSend := NewSynchronizedSend(stream.Send)
173167
resp, err := PlatformUninstall(
174-
stream.Context(), req,
168+
stream.Context(), s, req,
175169
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.PlatformUninstallResponse{TaskProgress: p}) },
176170
)
177171
if err != nil {
@@ -184,7 +178,7 @@ func (s *arduinoCoreServerImpl) PlatformUninstall(req *rpc.PlatformUninstallRequ
184178
func (s *arduinoCoreServerImpl) PlatformUpgrade(req *rpc.PlatformUpgradeRequest, stream rpc.ArduinoCoreService_PlatformUpgradeServer) error {
185179
syncSend := NewSynchronizedSend(stream.Send)
186180
resp, err := PlatformUpgrade(
187-
stream.Context(), req,
181+
stream.Context(), s, req,
188182
func(p *rpc.DownloadProgress) { syncSend.Send(&rpc.PlatformUpgradeResponse{Progress: p}) },
189183
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.PlatformUpgradeResponse{TaskProgress: p}) },
190184
)
@@ -304,7 +298,7 @@ func (s *arduinoCoreServerImpl) LibraryDownload(req *rpc.LibraryDownloadRequest,
304298
func (s *arduinoCoreServerImpl) LibraryInstall(req *rpc.LibraryInstallRequest, stream rpc.ArduinoCoreService_LibraryInstallServer) error {
305299
syncSend := NewSynchronizedSend(stream.Send)
306300
return LibraryInstall(
307-
stream.Context(), req,
301+
stream.Context(), s, req,
308302
func(p *rpc.DownloadProgress) { syncSend.Send(&rpc.LibraryInstallResponse{Progress: p}) },
309303
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.LibraryInstallResponse{TaskProgress: p}) },
310304
)
@@ -314,7 +308,7 @@ func (s *arduinoCoreServerImpl) LibraryInstall(req *rpc.LibraryInstallRequest, s
314308
func (s *arduinoCoreServerImpl) LibraryUpgrade(req *rpc.LibraryUpgradeRequest, stream rpc.ArduinoCoreService_LibraryUpgradeServer) error {
315309
syncSend := NewSynchronizedSend(stream.Send)
316310
return LibraryUpgrade(
317-
stream.Context(), req,
311+
stream.Context(), s, req,
318312
func(p *rpc.DownloadProgress) { syncSend.Send(&rpc.LibraryUpgradeResponse{Progress: p}) },
319313
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.LibraryUpgradeResponse{TaskProgress: p}) },
320314
)
@@ -331,7 +325,7 @@ func (s *arduinoCoreServerImpl) LibraryUninstall(req *rpc.LibraryUninstallReques
331325
// LibraryUpgradeAll FIXMEDOC
332326
func (s *arduinoCoreServerImpl) LibraryUpgradeAll(req *rpc.LibraryUpgradeAllRequest, stream rpc.ArduinoCoreService_LibraryUpgradeAllServer) error {
333327
syncSend := NewSynchronizedSend(stream.Send)
334-
return LibraryUpgradeAll(req,
328+
return LibraryUpgradeAll(s, req,
335329
func(p *rpc.DownloadProgress) { syncSend.Send(&rpc.LibraryUpgradeAllResponse{Progress: p}) },
336330
func(p *rpc.TaskProgress) { syncSend.Send(&rpc.LibraryUpgradeAllResponse{TaskProgress: p}) },
337331
)

‎commands/service_library_install.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import (
3131
)
3232

3333
// LibraryInstall resolves the library dependencies, then downloads and installs the libraries into the install location.
34-
func LibraryInstall(ctx context.Context, req *rpc.LibraryInstallRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
34+
func LibraryInstall(ctx context.Context, srv rpc.ArduinoCoreServiceServer, req *rpc.LibraryInstallRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
3535
// Obtain the library index from the manager
3636
li, err := instances.GetLibrariesIndex(req.GetInstance())
3737
if err != nil {
@@ -136,7 +136,8 @@ func LibraryInstall(ctx context.Context, req *rpc.LibraryInstallRequest, downloa
136136
}
137137
}
138138

139-
if err := Init(&rpc.InitRequest{Instance: req.GetInstance()}, nil); err != nil {
139+
stream := InitStreamResponseToCallbackFunction(ctx, nil)
140+
if err := srv.Init(&rpc.InitRequest{Instance: req.GetInstance()}, stream); err != nil {
140141
return err
141142
}
142143

‎commands/service_library_upgrade.go

+10-7
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,9 @@ import (
2424
)
2525

2626
// LibraryUpgradeAll upgrades all the available libraries
27-
func LibraryUpgradeAll(req *rpc.LibraryUpgradeAllRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
27+
func LibraryUpgradeAll(srv rpc.ArduinoCoreServiceServer, req *rpc.LibraryUpgradeAllRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
28+
ctx := context.Background()
29+
2830
li, err := instances.GetLibrariesIndex(req.GetInstance())
2931
if err != nil {
3032
return err
@@ -37,19 +39,20 @@ func LibraryUpgradeAll(req *rpc.LibraryUpgradeAllRequest, downloadCB rpc.Downloa
3739
libsToUpgrade := listLibraries(lme, li, true, false)
3840
release()
3941

40-
if err := upgrade(req.GetInstance(), libsToUpgrade, downloadCB, taskCB); err != nil {
42+
if err := upgrade(ctx, srv, req.GetInstance(), libsToUpgrade, downloadCB, taskCB); err != nil {
4143
return err
4244
}
4345

44-
if err := Init(&rpc.InitRequest{Instance: req.GetInstance()}, nil); err != nil {
46+
stream := InitStreamResponseToCallbackFunction(ctx, nil)
47+
if err := srv.Init(&rpc.InitRequest{Instance: req.GetInstance()}, stream); err != nil {
4548
return err
4649
}
4750

4851
return nil
4952
}
5053

5154
// LibraryUpgrade upgrades a library
52-
func LibraryUpgrade(ctx context.Context, req *rpc.LibraryUpgradeRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
55+
func LibraryUpgrade(ctx context.Context, srv rpc.ArduinoCoreServiceServer, req *rpc.LibraryUpgradeRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
5356
li, err := instances.GetLibrariesIndex(req.GetInstance())
5457
if err != nil {
5558
return err
@@ -75,10 +78,10 @@ func LibraryUpgrade(ctx context.Context, req *rpc.LibraryUpgradeRequest, downloa
7578
}
7679

7780
// Install update
78-
return upgrade(req.GetInstance(), []*installedLib{lib}, downloadCB, taskCB)
81+
return upgrade(ctx, srv, req.GetInstance(), []*installedLib{lib}, downloadCB, taskCB)
7982
}
8083

81-
func upgrade(instance *rpc.Instance, libs []*installedLib, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
84+
func upgrade(ctx context.Context, srv rpc.ArduinoCoreServiceServer, instance *rpc.Instance, libs []*installedLib, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) error {
8285
for _, lib := range libs {
8386
libInstallReq := &rpc.LibraryInstallRequest{
8487
Instance: instance,
@@ -87,7 +90,7 @@ func upgrade(instance *rpc.Instance, libs []*installedLib, downloadCB rpc.Downlo
8790
NoDeps: false,
8891
NoOverwrite: false,
8992
}
90-
err := LibraryInstall(context.Background(), libInstallReq, downloadCB, taskCB)
93+
err := LibraryInstall(ctx, srv, libInstallReq, downloadCB, taskCB)
9194
if err != nil {
9295
return err
9396
}

‎commands/service_platform_install.go

+4-2
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import (
2626
)
2727

2828
// PlatformInstall FIXMEDOC
29-
func PlatformInstall(ctx context.Context, req *rpc.PlatformInstallRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) (*rpc.PlatformInstallResponse, error) {
29+
func PlatformInstall(ctx context.Context, srv rpc.ArduinoCoreServiceServer, req *rpc.PlatformInstallRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) (*rpc.PlatformInstallResponse, error) {
3030
install := func() error {
3131
pme, release, err := instances.GetPackageManagerExplorer(req.GetInstance())
3232
if err != nil {
@@ -73,7 +73,9 @@ func PlatformInstall(ctx context.Context, req *rpc.PlatformInstallRequest, downl
7373
if err := install(); err != nil {
7474
return nil, err
7575
}
76-
if err := Init(&rpc.InitRequest{Instance: req.GetInstance()}, nil); err != nil {
76+
77+
stream := InitStreamResponseToCallbackFunction(ctx, nil)
78+
if err := srv.Init(&rpc.InitRequest{Instance: req.GetInstance()}, stream); err != nil {
7779
return nil, err
7880
}
7981
return &rpc.PlatformInstallResponse{}, nil

‎commands/service_platform_search_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func TestPlatformSearch(t *testing.T) {
4646
inst := createResp.GetInstance()
4747
require.NotNil(t, inst)
4848

49-
err = Init(&rpc.InitRequest{Instance: inst}, nil)
49+
err = srv.Init(&rpc.InitRequest{Instance: inst}, InitStreamResponseToCallbackFunction(ctx, nil))
5050
require.NoError(t, err)
5151

5252
t.Run("SearchAllVersions", func(t *testing.T) {
@@ -347,7 +347,7 @@ func TestPlatformSearchSorting(t *testing.T) {
347347
require.NoError(t, err)
348348
inst := createResp.GetInstance()
349349
require.NotNil(t, inst)
350-
err = Init(&rpc.InitRequest{Instance: inst}, nil)
350+
err = srv.Init(&rpc.InitRequest{Instance: inst}, InitStreamResponseToCallbackFunction(ctx, nil))
351351
require.NoError(t, err)
352352

353353
res, stat := PlatformSearch(&rpc.PlatformSearchRequest{

‎commands/service_platform_uninstall.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,11 @@ import (
2525
)
2626

2727
// PlatformUninstall FIXMEDOC
28-
func PlatformUninstall(ctx context.Context, req *rpc.PlatformUninstallRequest, taskCB rpc.TaskProgressCB) (*rpc.PlatformUninstallResponse, error) {
28+
func PlatformUninstall(ctx context.Context, srv rpc.ArduinoCoreServiceServer, req *rpc.PlatformUninstallRequest, taskCB rpc.TaskProgressCB) (*rpc.PlatformUninstallResponse, error) {
2929
if err := platformUninstall(req, taskCB); err != nil {
3030
return nil, err
3131
}
32-
if err := Init(&rpc.InitRequest{Instance: req.GetInstance()}, nil); err != nil {
32+
if err := srv.Init(&rpc.InitRequest{Instance: req.GetInstance()}, InitStreamResponseToCallbackFunction(ctx, nil)); err != nil {
3333
return nil, err
3434
}
3535
return &rpc.PlatformUninstallResponse{}, nil

‎commands/service_platform_upgrade.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import (
2525
)
2626

2727
// PlatformUpgrade FIXMEDOC
28-
func PlatformUpgrade(ctx context.Context, req *rpc.PlatformUpgradeRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) (*rpc.PlatformUpgradeResponse, error) {
28+
func PlatformUpgrade(ctx context.Context, srv rpc.ArduinoCoreServiceServer, req *rpc.PlatformUpgradeRequest, downloadCB rpc.DownloadProgressCB, taskCB rpc.TaskProgressCB) (*rpc.PlatformUpgradeResponse, error) {
2929
upgrade := func() (*cores.PlatformRelease, error) {
3030
pme, release, err := instances.GetPackageManagerExplorer(req.GetInstance())
3131
if err != nil {
@@ -57,7 +57,7 @@ func PlatformUpgrade(ctx context.Context, req *rpc.PlatformUpgradeRequest, downl
5757
if err != nil {
5858
return &rpc.PlatformUpgradeResponse{Platform: rpcPlatform}, err
5959
}
60-
if err := Init(&rpc.InitRequest{Instance: req.GetInstance()}, nil); err != nil {
60+
if err := srv.Init(&rpc.InitRequest{Instance: req.GetInstance()}, InitStreamResponseToCallbackFunction(ctx, nil)); err != nil {
6161
return nil, err
6262
}
6363

‎internal/cli/core/install.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func runInstallCommand(srv rpc.ArduinoCoreServiceServer, args []string, scriptFl
7676
NoOverwrite: noOverwrite,
7777
SkipPreUninstall: scriptFlags.DetectSkipPreUninstallValue(),
7878
}
79-
_, err := commands.PlatformInstall(context.Background(), platformInstallRequest, feedback.ProgressBar(), feedback.TaskProgress())
79+
_, err := commands.PlatformInstall(ctx, srv, platformInstallRequest, feedback.ProgressBar(), feedback.TaskProgress())
8080
if err != nil {
8181
feedback.Fatal(tr("Error during install: %v", err), feedback.ErrGeneric)
8282
}

‎internal/cli/core/search.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ func runSearchCommand(srv rpc.ArduinoCoreServiceServer, args []string, allVersio
6666
for _, idxRes := range res.GetUpdatedIndexes() {
6767
if idxRes.GetStatus() == rpc.IndexUpdateReport_STATUS_UPDATED {
6868
// At least one index has been updated, reinitialize the instance
69-
instance.Init(inst)
69+
instance.Init(ctx, srv, inst)
7070
break
7171
}
7272
}

‎internal/cli/core/uninstall.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ func runUninstallCommand(srv rpc.ArduinoCoreServiceServer, args []string, preUni
6464
}
6565
}
6666
for _, platformRef := range platformsRefs {
67-
_, err := commands.PlatformUninstall(context.Background(), &rpc.PlatformUninstallRequest{
67+
_, err := commands.PlatformUninstall(ctx, srv, &rpc.PlatformUninstallRequest{
6868
Instance: inst,
6969
PlatformPackage: platformRef.PackageName,
7070
Architecture: platformRef.Architecture,

‎internal/cli/core/upgrade.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ func Upgrade(ctx context.Context, srv rpc.ArduinoCoreServiceServer, inst *rpc.In
123123
SkipPostInstall: skipPostInstall,
124124
SkipPreUninstall: skipPreUninstall,
125125
}
126-
response, err := commands.PlatformUpgrade(context.Background(), r, feedback.ProgressBar(), feedback.TaskProgress())
126+
response, err := commands.PlatformUpgrade(ctx, srv, r, feedback.ProgressBar(), feedback.TaskProgress())
127127
warningMissingIndex(response)
128128
if err != nil {
129129
var alreadyAtLatestVersionErr *cmderrors.PlatformAlreadyAtTheLatestVersionError

‎internal/cli/instance/instance.go

+7-6
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ func CreateAndInitWithProfile(ctx context.Context, srv rpc.ArduinoCoreServiceSer
4444
if err != nil {
4545
feedback.Fatal(tr("Error creating instance: %v", err), feedback.ErrGeneric)
4646
}
47-
profile := InitWithProfile(instance, profileName, sketchPath)
47+
profile := InitWithProfile(ctx, srv, instance, profileName, sketchPath)
4848
return instance, profile
4949
}
5050

@@ -62,14 +62,14 @@ func create(ctx context.Context, srv rpc.ArduinoCoreServiceServer) (*rpc.Instanc
6262
// platform or library that we failed to load.
6363
// Package and library indexes files are automatically updated if the
6464
// CLI is run for the first time.
65-
func Init(instance *rpc.Instance) {
66-
InitWithProfile(instance, "", nil)
65+
func Init(ctx context.Context, srv rpc.ArduinoCoreServiceServer, instance *rpc.Instance) {
66+
InitWithProfile(ctx, srv, instance, "", nil)
6767
}
6868

6969
// InitWithProfile initializes instance by loading libraries and platforms specified in the given profile of the given sketch.
7070
// In case of loading failures return a list of errors for each platform or library that we failed to load.
7171
// Required Package and library indexes files are automatically downloaded.
72-
func InitWithProfile(instance *rpc.Instance, profileName string, sketchPath *paths.Path) *rpc.SketchProfile {
72+
func InitWithProfile(ctx context.Context, srv rpc.ArduinoCoreServiceServer, instance *rpc.Instance, profileName string, sketchPath *paths.Path) *rpc.SketchProfile {
7373
downloadCallback := feedback.ProgressBar()
7474
taskCallback := feedback.TaskProgress()
7575

@@ -79,7 +79,7 @@ func InitWithProfile(instance *rpc.Instance, profileName string, sketchPath *pat
7979
initReq.Profile = profileName
8080
}
8181
var profile *rpc.SketchProfile
82-
err := commands.Init(initReq, func(res *rpc.InitResponse) {
82+
err := srv.Init(initReq, commands.InitStreamResponseToCallbackFunction(ctx, func(res *rpc.InitResponse) error {
8383
if st := res.GetError(); st != nil {
8484
feedback.Warning(tr("Error initializing instance: %v", st.GetMessage()))
8585
}
@@ -96,7 +96,8 @@ func InitWithProfile(instance *rpc.Instance, profileName string, sketchPath *pat
9696
if p := res.GetProfile(); p != nil {
9797
profile = p
9898
}
99-
})
99+
return nil
100+
}))
100101
if err != nil {
101102
feedback.Warning(tr("Error initializing instance: %v", err))
102103
}

‎internal/cli/lib/install.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ func runInstallCommand(srv rpc.ArduinoCoreServiceServer, args []string, noDeps b
141141
NoOverwrite: noOverwrite,
142142
InstallLocation: installLocation,
143143
}
144-
err := commands.LibraryInstall(context.Background(), libraryInstallRequest, feedback.ProgressBar(), feedback.TaskProgress())
144+
err := commands.LibraryInstall(ctx, srv, libraryInstallRequest, feedback.ProgressBar(), feedback.TaskProgress())
145145
if err != nil {
146146
feedback.Fatal(tr("Error installing %s: %v", libRef.Name, err), feedback.ErrGeneric)
147147
}

‎internal/cli/lib/search.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ func runSearchCommand(srv rpc.ArduinoCoreServiceServer, args []string, namesOnly
116116
feedback.Fatal(tr("Error updating library index: %v", err), feedback.ErrGeneric)
117117
}
118118
if res.GetLibrariesIndex().GetStatus() == rpc.IndexUpdateReport_STATUS_UPDATED {
119-
instance.Init(inst)
119+
instance.Init(ctx, srv, inst)
120120
}
121121

122122
searchResp, err := commands.LibrarySearch(context.Background(), &rpc.LibrarySearchRequest{

0 commit comments

Comments
 (0)