Backened

Web App/Backend/.env

@@ -0,0 +1,3 @@
+JWTSECRETKEY = MyAPIForSensorsProjectForDataStoringAndFetching;
+USER = sensorsdb
+PASS = sensorsdb

Web App/Backend/app.js

@@ -0,0 +1,43 @@
+require("dotenv").config();
+const createError = require("http-errors");
+const express = require("express");
+const cookieParser = require("cookie-parser");
+const logger = require("morgan");
+const fileUpload = require("express-fileupload");
+
+const app = express();
+
+const userRoute = require("./routes/api/users");
+const mqttRoute = require("./routes/api/mqtt");
+const fileUploadRoute = require("./routes/api/fileUpload");
+
+//Database Connection
+require("./db/connection");
+
+app.use(logger("dev"));
+app.use(express.json());
+app.use(express.urlencoded({ extended: false }));
+app.use(cookieParser());
+app.use(fileUpload());
+
+app.use("/api/users", userRoute);
+app.use("/api/mqtt", mqttRoute);
+app.use("/api/fileUpload", fileUploadRoute);
+
+// catch 404 and forward to error handler
+app.use(function (req, res, next) {
+  next(createError(404));
+});
+
+// error handler
+app.use(function (err, req, res, next) {
+  // set locals, only providing error in development
+  res.locals.message = err.message;
+  res.locals.error = req.app.get("env") === "development" ? err : {};
+
+  // render the error page
+  res.status(err.status || 500);
+  res.render("error");
+});
+
+module.exports = app;

Web App/Backend/bin/www

@@ -0,0 +1,90 @@
+#!/usr/bin/env node
+
+/**
+ * Module dependencies.
+ */
+
+var app = require('../app');
+var debug = require('debug')('backend:server');
+var http = require('http');
+
+/**
+ * Get port from environment and store in Express.
+ */
+
+var port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+
+/**
+ * Create HTTP server.
+ */
+
+var server = http.createServer(app);
+
+/**
+ * Listen on provided port, on all network interfaces.
+ */
+
+server.listen(port);
+server.on('error', onError);
+server.on('listening', onListening);
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+  var port = parseInt(val, 10);
+
+  if (isNaN(port)) {
+    // named pipe
+    return val;
+  }
+
+  if (port >= 0) {
+    // port number
+    return port;
+  }
+
+  return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+  if (error.syscall !== 'listen') {
+    throw error;
+  }
+
+  var bind = typeof port === 'string'
+    ? 'Pipe ' + port
+    : 'Port ' + port;
+
+  // handle specific listen errors with friendly messages
+  switch (error.code) {
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
+      process.exit(1);
+      break;
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
+      process.exit(1);
+      break;
+    default:
+      throw error;
+  }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+  var addr = server.address();
+  var bind = typeof addr === 'string'
+    ? 'pipe ' + addr
+    : 'port ' + addr.port;
+  debug('Listening on ' + bind);
+}

Web App/Backend/captain-definition

@@ -0,0 +1,20 @@
+{
+ "schemaVersion" :2 ,
+
+
+ "dockerfileLines": [
+   "FROM node:14.15.4-alpine",
+   "RUN mkdir -p /usr/src/app3",
+   "WORKDIR /usr/src/app3",
+   "COPY ./ /usr/src/app3",
+   "RUN npm install && npm cache clean --force",
+
+   "ENV NODE_ENV production",
+   "ENV PORT 80",
+   "EXPOSE 80",
+   "CMD [ \"npm\", \"run\" ,\"start\"]"
+
+
+
+  ]
+}

Web App/Backend/db/connection.js

@@ -0,0 +1,16 @@
+const mongoose = require("mongoose");
+
+mongoose
+  .connect("mongodb://srv-captain--sensors-db/mydatabase?authSource=admin", {
+    user: "sensorsdb",
+    pass: "sensorsdb",
+    useNewUrlParser: true,
+    useUnifiedTopology: true,
+  })
+  .then(() => {
+    console.log("DB Connected");
+  })
+  .catch((err) => {
+    console.log("Error Connecting to Database");
+    console.log(err);
+  });

Web App/Backend/models/mqttmessage.js

@@ -0,0 +1,31 @@
+const mongoose = require("mongoose");
+
+let mqttMessageSchema = mongoose.Schema(
+  {
+    macAddress: {
+      type: String,
+      required: true,
+    },
+    FW_Version: {
+      type: String,
+    },
+    Environment: [
+      { Temperautre: Number, Humidity: Number, Atmospheric_Pressure: Number },
+    ],
+    Soil_Parameters: [
+      {
+        Soil_Moisture: Number,
+        EC: Number,
+        pH: Number,
+        Nitrogen: Number,
+        Phosphorus: Number,
+        Potassium: Number,
+      },
+    ],
+  },
+  { timestamps: true }
+);
+
+let mqttMessageModel = new mongoose.model("Mqttmessage", mqttMessageSchema);
+
+module.exports = mqttMessageModel;

Web App/Backend/models/user.js

@@ -0,0 +1,35 @@
+const mongoose = require("mongoose");
+// const Joi = require("joi");
+const jwt = require("jsonwebtoken");
+
+let userSchema = mongoose.Schema({
+  email: {
+    type: String,
+    required: true,
+    unique: true,
+    minlength: 5,
+    maxlength: 255,
+  },
+  password: {
+    type: String,
+    required: true,
+  },
+  confirmPassword: {
+    type: String,
+    required: true,
+  },
+});
+
+// function validateUser(user) {
+//   const schema = {
+//     email: Joi.string().min(5).max(255).required().email(),
+//   };
+// }
+userSchema.methods.generateAuthToken = function () {
+  const token = jwt.sign({ id: this._id }, process.env.JWTSECRETKEY);
+  return token;
+};
+let UserModel = new mongoose.model("User", userSchema);
+
+exports.UserModel = UserModel;
+// exports.validateUser = validateUser;