4 Commits

Author SHA1 Message Date
7d8e23768f Add proof-measure client (public securedBy / measured-immutability service)
proof-measure is a separate, public, unauthenticated Dragonchain service. Adds:
- client.UnauthenticatedClient: HMAC-free transport mirroring Client's
  marshal/decode/error handling.
- proofmeasure.ProofMeasureClient: GetSecurity / Report / Health, default base
  URL https://proof-measure.dragonchain.com; standalone + a DragonchainSDK.ProofMeasure handle.
- models for SecurityResult/RawMeasure/ReportRequest/TransactionReport/etc
  (decimals as strings, timestamps int64).
- httptest unit tests.
2026-06-04 13:40:21 -04:00
bc2b622873 client: allow injecting a custom *http.Client (SSRF-guardable)
NewClient hardcoded its *http.Client, so a server-side caller making
requests to an attacker-influenced baseURL (a tenant's prime_endpoint)
had no way to attach an SSRF policy — the transport followed redirects
and dialed any resolved IP, reachable being the cloud metadata service.

Add NewClientWithHTTPClient + NewDragonchainSDKWithHTTPClient so callers
can supply a client whose transport enforces a dial-time resolved-IP guard
and redirect policy. Existing constructors delegate with the prior default
(30s timeout), so this is backward compatible — the guard itself lives in
the consuming server (e.g. brill-api/pkg/prime), not in this client lib.
2026-06-04 12:32:33 -04:00
d945029f33 add GetInterchain: trace a transaction/block to validator blocks + interchain anchors
New Transaction.GetInterchain and Block.GetInterchain call the prime-node
/api/v1/{transaction,block}/{id}/interchain endpoints, returning an
InterchainTrace {blockId, validatorBlocks, interchainTransactions}. Adds local
VerificationBlock / InterchainTransaction / InterchainTrace model types.
2026-06-02 14:12:49 -04:00
621e359817 Fix Block model to match server: nest header with camelCase keys
The block endpoint returns block id / prev / timestamp nested under a
"header" object with camelCase keys (blockId, dcId, prevId, prevProof,
timestamp) and a proof of just {proof}. The previous flat snake_case
Block fields never matched the response and always deserialized empty.
Add a BlockHeader struct, nest it in Block, and make Proof.Scheme
omitempty. Verified live against a dev chain.
2026-05-29 17:08:47 -04:00
9 changed files with 544 additions and 16 deletions

View File

@@ -147,6 +147,43 @@ All API methods accept a `context.Context` as their first parameter for timeout
### Block ### Block
- `Get(ctx, blockID)` - Get block by ID - `Get(ctx, blockID)` - Get block by ID
### Proof Measure (public, unauthenticated)
- `GetSecurity(ctx, network, since)` - A network's accumulated security since `since` (unix seconds; `0` = service default), as raw measure + USD valuation. `network` = `"BTC"` or `"ETH"`.
- `Report(ctx, req)` - Per-transaction "securedBy" report over interchain anchors.
- `Health(ctx)` - Service liveness.
## Proof Measure
`proof-measure` is a separate, **public, unauthenticated** Dragonchain service
(the measured-immutability / "securedBy" metric) at
`https://proof-measure.dragonchain.com`. It needs no credentials. The SDK exposes
it two ways:
```go
// 1. Via the main SDK (targets the default public endpoint):
sec, err := client.ProofMeasure.GetSecurity(ctx, "BTC", time.Now().Add(-time.Hour).Unix())
if err != nil {
log.Fatal(err)
}
fmt.Printf("BTC secured by %s (%s) since %d\n", sec.ValueUSDFormatted, sec.Raw.Value+" "+sec.Raw.Unit, sec.SinceUnix)
// 2. Standalone (no prime credentials needed; empty URL = public prod):
import "git.dragonchain.com/dragonchain/prime-sdk-go/proofmeasure"
pm := proofmeasure.NewProofMeasureClient("") // or a custom base URL
report, err := pm.Report(ctx, &models.ReportRequest{
TransactionID: "tx-123", PrimeID: "my-prime", BlockID: "42",
Anchors: []models.ReportAnchorInput{
{Network: "BTC", TxHash: "0x...", Timestamp: anchorUnix},
{Network: "ETH", TxHash: "0x...", Timestamp: anchorUnix},
},
})
if err != nil {
log.Fatal(err)
}
fmt.Printf("Secured by %s across %d anchors\n", report.TotalValueUSDFormatted, len(report.Anchors))
```
## Authentication ## Authentication
The SDK uses HMAC-SHA256 authentication. You need to provide: The SDK uses HMAC-SHA256 authentication. You need to provide:

View File

@@ -25,3 +25,16 @@ func (bc *BlockClient) Get(ctx context.Context, blockID string) (*models.Block,
} }
return &resp, nil return &resp, nil
} }
// GetInterchain traces a block to the validator (verification) blocks that
// validated it and the public-chain interchain anchors those validator blocks
// were bundled into.
func (bc *BlockClient) GetInterchain(ctx context.Context, blockID string) (*models.InterchainTrace, error) {
var resp models.InterchainTrace
path := fmt.Sprintf("/api/v1/block/%s/interchain", blockID)
err := bc.client.Get(ctx, path, &resp)
if err != nil {
return nil, err
}
return &resp, nil
}

