anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Fix marshal payload

Browse source
This commit is contained in:
mcrakhman 2023-09-01 13:23:25 +02:00
parent 09d2c32610
commit 967a3b0330
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
1 changed files with 15 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

22
coordinator/coordinatorclient/coordinatorclient.go
View file

@ -60,16 +60,24 @@ func (c *coordinatorClient) Name() (name string) {
}
func (c *coordinatorClient) ChangeStatus(ctx context.Context, spaceId string, conf *coordinatorproto.DeletionConfirmPayloadWithSignature) (status *coordinatorproto.SpaceStatusPayload, err error) {
confMarshalled, err := conf.Marshal()
if err != nil {
return nil, err
}
err = c.doClient(ctx, func(cl coordinatorproto.DRPCCoordinatorClient) error {
resp, err := cl.SpaceStatusChange(ctx, &coordinatorproto.SpaceStatusChangeRequest{
var req *coordinatorproto.SpaceStatusChangeRequest
if conf != nil {
confMarshalled, err := conf.Marshal()
if err != nil {
return nil, err
}
req = &coordinatorproto.SpaceStatusChangeRequest{
SpaceId: spaceId,
DeletionPayload: confMarshalled,
DeletionPayloadType: coordinatorproto.DeletionPayloadType_Confirm,
})
}
} else {
req = &coordinatorproto.SpaceStatusChangeRequest{
SpaceId: spaceId,
}
}
err = c.doClient(ctx, func(cl coordinatorproto.DRPCCoordinatorClient) error {
resp, err := cl.SpaceStatusChange(ctx, req)
if err != nil {
return rpcerr.Unwrap(err)
}