(requestId string, hashedStep ProcessStep)
| 193 | } |
| 194 | |
| 195 | func buildProcessStepPayload(requestId string, hashedStep ProcessStep) map[string]interface{} { |
| 196 | if !config.IsSSECompactMode() { |
| 197 | return map[string]interface{}{ |
| 198 | "id": requestId, |
| 199 | "object": "process.step", |
| 200 | "created": hashedStep.Timestamp, |
| 201 | "process_step": hashedStep, |
| 202 | } |
| 203 | } |
| 204 | |
| 205 | processStep := map[string]interface{}{ |
| 206 | "step_code": hashedStep.StepCode, |
| 207 | "status": hashedStep.Status, |
| 208 | "message": hashedStep.Message, |
| 209 | } |
| 210 | if len(hashedStep.Data) > 0 { |
| 211 | processStep["data"] = hashedStep.Data |
| 212 | } |
| 213 | return map[string]interface{}{ |
| 214 | "object": "process.step", |
| 215 | "process_step": processStep, |
| 216 | } |
| 217 | } |
| 218 | |
| 219 | // hashIDsInStepData 对步骤数据中的ID字段进行hash化处理 |
| 220 | func hashIDsInStepData(data map[string]interface{}) map[string]interface{} { |
no outgoing calls
no test coverage detected