add azure emulator client so lstk status shows version

Author: carole-lavillonniere

cmd/status.go

@@ -8,6 +8,7 @@ import (
 	"github.com/localstack/lstk/internal/container"
 	"github.com/localstack/lstk/internal/emulator"
 	"github.com/localstack/lstk/internal/emulator/aws"
+	"github.com/localstack/lstk/internal/emulator/azure"
 	"github.com/localstack/lstk/internal/emulator/snowflake"
 	"github.com/localstack/lstk/internal/env"
 	"github.com/localstack/lstk/internal/output"
@@ -35,6 +36,7 @@ func newStatusCmd(cfg *env.Env) *cobra.Command {
 			clients := map[config.EmulatorType]emulator.Client{
 				config.EmulatorAWS:       aws.NewClient(),
 				config.EmulatorSnowflake: snowflake.NewClient(),
+				config.EmulatorAzure:     azure.NewClient(),
 			}
 
 			if isInteractiveMode(cfg) {

internal/emulator/azure/client.go

@@ -0,0 +1,66 @@
+package azure
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
+
+	"github.com/localstack/lstk/internal/emulator"
+)
+
+type Client struct {
+	http *http.Client
+}
+
+func NewClient() *Client {
+	return &Client{
+		http: &http.Client{
+			Transport: otelhttp.NewTransport(
+				http.DefaultTransport,
+				otelhttp.WithSpanNameFormatter(func(_ string, r *http.Request) string {
+					return "azure " + r.Method + " " + r.URL.Path
+				}),
+			),
+		},
+	}
+}
+
+type infoResponse struct {
+	Version string `json:"version"`
+}
+
+// FetchVersion reads the version from /_localstack/info. The Azure image's
+// /_localstack/health response does not carry a "version" field, so /info is
+// the only endpoint that surfaces it.
+func (c *Client) FetchVersion(ctx context.Context, host string) (string, error) {
+	url := fmt.Sprintf("http://%s/_localstack/info", host)
+	req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil)
+	if err != nil {
+		return "", fmt.Errorf("failed to create info request: %w", err)
+	}
+
+	resp, err := c.http.Do(req)
+	if err != nil {
+		return "", fmt.Errorf("failed to fetch info: %w", err)
+	}
+	defer func() { _ = resp.Body.Close() }()
+
+	if resp.StatusCode != http.StatusOK {
+		return "", fmt.Errorf("info endpoint returned status %d", resp.StatusCode)
+	}
+
+	var i infoResponse
+	if err := json.NewDecoder(resp.Body).Decode(&i); err != nil {
+		return "", fmt.Errorf("failed to decode info response: %w", err)
+	}
+	return i.Version, nil
+}
+
+// FetchResources is a no-op for Azure — the emulator does not expose
+// /_localstack/resources (returns 404).
+func (c *Client) FetchResources(_ context.Context, _ string) ([]emulator.Resource, error) {
+	return nil, nil
+}

internal/emulator/azure/client_test.go

@@ -0,0 +1,51 @@
+package azure
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestFetchVersion(t *testing.T) {
+	t.Parallel()
+
+	t.Run("returns version from info endpoint", func(t *testing.T) {
+		t.Parallel()
+		server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			assert.Equal(t, "/_localstack/info", r.URL.Path)
+			w.Header().Set("Content-Type", "application/json")
+			_, _ = fmt.Fprintln(w, `{"version": "2026.6.0.dev112:17a29a966", "edition": "azure-alpha"}`)
+		}))
+		defer server.Close()
+
+		c := NewClient()
+		version, err := c.FetchVersion(context.Background(), server.Listener.Addr().String())
+		require.NoError(t, err)
+		assert.Equal(t, "2026.6.0.dev112:17a29a966", version)
+	})
+
+	t.Run("returns error on non-200", func(t *testing.T) {
+		t.Parallel()
+		server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
+			w.WriteHeader(http.StatusInternalServerError)
+		}))
+		defer server.Close()
+
+		c := NewClient()
+		_, err := c.FetchVersion(context.Background(), server.Listener.Addr().String())
+		require.Error(t, err)
+	})
+}
+
+func TestFetchResources_AlwaysEmpty(t *testing.T) {
+	t.Parallel()
+	c := NewClient()
+	rows, err := c.FetchResources(context.Background(), "unused")
+	require.NoError(t, err)
+	assert.Empty(t, rows)
+}