代码拉取完成,页面将自动刷新
package client
import (
"context"
"fmt"
"gitee.com/wanjimao/dongli-kit/logging/slogger"
"gitee.com/wanjimao/dongli-kit/server/pkg/sfx"
"github.com/abiosoft/ishell"
mm "github.com/grpc-ecosystem/go-grpc-middleware/v2/metadata"
"google.golang.org/grpc/metadata"
buddy "gitee.com/wanjimao/dongli-platform/api/gen/buddy/api"
"gitee.com/wanjimao/dongli-platform/services/buddy/pkg/bfx"
)
// BuddyClient is the client for buddy service
type BuddyClient struct {
client buddy.BuddyServiceClient
cmd *ishell.Cmd
}
func CreateBuddyClient(host string) (*ishell.Cmd, error) {
client, err := bfx.NewBuddyClient(host, sfx.SecuritySettingsParams{})
if err != nil {
return nil, err
}
p := &BuddyClient{
client: client,
}
p.initShells()
return p.cmd, nil
}
func (p *BuddyClient) initShells() {
p.cmd = &ishell.Cmd{
Name: "buddy",
Help: "buddy service interactive",
Aliases: []string{"B"},
}
p.initSubShells()
}
func (p *BuddyClient) initSubShells() {
p.cmd.AddCmd(&ishell.Cmd{
Name: "add",
Help: "add buddy",
Aliases: []string{"A"},
Func: p.add,
})
}
func (p *BuddyClient) add(c *ishell.Context) {
c.ShowPrompt(false)
defer c.ShowPrompt(true)
msg := slogger.ReadLine(c, "buddy uid: ")
req := &buddy.AddBuddyRequest{
Uid: []string{msg},
ReqInfo: "test",
}
md := metadata.Pairs("authorization", fmt.Sprintf("%s %v", "bearer", "test"))
ctx := mm.MD(md).ToOutgoing(context.Background())
if response, err := p.client.AddBuddy(ctx, req); err != nil {
slogger.Warn(c, err)
} else {
slogger.Infof(c, "Response: %s", response)
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。