Skip to content

Commit 7ea7b2a

Browse files
committed
Add support for RDF & upgrade dependencies
1 parent 5f96fb7 commit 7ea7b2a

File tree

9 files changed

+592
-124
lines changed

9 files changed

+592
-124
lines changed

generated/api_grpc_pb.js

Lines changed: 101 additions & 100 deletions
Original file line numberDiff line numberDiff line change
@@ -21,155 +21,156 @@
2121
// SongServerRequest. Use snake_case (underscore_separated_names) for field names – for
2222
// example, song_name.
2323
//
24-
"use strict";
25-
var grpc = require("@grpc/grpc-js");
26-
var api_pb = require("./api_pb.js");
24+
'use strict';
25+
var grpc = require('@grpc/grpc-js');
26+
var api_pb = require('./api_pb.js');
2727

2828
function serialize_api_Check(arg) {
29-
if (!(arg instanceof api_pb.Check)) {
30-
throw new Error("Expected argument of type api.Check");
31-
}
32-
return Buffer.from(arg.serializeBinary());
29+
if (!(arg instanceof api_pb.Check)) {
30+
throw new Error('Expected argument of type api.Check');
31+
}
32+
return Buffer.from(arg.serializeBinary());
3333
}
3434

3535
function deserialize_api_Check(buffer_arg) {
36-
return api_pb.Check.deserializeBinary(new Uint8Array(buffer_arg));
36+
return api_pb.Check.deserializeBinary(new Uint8Array(buffer_arg));
3737
}
3838

3939
function serialize_api_LoginRequest(arg) {
40-
if (!(arg instanceof api_pb.LoginRequest)) {
41-
throw new Error("Expected argument of type api.LoginRequest");
42-
}
43-
return Buffer.from(arg.serializeBinary());
40+
if (!(arg instanceof api_pb.LoginRequest)) {
41+
throw new Error('Expected argument of type api.LoginRequest');
42+
}
43+
return Buffer.from(arg.serializeBinary());
4444
}
4545

4646
function deserialize_api_LoginRequest(buffer_arg) {
47-
return api_pb.LoginRequest.deserializeBinary(new Uint8Array(buffer_arg));
47+
return api_pb.LoginRequest.deserializeBinary(new Uint8Array(buffer_arg));
4848
}
4949

5050
function serialize_api_Operation(arg) {
51-
if (!(arg instanceof api_pb.Operation)) {
52-
throw new Error("Expected argument of type api.Operation");
53-
}
54-
return Buffer.from(arg.serializeBinary());
51+
if (!(arg instanceof api_pb.Operation)) {
52+
throw new Error('Expected argument of type api.Operation');
53+
}
54+
return Buffer.from(arg.serializeBinary());
5555
}
5656

5757
function deserialize_api_Operation(buffer_arg) {
58-
return api_pb.Operation.deserializeBinary(new Uint8Array(buffer_arg));
58+
return api_pb.Operation.deserializeBinary(new Uint8Array(buffer_arg));
5959
}
6060

6161
function serialize_api_Payload(arg) {
62-
if (!(arg instanceof api_pb.Payload)) {
63-
throw new Error("Expected argument of type api.Payload");
64-
}
65-
return Buffer.from(arg.serializeBinary());
62+
if (!(arg instanceof api_pb.Payload)) {
63+
throw new Error('Expected argument of type api.Payload');
64+
}
65+
return Buffer.from(arg.serializeBinary());
6666
}
6767

6868
function deserialize_api_Payload(buffer_arg) {
69-
return api_pb.Payload.deserializeBinary(new Uint8Array(buffer_arg));
69+
return api_pb.Payload.deserializeBinary(new Uint8Array(buffer_arg));
7070
}
7171

7272
function serialize_api_Request(arg) {
73-
if (!(arg instanceof api_pb.Request)) {
74-
throw new Error("Expected argument of type api.Request");
75-
}
76-
return Buffer.from(arg.serializeBinary());
73+
if (!(arg instanceof api_pb.Request)) {
74+
throw new Error('Expected argument of type api.Request');
75+
}
76+
return Buffer.from(arg.serializeBinary());
7777
}
7878

7979
function deserialize_api_Request(buffer_arg) {
80-
return api_pb.Request.deserializeBinary(new Uint8Array(buffer_arg));
80+
return api_pb.Request.deserializeBinary(new Uint8Array(buffer_arg));
8181
}
8282

8383
function serialize_api_Response(arg) {
84-
if (!(arg instanceof api_pb.Response)) {
85-
throw new Error("Expected argument of type api.Response");
86-
}
87-
return Buffer.from(arg.serializeBinary());
84+
if (!(arg instanceof api_pb.Response)) {
85+
throw new Error('Expected argument of type api.Response');
86+
}
87+
return Buffer.from(arg.serializeBinary());
8888
}
8989

