Skip to content

GitLab

A
arduino-cli
Commit 2c1b10d8 authored by Cristian Maglie's avatar Cristian Maglie
Browse files
Options

Added status streaming to Init grpc call 

This will be useful in the next commits
parent 02a8800f
Hide whitespace changes
Inline Side-by-side
Showing with 197 additions and 123 deletions
cli/cli.go
View file @ 2c1b10d8
......@@ -86,7 +86,7 @@ func packageManagerInitReq() *rpc.InitReq {
func InitInstance() *rpc.InitResp {
logrus.Info("Initializing package manager")
req := packageManagerInitReq()
resp, err := commands.Init(context.Background(), req)
resp, err := commands.Init(context.Background(), req, OutputProgressBar(), OutputTaskProgress())
if err != nil {
formatter.PrintError(err, "Error initializing package manager")
os.Exit(ErrGeneric)
......
commands/instances.go
View file @ 2c1b10d8
......@@ -72,7 +72,7 @@ func GetLibraryManager(req InstanceContainer) *librariesmanager.LibrariesManager
return i.lm
}
func Init(ctx context.Context, req *rpc.InitReq) (*rpc.InitResp, error) {
func Init(ctx context.Context, req *rpc.InitReq, downloadCB DownloadProgressCB, taskCB TaskProgressCB) (*rpc.InitResp, error) {
inConfig := req.GetConfiguration()
if inConfig == nil {
return nil, fmt.Errorf("invalid request")
......
daemon/client/client.go
View file @ 2c1b10d8
......@@ -46,7 +46,7 @@ func main() {
// INIT
fmt.Println("=== calling Init")
initResp, err := client.Init(context.Background(), &rpc.InitReq{
initRespStream, err := client.Init(context.Background(), &rpc.InitReq{
Configuration: &rpc.Configuration{
DataDir: datadir,
},
......@@ -55,9 +55,28 @@ func main() {
fmt.Printf("Error creating server instance: %s\n", err)
os.Exit(1)
}
instance := initResp.GetInstance()
fmt.Printf("---> %+v\n", initResp)
fmt.Println()
var instance *rpc.Instance
for {
initResp, err := initRespStream.Recv()
if err == io.EOF {
fmt.Println()
break
}
if err != nil {
fmt.Printf("Init error: %s\n", err)
os.Exit(1)
}
if initResp.GetInstance() != nil {
instance = initResp.GetInstance()
fmt.Printf("---> %+v\n", initResp)
}
if initResp.GetDownloadProgress() != nil {
fmt.Printf(">> DOWNLOAD: %s\n", initResp.GetDownloadProgress())
}
if initResp.GetTaskProgress() != nil {
fmt.Printf(">> TASK: %s\n", initResp.GetTaskProgress())
}
}
// UPDATE-INDEX
fmt.Println("=== calling UpdateIndex")
......
daemon/daemon.go
View file @ 2c1b10d8
......@@ -103,8 +103,16 @@ func (s *ArduinoCoreServerImpl) UpdateLibrariesIndex(req *rpc.UpdateLibrariesInd
return stream.Send(&rpc.UpdateLibrariesIndexResp{})
}
func (s *ArduinoCoreServerImpl) Init(ctx context.Context, req *rpc.InitReq) (*rpc.InitResp, error) {
return commands.Init(ctx, req)
func (s *ArduinoCoreServerImpl) Init(req *rpc.InitReq, stream rpc.ArduinoCore_InitServer) error {
resp, err := commands.Init(stream.Context(), req,
func(p *rpc.DownloadProgress) { stream.Send(&rpc.InitResp{DownloadProgress: p}) },
func(p *rpc.TaskProgress) { stream.Send(&rpc.InitResp{TaskProgress: p}) },
)
if err != nil {
return err
}
fmt.Println(resp)
return stream.Send(resp)
}
func (s *ArduinoCoreServerImpl) Compile(req *rpc.CompileReq, stream rpc.ArduinoCore_CompileServer) error {
......
rpc/commands.pb.go
View file @ 2c1b10d8
......@@ -46,7 +46,7 @@ func (m *Configuration) Reset() { *m = Configuration{} }
func (m *Configuration) String() string { return proto.CompactTextString(m) }
func (*Configuration) ProtoMessage() {}
func (*Configuration) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{0}
return fileDescriptor_commands_a00a100136eab5d5, []int{0}
}
func (m *Configuration) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Configuration.Unmarshal(m, b)
......@@ -106,7 +106,7 @@ func (m *InitReq) Reset() { *m = InitReq{} }
func (m *InitReq) String() string { return proto.CompactTextString(m) }
func (*InitReq) ProtoMessage() {}
func (*InitReq) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{1}
return fileDescriptor_commands_a00a100136eab5d5, []int{1}
}
func (m *InitReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_InitReq.Unmarshal(m, b)
......@@ -141,19 +141,21 @@ func (m *InitReq) GetLibraryManagerOnly() bool {
}
type InitResp struct {
Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
PlatformsIndexErrors []string `protobuf:"bytes,2,rep,name=platforms_index_errors,json=platformsIndexErrors,proto3" json:"platforms_index_errors,omitempty"`
LibrariesIndexError string `protobuf:"bytes,3,opt,name=libraries_index_error,json=librariesIndexError,proto3" json:"libraries_index_error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
PlatformsIndexErrors []string `protobuf:"bytes,2,rep,name=platforms_index_errors,json=platformsIndexErrors,proto3" json:"platforms_index_errors,omitempty"`
LibrariesIndexError string `protobuf:"bytes,3,opt,name=libraries_index_error,json=librariesIndexError,proto3" json:"libraries_index_error,omitempty"`
DownloadProgress *DownloadProgress `protobuf:"bytes,4,opt,name=download_progress,json=downloadProgress,proto3" json:"download_progress,omitempty"`
TaskProgress *TaskProgress `protobuf:"bytes,5,opt,name=task_progress,json=taskProgress,proto3" json:"task_progress,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *InitResp) Reset() { *m = InitResp{} }
func (m *InitResp) String() string { return proto.CompactTextString(m) }
func (*InitResp) ProtoMessage() {}
func (*InitResp) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{2}
return fileDescriptor_commands_a00a100136eab5d5, []int{2}
}
func (m *InitResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_InitResp.Unmarshal(m, b)
......@@ -194,6 +196,20 @@ func (m *InitResp) GetLibrariesIndexError() string {
return ""
}
func (m *InitResp) GetDownloadProgress() *DownloadProgress {
if m != nil {
return m.DownloadProgress
}
return nil
}
func (m *InitResp) GetTaskProgress() *TaskProgress {
if m != nil {
return m.TaskProgress
}
return nil
}
type DestroyReq struct {
Instance *Instance `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
......@@ -205,7 +221,7 @@ func (m *DestroyReq) Reset() { *m = DestroyReq{} }
func (m *DestroyReq) String() string { return proto.CompactTextString(m) }
func (*DestroyReq) ProtoMessage() {}
func (*DestroyReq) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{3}
return fileDescriptor_commands_a00a100136eab5d5, []int{3}
}
func (m *DestroyReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DestroyReq.Unmarshal(m, b)
......@@ -242,7 +258,7 @@ func (m *DestroyResp) Reset() { *m = DestroyResp{} }
func (m *DestroyResp) String() string { return proto.CompactTextString(m) }
func (*DestroyResp) ProtoMessage() {}
func (*DestroyResp) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{4}
return fileDescriptor_commands_a00a100136eab5d5, []int{4}
}
func (m *DestroyResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DestroyResp.Unmarshal(m, b)
......@@ -273,7 +289,7 @@ func (m *RescanReq) Reset() { *m = RescanReq{} }
func (m *RescanReq) String() string { return proto.CompactTextString(m) }
func (*RescanReq) ProtoMessage() {}
func (*RescanReq) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{5}
return fileDescriptor_commands_a00a100136eab5d5, []int{5}
}
func (m *RescanReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RescanReq.Unmarshal(m, b)
......@@ -312,7 +328,7 @@ func (m *RescanResp) Reset() { *m = RescanResp{} }
func (m *RescanResp) String() string { return proto.CompactTextString(m) }
func (*RescanResp) ProtoMessage() {}
func (*RescanResp) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{6}
return fileDescriptor_commands_a00a100136eab5d5, []int{6}
}
func (m *RescanResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_RescanResp.Unmarshal(m, b)
......@@ -357,7 +373,7 @@ func (m *UpdateIndexReq) Reset() { *m = UpdateIndexReq{} }
func (m *UpdateIndexReq) String() string { return proto.CompactTextString(m) }
func (*UpdateIndexReq) ProtoMessage() {}
func (*UpdateIndexReq) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{7}
return fileDescriptor_commands_a00a100136eab5d5, []int{7}
}
func (m *UpdateIndexReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateIndexReq.Unmarshal(m, b)
......@@ -395,7 +411,7 @@ func (m *UpdateIndexResp) Reset() { *m = UpdateIndexResp{} }
func (m *UpdateIndexResp) String() string { return proto.CompactTextString(m) }
func (*UpdateIndexResp) ProtoMessage() {}
func (*UpdateIndexResp) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{8}
return fileDescriptor_commands_a00a100136eab5d5, []int{8}
}
func (m *UpdateIndexResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateIndexResp.Unmarshal(m, b)
......@@ -433,7 +449,7 @@ func (m *UpdateLibrariesIndexReq) Reset() { *m = UpdateLibrariesIndexReq
func (m *UpdateLibrariesIndexReq) String() string { return proto.CompactTextString(m) }
func (*UpdateLibrariesIndexReq) ProtoMessage() {}
func (*UpdateLibrariesIndexReq) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{9}
return fileDescriptor_commands_a00a100136eab5d5, []int{9}
}
func (m *UpdateLibrariesIndexReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateLibrariesIndexReq.Unmarshal(m, b)
......@@ -471,7 +487,7 @@ func (m *UpdateLibrariesIndexResp) Reset() { *m = UpdateLibrariesIndexRe
func (m *UpdateLibrariesIndexResp) String() string { return proto.CompactTextString(m) }
func (*UpdateLibrariesIndexResp) ProtoMessage() {}
func (*UpdateLibrariesIndexResp) Descriptor() ([]byte, []int) {
return fileDescriptor_commands_43421ae8c8c5f1d9, []int{10}
return fileDescriptor_commands_a00a100136eab5d5, []int{10}
}
func (m *UpdateLibrariesIndexResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateLibrariesIndexResp.Unmarshal(m, b)
......@@ -525,7 +541,7 @@ const _ = grpc.SupportPackageIsVersion4
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type ArduinoCoreClient interface {
// Start a new instance of the Arduino Core Service
Init(ctx context.Context, in *InitReq, opts ...grpc.CallOption) (*InitResp, error)
Init(ctx context.Context, in *InitReq, opts ...grpc.CallOption) (ArduinoCore_InitClient, error)
// Destroy an instance of the Arduino Core Service
Destroy(ctx context.Context, in *DestroyReq, opts ...grpc.CallOption) (*DestroyResp, error)
// Rescan instance of the Arduino Core Service
......@@ -562,13 +578,36 @@ func NewArduinoCoreClient(cc *grpc.ClientConn) ArduinoCoreClient {
return &arduinoCoreClient{cc}
}
func (c *arduinoCoreClient) Init(ctx context.Context, in *InitReq, opts ...grpc.CallOption) (*InitResp, error) {
out := new(InitResp)
err := c.cc.Invoke(ctx, "/cc.arduino.core.rpc.ArduinoCore/Init", in, out, opts...)
func (c *arduinoCoreClient) Init(ctx context.Context, in *InitReq, opts ...grpc.CallOption) (ArduinoCore_InitClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[0], "/cc.arduino.core.rpc.ArduinoCore/Init", opts...)
if err != nil {
return nil, err
}
return out, nil
x := &arduinoCoreInitClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type ArduinoCore_InitClient interface {
Recv() (*InitResp, error)
grpc.ClientStream
}
type arduinoCoreInitClient struct {
grpc.ClientStream
}
func (x *arduinoCoreInitClient) Recv() (*InitResp, error) {
m := new(InitResp)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *arduinoCoreClient) Destroy(ctx context.Context, in *DestroyReq, opts ...grpc.CallOption) (*DestroyResp, error) {
......@@ -590,7 +629,7 @@ func (c *arduinoCoreClient) Rescan(ctx context.Context, in *RescanReq, opts ...g
}
func (c *arduinoCoreClient) UpdateIndex(ctx context.Context, in *UpdateIndexReq, opts ...grpc.CallOption) (ArduinoCore_UpdateIndexClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[0], "/cc.arduino.core.rpc.ArduinoCore/UpdateIndex", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[1], "/cc.arduino.core.rpc.ArduinoCore/UpdateIndex", opts...)
if err != nil {
return nil, err
}
......@@ -622,7 +661,7 @@ func (x *arduinoCoreUpdateIndexClient) Recv() (*UpdateIndexResp, error) {
}
func (c *arduinoCoreClient) UpdateLibrariesIndex(ctx context.Context, in *UpdateLibrariesIndexReq, opts ...grpc.CallOption) (ArduinoCore_UpdateLibrariesIndexClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[1], "/cc.arduino.core.rpc.ArduinoCore/UpdateLibrariesIndex", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[2], "/cc.arduino.core.rpc.ArduinoCore/UpdateLibrariesIndex", opts...)
if err != nil {
return nil, err
}
......@@ -663,7 +702,7 @@ func (c *arduinoCoreClient) BoardDetails(ctx context.Context, in *BoardDetailsRe
}
func (c *arduinoCoreClient) BoardAttach(ctx context.Context, in *BoardAttachReq, opts ...grpc.CallOption) (ArduinoCore_BoardAttachClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[2], "/cc.arduino.core.rpc.ArduinoCore/BoardAttach", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[3], "/cc.arduino.core.rpc.ArduinoCore/BoardAttach", opts...)
if err != nil {
return nil, err
}
......@@ -704,7 +743,7 @@ func (c *arduinoCoreClient) BoardList(ctx context.Context, in *BoardListReq, opt
}
func (c *arduinoCoreClient) Compile(ctx context.Context, in *CompileReq, opts ...grpc.CallOption) (ArduinoCore_CompileClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[3], "/cc.arduino.core.rpc.ArduinoCore/Compile", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[4], "/cc.arduino.core.rpc.ArduinoCore/Compile", opts...)
if err != nil {
return nil, err
}
......@@ -736,7 +775,7 @@ func (x *arduinoCoreCompileClient) Recv() (*CompileResp, error) {
}
func (c *arduinoCoreClient) PlatformInstall(ctx context.Context, in *PlatformInstallReq, opts ...grpc.CallOption) (ArduinoCore_PlatformInstallClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[4], "/cc.arduino.core.rpc.ArduinoCore/PlatformInstall", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[5], "/cc.arduino.core.rpc.ArduinoCore/PlatformInstall", opts...)
if err != nil {
return nil, err
}
......@@ -768,7 +807,7 @@ func (x *arduinoCorePlatformInstallClient) Recv() (*PlatformInstallResp, error)
}
func (c *arduinoCoreClient) PlatformDownload(ctx context.Context, in *PlatformDownloadReq, opts ...grpc.CallOption) (ArduinoCore_PlatformDownloadClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[5], "/cc.arduino.core.rpc.ArduinoCore/PlatformDownload", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[6], "/cc.arduino.core.rpc.ArduinoCore/PlatformDownload", opts...)
if err != nil {
return nil, err
}
......@@ -800,7 +839,7 @@ func (x *arduinoCorePlatformDownloadClient) Recv() (*PlatformDownloadResp, error
}
func (c *arduinoCoreClient) PlatformUninstall(ctx context.Context, in *PlatformUninstallReq, opts ...grpc.CallOption) (ArduinoCore_PlatformUninstallClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[6], "/cc.arduino.core.rpc.ArduinoCore/PlatformUninstall", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[7], "/cc.arduino.core.rpc.ArduinoCore/PlatformUninstall", opts...)
if err != nil {
return nil, err
}
......@@ -832,7 +871,7 @@ func (x *arduinoCorePlatformUninstallClient) Recv() (*PlatformUninstallResp, err
}
func (c *arduinoCoreClient) PlatformUpgrade(ctx context.Context, in *PlatformUpgradeReq, opts ...grpc.CallOption) (ArduinoCore_PlatformUpgradeClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[7], "/cc.arduino.core.rpc.ArduinoCore/PlatformUpgrade", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[8], "/cc.arduino.core.rpc.ArduinoCore/PlatformUpgrade", opts...)
if err != nil {
return nil, err
}
......@@ -864,7 +903,7 @@ func (x *arduinoCorePlatformUpgradeClient) Recv() (*PlatformUpgradeResp, error)
}
func (c *arduinoCoreClient) Upload(ctx context.Context, in *UploadReq, opts ...grpc.CallOption) (ArduinoCore_UploadClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[8], "/cc.arduino.core.rpc.ArduinoCore/Upload", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[9], "/cc.arduino.core.rpc.ArduinoCore/Upload", opts...)
if err != nil {
return nil, err
}
......@@ -914,7 +953,7 @@ func (c *arduinoCoreClient) PlatformList(ctx context.Context, in *PlatformListRe
}
func (c *arduinoCoreClient) LibraryDownload(ctx context.Context, in *LibraryDownloadReq, opts ...grpc.CallOption) (ArduinoCore_LibraryDownloadClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[9], "/cc.arduino.core.rpc.ArduinoCore/LibraryDownload", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[10], "/cc.arduino.core.rpc.ArduinoCore/LibraryDownload", opts...)
if err != nil {
return nil, err
}
......@@ -946,7 +985,7 @@ func (x *arduinoCoreLibraryDownloadClient) Recv() (*LibraryDownloadResp, error)
}
func (c *arduinoCoreClient) LibraryInstall(ctx context.Context, in *LibraryInstallReq, opts ...grpc.CallOption) (ArduinoCore_LibraryInstallClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[10], "/cc.arduino.core.rpc.ArduinoCore/LibraryInstall", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[11], "/cc.arduino.core.rpc.ArduinoCore/LibraryInstall", opts...)
if err != nil {
return nil, err
}
......@@ -978,7 +1017,7 @@ func (x *arduinoCoreLibraryInstallClient) Recv() (*LibraryInstallResp, error) {
}
func (c *arduinoCoreClient) LibraryUninstall(ctx context.Context, in *LibraryUninstallReq, opts ...grpc.CallOption) (ArduinoCore_LibraryUninstallClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[11], "/cc.arduino.core.rpc.ArduinoCore/LibraryUninstall", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[12], "/cc.arduino.core.rpc.ArduinoCore/LibraryUninstall", opts...)
if err != nil {
return nil, err
}
......@@ -1010,7 +1049,7 @@ func (x *arduinoCoreLibraryUninstallClient) Recv() (*LibraryUninstallResp, error
}
func (c *arduinoCoreClient) LibraryUpgradeAll(ctx context.Context, in *LibraryUpgradeAllReq, opts ...grpc.CallOption) (ArduinoCore_LibraryUpgradeAllClient, error) {
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[12], "/cc.arduino.core.rpc.ArduinoCore/LibraryUpgradeAll", opts...)
stream, err := c.cc.NewStream(ctx, &_ArduinoCore_serviceDesc.Streams[13], "/cc.arduino.core.rpc.ArduinoCore/LibraryUpgradeAll", opts...)
if err != nil {
return nil, err
}
......@@ -1062,7 +1101,7 @@ func (c *arduinoCoreClient) LibraryList(ctx context.Context, in *LibraryListReq,
// ArduinoCoreServer is the server API for ArduinoCore service.
type ArduinoCoreServer interface {
// Start a new instance of the Arduino Core Service
Init(context.Context, *InitReq) (*InitResp, error)
Init(*InitReq, ArduinoCore_InitServer) error
// Destroy an instance of the Arduino Core Service
Destroy(context.Context, *DestroyReq) (*DestroyResp, error)
// Rescan instance of the Arduino Core Service
......@@ -1095,22 +1134,25 @@ func RegisterArduinoCoreServer(s *grpc.Server, srv ArduinoCoreServer) {
s.RegisterService(&_ArduinoCore_serviceDesc, srv)
}
func _ArduinoCore_Init_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(InitReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ArduinoCoreServer).Init(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/cc.arduino.core.rpc.ArduinoCore/Init",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ArduinoCoreServer).Init(ctx, req.(*InitReq))
func _ArduinoCore_Init_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(InitReq)
if err := stream.RecvMsg(m); err != nil {
return err
}
return interceptor(ctx, in, info, handler)
return srv.(ArduinoCoreServer).Init(m, &arduinoCoreInitServer{stream})
}
type ArduinoCore_InitServer interface {
Send(*InitResp) error
grpc.ServerStream
}
type arduinoCoreInitServer struct {
grpc.ServerStream
}
func (x *arduinoCoreInitServer) Send(m *InitResp) error {
return x.ServerStream.SendMsg(m)
}
func _ArduinoCore_Destroy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
......@@ -1534,10 +1576,6 @@ var _ArduinoCore_serviceDesc = grpc.ServiceDesc{
ServiceName: "cc.arduino.core.rpc.ArduinoCore",
HandlerType: (*ArduinoCoreServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Init",
Handler: _ArduinoCore_Init_Handler,
},
{
MethodName: "Destroy",
Handler: _ArduinoCore_Destroy_Handler,
......@@ -1572,6 +1610,11 @@ var _ArduinoCore_serviceDesc = grpc.ServiceDesc{
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "Init",
Handler: _ArduinoCore_Init_Handler,
ServerStreams: true,
},
{
StreamName: "UpdateIndex",
Handler: _ArduinoCore_UpdateIndex_Handler,
......@@ -1641,65 +1684,67 @@ var _ArduinoCore_serviceDesc = grpc.ServiceDesc{
Metadata: "commands.proto",
}
func init() { proto.RegisterFile("commands.proto", fileDescriptor_commands_43421ae8c8c5f1d9) }
func init() { proto.RegisterFile("commands.proto", fileDescriptor_commands_a00a100136eab5d5) }
var fileDescriptor_commands_43421ae8c8c5f1d9 = []byte{
// 905 bytes of a gzipped FileDescriptorProto
var fileDescriptor_commands_a00a100136eab5d5 = []byte{
// 939 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xb4, 0x97, 0xdd, 0x72, 0xdb, 0x44,
0x14, 0xc7, 0x71, 0xdb, 0x69, 0xe2, 0xe3, 0x8f, 0xa6, 0xdb, 0x00, 0x1e, 0x0d, 0xa5, 0x41, 0xb5,
0x93, 0x96, 0xa1, 0x6e, 0x27, 0x70, 0xc3, 0x0d, 0x33, 0x6e, 0x5c, 0x20, 0xd3, 0x02, 0x1d, 0x81,
0x67, 0x98, 0xc2, 0xe0, 0x59, 0x4b, 0x1b, 0x67, 0xa7, 0xb2, 0x56, 0xec, 0xca, 0x14, 0x3f, 0x00,
0xcf, 0xc3, 0x05, 0x97, 0xbc, 0x1c, 0xbb, 0xab, 0x5d, 0xc5, 0x72, 0x24, 0x59, 0x34, 0xd3, 0x2b,
0x5b, 0xfb, 0xff, 0x9d, 0x8f, 0x3d, 0xf9, 0x1f, 0x25, 0x81, 0xae, 0xcf, 0x16, 0x0b, 0x1c, 0x05,
0x62, 0x18, 0x73, 0x96, 0x30, 0x74, 0xc7, 0xf7, 0x87, 0x98, 0x07, 0x4b, 0x1a, 0xb1, 0xa1, 0xcf,
0x38, 0x19, 0xf2, 0xd8, 0x77, 0xda, 0x0a, 0x62, 0x51, 0x8a, 0x38, 0xad, 0x19, 0x93, 0x84, 0x79,
0xe8, 0x48, 0x29, 0xa6, 0x21, 0x31, 0x8f, 0xa0, 0x63, 0xd2, 0xef, 0xed, 0x65, 0x1c, 0x32, 0x6c,
0xc1, 0x66, 0x48, 0x67, 0xe9, 0x57, 0xf7, 0x9f, 0x06, 0x74, 0x4e, 0x58, 0x74, 0x46, 0xe7, 0x4b,
0x8e, 0x13, 0xca, 0x22, 0xd4, 0x83, 0x9d, 0x00, 0x27, 0x78, 0x4c, 0x79, 0xaf, 0x71, 0xd0, 0x78,
0xd0, 0xf4, 0xec, 0x23, 0xea, 0x43, 0x47, 0xbc, 0x26, 0x89, 0x7f, 0x3e, 0x63, 0xec, 0xb5, 0xd2,
0xaf, 0x69, 0x3d, 0x7f, 0x88, 0x5c, 0x68, 0x07, 0xec, 0x4d, 0xa4, 0xca, 0x09, 0x05, 0x5d, 0xd7,
0x50, 0xee, 0x0c, 0x7d, 0x05, 0x8e, 0x6e, 0xfc, 0x3b, 0x1c, 0xe1, 0x39, 0xe1, 0xa3, 0x20, 0xa0,
0xaa, 0x36, 0x0e, 0x27, 0x3c, 0x14, 0xbd, 0x1b, 0x07, 0xd7, 0x65, 0x44, 0x05, 0xe1, 0xfe, 0xd5,
0x80, 0x9d, 0xd3, 0x88, 0x26, 0x1e, 0xf9, 0x1d, 0x7d, 0x0b, 0xf2, 0xde, 0x6b, 0x17, 0xd0, 0x5d,
0xb7, 0x8e, 0xdd, 0x61, 0xc1, 0xf4, 0x86, 0xb9, 0xab, 0x7a, 0xf9, 0x40, 0xf4, 0x04, 0xf6, 0xe5,
0x60, 0x38, 0xe6, 0xab, 0xe9, 0x22, 0x2d, 0x3b, 0x65, 0x51, 0xb8, 0xd2, 0xd7, 0xdc, 0xf5, 0x90,
0xd1, 0x4c, 0x47, 0x3f, 0x48, 0xc5, 0xfd, 0xbb, 0x01, 0xbb, 0x69, 0x1f, 0x22, 0x46, 0x5f, 0xc2,
0x2e, 0x8d, 0x44, 0x82, 0x23, 0x9f, 0x98, 0x1e, 0xee, 0x16, 0xf6, 0x70, 0x6a, 0x20, 0x2f, 0xc3,
0xd1, 0x17, 0xf0, 0x41, 0x1c, 0xe2, 0xe4, 0x8c, 0xf1, 0x85, 0x98, 0xd2, 0x28, 0x20, 0x7f, 0x4e,
0x09, 0xe7, 0x8c, 0x0b, 0x59, 0x5b, 0xcd, 0x62, 0x3f, 0x53, 0x4f, 0x95, 0xf8, 0x4c, 0x6b, 0xe8,
0x18, 0xde, 0x4f, 0x7b, 0xa2, 0x24, 0x17, 0x65, 0x46, 0x7e, 0x27, 0x13, 0x2f, 0x82, 0xdc, 0x6f,
0x00, 0xc6, 0x44, 0x24, 0x9c, 0xad, 0xd4, 0xec, 0xde, 0xbe, 0x65, 0xb7, 0x03, 0xad, 0x2c, 0x91,
0x88, 0xdd, 0xaf, 0xa1, 0x29, 0x3f, 0x7d, 0x1c, 0x5d, 0x31, 0xed, 0x1f, 0x00, 0x36, 0x8f, 0x1c,
0x69, 0xf9, 0x5c, 0x1a, 0x6f, 0x33, 0x97, 0x6b, 0xe5, 0x73, 0x79, 0x0e, 0xdd, 0x49, 0x2c, 0x8d,
0x4e, 0xf4, 0xd9, 0x15, 0x2f, 0x41, 0xe0, 0x56, 0x2e, 0x99, 0xbc, 0x89, 0x07, 0xb7, 0xed, 0x06,
0x4c, 0xe5, 0xe6, 0xcd, 0x39, 0x11, 0xc2, 0xa4, 0x1d, 0x14, 0xa6, 0x1d, 0x1b, 0xfa, 0xa5, 0x81,
0xbd, 0xbd, 0x60, 0xe3, 0xc4, 0xfd, 0x09, 0x3e, 0x4c, 0xcb, 0xbc, 0xc8, 0x5d, 0xe8, 0x8a, 0xcd,
0x47, 0xd0, 0x2b, 0xce, 0xfa, 0x6e, 0x6e, 0x71, 0xfc, 0xef, 0x1e, 0xb4, 0x46, 0x69, 0xdc, 0x89,
0x0c, 0x43, 0xcf, 0xe0, 0x86, 0x5a, 0x29, 0xf4, 0x51, 0x49, 0xc3, 0x7a, 0xeb, 0x9d, 0xbb, 0x15,
0xaa, 0xb4, 0xe3, 0x7b, 0xe8, 0x7b, 0xd8, 0x31, 0xfe, 0x44, 0xf7, 0x8a, 0x5b, 0xcb, 0xd6, 0xc0,
0x39, 0xa8, 0x06, 0x74, 0xbe, 0xe7, 0x70, 0x33, 0x35, 0x26, 0xfa, 0xb8, 0x90, 0xce, 0xdc, 0xef,
0xdc, 0xab, 0xd4, 0x75, 0xb2, 0x5f, 0xa1, 0xb5, 0x66, 0x10, 0x74, 0xbf, 0x30, 0x22, 0xef, 0x47,
0xa7, 0xbf, 0x1d, 0x52, 0xb9, 0x9f, 0x34, 0xd0, 0x1b, 0xd8, 0x2f, 0xfa, 0x09, 0xa2, 0xcf, 0x2a,
0x32, 0x5c, 0xb2, 0x90, 0xf3, 0xe8, 0x7f, 0xd0, 0xa6, 0xf0, 0x2f, 0xd0, 0x7e, 0xaa, 0x5e, 0xda,
0x63, 0x92, 0x60, 0x1a, 0x0a, 0x54, 0xdc, 0xf2, 0x3a, 0xa2, 0x0a, 0x0d, 0x6a, 0x50, 0xd2, 0x7b,
0xaf, 0xa0, 0xa5, 0xcf, 0x46, 0x49, 0x82, 0xfd, 0xf3, 0x92, 0x99, 0xad, 0x11, 0xe5, 0x33, 0xcb,
0x41, 0x22, 0x96, 0x8d, 0x7b, 0xd0, 0xd4, 0x87, 0x2f, 0xa8, 0x48, 0xd0, 0x27, 0xe5, 0x41, 0x4a,
0x57, 0x79, 0xdd, 0x6d, 0x88, 0xec, 0x57, 0x1a, 0xf0, 0x24, 0xfd, 0x7d, 0x5c, 0x62, 0x40, 0xa3,
0x96, 0x1b, 0x30, 0x03, 0x74, 0x8f, 0x67, 0x70, 0xeb, 0xa5, 0x79, 0xdb, 0xe9, 0xad, 0x0d, 0x43,
0x74, 0x54, 0x18, 0xb6, 0x41, 0xa9, 0xfc, 0x0f, 0xea, 0x81, 0xba, 0x0e, 0x85, 0x3d, 0x2b, 0xd8,
0xed, 0x45, 0xd5, 0xf1, 0x16, 0x53, 0x95, 0x1e, 0xd6, 0x24, 0x75, 0xa9, 0x10, 0x6e, 0x5b, 0x65,
0x12, 0x51, 0x73, 0xa9, 0xea, 0x0c, 0x19, 0xa7, 0x8a, 0x7d, 0x5a, 0x17, 0xdd, 0x1c, 0xe0, 0x24,
0x9e, 0x73, 0x1c, 0x90, 0x2d, 0x03, 0x34, 0xd4, 0xf6, 0x01, 0x66, 0xa0, 0xae, 0x23, 0xdf, 0x14,
0x13, 0xfd, 0xd7, 0x56, 0xc9, 0x9b, 0x22, 0x15, 0xcb, 0xdf, 0x14, 0x56, 0xd7, 0xc9, 0x30, 0x74,
0x6d, 0x95, 0x1f, 0x09, 0xe6, 0xd2, 0xf8, 0x87, 0x95, 0xad, 0xa4, 0x90, 0x4a, 0x7e, 0x54, 0x8b,
0x93, 0x46, 0x95, 0x5b, 0x6b, 0x4f, 0xb5, 0xff, 0xfb, 0x95, 0x81, 0x76, 0x05, 0x06, 0x35, 0x28,
0x99, 0x5c, 0x0e, 0x3d, 0x7d, 0x59, 0xac, 0x32, 0x33, 0x15, 0x37, 0xb6, 0x41, 0x95, 0x0f, 0xfd,
0x12, 0xa8, 0xe7, 0xe4, 0x43, 0xd7, 0x08, 0x76, 0x39, 0x0e, 0xab, 0xa2, 0xd7, 0x76, 0xe3, 0xa8,
0x16, 0x67, 0x57, 0xc3, 0x9c, 0x5f, 0xd8, 0xb5, 0xb2, 0xc9, 0x9c, 0x5b, 0x1f, 0xd6, 0x24, 0xed,
0x6a, 0x58, 0x25, 0x35, 0xd7, 0xa8, 0x74, 0x35, 0x2e, 0x71, 0xe5, 0xab, 0x51, 0x80, 0xea, 0x6a,
0xbf, 0x41, 0xc7, 0x48, 0xc6, 0x64, 0x83, 0xaa, 0xf0, 0x0b, 0x8f, 0x1d, 0xd6, 0xc1, 0xa4, 0x0b,
0x7e, 0x86, 0x96, 0x39, 0xd4, 0x0e, 0xbb, 0x5f, 0x15, 0x66, 0x0d, 0xd6, 0xdf, 0x0e, 0x89, 0xf8,
0x69, 0xff, 0x95, 0x3b, 0xa7, 0xc9, 0xf9, 0x72, 0x26, 0x91, 0xc5, 0x63, 0x83, 0xdb, 0xcf, 0x47,
0x7e, 0x48, 0x1f, 0xcb, 0xa8, 0xd9, 0x4d, 0xfd, 0xcf, 0xce, 0xe7, 0xff, 0x05, 0x00, 0x00, 0xff,
0xff, 0xc6, 0x2b, 0x48, 0xcf, 0x62, 0x0d, 0x00, 0x00,
0x14, 0xc7, 0x71, 0x5a, 0x9a, 0xe4, 0xd8, 0x4e, 0xd3, 0x6d, 0x80, 0x8c, 0x86, 0xd2, 0x54, 0x75,
0x92, 0x96, 0xa1, 0x6e, 0x27, 0x70, 0xc3, 0x0d, 0x33, 0x6e, 0x4c, 0x4b, 0xa6, 0x05, 0x3a, 0xa2,
0x9e, 0x61, 0x0a, 0x83, 0x67, 0x2d, 0x6d, 0x9c, 0x9d, 0xc8, 0x5a, 0xb1, 0x2b, 0x53, 0xfc, 0x00,
0x3c, 0x11, 0xd7, 0x3c, 0x01, 0x2f, 0xc5, 0xee, 0x6a, 0x57, 0xb6, 0x1c, 0x49, 0x16, 0xf5, 0xf4,
0xca, 0xd6, 0x9e, 0xdf, 0xf9, 0xdc, 0xff, 0x51, 0x1c, 0xd8, 0xf1, 0xd9, 0x64, 0x82, 0xa3, 0x40,
0x74, 0x63, 0xce, 0x12, 0x86, 0x6e, 0xfb, 0x7e, 0x17, 0xf3, 0x60, 0x4a, 0x23, 0xd6, 0xf5, 0x19,
0x27, 0x5d, 0x1e, 0xfb, 0x4e, 0x4b, 0x41, 0x2c, 0x4a, 0x11, 0xa7, 0x39, 0x62, 0x92, 0x30, 0x0f,
0x6d, 0x69, 0x8a, 0x69, 0x48, 0xcc, 0x23, 0x68, 0x9f, 0xf4, 0x7b, 0x6b, 0x1a, 0x87, 0x0c, 0x5b,
0x70, 0x3b, 0xa4, 0xa3, 0xf4, 0xab, 0xfb, 0x77, 0x03, 0xda, 0xa7, 0x2c, 0x3a, 0xa7, 0xe3, 0x29,
0xc7, 0x09, 0x65, 0x11, 0xda, 0x87, 0xcd, 0x00, 0x27, 0xb8, 0x4f, 0xf9, 0x7e, 0xe3, 0xa0, 0xf1,
0x60, 0xdb, 0xb3, 0x8f, 0xa8, 0x03, 0x6d, 0x71, 0x49, 0x12, 0xff, 0x62, 0xc4, 0xd8, 0xa5, 0xb2,
0x6f, 0x68, 0x7b, 0xfe, 0x10, 0xb9, 0xd0, 0x0a, 0xd8, 0xdb, 0x48, 0xa5, 0x13, 0x0a, 0xba, 0xa6,
0xa1, 0xdc, 0x19, 0xfa, 0x06, 0x1c, 0x5d, 0xf8, 0xf7, 0x38, 0xc2, 0x63, 0xc2, 0x7b, 0x41, 0x40,
0x55, 0x6e, 0x1c, 0x0e, 0x78, 0x28, 0xf6, 0xaf, 0x1f, 0x5c, 0x93, 0x1e, 0x15, 0x84, 0xfb, 0x57,
0x03, 0x36, 0xcf, 0x22, 0x9a, 0x78, 0xe4, 0x77, 0xf4, 0x1d, 0xc8, 0xbe, 0x17, 0x1a, 0xd0, 0x55,
0x37, 0x4f, 0xdc, 0x6e, 0xc1, 0xf4, 0xba, 0xb9, 0x56, 0xbd, 0xbc, 0x23, 0x7a, 0x02, 0x7b, 0x72,
0x30, 0x1c, 0xf3, 0xd9, 0x70, 0x92, 0xa6, 0x1d, 0xb2, 0x28, 0x9c, 0xe9, 0x36, 0xb7, 0x3c, 0x64,
0x6c, 0xa6, 0xa2, 0x1f, 0xa5, 0xc5, 0xfd, 0x77, 0x03, 0xb6, 0xd2, 0x3a, 0x44, 0x8c, 0xbe, 0x86,
0x2d, 0x1a, 0x89, 0x04, 0x47, 0x3e, 0x31, 0x35, 0xdc, 0x29, 0xac, 0xe1, 0xcc, 0x40, 0x5e, 0x86,
0xa3, 0xaf, 0xe0, 0xe3, 0x38, 0xc4, 0xc9, 0x39, 0xe3, 0x13, 0x31, 0xa4, 0x51, 0x40, 0xfe, 0x1c,
0x12, 0xce, 0x19, 0x17, 0x32, 0xb7, 0x9a, 0xc5, 0x5e, 0x66, 0x3d, 0x53, 0xc6, 0x6f, 0xb5, 0x0d,
0x9d, 0xc0, 0x47, 0x69, 0x4d, 0x94, 0xe4, 0xbc, 0xcc, 0xc8, 0x6f, 0x67, 0xc6, 0xb9, 0x13, 0xf2,
0xe0, 0x96, 0xbd, 0x89, 0xa1, 0x54, 0xc0, 0x98, 0x13, 0xa1, 0x06, 0xae, 0xaa, 0x3d, 0x2c, 0xac,
0xb6, 0x6f, 0xe8, 0x57, 0x06, 0xf6, 0x76, 0x83, 0xa5, 0x13, 0xf4, 0x0c, 0xda, 0x09, 0x16, 0x97,
0xf3, 0x78, 0x1f, 0xea, 0x78, 0xf7, 0x0a, 0xe3, 0xbd, 0x96, 0x64, 0x16, 0xab, 0x95, 0x2c, 0x3c,
0xb9, 0xcf, 0x01, 0xfa, 0x44, 0x24, 0x9c, 0xcd, 0xd4, 0xbd, 0xbe, 0xfb, 0x38, 0xdd, 0x36, 0x34,
0xb3, 0x40, 0x22, 0x76, 0x9f, 0xc1, 0xb6, 0xfc, 0xf4, 0x71, 0xb4, 0x66, 0xd8, 0x3f, 0x00, 0x6c,
0x1c, 0x79, 0xdd, 0xe5, 0x77, 0xd6, 0x78, 0x97, 0x3b, 0xdb, 0x28, 0xbd, 0x33, 0xf7, 0x05, 0xec,
0x0c, 0x62, 0xb9, 0x84, 0x44, 0x9f, 0xad, 0xd9, 0x04, 0x81, 0x9b, 0xb9, 0x60, 0xb2, 0x93, 0x42,
0x4d, 0x34, 0xd6, 0xd2, 0x84, 0xfb, 0x1a, 0x3e, 0x49, 0xd3, 0xbc, 0xcc, 0x35, 0xb4, 0x66, 0xf1,
0x11, 0xec, 0x17, 0x47, 0x7d, 0x3f, 0x5d, 0x9c, 0xfc, 0xb3, 0x0b, 0xcd, 0x5e, 0xea, 0x77, 0x2a,
0xdd, 0xd0, 0x73, 0xb8, 0xae, 0xd6, 0x1d, 0x7d, 0x5a, 0x52, 0xb0, 0x7e, 0x23, 0x39, 0x77, 0x2a,
0xac, 0x52, 0x8e, 0x1f, 0x3c, 0x69, 0xa0, 0x1f, 0x60, 0xd3, 0x28, 0x14, 0xdd, 0x2d, 0x2e, 0x2e,
0x5b, 0x04, 0xe7, 0xa0, 0x1a, 0x50, 0x11, 0xd1, 0x0b, 0xb8, 0x91, 0x4a, 0x13, 0x7d, 0x56, 0x48,
0x67, 0xfa, 0x77, 0xee, 0x56, 0xda, 0x75, 0xb0, 0x5f, 0xa1, 0xb9, 0x20, 0x11, 0x74, 0xbf, 0xd0,
0x23, 0xaf, 0x48, 0xa7, 0xb3, 0x1a, 0x32, 0xad, 0xbf, 0x85, 0xbd, 0xa2, 0x3b, 0x44, 0x5f, 0x54,
0x44, 0xb8, 0x22, 0x22, 0xe7, 0xd1, 0xff, 0xa0, 0x4d, 0xe2, 0x5f, 0xa0, 0xf5, 0x54, 0xfd, 0x49,
0xe9, 0x93, 0x04, 0xd3, 0x50, 0xa0, 0xe2, 0x92, 0x17, 0x11, 0x95, 0xe8, 0xb0, 0x06, 0x25, 0xd5,
0xf7, 0x06, 0x9a, 0xfa, 0xac, 0x97, 0x24, 0xd8, 0xbf, 0x28, 0x99, 0xd9, 0x02, 0x51, 0x3e, 0xb3,
0x1c, 0x24, 0x62, 0x59, 0xb8, 0x07, 0xdb, 0xfa, 0xf0, 0x25, 0x15, 0x09, 0xba, 0x57, 0xee, 0xa4,
0xec, 0x2a, 0xae, 0xbb, 0x0a, 0x91, 0xf5, 0x4a, 0x01, 0x9e, 0xa6, 0xbf, 0x16, 0x4a, 0x04, 0x68,
0xac, 0xe5, 0x02, 0xcc, 0x00, 0x5d, 0xe3, 0x39, 0xdc, 0x7c, 0x65, 0xde, 0x77, 0x7a, 0x6f, 0xc3,
0x10, 0x1d, 0x17, 0xba, 0x2d, 0x51, 0x2a, 0xfe, 0x83, 0x7a, 0xa0, 0xce, 0x43, 0x61, 0xd7, 0x1a,
0xec, 0xfe, 0xa2, 0x6a, 0x7f, 0x8b, 0xa9, 0x4c, 0x0f, 0x6b, 0x92, 0x3a, 0x55, 0x08, 0xb7, 0xac,
0x65, 0x10, 0x51, 0xd3, 0x54, 0x75, 0x84, 0x8c, 0x53, 0xc9, 0x3e, 0xaf, 0x8b, 0x2e, 0x0f, 0x70,
0x10, 0x8f, 0x39, 0x0e, 0xc8, 0x8a, 0x01, 0x1a, 0x6a, 0xf5, 0x00, 0x33, 0x50, 0xe7, 0x91, 0x6f,
0x8a, 0x81, 0xfe, 0x2d, 0x58, 0xf2, 0xa6, 0x48, 0x8d, 0xe5, 0x6f, 0x0a, 0x6b, 0xd7, 0xc1, 0x30,
0xec, 0xd8, 0x2c, 0x3f, 0x11, 0xcc, 0xa5, 0xf0, 0x8f, 0x2a, 0x4b, 0x49, 0x21, 0x15, 0xfc, 0xb8,
0x16, 0x27, 0x85, 0x2a, 0xb7, 0xd6, 0x9e, 0x6a, 0xfd, 0x77, 0x2a, 0x1d, 0xed, 0x0a, 0x1c, 0xd6,
0xa0, 0x64, 0x70, 0x39, 0xf4, 0xf4, 0x65, 0x31, 0xcb, 0xc4, 0x54, 0x5c, 0xd8, 0x12, 0x55, 0x3e,
0xf4, 0x2b, 0xa0, 0x9e, 0x93, 0x0f, 0x3b, 0xc6, 0x60, 0x97, 0xe3, 0xa8, 0xca, 0x7b, 0x61, 0x37,
0x8e, 0x6b, 0x71, 0x76, 0x35, 0xcc, 0xf9, 0x5c, 0xae, 0x95, 0x45, 0xe6, 0xd4, 0xfa, 0xb0, 0x26,
0x69, 0x57, 0xc3, 0x5a, 0x52, 0x71, 0xf5, 0x4a, 0x57, 0xe3, 0x0a, 0x57, 0xbe, 0x1a, 0x05, 0xa8,
0xce, 0xf6, 0x1b, 0xb4, 0x8d, 0xc9, 0x88, 0xec, 0xb0, 0xca, 0x7d, 0xae, 0xb1, 0xa3, 0x3a, 0x98,
0x54, 0xc1, 0xcf, 0xd0, 0x34, 0x87, 0x5a, 0x61, 0xf7, 0xab, 0xdc, 0xac, 0xc0, 0x3a, 0xab, 0x21,
0x11, 0x3f, 0xed, 0xbc, 0x71, 0xc7, 0x34, 0xb9, 0x98, 0x8e, 0x24, 0x32, 0x79, 0x6c, 0x70, 0xfb,
0xf9, 0xc8, 0x0f, 0xe9, 0x63, 0xe9, 0x35, 0xba, 0xa1, 0xff, 0x15, 0xfb, 0xf2, 0xbf, 0x00, 0x00,
0x00, 0xff, 0xff, 0x45, 0xa1, 0x67, 0x52, 0x00, 0x0e, 0x00, 0x00,
}
rpc/commands.proto
View file @ 2c1b10d8
......@@ -34,7 +34,7 @@ service ArduinoCore {
//-------------------
// Start a new instance of the Arduino Core Service
rpc Init(InitReq) returns (InitResp) {}
rpc Init(InitReq) returns (stream InitResp) {}
// Destroy an instance of the Arduino Core Service
rpc Destroy(DestroyReq) returns (DestroyResp) {}
......@@ -115,6 +115,8 @@ message InitResp {
Instance instance = 1;
repeated string platforms_index_errors = 2;
string libraries_index_error = 3;
DownloadProgress download_progress = 4;
TaskProgress task_progress = 5;
}
message DestroyReq { Instance instance = 1; }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment