C#•3y ago

❔ Losing bytes when delivering dynamic object via RabbitMQ

Hey there got a bit of a complex problem.
Got this code:

public static object ToDynamicClass(this ExpandoObject expando)
{
    AssemblyName assemblyName = new AssemblyName("DynamicAssembly");
    AssemblyBuilder assemblyBuilder = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.Run);
    ModuleBuilder moduleBuilder = assemblyBuilder.DefineDynamicModule("DynamicModule");
    TypeBuilder typeBuilder = moduleBuilder.DefineType("DynamicType", TypeAttributes.Public);

    foreach (var kvp in expando)
    {
        Type type = kvp.Value?.GetType() ?? typeof(object);
        FieldBuilder field = typeBuilder.DefineField("_" + kvp.Key, type, FieldAttributes.Private);
        PropertyBuilder property = typeBuilder.DefineProperty(kvp.Key, PropertyAttributes.HasDefault, type, null);

        MethodAttributes getSetAttr = MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig;

        MethodBuilder currGetPropMthdBldr = typeBuilder.DefineMethod("get_" + kvp.Key, getSetAttr, type, Type.EmptyTypes);
        ILGenerator currGetIL = currGetPropMthdBldr.GetILGenerator();
        currGetIL.Emit(OpCodes.Ldarg_0);
        currGetIL.Emit(OpCodes.Ldfld, field);
        currGetIL.Emit(OpCodes.Ret);

//Some code removed because of character limit

        property.SetGetMethod(currGetPropMthdBldr);
        property.SetSetMethod(currSetPropMthdBldr);
    }

    Type objType = typeBuilder.CreateType();

    object obj = Activator.CreateInstance(objType);
    foreach (var kvp in expando)
    {
        objType.GetProperty(kvp.Key)?.SetValue(obj, kvp.Value);
    }

    return obj;
}

public static object ToDynamicClass(this ExpandoObject expando)
{
    AssemblyName assemblyName = new AssemblyName("DynamicAssembly");
    AssemblyBuilder assemblyBuilder = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.Run);
    ModuleBuilder moduleBuilder = assemblyBuilder.DefineDynamicModule("DynamicModule");
    TypeBuilder typeBuilder = moduleBuilder.DefineType("DynamicType", TypeAttributes.Public);

    foreach (var kvp in expando)
    {
        Type type = kvp.Value?.GetType() ?? typeof(object);
        FieldBuilder field = typeBuilder.DefineField("_" + kvp.Key, type, FieldAttributes.Private);
        PropertyBuilder property = typeBuilder.DefineProperty(kvp.Key, PropertyAttributes.HasDefault, type, null);

        MethodAttributes getSetAttr = MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig;

        MethodBuilder currGetPropMthdBldr = typeBuilder.DefineMethod("get_" + kvp.Key, getSetAttr, type, Type.EmptyTypes);
        ILGenerator currGetIL = currGetPropMthdBldr.GetILGenerator();
        currGetIL.Emit(OpCodes.Ldarg_0);
        currGetIL.Emit(OpCodes.Ldfld, field);
        currGetIL.Emit(OpCodes.Ret);

//Some code removed because of character limit

        property.SetGetMethod(currGetPropMthdBldr);
        property.SetSetMethod(currSetPropMthdBldr);
    }

    Type objType = typeBuilder.CreateType();

    object obj = Activator.CreateInstance(objType);
    foreach (var kvp in expando)
    {
        objType.GetProperty(kvp.Key)?.SetValue(obj, kvp.Value);
    }

    return obj;
}

public static object ToDynamicClass(this ExpandoObject expando)
{
    AssemblyName assemblyName = new AssemblyName("DynamicAssembly");
    AssemblyBuilder assemblyBuilder = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.Run);
    ModuleBuilder moduleBuilder = assemblyBuilder.DefineDynamicModule("DynamicModule");
    TypeBuilder typeBuilder = moduleBuilder.DefineType("DynamicType", TypeAttributes.Public);

    foreach (var kvp in expando)
    {
        Type type = kvp.Value?.GetType() ?? typeof(object);
        FieldBuilder field = typeBuilder.DefineField("_" + kvp.Key, type, FieldAttributes.Private);
        PropertyBuilder property = typeBuilder.DefineProperty(kvp.Key, PropertyAttributes.HasDefault, type, null);

        MethodAttributes getSetAttr = MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig;

        MethodBuilder currGetPropMthdBldr = typeBuilder.DefineMethod("get_" + kvp.Key, getSetAttr, type, Type.EmptyTypes);
        ILGenerator currGetIL = currGetPropMthdBldr.GetILGenerator();
        currGetIL.Emit(OpCodes.Ldarg_0);
        currGetIL.Emit(OpCodes.Ldfld, field);
        currGetIL.Emit(OpCodes.Ret);

//Some code removed because of character limit

        property.SetGetMethod(currGetPropMthdBldr);
        property.SetSetMethod(currSetPropMthdBldr);
    }

    Type objType = typeBuilder.CreateType();

    object obj = Activator.CreateInstance(objType);
    foreach (var kvp in expando)
    {
        objType.GetProperty(kvp.Key)?.SetValue(obj, kvp.Value);
    }

    return obj;
}

