async def readMessages(cid):
    offset_id = 0
    limit = 100
    all_messages = []
    total_messages = 0
    total_count_limit = 0

    await client.start()
    # Ensure you're authorized
    if await client.is_user_authorized() == False:
        await client.send_code_request(phone)
        try:
            await client.sign_in(phone, input('Enter the code: '))
        except SessionPasswordNeededError:
            await client.sign_in(password=input('Password: '))
    global canal
    while True:
        print("Current Offset ID is:", offset_id, "; Total Messages:", total_messages)
        canal = await client.get_entity(PeerChannel(my_channel))
        history = await client(GetHistoryRequest(
            peer=my_channel, offset_id=offset_id, offset_date=None,
            add_offset=0, limit=limit, max_id=0, min_id=0, hash=0
        ))
        if not history.messages:
            break
        messages = history.messages
        for message in messages:
            print('message.text ' + message.text)
            print('message.raw_text ' + message.raw_text)
            all_messages.append(message.to_dict())
        offset_id = messages[len(messages) - 1].id
        total_messages = len(all_messages)
        if total_count_limit != 0 and total_messages >= total_count_limit:
            break
    return messages