Code

MQTT-support#766

Code

Open

kickster97 wants to merge 188 commits intomaincloudamqp/lavinmq:mainfrom mqtt-poccloudamqp/lavinmq:mqtt-pocCopy head branch name to clipboard

+3,690-87

Commits

Commits on Nov 21, 2024

• beginning of mqtt-poc, ping

  kickster97

  committed
  505588b

• add send/recieve oct_count, make prometheus controller compile

  kickster97

  committed
  45ba0f9

• client stores client_id and quick solution for UI

  kickster97

  committed
  6492763

• amqp publish

  kickster97

  committed
  4d57ff0

• mqtt integration spec: ping

  

  snichme

  authored and

  kickster97

  committed
  8e6c6cf

• fixup! amqp publish

  kickster97

  committed
  7347ed8

• int-specs

  

  snichme

  authored and

  kickster97

  committed
  2165723

• cleanup

  

  snichme

  authored and

  kickster97

  committed
  fdad4d5

• connect specs (pending)

  

  snichme

  authored and

  kickster97

  committed
  77963a9

• all integration specs (pending)

  

  snichme

  authored and

  kickster97

  committed
  48dd059

• Synchronizer -> channel

  

  snichme

  authored and

  kickster97

  committed
  c702b01

• spec: publish mqtt ends up in amqp queue

  

  snichme

  authored and

  kickster97

  committed
  2a381b6

• send puback after publish if qos > 0

  kickster97

  committed
  8076cdd

• publish will to session WIP

  kickster97

  committed
  88ef613

• publish returns PubAck

  

  snichme

  authored and

  kickster97

  committed
  21df350

• cleanup will preparation

  kickster97

  committed
  ab83ec2

• Got first working subscribe

  Show description for 0d402a8
  

  snichme

  authored and

  kickster97

  committed
  0d402a8

• subscribe specs

  

  snichme

  authored and

  kickster97

  committed
  8b08d11

• packet_id stuff

  

  snichme

  authored and

  kickster97

  committed
  d0ba355

• pass more connect specs

  kickster97

  committed
  b6d3996

• work on subscriber specs

  kickster97

  committed
  db6abee

• start working on broker for clients

  kickster97

  committed
  6a00891

• wrap vhost in broker for mqtt::client

  kickster97

  committed
  592600c

• pass more specs and handle session_present

  kickster97

  committed
  4f20533

• all connect specs working except replace client with new connection

  kickster97

  committed
  5f588ab

• fix logs in client and dot expect connack in specs

  kickster97

  committed
  6042f6f

• add sessions to broker, and handle incoming subscribe with session

  kickster97

  committed
  47be1ee

• fixup! add sessions to broker, and handle incoming subscribe with session

  kickster97

  committed
  622ac3c

• fixup! fixup! add sessions to broker, and handle incoming subscribe with session

  kickster97

  committed
  421a098

• subscribe and bind a session

  kickster97

  committed
  44b791d

• temp

  kickster97

  committed
  c931ce2

• exchange.publish

  

  snichme

  authored and

  kickster97

  committed
  b5d3a98

• mqtt exchange

  

  snichme

  authored and

  kickster97

  committed
  dafc567

• refactor mqtt session

  kickster97

  committed
  8baf983

• add get method to prepare for qos 1

  kickster97

  committed
  585cb6b

• feel like this got ugly, but subscribe specs are now passing

  kickster97

  committed
  5d76339

• cleanup old code and use session instead of queue

  kickster97

  committed
  81467de

• refctoring consumer handling, and handle msg acks better

  kickster97

  committed
  7f238e7

• move consumers deliver_loop to session, specs do not pass

  kickster97

  committed
  5bfa977

• cleanup

  kickster97

  committed
  4ecf4a9

• SubscriptionTree

  

  snichme

  authored and

  kickster97

  committed
  57e0ac8

• rebase main

  kickster97

  committed
  0650194

• format

  kickster97

  committed
  e1a2b82

• override method

  

  snichme

  authored and

  kickster97

  committed
  bd96dcf

• string token specs

  

  snichme

  authored and

  kickster97

  committed
  9fc032b

• crystal 1.14 fixes

  

  snichme

  authored and

  kickster97

  committed
  151860d

