Lwm2mAccessControlObject.cs

using System;
using System.Threading.Tasks;
using Waher.Networking.CoAP;
using Waher.Persistence;
using Waher.Persistence.Filters;

namespace Waher.Networking.LWM2M
{
	/// <summary>
	/// LWM2M Access Control object.
	/// </summary>
    public class Lwm2mAccessControlObject : Lwm2mObject
    {
		/// <summary>
		/// LWM2M Access Control object.
		/// </summary>
		public Lwm2mAccessControlObject()
			: base(2)
		{
		}

		/// <summary>
		/// Loads any Bootstrap information.
		/// </summary>
		public override async Task LoadBootstrapInfo()
		{
			this.ClearInstances();

			foreach (Lwm2mAccessControlObjectInstance Instance in await Database.Find<Lwm2mAccessControlObjectInstance>(
				new FilterFieldEqualTo("Id", this.Id), "InstanceId"))
			{
				try
				{
					this.Add(Instance);
				}
				catch (Exception)
				{
					await Database.Delete(Instance);
				}
			}

			await base.LoadBootstrapInfo();
		}

		/// <summary>
		/// Deletes any Bootstrap information.
		/// </summary>
		public override async Task DeleteBootstrapInfo()
		{
			await base.DeleteBootstrapInfo();
			this.ClearInstances();
		}

		/// <summary>
		/// If the resource handles subpaths.
		/// </summary>
		public override bool HandlesSubPaths => true;

		/// <summary>
		/// If the PUT method is allowed.
		/// </summary>
		public bool AllowsPUT => true;

		/// <summary>
		/// Executes the PUT method on the resource.
		/// </summary>
		/// <param name="Request">CoAP Request</param>
		/// <param name="Response">CoAP Response</param>
		/// <exception cref="CoapException">If an error occurred when processing the method.</exception>
		public async Task PUT(CoapMessage Request, CoapResponse Response)
		{
			if (this.Client.State == Lwm2mState.Bootstrap)
			{
				if (!string.IsNullOrEmpty(Request.SubPath) &&
					ushort.TryParse(Request.SubPath.Substring(1), out ushort InstanceId))
				{
					Lwm2mAccessControlObjectInstance Instance = new Lwm2mAccessControlObjectInstance(InstanceId);
					this.Add(Instance);
					this.Client.Endpoint.Register(Instance);
					await Instance.AfterRegister(this.Client);

					await Instance.PUT(Request, Response);
				}
				else
					await Response.RST(CoapCode.BadRequest);
			}
			else
				await Response.RST(CoapCode.Unauthorized);
		}
	}
}