-
-
Notifications
You must be signed in to change notification settings - Fork 2.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1e12f36
commit fa1b5ee
Showing
8 changed files
with
269 additions
and
31 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -89,8 +89,8 @@ lib: | |
|
|
||
| lib_install: | ||
| go get -v -d | ||
| go install -v github.com/sagernet/gomobile/cmd/[email protected]20230701084532-493ee2e45182 | ||
| go install -v github.com/sagernet/gomobile/cmd/[email protected]20230701084532-493ee2e45182 | ||
| go install -v github.com/sagernet/gomobile/cmd/[email protected]20230728014906-3de089147f59 | ||
| go install -v github.com/sagernet/gomobile/cmd/[email protected]20230728014906-3de089147f59 | ||
|
|
||
| clean: | ||
| rm -rf bin dist sing-box | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,219 @@ | ||
| package libbox | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "encoding/binary" | ||
|
|
||
| E "github.com/sagernet/sing/common/exceptions" | ||
| "github.com/sagernet/sing/common/rw" | ||
| ) | ||
|
|
||
| func EncodeChunkedMessage(data []byte) []byte { | ||
| var buffer bytes.Buffer | ||
| binary.Write(&buffer, binary.BigEndian, uint16(len(data))) | ||
| buffer.Write(data) | ||
| return buffer.Bytes() | ||
| } | ||
|
|
||
| func DecodeLengthChunk(data []byte) int32 { | ||
| return int32(binary.BigEndian.Uint16(data)) | ||
| } | ||
|
|
||
| const ( | ||
| MessageTypeError = iota | ||
| MessageTypeProfileList | ||
| MessageTypeProfileContentRequest | ||
| MessageTypeProfileContent | ||
| ) | ||
|
|
||
| type ErrorMessage struct { | ||
| Message string | ||
| } | ||
|
|
||
| func (e *ErrorMessage) Encode() []byte { | ||
| var buffer bytes.Buffer | ||
| buffer.WriteByte(MessageTypeError) | ||
| rw.WriteVString(&buffer, e.Message) | ||
| return buffer.Bytes() | ||
| } | ||
|
|
||
| func DecodeErrorMessage(data []byte) (*ErrorMessage, error) { | ||
| reader := bytes.NewReader(data) | ||
| messageType, err := rw.ReadByte(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if messageType != MessageTypeError { | ||
| return nil, E.New("invalid message") | ||
| } | ||
| var message ErrorMessage | ||
| message.Message, err = rw.ReadVString(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &message, nil | ||
| } | ||
|
|
||
| const ( | ||
| ProfileTypeLocal int32 = iota | ||
| ProfileTypeiCloud | ||
| ProfileTypeRemote | ||
| ) | ||
|
|
||
| type ProfilePreview struct { | ||
| ProfileID int64 | ||
| Name string | ||
| Type int32 | ||
| } | ||
|
|
||
| type ProfilePreviewIterator interface { | ||
| Next() *ProfilePreview | ||
| HasNext() bool | ||
| } | ||
|
|
||
| type ProfileEncoder struct { | ||
| profiles []ProfilePreview | ||
| } | ||
|
|
||
| func (e *ProfileEncoder) Append(profile *ProfilePreview) { | ||
| e.profiles = append(e.profiles, *profile) | ||
| } | ||
|
|
||
| func (e *ProfileEncoder) Encode() []byte { | ||
| var buffer bytes.Buffer | ||
| buffer.WriteByte(MessageTypeProfileList) | ||
| binary.Write(&buffer, binary.BigEndian, uint16(len(e.profiles))) | ||
| for _, preview := range e.profiles { | ||
| binary.Write(&buffer, binary.BigEndian, preview.ProfileID) | ||
| rw.WriteVString(&buffer, preview.Name) | ||
| binary.Write(&buffer, binary.BigEndian, preview.Type) | ||
| } | ||
| return buffer.Bytes() | ||
| } | ||
|
|
||
| type ProfileDecoder struct { | ||
| profiles []*ProfilePreview | ||
| } | ||
|
|
||
| func (d *ProfileDecoder) Decode(data []byte) error { | ||
| reader := bytes.NewReader(data) | ||
| messageType, err := reader.ReadByte() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if messageType != MessageTypeProfileList { | ||
| return E.New("invalid message") | ||
| } | ||
| var profileCount uint16 | ||
| err = binary.Read(reader, binary.BigEndian, &profileCount) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| for i := 0; i < int(profileCount); i++ { | ||
| var profile ProfilePreview | ||
| err = binary.Read(reader, binary.BigEndian, &profile.ProfileID) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| profile.Name, err = rw.ReadVString(reader) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| err = binary.Read(reader, binary.BigEndian, &profile.Type) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| d.profiles = append(d.profiles, &profile) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (d *ProfileDecoder) Iterator() ProfilePreviewIterator { | ||
| return newIterator(d.profiles) | ||
| } | ||
|
|
||
| type ProfileContentRequest struct { | ||
| ProfileID int64 | ||
| } | ||
|
|
||
| func (r *ProfileContentRequest) Encode() []byte { | ||
| var buffer bytes.Buffer | ||
| buffer.WriteByte(MessageTypeProfileContentRequest) | ||
| binary.Write(&buffer, binary.BigEndian, r.ProfileID) | ||
| return buffer.Bytes() | ||
| } | ||
|
|
||
| func DecodeProfileContentRequest(data []byte) (*ProfileContentRequest, error) { | ||
| reader := bytes.NewReader(data) | ||
| messageType, err := rw.ReadByte(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if messageType != MessageTypeProfileContentRequest { | ||
| return nil, E.New("invalid message") | ||
| } | ||
| var request ProfileContentRequest | ||
| err = binary.Read(reader, binary.BigEndian, &request.ProfileID) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &request, nil | ||
| } | ||
|
|
||
| type ProfileContent struct { | ||
| Name string | ||
| Type int32 | ||
| Config string | ||
| RemotePath string | ||
| AutoUpdate bool | ||
| LastUpdated int64 | ||
| } | ||
|
|
||
| func (c *ProfileContent) Encode() []byte { | ||
| var buffer bytes.Buffer | ||
| buffer.WriteByte(MessageTypeProfileContent) | ||
| rw.WriteVString(&buffer, c.Name) | ||
| binary.Write(&buffer, binary.BigEndian, c.Type) | ||
| rw.WriteVString(&buffer, c.Config) | ||
| rw.WriteVString(&buffer, c.RemotePath) | ||
| binary.Write(&buffer, binary.BigEndian, c.AutoUpdate) | ||
| binary.Write(&buffer, binary.BigEndian, c.LastUpdated) | ||
| return buffer.Bytes() | ||
| } | ||
|
|
||
| func DecodeProfileContent(data []byte) (*ProfileContent, error) { | ||
| reader := bytes.NewReader(data) | ||
| messageType, err := rw.ReadByte(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if messageType != MessageTypeProfileContent { | ||
| return nil, E.New("invalid message") | ||
| } | ||
| var content ProfileContent | ||
| content.Name, err = rw.ReadVString(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| err = binary.Read(reader, binary.BigEndian, &content.Type) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| content.Config, err = rw.ReadVString(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| content.RemotePath, err = rw.ReadVString(reader) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| err = binary.Read(reader, binary.BigEndian, &content.AutoUpdate) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| err = binary.Read(reader, binary.BigEndian, &content.LastUpdated) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &content, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.