|
1 | 1 | package impl |
2 | 2 |
|
3 | 3 | import ( |
| 4 | + "bytes" |
4 | 5 | "context" |
5 | 6 | "encoding/json" |
6 | 7 |
|
@@ -47,3 +48,35 @@ func (j *JMServer) GetAccountChat(ctx context.Context, req *pb.Empty) (*pb.Accou |
47 | 48 | status.Ok = true |
48 | 49 | return &pb.AccountDetailResponse{Status: &status, Payload: st}, nil |
49 | 50 | } |
| 51 | + |
| 52 | +func (j *JMServer) CallAPI(ctx context.Context, req *pb.HTTPRequest) (*pb.HTTPResponse, error) { |
| 53 | + method := req.GetMethod() |
| 54 | + reqUrl := req.GetPath() |
| 55 | + query := req.GetQuery() |
| 56 | + body := req.GetBody() |
| 57 | + header := req.GetHeader() |
| 58 | + apiClient := j.apiClient.Copy() |
| 59 | + var ( |
| 60 | + status pb.Status |
| 61 | + ) |
| 62 | + for k, v := range header { |
| 63 | + apiClient.SetHeader(k, v) |
| 64 | + } |
| 65 | + var bodyObj any |
| 66 | + if len(body) > 0 { |
| 67 | + if err := json.NewDecoder(bytes.NewBuffer(body)).Decode(&bodyObj); err != nil { |
| 68 | + logger.Errorf("Decode body failed: %v", err) |
| 69 | + status.Err = err.Error() |
| 70 | + return &pb.HTTPResponse{Status: &status}, err |
| 71 | + } |
| 72 | + } |
| 73 | + var resJson bytes.Buffer |
| 74 | + _, err := apiClient.Call(method, reqUrl, bodyObj, &resJson, query) |
| 75 | + if err != nil { |
| 76 | + logger.Errorf("Call: %v", err) |
| 77 | + status.Err = err.Error() |
| 78 | + return &pb.HTTPResponse{Status: &status}, err |
| 79 | + } |
| 80 | + status.Ok = true |
| 81 | + return &pb.HTTPResponse{Status: &status, Body: resJson.Bytes()}, nil |
| 82 | +} |
0 commit comments