View File

@@ -23,14 +23,23 @@ type Client struct {
} }
func NewClient(publicID, authKeyID, authKey, baseURL string) *Client { func NewClient(publicID, authKeyID, authKey, baseURL string) *Client {
return NewClientWithHTTPClient(publicID, authKeyID, authKey, baseURL, nil)
}
// NewClientWithHTTPClient is like NewClient but uses a caller-supplied
// *http.Client — e.g. one whose transport is SSRF-guarded, or one with a
// non-default timeout. A nil hc falls back to the package default (30s
// timeout, default transport), so existing callers are unaffected.
func NewClientWithHTTPClient(publicID, authKeyID, authKey, baseURL string, hc *http.Client) *Client {
if hc == nil {
hc = &http.Client{Timeout: 30 * time.Second}
}
return &Client{ return &Client{
publicID: publicID, publicID: publicID,
authKeyID: authKeyID, authKeyID: authKeyID,
authKey: authKey, authKey: authKey,
baseURL: strings.TrimSuffix(baseURL, "/"), baseURL: strings.TrimSuffix(baseURL, "/"),
httpClient: &http.Client{ httpClient: hc,
Timeout: 30 * time.Second,
},
} }
} }

103
client/unauthenticated.go Normal file
View File

@@ -0,0 +1,103 @@
package client
import (
"bytes"
"context"
"encoding/json"
"fmt"
"io"
"net/http"
"strings"
"time"
)
// UnauthenticatedClient is a minimal HTTP client for public Dragonchain services
// that require no HMAC credentials (e.g. the proof-measure service). It mirrors
// Client's body marshaling, status handling, and response decoding, but sends no
// Authorization/Dragonchain/Timestamp headers.
type UnauthenticatedClient struct {
baseURL string
httpClient *http.Client
}
// NewUnauthenticatedClient builds an UnauthenticatedClient with the default
// HTTP client (30s timeout).
func NewUnauthenticatedClient(baseURL string) *UnauthenticatedClient {
return NewUnauthenticatedClientWithHTTPClient(baseURL, nil)
}
// NewUnauthenticatedClientWithHTTPClient is like NewUnauthenticatedClient but
// routes requests through the caller-supplied *http.Client (e.g. an SSRF-guarded
// transport). A nil hc falls back to the package default.
func NewUnauthenticatedClientWithHTTPClient(baseURL string, hc *http.Client) *UnauthenticatedClient {
if hc == nil {
hc = &http.Client{Timeout: 30 * time.Second}
}
return &UnauthenticatedClient{
baseURL: strings.TrimSuffix(baseURL, "/"),
httpClient: hc,
}
}
// Endpoint returns the configured base URL.
func (c *UnauthenticatedClient) Endpoint() string { return c.baseURL }
func (c *UnauthenticatedClient) doRequest(ctx context.Context, method, path, contentType string, body any, response any) error {
var bodyBytes []byte
var err error
if body != nil {
if b, ok := body.([]byte); ok {
bodyBytes = b
} else {
bodyBytes, err = json.Marshal(body)
if err != nil {
return fmt.Errorf("failed to marshal request body: %w", err)
}
contentType = "application/json"
}
}
fullURL := c.baseURL + path
req, err := http.NewRequestWithContext(ctx, method, fullURL, bytes.NewBuffer(bodyBytes))
if err != nil {
return fmt.Errorf("failed to create request: %w", err)
}
if contentType != "" {
req.Header.Set("Content-Type", contentType)
}
req.Header.Set("Accept", "application/json")
resp, err := c.httpClient.Do(req)
if err != nil {
return fmt.Errorf("failed to execute request: %w", err)
}
defer resp.Body.Close()
respBody, err := io.ReadAll(resp.Body)
if err != nil {
return fmt.Errorf("failed to read response body: %w", err)
}
if resp.StatusCode >= 400 {
return fmt.Errorf("API error (status %d): %s", resp.StatusCode, strings.TrimSpace(string(respBody)))
}
if response != nil && len(respBody) > 0 {
if err := json.Unmarshal(respBody, response); err != nil {
return fmt.Errorf("failed to unmarshal response: %w", err)
}
}
return nil
}
// Get performs an unauthenticated GET and decodes the JSON response.
func (c *UnauthenticatedClient) Get(ctx context.Context, path string, response any) error {
return c.doRequest(ctx, http.MethodGet, path, "", nil, response)
}
// Post performs an unauthenticated POST and decodes the JSON response.
func (c *UnauthenticatedClient) Post(ctx context.Context, path, contentType string, body any, response any) error {
return c.doRequest(ctx, http.MethodPost, path, contentType, body, response)
}

