4000 - Initial commit for data query API

src/meta/api/endpoint/ApiEndPoint.ts

@@ -113,6 +113,10 @@ export const ApiEndPoint = {
     },
   },
 
+  DataQuery: {
+    one: () => apiPath('data-query'),
+  },
+
   ExtData: {
     Taxa: {
       search: () => apiPath('ext-data', 'taxa', 'search'),

src/server/api/api.ts

@@ -1,5 +1,6 @@
 import { Express } from 'express'
 
+import { DataQueryApi } from 'server/api/dataQuery'
 import { ExtDataApi } from 'server/api/extData'
 
 import { AdminApi } from './admin'
@@ -27,6 +28,7 @@ export const Api = {
     AdminApi.init(express)
     AreaApi.init(express)
     CycleDataApi.init(express)
+    DataQueryApi.init(express)
     DefinitionApi.init(express)
     ExtDataApi.init(express)
     FileApi.init(express)

src/server/api/dataQuery/getDashboardItems.ts

@@ -0,0 +1,22 @@
+import { Response } from 'express'
+
+import { CycleRequest } from 'meta/api/request'
+
+import { AssessmentController } from 'server/controller/assessment'
+import { DataQueryController } from 'server/controller/dataQuery'
+import Requests from 'server/utils/requests'
+
+type Query = { query: string; limit: string }
+
+export const getDashboardItems = async (req: CycleRequest<Query>, res: Response) => {
+  try {
+    const { assessmentName, cycleName } = req.query
+
+    const { assessment, cycle } = await AssessmentController.getOneWithCycle({ assessmentName, cycleName })
+
+    const result = await DataQueryController.getMany({ assessment, cycle })
+    Requests.send(res, result)
+  } catch (e) {
+    Requests.sendErr(res, e)
+  }
+}

src/server/api/dataQuery/index.ts

@@ -0,0 +1,11 @@
+import { Express } from 'express'
+
+import { ApiEndPoint } from 'meta/api/endpoint'
+
+import { getDashboardItems } from './getDashboardItems'
+
+export const DataQueryApi = {
+  init: (express: Express): void => {
+    express.get(ApiEndPoint.DataQuery.one(), getDashboardItems)
+  },
+}

src/server/controller/dataQuery/index.ts

@@ -0,0 +1,5 @@
+import { DataQueryRepository } from 'server/repository/dataQuery'
+
+export const DataQueryController = {
+  getMany: DataQueryRepository.getMany,
+}

src/server/repository/dataQuery/getMany.ts

@@ -0,0 +1,19 @@
+import { Assessment, Cycle } from 'meta/assessment'
+import { DashboardItem, DashboardItemType } from 'meta/dashboard'
+import { NodeExtType } from 'meta/nodeExt'
+
+import { BaseProtocol, DB, Schemas } from 'server/db'
+
+type Props = { assessment: Assessment; cycle: Cycle }
+
+export const getMany = async (
+  props: Props,
+  client: BaseProtocol = DB
+): Promise<Array<DashboardItem<DashboardItemType>>> => {
+  const { assessment, cycle } = props
+  const schemaCycle = Schemas.getNameCycle(assessment, cycle)
+
+  return client.many<DashboardItem<DashboardItemType>>(`select value from ${schemaCycle}.node_ext where type = $1`, [
+    NodeExtType.dataQuery,
+  ])
+}

src/server/repository/dataQuery/index.ts

@@ -0,0 +1,5 @@
+import { getMany } from 'server/repository/dataQuery/getMany'
+
+export const DataQueryRepository = {
+  getMany,
+}