Added aws Rekognition

Author: Programmerryoki

client/api/AWSRekognition.js

@@ -0,0 +1,32 @@
+const express = require('express');
+const router = express.Router();
+const { detectFace } = require('../aws_rekognition/aws_rekognition_client');
+const { OK, BAD_REQUEST, NOT_FOUND } = require('../config/config');
+const { addSignLog } = require('../util/logging-helpers');
+
+router.post('/AWS_rekognition', (req, res) => {
+  const { base64bytes } = req.body;
+  // const base64bytes = getBase64Image(faceImage);
+  // detectFace(faceImage)
+  detectFace(base64bytes)
+    .then((response) => {
+      return res.status(OK).send({ ...response });
+    })
+    .catch((error) => {
+      return res.status(BAD_REQUEST).send({ ...error });
+    });
+});
+
+// function getBase64Image(img) {
+//   let canvas = document.createElement('canvas');
+//   canvas.width = img.width;
+//   canvas.height = img.height;
+//   let ctx = canvas.getContext('2d');
+//   ctx.drawImage(img, 0, 0);
+
+//   let dataURL = canvas.toDataURL('image/png');
+
+//   return dataURL.replace(/^data:image\/(png|jpg);base64,/, '');
+// }
+
+module.exports = router;

client/api/SceRpcApiServer.js

@@ -29,14 +29,14 @@ class SceRpcApiServer {
       bodyParser.json({
         // support JSON-encoded request bodies
         limit: '50mb',
-        strict: true
+        strict: true,
       })
     );
     this.app.use(
       bodyParser.urlencoded({
         // support URL-encoded request bodies
         limit: '50mb',
-        extended: true
+        extended: true,
       })
     );
   }
@@ -64,7 +64,7 @@ class SceRpcApiServer {
   openConnection() {
     this.server = http.createServer(this.app);
     const { port } = this;
-    this.server.listen(port, function() {
+    this.server.listen(port, function () {
       console.debug(`Now listening on port ${port}`);
     });
   }
@@ -93,10 +93,10 @@ if (typeof module !== 'undefined' && !module.parent) {
   const apiRoutes = [
     __dirname + '/2DPrinting.js',
     __dirname + '/3DPrinting.js',
-    __dirname + '/LedSign.js'
+    __dirname + '/LedSign.js',
+    __dirname + '/AWSRekognition.js',
   ];
-  const server = new SceRpcApiServer(
-    apiRoutes, 8083, '/SceRpcApi/');
+  const server = new SceRpcApiServer(apiRoutes, 8083, '/SceRpcApi/');
   server.initializeEndpoints().then(() => {
     server.openConnection();
   });

client/aws_rekognition/aws_rekognition_client copy.js

@@ -0,0 +1,24 @@
+const grpc = require('grpc');
+const messages = require('./aws_rekognition_pb');
+const services = require('./aws_rekognition_grpc_pb');
+
+function detectFace(faceImageBytes) {
+  const client = new services.FaceImageClient(
+    'localhost:50051',
+    grpc.credentials.createInsecure()
+  );
+
+  const faceCoordinateRequest = new messages.FaceCoordinateRequest();
+  faceCoordinateRequest.setFaceimage(faceImageBytes);
+  return new Promise((resolve, reject) => {
+    client.requestFaceCoordinate(faceCoordinateRequest, (err, response) => {
+      if (err || !response) {
+        reject({ message: err, error: true });
+      } else {
+        resolve({ message: response, error: false });
+      }
+    });
+  });
+}
+
+module.exports = { detectFace };

client/aws_rekognition/aws_rekognition_client.js

@@ -0,0 +1,44 @@
+// GENERATED CODE -- DO NOT EDIT!
+
+'use strict';
+var grpc = require('grpc');
+var aws_rekognition_pb = require('./aws_rekognition_pb.js');
+
+function serialize_FaceCoordinateRequest(arg) {
+  if (!(arg instanceof aws_rekognition_pb.FaceCoordinateRequest)) {
+    throw new Error('Expected argument of type FaceCoordinateRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_FaceCoordinateRequest(buffer_arg) {
+  return aws_rekognition_pb.FaceCoordinateRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_FaceCoordinateResponse(arg) {
+  if (!(arg instanceof aws_rekognition_pb.FaceCoordinateResponse)) {
+    throw new Error('Expected argument of type FaceCoordinateResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_FaceCoordinateResponse(buffer_arg) {
+  return aws_rekognition_pb.FaceCoordinateResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+
+var FaceImageService = exports.FaceImageService = {
+  requestFaceCoordinate: {
+    path: '/FaceImage/RequestFaceCoordinate',
+    requestStream: false,
+    responseStream: false,
+    requestType: aws_rekognition_pb.FaceCoordinateRequest,
+    responseType: aws_rekognition_pb.FaceCoordinateResponse,
+    requestSerialize: serialize_FaceCoordinateRequest,
+    requestDeserialize: deserialize_FaceCoordinateRequest,
+    responseSerialize: serialize_FaceCoordinateResponse,
+    responseDeserialize: deserialize_FaceCoordinateResponse,
+  },
+};
+
+exports.FaceImageClient = grpc.makeGenericClientConstructor(FaceImageService);