Code

Initial Pull Request#1

Code

Merged

brentru merged 148 commits intoadafruit:masteradafruit/Adafruit_CircuitPython_MiniMQTT:masterfrom brentru:masterCopy head branch name to clipboardJul 16, 2019

+2,126-4

Commits

Commits on Jun 27, 2019

• cookiecutter init!

  

  brentru

  authored and

  brentru

  committed
  76c2839

  Copy full SHA for 76c2839

• add init, starting connect...

  

  brentru

  authored and

  brentru

  committed
  6863435

  Copy full SHA for 6863435

• connects to IO mqtt broker via socket, still need to remove passing the socket lib

  

  brentru

  authored and

  brentru

  committed
  775adff

  Copy full SHA for 775adff

• connects to Adafruit IO with MQTTS

  

  brentru

  authored and

  brentru

  committed
  ea99dbf

  Copy full SHA for ea99dbf

• generate a client identifier, add control flow for is_ssl boolean

  

  brentru

  authored and

  brentru

  committed
  ed2b12b

  Copy full SHA for ed2b12b

• generate a client_id based on cpu UUID

  

  brentru

  authored and

  brentru

  committed
  6f3a57a

  Copy full SHA for 6f3a57a

• add subscribe() method

  

  brentru

  authored and

  brentru

  committed
  e14df6d

  Copy full SHA for e14df6d

• add a reconnect method

  

  brentru

  authored and

  brentru

  committed
  789bf81

  Copy full SHA for 789bf81

• tie the reconnect into the code, hard reset the esp if it doesnt connect

  

  brentru

  authored and

  brentru

  committed
  51ed0ae

  Copy full SHA for 51ed0ae

• publish method works

  

  brentru

  authored and

  brentru

  committed
  0d25d3f

  Copy full SHA for 0d25d3f

• add pubsub example

  

  brentru

  authored and

  brentru

  committed
  9dafe23

  Copy full SHA for 9dafe23

• add a default callback method and set_callback

  

  brentru

  authored and

  brentru

  committed
  af70eb4

  Copy full SHA for af70eb4

• add naive impl. of associating callback methods with subscription topics

  

  brentru

  authored and

  brentru

  committed
  e296f11

  Copy full SHA for e296f11

Commits on Jun 28, 2019

• start working towards custom callback method dictionary mapping based off of subscription topic

  

  brentru

  committed
  e5fa86b

  Copy full SHA for e5fa86b

• tested default internal callback method, todo: test dict with a default and a custom callback

  

  brentru

  committed
  4da85f7

  Copy full SHA for 4da85f7

• add better error handling defs

  

  brentru

  committed
  1642c59

  Copy full SHA for 1642c59

• add checks for invalid QOS, message length

  

  brentru

  committed
  d29982c

  Copy full SHA for d29982c

• add msg size limits, topic size limits, setter/getter for size limits

  

  brentru

  committed
  fe1d98f

  Copy full SHA for fe1d98f

• add checks to mqtt publish for topic, message, and quos. add type conversions

  

  brentru

  committed
  e4db740

  Copy full SHA for e4db740

• refactoring and fix publish message type conversions

  

  brentru

  committed
  ef9ab3c

  Copy full SHA for ef9ab3c

• add updated example

  

  brentru

  committed
  054f613

  Copy full SHA for 054f613

Commits on Jul 1, 2019

• enforce some of the mqtt client_id spec, check hardware objects before proceeding

  

  brentru

  committed
  21db5ca

  Copy full SHA for 21db5ca

• drop wifimanager dependency, favor esp32spi

  

  brentru

  committed
  30b4a5f

  Copy full SHA for 30b4a5f

• only enforce alpanumeric/byte clientid limit on generated client id, lax on user-defined. set msg size lim to a constant

  

  brentru

  committed
  a967eb9

  Copy full SHA for a967eb9

• wait_for_message checks timeout value, allow more precise timeouts with a float instead of int

  

  brentru

  committed
  3db4911

  Copy full SHA for 3db4911

• add check on disconnect() for an empty socket before dc'ing

  

  brentru

  committed
  6dc0dd8

  Copy full SHA for 6dc0dd8

