sync with java: d3ec2c31bb8774b8cf3e07b3df4a759b277da483

Author: ml054

src/Documents/BulkInsertOperation.ts

@@ -23,7 +23,7 @@ import { CommandType } from "./Commands/CommandData";
 import { TypeUtil } from "../Utility/TypeUtil";
 import { IDisposable } from "../Types/Contracts";
 import { TypedTimeSeriesEntry } from "./Session/TimeSeries/TypedTimeSeriesEntry";
-import { ClassConstructor } from "../Types";
+import { ClassConstructor, EntityConstructor } from "../Types";
 import { TimeSeriesOperations } from "./TimeSeries/TimeSeriesOperations";
 import { TimeSeriesValuesHelper } from "./Session/TimeSeries/TimeSeriesValuesHelper";
 
@@ -397,18 +397,18 @@ export class BulkInsertOperation {
         return new BulkInsertOperation._attachmentsBulkInsertClass(this, id);
     }
 
-    public timeSeriesFor(id: string, name);
-    public timeSeriesFor<T extends object>(clazz: ClassConstructor<T>, id: string)
-    public timeSeriesFor<T extends object>(clazz: ClassConstructor<T>, id: string, name: string)
-    public timeSeriesFor<T extends object>(classOrId: ClassConstructor<T> | string, idOrName: string, name?: string) {
+    public timeSeriesFor(id: string, name): ITimeSeriesBulkInsert;
+    public timeSeriesFor<T extends object>(clazz: EntityConstructor<T>, id: string): ITypedTimeSeriesBulkInsert<T>;
+    public timeSeriesFor<T extends object>(clazz: EntityConstructor<T>, id: string, name: string): ITypedTimeSeriesBulkInsert<T>;
+    public timeSeriesFor<T extends object>(classOrId: EntityConstructor<T> | string, idOrName: string, name?: string) {
         if (TypeUtil.isString(classOrId)) {
             return this._timeSeriesFor(classOrId, idOrName);
         } else {
             return this._typedTimeSeriesFor(classOrId, idOrName, name);
         }
     }
 
-    private _typedTimeSeriesFor<T extends object>(clazz: ClassConstructor<T>, id: string, name: string = null) {
+    private _typedTimeSeriesFor<T extends object>(clazz: EntityConstructor<T>, id: string, name: string = null) {
         if (StringUtil.isNullOrEmpty(id)) {
             throwError("InvalidArgumentException", "Document id cannot be null or empty");
         }
@@ -616,7 +616,7 @@ export class BulkInsertOperation {
                         }
 
                         firstValue = false;
-                        this._operation._currentWriter.push(value.toString());
+                        this._operation._currentWriter.push((value ?? 0).toString());
                     }
 
                     if (tag) {

test/Ported/TimeSeries/TimeSeriesOperations.ts

@@ -848,7 +848,7 @@ describe("TimeSeriesOperations", function () {
         for (let i = 0; i <= 10; i++) {
             timeSeriesOp.append(
                 new AppendOperation(
-                    baseLine.add(i * 10, "minutes").toDate(), [ 72 ], "watches/fitbit"));
+                    baseLine.clone().add(i * 10, "minutes").toDate(), [ 72 ], "watches/fitbit"));
         }
 
         const timeSeriesBatch = new TimeSeriesBatchOperation(documentId, timeSeriesOp);

test/Ported/TimeSeries/TimeSeriesRawQuery.ts

@@ -96,7 +96,7 @@ select out(p) as heartRate, p.name`, RawQueryResult)
 
     it("canQueryTimeSeriesAggregation_DeclareSyntax_MultipleSeries", async () => {
         const baseLine = moment().startOf("day");
-        const baseLine2 = baseLine.add(-1, "day");
+        const baseLine2 = baseLine.clone().add(-1, "day");
 
         {
             const session = store.openSession();

test/Ported/TimeSeries/TimeSeriesSessionTest.ts

@@ -42,7 +42,7 @@ describe("TimeSeriesSessionTest", function () {
             assertThat(val.tag)
                 .isEqualTo("watches/fitbit");
             assertThat(val.timestamp.getTime())
-                .isEqualTo(baseLine.add(1, "minute").toDate().getTime());
+                .isEqualTo(baseLine.clone().add(1, "minute").toDate().getTime());
         }
     });