AnchorNet-Backend/migrations/001_initial_persistence.js at 2ca77d38ce5ee9dbd1c3f2d01dab09b757e5c665 · Baskarayelu/AnchorNet-Backend · GitHub

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
/* eslint-disable no-undef */
/** @param {import('node-pg-migrate').MigrationBuilder} pgm */
exports.up = (pgm) => {
  pgm.createTable("anchors", {
    id: { type: "text", primaryKey: true },
    name: { type: "text", notNull: true },
    registered_at: { type: "timestamptz", notNull: true },
    active: { type: "boolean", notNull: true, default: true },
  });

  pgm.createTable("liquidity_entries", {
    anchor: { type: "text", notNull: true, references: "anchors(id)", onDelete: "RESTRICT" },
    asset: { type: "text", notNull: true },
    amount: { type: "numeric(78,0)", notNull: true },
    updated_at: { type: "timestamptz", notNull: true },
  });
  pgm.addConstraint("liquidity_entries", "liquidity_entries_pkey", {
    primaryKey: ["anchor", "asset"],
  });
  pgm.addConstraint("liquidity_entries", "liquidity_amount_nonnegative", {
    check: "amount >= 0",
  });
  pgm.createIndex("liquidity_entries", ["asset", "anchor"]);

  pgm.createTable("settlements", {
    id: { type: "bigserial", primaryKey: true },
    anchor: { type: "text", notNull: true, references: "anchors(id)", onDelete: "RESTRICT" },
    asset: { type: "text", notNull: true },
    amount: { type: "numeric(78,0)", notNull: true },
    fee: { type: "numeric(78,0)", notNull: true },
    status: { type: "text", notNull: true, default: "pending" },
    created_at: { type: "timestamptz", notNull: true },
    cancel_reason: { type: "text" },
  });
  pgm.addConstraint("settlements", "settlement_amount_positive", { check: "amount > 0" });
  pgm.addConstraint("settlements", "settlement_fee_nonnegative", { check: "fee >= 0" });
  pgm.addConstraint("settlements", "settlement_status_valid", {
    check: "status IN ('pending', 'executed', 'cancelled')",
  });
  pgm.createIndex("settlements", ["anchor", "id"]);
  pgm.createIndex("settlements", ["asset", "id"]);
  pgm.createIndex("settlements", ["status", "id"]);
};

exports.down = (pgm) => {
  pgm.dropTable("settlements");
  pgm.dropTable("liquidity_entries");
  pgm.dropTable("anchors");
};