mathtext_fastapi/nlu.py

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)