Merge pull request #259 from valory-xyz/fix/streams

Fix/streams

Author: dvilelaf

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:bafybeibb5zbd55riqw2kmdncam3tg47dnqlvvig6byokvfxjzgv6wqxhby --service
+    autonomy fetch valory/impact_evaluator:0.1.0:bafybeibahzer2qkm43tcyratyuxfrtwc5bme2oqr37pgzwzblli4tms54e --service
     ```
 
 3. Build the Docker image of the service agents

packages/packages.json

@@ -15,24 +15,24 @@
         "connection/valory/twitter/0.1.0": "bafybeiatpdlh2o3j6qwwlxlu4vvumohkh6woslb5kkpap6pla47vincbp4",
         "connection/valory/openai/0.1.0": "bafybeiaryip2lbiluf7vjsdq6r5qiqdesmhqevrzekfrxpugfypqja6gae",
         "connection/valory/farcaster/0.1.0": "bafybeibbdas7lxbipksodaphjms3uop7vnzjqkroktjq2g6wbvgtlldaxi",
-        "skill/valory/dynamic_nft_abci/0.1.0": "bafybeidk4llioejff2iy7qzdxkjvxfy6cw6pkkawd756hn3iiyhedg6sm4",
-        "skill/valory/twitter_scoring_abci/0.1.0": "bafybeicmewtyr3mrx2cda74kiku3uyfveqe56dj5gl5oi65hwl4f2tm56e",
+        "skill/valory/dynamic_nft_abci/0.1.0": "bafybeib4l6povv23doi5nudsuptsfrfv5622vqet72fcxo6uxt3yohbfhq",
+        "skill/valory/twitter_scoring_abci/0.1.0": "bafybeick6ohjwoc7h7ab5ubkbbte2mivzsoypvdk65enuysisqk5vpksju",
         "skill/valory/ceramic_read_abci/0.1.0": "bafybeihmsruafswliwcgp5xh3qv44oup5bq2xbokky52gjs5w2zlsdd3tu",
         "skill/valory/ceramic_write_abci/0.1.0": "bafybeigh2yjhidqhr4fxo4ohn5n5b6wug5ssovdpcfehmlfser5arc5o5m",
-        "skill/valory/impact_evaluator_abci/0.1.0": "bafybeibksdpik2tvlwxdu3o7b6c67phydkcniuthgtsiyvdwr7j5mq64w4",
-        "skill/valory/generic_scoring_abci/0.1.0": "bafybeiavpwypdhjmjyo34nzjy7xnhsz67tar5ianejeipcfpyii7k3w2d4",
+        "skill/valory/impact_evaluator_abci/0.1.0": "bafybeidrneg3kcpkwt6mk6uzdod25xx22grrqnwrtamm4epjiiwr2wx2ge",
+        "skill/valory/generic_scoring_abci/0.1.0": "bafybeieiyawwyplv2eitq5tz7lfznf4ef3fjulgyuok4sskrbq6cgmaad4",
         "skill/valory/twitter_write_abci/0.1.0": "bafybeih6pax4t3fcss2jdgkh2bzeoi4eropdimmekrg67w43y4qcu2zkyy",
         "skill/valory/llm_abci/0.1.0": "bafybeiadgaty4ctrgipn6z5tvi6l5cbmpw7fxp5cbsjdwjom6p3ypwl3sy",
-        "skill/valory/decision_making_abci/0.1.0": "bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila",
-        "skill/valory/olas_week_abci/0.1.0": "bafybeib5gykn7qv76dvijnplhkwjin57bfz353sjtgiu4hqz5v2tnjur6e",
+        "skill/valory/decision_making_abci/0.1.0": "bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm",
+        "skill/valory/olas_week_abci/0.1.0": "bafybeidy6apcflgsmujmtg4pzpril6x6n337l7j74a7qtgm6x7moz2wkby",
         "skill/valory/mech_interact_abci/0.1.0": "bafybeight53ip54jyhor7ylssmvfuxhmq666bamn3pjw3q55pm6x7av54a",
         "skill/valory/farcaster_write_abci/0.1.0": "bafybeifd7pocsm4tztw3d635s7aj3tkppzca5w7n7ch7otw2aveht5pjpm",
         "skill/valory/farcaster_test_abci/0.1.0": "bafybeigowgmy5rk5f2m5xkxltq5qvquoj52zzwe6wxtsa2xx74ckuwgiiq",
         "skill/valory/staking_abci/0.1.0": "bafybeib4wwt2ezjwzb6gwqnfguqztqfquln4tlhrhwxkksxlafw2kfpqpu",
-        "agent/valory/impact_evaluator/0.1.0": "bafybeib4yfacggjker5pztagcebk3j7mp7sa5awn24og3xt7qdw7eps3my",
+        "agent/valory/impact_evaluator/0.1.0": "bafybeiemu24x5hl2ohqrqdfc4h2id56d5e25ax2icnsef27rxoe34nbcxm",
         "agent/valory/farcaster_test/0.1.0": "bafybeihuvlmkrsezp36ayxt7yogglr3hul7xr2fezgpminudgbz3ekchju",
-        "service/valory/impact_evaluator/0.1.0": "bafybeibb5zbd55riqw2kmdncam3tg47dnqlvvig6byokvfxjzgv6wqxhby",
-        "service/valory/impact_evaluator_local/0.1.0": "bafybeihwudva37g74sxgkezvq7rjsfth7z6ug7qmxamn33tcgxsulb4joy"
+        "service/valory/impact_evaluator/0.1.0": "bafybeibahzer2qkm43tcyratyuxfrtwc5bme2oqr37pgzwzblli4tms54e",
+        "service/valory/impact_evaluator_local/0.1.0": "bafybeiginh4ye4d4fpnhia54qoa3iosc5mtlkilne3gmhiy3rpxecrivbe"
     },
     "third_party": {
         "protocol/open_aea/signing/1.0.0": "bafybeig2d36zxy65vd7fwhs7scotuktydcarm74aprmrb5nioiymr3yixm",

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

@@ -46,20 +46,20 @@ protocols:
 skills:
 - valory/abstract_abci:0.1.0:bafybeidnxfm5lbkvlhov53hhv3fmoo7slngre27t3mdihjp75tpd76lf3i
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
-- valory/impact_evaluator_abci:0.1.0:bafybeibksdpik2tvlwxdu3o7b6c67phydkcniuthgtsiyvdwr7j5mq64w4
-- valory/generic_scoring_abci:0.1.0:bafybeiavpwypdhjmjyo34nzjy7xnhsz67tar5ianejeipcfpyii7k3w2d4
-- valory/twitter_scoring_abci:0.1.0:bafybeicmewtyr3mrx2cda74kiku3uyfveqe56dj5gl5oi65hwl4f2tm56e
+- valory/impact_evaluator_abci:0.1.0:bafybeidrneg3kcpkwt6mk6uzdod25xx22grrqnwrtamm4epjiiwr2wx2ge
+- valory/generic_scoring_abci:0.1.0:bafybeieiyawwyplv2eitq5tz7lfznf4ef3fjulgyuok4sskrbq6cgmaad4
+- valory/twitter_scoring_abci:0.1.0:bafybeick6ohjwoc7h7ab5ubkbbte2mivzsoypvdk65enuysisqk5vpksju
 - valory/ceramic_read_abci:0.1.0:bafybeihmsruafswliwcgp5xh3qv44oup5bq2xbokky52gjs5w2zlsdd3tu
 - valory/ceramic_write_abci:0.1.0:bafybeigh2yjhidqhr4fxo4ohn5n5b6wug5ssovdpcfehmlfser5arc5o5m
-- valory/dynamic_nft_abci:0.1.0:bafybeidk4llioejff2iy7qzdxkjvxfy6cw6pkkawd756hn3iiyhedg6sm4
+- valory/dynamic_nft_abci:0.1.0:bafybeib4l6povv23doi5nudsuptsfrfv5622vqet72fcxo6uxt3yohbfhq
 - valory/registration_abci:0.1.0:bafybeifurpc5kko5tq5bc2bwfgdvwpbhzytk2vhj56cb2d6lhdnm7irnhu
 - valory/reset_pause_abci:0.1.0:bafybeiavtmbqziu3i55t2clj2ih242vuq2nw4xp47heaxyusddggl664ya
 - valory/termination_abci:0.1.0:bafybeigpodcqf4vtk4pwj2d3fn2hbvv6fnwgqllowxwx3e76wonxen4zu4
 - valory/transaction_settlement_abci:0.1.0:bafybeibil7cfzuuyxge5rayxwqxvq467hhv73pngj3muqo7x6zkkjzlgs4
 - valory/twitter_write_abci:0.1.0:bafybeih6pax4t3fcss2jdgkh2bzeoi4eropdimmekrg67w43y4qcu2zkyy
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 - valory/llm_abci:0.1.0:bafybeiadgaty4ctrgipn6z5tvi6l5cbmpw7fxp5cbsjdwjom6p3ypwl3sy
-- valory/olas_week_abci:0.1.0:bafybeib5gykn7qv76dvijnplhkwjin57bfz353sjtgiu4hqz5v2tnjur6e
+- valory/olas_week_abci:0.1.0:bafybeidy6apcflgsmujmtg4pzpril6x6n337l7j74a7qtgm6x7moz2wkby
 - valory/mech_interact_abci:0.1.0:bafybeight53ip54jyhor7ylssmvfuxhmq666bamn3pjw3q55pm6x7av54a
 - valory/staking_abci:0.1.0:bafybeib4wwt2ezjwzb6gwqnfguqztqfquln4tlhrhwxkksxlafw2kfpqpu
 default_ledger: ethereum

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:bafybeib4yfacggjker5pztagcebk3j7mp7sa5awn24og3xt7qdw7eps3my
+agent: valory/impact_evaluator:0.1.0:bafybeiemu24x5hl2ohqrqdfc4h2id56d5e25ax2icnsef27rxoe34nbcxm
 number_of_agents: 4
 deployment:
   agent:

packages/valory/services/impact_evaluator_local/service.yaml

@@ -8,7 +8,7 @@ license: Apache-2.0
 fingerprint:
   README.md: bafybeign56hilwuoa6bgos3uqabss4gew4vadkik7vhj3ucpqw6nxtqtpe
 fingerprint_ignore_patterns: []
-agent: valory/impact_evaluator:0.1.0:bafybeib4yfacggjker5pztagcebk3j7mp7sa5awn24og3xt7qdw7eps3my
+agent: valory/impact_evaluator:0.1.0:bafybeiemu24x5hl2ohqrqdfc4h2id56d5e25ax2icnsef27rxoe34nbcxm
 number_of_agents: 1
 deployment:
   agent:

packages/valory/skills/decision_making_abci/skill.yaml

@@ -20,7 +20,7 @@ fingerprint:
   tasks/read_stream_preparation.py: bafybeicmjasiyecopfweobodzbmn3tbluu5q724uzzqkit6urn3lb5q354
   tasks/score_preparations.py: bafybeie7cfot24zcyod5becz6t5lasvva77httfkw57qmvgjk35d3qluxa
   tasks/signature_validation.py: bafybeihbwrv72hnh3ytko2i5oszqgdky2j6h2wse45wvuhf2j32lo2tsjy
-  tasks/staking.py: bafybeigvesonp36cswu7pcatfawnf3nlgtnepwkzqudiorr3eyxcyply3i
+  tasks/staking.py: bafybeibcobvleysxstlrnb6zkiysqtaqjahdkgiod4nx3iti4p6cfaqulm
   tasks/task_preparations.py: bafybeihfm3ms665fvz2qwmhmcwgl2ws5mt62pykomowoxpm6a46jlqvsmu
   tasks/tweet_validation_preparation.py: bafybeif3wbfskiyuij7unx72euklms7owrzwzgdu462xatvypalm6xrgca
   tasks/twitter_preparation.py: bafybeicn7stcvmd6oex55dwptwxpikpssbcwnj2d3xkercikg5nlzqh4k4

packages/valory/skills/decision_making_abci/tasks/staking.py

@@ -257,6 +257,10 @@ def check_extra_conditions(self):
             epoch = yield from self.get_staking_epoch(staking_contract_address)
             staking_contract_to_epoch[staking_contract_address] = epoch
 
+        self.context.logger.info(
+            f"staking_contract_to_epoch = {staking_contract_to_epoch}"
+        )
+
         # Get the updates.
         # Store them as a property since we will use them in _pre_task() to return the updates
         (

packages/valory/skills/dynamic_nft_abci/skill.yaml

@@ -31,7 +31,7 @@ protocols:
 - valory/http:1.0.0:bafybeih4azmfwtamdbkhztkm4xitep3gx6tfdnoz6tvllmaqnhu3klejfa
 skills:
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 behaviours:
   main:
     args: {}

packages/valory/skills/generic_scoring_abci/skill.yaml

@@ -28,7 +28,7 @@ contracts: []
 protocols: []
 skills:
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 behaviours:
   main:
     args: {}

packages/valory/skills/impact_evaluator_abci/skill.yaml

@@ -25,18 +25,18 @@ protocols: []
 skills:
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
 - valory/ceramic_read_abci:0.1.0:bafybeihmsruafswliwcgp5xh3qv44oup5bq2xbokky52gjs5w2zlsdd3tu
-- valory/generic_scoring_abci:0.1.0:bafybeiavpwypdhjmjyo34nzjy7xnhsz67tar5ianejeipcfpyii7k3w2d4
-- valory/twitter_scoring_abci:0.1.0:bafybeicmewtyr3mrx2cda74kiku3uyfveqe56dj5gl5oi65hwl4f2tm56e
+- valory/generic_scoring_abci:0.1.0:bafybeieiyawwyplv2eitq5tz7lfznf4ef3fjulgyuok4sskrbq6cgmaad4
+- valory/twitter_scoring_abci:0.1.0:bafybeick6ohjwoc7h7ab5ubkbbte2mivzsoypvdk65enuysisqk5vpksju
 - valory/ceramic_write_abci:0.1.0:bafybeigh2yjhidqhr4fxo4ohn5n5b6wug5ssovdpcfehmlfser5arc5o5m
-- valory/dynamic_nft_abci:0.1.0:bafybeidk4llioejff2iy7qzdxkjvxfy6cw6pkkawd756hn3iiyhedg6sm4
+- valory/dynamic_nft_abci:0.1.0:bafybeib4l6povv23doi5nudsuptsfrfv5622vqet72fcxo6uxt3yohbfhq
 - valory/registration_abci:0.1.0:bafybeifurpc5kko5tq5bc2bwfgdvwpbhzytk2vhj56cb2d6lhdnm7irnhu
 - valory/reset_pause_abci:0.1.0:bafybeiavtmbqziu3i55t2clj2ih242vuq2nw4xp47heaxyusddggl664ya
 - valory/termination_abci:0.1.0:bafybeigpodcqf4vtk4pwj2d3fn2hbvv6fnwgqllowxwx3e76wonxen4zu4
 - valory/transaction_settlement_abci:0.1.0:bafybeibil7cfzuuyxge5rayxwqxvq467hhv73pngj3muqo7x6zkkjzlgs4
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 - valory/llm_abci:0.1.0:bafybeiadgaty4ctrgipn6z5tvi6l5cbmpw7fxp5cbsjdwjom6p3ypwl3sy
 - valory/twitter_write_abci:0.1.0:bafybeih6pax4t3fcss2jdgkh2bzeoi4eropdimmekrg67w43y4qcu2zkyy
-- valory/olas_week_abci:0.1.0:bafybeib5gykn7qv76dvijnplhkwjin57bfz353sjtgiu4hqz5v2tnjur6e
+- valory/olas_week_abci:0.1.0:bafybeidy6apcflgsmujmtg4pzpril6x6n337l7j74a7qtgm6x7moz2wkby
 - valory/mech_interact_abci:0.1.0:bafybeight53ip54jyhor7ylssmvfuxhmq666bamn3pjw3q55pm6x7av54a
 - valory/staking_abci:0.1.0:bafybeib4wwt2ezjwzb6gwqnfguqztqfquln4tlhrhwxkksxlafw2kfpqpu
 behaviours:

packages/valory/skills/olas_week_abci/skill.yaml

@@ -31,7 +31,7 @@ protocols:
 - valory/llm:1.0.0:bafybeihj2orqapokafg7co3wlogwgf6cckaaj2bz3nuv4rm3opkoyhrlp4
 skills:
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 behaviours:
   main:
     args: {}

packages/valory/skills/twitter_scoring_abci/skill.yaml

@@ -32,7 +32,7 @@ protocols:
 - valory/contract_api:1.0.0:bafybeid247uig2ekykdumh7ewhp2cdq7rchaeqjj6e7urx35zfpdl5zrn4
 skills:
 - valory/abstract_round_abci:0.1.0:bafybeigyuls35k6rc2x5j5pcnrghfyojzqzjshhfoaco47ctfm3wjiapce
-- valory/decision_making_abci:0.1.0:bafybeia67wc3iozuyhymm5lsuji23vmqcpg7aulgw7pwmt4gl2743kvila
+- valory/decision_making_abci:0.1.0:bafybeihcblk4f2dadn2g2d3nkmbjf46qhhjzqqiw6upji65jo4rbfagumm
 - valory/mech_interact_abci:0.1.0:bafybeight53ip54jyhor7ylssmvfuxhmq666bamn3pjw3q55pm6x7av54a
 behaviours:
   main:

scripts/ceramic/streams.py

@@ -34,7 +34,8 @@
 # CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw146hft9w4phn07lb9y9sa5rrm8lvk1yl3e9zs7tvqgwx5mh7q6at"  # Jan 13th 2025
 # CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw149np6pye4uqwnes4kk1ulmotny52zgq11vpj27m00g1hvjun47h"  # Feb 3rd 2025 - failed clone
 # CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw14bdkz45jyguv0iii50v4av34rvbe5gdyoelvrgcjp8szrg1myhb"  # Feb 5th 2025
-CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw147hzu1c0hwzb0v7gcqn9ykcqzn0r72dn8gkvlp7c1hcjw3p50fs"    # Feb 7th 2025
+# CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw147hzu1c0hwzb0v7gcqn9ykcqzn0r72dn8gkvlp7c1hcjw3p50fs"  # Feb 7th 2025
+CONTRIBUTE_PROD_DB_STREAM_ID = "kjzl6cwe1jw148aoo6gsals6kkat9bjvaxgqrr2qnz877t0ex9s3ziywyjsgvx7"    # Feb 14th 2025
 
 
 # Centaurs DB

scripts/clone_contribute_streams.py

@@ -115,18 +115,6 @@ def main():
     # Get the prod data
     user_db, _, _ = ceramic.get_data(CONTRIBUTE_PROD_DB_STREAM_ID)
 
-    # Update multisigs and service_ids
-    for user_data in user_db["users"].values():
-
-        if user_data["service_multisig"]:
-            user_data["service_multisig_old"] = user_data["service_multisig"]
-            user_data["service_multisig"] = None
-
-        if user_data["service_id"]:
-            user_data["service_id_old"] = user_data["service_id"]
-            user_data["service_id"] = None
-
-
     # Clone into a new stream
     stream_id = user_db_batch_write(
         did=ceramic_did_str,