-
Notifications
You must be signed in to change notification settings - Fork 22
/
liquidity_provision.go
54 lines (45 loc) · 2.18 KB
/
liquidity_provision.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
// Copyright (C) 2023 Gobalsky Labs Limited
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as
// published by the Free Software Foundation, either version 3 of the
// License, or (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package spot
import (
"context"
"errors"
"code.vegaprotocol.io/vega/core/types"
)
var ErrCommitmentAmountTooLow = errors.New("commitment amount is too low")
// SubmitLiquidityProvision forwards a LiquidityProvisionSubmission to the Liquidity Engine.
func (m *Market) SubmitLiquidityProvision(ctx context.Context, sub *types.LiquidityProvisionSubmission, party, deterministicID string) error {
if err := m.liquidity.SubmitLiquidityProvision(ctx, sub, party, deterministicID, m.mkt.State); err != nil {
return err
}
// add the party to the list of all parties involved with
// this market
m.addParty(party)
return nil
}
// AmendLiquidityProvision forwards a LiquidityProvisionAmendment to the Liquidity Engine.
func (m *Market) AmendLiquidityProvision(ctx context.Context, lpa *types.LiquidityProvisionAmendment, party string, deterministicID string) error {
return m.liquidity.AmendLiquidityProvision(ctx, lpa, party, deterministicID, m.mkt.State)
}
// CancelLiquidityProvision forwards a LiquidityProvisionCancel to the Liquidity Engine.
func (m *Market) CancelLiquidityProvision(ctx context.Context, cancel *types.LiquidityProvisionCancellation, party string) error {
err := m.liquidity.CancelLiquidityProvision(ctx, party)
m.updateLiquidityFee(ctx)
// and remove the party from the equity share like calculation
m.equityShares.SetPartyStake(party, nil)
// force update of shares so they are updated for all
// _ = m.equityShares.SharesExcept(m.liquidity.GetInactiveParties())
return err
}