9e33febe3f
commit 1f029f560d96e4c273fbbc6e85cde23956967521 Author: Tnze <cjd001113@outlook.com> Date: Wed Dec 7 11:42:39 2022 +0800 Adjust struct field name commit 3216cc964c87880cfe3d76492a6ad399cb5660e8 Author: patyhank <mlpmmy@gmail.com> Date: Wed Dec 7 11:25:28 2022 +0800 Change PublicKeySignature to V2 commit 3308bd67b29f7734344d83503d41960934f84086 Author: patyhank <mlpmmy@gmail.com> Date: Wed Dec 7 11:19:20 2022 +0800 Change PublicKeySignature to V2
85 lines
2.1 KiB
Go
85 lines
2.1 KiB
Go
package user
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"encoding/pem"
|
|
"errors"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"time"
|
|
|
|
pk "github.com/Tnze/go-mc/net/packet"
|
|
)
|
|
|
|
var ServicesURL = "https://api.minecraftservices.com"
|
|
|
|
var client = http.DefaultClient
|
|
|
|
type KeyPairResp struct {
|
|
KeyPair struct {
|
|
PrivateKey string `json:"privateKey"`
|
|
PublicKey string `json:"publicKey"`
|
|
} `json:"keyPair"`
|
|
PublicKeySignature string `json:"publicKeySignature"`
|
|
PublicKeySignatureV2 string `json:"publicKeySignatureV2"`
|
|
ExpiresAt time.Time `json:"expiresAt"`
|
|
RefreshedAfter time.Time `json:"refreshedAfter"`
|
|
}
|
|
|
|
func (k KeyPairResp) WriteTo(w io.Writer) (int64, error) {
|
|
block, _ := pem.Decode([]byte(k.KeyPair.PublicKey))
|
|
if block == nil {
|
|
return 0, errors.New("pem decode error: no data is found")
|
|
}
|
|
signature, err := base64.StdEncoding.DecodeString(k.PublicKeySignatureV2)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return pk.Tuple{
|
|
pk.Long(k.ExpiresAt.UnixMilli()),
|
|
pk.ByteArray(block.Bytes),
|
|
pk.ByteArray(signature),
|
|
}.WriteTo(w)
|
|
}
|
|
|
|
func GetOrFetchKeyPair(accessToken string) (KeyPairResp, error) {
|
|
return fetchKeyPair(accessToken) // TODO: cache
|
|
}
|
|
|
|
func fetchKeyPair(accessToken string) (KeyPairResp, error) {
|
|
var keyPairResp KeyPairResp
|
|
err := post("/player/certificates", accessToken, &keyPairResp)
|
|
return keyPairResp, err
|
|
}
|
|
|
|
func post(endpoint string, accessToken string, resp interface{}) error {
|
|
rowResp, err := rawPost(endpoint, accessToken)
|
|
if err != nil {
|
|
return fmt.Errorf("request fail: %v", err)
|
|
}
|
|
defer rowResp.Body.Close()
|
|
err = json.NewDecoder(rowResp.Body).Decode(resp)
|
|
if err != nil {
|
|
return fmt.Errorf("parse resp fail: %v", err)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func rawPost(endpoint string, accessToken string) (*http.Response, error) {
|
|
PostRequest, err := http.NewRequest(
|
|
http.MethodPost,
|
|
ServicesURL+endpoint, nil)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("make request error: %v", err)
|
|
}
|
|
|
|
PostRequest.Header.Set("Authorization", "Bearer "+accessToken)
|
|
PostRequest.Header.Set("Content-Type", "application/json; charset=utf-8")
|
|
|
|
// Do
|
|
return client.Do(PostRequest)
|
|
}
|