Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 18ac756d44 | |||
| 4dabbcd23a | |||
| c3d6d017df | |||
| e15b205f9c |
0
.gitignore
vendored
Normal file → Executable file
0
.gitignore
vendored
Normal file → Executable file
57
README.md
Normal file → Executable file
57
README.md
Normal file → Executable file
@@ -5,7 +5,7 @@ A self-contained Go SDK for interacting with Dragonchain nodes.
|
|||||||
## Installation
|
## Installation
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
go get git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go
|
go get git.dragonchain.com/dragonchain/prime-sdk-go
|
||||||
```
|
```
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
@@ -19,8 +19,8 @@ import (
|
|||||||
"log"
|
"log"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go"
|
"git.dragonchain.com/dragonchain/prime-sdk-go"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
@@ -65,6 +65,57 @@ func main() {
|
|||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
|
## Transaction Modes
|
||||||
|
|
||||||
|
`Create` and `CreateBulk` return **immediately** with the assigned transaction ID(s). They do **not** wait for block inclusion. Blocks are assembled asynchronously on a ~5-second cycle.
|
||||||
|
|
||||||
|
### Fire and Forget
|
||||||
|
|
||||||
|
Most use cases only need the transaction ID. No polling required.
|
||||||
|
|
||||||
|
```go
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
resp, err := client.Transaction.Create(ctx, &models.TransactionCreateRequest{
|
||||||
|
TxnType: "my-transaction-type",
|
||||||
|
Payload: `{"message": "Hello Dragonchain"}`,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
fmt.Printf("Transaction ID: %s\n", resp.TransactionID)
|
||||||
|
// Done — no need to wait for a block.
|
||||||
|
```
|
||||||
|
|
||||||
|
### Wait for Block
|
||||||
|
|
||||||
|
If you need the block ID (e.g. for interchain verification or Daria), poll `Get` until `Header.BlockId` is populated.
|
||||||
|
|
||||||
|
```go
|
||||||
|
resp, err := client.Transaction.Create(ctx, &models.TransactionCreateRequest{
|
||||||
|
TxnType: "my-transaction-type",
|
||||||
|
Payload: `{"message": "Hello Dragonchain"}`,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Poll until the transaction is included in a block.
|
||||||
|
ticker := time.NewTicker(2 * time.Second)
|
||||||
|
defer ticker.Stop()
|
||||||
|
for range ticker.C {
|
||||||
|
txn, err := client.Transaction.Get(ctx, resp.TransactionID)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
if txn.Header.BlockId != "" {
|
||||||
|
fmt.Printf("Block ID: %s\n", txn.Header.BlockId)
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
## Available Endpoints
|
## Available Endpoints
|
||||||
|
|
||||||
All API methods accept a `context.Context` as their first parameter for timeout and cancellation control.
|
All API methods accept a `context.Context` as their first parameter for timeout and cancellation control.
|
||||||
|
|||||||
4
block/block.go
Normal file → Executable file
4
block/block.go
Normal file → Executable file
@@ -4,8 +4,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
type BlockClient struct {
|
type BlockClient struct {
|
||||||
|
|||||||
0
client/client.go
Normal file → Executable file
0
client/client.go
Normal file → Executable file
4
contract/contract.go
Normal file → Executable file
4
contract/contract.go
Normal file → Executable file
@@ -5,8 +5,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
type ContractClient struct {
|
type ContractClient struct {
|
||||||
|
|||||||
0
credentials/credentials.go
Normal file → Executable file
0
credentials/credentials.go
Normal file → Executable file
77
dragonchain.go
Normal file → Executable file
77
dragonchain.go
Normal file → Executable file
@@ -2,57 +2,60 @@
|
|||||||
//
|
//
|
||||||
// All API methods require a context.Context parameter for timeout and cancellation control.
|
// All API methods require a context.Context parameter for timeout and cancellation control.
|
||||||
//
|
//
|
||||||
// Example usage:
|
// Example — fire and forget (most use cases):
|
||||||
//
|
//
|
||||||
// package main
|
// client := sdk.NewDragonchainSDK(
|
||||||
//
|
// "your-public-id",
|
||||||
// import (
|
// "your-auth-key-id",
|
||||||
// "context"
|
// "your-auth-key",
|
||||||
// "fmt"
|
// "https://your-dragonchain-endpoint.com",
|
||||||
// "log"
|
|
||||||
// "time"
|
|
||||||
//
|
|
||||||
// "git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go"
|
|
||||||
// "git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
|
||||||
// )
|
// )
|
||||||
//
|
//
|
||||||
// func main() {
|
// ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
||||||
// client := sdk.NewDragonchainSDK(
|
// defer cancel()
|
||||||
// "your-public-id",
|
|
||||||
// "your-auth-key-id",
|
|
||||||
// "your-auth-key",
|
|
||||||
// "https://your-dragonchain-endpoint.com",
|
|
||||||
// )
|
|
||||||
//
|
//
|
||||||
// ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
// resp, err := client.Transaction.Create(ctx, &models.TransactionCreateRequest{
|
||||||
// defer cancel()
|
// TxnType: "my-transaction-type",
|
||||||
|
// Payload: `{"message": "Hello Dragonchain"}`,
|
||||||
|
// })
|
||||||
|
// if err != nil {
|
||||||
|
// log.Fatal(err)
|
||||||
|
// }
|
||||||
|
// fmt.Printf("Transaction ID: %s\n", resp.TransactionID)
|
||||||
|
// // Done — no need to wait for a block.
|
||||||
//
|
//
|
||||||
// // Check system health
|
// Example — wait for block inclusion (interchain / Daria):
|
||||||
// if err := client.System.Health(ctx); err != nil {
|
|
||||||
// log.Fatal(err)
|
|
||||||
// }
|
|
||||||
//
|
//
|
||||||
// // Create a transaction
|
// resp, err := client.Transaction.Create(ctx, &models.TransactionCreateRequest{
|
||||||
// txn := &models.TransactionCreateRequest{
|
// TxnType: "my-transaction-type",
|
||||||
// TxnType: "my-transaction-type",
|
// Payload: `{"message": "Hello Dragonchain"}`,
|
||||||
// Payload: map[string]interface{}{"message": "Hello Dragonchain"},
|
// })
|
||||||
// }
|
// if err != nil {
|
||||||
|
// log.Fatal(err)
|
||||||
|
// }
|
||||||
//
|
//
|
||||||
// resp, err := client.Transaction.Create(ctx, txn)
|
// // Poll until the transaction is included in a block.
|
||||||
|
// ticker := time.NewTicker(2 * time.Second)
|
||||||
|
// defer ticker.Stop()
|
||||||
|
// for range ticker.C {
|
||||||
|
// txn, err := client.Transaction.Get(ctx, resp.TransactionID)
|
||||||
// if err != nil {
|
// if err != nil {
|
||||||
// log.Fatal(err)
|
// log.Fatal(err)
|
||||||
// }
|
// }
|
||||||
// fmt.Printf("Created transaction: %s\n", resp.TransactionID)
|
// if txn.Header.BlockId != "" {
|
||||||
|
// fmt.Printf("Block ID: %s\n", txn.Header.BlockId)
|
||||||
|
// break
|
||||||
|
// }
|
||||||
// }
|
// }
|
||||||
package sdk
|
package sdk
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/block"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/block"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/contract"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/contract"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/system"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/system"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/transaction"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/transaction"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/transactiontype"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/transactiontype"
|
||||||
)
|
)
|
||||||
|
|
||||||
// DragonchainSDK is the main SDK client for interacting with Dragonchain nodes.
|
// DragonchainSDK is the main SDK client for interacting with Dragonchain nodes.
|
||||||
|
|||||||
2
go.mod
Normal file → Executable file
2
go.mod
Normal file → Executable file
@@ -1,4 +1,4 @@
|
|||||||
module git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go
|
module git.dragonchain.com/dragonchain/prime-sdk-go
|
||||||
|
|
||||||
go 1.24.5
|
go 1.24.5
|
||||||
|
|
||||||
|
|||||||
8
models/models.go
Normal file → Executable file
8
models/models.go
Normal file → Executable file
@@ -78,6 +78,7 @@ type SmartContractCreateRequest struct {
|
|||||||
ExecutionOrder string `json:"executionOrder"`
|
ExecutionOrder string `json:"executionOrder"`
|
||||||
EnvironmentVariables map[string]string `json:"environmentVariables,omitempty"`
|
EnvironmentVariables map[string]string `json:"environmentVariables,omitempty"`
|
||||||
Secrets map[string]string `json:"secret,omitempty"`
|
Secrets map[string]string `json:"secret,omitempty"`
|
||||||
|
Remote bool `json:"remote,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SmartContractUpdateRequest struct {
|
type SmartContractUpdateRequest struct {
|
||||||
@@ -101,6 +102,13 @@ type SmartContract struct {
|
|||||||
|
|
||||||
EnvVars map[string]string `json:"envVars"`
|
EnvVars map[string]string `json:"envVars"`
|
||||||
Secrets []string `json:"secrets"`
|
Secrets []string `json:"secrets"`
|
||||||
|
|
||||||
|
GrpcConnectionInfo *GrpcConnectionInfo `json:"grpcConnectionInfo,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type GrpcConnectionInfo struct {
|
||||||
|
Address string `json:"address"`
|
||||||
|
ApiKey string `json:"apiKey,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type SmartContractExecutionInfo struct {
|
type SmartContractExecutionInfo struct {
|
||||||
|
|||||||
4
system/system.go
Normal file → Executable file
4
system/system.go
Normal file → Executable file
@@ -3,8 +3,8 @@ package system
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
type SystemClient struct {
|
type SystemClient struct {
|
||||||
|
|||||||
12
transaction/transaction.go
Normal file → Executable file
12
transaction/transaction.go
Normal file → Executable file
@@ -4,8 +4,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
type TransactionClient struct {
|
type TransactionClient struct {
|
||||||
@@ -16,6 +16,10 @@ func NewTransactionClient(c *client.Client) *TransactionClient {
|
|||||||
return &TransactionClient{client: c}
|
return &TransactionClient{client: c}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Create submits a new transaction and returns immediately with the assigned transaction ID.
|
||||||
|
// It does NOT wait for the transaction to be included in a block. Block processing happens
|
||||||
|
// asynchronously on a ~5-second cycle. If you need the block ID (e.g. for interchain
|
||||||
|
// verification), poll Get until Header.BlockId is populated.
|
||||||
func (tc *TransactionClient) Create(ctx context.Context, req *models.TransactionCreateRequest) (*models.TransactionCreateResponse, error) {
|
func (tc *TransactionClient) Create(ctx context.Context, req *models.TransactionCreateRequest) (*models.TransactionCreateResponse, error) {
|
||||||
var resp models.TransactionCreateResponse
|
var resp models.TransactionCreateResponse
|
||||||
err := tc.client.Post(ctx, "/api/v1/transaction", models.ContentTypeJSON, req, &resp)
|
err := tc.client.Post(ctx, "/api/v1/transaction", models.ContentTypeJSON, req, &resp)
|
||||||
@@ -25,6 +29,10 @@ func (tc *TransactionClient) Create(ctx context.Context, req *models.Transaction
|
|||||||
return &resp, nil
|
return &resp, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// CreateBulk submits multiple transactions and returns immediately with the assigned transaction IDs.
|
||||||
|
// It does NOT wait for the transactions to be included in a block. Block processing happens
|
||||||
|
// asynchronously on a ~5-second cycle. If you need block IDs, poll Get for each transaction
|
||||||
|
// until Header.BlockId is populated.
|
||||||
func (tc *TransactionClient) CreateBulk(ctx context.Context, req *models.TransactionBulkRequest) (*models.TransactionBulkResponse, error) {
|
func (tc *TransactionClient) CreateBulk(ctx context.Context, req *models.TransactionBulkRequest) (*models.TransactionBulkResponse, error) {
|
||||||
var resp models.TransactionBulkResponse
|
var resp models.TransactionBulkResponse
|
||||||
err := tc.client.Post(ctx, "/api/v1/transaction/bulk", models.ContentTypeJSON, req, &resp)
|
err := tc.client.Post(ctx, "/api/v1/transaction/bulk", models.ContentTypeJSON, req, &resp)
|
||||||
|
|||||||
4
transactiontype/transactiontype.go
Normal file → Executable file
4
transactiontype/transactiontype.go
Normal file → Executable file
@@ -4,8 +4,8 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/client"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/client"
|
||||||
"git.dragonchain.com/dragonchain/dragonchain-prime-sdk-go/models"
|
"git.dragonchain.com/dragonchain/prime-sdk-go/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
type TransactionTypeClient struct {
|
type TransactionTypeClient struct {
|
||||||
|
|||||||
Reference in New Issue
Block a user