Add files via upload

Author: Mansvini

Dockerfile

@@ -0,0 +1,9 @@
+FROM node:16
+
+WORKDIR /usr/src/smartbrainapi
+
+COPY ./ ./
+
+RUN npm install
+
+CMD [ "/bin/bash" ]

controllers/authorization.js

@@ -0,0 +1,17 @@
+import redisClient from '../server.js';
+
+const requireAuth=(req, res, next)=>{
+    const {authorization}=req.headers;
+    if(!authorization) {
+        return res.status(401).json('Unauthorized');
+    }
+    return redisClient.get(authorization, (err, reply)=>{
+        if(err || !reply){
+            return res.status(401).json('Unauthorized')
+        }
+        console.log('you shall pass!');
+        return next();
+    })
+}
+
+export default requireAuth;

controllers/image.js

@@ -0,0 +1,21 @@
+import Clarifai from 'clarifai';
+
+const app = new Clarifai.App({
+  apiKey: '57f9910d75c54e98a69894833187303c'
+});
+
+export const handleApiCall=(req, res)=>{
+	app.models.predict(Clarifai.FACE_DETECT_MODEL, req.body.input)
+		.then(data=>res.json(data))
+		.catch(err=>res.status(400).json('unable to work with API'))
+}
+
+
+export const handleImage=(req, res, db)=>{
+	const {id}=req.body;
+	return db('users').where('id','=',id)
+	.increment('entries', 1)
+	.returning('entries')
+	.then(entries=>res.json(entries[0].entries))
+	.catch(err=>res.status(400).json('unable to get entries'))
+}

controllers/profile.js

@@ -0,0 +1,29 @@
+export const handleProfileGet=(req, res, db)=>{
+	const {id}=req.params;
+	return db.select('*').from('users').where({id
+		// id:id
+	})
+		.then(user=>{
+			if(user.length){
+				res.json(user[0]);
+			} else{
+				res.status(400).json('User not found');
+			}
+		})
+		.catch(err=>res.status(400).json('error getting user'))
+}
+
+export const handleProfileUpdate=(req, res, db)=>{
+	const {id}= req.params;
+	const {name, age, pet}=req.body.formInput;
+	db('users').where({id}).update({name, age, pet})
+		.then(resp=>{
+			if(resp){
+				res.json('success')
+			}
+			else{
+				res.status(400).json('Unable to update')
+			}
+		})
+		.catch(err=>res.status(400).json('error updating user'))
+}

controllers/register.js

@@ -0,0 +1,46 @@
+import {getAuthTokenId, createSession } from './signin.js';
+
+const handleRegister=(req, res, db, bcrypt)=>{
+	const {name, email, password}=req.body;
+	if(!email || !name || !password){
+		return Promise.reject('incorrect form submission');
+	}
+	const hash = bcrypt.hashSync(password);
+
+	return db.transaction(trx =>{
+		trx.insert({
+			email:email,
+			hash:hash
+		})
+		.into('login')
+		.returning('email')
+		.then(loginEmail=>{
+			return trx('users')
+			.returning('*')
+			.insert({
+				name:name,
+				email:loginEmail[0].email,
+				joined: new Date()
+			})
+				.then(response=> {
+					return response[0]})
+		})
+			.then(trx.commit)
+			.catch(trx.rollback)
+	})
+		.catch(err=>Promise.reject('unable to register'))
+}
+
+const register=(db, bcrypt)=>(req, res)=>{
+	const {authorization} =req.headers;
+	return authorization? getAuthTokenId(req, res) :
+		handleRegister(req, res, db, bcrypt)
+		.then (data=>{
+			return data.id && data.email ? createSession(data) : Promise.reject(data)
+		})
+		.then (session=> {
+			res.json(session)})
+		.catch(err=>res.status(400).json(err))
+}
+
+export default register;

controllers/signin.js

@@ -0,0 +1,63 @@
+import jwt from "jsonwebtoken";
+import redisClient from '../server.js';
+
+const handleSignIn=(db, bcrypt, req, res)=>{
+	const {email, password}=req.body;
+	if(!email || !password){
+		return Promise.reject('incorrect form submission');
+	}
+	return db.select('email', 'hash').from('login')
+			.where('email', '=', email)
+			.then(data=>{
+				const isValid=bcrypt.compareSync(password, data[0].hash)
+				if(isValid) {
+					return db.select('*').from('users')
+					.where('email', '=', email)
+						.then(user=>user[0])
+						.catch(err=>Promise.reject('unable to get user'))
+				} else {
+					Promise.reject('invalid credentials')
+				}
+			})
+			.catch(err=>Promise.reject('invalid credentials'))
+}
+
+export const getAuthTokenId=(req, res)=>{
+	const {authorization}=req.headers;
+	return redisClient.get(authorization, (err, reply)=>{
+		if(err || !reply){
+			return res.status(400).json('Unauthorised');
+		}
+		return res.json({id: reply})
+	})
+}
+
+const signToken=(email)=>{
+	const jwtPayload = {email};
+	return jwt.sign(jwtPayload, 'JWT_SECRET');
+}
+
+const setToken=(key, value)=>{
+	return Promise.resolve(redisClient.set(key, value))
+}
+
+export const createSession=(user)=>{
+	const {email, id} = user;
+	const token= signToken(email);
+	return setToken(token, id)
+		.then (()=>{
+			return {success: 'true', userId: id, token}
+		})
+		.catch(console.log)
+}
+
+export const signinAuthentication=(db, bcrypt)=>(req, res)=>{
+	const {authorization} =req.headers;
+	return authorization? getAuthTokenId(req, res) :
+		handleSignIn(db, bcrypt, req, res)
+		.then (data=>{
+			return data.id && data.email ? createSession(data) : Promise.reject(data)
+		})
+		.then (session=> res.json(session))
+		.catch(err=>res.status(400).json(err))
+}

controllers/signout.js

@@ -0,0 +1,9 @@
+import redisClient from '../server.js';
+
+const handleSignOut=((req, res)=>{
+    const {authorization}=req.headers;
+    redisClient.del(authorization);
+    res.json('successfully logged out');
+})
+
+export default handleSignOut;

docker-compose.yml

@@ -0,0 +1,32 @@
+services:
+
+  # Backend API
+  smartbrainapi:
+    container_name: backend
+    build: ./
+    command: npm start
+    working_dir: /usr/src/smartbrainapi
+    environment:
+      POSTGRES_URI: postgres://admin:password@postgres:5432/smartbrain
+      REDIS_URI: redis://redis:6379
+    ports:
+      - "3000:3000"
+    volumes:
+      - ./:/usr/src/smartbrainapi
+    
+  # Postgres
+  postgres:
+    environment:
+      POSTGRES_USER: admin
+      POSTGRES_PASSWORD: password
+      POSTGRES_DB: smartbrain
+      POSTGRES_HOST: postgres
+    build: ./postgres
+    ports:
+      - "5432:5432"
+
+  # Redis
+  redis:
+    image: redis
+    ports: 
+      - "6379:6379"