from flask import Flask, request from flask_restx import Api, Resource, fields import os from datetime import datetime app = Flask(__name__) api = Api(app, version='1.0', title='CCTV Image Upload API', description='A simple API for receiving CCTV images') # Namespace definition ns = api.namespace('cctv', description='CCTV operations') # Define the expected model for incoming data image_upload_model = api.model('ImageUpload', { 'image': fields.String(required=True, description='Image file', dt='File'), 'x-cctv-info': fields.String(required=False, description='CCTV identifier'), 'x-time-sent': fields.String(required=False, description='Time image was sent'), 'x-cctv-latitude': fields.String(required=False, description='Latitude of CCTV'), 'x-cctv-longitude': fields.String(required=False, description='Longitude of CCTV') }) # Define the directory where images will be saved IMAGE_DIR = "received_images" if not os.path.exists(IMAGE_DIR): os.makedirs(IMAGE_DIR) @ns.route('/infer', ) class ImageUpload(Resource): # @ns.expect(image_upload_model, validate=True) @ns.response(200, 'Success') @ns.response(400, 'Validation Error') def post(self): if 'file' not in request.files: ns.abort(400, 'No image part in the request') image = request.files['file'] cctv_info = request.headers.get('x-cctv-info', '') time_sent = request.headers.get('x-time-sent', '') cctv_latitude = request.headers.get('x-cctv-latitude', 'Not provided') cctv_longitude = request.headers.get('x-cctv-longitude', 'Not provided') if image.filename == '': ns.abort(400, 'No selected image') # Use current timestamp to avoid filename conflicts timestamp = datetime.now().strftime("%Y%m%d_%H%M%S") filename = f"{timestamp}_{cctv_info}.png" image_path = os.path.join(IMAGE_DIR, filename) image.save(image_path) return {"message": f"Image {filename} uploaded successfully!"} if __name__ == '__main__': app.run(debug=True, port=12345)