接收并处理回调

func EventCallback(w http.ResponseWriter, r *http.Request) {
    // 读取请求体
    body, err := ioutil.ReadAll(r.Body)
    if err != nil {
        http.Error(w, "Failed to read request body", http.StatusInternalServerError)
        log.Printf("Failed to read request body: %v", err)
        return
    }
    defer r.Body.Close()
    
    // 记录请求体日志
    log.Printf("EventCallback body %s", string(body))

    reqSignature := r.Header.Get("X-Coze-Signature")
    reqNonce := r.Header.Get("X-Coze-Nonce")
    reqTimestamp := r.Header.Get("X-Coze-Timestamp")

    // 校验签名
     sign := Signature(reqNonce, reqTimestamp, string(body), "your_connector_token")
    log.Printf("EventCallback sign gen: %s", sign)
    log.Printf("EventCallback sign result %t", sign == reqSignature)
    if sign != reqSignature{
        // 签名不通过处理
        http.Error(w, "Signature verification failed", http.StatusUnauthorized)
        log.Printf("Signature verification failed")
        return
    }

    // 反序列事件
    req := &ConnectorCallbackEvent{}
    err := json.Unmarshal(c.GetBodyBytes(), req)
    if err != nil {
       http.Error(w, "Failed to unmarshal ConnectorCallbackEvent", http.StatusInternalServerError)
        log.Printf("Failed to unmarshal ConnectorCallbackEvent: %+v", err)
        return
    }
    
    // 根据不同的 eventType，反序列化为不同的事件体
    var event BotPublishedEvent
    if req.Header.EventType == ConnectorCallbackEventTypeBotPublish {
       err = json.Unmarshal(req.Event, &event)
       if err != nil {
          http.Error(w, "Failed to unmarshal BotPublishedEvent", http.StatusInternalServerError)
            log.Printf("Failed to unmarshal BotPublishedEvent: %+v", err)
            return
       }
    }
    
    // 进行业务处理
    log.Printf("EventCallback BotID %d", event.BotID)
    log.Printf("EventCallback UserID %d", event.UserID)
    log.Printf("EventCallback Description %s", event.Description)
    log.Printf("EventCallback BotName %s", event.BotName)

    // 返回处理结果
    auditByte, _ := json.Marshal(ConnectorCallbackEventResponse{
        Audit: audit,
    })
    log.Printf("EventCallback auditByte: %s", string(auditByte))
    w.Header().Set("Content-Type", "application/json")
    w.WriteHeader(http.StatusOK)
    _, _ = w.Write(auditByte)
}

// 签名
func Signature(nonce string, timestamp string, body string, token string) string {
    var b strings.Builder
    b.WriteString(timestamp)
    b.WriteString(nonce)
    b.WriteString(token)
    b.WriteString(body)
    bs := []byte(b.String())
    h := sha1.New()
    h.Write(bs)
    bs = h.Sum(nil)
    return fmt.Sprintf("%x", bs)
}

// 以下为事件定义：

// 回调的总结构体
type ConnectorCallbackEvent struct {
    Header      ConnectorCallbackEventHeader `json:"header,omitempty"`
    Event       json.RawMessage              `json:"event,omitempty"`
}

// 事件类型
type ConnectorCallbackEventType string
const (
    // 发布类型
    ConnectorCallbackEventTypeBotPublish ConnectorCallbackEventType = "bot.published"
)

// 事件 header
type ConnectorCallbackEventHeader struct {
    EventType  ConnectorCallbackEventType `json:"event_type"`  // 通用事件类型
    EventID    string                     `json:"event_id"`    // 事件 ID
    CreatedAt  int64                      `json:"created_at"`  // 事件发生的UTC时间（毫秒）
}

// 根据 eventType 返回不同的结构
type BotPublishedEvent struct {
    UserID      int64                        `json:"user_id,omitempty"`     // 用户 ID
    BotID       int64                        `json:"bot_id,omitempty"`      // 机器人 ID
    BotName     string                       `json:"bot_name,omitempty"`    // 机器人名称
    Description string                       `json:"description,omitempty"` // 机器人描述
}

// 返回结构
type ConnectorCallbackEventResponse struct {
    Audit Audit `json:"audit,omitempty"` // 审核
    ShareLink string `json:"share_link,omitempty"` // 分享链接
}

type Audit struct{
    AuditStatus AuditStatus  `json:"audit_status,omitempty"`   // 审核状态
    Reason      string      `json:"reason,omitempty"`          // 原因
}

type AuditStatus int32
const (
    AuditStatus_Progress AuditStatus = 1 // 审核中
    AuditStatus_Audited  AuditStatus = 2 // 通过
    AuditStatus_Reject   AuditStatus = 3 // 拒绝
)