View File

@@ -50,9 +50,12 @@
package sdk package sdk
import ( import (
"net/http"
"git.dragonchain.com/dragonchain/prime-sdk-go/block" "git.dragonchain.com/dragonchain/prime-sdk-go/block"
"git.dragonchain.com/dragonchain/prime-sdk-go/client" "git.dragonchain.com/dragonchain/prime-sdk-go/client"
"git.dragonchain.com/dragonchain/prime-sdk-go/contract" "git.dragonchain.com/dragonchain/prime-sdk-go/contract"
"git.dragonchain.com/dragonchain/prime-sdk-go/proofmeasure"
"git.dragonchain.com/dragonchain/prime-sdk-go/system" "git.dragonchain.com/dragonchain/prime-sdk-go/system"
"git.dragonchain.com/dragonchain/prime-sdk-go/transaction" "git.dragonchain.com/dragonchain/prime-sdk-go/transaction"
"git.dragonchain.com/dragonchain/prime-sdk-go/transactiontype" "git.dragonchain.com/dragonchain/prime-sdk-go/transactiontype"
@@ -67,6 +70,11 @@ type DragonchainSDK struct {
Contract *contract.ContractClient Contract *contract.ContractClient
Block *block.BlockClient Block *block.BlockClient
System *system.SystemClient System *system.SystemClient
// ProofMeasure calls the public proof-measure service (measured immutability
// / "securedBy"). It is a separate, unauthenticated service, so this handle
// targets its default public endpoint (proofmeasure.DefaultBaseURL); for a
// custom endpoint construct a proofmeasure.ProofMeasureClient directly.
ProofMeasure *proofmeasure.ProofMeasureClient
} }
// NewDragonchainSDK creates a new Dragonchain SDK client. // NewDragonchainSDK creates a new Dragonchain SDK client.
@@ -80,7 +88,15 @@ type DragonchainSDK struct {
// Returns a configured SDK client ready to make API calls. // Returns a configured SDK client ready to make API calls.
// All API methods on the returned client require a context.Context parameter. // All API methods on the returned client require a context.Context parameter.
func NewDragonchainSDK(publicID, authKeyID, authKey, baseURL string) *DragonchainSDK { func NewDragonchainSDK(publicID, authKeyID, authKey, baseURL string) *DragonchainSDK {
c := client.NewClient(publicID, authKeyID, authKey, baseURL) return NewDragonchainSDKWithHTTPClient(publicID, authKeyID, authKey, baseURL, nil)
}
// NewDragonchainSDKWithHTTPClient is like NewDragonchainSDK but routes every
// request through the caller-supplied *http.Client. Pass a client whose
// transport enforces an SSRF policy (guarded dialer + redirect checks) when
// the baseURL is attacker-influenced. A nil hc falls back to the SDK default.
func NewDragonchainSDKWithHTTPClient(publicID, authKeyID, authKey, baseURL string, hc *http.Client) *DragonchainSDK {
c := client.NewClientWithHTTPClient(publicID, authKeyID, authKey, baseURL, hc)
return &DragonchainSDK{ return &DragonchainSDK{
client: c, client: c,
Transaction: transaction.NewTransactionClient(c), Transaction: transaction.NewTransactionClient(c),
@@ -88,6 +104,7 @@ func NewDragonchainSDK(publicID, authKeyID, authKey, baseURL string) *Dragonchai
Contract: contract.NewContractClient(c), Contract: contract.NewContractClient(c),
Block: block.NewBlockClient(c), Block: block.NewBlockClient(c),
System: system.NewSystemClient(c), System: system.NewSystemClient(c),
ProofMeasure: proofmeasure.NewProofMeasureClientWithHTTPClient("", hc),
} }
} }

View File

@@ -121,18 +121,23 @@ type SmartContractExecutionInfo struct {
} }
type Block struct { type Block struct {
Version string `json:"version"` Version string `json:"version"`
ID string `json:"block_id"` Header BlockHeader `json:"header"`
Timestamp string `json:"timestamp"` Transactions []string `json:"transactions"`
PrevID string `json:"prev_id"` Proof BlockProof `json:"proof"`
PrevProof string `json:"prev_proof"` }
Transactions []string `json:"transactions"`
Proof BlockProof `json:"proof"` type BlockHeader struct {
BlockId string `json:"blockId"`
DcId string `json:"dcId"`
PrevId string `json:"prevId"`
PrevProof string `json:"prevProof"`
Timestamp string `json:"timestamp"`
} }
type BlockProof struct { type BlockProof struct {
Scheme string `json:"scheme"`
Proof string `json:"proof"` Proof string `json:"proof"`
Scheme string `json:"scheme,omitempty"`
Nonce int64 `json:"nonce,omitempty"` Nonce int64 `json:"nonce,omitempty"`
} }
@@ -165,3 +170,120 @@ type ListResponse struct {
Items []interface{} `json:"items"` Items []interface{} `json:"items"`
TotalCount int `json:"total_count"` TotalCount int `json:"total_count"`
} }
// VerificationBlock is a validator's verification of a prime block.
type VerificationBlock struct {
Version string `json:"version"`
PrimeChainId string `json:"primeChainId"`
PrimeBlockId string `json:"primeBlockId"`
Timestamp string `json:"timestamp"`
VerifierPublicKey string `json:"verifierPublicKey"`
VerifierSignature string `json:"verifierSignature"`
}
// InterchainTransaction is an anchor broadcast to a public blockchain (e.g. ETH
// or BTC) that bundles one or more validator blocks. ValidatorBlocks holds the
// prime block ids covered; CoveredPrimeChainIds the prime chains they belong to.
type InterchainTransaction struct {
Id int `json:"id"`
Version string `json:"version"`
Timestamp string `json:"timestamp"`
ChainId string `json:"chainId"`
TransHash string `json:"transHash"`
BlockId string `json:"blockId"`
ValidatorBlocks []string `json:"validatorBlocks"`
ValidatorBlockhash string `json:"validatorBlockhash"`
Signature string `json:"signature"`
CoveredPrimeChainIds []string `json:"coveredPrimeChainIds"`
}
// InterchainTrace links a prime block to the validator (verification) blocks
// that validated it and the public-chain interchain anchors those validator
// blocks were bundled into. Returned by Transaction.GetInterchain and
// Block.GetInterchain.
type InterchainTrace struct {
BlockId string `json:"blockId"`
ValidatorBlocks []VerificationBlock `json:"validatorBlocks"`
InterchainTransactions []InterchainTransaction `json:"interchainTransactions"`
}
// --- proof-measure service (measured immutability / "securedBy") ---
//
// Decimal-valued fields are transmitted as strings (full precision); timestamps
// are int64 unix seconds.
// RawMeasure is a network's native cumulative security measure: cumulative
// hashes for PoW, stake-seconds for PoS.
type RawMeasure struct {
Value string `json:"value"` // human-scaled mantissa (e.g. "484.44")
Unit string `json:"unit"` // e.g. "Zettahashes", "ETH·s"
Base string `json:"base"` // unscaled base amount (hashes or stake-seconds)
}
// SecurityResult is the security a single network accrued for a window/anchor,
// exposed as the raw native measure AND a USD valuation (energy cost for PoW,
// staked value for PoS), plus a normalized 0..1 score.
type SecurityResult struct {
Network string `json:"network"`
Consensus string `json:"consensus"` // "pow" | "pos"
Raw RawMeasure `json:"raw"`
ValueUSD string `json:"valueUsd"` // decimal string
ValueUSDFormatted string `json:"valueUsdFormatted"` // e.g. "$1,234.56"
Label string `json:"label"` // e.g. "$X energy consumed" / "$X staked"
NormalizedScore string `json:"normalizedScore"` // decimal string in [0,1]
SinceUnix int64 `json:"since"` // window/anchor start (unix seconds)
AsOfUnix int64 `json:"asOf"` // latest sample time (unix seconds)
}
// ReportAnchorInput is one anchor supplied in a report request. Provide either
// Network ("BTC"/"ETH") or the public-chain numeric ChainID; Network wins.
type ReportAnchorInput struct {
Network string `json:"network,omitempty"`
ChainID string `json:"chainId,omitempty"`
TxHash string `json:"txHash"`
Timestamp int64 `json:"timestamp"` // anchor time, unix seconds
}
// ReportRequest is the body of ProofMeasure.Report: a transaction's interchain
// anchors. The service computes the security each anchor's network accumulated
// since the anchor and returns a TransactionReport.
type ReportRequest struct {
TransactionID string `json:"transactionId"`
PrimeID string `json:"primeId"`
BlockID string `json:"blockId"`
Anchors []ReportAnchorInput `json:"anchors"`
}
// AnchorSecurity is one interchain anchor with the security its public network
// has accumulated since the anchor was placed.
type AnchorSecurity struct {
Network string `json:"network"`
AnchorTimestamp int64 `json:"anchorTimestamp"` // unix seconds
AnchorTxHash string `json:"anchorTxHash"`
Security SecurityResult `json:"security"`
}
// HashPower is the combined raw hash power across a report's PoW anchors.
type HashPower struct {
Value string `json:"value"`
Units string `json:"units"`
}
// TransactionReport is the per-transaction "securedBy" report: every public-chain
// anchor covering the transaction's block with both raw and USD security, plus
// combined totals. HashPower is nil when there are no PoW anchors.
type TransactionReport struct {
TransactionID string `json:"transactionId"`
PrimeID string `json:"primeId"`
BlockID string `json:"blockId"`
Anchors []AnchorSecurity `json:"anchors"`
TotalValueUSD string `json:"totalValueUsd"`
TotalValueUSDFormatted string `json:"totalValueUsdFormatted"`
HashPower *HashPower `json:"hashPower"`
TotalNormalizedScore string `json:"totalNormalizedScore"`
}
// HealthResponse is the proof-measure liveness payload.
type HealthResponse struct {
Status string `json:"status"`
}