• publish matches mqtt spec

  

  brentru

  committed
  e7f9c28

  Copy full SHA for e7f9c28

• fix broken subscribe, _send_str already encodes the topic per spec.

  

  brentru

  committed
  8c372d6

  Copy full SHA for 8c372d6

• client_id is already encoded in connect, dont encode twice

  

  brentru

  committed
  5386cd3

  Copy full SHA for 5386cd3

• topic string should not be encoded twice, redundant code

  

  brentru

  committed
  0833fa1

  Copy full SHA for 0833fa1

• add last_will method to allow user-defined LWT, incorp. into init. add PUBACK errors

  

  brentru

  committed
  af3cce8

  Copy full SHA for af3cce8

• start work on unsubscribe

  

  brentru

  committed
  6a0d96e

  Copy full SHA for 6a0d96e

• pop topic from method handler dictionary on unsubscribe. handle publish and subscribe cases where there is no socket initalized due to a possible deinit.

  

  brentru

  committed
  91648c4

  Copy full SHA for 91648c4

• added inline docstring examples to subscription method

  

  brentru

  committed
  07a349c

  Copy full SHA for 07a349c

• Add publish_multiple method - publish to multiple topics at once!

  

  brentru

  committed
  1efb73f

  Copy full SHA for 1efb73f

• add subscribe_multiple - not working yet! - subscribes to multiple broker topics

  

  brentru

  committed
  9081744

  Copy full SHA for 9081744

Commits on Jul 2, 2019

• check for is_connected before will is set

  

  brentru

  committed
  6251536

  Copy full SHA for 6251536

• minimqttexception -> mmqtexception

  

  brentru

  committed
  c9051fd

  Copy full SHA for c9051fd

• check if topic is already subscribed to before subscribing

  

  brentru

  committed
  155c679

  Copy full SHA for 155c679

• associate return codes with their description

  

  brentru

  committed
  c6250f5

  Copy full SHA for c6250f5

• removal of puback error codes, mqtt error handling in favor of cleaner mmqtt exception class

  

  brentru

  committed
  f744599

  Copy full SHA for f744599

• ping method checks against pingresp, returns if true. raises if false

  

  brentru

  committed
  5a3b4af

  Copy full SHA for 5a3b4af

• start sketching on on_connect for paho-style ack callbacks

  

  brentru

  committed
  1fe9cda

  Copy full SHA for 1fe9cda

• working on_connect callback, add a user_data property and setter to conform with paho's callback style

  

  brentru

  committed
  e954938

  Copy full SHA for e954938

• add on_disconnect, check for a previously defined on_ack before calling it to avoid errors

  

  brentru

  committed
  f059558

  Copy full SHA for f059558

• added on_subscribe getter/setter and handling code to subscribe method

  

  brentru

  committed
  516db8d

  Copy full SHA for 516db8d

• fix disconnect callback, publish not working

  

  brentru

  committed
  d40288c

  Copy full SHA for d40288c

• add working publish for callbacks when qos = 0

  

  brentru

  committed
  5dff2ff

  Copy full SHA for 5dff2ff

• add network loop methods, untested as of now

  

  brentru

  committed
  3d44461

  Copy full SHA for 3d44461

• add larger example from pyportal

  

  brentru

  committed
  13010a4

  Copy full SHA for 13010a4

Commits on Jul 3, 2019

• fix CONNACK on_connect response codes

  

  brentru

  authored and

  brentru

  committed
  9acb8e1

  Copy full SHA for 9acb8e1

• add unsub...broken response

  

  brentru

  authored and

  brentru

  committed
  67b4d75

  Copy full SHA for 67b4d75

• increase timeout of wait_for_msg

  

  brentru

  authored and

  brentru

  committed
  1316214

  Copy full SHA for 1316214

• add working unsubscribe method, need stricter checking on the UNPUBACK

  

  brentru

  authored and

  brentru

  committed
  51d0b7b

  Copy full SHA for 51d0b7b

• handle unsuback better with a variable socket timeout

  

  brentru

  authored and

  brentru

  committed
  f27e7e5

  Copy full SHA for f27e7e5

• add on_unsubscribe ack handler

  

  brentru

  authored and

  brentru

  committed
  fba332c

  Copy full SHA for fba332c

