status-im
/
status-go
mirror of https://github.com/status-im/status-go.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

add logs

This commit is contained in:
Parvesh Monu 2024-09-19 12:53:50 +05:30
parent 6e5a32c022
commit 079bb25861
No known key found for this signature in database
GPG Key ID: F399696520817DE9
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
protocol/messenger_curated_communities.go
View File

@ -24,6 +24,7 @@ func (m *Messenger) startCuratedCommunitiesUpdateLoop() {
if m.contractMaker == nil { if m.contractMaker == nil {
logger.Warn("not starting curated communities loop: contract maker not initialized") logger.Warn("not starting curated communities loop: contract maker not initialized")
logger.Info("------ parvesh not starting curated communities loop: contract maker not initialized")
return return
} }
@ -41,12 +42,14 @@ func (m *Messenger) startCuratedCommunitiesUpdateLoop() {
select { select {
case <-time.After(interval): case <-time.After(interval):
// Immediate execution on first run, then set to regular interval // Immediate execution on first run, then set to regular interval
logger.Info("------ parvesh inside loop")
interval = curatedCommunitiesUpdateInterval interval = curatedCommunitiesUpdateInterval
curatedCommunities, err := m.getCuratedCommunitiesFromContract() curatedCommunities, err := m.getCuratedCommunitiesFromContract()
if err != nil { if err != nil {
interval = communitiesUpdateFailureInterval interval = communitiesUpdateFailureInterval
logger.Error("failed to get curated communities from contract", zap.Error(err)) logger.Error("failed to get curated communities from contract", zap.Error(err))
logger.Info("------ parvesh 1", zap.Error(err))
continue continue
} }
@ -80,6 +83,7 @@ func (m *Messenger) startCuratedCommunitiesUpdateLoop() {
} }
func (m *Messenger) getCuratedCommunitiesFromContract() (*communities.CuratedCommunities, error) { func (m *Messenger) getCuratedCommunitiesFromContract() (*communities.CuratedCommunities, error) {
logger := m.logger.Named("getCuratedcommunitiesfromcontract")
if m.contractMaker == nil { if m.contractMaker == nil {
return nil, errors.New("contract maker not initialized") return nil, errors.New("contract maker not initialized")
} }
@ -94,6 +98,8 @@ func (m *Messenger) getCuratedCommunitiesFromContract() (*communities.CuratedCom
chainID = 420 // Optimism Goerli chainID = 420 // Optimism Goerli
} }
logger.Info("------ parvesh 2", zap.Any("chainID", chainID))
directory, err := m.contractMaker.NewDirectory(chainID) directory, err := m.contractMaker.NewDirectory(chainID)
if err != nil { if err != nil {
return nil, err return nil, err
@ -114,10 +120,13 @@ func (m *Messenger) getCuratedCommunitiesFromContract() (*communities.CuratedCom
if err != nil { if err != nil {
return nil, err return nil, err
} }
logger.Info("------ parvesh 3", zap.Any("featuredContractCommunities", featuredContractCommunities))
var contractFeaturedCommunityIDs []string var contractFeaturedCommunityIDs []string
for _, c := range featuredContractCommunities { for _, c := range featuredContractCommunities {
contractFeaturedCommunityIDs = append(contractFeaturedCommunityIDs, types.HexBytes(c).String()) contractFeaturedCommunityIDs = append(contractFeaturedCommunityIDs, types.HexBytes(c).String())
} }
logger.Info("------ parvesh 3", zap.Any("contractCommunityIDs", contractCommunityIDs))
logger.Info("------ parvesh 4", zap.Any("contractFeaturedCommunityIDs", contractFeaturedCommunityIDs))
return &communities.CuratedCommunities{ return &communities.CuratedCommunities{
ContractCommunities: contractCommunityIDs, ContractCommunities: contractCommunityIDs,
@ -126,9 +135,11 @@ func (m *Messenger) getCuratedCommunitiesFromContract() (*communities.CuratedCom
} }
func (m *Messenger) fetchCuratedCommunities(curatedCommunities *communities.CuratedCommunities) (*communities.KnownCommunitiesResponse, error) { func (m *Messenger) fetchCuratedCommunities(curatedCommunities *communities.CuratedCommunities) (*communities.KnownCommunitiesResponse, error) {
logger := m.logger.Named("fetchCuratedcommunities")
response, err := m.communitiesManager.GetStoredDescriptionForCommunities(curatedCommunities.ContractCommunities) response, err := m.communitiesManager.GetStoredDescriptionForCommunities(curatedCommunities.ContractCommunities)
if err != nil { if err != nil {
return nil, err return nil, err
logger.Info("------ parvesh fetch curated error", zap.Error(err))
} }
response.ContractFeaturedCommunities = curatedCommunities.ContractFeaturedCommunities response.ContractFeaturedCommunities = curatedCommunities.ContractFeaturedCommunities
@ -144,13 +155,18 @@ func (m *Messenger) fetchCuratedCommunities(curatedCommunities *communities.Cura
_ = m.fetchCommunities(unknownCommunities) _ = m.fetchCommunities(unknownCommunities)
}() }()
logger.Info("------ parvesh fetch respone", zap.Any("response", response))
return response, nil return response, nil
} }
func (m *Messenger) CuratedCommunities() (*communities.KnownCommunitiesResponse, error) { func (m *Messenger) CuratedCommunities() (*communities.KnownCommunitiesResponse, error) {
logger := m.logger.Named("CuratedCommunities")
curatedCommunities, err := m.communitiesManager.GetCuratedCommunities() curatedCommunities, err := m.communitiesManager.GetCuratedCommunities()
logger.Info("------ parvesh currated communities access", zap.Any("curatedCommunities", curatedCommunities))
if err != nil { if err != nil {
return nil, err return nil, err
logger.Info("------ parvesh currated communities access error", zap.Error(err))
} }
return m.fetchCuratedCommunities(curatedCommunities) return m.fetchCuratedCommunities(curatedCommunities)
} }