in extension/client.go [95:127]
func (e *Client) Register(ctx context.Context, filename string) (*RegisterResponse, error) {
const action = "/register"
url := e.baseURL + action
reqBody, err := json.Marshal(map[string]interface{}{
"events": []EventType{Invoke, Shutdown},
})
if err != nil {
return nil, fmt.Errorf("failed to marshal register request body: %w", err)
}
httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewBuffer(reqBody))
if err != nil {
return nil, fmt.Errorf("failed to create register request: %w", err)
}
httpReq.Header.Set(extensionNameHeader, filename)
httpReq.Header.Set("User-Agent", version.UserAgent)
httpRes, err := e.httpClient.Do(httpReq)
if err != nil {
return nil, fmt.Errorf("extension register request failed: %w", err)
}
defer httpRes.Body.Close()
if httpRes.StatusCode != http.StatusOK {
return nil, fmt.Errorf("extension register request failed with status %s", httpRes.Status)
}
res := RegisterResponse{}
if err := json.NewDecoder(httpRes.Body).Decode(&res); err != nil {
return nil, fmt.Errorf("failed to decode register response body: %w", err)
}
e.ExtensionID = httpRes.Header.Get(extensionIdentiferHeader)
e.logger.Debugf("ExtensionID : %s", e.ExtensionID)
return &res, nil
}