View File

@@ -0,0 +1,78 @@
// Package proofmeasure is a client for the Dragonchain proof-measure service —
// the measured-immutability / "securedBy" metric for L1L5 verification chains.
//
// proof-measure is a separate, public, UNauthenticated service (no API keys),
// so this client takes only a base URL. It exposes a network's accumulated
// security as both a raw measure (cumulative hashes / stake-seconds) and a USD
// valuation, plus a per-transaction "securedBy" report over interchain anchors.
package proofmeasure
import (
"context"
"fmt"
"net/http"
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
)
// DefaultBaseURL is the public production proof-measure endpoint.
const DefaultBaseURL = "https://proof-measure.dragonchain.com"
// ProofMeasureClient calls the proof-measure HTTP API.
type ProofMeasureClient struct {
client *client.UnauthenticatedClient
}
// NewProofMeasureClient builds a client for the proof-measure service. An empty
// baseURL defaults to the public production endpoint (DefaultBaseURL).
func NewProofMeasureClient(baseURL string) *ProofMeasureClient {
return NewProofMeasureClientWithHTTPClient(baseURL, nil)
}
// NewProofMeasureClientWithHTTPClient is like NewProofMeasureClient but routes
// requests through the caller-supplied *http.Client. A nil hc uses the default.
func NewProofMeasureClientWithHTTPClient(baseURL string, hc *http.Client) *ProofMeasureClient {
if baseURL == "" {
baseURL = DefaultBaseURL
}
return &ProofMeasureClient{
client: client.NewUnauthenticatedClientWithHTTPClient(baseURL, hc),
}
}
// GetSecurity returns the security a public network (network = "BTC" or "ETH")
// has accumulated since the given unix timestamp, as both a raw measure and a
// USD valuation. A non-positive since omits the parameter, letting the service
// apply its default window.
func (pc *ProofMeasureClient) GetSecurity(ctx context.Context, network string, since int64) (*models.SecurityResult, error) {
path := fmt.Sprintf("/api/v1/security/%s", network)
if since > 0 {
path = fmt.Sprintf("%s?since=%d", path, since)
}
var resp models.SecurityResult
if err := pc.client.Get(ctx, path, &resp); err != nil {
return nil, err
}
return &resp, nil
}
// Report computes the per-transaction "securedBy" report for the supplied
// interchain anchors: each anchor's raw + USD security since it was placed, plus
// combined totals.
func (pc *ProofMeasureClient) Report(ctx context.Context, req *models.ReportRequest) (*models.TransactionReport, error) {
var resp models.TransactionReport
if err := pc.client.Post(ctx, "/api/v1/report", models.ContentTypeJSON, req, &resp); err != nil {
return nil, err
}
return &resp, nil
}
// Health reports service liveness and DB reachability.
func (pc *ProofMeasureClient) Health(ctx context.Context) (*models.HealthResponse, error) {
var resp models.HealthResponse
if err := pc.client.Get(ctx, "/api/v1/health", &resp); err != nil {
return nil, err
}
return &resp, nil
}

