Function decodeTask

tools/tdbg/chasm_decoder.go:53–110

(
	task *persistencespb.ChasmComponentAttributes_Task,
	registry *chasm.Registry,
)

}

func decodeTask(
	task *persistencespb.ChasmComponentAttributes_Task,
	registry *chasm.Registry,
) (*decodedTask, error) {
	typeID := task.GetTypeId()
	fqn, _ := registry.TaskFqnByID(typeID)

	var scheduledTime string
	if ts := task.GetScheduledTime(); ts != nil {
		scheduledTime = ts.AsTime().UTC().Format(defaultDateTimeFormat)
	}

	decoded := &decodedTask{
		TypeID:              typeID,
		TaskFQN:             fqn,
		Destination:         task.GetDestination(),
		ScheduledTime:       scheduledTime,
		VersionedTransition: task.GetVersionedTransition(),
		PhysicalTaskStatus:  task.GetPhysicalTaskStatus(),
	}

	rt, ok := registry.TaskByID(typeID)
	if !ok {
		decoded.RawData = task.GetData()
		return decoded, nil
	}

	goType := rt.GoType()
	if goType == nil {
		decoded.RawData = task.GetData()
		return decoded, nil
	}

	messageValue := reflect.New(goType.Elem())
	message, ok := messageValue.Interface().(proto.Message)
	if !ok {
		decoded.RawData = task.GetData()
		return decoded, nil
	}

	dataBlob := task.GetData()
	if dataBlob != nil && len(dataBlob.GetData()) > 0 {
		message = message.ProtoReflect().New().Interface()
		if err := serialization.Decode(dataBlob, message); err != nil {
			decoded.RawData = dataBlob
			return decoded, nil
		}
	}

	jsonBytes, err := codec.NewJSONPBEncoder().Encode(message)
	if err != nil {
		decoded.RawData = dataBlob
		return decoded, nil
	}

	decoded.DecodedData = json.RawMessage(jsonBytes)
	return decoded, nil
}