Feat/threads

docs/index.md

@@ -31,7 +31,7 @@ In order to run a local demo service based on the IEKit:
 2. Fetch the IEKit.
 
     ```bash
-    autonomy fetch valory/impact_evaluator:0.1.0:bafybeiewo55hyk4tgw53c2h7jszttk35lx3thuiodcpkzyi3fmrv74o7bq --service
+    autonomy fetch valory/impact_evaluator:0.1.0:bafybeifnxchpuxoeyxd4qu3jsbqquo4axpp57dk6omgsofoueqz242a62i --service
     ```
 
 3. Build the Docker image of the service agents

packages/packages.json

@@ -1,19 +1,19 @@
 {
     "dev": {
-        "agent/valory/impact_evaluator/0.1.0": "bafybeif6lpdpuq2pcocmre4iswp6puraxrlib6b2ydzew2daboei6pduju",
+        "agent/valory/impact_evaluator/0.1.0": "bafybeihkdnfnqow7rejl2hqgtlsvg33nsa6ua5gfdrxkuznbypgpxqhbwa",
         "contract/valory/dynamic_contribution/0.1.0": "bafybeie76ynpueo3hh2ujzcfgpqcsbyqwa4pdcc6g44a4he6bueyb4tqiy",
-        "service/valory/impact_evaluator/0.1.0": "bafybeiewo55hyk4tgw53c2h7jszttk35lx3thuiodcpkzyi3fmrv74o7bq",
+        "service/valory/impact_evaluator/0.1.0": "bafybeifnxchpuxoeyxd4qu3jsbqquo4axpp57dk6omgsofoueqz242a62i",
         "skill/valory/dynamic_nft_abci/0.1.0": "bafybeie5vfscnjpvuwqe5vk7i2rzzlqciojswdg7uh34fjnuk3bspca5zq",
-        "skill/valory/twitter_scoring_abci/0.1.0": "bafybeifu7vbznnx42oayoh24malmebchfvbitndzpbmf6xmp7hgq26buyy",
+        "skill/valory/twitter_scoring_abci/0.1.0": "bafybeigxqyksuvrimhl5qvzzvevfr6swca5vux37wqefluyxxqntnhhssu",
         "skill/valory/ceramic_read_abci/0.1.0": "bafybeidruvxgpbggchuvlnssuswdxuoz2ep6sjvzzqjeyckybb6gpjx3ia",
         "skill/valory/ceramic_write_abci/0.1.0": "bafybeigtkv57h5suaqqpjfknimfegbidovxna7cok7znsgzrfb4nftqvay",
-        "skill/valory/impact_evaluator_abci/0.1.0": "bafybeig5kiim7x6svzbrxsmwjqntlfqbdmaod5n2vjbs7yqwj5sldgi6y4",
+        "skill/valory/impact_evaluator_abci/0.1.0": "bafybeiff332ucpyz27itmc2ug3pcsd5vfemocdg2ikzbivebu4qhqfl24m",
         "skill/valory/generic_scoring_abci/0.1.0": "bafybeiemmcnduhdj427kgafkxcbn2rfhaihabtpda34yqnks7utm3g4xiq",
         "protocol/valory/twitter/0.1.0": "bafybeib4eyf7qbs7kdntqzhwqsaaj4o2mzcokcztaza6qgwt7sbxgkqu2m",
         "protocol/valory/llm/1.0.0": "bafybeigqybmg75vsxexmp57hkms7lkp7iwpf54r7wpygizxryvrhfqqpb4",
-        "connection/valory/twitter/0.1.0": "bafybeibndxp3l35osve5pj255waemunlzaacwtasyazjmcmrx7qo5wcrni",
+        "connection/valory/twitter/0.1.0": "bafybeiaomtrnfaau4y55oajc77zg67wpm44ws7iflqlkz2dpthevsowlme",
         "connection/valory/openai/0.1.0": "bafybeih7w2xmaecgznuhxpnbxcxjhfla6wlmx3umytindfgk6ibbwqq2lu",
-        "skill/valory/twitter_write_abci/0.1.0": "bafybeih662zzwew4egsm2m6mis5yjwfehhx2lciio5ngnbunolc6nkkyw4",
+        "skill/valory/twitter_write_abci/0.1.0": "bafybeidffe5gpwydbnop6o3gtbtlmvgfeogh3jtufvbizbwvnzq7ior2ci",
         "skill/valory/llm_abci/0.1.0": "bafybeictnqpioilfry2yxkwaaguam5zbo3ygw7slkpn3k36gfvo2cnnyam",
         "skill/valory/decision_making_abci/0.1.0": "bafybeih5nquchsfisp5taaxrpz7j7ur2teymey5tihlw654wrzgpy57bvq"
     },

packages/valory/agents/impact_evaluator/aea-config.yaml

@@ -21,7 +21,7 @@ connections:
 - valory/ledger:0.19.0:bafybeigfoz7d7si7s4jehvloq2zmiiocpbxcaathl3bxkyarxoerxq7g3a
 - valory/p2p_libp2p_client:0.1.0:bafybeihdnfdth3qgltefgrem7xyi4b3ejzaz67xglm2hbma2rfvpl2annq
 - valory/openai:0.1.0:bafybeih7w2xmaecgznuhxpnbxcxjhfla6wlmx3umytindfgk6ibbwqq2lu
-- valory/twitter:0.1.0:bafybeibndxp3l35osve5pj255waemunlzaacwtasyazjmcmrx7qo5wcrni
+- valory/twitter:0.1.0:bafybeiaomtrnfaau4y55oajc77zg67wpm44ws7iflqlkz2dpthevsowlme
 contracts:
 - valory/dynamic_contribution:0.1.0:bafybeie76ynpueo3hh2ujzcfgpqcsbyqwa4pdcc6g44a4he6bueyb4tqiy
 - valory/gnosis_safe:0.1.0:bafybeigvqg4lapdaa23dpc3pv67rdptdhey6e435mxqsw2gb2u74yw4yei
@@ -42,17 +42,17 @@ protocols:
 skills:
 - valory/abstract_abci:0.1.0:bafybeicg7dv7cff34nv2k2z47c4yp4kddsxp3wozonzow6tnvfvwndz3cy
 - valory/abstract_round_abci:0.1.0:bafybeigxjcci53vwytymzlhr37436yvenh7jup4astrn7dgyixo24aq2pq
-- valory/impact_evaluator_abci:0.1.0:bafybeig5kiim7x6svzbrxsmwjqntlfqbdmaod5n2vjbs7yqwj5sldgi6y4
+- valory/impact_evaluator_abci:0.1.0:bafybeiff332ucpyz27itmc2ug3pcsd5vfemocdg2ikzbivebu4qhqfl24m
 - valory/generic_scoring_abci:0.1.0:bafybeiemmcnduhdj427kgafkxcbn2rfhaihabtpda34yqnks7utm3g4xiq
-- valory/twitter_scoring_abci:0.1.0:bafybeifu7vbznnx42oayoh24malmebchfvbitndzpbmf6xmp7hgq26buyy
+- valory/twitter_scoring_abci:0.1.0:bafybeigxqyksuvrimhl5qvzzvevfr6swca5vux37wqefluyxxqntnhhssu
 - valory/ceramic_read_abci:0.1.0:bafybeidruvxgpbggchuvlnssuswdxuoz2ep6sjvzzqjeyckybb6gpjx3ia
 - valory/ceramic_write_abci:0.1.0:bafybeigtkv57h5suaqqpjfknimfegbidovxna7cok7znsgzrfb4nftqvay
 - valory/dynamic_nft_abci:0.1.0:bafybeie5vfscnjpvuwqe5vk7i2rzzlqciojswdg7uh34fjnuk3bspca5zq
 - valory/registration_abci:0.1.0:bafybeibc4kczqbh23sc6tufrzn3axmhp3vjav7fa3u6cnpvolrbbc2fd7i
 - valory/reset_pause_abci:0.1.0:bafybeid445uy6wwvugf3byzl7r73c7teu6xr5ezxb4h7cxbenghg3copvy
 - valory/termination_abci:0.1.0:bafybeiguy7pkrcptg6c754ioig4mlkr7truccym3fpv6jwpjx2tmpdbzhi
 - valory/transaction_settlement_abci:0.1.0:bafybeidpsnguxizkpihtkqzojr3em7yy7c6qc7gxpbh5vglmwws5wke7bi
-- valory/twitter_write_abci:0.1.0:bafybeih662zzwew4egsm2m6mis5yjwfehhx2lciio5ngnbunolc6nkkyw4
+- valory/twitter_write_abci:0.1.0:bafybeidffe5gpwydbnop6o3gtbtlmvgfeogh3jtufvbizbwvnzq7ior2ci
 - valory/decision_making_abci:0.1.0:bafybeih5nquchsfisp5taaxrpz7j7ur2teymey5tihlw654wrzgpy57bvq
 - valory/llm_abci:0.1.0:bafybeictnqpioilfry2yxkwaaguam5zbo3ygw7slkpn3k36gfvo2cnnyam
 default_ledger: ethereum

packages/valory/connections/twitter/connection.py

@@ -180,7 +180,19 @@ def create_tweet(
             )
         )
         try:
