60 lines
1.3 KiB
JavaScript
60 lines
1.3 KiB
JavaScript
import defineTrigger from '../../../../helpers/define-trigger.js';
|
|
|
|
export default defineTrigger({
|
|
name: 'New comment',
|
|
key: 'newComment',
|
|
description: 'Triggers when a new comment is created.',
|
|
pollInterval: 15,
|
|
arguments: [
|
|
{
|
|
label: 'Status',
|
|
key: 'status',
|
|
type: 'dropdown',
|
|
required: true,
|
|
variables: true,
|
|
options: [
|
|
{ label: 'Approve', value: 'approve' },
|
|
{ label: 'Unapprove', value: 'hold' },
|
|
{ label: 'Spam', value: 'spam' },
|
|
{ label: 'Trash', value: 'trash' },
|
|
],
|
|
},
|
|
],
|
|
|
|
async run($) {
|
|
const params = {
|
|
per_page: 100,
|
|
page: 1,
|
|
order: 'desc',
|
|
orderby: 'date',
|
|
status: $.step.parameters.status || '',
|
|
};
|
|
|
|
let totalPages = 1;
|
|
do {
|
|
const { data, headers } = await $.http.get(
|
|
'?rest_route=/wp/v2/comments',
|
|
{
|
|
params,
|
|
}
|
|
);
|
|
|
|
params.page = params.page + 1;
|
|
totalPages = Number(headers['x-wp-totalpages']);
|
|
|
|
if (data.length) {
|
|
for (const page of data) {
|
|
const dataItem = {
|
|
raw: page,
|
|
meta: {
|
|
internalId: page.id.toString(),
|
|
},
|
|
};
|
|
|
|
$.pushTriggerItem(dataItem);
|
|
}
|
|
}
|
|
} while (params.page <= totalPages);
|
|
},
|
|
});
|