mirror of
https://github.com/hanzoai/agents.git
synced 2026-10-30 18:48:36 +00:00
zeekayandGitHub
5b5cf9e9db
Transforms hanzoai/agents from a marketplace config repo into a full agent orchestration platform by merging the AgentField infrastructure: - Go control plane (K8s-like agent orchestration, service mesh, DAG workflows) - Python SDK (FastAPI-based agent framework, LiteLLM, memory, DID/VC) - TypeScript SDK (@hanzo/agents - Vercel AI SDK, MCP, workflows) - Go SDK (idiomatic agent builder + client) - React 19 embedded dashboard (XyFlow DAGs, Recharts, Radix UI) - Docker/K8s/Helm deployment configs - Examples: hello world, deep research, RAG, simulation, benchmarks - Functional test suite across Python/Go/TypeScript All references rebranded: AgentField → Hanzo Agents - Module: github.com/hanzoai/agents/control-plane - Python: hanzo_agents - TypeScript: @hanzo/agents - Go: github.com/hanzoai/agents/sdk/go - Env vars: HANZO_AGENTS_* - Config: hanzo-agents.yaml Previous marketplace configs moved to config/ directory.
121 lines
2.5 KiB
Go
121 lines
2.5 KiB
Go
package storage
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestParseTimeString(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
input string
|
|
wantErr bool
|
|
}{
|
|
{
|
|
name: "PostgreSQL timestamp with timezone and microseconds",
|
|
input: "2025-11-11 00:00:15.535675+00:00",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "PostgreSQL timestamp with negative timezone offset",
|
|
input: "2025-11-10 21:30:59.083244-05:00",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "PostgreSQL timestamp without microseconds",
|
|
input: "2025-11-11 00:00:15+00:00",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "RFC3339 format",
|
|
input: "2025-11-11T00:00:15.535675Z",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "SQLite format without timezone",
|
|
input: "2025-11-11 00:00:15.535675",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "Empty string",
|
|
input: "",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "Invalid format",
|
|
input: "not-a-timestamp",
|
|
wantErr: true,
|
|
},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := parseTimeString(tt.input)
|
|
if (err != nil) != tt.wantErr {
|
|
t.Errorf("parseTimeString() error = %v, wantErr %v", err, tt.wantErr)
|
|
return
|
|
}
|
|
if !tt.wantErr && tt.input != "" {
|
|
if result.IsZero() {
|
|
t.Errorf("parseTimeString() returned zero time for valid input %q", tt.input)
|
|
}
|
|
// Verify the result is in UTC
|
|
if result.Location() != time.UTC {
|
|
t.Errorf("parseTimeString() returned non-UTC time: %v", result.Location())
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestParseDBTime(t *testing.T) {
|
|
now := time.Now().UTC()
|
|
|
|
tests := []struct {
|
|
name string
|
|
input interface{}
|
|
wantErr bool
|
|
}{
|
|
{
|
|
name: "time.Time value",
|
|
input: now,
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "PostgreSQL string timestamp",
|
|
input: "2025-11-11 00:00:15.535675+00:00",
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "Byte slice timestamp",
|
|
input: []byte("2025-11-11 00:00:15.535675+00:00"),
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "nil value",
|
|
input: nil,
|
|
wantErr: false,
|
|
},
|
|
{
|
|
name: "Unsupported type",
|
|
input: 123,
|
|
wantErr: true,
|
|
},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := parseDBTime(tt.input)
|
|
if (err != nil) != tt.wantErr {
|
|
t.Errorf("parseDBTime() error = %v, wantErr %v", err, tt.wantErr)
|
|
return
|
|
}
|
|
if !tt.wantErr && tt.input != nil {
|
|
if result.IsZero() && tt.name != "nil value" {
|
|
t.Errorf("parseDBTime() returned zero time for valid input")
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|