Merge pull request #180 from ksraj123/feature-wikis

Feature wikis

Author: vaibhavdaren

.env.dev

@@ -4,10 +4,12 @@ JWT_SECRET="thisismysupersecrettokenjustkidding"
 DATABASE_URL="mongodb://mongo:27017/donut-development"
 SENDGRID_API_KEY='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'
 SOCKET_PORT=8810
-clientbaseurl = "http://localhost:3000"
+clientbaseurl="http://localhost:3000"
 SOCKET_PORT=8810
 REDIS_HOST="redis"
 REDIS_PORT=6379
 REDIS_PASSWORD="auth"
 REDIS_DB=0
 REDIS_ACTIVITY_DB=1
+GITHUB_OAUTH_APP_CLIENTID="a3e08516c35fe7e83f43"
+GITHUB_OAUTH_APP_CLIENTSECRET="8393d95c3bfeeb0943045f447a9d055cb660bce0"

app.js

@@ -27,6 +27,7 @@ const projectRouter = require('./app/routes/project')
 const notificationRouter = require('./app/routes/notification')
 const proposalRouter = require('./app/routes/proposal')
 const analyticsRouter = require('./app/routes/analytics')
+const wikisRouter = require('./app/routes/wikis')
 const activityRouter = require('./app/routes/activity')
 const ticketRouter = require('./app/routes/ticket')
 
@@ -107,6 +108,7 @@ app.use('/comment', commentRouter)
 app.use('/project', projectRouter)
 app.use('/proposal', proposalRouter)
 app.use('/analytics', analyticsRouter)
+app.use('/wikis', wikisRouter)
 app.use('/activity', activityRouter)
 app.use('/ticket', ticketRouter)
 

app/controllers/wikis.js

