Merge pull request #3 from allora-network/diego/ora-1199-coin-predict…

…ion-reputer-deployment-for-devnet

Minor fixes and README

.gitignore

@@ -7,3 +7,4 @@ logs/*
 worker-data
 head-data
 truth-data
+prices.db

Dockerfile_b7s

@@ -1,4 +1,4 @@
-FROM --platform=linux/amd64 alloranetwork/allora-inference-base:latest
+FROM --platform=linux/amd64 allora-inference-base:dev-latest
 
 USER root
 RUN pip install requests

README.md

@@ -24,6 +24,8 @@ The `Dockerfile_b7s` file is functional but simple, so you may want to change it
 
 For further details, please check the base repo [allora-inference-base](https://github.com/allora-network/allora-inference-base).
 
+Note: The reputers use an internal blockless topic adding the suffix `/reputer` to be added to the `--topic` flag, but not to the `--allora-chain-topic-id`. 
+
 ###  Application path
 
 By default, the application runtime lives under `/app`, as well as the Python code the worker provides (`/app/main.py`). The current user needs to have write permissions on `/app/runtime`.

app.py

@@ -50,7 +50,7 @@ def update_price(token_name, token_from, token_to):
             return jsonify({'error': 'Invalid token ID'}), 400
 
         timestamp = int(datetime.now().timestamp())
-        token = token_name.upper()
+        token = token_name.lower()
 
         # Save price into database
         conn = sqlite3.connect(DATABASE_PATH)
@@ -84,7 +84,7 @@ def init_price_token(token_name, token_from, token_to):
         # Check if there is any existing data for the specified token
         conn = sqlite3.connect(DATABASE_PATH)
         cursor = conn.cursor()
-        cursor.execute("SELECT COUNT(*) FROM prices WHERE token=? LIMIT 1", (token_name.upper(),))
+        cursor.execute("SELECT COUNT(*) FROM prices WHERE token=? LIMIT 1", (token_name.lower(),))
         count = cursor.fetchone()[0]
         conn.close()
 
@@ -111,7 +111,7 @@ def init_price_token(token_name, token_from, token_to):
         for data_point in historical_data:
             timestamp = int(data_point[0] / 1000)  # Convert milliseconds to seconds
             price = data_point[1]
-            cursor.execute("INSERT INTO prices (timestamp, token, price) VALUES (?, ?, ?)", (timestamp, token_name.upper(), price))
+            cursor.execute("INSERT INTO prices (timestamp, token, price) VALUES (?, ?, ?)", (timestamp, token_name.lower(), price))
             print(f"inserting data point {timestamp} : {price}" )
         conn.commit()
         conn.close()

docker-compose.yml

@@ -45,7 +45,7 @@ services:
           --runtime-path=/app/runtime --runtime-cli=bls-runtime --workspace=/data/workspace \
           --private-key=/data/keys/priv.bin --log-level=debug --port=9011 \
           --boot-nodes=/ip4/172.20.0.100/tcp/9010/p2p/12D3KooWNbKMnvUWZ2e3Z5bm4GzSJht7SALzpW2MsS2CBKfXuFfK \
-          --topic=1
+          --topic=1/reputer
     volumes:
       - ./worker-data:/data
     working_dir: /data