Thorben bender

.env

@@ -0,0 +1,2 @@
+JWT_SECRET="Super secret code"
+PORT=8000

.vscode/launch.json

@@ -0,0 +1,14 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "node",
+            "request": "launch",
+            "name": "Launch Program",
+            "program": "${workspaceFolder}\\index.js"
+        }
+    ]
+}

api/Routes/login/loginRoute.js

@@ -0,0 +1,17 @@
+const express = require('express');
+const login = require('./loginRouteHelper');
+
+const routes = express.Router();
+
+routes.post('/', async (req, res) => {
+    try {
+        message = await login(req.body);
+        if (message) {
+            res.status(200).json(message);
+        }
+    } catch (error) {
+        res.status(500).json(error);
+    }
+})
+
+module.exports = routes;

api/Routes/login/loginRoute.test.js

@@ -0,0 +1,15 @@
+const request = require('supertest');
+const db = require('../../../data/dbConfig');
+
+const server = require('../../../server/server');
+
+describe('login route', () => {
+
+    it('should login succesfull', () => {
+        return request(server)
+            .post('/login')
+            .send({ username: "Ben 8716", password: "Test" })
+            .expect('Content-Type', 'application/json; charset=utf-8')
+            .expect(200);
+    })
+})

api/Routes/login/loginRouteHelper.js

@@ -0,0 +1,18 @@
+const db = require('../../../data/dbConfig');
+const bcrypt = require('bcryptjs');
+const createToken = require('../../webtoken/webtoken');
+
+async function login(user) {
+    newUser = await db('Users').where({ username: user.username }).first();
+    if (newUser) {
+        if (user && bcrypt.compareSync(user.password, newUser.password)) {
+            const token = createToken(user);
+            return {
+                message: 'You are logged in',
+                token,
+            }
+        }
+    }
+}
+
+module.exports = login;

api/Routes/login/loginWithGoogle.js

@@ -0,0 +1,19 @@
+const passport = require('passport');
+const router = require('express').Router();
+const createToken = require('../../webtoken/webtoken');
+
+router.use(passport.initialize());
+
+router.get('', passport.authenticate('google', {
+    scope: ['profile']
+}));
+
+router.get('/redirect', passport.authenticate('google'), (req, res) => {
+    token = createToken(req.user);
+    if (token) {
+        res.status(200).json({ message: 'You are logged in', token })
+    }
+})
+
+
+module.exports = router;

api/Routes/register/registerRoute.js

@@ -0,0 +1,17 @@
+const express = require('express');
+const register = require('./registerRouteHelper');
+
+const route = express.Router();
+
+route.post('', async (req, res) => {
+    try {
+        user = await register(req.body);
+        if (user) {
+            res.status(200).json(user);
+        }
+    } catch (error) {
+        res.status(500).json(error);
+    }
+})
+
+module.exports = route;

api/Routes/register/registerRoute.test.js

@@ -0,0 +1,15 @@
+const request = require('supertest');
+const db = require('../../../data/dbConfig');
+
+const server = require('../../../server/server');
+
+
+describe('register route', () => {
+    it('should register succesfull', () => {
+        return request(server)
+            .post('/register')
+            .send({ username: `Ben ${Math.floor(Math.random() * 10000)}`, password: "Test" })
+            .expect('Content-Type', 'application/json; charset=utf-8')
+            .expect(200)
+    })
+})

api/Routes/register/registerRouteHelper.js

@@ -0,0 +1,12 @@
+const db = require('../../../data/dbConfig');
+const bcrypt = require('bcryptjs');
+
+
+
+function register(user) {
+    hash = bcrypt.hashSync(user.password, 10);
+    user.password = hash;
+    return db('Users').insert(user);
+}
+
+module.exports = register;

api/Routes/trends/trendsRoute.js