• subscription tree specs

  

  snichme

  authored and

  kickster97

  committed
  578aca1

• beginning of puback

  kickster97

  committed
  42ce5ee

• subscription tree specs

  

  snichme

  authored and

  kickster97

  committed
  de90cb7

• remove puts

  

  snichme

  authored and

  kickster97

  committed
  41a2798

• Use monkey patched IO::Buffered#peek(n) to ensure data exists

  

  spuun

  authored and

  kickster97

  committed
  db83ff8

• It should return slice

  

  spuun

  authored and

  kickster97

  committed
  daa13e3

• Add spec to verify positive size check

  

  spuun

  authored and

  kickster97

  committed
  1daac59

• Rename stuff in an attempt to make things more readable

  

  spuun

  authored and

  kickster97

  committed
  f431ac4

• Refactor specs

  

  spuun

  authored and

  kickster97

  committed
  275231b

• Cleaner specs

  

  spuun

  authored and

  kickster97

  committed
  e82506a

• Update spec description

  

  spuun

  authored and

  kickster97

  committed
  32d4e9a

• Fix condition when checking if enough data exists

  

  spuun

  authored and

  kickster97

  committed
  c036d47

• Move data in existing buffer if needed

  

  spuun

  authored and

  kickster97

  committed
  46c8a39

• Return what we got instead of rasing in read fails

  

  spuun

  authored and

  kickster97

  committed
  ce245c5

• Remove unused code

  

  spuun

  authored and

  kickster97

  committed
  e245bcb

• merge jons pr and fix sleep problem

  kickster97

  committed
  2ae36c2

• spec fix for subtree

  

  snichme

  authored and

  kickster97

  committed
  8062e81

• set dup value when delivering a msg

  kickster97

  committed
  f021fda

• cleanup

  kickster97

  committed
  2dd49d0

• retain_store and topic_tree

  kickster97

  committed
  06d8175

• Restructure retain-store and topic_tree for better fit in LavinMQ

  Show description for fd19bff
  

  kickster97

  and

  spuun

  committed
  fd19bff

• publish retained message

  kickster97

  committed
  f0f8f39

• Update src/lavinmq/mqtt/retain_store.cr

  Show description for ec59be4
  

  kickster97

  and

  spuun

  committed
  ec59be4

• retained messages spec pass

  kickster97

  committed
  7d765ad

• Improve handling of non-clean sesssions

  Show description for 7453bc5
  

  spuun

  authored and

  kickster97

  committed
  7453bc5

• pass will specs

  kickster97

  committed
  1d1cfd0

• cleanup

  kickster97

  committed
  5c16b7f

• pass duplicate message specs

  kickster97

  committed
  00250bb

• format

  kickster97

  committed
  6b989cc

• fix publish

  kickster97

  committed
  8172225

• remove obsolete header

  kickster97

  committed
  5580ea4

• cleanup

  kickster97

  committed
  9226687

• raise io error for invalid package_id

  kickster97

  committed
  0d7a268

• handle raise for double connect

  kickster97

  committed
  25b1aef

• revert double connect rescue

  kickster97

  committed
  cfe5eeb

• Remove unused variable

  

  spuun

  authored and

  kickster97

  committed
  183609a

• Use method overloading instead of type check

  

  spuun

  authored and

  kickster97

  committed
  11c7f30

• Use lowercase log source

  

  spuun

  authored and

  kickster97

  committed
  4626c1f

• Use mqtt.session as log source for Session

  

  spuun

  authored and

  kickster97

  committed
  dd18f2f

• Add spec to test publisher->subscriber flow

  

  spuun

  authored and

  kickster97

  committed
  02ecf2e

• Add spec to verify that session is restored properly

  

  spuun

  authored and

  kickster97

  committed
  21ea60f

• Use getter instead of instance variable

  

  spuun

  authored and

  kickster97

  committed
  7863af6

• beginning of max_inflight

  kickster97

  committed
  17dd34b

• send in topic to subscription tree, pass specs

  kickster97

  committed
  b44990c

• clean up

  kickster97

  committed
  2e49681

• create publish packet in client instead of accepting will in #broker:publish

  kickster97

  committed
  f263009

