app.py

"""
Simple Twitter/X posting microservice
Uses requests-oauthlib for OAuth 1.0a signing
Deploy to Railway, call from n8n
"""

import os
from flask import Flask, request, jsonify
from requests_oauthlib import OAuth1Session

app = Flask(__name__)

# Load from environment variables
API_KEY = os.environ.get('TWITTER_API_KEY')
API_SECRET = os.environ.get('TWITTER_API_SECRET')
ACCESS_TOKEN = os.environ.get('TWITTER_ACCESS_TOKEN')
ACCESS_TOKEN_SECRET = os.environ.get('TWITTER_ACCESS_TOKEN_SECRET')
WEBHOOK_SECRET = os.environ.get('WEBHOOK_SECRET', 'change-me-in-production')

def get_twitter_session():
    """Create OAuth1 session for Twitter API v2"""
    return OAuth1Session(
        API_KEY,
        client_secret=API_SECRET,
        resource_owner_key=ACCESS_TOKEN,
        resource_owner_secret=ACCESS_TOKEN_SECRET
    )

@app.route('/health', methods=['GET'])
def health():
    return jsonify({"status": "ok"})

@app.route('/tweet', methods=['POST'])
def post_tweet():
    # Simple auth check
    auth_header = request.headers.get('Authorization', '')
    if auth_header != f'Bearer {WEBHOOK_SECRET}':
        return jsonify({"error": "Unauthorized"}), 401
    
    data = request.get_json()
    if not data or 'text' not in data:
        return jsonify({"error": "Missing 'text' field"}), 400
    
    tweet_text = data['text']
    
    try:
        twitter = get_twitter_session()
        response = twitter.post(
            "https://api.twitter.com/2/tweets",
            json={"text": tweet_text}
        )
        
        if response.status_code == 201:
            result = response.json()
            return jsonify({
                "success": True,
                "tweet_id": result['data']['id'],
                "text": tweet_text
            })
        else:
            return jsonify({
                "success": False,
                "status_code": response.status_code,
                "error": response.text
            }), response.status_code
            
    except Exception as e:
        return jsonify({
            "success": False,
            "error": str(e)
        }), 500

if __name__ == '__main__':
    port = int(os.environ.get('PORT', 8080))
    app.run(host='0.0.0.0', port=port)
```

---