"""Constants for kinesis and maxwell."""
from config import TABLES_TO_LOG

# kinesis record's fields
EVENT_RECORDS = 'Records'
RECORD_KINESIS = 'kinesis'
KINESIS_DATA = 'data'

# maxwell record structure
MAXWELL_TABLE = 'table'
MAXWELL_TYPE = 'type'
MAXWELL_DATA = 'data'
MAXWELL_TIMESTAMP = 'ts'

# sql operation types from maxwell
TYPE_INSERT = 'insert'
TYPE_UPDATE = 'update'
TYPE_DELETE = 'delete'

ALLOWED_OPERATIONS = [
    TYPE_INSERT,
    TYPE_UPDATE,
    TYPE_DELETE
]

TABLES_TO_LOG = [
    table.strip() for table in TABLES_TO_LOG.split(',') if table.strip()
]