• Be consistent with typing

  

  spuun

  authored and

  kickster97

  committed
  750dd6a

• Add routing specs

  

  spuun

  authored and

  kickster97

  committed
  8f15518

• Lint

  

  spuun

  authored and

  kickster97

  committed
  d4f9ad3

• Return nil and let spec assert

  

  spuun

  authored and

  kickster97

  committed
  8618839

• Add a will spec (and some clean up)

  

  spuun

  authored and

  kickster97

  committed
  62625f8

• publish will if PacketDecode exception

  kickster97

  committed
  c95f65e

• move vhost logic from client into broker

  kickster97

  committed
  d1dcbbd

• Improve logging

  

  spuun

  authored and

  kickster97

  committed
  7ed81b3

• add retain_store specs for .retain and .each

  kickster97

  committed
  3cdf6aa

• No need to prefix class, use namespace

  

  spuun

  authored and

  kickster97

  committed
  358523c

• Update src/lavinmq/mqtt/client.cr

  Show description for 2c9ea27
  

  kickster97

  and

  spuun

  committed
  2c9ea27

• remove unnessecary socket.close

  kickster97

  committed
  42a9f9f

• log warning instead of raise

  kickster97

  committed
  9e1ddb6

• fetch max_inflight_messages form config

  kickster97

  committed
  7dd27fa

• Convert Publish to Message in exchange

  

  spuun

  authored and

  kickster97

  committed
  03e4e9d

• Less aggressive logging

  

  spuun

  authored and

  kickster97

  committed
  5d77985

• Suspend fiber while waiting for msg or consumer

  Show description for 2b1b38a
  

  spuun

  authored and

  kickster97

  committed
  2b1b38a

• add specs for handling connect packets with empty client_ids

  kickster97

  committed
  7f44080

• handle connect packets with empty client_id strings

  kickster97

  committed
  e487949

• fixup! Suspend fiber while waiting for msg or consumer

  

  spuun

  authored and

  kickster97

  committed
  95ac073

• Move Sessions to separate file

  

  spuun

  authored and

  kickster97

  committed
  f290486

• Dont convert topic to routing key, and use topic all the way through

  kickster97

  committed
  ea924f5

• prefix sessions with mqtt. and do not let amqp queues create queues that start with .mqtt

  kickster97

  committed
  96d5b54

• move validation to queue_factory and return preconditioned fail for amqp queues with .mqtt prefix

  kickster97

  committed
  c990e8e

• prefix_validation wip

  kickster97

  committed
  bc06320

• delete old cherry-picked code, replaced with #818

  kickster97

  committed
  db41e9d

• mqtt exchange receives MQTT::Publish but publish AMQP::Message to queue(session)

  

  snichme

  authored and

  kickster97

  committed
  d86b677

• remove obsolete spec

  kickster97

  committed
  d0f7879

• format

  kickster97

  committed
  09241ee

• rebase in abstrace queue

  kickster97

  committed
  08a1963

• adapt for queue abstraction

  kickster97

  committed
  20343ca

• repain broken amqp specs

  kickster97

  committed
  06a68fa

• rename prefix validator to namevalidator and move valid_entity_name into it

  kickster97

  committed
  0a1f49d

• remove unnessecary allocation in #NameValidator.valid_prefix

  kickster97

  committed
  28650de

• cleanup ordering in connections js

  kickster97

  committed
  024ff9c

• remove sessions from vhost, redundant

  kickster97

  committed
  76ab2c0

• use default random instead of secure for client_id

  kickster97

  committed
  56829e9

• delete unreferences messages in retain store when building index

  kickster97

  committed
  dbc41b6

• move exchange into the mqtt namespace

  kickster97

  committed
  8b063ff

• use mqtt namespace MqttBindingKey->BindingKey

  kickster97

  committed
  809626a

• remove redundant return value

  kickster97

  committed
  d6c9d7b

• update name validator

  kickster97

  committed
  813c081

• move unacked_messagesapi logic to queue and overload method in session

  kickster97

  committed
  df2cb43

• format

  kickster97

  committed
  4b9be56

• update logs for name validation failures

  kickster97

  committed
  f7ac14d

