: change route to refresh Token, add responsibility to clients

This commit is contained in:
StarAppeal
2024-03-10 15:29:07 +01:00
parent 4d697689ba
commit bbe6523609
2 changed files with 45 additions and 52 deletions
+11 -13
View File
@@ -8,24 +8,22 @@ export class SpotifyTokenGenerator {
public createRouter() {
const router = express.Router();
router.get("/token", async (req, res) => {
router.get("/refresh-token", async (req, res) => {
const userService = await this.callback();
const user = await userService.getUserById(req.payload._id);
const spotifyConfig = user.spotifyConfig;
const token = await new SpotifyTokenService().getToken(spotifyConfig);
const token = await new SpotifyTokenService().refreshToke(
spotifyConfig.refreshToken,
);
spotifyConfig.accessToken = token.accessToken;
spotifyConfig.expirationDate = new Date(
Date.now() + token.expiresIn * 1000,
);
user.spotifyConfig = spotifyConfig;
await userService.updateUser(req.payload._id, user);
if (token.expiresIn !== -1) {
console.log("Updating token");
spotifyConfig.accessToken = token.accessToken;
spotifyConfig.expirationDate = new Date(
Date.now() + token.expiresIn * 1000,
);
user.spotifyConfig = spotifyConfig;
await userService.updateUser(req.payload._id, user);
}
res.status(200).send({ accessToken: token.accessToken });
res.status(200).send({ result: spotifyConfig });
});
router.get(
+34 -39
View File
@@ -1,51 +1,46 @@
import { SpotifyConfig } from "../db/models/user";
import {SpotifyConfig} from "../db/models/user";
import axios from "axios";
import { OAuthTokenResponse } from "../interfaces/OAuthTokenResponse";
import {OAuthTokenResponse} from "../interfaces/OAuthTokenResponse";
const url = "https://accounts.spotify.com/api/token";
const clientId = process.env.SPOTIFY_CLIENT_ID;
const clientSecret = process.env.SPOTIFY_CLIENT_SECRET;
export class SpotifyTokenService {
public async getToken(spotifyConfig: SpotifyConfig) {
if (spotifyConfig.expirationDate > new Date()) {
return { accessToken: spotifyConfig.accessToken, expiresIn: -1 };
public async refreshToke(refreshToken: string) {
const response = await axios.post(
url,
`grant_type=refresh_token&refresh_token=${refreshToken}`,
{
headers: {
"Content-Type": "application/x-www-form-urlencoded",
Authorization: `Basic ${Buffer.from(
`${clientId}:${clientSecret}`,
).toString("base64")}`,
},
},
);
const token = response.data as OAuthTokenResponse;
return {accessToken: token.access_token, expiresIn: token.expires_in};
}
console.log("Refreshing token");
const response = await axios.post(
url,
`grant_type=refresh_token&refresh_token=${spotifyConfig.refreshToken}`,
{
headers: {
"Content-Type": "application/x-www-form-urlencoded",
Authorization: `Basic ${Buffer.from(
`${clientId}:${clientSecret}`,
).toString("base64")}`,
},
},
);
public async generateToken(authorizationCode: string, redirectUri: string) {
const response = await axios.post(
url,
`grant_type=authorization_code&code=${authorizationCode}&redirect_uri=${redirectUri}`,
{
headers: {
"Content-Type": "application/x-www-form-urlencoded",
Authorization: `Basic ${Buffer.from(
`${clientId}:${clientSecret}`,
).toString("base64")}`,
},
},
);
const token = response.data as OAuthTokenResponse;
return { accessToken: token.access_token, expiresIn: token.expires_in };
}
console.log(response.data);
public async generateToken(authorizationCode: string, redirectUri: string) {
const response = await axios.post(
url,
`grant_type=authorization_code&code=${authorizationCode}&redirect_uri=${redirectUri}`,
{
headers: {
"Content-Type": "application/x-www-form-urlencoded",
Authorization: `Basic ${Buffer.from(
`${clientId}:${clientSecret}`,
).toString("base64")}`,
},
},
);
console.log(response.data);
return response.data as OAuthTokenResponse;
}
return response.data as OAuthTokenResponse;
}
}