from collections import OrderedDict
from cam_server.pipeline.data_processing import functions
from logging import getLogger

_logger = getLogger(__name__)

def process_image(image, pulse_id, timestamp, x_axis, y_axis, parameters, bsdata):
    ret = OrderedDict()
    prefix = parameters["camera_name"]
    (x_profile, y_profile) = functions.get_x_y_profile(image)
    
    intensity = int(x_profile.sum())
    #ret[prefix+":intensity"] = intensity
    ret[prefix+":EVENT_NUM"] = intensity

    return ret