47 lines
2.9 KiB
JavaScript
47 lines
2.9 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.MessagePoller = void 0;
|
|
const pollingEndpointConsumerSeekIn_1 = require("../models/pollingEndpointConsumerSeekIn");
|
|
const pollingEndpointConsumerSeekOut_1 = require("../models/pollingEndpointConsumerSeekOut");
|
|
const pollingEndpointOut_1 = require("../models/pollingEndpointOut");
|
|
const request_1 = require("../request");
|
|
class MessagePoller {
|
|
constructor(requestCtx) {
|
|
this.requestCtx = requestCtx;
|
|
}
|
|
poll(appId, sinkId, options) {
|
|
const request = new request_1.SvixRequest(request_1.HttpMethod.GET, "/api/v1/app/{app_id}/poller/{sink_id}");
|
|
request.setPathParam("app_id", appId);
|
|
request.setPathParam("sink_id", sinkId);
|
|
request.setQueryParams({
|
|
limit: options === null || options === void 0 ? void 0 : options.limit,
|
|
iterator: options === null || options === void 0 ? void 0 : options.iterator,
|
|
event_type: options === null || options === void 0 ? void 0 : options.eventType,
|
|
channel: options === null || options === void 0 ? void 0 : options.channel,
|
|
after: options === null || options === void 0 ? void 0 : options.after,
|
|
});
|
|
return request.send(this.requestCtx, pollingEndpointOut_1.PollingEndpointOutSerializer._fromJsonObject);
|
|
}
|
|
consumerPoll(appId, sinkId, consumerId, options) {
|
|
const request = new request_1.SvixRequest(request_1.HttpMethod.GET, "/api/v1/app/{app_id}/poller/{sink_id}/consumer/{consumer_id}");
|
|
request.setPathParam("app_id", appId);
|
|
request.setPathParam("sink_id", sinkId);
|
|
request.setPathParam("consumer_id", consumerId);
|
|
request.setQueryParams({
|
|
limit: options === null || options === void 0 ? void 0 : options.limit,
|
|
iterator: options === null || options === void 0 ? void 0 : options.iterator,
|
|
});
|
|
return request.send(this.requestCtx, pollingEndpointOut_1.PollingEndpointOutSerializer._fromJsonObject);
|
|
}
|
|
consumerSeek(appId, sinkId, consumerId, pollingEndpointConsumerSeekIn, options) {
|
|
const request = new request_1.SvixRequest(request_1.HttpMethod.POST, "/api/v1/app/{app_id}/poller/{sink_id}/consumer/{consumer_id}/seek");
|
|
request.setPathParam("app_id", appId);
|
|
request.setPathParam("sink_id", sinkId);
|
|
request.setPathParam("consumer_id", consumerId);
|
|
request.setHeaderParam("idempotency-key", options === null || options === void 0 ? void 0 : options.idempotencyKey);
|
|
request.setBody(pollingEndpointConsumerSeekIn_1.PollingEndpointConsumerSeekInSerializer._toJsonObject(pollingEndpointConsumerSeekIn));
|
|
return request.send(this.requestCtx, pollingEndpointConsumerSeekOut_1.PollingEndpointConsumerSeekOutSerializer._fromJsonObject);
|
|
}
|
|
}
|
|
exports.MessagePoller = MessagePoller;
|
|
//# sourceMappingURL=messagePoller.js.map
|