-
Notifications
You must be signed in to change notification settings - Fork 138
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
Showing
16 changed files
with
158 additions
and
98 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
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
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,60 @@ | ||
| package db | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "strconv" | ||
| "strings" | ||
| ) | ||
|
|
||
| type CBMobileSubprotocolVersion int | ||
|
|
||
| const ( | ||
| // CBMobileReplicationV2 the original subprotocol used by CBLite 2.x | ||
| CBMobileReplicationV2 CBMobileSubprotocolVersion = iota + 2 | ||
| // CBMobileReplicationV3 minor changes to support revocation and ISGR | ||
| CBMobileReplicationV3 | ||
| // CBMobileReplicationV4 switched from RevTree-based revision IDs to Version Vectors (Hybrid Logical Vector) | ||
| CBMobileReplicationV4 | ||
|
|
||
| // _nextCBMobileSubprotocolVersions reserved for maxCBMobileSubprotocolVersion | ||
| _nextCBMobileSubprotocolVersions | ||
|
|
||
| // minCBMobileSubprotocolVersion is the minimum supported subprotocol version by SG | ||
| minCBMobileSubprotocolVersion = CBMobileReplicationV2 | ||
| // maxCBMobileSubprotocolVersion is the maximum supported subprotocol version by SG | ||
| maxCBMobileSubprotocolVersion = _nextCBMobileSubprotocolVersions - 1 | ||
| ) | ||
|
|
||
| const cbMobileBLIPSubprotocolPrefix = "CBMobile_" | ||
|
|
||
| // Format must match the AppProtocolId provided by the peer (CBLite / ISGR) | ||
| func (v CBMobileSubprotocolVersion) SubprotocolString() string { | ||
| return cbMobileBLIPSubprotocolPrefix + strconv.Itoa(int(v)) | ||
| } | ||
|
|
||
| // ParseSubprotocolString takes a 'CBMobile_' prefixed string and returns the subprotocol version. | ||
| func ParseSubprotocolString(s string) (CBMobileSubprotocolVersion, error) { | ||
| vStr, ok := strings.CutPrefix(s, cbMobileBLIPSubprotocolPrefix) | ||
| if !ok { | ||
| return 0, fmt.Errorf("invalid subprotocol string: %q", s) | ||
| } | ||
| v, err := strconv.Atoi(vStr) | ||
| if err != nil { | ||
| return 0, fmt.Errorf("invalid subprotocol string: %q: %w", s, err) | ||
| } | ||
| if v < int(minCBMobileSubprotocolVersion) || v > int(maxCBMobileSubprotocolVersion) { | ||
| return 0, fmt.Errorf("invalid subprotocol version: %q", s) | ||
| } | ||
| return CBMobileSubprotocolVersion(v), nil | ||
| } | ||
|
|
||
| // supportedSubprotocols returns a list of supported subprotocol versions, in order of most preferred first | ||
| func supportedSubprotocols() []string { | ||
| numSubprotocols := maxCBMobileSubprotocolVersion - minCBMobileSubprotocolVersion + 1 | ||
| subProtocols := make([]string, 0, numSubprotocols) | ||
| // iterate backwards so we prefer the latest protocol versions | ||
| for i := maxCBMobileSubprotocolVersion; i >= minCBMobileSubprotocolVersion; i-- { | ||
| subProtocols = append(subProtocols, i.SubprotocolString()) | ||
| } | ||
| return subProtocols | ||
| } |
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,17 @@ | ||
| package db | ||
|
|
||
| import ( | ||
| "testing" | ||
|
|
||
| "github.com/stretchr/testify/require" | ||
| ) | ||
|
|
||
| // TestSubprotocolString roundtrips the parse/format Subprotocol methods on the subprotocol constants. | ||
| func TestSubprotocolString(t *testing.T) { | ||
| for i := minCBMobileSubprotocolVersion; i <= maxCBMobileSubprotocolVersion; i++ { | ||
| str := i.SubprotocolString() | ||
| parsed, err := ParseSubprotocolString(str) | ||
| require.NoError(t, err) | ||
| require.Equal(t, i, parsed) | ||
| } | ||
| } |
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.