You've already forked npm-core-sdk
Latest generation
This commit is contained in:
ci core model
@@ -2880,14 +2880,14 @@ export const AppointmentCarrierDepartedResponse = new AppointmentCarrierDeparted
|
||||
* @generated ServiceType for protobuf service api.AppointmentInputAPI
|
||||
*/
|
||||
export const AppointmentInputAPI = new ServiceType("api.AppointmentInputAPI", [
|
||||
{ name: "Created", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment has been created." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCreatedRequest, O: AppointmentCreatedResponse },
|
||||
{ name: "Canceled", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment has been canceled." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCanceledRequest, O: AppointmentCanceledResponse },
|
||||
{ name: "CarrierInformationUpdated", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment carrier information have been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierInformationUpdatedRequest, O: AppointmentCarrierInformationUpdatedResponse },
|
||||
{ name: "CarrierExpected", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is exopected for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierExpectedRequest, O: AppointmentCarrierExpectedResponse },
|
||||
{ name: "CarrierArrived", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is arrived for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierArrivedRequest, O: AppointmentCarrierArrivedResponse },
|
||||
{ name: "ExpeditionStarted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment expedition is started." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentExpeditionStartedRequest, O: AppointmentExpeditionStartedResponse },
|
||||
{ name: "ExpeditionLoaded", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment expedition is loaded." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentExpeditionLoadedRequest, O: AppointmentExpeditionLoadedResponse },
|
||||
{ name: "ReceptionStarted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment reception is started." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentReceptionStartedRequest, O: AppointmentReceptionStartedResponse },
|
||||
{ name: "ReceptionUnloaded", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment reception is unloaded." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentReceptionUnloadedRequest, O: AppointmentReceptionUnloadedResponse },
|
||||
{ name: "CarrierDeparted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is departed for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierDepartedRequest, O: AppointmentCarrierDepartedResponse }
|
||||
{ name: "Created", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment has been created." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCreatedRequest, O: AppointmentCreatedResponse },
|
||||
{ name: "Canceled", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment has been canceled." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCanceledRequest, O: AppointmentCanceledResponse },
|
||||
{ name: "CarrierInformationUpdated", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "An appointment carrier information have been updated." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierInformationUpdatedRequest, O: AppointmentCarrierInformationUpdatedResponse },
|
||||
{ name: "CarrierExpected", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is exopected for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierExpectedRequest, O: AppointmentCarrierExpectedResponse },
|
||||
{ name: "CarrierArrived", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is arrived for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierArrivedRequest, O: AppointmentCarrierArrivedResponse },
|
||||
{ name: "ExpeditionStarted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment expedition is started." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentExpeditionStartedRequest, O: AppointmentExpeditionStartedResponse },
|
||||
{ name: "ExpeditionLoaded", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment expedition is loaded." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentExpeditionLoadedRequest, O: AppointmentExpeditionLoadedResponse },
|
||||
{ name: "ReceptionStarted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment reception is started." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentReceptionStartedRequest, O: AppointmentReceptionStartedResponse },
|
||||
{ name: "ReceptionUnloaded", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The appointment reception is unloaded." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentReceptionUnloadedRequest, O: AppointmentReceptionUnloadedResponse },
|
||||
{ name: "CarrierDeparted", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Input", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Inputs"], description: "The carrier is departed for the appointment." }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentCarrierDepartedRequest, O: AppointmentCarrierDepartedResponse }
|
||||
], { "api.serviceType": "Api", "api.k8sService": "collab-api-server" });
|
||||
|
||||
@@ -7,11 +7,11 @@ import { AppointmentQuery } from "./appointmentQuery";
|
||||
import type { CountLinesResult } from "./shared";
|
||||
import type { CountLinesQuery } from "./shared";
|
||||
import type { GetKPIDataResult } from "./clickhouse";
|
||||
import type { GetKPIDataQuery } from "./clickhouse";
|
||||
import type { GetKPIDataSiteQuery } from "./clickhouse";
|
||||
import type { ExtractResult } from "./shared";
|
||||
import type { ExtractQuery } from "./shared";
|
||||
import type { ExtractSiteQuery } from "./shared";
|
||||
import type { ElementByMatchResult } from "./shared";
|
||||
import type { ElementByMatchQuery } from "./shared";
|
||||
import type { ElementByMatchSiteQuery } from "./shared";
|
||||
import type { AppointmentByMatchResult } from "./appointmentQuery";
|
||||
import type { AppointmentByMatchQuery } from "./appointmentQuery";
|
||||
import type { AppointmentByFilterResult } from "./appointmentQuery";
|
||||
@@ -38,17 +38,17 @@ export interface IAppointmentQueryClient {
|
||||
*/
|
||||
findMatchingFieldValues(input: AppointmentByMatchQuery, options?: RpcOptions): UnaryCall<AppointmentByMatchQuery, AppointmentByMatchResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: FindMatchingFieldElements(api.ElementByMatchQuery) returns (api.ElementByMatchResult);
|
||||
* @generated from protobuf rpc: FindMatchingFieldElements(api.ElementByMatchSiteQuery) returns (api.ElementByMatchResult);
|
||||
*/
|
||||
findMatchingFieldElements(input: ElementByMatchQuery, options?: RpcOptions): UnaryCall<ElementByMatchQuery, ElementByMatchResult>;
|
||||
findMatchingFieldElements(input: ElementByMatchSiteQuery, options?: RpcOptions): UnaryCall<ElementByMatchSiteQuery, ElementByMatchResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: Extract(api.ExtractQuery) returns (api.ExtractResult);
|
||||
* @generated from protobuf rpc: Extract(api.ExtractSiteQuery) returns (api.ExtractResult);
|
||||
*/
|
||||
extract(input: ExtractQuery, options?: RpcOptions): UnaryCall<ExtractQuery, ExtractResult>;
|
||||
extract(input: ExtractSiteQuery, options?: RpcOptions): UnaryCall<ExtractSiteQuery, ExtractResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: GetKPIData(api.GetKPIDataQuery) returns (api.GetKPIDataResult);
|
||||
* @generated from protobuf rpc: GetKPIData(api.GetKPIDataSiteQuery) returns (api.GetKPIDataResult);
|
||||
*/
|
||||
getKPIData(input: GetKPIDataQuery, options?: RpcOptions): UnaryCall<GetKPIDataQuery, GetKPIDataResult>;
|
||||
getKPIData(input: GetKPIDataSiteQuery, options?: RpcOptions): UnaryCall<GetKPIDataSiteQuery, GetKPIDataResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: CountLines(api.CountLinesQuery) returns (api.CountLinesResult);
|
||||
*/
|
||||
@@ -85,25 +85,25 @@ export class AppointmentQueryClient implements IAppointmentQueryClient, ServiceI
|
||||
return stackIntercept<AppointmentByMatchQuery, AppointmentByMatchResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: FindMatchingFieldElements(api.ElementByMatchQuery) returns (api.ElementByMatchResult);
|
||||
* @generated from protobuf rpc: FindMatchingFieldElements(api.ElementByMatchSiteQuery) returns (api.ElementByMatchResult);
|
||||
*/
|
||||
findMatchingFieldElements(input: ElementByMatchQuery, options?: RpcOptions): UnaryCall<ElementByMatchQuery, ElementByMatchResult> {
|
||||
findMatchingFieldElements(input: ElementByMatchSiteQuery, options?: RpcOptions): UnaryCall<ElementByMatchSiteQuery, ElementByMatchResult> {
|
||||
const method = this.methods[3], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ElementByMatchQuery, ElementByMatchResult>("unary", this._transport, method, opt, input);
|
||||
return stackIntercept<ElementByMatchSiteQuery, ElementByMatchResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: Extract(api.ExtractQuery) returns (api.ExtractResult);
|
||||
* @generated from protobuf rpc: Extract(api.ExtractSiteQuery) returns (api.ExtractResult);
|
||||
*/
|
||||
extract(input: ExtractQuery, options?: RpcOptions): UnaryCall<ExtractQuery, ExtractResult> {
|
||||
extract(input: ExtractSiteQuery, options?: RpcOptions): UnaryCall<ExtractSiteQuery, ExtractResult> {
|
||||
const method = this.methods[4], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<ExtractQuery, ExtractResult>("unary", this._transport, method, opt, input);
|
||||
return stackIntercept<ExtractSiteQuery, ExtractResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: GetKPIData(api.GetKPIDataQuery) returns (api.GetKPIDataResult);
|
||||
* @generated from protobuf rpc: GetKPIData(api.GetKPIDataSiteQuery) returns (api.GetKPIDataResult);
|
||||
*/
|
||||
getKPIData(input: GetKPIDataQuery, options?: RpcOptions): UnaryCall<GetKPIDataQuery, GetKPIDataResult> {
|
||||
getKPIData(input: GetKPIDataSiteQuery, options?: RpcOptions): UnaryCall<GetKPIDataSiteQuery, GetKPIDataResult> {
|
||||
const method = this.methods[5], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GetKPIDataQuery, GetKPIDataResult>("unary", this._transport, method, opt, input);
|
||||
return stackIntercept<GetKPIDataSiteQuery, GetKPIDataResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: CountLines(api.CountLinesQuery) returns (api.CountLinesResult);
|
||||
|
||||
@@ -4,11 +4,11 @@
|
||||
import { CountLinesResult } from "./shared";
|
||||
import { CountLinesQuery } from "./shared";
|
||||
import { GetKPIDataResult } from "./clickhouse";
|
||||
import { GetKPIDataQuery } from "./clickhouse";
|
||||
import { GetKPIDataSiteQuery } from "./clickhouse";
|
||||
import { ExtractResult } from "./shared";
|
||||
import { ExtractQuery } from "./shared";
|
||||
import { ExtractSiteQuery } from "./shared";
|
||||
import { ElementByMatchResult } from "./shared";
|
||||
import { ElementByMatchQuery } from "./shared";
|
||||
import { ElementByMatchSiteQuery } from "./shared";
|
||||
import { ServiceType } from "@protobuf-ts/runtime-rpc";
|
||||
import type { BinaryWriteOptions } from "@protobuf-ts/runtime";
|
||||
import type { IBinaryWriter } from "@protobuf-ts/runtime";
|
||||
@@ -25,7 +25,7 @@ import { BlockFilter } from "./shared";
|
||||
import { Appointment } from "./appointment";
|
||||
import { ResultHeader } from "./shared";
|
||||
import { EntityID } from "./shared";
|
||||
import { QueryProjectHeader } from "./shared";
|
||||
import { QuerySiteHeader } from "./shared";
|
||||
//
|
||||
// Query-server services
|
||||
|
||||
@@ -34,9 +34,9 @@ import { QueryProjectHeader } from "./shared";
|
||||
*/
|
||||
export interface AppointmentByIdQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QueryProjectHeader Header = 1 [json_name = "Header"];
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QueryProjectHeader;
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* @generated from protobuf field: repeated api.EntityID IDs = 2 [json_name = "IDs"];
|
||||
*/
|
||||
@@ -60,9 +60,9 @@ export interface AppointmentByIdResult {
|
||||
*/
|
||||
export interface AppointmentByFilterQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QueryProjectHeader Header = 1 [json_name = "Header"];
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QueryProjectHeader;
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* Number of maximum result
|
||||
*
|
||||
@@ -102,9 +102,9 @@ export interface AppointmentByFilterResult {
|
||||
*/
|
||||
export interface AppointmentByMatchQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QueryProjectHeader Header = 1 [json_name = "Header"];
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QueryProjectHeader;
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* list of blockFilters structure for Find query, each element (BlockFilter) in the list is an "OR" part of the query, if not empty, simpleFilters (deprecated) & rangeFilters (deprecated) will be ignored
|
||||
*
|
||||
@@ -131,7 +131,7 @@ export interface AppointmentByMatchResult {
|
||||
class AppointmentByIdQuery$Type extends MessageType<AppointmentByIdQuery> {
|
||||
constructor() {
|
||||
super("api.AppointmentByIdQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QueryProjectHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 2, name: "IDs", kind: "message", localName: "IDs", jsonName: "IDs", repeat: 2 /*RepeatType.UNPACKED*/, T: () => EntityID, options: { "validate.rules": { repeated: { minItems: "1" } } } }
|
||||
], { "api.messageType": "Query", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "IDs"] } } });
|
||||
}
|
||||
@@ -147,8 +147,8 @@ class AppointmentByIdQuery$Type extends MessageType<AppointmentByIdQuery> {
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QueryProjectHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QueryProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* repeated api.EntityID IDs = 2 [json_name = "IDs"];*/ 2:
|
||||
message.IDs.push(EntityID.internalBinaryRead(reader, reader.uint32(), options));
|
||||
@@ -165,9 +165,9 @@ class AppointmentByIdQuery$Type extends MessageType<AppointmentByIdQuery> {
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: AppointmentByIdQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QueryProjectHeader Header = 1 [json_name = "Header"]; */
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QueryProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* repeated api.EntityID IDs = 2 [json_name = "IDs"]; */
|
||||
for (let i = 0; i < message.IDs.length; i++)
|
||||
EntityID.internalBinaryWrite(message.IDs[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join();
|
||||
@@ -239,7 +239,7 @@ export const AppointmentByIdResult = new AppointmentByIdResult$Type();
|
||||
class AppointmentByFilterQuery$Type extends MessageType<AppointmentByFilterQuery> {
|
||||
constructor() {
|
||||
super("api.AppointmentByFilterQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QueryProjectHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": {} } },
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": {} } },
|
||||
{ no: 4, name: "limitFilter", kind: "scalar", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of maximum result", example: "\"500\"" } } },
|
||||
{ no: 5, name: "queryContext", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 6, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter }
|
||||
@@ -259,8 +259,8 @@ class AppointmentByFilterQuery$Type extends MessageType<AppointmentByFilterQuery
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QueryProjectHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QueryProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* string limitFilter */ 4:
|
||||
message.limitFilter = reader.string();
|
||||
@@ -283,9 +283,9 @@ class AppointmentByFilterQuery$Type extends MessageType<AppointmentByFilterQuery
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: AppointmentByFilterQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QueryProjectHeader Header = 1 [json_name = "Header"]; */
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QueryProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* string limitFilter = 4; */
|
||||
if (message.limitFilter !== "")
|
||||
writer.tag(4, WireType.LengthDelimited).string(message.limitFilter);
|
||||
@@ -371,7 +371,7 @@ export const AppointmentByFilterResult = new AppointmentByFilterResult$Type();
|
||||
class AppointmentByMatchQuery$Type extends MessageType<AppointmentByMatchQuery> {
|
||||
constructor() {
|
||||
super("api.AppointmentByMatchQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QueryProjectHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 5, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter },
|
||||
{ no: 6, name: "MatchFields", kind: "message", localName: "MatchFields", jsonName: "MatchFields", repeat: 2 /*RepeatType.UNPACKED*/, T: () => MatchField, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "MatchField list structure, for FindMatching query" } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } });
|
||||
@@ -389,8 +389,8 @@ class AppointmentByMatchQuery$Type extends MessageType<AppointmentByMatchQuery>
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QueryProjectHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QueryProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* repeated api.BlockFilter BlockFilters = 5 [json_name = "BlockFilters"];*/ 5:
|
||||
message.BlockFilters.push(BlockFilter.internalBinaryRead(reader, reader.uint32(), options));
|
||||
@@ -410,9 +410,9 @@ class AppointmentByMatchQuery$Type extends MessageType<AppointmentByMatchQuery>
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: AppointmentByMatchQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QueryProjectHeader Header = 1 [json_name = "Header"]; */
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QueryProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* repeated api.BlockFilter BlockFilters = 5 [json_name = "BlockFilters"]; */
|
||||
for (let i = 0; i < message.BlockFilters.length; i++)
|
||||
BlockFilter.internalBinaryWrite(message.BlockFilters[i], writer.tag(5, WireType.LengthDelimited).fork(), options).join();
|
||||
@@ -480,11 +480,11 @@ export const AppointmentByMatchResult = new AppointmentByMatchResult$Type();
|
||||
* @generated ServiceType for protobuf service api.AppointmentQuery
|
||||
*/
|
||||
export const AppointmentQuery = new ServiceType("api.AppointmentQuery", [
|
||||
{ name: "GetByIds", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Query", "api.moduleID": "appointment", "api.tableName": "appointmentById", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Get Appointments from Ids" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByIdQuery, O: AppointmentByIdResult },
|
||||
{ name: "Find", options: { "api.customQuery": true, "api.rscType": "Site", "api.roles": "Platform.Site-Query", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Find Appointments using search criterias" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByFilterQuery, O: AppointmentByFilterResult },
|
||||
{ name: "FindMatchingFieldValues", options: { "api.customQuery": true, "api.rscType": "Site", "api.roles": "", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Using search criteria & a main field word, find the list of fields containing the searched word (used for auto completion purposes ...) " }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByMatchQuery, O: AppointmentByMatchResult },
|
||||
{ name: "FindMatchingFieldElements", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "using search criteria & a main field word, find the list of field elements containing the searched word (used for auto completion purposes ...) " }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ElementByMatchQuery, O: ElementByMatchResult },
|
||||
{ name: "Extract", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Schedule a data extraction" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExtractQuery, O: ExtractResult },
|
||||
{ name: "GetKPIData", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Get Appointment KPI data" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: GetKPIDataQuery, O: GetKPIDataResult },
|
||||
{ name: "CountLines", options: { "api.rscType": "Platform", "api.roles": "Platform.Site-Query", "api.moduleID": "appointment", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Count lines in database for project" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: CountLinesQuery, O: CountLinesResult }
|
||||
{ name: "GetByIds", options: { "api.rscType": "Site", "api.roles": "Platform.Site-Query", "api.moduleID": "slobooking", "api.tableName": "appointmentById", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Get Appointments from Ids" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByIdQuery, O: AppointmentByIdResult },
|
||||
{ name: "Find", options: { "api.customQuery": true, "api.rscType": "Site", "api.roles": "Platform.Site-Query", "api.moduleID": "slobooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Find Appointments using search criterias" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByFilterQuery, O: AppointmentByFilterResult },
|
||||
{ name: "FindMatchingFieldValues", options: { "api.customQuery": true, "api.rscType": "Site", "api.roles": "", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Using search criteria & a main field word, find the list of fields containing the searched word (used for auto completion purposes ...) " }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: AppointmentByMatchQuery, O: AppointmentByMatchResult },
|
||||
{ name: "FindMatchingFieldElements", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "using search criteria & a main field word, find the list of field elements containing the searched word (used for auto completion purposes ...) " }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ElementByMatchSiteQuery, O: ElementByMatchResult },
|
||||
{ name: "Extract", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Schedule a data extraction" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExtractSiteQuery, O: ExtractResult },
|
||||
{ name: "GetKPIData", options: { "api.rscType": "Site", "api.roles": "", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Get Appointment KPI data" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: GetKPIDataSiteQuery, O: GetKPIDataResult },
|
||||
{ name: "CountLines", options: { "api.rscType": "Platform", "api.roles": "Platform.Site-Query", "api.moduleID": "slotbooking", "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Appointment Query"], description: "Count lines in database for project" }, "google.api.method_visibility": { restriction: "PUBLIC" } }, I: CountLinesQuery, O: CountLinesResult }
|
||||
], { "api.serviceType": "Query", "api.k8sService": "collab-query-server" });
|
||||
|
||||
163
clickhouse.ts
163
clickhouse.ts
@@ -15,6 +15,7 @@ import { TimeFormat } from "./shared";
|
||||
import { ExtractColumnFormat } from "./shared";
|
||||
import { TranslationMap } from "./shared";
|
||||
import { BlockFilter } from "./shared";
|
||||
import { QuerySiteHeader } from "./shared";
|
||||
import { QueryProjectHeader } from "./shared";
|
||||
import { StringDateObject } from "./shared";
|
||||
/**
|
||||
@@ -208,6 +209,51 @@ export interface GetKPIDataQuery {
|
||||
*/
|
||||
KpiGroupName: string;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.GetKPIDataSiteQuery
|
||||
*/
|
||||
export interface GetKPIDataSiteQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* @generated from protobuf field: api.CHChartType ChartType = 2 [json_name = "ChartType"];
|
||||
*/
|
||||
ChartType: CHChartType;
|
||||
/**
|
||||
* @generated from protobuf field: api.CHQueryType QueryType = 3 [json_name = "QueryType"];
|
||||
*/
|
||||
QueryType: CHQueryType;
|
||||
/**
|
||||
* @generated from protobuf field: string QueryBlock = 4 [json_name = "QueryBlock"];
|
||||
*/
|
||||
QueryBlock: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated api.CHDimension Dimensions = 5 [json_name = "Dimensions"];
|
||||
*/
|
||||
Dimensions: CHDimension[];
|
||||
/**
|
||||
* @generated from protobuf field: repeated api.CHMetric Metrics = 6 [json_name = "Metrics"];
|
||||
*/
|
||||
Metrics: CHMetric[];
|
||||
/**
|
||||
* @generated from protobuf field: api.CHFilter Filter = 7 [json_name = "Filter"];
|
||||
*/
|
||||
Filter?: CHFilter;
|
||||
/**
|
||||
* @generated from protobuf field: string TargetTimeZone = 8 [json_name = "TargetTimeZone"];
|
||||
*/
|
||||
TargetTimeZone: string;
|
||||
/**
|
||||
* @generated from protobuf field: api.KpiDataResultFormat ResultFormat = 9 [json_name = "ResultFormat"];
|
||||
*/
|
||||
ResultFormat: KpiDataResultFormat;
|
||||
/**
|
||||
* @generated from protobuf field: string KpiGroupName = 10 [json_name = "KpiGroupName"];
|
||||
*/
|
||||
KpiGroupName: string;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.GetKPIDataForUserQuery
|
||||
*/
|
||||
@@ -1074,6 +1120,123 @@ class GetKPIDataQuery$Type extends MessageType<GetKPIDataQuery> {
|
||||
*/
|
||||
export const GetKPIDataQuery = new GetKPIDataQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class GetKPIDataSiteQuery$Type extends MessageType<GetKPIDataSiteQuery> {
|
||||
constructor() {
|
||||
super("api.GetKPIDataSiteQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 2, name: "ChartType", kind: "enum", localName: "ChartType", jsonName: "ChartType", T: () => ["api.CHChartType", CHChartType], options: { "validate.rules": { enum: { definedOnly: true } } } },
|
||||
{ no: 3, name: "QueryType", kind: "enum", localName: "QueryType", jsonName: "QueryType", T: () => ["api.CHQueryType", CHQueryType], options: { "validate.rules": { enum: { definedOnly: true } } } },
|
||||
{ no: 4, name: "QueryBlock", kind: "scalar", localName: "QueryBlock", jsonName: "QueryBlock", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 5, name: "Dimensions", kind: "message", localName: "Dimensions", jsonName: "Dimensions", repeat: 2 /*RepeatType.UNPACKED*/, T: () => CHDimension },
|
||||
{ no: 6, name: "Metrics", kind: "message", localName: "Metrics", jsonName: "Metrics", repeat: 2 /*RepeatType.UNPACKED*/, T: () => CHMetric },
|
||||
{ no: 7, name: "Filter", kind: "message", localName: "Filter", jsonName: "Filter", T: () => CHFilter },
|
||||
{ no: 8, name: "TargetTimeZone", kind: "scalar", localName: "TargetTimeZone", jsonName: "TargetTimeZone", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", tzData: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Target user time zone <a href='https://en.wikipedia.org/wiki/List_of_tz_database_time_zones'>format</a>", example: "\"Europe/Paris\"" } } },
|
||||
{ no: 9, name: "ResultFormat", kind: "enum", localName: "ResultFormat", jsonName: "ResultFormat", T: () => ["api.KpiDataResultFormat", KpiDataResultFormat], options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Result format selection", example: "\"KPIDATA_RESULT_FORMAT_SERIES\"" } } },
|
||||
{ no: 10, name: "KpiGroupName", kind: "scalar", localName: "KpiGroupName", jsonName: "KpiGroupName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["executionflow", "stock", "movement", "handlingunit", "actor", "item", "stock_extended", "claim"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Name of the analysis criterion to get the kpi data from", example: "\"executionflow\"" } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "ChartType", "QueryType", "QueryBlock", "Metrics", "KpiGroupName"] } } });
|
||||
}
|
||||
create(value?: PartialMessage<GetKPIDataSiteQuery>): GetKPIDataSiteQuery {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.ChartType = 0;
|
||||
message.QueryType = 0;
|
||||
message.QueryBlock = "";
|
||||
message.Dimensions = [];
|
||||
message.Metrics = [];
|
||||
message.TargetTimeZone = "";
|
||||
message.ResultFormat = 0;
|
||||
message.KpiGroupName = "";
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<GetKPIDataSiteQuery>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKPIDataSiteQuery): GetKPIDataSiteQuery {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* api.CHChartType ChartType = 2 [json_name = "ChartType"];*/ 2:
|
||||
message.ChartType = reader.int32();
|
||||
break;
|
||||
case /* api.CHQueryType QueryType = 3 [json_name = "QueryType"];*/ 3:
|
||||
message.QueryType = reader.int32();
|
||||
break;
|
||||
case /* string QueryBlock = 4 [json_name = "QueryBlock"];*/ 4:
|
||||
message.QueryBlock = reader.string();
|
||||
break;
|
||||
case /* repeated api.CHDimension Dimensions = 5 [json_name = "Dimensions"];*/ 5:
|
||||
message.Dimensions.push(CHDimension.internalBinaryRead(reader, reader.uint32(), options));
|
||||
break;
|
||||
case /* repeated api.CHMetric Metrics = 6 [json_name = "Metrics"];*/ 6:
|
||||
message.Metrics.push(CHMetric.internalBinaryRead(reader, reader.uint32(), options));
|
||||
break;
|
||||
case /* api.CHFilter Filter = 7 [json_name = "Filter"];*/ 7:
|
||||
message.Filter = CHFilter.internalBinaryRead(reader, reader.uint32(), options, message.Filter);
|
||||
break;
|
||||
case /* string TargetTimeZone = 8 [json_name = "TargetTimeZone"];*/ 8:
|
||||
message.TargetTimeZone = reader.string();
|
||||
break;
|
||||
case /* api.KpiDataResultFormat ResultFormat = 9 [json_name = "ResultFormat"];*/ 9:
|
||||
message.ResultFormat = reader.int32();
|
||||
break;
|
||||
case /* string KpiGroupName = 10 [json_name = "KpiGroupName"];*/ 10:
|
||||
message.KpiGroupName = reader.string();
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
|
||||
let d = reader.skip(wireType);
|
||||
if (u !== false)
|
||||
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: GetKPIDataSiteQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* api.CHChartType ChartType = 2 [json_name = "ChartType"]; */
|
||||
if (message.ChartType !== 0)
|
||||
writer.tag(2, WireType.Varint).int32(message.ChartType);
|
||||
/* api.CHQueryType QueryType = 3 [json_name = "QueryType"]; */
|
||||
if (message.QueryType !== 0)
|
||||
writer.tag(3, WireType.Varint).int32(message.QueryType);
|
||||
/* string QueryBlock = 4 [json_name = "QueryBlock"]; */
|
||||
if (message.QueryBlock !== "")
|
||||
writer.tag(4, WireType.LengthDelimited).string(message.QueryBlock);
|
||||
/* repeated api.CHDimension Dimensions = 5 [json_name = "Dimensions"]; */
|
||||
for (let i = 0; i < message.Dimensions.length; i++)
|
||||
CHDimension.internalBinaryWrite(message.Dimensions[i], writer.tag(5, WireType.LengthDelimited).fork(), options).join();
|
||||
/* repeated api.CHMetric Metrics = 6 [json_name = "Metrics"]; */
|
||||
for (let i = 0; i < message.Metrics.length; i++)
|
||||
CHMetric.internalBinaryWrite(message.Metrics[i], writer.tag(6, WireType.LengthDelimited).fork(), options).join();
|
||||
/* api.CHFilter Filter = 7 [json_name = "Filter"]; */
|
||||
if (message.Filter)
|
||||
CHFilter.internalBinaryWrite(message.Filter, writer.tag(7, WireType.LengthDelimited).fork(), options).join();
|
||||
/* string TargetTimeZone = 8 [json_name = "TargetTimeZone"]; */
|
||||
if (message.TargetTimeZone !== "")
|
||||
writer.tag(8, WireType.LengthDelimited).string(message.TargetTimeZone);
|
||||
/* api.KpiDataResultFormat ResultFormat = 9 [json_name = "ResultFormat"]; */
|
||||
if (message.ResultFormat !== 0)
|
||||
writer.tag(9, WireType.Varint).int32(message.ResultFormat);
|
||||
/* string KpiGroupName = 10 [json_name = "KpiGroupName"]; */
|
||||
if (message.KpiGroupName !== "")
|
||||
writer.tag(10, WireType.LengthDelimited).string(message.KpiGroupName);
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
return writer;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @generated MessageType for protobuf message api.GetKPIDataSiteQuery
|
||||
*/
|
||||
export const GetKPIDataSiteQuery = new GetKPIDataSiteQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class GetKPIDataForUserQuery$Type extends MessageType<GetKPIDataForUserQuery> {
|
||||
constructor() {
|
||||
super("api.GetKPIDataForUserQuery", [
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@reflex-platform/npm-core-sdk",
|
||||
"version": "1.11.0-SNAPSHOT-250523134555",
|
||||
"version": "1.11.0-SNAPSHOT-250523143645",
|
||||
"description": "npm libs from core model proto files",
|
||||
"homepage": "",
|
||||
"main": "index.ts",
|
||||
|
||||
427
shared.ts
427
shared.ts
@@ -316,6 +316,37 @@ export interface QueryProjectHeader {
|
||||
*/
|
||||
LocalizedLabel: boolean;
|
||||
}
|
||||
/**
|
||||
* Header for all query site messages
|
||||
*
|
||||
* @generated from protobuf message api.QuerySiteHeader
|
||||
*/
|
||||
export interface QuerySiteHeader {
|
||||
/**
|
||||
* Identifier of the site
|
||||
*
|
||||
* @generated from protobuf field: string SiteID = 1 [json_name = "SiteID"];
|
||||
*/
|
||||
SiteID: string;
|
||||
/**
|
||||
* Number of elements displayed
|
||||
*
|
||||
* @generated from protobuf field: string PagingState = 3 [json_name = "PagingState"];
|
||||
*/
|
||||
PagingState: string;
|
||||
/**
|
||||
* Number of additional elements to display
|
||||
*
|
||||
* @generated from protobuf field: string Limit = 4 [json_name = "Limit"];
|
||||
*/
|
||||
Limit: string;
|
||||
/**
|
||||
* Return the message in the user's language
|
||||
*
|
||||
* @generated from protobuf field: bool LocalizedLabel = 5 [json_name = "LocalizedLabel"];
|
||||
*/
|
||||
LocalizedLabel: boolean;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.ResultHeader
|
||||
*/
|
||||
@@ -1643,6 +1674,67 @@ export interface ExtractQuery {
|
||||
*/
|
||||
TimeFormat: TimeFormat;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.ExtractSiteQuery
|
||||
*/
|
||||
export interface ExtractSiteQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* @generated from protobuf field: string UserId = 2 [json_name = "UserId"];
|
||||
*/
|
||||
UserId: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated api.BlockFilter BlockFilters = 3 [json_name = "BlockFilters"];
|
||||
*/
|
||||
BlockFilters: BlockFilter[];
|
||||
/**
|
||||
* @generated from protobuf field: repeated string Fields = 4 [json_name = "Fields"];
|
||||
*/
|
||||
Fields: string[];
|
||||
/**
|
||||
* @generated from protobuf field: string ListSeparator = 5 [json_name = "ListSeparator"];
|
||||
*/
|
||||
ListSeparator: string;
|
||||
/**
|
||||
* @generated from protobuf field: string DecimalSeparator = 6 [json_name = "DecimalSeparator"];
|
||||
*/
|
||||
DecimalSeparator: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated string ColumnNames = 7 [json_name = "ColumnNames"];
|
||||
*/
|
||||
ColumnNames: string[];
|
||||
/**
|
||||
* @generated from protobuf field: map<string, api.TranslationMap> ColumnTranslationMaps = 8 [json_name = "ColumnTranslationMaps"];
|
||||
*/
|
||||
ColumnTranslationMaps: {
|
||||
[key: string]: TranslationMap;
|
||||
};
|
||||
/**
|
||||
* @generated from protobuf field: map<int32, api.ExtractColumnFormat> ColumnFormats = 9 [json_name = "ColumnFormats"];
|
||||
*/
|
||||
ColumnFormats: {
|
||||
[key: number]: ExtractColumnFormat;
|
||||
};
|
||||
/**
|
||||
* @generated from protobuf field: string TargetTimeZone = 10 [json_name = "TargetTimeZone"];
|
||||
*/
|
||||
TargetTimeZone: string;
|
||||
/**
|
||||
* @generated from protobuf field: string DateFormat = 11 [json_name = "DateFormat"];
|
||||
*/
|
||||
DateFormat: string;
|
||||
/**
|
||||
* @generated from protobuf field: string NumberFormat = 12 [json_name = "NumberFormat"];
|
||||
*/
|
||||
NumberFormat: string;
|
||||
/**
|
||||
* @generated from protobuf field: api.TimeFormat TimeFormat = 13 [json_name = "TimeFormat"];
|
||||
*/
|
||||
TimeFormat: TimeFormat;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.ExtractResult
|
||||
*/
|
||||
@@ -1783,6 +1875,27 @@ export interface ElementByMatchQuery {
|
||||
*/
|
||||
MatchElementField?: MatchElementField;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.ElementByMatchSiteQuery
|
||||
*/
|
||||
export interface ElementByMatchSiteQuery {
|
||||
/**
|
||||
* @generated from protobuf field: api.QuerySiteHeader Header = 1 [json_name = "Header"];
|
||||
*/
|
||||
Header?: QuerySiteHeader;
|
||||
/**
|
||||
* list of blockFilters structure for Find query, each element (BlockFilter) in the list is an "OR" part of the query
|
||||
*
|
||||
* @generated from protobuf field: repeated api.BlockFilter BlockFilters = 2 [json_name = "BlockFilters"];
|
||||
*/
|
||||
BlockFilters: BlockFilter[];
|
||||
/**
|
||||
* MatchElementField structure, containing wanted match string, and the fields to get.
|
||||
*
|
||||
* @generated from protobuf field: api.MatchElementField MatchElementField = 3 [json_name = "MatchElementField"];
|
||||
*/
|
||||
MatchElementField?: MatchElementField;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.ElementByMatchResult
|
||||
*/
|
||||
@@ -3383,6 +3496,77 @@ class QueryProjectHeader$Type extends MessageType<QueryProjectHeader> {
|
||||
*/
|
||||
export const QueryProjectHeader = new QueryProjectHeader$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class QuerySiteHeader$Type extends MessageType<QuerySiteHeader> {
|
||||
constructor() {
|
||||
super("api.QuerySiteHeader", [
|
||||
{ no: 1, name: "SiteID", kind: "scalar", localName: "SiteID", jsonName: "SiteID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", notContains: " " } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Identifier of the site" } } },
|
||||
{ no: 3, name: "PagingState", kind: "scalar", localName: "PagingState", jsonName: "PagingState", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Start position of the query result page. Pagination disabled if equal to -1.", example: "\"50\"" } } },
|
||||
{ no: 4, name: "Limit", kind: "scalar", localName: "Limit", jsonName: "Limit", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Length of the query result page", example: "\"50\"" } } },
|
||||
{ no: 5, name: "LocalizedLabel", kind: "scalar", localName: "LocalizedLabel", jsonName: "LocalizedLabel", T: 8 /*ScalarType.BOOL*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Return the message in the user's language" } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["SiteID"] } } });
|
||||
}
|
||||
create(value?: PartialMessage<QuerySiteHeader>): QuerySiteHeader {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.SiteID = "";
|
||||
message.PagingState = "";
|
||||
message.Limit = "";
|
||||
message.LocalizedLabel = false;
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<QuerySiteHeader>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: QuerySiteHeader): QuerySiteHeader {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* string SiteID = 1 [json_name = "SiteID"];*/ 1:
|
||||
message.SiteID = reader.string();
|
||||
break;
|
||||
case /* string PagingState = 3 [json_name = "PagingState"];*/ 3:
|
||||
message.PagingState = reader.string();
|
||||
break;
|
||||
case /* string Limit = 4 [json_name = "Limit"];*/ 4:
|
||||
message.Limit = reader.string();
|
||||
break;
|
||||
case /* bool LocalizedLabel = 5 [json_name = "LocalizedLabel"];*/ 5:
|
||||
message.LocalizedLabel = reader.bool();
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
|
||||
let d = reader.skip(wireType);
|
||||
if (u !== false)
|
||||
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: QuerySiteHeader, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* string SiteID = 1 [json_name = "SiteID"]; */
|
||||
if (message.SiteID !== "")
|
||||
writer.tag(1, WireType.LengthDelimited).string(message.SiteID);
|
||||
/* string PagingState = 3 [json_name = "PagingState"]; */
|
||||
if (message.PagingState !== "")
|
||||
writer.tag(3, WireType.LengthDelimited).string(message.PagingState);
|
||||
/* string Limit = 4 [json_name = "Limit"]; */
|
||||
if (message.Limit !== "")
|
||||
writer.tag(4, WireType.LengthDelimited).string(message.Limit);
|
||||
/* bool LocalizedLabel = 5 [json_name = "LocalizedLabel"]; */
|
||||
if (message.LocalizedLabel !== false)
|
||||
writer.tag(5, WireType.Varint).bool(message.LocalizedLabel);
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
return writer;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @generated MessageType for protobuf message api.QuerySiteHeader
|
||||
*/
|
||||
export const QuerySiteHeader = new QuerySiteHeader$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class ResultHeader$Type extends MessageType<ResultHeader> {
|
||||
constructor() {
|
||||
super("api.ResultHeader", [
|
||||
@@ -7044,6 +7228,188 @@ class ExtractQuery$Type extends MessageType<ExtractQuery> {
|
||||
*/
|
||||
export const ExtractQuery = new ExtractQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class ExtractSiteQuery$Type extends MessageType<ExtractSiteQuery> {
|
||||
constructor() {
|
||||
super("api.ExtractSiteQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 2, name: "UserId", kind: "scalar", localName: "UserId", jsonName: "UserId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 3, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter },
|
||||
{ no: 4, name: "Fields", kind: "scalar", localName: "Fields", jsonName: "Fields", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 5, name: "ListSeparator", kind: "scalar", localName: "ListSeparator", jsonName: "ListSeparator", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 6, name: "DecimalSeparator", kind: "scalar", localName: "DecimalSeparator", jsonName: "DecimalSeparator", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 7, name: "ColumnNames", kind: "scalar", localName: "ColumnNames", jsonName: "ColumnNames", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 8, name: "ColumnTranslationMaps", kind: "map", localName: "ColumnTranslationMaps", jsonName: "ColumnTranslationMaps", K: 9 /*ScalarType.STRING*/, V: { kind: "message", T: () => TranslationMap } },
|
||||
{ no: 9, name: "ColumnFormats", kind: "map", localName: "ColumnFormats", jsonName: "ColumnFormats", K: 5 /*ScalarType.INT32*/, V: { kind: "message", T: () => ExtractColumnFormat } },
|
||||
{ no: 10, name: "TargetTimeZone", kind: "scalar", localName: "TargetTimeZone", jsonName: "TargetTimeZone", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", tzData: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Target user time zone <a href='https://en.wikipedia.org/wiki/List_of_tz_database_time_zones'>format</a>", example: "\"Europe/Paris\"" } } },
|
||||
{ no: 11, name: "DateFormat", kind: "scalar", localName: "DateFormat", jsonName: "DateFormat", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Language code to format dates <a href='https://en.wikipedia.org/wiki/ISO_639'>format</a>", example: "\"en-US\"" } } },
|
||||
{ no: 12, name: "NumberFormat", kind: "scalar", localName: "NumberFormat", jsonName: "NumberFormat", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Language code to format numbers <a href='https://en.wikipedia.org/wiki/ISO_639'>format</a>", example: "\"en-US\"" } } },
|
||||
{ no: 13, name: "TimeFormat", kind: "enum", localName: "TimeFormat", jsonName: "TimeFormat", T: () => ["api.TimeFormat", TimeFormat], options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Hour clock time format" } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "UserId", "Fields", "ListSeparator", "DecimalSeparator", "ColumnName"] } } });
|
||||
}
|
||||
create(value?: PartialMessage<ExtractSiteQuery>): ExtractSiteQuery {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.UserId = "";
|
||||
message.BlockFilters = [];
|
||||
message.Fields = [];
|
||||
message.ListSeparator = "";
|
||||
message.DecimalSeparator = "";
|
||||
message.ColumnNames = [];
|
||||
message.ColumnTranslationMaps = {};
|
||||
message.ColumnFormats = {};
|
||||
message.TargetTimeZone = "";
|
||||
message.DateFormat = "";
|
||||
message.NumberFormat = "";
|
||||
message.TimeFormat = 0;
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<ExtractSiteQuery>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExtractSiteQuery): ExtractSiteQuery {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* string UserId = 2 [json_name = "UserId"];*/ 2:
|
||||
message.UserId = reader.string();
|
||||
break;
|
||||
case /* repeated api.BlockFilter BlockFilters = 3 [json_name = "BlockFilters"];*/ 3:
|
||||
message.BlockFilters.push(BlockFilter.internalBinaryRead(reader, reader.uint32(), options));
|
||||
break;
|
||||
case /* repeated string Fields = 4 [json_name = "Fields"];*/ 4:
|
||||
message.Fields.push(reader.string());
|
||||
break;
|
||||
case /* string ListSeparator = 5 [json_name = "ListSeparator"];*/ 5:
|
||||
message.ListSeparator = reader.string();
|
||||
break;
|
||||
case /* string DecimalSeparator = 6 [json_name = "DecimalSeparator"];*/ 6:
|
||||
message.DecimalSeparator = reader.string();
|
||||
break;
|
||||
case /* repeated string ColumnNames = 7 [json_name = "ColumnNames"];*/ 7:
|
||||
message.ColumnNames.push(reader.string());
|
||||
break;
|
||||
case /* map<string, api.TranslationMap> ColumnTranslationMaps = 8 [json_name = "ColumnTranslationMaps"];*/ 8:
|
||||
this.binaryReadMap8(message.ColumnTranslationMaps, reader, options);
|
||||
break;
|
||||
case /* map<int32, api.ExtractColumnFormat> ColumnFormats = 9 [json_name = "ColumnFormats"];*/ 9:
|
||||
this.binaryReadMap9(message.ColumnFormats, reader, options);
|
||||
break;
|
||||
case /* string TargetTimeZone = 10 [json_name = "TargetTimeZone"];*/ 10:
|
||||
message.TargetTimeZone = reader.string();
|
||||
break;
|
||||
case /* string DateFormat = 11 [json_name = "DateFormat"];*/ 11:
|
||||
message.DateFormat = reader.string();
|
||||
break;
|
||||
case /* string NumberFormat = 12 [json_name = "NumberFormat"];*/ 12:
|
||||
message.NumberFormat = reader.string();
|
||||
break;
|
||||
case /* api.TimeFormat TimeFormat = 13 [json_name = "TimeFormat"];*/ 13:
|
||||
message.TimeFormat = reader.int32();
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
|
||||
let d = reader.skip(wireType);
|
||||
if (u !== false)
|
||||
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
}
|
||||
private binaryReadMap8(map: ExtractSiteQuery["ColumnTranslationMaps"], reader: IBinaryReader, options: BinaryReadOptions): void {
|
||||
let len = reader.uint32(), end = reader.pos + len, key: keyof ExtractSiteQuery["ColumnTranslationMaps"] | undefined, val: ExtractSiteQuery["ColumnTranslationMaps"][any] | undefined;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case 1:
|
||||
key = reader.string();
|
||||
break;
|
||||
case 2:
|
||||
val = TranslationMap.internalBinaryRead(reader, reader.uint32(), options);
|
||||
break;
|
||||
default: throw new globalThis.Error("unknown map entry field for field api.ExtractSiteQuery.ColumnTranslationMaps");
|
||||
}
|
||||
}
|
||||
map[key ?? ""] = val ?? TranslationMap.create();
|
||||
}
|
||||
private binaryReadMap9(map: ExtractSiteQuery["ColumnFormats"], reader: IBinaryReader, options: BinaryReadOptions): void {
|
||||
let len = reader.uint32(), end = reader.pos + len, key: keyof ExtractSiteQuery["ColumnFormats"] | undefined, val: ExtractSiteQuery["ColumnFormats"][any] | undefined;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case 1:
|
||||
key = reader.int32();
|
||||
break;
|
||||
case 2:
|
||||
val = ExtractColumnFormat.internalBinaryRead(reader, reader.uint32(), options);
|
||||
break;
|
||||
default: throw new globalThis.Error("unknown map entry field for field api.ExtractSiteQuery.ColumnFormats");
|
||||
}
|
||||
}
|
||||
map[key ?? 0] = val ?? ExtractColumnFormat.create();
|
||||
}
|
||||
internalBinaryWrite(message: ExtractSiteQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* string UserId = 2 [json_name = "UserId"]; */
|
||||
if (message.UserId !== "")
|
||||
writer.tag(2, WireType.LengthDelimited).string(message.UserId);
|
||||
/* repeated api.BlockFilter BlockFilters = 3 [json_name = "BlockFilters"]; */
|
||||
for (let i = 0; i < message.BlockFilters.length; i++)
|
||||
BlockFilter.internalBinaryWrite(message.BlockFilters[i], writer.tag(3, WireType.LengthDelimited).fork(), options).join();
|
||||
/* repeated string Fields = 4 [json_name = "Fields"]; */
|
||||
for (let i = 0; i < message.Fields.length; i++)
|
||||
writer.tag(4, WireType.LengthDelimited).string(message.Fields[i]);
|
||||
/* string ListSeparator = 5 [json_name = "ListSeparator"]; */
|
||||
if (message.ListSeparator !== "")
|
||||
writer.tag(5, WireType.LengthDelimited).string(message.ListSeparator);
|
||||
/* string DecimalSeparator = 6 [json_name = "DecimalSeparator"]; */
|
||||
if (message.DecimalSeparator !== "")
|
||||
writer.tag(6, WireType.LengthDelimited).string(message.DecimalSeparator);
|
||||
/* repeated string ColumnNames = 7 [json_name = "ColumnNames"]; */
|
||||
for (let i = 0; i < message.ColumnNames.length; i++)
|
||||
writer.tag(7, WireType.LengthDelimited).string(message.ColumnNames[i]);
|
||||
/* map<string, api.TranslationMap> ColumnTranslationMaps = 8 [json_name = "ColumnTranslationMaps"]; */
|
||||
for (let k of globalThis.Object.keys(message.ColumnTranslationMaps)) {
|
||||
writer.tag(8, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k);
|
||||
writer.tag(2, WireType.LengthDelimited).fork();
|
||||
TranslationMap.internalBinaryWrite(message.ColumnTranslationMaps[k], writer, options);
|
||||
writer.join().join();
|
||||
}
|
||||
/* map<int32, api.ExtractColumnFormat> ColumnFormats = 9 [json_name = "ColumnFormats"]; */
|
||||
for (let k of globalThis.Object.keys(message.ColumnFormats)) {
|
||||
writer.tag(9, WireType.LengthDelimited).fork().tag(1, WireType.Varint).int32(parseInt(k));
|
||||
writer.tag(2, WireType.LengthDelimited).fork();
|
||||
ExtractColumnFormat.internalBinaryWrite(message.ColumnFormats[k as any], writer, options);
|
||||
writer.join().join();
|
||||
}
|
||||
/* string TargetTimeZone = 10 [json_name = "TargetTimeZone"]; */
|
||||
if (message.TargetTimeZone !== "")
|
||||
writer.tag(10, WireType.LengthDelimited).string(message.TargetTimeZone);
|
||||
/* string DateFormat = 11 [json_name = "DateFormat"]; */
|
||||
if (message.DateFormat !== "")
|
||||
writer.tag(11, WireType.LengthDelimited).string(message.DateFormat);
|
||||
/* string NumberFormat = 12 [json_name = "NumberFormat"]; */
|
||||
if (message.NumberFormat !== "")
|
||||
writer.tag(12, WireType.LengthDelimited).string(message.NumberFormat);
|
||||
/* api.TimeFormat TimeFormat = 13 [json_name = "TimeFormat"]; */
|
||||
if (message.TimeFormat !== 0)
|
||||
writer.tag(13, WireType.Varint).int32(message.TimeFormat);
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
return writer;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @generated MessageType for protobuf message api.ExtractSiteQuery
|
||||
*/
|
||||
export const ExtractSiteQuery = new ExtractSiteQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class ExtractResult$Type extends MessageType<ExtractResult> {
|
||||
constructor() {
|
||||
super("api.ExtractResult", [
|
||||
@@ -7545,6 +7911,67 @@ class ElementByMatchQuery$Type extends MessageType<ElementByMatchQuery> {
|
||||
*/
|
||||
export const ElementByMatchQuery = new ElementByMatchQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class ElementByMatchSiteQuery$Type extends MessageType<ElementByMatchSiteQuery> {
|
||||
constructor() {
|
||||
super("api.ElementByMatchSiteQuery", [
|
||||
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QuerySiteHeader, options: { "validate.rules": { message: { required: true } } } },
|
||||
{ no: 2, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter },
|
||||
{ no: 3, name: "MatchElementField", kind: "message", localName: "MatchElementField", jsonName: "MatchElementField", T: () => MatchElementField, options: { "validate.rules": { message: { required: true } } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } });
|
||||
}
|
||||
create(value?: PartialMessage<ElementByMatchSiteQuery>): ElementByMatchSiteQuery {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.BlockFilters = [];
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<ElementByMatchSiteQuery>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ElementByMatchSiteQuery): ElementByMatchSiteQuery {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* api.QuerySiteHeader Header = 1 [json_name = "Header"];*/ 1:
|
||||
message.Header = QuerySiteHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
||||
break;
|
||||
case /* repeated api.BlockFilter BlockFilters = 2 [json_name = "BlockFilters"];*/ 2:
|
||||
message.BlockFilters.push(BlockFilter.internalBinaryRead(reader, reader.uint32(), options));
|
||||
break;
|
||||
case /* api.MatchElementField MatchElementField = 3 [json_name = "MatchElementField"];*/ 3:
|
||||
message.MatchElementField = MatchElementField.internalBinaryRead(reader, reader.uint32(), options, message.MatchElementField);
|
||||
break;
|
||||
default:
|
||||
let u = options.readUnknownField;
|
||||
if (u === "throw")
|
||||
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
|
||||
let d = reader.skip(wireType);
|
||||
if (u !== false)
|
||||
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
|
||||
}
|
||||
}
|
||||
return message;
|
||||
}
|
||||
internalBinaryWrite(message: ElementByMatchSiteQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.QuerySiteHeader Header = 1 [json_name = "Header"]; */
|
||||
if (message.Header)
|
||||
QuerySiteHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
||||
/* repeated api.BlockFilter BlockFilters = 2 [json_name = "BlockFilters"]; */
|
||||
for (let i = 0; i < message.BlockFilters.length; i++)
|
||||
BlockFilter.internalBinaryWrite(message.BlockFilters[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join();
|
||||
/* api.MatchElementField MatchElementField = 3 [json_name = "MatchElementField"]; */
|
||||
if (message.MatchElementField)
|
||||
MatchElementField.internalBinaryWrite(message.MatchElementField, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
|
||||
let u = options.writeUnknownFields;
|
||||
if (u !== false)
|
||||
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
||||
return writer;
|
||||
}
|
||||
}
|
||||
/**
|
||||
* @generated MessageType for protobuf message api.ElementByMatchSiteQuery
|
||||
*/
|
||||
export const ElementByMatchSiteQuery = new ElementByMatchSiteQuery$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class ElementByMatchResult$Type extends MessageType<ElementByMatchResult> {
|
||||
constructor() {
|
||||
super("api.ElementByMatchResult", [
|
||||
|
||||
Reference in New Issue
Block a user