Dataweave - how to group by and sum details form array of elements

Question

hope you are well, how can I generate dynamic arrays by state? That is, maybe the payload in this case has two types of state (hold, fail) but in another case maybe it has different I don't know and the output payload needs to check the state in the input group by state, remove the fields you don't need and create a total field per state and add those that belong to it...

Input:

[
 {
   "numorder": "470",
   "message": "Order number 470 already registered.",
   "status": "hold",
   "description":"",
   "createAt":""
 },
 {
   "numorder": "471",
   "message": "Order number 471 already registered.",
   "status": "failure",
   "description":"",
   "createAt":""
 },{
   "numorder": "472",
   "message": "Order number 472 already registered.",
   "status": "failure",
   "description":"",
   "createAt":""
 }
]

Output:

{
  "totalHold":1,
  "totalFailure":2,
  "items":[
     { 
        "hold":[
           {
              "numorder":"470",
              "message":"Order number 470 already registered."
           }
        ],
        "failure":[
           {
              "numorder":"471",
              "message":"Order number 471 already registered."
           },
           {
              "numorder":"472",
              "message":"Order number 472 already registered."
           }
        ]
     }
  ]

}

NOTE: the state has to be dynamic because I don't know if the input is failure, hold, success, etc.

Any help would be appreciated. Thank you.

Answer 1

Dynamic? No se hable más...

First of all, you need to group by status and then count all the elements for every group found, this will be the base for the complete solution

var results = 
        payload groupBy ((item, index) -> item.status)
        pluck ((value, key, index) -> 
            (key as String): sizeOf(value)
        )

This will give you the next result:

[
  {
    "hold": 2
  },
  {
    "failure": 2
  },
  {
    "success": 1
  }
]

Then, you need to convert the array of objects of status to a single object where every element is the status found:

{(
    results map ((item, index) -> 
        item mapObject ((total, status, index) -> 
            (status): total
        )
    ) 
)}

This will give you next result:

{
  "hold": 2,
  "failure": 2,
  "success": 1
}

Next, based on the first result array, iterate over every status and filter the payload, then print only the numorder and message attribute

{ 
  "items":
    results map ((item, index) -> 
        item mapObject ((total, status, index) -> 
            (status as String): 
                (payload filter ((itemPayload, indexPayload) -> 
                    itemPayload.status == (status as String))
                        map ((item, index) -> { 
                            "numorder": item.numorder,
                            "message": item.message
                        })
                )
            )
        )
}

In order to test the results, I added an extra 2 elements with a different status and with and different order (not together)

[
 {
   "numorder": "470",
   "message": "Order number 470 already registered.",
   "status": "hold",
   "description":"",
   "createAt":""
 },
 {
   "numorder": "471",
   "message": "Order number 471 already registered.",
   "status": "failure",
   "description":"",
   "createAt":""
 },
 {
   "numorder": "472",
   "message": "Order number 472 already registered.",
   "status": "failure",
   "description":"",
   "createAt":""
 },
 {
   "numorder": "473",
   "message": "Order number 473 already registered.",
   "status": "success",
   "description":"",
   "createAt":""
 },
  {
   "numorder": "474",
   "message": "Order number 474 already registered.",
   "status": "hold",
   "description":"",
   "createAt":""
 } 
]

The final result is:

{
  "hold": 2,
  "failure": 2,
  "success": 1,
  "items": [
    {
      "hold": [
        {
          "numorder": "470",
          "message": "Order number 470 already registered."
        },
        {
          "numorder": "474",
          "message": "Order number 474 already registered."
        }
      ]
    },
    {
      "failure": [
        {
          "numorder": "471",
          "message": "Order number 471 already registered."
        },
        {
          "numorder": "472",
          "message": "Order number 472 already registered."
        }
      ]
    },
    {
      "success": [
        {
          "numorder": "473",
          "message": "Order number 473 already registered."
        }
      ]
    }
  ]
}

The complete code:

%dw 2.0
output application/json
var results = 
        payload groupBy ((item, index) -> item.status)
        pluck ((value, key, index) -> 
            (key as String): sizeOf(value)
        )
---
{(
    results map ((item, index) -> 
        item mapObject ((total, status, index) -> 
            (status): total
        )
    ) 
)}
++
{ 
  "items":
    results map ((item, index) -> 
        item mapObject ((total, status, index) -> 
            (status as String): 
                (payload filter ((itemPayload, indexPayload) -> 
                    itemPayload.status == (status as String))
                        map ((item, index) -> { 
                            "numorder": item.numorder,
                            "message": item.message
                        })
                )
            )
        )
}