Compare commits
	
		
			14 Commits
		
	
	
		
			feature/Co
			...
			feature/do
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 966d8bd79e | |||
| 5b42ce9f43 | |||
| 85320d3cf3 | |||
| 9d55c39e33 | |||
| d75e9d378d | |||
| 3cdaa2dc35 | |||
| 9af0ba1bb8 | |||
| 04c27560ea | |||
| 73157520ab | |||
| f862e4b8da | |||
| f85346aea9 | |||
| 1d438bc349 | |||
| 86999cd646 | |||
| 8979ad6db3 | 
							
								
								
									
										25
									
								
								.dockerignore
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										25
									
								
								.dockerignore
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,25 @@
 | 
			
		||||
**/.classpath
 | 
			
		||||
**/.dockerignore
 | 
			
		||||
**/.env
 | 
			
		||||
**/.git
 | 
			
		||||
**/.gitignore
 | 
			
		||||
**/.project
 | 
			
		||||
**/.settings
 | 
			
		||||
**/.toolstarget
 | 
			
		||||
**/.vs
 | 
			
		||||
**/.vscode
 | 
			
		||||
**/*.*proj.user
 | 
			
		||||
**/*.dbmdl
 | 
			
		||||
**/*.jfm
 | 
			
		||||
**/azds.yaml
 | 
			
		||||
**/docs
 | 
			
		||||
**/bin
 | 
			
		||||
**/docker-compose*
 | 
			
		||||
**/Dockerfile*
 | 
			
		||||
**/node_modules
 | 
			
		||||
**/npm-debug.log
 | 
			
		||||
**/obj
 | 
			
		||||
**/secrets.dev.yaml
 | 
			
		||||
**/values.dev.yaml
 | 
			
		||||
LICENSE
 | 
			
		||||
README.md
 | 
			
		||||
@@ -8,6 +8,9 @@
 | 
			
		||||
    <SpaRoot>ClientApp\</SpaRoot>
 | 
			
		||||
    <DefaultItemExcludes>$(DefaultItemExcludes);$(SpaRoot)node_modules\**</DefaultItemExcludes>
 | 
			
		||||
    <AssemblyName>Birdmap.API</AssemblyName>
 | 
			
		||||
    <UserSecretsId>a919c854-b332-49ee-8e38-96549f828836</UserSecretsId>
 | 
			
		||||
    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
 | 
			
		||||
    <DockerComposeProjectPath>..\docker-compose.dcproj</DockerComposeProjectPath>
 | 
			
		||||
  </PropertyGroup>
 | 
			
		||||
 | 
			
		||||
  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Release|AnyCPU'">
 | 
			
		||||
@@ -31,6 +34,7 @@
 | 
			
		||||
      <PrivateAssets>all</PrivateAssets>
 | 
			
		||||
      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
 | 
			
		||||
    </PackageReference>
 | 
			
		||||
    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.10.9" />
 | 
			
		||||
    <PackageReference Include="MQTTnet" Version="3.0.13" />
 | 
			
		||||
    <PackageReference Include="MQTTnet.AspNetCore" Version="3.0.13" />
 | 
			
		||||
    <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
 | 
			
		||||
@@ -52,6 +56,7 @@
 | 
			
		||||
    <None Remove="ClientApp\src\components\auth\Auth.tsx" />
 | 
			
		||||
    <None Remove="ClientApp\src\components\auth\AuthClient.ts" />
 | 
			
		||||
    <None Remove="ClientApp\src\components\auth\AuthService.ts" />
 | 
			
		||||
    <None Remove="ClientApp\src\components\dashboard\ServiceInfoService.ts" />
 | 
			
		||||
    <None Remove="ClientApp\src\components\devices\DeviceService.ts" />
 | 
			
		||||
  </ItemGroup>
 | 
			
		||||
 | 
			
		||||
