IPFS_DataTransmission.py

from ipfs_datatransmission import (
    TRANSM_SEND_TIMEOUT_SEC,
    TRANSM_REQ_MAX_RETRIES,
    TRANSM_RECV_TIMEOUT_SEC,
    BUFFER_SIZE,
    BLOCK_SIZE,
    transmit_data,
    listen_for_transmissions,
    TransmissionListener,
    start_conversation,
    listen_for_conversations,
    Conversation,
    ConversationListener,
    transmit_file,
    listen_for_file_transmissions,
    FileTransmitter,
    FileTransmissionReceiver,
    listen_to_buffers,
    listen_to_buffers_on_port,
    BufferSender,
    BufferReceiver,
)
from termcolor import colored
print(colored("IPFS_DataTransmission: DEPRECATED: The IPFS_DataTransmission module has been renamed to ipfs_datatransmission.ipfs_datatransmission to accord with PEP 8 naming conventions.", "yellow"))

# TODO: DEPRECATION WARNINGS


def TransmitData(
        data: bytes,
        peerID: str,
        req_lis_name: str,
        timeout_sec: int = TRANSM_SEND_TIMEOUT_SEC,
        max_retries: int = TRANSM_REQ_MAX_RETRIES):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.TransmitData) has been renamed to ipfs_datatransmission.transmit_data to accord with PEP 8 naming conventions.", "yellow"))
    return transmit_data(
        data,
        peerID,
        req_lis_name,
        timeout_sec=timeout_sec,
        max_retries=max_retries)


def ListenForTransmissions(listener_name, eventhandler):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.ListenForTransmissions) has been renamed to ipfs_datatransmission.listen_for_transmissions to accord with PEP 8 naming conventions.", "yellow"))
    return listen_for_transmissions(listener_name, eventhandler)


def StartConversation(conv_name,
                      peerID,
                      others_req_listener,
                      data_received_eventhandler=None,
                      file_eventhandler=None,
                      file_progress_callback=None,
                      encryption_callbacks=None,
                      timeout_sec=TRANSM_SEND_TIMEOUT_SEC,
                      max_retries=TRANSM_REQ_MAX_RETRIES,
                      dir="."):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.StartConversation) has been renamed to ipfs_datatransmission.start_conversation to accord with PEP 8 naming conventions.", "yellow"))
    return start_conversation(conv_name,
                              peerID,
                              others_req_listener,
                              data_received_eventhandler=data_received_eventhandler,
                              file_eventhandler=file_eventhandler,
                              file_progress_callback=file_progress_callback,
                              encryption_callbacks=encryption_callbacks,
                              timeout_sec=timeout_sec,
                              max_retries=max_retries,
                              dir=dir)


def ListenForConversations(conv_name, eventhandler):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.ListenForConversations) has been renamed to ipfs_datatransmission.listen_for_conversations to accord with PEP 8 naming conventions.", "yellow"))
    return listen_for_conversations(conv_name, eventhandler)


def TransmitFile(filepath,
                 peerID,
                 others_req_listener,
                 metadata=bytearray(),
                 progress_handler=None,
                 encryption_callbacks=None,
                 block_size=BLOCK_SIZE,
                 transmission_send_timeout_sec=TRANSM_SEND_TIMEOUT_SEC,
                 transmission_request_max_retries=TRANSM_REQ_MAX_RETRIES
                 ):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.TransmitFile) has been renamed to ipfs_datatransmission.transmit_file to accord with PEP 8 naming conventions.", "yellow"))
    return transmit_file(filepath,
                         peerID,
                         others_req_listener,
                         metadata=metadata,
                         progress_handler=progress_handler,
                         encryption_callbacks=encryption_callbacks,
                         block_size=block_size,
                         transm_send_timeout_sec=transmission_send_timeout_sec,
                         transm_req_max_retries=transmission_request_max_retries
                         )


def ListenForFileTransmissions(listener_name,
                               eventhandler,
                               progress_handler=None,
                               dir=".",
                               encryption_callbacks=None):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.ListenForFileTransmissions) has been renamed to ipfs_datatransmission.listen_for_file_transmissions to accord with PEP 8 naming conventions.", "yellow"))
    return listen_for_file_transmissions(listener_name,
                                         eventhandler,
                                         progress_handler=progress_handler,
                                         dir=dir,
                                         encryption_callbacks=encryption_callbacks)


def SendBufferToPort(buffer, addr, port):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.SendBufferToPort) has been removed in ipfs_api.", "yellow"))
    import socket
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    sock.sendto(buffer, (addr, port))


def ListenToBuffersOnPort(eventhandler,
                          port=0,
                          buffer_size=BUFFER_SIZE,
                          monitoring_interval=2,
                          status_eventhandler=None):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.ListenToBuffersOnPort) has been renamed to ipfs_datatransmission.listen_to_buffers_on_port to accord with PEP 8 naming conventions.", "yellow"))
    return listen_to_buffers_on_port(eventhandler,
                                     port=port,
                                     buffer_size=buffer_size,
                                     monitoring_interval=monitoring_interval,
                                     status_eventhandler=status_eventhandler)


