'use strict';

let Pegawai = require('../domains/pegawai');

let PegawaiRepository = function(db){
  this.db = db;
};

PegawaiRepository.prototype = {
  save: function(s, cb, errCb){
    let db = this.db;
    let data = {nip: s.nip, nama: s.nama, tmp_lhr: s.tmp_lhr};
    let query = 'INSERT INTO tbpegawai SET ?';
    db.query(query, data, (err, results) => {
      if(err){
        errCb(err);
      }
      cb(results);
    });
  },

  update: function(s, cb, errCb){
    let db = this.db;
    let data = [s.nama, s.tmp_lhr, s.nip];
    let query = 'UPDATE tbpegawai SET nama = ?, tmp_lhr = ? WHERE nip = ?';
    db.query(query, data, (err, results) => {
      if(err){
        errCb(err);
      }
      cb(results);
    });
  },

  delete: function(nip, cb, errCb){
    let db = this.db;
    let query = 'DELETE FROM tbpegawai WHERE nip = ?';
    db.query(query, [nip], (err, results) => {
      if(err){
        errCb(err);
      }
      cb(results);
    });
  },

  findOne: function(nip, cb, errCb){
    let db = this.db;
    let query = 'SELECT * FROM tbpegawai WHERE nip = ?';
    db.query(query, [nip], (err, results, fields) => {
      if(err){
        errCb(err);
      }
      if(!results){
        cb(`Data dengan NIP ${nip}, tidak di temukan`);
      }else{
        let s = results[0];
        let pegawai = new Pegawai(s.nip, s.nama, s.tmp_lhr);
        cb(pegawai);
      }
    });
  },

  findAll: function(cb, errCb){
    let db = this.db;
    let query = 'SELECT * FROM tbpegawai';
    db.query(query, (err, results, fields) => {
      if(err){
        errCb(err);
      }
      if(!results){
        cb('tabel pegawai kosong');
      }else{
        let pegawaiArray = [];
        for(let i=0;i<results.length;i++){
          let s = results[i];
          let pegawai = new Pegawai(s.nip, s.nama, s.tmp_lhr);
          pegawaiArray.push(pegawai);
        }
        cb(pegawaiArray);
      }
    });
  }
};

module.exports = PegawaiRepository;