-            response = api.create_tweet(text=text)
+            if isinstance(text, list):
+                # Thread
+                previous_tweet_id = None
+                for tweet in text:
+                    if not previous_tweet_id:
+                        response = api.create_tweet(text=tweet)
+                    else:
+                        response = api.create_tweet(text=tweet, in_reply_to_tweet_id=previous_tweet_id)
+                    previous_tweet_id = response.data["id"]
+            else:
+                # Single tweet
+                response = api.create_tweet(text=text)
+
         except TweepyHTTPException as e:
             error = "; ".join(e.api_messages)
             return cast(

packages/valory/connections/twitter/connection.yaml

@@ -7,7 +7,7 @@ license: Apache-2.0
 aea_version: '>=1.0.0, <2.0.0'
 fingerprint:
   __init__.py: bafybeibxwzkyh7odchnlkeczpguencdjiizm4nezfmi4drybn2zd25xdkq
-  connection.py: bafybeifjxjgsr2wddmxsmruxejrsfctgcla67gixs5d6hqrxh4hnkk4lrq
+  connection.py: bafybeia2qxkn77fffrozel3sybcpc57i5uewcpfbeblg7rcchmjqath55a
   readme.md: bafybeihg5yfzgqvg5ngy7r2o5tfeqnelx2ffxw4po5hmheqjfhumpmxpoq
 fingerprint_ignore_patterns: []
 connections: []

packages/valory/services/impact_evaluator/service.yaml

@@ -8,7 +8,7 @@ license: Apache-2.0
 fingerprint:
   README.md: bafybeign56hilwuoa6bgos3uqabss4gew4vadkik7vhj3ucpqw6nxtqtpe
 fingerprint_ignore_patterns: []
-agent: valory/impact_evaluator:0.1.0:bafybeif6lpdpuq2pcocmre4iswp6puraxrlib6b2ydzew2daboei6pduju
+agent: valory/impact_evaluator:0.1.0:bafybeihkdnfnqow7rejl2hqgtlsvg33nsa6ua5gfdrxkuznbypgpxqhbwa
 number_of_agents: 4
 deployment:
   agent:
@@ -80,7 +80,7 @@ extra:
         termination_sleep: ${TERMINATION_SLEEP:int:900}
         reset_pause_duration: ${RESET_PAUSE_DURATION:int:300}
         on_chain_service_id: ${ON_CHAIN_SERVICE_ID:int:null}
-        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:300}
+        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:30}
         retry_attempts: 400
         retry_timeout: 3
         request_retry_delay: 1.0
