Move examples from root to /Examples

Examples/Examples.WPF/Views/ConnectView.xaml.cs

@@ -0,0 +1,161 @@
+using Examples.WPF.RegisterCollections;
+using Examples.WPF.ViewModels;
+using MewtocolNet;
+using MewtocolNet.ComCassette;
+using MewtocolNet.Logging;
+using MewtocolNet.Registers;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Windows;
+using System.Windows.Controls;
+using System.Windows.Data;
+using System.Windows.Documents;
+using System.Windows.Input;
+using System.Windows.Media;
+using System.Windows.Media.Imaging;
+using System.Windows.Navigation;
+using System.Windows.Shapes;
+
+namespace Examples.WPF.Views;
+
+/// <summary>
+/// Interaktionslogik für ConnectView.xaml
+/// </summary>
+public partial class ConnectView : UserControl {
+
+    private ConnectViewViewModel viewModel;
+
+    public ConnectView() {
+
+        InitializeComponent();
+        viewModel = new ConnectViewViewModel();
+        this.DataContext = viewModel;
+
+        Unloaded += (s, e) => viewModel.EndTimer();
+
+    }
+
+    private void SelectedCassette(object sender, SelectionChangedEventArgs e) {
+
+        var cassette = (CassetteInformation)((DataGrid)sender).SelectedItem;
+        if (cassette == null) return;
+
+        viewModel.SelectedCassette(cassette);
+
+    }
+
+    private void ClickedConnectEth(object sender, RoutedEventArgs e) {
+
+        Application.Current.Dispatcher.BeginInvoke(async () => {
+
+            viewModel.IsConnecting = true;
+
+            var parsedInt = int.Parse(viewModel.SelectedPort);
+
+            IRegister<short> heartbeatSetter = null!;
+            IRegister<bool> outputContactReference = null!;
+            IRegister<bool> testBoolReference = null!;
+            IRegister<Word> wordRefTest = null!;
+
+            //build a new interface
+            App.ViewModel.Plc = Mewtocol.Ethernet(viewModel.SelectedIP, parsedInt)
+            .WithPoller()
+            .WithInterfaceSettings(setting => {
+
+                setting.TryReconnectAttempts = 10;
+                setting.TryReconnectDelayMs = 2000;
+                setting.SendReceiveTimeoutMs = 1000;
+                setting.HeartbeatIntervalMs = 3000;
+                setting.MaxDataBlocksPerWrite = 128;
+                setting.MaxOptimizationDistance = 20;
+
+            })
+            .WithCustomPollLevels(lvl => {
+
+                lvl.SetLevel(2, 3);
+                lvl.SetLevel(3, TimeSpan.FromSeconds(5));
+                lvl.SetLevel(4, TimeSpan.FromSeconds(10));
+
+            })
+            .WithRegisterCollections(collector => {
+
+                App.ViewModel.TestRegCollection = collector.AddCollection<TestRegisterCollection>();
+
+            })
+            .WithRegisters(b => {
+
+                b.Bool("X4").Build();
+                b.Bool("Y4").Build(out outputContactReference);
+                b.Bool("R10A").PollLevel(PollLevel.FirstIteration).Build(out testBoolReference);
+
+                b.Struct<short>("DT1000").Build(out heartbeatSetter);
+
+                //these will be merged into one
+                b.Struct<Word>("DT1000").Build(out wordRefTest);
+                b.Struct<Word>("DT1000").Build(out wordRefTest);
+
+                b.Struct<ushort>("DT1001").PollLevel(2).Build();
+                b.Struct<Word>("DT1002").PollLevel(2).Build();
+
+                b.Struct<int>("DDT1010").PollLevel(2).Build();
+                b.Struct<uint>("DDT1012").PollLevel(2).Build();
+                b.Struct<DWord>("DDT1014").PollLevel(2).Build();
+                b.Struct<float>("DDT1016").PollLevel(2).Build();
+                b.Struct<TimeSpan>("DDT1018").PollLevel(2).Build();
+
+                b.Struct<DateAndTime>("DDT1020").PollLevel(2).Build();
+                b.Struct<DateAndTime>("DDT1022").PollLevel(2).Build();
+
+                b.String("DT1028", 32).PollLevel(3).Build();
+                b.String("DT1046", 5).PollLevel(4).Build();
+
+                b.Struct<Word>("DT1000").AsArray(5).PollLevel(1).Build();
+
+            })
+            .WithHeartbeatTask(async (plc) => {
+
+                var randShort = (short)new Random().Next(short.MinValue, short.MaxValue);
+
+                //write direct
+                //await heartbeatSetter.WriteAsync(randShort);
+                //or by anonymous
+                await plc.Register.Struct<short>("DT1000").WriteAsync(randShort);
+
+                //write a register without a reference
+                bool randBool = new Random().Next(0, 2) == 1;
+                await plc.Register.Bool("Y4").WriteAsync(randBool);
+
+                if (testBoolReference.Value != null)
+                    await testBoolReference.WriteAsync(!testBoolReference.Value.Value);
+
+                await plc.Register.Struct<DateAndTime>("DDT1022").WriteAsync(DateAndTime.FromDateTime(DateTime.UtcNow));
+
+            })
+            .Build();
+
+            //connect to it
+            await App.ViewModel.Plc.ConnectAsync(async () => {
+
+                await App.ViewModel.Plc.RestartProgramAsync();
+
+            });
+
+            await App.ViewModel.Plc.AwaitFirstDataCycleAsync();
+
+            if (App.ViewModel.Plc.IsConnected) {
+
+                App.MainWindow.mainContent.Content = new PlcDataView();
+
+            }
+
+            viewModel.IsConnecting = false;
+
+        }, System.Windows.Threading.DispatcherPriority.Send);
+
+    }
+
+}