1
2
3
4
5
6
7
8

// npmコマンド実行
D:\home\site\wwwroot\<function_name>> npm init

// requestのインストール
D:\home\site\wwwroot\<function_name>> npm install request --save-dev

// request-promiseのインストール
D:\home\site\wwwroot\<function_name>> npm install request-promise --save-dev

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194

/*
 * kinone x Cisco Webex Messaging sample program
 * Copyright (c) 2017 Cybozu
 *
 * Licensed under the MIT License
 * https://opensource.org/license/mit/
 */

(function() {
  'use strict';
  const rp = require('request-promise');

  // Cisco Webex MessagingのBotのAccess Token
  const BEARER = 'XXX';

  // cybozu.comの実行用のユーザー(「ログイン名:パスワード」をBASE64エンコードしたもの)
  const CYBOZU_AUTH = 'XXX';

  // kintoneのドメイン
  const DOMAIN = 'https://{subdomain}.cybozu.com';

  // kintoneのタスク管理のタスク管理のアプリ番号
  const APP_ID = 1;

  let context,
    err = null;

  // Cisco Webex Messagingにメッセージをsendする
  function sendSpark(msg, markdown, roomid) {
    const body_post_spark = {}; // Cisco Webex Messagingに投稿する内容

    // markdownか否かで区分
    if (markdown) {
      body_post_spark.markdown = msg;
    } else {
      body_post_spark.text = msg;
    }

    body_post_spark.roomId = roomid;

    // Cisco Webex Messagingに投稿するためのオブジェクト
    const postspark = {
      url: 'https://api.ciscospark.com/v1/messages/',
      method: 'POST',
      auth: {bearer: BEARER},
      'Content-Type': 'application/json',
      json: body_post_spark
    };

    // 投稿を実行する
    return rp(postspark).then((res) => {
      context.log('投稿されました:' + msg);
      return res;
    });
  }

  // cybozu.comのユーザー情報を取得する
  function getUser(opt_offset, users) {
    const offset = opt_offset || 0;
    const objUser = users || {};

    const objGetUser = {
      url: DOMAIN + '/v1/users.json?offset=' + offset,
      headers: {'X-Cybozu-Authorization': CYBOZU_AUTH},
      method: 'GET',
      'Content-Type': 'application/json'
    };

    // ユーザー情報の取得を実行する
    return rp(objGetUser).then((res) => {
      const resUser = JSON.parse(res);

      // 取得したユーザー情報をオブジェクトに格納する
      for (let i = 0; i < resUser.users.length; i += 1) {
        objUser[resUser.users[i].email] = {code: resUser.users[i].code,
          name: resUser.users[i].name};
      }

      // 100件取得してる場合は、offsetを100ずらして再度ユーザー取得
      if (resUser.users.length === 100) {
        return getUser(offset + 100, objUser);
      }

      return objUser;
    });
  }

  // Cisco Webex Messagingの投稿者とe-mailが一致するcybozu.comのユーザー情報を取得する
  function getPostingUser(email, roomid) {
    context.log('roomid2= ' + roomid);

    // cybozu.comからユーザー情報を取得する
    return getUser().then((rtnUser) => {
      if (!(rtnUser[email])) {
        err = DOMAIN + ' 上に該当するユーザーが見つかりませんでした';
        return sendSpark(err, true, roomid);
      }
      // Cisco Webex Messagingの投稿者とe-mailが一致するユーザー情報を返す
      return rtnUser[email];
    }).catch((e) => {
      if (e) {
        throw Error(e);
      }
    });
  }

  // kintoneから残タスクを取得する
  function getTaskRemain(email, objUser, roomid) {
    const code = objUser.code.replace(/(^\s+)|(\s+$)/g, ''),
      param = 'responsible in ("' + code + '") and status not in ("' + encodeURIComponent('完了') + '")';

    const objTaskRemain = {
      url: DOMAIN + '/k/v1/records.json?app=' + APP_ID + '&query=' + param,
      headers: {'X-Cybozu-Authorization': CYBOZU_AUTH},
      method: 'GET',
      'Content-Type': 'application/json'
    };

    // 検索を実行する
    return rp(objTaskRemain).then((body) => {
      let msgstr = '';
      const obj = JSON.parse(body);
      const rec = obj.records;
      context.log(obj);

      // 検索結果を表示する
      if (objUser) {
        msgstr += '<@personEmail:' + email + '|' +
                                             objUser.name + 'さん>\n\n';
      }

      msgstr += '**----------------------------**\n\n';
      msgstr += '**' + rec.length + '件**が検索されました\n\n';
      for (let i = 0; i < rec.length; i += 1) {
        msgstr += '\n**【 ' + rec[i].task.value + ' 】**\n\n';
        msgstr += '- ステータス: ' + rec[i].status.value + '\n';
        msgstr += '- 詳細: ' + rec[i].detail.value + '\n';
      }

      msgstr += '\n**----------------------------**\n\n';
      return sendSpark(msgstr, true, roomid);
    });
  }

  module.exports = function(ct, event) {
    let sendpemail, roomid;
    context = ct;

    if (event.body.data) {
      // 投稿したメッセージの詳細を取得する
      const getmessage = {
        url: 'https://api.ciscospark.com/v1/messages/' + event.body.data.id,
        method: 'GET',
        auth: {bearer: BEARER},
        'Content-Type': 'application/json'
      };

      // メッセージの詳細の取得を実行する
      return rp(getmessage).then((body) => {
        const objbody = JSON.parse(body);

        // 投稿者の投稿者のemailの情報を保持しておく
        sendpemail = objbody.personEmail;

        // 投稿先のroomidを保持しておく
        roomid = objbody.roomId;

        // emailの情報を元に、、cybozu.comのユーザー情報を取得する
        if (!objbody.html) {
          return null;
        }

        const cmd = objbody.html ? objbody.html.split('</spark-mention>') : [];

        // botを指定した直後に「get」と入力された場合にのみ実行する
        if (cmd.length > 1 && cmd[1].indexOf('get') > -1) {
          return getPostingUser(sendpemail, roomid);
        }

        return null;

      }).then((rtnUser) => {

        if (rtnUser) {
          return getTaskRemain(sendpemail, rtnUser, roomid);
        }

      }).catch((e) => {

        context.log(e);
      });
    }
  };
})();