@@ -146,7 +146,7 @@ extra:
         termination_sleep: ${TERMINATION_SLEEP:int:900}
         reset_pause_duration: ${RESET_PAUSE_DURATION:int:300}
         on_chain_service_id: ${ON_CHAIN_SERVICE_ID:int:null}
-        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:300}
+        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:30}
         retry_attempts: 400
         retry_timeout: 3
         request_retry_delay: 1.0
@@ -212,7 +212,7 @@ extra:
         termination_sleep: ${TERMINATION_SLEEP:int:900}
         reset_pause_duration: ${RESET_PAUSE_DURATION:int:300}
         on_chain_service_id: ${ON_CHAIN_SERVICE_ID:int:null}
-        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:300}
+        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:30}
         retry_attempts: 400
         retry_timeout: 3
         request_retry_delay: 1.0
@@ -280,7 +280,7 @@ extra:
         keeper_allowed_retries: 3
         reset_pause_duration: ${RESET_PAUSE_DURATION:int:300}
         on_chain_service_id: ${ON_CHAIN_SERVICE_ID:int:null}
-        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:300}
+        reset_tendermint_after: ${RESET_TENDERMINT_AFTER:int:30}
         retry_attempts: 400
         retry_timeout: 3
         request_retry_delay: 1.0

packages/valory/skills/impact_evaluator_abci/fsm_specification.yaml

