Feature/es support server

client/test/workflow.test.js

@@ -343,6 +343,9 @@ describe('Workflow', () => {
         );
 
         terminateEl.trigger('click');
+
+        await Promise.delay(1000);
+
         const confirmTerminateEl = await summaryEl.waitUntilExists(
           '[data-modal="confirm-termination"]'
         );

server/middleware/tchannel-client/helpers/format-method.js

@@ -19,6 +19,6 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 // THE SOFTWARE.
 
-const formatMethod = method => `WorkflowService::${method}`;
+const formatMethod = ({ method, serviceName }) => `${serviceName}::${method}`;
 
 module.exports = formatMethod;

server/middleware/tchannel-client/helpers/index.js

@@ -24,7 +24,7 @@ const formatBody = require('./format-body');
 const formatMethod = require('./format-method');
 const formatRequestName = require('./format-request-name');
 const lookupAsync = require('./lookup-async');
-const makeChannel = require('./make-channel');
+const makeChannels = require('./make-channels');
 const makeRequest = require('./make-request');
 const uiTransform = require('./ui-transform');
 const withDomainPagingAndWorkflowExecution = require('./with-domain-paging-and-workflow-execution');
@@ -38,7 +38,7 @@ module.exports = {
   formatMethod,
   formatRequestName,
   lookupAsync,
-  makeChannel,
+  makeChannels,
   makeRequest,
   uiTransform,
   withDomainPagingAndWorkflowExecution,

server/middleware/tchannel-client/helpers/make-channel.js → server/middleware/tchannel-client/helpers/make-channels.js

@@ -25,7 +25,7 @@ const TChannelAsThrift = require('tchannel/as/thrift');
 const { PEERS } = require('../constants');
 const lookupAsync = require('./lookup-async');
 
-const makeChannel = async client => {
+const makeChannels = async client => {
   const ipPeers = await Promise.all(
     PEERS.map(peer => {
       const [host, port] = peer.split(':');
@@ -47,12 +47,20 @@ const makeChannel = async client => {
     },
   });
 
-  const tchannelAsThrift = TChannelAsThrift({
+  const adminTChannelAsThrift = TChannelAsThrift({
+    channel: cadenceChannel,
+    entryPoint: path.join(__dirname, '../../../idl/admin.thrift'),
+  });
+
+  const cadenceTChannelAsThrift = TChannelAsThrift({
     channel: cadenceChannel,
     entryPoint: path.join(__dirname, '../../../idl/cadence.thrift'),
   });
 
-  return tchannelAsThrift;
+  return {
+    admin: adminTChannelAsThrift,
+    cadence: cadenceTChannelAsThrift,
+  };
 };
 
-module.exports = makeChannel;
+module.exports = makeChannels;

server/middleware/tchannel-client/helpers/make-request.js

@@ -25,16 +25,18 @@ const formatMethod = require('./format-method');
 const formatRequestName = require('./format-request-name');
 const uiTransform = require('./ui-transform');
 
-const makeRequest = ({ authTokenHeaders, channel, ctx }) => ({
+const makeRequest = ({ authTokenHeaders, channels, ctx }) => ({
+  bodyTransform,
+  channelName = 'cadence',
   method,
   requestName,
-  bodyTransform,
   responseTransform,
+  serviceName = 'WorkflowService',
 }) => body =>
   new Promise((resolve, reject) => {
     try {
-      channel.request(REQUEST_CONFIG).send(
-        formatMethod(method),
+      channels[channelName].request(REQUEST_CONFIG).send(
+        formatMethod({ method, serviceName }),
         {
           ...authTokenHeaders,
         },

server/middleware/tchannel-client/index.js

@@ -25,7 +25,7 @@ const TChannel = require('tchannel');
 
 const {
   cliTransform,
-  makeChannel,
+  makeChannels,
   makeRequest,
   withDomainPaging,
   withWorkflowExecution,
@@ -37,10 +37,10 @@ const tchannelClient = async function(ctx, next) {
   const { authTokenHeaders = {} } = ctx;
 
   const client = TChannel();
-  const channel = await makeChannel(client);
+  const channels = await makeChannels(client);
   const request = makeRequest({
     authTokenHeaders,
-    channel,
+    channels,
     ctx,
   });
 
@@ -55,6 +55,12 @@ const tchannelClient = async function(ctx, next) {
       requestName: 'list',
       bodyTransform: withDomainPaging(ctx),
     }),
+    describeCluster: request({
+      channelName: 'admin',
+      method: 'DescribeCluster',
+      requestName: 'describe',
+      serviceName: 'AdminService',
+    }),
     describeDomain: request({
       method: 'DescribeDomain',
       requestName: 'describe',

server/router/constants.js

@@ -0,0 +1,27 @@
+// Copyright (c) 2021 Uber Technologies Inc.
+//
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+// THE SOFTWARE.
+
+const ONE_HOUR_IN_MILLISECONDS = 60 * 60 * 1000;
+const CLUSTER_CACHE_TTL = ONE_HOUR_IN_MILLISECONDS;
+
+module.exports = {
+  CLUSTER_CACHE_TTL,
+};

server/router/index.js

@@ -22,6 +22,7 @@
 const Router = require('koa-router');
 
 const {
+  clusterHandler,
   domainAuthorizationHandler,
   domainHandler,
   domainListHandler,
@@ -45,7 +46,10 @@ const { listWorkflows } = require('./helpers');
 
 const router = new Router();
 
+router.get('/api/cluster', clusterHandler);
+
 router.get('/api/domains', domainListHandler);
+
 router.get('/api/domains/:domain', domainHandler);
 
 /**

server/router/routes/cluster-handler.js

@@ -0,0 +1,41 @@
+// Copyright (c) 2021 Uber Technologies Inc.
+//
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+// THE SOFTWARE.
+
+const { CLUSTER_CACHE_TTL } = require('../constants');
+
+let cache = null;
+
+const clusterHandler = async ctx => {
+  if (cache) {
+    return (ctx.body = cache);
+  }
+
+  const cluster = await ctx.cadence.describeCluster();
+
+  cache = { ...cluster, membershipInfo: null };
+  ctx.body = cache;
+
+  // This timeout will clear cache after TTL period.
+  // It will fetch a new value on the next request to clusterHandler.
+  setTimeout(() => (cache = null), CLUSTER_CACHE_TTL);
+};
+
+module.exports = clusterHandler;

server/router/routes/index.js

@@ -19,6 +19,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 // THE SOFTWARE.
 
+const clusterHandler = require('./cluster-handler');
 const domainAuthorizationHandler = require('./domain-authorization-handler');
 const domainHandler = require('./domain-handler');
 const domainListHandler = require('./domain-list-handler');
@@ -38,6 +39,7 @@ const workflowSignalHandler = require('./workflow-signal-handler');
 const workflowTerminateHandler = require('./workflow-terminate-handler');
 
 module.exports = {
+  clusterHandler,
   domainAuthorizationHandler,
   domainHandler,
   domainListHandler,