Skip to content

Commit 3116091

Browse files
committed
fix: info log instead of error when json unmarshaling fails
1 parent e7f1eaa commit 3116091

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

services/akash/akash.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ func (as *AkashService) GetAkashDeployments(cfg config.Config, data *types.Async
3636
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
3737
}
3838
if err := json.Unmarshal(res, &deployments); err != nil {
39-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
39+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
4040
}
4141

4242
// get total deployments count
@@ -52,7 +52,7 @@ func (as *AkashService) GetAkashDeployments(cfg config.Config, data *types.Async
5252
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
5353
}
5454
if err := json.Unmarshal(resActive, &activeDeployments); err != nil {
55-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
55+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
5656
}
5757

5858
activeDeploymentsCount, err := strconv.Atoi(activeDeployments.Pagination.Total)
@@ -79,7 +79,7 @@ func (as *AkashService) GetAkashProviders(cfg config.Config, data *types.AsyncDa
7979
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
8080
}
8181
if err := json.Unmarshal(res, &providers); err != nil {
82-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
82+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
8383
}
8484

8585
// handle pagination
@@ -91,7 +91,7 @@ func (as *AkashService) GetAkashProviders(cfg config.Config, data *types.AsyncDa
9191
}
9292
var nextPage akash.ProvidersResponse
9393
if err := json.Unmarshal(res, &nextPage); err != nil {
94-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
94+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
9595
}
9696

9797
// append to the response
@@ -184,7 +184,7 @@ func (as *AkashService) IndexAuditorForProviderOwners(cfg config.Config, provide
184184
return fmt.Errorf("error querying auditors for provider owner: %w", err)
185185
}
186186
if err := json.Unmarshal(res, &auditors); err != nil {
187-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
187+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
188188
}
189189

190190
// handle pagination
@@ -196,7 +196,7 @@ func (as *AkashService) IndexAuditorForProviderOwners(cfg config.Config, provide
196196
}
197197
var nextPage akash.AuditorsResponse
198198
if err := json.Unmarshal(res, &nextPage); err != nil {
199-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
199+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
200200
}
201201

202202
// append to the response
@@ -272,7 +272,7 @@ func (as *AkashService) IndexDeploymentForProviderOwner(cfg config.Config, provi
272272
return fmt.Errorf("error querying deployments for provider owner: %w", err)
273273
}
274274
if err := json.Unmarshal(res, &deployments); err != nil {
275-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
275+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
276276
}
277277

278278
// handle pagination
@@ -284,7 +284,7 @@ func (as *AkashService) IndexDeploymentForProviderOwner(cfg config.Config, provi
284284
}
285285
var nextPage akash.DeploymentsResponse
286286
if err := json.Unmarshal(res, &nextPage); err != nil {
287-
zap.L().Fatal("", zap.Bool("Success", false), zap.String("err", err.Error()))
287+
zap.L().Info("", zap.Bool("Success", false), zap.String("err", err.Error()))
288288
}
289289

290290
// append to the response

0 commit comments

Comments
 (0)