unuse bolt receiver

src/server/crowi/index.js

@@ -58,7 +58,6 @@ function Crowi(rootdir) {
   this.cdnResourcesService = new CdnResourcesService();
   this.interceptorManager = new InterceptorManager();
   this.boltService = null;
-  this.boltRecieverService = null;
   this.xss = new Xss();
 
   this.tokens = null;
@@ -119,7 +118,6 @@ Crowi.prototype.init = async function() {
     this.setupPageService(),
     this.setupSyncPageStatusService(),
     this.setupBoltService(),
-    this.setupBoltRecieverService(),
   ]);
 
   // globalNotification depends on slack and mailer
@@ -660,11 +658,4 @@ Crowi.prototype.setupBoltService = async function() {
   }
 };
 
-Crowi.prototype.setupBoltRecieverService = async function() {
-  const BoltRecieverService = require('../service/bolt-reciever');
-  if (this.boltRecieverService == null) {
-    this.boltRecieverService = new BoltRecieverService(process.env.SLACK_SIGNING_SECRET, '/');
-  }
-};
-
 module.exports = Crowi;

src/server/service/bolt-reciever.js

@@ -1,44 +1,111 @@
-const { EventEmitter } = require('events');
-
-/**
- * the service class of SlackNotificationService
- */
-class BoltRecieverService extends EventEmitter {
-
-  init(app) {
-    this.bolt = app;
-  }
-
-  // This is a very simple implementation. Look at the ExpressReceiver source for more detail
-  async requestHandler(req, res) {
-    let ackCalled = false;
-
-    const event = {
-      body: req.body,
-      // Receivers are responsible for handling acknowledgements
-      // `ack` should be prepared to be called multiple times and
-      // possibly with `response` as an error
-      ack: (response) => {
-        if (ackCalled) {
-          return;
-        }
-
-        if (response instanceof Error) {
-          res.status(500).send();
-        }
-        else if (!response) {
-          res.send('');
-        }
-        else {
-          res.send(response);
-        }
-
-        ackCalled = true;
-      },
-    };
-    await this.bolt.processEvent(event);
-  }
-
-}
-
-module.exports = BoltRecieverService;
+// const { EventEmitter } = require('events');
+
+// // /**
+// //  * the service class of SlackNotificationService
+// //  */
+// // class BoltRecieverService extends EventEmitter {
+
+// //   init(app) {
+// //     this.bolt = app;
+// //   }
+
+// //   // // This is a very simple implementation. Look at the ExpressReceiver source for more detail
+// //   async requestHandler(req, res) {
+// //   //   let ackCalled = false;
+
+// //     //   const event = {
+// //     //     body: req.body,
+// //     //     // Receivers are responsible for handling acknowledgements
+// //     //     // `ack` should be prepared to be called multiple times and
+// //     //     // possibly with `response` as an error
+// //     //     ack: (response) => {
+// //     //       if (ackCalled) {
+// //     //         return;
+// //     //       }
+
+// //     //       if (response instanceof Error) {
+// //     //         res.status(500).send();
+// //     //       }
+// //     //       else if (!response) {
+// //     //         res.send('');
+// //     //       }
+// //     //       else {
+// //     //         res.send(response);
+// //     //       }
+
+// //   //       ackCalled = true;
+// //   //     },
+// //   //   };
+// //   //   await this.bolt.processEvent(event);
+// //   }
+
+// // }
+
+// // module.exports = BoltRecieverService;
+
+
+// class BoltRecieverService extends EventEmitter {
+
+//   constructor(signingSecret, endpoints, crowi) {
+//     super();
+//     this.app = crowi.express;
+
+//     for (const endpoint of endpoints) {
+//       this.app.post(endpoint, this.requestHandler.bind(this));
+//     }
+//   }
+
+//   init(app) {
+//     this.bolt = app;
+//   }
+
+//   async requestHandler(req, res) {
+//     let ackCalled = false;
+//     // 着信リクエストをパースするparseBody 関数があると仮定
+//     const parsedReq = 'parseBody(req)';
+//     // const parsedReq = parseBody(req);
+//     const event = {
+//       body: parsedReq.body,
+//       // レシーバーが確認作業に重要
+//       ack: (response) => {
+//         if (ackCalled) {
+//           return;
+//         }
+
+//         if (response instanceof Error) {
+//           res.status(500).send();
+//         }
+//         else if (!response) {
+//           res.send('');
+//         }
+//         else {
+//           res.send(response);
+//         }
+
+//         ackCalled = true;
+//       },
+//     };
+//     await this.bolt.processEvent(event);
+//   }
+
+// }
+
+
+// const { App, ExpressReceiver } = require('@slack/bolt');
+
+// // Bolt の Receiver を明に生成
+// // const receiver = new ExpressReceiver({ signingSecret: process.env.SLACK_SIGNING_SECRET });
+// const receiver = new BoltRecieverService({ signingSecret: process.env.SLACK_SIGNING_SECRET, endpoints: [], crowi: crowi });
+
+// // App をこのレシーバーを指定して生成
+// const bolt = new App({
+//   token: process.env.SLACK_BOT_TOKEN,
+//   receiver,
+// });
+
+// // Slack とのやりとりは App のメソッドで定義
+// bolt.event('message', async({ event, client }) => {
+//   // Do some slack-specific stuff here
+//   // await client.chat.postMessage(...);
+//   console.log('wwwwwwwwwwwwwwwwwwwwwwwwww');
+// });