1

#!/bin/bash

     2

     3

rm -f ./SRVOK ./PLCOK

     4

     5

     6

yes "" | openssl req -x509 -newkey rsa:2048 -keyout my_private_key.pem -out my_cert.pem \

     7

        -days 355 -nodes -addext "subjectAltName = URI:urn:example.org:FreeOpcUa:python-opcua"

     8

openssl x509 -outform der -in my_cert.pem -out my_cert.der

     9

    10

# Run server

    11

$BEREMIZPYTHONPATH - > >(

    12

    echo "Start SRV loop"

    13

    while read line; do 

    14

        # Wait for server to print modified value

    15

        echo "SRV>> $line"

    16

        if [[ "$line" == 3.4 ]]; then

    17

            echo "PLC could write value"

    18

            touch ./SRVOK

    19

        fi

    20

    done

    21

    echo "End SRV loop"

    22

) << EOF &

    23

    24

import sys

    25

import os

    26

import time

    27

import asyncio

    28

    29

from asyncua import ua, Server

    30

from asyncua.server.users import User, UserRole

    31

    32

# Asyncua can't work without (over)simple shared cerificates/privkey.

    33

# No user is involved in that case, but asyncua needs it.

    34

# Over permessive User Manager hereafter helps cuting that corner.

    35

class AllAdminUserManager:

    36

    def get_user(self, iserver, username=None, password=None, certificate=None):

    37

        return User(role=UserRole.Admin)

    38

    39

async def main():

    40

    server = Server(user_manager=AllAdminUserManager())

    41

    host = os.environ.get("OPCUA_DEFAULT_HOST", "127.0.0.1")

    42

    endpoint = "opc.tcp://"+host+":4840/freeopcua/server/"

    43

    await server.init()

    44

    server.set_endpoint(endpoint)

    45

    46

    server.set_security_policy([ua.SecurityPolicyType.Basic256Sha256_SignAndEncrypt])

    47

    await server.load_certificate("my_cert.der")

    48

    await server.load_private_key("my_private_key.pem")

    49

    50

    uri = "http://beremiz.github.io"

    51

    idx = await server.register_namespace(uri)

    52

    53

    objects = server.get_objects_node()

    54

    55

    testobj = await objects.add_object(idx, "TestObject")

    56

    testvarout = await testobj.add_variable(idx, "TestOut", 1.2)

    57

    testvar = await testobj.add_variable(idx, "TestIn", 5.6)

    58

    await testvar.set_writable()

    59

    60

    await server.start()

    61

    62

    try:

    63

        while True:

    64

            await asyncio.sleep(1)

    65

            print(await testvar.get_value())

    66

            sys.stdout.flush()

    67

    finally:

    68

        await server.stop()

    69

    70

asyncio.run(main())

    71

    72

EOF

    73

SERVER_PID=$!

    74

    75

PROJECT_FILES_DIR=$BEREMIZPATH/tests/projects/opcua_client_encrypted/project_files

    76

mkdir $PROJECT_FILES_DIR

    77

cp my_cert.der my_private_key.pem $PROJECT_FILES_DIR

    78

    79

# Start PLC with opcua test

    80

setsid $BEREMIZPYTHONPATH $BEREMIZPATH/Beremiz_cli.py -k \

    81

     --project-home $BEREMIZPATH/tests/projects/opcua_client_encrypted build transfer run > >(

    82

echo "Start PLC loop"

    83

while read line; do 

    84

    # Wait for PLC runtime to output expected value on stdout

    85

    echo "PLC>> $line"

    86

    if [[ "$line" == 1.2 ]]; then

    87

        echo "PLC could read value"

    88

        touch ./PLCOK

    89

    fi

    90

done

    91

echo "End PLC loop"

    92

) &

    93

PLC_PID=$!

    94

    95

echo all subprocess started, start polling results

    96

res=110  # default to ETIMEDOUT

    97

c=45

    98

while ((c--)); do

    99

    if [[ -a ./SRVOK && -a ./PLCOK ]]; then

   100

        echo got results.

   101

        res=0  # OK success

   102

        break

   103

    else

   104

        echo waiting.... $c

   105

        sleep 1

   106

    fi

   107

done

   108

   109

# Kill PLC and subprocess

   110

echo will kill PLC:$PLC_PID and SERVER:$SERVER_PID

   111

pkill -s $PLC_PID 

   112

kill $SERVER_PID

   113

   114

exit $res