services

package
v0.0.0-...-c2e5dec Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2025 License: MIT Imports: 94 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service 

type Service struct {
	KnowledgeUsecase ports.IKnowledgeUsecase
	AppConfigUseCase ports.IAppConfigUseCase
	AgentInfoUseCase ports.IAgentInfoUseCase
	// contains filtered or unexported fields
}

func NewService 

func NewService(conf *configs.Config) *Service

func (*Service) AgentAddLiquidityDAOToken 

func (s *Service) AgentAddLiquidityDAOToken(ctx context.Context, memeID uint) error

func (*Service) AgentChatSupport 

func (s *Service) AgentChatSupport(ctx context.Context, msg string) (string, error)

func (*Service) AgentChats 

func (s *Service) AgentChats(ctx context.Context, agentID string, messages serializers.AgentChatMessageReq) (*openai.ChatResponse, error)

func (*Service) AgentCreateAgentAssistant 

func (s *Service) AgentCreateAgentAssistant(ctx context.Context, address string, req *serializers.AssistantsReq) (*models.AgentInfo, error)

func (*Service) AgentCreateAgentAssistantForLocal 

func (s *Service) AgentCreateAgentAssistantForLocal(ctx context.Context, req *serializers.AssistantsReq) (*models.AgentInfo, error)

func (*Service) AgentCreateAgentStudio 

func (s *Service) AgentCreateAgentStudio(ctx context.Context, address, graphData string) ([]*models.AgentInfo, error)

//

func (*Service) AgentCreateMissionDefault 

func (s *Service) AgentCreateMissionDefault(ctx context.Context, agentInfoID uint) error

func (*Service) AgentDailyReport 

func (s *Service) AgentDailyReport(ctx context.Context) error

func (*Service) AgentDeployDAOToken 

func (s *Service) AgentDeployDAOToken(ctx context.Context, memeID uint) error

func (*Service) AgentDeployToken 

func (s *Service) AgentDeployToken(ctx context.Context, memeID uint) error

func (*Service) AgentMintNft 

func (s *Service) AgentMintNft(ctx context.Context, agentInfoID uint) error

func (*Service) AgentRequestTwitterShareCode 

func (s *Service) AgentRequestTwitterShareCode(ctx context.Context, topupAddress string) (string, string, error)

func (*Service) AgentSettleDAOToken 

func (s *Service) AgentSettleDAOToken(ctx context.Context, memeID uint) error

func (*Service) AgentSnapshotPostActionExecuted 

func (s *Service) AgentSnapshotPostActionExecuted(ctx context.Context, twitterPostID uint) error

func (*Service) AgentSnapshotPostCreate 

func (s *Service) AgentSnapshotPostCreate(ctx context.Context, missionID uint, orgTweetID, tokenSymbol string) error

func (*Service) AgentSnapshotPostCreateForUser 

func (s *Service) AgentSnapshotPostCreateForUser(ctx context.Context, networkID uint64, userAddress string, userPrompt string, agentBaseModel string, agentStoreMissionID uint) (*models.AgentSnapshotPost, error)

func (*Service) AgentSnapshotPostStatusInferRefund 

func (s *Service) AgentSnapshotPostStatusInferRefund(ctx context.Context, snapshotPostID uint) error

func (*Service) AgentTeleAlertByID 

func (s *Service) AgentTeleAlertByID(ctx context.Context, agentInfoID uint, refID string, amount *big.Float, networkID uint64) error

func (*Service) AgentTeleAlertNewAgentTrakerByID 

func (s *Service) AgentTeleAlertNewAgentTrakerByID(ctx context.Context, twitterInfoID uint) error

func (*Service) AgentTeleAlertNewTokenByID 

func (s *Service) AgentTeleAlertNewTokenByID(ctx context.Context, agentInfoID uint) error

func (*Service) AgentTeleAlertTopupNotActionByID 

func (s *Service) AgentTeleAlertTopupNotActionByID(ctx context.Context, agentInfoID uint) error

func (*Service) AgentTgeRefundBaseTokenMulti 

func (s *Service) AgentTgeRefundBaseTokenMulti(ctx context.Context, networkID uint64, ids []uint) error

func (*Service) AgentTgeTransferDAOTokenMulti 

func (s *Service) AgentTgeTransferDAOTokenMulti(ctx context.Context, launchpadID uint) error

func (*Service) AgentTwinTrain 

func (s *Service) AgentTwinTrain(ctx context.Context, agentInfoID uint) error

func (*Service) AgentTwitterPostCreateLaunchpad 

func (s *Service) AgentTwitterPostCreateLaunchpad(ctx context.Context, twitterPostID uint) error

func (*Service) AgentTwitterPostGenerateVideoByUserTweetId 

func (s *Service) AgentTwitterPostGenerateVideoByUserTweetId(ctx context.Context, twitterPostID uint) error

func (*Service) AgentTwitterPostSubmitVideoInferByID 

func (s *Service) AgentTwitterPostSubmitVideoInferByID(ctx context.Context, agentTwitterPostID uint) error

func (*Service) AgentUpdateAgentAssistant 

func (s *Service) AgentUpdateAgentAssistant(ctx context.Context, address string, req *serializers.AssistantsReq) (*models.AgentInfo, error)

func (*Service) AgentUpdateAgentStudio 

func (s *Service) AgentUpdateAgentStudio(ctx context.Context, address, agentID, graphData string) (*models.AgentInfo, error)

func (*Service) AgentUseKnowledgeBase 

func (s *Service) AgentUseKnowledgeBase(ctx context.Context, request *serializers.AgentUseKnowledgeBaseRequest) (*models.AgentInfoKnowledgeBase, error)

func (*Service) AgentVerifyShareTwitter 

func (s *Service) AgentVerifyShareTwitter(ctx context.Context, authSecretCode string, link string) (bool, error)

func (*Service) AgentWalletCreatePumpFunMeme 

func (s *Service) AgentWalletCreatePumpFunMeme(ctx context.Context, networkID uint64, agentContractID string, req *serializers.AdminCreatePumpfunMemeReq) error

func (*Service) AgentWalletGetSolanaTokenBalances 

func (s *Service) AgentWalletGetSolanaTokenBalances(ctx context.Context, networkID uint64, agentContractID string) ([]*serializers.SolanaTokenBalanceResp, error)

func (*Service) AgentWalletGetSolanaTokenPnls 

func (s *Service) AgentWalletGetSolanaTokenPnls(ctx context.Context, networkID uint64, agentContractID string) (any, error)

func (*Service) AgentWalletTradePumpFunMeme 

func (s *Service) AgentWalletTradePumpFunMeme(ctx context.Context, networkID uint64, agentContractID string, req *serializers.AdminTradePumpfunMemeReq) error

func (*Service) AgentWalletTradeRaydiumToken 

func (s *Service) AgentWalletTradeRaydiumToken(ctx context.Context, networkID uint64, agentContractID string, req *serializers.AdminTradePumpfunMemeReq) error

func (*Service) AnalyseSearchResults 

func (s *Service) AnalyseSearchResults(baseModel string, systemPrompt string, query string, searchedResult []string) (string, error)

func (*Service) AnalyzeAgentTwitterPostByTweetID 

func (s *Service) AnalyzeAgentTwitterPostByTweetID(tx *gorm.DB, tweetID string) error

/////////////////

func (*Service) ApproveMaxEAIForAddress 

func (s *Service) ApproveMaxEAIForAddress(
	ctx context.Context,
	networkID uint64,
	address string,
	spender string,
) (string, error)

func (*Service) BatchChatCompletionPrompt 

func (s *Service) BatchChatCompletionPrompt(ctx context.Context, request *serializers.ChatCompletionRequest) (*models.BatchInferHistory, error)

func (*Service) BatchPromptItemV2 

func (s *Service) BatchPromptItemV2(ctx context.Context, agentInfo *models.AgentInfo, request *models.AgentSnapshotPost) (*models.AgentSnapshotPost, error)

func (*Service) BlockchainDurations 

func (s *Service) BlockchainDurations(ctx context.Context) ([]uint, error)

func (*Service) CacheAgentSnapshotPost 

func (s *Service) CacheAgentSnapshotPost(snapshotPost *models.AgentSnapshotPost) error

func (*Service) CacheCheckIsTweetReplied 

func (s *Service) CacheCheckIsTweetReplied(ctx context.Context, twitterID string) (bool, error)

func (*Service) CacheListMemeThreadLatest 

func (s *Service) CacheListMemeThreadLatest(tx *gorm.DB, tokenAddress string) error

func (*Service) CacheMemeCandleDataChart 

func (s *Service) CacheMemeCandleDataChart(tx *gorm.DB, memeID uint) error

func (*Service) CacheMemeDetail 

func (s *Service) CacheMemeDetail(tx *gorm.DB, memAddress string) error

func (*Service) CacheMemeHolders 

func (s *Service) CacheMemeHolders(tx *gorm.DB, tokenAddress string) error

func (*Service) CacheMemeTradeHistoryLatest 

func (s *Service) CacheMemeTradeHistoryLatest(tx *gorm.DB, tokenAddress string) error

func (*Service) CacheMissionStoreResult 

func (s *Service) CacheMissionStoreResult(tx *gorm.DB, responseID string) error

func (*Service) CacheNotificationsLatest 

func (s *Service) CacheNotificationsLatest(tx *gorm.DB, userID uint) error

func (*Service) CalculateFunnyWeightMeme 

func (s *Service) CalculateFunnyWeightMeme(ctx context.Context, memeID uint) error

func (*Service) CaptureHtmlContentV4 

func (s *Service) CaptureHtmlContentV4(html string) (string, error)

func (*Service) ChargeUserStoreInstall 

func (s *Service) ChargeUserStoreInstall(ctx context.Context, agentStoreInstallID uint, urlPath string, status int) error

func (*Service) CheckAgentIsReadyToRunTwinTraining 

func (s *Service) CheckAgentIsReadyToRunTwinTraining(agentInfo *models.AgentInfo) (float64, bool, error)

func (*Service) CheckOwnerInscription 

func (s *Service) CheckOwnerInscription(delegate, vault, publicKey, tokenId, signature, signMessage string) bool

