larksuite-cli/internal/binding/lark_channel_test.go

// Copyright (c) 2026 Lark Technologies Pte. Ltd.
// SPDX-License-Identifier: MIT

package binding

import (
	"os"
	"path/filepath"
	"testing"
)

func TestReadLarkChannelConfig_Valid(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{"accounts":{"app":{"id":"cli_abc123","secret":"plain_secret","tenant":"feishu"}}}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}

	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if got := root.Accounts.App.ID; got != "cli_abc123" {
		t.Errorf("ID = %q, want %q", got, "cli_abc123")
	}
	if got := root.Accounts.App.Secret.Plain; got != "plain_secret" {
		t.Errorf("Secret.Plain = %q, want %q", got, "plain_secret")
	}
	if root.Accounts.App.Secret.Ref != nil {
		t.Errorf("expected Plain form, got SecretRef = %+v", root.Accounts.App.Secret.Ref)
	}
	if got := root.Accounts.App.Tenant; got != "feishu" {
		t.Errorf("Tenant = %q, want %q", got, "feishu")
	}
}

func TestReadLarkChannelConfig_LarkTenant(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{"accounts":{"app":{"id":"cli_xyz","secret":"s","tenant":"lark"}}}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}

	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if got := root.Accounts.App.Tenant; got != "lark" {
		t.Errorf("Tenant = %q, want %q", got, "lark")
	}
}

func TestReadLarkChannelConfig_MissingFile(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "does-not-exist.json")

	_, err := ReadLarkChannelConfig(p)
	if err == nil {
		t.Fatal("expected error for missing file, got nil")
	}
	if !os.IsNotExist(err) {
		t.Errorf("expected os.IsNotExist, got %v", err)
	}
}

func TestReadLarkChannelConfig_MalformedJSON(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	if err := os.WriteFile(p, []byte("{not valid json"), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}

	_, err := ReadLarkChannelConfig(p)
	if err == nil {
		t.Fatal("expected error for malformed JSON, got nil")
	}
}

func TestReadLarkChannelConfig_PartialFields(t *testing.T) {
	// schema isComplete check belongs at the binder layer; the reader should
	// happily parse a partial config — emptiness is detected downstream.
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{"accounts":{"app":{}}}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}

	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if root.Accounts.App.ID != "" {
		t.Errorf("expected empty ID, got %q", root.Accounts.App.ID)
	}
	if !root.Accounts.App.Secret.IsZero() {
		t.Errorf("expected zero Secret, got %+v", root.Accounts.App.Secret)
	}
}

func TestReadLarkChannelConfig_SecretEnvTemplate(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{"accounts":{"app":{"id":"cli_a","secret":"${LARK_APP_SECRET}","tenant":"feishu"}}}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}
	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if got := root.Accounts.App.Secret.Plain; got != "${LARK_APP_SECRET}" {
		t.Errorf("Secret.Plain = %q, want template string", got)
	}
}

func TestReadLarkChannelConfig_SecretRefExec(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{
		"accounts": {
			"app": {
				"id": "cli_a",
				"secret": {"source": "exec", "provider": "decrypt", "id": "app-cli_a"},
				"tenant": "feishu"
			}
		},
		"secrets": {
			"providers": {
				"decrypt": {"source": "exec", "command": "/usr/local/bin/lark-channel-bridge", "args": ["secrets", "get"]}
			}
		}
	}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}
	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if root.Accounts.App.Secret.Ref == nil {
		t.Fatal("expected SecretRef, got Plain")
	}
	if got := root.Accounts.App.Secret.Ref.Source; got != "exec" {
		t.Errorf("Secret.Ref.Source = %q, want %q", got, "exec")
	}
	if got := root.Accounts.App.Secret.Ref.ID; got != "app-cli_a" {
		t.Errorf("Secret.Ref.ID = %q, want %q", got, "app-cli_a")
	}
	if root.Secrets == nil || root.Secrets.Providers["decrypt"] == nil {
		t.Errorf("expected secrets.providers[decrypt] to be parsed")
	}
}

func TestReadLarkChannelConfig_SecretRefInvalidSource(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{"accounts":{"app":{"id":"cli_a","secret":{"source":"bogus","id":"x"},"tenant":"feishu"}}}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}
	if _, err := ReadLarkChannelConfig(p); err == nil {
		t.Fatal("expected error for invalid secret source, got nil")
	}
}

func TestReadLarkChannelConfig_UnknownFieldsIgnored(t *testing.T) {
	dir := t.TempDir()
	p := filepath.Join(dir, "config.json")
	data := `{
		"accounts": {
			"app": {"id": "cli_a", "secret": "s", "tenant": "feishu"},
			"oauth": {"clientId": "ignored"}
		},
		"preferences": {"theme": "dark"}
	}`
	if err := os.WriteFile(p, []byte(data), 0o600); err != nil {
		t.Fatalf("write temp file: %v", err)
	}

	root, err := ReadLarkChannelConfig(p)
	if err != nil {
		t.Fatalf("unexpected error: %v", err)
	}
	if got := root.Accounts.App.ID; got != "cli_a" {
		t.Errorf("ID = %q, want %q", got, "cli_a")
	}
}