// Copyright (c) 2021 Terminus, Inc.

//

// Licensed under the Apache License, Version 2.0 (the "License");

// you may not use this file except in compliance with the License.

// You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software

// distributed under the License is distributed on an "AS IS" BASIS,

// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

// See the License for the specific language governing permissions and

// limitations under the License.

package bundle

import (

"bytes"

"fmt"

"github.com/erda-project/erda/apistructs"

"github.com/erda-project/erda/bundle/apierrors"

)

// CreateMessage 发送消息（不包括 event ）, `Message.Labels` 见 `MessageLabel`

func (b *Bundle) CreateMessage(message *apistructs.MessageCreateRequest) error {

host, err := b.urls.EventBox()

if err != nil {

return err

}

hc := b.hc

var buf bytes.Buffer

resp, err := hc.Post(host).Path("/api/dice/eventbox/message/create").

Header("Accept", "application/json").

JSONBody(&message).Do().Body(&buf)

if err != nil {

return apierrors.ErrInvoke.InternalError(err)

}

if !resp.IsOK() {

return apierrors.ErrInvoke.InternalError(

fmt.Errorf("failed to create message, status code: %d, body: %v",

resp.StatusCode(),

buf.String(),

))

}

return nil

}