limit_check_lock (#287)

controller/store/limitCheckLock.go

@@ -0,0 +1,17 @@
+package store
+
+import (
+	"github.com/jmoiron/sqlx"
+	"github.com/pkg/errors"
+)
+
+func (str *Store) LimitCheckLock(acctId int, trx *sqlx.Tx) error {
+	rows, err := trx.Queryx("select * from limit_check_locks where account_id = $1 for update", acctId)
+	if err != nil {
+		return errors.Wrap(err, "error preparing limit_check_locks select statement")
+	}
+	if !rows.Next() {
+		return errors.Errorf("no limit_check_locks entry for account_id '%d'", acctId)
+	}
+	return nil
+}

controller/store/sql/postgresql/023_v0_4_31_limit_check_locks.sql

@@ -0,0 +1,7 @@
+-- +migrate Up
+
+create table limit_check_locks (
+    id                  serial                  primary key,
+    account_id          integer                 not null references accounts (id),
+    updated_at          timestamptz             not null default(current_timestamp)
+);

controller/store/store.go

@@ -24,6 +24,7 @@ type Model struct {
 type Config struct {
 	Path          string `cf:"+secret"`
 	Type          string
+	EnableLocking bool
 }
 
 type Store struct {