Clarification about incoming connections

[alienhunter3]

Hi

First, I found this module recently, and it looks absolutely perfect for a project that I have been trying to work on! Thanks for putting so much work into it!

I have a question that I haven't been able to work out for myself from the documentation yet:

If I have an application (just a pe.app.Application instance) and I have defined a custom connection class, what else do I have to do to process incoming connections?

I can see from direwolf logs and my connecting side that a connection has been created and allowed (regardless of whether my connection class has a query_accept method or not), but has the application or the engine created an instance of my connection class for that connection and placed it somewhere? Where do I get access to that? Do I have to have a receive handler defined and registered with my application's engine in order to create one?

If I add code to my connection class to have it add itself to a global list upon initialization, it works when I initiate the connection, but not when a connection is received.

Sorry if this is obvious!

Thanks!

import pe.app
import queue

connections = []

class MyConnection(pe.connect.Connection):
    def __init__(self, port, call_from, call_to, incoming=False):
        super().__init__(port, call_from, call_to, incoming)
        # Now perform any initialization of your own that you might need
        self.data = queue.Queue()

    def connected(self):
        connections.append(self)
        print("connected")
        # Now your connection is open

    def disconnected(self):
        print("disconnected")
        # Your connection is no longer open

    def data_received(self, pid, data):
        self.data.put(data)
        print(data)
        # Process your received data

    @classmethod
    def query_accept(port, call_from, call_to):
        return True

a = pe.app.Application()
a.start('localhost', 8000)

[alienhunter3]

Nevermind! My query_accept method had the wrong signature. Everything works. Cheers!