// ----------------------------------------------------------------------- // // Copyright 2011-2012 GRNET S.A. All rights reserved. // // Redistribution and use in source and binary forms, with or // without modification, are permitted provided that the following // conditions are met: // // 1. Redistributions of source code must retain the above // copyright notice, this list of conditions and the following // disclaimer. // // 2. Redistributions in binary form must reproduce the above // copyright notice, this list of conditions and the following // disclaimer in the documentation and/or other materials // provided with the distribution. // // THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS // OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED // WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF // USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED // AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT // LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN // ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE // POSSIBILITY OF SUCH DAMAGE. // // The views and conclusions contained in the software and // documentation are those of the authors and should not be // interpreted as representing official policies, either expressed // or implied, of GRNET S.A. // // ----------------------------------------------------------------------- using System; using System.Diagnostics; using System.Linq; using System.ServiceModel.Description; using Caliburn.Micro; using System.ServiceModel; using System.ComponentModel.Composition; using Pithos.Core; using Pithos.Interfaces; namespace Pithos.Client.WPF.Services { /// /// TODO: Update summary. /// [ServiceBehavior(ConcurrencyMode=ConcurrencyMode.Reentrant, UseSynchronizationContext=false, IncludeExceptionDetailInFaults = true)] [Export] public class StatusService : IStatusService,ISettingsService, ICommandsService { [Import] public IPithosSettings Settings { get; set; } [Import] public IStatusChecker Checker { get; set; } [Import] public PithosMonitor Monitor { get; set; } [Import] public IEventAggregator Events { get; set; } public StatusService() { IoC.BuildUp(this); } public FileOverlayStatus GetStatus(string filePath) { return Checker.GetFileOverlayStatus(filePath); } public void DisplayProperties(string filePath) { //Monitor. } public void GotoSite(string filePath) { if (string.IsNullOrWhiteSpace(filePath)) return; var activeAccount = Settings.Accounts.FirstOrDefault(acc => filePath.StartsWith(acc.RootPath, StringComparison.InvariantCultureIgnoreCase)); var address = String.Format("{0}/ui/?token={1}&user={2}", activeAccount.ServerUrl, activeAccount.ApiKey, Uri.EscapeUriString(activeAccount.AccountName)); Process.Start(address); } public PithosSettingsData GetSettings() { var data = new PithosSettingsData(Settings); return data; } public void ShowProperties(string fileName) { Events.Publish(new ShowFilePropertiesEvent(fileName)); } public static ServiceHost Start() { // Create a ServiceHost for the CalculatorService type and provide the base address. var baseAddress = new Uri("net.pipe://localhost/pithos"); var service = new ServiceHost(typeof(StatusService), baseAddress); var binding = new NetNamedPipeBinding(NetNamedPipeSecurityMode.None); service.AddServiceEndpoint(typeof(IStatusService), binding, "net.pipe://localhost/pithos/statuscache"); service.AddServiceEndpoint(typeof(ISettingsService), binding, "net.pipe://localhost/pithos/settings"); service.AddServiceEndpoint(typeof(ICommandsService), binding, "net.pipe://localhost/pithos/commands"); //// Add a mex endpoint /* var smb = new ServiceMetadataBehavior { HttpGetEnabled = true, HttpGetUrl = new Uri("http://localhost:30000/pithos/mex") }; service.Description.Behaviors.Add(smb); */ service.Faulted+=OnError; service.Open(); return service; } private static void OnError(object sender, EventArgs e) { } public static void Stop(ServiceHost statusService) { if (statusService == null) return; if (statusService.State == CommunicationState.Faulted) statusService.Abort(); else if (statusService.State != CommunicationState.Closed) statusService.Close(); } } }