Admina の自動化を Slack・Zapier・Google Apps Script と繋ぐ：双方向 6 パターンを解説

curl -i -X POST "<ZAPIER_CATCH_HOOK_URL>" \
  -H "Content-Type: application/json" \
  -d '{"text": "AdminaからZapierを起動"}'

// Admina Automation から Google Apps Script を起動
function doPost(e) {
    try {
        const body = e.postData.contents;
        const json = JSON.parse(body);

        console.log('Received webhook:', json);

        // ここでスプレッドシート書き込みや Slack 通知などを実装できます

        return ContentService
            .createTextOutput(JSON.stringify({ status: 'ok' }))
            .setMimeType(ContentService.MimeType.JSON);
    } catch (err) {
        console.error('Error handling webhook:', err);
        return ContentService
            .createTextOutput(JSON.stringify({ status: 'error', message: err.message }))
            .setMimeType(ContentService.MimeType.JSON);
    }
}

import { DefineFunction, Schema, SlackFunction } from "deno-slack-sdk/mod.ts";

export const SendAdminaWebhookFunction = DefineFunction({
  callback_id: "send_admina_webhook",
  title: "Admina のワークフローを起動",
  description: "Admina の Webhook トリガーにテキストを送信してワークフローを起動します",
  source_file: "functions/send_admina_webhook.ts",
  input_parameters: {
    properties: {
      text: {
        type: Schema.types.string,
        description: "Admina 側に送信するメッセージ本文",
      },
    },
    required: ["text"],
  },
  output_parameters: {
    properties: {
      status_code: {
        type: Schema.types.number,
        description: "Admina から返却された HTTP ステータスコード",
      },
      response_body: {
        type: Schema.types.string,
        description: "Admina から返却されたレスポンスボディ",
      },
    },
    required: ["status_code", "response_body"],
  },
});

async function computeSignature(
  secret: string,
  message: string,
): Promise<string> {
  const encoder = new TextEncoder();
  const key = await crypto.subtle.importKey(
    "raw",
    encoder.encode(secret),
    { name: "HMAC", hash: "SHA-256" },
    false,
    ["sign"],
  );
  const signatureBuffer = await crypto.subtle.sign(
    "HMAC",
    key,
    encoder.encode(message),
  );
  return new Uint8Array(signatureBuffer).toHex();
}

export default SlackFunction(
  SendAdminaWebhookFunction,
  async ({ inputs, env }) => {
    const webhookUrl = env.WEBHOOK_URL;
    const secret = env.SECRET;

    if (!webhookUrl || !secret) {
      return {
        error: "WEBHOOK_URL または SECRET が未設定です。`slack env add` で設定してください。",
      };
    }

    // 署名の計算対象文字列と送信するボディは完全に同一の文字列にする
    // (インデントや改行が入ると署名検証エラーになる)
    const body = JSON.stringify({ text: inputs.text });
    const timestamp = Date.now().toString();
    const signature = await computeSignature(secret, `${timestamp}.${body}`);

    let response: Response;
    try {
      response = await fetch(webhookUrl, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          "X-Webhook-Timestamp": timestamp,
          "X-Webhook-Signature": `sha256=${signature}`,
        },
        body,
      });
    } catch (error) {
      return { error: `Admina へのリクエストが失敗しました: ${error}` };
    }

    const responseBody = await response.text();

    if (!response.ok) {
      return {
        error: `Admina の Webhook がエラーを返しました (status=${response.status}): ${responseBody}`,
      };
    }

    return {
      outputs: {
        status_code: response.status,
        response_body: responseBody,
      },
    };
  },
);

import json
import hmac
import hashlib
import time
import requests

webhook_url = input_data.get('webhook_url', '')
secret_key = input_data.get('secret_key', '')

if not webhook_url or not secret_key:
    return {'error': 'webhook_url and secret_key are required', 'status_code': None}

payload = {"event": "test", "message": "hello"}

# 空白なしのコンパクトな JSON にする（署名対象と送信ボディを完全に一致させる）
json_string = json.dumps(payload, separators=(',', ':'))

timestamp = str(int(time.time() * 1000))
signature_string = f"{timestamp}.{json_string}"

signature = hmac.new(
    secret_key.encode(),
    signature_string.encode(),
    hashlib.sha256
).hexdigest()

headers = {
    'Content-Type': 'application/json',
    'X-Webhook-Timestamp': timestamp,
    'X-Webhook-Signature': f"sha256={signature}"
}

response = requests.post(webhook_url, data=json_string, headers=headers)

return {
    'status_code': response.status_code,
    'response_text': response.text
}

// Google Apps Script から Admina Automation を起動
function sendWebhook() {
    const props = PropertiesService.getScriptProperties();
    const WEBHOOK_URL = props.getProperty('WEBHOOK_URL');
    const SECRET = props.getProperty('SECRET');

    const body = JSON.stringify({ event: 'user.created', data: { text: 'hello gas' } });
    const timestamp = Date.now();

    const signBytes = Utilities.computeHmacSha256Signature(`${timestamp}.${body}`, SECRET);
    const signature = signBytes
        .map(b => ((b < 0 ? b + 256 : b).toString(16)).padStart(2, '0'))
        .join('');

    const options = {
        method: 'post',
        contentType: 'application/json',
        payload: body,
        headers: {
            'X-Webhook-Timestamp': String(timestamp),
            'X-Webhook-Signature': `sha256=${signature}`,
        },
        muteHttpExceptions: true,
    };

    const res = UrlFetchApp.fetch(WEBHOOK_URL, options);
    console.log(res.getResponseCode());
    console.log(res.getContentText());
}