mirror of
https://github.com/QuantumNous/new-api.git
synced 2026-03-30 08:56:02 +00:00
* feat: codex channel * feat: codex channel * feat: codex oauth flow * feat: codex refresh cred * feat: codex usage * fix: codex err message detail * fix: codex setting ui * feat: codex refresh cred task * fix: import err * fix: codex store must be false * fix: chat -> responses tool call * fix: chat -> responses tool call
57 lines
1.2 KiB
Go
57 lines
1.2 KiB
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"strings"
|
|
)
|
|
|
|
func FetchCodexWhamUsage(
|
|
ctx context.Context,
|
|
client *http.Client,
|
|
baseURL string,
|
|
accessToken string,
|
|
accountID string,
|
|
) (statusCode int, body []byte, err error) {
|
|
if client == nil {
|
|
return 0, nil, fmt.Errorf("nil http client")
|
|
}
|
|
bu := strings.TrimRight(strings.TrimSpace(baseURL), "/")
|
|
if bu == "" {
|
|
return 0, nil, fmt.Errorf("empty baseURL")
|
|
}
|
|
at := strings.TrimSpace(accessToken)
|
|
aid := strings.TrimSpace(accountID)
|
|
if at == "" {
|
|
return 0, nil, fmt.Errorf("empty accessToken")
|
|
}
|
|
if aid == "" {
|
|
return 0, nil, fmt.Errorf("empty accountID")
|
|
}
|
|
|
|
req, err := http.NewRequestWithContext(ctx, http.MethodGet, bu+"/backend-api/wham/usage", nil)
|
|
if err != nil {
|
|
return 0, nil, err
|
|
}
|
|
req.Header.Set("Authorization", "Bearer "+at)
|
|
req.Header.Set("chatgpt-account-id", aid)
|
|
req.Header.Set("Accept", "application/json")
|
|
if req.Header.Get("originator") == "" {
|
|
req.Header.Set("originator", "codex_cli_rs")
|
|
}
|
|
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return 0, nil, err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
body, err = io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return resp.StatusCode, nil, err
|
|
}
|
|
return resp.StatusCode, body, nil
|
|
}
|