(StringComparer.OrdinalIgnoreCase);
foreach (var (name, value) in headers)
{
lookup.TryAdd(name, value);
}
if (!lookup.TryGetValue("webhook-id", out var messageId) ||
!lookup.TryGetValue("webhook-timestamp", out var timestamp) ||
!lookup.TryGetValue("webhook-signature", out var signatures))
{
return false; // unsigned request: not from Anthropic
}
if (!long.TryParse(timestamp, out var signedAt) ||
Math.Abs(DateTimeOffset.UtcNow.ToUnixTimeSeconds() - signedAt) > ToleranceSeconds)
{
return false; // replayed, or the clocks disagree
}
// 标准 base64 字母表：URL 安全的解码器会推导出错误的密钥字节。
var encodedKey = secret.StartsWith("whsec_") ? secret["whsec_".Length..] : secret;
byte[] key;
try
{
key = Convert.FromBase64String(encodedKey);
}
catch (FormatException)
{
return false; // misconfigured secret: reject rather than crash
}
byte[] payload = [.. Encoding.UTF8.GetBytes($"{messageId}.{timestamp}."), .. body];
var expected = Encoding.UTF8.GetBytes(
"v1," + Convert.ToBase64String(HMACSHA256.HashData(key, payload)));
// FixedTimeEquals 为常量时间比较，长度不匹配时返回 false。
return signatures.Split(' ', StringSplitOptions.RemoveEmptyEntries).Any(candidate =>
CryptographicOperations.FixedTimeEquals(Encoding.UTF8.GetBytes(candidate), expected));
}
}
```
```go Go
package hooks
import (
"crypto/hmac"
"crypto/sha256"
"encoding/base64"
"net/http"
"strconv"
"strings"
"time"
)
const toleranceSeconds = 300
// verify 报告 body 是否由 Anthropic 为该组织签名。
// net/http 在查找时会规范化标头名称，因此大小写改变后的名称仍能匹配。
func verify(secret string, header http.Header, body []byte) bool {
messageID := header.Get("webhook-id")
timestamp := header.Get("webhook-timestamp")
signatures := header.Get("webhook-signature")
if messageID == "" || timestamp == "" || signatures == "" {
return false // unsigned request: not from Anthropic
}
signedAt, err := strconv.ParseInt(timestamp, 10, 64)
if err != nil {
return false
}
age := time.Now().Unix() - signedAt
if age > toleranceSeconds || age < -toleranceSeconds {
return false // replayed, or the clocks disagree
}
// 标准 base64 字母表：URL 安全的解码器会得出错误的密钥字节。
key, err := base64.StdEncoding.DecodeString(strings.TrimPrefix(secret, "whsec_"))
if err != nil {
return false
}
mac := hmac.New(sha256.New, key)
mac.Write([]byte(messageID + "." + timestamp + "."))
mac.Write(body)
expected := "v1," + base64.StdEncoding.EncodeToString(mac.Sum(nil))
for _, candidate := range strings.Fields(signatures) {
if hmac.Equal([]byte(candidate), []byte(expected)) { // constant-time
return true
}
}
return false
}
```
```java Java
import java.nio.charset.StandardCharsets;
import java.security.GeneralSecurityException;
import java.security.MessageDigest;
import java.time.Instant;
import java.util.Base64;
import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
public final class InferenceHookVerifier {
private static final long TOLERANCE_SECONDS = 300;
/**
* Returns true if the body was signed by Anthropic for this organization.
*
* Anthropic sends header names in lowercase, but proxies are free to
* re-case them, so normalize the lookup to lowercase.
*/
public static boolean verify(String secret, Map headers, byte[] body) {
Map lowercased = new HashMap<>();
headers.forEach((name, value) -> lowercased.put(name.toLowerCase(Locale.ROOT), value));
String messageId = lowercased.get("webhook-id");
String timestamp = lowercased.get("webhook-timestamp");
String signatures = lowercased.get("webhook-signature");
if (messageId == null || timestamp == null || signatures == null) {
return false; // unsigned request: not from Anthropic
}
long signedAt;
try {
signedAt = Long.parseLong(timestamp);
} catch (NumberFormatException _) {
return false;
}
if (Math.abs(Instant.now().getEpochSecond() - signedAt) > TOLERANCE_SECONDS) {
return false; // replayed, or the clocks disagree
}
// 标准 base64 字母表：URL 安全的解码器会推导出错误的密钥字节。
byte[] key;
try {
key = Base64.getDecoder().decode(
secret.startsWith("whsec_") ? secret.substring("whsec_".length()) : secret);
} catch (IllegalArgumentException _) {
return false; // misconfigured secret: reject rather than crash
}
byte[] expected;
try {
Mac mac = Mac.getInstance("HmacSHA256");
mac.init(new SecretKeySpec(key, "HmacSHA256"));
mac.update((messageId + "." + timestamp + ".").getBytes(StandardCharsets.UTF_8));
expected = ("v1," + Base64.getEncoder().encodeToString(mac.doFinal(body)))
.getBytes(StandardCharsets.UTF_8);
} catch (GeneralSecurityException impossible) {
// 每个 JVM 都自带 HmacSHA256，因此这在运行时永远不会触发。
throw new IllegalStateException(impossible);
}
for (String candidate : signatures.split(" ")) {
if (MessageDigest.isEqual(candidate.getBytes(StandardCharsets.UTF_8), expected)) {
return true; // MessageDigest.isEqual is constant-time
}
}
return false;
}
}
```
```php PHP
const TOLERANCE_SECONDS = 300;
/**
* Returns true if the body was signed by Anthropic for this organization.
*
* Anthropic sends header names in lowercase, but proxies are free to
* re-case them, so normalize the lookup to lowercase.
*/
function verify(string $secret, array $headers, string $body): bool
{
$lowercased = array_change_key_case($headers, CASE_LOWER);
$messageId = $lowercased['webhook-id'] ?? null;
$timestamp = $lowercased['webhook-timestamp'] ?? null;
$signatures = $lowercased['webhook-signature'] ?? null;
if ($messageId === null || $timestamp === null || $signatures === null) {
return false; // unsigned request: not from Anthropic
}
$signedAt = filter_var($timestamp, FILTER_VALIDATE_INT);
if ($signedAt === false || abs(time() - $signedAt) > TOLERANCE_SECONDS) {
return false; // replayed, or the clocks disagree
}
// 标准 base64 字母表：URL 安全的解码器会推导出错误的密钥字节。
$encodedKey = str_starts_with($secret, 'whsec_') ? substr($secret, strlen('whsec_')) : $secret;
$key = base64_decode($encodedKey, strict: true);
if ($key === false) {
return false;
}
$payload = "{$messageId}.{$timestamp}." . $body;
$expected = 'v1,' . base64_encode(hash_hmac('sha256', $payload, $key, binary: true));
foreach (explode(' ', $signatures) as $candidate) {
if (hash_equals($expected, $candidate)) { // constant-time
return true;
}
}
return false;
}
```
```ruby Ruby
# base64 在 Ruby 3.4 中是捆绑 gem：由 Bundler 管理的应用需添加 gem "base64"。
require "base64"
require "openssl"
TOLERANCE_SECONDS = 300
# 如果请求体由 Anthropic 为该组织签名，则返回 true。
#
# Anthropic 发送的标头名称为小写，但代理可以自由地
# 更改其大小写，因此将查找统一规范化为小写。
def verify(secret, headers, body)
lowercased = headers.transform_keys(&:downcase)
message_id = lowercased["webhook-id"]
timestamp = lowercased["webhook-timestamp"]
signatures = lowercased["webhook-signature"]
if message_id.nil? || timestamp.nil? || signatures.nil?
return false # unsigned request: not from Anthropic
end
signed_at = Integer(timestamp, exception: false)
if signed_at.nil? || (Time.now.to_i - signed_at).abs > TOLERANCE_SECONDS
return false # replayed, or the clocks disagree
end
# 标准 base64 字母表：URL 安全的解码器会推导出错误的密钥字节。
begin
key = Base64.strict_decode64(secret.delete_prefix("whsec_"))
rescue ArgumentError
return false # misconfigured secret: reject rather than crash
end
# 单独传入请求体，这样其编码就无需与前缀的编码一致。
hmac = OpenSSL::HMAC.new(key, "SHA256")
hmac.update("#{message_id}.#{timestamp}.")
hmac.update(body)
expected = "v1," + Base64.strict_encode64(hmac.digest)
signatures.split(" ").any? do |candidate|
# fixed_length_secure_compare 在长度不匹配时会抛出异常，因此先筛查长度。
candidate.bytesize == expected.bytesize &&
OpenSSL.fixed_length_secure_compare(candidate, expected)
end
end
```