@@ -145,13 +145,13 @@ transition_func:
     (TwitterHashtagsCollectionRound, API_ERROR): TwitterHashtagsCollectionRound
     (TwitterHashtagsCollectionRound, DONE): TwitterDecisionMakingRound
     (TwitterHashtagsCollectionRound, DONE_MAX_RETRIES): TwitterDecisionMakingRound
-    (TwitterHashtagsCollectionRound, NO_MAJORITY): TwitterHashtagsCollectionRound
-    (TwitterHashtagsCollectionRound, ROUND_TIMEOUT): TwitterHashtagsCollectionRound
+    (TwitterHashtagsCollectionRound, NO_MAJORITY): TwitterRandomnessRound
+    (TwitterHashtagsCollectionRound, ROUND_TIMEOUT): TwitterRandomnessRound
     (TwitterMentionsCollectionRound, API_ERROR): TwitterMentionsCollectionRound
     (TwitterMentionsCollectionRound, DONE): TwitterDecisionMakingRound
     (TwitterMentionsCollectionRound, DONE_MAX_RETRIES): TwitterDecisionMakingRound
-    (TwitterMentionsCollectionRound, NO_MAJORITY): TwitterMentionsCollectionRound
-    (TwitterMentionsCollectionRound, ROUND_TIMEOUT): TwitterMentionsCollectionRound
+    (TwitterMentionsCollectionRound, NO_MAJORITY): TwitterRandomnessRound
+    (TwitterMentionsCollectionRound, ROUND_TIMEOUT): TwitterRandomnessRound
     (TwitterRandomnessRound, DONE): TwitterSelectKeepersRound
     (TwitterRandomnessRound, NO_MAJORITY): TwitterRandomnessRound
     (TwitterRandomnessRound, ROUND_TIMEOUT): TwitterRandomnessRound

packages/valory/skills/impact_evaluator_abci/skill.yaml

@@ -10,7 +10,7 @@ fingerprint:
   behaviours.py: bafybeifhoufesr4r4re65mxjadqasjymvz6tkc25xn5yyn473yunhjiufe
   composition.py: bafybeifmf52jhbiyyqyxzd67gxrydedm44ouzib3jh56kzoe5xohjrhm34
   dialogues.py: bafybeigjknz4qqynbsltjje46gidg4rftsqw6ybjwegz24wetmycutpzh4
-  fsm_specification.yaml: bafybeiczfb5nrqfuugkhi3pa4gyw5odtv5bwl6twdh6rlmmq7dwxsxud7a
+  fsm_specification.yaml: bafybeiaiqgpoc364mgsrxvztopyfkxxemtp2zky3ivxtqtukkdhizuiy74
   handlers.py: bafybeidkli6fphcmdgwsys4lkyf3fx6fbawet4nt2pnixfypzijhg6b3ze
   models.py: bafybeifhcshu4iwqvc2fz3auu5ngfykkhvqnroeug52ilrwwc4kowkeg5a
   tests/__init__.py: bafybeievwzwojvq4aofk5kjpf4jzygfes7ew6s6svc6b6frktjnt3sicce
@@ -26,7 +26,7 @@ skills:
 - valory/abstract_round_abci:0.1.0:bafybeigxjcci53vwytymzlhr37436yvenh7jup4astrn7dgyixo24aq2pq
 - valory/ceramic_read_abci:0.1.0:bafybeidruvxgpbggchuvlnssuswdxuoz2ep6sjvzzqjeyckybb6gpjx3ia
 - valory/generic_scoring_abci:0.1.0:bafybeiemmcnduhdj427kgafkxcbn2rfhaihabtpda34yqnks7utm3g4xiq