@@ -0,0 +1,25 @@
+const router = require('express').Router();
+const Twitter = require('twitter');
+
+const client = new Twitter({
+    consumer_key: '4mHbWoxb3JzcfIFUyjDlyJL6h',
+    consumer_secret: 'EJa6iru09FRUVHpI7XRcR4m1DX0XSlZIapxTZLoRabqCIUwgFF',
+    bearer_token: 'AAAAAAAAAAAAAAAAAAAAAMQL%2BAAAAAAAOZVd9ROoyKKWxmET%2FkCxS8aqrrw%3DhgbkeyZVPR7P6VtVhaY4mx25Y9aZ88jteTj3fu31vlCJURej8T',
+});
+
+router.get('', async (req, res) => {
+    try {
+        var params = { screen_name: 'nodejs', id: 1 };
+        client.get('/trends/place.json', params, function (error, tweets, response) {
+            if (!error) {
+                res.status(200).json(tweets[0].trends);
+            } else {
+                res.send(error);
+            }
+        });
+    } catch (error) {
+        res.status(500).json(error);
+    }
+})
+
+module.exports = router;

api/config/keys.js

@@ -0,0 +1,6 @@
+module.exports = {
+    google: {
+        client_id: '270161845360-vhnm28ub30m36r7622065bnk0a5h763q.apps.googleusercontent.com',
+        client_secret: 'g0ZpdQZ8iJghn77yFeN8cMY2'
+    }
+}

api/config/passport-setup.js

@@ -0,0 +1,35 @@
+const passport = require('passport');
+const GoogleStrategy = require('passport-google-oauth20');
+const keys = require('./keys');
+const db = require('../../data/dbConfig');
+const bcrypt = require('bcryptjs');
+
+passport.serializeUser((user, done) => {
+    done(null, user);
+})
+
+passport.deserializeUser((user, done) => {
+    done(null, user);
+})
+
+passport.use(
+    new GoogleStrategy({
+        callbackURL: '/login/google/redirect',
+        clientID: keys.google.client_id,
+        clientSecret: keys.google.client_secret
+    }, (accessToken, refreshToken, profile, done) => {
+        const hashed = bcrypt.hashSync(profile.id, 10);
+        profile.id = hashed;
+        db('Users').where({ username: profile.displayName }).first()
+            .then(user => {
+                if (user) {
+                    done(null, user);
+                } else {
+                    db('Users').insert({ username: profile.displayName, password: profile.id })
+                        .then(user => {
+                            done(null, user);
+                        })
+                }
+            })
+    })
+)

api/webtoken/webtoken.js

@@ -0,0 +1,15 @@
+const jwt = require('jsonwebtoken');
+
+const createToken = user => {
+    const payload = {
+        subject: user.user_id,
+        username: user.username
+    };
+    const options = {
+        expiresIn: '1h'
+    };
+    const token = jwt.sign(payload, process.env.JWT_SECRET, options);
+    return token;
+}
+
+module.exports = createToken;

data/dbConfig.js

@@ -0,0 +1,6 @@
+const knex = require('knex');
+const config = require('../knexfile');
+
+const dbEnv = process.env.DB_ENV || 'development';
+
+module.exports = knex(config[dbEnv]);

data/migrations/20190415204301_createUserTable.js

@@ -0,0 +1,14 @@
+
+exports.up = function (knex, Promise) {
+    return knex.schema.createTable('Users', table => {
+        table.increments('user_id');
+
+        table.string('username').unique().notNullable();
+
+        table.string('password').notNullable();
+    })
+};
+
+exports.down = function (knex, Promise) {
+    return knex.schema.dropTableIfExists('Users');
+};

data/migrations/20190416205506_searchTable.js

@@ -0,0 +1,14 @@
+
+exports.up = function (knex, Promise) {
+    return knex.schema.createTable('Searches', table => {
+        table.increments('search_id');
+
+        table.string('search_message').notNullable();
+
+        table.integer('User').references('user_id').inTable('Users');
+    })
+};
+
+exports.down = function (knex, Promise) {
+    return knex.schema.dropTableIfExists('Searches');
+};

index.js

@@ -0,0 +1,10 @@
+require('dotenv').config();
+const server = require('./server/server');
+const passportSetup = require('./api/config/passport-setup');
+
+port = process.env.PORT || 8000
+
+
+server.listen(port, () => {
+    console.log(`Server listening on http://localhost:${port}`);
+})