elarian - npm Package Compare versions

Comparing version 0.2.5 to 0.2.6

lib/index.web.js

 /* global window */
-const { RSocketResumableTransport } = require('rsocket-core');
+const { RSocketResumableTransport, BufferEncoders } = require('rsocket-core');
 const RSocketWebSocketClient = require('rsocket-websocket-client').default;
@@ -27,10 +27,16 @@
         sessionDurationSeconds = 60,
-    }) => new RSocketResumableTransport(
-        () => new RSocketWebSocketClient({ url: `wss://${HOST}:${PORT}` }),
-        {
-            bufferSize,
-            resumeToken,
-            sessionDurationSeconds,
-        },
-    ),
+    }) => {
+        if (resumeToken) {
+            return new RSocketResumableTransport(
+                () => new RSocketWebSocketClient({ url: `wss://${HOST}:${PORT}` }, BufferEncoders),
+                {
+                    bufferSize,
+                    resumeToken,
+                    sessionDurationSeconds,
+                },
+                BufferEncoders,
+            );
+        }
+        return new RSocketWebSocketClient({ url: `wss://${HOST}:${PORT}` }, BufferEncoders);
+    },
 });
@@ -37,0 +43,0 @@

lib/utils/index.js

 const { RSocketClient } = require('rsocket-core');
-const { Duration } = require('google-protobuf/google/protobuf/duration_pb.js');
-const { Timestamp } = require('google-protobuf/google/protobuf/timestamp_pb.js');
-const { StringValue, Int32Value } = require('google-protobuf/google/protobuf/wrappers_pb.js');
+const { Duration } = require('google-protobuf/google/protobuf/duration_pb');
+const { Timestamp } = require('google-protobuf/google/protobuf/timestamp_pb');
+const { StringValue, Int32Value } = require('google-protobuf/google/protobuf/wrappers_pb');
 
@@ -529,3 +529,3 @@ const appSocket = require('./service/app_socket_pb');
 
-    const { log, getTransport } = platform;
+    const { log, getTransport, isBrowser } = platform;
 