• correct method handler call

  

  brentru

  authored and

  brentru

  committed
  9b0635b

  Copy full SHA for 9b0635b

• remove @setter/@Getter callbacks, make on_ methods public to usercode

  

  brentru

  authored and

  brentru

  committed
  c2c4f9c

  Copy full SHA for c2c4f9c

• add prelimary support for logging

  

  brentru

  authored and

  brentru

  committed
  ef74dfb

  Copy full SHA for ef74dfb

• fix logging, success from logger publish

  

  brentru

  authored and

  brentru

  committed
  7aa160b

  Copy full SHA for 7aa160b

Commits on Jul 5, 2019

• fix ping's handling of PINGRESP

  

  brentru

  committed
  345f8f1

  Copy full SHA for 345f8f1

• add logger debug statements, reduce reused variables in wait_for_msg

  

  brentru

  committed
  00756c9

  Copy full SHA for 00756c9

• starting mqtt test client

  

  brentru

  committed
  28ebc6b

  Copy full SHA for 28ebc6b

• add test harness and additional tests

  

  brentru

  committed
  eaaebb9

  Copy full SHA for eaaebb9

• consolidate some tests, fixup bugs

  

  brentru

  committed
  ffd87eb

  Copy full SHA for ffd87eb

• create a logger by default, pass client information to the user-defined subscribe method handler

  

  brentru

  committed
  acae093

  Copy full SHA for acae093

• docstring the strict method handler signature

  

  brentru

  committed
  ebff8e4

  Copy full SHA for ebff8e4

• remove topic-based callbacks in favor of default user-defined callbacks since wildcards could become a problem here.

  

  brentru

  committed
  f17f74f

  Copy full SHA for f17f74f

• fix PUBLISH log statement

  

  brentru

  committed
  8b864e3

  Copy full SHA for 8b864e3

• add callback to on_message within wait_for_msg, handle encoding the msg properly

  

  brentru

  committed
  d36b716

  Copy full SHA for d36b716

• update pubsub test for on_message

  

  brentru

  committed
  2f7a4d5

  Copy full SHA for 2f7a4d5

• topic-based resub, add a subscribed_topics list to track topics

  

  brentru

  committed
  af8e094

  Copy full SHA for af8e094

• multiple send start work

  

  brentru

  committed
  5ced62c

  Copy full SHA for 5ced62c

• adding new subscription code, broken down

  

  brentru

  committed
  0668f10

  Copy full SHA for 0668f10

• working single subscription

  

  brentru

  committed
  ef151e7

  Copy full SHA for ef151e7

• subscriptions to multiple topics work!

  

  brentru

  committed
  30a497a

  Copy full SHA for 30a497a

• add comments

  

  brentru

  committed
  599a70f

  Copy full SHA for 599a70f

Commits on Jul 8, 2019

• accept tuple into subscribe method signature

  

  brentru

  committed
  951443c

  Copy full SHA for 951443c

• log subscriptions to multiple topics

  

  brentru

  committed
  e9c07d7

  Copy full SHA for e9c07d7

• extend docstring for subscribe

  

  brentru

  committed
  8db7be2

  Copy full SHA for 8db7be2

• allow multiple UNSUBSCRIBE topics, add back subscribed_topics list to subscribe and unsubscribe

  

  brentru

  committed
  972f995

  Copy full SHA for 972f995

• refactor is_connected method, use it as a universal check before network actions

  

  brentru

  committed
  41bc399

  Copy full SHA for 41bc399

• add on_publish cb for qos of 2, assert

  

  brentru

  committed
  66c460c

  Copy full SHA for 66c460c

• stricter esp32spi check for attributes in the init

  

  brentru

  committed
  5b7da5e

  Copy full SHA for 5b7da5e

• redo init to be flexible enough for future network interfaces, fix how port is set to allow non-ssl/tls ports like 3033

  

  brentru

  committed
  93ca083

  Copy full SHA for 93ca083

• re-enable log boolean, check if the logger handler has been attached before outputting log info, remove old default handler

  

  brentru

  committed
  5a16869

  Copy full SHA for 5a16869

• drop multiple publishing, not defined within spec. drop esp-related actions, let the user handle those instead

  

  brentru

  committed
  db8f254

  Copy full SHA for db8f254

• add create_logger method for creating a new logger, post-initialization

  

  brentru

  committed
  3a3f9d5

  Copy full SHA for 3a3f9d5

• add a AMQTT-like example for publishing/subscribing with AIO

  

  brentru

  committed
  eb30162

  Copy full SHA for eb30162

• pylinting and fixing bugs

  

  brentru

  committed
  d85dc6a

  Copy full SHA for d85dc6a

• pass pylint

  

  brentru

  committed
  1e70f9b

  Copy full SHA for 1e70f9b

• fix ping() method, pingreq is TWO bytes not one

  

  brentru

  committed
  6413e9f

  Copy full SHA for 6413e9f

• add working AMQTT library example

  

  brentru

  committed
  e914e28

  Copy full SHA for e914e28

• fix SSL port instanciation

  

  brentru

  committed
  88e000d

  Copy full SHA for 88e000d

• check if a logger exists before calling it within publish

  

  brentru

  committed
  508f035

  Copy full SHA for 508f035

• restructure test framework

  

  brentru

  committed
  e332074

  Copy full SHA for e332074

• add wildcard publish test

  

  brentru

  committed
  21b74de

  Copy full SHA for 21b74de

• enforce topic name and filter limit on unsubscribe

  

  brentru

  committed
  f7c6d55

  Copy full SHA for f7c6d55

• define a method to allow post-initialization attachment of a loger object, change logger to a more verbose method name

  

  brentru

  committed
  c817477

  Copy full SHA for c817477

• add a valid check for UNSUBACK, wasnt explicitly checking the fixed header contents prior. Need to refactor back into multiple unsubscribe calls again

  

  brentru

  committed
  7181ed4

  Copy full SHA for 7181ed4

• add a generic topic check private method

  

  brentru

  committed
  a4027f2

  Copy full SHA for a4027f2

• strict topic check added

  

  brentru

  committed
  70c9e8e

  Copy full SHA for 70c9e8e

Commits on Jul 9, 2019

• strict length check on password

  

  brentru

  committed
  7f17ff5

  Copy full SHA for 7f17ff5

• rewrite of unsubscribe with strict return code handling to conform with MQTT spec

  

  brentru

  committed
  c027039

  Copy full SHA for c027039

• add to docstring...

  

  brentru

  committed
  47f2ce9

  Copy full SHA for 47f2ce9

• add _check_qos

  

  brentru

  committed
  3461736

  Copy full SHA for 3461736

• handle unsuback correctly

  

  brentru

  committed
  a6b387e

  Copy full SHA for a6b387e

• update hardware test to allow a settings python dict file for configuration

  

  brentru

  committed
  612ab3f

  Copy full SHA for 612ab3f

• fix import order

  

  brentru

  committed
  e4ccdb5

  Copy full SHA for e4ccdb5

• fix password encoding issue

  

  brentru

  committed
  623148e

  Copy full SHA for 623148e

• switching server_Address to server

  

  brentru

  committed
  2d40156

  Copy full SHA for 2d40156

• pass topic along with granted QOs to on_subscribe

  

  brentru

  committed
  6ae098a

  Copy full SHA for 6ae098a

• server/broker

  

  brentru

  committed
  16e0917

  Copy full SHA for 16e0917

• add minimqtt with replicatable unsuback issue

  

  brentru

  committed
  0a20d6b

  Copy full SHA for 0a20d6b

Commits on Jul 10, 2019

• add a method for setting network interface hardware, useful for later when we have more interfaces

  

  brentru

  authored and

  brentru

  committed
  8f69940

  Copy full SHA for 8f69940

• rewrite of reconnect

  

  brentru

  authored and

  brentru

  committed
  f5f65b6

  Copy full SHA for f5f65b6

• allow IP addresses along with URLs

  

  brentru

  authored and

  brentru

  committed
  7df2b9f

  Copy full SHA for 7df2b9f

• lint

  

  brentru

  authored and

  brentru

  committed
  3ac6772

  Copy full SHA for 3ac6772

