express-lib

제작이유

serverlessExpress에서 공통된 기능 배포시 불편함 해결위해 제작

업데이트 내용

• v3.0.1

라이브러리 최신화 제거된 기능 제거

iot 추가

사용법

새버전 공지시

각 프로젝트의 cloud9에서

1cd /home/ec2-user/environment/server/ServerlessExpress
2npm install --save @psyrenpark/express-lib

• 이후 최신버전으로 변경되었는지 확인할것.

미들웨어 적용

1var { awsMiddleware, httpMiddleware } = require("@psyrenpark/express-lib");
2
3app.use(require(`${__dirname}/middleware/db`));
4app.use(require(`${__dirname}/middleware/auth`));
5
6// 미들웨어 db와 auth 다음
7app.use(awsMiddleware); // aws 관련 함수
8app.use(httpMiddleware); // 통신 관련 함수

회원 탈퇴

• 서버 담장자는 클라이언트에서 유저 퇄퇴 기능을 요청 받을경우 아래와같이 작성할것
• 유저의 탈퇴는 디비와 코그니토가 연동되어 있으므로 조심할것
• 먼저 디비 해당유저의 정보를 비활성후 성공후 코그니토 deleteUser를 실행할것
• deleteUser는 롤백기능이 없음
• 클라이언트는 이 api가 성공후 꼭 반드시 로그아웃후 redux, context안의 유저 정보 정리할것
• 서버관리자에게 USER_POOL_ID 관련 작업 요청할것

1app.delete("/user/:user_no", async function (req, res) {
2  var result = [];
3  let transaction;
4
5  if (req.user_no !== req.param.user_no) {
6    res.status(403).send({ msg: "wrong" });
7    return;
8  }
9
10  try {
11    transaction = await req.sequelize.transaction();
12
13    var qeury_Deactive = req.mybatisMapper.getStatement(
14      "SQL",
15      "USER_DEATIVE",
16      {
17        user_id: req.user_id,
18        user_no: req.user_no,
19      },
20      { language: "sql", indent: "  " }
21    );
22
23    var deactiveUserData = await req.sequelize.query(qeury_Deactive, {
24      transaction: transaction,
25      type: req.sequelize.QueryTypes.SELECT,
26    });
27
28    if (deactiveUserData.length !== 1) {
29      throw new Error("wrong params");
30    }
31
32    var deleteUserData = await req.cognito.deleteUser({
33      //주의: 배포해야 지만 작동함 (권한필요)
34      username: req.user_id, //코그니토 고유 id
35    });
36
37    await transaction.commit();
38
39    res.json({
40      msg: "ok",
41    });
42  } catch (error) {
43    if (error) await transaction.rollback();
44    res.status(403).send({ msg: "wrong", error: error });
45  }
46});

이메일 전송

1app.post("/send_email", async function (req, res) {
2  var param = {
3    email: "test9999@ruu.kr", // req.user_info.email
4    msg: "인증코드 <h2>123456</h2>", // html 문법 사용가능
5    title: "싸이페어 인증메일입니다.", // 싸이페어 인증입니다.
6    type: "HTML", // default   type : "TEXT"
7  };
8
9  try {
10    var result = await req.ses.sendEmail(param);
11
12    res.json({
13      msg: "ok",
14    });
15  } catch (error) {
16    res.status(403).send({ msg: "wrong", error: error });
17  }
18});

문자 전송

1app.post("/send_sms", async function (req, res) {
2  var param = {
3    phone: "01000000000", //
4    msg: "인증코드 123456",
5    title: "싸이페어 인증문자입니다.",
6  };
7
8  try {
9    var result = await req.sms.sendSMS(param);
10
11    res.json({
12      msg: "ok",
13    });
14  } catch (error) {
15    res.status(403).send({ msg: "wrong", error: error });
16  }
17});

cdn clear

1app.post("/clear_cdn", async function (req, res) {
2  try {
3    var nowDate = new Date();
4    var nowTimestamp = "" + Math.round(nowDate);
5
6    var params = {
7      DistributionId: "E3NS7RWWXZFBWI", // 필요시 요청할 것
8      InvalidationBatch: {
9        CallerReference: nowTimestamp,
10        Paths: {
11          Quantity: "1",
12          Items: [
13            `/*`,
14            // `public/test/result/${country}/${test}/${fileName}`,
15          ],
16        },
17      },
18    };
19
20    var data = await req.cloudfront.clearCdn(params);
21
22    console.log(data);
23  } catch (error) {
24    console.log(error);
25  }
26
27  res.json({
28    msg: "test_test_test13-2 ok",
29  });
30});

푸쉬

s3 업로드

s3 인증 다운로드 링크