379 lines
10 KiB
JavaScript
379 lines
10 KiB
JavaScript
var express = require('express');
|
|
var router = express.Router();
|
|
var sqlite3 = require('sqlite3');
|
|
var Masto = require('mastodon');
|
|
const accounts_to_select = [
|
|
{
|
|
label: "tykayn",
|
|
value: "tykayn"
|
|
},
|
|
{
|
|
label: "modominem",
|
|
value: "modominem"
|
|
},
|
|
{
|
|
label: "qzine",
|
|
value: "qzine"
|
|
},
|
|
{
|
|
label: "curator",
|
|
value: "curator"
|
|
},
|
|
{
|
|
label: "kurator",
|
|
value: "kurator"
|
|
},
|
|
{
|
|
label: "voix du nucléaire",
|
|
value: "voixdunucleaire"
|
|
},
|
|
{
|
|
label: "The greatest Meme",
|
|
value: "meme"
|
|
},
|
|
{
|
|
label: "cil de gometz",
|
|
value: "cil_gometz"
|
|
},
|
|
]
|
|
const default_times = ['08:02:00', '08:42:00', '09:10:00', '09:15:00', '10:22:00', '12:22:00']
|
|
const database_masto = "mastodon_multi_accounts.db"
|
|
/* GET home page. */
|
|
let schedule_time = '';
|
|
|
|
router.get('/', function (req, res, next) {
|
|
|
|
if (!req.body.schedule_time) {
|
|
|
|
|
|
schedule_time = default_times[Math.floor(Math.random() * default_times.length)];
|
|
}
|
|
res.render('index', {accounts_to_select, reqBody: req.body, schedule_time});
|
|
});
|
|
|
|
|
|
// publier un message avec un certain compte
|
|
router.get('/publish', function (req, res, next) {
|
|
res.render('index', {title: 'Express'});
|
|
});
|
|
|
|
|
|
const connect = require('@databases/sqlite');
|
|
const {sql} = require('@databases/sqlite');
|
|
const {runOnChangeOnly} = require("nodemon/lib/config/defaults");
|
|
const fs = require("fs");
|
|
|
|
const db = connect(database_masto);
|
|
|
|
|
|
function createDatabase() {
|
|
var newdb = new sqlite3.Database(database_masto, sqlite3.OPEN_READWRITE | sqlite3.OPEN_CREATE, (err) => {
|
|
|
|
createTables(newdb);
|
|
})
|
|
}
|
|
|
|
function createTables(newdb) {
|
|
async function prepare() {
|
|
await db.query(sql`
|
|
create table posts_scheduled
|
|
(
|
|
action_id integer
|
|
constraint posts_scheduled_pk
|
|
primary key autoincrement,
|
|
post_username varchar not null,
|
|
content varchar not null,
|
|
medias varchar,
|
|
datetime datetime
|
|
);
|
|
|
|
create unique index posts_scheduled_action_id_uindex
|
|
on posts_scheduled (action_id);
|
|
|
|
insert into posts_scheduled
|
|
values (NULL, "modominem", "un message d'example", NULL);
|
|
|
|
`);
|
|
console.log('requête de création faite')
|
|
}
|
|
|
|
const prepared = prepare();
|
|
}
|
|
|
|
// ajouter un message à la file d'attente avec un certain compte
|
|
router.post('/add-to-queue', function (req, res, next) {
|
|
// get account
|
|
// get content*
|
|
// add to sql DB
|
|
|
|
// insert into posts_scheduled
|
|
// values (NULL, "modominem", "un message d'example", NULL);
|
|
var db = new sqlite3.Database(database_masto, sqlite3.OPEN_READWRITE | sqlite3.OPEN_CREATE, (err) => {
|
|
}
|
|
)
|
|
db.serialize(() => {
|
|
db.run('INSERT INTO posts_scheduled VALUES(?,?,?,?,?)', [null, req.body.author, req.body.message, req.body.fichier, null], function (err) {
|
|
if (err) {
|
|
return console.log(err.message);
|
|
res.render('index', {message: 'erreur ' + err.message});
|
|
|
|
}
|
|
console.log("nouveau post ajouté", req.body.author, req.body.message);
|
|
|
|
res.render('index', {message: 'message ajouté OK'});
|
|
|
|
});
|
|
});
|
|
|
|
|
|
});
|
|
|
|
|
|
function getAllPosts(db) {
|
|
return db.query(sql`SELECT *
|
|
FROM posts_scheduled
|
|
ORDER BY action_id DESC LIMIT 15;`)
|
|
}
|
|
|
|
router.get('/init-db', function (req, res, next) {
|
|
var db = new sqlite3.Database(database_masto, sqlite3.OPEN_READWRITE | sqlite3.OPEN_CREATE, (err) => {
|
|
console.log('got to create db')
|
|
createDatabase()
|
|
}
|
|
)
|
|
res.render('created_db', {});
|
|
});
|
|
|
|
router.get('/list', function (req, res, next) {
|
|
|
|
// let posts_list = [{
|
|
// action_id: 1,
|
|
// post_username: "modominem",
|
|
// content: "demo post list",
|
|
// medias: "media file name from assets folder",
|
|
// date_schedule: "2022-07-07 "
|
|
// }]
|
|
|
|
getAllPosts(db).then(
|
|
(results) => {
|
|
console.log("liste de posts ", results)
|
|
res.render('database', {posts_list: results});
|
|
},
|
|
(err) => console.error(err),
|
|
);
|
|
});
|
|
|
|
|
|
router.get('/add-example', function (req, res, next) {
|
|
// let db = connect(database_masto);
|
|
|
|
async function prepare() {
|
|
await db.query(sql`
|
|
insert into posts_scheduled
|
|
values (NULL, "modominem", "un message d'example", "image.jpg", NULL)
|
|
;
|
|
`).then(resp => {
|
|
console.log(resp)
|
|
|
|
let posts_list = []
|
|
res.redirect('/list')
|
|
},
|
|
err => {
|
|
console.log(err)
|
|
});
|
|
}
|
|
|
|
const prepared = prepare();
|
|
|
|
}
|
|
);
|
|
|
|
require('dotenv').config();
|
|
|
|
// publier le message en db dans la file
|
|
router.get('/publish-last-entry', function (req, res, next) {
|
|
|
|
var OAuth2 = require('oauth').OAuth2;
|
|
|
|
// console.log('process.env' , process.env)
|
|
var oauth = new OAuth2(process.env.APP_ID, process.env.SECRET, process.env.INSTANCE_MASTODON, null, '/oauth/token');
|
|
var url = oauth.getAuthorizeUrl({
|
|
redirect_uri: 'urn:ietf:wg:oauth:2.0:oob',
|
|
response_type: 'code',
|
|
scope: 'read write follow'
|
|
});
|
|
console.log('url ', url)
|
|
|
|
let status = "#mastoart of @tykayn"
|
|
let visibility = "unlisted" // public, unlisted, private, direct.
|
|
let media_filename = "colline.JPG"
|
|
let file_path = "assets/not_published/" + media_filename
|
|
let accessToken = process.env.TOKEN
|
|
let sensitive = false;
|
|
let scheduled_at = "2022-07-07T21:36:29.100Z";
|
|
let account_id = "2974"; // curator bliss
|
|
let language = "fr";
|
|
|
|
let enable_post = false;
|
|
|
|
// Get the user to open up the url in their browser and get the code
|
|
// oauth.getOAuthAccessToken('code from the authorization page that user should paste into your app',
|
|
// {grant_type: 'authorization_code', redirect_uri: 'urn:ietf:wg:oauth:2.0:oob'},
|
|
// function (err, accessToken, refreshToken, res) {
|
|
//
|
|
// console.log(err, accessToken, refreshToken , res);
|
|
|
|
const masto = new Masto({
|
|
access_token: accessToken,
|
|
api_url: process.env.INSTANCE_MASTODON + '/api/v1/',
|
|
});
|
|
|
|
if (enable_post) {
|
|
|
|
|
|
masto.post('media', {file: fs.createReadStream(file_path)}).then(resp => {
|
|
id = resp.data.id;
|
|
// doc https://docs.joinmastodon.org/methods/statuses/
|
|
|
|
console.log('media id ', resp.data.id)
|
|
console.log(resp.data)
|
|
masto.post('statuses', {
|
|
status: status,
|
|
media_ids: [id],
|
|
account_id,
|
|
visibility,
|
|
language,
|
|
sensitive
|
|
}).then(resp => {
|
|
// succès, marquer le post comme fait en BDD
|
|
console.log(resp)
|
|
|
|
var oldPath = file_path
|
|
var newPath = 'assets/published/' + media_filename
|
|
|
|
fs.rename(oldPath, newPath, function (err) {
|
|
if (err) throw err
|
|
console.log('Successfully renamed - AKA moved!')
|
|
})
|
|
|
|
},
|
|
err => {
|
|
console.error(err)
|
|
})
|
|
})
|
|
}
|
|
//
|
|
// if (!file) {
|
|
// return masto.post('statuses', {
|
|
// status,
|
|
// visibility,
|
|
// });
|
|
// }
|
|
|
|
// const response = await masto.post('media', {
|
|
// file: {
|
|
// value: file,
|
|
// options: {
|
|
// filename: 'assets/test.png',
|
|
// contentType: 'image/png',
|
|
// },
|
|
// },
|
|
// });
|
|
//
|
|
// return masto.post('statuses', {
|
|
// status,
|
|
// visibility,
|
|
// media_ids: [response.data.id],
|
|
// });
|
|
|
|
// })
|
|
|
|
res.render('index', {});
|
|
//
|
|
// getAllPosts(db).then(
|
|
// (results) => {
|
|
// console.log( "publier le premier message de la file d'attente" ,results[0])
|
|
// res.render('publish', {p: results[0]});
|
|
// },
|
|
// (err) => console.error(err),
|
|
// );
|
|
|
|
});
|
|
|
|
// répartir les publications dans le temps
|
|
// TODO
|
|
const limit_posts_per_day = 10
|
|
|
|
router.get('/dispatch-publication-in-time', function (req, res, next) {
|
|
|
|
getAllPosts(db).then(
|
|
(results) => {
|
|
console.log("répartir", results[0])
|
|
|
|
// on compte les posts et quel intervalle de temps mettre entre chaque pour tenir le rythme de X posts par jour
|
|
|
|
res.render('index', {p: results[0]});
|
|
},
|
|
(err) => console.error(err),
|
|
);
|
|
|
|
});
|
|
|
|
|
|
router.post('/direct-post', function (req, res, next) {
|
|
|
|
if (process.env['TOKEN_' + req.body.author]) {
|
|
|
|
let visibility = 'public';
|
|
let language = 'fr';
|
|
let sensitive = false;
|
|
|
|
let accessToken = process.env['TOKEN_' + req.body.author]
|
|
console.log('accessToken', accessToken)
|
|
const masto = new Masto({
|
|
access_token: accessToken,
|
|
api_url: process.env.INSTANCE_MASTODON + '/api/v1/',
|
|
});
|
|
|
|
let params = {
|
|
status: req.body.message,
|
|
visibility,
|
|
language,
|
|
sensitive
|
|
}
|
|
if (req.body.cw) {
|
|
params['spoiler_text'] = req.body.cw
|
|
}
|
|
if (req.body.scheduled_at && req.body.scheduled_at_bool) {
|
|
let dateschedule = new Date(req.body.scheduled_at)
|
|
params['scheduled_at'] = dateschedule.toISOString()
|
|
}
|
|
console.log(req.body)
|
|
|
|
if (!req.body.fichier) {
|
|
|
|
masto.post('statuses', params).then(rep => {
|
|
console.log('rep', rep)
|
|
}, err => {
|
|
console.error(err)
|
|
})
|
|
res.render('index', {bodyReq: req.body})
|
|
}
|
|
|
|
// if (req.body.fichier) {
|
|
//
|
|
// masto.post('statuses', params).then(rep => {
|
|
// console.log('rep', rep)
|
|
// }, err => {
|
|
// console.error(err)
|
|
// })
|
|
// res.render('index', {bodyReq: req.body})
|
|
// }
|
|
|
|
} else {
|
|
console.error('pas de token pour ' + req.body.author)
|
|
}
|
|
})
|
|
|
|
module.exports = router;
|