ZacharyZhang-NYandClaude Opus 4.6
e390e68594
Full self-hosted port of the Elydora tamper-evident audit protocol: - Hono API server with PostgreSQL, Redis, MinIO adapters - Ed25519 signed operations, chain hashing, Merkle epoch rollups - PBKDF2 password hashing, HMAC-SHA256 JWT, 5-role RBAC - Next.js management console - Node.js, Python, and Go SDKs - Docker Compose for local deployment - Helm chart for Kubernetes - Comprehensive security hardening and audit fixes applied Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
80 lines
2.1 KiB
Go
80 lines
2.1 KiB
Go
package elydora
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
)
|
|
|
|
// CreateExport creates a new compliance export job.
|
|
func (c *Client) CreateExport(params *CreateExportRequest) (*CreateExportResponse, error) {
|
|
var result CreateExportResponse
|
|
if err := c.doPost("/v1/exports", params, &result); err != nil {
|
|
return nil, err
|
|
}
|
|
return &result, nil
|
|
}
|
|
|
|
// ListExports lists all exports for the organization.
|
|
func (c *Client) ListExports() (*ListExportsResponse, error) {
|
|
var result ListExportsResponse
|
|
if err := c.doGet("/v1/exports", &result); err != nil {
|
|
return nil, err
|
|
}
|
|
return &result, nil
|
|
}
|
|
|
|
// GetExport retrieves a specific export by ID.
|
|
func (c *Client) GetExport(exportID string) (*GetExportResponse, error) {
|
|
var result GetExportResponse
|
|
if err := c.doGet(fmt.Sprintf("/v1/exports/%s", exportID), &result); err != nil {
|
|
return nil, err
|
|
}
|
|
return &result, nil
|
|
}
|
|
|
|
// DownloadExport downloads the raw file data for a completed export.
|
|
func (c *Client) DownloadExport(exportID string) ([]byte, error) {
|
|
u := c.baseURL + fmt.Sprintf("/v1/exports/%s/download", exportID)
|
|
|
|
req, err := http.NewRequest(http.MethodGet, u, nil)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("elydora: create request: %w", err)
|
|
}
|
|
if c.token != "" {
|
|
req.Header.Set("Authorization", "Bearer "+c.token)
|
|
}
|
|
|
|
resp, err := c.httpClient.Do(req)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("elydora: http request: %w", err)
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
body, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("elydora: read response body: %w", err)
|
|
}
|
|
|
|
if resp.StatusCode < 200 || resp.StatusCode >= 300 {
|
|
var errResp errorResponse
|
|
if jsonErr := json.Unmarshal(body, &errResp); jsonErr == nil && errResp.Error.Code != "" {
|
|
return nil, &ElydoraError{
|
|
StatusCode: resp.StatusCode,
|
|
Code: errResp.Error.Code,
|
|
Message: errResp.Error.Message,
|
|
RequestID: errResp.Error.RequestID,
|
|
Details: errResp.Error.Details,
|
|
}
|
|
}
|
|
return nil, &ElydoraError{
|
|
StatusCode: resp.StatusCode,
|
|
Code: ErrorCodeInternalError,
|
|
Message: string(body),
|
|
}
|
|
}
|
|
|
|
return body, nil
|
|
}
|