Socket
Socket
Sign inDemoInstall

@sajari/sdk-node

Package Overview
Dependencies
Maintainers
4
Versions
49
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@sajari/sdk-node - npm Package Compare versions

Comparing version 1.0.0-beta.7 to 2.0.0-beta.1

dist/protoUtils.d.ts
dist/protoUtils.js
dist/store/client.d.ts
dist/store/client.js
dist/store/fieldMutation.d.ts
dist/store/fieldMutation.js
dist/store/index.d.ts
dist/store/index.js
dist/store/record.d.ts
dist/store/record.js
dist/types.d.ts
dist/types.js

11

dist/api.js

@@ -10,3 +10,2 @@ "use strict";

var retryInterceptor_1 = __importDefault(require("./retryInterceptor"));
var utils_1 = require("./utils");
/**

@@ -74,3 +73,3 @@ * Custom formatter for call options.

_this.client.makeUnaryRequest(path, wrapEncoder(encoder), decoder, request, _this.metadata, {
deadline: utils_1.deadline(callOptions.deadline),
deadline: deadline(callOptions.deadline),
// tslint:disable-next-line:no-bitwise

@@ -96,3 +95,3 @@ propagate_flags: grpc_1.default.propagate.DEFAULTS & ~grpc_1.default.propagate.DEADLINE,

return new Promise(function (resolve, reject) {
_this.client.waitForReady(utils_1.deadline(seconds), function (err) {
_this.client.waitForReady(deadline(seconds), function (err) {
if (err) {

@@ -133,1 +132,7 @@ return reject(err);

}
/**
* @hidden
*/
function deadline(seconds) {
return new Date().setSeconds(new Date().getSeconds() + seconds);
}

18

dist/client.d.ts

@@ -1,9 +0,6 @@

import { CallOptions } from "./api";
import { FieldMutation } from "./engine/fieldMutation";
import { GetResponse, RecordMutation } from "./engine/interfaces";
import { Key } from "./engine/key";
import { Record } from "./engine/record";
import { Interaction } from "./interaction";
import { Pipeline } from "./pipeline";
import { PipelineIdentifier } from "./pipeline/pipeline";
import { Schema } from "./schema";
import { Store } from "./store/client";
export declare class Client {

@@ -17,13 +14,6 @@ private client;

wait(seconds: number): Promise<void>;
get(key: Key, callOptions?: CallOptions): Promise<Record>;
getMulti(keys: Key[], callOptions?: CallOptions): Promise<GetResponse[]>;
mutate(key: Key, fieldMutation: FieldMutation, callOptions?: CallOptions): Promise<void>;
mutateMulti(recordMutations: RecordMutation[], callOptions?: CallOptions): Promise<void>;
delete(key: Key, callOptions?: CallOptions): Promise<void>;
deleteMulti(keys: Key[], callOptions?: CallOptions): Promise<void>;
pipeline(pipeline: {
name: string;
}): Pipeline;
pipeline(pipeline: PipelineIdentifier): Pipeline;
schema(): Schema;
store(): Store;
interaction(): Interaction;
}

147

