/api/transactions/deposit

# Start import with GET request
curl -X GET "http://localhost:8080/api/transactions/deposit?file=C:\Users\User\tmp\coin1.bin&file=C:\Users\User\tmp\coin2.bin&memo=I%20love%20you!&wallet_path=C:/CloudCoin/Wallets/Default"

# Response:
# {
#   "status": "success",
#   "operation": "deposit",
#   "task_id": "Jan-31-25_03-45-12-PM",
#   "message": "Import task started successfully",
#   "file_count": 2
# }

# Step 2: Poll task status
curl -X GET "http://localhost:8080/api/transactions/task?id=Jan-31-25_03-45-12-PM"

# Step 3: Check receipt (after completion)
# Receipt saved to: [wallet]/Receipts/Jan-31-25_03-45-12-PM.import.txt

# Step 4: Check wallet balance
curl -X GET "http://localhost:8080/api/wallets/balance?wallet_path=C:/CloudCoin/Wallets/Default"

# Note: Remember to URL encode special characters in query parameters
# Example: Spaces become %20, backslashes might need escaping depending on shell

# Start import with POST request (JSON body)
curl -X POST "http://localhost:8080/api/transactions/deposit" \
  -H "Content-Type: application/json" \
  -d '{
    "files": [
      "C:\\Users\\User\\tmp\\coin1.bin",
      "C:\\Users\\User\\tmp\\coin2.bin",
      "C:\\Users\\User\\tmp\\coin3.bin"
    ],
    "memo": "I love you!",
    "wallet_path": "C:/CloudCoin/Wallets/Default"
  }'

# Response:
# {
#   "status": "success",
#   "operation": "deposit",
#   "task_id": "Jan-31-25_03-45-12-PM",
#   "message": "Import task started successfully",
#   "file_count": 3
# }

# Step 2: Poll task status
curl -X GET "http://localhost:8080/api/transactions/task?id=Jan-31-25_03-45-12-PM"

# Step 3: Check receipt (after completion)
# Receipt saved to: [wallet]/Receipts/Jan-31-25_03-45-12-PM.import.txt

# Step 4: Check wallet balance
curl -X GET "http://localhost:8080/api/wallets/balance?wallet_path=C:/CloudCoin/Wallets/Default"

# Note: JSON strings require double backslashes for Windows paths
# Example: "C:\\path\\file.bin" not "C:\path\file.bin"

package main

import (
    "encoding/json"
    "fmt"
    "io/ioutil"
    "net/http"
    "net/url"
    "strings"
    "time"
)

const ApiHost = "http://localhost:8080"

type ImportResponse struct {
    Status    string `json:"status"`
    Operation string `json:"operation"`
    TaskID    string `json:"task_id"`
    Message   string `json:"message"`
    FileCount int    `json:"file_count"`
}

type TaskStatus struct {
    Status   string `json:"status"`
    Progress int    `json:"progress"`
    Message  string `json:"message"`
}

type WalletBalance struct {
    TotalValue int `json:"total_value"`
    CoinCount  int `json:"coin_count"`
}

func importFiles(filePaths []string, memo string, walletPath string) error {
    // Step 1: Build query string with files (pipe-separated), memo, and optional wallet_path
    params := url.Values{}
    params.Add("files", strings.Join(filePaths, "|"))
    params.Add("memo", memo)
    if walletPath != "" {
        params.Add("wallet_path", walletPath)
    }

    // Step 2: Make GET request with query parameters
    requestURL := fmt.Sprintf("%s/api/transactions/deposit?%s", ApiHost, params.Encode())
    resp, err := http.Get(requestURL)
    if err != nil {
        return err
    }
    defer resp.Body.Close()

    body, _ := ioutil.ReadAll(resp.Body)

    var result ImportResponse
    if err := json.Unmarshal(body, &result); err != nil {
        return err
    }

    if result.Status != "success" {
        return fmt.Errorf("import failed: %s", result.Message)
    }

    fmt.Printf("Import started with task ID: %s\n", result.TaskID)
    fmt.Printf("Processing %d files\n", result.FileCount)
    fmt.Printf("Importing to wallet: %s\n", walletPath)

    // Step 3: Poll for completion
    if err := pollTaskStatus(result.TaskID); err != nil {
        return err
    }

    // Step 4: Check receipt
    fmt.Printf("Receipt saved to: [wallet]/Receipts/%s.import.txt\n", result.TaskID)

    // Step 5: Check updated balance
    return checkBalance(walletPath)
}

func pollTaskStatus(taskID string) error {
    for {
        requestURL := fmt.Sprintf("%s/api/transactions/task?id=%s", ApiHost, taskID)
        resp, err := http.Get(requestURL)
        if err != nil {
            return err
        }

        body, _ := ioutil.ReadAll(resp.Body)
        resp.Body.Close()

        var task TaskStatus
        if err := json.Unmarshal(body, &task); err != nil {
            return err
        }

        fmt.Printf("Status: %s, Progress: %d%%\n", task.Status, task.Progress)

        if task.Status == "completed" {
            fmt.Println("Import complete!")
            return nil
        } else if task.Status == "error" || task.Status == "failed" {
            return fmt.Errorf("import failed: %s", task.Message)
        }

        time.Sleep(1 * time.Second)
    }
}

func checkBalance(walletPath string) error {
    requestURL := fmt.Sprintf("%s/api/wallets/balance?wallet_path=%s",
        ApiHost, url.QueryEscape(walletPath))
    resp, err := http.Get(requestURL)
    if err != nil {
        return err
    }
    defer resp.Body.Close()

    body, _ := ioutil.ReadAll(resp.Body)

    var balance WalletBalance
    if err := json.Unmarshal(body, &balance); err != nil {
        return err
    }

    fmt.Printf("New wallet balance: %d CloudCoins, Total value: %d\n",
        balance.CoinCount, balance.TotalValue)
    return nil
}

func main() {
    filePaths := []string{
        "C:\\Users\\User\\tmp\\coin1.bin",
        "C:\\Users\\User\\tmp\\coin2.bin",
    }

    // Import to specified wallet
    if err := importFiles(filePaths, "I love you!", "C:/CloudCoin/Wallets/Default"); err != nil {
        fmt.Printf("Error: %v\n", err)
    }
}