First typescript iteration

1 files changed, 57 insertions, 0 deletions

diff --git a/server/controllers/api/requests.ts b/server/controllers/api/requests.ts
new file mode 100644
index 000000000..304499a4f
--- /dev/null
+++ b/server/controllers/api/requests.ts
@@ -0,0 +1,57 @@
+import express = require('express')
+import { parallel } from 'async'
+
+import {
+  getRequestScheduler,
+  getRequestVideoQaduScheduler,
+  getRequestVideoEventScheduler
+} from '../../lib'
+import { authenticate, ensureIsAdmin } from '../../middlewares'
+
+const requestsRouter = express.Router()
+
+requestsRouter.get('/stats',
+  authenticate,
+  ensureIsAdmin,
+  getStatsRequests
+)
+
+// ---------------------------------------------------------------------------
+
+export {
+  requestsRouter
+}
+
+// ---------------------------------------------------------------------------
+
+function getStatsRequests (req, res, next) {
+  parallel({
+    requestScheduler: buildRequestSchedulerFunction(getRequestScheduler()),
+    requestVideoQaduScheduler: buildRequestSchedulerFunction(getRequestVideoQaduScheduler()),
+    requestVideoEventScheduler: buildRequestSchedulerFunction(getRequestVideoEventScheduler())
+  }, function (err, result) {
+    if (err) return next(err)
+
+    return res.json(result)
+  })
+}
+
+// ---------------------------------------------------------------------------
+
+function buildRequestSchedulerFunction (requestScheduler) {
+  return function (callback) {
+    requestScheduler.remainingRequestsCount(function (err, count) {
+      if (err) return callback(err)
+
+      const result = {
+        totalRequests: count,
+        requestsLimitPods: requestScheduler.limitPods,
+        requestsLimitPerPod: requestScheduler.limitPerPod,
+        remainingMilliSeconds: requestScheduler.remainingMilliSeconds(),
+        milliSecondsInterval: requestScheduler.requestInterval
+      }
+
+      return callback(null, result)
+    })
+  }
+}