9090
function deserialize_api_Response(buffer_arg) {
91-
return api_pb.Response.deserializeBinary(new Uint8Array(buffer_arg));
91+
return api_pb.Response.deserializeBinary(new Uint8Array(buffer_arg));
9292
}
9393

9494
function serialize_api_TxnContext(arg) {
95-
if (!(arg instanceof api_pb.TxnContext)) {
96-
throw new Error("Expected argument of type api.TxnContext");
97-
}
98-
return Buffer.from(arg.serializeBinary());
95+
if (!(arg instanceof api_pb.TxnContext)) {
96+
throw new Error('Expected argument of type api.TxnContext');
97+
}
98+
return Buffer.from(arg.serializeBinary());
9999
}
100100

101101
function deserialize_api_TxnContext(buffer_arg) {
102-
return api_pb.TxnContext.deserializeBinary(new Uint8Array(buffer_arg));
102+
return api_pb.TxnContext.deserializeBinary(new Uint8Array(buffer_arg));
103103
}
104104

105105
function serialize_api_Version(arg) {
106-
if (!(arg instanceof api_pb.Version)) {
107-
throw new Error("Expected argument of type api.Version");
108-
}
109-
return Buffer.from(arg.serializeBinary());
106+
if (!(arg instanceof api_pb.Version)) {
107+
throw new Error('Expected argument of type api.Version');
108+
}
109+
return Buffer.from(arg.serializeBinary());
110110
}
111111

112112
function deserialize_api_Version(buffer_arg) {
113-
return api_pb.Version.deserializeBinary(new Uint8Array(buffer_arg));
113+
return api_pb.Version.deserializeBinary(new Uint8Array(buffer_arg));
114114
}
115115

116+
116117
// Graph response.
117-
var DgraphService = (exports.DgraphService = {
118-
login: {
119-
path: "/api.Dgraph/Login",
120-
requestStream: false,
121-
responseStream: false,
122-
requestType: api_pb.LoginRequest,
123-
responseType: api_pb.Response,
124-
requestSerialize: serialize_api_LoginRequest,
125-
requestDeserialize: deserialize_api_LoginRequest,
126-
responseSerialize: serialize_api_Response,
127-
responseDeserialize: deserialize_api_Response,
128-
},
129-
query: {
130-
path: "/api.Dgraph/Query",
131-
requestStream: false,
132-
responseStream: false,
133-
requestType: api_pb.Request,
134-
responseType: api_pb.Response,
135-
requestSerialize: serialize_api_Request,
136-
requestDeserialize: deserialize_api_Request,
137-
responseSerialize: serialize_api_Response,
138-
responseDeserialize: deserialize_api_Response,
139-
},
140-
alter: {
141-
path: "/api.Dgraph/Alter",
142-
requestStream: false,
143-
responseStream: false,
144-
requestType: api_pb.Operation,
145-
responseType: api_pb.Payload,
146-
requestSerialize: serialize_api_Operation,
147-
requestDeserialize: deserialize_api_Operation,
148-
responseSerialize: serialize_api_Payload,
149-
responseDeserialize: deserialize_api_Payload,
150-
},
151-
commitOrAbort: {
152-
path: "/api.Dgraph/CommitOrAbort",
153-
requestStream: false,
154-
responseStream: false,
155-
requestType: api_pb.TxnContext,
156-
responseType: api_pb.TxnContext,
157-
requestSerialize: serialize_api_TxnContext,
158-
requestDeserialize: deserialize_api_TxnContext,
159-
responseSerialize: serialize_api_TxnContext,
160-
responseDeserialize: deserialize_api_TxnContext,
161-
},
162-
checkVersion: {
163-
path: "/api.Dgraph/CheckVersion",
164-
requestStream: false,
165-
responseStream: false,
166-
requestType: api_pb.Check,
167-
responseType: api_pb.Version,
168-
requestSerialize: serialize_api_Check,
169-
requestDeserialize: deserialize_api_Check,
170-
responseSerialize: serialize_api_Version,
171-
responseDeserialize: deserialize_api_Version,
172-
},
173-
});
118+
var DgraphService = exports.DgraphService = {
119+
login: {
120+
path: '/api.Dgraph/Login',
121+
requestStream: false,
122+
responseStream: false,
123+
requestType: api_pb.LoginRequest,
124+
responseType: api_pb.Response,
125+
requestSerialize: serialize_api_LoginRequest,
126+
requestDeserialize: deserialize_api_LoginRequest,
127+
responseSerialize: serialize_api_Response,
128+
responseDeserialize: deserialize_api_Response,
129+
},
130+
query: {
131+
path: '/api.Dgraph/Query',
132+
requestStream: false,
133+
responseStream: false,
134+
requestType: api_pb.Request,
135+
responseType: api_pb.Response,
136+
requestSerialize: serialize_api_Request,
137+
requestDeserialize: deserialize_api_Request,
138+
responseSerialize: serialize_api_Response,
139+
responseDeserialize: deserialize_api_Response,
140+
},
141+
alter: {
142+
path: '/api.Dgraph/Alter',
143+
requestStream: false,
144+
responseStream: false,
145+
requestType: api_pb.Operation,
146+
responseType: api_pb.Payload,
147+
requestSerialize: serialize_api_Operation,
148+
requestDeserialize: deserialize_api_Operation,
149+
responseSerialize: serialize_api_Payload,
150+
responseDeserialize: deserialize_api_Payload,
151+
},
152+
commitOrAbort: {
153+
path: '/api.Dgraph/CommitOrAbort',
154+
requestStream: false,
155+
responseStream: false,
156+
requestType: api_pb.TxnContext,
157+
responseType: api_pb.TxnContext,
158+
requestSerialize: serialize_api_TxnContext,
159+
requestDeserialize: deserialize_api_TxnContext,
160+
responseSerialize: serialize_api_TxnContext,
161+
responseDeserialize: deserialize_api_TxnContext,
162+
},
163+
checkVersion: {
164+
path: '/api.Dgraph/CheckVersion',
165+
requestStream: false,
166+
responseStream: false,
167+
requestType: api_pb.Check,
168+
responseType: api_pb.Version,
169+
requestSerialize: serialize_api_Check,
170+
requestDeserialize: deserialize_api_Check,
171+
responseSerialize: serialize_api_Version,
172+
responseDeserialize: deserialize_api_Version,
173+
},
174+
};
174175

