api/assets.go

   1 package api
   2
   3 import (
   4         "context"
   5         "strings"
   6
   7         "github.com/vapor/asset"
   8         "github.com/vapor/crypto/ed25519/chainkd"
   9         chainjson "github.com/vapor/encoding/json"
  10
  11         log "github.com/sirupsen/logrus"
  12 )
  13
  14 // POST /create-asset
  15 func (a *API) createAsset(ctx context.Context, ins struct {
  16         Alias           string                 `json:"alias"`
  17         RootXPubs       []chainkd.XPub         `json:"root_xpubs"`
  18         Quorum          int                    `json:"quorum"`
  19         Definition      map[string]interface{} `json:"definition"`
  20         IssuanceProgram chainjson.HexBytes     `json:"issuance_program"`
  21 }) Response {
  22         ass, err := a.wallet.AssetReg.Define(
  23                 ins.RootXPubs,
  24                 ins.Quorum,
  25                 ins.Definition,
  26                 strings.ToUpper(strings.TrimSpace(ins.Alias)),
  27                 ins.IssuanceProgram,
  28         )
  29         if err != nil {
  30                 return NewErrorResponse(err)
  31         }
  32
  33         annotatedAsset, err := asset.Annotated(ass)
  34         if err != nil {
  35                 return NewErrorResponse(err)
  36         }
  37
  38         log.WithField("asset ID", annotatedAsset.ID.String()).Info("Created asset")
  39
  40         return NewSuccessResponse(annotatedAsset)
  41 }
  42
  43 // POST /update-asset-alias
  44 func (a *API) updateAssetAlias(updateAlias struct {
  45         ID       string `json:"id"`
  46         NewAlias string `json:"alias"`
  47 }) Response {
  48         if err := a.wallet.AssetReg.UpdateAssetAlias(updateAlias.ID, updateAlias.NewAlias); err != nil {
  49                 return NewErrorResponse(err)
  50         }
  51
  52         return NewSuccessResponse(nil)
  53 }