Add cloudevent support

[linakrisztian]

This PR adds the general functionality of the cloudevent (including setup + tests), which is: receival of cloudevent, conversion to actinia pc, and return of cloudevent. The actual implementation for starting the pc will be done in a separate PR (see also below)

Done in a separate PR (might also need discussion):

• pc to actinia + start job (see also notes within core/processing.py, function cloud_event_to_process_chain()
• decide for structured vs. binary cloudevents: see also api/cloudevent.py

[github-actions]

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

ruff

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/main.py

Line 73 in 4a39560

if __name__ == '__main__':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/main.py

Line 75 in 4a39560

log.debug('starting app in development mode...')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 2 to 4 in 4a39560

	# -*- coding: utf-8 -*-
	"""
	Copyright (c) 2018-2021 mundialis GmbH & Co. KG

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Line 28 in 4a39560

import glob

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 35 to 36 in 4a39560

	DEFAULT_CONFIG_PATH).glob('**/*.ini') if f.is_file()]
	GENERATED_CONFIG = DEFAULT_CONFIG_PATH + '/actinia-cloudevent-plugin.cfg'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 40 to 43 in 4a39560

	"""Default config for app and api doc
	"""
	version = '0.0.0'
	url = 'http://localhost:8080'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 47 to 56 in 4a39560

	"""Default config for database connection for jobtabelle
	"""
	host = 'localhost'
	port = '5432'
	database = 'gis'
	user = 'gis'
	pw = 'gis'
	schema = 'actinia'
	table = 'tab_jobs'
	id_field = 'idpk_jobs'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 60 to 64 in 4a39560

	"""Default config for logging
	"""
	logfile = 'actinia-cloudevent-plugin.log'
	level = 'DEBUG'
	type = 'stdout'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 68 to 75 in 4a39560

	"""Default config for actinia_core
	"""
	url = 'http://localhost:1236/api/v1/'
	user = 'actinia'
	filestorage = ''
	password = 'actinia'
	esa_apihub_user = 'changeme'
	esa_apihub_pw = 'changeme'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 79 to 84 in 4a39560

	"""Default config for database connection for geodata database
	"""
	host = 'localhost'
	port = '5432'
	database = 'gis'
	user = 'gis'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 89 to 91 in 4a39560

	def __init__(self):
	"""
	This class will overwrite the config classes above when config files

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Line 95 in 4a39560

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Line 104 in 4a39560

with open(GENERATED_CONFIG, 'w') as configfile:

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 2 to 4 in 4a39560

	# -*- coding: utf-8 -*-
	"""
	Copyright (c) 2025 mundialis GmbH & Co. KG

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 37 in 4a39560

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 41 to 43 in 4a39560

	log = logging.getLogger('actinia-cloudevent-plugin')
	werkzeugLog = logging.getLogger('werkzeug')
	gunicornLog = logging.getLogger('gunicorn')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 48 to 52 in 4a39560

	if LOGCONFIG.type == 'json' and not veto:
	logformat = CustomJsonFormatter('%(time) %(level) %(component)'
	'%(module) %(message) %(pathname)'
	'%(lineno) %(processName)'
	'%(threadName)')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 55 to 56 in 4a39560

	'%(log_color)s[%(asctime)s] %(levelname)-10s: %(name)s.%(module)-'
	'10s -%(message)s [in %(pathname)s:%(lineno)d]%(reset)s'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 61 to 62 in 4a39560

	def setLogHandler(logger, type, format):
	if type == 'stdout':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 64 in 4a39560

elif type == 'file':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 72 to 73 in 4a39560

	def add_fields(self, log_record, record, message_dict):
	super(CustomJsonFormatter, self).add_fields(

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 82 to 85 in 4a39560

	now = datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S.%fZ')
	log_record['time'] = now
	log_record['level'] = record.levelname
	log_record['component'] = record.name

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 88 in 4a39560

def createLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 91 in 4a39560

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 93 to 94 in 4a39560

	setLogHandler(log, 'file', fileformat)
	setLogHandler(log, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 97 in 4a39560

def createWerkzeugLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 99 in 4a39560

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 101 to 102 in 4a39560

	setLogHandler(werkzeugLog, 'file', fileformat)
	setLogHandler(werkzeugLog, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 105 in 4a39560

def createGunicornLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 107 in 4a39560

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 109 to 110 in 4a39560

	setLogHandler(gunicornLog, 'file', fileformat)
	setLogHandler(gunicornLog, 'stdout', stdoutformat)

[github-actions]

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

ruff

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 35 to 36 in a99d5ca

	DEFAULT_CONFIG_PATH).glob('**/*.ini') if f.is_file()]
	GENERATED_CONFIG = DEFAULT_CONFIG_PATH + '/actinia-cloudevent-plugin.cfg'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 40 to 43 in a99d5ca

	"""Default config for app and api doc
	"""
	version = '0.0.0'
	url = 'http://localhost:8080'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 47 to 56 in a99d5ca

	"""Default config for database connection for jobtabelle
	"""
	host = 'localhost'
	port = '5432'
	database = 'gis'
	user = 'gis'
	pw = 'gis'
	schema = 'actinia'
	table = 'tab_jobs'
	id_field = 'idpk_jobs'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 60 to 64 in a99d5ca

	"""Default config for logging
	"""
	logfile = 'actinia-cloudevent-plugin.log'
	level = 'DEBUG'
	type = 'stdout'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 68 to 75 in a99d5ca

	"""Default config for actinia_core
	"""
	url = 'http://localhost:1236/api/v1/'
	user = 'actinia'
	filestorage = ''
	password = 'actinia'
	esa_apihub_user = 'changeme'
	esa_apihub_pw = 'changeme'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 79 to 84 in a99d5ca

	"""Default config for database connection for geodata database
	"""
	host = 'localhost'
	port = '5432'
	database = 'gis'
	user = 'gis'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Lines 89 to 91 in a99d5ca

	def __init__(self):
	"""
	This class will overwrite the config classes above when config files

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Line 95 in a99d5ca

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/config.py

Line 104 in a99d5ca

with open(GENERATED_CONFIG, 'w') as configfile:

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 2 to 4 in a99d5ca

	# -*- coding: utf-8 -*-
	"""
	Copyright (c) 2025 mundialis GmbH & Co. KG

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 37 in a99d5ca

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 41 to 43 in a99d5ca

	log = logging.getLogger('actinia-cloudevent-plugin')
	werkzeugLog = logging.getLogger('werkzeug')
	gunicornLog = logging.getLogger('gunicorn')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 48 to 52 in a99d5ca

	if LOGCONFIG.type == 'json' and not veto:
	logformat = CustomJsonFormatter('%(time) %(level) %(component)'
	'%(module) %(message) %(pathname)'
	'%(lineno) %(processName)'
	'%(threadName)')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 55 to 56 in a99d5ca

	'%(log_color)s[%(asctime)s] %(levelname)-10s: %(name)s.%(module)-'
	'10s -%(message)s [in %(pathname)s:%(lineno)d]%(reset)s'

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 61 to 62 in a99d5ca

	def setLogHandler(logger, type, format):
	if type == 'stdout':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 64 in a99d5ca

elif type == 'file':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 72 to 73 in a99d5ca

	def add_fields(self, log_record, record, message_dict):
	super(CustomJsonFormatter, self).add_fields(

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 82 to 85 in a99d5ca

	now = datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S.%fZ')
	log_record['time'] = now
	log_record['level'] = record.levelname
	log_record['component'] = record.name

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 88 in a99d5ca

def createLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 91 in a99d5ca

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 93 to 94 in a99d5ca

	setLogHandler(log, 'file', fileformat)
	setLogHandler(log, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 97 in a99d5ca

def createWerkzeugLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 99 in a99d5ca

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 101 to 102 in a99d5ca

	setLogHandler(werkzeugLog, 'file', fileformat)
	setLogHandler(werkzeugLog, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 105 in a99d5ca

def createGunicornLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 107 in a99d5ca

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 109 to 110 in a99d5ca

	setLogHandler(gunicornLog, 'file', fileformat)
	setLogHandler(gunicornLog, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/wsgi.py

Lines 22 to 23 in a99d5ca

	from actinia_cloudevent_plugin.main import app as application

[github-actions]

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

ruff

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 64 in 25b6374

elif type == 'file':

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 72 to 73 in 25b6374

	def add_fields(self, log_record, record, message_dict):
	super(CustomJsonFormatter, self).add_fields(

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 82 to 85 in 25b6374

	now = datetime.utcnow().strftime('%Y-%m-%dT%H:%M:%S.%fZ')
	log_record['time'] = now
	log_record['level'] = record.levelname
	log_record['component'] = record.name

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 88 in 25b6374

def createLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 91 in 25b6374

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 93 to 94 in 25b6374

	setLogHandler(log, 'file', fileformat)
	setLogHandler(log, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 97 in 25b6374

def createWerkzeugLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 99 in 25b6374

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 101 to 102 in 25b6374

	setLogHandler(werkzeugLog, 'file', fileformat)
	setLogHandler(werkzeugLog, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 105 in 25b6374

def createGunicornLogger():

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Line 107 in 25b6374

fileformat = setLogFormat('veto')

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/resources/logging.py

Lines 109 to 110 in 25b6374

	setLogHandler(gunicornLog, 'file', fileformat)
	setLogHandler(gunicornLog, 'stdout', stdoutformat)

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/src/actinia_cloudevent_plugin/wsgi.py

Lines 22 to 23 in 25b6374

	from actinia_cloudevent_plugin.main import app as application

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Lines 4 to 5 in 25b6374

	from flask import Flask, request

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 7 in 25b6374

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 10 in 25b6374

@app.route("/", methods=["POST"])

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 18 in 25b6374

f"{event['type']} and specversion {event['specversion']}"

[github-actions]

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

ruff

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 7 in 563af7d

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 10 in 563af7d

@app.route("/", methods=["POST"])

---

[ruff] _{reported by reviewdog 🐶}

actinia-cloudevent-plugin/tests/cloudevent_receiver_server.py

Line 18 in 563af7d

f"{event['type']} and specversion {event['specversion']}"

[mmacata]

Very cool, thanks!