func (*Service) CheckOwnerNFT721 

func (s *Service) CheckOwnerNFT721(delegate, vault, contract, tokenId, signature, signMessage string) bool

func (*Service) CheckTwitterPostForTA 

func (s *Service) CheckTwitterPostForTA(tx *gorm.DB, agentInfoID uint, twitterUsername string, tweetMentions *twitter.UserTimeline) error

func (*Service) CheckedSeenMeme 

func (s *Service) CheckedSeenMeme(ctx context.Context, address, memAddress string) (bool, error)

func (*Service) ClaimFeeMisstionStore 

func (s *Service) ClaimFeeMisstionStore(ctx context.Context) error

func (*Service) CreateAPIKey 

func (s *Service) CreateAPIKey(ctx context.Context) (string, string, error)

func (*Service) CreateAgentInfoInstallCode 

func (s *Service) CreateAgentInfoInstallCode(ctx context.Context, userAddress string, agentInfoID uint) (*models.AgentInfoInstall, error)

func (*Service) CreateAgentInternalAction 

func (s *Service) CreateAgentInternalAction(ctx context.Context, req *serializers.AdminAgentActionReq) error

func (*Service) CreateAgentInternalActionByRefID 

func (s *Service) CreateAgentInternalActionByRefID(ctx context.Context, refID string, req *serializers.AdminAgentActionByRefReq) error

func (*Service) CreateAgentKnowledgeBase 

func (s *Service) CreateAgentKnowledgeBase(ctx context.Context) error

func (*Service) CreateAgentStoreInstallCode 

func (s *Service) CreateAgentStoreInstallCode(ctx context.Context, userAddress string, agentStoreID, agentInfoID uint) (*models.AgentStoreInstall, error)

func (*Service) CreateAgentTwitterPostForCreateLaunchpad 

func (s *Service) CreateAgentTwitterPostForCreateLaunchpad(tx *gorm.DB, agentInfoID uint, twitterUsername string, tweetMentions *twitter.UserTimeline) error

func (*Service) CreateAgentTwitterPostForGenerateVideo 

func (s *Service) CreateAgentTwitterPostForGenerateVideo(tx *gorm.DB, agentInfoID uint, twitterUsername string, tweetMentions *twitter.UserTimeline) error

func (*Service) CreateApiSubscriptionKeyForTest 

func (s *Service) CreateApiSubscriptionKeyForTest(ctx context.Context, address, twitterID string) (*models.ApiSubscriptionKey, error)

func (*Service) CreateApiTokenUsage 

func (s *Service) CreateApiTokenUsage(ctx context.Context, networkID uint64, apiKey string, endPoint string, numToken uint) error

func (*Service) CreateBTCAddress 

func (s *Service) CreateBTCAddress(ctx context.Context) (string, error)

func (*Service) CreateETHAddress 

func (s *Service) CreateETHAddress(ctx context.Context) (string, error)

func (*Service) CreateErc1155TransferEvent 

func (s *Service) CreateErc1155TransferEvent(ctx context.Context, networkID uint64, changeBalance map[string]bool) error

func (*Service) CreateErc20TokenTransferEvent 

func (s *Service) CreateErc20TokenTransferEvent(ctx context.Context, networkID uint64, event *ethapi.Erc20TokenTransferEventResp) error

func (*Service) CreateErc20TokenTransferEventLaunchpad 

func (s *Service) CreateErc20TokenTransferEventLaunchpad(ctx context.Context, networkID uint64, event *ethapi.Erc20TokenTransferEventResp) error

func (*Service) CreateErc20TransferEvent 

func (s *Service) CreateErc20TransferEvent(ctx context.Context, networkID uint64, changeBalance map[string]bool) error

func (*Service) CreateErc721TransferEvent 

func (s *Service) CreateErc721TransferEvent(ctx context.Context, event *ethapi.NftTransferEventResp) error

func (*Service) CreateMeme 

func (s *Service) CreateMeme(ctx context.Context, address string, networkID uint64, req *serializers.MemeReq) (*models.Meme, error)

func (*Service) CreateMemeNotifications 

func (s *Service) CreateMemeNotifications(tx *gorm.DB, userID, memeID, followerID uint, notiType models.NotiType, eventID string) error

func (*Service) CreateMemePool 

func (s *Service) CreateMemePool(ctx context.Context, networkID uint64, event *ethapi.UniswapPoolCreatedEventResp, syncInfo bool) error

func (*Service) CreateMemeShareTradeHistory 

func (s *Service) CreateMemeShareTradeHistory(ctx context.Context, networkID uint64, event *agentshares.AgentSharesTrade) error

func (*Service) CreateMemeThread 

func (s *Service) CreateMemeThread(ctx context.Context, address string, req *serializers.MemeThreadReq) (*models.MemeThreads, error)

func (*Service) CreateMemeTradeHistory 

func (s *Service) CreateMemeTradeHistory(ctx context.Context, event *ethapi.UniswapSwapEventResp) error

func (*Service) CreateOrUpdateTokenPrice 

func (s *Service) CreateOrUpdateTokenPrice(ctx context.Context, symbol string, price numeric.BigFloat) error

func (*Service) CreateSOLAddress 

func (s *Service) CreateSOLAddress(ctx context.Context) (string, error)

func (*Service) CreateSolanaTokenTransferEvent 

func (s *Service) CreateSolanaTokenTransferEvent(ctx context.Context, networkID uint64, event *bridgeapi.SolanaEAITxResp) error

func (*Service) CreateTRONAddress 

func (s *Service) CreateTRONAddress(ctx context.Context) (string, error)

func (*Service) CreateTokenInfo 

func (s *Service) CreateTokenInfo(ctx context.Context, agentID uint) error

func (*Service) CreateUpdateAgentSnapshotMission 

func (s *Service) CreateUpdateAgentSnapshotMission(ctx context.Context, agentID string, authHeader string, req []*serializers.AgentSnapshotMissionInfo) (*models.AgentInfo, error)

func (*Service) CreateUpdateUserTwitter 

func (s *Service) CreateUpdateUserTwitter(tx *gorm.DB, userTwitterID string) (*models.TwitterUser, error)

func (*Service) CreateUpdateUserTwitterByUserName 

func (s *Service) CreateUpdateUserTwitterByUserName(tx *gorm.DB, username string) (*models.TwitterUser, error)

func (*Service) DeleteAgentSnapshotMission 

func (s *Service) DeleteAgentSnapshotMission(ctx context.Context, missionID uint, userAddress string) (bool, error)

func (*Service) DeleteFilterAddrs 

func (s *Service) DeleteFilterAddrs(ctx context.Context, networkID uint64) error

func (*Service) DeleteRedisCachedWithKey 

func (s *Service) DeleteRedisCachedWithKey(cachedKey string) error

func (*Service) DeleteRedisCachedWithPrefix 

func (s *Service) DeleteRedisCachedWithPrefix(cachedKey string) error

func (*Service) DeployAgentKnowledgeBase 

func (s *Service) DeployAgentKnowledgeBase(ctx context.Context, info *models.KnowledgeBase) error

func (*Service) DeployAgentUpgradeable 

func (s *Service) DeployAgentUpgradeable(ctx context.Context, agentInfoID uint) error

func (*Service) DeployAgentUpgradeableAddress 

func (s *Service) DeployAgentUpgradeableAddress(
	ctx context.Context,
	networkID uint64,
	agentName string,
	agentVersion string,
	codeLanguage string,
	pointers []agentupgradeable.IAgentCodePointer,
	depsAgents []common.Address,
	agentOwner common.Address,
	isOnchain bool,
) (string, string, string, error)

func (*Service) DeployDAOTreasuryAddress 

func (s *Service) DeployDAOTreasuryAddress(ctx context.Context, networkID uint64) (string, error)

func (*Service) DeployDAOTreasuryLogic 

func (s *Service) DeployDAOTreasuryLogic(ctx context.Context, networkID uint64) (string, error)

func (*Service) DeployMultisend 

func (s *Service) DeployMultisend(ctx context.Context, networkID uint64) (string, error)

func (*Service) DeployProxyAdminAddress 

func (s *Service) DeployProxyAdminAddress(
	ctx context.Context,
	networkID uint64,
) (string, string, error)

func (*Service) DexPairsTradeLatest 

func (s *Service) DexPairsTradeLatest(ctx context.Context, contractAddress, networkSlug string) (*coinmarketcap.DexPairsTradeLatestResp, error)

func (*Service) DexScreenInfo 

func (s *Service) DexScreenInfo(ctx context.Context, contractAddress string) (interface{}, error)

func (*Service) DexSpotPairsLatest 

func (s *Service) DexSpotPairsLatest(ctx context.Context, quoteAssetSymbol, networkSlug string) (*coinmarketcap.DexSpotPairsLatestResp, error)

func (*Service) DisableJobs 

func (s *Service) DisableJobs()

func (*Service) ERC20RealWorldAgentAct 

func (s *Service) ERC20RealWorldAgentAct(
	ctx context.Context,
	uuid string,
	ipfsHash string,
) (string, error)

func (*Service) ERC20UtilityAgentFetchCode 

func (s *Service) ERC20UtilityAgentFetchCode(
	ctx context.Context,
	networkID uint64,
	contractAddress string,
) (string, error)

func (*Service) ERC20UtilityAgentGetStorageInfo 

func (s *Service) ERC20UtilityAgentGetStorageInfo(
	ctx context.Context,
	networkID uint64,
	contractAddress string,
) (*erc20utilityagent.IUtilityAgentStorageInfo, error)

func (*Service) ErcTransferEventsByTransactionV2 

func (s *Service) ErcTransferEventsByTransactionV2(ctx context.Context, networkID uint64, eventResp *ethapi.BlockChainEventResp) error

func (*Service) ExecuteLaunchpadTier 

func (s *Service) ExecuteLaunchpadTier(ctx context.Context, launchpadID, memberID uint, req *serializers.TierReq) error

func (*Service) ExecuteUpdateAgentInfoInContract 

