@foxglove/rtps - npm Package Compare versions

Comparing version 1.4.0 to 1.4.1

dist/common/DurabilityService.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.DurabilityService = void 0;
+const _1 = require(".");
 class DurabilityService {
@@ -14,3 +15,3 @@ constructor(leaseDuration, historyKind, historyDepth, maxSamples, maxInstances, maxSamplesPerInstance) {
     static fromCDR(reader) {
-        const leaseDuration = { sec: reader.int32(), nsec: reader.uint32() };
+        const leaseDuration = { sec: reader.int32(), nsec: (0, _1.fractionToNanoseconds)(reader.uint32()) };
         const historyKind = reader.uint32();
@@ -17,0 +18,0 @@ const historyDepth = reader.int32();

dist/common/index.d.ts

@@ -14,3 +14,4 @@ export * from "./DurabilityService";
 export * from "./SequenceNumberSet";
+export * from "./time";
 export * from "./types";
 //# sourceMappingURL=index.d.ts.map

dist/common/index.js

@@ -26,3 +26,4 @@ "use strict";
 __exportStar(require("./SequenceNumberSet"), exports);
+__exportStar(require("./time"), exports);
 __exportStar(require("./types"), exports);
 //# sourceMappingURL=index.js.map

dist/messaging/MessageView.test.js

@@ -45,3 +45,3 @@ "use strict";
         expect(infoTs.octetsToNextHeader).toEqual(8);
-        expect(infoTs.timestamp).toEqual({ sec: 1625943731, nsec: 1222751420 });
+        expect(infoTs.timestamp).toEqual({ sec: 1625943731, nsec: 284694000 });
         const dataMsg = subMessages[1];
@@ -64,3 +64,3 @@ expect(dataMsg instanceof submessages_1.DataMsgView).toEqual(true);
         expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 228));
-        expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 1222751420 });
+        expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 284694000 });
         let params = ParametersView_1.ParametersView.FromCdr(dataMsg.serializedData);
@@ -156,3 +156,3 @@ expect(params).toBeDefined();
             kind: common_1.Reliability.Reliable,
-            maxBlockingTime: { nsec: 4294967295, sec: 2147483647 },
+            maxBlockingTime: { nsec: 999999999, sec: 2147483647 },
         });
@@ -159,0 +159,0 @@ expect(allParams.get(common_1.ParameterId.PID_LIFESPAN)).toEqual({ sec: 10, nsec: 0 });

dist/messaging/Parameters.js

@@ -37,3 +37,3 @@ "use strict";
         this.writer.int32(value.maxBlockingTime.sec);
-        this.writer.uint32(value.maxBlockingTime.nsec);
+        this.writer.uint32((0, common_1.nanosecondsToFraction)(value.maxBlockingTime.nsec));
         this.writer.align(4);
@@ -86,3 +86,3 @@ }
         this.writer.int32(value.sec);
-        this.writer.uint32(value.nsec);
+        this.writer.uint32((0, common_1.nanosecondsToFraction)(value.nsec));
         this.writer.align(4);
@@ -89,0 +89,0 @@ }

dist/messaging/ParametersView.js

@@ -215,3 +215,3 @@ "use strict";
 function readTime(reader) {
-    return { sec: reader.int32(), nsec: reader.uint32() };
+    return { sec: reader.int32(), nsec: (0, common_1.fractionToNanoseconds)(reader.uint32()) };
 }
@@ -218,0 +218,0 @@ function isMultiParameter(parameterId) {

dist/messaging/submessages/InfoTs.js

@@ -16,3 +16,3 @@ "use strict";
         output.setInt32(offset + 4, this.timestamp.sec, littleEndian);
-        output.setUint32(offset + 8, this.timestamp.nsec, littleEndian);
+        output.setUint32(offset + 8, (0, common_1.nanosecondsToFraction)(this.timestamp.nsec), littleEndian);
         return 12;
@@ -25,3 +25,4 @@ }
         const sec = this.view.getInt32(this.offset + 4, this.littleEndian);
-        const nsec = this.view.getUint32(this.offset + 8, this.littleEndian);
+        const fraction = this.view.getUint32(this.offset + 8, this.littleEndian);
+        const nsec = (0, common_1.fractionToNanoseconds)(fraction);
         return { sec, nsec };
@@ -28,0 +29,0 @@ }

