Right, that leads to

nio.exceptions.LocalProtocolError: Matrix store and olm account is not loaded.

async def main() -> None:
    client = AsyncClient("https://matrix.org", uname)
    client.add_event_callback(message_callback, RoomMessageText)

    print(await client.login(pw))

    client.import_keys(  # This instruction causes the exception
        '/home/daniel/Downloads/element-keys.txt',
        pasphrase,
    )

    await client.sync_forever(timeout=30000) # milliseconds

asyncio.get_event_loop().run_until_complete(main())

Do i need to initialized a store or some olm

Right, that leads to

nio.exceptions.LocalProtocolError: Matrix store and olm account is not loaded.

async def main() -> None:
    client = AsyncClient("https://matrix.org", uname)
    client.add_event_callback(message_callback, RoomMessageText)

    print(await client.login(pw))

    client.import_keys(
        '/home/daniel/Downloads/element-keys.txt',
        pasphrase,
    )

    await client.sync_forever(timeout=30000) # milliseconds

asyncio.get_event_loop().run_until_complete(main())

Do i need to initialized a store or some olm

Right, that leads to

nio.exceptions.LocalProtocolError: Matrix store and olm account is not loaded.

async def main() -> None:
    client = AsyncClient("https://matrix.org", uname)
    client.add_event_callback(message_callback, RoomMessageText)

    print(await client.login(pw))

    client.import_keys(  # This instruction causes the exception
        '/home/daniel/Downloads/element-keys.txt',
        pasphrase,
    )

    await client.sync_forever(timeout=30000) # milliseconds

asyncio.get_event_loop().run_until_complete(main())

Do i need to initialized a store or some olm

I've managed to set up the encryption issue i had last night. Now I'm attempting to set up a named Sqlite store. If i do not set one, a default db file is created and the data stored to it. If i do create the store, no data is synced to it. Do I need to manually sync the database?

def async_client_factory() -> AsyncClient:
    store = SqliteStore(
        user_id=user_id,
        device_id=device_id,
        store_path=storage_path,
        database_name='storage.db',
    )

    config = AsyncClientConfig(
        max_limit_exceeded=0,
        max_timeouts=0,
        store_sync_tokens=True,
        encryption_enabled=True,
        store=store,
    )
    client = AsyncClient(
        homeserver=homeserver,
        user=user_id,
        config=config,
    )
    return client


async def main() -> None:
    client: AsyncClient = async_client_factory()

    client.add_event_callback(message_callback, RoomMessageText)
    client.add_response_callback(sync_cb, SyncResponse)

    resp = await client.login(password)
    print('client_id:', client.user_id)

    rooms = await client.joined_rooms()
    if isinstance(rooms, JoinedRoomsResponse):
        print('Connected to rooms:', rooms.rooms)

        for _room in rooms.rooms:
            room = MatrixRoom(
                room_id=_room,
                own_user_id=client.user_id,
                encrypted=True,
            )
            print(' -', room.display_name, room, room.member_count)
    await client.sync_forever(timeout=10000) # milliseconds

asyncio.get_event_loop().run_until_complete(main())

In reply to @aaron:raim.ist
(is there an easy way to decrypt the file manually so I can see what was included?)

In reply to @poljar:matrix.org
i think the store shouldn't be opened when you pass it as the store parameter, you just pass the class

In reply to @poljar:matrix.org
i think the established technique for this is to call sync() once manually and then register your callbacks and only then call sync_forever()