diff --git a/app/src/components/Sidebar/ValueRenderer/ValueRenderer.tsx b/app/src/components/Sidebar/ValueRenderer/ValueRenderer.tsx index 3a4f9ff..e65c317 100644 --- a/app/src/components/Sidebar/ValueRenderer/ValueRenderer.tsx +++ b/app/src/components/Sidebar/ValueRenderer/ValueRenderer.tsx @@ -1,12 +1,15 @@ +import * as log from 'electron-log' import * as q from '../../../../../backend/src/Model' import * as React from 'react' import CodeDiff from '../CodeDiff' import { AppState } from '../../../reducers' import { Base64Message } from '../../../../../backend/src/Model/Base64Message' +import { Payload } from '../../../../../backend/src/Model/sparkplug' import { connect } from 'react-redux' import { default as ReactResizeDetector } from 'react-resize-detector' import { ValueRendererDisplayMode } from '../../../reducers/Settings' import { Typography, Fade, Grow } from '@material-ui/core' +import { Buffer } from 'buffer'; interface Props { message: q.Message @@ -44,15 +47,37 @@ class ValueRenderer extends React.Component { } const str = Base64Message.toUnicodeString(msg) + try { JSON.parse(str) } catch (error) { - return [str, undefined] + try { + let payload = Payload.decode(this.base64MessageToUint8Array(msg)) + const json = Payload.toJSON(payload) + return [JSON.stringify(json, undefined, ' '), 'json'] + } catch (error) { + return [str, undefined] + } } return [this.messageToPrettyJson(str), 'json'] } + private base64MessageToUint8Array(msg: Base64Message): Uint8Array { + let dataUri = Base64Message.toDataUri(msg, "") + let parts = dataUri.split(',') + let b64 = parts[1] + + var binary_string = window.atob(b64); + var len = binary_string.length; + var bytes = new Uint8Array(len); + for (var i = 0; i < len; i++) { + bytes[i] = binary_string.charCodeAt(i); + } + + return bytes + } + private messageToPrettyJson(str: string): string | undefined { try { const json = JSON.parse(str) diff --git a/backend/package.json b/backend/package.json index 7a60fd2..40217ba 100644 --- a/backend/package.json +++ b/backend/package.json @@ -35,10 +35,14 @@ "sourceMap": true, "instrument": true }, + "dependencies": { + "protobufjs": "^6.11.2", + "long": "^4.0.0" + }, "peerDependencies": { "fs-extra": "^8.0.1", "js-base64": "^2.5.1", "lowdb": "^1.0.0", "mqtt": "^3.0.0" } -} +} \ No newline at end of file diff --git a/backend/src/Model/sparkplug.ts b/backend/src/Model/sparkplug.ts new file mode 100644 index 0000000..8351168 --- /dev/null +++ b/backend/src/Model/sparkplug.ts @@ -0,0 +1,2642 @@ +/* eslint-disable */ +import { util, configure, Writer, Reader } from "protobufjs/minimal"; +import * as Long from "long"; + +export const protobufPackage = "org.eclipse.tahu.protobuf"; + +/** Indexes of Data Types */ +export enum DataType { + /** Unknown - Unknown placeholder for future expansion. */ + Unknown = 0, + /** Int8 - Basic Types */ + Int8 = 1, + Int16 = 2, + Int32 = 3, + Int64 = 4, + UInt8 = 5, + UInt16 = 6, + UInt32 = 7, + UInt64 = 8, + Float = 9, + Double = 10, + Boolean = 11, + String = 12, + DateTime = 13, + Text = 14, + /** UUID - Additional Metric Types */ + UUID = 15, + DataSet = 16, + Bytes = 17, + File = 18, + Template = 19, + /** PropertySet - Additional PropertyValue Types */ + PropertySet = 20, + PropertySetList = 21, + /** Int8Array - Array Types */ + Int8Array = 22, + Int16Array = 23, + Int32Array = 24, + Int64Array = 25, + UInt8Array = 26, + UInt16Array = 27, + UInt32Array = 28, + UInt64Array = 29, + FloatArray = 30, + DoubleArray = 31, + BooleanArray = 32, + StringArray = 33, + DateTimeArray = 34, + UNRECOGNIZED = -1, +} + +export function dataTypeFromJSON(object: any): DataType { + switch (object) { + case 0: + case "Unknown": + return DataType.Unknown; + case 1: + case "Int8": + return DataType.Int8; + case 2: + case "Int16": + return DataType.Int16; + case 3: + case "Int32": + return DataType.Int32; + case 4: + case "Int64": + return DataType.Int64; + case 5: + case "UInt8": + return DataType.UInt8; + case 6: + case "UInt16": + return DataType.UInt16; + case 7: + case "UInt32": + return DataType.UInt32; + case 8: + case "UInt64": + return DataType.UInt64; + case 9: + case "Float": + return DataType.Float; + case 10: + case "Double": + return DataType.Double; + case 11: + case "Boolean": + return DataType.Boolean; + case 12: + case "String": + return DataType.String; + case 13: + case "DateTime": + return DataType.DateTime; + case 14: + case "Text": + return DataType.Text; + case 15: + case "UUID": + return DataType.UUID; + case 16: + case "DataSet": + return DataType.DataSet; + case 17: + case "Bytes": + return DataType.Bytes; + case 18: + case "File": + return DataType.File; + case 19: + case "Template": + return DataType.Template; + case 20: + case "PropertySet": + return DataType.PropertySet; + case 21: + case "PropertySetList": + return DataType.PropertySetList; + case 22: + case "Int8Array": + return DataType.Int8Array; + case 23: + case "Int16Array": + return DataType.Int16Array; + case 24: + case "Int32Array": + return DataType.Int32Array; + case 25: + case "Int64Array": + return DataType.Int64Array; + case 26: + case "UInt8Array": + return DataType.UInt8Array; + case 27: + case "UInt16Array": + return DataType.UInt16Array; + case 28: + case "UInt32Array": + return DataType.UInt32Array; + case 29: + case "UInt64Array": + return DataType.UInt64Array; + case 30: + case "FloatArray": + return DataType.FloatArray; + case 31: + case "DoubleArray": + return DataType.DoubleArray; + case 32: + case "BooleanArray": + return DataType.BooleanArray; + case 33: + case "StringArray": + return DataType.StringArray; + case 34: + case "DateTimeArray": + return DataType.DateTimeArray; + case -1: + case "UNRECOGNIZED": + default: + return DataType.UNRECOGNIZED; + } +} + +export function dataTypeToJSON(object: DataType): string { + switch (object) { + case DataType.Unknown: + return "Unknown"; + case DataType.Int8: + return "Int8"; + case DataType.Int16: + return "Int16"; + case DataType.Int32: + return "Int32"; + case DataType.Int64: + return "Int64"; + case DataType.UInt8: + return "UInt8"; + case DataType.UInt16: + return "UInt16"; + case DataType.UInt32: + return "UInt32"; + case DataType.UInt64: + return "UInt64"; + case DataType.Float: + return "Float"; + case DataType.Double: + return "Double"; + case DataType.Boolean: + return "Boolean"; + case DataType.String: + return "String"; + case DataType.DateTime: + return "DateTime"; + case DataType.Text: + return "Text"; + case DataType.UUID: + return "UUID"; + case DataType.DataSet: + return "DataSet"; + case DataType.Bytes: + return "Bytes"; + case DataType.File: + return "File"; + case DataType.Template: + return "Template"; + case DataType.PropertySet: + return "PropertySet"; + case DataType.PropertySetList: + return "PropertySetList"; + case DataType.Int8Array: + return "Int8Array"; + case DataType.Int16Array: + return "Int16Array"; + case DataType.Int32Array: + return "Int32Array"; + case DataType.Int64Array: + return "Int64Array"; + case DataType.UInt8Array: + return "UInt8Array"; + case DataType.UInt16Array: + return "UInt16Array"; + case DataType.UInt32Array: + return "UInt32Array"; + case DataType.UInt64Array: + return "UInt64Array"; + case DataType.FloatArray: + return "FloatArray"; + case DataType.DoubleArray: + return "DoubleArray"; + case DataType.BooleanArray: + return "BooleanArray"; + case DataType.StringArray: + return "StringArray"; + case DataType.DateTimeArray: + return "DateTimeArray"; + default: + return "UNKNOWN"; + } +} + +export interface Payload { + /** Timestamp at message sending time */ + timestamp: number; + /** Repeated forever - no limit in Google Protobufs */ + metrics: Payload_Metric[]; + /** Sequence number */ + seq: number; + /** UUID to track message type in terms of schema definitions */ + uuid: string; + /** To optionally bypass the whole definition above */ + body: Buffer; +} + +export interface Payload_Template { + /** The version of the Template to prevent mismatches */ + version: string; + /** Each metric includes a name, datatype, and optionally a value */ + metrics: Payload_Metric[]; + parameters: Payload_Template_Parameter[]; + /** Reference to a template if this is extending a Template or an instance - must exist if an instance */ + templateRef: string; + isDefinition: boolean; +} + +export interface Payload_Template_Parameter { + name: string; + type: number; + intValue: number | undefined; + longValue: number | undefined; + floatValue: number | undefined; + doubleValue: number | undefined; + booleanValue: boolean | undefined; + stringValue: string | undefined; + extensionValue: + | Payload_Template_Parameter_ParameterValueExtension + | undefined; +} + +export interface Payload_Template_Parameter_ParameterValueExtension {} + +export interface Payload_DataSet { + numOfColumns: number; + columns: string[]; + types: number[]; + rows: Payload_DataSet_Row[]; +} + +export interface Payload_DataSet_DataSetValue { + intValue: number | undefined; + longValue: number | undefined; + floatValue: number | undefined; + doubleValue: number | undefined; + booleanValue: boolean | undefined; + stringValue: string | undefined; + extensionValue: + | Payload_DataSet_DataSetValue_DataSetValueExtension + | undefined; +} + +export interface Payload_DataSet_DataSetValue_DataSetValueExtension {} + +export interface Payload_DataSet_Row { + elements: Payload_DataSet_DataSetValue[]; +} + +export interface Payload_PropertyValue { + type: number; + isNull: boolean; + intValue: number | undefined; + longValue: number | undefined; + floatValue: number | undefined; + doubleValue: number | undefined; + booleanValue: boolean | undefined; + stringValue: string | undefined; + propertysetValue: Payload_PropertySet | undefined; + /** List of Property Values */ + propertysetsValue: Payload_PropertySetList | undefined; + extensionValue: Payload_PropertyValue_PropertyValueExtension | undefined; +} + +export interface Payload_PropertyValue_PropertyValueExtension {} + +export interface Payload_PropertySet { + /** Names of the properties */ + keys: string[]; + values: Payload_PropertyValue[]; +} + +export interface Payload_PropertySetList { + propertyset: Payload_PropertySet[]; +} + +export interface Payload_MetaData { + /** Bytes specific metadata */ + isMultiPart: boolean; + /** General metadata */ + contentType: string; + /** File size, String size, Multi-part size, etc */ + size: number; + /** Sequence number for multi-part messages */ + seq: number; + /** File metadata */ + fileName: string; + /** File type (i.e. xml, json, txt, cpp, etc) */ + fileType: string; + /** md5 of data */ + md5: string; + /** Catchalls and future expansion */ + description: string; +} + +export interface Payload_Metric { + /** Metric name - should only be included on birth */ + name: string; + /** Metric alias - tied to name on birth and included in all later DATA messages */ + alias: number; + /** Timestamp associated with data acquisition time */ + timestamp: number; + /** DataType of the metric/tag value */ + datatype: number; + /** If this is historical data and should not update real time tag */ + isHistorical: boolean; + /** Tells consuming clients such as MQTT Engine to not store this as a tag */ + isTransient: boolean; + /** If this is null - explicitly say so rather than using -1, false, etc for some datatypes. */ + isNull: boolean; + /** Metadata for the payload */ + metadata: Payload_MetaData | undefined; + properties: Payload_PropertySet | undefined; + intValue: number | undefined; + longValue: number | undefined; + floatValue: number | undefined; + doubleValue: number | undefined; + booleanValue: boolean | undefined; + stringValue: string | undefined; + /** Bytes, File */ + bytesValue: Buffer | undefined; + datasetValue: Payload_DataSet | undefined; + templateValue: Payload_Template | undefined; + extensionValue: Payload_Metric_MetricValueExtension | undefined; +} + +export interface Payload_Metric_MetricValueExtension {} + +const basePayload: object = { timestamp: 0, seq: 0, uuid: "" }; + +export const Payload = { + encode(message: Payload, writer: Writer = Writer.create()): Writer { + if (message.timestamp !== 0) { + writer.uint32(8).uint64(message.timestamp); + } + for (const v of message.metrics) { + Payload_Metric.encode(v!, writer.uint32(18).fork()).ldelim(); + } + if (message.seq !== 0) { + writer.uint32(24).uint64(message.seq); + } + if (message.uuid !== "") { + writer.uint32(34).string(message.uuid); + } + if (message.body.length !== 0) { + writer.uint32(42).bytes(message.body); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload } as Payload; + message.metrics = []; + message.body = Buffer.alloc(0); + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.timestamp = longToNumber(reader.uint64() as Long); + break; + case 2: + message.metrics.push(Payload_Metric.decode(reader, reader.uint32())); + break; + case 3: + message.seq = longToNumber(reader.uint64() as Long); + break; + case 4: + message.uuid = reader.string(); + break; + case 5: + message.body = reader.bytes() as Buffer; + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload { + const message = { ...basePayload } as Payload; + message.metrics = []; + message.body = Buffer.alloc(0); + if (object.timestamp !== undefined && object.timestamp !== null) { + message.timestamp = Number(object.timestamp); + } else { + message.timestamp = 0; + } + if (object.metrics !== undefined && object.metrics !== null) { + for (const e of object.metrics) { + message.metrics.push(Payload_Metric.fromJSON(e)); + } + } + if (object.seq !== undefined && object.seq !== null) { + message.seq = Number(object.seq); + } else { + message.seq = 0; + } + if (object.uuid !== undefined && object.uuid !== null) { + message.uuid = String(object.uuid); + } else { + message.uuid = ""; + } + if (object.body !== undefined && object.body !== null) { + message.body = Buffer.from(bytesFromBase64(object.body)); + } + return message; + }, + + toJSON(message: Payload): unknown { + const obj: any = {}; + message.timestamp !== undefined && (obj.timestamp = message.timestamp); + if (message.metrics) { + obj.metrics = message.metrics.map((e) => + e ? Payload_Metric.toJSON(e) : undefined + ); + } else { + obj.metrics = []; + } + message.seq !== undefined && (obj.seq = message.seq); + message.uuid !== undefined && (obj.uuid = message.uuid); + message.body !== undefined && + (obj.body = base64FromBytes( + message.body !== undefined ? message.body : Buffer.alloc(0) + )); + return obj; + }, + + fromPartial(object: DeepPartial): Payload { + const message = { ...basePayload } as Payload; + message.metrics = []; + if (object.timestamp !== undefined && object.timestamp !== null) { + message.timestamp = object.timestamp; + } else { + message.timestamp = 0; + } + if (object.metrics !== undefined && object.metrics !== null) { + for (const e of object.metrics) { + message.metrics.push(Payload_Metric.fromPartial(e)); + } + } + if (object.seq !== undefined && object.seq !== null) { + message.seq = object.seq; + } else { + message.seq = 0; + } + if (object.uuid !== undefined && object.uuid !== null) { + message.uuid = object.uuid; + } else { + message.uuid = ""; + } + if (object.body !== undefined && object.body !== null) { + message.body = object.body; + } else { + message.body = Buffer.alloc(0); + } + return message; + }, +}; + +const basePayload_Template: object = { + version: "", + templateRef: "", + isDefinition: false, +}; + +export const Payload_Template = { + encode(message: Payload_Template, writer: Writer = Writer.create()): Writer { + if (message.version !== "") { + writer.uint32(10).string(message.version); + } + for (const v of message.metrics) { + Payload_Metric.encode(v!, writer.uint32(18).fork()).ldelim(); + } + for (const v of message.parameters) { + Payload_Template_Parameter.encode(v!, writer.uint32(26).fork()).ldelim(); + } + if (message.templateRef !== "") { + writer.uint32(34).string(message.templateRef); + } + if (message.isDefinition === true) { + writer.uint32(40).bool(message.isDefinition); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_Template { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_Template } as Payload_Template; + message.metrics = []; + message.parameters = []; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.version = reader.string(); + break; + case 2: + message.metrics.push(Payload_Metric.decode(reader, reader.uint32())); + break; + case 3: + message.parameters.push( + Payload_Template_Parameter.decode(reader, reader.uint32()) + ); + break; + case 4: + message.templateRef = reader.string(); + break; + case 5: + message.isDefinition = reader.bool(); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_Template { + const message = { ...basePayload_Template } as Payload_Template; + message.metrics = []; + message.parameters = []; + if (object.version !== undefined && object.version !== null) { + message.version = String(object.version); + } else { + message.version = ""; + } + if (object.metrics !== undefined && object.metrics !== null) { + for (const e of object.metrics) { + message.metrics.push(Payload_Metric.fromJSON(e)); + } + } + if (object.parameters !== undefined && object.parameters !== null) { + for (const e of object.parameters) { + message.parameters.push(Payload_Template_Parameter.fromJSON(e)); + } + } + if (object.templateRef !== undefined && object.templateRef !== null) { + message.templateRef = String(object.templateRef); + } else { + message.templateRef = ""; + } + if (object.isDefinition !== undefined && object.isDefinition !== null) { + message.isDefinition = Boolean(object.isDefinition); + } else { + message.isDefinition = false; + } + return message; + }, + + toJSON(message: Payload_Template): unknown { + const obj: any = {}; + message.version !== undefined && (obj.version = message.version); + if (message.metrics) { + obj.metrics = message.metrics.map((e) => + e ? Payload_Metric.toJSON(e) : undefined + ); + } else { + obj.metrics = []; + } + if (message.parameters) { + obj.parameters = message.parameters.map((e) => + e ? Payload_Template_Parameter.toJSON(e) : undefined + ); + } else { + obj.parameters = []; + } + message.templateRef !== undefined && + (obj.templateRef = message.templateRef); + message.isDefinition !== undefined && + (obj.isDefinition = message.isDefinition); + return obj; + }, + + fromPartial(object: DeepPartial): Payload_Template { + const message = { ...basePayload_Template } as Payload_Template; + message.metrics = []; + message.parameters = []; + if (object.version !== undefined && object.version !== null) { + message.version = object.version; + } else { + message.version = ""; + } + if (object.metrics !== undefined && object.metrics !== null) { + for (const e of object.metrics) { + message.metrics.push(Payload_Metric.fromPartial(e)); + } + } + if (object.parameters !== undefined && object.parameters !== null) { + for (const e of object.parameters) { + message.parameters.push(Payload_Template_Parameter.fromPartial(e)); + } + } + if (object.templateRef !== undefined && object.templateRef !== null) { + message.templateRef = object.templateRef; + } else { + message.templateRef = ""; + } + if (object.isDefinition !== undefined && object.isDefinition !== null) { + message.isDefinition = object.isDefinition; + } else { + message.isDefinition = false; + } + return message; + }, +}; + +const basePayload_Template_Parameter: object = { name: "", type: 0 }; + +export const Payload_Template_Parameter = { + encode( + message: Payload_Template_Parameter, + writer: Writer = Writer.create() + ): Writer { + if (message.name !== "") { + writer.uint32(10).string(message.name); + } + if (message.type !== 0) { + writer.uint32(16).uint32(message.type); + } + if (message.intValue !== undefined) { + writer.uint32(24).uint32(message.intValue); + } + if (message.longValue !== undefined) { + writer.uint32(32).uint64(message.longValue); + } + if (message.floatValue !== undefined) { + writer.uint32(45).float(message.floatValue); + } + if (message.doubleValue !== undefined) { + writer.uint32(49).double(message.doubleValue); + } + if (message.booleanValue !== undefined) { + writer.uint32(56).bool(message.booleanValue); + } + if (message.stringValue !== undefined) { + writer.uint32(66).string(message.stringValue); + } + if (message.extensionValue !== undefined) { + Payload_Template_Parameter_ParameterValueExtension.encode( + message.extensionValue, + writer.uint32(74).fork() + ).ldelim(); + } + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_Template_Parameter { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_Template_Parameter, + } as Payload_Template_Parameter; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.name = reader.string(); + break; + case 2: + message.type = reader.uint32(); + break; + case 3: + message.intValue = reader.uint32(); + break; + case 4: + message.longValue = longToNumber(reader.uint64() as Long); + break; + case 5: + message.floatValue = reader.float(); + break; + case 6: + message.doubleValue = reader.double(); + break; + case 7: + message.booleanValue = reader.bool(); + break; + case 8: + message.stringValue = reader.string(); + break; + case 9: + message.extensionValue = + Payload_Template_Parameter_ParameterValueExtension.decode( + reader, + reader.uint32() + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_Template_Parameter { + const message = { + ...basePayload_Template_Parameter, + } as Payload_Template_Parameter; + if (object.name !== undefined && object.name !== null) { + message.name = String(object.name); + } else { + message.name = ""; + } + if (object.type !== undefined && object.type !== null) { + message.type = Number(object.type); + } else { + message.type = 0; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = Number(object.intValue); + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = Number(object.longValue); + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = Number(object.floatValue); + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = Number(object.doubleValue); + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = Boolean(object.booleanValue); + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = String(object.stringValue); + } else { + message.stringValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_Template_Parameter_ParameterValueExtension.fromJSON( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, + + toJSON(message: Payload_Template_Parameter): unknown { + const obj: any = {}; + message.name !== undefined && (obj.name = message.name); + message.type !== undefined && (obj.type = message.type); + message.intValue !== undefined && (obj.intValue = message.intValue); + message.longValue !== undefined && (obj.longValue = message.longValue); + message.floatValue !== undefined && (obj.floatValue = message.floatValue); + message.doubleValue !== undefined && + (obj.doubleValue = message.doubleValue); + message.booleanValue !== undefined && + (obj.booleanValue = message.booleanValue); + message.stringValue !== undefined && + (obj.stringValue = message.stringValue); + message.extensionValue !== undefined && + (obj.extensionValue = message.extensionValue + ? Payload_Template_Parameter_ParameterValueExtension.toJSON( + message.extensionValue + ) + : undefined); + return obj; + }, + + fromPartial( + object: DeepPartial + ): Payload_Template_Parameter { + const message = { + ...basePayload_Template_Parameter, + } as Payload_Template_Parameter; + if (object.name !== undefined && object.name !== null) { + message.name = object.name; + } else { + message.name = ""; + } + if (object.type !== undefined && object.type !== null) { + message.type = object.type; + } else { + message.type = 0; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = object.intValue; + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = object.longValue; + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = object.floatValue; + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = object.doubleValue; + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = object.booleanValue; + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = object.stringValue; + } else { + message.stringValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_Template_Parameter_ParameterValueExtension.fromPartial( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, +}; + +const basePayload_Template_Parameter_ParameterValueExtension: object = {}; + +export const Payload_Template_Parameter_ParameterValueExtension = { + encode( + _: Payload_Template_Parameter_ParameterValueExtension, + writer: Writer = Writer.create() + ): Writer { + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_Template_Parameter_ParameterValueExtension { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_Template_Parameter_ParameterValueExtension, + } as Payload_Template_Parameter_ParameterValueExtension; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(_: any): Payload_Template_Parameter_ParameterValueExtension { + const message = { + ...basePayload_Template_Parameter_ParameterValueExtension, + } as Payload_Template_Parameter_ParameterValueExtension; + return message; + }, + + toJSON(_: Payload_Template_Parameter_ParameterValueExtension): unknown { + const obj: any = {}; + return obj; + }, + + fromPartial( + _: DeepPartial + ): Payload_Template_Parameter_ParameterValueExtension { + const message = { + ...basePayload_Template_Parameter_ParameterValueExtension, + } as Payload_Template_Parameter_ParameterValueExtension; + return message; + }, +}; + +const basePayload_DataSet: object = { numOfColumns: 0, columns: "", types: 0 }; + +export const Payload_DataSet = { + encode(message: Payload_DataSet, writer: Writer = Writer.create()): Writer { + if (message.numOfColumns !== 0) { + writer.uint32(8).uint64(message.numOfColumns); + } + for (const v of message.columns) { + writer.uint32(18).string(v!); + } + writer.uint32(26).fork(); + for (const v of message.types) { + writer.uint32(v); + } + writer.ldelim(); + for (const v of message.rows) { + Payload_DataSet_Row.encode(v!, writer.uint32(34).fork()).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_DataSet { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_DataSet } as Payload_DataSet; + message.columns = []; + message.types = []; + message.rows = []; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.numOfColumns = longToNumber(reader.uint64() as Long); + break; + case 2: + message.columns.push(reader.string()); + break; + case 3: + if ((tag & 7) === 2) { + const end2 = reader.uint32() + reader.pos; + while (reader.pos < end2) { + message.types.push(reader.uint32()); + } + } else { + message.types.push(reader.uint32()); + } + break; + case 4: + message.rows.push( + Payload_DataSet_Row.decode(reader, reader.uint32()) + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_DataSet { + const message = { ...basePayload_DataSet } as Payload_DataSet; + message.columns = []; + message.types = []; + message.rows = []; + if (object.numOfColumns !== undefined && object.numOfColumns !== null) { + message.numOfColumns = Number(object.numOfColumns); + } else { + message.numOfColumns = 0; + } + if (object.columns !== undefined && object.columns !== null) { + for (const e of object.columns) { + message.columns.push(String(e)); + } + } + if (object.types !== undefined && object.types !== null) { + for (const e of object.types) { + message.types.push(Number(e)); + } + } + if (object.rows !== undefined && object.rows !== null) { + for (const e of object.rows) { + message.rows.push(Payload_DataSet_Row.fromJSON(e)); + } + } + return message; + }, + + toJSON(message: Payload_DataSet): unknown { + const obj: any = {}; + message.numOfColumns !== undefined && + (obj.numOfColumns = message.numOfColumns); + if (message.columns) { + obj.columns = message.columns.map((e) => e); + } else { + obj.columns = []; + } + if (message.types) { + obj.types = message.types.map((e) => e); + } else { + obj.types = []; + } + if (message.rows) { + obj.rows = message.rows.map((e) => + e ? Payload_DataSet_Row.toJSON(e) : undefined + ); + } else { + obj.rows = []; + } + return obj; + }, + + fromPartial(object: DeepPartial): Payload_DataSet { + const message = { ...basePayload_DataSet } as Payload_DataSet; + message.columns = []; + message.types = []; + message.rows = []; + if (object.numOfColumns !== undefined && object.numOfColumns !== null) { + message.numOfColumns = object.numOfColumns; + } else { + message.numOfColumns = 0; + } + if (object.columns !== undefined && object.columns !== null) { + for (const e of object.columns) { + message.columns.push(e); + } + } + if (object.types !== undefined && object.types !== null) { + for (const e of object.types) { + message.types.push(e); + } + } + if (object.rows !== undefined && object.rows !== null) { + for (const e of object.rows) { + message.rows.push(Payload_DataSet_Row.fromPartial(e)); + } + } + return message; + }, +}; + +const basePayload_DataSet_DataSetValue: object = {}; + +export const Payload_DataSet_DataSetValue = { + encode( + message: Payload_DataSet_DataSetValue, + writer: Writer = Writer.create() + ): Writer { + if (message.intValue !== undefined) { + writer.uint32(8).uint32(message.intValue); + } + if (message.longValue !== undefined) { + writer.uint32(16).uint64(message.longValue); + } + if (message.floatValue !== undefined) { + writer.uint32(29).float(message.floatValue); + } + if (message.doubleValue !== undefined) { + writer.uint32(33).double(message.doubleValue); + } + if (message.booleanValue !== undefined) { + writer.uint32(40).bool(message.booleanValue); + } + if (message.stringValue !== undefined) { + writer.uint32(50).string(message.stringValue); + } + if (message.extensionValue !== undefined) { + Payload_DataSet_DataSetValue_DataSetValueExtension.encode( + message.extensionValue, + writer.uint32(58).fork() + ).ldelim(); + } + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_DataSet_DataSetValue { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_DataSet_DataSetValue, + } as Payload_DataSet_DataSetValue; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.intValue = reader.uint32(); + break; + case 2: + message.longValue = longToNumber(reader.uint64() as Long); + break; + case 3: + message.floatValue = reader.float(); + break; + case 4: + message.doubleValue = reader.double(); + break; + case 5: + message.booleanValue = reader.bool(); + break; + case 6: + message.stringValue = reader.string(); + break; + case 7: + message.extensionValue = + Payload_DataSet_DataSetValue_DataSetValueExtension.decode( + reader, + reader.uint32() + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_DataSet_DataSetValue { + const message = { + ...basePayload_DataSet_DataSetValue, + } as Payload_DataSet_DataSetValue; + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = Number(object.intValue); + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = Number(object.longValue); + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = Number(object.floatValue); + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = Number(object.doubleValue); + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = Boolean(object.booleanValue); + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = String(object.stringValue); + } else { + message.stringValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_DataSet_DataSetValue_DataSetValueExtension.fromJSON( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, + + toJSON(message: Payload_DataSet_DataSetValue): unknown { + const obj: any = {}; + message.intValue !== undefined && (obj.intValue = message.intValue); + message.longValue !== undefined && (obj.longValue = message.longValue); + message.floatValue !== undefined && (obj.floatValue = message.floatValue); + message.doubleValue !== undefined && + (obj.doubleValue = message.doubleValue); + message.booleanValue !== undefined && + (obj.booleanValue = message.booleanValue); + message.stringValue !== undefined && + (obj.stringValue = message.stringValue); + message.extensionValue !== undefined && + (obj.extensionValue = message.extensionValue + ? Payload_DataSet_DataSetValue_DataSetValueExtension.toJSON( + message.extensionValue + ) + : undefined); + return obj; + }, + + fromPartial( + object: DeepPartial + ): Payload_DataSet_DataSetValue { + const message = { + ...basePayload_DataSet_DataSetValue, + } as Payload_DataSet_DataSetValue; + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = object.intValue; + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = object.longValue; + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = object.floatValue; + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = object.doubleValue; + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = object.booleanValue; + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = object.stringValue; + } else { + message.stringValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_DataSet_DataSetValue_DataSetValueExtension.fromPartial( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, +}; + +const basePayload_DataSet_DataSetValue_DataSetValueExtension: object = {}; + +export const Payload_DataSet_DataSetValue_DataSetValueExtension = { + encode( + _: Payload_DataSet_DataSetValue_DataSetValueExtension, + writer: Writer = Writer.create() + ): Writer { + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_DataSet_DataSetValue_DataSetValueExtension { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_DataSet_DataSetValue_DataSetValueExtension, + } as Payload_DataSet_DataSetValue_DataSetValueExtension; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(_: any): Payload_DataSet_DataSetValue_DataSetValueExtension { + const message = { + ...basePayload_DataSet_DataSetValue_DataSetValueExtension, + } as Payload_DataSet_DataSetValue_DataSetValueExtension; + return message; + }, + + toJSON(_: Payload_DataSet_DataSetValue_DataSetValueExtension): unknown { + const obj: any = {}; + return obj; + }, + + fromPartial( + _: DeepPartial + ): Payload_DataSet_DataSetValue_DataSetValueExtension { + const message = { + ...basePayload_DataSet_DataSetValue_DataSetValueExtension, + } as Payload_DataSet_DataSetValue_DataSetValueExtension; + return message; + }, +}; + +const basePayload_DataSet_Row: object = {}; + +export const Payload_DataSet_Row = { + encode( + message: Payload_DataSet_Row, + writer: Writer = Writer.create() + ): Writer { + for (const v of message.elements) { + Payload_DataSet_DataSetValue.encode( + v!, + writer.uint32(10).fork() + ).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_DataSet_Row { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_DataSet_Row } as Payload_DataSet_Row; + message.elements = []; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.elements.push( + Payload_DataSet_DataSetValue.decode(reader, reader.uint32()) + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_DataSet_Row { + const message = { ...basePayload_DataSet_Row } as Payload_DataSet_Row; + message.elements = []; + if (object.elements !== undefined && object.elements !== null) { + for (const e of object.elements) { + message.elements.push(Payload_DataSet_DataSetValue.fromJSON(e)); + } + } + return message; + }, + + toJSON(message: Payload_DataSet_Row): unknown { + const obj: any = {}; + if (message.elements) { + obj.elements = message.elements.map((e) => + e ? Payload_DataSet_DataSetValue.toJSON(e) : undefined + ); + } else { + obj.elements = []; + } + return obj; + }, + + fromPartial(object: DeepPartial): Payload_DataSet_Row { + const message = { ...basePayload_DataSet_Row } as Payload_DataSet_Row; + message.elements = []; + if (object.elements !== undefined && object.elements !== null) { + for (const e of object.elements) { + message.elements.push(Payload_DataSet_DataSetValue.fromPartial(e)); + } + } + return message; + }, +}; + +const basePayload_PropertyValue: object = { type: 0, isNull: false }; + +export const Payload_PropertyValue = { + encode( + message: Payload_PropertyValue, + writer: Writer = Writer.create() + ): Writer { + if (message.type !== 0) { + writer.uint32(8).uint32(message.type); + } + if (message.isNull === true) { + writer.uint32(16).bool(message.isNull); + } + if (message.intValue !== undefined) { + writer.uint32(24).uint32(message.intValue); + } + if (message.longValue !== undefined) { + writer.uint32(32).uint64(message.longValue); + } + if (message.floatValue !== undefined) { + writer.uint32(45).float(message.floatValue); + } + if (message.doubleValue !== undefined) { + writer.uint32(49).double(message.doubleValue); + } + if (message.booleanValue !== undefined) { + writer.uint32(56).bool(message.booleanValue); + } + if (message.stringValue !== undefined) { + writer.uint32(66).string(message.stringValue); + } + if (message.propertysetValue !== undefined) { + Payload_PropertySet.encode( + message.propertysetValue, + writer.uint32(74).fork() + ).ldelim(); + } + if (message.propertysetsValue !== undefined) { + Payload_PropertySetList.encode( + message.propertysetsValue, + writer.uint32(82).fork() + ).ldelim(); + } + if (message.extensionValue !== undefined) { + Payload_PropertyValue_PropertyValueExtension.encode( + message.extensionValue, + writer.uint32(90).fork() + ).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_PropertyValue { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_PropertyValue } as Payload_PropertyValue; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.type = reader.uint32(); + break; + case 2: + message.isNull = reader.bool(); + break; + case 3: + message.intValue = reader.uint32(); + break; + case 4: + message.longValue = longToNumber(reader.uint64() as Long); + break; + case 5: + message.floatValue = reader.float(); + break; + case 6: + message.doubleValue = reader.double(); + break; + case 7: + message.booleanValue = reader.bool(); + break; + case 8: + message.stringValue = reader.string(); + break; + case 9: + message.propertysetValue = Payload_PropertySet.decode( + reader, + reader.uint32() + ); + break; + case 10: + message.propertysetsValue = Payload_PropertySetList.decode( + reader, + reader.uint32() + ); + break; + case 11: + message.extensionValue = + Payload_PropertyValue_PropertyValueExtension.decode( + reader, + reader.uint32() + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_PropertyValue { + const message = { ...basePayload_PropertyValue } as Payload_PropertyValue; + if (object.type !== undefined && object.type !== null) { + message.type = Number(object.type); + } else { + message.type = 0; + } + if (object.isNull !== undefined && object.isNull !== null) { + message.isNull = Boolean(object.isNull); + } else { + message.isNull = false; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = Number(object.intValue); + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = Number(object.longValue); + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = Number(object.floatValue); + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = Number(object.doubleValue); + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = Boolean(object.booleanValue); + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = String(object.stringValue); + } else { + message.stringValue = undefined; + } + if ( + object.propertysetValue !== undefined && + object.propertysetValue !== null + ) { + message.propertysetValue = Payload_PropertySet.fromJSON( + object.propertysetValue + ); + } else { + message.propertysetValue = undefined; + } + if ( + object.propertysetsValue !== undefined && + object.propertysetsValue !== null + ) { + message.propertysetsValue = Payload_PropertySetList.fromJSON( + object.propertysetsValue + ); + } else { + message.propertysetsValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_PropertyValue_PropertyValueExtension.fromJSON( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, + + toJSON(message: Payload_PropertyValue): unknown { + const obj: any = {}; + message.type !== undefined && (obj.type = message.type); + message.isNull !== undefined && (obj.isNull = message.isNull); + message.intValue !== undefined && (obj.intValue = message.intValue); + message.longValue !== undefined && (obj.longValue = message.longValue); + message.floatValue !== undefined && (obj.floatValue = message.floatValue); + message.doubleValue !== undefined && + (obj.doubleValue = message.doubleValue); + message.booleanValue !== undefined && + (obj.booleanValue = message.booleanValue); + message.stringValue !== undefined && + (obj.stringValue = message.stringValue); + message.propertysetValue !== undefined && + (obj.propertysetValue = message.propertysetValue + ? Payload_PropertySet.toJSON(message.propertysetValue) + : undefined); + message.propertysetsValue !== undefined && + (obj.propertysetsValue = message.propertysetsValue + ? Payload_PropertySetList.toJSON(message.propertysetsValue) + : undefined); + message.extensionValue !== undefined && + (obj.extensionValue = message.extensionValue + ? Payload_PropertyValue_PropertyValueExtension.toJSON( + message.extensionValue + ) + : undefined); + return obj; + }, + + fromPartial( + object: DeepPartial + ): Payload_PropertyValue { + const message = { ...basePayload_PropertyValue } as Payload_PropertyValue; + if (object.type !== undefined && object.type !== null) { + message.type = object.type; + } else { + message.type = 0; + } + if (object.isNull !== undefined && object.isNull !== null) { + message.isNull = object.isNull; + } else { + message.isNull = false; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = object.intValue; + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = object.longValue; + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = object.floatValue; + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = object.doubleValue; + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = object.booleanValue; + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = object.stringValue; + } else { + message.stringValue = undefined; + } + if ( + object.propertysetValue !== undefined && + object.propertysetValue !== null + ) { + message.propertysetValue = Payload_PropertySet.fromPartial( + object.propertysetValue + ); + } else { + message.propertysetValue = undefined; + } + if ( + object.propertysetsValue !== undefined && + object.propertysetsValue !== null + ) { + message.propertysetsValue = Payload_PropertySetList.fromPartial( + object.propertysetsValue + ); + } else { + message.propertysetsValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = + Payload_PropertyValue_PropertyValueExtension.fromPartial( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, +}; + +const basePayload_PropertyValue_PropertyValueExtension: object = {}; + +export const Payload_PropertyValue_PropertyValueExtension = { + encode( + _: Payload_PropertyValue_PropertyValueExtension, + writer: Writer = Writer.create() + ): Writer { + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_PropertyValue_PropertyValueExtension { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_PropertyValue_PropertyValueExtension, + } as Payload_PropertyValue_PropertyValueExtension; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(_: any): Payload_PropertyValue_PropertyValueExtension { + const message = { + ...basePayload_PropertyValue_PropertyValueExtension, + } as Payload_PropertyValue_PropertyValueExtension; + return message; + }, + + toJSON(_: Payload_PropertyValue_PropertyValueExtension): unknown { + const obj: any = {}; + return obj; + }, + + fromPartial( + _: DeepPartial + ): Payload_PropertyValue_PropertyValueExtension { + const message = { + ...basePayload_PropertyValue_PropertyValueExtension, + } as Payload_PropertyValue_PropertyValueExtension; + return message; + }, +}; + +const basePayload_PropertySet: object = { keys: "" }; + +export const Payload_PropertySet = { + encode( + message: Payload_PropertySet, + writer: Writer = Writer.create() + ): Writer { + for (const v of message.keys) { + writer.uint32(10).string(v!); + } + for (const v of message.values) { + Payload_PropertyValue.encode(v!, writer.uint32(18).fork()).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_PropertySet { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_PropertySet } as Payload_PropertySet; + message.keys = []; + message.values = []; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.keys.push(reader.string()); + break; + case 2: + message.values.push( + Payload_PropertyValue.decode(reader, reader.uint32()) + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_PropertySet { + const message = { ...basePayload_PropertySet } as Payload_PropertySet; + message.keys = []; + message.values = []; + if (object.keys !== undefined && object.keys !== null) { + for (const e of object.keys) { + message.keys.push(String(e)); + } + } + if (object.values !== undefined && object.values !== null) { + for (const e of object.values) { + message.values.push(Payload_PropertyValue.fromJSON(e)); + } + } + return message; + }, + + toJSON(message: Payload_PropertySet): unknown { + const obj: any = {}; + if (message.keys) { + obj.keys = message.keys.map((e) => e); + } else { + obj.keys = []; + } + if (message.values) { + obj.values = message.values.map((e) => + e ? Payload_PropertyValue.toJSON(e) : undefined + ); + } else { + obj.values = []; + } + return obj; + }, + + fromPartial(object: DeepPartial): Payload_PropertySet { + const message = { ...basePayload_PropertySet } as Payload_PropertySet; + message.keys = []; + message.values = []; + if (object.keys !== undefined && object.keys !== null) { + for (const e of object.keys) { + message.keys.push(e); + } + } + if (object.values !== undefined && object.values !== null) { + for (const e of object.values) { + message.values.push(Payload_PropertyValue.fromPartial(e)); + } + } + return message; + }, +}; + +const basePayload_PropertySetList: object = {}; + +export const Payload_PropertySetList = { + encode( + message: Payload_PropertySetList, + writer: Writer = Writer.create() + ): Writer { + for (const v of message.propertyset) { + Payload_PropertySet.encode(v!, writer.uint32(10).fork()).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_PropertySetList { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_PropertySetList, + } as Payload_PropertySetList; + message.propertyset = []; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.propertyset.push( + Payload_PropertySet.decode(reader, reader.uint32()) + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_PropertySetList { + const message = { + ...basePayload_PropertySetList, + } as Payload_PropertySetList; + message.propertyset = []; + if (object.propertyset !== undefined && object.propertyset !== null) { + for (const e of object.propertyset) { + message.propertyset.push(Payload_PropertySet.fromJSON(e)); + } + } + return message; + }, + + toJSON(message: Payload_PropertySetList): unknown { + const obj: any = {}; + if (message.propertyset) { + obj.propertyset = message.propertyset.map((e) => + e ? Payload_PropertySet.toJSON(e) : undefined + ); + } else { + obj.propertyset = []; + } + return obj; + }, + + fromPartial( + object: DeepPartial + ): Payload_PropertySetList { + const message = { + ...basePayload_PropertySetList, + } as Payload_PropertySetList; + message.propertyset = []; + if (object.propertyset !== undefined && object.propertyset !== null) { + for (const e of object.propertyset) { + message.propertyset.push(Payload_PropertySet.fromPartial(e)); + } + } + return message; + }, +}; + +const basePayload_MetaData: object = { + isMultiPart: false, + contentType: "", + size: 0, + seq: 0, + fileName: "", + fileType: "", + md5: "", + description: "", +}; + +export const Payload_MetaData = { + encode(message: Payload_MetaData, writer: Writer = Writer.create()): Writer { + if (message.isMultiPart === true) { + writer.uint32(8).bool(message.isMultiPart); + } + if (message.contentType !== "") { + writer.uint32(18).string(message.contentType); + } + if (message.size !== 0) { + writer.uint32(24).uint64(message.size); + } + if (message.seq !== 0) { + writer.uint32(32).uint64(message.seq); + } + if (message.fileName !== "") { + writer.uint32(42).string(message.fileName); + } + if (message.fileType !== "") { + writer.uint32(50).string(message.fileType); + } + if (message.md5 !== "") { + writer.uint32(58).string(message.md5); + } + if (message.description !== "") { + writer.uint32(66).string(message.description); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_MetaData { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_MetaData } as Payload_MetaData; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.isMultiPart = reader.bool(); + break; + case 2: + message.contentType = reader.string(); + break; + case 3: + message.size = longToNumber(reader.uint64() as Long); + break; + case 4: + message.seq = longToNumber(reader.uint64() as Long); + break; + case 5: + message.fileName = reader.string(); + break; + case 6: + message.fileType = reader.string(); + break; + case 7: + message.md5 = reader.string(); + break; + case 8: + message.description = reader.string(); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_MetaData { + const message = { ...basePayload_MetaData } as Payload_MetaData; + if (object.isMultiPart !== undefined && object.isMultiPart !== null) { + message.isMultiPart = Boolean(object.isMultiPart); + } else { + message.isMultiPart = false; + } + if (object.contentType !== undefined && object.contentType !== null) { + message.contentType = String(object.contentType); + } else { + message.contentType = ""; + } + if (object.size !== undefined && object.size !== null) { + message.size = Number(object.size); + } else { + message.size = 0; + } + if (object.seq !== undefined && object.seq !== null) { + message.seq = Number(object.seq); + } else { + message.seq = 0; + } + if (object.fileName !== undefined && object.fileName !== null) { + message.fileName = String(object.fileName); + } else { + message.fileName = ""; + } + if (object.fileType !== undefined && object.fileType !== null) { + message.fileType = String(object.fileType); + } else { + message.fileType = ""; + } + if (object.md5 !== undefined && object.md5 !== null) { + message.md5 = String(object.md5); + } else { + message.md5 = ""; + } + if (object.description !== undefined && object.description !== null) { + message.description = String(object.description); + } else { + message.description = ""; + } + return message; + }, + + toJSON(message: Payload_MetaData): unknown { + const obj: any = {}; + message.isMultiPart !== undefined && + (obj.isMultiPart = message.isMultiPart); + message.contentType !== undefined && + (obj.contentType = message.contentType); + message.size !== undefined && (obj.size = message.size); + message.seq !== undefined && (obj.seq = message.seq); + message.fileName !== undefined && (obj.fileName = message.fileName); + message.fileType !== undefined && (obj.fileType = message.fileType); + message.md5 !== undefined && (obj.md5 = message.md5); + message.description !== undefined && + (obj.description = message.description); + return obj; + }, + + fromPartial(object: DeepPartial): Payload_MetaData { + const message = { ...basePayload_MetaData } as Payload_MetaData; + if (object.isMultiPart !== undefined && object.isMultiPart !== null) { + message.isMultiPart = object.isMultiPart; + } else { + message.isMultiPart = false; + } + if (object.contentType !== undefined && object.contentType !== null) { + message.contentType = object.contentType; + } else { + message.contentType = ""; + } + if (object.size !== undefined && object.size !== null) { + message.size = object.size; + } else { + message.size = 0; + } + if (object.seq !== undefined && object.seq !== null) { + message.seq = object.seq; + } else { + message.seq = 0; + } + if (object.fileName !== undefined && object.fileName !== null) { + message.fileName = object.fileName; + } else { + message.fileName = ""; + } + if (object.fileType !== undefined && object.fileType !== null) { + message.fileType = object.fileType; + } else { + message.fileType = ""; + } + if (object.md5 !== undefined && object.md5 !== null) { + message.md5 = object.md5; + } else { + message.md5 = ""; + } + if (object.description !== undefined && object.description !== null) { + message.description = object.description; + } else { + message.description = ""; + } + return message; + }, +}; + +const basePayload_Metric: object = { + name: "", + alias: 0, + timestamp: 0, + datatype: 0, + isHistorical: false, + isTransient: false, + isNull: false, +}; + +export const Payload_Metric = { + encode(message: Payload_Metric, writer: Writer = Writer.create()): Writer { + if (message.name !== "") { + writer.uint32(10).string(message.name); + } + if (message.alias !== 0) { + writer.uint32(16).uint64(message.alias); + } + if (message.timestamp !== 0) { + writer.uint32(24).uint64(message.timestamp); + } + if (message.datatype !== 0) { + writer.uint32(32).uint32(message.datatype); + } + if (message.isHistorical === true) { + writer.uint32(40).bool(message.isHistorical); + } + if (message.isTransient === true) { + writer.uint32(48).bool(message.isTransient); + } + if (message.isNull === true) { + writer.uint32(56).bool(message.isNull); + } + if (message.metadata !== undefined) { + Payload_MetaData.encode( + message.metadata, + writer.uint32(66).fork() + ).ldelim(); + } + if (message.properties !== undefined) { + Payload_PropertySet.encode( + message.properties, + writer.uint32(74).fork() + ).ldelim(); + } + if (message.intValue !== undefined) { + writer.uint32(80).uint32(message.intValue); + } + if (message.longValue !== undefined) { + writer.uint32(88).uint64(message.longValue); + } + if (message.floatValue !== undefined) { + writer.uint32(101).float(message.floatValue); + } + if (message.doubleValue !== undefined) { + writer.uint32(105).double(message.doubleValue); + } + if (message.booleanValue !== undefined) { + writer.uint32(112).bool(message.booleanValue); + } + if (message.stringValue !== undefined) { + writer.uint32(122).string(message.stringValue); + } + if (message.bytesValue !== undefined) { + writer.uint32(130).bytes(message.bytesValue); + } + if (message.datasetValue !== undefined) { + Payload_DataSet.encode( + message.datasetValue, + writer.uint32(138).fork() + ).ldelim(); + } + if (message.templateValue !== undefined) { + Payload_Template.encode( + message.templateValue, + writer.uint32(146).fork() + ).ldelim(); + } + if (message.extensionValue !== undefined) { + Payload_Metric_MetricValueExtension.encode( + message.extensionValue, + writer.uint32(154).fork() + ).ldelim(); + } + return writer; + }, + + decode(input: Reader | Uint8Array, length?: number): Payload_Metric { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { ...basePayload_Metric } as Payload_Metric; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.name = reader.string(); + break; + case 2: + message.alias = longToNumber(reader.uint64() as Long); + break; + case 3: + message.timestamp = longToNumber(reader.uint64() as Long); + break; + case 4: + message.datatype = reader.uint32(); + break; + case 5: + message.isHistorical = reader.bool(); + break; + case 6: + message.isTransient = reader.bool(); + break; + case 7: + message.isNull = reader.bool(); + break; + case 8: + message.metadata = Payload_MetaData.decode(reader, reader.uint32()); + break; + case 9: + message.properties = Payload_PropertySet.decode( + reader, + reader.uint32() + ); + break; + case 10: + message.intValue = reader.uint32(); + break; + case 11: + message.longValue = longToNumber(reader.uint64() as Long); + break; + case 12: + message.floatValue = reader.float(); + break; + case 13: + message.doubleValue = reader.double(); + break; + case 14: + message.booleanValue = reader.bool(); + break; + case 15: + message.stringValue = reader.string(); + break; + case 16: + message.bytesValue = reader.bytes() as Buffer; + break; + case 17: + message.datasetValue = Payload_DataSet.decode( + reader, + reader.uint32() + ); + break; + case 18: + message.templateValue = Payload_Template.decode( + reader, + reader.uint32() + ); + break; + case 19: + message.extensionValue = Payload_Metric_MetricValueExtension.decode( + reader, + reader.uint32() + ); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(object: any): Payload_Metric { + const message = { ...basePayload_Metric } as Payload_Metric; + if (object.name !== undefined && object.name !== null) { + message.name = String(object.name); + } else { + message.name = ""; + } + if (object.alias !== undefined && object.alias !== null) { + message.alias = Number(object.alias); + } else { + message.alias = 0; + } + if (object.timestamp !== undefined && object.timestamp !== null) { + message.timestamp = Number(object.timestamp); + } else { + message.timestamp = 0; + } + if (object.datatype !== undefined && object.datatype !== null) { + message.datatype = Number(object.datatype); + } else { + message.datatype = 0; + } + if (object.isHistorical !== undefined && object.isHistorical !== null) { + message.isHistorical = Boolean(object.isHistorical); + } else { + message.isHistorical = false; + } + if (object.isTransient !== undefined && object.isTransient !== null) { + message.isTransient = Boolean(object.isTransient); + } else { + message.isTransient = false; + } + if (object.isNull !== undefined && object.isNull !== null) { + message.isNull = Boolean(object.isNull); + } else { + message.isNull = false; + } + if (object.metadata !== undefined && object.metadata !== null) { + message.metadata = Payload_MetaData.fromJSON(object.metadata); + } else { + message.metadata = undefined; + } + if (object.properties !== undefined && object.properties !== null) { + message.properties = Payload_PropertySet.fromJSON(object.properties); + } else { + message.properties = undefined; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = Number(object.intValue); + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = Number(object.longValue); + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = Number(object.floatValue); + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = Number(object.doubleValue); + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = Boolean(object.booleanValue); + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = String(object.stringValue); + } else { + message.stringValue = undefined; + } + if (object.bytesValue !== undefined && object.bytesValue !== null) { + message.bytesValue = Buffer.from(bytesFromBase64(object.bytesValue)); + } + if (object.datasetValue !== undefined && object.datasetValue !== null) { + message.datasetValue = Payload_DataSet.fromJSON(object.datasetValue); + } else { + message.datasetValue = undefined; + } + if (object.templateValue !== undefined && object.templateValue !== null) { + message.templateValue = Payload_Template.fromJSON(object.templateValue); + } else { + message.templateValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = Payload_Metric_MetricValueExtension.fromJSON( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, + + toJSON(message: Payload_Metric): unknown { + const obj: any = {}; + message.name !== undefined && (obj.name = message.name); + message.alias !== undefined && (obj.alias = message.alias); + message.timestamp !== undefined && (obj.timestamp = message.timestamp); + message.datatype !== undefined && (obj.datatype = message.datatype); + message.isHistorical !== undefined && + (obj.isHistorical = message.isHistorical); + message.isTransient !== undefined && + (obj.isTransient = message.isTransient); + message.isNull !== undefined && (obj.isNull = message.isNull); + message.metadata !== undefined && + (obj.metadata = message.metadata + ? Payload_MetaData.toJSON(message.metadata) + : undefined); + message.properties !== undefined && + (obj.properties = message.properties + ? Payload_PropertySet.toJSON(message.properties) + : undefined); + message.intValue !== undefined && (obj.intValue = message.intValue); + message.longValue !== undefined && (obj.longValue = message.longValue); + message.floatValue !== undefined && (obj.floatValue = message.floatValue); + message.doubleValue !== undefined && + (obj.doubleValue = message.doubleValue); + message.booleanValue !== undefined && + (obj.booleanValue = message.booleanValue); + message.stringValue !== undefined && + (obj.stringValue = message.stringValue); + message.bytesValue !== undefined && + (obj.bytesValue = + message.bytesValue !== undefined + ? base64FromBytes(message.bytesValue) + : undefined); + message.datasetValue !== undefined && + (obj.datasetValue = message.datasetValue + ? Payload_DataSet.toJSON(message.datasetValue) + : undefined); + message.templateValue !== undefined && + (obj.templateValue = message.templateValue + ? Payload_Template.toJSON(message.templateValue) + : undefined); + message.extensionValue !== undefined && + (obj.extensionValue = message.extensionValue + ? Payload_Metric_MetricValueExtension.toJSON(message.extensionValue) + : undefined); + return obj; + }, + + fromPartial(object: DeepPartial): Payload_Metric { + const message = { ...basePayload_Metric } as Payload_Metric; + if (object.name !== undefined && object.name !== null) { + message.name = object.name; + } else { + message.name = ""; + } + if (object.alias !== undefined && object.alias !== null) { + message.alias = object.alias; + } else { + message.alias = 0; + } + if (object.timestamp !== undefined && object.timestamp !== null) { + message.timestamp = object.timestamp; + } else { + message.timestamp = 0; + } + if (object.datatype !== undefined && object.datatype !== null) { + message.datatype = object.datatype; + } else { + message.datatype = 0; + } + if (object.isHistorical !== undefined && object.isHistorical !== null) { + message.isHistorical = object.isHistorical; + } else { + message.isHistorical = false; + } + if (object.isTransient !== undefined && object.isTransient !== null) { + message.isTransient = object.isTransient; + } else { + message.isTransient = false; + } + if (object.isNull !== undefined && object.isNull !== null) { + message.isNull = object.isNull; + } else { + message.isNull = false; + } + if (object.metadata !== undefined && object.metadata !== null) { + message.metadata = Payload_MetaData.fromPartial(object.metadata); + } else { + message.metadata = undefined; + } + if (object.properties !== undefined && object.properties !== null) { + message.properties = Payload_PropertySet.fromPartial(object.properties); + } else { + message.properties = undefined; + } + if (object.intValue !== undefined && object.intValue !== null) { + message.intValue = object.intValue; + } else { + message.intValue = undefined; + } + if (object.longValue !== undefined && object.longValue !== null) { + message.longValue = object.longValue; + } else { + message.longValue = undefined; + } + if (object.floatValue !== undefined && object.floatValue !== null) { + message.floatValue = object.floatValue; + } else { + message.floatValue = undefined; + } + if (object.doubleValue !== undefined && object.doubleValue !== null) { + message.doubleValue = object.doubleValue; + } else { + message.doubleValue = undefined; + } + if (object.booleanValue !== undefined && object.booleanValue !== null) { + message.booleanValue = object.booleanValue; + } else { + message.booleanValue = undefined; + } + if (object.stringValue !== undefined && object.stringValue !== null) { + message.stringValue = object.stringValue; + } else { + message.stringValue = undefined; + } + if (object.bytesValue !== undefined && object.bytesValue !== null) { + message.bytesValue = object.bytesValue; + } else { + message.bytesValue = undefined; + } + if (object.datasetValue !== undefined && object.datasetValue !== null) { + message.datasetValue = Payload_DataSet.fromPartial(object.datasetValue); + } else { + message.datasetValue = undefined; + } + if (object.templateValue !== undefined && object.templateValue !== null) { + message.templateValue = Payload_Template.fromPartial( + object.templateValue + ); + } else { + message.templateValue = undefined; + } + if (object.extensionValue !== undefined && object.extensionValue !== null) { + message.extensionValue = Payload_Metric_MetricValueExtension.fromPartial( + object.extensionValue + ); + } else { + message.extensionValue = undefined; + } + return message; + }, +}; + +const basePayload_Metric_MetricValueExtension: object = {}; + +export const Payload_Metric_MetricValueExtension = { + encode( + _: Payload_Metric_MetricValueExtension, + writer: Writer = Writer.create() + ): Writer { + return writer; + }, + + decode( + input: Reader | Uint8Array, + length?: number + ): Payload_Metric_MetricValueExtension { + const reader = input instanceof Reader ? input : new Reader(input); + let end = length === undefined ? reader.len : reader.pos + length; + const message = { + ...basePayload_Metric_MetricValueExtension, + } as Payload_Metric_MetricValueExtension; + while (reader.pos < end) { + const tag = reader.uint32(); + switch (tag >>> 3) { + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }, + + fromJSON(_: any): Payload_Metric_MetricValueExtension { + const message = { + ...basePayload_Metric_MetricValueExtension, + } as Payload_Metric_MetricValueExtension; + return message; + }, + + toJSON(_: Payload_Metric_MetricValueExtension): unknown { + const obj: any = {}; + return obj; + }, + + fromPartial( + _: DeepPartial + ): Payload_Metric_MetricValueExtension { + const message = { + ...basePayload_Metric_MetricValueExtension, + } as Payload_Metric_MetricValueExtension; + return message; + }, +}; + +declare var self: any | undefined; +declare var window: any | undefined; +var globalThis: any = (() => { + if (typeof globalThis !== "undefined") return globalThis; + if (typeof self !== "undefined") return self; + if (typeof window !== "undefined") return window; + if (typeof global !== "undefined") return global; + throw "Unable to locate global object"; +})(); + +const atob: (b64: string) => string = + globalThis.atob || + ((b64) => globalThis.Buffer.from(b64, "base64").toString("binary")); +function bytesFromBase64(b64: string): Uint8Array { + const bin = atob(b64); + const arr = new Uint8Array(bin.length); + for (let i = 0; i < bin.length; ++i) { + arr[i] = bin.charCodeAt(i); + } + return arr; +} + +const btoa: (bin: string) => string = + globalThis.btoa || + ((bin) => globalThis.Buffer.from(bin, "binary").toString("base64")); +function base64FromBytes(arr: Uint8Array): string { + const bin: string[] = []; + for (const byte of arr) { + bin.push(String.fromCharCode(byte)); + } + return btoa(bin.join("")); +} + +type Builtin = + | Date + | Function + | Uint8Array + | string + | number + | boolean + | undefined; +export type DeepPartial = T extends Builtin + ? T + : T extends Array + ? Array> + : T extends ReadonlyArray + ? ReadonlyArray> + : T extends {} + ? { [K in keyof T]?: DeepPartial } + : Partial; + +function longToNumber(long: Long): number { + if (long.gt(Number.MAX_SAFE_INTEGER)) { + throw new globalThis.Error("Value is larger than Number.MAX_SAFE_INTEGER"); + } + return long.toNumber(); +} + +// If you get a compile-error about 'Constructor and ... have no overlap', +// add '--ts_proto_opt=esModuleInterop=true' as a flag when calling 'protoc'. +if (util.Long !== Long) { + util.Long = Long as any; + configure(); +} diff --git a/backend/yarn.lock b/backend/yarn.lock index 3314a84..a672cdc 100644 --- a/backend/yarn.lock +++ b/backend/yarn.lock @@ -2,537 +2,89 @@ # yarn lockfile v1 -async-limiter@~1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/async-limiter/-/async-limiter-1.0.0.tgz#78faed8c3d074ab81f22b4e985d79e8738f720f8" - integrity sha512-jp/uFnooOiO+L211eZOoSyzpOITMXx1rBITauYykG3BRYPu8h0UcxsPNB04RR5vo4Tyz3+ay17tR6JVf9qzYWg== +"@protobufjs/aspromise@^1.1.1", "@protobufjs/aspromise@^1.1.2": + version "1.1.2" + resolved "https://registry.yarnpkg.com/@protobufjs/aspromise/-/aspromise-1.1.2.tgz#9b8b0cc663d669a7d8f6f5d0893a14d348f30fbf" + integrity sha1-m4sMxmPWaafY9vXQiToU00jzD78= -balanced-match@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/balanced-match/-/balanced-match-1.0.0.tgz#89b4d199ab2bee49de164ea02b89ce462d71b767" - integrity sha1-ibTRmasr7kneFk6gK4nORi1xt2c= +"@protobufjs/base64@^1.1.2": + version "1.1.2" + resolved "https://registry.yarnpkg.com/@protobufjs/base64/-/base64-1.1.2.tgz#4c85730e59b9a1f1f349047dbf24296034bb2735" + integrity sha512-AZkcAA5vnN/v4PDqKyMR5lx7hZttPDgClv83E//FMNhR2TMcLUhfRUBHCmSl0oi9zMgDDqRUJkSxO3wm85+XLg== -base64-js@^1.3.0: - version "1.3.0" - resolved "https://registry.yarnpkg.com/base64-js/-/base64-js-1.3.0.tgz#cab1e6118f051095e58b5281aea8c1cd22bfc0e3" - integrity sha512-ccav/yGvoa80BQDljCxsmmQ3Xvx60/UpBIij5QN21W3wBi/hhIC9OoO+KLpu9IJTS9j4DRVJ3aDDF9cMSoa2lw== +"@protobufjs/codegen@^2.0.4": + version "2.0.4" + resolved "https://registry.yarnpkg.com/@protobufjs/codegen/-/codegen-2.0.4.tgz#7ef37f0d010fb028ad1ad59722e506d9262815cb" + integrity sha512-YyFaikqM5sH0ziFZCN3xDC7zeGaB/d0IUb9CATugHWbd1FRFwWwt4ld4OYMPWu5a3Xe01mGAULCdqhMlPl29Jg== -bl@^1.2.2: - version "1.2.2" - resolved "https://registry.yarnpkg.com/bl/-/bl-1.2.2.tgz#a160911717103c07410cef63ef51b397c025af9c" - integrity sha512-e8tQYnZodmebYDWGH7KMRvtzKXaJHx3BbilrgZCfvyLUYdKpK1t5PSPmpkny/SgiTSCnjfLW7v5rlONXVFkQEA== - dependencies: - readable-stream "^2.3.5" - safe-buffer "^5.1.1" - -brace-expansion@^1.1.7: - version "1.1.11" - resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-1.1.11.tgz#3c7fcbf529d87226f3d2f52b966ff5271eb441dd" - integrity sha512-iCuPHDFgrHX7H2vEI/5xpz07zSHB00TpugqhmYtVmMO6518mCuRMoOYFldEBl0g187ufozdaHgWKcYFb61qGiA== - dependencies: - balanced-match "^1.0.0" - concat-map "0.0.1" - -buffer-from@^1.0.0: - version "1.1.1" - resolved "https://registry.yarnpkg.com/buffer-from/-/buffer-from-1.1.1.tgz#32713bc028f75c02fdb710d7c7bcec1f2c6070ef" - integrity sha512-MQcXEUbCKtEo7bhqEs6560Hyd4XaovZlO/k9V3hjVUF/zwW7KBVdSK4gIt/bzwS9MbR5qob+F5jusZsb0YQK2A== - -callback-stream@^1.0.2: +"@protobufjs/eventemitter@^1.1.0": version "1.1.0" - resolved "https://registry.yarnpkg.com/callback-stream/-/callback-stream-1.1.0.tgz#4701a51266f06e06eaa71fc17233822d875f4908" - integrity sha1-RwGlEmbwbgbqpx/BcjOCLYdfSQg= - dependencies: - inherits "^2.0.1" - readable-stream "> 1.0.0 < 3.0.0" + resolved "https://registry.yarnpkg.com/@protobufjs/eventemitter/-/eventemitter-1.1.0.tgz#355cbc98bafad5978f9ed095f397621f1d066b70" + integrity sha1-NVy8mLr61ZePntCV85diHx0Ga3A= -commist@^1.0.0: +"@protobufjs/fetch@^1.1.0": version "1.1.0" - resolved "https://registry.yarnpkg.com/commist/-/commist-1.1.0.tgz#17811ec6978f6c15ee4de80c45c9beb77cee35d5" - integrity sha512-rraC8NXWOEjhADbZe9QBNzLAN5Q3fsTPQtBV+fEVj6xKIgDgNiEVE6ZNfHpZOqfQ21YUzfVNUXLOEZquYvQPPg== + resolved "https://registry.yarnpkg.com/@protobufjs/fetch/-/fetch-1.1.0.tgz#ba99fb598614af65700c1619ff06d454b0d84c45" + integrity sha1-upn7WYYUr2VwDBYZ/wbUVLDYTEU= dependencies: - leven "^2.1.0" - minimist "^1.1.0" + "@protobufjs/aspromise" "^1.1.1" + "@protobufjs/inquire" "^1.1.0" -concat-map@0.0.1: - version "0.0.1" - resolved "https://registry.yarnpkg.com/concat-map/-/concat-map-0.0.1.tgz#d8a96bd77fd68df7793a73036a3ba0d5405d477b" - integrity sha1-2Klr13/Wjfd5OnMDajug1UBdR3s= - -concat-stream@^1.6.2: - version "1.6.2" - resolved "https://registry.yarnpkg.com/concat-stream/-/concat-stream-1.6.2.tgz#904bdf194cd3122fc675c77fc4ac3d4ff0fd1a34" - integrity sha512-27HBghJxjiZtIk3Ycvn/4kbJk/1uZuJFfuPEns6LaEvpvG1f0hTea8lilrouyo9mVc2GWdcEZ8OLoGmSADlrCw== - dependencies: - buffer-from "^1.0.0" - inherits "^2.0.3" - readable-stream "^2.2.2" - typedarray "^0.0.6" - -core-util-is@~1.0.0: +"@protobufjs/float@^1.0.2": version "1.0.2" - resolved "https://registry.yarnpkg.com/core-util-is/-/core-util-is-1.0.2.tgz#b5fd54220aa2bc5ab57aab7140c940754503c1a7" - integrity sha1-tf1UIgqivFq1eqtxQMlAdUUDwac= + resolved "https://registry.yarnpkg.com/@protobufjs/float/-/float-1.0.2.tgz#5e9e1abdcb73fc0a7cb8b291df78c8cbd97b87d1" + integrity sha1-Xp4avctz/Ap8uLKR33jIy9l7h9E= -d@1: - version "1.0.1" - resolved "https://registry.yarnpkg.com/d/-/d-1.0.1.tgz#8698095372d58dbee346ffd0c7093f99f8f9eb5a" - integrity sha512-m62ShEObQ39CfralilEQRjH6oAMtNCV1xJyEx5LpRYUVN+EviphDgUc/F3hnYbADmkiNs67Y+3ylmlG7Lnu+FA== - dependencies: - es5-ext "^0.10.50" - type "^1.0.1" - -duplexify@^3.5.1, duplexify@^3.6.0: - version "3.7.1" - resolved "https://registry.yarnpkg.com/duplexify/-/duplexify-3.7.1.tgz#2a4df5317f6ccfd91f86d6fd25d8d8a103b88309" - integrity sha512-07z8uv2wMyS51kKhD1KsdXJg5WQ6t93RneqRxUHnskXVtlYYkLqM0gqStQZ3pj073g687jPCHrqNfCzawLYh5g== - dependencies: - end-of-stream "^1.0.0" - inherits "^2.0.1" - readable-stream "^2.0.0" - stream-shift "^1.0.0" - -end-of-stream@^1.0.0, end-of-stream@^1.1.0, end-of-stream@^1.4.1: - version "1.4.1" - resolved "https://registry.yarnpkg.com/end-of-stream/-/end-of-stream-1.4.1.tgz#ed29634d19baba463b6ce6b80a37213eab71ec43" - integrity sha512-1MkrZNvWTKCaigbn+W15elq2BB/L22nqrSY5DKlo3X6+vclJm8Bb5djXJBmEX6fS3+zCh/F4VBK5Z2KxJt4s2Q== - dependencies: - once "^1.4.0" - -es5-ext@^0.10.35, es5-ext@^0.10.50, es5-ext@~0.10.14: - version "0.10.50" - resolved "https://registry.yarnpkg.com/es5-ext/-/es5-ext-0.10.50.tgz#6d0e23a0abdb27018e5ac4fd09b412bc5517a778" - integrity sha512-KMzZTPBkeQV/JcSQhI5/z6d9VWJ3EnQ194USTUwIYZ2ZbpN8+SGXQKt1h68EX44+qt+Fzr8DO17vnxrw7c3agw== - dependencies: - es6-iterator "~2.0.3" - es6-symbol "~3.1.1" - next-tick "^1.0.0" - -es6-iterator@~2.0.1, es6-iterator@~2.0.3: - version "2.0.3" - resolved "https://registry.yarnpkg.com/es6-iterator/-/es6-iterator-2.0.3.tgz#a7de889141a05a94b0854403b2d0a0fbfa98f3b7" - integrity sha1-p96IkUGgWpSwhUQDstCg+/qY87c= - dependencies: - d "1" - es5-ext "^0.10.35" - es6-symbol "^3.1.1" - -es6-map@^0.1.5: - version "0.1.5" - resolved "https://registry.yarnpkg.com/es6-map/-/es6-map-0.1.5.tgz#9136e0503dcc06a301690f0bb14ff4e364e949f0" - integrity sha1-kTbgUD3MBqMBaQ8LsU/042TpSfA= - dependencies: - d "1" - es5-ext "~0.10.14" - es6-iterator "~2.0.1" - es6-set "~0.1.5" - es6-symbol "~3.1.1" - event-emitter "~0.3.5" - -es6-set@~0.1.5: - version "0.1.5" - resolved "https://registry.yarnpkg.com/es6-set/-/es6-set-0.1.5.tgz#d2b3ec5d4d800ced818db538d28974db0a73ccb1" - integrity sha1-0rPsXU2ADO2BjbU40ol02wpzzLE= - dependencies: - d "1" - es5-ext "~0.10.14" - es6-iterator "~2.0.1" - es6-symbol "3.1.1" - event-emitter "~0.3.5" - -es6-symbol@3.1.1, es6-symbol@^3.1.1, es6-symbol@~3.1.1: - version "3.1.1" - resolved "https://registry.yarnpkg.com/es6-symbol/-/es6-symbol-3.1.1.tgz#bf00ef4fdab6ba1b46ecb7b629b4c7ed5715cc77" - integrity sha1-vwDvT9q2uhtG7Le2KbTH7VcVzHc= - dependencies: - d "1" - es5-ext "~0.10.14" - -event-emitter@~0.3.5: - version "0.3.5" - resolved "https://registry.yarnpkg.com/event-emitter/-/event-emitter-0.3.5.tgz#df8c69eef1647923c7157b9ce83840610b02cc39" - integrity sha1-34xp7vFkeSPHFXuc6DhAYQsCzDk= - dependencies: - d "1" - es5-ext "~0.10.14" - -extend@^3.0.0: - version "3.0.2" - resolved "https://registry.yarnpkg.com/extend/-/extend-3.0.2.tgz#f8b1136b4071fbd8eb140aff858b1019ec2915fa" - integrity sha512-fjquC59cD7CyW6urNXK0FBufkZcoiGG80wTuPujX590cB5Ttln20E2UB4S/WARVqhXffZl2LNgS+gQdPIIim/g== - -fs.realpath@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/fs.realpath/-/fs.realpath-1.0.0.tgz#1504ad2523158caa40db4a2787cb01411994ea4f" - integrity sha1-FQStJSMVjKpA20onh8sBQRmU6k8= - -glob-parent@^3.1.0: - version "3.1.0" - resolved "https://registry.yarnpkg.com/glob-parent/-/glob-parent-3.1.0.tgz#9e6af6299d8d3bd2bd40430832bd113df906c5ae" - integrity sha1-nmr2KZ2NO9K9QEMIMr0RPfkGxa4= - dependencies: - is-glob "^3.1.0" - path-dirname "^1.0.0" - -glob-stream@^6.1.0: - version "6.1.0" - resolved "https://registry.yarnpkg.com/glob-stream/-/glob-stream-6.1.0.tgz#7045c99413b3eb94888d83ab46d0b404cc7bdde4" - integrity sha1-cEXJlBOz65SIjYOrRtC0BMx73eQ= - dependencies: - extend "^3.0.0" - glob "^7.1.1" - glob-parent "^3.1.0" - is-negated-glob "^1.0.0" - ordered-read-streams "^1.0.0" - pumpify "^1.3.5" - readable-stream "^2.1.5" - remove-trailing-separator "^1.0.1" - to-absolute-glob "^2.0.0" - unique-stream "^2.0.2" - -glob@^7.1.1: - version "7.1.4" - resolved "https://registry.yarnpkg.com/glob/-/glob-7.1.4.tgz#aa608a2f6c577ad357e1ae5a5c26d9a8d1969255" - integrity sha512-hkLPepehmnKk41pUGm3sYxoFs/umurYfYJCerbXEyFIWcAzvpipAgVkBqqT9RBKMGjnq6kMuyYwha6csxbiM1A== - dependencies: - fs.realpath "^1.0.0" - inflight "^1.0.4" - inherits "2" - minimatch "^3.0.4" - once "^1.3.0" - path-is-absolute "^1.0.0" - -help-me@^1.0.1: +"@protobufjs/inquire@^1.1.0": version "1.1.0" - resolved "https://registry.yarnpkg.com/help-me/-/help-me-1.1.0.tgz#8f2d508d0600b4a456da2f086556e7e5c056a3c6" - integrity sha1-jy1QjQYAtKRW2i8IZVbn5cBWo8Y= - dependencies: - callback-stream "^1.0.2" - glob-stream "^6.1.0" - through2 "^2.0.1" - xtend "^4.0.0" + resolved "https://registry.yarnpkg.com/@protobufjs/inquire/-/inquire-1.1.0.tgz#ff200e3e7cf2429e2dcafc1140828e8cc638f089" + integrity sha1-/yAOPnzyQp4tyvwRQIKOjMY48Ik= -inflight@^1.0.4: - version "1.0.6" - resolved "https://registry.yarnpkg.com/inflight/-/inflight-1.0.6.tgz#49bd6331d7d02d0c09bc910a1075ba8165b56df9" - integrity sha1-Sb1jMdfQLQwJvJEKEHW6gWW1bfk= - dependencies: - once "^1.3.0" - wrappy "1" +"@protobufjs/path@^1.1.2": + version "1.1.2" + resolved "https://registry.yarnpkg.com/@protobufjs/path/-/path-1.1.2.tgz#6cc2b20c5c9ad6ad0dccfd21ca7673d8d7fbf68d" + integrity sha1-bMKyDFya1q0NzP0hynZz2Nf79o0= -inherits@2, inherits@^2.0.1, inherits@^2.0.3, inherits@~2.0.3: - version "2.0.3" - resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.3.tgz#633c2c83e3da42a502f52466022480f4208261de" - integrity sha1-Yzwsg+PaQqUC9SRmAiSA9CCCYd4= - -is-absolute@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/is-absolute/-/is-absolute-1.0.0.tgz#395e1ae84b11f26ad1795e73c17378e48a301576" - integrity sha512-dOWoqflvcydARa360Gvv18DZ/gRuHKi2NU/wU5X1ZFzdYfH29nkiNZsF3mp4OJ3H4yo9Mx8A/uAGNzpzPN3yBA== - dependencies: - is-relative "^1.0.0" - is-windows "^1.0.1" - -is-extglob@^2.1.0: - version "2.1.1" - resolved "https://registry.yarnpkg.com/is-extglob/-/is-extglob-2.1.1.tgz#a88c02535791f02ed37c76a1b9ea9773c833f8c2" - integrity sha1-qIwCU1eR8C7TfHahueqXc8gz+MI= - -is-glob@^3.1.0: - version "3.1.0" - resolved "https://registry.yarnpkg.com/is-glob/-/is-glob-3.1.0.tgz#7ba5ae24217804ac70707b96922567486cc3e84a" - integrity sha1-e6WuJCF4BKxwcHuWkiVnSGzD6Eo= - dependencies: - is-extglob "^2.1.0" - -is-negated-glob@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/is-negated-glob/-/is-negated-glob-1.0.0.tgz#6910bca5da8c95e784b5751b976cf5a10fee36d2" - integrity sha1-aRC8pdqMleeEtXUbl2z1oQ/uNtI= - -is-relative@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/is-relative/-/is-relative-1.0.0.tgz#a1bb6935ce8c5dba1e8b9754b9b2dcc020e2260d" - integrity sha512-Kw/ReK0iqwKeu0MITLFuj0jbPAmEiOsIwyIXvvbfa6QfmN9pkD1M+8pdk7Rl/dTKbH34/XBFMbgD4iMJhLQbGA== - dependencies: - is-unc-path "^1.0.0" - -is-unc-path@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/is-unc-path/-/is-unc-path-1.0.0.tgz#d731e8898ed090a12c352ad2eaed5095ad322c9d" - integrity sha512-mrGpVd0fs7WWLfVsStvgF6iEJnbjDFZh9/emhRDcGWTduTfNHd9CHeUwH3gYIjdbwo4On6hunkztwOaAw0yllQ== - dependencies: - unc-path-regex "^0.1.2" - -is-windows@^1.0.1: - version "1.0.2" - resolved "https://registry.yarnpkg.com/is-windows/-/is-windows-1.0.2.tgz#d1850eb9791ecd18e6182ce12a30f396634bb19d" - integrity sha512-eXK1UInq2bPmjyX6e3VHIzMLobc4J94i4AWn+Hpq3OU5KkrRC96OAcR3PRJ/pGu6m8TRnBHP9dkXQVsT/COVIA== - -isarray@~1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/isarray/-/isarray-1.0.0.tgz#bb935d48582cba168c06834957a54a3e07124f11" - integrity sha1-u5NdSFgsuhaMBoNJV6VKPgcSTxE= - -json-stable-stringify-without-jsonify@^1.0.1: - version "1.0.1" - resolved "https://registry.yarnpkg.com/json-stable-stringify-without-jsonify/-/json-stable-stringify-without-jsonify-1.0.1.tgz#9db7b59496ad3f3cfef30a75142d2d930ad72651" - integrity sha1-nbe1lJatPzz+8wp1FC0tkwrXJlE= - -leven@^2.1.0: - version "2.1.0" - resolved "https://registry.yarnpkg.com/leven/-/leven-2.1.0.tgz#c2e7a9f772094dee9d34202ae8acce4687875580" - integrity sha1-wuep93IJTe6dNCAq6KzORoeHVYA= - -minimatch@^3.0.4: - version "3.0.4" - resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-3.0.4.tgz#5166e286457f03306064be5497e8dbb0c3d32083" - integrity sha512-yJHVQEhyqPLUTgt9B83PXu6W3rx4MvvHvSUvToogpwoGDOUQ+yDrR0HRot+yOCdCO7u4hX3pWft6kWBBcqh0UA== - dependencies: - brace-expansion "^1.1.7" - -minimist@^1.1.0, minimist@^1.2.0: - version "1.2.0" - resolved "https://registry.yarnpkg.com/minimist/-/minimist-1.2.0.tgz#a35008b20f41383eec1fb914f4cd5df79a264284" - integrity sha1-o1AIsg9BOD7sH7kU9M1d95omQoQ= - -mqtt-packet@^6.0.0: - version "6.1.2" - resolved "https://registry.yarnpkg.com/mqtt-packet/-/mqtt-packet-6.1.2.tgz#239493d185c9209011a5a22ebce30e098c731f81" - integrity sha512-yVG5PoS3wJ8TLzfS8pQMsDVLAf/EipnBAG5XQE9X/9L0EMxuduI9J2WnlRvJT497K1CUT4VJWjoP08+CKiKt1Q== - dependencies: - bl "^1.2.2" - inherits "^2.0.3" - process-nextick-args "^2.0.0" - safe-buffer "^5.1.2" - -mqtt@^3.0.0: - version "3.0.0" - resolved "https://registry.yarnpkg.com/mqtt/-/mqtt-3.0.0.tgz#7961e5f61efba3eec37d5aa9c4cbcdeb6f841380" - integrity sha512-0nKV6MAc1ibKZwaZQUTb3iIdT4NVpj541BsYrqrGBcQdQ7Jd0MnZD1/6/nj1UFdGTboK9ZEUXvkCu2nPCugHFA== - dependencies: - base64-js "^1.3.0" - commist "^1.0.0" - concat-stream "^1.6.2" - end-of-stream "^1.4.1" - es6-map "^0.1.5" - help-me "^1.0.1" - inherits "^2.0.3" - minimist "^1.2.0" - mqtt-packet "^6.0.0" - pump "^3.0.0" - readable-stream "^2.3.6" - reinterval "^1.1.0" - split2 "^3.1.0" - websocket-stream "^5.1.2" - xtend "^4.0.1" - -next-tick@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/next-tick/-/next-tick-1.0.0.tgz#ca86d1fe8828169b0120208e3dc8424b9db8342c" - integrity sha1-yobR/ogoFpsBICCOPchCS524NCw= - -once@^1.3.0, once@^1.3.1, once@^1.4.0: - version "1.4.0" - resolved "https://registry.yarnpkg.com/once/-/once-1.4.0.tgz#583b1aa775961d4b113ac17d9c50baef9dd76bd1" - integrity sha1-WDsap3WWHUsROsF9nFC6753Xa9E= - dependencies: - wrappy "1" - -ordered-read-streams@^1.0.0: - version "1.0.1" - resolved "https://registry.yarnpkg.com/ordered-read-streams/-/ordered-read-streams-1.0.1.tgz#77c0cb37c41525d64166d990ffad7ec6a0e1363e" - integrity sha1-d8DLN8QVJdZBZtmQ/61+xqDhNj4= - dependencies: - readable-stream "^2.0.1" - -path-dirname@^1.0.0: - version "1.0.2" - resolved "https://registry.yarnpkg.com/path-dirname/-/path-dirname-1.0.2.tgz#cc33d24d525e099a5388c0336c6e32b9160609e0" - integrity sha1-zDPSTVJeCZpTiMAzbG4yuRYGCeA= - -path-is-absolute@^1.0.0: - version "1.0.1" - resolved "https://registry.yarnpkg.com/path-is-absolute/-/path-is-absolute-1.0.1.tgz#174b9268735534ffbc7ace6bf53a5a9e1b5c5f5f" - integrity sha1-F0uSaHNVNP+8es5r9TpanhtcX18= - -process-nextick-args@^2.0.0, process-nextick-args@~2.0.0: - version "2.0.0" - resolved "https://registry.yarnpkg.com/process-nextick-args/-/process-nextick-args-2.0.0.tgz#a37d732f4271b4ab1ad070d35508e8290788ffaa" - integrity sha512-MtEC1TqN0EU5nephaJ4rAtThHtC86dNN9qCuEhtshvpVBkAW5ZO7BASN9REnF9eoXGcRub+pFuKEpOHE+HbEMw== - -pump@^2.0.0: - version "2.0.1" - resolved "https://registry.yarnpkg.com/pump/-/pump-2.0.1.tgz#12399add6e4cf7526d973cbc8b5ce2e2908b3909" - integrity sha512-ruPMNRkN3MHP1cWJc9OWr+T/xDP0jhXYCLfJcBuX54hhfIBnaQmAUMfDcG4DM5UMWByBbJY69QSphm3jtDKIkA== - dependencies: - end-of-stream "^1.1.0" - once "^1.3.1" - -pump@^3.0.0: - version "3.0.0" - resolved "https://registry.yarnpkg.com/pump/-/pump-3.0.0.tgz#b4a2116815bde2f4e1ea602354e8c75565107a64" - integrity sha512-LwZy+p3SFs1Pytd/jYct4wpv49HiYCqd9Rlc5ZVdk0V+8Yzv6jR5Blk3TRmPL1ft69TxP0IMZGJ+WPFU2BFhww== - dependencies: - end-of-stream "^1.1.0" - once "^1.3.1" - -pumpify@^1.3.5: - version "1.5.1" - resolved "https://registry.yarnpkg.com/pumpify/-/pumpify-1.5.1.tgz#36513be246ab27570b1a374a5ce278bfd74370ce" - integrity sha512-oClZI37HvuUJJxSKKrC17bZ9Cu0ZYhEAGPsPUy9KlMUmv9dKX2o77RUmq7f3XjIxbwyGwYzbzQ1L2Ks8sIradQ== - dependencies: - duplexify "^3.6.0" - inherits "^2.0.3" - pump "^2.0.0" - -"readable-stream@> 1.0.0 < 3.0.0", readable-stream@^2.0.0, readable-stream@^2.0.1, readable-stream@^2.1.5, readable-stream@^2.2.2, readable-stream@^2.3.3, readable-stream@^2.3.5, readable-stream@^2.3.6, readable-stream@~2.3.6: - version "2.3.6" - resolved "https://registry.yarnpkg.com/readable-stream/-/readable-stream-2.3.6.tgz#b11c27d88b8ff1fbe070643cf94b0c79ae1b0aaf" - integrity sha512-tQtKA9WIAhBF3+VLAseyMqZeBjW0AHJoxOtYqSUZNJxauErmLbVm2FW1y+J/YA9dUrAC39ITejlZWhVIwawkKw== - dependencies: - core-util-is "~1.0.0" - inherits "~2.0.3" - isarray "~1.0.0" - process-nextick-args "~2.0.0" - safe-buffer "~5.1.1" - string_decoder "~1.1.1" - util-deprecate "~1.0.1" - -readable-stream@^3.0.0: - version "3.4.0" - resolved "https://registry.yarnpkg.com/readable-stream/-/readable-stream-3.4.0.tgz#a51c26754658e0a3c21dbf59163bd45ba6f447fc" - integrity sha512-jItXPLmrSR8jmTRmRWJXCnGJsfy85mB3Wd/uINMXA65yrnFo0cPClFIUWzo2najVNSl+mx7/4W8ttlLWJe99pQ== - dependencies: - inherits "^2.0.3" - string_decoder "^1.1.1" - util-deprecate "^1.0.1" - -reinterval@^1.1.0: +"@protobufjs/pool@^1.1.0": version "1.1.0" - resolved "https://registry.yarnpkg.com/reinterval/-/reinterval-1.1.0.tgz#3361ecfa3ca6c18283380dd0bb9546f390f5ece7" - integrity sha1-M2Hs+jymwYKDOA3Qu5VG85D17Oc= + resolved "https://registry.yarnpkg.com/@protobufjs/pool/-/pool-1.1.0.tgz#09fd15f2d6d3abfa9b65bc366506d6ad7846ff54" + integrity sha1-Cf0V8tbTq/qbZbw2ZQbWrXhG/1Q= -remove-trailing-separator@^1.0.1: +"@protobufjs/utf8@^1.1.0": version "1.1.0" - resolved "https://registry.yarnpkg.com/remove-trailing-separator/-/remove-trailing-separator-1.1.0.tgz#c24bce2a283adad5bc3f58e0d48249b92379d8ef" - integrity sha1-wkvOKig62tW8P1jg1IJJuSN52O8= + resolved "https://registry.yarnpkg.com/@protobufjs/utf8/-/utf8-1.1.0.tgz#a777360b5b39a1a2e5106f8e858f2fd2d060c570" + integrity sha1-p3c2C1s5oaLlEG+OhY8v0tBgxXA= -safe-buffer@^5.1.1, safe-buffer@^5.1.2, safe-buffer@~5.1.0, safe-buffer@~5.1.1: - version "5.1.2" - resolved "https://registry.yarnpkg.com/safe-buffer/-/safe-buffer-5.1.2.tgz#991ec69d296e0313747d59bdfd2b745c35f8828d" - integrity sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g== - -split2@^3.1.0: - version "3.1.1" - resolved "https://registry.yarnpkg.com/split2/-/split2-3.1.1.tgz#c51f18f3e06a8c4469aaab487687d8d956160bb6" - integrity sha512-emNzr1s7ruq4N+1993yht631/JH+jaj0NYBosuKmLcq+JkGQ9MmTw1RB1fGaTCzUuseRIClrlSLHRNYGwWQ58Q== - dependencies: - readable-stream "^3.0.0" - -stream-shift@^1.0.0: - version "1.0.0" - resolved "https://registry.yarnpkg.com/stream-shift/-/stream-shift-1.0.0.tgz#d5c752825e5367e786f78e18e445ea223a155952" - integrity sha1-1cdSgl5TZ+eG944Y5EXqIjoVWVI= - -string_decoder@^1.1.1: - version "1.2.0" - resolved "https://registry.yarnpkg.com/string_decoder/-/string_decoder-1.2.0.tgz#fe86e738b19544afe70469243b2a1ee9240eae8d" - integrity sha512-6YqyX6ZWEYguAxgZzHGL7SsCeGx3V2TtOTqZz1xSTSWnqsbWwbptafNyvf/ACquZUXV3DANr5BDIwNYe1mN42w== - dependencies: - safe-buffer "~5.1.0" - -string_decoder@~1.1.1: - version "1.1.1" - resolved "https://registry.yarnpkg.com/string_decoder/-/string_decoder-1.1.1.tgz#9cf1611ba62685d7030ae9e4ba34149c3af03fc8" - integrity sha512-n/ShnvDi6FHbbVfviro+WojiFzv+s8MPMHBczVePfUpDJLwoLT0ht1l4YwBCbi8pJAveEEdnkHyPyTP/mzRfwg== - dependencies: - safe-buffer "~5.1.0" - -through2-filter@^3.0.0: - version "3.0.0" - resolved "https://registry.yarnpkg.com/through2-filter/-/through2-filter-3.0.0.tgz#700e786df2367c2c88cd8aa5be4cf9c1e7831254" - integrity sha512-jaRjI2WxN3W1V8/FMZ9HKIBXixtiqs3SQSX4/YGIiP3gL6djW48VoZq9tDqeCWs3MT8YY5wb/zli8VW8snY1CA== - dependencies: - through2 "~2.0.0" - xtend "~4.0.0" - -through2@^2.0.1, through2@~2.0.0: - version "2.0.5" - resolved "https://registry.yarnpkg.com/through2/-/through2-2.0.5.tgz#01c1e39eb31d07cb7d03a96a70823260b23132cd" - integrity sha512-/mrRod8xqpA+IHSLyGCQ2s8SPHiCDEeQJSep1jqLYeEUClOFG2Qsh+4FU6G9VeqpZnGW/Su8LQGc4YKni5rYSQ== - dependencies: - readable-stream "~2.3.6" - xtend "~4.0.1" - -to-absolute-glob@^2.0.0: - version "2.0.2" - resolved "https://registry.yarnpkg.com/to-absolute-glob/-/to-absolute-glob-2.0.2.tgz#1865f43d9e74b0822db9f145b78cff7d0f7c849b" - integrity sha1-GGX0PZ50sIItufFFt4z/fQ98hJs= - dependencies: - is-absolute "^1.0.0" - is-negated-glob "^1.0.0" - -type@^1.0.1: - version "1.0.1" - resolved "https://registry.yarnpkg.com/type/-/type-1.0.1.tgz#084c9a17fcc9151a2cdb1459905c2e45e4bb7d61" - integrity sha512-MAM5dBMJCJNKs9E7JXo4CXRAansRfG0nlJxW7Wf6GZzSOvH31zClSaHdIMWLehe/EGMBkqeC55rrkaOr5Oo7Nw== - -typedarray@^0.0.6: - version "0.0.6" - resolved "https://registry.yarnpkg.com/typedarray/-/typedarray-0.0.6.tgz#867ac74e3864187b1d3d47d996a78ec5c8830777" - integrity sha1-hnrHTjhkGHsdPUfZlqeOxciDB3c= - -ultron@~1.1.0: - version "1.1.1" - resolved "https://registry.yarnpkg.com/ultron/-/ultron-1.1.1.tgz#9fe1536a10a664a65266a1e3ccf85fd36302bc9c" - integrity sha512-UIEXBNeYmKptWH6z8ZnqTeS8fV74zG0/eRU9VGkpzz+LIJNs8W/zM/L+7ctCkRrgbNnnR0xxw4bKOr0cW0N0Og== - -unc-path-regex@^0.1.2: - version "0.1.2" - resolved "https://registry.yarnpkg.com/unc-path-regex/-/unc-path-regex-0.1.2.tgz#e73dd3d7b0d7c5ed86fbac6b0ae7d8c6a69d50fa" - integrity sha1-5z3T17DXxe2G+6xrCufYxqadUPo= - -unique-stream@^2.0.2: - version "2.3.1" - resolved "https://registry.yarnpkg.com/unique-stream/-/unique-stream-2.3.1.tgz#c65d110e9a4adf9a6c5948b28053d9a8d04cbeac" - integrity sha512-2nY4TnBE70yoxHkDli7DMazpWiP7xMdCYqU2nBRO0UB+ZpEkGsSija7MvmvnZFUeC+mrgiUfcHSr3LmRFIg4+A== - dependencies: - json-stable-stringify-without-jsonify "^1.0.1" - through2-filter "^3.0.0" - -util-deprecate@^1.0.1, util-deprecate@~1.0.1: - version "1.0.2" - resolved "https://registry.yarnpkg.com/util-deprecate/-/util-deprecate-1.0.2.tgz#450d4dc9fa70de732762fbd2d4a28981419a0ccf" - integrity sha1-RQ1Nyfpw3nMnYvvS1KKJgUGaDM8= - -websocket-stream@^5.1.2: - version "5.5.0" - resolved "https://registry.yarnpkg.com/websocket-stream/-/websocket-stream-5.5.0.tgz#9827f2846fc0d2b4dca7aab8f92980b2548b868e" - integrity sha512-EXy/zXb9kNHI07TIMz1oIUIrPZxQRA8aeJ5XYg5ihV8K4kD1DuA+FY6R96HfdIHzlSzS8HiISAfrm+vVQkZBug== - dependencies: - duplexify "^3.5.1" - inherits "^2.0.1" - readable-stream "^2.3.3" - safe-buffer "^5.1.2" - ws "^3.2.0" - xtend "^4.0.0" - -wrappy@1: - version "1.0.2" - resolved "https://registry.yarnpkg.com/wrappy/-/wrappy-1.0.2.tgz#b5243d8f3ec1aa35f1364605bc0d1036e30ab69f" - integrity sha1-tSQ9jz7BqjXxNkYFvA0QNuMKtp8= - -ws@^3.2.0: - version "3.3.3" - resolved "https://registry.yarnpkg.com/ws/-/ws-3.3.3.tgz#f1cf84fe2d5e901ebce94efaece785f187a228f2" - integrity sha512-nnWLa/NwZSt4KQJu51MYlCcSQ5g7INpOrOMt4XV8j4dqTXdmlUmSHQ8/oLC069ckre0fRsgfvsKwbTdtKLCDkA== - dependencies: - async-limiter "~1.0.0" - safe-buffer "~5.1.0" - ultron "~1.1.0" - -xtend@^4.0.0, xtend@^4.0.1, xtend@~4.0.0, xtend@~4.0.1: +"@types/long@^4.0.1": version "4.0.1" - resolved "https://registry.yarnpkg.com/xtend/-/xtend-4.0.1.tgz#a5c6d532be656e23db820efb943a1f04998d63af" - integrity sha1-pcbVMr5lbiPbgg77lDofBJmNY68= + resolved "https://registry.yarnpkg.com/@types/long/-/long-4.0.1.tgz#459c65fa1867dafe6a8f322c4c51695663cc55e9" + integrity sha512-5tXH6Bx/kNGd3MgffdmP4dy2Z+G4eaXw0SE81Tq3BNadtnMR5/ySMzX4SLEzHJzSmPNn4HIdpQsBvXMUykr58w== + +"@types/node@>=13.7.0": + version "16.4.13" + resolved "https://registry.yarnpkg.com/@types/node/-/node-16.4.13.tgz#7dfd9c14661edc65cccd43a29eb454174642370d" + integrity sha512-bLL69sKtd25w7p1nvg9pigE4gtKVpGTPojBFLMkGHXuUgap2sLqQt2qUnqmVCDfzGUL0DRNZP+1prIZJbMeAXg== + +long@^4.0.0: + version "4.0.0" + resolved "https://registry.yarnpkg.com/long/-/long-4.0.0.tgz#9a7b71cfb7d361a194ea555241c92f7468d5bf28" + integrity sha512-XsP+KhQif4bjX1kbuSiySJFNAehNxgLb6hPRGJ9QsUr8ajHkuXGdrHmFUTUUXhDwVX2R5bY4JNZEwbUiMhV+MA== + +protobufjs@^6.11.2: + version "6.11.2" + resolved "https://registry.yarnpkg.com/protobufjs/-/protobufjs-6.11.2.tgz#de39fabd4ed32beaa08e9bb1e30d08544c1edf8b" + integrity sha512-4BQJoPooKJl2G9j3XftkIXjoC9C0Av2NOrWmbLWT1vH32GcSUHjM0Arra6UfTsVyfMAuFzaLucXn1sadxJydAw== + dependencies: + "@protobufjs/aspromise" "^1.1.2" + "@protobufjs/base64" "^1.1.2" + "@protobufjs/codegen" "^2.0.4" + "@protobufjs/eventemitter" "^1.1.0" + "@protobufjs/fetch" "^1.1.0" + "@protobufjs/float" "^1.0.2" + "@protobufjs/inquire" "^1.1.0" + "@protobufjs/path" "^1.1.2" + "@protobufjs/pool" "^1.1.0" + "@protobufjs/utf8" "^1.1.0" + "@types/long" "^4.0.1" + "@types/node" ">=13.7.0" + long "^4.0.0"