Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added IoT gateway project witn Netduino 3 WiFi
- Loading branch information
Showing
6 changed files
with
350 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,57 @@ | ||
| <?xml version="1.0" encoding="utf-8"?> | ||
| <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> | ||
| <PropertyGroup> | ||
| <AssemblyName>NetduinoToEventHub</AssemblyName> | ||
| <OutputType>Exe</OutputType> | ||
| <RootNamespace>NetduinoToEventHub</RootNamespace> | ||
| <ProjectTypeGuids>{b69e3092-b931-443c-abe7-7e7b65f2a37f};{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}</ProjectTypeGuids> | ||
| <ProductVersion>9.0.21022</ProductVersion> | ||
| <SchemaVersion>2.0</SchemaVersion> | ||
| <ProjectGuid>{5AEF163A-1DD4-43BD-B52C-F84A7340D9A9}</ProjectGuid> | ||
| <TargetFrameworkVersion>v4.3</TargetFrameworkVersion> | ||
| <NetMfTargetsBaseDir Condition="'$(NetMfTargetsBaseDir)'==''">$(MSBuildExtensionsPath32)\Microsoft\.NET Micro Framework\</NetMfTargetsBaseDir> | ||
| <DeployDevice>Netduino</DeployDevice> | ||
| <DeployTransport>USB</DeployTransport> | ||
| </PropertyGroup> | ||
| <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' "> | ||
| <DebugSymbols>true</DebugSymbols> | ||
| <DebugType>full</DebugType> | ||
| <Optimize>false</Optimize> | ||
| <OutputPath>bin\Debug\</OutputPath> | ||
| <DefineConstants>DEBUG;TRACE</DefineConstants> | ||
| <ErrorReport>prompt</ErrorReport> | ||
| <WarningLevel>4</WarningLevel> | ||
| </PropertyGroup> | ||
| <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' "> | ||
| <DebugType>pdbonly</DebugType> | ||
| <Optimize>true</Optimize> | ||
| <OutputPath>bin\Release\</OutputPath> | ||
| <DefineConstants>TRACE</DefineConstants> | ||
| <ErrorReport>prompt</ErrorReport> | ||
| <WarningLevel>4</WarningLevel> | ||
| </PropertyGroup> | ||
| <Import Project="$(NetMfTargetsBaseDir)$(TargetFrameworkVersion)\CSharp.Targets" /> | ||
| <ItemGroup> | ||
| <Compile Include="NtpClient.cs" /> | ||
| <Compile Include="Properties\AssemblyInfo.cs" /> | ||
| <Compile Include="Program.cs" /> | ||
| </ItemGroup> | ||
| <ItemGroup> | ||
| <Reference Include="Microsoft.SPOT.Hardware" /> | ||
| <Reference Include="Microsoft.SPOT.Hardware.PWM" /> | ||
| <Reference Include="Microsoft.SPOT.Hardware.SerialPort" /> | ||
| <Reference Include="Microsoft.SPOT.Native" /> | ||
| <Reference Include="Microsoft.SPOT.Net" /> | ||
| <Reference Include="Microsoft.SPOT.Time" /> | ||
| <Reference Include="SecretLabs.NETMF.Hardware" /> | ||
| <Reference Include="SecretLabs.NETMF.Hardware.Netduino" /> | ||
| <Reference Include="System" /> | ||
| <Reference Include="GoBus" /> | ||
| </ItemGroup> | ||
| <ItemGroup> | ||
| <ProjectReference Include="..\IoTClient\IoTClient.NetMf43\IoTClient.NetMf43.csproj"> | ||
| <Project>{0BFFA8ED-1C52-4C0C-97A2-6825A6D528CA}</Project> | ||
| <Name>IoTClient.NetMf43</Name> | ||
| </ProjectReference> | ||
| </ItemGroup> | ||
| </Project> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,111 @@ | ||
| /* | ||
| * NtpClient.cs | ||
| * | ||
| * Copyright (c) 2009, Michael Schwarz (http://www.schwarz-interactive.de) | ||
| * | ||
| * Permission is hereby granted, free of charge, to any person | ||
| * obtaining a copy of this software and associated documentation | ||
| * files (the "Software"), to deal in the Software without | ||
| * restriction, including without limitation the rights to use, | ||
| * copy, modify, merge, publish, distribute, sublicense, and/or | ||
| * sell copies of the Software, and to permit persons to whom the | ||
| * Software is furnished to do so, subject to the following conditions: | ||
| * | ||
| * The above copyright notice and this permission notice shall be | ||
| * included in all copies or substantial portions of the Software. | ||
| * | ||
| * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, | ||
| * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES | ||
| * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. | ||
| * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR | ||
| * ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF | ||
| * CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN | ||
| * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | ||
| * | ||
| * MS 09-02-16 added NtpClient | ||
| * | ||
| * | ||
| */ | ||
| using System; | ||
| using System.Text; | ||
| using System.Net; | ||
| using System.Net.Sockets; | ||
|
|
||
| namespace MFToolkit.Net.Ntp | ||
| { | ||
| /// <summary> | ||
| /// Static class to receive the time from a NTP server. | ||
| /// </summary> | ||
| public class NtpClient | ||
| { | ||
| /// <summary> | ||
| /// Gets the current DateTime from time-a.nist.gov. | ||
| /// </summary> | ||
| /// <returns>A DateTime containing the current time.</returns> | ||
| public static DateTime GetNetworkTime() | ||
| { | ||
| return GetNetworkTime("time-a.nist.gov"); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets the current DateTime from <paramref name="ntpServer"/>. | ||
| /// </summary> | ||
| /// <param name="ntpServer">The hostname of the NTP server.</param> | ||
| /// <returns>A DateTime containing the current time.</returns> | ||
| public static DateTime GetNetworkTime(string ntpServer) | ||
| { | ||
| IPAddress[] address = Dns.GetHostEntry(ntpServer).AddressList; | ||
|
|
||
| if (address == null || address.Length == 0) | ||
| throw new ArgumentException("Could not resolve ip address from '" + ntpServer + "'.", "ntpServer"); | ||
|
|
||
| IPEndPoint ep = new IPEndPoint(address[0], 123); | ||
|
|
||
| return GetNetworkTime(ep); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets the current DateTime form <paramref name="ep"/> IPEndPoint. | ||
| /// </summary> | ||
| /// <param name="ep">The IPEndPoint to connect to.</param> | ||
| /// <returns>A DateTime containing the current time.</returns> | ||
| public static DateTime GetNetworkTime(IPEndPoint ep) | ||
| { | ||
| Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); | ||
|
|
||
| s.Connect(ep); | ||
|
|
||
| byte[] ntpData = new byte[48]; // RFC 2030 | ||
| ntpData[0] = 0x1B; | ||
| for (int i = 1; i < 48; i++) | ||
| ntpData[i] = 0; | ||
|
|
||
| s.Send(ntpData); | ||
| s.Receive(ntpData); | ||
|
|
||
| byte offsetTransmitTime = 40; | ||
| ulong intpart = 0; | ||
| ulong fractpart = 0; | ||
|
|
||
| for (int i = 0; i <= 3; i++) | ||
| intpart = 256 * intpart + ntpData[offsetTransmitTime + i]; | ||
|
|
||
| for (int i = 4; i <= 7; i++) | ||
| fractpart = 256 * fractpart + ntpData[offsetTransmitTime + i]; | ||
|
|
||
| ulong milliseconds = (intpart * 1000 + (fractpart * 1000) / 0x100000000L); | ||
| s.Close(); | ||
|
|
||
| TimeSpan timeSpan = TimeSpan.FromTicks((long)milliseconds * TimeSpan.TicksPerMillisecond); | ||
|
|
||
| DateTime dateTime = new DateTime(1900, 1, 1); | ||
| dateTime += timeSpan; | ||
|
|
||
| TimeSpan offsetAmount = TimeZone.CurrentTimeZone.GetUtcOffset(dateTime); | ||
| DateTime networkDateTime = (dateTime + offsetAmount); | ||
|
|
||
| return networkDateTime; | ||
| } | ||
| } | ||
| } | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| using System; | ||
| using System.Net; | ||
| using System.Net.Sockets; | ||
| using System.Threading; | ||
| using Microsoft.SPOT; | ||
| using Microsoft.SPOT.Hardware; | ||
| using SecretLabs.NETMF.Hardware; | ||
| using SecretLabs.NETMF.Hardware.Netduino; | ||
| using ppatierno.TI; | ||
| using ppatierno.ST; | ||
| using ppatierno.IoT; | ||
| using Microsoft.SPOT.Time; | ||
| using System.Collections; | ||
|
|
||
| namespace NetduinoToEventHub | ||
| { | ||
| public class Program | ||
| { | ||
| // TI Sensor Tag parameters | ||
| private byte[] TI_SENSORTAG_ADDR = { 0x4E, 0x58, 0x6E, 0xE5, 0xC5, 0x78 }; | ||
| #if HEART_RATE | ||
| private byte[] BlueNRG_HRM_ADDR = { 0xFD, 0x00, 0x25, 0xEC, 0x02, 0x04 }; | ||
|
|
||
| BlueNRG_HRM blueNGR_HRM; | ||
| #endif | ||
| TISensorTag tiSensorTag; | ||
| IIoTClient iotClient; | ||
|
|
||
| #if CONNECT_THE_DOTS | ||
| // Event Hub connection string | ||
| private string connectionString = "[EVENT_HUB_CONNECTION_STRING]"; | ||
| private string eventhubentity = "[EVENT_HUB_NAME]"; | ||
| #else | ||
| // Event Hub connection string | ||
| private string connectionString = "[EVENT_HUB_CONNECTION_STRING]"; | ||
| private string eventhubentity = "[EVENT_HUB_NAME]"; | ||
| #endif | ||
|
|
||
| static AutoResetEvent networkAvailableEvent = new AutoResetEvent(false); | ||
| static AutoResetEvent networkAddressChangedEvent = new AutoResetEvent(false); | ||
|
|
||
| public static void Main() | ||
| { | ||
| (new Program()).Run(); | ||
| } | ||
|
|
||
| public void Run() | ||
| { | ||
| Microsoft.SPOT.Net.NetworkInformation.NetworkChange.NetworkAvailabilityChanged += NetworkChange_NetworkAvailabilityChanged; | ||
| Microsoft.SPOT.Net.NetworkInformation.NetworkChange.NetworkAddressChanged += NetworkChange_NetworkAddressChanged; | ||
|
|
||
| networkAvailableEvent.WaitOne(); | ||
| Debug.Print("link is up!"); | ||
| networkAddressChangedEvent.WaitOne(); | ||
| Debug.Print("address acquired: " + Microsoft.SPOT.Net.NetworkInformation.NetworkInterface.GetAllNetworkInterfaces()[0].IPAddress); | ||
|
|
||
| Debug.Print("\r\n*** GET NETWORK INTERFACE SETTINGS ***"); | ||
| Microsoft.SPOT.Net.NetworkInformation.NetworkInterface[] networkInterfaces = Microsoft.SPOT.Net.NetworkInformation.NetworkInterface.GetAllNetworkInterfaces(); | ||
| Debug.Print("Found " + networkInterfaces.Length + " network interfaces."); | ||
|
|
||
| // get date/time via NTP | ||
| DateTime dateTime = MFToolkit.Net.Ntp.NtpClient.GetNetworkTime(); | ||
| Utility.SetLocalTime(dateTime); | ||
|
|
||
| // set and open the IoT client | ||
| if (this.iotClient == null) | ||
| { | ||
| #if CONNECT_THE_DOTS | ||
| this.iotClient = new IoTClientDots("netduino", Guid.NewGuid().ToString(), connectionString, eventhubentity); | ||
| #elif HEART_RATE | ||
| this.iotClient = new IoTClientHealth("netduino", Guid.NewGuid().ToString(), connectionString, eventhubentity); | ||
| #else | ||
| this.iotClient = new IoTClient("netduino", Guid.NewGuid().ToString(), connectionString, eventhubentity); | ||
| #endif | ||
| } | ||
|
|
||
| if (!this.iotClient.IsOpen) | ||
| this.iotClient.Open(); | ||
|
|
||
| // NOTE : seems to be a .Net MF bug when in this ethernet handler and you are waiting | ||
| // a response on serial port, the data can't be received. | ||
| // Launch serial communication with BLE module on different thread. | ||
| Thread t = new Thread(this.SensorsSetup); | ||
| t.Start(); | ||
| //this.SensorsSetup(); | ||
|
|
||
| Thread.Sleep(Timeout.Infinite); | ||
| } | ||
|
|
||
| void NetworkChange_NetworkAddressChanged(object sender, EventArgs e) | ||
| { | ||
| Debug.Print("NetworkAddressChanged"); | ||
| networkAddressChangedEvent.Set(); | ||
| } | ||
|
|
||
| void NetworkChange_NetworkAvailabilityChanged(object sender, Microsoft.SPOT.Net.NetworkInformation.NetworkAvailabilityEventArgs e) | ||
| { | ||
| Debug.Print("NetworkAvailabilityChanged " + e.IsAvailable); | ||
| if (e.IsAvailable) | ||
| { | ||
| networkAvailableEvent.Set(); | ||
| } | ||
| } | ||
|
|
||
| private void SensorsSetup() | ||
| { | ||
| #if HEART_RATE | ||
| BlueNRG_HRMSettings settings = | ||
| new BlueNRG_HRMSettings | ||
| { | ||
| Address = BlueNRG_HRM_ADDR | ||
| }; | ||
|
|
||
| this.blueNGR_HRM = new BlueNRG_HRM(settings); | ||
|
|
||
| this.blueNGR_HRM.SensorValueChanged += device_SensorValueChanged; | ||
|
|
||
| this.blueNGR_HRM.Open(); | ||
| #else | ||
| // setup TI Sensor Tag | ||
| TISensorTagSettings settings = | ||
| new TISensorTagSettings | ||
| { | ||
| Address = TI_SENSORTAG_ADDR, | ||
| IsTemperatureEnabled = true, | ||
| IsHumidityEnabled = true, | ||
| IsAccelerometerEnabled = true, | ||
| Period = 100 | ||
| }; | ||
|
|
||
| this.tiSensorTag = new TISensorTag(settings); | ||
|
|
||
| // set notification handlers | ||
| this.tiSensorTag.SensorValueChanged += device_SensorValueChanged; | ||
|
|
||
| // open connection and start reading from sensors | ||
| this.tiSensorTag.Open(); | ||
| #endif | ||
| } | ||
|
|
||
| void device_SensorValueChanged(object sender, IDictionary e) | ||
| { | ||
| if ((this.iotClient != null) && (this.iotClient.IsOpen)) | ||
| { | ||
| this.iotClient.SendAsync(e); | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,25 @@ | ||
| using System.Reflection; | ||
| using System.Runtime.CompilerServices; | ||
| using System.Runtime.InteropServices; | ||
|
|
||
| // General Information about an assembly is controlled through the following | ||
| // set of attributes. Change these attribute values to modify the information | ||
| // associated with an assembly. | ||
| [assembly: AssemblyTitle("NetduinoToEventHub")] | ||
| [assembly: AssemblyDescription("")] | ||
| [assembly: AssemblyConfiguration("")] | ||
| [assembly: AssemblyCompany("")] | ||
| [assembly: AssemblyProduct("NetduinoToEventHub")] | ||
| [assembly: AssemblyCopyright("Copyright © 2015")] | ||
| [assembly: AssemblyTrademark("")] | ||
| [assembly: AssemblyCulture("")] | ||
|
|
||
| // Version information for an assembly consists of the following four values: | ||
| // | ||
| // Major Version | ||
| // Minor Version | ||
| // Build Number | ||
| // Revision | ||
| // | ||
| [assembly: AssemblyVersion("1.0.0.0")] | ||
| [assembly: AssemblyFileVersion("1.0.0.0")] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.