Skip to content

Commit 27dc6f9

Browse files
author
Akos Kitta
committed
Updated the TS/JS API with the monitoring.
Signed-off-by: Akos Kitta <kittaakos@typefox.io>
1 parent db78c8a commit 27dc6f9

File tree

4 files changed

+870
-0
lines changed

4 files changed

+870
-0
lines changed

‎arduino-ide-extension/src/node/cli-protocol/monitor/monitor_grpc_pb.d.ts

+40
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
// package: cc.arduino.cli.monitor
2+
// file: monitor/monitor.proto
3+
4+
/* tslint:disable */
5+
6+
import * as grpc from "@grpc/grpc-js";
7+
import * as monitor_monitor_pb from "../monitor/monitor_pb";
8+
import * as google_protobuf_struct_pb from "google-protobuf/google/protobuf/struct_pb";
9+
10+
interface IMonitorService extends grpc.ServiceDefinition<grpc.UntypedServiceImplementation> {
11+
streamingOpen: IMonitorService_IStreamingOpen;
12+
}
13+
14+
interface IMonitorService_IStreamingOpen extends grpc.MethodDefinition<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp> {
15+
path: string; // "/cc.arduino.cli.monitor.Monitor/StreamingOpen"
16+
requestStream: boolean; // true
17+
responseStream: boolean; // true
18+
requestSerialize: grpc.serialize<monitor_monitor_pb.StreamingOpenReq>;
19+
requestDeserialize: grpc.deserialize<monitor_monitor_pb.StreamingOpenReq>;
20+
responseSerialize: grpc.serialize<monitor_monitor_pb.StreamingOpenResp>;
21+
responseDeserialize: grpc.deserialize<monitor_monitor_pb.StreamingOpenResp>;
22+
}
23+
24+
export const MonitorService: IMonitorService;
25+
26+
export interface IMonitorServer {
27+
streamingOpen: grpc.handleBidiStreamingCall<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
28+
}
29+
30+
export interface IMonitorClient {
31+
streamingOpen(): grpc.ClientDuplexStream<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
32+
streamingOpen(options: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
33+
streamingOpen(metadata: grpc.Metadata, options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
34+
}
35+
36+
export class MonitorClient extends grpc.Client implements IMonitorClient {
37+
constructor(address: string, credentials: grpc.ChannelCredentials, options?: object);
38+
public streamingOpen(options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
39+
public streamingOpen(metadata?: grpc.Metadata, options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<monitor_monitor_pb.StreamingOpenReq, monitor_monitor_pb.StreamingOpenResp>;
40+
}

‎arduino-ide-extension/src/node/cli-protocol/monitor/monitor_grpc_pb.js

+62
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
// GENERATED CODE -- DO NOT EDIT!
2+
3+
// Original file comments:
4+
// This file is part of arduino-cli.
5+
//
6+
// Copyright 2019 ARDUINO SA (http://www.arduino.cc/)
7+
//
8+
// This software is released under the GNU General Public License version 3,
9+
// which covers the main part of arduino-cli.
10+
// The terms of this license can be found at:
11+
// https://www.gnu.org/licenses/gpl-3.0.en.html
12+
//
13+
// You can be released from the requirements of the above licenses by purchasing
14+
// a commercial license. Buying such a license is mandatory if you want to
15+
// modify or otherwise use the software for commercial activities involving the
16+
// Arduino software without disclosing the source code of your own applications.
17+
// To purchase a commercial license, send an email to license@arduino.cc.
18+
//
19+
'use strict';
20+
var grpc = require('@grpc/grpc-js');
21+
var monitor_monitor_pb = require('../monitor/monitor_pb.js');
22+
var google_protobuf_struct_pb = require('google-protobuf/google/protobuf/struct_pb.js');
23+
24+
function serialize_cc_arduino_cli_monitor_StreamingOpenReq(arg) {
25+
if (!(arg instanceof monitor_monitor_pb.StreamingOpenReq)) {
26+
throw new Error('Expected argument of type cc.arduino.cli.monitor.StreamingOpenReq');
27+
}
28+
return Buffer.from(arg.serializeBinary());
29+
}
30+
31+
function deserialize_cc_arduino_cli_monitor_StreamingOpenReq(buffer_arg) {
32+
return monitor_monitor_pb.StreamingOpenReq.deserializeBinary(new Uint8Array(buffer_arg));
33+
}
34+
35+
function serialize_cc_arduino_cli_monitor_StreamingOpenResp(arg) {
36+
if (!(arg instanceof monitor_monitor_pb.StreamingOpenResp)) {
37+
throw new Error('Expected argument of type cc.arduino.cli.monitor.StreamingOpenResp');
38+
}
39+
return Buffer.from(arg.serializeBinary());
40+
}
41+
42+
function deserialize_cc_arduino_cli_monitor_StreamingOpenResp(buffer_arg) {
43+
return monitor_monitor_pb.StreamingOpenResp.deserializeBinary(new Uint8Array(buffer_arg));
44+
}
45+
46+
47+
// Service that abstract a Monitor usage
48+
var MonitorService = exports.MonitorService = {
49+
streamingOpen: {
50+
path: '/cc.arduino.cli.monitor.Monitor/StreamingOpen',
51+
requestStream: true,
52+
responseStream: true,
53+
requestType: monitor_monitor_pb.StreamingOpenReq,
54+
responseType: monitor_monitor_pb.StreamingOpenResp,
55+
requestSerialize: serialize_cc_arduino_cli_monitor_StreamingOpenReq,
56+
requestDeserialize: deserialize_cc_arduino_cli_monitor_StreamingOpenReq,
57+
responseSerialize: serialize_cc_arduino_cli_monitor_StreamingOpenResp,
58+
responseDeserialize: deserialize_cc_arduino_cli_monitor_StreamingOpenResp,
59+
},
60+
};
61+
62+
exports.MonitorClient = grpc.makeGenericClientConstructor(MonitorService);

‎arduino-ide-extension/src/node/cli-protocol/monitor/monitor_pb.d.ts

+112
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,112 @@
1+
// package: cc.arduino.cli.monitor
2+
// file: monitor/monitor.proto
3+
4+
/* tslint:disable */
5+
6+
import * as jspb from "google-protobuf";
7+
import * as google_protobuf_struct_pb from "google-protobuf/google/protobuf/struct_pb";
8+
9+
export class StreamingOpenReq extends jspb.Message {
10+
11+
hasMonitorconfig(): boolean;
12+
clearMonitorconfig(): void;
13+
getMonitorconfig(): MonitorConfig | undefined;
14+
setMonitorconfig(value?: MonitorConfig): void;
15+
16+
17+
hasData(): boolean;
18+
clearData(): void;
19+
getData(): Uint8Array | string;
20+
getData_asU8(): Uint8Array;
21+
getData_asB64(): string;
22+
setData(value: Uint8Array | string): void;
23+
24+
25+
getContentCase(): StreamingOpenReq.ContentCase;
26+
27+
serializeBinary(): Uint8Array;
28+
toObject(includeInstance?: boolean): StreamingOpenReq.AsObject;
29+
static toObject(includeInstance: boolean, msg: StreamingOpenReq): StreamingOpenReq.AsObject;
30+
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
31+
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
32+
static serializeBinaryToWriter(message: StreamingOpenReq, writer: jspb.BinaryWriter): void;
33+
static deserializeBinary(bytes: Uint8Array): StreamingOpenReq;
34+
static deserializeBinaryFromReader(message: StreamingOpenReq, reader: jspb.BinaryReader): StreamingOpenReq;
35+
}
36+
37+
export namespace StreamingOpenReq {
38+
export type AsObject = {
39+
monitorconfig?: MonitorConfig.AsObject,
40+
data: Uint8Array | string,
41+
}
42+
43+
export enum ContentCase {
44+
CONTENT_NOT_SET = 0,
45+
46+
MONITORCONFIG = 1,
47+
48+
DATA = 2,
49+
50+
}
51+
52+
}
53+
54+
export class MonitorConfig extends jspb.Message {
55+
getTarget(): string;
56+
setTarget(value: string): void;
57+
58+
getType(): MonitorConfig.TargetType;
59+
setType(value: MonitorConfig.TargetType): void;
60+
61+
62+
hasAdditionalconfig(): boolean;
63+
clearAdditionalconfig(): void;
64+
getAdditionalconfig(): google_protobuf_struct_pb.Struct | undefined;
65+
setAdditionalconfig(value?: google_protobuf_struct_pb.Struct): void;
66+
67+
68+
serializeBinary(): Uint8Array;
69+
toObject(includeInstance?: boolean): MonitorConfig.AsObject;
70+
static toObject(includeInstance: boolean, msg: MonitorConfig): MonitorConfig.AsObject;
71+
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
72+
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
73+
static serializeBinaryToWriter(message: MonitorConfig, writer: jspb.BinaryWriter): void;
74+
static deserializeBinary(bytes: Uint8Array): MonitorConfig;
75+
static deserializeBinaryFromReader(message: MonitorConfig, reader: jspb.BinaryReader): MonitorConfig;
76+
}
77+
78+
export namespace MonitorConfig {
79+
export type AsObject = {
80+
target: string,
81+
type: MonitorConfig.TargetType,
82+
additionalconfig?: google_protobuf_struct_pb.Struct.AsObject,
83+
}
84+
85+
export enum TargetType {
86+
SERIAL = 0,
87+
}
88+
89+
}
90+
91+
export class StreamingOpenResp extends jspb.Message {
92+
getData(): Uint8Array | string;
93+
getData_asU8(): Uint8Array;
94+
getData_asB64(): string;
95+
setData(value: Uint8Array | string): void;
96+
97+
98+
serializeBinary(): Uint8Array;
99+
toObject(includeInstance?: boolean): StreamingOpenResp.AsObject;
100+
static toObject(includeInstance: boolean, msg: StreamingOpenResp): StreamingOpenResp.AsObject;
101+
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
102+
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
103+
static serializeBinaryToWriter(message: StreamingOpenResp, writer: jspb.BinaryWriter): void;
104+
static deserializeBinary(bytes: Uint8Array): StreamingOpenResp;
105+
static deserializeBinaryFromReader(message: StreamingOpenResp, reader: jspb.BinaryReader): StreamingOpenResp;
106+
}
107+
108+
export namespace StreamingOpenResp {
109+
export type AsObject = {
110+
data: Uint8Array | string,
111+
}
112+
}

0 commit comments

Comments
 (0)