Skip to content
This repository was archived by the owner on Aug 30, 2024. It is now read-only.

Add ws dials for resource load and ide status #111

Merged
merged 3 commits into from
Sep 4, 2020
Merged

Add ws dials for resource load and ide status #111

Changes from 2 commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ba5d4b8
Add ws dials for resource load and ide status
f0ssel Sep 4, 2020
77d3e64
Add WaitForEnvironmentReady utility
f0ssel Sep 4, 2020
89752df
Add build log types
f0ssel Sep 4, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 39 additions & 3 deletions coder-sdk/env.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,13 @@ package coder

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

"cdr.dev/coder-cli/internal/x/xjson"
"nhooyr.io/websocket"
"nhooyr.io/websocket/wsjson"
)

// Environment describes a Coder environment
Expand Down Expand Up @@ -78,14 +80,14 @@ type CreateEnvironmentRequest struct {

// CreateEnvironment sends a request to create an environment.
func (c Client) CreateEnvironment(ctx context.Context, orgID string, req CreateEnvironmentRequest) (*Environment, error) {
var env *Environment
var env Environment
err := c.requestBody(
ctx,
http.MethodPost, "/api/orgs/"+orgID+"/environments",
req,
env,
&env,
)
return env, err
return &env, err
}

// EnvironmentsByOrganization gets the list of environments owned by the given user.
Expand Down Expand Up @@ -116,6 +118,11 @@ func (c Client) DialWsep(ctx context.Context, env *Environment) (*websocket.Conn
return c.dialWs(ctx, "/proxy/environments/"+env.ID+"/wsep")
}

// DialIDEStatus opens a websocket connection for cpu load metrics on the environment
func (c Client) DialIDEStatus(ctx context.Context, envID string) (*websocket.Conn, error) {
return c.dialWs(ctx, "/proxy/environments/"+envID+"/ide/api/status")
}

// DialEnvironmentBuildLog opens a websocket connection for the environment build log messages
func (c Client) DialEnvironmentBuildLog(ctx context.Context, envID string) (*websocket.Conn, error) {
return c.dialWs(ctx, "/api/environments/"+envID+"/watch-update")
Expand All @@ -125,3 +132,32 @@ func (c Client) DialEnvironmentBuildLog(ctx context.Context, envID string) (*web
func (c Client) DialEnvironmentStats(ctx context.Context, envID string) (*websocket.Conn, error) {
return c.dialWs(ctx, "/api/environments/"+envID+"/watch-stats")
}

// DialResourceLoad opens a websocket connection for cpu load metrics on the environment
func (c Client) DialResourceLoad(ctx context.Context, envID string) (*websocket.Conn, error) {
return c.dialWs(ctx, "/api/environments/"+envID+"/watch-resource-load")
}

type buildLogMsg struct {
Type string `json:"type"`
}

// WaitForEnvironmentReady will watch the build log and return when done
func (c Client) WaitForEnvironmentReady(ctx context.Context, env *Environment) error {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why does this need the full environment when the above function doesn't?

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Ah, good point.

conn, err := c.DialEnvironmentBuildLog(ctx, env.ID)
if err != nil {
return fmt.Errorf("%s: dial build log: %w", env.Name, err)
}

for {
msg := buildLogMsg{}
err := wsjson.Read(ctx, conn, &msg)
if err != nil {
return fmt.Errorf("%s: reading build log msg: %w", env.Name, err)
}

if msg.Type == "done" {
return nil
}
}
}