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

rename protobuf.ProtoBuf -> protobuf.Message

Browse source
This commit is contained in:
Sergey Cherepanov 2025-04-08 13:41:23 +02:00
parent 5d2217aae8
commit 914642fb5b
No known key found for this signature in database
GPG key ID: 87F8EDE8FBDF637C
3 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
commonspace/object/acl/syncacl/response/response.go
View file

@ -2,6 +2,7 @@ package response
import ( import (
"fmt" "fmt"
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
"github.com/anyproto/any-sync/commonspace/spacesyncproto" "github.com/anyproto/any-sync/commonspace/spacesyncproto"

2
commonspace/spacesyncproto/spacesync.go
View file

@ -20,7 +20,7 @@ type ClientFactory interface {
} }
func MarshallSyncMessage(message proto.Message, spaceId, objectId string) (objMsg *ObjectSyncMessage, err error) { func MarshallSyncMessage(message proto.Message, spaceId, objectId string) (objMsg *ObjectSyncMessage, err error) {
payload, err := message.(protobuf.ProtoBuf).MarshalVT() payload, err := message.(protobuf.Message).MarshalVT()
if err != nil { if err != nil {
return return
} }

6
protobuf/protobuf.go
View file

@ -7,7 +7,7 @@ import (
"google.golang.org/protobuf/proto" "google.golang.org/protobuf/proto"
) )
type ProtoBuf interface { type Message interface {
SizeVT() (n int) SizeVT() (n int)
MarshalVT() (dAtA []byte, err error) MarshalVT() (dAtA []byte, err error)
UnmarshalVT(dAtA []byte) error UnmarshalVT(dAtA []byte) error
@ -15,7 +15,7 @@ type ProtoBuf interface {
} }
func MarshalAppend(buf []byte, pb proto.Message) ([]byte, error) { func MarshalAppend(buf []byte, pb proto.Message) ([]byte, error) {
if m, ok := pb.(ProtoBuf); ok { if m, ok := pb.(Message); ok {
siz := m.SizeVT() siz := m.SizeVT()
offset := len(buf) offset := len(buf)
buf = slices.Grow(buf, offset+siz)[:offset+siz] buf = slices.Grow(buf, offset+siz)[:offset+siz]
@ -24,7 +24,7 @@ func MarshalAppend(buf []byte, pb proto.Message) ([]byte, error) {
return nil, fmt.Errorf("proto: MarshalAppend not supported by %T", pb) return nil, fmt.Errorf("proto: MarshalAppend not supported by %T", pb)
} }
func MarshalToSizedBuffer(m ProtoBuf, b []byte, offset int) ([]byte, error) { func MarshalToSizedBuffer(m Message, b []byte, offset int) ([]byte, error) {
_, err := m.MarshalToSizedBufferVT(b[offset:]) _, err := m.MarshalToSizedBufferVT(b[offset:])
if err != nil { if err != nil {
return nil, err return nil, err