import os from datetime import datetime from dotenv import load_dotenv from supabase import create_client load_dotenv() SUPA = create_client(os.environ.get('SUPABASE_URL'), os.environ.get('SUPABASE_KEY')) def log_message_data_through_supabase_api(table_name, log_data): return SUPA.table(table_name).insert(log_data).execute() def format_datetime_in_isoformat(dt): return getattr(dt.now(), 'isoformat', lambda x: None)() def prepare_message_data_for_logging(message_data): project_data = { 'name': "turn.io", # Autogenerated fields: id, created_at, modified_at } project_data_log = log_message_data_through_supabase_api('project', project_data) contact_data = { 'project': project_data_log.data[0]['id'], # FK 'original_contact_id': message_data['message']['_vnd']['v1']['chat']['contact_uuid'], 'urn': "", 'language_code': "en", 'contact_inserted_at': format_datetime_in_isoformat(datetime.now()) # Autogenerated fields: id, created_at, modified_at } contact_data_log = log_message_data_through_supabase_api('contact', contact_data) message_data = { 'contact': contact_data_log.data[0]['id'], # FK 'original_message_id': message_data['message']['id'], 'text': message_data['message']['text']['body'], 'direction': message_data['message']['_vnd']['v1']['direction'], 'sender_type': message_data['message']['_vnd']['v1']['author']['type'], 'channel_type': "whatsapp / turn.io", 'message_inserted_at': message_data['message']['_vnd']['v1']['chat']['inserted_at'], 'message_modified_at': message_data['message']['_vnd']['v1']['chat']['updated_at'], 'message_sent_at': format_datetime_in_isoformat(datetime.now()) # Autogenerated fields: created_at, modified_at } message_data_log = log_message_data_through_supabase_api('message', message_data)