func (s *Service) ExecuteUpdateAgentInfoInContract(ctx context.Context, assistant *models.AgentInfo, request *serializers.UpdateAgentAssistantInContractRequest) (*serializers.UpdateAgentAssistantInContractResponse, error)

func (*Service) ExternalWalletBalances 

func (s *Service) ExternalWalletBalances(ctx context.Context, apiKey string) ([]*serializers.SolanaTokenBalanceResp, error)

func (*Service) ExternalWalletComputeOrder 

func (s *Service) ExternalWalletComputeOrder(ctx context.Context, apiKey string, req *serializers.ExternalWalletOrderReq) (float64, error)

func (*Service) ExternalWalletCreateOrder 

func (s *Service) ExternalWalletCreateOrder(ctx context.Context, apiKey string, req *serializers.ExternalWalletOrderReq) (*models.ExternalWalletOrder, error)

func (*Service) ExternalWalletCreateSOL 

func (s *Service) ExternalWalletCreateSOL(ctx context.Context) (*serializers.ExternalWalletResp, error)

func (*Service) ExternalWalletGet 

func (s *Service) ExternalWalletGet(ctx context.Context, apiKey string) (*serializers.ExternalWalletResp, error)

func (*Service) ExternalWalletGetOrders 

func (s *Service) ExternalWalletGetOrders(ctx context.Context, apiKey string, page int, limit int) ([]*models.ExternalWalletOrder, error)

func (*Service) ExternalWalletGetTokens 

func (s *Service) ExternalWalletGetTokens(ctx context.Context, apiKey string) ([]*models.ExternalWalletToken, error)

func (*Service) ExtractSolAddress 

func (s *Service) ExtractSolAddress(content string) string

func (*Service) FindAgenByTwitterUsername 

func (s *Service) FindAgenByTwitterUsername(ctx context.Context, twitterUsername string) (*models.AgentInfo, error)

func (*Service) FindAgentSnapshotMission 

func (s *Service) FindAgentSnapshotMission(ctx context.Context, agentId uint) ([]*models.AgentSnapshotMission, error)

func (*Service) FindAgentSnapshotPostAction 

func (s *Service) FindAgentSnapshotPostAction(ctx context.Context, agentId uint) ([]*models.AgentSnapshotPostAction, error)

func (*Service) FollowListDefaultTwitters 

func (s *Service) FollowListDefaultTwitters(ctx context.Context, agentID uint) error

func (*Service) FollowUsers 

func (s *Service) FollowUsers(ctx context.Context, address string, req *serializers.MemeThreadReq) (bool, error)

func (*Service) GeUserByAddress 

func (s *Service) GeUserByAddress(ctx context.Context, networkID uint64, address string) (*models.User, error)

func (*Service) GenerateAPIKey 

func (s *Service) GenerateAPIKey() (string, error)

func (*Service) GenerateKnowledgeQuery 

func (s *Service) GenerateKnowledgeQuery(baseModel string, histories []openai2.ChatCompletionMessage) (*string, error, string)

func (*Service) GenerateMemeStory 

func (s *Service) GenerateMemeStory(ctx context.Context, memeName string) (string, error)

func (*Service) GenerateTipAddress 

func (s *Service) GenerateTipAddress(ctx context.Context, agentInfoID uint) error

func (*Service) GenerateTokenImageBase64Gif 

func (s *Service) GenerateTokenImageBase64Gif(ctx context.Context, tokenSymbol, tokenName, tokenDesc string) string

func (*Service) GenerateTokenInfoFromSystemPrompt 

func (s *Service) GenerateTokenInfoFromSystemPrompt(ctx context.Context, tokenName, sysPrompt string) (*models.TweetParseInfo, error)

func (*Service) GetAddressPrk 

func (s *Service) GetAddressPrk(address string) string

func (*Service) GetAgentBrainHistory 

func (s *Service) GetAgentBrainHistory(ctx context.Context, agentID string, postID uint, page, limit int) ([]*models.AgentSnapshotPost, uint, error)

/brains

func (*Service) GetAgentChainFee 

func (s *Service) GetAgentChainFee(tx *gorm.DB, networkID uint64) (*models.AgentChainFee, error)

func (*Service) GetAgentChainFees 

func (s *Service) GetAgentChainFees(ctx context.Context) (map[string]interface{}, error)

func (*Service) GetAgentCreateLaunchpad 

func (s *Service) GetAgentCreateLaunchpad(ctx context.Context, userName, fullText string) (*models.TweetParseInfo, error)

func (*Service) GetAgentInfoDetail 

func (s *Service) GetAgentInfoDetail(ctx context.Context, networkID uint64, agentID string) (*models.AgentInfo, error)

func (*Service) GetAgentInfoDetailByAgentID 

func (s *Service) GetAgentInfoDetailByAgentID(ctx context.Context, agentID string) (*models.AgentInfo, error)

func (*Service) GetAgentInfoDetailByContract 

func (s *Service) GetAgentInfoDetailByContract(ctx context.Context, networkID uint64, agentContractID, agentContractAddress string) (*models.AgentInfo, error)

func (*Service) GetAgentInfoInstall 

func (s *Service) GetAgentInfoInstall(ctx context.Context, code string) (*models.AgentInfoInstall, error)

func (*Service) GetAgentSnapshotMissionConfigs 

func (s *Service) GetAgentSnapshotMissionConfigs(ctx context.Context, networkID uint64, platform string) ([]*models.AgentSnapshotMissionConfigs, error)

func (*Service) GetAgentSnapshotMissionTokens 

func (s *Service) GetAgentSnapshotMissionTokens(ctx context.Context) ([]configs.MissionTokensConfig, error)

func (*Service) GetAgentStore 

func (s *Service) GetAgentStore(ctx context.Context, storeId string) (*models.AgentStore, error)

func (*Service) GetAgentStoreDetail 

func (s *Service) GetAgentStoreDetail(ctx context.Context, id uint) (*models.AgentStore, error)

func (*Service) GetAgentStoreInstall 

func (s *Service) GetAgentStoreInstall(ctx context.Context, code string) (*models.AgentStoreInstall, error)

func (*Service) GetAgentSummaryReport 

func (s *Service) GetAgentSummaryReport(ctx context.Context) ([]*models.AgentInfo, error)

func (*Service) GetAgentTokenInfoFromContractAddress 

func (s *Service) GetAgentTokenInfoFromContractAddress(ctx context.Context, tokenAddress string) (string, string, error)

func (*Service) GetAgentTradeTokens 

func (s *Service) GetAgentTradeTokens(ctx context.Context, networkID uint64) ([]*models.AgentTradeToken, error)

func (*Service) GetAgentTwitterPostDetail 

func (s *Service) GetAgentTwitterPostDetail(ctx context.Context, postID uint) (*models.AgentTwitterPost, error)

func (*Service) GetAgentWallet 

func (s *Service) GetAgentWallet(tx *gorm.DB, networkID uint64, agentInfoID uint) (*models.AgentWallet, error)

func (*Service) GetAgentWalletSolanaTrades 

func (s *Service) GetAgentWalletSolanaTrades(ctx context.Context, networkID uint64, agentContractID string, mint string, page int, limit int) ([]*serializers.WalletActionTradeResp, error)

func (*Service) GetAllConfigs 

func (s *Service) GetAllConfigs(ctx context.Context) (map[uint64]map[string]string, error)

func (*Service) GetAllConfigsExplorer 

func (s *Service) GetAllConfigsExplorer(ctx context.Context) (map[uint64]string, error)

func (*Service) GetAllUserMentionsByUsername 

