multi: be consistent with UTC conversion of timestamp

Author: ellemouton

accounts/interface.go

@@ -130,7 +130,7 @@ func (a *OffChainBalanceAccount) HasExpired() bool {
 		return false
 	}
 
-	return a.ExpirationDate.Before(time.Now())
+	return a.ExpirationDate.Before(time.Now().UTC())
 }
 
 // CurrentBalanceSats returns the current account balance in satoshis.

cmd/litcli/autopilot.go

@@ -251,7 +251,7 @@ func listFeatures(cli *cli.Context) error {
 
 func initAutopilotSession(cli *cli.Context) error {
 	sessionLength := time.Second * time.Duration(cli.Uint64("expiry"))
-	sessionExpiry := time.Now().Add(sessionLength).Unix()
+	sessionExpiry := time.Now().UTC().Add(sessionLength).Unix()
 
 	ctx := getContext()
 	clientConn, cleanup, err := connectClient(cli, false)

firewall/request_logger.go

@@ -195,7 +195,7 @@ func (r *RequestLogger) addNewAction(ri *RequestInfo,
 
 	action := &firewalldb.Action{
 		RPCMethod:   ri.URI,
-		AttemptedAt: time.Now(),
+		AttemptedAt: time.Now().UTC(),
 		State:       firewalldb.ActionStateInit,
 	}
 

rules/rate_limit.go

@@ -134,7 +134,7 @@ func (r *RateLimitEnforcer) HandleRequest(ctx context.Context, uri string,
 	// Determine the start time of the actions window.
 	startTime := time.Now().Add(
 		-time.Duration(rateLim.NumHours) * time.Hour,
-	)
+	).UTC()
 
 	// Now count all relevant actions which have taken place after the
 	// start time.

session_rpcserver.go

@@ -132,7 +132,7 @@ func (s *sessionRpcServer) start(ctx context.Context) error {
 				continue
 			}
 
-			if sess.Expiry.Before(time.Now()) {
+			if sess.Expiry.Before(time.Now().UTC()) {
 				continue
 			}
 
@@ -190,7 +190,7 @@ func (s *sessionRpcServer) AddSession(ctx context.Context,
 	req *litrpc.AddSessionRequest) (*litrpc.AddSessionResponse, error) {
 
 	expiry := time.Unix(int64(req.ExpiryTimestampSeconds), 0)
-	if time.Now().After(expiry) {
+	if time.Now().UTC().After(expiry) {
 		return nil, fmt.Errorf("expiry must be in the future")
 	}
 
@@ -364,7 +364,7 @@ func (s *sessionRpcServer) resumeSession(ctx context.Context,
 	}
 
 	// Don't resume an expired session.
-	if sess.Expiry.Before(time.Now()) {
+	if sess.Expiry.Before(time.Now().UTC()) {
 		log.Debugf("Not resuming session %x with expiry %s",
 			pubKeyBytes, sess.Expiry)
 
@@ -440,15 +440,15 @@ func (s *sessionRpcServer) resumeSession(ctx context.Context,
 	// we do not yet have a static remote pub key for.
 	if sess.RemotePublicKey == nil {
 		deadline := sess.CreatedAt.Add(s.cfg.firstConnectionDeadline)
-		if deadline.Before(time.Now()) {
+		if deadline.Before(time.Now().UTC()) {
 			log.Debugf("Deadline for session %x has already "+
 				"passed. Revoking session", pubKeyBytes)
 
 			return s.cfg.db.RevokeSession(pubKey)
 		}
 
 		// Start the deadline timer.
-		deadlineDuration := time.Until(deadline)
+		deadlineDuration := deadline.Sub(time.Now().UTC())
 		deadlineTimer := time.AfterFunc(deadlineDuration, func() {
 			close(firstConnTimout)
 		})
@@ -489,7 +489,7 @@ func (s *sessionRpcServer) resumeSession(ctx context.Context,
 	go func() {
 		defer s.wg.Done()
 
-		ticker := time.NewTimer(time.Until(sess.Expiry))
+		ticker := time.NewTimer(sess.Expiry.Sub(time.Now().UTC()))
 		defer ticker.Stop()
 
 		select {
@@ -839,7 +839,7 @@ func (s *sessionRpcServer) AddAutopilotSession(ctx context.Context,
 	}
 
 	expiry := time.Unix(int64(req.ExpiryTimestampSeconds), 0)
-	if time.Now().After(expiry) {
+	if time.Now().UTC().After(expiry) {
 		return nil, fmt.Errorf("expiry must be in the future")
 	}