-- valory/twitter_scoring_abci:0.1.0:bafybeifu7vbznnx42oayoh24malmebchfvbitndzpbmf6xmp7hgq26buyy
+- valory/twitter_scoring_abci:0.1.0:bafybeigxqyksuvrimhl5qvzzvevfr6swca5vux37wqefluyxxqntnhhssu
 - valory/ceramic_write_abci:0.1.0:bafybeigtkv57h5suaqqpjfknimfegbidovxna7cok7znsgzrfb4nftqvay
 - valory/dynamic_nft_abci:0.1.0:bafybeie5vfscnjpvuwqe5vk7i2rzzlqciojswdg7uh34fjnuk3bspca5zq
 - valory/registration_abci:0.1.0:bafybeibc4kczqbh23sc6tufrzn3axmhp3vjav7fa3u6cnpvolrbbc2fd7i
@@ -35,7 +35,7 @@ skills:
 - valory/transaction_settlement_abci:0.1.0:bafybeidpsnguxizkpihtkqzojr3em7yy7c6qc7gxpbh5vglmwws5wke7bi
 - valory/decision_making_abci:0.1.0:bafybeih5nquchsfisp5taaxrpz7j7ur2teymey5tihlw654wrzgpy57bvq
 - valory/llm_abci:0.1.0:bafybeictnqpioilfry2yxkwaaguam5zbo3ygw7slkpn3k36gfvo2cnnyam
-- valory/twitter_write_abci:0.1.0:bafybeih662zzwew4egsm2m6mis5yjwfehhx2lciio5ngnbunolc6nkkyw4
+- valory/twitter_write_abci:0.1.0:bafybeidffe5gpwydbnop6o3gtbtlmvgfeogh3jtufvbizbwvnzq7ior2ci
 behaviours:
   main:
     args: {}

packages/valory/skills/twitter_scoring_abci/fsm_specification.yaml

@@ -52,13 +52,13 @@ transition_func:
     (TwitterHashtagsCollectionRound, API_ERROR): TwitterHashtagsCollectionRound
     (TwitterHashtagsCollectionRound, DONE): TwitterDecisionMakingRound
     (TwitterHashtagsCollectionRound, DONE_MAX_RETRIES): TwitterDecisionMakingRound
-    (TwitterHashtagsCollectionRound, NO_MAJORITY): TwitterHashtagsCollectionRound
-    (TwitterHashtagsCollectionRound, ROUND_TIMEOUT): TwitterHashtagsCollectionRound
+    (TwitterHashtagsCollectionRound, NO_MAJORITY): TwitterRandomnessRound
+    (TwitterHashtagsCollectionRound, ROUND_TIMEOUT): TwitterRandomnessRound
     (TwitterMentionsCollectionRound, API_ERROR): TwitterMentionsCollectionRound
     (TwitterMentionsCollectionRound, DONE): TwitterDecisionMakingRound
     (TwitterMentionsCollectionRound, DONE_MAX_RETRIES): TwitterDecisionMakingRound
-    (TwitterMentionsCollectionRound, NO_MAJORITY): TwitterMentionsCollectionRound
-    (TwitterMentionsCollectionRound, ROUND_TIMEOUT): TwitterMentionsCollectionRound
+    (TwitterMentionsCollectionRound, NO_MAJORITY): TwitterRandomnessRound
+    (TwitterMentionsCollectionRound, ROUND_TIMEOUT): TwitterRandomnessRound
     (TwitterRandomnessRound, DONE): TwitterSelectKeepersRound
     (TwitterRandomnessRound, NO_MAJORITY): TwitterRandomnessRound
     (TwitterRandomnessRound, ROUND_TIMEOUT): TwitterRandomnessRound

packages/valory/skills/twitter_scoring_abci/rounds.py

