aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/MachineStudio/Modules/Tango.MachineStudio.DB/ViewModels/UsersViewVM.cs
blob: 5606d9da8cb9e637d9e2ed9460af8d88fc0b2abd (plain)
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
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.BL.Entities;
using Tango.MachineStudio.Common.Notifications;
using SimpleValidator.Extensions;

namespace Tango.MachineStudio.DB.ViewModels
{
    public class UsersViewVM : DbTableViewModel<User>
    {
        public UsersViewVM(INotificationProvider notification) : base(notification)
        {
            SelectedRoles = new ObservableCollection<MultiComboVM<Role>>();
        }

        private ObservableCollection<MultiComboVM<Role>> _selectedRoles;
        public ObservableCollection<MultiComboVM<Role>> SelectedRoles
        {
            get { return _selectedRoles; }
            set { _selectedRoles = value; RaisePropertyChangedAuto(); }
        }

        protected override void OnEdit()
        {
            SelectedRoles = Adapter.Roles.Select(x => new MultiComboVM<Role>(x, () => RaisePropertyChanged(nameof(SelectedRoles)))).ToObservableCollection();

            foreach (var role in SelectedRoles)
            {
                if (SelectedEntity.UsersRoles.ToList().Exists(x => x.Role == role.Entity))
                {
                    role.IsSelected = true;
                }
            }

            base.OnEdit();
        }

        protected override void OnAdd()
        {
            SelectedRoles = Adapter.Roles.Select(x => new MultiComboVM<Role>(x, () => RaisePropertyChanged(nameof(SelectedRoles)))).ToObservableCollection();

            base.OnAdd();
        }

        protected override void OnBeforeEntitySave(DialogOpenMode mode, User user)
        {
            base.OnBeforeEntitySave(mode, user);

            Adapter.Context.UsersRoles.RemoveRange(user.UsersRoles);

            foreach (var role in SelectedRoles)
            {
                if (role.IsSelected)
                {
                    user.UsersRoles.Add(new UsersRole()
                    {
                        Role = role.Entity,
                        User = user,
                        RoleGuid = role.Entity.Guid,
                        UserGuid = user.Guid
                    });
                }
            }
        }

