generated from matrix-org/.github
-
Notifications
You must be signed in to change notification settings - Fork 5
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #117 from matrix-org/kegan/mitm-api
Basic reshuffling of callback/mitm code
- Loading branch information
Showing
12 changed files
with
169 additions
and
137 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,95 @@ | ||
| package mitm | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "encoding/json" | ||
| "io" | ||
| "net/http" | ||
| "net/url" | ||
| "sync" | ||
| "testing" | ||
| "time" | ||
|
|
||
| "github.com/matrix-org/complement/must" | ||
| ) | ||
|
|
||
| // must match the value in tests/addons/__init__.py | ||
| const magicMITMURL = "http://mitm.code" | ||
|
|
||
| var ( | ||
| boolTrue = true | ||
| boolFalse = false | ||
| ) | ||
|
|
||
| type Client struct { | ||
| client *http.Client | ||
| hostnameRunningComplement string | ||
| } | ||
|
|
||
| func NewClient(proxyURL *url.URL, hostnameRunningComplement string) *Client { | ||
| return &Client{ | ||
| hostnameRunningComplement: hostnameRunningComplement, | ||
| client: &http.Client{ | ||
| Timeout: 5 * time.Second, | ||
| Transport: &http.Transport{ | ||
| Proxy: http.ProxyURL(proxyURL), | ||
| }, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| func (m *Client) Configure(t *testing.T) *Configuration { | ||
| return &Configuration{ | ||
| t: t, | ||
| pathCfgs: make(map[string]*MITMPathConfiguration), | ||
| mu: &sync.Mutex{}, | ||
| client: m, | ||
| } | ||
| } | ||
|
|
||
| // Lock mitmproxy with the given set of options. | ||
| // | ||
| // If mitmproxy is already locked, this will fail the test. This is a low-level | ||
| // function which provides an escape hatch if the test needs special mitmproxy | ||
| // options. See https://docs.mitmproxy.org/stable/concepts-options/ for more | ||
| // information about options. | ||
| // | ||
| // In general, tests should not call this function, preferring to use .Configure | ||
| // which has a friendlier API shape. | ||
| func (m *Client) LockOptions(t *testing.T, options map[string]any) (lockID []byte) { | ||
| jsonBody, err := json.Marshal(map[string]interface{}{ | ||
| "options": options, | ||
| }) | ||
| t.Logf("lockOptions: %v", string(jsonBody)) | ||
| must.NotError(t, "failed to marshal options", err) | ||
| u := magicMITMURL + "/options/lock" | ||
| req, err := http.NewRequest("POST", u, bytes.NewBuffer(jsonBody)) | ||
| must.NotError(t, "failed to prepare request", err) | ||
| req.Header.Set("Content-Type", "application/json") | ||
| res, err := m.client.Do(req) | ||
| must.NotError(t, "failed to POST "+u, err) | ||
| must.Equal(t, res.StatusCode, 200, "controller returned wrong HTTP status") | ||
| lockID, err = io.ReadAll(res.Body) | ||
| must.NotError(t, "failed to read response", err) | ||
| return lockID | ||
| } | ||
|
|
||
| // Unlock mitmproxy using the lock ID provided. | ||
| // | ||
| // If mitmproxy is already unlocked, this will fail the test. If the lock ID | ||
| // does not match the ID of the existing lock, this will fail the test. | ||
| // This is a low-level function which provides an escape hatch if the test | ||
| // needs special mitmproxy options. See https://docs.mitmproxy.org/stable/concepts-options/ | ||
| // for more information about options. | ||
| // | ||
| // In general, tests should not call this function, preferring to use .Configure | ||
| // which has a friendlier API shape. | ||
| func (m *Client) UnlockOptions(t *testing.T, lockID []byte) { | ||
| t.Logf("unlockOptions") | ||
| req, err := http.NewRequest("POST", magicMITMURL+"/options/unlock", bytes.NewBuffer(lockID)) | ||
| must.NotError(t, "failed to prepare request", err) | ||
| req.Header.Set("Content-Type", "application/json") | ||
| res, err := m.client.Do(req) | ||
| must.NotError(t, "failed to do request", err) | ||
| must.Equal(t, res.StatusCode, 200, "controller returned wrong HTTP status") | ||
| } |
Oops, something went wrong.