• don't have risk of overwriting retain store msg files

  kickster97

  committed
  19272da

• ensure to remove file

  kickster97

  committed
  7e01510

• format

  kickster97

  committed
  84e548b

• replicate retain store, wip

  kickster97

  committed
  e71ab36

• add mqtts config + listener

  kickster97

  committed
  d3396cf

• format

  kickster97

  committed
  6d5ad0c

• replication spec works correctly

  kickster97

  committed
  f0ef2d2

• add mqtt_proxy for clustering client

  kickster97

  committed
  031aec7

• r+ needs file to exist before open

  kickster97

  committed
  e33d528

• format

  kickster97

  committed
  16e48be

• fix ameba failures

  kickster97

  committed
  1491120

• satisfy ameba for spec files

  kickster97

  committed
  4c3480b

• rename specfile with suffix

  kickster97

  committed
  068a174

• fix flaky wait_for

  kickster97

  committed
  dd1f110

• Use enum for protocol to get compile time validation

  

  spuun

  authored and

  kickster97

  committed
  ccde827

• Fix specs to use protocol enum

  

  spuun

  authored and

  kickster97

  committed
  aeeb4cb

• use short block notation

  kickster97

  committed
  cac1163

• fix mqtt exchange routing spec

  

  snichme

  authored and

  kickster97

  committed
  6b6188f

• remove comment

  

  snichme

  authored and

  kickster97

  committed
  71561ac

• scope fix

  

  snichme

  authored and

  kickster97

  committed
  9815c63

• Multi-vhost support

  

  spuun

  authored and

  kickster97

  committed
  1de72a1

• expand details tuple for consumer UI

  kickster97

  committed
  43bf65f

• no need to convert routing key

  kickster97

  committed
  ef2c7f3

• format

  kickster97

  committed
  6f0eedd

• handle unexpected close from client

  kickster97

  committed
  61a15e2

• connection_at for mqtt connections

  

  snichme

  authored and

  kickster97

  committed
  0525c76

• deliver packet not msg from session (#843)

  Show description for 131043d
  

  snichme

  authored and

  kickster97

  committed
  131043d

• truncate the previous content before you retain a message

  kickster97

  committed
  bf18a56

• safely overwrite retained messages

  kickster97

  committed
  9410a13

• Cant use constant as key in NamedTuple

  

  spuun

  authored and

  kickster97

  committed
  7ac09ab

• merge solutions for retain store

  kickster97

  committed
  cabf445

• general fixup after comments

  kickster97

  committed
  b29bc61

• format

  kickster97

  committed
  d19e4d1

• set flaky spec to pending

  kickster97

  committed
  1b87d0e

• just a test

  kickster97

  committed
  1af2f13

• just a test

  kickster97

  committed
  9345b85

• tmp: debug clustering_spec

  

  baelter

  authored and

  kickster97

  committed
  f097cc9

• finalize clustering spec

  kickster97

  committed
  69871d2

• use instance var for index file name

  kickster97

  committed
  1dc8cb6

Commits on Dec 2, 2024

• rescue argumenterror in deliver loop

  kickster97

  committed
  b6b1059

• format

  kickster97

  committed
  c67089d

Commits on Dec 3, 2024

• Fix mqtt unix listener (and some logging)

  spuun

  committed
  53854ce

• Prevent Channel::Closed error from being raised

  spuun

  committed
  88a2f28

Commits on Dec 10, 2024

• exception handling for mqtt default bindings

  kickster97

  committed
  7eecf47

• only allow selected policies to be applied for mqtt session

  kickster97

  committed
  d841337

• handle qos 2 at build_packet

  kickster97

  committed
  06162d9

Commits on Dec 11, 2024

• dont allow amqp queues or exchanges to bind to mqtt queues or exchanges

  kickster97

  committed
  56a71de

Commits on Dec 12, 2024

• forbidden to bind AMQP excahnges to the MQTT Session

  kickster97

  committed
  95be31f

• format

  kickster97

  committed
  d3d6cb1

Commits on Dec 13, 2024

• clean up review comments

  kickster97

  committed
  81ee5fd

• initialize @broekrs in server instead of in connection_factory

  kickster97

  committed
  2bbbcd9