Selecting a mobility option and sending the updated quote for the same (Node.js)
In this use case, the user selects a mobility option and receives the fare for the same
Code snippets
BPP receives protocol select
/*
Example Request JSON:
{
"context": {
"domain": "nic2004:60221",
"country": "IND",
"city": "std:080",
"action": "select",
"core_version": "0.9.1",
"bap_id": "https://mock_bap.com/",
"bap_uri": "https://mock_bap.com/beckn/",
"bpp_id": "https://mock_bpp.com/",
"bpp_uri": "https://mock_bpp.com/beckn/",
"transaction_id": "1209849124",
"message_id": "12341242343",
"timestamp": "2021-03-23T10:00:40.065Z"
},
"message": {
"order": {
"items":[
{
"id": "sedan_spot",
"quantity": {
"count": 1
}
}
]
}
}
}
*/
// Auth middleware authenticates the digital signature of the incoming request
router.post('/mobility/select', auth, select);
function select({ headers, body }, res) {
try {
const message = _.get(body, "message");
const context = _.get(body, "context");
if (!context) {
return res.status(400).send(httpResponse("NACK", "Missing Context"));
}
if (!message) {
return res.status(400).send(httpResponse("NACK", "Missing Message"));
}
// ... Returns the ack immediately and continue the processing after validation
res.status(200).send(httpResponse("ACK"));
processSelect(headers, body)
} catch (error) {
res.status(500).send(httpResponse("NACK", error));
}
};
BPP processes the search
function processSelect(requestHeaders, selectRequestBody) {
// Execute business logic here
let selectResponse = {}
generateResponse(requestHeaders, selectResponse)
}
BPP generates response
function generateResponse(requestHeaders, rawResponse){
/*
Example Request JSON :
{
"context": {
"domain": "nic2004:60221",
"country": "IND",
"city": "std:080",
"action": "on_select",
"core_version": "0.9.1",
"bap_id": "https://mock_bap.com/",
"bap_uri": "https://mock_bap.com/beckn/",
"bpp_id": "https://mock_bpp.com/",
"bpp_uri": "https://mock_bpp.com/beckn/",
"transaction_id": "1209849124",
"message_id": "12341242343",
"timestamp": "2021-03-23T10:00:40.065Z"
},
"message": {
"order": {
"provider": {
"id": "yellow-cabs",
"locations": [
{
"id": "closest-sedan-spot",
"gps": "12.9349377,77.6055586"
}
]
},
"items": [
{
"id": "sedan_spot",
"price" : {
"currency": "INR",
"value": "170"
},
"time": {
"label": "ETA",
"duration": "P13M"
},
"location_id": "closest-sedan-spot",
"quantity": {
"selected": {
"count": 1
},
"available": {
"count": 4
}
}
}
],
"quote": {
"price": {
"currency": "INR",
"value": "180"
},
"breakup": [
{
"title": "Sedan Spot Booking",
"price": {
"currency": "INR",
"value": "170"
}
},
{
"title": "Service Charge",
"price": {
"currency": "INR",
"value": "10"
}
}
]
}
}
}
}
*/
//The below code generates the above example JSON.
let onSelectResponseBody = {
}
//call protocol on_rating
await callOnSelect(requestHeaders, onSelectResponseBody);
}
BPP calls protocol on_select
async function callOnSelect(requestHeaders, onSelectResponseBody) {
// Take the subscriber Id from the header and calls the registry to get the url. If already cached it need not to call again
const uri = await lookup(requestHeaders);
// Construct Header
const headers = constructAuthHeader(); // Auth Header with digital Signature
return axios({ url: `${uri}/mobility/on_select`, method: "POST", headers, data: onSelectResponseBody });
}