Method CreateOrder

x/market/keeper/keeper.go:159–215

CreateOrder creates a new order with given group id and specifications. It returns created order

(ctx sdk.Context, gid dtypes.GroupID, spec dvbeta.GroupSpec, reclamation *dtypes.DeploymentReclamation)

// CreateOrder creates a new order with given group id and specifications. It returns created order
func (k Keeper) CreateOrder(ctx sdk.Context, gid dtypes.GroupID, spec dvbeta.GroupSpec, reclamation *dtypes.DeploymentReclamation) (types.Order, error) {
	oseq := uint32(1)
	var err error

	k.WithOrdersForGroup(ctx, gid, types.OrderActive, func(_ types.Order) bool {
		err = mv1.ErrOrderActive
		return true
	})

	k.WithOrdersForGroup(ctx, gid, types.OrderOpen, func(_ types.Order) bool {
		err = mv1.ErrOrderActive
		return true
	})

	k.WithOrdersForGroup(ctx, gid, types.OrderClosed, func(_ types.Order) bool {
		oseq++
		return false
	})

	if err != nil {
		return types.Order{}, fmt.Errorf("%w: create order: active order exists", err)
	}

	orderID := mv1.MakeOrderID(gid, oseq)

	pk := keys.OrderIDToKey(orderID)
	has, err := k.orders.Has(ctx, pk)
	if err != nil {
		return types.Order{}, err
	}
	if has {
		return types.Order{}, mv1.ErrOrderExists
	}

	order := types.Order{
		ID:          orderID,
		Spec:        spec,
		State:       types.OrderOpen,
		CreatedAt:   ctx.BlockHeight(),
		Reclamation: reclamation,
	}

	if err := k.orders.Set(ctx, pk, order); err != nil {
		return types.Order{}, fmt.Errorf("failed to create order: %w", err)
	}

	ctx.Logger().Info("created order", "order", order.ID)

	err = ctx.EventManager().EmitTypedEvent(
		&mv1.EventOrderCreated{ID: order.ID},
	)
	if err != nil {
		return types.Order{}, err
	}

	return order, nil
}