using System.Net.Http;
using System.Threading.Tasks;
using Example.RemoteAgents.GTKLinux.View;
+using log4net;
namespace Example.RemoteAgents.GTKLinux
{
public partial class MainWindow: Gtk.Window
{
ViewImpl view;
+ private static readonly ILog logger = LogManager.GetLogger(
+ System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
public MainWindow () : base (Gtk.WindowType.Toplevel)
{
async private void ButtonGetDateClicked(object sender, EventArgs a)
{
try {
- string currentDate = await view.getCurrentDate();
+ string currentDate = await view.GetCurrentDateAsync();
if (currentDate != null)
{
this.RemoteDate.Buffer.Text = currentDate;
}
catch (Exception e)
{
- Console.WriteLine("ButtonGetDateClicked. Message: {0} Stacktrace: {1}", e.Message, e.StackTrace);
+ logger.Error("ButtonGetDateClicked error: ", e);
}
}
}
using Newtonsoft.Json;
using Newtonsoft.Json.Converters;
using Newtonsoft.Json.Serialization;
+using System.Threading;
+using log4net;
namespace Example.RemoteAgents.GTKLinux.Model
{
public class CallRemoteProcedure
{
+ private static readonly ILog logger = LogManager.GetLogger(
+ System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
- async public Task<TResult> callRemoteService<TResult>(string uri, string method)
+ async public Task<TResult> PostRemoteServiceAsync<TResult>(string uri, string method)
+ {
+ POSTResult<TResult> postResult = await this.PostAsync<TResult>(uri, method, CancellationToken.None);
+
+ return postResult.result;
+ }
+
+ async private Task<POSTResult<TResult>> PostAsync<TResult>(string uri, string method, CancellationToken cancellation)
{
var postData = new POST();
postData.id = "2114567586433855105";
var jsonSettings = new JsonSerializerSettings{
Error = delegate(object sender, ErrorEventArgs args)
{
- Console.WriteLine(args.ErrorContext.Error.Message);
+ logger.Error(args.ErrorContext.Error.Message);
args.ErrorContext.Handled = true;
}
};
string data = JsonConvert.SerializeObject(postData, jsonSettings);
- HttpContent content = new StringContent(data, System.Text.Encoding.UTF8, "application/json-rpc");
- HttpResponseMessage response = await this.issueCall(uri, content);
+ // see: http://stackoverflow.com/questions/1329739/nested-using-statements-in-c-sharp
+ // see: http://stackoverflow.com/questions/5895879/when-do-we-need-to-call-dispose-in-dot-net-c
+ //TODO: Am I really sure I have to call the Dispose method of HttpContent content. In this case shouldn't it be stupid?
+ // for HttpResponseMessage response I am sure I have to do it but I am not for HttpContent content.
+ using (HttpContent content = new StringContent(data, System.Text.Encoding.UTF8, "application/json-rpc"))
+ using (HttpResponseMessage response = await this.PostAsync(uri, content, cancellation))
+ {
+ POSTResult<TResult> postResult = new POSTResult<TResult>();
- TResult result = default(TResult);
+ if (response.StatusCode == HttpStatusCode.OK) {
+ byte[] responseBytes = await response.Content.ReadAsByteArrayAsync();
+ string responseString = System.Text.Encoding.UTF8.GetString(responseBytes);
- if (response.StatusCode == HttpStatusCode.OK) {
- Task<byte[]> responseBytes = response.Content.ReadAsByteArrayAsync();
- string responseString = System.Text.Encoding.UTF8.GetString(responseBytes.Result);
+ postResult = JsonConvert.DeserializeObject<POSTResult<TResult>>(responseString, jsonSettings);
+ }
- POSTResult<TResult> postResult = JsonConvert.DeserializeObject<POSTResult<TResult>>(responseString, jsonSettings);
- result = postResult.result;
+ return postResult;
}
-
- return result;
}
- async private Task<HttpResponseMessage> issueCall(string uri, HttpContent content)
+ /// <summary>
+ /// Send a POST request to the specified Uri as an asynchronous operation.
+ /// </summary>
+ /// <param name="uri">The Uri the request is sent to.</param>
+ /// <param name="content">The HTTP request content sent to the server.</param>
+ /// <param name="System.Threading.CancellationToken">Cancellation token.</param>
+ /// <exception cref="System.InvalidOperationException">When some error.</exception>
+ /// <returns>System.Threading.Tasks.Task<![CDATA[<TResult>]]>.The task object representing the asynchronous operation.</returns>
+ async private Task<HttpResponseMessage> PostAsync(string uri, HttpContent content, CancellationToken cancellation)
{
using (HttpClient client = new HttpClient{ Timeout = TimeSpan.FromSeconds(5)})
{
- return await client.PostAsync(uri, content);
+ return await client.PostAsync(uri, content, cancellation);
}
}
projects / CSharpForFun / .git / commitdiff