public static object ToDynamicClass(this ExpandoObject expando)
{
    AssemblyName assemblyName = new AssemblyName("DynamicAssembly");
    AssemblyBuilder assemblyBuilder = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.Run);
    ModuleBuilder moduleBuilder = assemblyBuilder.DefineDynamicModule("DynamicModule");
    TypeBuilder typeBuilder = moduleBuilder.DefineType("DynamicType", TypeAttributes.Public);

    foreach (var kvp in expando)
    {
        Type type = kvp.Value?.GetType() ?? typeof(object);
        FieldBuilder field = typeBuilder.DefineField("_" + kvp.Key, type, FieldAttributes.Private);
        PropertyBuilder property = typeBuilder.DefineProperty(kvp.Key, PropertyAttributes.HasDefault, type, null);

        MethodAttributes getSetAttr = MethodAttributes.Public | MethodAttributes.SpecialName | MethodAttributes.HideBySig;

        MethodBuilder currGetPropMthdBldr = typeBuilder.DefineMethod("get_" + kvp.Key, getSetAttr, type, Type.EmptyTypes);
        ILGenerator currGetIL = currGetPropMthdBldr.GetILGenerator();
        currGetIL.Emit(OpCodes.Ldarg_0);
        currGetIL.Emit(OpCodes.Ldfld, field);
        currGetIL.Emit(OpCodes.Ret);

//Some code removed because of character limit

        property.SetGetMethod(currGetPropMthdBldr);
        property.SetSetMethod(currSetPropMthdBldr);
    }

    Type objType = typeBuilder.CreateType();

    object obj = Activator.CreateInstance(objType);
    foreach (var kvp in expando)
    {
        objType.GetProperty(kvp.Key)?.SetValue(obj, kvp.Value);
    }

    return obj;
}

Before when i tried to send the ExpandoObj itself all worked well.
Now Im sending a lift of objects the above methods produces using rabbitmq.
when i seralize i got a 1500 bytes messege size, when i recive the messege its only 120 bytes.
Any ideas what could be wrong?

antimatter8189OP•8/27/23, 10:10 AM

In addition all the properties get lost, literally get "Dynamic Type" at the UI layer with nothing in it

antimatter8189OP•8/27/23, 10:10 AM

The data loss occurs during transit somehow

deprecatio•8/27/23, 10:10 AM

what object are you using to deserialize this

antimatter8189OP•8/27/23, 10:12 AM

well its a BaseDTO that contains a List<objecT> and those are located in it

antimatter8189OP•8/27/23, 10:14 AM

 var converter = new ExpandoObjConverter;
var result = JsonConvert.DeseralizeObject<ExpandoObject>(json,converter);
rsultList.add(result)
dto.Result=resultList;
return DTO;

 var converter = new ExpandoObjConverter;
var result = JsonConvert.DeseralizeObject<ExpandoObject>(json,converter);
rsultList.add(result)
dto.Result=resultList;
return DTO;

The above code works, but if i add a line of

 result= ToDynamicClass(result)

 result= ToDynamicClass(result)

and send that list, all breaks

antimatter8189OP•8/28/23, 6:30 AM

no c# gods to help out on this?

deprecatio•8/28/23, 6:37 AM

have you tried using a dictionary instead of expando
did you look at the serialized object in the rabbit ui
did you try sending a message using rabbit ui to check deserialization of problematic fields

Ddeprecatio have you tried using a dictionary instead of expando did you look at the seriali...

antimatter8189OP•8/28/23, 1:59 PM

expando uses dictionary under the hood, what u mean seralize in rabbitui?
i reverted to using custom json converters, still working on it

deprecatio•8/28/23, 7:50 PM

i mean reading (and eventually sending) the message from the queue in the ui

Accord•8/29/23, 8:19 PM

Was this issue resolved? If so, run

/close

/close

otherwise I will mark this as stale and this post will be archived until there is new activity.

❔ Losing bytes when delivering dynamic object via RabbitMQ

Similar Threads

Similar Threads

Similar Threads