func (s *Service) GetAllUserMentionsByUsername(ctx context.Context, username, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetAllUserTweetsFromTwitterInfoToken 

func (s *Service) GetAllUserTweetsFromTwitterInfoToken(ctx context.Context, twitterInfo *models.TwitterInfo, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetApiKeyInfo 

func (s *Service) GetApiKeyInfo(ctx context.Context, apiKey string, address string) ([]*models.ApiSubscriptionKey, error)

func (*Service) GetApiPackages 

func (s *Service) GetApiPackages(ctx context.Context) ([]*models.ApiSubscriptionPackage, error)

func (*Service) GetApiUsage 

func (s *Service) GetApiUsage(ctx context.Context, apiKey string, page, limit int) ([]*models.ApiSubscriptionUsageLog, uint, error)

func (*Service) GetBatchItemDetail 

func (s *Service) GetBatchItemDetail(ctx context.Context, id uint) (*models.BatchInferHistory, error)

func (*Service) GetBrainDetailByTweetID 

func (s *Service) GetBrainDetailByTweetID(ctx context.Context, tweetID string) (*models.AgentSnapshotPost, error)

func (*Service) GetBrainDetailByTweetIDBK 

func (s *Service) GetBrainDetailByTweetIDBK(ctx context.Context, tweetID string) (*models.AgentSnapshotPost, error)

func (*Service) GetChartImage 

func (s *Service) GetChartImage(ctx context.Context, symbol string) (string, error)

func (*Service) GetConversationIdByTweetID 

func (s *Service) GetConversationIdByTweetID(tx *gorm.DB, tweetID string) string

func (*Service) GetDao 

func (s *Service) GetDao() *daos.DAO

func (*Service) GetDashboardAgentInfos 

func (s *Service) GetDashboardAgentInfos(ctx context.Context, networkID uint64, agentType int, agentTypes []int, tokenAddress, search, agentModel string, sortListStr []string, page, limit int) ([]*models.AgentInfo, uint, error)

func (*Service) GetEVMClient 

func (s *Service) GetEVMClient(ctx context.Context, networkID uint64) evmapi.BaseClient

func (*Service) GetEstimateTime 

func (s *Service) GetEstimateTime(ctx context.Context, agentInfo *models.AgentInfo) (*time.Time, error)

func (*Service) GetEthereumClient 

func (s *Service) GetEthereumClient(ctx context.Context, networkID uint64) *ethapi.Client

func (*Service) GetExtractDataFromPost 

func (s *Service) GetExtractDataFromPost(content string) (string, error)

func (*Service) GetFeedMemeReport 

func (s *Service) GetFeedMemeReport(ctx context.Context, address, search, sortType string, page, limit int) ([]*models.Meme, uint, error)

//////Feed API

func (*Service) GetFilterAddrs 

func (s *Service) GetFilterAddrs(ctx context.Context, networkID uint64) ([]string, error)

func (*Service) GetGifImageUrlFromTokenInfo 

func (s *Service) GetGifImageUrlFromTokenInfo(tokenSymbol, tokenName, tokenDesc string) (string, error)

func (*Service) GetImageUrlForBase64 

func (s *Service) GetImageUrlForBase64(stringBase64 string) (string, error)

func (*Service) GetInscriptonCollections 

func (s *Service) GetInscriptonCollections(ctx context.Context, f opensea.OpenSeaFilterCollections) (*opensea.CollectionsResp, error)

func (*Service) GetInscriptonInfo 

func (s *Service) GetInscriptonInfo(ctx context.Context, address string, f opensea.OpenSeaFilterCollections) (*moralis.NFTCollectionMetadata, error)

func (*Service) GetInscriptonInfoByTokenID 

func (s *Service) GetInscriptonInfoByTokenID(ctx context.Context, address, tokenId string, f opensea.OpenSeaFilterCollections) ([]moralis.MoralisToken, error)

func (*Service) GetJobDuration 

func (s *Service) GetJobDuration(durationUnit string) time.Duration

func (*Service) GetListAgentEaiTopup 

func (s *Service) GetListAgentEaiTopup(ctx context.Context, agentID string, typeStr string, page, limit int) ([]*models.AgentEaiTopup, uint, error)

func (*Service) GetListAgentInfos 

func (s *Service) GetListAgentInfos(ctx context.Context, networkID uint64, creator string, agentTypes []uint, kbStatus int64, keyword string, page, limit int) ([]*models.AgentInfo, uint, error)

func (*Service) GetListAgentLibrary 

func (s *Service) GetListAgentLibrary(ctx context.Context, networkID uint64) ([]*models.AgentLibrary, error)

func (*Service) GetListAgentStore 

func (s *Service) GetListAgentStore(ctx context.Context, search, types string, page, limit int) ([]*models.AgentStore, uint, error)

func (*Service) GetListAgentStoreByOwner 

func (s *Service) GetListAgentStoreByOwner(ctx context.Context, userAddress string, page, limit int) ([]*models.AgentStore, uint, error)

func (*Service) GetListAgentStoreInstall 

func (s *Service) GetListAgentStoreInstall(ctx context.Context, userAddress string, agentInfoID uint, page, limit int) ([]*models.AgentStoreInstall, uint, error)

func (*Service) GetListAgentTwitterLatestPost 

func (s *Service) GetListAgentTwitterLatestPost(
	ctx context.Context,
	networkID uint64,
	agentInfoIDs []uint,
	page, limit int,
) (map[uint]*models.AgentTwitterPost, error)

func (*Service) GetListAgentTwitterPost 

func (s *Service) GetListAgentTwitterPost(ctx context.Context, networkID uint64, page, limit int) ([]*models.AgentTwitterPost, uint, error)

func (*Service) GetListAgentUnClaimed 

func (s *Service) GetListAgentUnClaimed(ctx context.Context, search string, page, limit int) ([]*models.AgentInfo, uint, error)

func (*Service) GetListFollowers 

func (s *Service) GetListFollowers(ctx context.Context, userAddress string, page, limit int) ([]*models.MemeFollowers, uint, error)

func (*Service) GetListFollowings 

func (s *Service) GetListFollowings(ctx context.Context, userAddress string, page, limit int) ([]*models.MemeFollowers, uint, error)

func (*Service) GetListMemeReport 

func (s *Service) GetListMemeReport(ctx context.Context, chainID uint64,
	address, search, status string, following bool,
	sortListStr []string, page, limit int,
) ([]*models.Meme, uint, error)

func (*Service) GetListMemeThread 

func (s *Service) GetListMemeThread(ctx context.Context, userAddress, tokenAddress string, page, limit int) ([]*models.MemeThreads, uint, error)

func (*Service) GetListMemeThreadLatest 

func (s *Service) GetListMemeThreadLatest(ctx context.Context, tokenAddress string) (string, error)

func (*Service) GetListMemes 

func (s *Service) GetListMemes(ctx context.Context, address string, page, limit int) ([]*models.Meme, uint, error)

func (*Service) GetListMisstionStore 

func (s *Service) GetListMisstionStore(ctx context.Context, search string, page, limit int) ([]*models.MissionStore, uint, error)

func (*Service) GetListUserMentions 

func (s *Service) GetListUserMentions(ctx context.Context, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserMentionsByUsername 

func (s *Service) GetListUserMentionsByUsername(ctx context.Context, username, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTransactions 

func (s *Service) GetListUserTransactions(ctx context.Context, userAddress string, typeStr string, page, limit int) ([]*models.UserTransaction, uint, error)

func (*Service) GetListUserTweets 

func (s *Service) GetListUserTweets(ctx context.Context, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsAll 

func (s *Service) GetListUserTweetsAll(ctx context.Context, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsByAgentForTradeMission 

func (s *Service) GetListUserTweetsByAgentForTradeMission(ctx context.Context, refID string) ([]twitter.TweetObj, error)

func (*Service) GetListUserTweetsByUsername 

func (s *Service) GetListUserTweetsByUsername(ctx context.Context, username, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsByUsernameV1 

func (s *Service) GetListUserTweetsByUsernameV1(ctx context.Context, username, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsByUsersForTradeMission 

func (s *Service) GetListUserTweetsByUsersForTradeMission(ctx context.Context, userTwitterIds string) ([]twitter.TweetObj, error)

func (*Service) GetListUserTweetsFromTwitterInfoToken 

func (s *Service) GetListUserTweetsFromTwitterInfoToken(ctx context.Context, twitterInfo *models.TwitterInfo, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsFromTwitterInfoTokenV1 

func (s *Service) GetListUserTweetsFromTwitterInfoTokenV1(ctx context.Context, twitterInfo *models.TwitterInfo, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetListUserTweetsV1 

func (s *Service) GetListUserTweetsV1(ctx context.Context, twitterID, paginationToken string, maxResults int) (*twitter.UserTimeline, error)

func (*Service) GetMapAgentSnapshotMissionTokens 

func (s *Service) GetMapAgentSnapshotMissionTokens(ctx context.Context) (map[string]configs.MissionTokensConfig, error)

func (*Service) GetMapTokenPrice 

func (s *Service) GetMapTokenPrice(ctx context.Context) map[string]*big.Float

func (*Service) GetMemeBaseToken 

func (s *Service) GetMemeBaseToken(tx *gorm.DB, networkID uint64, baseSymbol string) string

func (*Service) GetMemeBaseTokenByTokens01 

func (s *Service) GetMemeBaseTokenByTokens01(tx *gorm.DB, networkID uint64, token0, token1 string) string

func (*Service) GetMemeBurnHistory 

func (s *Service) GetMemeBurnHistory(ctx context.Context, networkID uint64, userAddress, tokenAddress string, page, limit int) ([]*models.TokenTransfer, uint, error)

func (*Service) GetMemeChartCandleData 

func (s *Service) GetMemeChartCandleData(ctx context.Context, tokenAddress string, day uint, chartType string) (string, error)

func (*Service) GetMemeDetail 

func (s *Service) GetMemeDetail(ctx context.Context, address, memAddress string) (string, error)

func (*Service) GetMemeNotificationLatest 

func (s *Service) GetMemeNotificationLatest(ctx context.Context, userAddress string) (string, error)

func (*Service) GetMemeNotifications 

func (s *Service) GetMemeNotifications(ctx context.Context, userAddress string, page, limit int) ([]*models.MemeNotification, uint, error)

/

func (*Service) GetMemeTradeHistory 

func (s *Service) GetMemeTradeHistory(ctx context.Context, userAddress, tokenAddress string, page, limit int) ([]*models.MemeTradeHistory, uint, error)

func (*Service) GetMemeTradeHistoryLatest 

func (s *Service) GetMemeTradeHistoryLatest(ctx context.Context, tokenAddress string) (string, error)

func (*Service) GetMemeUserProfile 

func (s *Service) GetMemeUserProfile(ctx context.Context, networkID uint64, address string) (*models.User, error)

/////Users

func (*Service) GetMemeWhiteListAddress 

func (s *Service) GetMemeWhiteListAddress(ctx context.Context) ([]string, error)

func (*Service) GetMissionStoreHistory 

func (s *Service) GetMissionStoreHistory(ctx context.Context, id uint, page, limit int) ([]*models.MissionStoreHistory, uint, error)

func (*Service) GetMissionStoreRating 

func (s *Service) GetMissionStoreRating(ctx context.Context, id uint, page, limit int) ([]*models.MissionStoreRating, uint, error)

func (*Service) GetMissionStoreResult 

func (s *Service) GetMissionStoreResult(ctx context.Context, userAddress string, responseID string) (string, error)

func (*Service) GetMisstionStoreDetail 

func (s *Service) GetMisstionStoreDetail(ctx context.Context, id uint) (*models.MissionStore, error)

func (*Service) GetModelDefaultByChainID 

func (s *Service) GetModelDefaultByChainID(chainID uint64) string

func (*Service) GetNftCollectionMetadataByContract 

func (s *Service) GetNftCollectionMetadataByContract(ctx context.Context, address, cursor, pageSize string, f moralis.MoralisFilter) (*moralis.NFTCollectionMetadata, error)

func (*Service) GetNftCollectionMetadataByTokenID 

func (s *Service) GetNftCollectionMetadataByTokenID(ctx context.Context, address, tokenID string, f moralis.MoralisFilter) ([]moralis.MoralisToken, error)

func (*Service) GetPostTimeByTweetID 

func (s *Service) GetPostTimeByTweetID(tx *gorm.DB, tweetID string) *time.Time

func (*Service) GetPumpFunTokenPrice 

func (s *Service) GetPumpFunTokenPrice(ctx context.Context, mint string) (float64, error)

func (*Service) GetPumpFunTrades 

func (s *Service) GetPumpFunTrades(ctx context.Context, mint string, page int, limit int) ([]*serializers.PumpFunTradeResp, error)

func (*Service) GetRedisCachedWithKey 

func (s *Service) GetRedisCachedWithKey(cachedKey string, resp interface{}) error

func (*Service) GetResultFromRagSearch 

func (s *Service) GetResultFromRagSearch(request *serializers.RetrieveKnowledgeBaseRequest) (*serializers.RetrieveKnowledgeBaseResponse, error)

func (*Service) GetResultFromToolCall 

func (s *Service) GetResultFromToolCall(query string) (string, error)

func (*Service) GetSolanaDataChart24Hour 

func (s *Service) GetSolanaDataChart24Hour(ctx context.Context, mint string) ([]*serializers.DataChartResp, error)

func (*Service) GetSolanaTokenDecimals 

func (s *Service) GetSolanaTokenDecimals(mint string) (int, error)

func (*Service) GetTokenHolders 

func (s *Service) GetTokenHolders(ctx context.Context, tokenAddress string) (string, error)

func (*Service) GetTokenHolding 

func (s *Service) GetTokenHolding(ctx context.Context, userAddress string, page, limit int) ([]*models.Erc20Holder, uint, error)

func (*Service) GetTokenInfoByContract 

func (s *Service) GetTokenInfoByContract(ctx context.Context, tokenAddress string) (*dexscreener.PairsDetailResp, error)

func (*Service) GetTokenMarketPrice 

func (s *Service) GetTokenMarketPrice(tx *gorm.DB, symbol string) *big.Float

func (*Service) GetTokenQuoteLatestForSolana 

func (s *Service) GetTokenQuoteLatestForSolana(ctx context.Context, mint string) (any, error)

func (*Service) GetTradeAnalytic 

func (s *Service) GetTradeAnalytic(ctx context.Context, token string) (interface{}, error)

func (*Service) GetTradingAnalyticInfo 

func (s *Service) GetTradingAnalyticInfo(ctx context.Context, userName, fullText string) (*models.TweetParseInfo, error)

func (*Service) GetTryHistory 

func (s *Service) GetTryHistory(ctx context.Context, userAddress string, agentStoreID uint) (*models.AgentStoreTry, error)

func (*Service) GetTryHistoryDetail 

func (s *Service) GetTryHistoryDetail(ctx context.Context, userAddress string, historyID uint, page, limit int) ([]*models.AgentStoreTryDetail, error)

func (*Service) GetTwitterPostMaxChars 

func (s *Service) GetTwitterPostMaxChars(tx *gorm.DB, agentInfoID uint) (uint, error)

func (*Service) GetTwitterUserByID 

func (s *Service) GetTwitterUserByID(ctx context.Context, twitterID string) (*twitter.UserObj, error)

func (*Service) GetTwitterUserByUsername 

func (s *Service) GetTwitterUserByUsername(ctx context.Context, username string) (*twitter.UserObj, error)

func (*Service) GetTwitterUserFollowing 

func (s *Service) GetTwitterUserFollowing(ctx context.Context, twitterID, paginationToken string) (*twitter.UserFollowLookup, error)

func (*Service) GetTwitterUserFollowingByUsername 

func (s *Service) GetTwitterUserFollowingByUsername(ctx context.Context, username, paginationToken string) ([]rapid.Following, error)

func (*Service) GetTwitterUserFollowingRapid 

func (s *Service) GetTwitterUserFollowingRapid(ctx context.Context, twitterID, paginationToken string) ([]rapid.Following, error)

func (*Service) GetTwitterUserFollowingRapidByUsername 

func (s *Service) GetTwitterUserFollowingRapidByUsername(ctx context.Context, username, paginationToken string) ([]rapid.Following, error)

func (*Service) GetTwitterUserFollowingV1 

func (s *Service) GetTwitterUserFollowingV1(ctx context.Context, twitterID, paginationToken string) ([]rapid.Following, error)

func (*Service) GetTwitterVerified 

func (s *Service) GetTwitterVerified(tx *gorm.DB, agentInfoID uint) (bool, error)

func (*Service) GetUser 

func (s *Service) GetUser(tx *gorm.DB, networkID uint64, address string, forUpdate bool) (*models.User, error)

func (*Service) GetUser3700Liked 

func (s *Service) GetUser3700Liked(ctx context.Context, replied *bool, page, limit int) ([]*models.TwitterTweetLiked, error)

func (*Service) GetUserProfile 

func (s *Service) GetUserProfile(ctx context.Context, address string) (*models.User, error)

func (*Service) GetWebpageText 

func (s *Service) GetWebpageText(ctx context.Context, url string) (string, error)

func (*Service) GetZkClient 

func (s *Service) GetZkClient(ctx context.Context, networkID uint64) *zkapi.Client

func (*Service) HideMemeThread 

func (s *Service) HideMemeThread(ctx context.Context, address string, threadID uint) (bool, error)

func (*Service) ImageHubSubscriptionPriceUpdatedEvent 

func (s *Service) ImageHubSubscriptionPriceUpdatedEvent(ctx context.Context, networkID uint64, event *ethapi.ImageHubSubscriptionPriceUpdated) error

func (*Service) InfraTwitterAppAuthenCallback 

func (s *Service) InfraTwitterAppAuthenCallback(ctx context.Context, address, installUri string, code string) (string, error)

func (*Service) InfraTwitterAppAuthenInstall 

func (s *Service) InfraTwitterAppAuthenInstall(ctx context.Context, userAddress string) (string, error)

func (*Service) InscribeTxsLog 

func (s *Service) InscribeTxsLog(txHash string, inscribeTxHash string, logErr string)

func (*Service) IpfsUploadData 

func (s *Service) IpfsUploadData(ctx context.Context, ext string, dataBytes []byte) (string, error)

func (*Service) IpfsUploadDataForName 

func (s *Service) IpfsUploadDataForName(ctx context.Context, fileName string, dataBytes []byte) (string, error)

func (*Service) JobAgentAddLiquidityDAOToken 

func (s *Service) JobAgentAddLiquidityDAOToken(ctx context.Context) error

func (*Service) JobAgentDeployDAOToken 

func (s *Service) JobAgentDeployDAOToken(ctx context.Context) error

func (*Service) JobAgentDeployToken 

func (s *Service) JobAgentDeployToken(ctx context.Context) error

func (*Service) JobAgentLaunchpadEnd 

func (s *Service) JobAgentLaunchpadEnd(ctx context.Context) error

func (*Service) JobAgentMintNft 

func (s *Service) JobAgentMintNft(ctx context.Context) error

func (*Service) JobAgentSettleDAOToken 

func (s *Service) JobAgentSettleDAOToken(ctx context.Context) error

func (*Service) JobAgentSnapshotPostActionCancelled 

func (s *Service) JobAgentSnapshotPostActionCancelled(ctx context.Context) error

func (*Service) JobAgentSnapshotPostActionDupplicated 

func (s *Service) JobAgentSnapshotPostActionDupplicated(ctx context.Context) error

func (*Service) JobAgentSnapshotPostActionExecuted 

func (s *Service) JobAgentSnapshotPostActionExecuted(ctx context.Context) error

func (*Service) JobAgentSnapshotPostCreate 

func (s *Service) JobAgentSnapshotPostCreate(ctx context.Context) error

func (*Service) JobAgentSnapshotPostStatusInferRefund 

func (s *Service) JobAgentSnapshotPostStatusInferRefund(ctx context.Context) error

func (*Service) JobAgentStart 

func (s *Service) JobAgentStart(ctx context.Context) error

func (*Service) JobAgentTeleAlertTopupNotAction 

func (s *Service) JobAgentTeleAlertTopupNotAction(ctx context.Context) error

func (*Service) JobAgentTgeRefundBaseToken 

func (s *Service) JobAgentTgeRefundBaseToken(ctx context.Context) error

func (*Service) JobAgentTgeTransferDAOToken 

func (s *Service) JobAgentTgeTransferDAOToken(ctx context.Context) error

func (*Service) JobAgentTwinTrain 

func (s *Service) JobAgentTwinTrain(ctx context.Context) error

func (*Service) JobAgentTwitterPostCreateLaunchpad 

func (s *Service) JobAgentTwitterPostCreateLaunchpad(ctx context.Context) error

func (*Service) JobAgentTwitterPostGenerateVideo 

func (s *Service) JobAgentTwitterPostGenerateVideo(ctx context.Context) error

func (*Service) JobAgentTwitterPostSubmitVideoInfer 

func (s *Service) JobAgentTwitterPostSubmitVideoInfer(ctx context.Context) error

func (*Service) JobAgentTwitterPostTA 

func (s *Service) JobAgentTwitterPostTA(ctx context.Context) error

func (*Service) JobAgentTwitterScanResultGenerateVideo 

func (s *Service) JobAgentTwitterScanResultGenerateVideo(ctx context.Context) error

func (*Service) JobCheckMemeReachMarketCap 

func (s *Service) JobCheckMemeReachMarketCap(ctx context.Context) error

func (*Service) JobCreateAgentKnowledgeBase 

func (s *Service) JobCreateAgentKnowledgeBase(ctx context.Context) error

func (*Service) JobCreateTokenInfo 

func (s *Service) JobCreateTokenInfo(ctx context.Context) error

func (*Service) JobEnabledDB 

func (s *Service) JobEnabledDB(ctx context.Context) error

func (*Service) JobLuckyMoneyActionExecuted 

func (s *Service) JobLuckyMoneyActionExecuted(ctx context.Context) error

func (*Service) JobLuckyMoneyCollectPost 

func (s *Service) JobLuckyMoneyCollectPost(ctx context.Context) error

func (*Service) JobLuckyMoneyProcessUserReward 

func (s *Service) JobLuckyMoneyProcessUserReward(ctx context.Context) error

func (*Service) JobMemeAddPositionInternal 

func (s *Service) JobMemeAddPositionInternal(ctx context.Context) error

func (*Service) JobMemeAddPositionUniswap 

func (s *Service) JobMemeAddPositionUniswap(ctx context.Context) error

func (*Service) JobMemeBurnPositionUniswap 

func (s *Service) JobMemeBurnPositionUniswap(ctx context.Context) error

func (*Service) JobMemeRemovePositionInternal 

func (s *Service) JobMemeRemovePositionInternal(ctx context.Context) error

func (*Service) JobMigrateTronAddress 

func (s *Service) JobMigrateTronAddress(ctx context.Context) error

func (*Service) JobMigrateWalletActions 

func (s *Service) JobMigrateWalletActions(ctx context.Context) error

func (*Service) JobNameSubmitBatchInferFullPrompt 

func (s *Service) JobNameSubmitBatchInferFullPrompt(ctx context.Context, chainConfig *models.ChainConfig) string

func (*Service) JobRetryAddPool1 

func (s *Service) JobRetryAddPool1(ctx context.Context) error

func (*Service) JobRetryAddPool2 

func (s *Service) JobRetryAddPool2(ctx context.Context) error

func (*Service) JobRetryAgentDeployToken 

func (s *Service) JobRetryAgentDeployToken(ctx context.Context) error

func (*Service) JobRetryAgentMintNft 

func (s *Service) JobRetryAgentMintNft(ctx context.Context) error

func (*Service) JobRetryAgentMintNftError 

func (s *Service) JobRetryAgentMintNftError(ctx context.Context) error

func (*Service) JobRun 

func (s *Service) JobRun(ctx context.Context, jobName string, duration time.Duration, jobFunc func() error)

func (*Service) JobRunCheck 

func (s *Service) JobRunCheck(ctx context.Context, jobId string, jobFunc func() error) error

func (*Service) JobScanAgentTwitterPostForCreateLaunchpad 

func (s *Service) JobScanAgentTwitterPostForCreateLaunchpad(ctx context.Context) error

func (*Service) JobScanAgentTwitterPostForGenerateVideo 

func (s *Service) JobScanAgentTwitterPostForGenerateVideo(ctx context.Context) error

func (*Service) JobScanAgentTwitterPostForTA 

func (s *Service) JobScanAgentTwitterPostForTA(ctx context.Context) error

func (*Service) JobScanEventsByChain 

func (s *Service) JobScanEventsByChain(ctx context.Context) error

func (*Service) JobScanRepliesByLaunchpadTweetID 

func (s *Service) JobScanRepliesByLaunchpadTweetID(ctx context.Context) error

func (*Service) JobScanTwitterLiked 

func (s *Service) JobScanTwitterLiked(ctx context.Context) error

func (*Service) JobUpdateAgentImage 

func (s *Service) JobUpdateAgentImage(ctx context.Context) error

func (*Service) JobUpdateMarketPrice 

func (s *Service) JobUpdateMarketPrice(ctx context.Context) error

func (*Service) JobUpdateMemeUsdPrice 

func (s *Service) JobUpdateMemeUsdPrice(ctx context.Context) error

func (*Service) JobUpdateOffchainAutoOutput 

func (s *Service) JobUpdateOffchainAutoOutput(ctx context.Context) error

func (*Service) JobUpdateOffchainAutoOutput3Hour 

func (s *Service) JobUpdateOffchainAutoOutput3Hour(ctx context.Context) error

func (*Service) JobUpdateOffchainAutoOutputForMission 

func (s *Service) JobUpdateOffchainAutoOutputForMission(ctx context.Context) error

func (*Service) JobUpdateTokenPriceInfo 

func (s *Service) JobUpdateTokenPriceInfo(ctx context.Context) error

func (*Service) JobUpdateTwitterAccessToken 

func (s *Service) JobUpdateTwitterAccessToken(ctx context.Context) error

func (*Service) LaunchpadErc20TokenTransferEvent 

func (s *Service) LaunchpadErc20TokenTransferEvent(tx *gorm.DB, networkID uint64, event *ethapi.Erc20TokenTransferEventResp) error

func (*Service) LikeMemeThread 

func (s *Service) LikeMemeThread(ctx context.Context, address string, req *serializers.MemeThreadReq) (bool, error)

func (*Service) LookupUserTweets 

func (s *Service) LookupUserTweets(ctx context.Context, tweetIDs string) (*twitter.TweetLookups, error)

func (*Service) LookupUserTweetsV1 

func (s *Service) LookupUserTweetsV1(ctx context.Context, tweetIDs string) (*twitter.TweetLookups, error)

func (*Service) LuckyMoneyActionExecuted 

func (s *Service) LuckyMoneyActionExecuted(ctx context.Context, snapshotPostID uint) error

func (*Service) LuckyMoneyCollectPost 

func (s *Service) LuckyMoneyCollectPost(ctx context.Context, missionID uint) error

func (*Service) LuckyMoneyGetPostContent 

func (s *Service) LuckyMoneyGetPostContent(tx *gorm.DB, agentInfoID, missionID uint) (string, error)

func (*Service) LuckyMoneyProcessUserReward 

func (s *Service) LuckyMoneyProcessUserReward(ctx context.Context, luckyID uint) error

func (*Service) LuckyMoneyValidateRewardUser 

func (s *Service) LuckyMoneyValidateRewardUser(ctx context.Context, actionID uint) error

func (*Service) MemeAddPositionInternal 

func (s *Service) MemeAddPositionInternal(ctx context.Context, memeID uint) error

func (*Service) MemeAddPositionUniswap 

func (s *Service) MemeAddPositionUniswap(ctx context.Context, memeID uint) error

func (*Service) MemeBurnPositionUniswap 

func (s *Service) MemeBurnPositionUniswap(ctx context.Context, memeID uint) error

func (*Service) MemeEventsByTransaction 

func (s *Service) MemeEventsByTransaction(ctx context.Context, networkID uint64, txHash string) error

func (*Service) MemeEventsByTransactionEventResp 

func (s *Service) MemeEventsByTransactionEventResp(ctx context.Context, networkID uint64, eventResp *ethapi.BlockChainEventResp, forScan bool) error

func (*Service) MemeRemovePositionInternal 

func (s *Service) MemeRemovePositionInternal(ctx context.Context, memeID uint) error

func (*Service) MemeSnapshotTokenHolder 

func (s *Service) MemeSnapshotTokenHolder(ctx context.Context, tokenAddress string) error

func (*Service) MigrateWalletActionForID 

func (s *Service) MigrateWalletActionForID(ctx context.Context, walletActionID uint) error

func (*Service) MintAgent 

func (s *Service) MintAgent(ctx context.Context, agentInfoID uint) error

func (*Service) OpenseaCollections 

func (s *Service) OpenseaCollections(ctx context.Context, f opensea.OpenSeaFilterCollections) (*opensea.CollectionsResp, error)

func (*Service) OrderpaymentOrderPaidEvent 

func (s *Service) OrderpaymentOrderPaidEvent(ctx context.Context, networkID uint64, event *orderpayment.OrderpaymentOrderPaid) error

func (*Service) PauseAgent 

func (s *Service) PauseAgent(ctx context.Context, agentID string) (bool, error)

func (*Service) PostTwitterAferCreateToken 

func (s *Service) PostTwitterAferCreateToken(ctx context.Context, agentInfoID uint) error

func (*Service) PreviewAgentSystemPromp 

func (s *Service) PreviewAgentSystemPromp(ctx context.Context, personality, question string) (string, error)

func (*Service) PreviewAgentSystemPrompV1 

func (s *Service) PreviewAgentSystemPrompV1(ctx context.Context,
	messages string, agentId *uint, kbIdFromKnowledegeBase *string, modelNameFromRequest *string) (string, error)

func (*Service) PreviewStreamAgentSystemPromptV1 

func (s *Service) PreviewStreamAgentSystemPromptV1(ctx context.Context, writerResponse gin.ResponseWriter,
	outputChan chan *models.ChatCompletionStreamResponse,
	errChan chan error, doneChan chan bool)

func (*Service) ProcessDeposit 

func (s *Service) ProcessDeposit(ctx context.Context, depositNetworkID uint64, eventID string, txHash string, toAddress string, eventValue *big.Int) error

func (*Service) ProcessMissionTradingAnalytic 

func (s *Service) ProcessMissionTradingAnalytic(ctx context.Context, twitterPostID uint) error

func (*Service) ProcessStreamAgentSystemPromptV1 

func (s *Service) ProcessStreamAgentSystemPromptV1(ctx context.Context,
	req *serializers.PreviewRequest, outputChan chan *models.ChatCompletionStreamResponse,
	errChan chan error, doneChan chan bool)

func (*Service) ProxyAdminDAOUpgrade 

func (s *Service) ProxyAdminDAOUpgrade(ctx context.Context, networkID uint64, proxyAddress string) (string, error)

func (*Service) RatingMisstionStore 

func (s *Service) RatingMisstionStore(ctx context.Context, req *serializers.MissionStoreRatingReq) error

func (*Service) RedisCached 

func (s *Service) RedisCached(
	cachedKey string,
	enabled bool,
	expiration time.Duration,
	resp interface{},
	dataFetchedFunc func() (interface{}, error),
) error

func (*Service) RedisCachedWithoutHashKey 

func (s *Service) RedisCachedWithoutHashKey(
	cachedKey string,
	enabled bool,
	expiration time.Duration,
	resp interface{},
	dataFetchedFunc func() (interface{}, error),
) error

func (*Service) RedisFlushAll 

func (s *Service) RedisFlushAll(ctx context.Context) error

func (*Service) RefundApiTokenUsage 

func (s *Service) RefundApiTokenUsage(ctx context.Context, apiKey string, numToken uint) error

func (*Service) ReplyAferAutoCreateLaunchpad 

func (s *Service) ReplyAferAutoCreateLaunchpad(tx *gorm.DB, twitterPostID, launchpadId uint) error

func (*Service) ReplyAfterJoinLaunchpad 

func (s *Service) ReplyAfterJoinLaunchpad(tx *gorm.DB, twitterPostID, launchpadId uint, memberID uint, replyContent string) error

func (*Service) RetrieveKnowledge 

func (s *Service) RetrieveKnowledge(agentModel string, messages []openai2.ChatCompletionMessage,
	knowledgeBases []*models.KnowledgeBase, topK *int, threshold *float64) (string, error)

func (*Service) RetryAgentDeployToken 

func (s *Service) RetryAgentDeployToken(ctx context.Context, memeID uint) error

func (*Service) RunJobs 

func (s *Service) RunJobs(ctx context.Context) error

func (*Service) RunTeleBotJob 

func (s *Service) RunTeleBotJob(ctx context.Context) error

func (*Service) SampleTwitterAppAuthenCallback 

func (s *Service) SampleTwitterAppAuthenCallback(ctx context.Context, installCode string, installUri string, code string) (string, error)

func (*Service) SampleTwitterAppAuthenInstall 

func (s *Service) SampleTwitterAppAuthenInstall(ctx context.Context, installCode string, installUri string) (string, error)

func (*Service) SampleTwitterAppGetBTCPrice 

func (s *Service) SampleTwitterAppGetBTCPrice(ctx context.Context) string

func (*Service) SampleTwitterAppTweetMessage 

func (s *Service) SampleTwitterAppTweetMessage(ctx context.Context, apiKey string, content string) (string, error)

func (*Service) SaveAgentStore 

func (s *Service) SaveAgentStore(ctx context.Context, userAddress string, req *serializers.AgentStoreReq) (*models.AgentStore, error)

func (*Service) SaveAgentStoreCallback 

func (s *Service) SaveAgentStoreCallback(ctx context.Context, req *serializers.AuthenAgentStoreCallback) error

func (*Service) SaveMissionStore 

func (s *Service) SaveMissionStore(ctx context.Context, userAddress string, agentStoreID uint, req *serializers.AgentStoreMissionReq) error

func (*Service) ScanAgentInfraMintHash 

func (s *Service) ScanAgentInfraMintHash(ctx context.Context, userAddress string, networkID uint64, txHash string, agentStoreID uint) error

func (*Service) ScanAgentTwitterPostForGenerateVideo 

func (s *Service) ScanAgentTwitterPostForGenerateVideo(ctx context.Context, agentID uint) error

func (*Service) ScanAgentTwitterPostForTA 

func (s *Service) ScanAgentTwitterPostForTA(ctx context.Context, agentID uint) error

func (*Service) ScanEventsByChain 

func (s *Service) ScanEventsByChain(ctx context.Context, networkID uint64) error

func (*Service) ScanTokenTransferTxHash 

func (s *Service) ScanTokenTransferTxHash(ctx context.Context, networkID uint64, hash string) error

func (*Service) ScanTwitterTweetByParentID 

func (s *Service) ScanTwitterTweetByParentID(ctx context.Context, launchpad *models.Launchpad) (*twitter.TweetRecentSearch, error)

func (*Service) ScanTwitterTweetLiked 

func (s *Service) ScanTwitterTweetLiked(ctx context.Context) error

func (*Service) SeachTwitterUserByQuery 

func (s *Service) SeachTwitterUserByQuery(ctx context.Context, username string) (*twitter.UserLookups, error)

func (*Service) SearchRecentTweet 

func (s *Service) SearchRecentTweet(ctx context.Context, query, paginationToken string, maxResults int) (*twitter.TweetRecentSearch, error)

func (*Service) SearchRecentTweetV1 

func (s *Service) SearchRecentTweetV1(ctx context.Context, query, sinceID string, maxResults int) (*twitter.TweetRecentSearch, error)

func (*Service) SearchTokenTweet 

func (s *Service) SearchTokenTweet(ctx context.Context, query, paginationToken string, maxResults int) (*twitter.TweetRecentSearch, error)

func (*Service) SearchUsers 

func (s *Service) SearchUsers(ctx context.Context, query, paginationToken string) ([]*twitter.UserObj, error)

func (*Service) SendTeleMsgToChatID 

func (s *Service) SendTeleMsgToChatID(ctx context.Context, content, chatID string) (string, error)

func (*Service) SendTeleMsgToKBChannel 

func (s *Service) SendTeleMsgToKBChannel(ctx context.Context, content, chatID string) (string, error)

func (*Service) SetRedisCachedWithKey 

func (s *Service) SetRedisCachedWithKey(cachedKey string, req interface{}, expiration time.Duration) error

func (*Service) ShareMeme 

func (s *Service) ShareMeme(ctx context.Context, address, memAddress string) (bool, error)

func (*Service) StoreAddress 

func (s *Service) StoreAddress(ctx context.Context, address, prk string) (string, error)

func (*Service) StoreDefiAppAuthenInstall 

func (s *Service) StoreDefiAppAuthenInstall(ctx context.Context, installCode string, installUri string) (string, error)

func (*Service) StoreDefiAppGetWallet 

func (s *Service) StoreDefiAppGetWallet(ctx context.Context, apiKey string) (string, error)

func (*Service) StreamRetrieveKnowledge 

func (s *Service) StreamRetrieveKnowledge(ctx context.Context, agentModel string, messages []openai2.ChatCompletionMessage,
	knowledgeBases []*models.KnowledgeBase, topK *int, threshold *float64,
	outputChan chan *models.ChatCompletionStreamResponse,
	errChan chan error, doneChan chan bool)

func (*Service) SyncAgentInfoDetailByAgentID 

func (s *Service) SyncAgentInfoDetailByAgentID(ctx context.Context, agentID string) (*models.AgentInfo, error)

func (*Service) SyncGetTwitterUserByUsername 

func (s *Service) SyncGetTwitterUserByUsername(ctx context.Context, username string) (*models.TwitterUser, error)

func (*Service) SystemPromptManagerAgentDataUpdateEvent 

func (s *Service) SystemPromptManagerAgentDataUpdateEvent(ctx context.Context, networkID uint64, event *systempromptmanager.SystemPromptManagerAgentDataUpdate) error

func (*Service) SystemPromptManagerAgentURIUpdateEvent 

func (s *Service) SystemPromptManagerAgentURIUpdateEvent(ctx context.Context, networkID uint64, event *systempromptmanager.SystemPromptManagerAgentURIUpdate) error

func (*Service) SystemPromptManagerNewTokenEvent 

func (s *Service) SystemPromptManagerNewTokenEvent(ctx context.Context, networkID uint64, event *systempromptmanager.SystemPromptManagerNewToken) error

func (*Service) TestUtil 

func (s *Service) TestUtil()

func (*Service) TestVideo 

func (s *Service) TestVideo(ctx context.Context)

func (*Service) TokenTransferEventsByTransaction 

func (s *Service) TokenTransferEventsByTransaction(ctx context.Context, networkID uint64, eventResp *ethapi.Erc20TokenEventResp) error

func (*Service) TokenTransferEventsByTransactionV2 

func (s *Service) TokenTransferEventsByTransactionV2(ctx context.Context, networkID uint64, eventResp *ethapi.BlockChainEventResp) error

func (*Service) TransferFund 

func (s *Service) TransferFund(priKeyFrom string, toAddress string, fund *big.Int, networkId uint64) (string, error)

func (*Service) TweetByToken 

func (s *Service) TweetByToken(ctx context.Context, agentInfoID uint, req *serializers.AdminTweetReq) error

func (*Service) TweetGetFullText 

func (s *Service) TweetGetFullText(tweets twitter.TweetObj) string

func (*Service) TweetIsMention 

func (s *Service) TweetIsMention(tweets twitter.TweetObj, username string) bool

func (*Service) TweetIsMentionNBS 

func (s *Service) TweetIsMentionNBS(tweets twitter.TweetObj, username string) (string, bool)

func (*Service) TwitterOauthCallbackForApiSubscription 

func (s *Service) TwitterOauthCallbackForApiSubscription(ctx context.Context, callbackUrl, address, code, clientID string) error

func (*Service) TwitterOauthCallbackForCreateAgent 

func (s *Service) TwitterOauthCallbackForCreateAgent(ctx context.Context, callbackUrl, address, code, clientID string) error

func (*Service) TwitterOauthCallbackForInternalData 

func (s *Service) TwitterOauthCallbackForInternalData(ctx context.Context, callbackUrl, code string) error
func (s *Service) TwitterOauthCallbackForRelink(ctx context.Context, callbackUrl, address, code, clientID string) error

func (*Service) TwitterOauthCallbackV1 

func (s *Service) TwitterOauthCallbackV1(ctx context.Context, callbackUrl, address, code, agentID, clientID string) error

func (*Service) UnFollowUsers 

func (s *Service) UnFollowUsers(ctx context.Context, address string, req *serializers.MemeThreadReq) (bool, error)

func (*Service) UnLikeMemeThread 

func (s *Service) UnLikeMemeThread(ctx context.Context, address string, req *serializers.MemeThreadReq) (bool, error)

func (*Service) UnlinkAgentTwitterInfo 

func (s *Service) UnlinkAgentTwitterInfo(ctx context.Context, agentID string) (bool, error)

func (*Service) UpdateAgentExternalInfo 

func (s *Service) UpdateAgentExternalInfo(ctx context.Context, agentID string, req *serializers.AgentExternalInfoReq) (bool, error)

func (*Service) UpdateAgentFarcasterInfo 

func (s *Service) UpdateAgentFarcasterInfo(ctx context.Context, agentID string, fID string, fUsername string) (bool, error)

func (*Service) UpdateAgentInfoInContract 

func (s *Service) UpdateAgentInfoInContract(ctx context.Context, address string, req *serializers.UpdateAgentAssistantInContractRequest) (*models.AgentInfo, error)

func (*Service) UpdateAgentScanEventError 

func (s *Service) UpdateAgentScanEventError(ctx context.Context, agentInfoID uint, errData error) error

func (*Service) UpdateAgentScanEventSuccess 

func (s *Service) UpdateAgentScanEventSuccess(ctx context.Context, agentInfoID uint, lastTimeEvent *time.Time, lastId string) error

func (*Service) UpdateAgentTwitterInfo 

func (s *Service) UpdateAgentTwitterInfo(ctx context.Context, twitterInfoID uint) error

func (*Service) UpdateDataMissionTradeAnalytics 

func (s *Service) UpdateDataMissionTradeAnalytics(ctx context.Context, snapshotPostID uint) error

func (*Service) UpdateKnowledgeBaseInContractWithSignature 

func (s *Service) UpdateKnowledgeBaseInContractWithSignature(ctx context.Context, info *models.KnowledgeBase, request *serializers.UpdateKnowledgeBaseWithSignatureRequest) (*models.KnowledgeBase, error)

func (*Service) UpdateMemeInfo 

func (s *Service) UpdateMemeInfo(ctx context.Context, memeID uint) error

func (*Service) UpdateMemeLiquidityPosition 

func (s *Service) UpdateMemeLiquidityPosition(ctx context.Context, networkID uint64, event *ethapi.UniswapPositionLiquidity) error

func (*Service) UpdateOffchainAutoOutputForMission 

func (s *Service) UpdateOffchainAutoOutputForMission(ctx context.Context) error

func (*Service) UpdateOffchainAutoOutputV2 

func (s *Service) UpdateOffchainAutoOutputV2(ctx context.Context, snapshotPostID uint) error

func (*Service) UpdateOffchainAutoOutputV2ForId 

func (s *Service) UpdateOffchainAutoOutputV2ForId(ctx context.Context, snapshotPostID uint) error
func (s *Service) RetryAgentSnapshotPostActionExecuted(ctx context.Context, twitterPostID uint) error {
	err := s.JobRunCheck(
		ctx,
		fmt.Sprintf("RetryAgentSnapshotPostActionExecuted_%d", twitterPostID),
		func() error {
			var snapshotPostAction *models.AgentSnapshotPostAction
			contentLines := []string{}
			var accessToken, missionToolSet string
			postIds := []string{}
			err := daos.WithTransaction(
				daos.GetDBMainCtx(ctx),
				func(tx *gorm.DB) error {
					var err error
					snapshotPostAction, err = s.dao.FirstAgentSnapshotPostActionByID(
						tx,
						twitterPostID,
						map[string][]interface{}{},
						true,
					)
					if err != nil {
						return errs.NewError(err)
					}
					if snapshotPostAction.Status == models.AgentSnapshotPostActionStatusDone {
						agent, err := s.dao.FirstAgentInfoByID(
							tx,
							snapshotPostAction.AgentInfoID,
							map[string][]interface{}{
								"TwitterInfo": {},
							},
							false,
						)
						if err != nil {
							return errs.NewError(err)
						}
						//
						var refId, errText string
						agentSnapshotMission, err := s.dao.FirstAgentSnapshotMissionByID(
							tx,
							snapshotPostAction.AgentSnapshotMissionID,
							map[string][]interface{}{},
							false,
						)
						if err != nil {
							return errs.NewError(err)
						}
						missionToolSet = string(agentSnapshotMission.ToolSet)
						accessToken = agent.TwitterInfo.AccessToken
						switch snapshotPostAction.Type {
						case models.AgentSnapshotPostActionTypeTradeHold, models.AgentSnapshotPostActionTypeTradeBuy, models.AgentSnapshotPostActionTypeTradeSell, models.AgentSnapshotPostActionTypeTradeAnalytic:
							{
								switch missionToolSet {
								case string(models.ToolsetTypeTradeAnalyticsOnTwitter):
									{
										err = json.Unmarshal([]byte(snapshotPostAction.Content), &contentLines)
										if err != nil {
											return errs.NewError(err)
										}
										contentLines = helpers.SplitTextBySentenceAndCharLimitAndRemoveTrailingHashTag(strings.Join(contentLines, ". "), 250)
										if len(contentLines) <= 0 {
											return errs.NewError(errs.ErrBadRequest)
										}
										refId = snapshotPostAction.RefId
										postIds = append(postIds, refId)
									}
								default:
									{
										return errs.NewError(errs.ErrBadRequest)
									}
								}
							}
						default:
							{
								return errs.NewError(errs.ErrBadRequest)
							}
						}
						_ = errText
					}
					return nil
				},
			)
			if err != nil {
				return errs.NewError(err)
			}
			if len(postIds) > 0 && len(contentLines) > 1 {
				for i := 1; i < len(contentLines); i++ {
					var postId string
					switch snapshotPostAction.Type {
					case models.AgentSnapshotPostActionTypeTweet,
						models.AgentSnapshotPostActionTypeQuoteTweet,
						models.AgentSnapshotPostActionTypeCreateToken,
						models.AgentSnapshotPostActionTypeTweetV2:
						{
							postId, err = helpers.ReplyTweetByToken(accessToken, contentLines[i], postIds[0])
							if err != nil {
								return errs.NewError(err)
							}
						}
					case models.AgentSnapshotPostActionTypeReply,
						models.AgentSnapshotPostActionTypeTweetMulti:
						{
							postId, _ = helpers.ReplyTweetByToken(accessToken, contentLines[i], postIds[len(postIds)-1])
						}
					case models.AgentSnapshotPostActionTypeTradeHold, models.AgentSnapshotPostActionTypeTradeBuy, models.AgentSnapshotPostActionTypeTradeSell, models.AgentSnapshotPostActionTypeTradeAnalytic:
						{
							switch missionToolSet {
							case string(models.ToolsetTypeTradeAnalyticsOnTwitter):
								{
									postId, _ = helpers.ReplyTweetByToken(accessToken, contentLines[i], postIds[len(postIds)-1])
								}
							}
						}
					}
					if postId != "" {
						postIds = append(postIds, postId)
						err = daos.
							GetDBMainCtx(ctx).
							Model(&models.AgentSnapshotPostAction{}).
							Where("id = ?", twitterPostID).
							UpdateColumn("ref_ids", strings.Join(postIds, ",")).
							Error
						if err != nil {
							return errs.NewError(err)
						}
					}
				}
			}
			return nil
		},
	)
	if err != nil {
		return errs.NewError(err)
	}
	_ = s.UpdateOffchainAutoOutputV2(ctx, twitterPostID)
	return nil
}

func (*Service) UpdateScanBlockError 

func (s *Service) UpdateScanBlockError(ctx context.Context, chainID uint, lastBlockError error) error

func (*Service) UpdateScanBlockNumber 

func (s *Service) UpdateScanBlockNumber(ctx context.Context, chainID uint, lastBlockEvent int64) error

func (*Service) UpdateTokenPriceInfo 

func (s *Service) UpdateTokenPriceInfo(ctx context.Context, agentID uint) error

func (*Service) UpdateTwinStatus 

func (s *Service) UpdateTwinStatus(ctx context.Context, req *serializers.UpdateTwinStatusRequest) (*models.AgentInfo, error)

func (*Service) UpdateTwitterAccessToken 

func (s *Service) UpdateTwitterAccessToken(ctx context.Context, twitterInfoID uint) error

func (*Service) UploadDataToLightHouse 

func (s *Service) UploadDataToLightHouse(ctx context.Context, address string, req *serializers.DataUploadToLightHouse) (string, error)

func (*Service) UploadMisstionStore 

func (s *Service) UploadMisstionStore(ctx context.Context, req *serializers.MissionStoreReq) error

func (*Service) UserSeenMemeNotification 

func (s *Service) UserSeenMemeNotification(ctx context.Context, address string, notiID uint) (bool, error)

func (*Service) UserUploadFile 

func (s *Service) UserUploadFile(ctx context.Context, address string, fileHeader *multipart.FileHeader) (string, error)

func (*Service) UtilityPostTwitter 

func (s *Service) UtilityPostTwitter(ctx context.Context, userAddress string, req *serializers.AgentUtilityTwitterReq) (*serializers.AgentUtilityTwitterResp, error)

func (*Service) UtilityTwitterVerifyDeposit 

func (s *Service) UtilityTwitterVerifyDeposit(ctx context.Context, userAddress, txHash string) (bool, error)

func (*Service) ValidateTweetContentGenerateVideo 

func (s *Service) ValidateTweetContentGenerateVideo(ctx context.Context, userName, fullText string) (*models.TweetParseInfo, error)

func (*Service) ValidateUserStoreFee 

func (s *Service) ValidateUserStoreFee(ctx context.Context, apiKey string) (*models.AgentStoreInstall, error)

func (*Service) ValidatedFollowed 

func (s *Service) ValidatedFollowed(ctx context.Context, address, userAddress string) (bool, error)

func (*Service) VerifyAddressSignature 

func (s *Service) VerifyAddressSignature(ctx context.Context, networkID uint64, address string, message string, signature string) error

func (*Service) VerifyLoginUserByWeb3 

func (s *Service) VerifyLoginUserByWeb3(ctx context.Context, userIP, userAgent, address, message, signature string) (string, error)

Source Files

View all Source files

Directories

Path Synopsis
3rd
aidojo
binds/agentshares
binds/agenttoken
binds/agentupgradeable
binds/aikb721
binds/apechainnonfungiblepositionmanager
binds/apechainpool
binds/arbitrumfactory
binds/arbitrumnonfungiblepositionmanager
binds/arbitrumpool
binds/avaxnonfungiblepositionmanager
binds/basenonfungiblepositionmanager
binds/basequoterv2
binds/baseswaprouter02
binds/bridge
binds/bscfactory
binds/bscnonfungiblepositionmanager
binds/bscpool
binds/celononfungiblepositionmanager
binds/dagent721
binds/daotoken
binds/daotreasury
binds/erc1155
binds/erc20
binds/erc20realworldagent
binds/erc20utilityagent
binds/erc721
binds/ethereumnonfungiblepositionmanager
binds/gpumanager
binds/iagenttokendeployer
binds/ihybridmodel
binds/imagehub
binds/isystempromptmanager
binds/iv3swaprouter
binds/iworkerhub
binds/memenonfungiblepositionmanager
binds/multisend
binds/orderpayment
binds/polygonnonfungiblepositionmanager
binds/proxyadmin
binds/sunpumplaunchpad
binds/systempromptmanager
binds/transparentupgradeableproxy
binds/transparentupgradeableproxyzk
binds/uniswapv3factory
binds/uniswapv3pool
binds/wbvm
binds/workerhub
binds/zksyncnonfungiblepositionmanager
blockchain_utils
bridgeapi
btcapi
coingecko
coinmarketcap
core
deep_research
delegate_cash
dexscreener
eth
ethapi
evmapi
googlestorage
hiro
lighthouse
magiceden
moralis
openai
opensea
pumfun
rapid
taapi
trxapi
twitter
zkapi
zkclient

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.