-
Notifications
You must be signed in to change notification settings - Fork 0
/
ODataService.cs
107 lines (90 loc) · 4.56 KB
/
ODataService.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
namespace Microsoft.Data.Services.Toolkit
{
using System;
using System.Data.Services;
using System.Data.Services.Providers;
using System.ServiceModel;
using System.ServiceModel.Web;
using System.Web;
using Providers;
using ServiceModel;
/// <summary>
/// A custom DataService implementation.
/// </summary>
/// <typeparam name="T">The <see cref="Type"/> of the data service context.</typeparam>
[DispatchInspector(typeof(JsonInspector))]
public class ODataService<T> : DataService<T>, IServiceProvider
{
/// <summary>
/// Initializes a new instance of the ODataService class.
/// </summary>
public ODataService()
{
var uri = OperationContext.Current.IncomingMessageProperties.ContainsKey("MicrosoftDataServicesRequestUri")
? OperationContext.Current.IncomingMessageProperties["MicrosoftDataServicesRequestUri"] as Uri : HttpContext.Current.Request.Url;
var rootUrl = OperationContext.Current.IncomingMessageProperties.ContainsKey("MicrosoftDataServicesRootUri")
? OperationContext.Current.IncomingMessageProperties["MicrosoftDataServicesRootUri"] as Uri : null;
var urlSettings = UrlSettingsAttribute.GetServiceUrlSettings(GetType());
var urlSanitizer = new UrlSanitizer(urlSettings);
var sanitizedUrl = urlSanitizer.Sanitize(uri.ToString());
var rootUri = rootUrl == null ? WebOperationContext.Current.IncomingRequest.UriTemplateMatch.BaseUri : new Uri(rootUrl.ToString());
var rootUriBuilder = new UriBuilder(rootUri);
var requestUriBuilder = new UriBuilder(sanitizedUrl.ToString());
//// If we're not debugging, then attempt to refactor
//// the request host and port based on the URL settings.
if (!HttpContext.Current.Request.IsLocal)
{
if (!string.IsNullOrWhiteSpace(urlSettings.Host))
{
rootUriBuilder.Host = urlSettings.Host;
requestUriBuilder.Host = urlSettings.Host;
}
if (urlSettings.ClearPorts)
{
rootUriBuilder.Port = -1;
requestUriBuilder.Port = -1;
}
}
if (!rootUriBuilder.Path.EndsWith("/"))
rootUriBuilder.Path = rootUriBuilder.Path += "/";
if (!requestUriBuilder.Path.EndsWith("/"))
requestUriBuilder.Path = requestUriBuilder.Path += "/";
OperationContext.Current.IncomingMessageProperties["MicrosoftDataServicesRootUri"] = rootUriBuilder.Uri;
OperationContext.Current.IncomingMessageProperties["MicrosoftDataServicesRequestUri"] = requestUriBuilder.Uri;
}
/// <summary>
/// Returns the corresponding implementation based on the service type.
/// </summary>
/// <param name="serviceType">The <see cref="Type"/> of the service.</param>
/// <returns>An instance of the service implementation.</returns>
public virtual object GetService(Type serviceType)
{
if (serviceType == typeof(IDataServicePagingProvider))
return new GenericPagingProvider(this.DataServiceConfiguration().PageSizes(), this.CurrentDataSource);
return serviceType == typeof(IDataServiceStreamProvider) ? new EntityUrlReadOnlyStreamProvider() : null;
}
/// <summary>
/// Configures the current <see cref="HttpContext"/> cache if it is provided.
/// </summary>
/// <param name="args">A <see cref="ProcessRequestArgs"/> containing the arguments to be processed.</param>
protected override void OnStartProcessingRequest(ProcessRequestArgs args)
{
base.OnStartProcessingRequest(args);
var cacheSettings = EnableOutputCacheAttribute.GetServiceOutputCacheSettings(GetType());
if (cacheSettings == null)
return;
var context = HttpContext.Current;
var cache = HttpContext.Current.Response.Cache;
cache.SetCacheability(cacheSettings.HttpCacheability);
cache.SetExpires(context.Timestamp.AddSeconds(cacheSettings.ExpiresInSeconds));
cache.VaryByHeaders["Accept"] = true;
cache.VaryByHeaders["Accept-Charset"] = true;
cache.VaryByHeaders["Accept-Encoding"] = true;
cache.VaryByParams["*"] = true;
}
public T DataSource
{
get { return CurrentDataSource; }
}
}
}