1import { ApifyClient } from 'apify-client';
2
3
4
5const client = new ApifyClient({
6 token: '<YOUR_API_TOKEN>',
7});
8
9
10const input = {
11 "comparisons": [
12 {
13 "id": "synthetic-new-unaligned-source",
14 "domain": "example.invalid",
15 "baselineReports": [
16 {
17 "id": "baseline-receiver-a",
18 "format": "XML",
19 "xml": "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<feedback>\n <report_metadata><org_name>Receiver A</org_name><email>reports@receiver.example</email><report_id>baseline-20260916</report_id><date_range><begin>1789516800</begin><end>1789603199</end></date_range></report_metadata>\n <policy_published><domain>example.invalid</domain><adkim>r</adkim><aspf>r</aspf><p>none</p></policy_published>\n <record><row><source_ip>192.0.2.10</source_ip><count>20</count><policy_evaluated><disposition>none</disposition><dkim>pass</dkim><spf>pass</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>example.invalid</envelope_from></identifiers><auth_results><dkim><domain>example.invalid</domain><result>pass</result><selector>mail</selector></dkim><spf><domain>example.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>\n</feedback>"
20 }
21 ],
22 "currentReports": [
23 {
24 "id": "current-receiver-a",
25 "format": "XML",
26 "xml": "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<feedback>\n <report_metadata><org_name>Receiver A</org_name><email>reports@receiver.example</email><report_id>current-20260917</report_id><date_range><begin>1789603200</begin><end>1789689599</end></date_range></report_metadata>\n <policy_published><domain>example.invalid</domain><adkim>r</adkim><aspf>r</aspf><p>none</p></policy_published>\n <record><row><source_ip>192.0.2.10</source_ip><count>22</count><policy_evaluated><disposition>none</disposition><dkim>pass</dkim><spf>pass</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>example.invalid</envelope_from></identifiers><auth_results><dkim><domain>example.invalid</domain><result>pass</result><selector>mail</selector></dkim><spf><domain>example.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>\n <record><row><source_ip>198.51.100.44</source_ip><count>7</count><policy_evaluated><disposition>quarantine</disposition><dkim>fail</dkim><spf>fail</spf></policy_evaluated></row><identifiers><header_from>example.invalid</header_from><envelope_from>mailer.vendor.invalid</envelope_from></identifiers><auth_results><dkim><domain>mailer.vendor.invalid</domain><result>fail</result><selector>outbound</selector></dkim><spf><domain>mailer.vendor.invalid</domain><result>pass</result><scope>mfrom</scope></spf></auth_results></record>\n</feedback>"
27 }
28 ]
29 }
30 ]
31};
32
33
34const run = await client.actor("ceddl/dmarc-aggregate-drift-monitor").call(input);
35
36
37console.log('Results from dataset');
38console.log(`💾 Check your data here: https://console.apify.com/storage/datasets/${run.defaultDatasetId}`);
39const { items } = await client.dataset(run.defaultDatasetId).listItems();
40items.forEach((item) => {
41 console.dir(item);
42});
43
44