chore(simple_client): Add explicit ServiceUnavailable error type

client/simple.go

@@ -8,6 +8,11 @@ import (
 	"net/http"
 )
 
+var (
+	// 503 error type informing rollup to failover to other DA location
+	ErrServiceUnavailable = fmt.Errorf("eigenda service is unavailable")
+)
+
 // TODO: Add support for custom http client option
 type Config struct {
 	URL string
@@ -23,18 +28,11 @@ type SimpleCommitmentClient struct {
 	httpClient *http.Client
 }
 
-func New(cfg *Config) *SimpleCommitmentClient {
-	return &SimpleCommitmentClient{
-		cfg,
-		http.DefaultClient,
-	}
-}
-
 // Health indicates if the server is operational; useful for event based awaits
 // when integration testing
 func (c *SimpleCommitmentClient) Health() error {
 	url := c.cfg.URL + "/health"
-	req, err := http.NewRequestWithContext(context.Background(), http.MethodGet, url, nil)
+	req, err := http.NewRequest(http.MethodGet, url, nil)
 	if err != nil {
 		return err
 	}
@@ -43,7 +41,6 @@ func (c *SimpleCommitmentClient) Health() error {
 	if err != nil {
 		return err
 	}
-	defer resp.Body.Close()
 
 	if resp.StatusCode != http.StatusOK {
 		return fmt.Errorf("received bad status code: %d", resp.StatusCode)
@@ -81,7 +78,8 @@ func (c *SimpleCommitmentClient) GetData(ctx context.Context, comm []byte) ([]by
 	return b, nil
 }
 
-// SetData writes raw byte data to DA and returns the respective certificate
+// SetData writes raw byte data to DA and returns the associated certificate
+// which should be verified within the proxy
 func (c *SimpleCommitmentClient) SetData(ctx context.Context, b []byte) ([]byte, error) {
 	url := fmt.Sprintf("%s/put?commitment_mode=simple", c.cfg.URL)
 	req, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(b))
@@ -100,6 +98,10 @@ func (c *SimpleCommitmentClient) SetData(ctx context.Context, b []byte) ([]byte,
 		return nil, err
 	}
 
+	if resp.StatusCode == http.StatusServiceUnavailable {
+		return nil, ErrServiceUnavailable
+	}
+
 	if resp.StatusCode != http.StatusOK {
 		return nil, fmt.Errorf("failed to store data: %v, err = %s", resp.StatusCode, string(b))
 	}