Container Manager Plugin

8min
This plugin will interpret the current event and, if required, it will accordingly update an existing container.
Use case
Single leg - Update the status of the container based on job updates.
Input
tenantId
orderId
workOrderId
containerId
jobStatus
eventCode
reasonCode
location
callback
Output
ApplyEventToContainer (eventCode +reasonCode)
Logic
Container Type = “orderfpastest”
Input
﻿
Output
﻿
jobStatus
reasonCode
eventCode
reasonCode
CREATED
﻿
E-020
R-0046
IN_PROGRESS
﻿
E-021
R-0063
COMPLETED
!= R-0065
E-010
R-0041
COMPLETED
== R-0065
E-021
R-0029
Current Configuration
Rule
Job Complete Success Rule
Job Complete Success Rule
{
    "name": "Complete Job Success",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:6e33bb8f-7ca2-5a7a-add5-fc651c5048af",
    "serviceName": "orchestrator",
    "logic": {
        "==": [
            "$.reason",
            "R-0065"
        ]
    }
}
{
    "name": "Complete Job Success",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:6e33bb8f-7ca2-5a7a-add5-fc651c5048af",
    "serviceName": "orchestrator",
    "logic": {
        "==": [
            "$.reason",
            "R-0065"
        ]
    }
}
﻿
Job Started Rule
Job Started Rule
{
    "name": "Job Started",
    "event": "JobStartedEvent",
    "pluginWorkflowId": "plugin-workflow:6e33bb8f-7ca2-5a7a-add5-fc651c5048af",
    "serviceName": "orchestrator"
}
{
    "name": "Job Started",
    "event": "JobStartedEvent",
    "pluginWorkflowId": "plugin-workflow:6e33bb8f-7ca2-5a7a-add5-fc651c5048af",
    "serviceName": "orchestrator"
}
﻿
Plugin Workflow
Plugin Workflow
{
    "name": "CompleteJobWorkflow",
    "description": "workflow for job completion",
    "tag": [
        {
            "name": "workOrderManager",
            "value": "workflow"
        },
        {
            "name": "containerManager",
            "value": "workflow"
        }
    ],
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "workOrderManagerPlugin",
            "containerManagerPlugin"
        ]
    }
}
{
    "name": "CompleteJobWorkflow",
    "description": "workflow for job completion",
    "tag": [
        {
            "name": "workOrderManager",
            "value": "workflow"
        },
        {
            "name": "containerManager",
            "value": "workflow"
        }
    ],
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "workOrderManagerPlugin",
            "containerManagerPlugin"
        ]
    }
}
﻿
Plugin
Plugin
{
	"name": "containerManagerPlugin",
	"httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/containerManager/async",
	"httpMethod": "POST",
	"httpHeaders": {
		"plugin": "containerManager"
	},
	"httpRequestBodyTemplate": [{
			"outputJsonPath": {
				"tenantId": "$.tenantId",
				"orderId": "$.orderId",
				"jobStatus": "$.status",
				"reason": "$.reason"
			}
		},
		{
			"entity": "order",
			"input": {
				"tenantId": "$.tenantId",
				"id": "$.orderId"
			},
			"outputJsonPath": {
				"containerId": "$.workOrders[0].containers[0]"
			}
		},
		{
			"entity": "job",
			"input": {
				"tenantId": "$.tenantId",
				"id": "$.jobId"
			},
			"outputJsonPath": {
				"location": "$.objectives[1].location"
			}
		}
	],
	"dlqOnFailure": true,
	"requestTimeout": 5,
	"callbackTimeout": 5,
	"responseType": "ASYNC",
	"secretKey": "SECRET_KEY",
	"protocol": "HTTP"
}
{
	"name": "containerManagerPlugin",
	"httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/containerManager/async",
	"httpMethod": "POST",
	"httpHeaders": {
		"plugin": "containerManager"
	},
	"httpRequestBodyTemplate": [{
			"outputJsonPath": {
				"tenantId": "$.tenantId",
				"orderId": "$.orderId",
				"jobStatus": "$.status",
				"reason": "$.reason"
			}
		},
		{
			"entity": "order",
			"input": {
				"tenantId": "$.tenantId",
				"id": "$.orderId"
			},
			"outputJsonPath": {
				"containerId": "$.workOrders[0].containers[0]"
			}
		},
		{
			"entity": "job",
			"input": {
				"tenantId": "$.tenantId",
				"id": "$.jobId"
			},
			"outputJsonPath": {
				"location": "$.objectives[1].location"
			}
		}
	],
	"dlqOnFailure": true,
	"requestTimeout": 5,
	"callbackTimeout": 5,
	"responseType": "ASYNC",
	"secretKey": "SECRET_KEY",
	"protocol": "HTTP"
}
﻿
Try Container Manager Plugin.
Input		Output
jobStatus	reasonCode	eventCode	reasonCode
CREATED		E-020	R-0046
IN_PROGRESS		E-021	R-0063
COMPLETED	!= R-0065	E-010	R-0041
COMPLETED	== R-0065	E-021	R-0029
Updated 08 Aug 2023
Did this page help you?
Job Manager Plugin
Work Order Manager Plugin