Pipeline Settings

Aura / Pipeline Settings

2026/05/18 20:08:16 GMT-8

Pipeline Configurations

▸1Billing Flow - VGM (partial-auto)

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	Email Inbox (IMAP)	billing@nmt.com (Folder: VGM)	none	none	XLS, PDF	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm
1	—	MCP Server	mcp://file-parser/xls-to-json	VGM_RAW_FMT → STD_JSON	—
2	—	JS Engine	scripts/validate-vessel.js	STD_JSON → STD_JSON	—
3	—	AI Agent	agent:vgm-checker (Missing flags check)	STD_JSON → BILLING_PAYLOAD	—
4	—	API Plugin	https://api.internal/rates	BILLING_PAYLOAD → BILLING_PRICED	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/invoice	RECORD	BILLING_PRICED → FIN_INVOICE

!Approvals & Exceptions Routing

Trigger Source / Step	Condition	Approver / Reviewer	Action Resolution
Processing: Step 2	Validation fails (Vessel code mismatch)	OPS-DUTY-OFFICER	Route to manual review grid
Processing: Step 3	AI Confidence < 90% or Discrepancy	BILLING_OPS -> BILLING_SUPERVISOR	Require Multi-level Approval before Egress
Catch All	Any unhandled runtime error	SYSTEM_ADMIN	Send Alert & Park Record

Validation Rules (0)

None

Auto-Fix Rules (0)

None

▸2Billing Flow - Extra Discharge / Loading

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
1	SFTP	sftp://27.105.107.102:22/home/vm/jeter/aura_poc	none	*	XLS,XLSX	record.description.toLowerCase().includes("extra discharge/loading")
2	API Agent	http://localhost:3000/api/extract	*	*	JSON	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm
1	Container Movement History	JS Engine	scripts/ContainerEnquiryResults_csv_process.mjs	none → *	🔒 Confirm
2	Distinct Voyage List	JS Engine	scripts/DistinctVoyageList.js	* → *	🔒 Confirm
3	Nbis Charge Data	JS Engine	scripts/SearchNbisChargeData.js	* → *	🔒 Confirm
4	Notification email PV & Storage team	API Plugin	http://localhost:7050/elcs/api/public/aura/sendEmail	{"buId": "4028802380b126130180b12a96e20000"} → *	🔒 Confirm
5	Create MI Charge Data	JS Engine	scripts/CreateMIChargeData.js	* → *	🔒 Confirm
6	Send Approval Email	API Plugin	http://localhost:7050/elcs/api/public/aura/sendEmail	{"buId": "4028802380b126130180b12a96e20000"} → none	🔒 Confirm
7	Create MI Template	JS Engine	scripts/CreateMITemplateData.js	* → *	🔒 Confirm

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	http://localhost:7050/elcs/api/vgm/auraMiUpload	RECORD	? → ?

!Approvals & Exceptions Routing

No exception routes configured

Validation Rules (0)

None

Auto-Fix Rules (0)

None

▸3SFTP Vendor Invoices

Status: Active|Source: SFTP|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	SFTP	sftp://vendor.nmt.com:22/invoices	none	none	CSV, XLSX	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm	Actions
1	—	MCP Server	mcp://file-parser/csv-to-json	VENDOR_INV_FMT → STD_JSON	—
2	—	JS Engine	scripts/validate-invoice.js	STD_JSON → STD_JSON	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/invoice	RECORD	STD_JSON → FIN_INVOICE

!Approvals & Exceptions Routing

Trigger Source / Step	Condition	Approver / Reviewer	Action Resolution	Actions
Processing: Step 2	Validation fails (Amount mismatch)	ACCOUNTS_PAYABLE	Route to AP review queue
Catch All	Any unhandled runtime error	SYSTEM_ADMIN	Send Alert & Park Record

Validation Rules (2)

Date Formattypeof record.invoice_date === 'string' && record....

Amount Integrityrecord.net_amount + record.tax_amount == record.gr...

Auto-Fix Rules (2)

[0]Normalize HK$ to HKD

[1]Trim Whitespace from Vendor Name

▸4Email Bank Statements

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	Email Inbox (IMAP)	banking@nmt.com (Folder: Statements)	none	none	CSV, PDF	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm	Actions
1	—	MCP Server	mcp://file-parser/csv-to-json	BANK_STMT_FMT → STD_JSON	—
2	—	JS Engine	scripts/validate-bank-stmt.js	STD_JSON → STD_JSON	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/reconciliation	RECORD	STD_JSON → FIN_RECON

!Approvals & Exceptions Routing

Trigger Source / Step	Condition	Approver / Reviewer	Action Resolution	Actions
Processing: Step 2	Validation fails (Account format)	BANKING_OPS	Route to banking ops review
Catch All	Any unhandled runtime error	SYSTEM_ADMIN	Send Alert & Park Record

Validation Rules (2)

ISO Currency Codetypeof record.currency === 'string' && record.curr...

Account Lengthtypeof record.account_number === 'string' && recor...

Auto-Fix Rules (1)

[0]Reformat DD/MM/YYYY to YYYY-MM-DD

▸5Billing Flow - Email (Telex) Distribution

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	Email Inbox (IMAP)	billing@nmt.com (Folder: Telex)	none	none	XLS	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm	Actions
1	—	MCP Server	mcp://file-parser/xls-to-json	TELEX_RAW_FMT → STD_JSON	—
2	—	JS Engine	scripts/validate-telex.js	STD_JSON → BILLING_PAYLOAD	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/invoice	RECORD	BILLING_PAYLOAD → FIN_INVOICE

!Approvals & Exceptions Routing

No exception routes configured

Validation Rules (0)

None

Auto-Fix Rules (0)

None

▸6Billing Flow - Extra Work at CFS

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	Share Drive	\\nas\shared\cfs_extra	none	none	XLS	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm	Actions
1	—	MCP Server	mcp://file-parser/xls-to-json	CFS_RAW_FMT → STD_JSON	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/invoice	RECORD	STD_JSON → FIN_INVOICE

!Approvals & Exceptions Routing

No exception routes configured

Validation Rules (0)

None

Auto-Fix Rules (0)

None

▸7Billing Flow - Manual Invoice

Status: Active|Source: EMAIL|Updated: 2026-06-26

1Ingress Config

Order	Adapter Type	Endpoint/Config	Input Col	Output Col	Expected Format	Filter	Actions
0	Share Drive	\\nas\shared\manual_invoice	none	none	XLS, PDF	-

2Processing Modules

Order	Name	Engine Type	Handler / Target	Format Mapping (In → Out)	Confirm	Actions
1	—	MCP Server	mcp://file-parser/xls-to-json	MANUAL_INV_FMT → STD_JSON	🔒 Confirm
2	—	AI Agent	agent:invoice-checker	STD_JSON → BILLING_PAYLOAD	—

3Egress Config

Adapter Type	Destination	Data Source	Format Mapping	Actions
REST API POST	https://nmt.fin.systems/api/invoice	RECORD	BILLING_PAYLOAD → FIN_INVOICE

!Approvals & Exceptions Routing

No exception routes configured

Validation Rules (0)

None

Auto-Fix Rules (0)

None