UNFR/postauto
1
0
Fork 0
Code

ajout variable nom de table sql

Browse Source
This commit is contained in:
unfr 2025-08-08 22:01:26 +02:00
parent 13a887bc5e
commit 724c263203
5 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
autopost/conf.sh
View File

@ -17,6 +17,7 @@ NG_PASS=""
NG_NBR_CONN=""
dbtype="sqlite" # ou "mysql"
MYSQL_TABLE="" # OBLIGATOIRE
DB_FILE="/home/$USER/autopost/base_autopost.db"
MYSQL_HOST=""
MYSQL_PORT=
@ -25,3 +26,4 @@ MYSQL_PASS=""
MYSQL_DB=""

1
autopost/config.js
View File

@ -15,6 +15,7 @@ module.exports = {
DB_USER: '',
DB_PASSWORD: '',
DB_DATABASE: '',
DB_TABLE: '',
// Chemins personnalisables pour les dossiers
finishdirectory: path.join(__dirname, 'FINIS'),

8
autopost/posteur.sh
View File

@ -37,7 +37,7 @@ while true; do
autopost_file=$(echo "$autopost_json" | jq -r '.autopost')
if [[ "$autopost_file" == "0" ]]; then
verif=$(db_query "SELECT id, nom FROM \`release\` WHERE status = 0 LIMIT 1;")
verif=$(db_query "SELECT id, nom FROM \`$MYSQL_TABLE\` WHERE status = 0 LIMIT 1;")
if [ -n "$verif" ]; then
id=$(echo "$verif" | awk -F "|" '{print $1}' | xargs)
name=$(echo "$verif" | awk -F "|" '{print $2}' | xargs)
@ -51,7 +51,7 @@ while true; do
ret=$?
if [ $ret -ne 0 ]; then
echo -e "${ROUGE}Erreur parpar (code $ret). Marquage en échec.${NORMAL}" | tee -a "$LOG"
db_query "UPDATE \`release\` SET status = 2 WHERE id = ${id};"
db_query "UPDATE \`$MYSQL_TABLE\` SET status = 2 WHERE id = ${id};"
rm -f "${FILESANSEXT}.par2" "${FILESANSEXT}.vol*"
continue
fi
@ -79,7 +79,7 @@ while true; do
if [[ ${nzbsizebit} -le ${jsonsizebit} ]] || [[ ${nzbsizebit} = "NAN" ]]; then
echo -e "${ROUGE}PROBLEME TAILLE NZB${NORMAL}"
rm "${DOSSIER_NZB_ATTENTE}${FILESANSEXT}.nzb" "${FILESANSEXT}.par2" "${FILESANSEXT}.vol*"
db_query "UPDATE \`release\` SET status = 2 WHERE id = ${id};"
db_query "UPDATE \`$MYSQL_TABLE\` SET status = 2 WHERE id = ${id};"
else
echo -e "${CYAN}ENVOI SUR LE SITE${NORMAL}"
if [[ "${name}" =~ \.(iso)$ ]]; then
@ -104,7 +104,7 @@ while true; do
mv "${DOSSIER_NZB_ATTENTE}${FILESANSEXT}.7z" "${DOSSIER_NZB_FINAL}${first_char}/"
rm -rf "${FILESANSEXT}"*
rm "${DOSSIER_NZB_ATTENTE}${FILESANSEXT}.nzb"
db_query "UPDATE \`release\` SET status = 1 WHERE id = ${id};"
db_query "UPDATE \`$MYSQL_TABLE\` SET status = 1 WHERE id = ${id};"
echo -e "${VERT}FIN DE TRAITEMENT DE ${FILESANSEXT}${NORMAL}"
fi
else

10
autopost/server.js
View File

@ -91,12 +91,12 @@ autopostRouter.get('/', async (req, res) => {
try {
// Récupérer le nombre total d'enregistrements
const [countResult] = await db.query("SELECT COUNT(*) as total FROM `release`");
const [countResult] = await db.query("SELECT COUNT(*) as total FROM \`${config.DB_TABLE}\`");
const totalRecords = countResult[0].total;
const totalPages = Math.ceil(totalRecords / limit);
const [rows] = await db.query(
"SELECT nom, status, id FROM `release` ORDER BY (status = 2) DESC, id DESC LIMIT ? OFFSET ?",
"SELECT nom, status, id FROM \`${config.DB_TABLE}\` ORDER BY (status = 2) DESC, id DESC LIMIT ? OFFSET ?",
[limit, offset]
);
@ -456,7 +456,7 @@ autopostRouter.get('/search', async (req, res) => {
const searchQuery = "%" + q + "%";
try {
const [rows] = await db.query(
"SELECT nom, status, id FROM `release` WHERE nom LIKE ? ORDER BY id DESC LIMIT 500",
"SELECT nom, status, id FROM \`${config.DB_TABLE}\` WHERE nom LIKE ? ORDER BY id DESC LIMIT 500",
[searchQuery]
);
res.json(rows);
@ -576,7 +576,7 @@ autopostRouter.post('/edit/:id', async (req, res) => {
const id = req.params.id;
const newStatus = req.body.status;
try {
await db.query("UPDATE `release` SET status = ? WHERE id = ?", [newStatus, id]);
await db.query("UPDATE \`${config.DB_TABLE}\` SET status = ? WHERE id = ?", [newStatus, id]);
if (req.xhr || req.headers.accept.indexOf('json') > -1) {
res.json({ success: true });
} else {
@ -592,7 +592,7 @@ autopostRouter.post('/edit/:id', async (req, res) => {
autopostRouter.post('/delete/:id', async (req, res) => {
const id = req.params.id;
try {
await db.query("DELETE FROM `release` WHERE id = ?", [id]);
await db.query("DELETE FROM \`${config.DB_TABLE}\` WHERE id = ?", [id]);
if (req.xhr || req.headers.accept.indexOf('json') > -1) {
res.json({ success: true });
} else {

8
bin/postauto
View File

@ -12,7 +12,7 @@ checkdb() {
fi
else
# Vérifie si la table existe, sinon crée-la
exists=$(db_query "SHOW TABLES LIKE 'release';")
exists=$(db_query "SHOW TABLES LIKE \`$MYSQL_TABLE\`;")
if [ -z "$exists" ]; then
echo "La table 'release' n'existe pas. Création..."
do_createdb
@ -168,8 +168,8 @@ do_createdb() {
if [ "$dbtype" = "mysql" ]; then
mysql --default-character-set=utf8mb4 -h "$MYSQL_HOST" -P "$MYSQL_PORT" -u "$MYSQL_USER" -p"$MYSQL_PASS" -e "CREATE DATABASE IF NOT EXISTS \`$MYSQL_DB\` DEFAULT CHARACTER SET utf8mb4;"
mysql --default-character-set=utf8mb4 -h "$MYSQL_HOST" -P "$MYSQL_PORT" -u "$MYSQL_USER" -p"$MYSQL_PASS" -D "$MYSQL_DB" -e "
DROP TABLE IF EXISTS \`release\`;
CREATE TABLE \`release\` (
DROP TABLE IF EXISTS \`$MYSQL_TABLE\`;
CREATE TABLE \`$MYSQL_TABLE\` (
id INT PRIMARY KEY AUTO_INCREMENT,
nom VARCHAR(255) NOT NULL,
status INT NOT NULL DEFAULT 0
@ -182,7 +182,7 @@ CREATE TABLE \`release\` (
fi
fi
sqlite3 "$DB_FILE" <<EOF
CREATE TABLE \`release\` (
CREATE TABLE \`$MYSQL_TABLE\` (
id INTEGER PRIMARY KEY AUTOINCREMENT,
nom TEXT NOT NULL,
status INTEGER NOT NULL DEFAULT 0 CHECK(status IN (0, 1, 2, 3))