using Esiur.Resource; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using Esiur.Core; using Esiur.Data; using Esiur.Resource.Template; namespace Esiur.Stores; public class MemoryStore : IStore { public Instance Instance { get; set; } public event DestroyedEvent OnDestroy; KeyList resources = new KeyList(); public void Destroy() { OnDestroy?.Invoke(this); } public string Link(IResource resource) { if (resource.Instance.Store == this) return this.Instance.Name + "/$" + resource.Instance.Id; return null; } public AsyncReply Get(string path) { if (path.StartsWith("$")) { uint id; if (uint.TryParse(path.Substring(1), out id)) { foreach (var r in resources) if (r.Value.Instance.Id == id) return new AsyncReply(r.Value); } } else { foreach (var r in resources) if (r.Value.Instance.Name == path) return new AsyncReply(r.Value); } return new AsyncReply(null); } public AsyncReply Put(IResource resource) { resources.Add(resource.Instance.Id, resource);// new WeakReference(resource)); resource.Instance.Variables["children"] = new AutoList(resource.Instance); resource.Instance.Variables["parents"] = new AutoList(resource.Instance); return new AsyncReply(true); } public AsyncReply Retrieve(uint iid) { if (resources.ContainsKey(iid)) { if (resources.ContainsKey(iid))// .TryGetTarget(out r)) return new AsyncReply(resources[iid]); else return new AsyncReply(null); } else return new AsyncReply(null); } public AsyncReply Trigger(ResourceTrigger trigger) { return new AsyncReply(true); } public bool Record(IResource resource, string propertyName, object value, ulong? age, DateTime? dateTime) { throw new NotImplementedException(); } public AsyncReply> GetRecord(IResource resource, DateTime fromDate, DateTime toDate) { throw new NotImplementedException(); } public bool Remove(IResource resource) { resources.Remove(resource.Instance.Id); return true; } public bool Modify(IResource resource, string propertyName, object value, ulong? age, DateTime? dateTime) { return true; } public AsyncReply AddChild(IResource parent, IResource child) { if (parent.Instance.Store == this) { (parent.Instance.Variables["children"] as AutoList).Add(child); return new AsyncReply(true); } else return new AsyncReply(false); } public AsyncReply RemoveChild(IResource parent, IResource child) { throw new NotImplementedException(); } public AsyncReply AddParent(IResource resource, IResource parent) { if (resource.Instance.Store == this) { (resource.Instance.Variables["parents"] as AutoList).Add(parent); return new AsyncReply(true); } else return new AsyncReply(false); } public AsyncReply RemoveParent(IResource child, IResource parent) { throw new NotImplementedException(); } public AsyncBag Children(IResource resource, string name) where T : IResource { var children = (resource.Instance.Variables["children"] as AutoList); if (name == null) return new AsyncBag(children.Where(x => x is T).Select(x => (T)x).ToArray()); else return new AsyncBag(children.Where(x => x is T && x.Instance.Name == name).Select(x => (T)x).ToArray()); } public AsyncBag Parents(IResource resource, string name) where T : IResource { var parents = (resource.Instance.Variables["parents"] as AutoList); if (name == null) return new AsyncBag(parents.Where(x => x is T).Select(x => (T)x).ToArray()); else return new AsyncBag(parents.Where(x => x is T && x.Instance.Name == name).Select(x => (T)x).ToArray()); } }