/import

# Step 1: Initiate the import task
TASK_ID=$(curl -s -X POST "http://localhost:8006/api/v1/import" \
-H "Content-Type: application/json" \
-d '{"name":"Default","items":[{"type":"file","data":"/path/to/coins.stack"}]}' | jq -r .id)
echo "Import task started with ID: $TASK_ID"

# Step 2: Poll the task endpoint until finished
while true; do
  RESPONSE=$(curl -s "http://localhost:8006/api/v1/tasks/$TASK_ID")
  STATUS=$(echo $RESPONSE | jq -r .status)
  echo "Polling task... Status: $STATUS"
  if [[ "$STATUS" == "completed" || "$STATUS" == "error" ]]; then
    echo "Final Response:"
    echo $RESPONSE | jq
    break
  fi
  sleep 2
done

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
)

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

type ImportItem struct {
    Type string `json:"type"`
    Data string `json:"data"`
}
type ImportRequest struct {
    Name  string       `json:"name"`
    Tag   string       `json:"tag"`
    Items []ImportItem `json:"items"`
}

func main() {
    importPayload := ImportRequest{
        Name: "Default",
        Tag:   "From Go",
        Items: []ImportItem{{Type: "file", Data: "/path/to/your/coins.stack"}},
    }
    payloadBytes, _ := json.Marshal(importPayload)
    
    req, _ := http.NewRequest("POST", fmt.Sprintf("%s/api/v1/import", ApiHost), bytes.NewBuffer(payloadBytes))
    req.Header.Set("Content-Type", "application/json")
    
    client := &http.Client{}
    resp, err := client.Do(req)
    if err != nil { panic(err) }
    defer resp.Body.Close()

    // The initial response just gives us the task ID to monitor
    // ... polling logic would be the same as other examples
    fmt.Println("Import task submitted. Status Code:", resp.StatusCode)
}