logos-storage/logos-storage-go
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-go.git synced 2026-01-04 06:13:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

moves tests to a separate package to discorage testing of the implementation details and avoid import cycles in the future when using mocks

Browse Source
This commit is contained in:
Marcin Czenko 2025-10-22 21:02:28 +02:00
parent 57f7b873ac
commit 3e135f3c53
No known key found for this signature in database
GPG Key ID: A0449219BDBA98AE
2 changed files with 27 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
communities/codex_client_integration_test.go
View File

@ -1,7 +1,7 @@
//go:build integration //go:build integration
// +build integration // +build integration
package communities package communities_test
import ( import (
"bytes" "bytes"
@ -11,6 +11,8 @@ import (
"os" "os"
"testing" "testing"
"time" "time"
"go-codex-client/communities"
) )
// This test exercises real network calls against a running Codex node. // This test exercises real network calls against a running Codex node.
@ -27,7 +29,7 @@ import (
func TestIntegration_UploadAndDownload(t *testing.T) { func TestIntegration_UploadAndDownload(t *testing.T) {
host := getenv("CODEX_HOST", "localhost") host := getenv("CODEX_HOST", "localhost")
port := getenv("CODEX_API_PORT", "8080") port := getenv("CODEX_API_PORT", "8080")
client := NewCodexClient(host, port) client := communities.NewCodexClient(host, port)
// Optional request timeout override // Optional request timeout override
if ms := os.Getenv("CODEX_TIMEOUT_MS"); ms != "" { if ms := os.Getenv("CODEX_TIMEOUT_MS"); ms != "" {
@ -82,7 +84,7 @@ func TestIntegration_UploadAndDownload(t *testing.T) {
func TestIntegration_CheckNonExistingCID(t *testing.T) { func TestIntegration_CheckNonExistingCID(t *testing.T) {
host := getenv("CODEX_HOST", "localhost") host := getenv("CODEX_HOST", "localhost")
port := getenv("CODEX_API_PORT", "8080") port := getenv("CODEX_API_PORT", "8080")
client := NewCodexClient(host, port) client := communities.NewCodexClient(host, port)
// Generate random payload to ensure proper round-trip verification // Generate random payload to ensure proper round-trip verification
payload := make([]byte, 1024) payload := make([]byte, 1024)
@ -126,7 +128,7 @@ func TestIntegration_CheckNonExistingCID(t *testing.T) {
func TestIntegration_TriggerDownload(t *testing.T) { func TestIntegration_TriggerDownload(t *testing.T) {
host := getenv("CODEX_HOST", "localhost") host := getenv("CODEX_HOST", "localhost")
port := getenv("CODEX_API_PORT", "8001") // Use port 8001 as specified by user port := getenv("CODEX_API_PORT", "8001") // Use port 8001 as specified by user
client := NewCodexClient(host, port) client := communities.NewCodexClient(host, port)
// Optional request timeout override // Optional request timeout override
if ms := os.Getenv("CODEX_TIMEOUT_MS"); ms != "" { if ms := os.Getenv("CODEX_TIMEOUT_MS"); ms != "" {

40
communities/codex_client_test.go
View File

@ -1,4 +1,4 @@
package communities package communities_test
import ( import (
"bytes" "bytes"
@ -11,6 +11,8 @@ import (
"strings" "strings"
"testing" "testing"
"time" "time"
"go-codex-client/communities"
) )
func TestUpload_Success(t *testing.T) { func TestUpload_Success(t *testing.T) {
@ -47,7 +49,7 @@ func TestUpload_Success(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
// Act // Act
@ -82,7 +84,7 @@ func TestDownload_Success(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
var buf bytes.Buffer var buf bytes.Buffer
@ -124,7 +126,7 @@ func TestDownloadWithContext_Cancel(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Millisecond) ctx, cancel := context.WithTimeout(context.Background(), 30*time.Millisecond)
@ -169,7 +171,7 @@ func TestHasCid_Success(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
got, err := client.HasCid(tt.cid) got, err := client.HasCid(tt.cid)
@ -188,7 +190,7 @@ func TestHasCid_RequestError(t *testing.T) {
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})) server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
server.Close() // Close immediately so connection fails server.Close() // Close immediately so connection fails
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL // Use the closed server's URL client.BaseURL = server.URL // Use the closed server's URL
got, err := client.HasCid("zDvZRwzmTestCID") got, err := client.HasCid("zDvZRwzmTestCID")
@ -212,7 +214,7 @@ func TestHasCid_CidMismatch(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
got, err := client.HasCid(requestCid) got, err := client.HasCid(requestCid)
@ -245,7 +247,7 @@ func TestRemoveCid_Success(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
err := client.RemoveCid(testCid) err := client.RemoveCid(testCid)
@ -264,7 +266,7 @@ func TestRemoveCid_Error(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
err := client.RemoveCid(testCid) err := client.RemoveCid(testCid)
@ -305,7 +307,7 @@ func TestTriggerDownload(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -333,7 +335,7 @@ func TestTriggerDownloadWithContext_RequestError(t *testing.T) {
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})) server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
server.Close() server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -357,7 +359,7 @@ func TestTriggerDownloadWithContext_JSONParseError(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -382,7 +384,7 @@ func TestTriggerDownloadWithContext_HTTPError(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -414,7 +416,7 @@ func TestTriggerDownloadWithContext_Cancellation(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
// Cancel after 50ms (before server responds) // Cancel after 50ms (before server responds)
@ -457,7 +459,7 @@ func TestLocalDownload(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
var buf bytes.Buffer var buf bytes.Buffer
@ -490,7 +492,7 @@ func TestLocalDownloadWithContext_Success(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -510,7 +512,7 @@ func TestLocalDownloadWithContext_RequestError(t *testing.T) {
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})) server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
server.Close() server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -534,7 +536,7 @@ func TestLocalDownloadWithContext_HTTPError(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
ctx := context.Background() ctx := context.Background()
@ -560,7 +562,7 @@ func TestLocalDownloadWithContext_Cancellation(t *testing.T) {
})) }))
defer server.Close() defer server.Close()
client := NewCodexClient("localhost", "8080") client := communities.NewCodexClient("localhost", "8080")
client.BaseURL = server.URL client.BaseURL = server.URL
// Create a context with a very short timeout // Create a context with a very short timeout