Skip to content

victim login #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
dmutoni wants to merge 1 commit into
base: main
Choose a base branch
from
Open

victim login #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion config/config.env
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
NODE_ENV=development
PORT=6000
TOKEN_SECRET = $%secret()0*!RDFDShusr
TOKEN_SECRET = $%secret()0*!RDFDShusrfa%@9da(*$#)
PASSWORD = maniraguha
EMAIL = mutoni2222@gmail.com
39 changes: 0 additions & 39 deletions controllers/users.controller.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,6 @@ module.exports.createUser = asyncHandler(async (req, res) => {
res.status(422).send(validation.errors);
} else if (matched) {
const hashedPassword = await hashPassword(req.body.password);
console.log("password ", hashedPassword)
let inserts = [
uuidv4(),
req.body.first_name,
Expand All @@ -119,22 +118,18 @@ module.exports.createUser = asyncHandler(async (req, res) => {
res.status(401).send({error: err.sqlMessage})
// throw err;
} else {
console.log(results)
// results.send("row inserted");
return res.status(201).send({
error: false,
data: results,
message: 'New user has been created successfully.'
});
// console.log("Row inserted: "+ results.affectedRows);
}
});
}

})
})
module.exports.getTotalUsers = asyncHandler(async (req, res) => {
console.log("reached");
try {
await dbConnection.query("SELECT COUNT(*) AS totalUsers FROM dms_users", (err, rows, fields) => {
if (!err) {
Expand All @@ -144,7 +139,6 @@ module.exports.getTotalUsers = asyncHandler(async (req, res) => {
}
})
} catch (error) {
console.log(error);
return res.status(500).send({error: "internal server error"})
}
})
Expand All @@ -161,7 +155,6 @@ module.exports.getUsersBySector = asyncHandler(async (req, res) => {
res.send({status: false, data: err})
}
})
// console.log(report_id)
})

module.exports.getTotalUsersByDistrictID = asyncHandler(async (req, res) => {
Expand Down Expand Up @@ -202,11 +195,9 @@ module.exports.getUsersByDistrict = asyncHandler(async (req, res) => {
res.send({status: false, data: err})
}
})
// console.log(report_id)
})
module.exports.updateUser = asyncHandler(async (req, res) => {
let user_id = req.params['id'];
console.log(user_id)

user_id.trim();
// let ii_id = req.params.iid;
Expand All @@ -225,7 +216,6 @@ module.exports.updateUser = asyncHandler(async (req, res) => {
if (!matched) {
res.status(422).send(validation.errors);
} else if (matched) {
// console.log(user);
let inserts = {
first_name: req.body.first_name,
last_name: req.body.last_name,
Expand All @@ -238,7 +228,6 @@ module.exports.updateUser = asyncHandler(async (req, res) => {
user_type: req.body.user_type,
user_status: req.body.user_status
}
console.log(inserts);
if (!user_id || !inserts) {
return res.status(400).send({error: user, message: 'Please provide user and user id'});
}
Expand All @@ -257,12 +246,9 @@ module.exports.updateUser = asyncHandler(async (req, res) => {
}
})

// return res.status( 201 ).send( {error: false, data: inserts, user_id , message: 'user has been updated successfully.'} );
// console.log("Row inserted: "+ results.affectedRows);
}
;
})
console.log(printQuery);
}
});
});
Expand All @@ -275,10 +261,7 @@ module.exports.deleteUser = asyncHandler(async (req, res) => {
await dbConnection.query("UPDATE dms_users SET user_status = ? WHERE user_id = ?", [status, user_id], function (error, results, fields) {
if (error) throw error;
else {
console.log(results)
// results.send("row inserted");
return res.status(201).send({error: false, data: results, message: 'user has been delete successfully.'});
// console.l
}
});
})
Expand All @@ -296,8 +279,6 @@ const readFiles = (req, res) => {
}

