Skip to content

Commit

Permalink
Merge pull request #204 from tonkeeper/unnecessary_jettons
Browse files Browse the repository at this point in the history
remove unnecessary jettons
  • Loading branch information
mr-tron authored Oct 3, 2023
2 parents 46e82fd + 1a2a30a commit fc40684
Showing 1 changed file with 0 additions and 86 deletions.
86 changes: 0 additions & 86 deletions pkg/addressbook/addressbook.go
Original file line number Diff line number Diff line change
Expand Up @@ -222,8 +222,6 @@ func NewAddressBook(logger *zap.Logger, addressPath, jettonPath, collectionPath
func (b *Book) refresh(logger *zap.Logger, addressPath, jettonPath, collectionPath string) {
go b.refreshAddresses(logger, addressPath)
go b.refreshJettons(logger, jettonPath)
go b.refreshStonfiJettons(logger)
go b.refreshMegatonJettons(logger)
go b.refreshCollections(logger, collectionPath)
go b.refreshTfPools(logger)
}
Expand Down Expand Up @@ -264,38 +262,6 @@ func (b *Book) refreshJettons(logger *zap.Logger, jettonPath string) {
}
}

func (b *Book) refreshMegatonJettons(logger *zap.Logger) {
jettons, err := getMegatonJettons()
if err != nil {
logger.Info("failed to load megaton jettons")
return
}
b.mu.Lock()
defer b.mu.Unlock()
for _, jetton := range jettons {
_, ok := b.jettons[tongo.MustParseAccountID(jetton.Address)]
if !ok {
b.jettons[tongo.MustParseAccountID(jetton.Address)] = jetton
}
}
}

func (b *Book) refreshStonfiJettons(logger *zap.Logger) {
jettons, err := getStonfiJettons()
if err != nil {
logger.Info("failed to load stonfi jettons")
return
}
b.mu.Lock()
defer b.mu.Unlock()
for _, jetton := range jettons {
_, ok := b.jettons[tongo.MustParseAccountID(jetton.Address)]
if !ok {
b.jettons[tongo.MustParseAccountID(jetton.Address)] = jetton
}
}
}

func unique(approvers []oas.NftItemApprovedByItem) []oas.NftItemApprovedByItem {
sort.Slice(approvers, func(i, j int) bool {
return approvers[i] < approvers[j]
Expand Down Expand Up @@ -427,55 +393,3 @@ func _getGGWhitelist(client *graphql.Client) ([]tongo.AccountID, error) {
}
return addr, nil
}

func getMegatonJettons() ([]KnownJetton, error) {
response, err := http.Get("https://megaton.fi/api/token/infoList")
if err != nil {
return nil, err
}
defer response.Body.Close()
if response.StatusCode >= 300 {
return nil, fmt.Errorf("invalid status code %v", response.StatusCode)
}
var respBody []KnownJetton
if err = json.NewDecoder(response.Body).Decode(&respBody); err != nil {
return nil, err
}
for idx, jetton := range respBody {
address, err := tongo.ParseAccountID(jetton.Address)
if err != nil {
continue
}
jetton.Address = address.ToRaw()
respBody[idx] = jetton
}
return respBody, nil
}

func getStonfiJettons() ([]KnownJetton, error) {
response, err := http.Get("https://api.ston.fi/v1/pools")
if err != nil {
return nil, err
}
defer response.Body.Close()
if response.StatusCode >= 300 {
return nil, fmt.Errorf("invalid status code %v", response.StatusCode)
}
var respBody struct {
PoolList []struct {
Address string `json:"address"`
} `json:"pool_list"`
}
if err = json.NewDecoder(response.Body).Decode(&respBody); err != nil {
return nil, err
}
var jettons []KnownJetton
for _, jetton := range respBody.PoolList {
address, err := tongo.ParseAccountID(jetton.Address)
if err != nil {
continue
}
jettons = append(jettons, KnownJetton{Address: address.ToRaw()})
}
return jettons, nil
}

0 comments on commit fc40684

Please sign in to comment.