serverless-challenge/handler.js at master · Mrthnx/serverless-challenge · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
'use strict';

const { Employer } = require('./entities/employer');
const { employerUpdateValidate, employerCreateValidate } = require('./validation/employer')
const {
  getParamIdOfEvent,
  buildFilterEmployerFind,
  responseErrorServerInternal,
  responseNotFound,
  responseSuccess,
  responseError,
  isArrayEmptyOrNull
} = require('./utils/utils');

module.exports.getEmployer = async (event) => {
  try {
    const employerId = getParamIdOfEvent( event );

    const filterEmployer = buildFilterEmployerFind( employerId );

    const employers = await Employer.findAll(filterEmployer);

    if( isArrayEmptyOrNull( employers ) ) {
      return responseNotFound();
    }else {
      return responseSuccess( employers );
    }

  } catch (error) {
    console.error('Error:', error);
    return responseErrorServerInternal();
  }
};

module.exports.postEmployer = async (event) => {
  try {
    const bodyEmployer = event.body?JSON.parse(event.body):null;

    const {error} = await employerCreateValidate( bodyEmployer );

    if (error) {
      return responseErrorValidation(error);
    }

    const response = await Employer.create( bodyEmployer );

    if( response != 0 ) {
      return responseSuccess(_, 'Registro creado');
    }else {
      return responseError('Error al crear registro');
    }

  } catch (error) {
    console.error('Error:', error);
    return responseErrorServerInternal();
  }
};

module.exports.patchEmployer = async (event) => {
  try {
    const bodyEmployer = event.body?JSON.parse(event.body):null;

    const {error} = await employerUpdateValidate( bodyEmployer );

    if (error) {
      return responseErrorValidation(error);
    }

    const response = await Employer.update( {
      ...bodyEmployer, fechamodificacion: new Date()
    }, {
      where: {id: bodyEmployer.id, estado: true}
    } );

    if( response != 0 ) {
      return responseSuccess(_, 'Registro actualizado');
    }else {
      return responseError('Error al actualizar registro');
    }

  } catch (error) {
    console.error('Error:', error);
    return responseErrorServerInternal();
  }
};

module.exports.deleteEmployer = async (event) => {
  try {
    let employerId = getParamIdOfEvent(event);

    const response = await Employer.update({
      estado: false, fechamodificacion: new Date
    }, {
      where: {id: employerId, estado: true}
    });

    if( response != 0 ) {
      return responseSuccess(_, 'Registro eliminado');
    }else {
      return responseNotFound();
    }

  } catch (error) {
    console.error('Error:', error);
    return responseErrorServerInternal();
  }
};