Function CreateDatabaseTask

cmd/cql-proxy/api/database.go:358–387

CreateDatabaseTask handles the database creation process.

(ctx context.Context, _ *config.Config, db *gorp.DbMap, t *model.Task)

// CreateDatabaseTask handles the database creation process.
func CreateDatabaseTask(ctx context.Context, _ *config.Config, db *gorp.DbMap, t *model.Task) (r gin.H, err error) {
	args := struct {
		NodeCount uint16 `json:"node_count"`
	}{}

	err = json.Unmarshal(t.RawArgs, &args)
	if err != nil {
		err = errors.Wrapf(err, "unmarshal task args failed")
		return
	}

	tx, dbID, _, err := createDatabase(db, t.Developer, t.Account, args.NodeCount)
	if err != nil {
		err = errors.Wrapf(err, "create database failed")
		return
	}

	// wait for transaction to complete in several cycles
	timeoutCtx, cancelCtx := context.WithTimeout(ctx, 3*time.Minute)
	defer cancelCtx()

	lastState, _ := waitForTxState(timeoutCtx, tx)
	r = gin.H{
		"db":    dbID,
		"tx":    tx.String(),
		"state": lastState.String(),
	}

	return
}

// TopUpTask handles the database balance/advance payments top-up process.
func TopUpTask(ctx context.Context, cfg *config.Config, db *gorp.DbMap, t *model.Task) (r gin.H, err error) {