VI.Projector/VI.Projector.Connection.Remoting/RemoteConnectorServiceClient.cs

1using System;2using VI.Projector.Connection.Remoting.Proxies;3using VI.Projector.Schema;4using VI.Remoting.Security;5using VI.Remoting.Services;67namespace VI.Projector.Connection.Remoting;89/// <summary>10/// Special service client for the connector service in order to be able to inherit from RemoteServiceClient.11/// </summary>12internal sealed class RemoteConnectorServiceClient : RemoteServiceClient13{14	/// <summary>15	/// Gets the flag, whether the connector is connected.16	/// </summary>17	public bool IsConnected => Get<bool>("IsConnected");1819	/// <summary>20	/// Gets an unique id of the connected system.21	/// </summary>22	public SystemDescription SystemDescription => Get<SystemDescription>("SystemDescription");2324	/// <summary>25	/// Gets the capabilities of the connector.26	/// </summary>27	public SystemConnectorCapabilities Capabilities => Get<SystemConnectorCapabilities>("Capabilities");2829	/// <summary>30	/// Gets the last access time of the service.31	/// </summary>32	public System.DateTime LastAccessTime => Get<System.DateTime>("LastAccessTime");3334	/// <summary>35	/// Default constructor of class RemoteServiceClient.36	/// </summary>37	internal RemoteConnectorServiceClient(RemoteServiceDescriptor serviceDescriptor, AuthenticationParameters authParameters, RemoteClientOption clientOption)38		: base(serviceDescriptor, authParameters, clientOption)39	{40	}4142	/// <summary>43	/// Is called to subscribe all events.44	/// </summary>45	public void SubscribeEvents()46	{47		//IL_0000: Unknown result type (might be due to invalid IL or missing references)48		throw new NotImplementedException();49	}5051	protected override void OnDispose()52	{53		base.OnDispose();54	}5556	/// <summary>57	/// Establishes the connection to the system.58	/// </summary>59	/// <param name="connectionParameter">The parameter for the connection.</param>60	public void Connect(string connectionParameter)61	{62		CallMethod("Connect", ParameterInfo.Create("connectionParameter", connectionParameter));63	}6465	/// <summary>66	/// Disconnects an existing connection.67	/// </summary>68	public void Disconnect(DisconnectOptions options)69	{70		CallMethod("Disconnect", ParameterInfo.Create("options", options));71	}7273	/// <summary>74	/// Is called to get the revision of a particular schema type.75	/// </summary>76	/// <returns>The revision if known, otherwise null.</returns>77	public GetRevisionResult GetRevision(GetRevisionRequest request)78	{79		return CallFunction<GetRevisionResult>("GetRevision", new ParameterInfo[1] { ParameterInfo.Create("request", request) });80	}8182	/// <summary>83	/// Gets and removes the result with the given id.84	/// </summary>85	public SystemConnectorResult DequeueResult(string id)86	{87		return CallFunction<SystemConnectorResult>("DequeueResult", new ParameterInfo[1] { ParameterInfo.Create("id", id) });88	}8990	/// <summary>91	/// Gets one object of that class.92	/// </summary>93	/// <returns>The one schema object or null.</returns>94	public RemoteResult<QueryObjectDataResult> QueryObject(QueryObjectByKeyRequest request)95	{96		return CallFunction<RemoteResult<QueryObjectDataResult>>("QueryObject", new ParameterInfo[1] { ParameterInfo.Create("request", request) });97	}9899	/// <summary>100	/// Gets all objects of that class.101	/// </summary>102	/// <returns>The collection with all objects.</returns>103	public RemoteResult<QueryObjectDataResult> QueryObjects(QueryObjectsRequest request)104	{105		return CallFunction<RemoteResult<QueryObjectDataResult>>("QueryObjects", new ParameterInfo[1] { ParameterInfo.Create("request", request) });106	}107108	/// <summary>109	/// Creates a new object of that class.110	/// </summary>111	/// <returns>The new schema object or null.</returns>112	public CreateObjectDataResult CreateObject(CreateObjectRequest request)113	{114		return CallFunction<CreateObjectDataResult>("CreateObject", new ParameterInfo[1] { ParameterInfo.Create("request", request) });115	}116117	/// <summary>118	/// Commits all changes of an object.119	/// </summary>120	public RemoteConnectorServiceResultWithRequest<CommitObjectRequest, CommitObjectDataResult> CommitObject(CommitObjectRequest request)121	{122		return CallFunction<RemoteConnectorServiceResultWithRequest<CommitObjectRequest, CommitObjectDataResult>>("CommitObject", new ParameterInfo[1] { ParameterInfo.Create("request", request) });123	}124125	/// <summary>126	/// Deletes the given object.127	/// </summary>128	public RemoteConnectorServiceResultWithRequest<DeleteObjectRequest, DeleteObjectDataResult> DeleteObject(DeleteObjectRequest request)129	{130		return CallFunction<RemoteConnectorServiceResultWithRequest<DeleteObjectRequest, DeleteObjectDataResult>>("DeleteObject", new ParameterInfo[1] { ParameterInfo.Create("request", request) });131	}132133	/// <summary>134	/// Reloads the given objects with a different property set. Existing properties will be reused.135	/// </summary>136	/// <returns>The list of new objects.</returns>137	public RemoteResult<ReloadObjectDataResult> ReloadObject(ReloadObjectsRequest request)138	{139		return CallFunction<RemoteResult<ReloadObjectDataResult>>("ReloadObject", new ParameterInfo[1] { ParameterInfo.Create("request", request) });140	}141142	/// <summary>143	/// Executes the method.144	/// </summary>145	public RemoteConnectorServiceResultWithRequest<ExecuteMethodRequest, ExecuteObjectDataMethodResult> ExecuteMethod(ExecuteMethodRequest request)146	{147		return CallFunction<RemoteConnectorServiceResultWithRequest<ExecuteMethodRequest, ExecuteObjectDataMethodResult>>("ExecuteMethod", new ParameterInfo[1] { ParameterInfo.Create("request", request) });148	}149150	/// <summary>151	/// Resolves the reference objects of a certain reference.152	/// </summary>153	/// <returns>The list of new objects.</returns>154	public ResolveObjectDataReferenceResult ResolveReference(ResolveReferenceRequest request)155	{156		return CallFunction<ResolveObjectDataReferenceResult>("ResolveReference", new ParameterInfo[1] { ParameterInfo.Create("request", request) });157	}158159	/// <summary>160	/// Creates references to system objects.161	/// </summary>162	/// <returns>The list of references to the given system objects.</returns>163	public CreateObjectDataReferenceResult CreateReference(CreateReferenceRequest request)164	{165		return CallFunction<CreateObjectDataReferenceResult>("CreateReference", new ParameterInfo[1] { ParameterInfo.Create("request", request) });166	}167168	/// <summary>169	/// Begins a new update phase.170	/// </summary>171	public void BeginUpdate()172	{173		CallMethod("BeginUpdate");174	}175176	/// <summary>177	/// MUST be called after a begin update.178	/// </summary>179	public void EndUpdate()180	{181		CallMethod("EndUpdate");182	}183184	/// <summary>185	/// Resolves the object of the given type.186	/// </summary>187	/// <typeparam name="T">The type of the object to resolve. F.e. INativeSystemFilterFormatter or ISystemAttachedDataStore.</typeparam>188	/// <returns>The object or null if not supported.</returns>189	public T Resolve<T>(bool throwIfNotSupported)190	{191		T val = CallFunction<T, T>("Resolve", new ParameterInfo[1] { ParameterInfo.Create("throwIfNotSupported", throwIfNotSupported) });192		if (val is RemoteServiceProxyClientBase remoteServiceProxyClientBase)193		{194			remoteServiceProxyClientBase.UpdateWithUserData(base.ServiceDescriptor.AccessParameter, base.ClientOption);195		}196		return val;197	}198199	/// <summary>200	/// Gets a display of the connector.201	/// </summary>202	public string GetDisplay()203	{204		return CallFunction<string>("GetDisplay", System.Array.Empty<ParameterInfo>());205	}206207	/// <summary>208	/// Gets the schema of the system.209	/// </summary>210	/// <returns>The schema.</returns>211	public string GetSchema()212	{213		return CallFunction<string>("GetSchema", System.Array.Empty<ParameterInfo>());214	}215216	/// <summary>217	/// Gets the schema of the system.218	/// </summary>219	/// <returns>The schema.</returns>220	public void SetSchema(string schema)221	{222		CallMethod("SetSchema", ParameterInfo.Create("schema", schema));223	}224}225