Validate node ID, sequence ID and timestamp on synced payloads

pkg/db/queries.sql

@@ -46,13 +46,14 @@ DELETE FROM staged_originator_envelopes
 WHERE id = @id;
 
 -- name: SelectVectorClock :many
-SELECT
+SELECT DISTINCT ON (originator_node_id)
 	originator_node_id,
-	max(originator_sequence_id)::BIGINT AS originator_sequence_id
+	originator_sequence_id,
+	originator_envelope
 FROM
 	gateway_envelopes
-GROUP BY
-	originator_node_id;
+ORDER BY
+	originator_sequence_id DESC;
 
 -- name: GetAddressLogs :many
 SELECT

pkg/envelopes/originator.go

@@ -58,6 +58,10 @@ func (o *OriginatorEnvelope) OriginatorSequenceID() uint64 {
 	return o.UnsignedOriginatorEnvelope.OriginatorSequenceID()
 }
 
+func (o *OriginatorEnvelope) OriginatorNs() int64 {
+	return o.UnsignedOriginatorEnvelope.OriginatorNs()
+}
+
 func (o *OriginatorEnvelope) TargetTopic() topic.Topic {
 	return o.UnsignedOriginatorEnvelope.TargetTopic()
 }