server.js

import express from 'express';
import mysql from 'mysql';
import bodyParser from 'body-parser';
import Chatkit from '@pusher/chatkit-server';
import * as admin from 'firebase-admin';
import cors from 'cors';
import dotenv from 'dotenv';
dotenv.config({ path: '.env' });

const app = express();
const port = process.env.PORT;

let connection = mysql.createConnection({
  host: 'localhost',
  user: 'arakappa',
  password: process.env.DATABASE_PASSWORD,
  database: 'kashitaru',
});
connection.connect();

admin.initializeApp({                                       // Admin SDKを初期化
  credential: admin.credential.applicationDefault(),
  databaseURL: "https://kashitaru-434fb.firebaseio.com"
});

const chatkit = new Chatkit({
  instanceLocator: process.env.CHATKIT_INSTANCE_LOCATOR,
  key: process.env.CHATKIT_SECRET_KEY,
});


app.use(cors());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());


app.post('/api/share', (request, response) => {
  const {
    id,
    productName,
    productImgUrl,
    description,
    price,
    period,
    shippingArea,
    days,
  } = request.body;


  connection.query('INSERT INTO product SET ?',
    { id: id, productImg: `${productImgUrl}`, productName: `${productName}`, description: `${description}`, price: `${price}`, period: `${period}`, shippingArea: `${shippingArea}`, days: `${days}` },
    (error, results, fields) => {
      response.status(200).send('success!!');
    });


});

app.get('/api/share', (request, response) => {
  connection.query('SELECT * FROM `product` INNER JOIN `user` ON product.id = user.id', (error, results, fields) => {
    let resResults = [];
    for (let i = 0; i < results.length; i++) {
      let rslts = results[i];
      delete rslts.uid;
      resResults = resResults.concat(rslts)
    }
    response.status(200).send(resResults);
  });
});

// getProfile
app.post('/api/postProfileData', (request, response) => {
  const { id } = request.body;
  const columns = ['id', 'name', 'avatar', 'comment'];
  let resResults = {};
  connection.query('SELECT ?? FROM `user` WHERE id = ?', [columns, id], (error, results, fields) => {
    resResults.user = results[0];
    connection.query('SELECT * FROM `product` WHERE id =?', [id], (error, results, fields) => {
      resResults.product = results;
      response.status(200).send(resResults);
    });
  });
});

// signUp
app.post('/api/setUid', (request, response) => {
  const { idToken } = request.body;

  admin.auth().verifyIdToken(idToken)     // アクセストークンを受け取りユニークキーであるuidを受け取る。これが今までのnameとmailAddressになる
    .then((decodedToken) => {
      let uid = decodedToken.uid;

      connection.query('INSERT INTO user set ?', { uid: `${uid}` }, (error, results, fields) => {     // サインアップでは単純に新規ユーザーを登録するだけ。
        // console.log('set Succsee!!');                                                                  // プロフィール設定は行わない。
      });
      response.status(200).send('signUp success!!');
    }).catch(function (error) {
      console.log(error);
    });

});

// signIn
app.post('/api/getCurrentUser', (request, response) => {
  const { idToken } = request.body;

  admin.auth().verifyIdToken(idToken)
    .then((decodedToken) => {
      const gotUid = decodedToken.uid;
      const columns = ['id', 'name'];

      connection.query('SELECT ?? FROM `user` WHERE `uid` = ?', [columns, `${gotUid}`], (error, results, fields) => {
        response.status(200).send(results);
      });
    });

});

app.post('/api/updateUser', (request, response) => {
  const {
    idToken,                           // サーバ側でアクセストークンを元にuidを生成
    profileName,
    profileComment,
    avatarImg
  } = request.body;
  console.log(avatarImg)

  admin.auth().verifyIdToken(idToken)
    .then((decodedToken) => {
      let gotUid = decodedToken.uid;

      connection.query('UPDATE `user` SET `name` = ?, `comment` = ?, `avatar` = ? WHERE `uid` = ?',      // ユーザー情報をアップデート   // 更新の際にavatarImgの古いほうをfirebaseから消すようにしたい
        [`${profileName}`, `${profileComment}`, `${avatarImg}`, `${gotUid}`],
        (error, results, fields) => {
          connection.query('SELECT * FROM `user` WHERE `uid` = ?', [`${gotUid}`], (error, results, fields) => {    // 更新したユーザー情報を取得
            const rslt = results[0]
            delete rslt.uid;                                 // uid削除
            response.status(200).send(rslt);
          });
        });
    });
});

app.post('/api/user/shareInformation', (request, response) => {
  const { id } = request.body;

  connection.query('SELECT * FROM `product` WHERE `id` = ?', [id], (error, results, fields) => {
    console.log(results);
    response.status(200).send(results);
  });
});

// chatKitの設定
app.post('/users', (req, res) => {
  const { userId } = req.body;

  chatkit
    .createUser({
      id: userId,
      name: userId,
    })
    .then(() => {
      res.sendStatus(201);
    })
    .catch(err => {
      if (err.error === 'services/chatkit/user_already_exists') {
        console.log(`User already exists: ${userId}`);
        res.sendStatus(200);
      } else {
        res.status(err.status).json(err);
      }
    });
});

app.post('/authenticate', (req, res) => {
  const authData = chatkit.authenticate({
    userId: req.query.user_id,
  });
  res.status(authData.status).send(authData.body);
});


app.listen(port, err => {
  if (err) throw new Error(err)
  else console.log(`listening on port ${port}`)
});