feat(fine-tuning): improve service config reading and add configurable stake (#355)

- Optimize GetService to use direct contract call instead of GetAllServices
- Add unified error handling using IsServiceNotExist helper
- Add ProviderStake config field for customizable stake amount
- Align with inference service implementation pattern

Co-authored-by: Claude Sonnet 4.5 <noreply@anthropic.com>

Author: Ravenyjh

api/fine-tuning/config/config.go

@@ -27,6 +27,7 @@ type Service struct {
 		GpuCount int64  `yaml:"gpuCount"`
 	} `yaml:"quota"`
 	PricePerToken    int64             `yaml:"pricePerToken"`
+	ProviderStake    string            `yaml:"providerStake"` // Stake amount for first-time service registration (default: 100000000000000000000 = 100 0G)
 	CustomizedModels []CustomizedModel `yaml:"customizedModels"`
 	// ModelLocalPaths maps model hash to local file path for any model (including predefined models)
 	// When set, the broker will use the local model instead of downloading from 0G Storage
@@ -202,7 +203,7 @@ func GetConfig() *Config {
 			Database: struct {
 				FineTune string `yaml:"fineTune"`
 			}{
-				FineTune: "root:123456@tcp(0g-fine-tune-broker-db:3306)/fineTune?parseTime=true",
+				FineTune: "root:123456@tcp(mysql:3306)/fineTune?parseTime=true",
 			},
 			GasPrice: "",
 			Images: Images{

api/fine-tuning/internal/contract/service.go

@@ -2,7 +2,6 @@ package providercontract
 
 import (
 	"context"
-	"fmt"
 	"math/big"
 
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
@@ -46,7 +45,7 @@ func (c *ProviderContract) OccupyService(ctx context.Context, service config.Ser
 func (c *ProviderContract) AddOrUpdateService(ctx context.Context, service config.Service, occupied bool) error {
 	// Get existing service if any
 	old, err := c.GetService(ctx)
-	if err != nil && err.Error() != "service not found" {
+	if err != nil && !IsServiceNotExist(err) {
 		return errors.Wrap(err, "get service from contract")
 	}
 
@@ -88,7 +87,14 @@ func (c *ProviderContract) addOrUpdateServiceWithOld(ctx context.Context, servic
 	if old == nil {
 		// First-time registration: need to stake
 		stakeValue = DefaultProviderStake
-		c.logger.Infof("First-time service registration, staking %s", stakeValue.String())
+		if service.ProviderStake != "" {
+			stakeValue, err = util.ConvertToBigInt(service.ProviderStake)
+			if err != nil {
+				c.logger.Errorf("[addOrUpdateServiceWithOld] Failed to convert provider stake - stake=%s, error=%v", service.ProviderStake, err)
+				return errors.Wrap(err, "convert provider stake")
+			}
+		}
+		c.logger.Infof("[addOrUpdateServiceWithOld] First-time service registration, stake amount: %s", stakeValue.String())
 	}
 	// If old exists, it's an update, stakeValue remains nil (no additional stake)
 
@@ -154,26 +160,29 @@ func (c *ProviderContract) DeleteService(ctx context.Context) error {
 }
 
 func (c *ProviderContract) GetService(ctx context.Context) (*contract.Service, error) {
+	c.logger.Infof("[GetService] Starting to get service - provider=%s", c.ProviderAddress)
+
 	callOpts := &bind.CallOpts{
 		Context: ctx,
 	}
 
-	list, err := c.Contract.GetAllServices(callOpts)
+	service, err := c.Contract.GetService(callOpts, common.HexToAddress(c.ProviderAddress))
 	if err != nil {
-		return nil, err
-	}
-	for i := range list {
-		if list[i].Provider.String() == c.ProviderAddress {
-			return &list[i], nil
-		}
+		// Wrap error to extract details from rpc.jsonError Data field
+		wrappedErr := WrapContractError(err)
+		c.logger.Errorf("[GetService] Contract error - provider=%s: %v", c.ProviderAddress, wrappedErr)
+		return nil, wrappedErr
 	}
 
-	return nil, fmt.Errorf("service not found")
+	c.logger.Infof("[GetService] Retrieved service from contract - url=%s, models=%v, pricePerToken=%s, occupied=%v",
+		service.Url, service.Models, service.PricePerToken.String(), service.Occupied)
+
+	return &service, nil
 }
 
 func (c *ProviderContract) SyncServices(ctx context.Context, new config.Service) error {
 	old, err := c.GetService(ctx)
-	if err != nil && err.Error() != "service not found" {
+	if err != nil && !IsServiceNotExist(err) {
 		return err
 	}