@@ -607,15 +607,15 @@ class TwitterScoringAbciApp(AbciApp[Event]):
             Event.DONE: TwitterDecisionMakingRound,
             Event.DONE_MAX_RETRIES: TwitterDecisionMakingRound,
             Event.API_ERROR: TwitterMentionsCollectionRound,
-            Event.NO_MAJORITY: TwitterMentionsCollectionRound,
-            Event.ROUND_TIMEOUT: TwitterMentionsCollectionRound,
+            Event.NO_MAJORITY: TwitterRandomnessRound,
+            Event.ROUND_TIMEOUT: TwitterRandomnessRound,
         },
         TwitterHashtagsCollectionRound: {
             Event.DONE: TwitterDecisionMakingRound,
             Event.DONE_MAX_RETRIES: TwitterDecisionMakingRound,
             Event.API_ERROR: TwitterHashtagsCollectionRound,
-            Event.NO_MAJORITY: TwitterHashtagsCollectionRound,
-            Event.ROUND_TIMEOUT: TwitterHashtagsCollectionRound,
+            Event.NO_MAJORITY: TwitterRandomnessRound,
+            Event.ROUND_TIMEOUT: TwitterRandomnessRound,
         },
         TweetEvaluationRound: {
             Event.DONE: TwitterDecisionMakingRound,

packages/valory/skills/twitter_scoring_abci/skill.yaml

@@ -11,12 +11,12 @@ fingerprint:
   behaviours.py: bafybeia4ygnvr3qtw7o3ory5inwir2rtesnt7kswyftfsjak3bfhrhsaki
   ceramic_db.py: bafybeicusdonrdq6kirgkpdqmi3a6kmeal4nctnm5ozjqf5s5se6jpitjm
   dialogues.py: bafybeibdqzn37hbo2cq4skww4uh2zvvsjyaxxvdhxisefbdvmjp7rh53si
-  fsm_specification.yaml: bafybeidsw6qckqnput57ilb5h3ywk23u3ado33fzk5scag3lptf7ldn4wa
+  fsm_specification.yaml: bafybeignulsqolfatfv2zo6s3tw5zykqtydojc3kzrwcgovdtf7ofxj3xi
   handlers.py: bafybeid3nqvcyotqj5g5hlgrz57nf7vpjysmgvsxe3p7644f4z5dcwqn6u
   models.py: bafybeiajis7l5sv7b3fofuj3ehxai5d2uy6h6p4kabhrekjwkjs77lopxe
   payloads.py: bafybeibeqiwnua7uewbv5a7epebshjpueuqpcbw6s2y3u62kasdhiijs5i
   prompts.py: bafybeieiuqn427bgwfnzynxf3vtqfpvmqqscs5tyw4oibfofwropifotke
-  rounds.py: bafybeifb74pke5oymrid7xe53idcwmxfkzch2x2pcu3m7rf2l74izndgly
+  rounds.py: bafybeibqzguokmeb4qtcbsamvr4up2tc7utwcc2qz4tkeseb42ega57gju
   tests/__init__.py: bafybeidwzzd4ejsyf3aryd5kmrvd63h7ajgqyrxphmfaacvpjnneacejay
   tests/test_behaviours.py: bafybeihp46fd44n34bqyyqixm2g3khraouofefe54eatmw2ktw7poqqllq
   tests/test_ceramic_db.py: bafybeif2v7btjphbqabq6qdmfeyweg765seon74acg5vrrvznivzg2prey

packages/valory/skills/twitter_write_abci/skill.yaml

@@ -24,7 +24,7 @@ fingerprint:
   tests/test_rounds.py: bafybeia7j34hsmnygib4ser27yin2mktk5vrvlloozvtvoqtlzoz2ugaoq
 fingerprint_ignore_patterns: []
 connections:
-- valory/twitter:0.1.0:bafybeibndxp3l35osve5pj255waemunlzaacwtasyazjmcmrx7qo5wcrni
+- valory/twitter:0.1.0:bafybeiaomtrnfaau4y55oajc77zg67wpm44ws7iflqlkz2dpthevsowlme
 contracts: []
 protocols:
 - valory/twitter:0.1.0:bafybeib4eyf7qbs7kdntqzhwqsaaj4o2mzcokcztaza6qgwt7sbxgkqu2m