@@ -540,3 +540,3 @@ if (!notificationHandler && allowNotifications) {
         .setSimulatorMode(isSimulator)
-        .setSimplexMode(isSimulator ? true : !allowNotifications);
+        .setSimplexMode((isSimulator || isBrowser) ? true : !allowNotifications);
     if (authToken) {
@@ -543,0 +543,0 @@ data = data.setAuthToken(new StringValue().setValue(authToken));

lib/utils/service/common_model_pb.js

@@ -31,2 +31,4 @@ // source: common_model.proto
 goog.exportSymbol('proto.com.elarian.hera.proto.MediaType', null, global);
+goog.exportSymbol('proto.com.elarian.hera.proto.Memory', null, global);
+goog.exportSymbol('proto.com.elarian.hera.proto.MemoryUnit', null, global);
 /**
@@ -42,2 +44,23 @@ * Generated by JsPbCodeGenerator.
  */
+proto.com.elarian.hera.proto.Memory = function(opt_data) {
+  jspb.Message.initialize(this, opt_data, 0, -1, null, null);
+};
+goog.inherits(proto.com.elarian.hera.proto.Memory, jspb.Message);
+if (goog.DEBUG && !COMPILED) {
+  /**
+   * @public
+   * @override
+   */
+  proto.com.elarian.hera.proto.Memory.displayName = 'proto.com.elarian.hera.proto.Memory';
+}
+/**
+ * Generated by JsPbCodeGenerator.
+ * @param {Array=} opt_data Optional initial data array, typically from a
+ * server response, or constructed directly in Javascript. The array is used
+ * in place and becomes part of the constructed object. It is not cloned.
+ * If no data is provided, the constructed object will be empty, but still
+ * valid.
+ * @extends {jspb.Message}
+ * @constructor
+ */
 proto.com.elarian.hera.proto.DataMapValue = function(opt_data) {
@@ -160,3 +183,163 @@ jspb.Message.initialize(this, opt_data, 0, -1, null, proto.com.elarian.hera.proto.DataMapValue.oneofGroups_);
 
+
+
+if (jspb.Message.GENERATE_TO_OBJECT) {
 /**
+ * Creates an object representation of this proto.
+ * Field names that are reserved in JavaScript and will be renamed to pb_name.
+ * Optional fields that are not set will be set to undefined.
+ * To access a reserved field use, foo.pb_<name>, eg, foo.pb_default.
+ * For the list of reserved names please see:
+ *     net/proto2/compiler/js/internal/generator.cc#kKeyword.
+ * @param {boolean=} opt_includeInstance Deprecated. whether to include the
+ *     JSPB instance for transitional soy proto support:
+ *     http://goto/soy-param-migration
+ * @return {!Object}
+ */
+proto.com.elarian.hera.proto.Memory.prototype.toObject = function(opt_includeInstance) {
+  return proto.com.elarian.hera.proto.Memory.toObject(opt_includeInstance, this);
+};
+
+
+/**
+ * Static version of the {@see toObject} method.
+ * @param {boolean|undefined} includeInstance Deprecated. Whether to include
+ *     the JSPB instance for transitional soy proto support:
+ *     http://goto/soy-param-migration
+ * @param {!proto.com.elarian.hera.proto.Memory} msg The msg instance to transform.
+ * @return {!Object}
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.com.elarian.hera.proto.Memory.toObject = function(includeInstance, msg) {
+  var f, obj = {
+    unit: jspb.Message.getFieldWithDefault(msg, 1, 0),
+    value: jspb.Message.getFloatingPointFieldWithDefault(msg, 2, 0.0)
+  };
+
+  if (includeInstance) {
+    obj.$jspbMessageInstance = msg;
+  }
+  return obj;
+};
+}
+
+
+/**
+ * Deserializes binary data (in protobuf wire format).
+ * @param {jspb.ByteSource} bytes The bytes to deserialize.
+ * @return {!proto.com.elarian.hera.proto.Memory}
+ */
+proto.com.elarian.hera.proto.Memory.deserializeBinary = function(bytes) {
+  var reader = new jspb.BinaryReader(bytes);
+  var msg = new proto.com.elarian.hera.proto.Memory;
+  return proto.com.elarian.hera.proto.Memory.deserializeBinaryFromReader(msg, reader);
+};
+
+
+/**
+ * Deserializes binary data (in protobuf wire format) from the
+ * given reader into the given message object.
+ * @param {!proto.com.elarian.hera.proto.Memory} msg The message object to deserialize into.
+ * @param {!jspb.BinaryReader} reader The BinaryReader to use.
+ * @return {!proto.com.elarian.hera.proto.Memory}
+ */
+proto.com.elarian.hera.proto.Memory.deserializeBinaryFromReader = function(msg, reader) {
+  while (reader.nextField()) {
+    if (reader.isEndGroup()) {
+      break;
+    }
+    var field = reader.getFieldNumber();
+    switch (field) {
+    case 1:
+      var value = /** @type {!proto.com.elarian.hera.proto.MemoryUnit} */ (reader.readEnum());
+      msg.setUnit(value);
+      break;
+    case 2:
+      var value = /** @type {number} */ (reader.readDouble());
+      msg.setValue(value);
+      break;
+    default:
+      reader.skipField();
+      break;
+    }
+  }
+  return msg;
+};
+
+
+/**
+ * Serializes the message to binary data (in protobuf wire format).
+ * @return {!Uint8Array}
+ */
+proto.com.elarian.hera.proto.Memory.prototype.serializeBinary = function() {
+  var writer = new jspb.BinaryWriter();
+  proto.com.elarian.hera.proto.Memory.serializeBinaryToWriter(this, writer);
+  return writer.getResultBuffer();
+};
+
+
+/**
+ * Serializes the given message to binary data (in protobuf wire
+ * format), writing to the given BinaryWriter.
+ * @param {!proto.com.elarian.hera.proto.Memory} message
+ * @param {!jspb.BinaryWriter} writer
+ * @suppress {unusedLocalVariables} f is only used for nested messages
+ */
+proto.com.elarian.hera.proto.Memory.serializeBinaryToWriter = function(message, writer) {
+  var f = undefined;
+  f = message.getUnit();
+  if (f !== 0.0) {
+    writer.writeEnum(
+      1,
+      f
+    );
+  }
+  f = message.getValue();
+  if (f !== 0.0) {
+    writer.writeDouble(
+      2,
+      f
+    );
+  }
+};
+
+
+/**
+ * optional MemoryUnit unit = 1;
+ * @return {!proto.com.elarian.hera.proto.MemoryUnit}
+ */
+proto.com.elarian.hera.proto.Memory.prototype.getUnit = function() {
+  return /** @type {!proto.com.elarian.hera.proto.MemoryUnit} */ (jspb.Message.getFieldWithDefault(this, 1, 0));
+};
+
+
+/**
+ * @param {!proto.com.elarian.hera.proto.MemoryUnit} value
+ * @return {!proto.com.elarian.hera.proto.Memory} returns this
+ */
+proto.com.elarian.hera.proto.Memory.prototype.setUnit = function(value) {
+  return jspb.Message.setProto3EnumField(this, 1, value);
+};
+
+
+/**
+ * optional double value = 2;
+ * @return {number}
+ */
+proto.com.elarian.hera.proto.Memory.prototype.getValue = function() {
+  return /** @type {number} */ (jspb.Message.getFloatingPointFieldWithDefault(this, 2, 0.0));
+};
+
+
+/**
+ * @param {number} value
+ * @return {!proto.com.elarian.hera.proto.Memory} returns this
+ */
+proto.com.elarian.hera.proto.Memory.prototype.setValue = function(value) {
+  return jspb.Message.setProto3FloatField(this, 2, value);
+};
+
+
+
+/**
  * Oneof group definitions for this message. Each group defines the field
@@ -1480,2 +1663,13 @@ * numbers belonging to that group. When of these fields' value is set, all
 
+/**
+ * @enum {number}
+ */
+proto.com.elarian.hera.proto.MemoryUnit = {
+  MEMORY_UNIT_UNSPECIFIED: 0,
+  MEMORY_UNIT_BYTES: 1,
+  MEMORY_UNIT_KILOBYTES: 2,
+  MEMORY_UNIT_MEGABYTES: 3,
+  MEMORY_UNIT_GIGABYTES: 4
+};
+
 goog.object.extend(exports, proto.com.elarian.hera.proto);

package.json

 {
   "name": "elarian",
-  "version": "0.2.5",
+  "version": "0.2.6",
   "description": "Elarian JavaScript SDK",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -108,1 +108,5 @@ # Elarian
 If you find a bug, please file an issue on [our issue tracker on GitHub](https://github.com/ElarianLtd/javascript-sdk/issues).
+
+## Known Issues
+
+- `resumable` connection options prevents app from connecting

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

9884878

increased by0.1%

Number of lines in readme file

112

increased by3.7%

Worsened metrics

Number of package files

99

decreased by-1%

Lines of code

172250

decreased by-0.03%

No dependency changes