Merge branch 'main' of github.com:steveyegge/beads
# Conflicts: # .beads/beads.jsonl
This commit is contained in:
@@ -9,7 +9,7 @@
|
|||||||
"name": "beads",
|
"name": "beads",
|
||||||
"source": "./",
|
"source": "./",
|
||||||
"description": "AI-supervised issue tracker for coding workflows",
|
"description": "AI-supervised issue tracker for coding workflows",
|
||||||
"version": "0.21.8"
|
"version": "0.21.9"
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"name": "beads",
|
"name": "beads",
|
||||||
"description": "AI-supervised issue tracker for coding workflows. Manage tasks, discover work, and maintain context with simple CLI commands.",
|
"description": "AI-supervised issue tracker for coding workflows. Manage tasks, discover work, and maintain context with simple CLI commands.",
|
||||||
"version": "0.21.8",
|
"version": "0.21.9",
|
||||||
"author": {
|
"author": {
|
||||||
"name": "Steve Yegge",
|
"name": "Steve Yegge",
|
||||||
"url": "https://github.com/steveyegge"
|
"url": "https://github.com/steveyegge"
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
"runtime"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
)
|
)
|
||||||
@@ -250,7 +251,11 @@ func init() {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
testBD = filepath.Join(tmpDir, "bd")
|
bdBinary := "bd"
|
||||||
|
if runtime.GOOS == "windows" {
|
||||||
|
bdBinary = "bd.exe"
|
||||||
|
}
|
||||||
|
testBD = filepath.Join(tmpDir, bdBinary)
|
||||||
cmd := exec.Command("go", "build", "-o", testBD, ".")
|
cmd := exec.Command("go", "build", "-o", testBD, ".")
|
||||||
if out, err := cmd.CombinedOutput(); err != nil {
|
if out, err := cmd.CombinedOutput(); err != nil {
|
||||||
panic(string(out))
|
panic(string(out))
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ import (
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
// Version is the current version of bd (overridden by ldflags at build time)
|
// Version is the current version of bd (overridden by ldflags at build time)
|
||||||
Version = "0.21.8"
|
Version = "0.21.9"
|
||||||
// Build can be set via ldflags at compile time
|
// Build can be set via ldflags at compile time
|
||||||
Build = "dev"
|
Build = "dev"
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[project]
|
[project]
|
||||||
name = "beads-mcp"
|
name = "beads-mcp"
|
||||||
version = "0.21.8"
|
version = "0.21.9"
|
||||||
description = "MCP server for beads issue tracker."
|
description = "MCP server for beads issue tracker."
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
requires-python = ">=3.10"
|
requires-python = ">=3.10"
|
||||||
|
|||||||
@@ -4,4 +4,4 @@ This package provides an MCP (Model Context Protocol) server that exposes
|
|||||||
beads (bd) issue tracker functionality to MCP Clients.
|
beads (bd) issue tracker functionality to MCP Clients.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
__version__ = "0.21.8"
|
__version__ = "0.21.9"
|
||||||
|
|||||||
@@ -963,6 +963,8 @@ func TestValidateNoDuplicateExternalRefs(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestConcurrentExternalRefImports(t *testing.T) {
|
func TestConcurrentExternalRefImports(t *testing.T) {
|
||||||
|
t.Skip("TODO(bd-gpe7): Test hangs due to database deadlock - needs investigation")
|
||||||
|
|
||||||
t.Run("sequential imports with same external_ref are detected as updates", func(t *testing.T) {
|
t.Run("sequential imports with same external_ref are detected as updates", func(t *testing.T) {
|
||||||
store, err := sqlite.New(":memory:")
|
store, err := sqlite.New(":memory:")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -1029,6 +1031,10 @@ func TestConcurrentExternalRefImports(t *testing.T) {
|
|||||||
})
|
})
|
||||||
|
|
||||||
t.Run("concurrent updates to same external_ref with different timestamps", func(t *testing.T) {
|
t.Run("concurrent updates to same external_ref with different timestamps", func(t *testing.T) {
|
||||||
|
if testing.Short() {
|
||||||
|
t.Skip("Skipping slow concurrent test in short mode")
|
||||||
|
}
|
||||||
|
|
||||||
store, err := sqlite.New(":memory:")
|
store, err := sqlite.New(":memory:")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to create store: %v", err)
|
t.Fatalf("Failed to create store: %v", err)
|
||||||
@@ -1056,6 +1062,7 @@ func TestConcurrentExternalRefImports(t *testing.T) {
|
|||||||
|
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
results := make([]*Result, 3)
|
results := make([]*Result, 3)
|
||||||
|
done := make(chan bool, 1)
|
||||||
|
|
||||||
for i := 0; i < 3; i++ {
|
for i := 0; i < 3; i++ {
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
@@ -1077,7 +1084,17 @@ func TestConcurrentExternalRefImports(t *testing.T) {
|
|||||||
}(i)
|
}(i)
|
||||||
}
|
}
|
||||||
|
|
||||||
wg.Wait()
|
go func() {
|
||||||
|
wg.Wait()
|
||||||
|
done <- true
|
||||||
|
}()
|
||||||
|
|
||||||
|
select {
|
||||||
|
case <-done:
|
||||||
|
// Test completed normally
|
||||||
|
case <-time.After(30 * time.Second):
|
||||||
|
t.Fatal("Test timed out after 30 seconds - likely deadlock in concurrent imports")
|
||||||
|
}
|
||||||
|
|
||||||
finalIssue, err := store.GetIssueByExternalRef(ctx, externalRef)
|
finalIssue, err := store.GetIssueByExternalRef(ctx, externalRef)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@beads/bd",
|
"name": "@beads/bd",
|
||||||
"version": "0.21.8",
|
"version": "0.21.9",
|
||||||
"description": "Beads issue tracker - lightweight memory system for coding agents with native binary support",
|
"description": "Beads issue tracker - lightweight memory system for coding agents with native binary support",
|
||||||
"main": "bin/bd.js",
|
"main": "bin/bd.js",
|
||||||
"bin": {
|
"bin": {
|
||||||
|
|||||||
Reference in New Issue
Block a user