Source: client/parser/well-known-parsers.js

  1. /*
  2.  * Copyright 2023, TeamDev. All rights reserved.
  3.  *
  4.  * Licensed under the Apache License, Version 2.0 (the "License");
  5.  * you may not use this file except in compliance with the License.
  6.  * You may obtain a copy of the License at
  7.  *
  8.  * http://www.apache.org/licenses/LICENSE-2.0
  9.  *
  10.  * Redistribution and use in source and/or binary forms, with or without
  11.  * modification, must retain the above copyright notice and the following
  12.  * disclaimer.
  13.  *
  14.  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  15.  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  16.  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  17.  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  18.  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  19.  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  20.  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  21.  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  22.  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  23.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  24.  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  25.  */
  27. "use strict";
  29. import TypeParsers from './type-parsers';
  30. import ObjectParser from './object-parser';
  32. import wrappers from 'google-protobuf/google/protobuf/wrappers_pb';
  33. import struct from 'google-protobuf/google/protobuf/struct_pb';
  34. import {Empty} from 'google-protobuf/google/protobuf/empty_pb';
  35. import {Timestamp} from 'google-protobuf/google/protobuf/timestamp_pb';
  36. import {Duration} from 'google-protobuf/google/protobuf/duration_pb';
  37. import {FieldMask} from 'google-protobuf/google/protobuf/field_mask_pb';
  38. import {Any} from 'google-protobuf/google/protobuf/any_pb';
  40. /**
  41.  * The parsers for standard Protobuf types.
  42.  *
  43.  * <p>For the details about how the parsers should work,
  44.  * see {@link https://developers.google.com/protocol-buffers/docs/proto3#json Protobuf documentation}.
  45.  */
  47. class BoolValueParser extends ObjectParser {
  49.   fromObject(object) {
  50.     let boolValue = new wrappers.BoolValue();
  51.     boolValue.setValue(object);
  52.     return boolValue;
  53.   }
  54. }
  56. class BytesValueParser extends ObjectParser {
  58.   fromObject(object) {
  59.     let bytesValue = new wrappers.BytesValue();
  60.     bytesValue.setValue(object);
  61.     return bytesValue;
  62.   }
  63. }
  65. class DoubleValueParser extends ObjectParser {
  67.   fromObject(object) {
  68.     let doubleValue = new wrappers.DoubleValue();
  69.     doubleValue.setValue(object);
  70.     return doubleValue;
  71.   }
  72. }
  74. class FloatValueParser extends ObjectParser {
  76.   fromObject(object) {
  77.     let floatValue = new wrappers.FloatValue();
  78.     floatValue.setValue(object);
  79.     return floatValue;
  80.   }
  81. }
  83. class Int32ValueParser extends ObjectParser {
  85.   fromObject(object) {
  86.     let int32Value = new wrappers.Int32Value();
  87.     int32Value.setValue(object);
  88.     return int32Value;
  89.   }
  90. }
  92. class Int64ValueParser extends ObjectParser {
  94.   fromObject(object) {
  95.     let int64Value = new wrappers.Int64Value();
  96.     int64Value.setValue(object);
  97.     return int64Value;
  98.   }
  99. }
  101. class StringValueParser extends ObjectParser {
  103.   fromObject(object) {
  104.     let stringValue = new wrappers.StringValue();
  105.     stringValue.setValue(object);
  106.     return stringValue;
  107.   }
  108. }
  110. class UInt32ValueParser extends ObjectParser {
  112.   fromObject(object) {
  113.     let uInt32Value = new wrappers.UInt32Value();
  114.     uInt32Value.setValue(object);
  115.     return uInt32Value;
  116.   }
  117. }
  119. class UInt64ValueParser extends ObjectParser {
  121.   fromObject(object) {
  122.     let uInt64Value = new wrappers.UInt64Value();
  123.     uInt64Value.setValue(object);
  124.     return uInt64Value;
  125.   }
  126. }
  128. class ListValueParser extends ObjectParser {
  130.   fromObject(object) {
  131.     let listValue = new struct.ListValue;
  132.     object.forEach(
  133.       function callback(currentValue, index, array) {
  134.         let valueParser = new ValueParser();
  135.         array[index] = valueParser.fromObject(currentValue);
  136.       }
  137.     );
  138.     listValue.setValuesList(object);
  139.     return listValue;
  140.   }
  141. }
  143. class StructParser extends ObjectParser {
  145.   fromObject(object) {
  146.     let result = new struct.Struct();
  147.     let values = new ValueParser();
  148.     for (let fieldName in object) {
  149.       result.getFieldsMap().set(fieldName, values.fromObject(object[fieldName]));
  150.     }
  151.     return result;
  152.   }
  153. }
  155. class ValueParser extends ObjectParser {
  157.   fromObject(object) {
  158.     let result = new struct.Value();
  159.     if (object === null) {
  160.       result.setNullValue(struct.NullValue.NULL_VALUE);
  161.     } else if (typeof object === "number") {
  162.       result.setNumberValue(object);
  163.     } else if (typeof object === "string") {
  164.       result.setStringValue(object);
  165.     } else if (typeof object === "boolean") {
  166.       result.setBoolValue(object);
  167.     } else if (Array.isArray(object)) {
  168.       let parser = new ListValueParser(object);
  169.       let listValue = parser.fromObject(object);
  170.       result.setListValue(listValue);
  171.     } else {
  172.       let parser = new StructParser(object);
  173.       let structValue = parser.fromObject(object);
  174.       result.setStructValue(structValue);
  175.     }
  176.     return result;
  177.   }
  178. }
  180. class EmptyParser extends ObjectParser {
  182.   fromObject(object) {
  183.     let emptyValue = new Empty();
  184.     return emptyValue;
  185.   }
  186. }
  188. class TimestampParser extends ObjectParser {
  190.   fromObject(object) {
  191.     let date = new Date(object);
  192.     let result = new Timestamp();
  193.     result.fromDate(date);
  194.     return result;
  195.   }
  196. }
  198. class DurationParser extends ObjectParser {
  200.   fromObject(object) {
  201.     object = object.substring(0, object.length - 1);
  202.     let values = object.split(".");
  203.     let result = new Duration();
  204.     if (values.length === 1) {
  205.       result.setSeconds(values[0]);
  206.     } else if (values.length === 2) {
  207.       result.setSeconds(values[0]);
  208.       let nanos = values[1];
  209.       for (let i = 0; i < 9 - nanos.length; i++) {
  210.         nanos += "0";
  211.       }
  212.       let nanosNumber = parseInt(nanos, 10);
  213.       result.setNanos(nanosNumber);
  214.     }
  215.     return result;
  216.   }
  217. }
  219. class FieldMaskParser extends ObjectParser {
  221.   fromObject(object) {
  222.     let fieldMask = new FieldMask();
  223.     fieldMask.setPathsList(object.split(","));
  224.     return fieldMask;
  225.   }
  226. }
  228. class AnyParser extends ObjectParser {
  230.   fromObject(object) {
  231.     const typeUrl = object["@type"];
  232.     const isWellKnown = wellKnownParsers.has(typeUrl);
  233.     const packedValue = isWellKnown
  234.       ? object["value"]
  235.       : object;
  236.     const parser = TypeParsers.parserFor(typeUrl);
  237.     const messageValue = parser.fromObject(packedValue);
  238.     const bytes = messageValue.serializeBinary();
  239.     const anyMsg = new Any();
  240.     anyMsg.setTypeUrl(typeUrl);
  241.     anyMsg.setValue(bytes);
  242.     return anyMsg;
  243.   }
  244. }
  246. /**
  247.  * The map of parsers for standard Protobuf types.
  248.  *
  249.  * @type {Map<string, ObjectParser>}
  250.  */
  251. export const wellKnownParsers = new Map([
  252.   ['type.googleapis.com/google.protobuf.BoolValue', new BoolValueParser()],
  253.   ['type.googleapis.com/google.protobuf.BytesValue', new BytesValueParser()],
  254.   ['type.googleapis.com/google.protobuf.DoubleValue', new DoubleValueParser()],
  255.   ['type.googleapis.com/google.protobuf.FloatValue', new FloatValueParser()],
  256.   ['type.googleapis.com/google.protobuf.StringValue', new StringValueParser()],
  257.   ['type.googleapis.com/google.protobuf.Int32Value', new Int32ValueParser()],
  258.   ['type.googleapis.com/google.protobuf.Int64Value', new Int64ValueParser()],
  259.   ['type.googleapis.com/google.protobuf.UInt32Value', new UInt32ValueParser()],
  260.   ['type.googleapis.com/google.protobuf.UInt64Value', new UInt64ValueParser()],
  261.   ['type.googleapis.com/google.protobuf.Struct', new StructParser()],
  262.   ['type.googleapis.com/google.protobuf.Value', new ValueParser()],
  263.   ['type.googleapis.com/google.protobuf.ListValue', new ListValueParser()],
  264.   ['type.googleapis.com/google.protobuf.Empty', new EmptyParser()],
  265.   ['type.googleapis.com/google.protobuf.Timestamp', new TimestampParser()],
  266.   ['type.googleapis.com/google.protobuf.Duration', new DurationParser()],
  267.   ['type.googleapis.com/google.protobuf.FieldMask', new FieldMaskParser()],
  268.   ['type.googleapis.com/google.protobuf.Any', new AnyParser()]
  269. ]);