@@ -0,0 +1,142 @@
+const axios = require('axios')
+const HttpStatus = require('http-status-codes')
+const WikiHelper = require('../utils/wikis-helper')
+const HANDLER = require('../utils/response-helper')
+const Organization = require('../models/Organisation')
+const { changeFileOnRemote, addPageToIndex, fetchPagesIndex, updatePagesIndex, getOpts, getOrgId } = WikiHelper
+
+const clientId = process.env.GITHUB_OAUTH_APP_CLIENTID
+const clientSecret = process.env.GITHUB_OAUTH_APP_CLIENTSECRET
+
+const githubAPI = 'https://api.github.com'
+let accessToken = null
+let orgId = null
+
+module.exports = {
+
+  getWikis: async (req, res, next) => {
+    try {
+      if (!accessToken || !orgId) {
+        const Org = await Organization.find({}).lean().exec()
+        if (Org[0].wikis.accessToken && Org[0].wikis.orgId) {
+          accessToken = Org[0].wikis.accessToken
+          orgId = Org[0].wikis.orgId
+          WikiHelper.setOrgId(orgId)
+          WikiHelper.setOpts(accessToken)
+        }
+      }
+      if (!accessToken || !orgId) {
+        res.status(HttpStatus.OK).json({ wikis: 'NO_ACCESS_TOKEN' })
+      } else {
+        const data = await addPageToIndex(await fetchPagesIndex(), 'Home')
+        res.status(HttpStatus.OK).json({ wikis: data })
+      }
+    } catch (error) {
+      HANDLER.handleError(res, error)
+    }
+  },
+
+  getPage: async (req, res, next) => {
+    try {
+      let { title, ref } = req.query
+      if (!ref) {
+        ref = 'master'
+      }
+      const data = await addPageToIndex(await fetchPagesIndex(), title, ref)
+      res.status(HttpStatus.OK).json({ wikis: data })
+    } catch (err) {
+      res.status(HttpStatus.BAD_REQUEST).json({ Error: err.message })
+    }
+  },
+
+  editPage: async (req, res, next) => {
+    const { title, content, comments } = req.body
+    try {
+      await changeFileOnRemote(title, content, `${title} changes - ${comments}`)
+      if (title !== '_Sidebar') {
+        const data = await addPageToIndex(await fetchPagesIndex(), title)
+        res.status(HttpStatus.OK).json({ wikis: data })
+      } else {
+        await updatePagesIndex()
+        const data = await addPageToIndex(await fetchPagesIndex(), 'Home')
+        res.status(HttpStatus.OK).json({ wikis: data })
+      }
+    } catch (err) {
+      res.status(HttpStatus.BAD_REQUEST).json({ Error: err.message })
+    }
+  },
+
+  deletePage: async (req, res, next) => {
+    const { title } = req.body
+    try {
+      const baseUrl = `${githubAPI}/repos/${getOrgId()}/Donut-wikis-backup`
+      const data = {
+        message: `${title} deleted`,
+        sha: (await axios.get(`${baseUrl}/contents/${title}.md`, getOpts())).data.sha
+      }
+      const deleteCommit = (await axios.delete(`${baseUrl}/contents/${title}.md`, {
+        data: data,
+        headers: getOpts().headers
+      })).data.commit.sha
+      const issueNumber = await WikiHelper.getFileIssueNumber(title)
+      await axios.post(`${baseUrl}/issues/${issueNumber}/comments`, { body: deleteCommit }, getOpts())
+      const newIssueTitle = `${title}-deleted-${deleteCommit.substring(0, 8)}`
+      await axios.patch(`${baseUrl}/issues/${issueNumber}`, { title: newIssueTitle }, getOpts())
+      await updatePagesIndex()
+      await WikiHelper.clearPageFromCache(title)
+      res.status(HttpStatus.OK).json({ wikis: await addPageToIndex(await fetchPagesIndex(), 'Home') })
+    } catch (err) {
+      res.status(HttpStatus.BAD_REQUEST).json({ Error: err.message })
+    }
+  },
+
+  newPage: async (req, res, next) => {
+    const { title, content, comments } = req.body
+    try {
+      await changeFileOnRemote(title, content, `${title} initial commit - ${comments}`, true)
+      await updatePagesIndex()
+      const data = await addPageToIndex(await fetchPagesIndex(), title)
+      res.status(HttpStatus.OK).json({ wikis: data })
+    } catch (err) {
+      res.status(HttpStatus.BAD_REQUEST).json({ Error: err.message })
+    }
+  },
+
+  oauthCheck: async (req, res, next) => {
+    if (!accessToken) {
+      console.log('redirected to github auth')
+      res.status(HttpStatus.OK).json({
+        redirect: true,
+        redirect_url: `https://github.com/login/oauth/authorize?client_id=${clientId}&scope=repo`
+      })
+    } else {
+      res.status(HttpStatus.OK).json({
+        redirect: false
+      })
+    }
+  },
+
+  oauthCallback: async (req, res, next) => {
+    const body = {
+      client_id: clientId,
+      client_secret: clientSecret,
+      code: req.query.code
+    }
+    const opts = { headers: { accept: 'application/json' } }
+    try {
+      const resp = await axios.post('https://github.com/login/oauth/access_token', body, opts)
+      accessToken = resp.data.access_token
+      WikiHelper.setOpts(accessToken)
+      const Org = await Organization.find({}).exec()
+      orgId = await WikiHelper.getOrg()
+      Org[0].wikis.accessToken = accessToken
+      Org[0].wikis.orgId = orgId
+      await Org[0].save()
+      await WikiHelper.createRepo()
+      await updatePagesIndex()
+      res.redirect(`${process.env.clientbaseurl}/wikis`)
+    } catch (err) {
+      res.status(500).json({ message: err.message })
+    }
+  }
+}

app/models/Organisation.js

@@ -194,6 +194,10 @@ const orgSchema = new Schema({
     type: Date,
     required: true,
     default: Date.now()
+  },
+  wikis: {
+    accessToken: { type: String, default: null },
+    orgId: { type: String, default: null }
   }
 })
 module.exports = mongoose.model('Organization', orgSchema)

app/routes/wikis.js

@@ -0,0 +1,54 @@
+const express = require('express')
+const router = express.Router()
+const auth = require('../middleware/auth')
+const wikisController = require('../controllers/wikis')
+const isUnderMaintenance = require('../middleware/maintenance')
+
+router.get(
+  '/',
+  isUnderMaintenance,
+  auth,
+  wikisController.getWikis
+)
+
+router.get(
+  '/oauth-callback',
+  isUnderMaintenance,
+  wikisController.oauthCallback
+)
+
+router.get(
+  '/oauth-check',
+  isUnderMaintenance,
+  auth,
+  wikisController.oauthCheck
+)
+
+router.get(
+  '/pages',
+  isUnderMaintenance,
+  auth, wikisController.getPage
+)
+
+router.post(
+  '/pages',
+  isUnderMaintenance,
+  auth,
+  wikisController.newPage
+)
+
+router.patch(
+  '/pages',
+  isUnderMaintenance,
+  auth,
+  wikisController.editPage
+)
+
+router.delete(
+  '/pages',
+  isUnderMaintenance,
+  auth,
+  wikisController.deletePage
+)
+
+module.exports = router