82 lines
1.4 KiB
TypeScript
82 lines
1.4 KiB
TypeScript
import cors from '@koa/cors'
|
|
import Router from '@koa/router'
|
|
import 'dotenv/config'
|
|
import Koa from 'koa'
|
|
import {
|
|
clientId,
|
|
clientSecret,
|
|
PORT,
|
|
redirectUri,
|
|
serverUrl,
|
|
} from './config.js'
|
|
import { initMongodb } from './mongodb.js'
|
|
import { getAccessToken } from './oauth.js'
|
|
import { snakeToCamelCaseKeys } from './utils.js'
|
|
|
|
const mongo = await initMongodb()
|
|
|
|
type KoaState = Koa.DefaultState
|
|
type KoaContext = Koa.DefaultContext
|
|
|
|
const app = new Koa<KoaState, KoaContext>()
|
|
const router = new Router<KoaState, KoaContext>()
|
|
|
|
app.use(cors())
|
|
|
|
router.get('/connect', (ctx) => {
|
|
const url =
|
|
`${serverUrl}/oauth/authorize?` +
|
|
[
|
|
`client_id=${clientId}`,
|
|
`redirect_uri=${redirectUri}`,
|
|
`response_type=code`,
|
|
`state=`,
|
|
].join('&')
|
|
|
|
ctx.redirect(url)
|
|
})
|
|
|
|
router.get('/oauth', async (ctx) => {
|
|
const { code, error } = ctx.query
|
|
|
|
if (error) {
|
|
ctx.status = 400
|
|
ctx.body = error
|
|
|
|
return
|
|
}
|
|
if (typeof code !== 'string') {
|
|
ctx.status = 400
|
|
ctx.body = 'Bad code'
|
|
|
|
return
|
|
}
|
|
|
|
try {
|
|
const { body } = await getAccessToken({
|
|
serverUrl,
|
|
clientSecret,
|
|
clientId,
|
|
redirectUri,
|
|
code,
|
|
})
|
|
|
|
await mongo.saveOAuth(snakeToCamelCaseKeys(body))
|
|
|
|
ctx.status = 200
|
|
} catch (err) {
|
|
// eslint-disable-next-line no-console
|
|
console.error(err)
|
|
|
|
ctx.status = 400
|
|
}
|
|
})
|
|
|
|
app.use(router.routes())
|
|
app.use(router.allowedMethods())
|
|
|
|
app.listen(PORT, () => {
|
|
// eslint-disable-next-line no-console
|
|
console.log(`app listening on port ${PORT}`)
|
|
})
|