You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@olingo.apache.org by ko...@apache.org on 2015/03/23 10:58:43 UTC
[13/22] olingo-odata4-js git commit: [OLINGO-442] Cleanup bevor
release
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/ReflectionDataContext.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/ReflectionDataContext.cs b/JSLib/tests/code/ReflectionDataContext.cs
deleted file mode 100644
index eb70949..0000000
--- a/JSLib/tests/code/ReflectionDataContext.cs
+++ /dev/null
@@ -1,742 +0,0 @@
-// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved.
-// Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation
-// files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy,
-// modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the
-// Software is furnished to do so, subject to the following conditions:
-//
-// The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE
-// WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
-// COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
-// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-namespace DataJS.Tests
-{
- using System;
- using System.Collections;
- using System.Collections.Generic;
- using System.Collections.ObjectModel;
- using Microsoft.OData.Service;
- using Microsoft.OData.Service.Common;
- using System.Globalization;
- using System.Linq;
- using System.Reflection;
-
- /// <summary>
- /// Provides a reflection-based, updatable data context.
- /// </summary>
- public abstract class ReflectionDataContext
- {
- // Fields
- private List<object> deletedObjects = new List<object>();
- private List<Action> pendingChanges;
- private static Dictionary<Type, Dictionary<string, IList>> resourceSetsByContextTypeStorage = new Dictionary<Type, Dictionary<string, IList>>();
-
- // Methods
- protected ReflectionDataContext()
- {
- this.MetadataHelper = new ReflectionMetadataHelper(this);
- this.pendingChanges = new List<Action>();
- if (!resourceSetsByContextTypeStorage.ContainsKey(base.GetType()))
- {
- resourceSetsByContextTypeStorage.Add(base.GetType(), new Dictionary<string, IList>());
- foreach (string resourceSetName in this.MetadataHelper.GetResourceSetNames())
- {
- Type resourceType = this.MetadataHelper.GetResourceTypeOfSet(resourceSetName);
- IList listOfTInstance = Activator.CreateInstance(typeof(List<>).MakeGenericType(new Type[] { resourceType })) as IList;
- this.ResourceSetsStorage.Add(resourceSetName, listOfTInstance);
- }
- }
- this.EnsureDataIsInitialized();
- }
-
- public virtual void AddReferenceToCollection(object targetResource, string propertyName, object resourceToBeAdded)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyName, "propertyName");
- ExceptionUtilities.CheckArgumentNotNull(resourceToBeAdded, "resourceToBeAdded");
- UpdatableToken targetToken = UpdatableToken.AssertIsToken(targetResource, "targetResource");
- targetResource = targetToken.Resource;
- resourceToBeAdded = UpdatableToken.AssertIsTokenAndResolve(resourceToBeAdded, "resourceToBeAdded");
- IList list = this.GetValue(targetToken, propertyName) as IList;
- ExceptionUtilities.CheckObjectNotNull(list, "Property '{0}' on type '{1}' was not a list", new object[] { propertyName, targetResource.GetType().Name });
- this.pendingChanges.Add(delegate {
- list.Add(resourceToBeAdded);
- });
- }
-
- public virtual void ClearChanges()
- {
- this.pendingChanges.Clear();
- }
-
- public void ClearData()
- {
- this.ResourceSetsStorage.Clear();
- }
-
- private static bool CompareETagValues(Dictionary<string, object> resourceCookieValues, IEnumerable<KeyValuePair<string, object>> concurrencyValues)
- {
- if (concurrencyValues.Count<KeyValuePair<string, object>>() != resourceCookieValues.Count)
- {
- return false;
- }
- foreach (KeyValuePair<string, object> keyValuePair in concurrencyValues)
- {
- if (!resourceCookieValues.ContainsKey(keyValuePair.Key))
- {
- return false;
- }
- if (keyValuePair.Value == null)
- {
- return (resourceCookieValues[keyValuePair.Key] == null);
- }
- if (!keyValuePair.Value.Equals(resourceCookieValues[keyValuePair.Key]))
- {
- return false;
- }
- }
- return true;
- }
-
- public virtual object CreateResource(string containerName, string fullTypeName)
- {
- ExceptionUtilities.CheckArgumentNotNull(fullTypeName, "fullTypeName");
- UpdatableToken token = this.InstantiateResourceType(fullTypeName);
- if (containerName != null)
- {
- this.pendingChanges.Add(delegate {
- this.GetResourceSetEntities(containerName).Add(token.Resource);
- });
- }
- return token;
- }
-
- private void DeleteAllReferences(object targetResource)
- {
- foreach (string currentSetName in this.MetadataHelper.GetResourceSetNames())
- {
- Type currentEntityType = this.MetadataHelper.GetResourceTypeOfSet(currentSetName);
- IList entitySetList = this.GetResourceSetEntities(currentSetName);
- foreach (NavigationPropertyInfo navigationProperty in this.MetadataHelper.GetNavigationProperties(GetResourceTypeFullName(currentEntityType)))
- {
- if (navigationProperty.CollectionElementType != null)
- {
- foreach (object currentEntityInstance in entitySetList)
- {
- this.RemoveResourceFromCollectionOnTargetResourceMatch(targetResource, navigationProperty, currentEntityInstance);
- }
- }
- else
- {
- ExceptionUtilities.CheckObjectNotNull(navigationProperty.PropertyInfo, "Invalid navigation property info", new object[0]);
- foreach (object currentEntityInstance in entitySetList)
- {
- this.SetEntityReferenceToNullOnTargetResourceMatch(targetResource, navigationProperty, currentEntityInstance);
- }
- }
- }
- }
- }
-
- public virtual void DeleteResource(object targetResource)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- targetResource = UpdatableToken.AssertIsTokenAndResolve(targetResource, "targetResource");
- string resourceSetName = this.GetResourceSetOfTargetResource(targetResource);
- ExceptionUtilities.CheckObjectNotNull(resourceSetName, "Unable to find set of the resource to delete", new object[0]);
- this.deletedObjects.Add(targetResource);
- IList resourceSetList = this.GetResourceSetEntities(resourceSetName);
- this.DeleteAllReferences(targetResource);
- this.pendingChanges.Add(delegate {
- resourceSetList.Remove(targetResource);
- });
- }
-
- protected abstract void EnsureDataIsInitialized();
-
- protected virtual Type GetCollectionPropertyType(string fullTypeName, string propertyName)
- {
- Type type = this.MetadataHelper.FindClrTypeByFullName(fullTypeName);
- Type collectionType = null;
- if (type != null)
- {
- PropertyInfo property = type.GetProperty(propertyName);
- if (property != null)
- {
- collectionType = property.PropertyType;
- }
- }
- return collectionType;
- }
-
- private Dictionary<string, object> GetConcurrencyValues(object targetResource)
- {
- Dictionary<string, object> etagValues = new Dictionary<string, object>();
- foreach (string etagProperty in this.MetadataHelper.GetETagPropertiesOfType(GetResourceTypeFullName(targetResource.GetType())))
- {
- etagValues.Add(etagProperty, targetResource.GetType().GetProperty(etagProperty).GetValue(targetResource, null));
- }
- return etagValues;
- }
-
- public virtual object GetResource(IQueryable query, string fullTypeName)
- {
- ExceptionUtilities.CheckArgumentNotNull(query, "query");
- object resource = null;
- foreach (object r in query)
- {
- ExceptionUtilities.Assert(resource == null, "Invalid Uri specified. The query '{0}' must refer to a single resource", new object[] { query.ToString() });
- resource = r;
- }
- if (resource == null)
- {
- return null;
- }
- if (fullTypeName != null)
- {
- this.ValidateResourceType(resource, fullTypeName);
- }
- return new UpdatableToken(resource);
- }
-
- public IList<T> GetResourceSetEntities<T>(string resourceSetName)
- {
- return (IList<T>) this.GetResourceSetEntities(resourceSetName);
- }
-
- internal IList GetResourceSetEntities(string resourceSetName)
- {
- IList entities;
- if (!this.ResourceSetsStorage.TryGetValue(resourceSetName, out entities))
- {
- Type elementType = this.MetadataHelper.GetResourceTypeOfSet(resourceSetName);
- entities = (IList) Activator.CreateInstance(typeof(List<>).MakeGenericType(new Type[] { elementType }));
- this.ResourceSetsStorage[resourceSetName] = entities;
- }
- return entities;
- }
-
- private string GetResourceSetOfTargetResource(object targetResource)
- {
- foreach (string currentResourceSetName in this.MetadataHelper.GetResourceSetNames())
- {
- if (this.GetResourceSetEntities(currentResourceSetName).Contains(targetResource))
- {
- return currentResourceSetName;
- }
- }
- return null;
- }
-
- public static string GetResourceTypeFullName(Type type)
- {
- return type.FullName.Replace('+', '_');
- }
-
- public virtual object GetValue(object targetResource, string propertyName)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyName, "propertyName");
- UpdatableToken token = UpdatableToken.AssertIsToken(targetResource, "targetResource");
- if (token.PendingPropertyUpdates.ContainsKey(propertyName))
- {
- return token.PendingPropertyUpdates[propertyName];
- }
- targetResource = token.Resource;
- PropertyInfo pi = targetResource.GetType().GetProperty(propertyName);
- ExceptionUtilities.CheckObjectNotNull(pi, "Cannot find the property '{0}' on type '{1}'", new object[] { propertyName, targetResource.GetType().Name });
- object value = pi.GetValue(targetResource, null);
- if ((value != null) && (pi.PropertyType.Assembly == base.GetType().Assembly))
- {
- ExceptionUtilities.Assert(!this.MetadataHelper.IsTypeAnEntityType(pi.PropertyType), "GetValue should never be called for reference properties. Type was '{0}', property was '{1}'", new object[] { pi.PropertyType.FullName, propertyName });
- value = new UpdatableToken(value);
- }
- return value;
- }
-
- private UpdatableToken InstantiateResourceType(string fullTypeName)
- {
- Type t = this.MetadataHelper.FindClrTypeByFullName(fullTypeName);
- object instance = Activator.CreateInstance(t);
- UpdatableToken token = new UpdatableToken(instance);
- foreach (PropertyInfo p in t.GetProperties())
- {
- object generatedValue;
- PropertyInfo property = p;
- if (this.IsCollectionProperty(property))
- {
- Type collectionType = this.GetCollectionPropertyType(GetResourceTypeFullName(t), property.Name);
- if (collectionType != null)
- {
- object newCollection = Activator.CreateInstance(collectionType);
- token.PendingPropertyUpdates[property.Name] = newCollection;
- this.pendingChanges.Add(delegate {
- property.SetValue(instance, newCollection, null);
- });
- }
- }
- if (this.TryGetStoreGeneratedValue(fullTypeName, property.Name, out generatedValue))
- {
- token.PendingPropertyUpdates[property.Name] = generatedValue;
- this.pendingChanges.Add(delegate {
- property.SetValue(instance, generatedValue, null);
- });
- }
- }
- return token;
- }
-
- protected virtual bool IsCollectionProperty(PropertyInfo propertyInfo)
- {
- return ((typeof(IEnumerable).IsAssignableFrom(propertyInfo.PropertyType) && (propertyInfo.PropertyType != typeof(string))) && (propertyInfo.PropertyType != typeof(byte[])));
- }
-
- public virtual void RemoveReferenceFromCollection(object targetResource, string propertyName, object resourceToBeRemoved)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyName, "propertyName");
- ExceptionUtilities.CheckArgumentNotNull(resourceToBeRemoved, "resourceToBeRemoved");
- UpdatableToken.AssertIsToken(targetResource, "targetResource");
- resourceToBeRemoved = UpdatableToken.AssertIsTokenAndResolve(resourceToBeRemoved, "resourceToBeRemoved");
- IList list = this.GetValue(targetResource, propertyName) as IList;
- ExceptionUtilities.CheckObjectNotNull(list, "Property '{0}' on type '{1}' was not a list", new object[] { propertyName, targetResource.GetType().Name });
- this.pendingChanges.Add(delegate {
- list.Remove(resourceToBeRemoved);
- });
- }
-
- private void RemoveResourceFromCollectionOnTargetResourceMatch(object targetResource, NavigationPropertyInfo navigationPropertyInfo, object currentEntityInstance)
- {
- IEnumerable childCollectionObject = navigationPropertyInfo.PropertyInfo.GetValue(currentEntityInstance, null) as IEnumerable;
- if (childCollectionObject.Cast<object>().Any<object>(delegate (object o) {
- return o == targetResource;
- }))
- {
- MethodInfo removeMethod = navigationPropertyInfo.PropertyInfo.PropertyType.GetMethod("Remove");
- this.pendingChanges.Add(delegate {
- removeMethod.Invoke(childCollectionObject, new object[] { targetResource });
- });
- }
- }
-
- public virtual object ResetResource(object resource)
- {
- ExceptionUtilities.CheckArgumentNotNull(resource, "resource");
- UpdatableToken token = UpdatableToken.AssertIsToken(resource, "resource");
- resource = token.Resource;
- token = new UpdatableToken(resource);
- object newInstance = Activator.CreateInstance(resource.GetType());
- ExceptionUtilities.CheckObjectNotNull(newInstance, "Cannot reset resource because unable to creating new instance of type '{0}' returns null", new object[] { resource.GetType().Name });
- foreach (string propertyToReset in this.MetadataHelper.GetPropertiesToReset(GetResourceTypeFullName(resource.GetType())))
- {
- PropertyInfo pi = newInstance.GetType().GetProperty(propertyToReset);
- ExceptionUtilities.CheckObjectNotNull(pi, "Cannot reset resource because unable to find property '{0}'", new object[] { propertyToReset });
- object newValue = pi.GetValue(newInstance, null);
- this.pendingChanges.Add(delegate {
- pi.SetValue(resource, newValue, null);
- });
- token.PendingPropertyUpdates[propertyToReset] = newValue;
- }
- return token;
- }
-
- public virtual object ResolveResource(object resource)
- {
- ExceptionUtilities.CheckArgumentNotNull(resource, "resource");
- return UpdatableToken.AssertIsTokenAndResolve(resource, "resource");
- }
-
- public virtual void SaveChanges()
- {
- foreach (Action pendingChange in this.pendingChanges)
- {
- pendingChange();
- }
- this.pendingChanges.Clear();
- foreach (object deleted in this.deletedObjects)
- {
- foreach (object entity in this.ResourceSetsStorage.SelectMany<KeyValuePair<string, IList>, object>(delegate (KeyValuePair<string, IList> p) {
- return p.Value.Cast<object>();
- }))
- {
- ExceptionUtilities.Assert(!object.ReferenceEquals(deleted, entity), "Found deleted entity!", new object[0]);
- foreach (PropertyInfo propertyInfo in entity.GetType().GetProperties())
- {
- object value = propertyInfo.GetValue(entity, null);
- ExceptionUtilities.Assert(!object.ReferenceEquals(deleted, value), "Found deleted entity!", new object[0]);
- IEnumerable enumerable = value as IEnumerable;
- if (enumerable != null)
- {
- foreach (object valueElement in enumerable.Cast<object>())
- {
- ExceptionUtilities.Assert(!object.ReferenceEquals(deleted, valueElement), "Found deleted entity!", new object[0]);
- }
- }
- }
- }
- }
- this.deletedObjects.Clear();
- }
-
- protected virtual void SetCollectionPropertyValue(object targetResource, PropertyInfo propertyInfo, IEnumerable propertyValue)
- {
- object collection;
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyInfo, "propertyInfo");
- ExceptionUtilities.CheckArgumentNotNull(propertyValue, "propertyValue");
- Type collectionType = this.GetCollectionPropertyType(GetResourceTypeFullName(propertyInfo.ReflectedType), propertyInfo.Name);
- ExceptionUtilities.CheckObjectNotNull(collectionType, "Could not infer collection type for property", new object[0]);
- propertyValue = propertyValue.Cast<object>().Select<object, object>(delegate (object o) {
- return UpdatableToken.ResolveIfToken(o);
- });
- ConstructorInfo enumerableConstructor = collectionType.GetConstructor(new Type[] { typeof(IEnumerable) });
- if (enumerableConstructor != null)
- {
- collection = enumerableConstructor.Invoke(new object[] { propertyValue });
- }
- else if (collectionType.IsGenericType && (collectionType.GetGenericArguments().Count<Type>() == 1))
- {
- Type typeArgument = collectionType.GetGenericArguments().Single<Type>();
- ConstructorInfo typedEnumerableConstructor = collectionType.GetConstructor(new Type[] { typeof(IEnumerable<>).MakeGenericType(new Type[] { typeArgument }) });
- if (typedEnumerableConstructor != null)
- {
- object typedEnumerable = typeof(Enumerable).GetMethod("Cast").MakeGenericMethod(new Type[] { typeArgument }).Invoke(null, new object[] { propertyValue });
- collection = typedEnumerableConstructor.Invoke(new object[] { typedEnumerable });
- }
- else
- {
- MethodInfo typedAddMethod = collectionType.GetMethod("Add", new Type[] { typeArgument });
- ExceptionUtilities.CheckObjectNotNull(typedAddMethod, "Could not find constructor or add method for type: " + collectionType.FullName, new object[0]);
- collection = Activator.CreateInstance(collectionType);
- foreach (object element in propertyValue)
- {
- typedAddMethod.Invoke(collection, new object[] { element });
- }
- }
- }
- else
- {
- MethodInfo addMethod = collectionType.GetMethod("Add");
- ExceptionUtilities.CheckObjectNotNull(addMethod, "Could not find constructor or add method for type: " + collectionType.FullName, new object[0]);
- collection = Activator.CreateInstance(collectionType);
- foreach (object element in propertyValue)
- {
- addMethod.Invoke(collection, new object[] { element });
- }
- }
- propertyInfo.SetValue(targetResource, collection, null);
- }
-
- public virtual void SetConcurrencyValues(object resourceCookie, bool? checkForEquality, IEnumerable<KeyValuePair<string, object>> concurrencyValues)
- {
- ExceptionUtilities.CheckArgumentNotNull(resourceCookie, "resourceCookie");
- ExceptionUtilities.ThrowDataServiceExceptionIfFalse(checkForEquality.HasValue, 0x1a1, "Missing concurrency token for update operation", new object[0]);
- ExceptionUtilities.Assert(checkForEquality.Value, "Should not be called with check for equality parameter equal to false", new object[0]);
- ExceptionUtilities.CheckArgumentNotNull(concurrencyValues, "concurrencyValues");
- if (concurrencyValues.Any<KeyValuePair<string, object>>())
- {
- resourceCookie = UpdatableToken.AssertIsTokenAndResolve(resourceCookie, "resourceCookie");
- ExceptionUtilities.ThrowDataServiceExceptionIfFalse(CompareETagValues(this.GetConcurrencyValues(resourceCookie), concurrencyValues), 0x19c, "Concurrency tokens do not match", new object[0]);
- }
- }
-
- private void SetEntityReferenceToNullOnTargetResourceMatch(object targetResource, NavigationPropertyInfo navigationPropertyInfo, object currentEntityInstance)
- {
- if (navigationPropertyInfo.PropertyInfo.GetValue(currentEntityInstance, null) == targetResource)
- {
- this.pendingChanges.Add(delegate {
- navigationPropertyInfo.PropertyInfo.SetValue(currentEntityInstance, null, null);
- });
- }
- }
-
- public virtual void SetReference(object targetResource, string propertyName, object propertyValue)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyName, "propertyName");
- if (propertyValue != null)
- {
- UpdatableToken.AssertIsToken(propertyValue, "propertyValue");
- }
- this.SetValue(targetResource, propertyName, propertyValue);
- }
-
- public virtual void SetValue(object targetResource, string propertyName, object propertyValue)
- {
- ExceptionUtilities.CheckArgumentNotNull(targetResource, "targetResource");
- ExceptionUtilities.CheckArgumentNotNull(propertyName, "propertyName");
- UpdatableToken token = UpdatableToken.AssertIsToken(targetResource, "targetResource");
- targetResource = token.Resource;
- token.PendingPropertyUpdates[propertyName] = propertyValue;
- this.pendingChanges.Add(delegate {
- object generatedValue;
- Type t = targetResource.GetType();
- PropertyInfo pi = t.GetProperty(propertyName);
- ExceptionUtilities.CheckObjectNotNull(pi, "Unable to find property '{0}' on type '{1}'", new object[] { propertyName, targetResource.GetType().Name });
- if (this.TryGetStoreGeneratedValue(GetResourceTypeFullName(t), propertyName, out generatedValue))
- {
- propertyValue = generatedValue;
- }
- if (this.IsCollectionProperty(pi))
- {
- ExceptionUtilities.CheckObjectNotNull(propertyValue, "Collection property value was null", new object[0]);
- IEnumerable enumerable = propertyValue as IEnumerable;
- ExceptionUtilities.CheckObjectNotNull(enumerable, "Collection property value was not an enumerable", new object[0]);
- this.SetCollectionPropertyValue(targetResource, pi, enumerable);
- }
- else
- {
- propertyValue = UpdatableToken.ResolveIfToken(propertyValue);
- pi.SetValue(targetResource, propertyValue, null);
- }
- });
- }
-
- protected virtual bool TryGetStoreGeneratedValue(string fullTypeName, string propertyName, out object propertyValue)
- {
- propertyValue = null;
- return false;
- }
-
- private void ValidateResourceType(object targetResource, string fullTypeName)
- {
- ExceptionUtilities.Assert(this.MetadataHelper.FindClrTypeByFullName(fullTypeName).IsAssignableFrom(targetResource.GetType()), "Invalid uri specified. expected type: '{0}', actual type: '{1}'", new object[] { fullTypeName, targetResource.GetType().FullName });
- }
-
- // Properties
- internal ReflectionMetadataHelper MetadataHelper { get; set; }
-
- internal Dictionary<string, IList> ResourceSetsStorage
- {
- get
- {
- Dictionary<string, IList> resourceSetsLookup = null;
- Type currentContextType = base.GetType();
- ExceptionUtilities.Assert(resourceSetsByContextTypeStorage.TryGetValue(currentContextType, out resourceSetsLookup), "Cannot find resource sets by the context type '{0}'", new object[] { currentContextType });
- return resourceSetsLookup;
- }
- }
-
- #region Inner types.
-
- internal class ReflectionMetadataHelper
- {
- // Fields
- private ReflectionDataContext reflectionDataContext;
-
- // Methods
- public ReflectionMetadataHelper(ReflectionDataContext reflectionDataContext)
- {
- this.reflectionDataContext = reflectionDataContext;
- }
-
- public Type FindClrTypeByFullName(string resourceTypeFullName)
- {
- Type type = this.reflectionDataContext.GetType().Assembly.GetTypes().Where<Type>(delegate (Type t) {
- return (ReflectionDataContext.GetResourceTypeFullName(t) == resourceTypeFullName);
- }).FirstOrDefault<Type>();
- ExceptionUtilities.CheckObjectNotNull(type, "Unable to find type '{0}'", new object[] { resourceTypeFullName });
- return type;
- }
-
- public string[] GetETagPropertiesOfType(string fullTypeName)
- {
- Type type = this.FindClrTypeByFullName(fullTypeName);
- List<string> etags = new List<string>();
- foreach (ETagAttribute customAttribute in type.GetCustomAttributes(typeof(ETagAttribute), true))
- {
- etags.AddRange(customAttribute.PropertyNames);
- }
-
- return etags.ToArray();
- }
-
- public string[] GetKeyProperties(string fullTypeName)
- {
- Type type = this.FindClrTypeByFullName(fullTypeName);
- List<string> keyPropertyList = new List<string>();
- foreach (PropertyInfo keyProperty in type.GetProperties().Where(pi => pi.Name.Contains("ID")))
- {
- keyPropertyList.Add(keyProperty.Name);
- }
-
- foreach (DataServiceKeyAttribute customAttribute in type.GetCustomAttributes(typeof(DataServiceKeyAttribute), true))
- {
- keyPropertyList.AddRange(customAttribute.KeyNames);
- }
-
- return keyPropertyList.ToArray();
- }
-
- public NavigationPropertyInfo[] GetNavigationProperties(string fullTypeName)
- {
- Type type = this.FindClrTypeByFullName(fullTypeName);
- var navigationProperties = new List<NavigationPropertyInfo>();
- var keyProperties = new List<string>(this.GetKeyProperties(fullTypeName));
- foreach (PropertyInfo pi in type.GetProperties())
- {
- if (!keyProperties.Contains(pi.Name))
- {
- if (this.IsTypeAnEntityType(pi.PropertyType))
- {
- navigationProperties.Add(new NavigationPropertyInfo(pi, null));
- }
-
- if (pi.PropertyType.IsGenericType && ((pi.PropertyType.GetGenericTypeDefinition() == typeof(List<>)) || (pi.PropertyType.GetGenericTypeDefinition() == typeof(Collection<>))))
- {
- Type elementType = pi.PropertyType.GetGenericArguments()[0];
- if (this.IsTypeAnEntityType(elementType))
- {
- navigationProperties.Add(new NavigationPropertyInfo(pi, elementType));
- }
- }
- }
- }
-
- return navigationProperties.ToArray();
- }
-
- public string[] GetPropertiesToReset(string fullTypeName)
- {
- Type type = this.FindClrTypeByFullName(fullTypeName);
- var keyProperties = new List<string>(this.GetKeyProperties(fullTypeName));
- var navigationProperties = new List<string>(this.GetNavigationProperties(fullTypeName).Select(ni =>ni.PropertyInfo.Name));
- return type.GetProperties().Where(
- pi => !keyProperties.Contains(pi.Name) && !navigationProperties.Contains(pi.Name)
- ).Select(pi => pi.Name).ToArray();
- }
-
- public string[] GetResourceSetNames()
- {
- return this.reflectionDataContext.GetType().GetProperties().Where(
- pi => pi.PropertyType.IsGenericType && (pi.PropertyType.GetGenericTypeDefinition() == typeof(IQueryable<>))
- ).Select(pi => pi.Name).ToArray();
- }
-
- public Type GetResourceTypeOfSet(string resourceSetName)
- {
- PropertyInfo resourceSetPropertyInfo = this.reflectionDataContext.GetType().GetProperties().Where(pi => pi.Name == resourceSetName).FirstOrDefault();
- ExceptionUtilities.CheckObjectNotNull(resourceSetPropertyInfo, "Error finding type of set '{0}'", new object[] { resourceSetName });
- return resourceSetPropertyInfo.PropertyType.GetGenericArguments()[0];
- }
-
- public bool IsTypeAnEntityType(Type t)
- {
- foreach (string setName in this.GetResourceSetNames())
- {
- if (this.GetResourceTypeOfSet(setName).IsAssignableFrom(t))
- {
- return true;
- }
- }
-
- return false;
- }
- }
-
- internal static class ExceptionUtilities
- {
- // Methods
- public static void Assert(bool condition, string errorMessage, params object[] messageArguments)
- {
- if (!condition)
- {
- throw new InvalidOperationException("Assertion failed: " + string.Format(CultureInfo.InvariantCulture, errorMessage, messageArguments));
- }
- }
-
- public static void CheckArgumentNotNull(object argument, string argumentName)
- {
- if (argument == null)
- {
- throw new ArgumentNullException(argumentName);
- }
- }
-
- public static void CheckCollectionNotEmpty<TElement>(IEnumerable<TElement> argument, string argumentName)
- {
- CheckArgumentNotNull(argument, argumentName);
- if (!argument.Any<TElement>())
- {
- throw new ArgumentException(string.Format(CultureInfo.InvariantCulture, "Collection argument '{0}' must have at least one element.", new object[] { argumentName }));
- }
- }
-
- public static void CheckObjectNotNull(object value, string exceptionMessageFormatText, params object[] messageArguments)
- {
- Assert(exceptionMessageFormatText != null, "message cannnot be null", new object[0]);
- Assert(messageArguments != null, "messageArguments cannnot be null", new object[0]);
- if (value == null)
- {
- throw new InvalidOperationException(string.Format(CultureInfo.InvariantCulture, exceptionMessageFormatText, messageArguments));
- }
- }
-
- public static void ThrowDataServiceExceptionIfFalse(bool condition, int statusCode, string errorMessage, params object[] messageArguments)
- {
- if (!condition)
- {
- throw new DataServiceException(statusCode, string.Format(CultureInfo.InvariantCulture, errorMessage, messageArguments));
- }
- }
- }
-
- public class UpdatableToken
- {
- // Methods
- public UpdatableToken(object resource)
- {
- ExceptionUtilities.CheckArgumentNotNull(resource, "resource");
- this.Resource = resource;
- this.PendingPropertyUpdates = new Dictionary<string, object>();
- }
-
- public static UpdatableToken AssertIsToken(object resource, string name)
- {
- ExceptionUtilities.CheckArgumentNotNull(resource, "resource");
- UpdatableToken token = resource as UpdatableToken;
- ExceptionUtilities.CheckObjectNotNull(token, "{0} was not a token. Type was: '{1}'", new object[] { name, resource.GetType() });
- return token;
- }
-
- public static object AssertIsTokenAndResolve(object resource, string name)
- {
- return AssertIsToken(resource, name).Resource;
- }
-
- public static object ResolveIfToken(object resource)
- {
- UpdatableToken token = resource as UpdatableToken;
- if (token != null)
- {
- resource = token.Resource;
- }
- return resource;
- }
-
- // Properties
- public IDictionary<string, object> PendingPropertyUpdates { get; set; }
-
- public object Resource { get; set; }
- }
-
- internal class NavigationPropertyInfo
- {
- // Methods
- internal NavigationPropertyInfo(PropertyInfo pi, Type collectionElementType)
- {
- this.PropertyInfo = pi;
- this.CollectionElementType = collectionElementType;
- }
-
- // Properties
- public Type CollectionElementType { get; set; }
-
- public PropertyInfo PropertyInfo { get; set; }
- }
-
- #endregion Inner types.
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/atomreader.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/atomreader.cs b/JSLib/tests/code/atomreader.cs
deleted file mode 100644
index 1b4e762..0000000
--- a/JSLib/tests/code/atomreader.cs
+++ /dev/null
@@ -1,796 +0,0 @@
-/// <summary>
-/// Class used to parse the Content section of the feed to return the properties data and metadata
-/// </summary>
-
-namespace DataJS.Tests
-{
- using System;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.ServiceModel.Syndication;
- using Microsoft.Spatial;
- using System.Xml;
- using System.Xml.Linq;
-
- public static class AtomReader
- {
- const string atomXmlNs = "http://www.w3.org/2005/Atom";
- const string gmlXmlNs = "http://www.opengis.net/gml";
- const string odataRelatedPrefix = "http://schemas.microsoft.com/ado/2007/08/dataservices/related";
- const string odataRelatedLinksPrefix = "http://schemas.microsoft.com/ado/2007/08/dataservices/relatedlinks";
- const string odataXmlNs = "http://schemas.microsoft.com/ado/2007/08/dataservices";
- const string odataMetaXmlNs = "http://schemas.microsoft.com/ado/2007/08/dataservices/metadata";
- const string odataEditMediaPrefix = "http://schemas.microsoft.com/ado/2007/08/dataservices/edit-media";
- const string odataMediaResourcePrefix = "http://schemas.microsoft.com/ado/2007/08/dataservices/mediaresource";
-
- const string hrefAttribute = "href";
- const string titleElement = "title";
- const string workspaceElement = "workspace";
- const string workspacesProperty = "workspaces";
- const string collectionElement = "collection";
- const string collectionsProperty = "collections";
- const string extensionsProperty = "extensions";
- static string baseUri = string.Empty;
-
- /// <summary>
- /// Creates a service document object
- /// </summary>
- /// <param name="container">The XML container</param>
- /// <param name="uri">Uri to append to the href value</param>
- /// <returns>The service document JsonObject</returns>
- public static JsonObject ReadServiceDocument(TextReader payload, string baseUri)
- {
- JsonObject jsonObject = new JsonObject();
- XElement container = XElement.Load(payload);
-
- if (container != null && container.HasElements)
- {
- jsonObject["workspaces"] =
- container
- .Elements()
- .Where(element => element.Name.LocalName.Equals(workspaceElement))
- .Select(element => ReadWorkspaceObject(element, baseUri))
- .ToArray();
-
- jsonObject["extensions"] =
- container
- .Elements()
- .Where(element => !element.Name.LocalName.Equals(workspaceElement))
- .Select(element => ReadExtensionElement(element))
- .ToArray();
- }
-
- return jsonObject;
- }
-
- public static JsonObject ReadEntry(TextReader payload)
- {
- SyndicationItem item = SyndicationItem.Load(XmlReader.Create(payload));
- return ReadEntry(item);
- }
-
- public static JsonObject ReadFeed(TextReader payload)
- {
- SyndicationFeed feed = SyndicationFeed.Load(XmlReader.Create(payload));
- JsonObject feedData = new JsonObject();
- JsonObject feedMetadata = new JsonObject();
-
- feedData["results"] = feed.Items.Select(item => ReadEntry(item)).ToArray();
- feedData["__metadata"] = feedMetadata;
-
- feedMetadata["feed_extensions"] = feed.AttributeExtensions.Select(pair => ReadExtension(pair)).ToArray();
-
- if (feed.Id != null)
- {
- feedMetadata["uri"] = feed.Id;
- feedMetadata["uri_extensions"] = new JsonObject[] { };
- }
-
- if (feed.Title != null)
- {
- feedMetadata["title"] = feed.Title.Text;
- feedMetadata["title_extensions"] = GetTitleExtensions(feed.Title);
- }
-
- SyndicationLink feedSelfLink = GetLink("self", feed.Links);
- if (feedSelfLink != null)
- {
- feedMetadata["self"] = feedSelfLink.GetAbsoluteUri().AbsoluteUri;
- feedMetadata["self_extensions"] = GetLinkExtensions(feedSelfLink);
- }
-
- long? count = GetInlineCount(feed);
- if (count.HasValue)
- {
- feedData["__count"] = count.Value;
- }
-
- SyndicationLink feedNextLink = GetLink("next", feed.Links);
- if (feedNextLink != null)
- {
- feedData["__next"] = feedNextLink.GetAbsoluteUri().AbsoluteUri;
- feedMetadata["next_extensions"] = GetLinkExtensions(feedNextLink);
- }
-
- return feedData;
- }
-
- private static JsonObject ReadEntry(SyndicationItem item)
- {
- SyndicationLink entryEditLink = GetLink("edit", item.Links);
- SyndicationCategory entryCategory = item.Categories.FirstOrDefault();
-
- XElement propertiesElement = GetPropertiesElement(item);
- JsonObject entryData = ReadObject(propertiesElement);
- entryData = JsonObject.Merge(entryData, ReadNavigationProperties(item));
- entryData = JsonObject.Merge(entryData, ReadNamedStreams(item));
-
- JsonObject propertiesMetadata = ReadPropertiesMetadata(propertiesElement);
- propertiesMetadata = JsonObject.Merge(propertiesMetadata, ReadNavigationPropertiesMetadata(item));
- propertiesMetadata = JsonObject.Merge(propertiesMetadata, ReadNamedStreamMetadata(item));
-
- JsonObject entryMetadata = new JsonObject();
- entryData["__metadata"] = entryMetadata;
- entryMetadata["properties"] = propertiesMetadata;
-
- if (item.Id != null)
- {
- entryMetadata["uri"] = item.Id;
- entryMetadata["uri_extensions"] = new JsonObject[] { };
- }
-
- if (entryCategory != null)
- {
- entryMetadata["type"] = entryCategory.Name;
- entryMetadata["type_extensions"] = new JsonObject[] { };
- }
-
- if (entryEditLink != null)
- {
- entryMetadata["edit"] = entryEditLink.GetAbsoluteUri().AbsoluteUri;
- entryMetadata["edit_link_extensions"] = GetLinkExtensions(entryEditLink);
- }
-
- return entryData;
- }
-
- private static JsonObject ReadExtension(KeyValuePair<XmlQualifiedName, string> pair)
- {
- return ReaderUtils.CreateExtension(pair.Key.Name, pair.Key.Namespace, pair.Value);
- }
-
- private static string GetCollectionType(string type)
- {
- if (type != null && type.StartsWith("Collection("))
- {
- int start = 11;
- int end = type.IndexOf(")") - 11;
- return type.Substring(start, end);
- }
- return null;
- }
-
- /// <summary>
- /// Find the m:properties element within a feed entry
- /// </summary>
- /// <param name="item">The feed entry</param>
- /// <returns>The m:properties element</returns>
- private static XElement GetPropertiesElement(SyndicationItem item)
- {
- // Check if the m:properties element is within the content element
- XmlSyndicationContent xmlContent = item.Content as XmlSyndicationContent;
- if (xmlContent != null)
- {
- XElement contentElement = XElement.Load(xmlContent.GetReaderAtContent());
- return contentElement.Elements().FirstOrDefault(e => e.Name == XName.Get("properties", odataMetaXmlNs));
- }
- // If we're here, then we are dealing with a feed that has an MLE
- // i.e. the m:properties element is a peer of the content element, and shows up
- // in the elementExtensions instead
- SyndicationElementExtension propertiesElementExtension = item.ElementExtensions.FirstOrDefault(e => e.OuterName.Equals("properties"));
- if (propertiesElementExtension != null)
- {
- XNode propertiesElement = XNode.ReadFrom(propertiesElementExtension.GetReader());
- return (XElement)propertiesElement;
- }
-
- throw new NotSupportedException("Unsupported feed entry format");
- }
-
- /// <summary>
- /// Gets the inline count within a feed
- /// </summary>
- /// <param name="feed">The feed</param>
- /// <returns>The inline count, or null if none exists</returns>
- private static long? GetInlineCount(SyndicationFeed feed)
- {
- SyndicationElementExtension countElementExtension = feed.ElementExtensions.SingleOrDefault(extension =>
- extension.OuterName.Equals("count", StringComparison.OrdinalIgnoreCase) &&
- extension.OuterNamespace.Equals(odataMetaXmlNs));
-
- if (countElementExtension != null)
- {
- XElement countElement = (XElement)XNode.ReadFrom(countElementExtension.GetReader());
- return XmlConvert.ToInt64(countElement.Value);
- }
- else
- {
- return null;
- }
- }
-
- /// <summary>
- /// Gets the link with the specified relationship type
- /// </summary>
- /// <param name="rel">Relationship type</param>
- /// <param name="links">The set of links to search from</param>
- /// <returns>The link with the specified relationship type, or null if none exists</returns>
- private static SyndicationLink GetLink(string rel, IEnumerable<SyndicationLink> links)
- {
- return links.SingleOrDefault(link => link.RelationshipType.Equals(rel, StringComparison.InvariantCultureIgnoreCase));
- }
-
- private static IEnumerable<SyndicationLink> GetLinks(string rel, IEnumerable<SyndicationLink> links)
- {
- return links.Where(link => link.RelationshipType.StartsWith(rel, StringComparison.Ordinal));
- }
-
- //TODO refactor the extraction of extensions into extension elements and extension attribute methods.
- private static JsonObject[] GetLinkExtensions(SyndicationLink link)
- {
- List<JsonObject> extensions = new List<JsonObject>();
- //TODO: fix the inclusion of title as extension. Title attribute is not required in the link element and its
- //inclusion as an extension should be tested for the precesence of the attribute in the xml element. Unfortunately,
- //SyndicationLink doesn't allow for accessing the underlying XML document.. perhaps using an AtomFormatter10??
- extensions.Add(ReaderUtils.CreateExtension("title", null, link.Title));
- extensions.AddRange(link.AttributeExtensions.Select(pair => ReadExtension(pair)));
-
- return extensions.ToArray();
- }
-
- private static JsonObject[] GetTitleExtensions(TextSyndicationContent title)
- {
- List<JsonObject> extensions = new List<JsonObject>();
- extensions.Add(ReaderUtils.CreateExtension("type", null, title.Type));
- extensions.AddRange(title.AttributeExtensions.Select(pair => ReadExtension(pair)));
-
- return extensions.ToArray();
- }
-
- /// <summary>
- /// Gets the "type" value from a property element
- /// </summary>
- /// <param name="propertyElement">The property element</param>
- /// <returns>The "type" value, or default (Edm.String) if none specified</returns>
- private static string GetTypeAttribute(XElement propertyElement)
- {
- XAttribute typeAttribute = propertyElement.Attribute(XName.Get("type", odataMetaXmlNs));
- if (typeAttribute == null)
- {
- if (propertyElement.HasElements)
- {
- return null;
- }
- return "Edm.String";
- }
- return typeAttribute.Value;
- }
-
- private static bool HasTypeAttribute(XElement propertyElement)
- {
- return propertyElement.Attribute(XName.Get("type", odataMetaXmlNs)) != null;
- }
-
- private static bool IsCollectionProperty(XElement propertyElement)
- {
- string type = GetTypeAttribute(propertyElement);
- if (type != null && type.StartsWith("Collection("))
- {
- return true;
-
- }
- return propertyElement.Elements().Count(pe => pe.Name == XName.Get("element", odataXmlNs)) > 1;
- }
-
- private static JsonObject ReadWorkspaceObject(XElement container, string baseUri)
- {
- JsonObject jsonObject = new JsonObject();
-
- jsonObject["collections"] =
- container
- .Elements()
- .Where(element => element.Name.LocalName.Equals("collection"))
- .Select(element => ReadWorkspaceCollections(element, baseUri))
- .ToArray();
-
- jsonObject["extensions"] =
- container
- .Elements()
- .Where(element =>
- !(element.Name.LocalName.Equals("collection") ||
- element.Name.LocalName.Equals("title")))
- .Select(element => ReadExtensionElement(element))
- .ToArray();
-
- jsonObject["title"] =
- container
- .Elements()
- .Where(element => element.Name.LocalName.Equals("title"))
- .First()
- .Value;
-
- return jsonObject;
- }
-
- private static JsonObject ReadWorkspaceCollections(XElement container, string baseUri)
- {
- JsonObject jsonObject = new JsonObject();
- string title = string.Empty;
-
- jsonObject["extensions"] =
- container
- .Elements()
- .Where(element =>
- !(element.Name.LocalName.Equals(collectionElement) ||
- element.Name.LocalName.Equals(titleElement)))
- .Select(element => ReadExtensionElement(element))
- .ToArray();
-
- jsonObject["title"] =
- container
- .Elements()
- .Where(element => element.Name.LocalName.Equals("title"))
- .First()
- .Value;
-
- IEnumerable<XAttribute> hrefAttributes =
- container
- .Attributes()
- .Where(element => element.Name.LocalName.Equals("href"));
-
- jsonObject["href"] = baseUri + hrefAttributes.First().Value;
-
- return jsonObject;
- }
-
- private static JsonObject ReadExtensionElement(XElement element)
- {
- JsonObject jsonObject = ReaderUtils.CreateExtension(element.Name.LocalName, element.BaseUri, null);
- jsonObject.Remove("value");
- jsonObject["attributes"] = ReadExtensionAttributes(element);
- jsonObject["children"] = element.Elements().Select(child => ReadExtensionElement(element)).ToArray();
-
- return jsonObject;
- }
-
- private static JsonObject ReadExtensionAttribute(XAttribute attribute)
- {
- return ReaderUtils.CreateExtension(attribute.Name.LocalName, attribute.BaseUri, attribute.Value);
- }
-
- private static JsonObject[] ReadExtensionAttributes(XElement container)
- {
- List<JsonObject> attributes = new List<JsonObject>();
- foreach (XAttribute attribute in container.Attributes())
- {
- attributes.Add(ReadExtensionAttribute(attribute));
- }
- return attributes.ToArray();
- }
-
- private static JsonObject ReadNamedStreamMetadata(SyndicationItem item)
- {
- JsonObject propertiesMetadata = new JsonObject();
- JsonObject streamMetadata;
- string propertyName;
-
- foreach (SyndicationLink link in GetLinks(odataEditMediaPrefix, item.Links))
- {
- streamMetadata = new JsonObject();
- streamMetadata["edit_media_extensions"] = GetLinkExtensions(link);
- streamMetadata["media_src_extensions"] = new JsonObject[0];
-
- propertyName = link.RelationshipType.Substring(odataEditMediaPrefix.Length + 1);
- propertiesMetadata[propertyName] = streamMetadata;
- }
-
- foreach (SyndicationLink link in GetLinks(odataMediaResourcePrefix, item.Links))
- {
- streamMetadata = new JsonObject();
- streamMetadata["media_src_extensions"] = GetLinkExtensions(link);
-
- propertyName = link.RelationshipType.Substring(odataMediaResourcePrefix.Length + 1);
- if (propertiesMetadata.ContainsKey(propertyName))
- {
- streamMetadata = JsonObject.Merge((JsonObject)propertiesMetadata[propertyName], streamMetadata);
- }
- propertiesMetadata[propertyName] = streamMetadata;
- }
- return propertiesMetadata;
- }
-
- private static JsonObject ReadNamedStreams(SyndicationItem item)
- {
- // Not very elegant, but quick and easy, do it in two passes.
- JsonObject streams = new JsonObject();
- JsonObject streamValue;
- JsonObject mediaResource;
- string propertyName;
-
- foreach (SyndicationLink link in GetLinks(odataEditMediaPrefix, item.Links))
- {
- propertyName = link.RelationshipType.Substring(odataEditMediaPrefix.Length + 1);
- streamValue = new JsonObject();
- mediaResource = new JsonObject();
-
- streams[propertyName] = streamValue;
-
- streamValue["__mediaresource"] = mediaResource;
-
- mediaResource["edit_media"] = link.GetAbsoluteUri().AbsoluteUri;
- mediaResource["content_type"] = link.MediaType;
- mediaResource["media_src"] = link.GetAbsoluteUri().AbsoluteUri;
-
- var etagAttributeName = new XmlQualifiedName("etag", odataMetaXmlNs);
- if (link.AttributeExtensions.ContainsKey(etagAttributeName))
- {
- mediaResource["media_etag"] = link.AttributeExtensions[etagAttributeName];
- link.AttributeExtensions.Remove(etagAttributeName);
- }
- }
-
- foreach (SyndicationLink link in GetLinks(odataMediaResourcePrefix, item.Links))
- {
- propertyName = link.RelationshipType.Substring(odataMediaResourcePrefix.Length + 1);
- mediaResource = new JsonObject();
- mediaResource["content_type"] = link.MediaType;
- mediaResource["media_src"] = link.GetAbsoluteUri().AbsoluteUri;
-
- if (streams.ContainsKey(propertyName))
- {
- streamValue = streams[propertyName] as JsonObject;
- mediaResource = JsonObject.Merge(streamValue["__mediaresource"] as JsonObject, mediaResource);
- }
- else
- {
- streamValue = new JsonObject();
- }
- streamValue["__mediaresource"] = mediaResource;
- streams[propertyName] = streamValue;
- }
- return streams;
- }
-
- private static JsonObject ReadNavigationProperties(SyndicationItem item)
- {
- JsonObject navProperties = new JsonObject();
- SyndicationElementExtension inline;
-
- string propertyName;
- JsonObject propertyValue = null;
-
- foreach (SyndicationLink link in GetLinks(odataRelatedPrefix, item.Links))
- {
- propertyName = link.RelationshipType.Substring(odataRelatedPrefix.Length + 1);
- inline = link.ElementExtensions.SingleOrDefault(e =>
- odataMetaXmlNs.Equals(e.OuterNamespace, StringComparison.Ordinal) &&
- e.OuterName.Equals("inline", StringComparison.Ordinal));
-
- if (inline != null)
- {
- XElement inlineElement = (XElement)XNode.ReadFrom(inline.GetReader());
- XElement innerElement = inlineElement.Elements().FirstOrDefault();
-
- if (innerElement != null)
- {
- // By default the inner feed/entry does not have the xml:base attribute, so we need to
- // add it so that the parsed SyndicationFeed or SyndicationItem retains the baseUri
- if (link.BaseUri != null)
- {
- innerElement.SetAttributeValue(XNamespace.Xml + "base", link.BaseUri.OriginalString);
- }
-
- // We are converting to a string before creating the reader to strip out extra indenting,
- // otherwise the reader creates extra XmlText nodes that SyndicationFeed/SyndicationItem cannot handle
- try
- {
- propertyValue = ReadFeed(new StringReader(innerElement.ToString()));
- }
- catch (XmlException)
- {
- // Try with entry instead ..
-
- propertyValue = ReadEntry(new StringReader(innerElement.ToString()));
- }
- }
- }
- else
- {
- JsonObject deferred = new JsonObject();
- deferred["uri"] = link.GetAbsoluteUri().AbsoluteUri;
-
- propertyValue = new JsonObject();
- propertyValue["__deferred"] = deferred;
- }
- navProperties[propertyName] = propertyValue;
- }
- return navProperties;
- }
-
- private static JsonObject ReadNavigationPropertiesMetadata(SyndicationItem item)
- {
- JsonObject propertiesMetadata = new JsonObject();
- JsonObject navMetadata;
- string propertyName;
-
- foreach (SyndicationLink link in GetLinks(odataRelatedPrefix, item.Links))
- {
- navMetadata = new JsonObject();
- navMetadata["extensions"] = GetLinkExtensions(link).Where(e =>
- !(string.Equals(e["name"] as string, "inline", StringComparison.Ordinal) &&
- string.Equals(e["namespaceURI"] as string, odataMetaXmlNs, StringComparison.Ordinal))
- ).ToArray();
-
- propertyName = link.RelationshipType.Substring(odataRelatedPrefix.Length + 1);
- propertiesMetadata[propertyName] = navMetadata;
- }
-
- foreach (SyndicationLink link in GetLinks(odataRelatedLinksPrefix, item.Links))
- {
- navMetadata = new JsonObject();
- navMetadata["associationuri"] = link.GetAbsoluteUri().AbsoluteUri;
- navMetadata["associationuri_extensions"] = link.GetAbsoluteUri().AbsoluteUri;
-
- propertyName = link.RelationshipType.Substring(odataRelatedLinksPrefix.Length + 1);
- if (propertiesMetadata.ContainsKey(propertyName))
- {
- navMetadata = JsonObject.Merge(propertiesMetadata[propertyName] as JsonObject, navMetadata);
- }
- propertiesMetadata[propertyName] = navMetadata;
- }
-
- return propertiesMetadata;
- }
-
- private static JsonObject ReadPropertiesMetadata(XElement container)
- {
- JsonObject json = null;
- if (container != null && container.Elements().Any(e => e.Name.NamespaceName == odataXmlNs))
- {
- json = new JsonObject();
- foreach (XElement propertyElement in container.Elements())
- {
- json[propertyElement.Name.LocalName] = ReadPropertyMetadata(propertyElement);
- }
- }
- return json;
- }
-
- private static JsonObject ReadPropertyMetadata(XElement property)
- {
- var metadata = ReaderUtils.CreateEntryPropertyMetadata(GetTypeAttribute(property));
-
- if (IsCollectionProperty(property))
- {
- string collectionType = GetCollectionType(GetTypeAttribute(property));
- if (collectionType == null)
- {
- metadata["type"] = "Collection()";
- }
-
- List<JsonObject> elements = new List<JsonObject>();
- foreach (XElement item in property.Elements(XName.Get("element", odataXmlNs)))
- {
- string itemType =
- HasTypeAttribute(item) ? GetTypeAttribute(item) :
- IsCollectionProperty(item) ? "Collection()" : collectionType;
-
- var itemMetadata = ReaderUtils.CreateEntryPropertyMetadata(itemType);
- if (item.Elements().Any(e => e.Name.NamespaceName == odataXmlNs))
- {
- itemMetadata["properties"] = ReadPropertiesMetadata(item);
- }
- elements.Add(itemMetadata);
- }
- metadata["elements"] = elements.ToArray();
- }
- else if (property != null && property.Elements().Any(e => e.Name.NamespaceName == odataXmlNs))
- {
- metadata["properties"] = ReadPropertiesMetadata(property);
- }
-
- return metadata;
- }
-
- /// <summary>
- /// Creates a JsonObject from an XML container element (e.g. the m:properties element) of an OData ATOM feed entry.
- /// </summary>
- /// <param name="container">The XML container</param>
- /// <param name="buildValue">Function that builds a value from a property element</param>
- /// <returns>The JsonObject containing the name-value pairs</returns>
- private static JsonObject ReadObject(XElement container)
- {
- if (container == null)
- {
- return null;
- }
-
- var json = new JsonObject();
- foreach (XElement propertyElement in container.Elements())
- {
- json[propertyElement.Name.LocalName] = ReadDataItem(propertyElement);
- }
- return json;
- }
-
- private static JsonObject ReadCollectionProperty(XElement property, string typeName)
- {
- var collectionType = GetCollectionType(typeName);
-
- var json = new JsonObject();
- var results = new List<object>();
-
- foreach (XElement item in property.Elements())
- {
- object resultItem = ReadDataItem(item);
- results.Add(resultItem);
-
- JsonObject complexValue = resultItem as JsonObject;
- if (complexValue != null)
- {
- var metadata = complexValue["__metadata"] as JsonObject;
- if (!string.IsNullOrEmpty(collectionType) && metadata["type"] == null)
- {
- metadata["type"] = collectionType;
- }
- }
- }
-
- json["results"] = results;
- json["__metadata"] = ReaderUtils.CreateEntryPropertyMetadata(typeName, false);
-
- return json;
- }
-
- private static JsonObject ReadComplexProperty(XElement container, string typeName)
- {
- JsonObject json = ReadObject(container);
- json["__metadata"] = ReaderUtils.CreateEntryPropertyMetadata(GetTypeAttribute(container), false);
- return json;
- }
-
- private static JsonObject ReadJsonSpatialProperty(XElement container, XElement gmlValue, bool isGeography)
- {
- GmlFormatter gmlFormatter = GmlFormatter.Create();
- GeoJsonObjectFormatter jsonformatter = GeoJsonObjectFormatter.Create();
-
- bool ignoreCrc = !gmlValue.Attributes().Any(a => a.Name.LocalName == "srsName");
-
- ISpatial spatialValue;
- if (isGeography)
- {
- spatialValue = gmlFormatter.Read<Geography>(gmlValue.CreateReader());
- }
- else
- {
- spatialValue = gmlFormatter.Read<Geometry>(gmlValue.CreateReader());
- }
-
- IDictionary<string, object> geoJsonData = jsonformatter.Write(spatialValue);
- JsonObject json = new JsonObject();
-
- Queue<object> geoJsonScopes = new Queue<object>();
- Queue<object> jsonScopes = new Queue<object>();
-
- geoJsonScopes.Enqueue(geoJsonData);
- jsonScopes.Enqueue(json);
-
- Func<object, object> convertScope = (scope) =>
- {
- object newScope =
- scope is List<object> || scope is object[] ? (object)new List<Object>() :
- scope is IDictionary<string, object> ? (object)new JsonObject() :
- null;
-
- if (newScope != null)
- {
- geoJsonScopes.Enqueue(scope);
- jsonScopes.Enqueue(newScope);
- }
-
- return newScope ?? scope;
- };
-
- while (jsonScopes.Count > 0)
- {
- if (jsonScopes.Peek() is JsonObject)
- {
- var currentGeoJson = (IDictionary<string, object>)geoJsonScopes.Dequeue();
- var currentJson = (JsonObject)jsonScopes.Dequeue();
-
- foreach (var item in currentGeoJson)
- {
- if (!ignoreCrc || item.Key != "crs")
- {
- currentJson[item.Key] = convertScope(item.Value);
- }
- }
- }
- else
- {
- var currentGeoJson = (IEnumerable<object>)geoJsonScopes.Dequeue();
- var currentJson = (List<object>)jsonScopes.Dequeue();
-
- foreach (var item in currentGeoJson)
- {
- currentJson.Add(convertScope(item));
- }
- }
- }
- json["__metadata"] = ReaderUtils.CreateEntryPropertyMetadata(GetTypeAttribute(container), false);
- return json;
- }
-
- public static object ReadDataItem(XElement item)
- {
- string typeName = GetTypeAttribute(item);
- XElement gmlRoot = item.Elements().SingleOrDefault(e => e.Name.NamespaceName == gmlXmlNs);
-
- if (gmlRoot != null)
- {
- bool isGeography = typeName.StartsWith("Edm.Geography");
- return ReadJsonSpatialProperty(item, gmlRoot, isGeography);
- }
-
- bool isCollection = IsCollectionProperty(item);
- if (item.HasElements || isCollection)
- {
- // Complex type, Collection Type: parse recursively
- return isCollection ? ReadCollectionProperty(item, typeName) : ReadComplexProperty(item, typeName);
- }
-
- // Primitive type: null value
- XNamespace mNamespace = item.GetNamespaceOfPrefix("m");
- XAttribute nullAttribute = mNamespace == null ? null : item.Attribute(mNamespace.GetName("null"));
- if (nullAttribute != null && nullAttribute.Value.Equals("true", StringComparison.InvariantCultureIgnoreCase))
- {
- return null;
- }
-
- // Primitive type: check type and parse value accordingly
- string value = item.Value;
- switch (typeName)
- {
- case "Edm.Byte":
- return XmlConvert.ToByte(value);
- case "Edm.Int16":
- return XmlConvert.ToInt16(value);
- case "Edm.Int32":
- return XmlConvert.ToInt32(value);
- case "Edm.SByte":
- return XmlConvert.ToSByte(value);
- case "Edm.Boolean":
- return XmlConvert.ToBoolean(value);
- case "Edm.Double":
- return XmlConvert.ToDouble(value);
- case "Edm.Single":
- return XmlConvert.ToSingle(value);
- case "Edm.Guid":
- return XmlConvert.ToGuid(value);
- case "Edm.DateTime":
- return new JsDate(XmlConvert.ToDateTime(value, XmlDateTimeSerializationMode.Utc));
- case "Edm.DateTimeOffset":
- return new JsDate(XmlConvert.ToDateTimeOffset(value));
- case "Edm.Time":
- throw new NotSupportedException(typeName + " is not supported");
- // Decimal and Int64 values are sent as strings over the wire. This is the same behavior as WCF Data Services JSON serializer.
- case "Edm.Decimal":
- case "Edm.Int64":
- case "":
- default:
- return value;
- }
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/csdlreader.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/csdlreader.cs b/JSLib/tests/code/csdlreader.cs
deleted file mode 100644
index 253cf10..0000000
--- a/JSLib/tests/code/csdlreader.cs
+++ /dev/null
@@ -1,186 +0,0 @@
-/// <summary>
-/// Class used to parse csdl to create the metatdata object
-/// </summary>
-///
-
-namespace DataJS.Tests
-{
- using System;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.Xml.Linq;
-
-
- public static class CsdlReader
- {
- static readonly string knownNamespace = "http://docs.oasis-open.org";
- static readonly string[] repeatingElements =
- {
- "Action",
- "ActionImport",
- "Annotation",
- "Annotations",
- "Apply",
- "Binary",
- "Bool",
- "Cast",
- "Collection",
- "ComplexType",
- "Date",
- "DateTimeOffset",
- "Decimal",
- "Duration",
- "EntitySet",
- "EntityType",
- "EnumMember",
- "EnumType",
- "Float",
- "Function",
- "FunctionImport",
- "Guid",
- "If",
- "Int",
- "IsOf",
- "Key",
- "LabeledElement",
- "LabeledElementReference",
- "Member",
- "NavigationProperty",
- "NavigationPropertyBinding",
- "NavigationPropertyPath",
- "Null",
- "OnDelete",
- "Path",
- "Parameter",
- "Property",
- "PropertyPath",
- "PropertyRef",
- "PropertyValue",
- "Record",
- "ReferentialConstraint",
- "String",
- "Schema",
- "Singleton",
- "Term",
- "TimeOfDay",
- "TypeDefinition",
- "UrlRef",
- "Reference",
- "Include",
- "IncludeAnnotations"
- };
-
- public static Dictionary<string, object> ReadCsdl(TextReader payload)
- {
- return BuildElementJsonObject(XElement.Load(payload));
- }
-
- /// <summary>
- /// Build the attribute object
- /// </summary>
- /// <param name="xmlAttributes">IEnumberable of XAttributes to build the attribute object</param>
- /// <returns>The JsonObject containing the name-value pairs for an element's attributes</returns>
- static Dictionary<string, object> BuildAttributeJsonObject(IEnumerable<XAttribute> xmlAttributes)
- {
- Dictionary<string, object> jsonObject = new Dictionary<string, object>();
-
- foreach (XAttribute attribute in xmlAttributes)
- {
- if (!attribute.IsNamespaceDeclaration)
- {
- string attributeNamespace = attribute.Name.Namespace.ToString();
- if (string.IsNullOrEmpty(attributeNamespace) ||
- attributeNamespace.StartsWith(knownNamespace, StringComparison.InvariantCultureIgnoreCase))
- {
- jsonObject[MakeFirstLetterLowercase(attribute.Name.LocalName)] = attribute.Value;
- }
- }
- }
-
- return jsonObject;
- }
-
- /// <summary>
- /// Creates a JsonObject from an XML container element with each attribute or subelement as a property
- /// </summary>
- /// <param name="container">The XML container</param>
- /// <param name="buildValue">Function that builds a value from a property element</param>
- /// <returns>The JsonObject containing the name-value pairs</returns>
- public static Dictionary<string, object> BuildElementJsonObject(XElement container)
- {
- if (container == null)
- {
- return null;
- }
-
- Dictionary<string, object> jsonObject = new Dictionary<string, object>();
- string keyName = MakeFirstLetterLowercase(container.Name.LocalName);
-
- if (container.HasAttributes || container.HasElements)
- {
- Dictionary<string, List<Dictionary<string, object>>> repeatingObjectArrays = new Dictionary<string, List<Dictionary<string, object>>>();
-
- jsonObject = BuildAttributeJsonObject(container.Attributes());
-
- foreach (XElement propertyElement in container.Elements())
- {
- string propertyName = MakeFirstLetterLowercase(propertyElement.Name.LocalName);
- string properyNamespace = propertyElement.Name.Namespace.ToString();
-
- if (string.IsNullOrEmpty(properyNamespace) || properyNamespace.StartsWith(knownNamespace, StringComparison.InvariantCultureIgnoreCase))
- {
- // Check to see if the element is repeating and needs to be an array
- if (repeatingElements.Contains(propertyElement.Name.LocalName))
- {
- // See if property was already created as an array, if not then create it
- if (!repeatingObjectArrays.ContainsKey(propertyName))
- {
- repeatingObjectArrays.Add(propertyName, new List<Dictionary<string, object>>());
- }
-
- repeatingObjectArrays[propertyName].Add(BuildElementJsonObject(propertyElement));
- }
- else
- {
- jsonObject[propertyName] = BuildElementJsonObject(propertyElement);
- }
- }
- }
-
- foreach (string key in repeatingObjectArrays.Keys)
- {
- jsonObject[key] = repeatingObjectArrays[key].ToArray();
- }
- }
- else
- {
- jsonObject[MakeFirstLetterLowercase(container.Name.LocalName)] = container.Value;
- }
-
- return jsonObject;
- }
-
- /// <summary>
- /// Makes the first letter of a string lowercase
- /// </summary>
- /// <param name="name">The string to be modified</param>
- /// <returns>Modified string</returns>
- private static string MakeFirstLetterLowercase(string str)
- {
- if (!string.IsNullOrWhiteSpace(str))
- {
- if (str.Length > 1 && !(str[1].ToString() == str[1].ToString().ToUpper()))
- {
- return str[0].ToString().ToLower() + str.Substring(1);
- }
- else
- {
- return str;
- }
- }
-
- return str;
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/jsdate.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/jsdate.cs b/JSLib/tests/code/jsdate.cs
deleted file mode 100644
index a02c69f..0000000
--- a/JSLib/tests/code/jsdate.cs
+++ /dev/null
@@ -1,40 +0,0 @@
-/// <summary>
-/// The oracle's representation of a Javascript date object as deserialized by the library
-/// </summary>
-
-namespace DataJS.Tests
-{
- using System;
- using System.Collections.Generic;
- using System.IO;
- using System.Linq;
- using System.Net;
- using System.Runtime.Serialization;
- using System.ServiceModel;
- using System.ServiceModel.Activation;
- using System.ServiceModel.Syndication;
- using System.ServiceModel.Web;
- using System.Xml;
- using System.Xml.Linq;
- using Microsoft.Spatial;
- using Microsoft.OData.Core;
-
- [Serializable]
- public class JsDate : JsonObject
- {
- private static readonly DateTime JsEpoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
-
- public JsDate(DateTime dateTime)
- : base()
- {
- this["milliseconds"] = dateTime.Subtract(JsEpoch).TotalMilliseconds;
- }
-
- public JsDate(DateTimeOffset dateTimeOffset)
- : this(dateTimeOffset.UtcDateTime)
- {
- this["__edmType"] = "Edm.DateTimeOffset";
- this["__offset"] = (dateTimeOffset.Offset < TimeSpan.Zero ? "-" : "+") + dateTimeOffset.Offset.ToString("hh':'mm");
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/jsonobject.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/jsonobject.cs b/JSLib/tests/code/jsonobject.cs
deleted file mode 100644
index 79b914e..0000000
--- a/JSLib/tests/code/jsonobject.cs
+++ /dev/null
@@ -1,80 +0,0 @@
-/// <summary>
-/// A weakly typed representation of a JSON object using a dictionary implementation
-/// </summary>
-/// <typeparam name="T">The CLR type of the values of the properties</typeparam>
-
-namespace DataJS.Tests
-{
- using System;
- using System.Collections;
- using System.Collections.Generic;
- using System.Linq;
- using System.Runtime.Serialization;
-
- [Serializable]
- [KnownType(typeof(JsonObject))]
- [KnownType(typeof(JsonObject[]))]
- [KnownType(typeof(JsDate))]
- [KnownType(typeof(List<object>))]
- public class JsonObject : ISerializable, IEnumerable<KeyValuePair<string, object>>
- {
- Dictionary<string, object> dictionary = new Dictionary<string, object>();
-
- public void Remove(string key)
- {
- dictionary.Remove(key);
- }
-
- public object this[string key]
- {
- get
- {
- return this.dictionary[key];
- }
- set
- {
- this.dictionary[key] = value;
- }
- }
-
- public bool ContainsKey(string key)
- {
- return this.dictionary.ContainsKey(key);
- }
-
- public static JsonObject Merge(JsonObject first, JsonObject second)
- {
- if (first == null)
- {
- return second;
- }
-
- if (second != null)
- {
- JsonObject merged = new JsonObject();
- merged.dictionary = new Dictionary<string, object>(first.dictionary);
- foreach (var pair in second.dictionary)
- {
- merged.dictionary[pair.Key] = pair.Value;
- }
- return merged;
- }
- return first;
- }
-
- public void GetObjectData(SerializationInfo info, StreamingContext context)
- {
- this.dictionary.ToList().ForEach(pair => info.AddValue(pair.Key, pair.Value));
- }
-
- public IEnumerator<KeyValuePair<string, object>> GetEnumerator()
- {
- return this.dictionary.GetEnumerator();
- }
-
- IEnumerator IEnumerable.GetEnumerator()
- {
- return this.dictionary.GetEnumerator();
- }
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/olingo-odata4-js/blob/4621d41c/JSLib/tests/code/readerutils.cs
----------------------------------------------------------------------
diff --git a/JSLib/tests/code/readerutils.cs b/JSLib/tests/code/readerutils.cs
deleted file mode 100644
index 284ce04..0000000
--- a/JSLib/tests/code/readerutils.cs
+++ /dev/null
@@ -1,68 +0,0 @@
-using System.Collections.Generic;
-using System.IO;
-using System.Net;
-using System.Web.Script.Serialization;
-
-namespace DataJS.Tests
-{
- public static class ReaderUtils
- {
- public static JsonObject CreateEntryPropertyMetadata(string type)
- {
- return CreateEntryPropertyMetadata(type, true);
- }
-
- public static JsonObject CreateEntryPropertyMetadata(string type, bool withExtensions)
- {
- JsonObject json = new JsonObject();
- json["type"] = type;
-
-
- // TODO: add proper support for property extensions
- if (withExtensions)
- {
- json["extensions"] = new JsonObject[] { };
- }
-
- return json;
- }
-
- public static JsonObject CreateExtension(string name, string nameSpace, string value)
- {
- JsonObject json = new JsonObject();
- json["name"] = name;
- json["namespaceURI"] = nameSpace;
- json["value"] = value;
- return json;
- }
-
- public static WebRequest CreateRequest(string url, string user = null, string password = null)
- {
- WebRequest request = WebRequest.Create(url);
- if (user != null || password != null)
- {
- request.Credentials = new NetworkCredential(user, password);
- request.PreAuthenticate = true;
- }
-
- return request;
- }
-
- public static Stream ConvertDictionarytoJsonlightStream(Dictionary<string, object> dict)
- {
- MemoryStream stream = new MemoryStream();
- if (dict == null)
- {
- return stream;
- }
-
- string jsonString = new JavaScriptSerializer().Serialize(dict);
- StreamWriter writer = new StreamWriter(stream);
- writer.Write(jsonString);
- writer.Flush();
- stream.Position = 0;
- return stream;
- }
-
- }
-}
\ No newline at end of file