mirror of
https://github.com/p4gefau1t/trojan-go.git
synced 2024-04-21 12:21:34 +00:00
41 lines
1.1 KiB
Go
41 lines
1.1 KiB
Go
package api
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"testing"
|
|
|
|
"github.com/p4gefau1t/trojan-go/common"
|
|
"github.com/p4gefau1t/trojan-go/conf"
|
|
"github.com/p4gefau1t/trojan-go/stat"
|
|
"google.golang.org/grpc"
|
|
)
|
|
|
|
func TestClientAPI(t *testing.T) {
|
|
meter := &stat.MemoryTrafficMeter{}
|
|
go RunClientAPIService(context.Background(), &conf.GlobalConfig{
|
|
API: conf.APIConfig{
|
|
APIAddress: common.NewAddress("127.0.0.1", 10000, "tcp"),
|
|
},
|
|
}, meter)
|
|
meter.Count("test", 123, 456)
|
|
conn, err := grpc.Dial("127.0.0.1:10000", grpc.WithInsecure())
|
|
common.Must(err)
|
|
client := NewTrojanServiceClient(conn)
|
|
reply, err := client.QueryStats(context.Background(), &StatsRequest{})
|
|
common.Must(err)
|
|
fmt.Println(reply.Download, reply.Upload)
|
|
if reply.Download != 456 || reply.Upload != 123 {
|
|
t.Fatal("wrong result")
|
|
}
|
|
}
|
|
|
|
func TestRealClientAPI(t *testing.T) {
|
|
conn, err := grpc.Dial("127.0.0.1:10000", grpc.WithInsecure())
|
|
common.Must(err)
|
|
client := NewTrojanServiceClient(conn)
|
|
reply, err := client.QueryStats(context.Background(), &StatsRequest{})
|
|
common.Must(err)
|
|
fmt.Println(reply.Download, reply.Upload)
|
|
}
|