@@ -61,7 +66,6 @@
 | 
			
		||||
 | 
			
		||||
  <ItemGroup>
 | 
			
		||||
    <Folder Include="ClientApp\src\common\components\" />
 | 
			
		||||
    <Folder Include="ClientApp\src\components\dashboard\" />
 | 
			
		||||
  </ItemGroup>
 | 
			
		||||
 | 
			
		||||
  <ItemGroup>
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										115
									
								
								Birdmap.API/ClientApp/package-lock.json
									
									
									
										generated
									
									
									
								
							
							
						
						
									
										115
									
								
								Birdmap.API/ClientApp/package-lock.json
									
									
									
										generated
									
									
									
								
							@@ -1610,6 +1610,25 @@
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@nodelib/fs.stat/-/fs.stat-1.1.3.tgz",
 | 
			
		||||
      "integrity": "sha512-shAmDyaQC4H92APFoIaVDHCx5bStIocgvbwQyxPRrbUY20V1EYTbSDchWbuwlMG3V17cprZhA6+78JfB+3DTPw=="
 | 
			
		||||
    },
 | 
			
		||||
    "@rollup/plugin-babel": {
 | 
			
		||||
      "version": "5.2.1",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@rollup/plugin-babel/-/plugin-babel-5.2.1.tgz",
 | 
			
		||||
      "integrity": "sha512-Jd7oqFR2dzZJ3NWANDyBjwTtX/lYbZpVcmkHrfQcpvawHs9E4c0nYk5U2mfZ6I/DZcIvy506KZJi54XK/jxH7A==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "@babel/helper-module-imports": "^7.10.4",
 | 
			
		||||
        "@rollup/pluginutils": "^3.1.0"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "@rollup/pluginutils": {
 | 
			
		||||
      "version": "3.1.0",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@rollup/pluginutils/-/pluginutils-3.1.0.tgz",
 | 
			
		||||
      "integrity": "sha512-GksZ6pr6TpIjHm8h9lSQ8pi8BE9VeubNT0OMJ3B5uZJ8pz73NPiqOtCog/x2/QzM1ENChPKxMDhiQuRHsqc+lg==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "@types/estree": "0.0.39",
 | 
			
		||||
        "estree-walker": "^1.0.1",
 | 
			
		||||
        "picomatch": "^2.2.2"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "@svgr/babel-plugin-add-jsx-attribute": {
 | 
			
		||||
      "version": "4.2.0",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@svgr/babel-plugin-add-jsx-attribute/-/babel-plugin-add-jsx-attribute-4.2.0.tgz",
 | 
			
		||||
@@ -1761,6 +1780,11 @@
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@types/eslint-visitor-keys/-/eslint-visitor-keys-1.0.0.tgz",
 | 
			
		||||
      "integrity": "sha512-OCutwjDZ4aFS6PB1UZ988C4YgwlBHJd6wCeQqaLdmadZ/7e+w79+hbMUFC1QXDNCmdyoRfAFdm0RypzwR+Qpag=="
 | 
			
		||||
    },
 | 
			
		||||
    "@types/estree": {
 | 
			
		||||
      "version": "0.0.39",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@types/estree/-/estree-0.0.39.tgz",
 | 
			
		||||
      "integrity": "sha512-EYNwp3bU+98cpU4lAWYYL7Zz+2gryWH1qbdDTidVd6hkiR6weksdbMadyXKXNPEkQFhXM+hVO9ZygomHXp+AIw=="
 | 
			
		||||
    },
 | 
			
		||||
    "@types/glob": {
 | 
			
		||||
      "version": "7.1.3",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/@types/glob/-/glob-7.1.3.tgz",
 | 
			
		||||
@@ -2356,6 +2380,20 @@
 | 
			
		||||
        "normalize-path": "^2.1.1"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "apexcharts": {
 | 
			
		||||
      "version": "3.22.2",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/apexcharts/-/apexcharts-3.22.2.tgz",
 | 
			
		||||
      "integrity": "sha512-pR+cmApk7dhfYILBpe8RVb+FdLfVCt/RDWvAJO1F5feeSQ8lKDgFkRuVu9KOeEarHVXjUpnhLqHNMx7YaprK8A==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "@rollup/plugin-babel": "^5.2.1",
 | 
			
		||||
        "svg.draggable.js": "^2.2.2",
 | 
			
		||||
        "svg.easing.js": "^2.0.0",
 | 
			
		||||
        "svg.filter.js": "^2.0.2",
 | 
			
		||||
        "svg.pathmorphing.js": "^0.1.3",
 | 
			
		||||
        "svg.resize.js": "^1.4.3",
 | 
			
		||||
        "svg.select.js": "^3.0.1"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "aproba": {
 | 
			
		||||
      "version": "1.2.0",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/aproba/-/aproba-1.2.0.tgz",
 | 
			
		||||
@@ -5566,6 +5604,11 @@
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/estraverse/-/estraverse-4.3.0.tgz",
 | 
			
		||||
      "integrity": "sha512-39nnKffWz8xN1BU/2c79n9nB9HDzo0niYUqx6xyqUnyoAnQyyWpOTdZEeiCch8BBu515t4wp9ZmgVfVhn9EBpw=="
 | 
			
		||||
    },
 | 
			
		||||
    "estree-walker": {
 | 
			
		||||
      "version": "1.0.1",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/estree-walker/-/estree-walker-1.0.1.tgz",
 | 
			
		||||
      "integrity": "sha512-1fMXF3YP4pZZVozF8j/ZLfvnR8NSIljt56UhbZ5PeeDmmGHpgpdwQt7ITlGvYaQukCvuBRMLEiKiYC+oeIg4cg=="
 | 
			
		||||
    },
 | 
			
		||||
    "esutils": {
 | 
			
		||||
      "version": "2.0.3",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/esutils/-/esutils-2.0.3.tgz",
 | 
			
		||||
@@ -10799,6 +10842,14 @@
 | 
			
		||||
        "prop-types": "^15.6.2"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "react-apexcharts": {
 | 
			
		||||
      "version": "1.3.7",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/react-apexcharts/-/react-apexcharts-1.3.7.tgz",
 | 
			
		||||
      "integrity": "sha512-2OFhEHd70/WHN0kmrJtVx37UfaL71ZogVkwezmDqwQWgwhK6upuhlnEEX7tEq4xvjA+RFDn6hiUTNIuC/Q7Zqw==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "prop-types": "^15.5.7"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "react-app-polyfill": {
 | 
			
		||||
      "version": "1.0.6",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/react-app-polyfill/-/react-app-polyfill-1.0.6.tgz",
 | 
			
		||||
@@ -13066,6 +13117,70 @@
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg-parser/-/svg-parser-2.0.4.tgz",
 | 
			
		||||
      "integrity": "sha512-e4hG1hRwoOdRb37cIMSgzNsxyzKfayW6VOflrwvR+/bzrkyxY/31WkbgnQpgtrNp1SdpJvpUAGTa/ZoiPNDuRQ=="
 | 
			
		||||
    },
 | 
			
		||||
    "svg.draggable.js": {
 | 
			
		||||
      "version": "2.2.2",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.draggable.js/-/svg.draggable.js-2.2.2.tgz",
 | 
			
		||||
      "integrity": "sha512-JzNHBc2fLQMzYCZ90KZHN2ohXL0BQJGQimK1kGk6AvSeibuKcIdDX9Kr0dT9+UJ5O8nYA0RB839Lhvk4CY4MZw==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": "^2.0.1"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svg.easing.js": {
 | 
			
		||||
      "version": "2.0.0",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.easing.js/-/svg.easing.js-2.0.0.tgz",
 | 
			
		||||
      "integrity": "sha1-iqmUawqOJ4V6XEChDrpAkeVpHxI=",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": ">=2.3.x"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svg.filter.js": {
 | 
			
		||||
      "version": "2.0.2",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.filter.js/-/svg.filter.js-2.0.2.tgz",
 | 
			
		||||
      "integrity": "sha1-kQCOFROJ3ZIwd5/L5uLJo2LRwgM=",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": "^2.2.5"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svg.js": {
 | 
			
		||||
      "version": "2.7.1",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.js/-/svg.js-2.7.1.tgz",
 | 
			
		||||
      "integrity": "sha512-ycbxpizEQktk3FYvn/8BH+6/EuWXg7ZpQREJvgacqn46gIddG24tNNe4Son6omdXCnSOaApnpZw6MPCBA1dODA=="
 | 
			
		||||
    },
 | 
			
		||||
    "svg.pathmorphing.js": {
 | 
			
		||||
      "version": "0.1.3",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.pathmorphing.js/-/svg.pathmorphing.js-0.1.3.tgz",
 | 
			
		||||
      "integrity": "sha512-49HWI9X4XQR/JG1qXkSDV8xViuTLIWm/B/7YuQELV5KMOPtXjiwH4XPJvr/ghEDibmLQ9Oc22dpWpG0vUDDNww==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": "^2.4.0"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svg.resize.js": {
 | 
			
		||||
      "version": "1.4.3",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.resize.js/-/svg.resize.js-1.4.3.tgz",
 | 
			
		||||
      "integrity": "sha512-9k5sXJuPKp+mVzXNvxz7U0uC9oVMQrrf7cFsETznzUDDm0x8+77dtZkWdMfRlmbkEEYvUn9btKuZ3n41oNA+uw==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": "^2.6.5",
 | 
			
		||||
        "svg.select.js": "^2.1.2"
 | 
			
		||||
      },
 | 
			
		||||
      "dependencies": {
 | 
			
		||||
        "svg.select.js": {
 | 
			
		||||
          "version": "2.1.2",
 | 
			
		||||
          "resolved": "https://registry.npmjs.org/svg.select.js/-/svg.select.js-2.1.2.tgz",
 | 
			
		||||
          "integrity": "sha512-tH6ABEyJsAOVAhwcCjF8mw4crjXSI1aa7j2VQR8ZuJ37H2MBUbyeqYr5nEO7sSN3cy9AR9DUwNg0t/962HlDbQ==",
 | 
			
		||||
          "requires": {
 | 
			
		||||
            "svg.js": "^2.2.5"
 | 
			
		||||
          }
 | 
			
		||||
        }
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svg.select.js": {
 | 
			
		||||
      "version": "3.0.1",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svg.select.js/-/svg.select.js-3.0.1.tgz",
 | 
			
		||||
      "integrity": "sha512-h5IS/hKkuVCbKSieR9uQCj9w+zLHoPh+ce19bBYyqF53g6mnPB8sAtIbe1s9dh2S2fCmYX2xel1Ln3PJBbK4kw==",
 | 
			
		||||
      "requires": {
 | 
			
		||||
        "svg.js": "^2.6.5"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "svgo": {
 | 
			
		||||
      "version": "1.3.0",
 | 
			
		||||
      "resolved": "https://registry.npmjs.org/svgo/-/svgo-1.3.0.tgz",
 | 
			
		||||
 
 | 
			
		||||
@@ -7,6 +7,7 @@
 | 
			
		||||
    "@material-ui/icons": "^4.9.1",
 | 
			
		||||
    "@material-ui/lab": "^4.0.0-alpha.56",
 | 
			
		||||
    "@microsoft/signalr": "^5.0.0",
 | 
			
		||||
    "apexcharts": "^3.22.2",
 | 
			
		||||
    "bootstrap": "^4.3.1",
 | 
			
		||||
    "connected-react-router": "6.5.2",
 | 
			
		||||
    "google-map-react": "^2.1.9",
 | 
			
		||||
@@ -17,6 +18,7 @@
 | 
			
		||||
    "merge": "1.2.1",
 | 
			
		||||
    "popper.js": "^1.16.0",
 | 
			
		||||
    "react": "^16.11.0",
 | 
			
		||||
    "react-apexcharts": "^1.3.7",
 | 
			
		||||
    "react-dom": "16.11.0",
 | 
			
		||||
    "react-google-maps": "^9.4.5",
 | 
			
		||||
    "react-redux": "7.1.1",
 | 
			
		||||
 
 | 
			
		||||
@@ -16,6 +16,7 @@ import MapContainer from './components/heatmap/Heatmap';
 | 
			
		||||
import Devices from './components/devices/Devices';
 | 
			
		||||
import { blueGrey, blue, orange, grey } from '@material-ui/core/colors';
 | 
			
		||||
import DevicesContextProvider from './contexts/DevicesContextProvider'
 | 
			
		||||
import Dashboard from './components/dashboard/Dashboard';
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
const theme = createMuiTheme({
 | 
			
		||||
@@ -48,7 +49,7 @@ function App() {
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    const DashboardComponent = () => {
 | 
			
		||||
        return <Link to="/devices/5">This is a link</Link>;
 | 
			
		||||
        return <Dashboard isAdmin={isAdmin}/>;
 | 
			
		||||
    };
 | 
			
		||||
 | 
			
		||||
    const DevicesComponent = () => {
 | 
			
		||||
 
 | 
			
		||||
@@ -1,5 +1,5 @@
 | 
			
		||||
export default {
 | 
			
		||||
    probability_method_name: 'NotifyDeviceAsync',
 | 
			
		||||
    probability_method_name: 'NotifyMessagesAsync',
 | 
			
		||||
    update_method_name: 'NotifyDeviceUpdatedAsync',
 | 
			
		||||
    update_all_method_name: 'NotifyAllUpdatedAsync',
 | 
			
		||||
};
 | 
			
		||||
							
								
								
									
										328
									
								
								Birdmap.API/ClientApp/src/components/dashboard/Dashboard.jsx
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										328
									
								
								Birdmap.API/ClientApp/src/components/dashboard/Dashboard.jsx
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,328 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import Services from './services/Services';
 | 
			
		||||
import { blueGrey } from '@material-ui/core/colors';
 | 
			
		||||
import { Box, Grid, IconButton, Paper, Typography } from '@material-ui/core';
 | 
			
		||||
import DonutChart from './charts/DonutChart';
 | 
			
		||||
import HeatmapChart from './charts/HeatmapChart';
 | 
			
		||||
import BarChart from './charts/BarChart';
 | 
			
		||||
import LineChart from './charts/LineChart';
 | 
			
		||||
import DevicesContext from '../../contexts/DevicesContext';
 | 
			
		||||
import C from '../../common/Constants';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
    root: {
 | 
			
		||||
        flexGrow: 1,
 | 
			
		||||
        padding: '64px',
 | 
			
		||||
        backgroundColor: theme.palette.primary.dark,
 | 
			
		||||
    },
 | 
			
		||||
    typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
    },
 | 
			
		||||
    paper: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        padding: '16px',
 | 
			
		||||
    }
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
class Dashboard extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props);
 | 
			
		||||
 | 
			
		||||
        this.state = {
 | 
			
		||||
            deviceSeries: [],
 | 
			
		||||
            sensorSeries: [],
 | 
			
		||||
            heatmapSecondsSeries: [],
 | 
			
		||||
            heatmapMinutesSeries: [],
 | 
			
		||||
            barSeries: [],
 | 
			
		||||
            barCategories: [],
 | 
			
		||||
            lineSeries: [],
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        this.updateSeries = this.updateSeries.bind(this);
 | 
			
		||||
        this.updateDynamic = this.updateDynamic.bind(this);
 | 
			
		||||
        this.performTask = this.performTask.bind(this);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    static contextType = DevicesContext;
 | 
			
		||||
 | 
			
		||||
    componentDidMount() {
 | 
			
		||||
        this.context.addHandler(C.update_all_method_name, this.updateSeries);
 | 
			
		||||
        this.context.addHandler(C.update_method_name, this.updateSeries);
 | 
			
		||||
        this.updateSeries();
 | 
			
		||||
        this.updateDynamic();
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentWillUnmount() {
 | 
			
		||||
        this.context.removeHandler(C.update_all_method_name, this.updateSeries);
 | 
			
		||||
        this.context.removeHandler(C.update_method_name, this.updateSeries);
 | 
			
		||||
        if (this.updateTimer) {
 | 
			
		||||
            clearTimeout(this.updateTimer);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getItemsWithStatus(iterate, status) {
 | 
			
		||||
        const items = [];
 | 
			
		||||
 | 
			
		||||
        for (var d of iterate) {
 | 
			
		||||
            if (d.status == status) {
 | 
			
		||||
                items.push(d);
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        return items;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getDevicesWithStatus(status) {
 | 
			
		||||
        return this.getItemsWithStatus(this.context.devices, status);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getSensorsWithStatus(status) {
 | 
			
		||||
        const sensors = [];
 | 
			
		||||
 | 
			
		||||
        for (var d of this.context.devices) {
 | 
			
		||||
            sensors.push(...d.sensors)
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        return this.getItemsWithStatus(sensors, status);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getDeviceSeries() {
 | 
			
		||||
        var online = this.getDevicesWithStatus("Online").length;
 | 
			
		||||
        var offline = this.getDevicesWithStatus("Offline").length;
 | 
			
		||||
        var error = this.getDevicesWithStatus("Error").length;
 | 
			
		||||
 | 
			
		||||
        return [online, offline, error]
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getSensorSeries() {
 | 
			
		||||
        var online = this.getSensorsWithStatus("Online").length;
 | 
			
		||||
        var offline = this.getSensorsWithStatus("Offline").length;
 | 
			
		||||
        var unknown = this.getSensorsWithStatus("Unknown").length;
 | 
			
		||||
 | 
			
		||||
        return [online, offline, unknown]
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    updateSeries() {
 | 
			
		||||
        this.setState({
 | 
			
		||||
            deviceSeries: this.getDeviceSeries(),
 | 
			
		||||
            sensorSeries: this.getSensorSeries()
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    updateDynamic = () => {
 | 
			
		||||
        const secondAgo = new Date();
 | 
			
		||||
        secondAgo.setMilliseconds(0);
 | 
			
		||||
        const minuteAgo = new Date(Date.now() - 1000 * 60);
 | 
			
		||||
        const hourAgo = new Date(Date.now() - 1000 * 60 * 60);
 | 
			
		||||
 | 
			
		||||
        const minuteDevicePoints = {};
 | 
			
		||||
        const hourDevicePoints = {};
 | 
			
		||||
        const barDevicePoints = {};
 | 
			
		||||
        const linePoints = {};
 | 
			
		||||
 | 
			
		||||
        for (var d of this.context.devices) {
 | 
			
		||||
            minuteDevicePoints[d.id] = Array(60).fill(0);
 | 
			
		||||
            hourDevicePoints[d.id] = Array(60).fill(0);
 | 
			
		||||
            barDevicePoints[d.id] = Array(3).fill(0);
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        const processHeatmapItem = (items, index) => {
 | 
			
		||||
            const p = items[index];
 | 
			
		||||
            if (p.date > minuteAgo) {
 | 
			
		||||
                var seconds = Math.floor((p.date.getTime() - minuteAgo.getTime()) / 1000);
 | 
			
		||||
                var oldProb = minuteDevicePoints[p.deviceId][seconds];
 | 
			
		||||
                if (oldProb < p.prob) {
 | 
			
		||||
                    minuteDevicePoints[p.deviceId][seconds] = p.prob;
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (p.date > hourAgo) {
 | 
			
		||||
                var minutes = Math.floor((p.date.getTime() - hourAgo.getTime()) / (1000 * 60));
 | 
			
		||||
                var oldProb = hourDevicePoints[p.deviceId][minutes];
 | 
			
		||||
                if (oldProb < p.prob) {
 | 
			
		||||
                    hourDevicePoints[p.deviceId][minutes] = p.prob;
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (p.prob > 0.5 && p.prob <= 0.7) {
 | 
			
		||||
                barDevicePoints[p.deviceId][0] += 1;
 | 
			
		||||
            }
 | 
			
		||||
            if (p.prob > 0.7 && p.prob <= 0.9) {
 | 
			
		||||
                barDevicePoints[p.deviceId][1] += 1;
 | 
			
		||||
            }
 | 
			
		||||
            if (p.prob > 0.9) {
 | 
			
		||||
                barDevicePoints[p.deviceId][2] += 1;
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            if (p.date < secondAgo) {
 | 
			
		||||
                var shortDate = p.date.toUTCString();
 | 
			
		||||
                var point = linePoints[shortDate];
 | 
			
		||||
                if (point === undefined) {
 | 
			
		||||
                    linePoints[shortDate] = 1;
 | 
			
		||||
                } else {
 | 
			
		||||
                    linePoints[shortDate] += 1;
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        const onFinished = () => {
 | 
			
		||||
            const minuteHeatmapSeries = [];
 | 
			
		||||
 | 
			
		||||
            var i = 0;
 | 
			
		||||
            for (var p in minuteDevicePoints) {
 | 
			
		||||
                minuteHeatmapSeries.push({
 | 
			
		||||
                    name: "Device " + i,
 | 
			
		||||
                    data: minuteDevicePoints[p].map((value, index) => ({
 | 
			
		||||
                        x: new Date(Date.now() - (60 - index) * 1000).toLocaleTimeString('hu-HU'),
 | 
			
		||||
                        y: value
 | 
			
		||||
                    })),
 | 
			
		||||
                });
 | 
			
		||||
                i++;
 | 
			
		||||
            };
 | 
			
		||||
 | 
			
		||||
            const hourHeatmapSeries = [];
 | 
			
		||||
 | 
			
		||||
            var i = 0;
 | 
			
		||||
            for (var p in hourDevicePoints) {
 | 
			
		||||
                hourHeatmapSeries.push({
 | 
			
		||||
                    name: "Device " + i,
 | 
			
		||||
                    data: hourDevicePoints[p].map((value, index) => ({
 | 
			
		||||
                        x: new Date(Date.now() - (60 - index) * 1000 * 60).toLocaleTimeString('hu-HU').substring(0, 5),
 | 
			
		||||
                        y: value
 | 
			
		||||
                    })),
 | 
			
		||||
                });
 | 
			
		||||
                i++;
 | 
			
		||||
            };
 | 
			
		||||
 | 
			
		||||
            const barSeries = [];
 | 
			
		||||
 | 
			
		||||
            const getCount = column => {
 | 
			
		||||
                var counts = [];
 | 
			
		||||
 | 
			
		||||
                for (var p in barDevicePoints) {
 | 
			
		||||
                    counts.unshift(barDevicePoints[p][column]);
 | 
			
		||||
                }
 | 
			
		||||
 | 
			
		||||
                return counts;
 | 
			
		||||
            };
 | 
			
		||||
 | 
			
		||||
            barSeries.push({
 | 
			
		||||
                name: "Prob > 0.5",
 | 
			
		||||
                data: getCount(0),
 | 
			
		||||
            });
 | 
			
		||||
            barSeries.push({
 | 
			
		||||
                name: "Prob > 0.7",
 | 
			
		||||
                data: getCount(1),
 | 
			
		||||
            });
 | 
			
		||||
            barSeries.push({
 | 
			
		||||
                name: "Prob > 0.9",
 | 
			
		||||
                data: getCount(2),
 | 
			
		||||
            });
 | 
			
		||||
 | 
			
		||||
            const lineSeries = [{ name: "message/sec", data: [] }];
 | 
			
		||||
            for (var m in linePoints) {
 | 
			
		||||
                lineSeries[0].data.push({
 | 
			
		||||
                    x: new Date(m).getTime(),
 | 
			
		||||
                    y: linePoints[m],
 | 
			
		||||
                })
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            const getBarCategories = () => {
 | 
			
		||||
                const categories = [];
 | 
			
		||||
 | 
			
		||||
                for (var i = this.context.devices.length - 1; i >= 0; i--) {
 | 
			
		||||
                    categories.push("Device " + i)
 | 
			
		||||
                }
 | 
			
		||||
 | 
			
		||||
                return categories;
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            const toUpdate = [
 | 
			
		||||
                { heatmapSecondsSeries: minuteHeatmapSeries },
 | 
			
		||||
                { heatmapMinutesSeries: hourHeatmapSeries },
 | 
			
		||||
                { barSeries: barSeries },
 | 
			
		||||
                { barCategories: getBarCategories() },
 | 
			
		||||
                { lineSeries: lineSeries }
 | 
			
		||||
            ];
 | 
			
		||||
 | 
			
		||||
            //Set states must be done separately otherwise ApexChart's UI update freezes the page.
 | 
			
		||||
            this.performTask(toUpdate, 2, 300, (list, index) => {
 | 
			
		||||
                this.setState(list[index]);
 | 
			
		||||
            },
 | 
			
		||||
            () => {
 | 
			
		||||
                this.updateTimer = setTimeout(this.updateDynamic, 1000);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        this.performTask(this.context.heatmapPoints, Math.ceil(this.context.heatmapPoints.length / 50), 20,
 | 
			
		||||
            processHeatmapItem, onFinished);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    performTask(items, numToProcess, wait, processItem, onFinished) {
 | 
			
		||||
        var pos = 0;
 | 
			
		||||
        // This is run once for every numToProcess items.
 | 
			
		||||
        function iteration() {
 | 
			
		||||
            // Calculate last position.
 | 
			
		||||
            var j = Math.min(pos + numToProcess, items.length);
 | 
			
		||||
            // Start at current position and loop to last position.
 | 
			
		||||
            for (var i = pos; i < j; i++) {
 | 
			
		||||
                processItem(items, i);
 | 
			
		||||
            }
 | 
			
		||||
            // Increment current position.
 | 
			
		||||
            pos += numToProcess;
 | 
			
		||||
            // Only continue if there are more items to process.
 | 
			
		||||
            if (pos < items.length)
 | 
			
		||||
                setTimeout(iteration, wait); // Wait 10 ms to let the UI update.
 | 
			
		||||
            else
 | 
			
		||||
                onFinished();
 | 
			
		||||
        }
 | 
			
		||||
        iteration();
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        const { classes } = this.props;
 | 
			
		||||
        return (
 | 
			
		||||
            <Box className={classes.root}>
 | 
			
		||||
                <Grid container spacing={3}>
 | 
			
		||||
                    <Grid item xs={12}>
 | 
			
		||||
                        <Services isAdmin={this.props.isAdmin} />
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={6}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <DonutChart totalLabel="Devices" series={this.state.deviceSeries} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={6}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <DonutChart totalLabel="Sensors" series={this.state.sensorSeries} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={12}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <HeatmapChart label="Highest probability per second by devices" series={this.state.heatmapSecondsSeries} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={12}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <HeatmapChart label="Highest probability per minute by devices" series={this.state.heatmapMinutesSeries} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={6}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <BarChart label="# of messages by devices" series={this.state.barSeries} categories={this.state.barCategories} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                    <Grid item xs={6}>
 | 
			
		||||
                        <Paper className={classes.paper}>
 | 
			
		||||
                            <LineChart label="# of messages per second" series={this.state.lineSeries} />
 | 
			
		||||
                        </Paper>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </Grid>
 | 
			
		||||
            </Box>
 | 
			
		||||
        );
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default withStyles(styles)(Dashboard);
 | 
			
		||||
@@ -0,0 +1,92 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import Chart from 'react-apexcharts';
 | 
			
		||||
import { blueGrey, green, red, orange, amber } from '@material-ui/core/colors';
 | 
			
		||||
 | 
			
		||||
export class BarChart extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props)
 | 
			
		||||
    
 | 
			
		||||
        this.state = {
 | 
			
		||||
            options: {},
 | 
			
		||||
        };
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentDidUpdate(prevProps) {
 | 
			
		||||
        if (prevProps.categories !== this.props.categories) {
 | 
			
		||||
            this.setState({options: {
 | 
			
		||||
                chart: {
 | 
			
		||||
                  stacked: true,
 | 
			
		||||
                  animations: {
 | 
			
		||||
                      enabled: true,
 | 
			
		||||
                      easing: 'linear',
 | 
			
		||||
                      speed: 250,
 | 
			
		||||
                      animateGradually: {
 | 
			
		||||
                          enabled: false,
 | 
			
		||||
                      },
 | 
			
		||||
                      dynamicAnimation: {
 | 
			
		||||
                          enabled: true,
 | 
			
		||||
                          speed: 250
 | 
			
		||||
                      }
 | 
			
		||||
                  },
 | 
			
		||||
                },
 | 
			
		||||
                plotOptions: {
 | 
			
		||||
                  bar: {
 | 
			
		||||
                    horizontal: true,
 | 
			
		||||
                  },
 | 
			
		||||
                },
 | 
			
		||||
                colors: [blueGrey[500], blueGrey[700], blueGrey[900]],
 | 
			
		||||
                stroke: {
 | 
			
		||||
                  width: 1,
 | 
			
		||||
                  colors: ['#fff']
 | 
			
		||||
                },
 | 
			
		||||
                title: {
 | 
			
		||||
                  text: this.props.label,
 | 
			
		||||
                  style: {
 | 
			
		||||
                    fontSize: '22px',
 | 
			
		||||
                    fontWeight: 600,
 | 
			
		||||
                    fontFamily: 'Helvetica, Arial, sans-serif',
 | 
			
		||||
                  },
 | 
			
		||||
                },
 | 
			
		||||
                xaxis: {
 | 
			
		||||
                  categories: this.props.categories,
 | 
			
		||||
                  labels: {
 | 
			
		||||
                    formatter: function (val) {
 | 
			
		||||
                      return val;
 | 
			
		||||
                    }
 | 
			
		||||
                  }
 | 
			
		||||
                },
 | 
			
		||||
                yaxis: {
 | 
			
		||||
                  title: {
 | 
			
		||||
                    text: undefined
 | 
			
		||||
                  },
 | 
			
		||||
                },
 | 
			
		||||
                tooltip: {
 | 
			
		||||
                  y: {
 | 
			
		||||
                    formatter: function (val) {
 | 
			
		||||
                      return val;
 | 
			
		||||
                    }
 | 
			
		||||
                  }
 | 
			
		||||
                },
 | 
			
		||||
                fill: {
 | 
			
		||||
                  opacity: 1
 | 
			
		||||
                },
 | 
			
		||||
                legend: {
 | 
			
		||||
                    position: 'top',
 | 
			
		||||
                }
 | 
			
		||||
            }});
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        return (
 | 
			
		||||
            <Chart 
 | 
			
		||||
                options={this.state.options} 
 | 
			
		||||
                series={this.props.series} 
 | 
			
		||||
                type="bar" 
 | 
			
		||||
                height={600}
 | 
			
		||||
            />
 | 
			
		||||
        )
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default BarChart;
 | 
			
		||||
@@ -0,0 +1,67 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import Chart from 'react-apexcharts';
 | 
			
		||||
import { blueGrey, green, red } from '@material-ui/core/colors';
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
export class DonutChart extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props);
 | 
			
		||||
 | 
			
		||||
        this.state = {
 | 
			
		||||
            options: {
 | 
			
		||||
                legend: {
 | 
			
		||||
                    fontSize: '18px',
 | 
			
		||||
                },
 | 
			
		||||
                plotOptions: {
 | 
			
		||||
                    pie: {
 | 
			
		||||
                    startAngle: 0,
 | 
			
		||||
                    expandOnClick: false,
 | 
			
		||||
                    offsetX: 0,
 | 
			
		||||
                    offsetY: 0,
 | 
			
		||||
                    customScale: 1,
 | 
			
		||||
                    dataLabels: {
 | 
			
		||||
                        offset: 0,
 | 
			
		||||
                        minAngleToShowLabel: 10
 | 
			
		||||
                    }, 
 | 
			
		||||
                    donut: {
 | 
			
		||||
                        size: '65%',
 | 
			
		||||
                        background: 'transparent',
 | 
			
		||||
                        labels: {
 | 
			
		||||
                            show: true,
 | 
			
		||||
                            total: {
 | 
			
		||||
                                show: true,
 | 
			
		||||
                                showAlways: true,
 | 
			
		||||
                                label: props.totalLabel,
 | 
			
		||||
                                fontSize: '22px',
 | 
			
		||||
                                fontFamily: 'Helvetica, Arial, sans-serif',
 | 
			
		||||
                                fontWeight: 600,
 | 
			
		||||
                                color: '#373d3f',
 | 
			
		||||
                                formatter: function (w) {
 | 
			
		||||
                                    return w.globals.seriesTotals.reduce((a, b) => {
 | 
			
		||||
                                      return a + b
 | 
			
		||||
                                    }, 0)
 | 
			
		||||
                                }
 | 
			
		||||
                            }
 | 
			
		||||
                        }
 | 
			
		||||
                    },      
 | 
			
		||||
                    }
 | 
			
		||||
                },
 | 
			
		||||
                dataLabels: {
 | 
			
		||||
                  enabled: false
 | 
			
		||||
                },
 | 
			
		||||
                colors: [green[500], blueGrey[500], red[500]],
 | 
			
		||||
                labels: ['Online', 'Offline', 'Error / Unknown']},
 | 
			
		||||
          }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        return (
 | 
			
		||||
            <Chart 
 | 
			
		||||
            options={this.state.options} 
 | 
			
		||||
            series={this.props.series} 
 | 
			
		||||
            type="donut"/>
 | 
			
		||||
        )
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default DonutChart;
 | 
			
		||||
@@ -0,0 +1,55 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import Chart from 'react-apexcharts';
 | 
			
		||||
import { blueGrey, green, red } from '@material-ui/core/colors';
 | 
			
		||||
 | 
			
		||||
export class HeatmapChart extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props)
 | 
			
		||||
    
 | 
			
		||||
        this.state = {
 | 
			
		||||
            options: {
 | 
			
		||||
              chart: {
 | 
			
		||||
                animations: {
 | 
			
		||||
                  enabled: true,
 | 
			
		||||
                  easing: 'linear',
 | 
			
		||||
                  speed: 250,
 | 
			
		||||
                  animateGradually: {
 | 
			
		||||
                      enabled: false,
 | 
			
		||||
                      speed: 250,
 | 
			
		||||
                  },
 | 
			
		||||
                  dynamicAnimation: {
 | 
			
		||||
                      enabled: true,
 | 
			
		||||
                      speed: 250
 | 
			
		||||
                  }
 | 
			
		||||
                }
 | 
			
		||||
              },
 | 
			
		||||
              dataLabels: {
 | 
			
		||||
                enabled: false
 | 
			
		||||
              },
 | 
			
		||||
              colors: [blueGrey[900]],
 | 
			
		||||
              title: {
 | 
			
		||||
                text: props.label,
 | 
			
		||||
                style: {
 | 
			
		||||
                  fontSize: '22px',
 | 
			
		||||
                  fontWeight: 600,
 | 
			
		||||
                  fontFamily: 'Helvetica, Arial, sans-serif',
 | 
			
		||||
                },
 | 
			
		||||
              },
 | 
			
		||||
            },
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
    
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        return (
 | 
			
		||||
            <Chart
 | 
			
		||||
                options={this.state.options} 
 | 
			
		||||
                series={this.props.series} 
 | 
			
		||||
                type="heatmap"
 | 
			
		||||
                height={600}
 | 
			
		||||
            />
 | 
			
		||||
        )
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default HeatmapChart
 | 
			
		||||
@@ -0,0 +1,74 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import Chart from 'react-apexcharts';
 | 
			
		||||
import { blueGrey, green, red } from '@material-ui/core/colors';
 | 
			
		||||
 | 
			
		||||
export class LineChart extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props)
 | 
			
		||||
    
 | 
			
		||||
        this.state = {
 | 
			
		||||
            options: {
 | 
			
		||||
                chart: {
 | 
			
		||||
                    animations: {
 | 
			
		||||
                        enabled: true,
 | 
			
		||||
                        easing: 'linear',
 | 
			
		||||
                        speed: 250,
 | 
			
		||||
                        animateGradually: {
 | 
			
		||||
                            enabled: false,
 | 
			
		||||
                        },
 | 
			
		||||
                        dynamicAnimation: {
 | 
			
		||||
                            enabled: true,
 | 
			
		||||
                            speed: 250
 | 
			
		||||
                        }
 | 
			
		||||
                    },
 | 
			
		||||
                    zoom: {
 | 
			
		||||
                        enabled: false
 | 
			
		||||
                    }
 | 
			
		||||
                },
 | 
			
		||||
                colors: [blueGrey[900]],
 | 
			
		||||
                dataLabels: {
 | 
			
		||||
                    enabled: false
 | 
			
		||||
                },
 | 
			
		||||
                stroke: {
 | 
			
		||||
                    curve: 'straight'
 | 
			
		||||
                },
 | 
			
		||||
                title: {
 | 
			
		||||
                    text: this.props.label,
 | 
			
		||||
                    align: 'left',
 | 
			
		||||
                    style: {
 | 
			
		||||
                      fontSize: '22px',
 | 
			
		||||
                      fontWeight: 600,
 | 
			
		||||
                      fontFamily: 'Helvetica, Arial, sans-serif',
 | 
			
		||||
                    },
 | 
			
		||||
                },
 | 
			
		||||
                grid: {
 | 
			
		||||
                    row: {
 | 
			
		||||
                        colors: ['#f3f3f3', 'transparent'], // takes an array which will be repeated on columns
 | 
			
		||||
                        opacity: 0.5
 | 
			
		||||
                    },
 | 
			
		||||
                },
 | 
			
		||||
                xaxis: {
 | 
			
		||||
                    type: 'datetime',
 | 
			
		||||
                    labels: {
 | 
			
		||||
                      formatter: function (val) {
 | 
			
		||||
                        return new Date(val).toLocaleTimeString('hu-HU');
 | 
			
		||||
                      }
 | 
			
		||||
                    }
 | 
			
		||||
                }
 | 
			
		||||
          },
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        return (
 | 
			
		||||
            <Chart 
 | 
			
		||||
                options={this.state.options} 
 | 
			
		||||
                series={this.props.series} 
 | 
			
		||||
                type="line" 
 | 
			
		||||
                height={600}
 | 
			
		||||
            />
 | 
			
		||||
        )
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default LineChart
 | 
			
		||||
@@ -0,0 +1,61 @@
 | 
			
		||||
import { TextField } from '@material-ui/core';
 | 
			
		||||
import Button from '@material-ui/core/Button';
 | 
			
		||||
import Dialog from '@material-ui/core/Dialog';
 | 
			
		||||
import DialogActions from '@material-ui/core/DialogActions';
 | 
			
		||||
import DialogContent from '@material-ui/core/DialogContent';
 | 
			
		||||
import DialogTitle from '@material-ui/core/DialogTitle';
 | 
			
		||||
import React, { useState } from 'react';
 | 
			
		||||
 | 
			
		||||
export default function AddNewDialog(props) {
 | 
			
		||||
    const [name, setName] = useState("");
 | 
			
		||||
    const [url, setUrl] = useState("");
 | 
			
		||||
 | 
			
		||||
    const onNameChange = (event) => {
 | 
			
		||||
        setName(event.target.value);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    const onUrlChange = (event) => {
 | 
			
		||||
        setUrl(event.target.value);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    return (
 | 
			
		||||
        <div>
 | 
			
		||||
            <Dialog
 | 
			
		||||
                open={props.open}
 | 
			
		||||
                onClose={props.handleClose}
 | 
			
		||||
                aria-labelledby="alert-dialog-title"
 | 
			
		||||
                aria-describedby="alert-dialog-description"
 | 
			
		||||
            >
 | 
			
		||||
                <DialogTitle id="alert-dialog-title">{"Add new service."}</DialogTitle>
 | 
			
		||||
                <DialogContent>
 | 
			
		||||
                    <TextField
 | 
			
		||||
                        autoFocus
 | 
			
		||||
                        margin="dense"
 | 
			
		||||
                        id="name"
 | 
			
		||||
                        label="Name"
 | 
			
		||||
                        type="text"
 | 
			
		||||
                        onChange={onNameChange}
 | 
			
		||||
                        fullWidth
 | 
			
		||||
                    />
 | 
			
		||||
                    <TextField
 | 
			
		||||
                        autoFocus
 | 
			
		||||
                        margin="dense"
 | 
			
		||||
                        id="url"
 | 
			
		||||
                        label="Url"
 | 
			
		||||
                        type="text"
 | 
			
		||||
                        onChange={onUrlChange}
 | 
			
		||||
                        fullWidth
 | 
			
		||||
                    />
 | 
			
		||||
                </DialogContent>
 | 
			
		||||
                <DialogActions>
 | 
			
		||||
                    <Button onClick={props.handleClose} color="primary">
 | 
			
		||||
                        Cancel
 | 
			
		||||
                    </Button>
 | 
			
		||||
                    <Button onClick={() => props.handleAdd(name, url)} color="primary" autoFocus>
 | 
			
		||||
                        Add
 | 
			
		||||
                    </Button>
 | 
			
		||||
                </DialogActions>
 | 
			
		||||
            </Dialog>
 | 
			
		||||
        </div>
 | 
			
		||||
    );
 | 
			
		||||
}
 | 
			
		||||
@@ -0,0 +1,35 @@
 | 
			
		||||
import Button from '@material-ui/core/Button';
 | 
			
		||||
import Dialog from '@material-ui/core/Dialog';
 | 
			
		||||
import DialogActions from '@material-ui/core/DialogActions';
 | 
			
		||||
import DialogContent from '@material-ui/core/DialogContent';
 | 
			
		||||
import DialogContentText from '@material-ui/core/DialogContentText';
 | 
			
		||||
import DialogTitle from '@material-ui/core/DialogTitle';
 | 
			
		||||
import React from 'react';
 | 
			
		||||
 | 
			
		||||
export default function DeleteDialog(props) {
 | 
			
		||||
    return (
 | 
			
		||||
        <div>
 | 
			
		||||
            <Dialog
 | 
			
		||||
                open={props.open}
 | 
			
		||||
                onClose={() => props.handleClose(false)}
 | 
			
		||||
                aria-labelledby="alert-dialog-title"
 | 
			
		||||
                aria-describedby="alert-dialog-description"
 | 
			
		||||
            >
 | 
			
		||||
                <DialogTitle id="alert-dialog-title">{"Are you sure?"}</DialogTitle>
 | 
			
		||||
                <DialogContent>
 | 
			
		||||
                    <DialogContentText id="alert-dialog-description">
 | 
			
		||||
                        Deleting is permament.
 | 
			
		||||
                    </DialogContentText>
 | 
			
		||||
                </DialogContent>
 | 
			
		||||
                <DialogActions>
 | 
			
		||||
                    <Button onClick={() => props.handleClose(false)} color="primary">
 | 
			
		||||
                        Cancel
 | 
			
		||||
                    </Button>
 | 
			
		||||
                    <Button onClick={() => props.handleClose(true)} color="primary" autoFocus>
 | 
			
		||||
                        OK
 | 
			
		||||
                    </Button>
 | 
			
		||||
                </DialogActions>
 | 
			
		||||
            </Dialog>
 | 
			
		||||
        </div>
 | 
			
		||||
    );
 | 
			
		||||
}
 | 
			
		||||
@@ -0,0 +1,234 @@
 | 
			
		||||
import { Box, FormControlLabel, Grid, IconButton, Paper, TextField, Typography } from '@material-ui/core';
 | 
			
		||||
import Accordion from '@material-ui/core/Accordion';
 | 
			
		||||
import AccordionDetails from '@material-ui/core/AccordionDetails';
 | 
			
		||||
import AccordionSummary from '@material-ui/core/AccordionSummary';
 | 
			
		||||
import { blueGrey, green, red } from '@material-ui/core/colors';
 | 
			
		||||
import { CancelRounded, CheckCircleRounded, Delete, Edit } from '@material-ui/icons/';
 | 
			
		||||
import ExpandMoreIcon from '@material-ui/icons/ExpandMore';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import DeleteDialog from './DeleteDialog';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
    root: {
 | 
			
		||||
        flexGrow: 1,
 | 
			
		||||
        padding: '64px',
 | 
			
		||||
        backgroundColor: theme.palette.primary.dark,
 | 
			
		||||
    },
 | 
			
		||||
    acc_summary: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        padding: theme.spacing(2),
 | 
			
		||||
        textAlign: 'center',
 | 
			
		||||
        height: '75px',
 | 
			
		||||
    },
 | 
			
		||||
    acc_details: {
 | 
			
		||||
        backgroundColor: blueGrey[100],
 | 
			
		||||
    },
 | 
			
		||||
    grid_typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
    },
 | 
			
		||||
    grid_typo_2: {
 | 
			
		||||
        marginLeft: '5px',
 | 
			
		||||
        fontSize: theme.typography.pxToRem(15),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
        color: theme.palette.text.secondary,
 | 
			
		||||
    },
 | 
			
		||||
    typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
    },
 | 
			
		||||
    icon_box: {
 | 
			
		||||
        marginLeft: '30px',
 | 
			
		||||
    },
 | 
			
		||||
    paper: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        padding: theme.spacing(2),
 | 
			
		||||
        textAlign: 'center',
 | 
			
		||||
        height: '75px',
 | 
			
		||||
    }
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
class ServiceInfoComponent extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props);
 | 
			
		||||
 | 
			
		||||
        this.state = {
 | 
			
		||||
            isDialogOpen: false,
 | 
			
		||||
            isEditing: false,
 | 
			
		||||
            name: "",
 | 
			
		||||
            url: "",
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        this.handleDialogClose = this.handleDialogClose.bind(this);
 | 
			
		||||
        this.onNameChange = this.onNameChange.bind(this);
 | 
			
		||||
        this.onUrlChange = this.onUrlChange.bind(this);
 | 
			
		||||
        this.handleSaveCancel = this.handleSaveCancel.bind(this);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentDidMount() {
 | 
			
		||||
        this.setState({ name: this.props.info.service.name, url: this.props.info.service.uri });
 | 
			
		||||
 | 
			
		||||
        if (this.props.isEditing !== undefined) {
 | 
			
		||||
            this.setState({ isEditing: this.props.isEditing });
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    onNameChange(event) {
 | 
			
		||||
        this.setState({ name: event.target.value });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    onUrlChange(event) {
 | 
			
		||||
        this.setState({ url: event.target.value });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getColor(status) {
 | 
			
		||||
        if (status === "OK")
 | 
			
		||||
            return { color: green[600] };
 | 
			
		||||
        else
 | 
			
		||||
            return { color: red[600] };
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    handleDialogClose(result) {
 | 
			
		||||
        this.setState({ isDialogOpen: false });
 | 
			
		||||
        if (result === true) {
 | 
			
		||||
            this.props.service.delete(this.props.info.service.id);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    handleEditCancel(value) {
 | 
			
		||||
        this.setState({ isEditing: value });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    handleSaveCancel() {
 | 
			
		||||
        let request = {
 | 
			
		||||
            ...this.props.info.service
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        request.name = this.state.name;
 | 
			
		||||
        request.uri = this.state.url;
 | 
			
		||||
 | 
			
		||||
        if (request.id > 0) {
 | 
			
		||||
            this.props.service.put(request).catch(ex => {
 | 
			
		||||
                console.log(ex);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else {
 | 
			
		||||
            this.props.service.post(request).catch(ex => {
 | 
			
		||||
                console.log(ex);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        this.setState({ isEditing: false });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    renderSaveCancel() {
 | 
			
		||||
        return (
 | 
			
		||||
            <Box styles={{ marginLeft: 'auto' }}>
 | 
			
		||||
                <IconButton color="primary" onClick={this.handleSaveCancel}>
 | 
			
		||||
                    <CheckCircleRounded fontSize="large" />
 | 
			
		||||
                </IconButton>
 | 
			
		||||
                <IconButton color="primary" onClick={() => this.setState({ isEditing: false })}>
 | 
			
		||||
                    <CancelRounded fontSize="large" />
 | 
			
		||||
                </IconButton>
 | 
			
		||||
            </Box>
 | 
			
		||||
        );
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    renderButtons() {
 | 
			
		||||
        const renderEditDelete = () => {
 | 
			
		||||
            return (
 | 
			
		||||
                <React.Fragment>
 | 
			
		||||
                    <DeleteDialog open={this.state.isDialogOpen} handleClose={this.handleDialogClose}/>
 | 
			
		||||
                    <IconButton color="primary" onClick={() => this.handleEditCancel(true)}>
 | 
			
		||||
                        <Edit fontSize="large"/>
 | 
			
		||||
                    </IconButton>
 | 
			
		||||
                    <IconButton style={{color: red[600]}} onClick={() => this.setState({ isDialogOpen: true })}>
 | 
			
		||||
                        <Delete fontSize="large"/>
 | 
			
		||||
                    </IconButton>
 | 
			
		||||
                </React.Fragment>
 | 
			
		||||
            );
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        const { classes } = this.props;
 | 
			
		||||
        return (
 | 
			
		||||
            <Box className={classes.icon_box}>
 | 
			
		||||
                {this.props.isAdmin && this.props.info.service.name !== "Mqtt Client Service" ? renderEditDelete() : null}
 | 
			
		||||
            </Box>
 | 
			
		||||
        );
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        const { classes } = this.props;
 | 
			
		||||
 | 
			
		||||
        const renderAccordion = () => {
 | 
			
		||||
            return (
 | 
			
		||||
                <Accordion>
 | 
			
		||||
                    <AccordionSummary className={classes.acc_summary}
 | 
			
		||||
                        expandIcon={<ExpandMoreIcon />}
 | 
			
		||||
                        aria-controls={"device-panel-/" + this.props.info.service.name}
 | 
			
		||||
                        id={"device-panel-/" + this.props.info.service.name}>
 | 
			
		||||
                        <Grid container
 | 
			
		||||
                            spacing={1}
 | 
			
		||||
                            direction="row"
 | 
			
		||||
                            justify="flex-start"
 | 
			
		||||
                            alignItems="center">
 | 
			
		||||
                            <Grid item>
 | 
			
		||||
                                <Typography className={classes.grid_typo}>{this.props.info.service.name}</Typography>
 | 
			
		||||
                            </Grid>
 | 
			
		||||
                            <Grid item>
 | 
			
		||||
                                <Typography className={classes.grid_typo_2}>{this.props.info.service.uri}</Typography>
 | 
			
		||||
                            </Grid>
 | 
			
		||||
                            <Grid item style={{ marginLeft: 'auto' }}>
 | 
			
		||||
                                <Grid container
 | 
			
		||||
                                    spacing={1}
 | 
			
		||||
                                    direction="row"
 | 
			
		||||
                                    justify="flex-start"
 | 
			
		||||
                                    alignItems="center">
 | 
			
		||||
                                    <Grid item>
 | 
			
		||||
                                        <FormControlLabel
 | 
			
		||||
                                            onClick={(event) => event.stopPropagation()}
 | 
			
		||||
                                            onFocus={(event) => event.stopPropagation()}
 | 
			
		||||
                                            control={this.renderButtons()} />
 | 
			
		||||
                                    </Grid>
 | 
			
		||||
                                    <Grid item>
 | 
			
		||||
                                        <Typography style={this.getColor(this.props.info.statusCode)}>Status: <b>{this.props.info.statusCode}</b></Typography>
 | 
			
		||||
                                    </Grid>
 | 
			
		||||
                                </Grid>
 | 
			
		||||
                            </Grid>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                    </AccordionSummary>
 | 
			
		||||
                    <AccordionDetails className={classes.acc_details}>
 | 
			
		||||
                        {this.props.info.response}
 | 
			
		||||
                    </AccordionDetails>
 | 
			
		||||
                </Accordion>
 | 
			
		||||
            );
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        const renderTextFields = () => {
 | 
			
		||||
            return (
 | 
			
		||||
                <Paper className={classes.acc_summary}>
 | 
			
		||||
                    <Grid container
 | 
			
		||||
                        spacing={1}
 | 
			
		||||
                        direction="row"
 | 
			
		||||
                        justify="flex-start"
 | 
			
		||||
                        alignItems="center">
 | 
			
		||||
                        <Grid item xs>
 | 
			
		||||
                            <TextField label="Name" type="text" defaultValue={this.props.info.service.name} onChange={this.onNameChange} />
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item xs={6}>
 | 
			
		||||
                            <TextField label="Url" type="text" fullWidth defaultValue={this.props.info.service.uri} onChange={this.onUrlChange}/>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item xs>
 | 
			
		||||
                            {this.renderSaveCancel()}
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </Paper>
 | 
			
		||||
                );
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.state.isEditing ? renderTextFields() : renderAccordion();
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default withStyles(styles)(ServiceInfoComponent);
 | 
			
		||||
@@ -0,0 +1,386 @@
 | 
			
		||||
"use strict";
 | 
			
		||||
/* tslint:disable */
 | 
			
		||||
/* eslint-disable */
 | 
			
		||||
//----------------------
 | 
			
		||||
// <auto-generated>
 | 
			
		||||
//     Generated using the NSwag toolchain v13.8.2.0 (NJsonSchema v10.2.1.0 (Newtonsoft.Json v12.0.0.0)) (http://NSwag.org)
 | 
			
		||||
// </auto-generated>
 | 
			
		||||
//----------------------
 | 
			
		||||
// ReSharper disable InconsistentNaming
 | 
			
		||||
var __extends = (this && this.__extends) || (function () {
 | 
			
		||||
    var extendStatics = function (d, b) {
 | 
			
		||||
        extendStatics = Object.setPrototypeOf ||
 | 
			
		||||
            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
 | 
			
		||||
            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
 | 
			
		||||
        return extendStatics(d, b);
 | 
			
		||||
    };
 | 
			
		||||
    return function (d, b) {
 | 
			
		||||
        extendStatics(d, b);
 | 
			
		||||
        function __() { this.constructor = d; }
 | 
			
		||||
        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
 | 
			
		||||
    };
 | 
			
		||||
})();
 | 
			
		||||
Object.defineProperty(exports, "__esModule", { value: true });
 | 
			
		||||
exports.ApiException = exports.HttpStatusCode = exports.ServiceRequest = exports.ServiceInfo = void 0;
 | 
			
		||||
var ServiceInfoService = /** @class */ (function () {
 | 
			
		||||
    function ServiceInfoService(baseUrl, http) {
 | 
			
		||||
        this.jsonParseReviver = undefined;
 | 
			
		||||
        this.http = http ? http : window;
 | 
			
		||||
        this.baseUrl = baseUrl !== undefined && baseUrl !== null ? baseUrl : "";
 | 
			
		||||
    }
 | 
			
		||||
    ServiceInfoService.prototype.getCount = function () {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var url_ = this.baseUrl + "/api/Services/count";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
        var options_ = {
 | 
			
		||||
            method: "GET",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
        return this.http.fetch(url_, options_).then(function (_response) {
 | 
			
		||||
            return _this.processGetCount(_response);
 | 
			
		||||
        });
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.processGetCount = function (response) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var status = response.status;
 | 
			
		||||
        var _headers = {};
 | 
			
		||||
        if (response.headers && response.headers.forEach) {
 | 
			
		||||
            response.headers.forEach(function (v, k) { return _headers[k] = v; });
 | 
			
		||||
        }
 | 
			
		||||
        ;
 | 
			
		||||
        if (status === 200) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                var result200 = null;
 | 
			
		||||
                var resultData200 = _responseText === "" ? null : JSON.parse(_responseText, _this.jsonParseReviver);
 | 
			
		||||
                result200 = resultData200 !== undefined ? resultData200 : null;
 | 
			
		||||
                return result200;
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve(null);
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.get = function () {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
        var options_ = {
 | 
			
		||||
            method: "GET",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
        return this.http.fetch(url_, options_).then(function (_response) {
 | 
			
		||||
            return _this.processGet(_response);
 | 
			
		||||
        });
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.processGet = function (response) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var status = response.status;
 | 
			
		||||
        var _headers = {};
 | 
			
		||||
        if (response.headers && response.headers.forEach) {
 | 
			
		||||
            response.headers.forEach(function (v, k) { return _headers[k] = v; });
 | 
			
		||||
        }
 | 
			
		||||
        ;
 | 
			
		||||
        if (status === 200) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                var result200 = null;
 | 
			
		||||
                var resultData200 = _responseText === "" ? null : JSON.parse(_responseText, _this.jsonParseReviver);
 | 
			
		||||
                if (Array.isArray(resultData200)) {
 | 
			
		||||
                    result200 = [];
 | 
			
		||||
                    for (var _i = 0, resultData200_1 = resultData200; _i < resultData200_1.length; _i++) {
 | 
			
		||||
                        var item = resultData200_1[_i];
 | 
			
		||||
                        result200.push(ServiceInfo.fromJS(item));
 | 
			
		||||
                    }
 | 
			
		||||
                }
 | 
			
		||||
                return result200;
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve(null);
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.post = function (request) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
        var content_ = JSON.stringify(request);
 | 
			
		||||
        var options_ = {
 | 
			
		||||
            body: content_,
 | 
			
		||||
            method: "POST",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Content-Type": "application/json",
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
        return this.http.fetch(url_, options_).then(function (_response) {
 | 
			
		||||
            return _this.processPost(_response);
 | 
			
		||||
        });
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.processPost = function (response) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var status = response.status;
 | 
			
		||||
        var _headers = {};
 | 
			
		||||
        if (response.headers && response.headers.forEach) {
 | 
			
		||||
            response.headers.forEach(function (v, k) { return _headers[k] = v; });
 | 
			
		||||
        }
 | 
			
		||||
        ;
 | 
			
		||||
        if (status === 201) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                var result201 = null;
 | 
			
		||||
                var resultData201 = _responseText === "" ? null : JSON.parse(_responseText, _this.jsonParseReviver);
 | 
			
		||||
                result201 = ServiceRequest.fromJS(resultData201);
 | 
			
		||||
                return result201;
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve(null);
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.put = function (request) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
        var content_ = JSON.stringify(request);
 | 
			
		||||
        var options_ = {
 | 
			
		||||
            body: content_,
 | 
			
		||||
            method: "PUT",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Content-Type": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
        return this.http.fetch(url_, options_).then(function (_response) {
 | 
			
		||||
            return _this.processPut(_response);
 | 
			
		||||
        });
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.processPut = function (response) {
 | 
			
		||||
        var status = response.status;
 | 
			
		||||
        var _headers = {};
 | 
			
		||||
        if (response.headers && response.headers.forEach) {
 | 
			
		||||
            response.headers.forEach(function (v, k) { return _headers[k] = v; });
 | 
			
		||||
        }
 | 
			
		||||
        ;
 | 
			
		||||
        if (status === 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return;
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve(null);
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.delete = function (id) {
 | 
			
		||||
        var _this = this;
 | 
			
		||||
        var url_ = this.baseUrl + "/api/Services/{id}";
 | 
			
		||||
        if (id === undefined || id === null)
 | 
			
		||||
            throw new Error("The parameter 'id' must be defined.");
 | 
			
		||||
        url_ = url_.replace("{id}", encodeURIComponent("" + id));
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
        var options_ = {
 | 
			
		||||
            method: "DELETE",
 | 
			
		||||
            headers: {
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
        return this.http.fetch(url_, options_).then(function (_response) {
 | 
			
		||||
            return _this.processDelete(_response);
 | 
			
		||||
        });
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfoService.prototype.processDelete = function (response) {
 | 
			
		||||
        var status = response.status;
 | 
			
		||||
        var _headers = {};
 | 
			
		||||
        if (response.headers && response.headers.forEach) {
 | 
			
		||||
            response.headers.forEach(function (v, k) { return _headers[k] = v; });
 | 
			
		||||
        }
 | 
			
		||||
        ;
 | 
			
		||||
        if (status === 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return;
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then(function (_responseText) {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve(null);
 | 
			
		||||
    };
 | 
			
		||||
    return ServiceInfoService;
 | 
			
		||||
}());
 | 
			
		||||
exports.default = ServiceInfoService;
 | 
			
		||||
var ServiceInfo = /** @class */ (function () {
 | 
			
		||||
    function ServiceInfo(data) {
 | 
			
		||||
        if (data) {
 | 
			
		||||
            for (var property in data) {
 | 
			
		||||
                if (data.hasOwnProperty(property))
 | 
			
		||||
                    this[property] = data[property];
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
    ServiceInfo.prototype.init = function (_data) {
 | 
			
		||||
        if (_data) {
 | 
			
		||||
            this.service = _data["service"] ? ServiceRequest.fromJS(_data["service"]) : undefined;
 | 
			
		||||
            this.statusCode = _data["statusCode"];
 | 
			
		||||
            this.response = _data["response"];
 | 
			
		||||
        }
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfo.fromJS = function (data) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        var result = new ServiceInfo();
 | 
			
		||||
        result.init(data);
 | 
			
		||||
        return result;
 | 
			
		||||
    };
 | 
			
		||||
    ServiceInfo.prototype.toJSON = function (data) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        data["service"] = this.service ? this.service.toJSON() : undefined;
 | 
			
		||||
        data["statusCode"] = this.statusCode;
 | 
			
		||||
        data["response"] = this.response;
 | 
			
		||||
        return data;
 | 
			
		||||
    };
 | 
			
		||||
    return ServiceInfo;
 | 
			
		||||
}());
 | 
			
		||||
exports.ServiceInfo = ServiceInfo;
 | 
			
		||||
var ServiceRequest = /** @class */ (function () {
 | 
			
		||||
    function ServiceRequest(data) {
 | 
			
		||||
        if (data) {
 | 
			
		||||
            for (var property in data) {
 | 
			
		||||
                if (data.hasOwnProperty(property))
 | 
			
		||||
                    this[property] = data[property];
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
    ServiceRequest.prototype.init = function (_data) {
 | 
			
		||||
        if (_data) {
 | 
			
		||||
            this.id = _data["id"];
 | 
			
		||||
            this.name = _data["name"];
 | 
			
		||||
            this.uri = _data["uri"];
 | 
			
		||||
        }
 | 
			
		||||
    };
 | 
			
		||||
    ServiceRequest.fromJS = function (data) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        var result = new ServiceRequest();
 | 
			
		||||
        result.init(data);
 | 
			
		||||
        return result;
 | 
			
		||||
    };
 | 
			
		||||
    ServiceRequest.prototype.toJSON = function (data) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        data["id"] = this.id;
 | 
			
		||||
        data["name"] = this.name;
 | 
			
		||||
        data["uri"] = this.uri;
 | 
			
		||||
        return data;
 | 
			
		||||
    };
 | 
			
		||||
    return ServiceRequest;
 | 
			
		||||
}());
 | 
			
		||||
exports.ServiceRequest = ServiceRequest;
 | 
			
		||||
var HttpStatusCode;
 | 
			
		||||
(function (HttpStatusCode) {
 | 
			
		||||
    HttpStatusCode["Continue"] = "Continue";
 | 
			
		||||
    HttpStatusCode["SwitchingProtocols"] = "SwitchingProtocols";
 | 
			
		||||
    HttpStatusCode["Processing"] = "Processing";
 | 
			
		||||
    HttpStatusCode["EarlyHints"] = "EarlyHints";
 | 
			
		||||
    HttpStatusCode["OK"] = "OK";
 | 
			
		||||
    HttpStatusCode["Created"] = "Created";
 | 
			
		||||
    HttpStatusCode["Accepted"] = "Accepted";
 | 
			
		||||
    HttpStatusCode["NonAuthoritativeInformation"] = "NonAuthoritativeInformation";
 | 
			
		||||
    HttpStatusCode["NoContent"] = "NoContent";
 | 
			
		||||
    HttpStatusCode["ResetContent"] = "ResetContent";
 | 
			
		||||
    HttpStatusCode["PartialContent"] = "PartialContent";
 | 
			
		||||
    HttpStatusCode["MultiStatus"] = "MultiStatus";
 | 
			
		||||
    HttpStatusCode["AlreadyReported"] = "AlreadyReported";
 | 
			
		||||
    HttpStatusCode["IMUsed"] = "IMUsed";
 | 
			
		||||
    HttpStatusCode["MultipleChoices"] = "Ambiguous";
 | 
			
		||||
    HttpStatusCode["Ambiguous"] = "Ambiguous";
 | 
			
		||||
    HttpStatusCode["MovedPermanently"] = "Moved";
 | 
			
		||||
    HttpStatusCode["Moved"] = "Moved";
 | 
			
		||||
    HttpStatusCode["Found"] = "Redirect";
 | 
			
		||||
    HttpStatusCode["Redirect"] = "Redirect";
 | 
			
		||||
    HttpStatusCode["SeeOther"] = "RedirectMethod";
 | 
			
		||||
    HttpStatusCode["RedirectMethod"] = "RedirectMethod";
 | 
			
		||||
    HttpStatusCode["NotModified"] = "NotModified";
 | 
			
		||||
    HttpStatusCode["UseProxy"] = "UseProxy";
 | 
			
		||||
    HttpStatusCode["Unused"] = "Unused";
 | 
			
		||||
    HttpStatusCode["TemporaryRedirect"] = "TemporaryRedirect";
 | 
			
		||||
    HttpStatusCode["RedirectKeepVerb"] = "TemporaryRedirect";
 | 
			
		||||
    HttpStatusCode["PermanentRedirect"] = "PermanentRedirect";
 | 
			
		||||
    HttpStatusCode["BadRequest"] = "BadRequest";
 | 
			
		||||
    HttpStatusCode["Unauthorized"] = "Unauthorized";
 | 
			
		||||
    HttpStatusCode["PaymentRequired"] = "PaymentRequired";
 | 
			
		||||
    HttpStatusCode["Forbidden"] = "Forbidden";
 | 
			
		||||
    HttpStatusCode["NotFound"] = "NotFound";
 | 
			
		||||
    HttpStatusCode["MethodNotAllowed"] = "MethodNotAllowed";
 | 
			
		||||
    HttpStatusCode["NotAcceptable"] = "NotAcceptable";
 | 
			
		||||
    HttpStatusCode["ProxyAuthenticationRequired"] = "ProxyAuthenticationRequired";
 | 
			
		||||
    HttpStatusCode["RequestTimeout"] = "RequestTimeout";
 | 
			
		||||
    HttpStatusCode["Conflict"] = "Conflict";
 | 
			
		||||
    HttpStatusCode["Gone"] = "Gone";
 | 
			
		||||
    HttpStatusCode["LengthRequired"] = "LengthRequired";
 | 
			
		||||
    HttpStatusCode["PreconditionFailed"] = "PreconditionFailed";
 | 
			
		||||
    HttpStatusCode["RequestEntityTooLarge"] = "RequestEntityTooLarge";
 | 
			
		||||
    HttpStatusCode["RequestUriTooLong"] = "RequestUriTooLong";
 | 
			
		||||
    HttpStatusCode["UnsupportedMediaType"] = "UnsupportedMediaType";
 | 
			
		||||
    HttpStatusCode["RequestedRangeNotSatisfiable"] = "RequestedRangeNotSatisfiable";
 | 
			
		||||
    HttpStatusCode["ExpectationFailed"] = "ExpectationFailed";
 | 
			
		||||
    HttpStatusCode["MisdirectedRequest"] = "MisdirectedRequest";
 | 
			
		||||
    HttpStatusCode["UnprocessableEntity"] = "UnprocessableEntity";
 | 
			
		||||
    HttpStatusCode["Locked"] = "Locked";
 | 
			
		||||
    HttpStatusCode["FailedDependency"] = "FailedDependency";
 | 
			
		||||
    HttpStatusCode["UpgradeRequired"] = "UpgradeRequired";
 | 
			
		||||
    HttpStatusCode["PreconditionRequired"] = "PreconditionRequired";
 | 
			
		||||
    HttpStatusCode["TooManyRequests"] = "TooManyRequests";
 | 
			
		||||
    HttpStatusCode["RequestHeaderFieldsTooLarge"] = "RequestHeaderFieldsTooLarge";
 | 
			
		||||
    HttpStatusCode["UnavailableForLegalReasons"] = "UnavailableForLegalReasons";
 | 
			
		||||
    HttpStatusCode["InternalServerError"] = "InternalServerError";
 | 
			
		||||
    HttpStatusCode["NotImplemented"] = "NotImplemented";
 | 
			
		||||
    HttpStatusCode["BadGateway"] = "BadGateway";
 | 
			
		||||
    HttpStatusCode["ServiceUnavailable"] = "ServiceUnavailable";
 | 
			
		||||
    HttpStatusCode["GatewayTimeout"] = "GatewayTimeout";
 | 
			
		||||
    HttpStatusCode["HttpVersionNotSupported"] = "HttpVersionNotSupported";
 | 
			
		||||
    HttpStatusCode["VariantAlsoNegotiates"] = "VariantAlsoNegotiates";
 | 
			
		||||
    HttpStatusCode["InsufficientStorage"] = "InsufficientStorage";
 | 
			
		||||
    HttpStatusCode["LoopDetected"] = "LoopDetected";
 | 
			
		||||
    HttpStatusCode["NotExtended"] = "NotExtended";
 | 
			
		||||
    HttpStatusCode["NetworkAuthenticationRequired"] = "NetworkAuthenticationRequired";
 | 
			
		||||
})(HttpStatusCode = exports.HttpStatusCode || (exports.HttpStatusCode = {}));
 | 
			
		||||
var ApiException = /** @class */ (function (_super) {
 | 
			
		||||
    __extends(ApiException, _super);
 | 
			
		||||
    function ApiException(message, status, response, headers, result) {
 | 
			
		||||
        var _this = _super.call(this) || this;
 | 
			
		||||
        _this.isApiException = true;
 | 
			
		||||
        _this.message = message;
 | 
			
		||||
        _this.status = status;
 | 
			
		||||
        _this.response = response;
 | 
			
		||||
        _this.headers = headers;
 | 
			
		||||
        _this.result = result;
 | 
			
		||||
        return _this;
 | 
			
		||||
    }
 | 
			
		||||
    ApiException.isApiException = function (obj) {
 | 
			
		||||
        return obj.isApiException === true;
 | 
			
		||||
    };
 | 
			
		||||
    return ApiException;
 | 
			
		||||
}(Error));
 | 
			
		||||
exports.ApiException = ApiException;
 | 
			
		||||
function throwException(message, status, response, headers, result) {
 | 
			
		||||
    if (result !== null && result !== undefined)
 | 
			
		||||
        throw result;
 | 
			
		||||
    else
 | 
			
		||||
        throw new ApiException(message, status, response, headers, null);
 | 
			
		||||
}
 | 
			
		||||
//# sourceMappingURL=SystemInfoService.js.map
 | 
			
		||||
										
											
												File diff suppressed because one or more lines are too long
											
										
									
								
							@@ -0,0 +1,389 @@
 | 
			
		||||
/* tslint:disable */
 | 
			
		||||
/* eslint-disable */
 | 
			
		||||
//----------------------
 | 
			
		||||
// <auto-generated>
 | 
			
		||||
//     Generated using the NSwag toolchain v13.8.2.0 (NJsonSchema v10.2.1.0 (Newtonsoft.Json v12.0.0.0)) (http://NSwag.org)
 | 
			
		||||
// </auto-generated>
 | 
			
		||||
//----------------------
 | 
			
		||||
// ReSharper disable InconsistentNaming
 | 
			
		||||
 | 
			
		||||
export default class ServiceInfoService {
 | 
			
		||||
    private http: { fetch(url: RequestInfo, init?: RequestInit): Promise<Response> };
 | 
			
		||||
    private baseUrl: string;
 | 
			
		||||
    protected jsonParseReviver: ((key: string, value: any) => any) | undefined = undefined;
 | 
			
		||||
 | 
			
		||||
    constructor(baseUrl?: string, http?: { fetch(url: RequestInfo, init?: RequestInit): Promise<Response> }) {
 | 
			
		||||
        this.http = http ? http : <any>window;
 | 
			
		||||
        this.baseUrl = baseUrl !== undefined && baseUrl !== null ? baseUrl : "";
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    getCount(): Promise<number> {
 | 
			
		||||
        let url_ = this.baseUrl + "/api/Services/count";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
 | 
			
		||||
        let options_ = <RequestInit>{
 | 
			
		||||
            method: "GET",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.http.fetch(url_, options_).then((_response: Response) => {
 | 
			
		||||
            return this.processGetCount(_response);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected processGetCount(response: Response): Promise<number> {
 | 
			
		||||
        const status = response.status;
 | 
			
		||||
        let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
 | 
			
		||||
        if (status === 200) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
                let result200: any = null;
 | 
			
		||||
                let resultData200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver);
 | 
			
		||||
                result200 = resultData200 !== undefined ? resultData200 : <any>null;
 | 
			
		||||
                return result200;
 | 
			
		||||
            });
 | 
			
		||||
        } else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
                return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve<number>(<any>null);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    get(): Promise<ServiceInfo[]> {
 | 
			
		||||
        let url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
 | 
			
		||||
        let options_ = <RequestInit>{
 | 
			
		||||
            method: "GET",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.http.fetch(url_, options_).then((_response: Response) => {
 | 
			
		||||
            return this.processGet(_response);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected processGet(response: Response): Promise<ServiceInfo[]> {
 | 
			
		||||
        const status = response.status;
 | 
			
		||||
        let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
 | 
			
		||||
        if (status === 200) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            let result200: any = null;
 | 
			
		||||
            let resultData200 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver);
 | 
			
		||||
            if (Array.isArray(resultData200)) {
 | 
			
		||||
                result200 = [] as any;
 | 
			
		||||
                for (let item of resultData200)
 | 
			
		||||
                    result200!.push(ServiceInfo.fromJS(item));
 | 
			
		||||
            }
 | 
			
		||||
            return result200;
 | 
			
		||||
            });
 | 
			
		||||
        } else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve<ServiceInfo[]>(<any>null);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    post(request: ServiceRequest): Promise<ServiceRequest> {
 | 
			
		||||
        let url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
 | 
			
		||||
        const content_ = JSON.stringify(request);
 | 
			
		||||
 | 
			
		||||
        let options_ = <RequestInit>{
 | 
			
		||||
            body: content_,
 | 
			
		||||
            method: "POST",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Content-Type": "application/json",
 | 
			
		||||
                "Accept": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.http.fetch(url_, options_).then((_response: Response) => {
 | 
			
		||||
            return this.processPost(_response);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected processPost(response: Response): Promise<ServiceRequest> {
 | 
			
		||||
        const status = response.status;
 | 
			
		||||
        let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
 | 
			
		||||
        if (status === 201) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            let result201: any = null;
 | 
			
		||||
            let resultData201 = _responseText === "" ? null : JSON.parse(_responseText, this.jsonParseReviver);
 | 
			
		||||
            result201 = ServiceRequest.fromJS(resultData201);
 | 
			
		||||
            return result201;
 | 
			
		||||
            });
 | 
			
		||||
        } else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve<ServiceRequest>(<any>null);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    put(request: ServiceRequest): Promise<void> {
 | 
			
		||||
        let url_ = this.baseUrl + "/api/Services";
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
 | 
			
		||||
        const content_ = JSON.stringify(request);
 | 
			
		||||
 | 
			
		||||
        let options_ = <RequestInit>{
 | 
			
		||||
            body: content_,
 | 
			
		||||
            method: "PUT",
 | 
			
		||||
            headers: {
 | 
			
		||||
                "Content-Type": "application/json",
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.http.fetch(url_, options_).then((_response: Response) => {
 | 
			
		||||
            return this.processPut(_response);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected processPut(response: Response): Promise<void> {
 | 
			
		||||
        const status = response.status;
 | 
			
		||||
        let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
 | 
			
		||||
        if (status === 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return;
 | 
			
		||||
            });
 | 
			
		||||
        } else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve<void>(<any>null);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    delete(id: number): Promise<void> {
 | 
			
		||||
        let url_ = this.baseUrl + "/api/Services/{id}";
 | 
			
		||||
        if (id === undefined || id === null)
 | 
			
		||||
            throw new Error("The parameter 'id' must be defined.");
 | 
			
		||||
        url_ = url_.replace("{id}", encodeURIComponent("" + id));
 | 
			
		||||
        url_ = url_.replace(/[?&]$/, "");
 | 
			
		||||
 | 
			
		||||
        let options_ = <RequestInit>{
 | 
			
		||||
            method: "DELETE",
 | 
			
		||||
            headers: {
 | 
			
		||||
                'Authorization': sessionStorage.getItem('user')
 | 
			
		||||
            }
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        return this.http.fetch(url_, options_).then((_response: Response) => {
 | 
			
		||||
            return this.processDelete(_response);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected processDelete(response: Response): Promise<void> {
 | 
			
		||||
        const status = response.status;
 | 
			
		||||
        let _headers: any = {}; if (response.headers && response.headers.forEach) { response.headers.forEach((v: any, k: any) => _headers[k] = v); };
 | 
			
		||||
        if (status === 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return;
 | 
			
		||||
            });
 | 
			
		||||
        } else if (status !== 200 && status !== 204) {
 | 
			
		||||
            return response.text().then((_responseText) => {
 | 
			
		||||
            return throwException("An unexpected server error occurred.", status, _responseText, _headers);
 | 
			
		||||
            });
 | 
			
		||||
        }
 | 
			
		||||
        return Promise.resolve<void>(<any>null);
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export class ServiceInfo implements IServiceInfo {
 | 
			
		||||
    service?: ServiceRequest | undefined;
 | 
			
		||||
    statusCode!: HttpStatusCode;
 | 
			
		||||
    response?: string | undefined;
 | 
			
		||||
 | 
			
		||||
    constructor(data?: IServiceInfo) {
 | 
			
		||||
        if (data) {
 | 
			
		||||
            for (var property in data) {
 | 
			
		||||
                if (data.hasOwnProperty(property))
 | 
			
		||||
                    (<any>this)[property] = (<any>data)[property];
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    init(_data?: any) {
 | 
			
		||||
        if (_data) {
 | 
			
		||||
            this.service = _data["service"] ? ServiceRequest.fromJS(_data["service"]) : <any>undefined;
 | 
			
		||||
            this.statusCode = _data["statusCode"];
 | 
			
		||||
            this.response = _data["response"];
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    static fromJS(data: any): ServiceInfo {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        let result = new ServiceInfo();
 | 
			
		||||
        result.init(data);
 | 
			
		||||
        return result;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    toJSON(data?: any) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        data["service"] = this.service ? this.service.toJSON() : <any>undefined;
 | 
			
		||||
        data["statusCode"] = this.statusCode;
 | 
			
		||||
        data["response"] = this.response;
 | 
			
		||||
        return data;
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export interface IServiceInfo {
 | 
			
		||||
    service?: ServiceRequest | undefined;
 | 
			
		||||
    statusCode: HttpStatusCode;
 | 
			
		||||
    response?: string | undefined;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export class ServiceRequest implements IServiceRequest {
 | 
			
		||||
    id!: number;
 | 
			
		||||
    name?: string | undefined;
 | 
			
		||||
    uri?: string | undefined;
 | 
			
		||||
 | 
			
		||||
    constructor(data?: IServiceRequest) {
 | 
			
		||||
        if (data) {
 | 
			
		||||
            for (var property in data) {
 | 
			
		||||
                if (data.hasOwnProperty(property))
 | 
			
		||||
                    (<any>this)[property] = (<any>data)[property];
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    init(_data?: any) {
 | 
			
		||||
        if (_data) {
 | 
			
		||||
            this.id = _data["id"];
 | 
			
		||||
            this.name = _data["name"];
 | 
			
		||||
            this.uri = _data["uri"];
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    static fromJS(data: any): ServiceRequest {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        let result = new ServiceRequest();
 | 
			
		||||
        result.init(data);
 | 
			
		||||
        return result;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    toJSON(data?: any) {
 | 
			
		||||
        data = typeof data === 'object' ? data : {};
 | 
			
		||||
        data["id"] = this.id;
 | 
			
		||||
        data["name"] = this.name;
 | 
			
		||||
        data["uri"] = this.uri;
 | 
			
		||||
        return data;
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export interface IServiceRequest {
 | 
			
		||||
    id: number;
 | 
			
		||||
    name?: string | undefined;
 | 
			
		||||
    uri?: string | undefined;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export enum HttpStatusCode {
 | 
			
		||||
    Continue = "Continue",
 | 
			
		||||
    SwitchingProtocols = "SwitchingProtocols",
 | 
			
		||||
    Processing = "Processing",
 | 
			
		||||
    EarlyHints = "EarlyHints",
 | 
			
		||||
    OK = "OK",
 | 
			
		||||
    Created = "Created",
 | 
			
		||||
    Accepted = "Accepted",
 | 
			
		||||
    NonAuthoritativeInformation = "NonAuthoritativeInformation",
 | 
			
		||||
    NoContent = "NoContent",
 | 
			
		||||
    ResetContent = "ResetContent",
 | 
			
		||||
    PartialContent = "PartialContent",
 | 
			
		||||
    MultiStatus = "MultiStatus",
 | 
			
		||||
    AlreadyReported = "AlreadyReported",
 | 
			
		||||
    IMUsed = "IMUsed",
 | 
			
		||||
    MultipleChoices = "Ambiguous",
 | 
			
		||||
    Ambiguous = "Ambiguous",
 | 
			
		||||
    MovedPermanently = "Moved",
 | 
			
		||||
    Moved = "Moved",
 | 
			
		||||
    Found = "Redirect",
 | 
			
		||||
    Redirect = "Redirect",
 | 
			
		||||
    SeeOther = "RedirectMethod",
 | 
			
		||||
    RedirectMethod = "RedirectMethod",
 | 
			
		||||
    NotModified = "NotModified",
 | 
			
		||||
    UseProxy = "UseProxy",
 | 
			
		||||
    Unused = "Unused",
 | 
			
		||||
    TemporaryRedirect = "TemporaryRedirect",
 | 
			
		||||
    RedirectKeepVerb = "TemporaryRedirect",
 | 
			
		||||
    PermanentRedirect = "PermanentRedirect",
 | 
			
		||||
    BadRequest = "BadRequest",
 | 
			
		||||
    Unauthorized = "Unauthorized",
 | 
			
		||||
    PaymentRequired = "PaymentRequired",
 | 
			
		||||
    Forbidden = "Forbidden",
 | 
			
		||||
    NotFound = "NotFound",
 | 
			
		||||
    MethodNotAllowed = "MethodNotAllowed",
 | 
			
		||||
    NotAcceptable = "NotAcceptable",
 | 
			
		||||
    ProxyAuthenticationRequired = "ProxyAuthenticationRequired",
 | 
			
		||||
    RequestTimeout = "RequestTimeout",
 | 
			
		||||
    Conflict = "Conflict",
 | 
			
		||||
    Gone = "Gone",
 | 
			
		||||
    LengthRequired = "LengthRequired",
 | 
			
		||||
    PreconditionFailed = "PreconditionFailed",
 | 
			
		||||
    RequestEntityTooLarge = "RequestEntityTooLarge",
 | 
			
		||||
    RequestUriTooLong = "RequestUriTooLong",
 | 
			
		||||
    UnsupportedMediaType = "UnsupportedMediaType",
 | 
			
		||||
    RequestedRangeNotSatisfiable = "RequestedRangeNotSatisfiable",
 | 
			
		||||
    ExpectationFailed = "ExpectationFailed",
 | 
			
		||||
    MisdirectedRequest = "MisdirectedRequest",
 | 
			
		||||
    UnprocessableEntity = "UnprocessableEntity",
 | 
			
		||||
    Locked = "Locked",
 | 
			
		||||
    FailedDependency = "FailedDependency",
 | 
			
		||||
    UpgradeRequired = "UpgradeRequired",
 | 
			
		||||
    PreconditionRequired = "PreconditionRequired",
 | 
			
		||||
    TooManyRequests = "TooManyRequests",
 | 
			
		||||
    RequestHeaderFieldsTooLarge = "RequestHeaderFieldsTooLarge",
 | 
			
		||||
    UnavailableForLegalReasons = "UnavailableForLegalReasons",
 | 
			
		||||
    InternalServerError = "InternalServerError",
 | 
			
		||||
    NotImplemented = "NotImplemented",
 | 
			
		||||
    BadGateway = "BadGateway",
 | 
			
		||||
    ServiceUnavailable = "ServiceUnavailable",
 | 
			
		||||
    GatewayTimeout = "GatewayTimeout",
 | 
			
		||||
    HttpVersionNotSupported = "HttpVersionNotSupported",
 | 
			
		||||
    VariantAlsoNegotiates = "VariantAlsoNegotiates",
 | 
			
		||||
    InsufficientStorage = "InsufficientStorage",
 | 
			
		||||
    LoopDetected = "LoopDetected",
 | 
			
		||||
    NotExtended = "NotExtended",
 | 
			
		||||
    NetworkAuthenticationRequired = "NetworkAuthenticationRequired",
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export class ApiException extends Error {
 | 
			
		||||
    message: string;
 | 
			
		||||
    status: number;
 | 
			
		||||
    response: string;
 | 
			
		||||
    headers: { [key: string]: any; };
 | 
			
		||||
    result: any;
 | 
			
		||||
 | 
			
		||||
    constructor(message: string, status: number, response: string, headers: { [key: string]: any; }, result: any) {
 | 
			
		||||
        super();
 | 
			
		||||
 | 
			
		||||
        this.message = message;
 | 
			
		||||
        this.status = status;
 | 
			
		||||
        this.response = response;
 | 
			
		||||
        this.headers = headers;
 | 
			
		||||
        this.result = result;
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    protected isApiException = true;
 | 
			
		||||
 | 
			
		||||
    static isApiException(obj: any): obj is ApiException {
 | 
			
		||||
        return obj.isApiException === true;
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
function throwException(message: string, status: number, response: string, headers: { [key: string]: any; }, result?: any): any {
 | 
			
		||||
    if (result !== null && result !== undefined)
 | 
			
		||||
        throw result;
 | 
			
		||||
    else
 | 
			
		||||
        throw new ApiException(message, status, response, headers, null);
 | 
			
		||||
}
 | 
			
		||||
@@ -0,0 +1,88 @@
 | 
			
		||||
import { Grid, Typography } from '@material-ui/core';
 | 
			
		||||
import Accordion from '@material-ui/core/Accordion';
 | 
			
		||||
import AccordionDetails from '@material-ui/core/AccordionDetails';
 | 
			
		||||
import AccordionSummary from '@material-ui/core/AccordionSummary';
 | 
			
		||||
import { blueGrey } from '@material-ui/core/colors';
 | 
			
		||||
import ExpandMoreIcon from '@material-ui/icons/ExpandMore';
 | 
			
		||||
import { Skeleton } from '@material-ui/lab';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
    acc_summary: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        padding: theme.spacing(2),
 | 
			
		||||
        textAlign: 'center',
 | 
			
		||||
        height: '75px',
 | 
			
		||||
    },
 | 
			
		||||
    acc_details: {
 | 
			
		||||
        backgroundColor: blueGrey[100],
 | 
			
		||||
    },
 | 
			
		||||
    grid_typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
    },
 | 
			
		||||
    grid_typo_2: {
 | 
			
		||||
        marginLeft: '5px',
 | 
			
		||||
        fontSize: theme.typography.pxToRem(15),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
        color: theme.palette.text.secondary,
 | 
			
		||||
    },
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
class ServiceInfoSkeleton extends Component {
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        const { classes } = this.props;
 | 
			
		||||
 | 
			
		||||
        return (
 | 
			
		||||
            <Accordion>
 | 
			
		||||
                <AccordionSummary className={classes.acc_summary}
 | 
			
		||||
                    expandIcon={<ExpandMoreIcon />}>
 | 
			
		||||
                    <Grid container
 | 
			
		||||
                        spacing={1}
 | 
			
		||||
                        direction="row"
 | 
			
		||||
                        justify="flex-start"
 | 
			
		||||
                        alignItems="center">
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography className={classes.grid_typo}><Skeleton width={200} /></Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography className={classes.grid_typo_2}><Skeleton width={300} /></Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item style={{ marginLeft: 'auto' }}>
 | 
			
		||||
                            <Grid container
 | 
			
		||||
                                spacing={1}
 | 
			
		||||
                                direction="row"
 | 
			
		||||
                                justify="flex-start"
 | 
			
		||||
                                alignItems="center">
 | 
			
		||||
                                <Grid item>
 | 
			
		||||
                                    <Typography><Skeleton width={150} /></Typography>
 | 
			
		||||
                                </Grid>
 | 
			
		||||
                            </Grid>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </AccordionSummary>
 | 
			
		||||
                <AccordionDetails className={classes.acc_details}>
 | 
			
		||||
                    <Grid container
 | 
			
		||||
                        spacing={1}
 | 
			
		||||
                        direction="column"
 | 
			
		||||
                        justify="flex-start"
 | 
			
		||||
                        alignItems="flex-start">
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography><Skeleton width={800} /></Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography><Skeleton width={300} /></Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography><Skeleton width={500} /></Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </AccordionDetails>
 | 
			
		||||
            </Accordion>
 | 
			
		||||
        );
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default withStyles(styles)(ServiceInfoSkeleton);
 | 
			
		||||
@@ -0,0 +1,146 @@
 | 
			
		||||
import { Grid, IconButton, Paper, Typography } from '@material-ui/core';
 | 
			
		||||
import { blueGrey } from '@material-ui/core/colors';
 | 
			
		||||
import { AddBox, Refresh } from '@material-ui/icons/';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import { HubConnectionBuilder } from '@microsoft/signalr';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import AddNewDialog from './AddNewDialog';
 | 
			
		||||
import ServiceInfoService, { ServiceRequest } from './ServiceInfoService';
 | 
			
		||||
import ServiceInfoComponent from './ServiceInfoComponent';
 | 
			
		||||
import ServiceInfoSkeleton from './ServiceInfoSkeleton';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
    typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
        fontWeight: theme.typography.fontWeightRegular,
 | 
			
		||||
    },
 | 
			
		||||
    paper: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        height: '60px',
 | 
			
		||||
    }
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
const hub_url = "/hubs/services";
 | 
			
		||||
const notify_method_name = "NotifyUpdatedAsync";
 | 
			
		||||
 | 
			
		||||
class Services extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
        super(props);
 | 
			
		||||
 | 
			
		||||
        this.state = {
 | 
			
		||||
            hubConnection: null,
 | 
			
		||||
            isDialogOpen: false,
 | 
			
		||||
            isLoading: false,
 | 
			
		||||
            service: new ServiceInfoService(),
 | 
			
		||||
            services: [],
 | 
			
		||||
            serviceCount: [1, 2, 3],
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        this.handleDevicesUpdated = this.handleDevicesUpdated.bind(this);
 | 
			
		||||
        this.addDevice = this.addDevice.bind(this);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    handleDevicesUpdated() {
 | 
			
		||||
        this.setState({ isLoading: true });
 | 
			
		||||
 | 
			
		||||
        this.state.service.getCount().then(result => {
 | 
			
		||||
            const updatedCount = [];
 | 
			
		||||
            for (var i = 0; i < result; i++) {
 | 
			
		||||
                updatedCount.push(i);
 | 
			
		||||
            }
 | 
			
		||||
            this.setState({ serviceCount: updatedCount });
 | 
			
		||||
        }).catch(ex => {
 | 
			
		||||
            console.log(ex);
 | 
			
		||||
        });
 | 
			
		||||
 | 
			
		||||
        this.state.service.get().then(result => {
 | 
			
		||||
            const updatedServices = [];
 | 
			
		||||
            for (var s of result) {
 | 
			
		||||
                updatedServices.push(s);
 | 
			
		||||
            }
 | 
			
		||||
            this.setState({ services: updatedServices });
 | 
			
		||||
        }).catch(ex => {
 | 
			
		||||
            console.log(ex);
 | 
			
		||||
        }).finally(() => this.setState({ isLoading: false }));
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentDidMount() {
 | 
			
		||||
        this.handleDevicesUpdated();
 | 
			
		||||
        const newConnection = new HubConnectionBuilder()
 | 
			
		||||
            .withUrl(hub_url)
 | 
			
		||||
            .withAutomaticReconnect()
 | 
			
		||||
            .build();
 | 
			
		||||
 | 
			
		||||
        this.setState({ hubConnection: newConnection });
 | 
			
		||||
 | 
			
		||||
        newConnection.start()
 | 
			
		||||
            .then(_ => {
 | 
			
		||||
                console.log('Services hub Connected!');
 | 
			
		||||
                newConnection.on(notify_method_name, () => this.handleDevicesUpdated());
 | 
			
		||||
            }).catch(e => console.log('Services hub Connection failed: ', e));
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentWillUnmount() {
 | 
			
		||||
        if (this.state.hubConnection != null) {
 | 
			
		||||
            this.state.hubConnection.off(notify_method_name);
 | 
			
		||||
            console.log('Services hub Disconnected!');
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    addDevice(name, url) {
 | 
			
		||||
        this.setState({ isDialogOpen: false });
 | 
			
		||||
        let request = new ServiceRequest();
 | 
			
		||||
        request.id = 0;
 | 
			
		||||
        request.name = name;
 | 
			
		||||
        request.uri = url;
 | 
			
		||||
 | 
			
		||||
        this.state.service.post(request).catch(ex => {
 | 
			
		||||
            console.log(ex);
 | 
			
		||||
        });
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    render() {
 | 
			
		||||
        const { classes } = this.props;
 | 
			
		||||
 | 
			
		||||
        const ServiceComponents = this.state.services.map((info, index) => (
 | 
			
		||||
            <ServiceInfoComponent key={index} isAdmin={this.props.isAdmin} info={info} service={this.state.service} />
 | 
			
		||||
        ));
 | 
			
		||||
 | 
			
		||||
        const Skeletons = this.state.serviceCount.map((i, index) => (
 | 
			
		||||
            <ServiceInfoSkeleton key={index} />
 | 
			
		||||
        ));
 | 
			
		||||
 | 
			
		||||
        return (
 | 
			
		||||
            <React.Fragment>
 | 
			
		||||
                <Paper className={classes.paper} square>
 | 
			
		||||
                    <Grid container
 | 
			
		||||
                        spacing={0}
 | 
			
		||||
                        direction="row"
 | 
			
		||||
                        justify="center"
 | 
			
		||||
                        alignItems="center">
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography className={classes.typo}>Services</Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            {this.props.isAdmin ?
 | 
			
		||||
                                <IconButton color="primary" onClick={() => this.setState({ isDialogOpen: true })}>
 | 
			
		||||
                                    <AddBox fontSize="large" />
 | 
			
		||||
                                </IconButton>
 | 
			
		||||
                                : null
 | 
			
		||||
                            }
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <IconButton color="primary" onClick={this.handleDevicesUpdated}>
 | 
			
		||||
                                <Refresh fontSize="large" />
 | 
			
		||||
                            </IconButton>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                        <AddNewDialog open={this.state.isDialogOpen} handleClose={() => this.setState({ isDialogOpen: false })} handleAdd={this.addDevice} />
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </Paper>
 | 
			
		||||
                {this.state.isLoading ? Skeletons : ServiceComponents}
 | 
			
		||||
            </React.Fragment>
 | 
			
		||||
        );
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export default withStyles(styles)(Services);
 | 
			
		||||
@@ -1,14 +1,14 @@
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import { Box, FormControlLabel, Grid, IconButton, Typography } from '@material-ui/core';
 | 
			
		||||
import Accordion from '@material-ui/core/Accordion';
 | 
			
		||||
import { blue, blueGrey, green, orange, red, yellow } from '@material-ui/core/colors';
 | 
			
		||||
import AccordionSummary from '@material-ui/core/AccordionSummary';
 | 
			
		||||
import AccordionDetails from '@material-ui/core/AccordionDetails';
 | 
			
		||||
import ExpandMoreIcon from '@material-ui/icons/ExpandMore';
 | 
			
		||||
import { Grid, Typography, Paper, IconButton, Box, FormControlLabel } from '@material-ui/core';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import { withRouter } from "react-router";
 | 
			
		||||
import AccordionSummary from '@material-ui/core/AccordionSummary';
 | 
			
		||||
import { blueGrey, green, orange, red } from '@material-ui/core/colors';
 | 
			
		||||
import { Power, PowerOff, Refresh } from '@material-ui/icons/';
 | 
			
		||||
import DeviceService from '../../common/DeviceService'
 | 
			
		||||
import ExpandMoreIcon from '@material-ui/icons/ExpandMore';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import { withRouter } from "react-router";
 | 
			
		||||
import DeviceService from '../../common/DeviceService';
 | 
			
		||||
import DevicesContext from '../../contexts/DevicesContext';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
@@ -31,6 +31,7 @@ const styles = theme => ({
 | 
			
		||||
    grid_item: {
 | 
			
		||||
        width: '100%',
 | 
			
		||||
        marginLeft: '5px',
 | 
			
		||||
        marginRight: '30px',
 | 
			
		||||
    },
 | 
			
		||||
    grid_item_typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(15),
 | 
			
		||||
@@ -62,8 +63,8 @@ class DeviceComponent extends Component {
 | 
			
		||||
        if (status == "Online") {
 | 
			
		||||
            return { color: green[600] };
 | 
			
		||||
        } else if (status == "Offline") {
 | 
			
		||||
            return { color: orange[900] };
 | 
			
		||||
        } else /* if (device.status == "unknown") */ {
 | 
			
		||||
            return { color: blueGrey[500] };
 | 
			
		||||
        } else /* if (device.status == "Unknown" || device.status == "Error") */ {
 | 
			
		||||
            return { color: red[800] };
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 
 | 
			
		||||
@@ -1,11 +1,11 @@
 | 
			
		||||
import { Box, Paper, Typography, IconButton, Grid } from '@material-ui/core';
 | 
			
		||||
import { blue, blueGrey, green, orange, red, yellow } from '@material-ui/core/colors';
 | 
			
		||||
import { Box, Grid, IconButton, Paper, Typography } from '@material-ui/core';
 | 
			
		||||
import { blueGrey } from '@material-ui/core/colors';
 | 
			
		||||
import { Power, PowerOff, Refresh } from '@material-ui/icons/';
 | 
			
		||||
import { withStyles } from '@material-ui/styles';
 | 
			
		||||
import React from 'react';
 | 
			
		||||
import DeviceService from '../../common/DeviceService';
 | 
			
		||||
import DevicesContext from '../../contexts/DevicesContext';
 | 
			
		||||
import DeviceComponent from './DeviceComponent';
 | 
			
		||||
import { Power, PowerOff, Refresh } from '@material-ui/icons/';
 | 
			
		||||
 | 
			
		||||
const styles = theme => ({
 | 
			
		||||
    root: {
 | 
			
		||||
@@ -15,7 +15,6 @@ const styles = theme => ({
 | 
			
		||||
    paper: {
 | 
			
		||||
        backgroundColor: blueGrey[50],
 | 
			
		||||
        height: '60px',
 | 
			
		||||
        margin: 'auto',
 | 
			
		||||
    },
 | 
			
		||||
    typo: {
 | 
			
		||||
        fontSize: theme.typography.pxToRem(20),
 | 
			
		||||
@@ -69,15 +68,15 @@ class Devices extends React.Component {
 | 
			
		||||
            <Box className={classes.root}>
 | 
			
		||||
                <Paper className={classes.paper} square>
 | 
			
		||||
                    <Grid container
 | 
			
		||||
                        spacing={3}
 | 
			
		||||
                        spacing={0}
 | 
			
		||||
                        direction="row"
 | 
			
		||||
                        justify="center"
 | 
			
		||||
                        alignItems="center">
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            <Typography className={classes.typo}>All Devices</Typography>
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                            {this.renderButtons()}
 | 
			
		||||
                        <Grid item>
 | 
			
		||||
                            {this.renderButtons()}
 | 
			
		||||
                        </Grid>
 | 
			
		||||
                    </Grid>
 | 
			
		||||
                </Paper>
 | 
			
		||||
 
 | 
			
		||||
@@ -1,11 +1,9 @@
 | 
			
		||||
import RadioButtonCheckedIcon from '@material-ui/icons/RadioButtonChecked';
 | 
			
		||||
import PlayCircleFilledIcon from '@material-ui/icons/PlayCircleFilled';
 | 
			
		||||
import { shadows } from '@material-ui/system';
 | 
			
		||||
import { Box, Popover, Typography, Tooltip, Grid } from '@material-ui/core';
 | 
			
		||||
import { Box, Tooltip } from '@material-ui/core';
 | 
			
		||||
import { blue, red, yellow } from '@material-ui/core/colors';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import { useHistory, withRouter  } from 'react-router-dom';
 | 
			
		||||
import RadioButtonCheckedIcon from '@material-ui/icons/RadioButtonChecked';
 | 
			
		||||
import { makeStyles } from '@material-ui/styles';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import { withRouter } from 'react-router-dom';
 | 
			
		||||
 | 
			
		||||
class DeviceMarker extends Component {
 | 
			
		||||
    constructor(props) {
 | 
			
		||||
@@ -18,9 +16,9 @@ class DeviceMarker extends Component {
 | 
			
		||||
 | 
			
		||||
    getColor() {
 | 
			
		||||
        const { device } = this.props;
 | 
			
		||||
        if (device.status == "Online") {
 | 
			
		||||
        if (device.status === "Online") {
 | 
			
		||||
            return { color: blue[800] };
 | 
			
		||||
        } else if (device.status == "Offline") {
 | 
			
		||||
        } else if (device.status === "Offline") {
 | 
			
		||||
            return { color: yellow[800] };
 | 
			
		||||
        } else /* if (device.status == "unknown") */ {
 | 
			
		||||
            return { color: red[800] };
 | 
			
		||||
 
 | 
			
		||||
@@ -1,9 +1,9 @@
 | 
			
		||||
/*global google*/
 | 
			
		||||
import GoogleMapReact from 'google-map-react';
 | 
			
		||||
import React, { Component } from 'react';
 | 
			
		||||
import DeviceMarker from './DeviceMarker'
 | 
			
		||||
import C from '../../common/Constants'
 | 
			
		||||
import C from '../../common/Constants';
 | 
			
		||||
import DevicesContext from '../../contexts/DevicesContext';
 | 
			
		||||
import DeviceMarker from './DeviceMarker';
 | 
			
		||||
 | 
			
		||||
const lat_offset = 0.000038;
 | 
			
		||||
const lng_offset = -0.000058;
 | 
			
		||||
@@ -20,11 +20,18 @@ export default class MapContainer extends Component {
 | 
			
		||||
        };
 | 
			
		||||
 | 
			
		||||
        this.probabilityHandler = this.probabilityHandler.bind(this);
 | 
			
		||||
        this.handlePoint = this.handlePoint.bind(this);
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    static contextType = DevicesContext;
 | 
			
		||||
 | 
			
		||||
    probabilityHandler(point) {
 | 
			
		||||
    probabilityHandler(points) {
 | 
			
		||||
        for (var point of points) {
 | 
			
		||||
            this.handlePoint(point);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    handlePoint(point) {
 | 
			
		||||
        if (point.prob > 0.5) {
 | 
			
		||||
 | 
			
		||||
            this.setState({
 | 
			
		||||
 
 | 
			
		||||
@@ -60,6 +60,7 @@ export default class DevicesContextProvider extends Component {
 | 
			
		||||
        }
 | 
			
		||||
        service.getall().then(result => {
 | 
			
		||||
            this.setState({ devices: result });
 | 
			
		||||
            this.invokeHandlers(C.update_all_method_name, null);
 | 
			
		||||
        }).catch(ex => {
 | 
			
		||||
            console.log(ex);
 | 
			
		||||
        });
 | 
			
		||||
@@ -96,26 +97,29 @@ export default class DevicesContextProvider extends Component {
 | 
			
		||||
 | 
			
		||||
        newConnection.start()
 | 
			
		||||
            .then(_ => {
 | 
			
		||||
                console.log('Hub Connected!');
 | 
			
		||||
                console.log('Devices hub Connected!');
 | 
			
		||||
 | 
			
		||||
                newConnection.on(C.probability_method_name, (id, date, prob) => {
 | 
			
		||||
                newConnection.on(C.probability_method_name, (messages) => {
 | 
			
		||||
                    //console.log(method_name + " recieved: [id: " + id + ", date: " + date + ", prob: " + prob + "]");
 | 
			
		||||
                    var device = this.state.devices.filter(function (x) { return x.id === id })[0]
 | 
			
		||||
                    var newPoint = { lat: device.coordinates.latitude, lng: device.coordinates.longitude, prob: prob, date: date };
 | 
			
		||||
                    const newPoints = [];
 | 
			
		||||
                    for (var message of messages) {
 | 
			
		||||
                        var device = this.state.devices.filter(function (x) { return x.id === message.deviceId })[0]
 | 
			
		||||
                        var newPoint = { deviceId: device.id, lat: device.coordinates.latitude, lng: device.coordinates.longitude, prob: message.probability, date: new Date(message.date) };
 | 
			
		||||
                        newPoints.push(newPoint);
 | 
			
		||||
                    }
 | 
			
		||||
                    this.setState({
 | 
			
		||||
                        heatmapPoints: [...this.state.heatmapPoints, newPoint]
 | 
			
		||||
                        heatmapPoints: this.state.heatmapPoints.concat(newPoints)
 | 
			
		||||
                    });
 | 
			
		||||
 | 
			
		||||
                    this.invokeHandlers(C.probability_method_name, newPoint);
 | 
			
		||||
                    this.invokeHandlers(C.probability_method_name, newPoints);
 | 
			
		||||
                });
 | 
			
		||||
 | 
			
		||||
                newConnection.on(C.update_all_method_name, () => {
 | 
			
		||||
                    this.updateAllDevicesInternal(service);
 | 
			
		||||
                    this.invokeHandlers(C.update_all_method_name, null);
 | 
			
		||||
                });
 | 
			
		||||
 | 
			
		||||
                newConnection.on(C.update_method_name, (id) => this.updateDeviceInternal(id, service));
 | 
			
		||||
            }).catch(e => console.log('Hub Connection failed: ', e));
 | 
			
		||||
            }).catch(e => console.log('Devices hub Connection failed: ', e));
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
    componentWillUnmount() {
 | 
			
		||||
@@ -123,7 +127,7 @@ export default class DevicesContextProvider extends Component {
 | 
			
		||||
            this.state.hubConnection.off(C.probability_method_name);
 | 
			
		||||
            this.state.hubConnection.off(C.update_all_method_name);
 | 
			
		||||
            this.state.hubConnection.off(C.update_method_name);
 | 
			
		||||
            console.log('Hub Disconnected!');
 | 
			
		||||
            console.log('Devices hub Disconnected!');
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -1,14 +1,19 @@
 | 
			
		||||
using AutoMapper;
 | 
			
		||||
using Birdmap.API.DTOs;
 | 
			
		||||
using Birdmap.API.Services;
 | 
			
		||||
using Birdmap.API.Services.Hubs;
 | 
			
		||||
using Birdmap.API.Services.Mqtt;
 | 
			
		||||
using Birdmap.BLL.Interfaces;
 | 
			
		||||
using Birdmap.DAL.Entities;
 | 
			
		||||
using Microsoft.AspNetCore.Authorization;
 | 
			
		||||
using Microsoft.AspNetCore.Http;
 | 
			
		||||
using Microsoft.AspNetCore.Mvc;
 | 
			
		||||
using Microsoft.AspNetCore.SignalR;
 | 
			
		||||
using Microsoft.Extensions.Logging;
 | 
			
		||||
using System;
 | 
			
		||||
using System.Collections.Generic;
 | 
			
		||||
using System.Linq;
 | 
			
		||||
using System.Net;
 | 
			
		||||
using System.Net.Http;
 | 
			
		||||
using System.Threading.Tasks;
 | 
			
		||||
 | 
			
		||||
@@ -21,21 +26,34 @@ namespace Birdmap.API.Controllers
 | 
			
		||||
    {
 | 
			
		||||
        private readonly IServiceService _service;
 | 
			
		||||
        private readonly IMapper _mapper;
 | 
			
		||||
        private readonly IMqttClientService _mqttClientService;
 | 
			
		||||
        private readonly IHubContext<ServicesHub, IServicesHubClient> _hubContext;
 | 
			
		||||
        private readonly ILogger<ServicesController> _logger;
 | 
			
		||||
 | 
			
		||||
        public ServicesController(IServiceService service, IMapper mapper, ILogger<ServicesController> logger)
 | 
			
		||||
        public ServicesController(IServiceService service, IMapper mapper, MqttClientServiceProvider mqttClientProvider,
 | 
			
		||||
            IHubContext<ServicesHub, IServicesHubClient> hubContext, ILogger<ServicesController> logger)
 | 
			
		||||
        {
 | 
			
		||||
            _service = service;
 | 
			
		||||
            _mapper = mapper;
 | 
			
		||||
            _mqttClientService = mqttClientProvider.MqttClientService;
 | 
			
		||||
            _hubContext = hubContext;
 | 
			
		||||
            _logger = logger;
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        [HttpGet("count"), ProducesResponseType(StatusCodes.Status200OK)]
 | 
			
		||||
        public async Task<ActionResult<int>> GetCountAsync()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation($"Getting service count from db...");
 | 
			
		||||
 | 
			
		||||
            return await _service.GetServiceCountAsync() + 1;
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        [HttpGet, ProducesResponseType(StatusCodes.Status200OK)]
 | 
			
		||||
        public async Task<ActionResult<List<ServiceInfo>>> GetAsync()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation($"Getting all services from db...");
 | 
			
		||||
            var serviceInfos = (await _service.GetAllServicesAsync())
 | 
			
		||||
                .Select(s => new ServiceInfo { Service = _mapper.Map<ServiceRequest>(s) });
 | 
			
		||||
                .Select(s => new ServiceInfo { Service = _mapper.Map<ServiceRequest>(s) }).ToList();
 | 
			
		||||
 | 
			
		||||
            var client = new HttpClient();
 | 
			
		||||
            foreach (var si in serviceInfos)
 | 
			
		||||
@@ -50,11 +68,23 @@ namespace Birdmap.API.Controllers
 | 
			
		||||
                catch (Exception ex)
 | 
			
		||||
                {
 | 
			
		||||
                    _logger.LogWarning($"Requesting service [{si.Service.Name}] faulted.");
 | 
			
		||||
                    si.StatusCode = System.Net.HttpStatusCode.ServiceUnavailable;
 | 
			
		||||
                    si.StatusCode = HttpStatusCode.ServiceUnavailable;
 | 
			
		||||
                    si.Response = ex.ToString();
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            serviceInfos.Add(new()
 | 
			
		||||
            {
 | 
			
		||||
                Service = new()
 | 
			
		||||
                {
 | 
			
		||||
                    Id = 0,
 | 
			
		||||
                    Name = "Mqtt Client Service",
 | 
			
		||||
                    Uri = "localhost",
 | 
			
		||||
                },
 | 
			
		||||
                Response = $"IsConnected: {_mqttClientService.IsConnected}",
 | 
			
		||||
                StatusCode = _mqttClientService.IsConnected ? HttpStatusCode.OK : HttpStatusCode.ServiceUnavailable,
 | 
			
		||||
            });
 | 
			
		||||
 | 
			
		||||
            return serviceInfos.ToList();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
@@ -67,6 +97,7 @@ namespace Birdmap.API.Controllers
 | 
			
		||||
                _mapper.Map<Service>(request));
 | 
			
		||||
 | 
			
		||||
            _logger.LogInformation($"Created service [{created.Id}].");
 | 
			
		||||
            await _hubContext.Clients.All.NotifyUpdatedAsync();
 | 
			
		||||
 | 
			
		||||
            return CreatedAtAction(
 | 
			
		||||
                nameof(GetAsync),
 | 
			
		||||
@@ -82,6 +113,7 @@ namespace Birdmap.API.Controllers
 | 
			
		||||
            service.IsFromConfig = false;
 | 
			
		||||
 | 
			
		||||
            await _service.UpdateServiceAsync(service);
 | 
			
		||||
            await _hubContext.Clients.All.NotifyUpdatedAsync();
 | 
			
		||||
 | 
			
		||||
            return NoContent();
 | 
			
		||||
        }
 | 
			
		||||
@@ -93,6 +125,7 @@ namespace Birdmap.API.Controllers
 | 
			
		||||
            _logger.LogInformation($"Deleting service [{id}]...");
 | 
			
		||||
 | 
			
		||||
            await _service.DeleteServiceAsync(id);
 | 
			
		||||
            await _hubContext.Clients.All.NotifyUpdatedAsync();
 | 
			
		||||
 | 
			
		||||
            return NoContent();
 | 
			
		||||
        }
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										27
									
								
								Birdmap.API/Dockerfile
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										27
									
								
								Birdmap.API/Dockerfile
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,27 @@
 | 
			
		||||
FROM mcr.microsoft.com/dotnet/aspnet:5.0-buster-slim AS base
 | 
			
		||||
WORKDIR /app
 | 
			
		||||
RUN apt-get update && apt-get install -y curl
 | 
			
		||||
RUN curl -sL https://deb.nodesource.com/setup_lts.x | bash -
 | 
			
		||||
RUN apt-get update && apt-get install -y nodejs
 | 
			
		||||
 | 
			
		||||
FROM mcr.microsoft.com/dotnet/sdk:5.0-buster-slim AS build
 | 
			
		||||
RUN apt-get update && apt-get install -y curl
 | 
			
		||||
RUN curl -sL https://deb.nodesource.com/setup_lts.x | bash -
 | 
			
		||||
RUN apt-get update && apt-get install -y nodejs
 | 
			
		||||
WORKDIR /src
 | 
			
		||||
COPY ["Birdmap.API/Birdmap.API.csproj", "Birdmap.API/"]
 | 
			
		||||
COPY ["Birdmap.BLL/Birdmap.BLL.csproj", "Birdmap.BLL/"]
 | 
			
		||||
COPY ["Birdmap.Common/Birdmap.Common.csproj", "Birdmap.Common/"]
 | 
			
		||||
COPY ["Birdmap.DAL/Birdmap.DAL.csproj", "Birdmap.DAL/"]
 | 
			
		||||
RUN dotnet restore "Birdmap.API/Birdmap.API.csproj"
 | 
			
		||||
COPY . .
 | 
			
		||||
WORKDIR "/src/Birdmap.API"
 | 
			
		||||
RUN dotnet build "Birdmap.API.csproj" -c Release -o /app/build
 | 
			
		||||
 | 
			
		||||
FROM build AS publish
 | 
			
		||||
RUN dotnet publish "Birdmap.API.csproj" -c Release -o /app/publish
 | 
			
		||||
 | 
			
		||||
FROM base AS final
 | 
			
		||||
WORKDIR /app
 | 
			
		||||
COPY --from=publish /app/publish .
 | 
			
		||||
ENTRYPOINT ["dotnet", "Birdmap.API.dll"]
 | 
			
		||||
@@ -1,5 +1,6 @@
 | 
			
		||||
using Birdmap.DAL;
 | 
			
		||||
using Microsoft.AspNetCore.Hosting;
 | 
			
		||||
using Microsoft.Extensions.Configuration;
 | 
			
		||||
using Microsoft.Extensions.DependencyInjection;
 | 
			
		||||
using Microsoft.Extensions.Hosting;
 | 
			
		||||
using Microsoft.Extensions.Logging;
 | 
			
		||||
@@ -39,6 +40,10 @@ namespace Birdmap.API
 | 
			
		||||
 | 
			
		||||
        public static IHostBuilder CreateHostBuilder(string[] args) =>
 | 
			
		||||
            Host.CreateDefaultBuilder(args)
 | 
			
		||||
                .ConfigureAppConfiguration((hostingContext, config) =>
 | 
			
		||||
                {
 | 
			
		||||
                    config.AddEnvironmentVariables(prefix: "Birdmap_");
 | 
			
		||||
                })
 | 
			
		||||
                .ConfigureWebHostDefaults(webBuilder =>
 | 
			
		||||
                {
 | 
			
		||||
                    webBuilder.UseStartup<Startup>();
 | 
			
		||||
@@ -53,8 +58,8 @@ namespace Birdmap.API
 | 
			
		||||
        private static void SeedDatabase(IHost host)
 | 
			
		||||
        {
 | 
			
		||||
            using var scope = host.Services.CreateScope();
 | 
			
		||||
            var dbInitializer = scope.ServiceProvider.GetRequiredService<DbInitializer>();
 | 
			
		||||
 | 
			
		||||
            var dbInitializer = scope.ServiceProvider.GetRequiredService<DbInitializer>();
 | 
			
		||||
            dbInitializer.Initialize();
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
 
 | 
			
		||||
@@ -1,7 +1,11 @@
 | 
			
		||||
{
 | 
			
		||||
{
 | 
			
		||||
  "iisSettings": {
 | 
			
		||||
    "windowsAuthentication": false,
 | 
			
		||||
    "anonymousAuthentication": true,
 | 
			
		||||
    "iis": {
 | 
			
		||||
      "applicationUrl": "http://localhost/Birdmap.API",
 | 
			
		||||
      "sslPort": 0
 | 
			
		||||
    },
 | 
			
		||||
    "iisExpress": {
 | 
			
		||||
      "applicationUrl": "http://localhost:63288",
 | 
			
		||||
      "sslPort": 44331
 | 
			
		||||
@@ -12,16 +16,24 @@
 | 
			
		||||
      "commandName": "IISExpress",
 | 
			
		||||
      "launchBrowser": true,
 | 
			
		||||
      "environmentVariables": {
 | 
			
		||||
        "Birdmap_LocalDbConnectionString": "Data Source=DESKTOP-3600;Initial Catalog=birdmap2;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
 | 
			
		||||
        "ASPNETCORE_ENVIRONMENT": "Development"
 | 
			
		||||
      }
 | 
			
		||||
    },
 | 
			
		||||
    "Birdmap": {
 | 
			
		||||
      "commandName": "Project",
 | 
			
		||||
      "launchBrowser": true,
 | 
			
		||||
      "applicationUrl": "https://localhost:5001;http://localhost:5000",
 | 
			
		||||
      "environmentVariables": {
 | 
			
		||||
        "ASPNETCORE_ENVIRONMENT": "Development"
 | 
			
		||||
      }
 | 
			
		||||
      },
 | 
			
		||||
      "applicationUrl": "https://localhost:5001;http://localhost:5000"
 | 
			
		||||
    },
 | 
			
		||||
    "Docker": {
 | 
			
		||||
      "commandName": "Docker",
 | 
			
		||||
      "launchBrowser": true,
 | 
			
		||||
      "launchUrl": "{Scheme}://{ServiceHost}:{ServicePort}",
 | 
			
		||||
      "publishAllPorts": true,
 | 
			
		||||
      "useSSL": true
 | 
			
		||||
    }
 | 
			
		||||
  }
 | 
			
		||||
}
 | 
			
		||||
}
 | 
			
		||||
@@ -16,31 +16,16 @@ namespace Birdmap.API.Services.Hubs
 | 
			
		||||
 | 
			
		||||
        public override Task OnConnectedAsync()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Hub Client connected.");
 | 
			
		||||
            _logger.LogInformation("Devices Hub Client connected.");
 | 
			
		||||
 | 
			
		||||
            return base.OnConnectedAsync();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public override Task OnDisconnectedAsync(Exception exception)
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Hub Client disconnected.");
 | 
			
		||||
            _logger.LogInformation("Devices Hub Client disconnected.");
 | 
			
		||||
 | 
			
		||||
            return base.OnDisconnectedAsync(exception);
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public Task SendProbabilityAsync(Guid deviceId, DateTime date, double probability)
 | 
			
		||||
        {
 | 
			
		||||
            return Clients.All.NotifyDeviceAsync(deviceId, date, probability);
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public Task SendDeviceUpdateAsync(Guid deviceId)
 | 
			
		||||
        {
 | 
			
		||||
            return Clients.All.NotifyDeviceUpdatedAsync(deviceId);
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public Task SendAllUpdatedAsync()
 | 
			
		||||
        {
 | 
			
		||||
            return Clients.All.NotifyAllUpdatedAsync();
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -1,11 +1,14 @@
 | 
			
		||||
using System;
 | 
			
		||||
using System.Collections.Generic;
 | 
			
		||||
using System.Threading.Tasks;
 | 
			
		||||
 | 
			
		||||
namespace Birdmap.API.Services
 | 
			
		||||
{
 | 
			
		||||
    public record Message(Guid DeviceId, DateTime Date, double Probability);
 | 
			
		||||
 | 
			
		||||
    public interface IDevicesHubClient
 | 
			
		||||
    {
 | 
			
		||||
        Task NotifyDeviceAsync(Guid deviceId, DateTime date, double probability);
 | 
			
		||||
        Task NotifyMessagesAsync(IEnumerable<Message> messages);
 | 
			
		||||
        Task NotifyDeviceUpdatedAsync(Guid deviceId);
 | 
			
		||||
        Task NotifyAllUpdatedAsync();
 | 
			
		||||
    }
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										9
									
								
								Birdmap.API/Services/Hubs/IServicesHubClient.cs
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										9
									
								
								Birdmap.API/Services/Hubs/IServicesHubClient.cs
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,9 @@
 | 
			
		||||
using System.Threading.Tasks;
 | 
			
		||||
 | 
			
		||||
namespace Birdmap.API.Services.Hubs
 | 
			
		||||
{
 | 
			
		||||
    public interface IServicesHubClient
 | 
			
		||||
    {
 | 
			
		||||
        Task NotifyUpdatedAsync();
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
							
								
								
									
										31
									
								
								Birdmap.API/Services/Hubs/ServicesHub.cs
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										31
									
								
								Birdmap.API/Services/Hubs/ServicesHub.cs
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,31 @@
 | 
			
		||||
using Microsoft.AspNetCore.SignalR;
 | 
			
		||||
using Microsoft.Extensions.Logging;
 | 
			
		||||
using System;
 | 
			
		||||
using System.Threading.Tasks;
 | 
			
		||||
 | 
			
		||||
namespace Birdmap.API.Services.Hubs
 | 
			
		||||
{
 | 
			
		||||
    public class ServicesHub : Hub<IServicesHubClient>
 | 
			
		||||
    {
 | 
			
		||||
        private readonly ILogger<ServicesHub> _logger;
 | 
			
		||||
 | 
			
		||||
        public ServicesHub(ILogger<ServicesHub> logger)
 | 
			
		||||
        {
 | 
			
		||||
            _logger = logger;
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public override Task OnConnectedAsync()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Services Hub Client connected.");
 | 
			
		||||
 | 
			
		||||
            return base.OnConnectedAsync();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public override Task OnDisconnectedAsync(Exception exception)
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Services Hub Client disconnected.");
 | 
			
		||||
 | 
			
		||||
            return base.OnDisconnectedAsync(exception);
 | 
			
		||||
        }
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
@@ -10,6 +10,6 @@ namespace Birdmap.API.Services
 | 
			
		||||
                                          IMqttClientDisconnectedHandler,
 | 
			
		||||
                                          IMqttApplicationMessageReceivedHandler
 | 
			
		||||
    {
 | 
			
		||||
 | 
			
		||||
        public bool IsConnected { get; }
 | 
			
		||||
    }
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -13,6 +13,7 @@ using System.Collections.Generic;
 | 
			
		||||
using System.Linq;
 | 
			
		||||
using System.Threading;
 | 
			
		||||
using System.Threading.Tasks;
 | 
			
		||||
using Timer = System.Timers.Timer;
 | 
			
		||||
 | 
			
		||||
namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
{
 | 
			
		||||
@@ -23,6 +24,11 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
        private readonly ILogger<MqttClientService> _logger;
 | 
			
		||||
        private readonly IInputService _inputService;
 | 
			
		||||
        private readonly IHubContext<DevicesHub, IDevicesHubClient> _hubContext;
 | 
			
		||||
        private readonly Timer _hubTimer;
 | 
			
		||||
        private readonly List<Message> _messages = new();
 | 
			
		||||
        private readonly object _messageLock = new();
 | 
			
		||||
 | 
			
		||||
        public bool IsConnected => _mqttClient.IsConnected;
 | 
			
		||||
 | 
			
		||||
        public MqttClientService(IMqttClientOptions options, ILogger<MqttClientService> logger, IInputService inputService, IHubContext<DevicesHub, IDevicesHubClient> hubContext)
 | 
			
		||||
        {
 | 
			
		||||
@@ -30,10 +36,30 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
            _logger = logger;
 | 
			
		||||
            _inputService = inputService;
 | 
			
		||||
            _hubContext = hubContext;
 | 
			
		||||
            _hubTimer = new Timer()
 | 
			
		||||
            {
 | 
			
		||||
                AutoReset = true,
 | 
			
		||||
                Interval = 1000,
 | 
			
		||||
            };
 | 
			
		||||
            _hubTimer.Elapsed += SendMqttMessagesWithSignalR;
 | 
			
		||||
 | 
			
		||||
            _mqttClient = new MqttFactory().CreateMqttClient();
 | 
			
		||||
            ConfigureMqttClient();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        private void SendMqttMessagesWithSignalR(object sender, System.Timers.ElapsedEventArgs e)
 | 
			
		||||
        {
 | 
			
		||||
            lock (_messageLock)
 | 
			
		||||
            {
 | 
			
		||||
                if (_messages.Any())
 | 
			
		||||
                {
 | 
			
		||||
                    _logger.LogInformation($"Sending ({_messages.Count}) messages: {string.Join(" | ", _messages)}");
 | 
			
		||||
                    _hubContext.Clients.All.NotifyMessagesAsync(_messages);
 | 
			
		||||
                    _messages.Clear();
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        private void ConfigureMqttClient()
 | 
			
		||||
        {
 | 
			
		||||
            _mqttClient.ConnectedHandler = this;
 | 
			
		||||
@@ -54,7 +80,7 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
        {
 | 
			
		||||
            var message = eventArgs.ApplicationMessage.ConvertPayloadToString();
 | 
			
		||||
 | 
			
		||||
            _logger.LogInformation($"Recieved [{eventArgs.ClientId}] " +
 | 
			
		||||
            _logger.LogDebug($"Recieved [{eventArgs.ClientId}] " +
 | 
			
		||||
                $"Topic: {eventArgs.ApplicationMessage.Topic} | Payload: {message} | QoS: {eventArgs.ApplicationMessage.QualityOfServiceLevel} | Retain: {eventArgs.ApplicationMessage.Retain}");
 | 
			
		||||
 | 
			
		||||
            try
 | 
			
		||||
@@ -62,7 +88,10 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
                var payload = JsonConvert.DeserializeObject<Payload>(message);
 | 
			
		||||
                var inputResponse = await _inputService.GetInputAsync(payload.TagID);
 | 
			
		||||
 | 
			
		||||
                await _hubContext.Clients.All.NotifyDeviceAsync(inputResponse.Message.Device_id, inputResponse.Message.Date.UtcDateTime, payload.Probability);
 | 
			
		||||
                lock (_messageLock)
 | 
			
		||||
                {
 | 
			
		||||
                    _messages.Add(new Message(inputResponse.Message.Device_id, inputResponse.Message.Date.UtcDateTime, payload.Probability));
 | 
			
		||||
                }
 | 
			
		||||
            }
 | 
			
		||||
            catch (Exception ex)
 | 
			
		||||
            {
 | 
			
		||||
@@ -78,6 +107,7 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
                _logger.LogInformation($"Connected. Auth result: {eventArgs.AuthenticateResult}. Subscribing to topic: {topic}");
 | 
			
		||||
 | 
			
		||||
                await _mqttClient.SubscribeAsync(topic);
 | 
			
		||||
                _hubTimer.Start();
 | 
			
		||||
            }
 | 
			
		||||
            catch (Exception ex)
 | 
			
		||||
            {
 | 
			
		||||
@@ -87,17 +117,18 @@ namespace Birdmap.API.Services.Mqtt
 | 
			
		||||
 | 
			
		||||
        public async Task HandleDisconnectedAsync(MqttClientDisconnectedEventArgs eventArgs)
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogWarning(eventArgs.Exception, $"Disconnected. Reason {eventArgs.ReasonCode}. Auth result: {eventArgs.AuthenticateResult}. Reconnecting...");
 | 
			
		||||
            _logger.LogDebug(eventArgs.Exception, $"Disconnected. Reason {eventArgs.ReasonCode}. Auth result: {eventArgs.AuthenticateResult}. Reconnecting...");
 | 
			
		||||
 | 
			
		||||
            await Task.Delay(TimeSpan.FromSeconds(5));
 | 
			
		||||
 | 
			
		||||
            try
 | 
			
		||||
            {
 | 
			
		||||
                _hubTimer.Stop();
 | 
			
		||||
                await _mqttClient.ConnectAsync(_options, CancellationToken.None);
 | 
			
		||||
            }
 | 
			
		||||
            catch (Exception ex)
 | 
			
		||||
            {
 | 
			
		||||
                _logger.LogError(ex, $"Reconnect failed...");
 | 
			
		||||
                _logger.LogDebug(ex, $"Reconnect failed...");
 | 
			
		||||
            }
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -139,6 +139,7 @@ namespace Birdmap.API
 | 
			
		||||
                endpoints.MapHealthChecks("/health");
 | 
			
		||||
                endpoints.MapControllers();
 | 
			
		||||
                endpoints.MapHub<DevicesHub>("/hubs/devices");
 | 
			
		||||
                endpoints.MapHub<ServicesHub>("/hubs/services");
 | 
			
		||||
            });
 | 
			
		||||
 | 
			
		||||
            app.UseSpa(spa =>
 | 
			
		||||
 
 | 
			
		||||
@@ -9,7 +9,8 @@
 | 
			
		||||
  "AllowedHosts": "*",
 | 
			
		||||
  "Secret": "7vj.3KW.hYE!}4u6",
 | 
			
		||||
  // "LocalDbConnectionString": "Data Source=DESKTOP-3600\\SQLEXPRESS;Initial Catalog=birdmap;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
 | 
			
		||||
  "LocalDbConnectionString": "Data Source=DESKTOP-3600;Initial Catalog=birdmap;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
 | 
			
		||||
  //"LocalDbConnectionString": "Data Source=DESKTOP-3600;Initial Catalog=birdmap;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False",
 | 
			
		||||
  "LocalDbConnectionString": "Data Source=db;Initial Catalog=birdmap;User=sa;Password=RPSsql12345",
 | 
			
		||||
  "Defaults": {
 | 
			
		||||
    "Services": {
 | 
			
		||||
      "Local Database": "https://localhost:44331/health",
 | 
			
		||||
@@ -29,6 +30,7 @@
 | 
			
		||||
    ]
 | 
			
		||||
  },
 | 
			
		||||
  "UseDummyServices": true,
 | 
			
		||||
  "ServicesBaseUrl": "https://birb.k8s.kmlabz.com/",
 | 
			
		||||
  "Mqtt": {
 | 
			
		||||
    "BrokerHostSettings": {
 | 
			
		||||
      "Host": "localhost",
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										5
									
								
								Birdmap.API/libman.json
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										5
									
								
								Birdmap.API/libman.json
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,5 @@
 | 
			
		||||
{
 | 
			
		||||
  "version": "1.0",
 | 
			
		||||
  "defaultProvider": "cdnjs",
 | 
			
		||||
  "libraries": []
 | 
			
		||||
}
 | 
			
		||||
@@ -6,6 +6,7 @@ namespace Birdmap.BLL.Interfaces
 | 
			
		||||
{
 | 
			
		||||
    public interface IServiceService
 | 
			
		||||
    {
 | 
			
		||||
        Task<int> GetServiceCountAsync();
 | 
			
		||||
        Task<List<Service>> GetAllServicesAsync();
 | 
			
		||||
        Task<Service> GetServiceAsync(int id);
 | 
			
		||||
        Task<Service> CreateServiceAsync(Service service);
 | 
			
		||||
 
 | 
			
		||||
@@ -16,12 +16,12 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
        private const double centerLat = 48.275939;
 | 
			
		||||
        private const double radius = 0.001;
 | 
			
		||||
 | 
			
		||||
        private static readonly Random Rand = new Random();
 | 
			
		||||
        private static readonly Random Rand = new();
 | 
			
		||||
 | 
			
		||||
        private static readonly Lazy<ICollection<Device>> Devices = new Lazy<ICollection<Device>>(GenerateDevices);
 | 
			
		||||
        private static readonly Lazy<ICollection<Device>> Devices = new(GenerateDevices);
 | 
			
		||||
 | 
			
		||||
        private static readonly Dictionary<Guid, InputSingeResponse> TagToInput = new Dictionary<Guid, InputSingeResponse>();
 | 
			
		||||
        private static readonly object InputLock = new object();
 | 
			
		||||
        private static readonly Dictionary<Guid, InputSingeResponse> TagToInput = new();
 | 
			
		||||
        private static readonly object InputLock = new();
 | 
			
		||||
 | 
			
		||||
        private static ListOfDevices GenerateDevices()
 | 
			
		||||
        {
 | 
			
		||||
@@ -43,20 +43,20 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
                var sensors = new ArrayofSensors();
 | 
			
		||||
                for (int s = 0; s < Rand.Next(1, 6); s++)
 | 
			
		||||
                {
 | 
			
		||||
                    sensors.Add(new Sensor
 | 
			
		||||
                    sensors.Add(new()
 | 
			
		||||
                    {
 | 
			
		||||
                        Id = Guid.NewGuid(),
 | 
			
		||||
                        Status = GetRandomEnum<SensorStatus>(),
 | 
			
		||||
                    });
 | 
			
		||||
                }
 | 
			
		||||
 | 
			
		||||
                devices.Add(new Device
 | 
			
		||||
                devices.Add(new()
 | 
			
		||||
                {
 | 
			
		||||
                    Id = Guid.NewGuid(),
 | 
			
		||||
                    Sensors = sensors,
 | 
			
		||||
                    Status = GetRandomEnum<DeviceStatus>(),
 | 
			
		||||
                    Url = "dummyservice.device.url",
 | 
			
		||||
                    Coordinates = new Coordinates
 | 
			
		||||
                    Coordinates = new()
 | 
			
		||||
                    {
 | 
			
		||||
                        Latitude = GetPlusMinus(centerLat, radius),
 | 
			
		||||
                        Longitude = GetPlusMinus(centerLong, radius),
 | 
			
		||||
@@ -150,10 +150,10 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
            {
 | 
			
		||||
                if (!TagToInput.TryGetValue(tagID, out var value))
 | 
			
		||||
                {
 | 
			
		||||
                    value = new InputSingeResponse
 | 
			
		||||
                    value = new()
 | 
			
		||||
                    {
 | 
			
		||||
                        Status = "Dummy_OK",
 | 
			
		||||
                        Message = new InputObject
 | 
			
		||||
                        Message = new()
 | 
			
		||||
                        {
 | 
			
		||||
                            Tag = tagID,
 | 
			
		||||
                            Date = DateTime.Now,
 | 
			
		||||
 
 | 
			
		||||
@@ -23,8 +23,9 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
        private System.Net.Http.HttpClient _httpClient;
 | 
			
		||||
        private System.Lazy<Newtonsoft.Json.JsonSerializerSettings> _settings;
 | 
			
		||||
 | 
			
		||||
        public LiveDummyService(System.Net.Http.HttpClient httpClient)
 | 
			
		||||
        public LiveDummyService(string baseUrl, System.Net.Http.HttpClient httpClient)
 | 
			
		||||
        {
 | 
			
		||||
            _baseUrl = baseUrl;
 | 
			
		||||
            _httpClient = httpClient;
 | 
			
		||||
            _settings = new System.Lazy<Newtonsoft.Json.JsonSerializerSettings>(CreateSerializerSettings);
 | 
			
		||||
        }
 | 
			
		||||
 
 | 
			
		||||
@@ -23,8 +23,9 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
        private System.Net.Http.HttpClient _httpClient;
 | 
			
		||||
        private System.Lazy<Newtonsoft.Json.JsonSerializerSettings> _settings;
 | 
			
		||||
 | 
			
		||||
        public LiveInputService(System.Net.Http.HttpClient httpClient)
 | 
			
		||||
        public LiveInputService(string baseUrl, System.Net.Http.HttpClient httpClient)
 | 
			
		||||
        {
 | 
			
		||||
            _baseUrl = baseUrl;
 | 
			
		||||
            _httpClient = httpClient;
 | 
			
		||||
            _settings = new System.Lazy<Newtonsoft.Json.JsonSerializerSettings>(CreateSerializerSettings);
 | 
			
		||||
        }
 | 
			
		||||
 
 | 
			
		||||
@@ -17,6 +17,11 @@ namespace Birdmap.BLL.Services
 | 
			
		||||
            _context = context;
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public Task<int> GetServiceCountAsync()
 | 
			
		||||
        {
 | 
			
		||||
            return _context.Services.CountAsync();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        public async Task<Service> CreateServiceAsync(Service service)
 | 
			
		||||
        {
 | 
			
		||||
            _context.Services.Add(service);
 | 
			
		||||
 
 | 
			
		||||
@@ -2,6 +2,7 @@
 | 
			
		||||
using Birdmap.BLL.Services;
 | 
			
		||||
using Microsoft.Extensions.Configuration;
 | 
			
		||||
using Microsoft.Extensions.DependencyInjection;
 | 
			
		||||
using System.Net.Http;
 | 
			
		||||
 | 
			
		||||
namespace Birdmap.BLL
 | 
			
		||||
{
 | 
			
		||||
@@ -20,8 +21,20 @@ namespace Birdmap.BLL
 | 
			
		||||
            }
 | 
			
		||||
            else
 | 
			
		||||
            {
 | 
			
		||||
                services.AddTransient<IInputService, LiveInputService>();
 | 
			
		||||
                services.AddTransient<IDeviceService, LiveDummyService>();
 | 
			
		||||
                var baseUrl = configuration.GetValue<string>("ServicesBaseUrl");
 | 
			
		||||
 | 
			
		||||
                services.AddTransient<IInputService, LiveInputService>(serviceProvider =>
 | 
			
		||||
                {
 | 
			
		||||
                    var httpClient = serviceProvider.GetService<HttpClient>();
 | 
			
		||||
                    var service = new LiveInputService(baseUrl, httpClient);
 | 
			
		||||
                    return service;
 | 
			
		||||
                });
 | 
			
		||||
                services.AddTransient<IDeviceService, LiveDummyService>(serviceProvider =>
 | 
			
		||||
                {
 | 
			
		||||
                    var httpClient = serviceProvider.GetService<HttpClient>();
 | 
			
		||||
                    var service = new LiveDummyService(baseUrl, httpClient);
 | 
			
		||||
                    return service;
 | 
			
		||||
                });
 | 
			
		||||
            }
 | 
			
		||||
 | 
			
		||||
            return services;
 | 
			
		||||
 
 | 
			
		||||
@@ -22,10 +22,17 @@ namespace Birdmap.DAL
 | 
			
		||||
 | 
			
		||||
        public void Initialize()
 | 
			
		||||
        {
 | 
			
		||||
            EnsureCreated();
 | 
			
		||||
            AddDefaultUsers();
 | 
			
		||||
            AddDefaultServices();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        private void EnsureCreated()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Ensuring database is created...");
 | 
			
		||||
            _context.Database.EnsureCreated();
 | 
			
		||||
        }
 | 
			
		||||
 | 
			
		||||
        private void AddDefaultServices()
 | 
			
		||||
        {
 | 
			
		||||
            _logger.LogInformation("Removing previously added default services...");
 | 
			
		||||
 
 | 
			
		||||
@@ -13,6 +13,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Birdmap.Common", "Birdmap.C
 | 
			
		||||
EndProject
 | 
			
		||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MQTTnet.TestApp.WinForm", "MQTTnet.TestApp.WinForm\MQTTnet.TestApp.WinForm.csproj", "{E1707FE7-4A65-42AC-B71C-6CC1A55FC42A}"
 | 
			
		||||
EndProject
 | 
			
		||||
Project("{E53339B2-1760-4266-BCC7-CA923CBCF16C}") = "docker-compose", "docker-compose.dcproj", "{9443433B-1D13-41F0-B345-B36ACD15EF81}"
 | 
			
		||||
EndProject
 | 
			
		||||
Global
 | 
			
		||||
	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 | 
			
		||||
		Debug|Any CPU = Debug|Any CPU
 | 
			
		||||
@@ -39,6 +41,10 @@ Global
 | 
			
		||||
		{E1707FE7-4A65-42AC-B71C-6CC1A55FC42A}.Debug|Any CPU.Build.0 = Debug|Any CPU
 | 
			
		||||
		{E1707FE7-4A65-42AC-B71C-6CC1A55FC42A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 | 
			
		||||
		{E1707FE7-4A65-42AC-B71C-6CC1A55FC42A}.Release|Any CPU.Build.0 = Release|Any CPU
 | 
			
		||||
		{9443433B-1D13-41F0-B345-B36ACD15EF81}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 | 
			
		||||
		{9443433B-1D13-41F0-B345-B36ACD15EF81}.Debug|Any CPU.Build.0 = Debug|Any CPU
 | 
			
		||||
		{9443433B-1D13-41F0-B345-B36ACD15EF81}.Release|Any CPU.ActiveCfg = Release|Any CPU
 | 
			
		||||
		{9443433B-1D13-41F0-B345-B36ACD15EF81}.Release|Any CPU.Build.0 = Release|Any CPU
 | 
			
		||||
	EndGlobalSection
 | 
			
		||||
	GlobalSection(SolutionProperties) = preSolution
 | 
			
		||||
		HideSolutionNode = FALSE
 | 
			
		||||
 
 | 
			
		||||
							
								
								
									
										15
									
								
								docker-compose.dcproj
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										15
									
								
								docker-compose.dcproj
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,15 @@
 | 
			
		||||
<?xml version="1.0" encoding="utf-8"?>
 | 
			
		||||
<Project ToolsVersion="15.0" Sdk="Microsoft.Docker.Sdk">
 | 
			
		||||
  <PropertyGroup Label="Globals">
 | 
			
		||||
    <ProjectVersion>2.1</ProjectVersion>
 | 
			
		||||
    <DockerTargetOS>Linux</DockerTargetOS>
 | 
			
		||||
    <ProjectGuid>9443433b-1d13-41f0-b345-b36acd15ef81</ProjectGuid>
 | 
			
		||||
    <DockerLaunchAction>LaunchBrowser</DockerLaunchAction>
 | 
			
		||||
    <DockerServiceUrl>{Scheme}://localhost:{ServicePort}</DockerServiceUrl>
 | 
			
		||||
    <DockerServiceName>birdmap.api</DockerServiceName>
 | 
			
		||||
  </PropertyGroup>
 | 
			
		||||
  <ItemGroup>
 | 
			
		||||
    <None Include="docker-compose.yml" />
 | 
			
		||||
    <None Include=".dockerignore" />
 | 
			
		||||
  </ItemGroup>
 | 
			
		||||
</Project>
 | 
			
		||||
							
								
								
									
										44
									
								
								docker-compose.yml
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										44
									
								
								docker-compose.yml
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,44 @@
 | 
			
		||||
version: '3.4'
 | 
			
		||||
 | 
			
		||||
services:
 | 
			
		||||
    db:
 | 
			
		||||
        image: "mcr.microsoft.com/mssql/server:2019-latest"
 | 
			
		||||
        environment:
 | 
			
		||||
          - ACCEPT_EULA=Y
 | 
			
		||||
          - SA_PASSWORD=RPSsql12345
 | 
			
		||||
 | 
			
		||||
    birdmap.api:
 | 
			
		||||
        image: ${DOCKER_REGISTRY-}birdmapapi
 | 
			
		||||
        ports:
 | 
			
		||||
            - "8000:80"
 | 
			
		||||
            - "8001:443"
 | 
			
		||||
        volumes:
 | 
			
		||||
            - ${APPDATA}/Microsoft/UserSecrets:/root/.microsoft/usersecrets:ro
 | 
			
		||||
            - ${APPDATA}/ASP.NET/Https:/root/.aspnet/https:ro
 | 
			
		||||
        build:
 | 
			
		||||
          context: .
 | 
			
		||||
          dockerfile: Birdmap.API/Dockerfile
 | 
			
		||||
        depends_on:
 | 
			
		||||
            - db
 | 
			
		||||
        environment:
 | 
			
		||||
            - ASPNETCORE_ENVIRONMENT=Development
 | 
			
		||||
            - ASPNETCORE_URLS=https://+;http://+
 | 
			
		||||
            - ASPNETCORE_HTTPS_PORT=8001
 | 
			
		||||
            - ASPNETCORE_Kestrel__Certificates__Default__Password=certpass123
 | 
			
		||||
            - ASPNETCORE_Kestrel__Certificates__Default__Path=/root/.aspnet/https/aspnetapp.pfx
 | 
			
		||||
            - Birdmap_LocalDbConnectionString=Data Source=db;Initial Catalog=birdmap;User=sa;Password=RPSsql12345
 | 
			
		||||
            - Birdmap_Defaults__Users__0__Name=admin
 | 
			
		||||
            - Birdmap_Defaults__Users__0__Password=pass
 | 
			
		||||
            - Birdmap_Defaults__Users__0__Role=Admin
 | 
			
		||||
            - Birdmap_Defaults__Users__1__Name=user
 | 
			
		||||
            - Birdmap_Defaults__Users__1__Password=pass
 | 
			
		||||
            - Birdmap_Defaults__Users__1__Role=User
 | 
			
		||||
            - Birdmap_Defaults__Services__Local-Database=https://localhost/health
 | 
			
		||||
            - Birdmap_UseDummyServices=true
 | 
			
		||||
            - Birdmap_ServicesBaseUrl=https://birb.k8s.kmlabz.com/
 | 
			
		||||
            - Birdmap_Mqtt__BrokerHostSettings__Host=localhost
 | 
			
		||||
            - Birdmap_Mqtt__BrokerHostSettings__Port=1883
 | 
			
		||||
            - Birdmap_Mqtt__ClientSettings__Id=ASP.NET Core client
 | 
			
		||||
            - Birdmap_Mqtt__ClientSettings__Username=username
 | 
			
		||||
            - Birdmap_Mqtt__ClientSettings__Password=password
 | 
			
		||||
            - Birdmap_Mqtt__ClientSettings__Topic=devices/output
 | 
			
		||||
		Reference in New Issue
	
	Block a user