Refactor worker to derive its own account for each host (#1464)

Closes #1462

api/account.go

@@ -33,6 +33,10 @@ type (
 		// an account and the balance reported by a host.
 		Drift *big.Int `json:"drift"`
 
+		// Owner is the owner of the account which is responsible for funding
+		// it.
+		Owner string `json:"owner"`
+
 		// RequiresSync indicates whether an account needs to be synced with the
 		// host before it can be used again.
 		RequiresSync bool `json:"requiresSync"`

api/bus.go

@@ -45,6 +45,10 @@ type (
 )
 
 type (
+	AccountsSaveRequest struct {
+		Accounts []Account `json:"accounts"`
+	}
+
 	// BusStateResponse is the response type for the /bus/state endpoint.
 	BusStateResponse struct {
 		StartTime TimeRFC3339 `json:"startTime"`

api/worker.go

@@ -87,14 +87,6 @@ type (
 		TransactionSet []types.Transaction    `json:"transactionSet"`
 	}
 
-	// RHPFundRequest is the request type for the /rhp/fund endpoint.
-	RHPFundRequest struct {
-		ContractID types.FileContractID `json:"contractID"`
-		HostKey    types.PublicKey      `json:"hostKey"`
-		SiamuxAddr string               `json:"siamuxAddr"`
-		Balance    types.Currency       `json:"balance"`
-	}
-
 	// RHPPruneContractRequest is the request type for the /rhp/contract/:id/prune
 	// endpoint.
 	RHPPruneContractRequest struct {

autopilot/alerts.go

@@ -5,15 +5,12 @@ import (
 	"fmt"
 	"time"
 
-	rhpv3 "go.sia.tech/core/rhp/v3"
 	"go.sia.tech/core/types"
 	"go.sia.tech/renterd/alerts"
-	"go.sia.tech/renterd/api"
 	"go.sia.tech/renterd/object"
 )
 
 var (
-	alertAccountRefillID = alerts.RandomAlertID() // constant until restarted
 	alertHealthRefreshID = alerts.RandomAlertID() // constant until restarted
 	alertLowBalanceID    = alerts.RandomAlertID() // constant until restarted
 	alertMigrationID     = alerts.RandomAlertID() // constant until restarted
@@ -54,26 +51,6 @@ func newAccountLowBalanceAlert(address types.Address, balance, allowance types.C
 	}
 }
 
-func newAccountRefillAlert(id rhpv3.Account, contract api.ContractMetadata, err refillError) alerts.Alert {
-	data := map[string]interface{}{
-		"error":      err.Error(),
-		"accountID":  id.String(),
-		"contractID": contract.ID.String(),
-		"hostKey":    contract.HostKey.String(),
-	}
-	for i := 0; i < len(err.keysAndValues); i += 2 {
-		data[fmt.Sprint(err.keysAndValues[i])] = err.keysAndValues[i+1]
-	}
-
-	return alerts.Alert{
-		ID:        alerts.IDForAccount(alertAccountRefillID, id),
-		Severity:  alerts.SeverityError,
-		Message:   "Ephemeral account refill failed",
-		Data:      data,
-		Timestamp: time.Now(),
-	}
-}
-
 func newContractPruningFailedAlert(hk types.PublicKey, version, release string, fcid types.FileContractID, err error) alerts.Alert {
 	return alerts.Alert{
 		ID:       alerts.IDForContract(alertPruningID, fcid),