        protected override void OnValidating()
        {
            base.OnValidating();

            if (EditEntity.Email != null)
            {
                if (Adapter.Users.ToList().Exists(x => x.Guid != EditEntity.Guid && x.Email.ToLower() == EditEntity.Email.ToLower()))
                {
                    ValidationErrors.Add("Email already exist");
                }
            }

            if (!EditEntity.Email.IsEmail())
            {
                ValidationErrors.Add("Email address is invalid");
            }

            if (!EditEntity.Password.IsMinLength(4))
            {
                ValidationErrors.Add("Password must have at least 4 characters");
            }
        }
    }
}
class="w"> = new List<MachinesEvent>(); _eventTypesGuids = new Dictionary<EventTypes, BL.Entities.EventType>(); _application = applicationManager; _authentication = authenticationProvider; _logThread = new Thread(LogThreadMethod); _logThread.IsBackground = true; _logThread.Start(); _application.ConnectedMachineChanged += _application_ConnectedMachineChanged; } #endregion #region Private Methods private void Init() { if (!_isInitialized) { try { _db = ObservablesContext.CreateDefault(); _db.Configuration.LazyLoadingEnabled = false; _db.ActionTypes.ToList(); _db.EventTypesActions.ToList(); _db.EventTypesCategories.ToList(); _db.EventTypesGroups.ToList(); _db.EventTypes.ToList(); foreach (var type in _db.EventTypes) { _eventTypesGuids.Add((EventTypes)type.Code, type); } _isInitialized = true; } catch { _isInitialized = false; } } } #endregion #region Event Handlers /// <summary> /// Handle the application manager connected machine changed event. /// </summary> /// <param name="sender">The sender.</param> /// <param name="machine">The machine.</param> private void _application_ConnectedMachineChanged(object sender, IExternalBridgeClient machine) { if (machine != null) { if (machine.MachineEventsStateProvider != null) { machine.MachineEventsStateProvider.NewEvents -= MachineEventsStateProvider_NewEvents; machine.MachineEventsStateProvider.NewEvents += MachineEventsStateProvider_NewEvents; machine.MachineEventsStateProvider.EventsResolved -= MachineEventsStateProvider_EventsResolved; machine.MachineEventsStateProvider.EventsResolved += MachineEventsStateProvider_EventsResolved; } machine.RequestSent -= Machine_RequestSent; machine.RequestFailed -= Machine_RequestFailed; machine.ResponseReceived -= Machine_ResponseReceived; machine.RequestSent += Machine_RequestSent; machine.RequestFailed += Machine_RequestFailed; machine.ResponseReceived += Machine_ResponseReceived; } } /// <summary> /// Handles the RequestSent event of the connected machine. /// </summary> /// <param name="sender">The sender.</param> /// <param name="message">The message.</param> private void Machine_RequestSent(object sender, IMessage message) { Log(EventTypes.RequestSent, String.Format("Sending request '{0}'...{1}{2}", message.GetType().Name, Environment.NewLine, message.ToJsonString())); } /// <summary> /// Handles the RequestFailed event of the connected machine. /// </summary> /// <param name="sender">The source of the event.</param> /// <param name="e">The <see cref="RequestFailedEventArgs"/> instance containing the event data.</param> private void Machine_RequestFailed(object sender, RequestFailedEventArgs e) { Log(EventTypes.RequestFailed, String.Format("Request failed '{0}'...{1}{2}{1}{3}", e.Message.GetType().Name, Environment.NewLine, e.Message.ToJsonString(), e.Exception.ToString())); } /// <summary> /// Handles the ResponseReceived event of the connected machine. /// </summary> /// <param name="sender">The sender.</param> /// <param name="message">The message.</param> private void Machine_ResponseReceived(object sender, IMessage message) { Log(EventTypes.ResponseReceived, String.Format("Response received '{0}'...{1}{2}", message.GetType().Name, Environment.NewLine, message.ToJsonString())); } /// <summary> /// Handles the connected machine events state provider NewEvents event. /// </summary> /// <param name="sender">The sender.</param> /// <param name="events">The events.</param> private void MachineEventsStateProvider_NewEvents(object sender, IEnumerable<MachinesEvent> events) { foreach (var ev in events) { Log(ev); } } /// <summary> /// Handles the connected machine events state provider EventsResolved event. /// </summary> /// <param name="sender">The sender.</param> /// <param name="events">The events.</param> private void MachineEventsStateProvider_EventsResolved(object sender, IEnumerable<MachinesEvent> events) { foreach (var ev in events) { Log(String.Format("Event '{0}' resolved.", ev.EventType.Name)); } } #endregion #region Logging /// <summary> /// Logs the specified machine event. /// </summary> /// <param name="machineEvent">The machine event.</param> public void Log(MachinesEvent machineEvent) { machineEvent.HostName = _hostName; machineEvent.EventType = _eventTypesGuids[machineEvent.Type]; if (_application.ConnectedMachine == null || _authentication.CurrentUser == null) { _pendingEvents.Add(machineEvent); } else { if (_pendingEvents.Count > 0) { var pending = _pendingEvents.ToList(); _pendingEvents.Clear(); foreach (var ev in pending) { Log(ev); } } LogManager.Log("Logging event " + machineEvent.EventType.Name + " - " + machineEvent.Description); machineEvent.MachineGuid = _application.ConnectedMachine.Machine.Guid; machineEvent.UserGuid = _authentication.CurrentUser.Guid; machineEvent.User = _authentication.CurrentUser; _events.Enqueue(machineEvent); NewLog?.Invoke(this, machineEvent); } } /// <summary> /// Logs the specified event type. /// </summary> /// <param name="eventType">Type of the event.</param> /// <param name="message">The message.</param> public void Log(EventTypes eventType, string message, bool write_to_db = true) { Init(); MachinesEvent machineEvent = new MachinesEvent(); machineEvent.DateTime = DateTime.UtcNow; machineEvent.Description = message; machineEvent.EventType = _eventTypesGuids[eventType]; machineEvent.EventTypeGuid = machineEvent.EventType.Guid; if (write_to_db) { Log(machineEvent); } else { NewLog?.Invoke(this, machineEvent); } } /// <summary> /// Logs the specified hardware event. /// </summary> /// <param name="hardwareEvent">The hardware event.</param> public void Log(Event hardwareEvent) { Log((EventTypes)hardwareEvent.Type, hardwareEvent.Message); } /// <summary> /// Logs the specified exception using the <see cref="EventTypes.ApplicationException"/>. /// </summary> /// <param name="exception">The exception.</param> public void Log(Exception exception) { Log(EventTypes.ApplicationException, exception.ToString()); } /// <summary> /// Logs the specified exception using the <see cref="EventTypes.ApplicationException" />. /// </summary> /// <param name="exception">The exception.</param> /// <param name="description"></param> public void Log(Exception exception, string description) { Log(EventTypes.ApplicationException, description + Environment.NewLine + exception.ToString()); } /// <summary> /// Logs the specified message using the <see cref="EventTypes.ApplicationInformation"/>. /// </summary> /// <param name="message">The message.</param> public void Log(String message) { Log(EventTypes.ApplicationInformation, message); } /// <summary> /// Logging thread loop. /// </summary> private void LogThreadMethod() { while (true) { FlushAll(); Thread.Sleep(5000); } } /// <summary> /// Immediately saves all pending events to database. /// </summary> public void FlushAll() { bool _saveChanges = false; while (_events.Count > 0) { MachinesEvent ev = null; if (_events.TryDequeue(out ev)) { ev.User = null; _db.MachinesEvents.Add(ev); _saveChanges = true; } } if (_saveChanges) { try { _db.SaveChanges(); } catch (Exception ex) { LogManager.Log(ex, "Error saving machine event to database."); } } } #endregion } }