from pulsar.schema import *
import pulsar
import time
from dataclasses import dataclass
from typing import List
import uuid
from datetime import datetime


def post_data():
    class AuditEvent(Record):
        event = String()
        description = String()
        affected_id= String()
        affected_type= String()
        actor_id=String()
        actor_type=String()
    
    print("schema creation in process")
    client = pulsar.Client('<pulsar://localhost:6650>')
    time.sleep(5)

    producer = client.create_producer(
        topic='public/default/audit_file',
        schema=JsonSchema(AuditEvent),
    )

    print("post_data")
    producer.send(AuditEvent(
                            event='audit', 
                            description='Creating Event',
                            affected_id='328006c1-793f-43be-93824906',
                            affected_type='ACTOR_TYPE_SERVICE',
                            actor_id='018ac9c5-f594-722f-aeda7524b7a',
                            actor_type='ACTOR_TYPE_SERVICE'
                            )
                )
    
    
    print("data posted")


post_data()

120s

120s