def ListenToBuffers(eventhandler,
                    proto,
                    buffer_size=BUFFER_SIZE,
                    monitoring_interval=2,
                    status_eventhandler=None,
                    eventhandlers_on_new_threads=True):
    print(colored("IPFS_DataTransmission: DEPRECATED: This function (IPFS_DataTransmission.ListenToBuffersConversation.) has been renamed to ipfs_datatransmission.listen_to_buffers to accord with PEP 8 naming conventions.", "yellow"))
    return listen_to_buffers(eventhandler,
                             proto,
                             buffer_size=buffer_size,
                             monitoring_interval=monitoring_interval,
                             status_eventhandler=status_eventhandler,
                             eventhandlers_on_new_threads=eventhandlers_on_new_threads)


"""Methods for classes:"""


def __ConversationStart(self,
                        conv_name,
                        peerID,
                        others_req_listener,
                        data_received_eventhandler=None,
                        file_eventhandler=None,
                        file_progress_callback=None,
                        encryption_callbacks=None,
                        transmission_send_timeout_sec=TRANSM_SEND_TIMEOUT_SEC,
                        transmission_request_max_retries=TRANSM_REQ_MAX_RETRIES,
                        dir="."
                        ):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Start) has been renamed to start to accord with PEP 8 naming conventions.", "yellow"))
    return self.start(conv_name,
                      peerID,
                      others_req_listener,
                      data_received_eventhandler=data_received_eventhandler,
                      file_eventhandler=file_eventhandler,
                      file_progress_callback=file_progress_callback,
                      encryption_callbacks=encryption_callbacks,
                      transm_send_timeout_sec=transmission_send_timeout_sec,
                      transm_req_max_retries=transmission_request_max_retries,
                      dir=dir
                      )


def __ConversationJoin(self,
                       conv_name,
                       peerID,
                       others_trsm_listener,
                       data_received_eventhandler=None,
                       file_eventhandler=None,
                       file_progress_callback=None,
                       encryption_callbacks=None,
                       transmission_send_timeout_sec=TRANSM_SEND_TIMEOUT_SEC,
                       transmission_request_max_retries=TRANSM_REQ_MAX_RETRIES,
                       dir="."):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Join) has been renamed to join to accord with PEP 8 naming conventions.", "yellow"))
    self.join(conv_name,
              peerID,
              others_trsm_listener,
              data_received_eventhandler=data_received_eventhandler,
              file_eventhandler=file_eventhandler,
              file_progress_callback=file_progress_callback,
              encryption_callbacks=encryption_callbacks,
              transm_send_timeout_sec=transmission_send_timeout_sec,
              transm_req_max_retries=transmission_request_max_retries,
              dir=dir)


def __ConversationListen(self, timeout=None):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Listen) has been renamed to listen to accord with PEP 8 naming conventions.", "yellow"))
    return self.listen(timeout=None)


def __ConversationListenForFile(self, abs_timeout=None, no_coms_timeout=None):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (ListenForFile) has been renamed to listen_for_file to accord with PEP 8 naming conventions.", "yellow"))
    return self.listen_for_file(abs_timeout=None, no_coms_timeout=None)


def __ConversationSay(self,
                      data,
                      timeout_sec=Conversation._transm_send_timeout_sec,
                      max_retries=Conversation._transm_req_max_retries
                      ):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Say) has been renamed to say to accord with PEP 8 naming conventions.", "yellow"))
    return self.say(
        data,
        timeout_sec=timeout_sec,
        max_retries=max_retries
    )


def __ConversationTransmitFile(self,
                               filepath,
                               metadata=bytearray(),
                               progress_handler=Conversation.file_progress_callback,
                               block_size=BLOCK_SIZE,
                               TRANSM_SEND_TIMEOUT_SEC=Conversation._transm_send_timeout_sec,
                               TRANSM_REQ_MAX_RETRIES=Conversation._transm_req_max_retries
                               ):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (TransmitFile) has been renamed to transmit_file to accord with PEP 8 naming conventions.", "yellow"))
    return self.transmit_file(
        filepath,
        metadata=metadata,
        progress_handler=progress_handler,
        block_size=block_size,
        transm_send_timeout_sec=TRANSM_SEND_TIMEOUT_SEC,
        transm_req_max_retries=TRANSM_REQ_MAX_RETRIES
    )


def __ConversationTerminate(self):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Terminate) has been renamed to terminate to accord with PEP 8 naming conventions.", "yellow"))
    return self.terminate()


def __ConversationClose(self):
    print(colored("IPFS_DataTransmission.Conversation: DEPRECATED: This function (Close) has been renamed to terminate to accord with PEP 8 naming conventions.", "yellow"))
    return self.terminate()


Conversation.Start = __ConversationStart
Conversation.Join = __ConversationJoin
Conversation.Listen = __ConversationListen
Conversation.ListenForFile = __ConversationListenForFile
Conversation.Say = __ConversationSay
Conversation.TransmitFile = __ConversationTransmitFile
Conversation.Terminate = __ConversationTerminate
Conversation.Close = __ConversationClose


def __FileTransmitterStart(self):
    print(colored("IPFS_DataTransmission.FileTransmitter: DEPRECATED: This function is no longer implemented in ipfs_api as file transmissions now start automatically.", "yellow"))
    return


FileTransmitter.Start = __FileTransmitterStart