You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
117 lines
3.5 KiB
117 lines
3.5 KiB
//#region REQUIRE
|
|
const express = require('express')
|
|
const axios = require('axios');
|
|
const mariadb = require('mariadb');
|
|
//#endregion
|
|
|
|
//#region CONSTANTS
|
|
const port = 80
|
|
const clientId = process.env.CLIENT_ID;
|
|
const clientSecret = process.env.CLIENT_SECRET;
|
|
const redirectUri = 'https://felixmielcarek.github.io/callback/';
|
|
//#endregion
|
|
|
|
//#region APP INIT
|
|
|
|
const app = express()
|
|
app.listen(port, () => { console.log(`Big brother is listening on port ${port}`) })
|
|
|
|
//#endregion
|
|
|
|
//#region ACCESS TOKEN
|
|
app.get('/settings/deactivate', async (req,res) => {
|
|
const client = mariadb.createPool({
|
|
host: 'felixmielcarek-bigbrotherdb',
|
|
user: process.env.MARIADB_USER,
|
|
database: process.env.MARIADB_DATABASE,
|
|
password: process.env.MARIADB_PASSWORD
|
|
});
|
|
|
|
const code = req.query.code;
|
|
|
|
var authOptions = {
|
|
url: 'https://accounts.spotify.com/api/token', method: 'post', json: true,
|
|
data: { code: code, redirect_uri: redirectUri, grant_type: 'authorization_code' },
|
|
headers: {
|
|
'content-type': 'application/x-www-form-urlencoded',
|
|
'Authorization': 'Basic ' + (new Buffer.from(clientId + ':' + clientSecret).toString('base64'))
|
|
}
|
|
};
|
|
|
|
const response1 = await axios(authOptions);
|
|
const accessToken = response1.data.access_token
|
|
|
|
try {
|
|
const response2 = await axios.get(`https://api.spotify.com/v1/me`, { headers: { 'Authorization': 'Bearer ' + accessToken, } });
|
|
|
|
await client.getConnection()
|
|
|
|
const sqlQuery = `
|
|
DELETE FROM users
|
|
WHERE spotifyid = ?;
|
|
`;
|
|
|
|
client.query(sqlQuery, [response2.data.SpotifyId], (err, res) => {
|
|
if (err) {
|
|
console.error('Error executing query', err);
|
|
return;
|
|
}
|
|
console.log('Data deleted successfully');
|
|
client.end();
|
|
});
|
|
} catch (error) { console.log('Error getting user Spotify id') }
|
|
})
|
|
|
|
app.get('/', async (req, res) => {
|
|
const client = mariadb.createPool({
|
|
host: 'felixmielcarek-bigbrotherdb',
|
|
user: process.env.MARIADB_USER,
|
|
database: process.env.MARIADB_DATABASE,
|
|
password: process.env.MARIADB_PASSWORD
|
|
});
|
|
|
|
const code = req.query.code;
|
|
|
|
var authOptions = {
|
|
url: 'https://accounts.spotify.com/api/token', method: 'post', json: true,
|
|
data: { code: code, redirect_uri: redirectUri, grant_type: 'authorization_code' },
|
|
headers: {
|
|
'content-type': 'application/x-www-form-urlencoded',
|
|
'Authorization': 'Basic ' + (new Buffer.from(clientId + ':' + clientSecret).toString('base64'))
|
|
}
|
|
};
|
|
|
|
const response1 = await axios(authOptions);
|
|
const accessToken = response1.data.access_token
|
|
const refreshToken = response1.data.refresh_token
|
|
|
|
try {
|
|
const response2 = await axios.get(`https://api.spotify.com/v1/me`, { headers: { 'Authorization': 'Bearer ' + accessToken, } });
|
|
|
|
const data = {
|
|
SpotifyId: response2.data.id,
|
|
AccessToken: accessToken,
|
|
RefreshToken: refreshToken
|
|
};
|
|
|
|
await client.getConnection()
|
|
|
|
const sqlQuery = `
|
|
INSERT INTO users (spotifyid, accesstoken, refreshtoken)
|
|
VALUES (?, ?, ?)
|
|
ON DUPLICATE KEY UPDATE
|
|
accesstoken = VALUES(accesstoken),
|
|
refreshtoken = VALUES(refreshtoken);
|
|
`;
|
|
|
|
client.query(sqlQuery, [data.SpotifyId, data.AccessToken, data.RefreshToken], (err, res) => {
|
|
if (err) {
|
|
console.error('Error executing query', err);
|
|
return;
|
|
}
|
|
console.log('Data inserted/updated successfully');
|
|
client.end();
|
|
});
|
|
} catch (error) { console.log('Error getting user Spotify id') }
|
|
});
|
|
//#endregion
|