import os
import json
import requests
from google.oauth2 import service_account
from google.auth.transport.requests import Request
from googleapiclient.discovery import build

# 環境変数からサービスアカウントのJSON内容を取得
service_account_info = os.getenv('GOOGLE_APPLICATION_CREDENTIALS_CONTENT')

if service_account_info is None:
    raise ValueError("サービスアカウントのJSON内容が設定されていません。")

# JSON文字列を辞書に変換
service_account_info_dict = json.loads(service_account_info)

# サービスアカウント情報を使用して認証情報を作成
credentials = service_account.Credentials.from_service_account_info(
    service_account_info_dict,
    scopes=['https://www.googleapis.com/auth/chat.bot']  # 必要なスコープを指定
)

# Google Chat APIクライアントを作成
chat_service = build('chat', 'v1', credentials=credentials)

# メッセージを送信するスペースの名前（適切な形式に修正）
space_name = 'spaces/AAAAv_S3Bco'  # ここを実際のスペースIDに置き換えてください

# 初回メッセージを送信
initial_message = {
    'text': 'スレッドへ返信に変更テスト'
}

initial_response = chat_service.spaces().messages().create(
    parent=space_name,
    body=initial_message
).execute()

# スレッドキーを取得
thread_name = initial_response['thread']['name']
print('Initial message sent. Thread name:', thread_name)

return thread_name


# 後続のメッセージをスレッド内に送信するためのURLを構築
url = f'https://chat.googleapis.com/v1/{space_name}/messages?messageReplyOption=REPLY_MESSAGE_OR_FAIL'

# 後続のメッセージをスレッド内に送信
follow_up_message = {
    'text': 'スレッドへ返信.',
    'thread': {
        'name': thread_name
    }
}

# アクセストークンを取得
credentials.refresh(Request())
access_token = credentials.token

headers = {
    'Authorization': f'Bearer {access_token}',
    'Content-Type': 'application/json'
}

response = requests.post(url, headers=headers, data=json.dumps(follow_up_message))

print('Follow-up message sent:', response.json())