pocsag.hh

#ifndef __SDR_POSAG_HH__
#define __SDR_POSAG_HH__

#include "node.hh"

namespace sdr {

class POCSAG: public Sink<uint8_t>
{
public:
  class Message {
  public:
    Message();
    Message(uint32_t addr, uint8_t func);
    Message(const Message &other);

    Message &operator=(const Message &other);

    inline bool isEmpty() const { return _empty; }
    inline uint32_t address() const { return _address; }
    inline uint8_t function() const { return _function; }
    inline uint32_t bits() const { return _bits; }

    void addPayload(uint32_t word);

    int estimateText() const;
    int estimateNumeric() const;

    std::string asText() const;
    std::string asNumeric() const;
    std::string asHex() const;

  protected:
    uint32_t             _address;
    uint8_t              _function;
    bool                 _empty;
    uint32_t             _bits;
    std::vector<uint8_t> _payload;
  };

protected:
  typedef enum {
    WAIT,           
    RECEIVE,        
    CHECK_CONTINUE  
  } State;

public:
  POCSAG();

  void config(const Config &src_cfg);
  void process(const Buffer<uint8_t> &buffer, bool allow_overwrite);

  virtual void handleMessages();

protected:
  void _process_word(uint32_t word);
  void _reset_message();
  void _finish_message();

protected:
  State    _state;
  uint64_t _bits;
  uint8_t  _bitcount;
  uint8_t  _slot;
  Message _message;
  std::list<Message> _queue;
};


class POCSAGDump: public POCSAG
{
public:
  POCSAGDump(std::ostream &stream);

  void handleMessages();

protected:
  std::ostream &_stream;
};


}

#endif // __SDR_POSAG_HH__