Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 | 5x 5x 5x 5x 5x 5x 5x 5x 2x 2x 2x 2x 2x 2x 2x 2x 6x 2x 2x 1x 1x 1x 2x | import CoreFormsEnum from '@orchesty/nodejs-sdk/dist/lib/Application/Base/CoreFormsEnum';
import ABatchNode from '@orchesty/nodejs-sdk/dist/lib/Batch/ABatchNode';
import { HttpMethods } from '@orchesty/nodejs-sdk/dist/lib/Transport/HttpMethods';
import BatchProcessDto from '@orchesty/nodejs-sdk/dist/lib/Utils/BatchProcessDto';
import { HOST_URL } from '../JiraApplication';
export const JIRA_GET_UPDATED_WORKLOG_IDS_ENDPOINT = '/rest/api/3/worklog/updated';
export const NAME = 'jira-get-updated-worklog-ids';
export default class JiraGetUpdatedWorklogIdsBatch extends ABatchNode {
public getName(): string {
return NAME;
}
public async processAction(dto: BatchProcessDto<IInput, IOutput>): Promise<BatchProcessDto<IInput, IOutput>> {
const appInstall = await this.getApplicationInstallFromProcess(dto);
let { since } = dto.getJsonData();
Iif (!since || since < 0) {
since = 0;
}
const url = `${JIRA_GET_UPDATED_WORKLOG_IDS_ENDPOINT}?since=${since}`;
const nextUrl = dto.getBatchCursor(url);
const request = await this.getApplication().getRequestDto(dto, appInstall, HttpMethods.GET, nextUrl);
const response = await this.getSender().send<IResponse>(request);
const responseData = response.getJsonBody();
const worklogIds = responseData.values.map((item) => item.worklogId);
// Send the whole list as one item, since it is ment to be consumed by a
// connector, that operates on the whole list
dto.setItemList([worklogIds]);
if (!responseData.lastPage) {
// Use only path as the url since base is added to all request urls in the application
const baseUrl = appInstall.getSettings()?.[CoreFormsEnum.AUTHORIZATION_FORM]?.[HOST_URL];
const nextPageUrl = responseData.nextPage.replace(baseUrl, '');
dto.setBatchCursor(nextPageUrl);
}
return dto;
}
}
export interface IInput {
since: number;
}
type IOutput = number[];
interface IResponse {
lastPage: boolean;
self: string;
since: number;
until: number;
values: Value[];
nextPage: string;
}
interface Value {
properties: [];
updatedTime: number;
worklogId: number;
}
|