IoT and “Industrie 4.0” for SharePoint - Part I

  public partial class Program
   {
       private GasModule m_Gas;

       // This method is run when the mainboard is powered up or reset.  
       void ProgramStarted()
       {
           m_Gas = new GasModule(1, 2);
           m_Gas.OnThresholdReached += gas_OnThresholdReached;
           m_Gas.Start();

           new Thread(() =>
           {
               startReceiveCommandLoop();
           }).Start();

           // Use Debug.Print to show messages in Visual Studio's "Output" 
           // window during debugging.
           Debug.Print("Program Started");
       }

       /// <summary>
       /// Invoked when gas has reached defined threashold value.
       /// </summary>
       /// <param name="sender"></param>
       /// <param name="state"></param>
       void gas_OnThresholdReached(GasModule sender,
                                   ThresholdReachedEventArgs state)
       {
           publishCriticalEvent(state);
       }

       /// <summary>
       /// Sending sensor state.
       /// </summary>
       /// <param name="state"></param>
       private static void publishCriticalEvent(ThresholdReachedEventArgs state)
       {
           var settings = new ApplicationSettings("gasingressqueue");

           var tokenProvider =
           new TokenProvider(settings.DeviceAccount, settings.DeviceKey);
           var sendClient =
           new MessagingClient(settings.EventSubmissionUri, tokenProvider);

           try
           {
               var sensorMsg = new SimpleMessage
               {
                   Properties = { { "gaslevel", state.Threshold},
                                   {"timestamp", state.Timestamp},
                                   {"sensorid", state.SensorId},
                                   {"owner", "Damir Dobric – daenet GmbH"}}
               };

               sendClient.Send(sensorMsg);
               Debug.Print("New state sent: " + state.Timestamp.ToString() + ",
               " + state.Threshold);
           }
           catch (Exception ex)
           {

           }
       }

       /// <summary>
       /// Receiving commands.
       /// </summary>
       private void startReceiveCommandLoop()
       {
           while (true)
           {
               var settings = new ApplicationSettings("gascommandqueue");

               var tokenProvider =
               new TokenProvider(settings.DeviceAccount, settings.DeviceKey);
               var rcvClient =
               new MessagingClient(settings.EventSubmissionUri, tokenProvider);

               try
               {
                   var msg = rcvClient.Receive(TimeSpan.FromTicks
                   (TimeSpan.TicksPerSecond * 60),
                   ReceiveMode.ReceiveAndDelete);
                   string command = (string)msg.Properties["command"];
                   if (command != null)
                   {
                       string commad = (string)msg.Properties["command"];
                       string owner = (string)msg.Properties["owner"];
                       string timestamp = (string)msg.Properties["observed"];

                       if (command == "stop")
                           m_Gas.Stop();
                       else if (command == "start")
                           m_Gas.Start();
                       else if (command == "threshold")
                       {
                           double threshold;

                           string t = (string)msg.Properties["param"];
                           if (double.TryParse(t, out threshold))
                               m_Gas.SetThreshold(threshold);
                       }

                       Debug.Print("Command received: " + owner +
                       ", command: " + command);
                   }
               }
               catch (Exception ex)
               {
                   Debug.Print("Exception: " + ex.Message);
               }
           }
       }
   }