package.json

 {
   "name": "@foxglove/rtps",
-  "version": "1.4.0",
+  "version": "1.4.1",
   "description": "Real-Time Publish Subscribe (DDS-RTPS) protocol implementation with a pluggable transport layer. This is a subset of the complete specification optimized for ROS 2 (Robot Operating System) connections",
@@ -5,0 +5,0 @@ "license": "MIT",

src/common/DurabilityService.ts

 import { CdrReader } from "@foxglove/cdr";
 import { Time } from "@foxglove/rostime";
 
+import { fractionToNanoseconds } from ".";
 import { HistoryKind } from "./enums";
@@ -17,3 +18,3 @@
   static fromCDR(reader: CdrReader): DurabilityService {
-    const leaseDuration = { sec: reader.int32(), nsec: reader.uint32() };
+    const leaseDuration = { sec: reader.int32(), nsec: fractionToNanoseconds(reader.uint32()) };
     const historyKind = reader.uint32() as HistoryKind;
@@ -20,0 +21,0 @@ const historyDepth = reader.int32();

src/common/index.ts

@@ -14,2 +14,3 @@ export * from "./DurabilityService";
 export * from "./SequenceNumberSet";
+export * from "./time";
 export * from "./types";

src/messaging/MessageView.test.ts

@@ -58,3 +58,3 @@ import {
     expect(infoTs.octetsToNextHeader).toEqual(8);
-    expect(infoTs.timestamp).toEqual({ sec: 1625943731, nsec: 1222751420 });
+    expect(infoTs.timestamp).toEqual({ sec: 1625943731, nsec: 284694000 });
 
@@ -78,3 +78,3 @@ const dataMsg = subMessages[1]! as DataMsgView;
     expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 228));
-    expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 1222751420 });
+    expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 284694000 });
 
@@ -174,3 +174,3 @@ let params = ParametersView.FromCdr(dataMsg.serializedData)!;
       kind: Reliability.Reliable,
-      maxBlockingTime: { nsec: 4294967295, sec: 2147483647 },
+      maxBlockingTime: { nsec: 999999999, sec: 2147483647 },
     });
@@ -177,0 +177,0 @@ expect(allParams.get(ParameterId.PID_LIFESPAN)).toEqual({ sec: 10, nsec: 0 });

src/messaging/Parameters.ts

@@ -15,2 +15,3 @@ import { CdrWriter, EncapsulationKind } from "@foxglove/cdr";
   ReliabilityAndMaxBlockingTime,
+  nanosecondsToFraction,
 } from "../common";
@@ -54,3 +55,3 @@
     this.writer.int32(value.maxBlockingTime.sec);
-    this.writer.uint32(value.maxBlockingTime.nsec);
+    this.writer.uint32(nanosecondsToFraction(value.maxBlockingTime.nsec));
     this.writer.align(4);
@@ -111,3 +112,3 @@ }
     this.writer.int32(value.sec);
-    this.writer.uint32(value.nsec);
+    this.writer.uint32(nanosecondsToFraction(value.nsec));
     this.writer.align(4);
@@ -114,0 +115,0 @@ }

src/messaging/ParametersView.ts

@@ -18,2 +18,3 @@ import { CdrReader, EncapsulationKind } from "@foxglove/cdr";
   ReliabilityAndMaxBlockingTime,
+  fractionToNanoseconds,
 } from "../common";
@@ -260,3 +261,3 @@
 function readTime(reader: CdrReader): Time {
-  return { sec: reader.int32(), nsec: reader.uint32() };
+  return { sec: reader.int32(), nsec: fractionToNanoseconds(reader.uint32()) };
 }
@@ -263,0 +264,0 @@

src/messaging/submessages/InfoTs.ts

 import { Time } from "@foxglove/rostime";
 
-import { LittleEndian, SubMessageId } from "../../common";
+import {
+  fractionToNanoseconds,
+  LittleEndian,
+  nanosecondsToFraction,
+  SubMessageId,
+} from "../../common";
 import { SubMessage } from "../SubMessage";
@@ -17,3 +22,3 @@ import { SubMessageView } from "../SubMessageView";
     output.setInt32(offset + 4, this.timestamp.sec, littleEndian);
-    output.setUint32(offset + 8, this.timestamp.nsec, littleEndian);
+    output.setUint32(offset + 8, nanosecondsToFraction(this.timestamp.nsec), littleEndian);
     return 12;
@@ -26,5 +31,6 @@ }
     const sec = this.view.getInt32(this.offset + 4, this.littleEndian);
-    const nsec = this.view.getUint32(this.offset + 8, this.littleEndian);
+    const fraction = this.view.getUint32(this.offset + 8, this.littleEndian);
+    const nsec = fractionToNanoseconds(fraction);
     return { sec, nsec };
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

707364

increased by0.58%

Number of package files

385

increased by1.32%

Lines of code

10868

increased by0.69%

No dependency changes