From c5a494f28b45dbeda1fcccdccdf516f59bd59c44 Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Thu, 29 Jun 2023 19:45:26 +0800
Subject: [PATCH] optimize the calling process from api to rpc

---
 pkg/a2r/api2rpc.go | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 pkg/a2r/api2rpc.go

diff --git a/pkg/a2r/api2rpc.go b/pkg/a2r/api2rpc.go
new file mode 100644
index 000000000..bb1cb1fac
--- /dev/null
+++ b/pkg/a2r/api2rpc.go
@@ -0,0 +1,37 @@
+package a2r
+
+import (
+	"context"
+
+	"github.com/OpenIMSDK/Open-IM-Server/pkg/apiresp"
+	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/log"
+	"github.com/OpenIMSDK/Open-IM-Server/pkg/errs"
+	"github.com/gin-gonic/gin"
+	"google.golang.org/grpc"
+)
+
+func Call[A, B, C any](
+	rpc func(client C, ctx context.Context, req *A, options ...grpc.CallOption) (*B, error),
+	client C,
+	c *gin.Context,
+) {
+	var req A
+	if err := c.BindJSON(&req); err != nil {
+		log.ZWarn(c, "gin bind json error", err, "req", req)
+		apiresp.GinError(c, errs.ErrArgs.WithDetail(err.Error()).Wrap()) // 参数错误
+		return
+	}
+	if check, ok := any(&req).(interface{ Check() error }); ok {
+		if err := check.Check(); err != nil {
+			log.ZWarn(c, "custom check error", err, "req", req)
+			apiresp.GinError(c, errs.ErrArgs.Wrap(err.Error())) // 参数校验失败
+			return
+		}
+	}
+	data, err := rpc(client, c, &req)
+	if err != nil {
+		apiresp.GinError(c, err) // RPC调用失败
+		return
+	}
+	apiresp.GinSuccess(c, data) // 成功
+}