Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
I
im-microservice
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Li Feifei
im-microservice
Commits
f1956075
Commit
f1956075
authored
Jul 13, 2020
by
Li Feifei
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
实现好友关系的http服务
parent
a9c358f2
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
343 additions
and
7 deletions
+343
-7
main.go
main.go
+2
-1
im_user_relationship.pb.gw.go
pb/im_user_relationship.pb.gw.go
+317
-1
im_user_relationship.proto
u-proto/im_user_relationship.proto
+24
-5
No files found.
main.go
View file @
f1956075
...
@@ -22,12 +22,13 @@ func main() {
...
@@ -22,12 +22,13 @@ func main() {
}
}
beeLogger
.
Log
.
Success
(
"gRPC server is running on "
+
port
+
" port."
)
beeLogger
.
Log
.
Success
(
"gRPC server is running on "
+
port
+
" port."
)
// 启动http服务
go
func
()
{
go
func
()
{
if
err
:=
gateway
.
ProvideHTTP
(
Address
,
initialize
.
RpcServer
)
.
ListenAndServe
();
err
!=
nil
{
if
err
:=
gateway
.
ProvideHTTP
(
Address
,
initialize
.
RpcServer
)
.
ListenAndServe
();
err
!=
nil
{
beeLogger
.
Log
.
Fatalf
(
"failed to api serve: %v"
,
err
)
beeLogger
.
Log
.
Fatalf
(
"failed to api serve: %v"
,
err
)
}
}
}()
}()
// 启动grpc服务
if
err
:=
initialize
.
RpcServer
.
Serve
(
lis
);
err
!=
nil
{
if
err
:=
initialize
.
RpcServer
.
Serve
(
lis
);
err
!=
nil
{
beeLogger
.
Log
.
Fatalf
(
"failed to serve: %v"
,
err
)
beeLogger
.
Log
.
Fatalf
(
"failed to serve: %v"
,
err
)
...
...
pb/im_user_relationship.pb.gw.go
View file @
f1956075
...
@@ -31,6 +31,146 @@ var _ = runtime.String
...
@@ -31,6 +31,146 @@ var _ = runtime.String
var
_
=
utilities
.
NewDoubleArray
var
_
=
utilities
.
NewDoubleArray
var
_
=
descriptor
.
ForMessage
var
_
=
descriptor
.
ForMessage
func
request_UserRelationshipService_Add_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
client
UserRelationshipServiceClient
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipAddRequest
var
metadata
runtime
.
ServerMetadata
newReader
,
berr
:=
utilities
.
IOReaderFactory
(
req
.
Body
)
if
berr
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
berr
)
}
if
err
:=
marshaler
.
NewDecoder
(
newReader
())
.
Decode
(
&
protoReq
);
err
!=
nil
&&
err
!=
io
.
EOF
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
client
.
Add
(
ctx
,
&
protoReq
,
grpc
.
Header
(
&
metadata
.
HeaderMD
),
grpc
.
Trailer
(
&
metadata
.
TrailerMD
))
return
msg
,
metadata
,
err
}
func
local_request_UserRelationshipService_Add_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
server
UserRelationshipServiceServer
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipAddRequest
var
metadata
runtime
.
ServerMetadata
newReader
,
berr
:=
utilities
.
IOReaderFactory
(
req
.
Body
)
if
berr
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
berr
)
}
if
err
:=
marshaler
.
NewDecoder
(
newReader
())
.
Decode
(
&
protoReq
);
err
!=
nil
&&
err
!=
io
.
EOF
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
server
.
Add
(
ctx
,
&
protoReq
)
return
msg
,
metadata
,
err
}
var
(
filter_UserRelationshipService_Delete_0
=
&
utilities
.
DoubleArray
{
Encoding
:
map
[
string
]
int
{},
Base
:
[]
int
(
nil
),
Check
:
[]
int
(
nil
)}
)
func
request_UserRelationshipService_Delete_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
client
UserRelationshipServiceClient
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipDelRequest
var
metadata
runtime
.
ServerMetadata
if
err
:=
req
.
ParseForm
();
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
if
err
:=
runtime
.
PopulateQueryParameters
(
&
protoReq
,
req
.
Form
,
filter_UserRelationshipService_Delete_0
);
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
client
.
Delete
(
ctx
,
&
protoReq
,
grpc
.
Header
(
&
metadata
.
HeaderMD
),
grpc
.
Trailer
(
&
metadata
.
TrailerMD
))
return
msg
,
metadata
,
err
}
func
local_request_UserRelationshipService_Delete_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
server
UserRelationshipServiceServer
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipDelRequest
var
metadata
runtime
.
ServerMetadata
if
err
:=
req
.
ParseForm
();
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
if
err
:=
runtime
.
PopulateQueryParameters
(
&
protoReq
,
req
.
Form
,
filter_UserRelationshipService_Delete_0
);
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
server
.
Delete
(
ctx
,
&
protoReq
)
return
msg
,
metadata
,
err
}
var
(
filter_UserRelationshipService_All_0
=
&
utilities
.
DoubleArray
{
Encoding
:
map
[
string
]
int
{},
Base
:
[]
int
(
nil
),
Check
:
[]
int
(
nil
)}
)
func
request_UserRelationshipService_All_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
client
UserRelationshipServiceClient
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipListRequest
var
metadata
runtime
.
ServerMetadata
if
err
:=
req
.
ParseForm
();
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
if
err
:=
runtime
.
PopulateQueryParameters
(
&
protoReq
,
req
.
Form
,
filter_UserRelationshipService_All_0
);
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
client
.
All
(
ctx
,
&
protoReq
,
grpc
.
Header
(
&
metadata
.
HeaderMD
),
grpc
.
Trailer
(
&
metadata
.
TrailerMD
))
return
msg
,
metadata
,
err
}
func
local_request_UserRelationshipService_All_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
server
UserRelationshipServiceServer
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
UserRelationshipListRequest
var
metadata
runtime
.
ServerMetadata
if
err
:=
req
.
ParseForm
();
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
if
err
:=
runtime
.
PopulateQueryParameters
(
&
protoReq
,
req
.
Form
,
filter_UserRelationshipService_All_0
);
err
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
server
.
All
(
ctx
,
&
protoReq
)
return
msg
,
metadata
,
err
}
func
request_UserRelationshipService_SetSpecialRelation_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
client
UserRelationshipServiceClient
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
SetSpecialRelationReq
var
metadata
runtime
.
ServerMetadata
newReader
,
berr
:=
utilities
.
IOReaderFactory
(
req
.
Body
)
if
berr
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
berr
)
}
if
err
:=
marshaler
.
NewDecoder
(
newReader
())
.
Decode
(
&
protoReq
);
err
!=
nil
&&
err
!=
io
.
EOF
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
client
.
SetSpecialRelation
(
ctx
,
&
protoReq
,
grpc
.
Header
(
&
metadata
.
HeaderMD
),
grpc
.
Trailer
(
&
metadata
.
TrailerMD
))
return
msg
,
metadata
,
err
}
func
local_request_UserRelationshipService_SetSpecialRelation_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
server
UserRelationshipServiceServer
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
SetSpecialRelationReq
var
metadata
runtime
.
ServerMetadata
newReader
,
berr
:=
utilities
.
IOReaderFactory
(
req
.
Body
)
if
berr
!=
nil
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
berr
)
}
if
err
:=
marshaler
.
NewDecoder
(
newReader
())
.
Decode
(
&
protoReq
);
err
!=
nil
&&
err
!=
io
.
EOF
{
return
nil
,
metadata
,
status
.
Errorf
(
codes
.
InvalidArgument
,
"%v"
,
err
)
}
msg
,
err
:=
server
.
SetSpecialRelation
(
ctx
,
&
protoReq
)
return
msg
,
metadata
,
err
}
var
(
var
(
filter_UserRelationshipService_ListBlackAndMuteList_0
=
&
utilities
.
DoubleArray
{
Encoding
:
map
[
string
]
int
{},
Base
:
[]
int
(
nil
),
Check
:
[]
int
(
nil
)}
filter_UserRelationshipService_ListBlackAndMuteList_0
=
&
utilities
.
DoubleArray
{
Encoding
:
map
[
string
]
int
{},
Base
:
[]
int
(
nil
),
Check
:
[]
int
(
nil
)}
)
)
...
@@ -72,6 +212,86 @@ func local_request_UserRelationshipService_ListBlackAndMuteList_0(ctx context.Co
...
@@ -72,6 +212,86 @@ func local_request_UserRelationshipService_ListBlackAndMuteList_0(ctx context.Co
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func
RegisterUserRelationshipServiceHandlerServer
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
server
UserRelationshipServiceServer
)
error
{
func
RegisterUserRelationshipServiceHandlerServer
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
server
UserRelationshipServiceServer
)
error
{
mux
.
Handle
(
"POST"
,
pattern_UserRelationshipService_Add_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateIncomingContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
local_request_UserRelationshipService_Add_0
(
rctx
,
inboundMarshaler
,
server
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_Add_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"DELETE"
,
pattern_UserRelationshipService_Delete_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateIncomingContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
local_request_UserRelationshipService_Delete_0
(
rctx
,
inboundMarshaler
,
server
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_Delete_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_All_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateIncomingContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
local_request_UserRelationshipService_All_0
(
rctx
,
inboundMarshaler
,
server
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_All_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"PUT"
,
pattern_UserRelationshipService_SetSpecialRelation_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateIncomingContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
local_request_UserRelationshipService_SetSpecialRelation_0
(
rctx
,
inboundMarshaler
,
server
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_SetSpecialRelation_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_ListBlackAndMuteList_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_ListBlackAndMuteList_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
defer
cancel
()
...
@@ -133,6 +353,86 @@ func RegisterUserRelationshipServiceHandler(ctx context.Context, mux *runtime.Se
...
@@ -133,6 +353,86 @@ func RegisterUserRelationshipServiceHandler(ctx context.Context, mux *runtime.Se
// "UserRelationshipServiceClient" to call the correct interceptors.
// "UserRelationshipServiceClient" to call the correct interceptors.
func
RegisterUserRelationshipServiceHandlerClient
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
client
UserRelationshipServiceClient
)
error
{
func
RegisterUserRelationshipServiceHandlerClient
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
client
UserRelationshipServiceClient
)
error
{
mux
.
Handle
(
"POST"
,
pattern_UserRelationshipService_Add_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
request_UserRelationshipService_Add_0
(
rctx
,
inboundMarshaler
,
client
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_Add_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"DELETE"
,
pattern_UserRelationshipService_Delete_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
request_UserRelationshipService_Delete_0
(
rctx
,
inboundMarshaler
,
client
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_Delete_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_All_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
request_UserRelationshipService_All_0
(
rctx
,
inboundMarshaler
,
client
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_All_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"PUT"
,
pattern_UserRelationshipService_SetSpecialRelation_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
request_UserRelationshipService_SetSpecialRelation_0
(
rctx
,
inboundMarshaler
,
client
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_UserRelationshipService_SetSpecialRelation_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_ListBlackAndMuteList_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
mux
.
Handle
(
"GET"
,
pattern_UserRelationshipService_ListBlackAndMuteList_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
defer
cancel
()
...
@@ -157,9 +457,25 @@ func RegisterUserRelationshipServiceHandlerClient(ctx context.Context, mux *runt
...
@@ -157,9 +457,25 @@ func RegisterUserRelationshipServiceHandlerClient(ctx context.Context, mux *runt
}
}
var
(
var
(
pattern_UserRelationshipService_ListBlackAndMuteList_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"api"
,
"v1"
,
"listBlackAndMuteList"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
pattern_UserRelationshipService_Add_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"nimserver"
,
"friend"
,
"add"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
pattern_UserRelationshipService_Delete_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"nimserver"
,
"friend"
,
"delete"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
pattern_UserRelationshipService_All_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"nimserver"
,
"friend"
,
"get"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
pattern_UserRelationshipService_SetSpecialRelation_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"nimserver"
,
"user"
,
"setSpecialRelation"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
pattern_UserRelationshipService_ListBlackAndMuteList_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
},
[]
string
{
"nimserver"
,
"user"
,
"listBlackAndMuteList"
},
""
,
runtime
.
AssumeColonVerbOpt
(
true
)))
)
)
var
(
var
(
forward_UserRelationshipService_Add_0
=
runtime
.
ForwardResponseMessage
forward_UserRelationshipService_Delete_0
=
runtime
.
ForwardResponseMessage
forward_UserRelationshipService_All_0
=
runtime
.
ForwardResponseMessage
forward_UserRelationshipService_SetSpecialRelation_0
=
runtime
.
ForwardResponseMessage
forward_UserRelationshipService_ListBlackAndMuteList_0
=
runtime
.
ForwardResponseMessage
forward_UserRelationshipService_ListBlackAndMuteList_0
=
runtime
.
ForwardResponseMessage
)
)
u-proto/im_user_relationship.proto
View file @
f1956075
...
@@ -63,13 +63,31 @@ message ListBlackAndMuteListReply {
...
@@ -63,13 +63,31 @@ message ListBlackAndMuteListReply {
}
}
service
UserRelationshipService
{
service
UserRelationshipService
{
rpc
Add
(
UserRelationshipAddRequest
)
returns
(
UserRelationshipAddReply
)
{}
rpc
Add
(
UserRelationshipAddRequest
)
returns
(
UserRelationshipAddReply
)
{
rpc
Delete
(
UserRelationshipDelRequest
)
returns
(
UserRelationshipAddReply
)
{}
option
(
google.api.http
)
=
{
rpc
All
(
UserRelationshipListRequest
)
returns
(
UserRelationshipListReply
)
{}
post
:
"/nimserver/friend/add"
rpc
SetSpecialRelation
(
SetSpecialRelationReq
)
returns
(
UserRelationshipAddReply
)
{}
body
:
"*"
};
}
rpc
Delete
(
UserRelationshipDelRequest
)
returns
(
UserRelationshipAddReply
)
{
option
(
google.api.http
)
=
{
delete
:
"/nimserver/friend/delete"
};
}
rpc
All
(
UserRelationshipListRequest
)
returns
(
UserRelationshipListReply
)
{
option
(
google.api.http
)
=
{
get
:
"/nimserver/friend/get"
};
}
rpc
SetSpecialRelation
(
SetSpecialRelationReq
)
returns
(
UserRelationshipAddReply
)
{
option
(
google.api.http
)
=
{
put
:
"/nimserver/user/setSpecialRelation"
body
:
"*"
};
}
rpc
ListBlackAndMuteList
(
ListBlackAndMuteListReq
)
returns
(
ListBlackAndMuteListReply
)
{
rpc
ListBlackAndMuteList
(
ListBlackAndMuteListReq
)
returns
(
ListBlackAndMuteListReply
)
{
option
(
google.api.http
)
=
{
option
(
google.api.http
)
=
{
get
:
"/
api/v1
/listBlackAndMuteList"
get
:
"/
nimserver/user
/listBlackAndMuteList"
};
};
}
}
}
}
\ No newline at end of file
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment