path: root/python-wscomsrv.spec

%global _empty_manifest_terminate_build 0
Name:		python-WsComSrv
Version:	0.1.1555408076
Release:	1
Summary:	A basic websocket communication server
License:	MIT License
URL:		https://github.com/JulianKimmig/websocket_communication_server
Source0:	https://mirrors.aliyun.com/pypi/web/packages/52/68/30fd01b86b9d08ba1ccaec7099da3bcdc62835fe453e04195dce8e475103/WsComSrv-0.1.1555408076.tar.gz
BuildArch:	noarch

Requires:	python3-FilterDict
Requires:	python3-websocket-client
Requires:	python3-websockets

%description
##Server
A socket server which allows to communicate between websocket clients 
and send commands between them.
The server can be incoken by  
`socketserver = SockerServer()`  
by default the server uses 127.0.0.1 (normaly equally to 'localhost') as the host and the port 8888.  
This can be changed to any other host/port by using respective arguments:  
`socketserver = SockerServer(port='localhost',port=8888)`  

If the Server cannot bind to the host:port pair an OSError is thrown.
This can be used to connect to the first free port
```
SOCKETPORT=8888
notconnected = True
socketserver = None
while notconnected:
    try:
        socketserver = SockerServer(port=SOCKETPORT)
        notconnected = False
    except:
        SOCKETPORT += 1
```
after the port is opened it can be run constantly by calling:  
`socketserver.run_forever()`

By default the server ask any connected client for a identification and sends a time stamp which can be used for time synchronization (see below)

##Client
The package comes also with a client.
To invoke a client use:  
`wsc = WebSocketClient("name",host="ws://127.0.0.1:8888")`   
The name should be unique and the host has to be changed match the socket server.

If a host is provided (not None) the client connects immediately to the server. If no host is provides or the auto_connect is set to False
the connection has to be established by calling:  
`wsc.connect_to_socket("hostadress")`  

The client can call functions when connecting, disconnecting or an error occures:
to add a function call:  
`wsc.add_on_open("name", func[,overwrite=False])#run func on connecting`  
the name is used as a reference to remove the function if nescessary and overwrite=False (the default) protects already set functions from overwriting by the same name.
No parametes are passed to the function. Same goes for the disconnecting (add_on_close) and and error (add_on_error) functions.
By default the Client reconnects on error or on close. To turn this off set the **reconnect** attribute to false

In the same manner a on message can be assigned to the client. In this case the function passed resives the massage as parameter.

Initially an **intrinsic message validator** is added as on-message function which validates the massage according to the default message template:
```
{
        "type": "messagetype",
        "data": {},
        "from": sendername,
        "target": messagetarget,
    }
```

By default if the messagetype is "cmd" the message is threaten as a commandmessage and validated.
A commandmessage has to have the data-structure:
```
{
    "cmd": "commandname",
    "args": [],
    "kwargs": {}
}
``` 
Initially two commands are registered:  
- "indentify": answers to the identtify request of the server and registers with the SocketClient.name    
- "set_time": sets SocketClient.time to the given data which can be used for time synchronization.

additional commands can be registered via:  
`wsc.add_cmd_function('name',func[,overwrite=False])`  

Example:  
```
import time
import logging
import random
import threading
from websocket_communication_server.messagetemplates import commandmessage
from websocket_communication_server.socketclient import WebSocketClient
from websocket_communication_server.socketserver import SockerServer, SOCKETPORT


class Testclass:
    def __init__(self, host, name):
        self.runime = 0
        self.name = name
        self.wsc = WebSocketClient(name, host=host)
        self.wsc.add_cmd_function("pass_ball", self.pass_ball) # registers own pass_ball method to be called when reciving the pass_ball command
        self.pingpong = "ping" if "1" in name else "pong"
        self.opponent = "Player2" if "1" in name else "Player1"

    def pass_ball(self, catch=None): #methods called by the message validator should have default attributes to be valid against "TypeError: pass_ball() missing 1 required positional argument: 'catch'"
        if catch is None:
            print("End of the game because the ball went missing somewhere")
            return
        print(self.pingpong)  # prints ping or pong
        if not catch:
            print("Damn!")  # dont like losing the ball
        time.sleep(1)  # delay in game because it would be way to fast without, maybe the flytime of the ball :)
        self.wsc.write_to_socket(
            commandmessage(
                cmd="pass_ball", # the command to call at the reciver
                sender=self.name, # sender of the command
                target=self.opponent, # reciver
                catch=random.random() < 0.8, # 80% ball catch
            )
        )


if __name__ == "__main__":
    # connects to the firsts free port
    notconnected = True
    socketserver = None
    while notconnected:
        try:
            socketserver = SockerServer(port=SOCKETPORT)  # binds to 127.0.0.1:8888++
            notconnected = False
        except:
            SOCKETPORT += 1

    threading.Thread(
        target=socketserver.run_forever
    ).start()  # runs server forever in background
    test1 = Testclass(host=socketserver.ws_adress, name="Player1")  # create player 1
    test2 = Testclass(host=socketserver.ws_adress, name="Player2")  # create player 2
    time.sleep(1)  # gives the players enought timw to identify
    test1.pass_ball(True)  # throw the first ball
    while 1:
        time.sleep(1)  # play forever

```
Output:  
ping
pong
ping
pong
ping
pong
Damn!
ping
Damn!
pong
ping
pong
ping
pong
ping
pong
ping





%package -n python3-WsComSrv
Summary:	A basic websocket communication server
Provides:	python-WsComSrv
BuildRequires:	python3-devel
BuildRequires:	python3-setuptools
BuildRequires:	python3-pip
%description -n python3-WsComSrv
##Server
A socket server which allows to communicate between websocket clients 
and send commands between them.
The server can be incoken by  
`socketserver = SockerServer()`  
by default the server uses 127.0.0.1 (normaly equally to 'localhost') as the host and the port 8888.  
This can be changed to any other host/port by using respective arguments:  
`socketserver = SockerServer(port='localhost',port=8888)`  

If the Server cannot bind to the host:port pair an OSError is thrown.
This can be used to connect to the first free port
```
SOCKETPORT=8888
notconnected = True
socketserver = None
while notconnected:
    try:
        socketserver = SockerServer(port=SOCKETPORT)
        notconnected = False
    except:
        SOCKETPORT += 1
```
after the port is opened it can be run constantly by calling:  
`socketserver.run_forever()`

By default the server ask any connected client for a identification and sends a time stamp which can be used for time synchronization (see below)

##Client
The package comes also with a client.
To invoke a client use:  
`wsc = WebSocketClient("name",host="ws://127.0.0.1:8888")`   
The name should be unique and the host has to be changed match the socket server.

If a host is provided (not None) the client connects immediately to the server. If no host is provides or the auto_connect is set to False
the connection has to be established by calling:  
`wsc.connect_to_socket("hostadress")`  

The client can call functions when connecting, disconnecting or an error occures:
to add a function call:  
`wsc.add_on_open("name", func[,overwrite=False])#run func on connecting`  
the name is used as a reference to remove the function if nescessary and overwrite=False (the default) protects already set functions from overwriting by the same name.
No parametes are passed to the function. Same goes for the disconnecting (add_on_close) and and error (add_on_error) functions.
By default the Client reconnects on error or on close. To turn this off set the **reconnect** attribute to false

In the same manner a on message can be assigned to the client. In this case the function passed resives the massage as parameter.

Initially an **intrinsic message validator** is added as on-message function which validates the massage according to the default message template:
```
{
        "type": "messagetype",
        "data": {},
        "from": sendername,
        "target": messagetarget,
    }
```

By default if the messagetype is "cmd" the message is threaten as a commandmessage and validated.
A commandmessage has to have the data-structure:
```
{
    "cmd": "commandname",
    "args": [],
    "kwargs": {}
}
``` 
Initially two commands are registered:  
- "indentify": answers to the identtify request of the server and registers with the SocketClient.name    
- "set_time": sets SocketClient.time to the given data which can be used for time synchronization.

additional commands can be registered via:  
`wsc.add_cmd_function('name',func[,overwrite=False])`  

Example:  
```
import time
import logging
import random
import threading
from websocket_communication_server.messagetemplates import commandmessage
from websocket_communication_server.socketclient import WebSocketClient
from websocket_communication_server.socketserver import SockerServer, SOCKETPORT


class Testclass:
    def __init__(self, host, name):
        self.runime = 0
        self.name = name
        self.wsc = WebSocketClient(name, host=host)
        self.wsc.add_cmd_function("pass_ball", self.pass_ball) # registers own pass_ball method to be called when reciving the pass_ball command
        self.pingpong = "ping" if "1" in name else "pong"
        self.opponent = "Player2" if "1" in name else "Player1"

    def pass_ball(self, catch=None): #methods called by the message validator should have default attributes to be valid against "TypeError: pass_ball() missing 1 required positional argument: 'catch'"
        if catch is None:
            print("End of the game because the ball went missing somewhere")
            return
        print(self.pingpong)  # prints ping or pong
        if not catch:
            print("Damn!")  # dont like losing the ball
        time.sleep(1)  # delay in game because it would be way to fast without, maybe the flytime of the ball :)
        self.wsc.write_to_socket(
            commandmessage(
                cmd="pass_ball", # the command to call at the reciver
                sender=self.name, # sender of the command
                target=self.opponent, # reciver
                catch=random.random() < 0.8, # 80% ball catch
            )
        )


if __name__ == "__main__":
    # connects to the firsts free port
    notconnected = True
    socketserver = None
    while notconnected:
        try:
            socketserver = SockerServer(port=SOCKETPORT)  # binds to 127.0.0.1:8888++
            notconnected = False
        except:
            SOCKETPORT += 1

    threading.Thread(
        target=socketserver.run_forever
    ).start()  # runs server forever in background
    test1 = Testclass(host=socketserver.ws_adress, name="Player1")  # create player 1
    test2 = Testclass(host=socketserver.ws_adress, name="Player2")  # create player 2
    time.sleep(1)  # gives the players enought timw to identify
    test1.pass_ball(True)  # throw the first ball
    while 1:
        time.sleep(1)  # play forever

```
Output:  
ping
pong
ping
pong
ping
pong
Damn!
ping
Damn!
pong
ping
pong
ping
pong
ping
pong
ping





%package help
Summary:	Development documents and examples for WsComSrv
Provides:	python3-WsComSrv-doc
%description help
##Server
A socket server which allows to communicate between websocket clients 
and send commands between them.
The server can be incoken by  
`socketserver = SockerServer()`  
by default the server uses 127.0.0.1 (normaly equally to 'localhost') as the host and the port 8888.  
This can be changed to any other host/port by using respective arguments:  
`socketserver = SockerServer(port='localhost',port=8888)`  

If the Server cannot bind to the host:port pair an OSError is thrown.
This can be used to connect to the first free port
```
SOCKETPORT=8888
notconnected = True
socketserver = None
while notconnected:
    try:
        socketserver = SockerServer(port=SOCKETPORT)
        notconnected = False
    except:
        SOCKETPORT += 1
```
after the port is opened it can be run constantly by calling:  
`socketserver.run_forever()`

By default the server ask any connected client for a identification and sends a time stamp which can be used for time synchronization (see below)

##Client
The package comes also with a client.
To invoke a client use:  
`wsc = WebSocketClient("name",host="ws://127.0.0.1:8888")`   
The name should be unique and the host has to be changed match the socket server.

If a host is provided (not None) the client connects immediately to the server. If no host is provides or the auto_connect is set to False
the connection has to be established by calling:  
`wsc.connect_to_socket("hostadress")`  

The client can call functions when connecting, disconnecting or an error occures:
to add a function call:  
`wsc.add_on_open("name", func[,overwrite=False])#run func on connecting`  
the name is used as a reference to remove the function if nescessary and overwrite=False (the default) protects already set functions from overwriting by the same name.
No parametes are passed to the function. Same goes for the disconnecting (add_on_close) and and error (add_on_error) functions.
By default the Client reconnects on error or on close. To turn this off set the **reconnect** attribute to false

In the same manner a on message can be assigned to the client. In this case the function passed resives the massage as parameter.

Initially an **intrinsic message validator** is added as on-message function which validates the massage according to the default message template:
```
{
        "type": "messagetype",
        "data": {},
        "from": sendername,
        "target": messagetarget,
    }
```

By default if the messagetype is "cmd" the message is threaten as a commandmessage and validated.
A commandmessage has to have the data-structure:
```
{
    "cmd": "commandname",
    "args": [],
    "kwargs": {}
}
``` 
Initially two commands are registered:  
- "indentify": answers to the identtify request of the server and registers with the SocketClient.name    
- "set_time": sets SocketClient.time to the given data which can be used for time synchronization.

additional commands can be registered via:  
`wsc.add_cmd_function('name',func[,overwrite=False])`  

Example:  
```
import time
import logging
import random
import threading
from websocket_communication_server.messagetemplates import commandmessage
from websocket_communication_server.socketclient import WebSocketClient
from websocket_communication_server.socketserver import SockerServer, SOCKETPORT


class Testclass:
    def __init__(self, host, name):
        self.runime = 0
        self.name = name
        self.wsc = WebSocketClient(name, host=host)
        self.wsc.add_cmd_function("pass_ball", self.pass_ball) # registers own pass_ball method to be called when reciving the pass_ball command
        self.pingpong = "ping" if "1" in name else "pong"
        self.opponent = "Player2" if "1" in name else "Player1"

    def pass_ball(self, catch=None): #methods called by the message validator should have default attributes to be valid against "TypeError: pass_ball() missing 1 required positional argument: 'catch'"
        if catch is None:
            print("End of the game because the ball went missing somewhere")
            return
        print(self.pingpong)  # prints ping or pong
        if not catch:
            print("Damn!")  # dont like losing the ball
        time.sleep(1)  # delay in game because it would be way to fast without, maybe the flytime of the ball :)
        self.wsc.write_to_socket(
            commandmessage(
                cmd="pass_ball", # the command to call at the reciver
                sender=self.name, # sender of the command
                target=self.opponent, # reciver
                catch=random.random() < 0.8, # 80% ball catch
            )
        )


if __name__ == "__main__":
    # connects to the firsts free port
    notconnected = True
    socketserver = None
    while notconnected:
        try:
            socketserver = SockerServer(port=SOCKETPORT)  # binds to 127.0.0.1:8888++
            notconnected = False
        except:
            SOCKETPORT += 1

    threading.Thread(
        target=socketserver.run_forever
    ).start()  # runs server forever in background
    test1 = Testclass(host=socketserver.ws_adress, name="Player1")  # create player 1
    test2 = Testclass(host=socketserver.ws_adress, name="Player2")  # create player 2
    time.sleep(1)  # gives the players enought timw to identify
    test1.pass_ball(True)  # throw the first ball
    while 1:
        time.sleep(1)  # play forever

```
Output:  
ping
pong
ping
pong
ping
pong
Damn!
ping
Damn!
pong
ping
pong
ping
pong
ping
pong
ping





%prep
%autosetup -n WsComSrv-0.1.1555408076

%build
%py3_build

%install
%py3_install
install -d -m755 %{buildroot}/%{_pkgdocdir}
if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
pushd %{buildroot}
if [ -d usr/lib ]; then
	find usr/lib -type f -printf "\"/%h/%f\"\n" >> filelist.lst
fi
if [ -d usr/lib64 ]; then
	find usr/lib64 -type f -printf "\"/%h/%f\"\n" >> filelist.lst
fi
if [ -d usr/bin ]; then
	find usr/bin -type f -printf "\"/%h/%f\"\n" >> filelist.lst
fi
if [ -d usr/sbin ]; then
	find usr/sbin -type f -printf "\"/%h/%f\"\n" >> filelist.lst
fi
touch doclist.lst
if [ -d usr/share/man ]; then
	find usr/share/man -type f -printf "\"/%h/%f.gz\"\n" >> doclist.lst
fi
popd
mv %{buildroot}/filelist.lst .
mv %{buildroot}/doclist.lst .

%files -n python3-WsComSrv -f filelist.lst
%dir %{python3_sitelib}/*

%files help -f doclist.lst
%{_docdir}/*

%changelog
* Fri Jun 09 2023 Python_Bot <Python_Bot@openeuler.org> - 0.1.1555408076-1
- Package Spec generated