Get PostgreSQL rxTime from RxInfo if available.

brocaar · Aug 23, 2021 · 413ebd6 · 413ebd6
1 parent f6b052a
commit 413ebd6
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/internal/integration/postgresql/postgresql.go b/internal/integration/postgresql/postgresql.go
@@ -323,9 +323,18 @@ func (i *Integration) HandleJoinEvent(ctx context.Context, _ models.Integration,
 		return errors.Wrap(err, "new uuid error")
 	}
 
-	// TODO: refactor to use gateway provided time once RXInfo is available
-	// and timestamp is provided by gateway.
+	// get the rxTime either using the system-time or using one of the
+	// gateway provided timestamps.
 	rxTime := time.Now()
+	for _, rxInfo := range pl.RxInfo {
+		if rxInfo.Time != nil {
+			ts, err := ptypes.Timestamp(rxInfo.Time)
+			if err != nil {
+				return errors.Wrap(err, "protobuf timestamp error")
+			}
+			rxTime = ts
+		}
+	}
 
 	var devEUI lorawan.EUI64
 	var devAddr lorawan.DevAddr