sqldb: add UpsertSelfNode query

This query is less strict in terms of the latest update timestamp field.
We want to be less strict with our own node data since we always want
our own updates recorded.

Author: ellemouton

sqldb/sqlc/graph.sql.go

@@ -13,7 +13,7 @@ VALUES ('settle_index', 0)
 -- invoices table contains all the information shared by all the invoice types. 
 CREATE TABLE IF NOT EXISTS invoices (
     -- The id of the invoice. Translates to the AddIndex.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- The hash for this invoice. The invoice hash will always identify that 
     -- invoice.
@@ -104,7 +104,7 @@ CREATE INDEX IF NOT EXISTS invoice_feature_invoice_id_idx ON invoice_features(in
 CREATE TABLE IF NOT EXISTS invoice_htlcs (
     -- The id for this htlc. Used in foreign keys instead of the 
     -- htlc_id/chan_id combination.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- Short chan id indicating the htlc's origin. uint64 stored as text.
     chan_id TEXT NOT NULL, 

sqldb/sqlc/migrations/000001_invoices.up.sql

@@ -1,6 +1,6 @@
 -- invoice_event_types stores the different types of invoice events. 
 CREATE TABLE IF NOT EXISTS invoice_event_types(
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     description TEXT NOT NULL
 );
@@ -34,7 +34,7 @@ WHERE NOT EXISTS (
 -- AMP sub invoices. This table can be used to create a historical view of what
 -- happened to the node's invoices.
 CREATE TABLE IF NOT EXISTS invoice_events (
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- added_at is the timestamp when this event was added.
     added_at TIMESTAMP NOT NULL,

sqldb/sqlc/migrations/000003_invoice_events.up.sql

@@ -3,7 +3,7 @@
 -- don't have a mapping from hash to add index.
 CREATE TABLE IF NOT EXISTS invoice_payment_hashes (
      -- id represents is the key of the invoice in the KV store.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- add_index is the KV add index of the invoice.
     add_index BIGINT NOT NULL,

sqldb/sqlc/migrations/000006_invoice_migration.up.sql

@@ -7,7 +7,7 @@
 CREATE TABLE IF NOT EXISTS graph_nodes (
     -- The db ID of the node. This will only be used DB level
     -- relations.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- The protocol version that this node was gossiped on.
     version SMALLINT NOT NULL,
@@ -105,7 +105,7 @@ CREATE UNIQUE INDEX IF NOT EXISTS graph_source_nodes_unique ON graph_source_node
 -- channels stores all teh channels that we are aware of in the graph.
 CREATE TABLE IF NOT EXISTS graph_channels (
     -- The db ID of the channel.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- The protocol version that this node was gossiped on.
     version SMALLINT NOT NULL,
@@ -218,7 +218,7 @@ CREATE UNIQUE INDEX IF NOT EXISTS graph_channel_extra_types_unique ON graph_chan
 
 CREATE TABLE IF NOT EXISTS graph_channel_policies (
     -- The db ID of the channel policy.
-    id INTEGER PRIMARY KEY,
+    id BIGINT PRIMARY KEY,
 
     -- The protocol version that this update was gossiped on.
     version SMALLINT NOT NULL,
@@ -343,7 +343,7 @@ CREATE UNIQUE INDEX IF NOT EXISTS graph_zombie_channels_channel_id_version_idx
 
 CREATE TABLE IF NOT EXISTS graph_prune_log (
     -- The block height that the prune was performed at.
-    -- NOTE: we don't use INTEGER PRIMARY KEY here since that would
+    -- NOTE: we don't use BIGINT PRIMARY KEY here since that would
     -- get transformed into an auto-incrementing type by our SQL type
     -- replacement logic. We don't want that since this must be the
     -- actual block height and not an auto-incrementing value.

sqldb/sqlc/migrations/000008_graph.up.sql

@@ -21,6 +21,27 @@ WHERE graph_nodes.last_update IS NULL
     OR EXCLUDED.last_update > graph_nodes.last_update
 RETURNING id;
 
+-- We use a separate upsert for our own node since we want to be less strict
+-- about the last_update field. For our own node, we always want to
+-- update the record even if the last_update is the same as what we have.
+-- name: UpsertSourceNode :one
+INSERT INTO graph_nodes (
+    version, pub_key, alias, last_update, color, signature
+) VALUES (
+    $1, $2, $3, $4, $5, $6
+)
+ON CONFLICT (pub_key, version)
+    -- Update the following fields if a conflict occurs on pub_key
+    -- and version.
+    DO UPDATE SET
+        alias = EXCLUDED.alias,
+        last_update = EXCLUDED.last_update,
+        color = EXCLUDED.color,
+        signature = EXCLUDED.signature
+WHERE graph_nodes.last_update IS NULL
+    OR EXCLUDED.last_update >= graph_nodes.last_update
+RETURNING id;
+
 -- name: GetNodesByIDs :many
 SELECT *
 FROM graph_nodes