import jwt
import datetime
import hmac
import hashlib
from protos import agent_pb2
from agent_node.config import SECRET_KEY
def create_auth_token(node_id: str) -> str:
"""Creates a JWT for node authentication."""
payload = {
"sub": node_id,
"iat": datetime.datetime.utcnow(),
"exp": datetime.datetime.utcnow() + datetime.timedelta(minutes=10)
}
return jwt.encode(payload, SECRET_KEY, algorithm="HS256")
def verify_task_signature(task, secret=SECRET_KEY) -> bool:
"""Verifies HMAC signature for task payloads."""
sign_base = task.payload_json
expected_sig = hmac.new(secret.encode(), sign_base.encode(), hashlib.sha256).hexdigest()
return hmac.compare_digest(task.signature, expected_sig)