What if we remove all nulls?

Author: Paul Korzhyk

lib/clientStub.d.ts

@@ -2,12 +2,16 @@ import { Assigned, Mutation, Operation, Options, Payload, Request, Response, Txn
 export declare class DgraphClientStub {
     private readonly addr;
     private readonly options;
+    private readonly jsonParser;
     private legacyApi;
     private accessToken;
     private refreshToken;
     private autoRefresh;
     private autoRefreshTimer?;
-    constructor(addr?: string, legacyApi?: boolean, options?: Options);
+    constructor(addr?: string, stubConfig?: {
+        legacyApi?: boolean;
+        jsonParser?(text: string): any;
+    }, options?: Options);
     detectApiVersion(): Promise<string>;
     alter(op: Operation): Promise<Payload>;
     query(req: Request): Promise<Response>;

lib/clientStub.js

@@ -52,7 +52,8 @@ var jwt = require("jsonwebtoken");
 var errors_1 = require("./errors");
 var AUTO_REFRESH_PREFETCH_TIME = 5000;
 var DgraphClientStub = (function () {
-    function DgraphClientStub(addr, legacyApi, options) {
+    function DgraphClientStub(addr, stubConfig, options) {
+        if (stubConfig === void 0) { stubConfig = {}; }
         if (addr === undefined) {
             this.addr = "http://localhost:8080";
         }
@@ -65,7 +66,12 @@ var DgraphClientStub = (function () {
         else {
             this.options = options;
         }
-        this.legacyApi = !!legacyApi;
+        this.legacyApi = !!stubConfig.legacyApi;
+        this.jsonParser =
+            stubConfig.jsonParser !== undefined
+                ? stubConfig.jsonParser
+                :
+                    JSON.parse.bind(JSON);
     }
     DgraphClientStub.prototype.detectApiVersion = function () {
         return __awaiter(this, void 0, void 0, function () {
@@ -368,7 +374,7 @@ var DgraphClientStub = (function () {
                     case 2:
                         responseText = _a.sent();
                         try {
-                            json = JSON.parse(responseText);
+                            json = this.jsonParser(responseText);
                         }
                         catch (e) {
                             if (config.acceptRawText) {

lib/types.d.ts

@@ -1,9 +1,9 @@
 /// <reference types="node" />
 import * as https from "https";
 export interface Operation {
-    schema?: string | null;
-    dropAttr?: string | null;
-    dropAll?: boolean | null;
+    schema?: string;
+    dropAttr?: string;
+    dropAll?: boolean;
 }
 export interface Payload {
     data: {};
@@ -12,7 +12,7 @@ export interface Request {
     query: string;
     vars?: {
         [k: string]: string;
-    } | null;
+    };
     startTs?: number;
     timeout?: number;
     debug?: boolean;
@@ -36,13 +36,13 @@ export interface LoginResponse {
     };
 }
 export interface Mutation {
-    setJson?: object | null;
-    deleteJson?: object | null;
-    setNquads?: string | null;
-    deleteNquads?: string | null;
+    setJson?: object;
+    deleteJson?: object;
+    setNquads?: string;
+    deleteNquads?: string;
     startTs?: number;
-    commitNow?: boolean | null;
-    mutation?: string | null;
+    commitNow?: boolean;
+    mutation?: string;
     isJsonString?: boolean;
 }
 export interface Assigned {
@@ -60,16 +60,16 @@ export interface Extensions {
 }
 export interface TxnContext {
     start_ts: number;
-    aborted?: boolean | null;
-    keys?: string[] | null;
-    preds?: string[] | null;
+    aborted?: boolean;
+    keys?: string[];
+    preds?: string[];
     readOnly: boolean;
     bestEffort: boolean;
 }
 export interface Latency {
-    parsing_ns?: number | null;
-    processing_ns?: number | null;
-    encoding_ns?: number | null;
+    parsing_ns?: number;
+    processing_ns?: number;
+    encoding_ns?: number;
 }
 export interface TxnOptions {
     readOnly?: boolean;

src/types.ts

@@ -1,9 +1,9 @@
 import * as https from "https";
 
 export interface Operation {
-    schema?: string | null;
-    dropAttr?: string | null;
-    dropAll?: boolean | null;
+    schema?: string;
+    dropAttr?: string;
+    dropAll?: boolean;
 }
 
 export interface Payload {
@@ -12,7 +12,7 @@ export interface Payload {
 
 export interface Request {
     query: string;
-    vars?: { [k: string]: string } | null;
+    vars?: { [k: string]: string };
     startTs?: number;
     timeout?: number;
     debug?: boolean;
@@ -38,14 +38,14 @@ export interface LoginResponse {
 }
 
 export interface Mutation {
-    setJson?: object | null;
-    deleteJson?: object | null;
-    setNquads?: string | null;
-    deleteNquads?: string | null;
+    setJson?: object;
+    deleteJson?: object;
+    setNquads?: string;
+    deleteNquads?: string;
     startTs?: number;
-    commitNow?: boolean | null;
+    commitNow?: boolean;
     // Raw mutation text to send;
-    mutation?: string | null;
+    mutation?: string;
     // Set to true if `mutation` field (above) contains a JSON mutation.
     isJsonString?: boolean;
 }
@@ -66,17 +66,17 @@ export interface Extensions {
 
 export interface TxnContext {
     start_ts: number;
-    aborted?: boolean | null;
-    keys?: string[] | null;
-    preds?: string[] | null;
+    aborted?: boolean;
+    keys?: string[];
+    preds?: string[];
     readOnly: boolean;
     bestEffort: boolean;
 }
 
 export interface Latency {
-    parsing_ns?: number | null;
-    processing_ns?: number | null;
-    encoding_ns?: number | null;
+    parsing_ns?: number;
+    processing_ns?: number;
+    encoding_ns?: number;
 }
 
 export interface TxnOptions {