This repository was archived by the owner on Jul 13, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathService.cs
More file actions
148 lines (130 loc) · 3.8 KB
/
Service.cs
File metadata and controls
148 lines (130 loc) · 3.8 KB
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using SimpleStack.Cache;
using SimpleStack.Interfaces;
namespace SimpleStack
{
/// <summary>
/// Generic + Useful IService base class
/// </summary>
public class Service : IService, IRequiresRequestContext, IServiceBase, IDisposable
{
public IRequestContext RequestContext { get; set; }
private IResolver resolver;
public virtual IResolver GetResolver()
{
return resolver ?? EndpointHost.AppHost;
}
public virtual IAppHost GetAppHost()
{
return (resolver as IAppHost) ?? EndpointHost.AppHost;
}
public virtual Service SetResolver(IResolver resolver)
{
this.resolver = resolver;
return this;
}
public virtual T TryResolve<T>()
{
return this.GetResolver() == null
? default(T)
: this.GetResolver().TryResolve<T>();
}
public virtual T ResolveService<T>()
{
var service = TryResolve<T>();
var requiresContext = service as IRequiresRequestContext;
if (requiresContext != null)
{
requiresContext.RequestContext = this.RequestContext;
}
return service;
}
private IHttpRequest request;
protected virtual IHttpRequest Request
{
get { return request ?? (request = RequestContext != null ? RequestContext.Get<IHttpRequest>() : TryResolve<IHttpRequest>()); }
}
private IHttpResponse response;
protected virtual IHttpResponse Response
{
get { return response ?? (response = RequestContext != null ? RequestContext.Get<IHttpResponse>() : TryResolve<IHttpResponse>()); }
}
private ICacheClient cache;
public virtual ICacheClient Cache
{
get
{
return cache ??
(cache = TryResolve<ICacheClient>())/* ??
(cache = (TryResolve<IRedisClientsManager>() != null ? TryResolve<IRedisClientsManager>().GetCacheClient() : null))*/;
}
}
//private IDbConnection db;
//public virtual IDbConnection Db
//{
// get { return db ?? (db = TryResolve<IDbConnectionFactory>().Open()); }
//}
//private IRedisClient redis;
//public virtual IRedisClient Redis
//{
// get { return redis ?? (redis = TryResolve<IRedisClientsManager>().GetClient()); }
//}
//private IMessageProducer messageProducer;
//public virtual IMessageProducer MessageProducer
//{
// get { return messageProducer ?? (messageProducer = TryResolve<IMessageFactory>().CreateMessageProducer()); }
//}
//private ISessionFactory sessionFactory;
//public virtual ISessionFactory SessionFactory
//{
// get { return sessionFactory ?? (sessionFactory = TryResolve<ISessionFactory>()) ?? new SessionFactory(Cache); }
//}
///// <summary>
///// Dynamic Session Bag
///// </summary>
//private ISession session;
//public virtual ISession Session
//{
// get
// {
// return session ?? (session = TryResolve<ISession>() //Easier to mock
// ?? SessionFactory.GetOrCreateSession(Request, Response));
// }
//}
/// <summary>
/// Typed UserSession
/// </summary>
//private object userSession;
//protected virtual TUserSession SessionAs<TUserSession>()
//{
// if (userSession == null)
// {
// userSession = TryResolve<TUserSession>(); //Easier to mock
// if (userSession == null)
// userSession = Cache.SessionAs<TUserSession>(Request, Response);
// }
// return (TUserSession)userSession;
//}
//public virtual void PublishMessage<T>(T message)
//{
// //TODO: Register In-Memory IMessageFactory by default
// if (MessageProducer == null)
// throw new NullReferenceException("No IMessageFactory was registered, cannot PublishMessage");
// MessageProducer.Publish(message);
//}
public virtual void Dispose()
{
//if (db != null)
// db.Dispose();
//if (redis != null)
// redis.Dispose();
//if (messageProducer != null)
// messageProducer.Dispose();
}
}
}