esiur/esiur-dotnet
2
0
Fork 0
mirror of https://github.com/esiur/esiur-dotnet.git synced 2025-09-13 20:43:19 +00:00
Code Issues Projects Releases Wiki Activity

attr

Browse Source
This commit is contained in:
ahmed
2025-08-21 19:40:15 +03:00
parent 46b7744852
commit 488f80ff8d
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
Esiur/Net/IIP/DistributedConnectionProtocol.cs
View File

@@ -722,14 +722,15 @@ partial class DistributedConnection
} }
var (_, parsed) = Codec.ParseAsync(data, offset, this, null); var (_, parsed) = Codec.ParseAsync(data, 0, this, null, dataType);
if (parsed is AsyncReply reply) if (parsed is AsyncReply reply)
{ {
reply.Then((result) => reply.Then((result) =>
{ {
var map = (Map<byte, object>)result; var props = (Map<byte, object>)((object[])result)[4];
Warehouse.New(type, instanceName, store as IStore, parent, null, null, map) var attrs = (Map<byte, object>)((object[])result)[5];
Warehouse.New(type, instanceName, store as IStore, parent, null, attrs, props)
.Then(resource => .Then(resource =>
{ {
SendReply(IIPPacketReply.Completed, callback, resource.Instance.Id); SendReply(IIPPacketReply.Completed, callback, resource.Instance.Id);
@@ -2018,7 +2019,7 @@ partial class DistributedConnection
/// <param name="attributes">Resource attributeds.</param> /// <param name="attributes">Resource attributeds.</param>
/// <param name="values">Values for the resource properties.</param> /// <param name="values">Values for the resource properties.</param>
/// <returns>New resource instance</returns> /// <returns>New resource instance</returns>
public AsyncReply<DistributedResource> Create(IStore store, IResource parent, string className, Map<string, object> attributes, Map<string, object> values) public AsyncReply<DistributedResource> Create(IStore store, IResource parent, string className, Map<string, object> values, Map<string, object> attributes)
{ {
var reply = new AsyncReply<DistributedResource>(); var reply = new AsyncReply<DistributedResource>();
var pkt = new BinaryList() var pkt = new BinaryList()
@@ -2032,7 +2033,7 @@ partial class DistributedConnection
pkt.InsertInt32(8, pkt.Length); pkt.InsertInt32(8, pkt.Length);
SendRequest(IIPPacketRequest.CreateResource) SendRequest(IIPPacketRequest.CreateResource, store, parent, cl)
.AddUInt8Array(pkt.ToArray()) .AddUInt8Array(pkt.ToArray())
.Done() .Done()
.Then(args => .Then(args =>