• only log when a logger is provided

  

  brentru

  authored and

  brentru

  committed
  69d36ba

  Copy full SHA for 69d36ba

• add generalized example code with support for AIO or MQTT brokers

  

  brentru

  authored and

  brentru

  committed
  7981e9e

  Copy full SHA for 7981e9e

• nicer code example for AIO

  

  brentru

  authored and

  brentru

  committed
  c45c209

  Copy full SHA for c45c209

• nicer code for simpletest

  

  brentru

  authored and

  brentru

  committed
  5c45ec3

  Copy full SHA for 5c45ec3

• fixup example

  

  brentru

  authored and

  brentru

  committed
  1fa7835

  Copy full SHA for 1fa7835

• fix some pylint defs

  

  brentru

  authored and

  brentru

  committed
  ddf3e10

  Copy full SHA for ddf3e10

• update README.md

  

  brentru

  authored and

  brentru

  committed
  8a35e0a

  Copy full SHA for 8a35e0a

• add logger to requirements

  

  brentru

  authored and

  brentru

  committed
  6405286

  Copy full SHA for 6405286

• remove variable timeout, blocking read on wait_for_msg by default

  

  brentru

  authored and

  brentru

  committed
  f93feae

  Copy full SHA for f93feae

• add a long variable timeout to catch brokers like io forcefully disconnecting a client

  

  brentru

  authored and

  brentru

  committed
  4c7fc28

  Copy full SHA for 4c7fc28

• enable and add mock_imports to satisfy sphinx

  

  brentru

  authored and

  brentru

  committed
  1df31d4

  Copy full SHA for 1df31d4

• add logging since it's not in pypi..

  

  brentru

  authored and

  brentru

  committed
  89680cc

  Copy full SHA for 89680cc

• linting

  

  brentru

  authored and

  brentru

  committed
  d2662ae

  Copy full SHA for d2662ae

• add non-blocking check for message

  

  brentru

  authored and

  brentru

  committed
  c9d6b8d

  Copy full SHA for c9d6b8d

• add non-blocking and blocking control loops, make wait_for_msg a private method

  

  brentru

  authored and

  brentru

  committed
  a799f54

  Copy full SHA for a799f54

• add two new examples showing blocking vs nonblocking message loops, refactor adafruitiowifi example

  

  brentru

  authored and

  brentru

  committed
  1be4557

  Copy full SHA for 1be4557

• update examples

  

  brentru

  authored and

  brentru

  committed
  b0a4e53

  Copy full SHA for b0a4e53

• lint!

  

  brentru

  authored and

  brentru

  committed
  0587b66

  Copy full SHA for 0587b66

• fix docstring

  

  brentru

  authored and

  brentru

  committed
  268210e

  Copy full SHA for 268210e

• add docstring for class-level?

  

  brentru

  authored and

  brentru

  committed
  600e336

  Copy full SHA for 600e336

• add more docstrings

  

  brentru

  authored and

  brentru

  committed
  ec20990

  Copy full SHA for ec20990

• add blank lines

  

  brentru

  authored and

  brentru

  committed
  4e3456c

  Copy full SHA for 4e3456c

• pylint!!!

  

  brentru

  authored and

  brentru

  committed
  1177631

  Copy full SHA for 1177631

Commits on Jul 11, 2019

• esp32spi -> networkmanager object instead

  

  brentru

  committed
  e7ed0fa

  Copy full SHA for e7ed0fa

• drop esp32spi object in favor of wifimanager, update all examples

  

  brentru

  committed
  6d928e4

  Copy full SHA for 6d928e4

• add a wait_for_msg call to catch any async publish before pingresp

  

  brentru

  committed
  4cade94

  Copy full SHA for 4cade94

• check for a PUBLISH before a CONNACK

  

  brentru

  committed
  5c15d23

  Copy full SHA for 5c15d23

• fix out of bytestring error

  

  brentru

  committed
  07102d8

  Copy full SHA for 07102d8

• fix pylint errors

  

  brentru

  authored and

  brentru

  committed
  ceb26b6

  Copy full SHA for ceb26b6

Commits on Jul 16, 2019

• changes per @ladyada's review

  

  brentru

  committed
  1ae11a8

  Copy full SHA for 1ae11a8