Jul 26, 2021 · Jul 26, 2021 · Jul 26, 2021 · Jul 26, 2021 · Jul 26, 2021
diff --git a/coder-sdk/agent.go b/coder-sdk/agent.go
 package coder

 import (
 "context"
 "fmt"
 "net/http"
 )

 // UpdateLastConnectionAt updates the last connection at attribute of a workspace.
 func (c *DefaultClient) UpdateLastConnectionAt(ctx context.Context, workspaceID string) error {
 reqURL := fmt.Sprintf("/api/private/envagent/%s/update-last-connection-at", workspaceID)
 resp, err := c.request(ctx, http.MethodPost, reqURL, nil)
 if err != nil {
 return err
 }

 if resp.StatusCode != http.StatusOK {
 return NewHTTPError(resp)
 }

 return nil
 }
diff --git a/coder-sdk/interface.go b/coder-sdk/interface.go

 // DeleteSatelliteByID deletes a satellite entity from the Coder control plane.
 DeleteSatelliteByID(ctx context.Context,idstring)error

 // UpdateLastConnectionAt updates the last connection at attribute of a workspace.
 UpdateLastConnectionAt(ctx context.Context,workspaceIDstring)error
 }
diff --git a/internal/cmd/tunnel.go b/internal/cmd/tunnel.go
 "net/url"
 "os"
 "strconv"
 "time"

 "cdr.dev/slog"
 "cdr.dev/slog/sloggers/sloghuman"
 }
 c.log.Debug(ctx, "Connected to workspace!")

 sdk, err := newClient(ctx, false)
 if err != nil {
 return xerrors.Errorf("getting coder client: %w", err)
 }

 // regularly update the last connection at
 go func() {
 ticker := time.NewTicker(time.Minute)
 defer ticker.Stop()

 for {
 select {
 case <-ctx.Done():
 return
 case <-ticker.C:
 // silently ignore failures so we don't spam the console
 _ = sdk.UpdateLastConnectionAt(ctx, c.workspaceID)
 }
 }
 }()

 // proxy via stdio
 if c.stdio {
 go func() {
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,22 @@
		package coder

		import (
		"context"
		"fmt"
		"net/http"
		)

		// UpdateLastConnectionAt updates the last connection at attribute of a workspace.
		func (c *DefaultClient) UpdateLastConnectionAt(ctx context.Context, workspaceID string) error {
Copy link Member kylecarbsJul 26, 2021 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. Wetechnically already do this... right? https://github.com/cdr/m/commit/39ee8c732aebcfaef1cc43c8f6392c5849a2ade9#diff-658b44e208cfee6825cc7eead08c6383fded8ecf6a6708091665c29663732a93R122 Copy link ContributorAuthor f0sselJul 26, 2021 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. That only does so on connection, this will do so continuously for SSH connections and such kylecarbs reacted with thumbs up emoji
		reqURL := fmt.Sprintf("/api/private/envagent/%s/update-last-connection-at", workspaceID)
		resp, err := c.request(ctx, http.MethodPost, reqURL, nil)
		if err != nil {
		return err
		}

		if resp.StatusCode != http.StatusOK {
		return NewHTTPError(resp)
		}

		return nil
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -250,4 +250,7 @@ type Client interface {

		// DeleteSatelliteByID deletes a satellite entity from the Coder control plane.
		DeleteSatelliteByID(ctx context.Context,idstring)error

		// UpdateLastConnectionAt updates the last connection at attribute of a workspace.
		UpdateLastConnectionAt(ctx context.Context,workspaceIDstring)error
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -8,6 +8,7 @@ import (
		"net/url"
		"os"
		"strconv"
		"time"

		"cdr.dev/slog"
		"cdr.dev/slog/sloggers/sloghuman"
Expand DownExpand Up		@@ -130,6 +131,27 @@ func (c *tunnneler) start(ctx context.Context) error {
		}
		c.log.Debug(ctx, "Connected to workspace!")

		sdk, err := newClient(ctx, false)
		if err != nil {
		return xerrors.Errorf("getting coder client: %w", err)
		}

		// regularly update the last connection at
		go func() {
		ticker := time.NewTicker(time.Minute)
		defer ticker.Stop()

		for {
		select {
		case <-ctx.Done():
		return
		case <-ticker.C:
		// silently ignore failures so we don't spam the console
		_ = sdk.UpdateLastConnectionAt(ctx, c.workspaceID)
		}
		}
		}()

		// proxy via stdio
		if c.stdio {
		go func() {
Expand Down