175176
exports.DgraphClient = grpc.makeGenericClientConstructor(DgraphService);

generated/api_pb.d.ts

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,9 @@ export class Request extends jspb.Message {
2626
getCommitNow(): boolean;
2727
setCommitNow(value: boolean): void;
2828

29+
getRespFormat(): Request.RespFormatMap[keyof Request.RespFormatMap];
30+
setRespFormat(value: Request.RespFormatMap[keyof Request.RespFormatMap]): void;
31+
2932
serializeBinary(): Uint8Array;
3033
toObject(includeInstance?: boolean): Request.AsObject;
3134
static toObject(includeInstance: boolean, msg: Request): Request.AsObject;
@@ -45,7 +48,15 @@ export namespace Request {
4548
bestEffort: boolean,
4649
mutationsList: Array<Mutation.AsObject>,
4750
commitNow: boolean,
51+
respFormat: Request.RespFormatMap[keyof Request.RespFormatMap],
52+
}
53+
54+
export interface RespFormatMap {
55+
JSON: 0;
56+
RDF: 1;
4857
}
58+
59+
export const RespFormat: RespFormatMap;
4960
}
5061

5162
export class Uids extends jspb.Message {
@@ -70,6 +81,28 @@ export namespace Uids {
7081
}
7182
}
7283

84+
export class ListOfString extends jspb.Message {
85+
clearValueList(): void;
86+
getValueList(): Array<string>;
87+
setValueList(value: Array<string>): void;
88+
addValue(value: string, index?: number): string;
89+
90+
serializeBinary(): Uint8Array;
91+
toObject(includeInstance?: boolean): ListOfString.AsObject;
92+
static toObject(includeInstance: boolean, msg: ListOfString): ListOfString.AsObject;
93+
static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
94+
static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
95+
static serializeBinaryToWriter(message: ListOfString, writer: jspb.BinaryWriter): void;
96+
static deserializeBinary(bytes: Uint8Array): ListOfString;
97+
static deserializeBinaryFromReader(message: ListOfString, reader: jspb.BinaryReader): ListOfString;
98+
}
99+
100+
export namespace ListOfString {
101+
export type AsObject = {
102+
valueList: Array<string>,
103+
}
104+
}
105+
73106
export class Response extends jspb.Message {
74107
getJson(): Uint8Array | string;
75108
getJson_asU8(): Uint8Array;
@@ -93,6 +126,13 @@ export class Response extends jspb.Message {
93126

94127
getUidsMap(): jspb.Map<string, string>;
95128
clearUidsMap(): void;
129+
getRdf(): Uint8Array | string;
130+
getRdf_asU8(): Uint8Array;
131+
getRdf_asB64(): string;
132+
setRdf(value: Uint8Array | string): void;
133+
134+
getHdrsMap(): jspb.Map<string, ListOfString>;
135+
clearHdrsMap(): void;
96136
serializeBinary(): Uint8Array;
97137
toObject(includeInstance?: boolean): Response.AsObject;
98138
static toObject(includeInstance: boolean, msg: Response): Response.AsObject;
@@ -110,6 +150,8 @@ export namespace Response {
110150
latency?: Latency.AsObject,
111151
metrics?: Metrics.AsObject,
112152
uidsMap: Array<[string, string]>,
153+
rdf: Uint8Array | string,
154+
hdrsMap: Array<[string, ListOfString.AsObject]>,
113155
}
114156
}
115157

0 commit comments

Comments
 (0)