dist/client.js
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while (_) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
Object.defineProperty(exports, "__esModule", { value: true });
var proto_1 = require("../generated/proto");
var api_1 = require("./api");
var fieldMutation_1 = require("./engine/fieldMutation");
var key_1 = require("./engine/key");
var parse_1 = require("./engine/parse");
var interaction_1 = require("./interaction");
var pipeline_1 = require("./pipeline");
var schema_1 = require("./schema");
var utils_1 = require("./utils");
/**
* grpc method endpoint for record mutation
* @hidden
*/
var MutateRecordMethod = "sajari.engine.store.record.Store/Mutate";
/**
* grpc method endpoint for record retrieval
* @hidden
*/
var GetRecordMethod = "sajari.engine.store.record.Store/Get";
/**
* grpc method endpoint for record deletion
* @hidden
*/
var DeleteRecordMethod = "sajari.engine.store.record.Store/Delete";
var client_1 = require("./store/client");
var Client = /** @class */ (function () {

@@ -72,90 +18,2 @@ function Client(project, collection, credentials, endpoint) {

};
Client.prototype.get = function (key, callOptions) {
return __awaiter(this, void 0, void 0, function () {
var response, res;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, this.getMulti([key], callOptions)];
case 1:
response = _a.sent();
res = response[0];
if (res.error) {
throw res.error;
}
return [2 /*return*/, res.record];
}
});
});
};
Client.prototype.getMulti = function (keys, callOptions) {
return __awaiter(this, void 0, void 0, function () {
var request, response;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = new proto_1.sajari.engine.store.record.Keys({
keys: keys.map(key_1.Key.toProto)
});
return [4 /*yield*/, this.client.call(GetRecordMethod, request, proto_1.sajari.engine.store.record.Keys.encode, proto_1.sajari.engine.store.record.GetResponse.decode, callOptions)];
case 1:
response = _a.sent();
return [2 /*return*/, parse_1.parseRecordResponse(response)];
}
});
});
};
Client.prototype.mutate = function (key, fieldMutation, callOptions) {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
return [2 /*return*/, this.mutateMulti([{ key: key, mutations: [fieldMutation] }], callOptions)];
});
});
};
Client.prototype.mutateMulti = function (recordMutations, callOptions) {
return __awaiter(this, void 0, void 0, function () {
var request, response, err;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = fieldMutation_1.createMutationRequest(recordMutations);
return [4 /*yield*/, this.client.call(MutateRecordMethod, request, proto_1.sajari.engine.store.record.MutateRequest.encode, proto_1.sajari.engine.store.record.MutateResponse.decode, callOptions)];
case 1:
response = _a.sent();
err = utils_1.errorFromStatuses(response.status);
if (err) {
throw err;
}
return [2 /*return*/];
}
});
});
};
Client.prototype.delete = function (key, callOptions) {
return __awaiter(this, void 0, void 0, function () {
return __generator(this, function (_a) {
return [2 /*return*/, this.deleteMulti([key], callOptions)];
});
});
};
Client.prototype.deleteMulti = function (keys, callOptions) {
return __awaiter(this, void 0, void 0, function () {
var request, response, err;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = proto_1.sajari.engine.store.record.Keys.create({
keys: keys.map(key_1.Key.toProto)
});
return [4 /*yield*/, this.client.call(DeleteRecordMethod, request, proto_1.sajari.engine.store.record.Keys.encode, proto_1.sajari.engine.store.record.DeleteResponse.decode, callOptions)];
case 1:
response = _a.sent();
err = utils_1.errorFromStatuses(response.status);
if (err) {
throw err;
}
return [2 /*return*/];
}
});
});
};
Client.prototype.pipeline = function (pipeline) {

@@ -167,2 +25,5 @@ return new pipeline_1.PipelineImpl(pipeline, this.client);

};
Client.prototype.store = function () {
return new client_1.Store(this.client);
};
Client.prototype.interaction = function () {

@@ -169,0 +30,0 @@ return new interaction_1.Interaction(this.client);

6

dist/index.d.ts

@@ -1,6 +0,4 @@

export { status as errorCode } from "grpc";
export { status as statusCode } from "grpc";
export { Client } from "./client";
export { Key, Value } from "./types";
export { Session, DefaultSession, Tracking, TrackingType } from "./pipeline/session";
export { SearchResponse } from "./pipeline/search";
export { default as schema, FieldMode, Mutation, NameMutation, DescriptionMutation, TypeMutation, RepeatedMutation } from "./schema";
export { default as records, FieldMutation, Record, Key } from "./engine";

14

dist/index.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
// reexport the grpc status code enum
// re-export the grpc status code enum
var grpc_1 = require("grpc");
exports.errorCode = grpc_1.status;
exports.statusCode = grpc_1.status;
var client_1 = require("./client");

@@ -10,12 +10,2 @@ exports.Client = client_1.Client;

exports.DefaultSession = session_1.DefaultSession;
exports.Tracking = session_1.Tracking;
exports.TrackingType = session_1.TrackingType;
var schema_1 = require("./schema");
exports.schema = schema_1.default;
exports.FieldMode = schema_1.FieldMode;
exports.Mutation = schema_1.Mutation;
var engine_1 = require("./engine");
exports.records = engine_1.default;
exports.FieldMutation = engine_1.FieldMutation;
exports.Record = engine_1.Record;
exports.Key = engine_1.Key;

5

dist/interaction.d.ts

@@ -6,3 +6,3 @@ import { APIClient, CallOptions } from "./api";

*/
export declare const ConsumeInteractionEndpoint = "sajari.api.interaction.Interaction/Consume";
export declare const ConsumeInteractionEndpoint = "sajari.interaction.v2.Interaction/Consume";
export declare class Interaction {

@@ -14,4 +14,3 @@ /**

constructor(client: APIClient);
consume(req: {
token: string;
consume(token: string, info: {
identifier: string;

@@ -18,0 +17,0 @@ weight: number;

19

dist/interaction.js
"use strict";
var __assign = (this && this.__assign) || function () {
__assign = Object.assign || function(t) {
for (var s, i = 1, n = arguments.length; i < n; i++) {
s = arguments[i];
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
t[p] = s[p];
}
return t;
};
return __assign.apply(this, arguments);
};
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {

@@ -43,3 +54,3 @@ return new (P || (P = Promise))(function (resolve, reject) {

*/
exports.ConsumeInteractionEndpoint = "sajari.api.interaction.Interaction/Consume";
exports.ConsumeInteractionEndpoint = "sajari.interaction.v2.Interaction/Consume";
var Interaction = /** @class */ (function () {

@@ -49,3 +60,3 @@ function Interaction(client) {

}
Interaction.prototype.consume = function (req, opts) {
Interaction.prototype.consume = function (token, info, opts) {
if (opts === void 0) { opts = {}; }

@@ -57,4 +68,4 @@ return __awaiter(this, void 0, void 0, function () {

case 0:
request = proto_1.sajari.api.interaction.ConsumeRequest.create(req);
return [4 /*yield*/, this.client.call(exports.ConsumeInteractionEndpoint, request, proto_1.sajari.api.interaction.ConsumeRequest.encode, proto_1.sajari.rpc.Empty.decode, opts)];
request = proto_1.sajari.interaction.v2.ConsumeTokenRequest.create(__assign({ token: token }, info));
return [4 /*yield*/, this.client.call(exports.ConsumeInteractionEndpoint, request, proto_1.sajari.interaction.v2.ConsumeTokenRequest.encode, proto_1.sajari.interaction.v2.ConsumeTokenResponse.decode, opts)];
case 1:

@@ -61,0 +72,0 @@ _a.sent();

2

dist/pipeline/index.d.ts

@@ -1,1 +0,1 @@

export { Pipeline, PipelineDefinition, PipelineImpl } from "./pipeline";
export { Pipeline, PipelineIdentifier, PipelineImpl } from "./pipeline";

72

dist/pipeline/pipeline.d.ts
import { APIClient, CallOptions } from "../api";
import { Key } from "../engine/key";
import { Record } from "../engine/record";
import { AddResponse } from "./add";
import { KeyRecord, ReplaceResponse } from "./replace";
import { Record } from "../store/record";
import { Key } from "../types";
import { SearchResponse } from "./search";

@@ -11,4 +9,5 @@ import { Tracking } from "./session";

*/
export interface PipelineDefinition {
export interface PipelineIdentifier {
name: string;
version: string;
}

@@ -31,14 +30,12 @@ /**

*/
add(values: {
create(values: {
[k: string]: string;
}, record: Record, options?: CallOptions): Promise<Key>;
}, record: Record, options?: CallOptions): Promise<{
pipeline: PipelineIdentifier;
values: {
[k: string]: any;
};
key: Key;
}>;
/**
* AddMulti adds multiple records to a collection using a pipeline, returning
* a list of AddResponse objects which either contain the Key for the
* respective record, or an Error if the add fails.
*/
addMulti(values: {
[k: string]: string;
}, records: Record[], options?: CallOptions): Promise<AddResponse[]>;
/**
* Replace a record to a collection using a pipeline, returning the unique

@@ -49,12 +46,9 @@ * Key which can be used to retrieve the respective record.

[k: string]: string;
}, keyRecord: KeyRecord, options?: CallOptions): Promise<Key>;
/**
* ReplaceMulti replaces multiple records in a collection using a pipeline,
* returning a list of ReplaceResponse objects which either contain the Key
* for the new record created, and empty Key if the record already exists
* and was replaced, or an Error if the replace fails.
*/
replaceMulti(values: {
[k: string]: string;
}, keyRecords: KeyRecord[], options?: CallOptions): Promise<ReplaceResponse[]>;
}, key: Key, record: Record, options?: CallOptions): Promise<{
pipeline: PipelineIdentifier;
values: {
[k: string]: any;
};
key: Key;
}>;
}

@@ -68,18 +62,24 @@ /**

private client;
constructor(pipeline: PipelineDefinition, client: APIClient);
constructor(pipeline: PipelineIdentifier, client: APIClient);
search(values: {
[k: string]: string;
}, tracking: Tracking, options?: CallOptions): Promise<SearchResponse>;
add(values: {
[k: string]: string;
}, record: Record, options?: CallOptions): Promise<Key>;
addMulti(values: {
[k: string]: string;
}, records: Record[], options?: CallOptions): Promise<AddResponse[]>;
create(values: {
[k: string]: any;
}, record: Record, options?: CallOptions): Promise<{
pipeline: PipelineIdentifier;
values: {
[k: string]: any;
};
key: Key;
}>;
replace(values: {
[k: string]: string;
}, keyRecord: KeyRecord, options?: CallOptions): Promise<Key>;
replaceMulti(values: {
[k: string]: string;
}, keyRecords: KeyRecord[], options?: CallOptions): Promise<ReplaceResponse[]>;
}, key: Key, record: Record, options?: CallOptions): Promise<{
pipeline: PipelineIdentifier;
values: {
[k: string]: any;
};
key: Key;
}>;
}

112

dist/pipeline/pipeline.js

@@ -39,10 +39,25 @@ "use strict";

var proto_1 = require("../../generated/proto");
var add_1 = require("./add");
var replace_1 = require("./replace");
var protoUtils_1 = require("../protoUtils");
var record_1 = require("../store/record");
var types_1 = require("../types");
var search_1 = require("./search");
var session_1 = require("./session");
/**
* @hidden
*/
function PipelineIdentifierFromProto(v) {
if (v == null) {
throw new Error("sajari: invalid proto");
}
var x = proto_1.sajari.pipeline.v2.Identifier.create(v);
return {
name: x.name,
version: x.version
};
}
/**
* grpc method path for record ingestetion via a pipeline
* @hidden
*/
var PipelineAddMethod = "sajari.api.pipeline.v1.Store/Add";
var PipelineCreateRecordMethod = "sajari.pipeline.v2.Store/CreateRecord";
/**

@@ -52,3 +67,3 @@ * grpc method path for replace

*/
var PipelineReplaceMethod = "sajari.api.pipeline.v1.Store/Replace";
var PipelineReplaceRecordMethod = "sajari.pipeline.v2.Store/ReplaceRecord";
/**

@@ -58,3 +73,3 @@ * grpc method path for querying records

*/
var PipelineSearchMethod = "sajari.api.pipeline.v1.Query/Search";
var PipelineSearchMethod = "sajari.pipeline.v2.Query/Search";
/**

@@ -75,8 +90,16 @@ * PipelineImpl is the implementation of a Pipeline

case 0:
request = search_1.createSearchRequest(this.pipeline, values, tracking);
return [4 /*yield*/, this.client.call(PipelineSearchMethod, request, proto_1.sajari.api.pipeline.v1.SearchRequest.encode, proto_1.sajari.api.pipeline.v1.SearchResponse.decode, options)];
request = proto_1.sajari.pipeline.v2.SearchRequest.create({
pipeline: this.pipeline,
values: protoUtils_1.objectToStruct(values),
tracking: session_1.TrackingToProto(tracking)
});
return [4 /*yield*/, this.client.call(PipelineSearchMethod, request, proto_1.sajari.pipeline.v2.SearchRequest.encode, proto_1.sajari.pipeline.v2.SearchResponse.decode, options)];
case 1:
response = _a.sent();
results = search_1.parseSearchResponse(response);
return [2 /*return*/, { results: results, values: response.values }];
return [2 /*return*/, {
results: results,
values: protoUtils_1.structToObject(response.values),
pipeline: PipelineIdentifierFromProto(response.pipeline)
}];
}

@@ -86,21 +109,4 @@ });

};
PipelineImpl.prototype.add = function (values, record, options) {
PipelineImpl.prototype.create = function (values, record, options) {
return __awaiter(this, void 0, void 0, function () {
var response, res;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, this.addMulti(values, [record], options)];
case 1:
response = _a.sent();
res = response[0];
if (res.error) {
throw res.error;
}
return [2 /*return*/, res.key];
}
});
});
};
PipelineImpl.prototype.addMulti = function (values, records, options) {
return __awaiter(this, void 0, void 0, function () {
var request, response;

@@ -110,10 +116,15 @@ return __generator(this, function (_a) {

case 0:
request = add_1.createAddRequest(this.pipeline, values, records);
return [4 /*yield*/, this.client.call(PipelineAddMethod, request, proto_1.sajari.api.pipeline.v1.AddRequest.encode, proto_1.sajari.api.pipeline.v1.AddResponse.decode, options)];
request = proto_1.sajari.pipeline.v2.CreateRecordRequest.create({
pipeline: this.pipeline,
values: protoUtils_1.objectToStruct(values),
record: record_1.RecordToProto(record)
});
return [4 /*yield*/, this.client.call(PipelineCreateRecordMethod, request, proto_1.sajari.pipeline.v2.CreateRecordRequest.encode, proto_1.sajari.pipeline.v2.CreateRecordResponse.decode, options)];
case 1:
response = _a.sent();
if (response.response == null) {
throw new Error("sajari: empty response");
}
return [2 /*return*/, add_1.parseAddResponse(response.response)];
return [2 /*return*/, {
key: types_1.KeyFromProto(response.key),
values: protoUtils_1.structToObject(response.values),
pipeline: PipelineIdentifierFromProto(response.pipeline)
}];
}

@@ -123,21 +134,4 @@ });

};
PipelineImpl.prototype.replace = function (values, keyRecord, options) {
PipelineImpl.prototype.replace = function (values, key, record, options) {
return __awaiter(this, void 0, void 0, function () {
var response, res;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, this.replaceMulti(values, [keyRecord], options)];
case 1:
response = _a.sent();
res = response[0];
if (res.error) {
throw res.error;
}
return [2 /*return*/, res.key];
}
});
});
};
PipelineImpl.prototype.replaceMulti = function (values, keyRecords, options) {
return __awaiter(this, void 0, void 0, function () {
var request, response;

@@ -147,10 +141,16 @@ return __generator(this, function (_a) {

case 0:
request = replace_1.createReplaceRequest(this.pipeline, values, keyRecords);
return [4 /*yield*/, this.client.call(PipelineReplaceMethod, request, proto_1.sajari.api.pipeline.v1.ReplaceRequest.encode, proto_1.sajari.api.pipeline.v1.ReplaceResponse.decode, options)];
request = proto_1.sajari.pipeline.v2.ReplaceRecordRequest.create({
pipeline: this.pipeline,
values: protoUtils_1.objectToStruct(values),
key: types_1.KeyToProto(key),
record: record_1.RecordToProto(record)
});
return [4 /*yield*/, this.client.call(PipelineReplaceRecordMethod, request, proto_1.sajari.pipeline.v2.ReplaceRecordRequest.encode, proto_1.sajari.pipeline.v2.ReplaceRecordResponse.decode, options)];
case 1:
response = _a.sent();
if (response.response == null) {
throw new Error("sajari: empty response");
}
return [2 /*return*/, replace_1.parseReplaceResponse(response.response)];
return [2 /*return*/, {
key: types_1.KeyFromProto(response.key),
values: protoUtils_1.structToObject(response.values),
pipeline: PipelineIdentifierFromProto(response.pipeline)
}];
}

@@ -157,0 +157,0 @@ });

32

dist/pipeline/search.d.ts
import { sajari } from "../../generated/proto";
import { PipelineDefinition } from "./pipeline";
import { Token, Tracking } from "./session";
import { PipelineIdentifier } from "./pipeline";
import { Token } from "./session";
export interface Result {

@@ -10,3 +10,3 @@ score: number;

};
tokens?: Token;
token?: Token;
}

@@ -16,3 +16,3 @@ export interface Results {

totalResults: number;
time: number;
latency: number;
aggregates: Aggregates;

@@ -23,2 +23,3 @@ aggregateFilters: Aggregates;

export interface SearchResponse {
pipeline: PipelineIdentifier;
results: Results;

@@ -32,9 +33,9 @@ values: {

*/
export declare const createSearchRequest: (pipeline: PipelineDefinition, values: {
[k: string]: string;
}, tracking: Tracking) => sajari.api.pipeline.v1.SearchRequest;
export declare function parseSearchResponse(raw: sajari.pipeline.v2.SearchResponse): Results;
export interface Aggregates {
[k: string]: BucketsResponse | CountResponse | number;
}
/**
* @hidden
* BucketsResponse is a type returned from a query performing bucket aggregate.
*/
export declare function parseSearchResponse(raw: sajari.api.pipeline.v1.SearchResponse): Results;
export interface BucketsResponse {

@@ -44,10 +45,17 @@ [k: string]: BucketResponse;

export interface BucketResponse {
/**
* Name of the bucket.
*/
name: string;
/**
* Number of records.
*/
count: number;
}
/**
* CountResponse is a type returned from a query which has
* performed a count aggregate.
*/
export interface CountResponse {
[k: string]: number;
}
export interface Aggregates {
[k: string]: BucketsResponse | CountResponse | number;
}

43

dist/pipeline/search.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var proto_1 = require("../../generated/proto");
var utils_1 = require("../utils");
var protoUtils_1 = require("../protoUtils");
var types_1 = require("../types");
var session_1 = require("./session");

@@ -9,24 +10,8 @@ /**

*/
exports.createSearchRequest = function (pipeline, values, tracking) {
var req = {
pipeline: pipeline,
tracking: session_1.Tracking.toProto(tracking),
values: values
};
var err = proto_1.sajari.api.pipeline.v1.AddRequest.verify(req);
if (err) {
throw new Error("sajari: failed to verify AddRequest message: " + err);
}
return proto_1.sajari.api.pipeline.v1.SearchRequest.create(req);
};
/**
* @hidden
*/
function parseSearchResponse(raw) {
var msg = proto_1.sajari.api.pipeline.v1.SearchResponse.verify(raw);
var msg = proto_1.sajari.pipeline.v2.SearchResponse.verify(raw);
if (msg !== null) {
throw new Error(msg);
}
var response = proto_1.sajari.api.pipeline.v1.SearchResponse.create(raw);
var searchResponse = response.searchResponse;
var searchResponse = raw.queryResults;
var results = [];

@@ -37,8 +22,8 @@ var aggregates = {};

var totalResults = 0;
var time = 0;
if (searchResponse !== null) {
results = processResults(searchResponse.results, response.tokens);
var latency = 0;
if (searchResponse != null) {
results = processResults(searchResponse.results, raw.tokens);
reads = searchResponse.reads;
totalResults = searchResponse.totalResults;
time = parseFloat(searchResponse.time);
latency = protoUtils_1.parseDuration(searchResponse.latency);
if (Object.keys(searchResponse.aggregates).length > 0) {

@@ -54,3 +39,3 @@ aggregates = processAggregatesResponse(searchResponse.aggregates);

totalResults: totalResults,
time: time,
latency: latency,
results: results,

@@ -67,3 +52,3 @@ aggregates: aggregates,

return results.map(function (res, idx) {
var err = proto_1.sajari.engine.query.v1.Result.verify(res);
var err = proto_1.sajari.engine.v2.QueryResult.verify(res);
if (err) {

@@ -74,3 +59,3 @@ throw new Error("sajari: unable to verify Result message: " + err);

var values = Object.keys(result.values).reduce(function (vals, key) {
vals[key] = utils_1.Value.fromProto(result.values[key]);
vals[key] = types_1.ValueFromProto(result.values[key]);
return vals;

@@ -80,3 +65,3 @@ }, {});

if (tokens.length > idx) {
token = session_1.Token.fromProto(tokens[idx]);
token = session_1.TokenFromProto(tokens[idx]);
}

@@ -87,3 +72,3 @@ return {

values: values,
tokens: token
token: token
};

@@ -99,3 +84,3 @@ });

var value = aggregates[key];
switch (value.aggregateResponse) {
switch (value.aggregateResult) {
case "metric":

@@ -102,0 +87,0 @@ result[key] = value.metric.value;

46

dist/pipeline/session.d.ts
import { sajari } from "../../generated/proto";
/**
* Tracking defines behaviour for handling search sessions and result interactions.
* Tracking defines behaviour for handling search sessions
* and result interactions.
*/

@@ -9,3 +10,6 @@ export interface Tracking {

sequence?: number;
/** field is a unique field on each result used to associate tracking information to the result. */
/**
* field is a unique field on each result used to associate
* tracking information to the result.
*/
field?: string;

@@ -17,12 +21,10 @@ /** data values which will be recorded along with query requests. */

}
export declare namespace Tracking {
/**
* @hidden
*/
function toProto(t: Tracking): sajari.api.query.v1.SearchRequest.Tracking;
}
/**
* Session takes query values, maintains session state, and returns tracking data
* to be sent with search requests.
* @hidden
*/
export declare function TrackingToProto(t: Tracking): sajari.pipeline.v2.Tracking;
/**
* Session takes query values, maintains session state, and returns
* tracking data to be sent with search requests.
*/
export interface Session {

@@ -34,3 +36,6 @@ next(values: {

}
/** TrackingType defines the possible result-interaction tracking types used by [[DefaultSession]] */
/**
* TrackingType defines the possible result-interaction tracking
* types used by [[DefaultSession]]
*/
export declare enum TrackingType {

@@ -44,5 +49,6 @@ /** None disables tracking. */

}
export declare namespace TrackingType {
function toProto(t: TrackingType): sajari.api.query.v1.SearchRequest.Tracking.Type;
}
/**
* @hidden
*/
export declare function TrackingTypeToProto(t: TrackingType): sajari.pipeline.v2.Tracking.Type;
export interface ClickToken {

@@ -56,5 +62,6 @@ click: string;

export declare type Token = ClickToken | PosNegToken;
export declare namespace Token {
function fromProto(t: sajari.api.query.v1.IToken): Token;
}
/**
* @hidden
*/
export declare function TokenFromProto(t: sajari.pipeline.v2.IToken): Token;
/** DefaultSession holds state of a sequence of searches. */

@@ -86,3 +93,6 @@ export declare class DefaultSession implements Session {

});
/** next merges new values into the session and returns tracking data to be sent with search requests. */
/**
* next merges new values into the session and returns tracking data
* to be sent with search requests.
*/
next(values: {

@@ -89,0 +99,0 @@ [k: string]: string;

102

dist/pipeline/session.js

@@ -8,14 +8,14 @@ "use strict";

var proto_1 = require("../../generated/proto");
var Tracking;
(function (Tracking) {
/**
* @hidden
*/
function toProto(t) {
var tracking = deepmerge_1.default(t, { type: TrackingType.toProto(t.type) });
return proto_1.sajari.api.query.v1.SearchRequest.Tracking.create(tracking);
}
Tracking.toProto = toProto;
})(Tracking = exports.Tracking || (exports.Tracking = {}));
/** TrackingType defines the possible result-interaction tracking types used by [[DefaultSession]] */
/**
* @hidden
*/
function TrackingToProto(t) {
var tracking = deepmerge_1.default(t, { type: TrackingTypeToProto(t.type) });
return proto_1.sajari.pipeline.v2.Tracking.create(tracking);
}
exports.TrackingToProto = TrackingToProto;
/**
* TrackingType defines the possible result-interaction tracking
* types used by [[DefaultSession]]
*/
var TrackingType;

@@ -30,42 +30,43 @@ (function (TrackingType) {

})(TrackingType = exports.TrackingType || (exports.TrackingType = {}));
(function (TrackingType) {
function toProto(t) {
switch (t) {
case TrackingType.Click:
return proto_1.sajari.api.query.v1.SearchRequest.Tracking.Type.CLICK;
case TrackingType.PosNeg:
return proto_1.sajari.api.query.v1.SearchRequest.Tracking.Type.POS_NEG;
case TrackingType.None:
default:
return proto_1.sajari.api.query.v1.SearchRequest.Tracking.Type.NONE;
/**
* @hidden
*/
function TrackingTypeToProto(t) {
switch (t) {
case TrackingType.Click:
return proto_1.sajari.pipeline.v2.Tracking.Type.CLICK;
case TrackingType.PosNeg:
return proto_1.sajari.pipeline.v2.Tracking.Type.POS_NEG;
case TrackingType.None:
default:
return proto_1.sajari.pipeline.v2.Tracking.Type.NONE;
}
}
exports.TrackingTypeToProto = TrackingTypeToProto;
/**
* @hidden
*/
function TokenFromProto(t) {
if (t.click != null) {
if (t.click.token === "" || t.click.token == null) {
throw new Error("sajari: invalid click token");
}
return {
click: t.click.token
};
}
TrackingType.toProto = toProto;
})(TrackingType = exports.TrackingType || (exports.TrackingType = {}));
var Token;
(function (Token) {
function fromProto(t) {
if (t.click != null) {
if (t.click.token === "" || t.click.token == null) {
throw new Error("sajari: invalid click token");
}
return {
click: t.click.token
};
else if (t.posNeg != null) {
if (t.posNeg.pos === "" ||
t.posNeg.neg === "" ||
(t.posNeg.pos == null || t.posNeg.neg == null)) {
throw new Error("sajari: invalid posNeg token");
}
else if (t.posNeg != null) {
if (t.posNeg.pos === "" ||
t.posNeg.neg === "" ||
(t.posNeg.pos == null || t.posNeg.neg == null)) {
throw new Error("sajari: invalid posNeg token");
}
return {
pos: t.posNeg.pos,
neg: t.posNeg.neg
};
}
throw new Error("sajari: invalid token type");
return {
pos: t.posNeg.pos,
neg: t.posNeg.neg
};
}
Token.fromProto = fromProto;
})(Token = exports.Token || (exports.Token = {}));
throw new Error("sajari: invalid token type");
}
exports.TokenFromProto = TokenFromProto;
/** DefaultSession holds state of a sequence of searches. */

@@ -87,3 +88,6 @@ var DefaultSession = /** @class */ (function () {

}
/** next merges new values into the session and returns tracking data to be sent with search requests. */
/**
* next merges new values into the session and returns tracking data
* to be sent with search requests.
*/
DefaultSession.prototype.next = function (values) {

@@ -90,0 +94,0 @@ if (this.queryID === "") {

4

dist/retryInterceptor.d.ts
import { InterceptingCall } from "grpc";
/**
* https://github.com/grpc/proposal/pull/14/files#diff-c1aee0ddae63a3e9a9ba050796cd4b58R325
* @hidden
*/
export default function retryInterceptor(maxRetries?: number): (options: any, nextCall: any) => InterceptingCall;

9

dist/retryInterceptor.js

@@ -10,3 +10,6 @@ "use strict";

var debug = debug_1.default("sajari:api:retryInterceptor");
// https://github.com/grpc/proposal/pull/14/files#diff-c1aee0ddae63a3e9a9ba050796cd4b58R325
/**
* https://github.com/grpc/proposal/pull/14/files#diff-c1aee0ddae63a3e9a9ba050796cd4b58R325
* @hidden
*/
function retryInterceptor(maxRetries) {

@@ -57,4 +60,4 @@ if (maxRetries === void 0) { maxRetries = 3; }

newCall.start(metadata, retryListener);
newCall.sendMessage(savedSendMessage); // Added Call
newCall.halfClose(); // Added Call
newCall.sendMessage(savedSendMessage);
newCall.halfClose();
}

@@ -61,0 +64,0 @@ if (status.code !== grpc_1.status.OK &&

18

dist/schema/client.d.ts

@@ -9,6 +9,18 @@ import { APIClient, CallOptions } from "../api";

private client;
/**
* @hidden
*/
constructor(client: APIClient);
fields(options?: CallOptions): Promise<Field[]>;
add(fields: Field[], options?: CallOptions): Promise<void>;
mutateField(name: string, mutations: Mutation[], options?: CallOptions): Promise<void>;
/**
* listFields returns the fields in the schema.
*/
listFields(options?: CallOptions): Promise<Field[]>;
/**
* createField creates a new field in the schema.
*/
createField(field: Field, options?: CallOptions): Promise<void>;
/**
* mutateField mutates a field in the schema.
*/
mutateField(name: string, mutation: Mutation, options?: CallOptions): Promise<void>;
}

88

dist/schema/client.js

@@ -39,36 +39,53 @@ "use strict";

var proto_1 = require("../../generated/proto");
var utils_1 = require("../utils");
var field_1 = require("./field");
var utils_2 = require("./utils");
var mutation_1 = require("./mutation");
/**
* grpc method endpoint for getting the current schema fields
* ListFields returns the fields in the schema.
* @hidden
*/
var GetFieldsMethod = "sajari.engine.schema.Schema/GetFields";
var ListFieldsMethod = "sajari.engine.v2.Schema/ListFields";
/**
* grpc method endpoint for adding fields to the schema
* CreateField create a new field in the schema.
* @hidden
*/
var AddFieldsMethod = "sajari.engine.schema.Schema/AddFields";
var CreateFieldMethod = "sajari.engine.v2.Schema/CreateField";
/**
* grpc method endpoint for mutating a schema field
* MutateField mutates a field in the schema.
* @hidden
*/
var MutateFieldMethod = "sajari.engine.schema.Schema/MutateField";
var MutateFieldMethod = "sajari.engine.v2.Schema/MutateField";
var Schema = /** @class */ (function () {
/**
* @hidden
*/
function Schema(client) {
this.client = client;
}
// fields returns the fields in the collection.
Schema.prototype.fields = function (options) {
/**
* listFields returns the fields in the schema.
*/
Schema.prototype.listFields = function (options) {
return __awaiter(this, void 0, void 0, function () {
var request, response;
var fields, pageToken, request, response;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = new proto_1.sajari.rpc.Empty();
return [4 /*yield*/, this.client.call(GetFieldsMethod, request, proto_1.sajari.rpc.Empty.encode, proto_1.sajari.engine.schema.Fields.decode, options)];
fields = [];
pageToken = "";
_a.label = 1;
case 1:
if (!true) return [3 /*break*/, 3];
request = proto_1.sajari.engine.v2.ListFieldsRequest.create({
pageToken: pageToken
});
return [4 /*yield*/, this.client.call(ListFieldsMethod, request, proto_1.sajari.engine.v2.ListFieldsRequest.encode, proto_1.sajari.engine.v2.ListFieldsResponse.decode, options)];
case 2:
response = _a.sent();
return [2 /*return*/, response.fields.map(field_1.Field.fromProto)];
fields = fields.concat(response.fields.map(field_1.FieldFromProto));
if (response.nextPageToken === "") {
return [3 /*break*/, 3];
}
pageToken = response.nextPageToken;
return [3 /*break*/, 1];
case 3: return [2 /*return*/, fields];
}

@@ -78,17 +95,17 @@ });

};
// add adds Fields to the collection schema.
Schema.prototype.add = function (fields, options) {
/**
* createField creates a new field in the schema.
*/
Schema.prototype.createField = function (field, options) {
return __awaiter(this, void 0, void 0, function () {
var request, response, error;
var request;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = utils_2.createAddRequest(fields);
return [4 /*yield*/, this.client.call(AddFieldsMethod, request, proto_1.sajari.engine.schema.Fields.encode, proto_1.sajari.engine.schema.Response.decode, options)];
request = proto_1.sajari.engine.v2.CreateFieldRequest.create({
field: field_1.FieldToProto(field)
});
return [4 /*yield*/, this.client.call(CreateFieldMethod, request, proto_1.sajari.engine.v2.CreateFieldRequest.encode, proto_1.sajari.engine.v2.CreateFieldResponse.decode, options)];
case 1:
response = _a.sent();
error = utils_1.errorFromStatuses(response.status);
if (error) {
throw error;
}
_a.sent();
return [2 /*return*/];

@@ -99,19 +116,18 @@ }

};
// mutateField mutates a field identifier by name.
// Each mutation is performed in the order in which it is specified.
// If any fail, then the rest are ignored.
Schema.prototype.mutateField = function (name, mutations, options) {
/**
* mutateField mutates a field in the schema.
*/
Schema.prototype.mutateField = function (name, mutation, options) {
return __awaiter(this, void 0, void 0, function () {
var request, response, error;
var request;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
request = utils_2.createMutateFieldRequest(name, mutations);
return [4 /*yield*/, this.client.call(MutateFieldMethod, request, proto_1.sajari.engine.schema.MutateFieldRequest.encode, proto_1.sajari.engine.schema.Response.decode, options)];
request = proto_1.sajari.engine.v2.MutateFieldRequest.create({
name: name,
mutation: mutation_1.MutationToProto(mutation)
});
return [4 /*yield*/, this.client.call(MutateFieldMethod, request, proto_1.sajari.engine.v2.MutateFieldRequest.encode, proto_1.sajari.engine.v2.MutateFieldResponse.decode, options)];
case 1:
response = _a.sent();
error = utils_1.errorFromStatuses(response.status);
if (error) {
throw error;
}
_a.sent();
return [2 /*return*/];

@@ -118,0 +134,0 @@ }

73

dist/schema/field.d.ts
import { sajari } from "../../generated/proto";
/**
* Field represents a meta field which can be assigned in a collection record.
* Field defines the properties of a field in the schema.
*/
export interface Field {
/** Name is the name used to identify the field. */
name: string;
/** Description is a description of the field. */
description: string;
/**
* Type represents the underlying data type of the field.
* Default is a string.
*/
type: Type;
/** Mode defines the mode of the field. */
mode: FieldMode;
/** Repeated indicates that this field can hold a list of values. */
repeated: boolean;
indexed?: boolean;
}
export declare namespace Field {
/**
* @hidden
*/
function toProto(f: Field): sajari.engine.schema.Field;
/**
* @hidden
*/
function fromProto(f: sajari.engine.schema.IField): Field;
}
/**
* @hidden
*/
export declare function FieldToProto(f: Field): sajari.engine.v2.Field;
/**
* @hidden
*/
export declare function FieldFromProto(f: sajari.engine.v2.IField): Field;
/**
* Type represents the underlying data type of the field. Default is a string.

@@ -31,16 +36,14 @@ * @hidden

Float = 2,
Double = 5,
Boolean = 3,
Timestamp = 4
Double = 3,
Boolean = 4,
Timestamp = 5
}
export declare namespace Type {
/**
* @hidden
*/
function toProto(t: Type): sajari.engine.schema.Field.Type;
/**
* @hidden
*/
function fromProto(t: sajari.engine.schema.Field.Type): Type;
}
/**
* @hidden
*/
export declare function TypeToProto(t: Type): sajari.engine.v2.Field.Type;
/**
* @hidden
*/
export declare function TypeFromProto(t: sajari.engine.v2.Field.Type): Type;
export declare enum FieldMode {

@@ -61,14 +64,14 @@ /**

}
export declare namespace FieldMode {
/**
* @hidden
*/
function toProto(m: FieldMode): sajari.engine.schema.Field.Mode;
/**
* @hidden
*/
function fromProto(m: sajari.engine.schema.Field.Mode): FieldMode;
}
/**
* @hidden
*/
export declare function FieldModeToProto(m: FieldMode): sajari.engine.v2.Field.Mode;
/**
* @hidden
*/
export declare function FieldModeFromProto(m: sajari.engine.v2.Field.Mode): FieldMode;
export interface FieldOptions {
/** Description is a description of the field. */
description?: string;
/** Repeated indicates that this field can hold a list of values. */
repeated?: boolean;

@@ -75,0 +78,0 @@ mode?: FieldMode;

196

dist/schema/field.js

@@ -8,34 +8,30 @@ "use strict";

var proto_1 = require("../../generated/proto");
var Field;
(function (Field) {
/**
* @hidden
*/
function toProto(f) {
return new proto_1.sajari.engine.schema.Field(deepmerge_1.default(f, {
mode: FieldMode.toProto(f.mode),
type: Type.toProto(f.type)
}));
/**
* @hidden
*/
function FieldToProto(f) {
return proto_1.sajari.engine.v2.Field.create(deepmerge_1.default(f, {
mode: FieldModeToProto(f.mode),
type: TypeToProto(f.type)
}));
}
exports.FieldToProto = FieldToProto;
/**
* @hidden
*/
function FieldFromProto(f) {
var err = proto_1.sajari.engine.v2.Field.verify(f);
if (err) {
throw new Error("sajari: failed to verify Field message: " + err);
}
Field.toProto = toProto;
/**
* @hidden
*/
function fromProto(f) {
var err = proto_1.sajari.engine.schema.Field.verify(f);
if (err) {
throw new Error("sajari: failed to verify Field message: " + err);
}
var engineField = f;
return {
name: engineField.name,
description: engineField.description,
type: Type.fromProto(engineField.type),
mode: FieldMode.fromProto(engineField.mode),
repeated: engineField.repeated,
indexed: engineField.indexed
};
}
Field.fromProto = fromProto;
})(Field = exports.Field || (exports.Field = {}));
var engineField = f;
return {
name: engineField.name,
description: engineField.description,
type: TypeFromProto(engineField.type),
mode: FieldModeFromProto(engineField.mode),
repeated: engineField.repeated
};
}
exports.FieldFromProto = FieldFromProto;
/**

@@ -50,48 +46,46 @@ * Type represents the underlying data type of the field. Default is a string.

Type[Type["Float"] = 2] = "Float";
Type[Type["Double"] = 5] = "Double";
Type[Type["Boolean"] = 3] = "Boolean";
Type[Type["Timestamp"] = 4] = "Timestamp";
Type[Type["Double"] = 3] = "Double";
Type[Type["Boolean"] = 4] = "Boolean";
Type[Type["Timestamp"] = 5] = "Timestamp";
})(Type = exports.Type || (exports.Type = {}));
(function (Type) {
/**
* @hidden
*/
function toProto(t) {
switch (t) {
case Type.Integer:
return proto_1.sajari.engine.schema.Field.Type.INTEGER;
case Type.Float:
return proto_1.sajari.engine.schema.Field.Type.FLOAT;
case Type.Double:
return proto_1.sajari.engine.schema.Field.Type.DOUBLE;
case Type.Boolean:
return proto_1.sajari.engine.schema.Field.Type.BOOLEAN;
case Type.Timestamp:
return proto_1.sajari.engine.schema.Field.Type.TIMESTAMP;
default:
return proto_1.sajari.engine.schema.Field.Type.STRING;
}
/**
* @hidden
*/
function TypeToProto(t) {
switch (t) {
case Type.Integer:
return proto_1.sajari.engine.v2.Field.Type.INTEGER;
case Type.Float:
return proto_1.sajari.engine.v2.Field.Type.FLOAT;
case Type.Double:
return proto_1.sajari.engine.v2.Field.Type.DOUBLE;
case Type.Boolean:
return proto_1.sajari.engine.v2.Field.Type.BOOLEAN;
case Type.Timestamp:
return proto_1.sajari.engine.v2.Field.Type.TIMESTAMP;
default:
return proto_1.sajari.engine.v2.Field.Type.STRING;
}
Type.toProto = toProto;
/**
* @hidden
*/
function fromProto(t) {
switch (t) {
case proto_1.sajari.engine.schema.Field.Type.INTEGER:
return Type.Integer;
case proto_1.sajari.engine.schema.Field.Type.FLOAT:
return Type.Float;
case proto_1.sajari.engine.schema.Field.Type.DOUBLE:
return Type.Double;
case proto_1.sajari.engine.schema.Field.Type.BOOLEAN:
return Type.Boolean;
case proto_1.sajari.engine.schema.Field.Type.TIMESTAMP:
return Type.Timestamp;
default:
return Type.String;
}
}
exports.TypeToProto = TypeToProto;
/**
* @hidden
*/
function TypeFromProto(t) {
switch (t) {
case proto_1.sajari.engine.v2.Field.Type.INTEGER:
return Type.Integer;
case proto_1.sajari.engine.v2.Field.Type.FLOAT:
return Type.Float;
case proto_1.sajari.engine.v2.Field.Type.DOUBLE:
return Type.Double;
case proto_1.sajari.engine.v2.Field.Type.BOOLEAN:
return Type.Boolean;
case proto_1.sajari.engine.v2.Field.Type.TIMESTAMP:
return Type.Timestamp;
default:
return Type.String;
}
Type.fromProto = fromProto;
})(Type = exports.Type || (exports.Type = {}));
}
exports.TypeFromProto = TypeFromProto;
var FieldMode;

@@ -113,32 +107,30 @@ (function (FieldMode) {

})(FieldMode = exports.FieldMode || (exports.FieldMode = {}));
(function (FieldMode) {
/**
* @hidden
*/
function toProto(m) {
switch (m) {
case FieldMode.Required:
return proto_1.sajari.engine.schema.Field.Mode.REQUIRED;
case FieldMode.Unique:
return proto_1.sajari.engine.schema.Field.Mode.UNIQUE;
default:
return proto_1.sajari.engine.schema.Field.Mode.NULLABLE;
}
/**
* @hidden
*/
function FieldModeToProto(m) {
switch (m) {
case FieldMode.Required:
return proto_1.sajari.engine.v2.Field.Mode.REQUIRED;
case FieldMode.Unique:
return proto_1.sajari.engine.v2.Field.Mode.UNIQUE;
default:
return proto_1.sajari.engine.v2.Field.Mode.NULLABLE;
}
FieldMode.toProto = toProto;
/**
* @hidden
*/
function fromProto(m) {
switch (m) {
case proto_1.sajari.engine.schema.Field.Mode.REQUIRED:
return FieldMode.Required;
case proto_1.sajari.engine.schema.Field.Mode.UNIQUE:
return FieldMode.Unique;
default:
return FieldMode.Nullable;
}
}
exports.FieldModeToProto = FieldModeToProto;
/**
* @hidden
*/
function FieldModeFromProto(m) {
switch (m) {
case proto_1.sajari.engine.v2.Field.Mode.REQUIRED:
return FieldMode.Required;
case proto_1.sajari.engine.v2.Field.Mode.UNIQUE:
return FieldMode.Unique;
default:
return FieldMode.Nullable;
}
FieldMode.fromProto = fromProto;
})(FieldMode = exports.FieldMode || (exports.FieldMode = {}));
}
exports.FieldModeFromProto = FieldModeFromProto;
/**

@@ -145,0 +137,0 @@ * @hidden

2

dist/schema/index.d.ts

@@ -16,3 +16,3 @@ export { Mutation, NameMutation, DescriptionMutation, TypeMutation, RepeatedMutation } from "./mutation";

description: (d: string) => import("./mutation").DescriptionMutation;
type: (t: Type) => import("./mutation").TypeMutation;
type: (t: import("./field").Type) => import("./mutation").TypeMutation;
repeated: (b: boolean) => import("./mutation").RepeatedMutation;

@@ -19,0 +19,0 @@ };

2

dist/schema/index.js

@@ -5,4 +5,2 @@ "use strict";

var mutation_1 = require("./mutation");
var mutation_2 = require("./mutation");
exports.Mutation = mutation_2.Mutation;
var field_2 = require("./field");

@@ -9,0 +7,0 @@ exports.FieldMode = field_2.FieldMode;

15

dist/schema/mutation.d.ts
import { sajari } from "../../generated/proto";
import { Type } from "./field";
/** Mutation is a mutation of a schema field. */
export declare type Mutation = NameMutation | DescriptionMutation | TypeMutation | RepeatedMutation;
export declare namespace Mutation {
/**
* @hidden
*/
function toProto(m: Mutation): sajari.engine.schema.MutateFieldRequest.Mutation;
}
/**
* @hidden
*/
export declare function MutationToProto(m: Mutation): sajari.engine.v2.MutateFieldRequest.Mutation;
export interface NameMutation {
/** Name is a new name for the field. */
name: string;
}
export interface DescriptionMutation {
/** Description is the new description for the field. */
description: string;
}
export interface TypeMutation {
/** Type changes the underlying type of the field. */
type: Type;
}
export interface RepeatedMutation {
/** Repeated sets whether the field values are repeated. */
repeated: boolean;

@@ -21,0 +24,0 @@ }

23

dist/schema/mutation.js

@@ -5,16 +5,13 @@ "use strict";

var field_1 = require("./field");
var Mutation;
(function (Mutation) {
/**
* @hidden
*/
function toProto(m) {
var mut = m;
if ("type" in mut) {
mut.type = field_1.Type.toProto(mut.type);
}
return proto_1.sajari.engine.schema.MutateFieldRequest.Mutation.create(mut);
/**
* @hidden
*/
function MutationToProto(m) {
var mut = m;
if ("type" in mut) {
mut.type = field_1.TypeToProto(mut.type);
}
Mutation.toProto = toProto;
})(Mutation = exports.Mutation || (exports.Mutation = {}));
return proto_1.sajari.engine.v2.MutateFieldRequest.Mutation.create(mut);
}
exports.MutationToProto = MutationToProto;
function name(n) {

@@ -21,0 +18,0 @@ return {

32

package.json
{
"name": "@sajari/sdk-node",
"version": "1.0.0-beta.7",
"version": "2.0.0-beta.1",
"main": "dist/index.js",

@@ -32,22 +32,22 @@ "types": "dist/index.d.ts",

"dependencies": {
"debug": "^4.1.0",
"deepmerge": "^2.2.1",
"grpc": "1.15.1",
"debug": "^4.1.1",
"deepmerge": "^3.2.0",
"grpc": "1.16.1",
"protobufjs": "^6.8.8"
},
"devDependencies": {
"@types/debug": "0.0.31",
"@types/jest": "^23.3.9",
"globby": "^8.0.1",
"@types/debug": "^4.1.2",
"@types/jest": "^24.0.11",
"globby": "^9.1.0",
"grpc-tools": "^1.7.1",
"jest": "^23.6.0",
"make-dir": "^1.3.0",
"npm-run-all": "^4.1.3",
"prettier": "^1.15.2",
"ts-jest": "^23.10.4",
"tslint": "^5.11.0",
"tslint-config-prettier": "^1.16.0",
"typedoc": "^0.13.0",
"typescript": "^3.1.6"
"jest": "^24.5.0",
"make-dir": "^2.1.0",
"npm-run-all": "^4.1.5",
"prettier": "^1.16.4",
"ts-jest": "^24.0.0",
"tslint": "^5.14.0",
"tslint-config-prettier": "^1.18.0",
"typedoc": "^0.14.2",
"typescript": "^3.3.3333"
}
}

7

README.md
# @sajari/sdk-node
> Node.js SDK for Sajari APIs
> Node.js SDK for Sajari APIs <br/>
> NOTE: THIS IS STILL IN ALPHA

@@ -61,3 +62,3 @@ ## Getting Started

// get the pipeline client
const pipeline = client.pipeline("<your pipeline name>")
const pipeline = client.pipeline({name: "<your pipeline name>", version: "<your pipeline version>"});

@@ -84,3 +85,3 @@ const record = {

const session = new DefaultSession(TrackingType.None);
const pipeline = client.pipeline("<your pipeline name>");
const pipeline = client.pipeline({name: "<your pipeline name>", version: "<your pipeline version>"});
const values = { q: "hello" };

@@ -87,0 +88,0 @@ 

generated/proto-defs.json

Sorry, the diff of this file is too big to display

generated/proto.d.ts

Sorry, the diff of this file is too big to display

generated/proto.js

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc