receiver.py

# from __future__ import print_function
import time
from RF24 import *
import pdb
import base64
import RPi.GPIO as GPIO
import os, sys

irq_gpio_pin = None

radio = RF24(22, 0)
pipes = [0xF0F0F0F0E1, 0x7365727631]


def setup():
    pdb.set_trace()
    # radio.printDetails()
    # radio.begin()
    print ("Hallo")
    pdb.set_trace()

    #radio.payloadSize = 16  # len(message)
    # radio.enableDynamicPayloads()
    radio.setAutoAck(1)
    radio.setDataRate(RF24_250KBPS)  # 250kbs
    radio.setPALevel(RF24_PA_MAX)

    pdb.set_trace()

    radio.setChannel(90)
    radio.setRetries(15, 15)
    radio.setCRCLength(RF24_CRC_16)
    radio.openWritingPipe(pipes[1])
    radio.openReadingPipe(1, pipes[0])
    # radio.maskIRQ(0,0,1)
    radio.startListening()


def writeToFile(received_payload):
    print('Got payload size={} value="{}"'.format(radio.payloadSize, received_payload.decode('utf-8')))

    # Timestamp erzeugen
    utime = int(time.time())

    # Hier aktuelle Zeit einfuegen
    data.write("1481278800" + " " + received_payload + " \n")  # % utime
    data.flush()


def receive():
    if radio.available():
        while radio.available():
            len = radio.payloadSize

            receive_payload = radio.read(len)
            writeToFile(receive_payload)


# Hauptprogramm:
pdb.set_trace()
print ("Hallo")
pdb.set_trace()
setup()
radio.printDetails()
data = open('datafifo', 'a+')
print("Hauptprogramm:")
while 1:
    receive()

    # spaeter durch interrupt ersetzten
    time.sleep(1)
data.close()