GASでTwitterのDMを取得したいが認証情報が足りないと言われる

Question

はじめに

GASでTwitterbotを作ろうとしています。とりあえずの処理としてDMで受け取ったメッセージをツイートしたいと考えています。しかし、DMを取得しようとするとエラーが出てしまいます。pythonでは実装できただけにどうすれば良いか分からず困っています。

#発生するエラー
Exception: Request failed for https://api.twitter.com returned code 401. Truncated server response: {"errors":[{"code":32,"message":"Could not authenticate you."}]}

#実現したいこと
TwitterのDM(厳密に言えばDMイベント)を取得したい

#ソースコード

// セルを取得
var sheetData = SpreadsheetApp.getActiveSpreadsheet().getSheetByName("シート1"); // 「シート1」はシート名
var postMessageCell = sheetData.getRange(2, 1); // セルの位置。縦横それぞれ1～の番号で指定できる

// ツイートを投稿
function postUpdateStatus() {
  var service  = getTwitterService();
  var response = service.fetch('https://api.twitter.com/1.1/statuses/update.json', {
    method: 'post',
    payload: { status: postMessageCell.getValue() }
  });
}

//ここが実行できない
function getDmMedia(){
  var api = getTwitterService();
  var responce = api.fetch('https://api.twitter.com/1.1/direct_messages/events/list.json', {
    method: 'get',
    payload: {count:10}
  });
}


// Twitter AppのConsumer Api Key
var CONSUMER_KEY = "******";
var CONSUMER_SECRET = "*********";

// 認証URLを取得しログに出力する
function logAuthorizeUri() {
  var twitterService = getTwitterService();
  Logger.log(twitterService.authorize());
}

// OAuth認証をよしなにしてくれるサービスクラスのインスタンスを生成・取得する
function getTwitterService() {
  return OAuth1.createService('Twitter')
      .setAccessTokenUrl('https://api.twitter.com/oauth/access_token')
      .setRequestTokenUrl('https://api.twitter.com/oauth/request_token')
      .setAuthorizationUrl('https://api.twitter.com/oauth/authenticate')
      .setConsumerKey(CONSUMER_KEY)
      .setConsumerSecret(CONSUMER_SECRET)
      // リダイレクト時に実行されるコールバック関数を指定する
      .setCallbackFunction('authCallback')
      // アクセストークンを保存するPropertyStoreを指定する
      .setPropertyStore(PropertiesService.getUserProperties());
}

// リダイレクト時に実行されるコールバック関数
function authCallback(request) {
  var twitterService = getTwitterService();
  // ここで認証成功時にアクセストークンがPropertyStoreに保存される
  var isAuthorized = twitterService.handleCallback(request);
  if (isAuthorized) {
    return HtmlService.createHtmlOutput('Success');
  } else {
    return HtmlService.createHtmlOutput('Denied');
  }
}

function reset() {
  var twitterService = getTwitterService();
  twitterService.reset();
}

function getUserId() {
  var service = getTwitterService();
  var screenName = "saba_haisin" //@screen_nameさんにDMを送る場合
  var requestURL = "https://api.twitter.com/1.1/users/lookup.json?screen_name=" + screenName
  var response = service.fetch(requestURL, {
    method: "get",
    contentType: 'application/json'
  });
  var o = JSON.parse(response.getContentText());
  var user_id = o[0].id_str //配列で帰ってくるのでそのうちの最初の要素のuser_idを取得する
  
  newDirectMessage(user_id)
}

function newDirectMessage(user_id){
  try{
    var service = getTwitterService();
    var payload = JSON.stringify({
      event: {
        type: 'message_create',
        message_create: {
          target: {
            recipient_id: String(user_id)
          },
          message_data: { text: "テスト" }
        }
      }
    });
    var response = service.fetch('https://api.twitter.com/1.1/direct_messages/events/new.json',{
      method: 'POST',
      contentType: 'application/json',
      payload: payload
    });
    return response;
  } catch(e) {
    Logger.log('Exception:'+e);
  }
}

#補足・試したこと
DMの送信や投稿はできるため認証自体は行われていると思っています。
公式リファレンスをみても特に追加の認証が必要と言った情報は見つけられませんでした。公式リファレンス，ダイレクトメッセージイベントの取得

#pythonでDMを取得するコード
pythonでの取得する場合のコードも載せておきます。

# -*- coding: utf-8 -*-
from requests_oauthlib import OAuth1Session
import json



consumer_key='**********'
consumer_secret='**********'
access_token='**********'
access_token_secret='**********'

token=OAuth1Session(consumer_key,consumer_secret,access_token,access_token_secret)
end_point = 'https://api.twitter.com/1.1/direct_messages/events/list.json'

def main():
    params={'count':5}
    res = token.get(end_point,params=params)
    directmsg = json.loads(res.text)
    #これでDMのイベントを取得
if __name__ == '__main__':
    main()

Answer 1

POSTではなくGETなので、payloadは渡しません。
下記のようにurlにパラメータを付加する形としてください。

function QueryString(dict) {
  var keys = [];
  for(var k in dict) {
    keys.push(k + '=' + encodeURI(dict[k]));
  }
  return keys.join("&");
}

function getDmMedia(){
  const api = getService();
  const params = {count : 10};
  const qs = QueryString(params);
  const response = api.fetch(`https://api.twitter.com/1.1/direct_messages/events/list.json?${qs}`);
  console.log(JSON.parse(response));
}

　

または単純に、QueryString関数を使わずURLに直接パラメータを付けて

function getDmMedia(){
  const api = getService();
  const response = api.fetch('https://api.twitter.com/1.1/direct_messages/events/list.json?count=10');
  console.log(JSON.parse(response));
}

でも取れます。

Comments

[saba_111]

ありがとうございます。GASに関して初心者であるため仕様が分からず格闘していました。POSTの際にはURLに付随もしくはQueryString関数を用いてリクエストを送るのですね。