module.exports.createUSerSignature = async (req, res) => {
console.log("something")
console.log(req.body.signatures)
if (!req.params) {
return res.status(400).send({success: false, data: "no provided id"})
}
Expand All @@ -313,14 +294,11 @@ module.exports.createUSerSignature = async (req, res) => {
let inserts = {
user_signature: req.file.filename
}
// console.log()
await dbConnection.query("UPDATE dms_users SET ? where user_id = ?", [inserts, user_id], function (error, results, fields) {
if (error) {
// deleteFile()
res.status(401).send({error: error.sqlMessage})
throw err;
} else {
console.log(results);
return res.status(201).send({error: false, data: inserts, message: 'user has been updated successfully.'});
}
;
Expand All @@ -332,16 +310,9 @@ let userWithSameCategory = [];
const updateNationalUsers = (req, res) => {
dbConnection.query("UPDATE dms_users SET ? where user_type = 'NATIONAL' ", [readFiles(req, res)], function (error, results, fields) {
if (error) {
// fs.unlink('images' + req.file.filename, () => {
// return res.status(404).send({ message: "error occurred" })
// })
deleteFile(req.file.filename)
return res.status(500).send({success: false, message: "error occurred"});
// res.status(401).send({ error: error.sqlMessage })
throw error;
} else {
console.log("files ", readFiles(req, res));

return res.status(201).send({
error: false,
data: readFiles(req, res),
Expand All @@ -357,16 +328,8 @@ const updateUsersWithTheSameId = (req, res, index) => {

dbConnection.query("UPDATE dms_users SET ? where user_id = ? ", [readFiles(req, res), index], function (error, results, fields) {
if (error) {
// fs.unlink('images' + req.file.filename, () => {
// return res.status(404).send({ message: "error occurred" })
// })
deleteFile(req.file.filename)
// return res.status(500).send({message: "error occurred"});
// res.status(401).send({ error: error.sqlMessage })
throw error;
} else {
console.log(results);
// return res.status(201).send({ error: false, data: results, message: 'user has been updated successfully.' });
}
;
})
Expand Down Expand Up @@ -431,8 +394,6 @@ module.exports.createLevelSignature = async (req, res) => {
}
}
exports.login = async (req, res) => {
// let user_id = req.params['id'];
// user_id.trim();
console.log(req.body)
dbConnection.query("SELECT * FROM dms_users JOIN dms_sectors ON (dms_sectors.sector_id = dms_users.sector_id) JOIN dms_districts ON (dms_districts.district_id = dms_sectors.district_id) JOIN dms_provinces ON (dms_provinces.province_id=dms_districts.province_id) WHERE email = ?",
[req.body.email], async (err, rowsFound, fields) => {
Expand Down
43 changes: 29 additions & 14 deletions controllers/victims.controller.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,13 @@
const app = require('express');
const asyncHandler = require('../middleware/async');
const {v4: uuidv4} = require('uuid');
const { v4: uuidv4 } = require('uuid');

const Router = app.Router();
const dbConnection = require('../config/db.config');
const {Validator} = require('node-input-validator');
const { Validator } = require('node-input-validator');
const { generateVictimPin } = require('../utils/functions/functions');
const {generateAuthToken} = require('../utils/tokens/generateToken')

// let payloadChecker = require('payload-validator');

// Router.get("/getAllVictims", (req, res) => {
Expand All @@ -20,7 +23,7 @@ const {Validator} = require('node-input-validator');
module.exports.getVictims = asyncHandler(async (req, res) => {
await dbConnection.query("SELECT * FROM dms_victims", (err, rows, fields) => {
if (!err) {
res.status(200).json({success: true, data: rows});
res.status(200).json({ success: true, data: rows });
} else {
console.log(err);
}
Expand All @@ -34,9 +37,9 @@ module.exports.getVictimById = asyncHandler(async (req, res) => {
dbConnection.query("SELECT * FROM dms_victims WHERE victim_id = ?",
[victim_id], function (err, rowsFound, fields) {
if (!err) {
return res.send({success: true, data: rowsFound});
return res.send({ success: true, data: rowsFound });
} else {
return res.send({success: false, data: err})
return res.send({ success: false, data: err })
}
})
})
Expand All @@ -62,10 +65,9 @@ module.exports.createVictim = asyncHandler(async (req, res) => {

validation.check().then(async (matched) => {
if (!matched) {
res.status(422).send({success: false, data: validation.errors});
res.status(422).send({ success: false, data: validation.errors });
} else if (matched) {
let victim_pin = req.body.village_id

let victim_pin = generateVictimPin();
let inserts = [
uuidv4(),
victim_pin,
Expand All @@ -82,11 +84,10 @@ module.exports.createVictim = asyncHandler(async (req, res) => {
req.body.isibo,
req.body.village_id
]
console.log("reaching");
let sql = "INSERT INTO dms_victims(victim_id,victim_pin, first_name, last_name, gender, marital_status,family_members, primary_phone_number, secondary_phone_number, national_id, is_employed, ikiciro_ubudehe, isibo, village_id) VALUES (?);";
await dbConnection.query(sql, [inserts], (err, results, fields) => {
if (err) {
res.status(401).send({error: err.sqlMessage})
res.status(401).send({ error: err.sqlMessage })
// throw err;
} else {
let returnValues = {
Expand Down Expand Up @@ -118,6 +119,20 @@ module.exports.createVictim = asyncHandler(async (req, res) => {

})
})
module.exports.loginVictim = async (req, res) => {
dbConnection.query("SELECT * FROM dms_victims WHERE victim_pin = ? AND primary_phone_number = ?",
[req.body.victim_pin, req.body.primary_phone_number], async (err, rowsFound, fields) => {
if (!err) {

if (!rowsFound.length > 0) return res.status(400).send({success: false, data: "invalid credentials "});
const userId = rowsFound[0].user_id;
const userUniqueness = rowsFound[0].primary_phone_number
return res.status(201).send({success: true, token: generateAuthToken(userId,userUniqueness )})
} else {
return res.send({success: false, data: err})
}
})
}
module.exports.updateVictim = asyncHandler(async (req, res) => {
let victim_id = req.params['id'];
victim_id.trim();
Expand Down Expand Up @@ -159,11 +174,11 @@ module.exports.updateVictim = asyncHandler(async (req, res) => {

console.log(inserts);
if (!victim_id || !inserts) {
return res.status(400).send({error: victim, message: 'Please provide victim and victim id'});
return res.status(400).send({ error: victim, message: 'Please provide victim and victim id' });
}
await dbConnection.query("UPDATE dms_victims SET ? WHERE victim_id = ?", [inserts, victim_id], function (error, results, fields) {
if (error) throw error;
return res.send({error: false, data: results, message: 'victim has been updated successfully.'});
return res.send({ error: false, data: results, message: 'victim has been updated successfully.' });
})
}
});
Expand All @@ -172,11 +187,11 @@ module.exports.deleteVictim = asyncHandler(async (req, res) => {
let victim_id = req.params['id'];
victim_id.trim();
if (!victim_id) {
return res.status(400).send({error: true, message: 'Please provide a user id'});
return res.status(400).send({ error: true, message: 'Please provide a user id' });
}
await dbConnection.query('DELETE FROM dms_victims WHERE victim_id = ?', [victim_id], function (error, results, fields) {
if (error) throw error;
return res.send({error: false, data: results, message: 'victim has been delete successfully.'});
return res.send({ error: false, data: results, message: 'victim has been delete successfully.' });
});
})

Expand Down
Loading