arthur/artdanj-api
1
0
Fork 0
mirror of https://github.com/ArthurDanjou/artdanj-api.git synced 2026-01-31 11:57:50 +01:00
Code Issues 2 Packages Projects Releases Wiki Activity

Add try catch

Browse Source
This commit is contained in:
Arthur Danjou
2021-11-27 16:24:41 +01:00
parent eab82d26b2
commit 9cb299abee
2 changed files with 41 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
app/Tasks/StatesTask.ts
View File

@@ -12,28 +12,32 @@ interface StatesResponse {
} }
async function getCurrentTime(): Promise<void> { async function getCurrentTime(): Promise<void> {
const response = await axios.get<{ data: StatesResponse[]}>(`https://wakatime.com/api/v1/users/${Env.get('WAKATIME_USER')}/heartbeats`, { try {
headers: { const response = await axios.get<{ data: StatesResponse[]}>(`https://wakatime.com/api/v1/users/${Env.get('WAKATIME_USER')}/heartbeats`, {
Authorization: `Basic ${btoa(Env.get('WAKATIME_KEY'))}`, headers: {
}, Authorization: `Basic ${btoa(Env.get('WAKATIME_KEY'))}`,
params: { },
date: new Date(), params: {
}, date: new Date(),
}) },
})
if (response.status === 200) { if (response.status === 200) {
const heartbeat = response.data.data[response.data.data.length - 1] const heartbeat = response.data.data[response.data.data.length - 1]
const current_time = new Date(Date.now()).getTime() / 1000 const current_time = new Date(Date.now()).getTime() / 1000
if (heartbeat && heartbeat.time!) { if (heartbeat && heartbeat.time!) {
const active = current_time - heartbeat.time <= 60 * 5 // Less than 5 min. const active = current_time - heartbeat.time <= 60 * 5 // Less than 5 min.
const redis_state = await Redis.get('states:developing') === 'true' const redis_state = await Redis.get('states:developing') === 'true'
if (redis_state !== active) { if (redis_state !== active) {
await Redis.set('states:developing', String(active)) await Redis.set('states:developing', String(active))
if (redis_state) await Redis.set('states:sleeping', 'false') if (redis_state) await Redis.set('states:sleeping', 'false')
}
} }
} }
} catch (error) {
Logger.error('Error while getting the states')
} }
} }

36
app/Tasks/StatsTask.ts
View File

@@ -17,24 +17,28 @@ interface StatsResponse {
} }
async function getDevelopmentHours(): Promise<void> { async function getDevelopmentHours(): Promise<void> {
const response = await axios.get<{ data: StatsResponse[]}>(`https://wakatime.com/share/@${Env.get('WAKATIME_USER')}/${Env.get('WAKATIME_ID')}.json`) try {
if (response.status === 200) { const response = await axios.get<{ data: StatsResponse[]}>(`https://wakatime.com/share/@${Env.get('WAKATIME_USER')}/${Env.get('WAKATIME_ID')}.json`)
const mapped_stats = response.data.data.map((item: StatsResponse) => { if (response.status === 200) {
return { const mapped_stats = response.data.data.map((item: StatsResponse) => {
seconds: item.grand_total.total_seconds, date: item.range.date, return {
} seconds: item.grand_total.total_seconds, date: item.range.date,
}) }
for (const data of mapped_stats) {
await DevelopmentHour.updateOrCreate({
date: data.date.split('T')[0],
}, {
date: data.date.split('T')[0],
seconds: data.seconds,
}) })
}
await UpdateGithubReadme() for (const data of mapped_stats) {
await DevelopmentHour.updateOrCreate({
date: data.date.split('T')[0],
}, {
date: data.date.split('T')[0],
seconds: data.seconds,
})
}
await UpdateGithubReadme()
}
} catch (error) {
Logger.error('Error while getting the stats')
} }
} }