View File

@@ -0,0 +1,135 @@
package proofmeasure
import (
"context"
"encoding/json"
"io"
"net/http"
"net/http/httptest"
"testing"
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
)
func TestGetSecurity(t *testing.T) {
var gotPath string
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
gotPath = r.URL.RequestURI()
w.Header().Set("Content-Type", "application/json")
_, _ = io.WriteString(w, `{
"network":"BTC","consensus":"pow",
"raw":{"value":"71.63","unit":"Yottahashes","base":"7.16e25"},
"valueUsd":"13928170.26","valueUsdFormatted":"$13,928,170.26",
"label":"$13,928,170.26 energy consumed","normalizedScore":"0.9234",
"since":1780504894,"asOf":1780591253}`)
}))
defer srv.Close()
pc := NewProofMeasureClient(srv.URL)
res, err := pc.GetSecurity(context.Background(), "BTC", 1780504894)
if err != nil {
t.Fatalf("GetSecurity: %v", err)
}
if gotPath != "/api/v1/security/BTC?since=1780504894" {
t.Errorf("path = %q, want /api/v1/security/BTC?since=1780504894", gotPath)
}
if res.Network != "BTC" || res.Consensus != "pow" {
t.Errorf("network/consensus = %q/%q", res.Network, res.Consensus)
}
if res.Raw.Unit != "Yottahashes" || res.ValueUSD != "13928170.26" {
t.Errorf("raw.unit=%q valueUsd=%q", res.Raw.Unit, res.ValueUSD)
}
if res.SinceUnix != 1780504894 || res.AsOfUnix != 1780591253 {
t.Errorf("since/asOf = %d/%d", res.SinceUnix, res.AsOfUnix)
}
}
func TestGetSecurity_NoSinceOmitsParam(t *testing.T) {
var gotPath string
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
gotPath = r.URL.RequestURI()
_, _ = io.WriteString(w, `{"network":"ETH","consensus":"pos"}`)
}))
defer srv.Close()
if _, err := NewProofMeasureClient(srv.URL).GetSecurity(context.Background(), "ETH", 0); err != nil {
t.Fatalf("GetSecurity: %v", err)
}
if gotPath != "/api/v1/security/ETH" {
t.Errorf("path = %q, want /api/v1/security/ETH (no since)", gotPath)
}
}
func TestReport(t *testing.T) {
var gotMethod, gotPath string
var gotReq models.ReportRequest
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
gotMethod, gotPath = r.Method, r.URL.Path
_ = json.NewDecoder(r.Body).Decode(&gotReq)
w.Header().Set("Content-Type", "application/json")
_, _ = io.WriteString(w, `{
"transactionId":"tx-1","primeId":"p-1","blockId":"42",
"anchors":[{"network":"BTC","anchorTimestamp":1712345678,"anchorTxHash":"0xabc",
"security":{"network":"BTC","consensus":"pow","valueUsd":"100.00"}}],
"totalValueUsd":"100.00","totalValueUsdFormatted":"$100.00",
"hashPower":{"value":"40.06","units":"Yottahashes"},"totalNormalizedScore":"0.9"}`)
}))
defer srv.Close()
pc := NewProofMeasureClient(srv.URL)
rep, err := pc.Report(context.Background(), &models.ReportRequest{
TransactionID: "tx-1", PrimeID: "p-1", BlockID: "42",
Anchors: []models.ReportAnchorInput{{Network: "BTC", TxHash: "0xabc", Timestamp: 1712345678}},
})
if err != nil {
t.Fatalf("Report: %v", err)
}
if gotMethod != http.MethodPost || gotPath != "/api/v1/report" {
t.Errorf("method/path = %s %s", gotMethod, gotPath)
}
if len(gotReq.Anchors) != 1 || gotReq.Anchors[0].Network != "BTC" {
t.Errorf("request anchors not sent: %+v", gotReq.Anchors)
}
if rep.TotalValueUSD != "100.00" || rep.HashPower == nil || rep.HashPower.Units != "Yottahashes" {
t.Errorf("report decode wrong: %+v", rep)
}
if len(rep.Anchors) != 1 || rep.Anchors[0].Security.Network != "BTC" {
t.Errorf("report anchors decode wrong: %+v", rep.Anchors)
}
}
func TestHealth(t *testing.T) {
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
if r.URL.Path != "/api/v1/health" {
t.Errorf("health path = %q", r.URL.Path)
}
_, _ = io.WriteString(w, `{"status":"ok"}`)
}))
defer srv.Close()
h, err := NewProofMeasureClient(srv.URL).Health(context.Background())
if err != nil {
t.Fatalf("Health: %v", err)
}
if h.Status != "ok" {
t.Errorf("status = %q, want ok", h.Status)
}
}
func TestDefaultBaseURL(t *testing.T) {
if NewProofMeasureClient("") == nil {
t.Fatal("nil client for empty base URL")
}
}
func TestErrorStatus(t *testing.T) {
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusBadRequest)
_, _ = io.WriteString(w, `bad request`)
}))
defer srv.Close()
if _, err := NewProofMeasureClient(srv.URL).Health(context.Background()); err == nil {
t.Fatal("expected an error on 400 status, got nil")
}
}

View File

@@ -52,6 +52,20 @@ func (tc *TransactionClient) Get(ctx context.Context, transactionID string) (*mo
return &resp, nil return &resp, nil
} }
// GetInterchain traces a transaction to the validator (verification) blocks that
// validated its prime block and the public-chain interchain anchors those
// validator blocks were bundled into. If the transaction is still pending (not
// yet in a block) the trace's slices are empty.
func (tc *TransactionClient) GetInterchain(ctx context.Context, transactionID string) (*models.InterchainTrace, error) {
var resp models.InterchainTrace
path := fmt.Sprintf("/api/v1/transaction/%s/interchain", transactionID)
err := tc.client.Get(ctx, path, &resp)
if err != nil {
return nil, err
}
return &resp, nil
}
func (tc *TransactionClient) List(ctx context.Context) (*models.ListTransactionsResponse, error) { func (tc *TransactionClient) List(ctx context.Context) (*models.ListTransactionsResponse, error) {
var resp models.ListTransactionsResponse var resp models.ListTransactionsResponse
path := "/api/v1/transaction/" path := "/api/v1/transaction/"